feat(garden): 添加个人历史完成率配置和个人任务效率统计功能

- 在DictTypeConstants中新增COMPLETION_RATE_CONFIG字典类型用于个人历史完成率配置 - 在TaskDistanceSortRespVO中添加historyCompletionRate字段用于存储个人历史完成率 - 在UserTaskEfficiencyDO中添加historyCompletionRate字段用于存储个人历史完成率 - 在HomepageSummaryServiceImpl的多个方法中加载效率数据并设置个人历史完成率 - 在TaskEfficiencyCalculateJob中实现个人历史完成率计算逻辑 - 在UserTaskEfficiencyMapper中添加statHistoryTotalCount查询方法 - 在MyBatis映射文件中添加统计用户6个月历史任务总量的SQL - 在RoadApiImpl中为getRoadInfoById方法禁用数据权限注解 - 将应用环境配置从dev切换到prod模式

feat(garden): 添加个人历史完成率配置和个人任务效率统计功能
- 在DictTypeConstants中新增COMPLETION_RATE_CONFIG字典类型用于个人历史完成率配置 - 在TaskDistanceSortRespVO中添加historyCompletionRate字段用于存储个人历史完成率 - 在UserTaskEfficiencyDO中添加historyCompletionRate字段用于存储个人历史完成率 - 在HomepageSummaryServiceImpl的多个方法中加载效率数据并设置个人历史完成率 - 在TaskEfficiencyCalculateJob中实现个人历史完成率计算逻辑 - 在UserTaskEfficiencyMapper中添加statHistoryTotalCount查询方法 - 在MyBatis映射文件中添加统计用户6个月历史任务总量的SQL - 在RoadApiImpl中为getRoadInfoById方法禁用数据权限注解 - 将应用环境配置从dev切换到prod模式
王彪总
1 parent 285d3e4e
Showing 9 changed files with 94 additions and 11 deletions
urbanops-module-garden/src/main/java/com/zteits/urbanops/module/garden/api/road/RoadApiImpl.java
urbanops-module-garden/src/main/java/com/zteits/urbanops/module/garden/controller/app/homepage/vo/TaskDistanceSortRespVO.java
urbanops-module-garden/src/main/java/com/zteits/urbanops/module/garden/dal/dataobject/UserTaskEfficiencyDO.java
urbanops-module-garden/src/main/java/com/zteits/urbanops/module/garden/dal/mysql/UserTaskEfficiencyMapper.java
urbanops-module-garden/src/main/java/com/zteits/urbanops/module/garden/job/TaskEfficiencyCalculateJob.java
urbanops-module-garden/src/main/java/com/zteits/urbanops/module/garden/service/homepage/HomepageSummaryServiceImpl.java
urbanops-module-garden/src/main/resources/mapper/UserTaskEfficiencyMapper.xml
urbanops-module-system/src/main/java/com/zteits/urbanops/module/system/enums/DictTypeConstants.java
urbanops-server/src/main/resources/application.yaml
@@ -5,6 +5,7 @@ import cn.hutool.json.JSONUtil;
 import com.alibaba.fastjson.JSON;
 import com.zteits.urbanops.framework.common.util.http.HttpUtils;
 import com.zteits.urbanops.framework.common.util.object.BeanUtils;
+import com.zteits.urbanops.framework.datapermission.core.annotation.DataPermission;
 import com.zteits.urbanops.module.garden.controller.admin.road.vo.RoadRespVO;
 import com.zteits.urbanops.module.garden.dto.road.RoadReqDTO;
 import com.zteits.urbanops.module.garden.dto.road.RoadRespDTO;
@@ -69,6 +70,7 @@ public class RoadApiImpl implements RoadApi {
     }
  
     @Override
