From 342488a7cfaab1b40db7b807427c0414babb3de2 Mon Sep 17 00:00:00 2001
From: udieudie <udieudie@126.com>
Date: Sun, 11 May 2025 00:20:35 +0800
Subject: [PATCH 01/16] =?UTF-8?q?david/feat:=E5=A2=9E=E5=8A=A0=E6=96=B0?=
 =?UTF-8?q?=E7=9A=84=E6=B5=B7=E9=87=8F=E8=AF=B7=E6=B1=82=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 main.go              |  2 +-
 templates/index.html | 12 ++++++++++++
 2 files changed, 13 insertions(+), 1 deletion(-)

diff --git a/main.go b/main.go
index ca10cef..0556318 100644
--- a/main.go
+++ b/main.go
@@ -20,7 +20,7 @@ import (
 func main() {
 	// 1. 定义并解析命令行参数
 	var env string
-	flag.StringVar(&env, "env", "prod", "运行环境（dev/prod）")
+	flag.StringVar(&env, "env", "dev", "运行环境（dev/prod）")
 	flag.Parse()
 	env = strings.ToLower(env) // 统一转为小写
 
diff --git a/templates/index.html b/templates/index.html
index 3675bac..6dd84a1 100644
--- a/templates/index.html
+++ b/templates/index.html
@@ -106,6 +106,12 @@
 
 <button onclick="sendClientErrorRequest()">测试客户端报错请求</button>
 
+<br/>
+<br/>
+<br/>
+
+<button onclick="sendManyRequest()">模拟大量送礼物的请求</button>
+
 
 <script>
     var ws = null;
@@ -1192,6 +1198,12 @@
 
         });
     }
+    
+    function sendManyRequest(){
+        for (let i = 0; i < 1000000; i++) {
+            sendLikeMsg()
+        }
+    }
 
     function sendGetRequest(url, params = {}, headers = {}) {
         return new Promise((resolve, reject) => {
-- 
Gitee


From 7afc42aaf89704eb9635966ebbef53a2249df50d Mon Sep 17 00:00:00 2001
From: udieudie <udieudie@126.com>
Date: Thu, 15 May 2025 00:23:29 +0800
Subject: [PATCH 02/16] =?UTF-8?q?david/feat:=E5=A2=9E=E5=8A=A0=E6=B5=8B?=
 =?UTF-8?q?=E8=AF=95=E6=89=B9=E9=87=8F=E8=AF=B7=E6=B1=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/controller/httpController.go | 119 ++++++++++++++++++++++++++++++-
 app/service/live_room_service.go | 111 ++++++++++++++++++++++++++++
 templates/index.html             |  64 +++++++++++++++--
 3 files changed, 286 insertions(+), 8 deletions(-)

diff --git a/app/controller/httpController.go b/app/controller/httpController.go
index 6e803f7..5322fdb 100644
--- a/app/controller/httpController.go
+++ b/app/controller/httpController.go
@@ -44,7 +44,8 @@ type RecordClientErrorRequest struct {
 }
 
 type HttpController struct {
-	mu sync.Mutex // 添加互斥锁字段
+	mu         sync.Mutex // 添加互斥锁字段
+	testSwitch int
 }
 
 func NewHttpController() *HttpController {
@@ -75,6 +76,15 @@ func (h *HttpController) RegisterRoutes(router *gin.Engine) {
 			fmt.Println("[DEBUG] /api/v1/getGiftRequest hit") // 测试路由是否触发
 			h.GetGiftRequest(c)
 		})
+		apiGroup.POST("/OpenSendManyRequest", func(c *gin.Context) {
+			fmt.Println("[DEBUG] /api/v1/OpenSendManyRequest hit") // 测试路由是否触发
+			h.OpenSendManyRequest(c)
+		})
+
+		apiGroup.POST("/CloseSendManyRequest", func(c *gin.Context) {
+			fmt.Println("[DEBUG] /api/v1/CloseSendManyRequest hit") // 测试路由是否触发
+			h.CloseSendManyRequest(c)
+		})
 
 		//apiGroup.GET("/getToken", h.GetToken)
 		apiGroup.POST("/auth/anchor/login", func(c *gin.Context) {
@@ -164,6 +174,113 @@ func (h *HttpController) AuthAnchorLogin(c *gin.Context) {
 	})
 }
 
+// 发送批量请求开启
+func (h *HttpController) OpenSendManyRequest(c *gin.Context) {
+	var req models.GiftRequestPayloadArr
+	if err := c.ShouldBindJSON(&req); err != nil {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "invalid request format"})
+		return
+	}
+
+	// 检查 x-roomid 的值
+	roomId := c.GetHeader("x-roomid")
+	if roomId == "" {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "no roomid"})
+		return
+	}
+
+	go h.SendManyRequest(roomId)
+
+	// 返回处理结果（根据业务需求调整返回结构）
+	c.JSON(http.StatusOK, gin.H{
+		"code":    0,
+		"message": "success",
+		"data":    gin.H{},
+	})
+}
+
+// 发送批量请求
+func (h *HttpController) SendManyRequest(liveRoomID string) {
+
+	if h.testSwitch == 1 {
+		return
+	}
+
+	h.testSwitch = 1
+
+	// 定义 User 结构体
+	type User struct {
+		Username    string
+		UserId      string
+		UserImgHead string
+	}
+
+	// 初始化 User 数组（包含 3 个元素）
+	users := [3]User{
+		{Username: "Alice", UserId: "1001", UserImgHead: "http://82.157.179.66:8001/static/03763e7c5fd77d3ba9d0ed2b35f5bfeb.jpeg"},
+		{Username: "Bob", UserId: "1002", UserImgHead: "http://82.157.179.66:8001/static/16e1041e5e02db1c77678084102a9b6b.jpeg"},
+		{Username: "Charlie", UserId: "1003", UserImgHead: "http://82.157.179.66:8001/static/8944face68cc71bc452ea8a4fd0abc5b.jpeg"},
+	}
+
+	for i := 0; i < len(users); i++ {
+		service.LiveRoomService{}.SendTestPingLunNoStoage(liveRoomID, users[i].UserId, users[i].Username, users[i].UserImgHead, i+1)
+	}
+
+	// 初始化礼物 ID 字符串数组（包含 5 个元素）
+	giftIds := [8]string{
+		"n1/Dg1905sj1FyoBlQBvmbaDZFBNaKuKZH6zxHkv8Lg5x2cRfrKUTb8gzMs=",
+		"28rYzVFNyXEXFC8HI+f/WG+I7a6lfl3OyZZjUS+CVuwCgYZrPrUdytGHu0c=",
+		"fJs8HKQ0xlPRixn8JAUiL2gFRiLD9S6IFCFdvZODSnhyo9YN8q7xUuVVyZI=",
+		"PJ0FFeaDzXUreuUBZH6Hs+b56Jh0tQjrq0bIrrlZmv13GSAL9Q1hf59fjGk=",
+		"IkkadLfz7O/a5UR45p/OOCCG6ewAWVbsuzR/Z+v1v76CBU+mTG/wPjqdpfg=",
+		"gx7pmjQfhBaDOG2XkWI2peZ66YFWkCWRjZXpTqb23O/epru+sxWyTV/3Ufs=",
+		"pGLo7HKNk1i4djkicmJXf6iWEyd+pfPBjbsHmd3WcX0Ierm2UdnRR7UINvI=",
+		"P7zDZzpeO215SpUptB+aURb1+zC14UC9MY1+MHszKoF0p5gzYk8CNEbey60=",
+	}
+
+	for {
+		if h.testSwitch == 0 {
+			break
+		}
+		for i := 0; i < len(users); i++ {
+			for j := 0; j < len(giftIds); j++ {
+				service.LiveRoomService{}.SendTestGiftNoStoage(liveRoomID, users[i].UserId, users[i].Username, users[i].UserImgHead,
+					giftIds[j], 1, i+1)
+
+				time.Sleep(10 * time.Millisecond)
+			}
+		}
+	}
+
+	return
+}
+
+// 发送批量请求关闭
+func (h *HttpController) CloseSendManyRequest(c *gin.Context) {
+	var req models.GiftRequestPayloadArr
+	if err := c.ShouldBindJSON(&req); err != nil {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "invalid request format"})
+		return
+	}
+
+	// 检查 x-roomid 的值
+	roomId := c.GetHeader("x-roomid")
+	if roomId == "" {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "no roomid"})
+		return
+	}
+
+	h.testSwitch = 0
+
+	// 返回处理结果（根据业务需求调整返回结构）
+	c.JSON(http.StatusOK, gin.H{
+		"code":    0,
+		"message": "success",
+		"data":    gin.H{},
+	})
+
+}
+
 // 示例：获取用户信息的HTTP处理
 func (h *HttpController) finishGame(c *gin.Context) {
 	var req FinishGameRequest
diff --git a/app/service/live_room_service.go b/app/service/live_room_service.go
index e26f5b1..e703cad 100644
--- a/app/service/live_room_service.go
+++ b/app/service/live_room_service.go
@@ -82,6 +82,54 @@ func (ls LiveRoomService) OneUserJoinTrack(liveRoomID string, userId string, tra
 	return nil
 }
 
+func (ls LiveRoomService) SendTestPingLunNoStoage(liveRoomID string, userId, userName, userHeadImg string, track int) error {
+	now := time.Now()
+	// 创建一个礼物事件
+	data := models.LiveEventData{
+		Event: "broad_join_track",
+		Data: struct {
+			MsgID         string `json:"msg_id"`         // 事件的ID
+			SecOpenID     string `json:"sec_openid"`     // 用户的加密openid
+			Type          string `json:"type"`           // 事件类型：comment, gift, like
+			Content       string `json:"content"`        // 评论内容（仅评论有效）
+			Camp          int    `json:"camp"`           // 评论内容（仅评论有效）
+			SecGiftID     string `json:"sec_gift_id"`    // 加密的礼物id（仅礼物有效）
+			GiftNum       int    `json:"gift_num"`       // 送出的礼物数量（仅礼物有效）
+			GiftValue     int    `json:"gift_value"`     // 礼物总价值，单位分（仅礼物有效）
+			Name          string `json:"name"`           // 用户昵称
+			Level         int    `json:"level"`          // 用户等级
+			AccGiftScore  int    `json:"acc_gift_score"` // 直播间当前用户累计礼物价值
+			LikeNum       string `json:"like_num"`       // 点赞数量（仅点赞有效）
+			AvatarURL     string `json:"avatar_url"`     // 用户头像
+			Nickname      string `json:"nickname"`       // 用户昵称
+			UserScore     int    `json:"user_score"`     // 用户积分
+			GiftLevel     int    `json:"gift_level"`     // 礼物等级
+			GiftUpgrading int    `json:"gift_upgrading"` // 礼物当前次升级
+			GameScore     int    `json:"game_score"`     // 游戏当局分数
+			Timestamp     int64  `json:"timestamp"`      // 事件时间戳
+		}{
+			MsgID:     uuid.New().String(),
+			SecOpenID: userId,
+			Type:      "broad_join_track",
+			Content:   strconv.Itoa(track),
+			Camp:      track,
+			SecGiftID: "n1/Dg1905sj1FyoBlQBvmbaDZFBNaKuKZH6zxHkv8Lg5x2cRfrKUTb8gzMs=",
+			GiftNum:   2,
+			GiftValue: 10,
+			Name:      "",
+			Nickname:  userName,
+			Level:     1,
+			AvatarURL: userHeadImg,
+			UserScore: 123,
+			Timestamp: now.UnixMilli(),
+		},
+	}
+
+	//i.eventManager.AddEventData(liveRoomID, data)
+	manager.Get().EventManager().AddEventData(liveRoomID, data)
+	return nil
+}
+
 func (ls LiveRoomService) OneUserSendGift(msgID string, liveRoomID string, userId string, giftId string, giftNum int) error {
 	// 1、获取直播间状态
 	liveRoomInfo, err := manager.Get().LiveRoomManager().GetLiveInfo(liveRoomID)
@@ -224,6 +272,69 @@ func (ls LiveRoomService) OneUserSendGift(msgID string, liveRoomID string, userI
 	fmt.Println(liveRoomID, "号直播间，收货礼物广播事件 已 add")
 	return nil
 }
+
+func (ls LiveRoomService) SendTestGiftNoStoage(liveRoomID string, userId, userName, userHeadImg string, giftId string, giftNum int, track int) error {
+
+	now := time.Now()
+
+	giftInfo, err := manager.Get().GiftManager().GetGiftByID(giftId)
+	if err != nil {
+		return fmt.Errorf("can not find gift by giftId , err : %v", err)
+	}
+
+	giftName := giftInfo.Name
+	giftValue := giftInfo.Value
+	giftScore := giftInfo.Score
+
+	// 创建一个礼物事件
+	data := models.LiveEventData{
+		Event: "broad_live_gift",
+		Data: struct {
+			MsgID         string `json:"msg_id"`         // 事件的ID
+			SecOpenID     string `json:"sec_openid"`     // 用户的加密openid
+			Type          string `json:"type"`           // 事件类型：comment, gift, like
+			Content       string `json:"content"`        // 评论内容（仅评论有效）
+			Camp          int    `json:"camp"`           // 所属阵营
+			SecGiftID     string `json:"sec_gift_id"`    // 加密的礼物id（仅礼物有效）
+			GiftNum       int    `json:"gift_num"`       // 送出的礼物数量（仅礼物有效）
+			GiftValue     int    `json:"gift_value"`     // 礼物总价值，单位分（仅礼物有效）
+			Name          string `json:"name"`           // 用户昵称
+			Level         int    `json:"level"`          // 用户等级
+			AccGiftScore  int    `json:"acc_gift_score"` // 直播间当前用户累计礼物价值
+			LikeNum       string `json:"like_num"`       // 点赞数量（仅点赞有效）
+			AvatarURL     string `json:"avatar_url"`     // 用户头像
+			Nickname      string `json:"nickname"`       // 用户昵称
+			UserScore     int    `json:"user_score"`     // 用户积分
+			GiftLevel     int    `json:"gift_level"`     // 礼物等级
+			GiftUpgrading int    `json:"gift_upgrading"` // 礼物当前次升级
+			GameScore     int    `json:"game_score"`     // 游戏当局分数
+			Timestamp     int64  `json:"timestamp"`      // 事件时间戳
+		}{
+			MsgID:         uuid.New().String(),
+			SecOpenID:     userId,
+			Type:          "live_gift",
+			Camp:          track,
+			SecGiftID:     giftId,
+			GiftNum:       giftNum,
+			GiftValue:     giftValue,
+			Name:          giftName,
+			Nickname:      userName,
+			Level:         1,
+			AccGiftScore:  giftScore,
+			AvatarURL:     userHeadImg,
+			UserScore:     giftScore,
+			GiftLevel:     1,
+			GiftUpgrading: 0,
+			GameScore:     giftScore,
+			Timestamp:     now.UnixMilli(),
+		},
+	}
+
+	//i.eventManager.AddEventData(liveRoomID, data)
+	manager.Get().EventManager().AddEventData(liveRoomID, data)
+	fmt.Println(liveRoomID, "号直播间，收货礼物广播事件 已 add")
+	return nil
+}
 func (ls LiveRoomService) FinishGame(msgID string, liveRoomId string, finishTrackInfos []models.FinishTrackInfo, timestamp int) ([]models.LiveRoomResult, error) {
 	// 获取直播间信息
 	liveRoomInfo, err := manager.Get().LiveRoomManager().GetLiveInfo(liveRoomId)
diff --git a/templates/index.html b/templates/index.html
index 6dd84a1..9b2ae39 100644
--- a/templates/index.html
+++ b/templates/index.html
@@ -93,12 +93,13 @@
 <br/>
 <br/>
 
-<button onclick="sendGetRanksRequest()">获取排行榜数据</button>
+<button onclick="openSendManyRequest()">开启批量请求</button>
+
 <br/>
 <br/>
 <br/>
 
-<button onclick="sendGetWorldRecordsRequest()">获取世界纪录数据</button>
+<button onclick="closeSendManyRequest()">关闭批量请求</button>
 
 <br/>
 <br/>
@@ -106,11 +107,7 @@
 
 <button onclick="sendClientErrorRequest()">测试客户端报错请求</button>
 
-<br/>
-<br/>
-<br/>
 
-<button onclick="sendManyRequest()">模拟大量送礼物的请求</button>
 
 
 <script>
@@ -1173,6 +1170,50 @@
         });
     }
 
