From 4995469ae28ce99f5e682895c0708d15f4dc63cd Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 15 十月 2024 14:38:03 +0800
Subject: [PATCH] 将CMQ替换为rabbitmq
---
fanli/src/main/java/com/yeshi/fanli/job/order/UpdateCommonOrderJob.java | 6 +++++-
1 files changed, 5 insertions(+), 1 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/job/order/UpdateCommonOrderJob.java b/fanli/src/main/java/com/yeshi/fanli/job/order/UpdateCommonOrderJob.java
index f365e59..7feb7c9 100644
--- a/fanli/src/main/java/com/yeshi/fanli/job/order/UpdateCommonOrderJob.java
+++ b/fanli/src/main/java/com/yeshi/fanli/job/order/UpdateCommonOrderJob.java
@@ -8,6 +8,7 @@
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.mq.cmq.order.OrdersCMQManager;
+import com.yeshi.fanli.util.mq.rabbit.RabbitmqManager;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
@@ -26,6 +27,9 @@
@Resource
private CommonOrderService commonOrderService;
+ @Resource
+ private OrdersCMQManager ordersCMQManager;
+
@XxlJob("order-update-pay-state")
public ReturnT<String> updatePayState(String param) throws Exception {
//鏇存柊20-25澶╀箣鍓嶇殑鏈鐞嗚鍗�
@@ -40,7 +44,7 @@
resultList = commonOrderService.listPayStateOrder(null, new Date(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * 25), new Date(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * 20), 1, 500);
}
for (CommonOrder co : resultList) {
- OrdersCMQManager.getInstance().addOrder(new CommonOrderMQMsg(co.getOrderNo(), co.getSourceType()));
+ ordersCMQManager.addOrder(new CommonOrderMQMsg(co.getOrderNo(), co.getSourceType()));
}
return ReturnT.SUCCESS;
}
--
Gitblit v1.8.0