网格综治管理定时任务

huanghongfa

2021-06-07 4531af97bd43242e879d4ba4d29d743777af56d9

网格综治管理定时任务

 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/grid/GridService.java

@@ -845,4 +845,11 @@
     */
    @PostMapping("/eventgridmembergpslog/add")
    R gridReportPosition(@RequestBody GridMemberPositionDTO memberPositionDTO);

    /**
     * 定时任务扫描网格员工作状态
     * @return  定时任务扫描结果
     */
    @PostMapping("/eventgridmemberwarnlog/judge")
    R timedTaskGridMember();
}

 springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/api/EventGridMemberWarnLogApi.java

@@ -80,4 +80,13 @@
        return eventGridMemberWarnLogService.eventGridMemberWarnLogDetails(id);
    };

    /**
     * 定时任务扫描网格员工作状态
     * @return  定时任务扫描结果
     */
    @PostMapping("/judge")
    public R timedTaskGridMember(){
        return eventGridMemberWarnLogService.timedTaskGridMember();
    }

}

 springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/model/dos/EventGridMemberGpsLogDO.java

@@ -70,4 +70,13 @@
     * 定位地址信息   列：position_address
     */
    private String positionAddress;

    /**
     * 位置信息状态（1、为判定2、正常3、是不正常）
     */
    public interface positionStation{
        int no = 1;
        int normal = 2;
        int abnormal = 3;
    }
}

 springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/EventGridMemberWarnLogService.java

@@ -60,5 +60,11 @@
     */
    R gridMemberWorkWarning(EventGridMemberWainDTO gridMemberWainDTO);

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


}

 springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventGridMemberWarnLogServiceImpl.java

@@ -1,5 +1,6 @@
package com.panzhihua.service_grid.service.impl;

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;
@@ -16,6 +17,7 @@

import javax.annotation.Resource;
import java.util.Date;
import java.util.List;

/**
 * @auther lyq
@@ -28,6 +30,10 @@

    @Resource
    private EventGridMemberWarnLogMapper eventGridMemberWarnLogMapper;
    @Resource
    private EventGridMemberGpsLogMapper eventGridMemberGpsLogMapper;
    @Resource
    private EventGridDataMapper eventGridDataMapper;
    /**
     * 新增网格员定时上报地理预警记录
     * @param eventGridMemberWarnLogAddDTO
@@ -108,4 +114,38 @@
        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 -> {
                //取出经纬度信息




            });
        }





        return R.ok();
    }

}

 springcloud_k8s_panzhihuazhihuishequ/timejob/src/main/java/com/panzhihua/timejob/jobhandler/GridMemberJobHandler.java

New file
@@ -0,0 +1,29 @@
package com.panzhihua.timejob.jobhandler;

import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.service.grid.GridService;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

/**
 * 综治管理定时任务
 */
@Slf4j
@Component
public class GridMemberJobHandler {

    @Resource
    private GridService gridService;

    @XxlJob("timedTaskGridMemberJobHandler")
    public ReturnT<String> timedTaskGridMemberJobHandler(String param) throws Exception {
        log.info("定时任务判断网格员是否在岗开始");
        R r=gridService.getGridMemberListsByGrid(null);
        log.info("执行结果【{}】",r.toString());
        return ReturnT.SUCCESS;
    }
}