| | |
| | | import java.time.Instant; |
| | | import java.util.List; |
| | | |
| | | /** |
| | | * @author lin |
| | | */ |
| | | public class CatalogData { |
| | | private int sn; // 命令序列号 |
| | | /** |
| | | * 命令序列号 |
| | | */ |
| | | private int sn; |
| | | private int total; |
| | | private List<DeviceChannel> channelList; |
| | | private Instant lastTime; |
| | |
| | | |
| | | /** |
| | | * 摄像机同步状态 |
| | | * @author lin |
| | | */ |
| | | public class SyncStatus { |
| | | private int total; |
| | | private int current; |
| | | private String errorMsg; |
| | | |
| | | private boolean syncIng; |
| | | |
| | | public int getTotal() { |
| | | return total; |
| | |
| | | public void setErrorMsg(String errorMsg) { |
| | | this.errorMsg = errorMsg; |
| | | } |
| | | |
| | | public boolean isSyncIng() { |
| | | return syncIng; |
| | | } |
| | | |
| | | public void setSyncIng(boolean syncIng) { |
| | | this.syncIng = syncIng; |
| | | } |
| | | } |
| | |
| | | syncStatus.setCurrent(catalogData.getChannelList().size()); |
| | | syncStatus.setTotal(catalogData.getTotal()); |
| | | syncStatus.setErrorMsg(catalogData.getErrorMsg()); |
| | | if (catalogData.getStatus().equals(CatalogData.CatalogDataStatus.end)) { |
| | | syncStatus.setSyncIng(false); |
| | | }else { |
| | | syncStatus.setSyncIng(true); |
| | | } |
| | | return syncStatus; |
| | | } |
| | | |
| | |
| | | int sumNum = Integer.parseInt(sumNumElement.getText()); |
| | | |
| | | if (sumNum == 0) { |
| | | logger.info("收到来自设备【{}】的通道: 0个", take.getDevice().getDeviceId()); |
| | | // 数据已经完整接收 |
| | | storager.cleanChannelsForDevice(take.getDevice().getDeviceId()); |
| | | catalogDataCatch.setChannelSyncEnd(take.getDevice().getDeviceId(), null); |
| | |
| | | } |
| | | |
| | | if (res.data.data != null) { |
| | | if (res.data.syncIng) { |
| | | if (res.data.data.total == 0) { |
| | | if (res.data.data.errorMsg !== null ){ |
| | | this.msg = res.data.data.errorMsg; |
| | |
| | | } |
| | | } |
| | | } |
| | | }else { |
| | | this.syncStatus = "success" |
| | | this.percentage = 100; |
| | | this.msg = '同步成功'; |
| | | } |
| | | |
| | | } |
| | | }else { |
| | | if (this.syncFlag) { |
| | | this.syncStatus = "success" |