勤策更新的员工数据，t-1、t日

src/main/java/com/wangxiaolu/promotion/service/user/QinCeDataTaskService.java

@@ -8,7 +8,7 @@ package com.wangxiaolu.promotion.service.user;
 public interface QinCeDataTaskService {
     void departmentSyncTask();
 
-    void employeeSyncTask();
+    void employeeSyncTask(int offset);
 
     void shopDetailAllTask();
 

src/main/java/com/wangxiaolu/promotion/service/user/impl/QinCeDataTaskServiceImpl.java

@@ -64,9 +64,9 @@ public class QinCeDataTaskServiceImpl implements QinCeDataTaskService {
     }
 
     @Override
-    public void employeeSyncTask() {
+    public void employeeSyncTask(int offset) {
         // 查询组织架构参数、创建url
-        Map<String, Object> params = qinCeUtils.queryEmployeeParam(false);
+        Map<String, Object> params = qinCeUtils.queryEmployeeParam(offset);
         String url = qinCeUtils.builderUrl(QinCeUtils.QUERY_EMPLOYEE, params);
         // 发起请求、接收结果
         JSONObject resultJson = OkHttp.postQC(url, params);

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

@@ -92,13 +92,13 @@ public class QinCeUtils {
     /**
      * 查询[人员]参数
      */
-    public Map<String, Object> queryEmployeeParam(boolean queryId) {
+    public Map<String, Object> queryEmployeeParam(int offset) {
         Map<String, Object> params = new HashMap<>();
         // 根据来源勤策的员工唯一标识精确查询
-        if (queryId) {
-            params.put("id", "");
-        }
-        DateTime dateTime = DateUtil.offsetDay(new Date(), -1);
+//        if (queryId) {
+//            params.put("id", "");
+//        }
+        DateTime dateTime = DateUtil.offsetDay(new Date(), offset);
         params.put("modify_date", DateUtil.format(dateTime, DatePattern.NORM_DATE_PATTERN));
         return params;
     }

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

@@ -45,10 +45,20 @@ public class XxlJobHandler {
     @XxlJob("qince_employee_task")
     public void employeeSyncTask(){
         log.info("[xxl-job] start === 同步昨日修改过的员工数据");
-        qinCeDataTaskService.employeeSyncTask();
+        qinCeDataTaskService.employeeSyncTask(-1);
         log.info("[xxl-job] end === 同步昨日修改过的员工修改数据");
     }
 
+    /**
+     * t更新的员工数据
+     */
+    @XxlJob("qince_employee_task_today")
+    public void employeeSyncTaskToday(){
+        log.info("[xxl-job] start === 同步今日修改过的员工数据");
+        qinCeDataTaskService.employeeSyncTask(0);
+        log.info("[xxl-job] end === 同步今日修改过的员工修改数据");
+    }
+
     /**
      * 1小时内修改过的终端数据
      */

src/test/java/com/wangxiaolu/promotion/utils/OkHttpTest.java

@@ -47,7 +47,7 @@ class OkHttpTest {
     @Test
     void postEmployee() {
         // 查询组织架构参数
-        Map<String, Object> params = qinCeUtils.queryEmployeeParam(false);
+        Map<String, Object> params = qinCeUtils.queryEmployeeParam(0);
 
         // 创建url
         String url = qinCeUtils.builderUrl(QinCeUtils.QUERY_EMPLOYEE,params);