APP端-首页-消息推送

airport-admin/src/main/java/com/sundot/airport/web/controller/item/SeizureMessagePushController.java

@@ -0,0 +1,73 @@
+package com.sundot.airport.web.controller.item;
+
+import com.sundot.airport.common.core.controller.BaseController;
+import com.sundot.airport.common.core.domain.AjaxResult;
+import com.sundot.airport.common.core.domain.model.LoginUser;
+import com.sundot.airport.common.utils.DateUtils;
+import com.sundot.airport.common.utils.SecurityUtils;
+import com.sundot.airport.item.domain.push.SeizureMessagePushDTO;
+import com.sundot.airport.item.service.ISeizureMessagePushService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.Date;
+
+/**
+ * 查获消息推送 Controller
+ *
+ * @author wangxx
+ * @date 2026-03-31
+ */
+@Slf4j
+@RestController
+@RequestMapping("/item/seizure/push")
+@Api(tags = "查获消息推送")
+public class SeizureMessagePushController extends BaseController {
+
+    @Autowired
+    private ISeizureMessagePushService seizureMessagePushService;
+
+    /**
+     * 获取查获消息推送数据
+     *
+     * @param startDate 开始日期（可选，格式：yyyy-MM-dd）
+     * @param endDate   结束日期（可选，格式：yyyy-MM-dd）
+     * @return 查获消息推送数据
+     */
+    @ApiOperation("获取查获消息推送数据")
+    @GetMapping("/message")
+    public AjaxResult getMessagePushData(@RequestParam(required = false) String startDate,
+                                         @RequestParam(required = false) String endDate) {
+        try {
+            LoginUser loginUser = SecurityUtils.getLoginUser();
+            Long userId = loginUser.getUserId();
+            Long deptId = loginUser.getDeptId();
+
+            Date startDateTime;
+            Date endDateTime;
+
+            if (startDate == null || endDate == null) {
+                // 默认近 15 天（不包含今天）
+                endDateTime = DateUtils.addDays(new Date(), -1);
+                startDateTime = DateUtils.addDays(endDateTime, -14);
+            } else {
+                startDateTime = DateUtils.parseDate(startDate);
+                endDateTime = DateUtils.parseDate(endDate);
+            }
+
+            SeizureMessagePushDTO result = seizureMessagePushService.getSeizureMessagePushData(
+                    userId, deptId, startDateTime, endDateTime);
+
+            return AjaxResult.success(result);
+        } catch (Exception e) {
+            log.error("获取查获消息推送数据失败，error: ", e);
+            return AjaxResult.error("获取查获消息推送数据失败：" + e.getMessage());
+        }
+    }
+}

airport-attendance/src/main/java/com/sundot/airport/attendance/calculator/AttendancePersonCountCalculator.java

@@ -2,10 +2,13 @@ package com.sundot.airport.attendance.calculator;
 
 import com.sundot.airport.attendance.domain.AttendanceRecord;
 import com.sundot.airport.attendance.mapper.AttendanceRecordMapper;
+import com.sundot.airport.common.core.domain.entity.SysDept;
+import com.sundot.airport.common.enums.DeptTypeEnum;
 import com.sundot.airport.common.enums.IndicatorTypeEnum;
 import com.sundot.airport.common.statistics.AbstractIndicatorCalculator;
 import com.sundot.airport.common.statistics.IndicatorCalculationParams;
 import com.sundot.airport.common.statistics.TimeDimensionProcessor;
+import com.sundot.airport.system.mapper.SysDeptMapper;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
@@ -25,6 +28,9 @@ public class AttendancePersonCountCalculator extends AbstractIndicatorCalculator
     @Autowired
     private TimeDimensionProcessor timeDimensionProcessor;
 
