From a47f9e486847396e5adbdec7a6476a854a38d352 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Sat, 27 Apr 2024 16:00:36 +0800
Subject: [PATCH] 1

---
 src/main/java/com/nq/service/impl/EchoServices.java |   64 ++++++++++++++++++++++++-------
 1 files changed, 49 insertions(+), 15 deletions(-)

diff --git a/src/main/java/com/nq/service/impl/EchoServices.java b/src/main/java/com/nq/service/impl/EchoServices.java
index cfb954f..319c337 100644
--- a/src/main/java/com/nq/service/impl/EchoServices.java
+++ b/src/main/java/com/nq/service/impl/EchoServices.java
@@ -1,22 +1,30 @@
 package com.nq.service.impl;
 
-import com.baomidou.mybatisplus.core.conditions.Wrapper;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.nq.dao.EChoMapper;
 import com.nq.dao.OrderEchoMapper;
+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.reponse.OrderEChoReponse;
 import com.nq.service.IEchoServices;
 import com.nq.service.IUserService;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import javax.servlet.http.HttpServletRequest;
 import java.math.BigDecimal;
+import java.math.RoundingMode;
 import java.util.ArrayList;
 import java.util.List;
 
+@Slf4j
 @Service
 public class EchoServices implements IEchoServices {
 
@@ -29,13 +37,19 @@
     @Autowired
     IUserService iUserService;
 
+    @Autowired
+    private UserAssetsServices serAssetsServices;
+
+    @Autowired
+    private UserAssetsMapper userAssetsMapper;
+
     @Override
     public List<EChoBean> queryList() {
-        return eChoMapper.selectQueryAll();
+        return eChoMapper.selectList(new LambdaQueryWrapper<EChoBean>());
     }
 
     @Override
-    public boolean buyECho(String eId, Integer money, HttpServletRequest request) {
+    public boolean buyECho(String eId, BigDecimal money, HttpServletRequest request) {
 
         User user = this.iUserService.getCurrentRefreshUser(request);
 
@@ -60,7 +74,12 @@
             orderEchoBean.setMoney(money.toString());
             orderEchoBean.setState("1");
 
-            iUserService.updateAmt(user.getId(),money.toString(),1);
+            UserAssets userAssets = userAssetsMapper.selectOne(new LambdaQueryWrapper<UserAssets>()
+                    .eq(UserAssets::getUserId, orderEchoBean.getUserId())
+                    .eq(UserAssets::getAccectType, "IN")
+            );
+            userAssets.setAvailableBalance(userAssets.getAvailableBalance().subtract(money));
+            userAssetsMapper.updateById(userAssets);
             return orderEchoMapper.insert(orderEchoBean) >= 1;
         }
     }
@@ -75,24 +94,39 @@
     }
 
     @Override
-    public List<OrderEchoBean> queryALLOrderEcho() {
+    public List<OrderEChoReponse> queryALLOrderEcho() {
         return orderEchoMapper.queryAll();
     }
 
     @Override
     public void sendMoney() {
         QueryWrapper<OrderEchoBean> queryWrapper = new QueryWrapper<>();
-        queryWrapper.eq("state",1);
-        queryWrapper.ge("end_time",System.currentTimeMillis());
-        List<OrderEchoBean> list =  orderEchoMapper.selectList(queryWrapper);
-        for (int i = 0; i <list.size() ; i++) {
-            OrderEchoBean orderEchoBean = list.get(i);
-            BigDecimal money = BigDecimal.valueOf(Long.parseLong(orderEchoBean.getMoney()));
-            BigDecimal rate = BigDecimal.valueOf(Long.parseLong(orderEchoBean.getReturnOfRate()));
-            String money1 =rate.divide(BigDecimal.valueOf(100)).add(BigDecimal.valueOf(1)).multiply(money).setScale(2).toString();
-            iUserService.updateAmt(Integer.parseInt(orderEchoBean.getUserId()),money1,0);
-            orderEchoBean.setState("2");
+        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);
+
+            // 本金*收益率*周期/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);
+            }
         }
+
     }
 
     @Override

--
Gitblit v1.9.3