package org.jeecg.modules.mdc.subcontrol.service.impl;

import org.apache.commons.lang.StringUtils;
import org.checkerframework.checker.units.qual.A;
import org.jeecg.modules.mdc.entity.EquipmentLog;
import org.jeecg.modules.mdc.service.*;
import org.jeecg.modules.mdc.subcontrol.service.MdcBigScreenService;
import org.jeecg.modules.mdc.subcontrol.vo.LastWeekDataRankingVo;
import org.jeecg.modules.mdc.subcontrol.vo.LastWeekDataVo;
import org.jeecg.modules.mdc.subcontrol.vo.MdcEquipmentOpVo;
import org.jeecg.modules.mdc.util.DateUtils;
import org.jeecg.modules.mdc.vo.MdcEquipmentVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import javax.xml.crypto.Data;
import java.math.BigDecimal;
import java.time.DayOfWeek;
import java.time.LocalDate;
import java.time.format.DateTimeFormatter;
import java.time.temporal.TemporalAdjusters;
import java.util.*;
import java.util.stream.Collectors;

/**
 * @author: LiuS
 * @create: 2023-01-05 11:42
 */
@Service
public class MdcBigScreenServiceImpl implements MdcBigScreenService {

    @Resource
    private IMdcEquipmentService mdcEquipmentService;

    @Resource
    private IEquipmentStatisticalInfoService equipmentStatisticalInfoService;
    @Autowired
    private IMdcEquipmentStatisticalShiftInfoService mdcEquipmentStatisticalShiftInfoService;
    @Autowired
    private IMdcEquipmentStatisticalInfoService mdcEquipmentStatisticalInfoService;


    @Resource
    private IEquipmentLogService equipmentLogService;


    /**
     * 根据厂区id获取上周数据
     */
    @Override
    public Map<String, Object> findDataByLastWeek() {
        Map<String, Object> result = new HashMap<>();
        List<BigDecimal> openingRateList = new ArrayList<>();
        List<BigDecimal> processingRateList = new ArrayList<>();
        List<BigDecimal> shiftRateList = new ArrayList<>();
        //获取上周周一日期和周六日期
        LocalDate today = LocalDate.now().minusDays(7L);
        LocalDate monday = today.with(TemporalAdjusters.previousOrSame(DayOfWeek.MONDAY));
        LocalDate saturday = today.with(TemporalAdjusters.nextOrSame(DayOfWeek.SATURDAY));
        List<String> dates = getMiddleDate(monday, saturday);
        List<String> equipmentIdList = new ArrayList<>();
        //根据厂区id获取厂区设备信息
        equipmentIdList = mdcEquipmentService.listEquipmentId(null);
        //上周利用率和开机率数据
        List<LastWeekDataVo> lastWeekDataVos = equipmentStatisticalInfoService.findDataForBigScreen(equipmentIdList, monday.format(DateTimeFormatter.BASIC_ISO_DATE), saturday.format(DateTimeFormatter.BASIC_ISO_DATE));
        if (lastWeekDataVos.isEmpty()) {
            for (int i = 0; i < dates.size(); i++) {
                openingRateList.add(new BigDecimal("0"));
                processingRateList.add(new BigDecimal("0"));
            }
        } else {
            for (int i = 0; i < dates.size(); i++) {
                Integer size = equipmentStatisticalInfoService.findEquipmentId(equipmentIdList, dates.get(i));
                if (dates.get(i).equals(lastWeekDataVos.get(i).getTheDate())) {
                    openingRateList.add(new BigDecimal(String.format("%.2f", (Float.parseFloat(lastWeekDataVos.get(i).getOpeningLong()) / (86400 * size) * 100))));
                    processingRateList.add(new BigDecimal(String.format("%.2f", (Float.parseFloat(lastWeekDataVos.get(i).getProcessingLong()) / (86400 * size) * 100))));
                } else {
                    openingRateList.add(new BigDecimal("0"));
                    processingRateList.add(new BigDecimal("0"));
                }
            }
        }

        //上周班次利用率数据
        List<LastWeekDataVo> lastWeekDataList = mdcEquipmentStatisticalShiftInfoService.
                findDataForBigScreen(equipmentIdList, monday.toString(), saturday.toString());
        List<String> middleDates = getMiddleDates(monday, saturday);

        if (lastWeekDataList.isEmpty()) {
            for (int i = 0; i < middleDates.size(); i++) {
                shiftRateList.add(new BigDecimal("0"));
            }
        } else {
            Map<String,LastWeekDataVo> map = new HashMap<>();
            for (LastWeekDataVo s : lastWeekDataList) {
                map.put(s.getTheDate(),s);
            }
            for (int i = 0; i < middleDates.size(); i++) {
                if (i < lastWeekDataList.size()) {
                    if ( map.containsKey(middleDates.get(i))) {
                        LastWeekDataVo vo =  map.get(middleDates.get(i));
                        if (!"0".equals(vo.getTotalLong())) {
                            shiftRateList.add(new BigDecimal(vo.getProcessingLong()).
                                    divide(new BigDecimal(vo.getTotalLong()),
                                            4, BigDecimal.ROUND_HALF_UP)
                                    .setScale(4, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal(100)));
                        } else {
                            shiftRateList.add(new BigDecimal("0"));
                        }
                    }

                }
                 else {
                    shiftRateList.add(new BigDecimal("0"));
                }
            }
        }
        result.put("openingRateList", openingRateList);
        result.put("processingRateList", processingRateList);
        result.put("shiftRateList", shiftRateList);

        return result;
    }

