增加假的报警代码

yangys

2024-09-10 1bf92cd596e6d1c259e471dae605fca4d0ed8824

 collect/src/main/java/com/qianwen/mdc/collect/service/IOTMqttReceiveService.java

@@ -27,12 +27,12 @@
   @Autowired
   private  RedisUtil redisUtil;
   /**
    * 处理收到的消息
    * 处理收到的消息,对应TelemetryDataPostingConsumer
    * @param payload
    */
   public void handle(String payload) {
        //System.out.println("Received message122: " + payload);
        //解析消息未
        //解析消息
        List<TelemetryData> teleList = parsePayload(payload);
        
        collectDataService.handleCollectData(teleList);
@@ -86,10 +86,15 @@
        return dtList;
   }
   
   /**
    * 根据对应表缓存，获取appId对应的id
    * @param appId
    * @return
    */
   public long getWorkstationIdByAppId(String appId) {

      Object wid = redisUtil.hget("workstation-appid-map", appId);
      String workstationId = String.valueOf(Optional.ofNullable(wid).orElse("-1"));
      String workstationId = String.valueOf(Optional.ofNullable(wid).orElse(appId));
   
      return Long.parseLong(workstationId);
   }