package com.product.admin.service;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.google.common.base.Joiner;
import com.product.core.dao.BaseDao;
import com.product.core.entity.DataTableEntity;
import com.product.core.entity.FieldMetaEntity;
import com.product.core.entity.FieldSetEntity;
import com.product.core.entity.SQLEntity;
import com.product.core.exception.BaseException;

import java.io.IOException;
import java.util.*;

import com.product.core.spring.context.SpringMVCContextHolder;
import org.apache.http.HttpEntity;
import org.apache.http.HttpStatus;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import com.product.core.service.support.AbstractBaseService;
import com.product.util.BaseUtil;
import com.product.admin.config.CmnConst;
import com.product.admin.config.SystemCode;

/**
 * Copyright © 2020 LX-BASE
 *
 * @Title: LX-BASE-SERVER
 * @Project: base-server-admin
 * @Date: 2020年11月20日
 * @Author: Mr.Xu
 * @Description:公共汇率
 */
@Component
public class SystemExchangeRateService extends AbstractBaseService {

    @Autowired
    private BaseDao dao;


    /**
     * 更新所有汇率
     *
     * @return
     * @throws BaseException
     */
    public boolean updateCurrencyRate() throws BaseException {
        List<String> currencyCodes = getCurrencyCodes();
        return dao.add(getCurrencyRates(currencyCodes));
    }

    /**
     * 获取所有启用货币code
     *
     * @throws BaseException
     */
    public List<String> getCurrencyCodes() throws BaseException {
        SQLEntity sqlEntity = new SQLEntity();
        sqlEntity.setTableNames(CmnConst.PRODUCT_COMMON_CURRENCY);
        sqlEntity.setFilter("is_used=1");
        DataTableEntity dt = dao.listTable(sqlEntity);
        if (!BaseUtil.dataTableIsEmpty(dt)) {
            List<String> currencyCodes = new ArrayList<>();
            for (int i = 0; i < dt.getRows(); i++) {
                currencyCodes.add(dt.getString(i, "currency_code"));
            }
            return currencyCodes;
        }
        return Collections.emptyList();
    }

    /**
     * 获取指定货币汇率
     *
     * @param originalCurrency 原货币
     * @param foreignCurrencys 兑换后货币 集合多个用逗号分隔
     * @return
     * @throws BaseException
     */
    public DataTableEntity getAssignCurrencyRate(String originalCurrency, String foreignCurrencys)
            throws BaseException {
        Map<String, Object> map = new HashMap<>();
        map.put("base", originalCurrency);
        map.put("symbols", foreignCurrencys);
        String url = BaseUtil.urlParamsJoin(CmnConst.RATE_API_URL, map);
        if (BaseUtil.strIsNull(url)) {
            return null;
        }
        JSONObject sendRequest = sendRequest(url, null, 0, 0);
        String errorKey = "error";
        String saveRateKey = "getAssignCurrencyRate(String originalCurrency, String foreignCurrencys)";
        if (sendRequest == null || sendRequest.isEmpty()) {
            throw new BaseException(SystemCode.SYSTEM_GAIN_CURRENCY_RATE_PARAM_EMPTY_FIAL.getValue(),
                    SystemCode.SYSTEM_GAIN_CURRENCY_RATE_PARAM_EMPTY_FIAL.getText() , this.getClass(),
                    saveRateKey);
        }
        if (!BaseUtil.strIsNull(sendRequest.getString(errorKey))) {
            throw new BaseException(SystemCode.SYSTEM_GAIN_CURRENCY_RATE_PARAM_EMPTY_FIAL.getValue(),
                    SystemCode.SYSTEM_GAIN_CURRENCY_RATE_PARAM_EMPTY_FIAL.getText() + "," + sendRequest.getString(errorKey), this.getClass(),
                    saveRateKey);
        }
        return paramsJoinToDataTable(sendRequest);
    }

