package jnpf.flowable.model.flowable;

import com.alibaba.fastjson.JSONObject;
import jnpf.config.ConfigValueUtil;
import jnpf.constant.MsgCode;
import jnpf.exception.WorkFlowException;
import jnpf.util.JsonUtil;
import jnpf.util.StringUtil;
import jnpf.util.UserProvider;
import jnpf.util.text.CharsetKit;
import jnpf.util.wxutil.HttpUtil;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import java.net.URLDecoder;
import java.util.List;
import java.util.Map;

@Slf4j
@Component
@RequiredArgsConstructor
public class FlowAbleUrl {


    private final ConfigValueUtil configValueUtil;

    public static final String DEPLOYMENT_ID = "?deploymentId=";
    public static final String TASK_ID = "?taskId=";
    public static final String TASK_KEY = "&taskKey=";

    public String deployFlowAble(String flowXml, String key) throws WorkFlowException {
        String url = getFlowAbleUrl() + "/api/Flow/definition/deploy";
        FlowAbleForm flowAbleForm = new FlowAbleForm();
        flowAbleForm.setKey(key);
        try {
            flowAbleForm.setBpmnXml(URLDecoder.decode(flowXml, CharsetKit.UTF_8));
        } catch (Exception e) {
            flowAbleForm.setBpmnXml(flowXml);
        }
        JSONObject jsonObject = request(url, "POST", JsonUtil.getObjectToString(flowAbleForm));
        FlowAbleModel flowAbleModel = JsonUtil.getJsonToBean(jsonObject, FlowAbleModel.class);
        if (null == flowAbleModel) {
            log.error(MsgCode.WF090.get());
            throw new WorkFlowException(MsgCode.WF142.get());
        }
        if (Boolean.FALSE.equals(flowAbleModel.getSuccess())) {
            throw new WorkFlowException(flowAbleModel.getMsg());
        }
        FlowAbleData data = JsonUtil.getJsonToBean(flowAbleModel.getData(), FlowAbleData.class);
        return data.getDeploymentId();
    }

    private String getFlowAbleUrl() {
        return configValueUtil.getFlowDomain();
    }

    /**
     * 引擎 HTTP 调用统一出口：在原 HttpUtil.httpRequest 外记录往返耗时，
     * 日志标记 [flow-engine-timing]，与引擎侧 [engine-timing] 相减即 HTTP 编排开销，
     * 为"是否内嵌引擎"决策积累数据（tasks/handoff-20260609-flow-engine-perf.md）。
     * 异常与返回值原样透传，finally 只读计时不改变任何行为。
     */
    private JSONObject request(String url, String method, String body) {
        long start = System.nanoTime();
        JSONObject result = null;
        try {
            result = HttpUtil.httpRequest(url, method, body, UserProvider.getToken());
            return result;
        } finally {
            long costMs = (System.nanoTime() - start) / 1_000_000;
            log.info("[flow-engine-timing] {} {} {}ms success={}", method, endpointPattern(url), costMs, isBizSuccess(result));
        }
    }

    /**
     * 取 /api/Flow 起始的端点模式（去域名与 query，并把 ID 路径段规整为 {id}），
     * 使日志可按端点聚合、且不泄露实例/任务业务标识。
     */
    private String endpointPattern(String url) {
        int i = url.indexOf("/api/Flow");
        String path = i < 0 ? url : url.substring(i);
        int q = path.indexOf('?');
        if (q >= 0) {
            path = path.substring(0, q);
        }
        // UUID（引擎主键雪花/uuid）与纯数字段统一成 {id}，避免高基数
        return path.replaceAll("/[0-9a-fA-F]{8}-[0-9a-fA-F-]{27,}", "/{id}")
                   .replaceAll("/\\d{6,}", "/{id}");
    }

    /** 业务是否成功（success!=false 视为成功；null 响应记 false），供耗时日志区分慢与失败 */
    private boolean isBizSuccess(JSONObject result) {
        if (result == null) {
            return false;
        }
        Object success = result.get("success");
        return !Boolean.FALSE.equals(success);
    }

