水厂运营分析 工单统计

 package com.skua.modules.dataAnalysis.controller;
 package com.skua.modules.dataAnalysis.controller;
 
 
+import cn.hutool.core.bean.BeanUtil;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.skua.common.constant.BusinessConstant;
 import com.skua.core.api.vo.Result;
 import com.skua.core.api.vo.Result;
+import com.skua.core.context.SpringContextUtils;
 import com.skua.modules.dataAnalysis.service.IFactoryCenterService;
 import com.skua.modules.dataAnalysis.service.IFactoryCenterService;
 import com.skua.modules.dataAnalysis.service.IFactoryOperateCenterService;
 import com.skua.modules.dataAnalysis.service.IFactoryOperateCenterService;
 import com.skua.modules.dataAnalysis.vo.*;
 import com.skua.modules.dataAnalysis.vo.*;
+import com.skua.modules.flow.business.service.FlowBusinessService;
+import com.skua.modules.flow.core.entity.BladeFlow;
+import com.skua.modules.flow.support.Condition;
+import com.skua.modules.flow.support.Query;
+import com.skua.tool.util.DateUtils;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
 import lombok.extern.slf4j.Slf4j;
@@ -25,6 +34,9 @@ public class FactoryOperateCenterController {
     @Autowired
     @Autowired
     private IFactoryOperateCenterService factoryOperateCenterService;
     private IFactoryOperateCenterService factoryOperateCenterService;
 
 
+    @Autowired
+    private FlowBusinessService flowBusinessService;
+
     @ApiOperation(value="厂区统计数据", notes="厂区统计数据")
     @ApiOperation(value="厂区统计数据", notes="厂区统计数据")
     @GetMapping(value = "/getData")
     @GetMapping(value = "/getData")
     public Result<Map<String,Object>> getData(String departId,String month) {
     public Result<Map<String,Object>> getData(String departId,String month) {
@@ -100,8 +112,39 @@ public class FactoryOperateCenterController {
     @GetMapping(value = "/flow")
     @GetMapping(value = "/flow")
     public Result<Map<String,Object>> getFlowData(String departId,String month) {
     public Result<Map<String,Object>> getFlowData(String departId,String month) {
         Result<Map<String,Object>> result = new Result<Map<String,Object>>();
         Result<Map<String,Object>> result = new Result<Map<String,Object>>();
-        Map<String,Object> map = factoryOperateCenterService.getFlowData(departId,month);
+//        Map<String,Object> map = factoryOperateCenterService.getFlowData(departId,month);
+        WorkAnalysisController workAnalysisController = (WorkAnalysisController) SpringContextUtils.getBean(WorkAnalysisController.class);
+        int days = DateUtils.lengthOfSomeMonth(Integer.parseInt(month.split("-")[0]), Integer.parseInt(month.split("-")[1]));
+        String startTime = month + "-01" + BusinessConstant.startTimeSuffix;
+        String endTime = month + "-" + days + BusinessConstant.endTimeSuffix;
+        Result<List<ProcessProgressVO>> voResult = workAnalysisController.analysisByProcessProgress(1, departId, 1, startTime.substring(0, 10), endTime.substring(0 ,10));
+        int ing = 0, no = 0, yes = 0, total = 0;
+        if (!voResult.getResult().isEmpty()) {
+            Map<String, Object> tmpMap = BeanUtil.beanToMap(voResult.getResult().get(0), false, true);
+            for (String key: tmpMap.keySet()) {
+                if (key.endsWith("TotalNum")) {
+                    total += Integer.parseInt(tmpMap.get(key).toString());
+                } else if (key.endsWith("HandleNum")) {
+                    yes += Integer.parseInt(tmpMap.get(key).toString());
+                }
+            }
+        }
+        // 查询工作流待签收
+        BladeFlow bladeFlow = new BladeFlow();
+        bladeFlow.setBeginDate(DateUtils.strToDate(startTime, BusinessConstant.dateFormat));
+        bladeFlow.setEndDate(DateUtils.strToDate(endTime, BusinessConstant.dateFormat));
+        Query query = new Query();
+        query.setCurrent(1);
+        query.setSize(10000);
+        IPage<BladeFlow> claimPage = this.flowBusinessService.selectClaimPage(Condition.getPage(query), bladeFlow);
+        no = claimPage.getRecords().size();
         result.setSuccess(true);
         result.setSuccess(true);
+
+        Map<String, Object> map = new HashMap<>();
+        map.put("no", no);
+        map.put("ing", total - yes - no);
+        map.put("yes", yes);
+        map.put("total", total);
         result.setResult(map);
         result.setResult(map);
         return result;
         return result;
     }
     }