宁夏三级mom后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
tuqin
2026-11-03 5d8a5addb80d0f1663862963b76a1a4a7d9295fd 
 yudao-module-hrm/src/main/java/cn/iocoder/yudao/module/hrm/service/salary/HrmSalaryCalculationServiceImpl.java


@@ -6,6 +6,8 @@


import cn.iocoder.yudao.module.hrm.controller.admin.salary.vo.HrmSalaryCalculationPageReqVO;


import cn.iocoder.yudao.module.hrm.dal.dataobject.approval.HrmLeaveApplicationDO;


import cn.iocoder.yudao.module.hrm.dal.dataobject.approval.HrmOvertimeApplicationDO;


import cn.iocoder.yudao.module.hrm.dal.dataobject.attendance.HrmEmployeeScheduleDO;


import cn.iocoder.yudao.module.hrm.dal.dataobject.attendance.HrmShiftDO;


import cn.iocoder.yudao.module.hrm.dal.dataobject.employee.HrmEmployeeDO;


import cn.iocoder.yudao.module.hrm.dal.dataobject.salary.HrmEmployeeSalaryDO;


import cn.iocoder.yudao.module.hrm.dal.dataobject.salary.HrmEmployeeSocialSecurityDO;


@@ -16,6 +18,8 @@


import cn.iocoder.yudao.module.hrm.dal.dataobject.salary.HrmSocialSecuritySchemeDO;


import cn.iocoder.yudao.module.hrm.dal.dataobject.salary.HrmSalaryStructureDO;


import cn.iocoder.yudao.module.hrm.dal.mysql.approval.HrmLeaveApplicationMapper;


import cn.iocoder.yudao.module.hrm.dal.mysql.attendance.HrmEmployeeScheduleMapper;


import cn.iocoder.yudao.module.hrm.dal.mysql.attendance.HrmShiftMapper;


import cn.iocoder.yudao.module.hrm.dal.mysql.approval.HrmOvertimeApplicationMapper;


import cn.iocoder.yudao.module.hrm.dal.mysql.employee.HrmEmployeeMapper;


import cn.iocoder.yudao.module.hrm.dal.mysql.salary.HrmEmployeeSalaryMapper;


@@ -28,6 +32,9 @@


import cn.iocoder.yudao.module.hrm.dal.mysql.salary.HrmSalaryStructureMapper;


import cn.iocoder.yudao.module.hrm.dal.redis.HrmNoRedisDAO;


import cn.iocoder.yudao.module.system.api.dept.DeptApi;


import cn.iocoder.yudao.module.system.api.notify.NotifyMessageSendApi;


import cn.iocoder.yudao.module.system.api.notify.dto.NotifySendSingleToUserReqDTO;


import lombok.extern.slf4j.Slf4j;


import cn.iocoder.yudao.module.hrm.enums.HrmOvertimeTypeEnum;


import jakarta.annotation.Resource;


import org.springframework.stereotype.Service;


@@ -39,8 +46,12 @@


import java.time.LocalDate;


import java.time.LocalDateTime;


import java.time.YearMonth;


import java.util.Collections;


import java.util.HashMap;


import java.util.List;


import java.util.Map;


import java.util.Objects;


import java.util.Set;


import java.util.stream.Collectors;




import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;


@@ -53,6 +64,7 @@


 */


@Service


@Validated


@Slf4j


public class HrmSalaryCalculationServiceImpl implements HrmSalaryCalculationService {




    /**


@@ -83,6 +95,8 @@


    @Resource


    private DeptApi deptApi;


    @Resource


    private NotifyMessageSendApi notifyMessageSendApi;


    @Resource


    private HrmDeductionService deductionService;


    @Resource


    private HrmLeaveApplicationMapper leaveApplicationMapper;


@@ -96,10 +110,35 @@


    private HrmSalaryPaymentMapper salaryPaymentMapper;


    @Resource


    private HrmSalaryPaymentDetailMapper salaryPaymentDetailMapper;


    @Resource


    private HrmEmployeeScheduleMapper employeeScheduleMapper;


    @Resource


    private HrmShiftMapper shiftMapper;




    @Override


    public PageResult<HrmSalaryCalculationDO> getSalaryCalculationPage(HrmSalaryCalculationPageReqVO pageReqVO) {


        return salaryCalculationMapper.selectPage(pageReqVO);


    }




    @Override


    public PageResult<HrmSalaryCalculationDO> getMySalaryCalculationPage(Long userId, HrmSalaryCalculationPageReqVO pageReqVO) {


        // 强制限定为当前登录人：忽略前端传入的 userId / deptId，防止越权查看他人工资


        pageReqVO.setUserId(userId);


        pageReqVO.setDeptId(null);


        return salaryCalculationMapper.selectPage(pageReqVO);


    }




    @Override


    public HrmSalaryCalculationDO getMySalaryCalculation(Long id, Long userId) {


        HrmSalaryCalculationDO calculation = salaryCalculationMapper.selectById(id);


        if (calculation == null) {


            return null;


        }


        // 不属于本人的记录一律视为不存在，避免通过猜 id 越权查看他人工资


        if (!java.util.Objects.equals(calculation.getUserId(), userId)) {


            return null;


        }


        return calculation;


    }




    @Override


@@ -225,6 +264,11 @@


        OvertimeSalary overtimeSalary = calculateOvertimeSalary(employee, employeeSalary, period, baseSalary);


        BigDecimal overtimePay = overtimeSalary.pay();




        // 按排班累计出勤天数与排班总工时（无排班时出勤天数回退默认 22）


        ScheduleStat scheduleStat = calculateScheduleStat(employeeId, period);


        Integer workDays = scheduleStat.scheduledDays() > 0 ? scheduleStat.scheduledDays() : 22;


        BigDecimal totalWorkHours = scheduleStat.totalWorkHours();




        // 应发工资总额


        BigDecimal totalIncome = baseSalary.add(performanceSalary).add(mealAllowance)


                .add(transportAllowance).add(otherAllowance).add(overtimePay);


@@ -295,8 +339,9 @@


                .otherDeduction(otherDeduction)


                .leaveDeduction(leaveDeduction)


                .actualSalary(actualSalary)


                .workDays(22) // 默认工作日


                .workDays(workDays) // 按排班累计应出勤天数，无排班时回退 22


                .overtimeHours(overtimeSalary.hours())


                .totalWorkHours(totalWorkHours)


                .status(0) // 待确认


                .build();


    }


@@ -401,6 +446,37 @@




    private record OvertimeSalary(BigDecimal hours, BigDecimal pay) {}




    private record ScheduleStat(int scheduledDays, BigDecimal totalWorkHours) {}




    /**


     * 按排班表累计员工的出勤天数与排班总工时。


     * 仅统计有班次的排班记录，班次标准工时之和即为排班工时。


     */


