1

zj

2024-05-15 38e2dae2721ef4b2f458f88974fbdaef1afa6db6

1

 src/main/java/com/nq/service/impl/EchoServices.java

@@ -98,52 +98,54 @@

    @Override
    public void sendMoney() {
        QueryWrapper<OrderEchoBean> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("state", 1);
        queryWrapper.lt("end_time", System.currentTimeMillis());
        List<OrderEchoBean> list = orderEchoMapper.selectList(queryWrapper);
        log.info("基金定时任务执行数量:{}",list.size());
        for (OrderEchoBean orderEchoBean : list) {
            BigDecimal money = new BigDecimal(orderEchoBean.getMoney()); // 本金
            BigDecimal rate = new BigDecimal(orderEchoBean.getReturnOfRate()); // 收益率
            // 将rate除以100，并向上取整
            rate = rate.divide(new BigDecimal(100), 2, RoundingMode.HALF_UP);
        try {
            QueryWrapper<OrderEchoBean> queryWrapper = new QueryWrapper<>();
            queryWrapper.eq("state", 1);
            queryWrapper.lt("end_time", System.currentTimeMillis());
            List<OrderEchoBean> list = orderEchoMapper.selectList(queryWrapper);
            log.info("基金定时任务执行数量:{}", list.size());
            for (OrderEchoBean orderEchoBean : list) {
                try {
                    BigDecimal money = new BigDecimal(orderEchoBean.getMoney()); // 本金
                    BigDecimal rate = new BigDecimal(orderEchoBean.getReturnOfRate()); // 收益率
                    // 将rate除以100，并向上取整
                    rate = rate.divide(new BigDecimal(100), 2, RoundingMode.HALF_UP);

            // 本金*收益率*周期/365=收益金额
            BigDecimal incomeAmount = money.multiply(rate);
            BigDecimal aml = incomeAmount.add(money);
            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());
                    // 本金*收益率*周期/365=收益金额
                    BigDecimal incomeAmount = money.multiply(rate);
                    BigDecimal aml = incomeAmount.add(money);
                    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);
                } catch (Exception e) {
                    log.error("基金定时任务---失败: " + orderEchoBean.getId(), e);
                }
            }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);
        } catch (Exception ex) {
            log.error("基金定时任务---失败: ", ex);
        }

    }

    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) {

 src/main/java/com/nq/service/impl/UserPositionServiceImpl.java

@@ -1629,25 +1629,29 @@
    @Override
    @Transactional
    public void stockConstraint(List<UserPosition> list) {
        SiteSetting siteSetting = iSiteSettingService.getSiteSetting();
        try {
            SiteSetting siteSetting = iSiteSettingService.getSiteSetting();

        for (UserPosition position : list) {
            UserAssets userAssets = userAssetsMapper.selectOne(new LambdaQueryWrapper<UserAssets>()
                    .eq(UserAssets::getUserId, position.getUserId())
                    .eq(UserAssets::getAccectType, "IN")
            );
            if(userAssets.getAmountToBeCovered().compareTo(BigDecimal.ZERO) > 0){
                continue;
            }
            //平仓检查
            Result result = getResult(position);
            if (result == null) continue;
            for (UserPosition position : list) {
                UserAssets userAssets = userAssetsMapper.selectOne(new LambdaQueryWrapper<UserAssets>()
                        .eq(UserAssets::getUserId, position.getUserId())
                        .eq(UserAssets::getAccectType, "IN")
                );
                if(userAssets.getAmountToBeCovered().compareTo(BigDecimal.ZERO) > 0){
                    continue;
                }
                //平仓检查
                Result result = getResult(position);
                if (result == null) continue;

            Integer liquidation = 0;
            liquidation = isLiquidation(position, result.signum, result.profit, liquidation);
            if(liquidation != 0){
                extracted(position, result.nowPrice, result.stock,liquidation);
                Integer liquidation = 0;
                liquidation = isLiquidation(position, result.signum, result.profit, liquidation);
                if(liquidation != 0){
                    extracted(position, result.nowPrice, result.stock,liquidation);
                }
            }
        }catch (Exception e){
            log.error("强制平仓--->错误",e);
        }
    }