+    @Autowired
+    private SysDeptMapper sysDeptMapper;
+
     @Override
     public BigDecimal calculate(IndicatorCalculationParams params) {
         // 确保时间范围已计算
@@ -34,6 +40,19 @@ public class AttendancePersonCountCalculator extends AbstractIndicatorCalculator
         AttendanceRecord record = new AttendanceRecord();
         record.setAttendanceDateStart(params.getStartTime());
         record.setAttendanceDateEnd(params.getEndTime());
+        if (params.getDeptId() != null) {
+            // 按部门统计（大队、科室、班组等）
+            SysDept sysDept = sysDeptMapper.selectDeptById(params.getDeptId());
+            if (DeptTypeEnum.TEAMS.getCode().equals(sysDept.getDeptType())) {
+                record.setTeamCode(params.getDeptId().toString());
+            } else if (DeptTypeEnum.MANAGER.getCode().equals(sysDept.getDeptType())) {
+                record.setDepartmentCode(params.getDeptId().toString());
+            } else if (DeptTypeEnum.BRIGADE.getCode().equals(sysDept.getDeptType())) {
+                record.setBrigadeCode(params.getDeptId().toString());
+            } else if (DeptTypeEnum.STATION.getCode().equals(sysDept.getDeptType())) {
+                record.setStationCode(params.getDeptId().toString());
+            }
+        }
 
         // 查询考勤记录
         List<AttendanceRecord> records = attendanceRecordMapper.selectAttendanceRecordList(record);

airport-item/src/main/java/com/sundot/airport/item/domain/push/SeizureMessagePushDTO.java

@@ -0,0 +1,110 @@
+package com.sundot.airport.item.domain.push;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.math.BigDecimal;
+import java.util.List;
+
+/**
+ * 查获消息推送数据传输对象
+ * 用于向登录用户推送其名下的全站查获信息
+ */
+@Data
+@ApiModel(value = "SeizureMessagePushDTO", description = "查获消息推送数据")
+public class SeizureMessagePushDTO {
+
+    /**
+     * 移交公安违禁品 TOP3
+     */
+    @ApiModelProperty("移交公安违禁品 TOP3")
+    private List<ProhibitedItemTop3> prohibitedItemsTop3;
+
+    /**
+     * 故意隐匿物品藏匿部位 TOP3
+     */
+    @ApiModelProperty("故意隐匿物品藏匿部位 TOP3")
+    private List<ConcealmentPositionTop3> concealmentPositionsTop3;
+
+    /**
+     * 移交公安违禁品高发通道 TOP3
+     */
+    @ApiModelProperty("移交公安违禁品高发通道 TOP3")
+    private List<HighRiskChannelTop3> highRiskChannelsTop3;
+
+    /**
+     * 移交公安违禁品 TOP3
+     */
+    @Data
+    @ApiModel(value = "ProhibitedItemTop3", description = "移交公安违禁品 TOP3")
+    public static class ProhibitedItemTop3 {
+
+        @ApiModelProperty("排名")
+        private Integer rank;
+
+        @ApiModelProperty("违禁品一级分类编码")
+        private String categoryCodeOne;
+
+        @ApiModelProperty("违禁品一级分类名称")
+        private String categoryNameOne;
+
+        @ApiModelProperty("违禁品二级分类编码")
+        private String categoryCodeTwo;
+
+        @ApiModelProperty("违禁品二级分类名称")
+        private String categoryNameTwo;
+
+        @ApiModelProperty("查获数量")
+        private BigDecimal seizureCount;
+    }
+
+    /**
+     * 故意隐匿物品藏匿部位 TOP3
+     */
+    @Data
+    @ApiModel(value = "ConcealmentPositionTop3", description = "故意隐匿物品藏匿部位 TOP3")
+    public static class ConcealmentPositionTop3 {
+
+        @ApiModelProperty("排名")
+        private Integer rank;
+
+        @ApiModelProperty("藏匿部位一级分类编码")
+        private String positionCodeOne;
+
+        @ApiModelProperty("藏匿部位一级分类名称")
+        private String positionNameOne;
+
+        @ApiModelProperty("藏匿部位二级分类编码")
+        private String positionCodeTwo;
+
+        @ApiModelProperty("藏匿部位二级分类名称")
+        private String positionNameTwo;
+
+        @ApiModelProperty("隐匿次数")
+        private BigDecimal concealmentCount;
+    }
+
+    /**
+     * 移交公安违禁品高发通道 TOP3
+     */
+    @Data
+    @ApiModel(value = "HighRiskChannelTop3", description = "移交公安违禁品高发通道 TOP3")
+    public static class HighRiskChannelTop3 {
+
+        @ApiModelProperty("排名")
+        private Integer rank;
+
+        @ApiModelProperty("航站楼")
+        private String terminalName;
+
+        @ApiModelProperty("区域")
+        private String areaName;
+
+        @ApiModelProperty("具体通道名称")
+        private String channelName;
+
+        @ApiModelProperty("移交公安数")
+        private BigDecimal transferToPoliceCount;
+    }
+}

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

@@ -5,6 +5,7 @@ import com.sundot.airport.common.core.domain.SysUsageReportSeizureDto;
 import com.sundot.airport.item.domain.*;
 import com.sundot.airport.item.domain.dto.ConcealmentPositionTop1DTO;
 import com.sundot.airport.item.domain.dto.ProhibitedItemsTop3DTO;
+import com.sundot.airport.item.domain.push.SeizureMessagePushDTO;
 import org.apache.ibatis.annotations.Param;
 
 import java.math.BigDecimal;
@@ -230,4 +231,29 @@ public interface ItemLargeScreenMapper {
      */
     List<ItemXRayMissCheckUserStatsDto> xRayMissCheckUserStatsTop3(BaseLargeScreenQueryParamDto dto);
 
+
+    /**
+     * 查询移交公安违禁品 TOP3
+     *
+     * @param dto 查询参数
+     * @return 移交公安违禁品 TOP3 列表
+     */
+    List<SeizureMessagePushDTO.ProhibitedItemTop3> selectProhibitedItemsTop3ForPush(BaseLargeScreenQueryParamDto dto);
+
+    /**
+     * 查询故意隐匿物品藏匿部位 TOP3
+     *
+     * @param dto 查询参数
+     * @return 故意隐匿物品藏匿部位 TOP3 列表
+     */
+    List<SeizureMessagePushDTO.ConcealmentPositionTop3> selectConcealmentPositionsTop3ForPush(BaseLargeScreenQueryParamDto dto);
+
+    /**
+     * 查询移交公安违禁品高发通道 TOP3
+     *
+     * @param dto 查询参数
+     * @return 移交公安违禁品高发通道 TOP3 列表
+     */
+    List<SeizureMessagePushDTO.HighRiskChannelTop3> selectHighRiskChannelsTop3ForPush(BaseLargeScreenQueryParamDto dto);
+
 }

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

@@ -0,0 +1,25 @@
+package com.sundot.airport.item.service;
+
+import com.sundot.airport.item.domain.push.SeizureMessagePushDTO;
+
+import java.util.Date;
+
+/**
+ * 查获消息推送服务接口
+ *
+ * @author wangxx
+ * @date 2026-03-31
+ */
+public interface ISeizureMessagePushService {
+
+    /**
+     * 获取查获消息推送数据
+     *
+     * @param userId    用户 ID
+     * @param deptId    部门 ID
+     * @param startDate 开始日期
+     * @param endDate   结束日期
+     * @return 查获消息推送数据
+     */
+    SeizureMessagePushDTO getSeizureMessagePushData(Long userId, Long deptId, Date startDate, Date endDate);
+}

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

@@ -0,0 +1,144 @@
+package com.sundot.airport.item.service.impl;
+
+import cn.hutool.core.collection.CollUtil;
+import com.sundot.airport.common.core.domain.BaseLargeScreenQueryParamDto;
+import com.sundot.airport.common.core.domain.entity.SysDept;
+import com.sundot.airport.common.exception.ServiceException;
+import com.sundot.airport.item.domain.push.SeizureMessagePushDTO;
+import com.sundot.airport.item.mapper.ItemLargeScreenMapper;
+import com.sundot.airport.item.service.ISeizureMessagePushService;
+import com.sundot.airport.system.service.ISysDeptService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * 查获消息推送服务实现类
+ *
+ * @author wangxx
+ * @date 2026-03-31
+ */
+@Slf4j
+@Service
+public class SeizureMessagePushServiceImpl implements ISeizureMessagePushService {
+
+    @Autowired
+    private ItemLargeScreenMapper itemLargeScreenMapper;
+
+    @Autowired
+    private ISysDeptService sysDeptService;
+
+    /**
+     * 获取查获消息推送数据
+     *
+     * @param userId    用户 ID
+     * @param deptId    部门 ID
+     * @param startDate 开始日期
+     * @param endDate   结束日期
+     * @return 查获消息推送数据
+     */
+    @Override
+    public SeizureMessagePushDTO getSeizureMessagePushData(Long userId, Long deptId, Date startDate, Date endDate) {
+        try {
+            // 1. 获取用户所在的站点 ID
+            Long stationId = getStationIdByUserId(userId, deptId);
+            if (stationId == null) {
+                throw new ServiceException("未找到用户所属的站点信息");
+            }
+
+            // 2. 构建查询参数（直接使用站点 ID 查询全站数据）
+            BaseLargeScreenQueryParamDto queryDto = new BaseLargeScreenQueryParamDto();
+            queryDto.setInspectStationId(stationId);
+            queryDto.setStartDate(startDate);
+            queryDto.setEndDate(endDate);
+
+            // 3. 查询移交公安违禁品 TOP3
+            List<SeizureMessagePushDTO.ProhibitedItemTop3> prohibitedItemsTop3 = getProhibitedItemsTop3(queryDto);
+
+            // 4. 查询故意隐匿物品藏匿部位 TOP3
+            List<SeizureMessagePushDTO.ConcealmentPositionTop3> concealmentPositionsTop3 = getConcealmentPositionsTop3(queryDto);
+
+            // 5. 查询移交公安违禁品高发通道 TOP3
+            List<SeizureMessagePushDTO.HighRiskChannelTop3> highRiskChannelsTop3 = getHighRiskChannelsTop3(queryDto);
+
+            // 6. 组装返回结果
+            SeizureMessagePushDTO result = new SeizureMessagePushDTO();
+            result.setProhibitedItemsTop3(prohibitedItemsTop3);
+            result.setConcealmentPositionsTop3(concealmentPositionsTop3);
+            result.setHighRiskChannelsTop3(highRiskChannelsTop3);
+
+            return result;
+        } catch (Exception e) {
+            log.error("获取查获消息推送数据失败，userId: {}, deptId: {}, error: {}", userId, deptId, e.getMessage());
+            throw new ServiceException("获取查获消息推送数据失败：" + e.getMessage());
+        }
+    }
+
+    /**
+     * 根据用户 ID 获取所在站点 ID
+     */
+    private Long getStationIdByUserId(Long userId, Long deptId) {
+        try {
+            // 从当前用户的部门向上查找站点
+            SysDept currentDept = sysDeptService.selectDeptById(deptId);
+            while (currentDept != null && !"STATION".equals(currentDept.getDeptType())) {
+                currentDept = sysDeptService.selectDeptById(currentDept.getParentId());
+            }
+            return currentDept != null ? currentDept.getDeptId() : null;
+        } catch (Exception e) {
+            log.error("获取站点 ID 失败，userId: {}, deptId: {}, error: {}", userId, deptId, e.getMessage());
+            return null;
+        }
+    }
+
+    /**
+     * 获取移交公安违禁品 TOP3
+     */
+    private List<SeizureMessagePushDTO.ProhibitedItemTop3> getProhibitedItemsTop3(BaseLargeScreenQueryParamDto dto) {
+        List<SeizureMessagePushDTO.ProhibitedItemTop3> resultList = itemLargeScreenMapper.selectProhibitedItemsTop3ForPush(dto);
+
+        // 设置排名
+        if (CollUtil.isNotEmpty(resultList)) {
+            for (int i = 0; i < resultList.size(); i++) {
+                resultList.get(i).setRank(i + 1);
+            }
+        }
+
+        return resultList;
+    }
+
+    /**
+     * 获取故意隐匿物品藏匿部位 TOP3
+     */
+    private List<SeizureMessagePushDTO.ConcealmentPositionTop3> getConcealmentPositionsTop3(BaseLargeScreenQueryParamDto dto) {
+        List<SeizureMessagePushDTO.ConcealmentPositionTop3> resultList = itemLargeScreenMapper.selectConcealmentPositionsTop3ForPush(dto);
+
+        // 设置排名
+        if (CollUtil.isNotEmpty(resultList)) {
+            for (int i = 0; i < resultList.size(); i++) {
+                resultList.get(i).setRank(i + 1);
+            }
+        }
+
+        return resultList;
+    }
+
+    /**
+     * 获取移交公安违禁品高发通道 TOP3
+     */
+    private List<SeizureMessagePushDTO.HighRiskChannelTop3> getHighRiskChannelsTop3(BaseLargeScreenQueryParamDto dto) {
+        List<SeizureMessagePushDTO.HighRiskChannelTop3> resultList = itemLargeScreenMapper.selectHighRiskChannelsTop3ForPush(dto);
+
+        // 设置排名
+        if (CollUtil.isNotEmpty(resultList)) {
+            for (int i = 0; i < resultList.size(); i++) {
+                resultList.get(i).setRank(i + 1);
+            }
+        }
+
+        return resultList;
+    }
+}

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

@@ -772,4 +772,112 @@
         limit 3
     </select>
 
+    <!-- 查询移交公安违禁品 TOP3(用于消息推送) -->
+    <select id="selectProhibitedItemsTop3ForPush"
+            resultType="com.sundot.airport.item.domain.push.SeizureMessagePushDTO$ProhibitedItemTop3">
+        SELECT
+        isi.category_code_one AS categoryCodeOne,
+        isi.category_name_one AS categoryNameOne,
+        isi.category_code_two AS categoryCodeTwo,
+        isi.category_name_two AS categoryNameTwo,
+        SUM(isi.quantity) AS seizureCount,
+        0 AS rank
+        FROM item_seizure_record isr
+        LEFT JOIN item_seizure_items isi ON isr.id = isi.record_id
+        WHERE isr.process_status = 3
+        <if test="inspectStationId != null">
+            AND isr.inspect_station_id = #{inspectStationId}
+        </if>
+        <if test="inspectBrigadeId != null">
+            and isr.inspect_brigade_id = #{inspectBrigadeId}
+        </if>
+        <if test="inspectDepartmentId != null">
+            and isr.inspect_department_id = #{inspectDepartmentId}
+        </if>
+        <if test="inspectTeamId != null">
+            and isr.inspect_team_id = #{inspectTeamId}
+        </if>
+        <if test="startDate != null and endDate != null">
+            AND isr.seizure_time &gt;= #{startDate}
+            AND isr.seizure_time &lt; date_add(#{endDate}, interval 1 day)
+        </if>
+        AND isi.handling_method = 'TRANSFER_TO_AIRPORT_POLICE'
+        GROUP BY isi.category_code_one, isi.category_name_one, isi.category_code_two, isi.category_name_two
+        ORDER BY seizureCount DESC
+        LIMIT 3
+    </select>
+
+    <!-- 查询故意隐匿物品藏匿部位 TOP3(用于消息推送) -->
+    <select id="selectConcealmentPositionsTop3ForPush"
+            resultType="com.sundot.airport.item.domain.push.SeizureMessagePushDTO$ConcealmentPositionTop3">
+        SELECT
+        isi.check_position_code_one AS positionCodeOne,
+        isi.check_position_name_one AS positionNameOne,
+        isi.check_position_code_two AS positionCodeTwo,
+        isi.check_position_name_two AS positionNameTwo,
+        SUM(isi.quantity) AS concealmentCount,
+        0 AS rank
+        FROM item_seizure_record isr
+        LEFT JOIN item_seizure_items isi ON isr.id = isi.record_id
+        WHERE isr.process_status = 3
+        <if test="inspectStationId != null">
+            AND isr.inspect_station_id = #{inspectStationId}
+        </if>
+        <if test="inspectBrigadeId != null">
+            and isr.inspect_brigade_id = #{inspectBrigadeId}
+        </if>
+        <if test="inspectDepartmentId != null">
+            and isr.inspect_department_id = #{inspectDepartmentId}
+        </if>
+        <if test="inspectTeamId != null">
+            and isr.inspect_team_id = #{inspectTeamId}
+        </if>
+        <if test="startDate != null and endDate != null">
+            AND isr.seizure_time &gt;= #{startDate}
+            AND isr.seizure_time &lt; date_add(#{endDate}, interval 1 day)
+        </if>
+        AND isi.is_active_concealment = 1
+        GROUP BY isi.check_position_code_one, isi.check_position_name_one, isi.check_position_code_two,
+        isi.check_position_name_two
+        ORDER BY concealmentCount DESC
+        LIMIT 3
+    </select>
+
+    <!-- 查询移交公安违禁品高发通道 TOP3(用于消息推送) -->
+    <select id="selectHighRiskChannelsTop3ForPush"
+            resultType="com.sundot.airport.item.domain.push.SeizureMessagePushDTO$HighRiskChannelTop3">
+        SELECT
+        isr.terminl_name AS terminalName,
+        isr.regional_name AS areaName,
+        isr.channel_name AS channelName,
+        SUM(isi.quantity) AS transferToPoliceCount,
+        0 AS rank
+        FROM item_seizure_record isr
+        LEFT JOIN item_seizure_items isi ON isr.id = isi.record_id
+        WHERE isr.process_status = 3
+        <if test="inspectStationId != null">
+            AND isr.inspect_station_id = #{inspectStationId}
+        </if>
+        <if test="inspectBrigadeId != null">
+            and isr.inspect_brigade_id = #{inspectBrigadeId}
+        </if>
+        <if test="inspectDepartmentId != null">
+            and isr.inspect_department_id = #{inspectDepartmentId}
+        </if>
+        <if test="inspectTeamId != null">
+            and isr.inspect_team_id = #{inspectTeamId}
+        </if>
+        <if test="startDate != null and endDate != null">
+            AND isr.seizure_time &gt;= #{startDate}
+            AND isr.seizure_time &lt; date_add(#{endDate}, interval 1 day)
+        </if>
+        AND isi.handling_method = 'TRANSFER_TO_AIRPORT_POLICE'
+        AND isr.terminl_name IS NOT NULL
+        AND isr.regional_name IS NOT NULL
+        AND isr.channel_name IS NOT NULL
+        GROUP BY isr.terminl_name, isr.regional_name, isr.channel_name
+        ORDER BY transferToPoliceCount DESC
+        LIMIT 3
+    </select>
+
 </mapper>