From 19f59c243e8df97c8b9fd9dba4e758be8235d68b Mon Sep 17 00:00:00 2001
From: huang <1532065656@qq.com>
Date: 星期二, 25 十一月 2025 17:02:54 +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