package cn.iocoder.yudao.module.hrm.service.workhour;

import cn.hutool.core.collection.CollUtil;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.module.hrm.controller.admin.workhour.vo.HrmEmployeeWorkHourReqVO;
import cn.iocoder.yudao.module.hrm.controller.admin.workhour.vo.HrmWorkHourSummaryPageReqVO;
import cn.iocoder.yudao.module.hrm.controller.admin.workhour.vo.HrmWorkHourSummaryRespVO;
import cn.iocoder.yudao.module.hrm.dal.dataobject.employee.HrmEmployeeDO;
import cn.iocoder.yudao.module.hrm.dal.dataobject.workhour.HrmWorkHourSummaryDO;
import cn.iocoder.yudao.module.hrm.dal.mysql.attendance.HrmAttendanceRecordMapper;
import cn.iocoder.yudao.module.hrm.dal.mysql.workhour.HrmWorkHourSummaryMapper;
import cn.iocoder.yudao.module.hrm.service.employee.HrmEmployeeService;
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.transaction.annotation.Transactional;
import org.springframework.validation.annotation.Validated;

import java.math.BigDecimal;
import java.time.YearMonth;
import java.util.Collections;
import java.util.List;
import java.util.Map;

/**
 * 月度工时汇总 Service 实现类
 *
 * @author 超级管理员
 */
@Service
@Validated
public class HrmWorkHourSummaryServiceImpl implements HrmWorkHourSummaryService {

    @Resource
    private HrmWorkHourSummaryMapper workHourSummaryMapper;
    @Resource
    private HrmAttendanceRecordMapper attendanceRecordMapper;
    @Resource
    private HrmEmployeeService employeeService;
    @Resource
    private DeptApi deptApi;

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void generateMonthly(String period) {
        YearMonth yearMonth = YearMonth.parse(period);
        HrmEmployeeWorkHourReqVO reqVO = new HrmEmployeeWorkHourReqVO();
        reqVO.setStartDate(yearMonth.atDay(1));
        reqVO.setEndDate(yearMonth.atEndOfMonth());
        for (Map<String, Object> row : attendanceRecordMapper.selectWorkHourSummary(reqVO)) {
            Long employeeId = toLong(row.get("user_id"));
            if (employeeId == null) {
                continue;
            }
            HrmEmployeeDO employee = employeeService.getEmployee(employeeId);
            HrmWorkHourSummaryDO summary = workHourSummaryMapper.selectByEmployeeIdAndPeriod(employeeId, period);
            if (summary == null) {
                summary = new HrmWorkHourSummaryDO();
                summary.setEmployeeId(employeeId);
                summary.setPeriod(period);
            }
            summary.setDeptId(employee != null ? employee.getDeptId() : null);
            summary.setWorkDays(toInteger(row.get("work_days")));
            summary.setWorkHours(toDecimal(row.get("work_hours")));
            summary.setOvertimeHours(toDecimal(row.get("overtime_hours")));
            if (summary.getId() == null) {
                workHourSummaryMapper.insert(summary);
            } else {
                workHourSummaryMapper.updateById(summary);
            }
        }
    }

    @Override
    public PageResult<HrmWorkHourSummaryRespVO> getWorkHourSummaryPage(HrmWorkHourSummaryPageReqVO pageReqVO) {
        PageResult<HrmWorkHourSummaryDO> pageResult = workHourSummaryMapper.selectPage(pageReqVO);
        if (CollUtil.isEmpty(pageResult.getList())) {
            return new PageResult<>(Collections.emptyList(), pageResult.getTotal());
        }
        List<HrmWorkHourSummaryRespVO> list = pageResult.getList().stream()
                .map(this::convert)
                .toList();
        return new PageResult<>(list, pageResult.getTotal());
    }

    private HrmWorkHourSummaryRespVO convert(HrmWorkHourSummaryDO summary) {
        HrmWorkHourSummaryRespVO respVO = new HrmWorkHourSummaryRespVO();
        respVO.setId(summary.getId());
        respVO.setEmployeeId(summary.getEmployeeId());
        respVO.setDeptId(summary.getDeptId());
        respVO.setPeriod(summary.getPeriod());
        respVO.setWorkDays(summary.getWorkDays());
        respVO.setWorkHours(summary.getWorkHours());
        respVO.setOvertimeHours(summary.getOvertimeHours());
        respVO.setRemark(summary.getRemark());
        respVO.setCreateTime(summary.getCreateTime());
        HrmEmployeeDO employee = employeeService.getEmployee(summary.getEmployeeId());
        if (employee != null) {
            respVO.setEmployeeNo(employee.getEmployeeNo());
            respVO.setEmployeeName(employee.getName());
        }
        if (summary.getDeptId() != null) {
            DeptRespDTO dept = deptApi.getDept(summary.getDeptId());
            if (dept != null) {
                respVO.setDeptName(dept.getName());
            }
        }
        return respVO;
    }

    private Long toLong(Object value) {
        return value instanceof Number ? ((Number) value).longValue() : null;
    }

    private Integer toInteger(Object value) {
        return value instanceof Number ? ((Number) value).intValue() : 0;
    }

    private BigDecimal toDecimal(Object value) {
        return value instanceof Number ? new BigDecimal(value.toString()) : BigDecimal.ZERO;
    }

}