    /**
     * 启动流程实例
     *
     * @param deploymentId 引擎部署ID
     * @param variables    变量
     */
    public String startInstance(String deploymentId, Map<String, Object> variables) throws WorkFlowException {
        String url = getFlowAbleUrl() + "/api/Flow/instance/start";
        InstanceStartFo fo = new InstanceStartFo();
        fo.setDeploymentId(deploymentId);
        fo.setVariables(variables);
        JSONObject jsonObject = request(url, "POST", JsonUtil.getObjectToString(fo));
        FlowAbleModel flowAbleModel = JsonUtil.getJsonToBean(jsonObject, FlowAbleModel.class);
        if (null == flowAbleModel) {
            log.error(MsgCode.WF091.get());
            throw new WorkFlowException(MsgCode.WF142.get());
        }
        if (Boolean.FALSE.equals(flowAbleModel.getSuccess())) {
            throw new WorkFlowException(flowAbleModel.getMsg());
        }
        FlowAbleData data = JsonUtil.getJsonToBean(flowAbleModel.getData(), FlowAbleData.class);
        return data.getInstanceId();
    }

    /**
     * 获取当前任务
     *
     * @param instanceId 引擎实例ID
     */
    public List<FlowableTaskModel> getCurrentTask(String instanceId) throws WorkFlowException {
        String url = getFlowAbleUrl() + "/api/Flow/task/list/" + instanceId;
        JSONObject jsonObject = request(url, "GET", null);
        FlowAbleModel flowAbleModel = JsonUtil.getJsonToBean(jsonObject, FlowAbleModel.class);
        if (null == flowAbleModel) {
            log.error(MsgCode.WF092.get());
            throw new WorkFlowException(MsgCode.WF142.get());
        }
        if (Boolean.FALSE.equals(flowAbleModel.getSuccess())) {
            throw new WorkFlowException(flowAbleModel.getMsg());
        }
        return JsonUtil.getJsonToList(flowAbleModel.getData(), FlowableTaskModel.class);
    }

    /**
     * 删除流程实例
     *
     * @param instanceId   实例ID
     * @param deleteReason 删除原因
     */
    public void deleteInstance(String instanceId, String deleteReason) throws WorkFlowException {
        String url = getFlowAbleUrl() + "/api/Flow/instance?instanceId=" + instanceId;
        if (StringUtil.isNotEmpty(deleteReason)) {
            url += "&deleteReason=" + deleteReason;
        }
        JSONObject jsonObject = request(url, "DELETE", null);
        FlowAbleModel flowAbleModel = JsonUtil.getJsonToBean(jsonObject, FlowAbleModel.class);
        if (null == flowAbleModel || !flowAbleModel.getSuccess()) {
            log.error("流程实例删除异常: {}", flowAbleModel);
        }
    }

    /**
     * 获取出线Key集合
     *
     * @param fo 参数类
     */
    public List<String> getOutgoingFlows(OutgoingFlowsFo fo) throws WorkFlowException {
        String url = getFlowAbleUrl() + "/api/Flow/task/outgoing/flows";
        if (StringUtil.isNotEmpty(fo.getTaskId())) {
            url += TASK_ID + fo.getTaskId();
        } else {
            url += DEPLOYMENT_ID + fo.getDeploymentId() + TASK_KEY + fo.getTaskKey();
        }
        JSONObject jsonObject = request(url, "GET", null);
        FlowAbleModel flowAbleModel = JsonUtil.getJsonToBean(jsonObject, FlowAbleModel.class);
        if (null == flowAbleModel) {
            log.error(MsgCode.WF094.get());
            throw new WorkFlowException(MsgCode.WF142.get());
        }
        if (Boolean.FALSE.equals(flowAbleModel.getSuccess())) {
            throw new WorkFlowException(flowAbleModel.getMsg());
        }
        return JsonUtil.getJsonToList(flowAbleModel.getData(), String.class);
    }

