| | |
|---|
| | | public class TTestLiveController extends BaseController |
|---|
| | | { |
|---|
| | | private final ITestLiveService liveService; |
|---|
| | | public TTestLiveController(ITestLiveService liveService) { this.liveService = liveService; } |
|---|
| | | public TTestLiveController(ITestLiveService liveService) |
|---|
| | | { this.liveService = liveService; } |
|---|
| | | |
|---|
| | | @PreAuthorize("@ss.hasPermi('system:test:query')") |
|---|
| | | @GetMapping("/{testId}/live-state") |
|---|
| | | public AjaxResult liveState(@PathVariable Long testId) { return success(liveService.current(testId)); } |
|---|
| | | |
|---|
| | | /** 推送实时快照、设备状态和可追溯的异常事实。 */ |
|---|
| | | @PreAuthorize("@ss.hasPermi('system:test:query')") |
|---|
| | | @GetMapping(value = "/{testId}/live", produces = MediaType.TEXT_EVENT_STREAM_VALUE) |
|---|
| | | public SseEmitter live(@PathVariable Long testId) { return liveService.stream(testId); } |
|---|
