| | |
|---|
| | | channelList.add(deviceChannel); |
|---|
| | | } |
|---|
| | | int sn = Integer.parseInt(snElement.getText()); |
|---|
| | | logger.info("收到来自设备【{}】的通道: {}个，{}/{}", device.getDeviceId(), channelList.size(), catalogDataCatch.get(key) == null ? 0 :catalogDataCatch.get(key).size(), sumNum); |
|---|
| | | catalogDataCatch.put(device.getDeviceId(), sn, sumNum, device, channelList); |
|---|
| | | logger.info("收到来自设备【{}】的通道: {}个，{}/{}", device.getDeviceId(), channelList.size(), catalogDataCatch.get(device.getDeviceId()) == null ? 0 :catalogDataCatch.get(device.getDeviceId()).size(), sumNum); |
|---|
| | | if (catalogDataCatch.get(device.getDeviceId()).size() == sumNum) { |
|---|
| | | // 数据已经完整接收 |
|---|
| | | boolean resetChannelsResult = storager.resetChannels(device.getDeviceId(), catalogDataCatch.get(device.getDeviceId())); |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | public boolean isSyncRunning(String deviceId) { |
|---|
| | | if (catalogDataCatch.get(deviceId) == null) { |
|---|
| | | return false; |
|---|
| | | }else { |
|---|
| | | return catalogDataCatch.isSyncRunning(deviceId); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | public void setChannelSyncReady(Device device, int sn) { |
|---|
| | | catalogDataCatch.addReady(device, sn); |
|---|
| | | } |
|---|
