定时统计本年履职任务完成情况

soc-modules/soc-modules-core/src/main/resources/mapper/board/CockpitMapper.xml

@@ -19,6 +19,25 @@
         and org_path like concat(#{orgPath},'%')
         GROUP BY org_id,org_path
     </select>
+
+    <select id="statisticOneOrgResumptionTask" resultType="com.xunmei.core.board.vo.web.ResumptionTaskStatisticVo">
+        SELECT
+            org_id,
+            org_path,
+            count( 0 ) AS task_total,
+            SUM( CASE `status` WHEN 3 THEN 1 ELSE 0 END ) AS completed_count
+        FROM
+            core_resumption r
+            inner join core_resumption_plan p on r.plan_id=p.id and p.plan_cycle &lt; 5 and p.plan_exec in (2,3,4)
+        WHERE
+            (
+               #{startDate}    <![CDATA[<=]]> r.plan_end_time
+               and #{endDate} >= r.plan_end_time
+            )
+          and r.org_id = #{orgId}
+    </select>
+
+
     <!--    <select id="safetyCheck" resultType="com.xunmei.core.board.vo.web.TaskStatisticVo">-->
     <!--        SELECT-->
     <!--        org_id,-->

soc-modules/soc-modules-job/src/main/java/com/xunmei/job/task/CoreResumptionTask.java

@@ -48,4 +48,13 @@ public class CoreResumptionTask {
         AjaxResult result = remoteResumptionTaskService.buildPdf();
         log.info("生成pdf，当前任务 时间：{}，结果：{}", new Date(), JSON.toJSONString(result));
     }
+
+    /**
+     * 每天定时计算每个机构本年内的履职任务数量和完成数量，供驾驶舱使用
+     */
+    public void statisticTaskCount() {
+        log.info("开始统计机构履职任务数量 时间：{}", new Date());
+        R<Boolean> result = remoteResumptionTaskService.statisticTaskCount();
+        log.info("统计机构履职任务数量完成，当前任务 时间：{}，结果：{}", new Date(), JSON.toJSONString(result));
+    }
 }