package cn.autoform.web.client.impl;

import cn.autoform.bean.Tenant;
import cn.autoform.db.entity.IpAndPortEntity;
import cn.autoform.fw.exception.IEMRuntimeException;
import cn.autoform.util.CacheUtil;
import cn.autoform.util.HttpUtil;
import cn.autoform.util.thread.Keys;
import cn.autoform.util.thread.ThreadData;
import cn.autoform.util.tool.JSONTool;
import cn.autoform.util.tool.ObjectUtil;
import cn.autoform.web.client.CscApiService;
import cn.autoform.web.client.bean.*;
import cn.autoform.web.client.conster.BaseConst;
import cn.autoform.web.client.util.CscUtils;
import cn.autoform.web.client.util.HttpClientTool;
import cn.autoform.web.client.util.IpAndPortTool;
import cn.autoform.web.client.util.OrgUtil;
import com.alibaba.fastjson.TypeReference;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.ui.ModelMap;

import java.util.*;
import java.util.concurrent.TimeoutException;
@Slf4j
@Service
public class CscApiServiceImpl  implements CscApiService,BaseConst{

	@Value("${autoForm.cscApi}")
	private String ProcessClient;
	
	@Autowired
	private IpAndPortTool ipAndPortTool;

	private static final String USER_NAME = "USER_NAME";
	
	private static final Map<String,String> ipMap = new HashMap<>();
	
