package jnpf.onlinedev.controller;

import jnpf.base.ActionResult;
import jnpf.base.DataSourceApi;
import jnpf.base.entity.VisualAliasEntity;
import jnpf.base.entity.VisualdevEntity;
import jnpf.base.entity.VisualdevReleaseEntity;
import jnpf.base.model.FormDeleteResult;
import jnpf.base.model.VisualDevJsonModel;
import jnpf.base.model.export.VisualExportVo;
import jnpf.base.model.flow.DataModel;
import jnpf.base.model.flow.FlowFormDataModel;
import jnpf.base.model.flow.FlowStateModel;
import jnpf.base.model.online.VisualdevModelDataInfoVO;
import jnpf.base.service.FlowFormRelationService;
import jnpf.base.service.VisualAliasService;
import jnpf.base.service.VisualdevReleaseService;
import jnpf.base.service.VisualdevService;
import jnpf.base.util.FlowFormDataUtil;
import jnpf.base.util.FlowFormHttpReqUtils;
import jnpf.database.model.entity.DbLinkEntity;
import jnpf.onlinedev.VisualdevOnlineApi;
import jnpf.onlinedev.model.OnlineInfoModel;
import jnpf.onlinedev.model.VisualParamModel;
import jnpf.onlinedev.model.log.VisualLogForm;
import jnpf.onlinedev.service.VisualDevInfoService;
import jnpf.onlinedev.service.VisualDevListService;
import jnpf.onlinedev.service.VisualLogService;
import jnpf.onlinedev.service.VisualdevModelDataService;
import jnpf.onlinedev.util.FlowFormCustomUtils;
import jnpf.onlinedev.util.OnlinePublicUtils;
import jnpf.util.*;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.CollectionUtils;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.*;

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

@Slf4j
@RestController
@RequiredArgsConstructor
@RequestMapping("/VisualdevForFlow")
public class VisualdevForFlowController implements VisualdevOnlineApi {

    private final VisualdevReleaseService visualdevReleaseService;
    private final VisualDevListService visualDevListService;
    private final VisualDevInfoService visualDevInfoService;
    private final FlowFormHttpReqUtils flowFormHttpReqUtils;
    private final FlowFormCustomUtils flowFormCustomUtils;
    private final FlowFormDataUtil flowDataUtil;
    private final DataSourceApi dblinkService;
    private final FlowFormRelationService flowFormRelationService;
    private final VisualdevModelDataService visualdevModelDataService;
    private final VisualdevService visualdevService;
    private final VisualAliasService aliasService;
    // AUDIT 补丁（2026-08-05，登记 tasks/jnpf-platform-patches.md #7）：
    // 流程实例删除会连带删掉业务表单数据，平台原生此路径不发任何 VSLOG 事件。
    private final VisualLogService visualLogService;

    @Override
    @PostMapping("/saveOrUpdate")
    public ActionResult<Object> saveOrUpdate(@RequestBody FlowFormDataModel flowFormDataModel) {
        DataModel dataModel = null;
        try {
            String id = flowFormDataModel.getId();
            String formId = flowFormDataModel.getFormId();
            String flowId = flowFormDataModel.getFlowId();
            Map<String, Object> map = flowFormDataModel.getMap();
            List<Map<String, Object>> formOperates = flowFormDataModel.getFormOperates();
            VisualdevReleaseEntity entity = visualdevReleaseService.getById(formId);
            VisualdevEntity visualdevEntity = JsonUtil.getJsonToBean(entity, VisualdevEntity.class);

            map.put(FlowFormConstant.FLOWID, flowId);
            if (map.get(TableFeildsEnum.VERSION.getField().toUpperCase()) != null) {//针对Oracle数据库大小写敏感，出现大写字段补充修复
                map.put(TableFeildsEnum.VERSION.getField(), map.get(TableFeildsEnum.VERSION.getField().toUpperCase()));
            }

            //系统表单
            if (entity.getType() == 2) {
                map.put("formOperates", formOperates);
                flowFormHttpReqUtils.saveOrUpdate(visualdevEntity, id, UserProvider.getToken(), map);
            } else {
                dataModel = flowFormCustomUtils.saveOrUpdate(visualdevEntity, flowFormDataModel);
            }
        } catch (Exception e) {
            log.error(e.getMessage(), e);
            return ActionResult.fail(e.getMessage());
        }
        return ActionResult.success(dataModel);
    }

