更新全量有效员工数据

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

@@ -17,4 +17,7 @@ public interface QinCeDataTaskService {
     void productAllTask();
 
     void productDealers();
+
+    void employeeSyncTaskAll();
+
 }

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

@@ -137,6 +137,22 @@ public class QinCeDataTaskServiceImpl implements QinCeDataTaskService {
         }
     }
 
+    @Override
+    public void employeeSyncTaskAll() {
+        // 查询组织架构参数、创建url
+        Map<String, Object> params = qinCeUtils.queryEmployeeAllParam();
+        String url = qinCeUtils.builderUrl(QinCeUtils.QUERY_EMPLOYEE, params);
+        // 发起请求、接收结果
+        JSONObject resultJson = OkHttp.postQC(url, params);
+        JSONArray responseDatas = resultJson.getJSONArray("response_data");
+
+        if (responseDatas.size() <= 0) {
+            log.error("勤策-同步所有有效人员数据，未查询到数据");
+            return;
+        }
+        qinCeEmployeeDao.employeeSyncTask(responseDatas);
+    }
+
     private boolean booleanDealersPage(Integer pageNum){
         Map<String, Object> params = qinCeUtils.queryDealerParam(pageNum);
         String url = qinCeUtils.builderUrl(QinCeUtils.QUERY_DEALER, params);

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

@@ -103,6 +103,16 @@ public class QinCeUtils {
         return params;
     }
 
+    /**
+     * 查询[人员]参数
+     */
+    public Map<String, Object> queryEmployeeAllParam() {
+        Map<String, Object> params = new HashMap<>();
+//        0：删除，1：正常，2：停用
+        params.put("emp_status", "1");
+        return params;
+    }
+
     /**
      * 查询[客户管理-终端]参数
      */

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

@@ -52,7 +52,17 @@ public class XxlJobHandler {
     public void employeeSyncTaskToday(){
         log.info("[xxl-job] start === 同步今日修改过的员工数据");
         qinCeDataTaskService.employeeSyncTask(0);
-        log.info("[xxl-job] end === 同步今日修改过的员工修改数据");
+        log.info("[xxl-job] end === 同步今日修改过的员工数据");
+    }
+
+    /**
+     * t更新的全量员工数据
+     */
+    @XxlJob("qince_employee_task_all")
+    public void employeeSyncTaskAll(){
+        log.info("[xxl-job] start === 同步全量有效员工数据");
+        qinCeDataTaskService.employeeSyncTaskAll();
+        log.info("[xxl-job] end === 同步全量有效员工数据");
     }
 
     /**