| | |
|---|
| | | */ |
|---|
| | | |
|---|
| | | //设置收到数据时刻 |
|---|
| | | TcpSessionCache.cacheUpDataTime(rtuAddr); |
|---|
| | | TcpSessionCache.whenUpData(rtuAddr); |
|---|
| | | |
|---|
| | | if(protocolName != null){ |
|---|
| | | //对上行数据进行处理 |
|---|
| | |
|---|
| | | }else{ |
|---|
| | | MidResult[] midRs = dri.parseData(ServerProperties.isLowPower, rtuAddrAtHead, upBuf, upHex, new DriverParserDataCallback(){ |
|---|
| | | @Override |
|---|
| | | public void callback(String rtuAddrAtHead, String code, String codeName, String upHex, Boolean reportOrResponse_trueOrFalse, boolean parseFail, String rtuAddrInData) { |
|---|
| | | public void callback(String rtuAddrAtHead, |
|---|
| | | String code, |
|---|
| | | String codeName, |
|---|
| | | String upHex, |
|---|
| | | Boolean reportOrResponse_trueOrFalse, |
|---|
| | | boolean parseFail, |
|---|
| | | String rtuAddrInData, |
|---|
| | | Object ...objs) { |
|---|
| | | //更新终端状态 |
|---|
| | | if(rtuAddrInData != null && !rtuAddrInData.equals(rtuAddrAtHead)){ |
|---|
| | | //数据头中的RTU地址与数据中的RTU地址不一致，更换成数据中的RTU地址 |
|---|
| | |
|---|
| | | @Override |
|---|
| | | public void exception(Exception e) { |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | }, objs); |
|---|
| | | } |
|---|
| | | }) ; |
|---|
| | | if(midRs != null){ |
|---|