    private ScheduleStat calculateScheduleStat(Long employeeId, String period) {


        YearMonth yearMonth = YearMonth.parse(period);


        List<HrmEmployeeScheduleDO> schedules = employeeScheduleMapper.selectListByEmployeeIdAndPeriod(


                employeeId, yearMonth.atDay(1), yearMonth.atEndOfMonth());


        if (CollUtil.isEmpty(schedules)) {


            return new ScheduleStat(0, BigDecimal.ZERO);


        }


        Set<Long> shiftIds = schedules.stream().map(HrmEmployeeScheduleDO::getShiftId)


                .filter(Objects::nonNull).collect(Collectors.toSet());


        Map<Long, HrmShiftDO> shiftMap = CollUtil.isEmpty(shiftIds) ? Collections.emptyMap()


                : shiftMapper.selectBatchIds(shiftIds).stream()


                        .collect(Collectors.toMap(HrmShiftDO::getId, shift -> shift, (a, b) -> a));


        int scheduledDays = 0;


        BigDecimal totalWorkHours = BigDecimal.ZERO;


        for (HrmEmployeeScheduleDO schedule : schedules) {


            HrmShiftDO shift = schedule.getShiftId() == null ? null : shiftMap.get(schedule.getShiftId());


            if (shift == null) {


                continue;


            }


            scheduledDays++;


            totalWorkHours = totalWorkHours.add(shift.getWorkHours() != null ? shift.getWorkHours() : BigDecimal.ZERO);


        }


        return new ScheduleStat(scheduledDays, totalWorkHours.setScale(2, RoundingMode.HALF_UP));


    }




    @Override


    @Transactional(rollbackFor = Exception.class)


    public void confirmSalaryCalculation(List<Long> ids) {


@@ -422,6 +498,8 @@


            salaryCalculationMapper.updateById(salaryCalculation);


            // 记录周期


            period = salaryCalculation.getPeriod();


            // 确认后给该员工发送工资条通知（失败不影响确认主流程）


            sendPayslipNotice(salaryCalculation);


        }




        // 检查该周期是否所有核算记录都已确认，自动生成发放台账


@@ -433,6 +511,39 @@


    /**


     * 检查该周期是否所有核算记录都已确认，如果全部确认则自动生成发放台账


     */


    /**


     * 工资条通知的站内信模板编码


     *


     * 对应 system_notify_template.code = salary_payslip_notice


     */


    private static final String TEMPLATE_CODE_PAYSLIP = "salary_payslip_notice";




    /**


     * 给员工发送工资条通知（APP 站内信）


     *


     * 通知失败只记日志，不影响核算确认主流程


     */


    private void sendPayslipNotice(HrmSalaryCalculationDO calculation) {


        if (calculation == null || calculation.getUserId() == null) {


            return;


        }


        try {


            NotifySendSingleToUserReqDTO reqDTO = new NotifySendSingleToUserReqDTO();


            reqDTO.setUserId(calculation.getUserId());


            reqDTO.setTemplateCode(TEMPLATE_CODE_PAYSLIP);


            Map<String, Object> params = new HashMap<>();


            params.put("period", calculation.getPeriod());


            params.put("actualSalary", calculation.getActualSalary());


            reqDTO.setTemplateParams(params);


            notifyMessageSendApi.sendSingleMessageToAdmin(reqDTO);


            log.info("[sendPayslipNotice] 工资条通知已发送，userId={}, period={}",


                    calculation.getUserId(), calculation.getPeriod());


        } catch (Exception e) {


            log.warn("[sendPayslipNotice] 工资条通知发送失败，userId={}, period={}",


                    calculation.getUserId(), calculation.getPeriod(), e);


        }


    }




    private void autoGeneratePaymentIfAllConfirmed(String period) {


        // 查询该周期所有核算记录


        List<HrmSalaryCalculationDO> allCalculations = salaryCalculationMapper.selectListByPeriod(period);