| | |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.nq.common.ServerResponse; |
| | | import com.nq.dao.MoneyLogMapper; |
| | | import com.nq.dao.UserAssetsMapper; |
| | | import com.nq.enums.EUserAssets; |
| | | import com.nq.pojo.MoneyLog; |
| | | import com.nq.pojo.UserAssets; |
| | | import com.nq.service.IUserAssetsServices; |
| | | import org.springframework.stereotype.Service; |
| | |
| | | @Resource |
| | | UserAssetsMapper userAssetsMapper; |
| | | |
| | | @Resource |
| | | MoneyLogMapper moneyLogMapper; |
| | | |
| | | @Override |
| | | public UserAssets assetsByTypeAndUserId(String accetType, Integer userId) { |
| | |
| | | accetType = "US"; |
| | | } |
| | | UserAssets userAssets = assetsByTypeAndUserId(accetType,userId); |
| | | |
| | | String type = eUserAssets.getDesc(); |
| | | String before = userAssets.getAvailableBalance().setScale(2).toString(); |
| | | String accectType = userAssets.getAccectType(); |
| | | if(Objects.equals(eUserAssets.getCode(), EUserAssets.BUY.getCode())){ |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount)); |
| | | userAssets.setFreezeMoney(userAssets.getFreezeMoney().add(amount.negate())); |
| | |
| | | }else if(Objects.equals(eUserAssets.getCode(), EUserAssets.WITHDRAW.getCode())){ |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount)); |
| | | } |
| | | //TODO 添加日志 |
| | | |
| | | String after = userAssets.getAvailableBalance().toString(); |
| | | MoneyLog moneyLog = new MoneyLog(); |
| | | moneyLog.setDescs(eUserAssets.getDesc()); |
| | | moneyLog.setBeFore(before); |
| | | moneyLog.setAfter(after); |
| | | moneyLog.setAmount(amount.toString()); |
| | | moneyLog.setAccectType(accectType); |
| | | moneyLog.setType(type); |
| | | moneyLog.setUserId(userId+""); |
| | | moneyLogMapper.insert(moneyLog); |
| | | return userAssetsMapper.updateById(userAssets)>1; |
| | | } |
| | | } |