From bef3b23ca8918a355f6ff9751b46f4c35970f19e Mon Sep 17 00:00:00 2001
From: zainali5120 <512061637@qq.com>
Date: Sun, 25 Oct 2020 14:09:43 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/whole' into whole

---
 src/main/java/com/xcong/excoin/modules/contract/parameter/vo/HoldOrderDetailVo.java               |    8 ++
 src/main/java/com/xcong/excoin/utils/dingtalk/DingTalkUtils.java                                  |    4 
 src/main/java/com/xcong/excoin/modules/contract/service/impl/OrderWebsocketServiceImpl.java       |    3 
 src/main/java/com/xcong/excoin/configurations/security/TokenFilter.java                           |    2 
 src/main/java/com/xcong/excoin/utils/ThreadPoolUtils.java                                         |    1 
 src/main/java/com/xcong/excoin/common/enumerates/SymbolsPlacesEnum.java                           |   38 ++++++++++++
 src/main/resources/application-app.yml                                                            |    6 +-
 src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractEntrustOrderServiceImpl.java |    4 +
 src/main/java/com/xcong/excoin/modules/symbols/service/SymbolsService.java                        |    3 +
 src/main/java/com/xcong/excoin/modules/contract/parameter/vo/OrderDetailVo.java                   |    8 ++
 src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java                 |    4 
 src/main/java/com/xcong/excoin/utils/mail/Sms106Send.java                                         |    3 
 src/main/java/com/xcong/excoin/common/enumerates/MemberWalletCoinEnum.java                        |    4 
 src/main/resources/application-newprice.yml                                                       |    6 +-
 src/main/java/com/xcong/excoin/modules/contract/parameter/vo/OrderListVo.java                     |    5 +
 src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractHoldOrderServiceImpl.java    |    6 ++
 src/main/java/com/xcong/excoin/modules/coin/service/impl/CoinServiceImpl.java                     |    4 
 src/main/java/com/xcong/excoin/modules/contract/parameter/vo/HoldOrderListVo.java                 |    5 +
 src/main/java/com/xcong/excoin/modules/contract/controller/ContractOrderController.java           |    3 
 src/main/java/com/xcong/excoin/modules/blackchain/service/Impl/BlockSeriveImpl.java               |    4 
 src/main/java/com/xcong/excoin/modules/coin/parameter/vo/MemberAccountMoneyChangeInfoVo.java      |    2 
 src/main/resources/application-loop.yml                                                           |    6 +-
 src/main/resources/application-dayline.yml                                                        |    6 +-
 src/main/java/com/xcong/excoin/modules/contract/service/impl/RabbitOrderServiceImpl.java          |    5 +
 src/test/java/com/xcong/excoin/WholeTest.java                                                     |    2 
 src/main/java/com/xcong/excoin/modules/contract/parameter/vo/ContractMoneyInfoVo.java             |    3 +
 src/main/java/com/xcong/excoin/modules/symbols/service/impl/SymbolsServiceImpl.java               |    1 
 src/main/resources/application.yml                                                                |   12 ++--
 28 files changed, 115 insertions(+), 43 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/common/enumerates/MemberWalletCoinEnum.java b/src/main/java/com/xcong/excoin/common/enumerates/MemberWalletCoinEnum.java
index e4d58dc..58a7210 100644
--- a/src/main/java/com/xcong/excoin/common/enumerates/MemberWalletCoinEnum.java
+++ b/src/main/java/com/xcong/excoin/common/enumerates/MemberWalletCoinEnum.java
@@ -14,9 +14,9 @@
 	CONTENTFROMWALLETCOIN("0002","由币币账户转入"),
 	
 	CONTENTTOWALLETCOIN("0003","转出至币币账户"),
-	CONTENTFROMCONTRACT("0004","由合约账户转入"),
+	CONTENTFROMCONTRACT("0004","合约账户转入"),
 	
-	CONTENTFROMAGENT("0005","由代理账户转入"),
+	CONTENTFROMAGENT("0005","代理账户转入"),
 	
 	WALLETCOINCODE("USDT", "USDT"),
 	
