blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zxl
4 天以前 f77a9d8f16bae6b4cf809891f037c038070e81ed 
 ycl-server/src/main/java/com/ycl/task/ContractResultTask.java


@@ -1,22 +1,28 @@


package com.ycl.task;




import com.ycl.platform.domain.entity.CheckResult;


import com.ycl.platform.domain.entity.ContractResultRecord;


import com.ycl.platform.domain.entity.ContractScore;


import com.ycl.platform.domain.entity.TContract;


import com.ycl.platform.service.ICheckResultService;


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 jakarta.annotation.PostConstruct;


import enumeration.general.CalculateReportStatusEnum;


import enumeration.general.PublishType;


import lombok.Data;


import org.springframework.scheduling.annotation.Scheduled;


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.ArrayList;


import java.util.Calendar;


import java.util.Date;


import java.util.List;




/**


@@ -24,23 +30,71 @@


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


 */




@Component


@Slf4j


@Data


@Component("contractResultTask")


public class ContractResultTask {




    private final ITContractService contractService;


    private final IContractScoreService contractScoreService;


    private final ICheckResultService checkResultService;




    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号执行


     * 每个月1号执行，统计考核结果


     */


    @Scheduled(cron = "0 0 0 1 * ?")


    // @PostConstruct


    // 多表


    @Transactional


    public void contractResultTask() {


        // 查询有效期内的合同


        List<TContract> list = contractService.selectUsingContract();


@@ -49,17 +103,66 @@


            // 上个月扣分记录


            List<ContractScore> contractScore = contractScoreService.getDateRangeScoreByContractId(tContract.getId(), startTime, endTime);


            // 新增考核结果


            CheckResult checkResult = new CheckResult();


            checkResult.setUnitId(tContract.getUnitId());


            checkResult.setContractId(tContract.getId());


            checkResult.setPublish(0);


            checkResult.setCheckTime(DateUtils.getNowDate());


            checkResultService.save(checkResult);


            // 新增考核结果记录


            List<ContractResultRecord> contractResultRecord = new ArrayList<>();


            BeanUtils.copyBeanProp(contractResultRecord, contractScore);


            checkResultService.saveBatchRecord(contractResultRecord);


            //获取上个月时间


            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;


    }






@@ -75,5 +178,19 @@


        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);


    }




}