| | |
| | | */ |
| | | public void analysis(String sessionKey, IoMessage message) throws Exception { |
| | | |
| | | String companyId = ContextUtil.getDefaultCompanyId(); |
| | | //FZZY云服务器-许昌军粮 |
| | | if("1000".equals(companyId)){ |
| | | companyId = "5323"; |
| | | } |
| | | message.setCompanyId(companyId); |
| | | //注册 |
| | | if (BhznGrainV1ServerUtils.FUNCTION_ID_F1.equals(message.getFunctionId())) { |
| | | //DO NOTHING |
| | | |
| | | log.info("主机------->>平台:注册信息报文={}", message); |
| | | DeviceSer ser = coreSerService.getCacheSerBySn("5323",message.getAddr()); |
| | | |
| | | DeviceSer ser = coreSerService.getCacheSerBySn(message.getCompanyId(), message.getAddr()); |
| | | if(ser!= null ){ |
| | | ser.setIp(message.getIp()); |
| | | ser.setPort(message.getPort()); |
| | |
| | | |
| | | //根据分机地址获取分机信息 |
| | | |
| | | DeviceSer ser = coreSerService.getCacheSer("5323", message.getAddr()); |
| | | DeviceSer ser = coreSerService.getCacheSer(message.getCompanyId(), message.getAddr()); |
| | | if (ser == null) { |
| | | replayGrain(message); |
| | | log.error("主机-------->>平台,解析粮情失败,未获取到系统粮情主机配置:" + message.getAddr()); |
| | |
| | | int cableY = 1; |
| | | int cableX = 1; |
| | | |
| | | if(DepotType.TYPE_01.equals(depot.getDepotType())){ |
| | | if(DepotType.TYPE_01.getCode().equals(depot.getDepotType())){ |
| | | cableZ = Integer.valueOf(attCable[0]); |
| | | cableY = Integer.valueOf(attCable[1]); |
| | | cableX = Integer.valueOf(attCable[2]); |
| | |
| | | int cableY = 1; |
| | | int cableX = 1; |
| | | |
| | | if(DepotType.TYPE_01.equals(depot.getDepotType())){ |
| | | if(DepotType.TYPE_01.getCode().equals(depot.getDepotType())){ |
| | | cableZ = Integer.valueOf(attCable[0]); |
| | | cableY = Integer.valueOf(attCable[1]); |
| | | cableX = Integer.valueOf(attCable[2]); |
| | |
| | | int cableY = 1; |
| | | int cableX = 1; |
| | | |
| | | if(DepotType.TYPE_01.equals(depot.getDepotType())){ |
| | | if(DepotType.TYPE_01.getCode().equals(depot.getDepotType())){ |
| | | cableZ = Integer.valueOf(attCable[0]); |
| | | cableY = Integer.valueOf(attCable[1]); |
| | | cableX = Integer.valueOf(attCable[2]); |
| | |
| | | private void analysisTh(IoMessage message) { |
| | | try { |
| | | THDto th = new THDto(); |
| | | th.setCompanyId("5323"); |
| | | th.setCompanyId(message.getCompanyId()); |
| | | String data = message.getContent(); |
| | | String houseNo = data.substring(0, 2); |
| | | String t = data.substring(4, 8); |