1

zj

2024-04-26 cf4abf670a2fea1151c136e9bdf0c7fcedca27e9

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

@@ -1,12 +1,17 @@
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 org.springframework.beans.factory.annotation.Autowired;
@@ -14,6 +19,7 @@

import javax.servlet.http.HttpServletRequest;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.ArrayList;
import java.util.List;

@@ -29,13 +35,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 +72,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 +92,38 @@
    }

    @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);
        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