diff --git a/src/main/java/com/xcong/excoin/common/enumerates/SymbolsPlacesEnum.java b/src/main/java/com/xcong/excoin/common/enumerates/SymbolsPlacesEnum.java
new file mode 100644
index 0000000..01d0e90
--- /dev/null
+++ b/src/main/java/com/xcong/excoin/common/enumerates/SymbolsPlacesEnum.java
@@ -0,0 +1,38 @@
+package com.xcong.excoin.common.enumerates;
+
+import lombok.Getter;
+
+/**
+ * 币种小数点
+ */
+@Getter
+public enum SymbolsPlacesEnum {
+
+    BTC("BTC/USDT", 2)
+    ,ETH("ETH/USDT", 2)
+    ,LTC("LTC/USDT", 2)
+    ,BCH("BCH/USDT", 2)
+    ,EOS("EOS/USDT", 4)
+    ,XRP("XRP/USDT", 5)
+    ,ETC("ETC/USDT", 4);
+
+    private String symbol;
+
+    private Integer places;
+
+    private SymbolsPlacesEnum(String symbol, Integer places) {
+        this.symbol = symbol;
+        this.places = places;
+    }
+
+    public static Integer getValueByName(String symbol) {
+        Integer places = 0;
+        for (SymbolsPlacesEnum symbolsPlacesEnum : values()) {
+            if (symbol.equals(symbolsPlacesEnum.getSymbol())){
+                places = symbolsPlacesEnum.getPlaces();
+                break;
+            }
+        }
+        return places;
+    }
+}
diff --git a/src/main/java/com/xcong/excoin/configurations/security/TokenFilter.java b/src/main/java/com/xcong/excoin/configurations/security/TokenFilter.java
index 362eb8b..938b6cd 100644
--- a/src/main/java/com/xcong/excoin/configurations/security/TokenFilter.java
+++ b/src/main/java/com/xcong/excoin/configurations/security/TokenFilter.java
@@ -116,7 +116,7 @@
         boolean isDebug = applicationProperties.isDebug();
         if (!isDebug) {
             long currentTime = System.currentTimeMillis();
-            return currentTime - time <= 10000;
+            return currentTime - time <= 30000;
         }
         return true;
     }
diff --git a/src/main/java/com/xcong/excoin/modules/blackchain/service/Impl/BlockSeriveImpl.java b/src/main/java/com/xcong/excoin/modules/blackchain/service/Impl/BlockSeriveImpl.java
index 87d9239..acef51c 100644
--- a/src/main/java/com/xcong/excoin/modules/blackchain/service/Impl/BlockSeriveImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/blackchain/service/Impl/BlockSeriveImpl.java
@@ -100,12 +100,12 @@
                         }
                         break;
                     case "EOS":
-                        address = "biyicteos123";
+                        address = "hibitdeposit";
                         map.put("address", address);
                         map.put("lable", uuid);
                         break;
                     case "XRP":
-                        address = "biyicteos123";
+                        address = "rKMGEyjXErL2dx9ck5QXFJVH8onSfHF5gn";
                         map.put("address", address);
                         map.put("lable", uuid);
                         break;
diff --git a/src/main/java/com/xcong/excoin/modules/coin/parameter/vo/MemberAccountMoneyChangeInfoVo.java b/src/main/java/com/xcong/excoin/modules/coin/parameter/vo/MemberAccountMoneyChangeInfoVo.java
index 69306a0..4255a54 100644
--- a/src/main/java/com/xcong/excoin/modules/coin/parameter/vo/MemberAccountMoneyChangeInfoVo.java
+++ b/src/main/java/com/xcong/excoin/modules/coin/parameter/vo/MemberAccountMoneyChangeInfoVo.java
@@ -40,7 +40,7 @@
 	private int status;
 	
 	@ApiModelProperty(value = "时间")
-	@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+	@JsonFormat(pattern = "HH:mm MM/dd", timezone = "GMT+8")
     private Date updateTime;
 
 }
diff --git a/src/main/java/com/xcong/excoin/modules/coin/service/impl/CoinServiceImpl.java b/src/main/java/com/xcong/excoin/modules/coin/service/impl/CoinServiceImpl.java
index 89de828..13f7a05 100644
--- a/src/main/java/com/xcong/excoin/modules/coin/service/impl/CoinServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/coin/service/impl/CoinServiceImpl.java
@@ -494,7 +494,7 @@
     	memberAccountMoneyChangeDao.insert(memberAccountRecord);
     	
     	//添加资金划转历史记录
-    	memberAccountRecord.setContent("由合约"+symbol+"账户转入");
+    	memberAccountRecord.setContent("合约"+symbol+"账户转入");
     	memberAccountRecord.setSymbol(walletCode);
     	memberAccountRecord.setType(MemberAccountMoneyChange.TYPE_WALLET_COIN);
     	memberAccountRecord.setAmount(balance);
