package cn.iocoder.yudao.module.mes.service.home;

import cn.iocoder.yudao.framework.common.util.date.LocalDateTimeUtils;
import cn.iocoder.yudao.module.mes.controller.admin.home.vo.MesHomeProductionTrendRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.home.vo.MesHomeSummaryRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.home.vo.MesHomeWorkOrderStatusRespVO;
import cn.iocoder.yudao.module.mes.dal.mysql.home.MesHomeStatisticsMapper;
import cn.iocoder.yudao.module.mes.enums.dv.MesDvMachineryStatusEnum;
import cn.iocoder.yudao.module.mes.enums.pro.MesProWorkOrderStatusEnum;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.*;

/**
 * MES 首页统计 Service 实现类
 *
 * @author 超级管理员
 */
@Service
public class MesHomeStatisticsServiceImpl implements MesHomeStatisticsService {

    @Resource
    private MesHomeStatisticsMapper homeStatisticsMapper;

    @Override
    public MesHomeSummaryRespVO getHomeSummary() {
        MesHomeSummaryRespVO summary = new MesHomeSummaryRespVO();

        // 1. 工单统计
        List<Map<String, Object>> workOrderStats = homeStatisticsMapper.selectWorkOrderCountGroupByStatus();
        long activeCount = 0L;
        long prepareCount = 0L;
        long finishedCount = 0L;
        for (Map<String, Object> stat : workOrderStats) {
            int status = ((Number) stat.get("status")).intValue();
            long count = ((Number) stat.get("count")).longValue();
            if (status == MesProWorkOrderStatusEnum.CONFIRMED.getStatus()) {
                activeCount = count;
            } else if (status == MesProWorkOrderStatusEnum.PREPARE.getStatus()) {
                prepareCount = count;
            } else if (status == MesProWorkOrderStatusEnum.FINISHED.getStatus()) {
                finishedCount = count;
            }
        }
        summary.setWorkOrderActiveCount(activeCount);
        summary.setWorkOrderPrepareCount(prepareCount);
        summary.setWorkOrderFinishedCount(finishedCount);

        // 2. 今日产量
        LocalDateTime today = LocalDateTimeUtils.getToday();
        LocalDateTime yesterday = LocalDateTimeUtils.getYesterday();
        Map<String, BigDecimal> todayFeedback = homeStatisticsMapper.selectFeedbackSummary(today, null);
        summary.setTodayOutput(getDecimal(todayFeedback, "feedbackQuantity"));
        summary.setTodayQualifiedQuantity(getDecimal(todayFeedback, "qualifiedQuantity"));
        summary.setTodayUnqualifiedQuantity(getDecimal(todayFeedback, "unqualifiedQuantity"));

        // 3. 昨日产量
        Map<String, BigDecimal> yesterdayFeedback = homeStatisticsMapper.selectFeedbackSummary(yesterday, today);
        summary.setYesterdayOutput(getDecimal(yesterdayFeedback, "feedbackQuantity"));

        // 4. 设备统计
        List<Map<String, Object>> machineryStats = homeStatisticsMapper.selectMachineryCountGroupByStatus();
        long total = 0L;
        long producing = 0L;
        long stop = 0L;
        long maintenance = 0L;
        for (Map<String, Object> stat : machineryStats) {
            int status = ((Number) stat.get("status")).intValue();
            long count = ((Number) stat.get("count")).longValue();
            total += count;
            if (status == MesDvMachineryStatusEnum.PRODUCING.getStatus()) {
                producing = count;
            } else if (status == MesDvMachineryStatusEnum.STOP.getStatus()) {
                stop = count;
            } else if (status == MesDvMachineryStatusEnum.MAINTENANCE.getStatus()) {
                maintenance = count;
            }
        }
        summary.setMachineryTotal(total);
        summary.setMachineryProducing(producing);
        summary.setMachineryStop(stop);
        summary.setMachineryMaintenance(maintenance);

        // 5. 异常/待办
        summary.setAndonActiveCount(homeStatisticsMapper.selectAndonActiveCount());
        summary.setRepairActiveCount(homeStatisticsMapper.selectRepairActiveCount());

        // 6. 质检合格率（来料 / 过程 / 出货）
        //    数量口径 = 合格数量 / 检验数量；不过滤单据状态，也不做时间范围限制（全量累计）
        Map<String, Map<String, BigDecimal>> qcSummary = new HashMap<>();
        for (Map<String, Object> row : homeStatisticsMapper.selectQcQualifiedSummary()) {
            Map<String, BigDecimal> metrics = new HashMap<>();
            metrics.put("checkQuantity", getDecimalFromObj(row.get("checkQuantity")));
            metrics.put("qualifiedQuantity", getDecimalFromObj(row.get("qualifiedQuantity")));
            qcSummary.put(String.valueOf(row.get("type")), metrics);
        }
        summary.setIqcQualifiedRate(calcQcQualifiedRate(qcSummary.get("IQC")));
        summary.setIpqcQualifiedRate(calcQcQualifiedRate(qcSummary.get("IPQC")));
        summary.setOqcQualifiedRate(calcQcQualifiedRate(qcSummary.get("OQC")));
        // 三个环节各自的检验数量合计（合格率的分母），供卡片副行展示样本量
        summary.setIqcCheckQuantity(calcCheckQuantity(qcSummary.get("IQC")));
        summary.setIpqcCheckQuantity(calcCheckQuantity(qcSummary.get("IPQC")));
        summary.setOqcCheckQuantity(calcCheckQuantity(qcSummary.get("OQC")));

        return summary;
    }

