From 0d459eafa7ad5bb08cc852bea4ebb2ef9e2a3d3a Mon Sep 17 00:00:00 2001 From: udieudie Date: Sat, 14 Jun 2025 15:39:03 +0800 Subject: [PATCH 1/9] =?UTF-8?q?david/hotfix:=E5=A2=9E=E5=8A=A0=E8=AF=B7?= =?UTF-8?q?=E6=B1=82sync=E7=9A=84=E5=90=8C=E6=AD=A5=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/manager/douyin/dy_service_manager.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/app/manager/douyin/dy_service_manager.go b/app/manager/douyin/dy_service_manager.go index 771b386..d95d398 100644 --- a/app/manager/douyin/dy_service_manager.go +++ b/app/manager/douyin/dy_service_manager.go @@ -121,6 +121,10 @@ func GetDouyinToken() (accessToken string, expiresIn int, err error) { return "", 0, fmt.Errorf("抖音接口错误[%d]: %s", response.ErrNo, response.ErrTips) } + fmt.Printf("生成抖音Token : %s, 请求url : %s, requestBody : %v, headers : %v", response.Data.AccessToken, + apiURL, requestBody, headers, + ) + return response.Data.AccessToken, response.Data.ExpiresIn, nil } @@ -342,7 +346,9 @@ func SyncGameStatusToDouYin(accessToken string, anchorOpenId string, liveRoomId // 处理错误码 if response.ErrNo != 0 { - return fmt.Errorf("抖音接口错误[%d]: %s", response.ErrNo, response.ErrMsg) + return fmt.Errorf("抖音接口错误[%d]: %s, 请求url: %s, requstBody : %v, headers : %v ", response.ErrNo, response.ErrMsg, + apiURL, requestBody, headers, + ) } fmt.Println("同步抖音直播间 状态 : ", status, ", 直播id : ", liveRoomId, " , 成功") -- Gitee From cdb7e461f8d3588da9bd37856bf216e90c7872ad Mon Sep 17 00:00:00 2001 From: udieudie Date: Sat, 14 Jun 2025 15:47:18 +0800 Subject: [PATCH 2/9] =?UTF-8?q?david/hotfix:=E4=BF=AE=E5=A4=8D=E8=AF=B7?= =?UTF-8?q?=E6=B1=82=E7=9A=84appi=E7=9A=84=E4=B8=8D=E5=AF=B9=E7=9A=84?= =?UTF-8?q?=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/manager/douyin/dy_service_manager.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/app/manager/douyin/dy_service_manager.go b/app/manager/douyin/dy_service_manager.go index d95d398..07ff555 100644 --- a/app/manager/douyin/dy_service_manager.go +++ b/app/manager/douyin/dy_service_manager.go @@ -309,7 +309,7 @@ func SyncGameStatusToDouYin(accessToken string, anchorOpenId string, liveRoomId // 构建请求参数 requestBody := struct { AnchorOpenId string `json:"anchor_open_id"` - Appid string `json:"appid"` + Appid string `json:"app_id"` RoomId string `json:"room_id"` RoundId int64 `json:"round_id"` StartTime int64 `json:"start_time"` // 本局开始时间，秒级时间戳 -- Gitee From ba850f9d22013f150c3b5dc764936f918f818076 Mon Sep 17 00:00:00 2001 From: udieudie Date: Sat, 14 Jun 2025 16:02:54 +0800 Subject: [PATCH 3/9] =?UTF-8?q?david/hotfix:=E8=B0=83=E6=95=B4sql=E9=94=99?= =?UTF-8?q?=E8=AF=AF=E7=9A=84=E6=97=A5=E5=BF=97=E8=AE=B0=E5=BD=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../douyin_fail_gift_record_mysql_storage.go | 4 ++-- app/manager/gift_record_mysql_storage.go | 16 ++++++++-------- app/manager/live_room_mysql_storage.go | 8 ++++---- 3 files changed, 14 insertions(+), 14 deletions(-) diff --git a/app/manager/douyin_fail_gift_record_mysql_storage.go b/app/manager/douyin_fail_gift_record_mysql_storage.go index db58a6b..9927143 100644 --- a/app/manager/douyin_fail_gift_record_mysql_storage.go +++ b/app/manager/douyin_fail_gift_record_mysql_storage.go @@ -185,8 +185,8 @@ func (grm *DouYinFailGiftRecordMysqlStorage) GetLastPageNumAndCountByLiveRoomId( log.Printf("No live room found with ID: %s", liveRoomID) return nil, err // 没有找到数据，返回 ErrNoRows } - log.Printf("Error querying live room: %v", err) // 打印其他错误信息 - return nil, err // 返回其他错误 + log.Printf("Error querying GetLastPageNumAndCountByLiveRoomId : %v", err) // 打印其他错误信息 + return nil, err // 返回其他错误 } // 执行 SQL 查询 diff --git a/app/manager/gift_record_mysql_storage.go b/app/manager/gift_record_mysql_storage.go index 416adab..66c415e 100644 --- a/app/manager/gift_record_mysql_storage.go +++ b/app/manager/gift_record_mysql_storage.go @@ -165,8 +165,8 @@ func (grm *GiftRecordMysqlStorage) GetLastGiftRecordByUserIdAndGiftId(liveRoomID log.Printf("No live room found with ID: %s", liveRoomID) return nil, err // 没有找到数据，返回 ErrNoRows } - log.Printf("Error querying live room: %v", err) // 打印其他错误信息 - return nil, err // 返回其他错误 + log.Printf("Error querying GetLastGiftRecordByUserIdAndGiftId : %v", err) // 打印其他错误信息 + return nil, err // 返回其他错误 } // 查询成功，返回结果 @@ -198,8 +198,8 @@ func (grm *GiftRecordMysqlStorage) GetGiftCountByUserAndGiftId(liveRoomID string log.Printf("No live room found with ID: %s", liveRoomID) return 0, err // 没有找到数据，返回 ErrNoRows } - log.Printf("Error querying live room: %v", err) // 打印其他错误信息 - return 0, err // 返回其他错误 + log.Printf("Error querying GetGiftCountByUserAndGiftId : %v", err) // 打印其他错误信息 + return 0, err // 返回其他错误 } // 查询成功，返回结果 @@ -227,8 +227,8 @@ func (grm *GiftRecordMysqlStorage) GetTotalScoreByRoomId(liveRoomID string, time log.Printf("No live room found with ID: %s", liveRoomID) return 0, err // 没有找到数据，返回 ErrNoRows } - log.Printf("Error querying live room: %v", err) // 打印其他错误信息 - return 0, err // 返回其他错误 + log.Printf("Error querying GetTotalScoreByRoomId : %v", err) // 打印其他错误信息 + return 0, err // 返回其他错误 } // 查询成功，返回结果 @@ -257,8 +257,8 @@ func (grm *GiftRecordMysqlStorage) GetAccScoreByRoomIdAndUserId(liveRoomID strin log.Printf("No live room found with ID: %s", liveRoomID) return 0, err // 没有找到数据，返回 ErrNoRows } - log.Printf("Error querying live room: %v", err) // 打印其他错误信息 - return 0, err // 返回其他错误 + log.Printf("Error querying GetAccScoreByRoomIdAndUserId : %v", err) // 打印其他错误信息 + return 0, err // 返回其他错误 } // 查询成功，返回结果 diff --git a/app/manager/live_room_mysql_storage.go b/app/manager/live_room_mysql_storage.go index 718e32b..7f55cc3 100644 --- a/app/manager/live_room_mysql_storage.go +++ b/app/manager/live_room_mysql_storage.go @@ -204,8 +204,8 @@ func (lrm *LiveRoomMysqlStorage) GetLiveRoom(liveRoomID string) (*LiveRoomMysqlI log.Printf("No live room found with ID: %s", liveRoomID) return nil, err // 没有找到数据，返回 ErrNoRows } - log.Printf("Error querying live room: %v", err) // 打印其他错误信息 - return nil, err // 返回其他错误 + log.Printf("Error querying GetLiveRoom: %v", err) // 打印其他错误信息 + return nil, err // 返回其他错误 } // 查询成功，返回结果 @@ -623,8 +623,8 @@ func (lrm *LiveRoomMysqlStorage) GetGameDate(liveRoomID string, times int) (*Gam log.Printf("No live room found with ID: %s", liveRoomID) return nil, err // 没有找到数据，返回 ErrNoRows } - log.Printf("Error querying live room: %v", err) // 打印其他错误信息 - return nil, err // 返回其他错误 + log.Printf("Error querying GetGameDate : %v", err) // 打印其他错误信息 + return nil, err // 返回其他错误 } // 查询成功，返回结果 -- Gitee From 18d158b6153a029e139d47e5e0b13d34e96517e5 Mon Sep 17 00:00:00 2001 From: udieudie Date: Sat, 14 Jun 2025 16:09:40 +0800 Subject: [PATCH 4/9] =?UTF-8?q?david/hotfix:=E5=A2=9E=E5=8A=A0=E9=94=99?= =?UTF-8?q?=E8=AF=AF=E6=97=A5=E5=BF=97=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/manager/gift_record_mysql_storage.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/app/manager/gift_record_mysql_storage.go b/app/manager/gift_record_mysql_storage.go index 66c415e..ad1c3f8 100644 --- a/app/manager/gift_record_mysql_storage.go +++ b/app/manager/gift_record_mysql_storage.go @@ -257,8 +257,9 @@ func (grm *GiftRecordMysqlStorage) GetAccScoreByRoomIdAndUserId(liveRoomID strin log.Printf("No live room found with ID: %s", liveRoomID) return 0, err // 没有找到数据，返回 ErrNoRows } - log.Printf("Error querying GetAccScoreByRoomIdAndUserId : %v", err) // 打印其他错误信息 - return 0, err // 返回其他错误 + log.Printf("Error querying GetAccScoreByRoomIdAndUserId : %v, liveRoomID : %s, times : %i, userId : %s", + err, liveRoomID, times, userId) // 打印其他错误信息 + return 0, err // 返回其他错误 } // 查询成功，返回结果 -- Gitee From 5efc3b97ee162b3ffbf03ced164856755c874a03 Mon Sep 17 00:00:00 2001 From: udieudie Date: Sat, 14 Jun 2025 16:15:42 +0800 Subject: [PATCH 5/9] david --- app/manager/gift_record_mysql_storage.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/app/manager/gift_record_mysql_storage.go b/app/manager/gift_record_mysql_storage.go index ad1c3f8..5e58582 100644 --- a/app/manager/gift_record_mysql_storage.go +++ b/app/manager/gift_record_mysql_storage.go @@ -227,8 +227,9 @@ func (grm *GiftRecordMysqlStorage) GetTotalScoreByRoomId(liveRoomID string, time log.Printf("No live room found with ID: %s", liveRoomID) return 0, err // 没有找到数据，返回 ErrNoRows } - log.Printf("Error querying GetTotalScoreByRoomId : %v", err) // 打印其他错误信息 - return 0, err // 返回其他错误 + log.Printf("Error querying GetTotalScoreByRoomId : %v, liveRoomID : %s, times : %i", + err, liveRoomID, times) // 打印其他错误信息 + return 0, err // 返回其他错误 } // 查询成功，返回结果 -- Gitee From d2b26326403d0dc6460447d894bf579a6c28bbc9 Mon Sep 17 00:00:00 2001 From: udieudie Date: Sat, 14 Jun 2025 16:18:15 +0800 Subject: [PATCH 6/9] =?UTF-8?q?david/hotfix:=E8=B0=83=E6=95=B4=E6=97=A5?= =?UTF-8?q?=E5=BF=97=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/manager/gift_record_mysql_storage.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/app/manager/gift_record_mysql_storage.go b/app/manager/gift_record_mysql_storage.go index 5e58582..4290691 100644 --- a/app/manager/gift_record_mysql_storage.go +++ b/app/manager/gift_record_mysql_storage.go @@ -227,9 +227,9 @@ func (grm *GiftRecordMysqlStorage) GetTotalScoreByRoomId(liveRoomID string, time log.Printf("No live room found with ID: %s", liveRoomID) return 0, err // 没有找到数据，返回 ErrNoRows } - log.Printf("Error querying GetTotalScoreByRoomId : %v, liveRoomID : %s, times : %i", + log.Printf("Error querying GetTotalScoreByRoomId : %v, liveRoomID : %s, times : %d", err, liveRoomID, times) // 打印其他错误信息 - return 0, err // 返回其他错误 + return 0, err // 返回其他错误 } // 查询成功，返回结果 @@ -258,9 +258,9 @@ func (grm *GiftRecordMysqlStorage) GetAccScoreByRoomIdAndUserId(liveRoomID strin log.Printf("No live room found with ID: %s", liveRoomID) return 0, err // 没有找到数据，返回 ErrNoRows } - log.Printf("Error querying GetAccScoreByRoomIdAndUserId : %v, liveRoomID : %s, times : %i, userId : %s", + log.Printf("Error querying GetAccScoreByRoomIdAndUserId : %v, liveRoomID : %s, times : %d, userId : %s", err, liveRoomID, times, userId) // 打印其他错误信息 - return 0, err // 返回其他错误 + return 0, err // 返回其他错误 } // 查询成功，返回结果 -- Gitee From 13d09937824cad1813317c8e82990a96299cd01f Mon Sep 17 00:00:00 2001 From: udieudie Date: Sat, 14 Jun 2025 16:24:17 +0800 Subject: [PATCH 7/9] =?UTF-8?q?david/hotfix:=E5=A2=9E=E5=8A=A0=E6=97=A5?= =?UTF-8?q?=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/controller/indexController.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/app/controller/indexController.go b/app/controller/indexController.go index 8cc7a47..4290390 100644 --- a/app/controller/indexController.go +++ b/app/controller/indexController.go @@ -153,9 +153,15 @@ func (i *IndexController) Regist(ctx *gin.Context) { i.returnGenTokenMsg(conn, loginToken, liveRoomUserInfo.RoomId) backDataByTime := ctx.Query("backDataByTime") + + fmt.Println("register backDataByTime backDataByTime : ", backDataByTime) + if !(backDataByTime == "") { + fmt.Println("register backDataByTime backDataByTime into if : ", backDataByTime) backDataByTimeI64, _ := strconv.ParseInt(backDataByTime, 10, 64) + fmt.Println("service.DealBackDataByTime : ", liveRoomInfo.LiveRoomId, liveRoomInfo.Times, backDataByTimeI64) + go service.DealBackDataByTime(conn, liveRoomInfo.LiveRoomId, liveRoomInfo.Times, backDataByTimeI64) } -- Gitee From 92b0d0fad4621fb1c828600554f7c4c710221996 Mon Sep 17 00:00:00 2001 From: udieudie Date: Sat, 14 Jun 2025 16:27:17 +0800 Subject: [PATCH 8/9] =?UTF-8?q?david/hotfix:=E6=97=A5=E5=BF=97=E4=BF=A1?= =?UTF-8?q?=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/controller/indexController.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/app/controller/indexController.go b/app/controller/indexController.go index 4290390..d2dd980 100644 --- a/app/controller/indexController.go +++ b/app/controller/indexController.go @@ -156,7 +156,7 @@ func (i *IndexController) Regist(ctx *gin.Context) { fmt.Println("register backDataByTime backDataByTime : ", backDataByTime) - if !(backDataByTime == "") { + if !(backDataByTime == "" || backDataByTime != "0") { fmt.Println("register backDataByTime backDataByTime into if : ", backDataByTime) backDataByTimeI64, _ := strconv.ParseInt(backDataByTime, 10, 64) -- Gitee From 5286b8f1c267d1e4a0df97a91aced01a68a0c85c Mon Sep 17 00:00:00 2001 From: udieudie Date: Sat, 14 Jun 2025 16:30:25 +0800 Subject: [PATCH 9/9] =?UTF-8?q?david/hotfix:=E6=97=A5=E5=BF=97=E4=BF=A1?= =?UTF-8?q?=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/controller/indexController.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/app/controller/indexController.go b/app/controller/indexController.go index d2dd980..0c5b425 100644 --- a/app/controller/indexController.go +++ b/app/controller/indexController.go @@ -156,7 +156,7 @@ func (i *IndexController) Regist(ctx *gin.Context) { fmt.Println("register backDataByTime backDataByTime : ", backDataByTime) - if !(backDataByTime == "" || backDataByTime != "0") { + if !(backDataByTime == "" || backDataByTime == "0") { fmt.Println("register backDataByTime backDataByTime into if : ", backDataByTime) backDataByTimeI64, _ := strconv.ParseInt(backDataByTime, 10, 64) -- Gitee