@@ -965,7 +965,7 @@
         memberAccountMoneyChangeDao.insert(memberAccountRecord);
 
         //添加合约资金划转历史记录
-        memberAccountRecord.setContent("由合约"+symbolOut+"账户转入至合约"+symbolIn+"账户");
+        memberAccountRecord.setContent("合约"+symbolOut+"账户转入至合约"+symbolIn+"账户");
         memberAccountRecord.setAmount(balance);
         memberAccountMoneyChangeDao.insert(memberAccountRecord);
         
diff --git a/src/main/java/com/xcong/excoin/modules/contract/controller/ContractOrderController.java b/src/main/java/com/xcong/excoin/modules/contract/controller/ContractOrderController.java
index 822744f..59eed54 100644
--- a/src/main/java/com/xcong/excoin/modules/contract/controller/ContractOrderController.java
+++ b/src/main/java/com/xcong/excoin/modules/contract/controller/ContractOrderController.java
@@ -126,7 +126,8 @@
     @ApiOperation(value = "全仓模式 - 变更仓位类型")
     @GetMapping(value = "/changePositionType")
     public Result changePositionType() {
-        return contractHoldOrderService.changePositionType();
+        return Result.fail("无法切换");
+//        return contractHoldOrderService.changePositionType();
     }
 
     @GetMapping(value = "/findPositionType")
diff --git a/src/main/java/com/xcong/excoin/modules/contract/parameter/vo/ContractMoneyInfoVo.java b/src/main/java/com/xcong/excoin/modules/contract/parameter/vo/ContractMoneyInfoVo.java
index ec0d97d..06c142c 100644
--- a/src/main/java/com/xcong/excoin/modules/contract/parameter/vo/ContractMoneyInfoVo.java
+++ b/src/main/java/com/xcong/excoin/modules/contract/parameter/vo/ContractMoneyInfoVo.java
@@ -41,6 +41,9 @@
     @ApiModelProperty(value = "规格")
     private BigDecimal symbolSku;
 
+    @ApiModelProperty(value = "涨跌幅")
+    private BigDecimal upOrDown;
+
     public BigDecimal getBeUsedBondAmount() {
         return beUsedBondAmount.setScale(4, BigDecimal.ROUND_DOWN);
     }
diff --git a/src/main/java/com/xcong/excoin/modules/contract/parameter/vo/HoldOrderDetailVo.java b/src/main/java/com/xcong/excoin/modules/contract/parameter/vo/HoldOrderDetailVo.java
index 66f370b..d1739ee 100644
--- a/src/main/java/com/xcong/excoin/modules/contract/parameter/vo/HoldOrderDetailVo.java
+++ b/src/main/java/com/xcong/excoin/modules/contract/parameter/vo/HoldOrderDetailVo.java
@@ -1,6 +1,7 @@
 package com.xcong.excoin.modules.contract.parameter.vo;
 
 import com.fasterxml.jackson.annotation.JsonFormat;
+import com.xcong.excoin.common.enumerates.SymbolsPlacesEnum;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
@@ -63,8 +64,11 @@
     @ApiModelProperty("倍率杠杆")
     private int leverRatio;
 
