同步勤策 - 部门/人员/终端数据

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

-package com.wangxiaolu.promotion.timedtask;
+package com.wangxiaolu.promotion.xxljobtask;
 
+import com.wangxiaolu.promotion.service.user.QinCeDataTaskService;
 import com.xxl.job.core.context.XxlJobHelper;
 import com.xxl.job.core.handler.annotation.XxlJob;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
-import java.util.concurrent.TimeUnit;
-
 /**
- * XxlJob开发示例（Bean模式）
  *
  * 开发步骤：
  *      1、任务开发：在Spring Bean实例中，开发Job方法；
@@ -22,17 +21,38 @@ import java.util.concurrent.TimeUnit;
 @Slf4j
 public class XxlJobHandler {
 
+    @Autowired
+    QinCeDataTaskService qinCeDataTaskService;
+
+
     /**
-     * 1、简单任务示例（Bean模式）
+     * 同步组织架构/部门数据
      */
-    @XxlJob("demoJobHandler")
-    public void demoJobHandler() throws Exception {
-        log.info("XXL-JOB, Hello World.");
+    @XxlJob("qince_department_task")
+    public void departmentSyncTask(){
+        log.info("[xxl-job] start === 同步勤策部门数据");
+        qinCeDataTaskService.departmentSyncTask();
+        log.info("[xxl-job] end === 同步勤策部门数据");
+    }
 
-        for (int i = 0; i < 5; i++) {
-            XxlJobHelper.log("test beat at:" + i);
+    /**
+     * 同步员工数据
+     */
+    @XxlJob("qince_employee_task")
+    public void employeeSyncTask(){
+        log.info("[xxl-job] start === 同步员工数据");
+        qinCeDataTaskService.employeeSyncTask();
+        log.info("[xxl-job] end === 同步员工数据");
     }
-        log.info("xxl job task end");
+
+    /**
+     * 同步[终端数据]
+     */
+    @XxlJob("qince_shop_task")
+    public void shopDetailAllTask(){
+        log.info("[xxl-job] start === 同步终端数据");
+        qinCeDataTaskService.shopDetailAllTask();
+        log.info("[xxl-job] end === 同步终端数据");
     }
 
 }