From 8e30aa7c1f0384f09278699318b4902b815b42a7 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期五, 26 四月 2019 18:01:25 +0800 Subject: [PATCH] 维权返利初步修改,拼多多初步增加 --- fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserMoneyServiceImpl.java | 47 +++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 47 insertions(+), 0 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserMoneyServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserMoneyServiceImpl.java index 027c612..3ddff9e 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserMoneyServiceImpl.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserMoneyServiceImpl.java @@ -5,15 +5,28 @@ 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.user.UserMoneyService; +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) { @@ -34,4 +47,38 @@ 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 { + 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 { + UserMoneyChangeCMQManager.getInstance().addUserMoneyChangeMsg(new UserMoneyChangeDTO(uid, money)); + } catch (Exception e) { + try { + LogHelper.errorDetailInfo(e); + } catch (Exception e1) { + e1.printStackTrace(); + } + } + + } + } -- Gitblit v1.8.0