定时推送

src/main/java/com/hzjt/config/ScheduleTaskConfig.java

@@ -83,7 +83,7 @@ public class ScheduleTaskConfig {
     /***
      * 每5分钟执行一次查询车流推送给广达
      */
-    @Scheduled(cron = "0 */5 * * * ?")
+    @Scheduled(fixedDelay = 1000*5)
     private void sendToguangdaDevice() {
         log.info("fiveflow  sendto guangda" );
         //查询所有未推送的数据

src/main/java/com/hzjt/service/TraffFlowService.java

@@ -111,7 +111,7 @@ public class TraffFlowService {
         log.info("fiveflow url" +url);
         HttpEntity<List<VideoDeviceTraffic>> requestEntity = new HttpEntity<>(list, headers);
         try{
-            ResultObj obj= CompletableFuture.supplyAsync(() -> restTemplate.postForObject(url, requestEntity, ResultObj.class)).get(timeout,TimeUnit.MILLISECONDS);
+            ResultObj obj=restTemplate.postForObject(url, requestEntity, ResultObj.class);
             log.info("send devicelist to guangda  result "+obj.getStatus()+obj.getData()+obj.getMsg());
         }catch (Exception ex){
             log.error("send devicelist to guangda  error:"+ex.toString());