| | |
|---|
| | | 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={}，port={}，msg={}", session.getAddress(), session.getPort(), message); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | if(StringUtils.isEmpty(reMessage.getSn())){ |
|---|
| | | //气象站 |
|---|
| | | reMessage.setSn("9999"); |
|---|
| | | } |
|---|
| | | //根据SN获取组织编码 |
|---|
| | | String companyId = ContextUtil.getCompanyIdBySn(reMessage.getSn()); |
|---|
| | | if (null == companyId) { |
|---|
