首页-能力对比-查获上报

airport-admin/src/main/java/com/sundot/airport/web/controller/system/SysHomePageController.java

@@ -2,6 +2,7 @@ package com.sundot.airport.web.controller.system;
 
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
+import com.sundot.airport.attendance.service.IAttendancePostRecordService;
 import com.sundot.airport.check.service.ICheckLargeScreenService;
 import com.sundot.airport.common.core.controller.BaseController;
 import com.sundot.airport.common.core.domain.AjaxResult;
@@ -11,14 +12,18 @@ import com.sundot.airport.common.core.domain.SysHomePageDetailDto;
 import com.sundot.airport.common.core.domain.SysHomePageDetailQueryParamDto;
 import com.sundot.airport.common.core.domain.SysHomePageRankingDto;
 import com.sundot.airport.common.core.domain.entity.SysDept;
+import com.sundot.airport.common.core.domain.entity.SysUser;
 import com.sundot.airport.common.enums.DataPermissionType;
 import com.sundot.airport.common.enums.DeptType;
 import com.sundot.airport.common.enums.DeptTypeEnum;
 import com.sundot.airport.common.enums.HomePageQueryEnum;
 import com.sundot.airport.common.enums.SourceTypeEnum;
 import com.sundot.airport.common.exception.ServiceException;
+import com.sundot.airport.common.utils.DateUtils;
+import com.sundot.airport.item.mapper.SeizureReportMapper;
 import com.sundot.airport.system.service.ISysDeptService;
 import com.sundot.airport.system.service.ISysLearningGrowthService;
+import com.sundot.airport.system.service.ISysUserService;
 import com.sundot.airport.web.core.utils.DataPermissionUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -31,6 +36,7 @@ import org.springframework.web.bind.annotation.RestController;
 import java.math.BigDecimal;
 import java.math.RoundingMode;
 import java.util.ArrayList;
+import java.util.Calendar;
 import java.util.Collections;
 import java.util.List;
 import java.util.stream.Collectors;
