| | |
| | | |
| | | |
| | | @Override |
| | | public Boolean availablebalanceChange(String accetType, Integer userId, EUserAssets eUserAssets, BigDecimal amount, String desc, String descType) { |
| | | public Boolean availablebalanceChange(String accetType, Integer userId, EUserAssets eUserAssets, BigDecimal amount, String desc, String descType) throws Exception { |
| | | //UserAssets userAssets = assetsByTypeAndUserId(accetType,userId); |
| | | //查询墨西哥账户 |
| | | UserAssets userAssets = assetsByTypeAndUserId(EStockType.MX.getCode(), userId); |
| | |
| | | if (exchangeRate != null) { |
| | | //转换为墨西哥币 |
| | | amount = exchangeAmountByRate(amount, exchangeRate.getRata()); |
| | | } else { |
| | | log.error("availablebalanceChange ExchangeRate is null:{}>>{}", stockType.getSymbol(), EStockType.MX.getSymbol()); |
| | | throw new Exception("货币转换汇率未设置"); |
| | | } |
| | | } |
| | | UserPosition userPosition = userPositionMapper.selectOne(new LambdaQueryWrapper<UserPosition>().gt(UserPosition::getAmountToBeCovered, BigDecimal.ZERO).eq(UserPosition::getUserId,userAssets.getUserId())); |
| | |
| | | } |
| | | |
| | | |
| | | public Boolean aiAvailableBalanceChange(String accetType, Integer userId, EUserAssets eUserAssets, BigDecimal amount, BigDecimal buyAmount) { |
| | | public Boolean aiAvailableBalanceChange(String accetType, Integer userId, EUserAssets eUserAssets, BigDecimal amount) throws Exception { |
| | | //查询墨西哥账户 |
| | | UserAssets userAssets = assetsByTypeAndUserId(EStockType.MX.getCode(), userId); |
| | | //如果不是墨西哥币需要转换金额 |
| | |
| | | if (exchangeRate != null) { |
| | | //转换为墨西哥币 |
| | | amount = exchangeAmountByRate(amount, exchangeRate.getRata()); |
| | | buyAmount = exchangeAmountByRate(buyAmount, exchangeRate.getRata()); |
| | | } else { |
| | | return false; |
| | | log.error("ExchangeRate is null:{}>>{}", stockType.getSymbol(), EStockType.MX.getSymbol()); |
| | | throw new Exception("货币转换汇率未设置"); |
| | | } |
| | | } |
| | | String before = userAssets.getAvailableBalance().toString(); |
| | |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount)); |
| | | } else if (eUserAssets.getCode().equals(EUserAssets.AI_SETTLEMENT.getCode())) { |
| | | //解除购买冻结金额 |
| | | userAssets.setFreezeMoney(userAssets.getFreezeMoney().add(buyAmount.negate())); |
| | | //归还可用金额(购买金额+收益) |
| | | userAssets.setFreezeMoney(userAssets.getFreezeMoney().add(amount.negate())); |
| | | //归还购买金额 |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount)); |
| | | } else if (eUserAssets.getCode().equals(EUserAssets.AI_SETTLEMENT_INT.getCode())) { |
| | | //收益 |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount)); |
| | | } else if(eUserAssets.getCode().equals(EUserAssets.DK.getCode())) { |
| | | //发放贷款金额 |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount)); |
| | | } else if(eUserAssets.getCode().equals(EUserAssets.RT_DK.getCode())) { |
| | | //归还贷款 |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount.negate())); |
| | | } else if(eUserAssets.getCode().equals(EUserAssets.RT_DK_INT.getCode())) { |
| | | //贷款利息 |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount.negate())); |
| | | } |
| | | |
| | | String after = userAssets.getAvailableBalance().toString(); |
| | | MoneyLog moneyLog = new MoneyLog(); |
| | | moneyLog.setDescs(eUserAssets.getDesc()); |