package cn.autoform.web.client.impl;

import cn.autoform.bean.*;
import cn.autoform.bean.page.PageResult;
import cn.autoform.bean.power.PowerButton;
import cn.autoform.bean.system.UserInfo;
import cn.autoform.db.entity.IpAndPortEntity;
import cn.autoform.db.exten.SelectForm;
import cn.autoform.db.exten.ServicesFormData;
import cn.autoform.db.exten.TableStructure;
import cn.autoform.fw.exception.FormClientException;
import cn.autoform.fw.exception.FormClientTimeout;
import cn.autoform.fw.exception.RestResult;
import cn.autoform.log.bean.OperationLog;
import cn.autoform.util.tool.GetFormClientResult;
import cn.autoform.util.tool.JSONTool;
import cn.autoform.util.tool.ObjectUtil;
import cn.autoform.util.tool.RequestContext;
import cn.autoform.web.client.FormClient;
import cn.autoform.web.client.util.HttpClientTool;
import cn.autoform.web.client.util.IpAndPortTool;
import com.alibaba.fastjson.TypeReference;
import com.iemsoft.framework.cloud.core.tools.http.Http;
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;

@Service
public class FormClientImpl implements FormClient {

    @Value("${autoForm.businessSystem}")
    private String autoFormClient;

    @Autowired
    IpAndPortTool ipAndPortTool;

    private static final Map<String, String> ipMap = new HashMap<>();

    public static final String CLIENT_CONTEXT_PATH = "/auto-form-client";

    static {
        ipMap.put("dataInsert", "%s/epc/epc-form" + CLIENT_CONTEXT_PATH + "/data/insert");
        ipMap.put("impDatas", "%s/epc/epc-form" + CLIENT_CONTEXT_PATH + "/data/impDatas");
        ipMap.put("dataUpdate", "%s/epc/epc-form" + CLIENT_CONTEXT_PATH + "/data/update");
        ipMap.put("dataDelete", "%s/epc/epc-form" + CLIENT_CONTEXT_PATH + "/data/delete");
        ipMap.put("dataSelectAll", "%s/epc/epc-form" + CLIENT_CONTEXT_PATH + "/data/selectAll");
        ipMap.put("dataSelectPage", "%s/epc/epc-form" + CLIENT_CONTEXT_PATH + "/data/selectPage");
        ipMap.put("dataSelectOne", "%s/epc/epc-form" + CLIENT_CONTEXT_PATH + "/data/selectOne");
        ipMap.put("createTable", "%s/epc/epc-form" + CLIENT_CONTEXT_PATH + "/create/table");
        ipMap.put("updateTable", "%s/epc/epc-form" + CLIENT_CONTEXT_PATH + "/update/table");
        ipMap.put("selectFormValue", "%s/epc/epc-form" + CLIENT_CONTEXT_PATH + "/select/formFieldMainValue");
        ipMap.put("getAssociateDataSourse", "%s/epc/epc-form" + CLIENT_CONTEXT_PATH + "/select/associateDataSourse");
        ipMap.put("getAssociateData", "%s/epc/epc-form" + CLIENT_CONTEXT_PATH + "/select/associateData");
        ipMap.put("getAssociateTitle", "%s/epc/epc-form" + CLIENT_CONTEXT_PATH + "/select/associateTitle");
        ipMap.put("operationLog", "%s/epc/epc-form" + "/form/operationLog");

        ipMap.put("workFlowOver", "%s/epc/epc-form" + CLIENT_CONTEXT_PATH + "/WorkFlow/over");
        ipMap.put("workFlowBefor", "%s/epc/epc-form" + CLIENT_CONTEXT_PATH + "/WorkFlow/befor");
        ipMap.put("workFlowAfter", "%s/epc/epc-form" + CLIENT_CONTEXT_PATH + "/WorkFlow/after");
        ipMap.put("workFlowRollback", "%s/epc/epc-form" + CLIENT_CONTEXT_PATH + "/WorkFlow/rollback");
        ipMap.put("workFlowCreate", "%s/epc/epc-form" + CLIENT_CONTEXT_PATH + "/WorkFlow/create");

        ipMap.put("budget", "%s/epc/epc-form" + CLIENT_CONTEXT_PATH + "/form/data/budget");
        ipMap.put("getUserInfo", "%s/epc/epc-tenant/tenant/getUserCode");
//		ipMap.put("getHigorg", "%s/epc/epc-tenant/tenant/data/budget");
        ipMap.put("getCode", "%s/epc/epc-form" + CLIENT_CONTEXT_PATH + "/select/higCode");
        ipMap.put("getUserName", "%s/epc/epc-form" + CLIENT_CONTEXT_PATH + "/data/getUserName");
        ipMap.put("updateState", "%s/epc/epc-form/form/data/updateState"); //费用云内部请求
        ipMap.put("selectState", "%s/epc/epc-form/form/data/selectState"); //费用云内部请求
        ipMap.put("getAllButton", "%s/epc/epc-form/form/button/getAllButton");//费用云 自定义按钮权限
        ipMap.put("formSolidiFication", "%s/epc/epc-form/data/formSolidiFication");//单据固化
        ipMap.put("addExcelLog", "%s/epc/epc-form/form/excel/addExcelLog");
        ipMap.put("updateExcelLog", "%s/epc/epc-form/form/excel/updateExcelLog");
        ipMap.put("selectLog", "%s/epc/epc-form/form/select/operationLog");//操作日志查询接口
//		ipMap.put("dataInsert", "%s/data/insert");
//		ipMap.put("dataUpdate", "%s/data/update");
//		ipMap.put("dataDelete", "%s/data/delete");
//		ipMap.put("dataSelectAll", "%s/data/selectAll");
//		ipMap.put("dataSelectPage", "%s/data/selectPage");
//		ipMap.put("dataSelectOne", "%s/data/selectOne");
//		ipMap.put("createTable", "%s/create/table");
//		ipMap.put("updateTable", "%s/update/table");
//		ipMap.put("selectFormValue", "%s/select/formFieldMainValue");
//		ipMap.put("getAssociateDataSourse", "%s/select/associateDataSourse");
//		ipMap.put("getAssociateData", "%s/select/associateData");
//		ipMap.put("getAssociateTitle", "%s/select/associateTitle");
    }

