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/money/UserMoneyServiceImpl.java | 200 ++++++++++++++++++++++++++++---------------------
1 files changed, 113 insertions(+), 87 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/money/UserMoneyServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/money/UserMoneyServiceImpl.java
index 40cc29d..f3537f6 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/money/UserMoneyServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/money/UserMoneyServiceImpl.java
@@ -1,87 +1,113 @@
-package com.yeshi.fanli.service.impl.money;
-
-import java.math.BigDecimal;
-
-import javax.annotation.Resource;
-
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
-
-import com.yeshi.fanli.dao.mybatis.UserInfoMapper;
-import com.yeshi.fanli.dao.mybatis.money.UserMoneyDetailMapper;
-import com.yeshi.fanli.dao.mybatis.share.ShareMapper;
-import com.yeshi.fanli.dto.money.UserMoneyChangeDTO;
-import com.yeshi.fanli.entity.money.UserMoneyDetail;
-import com.yeshi.fanli.log.LogHelper;
-import com.yeshi.fanli.service.inter.money.UserMoneyService;
-import com.yeshi.fanli.util.Constant;
-import com.yeshi.fanli.util.cmq.UserMoneyChangeCMQManager;
-
-@Service
-public class UserMoneyServiceImpl implements UserMoneyService {
-
- @Resource
- private ShareMapper shareMapper;
-
- @Resource
- private UserInfoMapper userInfoMapper;
-
- @Resource
- private UserMoneyDetailMapper userMoneyDetailMapper;
-
- @Override
- public BigDecimal getMoneyToday(Long uid) {
- BigDecimal money = shareMapper.getMoneyToday(uid + "");
- return money == null ? new BigDecimal(0) : money;
- }
-
- @Override
- public BigDecimal getMoneyMonth(Long uid) {
- BigDecimal money = shareMapper.getMoneyMonth(uid + "");
- return money == null ? new BigDecimal(0) : money;
- }
-
- @Override
- public BigDecimal getMoneyLastMonth(Long uid) {
- BigDecimal money = shareMapper.getMoneyLastMonth(uid + "");
-
- return money == null ? new BigDecimal(0) : money;
- }
-
- @Transactional
- @Override
- public void subUserMoney(Long uid, BigDecimal money, UserMoneyDetail detail) {
- userMoneyDetailMapper.insertSelective(detail);
- userInfoMapper.subHongBaoByUid(uid, money);
- try {
- if (!Constant.IS_TEST)
- UserMoneyChangeCMQManager.getInstance()
- .addUserMoneyChangeMsg(new UserMoneyChangeDTO(uid, new BigDecimal(0).subtract(money)));
- } catch (Exception e) {
- try {
- LogHelper.errorDetailInfo(e);
- } catch (Exception e1) {
- e1.printStackTrace();
- }
- }
- }
-
- @Transactional
- @Override
- public void addUserMoney(Long uid, BigDecimal money, UserMoneyDetail detail) {
- userMoneyDetailMapper.insertSelective(detail);
- userInfoMapper.addHongBaoByUid(uid, money);
- try {
- if (!Constant.IS_TEST)
- UserMoneyChangeCMQManager.getInstance().addUserMoneyChangeMsg(new UserMoneyChangeDTO(uid, money));
- } catch (Exception e) {
- try {
- LogHelper.errorDetailInfo(e);
- } catch (Exception e1) {
- e1.printStackTrace();
- }
- }
-
- }
-
-}
+package com.yeshi.fanli.service.impl.money;
+
+import com.aliyun.openservices.ons.api.Message;
+import com.yeshi.fanli.dao.mybatis.UserInfoMapper;
+import com.yeshi.fanli.dao.mybatis.money.UserMoneyDetailMapper;
+import com.yeshi.fanli.dao.mybatis.share.ShareMapper;
+import com.yeshi.fanli.dto.money.UserMoneyChangeDTO;
+import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;
+import com.yeshi.fanli.dto.mq.user.body.UserMoneyChangeMQMsg;
+import com.yeshi.fanli.entity.bus.user.UserInfo;
+import com.yeshi.fanli.entity.money.UserMoneyDetail;
+import com.yeshi.fanli.log.LogHelper;
+import com.yeshi.fanli.service.inter.money.UserMoneyService;
+import com.yeshi.fanli.service.manger.msg.RocketMQManager;
+import com.yeshi.fanli.util.Constant;
+import com.yeshi.fanli.util.mq.cmq.UserMoneyChangeCMQManager;
+import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;
+import com.yeshi.fanli.util.rocketmq.MQTopicName;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+import java.math.BigDecimal;
+import java.util.Date;
+
+@Service
+public class UserMoneyServiceImpl implements UserMoneyService {
+
+ @Resource
+ private ShareMapper shareMapper;
+
+ @Resource
+ private UserInfoMapper userInfoMapper;
+
+ @Resource
+ private UserMoneyDetailMapper userMoneyDetailMapper;
+
+ @Resource
+ private RocketMQManager rocketMQManager;
+
+ @Resource
+ private UserMoneyChangeCMQManager userMoneyChangeCMQManager;
+
+ @Override
+ public BigDecimal getMoneyToday(Long uid) {
+ BigDecimal money = shareMapper.getMoneyToday(uid + "");
+ return money == null ? new BigDecimal(0) : money;
+ }
+
+ @Override
+ public BigDecimal getMoneyMonth(Long uid) {
+ BigDecimal money = shareMapper.getMoneyMonth(uid + "");
+ return money == null ? new BigDecimal(0) : money;
+ }
+
+ @Override
+ public BigDecimal getMoneyLastMonth(Long uid) {
+ BigDecimal money = shareMapper.getMoneyLastMonth(uid + "");
+
+ return money == null ? new BigDecimal(0) : money;
+ }
+
+ @Transactional
+ @Override
+ public void subUserMoney(Long uid, BigDecimal money, UserMoneyDetail detail) {
+ userMoneyDetailMapper.insertSelective(detail);
+ userInfoMapper.subHongBaoByUid(uid, money);
+ try {
+ if (!Constant.IS_TEST)
+ userMoneyChangeCMQManager
+ .addUserMoneyChangeMsg(new UserMoneyChangeDTO(uid, new BigDecimal(0).subtract(money)));
+ } catch (Exception e) {
+ try {
+ LogHelper.errorDetailInfo(e);
+ } catch (Exception e1) {
+ e1.printStackTrace();
+ }
+ }
+ }
+
+ @Transactional
+ @Override
+ public void addUserMoney(Long uid, BigDecimal money, UserMoneyDetail detail) {
+ userMoneyDetailMapper.insertSelective(detail);
+ userInfoMapper.addHongBaoByUid(uid, money);
+ try {
+ if (!Constant.IS_TEST)
+ userMoneyChangeCMQManager.addUserMoneyChangeMsg(new UserMoneyChangeDTO(uid, money));
+ } catch (Exception e) {
+ try {
+ LogHelper.errorDetailInfo(e);
+ } catch (Exception e1) {
+ e1.printStackTrace();
+ }
+ }
+ // 鍙戦�佽祫閲戝埌璐︽秷鎭�
+
+ if (!Constant.IS_TEST) {
+ UserMoneyChangeMQMsg msg = new UserMoneyChangeMQMsg(uid, money, new Date());
+ Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.userMoneyAdd, msg);
+ rocketMQManager.sendNormalMsg(message, null);
+ }
+ }
+
+ @Override
+ public BigDecimal getBalance(Long uid) {
+ UserInfo userInfo = userInfoMapper.selectByPrimaryKey(uid);
+ if (userInfo == null)
+ return null;
+ return userInfo.getMyHongBao();
+ }
+
+}
--
Gitblit v1.8.0