| | |
|---|
| | | if(orgBusi == null){ |
|---|
| | | log.error("严重错误，未能得到标签为" + nbRtu.orgTag + "的供水机构数据库业务Busi"); |
|---|
| | | }else{ |
|---|
| | | BaMeter meter = DbOrgBuzi.getMeterByImeiAndNo(orgBusi, imei, meterNo) ; |
|---|
| | | BaMeter meter = DbOrgBuzi.getMeterByImeiAndNo(orgBusi, imei, rtuAddr) ; |
|---|
| | | //可能未查询到meter，即仍是流浪者RTU，但仍要后续处理：（1）、仍能识别出流浪者RTU，（2）、仍要记录其上报数据 |
|---|
| | | if(meter != null){ |
|---|
| | | String protocol = d.getProtocol() ; |
|---|
| | |
|---|
| | | }else{ |
|---|
| | | //NB产品（RTU实体）未分配给具体的供水机构 |
|---|
| | | //流浪者RTU |
|---|
| | | rtuTramp = DbSyBuzi.getSyRtuTramp(baseBusi, imei, meterNo) ; |
|---|
| | | rtuTramp = DbSyBuzi.getSyRtuTramp(baseBusi, imei, rtuAddr) ; |
|---|
| | | if(rtuTramp == null){ |
|---|
| | | rtuTramp = new SyRtuTramp(imei, meterNo) ; |
|---|
| | | rtuTramp = new SyRtuTramp(imei, rtuAddr) ; |
|---|
| | | } |
|---|
| | | this.taskResult = new Object[]{baseBusi, orgBusi, nbRtu, rtuTramp, null} ; |
|---|
| | | this.toNextOneTask(data, TkDealRtuTramp.taskId); |
|---|
| | |
|---|
| | | }else{ |
|---|
| | | //数据库中未查询到NB产品（RTU实体） |
|---|
| | | //流浪者RTU |
|---|
| | | rtuTramp = DbSyBuzi.getSyRtuTramp(baseBusi, imei, meterNo) ; |
|---|
| | | rtuTramp = DbSyBuzi.getSyRtuTramp(baseBusi, imei, rtuAddr) ; |
|---|
| | | if(rtuTramp == null){ |
|---|
| | | rtuTramp = new SyRtuTramp(imei, meterNo) ; |
|---|
| | | rtuTramp = new SyRtuTramp(imei, rtuAddr) ; |
|---|
| | | } |
|---|
| | | this.taskResult = new Object[]{baseBusi, orgBusi, nbRtu, rtuTramp, null} ; |
|---|
| | | this.toNextOneTask(data, TkDealRtuTramp.taskId); |
|---|
