异常查获数据接口【/abnormal-seizure-data】和【/abnormal-seizure-data-top3】

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

@@ -441,4 +441,6 @@ public interface SeizureReportMapper {
     public List<ItemLargeScreenHomePageSeizureReportSqlDto> homePageSeizureReport(BaseLargeScreenQueryParamDto dto);
 
     List<ItemLargeScreenHomePageSeizureReportSqlDto> homePageSeizureReportBrigadeId(BaseLargeScreenQueryParamDto dto);
+
+    List<ItemLargeScreenHomePageSeizureReportSqlDto> homePageSeizureReportDepartmentId(BaseLargeScreenQueryParamDto dto);
 }

airport-item/src/main/java/com/sundot/airport/item/service/SeizureDistributionService.java

@@ -256,11 +256,14 @@ public class SeizureDistributionService {
 
         // 获取该站点下的所有大队
         List<SysDept> brigades = getBrigadesByStation(dto.getInspectStationId());
+        // 获取该站点下的所有科室
+        List<SysDept> departments = getDepartmentsByStation(dto.getInspectStationId());
 
         // 构建所有分组：先添加站级，再添加大队级
         List<SysDept> allGroups = new ArrayList<>();
         allGroups.add(stationDept); // 添加站级
         allGroups.addAll(brigades); // 添加大队级
+        allGroups.addAll(departments); // 添加科室级
 
         // 获取查获数量数据
         List<SeizureLargeScreenHomePageItemDto> seizureReportList = getSeizureDataForStation(dto.getDeptId(), dto.getStartDate(), dto.getEndDate());
@@ -288,6 +291,13 @@ public class SeizureDistributionService {
             groupedQuantities.put(dept.getDeptName(), deptQuantities);
         }
 
+        // 然后处理科室级数据
+        for (SysDept dept : departments) {
+            List<SeizureLargeScreenHomePageItemDto> departmentSeizureReportList = getSeizureDataForDepartment(dept.getDeptId(), dto.getStartDate(), dto.getEndDate());
+            List<BigDecimal> deptQuantities = departmentSeizureReportList.stream().map(SeizureLargeScreenHomePageItemDto::getQuantity).filter(Objects::nonNull).collect(Collectors.toList());
+            groupedQuantities.put(dept.getDeptName(), deptQuantities);
+        }
+
         // 为每个分组计算箱线图数据
         List<GroupedBoxPlotDataDto> result = new ArrayList<>();
 
@@ -420,4 +430,44 @@ public class SeizureDistributionService {
             return lowerValue.add(upperValue.subtract(lowerValue).multiply(BigDecimal.valueOf(fraction)));
         }
     }
+
+    /**
+     * 获取指定站点下的所有科室
+     *
+     * @param stationDeptId 站点部门ID
+     * @return 大队列表
+     */
+    private List<SysDept> getDepartmentsByStation(Long stationDeptId) {
+        if (stationDeptId == null) {
+            return Collections.emptyList();
+        }
+
+        // 查询站点下的所有子部门
+        List<SysDept> childrenDepts = sysDeptService.selectChildrenDeptById(stationDeptId);
+
+        // 过滤出大队级别的部门
+        return childrenDepts.stream()
+                .filter(dept -> DeptTypeEnum.MANAGER.getCode().equals(dept.getDeptType()))
+                .collect(Collectors.toList());
+    }
+
+    /**
+     * 获取指定科室的查获数据（科室级别）
+     *
+     * @param departmentId 科室ID
+     * @param startDate 开始日期
+     * @param endDate   结束日期
+     * @return 科室级别查获数据列表
+     */
+    private List<SeizureLargeScreenHomePageItemDto> getSeizureDataForDepartment(Long departmentId, Date startDate, Date endDate) {
+        if (departmentId == null) {
+            return Collections.emptyList();
+        }
+        // 创建查询参数
+        BaseLargeScreenQueryParamDto dto = new BaseLargeScreenQueryParamDto();
+        dto.setInspectDepartmentId(departmentId);
+        dto.setStartDate(startDate);
+        dto.setEndDate(DateUtils.addDays(endDate, 1));
+        return seizureReportService.getSeizureLargeScreenHomePinspectBrigadeIdList(dto);
+    }
 }

airport-item/src/main/java/com/sundot/airport/item/service/impl/ItemLargeScreenServiceImpl.java

@@ -663,6 +663,25 @@ public class ItemLargeScreenServiceImpl implements ItemLargeScreenService {
                     upperBound = boxPlotData.getUpperBound();
                 }
             }
