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/service/impl/order/OrderMoneySettleServiceImpl.java | 27 ++++++++++++++++++++++-----
1 files changed, 22 insertions(+), 5 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 71d32ad..af55571 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
@@ -13,6 +13,7 @@
import javax.annotation.Resource;
+import com.yeshi.fanli.util.mq.rabbit.RabbitmqManager;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
@@ -115,13 +116,16 @@
@Resource
private RocketMQManager rocketMQManager;
+ @Resource
+ private HongBaoRecieveCMQManager hongBaoRecieveCMQManager;
+
// 涓嬬骇琚皝绂侊紝绾㈠寘澶辨晥
private void invalidHongBaoForbidden(HongBaoV2 hongBaoV2) throws TeamRewardDebtException {
if (hongBaoV2.getState() == HongBaoV2.STATE_SHIXIAO || hongBaoV2.getState() == HongBaoV2.STATE_YILINGQU || hongBaoV2.getState() == HongBaoV2.STATE_LINGQUING)
return;
//濡傛灉鍦ㄥ伩杩橀噷闈㈠氨鍏堝伩杩橈紝鐒跺悗鍐嶅け鏁�
TeamRewardDebt debt = teamRewardDebtService.selectBySourceId(hongBaoV2.getId());
- if (debt != null && debt.getLeftMoney().compareTo(hongBaoV2.getMoney()) <= 0) {
+ if (debt != null &&debt.getLeftMoney().compareTo(new BigDecimal(0))>0 && debt.getLeftMoney().compareTo(hongBaoV2.getMoney()) <= 0) {
teamRewardDebtService.repayDebt(debt.getId(), hongBaoV2.getMoney(), "灏佺澶辨晥锛屽厛鍋胯繕鍐嶅け鏁�");
}
@@ -161,6 +165,13 @@
public void inviteSettleVipShop(Long uid, Date maxPregetTime) throws OrderMoneySettleException {
// 鏌ヨUID鐨勪竴浜岀骇閭�璇疯禋
int sourceType = Constant.SOURCE_TYPE_VIP;
+ inviteSettle(uid, sourceType, maxPregetTime);
+ }
+
+ @Override
+ public void inviteSettleDY(Long uid, Date maxPregetTime) throws OrderMoneySettleException {
+ // 鏌ヨUID鐨勪竴浜岀骇閭�璇疯禋
+ int sourceType = Constant.SOURCE_TYPE_DY;
inviteSettle(uid, sourceType, maxPregetTime);
}
@@ -205,6 +216,7 @@
try {
invalidHongBaoForbidden(item);
} catch (TeamRewardDebtException e) {
+ e.printStackTrace();
throw new OrderMoneySettleException(10, "鍋胯繕鍑洪敊");
}
hongBaoList.remove(i);
@@ -347,6 +359,11 @@
shareSettle(Constant.SOURCE_TYPE_SUNING, uid, maxPregetTime);
}
+ @Override
+ public void shareSettleDY(Long uid, Date maxPregetTime) throws OrderMoneySettleException {
+ shareSettle(Constant.SOURCE_TYPE_DY, uid, maxPregetTime);
+ }
+
private void shareSettle(int sourceType, Long uid, Date maxPregetTime) throws OrderMoneySettleException {
/**
* 澶勭悊鍒嗕韩璧�
@@ -484,7 +501,7 @@
hbIdList.add(v2.getId());
accountDetailsHongBaoMapService.saveAccountDetailsHongBaoMap(v2.getId(), userMoneyDetail.getId());
try {
- HongBaoRecieveCMQManager.getInstance().addHongBaoRecieveMsg(v2.getId());
+ hongBaoRecieveCMQManager.addHongBaoRecieveMsg(v2.getId());
} catch (Exception e) {
LogHelper.errorDetailInfo(e);
}
@@ -588,7 +605,7 @@
for (Long hongBaoId : hbIdList) {
try {
if (Constant.ENABLE_MQ)
- HongBaoRecieveCMQManager.getInstance().addHongBaoRecieveMsg(hongBaoId);
+ hongBaoRecieveCMQManager.addHongBaoRecieveMsg(hongBaoId);
} catch (Exception e) {
LogHelper.errorDetailInfo(e);
}
@@ -677,7 +694,7 @@
for (Long hongBaoId : recieveHongBaoIds) {
try {
if (Constant.ENABLE_MQ)
- HongBaoRecieveCMQManager.getInstance().addHongBaoRecieveMsg(hongBaoId);
+ hongBaoRecieveCMQManager.addHongBaoRecieveMsg(hongBaoId);
} catch (Exception e) {
LogHelper.errorDetailInfo(e);
}
@@ -754,7 +771,7 @@
for (Long hongBaoId : recieveHongBaoIds) {
try {
if (Constant.ENABLE_MQ)
- HongBaoRecieveCMQManager.getInstance().addHongBaoRecieveMsg(hongBaoId);
+ hongBaoRecieveCMQManager.addHongBaoRecieveMsg(hongBaoId);
} catch (Exception e) {
LogHelper.errorDetailInfo(e);
}
--
Gitblit v1.8.0