package jnpf.dmsService;

import jnpf.dmsEntity.permission.entity.DmsFilePermissionEntity;
import jnpf.dmsEntity.print.DmsWenjianDayinShenqingDetailEntity;
import jnpf.dmsEntity.print.DmsWenjianDayinShenqingEntity;
import jnpf.dmsEntity.print.form.DmsWorkflowPrintAuthorizeForm;
import jnpf.dmsEntity.print.vo.DmsWorkflowPrintAuthorizationVO;
import jnpf.dmsEntity.print.vo.DmsWorkflowPrintFileVO;
import jnpf.dmsIntegration.audit.DmsAuditRequestSignResolver;
import jnpf.dmsMapper.DmsWenjianDayinShenqingDetailMapper;
import jnpf.dmsMapper.DmsWenjianDayinShenqingMapper;
import jnpf.exception.DataException;
import jnpf.flowable.WorkFlowApi;
import jnpf.flowable.entity.TaskEntity;
import jnpf.flowable.enums.TaskStatusEnum;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.Map;
import java.util.UUID;
import java.util.stream.Collectors;

@Service
@RequiredArgsConstructor
public class DmsWorkflowPrintAuthorizationService {
    private static final String SOURCE_PREFIX = "print-request:";

    private final WorkFlowApi workFlowApi;
    private final DmsWenjianDayinShenqingMapper requestMapper;
    private final DmsWenjianDayinShenqingDetailMapper detailMapper;
    private final DmsWorkflowFileResolutionService fileResolutionService;
    private final DmsPermissionGrantService permissionGrantService;

    @Transactional(rollbackFor = Exception.class)
    public DmsWorkflowPrintAuthorizationVO authorize(
            String tenantId, DmsWorkflowPrintAuthorizeForm form, String serviceId) {
        String flowId = requiredText(form.getSourceId(), "流程ID不能为空");
        String taskId = requiredText(form.getTaskId(), "流程任务ID不能为空");
        TaskEntity task = requireApprovedTask(flowId, taskId);
        DmsWenjianDayinShenqingEntity request = uniqueRequest(
                requestMapper.selectByFlowForUpdate(tenantId, flowId, taskId));
        if (!TaskStatusEnum.PASSED.getCode().equals(request.getFlowState())) {
            throw new DataException("文件打印申请尚未审批通过");
        }
        if (trimToNull(form.getBizSign()) == null) {
            form.setBizSign(trimToNull(request.getBizSign()));
        }
        String applicantUserId = requiredText(request.getApplicantUserId(), "文件打印申请缺少申请人");
        List<DmsWenjianDayinShenqingDetailEntity> details =
                detailMapper.selectByRequestForUpdate(tenantId, request.getId());
        if (details == null || details.isEmpty()) {
            throw new DataException("文件打印申请没有可授权的文件明细");
        }

        List<ResolvedPrintFile> files = new ArrayList<>(details.size());
        for (DmsWenjianDayinShenqingDetailEntity detail : details) {
            DmsWorkflowFileResolutionService.ResolvedFile file = fileResolutionService.resolve(
                    tenantId, detail.getId(), detail.getFileReferenceId(), detail.getFileNumber(),
                    detail.getFileName(), detail.getVersionLabel());
            files.add(new ResolvedPrintFile(detail, file, parseCopies(detail)));
        }
        List<UUID> uniqueVersionIds = new ArrayList<>(new LinkedHashSet<>(files.stream()
                .map(value -> value.file.getFileVersion().getId()).collect(Collectors.toList())));
        List<DmsFilePermissionEntity> permissions = permissionGrantService
                .ensureWorkflowPrintPermissions(tenantId, SOURCE_PREFIX + request.getId(),
                        applicantUserId, uniqueVersionIds, serviceId,
                        DmsAuditRequestSignResolver.resolve(form));
        Map<UUID, UUID> permissionIds = new HashMap<>();
        for (DmsFilePermissionEntity permission : permissions) {
            permissionIds.put(permission.getResourceId(), permission.getId());
        }

        DmsWorkflowPrintAuthorizationVO result = new DmsWorkflowPrintAuthorizationVO();
        result.setTaskId(taskId);
        result.setFlowState(task.getStatus());
        result.setFlowStatus(TaskStatusEnum.PASSED.getMessage());
        result.setCompleted(Boolean.TRUE);
        result.setApplicantUserId(applicantUserId);
        for (ResolvedPrintFile file : files) {
            DmsWorkflowPrintFileVO item = new DmsWorkflowPrintFileVO();
            item.setRequestDetailId(file.detail.getId());
            item.setBusinessFileId(file.file.getBusinessFile().getId());
            item.setBusinessFileVersionId(file.file.getBusinessVersion().getId());
            item.setDocumentId(file.file.getFileVersion().getDocumentId());
            item.setFileVersionId(file.file.getFileVersion().getId());
            item.setFileName(file.file.getFileVersion().getFileName());
            item.setMimeType(file.file.getFileVersion().getMimeType());
            item.setSizeBytes(file.file.getFileVersion().getSizeBytes());
            item.setPermissionId(permissionIds.get(file.file.getFileVersion().getId()));
            item.setPermanent(Boolean.TRUE);
            item.setPrintCopies(file.copies);
            item.setPrintPages(trimToNull(file.detail.getPrintPages()));
            item.setPurpose(trimToNull(file.detail.getPurpose()));
            item.setReason(trimToNull(file.detail.getReason()));
            item.setOtherReason(trimToNull(file.detail.getOtherReason()));
            item.setApplicationType(trimToNull(file.detail.getApplicationType()));
            result.getFiles().add(item);
        }
        return result;
    }

