package com.panzhihua.service_grid.service.impl;

import java.util.Date;
import java.util.List;

import javax.annotation.Resource;

import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.panzhihua.common.model.dtos.grid.*;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.grid.EventGridMemberWarnLogDetailsVO;
import com.panzhihua.common.model.vos.grid.EventGridMemberWarnLogVO;
import com.panzhihua.common.model.vos.grid.LatLngVO;
import com.panzhihua.common.utlis.LngLatUtils;
import com.panzhihua.common.utlis.StringUtils;
import com.panzhihua.service_grid.dao.EventGridDataMapper;
import com.panzhihua.service_grid.dao.EventGridMemberGpsLogMapper;
import com.panzhihua.service_grid.dao.EventGridMemberRelationMapper;
import com.panzhihua.service_grid.dao.EventGridMemberWarnLogMapper;
import com.panzhihua.service_grid.model.dos.EventGridDataDO;
import com.panzhihua.service_grid.model.dos.EventGridMemberGpsLogDO;
import com.panzhihua.service_grid.model.dos.EventGridMemberRelationDO;
import com.panzhihua.service_grid.model.dos.EventGridMemberWarnLogDO;
import com.panzhihua.service_grid.service.EventGridMemberWarnLogService;

import lombok.extern.slf4j.Slf4j;

/**
 * @auther lyq
 * @create 2021-04-14 15:03:01
 * @describe 订单表服务实现类
 */