+    @ApiModelProperty("剩余张数")
+    private int symbolCntSale;
+
     public String getOpeningPrice() {
-        return openingPrice == null ? "" : openingPrice.setScale(4, BigDecimal.ROUND_DOWN).toPlainString();
+        return openingPrice == null ? "" : openingPrice.setScale(SymbolsPlacesEnum.getValueByName(this.symbol), BigDecimal.ROUND_DOWN).toPlainString();
     }
 
     public String getOpeningFeeAmount() {
@@ -80,7 +84,7 @@
     }
 
     public String getForceClosingPrice() {
-        return forceClosingPrice == null ? "" : forceClosingPrice.setScale(4, BigDecimal.ROUND_DOWN).toPlainString();
+        return forceClosingPrice == null ? "" : forceClosingPrice.setScale(SymbolsPlacesEnum.getValueByName(this.symbol), BigDecimal.ROUND_DOWN).toPlainString();
     }
 
     public void setOpeningFeeAmount(BigDecimal openingFeeAmount, BigDecimal feeSpread) {
diff --git a/src/main/java/com/xcong/excoin/modules/contract/parameter/vo/HoldOrderListVo.java b/src/main/java/com/xcong/excoin/modules/contract/parameter/vo/HoldOrderListVo.java
index 0e924ca..e5310e6 100644
--- a/src/main/java/com/xcong/excoin/modules/contract/parameter/vo/HoldOrderListVo.java
+++ b/src/main/java/com/xcong/excoin/modules/contract/parameter/vo/HoldOrderListVo.java
@@ -1,6 +1,7 @@
 package com.xcong.excoin.modules.contract.parameter.vo;
 
 import com.fasterxml.jackson.annotation.JsonFormat;
+import com.xcong.excoin.common.enumerates.SymbolsPlacesEnum;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
@@ -73,7 +74,7 @@
     private Integer positionType;
 
     public String getOpeningPrice() {
-        return openingPrice.setScale(4, BigDecimal.ROUND_DOWN).toPlainString();
+        return openingPrice.setScale(SymbolsPlacesEnum.getValueByName(this.symbol), BigDecimal.ROUND_DOWN).toPlainString();
     }
 
     public String getBondAmount() {
@@ -81,7 +82,7 @@
     }
 
     public String getForceClosingPrice() {
-        return forceClosingPrice.setScale(4, BigDecimal.ROUND_DOWN).toPlainString();
+        return forceClosingPrice.setScale(SymbolsPlacesEnum.getValueByName(this.symbol), BigDecimal.ROUND_DOWN).toPlainString();
     }
 
     public String getProfitOrLoss() {
diff --git a/src/main/java/com/xcong/excoin/modules/contract/parameter/vo/OrderDetailVo.java b/src/main/java/com/xcong/excoin/modules/contract/parameter/vo/OrderDetailVo.java
index 2939331..4ac6b37 100644
--- a/src/main/java/com/xcong/excoin/modules/contract/parameter/vo/OrderDetailVo.java
+++ b/src/main/java/com/xcong/excoin/modules/contract/parameter/vo/OrderDetailVo.java
@@ -1,6 +1,7 @@
 package com.xcong.excoin.modules.contract.parameter.vo;
 
 import com.fasterxml.jackson.annotation.JsonFormat;
+import com.xcong.excoin.common.enumerates.SymbolsPlacesEnum;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
@@ -81,8 +82,11 @@
     @ApiModelProperty("杠杆")
     private int leverRatio;
 
+    @ApiModelProperty("剩余张数")
+    private int symbolCntSale;
+
     public String getClosingPrice() {
-        return closingPrice == null ? "" : closingPrice.setScale(4, BigDecimal.ROUND_DOWN).toPlainString();
+        return closingPrice == null ? "" : closingPrice.setScale(SymbolsPlacesEnum.getValueByName(this.symbol), BigDecimal.ROUND_DOWN).toPlainString();
     }
 
     public String getClosingFeeAmount() {
@@ -94,7 +98,7 @@
     }
 
     public String getOpeningPrice() {
-        return openingPrice == null ? "" : openingPrice.setScale(4, BigDecimal.ROUND_DOWN).toPlainString();
+        return openingPrice == null ? "" : openingPrice.setScale(SymbolsPlacesEnum.getValueByName(this.symbol), BigDecimal.ROUND_DOWN).toPlainString();
     }
 
     public String getOpeningFeeAmount() {
diff --git a/src/main/java/com/xcong/excoin/modules/contract/parameter/vo/OrderListVo.java b/src/main/java/com/xcong/excoin/modules/contract/parameter/vo/OrderListVo.java
index 48cc3ba..9839096 100644
--- a/src/main/java/com/xcong/excoin/modules/contract/parameter/vo/OrderListVo.java
+++ b/src/main/java/com/xcong/excoin/modules/contract/parameter/vo/OrderListVo.java
@@ -4,7 +4,7 @@
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
-import org.web3j.abi.datatypes.Int;
+import org.web3j.abi.datatypes.primitive.Int;
 
 import java.math.BigDecimal;
 import java.util.Date;
@@ -70,6 +70,9 @@
     @ApiModelProperty(value = "合约类型 1-普通 2-跟单")
     private Integer contractType;
 
+    @ApiModelProperty(value = "杠杆倍率")
+    private Integer leverRatio;
+
     public String getOpeningFeeAmount() {
         return openingFeeAmount == null ? "" : openingFeeAmount.setScale(4, BigDecimal.ROUND_DOWN).toPlainString();
     }
diff --git a/src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractEntrustOrderServiceImpl.java b/src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractEntrustOrderServiceImpl.java
index 4b263e1..96c64d6 100644
--- a/src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractEntrustOrderServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractEntrustOrderServiceImpl.java
@@ -264,7 +264,9 @@
         } else {
             walletContractEntity = memberWalletContractDao.findWalletContractByMemberIdAndSymbol(memberEntity.getId(), CoinTypeConvert.convertContractTypeToCoin(entrustOrderEntity.getSymbol()));
 
-            memberWalletContractDao.increaseWalletContractBalanceById(entrustOrderEntity.getEntrustAmount(), null, entrustOrderEntity.getBondAmount().negate(), walletContractEntity.getId());
+            if (ContractEntrustOrderEntity.ENTRUST_TYPE_OPEN_MORE == entrustOrderEntity.getEntrustType() || ContractEntrustOrderEntity.ENTRUST_TYPE_OPEN_LESS == entrustOrderEntity.getEntrustType()) {
+                memberWalletContractDao.increaseWalletContractBalanceById(entrustOrderEntity.getEntrustAmount(), null, entrustOrderEntity.getBondAmount().negate(), walletContractEntity.getId());
+            }
         }
 
         ContractOrderEntity orderEntity = ContractEntrustOrderEntityMapper.INSTANCE.entrustOrderToOrder(entrustOrderEntity);
diff --git a/src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractHoldOrderServiceImpl.java b/src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractHoldOrderServiceImpl.java
index f05568c..2f4daa2 100644
--- a/src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractHoldOrderServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/contract/service/impl/ContractHoldOrderServiceImpl.java
@@ -34,6 +34,8 @@
 import com.xcong.excoin.modules.member.entity.*;
 import com.xcong.excoin.modules.platform.dao.TradeSettingDao;
 import com.xcong.excoin.modules.platform.entity.PlatformTradeSettingEntity;
+import com.xcong.excoin.modules.symbols.parameter.vo.HomeSymbolsVo;
+import com.xcong.excoin.modules.symbols.service.SymbolsService;
 import com.xcong.excoin.rabbit.producer.OrderProducer;
 import com.xcong.excoin.utils.*;
 import com.xcong.excoin.rabbit.pricequeue.OrderModel;
@@ -93,6 +95,8 @@
     private FollowTraderInfoDao followTraderInfoDao;
     @Resource
     private FollowFollowerOrderRelationDao followFollowerOrderRelationDao;
+    @Resource
+    private SymbolsService symbolsService;
 
     @Transactional(rollbackFor = Exception.class)
     @Override
@@ -805,6 +809,7 @@
 //            contractMoneyInfoVo.setAvailableBalance(available);
 //        }
 
+        HomeSymbolsVo symbolReturnData = symbolsService.getSymbolReturnData(symbol);
 
         contractMoneyInfoVo.setBeUsedBondAmount(beUsedBondAmount);
         contractMoneyInfoVo.setFrozenBondAmount(frozenBondAmount);
@@ -815,6 +820,7 @@
         contractMoneyInfoVo.setNewPrice(newPriceSymbol);
         contractMoneyInfoVo.setSymbolSku(cacheSettingUtils.getSymbolSku(symbol));
         contractMoneyInfoVo.setLeverRate(rateEntity.getLevelRateUp());
+        contractMoneyInfoVo.setUpOrDown(symbolReturnData.getUpOrDown());
         return Result.ok(contractMoneyInfoVo);
     }
 
diff --git a/src/main/java/com/xcong/excoin/modules/contract/service/impl/OrderWebsocketServiceImpl.java b/src/main/java/com/xcong/excoin/modules/contract/service/impl/OrderWebsocketServiceImpl.java
index c6d461b..a0ef098 100644
--- a/src/main/java/com/xcong/excoin/modules/contract/service/impl/OrderWebsocketServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/contract/service/impl/OrderWebsocketServiceImpl.java
@@ -637,6 +637,7 @@
                 contractHoldOrderEntity.setOpeningPrice(entrustPrice);
                 contractHoldOrderEntity.setTradeType(ContractHoldOrderEntity.TRADE_TYPE_LIMIT);
                 contractHoldOrderEntity.setOperateNo(1);
+                contractHoldOrderEntity.setSymbolCntSale(contractHoldOrderEntity.getSymbolCnt());
                 contractHoldOrderService.save(contractHoldOrderEntity);
 
                 // 需要一个历史插入
@@ -710,7 +711,7 @@
             }
 
             holdOrderEntity.setTradeType(ContractHoldOrderEntity.TRADE_TYPE_LIMIT);