    private TaskEntity requireApprovedTask(String flowId, String taskId) {
        TaskEntity task = workFlowApi.getInfoSubmit(taskId);
        if (task == null || !taskId.equals(task.getId())) {
            throw new DataException("未找到与taskId匹配的流程任务");
        }
        if (!flowId.equals(task.getFlowId()) && !flowId.equals(task.getTemplateId())) {
            throw new DataException("流程任务不属于指定flowID");
        }
        if (!TaskStatusEnum.PASSED.getCode().equals(task.getStatus())) {
            throw new DataException("流程任务尚未审核通过，不能授予打印权限");
        }
        return task;
    }

    private DmsWenjianDayinShenqingEntity uniqueRequest(
            List<DmsWenjianDayinShenqingEntity> requests) {
        if (requests == null || requests.isEmpty()) {
            throw new DataException("未找到对应的文件打印申请");
        }
        if (requests.size() != 1) {
            throw new DataException("流程任务关联了多条文件打印申请");
        }
        return requests.get(0);
    }

    private int parseCopies(DmsWenjianDayinShenqingDetailEntity detail) {
        String value = requiredText(detail.getPrintCopies(),
                "打印申请明细缺少打印数量：" + detail.getId());
        try {
            int copies = Integer.parseInt(value);
            if (copies < 1 || copies > 999) {
                throw new NumberFormatException();
            }
            return copies;
        } catch (NumberFormatException exception) {
            throw new DataException("打印申请明细的打印数量必须是 1 到 999 的整数：" + detail.getId());
        }
    }

    private String requiredText(String value, String message) {
        String normalized = trimToNull(value);
        if (normalized == null) {
            throw new DataException(message);
        }
        return normalized;
    }

    private String trimToNull(String value) {
        return value == null || value.trim().isEmpty() ? null : value.trim();
    }

    private static final class ResolvedPrintFile {
        private final DmsWenjianDayinShenqingDetailEntity detail;
        private final DmsWorkflowFileResolutionService.ResolvedFile file;
        private final int copies;

        private ResolvedPrintFile(DmsWenjianDayinShenqingDetailEntity detail,
                                  DmsWorkflowFileResolutionService.ResolvedFile file,
                                  int copies) {
            this.detail = detail;
            this.file = file;
            this.copies = copies;
        }
    }
}