l1024-jav/src/main/java/top/lvzhiqiang/service/impl/CoinServiceImpl.java

package top.lvzhiqiang.service.impl;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import lombok.extern.slf4j.Slf4j;
import me.chanjar.weixin.common.error.WxErrorException;
import me.chanjar.weixin.cp.api.WxCpGroupRobotService;
import me.chanjar.weixin.cp.api.WxCpService;
import me.chanjar.weixin.cp.api.impl.WxCpServiceImpl;
import me.chanjar.weixin.cp.bean.article.NewArticle;
import me.chanjar.weixin.cp.bean.message.WxCpMessage;
import me.chanjar.weixin.cp.bean.message.WxCpMessageSendResult;
import me.chanjar.weixin.cp.config.impl.WxCpDefaultConfigImpl;
import org.jsoup.Connection;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.StopWatch;
import top.lvzhiqiang.config.InitRunner;
import top.lvzhiqiang.config.WorkWeixinProperties;
import top.lvzhiqiang.entity.CoinHistoryOrder;
import top.lvzhiqiang.entity.CoinMonitorCurrency;
import top.lvzhiqiang.entity.CoinTrader;
import top.lvzhiqiang.mapper.CoinMapper;
import top.lvzhiqiang.service.CoinService;
import top.lvzhiqiang.util.*;

import javax.annotation.Resource;
import java.io.UnsupportedEncodingException;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.security.InvalidKeyException;
import java.text.DecimalFormat;
import java.time.Duration;
import java.time.LocalDateTime;
import java.util.*;
import java.util.concurrent.*;
import java.util.function.Function;
import java.util.stream.Collectors;

/**
 * Coin ServiceImpl
 *
 * @author lvzhiqiang
 * 2023/9/5 15:23
 */
@Service
@Slf4j
public class CoinServiceImpl implements CoinService {

    /**
     * 任务告警方式-应用文本卡片
     */
    public static final String JOB_ALARM_MODE_APP_TEXT_CARD = "1";

    /**
     * 任务告警方式-群聊机器人
     */
    public static final String JOB_ALARM_MODE_CHAT_BOT = "2";

    /**
     * 任务告警方式（1：应用文本卡片，2：群聊机器人文本消息）
     */
    public static String JOB_ALARM_MODE = "1";

    // 所有REST请求的header都必须包含以下key：
    private static final Map<String, String> basicHeaderMap = new HashMap<>();
    private static final Map<String, String> basicHeaderMap4OKX = new HashMap<>();
    // 主域名 URL
    private static final String mainUrl = "https://api.bitget.com";
    // 私钥，由系统随机生成，用于签名的生成。
    private static final String secretKey = "1fdd0fc2976bea80189ba13710e12825ca3ef6c5e25a0d76fd03f8f6cd4a61d9";
    private static final String secretKey4OKX = "32AC470662FBB633374B9A41950995A9";

    @Resource
    private CoinMapper coinMapper;
    @Resource
    private WxCpService wxCpService;
    @Autowired(required = false)
    private WorkWeixinProperties properties;

    private final Map<String, String> orderMap = new ConcurrentHashMap<>();
    private final Map<String, JSONObject> mixMap = new ConcurrentHashMap<>();
    private final static ScheduledExecutorService scheduler = new ScheduledThreadPoolExecutor(10);

    private final ForkJoinPool forkJoinPool = new ForkJoinPool(16);
    private final ForkJoinPool forkJoinPool2 = new ForkJoinPool(16);
    private final ForkJoinPool forkJoinPool3 = new ForkJoinPool(16);
    private final ForkJoinPool forkJoinPool4 = new ForkJoinPool(16);
    private final ForkJoinPool forkJoinPool5 = new ForkJoinPool(16);
    private static final DecimalFormat df1 = new DecimalFormat("#,##0.00");

    private static final WxCpServiceImpl wxCpService4News;

    static {
        // API KEY作为一个字符串。
        basicHeaderMap.put("ACCESS-KEY", "bg_433d37306df0e8901c6d107c6d9e9111");
        // 使用base64编码签名（请参阅签名消息）。
        basicHeaderMap.put("ACCESS-SIGN", "");
        // 您请求的时间戳。
        basicHeaderMap.put("ACCESS-TIMESTAMP", "");
        // 您在创建API KEY时设置的口令。
        basicHeaderMap.put("ACCESS-PASSPHRASE", "7f934f62f2701bee932204580d115228");
        // 统一设置为application/json。
        basicHeaderMap.put("Content-Type", "application/json");
        // 支持多语言, 如：中文(zh-CN),英语(en-US)
        basicHeaderMap.put("locale", "zh-CN");

        // 字符串类型的APIKey
        basicHeaderMap4OKX.put("OK-ACCESS-KEY","25e4f515-5efd-4bb9-a934-3949b21d9f10");
        // 使用HMAC SHA256哈希函数获得哈希值，再使用Base-64编码（请参阅签名）
        basicHeaderMap4OKX.put("OK-ACCESS-SIGN","");
        // 发起请求的时间（UTC），如：2020-12-08T09:08:57.715Z
        basicHeaderMap4OKX.put("OK-ACCESS-TIMESTAMP","");
        // 您在创建API密钥时指定的Passphrase
        basicHeaderMap4OKX.put("OK-ACCESS-PASSPHRASE","tmvxeGY#Q#Y2qm8");
        // 统一设置为application/json
        basicHeaderMap4OKX.put("Content-Type", "application/json");

        df1.setRoundingMode(RoundingMode.HALF_UP);


        WxCpDefaultConfigImpl wxCpDefaultConfig = new WxCpDefaultConfigImpl();
        wxCpDefaultConfig.setCorpId("ww95a4adba56acb55f");
        wxCpDefaultConfig.setAgentId(1000004);
        wxCpDefaultConfig.setCorpSecret("hG50gbVZ8pXm3tSzY3BpwTzbrMmm6sTf8_bPfJG_6Yc");
        wxCpService4News = new WxCpServiceImpl();
        wxCpService4News.setWxCpConfigStorage(wxCpDefaultConfig);
    }

    @Override
    @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
    public void syncData(String startTime, String endTime, String pageSize) {
        // 获取全部历史委托
        Map<String, String> paramMap = new LinkedHashMap<>();
        paramMap.put("productType", "umcbl");
        paramMap.put("startTime", startTime);
        paramMap.put("endTime", endTime);
        paramMap.put("pageSize", pageSize);

        String signQueryString = paramMap.entrySet().stream().map(e -> e.getKey() + "=" + e.getValue()).collect(Collectors.joining("&"));

        JSONObject response = requestApi4Common("/api/mix/v1/order/historyProductType", signQueryString, null, JsoupUtil.HTTP_GET, paramMap);

        JSONArray orderList = response.getJSONObject("data").getJSONArray("orderList");
        if (orderList.size() > 0) {
            coinMapper.insertHistoryOrderList(JSONArray.parseArray(orderList.toJSONString(), CoinHistoryOrder.class));
            log.warn("syncData->insertHistoryOrderList，startTime={},endTime={},size={}", startTime, endTime, orderList.size());
        }
    }

    @Override
    public void syncData4TraderList() {
        StopWatch stopWatch = new StopWatch();
        stopWatch.start();

        // 获取交易员列表
        Map<String, String> paramMap = new LinkedHashMap<>();
        paramMap.put("sortRule", "composite");
        paramMap.put("sortFlag", "desc");
        paramMap.put("languageType", "en-US");
        paramMap.put("pageSize", "20");

        int i = 0;
        String url = "/api/mix/v1/trace/traderList";
        JSONObject response;
        int totalNum = 0;
        for (; ; ) {
            paramMap.put("pageNo", String.valueOf(++i));
            String signQueryString = paramMap.entrySet().stream().map(e -> e.getKey() + "=" + e.getValue()).collect(Collectors.joining("&"));
            response = requestApi4Common(url, signQueryString, null, JsoupUtil.HTTP_GET, paramMap);
            JSONArray dataList = response.getJSONArray("data");
            if (dataList.size() == 0) {
                break;
            }

            try {
                syncData4TraderListSub(dataList);
            } catch (Exception e) {
                log.error("syncData4TraderListSub error，paramMap={}", paramMap, e);
            }

            totalNum += dataList.size();
        }

        log.warn("syncData4TraderList 结束：time={},totalNum={}", stopWatch.getTotalTimeSeconds(), totalNum);
    }

    @Override
    @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
    public void syncData4TraderListSub(JSONArray dataList) {
        coinMapper.insertMixTradeList(parseMixTradeList(dataList));
    }

