From 47fbd69642ca944f051ed5fb7bcc93dfc2c5a1cc Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=AB=98=E8=8D=A3=E7=90=B3?= Date: Mon, 18 Sep 2023 21:20:37 +0800 Subject: [PATCH] =?UTF-8?q?feature:=E5=8D=87=E7=BA=A7xxl?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/dxhy/order/consumer/handle/SyncTask.java | 15 +++++++++------ 1 file changed, 9 insertions(+), 6 deletions(-) diff --git a/order-management-consumer/src/main/java/com/dxhy/order/consumer/handle/SyncTask.java b/order-management-consumer/src/main/java/com/dxhy/order/consumer/handle/SyncTask.java index 7dc78ff8..9e642a4f 100644 --- a/order-management-consumer/src/main/java/com/dxhy/order/consumer/handle/SyncTask.java +++ b/order-management-consumer/src/main/java/com/dxhy/order/consumer/handle/SyncTask.java @@ -19,6 +19,7 @@ import com.dxhy.order.baseservice.module.thirdservice.simsback.service.SimsBackS import com.dxhy.order.consumer.modules.manager.service.InvoiceService; import com.dxhy.order.consumer.modules.order.service.OrderProcessService; import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.context.XxlJobHelper; import com.xxl.job.core.handler.IJobHandler; import com.xxl.job.core.handler.annotation.XxlJob; import lombok.extern.slf4j.Slf4j; @@ -54,8 +55,8 @@ public class SyncTask { @Resource private RedisService redisService; - @XxlJob("ukeySyncTask") - public ReturnT execute(String param) { + @XxlJob(value = "ukeySyncTask") + public void ukeySyncTask(String param) { log.debug("{}定时任务开始,请求参数:{}", LOGGER_MSG, param); /** @@ -73,7 +74,7 @@ public class SyncTask { Map paramMap = JsonUtils.getInstance().parseObject(param, Map.class); if (ObjectUtil.isNull(paramMap)) { log.error("{}定时任务请求参数为空:{}", LOGGER_MSG, param); - return ReturnT.FAIL; + return; } List shList = NsrsbhUtils.transShListByXhfNsrsbh((String) paramMap.get("xhfNsrsbh")); @@ -125,11 +126,13 @@ public class SyncTask { } } catch (Exception e) { + XxlJobHelper.log("{}定时任务执行异常:{}", LOGGER_MSG, e); log.error("{}定时任务执行异常:{}", LOGGER_MSG, e); - return ReturnT.FAIL; + return ; } - log.debug("{}定时任务完成", LOGGER_MSG); - return ReturnT.SUCCESS; + XxlJobHelper.log("{}定时任务完成", LOGGER_MSG); + //log.debug("{}定时任务完成", LOGGER_MSG); + return ; }