EasyGBS向多个级联平台上传通道的异常现象分析与解决

原创

TSINGSEE青犀视频

发布于 2022-10-21 09:05:11

27500

代码可运行

文章被收录于专栏：TSINGSEE青犀视频TSINGSEE青犀视频

运行总次数：0

代码可运行

国标视频云服务EasyGBS支持设备/平台通过国标GB28181协议注册接入，并能实现视频的实时监控直播、录像、检索与回看、语音对讲、云存储、告警、平台级联等功能。其中，级联功能可以实现平台与平台之间的数据互联互通，降低数据共享难度，在很多安防场景中均有应用，如明厨亮灶、平安乡村等。

我们在测试平台功能时发现，当EasyGBS向多个上级平台级联，选择通道时，会出现选中其他级联平台的通道，影响到前一个平台的设备选择。

于是我们对该情况进行了排查。经过分析发现，在级联选择通道时，没有指定级联信息的ID，所以出现了上述情况，如图所示：

else if opt == "del" {
		for i, v := range ids {
			ids := strings.Split(v, ",")
			if len(ids) != 2 {
				break
			}
			if i == 0 {
				sql = fmt.Sprintf(`(channel_id = '%s' and device_id = '%s' )`, ids[0], ids[1])
			} else {
				sql = fmt.Sprintf(` %s or (channel_id = '%s' and device_id = '%s')`, sql, ids[0], ids[1])
			}
		}
		if len(ids) > 0 {
			if err := db.SQLite.Delete(models.CascadeChannel{}, sql).Error; err != nil {
				c.AbortWithStatusJSON(400, err.Error())
				return
			}
		}

	}

可添加如下代码：

for i, v := range ids {
			ids := strings.Split(v, ",")
			if len(ids) != 2 {
				break
			}
			if i == 0 {
				sql = fmt.Sprintf(`(channel_id = '%s' and device_id = '%s' and cascade_id = '%d')`, ids[0], ids[1], cascade_id)
			} else {
				sql = fmt.Sprintf(` %s or (channel_id = '%s' and device_id = '%s' and cascade_id = '%d')`, sql, ids[0], ids[1], cascade_id)
			}
		}
		if len(ids) > 0 {
			if err := db.SQLite.Delete(models.CascadeChannel{}, sql).Error; err != nil {
				c.AbortWithStatusJSON(400, err.Error())
				return
			}
		}