package com.changhong.epc.rely.api.service.workFlow.impl;

import com.alibaba.fastjson.TypeReference;
import com.changhong.epc.constter.base.Context;
import com.changhong.epc.constter.system.SystemClients;
import com.changhong.epc.constter.system.prop.ChangHongProperties;
import com.changhong.epc.constter.system.prop.ChangHongProperties.PassPortName;
import com.changhong.epc.rely.api.service.workFlow.WorkFlowService;
import com.changhong.epc.rely.api.tool.HttpUtil;
import com.changhong.epc.rely.api.tool.WorkflowTool;
import com.iemsoft.framework.cloud.core.constant.BaseConst;
import com.iemsoft.framework.cloud.core.exception.IEMRuntimeException;
import com.iemsoft.framework.cloud.core.thread.Keys;
import com.iemsoft.framework.cloud.core.thread.ThreadData;
import com.iemsoft.framework.cloud.core.tools.SpringUtil;
import com.iemsoft.framework.cloud.core.tools.http.Http;
import com.iemsoft.framework.cloud.core.tools.http.IEMHttpException;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.ui.ModelMap;

import java.util.Map;
import java.util.Objects;
import java.util.concurrent.TimeoutException;
@Slf4j
@Service("workFlowServiceImpl")
public class WorkFlowServiceImpl implements WorkFlowService,BaseConst,SystemClients {
	
	@Autowired
	private WorkflowTool workflowTool;
	
	
	@Autowired
	private ChangHongProperties changHongProperties;

	/**
	 * 删除流程定义，批量
	 */
	@Override
	public Map<String, Object> defineDelete(Map<String,Object> maps) throws TimeoutException {
		Map<String,Object> map =  null;		
		try {
			map = HttpUtil.post(changHongProperties.getPassUrl(PassPortName.DEF_DELETE, null)
						, null,workflowTool.getProcess(maps).getFlowmap()
						, null,  new TypeReference<Map<String,Object>>(){}.getType());
			// System.out.println("最后参数"+JSONTool.toJson(workflowTool.getProcess(maps).getFlowmap()));
			return map;
		} catch (Exception e) {
			throw new IEMRuntimeException(C0002).setchildIEMExc(changHongProperties.getPassUrl(PassPortName.FIND_TENANT_ORGANIZATION, null));
		}
	}
	
	/**
	 * 部署流程定义
	 */
	@Override
	public Map<String, Object> definePeploy(Map<String,Object> maps) throws TimeoutException {
		Map<String,Object> map =  null;		
		try {
			map = HttpUtil.post(changHongProperties.getPassUrl(PassPortName.DEF_DEPLOY, null)
						, null,workflowTool.getProcess(maps).getFlowmap()
						, null,  new TypeReference<Map<String,Object>>(){}.getType());
			// System.out.println("最后参数"+JSONTool.toJson(workflowTool.getProcess(maps).getFlowmap()));
			return map;
		} catch (Exception e) {
			throw new IEMRuntimeException(C0002).setchildIEMExc(changHongProperties.getPassUrl(PassPortName.FIND_TENANT_ORGANIZATION, null));
		}
	}
	
	/**
	 * 流程定义分页查询
	 */
	@Override
	public Map<String, Object> defineSeache(Map<String,Object> maps) throws TimeoutException {
		Map<String,Object> map =  null;		
		try {
			map = HttpUtil.post(changHongProperties.getPassUrl(PassPortName.DEF_SEACHE, null)
						, null,workflowTool.getProcess(maps).getFlowmap()
						, null,  new TypeReference<Map<String,Object>>(){}.getType());
			// System.out.println("最后参数"+JSONTool.toJson(workflowTool.getProcess(maps).getFlowmap()));
			return map;
		} catch (Exception e) {
			throw new IEMRuntimeException(C0002).setchildIEMExc(changHongProperties.getPassUrl(PassPortName.FIND_TENANT_ORGANIZATION, null));
		}
	}
	
	/**
	 * 创建流程定义
	 */
	@Override
	public Map<String, Object> defineCreate(Map<String,Object> maps) throws TimeoutException {
		Map<String,Object> map =  null;
		// System.out.println("进入方法2");
		// System.out.println("参数："+JSONTool.toJson(maps));
		// System.out.println("入口参数"+ changHongProperties.getPassUrl(PassPortName.DEF_CREATE, null));
		
		try {
			map = HttpUtil.post(changHongProperties.getPassUrl(PassPortName.DEF_CREATE, null)
						, null,workflowTool.getProcess(maps).getFlowmap()
						, null,  new TypeReference<Map<String,Object>>(){}.getType());
			// System.out.println("最后参数"+JSONTool.toJson(workflowTool.getProcess(maps).getFlowmap()));
			return map;
		} catch (Exception e) {
			throw new IEMRuntimeException(C0002).setchildIEMExc(changHongProperties.getPassUrl(PassPortName.FIND_TENANT_ORGANIZATION, null));
		}
	}
	