+    @DataPermission(enable = false)
     public RoadStreetRespDTO getRoadInfoById(String id) {
         RoadRespVO roadRespVO = roadService.getUniqueRoad(Long.parseLong(id));
         if(null == roadRespVO){
@@ -55,4 +55,7 @@ public class TaskDistanceSortRespVO extends TaskDetailsRspVo {
  
     /** 班组平均完成时长（分钟） */
     private BigDecimal teamAvgMinutes;
+
+    /** 个人历史完成率 = 6个月内已完成 / 6个月内总任务数 */
+    private BigDecimal historyCompletionRate;
 }
@@ -53,6 +53,9 @@ public class UserTaskEfficiencyDO extends BaseDO {
     /** 效率比 = teamAvg / userAvg */
     private BigDecimal efficiencyRatio;
  
+    /** 个人历史完成率 = 6个月内已完成 / 6个月内总任务数 */
+    private BigDecimal historyCompletionRate;
+
     /** 统计周期 yyyy-MM */
     private String statPeriod;
 }
@@ -40,4 +40,7 @@ public interface UserTaskEfficiencyMapper extends BaseMapperX&lt;UserTaskEfficiency
  
     /** 工单效率统计 */
     List<Map<String, Object>> statWorkOrderEfficiency(@Param("beginTime") String beginTime);
+
+    /** 从 task_statistics 汇总用户 6 个月历史任务总量 */
+    List<Map<String, Object>> statHistoryTotalCount(@Param("beginDate") String beginDate);
 }
@@ -39,6 +39,7 @@ public class TaskEfficiencyCalculateJob implements JobHandler {
  
             // 2. 6个月窗口
             String beginTime = LocalDate.now().minusMonths(6).withDayOfMonth(1) + " 00:00:00";
+            String beginDate = LocalDate.now().minusMonths(6).withDayOfMonth(1).toString();
  
             // 3. 三类任务分别统计
             List<UserTaskEfficiencyDO> all = new ArrayList<>();
@@ -59,6 +60,19 @@ public class TaskEfficiencyCalculateJob implements JobHandler {
                 e.setEfficiencyRatio(calcRatio(e.getAvgMinutes(), e.getTeamAvgMinutes()));
             }
  
+            // 5.5 计算个人历史完成率
+            Map<Long, Map<String, Object>> historyMap = loadHistoryTotalMap(beginDate);
+            for (UserTaskEfficiencyDO e : all) {
+                Map<String, Object> h = historyMap.get(e.getUserId());
+                if (h != null) {
+                    long total = toLong(h.get("history_total"));
+                    long completed = toLong(h.get("history_completed"));
+                    e.setHistoryCompletionRate(total > 0
+                        ? BigDecimal.valueOf(completed).divide(BigDecimal.valueOf(total), 4, RoundingMode.HALF_UP)
+                        : BigDecimal.ZERO);
+                }
+            }
+
             // 6. 生成大类汇总（ALL）
             all.addAll(buildCategorySummary(all, statPeriod));
  
@@ -132,6 +146,17 @@ public class TaskEfficiencyCalculateJob implements JobHandler {
         return ratio;
     }
  
+    private Map<Long, Map<String, Object>> loadHistoryTotalMap(String beginDate) {
+        List<Map<String, Object>> rows = userTaskEfficiencyMapper.statHistoryTotalCount(beginDate);
+        Map<Long, Map<String, Object>> map = new LinkedHashMap<>();
+        if (rows != null) {
+            for (Map<String, Object> row : rows) {
+                map.put(toLong(row.get("user_id")), row);
+            }
+        }
+        return map;
+    }
+
     private List<UserTaskEfficiencyDO> buildCategorySummary(List<UserTaskEfficiencyDO> all, String statPeriod) {
         Map<String, List<UserTaskEfficiencyDO>> catMap = new LinkedHashMap<>();
         for (UserTaskEfficiencyDO e : all) {
@@ -178,6 +203,19 @@ public class TaskEfficiencyCalculateJob implements JobHandler {
             s.setEfficiencyRatio(ratioWeight > 0
                 ? weightedRatio.divide(BigDecimal.valueOf(ratioWeight), 4, RoundingMode.HALF_UP)
                 : BigDecimal.ONE);
+            // 加权计算 historyCompletionRate
+            BigDecimal weightedRate = BigDecimal.ZERO;
+            int rateWeightCnt = 0;
+            for (UserTaskEfficiencyDO e : group) {
+                if (e.getCompletedCount() > 0 && e.getHistoryCompletionRate() != null) {
+                    weightedRate = weightedRate.add(
+                        e.getHistoryCompletionRate().multiply(BigDecimal.valueOf(e.getCompletedCount())));
+                    rateWeightCnt += e.getCompletedCount();
+                }
+            }
+            s.setHistoryCompletionRate(rateWeightCnt > 0
+                ? weightedRate.divide(BigDecimal.valueOf(rateWeightCnt), 4, RoundingMode.HALF_UP)
+                : BigDecimal.ZERO);
             summaries.add(s);
         }
         return summaries;
@@ -458,9 +458,20 @@ public class HomepageSummaryServiceImpl implements HomepageSummaryService{
             if (db == null) return -1;
             return da.compareTo(db);
         });
-        result.setSortedTasks(sortedTasks);
         result.setTeamProgress(teamProgress);
         result.setTotalPendingTasks(sortedTasks.size());
+
+        // 4.5 加载效率数据，设置个人历史完成率
+        Map<String, UserTaskEfficiencyDO> effMap = loadEfficiencyMap(userId);
+        for (TaskDistanceSortRespVO task : sortedTasks) {
+            UserTaskEfficiencyDO effDO = lookupEfficiency(effMap, task.getTaskType(), task.getTaskSubType());
+            if (effDO != null && effDO.getHistoryCompletionRate() != null) {
+                task.setHistoryCompletionRate(effDO.getHistoryCompletionRate());
+            }
+        }
+
+        result.setSortedTasks(sortedTasks);
+
         int totalDist = 0;
         int totalWalkMin = 0;
         int totalTriMin = 0;
@@ -508,6 +519,14 @@ public class HomepageSummaryServiceImpl implements HomepageSummaryService{
                 result.add(sortVo);
             }
         }
+        // 加载效率数据，设置个人历史完成率
+        Map<String, UserTaskEfficiencyDO> effMap = loadEfficiencyMap(userId);
+        for (TaskDistanceSortRespVO task : result) {
+            UserTaskEfficiencyDO effDO = lookupEfficiency(effMap, task.getTaskType(), task.getTaskSubType());
+            if (effDO != null && effDO.getHistoryCompletionRate() != null) {
+                task.setHistoryCompletionRate(effDO.getHistoryCompletionRate());
+            }
+        }
         logTaskList("已办SQL原始记录", result);
         Log.info("返回App参数: " + JSON.toJSONString(result));
         return result;
@@ -674,17 +693,17 @@ public class HomepageSummaryServiceImpl implements HomepageSummaryService{
             TeamProgressVO teamProgress = buildTeamProgress(userId, deptId);
             TaskDistanceSortResultVO result = new TaskDistanceSortResultVO();
             sortedTasks.sort((a, b) -> {
-            Integer da = a.getDistance(), db = b.getDistance();
-            if (da == null && db == null) return 0;
-            if (da == null) return 1;
-            if (db == null) return -1;
-            return da.compareTo(db);
-        });
-        result.setSortedTasks(sortedTasks);
+                Integer da = a.getDistance(), db = b.getDistance();
+                if (da == null && db == null) return 0;
+                if (da == null) return 1;
+                if (db == null) return -1;
+                return da.compareTo(db);
+            });
             result.setTeamProgress(teamProgress);
             result.setTotalPendingTasks(sortedTasks.size());
+            result.setSortedTasks(sortedTasks);
             Log.info("返回App参数: " + JSON.toJSONString(result));
-        return result;
+            return result;
         }
  
         List<Long> roleIds = roleApi.getRoleIdsByUserId(userId);
