package com.xcong.excoin.modules.coin.service.impl;
|
|
import java.math.BigDecimal;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import javax.annotation.Resource;
|
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.kebex.app.entity.member.Member;
|
import com.kebex.app.entity.member.MemberAccountFlowRecord;
|
import com.kebex.app.entity.member.WalletCoin;
|
import com.kebex.app.entity.order.CoinOrderMain;
|
import com.kebex.app.entity.order.CoinsOrderDetail;
|
import com.kebex.app.entity.trade.TradeSetting;
|
import com.kebex.common.huobiapi.CoinTypeConConvert;
|
import com.xcong.excoin.common.LoginUserUtils;
|
import com.xcong.excoin.common.enumerates.MemberWalletCoinEnum;
|
import com.xcong.excoin.common.response.Result;
|
import com.xcong.excoin.modules.coin.dao.MemberSelectSymbolsDao;
|
import com.xcong.excoin.modules.coin.dao.OrderCoinDao;
|
import com.xcong.excoin.modules.coin.dao.platform.CnyUsdtExchangeDao;
|
import com.xcong.excoin.modules.coin.dao.platform.TradeSettingDao;
|
import com.xcong.excoin.modules.coin.entity.CnyUsdtExchange;
|
import com.xcong.excoin.modules.coin.entity.OrderCoinEntity;
|
import com.xcong.excoin.modules.coin.entity.PlatformTradeSettingEntity;
|
import com.xcong.excoin.modules.coin.service.OrderCoinService;
|
import com.xcong.excoin.modules.member.dao.MemberWalletCoinDao;
|
import com.xcong.excoin.modules.member.entity.MemberSelectSymbolsEntity;
|
import com.xcong.excoin.modules.member.entity.MemberWalletCoinEntity;
|
import com.xcong.excoin.utils.MessageSourceUtils;
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import cn.hutool.core.util.StrUtil;
|
|
@Service
|
public class OrderCoinServiceImpl extends ServiceImpl<OrderCoinDao, OrderCoinEntity> implements OrderCoinService{
|
|
@Resource
|
TradeSettingDao platformTradeSettingDao;
|
@Resource
|
MemberWalletCoinDao memberWalletCoinDao;
|
@Resource
|
MemberSelectSymbolsDao memberSelectSymbolsDao;
|
@Resource
|
CnyUsdtExchangeDao cnyUsdtExchangeDao;
|
|
@Override
|
public Result enterTransactionPageOfWalletCoin(String symbol, String type) {
|
if (StrUtil.isBlank(symbol)) {
|
return Result.fail(MessageSourceUtils.getString("order_service_0001"));
|
}
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
//获取该币种的币币账户信息
|
MemberWalletCoinEntity walletCoin = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId, symbol);
|
|
PlatformTradeSettingEntity tradeSetting = platformTradeSettingDao.findTradeSetting();
|
if (tradeSetting == null) {
|
return Result.fail(MessageSourceUtils.getString("order_service_0003"));
|
}
|
//获取USDT的币币账户信息
|
MemberWalletCoinEntity walletCoinUsdt = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId,
|
MemberWalletCoinEnum.WALLETCOINCODE.getValue());
|
/**
|
* todo
|
*/
|
//获取某个币种的收盘价
|
//Double closePrice = symbolsService.getCloseSymbolsBySymbolsName(symbol+"/USDT");
|
BigDecimal closePrice = new BigDecimal("100.0000");
|
|
List<MemberSelectSymbolsEntity> memSymbols = memberSelectSymbolsDao.selectSymbolByMemIdAndSymbol(memberId, symbol);
|
|
CnyUsdtExchange cnyUsdtExchange = cnyUsdtExchangeDao.getCNYAndUSDTOne();
|
BigDecimal cnyUsdt = cnyUsdtExchange.getValue();
|
|
Map<String, Object> map = new HashMap<String, Object>();
|
if(CollUtil.isEmpty(memSymbols)) {
|
map.put(MemberWalletCoinEnum.ENTERTRANSACTIONPAGEOFWALLETCOIN_ISCOLLECT_NO.getName(),
|
MemberWalletCoinEnum.ENTERTRANSACTIONPAGEOFWALLETCOIN_ISCOLLECT_NO.getValue());//是否已经自选该币种
|
}else {
|
map.put(MemberWalletCoinEnum.ENTERTRANSACTIONPAGEOFWALLETCOIN_ISCOLLECT_YES.getName(),
|
MemberWalletCoinEnum.ENTERTRANSACTIONPAGEOFWALLETCOIN_ISCOLLECT_YES.getValue());//是否已经自选该币种
|
}
|
if (ObjectUtil.isEmpty(walletCoin))
|
return Result.fail(MessageSourceUtils.getString("order_service_0003"));
|
|
map.put(MemberWalletCoinEnum.ENTERTRANSACTIONPAGEOFWALLETCOIN_SPREAD.getValue(), tradeSetting.getSpread());// 点差
|
map.put(MemberWalletCoinEnum.ENTERTRANSACTIONPAGEOFWALLETCOIN_CLOSINGRATIO.getValue(), tradeSetting.getFeeRatio());// 手续费用率
|
if(MemberWalletCoinEnum.ENTERTRANSACTIONPAGEOFWALLETCOIN_BUY.getValue().equals(type)) {//买入
|
map.put(MemberWalletCoinEnum.ENTERTRANSACTIONPAGEOFWALLETCOIN_MEMBERMONEY.getValue(), walletCoinUsdt.getAvailableBalance());// 用户可用金额
|
}else {
|
map.put(MemberWalletCoinEnum.ENTERTRANSACTIONPAGEOFWALLETCOIN_MEMBERMONEY.getValue(), walletCoin.getAvailableBalance());// 用户可用金额
|
}
|
|
map.put(MemberWalletCoinEnum.ENTERTRANSACTIONPAGEOFWALLETCOIN_CURRENTPRICE.getValue(), closePrice);//当前价
|
map.put(MemberWalletCoinEnum.ENTERTRANSACTIONPAGEOFWALLETCOIN_CNYUSDT.getValue(), cnyUsdt);//比例
|
map.put(MemberWalletCoinEnum.ENTERTRANSACTIONPAGEOFWALLETCOIN_CURRENTPRICECNY.getValue(), cnyUsdt.multiply(closePrice));//换算成人民币的币种价格
|
return Result.ok(map);
|
}
|
|
@Override
|
@Transactional
|
public Result submitSalesWalletCoinOrder(String symbol, Integer type, Integer tradeType, BigDecimal price,
|
BigDecimal amount) {
|
try {
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
|
String[] symbols = symbol.split("/");
|
if (symbols.length <= 0) {
|
return Result.fail(MessageSourceUtils.getString("order_service_0008"));
|
}
|
/**
|
* todo
|
*/
|
//查询当前价
|
//BigDecimal nowPrice = new BigDecimal(redisUtil.getString(CoinTypeConConvert.convertToKey(symbol+"/USDT")));
|
BigDecimal nowPrice = new BigDecimal("100.0000");
|
|
// 获取交易管理的杠杠倍率，手续费率等信息，由平台进行设置
|
symbol = symbol.toUpperCase();
|
MemberWalletCoinEntity walletCoin = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId, symbols[0]);
|
MemberWalletCoinEntity walletCoinUsdt = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId,
|
MemberWalletCoinEnum.WALLETCOINCODE.getValue());
|
if (ObjectUtil.isEmpty(walletCoin) || ObjectUtil.isEmpty(walletCoinUsdt) ) {
|
return Result.fail(MessageSourceUtils.getString("order_service_0003"));
|
}
|
// 查询交易设置
|
PlatformTradeSettingEntity tradeSetting = platformTradeSettingDao.findTradeSetting();
|
if(ObjectUtil.isEmpty(tradeSetting)) {
|
return Result.fail(MessageSourceUtils.getString("order_service_0009"));
|
}
|
//手续费率
|
BigDecimal ServiceRate = new BigDecimal(MemberWalletCoinEnum.SUBMITSALESWALLETCOINORDER_SERVICERATE.getValue());
|
// 手续费用(手续费=建仓价X数量X手续费率)
|
BigDecimal closingPrice = price.multiply(amount).multiply(ServiceRate).setScale(4, BigDecimal.ROUND_DOWN);
|
//总费用 = 成交价*数量+手续费
|
BigDecimal totalPayPrice = price.multiply(amount).add(closingPrice).setScale(4, BigDecimal.ROUND_DOWN);
|
if(MemberWalletCoinEnum.SUBMITSALESWALLETCOINORDER_TYPE.getValue().equals(type.toString())) {
|
//买入，所需总费用跟用户USDT金额进行比较
|
if (totalPayPrice.compareTo(walletCoinUsdt.getAvailableBalance()) > 0) {
|
return Result.fail(MessageSourceUtils.getString("order_service_0010"));
|
}
|
}else {
|
//卖出，所需总费用跟用户所对应的币种金额进行比较
|
if (amount.compareTo(walletCoin.getAvailableBalance()) > 0) {
|
return Result.fail(MessageSourceUtils.getString("order_service_0010"));
|
}
|
}
|
|
CoinOrderMain order = new CoinOrderMain();
|
|
// 创建订单
|
if (tradeType == 2) {// 如果是限价交易直接插入主表数据
|
order.setStatus(1);
|
order.setMemId(member.getmId());
|
order.setOpenPrice(price.doubleValue());
|
order.setOpenTime(new Date());
|
order.setOrderNo(generateSimpleSerialno(member.getmId() + ""));
|
order.setOrderType(type);
|
order.setRewardRatio(price
|
.multiply(amount).doubleValue());
|
order.setForceSetPrice(nowPrice.doubleValue());
|
// order.setStatus(3);
|
order.setSysbol(symbol);
|
order.setSysbolNumber(amount);
|
order.setSysbolFlatNumber(amount);
|
order.setTradeType(tradeType);
|
order.setVersion(1);
|
order.setClosingPrice(closingPrice);
|
orderMapper.addCoinMainOrder(order);
|
|
//更新用户钱包信息
|
//冻结相应的资产
|
if(type == 1) {//如果是买入，所对应的币种增加，USDT账户减少金额
|
// 更新用户的可用金额，冻结金额
|
walletCoinUsdt.setAvailableBalance(walletCoinUsdt.getAvailableBalance()-totalPayPrice.doubleValue());
|
walletCoinUsdt.setFrozenBalance(walletCoinUsdt.getFrozenBalance()+totalPayPrice.doubleValue());
|
walletCoinDao.updateByModel(walletCoinUsdt);
|
}else {
|
//如果是卖出，币种减少，USDT增加
|
BigDecimal availableBalance = new BigDecimal(walletCoin.getAvailableBalance()).subtract(amount).setScale(8, BigDecimal.ROUND_HALF_UP);
|
walletCoin.setAvailableBalance(availableBalance.doubleValue());
|
walletCoin.setFrozenBalance(walletCoin.getFrozenBalance()+amount.doubleValue());
|
walletCoinDao.updateByModel(walletCoin);
|
}
|
} else {
|
//如果是市价交易,主表和附表都需要插入数据
|
order.setStatus(3);
|
order.setMemId(member.getmId());
|
order.setForceSetPrice(nowPrice.doubleValue());
|
order.setOpenPrice(nowPrice.doubleValue());
|
order.setOpenTime(new Date());
|
order.setOrderNo(generateSimpleSerialno(member.getmId() + ""));
|
order.setOrderType(type);
|
order.setRewardRatio(nowPrice
|
.multiply(amount).doubleValue());
|
// order.setStatus(3);
|
order.setSysbol(symbol);
|
order.setSysbolNumber(amount);
|
order.setSysbolFlatNumber(amount);
|
order.setTradeType(tradeType);
|
order.setVersion(1);
|
order.setClosingPrice(closingPrice);
|
orderMapper.addCoinMainOrder(order);
|
//
|
CoinsOrderDetail detail = new CoinsOrderDetail();
|
detail.setClosingPrice(closingPrice.doubleValue());
|
detail.setCreateTime(new Date());
|
detail.setEntrustStatus(1);
|
detail.setEntrustType(type);
|
detail.setExitPrice(price.doubleValue());
|
detail.setExitType(1);
|
detail.setMainId(order.getId());
|
detail.setMemberId(member.getmId());
|
detail.setMemberPhone(member.getPhone());
|
detail.setPrePrice(price
|
.multiply(amount).doubleValue());
|
detail.setRewardRatio(0.0);
|
detail.setSerialno(generateSimpleSerialno(member.getmId() + ""));
|
detail.setSymbol(symbol);
|
detail.setSymbolSku(amount);
|
detail.setSymbolSkuNumber(amount);
|
detail.setTradePrice(price.doubleValue());
|
detail.setTradeType(tradeType);
|
detail.setVersion(1);
|
coinOrderDetailMapper.insert(detail);
|
|
if(type == 1) {//如果是买入，所对应的币种增加，USDT账户减少金额
|
// 更新用户的可用金额
|
BigDecimal availableBalance = new BigDecimal(walletCoin.getAvailableBalance()).add(amount).setScale(8, BigDecimal.ROUND_HALF_UP);
|
walletCoin.setAvailableBalance(availableBalance.doubleValue());
|
walletCoinDao.updateByModel(walletCoin);
|
|
walletCoinUsdt.setAvailableBalance(walletCoinUsdt.getAvailableBalance()-totalPayPrice.doubleValue());
|
walletCoinDao.updateByModel(walletCoinUsdt);
|
}else {
|
//如果是卖出，币种减少，USDT增加
|
BigDecimal availableBalance = new BigDecimal(walletCoin.getAvailableBalance()).subtract(amount).setScale(8, BigDecimal.ROUND_HALF_UP);
|
walletCoin.setAvailableBalance(availableBalance.doubleValue());
|
walletCoinDao.updateByModel(walletCoin);
|
|
walletCoinUsdt.setAvailableBalance(walletCoinUsdt.getAvailableBalance()+totalPayPrice.doubleValue());
|
walletCoinDao.updateByModel(walletCoinUsdt);
|
}
|
|
//返佣
|
// calYj(member.getmId(), closingPrice, order);
|
// String reference = member.getReference();
|
//返佣
|
// agentReturn(reference,closingPrice.doubleValue(),detail);
|
|
}
|
// 流水记录
|
MemberAccountFlowRecord record = new MemberAccountFlowRecord();
|
record.setCreateTime(new Date());
|
if (type == 1) {
|
record.setDirectionSource("币币买入"+symbol);
|
record.setRemark("买入"+symbol+":"+amount);
|
record.setPrice(totalPayPrice.doubleValue());
|
} else {
|
record.setDirectionSource("币币卖出"+symbol);
|
record.setRemark("卖出"+symbol+":"+amount);
|
record.setPrice(-totalPayPrice.doubleValue());
|
}
|
record.setMemberBalance(walletCoinUsdt.getAvailableBalance());
|
record.setMemberid(member.getmId());
|
record.setSymbolName(symbol);
|
record.setMemberName(member.getRealName());
|
record.setMemberPhone(member.getPhone());
|
|
memberMapper.addFlowRecord(record);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return Result.success(MessageSourceUtils.getString("order_service_0011"));
|
}
|
|
}
|