    /**
     * 获取线之后的任务节点
     *
     * @param deploymentId 部署id
     * @param flowKey      连接线的Key
     */
    public List<String> getTaskKeyAfterFlow(String deploymentId, String flowKey) throws WorkFlowException {
        String url = getFlowAbleUrl() + "/api/Flow/task/flow/target?deploymentId=" + deploymentId + "&flowKey=" + flowKey;
        JSONObject jsonObject = request(url, "GET", null);
        FlowAbleModel flowAbleModel = JsonUtil.getJsonToBean(jsonObject, FlowAbleModel.class);
        if (null == flowAbleModel) {
            log.error(MsgCode.WF095.get());
            throw new WorkFlowException(MsgCode.WF142.get());
        }
        if (Boolean.FALSE.equals(flowAbleModel.getSuccess())) {
            throw new WorkFlowException(flowAbleModel.getMsg());
        }
        return JsonUtil.getJsonToList(flowAbleModel.getData(), String.class);
    }

    /**
     * 获取下一级任务节点集合
     *
     * @param fo 参数类
     */
    public List<FlowableNodeModel> getNext(NextOrPrevFo fo) throws WorkFlowException {
        String url = getFlowAbleUrl() + "/api/Flow/task/next";
        if (StringUtil.isNotEmpty(fo.getTaskId())) {
            url += TASK_ID + fo.getTaskId();
        } else {
            url += DEPLOYMENT_ID + fo.getDeploymentId() + TASK_KEY + fo.getTaskKey();
        }
        JSONObject jsonObject = request(url, "GET", null);
        FlowAbleModel flowAbleModel = JsonUtil.getJsonToBean(jsonObject, FlowAbleModel.class);
        if (null == flowAbleModel) {
            log.error(MsgCode.WF096.get());
            throw new WorkFlowException(MsgCode.WF142.get());
        }
        if (Boolean.FALSE.equals(flowAbleModel.getSuccess())) {
            throw new WorkFlowException(flowAbleModel.getMsg());
        }
        return JsonUtil.getJsonToList(flowAbleModel.getData(), FlowableNodeModel.class);
    }

    /**
     * 获取上一级任务节点id集合
     *
     * @param fo 参数类
     */
    public List<String> getPrev(NextOrPrevFo fo) throws WorkFlowException {
        String url = getFlowAbleUrl() + "/api/Flow/task/prev";
        if (StringUtil.isNotEmpty(fo.getTaskId())) {
            url += TASK_ID + fo.getTaskId();
        } else {
            url += DEPLOYMENT_ID + fo.getDeploymentId() + TASK_KEY + fo.getTaskKey();
        }
        JSONObject jsonObject = request(url, "GET", null);
        FlowAbleModel flowAbleModel = JsonUtil.getJsonToBean(jsonObject, FlowAbleModel.class);
        if (null == flowAbleModel) {
            log.error(MsgCode.WF097.get());
            throw new WorkFlowException(MsgCode.WF142.get());
        }
        if (Boolean.FALSE.equals(flowAbleModel.getSuccess())) {
            throw new WorkFlowException(flowAbleModel.getMsg());
        }
        return JsonUtil.getJsonToList(flowAbleModel.getData(), String.class);
    }

    /**
     * 完成流程任务
     *
     * @param fo 参数类
     */
    public void complete(CompleteFo fo) throws WorkFlowException {
        String url = getFlowAbleUrl() + "/api/Flow/task/complete";
        JSONObject jsonObject = request(url, "POST", JsonUtil.getObjectToString(fo));
        FlowAbleModel flowAbleModel = JsonUtil.getJsonToBean(jsonObject, FlowAbleModel.class);
        if (null == flowAbleModel) {
            log.error(MsgCode.WF098.get());
            throw new WorkFlowException(MsgCode.WF142.get());
        }
        if (Boolean.FALSE.equals(flowAbleModel.getSuccess())) {
            throw new WorkFlowException(flowAbleModel.getMsg());
        }
    }

