package jnpf.limsService.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import jnpf.audit.sdk.annotation.AuditLog;
import jnpf.exception.DataException;
import jnpf.limsEntity.LimsWendingxingXiaohuiShenqingEntity;
import jnpf.limsMapper.LimsWendingxingXiaohuiShenqingMapper;
import jnpf.limsService.LimsWendingxingXiaohuiShenqingService;
import jnpf.limsService.support.LimsWendingxingXiaohuiFlowStatusResolver;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.StringUtils;

import java.util.List;
import java.util.Objects;

@Service
public class LimsWendingxingXiaohuiShenqingServiceImpl
        implements LimsWendingxingXiaohuiShenqingService {

    @Autowired
    private LimsWendingxingXiaohuiShenqingMapper xiaohuiShenqingMapper;

    @Override
    @Transactional(rollbackFor = Exception.class)
    @AuditLog(action = "FLOW_START", label = "稳定性销毁流程发起", bizType = "WENDINGXING",
            bizCodeExpr = "#flowId", bizCodeRequired = false,
            targetTable = "lims_wendingxing_xiaohui_shenqing",
            targetIdExpr = "T(jnpf.limsService.support.LimsAuditTargetIds).wendingxingDestroyByFlow(#flowId, #taskId)",
            diff = true, entityClass = LimsWendingxingXiaohuiShenqingEntity.class)
    public void syncFlowStarted(String flowId, String taskId) throws DataException {
        LimsWendingxingXiaohuiShenqingEntity shenqing = findByFlow(flowId, taskId);
        if (LimsWendingxingXiaohuiFlowStatusResolver.COMPLETED.equals(shenqing.getBizStatus())) {
            return;
        }
        updateBizStatus(shenqing, LimsWendingxingXiaohuiFlowStatusResolver.PROCESSING);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    @AuditLog(action = "FLOW_END", label = "稳定性销毁流程结束", bizType = "WENDINGXING",
            bizCodeExpr = "#flowId", bizCodeRequired = false,
            targetTable = "lims_wendingxing_xiaohui_shenqing",
            targetIdExpr = "T(jnpf.limsService.support.LimsAuditTargetIds).wendingxingDestroyByFlow(#flowId, #taskId)",
            diff = true, entityClass = LimsWendingxingXiaohuiShenqingEntity.class)
    public void syncFlowEnded(String flowId, String taskId, Integer flowState) throws DataException {
        if (!LimsWendingxingXiaohuiFlowStatusResolver.isTerminal(flowState)) {
            throw new DataException("流程尚未结束，当前状态：" + flowState);
        }
        LimsWendingxingXiaohuiShenqingEntity shenqing = findByFlow(flowId, taskId);
        updateBizStatus(shenqing, LimsWendingxingXiaohuiFlowStatusResolver.COMPLETED);
    }

    private LimsWendingxingXiaohuiShenqingEntity findByFlow(String flowId, String taskId)
            throws DataException {
        String resolvedFlowId = trimToEmpty(flowId);
        String resolvedTaskId = trimToEmpty(taskId);
        if (!StringUtils.hasText(resolvedFlowId)) {
            throw new DataException("流程id(flow_id)不能为空");
        }
        if (!StringUtils.hasText(resolvedTaskId)) {
            throw new DataException("流程任务id(task_id)不能为空");
        }

        LambdaQueryWrapper<LimsWendingxingXiaohuiShenqingEntity> query = new LambdaQueryWrapper<>();
        query.eq(LimsWendingxingXiaohuiShenqingEntity::getFFlowId, resolvedFlowId)
                .eq(LimsWendingxingXiaohuiShenqingEntity::getFFlowTaskId, resolvedTaskId)
                .and(w -> w.isNull(LimsWendingxingXiaohuiShenqingEntity::getFDeleteMark)
                        .or()
                        .ne(LimsWendingxingXiaohuiShenqingEntity::getFDeleteMark, 1));
        List<LimsWendingxingXiaohuiShenqingEntity> list = xiaohuiShenqingMapper.selectList(query);
        if (list == null || list.isEmpty()) {
            throw new DataException("稳定性销毁申请不存在：flow_id=" + resolvedFlowId
                    + ", task_id=" + resolvedTaskId);
        }
        if (list.size() > 1) {
            throw new DataException("多个稳定性销毁申请关联同一流程任务：task_id=" + resolvedTaskId);
        }
        return list.get(0);
    }

    private void updateBizStatus(LimsWendingxingXiaohuiShenqingEntity shenqing, String targetStatus)
            throws DataException {
        if (Objects.equals(shenqing.getBizStatus(), targetStatus)) {
            return;
        }
        LambdaUpdateWrapper<LimsWendingxingXiaohuiShenqingEntity> update = new LambdaUpdateWrapper<>();
        update.eq(LimsWendingxingXiaohuiShenqingEntity::getId, shenqing.getId())
                .eq(LimsWendingxingXiaohuiShenqingEntity::getFTenantId, shenqing.getFTenantId())
                .and(w -> w.isNull(LimsWendingxingXiaohuiShenqingEntity::getFDeleteMark)
                        .or()
                        .ne(LimsWendingxingXiaohuiShenqingEntity::getFDeleteMark, 1))
                .set(LimsWendingxingXiaohuiShenqingEntity::getBizStatus, targetStatus);
        if (xiaohuiShenqingMapper.update(null, update) != 1) {
            throw new DataException("稳定性销毁申请状态更新失败，请刷新后重试");
        }
    }

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