bug fix

src/main/java/org/springblade/modules/job/CarInfoTask.java

@@ -171,7 +171,7 @@ public class CarInfoTask {
             nextSite = preSite;
         }
         BusLine busLine = BusLineCache.getBusLine(info.getUpordown(), nextSite.getSname(), nextSite.getWeizhi());
-        log.info("================BusLineCache.getBusLine(Upordown(), Sname(), Weizhi())");
+        log.info("================ BusLineCache.getBusLine(" + info.getUpordown() + ", " + nextSite.getSname() + ", " + nextSite.getWeizhi() + ")");
 
         // 组织返回数据
         Map<String, Object> resultMap = new HashMap<>();
@@ -182,7 +182,7 @@ public class CarInfoTask {
             resultMap.put("articleData", "");
             resultMap.put("activityData", "");
             resultMap.put("scenicData", "");
-            resultMap.put("imgData", "");
+            resultMap.put("imgData", new ArrayList<>());
             resultMap.put("busNo", "");
             resultMap.put("speed", "");
         } else {

src/main/java/org/springblade/modules/websocket/handler/WebsocketHandler.java

@@ -67,6 +67,7 @@ public class WebsocketHandler extends TextWebSocketHandler {
         System.out.println("Received message from client: " + message.getPayload());
         TextMessage msg = new TextMessage(message.getPayload());
 
+        // 若为返回的接收的推送推流状态结果, 更新到redis, 否则, 原样返回给客户端
         if (Func.isNotBlank(msg.getPayload())) {
             // {"msgType":"status","data":{"status":"ok"}}
             JSONObject jsonObject = JSON.parseObject(msg.getPayload());
@@ -76,6 +77,8 @@ public class WebsocketHandler extends TextWebSocketHandler {
                     redisTemplate.opsForValue().set("websocket-status-return", BusinessConstant.BOOLEAN_STR_TRUE, 5, TimeUnit.SECONDS);
                 }
             }
+        } else {
+            session.sendMessage(msg);
         }
     }
 }