package com.ycl.task;

import com.ycl.platform.domain.entity.*;
import com.ycl.platform.mapper.CalculateRecordMapper;
import com.ycl.platform.service.CalculateRecordService;
import com.ycl.platform.service.IContractResultService;
import com.ycl.platform.service.IContractScoreService;
import com.ycl.platform.service.ITContractService;
import com.ycl.utils.DateUtils;
import com.ycl.utils.bean.BeanUtils;
import enumeration.general.CalculateReportStatusEnum;
import enumeration.general.PublishType;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;

import java.math.BigDecimal;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
import java.time.format.DateTimeFormatter;
import java.util.Calendar;
import java.util.Date;
import java.util.List;

/**
 * @author ghl
 * @since 2024/4/28 下午 4:14
 */

@Slf4j
@Data
@Component("contractResultTask")
public class ContractResultTask {

    private final ITContractService contractService;
    private final IContractScoreService contractScoreService;
    private final IContractResultService checkResultService;
    private final CalculateRecordMapper calculateRecordMapper;
    private String startTime;
    private String endTime;

    @Transactional
    public void contractResultTaskByDay(){
        // 查询有效期内的合同
        List<TContract> list = contractService.selectUsingContract();
        String startTime = "2025-06-17 00:00:00";
        String endTime = "2025-06-17 23:59:59";
//        getDayStartAndEnd(startTime,endTime);
        for (TContract tContract : list) {
            // 获得昨天的扣分记录
            List<ContractScore> contractScore = contractScoreService.getDateRangeScoreByContractId(tContract.getId(), startTime, endTime);

            System.out.println("打印昨日扣分记录");
            System.out.println(contractScore);
            if (CollectionUtils.isEmpty(contractScore)){
                log.error("昨日扣分记录列表为空");
                return;
            }
            // 新增考核结果
            Calendar calendar = Calendar.getInstance();
            calendar.add(Calendar.DATE, -1);
            ContractResult contractResult = getCheckResult(tContract, contractScore);
            contractResult.setWhichMonth(calendar.get(Calendar.MONTH)+1);
            contractResult.setWhichYear(calendar.get(Calendar.YEAR));
            contractResult.setWhichDay(calendar.get(Calendar.DAY_OF_MONTH));

            checkResultService.save(contractResult);
//            // 新增考核结果记录
//            List<ContractResultRecord> contractResultRecord = getContractResultRecord(contractScore, contractResult);
//            checkResultService.saveBatchRecord(contractResultRecord);
            // 新增核算明细记录
            CalculateRecord calculateRecord = new CalculateRecord();
            //改为直接去查
//            calculateRecord.setScore(contractResult.getScore());
            calculateRecord.setContractId(Integer.parseInt(tContract.getId()+""));
            calculateRecord.setCreateTime(new Date());
            calculateRecord.setUpdateTime(new Date());
            calculateRecord.setStatus(PublishType.UNPUBLISHED.getCode());

            calculateRecord.setWhichYear(calendar.get(Calendar.YEAR));
            calculateRecord.setWhichMonth(calendar.get(Calendar.MONTH)+1);
            calculateRecord.setWhichDay(calendar.get(Calendar.DAY_OF_MONTH));
            System.out.println("新增核算记录");
            System.out.println(calculateRecord);

            calculateRecordMapper.insert(calculateRecord);


        }
    }
    /**
     * 每个月1号执行，统计考核结果
     */
    @Transactional
    public void contractResultTask() {
        // 查询有效期内的合同
        List<TContract> list = contractService.selectUsingContract();
        getLastMonth();
        for (TContract tContract : list) {
            // 上个月扣分记录
            List<ContractScore> contractScore = contractScoreService.getDateRangeScoreByContractId(tContract.getId(), startTime, endTime);
            // 新增考核结果
            //获取上个月时间
            Calendar calendar = Calendar.getInstance();
            calendar.add(Calendar.MONTH, -1);
            ContractResult contractResult = getCheckResult(tContract, contractScore);
            contractResult.setWhichMonth(calendar.get(Calendar.MONTH)+1);
            contractResult.setWhichYear(calendar.get(Calendar.YEAR));
            checkResultService.save(contractResult);
//            // 新增考核结果记录
//            List<ContractResultRecord> contractResultRecord = getContractResultRecord(contractScore, contractResult);
//            checkResultService.saveBatchRecord(contractResultRecord);
            // 新增核算明细记录
            CalculateRecord calculateRecord = new CalculateRecord();
            //改为直接去查
//            calculateRecord.setScore(contractResult.getScore());
            calculateRecord.setContractId(Integer.parseInt(tContract.getId()+""));
            calculateRecord.setCreateTime(new Date());
            calculateRecord.setUpdateTime(new Date());
            calculateRecord.setStatus(PublishType.UNPUBLISHED.getCode());

            calculateRecord.setWhichYear(calendar.get(Calendar.YEAR));
            calculateRecord.setWhichMonth(calendar.get(Calendar.MONTH)+1);
            calculateRecordMapper.insert(calculateRecord);
        }
    }

    /**
     * 保存考核记录
     *
     * @param contractScore  扣分
     * @param contractResult 考核结果
     * @return 考核记录
     */
    private List<ContractResultRecord> getContractResultRecord(List<ContractScore> contractScore, ContractResult contractResult) {
        return contractScore.stream().map(
                item -> {
                    ContractResultRecord record = new ContractResultRecord();
                    BeanUtils.copyProperties(item, record);
                    record.setResultId(contractResult.getId());
                    record.setCreateTime(DateUtils.getNowDate());
                    return record;
                }
        ).toList();
    }

    /**
     * 计算考核结果
     *
     * @param tContract     合同
     * @param contractScore 扣分
     * @return 考核结果
     */
    private ContractResult getCheckResult(TContract tContract, List<ContractScore> contractScore) {
        ContractResult contractResult = new ContractResult();
        contractResult.setUnitId(tContract.getUnitId());
        contractResult.setContractId(tContract.getId());
        contractResult.setPublish(0);
        contractResult.setCheckTime(DateUtils.getNowDate());
        //改为直接去查
//        contractResult.setScore(contractScore.isEmpty() ? new BigDecimal("100") : new BigDecimal("100").subtract(contractScore.stream().map(ContractScore::getScore).reduce(BigDecimal::add).get()));
        return contractResult;
    }


    /**
     * 获取上个月的第一天和最后一天
     */
    public void getLastMonth() {
        LocalDate currentDate = LocalDate.now().minusMonths(1);
        LocalDate firstDayOfMonth = currentDate.withDayOfMonth(1);
        String firstDay = firstDayOfMonth.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
        LocalDate lastDayOfMonth = currentDate.withDayOfMonth(currentDate.lengthOfMonth());
        String lastDay = lastDayOfMonth.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
        this.startTime = firstDay;
        this.endTime = lastDay;
    }
    /**
    * 获取今天的开始时间与结束时间
    * */
    public void getDayStartAndEnd(String startTime,String endTime) {

        LocalDate today = LocalDate.now().minusDays(1);
        LocalDateTime startOfDay = today.atStartOfDay(); // 00:00:00
        LocalDateTime endOfDay = today.atTime(LocalTime.MAX); // 23:59:59.999999999

        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");

        startTime = startOfDay.format(formatter);
        endTime = endOfDay.format(formatter);
    }

}