    @SuppressWarnings({"unchecked", "rawtypes"})
    @Override
    public Object addFormDataClient(ServicesFormData formData) throws TimeoutException, FormClientException {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        HttpClientTool<RestResult> hc = new HttpClientTool(String.format(ipMap.get("dataInsert"), ipAndPortEntity.getIp()));
        hc.setBodyInfos(formData);
        RestResult result = hc.sendPost(
                j -> JSONTool.toObj(j, new TypeReference<RestResult>() {
                }));
        return GetFormClientResult.getRightResult(result);
    }
    @SuppressWarnings({"unchecked", "rawtypes"})
    @Override
    public PageResult<List<OperationLog>> selectOperationLog(Map<String,Object> map) throws TimeoutException, FormClientException {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        HttpClientTool<RestResult> hc = new HttpClientTool(String.format(ipMap.get("selectLog"), ipAndPortEntity.getIp()));
        hc.setBodyInfos(map);
        RestResult result = hc.sendPost(
                j -> JSONTool.toObj(j, new TypeReference<RestResult>() {
                }));
        return GetFormClientResult.getRightResult(result);
    }
    @Override
    public Object addOperationLog(Map<String,String> map) throws TimeoutException, FormClientException {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        HttpClientTool<RestResult> hc = new HttpClientTool(String.format(ipMap.get("operationLog"), ipAndPortEntity.getIp()));
        hc.setBodyInfos(map);
        RestResult result = hc.sendPost(
                j -> JSONTool.toObj(j, new TypeReference<RestResult>() {
                }));
        return GetFormClientResult.getRightResult(result);
    }

    @SuppressWarnings({"unchecked", "rawtypes"})
    @Override
    public String mmp(String org) throws TimeoutException, FormClientException {
        Map<String, String> map = new HashMap<String, String>();
        map.put("code", org);
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        HttpClientTool<RestResult> hc = new HttpClientTool(String.format(ipMap.get("getCode"), ipAndPortEntity.getIp()));
        hc.setBodyInfos(map);
        RestResult result = hc.sendPost(
                j -> JSONTool.toObj(j, new TypeReference<RestResult>() {
                }));
        Map<String, Object> res = JSONTool.toObj(JSONTool.toJson(result.getData()), Map.class);
        Object a = res.get("data");
        if (a != null) {
            Map<String, String> orgs = JSONTool.toObj(JSONTool.toJson(a), Map.class);
            return orgs.get("parentCode");
        }
        return null;
    }

