子公司工单分布按来源统计

wangqian
1 parent 4c9efe7f
Showing 6 changed files with 157 additions and 4 deletions
urbanops-module-garden/src/main/java/com/zteits/urbanops/module/garden/controller/admin/homepage/MaintainSummaryController.java
urbanops-module-garden/src/main/java/com/zteits/urbanops/module/garden/controller/admin/homepage/vo/CommitWorkOrderSourceRespVo.java
urbanops-module-garden/src/main/java/com/zteits/urbanops/module/garden/dal/mysql/homepage/HomepageSummaryMapper.java
urbanops-module-garden/src/main/java/com/zteits/urbanops/module/garden/service/homepage/MaintainSummaryService.java
urbanops-module-garden/src/main/java/com/zteits/urbanops/module/garden/service/homepage/MaintainSummaryServiceImpl.java
urbanops-module-garden/src/main/resources/mapper/homepage/HomepageSummaryMapper.xml
@@ -2,6 +2,7 @@ package com.zteits.urbanops.module.garden.controller.admin.homepage;
 import com.zteits.urbanops.framework.common.pojo.CommonResult;
 import com.zteits.urbanops.module.garden.controller.admin.homepage.vo.CommitWorkOrderRespVo;
+import com.zteits.urbanops.module.garden.controller.admin.homepage.vo.CommitWorkOrderSourceRespVo;
 import com.zteits.urbanops.module.garden.controller.admin.homepage.vo.HomePageSummaryReqVO;
 import com.zteits.urbanops.module.garden.service.homepage.MaintainSummaryService;
 import io.swagger.v3.oas.annotations.Operation;
