9.17

zyy

2025-09-19 f9ea0dcfb4bf3665caab910e0239d5048a3005fc

 trading-order-service/src/main/java/com/yami/trading/service/ico/IcoService.java

@@ -1,13 +1,11 @@
package com.yami.trading.service.ico;


import cn.hutool.core.convert.Convert;
import cn.hutool.core.date.DateTime;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.yami.trading.bean.ico.domain.Ico;
import com.yami.trading.bean.ico.domain.UserSubscription;
import com.yami.trading.bean.item.domain.Item;
import com.yami.trading.bean.model.MoneyLog;
import com.yami.trading.bean.model.User;
import com.yami.trading.bean.model.Wallet;
@@ -21,16 +19,12 @@
import com.yami.trading.service.MoneyLogService;
import com.yami.trading.service.WalletService;
import com.yami.trading.service.user.UserService;
import com.yami.trading.service.user.WalletExtendService;
import io.swagger.v3.oas.annotations.parameters.RequestBody;
import lombok.extern.slf4j.Slf4j;

import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.validation.Valid;
import java.math.BigDecimal;
import java.util.Date;

@@ -55,83 +49,83 @@
    @Autowired
    MoneyLogService moneyLogService;

    @Autowired
    WalletExtendService walletExtendService;

    /**
     * 新币申购
     * @param model
     * @return
     */
    public Result<String> subscribe(UserSubscription model) {
        try {
            if (model == null || model.getIcoProjectId() == null) {
                throw new YamiShopBindException("参数异常");
            }
            String partyId = model.getUserId();
            Ico ico = this.getById(model.getIcoProjectId());
            if (ico == null) {
                throw new YamiShopBindException("新币不存在");
            }
        if (model == null || model.getIcoProjectId() == null) {
            throw new YamiShopBindException("参数异常");
        }
        String partyId = model.getUserId();
        Ico ico = this.getById(model.getIcoProjectId());
        if (ico == null) {
            throw new YamiShopBindException("新币不存在");
        }

            User party = userService.getById(partyId);
            if (!party.isEnabled()) {
                return Result.succeed("User is locked");
            }
            if (Constants.SECURITY_ROLE_TEST.equals(party.getRoleName())) {
                throw new YamiShopBindException("无权限");
            }
            if (!C2cLock.add(partyId)) {
                throw new YamiShopBindException("Please try again later");
            }
        User party = userService.getById(partyId);
        if (!party.isEnabled()) {
            throw new YamiShopBindException("User is locked");
        }
        if (Constants.SECURITY_ROLE_TEST.equals(party.getRoleName())) {
            throw new YamiShopBindException("无权限");
        }

            if (model.getSubscribeNums() == null || model.getSubscribeNums() == 0) {
                throw new YamiShopBindException("申请数量不能为空");
            }
            //购买金额
            BigDecimal amount = ico.getUnitAmount().multiply(new BigDecimal(model.getSubscribeNums()));
            /*Wallet wallet = walletService.saveWalletByPartyId(partyId);
            if (amount.compareTo(wallet.getMoney()) > 0) {
        if (model.getSubscribeNums() == null || model.getSubscribeNums() == 0) {
            throw new YamiShopBindException("申请数量不能为空");
        }
        //购买金额
        BigDecimal amount = ico.getUnitAmount().multiply(new BigDecimal(model.getSubscribeNums()));
        if(amount.compareTo(ico.getMinContribution()) < 0 ){
            throw new YamiShopBindException("最低投资额: " + ico.getMinContribution());
        }
        if(amount.compareTo(ico.getMaxContribution()) > 0 ){
            throw new YamiShopBindException("最高投资额: " + ico.getMaxContribution());
        }
        Date currentDate = new Date();
        if(currentDate.before(ico.getStartDate())){
            throw new YamiShopBindException("未开售");
        }
        if(currentDate.after(ico.getEndDate())){
            throw new YamiShopBindException("已结束");
        }

        model.setStatus(1);
        model.setUserId(partyId);
        if (model.getSubscriptionType() == null) { //默认自主申购
            model.setSubscriptionType(1);
        }

        Wallet wallet = walletService.saveWalletByPartyId(partyId);
        if(wallet.getAmountToBeCovered().compareTo(BigDecimal.ZERO) > 0){
            throw new YamiShopBindException("请先缴清待补资金");
        }

        //需要先支付
        if (ico.getIsPayDown() !=null && ico.getIsPayDown() == 1) {
            //手续费
            BigDecimal fee = ico.getUnitFee().multiply(new BigDecimal(model.getSubscribeNums()));
            BigDecimal totalAmount = amount.add(fee);
            if (totalAmount.compareTo(wallet.getMoney()) > 0) {
                throw new YamiShopBindException("余额不足");
            }*/
            if(amount.compareTo(ico.getMinContribution()) < 0 ){
                throw new YamiShopBindException("最低投资额: " + ico.getMinContribution());
            }
            if(amount.compareTo(ico.getMaxContribution()) > 0 ){
                throw new YamiShopBindException("最高投资额: " + ico.getMaxContribution());
            }
            Date currentDate = new Date();
            if(currentDate.before(ico.getStartDate())){
                throw new YamiShopBindException("未开售");
            }
            if(currentDate.after(ico.getEndDate())){
                throw new YamiShopBindException("已结束");
            }

            model.setStatus(1);
            model.setUserId(partyId);
            if (model.getSubscriptionType() == null) { //默认自主申购
                model.setSubscriptionType(1);
            }
            userSubscriptionService.save(model);
            /*walletService.update(partyId, Arith.sub(0, amount.doubleValue()));
            BigDecimal before = wallet.getMoney();
            walletService.update(partyId, totalAmount.negate().doubleValue());

            // 保存 资金日志
            MoneyLog moneylog = new MoneyLog();
            moneylog.setCategory(Constants.MONEYLOG_CONTENT_NEW_COIN);
            moneylog.setAmountBefore(wallet.getMoney());
            moneylog.setAmount(amount);
            moneylog.setAmountAfter(BigDecimal.valueOf(Arith.sub(wallet.getMoney().doubleValue(), amount.doubleValue())));
            moneylog.setLog("新币购买，申购金额[" + amount + "]");
            moneylog.setAmountBefore(before);
            moneylog.setAmount(totalAmount.negate());
            moneylog.setAmountAfter(before.subtract(totalAmount));
            moneylog.setLog("新币购买，申购金额[" + amount + "]" + "手续费金额[" + fee + "]");
            moneylog.setUserId(partyId);
            moneylog.setSymbol(ico.getSymbol());
            moneylog.setWalletType(ico.getSymbol());
            moneylog.setContentType(Constants.MONEYLOG_CONTENT_NEW_COIN_OPEN);
            moneyLogService.save(moneylog);*/
            return Result.ok("申请成功" );
        } catch (Exception e) {
            throw new RuntimeException(e);
            moneylog.setContentType(Constants.MONEYLOG_CONTENT_NEW_COIN_BUY);
            moneyLogService.save(moneylog);
        }
        userSubscriptionService.save(model);
        return Result.ok("申请成功" );
    }


