| | |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; |
| | | import com.nq.Repository.ExchangeRateRepository; |
| | | import com.nq.common.ServerResponse; |
| | | import com.nq.dao.*; |
| | |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import javax.annotation.Resource; |
| | | import javax.validation.constraints.Email; |
| | | import java.math.BigDecimal; |
| | | import java.math.RoundingMode; |
| | | import java.util.Date; |
| | |
| | | |
| | | @Autowired |
| | | UserRechargeServiceImpl userRechargeService; |
| | | |
| | | @Autowired |
| | | UserWithdrawServiceImpl withdrawService; |
| | | |
| | | @Resource |
| | | UserRechargeMapper userRechargeMapper; |
| | |
| | | String type = eUserAssets.getDesc(); |
| | | String before = userAssets.getAvailableBalance().toString(); |
| | | String accectType = userAssets.getAccectType(); |
| | | if(Objects.equals(eUserAssets.getCode(), EUserAssets.BUY.getCode())){ |
| | | BigDecimal amountLog = amount; |
| | | 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.CLOSE_POSITION.getCode())){ |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount)); |
| | | extracted(amount, userAssets); |
| | | }else if(Objects.equals(eUserAssets.getCode(), EUserAssets.CLOSE_POSITION_RETURN_SECURITY_DEPOSIT.getCode())){ |
| | | }else if(Objects.equals(eUserAssets.getCode(), EUserAssets.CLOSE_POSITION_RETURN_SECURITY_DEPOSIT.getCode())){ |
| | | if(userAssets.getAmountToBeCovered().compareTo(BigDecimal.ZERO) > 0){ |
| | | BigDecimal availableBalance = amount.subtract(userAssets.getAmountToBeCovered()); |
| | | availableBalance = availableBalance.subtract(userAssets.getHandlingChargeWritten()); |
| | |
| | | }else{ |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount)); |
| | | } |
| | | userAssets.setFreezeMoney(userAssets.getFreezeMoney().subtract(amount)); |
| | | userAssets.setFreezeMoney(userAssets.getFreezeMoney().subtract(amount)); |
| | | }else if(Objects.equals(eUserAssets.getCode(), EUserAssets.CALCULATE_PROFIT_AND_LOSS.getCode())){ |
| | | extracted(amount, userAssets); |
| | | }else if(Objects.equals(eUserAssets.getCode(), EUserAssets.TRANSFER.getCode())){ |
| | | extracted(amount, userAssets); |
| | | }else if(Objects.equals(eUserAssets.getCode(), EUserAssets.TRANSFER.getCode())){ |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount)); |
| | | eUserAssets.setDesc(desc); |
| | | eUserAssets.setDesc(desc); |
| | | }else if(Objects.equals(eUserAssets.getCode(), EUserAssets.TOP_UP.getCode())){ |
| | | if(userAssets.getAmountToBeCovered().compareTo(BigDecimal.ZERO) > 0){ |
| | | BigDecimal availableBalance = amount.subtract(userAssets.getAmountToBeCovered()); |
| | |
| | | userAssets.setAmountToBeCovered(BigDecimal.ZERO); |
| | | userAssets.setHandlingChargeWritten(BigDecimal.ZERO); |
| | | }else{ |
| | | userAssets.setFreezeMoney(userAssets.getFreezeMoney().add(amount)); |
| | | userAssets.setHandlingChargeWritten(BigDecimal.ZERO); |
| | | userAssets.setAmountToBeCovered(availableBalance.negate()); |
| | | BigDecimal subtract = amount.subtract(userAssets.getHandlingChargeWritten()); |
| | | if(subtract.compareTo(BigDecimal.ZERO) >= 0) { |
| | | BigDecimal decimal = amount.subtract(userAssets.getAmountToBeCovered()); |
| | | decimal = decimal.subtract(userAssets.getHandlingChargeWritten()); |
| | | userAssets.setFreezeMoney(userAssets.getFreezeMoney().add(amount.subtract(userAssets.getHandlingChargeWritten()))); |
| | | userAssets.setHandlingChargeWritten(BigDecimal.ZERO); |
| | | userAssets.setAmountToBeCovered(decimal.negate()); |
| | | }else{ |
| | | userAssets.setHandlingChargeWritten(userAssets.getHandlingChargeWritten().subtract(amount)); |
| | | } |
| | | } |
| | | }else{ |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount)); |
| | |
| | | }else if(Objects.equals(eUserAssets.getCode(), EUserAssets.HANDLING_CHARGE.getCode())){ |
| | | if(userAssets.getAvailableBalance().compareTo(amount.abs()) >= 0){ |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount.negate())); |
| | | amountLog = amount.negate(); |
| | | }else { |
| | | userAssets.setHandlingChargeWritten(userAssets.getHandlingChargeWritten().add(amount.abs())); |
| | | } |
| | | userAssets.setHandlingCharge(userAssets.getHandlingCharge().add(amount.abs())); |
| | | |
| | | extracted(amount.negate(),userAssets); |
| | | }else if(Objects.equals(eUserAssets.getCode(), EUserAssets.CONSTRAINT_CLOSE_POSITION.getCode())){ |
| | | }else if(Objects.equals(eUserAssets.getCode(), EUserAssets.CONSTRAINT_CLOSE_POSITION.getCode())){ |
| | | userAssets.setFreezeMoney(userAssets.getFreezeMoney().subtract(amount)); |
| | | if(userAssets.getIsZf() == 0){ |
| | | userAssets.setCumulativeProfitAndLoss(userAssets.getCumulativeProfitAndLoss().subtract(amount)); |
| | |
| | | userAssets.setCumulativeProfitAndLoss(userAssets.getCumulativeProfitAndLoss().add(amount)); |
| | | } |
| | | extracted(userAssets); |
| | | } |
| | | } |
| | | |
| | | if(null != userPosition){ |
| | | userPosition.setAmountToBeCovered(userAssets.getAmountToBeCovered().add(userAssets.getHandlingChargeWritten())); |
| | |
| | | moneyLog.setDescs(eUserAssets.getDesc()); |
| | | moneyLog.setBeFore(before); |
| | | moneyLog.setAfter(after); |
| | | moneyLog.setAmount(amount.toString()); |
| | | moneyLog.setAmount(amountLog.toString()); |
| | | moneyLog.setAccectType(accectType); |
| | | moneyLog.setType(eUserAssets.getCode()); |
| | | moneyLog.setUserId(userId+""); |
| | |
| | | //冻结金额 |
| | | userAssets.setFreezeMoney(userAssets.getFreezeMoney().add(amount)); |
| | | //扣除可用金额 |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount.negate())); |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().subtract(amount)); |
| | | amount = amount.negate(); |
| | | } else if (eUserAssets.getCode().equals(EUserAssets.BUY_AI_REJECT.getCode())) { |
| | | //解除冻结金额 |
| | | userAssets.setFreezeMoney(userAssets.getFreezeMoney().add(amount.negate())); |
| | | userAssets.setFreezeMoney(userAssets.getFreezeMoney().subtract(amount)); |
| | | //归还可用金额 |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount)); |
| | | } else if (eUserAssets.getCode().equals(EUserAssets.AI_SETTLEMENT.getCode())) { |
| | | //解除购买冻结金额 |
| | | userAssets.setFreezeMoney(userAssets.getFreezeMoney().add(amount.negate())); |
| | | userAssets.setFreezeMoney(userAssets.getFreezeMoney().subtract(amount)); |
| | | //归还购买金额 |
| | | 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.RT_DK.getCode())) { |
| | | //归还贷款 |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount.negate())); |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().subtract(amount)); |
| | | amount = amount.negate(); |
| | | } else if(eUserAssets.getCode().equals(EUserAssets.RT_DK_INT.getCode())) { |
| | | //贷款利息 |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount.negate())); |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().subtract(amount)); |
| | | amount = amount.negate(); |
| | | } |
| | | |
| | | String after = userAssets.getAvailableBalance().toString(); |
| | | //资金明细 |
| | | MoneyLog moneyLog = new MoneyLog(); |
| | | moneyLog.setDescs(eUserAssets.getDesc()); |
| | | moneyLog.setBeFore(before); |
| | |
| | | moneyLog.setAmount(amount.toString()); |
| | | moneyLog.setAccectType(userAssets.getAccectType()); |
| | | moneyLog.setType(eUserAssets.getCode()); |
| | | moneyLog.setUserId(userAssets.getId()+""); |
| | | moneyLog.setUserId(userAssets.getUserId()+""); |
| | | moneyLog.setSymbol(EStockType.getEStockTypeByCode(userAssets.getAccectType()).getSymbol()); |
| | | moneyLog.setCreateTime(new Date()); |
| | | moneyLogMapper.insert(moneyLog); |