package jnpf.dmsService.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import jnpf.dmsEntity.DmsWenjianBianhaoGuizeEntity;
import jnpf.dmsMapper.DmsWenjianBianhaoGuizeMapper;
import jnpf.dmsService.DmsWenjianBianhaoGuizeTongguoService;
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 DmsWenjianBianhaoGuizeTongguoServiceImpl
        implements DmsWenjianBianhaoGuizeTongguoService {

    private static final String BIZ_ENABLED_DISABLED = "disabled";

    private final DmsWenjianBianhaoGuizeMapper guizeMapper;

    @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)");
        List<DmsWenjianBianhaoGuizeEntity> guizes = findGuizes(resolvedFlowId, resolvedTaskId);
        Set<String> guizeIds = new LinkedHashSet<>();
        Set<String> liushuihaos = new LinkedHashSet<>();
        for (DmsWenjianBianhaoGuizeEntity guize : guizes) {
            guizeIds.add(guize.getId());
            String liushuihao = trimToEmpty(guize.getGuizeLiushuihao());
            if (!liushuihao.isEmpty()) {
                liushuihaos.add(liushuihao);
            }
        }
        for (String liushuihao : liushuihaos) {
            disableOtherRules(liushuihao, guizeIds);
        }
    }

    private List<DmsWenjianBianhaoGuizeEntity> findGuizes(String flowId, String taskId) throws DataException {
        LambdaQueryWrapper<DmsWenjianBianhaoGuizeEntity> query = new LambdaQueryWrapper<>();
        query.eq(DmsWenjianBianhaoGuizeEntity::getFlowId, flowId)
                .eq(DmsWenjianBianhaoGuizeEntity::getFlowTaskId, taskId)
                .isNull(DmsWenjianBianhaoGuizeEntity::getDeleteMark);
        List<DmsWenjianBianhaoGuizeEntity> guizes = guizeMapper.selectList(query);
        if (guizes.isEmpty()) {
            throw new DataException("未找到文件编号规则：flow_id=" + flowId + ", task_id=" + taskId);
        }
        return guizes;
    }

    private void disableOtherRules(String liushuihao, Set<String> currentGuizeIds) {
        LambdaUpdateWrapper<DmsWenjianBianhaoGuizeEntity> update = new LambdaUpdateWrapper<>();
        update.eq(DmsWenjianBianhaoGuizeEntity::getGuizeLiushuihao, liushuihao)
                .notIn(DmsWenjianBianhaoGuizeEntity::getId, currentGuizeIds)
                .and(wrapper -> wrapper.isNull(DmsWenjianBianhaoGuizeEntity::getBizEnabled)
                        .or()
                        .ne(DmsWenjianBianhaoGuizeEntity::getBizEnabled, BIZ_ENABLED_DISABLED))
                .set(DmsWenjianBianhaoGuizeEntity::getBizEnabled, BIZ_ENABLED_DISABLED);
        guizeMapper.update(null, update);
    }

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