设备上报

src/main/java/com/cec/plugins/service/task/DeviceScheduleService.java

@@ -5,6 +5,8 @@ import com.cec.plugins.enumerate.DeviceEnum;
 import com.cec.plugins.service.RedisClientSource;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
 /**
@@ -20,6 +22,8 @@ public class DeviceScheduleService {
     private final RedisClientSource redisClientSource;
     private final ReportService reportService;
 
+    @Async
+    @Scheduled(fixedDelayString = "${project.platform.fixed-delay}")
     public void heartbeat() {
         DeviceDto dto = new DeviceDto();
         for (DeviceEnum deviceEnum : DeviceEnum.values()) {