    /**
     * 根据厂区id获取上周运行效率排名
     */
    @Override
    public List<LastWeekDataRankingVo> findDataRankingByLastWeek() {
        List<LastWeekDataRankingVo> voList = new ArrayList<>();

        //获取上周周一日期和周六日期
        LocalDate today = LocalDate.now();
        String monday = today.minusDays(7).format(DateTimeFormatter.BASIC_ISO_DATE);
        String saturday = today.minusDays(1).format(DateTimeFormatter.BASIC_ISO_DATE);
        //根据id获取设备id集合
        List<String> equipmentIdList = mdcEquipmentService.listEquipmentId(null);
        if (!equipmentIdList.isEmpty()) {
            List<LastWeekDataVo> lastWeekDataVos = equipmentStatisticalInfoService.findDataRankingForBigScreen(equipmentIdList, monday, saturday);
            if (!lastWeekDataVos.isEmpty()) {
                for (LastWeekDataVo lastWeekDataVo : lastWeekDataVos) {
                    Long size = mdcEquipmentStatisticalInfoService.selectSize(lastWeekDataVo.getEquipment(), monday, saturday);
                    if (StringUtils.isNotEmpty(lastWeekDataVo.getProcessingLong()) && Float.parseFloat(lastWeekDataVo.getProcessingLong()) >0) {
                        lastWeekDataVo.setUtilization(new BigDecimal(String.format("%.2f",
                                (Float.parseFloat(lastWeekDataVo.getProcessingLong()) / (86400 * size) * 100))));
                    } else {
                        lastWeekDataVo.setUtilization(new BigDecimal(0));
                    }

                }
                List<LastWeekDataVo> collect = lastWeekDataVos.stream().sorted(Comparator.comparing(LastWeekDataVo::getUtilization).reversed()).collect(Collectors.toList());
                if (collect.size() > 6) {
                    List<LastWeekDataVo> topList = collect.subList(0, 6);
                    for (LastWeekDataVo vo : topList) {
                        LastWeekDataRankingVo rankingVo = new LastWeekDataRankingVo();
                        rankingVo.setTopName(vo.getEquipment());
                        rankingVo.setTopRate(vo.getUtilization().toString());
                        voList.add(rankingVo);
                    }
                } else {
                    for (LastWeekDataVo vo : collect) {
                        LastWeekDataRankingVo rankingVo = new LastWeekDataRankingVo();
                        rankingVo.setTopName(vo.getEquipment());
                        rankingVo.setTopRate(vo.getUtilization().toString());
                        voList.add(rankingVo);
                    }
                }

            }
        }

        return voList;

    }

