jack
2024-04-02 4046f94a57f0c10e9509a49ad0d37d701aeb8186
src/main/java/com/nq/service/impl/UserAssetsServices.java
@@ -2,8 +2,10 @@
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;
@@ -22,6 +24,8 @@
    @Resource
    UserAssetsMapper userAssetsMapper;
    @Resource
    MoneyLogMapper moneyLogMapper;
    @Override
    public UserAssets assetsByTypeAndUserId(String accetType, Integer userId) {
@@ -85,6 +89,10 @@
            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()));
@@ -103,8 +111,16 @@
        }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;
    }
}