package com.yami.trading.admin.facade;

import cn.hutool.core.collection.CollectionUtil;
import com.google.common.collect.Lists;
import com.yami.trading.bean.data.domain.Realtime;
import com.yami.trading.bean.item.domain.Item;
import com.yami.trading.bean.item.dto.MarketQuotations;
import com.yami.trading.bean.item.dto.MarketQuotationsAdjust;
import com.yami.trading.bean.model.Log;
import com.yami.trading.common.constants.Constants;
import com.yami.trading.common.lang.LangUtils;
import com.yami.trading.common.util.Arith;
import com.yami.trading.common.util.IPHelper;
import com.yami.trading.common.util.ThreadUtils;
import com.yami.trading.huobi.data.DataCache;
import com.yami.trading.huobi.data.internal.AdjustmentValueService;
import com.yami.trading.huobi.data.model.AdjustmentValue;
import com.yami.trading.security.common.model.YamiSysUser;
import com.yami.trading.security.common.util.SecurityUtils;
import com.yami.trading.service.data.DataService;
import com.yami.trading.service.item.ItemService;
import com.yami.trading.service.system.LogService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Component;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.text.MessageFormat;
import java.util.*;

@Component
@Slf4j
public class MarketQuotationsFacade {
    @Qualifier("dataService")
    @Autowired
    private DataService dataService;

    @Autowired
    private AdjustmentValueService adjustmentValueService;

    @Autowired
    private ItemService itemService;

    @Autowired
    private LogService logService;

    /**
     * 行情列表
     *
     * @return
     */
    public List<MarketQuotations> marketQuotationsList(List<String> symbols) {
        if (CollectionUtils.isEmpty(symbols)) {
            return null;
        }
        List<MarketQuotations> resultList = Lists.newLinkedList();
        List<Realtime> realtimes = this.dataService.realtime(StringUtils.join(symbols, ","));
        Set<String> symbolKey = new HashSet<String>();
        for (Realtime realtime : realtimes) {
            Integer decimal = itemService.getDecimal(realtime.getSymbol());
            MarketQuotations marketQuotations = new MarketQuotations();
            if (symbolKey.contains(realtime.getSymbol())) continue;
            String name = itemService.findBySymbol(realtime.getSymbol()).getName();
            marketQuotations.setName(name);

            marketQuotations.setSymbol(realtime.getSymbol());
            BigDecimal currentValue = this.adjustmentValueService.getCurrentValue(realtime.getSymbol());
            if (currentValue == null) {
                marketQuotations.setAdjustValue("0");
                marketQuotations.setNewPrice(Arith.str(realtime.getClose(), decimal));
            } else {
                marketQuotations.setAdjustValue(Arith.str(currentValue, decimal));
                // 原来价格是调整之后减去调整值
                marketQuotations.setNewPrice(realtime.getClose().subtract(currentValue).setScale(decimal, BigDecimal.ROUND_HALF_UP).toPlainString());
            }
            marketQuotations.setAfterValue(Arith.str(realtime.getClose(), decimal));
            resultList.add(marketQuotations);
            symbolKey.add(realtime.getSymbol());
        }
        return resultList;
    }

    /**
     * 获取详情
     *
     * @param symbol
     * @return
     */
    public MarketQuotationsAdjust getDetails(String symbol) {
        MarketQuotationsAdjust marketQuotationsAdjust = new MarketQuotationsAdjust();
        Integer decimal = itemService.getDecimal(symbol);
        marketQuotationsAdjust.setSymbol(symbol);
        Realtime realtime = DataCache.getRealtime(symbol);
        if (realtime == null) {
            List<Realtime> realtimeList = this.dataService.realtime(symbol);
            if (CollectionUtil.isEmpty(realtimeList)) {
                log.error("{} 当前没有实时价格", symbol);
                return marketQuotationsAdjust;
            }
            realtime = realtimeList.get(0);
        }
        Item item = this.itemService.findBySymbol(symbol);
        BigDecimal currentValue = this.adjustmentValueService.getCurrentValue(symbol);
        if (currentValue == null) {
            marketQuotationsAdjust.setAdjustValue(Arith.str(0, decimal));
        } else {
            marketQuotationsAdjust.setAdjustValue(Arith.str(currentValue, decimal));
        }
        if (currentValue == null) {
            marketQuotationsAdjust.setNewPrice(Arith.str(realtime.getClose(), decimal));
        } else {
            marketQuotationsAdjust.setNewPrice(realtime.getClose().subtract(currentValue).setScale(decimal, RoundingMode.HALF_UP).toPlainString());
        }
        marketQuotationsAdjust.setPips(Arith.str(item.getPips(), decimal));
        marketQuotationsAdjust.setAfterValue(Arith.str(realtime.getClose(), decimal));

        AdjustmentValue delayValue = this.adjustmentValueService.getDelayValue(symbol);

        if (delayValue != null) {
            marketQuotationsAdjust.setDelayValue(Arith.str(delayValue.getValue(), decimal));
            marketQuotationsAdjust.setDelaySecond("" + delayValue.getSecond());
        }
        return marketQuotationsAdjust;
    }