    @Override
    @DeleteMapping("/delete")
    public boolean delete(@RequestParam("formId") String formId, @RequestParam("id") String id) {
        try {
            VisualdevReleaseEntity entity = visualdevReleaseService.getById(formId);
            VisualdevEntity visualdevEntity = JsonUtil.getJsonToBean(entity, VisualdevEntity.class);
            //系统表单
            if (entity.getType() == 2) {
                // 系统表单的数据不在本库（走 HTTP 打到外部系统），本地无快照可取，
                // 也不该产出指向本库的审计事件——这条分支不发。
                flowFormHttpReqUtils.delete(visualdevEntity, id, UserProvider.getToken());
            } else {
                VisualDevJsonModel visualJsonModel = OnlinePublicUtils.getVisualJsonModel(visualdevEntity);
                DbLinkEntity linkEntity = StringUtil.isNotEmpty(visualdevEntity.getDbLinkId()) ? dblinkService.getInfo(visualdevEntity.getDbLinkId()) : null;

                // ── AUDIT 补丁（2026-08-05，登记 tasks/jnpf-platform-patches.md #7）第 1/2 段 ──
                // 触发链：用户在流程列表删除流程实例 → TaskServiceImpl.delete/deleteBatch
                //        → OperatorUtil.deleteFormData → ServiceUtil.deleteFormData
                //        → Feign visualdevApi.delete(formId, id) → 本方法。
                // 🔴 顺序是硬约束：主键解析与快照都必须在 deleteTable **之前**——删完再查什么都没有。
                // 入参 id 可能是 flowTaskId（deleteTable 按「主键 = id OR flowTaskId = id」定位），
                // 而审计事件的 dataId 必须是业务主键，否则查询侧对不上记录。
                Object auditMainId = null;
                Map<String, Object> auditSnapshot = null;
                try {
                    auditMainId = flowDataUtil.resolveMainId(id, visualJsonModel, linkEntity);
                    if (auditMainId != null) {
                        auditSnapshot = auditDeleteSnapshot(String.valueOf(auditMainId), visualdevEntity);
                    }
                } catch (Throwable t) {
                    log.warn("[AUDIT] 流程删除取快照失败，本次删除不带内容快照。formId={}, id={}, error={}",
                            formId, id, t.getMessage());
                    auditMainId = null;
                    auditSnapshot = null;
                }
                // ── 第 1/2 段结束 ──────────────────────────────────────────────────────────

                FormDeleteResult delResult = flowDataUtil.deleteTable(id, visualJsonModel, linkEntity);

                // ── AUDIT 补丁 第 2/2 段 ───────────────────────────────────────────────────
                // dataId 回落到 delResult.getMainId()：上面解析失败但删除成功时，
                // 「这次删过」这个事实不能缺——缺的只能是内容快照。
                // 不设 batchOpId/batchSize：这是单条删除，审计侧 batchOpId 为空时回落到
                // EVENT_ID_PREFIX + eventId，batchSize 为 null 时不缀「共 N 条」。
                // 不设 bizSign：流程实例删除没有电子签名入口。
                Object eventDataId = auditMainId != null ? auditMainId : (delResult == null ? null : delResult.getMainId());
                if (delResult != null && delResult.isDeleted() && eventDataId != null) {
                    try {
                        visualLogService.createEventLog(VisualLogForm.builder()
                                .modelId(formId)
                                .dataId(String.valueOf(eventDataId))
                                .newData(auditSnapshot)
                                .type(2)
                                .build());
                    } catch (Throwable t) {
                        log.warn("[AUDIT] 流程删除事件发布失败，已跳过。formId={}, id={}, error={}",
                                formId, id, t.getMessage());
                    }
                }
                // ── AUDIT 补丁结束 ────────────────────────────────────────────────────────
            }
        } catch (Exception e) {
            return false;
        }
        return true;
    }