-            holdOrderEntity.setSymbolCntSale(holdOrderEntity.getSymbolCnt());
+            holdOrderEntity.setSymbolCntSale(entrustOrder.getSymbolCnt());
             holdOrderEntity.setOpeningFeeAmount(openFeePrice);
             holdOrderEntity.setOpeningPrice(entrustOrder.getEntrustPrice());
             holdOrderEntity.setMarkPrice(entrustOrder.getEntrustPrice());
diff --git a/src/main/java/com/xcong/excoin/modules/contract/service/impl/RabbitOrderServiceImpl.java b/src/main/java/com/xcong/excoin/modules/contract/service/impl/RabbitOrderServiceImpl.java
index 449dc44..ad1cae7 100644
--- a/src/main/java/com/xcong/excoin/modules/contract/service/impl/RabbitOrderServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/contract/service/impl/RabbitOrderServiceImpl.java
@@ -300,6 +300,8 @@
             // 保证金
             BigDecimal bondAmount = CalculateUtil.getBondAmount(holdOrderEntity.getOpeningPrice(), lotNumber, closeCnt, holdOrderEntity.getLeverRatio());
 
+            BigDecimal rewardRatio = profitOrLoss.divide(bondAmount, 8, BigDecimal.ROUND_DOWN);
+
             log.info("bondAmount:{}", bondAmount);
             // 平仓手续费  TODO 可能需要修复手续费
             BigDecimal fee = BigDecimal.ZERO;
