From 73699775f5546177ce71e3bae33d83a8aa346793 Mon Sep 17 00:00:00 2001
From: gao <gaoleox@163>
Date: Mon, 25 May 2020 11:28:10 +0800
Subject: [PATCH] Merge branch 'master' of https://chonggaoxiao:xcg523511090712@gitee.com/chonggaoxiao/new_excoin.git

---
 src/main/java/com/xcong/excoin/modules/coin/service/impl/OrderCoinServiceImpl.java |  109 ++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 109 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/modules/coin/service/impl/OrderCoinServiceImpl.java b/src/main/java/com/xcong/excoin/modules/coin/service/impl/OrderCoinServiceImpl.java
new file mode 100644
index 0000000..0c60ebc
--- /dev/null
+++ b/src/main/java/com/xcong/excoin/modules/coin/service/impl/OrderCoinServiceImpl.java
@@ -0,0 +1,109 @@
+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.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+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.OrderCoinsEntity;
+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, OrderCoinsEntity> 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) {
+		
+		return Result.ok(MessageSourceUtils.getString("order_service_0011"));
+	}
+
+}

--
Gitblit v1.9.1