From 38e2dae2721ef4b2f458f88974fbdaef1afa6db6 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Wed, 15 May 2024 00:18:16 +0800
Subject: [PATCH] 1
---
src/main/java/com/nq/service/impl/EchoServices.java | 82 +++++++++++++++++++++--------------------
src/main/java/com/nq/service/impl/UserPositionServiceImpl.java | 36 ++++++++++--------
2 files changed, 62 insertions(+), 56 deletions(-)
diff --git a/src/main/java/com/nq/service/impl/EchoServices.java b/src/main/java/com/nq/service/impl/EchoServices.java
index 29e0f66..8ef961d 100644
--- a/src/main/java/com/nq/service/impl/EchoServices.java
+++ b/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) {
diff --git a/src/main/java/com/nq/service/impl/UserPositionServiceImpl.java b/src/main/java/com/nq/service/impl/UserPositionServiceImpl.java
index 3503d21..de70f90 100644
--- a/src/main/java/com/nq/service/impl/UserPositionServiceImpl.java
+++ b/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);
}
}
--
Gitblit v1.9.3