添加消息发送

refined-manager/src/main/java/com/mortals/xhx/thread/AlarmSendMsgThread.java

@@ -13,6 +13,7 @@ import com.mortals.xhx.module.alarm.model.AlarmRecordsQuery;
 import com.mortals.xhx.module.alarm.service.AlarmRecordsService;
 import com.mortals.xhx.module.device.service.DeviceService;
 import com.mortals.xhx.queue.*;
+import com.mortals.xhx.utils.SpringUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.rabbit.connection.CorrelationData;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
@@ -31,13 +32,10 @@ import java.util.List;
  * @date: 2025/4/3 17:00
  */
 @Slf4j
-@Service
 public class AlarmSendMsgThread extends AbstractThread {
 
-    @Autowired
     private AlarmRecordsService recordsService;
 
-    @Autowired
     private RabbitTemplate rabbitTemplate;
 
     @Override
@@ -49,6 +47,9 @@ public class AlarmSendMsgThread extends AbstractThread {
     protected void process() {
         log.info("AlarmSendMsgThread process");
 
+        recordsService=SpringUtils.getBean(AlarmRecordsService.class);
+        rabbitTemplate = SpringUtils.getBean(RabbitTemplate.class);
+
         List<AlarmRecordsEntity> alarmRecordsEntities = recordsService.find(new AlarmRecordsQuery().push(YesNoEnum.NO.getValue()));
         for (AlarmRecordsEntity alarmRecordsEntity : alarmRecordsEntities) {