    private List<CoinTrader> parseMixTradeList(JSONArray dataList) {
        List<CoinTrader> mixTraderList = JSONArray.parseArray(dataList.toJSONString(), CoinTrader.class);
        mixTraderList.stream().forEach(e -> {
            Map<String, String> columnMap = e.getColumnList().stream().filter(Objects::nonNull)
                    .collect(Collectors.toMap(
                            object -> {
                                JSONObject item = (JSONObject) object;
                                return item.getString("describe");
                            },
                            object -> {
                                JSONObject item = (JSONObject) object;
                                return item.getString("value");
                            }
                    ));
            e.setRoi(columnMap.get("ROI"));
            e.setTotalProfit(columnMap.get("Total PnL").replace("$", "").replace(",", ""));
            e.setTotalFollowersProfit(columnMap.get("Total followers PnL").replace("$", "").replace(",", ""));
            e.setAum(columnMap.get("AUM").replace("$", "").replace(",", ""));
            e.setMaxCallbackRate(columnMap.get("Max drawdown"));
            e.setLast3wWinRate(columnMap.get("Last 3W win rate"));
            e.setAverageWinRate(StringUtils.isNotEmpty(e.getAverageWinRate()) ? new BigDecimal(e.getAverageWinRate()).setScale(2, RoundingMode.HALF_UP).toPlainString() : "0.00");
        });

        return mixTraderList;
    }

    @Override
    public String orderDetail(String trackingNo) {
        Map<String, String> paramMap = new LinkedHashMap<>();
        paramMap.put("traderId", "b1b5467f8bb73f53ac97");
        paramMap.put("pageSize", "20");

        StringBuffer sb = new StringBuffer();
        // 交易员当前带单列表筛选
        for (int j = 1; j < 5; j++) {
            try {
                paramMap.put("pageNo", j + "");
                JSONObject response = requestApi4Common("/api/mix/v1/trace/report/order/currentList", null, JSONObject.toJSONString(paramMap), JsoupUtil.HTTP_POST, paramMap);
                JSONArray orderList = response.getJSONArray("data");
                for (int i = 0; i < orderList.size(); i++) {
                    JSONObject order = orderList.getJSONObject(i);
                    String trackingNo1 = order.getString("trackingNo");
                    if (trackingNo.equals(trackingNo1)) {
                        sb.append("<table border=\"1\" cellspacing=\"0\"><tr><th>键</th><th>值</th></tr>");
                        sb.append("<tr><td>交易对</td><td>").append(order.getString("symbol")).append("</td></tr>");
                        sb.append("<tr><td>持仓方向</td><td>").append(InitRunner.publicParamsMap.get("holdSide").getString(order.getString("holdSide"))).append("</td></tr>");
                        sb.append("<tr><td>杠杆倍数</td><td>").append(order.getString("leverage")).append("</td></tr>");
                        sb.append("<tr><td>开仓均价</td><td>").append(order.getString("openPrice")).append("</td></tr>");
                        sb.append("<tr><td>开仓时间</td><td>").append(DateUtils.longToString(order.getLong("openTime"))).append("</td></tr>");
                        sb.append("<tr><td>此笔订单跟单人数</td><td>").append(order.getString("followerNum")).append("</td></tr>");
                        sb.append("<tr><td>保证金</td><td>").append(order.getString("marginAmount")).append("</td></tr>");
                        sb.append("<tr><td>止盈价</td><td>").append(order.getString("takeProfitPrice")).append("</td></tr>");
                        sb.append("<tr><td>止损价</td><td>").append(order.getString("stopLossPrice")).append("</td></tr>");
                        sb.append("<tr><td>交易员</td><td>").append("hale").append("</td></tr>");

                        sb.append("</table>");

                        break;
                    }
                }
            } catch (Exception e) {
            }
        }
        // 交易员历史带单列表筛选
        if (sb.length() == 0) {
            for (int j = 1; j < 5; j++) {
                try {
                    paramMap.put("pageNo", j + "");
                    JSONObject response = requestApi4Common("/api/mix/v1/trace/report/order/historyList", null, JSONObject.toJSONString(paramMap), JsoupUtil.HTTP_POST, paramMap);
                    JSONArray orderList = response.getJSONArray("data");
                    for (int i = 0; i < orderList.size(); i++) {
                        JSONObject order = orderList.getJSONObject(i);
                        String trackingNo1 = order.getString("trackingNo");
                        if (trackingNo.equals(trackingNo1)) {
                            sb.append("<table border=\"1\" cellspacing=\"0\" style=\"font-size: 20px;\"><tr><th>键</th><th>值</th></tr>");
                            sb.append("<tr><td>交易对</td><td>").append(order.getString("symbol")).append("</td></tr>");
                            sb.append("<tr><td>持仓方向</td><td>").append(InitRunner.publicParamsMap.get("holdSide").getString(order.getString("holdSide"))).append("</td></tr>");
                            sb.append("<tr><td>杠杆倍数</td><td>").append(order.getString("leverage")).append("</td></tr>");
                            sb.append("<tr><td>开仓均价</td><td>").append(order.getString("openPrice")).append("</td></tr>");
                            sb.append("<tr><td>开仓时间</td><td>").append(DateUtils.longToString(order.getLong("openTime"))).append("</td></tr>");
                            sb.append("<tr><td>此笔订单跟单人数</td><td>").append(order.getString("followerNum")).append("</td></tr>");
                            sb.append("<tr><td>保证金</td><td>").append(order.getString("marginAmount")).append("</td></tr>");
                            sb.append("<tr><td>平仓均价</td><td>").append(order.getString("closePrice")).append("</td></tr>");
                            sb.append("<tr><td>平仓时间</td><td>").append(DateUtils.longToString(order.getLong("closeTime"))).append("</td></tr>");
                            sb.append("<tr><td>平仓数量</td><td>").append(order.getString("closeAmount")).append("</td></tr>");
                            sb.append("<tr><td>交易员</td><td>").append("hale").append("</td></tr>");

                            sb.append("</table>");

                            break;
                        }
                    }
                } catch (Exception e) {
                }
            }
        }

        return sb.toString();
    }

    @Override
    public String orderDetail2(String orderId, String symbol) {
        Map<String, String> paramMap = new LinkedHashMap<>();
        paramMap.put("symbol", symbol);
        paramMap.put("orderId", orderId);

        StringBuffer sb = new StringBuffer("<table border=\"1\" cellspacing=\"0\" style=\"font-size: 20px;\"><tr><th>键</th><th>值</th></tr>");
        // 获取订单详情
        try {
            String signQueryString = paramMap.entrySet().stream().map(e -> e.getKey() + "=" + e.getValue()).collect(Collectors.joining("&"));
            JSONObject response = requestApi4Common("/api/mix/v1/order/detail", signQueryString, null, JsoupUtil.HTTP_GET, paramMap);
            JSONObject order = response.getJSONObject("data");

            sb.append("<tr><td>交易对</td><td>").append(order.getString("symbol")).append("</td></tr>");
            sb.append("<tr><td>交易方向</td><td>").append(InitRunner.publicParamsMap.get("side").getString(order.getString("side"))).append("</td></tr>");
            sb.append("<tr><td>杠杆倍数</td><td>").append(order.getString("leverage")).append("</td></tr>");
            sb.append("<tr><td>成交均价</td><td>").append(order.getString("priceAvg")).append("</td></tr>");
            sb.append("<tr><td>委托价格</td><td>").append(order.getString("price")).append("</td></tr>");
            sb.append("<tr><td>手续费</td><td>").append(order.getString("fee")).append("</td></tr>");
            sb.append("<tr><td>订单状态</td><td>").append(InitRunner.publicParamsMap.get("state").getString(order.getString("state"))).append("</td></tr>");
            sb.append("<tr><td>交易类型</td><td>").append(InitRunner.publicParamsMap.get("orderType").getString(order.getString("orderType"))).append("</td></tr>");
            sb.append("<tr><td>总盈亏</td><td>").append(order.getString("totalProfits")).append("</td></tr>");
            sb.append("<tr><td>预设止盈价格</td><td>").append(order.getString("presetTakeProfitPrice")).append("</td></tr>");
            sb.append("<tr><td>预设止损价格</td><td>").append(order.getString("presetStopLossPrice")).append("</td></tr>");
            sb.append("<tr><td>创建时间</td><td>").append(DateUtils.longToString(order.getLong("cTime"))).append("</td></tr>");
            sb.append("<tr><td>更新时间</td><td>").append(DateUtils.longToString(order.getLong("uTime"))).append("</td></tr>");
        } catch (Exception e) {
            log.error("orderDetail2 error，orderId={}，symbol={}", orderId, symbol, e);
        }

        sb.append("</table>");

        return sb.toString();
    }