	/**
	 * 退回流程实例
	 */
	@Override
	public Map<String, Object> instBack(Map<String,Object> maps) throws TimeoutException {
		Map<String,Object> map =  null;		
		try {
			map = HttpUtil.post(changHongProperties.getPassUrl(PassPortName.INST_BACK, null)
						, null,workflowTool.getProcess(maps).getFlowmap()
						, null,  new TypeReference<Map<String,Object>>(){}.getType());
			// System.out.println("最后参数"+JSONTool.toJson(workflowTool.getProcess(maps).getFlowmap()));
			return map;
		} catch (Exception e) {
			throw new IEMRuntimeException(C0002).setchildIEMExc(changHongProperties.getPassUrl(PassPortName.FIND_TENANT_ORGANIZATION, null));
		}
	}
	
	/**
	 * 设置代理
	 */
	@Override
	public Map<String, Object> agentCreat(Map<String,Object> maps) throws TimeoutException {
		Map<String,Object> map =  null;		
		try {
			map = HttpUtil.post(changHongProperties.getPassUrl(PassPortName.CREATE_AGENT, null)
						, null,workflowTool.getProcess(maps).getFlowmap()
						, null,  new TypeReference<Map<String,Object>>(){}.getType());
			// System.out.println("最后参数"+JSONTool.toJson(workflowTool.getProcess(maps).getFlowmap()));
			return map;
		} catch (Exception e) {
			throw new IEMRuntimeException(C0002).setchildIEMExc(changHongProperties.getPassUrl(PassPortName.FIND_TENANT_ORGANIZATION, null));
		}
	}
	
	/**
	 * 创建流程实例
	 */
	@Override
	public Map<String, Object> instCreat(Map<String,Object> maps) throws TimeoutException {
		Map<String,Object> map =  null;		
		try {
			map = HttpUtil.post(changHongProperties.getPassUrl(PassPortName.INST_CREATE, null)
						, null,workflowTool.getProcess(maps).getFlowmap()
						, null,  new TypeReference<Map<String,Object>>(){}.getType());
			// System.out.println("最后参数"+JSONTool.toJson(workflowTool.getProcess(maps).getFlowmap()));
			return map;
		} catch (Exception e) {
			throw new IEMRuntimeException(C0002).setchildIEMExc(changHongProperties.getPassUrl(PassPortName.FIND_TENANT_ORGANIZATION, null));
		}
	}

	/**
	 * 撤销流程实例
	 */
	@Override
	public Map<String, Object> instDrawBack(Map<String,Object> maps) throws TimeoutException {
		Map<String,Object> map =  null;		
		try {
			map = HttpUtil.post(changHongProperties.getPassUrl(PassPortName.INST_DRAWBACK, null)
						, null,workflowTool.getProcess(maps).getFlowmap()
						, null,  new TypeReference<Map<String,Object>>(){}.getType());
			// System.out.println("最后参数"+JSONTool.toJson(workflowTool.getProcess(maps).getFlowmap()));
			return map;
		} catch (Exception e) {
			throw new IEMRuntimeException(C0002).setchildIEMExc(changHongProperties.getPassUrl(PassPortName.FIND_TENANT_ORGANIZATION, null));
		}
	}

	/**
	 * 结束流程实例
	 */
	@Override
	public Map<String, Object> instOver(Map<String,Object> maps) throws TimeoutException {
		Map<String,Object> map =  null;		
		try {
			map = HttpUtil.post(changHongProperties.getPassUrl(PassPortName.INST_OVER, null)
						, null,workflowTool.getProcess(maps).getFlowmap()
						, null,  new TypeReference<Map<String,Object>>(){}.getType());
			// System.out.println("最后参数"+JSONTool.toJson(workflowTool.getProcess(maps).getFlowmap()));
			return map;
		} catch (Exception e) {
			throw new IEMRuntimeException(C0002).setchildIEMExc(changHongProperties.getPassUrl(PassPortName.FIND_TENANT_ORGANIZATION, null));
		}
	}
	