    /**
     * 行情调整预计算值
     *
     * @param symbol
     * @param type
     * @param value
     * @return
     */
    public Map<String, String> calculateValue(String symbol, String type, double value) {
        Map<String, String> resultMap = new HashMap<String, String>();
        Integer decimal = itemService.getDecimal(symbol);

        Realtime realtime = null;

        realtime = this.dataService.realtime(symbol).get(0);
        Item item = this.itemService.findBySymbol(symbol);
        BigDecimal currentValue = this.adjustmentValueService.getCurrentValue(symbol);
        if (currentValue == null) {
            resultMap.put("newPrice", Arith.str(realtime.getClose(), decimal));
        } else {
            resultMap.put("newPrice", realtime.getClose().subtract(currentValue).toPlainString());
        }

        double temp;
        if (type.equalsIgnoreCase("0")) {
            temp = Arith.add(value, item.getPips().doubleValue());
            // 调整量
            resultMap.put("adjustCurrentValue", Arith.str(temp, decimal));
            // 调整后的值
            resultMap.put("adjustValueAfter", Arith.add(realtime.getClose().doubleValue(), temp, decimal));
        } else if (type.equalsIgnoreCase("1")) {
            temp = Arith.sub(value, item.getPips().doubleValue());

            resultMap.put("adjustCurrentValue", temp + "");
            resultMap.put("adjustValueAfter", Arith.add(realtime.getClose().doubleValue(), temp, decimal));
        } else {
            temp = value;
            resultMap.put("adjustCurrentValue", temp + "");
            resultMap.put("adjustValueAfter", Arith.add(realtime.getClose().doubleValue(), temp, decimal));
        }

        if (currentValue == null) {
            resultMap.put("adjustValue", Arith.str(item.getPips(), decimal));
        } else {
            resultMap.put("adjustValue", Arith.add(temp, currentValue.doubleValue(), decimal));
        }
        AdjustmentValue delayValue = this.adjustmentValueService.getDelayValue(symbol);

        if (delayValue != null) {
            resultMap.put("delayValue", Arith.str(delayValue.getValue(), decimal));
            resultMap.put("delaySecond", delayValue.getSecond() + "");
        }
        return resultMap;

    }

    public void adjust(String symbol, Double second, BigDecimal value) {
        BigDecimal currentValue = this.adjustmentValueService.getCurrentValue(symbol);
        if (currentValue == null) {
            Realtime realtime = this.dataService.realtime(symbol).get(0);
            currentValue = realtime.getClose();
        }
        String log = MessageFormat.format("ip:" + IPHelper.getIpAddr() + ",管理员调整行情,币种:{0},原值:{1},调整值:{2},调整时间:{3}",
                symbol, currentValue.toPlainString(), value.toPlainString(), second);

        this.adjustmentValueService.adjust(symbol, value, second);
        saveLog(log);
        ThreadUtils.sleep(1000);

    }

    public void saveLog(String content) {
        YamiSysUser sysUser = SecurityUtils.getSysUser();
        Log log = new Log();
        log.setCategory(Constants.LOG_CATEGORY_OPERATION);
        log.setOperator(sysUser.getUsername());
        log.setUsername(sysUser.getUsername());
        log.setUserId(sysUser.getUserId().toString());
        log.setLog(content);
        log.setCreateTime(new Date());
        logService.save(log);
    }
}