+        } else if (dto.getInspectDepartmentId() != null) {
+            // 根据 id 获取部门信息
+            SysDept dept = sysDeptService.selectDeptById(dto.getInspectDepartmentId());
+            if (Objects.isNull(dept)) {
+                return Collections.emptyList();
+            }
+
+            // 查找匹配的分组数据
+            Optional<GroupedBoxPlotDataDto> matchedGroup = boxPlotDataList.stream()
+                    .filter(grouped -> Objects.equals(grouped.getGroupName(), dept.getDeptName()))
+                    .findFirst();
+
+            if (matchedGroup.isPresent()) {
+                BoxPlotDataDto boxPlotData = matchedGroup.get().getBoxPlotData();
+                if (Objects.nonNull(boxPlotData)) {
+                    lowerBound = boxPlotData.getLowerBound();
+                    upperBound = boxPlotData.getUpperBound();
+                }
+            }
         } else {
             GroupedBoxPlotDataDto firstGroup = boxPlotDataList.get(0);
             if (Objects.nonNull(firstGroup) && Objects.nonNull(firstGroup.getBoxPlotData())) {
@@ -681,6 +700,10 @@ public class ItemLargeScreenServiceImpl implements ItemLargeScreenService {
             // 有大队 ID，查询大队数据
             seizureReportList = seizureReportMapper.homePageSeizureReportBrigadeId(dto);
             userInfoList = sysUserService.homePageUserInfoByBrigadeId(dto.getInspectBrigadeId());
+        } else if (dto.getInspectDepartmentId() != null) {
+            // 有科室 ID，查询科室数据
+            seizureReportList = seizureReportMapper.homePageSeizureReportDepartmentId(dto);
+            userInfoList = sysUserService.homePageUserInfoByDepartmentId(dto.getInspectDepartmentId());
         } else {
             // 无大队 ID，查询全站数据
             seizureReportList = seizureReportMapper.homePageSeizureReport(dto);
@@ -704,6 +727,10 @@ public class ItemLargeScreenServiceImpl implements ItemLargeScreenService {
         for (LargeScreenHomePageUserInfoSqlDto userInfo : userInfoList) {
             BigDecimal totalQuantity = userSeizureMap.getOrDefault(userInfo.getUserId(), BigDecimal.ZERO);
 
+            if (lowerBound == null || upperBound == null) {
+                continue;
+            }
+
             // 判断是否为异常值
             if (totalQuantity.compareTo(lowerBound) < 0 || totalQuantity.compareTo(upperBound) > 0) {
                 ItemAbnormalSeizureDto abnormalDto = new ItemAbnormalSeizureDto();
@@ -759,6 +786,25 @@ public class ItemLargeScreenServiceImpl implements ItemLargeScreenService {
                     upperBound = boxPlotData.getUpperBound();
                 }
             }
+        } else if (dto.getInspectDepartmentId() != null) {
+            // 根据 id 获取部门信息
+            SysDept dept = sysDeptService.selectDeptById(dto.getInspectDepartmentId());
+            if (Objects.isNull(dept)) {
+                return result;
+            }
+
+            // 查找匹配的分组数据
+            Optional<GroupedBoxPlotDataDto> matchedGroup = boxPlotDataList.stream()
+                    .filter(grouped -> Objects.equals(grouped.getGroupName(), dept.getDeptName()))
+                    .findFirst();
+
+            if (matchedGroup.isPresent()) {
+                BoxPlotDataDto boxPlotData = matchedGroup.get().getBoxPlotData();
+                if (Objects.nonNull(boxPlotData)) {
+                    lowerBound = boxPlotData.getLowerBound();
+                    upperBound = boxPlotData.getUpperBound();
+                }
+            }
         } else {
             GroupedBoxPlotDataDto firstGroup = boxPlotDataList.get(0);
             if (Objects.nonNull(firstGroup) && Objects.nonNull(firstGroup.getBoxPlotData())) {
@@ -776,6 +822,10 @@ public class ItemLargeScreenServiceImpl implements ItemLargeScreenService {
             // 有大队 ID，查询大队数据
             seizureReportList = seizureReportMapper.homePageSeizureReportBrigadeId(dto);
             userInfoList = sysUserService.homePageUserInfoByBrigadeId(dto.getInspectBrigadeId());
+        } else if (dto.getInspectDepartmentId() != null) {
+            // 有科室 ID，查询科室数据
+            seizureReportList = seizureReportMapper.homePageSeizureReportDepartmentId(dto);
+            userInfoList = sysUserService.homePageUserInfoByDepartmentId(dto.getInspectDepartmentId());
         } else {
             // 无大队 ID，查询全站数据
             seizureReportList = seizureReportMapper.homePageSeizureReport(dto);
@@ -800,6 +850,10 @@ public class ItemLargeScreenServiceImpl implements ItemLargeScreenService {
         for (LargeScreenHomePageUserInfoSqlDto userInfo : userInfoList) {
             BigDecimal totalQuantity = userSeizureMap.getOrDefault(userInfo.getUserId(), BigDecimal.ZERO);
 
+            if (lowerBound == null || upperBound == null) {
+                continue;
+            }
+
             // 判断是否为异常值
             if (totalQuantity.compareTo(upperBound) > 0) {
                 // 显著高于

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

@@ -790,4 +790,21 @@
             and isr.inspect_brigade_id = #{inspectBrigadeId}
         </if>
     </select>
+
+    <select id="homePageSeizureReportDepartmentId"
+            resultType="com.sundot.airport.item.domain.ItemLargeScreenHomePageSeizureReportSqlDto">
+        select isr.inspect_user_id userId,
+        isr.inspect_user_name userName,
+        isi.quantity quantity
+        from item_seizure_record isr
+        left join item_seizure_items isi on isr.id = isi.record_id
+        where 1 = 1
+        and isr.process_status = 3
+        <if test="startDate != null and endDate != null">
+            AND isr.create_time BETWEEN #{startDate} AND #{endDate}
+        </if>
+        <if test="inspectDepartmentId != null">
+            and isr.inspect_department_id = #{inspectDepartmentId}
+        </if>
+    </select>
 </mapper>

airport-system/src/main/java/com/sundot/airport/system/mapper/SysUserMapper.java

@@ -246,4 +246,12 @@ public interface SysUserMapper {
      * @return 用户信息列表
      */
     public List<LargeScreenHomePageUserInfoSqlDto> homePageUserInfoByBrigadeId(@Param("brigadeId") Long brigadeId);
+
+    /**
+     * 首页 - 用户信息（按科室 ID 筛选）
+     *
+     * @param departmentId 科室 ID
+     * @return 用户信息列表
+     */
+    public List<LargeScreenHomePageUserInfoSqlDto> homePageUserInfoByDepartmentId(@Param("departmentId") Long departmentId);
 }

airport-system/src/main/java/com/sundot/airport/system/service/ISysUserService.java

@@ -336,4 +336,12 @@ public interface ISysUserService {
      * @return 用户信息列表
      */
     public List<LargeScreenHomePageUserInfoSqlDto> homePageUserInfoByBrigadeId(Long brigadeId);
+
+    /**
+     * 首页 - 用户信息（按科室 ID 筛选）
+     *
+     * @param departmentId 科室 ID
+     * @return 用户信息列表
+     */
+    public List<LargeScreenHomePageUserInfoSqlDto> homePageUserInfoByDepartmentId(Long departmentId);
 }

airport-system/src/main/java/com/sundot/airport/system/service/impl/SysUserServiceImpl.java

@@ -1202,4 +1202,9 @@ public class SysUserServiceImpl implements ISysUserService {
     public List<LargeScreenHomePageUserInfoSqlDto> homePageUserInfoByBrigadeId(Long brigadeId) {
         return userMapper.homePageUserInfoByBrigadeId(brigadeId);
     }
+
+    @Override
+    public List<LargeScreenHomePageUserInfoSqlDto> homePageUserInfoByDepartmentId(Long departmentId) {
+        return userMapper.homePageUserInfoByDepartmentId(departmentId);
+    }
 }

airport-system/src/main/resources/mapper/system/SysUserMapper.xml

@@ -1041,7 +1041,8 @@
           and sr.role_key in ('banzuzhang', 'SecurityCheck')
     </select>
 
-    <select id="homePageUserInfoByBrigadeId" resultType="com.sundot.airport.common.core.domain.LargeScreenHomePageUserInfoSqlDto">
+    <select id="homePageUserInfoByBrigadeId"
+            resultType="com.sundot.airport.common.core.domain.LargeScreenHomePageUserInfoSqlDto">
         select su.user_id      userId,
                su.user_name    userName,
                su.nick_name    nickName,
@@ -1064,4 +1065,29 @@
           and sr.role_key in ('banzuzhang', 'SecurityCheck')
           and sd_dd.dept_id = #{brigadeId}
     </select>
+
+    <select id="homePageUserInfoByDepartmentId"
+            resultType="com.sundot.airport.common.core.domain.LargeScreenHomePageUserInfoSqlDto">
+        select su.user_id      userId,
+               su.user_name    userName,
+               su.nick_name    nickName,
+               sd_bz.dept_id   teamId,
+               sd_bz.dept_name teamName,
+               sd_ks.dept_id   departmentId,
+               sd_ks.dept_name departmentName,
+               sd_dd.dept_id   brigadeId,
+               sd_dd.dept_name brigadeName,
+               sd_zj.dept_id   stationId,
+               sd_zj.dept_name stationName
+        from sys_user su
+                 inner join sys_user_role sur on sur.user_id = su.user_id
+                 inner join sys_role sr on sr.role_id = sur.role_id
+                 inner join sys_dept sd_bz on sd_bz.dept_id = su.dept_id
+                 inner join sys_dept sd_ks on sd_ks.dept_id = sd_bz.parent_id
+                 inner join sys_dept sd_dd on sd_dd.dept_id = sd_ks.parent_id
+                 inner join sys_dept sd_zj on sd_zj.dept_id = sd_dd.parent_id
+        where 1 = 1
+          and sr.role_key in ('banzuzhang', 'SecurityCheck')
+          and sd_ks.dept_id = #{departmentId}
+    </select>
 </mapper>