    @SuppressWarnings({"unchecked", "rawtypes"})
    @Override
    public void updateFormDataClient(ServicesFormData formData) throws TimeoutException, FormClientException {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        HttpClientTool<RestResult> hc = new HttpClientTool(String.format(ipMap.get("dataUpdate"), ipAndPortEntity.getIp()));
        hc.setBodyInfos(formData);
        System.out.println("回写状态:" + JSONTool.toJson(formData));
        RestResult result = hc.sendPost(
                j -> JSONTool.toObj(j, new TypeReference<RestResult>() {
                }));
        GetFormClientResult.getRightResult(result);
    }

    @SuppressWarnings({"rawtypes", "unchecked"})
    @Override
    public void deleteFormDataClient(ServicesFormData formData) throws TimeoutException, FormClientException {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        HttpClientTool<RestResult> hc = new HttpClientTool(String.format(ipMap.get("dataDelete"), ipAndPortEntity.getIp()));
        hc.setBodyInfos(formData);
        RestResult result = hc.sendPost(
                j -> JSONTool.toObj(j, new TypeReference<RestResult>() {
                }));
        GetFormClientResult.getRightResult(result);
    }

    @SuppressWarnings({"rawtypes", "unchecked"})
    @Override
    public List<Map<String, Object>> queryFormDataList(SelectForm selectForm) throws FormClientException {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        HttpClientTool<RestResult<List<Map<String, Object>>>> hc = new HttpClientTool(String.format(ipMap.get("dataSelectAll"), ipAndPortEntity.getIp()));
        hc.setBodyInfos(selectForm);
        RestResult<List<Map<String, Object>>> result;
        try {
            result = hc.sendPost(
                    j -> JSONTool.toObj(j, new TypeReference<RestResult<List<Map<String, Object>>>>() {
                    }));
            return GetFormClientResult.getRightResult(result);
        } catch (TimeoutException e) {
            throw new FormClientTimeout();
        }
    }

    @SuppressWarnings({"rawtypes", "unchecked"})
    @Override
    public Map<String, Object> queryFormDataOne(SelectForm selectForm) throws TimeoutException, FormClientException {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        HttpClientTool<RestResult<Map<String, Object>>> hc = new HttpClientTool(String.format(ipMap.get("dataSelectOne"), ipAndPortEntity.getIp()));
        hc.setBodyInfos(selectForm);
        RestResult<Map<String, Object>> result = hc.sendPost(
                j -> JSONTool.toObj(j, new TypeReference<RestResult<Map<String, Object>>>() {
                }.getType()));
        return GetFormClientResult.getRightResult(result);
    }

    @SuppressWarnings({"rawtypes", "unchecked"})
    @Override
    public PageResult<Map<String, Object>> queryFormDataPage(SelectForm selectForm) throws FormClientException {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        HttpClientTool<RestResult<PageResult<Map<String, Object>>>> hc = new HttpClientTool(String.format(ipMap.get("dataSelectPage"), ipAndPortEntity.getIp()));
        hc.setBodyInfos(selectForm);
        try {
            return GetFormClientResult.getRightResult(hc.sendPost(
                    j -> JSONTool.toObj(j, new TypeReference<RestResult<PageResult<Map<String, Object>>>>() {
                    })));
        } catch (TimeoutException e) {
            e.printStackTrace();
            throw new FormClientTimeout();
        }

    }

    @SuppressWarnings({"rawtypes", "unchecked"})
    @Override
    public void createTable(TableStructure tableStructure) throws TimeoutException, FormClientException {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
//		System.out.println(JSONTool.toJson(tableStructure));
//		System.out.println(String.format(ipMap.get("createTable"), ipAndPortEntity.getIp()));
        HttpClientTool<RestResult<Integer>> hc = new HttpClientTool(String.format(ipMap.get("createTable"), ipAndPortEntity.getIp()));
        hc.setBodyInfos(tableStructure);
        GetFormClientResult.getRightResult(hc.sendPost(
                j -> JSONTool.toObj(j, new TypeReference<RestResult<Integer>>() {
                })));
    }

