首页-考勤统计

airport-admin/src/main/java/com/sundot/airport/web/controller/attendance/AttendancePostRecordController.java

@@ -42,7 +42,6 @@ import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
 
 import javax.servlet.http.HttpServletResponse;
-import java.text.SimpleDateFormat;
 import java.time.LocalDateTime;
 import java.time.ZoneId;
 import java.util.*;
@@ -142,7 +141,7 @@ public class AttendancePostRecordController extends BaseController {
             queryDate = DateUtils.getNowDate();
         }
         // 先获取当前用户今天的记录，取出班次信息
-        List<AttendancePostRecord> userRecords = attendancePostRecordService.selectTodayRecordsByUserId(createBy, userId, queryDate);
+        List<AttendancePostRecord> userRecords = attendancePostRecordService.selectTodayRecordsByUserId(createBy, userId, queryDate, null);
 
         if (userRecords.isEmpty()) {
             return AjaxResult.success(new ArrayList<>());
@@ -1127,7 +1126,7 @@ public class AttendancePostRecordController extends BaseController {
             if (shiftDate == null) {
                 shiftDate = DateUtils.getNowDate();
             }
-            List<AttendancePostRecord> userRecords = attendancePostRecordService.selectTodayRecordsByUserId(null, userId, shiftDate);
+            List<AttendancePostRecord> userRecords = attendancePostRecordService.selectTodayRecordsByUserId(null, userId, shiftDate, null);
 
             // 检查是否有已锁定且在当前班次周期内的记录
 //            return userRecords.stream()
@@ -1162,5 +1161,14 @@ public class AttendancePostRecordController extends BaseController {
         }
     }
 
-
+    /**
+     * 根据角色标识查询今日上岗用户列表
+     */
+    @PostMapping("/selectUserListByRoleKey")
+    public AjaxResult selectUserListByRoleKey(@RequestBody List<String> roleTypeList) {
+        // 计算当前时间对应的班次日期
+        Date queryDate = DateUtils.getNowDate();
+        List<SysUser> result = attendancePostRecordService.selectUserListByRoleKey(null, roleTypeList);
+        return AjaxResult.success(result);
+    }
 }

airport-admin/src/main/java/com/sundot/airport/web/controller/attendance/AttendanceTeamUserRecordController.java

@@ -100,7 +100,7 @@ public class AttendanceTeamUserRecordController extends BaseController {
     @PreAuthorize("@ss.hasPermi('attendance:record:query')")
     @GetMapping(value = "/{userId}")
     public AjaxResult getInfo(@PathVariable("userId") Long userId, @PathVariable("attendanceDate") Date attendanceDate) {
-        return success(attendanceTeamUserRecordService.selectAttendanceTeamUserRecordByUserId(userId, attendanceDate));
+        return success(attendanceTeamUserRecordService.selectAttendanceTeamUserRecordByUserId(userId, attendanceDate, null));
     }
 
     /**

airport-admin/src/main/java/com/sundot/airport/web/controller/attendance/api/AttendanceController.java

@@ -8,10 +8,12 @@ import com.sundot.airport.attendance.service.IAttendanceRecordService;
 import com.sundot.airport.common.annotation.Log;
 import com.sundot.airport.common.core.controller.BaseController;
 import com.sundot.airport.common.core.domain.AjaxResult;
+import com.sundot.airport.common.core.domain.entity.SysUser;
 import com.sundot.airport.common.dto.AttendanceRecordDTO;
 import com.sundot.airport.common.dto.AttendanceRecordReq;
 import com.sundot.airport.common.dto.UserInfo;
 import com.sundot.airport.common.enums.BusinessType;
+import com.sundot.airport.common.utils.DateUtils;
 import com.sundot.airport.system.service.ISysConfigService;
 import com.sundot.airport.web.core.cache.UserCache;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -23,6 +25,7 @@ import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 import java.util.Date;
+import java.util.List;
 
 /**
  * 考勤管理 h5 api
@@ -70,4 +73,15 @@ public class AttendanceController extends BaseController {
         return AjaxResult.success("操作成功", attendanceRecordService.getRecordType());
     }
 
+    /**
+     * 根据角色标识查询今日打卡用户列表
+     */
+    @PostMapping("/selectUserListByRoleKey")
+    public AjaxResult selectUserListByRoleKey(@RequestBody List<String> roleTypeList) {
+        // 计算当前时间对应的班次日期
+        Date queryDate = DateUtils.getNowDate();
+        List<SysUser> result = attendanceRecordService.selectUserListByRoleKey(queryDate, roleTypeList);
+        return AjaxResult.success(result);
+    }
+
 }

airport-admin/src/main/java/com/sundot/airport/web/controller/home/AttendanceIndexStatsController.java