@@ -320,6 +322,7 @@
             contractOrderEntity.setRewardAmount(profitOrLoss);
             contractOrderEntity.setBondAmount(bondAmount);
             contractOrderEntity.setClosingFeeAmount(fee);
+            contractOrderEntity.setRewardRatio(rewardRatio);
             contractOrderDao.insert(contractOrderEntity);
 
             if (holdOrderEntity.getSymbolCntSale() != 0) {
@@ -376,7 +379,7 @@
         log.info("执行平仓委托");
 
         Long memberId = entrustOrder.getMemberId();
-        int orderType = entrustOrder.getEntrustType() == ContractEntrustOrderEntity.ENTRUST_TYPE_CLOSE_MORE ? ContractHoldOrderEntity.OPENING_TYPE_MORE : ContractHoldOrderEntity.OPENING_TYPE_LESS;
+        int orderType = entrustOrder.getEntrustType() == ContractEntrustOrderEntity.ENTRUST_TYPE_CLOSE_MORE ? ContractOrderEntity.ORDER_TYPE_CLOSE_MORE : ContractOrderEntity.ORDER_TYPE_CLOSE_LESS;
         String symbol = entrustOrder.getSymbol();
 
         MemberEntity memberEntity = memberDao.selectById(memberId);
diff --git a/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java b/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java
index 07dea96..c8a29f6 100644
--- a/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/member/service/impl/MemberServiceImpl.java
@@ -162,13 +162,13 @@
         member.setCertifyStatus(MemberEntity.CERTIFY_STATUS_UN_SUBMIT);
         member.setIsForce(1);
         member.setIsProfit(0);
-        member.setContractPositionType(ContractEntrustOrderEntity.POSITION_TYPE_ALL);
+        member.setContractPositionType(ContractEntrustOrderEntity.POSITION_TYPE_ADD);
         memberDao.insert(member);
 
         MemberSettingEntity memberSettingEntity = new MemberSettingEntity();
         memberSettingEntity.setSpread(BigDecimal.ONE);
         memberSettingEntity.setClosingSpread(BigDecimal.valueOf(5));
-        memberSettingEntity.setForceParam(BigDecimal.valueOf(0.0055));
+        memberSettingEntity.setForceParam(BigDecimal.valueOf(0.0075));
         memberSettingEntity.setMemberId(member.getId());
         memberSettingDao.insert(memberSettingEntity);
 
diff --git a/src/main/java/com/xcong/excoin/modules/symbols/service/SymbolsService.java b/src/main/java/com/xcong/excoin/modules/symbols/service/SymbolsService.java
index be91c71..c7c54b3 100644
--- a/src/main/java/com/xcong/excoin/modules/symbols/service/SymbolsService.java
+++ b/src/main/java/com/xcong/excoin/modules/symbols/service/SymbolsService.java
@@ -3,6 +3,7 @@
 
 import com.xcong.excoin.common.response.Result;
 import com.xcong.excoin.modules.symbols.parameter.dto.KlineDetailDto;
+import com.xcong.excoin.modules.symbols.parameter.vo.HomeSymbolsVo;
 
 /**
  * @author wzy
@@ -18,4 +19,6 @@
 
     public Result findKlineDetails(KlineDetailDto klineDetailDto);
 
+    public HomeSymbolsVo getSymbolReturnData(String symbol);
+
 }
diff --git a/src/main/java/com/xcong/excoin/modules/symbols/service/impl/SymbolsServiceImpl.java b/src/main/java/com/xcong/excoin/modules/symbols/service/impl/SymbolsServiceImpl.java
index 95d294a..e714412 100644
--- a/src/main/java/com/xcong/excoin/modules/symbols/service/impl/SymbolsServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/symbols/service/impl/SymbolsServiceImpl.java
@@ -124,6 +124,7 @@
         return Result.ok(homeSymbolsVo);
     }
 
+    @Override
     public HomeSymbolsVo getSymbolReturnData(String symbol) {
         PlatformCnyUsdtExchangeEntity cnyUsdtExchange = platformCnyUsdtExchangeDao.getCNYAndUSDTOne();
         // 获取当日k线数据
diff --git a/src/main/java/com/xcong/excoin/utils/ThreadPoolUtils.java b/src/main/java/com/xcong/excoin/utils/ThreadPoolUtils.java
index af0fd99..e9f4d3b 100644
--- a/src/main/java/com/xcong/excoin/utils/ThreadPoolUtils.java
+++ b/src/main/java/com/xcong/excoin/utils/ThreadPoolUtils.java
@@ -78,6 +78,7 @@
             @Override
             public void run() {
                 try {
+                    Thread.sleep(500);
                     CalculateUtil.getForceSetPriceForWhole(symbol, memberEntity);
                 } catch (Exception e) {
                     log.error("全仓模式预估强平价", e);
diff --git a/src/main/java/com/xcong/excoin/utils/dingtalk/DingTalkUtils.java b/src/main/java/com/xcong/excoin/utils/dingtalk/DingTalkUtils.java
index 70ed481..2ccc1aa 100644
--- a/src/main/java/com/xcong/excoin/utils/dingtalk/DingTalkUtils.java
+++ b/src/main/java/com/xcong/excoin/utils/dingtalk/DingTalkUtils.java
@@ -21,11 +21,11 @@
 @Slf4j
 public class DingTalkUtils {
 
-    private static final String SECRET = "SECc0b73559742b950f07eabbd050c406a6abb3b67d112d3735289e90f58884c543";
+    private static final String SECRET = "SEC6b1c402a4fa857e7c5e9e6d4d4afd1296a520893af68e063c7a7f005b4ae2a34";
 
     public static void sendActionCard(int type) {
         log.info("send dingtalk");
-        String url = "https://oapi.dingtalk.com/robot/send?access_token=161d5e5b60ae5d6b4c80f2a9c35f9f212961a7c7154aa7e94b99503eca3886b0";
+        String url = "https://oapi.dingtalk.com/robot/send?access_token=acc3ae94c91b06372b8465ba3fc079fc9bf382fbf8aee10fb4307ab978c1f5f7";
         Long timestamp = System.currentTimeMillis();
         try {
             String sign = generateSign(timestamp);
diff --git a/src/main/java/com/xcong/excoin/utils/mail/Sms106Send.java b/src/main/java/com/xcong/excoin/utils/mail/Sms106Send.java
index 567a027..c89f642 100644
--- a/src/main/java/com/xcong/excoin/utils/mail/Sms106Send.java
+++ b/src/main/java/com/xcong/excoin/utils/mail/Sms106Send.java
@@ -37,8 +37,9 @@
     }
 
     public static boolean sendRechargeMsg(String phone, String time, String orderNo) {
-        String msg = "尊敬的用户,您的帐号于{}有一笔成功充值订单,如有疑问请联系客服,订单编号为{}";
+        String msg = "尊敬的用户,您的帐号于{}有一笔成功充值订单,订单编号为{}";
         String content = StrUtil.format(msg, time, orderNo);
+        log.info("短信发送:{}", content);
         return request(phone, content, "充值");
     }
 
diff --git a/src/main/resources/application-app.yml b/src/main/resources/application-app.yml
index d19e4cb..59cef21 100644
--- a/src/main/resources/application-app.yml
+++ b/src/main/resources/application-app.yml
@@ -48,13 +48,13 @@
   ## redis配置
   redis:
     ## Redis数据库索引(默认为0)
-    database: 2
+    database: 1
     ## Redis服务器地址
-    host: 47.114.114.219
+    host: 114.55.92.106
     ## Redis服务器连接端口
     port: 6379
     ## Redis服务器连接密码(默认为空)
-    password: biyi123
+    password: hibit123
     jedis:
       pool:
         ## 连接池最大连接数(使用负值表示没有限制)
diff --git a/src/main/resources/application-dayline.yml b/src/main/resources/application-dayline.yml
index ee8bb43..66e652f 100644
--- a/src/main/resources/application-dayline.yml
+++ b/src/main/resources/application-dayline.yml
@@ -48,13 +48,13 @@
   ## redis配置
   redis:
     ## Redis数据库索引(默认为0)
-    database: 2
+    database: 1
     ## Redis服务器地址
-    host: 47.114.114.219
+    host: 114.55.92.106
     ## Redis服务器连接端口
     port: 6379
     ## Redis服务器连接密码(默认为空)
-    password: biyi123
+    password: hibit123
     jedis:
       pool:
         ## 连接池最大连接数(使用负值表示没有限制)
diff --git a/src/main/resources/application-loop.yml b/src/main/resources/application-loop.yml
index 57d631e..2bb0e1e 100644
--- a/src/main/resources/application-loop.yml
+++ b/src/main/resources/application-loop.yml
@@ -48,13 +48,13 @@
   ## redis配置
   redis:
     ## Redis数据库索引(默认为0)
-    database: 2
+    database: 1
     ## Redis服务器地址
-    host: 47.114.114.219
+    host: 114.55.92.106
     ## Redis服务器连接端口
     port: 6379
     ## Redis服务器连接密码(默认为空)
-    password: biyi123
+    password: hibit123
     jedis:
       pool:
         ## 连接池最大连接数(使用负值表示没有限制)
diff --git a/src/main/resources/application-newprice.yml b/src/main/resources/application-newprice.yml
index 06c4be8..93eddfa 100644
--- a/src/main/resources/application-newprice.yml
+++ b/src/main/resources/application-newprice.yml
@@ -48,13 +48,13 @@
   ## redis配置
   redis:
     ## Redis数据库索引(默认为0)
-    database: 2
+    database: 1
     ## Redis服务器地址
-    host: 47.114.114.219
+    host: 114.55.92.106
     ## Redis服务器连接端口
     port: 6379
     ## Redis服务器连接密码(默认为空)
-    password: biyi123
+    password: hibit123
     jedis:
       pool:
         ## 连接池最大连接数(使用负值表示没有限制)
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index ffca27b..73e32f2 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -7,12 +7,12 @@
   profiles:
     active: dev
   datasource:
-#    url: jdbc:mysql://rm-bp151tw8er79ig9kb5o.mysql.rds.aliyuncs.com:3306/db_biue?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2b8
-#    username: ctcoin_data
-#    password: ctcoin_123
-    url: jdbc:mysql://120.27.238.55:3306/kss_framework?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2b8
-    username: ct_test
-    password: 123456
+    url: jdbc:mysql://rm-bp151tw8er79ig9kb5o.mysql.rds.aliyuncs.com:3306/db_hibit?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2b8
+    username: ctcoin_data
+    password: ctcoin_123
+#    url: jdbc:mysql://120.27.238.55:3306/kss_framework?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2b8
+#    username: ct_test
+#    password: 123456
     driver-class-name: com.mysql.jdbc.Driver
     type: com.alibaba.druid.pool.DruidDataSource
     druid:
diff --git a/src/test/java/com/xcong/excoin/WholeTest.java b/src/test/java/com/xcong/excoin/WholeTest.java
index 954c68d..8c633c4 100644
--- a/src/test/java/com/xcong/excoin/WholeTest.java
+++ b/src/test/java/com/xcong/excoin/WholeTest.java
@@ -111,7 +111,7 @@
      */
     @Test
     public void forceSetPriceTest() {
-        MemberEntity memberEntity = memberDao.selectById(5L);
+        MemberEntity memberEntity = memberDao.selectById(66L);
         CalculateUtil.getForceSetPriceForWhole("BTC/USDT", memberEntity);
     }
 

--
Gitblit v1.9.1