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.DmsDanganXiaohuiShenqingEntity;
import jnpf.dmsEntity.DmsDanganXiaohuiShenqingZixiangEntity;
import jnpf.dmsMapper.DmsDanganCundangShenqingDanganheMapper;
import jnpf.dmsMapper.DmsDanganXiaohuiShenqingMapper;
import jnpf.dmsMapper.DmsDanganXiaohuiShenqingZixiangMapper;
import jnpf.dmsService.DmsDanganXiaohuiShenqingTongguoService;
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 DmsDanganXiaohuiShenqingTongguoServiceImpl
        implements DmsDanganXiaohuiShenqingTongguoService {

    private final DmsDanganXiaohuiShenqingMapper shenqingMapper;
    private final DmsDanganXiaohuiShenqingZixiangMapper 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)");

        DmsDanganXiaohuiShenqingEntity shenqing = findApplication(resolvedFlowId, resolvedTaskId);
        Set<String> danganheIds = findDanganheIds(shenqing.getId());
        List<DmsDanganCundangShenqingDanganheEntity> danganheList = findSourceDanganhe(danganheIds);
        ensureAssignable(danganheList, shenqing.getId());

        LambdaUpdateWrapper<DmsDanganCundangShenqingDanganheEntity> update = new LambdaUpdateWrapper<>();
        update.in(DmsDanganCundangShenqingDanganheEntity::getId, danganheIds)
                .isNull(DmsDanganCundangShenqingDanganheEntity::getDeleteMark)
                .and(wrapper -> wrapper.isNull(DmsDanganCundangShenqingDanganheEntity::getXiaohuiId)
                        .or()
                        .eq(DmsDanganCundangShenqingDanganheEntity::getXiaohuiId, shenqing.getId()))
                .set(DmsDanganCundangShenqingDanganheEntity::getXiaohuiId, shenqing.getId());
        if (danganheMapper.update(null, update) != danganheIds.size()) {
            throw new DataException("档案盒销毁关联发生并发变更，请重新处理");
        }
    }

    private DmsDanganXiaohuiShenqingEntity findApplication(String flowId, String taskId) throws DataException {
        LambdaQueryWrapper<DmsDanganXiaohuiShenqingEntity> query = new LambdaQueryWrapper<>();
        query.eq(DmsDanganXiaohuiShenqingEntity::getFlowId, flowId)
                .eq(DmsDanganXiaohuiShenqingEntity::getFlowTaskId, taskId)
                .isNull(DmsDanganXiaohuiShenqingEntity::getDeleteMark);
        List<DmsDanganXiaohuiShenqingEntity> 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<DmsDanganXiaohuiShenqingZixiangEntity> query = new LambdaQueryWrapper<>();
        query.eq(DmsDanganXiaohuiShenqingZixiangEntity::getForeignId, shenqingId)
                .isNull(DmsDanganXiaohuiShenqingZixiangEntity::getDeleteMark);
        List<DmsDanganXiaohuiShenqingZixiangEntity> details = zixiangMapper.selectList(query);
        if (details.isEmpty()) {
            throw new DataException("档案销毁申请未关联档案盒明细，无法通过");
        }
        Set<String> ids = new LinkedHashSet<>();
        for (DmsDanganXiaohuiShenqingZixiangEntity detail : details) {
            String danganheId = trimToEmpty(detail.getDanganheId());
            if (danganheId.isEmpty()) {
                throw new DataException("档案销毁申请明细缺少档案盒ID(danganhe_id)");
            }
            if (!ids.add(danganheId)) {
                throw new DataException("档案销毁申请明细包含重复档案盒ID(danganhe_id)");
            }
        }
        return ids;
    }

    private List<DmsDanganCundangShenqingDanganheEntity> findSourceDanganhe(Set<String> danganheIds)
            throws DataException {
        LambdaQueryWrapper<DmsDanganCundangShenqingDanganheEntity> query = new LambdaQueryWrapper<>();
        query.in(DmsDanganCundangShenqingDanganheEntity::getId, danganheIds)
                .isNull(DmsDanganCundangShenqingDanganheEntity::getDeleteMark);
        List<DmsDanganCundangShenqingDanganheEntity> danganheList = danganheMapper.selectList(query);
        if (danganheList.size() != danganheIds.size()) {
            throw new DataException("存在未找到或已删除的档案盒，无法通过销毁申请");
        }
        return danganheList;
    }

    private void ensureAssignable(List<DmsDanganCundangShenqingDanganheEntity> danganheList, String shenqingId)
            throws DataException {
        for (DmsDanganCundangShenqingDanganheEntity danganhe : danganheList) {
            String currentXiaohuiId = trimToEmpty(danganhe.getXiaohuiId());
            if (!currentXiaohuiId.isEmpty() && !shenqingId.equals(currentXiaohuiId)) {
                throw new DataException("档案盒已关联其他销毁申请，无法重复通过");
            }
        }
    }

    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();
    }
}