From 30d8e227e8d823b6c38c3b9c90ac2df03b63befe Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 25 二月 2025 16:41:22 +0800
Subject: [PATCH] 淘宝转链接口更新
---
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/order/MQLocalUserCouponUsedTransactionChecker.java | 108 +++++++++++++++++++++++++++---------------------------
1 files changed, 54 insertions(+), 54 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/order/MQLocalUserCouponUsedTransactionChecker.java b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/order/MQLocalUserCouponUsedTransactionChecker.java
index 7c37be1..52adec0 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/order/MQLocalUserCouponUsedTransactionChecker.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/order/MQLocalUserCouponUsedTransactionChecker.java
@@ -1,54 +1,54 @@
-package com.yeshi.fanli.util.rocketmq.order;
-
-import javax.annotation.Resource;
-
-import org.springframework.stereotype.Component;
-
-import com.aliyun.openservices.ons.api.Message;
-import com.aliyun.openservices.ons.api.transaction.TransactionStatus;
-import com.google.gson.Gson;
-import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;
-import com.yeshi.fanli.dto.mq.user.body.UserSystemCouponUseMQMsg;
-import com.yeshi.fanli.entity.bus.user.UserSystemCouponRecord;
-import com.yeshi.fanli.entity.system.SystemCoupon;
-import com.yeshi.fanli.service.inter.user.UserSystemCouponRecordService;
-import com.yeshi.fanli.util.rocketmq.MQTopicName;
-
-/**
- * 鍒镐娇鐢ㄤ簨鍔℃鏌�
- *
- * @author Administrator
- *
- */
-@Component
-public class MQLocalUserCouponUsedTransactionChecker {
- @Resource
- private UserSystemCouponRecordService userSystemCouponRecordService;
-
- public MQLocalUserCouponUsedTransactionChecker() {
-
- }
-
- public TransactionStatus check(Message msg) {
- if (msg.getTopic().equalsIgnoreCase(MQTopicName.TOPIC_USER.name())) {
- if (msg.getTag().equalsIgnoreCase(UserTopicTagEnum.useSystemCoupon.name())) {// 杩斿埄濂栧姳鍒�
- // 鏌ヨ鏄惁浣跨敤鎴愬姛
- UserSystemCouponUseMQMsg dto = new Gson().fromJson(new String(msg.getBody()),
- UserSystemCouponUseMQMsg.class);
-
- if (SystemCoupon.CouponTypeEnum.rebatePercentCoupon.name().equalsIgnoreCase(dto.getCouponType())) {
- UserSystemCouponRecord record = userSystemCouponRecordService
- .getNearByUserCouponId(dto.getUserSystemCouponId());
- if (record != null) {
- if (record.getOrderNo().equalsIgnoreCase(dto.getOrderId())
- && dto.getSourceType().intValue() == record.getGoodSource()) {
- return TransactionStatus.CommitTransaction;
- }
- }
- return TransactionStatus.RollbackTransaction;
- }
- }
- }
- return TransactionStatus.Unknow;
- }
-}
+package com.yeshi.fanli.util.rocketmq.order;
+
+import javax.annotation.Resource;
+
+import org.springframework.stereotype.Component;
+
+import com.aliyun.openservices.ons.api.Message;
+import com.aliyun.openservices.ons.api.transaction.TransactionStatus;
+import com.google.gson.Gson;
+import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;
+import com.yeshi.fanli.dto.mq.user.body.UserSystemCouponUseMQMsg;
+import com.yeshi.fanli.entity.bus.user.UserSystemCouponRecord;
+import com.yeshi.fanli.entity.system.SystemCoupon;
+import com.yeshi.fanli.service.inter.user.UserSystemCouponRecordService;
+import com.yeshi.fanli.util.rocketmq.MQTopicName;
+
+/**
+ * 鍒镐娇鐢ㄤ簨鍔℃鏌�
+ *
+ * @author Administrator
+ *
+ */
+@Component
+public class MQLocalUserCouponUsedTransactionChecker {
+ @Resource
+ private UserSystemCouponRecordService userSystemCouponRecordService;
+
+ public MQLocalUserCouponUsedTransactionChecker() {
+
+ }
+
+ public TransactionStatus check(Message msg) {
+ if (msg.getTopic().equalsIgnoreCase(MQTopicName.TOPIC_USER.name())) {
+ if (msg.getTag().equalsIgnoreCase(UserTopicTagEnum.useSystemCoupon.name())) {// 杩斿埄濂栧姳鍒�
+ // 鏌ヨ鏄惁浣跨敤鎴愬姛
+ UserSystemCouponUseMQMsg dto = new Gson().fromJson(new String(msg.getBody()),
+ UserSystemCouponUseMQMsg.class);
+
+ if (SystemCoupon.CouponTypeEnum.rebatePercentCoupon.name().equalsIgnoreCase(dto.getCouponType())) {
+ UserSystemCouponRecord record = userSystemCouponRecordService
+ .getNearByUserCouponId(dto.getUserSystemCouponId());
+ if (record != null) {
+ if (record.getOrderNo().equalsIgnoreCase(dto.getOrderId())
+ && dto.getSourceType().intValue() == record.getGoodSource()) {
+ return TransactionStatus.CommitTransaction;
+ }
+ }
+ return TransactionStatus.RollbackTransaction;
+ }
+ }
+ }
+ return TransactionStatus.Unknow;
+ }
+}
--
Gitblit v1.8.0