diff --git a/app/controller/indexController.go b/app/controller/indexController.go index 8cc7a47776d90b77c17523215229555a675ecb99..0c5b4250593586746f40338504ab20aeeb8efa86 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") - if !(backDataByTime == "") { + + fmt.Println("register backDataByTime backDataByTime : ", backDataByTime) + + if !(backDataByTime == "" || backDataByTime == "0") { + 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) } diff --git a/app/manager/douyin/dy_service_manager.go b/app/manager/douyin/dy_service_manager.go index 771b386f61f60cda9f1b41a820b000319c8b906b..07ff5550c714bb9536754ac2998737b6fb80915b 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 } @@ -305,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"` // 本局开始时间,秒级时间戳 @@ -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, " , 成功") diff --git a/app/manager/douyin_fail_gift_record_mysql_storage.go b/app/manager/douyin_fail_gift_record_mysql_storage.go index db58a6baa3b96ede680a53cc8800f075f9842733..99271434a1f2dd59c28fb057af1425674c81c9b1 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 416adab42de0d8067bc58e4916d459d95ed0d388..4290691174d94991ba886455900e225cf9b5fe6b 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,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 live room: %v", err) // 打印其他错误信息 - return 0, err // 返回其他错误 + log.Printf("Error querying GetTotalScoreByRoomId : %v, liveRoomID : %s, times : %d", + err, liveRoomID, times) // 打印其他错误信息 + return 0, err // 返回其他错误 } // 查询成功,返回结果 @@ -257,8 +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 live room: %v", err) // 打印其他错误信息 - return 0, err // 返回其他错误 + log.Printf("Error querying GetAccScoreByRoomIdAndUserId : %v, liveRoomID : %s, times : %d, userId : %s", + err, liveRoomID, times, userId) // 打印其他错误信息 + return 0, err // 返回其他错误 } // 查询成功,返回结果 diff --git a/app/manager/live_room_mysql_storage.go b/app/manager/live_room_mysql_storage.go index 718e32bb14946535760c77e0b2e80a479a77aaef..7f55cc3ed00ca61b727bee4953ebbf64d13dbfaa 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 // 返回其他错误 } // 查询成功,返回结果