package jnpf.dmsService.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import jnpf.dmsEntity.DmsDanganCundangShenqingDanganheEntity;
import jnpf.dmsEntity.DmsDanganJieyueFuyinShenqingEntity;
import jnpf.dmsEntity.DmsDanganJieyueFuyinShenqingZixiangEntity;
import jnpf.dmsMapper.DmsDanganCundangShenqingDanganheMapper;
import jnpf.dmsMapper.DmsDanganJieyueFuyinShenqingMapper;
import jnpf.dmsMapper.DmsDanganJieyueFuyinShenqingZixiangMapper;
import jnpf.dmsService.DmsDanganJieyueFuyinShenqingTongguoService;
import jnpf.exception.DataException;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.LinkedHashSet;
import java.util.List;
import java.util.Set;

@Service
@RequiredArgsConstructor
public class DmsDanganJieyueFuyinShenqingTongguoServiceImpl
        implements DmsDanganJieyueFuyinShenqingTongguoService {

    private final DmsDanganJieyueFuyinShenqingMapper shenqingMapper;
    private final DmsDanganJieyueFuyinShenqingZixiangMapper zixiangMapper;
    private final DmsDanganCundangShenqingDanganheMapper danganheMapper;

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void tongguo(String flowId, String taskId) throws DataException {
        String resolvedFlowId = requireValue(flowId, "流程ID(flow_id)");
        String resolvedTaskId = requireValue(taskId, "流程任务ID(task_id)");
        DmsDanganJieyueFuyinShenqingEntity shenqing = findApplication(resolvedFlowId, resolvedTaskId);
        Set<String> danganheIds = findDanganheIds(shenqing.getId());
        syncApprovedDetails(shenqing);

        LambdaUpdateWrapper<DmsDanganCundangShenqingDanganheEntity> update = new LambdaUpdateWrapper<>();
        update.in(DmsDanganCundangShenqingDanganheEntity::getId, danganheIds)
                .isNull(DmsDanganCundangShenqingDanganheEntity::getDeleteMark)
                .set(DmsDanganCundangShenqingDanganheEntity::getJieyueId, shenqing.getId());
        if (danganheMapper.update(null, update) != danganheIds.size()) {
            throw new DataException("存在未找到或已删除的档案盒，无法通过借阅复印申请");
        }
    }

    private void syncApprovedDetails(DmsDanganJieyueFuyinShenqingEntity shenqing) {
        LambdaUpdateWrapper<DmsDanganJieyueFuyinShenqingZixiangEntity> update = new LambdaUpdateWrapper<>();
        update.eq(DmsDanganJieyueFuyinShenqingZixiangEntity::getForeignId, shenqing.getId())
                .isNull(DmsDanganJieyueFuyinShenqingZixiangEntity::getDeleteMark)
                .set(DmsDanganJieyueFuyinShenqingZixiangEntity::getShifouYitongguo, "yes")
                .set(DmsDanganJieyueFuyinShenqingZixiangEntity::getShenqingRen, shenqing.getShenqingRen())
                .set(DmsDanganJieyueFuyinShenqingZixiangEntity::getShenqingRiqi, shenqing.getShenqingRiqi())
                .set(DmsDanganJieyueFuyinShenqingZixiangEntity::getShenqingBumen, shenqing.getShenqingBumen());
        zixiangMapper.update(null, update);
    }

    private DmsDanganJieyueFuyinShenqingEntity findApplication(String flowId, String taskId) throws DataException {
        LambdaQueryWrapper<DmsDanganJieyueFuyinShenqingEntity> query = new LambdaQueryWrapper<>();
        query.eq(DmsDanganJieyueFuyinShenqingEntity::getFlowId, flowId)
                .eq(DmsDanganJieyueFuyinShenqingEntity::getFlowTaskId, taskId)
                .isNull(DmsDanganJieyueFuyinShenqingEntity::getDeleteMark);
        List<DmsDanganJieyueFuyinShenqingEntity> applications = shenqingMapper.selectList(query);
        if (applications.isEmpty()) {
            throw new DataException("未找到档案盒借阅复印申请：flow_id=" + flowId + ", task_id=" + taskId);
        }
        if (applications.size() > 1) {
            throw new DataException("flow_id与task_id关联了多条档案盒借阅复印申请，无法确认通过记录");
        }
        return applications.get(0);
    }

    private Set<String> findDanganheIds(String shenqingId) throws DataException {
        LambdaQueryWrapper<DmsDanganJieyueFuyinShenqingZixiangEntity> query = new LambdaQueryWrapper<>();
        query.eq(DmsDanganJieyueFuyinShenqingZixiangEntity::getForeignId, shenqingId)
                .isNull(DmsDanganJieyueFuyinShenqingZixiangEntity::getDeleteMark);
        List<DmsDanganJieyueFuyinShenqingZixiangEntity> details = zixiangMapper.selectList(query);
        if (details.isEmpty()) {
            throw new DataException("档案盒借阅复印申请未关联档案盒明细，无法通过");
        }

        Set<String> ids = new LinkedHashSet<>();
        for (DmsDanganJieyueFuyinShenqingZixiangEntity detail : details) {
            String danganheId = trimToEmpty(detail.getDanganheId());
            if (danganheId.isEmpty()) {
                throw new DataException("档案盒借阅复印申请明细缺少档案盒ID(danganhe_id)");
            }
            ids.add(danganheId);
        }
        return ids;
    }

    private String requireValue(String value, String fieldName) throws DataException {
        String resolved = trimToEmpty(value);
        if (resolved.isEmpty()) {
            throw new DataException(fieldName + "不能为空");
        }
        return resolved;
    }

    private String trimToEmpty(String value) {
        return value == null ? "" : value.trim();
    }
}