package cn.emay.sdk.util;

import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Comparator;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;

import cn.emay.sdk.common.CommonConstants;
import cn.emay.sdk.core.dto.cache.UrlDTO;
import cn.emay.sdk.core.dto.sms.common.ResultModel;
import cn.emay.sdk.core.dto.sms.request.BalanceRequest;
import cn.emay.sdk.core.dto.sms.response.BalanceResponse;
import cn.emay.sdk.util.http.client.EmayHttpClient;
import cn.emay.sdk.util.http.request.impl.EmayHttpRequestString;
import cn.emay.sdk.util.http.response.impl.string.EmayHttpResponseString;
import cn.emay.sdk.util.http.response.impl.string.EmayHttpResponseStringPraser;
import cn.emay.sdk.util.json.JsonHelper;
import cn.emay.sdk.util.json.gson.JsonArray;
import cn.emay.sdk.util.json.gson.JsonElement;
import cn.emay.sdk.util.json.gson.JsonParser;
import cn.emay.sdk.util.json.gson.reflect.TypeToken;

public class HostUtil {

	public static String getUrl(String appId, String secretkey) {
		String host = "";
		List<String> list = CommonConstants.interList;
		try {
			if (list != null) {
				long minUseTime = -1l;
				for (String url : list) {
					long useTime = getBalance(appId, secretkey, url);
					if (useTime == -1) {
						continue;
					} else if (minUseTime == -1 || minUseTime > useTime) {
						minUseTime = useTime;
						host = url;
					}
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return host;
	}

	public static void getSDKInter() {

		EmayHttpClient client = new EmayHttpClient();
		EmayHttpRequestString request = null;
		try {
			request = new EmayHttpRequestString(CommonConstants.getSdkUrl, "UTF-8", "POST", null, null, null);
			EmayHttpResponseString res = client.service(request, new EmayHttpResponseStringPraser());
			if (res != null && res.getResultCode().getCode().equals("SUCCESS")) {
				String json = res.getResultString();
				if (json != null && !json.equals("")) {
					List<String> list = new ArrayList<String>();
					JsonArray array = new JsonParser().parse(json).getAsJsonObject().getAsJsonArray("result");
					Iterator<JsonElement> iterator = array.iterator();
					while (iterator.hasNext()) {
						JsonElement element = iterator.next();
						String ip = element.getAsJsonObject().get("ip").getAsString();
						Integer port = element.getAsJsonObject().get("port").getAsInt();
						list.add("http://" + ip + ":" + port);
					}
					CommonConstants.interList = list;
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
		}

	}

	public static long getBalance(String appId, String secretKey, String host) {
		long useTime = 0l;
		try {
			long time = System.currentTimeMillis();
			BalanceRequest request = new BalanceRequest();
			ResultModel<BalanceResponse> result = HttpUtil.request(appId, secretKey, host + "/inter/getBalance", request, BalanceResponse.class);
			if (result != null && result.getCode().equals("SUCCESS")) {
				useTime = System.currentTimeMillis() - time;
			} else {
				useTime = -1l;
			}
		} catch (Exception e) {
			e.printStackTrace();
			useTime = -1l;
		}
		return useTime;

	}

	public static List<Entry<String, Integer>> sortMap(Map<String, Integer> map) {
		List<Entry<String, Integer>> list = new ArrayList<Entry<String, Integer>>(map.entrySet());
		Collections.sort(list, new Comparator<Map.Entry<String, Integer>>() {
			public int compare(Map.Entry<String, Integer> o1, Map.Entry<String, Integer> o2) {
				return (o2.getValue() - o1.getValue());
			}
		});
		return list;
	}

	public static File creatCacheFile(String filePath) {
		File file = null;
		try {
			if (StringUtil.isEmpty(filePath)) {
				file = new File(CommonConstants.fileName);
				if (!file.exists()) {
					file.createNewFile();
				}
				return file;
			}
			file = new File(filePath);
			if (!file.exists()) {
				File fileParent = file.getParentFile();
				if (!fileParent.exists()) {
					fileParent.mkdirs();
				}
				file.createNewFile();
			}
			if (!file.canWrite() || !file.canRead()) {
				return null;
			}
		} catch (Exception e) {
			e.printStackTrace();
			return null;
		}
		return file;
	}

	public static boolean writeFile(File file, String content) {
		BufferedOutputStream bos = null;
		try {
			bos = new BufferedOutputStream(new FileOutputStream(file));
			bos.write(content.getBytes("UTF-8"));
			bos.flush();
		} catch (Exception e) {
			e.printStackTrace();
			return false;
		} finally {
			try {
				bos.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		return true;
	}

	public static String readFile(File file) {
		long fileSize = file.length();
		String json = "";
		if (fileSize > Integer.MAX_VALUE) {
			return null;
		}
		byte[] by = new byte[(int) fileSize];
		try {
			FileInputStream in = new FileInputStream(file);
			int offset = 0;
			int numRead = 0;
			while (offset < by.length && (numRead = in.read(by, offset, by.length - offset)) >= 0) {
				offset += numRead;
			}
			json = new String(by, "UTF-8");
			in.close();
		} catch (Exception e) {
			return null;
		}
		return json;
	}

	public static void contrastWrite(File file, String appId, String host) {
		List<UrlDTO> list = new ArrayList<UrlDTO>();
		String json = readFile(file);
		if (StringUtil.isEmpty(json)) {
			UrlDTO dto = new UrlDTO(appId, host);
			list.add(dto);
			json = JsonHelper.toJsonString(list);
			writeFile(file, json);
		} else {
			list = JsonHelper.fromJson(new TypeToken<List<UrlDTO>>() {
			}, json);
			Map<String, String> map = new HashMap<String, String>();
			for (UrlDTO urlDTO : list) {
				map.put(urlDTO.getAppId(), urlDTO.getUrl());
				if (urlDTO.getAppId().equals(appId) && !urlDTO.getUrl().equals(host)) {
					urlDTO.setUrl(host);
					json = JsonHelper.toJsonString(list);
					writeFile(file, json);
					break;
				}

			}
			if (!map.containsKey(appId)) {
				list.add(new UrlDTO(appId, host));
				writeFile(file, JsonHelper.toJsonString(list));
			}
		}
	}

	public static String getFileUrl(File file, String appId) {
		String url = "";
		String json = readFile(file);
		if (StringUtil.isEmpty(json)) {
			return url;
		} else {
			List<UrlDTO> list = JsonHelper.fromJson(new TypeToken<List<UrlDTO>>() {
			}, json);
			for (UrlDTO urlDTO : list) {
				if (urlDTO.getAppId().equals(appId)) {
					url = urlDTO.getUrl();
					break;
				}
			}
		}
		return url;
	}
}