package jnpf.dmsService;

import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.node.ObjectNode;
import jnpf.exception.DataException;
import jnpf.permission.UserApi;
import jnpf.permission.entity.UserEntity;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
import java.util.*;

/** Snapshots native form personnel fields at registration; workflow configuration owns role assignment. */
@Service
@RequiredArgsConstructor
@Slf4j
public class DmsApprovedVersionPropertiesService {
    private final UserApi users;
    private final ObjectMapper json;

    public JsonNode create(String preparedBy, String storedReviewerIds) {
        LinkedHashSet<String> reviewerIds = reviewerIds(storedReviewerIds);
        Set<String> ids = new LinkedHashSet<>(reviewerIds);
        if (StringUtils.hasText(preparedBy)) ids.add(preparedBy);
        Map<String, String> names = new HashMap<>();
        if (!ids.isEmpty()) {
            List<UserEntity> found = lookupNames(ids);
            for (UserEntity user : found) {
                if (user != null && ids.contains(user.getId()))
                    names.put(user.getId(), user.getRealName() == null ? "" : user.getRealName());
            }
        }
        ObjectNode result = json.createObjectNode();
        result.put("prepared_by_name", names.getOrDefault(preparedBy, ""));
        var reviewers = result.putArray("reviewers");
        for (String id : reviewerIds) reviewers.addObject().put("user_id", id).put("name", names.getOrDefault(id, ""));
        return result;
    }

    private List<UserEntity> lookupNames(Set<String> ids) {
        // Names are optional display snapshots; directory availability must not block registration.
        try {
            List<UserEntity> found = users.getUserName(new ArrayList<>(ids));
            return found == null ? List.of() : found;
        } catch (RuntimeException e) {
            log.warn("版本人员姓名查询失败，保留人员ID继续登记，异常类型：{}", e.getClass().getSimpleName());
            return List.of();
        }
    }

    private LinkedHashSet<String> reviewerIds(String stored) {
        LinkedHashSet<String> ids = new LinkedHashSet<>();
        if (!StringUtils.hasText(stored)) return ids;
        String valueText = stored.trim();
        // Workflow operation mapping writes the current operator ID as a scalar.
        // Keep the version/API contract as an array and accept existing multi-user values.
        if (!valueText.startsWith("[")) {
            if ("null".equals(valueText) || valueText.matches(".*[\\[\\]{}\",].*"))
                throw new DataException("审核人字段必须为人员ID或人员ID数组");
            ids.add(valueText);
            return ids;
        }
        try {
            // Native multi-user fields are persisted as JSON arrays by FlowFormDataUtil.
            JsonNode value = json.readTree(stored);
            if (value == null || !value.isArray()) throw new DataException("审核人字段必须为人员ID数组");
            for (JsonNode id : value) {
                if (!id.isTextual() || !StringUtils.hasText(id.textValue()))
                    throw new DataException("审核人字段包含无效人员ID");
                ids.add(id.textValue().trim());
            }
            return ids;
        } catch (java.io.IOException e) {
            throw new DataException("审核人字段格式不正确");
        }
    }

}