package jnpf.base.service;

import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import jnpf.base.entity.VisualdevEntity;
import jnpf.base.mapper.UploadEditReadMapper;
import jnpf.base.model.ColumnDataModel;
import jnpf.base.model.form.ModuleFormModel;
import jnpf.base.model.uploadedit.UploadEditContext;
import jnpf.base.util.UploadEditStateMachine;
import jnpf.exception.DataException;
import jnpf.permissions.PermissionInterfaceImpl;
import jnpf.util.JsonUtil;
import jnpf.util.UserProvider;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
import java.util.*;

/** Narrow shared-load reads; native detail rendering and persistence remain unchanged. */
@Service
@RequiredArgsConstructor
public class UploadEditReadService {
    private static final ObjectMapper JSON = new ObjectMapper();
    private final UploadEditReadMapper mapper;

    public VisualdevEntity model(String id) {
        VisualdevEntity model = mapper.releasedModel(id);
        return model == null ? mapper.designModel(id) : model;
    }

    /** Null means the published mapping needs the original native reader, never a failed query. */
    public Map<String, Object> dmsAttachment(VisualdevEntity model, UploadEditContext context, Map<?, ?> fieldConfig) {
        String table = supportedTable(model, context, fieldConfig);
        if (table == null) return null;
        boolean child = StringUtils.hasText(context.getParentField());
        if (child && !StringUtils.hasText(context.getRowId())) throw new DataException("子表行尚无跟踪 ID");
        // Preserve the native menu field boundary; denied/missing fields must not become empty attachments.
        ColumnDataModel columns = JsonUtil.getJsonToBean(model.getColumnData(), ColumnDataModel.class);
        if (columns != null && Boolean.TRUE.equals(columns.getUseFormPermission()) && StringUtils.hasText(context.getMenuId())) {
            Object granted = PermissionInterfaceImpl.getFormMap().get(context.getMenuId());
            String key = child ? context.getParentField() + "-" + context.getField() : context.getField();
            if (granted == null || JsonUtil.getJsonToList(granted, ModuleFormModel.class).stream()
                    .noneMatch(item -> key.equals(item.getEnCode()))) throw new DataException("没有附件字段查看权限");
        }
        String tenant = UserProvider.getUser().getTenantId();
        Map<String, Object> row = mapper.dmsAttachment(table, StringUtils.hasText(tenant) ? tenant : "0",
                context.getRecordId(), child ? context.getRowId() : null);
        if (row == null) throw new DataException("原生表单记录不存在");
        Map<String, Object> data = new HashMap<>();
        data.put("id", row.get("id")); data.put("flowTaskId", row.get("flowTaskId"));
        List<Map<String, Object>> files = UploadEditStateMachine.files(row.get("fileJson"));
        if (child) {
            if (!Objects.equals(context.getRowId(), row.get("rowId"))) throw new DataException("附件所属子表行不存在");
            data.put(context.getParentField(), List.of(Map.of("id", row.get("rowId"), context.getField(), files)));
        } else data.put(context.getField(), files);
        return data;
    }

    /** Only optimize the verified default-source DMS schema; changed mappings retain native support. */
    String supportedTable(VisualdevEntity model, UploadEditContext context, Map<?, ?> fieldConfig) {
        if (!"0".equals(model.getDbLinkId()) || Boolean.TRUE.equals(fieldConfig.get("isVirtualField"))) return null;
        try {
            JsonNode form = JSON.readTree(model.getFormData());
            String table = form.path("tableName").asText();
            if (!Set.of("dms_wenjian_xinzeng_shenhe", "dms_wenjian_xiuding_shenhe").contains(table)
                    || !form.path("logicalDelete").asBoolean() || form.path("primaryKeyPolicy").asInt() != 1
                    || !table.equals(fieldConfig.get("tableName"))) return null;
            boolean child = StringUtils.hasText(context.getParentField());
            if (child ? !"jilu_mingxi".equals(context.getParentField()) || !"jilu_wenjian".equals(context.getField())
                    || !(table + "_jilu_mingxi").equals(fieldConfig.get("relationTable"))
                    : !"wenjian".equals(context.getField()) || Boolean.TRUE.equals(fieldConfig.get("isSubTable"))) return null;
            JsonNode tables = JSON.readTree(model.getVisualTables());
            if (tables == null || !tables.isArray()) return null;
            JsonNode main = null, detail = null;
            for (JsonNode item : tables) {
                if ("1".equals(item.path("typeId").asText())) {
                    if (main != null) return null;
                    main = item;
                }
                if ((table + "_jilu_mingxi").equals(item.path("table").asText())) detail = item;
            }
            if (main == null || !table.equals(main.path("table").asText()) || !standardPrimaryKey(main)
                    || !hasColumns(main, "f_id", "f_tenant_id", "f_delete_mark", "f_flow_task_id", "wenjian")) return null;
            if (child && (detail == null || !standardPrimaryKey(detail)
                    || !hasColumns(detail, "f_id", "f_tenant_id", "f_delete_mark", "f_foreign_id", "jilu_wenjian")
                    || !"f_foreign_id".equals(detail.path("tableField").asText())
                    || !"f_id".equals(detail.path("relationField").asText()))) return null;
            return table;
        } catch (Exception malformedMapping) {
            return null; // The existing native reader owns unsupported/malformed metadata errors.
        }
    }

    private boolean standardPrimaryKey(JsonNode table) {
        List<String> keys = new ArrayList<>();
        for (JsonNode field : table.path("fields")) {
            if (field.path("primaryKey").asInt() == 1 && !"f_tenant_id".equals(field.path("field").asText()))
                keys.add(field.path("field").asText());
        }
        return keys.equals(List.of("f_id"));
    }

    private boolean hasColumns(JsonNode table, String... required) {
        Set<String> columns = new HashSet<>();
        for (JsonNode field : table.path("fields")) columns.add(field.path("field").asText());
        return columns.containsAll(Arrays.asList(required));
    }
}