package cn.emay.sdk.client;

import java.io.File;
import java.util.Date;

import cn.emay.sdk.common.CommonConstants;
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.request.MoRequest;
import cn.emay.sdk.core.dto.sms.request.ReportRequest;
import cn.emay.sdk.core.dto.sms.request.RetrieveReportRequest;
import cn.emay.sdk.core.dto.sms.request.SmsBatchOnlyRequest;
import cn.emay.sdk.core.dto.sms.request.SmsBatchRequest;
import cn.emay.sdk.core.dto.sms.request.SmsPersonalityAllRequest;
import cn.emay.sdk.core.dto.sms.request.SmsPersonalityRequest;
import cn.emay.sdk.core.dto.sms.request.SmsSingleRequest;
import cn.emay.sdk.core.dto.sms.response.BalanceResponse;
import cn.emay.sdk.core.dto.sms.response.MoResponse;
import cn.emay.sdk.core.dto.sms.response.ReportResponse;
import cn.emay.sdk.core.dto.sms.response.RetrieveReportResponse;
import cn.emay.sdk.core.dto.sms.response.SmsResponse;
import cn.emay.sdk.core.service.SDKService;
import cn.emay.sdk.core.service.security.SDKSecurityServiceImpl;
import cn.emay.sdk.task.ContrastHostTask;
import cn.emay.sdk.util.DateUtil;
import cn.emay.sdk.util.HostUtil;
import cn.emay.sdk.util.Md5;
import cn.emay.sdk.util.StringUtil;
import cn.emay.sdk.util.exception.SDKParamsException;
import cn.emay.sdk.util.http.common.EmayHttpResultCode;

public class SmsSDKClient {

	/**
	 * 亿美服务帐号
	 */
	private String appId;
	/**
	 * 亿美服务密码
	 */
	private String secretkey;

	private SDKService service;
	/**
	 * 亿美http请求地址
	 */
	private String host;
	/**
	 * SDK缓存目录
	 */
	private File file;

	/**
	 * @param ip
	 *            亿美网关IP
	 * @param port
	 *            亿美网关端口
	 * @param appId
	 *            亿美服务帐号
	 * @param secretkey
	 *            亿美服务密码
	 * @throws SDKParamsException
	 */
	public SmsSDKClient(String ip, int port, String appId, String secretkey) throws SDKParamsException {
		if (StringUtil.isEmpty(appId) || StringUtil.isEmpty(secretkey) || StringUtil.isEmpty(ip) || port <= 0) {
			throw new SDKParamsException("SDK params error");
		}
		this.appId = appId;
		this.secretkey = secretkey;
		if (!ip.toLowerCase().startsWith("http://")) {
			ip = "http://" + ip;
		}
		host = ip + ":" + port;
		CommonConstants.isBest = true;
		CommonConstants.bestUrl = host;
		service = new SDKSecurityServiceImpl();
	}

	/**
	 * @param appId
	 *            亿美服务帐号
	 * @param secretkey
	 *            亿美服务密码
	 * @throws SDKParamsException
	 */
	public SmsSDKClient(String appId, String secretkey) throws SDKParamsException {
		this(appId, secretkey, "");
	}

	/**
	 * 
	 * @param appId
	 *            亿美服务帐号
	 * @param secretkey
	 *            亿美服务密码
	 * @param filePath
	 *            缓存数据目录(用于存储请求地址)
	 * @throws SDKParamsException
	 */
	public SmsSDKClient(String appId, String secretkey, String filePath) throws SDKParamsException {
		if (StringUtil.isEmpty(appId) || StringUtil.isEmpty(secretkey)) {
			throw new SDKParamsException("SDK params error");
		}
		this.appId = appId;
		this.secretkey = secretkey;
		file = HostUtil.creatCacheFile(filePath);
		String url = HostUtil.getFileUrl(file, appId);
		if (StringUtil.isEmpty(url)) {
			HostUtil.getSDKInter();
			if (CommonConstants.interList == null || CommonConstants.interList.isEmpty()) {
				throw new SDKParamsException("SDK Request interface address exception");
			}
			new Thread(new ContrastHostTask(file, appId, secretkey)).start();
			CommonConstants.bestUrl = CommonConstants.interList.get(0);
		} else {
			CommonConstants.isBest = true;
			CommonConstants.bestUrl = url;
		}
		service = new SDKSecurityServiceImpl();
	}