    @SuppressWarnings({"rawtypes", "unchecked"})
    @Override
    public void updateTable(TableStructure tableStructure) throws Exception {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        HttpClientTool<RestResult<Integer>> hc = new HttpClientTool(String.format(ipMap.get("updateTable"), ipAndPortEntity.getIp()));
        hc.setBodyInfos(tableStructure);
        hc.sendPost(
                j -> JSONTool.toObj(j, new TypeReference<RestResult<Integer>>() {
                }));
//		 GetFormClientResult.getRightResult();
    }

    @SuppressWarnings({"rawtypes", "unchecked"})
    @Override
    public List<String> getFormFieldMainValue(String field, String tableName, String formID, String tenantID) throws TimeoutException, FormClientException {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        HttpClientTool<RestResult<List<String>>> hc = new HttpClientTool(String.format(ipMap.get("selectFormValue"), ipAndPortEntity.getIp()));
        Map<String, String> BodyInfos = new HashMap<>();
        BodyInfos.put("field", field);
        BodyInfos.put("tableName", tableName);
        hc.setBodyInfos(BodyInfos);
        RestResult<List<String>> result = hc.sendPost(
                j -> JSONTool.toObj(j, new TypeReference<RestResult<List<String>>>() {
                }));
        return GetFormClientResult.getRightResult(result);
    }

    @SuppressWarnings({"rawtypes", "unchecked"})
    @Override
    public List<Map<String, Object>> getAssociateDataSourse() throws TimeoutException, FormClientException {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        HttpClientTool<RestResult<List<Map<String, Object>>>> hc = new HttpClientTool(String.format(ipMap.get("getAssociateDataSourse"), ipAndPortEntity.getIp()));
        RestResult<List<Map<String, Object>>> result = hc.sendPost(
                j -> JSONTool.toObj(j, new TypeReference<RestResult<List<Map<String, Object>>>>() {
                }));
        return GetFormClientResult.getRightResult(result);
    }

    @SuppressWarnings({"unchecked", "rawtypes"})
    @Override
    public Map<String, Object> getAssociateData(BudgetData budgetData) throws TimeoutException, FormClientException {
        System.err.println(JSONTool.toJson(budgetData));
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        HttpClientTool<RestResult<Map<String, Object>>> hc = new HttpClientTool(String.format(ipMap.get("getAssociateData"), ipAndPortEntity.getIp()));
        hc.setBodyInfos(budgetData);
        RestResult<Map<String, Object>> result = hc.sendPost(
                j -> JSONTool.toObj(j, new TypeReference<RestResult<Map<String, Object>>>() {
                }));
        return GetFormClientResult.getRightResult(result);
    }

    @SuppressWarnings("rawtypes")
    @Override
    public List<BudgetTitle> getAssociateTitle(Map<String, Object> key) throws TimeoutException, FormClientException {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        @SuppressWarnings("unchecked")
        HttpClientTool<RestResult<List<BudgetTitle>>> hc = new HttpClientTool(String.format(ipMap.get("getAssociateTitle"), ipAndPortEntity.getIp()));
        hc.setBodyInfos(key);
        RestResult<List<BudgetTitle>> result = hc.sendPost(
                j -> JSONTool.toObj(j, new TypeReference<RestResult<List<BudgetTitle>>>() {
                }));
        return GetFormClientResult.getRightResult(result);
    }

    @SuppressWarnings("rawtypes")
    @Override
    public Object getBudget(ProcessBudget processBudget) throws TimeoutException, FormClientException {
        System.err.println(JSONTool.toJson(processBudget));
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        @SuppressWarnings("unchecked")
        HttpClientTool<RestResult<Object>> hc = new HttpClientTool(String.format(ipMap.get("budget"), ipAndPortEntity.getIp()));
        hc.setBodyInfos(processBudget);
        RestResult<Object> result = hc.sendPost(
                j -> JSONTool.toObj(j, new TypeReference<RestResult<Object>>() {
                }));
        return GetFormClientResult.getRightResult(result);
    }