@@ -0,0 +1,554 @@
+package com.sundot.airport.web.controller.home;
+
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import com.sundot.airport.attendance.domain.AttendanceCheckRecord;
+import com.sundot.airport.attendance.domain.AttendancePostRecord;
+import com.sundot.airport.attendance.domain.AttendanceTeamUserRecord;
+import com.sundot.airport.attendance.enums.CheckInTypeEnum;
+import com.sundot.airport.attendance.service.IAttendanceCheckRecordService;
+import com.sundot.airport.attendance.service.IAttendancePostRecordService;
+import com.sundot.airport.attendance.service.IAttendanceTeamUserRecordService;
+import com.sundot.airport.check.service.ICheckLargeScreenService;
+import com.sundot.airport.common.core.controller.BaseController;
+import com.sundot.airport.common.core.domain.AjaxResult;
+import com.sundot.airport.common.core.domain.BaseLargeScreenQueryParamDto;
+import com.sundot.airport.common.core.domain.entity.SysDept;
+import com.sundot.airport.common.core.domain.entity.SysUser;
+import com.sundot.airport.common.core.domain.model.LoginUser;
+import com.sundot.airport.common.dto.AttendanceStatsResult;
+import com.sundot.airport.common.dto.BrigadeLeaderStats;
+import com.sundot.airport.common.dto.ChannelOpenStats;
+import com.sundot.airport.common.dto.SectionLeaderStats;
+import com.sundot.airport.common.dto.SecurityCheckStats;
+import com.sundot.airport.common.dto.StationLeaderStats;
+import com.sundot.airport.common.dto.TeamLeaderStats;
+import com.sundot.airport.common.enums.DeptType;
+import com.sundot.airport.common.enums.RoleTypeEnum;
+import com.sundot.airport.common.enums.SourceTypeEnum;
+import com.sundot.airport.common.exception.ServiceException;
+import com.sundot.airport.common.utils.SecurityUtils;
+import com.sundot.airport.common.utils.StringUtils;
+import com.sundot.airport.item.domain.ItemSeizureRecord;
+import com.sundot.airport.item.domain.ItemSeizureRecordDTO;
+import com.sundot.airport.item.domain.SimpleDutySchedule;
+import com.sundot.airport.item.mapper.SimpleDutyScheduleMapper;
+import com.sundot.airport.item.service.IItemSeizureRecordService;
+import com.sundot.airport.system.domain.vo.PositionInfoVO;
+import com.sundot.airport.system.service.IBasePositionService;
+import com.sundot.airport.system.service.ISysDeptService;
+import com.sundot.airport.system.service.ISysUserService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestHeader;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Calendar;
+import java.util.Collections;
+import java.util.Date;
+import java.util.List;
+import java.util.Objects;
+import java.util.stream.Collectors;
+
+/**
+ * 考勤统计控制器
+ * 实现不同角色的考勤统计数据查询
+ *
+ * @author wangxx
+ */
+@RestController
+@RequestMapping("/attendance/stats")
+public class AttendanceIndexStatsController extends BaseController {
+
+    @Autowired
+    private IAttendancePostRecordService attendancePostRecordService;
+
+    @Autowired
+    private IAttendanceTeamUserRecordService attendanceTeamUserRecordService;
+
+
+    @Autowired
+    private ISysUserService sysUserService;
+
+    @Autowired
+    private IItemSeizureRecordService itemSeizureRecordService;
+
+    @Autowired
+    private IAttendanceCheckRecordService attendanceCheckRecordService;
+
+    @Autowired
+    private IBasePositionService basePositionService;
+
+    @Autowired
+    private ICheckLargeScreenService checkLargeScreenService;
+
+    @Autowired
+    private SimpleDutyScheduleMapper simpleDutyScheduleMapper;
+
+    @Autowired
+    private ISysDeptService sysDeptService;
+
+    /**
+     * 获取考勤统计数据
+     * 根据当前登录用户的角色返回不同的考勤统计数据
+     */
+    @GetMapping("/getAttendanceStats")
+    public AjaxResult getAttendanceStats(@RequestHeader(value = "X-Request-Source", defaultValue = "mobile") String source) {
+        LoginUser loginUser = getLoginUser();
+        SysUser currentUser = loginUser.getUser();
+        Long userId = currentUser.getUserId();
+        Long deptId = currentUser.getDeptId();
+
+        // 获取用户角色列表
+        List<String> roleKeys = currentUser.getRoles().stream()
+                .map(role -> role.getRoleKey())
+                .collect(ArrayList::new, ArrayList::add, ArrayList::addAll);
+
+        AttendanceStatsResult result = new AttendanceStatsResult();
+
+        // 根据角色返回不同的统计数据
+        if (StrUtil.equals(SourceTypeEnum.mobile.getCode(), source)) {
+            if (roleKeys.contains(RoleTypeEnum.SecurityCheck.getCode())) {
+                // 安检员角色：查出勤班组、出勤通道、出勤时间
+                result.setSecurityCheckStats(getSecurityCheckStats(userId, deptId));
+            } else if (roleKeys.contains(RoleTypeEnum.banzuzhang.getCode())) {
+                // 班组长角色：查出勤班组、出勤通道、出勤时间
+                result.setTeamLeaderStats(getTeamLeaderStats(userId, deptId));
+            } else if (roleKeys.contains(RoleTypeEnum.kezhang.getCode())) {
+                // 科长角色：查在岗班组、在岗人员、出勤时间、今日查获上报
+                result.setSectionLeaderStats(getSectionLeaderStats(userId, deptId));
+            } else if (roleKeys.contains(RoleTypeEnum.jingli.getCode()) || roleKeys.contains(RoleTypeEnum.xingzheng.getCode())) {
+                // 经理和大队行政角色：查在岗班组、在岗人员、通道开放、今日查获上报
+                result.setBrigadeLeaderStats(getBrigadeLeaderStats(userId, deptId));
+            } else if (roleKeys.contains(RoleTypeEnum.test.getCode()) || roleKeys.contains(RoleTypeEnum.zhijianke.getCode()) || roleKeys.contains(RoleTypeEnum.admin.getCode())) {
+                // 站长和质检科角色：查在岗班组、在岗人员、通道开放、今日查获上报
+                result.setStationLeaderStats(getStationLeaderStats(userId, deptId));
+            } else {
+                throw new ServiceException("当前用户角色无法获取考勤统计数据");
+            }
+        } else {
+            List<SysDept> sysDeptList = sysDeptService.selectAllDept(SecurityUtils.getLoginUser().getDeptId());
+            Collections.reverse(sysDeptList);
+            SysDept stationDept = sysDeptList.stream().filter(x -> StrUtil.equals(DeptType.STATION.getCode(), x.getDeptType())).findFirst().orElse(null);
+            if (ObjectUtil.isNull(stationDept)) {
+                throw new ServiceException("未查询到站级部门信息");
+            }
+            // 站长和质检科角色：查在岗班组、在岗人员、通道开放、今日查获上报
+            result.setStationLeaderStats(getStationLeaderStats(userId, stationDept.getDeptId()));
+        }
+
+        return AjaxResult.success(result);
+    }
+
+    /**
+     * 安检员考勤统计数据
+     * 出勤班组：查询哪个班组长在勤务板块将该安检员维护到自己班组，则显示班组长所在组织架构的班组名称
+     * 出勤通道：进入该界面的时候班组长将该安检员带上哪个通道（仅显示最后一个层级，例如A02通道）
+     * 出勤时间：安检员打卡时间，若未打卡需要提示未打卡
+     */
+    private SecurityCheckStats getSecurityCheckStats(Long userId, Long deptId) {
+        SecurityCheckStats stats = new SecurityCheckStats();
+
+        // 获取当前日期
+        Date today = DateUtil.beginOfDay(new Date());
+
+        // 获取该安检员今日的班组维护记录
+        AttendanceTeamUserRecord teamUserRecord = attendanceTeamUserRecordService.selectAttendanceTeamUserRecordByUserId(userId, null, "1");
+
+        if (teamUserRecord != null) {
+            stats.setAttendanceTeamName(teamUserRecord.getAttendanceTeamName());
+        } else {
+            stats.setAttendanceTeamName("未分配班组");
+        }
+
+        // 获取安检员的打卡记录（上岗时间）
+        List<AttendancePostRecord> checkInRecords = attendancePostRecordService.selectTodayRecordsByUserId(null, userId, null, "1");
+        if (CollUtil.isNotEmpty(checkInRecords)) {
+            // 获取最后一条上岗记录
+            AttendancePostRecord lastRecord = checkInRecords.get(checkInRecords.size() - 1);
+            // 获取通道信息（从通道名称中提取最后一个层级）
+            if (StrUtil.isNotBlank(lastRecord.getChannelName())) {
+                String channelName = extractChannelName(lastRecord.getChannelName());
+                stats.setAttendanceChannel(channelName);
+            } else {
+                stats.setAttendanceChannel("未分配通道");
+            }
+        } else {
+            stats.setAttendanceChannel("未分配通道");
+        }
+
+        // 获取安检员的打卡记录
+        AttendanceCheckRecord attendanceCheckRecord = new AttendanceCheckRecord();
+        attendanceCheckRecord.setUserId(userId);
+        List<AttendanceCheckRecord> attendanceCheckRecords = attendanceCheckRecordService.selectAttendanceCheckRecordList(attendanceCheckRecord);
+        if (CollUtil.isNotEmpty(attendanceCheckRecords)) {
+            AttendanceCheckRecord lastRecord = attendanceCheckRecords.get(attendanceCheckRecords.size() - 1);
+            if (StrUtil.equals(CheckInTypeEnum.CLOCK_IN.getValue(), lastRecord.getCheckInType())) {
+                stats.setAttendanceTime(lastRecord.getCheckInTime());
+                stats.setAttendanceTimeTips("已打卡");
+            } else {
+                stats.setAttendanceTime(null);
+                stats.setAttendanceTimeTips("未打卡");
+            }
+        } else {
+            stats.setAttendanceTime(null);
+            stats.setAttendanceTimeTips("未打卡");
+        }
+        return stats;
+    }
+
+    /**
+     * 班组长考勤统计数据
+     * 出勤班组：查询该班组长在勤务板块将该安检员维护到自己班组，则显示自己所在组织架构的班组名称
+     * 出勤通道：进入该界面的时候班组长将该安检员带上哪个通道（仅显示最后一个层级，例如A02通道）
+     * 出勤时间：班组长打卡时间，若未打卡需要提示未打卡
+     */
+    private TeamLeaderStats getTeamLeaderStats(Long userId, Long deptId) {
+        TeamLeaderStats stats = new TeamLeaderStats();
+        Date today = DateUtil.beginOfDay(new Date());
+
+        // 获取班组长所在班组信息
+        AttendanceTeamUserRecord teamUserRecord = attendanceTeamUserRecordService.selectAttendanceTeamUserRecordByUserId(userId, null, "1");
+
+        if (teamUserRecord != null) {
+            stats.setAttendanceTeamName(teamUserRecord.getAttendanceTeamName());
+        } else {
+            stats.setAttendanceTeamName("未分配班组");
+        }
+        // 获取通道信息（从通道名称中提取最后一个层级）
+        List<AttendancePostRecord> checkInRecords = attendancePostRecordService.selectTodayRecordsByUserId(null, userId, null, "1");
+        if (CollUtil.isNotEmpty(checkInRecords)) {
+            // 获取最后一条上岗记录
+            AttendancePostRecord lastRecord = checkInRecords.get(checkInRecords.size() - 1);
+            if (StrUtil.isNotBlank(lastRecord.getChannelName())) {
+                String channelName = extractChannelName(lastRecord.getChannelName());
+                stats.setAttendanceChannel(channelName);
+            } else {
+                stats.setAttendanceChannel("未分配通道");
+            }
+        } else {
+            stats.setAttendanceChannel("未分配通道");
+        }
+
+        // 获取班组长的打卡记录
+        AttendanceCheckRecord attendanceCheckRecord = new AttendanceCheckRecord();
+        attendanceCheckRecord.setUserId(userId);
+        List<AttendanceCheckRecord> attendanceCheckRecords = attendanceCheckRecordService.selectAttendanceCheckRecordList(attendanceCheckRecord);
+        if (CollUtil.isNotEmpty(attendanceCheckRecords)) {
+            AttendanceCheckRecord lastRecord = attendanceCheckRecords.get(attendanceCheckRecords.size() - 1);
+            if (StrUtil.equals(CheckInTypeEnum.CLOCK_IN.getValue(), lastRecord.getCheckInType())) {
+                stats.setAttendanceTime(lastRecord.getCheckInTime());
+                stats.setAttendanceTimeTips("已打卡");
+            } else {
+                stats.setAttendanceTime(null);
+                stats.setAttendanceTimeTips("未打卡");
+            }
+        } else {
+            stats.setAttendanceTime(null);
+            stats.setAttendanceTimeTips("未打卡");
+        }
+
+        return stats;
+    }
+
+    /**
+     * 科长考勤统计数据
+     * 在岗班组：进入界面时有多少班组长打了上岗卡/多少班组长维护人员区域
+     * 在岗人员：进入该界面的时候多少人被带上通道/多少人的信息被班组长进行了维护
+     * 出勤时间：科长打卡时间，若未打卡需要提示未打卡
+     * 今日查获上报：今日安检员和班组长进行上报的数量，不需要完成审核
+     */
+    private SectionLeaderStats getSectionLeaderStats(Long userId, Long deptId) {
+        SectionLeaderStats stats = new SectionLeaderStats();
+
+        // 获取当天开始和结束时间
+        Date[] dayRange = getDayStartAndEnd();
+        Date startOfDay = dayRange[0];
+        Date endOfDay = dayRange[1];
+
+        AttendanceCheckRecord attendanceCheckRecord = new AttendanceCheckRecord();
+        attendanceCheckRecord.setUserId(userId);
+        List<AttendanceCheckRecord> attendanceCheckRecords = attendanceCheckRecordService.selectAttendanceCheckRecordList(attendanceCheckRecord);
+        if (CollUtil.isNotEmpty(attendanceCheckRecords)) {
+            AttendanceCheckRecord lastRecord = attendanceCheckRecords.get(attendanceCheckRecords.size() - 1);
+            if (StrUtil.equals(CheckInTypeEnum.CLOCK_IN.getValue(), lastRecord.getCheckInType())) {
+                stats.setAttendanceTime(lastRecord.getCheckInTime());
+                stats.setAttendanceTimeTips("已打卡");
+            } else {
+                stats.setAttendanceTime(null);
+                stats.setAttendanceTimeTips("未打卡");
+            }
+        } else {
+            stats.setAttendanceTime(null);
+            stats.setAttendanceTimeTips("未打卡");
+        }
+        // 获取在岗班组数量（打了上岗卡的班组长数量/维护了人员区域的班组长数量）
+        String onDutyTeamCount = getOnDutyTeamCount(deptId, startOfDay, endOfDay);
+        stats.setOnDutyTeamCount(onDutyTeamCount);
+
+        // 获取在岗人员数量（被带上通道的人员数量或被班组长维护的人员数量）
+        String onDutyPersonnelCount = getOnDutyPersonnelCount(deptId, startOfDay, endOfDay);
+        stats.setOnDutyPersonnelCount(onDutyPersonnelCount);
+
+        // 获取今日查获上报数量（安检员和班组长上报的数量，不需要完成审核）
+        int todaySeizureReportCount = getTodaySeizureReportCount(deptId, startOfDay, endOfDay, "3");
+        stats.setTodaySeizureReportCount(todaySeizureReportCount);
+
+        // 获取今日巡检问题数
+        Integer todayCheckCorrectionCount = getTodayCheckCorrectionCount();
+        stats.setTodayCheckCorrectionCount(todayCheckCorrectionCount);
+
+        return stats;
+    }
+
+    /**
+     * 站长/质检科考勤统计数据
+     * 在岗班组：进入界面时有多少班组长打了上岗卡/多少班组长维护人员区域
+     * 在岗人员：进入该界面的时候多少人被带上通道/多少人的信息被班组长进行了维护
+     * 通道开放：开放通道/总通道
+     * 今日查获上报：今日安检员和班组长进行上报的数量，不需要完成审核
+     */
+    private StationLeaderStats getStationLeaderStats(Long userId, Long deptId) {
+        StationLeaderStats stats = new StationLeaderStats();
+
+        // 获取当天开始和结束时间
+        Date[] dayRange = getDayStartAndEnd();
+        Date startOfDay = dayRange[0];
+        Date endOfDay = dayRange[1];
+
+        // 获取在岗班组数量（打了上岗卡的班组长数量/维护了人员区域的班组长数量）
+        String onDutyTeamCount = getOnDutyTeamCount(deptId, startOfDay, endOfDay);
+        stats.setOnDutyTeamCount(onDutyTeamCount);
+
+        // 获取在岗人员数量（被带上通道的人员数量/被班组长维护的人员数量）
+        String onDutyPersonnelCount = getOnDutyPersonnelCount(deptId, startOfDay, endOfDay);
+        stats.setOnDutyPersonnelCount(onDutyPersonnelCount);
+
+        // 获取通道开放情况：开放通道/总通道
+        ChannelOpenStats channelStats = getChannelOpenStats(startOfDay, endOfDay);
+        stats.setChannelOpenStats(channelStats);
+
+        // 获取今日查获上报数量（安检员和班组长上报的数量，不需要完成审核）
+        int todaySeizureReportCount = getTodaySeizureReportCount(deptId, startOfDay, endOfDay, "1");
+        stats.setTodaySeizureReportCount(todaySeizureReportCount);
+
+        // 获取今日巡检问题数
+        Integer todayCheckCorrectionCount = getTodayCheckCorrectionCount();
+        stats.setTodayCheckCorrectionCount(todayCheckCorrectionCount);
+
+        SimpleDutySchedule simpleDutySchedule = simpleDutyScheduleMapper.selectSimpleDutyScheduleByDate(new Date());
+        if (Objects.nonNull(simpleDutySchedule)) {
+            stats.setDutyDeptName(simpleDutySchedule.getDepartmentName());
+        }
+
+        return stats;
+    }
+
+    /**
+     * 获取当天开始和结束时间
+     */
+    private Date[] getDayStartAndEnd() {
+        Calendar calendar = Calendar.getInstance();
+        calendar.set(Calendar.HOUR_OF_DAY, 0);
+        calendar.set(Calendar.MINUTE, 0);
+        calendar.set(Calendar.SECOND, 0);
+        calendar.set(Calendar.MILLISECOND, 0);
+        Date startOfDay = calendar.getTime();
+
+        calendar.set(Calendar.HOUR_OF_DAY, 23);
+        calendar.set(Calendar.MINUTE, 59);
+        calendar.set(Calendar.SECOND, 59);
+        calendar.set(Calendar.MILLISECOND, 999);
+        Date endOfDay = calendar.getTime();
+
+        return new Date[]{startOfDay, endOfDay};
+    }
+
+    /**
+     * 上岗卡的班组长数量/维护了人员区域的班组长数量
+     */
+    private String getOnDutyTeamCount(Long deptId, Date startOfDay, Date endOfDay) {
+        // 查询该部门下的班组长上岗记录（在指定时间范围内的记录）
+        // 先获取该部门下的所有班组长
+        List<SysUser> teamLeaderUsers = sysUserService.selectUserListByRoleKeyAndDeptId(Collections.singletonList(RoleTypeEnum.banzuzhang.getCode()), deptId);
+
+        if (CollUtil.isEmpty(teamLeaderUsers)) {
+            return "0/0";
+        }
+
+        int onDutyCount = 0;
+        // 统计在指定时间段内有上岗记录的班组长数量
+        for (SysUser teamLeader : teamLeaderUsers) {
+            List<AttendancePostRecord> attendancePostRecords = attendancePostRecordService.selectTeamOnList(new Date(), teamLeader.getDeptId());
+            if (CollUtil.isNotEmpty(attendancePostRecords)) {
+                onDutyCount++;
+            }
+        }
+
+        List<Long> teamList = teamLeaderUsers.stream().map(SysUser::getDeptId).distinct().collect(Collectors.toList());
+        // 统计该部门下维护了人员的班组数量
+        AttendanceTeamUserRecord queryRecord = new AttendanceTeamUserRecord();
+        queryRecord.setCheckInType("1");
+        List<AttendanceTeamUserRecord> teamUserRecords = attendanceTeamUserRecordService.selectAttendanceTeamUserRecordList(queryRecord, true);
+        List<Long> distinctTeamIds = teamUserRecords.stream().filter(team -> teamList.contains(team.getAttendanceTeamId())).map(AttendanceTeamUserRecord::getAttendanceTeamId).distinct().collect(Collectors.toList());
+
+
+        //打了上岗卡的班组长数量/维护了人员区域的班组长数量
+        return onDutyCount + "/" + distinctTeamIds.size();
+    }
+
+    /**
+     * 获取在岗人员数量(在岗人/被维护的人)
+     */
+    private String getOnDutyPersonnelCount(Long deptId, Date startOfDay, Date endOfDay) {
+        // 查询该部门下的人员上岗记录（在指定时间范围内的记录）
+        // 获取该部门下的所有安检员和班组长
+        List<SysUser> personnelUsers = sysUserService.selectUserListByRoleKeyAndDeptId(
+                Arrays.asList(RoleTypeEnum.banzuzhang.getCode(), RoleTypeEnum.SecurityCheck.getCode()),
+                deptId
+        );
+
+        if (CollUtil.isEmpty(personnelUsers)) {
+            return "0/0";
+        }
+
+        List<Long> personnelList = personnelUsers.stream().filter(item -> Objects.nonNull(item.getUserId())).map(item -> item.getUserId()).collect(Collectors.toList());
+
+
+        int onDutyCount = 0;
+        // 统计在指定时间段内有上岗记录的人员数量
+        for (Long personnel : personnelList) {
+            List<AttendancePostRecord> records = attendancePostRecordService.selectTodayRecordsByUserId(null, personnel, null, "1");
+            if (CollUtil.isNotEmpty(records)) {
+                onDutyCount++;
+            }
+        }
+
+        // 统计该部门下被维护到班组的人员数量
+        AttendanceTeamUserRecord queryRecord = new AttendanceTeamUserRecord();
+        queryRecord.setCheckInType("1");
+        List<AttendanceTeamUserRecord> teamUserRecords = attendanceTeamUserRecordService.selectAttendanceTeamUserRecordList(queryRecord, true);
+        List<Long> teamUserIds = teamUserRecords.stream().filter(team -> personnelList.contains(team.getUserId())).map(team -> team.getUserId()).collect(Collectors.toList());
+
+        // 返回两个统计中较大的值（被带上通道的人员数量或被班组长维护的人员数量）
+        return onDutyCount + "/" + teamUserIds.size();
+    }
+
+    /**
+     * 获取今日查获上报数量
+     */
+    private int getTodaySeizureReportCount(Long deptId, Date startOfDay, Date endOfDay, String type) {
+        // 查询今日的查获上报记录数量（安检员和班组长上报的数量，不需要完成审核）
+        ItemSeizureRecordDTO record = new ItemSeizureRecordDTO();
+        switch (type) {
+            case "1":
+                record.setInspectStationId(deptId);
+                break;
+            case "2":
+                record.setInspectBrigadeId(deptId);
+                break;
+            case "3":
+                record.setInspectDepartmentId(deptId);
+                break;
+            default:
+                break;
+        }
+        record.setBeginTime(startOfDay);
+        record.setEndTime(endOfDay);
+        // 不限制process_status，即包含所有状态的记录（不需要完成审核）
+        List<ItemSeizureRecord> seizureRecords = itemSeizureRecordService.selectItemSeizureRecordList(record);
+        return seizureRecords.size();
+    }
+
+    /**
+     * 获取通道开放统计
+     */
+    private ChannelOpenStats getChannelOpenStats(Date startOfDay, Date endOfDay) {
+        ChannelOpenStats stats = new ChannelOpenStats();
+
+        // 查询所有通道
+        List<PositionInfoVO> positionInfoVOS = basePositionService.selectChannelsUnderArea(new ArrayList<>());
+        // 获取所有通道的开放状态
+        AttendancePostRecord queryPostRecord = new AttendancePostRecord();
+        queryPostRecord.setCheckOutTimeType(1);
+        List<AttendancePostRecord> postRecords = attendancePostRecordService.selectAttendancePostRecordList(queryPostRecord);
+        List<String> collect = postRecords.stream().filter(item -> StringUtils.isNotEmpty(item.getChannelName())).map(item -> extractChannelName(item.getChannelName())).distinct().collect(Collectors.toList());
+
+        stats.setOpenChannels(collect.size());
+        stats.setTotalChannels(positionInfoVOS.size());
+        return stats;
+    }
+
+    /**
+     * 从通道名称中提取最后一个层级（例如从"安检A区/A02通道"中提取"A02通道"）
+     */
+    private String extractChannelName(String fullChannelName) {
+        if (StrUtil.isBlank(fullChannelName)) {
+            return "";
+        }
+
+        // 按斜杠分割，取最后一部分
+        String[] parts = fullChannelName.split("/");
+        if (parts.length > 0) {
+            return parts[parts.length - 1].trim();
+        }
+
+        return fullChannelName.trim();
+    }
+
+    /**
+     * 获取今日巡检问题数
+     */
+    private Integer getTodayCheckCorrectionCount() {
+        BaseLargeScreenQueryParamDto queryParam = new BaseLargeScreenQueryParamDto();
+        return checkLargeScreenService.checkCorrectionCount(queryParam);
+    }
+
+    /**
+     * 经理和大队行政考勤统计数据
+     * 在岗班组：进入界面时有多少班组长打了上岗卡/多少班组长维护人员区域
+     * 在岗人员：进入该界面的时候多少人被带上通道/多少人的信息被班组长进行了维护
+     * 通道开放：开放通道/总通道
+     * 今日查获上报：今日安检员和班组长进行上报的数量，不需要完成审核
+     */
+    private BrigadeLeaderStats getBrigadeLeaderStats(Long userId, Long deptId) {
+        BrigadeLeaderStats stats = new BrigadeLeaderStats();
+
+        // 获取当天开始和结束时间
+        Date[] dayRange = getDayStartAndEnd();
+        Date startOfDay = dayRange[0];
+        Date endOfDay = dayRange[1];
+
+        // 获取在岗班组数量（打了上岗卡的班组长数量/维护了人员区域的班组长数量）
+        String onDutyTeamCount = getOnDutyTeamCount(deptId, startOfDay, endOfDay);
+        stats.setOnDutyTeamCount(onDutyTeamCount);
+
+        // 获取在岗人员数量（被带上通道的人员数量/被班组长维护的人员数量）
+        String onDutyPersonnelCount = getOnDutyPersonnelCount(deptId, startOfDay, endOfDay);
+        stats.setOnDutyPersonnelCount(onDutyPersonnelCount);
+
+        // 获取通道开放情况：开放通道/总通道
+        ChannelOpenStats channelStats = getChannelOpenStats(startOfDay, endOfDay);
+        stats.setChannelOpenStats(channelStats);
+
+        // 获取今日查获上报数量（安检员和班组长上报的数量，不需要完成审核）
+        int todaySeizureReportCount = getTodaySeizureReportCount(deptId, startOfDay, endOfDay, "2");
+        stats.setTodaySeizureReportCount(todaySeizureReportCount);
+
+        // 获取今日巡检问题数
+        Integer todayCheckCorrectionCount = getTodayCheckCorrectionCount();
+        stats.setTodayCheckCorrectionCount(todayCheckCorrectionCount);
+
+        SimpleDutySchedule simpleDutySchedule = simpleDutyScheduleMapper.selectSimpleDutyScheduleByDate(new Date());
+        if (Objects.nonNull(simpleDutySchedule)) {
+            stats.setDutyDeptName(simpleDutySchedule.getDepartmentName());
+        }
+
+        return stats;
+    }
+}

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

