package org.sxkj.gd.workorder.utils;

import lombok.extern.slf4j.Slf4j;
import org.sxkj.gd.workorder.entity.GdPatrolTaskEntity;
import org.sxkj.gd.workorder.enums.PatrolTaskStatusEnum;
import org.sxkj.gd.workorder.enums.WorkOrderStatusEnum;

import java.util.List;
import java.util.Objects;
import java.util.Optional;
import java.util.stream.Collectors;

/**
 * 工单状态聚合工具类
 * 用于根据子任务状态计算主任务状态
 *
 * @author lw
 * @since 2026-06-26
 */
@Slf4j
public class WorkOrderStatusAggregator {

	/**
	 * 根据子任务列表聚合计算主任务状态
	 *
	 * @param subTasks 子任务列表
	 * @return 主任务状态，如果没有有效子任务则返回"接单响应_已取消"
	 */
	public static WorkOrderStatusEnum aggregateWorkOrderStatus(List<GdPatrolTaskEntity> subTasks) {
		// 1. 参数校验：防止空指针
		if (subTasks == null || subTasks.isEmpty()) {
			log.warn("子任务列表为空，返回默认状态：接单响应_已取消");
			return WorkOrderStatusEnum.RESPONDING_CANCELED;
		}

		// 2. 过滤有效子任务（排除忽略状态）
		List<GdPatrolTaskEntity> validSubTasks = subTasks.stream()
			.filter(task -> task != null && task.getTaskStatus() != null)
			.filter(task -> {
				PatrolTaskStatusEnum statusEnum = PatrolTaskStatusEnum.getByValue(task.getTaskStatus());
				return statusEnum != null && !statusEnum.isShouldIgnore();
			})
			.collect(Collectors.toList());

		// 3. 如果没有有效子任务，返回"接单响应_已取消"
		if (validSubTasks.isEmpty()) {
			log.info("所有子任务都被撤回或拒绝，主任务状态：接单响应_已取消");
			return WorkOrderStatusEnum.RESPONDING_CANCELED;
		}

		// 4. 找到权重最小的有效子任务状态（进度最慢）
		Optional<PatrolTaskStatusEnum> minWeightStatus = validSubTasks.stream()
			.map(task -> PatrolTaskStatusEnum.getByValue(task.getTaskStatus()))
			.filter(Objects::nonNull)
			.min((s1, s2) -> Integer.compare(s1.getWeight(), s2.getWeight()));

		// 5. 如果找到最小权重状态，返回对应的主任务状态
		if (minWeightStatus.isPresent()) {
			WorkOrderStatusEnum workOrderStatus = minWeightStatus.get().getWorkOrderStatusMapping();
			log.info("最小进度子任务状态：{}，对应主任务状态：{}", 
				minWeightStatus.get().getDesc(), workOrderStatus.getDesc());
			return workOrderStatus;
		}

		// 6. 兜底逻辑：返回默认状态
		log.warn("无法找到有效的主任务状态映射，返回默认状态：接单响应_已取消");
		return WorkOrderStatusEnum.RESPONDING_CANCELED;
	}
}