    @Override
    public List<MesHomeWorkOrderStatusRespVO> getWorkOrderStatusDistribution() {
        List<Map<String, Object>> stats = homeStatisticsMapper.selectWorkOrderCountGroupByStatus();
        List<MesHomeWorkOrderStatusRespVO> result = new ArrayList<>();
        for (MesProWorkOrderStatusEnum statusEnum : MesProWorkOrderStatusEnum.values()) {
            long count = 0L;
            for (Map<String, Object> stat : stats) {
                if (((Number) stat.get("status")).intValue() == statusEnum.getStatus()) {
                    count = ((Number) stat.get("count")).longValue();
                    break;
                }
            }
            result.add(new MesHomeWorkOrderStatusRespVO(statusEnum.getStatus(), statusEnum.getName(), count));
        }
        return result;
    }

    @Override
    public List<MesHomeProductionTrendRespVO> getProductionTrend(Integer days) {
        LocalDate endDate = LocalDate.now().plusDays(1);
        LocalDate startDate = endDate.minusDays(days);
        LocalDateTime beginTime = startDate.atStartOfDay();
        LocalDateTime endTime = endDate.atStartOfDay();

        // 查询数据库
        List<Map<String, Object>> dbData = homeStatisticsMapper.selectDailyFeedbackTrend(beginTime, endTime);
        Map<String, Map<String, Object>> dateMap = new LinkedHashMap<>();
        for (Map<String, Object> row : dbData) {
            dateMap.put((String) row.get("date"), row);
        }

        // 补全所有日期（无数据的日期填 0）
        DateTimeFormatter fmt = DateTimeFormatter.ofPattern("yyyy-MM-dd");
        List<MesHomeProductionTrendRespVO> result = new ArrayList<>();
        for (LocalDate d = startDate; d.isBefore(endDate); d = d.plusDays(1)) {
            String dateStr = d.format(fmt);
            Map<String, Object> row = dateMap.get(dateStr);
            MesHomeProductionTrendRespVO vo = new MesHomeProductionTrendRespVO();
            vo.setDate(dateStr);
            if (row != null) {
                vo.setQuantity(getDecimalFromObj(row.get("quantity")));
                vo.setQualifiedQuantity(getDecimalFromObj(row.get("qualifiedQuantity")));
                vo.setUnqualifiedQuantity(getDecimalFromObj(row.get("unqualifiedQuantity")));
            } else {
                vo.setQuantity(BigDecimal.ZERO);
                vo.setQualifiedQuantity(BigDecimal.ZERO);
                vo.setUnqualifiedQuantity(BigDecimal.ZERO);
            }
            result.add(vo);
        }
        return result;
    }

    // ========== 工具方法 ==========

    private BigDecimal getDecimal(Map<String, BigDecimal> map, String key) {
        if (map == null || map.get(key) == null) {
            return BigDecimal.ZERO;
        }
        return map.get(key);
    }

    private BigDecimal getDecimalFromObj(Object obj) {
        if (obj == null) {
            return BigDecimal.ZERO;
        }
        if (obj instanceof BigDecimal) {
            return (BigDecimal) obj;
        }
        return new BigDecimal(obj.toString());
    }

    /**
     * 计算质检合格率（百分比，保留两位小数）
     *
     * 检验数量为 0（即没有已完成的质检单）时返回 null，
     * 让页面显示「—」，而不是误导性的 0%。
     */
    private BigDecimal calcQcQualifiedRate(Map<String, BigDecimal> qcSummary) {
        if (qcSummary == null) {
            return null;
        }
        BigDecimal checkedQuantity = getDecimal(qcSummary, "checkQuantity");
        if (checkedQuantity.compareTo(BigDecimal.ZERO) <= 0) {
            return null;
        }
        return getDecimal(qcSummary, "qualifiedQuantity")
                .multiply(BigDecimal.valueOf(100))
                .divide(checkedQuantity, 2, RoundingMode.HALF_UP);
    }

    /**
     * 取该检验环节的检验数量合计（合格率的分母，即卡片副行展示的样本量）
     *
     * 该环节没有任何质检单时返回 0。
     */
    private Long calcCheckQuantity(Map<String, BigDecimal> qcSummary) {
        if (qcSummary == null) {
            return 0L;
        }
        return getDecimal(qcSummary, "checkQuantity").longValue();
    }

}