@@ -45,6 +51,9 @@ import java.util.stream.Collectors;
 public class SysHomePageController extends BaseController {
 
     @Autowired
+    private ISysUserService sysUserService;
+
+    @Autowired
     private ISysDeptService deptService;
 
     @Autowired
@@ -53,6 +62,12 @@ public class SysHomePageController extends BaseController {
     @Autowired
     private ISysLearningGrowthService sysLearningGrowthService;
 
+    @Autowired
+    private SeizureReportMapper seizureReportMapper;
+
+    @Autowired
+    private IAttendancePostRecordService attendancePostRecordService;
+
     /**
      * 首页-排名
      */
@@ -260,6 +275,8 @@ public class SysHomePageController extends BaseController {
             resultItem.setLearningGrowthScoreGraph(resultItem.getLearningGrowthScore().divide(BigDecimal.valueOf(100), 4, RoundingMode.HALF_UP));
             resultItem.setCheckPassRate(getCheckPassRate(item));
             resultItem.setCheckPassRateGraph(resultItem.getCheckPassRate());
+            resultItem.setSeizureCount(getSeizureCount(item));
+            resultItem.setSeizureCountGraph(getSeizureCountGraph(item));
             result.add(resultItem);
         }
         return result;
@@ -297,4 +314,141 @@ public class SysHomePageController extends BaseController {
         return sysLearningGrowthService.learningGrowthAverage(dto);
     }
 
+    /**
+     * 部门值计算器函数式接口
+     */
+    @FunctionalInterface
+    private interface DeptValueCalculator {
+        BigDecimal calculate(String deptType, SysHomePageDetailQueryParamDto item);
+    }
+
+    /**
+     * 获取查获数量
+     */
+    private BigDecimal getSeizureCount(SysHomePageDetailQueryParamDto item) {
+        if (item.getEndDate() != null) {
+            item.setEndDate(DateUtils.addSeconds(DateUtils.truncate(item.getEndDate(), Calendar.DAY_OF_MONTH), 86399));
+        }
+        if (StrUtil.equals(HomePageQueryEnum.USER.getCode(), item.getType())) {
+            return seizureReportMapper.selectSelfSeizureCount(item.getId(), item.getStartDate(), item.getEndDate());
+        } else {
+            return calculateDeptBasedValue(item, this::calculateAverageSeizureCountForDeptType);
+        }
+    }
+
+    /**
+     * 获取查获数量图形
+     */
+    private BigDecimal getSeizureCountGraph(SysHomePageDetailQueryParamDto item) {
+        if (item.getEndDate() != null) {
+            item.setEndDate(DateUtils.addSeconds(DateUtils.truncate(item.getEndDate(), Calendar.DAY_OF_MONTH), 86399));
+        }
+        if (StrUtil.equals(HomePageQueryEnum.USER.getCode(), item.getType())) {
+            BigDecimal totalSeizure = seizureReportMapper.selectSelfSeizureCount(item.getId(), item.getStartDate(), item.getEndDate());
+            Long stationId = getStationIdByUserId(item.getId());
+            BigDecimal maxSeizureCount = seizureReportMapper.selectMaxSeizureCountInStation(stationId, item.getStartDate(), item.getEndDate());
+            return (maxSeizureCount != null && maxSeizureCount.compareTo(BigDecimal.ZERO) > 0) ?
+                    totalSeizure.divide(maxSeizureCount, 4, RoundingMode.HALF_UP) : BigDecimal.ZERO;
+        } else {
+            return calculateDeptBasedValue(item, this::calculateSeizureCountGraphForDeptType);
+        }
+    }
+
+    /**
+     * 获取部门相关数值的通用方法
+     */
+    private BigDecimal calculateDeptBasedValue(SysHomePageDetailQueryParamDto item,
+                                               DeptValueCalculator calculator) {
+        SysDept sysDept = deptService.selectDeptById(item.getId());
+        if (sysDept == null) {
+            return BigDecimal.ZERO;
+        }
+        return calculator.calculate(sysDept.getDeptType(), item);
+    }
+
+    /**
+     * 平均查获数量计算
+     */
+    private BigDecimal calculateAverageSeizureCountForDeptType(String deptType, SysHomePageDetailQueryParamDto item) {
+        switch (deptType) {
+            case "TEAMS":
+                BigDecimal totalTeamSeizure = seizureReportMapper.selectTeamAverage(item.getId(), item.getStartDate(), item.getEndDate());
+                Integer teamUserCount = seizureReportMapper.selectUserCountByTeamId(item.getId());
+                return (teamUserCount != null && teamUserCount > 0) ?
+                        totalTeamSeizure.divide(new BigDecimal(teamUserCount), 2, RoundingMode.HALF_UP) : BigDecimal.ZERO;
+            case "MANAGER":
+                BigDecimal totalDepartmentSeizure = seizureReportMapper.selectDepartmentAverage(item.getId(), item.getStartDate(), item.getEndDate());
+                Integer deptUserCount = seizureReportMapper.selectUserCountByDepartmentId(item.getId());
+                return (deptUserCount != null && deptUserCount > 0) ?
+                        totalDepartmentSeizure.divide(new BigDecimal(deptUserCount), 2, RoundingMode.HALF_UP) : BigDecimal.ZERO;
+            case "BRIGADE":
+                BigDecimal totalBrigadeSeizure = seizureReportMapper.selectBrigadeAverage(item.getId(), item.getStartDate(), item.getEndDate());
+                Integer brigadeUserCount = seizureReportMapper.selectUserCountByBrigadeId(item.getId());
+                return (brigadeUserCount != null && brigadeUserCount > 0) ?
+                        totalBrigadeSeizure.divide(new BigDecimal(brigadeUserCount), 2, RoundingMode.HALF_UP) : BigDecimal.ZERO;
+            case "STATION":
+                BigDecimal totalStationSeizure = seizureReportMapper.selectStationAverage(item.getId(), item.getStartDate(), item.getEndDate());
+                Integer stationUserCount = seizureReportMapper.selectUserCountByStationId(item.getId());
+                return (stationUserCount != null && stationUserCount > 0) ?
+                        totalStationSeizure.divide(new BigDecimal(stationUserCount), 2, RoundingMode.HALF_UP) : BigDecimal.ZERO;
+            default:
+                return BigDecimal.ZERO;
+        }
+    }
+
+    /**
+     * 查获数量图表计算
+     */
+    private BigDecimal calculateSeizureCountGraphForDeptType(String deptType, SysHomePageDetailQueryParamDto item) {
+        switch (deptType) {
+            case "TEAMS":
+                Long sectionDeptId = seizureReportMapper.selectSectionDeptIdByTeamId(item.getId());
+                Long brigadeDeptId = seizureReportMapper.selectBrigadeDeptIdByDepartmentId(sectionDeptId);
+                Long stationId = seizureReportMapper.selectStationDeptIdByDeptId(brigadeDeptId);
+                BigDecimal totalTeamSeizure = seizureReportMapper.selectTeamAverage(item.getId(), item.getStartDate(), item.getEndDate());
+                //查询班级人数
+                Integer teamUserCount = seizureReportMapper.selectUserCountByTeamId(item.getId());
+                BigDecimal maxSeizureCount = seizureReportMapper.selectMaxSeizureCountInStation(stationId, item.getStartDate(), item.getEndDate());
+                return (maxSeizureCount != null && maxSeizureCount.compareTo(BigDecimal.ZERO) > 0 && teamUserCount != null && teamUserCount > 0) ?
+                        totalTeamSeizure.divide(new BigDecimal(teamUserCount), 2, RoundingMode.HALF_UP).divide(maxSeizureCount, 4, RoundingMode.HALF_UP) : BigDecimal.ZERO;
+            case "MANAGER":
+                Long brigadeId = seizureReportMapper.selectBrigadeDeptIdByDepartmentId(item.getId());
+                Long deptStationId = seizureReportMapper.selectStationDeptIdByDeptId(brigadeId);
+                BigDecimal totalDepartmentSeizure = seizureReportMapper.selectDepartmentAverage(item.getId(), item.getStartDate(), item.getEndDate());
+                BigDecimal maxSeizureCountForDept = seizureReportMapper.selectMaxSeizureCountInStation(deptStationId, item.getStartDate(), item.getEndDate());
+                //查询科室人数
+                Integer deptUserCount = seizureReportMapper.selectUserCountByDepartmentId(item.getId());
+                return (maxSeizureCountForDept != null && maxSeizureCountForDept.compareTo(BigDecimal.ZERO) > 0 && deptUserCount != null && deptUserCount > 0) ?
+                        totalDepartmentSeizure.divide(new BigDecimal(deptUserCount), 2, RoundingMode.HALF_UP).divide(maxSeizureCountForDept, 4, RoundingMode.HALF_UP) : BigDecimal.ZERO;
+            case "BRIGADE":
+                Long stationDeptId = seizureReportMapper.selectStationDeptIdByDeptId(item.getId());
+                BigDecimal totalBrigadeSeizure = seizureReportMapper.selectBrigadeAverage(item.getId(), item.getStartDate(), item.getEndDate());
+                BigDecimal maxSeizureCountFor = seizureReportMapper.selectMaxSeizureCountInStation(stationDeptId, item.getStartDate(), item.getEndDate());
+                //查询大队人数
+                Integer deptBrigadeUserCount = seizureReportMapper.selectUserCountByBrigadeId(item.getId());
+                return (maxSeizureCountFor != null && maxSeizureCountFor.compareTo(BigDecimal.ZERO) > 0 && deptBrigadeUserCount != null && deptBrigadeUserCount > 0) ?
+                        totalBrigadeSeizure.divide(new BigDecimal(deptBrigadeUserCount), 2, RoundingMode.HALF_UP).divide(maxSeizureCountFor, 4, RoundingMode.HALF_UP) : BigDecimal.ZERO;
+            case "STATION":
+                BigDecimal totalStationSeizure = seizureReportMapper.selectStationAverage(item.getId(), item.getStartDate(), item.getEndDate());
+                BigDecimal maxSeizureCountForStation = seizureReportMapper.selectMaxSeizureCountInStation(item.getId(), item.getStartDate(), item.getEndDate());
+                //查询站人数
+                Integer stationUserCount = seizureReportMapper.selectUserCountByStationId(item.getId());
+                return (maxSeizureCountForStation != null && maxSeizureCountForStation.compareTo(BigDecimal.ZERO) > 0 && stationUserCount != null && stationUserCount > 0) ?
+                        totalStationSeizure.divide(new BigDecimal(stationUserCount), 2, RoundingMode.HALF_UP).divide(maxSeizureCountForStation, 4, RoundingMode.HALF_UP) : BigDecimal.ZERO;
+            default:
+                return BigDecimal.ZERO;
+        }
+    }
+
+    /**
+     * 根据用户ID获取对应站点ID
+     */
+    private Long getStationIdByUserId(Long userId) {
+        SysUser sysUser = sysUserService.selectUserById(userId);
+        List<SysDept> deptList = deptService.selectAllDept(sysUser.getDeptId());
+        Collections.reverse(deptList);
+        SysDept station = deptList.stream().filter(x -> StrUtil.equals(DeptType.STATION.getCode(), x.getDeptType())).findFirst().orElse(null);
+        return station != null ? station.getDeptId() : 0;
+    }
+
 }

airport-item/src/main/java/com/sundot/airport/item/mapper/SeizureReportMapper.java

@@ -116,6 +116,14 @@ public interface SeizureReportMapper {
     public Long selectSectionDeptIdByTeamId(@Param("teamId") Long teamId);
 
     /**
+     * 查询大队部门ID（根据科室ID）
+     *
+     * @param departmentId 科室ID
+     * @return 大队ID
+     */
+    public Long selectBrigadeDeptIdByDepartmentId(@Param("departmentId") Long departmentId);
+
+    /**
      * 查询站点部门ID（根据部门ID）
      *
      * @param deptId 部门ID

airport-item/src/main/resources/mapper/item/SeizureReportMapper.xml

@@ -186,6 +186,13 @@
         WHERE dept_id = #{teamId}
     </select>
 
+    <!-- 查询大队部门ID（根据科室ID） -->
+    <select id="selectBrigadeDeptIdByDepartmentId" resultType="java.lang.Long">
+        SELECT parent_id
+        FROM sys_dept
+        WHERE dept_id = #{departmentId}
+    </select>
+
     <!-- 查询站点部门ID（根据部门ID） -->
     <select id="selectStationDeptIdByDeptId" resultType="java.lang.Long">
         SELECT parent_id