    /**
     * 获取流程实例
     *
     * @param instanceId 实例id
     */
    public FlowableInstanceModel getInstance(String instanceId) throws WorkFlowException {
        String url = getFlowAbleUrl() + "/api/Flow/instance/" + instanceId;
        JSONObject jsonObject = request(url, "GET", null);
        FlowAbleModel flowAbleModel = JsonUtil.getJsonToBean(jsonObject, FlowAbleModel.class);
        if (null == flowAbleModel) {
            log.error(MsgCode.WF099.get());
            throw new WorkFlowException(MsgCode.WF142.get());
        }
        if (Boolean.FALSE.equals(flowAbleModel.getSuccess())) {
            throw new WorkFlowException(flowAbleModel.getMsg());
        }
        return JsonUtil.getJsonToBean(flowAbleModel.getData(), FlowableInstanceModel.class);
    }

    /**
     * 获取未经过的节点
     *
     * @param instanceId 引擎实例主键
     */
    public List<String> getTobePass(String instanceId) throws WorkFlowException {
        String url = getFlowAbleUrl() + "/api/Flow/task/tobe/pass/" + instanceId;
        JSONObject jsonObject = request(url, "GET", null);
        FlowAbleModel flowAbleModel = JsonUtil.getJsonToBean(jsonObject, FlowAbleModel.class);
        if (null == flowAbleModel) {
            log.error(MsgCode.WF100.get());
            throw new WorkFlowException(MsgCode.WF142.get());
        }
        if (Boolean.FALSE.equals(flowAbleModel.getSuccess())) {
            throw new WorkFlowException(flowAbleModel.getMsg());
        }
        return JsonUtil.getJsonToList(flowAbleModel.getData(), String.class);
    }

    /**
     * 获取节点的后续节点
     *
     * @param fo 参数
     */
    public List<String> getAfter(AfterFo fo) throws WorkFlowException {
        String url = getFlowAbleUrl() + "/api/Flow/task/after";
        JSONObject jsonObject = request(url, "POST", JsonUtil.getObjectToString(fo));
        FlowAbleModel flowAbleModel = JsonUtil.getJsonToBean(jsonObject, FlowAbleModel.class);
        if (null == flowAbleModel) {
            log.error(MsgCode.WF101.get());
            throw new WorkFlowException(MsgCode.WF142.get());
        }
        if (Boolean.FALSE.equals(flowAbleModel.getSuccess())) {
            throw new WorkFlowException(flowAbleModel.getMsg());
        }
        return JsonUtil.getJsonToList(flowAbleModel.getData(), String.class);
    }

    /**
     * 获取可回退的节点ID
     *
     * @param taskId 引擎任务主键
     */
    public List<String> getFallbacks(String taskId) throws WorkFlowException {
        String url = getFlowAbleUrl() + "/api/Flow/task/fallbacks/" + taskId;
        JSONObject jsonObject = request(url, "GET", null);
        FlowAbleModel flowAbleModel = JsonUtil.getJsonToBean(jsonObject, FlowAbleModel.class);
        if (null == flowAbleModel) {
            log.error(MsgCode.WF102.get());
            throw new WorkFlowException(MsgCode.WF142.get());
        }
        if (Boolean.FALSE.equals(flowAbleModel.getSuccess())) {
            throw new WorkFlowException(flowAbleModel.getMsg());
        }
        return JsonUtil.getJsonToList(flowAbleModel.getData(), String.class);
    }

    /**
     * 退回
     *
     * @param fo 参数
     */
    public void back(BackFo fo) throws WorkFlowException {
        String url = getFlowAbleUrl() + "/api/Flow/task/back";
        JSONObject jsonObject = request(url, "POST", JsonUtil.getObjectToString(fo));
        FlowAbleModel flowAbleModel = JsonUtil.getJsonToBean(jsonObject, FlowAbleModel.class);
        if (null == flowAbleModel) {
            log.error(MsgCode.WF103.get());
            throw new WorkFlowException(MsgCode.WF142.get());
        }
        if (Boolean.FALSE.equals(flowAbleModel.getSuccess())) {
            throw new WorkFlowException(flowAbleModel.getMsg());
        }
    }

