网格员巡查统计定时任务

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/feign/DataStatisticalOpenFeignClient.java

@@ -6,6 +6,7 @@ import com.epmet.dto.StatsFormDTO;
 import com.epmet.dto.extract.form.ExtractIndexFormDTO;
 import com.epmet.dto.extract.form.ExtractOriginFormDTO;
 import com.epmet.dto.extract.form.ExtractScreenFormDTO;
+import com.epmet.dto.extract.form.StaffPatrolStatsFormDTO;
 import com.epmet.dto.group.form.GroupStatsFormDTO;
 import com.epmet.dto.screen.form.InitCustomerIndexForm;
 import com.epmet.dto.stats.form.CustomerIdAndDateIdFormDTO;
@@ -256,4 +257,14 @@ public interface DataStatisticalOpenFeignClient {
     @PostMapping("/data/stats/vanguard/gridvanguardstats")
     Result gridVanguardStats(@RequestBody StatsFormDTO formDTO);
 
+    /**
+     * desc: 网格员巡查统计初始化及校正
+     *
+     * @param formDTO
+     * @return com.epmet.commons.tools.utils.Result
+     * @author LiuJanJun
+     * @date 2021/7/2 3:04 下午
+     */
+    @PostMapping("/data/stats/bizData/stats/patrol")
+    Result staffPatrolStats(@RequestBody StaffPatrolStatsFormDTO formDTO);
 }

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/feign/impl/DataStatisticalOpenFeignClientFallBack.java

@@ -7,6 +7,7 @@ import com.epmet.dto.StatsFormDTO;
 import com.epmet.dto.extract.form.ExtractIndexFormDTO;
 import com.epmet.dto.extract.form.ExtractOriginFormDTO;
 import com.epmet.dto.extract.form.ExtractScreenFormDTO;
+import com.epmet.dto.extract.form.StaffPatrolStatsFormDTO;
 import com.epmet.dto.group.form.GroupStatsFormDTO;
 import com.epmet.dto.screen.form.InitCustomerIndexForm;
 import com.epmet.dto.stats.form.CustomerIdAndDateIdFormDTO;
@@ -256,4 +257,9 @@ public class DataStatisticalOpenFeignClientFallBack implements DataStatisticalOp
     public Result gridVanguardStats(StatsFormDTO formDTO) {
         return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "gridVanguardStats", formDTO);
     }
+
+    @Override
+    public Result staffPatrolStats(StaffPatrolStatsFormDTO formDTO) {
+        return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "staffPatrolStats", formDTO);
+    }
 }

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/biz/impl/BizDataStatsServiceImpl.java

@@ -31,7 +31,7 @@ import java.util.Map;
 import java.util.stream.Collectors;
 
 /**
- * desc:【天】网格员巡查统计
+ * desc:【天】业务库里的统计
  *
  * @author: LiuJanJun
  * @date: 2021/6/29 3:08 下午

epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/BizDataStatsService.java

@@ -0,0 +1,10 @@
+package com.epmet.service;
+
+import com.epmet.commons.tools.utils.Result;
+import com.epmet.dto.extract.form.StaffPatrolStatsFormDTO;
+
+public interface BizDataStatsService {
+
+    Result exeStaffPatrolStats(StaffPatrolStatsFormDTO formDTO);
+
+}

epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/service/impl/BizDataStatsServiceImpl.java

@@ -0,0 +1,23 @@
+package com.epmet.service.impl;
+
+import com.epmet.commons.tools.utils.Result;
+import com.epmet.dto.extract.form.StaffPatrolStatsFormDTO;
+import com.epmet.feign.DataStatisticalOpenFeignClient;
+import com.epmet.service.BizDataStatsService;
+import org.springframework.beans.factory.annotation.Autowired;
+
+/**
+ * desc:业务库 数据统计服务实现
+ *
+ * @author: LiuJanJun
+ * @date: 2021/7/2 2:58 下午
+ * @version: 1.0
+ */
+public class BizDataStatsServiceImpl implements BizDataStatsService {
+    @Autowired
+    private DataStatisticalOpenFeignClient feignClient;
+    @Override
+    public Result exeStaffPatrolStats(StaffPatrolStatsFormDTO formDTO) {
+        return feignClient.staffPatrolStats(formDTO);
+    }
+}

epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/StaffPatrolStatsTask.java

@@ -0,0 +1,34 @@
+package com.epmet.task;
+
+import com.alibaba.fastjson.JSON;
+import com.epmet.commons.tools.utils.Result;
+import com.epmet.dto.extract.form.StaffPatrolStatsFormDTO;
+import com.epmet.service.BizDataStatsService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author zhaoqifeng
+ * @dscription
+ * @date 2020/6/23 14:36
+ */
+@Slf4j
+@Component("dimInitTask")
+public class StaffPatrolStatsTask implements ITask {
+
+	@Autowired
+	private BizDataStatsService bizDataStatsService;
+
+	@Override
+	public void run(String params) {
+		log.debug("DimInitTask定时任务正在执行，参数为：{}", params);
+		StaffPatrolStatsFormDTO formDTO = JSON.parseObject(params, StaffPatrolStatsFormDTO.class);
+		Result result = bizDataStatsService.exeStaffPatrolStats(formDTO);
+		if (result.success()){
+			log.debug("StaffPatrolStatsTask定时任务正在执行定时任务执行成功");
+		}else {
+			log.debug("StaffPatrolStatsTask定时任务正在执行定时任务执行失败:" + result.getMsg());
+		}
+	}
+}