From 531b50cab6e42e6146a419bc71c5b494fff774b2 Mon Sep 17 00:00:00 2001
From: tuqin <tuqin@tuqin.cn>
Date: 星期二, 27 十月 2026 09:48:33 +0800
Subject: [PATCH] feat(hrm): 考勤规则支持 Excel 导入;修复定位打卡测试类编译错误

---
 yudao-module-hrm/src/main/java/cn/iocoder/yudao/module/hrm/service/attendance/HrmAttendanceRuleServiceImpl.java |   94 +++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 94 insertions(+), 0 deletions(-)

diff --git a/yudao-module-hrm/src/main/java/cn/iocoder/yudao/module/hrm/service/attendance/HrmAttendanceRuleServiceImpl.java b/yudao-module-hrm/src/main/java/cn/iocoder/yudao/module/hrm/service/attendance/HrmAttendanceRuleServiceImpl.java
index fbe8cc5..a875825 100644
--- a/yudao-module-hrm/src/main/java/cn/iocoder/yudao/module/hrm/service/attendance/HrmAttendanceRuleServiceImpl.java
+++ b/yudao-module-hrm/src/main/java/cn/iocoder/yudao/module/hrm/service/attendance/HrmAttendanceRuleServiceImpl.java
@@ -1,22 +1,34 @@
 package cn.iocoder.yudao.module.hrm.service.attendance;
 
+import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.util.StrUtil;
+import cn.iocoder.yudao.framework.common.exception.ServiceException;
 import cn.iocoder.yudao.framework.common.pojo.PageResult;
 import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
 import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
+import cn.iocoder.yudao.module.hrm.controller.admin.attendance.vo.HrmAttendanceRuleImportExcelVO;
+import cn.iocoder.yudao.module.hrm.controller.admin.attendance.vo.HrmAttendanceRuleImportReqVO;
+import cn.iocoder.yudao.module.hrm.controller.admin.attendance.vo.HrmAttendanceRuleImportRespVO;
 import cn.iocoder.yudao.module.hrm.controller.admin.attendance.vo.HrmAttendanceRulePageReqVO;
 import cn.iocoder.yudao.module.hrm.controller.admin.attendance.vo.HrmAttendanceRuleSaveReqVO;
 import cn.iocoder.yudao.module.hrm.dal.dataobject.attendance.HrmAttendanceRuleDO;
 import cn.iocoder.yudao.module.hrm.dal.mysql.attendance.HrmAttendanceRuleMapper;
+import cn.iocoder.yudao.module.system.api.dept.DeptApi;
+import cn.iocoder.yudao.module.system.api.dept.dto.DeptRespDTO;
 import jakarta.annotation.Resource;
 import org.springframework.stereotype.Service;
 import org.springframework.validation.annotation.Validated;
 
 import java.math.BigDecimal;
 import java.time.LocalDate;
+import java.util.ArrayList;
+import java.util.LinkedHashMap;
 import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
 
 import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
