package com.yami.trading.service.ico;
|
|
|
import cn.hutool.core.date.DateTime;
|
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;
|
import com.yami.trading.bean.model.WalletExtend;
|
import com.yami.trading.common.constants.Constants;
|
import com.yami.trading.common.domain.Result;
|
import com.yami.trading.common.exception.YamiShopBindException;
|
import com.yami.trading.common.util.Arith;
|
import com.yami.trading.common.util.C2cLock;
|
import com.yami.trading.dao.ico.IcoMapper;
|
import com.yami.trading.service.MoneyLogService;
|
import com.yami.trading.service.WalletService;
|
import com.yami.trading.service.user.UserService;
|
import lombok.extern.slf4j.Slf4j;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.math.BigDecimal;
|
import java.util.Date;
|
|
/**
|
* 新币Service
|
|
*/
|
@Service
|
@Transactional
|
@Slf4j
|
public class IcoService extends ServiceImpl<IcoMapper, Ico> {
|
|
@Autowired
|
UserService userService;
|
|
@Autowired
|
WalletService walletService;
|
|
@Autowired
|
UserSubscriptionService userSubscriptionService;
|
|
@Autowired
|
MoneyLogService moneyLogService;
|
|
/**
|
* 新币申购
|
*/
|
public Result<String> subscribe(UserSubscription model) {
|
if (model == null || model.getIcoProjectId() == null) {
|
throw new YamiShopBindException("Invalid parameters");
|
}
|
String partyId = model.getUserId();
|
Ico ico = this.getById(model.getIcoProjectId());
|
if (ico == null) {
|
throw new YamiShopBindException("New coin does not exist");
|
}
|
|
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("Permission denied");
|
}
|
|
if (model.getSubscribeNums() == null || model.getSubscribeNums() == 0) {
|
throw new YamiShopBindException("Application quantity cannot be empty");
|
}
|
//购买金额
|
BigDecimal amount = ico.getUnitAmount().multiply(new BigDecimal(model.getSubscribeNums()));
|
if(amount.compareTo(ico.getMinContribution()) < 0 ){
|
throw new YamiShopBindException("Minimum investment: " + ico.getMinContribution());
|
}
|
if(amount.compareTo(ico.getMaxContribution()) > 0 ){
|
throw new YamiShopBindException("Maximum investment: " + ico.getMaxContribution());
|
}
|
Date currentDate = new Date();
|
if(currentDate.before(ico.getStartDate())){
|
throw new YamiShopBindException("Not yet on sale");
|
}
|
if(currentDate.after(ico.getEndDate())){
|
throw new YamiShopBindException("Already ended");
|
}
|
|
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("Please pay outstanding supplementary funds first");
|
}
|
|
//需要先支付
|
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("Insufficient balance");
|
}
|
BigDecimal before = wallet.getMoney();
|
walletService.update(partyId, totalAmount.negate().doubleValue());
|
|
// 保存 资金日志
|
MoneyLog moneylog = new MoneyLog();
|
moneylog.setCategory(Constants.MONEYLOG_CONTENT_NEW_COIN);
|
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_BUY);
|
moneyLogService.save(moneylog);
|
}
|
userSubscriptionService.save(model);
|
return Result.ok("申请成功" );
|
}
|
|
|
public Result <String> updateRecord(UserSubscription model) {
|
try {
|
if( model.getId() == null || model.getStatus() == null){
|
throw new YamiShopBindException("Please enter parameters");
|
}
|
UserSubscription userSubscription = userSubscriptionService.getById(model.getId());
|
if (userSubscription == null) {
|
throw new YamiShopBindException("Record does not exist");
|
}
|
if (model.getStatus() == 3|| model.getStatus() == 2) {
|
userSubscription.setEndTime(DateTime.now());
|
}
|
if (userSubscription.getStatus() == 5) {
|
throw new YamiShopBindException("It's been converted");
|
}
|
if(userSubscription.getStatus() == 3 || userSubscription.getStatus() == 2){
|
throw new YamiShopBindException("Subscription status cannot be changed");
|
}
|
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("Allotted quantity cannot be less than 0");
|
}
|
if(model.getBallotNumber() > userSubscription.getSubscribeNums()){
|
throw new YamiShopBindException("Configured allotted quantity cannot exceed application quantity");
|
}
|
}
|
userSubscription.setStatus(model.getStatus());
|
userSubscription.setBallotNumber(model.getBallotNumber());
|
|
//资金账户
|
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 {
|
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);
|
}
|
userSubscription.setStatus(5);
|
}
|
if (model.getStatus() == 3 || model.getStatus() == 5) { //转入账户
|
//获取币账户
|
WalletExtend walletExtend = walletService.saveExtendByPara(userId, ico.getSymbol());
|
walletService.updateExtend(userId, walletExtend.getWallettype(), model.getBallotNumber());
|
}
|
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;
|
}
|
}
|