    /**
     * 节点跳转
     *
     * @param fo 参数
     */
    public void jump(JumpFo fo) throws WorkFlowException {
        String url = getFlowAbleUrl() + "/api/Flow/task/jump";
        JSONObject jsonObject = request(url, "POST", JsonUtil.getObjectToString(fo));
        FlowAbleModel flowAbleModel = JsonUtil.getJsonToBean(jsonObject, FlowAbleModel.class);
        if (null == flowAbleModel) {
            log.error(MsgCode.WF104.get());
            throw new WorkFlowException(MsgCode.WF142.get());
        }
        if (Boolean.FALSE.equals(flowAbleModel.getSuccess())) {
            throw new WorkFlowException(flowAbleModel.getMsg());
        }
    }

    /**
     * 任务完成的补偿
     *
     * @param fo 参数
     */
    public List<FlowableTaskModel> compensate(CompensateFo fo) throws WorkFlowException {
        String url = getFlowAbleUrl() + "/api/Flow/task/compensate";
        JSONObject jsonObject = request(url, "POST", JsonUtil.getObjectToString(fo));
        FlowAbleModel flowAbleModel = JsonUtil.getJsonToBean(jsonObject, FlowAbleModel.class);
        if (null == flowAbleModel) {
            log.error(MsgCode.WF105.get());
            throw new WorkFlowException(MsgCode.WF142.get());
        }
        if (Boolean.FALSE.equals(flowAbleModel.getSuccess())) {
            throw new WorkFlowException(flowAbleModel.getMsg());
        }
        return JsonUtil.getJsonToList(flowAbleModel.getData(), FlowableTaskModel.class);
    }

    /**
     * 获取历史节点
     *
     * @param instanceId 实例主键
     */
    public List<FlowableHistoricModel> getHistoric(String instanceId) throws WorkFlowException {
        String url = getFlowAbleUrl() + "/api/Flow/task/historic/" + instanceId;
        JSONObject jsonObject = request(url, "GET", null);
        FlowAbleModel flowAbleModel = JsonUtil.getJsonToBean(jsonObject, FlowAbleModel.class);
        if (null == flowAbleModel) {
            log.error("获取历史节点失败");
            throw new WorkFlowException(MsgCode.WF142.get());
        }
        if (Boolean.FALSE.equals(flowAbleModel.getSuccess())) {
            throw new WorkFlowException(flowAbleModel.getMsg());
        }
        return JsonUtil.getJsonToList(flowAbleModel.getData(), FlowableHistoricModel.class);
    }

    /**
     * 获取历史结束节点
     *
     * @param instanceId 实例主键
     */
    public List<String> getHistoricEnd(String instanceId) throws WorkFlowException {
        String url = getFlowAbleUrl() + "/api/Flow/task/historic/end/" + instanceId;
        JSONObject jsonObject = request(url, "GET", null);
        FlowAbleModel flowAbleModel = JsonUtil.getJsonToBean(jsonObject, FlowAbleModel.class);
        if (null == flowAbleModel) {
            log.error("获取历史结束节点失败");
            throw new WorkFlowException(MsgCode.WF142.get());
        }
        if (Boolean.FALSE.equals(flowAbleModel.getSuccess())) {
            throw new WorkFlowException(flowAbleModel.getMsg());
        }
        return JsonUtil.getJsonToList(flowAbleModel.getData(), String.class);
    }

    /**
     * 获取元素信息
     *
     * @param deploymentId 部署id
     * @param key          节点key
     */
    public FlowableNodeModel getElementInfo(String deploymentId, String key) throws WorkFlowException {
        String url = getFlowAbleUrl() + "/api/Flow/task/element/info";
        url += DEPLOYMENT_ID + deploymentId + "&key=" + key;
        JSONObject jsonObject = request(url, "GET", null);
        FlowAbleModel flowAbleModel = JsonUtil.getJsonToBean(jsonObject, FlowAbleModel.class);
        if (null == flowAbleModel) {
            log.error("获取元素信息失败");
            throw new WorkFlowException(MsgCode.WF142.get());
        }
        if (Boolean.FALSE.equals(flowAbleModel.getSuccess())) {
            throw new WorkFlowException(flowAbleModel.getMsg());
        }
        return JsonUtil.getJsonToBean(flowAbleModel.getData(), FlowableNodeModel.class);
    }
}