feature:升级xxl

release
高荣琳 2 years ago
parent 735b3bdd49
commit 47fbd69642
  1. 15
      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.manager.service.InvoiceService;
import com.dxhy.order.consumer.modules.order.service.OrderProcessService; import com.dxhy.order.consumer.modules.order.service.OrderProcessService;
import com.xxl.job.core.biz.model.ReturnT; 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.IJobHandler;
import com.xxl.job.core.handler.annotation.XxlJob; import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
@ -54,8 +55,8 @@ public class SyncTask {
@Resource @Resource
private RedisService redisService; private RedisService redisService;
@XxlJob("ukeySyncTask") @XxlJob(value = "ukeySyncTask")
public ReturnT<String> execute(String param) { public void ukeySyncTask(String param) {
log.debug("{}定时任务开始,请求参数:{}", LOGGER_MSG, param); log.debug("{}定时任务开始,请求参数:{}", LOGGER_MSG, param);
/** /**
@ -73,7 +74,7 @@ public class SyncTask {
Map paramMap = JsonUtils.getInstance().parseObject(param, Map.class); Map paramMap = JsonUtils.getInstance().parseObject(param, Map.class);
if (ObjectUtil.isNull(paramMap)) { if (ObjectUtil.isNull(paramMap)) {
log.error("{}定时任务请求参数为空:{}", LOGGER_MSG, param); log.error("{}定时任务请求参数为空:{}", LOGGER_MSG, param);
return ReturnT.FAIL; return;
} }
List<String> shList = NsrsbhUtils.transShListByXhfNsrsbh((String) paramMap.get("xhfNsrsbh")); List<String> shList = NsrsbhUtils.transShListByXhfNsrsbh((String) paramMap.get("xhfNsrsbh"));
@ -125,11 +126,13 @@ public class SyncTask {
} }
} catch (Exception e) { } catch (Exception e) {
XxlJobHelper.log("{}定时任务执行异常:{}", LOGGER_MSG, e);
log.error("{}定时任务执行异常:{}", LOGGER_MSG, e); log.error("{}定时任务执行异常:{}", LOGGER_MSG, e);
return ReturnT.FAIL; return ;
} }
log.debug("{}定时任务完成", LOGGER_MSG); XxlJobHelper.log("{}定时任务完成", LOGGER_MSG);
return ReturnT.SUCCESS; //log.debug("{}定时任务完成", LOGGER_MSG);
return ;
} }

Loading…
Cancel
Save