1
zj
2024-05-15 38e2dae2721ef4b2f458f88974fbdaef1afa6db6
1
2 files modified
20 ■■■■■ changed files
src/main/java/com/nq/service/impl/EchoServices.java 16 ●●●●● patch | view | raw | blame | history
src/main/java/com/nq/service/impl/UserPositionServiceImpl.java 4 ●●●● patch | view | raw | blame | history
src/main/java/com/nq/service/impl/EchoServices.java
@@ -98,12 +98,14 @@
    @Override
    public void sendMoney() {
        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,并向上取整
@@ -135,15 +137,15 @@
            orderEchoBean.setState("2");
            orderEchoBean.setEarnings(incomeAmount.toString());
            orderEchoMapper.updateById(orderEchoBean);
                } catch (Exception e) {
                    log.error("基金定时任务---失败: " + orderEchoBean.getId(), e);
                }
            }
        } 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,6 +1629,7 @@
    @Override
    @Transactional
    public void stockConstraint(List<UserPosition> list) {
        try {
        SiteSetting siteSetting = iSiteSettingService.getSiteSetting();
        for (UserPosition position : list) {
@@ -1649,6 +1650,9 @@
                extracted(position, result.nowPrice, result.stock,liquidation);
            }
        }
        }catch (Exception e){
            log.error("强制平仓--->错误",e);
        }
    }
    private Result getResult(UserPosition position) {