    @SuppressWarnings({"unchecked", "rawtypes"})
    @Override
    public void workFlowOver(WorkFlowStateEntity workFlowStateEntity) throws TimeoutException, FormClientException {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        RestResult<Object> result = (RestResult<Object>)
                Http.post(String.format(ipMap.get("workFlowOver"), ipAndPortEntity.getIp()), RestResult.class)
                        .addBody(workFlowStateEntity)
                        .addHeader(RequestContext.getHeader())
                        .execute(new TypeReference<RestResult<Object>>() {
                        }.getType())
                        .orElse(RestResult.newInstance());
        GetFormClientResult.getRightResult(result);

    }

    @Override
    public void workFlowAfter(WorkFlowStateEntity workFlowStateEntity) throws TimeoutException, FormClientException {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        RestResult<Object> result = (RestResult<Object>)
                Http.post(String.format(ipMap.get("workFlowAfter"), ipAndPortEntity.getIp()), RestResult.class)
                        .addBody(workFlowStateEntity)
                        .addHeader(RequestContext.getHeader())
                        .execute(new TypeReference<RestResult<Object>>() {
                        }.getType())
                        .orElse(RestResult.newInstance());
        GetFormClientResult.getRightResult(result);
    }

    @Override
    public void workFlowBefor(WorkFlowStateEntity workFlowStateEntity) throws TimeoutException, FormClientException {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        RestResult<Object> result = (RestResult<Object>)
                Http.post(String.format(ipMap.get("workFlowBefor"), ipAndPortEntity.getIp()), RestResult.class)
                        .addBody(workFlowStateEntity)
                        .addHeader(RequestContext.getHeader())
                        .execute(new TypeReference<RestResult<Object>>() {
                        }.getType())
                        .orElse(RestResult.newInstance());
        GetFormClientResult.getRightResult(result);
    }

    @SuppressWarnings("rawtypes")
    @Override
    public String getUserName(String formID, String tenantID, Integer dataRowNum) throws TimeoutException, FormClientException {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        @SuppressWarnings("unchecked")
        HttpClientTool<RestResult<String>> hc = new HttpClientTool(String.format(ipMap.get("getUserName"), ipAndPortEntity.getIp()));
        hc.setBodyInfos(new ModelMap("formID", formID)
                .addAttribute("tenantID", tenantID)
                .addAttribute("dataRowNum", dataRowNum)
                .addAttribute("formName", "formdata_" + tenantID + "_" + formID));
        RestResult<String> result = hc.sendPost(
                j -> JSONTool.toObj(j, new TypeReference<RestResult<String>>() {
                }));
        return GetFormClientResult.getRightResult(result);
    }

    @SuppressWarnings("rawtypes")
    @Override
    public int updateState(ProcessState process) throws FormClientException, TimeoutException {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        Map<String, Object> result = (Map<String, Object>)
                Http.post(String.format(ipMap.get("updateState"), ipAndPortEntity.getIp()), Map.class)
                        .addBody(process)
                        .addHeader(RequestContext.getHeader())
                        .execute(new TypeReference<Map<String, Object>>() {
                        }.getType())
                        .orElse(Collections.EMPTY_MAP);
        return Integer.parseInt(Objects.toString(JSONTool.toJson(result.get("data")), "-1"));
    }

    @Override
    public ProcessState selectState(ProcessState process) throws TimeoutException {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        HttpClientTool<Map<String, Object>> hc = new HttpClientTool<Map<String, Object>>(String.format(ipMap.get("selectState"), ipAndPortEntity.getIp()));
        hc.setBodyInfos(process);
        Map<String, Object> result = hc.sendPost(
                j -> JSONTool.toObj(j, new TypeReference<Map<String, Object>>() {
                }));
        System.out.println("查询返回结果:" + JSONTool.toJson(result));
        Object o = result.get("data");
        if (!ObjectUtil.empty(o)) {
            return JSONTool.toObj(JSONTool.toJson(o), ProcessState.class);
        } else {
            return null;
        }
    }

    @Override
    public PowerButton getAllButton(String formId, ProcessState state) throws TimeoutException {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        HttpClientTool<Map<String, Object>> hc = new HttpClientTool<Map<String, Object>>(String.format(ipMap.get("getAllButton"), ipAndPortEntity.getIp()));
        hc.setBodyInfos(new ModelMap("formId", formId).addAttribute("state", state));
        Map<String, Object> result = hc.sendPost(
                j -> JSONTool.toObj(j, new TypeReference<Map<String, Object>>() {
                }));
        Object obj = result.get("data");
        return JSONTool.toObj(JSONTool.toJson(obj), PowerButton.class);
    }

