feat add Scheduled

dengwei
1 parent 58c17ebf
Showing 1 changed file with 12 additions and 5 deletions
cashier-mall/src/main/java/com/diligrp/cashier/mall/service/sourcechannel/RtMallChannel.java
@@ -31,6 +31,9 @@ import org.springframework.stereotype.Component;
 import java.util.List;
 import java.util.Map;
 import java.util.Objects;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
 /**
  * @ClassName RtMallChannel.java
@@ -43,6 +46,8 @@ import java.util.Objects;
 @Component
 public class RtMallChannel extends AbstractSourceChannel {
     private static final Logger LOG = LoggerFactory.getLogger(RtMallChannel.class);
+    private static final ScheduledExecutorService SCHEDULER = Executors.newScheduledThreadPool(5,
+            Thread.ofVirtual().name("delay-cashier-", 0).factory());
     @Override
     public String authUrl(AuthLoginCO authLogin, String token, long timestamp) {
@@ -97,11 +102,13 @@ public class RtMallChannel extends AbstractSourceChannel {
      */
     @Override
     public void refundCallBack(RefundResultBO event, MallBizRefund mallBizRefund) {
-        MallBizOrder mallBizOrder = mallBizOrderDao.selectByPrimaryKey(mallBizRefund.getBizOrderId());
-        // 目前大润发只对小程序支付存在回调逻辑
-        if (Objects.equals(mallBizOrder.getOrderType(), OrderType.MINI_PROGRAM.code)) {
-            refundCallBack(event, mallBizOrder, mallBizRefund);
-        }
+        SCHEDULER.schedule(() -> {
+            MallBizOrder mallBizOrder = mallBizOrderDao.selectByPrimaryKey(mallBizRefund.getBizOrderId());
+            // 目前大润发只对小程序支付存在回调逻辑
+            if (Objects.equals(mallBizOrder.getOrderType(), OrderType.MINI_PROGRAM.code)) {
+                refundCallBack(event, mallBizOrder, mallBizRefund);
+            }
+        }, 5, TimeUnit.SECONDS);
     }
     /**