package jnpf.onlinedev.util;

import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.http.HttpRequest;
import cn.hutool.http.Method;
import jnpf.base.UserInfo;
import jnpf.base.model.VisualLogModel;
import jnpf.base.model.flow.DataModel;
import jnpf.config.ConfigValueUtil;
import jnpf.flowable.TriggerApi;
import jnpf.flowable.model.trigger.TriggerDataFo;
import jnpf.message.model.TriggerDataModel;
import jnpf.message.model.TriggerModel;
import jnpf.onlinedev.model.AsyncExecuteModel;
import jnpf.util.Constants;
import jnpf.util.JsonUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;

@Component
public class IntegrateUtil {
    @Autowired
    private ConfigValueUtil configValueUtil;
    @Autowired
    private TriggerApi triggerApi;

    public List<TriggerDataModel> asyncDelExecute(AsyncExecuteModel executeModel) {
        String modelId = executeModel.getModelId();
        Integer trigger = executeModel.getTrigger();
        List<String> dataId = executeModel.getDataId();
        DataModel dataModel = executeModel.getDataModel();
        List<Map<String, Object>> dataMap = executeModel.getDataMap();

        TriggerDataFo fo = new TriggerDataFo();
        fo.setModelId(modelId);
        fo.setTrigger(trigger);
        fo.setDataId(dataId);
        fo.setDataMap(dataMap);
        if (dataModel != null) {
            List<VisualLogModel> listLog = dataModel.getListLog();
            if (CollectionUtil.isNotEmpty(listLog)) {
                List<String> updateFields = this.getUpdateFields(listLog);
                fo.setUpdateFields(updateFields);
            }
        }

        List<TriggerDataModel> resultData = triggerApi.getTriggerDataModel(fo);
        return resultData;
    }

    @Async
    public void asyncExecute(AsyncExecuteModel executeModel) {
        String modelId = executeModel.getModelId();
        Integer trigger = executeModel.getTrigger();
        List<String> dataId = executeModel.getDataId();
        UserInfo userInfo = executeModel.getUserInfo();
        DataModel dataModel = executeModel.getDataModel();
        List<Map<String, Object>> dataMap = executeModel.getDataMap();

        TriggerDataFo fo = new TriggerDataFo();
        fo.setModelId(modelId);
        fo.setTrigger(trigger);
        fo.setDataId(dataId);
        fo.setDataMap(dataMap);
        if (dataModel != null) {
            List<VisualLogModel> listLog = dataModel.getListLog();
            if (CollectionUtil.isNotEmpty(listLog)) {
                List<String> updateFields = this.getUpdateFields(listLog);
                fo.setUpdateFields(updateFields);
            }
        }

        List<TriggerDataModel> resultData = triggerApi.getTriggerDataModel(fo);
        if (!resultData.isEmpty()) {
            String url = configValueUtil.getApiDomain() + "/api/workflow/trigger/Execute";
            TriggerModel model = new TriggerModel();
            model.setUserInfo(userInfo);
            model.setDataList(resultData);
            HttpRequest request = HttpRequest.of(url).method(Method.POST).body(JsonUtil.getObjectToString(model));
            request.header(Constants.AUTHORIZATION, userInfo.getToken());
            request.execute().body();
        }
    }

    private List<String> getUpdateFields(List<VisualLogModel> listLog) {
        List<String> updateFields = new ArrayList<>();
        if (CollectionUtil.isNotEmpty(listLog)) {
            for (VisualLogModel logModel : listLog) {
                String field = logModel.getField();
                List<Map<String, Object>> chidField = logModel.getChidField();
                List<Map<String, Object>> chidData = logModel.getChidData();
                if (CollectionUtil.isNotEmpty(chidField) && CollectionUtil.isNotEmpty(chidData)) {
                    // 子表
                    for (Map<String, Object> map : chidField) {
                        String key = (String) map.get("prop");
                        for (Map<String, Object> child : chidData) {
                            if (!ObjectUtil.equals(child.get(key), child.get("jnpf_old_" + key))) {
                                updateFields.add(field + "-" + key);
                                break;
                            }
                        }
                    }
                } else {
                    updateFields.add(field);
                }
            }
        }
        return updateFields;
    }
}