    @Override
    public int formSolidiFication(FormSolidiFication map) throws TimeoutException {
        @SuppressWarnings("unchecked")
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        HttpClientTool<Map<String, Object>> hc = new HttpClientTool<Map<String, Object>>(String.format(ipMap.get("formSolidiFication"), ipAndPortEntity.getIp()));
        hc.setBodyInfos(map);
        Map<String, Object> ma = hc.sendPost(
                j -> JSONTool.toObj(j, new TypeReference<Map<String, Object>>() {
                }));
        return Integer.parseInt(Objects.toString(ma.get("data"), "-1"));
    }

    @Override
    public Integer impDatas(List<ServicesFormData> allFormDataList) throws TimeoutException {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        HttpClientTool<Map<String, Object>> hc = new HttpClientTool<Map<String, Object>>(String.format(ipMap.get("impDatas"), ipAndPortEntity.getIp()));
        hc.setBodyInfos(allFormDataList);
        Map<String, Object> ma = hc.sendPost(
                j -> JSONTool.toObj(j, new TypeReference<Map<String, Object>>() {
                }));
        return Integer.parseInt(Objects.toString(ma.get("data"), "-1"));
    }

    @Override
    public Integer addExcelLog(ExcelLog excelLog) throws TimeoutException {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        HttpClientTool<Map<String, Object>> hc = new HttpClientTool<Map<String, Object>>(String.format(ipMap.get("addExcelLog"), ipAndPortEntity.getIp()));
        hc.setBodyInfos(excelLog);
        Map<String, Object> ma = hc.sendPost(
                j -> JSONTool.toObj(j, new TypeReference<Map<String, Object>>() {
                }));
        return Integer.parseInt(Objects.toString(ma.get("data"), "-1"));
    }

    @Override
    public Integer updateExcelLog(ExcelLog excelLog) throws TimeoutException {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        HttpClientTool<Map<String, Object>> hc = new HttpClientTool<Map<String, Object>>(String.format(ipMap.get("updateExcelLog"), ipAndPortEntity.getIp()));
        hc.setBodyInfos(excelLog);
        Map<String, Object> ma = hc.sendPost(
                j -> JSONTool.toObj(j, new TypeReference<Map<String, Object>>() {
                }));
        return Integer.parseInt(Objects.toString(ma.get("data"), "-1"));
    }

    @Override
    public void workFlowRollback(WorkFlowStateEntity workFlowStateEntity) {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        RestResult<Object> result = (RestResult<Object>)
                Http.post(String.format(ipMap.get("workFlowRollback"), ipAndPortEntity.getIp()), RestResult.class)
                        .addBody(workFlowStateEntity)
                        .addHeader(RequestContext.getHeader())
                        .execute(new TypeReference<RestResult<Object>>() {
                        }.getType())
                        .orElse(RestResult.newInstance());
        GetFormClientResult.getRightResult(result);
    }

    @Override
    public void workFlowCreate(WorkFlowStateEntity workFlowStateEntity) {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        RestResult<Object> result = (RestResult<Object>)
                Http.post(String.format(ipMap.get("workFlowCreate"), ipAndPortEntity.getIp()), RestResult.class)
                        .addBody(workFlowStateEntity)
                        .addHeader(RequestContext.getHeader())
                        .execute(new TypeReference<RestResult<Object>>() {
                        }.getType())
                        .orElse(RestResult.newInstance());
        GetFormClientResult.getRightResult(result);
    }

    @Override
    public UserInfo getUserInfo() {
        IpAndPortEntity ipAndPortEntity = ipAndPortTool.queryIpAndPortByServiceName(autoFormClient);
        RestResult<UserInfo> result = (RestResult<UserInfo>)
                Http.post(String.format(ipMap.get("getUserInfo"), ipAndPortEntity.getIp()), RestResult.class)
                        .addBody(new UserInfo())
                        .addHeader(RequestContext.getHeader())
                        .execute(new TypeReference<RestResult<UserInfo>>() {
                        }.getType())
                        .orElse(RestResult.newInstance());
        GetFormClientResult.getRightResultGetUserCode(result);
        return  result.getData();
    }


}