From ebbbe9c349a707136aa13f1bf8201517881f5967 Mon Sep 17 00:00:00 2001 From: xhxu Date: Sat, 7 May 2022 13:16:49 +0800 Subject: [PATCH] //update push --- .../schedule/TtOrderPushErrorSchedule.java | 41 +++++++++++++++++++ 1 file changed, 41 insertions(+) create mode 100644 mallinkSchedule/src/main/java/com/iformall/schedule/TtOrderPushErrorSchedule.java diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/TtOrderPushErrorSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/TtOrderPushErrorSchedule.java new file mode 100644 index 000000000..d91f80c46 --- /dev/null +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/TtOrderPushErrorSchedule.java @@ -0,0 +1,41 @@ +package com.iformall.schedule; + +import com.iformall.domain.po.TtOrderPushError; +import com.iformall.mapper.TtOrderPushErrorMapper; +import com.iformall.service.WxOrderService; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.scheduling.annotation.Async; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; + +import java.util.List; + +@Component +public class TtOrderPushErrorSchedule { + + private final Logger logger = LoggerFactory.getLogger(this.getClass()); + + @Autowired + private TtOrderPushErrorMapper ttOrderPushErrorMapper; + + @Autowired + private WxOrderService wxOrderService; + + @Async + @Scheduled(cron = "0 0 1 * * ?") + public void OrderPushErrorTaskSchedule() { + List orderPushErrors = ttOrderPushErrorMapper.findList(new TtOrderPushError()); + if(orderPushErrors != null && orderPushErrors.size() > 0){ + for (TtOrderPushError error:orderPushErrors) { + try{ + wxOrderService.sendInsideOrderPushMsg(error,error.getId()); + }catch(Exception e){ + logger.error("订单同步重试error"); + } + } + } + } + +} \ No newline at end of file