1

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) {