From d120068846683acee24f6e2e0b96bc9e792062af Mon Sep 17 00:00:00 2001 From: linrf Date: Thu, 29 Jun 2023 18:28:05 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=BB=E5=8A=A8=E4=BB=BB=E5=8A=A1=E9=87=8D?= =?UTF-8?q?=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../server/collect/dept/ws/DeptWsCollectJob.java | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) 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()); }