    @Override
    @GetMapping("/info")
    public ActionResult<Object> info(@RequestParam("formId") String formId, @RequestParam("id") String id) {
        ActionResult<Object> result = new ActionResult<>();
        Map<String, Object> allDataMap = new HashMap<>();
        VisualdevReleaseEntity entity = visualdevReleaseService.getById(formId);
        VisualdevEntity visualdevEntity = JsonUtil.getJsonToBean(entity, VisualdevEntity.class);
        result.setCode(visualdevEntity == null ? 400 : 200);
        result.setMsg(visualdevEntity == null ? "表单信息不存在" : "");
        if (visualdevEntity != null) {
            //判断是否为系统表单
            boolean b = visualdevEntity.getType() == 2;
            if (b) {
                allDataMap.putAll(flowFormHttpReqUtils.info(visualdevEntity, id, UserProvider.getToken()));
            } else {
                allDataMap.putAll(flowFormCustomUtils.info(visualdevEntity, id));
            }
        }
        result.setData(allDataMap);
        return result;
    }

    @Override
    @GetMapping("/getFormConfig")
    public VisualdevEntity getFormConfig(@RequestParam("formId") String formId) {
        VisualdevReleaseEntity entity = visualdevReleaseService.getById(formId);
        return JsonUtil.getJsonToBean(entity, VisualdevEntity.class);
    }

    @Override
    @PostMapping("/getFormConfigList")
    public List<VisualdevEntity> getFormConfigList(@RequestBody List<String> formIds) {
        List<VisualdevReleaseEntity> list = visualdevReleaseService.selectByIds(formIds,
                VisualdevReleaseEntity::getId,
                VisualdevReleaseEntity::getEnCode,
                VisualdevReleaseEntity::getFullName,
                VisualdevReleaseEntity::getWebType,
                VisualdevReleaseEntity::getType);
        return CollectionUtils.isNotEmpty(list) ? JsonUtil.getJsonToList(list, VisualdevEntity.class) : new ArrayList<>();
    }

    @Override
    @PostMapping("/saveFlowIdByFormIds")
    public void saveFlowIdByFormIds(@RequestBody String flowId, @RequestParam("formId") List<String> formIds) {
        flowFormRelationService.saveFlowIdByFormIds(flowId, formIds);
    }

    @Override
    @GetMapping("/getReleaseInfo")
    public VisualdevEntity getReleaseInfo(@RequestParam("formId") String formId) {
        return visualdevService.getReleaseInfo(formId);
    }

    @Override
    @PostMapping("/getListWithTableList")
    public List<Map<String, Object>> getListWithTableList(@RequestBody VisualParamModel model) {
        return visualDevListService.getListWithTableList(model.getVisualDevJsonModel(), model.getPagination(), model.getUserInfo());
    }

    @Override
    @PostMapping("/getEditDataInfo")
    public VisualdevModelDataInfoVO getEditDataInfo(@RequestBody VisualParamModel model) {
        return visualDevInfoService.getEditDataInfo(model.getId(), model.getVisualdevEntity(), OnlineInfoModel.builder().build());
    }

    @Override
    @PostMapping("/visualCreate")
    public ActionResult<Object> visualCreate(@RequestBody VisualParamModel model) {
        DataModel dataModel;
        try {
            dataModel = visualdevModelDataService.visualCreate(VisualParamModel.builder().visualdevEntity(model.getVisualdevEntity()).data(model.getData()).build());
        } catch (Exception e) {
            e.printStackTrace();
            return ActionResult.fail(e.getMessage());
        }
        return ActionResult.success(dataModel);
    }

    @Override
    @PostMapping("/visualUpdate")
    public ActionResult<Object> visualUpdate(@RequestBody VisualParamModel model) {
        DataModel dataModel;
        try {
            dataModel = visualdevModelDataService.visualUpdate(model);
        } catch (Exception e) {
            e.printStackTrace();
            return ActionResult.fail(e.getMessage());
        }
        return ActionResult.success(dataModel);
    }

    @Override
    @PostMapping("/visualDelete")
    public ActionResult<Object> visualDelete(@RequestBody VisualParamModel model) {
        try {
            visualdevModelDataService.visualDelete(model.getVisualdevEntity(), model.getDataList());
        } catch (Exception e) {
            e.printStackTrace();
            return ActionResult.fail(e.getMessage());
        }
        return ActionResult.success();
    }

