From 7f228da10dd393e45c36e1240c5e71aa9f14fc43 Mon Sep 17 00:00:00 2001
From: vince <757871790@qq.com>
Date: 星期五, 07 七月 2023 19:14:26 +0800
Subject: [PATCH] 气象站
---
igds-protocol-bhzn/src/main/java/com/ld/igds/protocol/bhzn/verb/server/BhznVerbMessageConsumer.java | 9 ++++++---
1 files changed, 6 insertions(+), 3 deletions(-)
diff --git a/igds-protocol-bhzn/src/main/java/com/ld/igds/protocol/bhzn/verb/server/BhznVerbMessageConsumer.java b/igds-protocol-bhzn/src/main/java/com/ld/igds/protocol/bhzn/verb/server/BhznVerbMessageConsumer.java
index a358996..56d2940 100644
--- a/igds-protocol-bhzn/src/main/java/com/ld/igds/protocol/bhzn/verb/server/BhznVerbMessageConsumer.java
+++ b/igds-protocol-bhzn/src/main/java/com/ld/igds/protocol/bhzn/verb/server/BhznVerbMessageConsumer.java
@@ -51,13 +51,16 @@
reMessage = JSON.parseObject(message, IoMessage.class);
JSONObject jsonObject = JSON.parseObject(message);
reMessage.setContentStr(jsonObject.getString("content"));
- if (StringUtils.isEmpty(reMessage.getSn()) ||
- reMessage.getStNum()== null ||
+ if (
reMessage.getCmd() == null) {
+
log.error("鎺у埗鏌�------>>>>骞冲彴锛氭姤鏂囦俊鎭笉瀹屾暣锛屼笉鍋氳В鏋�-IP={}锛宲ort={}锛宮sg={}", session.getAddress(), session.getPort(), message);
return;
}
-
+ if(StringUtils.isEmpty(reMessage.getSn())){
+ //姘旇薄绔�
+ reMessage.setSn("9999");
+ }
//鏍规嵁SN鑾峰彇缁勭粐缂栫爜
String companyId = ContextUtil.getCompanyIdBySn(reMessage.getSn());
if (null == companyId) {
--
Gitblit v1.9.3