package jnpf.dmsService;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import jnpf.base.ActionResult;
import jnpf.base.ActionResultCode;
import jnpf.dms.DmsResourceApi;
import jnpf.dmsEntity.DmsWenjianBanbenEntity;
import jnpf.dmsEntity.download.entity.DmsWenjianXiazaiShenqingDetailEntity;
import jnpf.dmsEntity.download.entity.DmsWenjianXiazaiShenqingEntity;
import jnpf.dmsEntity.permission.form.DmsPersonalFolderDownloadForm;
import jnpf.dmsEntity.permission.vo.DmsPersonalFolderAddResultVO;
import jnpf.dmsMapper.DmsWenjianBanbenMapper;
import jnpf.dmsMapper.DmsWenjianXiazaiShenqingDetailMapper;
import jnpf.dmsMapper.DmsWenjianXiazaiShenqingMapper;
import jnpf.exception.DataException;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.Date;
import java.util.LinkedHashMap;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.UUID;

/** 文件辅助管理中的下载授权业务。 */
@Service
@RequiredArgsConstructor
public class DmsWenjianFuzhuGuanliXiazaiService {

    private static final String FLOWABLE_SERVICE_ID = "jnpf-flowable";

    private final DmsWenjianXiazaiShenqingMapper shenqingMapper;
    private final DmsWenjianXiazaiShenqingDetailMapper zixiangMapper;
    private final DmsWenjianBanbenMapper banbenMapper;
    private final DmsResourceApi dmsResourceApi;

    /**
     * 根据流程申请把获批下载的文件版本加入申请人的个人文件夹。
     */
    public DmsPersonalFolderAddResultVO xiazaiWenjianShouquan(
            String flowId, String flowTaskId) {
        String normalizedFlowId = requireValue(flowId, "流程ID(flow_id)");
        String normalizedFlowTaskId = requireValue(flowTaskId, "流程任务ID(flow_task_id)");
        DmsWenjianXiazaiShenqingEntity shenqing = findShenqing(
                normalizedFlowId, normalizedFlowTaskId);
        List<DmsWenjianXiazaiShenqingDetailEntity> zixiangs = findZixiangs(shenqing.getId());
        Set<String> banbenIds = extractBanbenIds(zixiangs);
        Map<String, DmsWenjianBanbenEntity> banbenById = findBanbens(banbenIds);
        List<DownloadAuthorizationTarget> targets = buildAuthorizationTargets(zixiangs, banbenById);
        DmsPersonalFolderDownloadForm downloadForm = buildDownloadForm(shenqing, targets);

        ActionResult<DmsPersonalFolderAddResultVO> response;
        try {
            response = dmsResourceApi.addDownloadedFilesToPersonalFolder(
                    FLOWABLE_SERVICE_ID, downloadForm);
        } catch (RuntimeException exception) {
            throw new DataException("调用DMS个人文件夹下载授权接口失败");
        }
        if (response == null || !ActionResultCode.SUCCESS.getCode().equals(response.getCode())
                || response.getData() == null) {
            String message = response == null ? null : response.getMsg();
            throw new DataException(isBlank(message) ? "下载文件授权失败或响应数据不完整" : message);
        }
        return response.getData();
    }

    /** 查询流程唯一对应的未删除下载申请。 */
    private DmsWenjianXiazaiShenqingEntity findShenqing(String flowId, String flowTaskId) {
        LambdaQueryWrapper<DmsWenjianXiazaiShenqingEntity> query = new LambdaQueryWrapper<>();
        query.eq(DmsWenjianXiazaiShenqingEntity::getFlowId, flowId)
                .eq(DmsWenjianXiazaiShenqingEntity::getFlowTaskId, flowTaskId)
                .isNull(DmsWenjianXiazaiShenqingEntity::getDeleteMark);
        List<DmsWenjianXiazaiShenqingEntity> rows = shenqingMapper.selectList(query);
        if (rows.isEmpty()) {
            throw new DataException("未找到文件下载申请：flow_id=" + flowId
                    + ", flow_task_id=" + flowTaskId);
        }
        if (rows.size() > 1) {
            throw new DataException("flow_id与flow_task_id关联了多条文件下载申请，无法授权");
        }
        return rows.get(0);
    }

    /** 根据申请主键查询未删除的下载申请明细。 */
    private List<DmsWenjianXiazaiShenqingDetailEntity> findZixiangs(String shenqingId) {
        LambdaQueryWrapper<DmsWenjianXiazaiShenqingDetailEntity> query = new LambdaQueryWrapper<>();
        query.eq(DmsWenjianXiazaiShenqingDetailEntity::getRequestId, shenqingId)
                .isNull(DmsWenjianXiazaiShenqingDetailEntity::getDeleteMark);
        List<DmsWenjianXiazaiShenqingDetailEntity> rows = zixiangMapper.selectList(query);
        if (rows.isEmpty()) {
            throw new DataException("文件下载申请未关联下载明细，无法授权");
        }
        return rows;
    }

