[fixed]我来贷未推送数据存入到定时器中

ab

2024-11-04 09d882262f530ded672f1c01fb65a1fefa00d52d

 src/main/java/com/nova/sankuai/DefaultScheduleTask.java

@@ -1,12 +1,12 @@
package com.nova.sankuai;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.nova.sankuai.domain.entity.CustomerWldPushRecord;
import com.nova.sankuai.domain.entity.PayRecord;
import com.nova.sankuai.infra.utils.MessageCodeUtil;
import com.nova.sankuai.service.ICapitalInfoService;
import com.nova.sankuai.service.ICustomerCapitalResultService;
import com.nova.sankuai.service.IPayRecordService;
import com.nova.sankuai.service.IYqgRepayOrderService;
import com.nova.sankuai.infra.utils.wolaidai.WolaidaiUtil;
import com.nova.sankuai.infra.utils.zcy.ZcyUtil;
import com.nova.sankuai.service.*;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
@@ -19,6 +19,7 @@

import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.util.List;

@Configuration
@EnableScheduling
@@ -36,6 +37,9 @@

    @Resource
    private ICustomerCapitalResultService customerCapitalResultService;

    @Resource
    private ICustomerWldPushRecordService customerWldPushRecordService;

    @Resource
    private ICapitalInfoService capitalInfoService;
@@ -98,6 +102,20 @@
        payRecordService.remove(wrapper);
    }

    @Resource
    private WolaidaiUtil wolaidaiUtil;
    /**
     * ab于2024-11-04日新增：每隔5分钟执行一次任务，推送我来贷未推送过的数据
     */
    @Scheduled(fixedRate = 300000) //每隔5分钟执行一次任务, 单位为毫秒
    private void wldPush() {

        List<CustomerWldPushRecord> lst = customerWldPushRecordService.list();
        for (CustomerWldPushRecord customerWldPushRecord : lst) {
            wolaidaiUtil.wldCronPush(customerWldPushRecord);
        }
    }

    /*@ApiOperation(value = "定时每天9点半开启慧借")
    @Scheduled(cron = "0 30 9 * * ?")
    private void startHj() {