package io.bhex.broker.server.grpc.server.service.statistics;

import com.google.common.base.Strings;
import com.google.common.cache.CacheBuilder;
import com.google.common.cache.CacheLoader;
import com.google.common.cache.LoadingCache;
import io.bhex.base.token.GetTokenRequest;
import io.bhex.base.token.TokenDetail;
import io.bhex.broker.common.util.JsonUtil;
import io.bhex.broker.grpc.statistics.FinanceRealTime;
import io.bhex.broker.grpc.statistics.FinanceRealTimeResponse;
import io.bhex.broker.server.domain.RateBo;
import io.bhex.broker.server.grpc.client.service.GrpcTokenService;
import io.bhex.broker.server.model.Symbol;
import io.bhex.broker.server.statistics.clear.mapper.StatisticsClearOdsMapper;
import io.bhex.broker.server.statistics.statistics.mapper.StatisticsOdsMapper;
import lombok.extern.slf4j.Slf4j;
import org.joda.time.DateTime;
import org.joda.time.DateTimeZone;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import xyz.coins.commonutils.JsonConvertor;

import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import java.lang.reflect.Method;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Comparator;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.TimeZone;
import java.util.concurrent.TimeUnit;

/**
 * @author wangsc
 * @description 统计Ods服务
 * @date 2020-06-19 19:59
 */
@Service
@Slf4j
public class StatisticsOdsService {

    @Resource
    private StatisticsOdsMapper statisticsOdsMapper;

    @Resource
    private StatisticsClearOdsMapper statisticsClearOdsMapper;

    @Resource
    private GrpcTokenService grpcTokenService;

    private final Integer PH_DEPOSIT = 701;
    private final Integer PH_WITHDRAWAL = 702;
    private final Integer FIAT_DEPOSIT = 12;
    private final Integer FIAT_WITHDRAWAL = 22;
    private final Integer CHAIN_DEPOSIT = 10;
    private final Integer CHAIN_WITHDRAWAL = 20;
    private final Integer BUY_LOAD = 16;
    private final Integer PAY_BILL = 17;
    private final Integer INVOICE_PAY = 24;

    private LoadingCache<String, RateBo> TOKEN_RATE_CACHE;

    private LoadingCache<String, BigDecimal> BALANCE_FLOW_CACHE;

    @Resource
    @Qualifier("quoteRedisTemplate")
    private RedisTemplate quoteRedisTemplate;

    private final String RATE_KEY = "MKT:QUOTE:RATE";

    private final RateBo NULL = new RateBo();

    @PostConstruct
    public void init() {
        TOKEN_RATE_CACHE = CacheBuilder.newBuilder()
                .refreshAfterWrite(60, TimeUnit.SECONDS)
                .maximumSize(1000)
                .build(new CacheLoader<>() {
                    @Override
                    public RateBo load(String token) {
                        try {
                            Object tokenObj = quoteRedisTemplate.opsForHash().get(RATE_KEY, token);
                            if (Objects.isNull(tokenObj)) {
                                return NULL;
                            }
                            log.info("tokenObj,{}",tokenObj.toString());
                            return JsonConvertor.fromJsonString(tokenObj.toString(), RateBo.class);
                        } catch (Exception e) {
                            log.error("loadExchangeRateFromRedis error.", e);
                        }
                        return NULL;
                    }
                });

        BALANCE_FLOW_CACHE = CacheBuilder.newBuilder()
                .refreshAfterWrite(60, TimeUnit.SECONDS)
                .maximumSize(1000)
                .build(new CacheLoader<>() {
                    @Override
                    public BigDecimal load(String key) {
                        String[] split = key.split("#");
                        Integer type = Integer.valueOf(split[0]);
                        BigDecimal money = statisticsClearOdsMapper.groupBySubject(type,split[1],split[2],split[3]);
                        return money == null ? BigDecimal.ZERO:money;
                    }
                });
    }

    public BigDecimal getRate(String baseToken, String quoteToken) {
        if (baseToken.equalsIgnoreCase(quoteToken)) {
            return BigDecimal.ONE;
        }
        try {
            RateBo rateBo = TOKEN_RATE_CACHE.get(baseToken);
            if (rateBo != null) {
                return rateBo.getRate(quoteToken);
            }
        } catch (Exception e) {
            log.error("getRate error.{},quoteToken.{},message.{}", baseToken, quoteToken, e.getMessage());
        }
        return BigDecimal.ZERO;
    }


}

google cache