commit heartbeat fix

inspur-work/src/main/java/com/inspur/thrid/PBXConstant.java

@@ -23,6 +23,8 @@ public class PBXConstant {
 
     public static final String CALL_DIAL = "/openapi/v1.0/call/dial?access_token=";
 
+    public static final String WS_HEARTBEAT_RSP = "heartbeat response";
+
 
     public static final String SUBSCRIBE_MESSAGE_LIST = "{\"topic_list\":[30016,30017]}";
 }

inspur-work/src/main/java/com/inspur/thrid/impl/PBXServiceImpl.java

@@ -269,7 +269,6 @@ public class PBXServiceImpl implements IPBXService {
     }
 
     private void transferCall(WsDtmfMessage wsDtmfMessage, ElevatorInfo elevatorInfo) {
-
         // TODO 调用pbx接口转接电话
         Map<String, String> params = new HashMap<String, String>(6);
         // channel_id

inspur-work/src/main/java/com/inspur/websoket/client/PBXWebSocketClient.java

@@ -39,7 +39,13 @@ public class PBXWebSocketClient extends WebSocketClient {
      */
     @Override
     public void onMessage(String message) {
-        log.info("websocket客户端收到消息={}", message);
+        log.info("websocket客户端收到消息 : {}", message);
+
+        // 心跳响应特殊处理
+        if (PBXConstant.WS_HEARTBEAT_RSP.equals(message)) {
+            log.debug("收到心跳响应");
+            return;
+        }
         // 处理收到的消息
         JSONObject messageJson = JSONObject.parseObject(message);
         Integer eventType = messageJson.getInteger("type");