@@ -1,5 +1,6 @@
 package com.sundot.airport.web.controller.system;
 
+import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
 import com.sundot.airport.attendance.service.IAttendancePostRecordService;
@@ -17,6 +18,7 @@ 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.RoleTypeEnum;
 import com.sundot.airport.common.enums.SourceTypeEnum;
 import com.sundot.airport.common.exception.ServiceException;
 import com.sundot.airport.common.utils.DateUtils;
@@ -37,6 +39,7 @@ import org.springframework.web.bind.annotation.RestController;
 import java.math.BigDecimal;
 import java.math.RoundingMode;
 import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.Calendar;
 import java.util.Collections;
 import java.util.List;
@@ -282,6 +285,8 @@ public class SysHomePageController extends BaseController {
             resultItem.setCheckPassRateGraph(resultItem.getCheckPassRate());
             resultItem.setSeizureCount(getSeizureCount(item));
             resultItem.setSeizureCountGraph(getSeizureCountGraph(item));
+            resultItem.setWorkingHours(getWorkingHours(item));
+            resultItem.setWorkingHoursGraph(getWorkingHoursGraph(item));
             // 抽问抽答正确率
             resultItem.setAnswersAccuracy(getAnswersAccuracy(item));
             resultItem.setAnswersAccuracyGraph(resultItem.getAnswersAccuracy());
@@ -473,4 +478,69 @@ public class SysHomePageController extends BaseController {
         return station != null ? station.getDeptId() : 0;
     }
 
+    private BigDecimal getWorkingHours(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 bigDecimal = attendancePostRecordService.selectPersonalTotalWorkDurationInTimeRange(item.getId(), item.getStartDate(), item.getEndDate());
+            return bigDecimal != null ? bigDecimal.divide(BigDecimal.valueOf(60), 2, RoundingMode.HALF_UP) : BigDecimal.ZERO;
+        } else {
+            return calculateDeptBasedValue(item, this::calculateAverageWorkDurationForDeptType);
+        }
+    }
+
+    private BigDecimal getWorkingHoursGraph(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 totalWorkDuration = attendancePostRecordService.selectPersonalTotalWorkDurationInTimeRange(item.getId(), item.getStartDate(), item.getEndDate());
+            Long stationId = getStationIdByUserId(item.getId());
+            BigDecimal maxUserWorkDuration = attendancePostRecordService.selectTopUserWorkDurationInTimeRange(stationId, item.getStartDate(), item.getEndDate());
+            return (maxUserWorkDuration != null && maxUserWorkDuration.compareTo(BigDecimal.ZERO) > 0) ?
+                    totalWorkDuration.divide(maxUserWorkDuration, 4, RoundingMode.HALF_UP) : BigDecimal.ZERO;
+        } else {
+            return calculateDeptBasedValue(item, this::calculateWorkDurationForDeptType);
+        }
+    }
+
+    /**
+     * 平均工作时长计算
+     */
+    private BigDecimal calculateAverageWorkDurationForDeptType(String deptType, SysHomePageDetailQueryParamDto item) {
+        List<SysUser> sysUserList = sysUserService.selectUserListByRoleKeyAndDeptId(Arrays.asList(RoleTypeEnum.banzuzhang.getCode(), RoleTypeEnum.SecurityCheck.getCode()), item.getId());
+        if (CollUtil.isEmpty(sysUserList)) {
+            return BigDecimal.ZERO;
+        }
+        List<Long> list = sysUserList.stream().map(SysUser::getUserId).distinct().collect(Collectors.toList());
+        int size = list.size();
+        BigDecimal totalWorkDuration = attendancePostRecordService.selectTotalWorkDurationInTimeRange(list, item.getStartDate(), item.getEndDate());
+        return totalWorkDuration.divide(new BigDecimal(60), 2, RoundingMode.HALF_UP).divide(new BigDecimal(size), 2, RoundingMode.HALF_UP);
+    }
+
+    /**
+     * 工作时长图表计算
+     */
+    private BigDecimal calculateWorkDurationForDeptType(String deptType, SysHomePageDetailQueryParamDto item) {
+        List<SysDept> deptList = deptService.selectAllDept(item.getId());
+        if (CollUtil.isEmpty(deptList)) {
+            return BigDecimal.ZERO;
+        }
+        Collections.reverse(deptList);
+        SysDept station = deptList.stream().filter(x -> StrUtil.equals(DeptType.STATION.getCode(), x.getDeptType())).findFirst().orElse(null);
+        BigDecimal maxUserWorkDuration = attendancePostRecordService.selectTopUserWorkDurationInTimeRange(station.getDeptId(), item.getStartDate(), item.getEndDate());
+        if (maxUserWorkDuration == null || maxUserWorkDuration.compareTo(BigDecimal.ZERO) == 0) {
+            return BigDecimal.ZERO;
+        }
+        List<SysUser> sysUserList = sysUserService.selectUserListByRoleKeyAndDeptId(Arrays.asList(RoleTypeEnum.banzuzhang.getCode(), RoleTypeEnum.SecurityCheck.getCode()), item.getId());
+        if (CollUtil.isEmpty(sysUserList)) {
+            return BigDecimal.ZERO;
+        }
+        List<Long> list = sysUserList.stream().map(SysUser::getUserId).distinct().collect(Collectors.toList());
+        int size = list.size();
+        BigDecimal totalWorkDuration = attendancePostRecordService.selectTotalWorkDurationInTimeRange(list, item.getStartDate(), item.getEndDate());
+        return totalWorkDuration.divide(new BigDecimal(size), 2, RoundingMode.HALF_UP).divide(maxUserWorkDuration, 4, RoundingMode.HALF_UP);
+    }
+
 }