	/**
	 * 设置代办
	 */
	@Override
	public Map<String, Object> chargeCreate(Map<String,Object> maps) throws TimeoutException {
		Map<String,Object> map =  null;		
		try {
			map = HttpUtil.post(changHongProperties.getPassUrl(PassPortName.CREATE_CHARGE, null)
						, null,workflowTool.getProcess(maps).getFlowmap()
						, null,  new TypeReference<Map<String,Object>>(){}.getType());
			// System.out.println("最后参数"+JSONTool.toJson(workflowTool.getProcess(maps).getFlowmap()));
			return map;
		} catch (Exception e) {
			throw new IEMRuntimeException(C0002).setchildIEMExc(changHongProperties.getPassUrl(PassPortName.FIND_TENANT_ORGANIZATION, null));
		}
	}

	/**
	 * 执行流程实例
	 */
	@Override
	public Map<String, Object> instFinish(Map<String,Object> maps) throws TimeoutException {
		Map<String,Object> map =  null;		
		
		try {
			map = HttpUtil.post(changHongProperties.getPassUrl(PassPortName.INST_FINISH, null)
						, null,workflowTool.getProcess(maps).getFlowmap()
						, null,  new TypeReference<Map<String,Object>>(){}.getType());
			// System.out.println("最后参数"+JSONTool.toJson(workflowTool.getProcess(maps).getFlowmap()));
			return map;
		} catch (Exception e) {
			throw new IEMRuntimeException(C0002).setchildIEMExc(changHongProperties.getPassUrl(PassPortName.FIND_TENANT_ORGANIZATION, null));
		}
	}

	/**
	 * 查询流程待办
	 */
	@Override
	public Map<String, Object> instSeacheHandle(Map<String,Object> maps) throws TimeoutException {
		Map<String,Object> map;
		try {
			maps.put("tenantId", ThreadData.get(Keys.TENANT_ID));
			maps.put("compId", ThreadData.get(Keys.COMPANY_ID));
			maps.put("appId", SpringUtil.getBean(ChangHongProperties.class).getProcessServiceId());
			maps.put("openId", Context.getOpenId());
			maps.put("sourceSystem", "epc");
			map = HttpUtil.post(changHongProperties.getPassUrl(PassPortName.SEACHE_HANDLE, null)
						, null,workflowTool.getProcess(maps).getFlowmap()
						, null,  new TypeReference<Map<String,Object>>(){}.getType());
			// System.out.println("最后参数"+JSONTool.toJson(workflowTool.getProcess(maps).getFlowmap()));
			return map;
		} catch (Exception e) {
			throw new IEMRuntimeException(C0002).setchildIEMExc(changHongProperties.getPassUrl(PassPortName.FIND_TENANT_ORGANIZATION, null));
		}
	}
	
	/**
	 * 流程实例log(参数为空即查询所有)
	 */
	@Override
	public Map<String, Object> instLog(Map<String,Object> maps) throws TimeoutException {
		Map<String,Object> map =  null;		
		try {
			map = HttpUtil.post(changHongProperties.getPassUrl(PassPortName.INST_LOG, null)
						, null,workflowTool.getProcess(maps).getFlowmap()
						, null,  new TypeReference<Map<String,Object>>(){}.getType());
			// System.out.println("最后参数"+JSONTool.toJson(workflowTool.getProcess(maps).getFlowmap()));
			return map;
		} catch (Exception e) {
			throw new IEMRuntimeException(C0002).setchildIEMExc(changHongProperties.getPassUrl(PassPortName.FIND_TENANT_ORGANIZATION, null));
		}
	}

	/**
	 * 获取所有可退回项目
	 */
	@Override
	public Map<String, Object> getBack(Map<String,Object> maps) throws TimeoutException {
		Map<String,Object> map =  null;		
		try {
			map = HttpUtil.post(changHongProperties.getPassUrl(PassPortName.GET_BACK, null)
						, null,workflowTool.getProcess(maps).getFlowmap()
						, null,  new TypeReference<Map<String,Object>>(){}.getType());
			// System.out.println("最后参数"+JSONTool.toJson(workflowTool.getProcess(maps).getFlowmap()));
			return map;
		} catch (Exception e) {
			throw new IEMRuntimeException(C0002).setchildIEMExc(changHongProperties.getPassUrl(PassPortName.FIND_TENANT_ORGANIZATION, null));
		}
	}

	/**
	 * 查询代理(参数为空即查询所有信息)
	 */
	@Override
	public Map<String, Object> instAgent(Map<String,Object> maps) throws TimeoutException {
		Map<String,Object> map =  null;		
		try {
			map = HttpUtil.post(changHongProperties.getPassUrl(PassPortName.INST_AGENT, null)
						, null,workflowTool.getProcess(maps).getFlowmap()
						, null,  new TypeReference<Map<String,Object>>(){}.getType());
			// System.out.println("最后参数"+JSONTool.toJson(workflowTool.getProcess(maps).getFlowmap()));
			return map;
		} catch (Exception e) {
			throw new IEMRuntimeException(C0002).setchildIEMExc(changHongProperties.getPassUrl(PassPortName.FIND_TENANT_ORGANIZATION, null));
		}
	}