@@ -48,6 +49,12 @@ public class MaintainSummaryController {
     public CommonResult<Map<String, CommitWorkOrderRespVo>> getWorkOrderDistribution(@Valid @RequestBody HomePageSummaryReqVO req) {
         return success(maintainSummaryService.getWorkOrderDistribution(req));
     }
+
+    @PostMapping("/getWorkOrderDistributionBySource")
+    @Operation(summary = "子公司工单分布")
+    public CommonResult<Map<String, CommitWorkOrderSourceRespVo>> getWorkOrderDistributionBySource(@Valid @RequestBody HomePageSummaryReqVO req) {
+        return success(maintainSummaryService.getWorkOrderDistributionBySource(req));
+    }
     @PostMapping("/getWorkOrderHeatmap")
     @Operation(summary = "工单热力图")
     public CommonResult<List<Map<String, Object>>> getWorkOrderHeatmap() {
+package com.zteits.urbanops.module.garden.controller.admin.homepage.vo;
+
+import lombok.Data;
+
+/**
+ * @Classname CommitWorkOrderRespVo
+ * @Description 子公司分布返回
+ * @Date 2025/12/30 22:01
+ * @Created by wangqian
+ */
+@Data
+public class CommitWorkOrderSourceRespVo {
+
+    private Long companyId;
+
+    private String companyName;
+    //巡查
+    private Integer patrolCount;
+    //
+    private Integer touristResidentCount;
+    //12345
+    private Integer otherCount;
+    //网格
+    private Integer gridCount;
+    //大区经理
+    private Integer regionalManagerCount;
+    //ai
+    private Integer aiCount;
+
+}
@@ -3,6 +3,7 @@ package com.zteits.urbanops.module.garden.dal.mysql.homepage;
 import com.zteits.urbanops.framework.mybatis.core.mapper.BaseMapperX;
 import com.zteits.urbanops.module.garden.controller.admin.homepage.vo.CommitTaskStatisticsRespVo;
 import com.zteits.urbanops.module.garden.controller.admin.homepage.vo.CommitWorkOrderRespVo;
+import com.zteits.urbanops.module.garden.controller.admin.homepage.vo.CommitWorkOrderSourceRespVo;
 import com.zteits.urbanops.module.garden.controller.admin.homepage.vo.WorkOrderTrendRespVo;
 import com.zteits.urbanops.module.garden.dal.dataobject.departmentcost.DepartmentCostDO;
 import org.apache.ibatis.annotations.Mapper;
@@ -77,6 +78,13 @@ public interface HomepageSummaryMapper  extends BaseMapperX&lt;DepartmentCostDO&gt; {
     List<CommitWorkOrderRespVo> countWorkOrderDistribution(@Param("companyId") Long companyId, @Param("beginTime") String beginTime, @Param("endTime") String endTime);
     /**
      * @Author wangqian
+     * @Description 公司+问题来源
+     * @Date 2025/12/30 21:52
+     */
+    List<CommitWorkOrderSourceRespVo> countWorkOrderDistributionBySource(@Param("companyId") Long companyId, @Param("beginTime") String beginTime, @Param("endTime") String endTime);
+
+    /**
+     * @Author wangqian
      * @Description 热力图
      * @Date 2025/12/31 14:29
      */
 package com.zteits.urbanops.module.garden.service.homepage;
 import com.zteits.urbanops.module.garden.controller.admin.homepage.vo.CommitWorkOrderRespVo;
+import com.zteits.urbanops.module.garden.controller.admin.homepage.vo.CommitWorkOrderSourceRespVo;
 import com.zteits.urbanops.module.garden.controller.admin.homepage.vo.HomePageSummaryReqVO;
 import java.util.List;
@@ -37,6 +38,14 @@ public interface MaintainSummaryService {
      * @Param req
      */
     Map<String, CommitWorkOrderRespVo> getWorkOrderDistribution(HomePageSummaryReqVO req);
+
+    /**
+     * @Author wangqian
+     * @Description 按公司、问题来源统计
+     * @Date 2025/12/30 21:50
+     * @Param req
+     */
+    Map<String, CommitWorkOrderSourceRespVo> getWorkOrderDistributionBySource(HomePageSummaryReqVO req);
     /**
      * @Author wangqian
      * @Description 工单热量图
@@ -5,10 +5,7 @@ import cn.hutool.core.util.ObjectUtil;
 import com.zteits.urbanops.framework.common.biz.system.dict.dto.DictDataRespDTO;
 import com.zteits.urbanops.framework.common.util.object.BeanUtils;
 import com.zteits.urbanops.framework.security.core.util.SecurityFrameworkUtils;
-import com.zteits.urbanops.module.garden.controller.admin.homepage.vo.CommitTaskStatisticsRespVo;
-import com.zteits.urbanops.module.garden.controller.admin.homepage.vo.CommitWorkOrderRespVo;
-import com.zteits.urbanops.module.garden.controller.admin.homepage.vo.HomePageSummaryReqVO;
-import com.zteits.urbanops.module.garden.controller.admin.homepage.vo.WorkOrderTrendRespVo;
+import com.zteits.urbanops.module.garden.controller.admin.homepage.vo.*;
 import com.zteits.urbanops.module.garden.dal.mysql.homepage.HomepageSummaryMapper;
 import com.zteits.urbanops.module.garden.enums.CommonConstants;
 import com.zteits.urbanops.module.system.api.dept.DeptApi;
@@ -345,6 +342,76 @@ public class MaintainSummaryServiceImpl implements MaintainSummaryService {
         return orderedMap;
     }
+
+    @Override
+    public Map<String, CommitWorkOrderSourceRespVo> getWorkOrderDistributionBySource(HomePageSummaryReqVO req) {
+        Long companyId = SecurityFrameworkUtils.getLoginUserDeptId();
+        if(null == companyId || companyId == 0L || companyId == 100L){
+            companyId = null;
+        }
+        Map<String, CommitWorkOrderSourceRespVo> respMap = new HashMap<>();
+        //初始化对象
+        List<CommitWorkOrderSourceRespVo> respList = new ArrayList<>();
+        List<DeptRespVO> deptRespVOList =  deptApi.getCompanyList();
+        for (DeptRespVO deptRespVO : deptRespVOList) {
+            CommitWorkOrderSourceRespVo vo = new CommitWorkOrderSourceRespVo();
+            vo.setCompanyId(deptRespVO.getId());
+            vo.setCompanyName(deptRespVO.getName());
+            vo.setPatrolCount(0);
+            vo.setTouristResidentCount(0);
+            vo.setGridCount(0);
+            vo.setOtherCount(0);
+            vo.setAiCount(0);
+            vo.setRegionalManagerCount(0);
+            respList.add(vo);
+        }
+
+        List<CommitWorkOrderSourceRespVo> countList = homepageSummaryMapper.countWorkOrderDistributionBySource(companyId,req.getBeginTime(), req.getEndTime());
+        Map<Long, CommitWorkOrderSourceRespVo> companyIdMap = new HashMap<>();
+        if (CollectionUtils.isNotEmpty(countList)) {
+            companyIdMap = countList.stream()
+                    .collect(Collectors.toMap(
+                            CommitWorkOrderSourceRespVo::getCompanyId,
+                            item -> item,
+                            (existing, newValue) -> existing
+                    ));
+        }
+        for (CommitWorkOrderSourceRespVo respVo : respList) {
+            if (!companyIdMap.isEmpty()) {
+                CommitWorkOrderSourceRespVo vo = companyIdMap.get(respVo.getCompanyId());
+                if(vo != null) {
+                    respVo.setPatrolCount(vo.getPatrolCount());
+                    respVo.setTouristResidentCount(vo.getTouristResidentCount());
+                    respVo.setGridCount(vo.getGridCount());
+                    respVo.setAiCount(vo.getAiCount());
+                    respVo.setOtherCount(vo.getOtherCount());
+                    respVo.setRegionalManagerCount(vo.getRegionalManagerCount());
+                }
+            }
+        }
+        // 排序
+        String[] companyNames = {"蓟城广安", "蓟城德胜", "西城园林", "三海投资", "绿美园林"};
+        Map<String, Integer> companyIndexMap = new HashMap<>();
+        for (int i = 0; i < companyNames.length; i++) {
+            companyIndexMap.put(companyNames[i], i);
+        }
+        List<CommitWorkOrderSourceRespVo> sortedList = respList.stream()
+                // 过滤：仅保留companyNames中存在的单位
+                .filter(item -> companyIndexMap.containsKey(item.getCompanyName()))
+                // 按预定义顺序排序
+                .sorted(Comparator.comparing(item -> companyIndexMap.get(item.getCompanyName())))
+                .collect(Collectors.toList());
+
+        Map<String, CommitWorkOrderSourceRespVo> orderedMap = sortedList.stream()
+                .collect(Collectors.toMap(
+                        CommitWorkOrderSourceRespVo::getCompanyName,
+                        Function.identity(),
+                        (existing, replacement) -> existing,
+                        LinkedHashMap::new
+                ));
+
+        return orderedMap;
+    }
     /**
      * @Author wangqian
      * @Description 热力图
@@ -205,6 +205,38 @@
         GROUP BY
          t.worker_company_id
     </select>
+    <select id="countWorkOrderDistributionBySource" resultType="com.zteits.urbanops.module.garden.controller.admin.homepage.vo.CommitWorkOrderSourceRespVo">
+        SELECT
+        t.worker_company_id AS companyId,
+        -- source_id=1：巡查工单
+        SUM(CASE WHEN t.source_id = 1 THEN 1 ELSE 0 END) AS patrolCount,
+        -- source_id=2：游客居民工单
+        SUM(CASE WHEN t.source_id = 2 THEN 1 ELSE 0 END) AS touristResidentCount,
+        -- source_id=3：12345工单
+        SUM(CASE WHEN t.source_id = 3 THEN 1 ELSE 0 END) AS otherCount,
+        -- source_id=4：网格工单
+        SUM(CASE WHEN t.source_id = 4 THEN 1 ELSE 0 END) AS gridCount,
+        -- source_id=5：大区经理工单
+        SUM(CASE WHEN t.source_id = 5 THEN 1 ELSE 0 END) AS regionalManagerCount,
+        -- source_id=6：AI工单
+        SUM(CASE WHEN t.source_id = 6 THEN 1 ELSE 0 END) AS aiCount
+        FROM
+        workorder_main_info t
+        <where>
+            deleted = 0
+            <if test="companyId != null">
+                and t.worker_company_id = #{companyId}
+            </if>
+            <if test="beginTime != null and beginTime != ''">
+                AND t.create_time >= #{beginTime}
+            </if>
+            <if test="endTime != null and endTime != ''">
+                AND t.create_time &lt; #{endTime}
+            </if>
+        </where>
+        GROUP BY
+        t.worker_company_id
+    </select>
     <!--热量图-->
     <select id="countWorkOrderHeatmap"  resultType="java.util.Map" >
         SELECT