	static {
		ipMap.put("ByTenantId", "%s/csc-ie-user/rest/json/api/tenant/findOrganization");
		ipMap.put("findRelationDetail", "%s/csc-ie-user/rest/json/api/organization/findRelationDetail");
		ipMap.put("findTenantCompanys", "%s/csc-ie-user/rest/json/api/organization/findRelationDetail");
		ipMap.put("findSystemList", "%s/csc-ie-user/rest/json/api/company/findSystemList");
		ipMap.put("findOrganizationByCompanyId", "%s");
		ipMap.put("findTenantsAndCompanys", "%s/csc-ie-user/rest/json/api/user/findTenantsAndCompanys");
		ipMap.put("findUserOrgs", "%s");
	}
	
	
	/**
	 * 根据租户id查询租户下的公司列表
	 * @param
	 * @return
	 */
	@Override
	public Tenant findTenantCompanys(Map<String,Object> map) {
		// TODO Auto-generated method stub
		return null;
	}
	
	
	/**
	 * 根据租户id查询租户对应的组织机构信息
	 * @return
	 */
	@SuppressWarnings({ "unchecked", "rawtypes" })
	@Override
	public Map<String,Object> findOrganizationByTenantId(Map<String,Object> map){
		Map<String,Object> maps = null;
		IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(ProcessClient);
		System.out.println("请求路径:"+String.format(ipMap.get("findOrganizationByTenantId"), ipAndPortEntity.getIp()));
		HttpClientTool<Map> hc = new HttpClientTool(String.format(ipMap.get("findOrganizationByTenantId"), ipAndPortEntity.getIp()));
		hc.setParams(CscUtils.getParam(new ModelMap("tenantId", map.get("tenantID"))));
		try {
			maps = hc.sendPost(j->JSONTool.toObj(j, new TypeReference<Map<String,Object>>(){}));
		} catch (TimeoutException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
	
		
		return maps;
	}

	/**
	 * 根据公司id获取所有业务系统
	 * @return
	 */
	@Override
	public Company findSystemList(Map<String,Object> map) {
		// TODO Auto-generated method stub
		return null;
	}

	/**
	 * 根据公司id获取该公司对应的组织结构信息
	 * @return
	 */
	@Override
	public Organizations findOrganizationByCompanyId(Map<String,Object> map) {
		// TODO Auto-generated method stub
		return null;
	}

	/**
	 * 通过openId查询用户所属的租户和公司信息
	 * @return
	 */
	@Override
	public TenantsAndCompanys findTenantsAndCompanys(Map<String,Object> map) {
		// TODO Auto-generated method stub
		return null;
	}

	/**
	 * 通过openId查询用户所属组织机构
	 */
	@Override
	public Organizations findUserOrgs(Map<String,Object> map) {
		// TODO Auto-generated method stub
		return null;
	}

	/**
	 * 
	 * 根据公司id获取公司下的组织机构用户岗位信息
	 *
	 */
	@SuppressWarnings({ "unchecked", "rawtypes" })
	@Override
	public List<Organization> findRelationDetail(Map<String,Object> map) {
		Map<String,Object> maps = null;
		IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(ProcessClient);
		
		HttpClientTool<Map> hc = new HttpClientTool(String.format(ipMap.get("findRelationDetail"), ipAndPortEntity.getIp()));
		//hc.setBodyInfos(CscUtils.getParam(new ModelMap("companyId", map.get("companyId"))));
		hc.setParams(CscUtils.getParam(new ModelMap("companyId", map.get("companyId"))));
		try {
			maps = hc.sendPost(j->JSONTool.toObj(j, new TypeReference<Map<String,Object>>(){}));
		} catch (TimeoutException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		//格式话组织机构数据
		List<Organization> orgs = JSONTool.toObj(JSONTool.toJson(maps),Organizations.class).getOrgs();
		OrgUtil.organizationFormat(orgs);
		return orgs;
	}
	
	public TenantsAndCompanys findTenantsAndCompanys() {
		TenantsAndCompanys tenantsAndCompanys = null;
		List<cn.autoform.web.client.bean.Tenant> tt=new ArrayList<>();
		IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(ProcessClient);
		try {
			System.out.println("url:"+String.format(ipMap.get("findTenantsAndCompanys"), ipAndPortEntity.getIp()));
			tenantsAndCompanys = HttpUtil.post(
					String.format(ipMap.get("findTenantsAndCompanys"), ipAndPortEntity.getIp())
						, null, CscUtils.getParam(new ModelMap("openId",ThreadData.get(Keys.OPEN_ID)/*"e1b50368384f4a27"*/))
						, null,  new TypeReference<TenantsAndCompanys>(){});
			System.out.println("返回结果:"+JSONTool.toJson(tenantsAndCompanys));
			if(ObjectUtil.empty(tenantsAndCompanys.getTenants())){
				System.out.println("当前无租户");
				return null;
			}
			for (cn.autoform.web.client.bean.Tenant ts : tenantsAndCompanys.getTenants()) {
				List<Company> com=new ArrayList<>();
				for (Company ts1 : ts.getCompanys()) {
				  Company sys = findSystemList(ts1.getId());
					ts1.setData(sys.getData());
					com.add(ts1);
					}
					ts.setCompanys(com);
					tt.add(ts);
				}
			tenantsAndCompanys.setTenants(tt);
			return tenantsAndCompanys;
		} catch (Exception e) {
			throw new IEMRuntimeException(N0002)/*.setchildIEMExc(changHongProperties.getPassUrl(PassPortName.FIND_USER_TENANTSANDCOMPANYS, null))*/;
		}
	}
	
	public Company findSystemList(Integer id) {
		IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(ProcessClient);
		Company sys = null;
	try {
		sys=HttpUtil.post(String.format(ipMap.get("findSystemList"), ipAndPortEntity.getIp())
				, null, CscUtils.getParam(new ModelMap("companyId", id)) //ThreadData.get(COMPANY_ID) 应该传入的参数
				, null,  new TypeReference<Company>(){});
		System.out.println("公司ID:"+JSONTool.toJson(sys));
		return sys;
	} catch (Exception e) {
		throw new IEMRuntimeException(C0002).setchildIEMExc("error");
	}
	
}
	@SuppressWarnings("unchecked")
	@Override
	public Organizations findRelationDetail(Integer companyId) {
		Map<String,Object> maps = null;
		Organizations orgs = null;
		IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(ProcessClient);
		
		
		HttpClientTool<Map> hc = new HttpClientTool(String.format(ipMap.get("findRelationDetail"), ipAndPortEntity.getIp()));
		//hc.setBodyInfos(CscUtils.getParam(new ModelMap("companyId", map.get("companyId"))));
		hc.setParams(CscUtils.getParam(new ModelMap("companyId", companyId)));
		try {
			maps = hc.sendPost(j->JSONTool.toObj(j, new TypeReference<Map<String,Object>>(){}));
			orgs = JSONTool.toObj(JSONTool.toJson(maps),Organizations.class);
		} catch (TimeoutException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		//格式话组织机构数据
		
		return orgs;
	}

	@SuppressWarnings("unchecked")
	@Override
	public Organization findOrganization(Integer tenantID) {
		Map<String,Object> maps = null;
		Organization orgs = null;
		IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(ProcessClient);
		HttpClientTool<Map> hc = new HttpClientTool(String.format(ipMap.get("ByTenantId"), ipAndPortEntity.getIp()));
		hc.setParams(CscUtils.getParam(new ModelMap("tenantId", tenantID)));
		try {
			maps = hc.sendPost(j->JSONTool.toObj(j, new TypeReference<Map<String,Object>>(){}));
			orgs = JSONTool.toObj(JSONTool.toJson(maps.get("organization")),Organization.class);
		} catch (TimeoutException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return orgs;
	}

	@SuppressWarnings({ "unchecked", "rawtypes" })
	@Override
//	@Cacheable(value="orgList")
	public List<Organization> findRelationDetail() {
		return CacheUtil.get(String.format("orgList:%s:%s", ThreadData.get(Keys.TOKEN), ThreadData.get(Keys.COMPANY_ID)), List.class, 1000*60*60*24, ()->{
			Organizations maps = null;
			IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(ProcessClient);

			HttpClientTool<Organizations> hc = new HttpClientTool(String.format(ipMap.get("findRelationDetail"), ipAndPortEntity.getIp()));
			hc.setParams(CscUtils.getParam(new ModelMap("companyId", ThreadData.get(Keys.COMPANY_ID))));
			hc.setCookie(null);
			try {
				maps = hc.sendPost(j->JSONTool.toObj(j, new TypeReference<Organizations>(){}));
			} catch (TimeoutException e) {
				e.printStackTrace();
				log.error("查询组织机构错误!");
			}

			return Optional.ofNullable(maps).map(Organizations::getOrgs).orElse(Collections.EMPTY_LIST);
		});
	}

	//匹配人员Id
	@Override
	public String getUserId(String openId) {
		if(ObjectUtil.empty(openId)){
			return " ";
		}
		return getUser(findRelationDetail(), openId).map(User::getId).orElse("");
	}
	
	public Optional<User> getUser(List<Organization> children, String openId){
		if (ObjectUtil.empty(children)) {
			return Optional.empty();
		}
		Optional<User> result;
		for(Organization o :children){
			if(!ObjectUtil.empty(o.getUsers())){
				for(User u: o.getUsers()){
					if(openId.equals(u.getOpenId()) || Objects.equals(openId,u.getPhone())){
						return Optional.ofNullable(u);
					}
				}
			}
			result = getUser(o.getChildren(), openId);
			if(result.isPresent()){
				return result;
			}
		}
		return Optional.empty();
	}
	
//	@Cacheable(USER_NAME)
	@Override
	public String getUserName(String openId) {
		if(openId==null || "".equals(openId)){
			return " ";
		}
		return getUser(findRelationDetail(), openId).map(User::getName).orElse("");
	}

}