1

zj

2024-10-08 e64cc04da1568aff094c687fa18682b8d435f0b1

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

@@ -1,22 +1,28 @@
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.pojo.EChoBean;
import com.nq.pojo.OrderEchoBean;
import com.nq.pojo.User;
import com.nq.dao.UserAssetsMapper;
import com.nq.dao.UserPositionMapper;
import com.nq.enums.EStockType;
import com.nq.enums.EUserAssets;
import com.nq.pojo.*;
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 +35,22 @@
    @Autowired
    IUserService iUserService;

    @Autowired
    private UserAssetsServices serAssetsServices;

    @Autowired
    private UserAssetsMapper userAssetsMapper;

    @Autowired
    private UserPositionMapper userPositionMapper;

    @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,13 +75,19 @@
            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));
            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<>();
@@ -75,26 +96,66 @@
    }

    @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");
        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());
                        }
                    } else {
                        userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(aml));
                    }
                    UserPosition userPosition = userPositionMapper.selectOne(new LambdaQueryWrapper<UserPosition>().gt(UserPosition::getAmountToBeCovered, BigDecimal.ZERO).eq(UserPosition::getUserId,userAssets.getUserId()));
                    if(null != userPosition){
                        userPosition.setAmountToBeCovered(userAssets.getAmountToBeCovered());
                        userPositionMapper.updateById(userPosition);
                    }
                    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);
                }
            }
        } catch (Exception ex) {
            log.error("基金定时任务---失败: ", ex);
        }
    }


    @Override
    public int insertEcho(EChoBean eChoBean) {
        return eChoMapper.insert(eChoBean);