	/**
	 * 状态报告重新获取
	 * 
	 * @param reportRequest
	 * @return
	 */
	public ResultModel<RetrieveReportResponse> retrieveReport(RetrieveReportRequest reportRequest) {
		String timestamp = DateUtil.toString(new Date(), "yyyyMMddHHmmss");
		String sign = Md5.md5((appId + secretkey + timestamp).getBytes());
		String url = (host == null || host.equals("")) ? CommonConstants.bestUrl : host;
		return service.retrieveReport(appId, timestamp, sign, url, reportRequest);
	}

	/**
	 * 发送单条短信
	 * 
	 * @param request
	 * @return
	 */

	public ResultModel<SmsResponse> sendSingleSms(SmsSingleRequest request) {
		String url = (host == null || host.equals("")) ? CommonConstants.bestUrl : host;
		return service.sendSingleSms(appId, secretkey, url, request);
	}

	/**
	 * 发送批次短信【非自定义smsid】
	 * 
	 * @param request
	 * @return
	 */
	public ResultModel<SmsResponse[]> sendBatchOnlySms(SmsBatchOnlyRequest request) {
		String url = (host == null || host.equals("")) ? CommonConstants.bestUrl : host;
		return service.sendBatchOnlySms(appId, secretkey, url, request);
	}

	/**
	 * 发送批次短信【自定义smsid】
	 * 
	 * @param request
	 * @return
	 * @throws SDKParamsException
	 */
	public ResultModel<SmsResponse[]> sendBatchSms(SmsBatchRequest request) throws SDKParamsException {
		String url = (host == null || host.equals("")) ? CommonConstants.bestUrl : host;
		return service.sendBatchSms(appId, secretkey, url, request);
	}

	/**
	 * 发送个性短信
	 * 
	 * @param request
	 * @return
	 */

	public ResultModel<SmsResponse[]> sendPersonalitySms(SmsPersonalityRequest request) throws SDKParamsException {
		String url = (host == null || host.equals("")) ? CommonConstants.bestUrl : host;
		return service.sendPersonalitySms(appId, secretkey, url, request);
	}

	/**
	 * 发送个性短信【全属性个性】
	 * 
	 * @param request
	 * @return
	 */
	public ResultModel<SmsResponse[]> sendPersonalityAllSMS(SmsPersonalityAllRequest request) throws SDKParamsException {
		String url = (host == null || host.equals("")) ? CommonConstants.bestUrl : host;
		return service.sendPersonalityAllSms(appId, secretkey, url, request);
	}

	/**
	 * 获取余额
	 * 
	 * @param request
	 * @return
	 */
	public ResultModel<BalanceResponse> getBalance(BalanceRequest request) {
		String url = (host == null || host.equals("")) ? CommonConstants.bestUrl : host;
		return service.getBalance(appId, secretkey, url, request);
	}

	/**
	 * 获取状态报告
	 * 
	 * @param request
	 * @return
	 */

	public ResultModel<ReportResponse[]> getReport(ReportRequest reportRequest) {
		String url = "";
		if (CommonConstants.isBest) {
			url = CommonConstants.bestUrl;
		} else {
			return new ResultModel<ReportResponse[]>(EmayHttpResultCode.SUCCESS.getCode(), new ReportResponse[0]);
		}
		return service.getReport(appId, secretkey, url, reportRequest);
	}

	/**
	 * 获取上行短信
	 * 
	 * @param request
	 * @return
	 */
	public ResultModel<MoResponse[]> getMo(MoRequest request) {
		String url = "";
		if (CommonConstants.isBest) {
			url = CommonConstants.bestUrl;
		} else {
			return new ResultModel<MoResponse[]>(EmayHttpResultCode.SUCCESS.getCode(), new MoResponse[0]);
		}
		return service.getMo(appId, secretkey, url, request);
	}

}