	/**
	 * 查询代理去除流程定义信息
	 */
	@Override
	public Map<String, Object> instAgentDefMsg(Map<String,Object> maps) throws TimeoutException {
		Map<String,Object> map =  null;		
		try {
			map = HttpUtil.post(changHongProperties.getPassUrl(PassPortName.AGENT_DEFMSG, null)
						, null,workflowTool.getProcess(maps).getFlowmap()
						, null,  new TypeReference<Map<String,Object>>(){}.getType());
			// System.out.println("最后参数"+JSONTool.toJson(workflowTool.getProcess(maps).getFlowmap()));
			return map;
		} catch (Exception e) {
			throw new IEMRuntimeException(C0002).setchildIEMExc(changHongProperties.getPassUrl(PassPortName.FIND_TENANT_ORGANIZATION, null));
		}
	}

	/**
	 * 查询流程实例(参数都为空，即查询所有)
	 */
	@Override
	public Map<String, Object> instSeache(Map<String,Object> maps) throws TimeoutException {
		Map<String,Object> map =  null;		
		try {
			maps.put("sourceSystem", "epc");
			maps.put("openId", Context.getOpenId());
			map = HttpUtil.post(changHongProperties.getPassUrl(PassPortName.INST_SEACHE, null)
						, null,workflowTool.getProcess(maps).getFlowmap()
						, null,  new TypeReference<Map<String,Object>>(){}.getType());
			// System.out.println("最后参数"+JSONTool.toJson(workflowTool.getProcess(maps).getFlowmap()));
			return map;
		} catch (Exception e) {
			throw new IEMRuntimeException(C0002).setchildIEMExc(changHongProperties.getPassUrl(PassPortName.FIND_TENANT_ORGANIZATION, null));
		}
	}

	/**
	 * 租户注册系统
	 */
	@Override
	public Map<String, Object> appCreate(Map<String,Object> maps) throws TimeoutException {
		Map<String,Object> map =  null;		
		try {
			map = HttpUtil.post(changHongProperties.getPassUrl(PassPortName.APP_CREATE, null)
						, null,workflowTool.getProcess(maps).getFlowmap()
						, null,  new TypeReference<Map<String,Object>>(){}.getType());
			// System.out.println("最后参数"+JSONTool.toJson(workflowTool.getProcess(maps).getFlowmap()));
			return map;
		} catch (Exception e) {
			throw new IEMRuntimeException(C0002).setchildIEMExc(changHongProperties.getPassUrl(PassPortName.FIND_TENANT_ORGANIZATION, null));
		}
	}

	@Override
	public Integer initialization(Integer tenantId, Integer companyId) {
		if(check(tenantId, companyId)){
			return 1;
		}
		return Http.post(changHongProperties.getPassUrl(PassPortName.UBP_INITIALIZATION, null), Map.class)
				.addUrlParam(workflowTool.getProcess(
							new ModelMap("tenantId", tenantId)
							.addAttribute("companyId", companyId)
							.addAttribute("serviceId", changHongProperties.getProcessServiceId())
						).getChackmap()
				)
				.addValidate(res->{
					if(!Objects.equals(res.get("resCode"), "00000")){
						throw new IEMHttpException(Objects.toString(res.get("resMsg")));
					}
				})
				.execute(new TypeReference<Map<String, String>>(){}.getType())
				.map(res->res.get("data"))
				.map(Object::toString)
				.map(Integer::valueOf)
				.orElse(0);
	}

	@Override
	public Boolean check(Integer tenantId, Integer companyId) {
		return Http.post(changHongProperties.getPassUrl(PassPortName.UBP_CHECK, null), Map.class)
				.addUrlParam(workflowTool.getProcess(
						new ModelMap("tenantId", tenantId)
								.addAttribute("companyId", companyId)
								.addAttribute("serviceId", changHongProperties.getProcessServiceId())
						).getChackmap()
				)
				.addValidate(res->{
					if(!Objects.equals(res.get("resCode"), "00000")){
						throw new IEMHttpException(Objects.toString(res.get("resMsg")));
					}
				})
				.execute(new TypeReference<Map<String, String>>(){}.getType())
				.map(res->res.get("data"))
				.map(Object::toString)
				.map(Boolean::valueOf)
				.orElse(false);
	}

}