+    function openSendManyRequest(){
+        const url = `http://${ip}/api/v1/OpenSendManyRequest`;
+
+        liveRoomID = document.getElementById('liveRoomId').value;
+        if(liveRoomID == ''){
+            alert("请填写直播间号")
+            return
+        }
+
+        const data =  {
+            "live_room_id": liveRoomID,
+        }
+        const headers = {
+            'Content-Type': 'application/json',
+            'x-roomid': liveRoomID,
+        };
+
+        sendPostRequest(url, data, headers).then(res=>{
+
+        });
+    }
+
+    function closeSendManyRequest(){
+        const url = `http://${ip}/api/v1/CloseSendManyRequest`;
+
+        liveRoomID = document.getElementById('liveRoomId').value;
+        if(liveRoomID == ''){
+            alert("请填写直播间号")
+            return
+        }
+
+        const data =  {
+            "live_room_id": liveRoomID,
+        }
+        const headers = {
+            'Content-Type': 'application/json',
+            'x-roomid': liveRoomID,
+        };
+
+        sendPostRequest(url, data, headers).then(res=>{
+
+        });
+    }
+
     function sendClientErrorRequest(){
         const url = `http://${ip}/api/v1/recordClientError`;
 
@@ -1200,7 +1241,16 @@
     }
     
     function sendManyRequest(){
-        for (let i = 0; i < 1000000; i++) {
+        let giftNum = document.getElementById('giftNum').value;
+        if(giftNum !='' && parseInt(giftNum)<=0){
+            alert("礼物数量请填入数字")
+            return
+        }
+        if(giftNum===''){
+            giftNum = 1
+            document.getElementById('giftNum').value = giftNum
+        }
+        for (let i = 0; i < giftNum; i++) {
             sendLikeMsg()
         }
     }
-- 
Gitee


From 0f9e6eecac86f4a31ef7afd1589975596a695111 Mon Sep 17 00:00:00 2001
From: udieudie <udieudie@126.com>
Date: Thu, 15 May 2025 00:27:52 +0800
Subject: [PATCH 03/16] =?UTF-8?q?david/feat:=E8=B0=83=E6=95=B4=E7=BB=93?=
 =?UTF-8?q?=E6=9D=9F=E6=89=B9=E9=87=8F=E8=AF=B7=E6=B1=82=E6=8C=89=E9=92=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 templates/index.html | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/templates/index.html b/templates/index.html
index 9b2ae39..650bcd8 100644
--- a/templates/index.html
+++ b/templates/index.html
@@ -61,6 +61,8 @@
 
 <button onclick="endGame()">5为直播间结束游戏</button>
 
+<button onclick="closeSendManyRequest()">关闭批量请求</button>
+
 <br/>
 <br/>
 
-- 
Gitee


From f041bc16c0564039f62eb745105e24d1e7454aee Mon Sep 17 00:00:00 2001
From: udieudie <udieudie@126.com>
Date: Thu, 15 May 2025 01:20:19 +0800
Subject: [PATCH 04/16] =?UTF-8?q?david/feat:=E5=A2=9E=E5=8A=A0=E4=BB=85?=
 =?UTF-8?q?=E7=82=B9=E8=B5=9E=E5=8A=9F=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/controller/httpController.go | 95 +++++++++++++++++++++++++++++++-
 app/service/live_room_service.go |  4 +-
 templates/index.html             | 28 ++++++++++
 3 files changed, 123 insertions(+), 4 deletions(-)

diff --git a/app/controller/httpController.go b/app/controller/httpController.go
index 5322fdb..d816e56 100644
--- a/app/controller/httpController.go
+++ b/app/controller/httpController.go
@@ -76,6 +76,11 @@ func (h *HttpController) RegisterRoutes(router *gin.Engine) {
 			fmt.Println("[DEBUG] /api/v1/getGiftRequest hit") // 测试路由是否触发
 			h.GetGiftRequest(c)
 		})
+		apiGroup.POST("/OpenSendManyZanRequest", func(c *gin.Context) {
+			fmt.Println("[DEBUG] /api/v1/OpenSendManyZanRequest hit") // 测试路由是否触发
+			h.OpenSendManyZanRequest(c)
+		})
+
 		apiGroup.POST("/OpenSendManyRequest", func(c *gin.Context) {
 			fmt.Println("[DEBUG] /api/v1/OpenSendManyRequest hit") // 测试路由是否触发
 			h.OpenSendManyRequest(c)
@@ -174,6 +179,83 @@ func (h *HttpController) AuthAnchorLogin(c *gin.Context) {
 	})
 }
 