    @Override
    @PostMapping("/deleteByTableName")
    public ActionResult<Object> deleteByTableName(@RequestBody FlowFormDataModel model) {
        try {
            visualdevModelDataService.deleteByTableName(model);
        } catch (Exception e) {
            e.printStackTrace();
            return ActionResult.fail(e.getMessage());
        }
        return ActionResult.success();
    }

    @Override
    @PostMapping("/saveState")
    public void saveState(@RequestBody FlowStateModel model) {
        List<String> formIds = model.getFormIds();
        String flowTaskId = model.getFlowTaskId();
        Integer flowState = model.getFlowState();
        for (String formId : formIds) {
            VisualdevReleaseEntity entity = visualdevReleaseService.getById(formId);
            if (entity == null) continue;
            VisualdevEntity visualdevEntity = JsonUtil.getJsonToBean(entity, VisualdevEntity.class);
            //系统表单
            if (entity.getType() == 2) {
                flowFormHttpReqUtils.saveState(visualdevEntity, flowTaskId, flowState);
            } else {
                flowDataUtil.saveState(visualdevEntity, flowTaskId, flowState);
            }
        }
    }

    @Override
    @GetMapping("/getExportList")
    public List<VisualExportVo> getExportList(@RequestParam("systemId") String systemId) {
        return visualdevService.getExportList(systemId);
    }

    @Override
    @PostMapping("/importCopy")
    public boolean importCopy(@RequestBody List<VisualExportVo> list, @RequestParam("systemId") String systemId) {
        try {
            for (VisualExportVo item : list) {
                VisualdevEntity entity = JsonUtil.getJsonToBean(item, VisualdevEntity.class);
                String id = RandomUtil.uuId();
                entity.setId(id);
                entity.setCreatorTime(DateUtil.getNowDate());
                entity.setCreatorUserId(UserProvider.getUser().getUserId());
                entity.setLastModifyTime(null);
                entity.setLastModifyUserId(null);
                entity.setState(0);
                entity.setSystemId(systemId);
                visualdevService.setAutoEnCode(entity);
                visualdevService.save(entity);
                if (StringUtil.isNotEmpty(item.getAliasListJson())) {
                    List<VisualAliasEntity> jsonToList = JsonUtil.getJsonToList(item.getAliasListJson(), VisualAliasEntity.class);
                    for (VisualAliasEntity aliasEntity : jsonToList) {
                        aliasService.copyEntity(aliasEntity, id);
                    }
                }
            }
            return true;
        } catch (Exception e) {
            log.error(e.getMessage());
        }
        return false;
    }

    @Override
    @GetMapping("/deleteBySystemId")
    public void deleteBySystemId(@RequestParam("systemId") String systemId) {
        visualdevService.deleteBySystemId(systemId);
    }

    /**
     * AUDIT 补丁（2026-08-05，登记 tasks/jnpf-platform-patches.md #7）：
     * 取被删数据的快照，供审计层 0 渲染标题与留存 data_snapshot。
     *
     * <p>与 {@code VisualdevModelDataController.auditDeleteSnapshot} 同款参数
     * （needRlationFiled=true, needSwap=false），保证两条删除路径产出的 newData 同构，
     * 审计侧的渲染链路得以原样复用。
     *
     * <p>入参必须是**业务主键**（不是 flowTaskId）——调用方先经
     * {@code flowDataUtil.resolveMainId} 解析。
     *
     * <p>取不到返回 null：事件照发（「这次删过」不能缺），只是没有快照可渲染。
     */
    private Map<String, Object> auditDeleteSnapshot(String id, VisualdevEntity visualdevEntity) {
        try {
            VisualdevModelDataInfoVO info = visualDevInfoService.getEditDataInfo(id, visualdevEntity,
                    OnlineInfoModel.builder().needRlationFiled(true).needSwap(false).build());
            return info == null ? null : JsonUtil.stringToMap(info.getData());
        } catch (Throwable t) {
            log.warn("[AUDIT] 取删除快照失败 id={}, error={}", id, t.getMessage());
            return null;
        }
    }

}