Browse Source

增加经纬 心跳配置 增加输出日志

jianghouwei 6 years ago
parent
commit
123906de0e

+ 4 - 1
src/main/java/com/tidecloud/dataacceptance/service/impl/WatchJWServerHandler.java

@@ -167,6 +167,7 @@ public class WatchJWServerHandler extends HexBinaryAcceptanceHandlerAdapter {
                     normalReply(factory, channel, "BPHT");
                     if (beatMap.containsKey(deviceId)) {
                         beatMap.put(deviceId, 2);
+                        logger.warn("标记APHT=2参数状态变更deviceId=" + deviceId);
                     }
                     break;
                 case "AP49": // 心率上传  IWAP49,68#
@@ -177,10 +178,12 @@ public class WatchJWServerHandler extends HexBinaryAcceptanceHandlerAdapter {
                     normalReply(factory, channel, "BP49");
                     if (beatMap.containsKey(deviceId)) {
                         beatMap.put(deviceId, 2);
+                        logger.warn("标记AP49=2参数状态变更deviceId=" + deviceId);
                     }
                     break;
                 case "APXL": // 心率主动下发,终端回复
                     beatMap.put(deviceId, 1);// 标记下发成功
+                    logger.warn("标记APXL = 1参数状态变更deviceId=" + deviceId);
                     break;
                 case "AP07": // 语音上传
                     // TODO 设置语音上传  IWAP07,20140818064408,6,1,1024,XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX#
@@ -256,6 +259,7 @@ public class WatchJWServerHandler extends HexBinaryAcceptanceHandlerAdapter {
                 }
             } else {
                 beatMap.remove(deviceId);
+                logger.warn("标记参数移除deviceId=" + deviceId);
             }
         } catch (Exception e) {
             logger.error("心率下行发送异常!!!!! deviceId=" + deviceId);
@@ -356,7 +360,6 @@ public class WatchJWServerHandler extends HexBinaryAcceptanceHandlerAdapter {
             byte[] bytes = new byte[voiceMsg.getLength() + 1];
             byteBufIn.readBytes(bytes);
             String msg1 = new String(bytes, "UTF-8");
-            logger.warn("入库参数" + msg1);
             voiceMsg.setMsg(bytes);
         } catch (Exception e) {
             logger.warn("语音解析错无" + JSON.toJSONString(voiceMsg) + ":" + e.getStackTrace());