From 3323b4f6b4cc38bb3d76936a56dbcfabc534baab Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=BC=A0=E6=88=90?= <light.zhang@ysinc.com>
Date: Thu, 18 Dec 2025 13:10:15 +0800
Subject: [PATCH] 1

---
 api/middleware/schedule/taskQueue.js | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/api/middleware/schedule/taskQueue.js b/api/middleware/schedule/taskQueue.js
index fb9bebd..6645aba 100644
--- a/api/middleware/schedule/taskQueue.js
+++ b/api/middleware/schedule/taskQueue.js
@@ -8,6 +8,7 @@ const ErrorHandler = require('./ErrorHandler');
 const deviceManager = require('./deviceManager');
 const ScheduleUtils = require('./utils');
 const ScheduleConfig = require('./config');
+const deviceWorkStatusNotifier = require('./deviceWorkStatusNotifier');
 
 /**
  * 任务队列管理器（重构版）
@@ -583,7 +584,6 @@ class TaskQueue {
             );
 
             // 推送设备工作状态（任务开始执行）
-            const deviceWorkStatusNotifier = require('./deviceWorkStatusNotifier');
             const summary = await this.getTaskStatusSummary(task.sn_code);
             await deviceWorkStatusNotifier.sendDeviceWorkStatus(task.sn_code, summary);
 
@@ -622,8 +622,7 @@ class TaskQueue {
                 { where: { id: task.id } }
             );
 
-            // 推送设备工作状态（任务完成）
-            const deviceWorkStatusNotifier = require('./deviceWorkStatusNotifier');
+         
             const summary = await this.getTaskStatusSummary(task.sn_code);
             await deviceWorkStatusNotifier.sendDeviceWorkStatus(task.sn_code, summary);
 
@@ -662,7 +661,6 @@ class TaskQueue {
                 );
 
                 // 推送设备工作状态（任务失败）
-                const deviceWorkStatusNotifier = require('./deviceWorkStatusNotifier');
                 const summary = await this.getTaskStatusSummary(task.sn_code);
                 await deviceWorkStatusNotifier.sendDeviceWorkStatus(task.sn_code, summary);
             } catch (dbError) {