admin
2020-05-06 24a8d17e007545f7426c48352109aa1a9c6587ee
fanli/src/main/java/com/yeshi/fanli/service/impl/money/UserMoneyServiceImpl.java
@@ -11,9 +11,11 @@
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.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.util.Constant;
import com.yeshi.fanli.util.cmq.UserMoneyChangeCMQManager;
@Service
@@ -53,8 +55,9 @@
      userMoneyDetailMapper.insertSelective(detail);
      userInfoMapper.subHongBaoByUid(uid, money);
      try {
         UserMoneyChangeCMQManager.getInstance()
               .addUserMoneyChangeMsg(new UserMoneyChangeDTO(uid, new BigDecimal(0).subtract(money)));
         if (!Constant.IS_TEST)
            UserMoneyChangeCMQManager.getInstance()
                  .addUserMoneyChangeMsg(new UserMoneyChangeDTO(uid, new BigDecimal(0).subtract(money)));
      } catch (Exception e) {
         try {
            LogHelper.errorDetailInfo(e);
@@ -70,7 +73,8 @@
      userMoneyDetailMapper.insertSelective(detail);
      userInfoMapper.addHongBaoByUid(uid, money);
      try {
         UserMoneyChangeCMQManager.getInstance().addUserMoneyChangeMsg(new UserMoneyChangeDTO(uid, money));
         if (!Constant.IS_TEST)
            UserMoneyChangeCMQManager.getInstance().addUserMoneyChangeMsg(new UserMoneyChangeDTO(uid, money));
      } catch (Exception e) {
         try {
            LogHelper.errorDetailInfo(e);
@@ -81,4 +85,12 @@
   }
   @Override
   public BigDecimal getBalance(Long uid) {
      UserInfo userInfo = userInfoMapper.selectByPrimaryKey(uid);
      if (userInfo == null)
         return null;
      return userInfo.getMyHongBao();
   }
}