From 09d882262f530ded672f1c01fb65a1fefa00d52d Mon Sep 17 00:00:00 2001
From: ab <myjf007@126.com>
Date: Tue, 05 Nov 2024 09:37:41 +0800
Subject: [PATCH] [fixed]我来贷未推送数据存入到定时器中
---
src/main/java/com/nova/sankuai/DefaultScheduleTask.java | 26 ++++++++++++++++++++++----
1 files changed, 22 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/nova/sankuai/DefaultScheduleTask.java b/src/main/java/com/nova/sankuai/DefaultScheduleTask.java
index 952ece4..5a32d78 100644
--- a/src/main/java/com/nova/sankuai/DefaultScheduleTask.java
+++ b/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() {
--
Gitblit v1.9.3