@@ -150,10 +144,11 @@
            if (userSubscription.getStatus() == 5) {
                throw new YamiShopBindException("It's been converted");
            }
            if(userSubscription.getStatus() == 3){
            if(userSubscription.getStatus() == 3 || userSubscription.getStatus() == 2){
                throw new YamiShopBindException("不能更改申购状态");
            }
            Ico ico = this.getById(model.getIcoProjectId());
            Ico ico = this.getById(userSubscription.getIcoProjectId());
            String userId = userSubscription.getUserId();
            if (model.getStatus() == 3 || model.getStatus() == 5) {
                if(model.getBallotNumber() == null || model.getBallotNumber() == 0){
                    throw new YamiShopBindException("中签数量不能小于0");
@@ -164,46 +159,109 @@
            }
            userSubscription.setStatus(model.getStatus());
            userSubscription.setBallotNumber(model.getBallotNumber());
            if (model.getStatus() == 3) { //中签
                int applyNumber = userSubscription.getSubscribeNums() - model.getBallotNumber();
                BigDecimal amount = ico.getUnitAmount().multiply(new BigDecimal(applyNumber));
                //资金账户
                Wallet wallet = walletService.saveWalletByPartyId(userSubscription.getUserId());
                BigDecimal subtract = amount.subtract(wallet.getMoney());
                if (subtract.compareTo(BigDecimal.ZERO) > 0) {
                    //放入待补
                    wallet.setMoney(BigDecimal.ZERO);
                    wallet.setAmountToBeCovered(subtract);
                    if (!walletService.updateById(wallet)) {
                        throw new YamiShopBindException("操作钱包失败!");

            //资金账户
            Wallet wallet = walletService.saveWalletByPartyId(userId);
            BigDecimal before = wallet.getMoney();
            if (model.getStatus() == 2) {   //未中签
                //预支付退回全部资金
                if(ico.getIsPayDown() !=null && ico.getIsPayDown() == 1) {
                    BigDecimal refundPrice = ico.getUnitAmount().multiply(new BigDecimal(userSubscription.getSubscribeNums()));
                    BigDecimal fee = ico.getUnitFee().multiply(new BigDecimal(userSubscription.getSubscribeNums()));
                    BigDecimal totalAmount = refundPrice.add(fee);
                    wallet = walletService.updateToBeCovered(wallet, totalAmount, 1);
                    //保存 资金日志
                    MoneyLog moneylog = new MoneyLog();
                    moneylog.setCategory(Constants.MONEYLOG_CONTENT_NEW_COIN);
                    moneylog.setAmountBefore(before);
                    moneylog.setAmount(totalAmount);
                    moneylog.setAmountAfter(wallet.getMoney());
                    moneylog.setLog("新币未中签，退回金额[" + refundPrice + "]" + "退回手续费[" + fee + "]");
                    moneylog.setUserId(userId);
                    moneylog.setSymbol(ico.getSymbol());
                    moneylog.setWalletType(ico.getSymbol());
                    moneylog.setContentType(Constants.MONEYLOG_CONTENT_NEW_COIN_RT_BUY);
                    moneyLogService.save(moneylog);
                }
            } else if (model.getStatus() == 3) { //中签
                //已经预支付
                if(ico.getIsPayDown() !=null && ico.getIsPayDown() == 1) {
                    long applyNumber = userSubscription.getSubscribeNums() - model.getBallotNumber();
                    if(applyNumber > 0) {
                        //退回资金
                        BigDecimal refundPrice = ico.getUnitAmount().multiply(new BigDecimal(applyNumber));
                        BigDecimal fee = ico.getUnitFee().multiply(new BigDecimal(applyNumber));
                        BigDecimal totalAmount = refundPrice.add(fee);
                        wallet = walletService.updateToBeCovered(wallet, totalAmount, 1);

                        //保存 资金日志
                        MoneyLog moneylog = new MoneyLog();
                        moneylog.setCategory(Constants.MONEYLOG_CONTENT_NEW_COIN);
                        moneylog.setAmountBefore(before);
                        moneylog.setAmount(totalAmount);
                        moneylog.setAmountAfter(wallet.getMoney());
                        moneylog.setLog("新币购买，退回金额[" + refundPrice + "]" + "退回手续费[" + fee + "]");
                        moneylog.setUserId(userId);
                        moneylog.setSymbol(ico.getSymbol());
                        moneylog.setWalletType(ico.getSymbol());
                        moneylog.setContentType(Constants.MONEYLOG_CONTENT_NEW_COIN_RT_BUY);
                        moneyLogService.save(moneylog);
                    }
                } else {
                    //扣除资金
                    walletService.update(userSubscription.getUserId(), amount.negate().doubleValue());
                    BigDecimal amount = ico.getUnitAmount().multiply(new BigDecimal(model.getBallotNumber()));
                    //手续费
                    BigDecimal fee = ico.getUnitFee().multiply(new BigDecimal(model.getBallotNumber()));
                    BigDecimal totalAmount = amount.add(fee);
                    wallet = walletService.updateToBeCovered(wallet, totalAmount, 2);
                    //保存 资金日志
                    MoneyLog moneylog = new MoneyLog();
                    moneylog.setCategory(Constants.MONEYLOG_CONTENT_NEW_COIN);
                    moneylog.setAmountBefore(before);
                    moneylog.setAmount(totalAmount.negate());
                    moneylog.setAmountAfter(wallet.getMoney());
                    moneylog.setLog("新币购买，申购金额[" + amount + "]" + "手续费金额[" + fee + "]");
                    moneylog.setUserId(userId);
                    moneylog.setSymbol(ico.getSymbol());
                    moneylog.setWalletType(ico.getSymbol());
                    moneylog.setContentType(Constants.MONEYLOG_CONTENT_NEW_COIN_BUY);
                    moneyLogService.save(moneylog);
                }
                //保存 资金日志
                MoneyLog moneylog = new MoneyLog();
                moneylog.setCategory(Constants.MONEYLOG_CONTENT_NEW_COIN);
                moneylog.setAmountBefore(wallet.getMoney());
                moneylog.setAmount(amount);
                moneylog.setAmountAfter(BigDecimal.valueOf(Arith.sub(wallet.getMoney().doubleValue(), amount.doubleValue())));
                moneylog.setLog("新币购买，申购金额[" + amount + "]");
                moneylog.setUserId(userSubscription.getUserId());
                moneylog.setSymbol(ico.getSymbol());
                moneylog.setWalletType(ico.getSymbol());
                moneylog.setContentType(Constants.MONEYLOG_CONTENT_NEW_COIN_OPEN);
                moneyLogService.save(moneylog);
                userSubscription.setStatus(5);
            }
            if (model.getStatus() == 3 || model.getStatus() == 5) {  //转入账户
                //获取币账户
                WalletExtend walletExtend = walletService.saveExtendByPara(userSubscription.getUserId(), ico.getSymbol());
                walletService.updateExtend(userSubscription.getUserId(), walletExtend.getWallettype(), model.getBallotNumber());
                WalletExtend walletExtend = walletService.saveExtendByPara(userId, ico.getSymbol());
                walletService.updateExtend(userId, walletExtend.getWallettype(), model.getBallotNumber());
            }
            userSubscriptionService.save(userSubscription);
            userSubscriptionService.saveOrUpdate(userSubscription);
            return Result.ok ( "操作成功" );
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    public Item icoToItem(Item item, Ico ico) {
        item.setName(ico.getName());
        item.setSymbol(ico.getSymbol());
        item.setSymbolData(ico.getSymbolData());
        item.setPips(ico.getPips());
        item.setPipsAmount(ico.getPipsAmount());
        item.setAdjustmentValue(ico.getAdjustmentValue());
        item.setUnitAmount(ico.getUnitAmount());
        item.setUnitFee(ico.getUnitFee());
        item.setMarket("");
        item.setDecimals(ico.getDecimals());
        item.setMultiple(ico.getMultiple());
        item.setBorrowingRate(ico.getBorrowingRate());
        item.setSymbolFullName(ico.getName());
        item.setType(Item.cryptos);
        item.setCategory(Item.cryptos);
        item.setShowStatus("1");
        item.setTradeStatus("1");
        item.setQuoteCurrency(ico.getCurrency());
        item.setCurrencyType(1);  //新币
        item.setStatus(1);
        item.setTradeType(ico.getIsContractTrading().toString());
        return item;
    }
}