@@ -743,6 +762,7 @@ public class HomepageSummaryServiceImpl implements HomepageSummaryService{
                 if (effDO != null) {
                     task.setUserAvgMinutes(effDO.getAvgMinutes());
                     task.setTeamAvgMinutes(effDO.getTeamAvgMinutes());
+                    task.setHistoryCompletionRate(effDO.getHistoryCompletionRate());
                 }
  
                 if (task.getTaskLat() != null && task.getTaskLon() != null) {
@@ -807,9 +827,10 @@ public class HomepageSummaryServiceImpl implements HomepageSummaryService{
             if (db == null) return -1;
             return da.compareTo(db);
         });
-        result.setSortedTasks(sortedTasks);
         result.setTeamProgress(teamProgress);
         result.setTotalPendingTasks(sortedTasks.size());
+        result.setSortedTasks(sortedTasks);
+
         int totalDist = 0;
         for (TaskDistanceSortRespVO t : sortedTasks) {
             if (t.getDistance() != null) totalDist += t.getDistance();
@@ -71,4 +71,15 @@
         GROUP BY t.ASSIGNEE_, u.dept_id, m.order_type
     </select>
  
+    <!-- 汇总用户 6 个月历史任务总量 -->
+    <select id="statHistoryTotalCount" resultType="java.util.Map">
+        SELECT user_id,
+               SUM(insp_total + mt_total + wo_total) AS history_total,
+               SUM(insp_completed + mt_completed + wo_completed) AS history_completed
+        FROM garden_task_statistics
+        WHERE busi_date >= #{beginDate}
+          AND deleted = 0
+        GROUP BY user_id
+    </select>
+
 </mapper>
@@ -36,4 +36,6 @@ public interface DictTypeConstants {
  
     String TASK_SORT_WEIGHT_CONFIG = "task_sort_weight_config"; // 智能排序权重配置
  
+    String COMPLETION_RATE_CONFIG = "completion_rate_config"; // 个人历史完成率配置
+
 }
@@ -3,7 +3,7 @@ spring:
     name: urbanops-server
  
   profiles:
-    active: dev
+    active: prod
  
  
   main: