From b9b263043cbb2e028017b9a5626c664b54513749 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期一, 14 十月 2024 17:46:11 +0800
Subject: [PATCH] 将CMQ替换为rabbitmq
---
fanli/src/main/java/com/yeshi/fanli/job/order/taobao/UpdateTBRelationAndSpecialOrderJob.java | 8 ++++++--
1 files changed, 6 insertions(+), 2 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/job/order/taobao/UpdateTBRelationAndSpecialOrderJob.java b/fanli/src/main/java/com/yeshi/fanli/job/order/taobao/UpdateTBRelationAndSpecialOrderJob.java
index c6bd6f3..aaa8dcc 100644
--- a/fanli/src/main/java/com/yeshi/fanli/job/order/taobao/UpdateTBRelationAndSpecialOrderJob.java
+++ b/fanli/src/main/java/com/yeshi/fanli/job/order/taobao/UpdateTBRelationAndSpecialOrderJob.java
@@ -8,6 +8,7 @@
import javax.annotation.Resource;
import com.yeshi.fanli.util.*;
+import com.yeshi.fanli.util.mq.rabbit.RabbitmqManager;
import org.springframework.stereotype.Component;
import com.xxl.job.core.biz.model.ReturnT;
@@ -33,6 +34,9 @@
@Resource
private RedisManager redisManager;
+
+ @Resource
+ private RabbitmqManager rabbitmqManager;
/**
* 鏇存柊娓犻亾璁㈠崟
@@ -122,9 +126,9 @@
if (orders != null && orders.size() > 0 && System.currentTimeMillis()
- TimeUtil.convertToTimeTemp(orders.get(0).getCreateTime(), "yyyy-MM-dd HH:mm:ss") < 1000
* 60 * 10L)// 10鍒嗛挓鍐呬骇鐢熺殑鍗曚綔涓烘柊璁㈠崟澶勭悊
- CMQManager.getInstance().addTaoBaoNewOrderMsg(key);
+ rabbitmqManager.addTaoBaoNewOrderMsg(key);
else
- CMQManager.getInstance().addTaoBaoOrderMsg(key);
+ rabbitmqManager.addTaoBaoOrderMsg(key);
try {
// 20鍒嗛挓鍐呬笉鍐嶅鐞�
--
Gitblit v1.8.0