From 62a447d89331aee1feae7724c7616aa1bb2cfe79 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 16 十月 2024 14:28:37 +0800
Subject: [PATCH] 将CMQ替换为rabbitmq
---
fanli/src/main/java/com/yeshi/fanli/job/order/UpdateCommonOrderJob.java | 25 ++++++++++++++++++-------
1 files changed, 18 insertions(+), 7 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 8318e04..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
@@ -5,7 +5,10 @@
import com.yeshi.fanli.dto.mq.order.body.CommonOrderMQMsg;
import com.yeshi.fanli.entity.order.CommonOrder;
import com.yeshi.fanli.service.inter.order.CommonOrderService;
+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;
@@ -24,17 +27,25 @@
@Resource
private CommonOrderService commonOrderService;
+ @Resource
+ private OrdersCMQManager ordersCMQManager;
+
@XxlJob("order-update-pay-state")
public ReturnT<String> updatePayState(String param) throws Exception {
//鏇存柊20-25澶╀箣鍓嶇殑鏈鐞嗚鍗�
- List<CommonOrder> 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()));
+ List<CommonOrder> resultList = null;
+ if (!StringUtil.isNullOrEmpty(param)) {
+ if (param.length() > 1) {
+ resultList = commonOrderService.getByOrderNo(null, param);
+ } else {
+ resultList = commonOrderService.listPayStateOrder(Integer.parseInt(param), new Date(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * 25), new Date(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * 10), 1, 500);
+ }
+ } else {
+ 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.addOrder(new CommonOrderMQMsg(co.getOrderNo(), co.getSourceType()));
}
return ReturnT.SUCCESS;
}
-
-
-
-
}
--
Gitblit v1.8.0