package com.mes.task.service;
|
|
import com.mes.task.entity.MultiDeviceTask;
|
import com.mes.task.entity.TaskStepDetail;
|
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
|
|
import java.util.List;
|
|
/**
|
* 任务状态通知服务
|
* 用于实时推送任务执行状态
|
*
|
* @author mes
|
* @since 2025-01-XX
|
*/
|
public interface TaskStatusNotificationService {
|
|
/**
|
* 创建SSE连接
|
*
|
* @param taskId 任务ID（可选，如果为null则监听所有任务）
|
* @return SSE发射器
|
*/
|
SseEmitter createConnection(String taskId);
|
|
/**
|
* 发送任务状态更新
|
*
|
* @param task 任务实体
|
*/
|
void notifyTaskStatus(MultiDeviceTask task);
|
|
/**
|
* 发送任务步骤更新
|
*
|
* @param taskId 任务ID
|
* @param step 步骤详情
|
*/
|
void notifyStepUpdate(String taskId, TaskStepDetail step);
|
|
/**
|
* 发送任务步骤列表更新
|
*
|
* @param taskId 任务ID
|
* @param steps 步骤列表
|
*/
|
void notifyStepsUpdate(String taskId, List<TaskStepDetail> steps);
|
|
/**
|
* 关闭指定任务的连接
|
*
|
* @param taskId 任务ID
|
*/
|
void closeConnections(String taskId);
|
|
/**
|
* 关闭所有连接
|
*/
|
void closeAllConnections();
|
}
|