    /**
     * 获取汇率
     *
     * @param currencyCodes 汇率code 集合
     * @return
     * @throws BaseException
     */
    public DataTableEntity getCurrencyRates(List<String> currencyCodes) throws BaseException {

        if (currencyCodes == null) {
            return null;
        }
        DataTableEntity result = null;
        for (int i = 0; i < currencyCodes.size(); i++) {
            Map<String, Object> map = new HashMap<>();
            List<String> currencyCodes2 = new ArrayList<>();
            currencyCodes2.addAll(currencyCodes);
            currencyCodes2.remove(currencyCodes2.get(i));
            map.put("base", currencyCodes.get(i));
            map.put("symbols", Joiner.on(",").join(currencyCodes2));
            String url = BaseUtil.urlParamsJoin(CmnConst.RATE_API_URL, map);
            if (BaseUtil.strIsNull(url)) {
                continue;
            }
            JSONObject sendRequest = sendRequest(url, null, 0, 0);
            String error = null;
            if (sendRequest != null) {
                sendRequest.getString("error");
            }
            if (sendRequest == null || !BaseUtil.strIsNull(error)) {
                throw new BaseException(SystemCode.SYSTEM_GAIN_CURRENCY_RATE_PARAM_EMPTY_FIAL.getValue(),
                        SystemCode.SYSTEM_GAIN_CURRENCY_RATE_PARAM_EMPTY_FIAL.getText() + "," + error, this.getClass(),
                        "getCurrencyRates(List<String> currencyCodes) throws BaseException");
            }
            sendRequest.put("url", url);
            DataTableEntity saveRate = paramsJoinToDataTable(sendRequest);
            if (result == null) {
                result = saveRate;
            } else {
                result = BaseUtil.dataTableMerge(result, saveRate);
            }
        }
        return result;
    }

    /**
     * 第三方参数拼接成dataTable
     *
     * @param json
     * @return
     */

    public DataTableEntity paramsJoinToDataTable(JSONArray array) throws BaseException {
        if (array == null) { // 第三方接口返回信息为空
            throw new BaseException(SystemCode.SYSTEM_GAIN_CURRENCY_RATE_PARAM_EMPTY_FIAL.getValue(),
                    SystemCode.SYSTEM_GAIN_CURRENCY_RATE_PARAM_EMPTY_FIAL.getText(), this.getClass(), "saveRate");
        }
        DataTableEntity result = null;
        for (int i = 0; i < array.size(); i++) {
            DataTableEntity saveRate = paramsJoinToDataTable(array.getJSONObject(i));
            if (result == null) {
                result = saveRate;
            } else {
                result = BaseUtil.dataTableMerge(result, saveRate);
            }
        }
        return result;
    }

    /**
     * 第三方参数拼接成dataTable
     *
     * @param json
     * @return
     */

    public DataTableEntity paramsJoinToDataTable(JSONObject json) throws BaseException {
        if (json == null || json.getJSONObject("rates") == null) { // 第三方接口返回信息为空
            throw new BaseException(SystemCode.SYSTEM_GAIN_CURRENCY_RATE_PARAM_EMPTY_FIAL.getValue(),
                    SystemCode.SYSTEM_GAIN_CURRENCY_RATE_PARAM_EMPTY_FIAL.getText(), this.getClass(), "saveRate");
        }
        DataTableEntity dt = new DataTableEntity();
        String base = json.getString("base");

        String date = json.getString("date");
        JSONObject resultJson = json.getJSONObject("rates");
        for (String currencyCode : resultJson.keySet()) {
            FieldSetEntity fs = new FieldSetEntity();
            FieldMetaEntity metaEntity = new FieldMetaEntity();
            metaEntity.setTableName(new Object[]{CmnConst.PRODUCT_COMMON_FOREIGN_EXCHANGE_RATE});
            fs.setMeta(metaEntity);
            fs.setValue("foreign_currency_uuid", currencyCode);
            fs.setValue("exchanged_utc_datetime", date);
            fs.setValue("exchange_time_zone", 0);
            fs.setValue("original_currency_uuid", base);
            fs.setValue("exchange_rate", resultJson.getString(currencyCode));
            BaseUtil.createCreatorAndCreationTime(null, fs);
            fs.setValue(CmnConst.CREATED_BY, "1");
            dt.addFieldSetEntity(fs);
        }
        return dt;
    }

    /**
     * 发送http 请求获取数据
     *
     * @param url
     * @param token
     * @param socketTimeout
     * @param connectTimeout
     * @return
     */
    private JSONObject sendRequest(String url, String token, int socketTimeout, int connectTimeout) {
        if (token == null) {
            token = "";
        }
        HttpGet request = new HttpGet(url);
        if (socketTimeout <= 0) {
            socketTimeout = 6000;
        }
        if (connectTimeout <= 0) {
            connectTimeout = 6000;
        }
        RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(socketTimeout)
                .setConnectTimeout(connectTimeout).build();
        request.setConfig(requestConfig);
        request.setHeader("Authorization", token);
        try (CloseableHttpClient client = HttpClients.createDefault()) {
            CloseableHttpResponse response = client.execute(request);
            if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
                HttpEntity entity = response.getEntity();
                String strResult = EntityUtils.toString(entity, "utf-8");
                return JSON.parseObject(strResult);
            }
        } catch (IOException e) {
            throw new BaseException(e);
        } finally {
            request.releaseConnection();
        }
        return null;
    }

}