From 94984cd5d30972218fd51970f0f93c1b7c543438 Mon Sep 17 00:00:00 2001
From: "xiaodong.hu" <1075471126@qq.com>
Date: Tue, 25 Jul 2023 13:54:40 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E7=A8=BD=E6=A0=B8=E8=84=9A?=
 =?UTF-8?q?=E6=9C=AC=E6=89=A7=E8=A1=8C=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/cool/store/job/EcSyncDataJob.java  | 17 +++++++++++++++--
 1 file changed, 15 insertions(+), 2 deletions(-)

diff --git a/coolstore-partner-service/src/main/java/com/cool/store/job/EcSyncDataJob.java b/coolstore-partner-service/src/main/java/com/cool/store/job/EcSyncDataJob.java
index d6254e622..c86786d31 100644
--- a/coolstore-partner-service/src/main/java/com/cool/store/job/EcSyncDataJob.java
+++ b/coolstore-partner-service/src/main/java/com/cool/store/job/EcSyncDataJob.java
@@ -7,6 +7,7 @@ import com.cool.store.mapper.HyPartnerUserInfoMapper;
 import com.cool.store.sdk.ec.EcClient;
 import com.cool.store.sdk.ec.request.SyncEcCustomerRequest;
 import com.cool.store.service.EcSyncService;
+import com.cool.store.utils.StringUtil;
 import com.xxl.job.core.context.XxlJobHelper;
 import com.xxl.job.core.handler.annotation.XxlJob;
 import lombok.extern.slf4j.Slf4j;
@@ -59,8 +60,18 @@ public class EcSyncDataJob {
 
     //定时同步小程序数据到ec
     private void syncAppletToEcExecute() {
+        // 获取参数
+        String param = XxlJobHelper.getJobParam();
+        String startTime = "";
+        if (StringUtil.isNotEmpty(param)) {
+            XxlJobHelper.log("输入参数为：" + param);
+            startTime = param;
+        } else {
+            startTime = getHourDayDate(-5, 0);
+        }
+        String endTime = DateUtil.now();
         //获取总数
-        int size = hyPartnerUserInfoMapper.selectByHourDateCount(getHourDayDate(-5, 0), DateUtil.now());
+        int size = hyPartnerUserInfoMapper.selectByHourDateCount(startTime, endTime);
         //执行数
         int counts = size / count;
         //取余，如果大于1，就再加一
@@ -68,8 +79,10 @@ public class EcSyncDataJob {
         if (yu > 0) {
             counts += 1;
         }
+        XxlJobHelper.log("开始时间为：" + startTime+"，结束时间为："+endTime);
         for (int i = 1; i <= counts; i++) {
-            List<SyncEcCustomerDO> list = hyPartnerUserInfoMapper.selectByHourDate(getHourDayDate(-5, 0), DateUtil.now(),count * (i - 1),count);
+            XxlJobHelper.log("执行limit1：" + count * (i - 1)+"，执行limit2："+count);
+            List<SyncEcCustomerDO> list = hyPartnerUserInfoMapper.selectByHourDate(startTime, endTime,count * (i - 1),count);
             SyncEcCustomerRequest syncEcCustomerRequest = new SyncEcCustomerRequest();
             syncEcCustomerRequest.setParameter(list);
             EcClient ecClient = new EcClient();