主动任务重试

common-collect/src/main/java/com/docus/server/collect/dept/ws/DeptWsCollectJob.java

@@ -1,10 +1,11 @@
 package com.docus.server.collect.dept.ws;
 
+import com.docus.log.annotation.TrackRetryListener;
 import com.docus.server.collect.ICollector;
-import com.docus.server.entity.TaskConfig;
 import com.docus.server.collect.web.job.AbstractCollectJob;
-import com.docus.server.util.PeriodTime;
+import com.docus.server.entity.TaskConfig;
 import com.docus.server.sys.common.pojo.dto.DeptDTO;
+import com.docus.server.util.PeriodTime;
 import com.xxl.job.core.handler.annotation.XxlJob;
 import org.springframework.stereotype.Component;
 
@@ -26,7 +27,8 @@ public class DeptWsCollectJob extends AbstractCollectJob<DeptDTO> {
      * xxl jobhandler 手工执行
      */
     @XxlJob("startAllDeptWsCollect")
-    public void startAllDeptWsCollect() {
+    @TrackRetryListener("startAllDeptWsCollect")
+    public void startAllDeptWsCollect(String param) {
         super.startCollectAll(getJobParam());
     }
 
@@ -34,7 +36,8 @@ public class DeptWsCollectJob extends AbstractCollectJob<DeptDTO> {
      * xxl jobhandler 配置定时启动，如果未完成任务跳过。
      */
     @XxlJob("startIncDeptWsCollect")
-    public void startIncDeptWsCollect() {
+    @TrackRetryListener("startIncDeptWsCollect")
+    public void startIncDeptWsCollect(String param) {
         super.startCollectIncrement(getJobParam());
     }