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/service/impl/order/OrderProcessServiceImpl.java | 102 +++++++++++++++++++++-----------------------------
1 files changed, 43 insertions(+), 59 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderProcessServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderProcessServiceImpl.java
index 94ba7da..3aa2546 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderProcessServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderProcessServiceImpl.java
@@ -1,32 +1,5 @@
package com.yeshi.fanli.service.impl.order;
-import java.math.BigDecimal;
-import java.math.RoundingMode;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import java.util.UUID;
-
-import javax.annotation.Resource;
-
-import com.yeshi.fanli.entity.SystemEnum;
-import com.yeshi.fanli.entity.SystemPIDInfo;
-import com.yeshi.fanli.entity.dy.DYOrder;
-import com.yeshi.fanli.service.manger.PIDManager;
-import com.yeshi.fanli.service.manger.order.TeamRewardManager;
-import com.yeshi.fanli.util.goods.douyin.DYUtil;
-import com.yeshi.fanli.util.mq.rabbit.RabbitmqManager;
-import com.yeshi.fanli.util.pinduoduo.PinDuoDuoUtil;
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Propagation;
-import org.springframework.transaction.annotation.Transactional;
-import org.yeshi.utils.NumberUtil;
-
import com.aliyun.openservices.ons.api.Message;
import com.aliyun.openservices.ons.api.transaction.LocalTransactionExecuter;
import com.aliyun.openservices.ons.api.transaction.TransactionProducer;
@@ -43,10 +16,13 @@
import com.yeshi.fanli.dto.mq.order.body.OrderMoneyRecievedMQMsg;
import com.yeshi.fanli.dto.order.CommonOrderAddResultDTO;
import com.yeshi.fanli.dto.order.HongBaoAddResult;
+import com.yeshi.fanli.entity.SystemEnum;
+import com.yeshi.fanli.entity.SystemPIDInfo;
import com.yeshi.fanli.entity.bus.user.HongBaoV2;
import com.yeshi.fanli.entity.bus.user.Order;
import com.yeshi.fanli.entity.bus.user.UserExtraTaoBaoInfo;
import com.yeshi.fanli.entity.bus.user.UserInfo;
+import com.yeshi.fanli.entity.dy.DYOrder;
import com.yeshi.fanli.entity.elme.ElmeHongBaoOrderMap;
import com.yeshi.fanli.entity.elme.ElmeOrder;
import com.yeshi.fanli.entity.jd.JDOrder;
@@ -56,11 +32,7 @@
import com.yeshi.fanli.entity.order.HongBaoOrder;
import com.yeshi.fanli.entity.pdd.PDDOrder;
import com.yeshi.fanli.entity.suning.SuningOrderInfo;
-import com.yeshi.fanli.entity.taobao.PidUser;
-import com.yeshi.fanli.entity.taobao.TaoBaoOrder;
-import com.yeshi.fanli.entity.taobao.TaoBaoUnionConfig;
-import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanDrawBack;
-import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;
+import com.yeshi.fanli.entity.taobao.*;
import com.yeshi.fanli.entity.vipshop.VipShopOrder;
import com.yeshi.fanli.entity.vipshop.VipShopOrderDetail;
import com.yeshi.fanli.exception.elme.ElmeOrderException;
@@ -78,11 +50,7 @@
import com.yeshi.fanli.service.inter.elme.ElmeOrderService;
import com.yeshi.fanli.service.inter.money.UserMoneyService;
import com.yeshi.fanli.service.inter.money.tb.TaoBaoWeiQuanDrawBackService;
-import com.yeshi.fanli.service.inter.order.CommonOrderService;
-import com.yeshi.fanli.service.inter.order.HongBaoV2Service;
-import com.yeshi.fanli.service.inter.order.LostOrderService;
-import com.yeshi.fanli.service.inter.order.OrderMoneySettleService;
-import com.yeshi.fanli.service.inter.order.OrderProcessService;
+import com.yeshi.fanli.service.inter.order.*;
import com.yeshi.fanli.service.inter.order.jd.JDOrderService;
import com.yeshi.fanli.service.inter.order.msg.UserOrderMsgNotificationService;
import com.yeshi.fanli.service.inter.order.pdd.PDDOrderService;
@@ -90,23 +58,33 @@
import com.yeshi.fanli.service.inter.taobao.TaoBaoBuyRelationMapService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService;
import com.yeshi.fanli.service.inter.user.tb.UserExtraTaoBaoInfoService;
+import com.yeshi.fanli.service.manger.PIDManager;
import com.yeshi.fanli.service.manger.msg.RocketMQManager;
import com.yeshi.fanli.service.manger.order.HongBaoV2AddManager;
-import com.yeshi.fanli.util.CMQManager;
+import com.yeshi.fanli.service.manger.order.TeamRewardManager;
import com.yeshi.fanli.util.Constant;
-import org.yeshi.utils.MoneyBigDecimalUtil;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.TaoBaoConstant;
-import org.yeshi.utils.TimeUtil;
import com.yeshi.fanli.util.factory.UserMoneyDetailFactory;
-import com.yeshi.fanli.util.jd.JDApiUtil;
+import com.yeshi.fanli.util.goods.douyin.DYUtil;
import com.yeshi.fanli.util.mq.cmq.order.PlaceOrderCMQManager;
import com.yeshi.fanli.util.mq.cmq.order.TeamOrderCMQManager;
-import com.yeshi.fanli.util.pinduoduo.PinDuoDuoApiUtil;
+import com.yeshi.fanli.util.mq.rabbit.RabbitmqManager;
+import com.yeshi.fanli.util.pinduoduo.PinDuoDuoUtil;
import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;
import com.yeshi.fanli.util.rocketmq.MQTopicName;
-import com.yeshi.fanli.util.suning.SuningApiUtil;
import com.yeshi.fanli.util.vipshop.VipShopUtil;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+import org.yeshi.utils.MoneyBigDecimalUtil;
+import org.yeshi.utils.NumberUtil;
+import org.yeshi.utils.TimeUtil;
+
+import javax.annotation.Resource;
+import java.math.BigDecimal;
+import java.math.RoundingMode;
+import java.util.*;
@Service
public class OrderProcessServiceImpl implements OrderProcessService {
@@ -179,6 +157,12 @@
@Resource
private RabbitmqManager rabbitmqManager;
+
+ @Resource
+ private TeamOrderCMQManager teamOrderCMQManager;
+
+ @Resource
+ private PlaceOrderCMQManager placeOrderCMQManager;
/**
* 鏄惁鏄垎浜鍗�
@@ -477,7 +461,7 @@
continue;
try {
if (Constant.ENABLE_MQ)
- CMQManager.getInstance().addFanLiMsgNew(hb);
+ rabbitmqManager.addFanLiMsgNew(hb);
} catch (Exception e) {
try {
LogHelper.errorDetailInfo(e);
@@ -597,7 +581,7 @@
try {
if (order.getState().contains("缁存潈鎴愬姛")) {
if (Constant.ENABLE_MQ)
- CMQManager.getInstance().addWeiQuanOrderMsg(order);
+ rabbitmqManager.addWeiQuanOrderMsg(order);
}
} catch (Exception e) {
LogHelper.error("缁存潈璁㈠崟鍔犲叆鍒伴槦鍒楀嚭閿�:" + order != null ? new Gson().toJson(order) : null);
@@ -683,7 +667,7 @@
Long uid = its.next();
try {
if (Constant.ENABLE_MQ)
- TeamOrderCMQManager.getInstance().addFanLiTeamIncomePreMsg(new UidDateDTO(uid, maxTime));
+ teamOrderCMQManager.addFanLiTeamIncomePreMsg(new UidDateDTO(uid, maxTime));
} catch (Exception e) {
e.printStackTrace();
LogHelper.error(e);
@@ -717,7 +701,7 @@
Long uid = its.next();
try {
if (Constant.ENABLE_MQ)
- CMQManager.getInstance().addFanLiShareMsg(new UidDateDTO(uid, maxTime));
+ rabbitmqManager.addFanLiShareMsg(new UidDateDTO(uid, maxTime));
} catch (Exception e) {
e.printStackTrace();
LogHelper.error(e);
@@ -914,7 +898,7 @@
order.setUserInfo(new UserInfo(uid));
try {
if (Constant.ENABLE_MQ)
- PlaceOrderCMQManager.getInstance().addPlaceOrderMsg(order);
+ placeOrderCMQManager.addPlaceOrderMsg(order);
} catch (Exception e) {
}
}
@@ -965,7 +949,7 @@
order.setUserInfo(new UserInfo(uid));
try {
if (Constant.ENABLE_MQ)
- PlaceOrderCMQManager.getInstance().addPlaceOrderMsg(order);
+ placeOrderCMQManager.addPlaceOrderMsg(order);
} catch (Exception e) {
}
}
@@ -1097,7 +1081,7 @@
order.setUserInfo(new UserInfo(uid));
try {
if (Constant.ENABLE_MQ)
- PlaceOrderCMQManager.getInstance().addPlaceOrderMsg(order);
+ placeOrderCMQManager.addPlaceOrderMsg(order);
} catch (Exception e) {
}
}
@@ -1128,7 +1112,7 @@
order.setUserInfo(new UserInfo(uid));
try {
if (Constant.ENABLE_MQ)
- PlaceOrderCMQManager.getInstance().addPlaceOrderMsg(order);
+ placeOrderCMQManager.addPlaceOrderMsg(order);
} catch (Exception e) {
}
}
@@ -1248,7 +1232,7 @@
order.setUserInfo(new UserInfo(uid));
try {
if (Constant.ENABLE_MQ)
- PlaceOrderCMQManager.getInstance().addPlaceOrderMsg(order);
+ placeOrderCMQManager.addPlaceOrderMsg(order);
} catch (Exception e) {
}
}
@@ -1281,7 +1265,7 @@
order.setUserInfo(new UserInfo(uid));
try {
if (Constant.ENABLE_MQ)
- PlaceOrderCMQManager.getInstance().addPlaceOrderMsg(order);
+ placeOrderCMQManager.addPlaceOrderMsg(order);
} catch (Exception e) {
}
}
@@ -1384,7 +1368,7 @@
order.setUserInfo(new UserInfo(uid));
try {
if (Constant.ENABLE_MQ)
- PlaceOrderCMQManager.getInstance().addPlaceOrderMsg(order);
+ placeOrderCMQManager.addPlaceOrderMsg(order);
} catch (Exception e) {
}
}
@@ -1415,7 +1399,7 @@
order.setUserInfo(new UserInfo(uid));
try {
if (Constant.ENABLE_MQ)
- PlaceOrderCMQManager.getInstance().addPlaceOrderMsg(order);
+ placeOrderCMQManager.addPlaceOrderMsg(order);
} catch (Exception e) {
}
}
@@ -1525,7 +1509,7 @@
order.setUserInfo(new UserInfo(uid));
try {
if (Constant.ENABLE_MQ)
- PlaceOrderCMQManager.getInstance().addPlaceOrderMsg(order);
+ placeOrderCMQManager.addPlaceOrderMsg(order);
} catch (Exception e) {
}
}
@@ -1558,7 +1542,7 @@
order.setUserInfo(new UserInfo(uid));
try {
if (Constant.ENABLE_MQ)
- PlaceOrderCMQManager.getInstance().addPlaceOrderMsg(order);
+ placeOrderCMQManager.addPlaceOrderMsg(order);
} catch (Exception e) {
}
}
@@ -1649,7 +1633,7 @@
order.setUserInfo(new UserInfo(uid));
try {
if (Constant.ENABLE_MQ)
- PlaceOrderCMQManager.getInstance().addPlaceOrderMsg(order);
+ placeOrderCMQManager.addPlaceOrderMsg(order);
} catch (Exception e) {
}
}
@@ -1680,7 +1664,7 @@
order.setUserInfo(new UserInfo(uid));
try {
if (Constant.ENABLE_MQ)
- PlaceOrderCMQManager.getInstance().addPlaceOrderMsg(order);
+ placeOrderCMQManager.addPlaceOrderMsg(order);
} catch (Exception e) {
}
}
--
Gitblit v1.8.0