mirror of
https://gitee.com/pan648540858/wvp-GB28181-pro.git
synced 2026-05-26 23:17:50 +08:00
Compare commits
No commits in common. "d7ba1cab30dba3a915fea939b0f702e660d798c2" and "e22d96cfb79900050c9067e8ea9a797baaffd3e1" have entirely different histories.
d7ba1cab30
...
e22d96cfb7
@ -194,15 +194,6 @@ public class CatalogDataManager implements CommandLineRunner {
|
|||||||
for (String key : keySet) {
|
for (String key : keySet) {
|
||||||
CatalogData catalogData = dataMap.get(key);
|
CatalogData catalogData = dataMap.get(key);
|
||||||
if (catalogData != null && deviceId.equals(catalogData.getDevice().getDeviceId())) {
|
if (catalogData != null && deviceId.equals(catalogData.getDevice().getDeviceId())) {
|
||||||
// 此时检查是否过期
|
|
||||||
Instant instantBefore30S = Instant.now().minusMillis(TimeUnit.SECONDS.toMillis(30));
|
|
||||||
if ((catalogData.getStatus().equals(CatalogData.CatalogDataStatus.end)
|
|
||||||
|| catalogData.getStatus().equals(CatalogData.CatalogDataStatus.ready))
|
|
||||||
&& catalogData.getTime().isBefore(instantBefore30S)) {
|
|
||||||
dataMap.remove(key);
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
return !catalogData.getStatus().equals(CatalogData.CatalogDataStatus.end);
|
return !catalogData.getStatus().equals(CatalogData.CatalogDataStatus.end);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -231,7 +222,6 @@ public class CatalogDataManager implements CommandLineRunner {
|
|||||||
String deviceId = catalogData.getDevice().getDeviceId();
|
String deviceId = catalogData.getDevice().getDeviceId();
|
||||||
int sn = catalogData.getSn();
|
int sn = catalogData.getSn();
|
||||||
List<DeviceChannel> deviceChannelList = getDeviceChannelList(deviceId, sn);
|
List<DeviceChannel> deviceChannelList = getDeviceChannelList(deviceId, sn);
|
||||||
try {
|
|
||||||
if (catalogData.getTotal() == deviceChannelList.size()) {
|
if (catalogData.getTotal() == deviceChannelList.size()) {
|
||||||
deviceChannelService.resetChannels(catalogData.getDevice().getId(), deviceChannelList);
|
deviceChannelService.resetChannels(catalogData.getDevice().getId(), deviceChannelList);
|
||||||
}else {
|
}else {
|
||||||
@ -245,12 +235,8 @@ public class CatalogDataManager implements CommandLineRunner {
|
|||||||
if (groupList != null && !groupList.isEmpty()) {
|
if (groupList != null && !groupList.isEmpty()) {
|
||||||
groupService.batchAdd(groupList);
|
groupService.batchAdd(groupList);
|
||||||
}
|
}
|
||||||
}catch (Exception e) {
|
|
||||||
log.error("[国标通道同步] 入库失败: ", e);
|
|
||||||
}
|
|
||||||
String errorMsg = "更新成功,共" + catalogData.getTotal() + "条,已更新" + deviceChannelList.size() + "条";
|
String errorMsg = "更新成功,共" + catalogData.getTotal() + "条,已更新" + deviceChannelList.size() + "条";
|
||||||
catalogData.setErrorMsg(errorMsg);
|
catalogData.setErrorMsg(errorMsg);
|
||||||
catalogData.setStatus(CatalogData.CatalogDataStatus.end);
|
|
||||||
}else if (catalogData.getStatus().equals(CatalogData.CatalogDataStatus.ready)) {
|
}else if (catalogData.getStatus().equals(CatalogData.CatalogDataStatus.ready)) {
|
||||||
String errorMsg = "同步失败,等待回复超时";
|
String errorMsg = "同步失败,等待回复超时";
|
||||||
catalogData.setErrorMsg(errorMsg);
|
catalogData.setErrorMsg(errorMsg);
|
||||||
|
|||||||
@ -143,7 +143,7 @@ export default {
|
|||||||
isFlv: false,
|
isFlv: false,
|
||||||
isFullResize: false,
|
isFullResize: false,
|
||||||
isNotMute: this.isNotMute,
|
isNotMute: this.isNotMute,
|
||||||
isResize: true,
|
isResize: false,
|
||||||
keepScreenOn: true,
|
keepScreenOn: true,
|
||||||
loadingText: '请稍等, 视频加载中......',
|
loadingText: '请稍等, 视频加载中......',
|
||||||
loadingTimeout: 10,
|
loadingTimeout: 10,
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user