+import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.filterList;
 import static cn.iocoder.yudao.module.hrm.enums.ErrorCodeConstants.*;
 
 /**
@@ -33,6 +45,9 @@
 
     @Resource
     private HrmAttendanceRuleMapper attendanceRuleMapper;
+
+    @Resource
+    private DeptApi deptApi;
 
     @Override
     public Long createAttendanceRule(HrmAttendanceRuleSaveReqVO createReqVO) {
@@ -208,4 +223,83 @@
         return attendanceRuleMapper.selectList(wrapper);
     }
 
+    /**
+     * 瀵煎叆鑰冨嫟瑙勫垯锛堢Щ妞嶈嚜鏂伴珮鐢靛姏锛�
+     *
+     * 璇存槑锛氬鍏ユ寜銆岃鍒欏悕绉般�嶅垽閲嶏紱宸插瓨鍦ㄦ椂闇� updateSupport=true 鎵嶈鐩栥��
+     * 閮ㄩ棬鎸夊悕绉板尮閰嶏紙deptName -> deptId锛夛紝閮ㄩ棬涓虹┖琛ㄧず鍏ㄥ眬瑙勫垯銆�
+     */
+    @Override
+    public HrmAttendanceRuleImportRespVO importAttendanceRuleList(
+            List<HrmAttendanceRuleImportExcelVO> importList, HrmAttendanceRuleImportReqVO importReqVO) {
+        // 1. 鏍¢獙闈炵┖
+        importList = filterList(importList, item -> StrUtil.isNotBlank(item.getName()));
+        if (CollUtil.isEmpty(importList)) {
+            throw exception(ATTENDANCE_RULE_IMPORT_LIST_IS_EMPTY);
+        }
+        // 2. 棰勫姞杞介儴闂ㄥ悕绉� -> 閮ㄩ棬ID
+        Map<String, Long> deptMap = deptApi.getDeptList().stream()
+                .filter(dept -> StrUtil.isNotBlank(dept.getName()))
+                .collect(Collectors.toMap(DeptRespDTO::getName, DeptRespDTO::getId, (a, b) -> a));
+        // 3. 閫愭潯澶勭悊
+        HrmAttendanceRuleImportRespVO respVO = HrmAttendanceRuleImportRespVO.builder()
+                .createNames(new ArrayList<>())
+                .updateNames(new ArrayList<>())
+                .failureNames(new LinkedHashMap<>())
+                .build();
+        importList.forEach(importRule -> {
+            try {
+                // 3.1 瑙f瀽閮ㄩ棬
+                Long deptId = null;
+                if (StrUtil.isNotBlank(importRule.getDeptName())) {
+                    deptId = deptMap.get(importRule.getDeptName());
+                    if (deptId == null) {
+                        throw exception(ATTENDANCE_RULE_DEPT_NOT_EXISTS, importRule.getDeptName());
+                    }
+                }
+                // 3.2 鍒ゆ柇鏄惁瀛樺湪锛堟寜鍚嶇О鍞竴锛�
+                HrmAttendanceRuleDO existRule = attendanceRuleMapper.selectOne(HrmAttendanceRuleDO::getName, importRule.getName());
+                if (existRule == null) {
+                    // 3.2.1 鏂板
+                    HrmAttendanceRuleDO rule = BeanUtils.toBean(importRule, HrmAttendanceRuleDO.class).setDeptId(deptId);
+                    applyImportDefaults(rule);
+                    attendanceRuleMapper.insert(rule);
+                    respVO.getCreateNames().add(importRule.getName());
+                    return;
+                }
+                // 3.2.2 宸插瓨鍦紝鍒ゆ柇鏄惁鍏佽鏇存柊
+                if (!Boolean.TRUE.equals(importReqVO.getUpdateSupport())) {
+                    respVO.getFailureNames().put(importRule.getName(),
+                            StrUtil.format(ATTENDANCE_RULE_EXISTS.getMsg(), importRule.getName()));
+                    return;
+                }
+                HrmAttendanceRuleDO updateRule = BeanUtils.toBean(importRule, HrmAttendanceRuleDO.class)
+                        .setId(existRule.getId()).setDeptId(deptId);
+                applyImportDefaults(updateRule);
+                attendanceRuleMapper.updateById(updateRule);
+                respVO.getUpdateNames().add(importRule.getName());
+            } catch (ServiceException ex) {
+                respVO.getFailureNames().put(importRule.getName(), ex.getMessage());
+            }
+        });
+        return respVO;
+    }
+
+    /**
+     * 瀵煎叆鏃剁殑榛樿鍊艰ˉ鍏紙涓庨〉闈㈡柊澧炰繚鎸佷竴鑷寸殑榛樿鍙e緞锛涗笉瑕嗙洊鍦扮偣瀛楁锛岄伩鍏嶅鍏ユ竻绌哄凡閰嶇疆鐨勫湴鐐癸級
+     */
+    private void applyImportDefaults(HrmAttendanceRuleDO rule) {
+        if (rule.getLateAllowMinutes() == null) {
+            rule.setLateAllowMinutes(0);
+        }
+        if (rule.getEarlyAllowMinutes() == null) {
+            rule.setEarlyAllowMinutes(0);
+        }
+        if (rule.getOvertimeThreshold() == null) {
+            rule.setOvertimeThreshold(BigDecimal.ONE);
+        }
+        if (rule.getStatus() == null) {
+            rule.setStatus(0);
+        }
+    }
 }

--
Gitblit v1.9.3