package cn.autoform.web.client.impl;

import java.util.*;
import java.util.concurrent.TimeoutException;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import com.alibaba.fastjson.TypeReference;

import cn.autoform.bean.CodeAndValueBean;
import cn.autoform.db.entity.IpAndPortEntity;
import cn.autoform.db.entity.MasterDefineEntity;
import cn.autoform.db.entity.MasterElementEntity;
import cn.autoform.db.entity.MasterValueEntity;
import cn.autoform.db.exten.MasterData;
import cn.autoform.db.exten.MasterValue;
import cn.autoform.fw.exception.FormClientException;
import cn.autoform.fw.exception.RestResult;
import cn.autoform.util.thread.Keys;
import cn.autoform.util.thread.ThreadData;
import cn.autoform.util.tool.GetFormClientResult;
import cn.autoform.util.tool.JSONTool;
import cn.autoform.web.client.MasterClient;
import cn.autoform.web.client.util.HttpClientTool;
import cn.autoform.web.client.util.IpAndPortTool;
import cn.autoform.web.mapper.masterdata.MasterDataMapper;

@Service
public class MasterClientImpl implements MasterClient {

	private static final Map<String,String> ipMap = new HashMap<>();
	
	@Value("${autoForm.businessSystem}")
	private String autoFormClient;	
	
	static {
		ipMap.put("selectAll", "%s/epc/epc-form"+FormClientImpl.CLIENT_CONTEXT_PATH+"/define/selectAll");
		ipMap.put("search", "%s/epc/epc-form"+FormClientImpl.CLIENT_CONTEXT_PATH+"/define/search");
		ipMap.put("mainElements", "%s/epc/epc-form"+FormClientImpl.CLIENT_CONTEXT_PATH+"/select/mainElements");
		ipMap.put("codeToValue", "%s/epc/epc-form"+FormClientImpl.CLIENT_CONTEXT_PATH+"/select/codeToValue");
//		ipMap.put("selectAll", "%s/define/selectAll");
//		ipMap.put("search", "%s/define/search");
//		ipMap.put("mainElements", "%s/select/mainElements");
	}
	
	@Autowired
	MasterDataMapper masterDataMapper = null;
	
	@Autowired
	IpAndPortTool ipAndPortTool;
	
	@SuppressWarnings({ "unchecked", "rawtypes" })
	@Override
	public List<MasterDefineEntity> queryClientMasterDefines(MasterData masterData) throws TimeoutException, FormClientException {
		System.err.println(JSONTool.toJson(masterData));
		IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
		System.err.println(ipAndPortEntity.getIp() + ":"  + ipAndPortEntity.getPort());
		HttpClientTool<RestResult<List<MasterDefineEntity>>> hc = new HttpClientTool(String.format(ipMap.get("selectAll"), ipAndPortEntity.getIp()));
		hc.setBodyInfos(masterData);
		RestResult<List<MasterDefineEntity>> result = hc.sendPost(
				j->JSONTool.toObj(j, new TypeReference<RestResult<List<MasterDefineEntity>>>(){}));
		return GetFormClientResult.getRightResult(result);
	}

	@SuppressWarnings({ "unchecked", "rawtypes" })
	@Override
	public List<MasterElementEntity> queryClientMasterElements(MasterData masterData) throws Exception {
		IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
		HttpClientTool<RestResult<List<MasterElementEntity>>> hc = new HttpClientTool(String.format(ipMap.get("search"), ipAndPortEntity.getIp()));
		hc.setBodyInfos(masterData);
		RestResult<List<MasterElementEntity>> result = hc.sendPost(
				j->JSONTool.toObj(j, new TypeReference<RestResult<List<MasterElementEntity>>>(){}));
		return GetFormClientResult.getRightResult(result);
	}

	@SuppressWarnings({ "unchecked", "rawtypes" })
	@Override
	public List<CodeAndValueBean> queryClientMasterValues(MasterValue masterValue) throws Exception {
		System.err.println(JSONTool.toJson(masterValue));
		System.out.println("公司ID"+ThreadData.get(Keys.COMPANY_ID));
		IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
		HttpClientTool<RestResult<List<CodeAndValueBean>>> hc = new HttpClientTool(String.format(ipMap.get("mainElements"), ipAndPortEntity.getIp()));
		hc.setBodyInfos(masterValue);
		Map<String,Object> m = getCookies();
		System.out.println("heard:"+JSONTool.toJson(m));
		hc.setCookie(m);
		RestResult<List<CodeAndValueBean>> result = hc.sendPost(
				j->JSONTool.toObj(j, new TypeReference<RestResult<List<CodeAndValueBean>>>(){}.getType()));
		return (List<CodeAndValueBean>)Optional.ofNullable(GetFormClientResult.getRightResult(result)).orElse(new ArrayList<>());
		
	}

	@Override
	public CodeAndValueBean masterValueCodeToName(MasterValue masterValue) throws Exception {
		System.err.println(JSONTool.toJson(masterValue));
		IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
		System.out.println("ip:"+JSONTool.toJson(ipAndPortEntity));
		HttpClientTool<RestResult<CodeAndValueBean>> hc = new HttpClientTool<RestResult<CodeAndValueBean>>(String.format(ipMap.get("codeToValue"), ipAndPortEntity.getIp()));
		hc.setBodyInfos(masterValue);
		RestResult<CodeAndValueBean> result = hc.sendPost(
				j->JSONTool.toObj(j, new TypeReference<RestResult<CodeAndValueBean>>(){}));
		return GetFormClientResult.getRightResult(result);
	}
	
	//下面是之前的方法
//	public List<MasterValueEntity> queryClientMasterValues(MasterValue masterValue) throws Exception {
//		System.err.println(JSONTool.toJson(masterValue));
//		IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
//		HttpClientTool<RestResult<List<MasterValueEntity>>> hc = new HttpClientTool(String.format(ipMap.get("mainElements"), ipAndPortEntity.getIp()));
//		hc.setBodyInfos(masterValue);
//		RestResult<List<MasterValueEntity>> result = hc.sendPost(
//				j->JSONTool.toObj(j, new TypeReference<RestResult<List<MasterValueEntity>>>(){}));
//		return GetFormClientResult.getRightResult(result);
//		
//	}
	
	public Map<String,Object> getCookies(){
		Map<String,Object> map = new HashMap<String,Object>();
		map.put("companyId", ThreadData.get(Keys.COMPANY_ID));
		map.put("openId", ThreadData.get(Keys.OPEN_ID));
		map.put("token", ThreadData.get(Keys.TOKEN));
		map.put("tenantId", ThreadData.get(Keys.TENANT_ID));
		System.out.println("Cookie访问业务系统:"+JSONTool.toJson(map));
		return map;
	}
}