From a62d474f024332dde7616054c549b7794f120151 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 02 七月 2020 10:20:19 +0800
Subject: [PATCH] 增加华为广告控制
---
fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderMoneySettleServiceImpl.java | 20 ++++++++++++++++++++
1 files changed, 20 insertions(+), 0 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderMoneySettleServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderMoneySettleServiceImpl.java
index ffef0f8..e6fe708 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderMoneySettleServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderMoneySettleServiceImpl.java
@@ -52,6 +52,7 @@
import com.yeshi.fanli.service.inter.order.CommonOrderService;
import com.yeshi.fanli.service.inter.order.OrderMoneySettleService;
import com.yeshi.fanli.service.inter.user.UserSystemCouponService;
+import com.yeshi.fanli.service.manger.msg.RocketMQManager;
import com.yeshi.fanli.service.manger.order.TeamRewardManager;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.TimeUtil;
@@ -106,6 +107,9 @@
@Resource
private TeamRewardManager teamRewardManager;
+
+ @Resource
+ private RocketMQManager rocketMQManager;
// 涓嬬骇琚皝绂侊紝绾㈠寘澶辨晥
private void invalidHongBaoForbidden(Long id) {
@@ -167,6 +171,8 @@
Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.teamRewardPreRecieved, mqMsg);
msg.setKey(taskKey);
+
+
// 娣诲姞浜嬪姟娑堟伅
try {
orderTransactionProducer.send(msg, new LocalTransactionExecuter() {
@@ -181,6 +187,20 @@
return TransactionStatus.CommitTransaction;
}
}, null);
+
+// rocketMQManager.sendTransactionalMsg(msg, taskKey, new RocketMQManager.ITransactionalMQEvent() {
+// @Override
+// public TransactionStatus excute(Message arg0, Object arg1) {
+// try {
+// fanliInvite(hongBaoList, uid, Constant.SOURCE_TYPE_TAOBAO, taskKey, maxPregetTime);
+// } catch (Exception e) {
+// e.printStackTrace();
+// return TransactionStatus.RollbackTransaction;
+// }
+// return TransactionStatus.CommitTransaction;
+// }
+// });
+
} catch (Exception e) {
e.printStackTrace();
LogHelper.mqError(e.getMessage(), msg.getTopic(), msg.getTag(), new Gson().toJson(mqMsg));
--
Gitblit v1.8.0