airport-attendance/src/main/java/com/sundot/airport/attendance/mapper/AttendancePostRecordMapper.java

@@ -1,8 +1,10 @@
 package com.sundot.airport.attendance.mapper;
 
 import com.sundot.airport.attendance.domain.AttendancePostRecord;
+import com.sundot.airport.common.core.domain.entity.SysUser;
 import org.apache.ibatis.annotations.Param;
 
+import java.math.BigDecimal;
 import java.util.Date;
 import java.util.List;
 
@@ -69,7 +71,7 @@ public interface AttendancePostRecordMapper {
      * @param today    当天日期
      * @return 上岗记录集合
      */
-    public List<AttendancePostRecord> selectTodayRecordsByUserId(@Param("createBy") Long createBy, @Param("userId") Long userId, @Param("today") Date today);
+    public List<AttendancePostRecord> selectTodayRecordsByUserId(@Param("createBy") Long createBy, @Param("userId") Long userId, @Param("today") Date today, @Param("locked") String locked);
 
     /**
      * 查询指定班次代码当天的上岗记录
@@ -146,4 +148,43 @@ public interface AttendancePostRecordMapper {
      * @return 考勤日期
      */
     public Date selectMaxDateByUserId(@Param("createBy") Long createBy, @Param("userId") Long userId);
+
+    /**
+     * 根据角色标识查询今日上岗用户列表
+     *
+     * @param date 考勤日期
+     * @param list 角色标识
+     * @return 用户列表
+     */
+    List<SysUser> selectUserListByRoleKey(@Param("date") Date date, @Param("locked") String locked, @Param("list") List<String> list);
+
+    /**
+     * 查询指定个人在指定时间段内的总工作时长
+     *
+     * @param userId    用户ID
+     * @param startTime 开始时间
+     * @param endTime   结束时间
+     * @return 个人总工作时长（分钟）
+     */
+    BigDecimal selectPersonalTotalWorkDurationInTimeRange(@Param("userId") Long userId, @Param("startTime") Date startTime, @Param("endTime") Date endTime);
+
+    /**
+     * 查询站级别指定时间段内工作时长总和最高的时长
+     *
+     * @param attendanceStationId 考勤站点ID
+     * @param startTime           开始时间
+     * @param endTime             结束时间
+     * @return 包含用户ID和总工作时长的结果Map，key为userId和totalWorkDuration
+     */
+    BigDecimal selectTopUserWorkDurationInTimeRange(@Param("attendanceStationId") Long attendanceStationId, @Param("startTime") Date startTime, @Param("endTime") Date endTime);
+
+    /**
+     * 查询指定用户ID列表在指定时间段内的总工作时长
+     *
+     * @param list      用户ID列表
+     * @param startTime 开始时间
+     * @param endTime   结束时间
+     * @return 总工作时长（分钟）
+     */
+    BigDecimal selectTotalWorkDurationInTimeRange(@Param("list") List<Long> list, @Param("startTime") Date startTime, @Param("endTime") Date endTime);
 }

airport-attendance/src/main/java/com/sundot/airport/attendance/mapper/AttendanceRecordMapper.java

@@ -1,7 +1,10 @@
 package com.sundot.airport.attendance.mapper;
 
 import com.sundot.airport.attendance.domain.AttendanceRecord;
+import com.sundot.airport.common.core.domain.entity.SysUser;
+import org.apache.ibatis.annotations.Param;
 
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -58,4 +61,13 @@ public interface AttendanceRecordMapper {
      * @return 结果
      */
     public int deleteAttendanceRecordByIds(Long[] ids);
+
+    /**
+     * 根据角色标识查询今日打卡用户列表
+     *
+     * @param date 考勤日期
+     * @param list 角色标识
+     * @return 用户列表
+     */
+    List<SysUser> selectUserListByRoleKey(@Param("date") Date date, @Param("locked") String locked, @Param("list") List<String> list);
 }

airport-attendance/src/main/java/com/sundot/airport/attendance/mapper/AttendanceTeamUserRecordMapper.java

@@ -19,7 +19,7 @@ public interface AttendanceTeamUserRecordMapper {
      * @param userId 考勤班组成员主键
      * @return 考勤班组成员
      */
-    public AttendanceTeamUserRecord selectAttendanceTeamUserRecordByUserId(@Param("userId") Long userId, @Param("attendanceDate") Date attendanceDate);
+    public AttendanceTeamUserRecord selectAttendanceTeamUserRecordByUserId(@Param("userId") Long userId, @Param("attendanceDate") Date attendanceDate, @Param("checkInType") String checkInType);
 
     /**
      * 查询考勤班组成员列表

airport-attendance/src/main/java/com/sundot/airport/attendance/service/IAttendancePostRecordService.java

@@ -1,8 +1,9 @@
 package com.sundot.airport.attendance.service;
 
 import com.sundot.airport.attendance.domain.AttendancePostRecord;
-import com.sundot.airport.attendance.dto.AttendanceRecordCountDTO;
+import com.sundot.airport.common.core.domain.entity.SysUser;
 
+import java.math.BigDecimal;
 import java.util.Date;
 import java.util.List;
 import java.util.Map;
@@ -70,7 +71,7 @@ public interface IAttendancePostRecordService {
      * @param today    当天日期
      * @return 上岗记录集合
      */
-    public List<AttendancePostRecord> selectTodayRecordsByUserId(Long createBy, Long userId, Date today);
+    public List<AttendancePostRecord> selectTodayRecordsByUserId(Long createBy, Long userId, Date today, String locked);
 
     /**
      * 查询指定班次代码当天的上岗记录
@@ -156,4 +157,42 @@ public interface IAttendancePostRecordService {
      * @return 考勤日期
      */
     public Date selectMaxDateByUserId(Long createBy, Long userId);
+
+    /**
+     * 查询指定个人在指定时间段内的总工作时长
+     *
+     * @param userId    用户ID
+     * @param startTime 开始时间
+     * @param endTime   结束时间
+     * @return 个人总工作时长（分钟）
+     */
+    BigDecimal selectPersonalTotalWorkDurationInTimeRange(Long userId, Date startTime, Date endTime);
+
+    /**
+     * 查询站级别指定时间段内工作时长总和最高的时长
+     *
+     * @param startTime 开始时间
+     * @param endTime   结束时间
+     * @return 在岗记录列表
+     */
+    BigDecimal selectTopUserWorkDurationInTimeRange(Long userId, Date startTime, Date endTime);
+
+    /**
+     * 根据角色标识查询今日上岗用户列表
+     *
+     * @param date 考勤日期
+     * @param list 角色标识
+     * @return 用户列表
+     */
+    public List<SysUser> selectUserListByRoleKey(Date date, List<String> list);
+
+    /**
+     * 查询指定用户ID列表在指定时间段内的总工作时长
+     *
+     * @param list      用户ID列表
+     * @param startTime 开始时间
+     * @param endTime   结束时间
+     * @return 总工作时长（分钟）
+     */
+    BigDecimal selectTotalWorkDurationInTimeRange(List<Long> list, Date startTime, Date endTime);
 }

airport-attendance/src/main/java/com/sundot/airport/attendance/service/IAttendanceRecordService.java

@@ -2,6 +2,7 @@ package com.sundot.airport.attendance.service;
 
 import com.sundot.airport.attendance.domain.AttendanceCheckRecord;
 import com.sundot.airport.attendance.domain.AttendanceRecord;
+import com.sundot.airport.common.core.domain.entity.SysUser;
 import com.sundot.airport.common.dto.AttendanceRecordDTO;
 import com.sundot.airport.common.dto.AttendanceRecordRep;
 import com.sundot.airport.common.dto.AttendanceRecordReq;
@@ -97,4 +98,13 @@ public interface IAttendanceRecordService {
      * 查询可打卡类型:1=签到,2=签退
      */
     String getRecordType();
+
+    /**
+     * 根据角色标识查询今日打卡用户列表
+     *
+     * @param date 考勤日期
+     * @param list 角色标识
+     * @return 用户列表
+     */
+    public List<SysUser> selectUserListByRoleKey(Date date, List<String> list);
 }

airport-attendance/src/main/java/com/sundot/airport/attendance/service/IAttendanceTeamUserRecordService.java

@@ -18,7 +18,7 @@ public interface IAttendanceTeamUserRecordService {
      * @param userId 考勤班组成员主键
      * @return 考勤班组成员
      */
-    public AttendanceTeamUserRecord selectAttendanceTeamUserRecordByUserId(Long userId, Date attendanceDate);
+    public AttendanceTeamUserRecord selectAttendanceTeamUserRecordByUserId(Long userId, Date attendanceDate, String checkInType);
 
     /**
      * 查询考勤班组成员列表

airport-attendance/src/main/java/com/sundot/airport/attendance/service/impl/AttendancePostRecordServiceImpl.java

@@ -4,12 +4,14 @@ import cn.hutool.core.collection.CollectionUtil;
 import com.sundot.airport.attendance.domain.AttendancePostRecord;
 import com.sundot.airport.attendance.mapper.AttendancePostRecordMapper;
 import com.sundot.airport.attendance.service.IAttendancePostRecordService;
+import com.sundot.airport.common.core.domain.entity.SysUser;
 import com.sundot.airport.common.utils.DateUtils;
 import com.sundot.airport.common.utils.StringUtils;
 import com.sundot.airport.system.service.ISysConfigService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.math.BigDecimal;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -128,8 +130,8 @@ public class AttendancePostRecordServiceImpl implements IAttendancePostRecordSer
      * @return 上岗记录集合
      */
     @Override
-    public List<AttendancePostRecord> selectTodayRecordsByUserId(Long createBy, Long userId, Date today) {
-        return attendancePostRecordMapper.selectTodayRecordsByUserId(createBy, userId, today);
+    public List<AttendancePostRecord> selectTodayRecordsByUserId(Long createBy, Long userId, Date today, String locked) {
+        return attendancePostRecordMapper.selectTodayRecordsByUserId(createBy, userId, today, locked);
     }
 
     /**
@@ -306,4 +308,39 @@ public class AttendancePostRecordServiceImpl implements IAttendancePostRecordSer
     public Date selectMaxDateByUserId(Long createBy, Long userId) {
         return attendancePostRecordMapper.selectMaxDateByUserId(createBy, userId);
     }
+
+    @Override
+    public BigDecimal selectPersonalTotalWorkDurationInTimeRange(Long userId, Date startTime, Date endTime) {
+        return attendancePostRecordMapper.selectPersonalTotalWorkDurationInTimeRange(userId, startTime, endTime);
+    }
+
+    @Override
+    public BigDecimal selectTopUserWorkDurationInTimeRange(Long attendanceStationId, Date startTime, Date endTime) {
+        return attendancePostRecordMapper.selectTopUserWorkDurationInTimeRange(attendanceStationId, startTime, endTime);
+    }
+
+    /**
+     * 根据角色标识查询今日上岗用户列表
+     *
+     * @param date 考勤日期
+     * @param list 角色标识
+     * @return 用户列表
+     */
+    @Override
+    public List<SysUser> selectUserListByRoleKey(Date date, List<String> list) {
+        return attendancePostRecordMapper.selectUserListByRoleKey(date, "1", list);
+    }
+
+    /**
+     * 查询指定用户ID列表在指定时间段内的总工作时长
+     *
+     * @param list      用户ID列表
+     * @param startTime 开始时间
+     * @param endTime   结束时间
+     * @return 总工作时长（分钟）
+     */
+    @Override
+    public BigDecimal selectTotalWorkDurationInTimeRange(List<Long> list, Date startTime, Date endTime) {
+        return attendancePostRecordMapper.selectTotalWorkDurationInTimeRange(list, startTime, endTime);
+    }
 }

airport-attendance/src/main/java/com/sundot/airport/attendance/service/impl/AttendanceRecordServiceImpl.java

@@ -15,6 +15,7 @@ import com.sundot.airport.attendance.service.IAttendancePostRecordService;
 import com.sundot.airport.attendance.service.IAttendanceRecordService;
 import com.sundot.airport.attendance.service.IAttendanceTeamUserRecordService;
 import com.sundot.airport.common.core.domain.entity.SysRole;
+import com.sundot.airport.common.core.domain.entity.SysUser;
 import com.sundot.airport.common.dto.AttendanceRecordDTO;
 import com.sundot.airport.common.dto.AttendanceRecordRep;
 import com.sundot.airport.common.dto.AttendanceRecordReq;
@@ -618,4 +619,16 @@ public class AttendanceRecordServiceImpl implements IAttendanceRecordService {
         }
         return "2";
     }