    /** 从下载明细提取业务版本 ID，并保持原顺序去重。 */
    private Set<String> extractBanbenIds(List<DmsWenjianXiazaiShenqingDetailEntity> zixiangs) {
        Set<String> ids = new LinkedHashSet<>();
        for (DmsWenjianXiazaiShenqingDetailEntity zixiang : zixiangs) {
            ids.add(requireValue(zixiang.getBanbenId(), "文件下载明细版本ID(banben_id)"));
        }
        return ids;
    }

    /** 按明细版本 ID 查询未删除的业务文件版本。 */
    private Map<String, DmsWenjianBanbenEntity> findBanbens(Set<String> banbenIds) {
        LambdaQueryWrapper<DmsWenjianBanbenEntity> query = new LambdaQueryWrapper<>();
        query.in(DmsWenjianBanbenEntity::getId, banbenIds)
                .isNull(DmsWenjianBanbenEntity::getDeleteMark);
        List<DmsWenjianBanbenEntity> rows = banbenMapper.selectList(query);
        if (rows.size() != banbenIds.size()) {
            throw new DataException("部分下载明细未找到对应的有效文件版本");
        }

        Map<String, DmsWenjianBanbenEntity> result = new LinkedHashMap<>();
        for (DmsWenjianBanbenEntity row : rows) {
            result.put(row.getId(), row);
        }
        return result;
    }

    /** 关联下载时限与文件中心文件、版本 ID，形成待授权数据。 */
    private List<DownloadAuthorizationTarget> buildAuthorizationTargets(
            List<DmsWenjianXiazaiShenqingDetailEntity> zixiangs,
            Map<String, DmsWenjianBanbenEntity> banbenById) {
        List<DownloadAuthorizationTarget> targets = new ArrayList<>(zixiangs.size());
        for (DmsWenjianXiazaiShenqingDetailEntity zixiang : zixiangs) {
            String banbenId = zixiang.getBanbenId().trim();
            requireValue(zixiang.getXiazaiShixian(), "文件下载明细下载时限(xiazai_shixian)");
            DmsWenjianBanbenEntity banben = banbenById.get(banbenId);
            if (banben == null) {
                throw new DataException("未找到文件版本：banben_id=" + banbenId);
            }
            requireValue(banben.getWenjianZhongxinBanbenId(), "文件中心版本ID");
            requireValue(banben.getWenjianZhongxinWenjianId(), "文件中心文件ID");
            targets.add(new DownloadAuthorizationTarget(zixiang, banben));
        }
        return targets;
    }

    /** 组装个人文件夹下载授权请求。 */
    private DmsPersonalFolderDownloadForm buildDownloadForm(
            DmsWenjianXiazaiShenqingEntity shenqing,
            List<DownloadAuthorizationTarget> targets) {
        List<DmsPersonalFolderDownloadForm.FileRelation> files =
                new ArrayList<>(targets.size());
        for (DownloadAuthorizationTarget target : targets) {
            DmsPersonalFolderDownloadForm.FileRelation relation =
                    new DmsPersonalFolderDownloadForm.FileRelation();
            try {
                relation.setDocumentId(UUID.fromString(
                        target.banben.getWenjianZhongxinWenjianId().trim()));
                relation.setFileVersionId(UUID.fromString(
                        target.banben.getWenjianZhongxinBanbenId().trim()));
            } catch (IllegalArgumentException exception) {
                throw new DataException("文件中心文件ID或版本ID格式不正确：banben_id="
                        + target.banben.getId());
            }
            relation.setValidTo(calculateValidTo(
                    target.zixiang.getXiazaiShixian(), target.banben.getId()));
            files.add(relation);
        }

        DmsPersonalFolderDownloadForm form = new DmsPersonalFolderDownloadForm();
        form.setUserId(requireValue(shenqing.getApplicantUserId(), "文件下载申请人(shenqing_ren)"));
        form.setFiles(files);
        form.setRequestId(shenqing.getId());
        return form;
    }

    /** 将下载时限转换为当天结束时间；na 表示永久有效。 */
    private Date calculateValidTo(String rawXiazaiShixian, String banbenId) {
        return DmsDownloadDeadline.resolve(rawXiazaiShixian, banbenId);
    }

    private String requireValue(String value, String fieldName) {
        if (isBlank(value)) {
            throw new DataException(fieldName + "不能为空");
        }
        return value.trim();
    }

    private boolean isBlank(String value) {
        return value == null || value.trim().isEmpty();
    }

    /** 单条待授权文件数据。 */
    private static final class DownloadAuthorizationTarget {
        private final DmsWenjianXiazaiShenqingDetailEntity zixiang;
        private final DmsWenjianBanbenEntity banben;

        private DownloadAuthorizationTarget(DmsWenjianXiazaiShenqingDetailEntity zixiang,
                                            DmsWenjianBanbenEntity banben) {
            this.zixiang = zixiang;
            this.banben = banben;
        }
    }
}