同步勤策数据时间间隔修改

src/main/java/com/wangxiaolu/promotion/utils/QinCeUtils.java

@@ -80,17 +80,18 @@ public class QinCeUtils {
     }
 
     /**
-     *todo 全量查 查询[部门]参数
+     * 全量 查询[部门]参数
      */
     public Map<String, Object> queryOrgParam() {
         Map<String, Object> params = new HashMap<>();
-        DateTime dateTime = DateUtil.offsetDay(new Date(), -1);
-        params.put("modify_date", DateUtil.format(dateTime, DatePattern.NORM_DATE_PATTERN));
+//        DateTime dateTime = DateUtil.offsetDay(new Date(), -1);
+//        params.put("modify_date", DateUtil.format(dateTime, DatePattern.NORM_DATE_PATTERN));
+        params.put("modify_date", "");
         return params;
     }
 
     /**
-     * todo 查询[人员]参数
+     * 查询[人员]参数
      */
     public Map<String, Object> queryEmployeeParam(boolean queryId) {
         Map<String, Object> params = new HashMap<>();
@@ -98,8 +99,9 @@ public class QinCeUtils {
         if (queryId) {
             params.put("id", "");
         }
-        DateTime dateTime = DateUtil.offsetDay(new Date(), -1);
-        params.put("modify_date", DateUtil.format(dateTime, DatePattern.NORM_DATE_PATTERN));
+//        DateTime dateTime = DateUtil.offsetDay(new Date(), -1);
+//        params.put("modify_date", DateUtil.format(dateTime, DatePattern.NORM_DATE_PATTERN));
+        params.put("modify_date", "");
         return params;
     }
 
@@ -111,7 +113,7 @@ public class QinCeUtils {
         // 分页页码，默认1
         params.put("page_number", pageNum);
         // 查询指定数据 params.put("store_code", "POS00040423"); after_modify_date：查询更新时间(2小时之内)的门店数据。格式：yyyy-MM-dd HH:mm:SS
-        DateTime dateTime = DateUtil.offsetHour(new Date(), -2);
+        DateTime dateTime = DateUtil.offsetDay(new Date(), -1);
         params.put("after_modify_date", DateUtil.format(dateTime, DatePattern.NORM_DATETIME_PATTERN));
         return params;
     }
@@ -153,15 +155,16 @@ public class QinCeUtils {
         return params;
     }
 
+    /**
+     * 同步「经销商」数据
+     */
     public Map<String, Object> queryDealerParam(Integer pageNum) {
         Map<String, Object> params = new HashMap<>();
         params.put("page_number", pageNum);
-//        记录状态。0：已删除，1：正常 params.put("status", "1");
 
-        //todo 全量数据同步后，再开启指定日期同步
-//        DateTime dateTime = DateUtil.offsetHour(new Date(), -2);
-//        params.put("after_create_date", DateUtil.format(dateTime, DatePattern.NORM_DATETIME_PATTERN));
-        params.put("after_create_date", "");
+        // 全量数据同步后，再开启指定日期同步
+        DateTime dateTime = DateUtil.offsetDay(new Date(), -1);
+        params.put("after_create_date", DateUtil.format(dateTime, DatePattern.NORM_DATETIME_PATTERN));
         return params;
     }
 }

src/main/java/com/wangxiaolu/promotion/xxljobtask/XxlJobHandler.java

@@ -31,9 +31,9 @@ public class XxlJobHandler {
      */
     @XxlJob("qince_department_task")
     public void departmentSyncTask(){
-        log.info("[xxl-job] start === 同步勤策部门——昨天修改数据");
+        log.info("[xxl-job] start === 同步全量勤策部门数据");
         qinCeDataTaskService.departmentSyncTask();
-        log.info("[xxl-job] end === 同步勤策部门——昨天修改数据");
+        log.info("[xxl-job] end === 同步全量勤策部门数据");
     }
 
     /**
@@ -42,9 +42,9 @@ public class XxlJobHandler {
      */
     @XxlJob("qince_employee_task")
     public void employeeSyncTask(){
-        log.info("[xxl-job] start === 同步员工——昨天修改数据");
+        log.info("[xxl-job] start === 同步全量员工数据");
         qinCeDataTaskService.employeeSyncTask();
-        log.info("[xxl-job] end === 同步员工——昨天修改数据");
+        log.info("[xxl-job] end === 同步全量员工修改数据");
     }
 
     /**
@@ -54,9 +54,9 @@ public class XxlJobHandler {
      */
     @XxlJob("qince_shop_task")
     public void shopDetailAllTask(){
-        log.info("[xxl-job] start === 同步终端数据");
+        log.info("[xxl-job] start === 同步近1日内终端数据");
         qinCeDataTaskService.shopDetailAllTask();
-        log.info("[xxl-job] end === 同步终端数据");
+        log.info("[xxl-job] end === 同步近1日内终端数据");
     }
 
     /**
@@ -85,14 +85,14 @@ public class XxlJobHandler {
 
     /**
      * 同步[经销商列表]
-     * 近2日内更新的经销商
+     * 近1日内更新的经销商
      * 0 0 2
      */
     @XxlJob("qince_dealers")
     public void dealersTask(){
-        log.info("[xxl-job] start === 同步经销商");
+        log.info("[xxl-job] start === 同步近1日内经销商");
         qinCeDataTaskService.productDealers();
-        log.info("[xxl-job] end === 同步经销商");
+        log.info("[xxl-job] end === 同步近1日内经销商");
     }
 
 }