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/service/manger/JobManager.java | 80 ----------------------------------------
1 files changed, 0 insertions(+), 80 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/manger/JobManager.java b/fanli/src/main/java/com/yeshi/fanli/service/manger/JobManager.java
index 9236c69..a838159 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/manger/JobManager.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/manger/JobManager.java
@@ -166,8 +166,6 @@
*/
public void start() {
doExtractResult();// 澶勭悊鎻愮幇缁撴灉
- doTaoBaoOrders();// 澶勭悊娣樺疂璁㈠崟
- doTaoBaoNewOrders();// 澶勭悊娣樺疂璁㈠崟锛堝垰鍒氫骇鐢熺殑锛�
doOrderFanLiNew();// 鏂扮増杩斿埄
doOrderShareFanLi();
doWeiQuanOrder();// 澶勭悊缁存潈璁㈠崟
@@ -257,84 +255,6 @@
}
}
});
- }
-
- /**
- * 澶勭悊娣樺疂璁㈠崟
- */
- public void doTaoBaoOrders() {
- String methodName = getMethodName(Thread.currentThread());
- // 鍚屾椂寮�鍚�3涓嚎绋嬪鐞�
- for (int i = 0; i < 3; i++) {
- new JobThreadExecutorServiceImpl().run(new MyRunnable(methodName) {
- @Override
- public void run() {
- super.run();
- try {
- // 鍙�16涓鍗�
- List<String> orderIds = CMQManager.getInstance().consumeTaoBaoOrderMsg(16);
- if (orderIds != null) {
- for (String orderId : orderIds) {
- if (NumberUtil.isNumeric(orderId.trim())) {
- Map<String, List<TaoBaoOrder>> map = new HashMap<>();
- List<TaoBaoOrder> orderList = taoBaoOrderService
- .getTaoBaoOrderByOrderId(orderId);
- map.put(orderId, orderList);
- LogHelper.orderInfo("寮�濮嬪鐞嗚鍗�:" + orderId);
- orderProcessService.processOrder(map);
- LogHelper.orderInfo("缁撴潫澶勭悊璁㈠崟:" + orderId);
- }
- }
- }
- } catch (Exception e) {
- try {
- LogHelper.errorDetailInfo(e);
- } catch (Exception e1) {
-
- }
- }
- }
- });
- }
- }
-
- /**
- * 鍒氬垰浜х敓鐨勮鍗�
- */
- public void doTaoBaoNewOrders() {
- String methodName = getMethodName(Thread.currentThread());
- // 鍚屾椂寮�鍚�3涓嚎绋嬪鐞�
- for (int i = 0; i < 1; i++) {
- new JobThreadExecutorServiceImpl().run(new MyRunnable(methodName) {
- @Override
- public void run() {
- super.run();
- try {
- // 鍙�16涓鍗�
- List<String> orderIds = CMQManager.getInstance().consumeTaoBaoNewOrderMsg(16);
- Map<String, List<TaoBaoOrder>> map = new HashMap<>();
- if (orderIds != null) {
- for (String orderId : orderIds) {
- List<TaoBaoOrder> orderList = taoBaoOrderService.getTaoBaoOrderByOrderId(orderId);
- map.put(orderId, orderList);
-
- LogHelper.orderInfo("鏂拌鍗�-寮�濮嬪鐞嗚鍗�:" + orderId);
- long startTime = System.currentTimeMillis();
- orderProcessService.processOrder(map);
- LogHelper.orderInfo("鏂拌鍗�-缁撴潫澶勭悊璁㈠崟:" + orderId + "- 澶勭悊鏃堕棿:"
- + (System.currentTimeMillis() - startTime));
- }
- }
- } catch (Exception e) {
- try {
- LogHelper.errorDetailInfo(e);
- } catch (Exception e1) {
-
- }
- }
- }
- });
- }
}
/**
--
Gitblit v1.8.0