| | |
| | | public void onSubscribe(String identifier, Object value) { |
| | | |
| | | try { |
| | | if(null != value) { |
| | | if(null != value && Integer.valueOf(value.toString())!= 0) { |
| | | String[] nodes = identifier.split("[.]"); |
| | | String thoroughfare = nodes[0];//通道 |
| | | String device = nodes[1];//设备 |
| | |
| | | recordDataDoneValue = outSaveDate(thoroughfare,device); |
| | | //记录数据完成 |
| | | String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone"; |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(Integer.valueOf(RecordDataDoneAddress)).build()); |
| | | miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(Integer.valueOf(recordDataDoneValue)).build()); |
| | | }else { |
| | | //手动工位 |
| | | WebSocketUsers.sendMessageToUserByText(map.get(device), "END"); |