    /**
     * 获取设备当前状态
     */
    @Override
    public List<MdcEquipmentOpVo> findEquipmentStatus() {
        List<MdcEquipmentOpVo> result = new ArrayList<>();
        //根据id获取设备id集合
        List<String> equipmentIdList = mdcEquipmentService.listEquipmentId(null);

        if (!equipmentIdList.isEmpty()) {
            List<EquipmentLog> logs = equipmentLogService.getEquipmentStatusList(equipmentIdList);
            //根据设备id集合查询设备实时状态
            for (EquipmentLog equipmentId : logs) {
                if (equipmentId != null) {
                    MdcEquipmentOpVo vo = new MdcEquipmentOpVo();
                    vo.setEquipmentId(equipmentId.getEquipmentId());
                    if (equipmentId.getOporation() != null) {
                        switch (equipmentId.getOporation()) {
                            case 1:
                                vo.setOporation(1);
                                vo.setOporationDict("待机");
                                break;
                            case 2:
                                vo.setOporationDict("待机");
                                vo.setOporation(2);
                                break;
                            case 3:
                                vo.setOporationDict("运行");
                                vo.setOporation(3);
                                break;
                            case 22:
                                vo.setOporationDict("报警");
                                vo.setOporation(22);
                                break;
                            default:
                                vo.setOporationDict("关机");
                                vo.setOporation(0);
                                break;
                        }
                    } else {
                        vo.setOporation(0);
                        vo.setOporationDict("关机");
                    }
                    result.add(vo);
                } else {
                    MdcEquipmentOpVo vo = new MdcEquipmentOpVo();
                    vo.setOporation(0);
                    vo.setOporationDict("关机");
                    result.add(vo);
                }
            }
        }
        return result;
    }

    /**
     * 获取全厂当前设备状态信息
     */
    @Override
    public Map<String, Object> findAllEquipmentStatus() {
        int runCount = 0;
        int standbyCount = 0;
        int alarmCount = 0;
        int offCount = 0;
        List<String> equipmentIdList = mdcEquipmentService.listEquipmentId(null);
        List<EquipmentLog> equipmentLogs = new ArrayList<>();
        for (String equipmentId : equipmentIdList) {
            EquipmentLog equipmentLog = equipmentLogService.selectEquipmentOporation(equipmentId);
            if (equipmentLog != null) {
                equipmentLogs.add(equipmentLog);
            } else {
                offCount += 1;
            }
        }
        if (!equipmentLogs.isEmpty()) {
            for (EquipmentLog equipmentLog : equipmentLogs) {
                if (equipmentLog.getOporation() != null) {
                    switch (equipmentLog.getOporation()) {
                        case 1:
                        case 2:
                            standbyCount += 1;
                            break;
                        case 3:
                            runCount += 1;
                            break;
                        case 22:
                            alarmCount += 1;
                            break;
                        default:
                            offCount += 1;
                            break;
                    }
                } else {
                    offCount += 1;
                }
            }
        }
        Map<String, Object> result = new HashMap<>();
        result.put("runCount", runCount);
        result.put("standbyCount", standbyCount);
        result.put("alarmCount", alarmCount);
        result.put("offCount", offCount);

        return result;
    }

    /**
     * 20230101
     *
     * @param begin 开始日期
     * @param end   结束日期
     * @return 开始与结束之间的所有日期，包括起止
     */
    public static List<String> getMiddleDate(LocalDate begin, LocalDate end) {
        List<String> localDateList = new ArrayList<>();
        long length = end.toEpochDay() - begin.toEpochDay();
        for (long i = length; i >= 0; i--) {
            localDateList.add(end.minusDays(i).format(DateTimeFormatter.BASIC_ISO_DATE));
        }
        return localDateList;
    }

    /**
     * 2023-01-01
     *
     * @param begin 开始日期
     * @param end   结束日期
     * @return 开始与结束之间的所有日期，包括起止
     */
    public static List<String> getMiddleDates(LocalDate begin, LocalDate end) {
        List<String> localDateList = new ArrayList<>();
        long length = end.toEpochDay() - begin.toEpochDay();
        for (long i = length; i >= 0; i--) {
            String date = end.minusDays(i).toString().replace("-","");
            localDateList.add(date);
        }
        return localDateList;
    }

}