From 9e2477ea31a86bbda235cb39af1711c219492589 Mon Sep 17 00:00:00 2001
From: ydajiang <diyidacheng@gmail.com>
Date: Wed, 24 Sep 2025 20:08:06 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E5=88=A0=E9=99=A4=E5=B9=BF=E6=92=AD?=
 =?UTF-8?q?=E4=BC=9A=E8=AF=9D=E5=A4=B1=E8=B4=A5=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 stack/broadcast.go | 2 +-
 stack/sink.go      | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/stack/broadcast.go b/stack/broadcast.go
index 6c35332..7ac0ae8 100644
--- a/stack/broadcast.go
+++ b/stack/broadcast.go
@@ -40,7 +40,7 @@ func (d *Device) StartBroadcast(streamId common.StreamID, deviceId, channelId st
 	sink := &dao.SinkModel{
 		SinkStreamID: sinkStreamId,
 		StreamID:     streamId,
-		Protocol:     SourceTypeGBTalk,
+		Protocol:     TransStreamGBTalk,
 		CreateTime:   time.Now().Unix(),
 		SetupType:    common.SetupTypePassive,
 	}
diff --git a/stack/sink.go b/stack/sink.go
index faf88f2..6d8eda5 100644
--- a/stack/sink.go
+++ b/stack/sink.go
@@ -29,6 +29,7 @@ func (s *Sink) Close(bye, ms bool) {
 
 	// 目前只有一对一对讲, 断开就删除整个websocket对讲流
 	if s.Protocol == TransStreamGBTalk {
+		_, _ = dao.Sink.DeleteSinkBySinkStreamID(s.SinkStreamID)
 		_, _ = dao.Stream.DeleteStream(s.StreamID)
 		// 删除流媒体source
 		_ = MSCloseSource(string(s.StreamID))