From 2bb8c9ae6db2668213d03d02cd8b38e6bc7aae83 Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Fri, 21 Aug 2020 11:22:33 +0800
Subject: [PATCH] Merge branch 'whole' of https://gitee.com/chonggaoxiao/new_excoin into whole

---
 src/main/java/com/xcong/excoin/utils/ThreadPoolUtils.java |   29 ++++++++++++++++++++++++++++-
 1 files changed, 28 insertions(+), 1 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/utils/ThreadPoolUtils.java b/src/main/java/com/xcong/excoin/utils/ThreadPoolUtils.java
index 528598c..af0fd99 100644
--- a/src/main/java/com/xcong/excoin/utils/ThreadPoolUtils.java
+++ b/src/main/java/com/xcong/excoin/utils/ThreadPoolUtils.java
@@ -3,8 +3,11 @@
 import com.xcong.excoin.modules.contract.entity.ContractOrderEntity;
 import com.xcong.excoin.modules.contract.service.impl.OrderWebsocketServiceImpl;
 import com.xcong.excoin.modules.documentary.service.FollowOrderOperationService;
+import com.xcong.excoin.modules.member.entity.MemberEntity;
 import com.xcong.excoin.utils.dingtalk.DingTalkUtils;
+import lombok.extern.slf4j.Slf4j;
 
+import javax.validation.constraints.NotNull;
 import java.math.BigDecimal;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
@@ -13,6 +16,7 @@
  * @author wzy
  * @date 2020-06-01
  **/
+@Slf4j
 public class ThreadPoolUtils {
 
     public static final ExecutorService EXECUTOR = Executors.newFixedThreadPool(20);
@@ -54,7 +58,30 @@
         EXECUTOR.execute(new Runnable() {
             @Override
             public void run() {
-                followOrderOperationService.addFollowerOrder(id);
+                try {
+                    followOrderOperationService.addFollowerOrder(id);
+                } catch (Exception e) {
+                    log.error("产生跟单任务报错", e);
+                }
+            }
+        });
+    }
+
+    /**
+     * 全仓模式 -- 预估强平价
+     *
+     * @param symbol       币种
+     * @param memberEntity 会员信息
+     */
+    public static void sendWholeForceClosingPrice(@NotNull String symbol, @NotNull MemberEntity memberEntity) {
+        EXECUTOR.execute(new Runnable() {
+            @Override
+            public void run() {
+                try {
+                    CalculateUtil.getForceSetPriceForWhole(symbol, memberEntity);
+                } catch (Exception e) {
+                    log.error("全仓模式预估强平价", e);
+                }
             }
         });
     }

--
Gitblit v1.9.1