+
+    /**
+     * 根据角色标识查询今日打卡用户列表
+     *
+     * @param date 考勤日期
+     * @param list 角色标识
+     * @return 用户列表
+     */
+    @Override
+    public List<SysUser> selectUserListByRoleKey(Date date, List<String> list) {
+        return attendanceRecordMapper.selectUserListByRoleKey(date, "1", list);
+    }
 }

airport-attendance/src/main/java/com/sundot/airport/attendance/service/impl/AttendanceTeamUserRecordServiceImpl.java

@@ -47,8 +47,8 @@ public class AttendanceTeamUserRecordServiceImpl implements IAttendanceTeamUserR
      * @return 考勤班组成员
      */
     @Override
-    public AttendanceTeamUserRecord selectAttendanceTeamUserRecordByUserId(Long userId, Date attendanceDate) {
-        return attendanceTeamUserRecordMapper.selectAttendanceTeamUserRecordByUserId(userId, attendanceDate);
+    public AttendanceTeamUserRecord selectAttendanceTeamUserRecordByUserId(Long userId, Date attendanceDate, String checkInType) {
+        return attendanceTeamUserRecordMapper.selectAttendanceTeamUserRecordByUserId(userId, attendanceDate, checkInType);
     }
 
     @Override

airport-attendance/src/main/resources/mapper/attendance/AttendancePostRecordMapper.xml

@@ -307,6 +307,9 @@
             <if test="today != null">
                 AND DATE(attendance_date) = DATE(#{today})
             </if>
+            <if test="locked != null">
+                and locked=#{locked}
+            </if>
         </where>
         ORDER BY check_in_time
     </select>
@@ -426,4 +429,61 @@
             </if>
         </where>
     </select>
+
+    <select id="selectPersonalTotalWorkDurationInTimeRange" resultType="java.math.BigDecimal">
+        SELECT COALESCE(SUM(work_duration), 0) as totalWorkDuration
+        FROM attendance_post_record
+        WHERE user_id = #{userId}
+          AND check_in_time &lt;= #{endTime}
+          AND check_out_time >= #{startTime}
+          AND work_duration IS NOT NULL
+          AND work_duration > 0
+    </select>
+
+    <select id="selectTopUserWorkDurationInTimeRange" resultType="java.math.BigDecimal">
+        select max(totalWorkDuration) as maxTotalWorkDuration
+        from (SELECT user_id as userId, SUM(work_duration) as totalWorkDuration
+              FROM attendance_post_record
+              WHERE attendance_station_id = #{attendanceStationId}
+                AND check_in_time &lt;= #{endTime}
+                AND check_out_time >= #{startTime}
+                AND work_duration IS NOT NULL
+                AND work_duration > 0
+              GROUP BY user_id) as user_durations
+    </select>
+
+    <select id="selectUserListByRoleKey" resultType="sysUser">
+        select distinct su.user_id userId,
+        su.user_name userName,
+        su.nick_name nickName
+        from attendance_post_record apr
+        inner join sys_user su on su.user_id = apr.user_id
+        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
+        where 1 = 1
+        <if test="date != null">
+            and date(apr.attendance_date) = date(#{date})
+        </if>
+        <if test="locked != null">
+            and apr.locked = #{locked}
+        </if>
+        and sr.role_key in
+        <foreach collection="list" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </select>
+
+    <select id="selectTotalWorkDurationInTimeRange" resultType="java.math.BigDecimal">
+        select coalesce(sum(work_duration), 0) as totalWorkDuration
+        from attendance_post_record
+        where user_id in
+        <foreach collection="list" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+        and check_in_time &lt;= #{endTime}
+        and check_out_time >= #{startTime}
+        and work_duration is not null
+        and work_duration > 0
+    </select>
+
 </mapper>

airport-attendance/src/main/resources/mapper/attendance/AttendanceRecordMapper.xml

@@ -204,4 +204,23 @@
             #{id}
         </foreach>
     </delete>
+
+    <select id="selectUserListByRoleKey" resultType="sysUser">
+        select distinct su.user_id userId,
+        su.user_name userName,
+        su.nick_name nickName
+        from attendance_record ar
+        inner join sys_user su on su.user_id = ar.user_id
+        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
+        where 1 = 1
+        <if test="date != null">
+            and date(ar.attendance_date) = date(#{date})
+        </if>
+        and sr.role_key in
+        <foreach collection="list" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </select>
+
 </mapper>

airport-attendance/src/main/resources/mapper/attendance/AttendanceTeamUserRecordMapper.xml

@@ -68,8 +68,11 @@
 
     <select id="selectAttendanceTeamUserRecordByUserId" resultMap="AttendanceTeamUserRecordResult">
         <include refid="selectAttendanceTeamUserRecordVo"/>
-        where user_id = #{userId}
-        and DATE(attendance_date) = DATE(#{attendanceDate})
+        where 1 = 1
+        <if test="userId != null ">and user_id = #{userId}</if>
+        <if test="attendanceDate != null ">and DATE(attendance_date) = DATE(#{attendanceDate})</if>
+        <if test="checkInType != null ">and check_in_type = #{checkInType}</if>
+        limit 1
     </select>
 
     <insert id="insertAttendanceTeamUserRecord" parameterType="AttendanceTeamUserRecord">

airport-common/src/main/java/com/sundot/airport/common/dto/AttendanceStatsResult.java

@@ -0,0 +1,28 @@
+package com.sundot.airport.common.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * 考勤统计数据返回对象
+ *
+ * @author ruoyi
+ */
+@Data
+public class AttendanceStatsResult {
+    // 安检员统计
+    @ApiModelProperty("安检员统计")
+    private SecurityCheckStats securityCheckStats;
+    // 班组统计
+    @ApiModelProperty("班组统计")
+    private TeamLeaderStats teamLeaderStats;
+    // 科室统计
+    @ApiModelProperty("科室统计")
+    private SectionLeaderStats sectionLeaderStats;
+    // 大队统计
+    @ApiModelProperty("大队统计")
+    private BrigadeLeaderStats brigadeLeaderStats;
+    // 站长统计
+    @ApiModelProperty("站长统计")
+    private StationLeaderStats stationLeaderStats;
+}

airport-common/src/main/java/com/sundot/airport/common/dto/BrigadeLeaderStats.java

@@ -0,0 +1,43 @@
+package com.sundot.airport.common.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * 经理/大队行政考勤统计数据对象
+ *
+ * @author ruoyi
+ */
+@Data
+public class BrigadeLeaderStats {
+    /**
+     * 在岗班组数量
+     */
+    @ApiModelProperty("在岗班组数量")
+    private String onDutyTeamCount;
+    /**
+     * 在岗人员数量
+     */
+    @ApiModelProperty("在岗人员数量")
+    private String onDutyPersonnelCount;
+    /**
+     * 通道开放统计
+     */
+    @ApiModelProperty("通道开放统计")
+    private ChannelOpenStats channelOpenStats;
+    /**
+     * 今日查获上报数量
+     */
+    @ApiModelProperty("今日查获上报数量")
+    private Integer todaySeizureReportCount;
+    /**
+     * 今日巡检问题数
+     */
+    @ApiModelProperty("今日巡检问题数")
+    private Integer todayCheckCorrectionCount;
+    /**
+     * 在岗大队
+     */
+    @ApiModelProperty("在岗大队")
+    private String dutyDeptName;
+}

airport-common/src/main/java/com/sundot/airport/common/dto/ChannelOpenStats.java

@@ -0,0 +1,14 @@
+package com.sundot.airport.common.dto;
+
+import lombok.Data;
+
+/**
+ * 通道开放统计对象
+ *
+ * @author ruoyi
+ */
+@Data
+public class ChannelOpenStats {
+    private Integer openChannels; // 开放通道数
+    private Integer totalChannels; // 总通道数
+}

airport-common/src/main/java/com/sundot/airport/common/dto/DutyScheduleGenerateReq.java

@@ -0,0 +1,93 @@
+package com.sundot.airport.common.dto;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+
+import java.util.Date;
+
+/**
+ * 排班计划生成请求参数对象
+ *
+ * @author wangxx
+ * @date 2026-01-23
+ */
+public class DutyScheduleGenerateReq {
+
+    /**
+     * 开始日期
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd", timezone = "GMT+8")
+    private Date startDate;
+
+    /**
+     * 开始部门ID
+     */
+    private Long startDeptId;
+
+    /**
+     * 部门列表，逗号分隔的部门ID
+     */
+    private String deptIds;
+
+    /**
+     * 班次安排，格式：9-17,17-9 或 9-9(跨天)
+     */
+    private String shifts;
+
+    /**
+     * 生成天数（默认365天）
+     */
+    private Integer daysToGenerate = 365;
+
+    /**
+     * 站级部门ID
+     */
+    private Long stationId;
+
+    public Date getStartDate() {
+        return startDate;
+    }
+
+    public void setStartDate(Date startDate) {
+        this.startDate = startDate;
+    }
+
+    public Long getStartDeptId() {
+        return startDeptId;
+    }
+
+    public void setStartDeptId(Long startDeptId) {
+        this.startDeptId = startDeptId;
+    }
+
+    public String getDeptIds() {
+        return deptIds;
+    }
+
+    public void setDeptIds(String deptIds) {
+        this.deptIds = deptIds;
+    }
+
+    public String getShifts() {
+        return shifts;
+    }
+
+    public void setShifts(String shifts) {
+        this.shifts = shifts;
+    }
+
+    public Integer getDaysToGenerate() {
+        return daysToGenerate;
+    }
+
+    public void setDaysToGenerate(Integer daysToGenerate) {
+        this.daysToGenerate = daysToGenerate;
+    }
+
+    public Long getStationId() {
+        return stationId;
+    }
+
+    public void setStationId(Long stationId) {
+        this.stationId = stationId;
+    }
+}

airport-common/src/main/java/com/sundot/airport/common/dto/SectionLeaderStats.java

@@ -0,0 +1,47 @@
+package com.sundot.airport.common.dto;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * 科长考勤统计数据对象
+ *
+ * @author ruoyi
+ */
+@Data
+public class SectionLeaderStats {
+    /**
+     * 出勤时间
+     */
+    @ApiModelProperty("出勤时间")
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    private Date attendanceTime;
+    /**
+     * 出勤时间提示
+     */
+    @ApiModelProperty("出勤时间提示(打卡/未打卡)")
+    private String attendanceTimeTips;
+    /**
+     * 在岗班组数量
+     */
+    @ApiModelProperty("在岗班组数量")
+    private String onDutyTeamCount;
+    /**
+     * 在岗人员数量
+     */
+    @ApiModelProperty("在岗人员数量")
+    private String onDutyPersonnelCount;
+    /**
+     * 今日查获上报数量
+     */
+    @ApiModelProperty("今日查获上报数量")
+    private Integer todaySeizureReportCount;
+    /**
+     * 今日巡检问题数
+     */
+    @ApiModelProperty("今日巡检问题数")
+    private Integer todayCheckCorrectionCount;
+}

airport-common/src/main/java/com/sundot/airport/common/dto/SecurityCheckStats.java

@@ -0,0 +1,29 @@
+package com.sundot.airport.common.dto;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * 安检员考勤统计数据对象
+ *
+ * @author ruoyi
+ */
+@Data
+public class SecurityCheckStats {
+    // 出勤班组
+    @ApiModelProperty("出勤班组")
+    private String attendanceTeamName;
+    // 出勤通道
+    @ApiModelProperty("出勤通道")
+    private String attendanceChannel;
+    // 出勤时间
+    @ApiModelProperty("出勤时间")
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    private Date attendanceTime;
+    // 出勤时间提示
+    @ApiModelProperty("出勤时间提示(打卡/未打卡)")
+    private String attendanceTimeTips;
+}

airport-common/src/main/java/com/sundot/airport/common/dto/StationLeaderStats.java

@@ -0,0 +1,43 @@
+package com.sundot.airport.common.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * 站长/质检科考勤统计数据对象
+ *
+ * @author ruoyi
+ */
+@Data
+public class StationLeaderStats {
+    /**
+     * 在岗班组数量
+     */
+    @ApiModelProperty("在岗班组数量")
+    private String onDutyTeamCount;
+    /**
+     * 在岗人员数量
+     */
+    @ApiModelProperty("在岗人员数量")
+    private String onDutyPersonnelCount;
+    /**
+     * 通道开放统计
+     */
+    @ApiModelProperty("通道开放统计")
+    private ChannelOpenStats channelOpenStats;
+    /**
+     * 今日查获上报数量
+     */
+    @ApiModelProperty("今日查获上报数量")
+    private Integer todaySeizureReportCount;
+    /**
+     * 今日巡检问题数
+     */
+    @ApiModelProperty("今日巡检问题数")
+    private Integer todayCheckCorrectionCount;
+    /**
+     * 在岗科室
+     */
+    @ApiModelProperty("在岗科室")
+    private String dutyDeptName;
+}

airport-common/src/main/java/com/sundot/airport/common/dto/TeamLeaderStats.java

@@ -0,0 +1,37 @@
+package com.sundot.airport.common.dto;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * 班组长考勤统计数据对象
+ *
+ * @author ruoyi
+ */
+@Data
+public class TeamLeaderStats {
+    /**
+     * 出勤班组
+     */
+    @ApiModelProperty("出勤班组")
+    private String attendanceTeamName;
+    /**
+     * 出勤通道
+     */
+    @ApiModelProperty("出勤通道")
+    private String attendanceChannel;
+    /**
+     * 出勤时间
+     */
+    @ApiModelProperty("出勤时间")
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    private Date attendanceTime;
+    /**
+     * 出勤时间提示
+     */
+    @ApiModelProperty("出勤时间提示(打卡/未打卡)")
+    private String attendanceTimeTips;
+}

airport-item/src/main/java/com/sundot/airport/item/controller/SimpleDutyScheduleController.java

@@ -0,0 +1,139 @@
+package com.sundot.airport.item.controller;
+
+import com.sundot.airport.common.annotation.Log;
+import com.sundot.airport.common.core.controller.BaseController;
+import com.sundot.airport.common.core.domain.AjaxResult;
+import com.sundot.airport.common.core.domain.entity.SysDept;
+import com.sundot.airport.common.core.page.TableDataInfo;
+import com.sundot.airport.common.dto.DutyScheduleGenerateReq;
+import com.sundot.airport.common.enums.BusinessType;
+import com.sundot.airport.common.utils.poi.ExcelUtil;
+import com.sundot.airport.item.domain.SimpleDutySchedule;
+import com.sundot.airport.item.service.ISimpleDutyScheduleService;
+import com.sundot.airport.system.service.ISysDeptService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.DeleteMapping;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.PutMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * 值班安排Controller
+ *
+ * @author wangxx
+ * @date 2026-01-14
+ */
+@RestController
+@RequestMapping("/item/simpleDutySchedule")
+public class SimpleDutyScheduleController extends BaseController {
+    @Autowired
+    private ISimpleDutyScheduleService simpleDutyScheduleService;
+    @Autowired
+    private ISysDeptService sysDeptService;
+
+    /**
+     * 查询值班安排列表
+     */
+    @GetMapping("/list")
+    public TableDataInfo list(SimpleDutySchedule simpleDutySchedule) {
+        startPage();
+        List<SimpleDutySchedule> list = simpleDutyScheduleService.selectSimpleDutyScheduleList(simpleDutySchedule);
+        return getDataTable(list);
+    }
+
+    /**
+     * 导出值班安排列表
+     */
+    @Log(title = "值班安排", businessType = BusinessType.EXPORT)
+    @PostMapping("/export")
+    public AjaxResult export(SimpleDutySchedule simpleDutySchedule) {
+        List<SimpleDutySchedule> list = simpleDutyScheduleService.selectSimpleDutyScheduleList(simpleDutySchedule);
+        ExcelUtil<SimpleDutySchedule> util = new ExcelUtil<SimpleDutySchedule>(SimpleDutySchedule.class);
+        return util.exportExcel(list, "值班安排数据");
+    }
+
+
+    /**
+     * 新增值班安排
+     */
+    @Log(title = "值班安排", businessType = BusinessType.INSERT)
+    @PostMapping
+    public AjaxResult add(@RequestBody SimpleDutySchedule simpleDutySchedule) {
+        return toAjax(simpleDutyScheduleService.insertSimpleDutySchedule(simpleDutySchedule));
+    }
+
+    /**
+     * 修改值班安排
+     */
+    @Log(title = "值班安排", businessType = BusinessType.UPDATE)
+    @PutMapping
+    public AjaxResult edit(@RequestBody SimpleDutySchedule simpleDutySchedule) {
+        return toAjax(simpleDutyScheduleService.updateSimpleDutySchedule(simpleDutySchedule));
+    }
+
+    /**
+     * 删除值班安排
+     */
+    @Log(title = "值班安排", businessType = BusinessType.DELETE)
+    @DeleteMapping("/{scheduleIds}")
+    public AjaxResult remove(@PathVariable Long[] scheduleIds) {
+        return toAjax(simpleDutyScheduleService.deleteSimpleDutyScheduleByIds(scheduleIds));
+    }
+
+
+    /**
+     * 生成统一排班计划（支持单班、两班倒、多班倒等模式）
+     *
+     * @param req 排班计划生成请求参数
+     */
+    @Log(title = "生成统一排班计划", businessType = BusinessType.INSERT)
+    @PostMapping("/generateUnifiedSchedule")
+    public AjaxResult generateUnifiedSchedule(@RequestBody DutyScheduleGenerateReq req) {
+        // 查询循环部门
+        String[] deptParts = req.getDeptIds().split(",");
+        List<SysDept> departmentList = new ArrayList<>();
+        SysDept startDepartment = new SysDept();
+        for (String deptId : deptParts) {
+            long id = Long.parseLong(deptId);
+            //根据部门id 查询部门信息
+            SysDept dept = sysDeptService.selectDeptById(id);
+            departmentList.add(dept);
+            if (id == req.getStartDeptId()) {
+                startDepartment = dept;
+            }
+        }
+
+        // 解析班次安排字符串，格式："9-17,17-9" 或 "9-9"（跨天）
+        String[] shiftPairs = req.getShifts().split(",");
+        int[][] shiftsArray = new int[shiftPairs.length][2];
+
+        for (int i = 0; i < shiftPairs.length; i++) {
+            String[] times = shiftPairs[i].split("-");
+            if (times.length != 2) {
+                throw new IllegalArgumentException("班次格式错误，应为 HH-HH 格式，如 9-17");
+            }
+            shiftsArray[i][0] = Integer.parseInt(times[0]); // 开始时间
+            shiftsArray[i][1] = Integer.parseInt(times[1]); // 结束时间
+        }
+
+        SysDept stationDepartment = sysDeptService.selectDeptById(req.getStationId());
+
+        List<SimpleDutySchedule> scheduleList = simpleDutyScheduleService.generateUnifiedSchedule(
+                req.getStartDate(), startDepartment, departmentList, shiftsArray, req.getDaysToGenerate(), stationDepartment);
+
+        // 批量插入或更新排班安排（如果已存在则覆盖）
+        int successCount = 0;
+        if (!scheduleList.isEmpty()) {
+            successCount = simpleDutyScheduleService.batchInsertOrUpdateSimpleDutySchedule(scheduleList);
+        }
+
+        return AjaxResult.success("成功生成 " + successCount + " 条排班安排");
+    }
+}

airport-item/src/main/java/com/sundot/airport/item/domain/SimpleDutySchedule.java

@@ -0,0 +1,185 @@
+package com.sundot.airport.item.domain;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.sundot.airport.common.core.domain.BaseEntity;
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+
+import java.util.Date;
+
+/**
+ * 简化值班安排对象
+ *
+ * @author sundot
+ * @date 2026-01-14
+ */
+public class SimpleDutySchedule extends BaseEntity {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键ID
+     */
+    private Long id;
+
+    /**
+     * 站点ID
+     */
+    private Long stationId;
+
+    /**
+     * 站点名称
+     */
+    private String stationName;
+
+    /**
+     * 部门ID
+     */
+    private Long departmentId;
+
+    /**
+     * 部门名称
+     */
+    private String departmentName;
+
+    /**
+     * 值班日期
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    private Date dutyDate;
+
+    /**
+     * 开始时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    private Date startTime;
+
+    /**
+     * 结束时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+    private Date endTime;
+
+    /**
+     * 是否跨天（1跨天，0不跨天）
+     */
+    private Integer crossDay;
+
+    /**
+     * 状态（0正常 1停用）
+     */
+    private String status;
+
+    /**
+     * 备注
+     */
+    private String remark;
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public String getStationName() {
+        return stationName;
+    }
+
+    public void setStationName(String stationName) {
+        this.stationName = stationName;
+    }
+
+    public Long getStationId() {
+        return stationId;
+    }
+
+    public void setStationId(Long stationId) {
+        this.stationId = stationId;
+    }
+
+    public String getDepartmentName() {
+        return departmentName;
+    }
+
+    public void setDepartmentName(String departmentName) {
+        this.departmentName = departmentName;
+    }
+
+    public Long getDepartmentId() {
+        return departmentId;
+    }
+
+    public void setDepartmentId(Long departmentId) {
+        this.departmentId = departmentId;
+    }
+
+    public Date getDutyDate() {
+        return dutyDate;
+    }
+
+    public void setDutyDate(Date dutyDate) {
+        this.dutyDate = dutyDate;
+    }
+
+    public Date getStartTime() {
+        return startTime;
+    }
+
+    public void setStartTime(Date startTime) {
+        this.startTime = startTime;
+    }
+
+    public Date getEndTime() {
+        return endTime;
+    }
+
+    public void setEndTime(Date endTime) {
+        this.endTime = endTime;
+    }
+
+    public Integer getCrossDay() {
+        return crossDay;
+    }
+
+    public void setCrossDay(Integer crossDay) {
+        this.crossDay = crossDay;
+    }
+
+    public String getStatus() {
+        return status;
+    }
+
+    public void setStatus(String status) {
+        this.status = status;
+    }
+
+    public String getRemark() {
+        return remark;
+    }
+
+    public void setRemark(String remark) {
+        this.remark = remark;
+    }
+
+    @Override
+    public String toString() {
+        return new ToStringBuilder(this, ToStringStyle.MULTI_LINE_STYLE)
+                .append("id", getId())
+                .append("stationId", getStationId())
+                .append("stationName", getStationName())
+                .append("departmentId", getDepartmentId())
+                .append("departmentName", getDepartmentName())
+                .append("dutyDate", getDutyDate())
+                .append("startTime", getStartTime())
+                .append("endTime", getEndTime())
+                .append("crossDay", getCrossDay())
+                .append("status", getStatus())
+                .append("createBy", getCreateBy())
+                .append("createTime", getCreateTime())
+                .append("updateBy", getUpdateBy())
+                .append("updateTime", getUpdateTime())
+                .append("remark", getRemark())
+                .toString();
+    }
+}

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

@@ -0,0 +1,85 @@
+package com.sundot.airport.item.mapper;
+
+import com.sundot.airport.item.domain.SimpleDutySchedule;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * 值班安排Mapper接口
+ *
+ * @author wangxx
+ * @date 2026-01-14
+ */
+public interface SimpleDutyScheduleMapper {
+    /**
+     * 查询值班安排
+     *
+     * @param id 排班ID
+     * @return 值班安排
+     */
+    public SimpleDutySchedule selectSimpleDutyScheduleByScheduleId(Long id);
+
+    /**
+     * 查询值班安排列表
+     *
+     * @param simpleDutySchedule 值班安排
+     * @return 值班安排集合
+     */
+    public List<SimpleDutySchedule> selectSimpleDutyScheduleList(SimpleDutySchedule simpleDutySchedule);
+
+    /**
+     * 根据日期查询值班安排
+     *
+     * @param dutyDate 值班日期
+     * @return 值班安排
+     */
+    public SimpleDutySchedule selectSimpleDutyScheduleByDate(Date dutyDate);
+
+    /**
+     * 根据站点和日期查询值班安排
+     *
+     * @return 值班安排
+     */
+    public SimpleDutySchedule selectSimpleDutyScheduleByStationAndDate(SimpleDutySchedule simpleDutySchedule);
+
+    /**
+     * 新增值班安排
+     *
+     * @param simpleDutySchedule 值班安排
+     * @return 结果
+     */
+    public int insertSimpleDutySchedule(SimpleDutySchedule simpleDutySchedule);
+
+    /**
+     * 修改值班安排
+     *
+     * @param simpleDutySchedule 值班安排
+     * @return 结果
+     */
+    public int updateSimpleDutySchedule(SimpleDutySchedule simpleDutySchedule);
+
+    /**
+     * 删除值班安排
+     *
+     * @param scheduleId 排班ID
+     * @return 结果
+     */
+    public int deleteSimpleDutyScheduleByScheduleId(Long scheduleId);
+
+    /**
+     * 批量删除值班安排
+     *
+     * @param scheduleIds 需要删除的数据ID
+     * @return 结果
+     */
+    public int deleteSimpleDutyScheduleByScheduleIds(Long[] scheduleIds);
+
+    /**
+     * 批量新增值班安排信息
+     *
+     * @param simpleDutyScheduleList 值班安排列表
+     * @return 结果
+     */
+    public int batchInsertSimpleDutySchedule(List<SimpleDutySchedule> simpleDutyScheduleList);
+}

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

@@ -0,0 +1,95 @@
+package com.sundot.airport.item.service;
+
+import com.sundot.airport.common.core.domain.entity.SysDept;
+import com.sundot.airport.item.domain.SimpleDutySchedule;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * 值班安排 服务层
+ *
+ * @author wangxx
+ * @date 2026-01-14
+ */
+public interface ISimpleDutyScheduleService {
+
+    /**
+     * 查询值班安排列表
+     *
+     * @param simpleDutySchedule 值班安排信息
+     * @return 值班安排集合
+     */
+    public List<SimpleDutySchedule> selectSimpleDutyScheduleList(SimpleDutySchedule simpleDutySchedule);
+
+    /**
+     * 根据日期查询值班安排
+     *
+     * @param dutyDate 值班日期
+     * @return 值班安排
+     */
+    public SimpleDutySchedule selectSimpleDutyScheduleByDate(Date dutyDate);
+
+
+    /**
+     * 新增值班安排
+     *
+     * @param simpleDutySchedule 值班安排信息
+     * @return 结果
+     */
+    public int insertSimpleDutySchedule(SimpleDutySchedule simpleDutySchedule);
+
+    /**
+     * 修改值班安排
+     *
+     * @param simpleDutySchedule 值班安排信息
+     * @return 结果
+     */
+    public int updateSimpleDutySchedule(SimpleDutySchedule simpleDutySchedule);
+
+    /**
+     * 批量删除值班安排信息
+     *
+     * @param scheduleIds 需要删除的排班ID
+     * @return 结果
+     */
+    public int deleteSimpleDutyScheduleByIds(Long[] scheduleIds);
+
+    /**
+     * 批量新增值班安排信息
+     *
+     * @param simpleDutyScheduleList 值班安排列表
+     * @return 结果
+     */
+    public int batchInsertSimpleDutySchedule(List<SimpleDutySchedule> simpleDutyScheduleList);
+
+    /**
+     * 批量插入或更新值班安排（对列表中的每条记录执行插入或更新操作）
+     *
+     * @param simpleDutyScheduleList 值班安排列表
+     * @return 成功处理的记录总数
+     */
+    public int batchInsertOrUpdateSimpleDutySchedule(List<SimpleDutySchedule> simpleDutyScheduleList);
+
+    /**
+     * 插入或更新单条值班安排（先尝试更新，如果不存在则插入）
+     *
+     * @param simpleDutySchedule 值班安排信息
+     * @return 结果
+     */
+    public int insertOrUpdateSimpleDutySchedule(SimpleDutySchedule simpleDutySchedule);
+
+
+    /**
+     * 生成统一排班计划（支持单班、两班倒、多班倒等模式）
+     *
+     * @param startDate         起始日期
+     * @param startDepartment   起始部门对象，包含部门ID和名称
+     * @param departments       部门信息列表，包含部门ID和名称
+     * @param shifts            班次安排数组，每个元素包含[startHour, endHour]
+     * @param daysToGenerate    生成天数
+     * @param stationDepartment 站点部门对象，包含站点ID和名称
+     * @return SimpleDutySchedule列表
+     */
+    public List<SimpleDutySchedule> generateUnifiedSchedule(Date startDate, SysDept startDepartment, List<SysDept> departments, int[][] shifts, int daysToGenerate, SysDept stationDepartment);
+}

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

@@ -0,0 +1,154 @@
+package com.sundot.airport.item.service.impl;
+
+import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
+import com.sundot.airport.common.core.domain.entity.SysDept;
+import com.sundot.airport.common.core.domain.model.LoginUser;
+import com.sundot.airport.common.utils.SecurityUtils;
+import com.sundot.airport.item.domain.SimpleDutySchedule;
+import com.sundot.airport.item.mapper.SimpleDutyScheduleMapper;
+import com.sundot.airport.item.service.ISimpleDutyScheduleService;
+import com.sundot.airport.item.utils.UnifiedDutyScheduler;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * 值班安排 服务层实现
+ *
+ * @author wangxx
+ * @date 2026-01-14
+ */
+@Service
+public class SimpleDutyScheduleServiceImpl implements ISimpleDutyScheduleService {
+    @Autowired
+    private SimpleDutyScheduleMapper simpleDutyScheduleMapper;
+
+    /**
+     * 查询值班安排列表
+     *
+     * @param simpleDutySchedule 值班安排信息
+     * @return 值班安排集合
+     */
+    @Override
+    public List<SimpleDutySchedule> selectSimpleDutyScheduleList(SimpleDutySchedule simpleDutySchedule) {
+        return simpleDutyScheduleMapper.selectSimpleDutyScheduleList(simpleDutySchedule);
+    }
+
+    /**
+     * 根据日期查询值班安排
+     *
+     * @param dutyDate 值班日期
+     * @return 值班安排
+     */
+    @Override
+    public SimpleDutySchedule selectSimpleDutyScheduleByDate(Date dutyDate) {
+        return simpleDutyScheduleMapper.selectSimpleDutyScheduleByDate(dutyDate);
+    }
+
+
+    /**
+     * 新增值班安排
+     *
+     * @param simpleDutySchedule 值班安排信息
+     * @return 结果
+     */
+    @Override
+    public int insertSimpleDutySchedule(SimpleDutySchedule simpleDutySchedule) {
+        return simpleDutyScheduleMapper.insertSimpleDutySchedule(simpleDutySchedule);
+    }
+
+    /**
+     * 修改值班安排
+     *
+     * @param simpleDutySchedule 值班安排信息
+     * @return 结果
+     */
+    @Override
+    public int updateSimpleDutySchedule(SimpleDutySchedule simpleDutySchedule) {
+        return simpleDutyScheduleMapper.updateSimpleDutySchedule(simpleDutySchedule);
+    }
+
+    /**
+     * 批量删除值班安排对象
+     *
+     * @param scheduleIds 需要删除的数据ID
+     * @return 结果
+     */
+    @Override
+    public int deleteSimpleDutyScheduleByIds(Long[] scheduleIds) {
+        return simpleDutyScheduleMapper.deleteSimpleDutyScheduleByScheduleIds(scheduleIds);
+    }
+
+    /**
+     * 批量新增值班安排信息
+     *
+     * @param simpleDutyScheduleList 值班安排列表
+     * @return 结果
+     */
+    @Override
+    public int batchInsertSimpleDutySchedule(List<SimpleDutySchedule> simpleDutyScheduleList) {
+        return simpleDutyScheduleMapper.batchInsertSimpleDutySchedule(simpleDutyScheduleList);
+    }
+
+    /**
+     * 插入或更新单条值班安排（先尝试更新，如果不存在则插入）
+     *
+     * @param simpleDutySchedule 值班安排信息
+     * @return 结果
+     */
+    @Override
+    public int insertOrUpdateSimpleDutySchedule(SimpleDutySchedule simpleDutySchedule) {
+        // 首先检查是否存在符合条件的记录
+        SimpleDutySchedule existingRecord = simpleDutyScheduleMapper.selectSimpleDutyScheduleByStationAndDate(simpleDutySchedule);
+
+        if (existingRecord != null) {
+            // 如果存在，则更新现有记录
+            simpleDutySchedule.setId(existingRecord.getId());
+            return simpleDutyScheduleMapper.updateSimpleDutySchedule(simpleDutySchedule);
+        } else {
+            // 如果不存在，则插入新记录
+            return simpleDutyScheduleMapper.insertSimpleDutySchedule(simpleDutySchedule);
+        }
+    }
+
+
+    /**
+     * 批量插入或更新值班安排（对列表中的每条记录执行插入或更新操作）
+     *
+     * @param simpleDutyScheduleList 值班安排列表
+     * @return 成功处理的记录总数
+     */
+    @Override
+    public int batchInsertOrUpdateSimpleDutySchedule(List<SimpleDutySchedule> simpleDutyScheduleList) {
+        int successCount = 0;
+        LoginUser loginUser = SecurityUtils.getLoginUser();
+        for (SimpleDutySchedule schedule : simpleDutyScheduleList) {
+            //当前登录人
+            schedule.setCreateBy(ObjectUtils.isEmpty(loginUser) ? "admin" : loginUser.getUsername());
+            schedule.setCreateTime(new Date());
+            int result = insertOrUpdateSimpleDutySchedule(schedule);
+            if (result > 0) {
+                successCount++;
+            }
+        }
+        return successCount;
+    }
+
+    /**
+     * 生成统一排班计划（支持单班、两班倒、多班倒等模式）
+     *
+     * @param startDate         起始日期
+     * @param startDepartment   起始部门对象，包含部门ID和名称
+     * @param departments       部门信息列表，包含部门ID和名称
+     * @param shifts            班次安排数组，每个元素包含[startHour, endHour]
+     * @param daysToGenerate    生成天数
+     * @param stationDepartment 站点部门对象，包含站点ID和名称
+     * @return SimpleDutySchedule列表
+     */
+    @Override
+    public List<SimpleDutySchedule> generateUnifiedSchedule(Date startDate, SysDept startDepartment, List<SysDept> departments, int[][] shifts, int daysToGenerate, SysDept stationDepartment) {
+        return UnifiedDutyScheduler.generateUnifiedSchedule(startDate, startDepartment, departments, shifts, daysToGenerate, stationDepartment);
+    }
+}

airport-item/src/main/java/com/sundot/airport/item/utils/UnifiedDutyScheduler.java

@@ -0,0 +1,158 @@
+package com.sundot.airport.item.utils;
+
+import com.sundot.airport.common.core.domain.entity.SysDept;
+import com.sundot.airport.item.domain.SimpleDutySchedule;
+
+import java.util.ArrayList;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * 统一值班排班调度器
+ * 支持多种排班模式：
+ * 1. 单班模式：如9点到次日9点（24小时值班）
+ * 2. 两班倒模式：如9-17, 17-9
+ *
+ * @author wangxx
+ * @date 2026-01-14
+ */
+public class UnifiedDutyScheduler {
+
+    /**
+     * 生成统一排班计划
+     *
+     * @param startDate         起始日期
+     * @param startDepartment   起始部门
+     * @param departments       循环排岗部门信息列表
+     * @param shifts            班次安排数组，每个元素包含[startHour, endHour]
+     * @param daysToGenerate    生成天数
+     * @param stationDepartment 站点部门对象，包含站点ID和名称
+     * @return SimpleDutySchedule列表
+     */
+    public static List<SimpleDutySchedule> generateUnifiedSchedule(Date startDate, SysDept startDepartment, List<SysDept> departments, int[][] shifts, int daysToGenerate, SysDept stationDepartment) {
+        List<SimpleDutySchedule> scheduleList = new ArrayList<>();
+
+        // 提取部门名称数组和部门ID数组
+        String[] deptNames = departments.stream()
+                .map(SysDept::getDeptName)
+                .toArray(String[]::new);
+        Long[] departmentIds = departments.stream()
+                .map(SysDept::getDeptId)
+                .toArray(Long[]::new);
+
+        // 验证部门ID数组长度是否与部门名称数组一致
+        if (departmentIds != null && departmentIds.length != deptNames.length) {
+            throw new IllegalArgumentException("部门ID数组长度与部门名称数组长度不匹配");
+        }
+
+        // 获取起始部门名称
+        String startDeptName = startDepartment != null ? startDepartment.getDeptName() : null;
+
+        if (startDeptName == null) {
+            throw new IllegalArgumentException("未找到指定的起始部门名称");
+        }
+
+        // 找到起始科室的索引
+        int startIndex = -1;
+        for (int i = 0; i < deptNames.length; i++) {
+            if (deptNames[i].equals(startDeptName)) {
+                startIndex = i;
+                break;
+            }
+        }
+
+        if (startIndex == -1) {
+            throw new IllegalArgumentException("未找到指定的起始科室: " + startDeptName);
+        }
+
+        // 从起始日期开始生成排班
+        Calendar calendar = Calendar.getInstance();
+        calendar.setTime(startDate);
+
+        int currentDeptIndex = startIndex;
+
+        // 计算总的班次数
+        int totalShifts = daysToGenerate * shifts.length;
+
+        for (int i = 0; i < totalShifts; i++) {
+            // 确定当前是哪一天的第几个班次
+            int dayIndex = i / shifts.length; // 第几天
+            int shiftIndex = i % shifts.length; // 当天的第几个班次
+
+            // 获取班次信息 [startHour, endHour]
+            int[] shift = shifts[shiftIndex];
+            int startTime = shift[0];
+            int endTime = shift[1];
+
+            // 计算班次日期
+            Calendar shiftCalendar = (Calendar) calendar.clone();
+            shiftCalendar.add(Calendar.DAY_OF_MONTH, dayIndex);
+
+            // 判断是否跨天
+            boolean isCrossDay = false;
+            if (startTime > endTime) {
+                // 如果开始时间大于结束时间，说明跨天，例如22点到次日6点
+                isCrossDay = true;
+            } else if (startTime == endTime && shifts.length == 1) {
+                // 对于24小时连续值班情况，如9点到次日9点，由于是一整天(24小时)值班，所以肯定跨天
+                isCrossDay = true;
+            }
+
+            // 确定当前班次的科室
+            int deptIndex = (currentDeptIndex + shiftIndex) % deptNames.length; // 同一天内不同班次也轮换科室
+
+            // 创建班次安排
+            SimpleDutySchedule shiftSchedule = new SimpleDutySchedule();
+            shiftSchedule.setStationId(stationDepartment.getDeptId());
+            shiftSchedule.setStationName(stationDepartment.getDeptName());
+
+            if (departmentIds != null && departmentIds.length > deptIndex) {
+                shiftSchedule.setDepartmentId(departmentIds[deptIndex]);
+
+                // 使用部门信息列表中的名称
+                SysDept dept = departments.get(deptIndex);
+                if (dept != null) {
+                    shiftSchedule.setDepartmentName(dept.getDeptName());
+                } else {
+                    shiftSchedule.setDepartmentName(deptNames[deptIndex]); // fallback to name array
+                }
+            } else {
+                shiftSchedule.setDepartmentName(deptNames[deptIndex]);
+            }
+            shiftSchedule.setDutyDate(shiftCalendar.getTime());
+
+            // 设置完整的开始时间
+            Calendar startCal = (Calendar) shiftCalendar.clone();
+            startCal.set(Calendar.HOUR_OF_DAY, startTime);
+            startCal.set(Calendar.MINUTE, 0);
+            startCal.set(Calendar.SECOND, 0);
+            startCal.set(Calendar.MILLISECOND, 0);
+            shiftSchedule.setStartTime(startCal.getTime());
+
+            // 设置完整的结束时间
+            Calendar endCal = (Calendar) shiftCalendar.clone();
+            if (isCrossDay) {
+                endCal.add(Calendar.DAY_OF_MONTH, 1);
+            }
+            endCal.set(Calendar.HOUR_OF_DAY, endTime);
+            endCal.set(Calendar.MINUTE, 0);
+            endCal.set(Calendar.SECOND, 0);
+            endCal.set(Calendar.MILLISECOND, 0);
+            shiftSchedule.setEndTime(endCal.getTime());
+
+            shiftSchedule.setCrossDay(isCrossDay ? 1 : 0);
+            shiftSchedule.setStatus("0");
+            scheduleList.add(shiftSchedule);
+
+            // 根据班次安排模式决定何时轮换科室
+            if (shiftIndex == shifts.length - 1) {
+                // 每天结束后轮换科室
+                currentDeptIndex = (currentDeptIndex + 1) % deptNames.length;
+            }
+        }
+
+        return scheduleList;
+    }
+
+}

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

@@ -0,0 +1,154 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.sundot.airport.item.mapper.SimpleDutyScheduleMapper">
+
+    <resultMap type="SimpleDutySchedule" id="SimpleDutyScheduleResult">
+        <result property="id" column="id"/>
+        <result property="stationId" column="station_id"/>
+        <result property="stationName" column="station_name"/>
+        <result property="departmentId" column="department_id"/>
+        <result property="departmentName" column="department_name"/>
+        <result property="dutyDate" column="duty_date"/>
+        <result property="startTime" column="start_time"/>
+        <result property="endTime" column="end_time"/>
+        <result property="crossDay" column="cross_day"/>
+        <result property="status" column="status"/>
+        <result property="createBy" column="create_by"/>
+        <result property="createTime" column="create_time"/>
+        <result property="updateBy" column="update_by"/>
+        <result property="updateTime" column="update_time"/>
+        <result property="remark" column="remark"/>
+    </resultMap>
+
+    <sql id="selectSimpleDutyScheduleVo">
+        select id,
+               station_id,
+               station_name,
+               department_id,
+               department_name,
+               duty_date,
+               start_time,
+               end_time,
+               cross_day,
+               status,
+               create_by,
+               create_time,
+               update_by,
+               update_time,
+               remark
+        from simple_duty_schedule
+    </sql>
+
+    <select id="selectSimpleDutyScheduleByScheduleId" parameterType="Long" resultMap="SimpleDutyScheduleResult">
+        <include refid="selectSimpleDutyScheduleVo"/>
+        where id = #{id}
+    </select>
+
+    <select id="selectSimpleDutyScheduleList" parameterType="SimpleDutySchedule" resultMap="SimpleDutyScheduleResult">
+        <include refid="selectSimpleDutyScheduleVo"/>
+        <where>
+            <if test="stationName != null  and stationName != ''">and station_name = #{stationName}</if>
+            <if test="departmentName != null  and departmentName != ''">and department_name = #{departmentName}</if>
+            <if test="dutyDate != null ">and duty_date = #{dutyDate}</if>
+            <if test="startTime != null ">and start_time >= #{startTime}</if>
+            <if test="endTime != null ">and end_time &lt;= #{endTime}</if>
+            <if test="crossDay != null ">and cross_day = #{crossDay}</if>
+            <if test="status != null  and status != ''">and status = #{status}</if>
+        </where>
+        order by duty_date asc
+    </select>
+
+    <select id="selectSimpleDutyScheduleByDate" parameterType="Date" resultMap="SimpleDutyScheduleResult">
+        <include refid="selectSimpleDutyScheduleVo"/>
+        where start_time &lt;= #{dutyDate} and end_time >= #{dutyDate}
+    </select>
+
+    <select id="selectSimpleDutyScheduleByStationAndDate" resultMap="SimpleDutyScheduleResult">
+        <include refid="selectSimpleDutyScheduleVo"/>
+        where station_id = #{stationId} and department_id = #{departmentId} and duty_date = #{dutyDate}
+    </select>
+
+    <insert id="insertSimpleDutySchedule" parameterType="SimpleDutySchedule" useGeneratedKeys="true" keyProperty="id">
+        insert into simple_duty_schedule
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="stationId != null">station_id,</if>
+            <if test="stationName != null and stationName != ''">station_name,</if>
+            <if test="departmentId != null">department_id,</if>
+            <if test="departmentName != null and departmentName != ''">department_name,</if>
+            <if test="dutyDate != null">duty_date,</if>
+            <if test="startTime != null">start_time,</if>
+            <if test="endTime != null">end_time,</if>
+            <if test="crossDay != null">cross_day,</if>
+            <if test="status != null and status != ''">status,</if>
+            <if test="createBy != null and createBy != ''">create_by,</if>
+            <if test="createTime != null">create_time,</if>
+            <if test="updateBy != null and updateBy != ''">update_by,</if>
+            <if test="updateTime != null">update_time,</if>
+            <if test="remark != null and remark != ''">remark,</if>
+        </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="stationId != null">#{stationId},</if>
+            <if test="stationName != null and stationName != ''">#{stationName},</if>
+            <if test="departmentId != null">#{departmentId},</if>
+            <if test="departmentName != null and departmentName != ''">#{departmentName},</if>
+            <if test="dutyDate != null">#{dutyDate},</if>
+            <if test="startTime != null">#{startTime},</if>
+            <if test="endTime != null">#{endTime},</if>
+            <if test="crossDay != null">#{crossDay},</if>
+            <if test="status != null and status != ''">#{status},</if>
+            <if test="createBy != null and createBy != ''">#{createBy},</if>
+            <if test="createTime != null">#{createTime},</if>
+            <if test="updateBy != null and updateBy != ''">#{updateBy},</if>
+            <if test="updateTime != null">#{updateTime},</if>
+            <if test="remark != null and remark != ''">#{remark},</if>
+        </trim>
+    </insert>
+
+    <update id="updateSimpleDutySchedule" parameterType="SimpleDutySchedule">
+        update simple_duty_schedule
+        <trim prefix="SET" suffixOverrides=",">
+            <if test="stationId != null">station_id = #{stationId},</if>
+            <if test="stationName != null and stationName != ''">station_name = #{stationName},</if>
+            <if test="departmentId != null">department_id = #{departmentId},</if>
+            <if test="departmentName != null and departmentName != ''">department_name = #{departmentName},</if>
+            <if test="dutyDate != null">duty_date = #{dutyDate},</if>
+            <if test="startTime != null">start_time = #{startTime},</if>
+            <if test="endTime != null">end_time = #{endTime},</if>
+            <if test="crossDay != null">cross_day = #{crossDay},</if>
+            <if test="status != null and status != ''">status = #{status},</if>
+            <if test="updateBy != null and updateBy != ''">update_by = #{updateBy},</if>
+            <if test="updateTime != null">update_time = #{updateTime},</if>
+            <if test="remark != null and remark != ''">remark = #{remark},</if>
+        </trim>
+        where id = #{id}
+    </update>
+
+    <delete id="deleteSimpleDutyScheduleByScheduleId" parameterType="Long">
+        delete
+        from simple_duty_schedule
+        where id = #{id}
+    </delete>
+
+    <delete id="deleteSimpleDutyScheduleByScheduleIds" parameterType="String">
+        delete from simple_duty_schedule where id in
+        <foreach item="id" collection="array" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </delete>
+
+
+    <insert id="batchInsertSimpleDutySchedule" parameterType="SimpleDutySchedule">
+        insert into simple_duty_schedule
+        (station_id, station_name, department_id, department_name, duty_date, start_time, end_time,
+        cross_day, status, create_by, create_time, update_by, update_time, remark)
+        values
+        <foreach item="item" collection="list" separator=",">
+            (#{item.stationId}, #{item.stationName}, #{item.departmentId}, #{item.departmentName},
+            #{item.dutyDate}, #{item.startTime}, #{item.endTime}, #{item.crossDay}, #{item.status},
+            #{item.createBy}, #{item.createTime}, #{item.updateBy}, #{item.updateTime}, #{item.remark})
+        </foreach>
+    </insert>
+
+</mapper>