    @Override
    public String monitorJob() {
        // BITGET开仓平仓监控报警
        scheduler.scheduleWithFixedDelay(() -> {
            LocalDateTime endTime = LocalDateTime.now();
            // 全部历史委托列表
            Map<String, String> paramMap = new LinkedHashMap<>();
            paramMap.put("productType", "umcbl");
            paramMap.put("startTime", String.valueOf(DateUtils.localDateTimeToMilliseconds(endTime.minusMinutes(1))));
            paramMap.put("endTime", String.valueOf(DateUtils.localDateTimeToMilliseconds(endTime)));
            paramMap.put("pageSize", "100");

            String signQueryString = paramMap.entrySet().stream().map(e -> e.getKey() + "=" + e.getValue()).collect(Collectors.joining("&"));
            try {
                JSONObject response = requestApi4Common("/api/mix/v1/order/historyProductType", signQueryString, null, JsoupUtil.HTTP_GET, paramMap);
                JSONArray orderList = response.getJSONObject("data").getJSONArray("orderList");

                for (int i = 0; i < orderList.size(); i++) {
                    JSONObject order = orderList.getJSONObject(i);
                    LocalDateTime cTime = DateUtils.longToLocalDateTime(order.getLong("cTime"));
                    String orderId = order.getString("orderId");
                    String symbol = order.getString("symbol");
                    if (Duration.between(cTime, endTime).getSeconds() < 50 && !orderMap.containsKey(orderId)) {
                        orderMap.put(orderId, "1");

                        String content = "<div class=\"highlight\">交易对：" + order.getString("symbol") + "</div>" +
                                "<div>交易方向：" + InitRunner.publicParamsMap.get("side").getString(order.getString("side")) + "</div>" +
                                "<div>杠杆倍数：" + order.getString("leverage") + "</div>" +
                                "<div>成交均价：" + order.getString("priceAvg") + "</div>" +
                                "<div>委托价格：" + order.getString("price") + "</div>" +
                                "<div>订单状态：" + InitRunner.publicParamsMap.get("state").getString(order.getString("state")) + "</div>" +
                                "<div>订单类型：" + InitRunner.publicParamsMap.get("orderType").getString(order.getString("orderType")) + "</div>" +
                                "<div class=\"gray\">订单时间：" + DateUtils.longToString(order.getLong("cTime")) + "</div>";
                        JSONObject params = new JSONObject();
                        params.put("title", (order.getString("side").contains("open") ? "BITGET合约开单" : "BITGET合约平单") + "报警");
                        params.put("logUrl", "https://jav.lvzhiqiang.top/coin/orderDetail2/" + orderId + "/" + symbol);
                        params.put("btnTxt", "订单详情");
                        SpringUtils.getBean(CoinServiceImpl.class).monitorAlarm4APP_TEXT_CARD(content, params, null);
                    }
                }
            } catch (Exception e) {
            }
        }, 0, 2, TimeUnit.SECONDS);

        // OKX开仓平仓监控报警
        scheduler.scheduleWithFixedDelay(() -> {
            LocalDateTime endTime = LocalDateTime.now();
            // 全部历史委托列表
            Map<String, String> paramMap = new LinkedHashMap<>();
            paramMap.put("productType", "umcbl");
            paramMap.put("startTime", String.valueOf(DateUtils.localDateTimeToMilliseconds(endTime.minusMinutes(1))));
            paramMap.put("endTime", String.valueOf(DateUtils.localDateTimeToMilliseconds(endTime)));
            paramMap.put("pageSize", "100");

            String signQueryString = paramMap.entrySet().stream().map(e -> e.getKey() + "=" + e.getValue()).collect(Collectors.joining("&"));
            try {
                JSONObject response = requestApi4Common("/api/mix/v1/order/historyProductType", signQueryString, null, JsoupUtil.HTTP_GET, paramMap);
                JSONArray orderList = response.getJSONObject("data").getJSONArray("orderList");

                for (int i = 0; i < orderList.size(); i++) {
                    JSONObject order = orderList.getJSONObject(i);
                    LocalDateTime cTime = DateUtils.longToLocalDateTime(order.getLong("cTime"));
                    String orderId = order.getString("orderId");
                    String symbol = order.getString("symbol");
                    if (Duration.between(cTime, endTime).getSeconds() < 50 && !orderMap.containsKey(orderId)) {
                        orderMap.put(orderId, "1");

                        String content = "<div class=\"highlight\">交易对：" + order.getString("symbol") + "</div>" +
                                "<div>交易方向：" + InitRunner.publicParamsMap.get("side").getString(order.getString("side")) + "</div>" +
                                "<div>杠杆倍数：" + order.getString("leverage") + "</div>" +
                                "<div>成交均价：" + order.getString("priceAvg") + "</div>" +
                                "<div>委托价格：" + order.getString("price") + "</div>" +
                                "<div>订单状态：" + InitRunner.publicParamsMap.get("state").getString(order.getString("state")) + "</div>" +
                                "<div>订单类型：" + InitRunner.publicParamsMap.get("orderType").getString(order.getString("orderType")) + "</div>" +
                                "<div class=\"gray\">订单时间：" + DateUtils.longToString(order.getLong("cTime")) + "</div>";
                        JSONObject params = new JSONObject();
                        params.put("title", (order.getString("side").contains("open") ? "BITGET合约开单" : "BITGET合约平单") + "报警");
                        params.put("logUrl", "https://jav.lvzhiqiang.top/coin/orderDetail2/" + orderId + "/" + symbol);
                        params.put("btnTxt", "订单详情");
                        SpringUtils.getBean(CoinServiceImpl.class).monitorAlarm4APP_TEXT_CARD(content, params, null);
                    }
                }
            } catch (Exception e) {
            }
        }, 0, 2, TimeUnit.SECONDS);

        scheduler.scheduleAtFixedRate(() -> {
            // BITGET全部合约仓位信息V2
            Map<String, String> paramMap = new HashMap<>();
            paramMap.put("productType", "umcbl");

            String signQueryString = paramMap.entrySet().stream().map(e -> e.getKey() + "=" + e.getValue()).collect(Collectors.joining("&"));
            try {
                JSONObject response = requestApi4Common("/api/mix/v1/position/allPosition-v2", signQueryString, null, JsoupUtil.HTTP_GET, paramMap);
                JSONArray mixList = response.getJSONArray("data");
                for (int i = 0; i < mixList.size(); i++) {
                    JSONObject mixData = mixList.getJSONObject(i);

                    String symbol = mixData.getString("symbol");
                    String margin = mixData.getString("margin");
                    String averageOpenPrice = mixData.getString("averageOpenPrice");
                    String key = symbol + margin + averageOpenPrice;

                    // 回报率=未实现盈亏/保证金

                    // 持仓方向 long：多头 short：空头
                    String holdSide = mixData.getString("holdSide");
                    BigDecimal returnRate = new BigDecimal(mixData.getString("unrealizedPL")).divide(new BigDecimal(margin), 4, RoundingMode.HALF_UP);
                    for (int j = 1; j <= 10; j++) {
                        BigDecimal grid = BigDecimal.valueOf(0.5).multiply(BigDecimal.valueOf(j));
                        if (returnRate.compareTo(grid) < 0) {
                            if (mixMap.containsKey(key)) {
                                mixMap.get(key).put("returnRate", returnRate);
                            } else {
                                JSONObject jsonObject = new JSONObject();
                                jsonObject.put("returnRate", returnRate);
                                mixMap.put(key, jsonObject);
                            }
                            break;
                        }

                        if (returnRate.compareTo(grid) > 0) {
                            if (mixMap.containsKey(key)) {
                                mixMap.get(key).put("returnRate", returnRate);
                                if (mixMap.get(key).containsKey(grid.toPlainString())) {
                                    continue;
                                } else {
                                    mixMap.get(key).put(grid.toPlainString(), true);

                                    String requestUrl = mainUrl + "/api/mix/v1/market/ticker?symbol=" + symbol;
                                    String last = "--";
                                    try {
                                        Connection.Response responseTicker = JsoupUtil.requestBody(requestUrl, JsoupUtil.HTTP_GET, InitRunner.proxy, null, null);
                                        last = JSONObject.parseObject(responseTicker.body()).getJSONObject("data").getString("last");
                                    } catch (Exception e) {
                                    }
                                    String content = "币对名称：" + symbol + "\n" +
                                            "持仓方向：" + InitRunner.publicParamsMap.get("holdSide").getString(mixData.getString("holdSide")) + "\n" +
                                            "杠杆倍数：" + mixData.getString("leverage") + "\n" +
                                            "开仓均价：" + mixData.getString("averageOpenPrice") + "\n" +
                                            "当前价格：" + last + "\n" +
                                            "回报率：" + returnRate.multiply(BigDecimal.valueOf(100)).setScale(2, RoundingMode.HALF_UP).toPlainString() + "，超过" + grid.multiply(BigDecimal.valueOf(100)).setScale(2, RoundingMode.HALF_UP).toPlainString();
                                    SpringUtils.getBean(CoinServiceImpl.class).monitorAlarm4CHAT_BOT(content, null);
                                }
                            } else {
                                JSONObject jsonObject = new JSONObject();
                                jsonObject.put("returnRate", returnRate);
                                jsonObject.put(grid.toPlainString(), true);
                                mixMap.put(key, jsonObject);

                                String requestUrl = mainUrl + "/api/mix/v1/market/ticker?symbol=" + symbol;
                                String last = "--";
                                try {
                                    Connection.Response responseTicker = JsoupUtil.requestBody(requestUrl, JsoupUtil.HTTP_GET, InitRunner.proxy, null, null);
                                    last = JSONObject.parseObject(responseTicker.body()).getJSONObject("data").getString("last");
                                } catch (Exception e) {
                                }
                                String content = "币对名称：" + symbol + "\n" +
                                        "持仓方向：" + InitRunner.publicParamsMap.get("holdSide").getString(mixData.getString("holdSide")) + "\n" +
                                        "杠杆倍数：" + mixData.getString("leverage") + "\n" +
                                        "开仓均价：" + mixData.getString("averageOpenPrice") + "\n" +
                                        "当前价格：" + last + "\n" +
                                        "回报率：" + returnRate.multiply(BigDecimal.valueOf(100)).setScale(2, RoundingMode.HALF_UP).toPlainString() + "，超过" + grid.multiply(BigDecimal.valueOf(100)).setScale(2, RoundingMode.HALF_UP).toPlainString();
                                SpringUtils.getBean(CoinServiceImpl.class).monitorAlarm4CHAT_BOT(content, null);

                                //break;
                            }
                        }
                    }
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }, 0, 5, TimeUnit.SECONDS);

        // BITGET跟单员监控报警
        scheduler.scheduleWithFixedDelay(() -> {
            List<String> monitorTraderList = coinMapper.findMonitorTraderList();
            forkJoinPool5.submit(() -> monitorTraderList.parallelStream().forEach(e -> {
                LocalDateTime endTime = LocalDateTime.now();
                // 交易员当前带单列表
                Map<String, String> paramMap = new LinkedHashMap<>();

                String[] split = e.split("\\|");

                paramMap.put("traderId", split[0]);
                paramMap.put("pageNo", "1");
                paramMap.put("pageSize", "20");

                try {
                    JSONObject response = requestApi4Common("/api/mix/v1/trace/report/order/currentList", null, JSONObject.toJSONString(paramMap), JsoupUtil.HTTP_POST, paramMap);
                    JSONArray orderList = response.getJSONArray("data");

                    for (int i = 0; i < orderList.size(); i++) {
                        JSONObject order = orderList.getJSONObject(i);
                        LocalDateTime openTime = DateUtils.longToLocalDateTime(order.getLong("openTime"));
                        String trackingNo = order.getString("trackingNo");
                        if (Duration.between(openTime, endTime).getSeconds() < 50 && !orderMap.containsKey(trackingNo)) {
                            orderMap.put(trackingNo, "1");

                            String content = "<div class=\"highlight\">交易对：" + order.getString("symbol") + "</div>" +
                                    "<div>持仓方向：" + InitRunner.publicParamsMap.get("holdSide").getString(order.getString("holdSide")) + "</div>" +
                                    "<div>杠杆倍数：" + order.getString("leverage") + "</div>" +
                                    "<div>开仓均价：" + order.getString("openPrice") + "</div>" +
                                    "<div>止盈价：" + order.getString("takeProfitPrice") + "</div>" +
                                    "<div>止损价：" + order.getString("stopLossPrice") + "</div>" +
                                    "<div >交易员：" + split[1] + "</div>" +
                                    "<div class=\"gray\">开仓时间：" + DateUtils.longToString(order.getLong("openTime")) + "</div>";
                            JSONObject params = new JSONObject();
                            params.put("title", "BITGET交易员开单报警");
                            params.put("logUrl", "https://jav.lvzhiqiang.top/coin/orderDetail/" + order.getString("trackingNo"));
                            params.put("btnTxt", "跟单详情");
                            SpringUtils.getBean(CoinServiceImpl.class).monitorAlarm4APP_TEXT_CARD(content, params, null);
                        }
                    }
                } catch (Exception ex) {
                }
            })).join();
        }, 0, 3, TimeUnit.SECONDS);

        // 星球日报新闻快讯监控报警
        scheduler.scheduleWithFixedDelay(() -> {
            try {
                Connection.Response response = JsoupUtil.requestBody("https://www.odaily.news/v1/openapi/feeds", JsoupUtil.HTTP_GET, InitRunner.proxy, null, null);
                JSONObject result = JSONObject.parseObject(response.body());
                JSONArray newsList = result.getJSONObject("data").getJSONArray("arr_news");

                LocalDateTime endTime = LocalDateTime.now();
                for (int i = 0; i < newsList.size(); i++) {
                    if (i == 5) {
                        break;
                    }

                    JSONObject news = newsList.getJSONObject(i);
                    String id = "Odaily" + news.getString("id");
                    String publishedAt = news.getString("published_at");
                    LocalDateTime publishedAtTime = DateUtils.stringToLocalDateTime(publishedAt);
                    if (Duration.between(publishedAtTime, endTime).getSeconds() < 20 && !orderMap.containsKey(id)) {
                        orderMap.put(id, "1");

                        String type = news.getString("type");
                        String title = news.getString("title");
                        String link = news.getString("link");

                        String content = "";
                        JSONObject params = new JSONObject();
                        params.put("title", "Odaily监控报警");
                        params.put("btnTxt", "新闻详情");
                        params.put("logUrl", link);
                        params.put("user", "@all");
                        params.put("agentId", 1000004);

                        if ("newsflashes".equals(type)) {
                            String newsUrl = news.getString("news_url");
                            content = "<div class=\"highlight\">标题：" + title + "</div>" +
                                    "<div>类型：" + "新闻快讯" + "</div>" +
                                    "<div>发布时间：" + publishedAt + "</div>" +
                                    "<div class=\"gray\">描述：" + news.getString("description").replace("\n", "&nbsp;&nbsp;&nbsp;&nbsp;") + "</div>";
                        } else if ("posts".equals(type)) {
                            content = "<div class=\"highlight\">标题：" + title + "</div>" +
                                    "<div>类型：" + "帖子" + "</div>" +
                                    "<div>发布时间：" + publishedAt + "</div>" +
                                    "<div class=\"gray\">描述：" + news.getString("summary").replace("\n", "&nbsp;&nbsp;&nbsp;&nbsp;") + "</div>";
                        }

                        SpringUtils.getBean(CoinServiceImpl.class).monitorAlarm4APP_TEXT_CARD(content, params, wxCpService4News);
                    }
                }
            } catch (Exception e) {
            }
        }, 0, 3, TimeUnit.SECONDS);

        // 律动日报新闻快讯监控报警
        scheduler.scheduleWithFixedDelay(() -> {
            try {
                Map<String, String> paramMap = new HashMap<>();
                paramMap.put("size", "10");
                paramMap.put("page", "1");
                Connection.Response response = JsoupUtil.requestBody("https://api.theblockbeats.news/v1/open-api/open-flash", JsoupUtil.HTTP_GET, InitRunner.proxy, null, paramMap);
                JSONObject result = JSONObject.parseObject(response.body());
                JSONArray newsList = result.getJSONObject("data").getJSONArray("data");

                LocalDateTime endTime = LocalDateTime.now();
                for (int i = 0; i < newsList.size(); i++) {
                    if (i == 5) {
                        break;
                    }

                    JSONObject news = newsList.getJSONObject(i);
                    String id = "BlockBeats" + news.getString("id");
                    String createTime = news.getString("create_time");
                    LocalDateTime createTimeTime = DateUtils.longToLocalDateTime_(Long.valueOf(createTime));
                    createTime = DateUtils.localDateTimeToString(createTimeTime);
                    if (Duration.between(createTimeTime, endTime).getSeconds() < 20 && !orderMap.containsKey(id)) {
                        orderMap.put(id, "1");

                        String title = news.getString("title");
                        String content = news.getString("content");
                        String pic = news.getString("pic");
                        String link = news.getString("link");
                        String url = news.getString("url");

                        JSONObject params = new JSONObject();
                        params.put("title", "BlockBeats监控报警");
                        params.put("btnTxt", "新闻详情");
                        params.put("logUrl", link);
                        params.put("user", "@all");
                        params.put("agentId", 1000004);
                        if (StringUtils.isEmpty(pic)) {
                            // 文本卡片
                            String contentStr = "<div class=\"highlight\">标题：" + title + "</div>" +
                                    "<div>类型：" + "新闻快讯" + "</div>" +
                                    "<div>发布时间：" + createTime + "</div>" +
                                    "<div class=\"gray\">描述：" + content.replace("\n", "&nbsp;&nbsp;&nbsp;&nbsp;") + "</div>";
                            SpringUtils.getBean(CoinServiceImpl.class).monitorAlarm4APP_TEXT_CARD(contentStr, params, wxCpService4News);
                        } else {
                            // 图文
                            NewArticle article1 = new NewArticle();
                            article1.setUrl(link);
                            article1.setPicUrl(pic);
                            article1.setDescription(content);
                            article1.setTitle(title);

                            SpringUtils.getBean(CoinServiceImpl.class).monitorAlarm4NEWS(params, wxCpService4News, article1);
                        }
                    }
                }
            } catch (Exception e) {
            }
        }, 0, 3, TimeUnit.SECONDS);

        return null;
    }

    @Override
    @Async("coinTaskExecutor")
    public void monitorAlarm4APP_TEXT_CARD(String content, JSONObject params, WxCpService wxCpServiceFinal) {
        // 文本卡片模式发消息
        String title = "监控告警明细";
        if (params.containsKey("title")) {
            title = params.getString("title");
        }
        String logUrl = "https://lvzhiqiang.top";
        if (params.containsKey("logUrl")) {
            logUrl = params.getString("logUrl");
        }
        String btnTxt = "日志详情";
        if (params.containsKey("btnTxt")) {
            btnTxt = params.getString("btnTxt");
        }
        String user = "LvZhiQiang";
        if (params.containsKey("user")) {
            user = params.getString("user");
        }
        String party = "";
        if (params.containsKey("party")) {
            party = params.getString("party");
        }
        String tag = "";
        if (params.containsKey("tag")) {
            tag = params.getString("tag");
        }

        Integer agentId = properties.getAgentId();
        if (params.containsKey("agentId")) {
            agentId = params.getInteger("agentId");
        }

        if (wxCpServiceFinal == null) {
            wxCpServiceFinal = wxCpService;
        }

        WxCpMessage wxCpMessage = WxCpMessage.TEXTCARD().agentId(agentId)
                .toUser(user)
                .toParty(party)
                .toTag(tag)
                .title(title).description(content)
                .url(logUrl).btnTxt(btnTxt)
                .build();
        try {
            log.info("企业微信推送消息，send message: {}", wxCpMessage);
            WxCpMessageSendResult sendResult = wxCpServiceFinal.getMessageService().send(wxCpMessage);
            log.info("企业微信推送消息成功，send result: {}", sendResult);
        } catch (WxErrorException e) {
            log.error("企业微信推送消息失败！Detail: ", e);
        }
    }

    @Override
    @Async("coinTaskExecutor")
    public void monitorAlarm4NEWS(JSONObject params, WxCpService wxCpServiceFinal, NewArticle... articles) {
        // 图文消息
        String title = "监控告警明细";
        if (params.containsKey("title")) {
            title = params.getString("title");
        }
        String logUrl = "https://lvzhiqiang.top";
        if (params.containsKey("logUrl")) {
            logUrl = params.getString("logUrl");
        }
        String btnTxt = "日志详情";
        if (params.containsKey("btnTxt")) {
            btnTxt = params.getString("btnTxt");
        }
        String user = "LvZhiQiang";
        if (params.containsKey("user")) {
            user = params.getString("user");
        }
        String party = "";
        if (params.containsKey("party")) {
            party = params.getString("party");
        }
        String tag = "";
        if (params.containsKey("tag")) {
            tag = params.getString("tag");
        }

        Integer agentId = properties.getAgentId();
        if (params.containsKey("agentId")) {
            agentId = params.getInteger("agentId");
        }

        if (wxCpServiceFinal == null) {
            wxCpServiceFinal = wxCpService;
        }

        WxCpMessage wxCpMessage = WxCpMessage.NEWS().agentId(agentId)
                .toUser(user)
                .toParty(party)
                .toTag(tag)
                .addArticle(articles)
                .build();
        try {
            log.info("企业微信推送消息，send message: {}", wxCpMessage);
            WxCpMessageSendResult sendResult = wxCpServiceFinal.getMessageService().send(wxCpMessage);
            log.info("企业微信推送消息成功，send result: {}", sendResult);
        } catch (WxErrorException e) {
            log.error("企业微信推送消息失败！Detail: ", e);
        }
    }

    @Override
    @Async("coinTaskExecutor")
    public void monitorAlarm4CHAT_BOT(String content, JSONObject params) {
        // 调用企业微信群聊机器人发消息
        WxCpGroupRobotService groupRobotService = wxCpService.getGroupRobotService();
        String webhookUrl = "https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=082970da-2a33-422a-81f6-15f9bde87940";

        List<String> userList = Collections.singletonList("LvZhiQiang");
        if (params != null && params.containsKey("user")) {
            userList = Arrays.asList(params.getString("user").split("[|,]"));
        }
        try {
            log.info("企业微信推送消息，send content: {}, userIdSet: {}", content, userList);
            groupRobotService.sendText(webhookUrl, content, userList, Collections.emptyList());
            log.info("企业微信推送消息成功");
        } catch (WxErrorException e) {
            log.error("企业微信推送消息失败！Detail: ", e);
        }
    }

    @Override
    @Async("coinTaskExecutor")
    public void monitorAlarm(String content, String jobAlarmMode) {
        // 判断告警模式
        if (StringUtils.isEmpty(JOB_ALARM_MODE)) {
            jobAlarmMode = JOB_ALARM_MODE;
        }

        // 文本卡片模式发消息
        if (JOB_ALARM_MODE_APP_TEXT_CARD.equals(jobAlarmMode)) {
            String title = "监控告警明细";
            String logUrl = "https://lvzhiqiang.top";
            String btnTxt = "日志详情";

            WxCpMessage wxCpMessage = WxCpMessage.TEXTCARD().agentId(properties.getAgentId())
                    .toUser("LvZhiQiang")
                    .toParty("")
                    .toTag("")
                    .title(title).description(content)
                    .url(logUrl).btnTxt(btnTxt)
                    .build();
            try {
                log.info("企业微信推送消息，send message: {}", wxCpMessage);
                WxCpMessageSendResult sendResult = wxCpService.getMessageService().send(wxCpMessage);
                log.info("企业微信推送消息成功，send result: {}", sendResult);
            } catch (WxErrorException e) {
                log.error("企业微信推送消息失败！Detail: ", e);
            }
        }
        // 调用企业微信群聊机器人发消息
        if (JOB_ALARM_MODE_CHAT_BOT.equals(jobAlarmMode)) {
            WxCpGroupRobotService groupRobotService = wxCpService.getGroupRobotService();
            String webhookUrl = "https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=082970da-2a33-422a-81f6-15f9bde87940";
            try {
                log.info("企业微信推送消息，send content: {}, userIdSet: {}", content, "LvZhiQiang");
                groupRobotService.sendText(webhookUrl, content, Collections.singletonList("LvZhiQiang"), Collections.emptyList());
                log.info("企业微信推送消息成功");
            } catch (WxErrorException e) {
                log.error("企业微信推送消息失败！Detail: ", e);
            }
        }
    }

    /**
     * 请求通用API方法
     */
    private JSONObject requestApi4Common(String requestPath, String signQueryString, String signBody, String httpMethod, Map<String, String> paramMap) {
        String timestamp = String.valueOf(System.currentTimeMillis());

        Map<String, String> headerMap = new HashMap<>();
        headerMap.putAll(basicHeaderMap);
        try {
            String accessSign = CheckSign4Bitget.generate(timestamp, httpMethod, requestPath, signQueryString, signBody, secretKey);
            headerMap.put("ACCESS-TIMESTAMP", timestamp);
            headerMap.put("ACCESS-SIGN", accessSign);
        } catch (CloneNotSupportedException e) {
            throw new RuntimeException(e);
        } catch (InvalidKeyException e) {
            throw new RuntimeException(e);
        } catch (UnsupportedEncodingException e) {
            throw new RuntimeException(e);
        }

        try {
            String requestUrl = mainUrl + requestPath;

            if (httpMethod.equals(JsoupUtil.HTTP_GET)) {
                Connection.Response response = JsoupUtil.requestBody(requestUrl, httpMethod, InitRunner.proxy, headerMap, paramMap);
                return JSONObject.parseObject(response.body());
            } else {
                Connection.Response response = JsoupUtil.requestBodyJSON(requestUrl, httpMethod, InitRunner.proxy, null, headerMap, paramMap);
                return JSONObject.parseObject(response.body());
            }
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    private JSONObject requestApi4Common4OKX(String requestPath, String signQueryString, String signBody, String httpMethod, Map<String, String> paramMap) {
        String timestamp = String.valueOf(System.currentTimeMillis());

        Map<String, String> headerMap = new HashMap<>();
        headerMap.putAll(basicHeaderMap4OKX);
        try {
            String accessSign = CheckSign4Bitget.generate(timestamp, httpMethod, requestPath, signQueryString, signBody, secretKey4OKX);
            headerMap.put("ACCESS-TIMESTAMP", timestamp);
            headerMap.put("ACCESS-SIGN", accessSign);
        } catch (CloneNotSupportedException e) {
            throw new RuntimeException(e);
        } catch (InvalidKeyException e) {
            throw new RuntimeException(e);
        } catch (UnsupportedEncodingException e) {
            throw new RuntimeException(e);
        }

        try {
            String requestUrl = mainUrl + requestPath;

            if (httpMethod.equals(JsoupUtil.HTTP_GET)) {
                Connection.Response response = JsoupUtil.requestBody(requestUrl, httpMethod, InitRunner.proxy, headerMap, paramMap);
                return JSONObject.parseObject(response.body());
            } else {
                Connection.Response response = JsoupUtil.requestBodyJSON(requestUrl, httpMethod, InitRunner.proxy, null, headerMap, paramMap);
                return JSONObject.parseObject(response.body());
            }
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    @Override
    public Object mainSearch(JSONObject params) throws Exception {
        JSONArray result = new JSONArray();
        if (params.getString("nameEn").equals("allPositionv2")) {
            Map<String, String> paramMap = new HashMap<>();
            paramMap.put("productType", "umcbl");

            String signQueryString = paramMap.entrySet().stream().map(e -> e.getKey() + "=" + e.getValue()).collect(Collectors.joining("&"));

            JSONObject response = requestApi4Common(params.getString("url"), signQueryString, null, JsoupUtil.HTTP_GET, paramMap);

            result = response.getJSONArray("data");

            renderMainSearch4AllPositionv2(result, params.getInteger("unrealizedPLSort"));
        } else if (params.getString("nameEn").equals("orderMarginCoinCurrent")) {
            Map<String, String> paramMap = new LinkedHashMap<>();
            paramMap.put("productType", "umcbl");
            paramMap.put("marginCoin", "USDT");

            String signQueryString = paramMap.entrySet().stream().map(e -> e.getKey() + "=" + e.getValue()).collect(Collectors.joining("&"));

            JSONObject response = requestApi4Common(params.getString("url"), signQueryString, null, JsoupUtil.HTTP_GET, paramMap);

            result = response.getJSONArray("data");

            renderMainSearch4OrderMarginCoinCurrent(result, params.getInteger("chaRateSort"));
        } else if (params.getString("nameEn").equals("orderHistoryProductType")) {
            PageHelper.startPage(params.getInteger("pageNo"), params.getInteger("pageSize"), true);
            List<CoinHistoryOrder> historyOrderList = coinMapper.findHistoryOrderList(params.toJavaObject(Map.class));

            PageInfo<CoinHistoryOrder> historyOrderPageInfo = new PageInfo<>(historyOrderList);

            renderMainSearch4OrderHistoryProductType(historyOrderList);
            //result = (JSONArray) JSON.toJSON(historyOrderList);
            return historyOrderPageInfo;
        } else if (params.getString("nameEn").equals("traderList")) {
            PageHelper.startPage(params.getInteger("pageNo"), params.getInteger("pageSize"), true);
            List<CoinTrader> mixTraderList = coinMapper.findMixTraderList(params.toJavaObject(Map.class));

            PageInfo<CoinTrader> coinTraderPageInfo = new PageInfo<>(mixTraderList);

            renderMainSearch4TraderList(mixTraderList);
            //result = (JSONArray) JSON.toJSON(mixTraderList);
            return coinTraderPageInfo;
        } else if (params.getString("nameEn").equals("monitorCurrency")) {
            List<CoinMonitorCurrency> monitorCurrencyList = coinMapper.findMonitorCurrencyList();

            String requestUrl = mainUrl + params.getString("url");
            Connection.Response response = JsoupUtil.requestBody(requestUrl, JsoupUtil.HTTP_GET, InitRunner.proxy, null, null);
            result = JSONObject.parseObject(response.body()).getJSONArray("data");

            result = renderMainSearch4MonitorCurrency(result, monitorCurrencyList, params.getInteger("changeUtcSort"));
        } else if (params.getString("nameEn").equals("currentPlan")) {
            Map<String, String> paramMap = new LinkedHashMap<>();
            paramMap.put("productType", "umcbl");
            paramMap.put("isPlan", "plan");

            String signQueryString = paramMap.entrySet().stream().map(e -> e.getKey() + "=" + e.getValue()).collect(Collectors.joining("&"));


            JSONObject response = requestApi4Common(params.getString("url"), signQueryString, null, JsoupUtil.HTTP_GET, paramMap);

            result = response.getJSONArray("data");

            renderMainSearch4CurrentPlan(result, params.getInteger("chaRateSort"));
        }

        return result;
    }

    private void renderMainSearch4TraderList(List<CoinTrader> mixTraderList) {
        for (CoinTrader mixTrader : mixTraderList) {

            mixTrader.setLastTradeTime(DateUtils.longToString(Long.valueOf(mixTrader.getLastTradeTime())));
        }
    }

    /**
     * 渲染获取当前计划委托(止盈止损)列表
     *
     * @param result
     */
    private void renderMainSearch4CurrentPlan(JSONArray result, Integer chaRateSort) {
        forkJoinPool3.submit(() -> result.parallelStream().forEach(e -> {
            JSONObject jsonObject = (JSONObject) e;

            // 币对名称
            String symbol = jsonObject.getString("symbol");
            jsonObject.put("symbol", "<strong style=\"background-color:#F1B90d;\"><font color=\"#242A30\">" + symbol.replace("USDT_UMCBL", "") + "</font></strong>USDT_UMCBL");
            // 订单状态
            jsonObject.put("status", InitRunner.publicParamsMap.get("status").getString(jsonObject.getString("status")));
            // 交易类型
            jsonObject.put("orderType", InitRunner.publicParamsMap.get("orderType").getString(jsonObject.getString("orderType")));
            // 订单类型
            jsonObject.put("planType", InitRunner.publicParamsMap.get("planType").getString(jsonObject.getString("planType")));
            // 开单方向
            String side = jsonObject.getString("side");
            jsonObject.put("side", InitRunner.publicParamsMap.get("side").getString(side));
            if (side.equals("open_long")) {
                jsonObject.put("sideStyle", " style=\"color:#FFFFFF;background-color:#1DA2B4;\"");
            } else if (side.equals("open_short")) {
                jsonObject.put("sideStyle", " style=\"color:#FFFFFF;background-color:#F1493F;\"");
            } else {
                jsonObject.put("sideStyle", " style=\"color:#FFFFFF;background-color:#F0F0F0;\"");
            }
            // 触发类型
            jsonObject.put("triggerType", InitRunner.publicParamsMap.get("triggerType").getString(jsonObject.getString("triggerType")));

            jsonObject.put("cTime", DateUtils.longToString(jsonObject.getLong("cTime")));
            jsonObject.put("uTime", StringUtils.isEmpty(jsonObject.getString("uTime")) ? "--" : DateUtils.longToString(jsonObject.getLong("uTime")));

            // 获取合约标记价格
            String requestUrl = mainUrl + "/api/mix/v1/market/mark-price?symbol=" + symbol;
            try {
                Connection.Response response = JsoupUtil.requestBody(requestUrl, JsoupUtil.HTTP_GET, InitRunner.proxy, null, null);
                String markPrice = JSONObject.parseObject(response.body()).getJSONObject("data").getString("markPrice");

                BigDecimal chaRate = BigDecimal.ZERO;
                if ("open_long".equals(side)) {
                    chaRate = new BigDecimal(markPrice).divide(new BigDecimal(jsonObject.getString("triggerPrice")), 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)).setScale(2, RoundingMode.HALF_UP);
                } else if ("open_short".equals(side)) {
                    chaRate = new BigDecimal(jsonObject.getString("triggerPrice")).divide(new BigDecimal(markPrice), 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)).setScale(2, RoundingMode.HALF_UP);
                }

                jsonObject.put("markPrice", markPrice);
                jsonObject.put("markPriceStyle", " style=\"color:#252B31;background-color:#C4ADE9;font-weight:bold;\"");
                jsonObject.put("chaRate", chaRate);
                jsonObject.put("chaRateStyle", " style=\"color:#FFFFFF;background-color:#5EA294;\"");
            } catch (Exception ex) {
                throw new RuntimeException(ex);
            }
        })).join();

        if (chaRateSort != 0) {
            Collections.sort(result, (o1, o2) -> chaRateSort * (((JSONObject) o1).getBigDecimal("chaRate").compareTo(((JSONObject) o2).getBigDecimal("chaRate"))));
        }
    }

    /**
     * 渲染获取监控币种列表
     *
     * @param monitorCurrencyList
     */
    private JSONArray renderMainSearch4MonitorCurrency(JSONArray result, List<CoinMonitorCurrency> monitorCurrencyList, Integer changeUtcSort) {
        Map<String, CoinMonitorCurrency> monitorCurrencyMap = monitorCurrencyList.stream().collect(Collectors.toMap(CoinMonitorCurrency::getSymbol, Function.identity(), (key1, key2) -> key1));
        Set<String> symbolSet = monitorCurrencyMap.keySet();

        JSONArray array = result.stream()
                .filter(iter -> symbolSet.contains(((JSONObject) iter).getString("symbol")))
                .collect(Collectors.toCollection(JSONArray::new));

        forkJoinPool.submit(() -> array.parallelStream().forEach(e -> {
            JSONObject jsonObject = (JSONObject) e;
            jsonObject.put("changeUtc", jsonObject.getBigDecimal("changeUtc").multiply(BigDecimal.valueOf(100)).setScale(2, RoundingMode.HALF_UP));
            jsonObject.put("change", jsonObject.getBigDecimal("change").multiply(BigDecimal.valueOf(100)).setScale(2, RoundingMode.HALF_UP));
            jsonObject.put("ts", DateUtils.longToString(jsonObject.getLong("ts")));

            jsonObject.put("category", monitorCurrencyMap.get(jsonObject.getString("symbol")).getCategory());

            // UTC0时涨跌幅
            if (jsonObject.getBigDecimal("changeUtc").compareTo(BigDecimal.ZERO) < 0) {
                jsonObject.put("changeUtcStyle", " style=\"color:#FFFFFF;background-color:#F1493F;\"");
            } else {
                jsonObject.put("changeUtcStyle", " style=\"color:#FFFFFF;background-color:#1DA2B4;\"");
            }
            // 24小时涨跌幅
            if (jsonObject.getBigDecimal("change").compareTo(BigDecimal.ZERO) < 0) {
                jsonObject.put("changeStyle", " style=\"color:#FFFFFF;background-color:#F1493F;\"");
            } else {
                jsonObject.put("changeStyle", " style=\"color:#FFFFFF;background-color:#1DA2B4;\"");
            }
            // 币对名称
            String symbol = jsonObject.getString("symbol").replace("USDT", "");
            jsonObject.put("symbol", "<strong style=\"background-color:#F1B90d;\"><font color=\"#242A30\">" + symbol + "</font></strong>USDT");
            // 标记价格
            jsonObject.put("closeStyle", " style=\"color:#252B31;background-color:#C4ADE9;font-weight:bold;\"");
            // 基础币量 计价币量 usdt币量
            jsonObject.put("baseVol", readableFileSize(jsonObject.getDouble("baseVol")));
            jsonObject.put("quoteVol", readableFileSize(jsonObject.getDouble("quoteVol")));
            jsonObject.put("usdtVol", readableFileSize(jsonObject.getDouble("usdtVol")));
        })).join();

        if (changeUtcSort != 0) {
            Collections.sort(array, (o1, o2) -> changeUtcSort * (((JSONObject) o1).getBigDecimal("changeUtc").compareTo(((JSONObject) o2).getBigDecimal("changeUtc"))));
        }

        return array;
    }

    /**
     * 渲染获取全部历史委托
     *
     * @param historyOrderList
     */
    private void renderMainSearch4OrderHistoryProductType(List<CoinHistoryOrder> historyOrderList) {
        for (CoinHistoryOrder coinHistoryOrder : historyOrderList) {
            // 币种名称
            coinHistoryOrder.setSymbol(coinHistoryOrder.getSymbol().replace("USDT_UMCBL", ""));
            // 订单状态
            coinHistoryOrder.setState(InitRunner.publicParamsMap.get("state").getString(coinHistoryOrder.getState()));
            // 开单方向
            coinHistoryOrder.setSide(InitRunner.publicParamsMap.get("side").getString(coinHistoryOrder.getSide()));
            // 总盈亏
            String TotalProfits = "0E-8";
            if (!coinHistoryOrder.getTotalProfits().contains("0E-8")) {
                TotalProfits = new BigDecimal(coinHistoryOrder.getTotalProfits()).setScale(2, RoundingMode.HALF_UP).toPlainString();
            }
            coinHistoryOrder.setTotalProfits(TotalProfits);
            // 手续费
            String fee = "0E-8";
            if (!coinHistoryOrder.getFee().contains("0E-8")) {
                fee = new BigDecimal(coinHistoryOrder.getFee()).setScale(2, RoundingMode.HALF_UP).toPlainString();
            }
            coinHistoryOrder.setFee(fee);
            // 持仓方向
            coinHistoryOrder.setPosSide(InitRunner.publicParamsMap.get("posSide").getString(coinHistoryOrder.getPosSide()));
            // 仓位模式
            coinHistoryOrder.setMarginMode(InitRunner.publicParamsMap.get("marginMode").getString(coinHistoryOrder.getMarginMode()));
            // 交易类型
            coinHistoryOrder.setOrderType(InitRunner.publicParamsMap.get("orderType").getString(coinHistoryOrder.getOrderType()));
            // 交易方向
            coinHistoryOrder.setTradeSide(InitRunner.publicParamsMap.get("tradeSide").getString(coinHistoryOrder.getTradeSide()));
            // 持仓模式
            coinHistoryOrder.setHoldMode(InitRunner.publicParamsMap.get("holdMode").getString(coinHistoryOrder.getHoldMode()));
            // orderSource
            coinHistoryOrder.setOrderSource(InitRunner.publicParamsMap.get("orderSource").getString(coinHistoryOrder.getOrderSource()));

            coinHistoryOrder.setCTime(DateUtils.longToString(Long.valueOf(coinHistoryOrder.getCTime())));
            coinHistoryOrder.setUTime(DateUtils.longToString(Long.valueOf(coinHistoryOrder.getUTime())));
        }
    }

    /**
     * 渲染获取全部当前委托
     *
     * @param result
     */
    private void renderMainSearch4OrderMarginCoinCurrent(JSONArray result, Integer chaRateSort) {
        forkJoinPool2.submit(() -> result.parallelStream().forEach(e -> {
            JSONObject jsonObject = (JSONObject) e;
            // 币对名称
            String symbol = jsonObject.getString("symbol");
            jsonObject.put("symbol", "<strong style=\"background-color:#F1B90d;\"><font color=\"#242A30\">" + symbol.replace("USDT_UMCBL", "") + "</font></strong>USDT_UMCBL");
            // 订单状态
            jsonObject.put("state", InitRunner.publicParamsMap.get("state").getString(jsonObject.getString("state")));
            // 开单方向
            String side = jsonObject.getString("side");
            jsonObject.put("side", InitRunner.publicParamsMap.get("side").getString(side));
            if (side.equals("open_long")) {
                jsonObject.put("sideStyle", " style=\"color:#FFFFFF;background-color:#1DA2B4;\"");
            } else if (side.equals("open_short")) {
                jsonObject.put("sideStyle", " style=\"color:#FFFFFF;background-color:#F1493F;\"");
            } else {
                jsonObject.put("sideStyle", " style=\"color:#FFFFFF;background-color:#F0F0F0;\"");
            }
            // 交易类型
            jsonObject.put("orderType", InitRunner.publicParamsMap.get("orderType").getString(jsonObject.getString("orderType")));
            // 止盈止损
            jsonObject.put("presetTakeProfitPrice", StringUtils.isEmpty(jsonObject.getString("presetTakeProfitPrice")) ? "--" : jsonObject.getString("presetTakeProfitPrice"));
            jsonObject.put("presetStopLossPrice", StringUtils.isEmpty(jsonObject.getString("presetTakeProfitPrice")) ? "--" : jsonObject.getString("presetTakeProfitPrice"));
            // 持仓模式
            jsonObject.put("holdMode", InitRunner.publicParamsMap.get("holdMode").getString(jsonObject.getString("holdMode")));
            // orderSource
            jsonObject.put("orderSource", InitRunner.publicParamsMap.get("orderSource").getString(jsonObject.getString("orderSource")));
            // 仓位模式
            jsonObject.put("marginMode", InitRunner.publicParamsMap.get("marginMode").getString(jsonObject.getString("marginMode")));

            jsonObject.put("cTime", DateUtils.longToString(jsonObject.getLong("cTime")));
            jsonObject.put("uTime", DateUtils.longToString(jsonObject.getLong("uTime")));

            // 获取合约标记价格
            String requestUrl = mainUrl + "/api/mix/v1/market/mark-price?symbol=" + symbol;
            try {
                Connection.Response response = JsoupUtil.requestBody(requestUrl, JsoupUtil.HTTP_GET, InitRunner.proxy, null, null);
                String markPrice = JSONObject.parseObject(response.body()).getJSONObject("data").getString("markPrice");

                BigDecimal chaRate = BigDecimal.ZERO;
                if ("open_short".equals(side)) {
                    chaRate = new BigDecimal(markPrice).divide(new BigDecimal(jsonObject.getString("price")), 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)).setScale(2, RoundingMode.HALF_UP);
                } else if ("open_long".equals(side)) {
                    chaRate = new BigDecimal(jsonObject.getString("price")).divide(new BigDecimal(markPrice), 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)).setScale(2, RoundingMode.HALF_UP);
                }

                jsonObject.put("markPrice", markPrice);
                jsonObject.put("markPriceStyle", " style=\"color:#252B31;background-color:#C4ADE9;font-weight:bold;\"");
                jsonObject.put("chaRate", chaRate);
                jsonObject.put("chaRateStyle", " style=\"color:#FFFFFF;background-color:#5EA294;\"");
            } catch (Exception ex) {
                throw new RuntimeException(ex);
            }
        })).join();

        if (chaRateSort != 0) {
            Collections.sort(result, (o1, o2) -> chaRateSort * (((JSONObject) o1).getBigDecimal("chaRate").compareTo(((JSONObject) o2).getBigDecimal("chaRate"))));
        }
    }

    /**
     * 渲染获取全部合约仓位信息V2
     *
     * @param result
     */
    private void renderMainSearch4AllPositionv2(JSONArray result, Integer unrealizedPLSort) {
        forkJoinPool4.submit(() -> result.parallelStream().forEach(e -> {
            JSONObject jsonObject = (JSONObject) e;

            // 币对名称
            String symbol = jsonObject.getString("symbol");
            jsonObject.put("symbol", "<strong style=\"background-color:#F1B90d;\"><font color=\"#242A30\">" + symbol.replace("USDT_UMCBL", "") + "</font></strong>USDT_UMCBL");

            // 持仓方向
            String holdSide = jsonObject.getString("holdSide");
            jsonObject.put("holdSide", InitRunner.publicParamsMap.get("holdSide").getString(holdSide));
            if (holdSide.equals("long")) {
                jsonObject.put("holdSideStyle", " style=\"color:#FFFFFF;background-color:#1DA2B4;\"");
            } else if (holdSide.equals("short")) {
                jsonObject.put("holdSideStyle", " style=\"color:#FFFFFF;background-color:#F1493F;\"");
            } else {
                jsonObject.put("holdSideStyle", " style=\"color:#FFFFFF;background-color:#F0F0F0;\"");
            }
            // 保证金模式
            jsonObject.put("marginMode", InitRunner.publicParamsMap.get("marginMode").getString(jsonObject.getString("marginMode")));
            // 持仓模式
            jsonObject.put("holdMode", InitRunner.publicParamsMap.get("holdMode").getString(jsonObject.getString("holdMode")));

            // 最近更新时间 保证金数量 (保证金币种) 平均开仓价 未实现盈亏 预估强平价
            jsonObject.put("cTime", DateUtils.longToString(jsonObject.getLong("cTime")));
            jsonObject.put("margin", new BigDecimal(jsonObject.getString("margin")).setScale(4, RoundingMode.HALF_UP));
            jsonObject.put("averageOpenPrice", new BigDecimal(jsonObject.getString("averageOpenPrice")).setScale(4, RoundingMode.HALF_UP));
            jsonObject.put("unrealizedPL", new BigDecimal(jsonObject.getString("unrealizedPL")).setScale(4, RoundingMode.HALF_UP));
            jsonObject.put("liquidationPrice", new BigDecimal(jsonObject.getString("liquidationPrice")).setScale(4, RoundingMode.HALF_UP));

            // 未实现盈亏
            if (jsonObject.getBigDecimal("unrealizedPL").compareTo(BigDecimal.ZERO) < 0) {
                jsonObject.put("unrealizedPLStyle", " style=\"color:#FFFFFF;background-color:#F1493F;\"");
            } else {
                jsonObject.put("unrealizedPLStyle", " style=\"color:#FFFFFF;background-color:#1DA2B4;\"");
            }

            // 回报率=未实现盈亏/保证金
            BigDecimal returnRate = jsonObject.getBigDecimal("unrealizedPL").divide(jsonObject.getBigDecimal("margin"), 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)).setScale(2, RoundingMode.HALF_UP);
            jsonObject.put("returnRate", returnRate);
            if (returnRate.compareTo(BigDecimal.ZERO) < 0) {
                jsonObject.put("returnRateStyle", " style=\"color:#FFFFFF;background-color:#F1493F;\"");
            } else {
                jsonObject.put("returnRateStyle", " style=\"color:#FFFFFF;background-color:#1DA2B4;\"");
            }

            // 获取当前资金费率
            String requestUrl = mainUrl + "/api/mix/v1/market/current-fundRate?symbol=" + symbol;
            try {
                Connection.Response response = JsoupUtil.requestBody(requestUrl, JsoupUtil.HTTP_GET, InitRunner.proxy, null, null);
                String fundingRate = JSONObject.parseObject(response.body()).getJSONObject("data").getString("fundingRate");

                if (new BigDecimal(fundingRate).compareTo(BigDecimal.ZERO) < 0) {
                    jsonObject.put("fundingRateStyle", " style=\"color:#FFFFFF;background-color:#F1493F;\"");
                } else {
                    jsonObject.put("fundingRateStyle", " style=\"color:#FFFFFF;background-color:#1DA2B4;\"");
                }
                jsonObject.put("fundingRate", new BigDecimal(fundingRate).multiply(BigDecimal.valueOf(100)).setScale(4, RoundingMode.HALF_UP).toPlainString() + "%");
            } catch (Exception ex) {
                throw new RuntimeException(ex);
            }

            // 标记价格
            jsonObject.put("marketPriceStyle", " style=\"color:#252B31;background-color:#C4ADE9;font-weight:bold;\"");

        })).join();

        if (unrealizedPLSort != 0) {
            Collections.sort(result, (o1, o2) -> unrealizedPLSort * (((JSONObject) o1).getBigDecimal("unrealizedPL").compareTo(((JSONObject) o2).getBigDecimal("unrealizedPL"))));
        }
    }

    /**
     * Java实现字节转换，可以自动转换为B、KB、MB、GB、TB
     *
     * @param size
     * @return
     */
    private String readableFileSize(double size) {
        if (size <= 0) {
            return "0";
        }
        final String[] units = new String[]{"B", "K", "M", "G", "T"};
        int digitGroups = (int) (Math.log10(size) / Math.log10(1000));
        return df1.format(size / Math.pow(1000, digitGroups)) + units[digitGroups];
    }
}