提交一把

jiangping

2024-07-30 94b15dee8f8a9d181f14e99eaa620e52f197ee35

 server/platform/src/main/java/com/doumee/task/ScheduleTool.java

@@ -1,6 +1,11 @@
package com.doumee.task;


import com.doumee.dao.business.model.InsuranceApply;
import com.doumee.service.business.CompanyService;
import com.doumee.service.business.InsuranceApplyService;
import com.doumee.service.business.UnionApplyService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
@@ -14,16 +19,83 @@
 */
@Component
@EnableScheduling
@Slf4j
public class ScheduleTool {
    @Autowired
    private CompanyService companyService;

    @Autowired
    private InsuranceApplyService insuranceApplyService;

    @Autowired
    private UnionApplyService unionApplyService;


    /**
     * 定时处理爬虫源数据，生成素材库数据
     * @throws Exception
     */
    @Scheduled(fixedDelay=30*60*1000,initialDelay = 30000)
    public void dealOploadEvent() throws Exception {

    @Scheduled(fixedDelay= 60*1000,initialDelay = 30000)
    public void startSignAuthAuto() throws Exception {
        log.info("==============定时注册企业君子签账号=======start======");
        companyService.startSignAuthAuto();
        log.info("==============定时注册企业君子签账号======end=======");
    }
    /**
     * @throws Exception
     */
    @Scheduled(fixedDelay= 60*1000,initialDelay = 30000)
    public void dealComSignAuthStatus() throws Exception {
        log.info("==============定时查询企业电子签认证状态=======start======");
        companyService.dealSignAuthStatus();
        log.info("==============定时查询企业电子签认证状态======end=======");
    }
    /**
     * @throws Exception
     */
    @Scheduled(fixedDelay= 60*1000*2 ,initialDelay = 30000)
    public void deal() throws Exception {
        log.info("==============定时查询企业电子签签署状态=======start======");
        insuranceApplyService.dealWaitSignedData();
        log.info("==============定时查询企业电子签签署状态======end=======");
    }
    /**
     * @throws Exception
     */
    @Scheduled(fixedDelay= 60*1000,initialDelay = 30000)
    public void dealComSigIdStatus() throws Exception {
        log.info("==============定时上传待上传的企业电子印章数据=======start======");
        companyService.dealSignIdStatus();
        log.info("==============定时上传待上传的企业电子印章数据======end=======");
    }


    /**
     * 定时更新保单金额 每天凌晨 12.05 分执行
     * @throws Exception
     */
    @Scheduled(cron = "0 5 00 * * ?")
    public void updateApplyCurrentFee(){
        log.info("==============定时更新保单实际金额=======start======");
        insuranceApplyService.updateApplyCurrentFee(null,null);
        log.info("==============定时更新保单实际金额======end=======");

        log.info("==============定时更新合并单实际金额=======start======");
        unionApplyService.updateUnionApplyCurrentFee(null);
        log.info("==============定时更新合并单实际金额======end=======");
    }



    /**
     * 定时更新生成续保提醒
     * @throws Exception
     */
    @Scheduled(cron = "0 1 00 * * ?")
    public void generateNotice(){
        log.info("==============定时更新生成续保提醒=======start======");
        insuranceApplyService.generateNotice();
        log.info("==============定时更新生成续保提醒======end=======");
    }


}