@Slf4j
@Service
public class EventGridMemberWarnLogServiceImpl extends
    ServiceImpl<EventGridMemberWarnLogMapper, EventGridMemberWarnLogDO> implements EventGridMemberWarnLogService {

    @Resource
    private EventGridMemberWarnLogMapper eventGridMemberWarnLogMapper;
    @Resource
    private EventGridMemberGpsLogMapper eventGridMemberGpsLogMapper;
    @Resource
    private EventGridDataMapper eventGridDataMapper;
    @Resource
    private EventGridMemberRelationMapper eventGridMemberRelationMapper;

    /**
     * 新增网格员定时上报地理预警记录
     * 
     * @param eventGridMemberWarnLogAddDTO
     * @return 新增结果
     */
    public R add(EventGridMemberWarnLogAddDTO eventGridMemberWarnLogAddDTO) {
        EventGridMemberWarnLogDO eventGridMemberWarnLogDO = new EventGridMemberWarnLogDO();
        BeanUtils.copyProperties(eventGridMemberWarnLogAddDTO, eventGridMemberWarnLogDO);
        eventGridMemberWarnLogDO.setCreateAt(new Date());
        if (eventGridMemberWarnLogMapper.insert(eventGridMemberWarnLogDO) > 0) {
            return R.ok();
        }
        return R.fail();
    }

    /**
     * 修改网格员定时上报地理预警记录
     * 
     * @param eventGridMemberWarnLogEditDTO
     * @return 维护结果
     */
    public R edit(EventGridMemberWarnLogEditDTO eventGridMemberWarnLogEditDTO) {
        EventGridMemberWarnLogDO eventGridMemberWarnLogDO = new EventGridMemberWarnLogDO();
        BeanUtils.copyProperties(eventGridMemberWarnLogEditDTO, eventGridMemberWarnLogDO);
        // eventGridMemberWarnLogDO.setUpdateAt(new Date());
        if (eventGridMemberWarnLogMapper.updateById(eventGridMemberWarnLogDO) > 0) {
            return R.ok();
        }
        return R.fail();
    }

    /**
     * 分页查找网格员定时上报地理预警记录
     * 
     * @param pageEventGridMemberWarnLogDTO
     * @return 维护结果
     */
    public R<IPage<EventGridMemberWarnLogVO>> query(PageEventGridMemberWarnLogDTO pageEventGridMemberWarnLogDTO) {
        Page page = new Page(1, 10);
        if (pageEventGridMemberWarnLogDTO.getPageNum() != null) {
            page.setCurrent(pageEventGridMemberWarnLogDTO.getPageNum());
        }
        if (pageEventGridMemberWarnLogDTO.getPageSize() != null) {
            page.setSize(pageEventGridMemberWarnLogDTO.getPageSize());
        }
        return R.ok(eventGridMemberWarnLogMapper.findByPage(page, pageEventGridMemberWarnLogDTO));
    }

    /**
     * 删除网格员定时上报地理预警记录
     * 
     * @param EventGridMemberWarnLogDeleteDTO
     * @return 平台用户信息
     */
    public R delete(EventGridMemberWarnLogDeleteDTO EventGridMemberWarnLogDeleteDTO) {
        return R.fail();
    }

    /**
     * 查询网格员定时上报地理预警记录详细信息
     * 
     * @param id
     *            网格员定时上报地理预警记录 id
     * @return 查找结果
     */
    public R<EventGridMemberWarnLogDetailsVO> eventGridMemberWarnLogDetails(Long id) {
        EventGridMemberWarnLogDO eventGridMemberWarnLogDO = eventGridMemberWarnLogMapper.selectById(id);
        if (eventGridMemberWarnLogDO != null) {
            EventGridMemberWarnLogDetailsVO eventGridMemberWarnLogDetailsVO = new EventGridMemberWarnLogDetailsVO();
            BeanUtils.copyProperties(eventGridMemberWarnLogDO, eventGridMemberWarnLogDetailsVO);
            return R.ok(eventGridMemberWarnLogDetailsVO);
        }
        return R.fail();
    }

    /**
     * 后台获取网格员预警记录
     * 
     * @param gridMemberWainDTO
     *            请求参数
     * @return 预警记录
     */
    @Override
    public R gridMemberWorkWarning(EventGridMemberWainDTO gridMemberWainDTO) {
        return R.ok(this.baseMapper.gridMemberWorkWarning(
            new Page(gridMemberWainDTO.getPageNum(), gridMemberWainDTO.getPageSize()), gridMemberWainDTO));
    }

    /**
     * 定时任务扫描网格员工作状态
     * 
     * @return 定时任务扫描结果
     */
    @Override
    public R timedTaskGridMember() {

        // 查询所有网格数据
        List<EventGridDataDO> gridDataDOList = eventGridDataMapper.selectList(
            new QueryWrapper<EventGridDataDO>().lambda().eq(EventGridDataDO::getType, EventGridDataDO.type.sq));
        if (gridDataDOList.isEmpty()) {
            return R.fail("未查询到网格数据");
        }

        List<EventGridMemberGpsLogDO> memberGpsLogDOS =
            eventGridMemberGpsLogMapper.selectList(new QueryWrapper<EventGridMemberGpsLogDO>().lambda()
                .eq(EventGridMemberGpsLogDO::getPositionStation, EventGridMemberGpsLogDO.positionStation.no));
        if (!memberGpsLogDOS.isEmpty()) {
            memberGpsLogDOS.forEach(memberGpsLog -> {
                if (StringUtils.isNotEmpty(memberGpsLog.getLngLat())) {
                    String[] lngLat = memberGpsLog.getLngLat().split(",");
                    Double lat = Double.valueOf(lngLat[0]);
                    Double lng = Double.valueOf(lngLat[1]);
                    // 遍历所有网格信息匹配网格员的坐标点是否在网格内
                    Boolean isOk = true;

                    Integer workStatus = 2;

                    for (EventGridDataDO gridData : gridDataDOList) {
                        if (StringUtils.isNotEmpty(gridData.getData())) {
                            List<LatLngVO> latLngList = LngLatUtils.getLatLngFromText(gridData.getData());
                            if (LngLatUtils.isInPolygon(latLngList, lng, lat)) {// 匹配通过
                                // 判断当前网格员与此网格是否有关系
                                Integer count = eventGridMemberRelationMapper
                                    .selectCount(new QueryWrapper<EventGridMemberRelationDO>().lambda()
                                        .eq(EventGridMemberRelationDO::getGridMemberId, memberGpsLog.getGridMemberId())
                                        .eq(EventGridMemberRelationDO::getGridId, memberGpsLog.getGridId()));
                                if (count > 0) {
                                    isOk = false;
                                    workStatus = 1;
                                    memberGpsLog.setGridId(gridData.getId());
                                    memberGpsLog.setGridCommunityId(gridData.getGridCommunityId());
                                    memberGpsLog.setGridStreetId(gridData.getGridStreetId());
                                    memberGpsLog.setGridName(gridData.getGridName());
                                    memberGpsLog.setPositionStation(EventGridMemberGpsLogDO.positionStation.normal);
                                    eventGridMemberGpsLogMapper.updateById(memberGpsLog);
                                    // 修改用户工作状态
                                    this.baseMapper.setUserWorkStatus(memberGpsLog.getGridMemberId(), workStatus);
                                    break;
                                }
                            }
                        }
                    }
                    if (isOk) {// 此网格员脱岗
                        memberGpsLog.setPositionStation(EventGridMemberGpsLogDO.positionStation.abnormal);
                        workStatus = 2;
                        // 新增网格员预警信息
                        EventGridMemberWarnLogDO memberWarnLogDO = new EventGridMemberWarnLogDO();
                        BeanUtils.copyProperties(memberGpsLog, memberWarnLogDO);
                        memberWarnLogDO.setId(null);
                        memberWarnLogDO.setContent("工作时间未在网格内预警");
                        memberWarnLogDO.setHappenAt(memberGpsLog.getCreateAt());
                        this.baseMapper.insert(memberWarnLogDO);

                        eventGridMemberGpsLogMapper.updateById(memberGpsLog);
                        // 修改用户工作状态
                        this.baseMapper.setUserWorkStatus(memberGpsLog.getGridMemberId(), workStatus);
                    }
                }
            });
        }
        return R.ok();
    }

}