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