From 73aa66976e35252378be3f09be2474193ccd0bf6 Mon Sep 17 00:00:00 2001
From: huang <1532065656@qq.com>
Date: 星期五, 05 十二月 2025 17:15:20 +0800
Subject: [PATCH] 修改任务执行步骤状态完成检验
---
mes-processes/mes-plcSend/src/main/java/com/mes/task/controller/TaskStatusNotificationController.java | 11 ++++++++++-
1 files changed, 10 insertions(+), 1 deletions(-)
diff --git a/mes-processes/mes-plcSend/src/main/java/com/mes/task/controller/TaskStatusNotificationController.java b/mes-processes/mes-plcSend/src/main/java/com/mes/task/controller/TaskStatusNotificationController.java
index b5247b8..cdaa096 100644
--- a/mes-processes/mes-plcSend/src/main/java/com/mes/task/controller/TaskStatusNotificationController.java
+++ b/mes-processes/mes-plcSend/src/main/java/com/mes/task/controller/TaskStatusNotificationController.java
@@ -16,15 +16,17 @@
* @since 2025-01-XX
*/
@RestController
-@RequestMapping("/api/plcSend/task/notification")
+@RequestMapping("task/notification")
@Api(tags = "浠诲姟鐘舵�侀�氱煡")
@RequiredArgsConstructor
+@CrossOrigin(origins = "*", maxAge = 3600)
public class TaskStatusNotificationController {
private final TaskStatusNotificationService notificationService;
@GetMapping(value = "/sse", produces = "text/event-stream")
@ApiOperation("鍒涘缓SSE杩炴帴锛岀洃鍚换鍔＄姸鎬佸彉鍖�")
+ @CrossOrigin(origins = "*")
public SseEmitter createConnection(@RequestParam(required = false) String taskId) {
SseEmitter emitter = notificationService.createConnection(taskId);
if (emitter == null) {
@@ -33,8 +35,15 @@
return emitter;
}
+ @RequestMapping(value = "/sse", method = RequestMethod.OPTIONS)
+ @CrossOrigin(origins = "*")
+ public void options() {
+ // 澶勭悊 OPTIONS 棰勬璇锋眰
+ }
+
@GetMapping(value = "/sse/all", produces = "text/event-stream")
@ApiOperation("鍒涘缓SSE杩炴帴锛岀洃鍚墍鏈変换鍔＄姸鎬佸彉鍖�")
+ @CrossOrigin(origins = "*")
public SseEmitter createConnectionForAllTasks() {
return createConnection(null);
}
--
Gitblit v1.8.0