diff --git a/common-collect/src/main/java/com/docus/server/collect/dept/ws/DeptWsCollectJob.java b/common-collect/src/main/java/com/docus/server/collect/dept/ws/DeptWsCollectJob.java index 9ba8f72..106c610 100644 --- a/common-collect/src/main/java/com/docus/server/collect/dept/ws/DeptWsCollectJob.java +++ b/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 { * 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 { * xxl jobhandler 配置定时启动,如果未完成任务跳过。 */ @XxlJob("startIncDeptWsCollect") - public void startIncDeptWsCollect() { + @TrackRetryListener("startIncDeptWsCollect") + public void startIncDeptWsCollect(String param) { super.startCollectIncrement(getJobParam()); }