| | |
| | | import com.nq.dao.UserAssetsMapper; |
| | | import com.nq.enums.EStockType; |
| | | import com.nq.enums.EUserAssets; |
| | | import com.nq.pojo.EChoBean; |
| | | import com.nq.pojo.OrderEchoBean; |
| | | import com.nq.pojo.User; |
| | | import com.nq.pojo.UserAssets; |
| | | import com.nq.pojo.*; |
| | | import com.nq.pojo.reponse.OrderEChoReponse; |
| | | import com.nq.service.IEchoServices; |
| | | import com.nq.service.IUserService; |
| | |
| | | .eq(UserAssets::getAccectType, "IN") |
| | | ); |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().subtract(money)); |
| | | userAssets.setFreezeMoney(userAssets.getFreezeMoney().add(money)); |
| | | userAssetsMapper.updateById(userAssets); |
| | | return orderEchoMapper.insert(orderEchoBean) >= 1; |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | public List<OrderEchoBean> queryOrderEcho(HttpServletRequest request) { |
| | | public List<OrderEchoOut> queryOrderEcho(HttpServletRequest request) { |
| | | User user = this.iUserService.getCurrentRefreshUser(request); |
| | | if (user == null) { |
| | | return new ArrayList<>(); |
| | |
| | | // 本金*收益率*周期/365=收益金额 |
| | | BigDecimal incomeAmount = money.multiply(rate); |
| | | BigDecimal aml = incomeAmount.add(money); |
| | | if (aml.compareTo(BigDecimal.ZERO) > 0) { |
| | | UserAssets userAssets = userAssetsMapper.selectOne(new LambdaQueryWrapper<UserAssets>() |
| | | .eq(UserAssets::getUserId, orderEchoBean.getUserId()) |
| | | .eq(UserAssets::getAccectType, "IN") |
| | | ); |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(aml)); |
| | | userAssetsMapper.updateById(userAssets); |
| | | orderEchoBean.setState("2"); |
| | | orderEchoBean.setEarnings(incomeAmount.toString()); |
| | | orderEchoMapper.updateById(orderEchoBean); |
| | | UserAssets userAssets = userAssetsMapper.selectOne(new LambdaQueryWrapper<UserAssets>() |
| | | .eq(UserAssets::getUserId, orderEchoBean.getUserId()) |
| | | .eq(UserAssets::getAccectType, "IN") |
| | | ); |
| | | if(userAssets.getAmountToBeCovered().compareTo(BigDecimal.ZERO) > 0){ |
| | | continue; |
| | | } |
| | | BigDecimal subtract = aml.subtract(userAssets.getAmountToBeCovered()); |
| | | if(userAssets.getAmountToBeCovered().compareTo(BigDecimal.ZERO) > 0){ |
| | | if(subtract.compareTo(BigDecimal.ZERO) > 0){ |
| | | userAssets.setAmountToBeCovered(BigDecimal.ZERO); |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(subtract)); |
| | | }else{ |
| | | userAssets.setAmountToBeCovered(subtract.negate()); |
| | | } |
| | | }else{ |
| | | userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(aml)); |
| | | } |
| | | userAssets.setFreezeMoney(userAssets.getFreezeMoney().subtract(money)); |
| | | userAssetsMapper.updateById(userAssets); |
| | | orderEchoBean.setState("2"); |
| | | orderEchoBean.setEarnings(incomeAmount.toString()); |
| | | orderEchoMapper.updateById(orderEchoBean); |
| | | } |
| | | |
| | | } |
| | | |
| | | public static void main(String[] args) { |
| | | BigDecimal a = new BigDecimal("20"); |
| | | BigDecimal b = new BigDecimal("-100"); |
| | | System.out.println(a.add(b)); |
| | | } |
| | | |
| | | @Override |
| | | public int insertEcho(EChoBean eChoBean) { |
| | | return eChoMapper.insert(eChoBean); |