+// 发送批量请求开启
+func (h *HttpController) OpenSendManyZanRequest(c *gin.Context) {
+	var req models.GiftRequestPayloadArr
+	if err := c.ShouldBindJSON(&req); err != nil {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "invalid request format"})
+		return
+	}
+
+	// 检查 x-roomid 的值
+	roomId := c.GetHeader("x-roomid")
+	if roomId == "" {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "no roomid"})
+		return
+	}
+
+	go h.SendManyZanRequest(roomId)
+
+	// 返回处理结果（根据业务需求调整返回结构）
+	c.JSON(http.StatusOK, gin.H{
+		"code":    0,
+		"message": "success",
+		"data":    gin.H{},
+	})
+}
+
+// 发送批量请求
+func (h *HttpController) SendManyZanRequest(liveRoomID string) {
+
+	if h.testSwitch == 1 {
+		return
+	}
+
+	h.testSwitch = 1
+
+	// 定义 User 结构体
+	type User struct {
+		Username    string
+		UserId      string
+		UserImgHead string
+	}
+
+	// 初始化 User 数组（包含 3 个元素）
+	users := [3]User{
+		{Username: "Alice", UserId: "1001", UserImgHead: "http://82.157.179.66:8001/static/03763e7c5fd77d3ba9d0ed2b35f5bfeb.jpeg"},
+		{Username: "Bob", UserId: "1002", UserImgHead: "http://82.157.179.66:8001/static/16e1041e5e02db1c77678084102a9b6b.jpeg"},
+		{Username: "Charlie", UserId: "1003", UserImgHead: "http://82.157.179.66:8001/static/8944face68cc71bc452ea8a4fd0abc5b.jpeg"},
+	}
+
+	for i := 0; i < len(users); i++ {
+		service.LiveRoomService{}.SendTestPingLunNoStoage(liveRoomID, users[i].UserId, users[i].Username, users[i].UserImgHead, i+1)
+	}
+
+	// 初始化礼物 ID 字符串数组（包含 5 个元素）
+	giftIds := [1]string{
+		"1",
+	}
+
+	accScore := 0
+	for {
+		if h.testSwitch == 0 {
+			break
+		}
+
+		for i := 0; i < len(users); i++ {
+			for j := 0; j < len(giftIds); j++ {
+				accScore++
+				service.LiveRoomService{}.SendTestGiftNoStoage(liveRoomID, users[i].UserId, users[i].Username, users[i].UserImgHead,
+					giftIds[j], 1, i+1, accScore)
+
+				time.Sleep(10 * time.Millisecond)
+			}
+		}
+	}
+
+	return
+}
+
 // 发送批量请求开启
 func (h *HttpController) OpenSendManyRequest(c *gin.Context) {
 	var req models.GiftRequestPayloadArr
@@ -227,7 +309,8 @@ func (h *HttpController) SendManyRequest(liveRoomID string) {
 	}
 
 	// 初始化礼物 ID 字符串数组（包含 5 个元素）
-	giftIds := [8]string{
+	giftIds := [9]string{
+		"1",
 		"n1/Dg1905sj1FyoBlQBvmbaDZFBNaKuKZH6zxHkv8Lg5x2cRfrKUTb8gzMs=",
 		"28rYzVFNyXEXFC8HI+f/WG+I7a6lfl3OyZZjUS+CVuwCgYZrPrUdytGHu0c=",
 		"fJs8HKQ0xlPRixn8JAUiL2gFRiLD9S6IFCFdvZODSnhyo9YN8q7xUuVVyZI=",
@@ -238,14 +321,22 @@ func (h *HttpController) SendManyRequest(liveRoomID string) {
 		"P7zDZzpeO215SpUptB+aURb1+zC14UC9MY1+MHszKoF0p5gzYk8CNEbey60=",
 	}
 
+	accScore := 0
 	for {
 		if h.testSwitch == 0 {
 			break
 		}
 		for i := 0; i < len(users); i++ {
 			for j := 0; j < len(giftIds); j++ {
+
+				giftInfo, err := manager.Get().GiftManager().GetGiftByID(giftIds[j])
+				if err != nil {
+				}
+
+				giftScore := giftInfo.Score
+				accScore = accScore + giftScore
 				service.LiveRoomService{}.SendTestGiftNoStoage(liveRoomID, users[i].UserId, users[i].Username, users[i].UserImgHead,
-					giftIds[j], 1, i+1)
+					giftIds[j], 1, i+1, accScore)
 
 				time.Sleep(10 * time.Millisecond)
 			}
diff --git a/app/service/live_room_service.go b/app/service/live_room_service.go
index e703cad..63ee68a 100644
--- a/app/service/live_room_service.go
+++ b/app/service/live_room_service.go
@@ -273,7 +273,7 @@ func (ls LiveRoomService) OneUserSendGift(msgID string, liveRoomID string, userI
 	return nil
 }
 
-func (ls LiveRoomService) SendTestGiftNoStoage(liveRoomID string, userId, userName, userHeadImg string, giftId string, giftNum int, track int) error {
+func (ls LiveRoomService) SendTestGiftNoStoage(liveRoomID string, userId, userName, userHeadImg string, giftId string, giftNum int, track, accGiftScore int) error {
 
 	now := time.Now()
 
@@ -320,7 +320,7 @@ func (ls LiveRoomService) SendTestGiftNoStoage(liveRoomID string, userId, userNa
 			Name:          giftName,
 			Nickname:      userName,
 			Level:         1,
-			AccGiftScore:  giftScore,
+			AccGiftScore:  accGiftScore,
 			AvatarURL:     userHeadImg,
 			UserScore:     giftScore,
 			GiftLevel:     1,
diff --git a/templates/index.html b/templates/index.html
index 650bcd8..ef5c7de 100644
--- a/templates/index.html
+++ b/templates/index.html
@@ -101,6 +101,12 @@
 <br/>
 <br/>
 
+<button onclick="openSendManyZanRequest()">开启批量请求（仅有赞）</button>
+
+<br/>
+<br/>
+<br/>
+
 <button onclick="closeSendManyRequest()">关闭批量请求</button>
 
 <br/>
@@ -1194,6 +1200,28 @@
         });
     }
 
+    function openSendManyZanRequest(){
+        const url = `http://${ip}/api/v1/OpenSendManyZanRequest`;
+
+        liveRoomID = document.getElementById('liveRoomId').value;
+        if(liveRoomID == ''){
+            alert("请填写直播间号")
+            return
+        }
+
+        const data =  {
+            "live_room_id": liveRoomID,
+        }
+        const headers = {
+            'Content-Type': 'application/json',
+            'x-roomid': liveRoomID,
+        };
+
+        sendPostRequest(url, data, headers).then(res=>{
+
+        });
+    }
+
     function closeSendManyRequest(){
         const url = `http://${ip}/api/v1/CloseSendManyRequest`;
 
-- 
Gitee


From 8195c0da4d96fbb964822232be27f888b2720a08 Mon Sep 17 00:00:00 2001
From: udieudie <udieudie@126.com>
Date: Thu, 15 May 2025 01:23:31 +0800
Subject: [PATCH 05/16] =?UTF-8?q?david/feat:=E8=AE=A9=E6=B5=8B=E8=AF=95?=
 =?UTF-8?q?=E6=89=B9=E9=87=8F=E6=95=B0=E6=8D=AE=E7=9A=84=E7=A7=AF=E5=88=86?=
 =?UTF-8?q?=E6=B1=A0=E6=95=B0=E6=8D=AE=E5=8F=98=E6=88=90=E5=8A=A8=E6=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/service/live_room_service.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/app/service/live_room_service.go b/app/service/live_room_service.go
index 63ee68a..17b1cde 100644
--- a/app/service/live_room_service.go
+++ b/app/service/live_room_service.go
@@ -325,7 +325,7 @@ func (ls LiveRoomService) SendTestGiftNoStoage(liveRoomID string, userId, userNa
 			UserScore:     giftScore,
 			GiftLevel:     1,
 			GiftUpgrading: 0,
-			GameScore:     giftScore,
+			GameScore:     accGiftScore,
 			Timestamp:     now.UnixMilli(),
 		},
 	}
-- 
Gitee


From 13f9b313434e1a96458cc18c3af9087e75deeec4 Mon Sep 17 00:00:00 2001
From: udieudie <udieudie@126.com>
Date: Thu, 15 May 2025 23:14:48 +0800
Subject: [PATCH 06/16] =?UTF-8?q?david/feat:x=E4=BF=AE=E5=A4=8D=E7=BB=93?=
 =?UTF-8?q?=E7=AE=97=E7=9A=84bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/service/live_room_service.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/app/service/live_room_service.go b/app/service/live_room_service.go
index 17b1cde..1fc2890 100644
--- a/app/service/live_room_service.go
+++ b/app/service/live_room_service.go
@@ -442,8 +442,8 @@ func (ls LiveRoomService) FinishGame(msgID string, liveRoomId string, finishTrac
 		// 将礼物记录记录到每个UserId的礼物积分总数
 		if scoreRecord, exists := liveRoomUserScoreRecord[giftRecord.UserId]; exists {
 			liveRoomUserScoreRecord[giftRecord.UserId] = userScoreRecord{
-				Value:     scoreRecord.Value + giftRecord.Value,
-				Score:     scoreRecord.Score + giftRecord.Score,
+				Value:     scoreRecord.Value + giftRecord.TotalValue,
+				Score:     scoreRecord.Score + giftRecord.TotalScore,
 				Track:     giftRecord.Track,
 				UserName:  giftRecord.UserName,
 				HeadImg:   giftRecord.UserHeadImg,
-- 
Gitee


From 1ffe5226a7dc53d51aaf5a048dc1417e31e3f9c7 Mon Sep 17 00:00:00 2001
From: udieudie <udieudie@126.com>
Date: Mon, 19 May 2025 02:05:43 +0800
Subject: [PATCH 07/16] =?UTF-8?q?david/feat:=E4=BF=AE=E5=A4=8D=E5=AE=8C?=
 =?UTF-8?q?=E8=B5=9B=E7=BB=93=E7=AE=97=E5=8F=8A=E7=A7=AF=E5=88=86=E5=88=86?=
 =?UTF-8?q?=E9=85=8D=E7=9A=84=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/service/live_room_service.go | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/app/service/live_room_service.go b/app/service/live_room_service.go
index 1fc2890..1bfc154 100644
--- a/app/service/live_room_service.go
+++ b/app/service/live_room_service.go
@@ -433,11 +433,11 @@ func (ls LiveRoomService) FinishGame(msgID string, liveRoomId string, finishTrac
 	}
 	trackBiggestMap := make(map[int]trackBiggestRecord)
 	for _, giftRecord := range giftRecordList {
-		liveRoomTotalScore += giftRecord.Score
+		liveRoomTotalScore += giftRecord.TotalScore
 		if championTrack == giftRecord.Track {
-			liveRoomChampionTrackTotalScore += giftRecord.Score
+			liveRoomChampionTrackTotalScore += giftRecord.TotalScore
 		} else if utils.Exists(finishTrackArr, giftRecord.Track) {
-			liveRoomOtherFinishTrackTotalScore += giftRecord.Score
+			liveRoomOtherFinishTrackTotalScore += giftRecord.TotalScore
 		}
 		// 将礼物记录记录到每个UserId的礼物积分总数
 		if scoreRecord, exists := liveRoomUserScoreRecord[giftRecord.UserId]; exists {
@@ -454,8 +454,8 @@ func (ls LiveRoomService) FinishGame(msgID string, liveRoomId string, finishTrac
 		} else {
 			// 如果 userId 不存在，直接初始化 Score
 			liveRoomUserScoreRecord[giftRecord.UserId] = userScoreRecord{
-				Value:     giftRecord.Value,
-				Score:     giftRecord.Score,
+				Value:     giftRecord.TotalValue,
+				Score:     giftRecord.TotalScore,
 				Track:     giftRecord.Track,
 				UserName:  giftRecord.UserName,
 				HeadImg:   giftRecord.UserHeadImg,
-- 
Gitee


From db9912316c8695679abfd0e7956f7c19eddd5e96 Mon Sep 17 00:00:00 2001
From: udieudie <udieudie@126.com>
Date: Tue, 20 May 2025 02:13:31 +0800
Subject: [PATCH 08/16] =?UTF-8?q?david/feat:=E5=A2=9E=E5=8A=A0=E8=87=AA?=
 =?UTF-8?q?=E6=9F=A5=E5=B7=A5=E5=85=B7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/controller/dyPushController.go       | 61 ++++++++++++++++++++++++
 app/manager/douyin/dy_service_manager.go | 17 +++++++
 app/manager/gift_manager.go              |  2 +
 app/models/models.go                     | 16 +++++++
 templates/index.html                     | 14 ++++++
 5 files changed, 110 insertions(+)

diff --git a/app/controller/dyPushController.go b/app/controller/dyPushController.go
index 91fc4b5..b2303af 100644
--- a/app/controller/dyPushController.go
+++ b/app/controller/dyPushController.go
@@ -43,6 +43,11 @@ func (h *dyPushController) RegisterRoutes(router *gin.Engine) {
 				h.dyPushZan(c)
 			})
 
+			authGroup.POST("/dyPushFans", func(c *gin.Context) {
+				fmt.Println("[DEBUG] /dyPushFans") // 测试路由是否触发
+				h.dyPushFans(c)
+			})
+
 			authGroup.HEAD("/dyPushPingLun", func(c *gin.Context) {
 				fmt.Println("[DEBUG] get /dyPushPingLun") // 测试路由是否触发
 				c.JSON(http.StatusOK, gin.H{
@@ -325,6 +330,62 @@ func (h *dyPushController) dyPushZan(c *gin.Context) {
 	})
 }
 
+// 示例：获取用户信息的HTTP处理
+func (h *dyPushController) dyPushFans(c *gin.Context) {
+	var req []models.FansOneRequest
+	if err := c.ShouldBindJSON(&req); err != nil {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "invalid request format"})
+		return
+	}
+
+	// 检查 x-roomid 的值
+	roomId := c.GetHeader("x-roomid")
+	if roomId == "" {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "no roomid"})
+		return
+	}
+
+	// 检查 X-Msg-Type 的值
+	msgType := c.GetHeader("X-Msg-Type")
+	if msgType == "" {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "no Msg type"})
+		return
+	}
+
+	// 检查 X-Nonce-Str 的值
+	nonceStr := c.GetHeader("X-Nonce-Str")
+	if nonceStr == "" {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "no nonce str"})
+		return
+	}
+
+	for _, item := range req {
+		giftId := "2"
+		if item.FansClubReasonType == 2 {
+			// 代表加入粉丝团
+			giftId = "2"
+		} else if item.FansClubReasonType == 1 {
+			// 代表粉丝团升级
+			giftId = "3"
+		}
+
+		// 代表加入粉丝团
+
+		err := service.LiveRoomService{}.OneUserSendGift(item.MsgID, roomId, item.SecOpenID,
+			giftId, 1)
+		if err != nil {
+		}
+
+	}
+
+	// 返回处理结果（根据业务需求调整返回结构）
+	c.JSON(http.StatusOK, gin.H{
+		"code":    0,
+		"message": "success",
+		"data":    gin.H{},
+	})
+}
+
 // 示例：获取用户信息的HTTP处理
 func (h *dyPushController) dyPushFensi(c *gin.Context) {
 	//var req FinishGameRequest
diff --git a/app/manager/douyin/dy_service_manager.go b/app/manager/douyin/dy_service_manager.go
index 7726b65..5812317 100644
--- a/app/manager/douyin/dy_service_manager.go
+++ b/app/manager/douyin/dy_service_manager.go
@@ -130,10 +130,12 @@ func StartDouYinLiveRoomAllTask(accessToken string, liveRoomId string) (err erro
 	//1. 评论：live_comment
 	//2. 礼物：live_gift
 	//3. 点赞：live_like"
+	//4. 粉丝团：live_fansclub"
 
 	const liveCommentType = "live_comment"
 	const LiveGiftType = "live_gift"
 	const LiveLikeType = "live_like"
+	const LiveFansType = "live_fansclub"
 
 	err = StartDouYinLiveRoomSingleTask(accessToken, liveRoomId, liveCommentType)
 	if err != nil {
@@ -156,6 +158,13 @@ func StartDouYinLiveRoomAllTask(accessToken string, liveRoomId string) (err erro
 	}
 	fmt.Println("直播间", liveRoomId, " 已经开通点赞推送")
 
+	err = StartDouYinLiveRoomSingleTask(accessToken, liveRoomId, LiveFansType)
+	if err != nil {
+		fmt.Println("直播间", liveRoomId, " 开启粉丝团推送出错 : ", err)
+
+	}
+	fmt.Println("直播间", liveRoomId, " 已经开通粉丝团推送")
+
 	return nil
 }
 
@@ -210,10 +219,12 @@ func StopDouYinLiveRoomAllTask(accessToken string, liveRoomId string) (err error
 	//1. 评论：live_comment
 	//2. 礼物：live_gift
 	//3. 点赞：live_like"
+	//4. 粉丝团：live_fansclub"
 
 	const liveCommentType = "live_comment"
 	const LiveGiftType = "live_gift"
 	const LiveLikeType = "live_like"
+	const LiveFansType = "live_fansclub"
 
 	err = StopDouYinLiveRoomSingleTask(accessToken, liveRoomId, liveCommentType)
 	if err != nil {
@@ -234,6 +245,12 @@ func StopDouYinLiveRoomAllTask(accessToken string, liveRoomId string) (err error
 	}
 	fmt.Println("直播间", liveRoomId, " 已经关闭点赞推送")
 
+	err = StopDouYinLiveRoomSingleTask(accessToken, liveRoomId, LiveFansType)
+	if err != nil {
+		fmt.Println("直播间", liveRoomId, " 关闭粉丝团推送出错 : ", err)
+	}
+	fmt.Println("直播间", liveRoomId, " 已经关闭粉丝团推送")
+
 	return nil
 }
 
diff --git a/app/manager/gift_manager.go b/app/manager/gift_manager.go
index f5f3a57..a22109e 100644
--- a/app/manager/gift_manager.go
+++ b/app/manager/gift_manager.go
@@ -19,6 +19,8 @@ type GiftManager struct {
 // 定义全局的gift列表
 var giftList = []Gift{
 	{ID: "1", Name: "点赞", Value: 0, Score: 1, UpgradeLimit: 999999},
+	{ID: "2", Name: "加入粉丝团", Value: 10, Score: 75, UpgradeLimit: 999999},
+	{ID: "3", Name: "粉丝团升级", Value: 100, Score: 750, UpgradeLimit: 999999},
 	{ID: "n1/Dg1905sj1FyoBlQBvmbaDZFBNaKuKZH6zxHkv8Lg5x2cRfrKUTb8gzMs=", Name: "仙女棒", Value: 10, Score: 75, UpgradeLimit: 66},
 	{ID: "eplFUy7i0B0fiv0Iym1MpOZa5XmUE8g/WUAyJ6Tc+UJJDpcs7pzclNOz/WM=", Name: "黄色仙女棒", Value: 10, Score: 75, UpgradeLimit: 66},
 	{ID: "4I66OIE1HKWfM7PNvAHtAgYUSNlggSEgcpo3ai8GYQXAWqjrDuH8NtjsWEQ=", Name: "蓝色仙女棒", Value: 10, Score: 75, UpgradeLimit: 66},
diff --git a/app/models/models.go b/app/models/models.go
index 476b05c..07360cf 100644
--- a/app/models/models.go
+++ b/app/models/models.go
@@ -160,6 +160,22 @@ type LikeOneRequest struct {
 	Timestamp int64  `json:"timestamp"`
 }
 
+// 抖音推送数据的点赞元数据
+type FansOneRequest struct {
+	MsgID              string `json:"msg_id"`
+	SecOpenID          string `json:"sec_openid"`
+	AvatarURL          string `json:"avatar_url"`
+	Nickname           string `json:"nickname"`
+	Timestamp          int64  `json:"timestamp"`
+	FansClubLevel      int    `json:"fansclub_level"`       // 用户粉丝团等级，加团消息下默认传1
+	FansClubReasonType int    `json:"fansclub_reason_type"` // 粉丝团消息类型：1-升级，2-加团
+}
+
+// 抖音推送数据的点赞元数据
+type FansRequest struct {
+	Arr []FansOneRequest `json:"arr"`
+}
+
 type LikeRequest struct {
 	Arr []LikeOneRequest `json:"arr"`
 }
diff --git a/templates/index.html b/templates/index.html
index ef5c7de..867f86f 100644
--- a/templates/index.html
+++ b/templates/index.html
@@ -55,6 +55,8 @@
 <button onclick="sendOneGiftMsg(5)">送礼物-电池</button>
 <button onclick="sendOneGiftMsg(6)">送礼物-炸弹</button>
 <button onclick="sendOneGiftMsg(7)">送礼物-空投</button>
+<button onclick="sendOneGiftMsg(11)">粉丝团-加入</button>
+<button onclick="sendOneGiftMsg(12)">粉丝团-升级</button>
 
 <br/>
 <br/>
@@ -179,6 +181,18 @@
             name: "点赞",
             value: 0,
         },
+        {
+            id: 11,
+            giftId : "2",
+            name: "加入粉丝团",
+            value: 0,
+        },
+        {
+            id: 12,
+            giftId : "3",
+            name: "粉丝团升级",
+            value: 0,
+        },
         {
             id: 2,
             giftId : "n1/Dg1905sj1FyoBlQBvmbaDZFBNaKuKZH6zxHkv8Lg5x2cRfrKUTb8gzMs=",
-- 
Gitee


From a3919258ada0def564f6f4f0ca46191084ea3ce0 Mon Sep 17 00:00:00 2001
From: udieudie <udieudie@126.com>
Date: Tue, 20 May 2025 02:32:18 +0800
Subject: [PATCH 09/16] =?UTF-8?q?david/feat:=E5=A2=9E=E5=8A=A0fans?=
 =?UTF-8?q?=E5=9B=9E=E8=B0=83=E7=9A=84head=E5=9B=9E=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/controller/dyPushController.go | 26 +++++++-------------------
 1 file changed, 7 insertions(+), 19 deletions(-)

diff --git a/app/controller/dyPushController.go b/app/controller/dyPushController.go
index b2303af..d57afc0 100644
--- a/app/controller/dyPushController.go
+++ b/app/controller/dyPushController.go
@@ -75,9 +75,13 @@ func (h *dyPushController) RegisterRoutes(router *gin.Engine) {
 				})
 			})
 
-			authGroup.POST("/dyPushFensi", func(c *gin.Context) {
-				fmt.Println("[DEBUG] /dyPushFensi") // 测试路由是否触发
-				h.dyPushFensi(c)
+			authGroup.HEAD("/dyPushFans", func(c *gin.Context) {
+				fmt.Println("[DEBUG] get /dyPushFans") // 测试路由是否触发
+				c.JSON(http.StatusOK, gin.H{
+					"code":    0,
+					"message": "success",
+					"data":    gin.H{},
+				})
 			})
 
 			authGroup.POST("/dyGetZhenYing", func(c *gin.Context) {
@@ -386,22 +390,6 @@ func (h *dyPushController) dyPushFans(c *gin.Context) {
 	})
 }
 
-// 示例：获取用户信息的HTTP处理
-func (h *dyPushController) dyPushFensi(c *gin.Context) {
-	//var req FinishGameRequest
-	//if err := c.ShouldBindJSON(&req); err != nil {
-	//	c.JSON(http.StatusBadRequest, gin.H{"error": "invalid request format"})
-	//	return
-	//}
-
-	// 返回处理结果（根据业务需求调整返回结构）
-	c.JSON(http.StatusOK, gin.H{
-		"code":    0,
-		"message": "success",
-		"data":    gin.H{},
-	})
-}
-
 // 示例：获取用户信息的HTTP处理
 func (h *dyPushController) dyGetZhenYing(c *gin.Context) {
 	//var req FinishGameRequest
-- 
Gitee


From 4dd6a02726d8fe2f0487f30ff8dd0ed20509d279 Mon Sep 17 00:00:00 2001
From: udieudie <udieudie@126.com>
Date: Wed, 21 May 2025 22:54:58 +0800
Subject: [PATCH 10/16] =?UTF-8?q?david/feat:=E7=9B=B4=E6=92=AD=E9=97=B4?=
 =?UTF-8?q?=E8=A2=AB=E8=BF=9E=E6=8E=A5=E7=9A=84=E6=97=B6=E5=80=99=EF=BC=8C?=
 =?UTF-8?q?=E5=A6=82=E6=9E=9C=E4=B9=8B=E5=89=8D=E7=8A=B6=E6=80=81=E6=98=AF?=
 =?UTF-8?q?=E5=BC=80=E5=A7=8B=E7=9A=84=EF=BC=8C=E5=88=99=E5=90=AF=E5=8A=A8?=
 =?UTF-8?q?=E6=89=80=E6=9C=89=E6=8E=A8=E9=80=81=E4=BB=BB=E5=8A=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/controller/indexController.go | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/app/controller/indexController.go b/app/controller/indexController.go
index 771b948..e3310d6 100644
--- a/app/controller/indexController.go
+++ b/app/controller/indexController.go
@@ -124,6 +124,16 @@ func (i *IndexController) Regist(ctx *gin.Context) {
 
 	manager.Get().ConnectionManager().Register(conn, liveRoomUserInfo.RoomId, liveRoomUserInfo.AnchorOpenId)
 
+	// TODO
+	liveRoomInfo, err := manager.Get().LiveRoomManager().GetLiveInfo(liveRoomUserInfo.RoomId)
+	if err == nil {
+		if liveRoomInfo.State == "start" {
+			service.DouYinService{}.StartDouYinLiveRoomAllTask(liveRoomUserInfo.RoomId)
+		}
+	} else {
+		fmt.Println("get live room err : ", err)
+	}
+
 	headImgArr := []string{
 		"http://82.157.179.66:8001/static/03763e7c5fd77d3ba9d0ed2b35f5bfeb.jpeg",
 		"http://82.157.179.66:8001/static/16e1041e5e02db1c77678084102a9b6b.jpeg",
-- 
Gitee


From 35815aff0de2e4ccd02ba0b17a35d7074ea63957 Mon Sep 17 00:00:00 2001
From: udieudie <udieudie@126.com>
Date: Fri, 23 May 2025 18:30:25 +0800
Subject: [PATCH 11/16] =?UTF-8?q?david/feat:=E5=A2=9E=E5=8A=A0=E7=94=A8?=
 =?UTF-8?q?=E6=88=B7=E9=80=9A=E8=BF=87=E5=B0=8F=E6=91=87=E6=9D=86=E9=80=89?=
 =?UTF-8?q?=E6=8B=A9=E9=98=B5=E8=90=A5=E7=9B=B8=E5=85=B3=E7=9A=84=E6=8E=A5?=
 =?UTF-8?q?=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/controller/dyPushController.go       | 125 ++++++++++++++++++++---
 app/controller/httpController.go         |   5 +
 app/controller/indexController.go        |   8 ++
 app/manager/douyin/dy_service_manager.go |  96 +++++++++++++++++
 app/manager/live_room_mamanger.go        |  12 ++-
 app/manager/live_room_mysql_storage.go   |  42 +++++---
 app/models/models.go                     |  27 ++++-
 app/service/douyin_service.go            |  59 +++++++++++
 app/service/live_room_service.go         |  14 ++-
 9 files changed, 355 insertions(+), 33 deletions(-)

diff --git a/app/controller/dyPushController.go b/app/controller/dyPushController.go
index d57afc0..961b9b9 100644
--- a/app/controller/dyPushController.go
+++ b/app/controller/dyPushController.go
@@ -94,6 +94,24 @@ func (h *dyPushController) RegisterRoutes(router *gin.Engine) {
 				h.dyPushZhenYing(c)
 			})
 
+			authGroup.HEAD("/dyGetZhenYing", func(c *gin.Context) {
+				fmt.Println("[DEBUG] get /dyGetZhenYing") // 测试路由是否触发
+				c.JSON(http.StatusOK, gin.H{
+					"code":    0,
+					"message": "success",
+					"data":    gin.H{},
+				})
+			})
+
+			authGroup.HEAD("/dyPushZhenYing", func(c *gin.Context) {
+				fmt.Println("[DEBUG] get /dyPushZhenYing") // 测试路由是否触发
+				c.JSON(http.StatusOK, gin.H{
+					"code":    0,
+					"message": "success",
+					"data":    gin.H{},
+				})
+			})
+
 		}
 
 	}
@@ -392,27 +410,108 @@ func (h *dyPushController) dyPushFans(c *gin.Context) {
 
 // 示例：获取用户信息的HTTP处理
 func (h *dyPushController) dyGetZhenYing(c *gin.Context) {
-	//var req FinishGameRequest
-	//if err := c.ShouldBindJSON(&req); err != nil {
-	//	c.JSON(http.StatusBadRequest, gin.H{"error": "invalid request format"})
-	//	return
-	//}
+	var req models.DouYinGetUserGroupRequest
+	if err := c.ShouldBindJSON(&req); err != nil {
+		c.JSON(http.StatusBadRequest, gin.H{"dyGetZhenYing error": "invalid request format"})
+		return
+	}
+
+	// 检查 x-roomid 的值
+	xRoomId := c.GetHeader("x-roomid")
+	if xRoomId == "" {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "no roomid"})
+		return
+	}
+
+	if xRoomId != req.RoomId {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "params check error"})
+		return
+	}
+
+	GameTimes := 1
+	status := 1
+	liveRoomInfo, err := manager.Get().LiveRoomManager().GetLiveInfo(req.RoomId)
+	if err != nil {
+		GameTimes = 0
+		// 返回处理结果（根据业务需求调整返回结构）
+		c.JSON(http.StatusOK, gin.H{
+			"errcode": 0,
+			"errmsg":  "success",
+			"data": gin.H{
+				"round_id":          GameTimes,
+				"round_status":      2,
+				"user_group_status": 0,
+				"group_id":          "",
+			},
+		})
+		return
+	}
+
+	GameTimes = liveRoomInfo.Times
+	if liveRoomInfo.State == "start" {
+		status = 1
+	} else {
+		status = 2
+	}
+
+	userTrackInfo, err := manager.Get().LiveRoomManager().GetLiveTrackInfoByUserId(req.RoomId, req.OpenId)
+	if err != nil {
+		c.JSON(http.StatusOK, gin.H{
+			"errcode": 0,
+			"errmsg":  "success",
+			"data": gin.H{
+				"round_id":          GameTimes,
+				"round_status":      status,
+				"user_group_status": 0,
+				"group_id":          "",
+			},
+		})
+		return
+	}
 
 	// 返回处理结果（根据业务需求调整返回结构）
 	c.JSON(http.StatusOK, gin.H{
-		"code":    0,
-		"message": "success",
-		"data":    gin.H{},
+		"errcode": 0,
+		"errmsg":  "success",
+		"data": gin.H{
+			"round_id":          GameTimes,
+			"round_status":      status,
+			"user_group_status": 1,
+			"group_id":          string(userTrackInfo.Track),
+		},
 	})
 }
 
 // 示例：获取用户信息的HTTP处理
 func (h *dyPushController) dyPushZhenYing(c *gin.Context) {
-	//var req FinishGameRequest
-	//if err := c.ShouldBindJSON(&req); err != nil {
-	//	c.JSON(http.StatusBadRequest, gin.H{"error": "invalid request format"})
-	//	return
-	//}
+	var req models.DouYinPushUserGroupRequest
+	if err := c.ShouldBindJSON(&req); err != nil {
+		c.JSON(http.StatusBadRequest, gin.H{"dyGetZhenYing error": "invalid request format"})
+		return
+	}
+
+	// 检查 x-roomid 的值
+	xRoomId := c.GetHeader("x-roomid")
+	if xRoomId == "" {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "no roomid"})
+		return
+	}
+
+	if xRoomId != req.RoomId {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "params check error"})
+		return
+	}
+
+	trackNum, err := strconv.Atoi(req.GroupId)
+	if err != nil {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "params GroupId check error"})
+		return
+	}
+	err = service.LiveRoomService{}.OneUserJoinTrack(req.RoomId, req.OpenId, trackNum)
+	if err != nil {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "dou yin push zhen ying but join error" + err.Error()})
+		return
+	}
 
 	// 返回处理结果（根据业务需求调整返回结构）
 	c.JSON(http.StatusOK, gin.H{
diff --git a/app/controller/httpController.go b/app/controller/httpController.go
index d816e56..e9994a0 100644
--- a/app/controller/httpController.go
+++ b/app/controller/httpController.go
@@ -405,6 +405,11 @@ func (h *HttpController) finishGame(c *gin.Context) {
 		if err != nil {
 			fmt.Println("stop dou yin live room all task err : ", err, ", room id : ", roomId)
 		}
+
+		err = service.DouYinService{}.SyncGameStatusToDouYinService(roomId, 2, req.FinishTrackInfo)
+		if err != nil {
+			fmt.Println("sync game status end to dou yin err : ", err, ", room id : ", roomId)
+		}
 	}
 
 	// 返回处理结果（根据业务需求调整返回结构）
diff --git a/app/controller/indexController.go b/app/controller/indexController.go
index e3310d6..60170a8 100644
--- a/app/controller/indexController.go
+++ b/app/controller/indexController.go
@@ -201,6 +201,14 @@ func (i *IndexController) HandleStartGameMessage(conn *websocket.Conn, msg Messa
 		if err != nil {
 			fmt.Println("start dou yin live room all task err : ", err, ", room id : ", liveRoomID)
 		}
+
+		var finishTrackInfo []models.FinishTrackInfo
+		// status 为1是开始
+		err = service.DouYinService{}.SyncGameStatusToDouYinService(liveRoomID, 1, finishTrackInfo)
+		if err != nil {
+			fmt.Println("sync game status start to dou yin err : ", err, ", room id : ", liveRoomID)
+		}
+
 	}
 
 	// 创建一个开始游戏的事件
diff --git a/app/manager/douyin/dy_service_manager.go b/app/manager/douyin/dy_service_manager.go
index 5812317..e466fd4 100644
--- a/app/manager/douyin/dy_service_manager.go
+++ b/app/manager/douyin/dy_service_manager.go
@@ -298,6 +298,102 @@ func StopDouYinLiveRoomSingleTask(accessToken string, liveRoomId string, taskTyp
 	return nil
 }
 
+// SyncGameStatusToDouYin 同步对局状态给抖音
+func SyncGameStatusToDouYin(accessToken string, anchorOpenId string, liveRoomId string, times int, startTime int64, endTime int64, status int, resultList []models.SyncGameGroupResultToDouYinBody) (err error) {
+	apiURL := config.Get().Douyin.APIWebcastBaseURL + "/api/gaming_con/round/sync_status" // 沙盒环境
+
+	// 构建请求参数
+	requestBody := struct {
+		AnchorOpenId    string                                   `json:"anchor_open_id"`
+		Appid           string                                   `json:"appid"`
+		RoomId          string                                   `json:"roomid"`
+		RoundId         int64                                    `json:"round_id"`
+		StartTime       int64                                    `json:"start_time"` // 本局开始时间，秒级时间戳
+		EndTime         int64                                    `json:"end_time"`   // 本局结束时间，秒级时间戳。同步的对局状态为对局结束时，该字段必传。
+		Status          int                                      `json:"status"`     // 当前房间的游戏对局状态（1=已开始、2=已结束）
+		GroupResultList []models.SyncGameGroupResultToDouYinBody `json:"group_result_list"`
+	}{
+		AnchorOpenId:    anchorOpenId,
+		Appid:           config.Get().Douyin.AppID,
+		RoomId:          liveRoomId,
+		RoundId:         int64(times),
+		StartTime:       startTime,
+		EndTime:         endTime,
+		Status:          status,
+		GroupResultList: resultList,
+	}
+
+	// 设置请求头
+	headers := map[string]string{
+		"content-type": "application/json",
+		"X-Token":      accessToken,
+	}
+
+	// 定义响应结构
+	var response struct {
+		ErrNo  int    `json:"errcode"`
+		ErrMsg string `json:"errmsg"`
+	}
+
+	// 发送请求
+	if err := utils.Post(apiURL, requestBody, headers, &response); err != nil {
+		return fmt.Errorf("请求失败: %w", err)
+	}
+
+	// 处理错误码
+	if response.ErrNo != 0 {
+		return fmt.Errorf("抖音接口错误[%d]: %s", response.ErrNo, response.ErrMsg)
+	}
+
+	fmt.Println("同步抖音直播间 状态 : ", status, ", 直播id : ", liveRoomId, " , 成功")
+	return nil
+}
+
+// SyncUserGroupToDouYin 同步用户选择阵营给抖音
+func SyncUserGroupToDouYin(accessToken string, liveRoomId string, times int, groupId string, openId string) (err error) {
+	apiURL := config.Get().Douyin.APIWebcastBaseURL + "/api/gaming_con/round/upload_user_group_info" // 沙盒环境
+
+	// 构建请求参数
+	requestBody := struct {
+		Appid   string `json:"appid"`
+		GroupId string `json:"group_id"`
+		OpenId  string `json:"open_id"`
+		RoomId  string `json:"roomid"`
+		RoundId int64  `json:"round_id"`
+	}{
+		Appid:   config.Get().Douyin.AppID,
+		GroupId: groupId,
+		OpenId:  openId,
+		RoomId:  liveRoomId,
+		RoundId: int64(times),
+	}
+
+	// 设置请求头
+	headers := map[string]string{
+		"content-type": "application/json",
+		"X-Token":      accessToken,
+	}
+
+	// 定义响应结构
+	var response struct {
+		ErrNo  int    `json:"errcode"`
+		ErrMsg string `json:"errmsg"`
+	}
+
+	// 发送请求
+	if err := utils.Post(apiURL, requestBody, headers, &response); err != nil {
+		return fmt.Errorf("请求失败: %w", err)
+	}
+
+	// 处理错误码
+	if response.ErrNo != 0 {
+		return fmt.Errorf("抖音接口错误[%d]: %s", response.ErrNo, response.ErrMsg)
+	}
+
+	fmt.Println("同步抖音直播间 用户 : ", openId, ", 阵营 : ", groupId, ", 直播id : ", liveRoomId, " , 成功")
+	return nil
+}
+
 func GetDouYinRoomInfo(accessToken, clientToken string) (*models.LiveRoomUserInfo, error) {
 	apiURL := config.Get().Douyin.APIWebcastBaseURL + "/api/webcastmate/info"
 
diff --git a/app/manager/live_room_mamanger.go b/app/manager/live_room_mamanger.go
index e4ce4c9..47b7518 100644
--- a/app/manager/live_room_mamanger.go
+++ b/app/manager/live_room_mamanger.go
@@ -27,6 +27,8 @@ type LiveRoomInfo struct {
 	NickName          string       `json:"nick_name"`
 	FailGiftPageNum   int          `json:"fail_gift_page_num"`
 	FailGiftWholePage int          `json:"fail_gift_whole_page"`
+	StartAt           sql.NullTime `json:"start_at"`  // 使用 NullTime
+	EndAt             sql.NullTime `json:"end_at"`    // 使用 NullTime
 	CreateAt          sql.NullTime `json:"create_at"` // 使用 NullTime
 	UpdateAt          sql.NullTime `json:"update_at"` // 使用 NullTime
 }
@@ -106,9 +108,9 @@ func (lrm *LiveRoomManager) CreateLiveRoomIfNotExist(liveRoomID, AnchorOpenId, A
 }
 
 // SetLiveRoomStatus 设置直播间的状态
-func (lrm *LiveRoomManager) JoinLiveRoomCamp(liveRoomID string, userId string, track int) error {
+func (lrm *LiveRoomManager) JoinLiveRoomCamp(liveRoomId string, times int, state string, userId string, track int) error {
 	if config.Get().Database.Enabled {
-		_, err := lrm.storage.JoinLiveRoomTrackMysql(liveRoomID, userId, track)
+		_, err := lrm.storage.JoinLiveRoomTrackMysql(liveRoomId, times, state, userId, track)
 		if err != nil {
 			return err
 		}
@@ -120,8 +122,8 @@ func (lrm *LiveRoomManager) JoinLiveRoomCamp(liveRoomID string, userId string, t
 	defer lrm.mu.Unlock()
 
 	// 如果不存在，则初始化一个新的状态
-	if _, exists := lrm.roomUserTrack[liveRoomID][userId]; !exists {
-		lrm.roomUserTrack[liveRoomID][userId] = UserTrack{Track: track}
+	if _, exists := lrm.roomUserTrack[liveRoomId][userId]; !exists {
+		lrm.roomUserTrack[liveRoomId][userId] = UserTrack{Track: track}
 	}
 
 	return nil
@@ -160,6 +162,8 @@ func (lrm *LiveRoomManager) GetLiveInfo(liveRoomID string) (*LiveRoomInfo, error
 			LiveRoomId: liveMysqlInfo.LiveRoomId,
 			State:      liveMysqlInfo.State,
 			Times:      liveMysqlInfo.Times,
+			StartAt:    liveMysqlInfo.StartAt,
+			EndAt:      liveMysqlInfo.EndAt,
 			CreateAt:   liveMysqlInfo.CreateAt,
 			UpdateAt:   liveMysqlInfo.UpdateAt,
 		}, nil // 返回 LiveRoomStatus 和 false
diff --git a/app/manager/live_room_mysql_storage.go b/app/manager/live_room_mysql_storage.go
index de866bb..faa2561 100644
--- a/app/manager/live_room_mysql_storage.go
+++ b/app/manager/live_room_mysql_storage.go
@@ -18,6 +18,8 @@ type LiveRoomMysqlInfo struct {
 	AnchorOpenId string       `db:"anchor_open_id"`
 	AvatarUrl    string       `db:"avatar_url"`
 	NickName     string       `db:"nick_name"`
+	StartAt      sql.NullTime `db:"start_at"`  // 使用 NullTime
+	EndAt        sql.NullTime `db:"end_at"`    // 使用 NullTime
 	CreateAt     sql.NullTime `db:"create_at"` // 使用 NullTime
 	UpdateAt     sql.NullTime `db:"update_at"` // 使用 NullTime
 }
@@ -182,14 +184,29 @@ func (lrm *LiveRoomMysqlStorage) GetLiveRoom(liveRoomID string) (*LiveRoomMysqlI
 
 // SetLiveRoomstate 设置直播间的状态
 func (lrm *LiveRoomMysqlStorage) SetLiveRoom(liveRoomID string, state string, times int) error {
-	_, err := db.GetDB().Exec(`
+	query := ""
+	if state == "start" {
+		query = `
 		update live_room
 		set state = ?,
 			times = ?,
+			start_at = CURRENT_TIMESTAMP,
 			update_at = CURRENT_TIMESTAMP
 		where
 		    live_room_id = ?
-	`,
+	`
+	} else if state == "end" {
+		query = `
+		update live_room
+		set state = ?,
+			times = ?,
+			end_at = CURRENT_TIMESTAMP,
+			update_at = CURRENT_TIMESTAMP
+		where
+		    live_room_id = ?
+	`
+	}
+	_, err := db.GetDB().Exec(query,
 		state, times, liveRoomID) // 更新值参数
 
 	if err != nil {
@@ -249,24 +266,23 @@ func (lrm *LiveRoomMysqlStorage) GetLiveTrackByUserId(liveRoomId string, userId
 }
 
 // 设置直播间用户参加阵营的数据
-func (lrm *LiveRoomMysqlStorage) JoinLiveRoomTrackMysql(liveRoomId string, userId string, track int) (*LiveTrackUserMysqlInfo, error) {
-	liveRoomMysqlInfo, err := lrm.GetLiveRoom(liveRoomId)
-
-	if err != nil {
-		return nil, fmt.Errorf("join live room track error : %v, by no live room", err)
+func (lrm *LiveRoomMysqlStorage) JoinLiveRoomTrackMysql(liveRoomId string, times int, state string, userId string, track int) (*LiveTrackUserMysqlInfo, error) {
+	//liveRoomMysqlInfo, err := lrm.GetLiveRoom(liveRoomId)
+	//if err != nil {
+	//	return nil, fmt.Errorf("join live room track error : %v, by no live room", err)
+	//}
+
+	if state == "end" {
+		return nil, fmt.Errorf("join live room track error because live room state is end")
 	}
 
-	if liveRoomMysqlInfo.State == "end" {
-		return nil, fmt.Errorf("join live room track error : %v, by live room state is end", err)
-	}
-
-	liveTrackUserMysqlInfo, err := lrm.GetLiveTrackByUserId(liveRoomId, userId, liveRoomMysqlInfo.Times)
+	liveTrackUserMysqlInfo, err := lrm.GetLiveTrackByUserId(liveRoomId, userId, times)
 
 	if err == nil {
 		return liveTrackUserMysqlInfo, fmt.Errorf("user has join live room track ")
 	}
 
-	err = lrm.CreateLiveTrack(liveRoomId, userId, liveRoomMysqlInfo.Times, track)
+	err = lrm.CreateLiveTrack(liveRoomId, userId, times, track)
 	if err != nil {
 		return nil, fmt.Errorf("failed to initialize user live track: %v", err)
 	}
diff --git a/app/models/models.go b/app/models/models.go
index 07360cf..a416bcb 100644
--- a/app/models/models.go
+++ b/app/models/models.go
@@ -160,6 +160,10 @@ type LikeOneRequest struct {
 	Timestamp int64  `json:"timestamp"`
 }
 
+type LikeRequest struct {
+	Arr []LikeOneRequest `json:"arr"`
+}
+
 // 抖音推送数据的点赞元数据
 type FansOneRequest struct {
 	MsgID              string `json:"msg_id"`
@@ -176,6 +180,25 @@ type FansRequest struct {
 	Arr []FansOneRequest `json:"arr"`
 }
 
-type LikeRequest struct {
-	Arr []LikeOneRequest `json:"arr"`
+// 抖音推送数据的点赞元数据
+type SyncGameGroupResultToDouYinBody struct {
+	GroupId string `json:"group_id"` // 阵营id，red, green, yellow
+	Result  int    `json:"result"`   // 对局结果（1=胜利、2=失败、3=平局）
+}
+
+// 抖音查询观众阵营的数据结构
+type DouYinGetUserGroupRequest struct {
+	AppId  string `json:"app_id"`
+	OpenId string `json:"open_id"`
+	RoomId string `json:"room_id"`
+}
+
+// 抖音推送观众选择阵营的数据结构
+type DouYinPushUserGroupRequest struct {
+	AppId     string `json:"app_id"`
+	OpenId    string `json:"open_id"`
+	RoomId    string `json:"room_id"`
+	GroupId   string `json:"group_id"`
+	AvatarUrl string `json:"avatar_url"`
+	NickName  string `json:"nickname"`
 }
diff --git a/app/service/douyin_service.go b/app/service/douyin_service.go
index 741f4f9..d316cb7 100644
--- a/app/service/douyin_service.go
+++ b/app/service/douyin_service.go
@@ -56,6 +56,65 @@ func (ls DouYinService) StopDouYinLiveRoomAllTask(liveRoomId string) error {
 	}
 	return nil
 }
+
+func (ls DouYinService) SyncGameStatusToDouYinService(liveRoomId string, status int, FinishTrackInfo []models.FinishTrackInfo) error {
+	token, err := ls.GetToken()
+	if err != nil {
+		return err
+	}
+
+	liveRoomInfo, err := manager.Get().LiveRoomManager().GetLiveInfo(liveRoomId)
+	loc, _ := time.LoadLocation("Asia/Shanghai")
+
+	startTime := int64(0)
+	endTime := int64(0)
+	var resultList []models.SyncGameGroupResultToDouYinBody
+
+	if status == 1 {
+		startTime = time.Now().In(loc).Unix()
+	} else {
+		startTime = liveRoomInfo.StartAt.Time.UnixMilli()
+		endTime = liveRoomInfo.EndAt.Time.UnixMilli()
+		for _, info := range FinishTrackInfo {
+			gameResult := 3
+			if info.IsChampion == 1 {
+				gameResult = 1
+			} else if info.IsFinish == 1 {
+				gameResult = 2
+			} else {
+				gameResult = 3
+			}
+			result := models.SyncGameGroupResultToDouYinBody{
+				GroupId: string(info.Track),
+				Result:  gameResult,
+			}
+
+			resultList = append(resultList, result)
+		}
+	}
+
+	err = douyin.SyncGameStatusToDouYin(token, liveRoomInfo.AnchorOpenId, liveRoomId, liveRoomInfo.Times, startTime, endTime, status, resultList)
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
+func (ls DouYinService) SyncUserGroupToDouYinService(liveRoomId string, times int, groupId string, openId string) error {
+	token, err := ls.GetToken()
+	if err != nil {
+		return err
+	}
+
+	//liveRoomInfo, err := manager.Get().LiveRoomManager().GetLiveInfo(liveRoomId)
+
+	err = douyin.SyncUserGroupToDouYin(token, liveRoomId, times, groupId, openId)
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
 func (ls DouYinService) RequestDouYinForLiveLogin(liveRoomToken string) (models.LiveRoomUserInfo, error) {
 	if liveRoomToken == "this@is*Test" {
 		return models.LiveRoomUserInfo{
diff --git a/app/service/live_room_service.go b/app/service/live_room_service.go
index 1bfc154..782234c 100644
--- a/app/service/live_room_service.go
+++ b/app/service/live_room_service.go
@@ -14,7 +14,12 @@ import (
 type LiveRoomService struct{}
 
 func (ls LiveRoomService) OneUserJoinTrack(liveRoomID string, userId string, track int) error {
-	err := manager.Get().LiveRoomManager().JoinLiveRoomCamp(liveRoomID, userId, track)
+	liveRoomInfo, err := manager.Get().LiveRoomManager().GetLiveInfo(liveRoomID)
+	if err != nil {
+		return fmt.Errorf("want join track but get live info error: %v, by no live room", err)
+	}
+
+	err = manager.Get().LiveRoomManager().JoinLiveRoomCamp(liveRoomID, liveRoomInfo.Times, liveRoomInfo.State, userId, track)
 
 	if err != nil {
 		return err
@@ -36,6 +41,13 @@ func (ls LiveRoomService) OneUserJoinTrack(liveRoomID string, userId string, tra
 		UserScore = userInfo.Score
 	}
 
+	if liveRoomID != utils.TestRoomId {
+		err := DouYinService{}.SyncUserGroupToDouYinService(liveRoomID, liveRoomInfo.Times, string(track), userId)
+		if err != nil {
+			fmt.Println("sync user group status end to dou yin err : ", err, ", room id : ", liveRoomID)
+		}
+	}
+
 	// 创建一个礼物事件
 	data := models.LiveEventData{
 		Event: "broad_join_track",
-- 
Gitee


From 0d5afd405d107397df8d10e300dc2f2adcca116f Mon Sep 17 00:00:00 2001
From: udieudie <udieudie@126.com>
Date: Mon, 26 May 2025 14:03:17 +0800
Subject: [PATCH 12/16] =?UTF-8?q?david/feat:=E5=A2=9E=E5=8A=A0=E7=94=A8?=
 =?UTF-8?q?=E6=88=B7=E7=AD=89=E7=BA=A79=E7=BA=A7=E5=92=8C10=E7=BA=A7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/manager/level_manager.go | 18 ++++++++++--------
 1 file changed, 10 insertions(+), 8 deletions(-)

diff --git a/app/manager/level_manager.go b/app/manager/level_manager.go
index 27852d8..ec87023 100644
--- a/app/manager/level_manager.go
+++ b/app/manager/level_manager.go
@@ -16,14 +16,16 @@ type LevelManager struct {
 
 // 定义全局的gift列表
 var levelList = []LevelSet{
-	{Level: 1, UpperLimit: 1000, LevelGift: "1_ji_li_wu"},    // 1.3元
-	{Level: 2, UpperLimit: 3000, LevelGift: "2_ji_li_wu"},    // 3.9元
-	{Level: 3, UpperLimit: 5000, LevelGift: "3_ji_li_wu"},    // 6.66元
-	{Level: 4, UpperLimit: 80000, LevelGift: "4_ji_li_wu"},   // 106.7元
-	{Level: 5, UpperLimit: 300000, LevelGift: "5_ji_li_wu"},  // 400元
-	{Level: 6, UpperLimit: 675000, LevelGift: "6_ji_li_wu"},  // 900元
-	{Level: 7, UpperLimit: 1500000, LevelGift: "7_ji_li_wu"}, // 2000元
-	{Level: 8, UpperLimit: 3800000, LevelGift: "8_ji_li_wu"}, // 5066元
+	{Level: 1, UpperLimit: 1000, LevelGift: "1_ji_li_wu"},       // 1.3元
+	{Level: 2, UpperLimit: 3000, LevelGift: "2_ji_li_wu"},       // 3.9元
+	{Level: 3, UpperLimit: 5000, LevelGift: "3_ji_li_wu"},       // 6.66元
+	{Level: 4, UpperLimit: 80000, LevelGift: "4_ji_li_wu"},      // 106.7元
+	{Level: 5, UpperLimit: 300000, LevelGift: "5_ji_li_wu"},     // 400元
+	{Level: 6, UpperLimit: 675000, LevelGift: "6_ji_li_wu"},     // 900元
+	{Level: 7, UpperLimit: 1500000, LevelGift: "7_ji_li_wu"},    // 2000元
+	{Level: 8, UpperLimit: 3800000, LevelGift: "8_ji_li_wu"},    // 5066元
+	{Level: 9, UpperLimit: 6050000, LevelGift: "9_ji_li_wu"},    // 8066元
+	{Level: 10, UpperLimit: 11275000, LevelGift: "10_ji_li_wu"}, // 15033元
 }
 
 // NewLevelManager 初始化LevelManager
-- 
Gitee


From c79d0ea941f66434fa2b437f2087bcc2bf43dd29 Mon Sep 17 00:00:00 2001
From: udieudie <udieudie@126.com>
Date: Tue, 27 May 2025 18:41:53 +0800
Subject: [PATCH 13/16] =?UTF-8?q?david/feat:=E5=A2=9E=E5=8A=A0https?=
 =?UTF-8?q?=E7=9A=84=E8=AF=B7=E6=B1=82=E9=80=89=E9=A1=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 templates/index.html | 95 ++++++++++++++++++++++----------------------
 1 file changed, 48 insertions(+), 47 deletions(-)

diff --git a/templates/index.html b/templates/index.html
index 867f86f..543710b 100644
--- a/templates/index.html
+++ b/templates/index.html
@@ -128,6 +128,9 @@
     var userId = ""
     var consoleMessageArray = []
     var ip = "82.157.179.66:8001"
+    var wsRequestMethod = "ws"
+    var httpRequestMethod = "http"
+    var ip = "82.157.179.66:8001"
     var moneyRemaining = 3000
     // 直播间登录给的token
     var liveRoomToken = ""
@@ -138,14 +141,14 @@
     setMonyRemainingText(moneyRemaining)
 
     var headImgArr = [
-            "http://82.157.179.66:8001/static/03763e7c5fd77d3ba9d0ed2b35f5bfeb.jpeg",
-            "http://82.157.179.66:8001/static/16e1041e5e02db1c77678084102a9b6b.jpeg",
-            "http://82.157.179.66:8001/static/8944face68cc71bc452ea8a4fd0abc5b.jpeg",
-            "http://82.157.179.66:8001/static/9c19c581f33e134b252d44dbc5ddef67.jpg",
-            "http://82.157.179.66:8001/static/1a59df123cac3944d1104dd164160888.jpeg",
-            "http://82.157.179.66:8001/static/d5ade3fccf97e1fc59ba2c7c63619cf9.jpg",
-            "http://82.157.179.66:8001/static/a45f096821bb09659443c512c204ec47.jpeg",
-            "http://82.157.179.66:8001/static/391b8b23c018e957d38b6787f0791fa7.jpeg",
+            "https://blaze-api-test.xinghuohuiju.com/static/03763e7c5fd77d3ba9d0ed2b35f5bfeb.jpeg",
+            "https://blaze-api-test.xinghuohuiju.com/static/16e1041e5e02db1c77678084102a9b6b.jpeg",
+            "https://blaze-api-test.xinghuohuiju.com/static/8944face68cc71bc452ea8a4fd0abc5b.jpeg",
+            "https://blaze-api-test.xinghuohuiju.com/static/9c19c581f33e134b252d44dbc5ddef67.jpg",
+            "https://blaze-api-test.xinghuohuiju.com/static/1a59df123cac3944d1104dd164160888.jpeg",
+            "https://blaze-api-test.xinghuohuiju.com/static/d5ade3fccf97e1fc59ba2c7c63619cf9.jpg",
+            "https://blaze-api-test.xinghuohuiju.com/static/a45f096821bb09659443c512c204ec47.jpeg",
+            "https://blaze-api-test.xinghuohuiju.com/static/391b8b23c018e957d38b6787f0791fa7.jpeg",
     ]
 
     var headImg = headImgArr[Math.floor(Math.random() * (headImgArr.length - 1))];
@@ -174,6 +177,13 @@
         ip = ip.replaceAll(":8001", ":8011")
     }
 
+    var isHttps = queryParams.https === '1'; // 检查是否有local=1参数
+    if(isHttps){
+        wsRequestMethod = "wss"
+        httpRequestMethod = "https"
+    }
+
+
     var giftList = [
         {
             id: 1,
@@ -258,8 +268,7 @@
 
         liveRoomToken = encodeURIComponent(liveRoomToken)
 
-        // var url = "ws://" + ip + ":8001/index/regist?liveRoomID=" + liveRoomID + "&liveRoomToken=" + liveRoomToken;
-        var url = "ws://" + ip + "/index/regist?" + "liveRoomToken=" + liveRoomToken;
+        var url = wsRequestMethod + "://" + ip + "/index/regist?" + "liveRoomToken=" + liveRoomToken;
         console.log("connect ws url : ", url)
         useConnection(url)
         if (ws.readyState === WebSocket.OPEN) {
@@ -392,7 +401,7 @@
         }
         giftNum = parseInt(giftNum)
 
-        const url = `http://${ip}/api/v1/getLikeRequest`;
+        const url = httpRequestMethod + `://${ip}/api/v1/getLikeRequest`;
 
         let likeArr = [
             {
@@ -443,7 +452,7 @@
             return
         }
 
-        const url = `http://${ip}/api/v1/getGiftRequest`;
+        const url = httpRequestMethod + `://${ip}/api/v1/getGiftRequest`;
 
         let giftData = getGiftData(giftId)
 
@@ -564,7 +573,7 @@
 
         joinedTrack = num
 
-        const url = `http://${ip}/api/v1/getPingLun`;
+        const url = httpRequestMethod + `://${ip}/api/v1/getPingLun`;
 
         console.log("sendJoinMsg function sendJoinMsg joinedTrack : ", joinedTrack)
         console.log("sendJoinMsg function sendJoinMsg headImg : ", headImg)
@@ -834,7 +843,7 @@
     }
 
     function sendTokenRequest(){
-        const url = `http://${ip}/api/v1/getToken`;
+        const url = httpRequestMethod + `://${ip}/api/v1/getToken`;
         const params = { userId: 'david' };
         const headers = { 'Authorization': 'Bearer your-token' };
 
@@ -848,7 +857,7 @@
     }
 
     function sendAnchorLoginRequst(){
-        const url = `http://${ip}/api/v1/auth/anchor/login`;
+        const url = httpRequestMethod + `://${ip}/api/v1/auth/anchor/login`;
         const params = { token: 'david-token-test' };
         // const headers = { 'Authorization': 'Bearer your-token' };
 
@@ -876,22 +885,14 @@
 
 
     function sendPingLunRequest(){
-        const url = `http://${ip}/api/v1/getPingLun`;
-
-        // "http://82.157.179.66:8001/static/16e1041e5e02db1c77678084102a9b6b.jpeg",
-        //     "http://82.157.179.66:8001/static/8944face68cc71bc452ea8a4fd0abc5b.jpeg",
-        //     "http://82.157.179.66:8001/static/9c19c581f33e134b252d44dbc5ddef67.jpg",
-        //     "http://82.157.179.66:8001/static/1a59df123cac3944d1104dd164160888.jpeg",
-        //     "http://82.157.179.66:8001/static/d5ade3fccf97e1fc59ba2c7c63619cf9.jpg",
-        //     "http://82.157.179.66:8001/static/a45f096821bb09659443c512c204ec47.jpeg",
-        //     "http://82.157.179.66:8001/static/391b8b23c018e957d38b6787f0791fa7.jpeg",
+        const url = httpRequestMethod + `://${ip}/api/v1/getPingLun`;
 
         let pinglunArr = [
             {
                 "msg_id": "123456781",  // string类型id
                 "sec_openid":"kjabfjkabef",    // 评论用户的加密openid, 当前其实没有加密
                 "content":"1",       // 评论内容
-                "avatar_url":"http://82.157.179.66:8001/static/03763e7c5fd77d3ba9d0ed2b35f5bfeb.jpeg",     // 评论用户头像
+                "avatar_url":"https://blaze-api-test.xinghuohuiju.com/static/03763e7c5fd77d3ba9d0ed2b35f5bfeb.jpeg",     // 评论用户头像
                 "nickname":"yihao",      // 评论用户昵称(不加密)
                 "timestamp":1649068664, // 评论毫秒级时间戳
             },
@@ -900,7 +901,7 @@
                 "msg_id": "1234aegaeg1",  // string类型id
                 "sec_openid":"kjabfjkabef",    // 评论用户的加密openid, 当前其实没有加密
                 "content":"2",       // 评论内容
-                "avatar_url":"http://82.157.179.66:8001/static/03763e7c5fd77d3ba9d0ed2b35f5bfeb.jpeg",     // 评论用户头像
+                "avatar_url":"https://blaze-api-test.xinghuohuiju.com/static/03763e7c5fd77d3ba9d0ed2b35f5bfeb.jpeg",     // 评论用户头像
                 "nickname":"yihao",      // 评论用户昵称(不加密)
                 "timestamp":1649068964, // 评论毫秒级时间戳
             },
@@ -909,7 +910,7 @@
                 "msg_id": "1aegaegfafaegaeg1",  // string类型id
                 "sec_openid":"aaaaafjkabef",    // 评论用户的加密openid, 当前其实没有加密
                 "content":"2",       // 评论内容
-                "avatar_url":"http://82.157.179.66:8001/static/9c19c581f33e134b252d44dbc5ddef67.jpeg",     // 评论用户头像
+                "avatar_url":"https://blaze-api-test.xinghuohuiju.com/static/9c19c581f33e134b252d44dbc5ddef67.jpeg",     // 评论用户头像
                 "nickname":"erhao",      // 评论用户昵称(不加密)
                 "timestamp":1649068964, // 评论毫秒级时间戳
             },
@@ -918,7 +919,7 @@
                 "msg_id": "1234aaegaefgaafag1",  // string类型id
                 "sec_openid":"kjabfjkgegegegegf",    // 评论用户的加密openid, 当前其实没有加密
                 "content":"3",       // 评论内容
-                "avatar_url":"http://82.157.179.66:8001/static/1a59df123cac3944d1104dd164160888.jpeg",     // 评论用户头像
+                "avatar_url":"https://blaze-api-test.xinghuohuiju.com/static/1a59df123cac3944d1104dd164160888.jpeg",     // 评论用户头像
                 "nickname":"sanhao",      // 评论用户昵称(不加密)
                 "timestamp":1649068964, // 评论毫秒级时间戳
             },
@@ -927,7 +928,7 @@
                 "msg_id": "1234aegaegeaegaaeg1",  // string类型id
                 "sec_openid":"aaaaaaaaaaaa",    // 评论用户的加密openid, 当前其实没有加密
                 "content":"nihao",       // 评论内容
-                "avatar_url":"http://82.157.179.66:8001/static/391b8b23c018e957d38b6787f0791fa7.jpeg",     // 评论用户头像
+                "avatar_url":"https://blaze-api-test.xinghuohuiju.com/static/391b8b23c018e957d38b6787f0791fa7.jpeg",     // 评论用户头像
                 "nickname":"sihao",      // 评论用户昵称(不加密)
                 "timestamp":1649068964, // 评论毫秒级时间戳
             },
@@ -936,7 +937,7 @@
                 "msg_id": "12wrhrewgsasafegaeg1",  // string类型id
                 "sec_openid":"bbbbtaekabbbbbb",    // 评论用户的加密openid, 当前其实没有加密
                 "content":"3",       // 评论内容
-                "avatar_url":"http://82.157.179.66:8001/static/a45f096821bb09659443c512c204ec47.jpeg",     // 评论用户头像
+                "avatar_url":"https://blaze-api-test.xinghuohuiju.com/static/a45f096821bb09659443c512c204ec47.jpeg",     // 评论用户头像
                 "nickname":"wuhao",      // 评论用户昵称(不加密)
                 "timestamp":1649068964, // 评论毫秒级时间戳
             },
@@ -945,7 +946,7 @@
                 "msg_id": "1234aegaeg1",  // string类型id
                 "sec_openid":"cccabfjkcccccc",    // 评论用户的加密openid, 当前其实没有加密
                 "content":"1",       // 评论内容
-                "avatar_url":"http://82.157.179.66:8001/static/03763e7c5fd77d3ba9d0ed2b35f5bfeb.jpeg",     // 评论用户头像
+                "avatar_url":"https://blaze-api-test.xinghuohuiju.com/static/03763e7c5fd77d3ba9d0ed2b35f5bfeb.jpeg",     // 评论用户头像
                 "nickname":"liuhao",      // 评论用户昵称(不加密)
                 "timestamp":1649068964, // 评论毫秒级时间戳
             }
@@ -969,7 +970,7 @@
     }
 
     function sendGiftRequest(){
-        const url = `http://${ip}/api/v1/getGift`;
+        const url = httpRequestMethod + `://${ip}/api/v1/getGift`;
 
         let giftArr = [
             {
@@ -978,7 +979,7 @@
                 "sec_gift_id": "PJ0FFeaDzXUreuUBZH6Hs+b56Jh0tQjrq0bIrrlZmv13GSAL9Q1hf59fjGk=",  // 加密的礼物id
                 "gift_num": 22,        // 送出的礼物数量
                 "gift_value": 10000,    // 礼物总价值，单位分
-                "avatar_url":"http://82.157.179.66:8001/static/03763e7c5fd77d3ba9d0ed2b35f5bfeb.jpeg",     // 评论用户头像
+                "avatar_url":"https://blaze-api-test.xinghuohuiju.com/static/03763e7c5fd77d3ba9d0ed2b35f5bfeb.jpeg",     // 评论用户头像
                 "nickname":"yihao",      // 评论用户昵称(不加密)
                 "timestamp":1649068664, // 评论毫秒级时间戳
             },
@@ -989,7 +990,7 @@
                 "sec_gift_id": "gx7pmjQfhBaDOG2XkWI2peZ66YFWkCWRjZXpTqb23O/epru+sxWyTV/3Ufs=",  // 加密的礼物id
                 "gift_num": 8,        // 送出的礼物数量
                 "gift_value": 10000,    // 礼物总价值，单位分
-                "avatar_url":"http://82.157.179.66:8001/static/03763e7c5fd77d3ba9d0ed2b35f5bfeb.jpeg",     // 评论用户头像
+                "avatar_url":"https://blaze-api-test.xinghuohuiju.com/static/03763e7c5fd77d3ba9d0ed2b35f5bfeb.jpeg",     // 评论用户头像
                 "nickname":"yihao",      // 评论用户昵称(不加密)
                 "timestamp":1649068964, // 评论毫秒级时间戳
             },
@@ -1000,7 +1001,7 @@
                 "sec_gift_id": "n1/Dg1905sj1FyoBlQBvmbaDZFBNaKuKZH6zxHkv8Lg5x2cRfrKUTb8gzMs=",  // 加密的礼物id
                 "gift_num": 1,        // 送出的礼物数量
                 "gift_value": 10000,    // 礼物总价值，单位分    // 评论内容
-                "avatar_url":"http://82.157.179.66:8001/static/9c19c581f33e134b252d44dbc5ddef67.jpeg",     // 评论用户头像
+                "avatar_url":"https://blaze-api-test.xinghuohuiju.com/static/9c19c581f33e134b252d44dbc5ddef67.jpeg",     // 评论用户头像
                 "nickname":"erhao",      // 评论用户昵称(不加密)
                 "timestamp":1649068964, // 评论毫秒级时间戳
             },
@@ -1011,7 +1012,7 @@
                 "sec_gift_id": "28rYzVFNyXEXFC8HI+f/WG+I7a6lfl3OyZZjUS+CVuwCgYZrPrUdytGHu0c=",  // 加密的礼物id
                 "gift_num": 2,        // 送出的礼物数量
                 "gift_value": 10000,    // 礼物总价值，单位分
-                "avatar_url":"http://82.157.179.66:8001/static/1a59df123cac3944d1104dd164160888.jpeg",     // 评论用户头像
+                "avatar_url":"https://blaze-api-test.xinghuohuiju.com/static/1a59df123cac3944d1104dd164160888.jpeg",     // 评论用户头像
                 "nickname":"sanhao",      // 评论用户昵称(不加密)
                 "timestamp":1649068964, // 评论毫秒级时间戳
             },
@@ -1022,7 +1023,7 @@
                 "sec_gift_id": "P7zDZzpeO215SpUptB+aURb1+zC14UC9MY1+MHszKoF0p5gzYk8CNEbey60=",  // 加密的礼物id
                 "gift_num": 3,        // 送出的礼物数量
                 "gift_value": 10000,    // 礼物总价值，单位分
-                "avatar_url":"http://82.157.179.66:8001/static/391b8b23c018e957d38b6787f0791fa7.jpeg",     // 评论用户头像
+                "avatar_url":"https://blaze-api-test.xinghuohuiju.com/static/391b8b23c018e957d38b6787f0791fa7.jpeg",     // 评论用户头像
                 "nickname":"sihao",      // 评论用户昵称(不加密)
                 "timestamp":1649068964, // 评论毫秒级时间戳
             },
@@ -1033,7 +1034,7 @@
                 "sec_gift_id": "PJ0FFeaDzXUreuUBZH6Hs+b56Jh0tQjrq0bIrrlZmv13GSAL9Q1hf59fjGk=",  // 加密的礼物id
                 "gift_num": 2,        // 送出的礼物数量
                 "gift_value": 10000,    // 礼物总价值，单位分
-                "avatar_url":"http://82.157.179.66:8001/static/a45f096821bb09659443c512c204ec47.jpeg",     // 评论用户头像
+                "avatar_url":"https://blaze-api-test.xinghuohuiju.com/static/a45f096821bb09659443c512c204ec47.jpeg",     // 评论用户头像
                 "nickname":"wuhao",      // 评论用户昵称(不加密)
                 "timestamp":1649068964, // 评论毫秒级时间戳
             },
@@ -1044,7 +1045,7 @@
                 "sec_gift_id": "IkkadLfz7O/a5UR45p/OOCCG6ewAWVbsuzR/Z+v1v76CBU+mTG/wPjqdpfg=",  // 加密的礼物id
                 "gift_num": 1,        // 送出的礼物数量
                 "gift_value": 10000,    // 礼物总价值，单位分
-                "avatar_url":"http://82.157.179.66:8001/static/03763e7c5fd77d3ba9d0ed2b35f5bfeb.jpeg",     // 评论用户头像
+                "avatar_url":"https://blaze-api-test.xinghuohuiju.com/static/03763e7c5fd77d3ba9d0ed2b35f5bfeb.jpeg",     // 评论用户头像
                 "nickname":"liuhao",      // 评论用户昵称(不加密)
                 "timestamp":1649068964, // 评论毫秒级时间戳
             }
@@ -1068,7 +1069,7 @@
     }
 
     function sendFinishRequest(){
-        const url = `http://${ip}/api/v1/auth/finishGame`;
+        const url = httpRequestMethod + `://${ip}/api/v1/auth/finishGame`;
 
         let message = {
                 "msg_id": "1029378912340134",  // string类型id
@@ -1125,7 +1126,7 @@
     }
 
     function sendGetRanksRequest(){
-        const url = `http://${ip}/api/v1/auth/getRanks`;
+        const url = httpRequestMethod + `://${ip}/api/v1/auth/getRanks`;
 
         liveRoomID = document.getElementById('liveRoomId').value;
         if(liveRoomID == ''){
@@ -1152,7 +1153,7 @@
             //     "index": 1,      // 排名
             //     "user_id": "wejhrwiuehr",  // User id
             //     "user_name": "asegfhaeg",  // user name
-            //     "head_img": "http://82.157.179.66:8001/static/a45f096821bb09659443c512c204ec47.jpeg",
+            //     "head_img": "https://blaze-api-test.xinghuohuiju.com/static/a45f096821bb09659443c512c204ec47.jpeg",
                                     //  用户头像
             //     "level": 7,      // 用户登记
             //     "value": 922950      // 对应的排行数据，分数，里程，登高
@@ -1163,7 +1164,7 @@
     }
 
     function sendGetWorldRecordsRequest(){
-        const url = `http://${ip}/api/v1/auth/getWorldRecords`;
+        const url = httpRequestMethod + `://${ip}/api/v1/auth/getWorldRecords`;
 
         liveRoomID = document.getElementById('liveRoomId').value;
         if(liveRoomID == ''){
@@ -1193,7 +1194,7 @@
     }
 
     function openSendManyRequest(){
-        const url = `http://${ip}/api/v1/OpenSendManyRequest`;
+        const url = httpRequestMethod + `://${ip}/api/v1/OpenSendManyRequest`;
 
         liveRoomID = document.getElementById('liveRoomId').value;
         if(liveRoomID == ''){
@@ -1215,7 +1216,7 @@
     }
 
     function openSendManyZanRequest(){
-        const url = `http://${ip}/api/v1/OpenSendManyZanRequest`;
+        const url = httpRequestMethod + `://${ip}/api/v1/OpenSendManyZanRequest`;
 
         liveRoomID = document.getElementById('liveRoomId').value;
         if(liveRoomID == ''){
@@ -1237,7 +1238,7 @@
     }
 
     function closeSendManyRequest(){
-        const url = `http://${ip}/api/v1/CloseSendManyRequest`;
+        const url = httpRequestMethod + `://${ip}/api/v1/CloseSendManyRequest`;
 
         liveRoomID = document.getElementById('liveRoomId').value;
         if(liveRoomID == ''){
@@ -1259,7 +1260,7 @@
     }
 
     function sendClientErrorRequest(){
-        const url = `http://${ip}/api/v1/recordClientError`;
+        const url = httpRequestMethod + `://${ip}/api/v1/recordClientError`;
 
         const data =  {"live_room_id": "111",
             "desc": "this is desc",
-- 
Gitee


From 6c041e536e296e886a7f9ccb29016fbb06136d17 Mon Sep 17 00:00:00 2001
From: udieudie <udieudie@126.com>
Date: Tue, 27 May 2025 18:47:00 +0800
Subject: [PATCH 14/16] =?UTF-8?q?david/feat:=E5=A2=9E=E5=8A=A0=E8=AE=BE?=
 =?UTF-8?q?=E7=BD=AE=E8=AF=B7=E6=B1=82=E5=9F=9F=E5=90=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 templates/index.html | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/templates/index.html b/templates/index.html
index 543710b..f4250d0 100644
--- a/templates/index.html
+++ b/templates/index.html
@@ -127,7 +127,6 @@
     var liveRoomID = "11111"
     var userId = ""
     var consoleMessageArray = []
-    var ip = "82.157.179.66:8001"
     var wsRequestMethod = "ws"
     var httpRequestMethod = "http"
     var ip = "82.157.179.66:8001"
@@ -183,6 +182,11 @@
         httpRequestMethod = "https"
     }
 
+    var settingHostName = queryParams.host === '1'; // 检查是否有local=1参数
+    if(settingHostName){
+        ip = settingHostName
+    }
+
 
     var giftList = [
         {
-- 
Gitee


From 6ce4cc8d4a22c3730414aa1a022331fb107312cd Mon Sep 17 00:00:00 2001
From: udieudie <udieudie@126.com>
Date: Tue, 27 May 2025 19:03:25 +0800
Subject: [PATCH 15/16] =?UTF-8?q?david/feat:=E4=BF=AE=E5=A4=8D=E8=AE=BE?=
 =?UTF-8?q?=E7=BD=AEhost=E7=9A=84=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 templates/index.html | 1 +
 1 file changed, 1 insertion(+)

diff --git a/templates/index.html b/templates/index.html
index f4250d0..3cfe7f7 100644
--- a/templates/index.html
+++ b/templates/index.html
@@ -185,6 +185,7 @@
     var settingHostName = queryParams.host === '1'; // 检查是否有local=1参数
     if(settingHostName){
         ip = settingHostName
+        console.log("set ip : ", ip)
     }
 
 
-- 
Gitee


From 040dbedc0a01b7d8cf6d380e758d16d816131855 Mon Sep 17 00:00:00 2001
From: udieudie <udieudie@126.com>
Date: Tue, 27 May 2025 19:35:44 +0800
Subject: [PATCH 16/16] =?UTF-8?q?david/feat:=E5=A2=9E=E5=8A=A0host?=
 =?UTF-8?q?=E7=9A=84=E6=8E=A7=E5=88=B6=E5=8F=B0=E8=BE=93=E5=87=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 templates/index.html | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/templates/index.html b/templates/index.html
index 3cfe7f7..5625439 100644
--- a/templates/index.html
+++ b/templates/index.html
@@ -182,7 +182,10 @@
         httpRequestMethod = "https"
     }
 
-    var settingHostName = queryParams.host === '1'; // 检查是否有local=1参数
+    var settingHostName = queryParams.host ; // 检查是否有local=1参数
+
+    console.log("queryParams.host : ", queryParams.host)
+
     if(settingHostName){
         ip = settingHostName
         console.log("set ip : ", ip)
-- 
Gitee