From 814801ee04418d04a6d825f10d642fddc05d30bb Mon Sep 17 00:00:00 2001 From: qydysky <32743305+qydysky@users.noreply.github.com> Date: Thu, 31 Mar 2022 16:02:43 +0800 Subject: [PATCH] =?utf8?q?=E4=BB=A3=E7=A0=81fix?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- F/api.go | 1900 +++++++++++++++++++++++++++++------------------------- 1 file changed, 1012 insertions(+), 888 deletions(-) diff --git a/F/api.go b/F/api.go index ef0bd2c..c91a4d2 100644 --- a/F/api.go +++ b/F/api.go @@ -1,220 +1,222 @@ package F import ( - "time" - "os" - "strconv" - "strings" - "context" + "context" "encoding/json" "net/http" "net/url" + "os" + "strconv" + "strings" + "time" c "github.com/qydysky/bili_danmu/CV" J "github.com/qydysky/bili_danmu/Json" + "github.com/skratchdot/open-golang/open" p "github.com/qydysky/part" + funcCtrl "github.com/qydysky/part/funcCtrl" g "github.com/qydysky/part/get" - web "github.com/qydysky/part/web" - reqf "github.com/qydysky/part/reqf" limit "github.com/qydysky/part/limit" - funcCtrl "github.com/qydysky/part/funcCtrl" + reqf "github.com/qydysky/part/reqf" + web "github.com/qydysky/part/web" uuid "github.com/gofrs/uuid" - qr "github.com/skip2/go-qrcode" "github.com/mdp/qrterminal/v3" - "github.com/skratchdot/open-golang/open" + qr "github.com/skip2/go-qrcode" ) var apilog = c.Log.Base(`api`) -var api_limit = limit.New(1,2000,30000)//频率限制1次/2s，最大等待时间30s +var api_limit = limit.New(1, 2000, 30000) //频率限制1次/2s，最大等待时间30s func Get(key string) { apilog := apilog.Base_add(`Get`) - if api_limit.TO() {return}//超额请求阻塞，超时将取消 + if api_limit.TO() { + return + } //超额请求阻塞，超时将取消 - var api_can_get = map[string][]func()([]string){ - `Cookie`:[]func()([]string){//Cookie + var api_can_get = map[string][]func() []string{ + `Cookie`: { //Cookie Get_cookie, }, - `Uid`:[]func()([]string){//用戶uid + `Uid`: { //用戶uid GetUid, }, - `UpUid`:[]func()([]string){//主播uid + `UpUid`: { //主播uid getInfoByRoom, getRoomPlayInfo, Html, }, - `Live_Start_Time`:[]func()([]string){//直播开始时间 + `Live_Start_Time`: { //直播开始时间 getInfoByRoom, getRoomPlayInfo, Html, }, - `Liveing`:[]func()([]string){//是否在直播 + `Liveing`: { //是否在直播 getInfoByRoom, getRoomPlayInfo, Html, }, - `Title`:[]func()([]string){//直播间标题 + `Title`: { //直播间标题 getInfoByRoom, Html, }, - `Uname`:[]func()([]string){//主播名 + `Uname`: { //主播名 getInfoByRoom, Html, }, - `ParentAreaID`:[]func()([]string){//分区 + `ParentAreaID`: { //分区 getInfoByRoom, Html, }, - `AreaID`:[]func()([]string){//子分区 + `AreaID`: { //子分区 getInfoByRoom, Html, }, - `Roomid`:[]func()([]string){//房间id + `Roomid`: { //房间id missRoomId, }, - `GuardNum`:[]func()([]string){//舰长数 + `GuardNum`: { //舰长数 Get_guardNum, getInfoByRoom, getRoomPlayInfo, Html, }, - `Note`:[]func()([]string){//分区排行 + `Note`: { //分区排行 Get_HotRank, getInfoByRoom, Html, }, - `Locked`:[]func()([]string){//直播间是否被封禁 + `Locked`: { //直播间是否被封禁 getInfoByRoom, Html, }, - `Live_qn`:[]func()([]string){//当前直播流质量 + `Live_qn`: { //当前直播流质量 getRoomPlayInfo, Html, }, - `AcceptQn`:[]func()([]string){//允许的清晰度 + `AcceptQn`: { //允许的清晰度 getRoomPlayInfo, Html, }, - `Live`:[]func()([]string){//直播流链接 + `Live`: { //直播流链接 getRoomPlayInfoByQn, getRoomPlayInfo, Html, }, - `Token`:[]func()([]string){//弹幕钥 + `Token`: { //弹幕钥 getDanmuInfo, }, - `WSURL`:[]func()([]string){//弹幕链接 + `WSURL`: { //弹幕链接 getDanmuInfo, }, // `VERSION`:[]func()([]string){//客户版本 不再需要 // Get_Version, // }, - `LIVE_BUVID`:[]func()([]string){//LIVE_BUVID + `LIVE_BUVID`: { //LIVE_BUVID Get_LIVE_BUVID, }, - `Silver_2_coin`:[]func()([]string){//银瓜子2硬币 + `Silver_2_coin`: { //银瓜子2硬币 Silver_2_coin, }, - `CheckSwitch_FansMedal`:[]func()([]string){//切换粉丝牌 + `CheckSwitch_FansMedal`: { //切换粉丝牌 CheckSwitch_FansMedal, }, } - var check = map[string]func()(bool){ - `Uid`:func()(bool){//用戶uid + var check = map[string]func() bool{ + `Uid`: func() bool { //用戶uid return c.Uid != 0 }, - `UpUid`:func()(bool){//主播uid + `UpUid`: func() bool { //主播uid return c.UpUid != 0 }, - `Live_Start_Time`:func()(bool){//直播开始时间 + `Live_Start_Time`: func() bool { //直播开始时间 return c.Live_Start_Time != time.Time{} }, - `Liveing`:func()(bool){//是否在直播 + `Liveing`: func() bool { //是否在直播 return true }, - `Title`:func()(bool){//直播间标题 + `Title`: func() bool { //直播间标题 return c.Title != `` }, - `Uname`:func()(bool){//主播名 + `Uname`: func() bool { //主播名 return c.Uname != `` }, - `ParentAreaID`:func()(bool){//分区 + `ParentAreaID`: func() bool { //分区 return c.ParentAreaID != 0 }, - `AreaID`:func()(bool){//子分区 + `AreaID`: func() bool { //子分区 return c.AreaID != 0 }, - `Roomid`:func()(bool){//房间id + `Roomid`: func() bool { //房间id return c.Roomid != 0 }, - `GuardNum`:func()(bool){//舰长数 + `GuardNum`: func() bool { //舰长数 return c.GuardNum != 0 }, - `Note`:func()(bool){//分区排行 + `Note`: func() bool { //分区排行 return c.Note != `` }, - `Locked`:func()(bool){//直播间是否被封禁 + `Locked`: func() bool { //直播间是否被封禁 return true }, - `Live_qn`:func()(bool){//当前直播流质量 + `Live_qn`: func() bool { //当前直播流质量 return c.Live_qn != 0 }, - `AcceptQn`:func()(bool){//允许的清晰度 + `AcceptQn`: func() bool { //允许的清晰度 return len(c.AcceptQn) != 0 }, - `Live`:func()(bool){//直播流链接 + `Live`: func() bool { //直播流链接 return len(c.Live) != 0 }, - `Token`:func()(bool){//弹幕钥 + `Token`: func() bool { //弹幕钥 return c.Token != `` }, - `WSURL`:func()(bool){//弹幕链接 + `WSURL`: func() bool { //弹幕链接 return len(c.WSURL) != 0 }, // `VERSION`:func()(bool){//客户版本 不再需要 // return c.VERSION != `2.0.11` // }, - `LIVE_BUVID`:func()(bool){//LIVE_BUVID + `LIVE_BUVID`: func() bool { //LIVE_BUVID return c.LIVE_BUVID }, - `Silver_2_coin`:func()(bool){//银瓜子2硬币 + `Silver_2_coin`: func() bool { //银瓜子2硬币 return true }, - `CheckSwitch_FansMedal`:func()(bool){//切换粉丝牌 + `CheckSwitch_FansMedal`: func() bool { //切换粉丝牌 return true }, - `Cookie`:func()(bool){//Cookie + `Cookie`: func() bool { //Cookie return true }, } - if fList,ok := api_can_get[key];ok{ - for _,fItem := range fList{ + if fList, ok := api_can_get[key]; ok { + for _, fItem := range fList { apilog.L(`T: `, `Get`, key) missKey := fItem() if len(missKey) > 0 { - apilog.L(`T: `,`missKey when get`,key,missKey) - for _,misskeyitem := range missKey{ - if checkf,ok := check[misskeyitem];ok && checkf() { + apilog.L(`T: `, `missKey when get`, key, missKey) + for _, misskeyitem := range missKey { + if checkf, ok := check[misskeyitem]; ok && checkf() { continue } if misskeyitem == key { - apilog.L(`W: `,`missKey equrt key`,key,missKey) + apilog.L(`W: `, `missKey equrt key`, key, missKey) continue } Get(misskeyitem) } missKey := fItem() if len(missKey) > 0 { - apilog.L(`W: `,`missKey when get`,key,missKey) + apilog.L(`W: `, `missKey when get`, key, missKey) continue } } - if checkf,ok := check[key];ok && checkf() { + if checkf, ok := check[key]; ok && checkf() { break } } @@ -222,9 +224,9 @@ func Get(key string) { } func GetUid() (missKey []string) { - if uid,ok := c.Cookie.LoadV(`DedeUserID`).(string);!ok{//cookie中无DedeUserID + if uid, ok := c.Cookie.LoadV(`DedeUserID`).(string); !ok { //cookie中无DedeUserID missKey = append(missKey, `Cookie`) - } else if uid,e := strconv.Atoi(uid);e != nil{ + } else if uid, e := strconv.Atoi(uid); e != nil { missKey = append(missKey, `Cookie`) } else { c.Uid = uid @@ -234,24 +236,26 @@ func GetUid() (missKey []string) { func Info(UpUid int) (info J.Info) { apilog := apilog.Base_add(`Info`) - if api_limit.TO() {return}//超额请求阻塞，超时将取消 + if api_limit.TO() { + return + } //超额请求阻塞，超时将取消 //html { req := reqf.New() if err := req.Reqf(reqf.Rval{ - Url:`https://api.bilibili.com/x/space/acc/info?mid=`+strconv.Itoa(UpUid)+`&jsonp=jsonp`, - Proxy:c.Proxy, - Timeout:10*1000, - Retry:2, - });err != nil { - apilog.L(`E: `,err) + Url: `https://api.bilibili.com/x/space/acc/info?mid=` + strconv.Itoa(UpUid) + `&jsonp=jsonp`, + Proxy: c.Proxy, + Timeout: 10 * 1000, + Retry: 2, + }); err != nil { + apilog.L(`E: `, err) return } //Info { - if e := json.Unmarshal(req.Respon,&info);e != nil{ + if e := json.Unmarshal(req.Respon, &info); e != nil { apilog.L(`E: `, e) return } else if info.Code != 0 { @@ -272,32 +276,32 @@ func Html() (missKey []string) { } Roomid := strconv.Itoa(c.Roomid) - + //html { r := g.Get(reqf.Rval{ - Url:"https://live.bilibili.com/" + Roomid, - Proxy:c.Proxy, + Url: "https://live.bilibili.com/" + Roomid, + Proxy: c.Proxy, }) - if tmp := r.S(``, 0, 0);tmp.Err != nil { + if tmp := r.S(``, 0, 0); tmp.Err != nil { apilog.L(`E: `, `不存在`) } else { s := tmp.RS[0] //Roominitres { - var j struct{ - Roominitres J.Roominitres `json:"roomInitRes"` + var j struct { + Roominitres J.Roominitres `json:"roomInitRes"` } - if e := json.Unmarshal([]byte(s),&j);e != nil{ + if e := json.Unmarshal([]byte(s), &j); e != nil { apilog.L(`E: `, e) return } else if j.Roominitres.Code != 0 { apilog.L(`E: `, j.Roominitres.Message) return } - + //主播uid c.UpUid = j.Roominitres.Data.UID //房间号（完整） @@ -305,10 +309,10 @@ func Html() (missKey []string) { c.Roomid = j.Roominitres.Data.RoomID } //直播开始时间 - c.Live_Start_Time = time.Unix(int64(j.Roominitres.Data.LiveTime),0) + c.Live_Start_Time = time.Unix(int64(j.Roominitres.Data.LiveTime), 0) //是否在直播 c.Liveing = j.Roominitres.Data.LiveStatus == 1 - + //未在直播，不获取直播流 if !c.Liveing { c.Live_qn = 0 @@ -321,50 +325,58 @@ func Html() (missKey []string) { { type Stream_name struct { Protocol_name string - Format_name string - Codec_name string + Format_name string + Codec_name string } var name_map = map[string]Stream_name{ - `flv`: Stream_name{ - Protocol_name:"http_stream", - Format_name:"flv", - Codec_name:"avc", + `flv`: { + Protocol_name: "http_stream", + Format_name: "flv", + Codec_name: "avc", }, - `hls`: Stream_name{ - Protocol_name:"http_hls", - Format_name:"fmp4", - Codec_name:"avc", + `hls`: { + Protocol_name: "http_hls", + Format_name: "fmp4", + Codec_name: "avc", }, } - + want_type := name_map[`hls`] - if v,ok := c.K_v.LoadV(`直播流类型`).(string);ok { - if v,ok := name_map[v];ok { + if v, ok := c.K_v.LoadV(`直播流类型`).(string); ok { + if v, ok := name_map[v]; ok { want_type = v } else { - apilog.L(`I: `, `未找到`,v,`,默认hls`) + apilog.L(`I: `, `未找到`, v, `,默认hls`) } } else { apilog.L(`T: `, `默认flv`) } - - for _,v := range j.Roominitres.Data.PlayurlInfo.Playurl.Stream { - if v.ProtocolName != want_type.Protocol_name {continue} - - for _,v := range v.Format { - if v.FormatName != want_type.Format_name {continue} - - for _,v := range v.Codec { - if v.CodecName != want_type.Codec_name {continue} - + + for _, v := range j.Roominitres.Data.PlayurlInfo.Playurl.Stream { + if v.ProtocolName != want_type.Protocol_name { + continue + } + + for _, v := range v.Format { + if v.FormatName != want_type.Format_name { + continue + } + + for _, v := range v.Codec { + if v.CodecName != want_type.Codec_name { + continue + } + //当前直播流质量 c.Live_qn = v.CurrentQn - if c.Live_want_qn == 0 {c.Live_want_qn = v.CurrentQn} + if c.Live_want_qn == 0 { + c.Live_want_qn = v.CurrentQn + } //允许的清晰度 { var tmp = make(map[int]string) - for _,v := range v.AcceptQn { - if s,ok := c.Qn[v];ok{ + for _, v := range v.AcceptQn { + if s, ok := c.Qn[v]; ok { tmp[v] = s } } @@ -372,7 +384,7 @@ func Html() (missKey []string) { } //直播流链接 c.Live = []string{} - for _,v1 := range v.URLInfo { + for _, v1 := range v.URLInfo { c.Live = append(c.Live, v1.Host+v.BaseURL+v1.Extra) } } @@ -383,11 +395,11 @@ func Html() (missKey []string) { //Roominfores { - var j struct{ + var j struct { Roominfores J.Roominfores `json:"roomInitRes"` } - if e := json.Unmarshal([]byte(s),&j);e != nil{ + if e := json.Unmarshal([]byte(s), &j); e != nil { apilog.L(`E: `, e) return } else if j.Roominfores.Code != 0 { @@ -407,14 +419,14 @@ func Html() (missKey []string) { c.GuardNum = j.Roominfores.Data.GuardInfo.Count //分区排行 c.Note = j.Roominfores.Data.HotRankInfo.AreaName - if rank := j.Roominfores.Data.HotRankInfo.Rank;rank > 50 || rank == 0 { + if rank := j.Roominfores.Data.HotRankInfo.Rank; rank > 50 || rank == 0 { c.Note += "50+" } else { c.Note += strconv.Itoa(rank) } //直播间是否被封禁 - if j.Roominfores.Data.RoomInfo.LockStatus == 1{ - apilog.L(`W: `,"直播间封禁中") + if j.Roominfores.Data.RoomInfo.LockStatus == 1 { + apilog.L(`W: `, "直播间封禁中") c.Locked = true return } @@ -425,7 +437,7 @@ func Html() (missKey []string) { } func missRoomId() (missKey []string) { - apilog.Base_add(`missRoomId`).L(`E: `,`missRoomId`) + apilog.Base_add(`missRoomId`).L(`E: `, `missRoomId`) return } @@ -439,18 +451,18 @@ func getInfoByRoom() (missKey []string) { Roomid := strconv.Itoa(c.Roomid) - {//使用其他api + { //使用其他api req := reqf.New() if err := req.Reqf(reqf.Rval{ - Url:"https://api.live.bilibili.com/xlive/web-room/v1/index/getInfoByRoom?room_id=" + Roomid, - Header:map[string]string{ - `Referer`:"https://live.bilibili.com/" + Roomid, + Url: "https://api.live.bilibili.com/xlive/web-room/v1/index/getInfoByRoom?room_id=" + Roomid, + Header: map[string]string{ + `Referer`: "https://live.bilibili.com/" + Roomid, }, - Proxy:c.Proxy, - Timeout:10*1000, - Retry:2, - });err != nil { - apilog.L(`E: `,err) + Proxy: c.Proxy, + Timeout: 10 * 1000, + Retry: 2, + }); err != nil { + apilog.L(`E: `, err) return } @@ -458,7 +470,7 @@ func getInfoByRoom() (missKey []string) { { var j J.Roominfores - if e := json.Unmarshal(req.Respon,&j);e != nil{ + if e := json.Unmarshal(req.Respon, &j); e != nil { apilog.L(`E: `, e) return } else if j.Code != 0 { @@ -467,7 +479,7 @@ func getInfoByRoom() (missKey []string) { } //直播开始时间 - c.Live_Start_Time = time.Unix(int64(j.Data.RoomInfo.LiveStartTime),0) + c.Live_Start_Time = time.Unix(int64(j.Data.RoomInfo.LiveStartTime), 0) //是否在直播 c.Liveing = j.Data.RoomInfo.LiveStatus == 1 //直播间标题 @@ -488,14 +500,14 @@ func getInfoByRoom() (missKey []string) { c.GuardNum = j.Data.GuardInfo.Count //分区排行 c.Note = j.Data.HotRankInfo.AreaName - if rank := j.Data.HotRankInfo.Rank;rank > 50 || rank == 0 { + if rank := j.Data.HotRankInfo.Rank; rank > 50 || rank == 0 { c.Note += "50+" } else { c.Note += strconv.Itoa(rank) } //直播间是否被封禁 - if j.Data.RoomInfo.LockStatus == 1{ - apilog.L(`W: `,"直播间封禁中") + if j.Data.RoomInfo.LockStatus == 1 { + apilog.L(`W: `, "直播间封禁中") c.Locked = true return } @@ -513,36 +525,38 @@ func getRoomPlayInfo() (missKey []string) { if !c.LIVE_BUVID { missKey = append(missKey, `LIVE_BUVID`) } - if len(missKey) > 0 {return} - + if len(missKey) > 0 { + return + } + Roomid := strconv.Itoa(c.Roomid) - + //Roominitres { Cookie := make(map[string]string) - c.Cookie.Range(func(k,v interface{})(bool){ + c.Cookie.Range(func(k, v interface{}) bool { Cookie[k.(string)] = v.(string) return true }) req := reqf.New() if err := req.Reqf(reqf.Rval{ - Url:"https://api.live.bilibili.com/xlive/web-room/v2/index/getRoomPlayInfo?no_playurl=0&mask=1&qn=0&platform=web&protocol=0,1&format=0,2&codec=0,1&room_id=" + Roomid, - Header:map[string]string{ - `Referer`:"https://live.bilibili.com/" + Roomid, - `Cookie`:reqf.Map_2_Cookies_String(Cookie), + Url: "https://api.live.bilibili.com/xlive/web-room/v2/index/getRoomPlayInfo?no_playurl=0&mask=1&qn=0&platform=web&protocol=0,1&format=0,2&codec=0,1&room_id=" + Roomid, + Header: map[string]string{ + `Referer`: "https://live.bilibili.com/" + Roomid, + `Cookie`: reqf.Map_2_Cookies_String(Cookie), }, - Proxy:c.Proxy, - Timeout:10*1000, - Retry:2, - });err != nil { - apilog.L(`E: `,err) + Proxy: c.Proxy, + Timeout: 10 * 1000, + Retry: 2, + }); err != nil { + apilog.L(`E: `, err) return } var j J.Roominitres - if e := json.Unmarshal([]byte(req.Respon),&j);e != nil{ + if e := json.Unmarshal([]byte(req.Respon), &j); e != nil { apilog.L(`E: `, e) return } else if j.Code != 0 { @@ -553,14 +567,14 @@ func getRoomPlayInfo() (missKey []string) { //主播uid c.UpUid = j.Data.UID //房间号（完整） - if j.Data.RoomID != 0{ + if j.Data.RoomID != 0 { c.Roomid = j.Data.RoomID } //直播开始时间 - c.Live_Start_Time = time.Unix(int64(j.Data.LiveTime),0) + c.Live_Start_Time = time.Unix(int64(j.Data.LiveTime), 0) //是否在直播 c.Liveing = j.Data.LiveStatus == 1 - + //未在直播，不获取直播流 if !c.Liveing { c.Live_qn = 0 @@ -573,51 +587,59 @@ func getRoomPlayInfo() (missKey []string) { { type Stream_name struct { Protocol_name string - Format_name string - Codec_name string + Format_name string + Codec_name string } var name_map = map[string]Stream_name{ - `flv`: Stream_name{ - Protocol_name:"http_stream", - Format_name:"flv", - Codec_name:"avc", + `flv`: { + Protocol_name: "http_stream", + Format_name: "flv", + Codec_name: "avc", }, - `hls`: Stream_name{ - Protocol_name:"http_hls", - Format_name:"fmp4", - Codec_name:"avc", + `hls`: { + Protocol_name: "http_hls", + Format_name: "fmp4", + Codec_name: "avc", }, } - + want_type := name_map[`hls`] - if v,ok := c.K_v.LoadV(`直播流类型`).(string);ok { - if v,ok := name_map[v];ok { + if v, ok := c.K_v.LoadV(`直播流类型`).(string); ok { + if v, ok := name_map[v]; ok { want_type = v } else { - apilog.L(`I: `, `未找到`,v,`,默认hls`) + apilog.L(`I: `, `未找到`, v, `,默认hls`) } } else { apilog.L(`T: `, `默认hls`) } no_found_type := true for { - for _,v := range j.Data.PlayurlInfo.Playurl.Stream { - if v.ProtocolName != want_type.Protocol_name {continue} - - for _,v := range v.Format { - if v.FormatName != want_type.Format_name {continue} - - for _,v := range v.Codec { - if v.CodecName != want_type.Codec_name {continue} - + for _, v := range j.Data.PlayurlInfo.Playurl.Stream { + if v.ProtocolName != want_type.Protocol_name { + continue + } + + for _, v := range v.Format { + if v.FormatName != want_type.Format_name { + continue + } + + for _, v := range v.Codec { + if v.CodecName != want_type.Codec_name { + continue + } + //当前直播流质量 c.Live_qn = v.CurrentQn - if c.Live_want_qn == 0 {c.Live_want_qn = v.CurrentQn} + if c.Live_want_qn == 0 { + c.Live_want_qn = v.CurrentQn + } //允许的清晰度 { var tmp = make(map[int]string) - for _,v := range v.AcceptQn { - if s,ok := c.Qn[v];ok{ + for _, v := range v.AcceptQn { + if s, ok := c.Qn[v]; ok { tmp[v] = s } } @@ -625,7 +647,7 @@ func getRoomPlayInfo() (missKey []string) { } //直播流链接 c.Live = []string{} - for _,v1 := range v.URLInfo { + for _, v1 := range v.URLInfo { c.Live = append(c.Live, v1.Host+v.BaseURL+v1.Extra) } } @@ -658,53 +680,57 @@ func getRoomPlayInfoByQn() (missKey []string) { if !c.LIVE_BUVID { missKey = append(missKey, `LIVE_BUVID`) } - if len(missKey) > 0 {return} + if len(missKey) > 0 { + return + } { AcceptQn := []int{} - for k,_ := range c.AcceptQn { - if k <= c.Live_want_qn {AcceptQn = append(AcceptQn, k)} + for k, _ := range c.AcceptQn { + if k <= c.Live_want_qn { + AcceptQn = append(AcceptQn, k) + } } MaxQn := 0 - for i:=0; len(AcceptQn)>i; i+=1{ + for i := 0; len(AcceptQn) > i; i += 1 { if AcceptQn[i] > MaxQn { MaxQn = AcceptQn[i] } } if MaxQn == 0 { - apilog.L(`W: `,"使用默认") + apilog.L(`W: `, "使用默认") } c.Live_qn = MaxQn } - + Roomid := strconv.Itoa(c.Roomid) - + //Roominitres { Cookie := make(map[string]string) - c.Cookie.Range(func(k,v interface{})(bool){ + c.Cookie.Range(func(k, v interface{}) bool { Cookie[k.(string)] = v.(string) return true }) req := reqf.New() if err := req.Reqf(reqf.Rval{ - Url:"https://api.live.bilibili.com/xlive/web-room/v2/index/getRoomPlayInfo?no_playurl=0&mask=1&qn="+ strconv.Itoa(c.Live_qn) +"&platform=web&protocol=0,1&format=0,2&codec=0,1&room_id=" + Roomid, - Header:map[string]string{ - `Referer`:"https://live.bilibili.com/" + Roomid, - `Cookie`:reqf.Map_2_Cookies_String(Cookie), + Url: "https://api.live.bilibili.com/xlive/web-room/v2/index/getRoomPlayInfo?no_playurl=0&mask=1&qn=" + strconv.Itoa(c.Live_qn) + "&platform=web&protocol=0,1&format=0,2&codec=0,1&room_id=" + Roomid, + Header: map[string]string{ + `Referer`: "https://live.bilibili.com/" + Roomid, + `Cookie`: reqf.Map_2_Cookies_String(Cookie), }, - Proxy:c.Proxy, - Timeout:10*1000, - Retry:2, - });err != nil { - apilog.L(`E: `,err) + Proxy: c.Proxy, + Timeout: 10 * 1000, + Retry: 2, + }); err != nil { + apilog.L(`E: `, err) return } var j J.Roominitres - if e := json.Unmarshal([]byte(req.Respon),&j);e != nil{ + if e := json.Unmarshal([]byte(req.Respon), &j); e != nil { apilog.L(`E: `, e) return } else if j.Code != 0 { @@ -715,14 +741,14 @@ func getRoomPlayInfoByQn() (missKey []string) { //主播uid c.UpUid = j.Data.UID //房间号（完整） - if j.Data.RoomID != 0{ + if j.Data.RoomID != 0 { c.Roomid = j.Data.RoomID } //直播开始时间 - c.Live_Start_Time = time.Unix(int64(j.Data.LiveTime),0) + c.Live_Start_Time = time.Unix(int64(j.Data.LiveTime), 0) //是否在直播 c.Liveing = j.Data.LiveStatus == 1 - + //未在直播，不获取直播流 if !c.Liveing { c.Live_qn = 0 @@ -735,54 +761,62 @@ func getRoomPlayInfoByQn() (missKey []string) { { type Stream_name struct { Protocol_name string - Format_name string - Codec_name string + Format_name string + Codec_name string } var name_map = map[string]Stream_name{ - `flv`: Stream_name{ - Protocol_name:"http_stream", - Format_name:"flv", - Codec_name:"avc", + `flv`: { + Protocol_name: "http_stream", + Format_name: "flv", + Codec_name: "avc", }, - `hls`: Stream_name{ - Protocol_name:"http_hls", - Format_name:"fmp4", - Codec_name:"avc", + `hls`: { + Protocol_name: "http_hls", + Format_name: "fmp4", + Codec_name: "avc", }, } - + want_type := name_map[`hls`] - if v,ok := c.K_v.LoadV(`直播流类型`).(string);ok { - if v,ok := name_map[v];ok { + if v, ok := c.K_v.LoadV(`直播流类型`).(string); ok { + if v, ok := name_map[v]; ok { want_type = v } else { - apilog.L(`I: `, `未找到`,v,`,默认hls`) + apilog.L(`I: `, `未找到`, v, `,默认hls`) } } else { apilog.L(`T: `, `默认hls`) } - + no_found_type := true for { - for _,v := range j.Data.PlayurlInfo.Playurl.Stream { - if v.ProtocolName != want_type.Protocol_name {continue} - - for _,v := range v.Format { - if v.FormatName != want_type.Format_name {continue} - - for _,v := range v.Codec { - if v.CodecName != want_type.Codec_name {continue} - + for _, v := range j.Data.PlayurlInfo.Playurl.Stream { + if v.ProtocolName != want_type.Protocol_name { + continue + } + + for _, v := range v.Format { + if v.FormatName != want_type.Format_name { + continue + } + + for _, v := range v.Codec { + if v.CodecName != want_type.Codec_name { + continue + } + no_found_type = false - + //当前直播流质量 c.Live_qn = v.CurrentQn - if c.Live_want_qn == 0 {c.Live_want_qn = v.CurrentQn} + if c.Live_want_qn == 0 { + c.Live_want_qn = v.CurrentQn + } //允许的清晰度 { var tmp = make(map[int]string) - for _,v := range v.AcceptQn { - if s,ok := c.Qn[v];ok{ + for _, v := range v.AcceptQn { + if s, ok := c.Qn[v]; ok { tmp[v] = s } } @@ -790,7 +824,7 @@ func getRoomPlayInfoByQn() (missKey []string) { } //直播流链接 c.Live = []string{} - for _,v1 := range v.URLInfo { + for _, v1 := range v.URLInfo { c.Live = append(c.Live, v1.Host+v.BaseURL+v1.Extra) } } @@ -809,7 +843,7 @@ func getRoomPlayInfoByQn() (missKey []string) { break } } - if s,ok := c.Qn[c.Live_qn];!ok{ + if s, ok := c.Qn[c.Live_qn]; !ok { apilog.L(`W: `, `未知清晰度`, c.Live_qn) } else { apilog.L(`I: `, s) @@ -828,86 +862,92 @@ func getDanmuInfo() (missKey []string) { if !c.LIVE_BUVID { missKey = append(missKey, `LIVE_BUVID`) } - if len(missKey) > 0 {return} + if len(missKey) > 0 { + return + } Roomid := strconv.Itoa(c.Roomid) - + //GetDanmuInfo { Cookie := make(map[string]string) - c.Cookie.Range(func(k,v interface{})(bool){ + c.Cookie.Range(func(k, v interface{}) bool { Cookie[k.(string)] = v.(string) return true }) req := reqf.New() if err := req.Reqf(reqf.Rval{ - Url:"https://api.live.bilibili.com/xlive/web-room/v1/index/getDanmuInfo?type=0&id=" + Roomid, - Header:map[string]string{ - `Referer`:"https://live.bilibili.com/" + Roomid, - `Cookie`:reqf.Map_2_Cookies_String(Cookie), + Url: "https://api.live.bilibili.com/xlive/web-room/v1/index/getDanmuInfo?type=0&id=" + Roomid, + Header: map[string]string{ + `Referer`: "https://live.bilibili.com/" + Roomid, + `Cookie`: reqf.Map_2_Cookies_String(Cookie), }, - Proxy:c.Proxy, - Timeout:10*1000, - });err != nil { - apilog.L(`E: `,err) + Proxy: c.Proxy, + Timeout: 10 * 1000, + }); err != nil { + apilog.L(`E: `, err) return } var j J.GetDanmuInfo - if e := json.Unmarshal([]byte(req.Respon),&j);e != nil{ + if e := json.Unmarshal([]byte(req.Respon), &j); e != nil { apilog.L(`E: `, e) return } else if j.Code != 0 { apilog.L(`E: `, j.Message) return } - + //弹幕钥 c.Token = j.Data.Token //弹幕链接 - for _,v := range j.Data.HostList { - c.WSURL = append(c.WSURL, "wss://" + v.Host + "/sub") + for _, v := range j.Data.HostList { + c.WSURL = append(c.WSURL, "wss://"+v.Host+"/sub") } } return } -func Get_face_src(uid string) (string) { - if uid == "" {return ""} - if api_limit.TO() {return ""}//超额请求阻塞，超时将取消 +func Get_face_src(uid string) string { + if uid == "" { + return "" + } + if api_limit.TO() { + return "" + } //超额请求阻塞，超时将取消 apilog := apilog.Base_add(`获取头像`) - + Cookie := make(map[string]string) - c.Cookie.Range(func(k,v interface{})(bool){ + c.Cookie.Range(func(k, v interface{}) bool { Cookie[k.(string)] = v.(string) return true }) req := reqf.New() if err := req.Reqf(reqf.Rval{ - Url:"https://api.live.bilibili.com/xlive/web-room/v1/index/getDanmuMedalAnchorInfo?ruid=" + uid, - Header:map[string]string{ - `Referer`:"https://live.bilibili.com/" + strconv.Itoa(c.Roomid), - `Cookie`:reqf.Map_2_Cookies_String(Cookie), + Url: "https://api.live.bilibili.com/xlive/web-room/v1/index/getDanmuMedalAnchorInfo?ruid=" + uid, + Header: map[string]string{ + `Referer`: "https://live.bilibili.com/" + strconv.Itoa(c.Roomid), + `Cookie`: reqf.Map_2_Cookies_String(Cookie), }, - Proxy:c.Proxy, - Timeout:10*1000, - Retry:2, - });err != nil { - apilog.L(`E: `,err) + Proxy: c.Proxy, + Timeout: 10 * 1000, + Retry: 2, + }); err != nil { + apilog.L(`E: `, err) return "" } res := string(req.Respon) - if msg := p.Json().GetValFromS(res, "message");msg == nil || msg != "0" { - apilog.L(`E: `,"message", msg) + if msg := p.Json().GetValFromS(res, "message"); msg == nil || msg != "0" { + apilog.L(`E: `, "message", msg) return "" } rface := p.Json().GetValFromS(res, "data.rface") if rface == nil { - apilog.L(`E: `,"data.rface", rface) + apilog.L(`E: `, "data.rface", rface) return "" } return rface.(string) + `@58w_58h` @@ -928,45 +968,47 @@ func Get_HotRank() (missKey []string) { if !c.LIVE_BUVID { missKey = append(missKey, `LIVE_BUVID`) } - if len(missKey) > 0 {return} + if len(missKey) > 0 { + return + } Roomid := strconv.Itoa(c.Roomid) - + //getHotRank { Cookie := make(map[string]string) - c.Cookie.Range(func(k,v interface{})(bool){ + c.Cookie.Range(func(k, v interface{}) bool { Cookie[k.(string)] = v.(string) return true }) req := reqf.New() if err := req.Reqf(reqf.Rval{ - Url:`https://api.live.bilibili.com/xlive/general-interface/v1/rank/getHotRank?ruid=`+strconv.Itoa(c.UpUid)+`&room_id=`+Roomid+`&is_pre=0&page_size=50&source=2&area_id=`+strconv.Itoa(c.ParentAreaID), - Header:map[string]string{ - `Host`: `api.live.bilibili.com`, - `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, - `Accept`: `application/json, text/plain, */*`, + Url: `https://api.live.bilibili.com/xlive/general-interface/v1/rank/getHotRank?ruid=` + strconv.Itoa(c.UpUid) + `&room_id=` + Roomid + `&is_pre=0&page_size=50&source=2&area_id=` + strconv.Itoa(c.ParentAreaID), + Header: map[string]string{ + `Host`: `api.live.bilibili.com`, + `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, + `Accept`: `application/json, text/plain, */*`, `Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`, `Accept-Encoding`: `gzip, deflate, br`, - `Origin`: `https://live.bilibili.com`, - `Connection`: `keep-alive`, - `Pragma`: `no-cache`, - `Cache-Control`: `no-cache`, - `Referer`:"https://live.bilibili.com/" + Roomid, - `Cookie`:reqf.Map_2_Cookies_String(Cookie), + `Origin`: `https://live.bilibili.com`, + `Connection`: `keep-alive`, + `Pragma`: `no-cache`, + `Cache-Control`: `no-cache`, + `Referer`: "https://live.bilibili.com/" + Roomid, + `Cookie`: reqf.Map_2_Cookies_String(Cookie), }, - Proxy:c.Proxy, - Timeout:3*1000, - Retry:2, - });err != nil { - apilog.L(`E: `,err) + Proxy: c.Proxy, + Timeout: 3 * 1000, + Retry: 2, + }); err != nil { + apilog.L(`E: `, err) return } var j J.GetHotRank - if e := json.Unmarshal([]byte(req.Respon),&j);e != nil{ + if e := json.Unmarshal([]byte(req.Respon), &j); e != nil { apilog.L(`E: `, e) return } else if j.Code != 0 { @@ -998,45 +1040,47 @@ func Get_guardNum() (missKey []string) { if !c.LIVE_BUVID { missKey = append(missKey, `LIVE_BUVID`) } - if len(missKey) > 0 {return} + if len(missKey) > 0 { + return + } Roomid := strconv.Itoa(c.Roomid) - + //Get_guardNum { Cookie := make(map[string]string) - c.Cookie.Range(func(k,v interface{})(bool){ + c.Cookie.Range(func(k, v interface{}) bool { Cookie[k.(string)] = v.(string) return true }) req := reqf.New() if err := req.Reqf(reqf.Rval{ - Url:`https://api.live.bilibili.com/xlive/app-room/v2/guardTab/topList?roomid=`+Roomid+`&page=1&ruid=`+strconv.Itoa(c.UpUid)+`&page_size=29`, - Header:map[string]string{ - `Host`: `api.live.bilibili.com`, - `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, - `Accept`: `application/json, text/plain, */*`, + Url: `https://api.live.bilibili.com/xlive/app-room/v2/guardTab/topList?roomid=` + Roomid + `&page=1&ruid=` + strconv.Itoa(c.UpUid) + `&page_size=29`, + Header: map[string]string{ + `Host`: `api.live.bilibili.com`, + `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, + `Accept`: `application/json, text/plain, */*`, `Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`, `Accept-Encoding`: `gzip, deflate, br`, - `Origin`: `https://live.bilibili.com`, - `Connection`: `keep-alive`, - `Pragma`: `no-cache`, - `Cache-Control`: `no-cache`, - `Referer`:"https://live.bilibili.com/" + Roomid, - `Cookie`:reqf.Map_2_Cookies_String(Cookie), + `Origin`: `https://live.bilibili.com`, + `Connection`: `keep-alive`, + `Pragma`: `no-cache`, + `Cache-Control`: `no-cache`, + `Referer`: "https://live.bilibili.com/" + Roomid, + `Cookie`: reqf.Map_2_Cookies_String(Cookie), }, - Proxy:c.Proxy, - Timeout:3*1000, - Retry:2, - });err != nil { - apilog.L(`E: `,err) + Proxy: c.Proxy, + Timeout: 3 * 1000, + Retry: 2, + }); err != nil { + apilog.L(`E: `, err) return } var j J.GetGuardNum - if e := json.Unmarshal([]byte(req.Respon),&j);e != nil{ + if e := json.Unmarshal([]byte(req.Respon), &j); e != nil { apilog.L(`E: `, e) return } else if j.Code != 0 { @@ -1058,7 +1102,7 @@ func Get_guardNum() (missKey []string) { // if len(missKey) != 0 {return} // Roomid := strconv.Itoa(c.Roomid) - + // apilog := apilog.Base_add(`获取客户版本`) // var player_js_url string @@ -1115,23 +1159,25 @@ func Get_guardNum() (missKey []string) { // } //调用记录 -var boot_Get_cookie funcCtrl.FlashFunc//新的替代旧的 +var boot_Get_cookie funcCtrl.FlashFunc //新的替代旧的 //扫码登录 func Get_cookie() (missKey []string) { - if v,ok := c.K_v.LoadV(`扫码登录`).(bool);!ok || !v {return} + if v, ok := c.K_v.LoadV(`扫码登录`).(bool); !ok || !v { + return + } apilog := apilog.Base_add(`获取Cookie`) - - if p.Checkfile().IsExist("cookie.txt") {//读取cookie文件 - if cookieString := string(CookieGet());cookieString != ``{ - for k,v := range reqf.Cookies_String_2_Map(cookieString){//cookie存入全局变量syncmap + + if p.Checkfile().IsExist("cookie.txt") { //读取cookie文件 + if cookieString := string(CookieGet()); cookieString != `` { + for k, v := range reqf.Cookies_String_2_Map(cookieString) { //cookie存入全局变量syncmap c.Cookie.Store(k, v) } if miss := CookieCheck([]string{ `bili_jct`, `DedeUserID`, - });len(miss) == 0 { + }); len(miss) == 0 { return } } @@ -1143,26 +1189,26 @@ func Get_cookie() (missKey []string) { var img_url string var oauth string - {//获取二维码 + { //获取二维码 r := reqf.New() if e := r.Reqf(reqf.Rval{ - Url:`https://passport.bilibili.com/qrcode/getLoginUrl`, - Proxy:c.Proxy, - Timeout:10*1000, - Retry:2, - });e != nil { - apilog.L(`E: `,e) + Url: `https://passport.bilibili.com/qrcode/getLoginUrl`, + Proxy: c.Proxy, + Timeout: 10 * 1000, + Retry: 2, + }); e != nil { + apilog.L(`E: `, e) return } - var res struct{ - Code int `json:"code"` + var res struct { + Code int `json:"code"` Status bool `json:"status"` - Data struct{ - Url string `json:"url"` + Data struct { + Url string `json:"url"` OauthKey string `json:"oauthKey"` } `json:"data"` } - if e := json.Unmarshal(r.Respon, &res);e != nil { + if e := json.Unmarshal(r.Respon, &res); e != nil { apilog.L(`E: `, e) return } @@ -1174,136 +1220,155 @@ func Get_cookie() (missKey []string) { apilog.L(`E: `, `status == false`) return } - + if res.Data.Url == `` { apilog.L(`E: `, `Data.Urls == ""`) return - } else {img_url = res.Data.Url} + } else { + img_url = res.Data.Url + } if res.Data.OauthKey == `` { apilog.L(`E: `, `Data.OauthKey == ""`) return - } else {oauth = res.Data.OauthKey} + } else { + oauth = res.Data.OauthKey + } } //有新实例，退出 - if boot_Get_cookie.NeedExit(id) {return} + if boot_Get_cookie.NeedExit(id) { + return + } var server = &http.Server{ - Addr: p.Sys().GetIntranetIp()+":"+strconv.Itoa(p.Sys().GetFreePort()), + Addr: p.Sys().GetIntranetIp() + ":" + strconv.Itoa(p.Sys().GetFreePort()), } - {//生成二维码 - qr.WriteFile(img_url,qr.Medium,256,`qr.png`) + { //生成二维码 + qr.WriteFile(img_url, qr.Medium, 256, `qr.png`) if !p.Checkfile().IsExist(`qr.png`) { - apilog.L(`E: `,`qr error`) + apilog.L(`E: `, `qr error`) return } //启动web s := web.New(server) - s.Handle(map[string]func(http.ResponseWriter,*http.Request){ - `/`:func(w http.ResponseWriter,r *http.Request){ + s.Handle(map[string]func(http.ResponseWriter, *http.Request){ + `/`: func(w http.ResponseWriter, r *http.Request) { var path string = r.URL.Path[1:] - if path == `` {path = `index.html`} + if path == `` { + path = `index.html` + } http.ServeFile(w, r, path) }, - `/exit`:func(w http.ResponseWriter,r *http.Request){ + `/exit`: func(w http.ResponseWriter, r *http.Request) { s.Server.Shutdown(context.Background()) }, }) defer server.Shutdown(context.Background()) - if c.K_v.LoadV(`扫码登录自动打开标签页`).(bool) {open.Run(`http://`+server.Addr+`/qr.png`)} + if c.K_v.LoadV(`扫码登录自动打开标签页`).(bool) { + open.Run(`http://` + server.Addr + `/qr.png`) + } apilog.Block(1000) //show qr code in cmd qrterminal.GenerateWithConfig(img_url, qrterminal.Config{ - Level: qrterminal.L, - Writer: os.Stdout, + Level: qrterminal.L, + Writer: os.Stdout, BlackChar: ` `, WhiteChar: `OO`, }) - apilog.L(`W: `,`打开链接扫码(命令行黑底)登录：`,`http://`+server.Addr+`/qr.png`) + apilog.L(`W: `, `手机扫命令行二维码登录`) + apilog.L(`W: `, `或打开链接扫码登录：`, `http://`+server.Addr+`/qr.png`) p.Sys().Timeoutf(1) } - + //有新实例，退出 - if boot_Get_cookie.NeedExit(id) {return} + if boot_Get_cookie.NeedExit(id) { + return + } var cookie string - {//3s刷新查看是否通过 - max_try := 20 - + { //循环查看是否通过 Cookie := make(map[string]string) - c.Cookie.Range(func(k,v interface{})(bool){ + c.Cookie.Range(func(k, v interface{}) bool { Cookie[k.(string)] = v.(string) return true }) - for max_try > 0 { - max_try -= 1 + for { + //3s刷新查看是否通过 p.Sys().Timeoutf(3) - + //有新实例，退出 - if boot_Get_cookie.NeedExit(id) {return} + if boot_Get_cookie.NeedExit(id) { + return + } r := reqf.New() if e := r.Reqf(reqf.Rval{ - Url:`https://passport.bilibili.com/qrcode/getLoginInfo`, - PostStr:`oauthKey=`+oauth, - Header:map[string]string{ - `Content-Type`:`application/x-www-form-urlencoded; charset=UTF-8`, - `Referer`: `https://passport.bilibili.com/login`, - `Cookie`:reqf.Map_2_Cookies_String(Cookie), + Url: `https://passport.bilibili.com/qrcode/getLoginInfo`, + PostStr: `oauthKey=` + oauth, + Header: map[string]string{ + `Content-Type`: `application/x-www-form-urlencoded; charset=UTF-8`, + `Referer`: `https://passport.bilibili.com/login`, + `Cookie`: reqf.Map_2_Cookies_String(Cookie), }, - Proxy:c.Proxy, - Timeout:10*1000, - Retry:2, - });e != nil { - apilog.L(`E: `,e) + Proxy: c.Proxy, + Timeout: 10 * 1000, + Retry: 2, + }); e != nil { + apilog.L(`E: `, e) return } - res := string(r.Respon) - if v,ok := p.Json().GetValFromS(res, "status").(bool);!ok { - apilog.L(`E: `,`getLoginInfo status false`) - return - } else if !v { - if v,ok := p.Json().GetValFromS(res, "message").(string);ok { - if max_try < 5 || max_try%5 == 0 {//减少日志频度 - apilog.L(`W: `,`登录中`,v,max_try) - } + + var res struct { + Status bool `josn:"status"` + Message string `json:"message"` + } + + if e := json.Unmarshal(r.Respon, &res); e != nil { + apilog.L(`E: `, e.Error(), string(r.Respon)) + } + + if !res.Status { + if res.Message == `Can't Match oauthKey~` { + apilog.L(`W: `, `登录超时`) + return } - continue } else { - apilog.L(`W: `,`登录，并保存了cookie`) - if v := r.Response.Cookies();len(v) == 0 { - apilog.L(`E: `,`getLoginInfo cookies len == 0`) + apilog.L(`W: `, `登录，并保存了cookie`) + if v := r.Response.Cookies(); len(v) == 0 { + apilog.L(`E: `, `getLoginInfo cookies len == 0`) return } else { - cookie = reqf.Map_2_Cookies_String(reqf.Cookies_List_2_Map(v))//cookie to string + cookie = reqf.Map_2_Cookies_String(reqf.Cookies_List_2_Map(v)) //cookie to string } if cookie == `` { - apilog.L(`E: `,`getLoginInfo cookies ""`) + apilog.L(`E: `, `getLoginInfo cookies ""`) return - } else {break} + } else { + break + } } } - if max_try <= 0 { - apilog.L(`W: `,`登录取消`) + if len(cookie) == 0 { return } - if len(cookie) == 0 {return} } //有新实例，退出 - if boot_Get_cookie.NeedExit(id) {return} + if boot_Get_cookie.NeedExit(id) { + return + } - {//写入cookie.txt - for k,v := range reqf.Cookies_String_2_Map(cookie){ + { //写入cookie.txt + for k, v := range reqf.Cookies_String_2_Map(cookie) { c.Cookie.Store(k, v) } //生成cookieString cookieString := `` { - c.Cookie.Range(func(k,v interface{})(bool){ - cookieString += k.(string)+`=`+v.(string)+`; ` + c.Cookie.Range(func(k, v interface{}) bool { + cookieString += k.(string) + `=` + v.(string) + `; ` return true }) t := []rune(cookieString) @@ -1314,9 +1379,11 @@ func Get_cookie() (missKey []string) { } //有新实例，退出 - if boot_Get_cookie.NeedExit(id) {return} + if boot_Get_cookie.NeedExit(id) { + return + } - {//清理 + { //清理 if p.Checkfile().IsExist(`qr.png`) { os.RemoveAll(`qr.png`) return @@ -1329,158 +1396,161 @@ func Get_cookie() (missKey []string) { func Get_cookie_by_msg() { /* - https://passport.bilibili.com/x/passport-login/web/sms/send + https://passport.bilibili.com/x/passport-login/web/sms/send */ } //牌子 -type TGet_list_in_room struct{ - Medal_id int `json:"medal_id"`//牌子id - Medal_name string `json:"medal_name"`//牌子名 - Target_id int `json:"target_id"`//牌子up主uid - Target_name string `json:"target_name"`//牌子up主名 - Room_id int `json:"roomid"`//牌子直播间 - Last_wear_time int `json:"last_wear_time"`//佩戴有效截止时间（佩戴本身不会刷新，发弹幕，送小心心，送金瓜子礼物才会刷新） - Today_intimacy int `json:"today_intimacy"`//今日亲密(0:未发送弹幕 100:已发送弹幕) - Is_lighted int `json:"is_lighted"`//牌子是否熄灭(0:熄灭 1:亮) +type TGet_list_in_room struct { + Medal_id int `json:"medal_id"` //牌子id + Medal_name string `json:"medal_name"` //牌子名 + Target_id int `json:"target_id"` //牌子up主uid + Target_name string `json:"target_name"` //牌子up主名 + Room_id int `json:"roomid"` //牌子直播间 + Last_wear_time int `json:"last_wear_time"` //佩戴有效截止时间（佩戴本身不会刷新，发弹幕，送小心心，送金瓜子礼物才会刷新） + Today_intimacy int `json:"today_intimacy"` //今日亲密(0:未发送弹幕 100:已发送弹幕) + Is_lighted int `json:"is_lighted"` //牌子是否熄灭(0:熄灭 1:亮) } + //获取牌子信息 func Get_list_in_room() (array []TGet_list_in_room) { - + apilog := apilog.Base_add(`获取牌子`) //验证cookie if missKey := CookieCheck([]string{ `bili_jct`, `DedeUserID`, `LIVE_BUVID`, - });len(missKey) != 0 { - apilog.L(`T: `,`Cookie无Key:`,missKey) + }); len(missKey) != 0 { + apilog.L(`T: `, `Cookie无Key:`, missKey) return } Cookie := make(map[string]string) - c.Cookie.Range(func(k,v interface{})(bool){ + c.Cookie.Range(func(k, v interface{}) bool { Cookie[k.(string)] = v.(string) return true }) - {//获取牌子列表 + { //获取牌子列表 var medalList []TGet_list_in_room - for pageNum:=1; true;pageNum+=1{ + for pageNum := 1; true; pageNum += 1 { r := reqf.New() if e := r.Reqf(reqf.Rval{ - Url:`https://api.live.bilibili.com/fans_medal/v5/live_fans_medal/iApiMedal?page=`+strconv.Itoa(pageNum)+`&pageSize=10`, - Header:map[string]string{ - `Cookie`:reqf.Map_2_Cookies_String(Cookie), + Url: `https://api.live.bilibili.com/fans_medal/v5/live_fans_medal/iApiMedal?page=` + strconv.Itoa(pageNum) + `&pageSize=10`, + Header: map[string]string{ + `Cookie`: reqf.Map_2_Cookies_String(Cookie), }, - Proxy:c.Proxy, - Timeout:10*1000, - Retry:2, - });e != nil { - apilog.L(`E: `,e) + Proxy: c.Proxy, + Timeout: 10 * 1000, + Retry: 2, + }); e != nil { + apilog.L(`E: `, e) return } - - var res struct{ - Code int `json:"code"` - Msg string `json:"msg"` + + var res struct { + Code int `json:"code"` + Msg string `json:"msg"` Message string `json:"message"` - Data struct{ - FansMedalList []TGet_list_in_room `json"fansMedalList"` - Pageinfo struct{ + Data struct { + FansMedalList []TGet_list_in_room `json:"fansMedalList"` + Pageinfo struct { Totalpages int `json:"totalpages"` - CurPage int `json:"curPage"` + CurPage int `json:"curPage"` } `json:"pageinfo"` } `json:"data"` } - - if e := json.Unmarshal(r.Respon, &res);e != nil{ - apilog.L(`E: `,e) + + if e := json.Unmarshal(r.Respon, &res); e != nil { + apilog.L(`E: `, e) } - + if res.Code != 0 { - apilog.L(`E: `,`返回code`, res.Code, res.Msg) + apilog.L(`E: `, `返回code`, res.Code, res.Msg) return } medalList = append(medalList, res.Data.FansMedalList...) - if res.Data.Pageinfo.CurPage == res.Data.Pageinfo.Totalpages {break} + if res.Data.Pageinfo.CurPage == res.Data.Pageinfo.Totalpages { + break + } time.Sleep(time.Second) } - return medalList } } -type TGet_weared_medal struct{ - Medal_id int `json:"medal_id"`//牌子id - Medal_name string `json:"medal_name"`//牌子名 - Target_id int `json:"target_id"`//牌子up主uid - Target_name string `json:"target_name"`//牌子up主名 - Roominfo Roominfo `json:"roominfo"`//牌子直播间 - Today_intimacy int `json:"today_intimacy"`//今日亲密(0:未发送弹幕 100:已发送弹幕) - Is_lighted int `json:"is_lighted"`//牌子是否熄灭(0:熄灭 1:亮) +type TGet_weared_medal struct { + Medal_id int `json:"medal_id"` //牌子id + Medal_name string `json:"medal_name"` //牌子名 + Target_id int `json:"target_id"` //牌子up主uid + Target_name string `json:"target_name"` //牌子up主名 + Roominfo Roominfo `json:"roominfo"` //牌子直播间 + Today_intimacy int `json:"today_intimacy"` //今日亲密(0:未发送弹幕 100:已发送弹幕) + Is_lighted int `json:"is_lighted"` //牌子是否熄灭(0:熄灭 1:亮) } -type Roominfo struct{ +type Roominfo struct { Room_id int `json:"room_id"` } + //获取当前佩戴的牌子 func Get_weared_medal() (item TGet_weared_medal) { - + apilog := apilog.Base_add(`获取牌子`) //验证cookie if missKey := CookieCheck([]string{ `bili_jct`, `DedeUserID`, `LIVE_BUVID`, - });len(missKey) != 0 { - apilog.L(`T: `,`Cookie无Key:`,missKey) + }); len(missKey) != 0 { + apilog.L(`T: `, `Cookie无Key:`, missKey) return } Cookie := make(map[string]string) - c.Cookie.Range(func(k,v interface{})(bool){ + c.Cookie.Range(func(k, v interface{}) bool { Cookie[k.(string)] = v.(string) return true }) - {//获取 + { //获取 r := reqf.New() if e := r.Reqf(reqf.Rval{ - Url:`https://api.live.bilibili.com/live_user/v1/UserInfo/get_weared_medal`, - Header:map[string]string{ - `Cookie`:reqf.Map_2_Cookies_String(Cookie), + Url: `https://api.live.bilibili.com/live_user/v1/UserInfo/get_weared_medal`, + Header: map[string]string{ + `Cookie`: reqf.Map_2_Cookies_String(Cookie), }, - Proxy:c.Proxy, - Timeout:10*1000, - Retry:2, - });e != nil { - apilog.L(`E: `,e) + Proxy: c.Proxy, + Timeout: 10 * 1000, + Retry: 2, + }); e != nil { + apilog.L(`E: `, e) return } - var res struct{ - Code int `json:"code"` - Msg string `json:"msg"` - Message string `json:"message"` - Data TGet_weared_medal `json:"data"` + var res struct { + Code int `json:"code"` + Msg string `json:"msg"` + Message string `json:"message"` + Data TGet_weared_medal `json:"data"` } - if e := json.Unmarshal(r.Respon, &res);e != nil && res.Msg == ``{//未佩戴时的data是array型会导致错误 - apilog.L(`E: `,e) + if e := json.Unmarshal(r.Respon, &res); e != nil && res.Msg == `` { //未佩戴时的data是array型会导致错误 + apilog.L(`E: `, e) return } if res.Code != 0 { - apilog.L(`E: `,`返回code`, res.Code, res.Msg) + apilog.L(`E: `, `返回code`, res.Code, res.Msg) return } return res.Data } - + } func CheckSwitch_FansMedal() (missKey []string) { @@ -1488,49 +1558,51 @@ func CheckSwitch_FansMedal() (missKey []string) { if !c.LIVE_BUVID { missKey = append(missKey, `LIVE_BUVID`) } - if c.UpUid == 0{ + if c.UpUid == 0 { missKey = append(missKey, `UpUid`) } if len(missKey) > 0 { return } - + apilog := apilog.Base_add(`切换粉丝牌`) //验证cookie if missCookie := CookieCheck([]string{ `bili_jct`, `DedeUserID`, `LIVE_BUVID`, - });len(missCookie) != 0 { - apilog.L(`T: `,`Cookie无Key:`,missCookie) + }); len(missCookie) != 0 { + apilog.L(`T: `, `Cookie无Key:`, missCookie) return } Cookie := make(map[string]string) - c.Cookie.Range(func(k,v interface{})(bool){ + c.Cookie.Range(func(k, v interface{}) bool { Cookie[k.(string)] = v.(string) return true }) - {//获取当前牌子，验证是否本直播间牌子 + { //获取当前牌子，验证是否本直播间牌子 res := Get_weared_medal() - c.Wearing_FansMedal = res.Roominfo.Room_id//更新佩戴信息 + c.Wearing_FansMedal = res.Roominfo.Room_id //更新佩戴信息 if res.Target_id == c.UpUid { return } } - var medal_id int//将要使用的牌子id + var medal_id int //将要使用的牌子id //检查是否有此直播间的牌子 { medal_list := Get_list_in_room() - for _,v := range medal_list { - if v.Target_id != c.UpUid {continue} + for _, v := range medal_list { + if v.Target_id != c.UpUid { + continue + } medal_id = v.Medal_id } - if medal_id == 0 {//无牌 - apilog.L(`I: `,`无主播粉丝牌`) - if c.Wearing_FansMedal == 0 {//当前没牌 + if medal_id == 0 { //无牌 + apilog.L(`I: `, `无主播粉丝牌`) + if c.Wearing_FansMedal == 0 { //当前没牌 return } } @@ -1540,46 +1612,49 @@ func CheckSwitch_FansMedal() (missKey []string) { post_url string post_str string ) - {//生成佩戴信息 - csrf,_ := c.Cookie.LoadV(`bili_jct`).(string) - if csrf == `` {apilog.L(`E: `,"Cookie错误,无bili_jct=");return} - - post_str = `csrf_token=`+csrf+`&csrf=`+csrf - - if medal_id == 0 {//无牌，不佩戴牌子 + { //生成佩戴信息 + csrf, _ := c.Cookie.LoadV(`bili_jct`).(string) + if csrf == `` { + apilog.L(`E: `, "Cookie错误,无bili_jct=") + return + } + + post_str = `csrf_token=` + csrf + `&csrf=` + csrf + + if medal_id == 0 { //无牌，不佩戴牌子 post_url = `https://api.live.bilibili.com/xlive/web-room/v1/fansMedal/take_off` } else { post_url = `https://api.live.bilibili.com/xlive/web-room/v1/fansMedal/wear` - post_str = `medal_id=`+strconv.Itoa(medal_id)+`&`+post_str + post_str = `medal_id=` + strconv.Itoa(medal_id) + `&` + post_str } } - {//切换牌子 + { //切换牌子 r := reqf.New() if e := r.Reqf(reqf.Rval{ - Url:post_url, - PostStr:post_str, - Header:map[string]string{ - `Cookie`:reqf.Map_2_Cookies_String(Cookie), - `Content-Type`:`application/x-www-form-urlencoded; charset=UTF-8`, - `Referer`: `https://passport.bilibili.com/login`, + Url: post_url, + PostStr: post_str, + Header: map[string]string{ + `Cookie`: reqf.Map_2_Cookies_String(Cookie), + `Content-Type`: `application/x-www-form-urlencoded; charset=UTF-8`, + `Referer`: `https://passport.bilibili.com/login`, }, - Proxy:c.Proxy, - Timeout:10*1000, - Retry:2, - });e != nil { - apilog.L(`E: `,e) + Proxy: c.Proxy, + Timeout: 10 * 1000, + Retry: 2, + }); e != nil { + apilog.L(`E: `, e) return } res := string(r.Respon) - if v,ok := p.Json().GetValFromS(res, "code").(float64);ok && v == 0 { - apilog.L(`I: `,`自动切换粉丝牌 id:`,medal_id) - c.Wearing_FansMedal = medal_id//更新佩戴信息 + if v, ok := p.Json().GetValFromS(res, "code").(float64); ok && v == 0 { + apilog.L(`I: `, `自动切换粉丝牌 id:`, medal_id) + c.Wearing_FansMedal = medal_id //更新佩戴信息 return } - if v,ok := p.Json().GetValFromS(res, "message").(string);ok { - apilog.L(`E: `,`Get_FansMedal wear message`, v) + if v, ok := p.Json().GetValFromS(res, "message").(string); ok { + apilog.L(`E: `, `Get_FansMedal wear message`, v) } else { - apilog.L(`E: `,`Get_FansMedal wear message nil`) + apilog.L(`E: `, `Get_FansMedal wear message nil`) } } return @@ -1587,173 +1662,180 @@ func CheckSwitch_FansMedal() (missKey []string) { //签到 func Dosign() { - apilog := apilog.Base_add(`签到`).L(`T: `,`签到`) + apilog := apilog.Base_add(`签到`).L(`T: `, `签到`) //验证cookie if missKey := CookieCheck([]string{ `bili_jct`, `DedeUserID`, `LIVE_BUVID`, - });len(missKey) != 0 { - apilog.L(`T: `,`Cookie无Key:`,missKey) + }); len(missKey) != 0 { + apilog.L(`T: `, `Cookie无Key:`, missKey) return } - - {//检查是否签到 + { //检查是否签到 Cookie := make(map[string]string) - c.Cookie.Range(func(k,v interface{})(bool){ + c.Cookie.Range(func(k, v interface{}) bool { Cookie[k.(string)] = v.(string) return true }) req := reqf.New() if err := req.Reqf(reqf.Rval{ - Url:`https://api.live.bilibili.com/xlive/web-ucenter/v1/sign/WebGetSignInfo`, - Header:map[string]string{ - `Host`: `api.live.bilibili.com`, - `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, - `Accept`: `application/json, text/plain, */*`, + Url: `https://api.live.bilibili.com/xlive/web-ucenter/v1/sign/WebGetSignInfo`, + Header: map[string]string{ + `Host`: `api.live.bilibili.com`, + `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, + `Accept`: `application/json, text/plain, */*`, `Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`, `Accept-Encoding`: `gzip, deflate, br`, - `Origin`: `https://live.bilibili.com`, - `Connection`: `keep-alive`, - `Pragma`: `no-cache`, - `Cache-Control`: `no-cache`, - `Referer`:"https://live.bilibili.com/all", - `Cookie`:reqf.Map_2_Cookies_String(Cookie), + `Origin`: `https://live.bilibili.com`, + `Connection`: `keep-alive`, + `Pragma`: `no-cache`, + `Cache-Control`: `no-cache`, + `Referer`: "https://live.bilibili.com/all", + `Cookie`: reqf.Map_2_Cookies_String(Cookie), }, - Proxy:c.Proxy, - Timeout:3*1000, - Retry:2, - });err != nil { - apilog.L(`E: `,err) + Proxy: c.Proxy, + Timeout: 3 * 1000, + Retry: 2, + }); err != nil { + apilog.L(`E: `, err) return } - + var msg struct { - Code int `json:"code"` + Code int `json:"code"` Message string `json:"message"` - Data struct { + Data struct { Status int `json:"status"` } `json:"data"` } - if e := json.Unmarshal(req.Respon,&msg);e != nil{ - apilog.L(`E: `,e) + if e := json.Unmarshal(req.Respon, &msg); e != nil { + apilog.L(`E: `, e) } - if msg.Code != 0 {apilog.L(`E: `,msg.Message);return} - if msg.Data.Status == 1 {//今日已签到 + if msg.Code != 0 { + apilog.L(`E: `, msg.Message) + return + } + if msg.Data.Status == 1 { //今日已签到 return } } - {//签到 + { //签到 Cookie := make(map[string]string) - c.Cookie.Range(func(k,v interface{})(bool){ + c.Cookie.Range(func(k, v interface{}) bool { Cookie[k.(string)] = v.(string) return true }) req := reqf.New() if err := req.Reqf(reqf.Rval{ - Url:`https://api.live.bilibili.com/xlive/web-ucenter/v1/sign/DoSign`, - Header:map[string]string{ - `Host`: `api.live.bilibili.com`, - `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, - `Accept`: `application/json, text/plain, */*`, + Url: `https://api.live.bilibili.com/xlive/web-ucenter/v1/sign/DoSign`, + Header: map[string]string{ + `Host`: `api.live.bilibili.com`, + `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, + `Accept`: `application/json, text/plain, */*`, `Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`, `Accept-Encoding`: `gzip, deflate, br`, - `Origin`: `https://live.bilibili.com`, - `Connection`: `keep-alive`, - `Pragma`: `no-cache`, - `Cache-Control`: `no-cache`, - `Referer`:"https://live.bilibili.com/all", - `Cookie`:reqf.Map_2_Cookies_String(Cookie), + `Origin`: `https://live.bilibili.com`, + `Connection`: `keep-alive`, + `Pragma`: `no-cache`, + `Cache-Control`: `no-cache`, + `Referer`: "https://live.bilibili.com/all", + `Cookie`: reqf.Map_2_Cookies_String(Cookie), }, - Proxy:c.Proxy, - Timeout:3*1000, - Retry:2, - });err != nil { - apilog.L(`E: `,err) + Proxy: c.Proxy, + Timeout: 3 * 1000, + Retry: 2, + }); err != nil { + apilog.L(`E: `, err) return } - + var msg struct { - Code int `json:"code"` + Code int `json:"code"` Message string `json:"message"` - Data struct { + Data struct { HadSignDays int `json:"hadSignDays"` } `json:"data"` } - if e := json.Unmarshal(req.Respon,&msg);e != nil{ - apilog.L(`E: `,e) + if e := json.Unmarshal(req.Respon, &msg); e != nil { + apilog.L(`E: `, e) } - if msg.Code == 0 {apilog.L(`I: `,`签到成功!本月已签到`, msg.Data.HadSignDays,`天`);return} - apilog.L(`E: `,msg.Message) + if msg.Code == 0 { + apilog.L(`I: `, `签到成功!本月已签到`, msg.Data.HadSignDays, `天`) + return + } + apilog.L(`E: `, msg.Message) } } //LIVE_BUVID func Get_LIVE_BUVID() (missKey []string) { - apilog := apilog.Base_add(`LIVE_BUVID`).L(`T: `,`获取`) - - if live_buvid,ok := c.Cookie.LoadV(`LIVE_BUVID`).(string);ok && live_buvid != `` { - apilog.L(`T: `,`存在`) + apilog := apilog.Base_add(`LIVE_BUVID`).L(`T: `, `获取`) + + if live_buvid, ok := c.Cookie.LoadV(`LIVE_BUVID`).(string); ok && live_buvid != `` { + apilog.L(`T: `, `存在`) c.LIVE_BUVID = true return } //当房间处于特殊活动状态时，将会获取不到，此处使用了若干著名up主房间进行尝试 roomIdList := []string{ - "3",//哔哩哔哩音悦台 - "2",//直播姬 - "1",//哔哩哔哩直播 + "3", //哔哩哔哩音悦台 + "2", //直播姬 + "1", //哔哩哔哩直播 } - for _,roomid := range roomIdList{//获取 + for _, roomid := range roomIdList { //获取 req := reqf.New() if err := req.Reqf(reqf.Rval{ - Url:`https://api.live.bilibili.com/live/getRoomKanBanModel?roomid=`+roomid, - Header:map[string]string{ - `Host`: `live.bilibili.com`, - `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, - `Accept`: `text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8`, - `Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`, - `Accept-Encoding`: `gzip, deflate, br`, - `Connection`: `keep-alive`, - `Cache-Control`: `no-cache`, - `Referer`:"https://live.bilibili.com", - `DNT`: `1`, + Url: `https://api.live.bilibili.com/live/getRoomKanBanModel?roomid=` + roomid, + Header: map[string]string{ + `Host`: `live.bilibili.com`, + `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, + `Accept`: `text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8`, + `Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`, + `Accept-Encoding`: `gzip, deflate, br`, + `Connection`: `keep-alive`, + `Cache-Control`: `no-cache`, + `Referer`: "https://live.bilibili.com", + `DNT`: `1`, `Upgrade-Insecure-Requests`: `1`, }, - Proxy:c.Proxy, - Timeout:3*1000, - Retry:2, - });err != nil { - apilog.L(`E: `,err) + Proxy: c.Proxy, + Timeout: 3 * 1000, + Retry: 2, + }); err != nil { + apilog.L(`E: `, err) return } //cookie var has bool - for k,v := range reqf.Cookies_List_2_Map(req.Response.Cookies()){ + for k, v := range reqf.Cookies_List_2_Map(req.Response.Cookies()) { c.Cookie.Store(k, v) - if k == `LIVE_BUVID` {has = true} + if k == `LIVE_BUVID` { + has = true + } } if has { - apilog.L(`I: `,`获取到LIVE_BUVID，保存cookie`) + apilog.L(`I: `, `获取到LIVE_BUVID，保存cookie`) break } else { - apilog.L(`I: `, roomid,`未获取到，重试`) + apilog.L(`I: `, roomid, `未获取到，重试`) time.Sleep(time.Second) } } - + Cookie := make(map[string]string) - c.Cookie.Range(func(k,v interface{})(bool){ + c.Cookie.Range(func(k, v interface{}) bool { Cookie[k.(string)] = v.(string) return true }) - + CookieSet([]byte(reqf.Map_2_Cookies_String(Cookie))) c.LIVE_BUVID = true @@ -1762,98 +1844,116 @@ func Get_LIVE_BUVID() (missKey []string) { } //小心心 -type E_json struct{ - Code int `json:"code"` +type E_json struct { + Code int `json:"code"` Message string `json:"message"` - Ttl int `json:"ttl"` - Data struct{ - Timestamp int `json:"timestamp"` - Heartbeat_interval int `json:"heartbeat_interval"` - Secret_key string `json:"secret_key"` - Secret_rule []int `json:"secret_rule"` - Patch_status int `json:"patch_status"` + Ttl int `json:"ttl"` + Data struct { + Timestamp int `json:"timestamp"` + Heartbeat_interval int `json:"heartbeat_interval"` + Secret_key string `json:"secret_key"` + Secret_rule []int `json:"secret_rule"` + Patch_status int `json:"patch_status"` } `json:"data"` } //调用记录 -var boot_F_x25Kn funcCtrl.FlashFunc//新的替代旧的 +var boot_F_x25Kn funcCtrl.FlashFunc //新的替代旧的 func F_x25Kn_cancel() { - apilog.Base_add(`小心心`).L(`T: `,`取消`) - boot_F_x25Kn.Flash()//获取函数调用会话id + apilog.Base_add(`小心心`).L(`T: `, `取消`) + boot_F_x25Kn.Flash() //获取函数调用会话id boot_F_x25Kn.UnFlash() } func F_x25Kn() { apilog := apilog.Base_add(`小心心`) - if c.Wearing_FansMedal == 0{apilog.L(`I: `,`无粉丝牌，不获取`);return} + if c.Wearing_FansMedal == 0 { + apilog.L(`I: `, `无粉丝牌，不获取`) + return + } //验证cookie if missKey := CookieCheck([]string{ `bili_jct`, `DedeUserID`, `LIVE_BUVID`, - });len(missKey) != 0 { - apilog.L(`T: `,`Cookie无Key:`,missKey) + }); len(missKey) != 0 { + apilog.L(`T: `, `Cookie无Key:`, missKey) return } - if c.ParentAreaID == -1 {apilog.L(`E: `,`失败！未获取Parent_area_id`);return} - if c.AreaID == -1 {apilog.L(`E: `,`失败！未获取Area_id`);return} - if api_limit.TO() {apilog.L(`E: `,`超时！`);return}//超额请求阻塞，超时将取消 + if c.ParentAreaID == -1 { + apilog.L(`E: `, `失败！未获取Parent_area_id`) + return + } + if c.AreaID == -1 { + apilog.L(`E: `, `失败！未获取Area_id`) + return + } + if api_limit.TO() { + apilog.L(`E: `, `超时！`) + return + } //超额请求阻塞，超时将取消 - id := boot_F_x25Kn.Flash()//获取函数调用会话id + id := boot_F_x25Kn.Flash() //获取函数调用会话id defer boot_F_x25Kn.UnFlash() - {//查看今天小心心数量 + { //查看今天小心心数量 var num = 0 - for _,v := range Gift_list() { - if v.Gift_id == 30607 && v.Expire_at - int(p.Sys().GetSTime()) > 6 * 86400 { + for _, v := range Gift_list() { + if v.Gift_id == 30607 && v.Expire_at-int(p.Sys().GetSTime()) > 6*86400 { num = v.Gift_num } } if num == 24 { - Close(0)//关闭全部（0）浏览器websocket连接 - apilog.L(`I: `,`今天小心心已满！`) + Close(0) //关闭全部（0）浏览器websocket连接 + apilog.L(`I: `, `今天小心心已满！`) return } else { - apilog.L(`I: `,`今天已有`,num,`个小心心，开始获取`) - defer apilog.L(`T: `,`退出`) + apilog.L(`I: `, `今天已有`, num, `个小心心，开始获取`) + defer apilog.L(`T: `, `退出`) } } - + var ( - res E_json + res E_json loop_num = 0 ) - csrf,_ := c.Cookie.LoadV(`bili_jct`).(string) - if csrf == `` {apilog.L(`E: `,"Cookie错误,无bili_jct");return} + csrf, _ := c.Cookie.LoadV(`bili_jct`).(string) + if csrf == `` { + apilog.L(`E: `, "Cookie错误,无bili_jct") + return + } LIVE_BUVID := c.Cookie.LoadV(`LIVE_BUVID`).(string) - if LIVE_BUVID == `` {apilog.L(`E: `,"Cookie错误,无LIVE_BUVID");return} + if LIVE_BUVID == `` { + apilog.L(`E: `, "Cookie错误,无LIVE_BUVID") + return + } var new_uuid string { - if tmp_uuid,e := uuid.NewV4();e == nil { + if tmp_uuid, e := uuid.NewV4(); e == nil { new_uuid = tmp_uuid.String() } else { - apilog.L(`E: `,e) + apilog.L(`E: `, e) return } } - {//初始化 + { //初始化 - PostStr := `id=[`+strconv.Itoa(c.ParentAreaID)+`,`+strconv.Itoa(c.AreaID)+`,`+strconv.Itoa(loop_num)+`,`+strconv.Itoa(c.Roomid)+`]&` - PostStr += `device=["`+LIVE_BUVID+`","`+new_uuid+`"]&` - PostStr += `ts=`+strconv.Itoa(int(p.Sys().GetMTime())) + PostStr := `id=[` + strconv.Itoa(c.ParentAreaID) + `,` + strconv.Itoa(c.AreaID) + `,` + strconv.Itoa(loop_num) + `,` + strconv.Itoa(c.Roomid) + `]&` + PostStr += `device=["` + LIVE_BUVID + `","` + new_uuid + `"]&` + PostStr += `ts=` + strconv.Itoa(int(p.Sys().GetMTime())) PostStr += `&is_patch=0&` PostStr += `heart_beat=[]&` PostStr += `ua=Mozilla/5.0 (X11; Linux x86_64; rv:84.0) Gecko/20100101 Firefox/84.0&` - PostStr += `csrf_token=`+csrf+`&csrf=`+csrf+`&` + PostStr += `csrf_token=` + csrf + `&csrf=` + csrf + `&` PostStr += `visit_id=` Cookie := make(map[string]string) - c.Cookie.Range(func(k,v interface{})(bool){ + c.Cookie.Range(func(k, v interface{}) bool { Cookie[k.(string)] = v.(string) return true }) @@ -1861,181 +1961,183 @@ func F_x25Kn() { req := reqf.New() for { //新调用，此退出 - if boot_F_x25Kn.NeedExit(id) {return} + if boot_F_x25Kn.NeedExit(id) { + return + } if err := req.Reqf(reqf.Rval{ - Url:`https://live-trace.bilibili.com/xlive/data-interface/v1/x25Kn/E`, - Header:map[string]string{ - `Host`: `api.live.bilibili.com`, - `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, - `Accept`: `application/json, text/plain, */*`, - `Content-Type`: `application/x-www-form-urlencoded`, + Url: `https://live-trace.bilibili.com/xlive/data-interface/v1/x25Kn/E`, + Header: map[string]string{ + `Host`: `api.live.bilibili.com`, + `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, + `Accept`: `application/json, text/plain, */*`, + `Content-Type`: `application/x-www-form-urlencoded`, `Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`, `Accept-Encoding`: `gzip, deflate, br`, - `Origin`: `https://live.bilibili.com`, - `Connection`: `keep-alive`, - `Pragma`: `no-cache`, - `Cache-Control`: `no-cache`, - `Referer`:"https://live.bilibili.com/"+strconv.Itoa(c.Roomid), - `Cookie`:reqf.Map_2_Cookies_String(Cookie), + `Origin`: `https://live.bilibili.com`, + `Connection`: `keep-alive`, + `Pragma`: `no-cache`, + `Cache-Control`: `no-cache`, + `Referer`: "https://live.bilibili.com/" + strconv.Itoa(c.Roomid), + `Cookie`: reqf.Map_2_Cookies_String(Cookie), }, - PostStr:url.PathEscape(PostStr), - Proxy:c.Proxy, - Timeout:5*1000, - Retry:2, - });err != nil { + PostStr: url.PathEscape(PostStr), + Proxy: c.Proxy, + Timeout: 5 * 1000, + Retry: 2, + }); err != nil { if !reqf.IsTimeout(err) { - apilog.L(`E: `,err) + apilog.L(`E: `, err) return } - apilog.L(`W: `,`响应超时，1min后重试`) + apilog.L(`W: `, `响应超时，1min后重试`) time.Sleep(time.Minute) } else { break } } - if e := json.Unmarshal(req.Respon,&res);e != nil { - apilog.L(`E: `,e) + if e := json.Unmarshal(req.Respon, &res); e != nil { + apilog.L(`E: `, e) return } - if res.Code != 0{ - apilog.L(`E: `,`返回错误`,res.Message) + if res.Code != 0 { + apilog.L(`E: `, `返回错误`, res.Message) return } } - {//loop + { //loop for loop_num < (24+2)*5 { loop_num += 1 //查看今天小心心数量 - if loop_num > 5 && loop_num%5 == 2 {//5min后每5min - {//查看今天小心心数量 + if loop_num > 5 && loop_num%5 == 2 { //5min后每5min + { //查看今天小心心数量 var num = 0 - for _,v := range Gift_list() { - if v.Gift_id == 30607 && v.Expire_at - int(p.Sys().GetSTime()) > 6 * 86400 { + for _, v := range Gift_list() { + if v.Gift_id == 30607 && v.Expire_at-int(p.Sys().GetSTime()) > 6*86400 { num = v.Gift_num } } if num == 24 { - Close(0)//关闭全部（0）浏览器websocket连接 - apilog.L(`I: `,`今天小心心已满！`) + Close(0) //关闭全部（0）浏览器websocket连接 + apilog.L(`I: `, `今天小心心已满！`) return } else { - apilog.L(`I: `,`获取了今天的第`,num,`个小心心`) + apilog.L(`I: `, `获取了今天的第`, num, `个小心心`) } } } - <- time.After(time.Second*time.Duration(res.Data.Heartbeat_interval)) - + <-time.After(time.Second * time.Duration(res.Data.Heartbeat_interval)) + //新调用，此退出 - if boot_F_x25Kn.NeedExit(id) {return} + if boot_F_x25Kn.NeedExit(id) { + return + } var ( rt_obj = RT{ - R:R{ - Id:`[`+strconv.Itoa(c.ParentAreaID)+`,`+strconv.Itoa(c.AreaID)+`,`+strconv.Itoa(loop_num)+`,`+strconv.Itoa(c.Roomid)+`]`, - Device:`["`+LIVE_BUVID+`","`+new_uuid+`"]`, - Ets:res.Data.Timestamp, - Benchmark:res.Data.Secret_key, - Time:res.Data.Heartbeat_interval, - Ts:int(p.Sys().GetMTime()), - Ua:`Mozilla/5.0 (X11; Linux x86_64; rv:84.0) Gecko/20100101 Firefox/84.0`, + R: R{ + Id: `[` + strconv.Itoa(c.ParentAreaID) + `,` + strconv.Itoa(c.AreaID) + `,` + strconv.Itoa(loop_num) + `,` + strconv.Itoa(c.Roomid) + `]`, + Device: `["` + LIVE_BUVID + `","` + new_uuid + `"]`, + Ets: res.Data.Timestamp, + Benchmark: res.Data.Secret_key, + Time: res.Data.Heartbeat_interval, + Ts: int(p.Sys().GetMTime()), + Ua: `Mozilla/5.0 (X11; Linux x86_64; rv:84.0) Gecko/20100101 Firefox/84.0`, }, - T:res.Data.Secret_rule, + T: res.Data.Secret_rule, } wasm string ) - - if rt_obj,wasm = Wasm(0, rt_obj);wasm == `` {//0全局 - apilog.L(`E: `,`发生错误`) + if rt_obj, wasm = Wasm(0, rt_obj); wasm == `` { //0全局 + apilog.L(`E: `, `发生错误`) return } - PostStr := `id=`+rt_obj.R.Id+`&` - PostStr += `device=["`+LIVE_BUVID+`","`+new_uuid+`"]&` - PostStr += `ets=`+strconv.Itoa(res.Data.Timestamp) - PostStr += `&benchmark=`+res.Data.Secret_key - PostStr += `&time=`+strconv.Itoa(res.Data.Heartbeat_interval) - PostStr += `&ts=`+strconv.Itoa(rt_obj.R.Ts) + PostStr := `id=` + rt_obj.R.Id + `&` + PostStr += `device=["` + LIVE_BUVID + `","` + new_uuid + `"]&` + PostStr += `ets=` + strconv.Itoa(res.Data.Timestamp) + PostStr += `&benchmark=` + res.Data.Secret_key + PostStr += `&time=` + strconv.Itoa(res.Data.Heartbeat_interval) + PostStr += `&ts=` + strconv.Itoa(rt_obj.R.Ts) PostStr += `&is_patch=0&` PostStr += `heart_beat=[]&` - PostStr += `ua=`+rt_obj.R.Ua+`&` - PostStr += `csrf_token=`+csrf+`&csrf=`+csrf+`&` + PostStr += `ua=` + rt_obj.R.Ua + `&` + PostStr += `csrf_token=` + csrf + `&csrf=` + csrf + `&` PostStr += `visit_id=` - PostStr = `s=`+wasm+`&`+PostStr + PostStr = `s=` + wasm + `&` + PostStr Cookie := make(map[string]string) - c.Cookie.Range(func(k,v interface{})(bool){ + c.Cookie.Range(func(k, v interface{}) bool { Cookie[k.(string)] = v.(string) return true }) req := reqf.New() if err := req.Reqf(reqf.Rval{ - Url:`https://live-trace.bilibili.com/xlive/data-interface/v1/x25Kn/X`, - Header:map[string]string{ - `Host`: `api.live.bilibili.com`, - `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, - `Accept`: `application/json, text/plain, */*`, - `Content-Type`: `application/x-www-form-urlencoded`, + Url: `https://live-trace.bilibili.com/xlive/data-interface/v1/x25Kn/X`, + Header: map[string]string{ + `Host`: `api.live.bilibili.com`, + `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, + `Accept`: `application/json, text/plain, */*`, + `Content-Type`: `application/x-www-form-urlencoded`, `Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`, `Accept-Encoding`: `gzip, deflate, br`, - `Origin`: `https://live.bilibili.com`, - `Connection`: `keep-alive`, - `Pragma`: `no-cache`, - `Cache-Control`: `no-cache`, - `Referer`:"https://live.bilibili.com/"+strconv.Itoa(c.Roomid), - `Cookie`:reqf.Map_2_Cookies_String(Cookie), + `Origin`: `https://live.bilibili.com`, + `Connection`: `keep-alive`, + `Pragma`: `no-cache`, + `Cache-Control`: `no-cache`, + `Referer`: "https://live.bilibili.com/" + strconv.Itoa(c.Roomid), + `Cookie`: reqf.Map_2_Cookies_String(Cookie), }, - PostStr:url.PathEscape(PostStr), - Proxy:c.Proxy, - Timeout:5*1000, - Retry:2, - });err != nil { + PostStr: url.PathEscape(PostStr), + Proxy: c.Proxy, + Timeout: 5 * 1000, + Retry: 2, + }); err != nil { if !reqf.IsTimeout(err) { loop_num -= 1 - apilog.L(`W: `,`响应超时，将重试`) + apilog.L(`W: `, `响应超时，将重试`) continue } - apilog.L(`E: `,err) + apilog.L(`E: `, err) return } - if e := json.Unmarshal(req.Respon,&res);e != nil { - apilog.L(`E: `,e) + if e := json.Unmarshal(req.Respon, &res); e != nil { + apilog.L(`E: `, e) return } - - if res.Code != 0{ - apilog.L(`E: `,`返回错误`,res.Message) + + if res.Code != 0 { + apilog.L(`E: `, `返回错误`, res.Message) return } } } - return } //礼物列表 type Gift_list_type struct { - Code int `json:"code"` - Message string `json:"message"` - Data Gift_list_type_Data `json:"data"` + Code int `json:"code"` + Message string `json:"message"` + Data Gift_list_type_Data `json:"data"` } type Gift_list_type_Data struct { List []Gift_list_type_Data_List `json:"list"` } -type Gift_list_type_Data_List struct{ - Bag_id int `json:"bag_id"` - Gift_id int `json:"gift_id"` +type Gift_list_type_Data_List struct { + Bag_id int `json:"bag_id"` + Gift_id int `json:"gift_id"` Gift_name string `json:"gift_name"` - Gift_num int `json:"gift_num"` - Expire_at int `json:"expire_at"` + Gift_num int `json:"gift_num"` + Expire_at int `json:"expire_at"` } func Gift_list() (list []Gift_list_type_Data_List) { @@ -2045,56 +2147,62 @@ func Gift_list() (list []Gift_list_type_Data_List) { `bili_jct`, `DedeUserID`, `LIVE_BUVID`, - });len(missKey) != 0 { - apilog.L(`T: `,`Cookie无Key:`,missKey) + }); len(missKey) != 0 { + apilog.L(`T: `, `Cookie无Key:`, missKey) + return + } + if c.Roomid == 0 { + apilog.L(`E: `, `失败！无Roomid`) return } - if c.Roomid == 0 {apilog.L(`E: `,`失败！无Roomid`);return} - if api_limit.TO() {apilog.L(`E: `,`超时！`);return}//超额请求阻塞，超时将取消 + if api_limit.TO() { + apilog.L(`E: `, `超时！`) + return + } //超额请求阻塞，超时将取消 Cookie := make(map[string]string) - c.Cookie.Range(func(k,v interface{})(bool){ + c.Cookie.Range(func(k, v interface{}) bool { Cookie[k.(string)] = v.(string) return true }) req := reqf.New() if err := req.Reqf(reqf.Rval{ - Url:`https://api.live.bilibili.com/xlive/web-room/v1/gift/bag_list?t=`+strconv.Itoa(int(p.Sys().GetMTime()))+`&room_id=`+strconv.Itoa(c.Roomid), - Header:map[string]string{ - `Host`: `api.live.bilibili.com`, - `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, - `Accept`: `application/json, text/plain, */*`, + Url: `https://api.live.bilibili.com/xlive/web-room/v1/gift/bag_list?t=` + strconv.Itoa(int(p.Sys().GetMTime())) + `&room_id=` + strconv.Itoa(c.Roomid), + Header: map[string]string{ + `Host`: `api.live.bilibili.com`, + `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, + `Accept`: `application/json, text/plain, */*`, `Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`, `Accept-Encoding`: `gzip, deflate, br`, - `Origin`: `https://live.bilibili.com`, - `Connection`: `keep-alive`, - `Pragma`: `no-cache`, - `Cache-Control`: `no-cache`, - `Referer`:"https://live.bilibili.com/"+strconv.Itoa(c.Roomid), - `Cookie`:reqf.Map_2_Cookies_String(Cookie), + `Origin`: `https://live.bilibili.com`, + `Connection`: `keep-alive`, + `Pragma`: `no-cache`, + `Cache-Control`: `no-cache`, + `Referer`: "https://live.bilibili.com/" + strconv.Itoa(c.Roomid), + `Cookie`: reqf.Map_2_Cookies_String(Cookie), }, - Proxy:c.Proxy, - Timeout:3*1000, - Retry:2, - });err != nil { - apilog.L(`E: `,err) + Proxy: c.Proxy, + Timeout: 3 * 1000, + Retry: 2, + }); err != nil { + apilog.L(`E: `, err) return } var res Gift_list_type - if e := json.Unmarshal(req.Respon,&res);e != nil { - apilog.L(`E: `,e) + if e := json.Unmarshal(req.Respon, &res); e != nil { + apilog.L(`E: `, e) return } - if res.Code != 0{ - apilog.L(`E: `,res.Message) + if res.Code != 0 { + apilog.L(`E: `, res.Message) return } - apilog.L(`T: `,`成功`) + apilog.L(`T: `, `成功`) return res.Data.List } @@ -2105,53 +2213,55 @@ func Silver_2_coin() (missKey []string) { if !c.LIVE_BUVID { missKey = append(missKey, `LIVE_BUVID`) } - if len(missKey) > 0 {return} + if len(missKey) > 0 { + return + } //验证cookie if miss := CookieCheck([]string{ `bili_jct`, `DedeUserID`, `LIVE_BUVID`, - });len(miss) != 0 { - apilog.L(`T: `,`Cookie无Key:`,miss) + }); len(miss) != 0 { + apilog.L(`T: `, `Cookie无Key:`, miss) return } var Silver int - {//验证是否还有机会 + { //验证是否还有机会 Cookie := make(map[string]string) - c.Cookie.Range(func(k,v interface{})(bool){ + c.Cookie.Range(func(k, v interface{}) bool { Cookie[k.(string)] = v.(string) return true }) req := reqf.New() if err := req.Reqf(reqf.Rval{ - Url:`https://api.live.bilibili.com/xlive/revenue/v1/wallet/getStatus`, - Header:map[string]string{ - `Host`: `api.live.bilibili.com`, - `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, - `Accept`: `application/json, text/plain, */*`, + Url: `https://api.live.bilibili.com/xlive/revenue/v1/wallet/getStatus`, + Header: map[string]string{ + `Host`: `api.live.bilibili.com`, + `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, + `Accept`: `application/json, text/plain, */*`, `Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`, `Accept-Encoding`: `gzip, deflate, br`, - `Origin`: `https://link.bilibili.com`, - `Connection`: `keep-alive`, - `Pragma`: `no-cache`, - `Cache-Control`: `no-cache`, - `Referer`:`https://link.bilibili.com/p/center/index`, - `Cookie`:reqf.Map_2_Cookies_String(Cookie), + `Origin`: `https://link.bilibili.com`, + `Connection`: `keep-alive`, + `Pragma`: `no-cache`, + `Cache-Control`: `no-cache`, + `Referer`: `https://link.bilibili.com/p/center/index`, + `Cookie`: reqf.Map_2_Cookies_String(Cookie), }, - Proxy:c.Proxy, - Timeout:3*1000, - Retry:2, - });err != nil { - apilog.L(`E: `,err) + Proxy: c.Proxy, + Timeout: 3 * 1000, + Retry: 2, + }); err != nil { + apilog.L(`E: `, err) return } - + var j J.ApiXliveRevenueV1WalletGetStatus - if e := json.Unmarshal([]byte(req.Respon),&j);e != nil{ + if e := json.Unmarshal([]byte(req.Respon), &j); e != nil { apilog.L(`E: `, e) return } else if j.Code != 0 { @@ -2168,40 +2278,40 @@ func Silver_2_coin() (missKey []string) { Silver = j.Data.Silver } - {//获取交换规则，验证数量足够 + { //获取交换规则，验证数量足够 Cookie := make(map[string]string) - c.Cookie.Range(func(k,v interface{})(bool){ + c.Cookie.Range(func(k, v interface{}) bool { Cookie[k.(string)] = v.(string) return true }) req := reqf.New() if err := req.Reqf(reqf.Rval{ - Url:`https://api.live.bilibili.com/xlive/revenue/v1/wallet/getRule`, - Header:map[string]string{ - `Host`: `api.live.bilibili.com`, - `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, - `Accept`: `application/json, text/plain, */*`, + Url: `https://api.live.bilibili.com/xlive/revenue/v1/wallet/getRule`, + Header: map[string]string{ + `Host`: `api.live.bilibili.com`, + `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, + `Accept`: `application/json, text/plain, */*`, `Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`, `Accept-Encoding`: `gzip, deflate, br`, - `Origin`: `https://link.bilibili.com`, - `Connection`: `keep-alive`, - `Pragma`: `no-cache`, - `Cache-Control`: `no-cache`, - `Referer`:`https://link.bilibili.com/p/center/index`, - `Cookie`:reqf.Map_2_Cookies_String(Cookie), + `Origin`: `https://link.bilibili.com`, + `Connection`: `keep-alive`, + `Pragma`: `no-cache`, + `Cache-Control`: `no-cache`, + `Referer`: `https://link.bilibili.com/p/center/index`, + `Cookie`: reqf.Map_2_Cookies_String(Cookie), }, - Proxy:c.Proxy, - Timeout:3*1000, - Retry:2, - });err != nil { - apilog.L(`E: `,err) + Proxy: c.Proxy, + Timeout: 3 * 1000, + Retry: 2, + }); err != nil { + apilog.L(`E: `, err) return } - + var j J.ApixliveRevenueV1WalletGetRule - - if e := json.Unmarshal([]byte(req.Respon),&j);e != nil{ + + if e := json.Unmarshal([]byte(req.Respon), &j); e != nil { apilog.L(`E: `, e) return } else if j.Code != 0 { @@ -2214,59 +2324,62 @@ func Silver_2_coin() (missKey []string) { return } } - - {//交换 - csrf,_ := c.Cookie.LoadV(`bili_jct`).(string) - if csrf == `` {apilog.L(`E: `,"Cookie错误,无bili_jct=");return} - - post_str := `csrf_token=`+csrf+`&csrf=`+csrf + + { //交换 + csrf, _ := c.Cookie.LoadV(`bili_jct`).(string) + if csrf == `` { + apilog.L(`E: `, "Cookie错误,无bili_jct=") + return + } + + post_str := `csrf_token=` + csrf + `&csrf=` + csrf Cookie := make(map[string]string) - c.Cookie.Range(func(k,v interface{})(bool){ + c.Cookie.Range(func(k, v interface{}) bool { Cookie[k.(string)] = v.(string) return true }) req := reqf.New() if err := req.Reqf(reqf.Rval{ - Url:`https://api.live.bilibili.com/xlive/revenue/v1/wallet/silver2coin`, - PostStr:url.PathEscape(post_str), - Header:map[string]string{ - `Host`: `api.live.bilibili.com`, - `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, - `Accept`: `application/json, text/plain, */*`, + Url: `https://api.live.bilibili.com/xlive/revenue/v1/wallet/silver2coin`, + PostStr: url.PathEscape(post_str), + Header: map[string]string{ + `Host`: `api.live.bilibili.com`, + `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, + `Accept`: `application/json, text/plain, */*`, `Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`, `Accept-Encoding`: `gzip, deflate, br`, - `Origin`: `https://link.bilibili.com`, - `Connection`: `keep-alive`, - `Pragma`: `no-cache`, - `Cache-Control`: `no-cache`, - `Content-Type`: `application/x-www-form-urlencoded`, - `Referer`:`https://link.bilibili.com/p/center/index`, - `Cookie`:reqf.Map_2_Cookies_String(Cookie), + `Origin`: `https://link.bilibili.com`, + `Connection`: `keep-alive`, + `Pragma`: `no-cache`, + `Cache-Control`: `no-cache`, + `Content-Type`: `application/x-www-form-urlencoded`, + `Referer`: `https://link.bilibili.com/p/center/index`, + `Cookie`: reqf.Map_2_Cookies_String(Cookie), }, - Proxy:c.Proxy, - Timeout:3*1000, - Retry:2, - });err != nil { - apilog.L(`E: `,err) + Proxy: c.Proxy, + Timeout: 3 * 1000, + Retry: 2, + }); err != nil { + apilog.L(`E: `, err) return } - + save_cookie(req.Response.Cookies()) - var res struct{ - Code int `json:"code"` - Msg string `json:"msg"` + var res struct { + Code int `json:"code"` + Msg string `json:"msg"` Message string `json:"message"` } - - if e := json.Unmarshal(req.Respon, &res);e != nil{ + + if e := json.Unmarshal(req.Respon, &res); e != nil { apilog.L(`E: `, e) return } - - if res.Code != 0{ + + if res.Code != 0 { apilog.L(`E: `, res.Message) return } @@ -2275,13 +2388,13 @@ func Silver_2_coin() (missKey []string) { return } -func save_cookie(Cookies []*http.Cookie){ - for k,v := range reqf.Cookies_List_2_Map(Cookies){ +func save_cookie(Cookies []*http.Cookie) { + for k, v := range reqf.Cookies_List_2_Map(Cookies) { c.Cookie.Store(k, v) } Cookie := make(map[string]string) - c.Cookie.Range(func(k,v interface{})(bool){ + c.Cookie.Range(func(k, v interface{}) bool { Cookie[k.(string)] = v.(string) return true }) @@ -2289,82 +2402,88 @@ func save_cookie(Cookies []*http.Cookie){ } //正在直播主播 -type UpItem struct{ - Uname string `json:"uname"` - Title string `json:"title"` - Roomid int `json:"roomid"` +type UpItem struct { + Uname string `json:"uname"` + Title string `json:"title"` + Roomid int `json:"roomid"` } + func Feed_list() (Uplist []UpItem) { - apilog := apilog.Base_add(`正在直播主播`).L(`T: `,`获取中`) + apilog := apilog.Base_add(`正在直播主播`).L(`T: `, `获取中`) //验证cookie if missKey := CookieCheck([]string{ `bili_jct`, `DedeUserID`, `LIVE_BUVID`, - });len(missKey) != 0 { - apilog.L(`T: `,`Cookie无Key:`,missKey) + }); len(missKey) != 0 { + apilog.L(`T: `, `Cookie无Key:`, missKey) return } - if api_limit.TO() {apilog.L(`E: `,`超时！`);return}//超额请求阻塞，超时将取消 + if api_limit.TO() { + apilog.L(`E: `, `超时！`) + return + } //超额请求阻塞，超时将取消 Cookie := make(map[string]string) - c.Cookie.Range(func(k,v interface{})(bool){ + c.Cookie.Range(func(k, v interface{}) bool { Cookie[k.(string)] = v.(string) return true }) req := reqf.New() - for pageNum:=1; true; pageNum+=1 { + for pageNum := 1; true; pageNum += 1 { if err := req.Reqf(reqf.Rval{ - Url:`https://api.live.bilibili.com/xlive/web-ucenter/v1/xfetter/FeedList?page=`+strconv.Itoa(pageNum)+`&pagesize=10`, - Header:map[string]string{ - `Host`: `api.live.bilibili.com`, - `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, - `Accept`: `application/json, text/plain, */*`, + Url: `https://api.live.bilibili.com/xlive/web-ucenter/v1/xfetter/FeedList?page=` + strconv.Itoa(pageNum) + `&pagesize=10`, + Header: map[string]string{ + `Host`: `api.live.bilibili.com`, + `User-Agent`: `Mozilla/5.0 (X11; Linux x86_64; rv:83.0) Gecko/20100101 Firefox/83.0`, + `Accept`: `application/json, text/plain, */*`, `Accept-Language`: `zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2`, `Accept-Encoding`: `gzip, deflate, br`, - `Origin`: `https://t.bilibili.com`, - `Connection`: `keep-alive`, - `Pragma`: `no-cache`, - `Cache-Control`: `no-cache`, - `Referer`:`https://t.bilibili.com/pages/nav/index_new`, - `Cookie`:reqf.Map_2_Cookies_String(Cookie), + `Origin`: `https://t.bilibili.com`, + `Connection`: `keep-alive`, + `Pragma`: `no-cache`, + `Cache-Control`: `no-cache`, + `Referer`: `https://t.bilibili.com/pages/nav/index_new`, + `Cookie`: reqf.Map_2_Cookies_String(Cookie), }, - Proxy:c.Proxy, - Timeout:3*1000, - Retry:2, - });err != nil { - apilog.L(`E: `,err) + Proxy: c.Proxy, + Timeout: 3 * 1000, + Retry: 2, + }); err != nil { + apilog.L(`E: `, err) return } - var res struct{ - Code int `json:"code"` - Msg string `json:"msg"` + var res struct { + Code int `json:"code"` + Msg string `json:"msg"` Message string `json:"message"` - Data struct{ - Results int `json:"results"` - List []UpItem `json:"list"` + Data struct { + Results int `json:"results"` + List []UpItem `json:"list"` } `json:"data"` } - if e := json.Unmarshal(req.Respon, &res);e != nil{ + if e := json.Unmarshal(req.Respon, &res); e != nil { apilog.L(`E: `, e) return } - if res.Code != 0{ + if res.Code != 0 { apilog.L(`E: `, res.Message) return } Uplist = append(Uplist, res.Data.List...) - if pageNum*10 > res.Data.Results {break} + if pageNum*10 > res.Data.Results { + break + } time.Sleep(time.Second) } - apilog.L(`T: `,`完成`) + apilog.L(`T: `, `完成`) return } @@ -2373,24 +2492,24 @@ func GetHistory(Roomid_int int) (j J.GetHistory) { Roomid := strconv.Itoa(Roomid_int) - {//使用其他api + { //使用其他api req := reqf.New() if err := req.Reqf(reqf.Rval{ - Url:"https://api.live.bilibili.com/xlive/web-room/v1/dM/gethistory?roomid=" + Roomid, - Header:map[string]string{ - `Referer`:"https://live.bilibili.com/" + Roomid, + Url: "https://api.live.bilibili.com/xlive/web-room/v1/dM/gethistory?roomid=" + Roomid, + Header: map[string]string{ + `Referer`: "https://live.bilibili.com/" + Roomid, }, - Proxy:c.Proxy, - Timeout:10*1000, - Retry:2, - });err != nil { - apilog.L(`E: `,err) + Proxy: c.Proxy, + Timeout: 10 * 1000, + Retry: 2, + }); err != nil { + apilog.L(`E: `, err) return } //GetHistory { - if e := json.Unmarshal(req.Respon,&j);e != nil{ + if e := json.Unmarshal(req.Respon, &j); e != nil { apilog.L(`E: `, e) return } else if j.Code != 0 { @@ -2402,25 +2521,28 @@ func GetHistory(Roomid_int int) (j J.GetHistory) { return } -type searchresult struct{ - Roomid int - Uname string +type searchresult struct { + Roomid int + Uname string Is_live bool } func SearchUP(s string) (list []searchresult) { apilog := apilog.Base_add(`搜索主播`) - if api_limit.TO() {apilog.L(`E: `,`超时！`);return}//超额请求阻塞，超时将取消 - - {//使用其他api + if api_limit.TO() { + apilog.L(`E: `, `超时！`) + return + } //超额请求阻塞，超时将取消 + + { //使用其他api req := reqf.New() if err := req.Reqf(reqf.Rval{ - Url:"https://api.bilibili.com/x/web-interface/search/type?context=&search_type=live_user&cover_type=user_cover&page=1&order=&category_id=&__refresh__=true&_extra=&highlight=1&single_column=0&keyword=" + url.PathEscape(s), - Proxy:c.Proxy, - Timeout:10*1000, - Retry:2, - });err != nil { - apilog.L(`E: `,err) + Url: "https://api.bilibili.com/x/web-interface/search/type?context=&search_type=live_user&cover_type=user_cover&page=1&order=&category_id=&__refresh__=true&_extra=&highlight=1&single_column=0&keyword=" + url.PathEscape(s), + Proxy: c.Proxy, + Timeout: 10 * 1000, + Retry: 2, + }); err != nil { + apilog.L(`E: `, err) return } @@ -2428,7 +2550,7 @@ func SearchUP(s string) (list []searchresult) { //Search { - if e := json.Unmarshal(req.Respon,&j);e != nil{ + if e := json.Unmarshal(req.Respon, &j); e != nil { apilog.L(`E: `, e) return } else if j.Code != 0 { @@ -2438,15 +2560,16 @@ func SearchUP(s string) (list []searchresult) { } if j.Data.Numresults == 0 { - apilog.L(`I: `,`没有匹配`);return + apilog.L(`I: `, `没有匹配`) + return } - for i:=0;i`,``) - uname = strings.ReplaceAll(uname, ``,``) + for i := 0; i < len(j.Data.Result); i += 1 { + uname := strings.ReplaceAll(j.Data.Result[i].Uname, ``, ``) + uname = strings.ReplaceAll(uname, ``, ``) list = append(list, searchresult{ - Roomid: j.Data.Result[i].Roomid, - Uname: uname, + Roomid: j.Data.Result[i].Roomid, + Uname: uname, Is_live: j.Data.Result[i].IsLive, }) } @@ -2458,28 +2581,29 @@ func SearchUP(s string) (list []searchresult) { func KeepConnect() { for !IsConnected() { - time.Sleep(time.Duration(30)*time.Second) + time.Sleep(time.Duration(30) * time.Second) } - return } func IsConnected() bool { apilog := apilog.Base_add(`IsConnected`) - v,ok := c.K_v.LoadV(`网络中断不退出`).(bool) - if !ok || !v {return true} + v, ok := c.K_v.LoadV(`网络中断不退出`).(bool) + if !ok || !v { + return true + } req := reqf.New() if err := req.Reqf(reqf.Rval{ - Url:"https://www.bilibili.com", - Proxy:c.Proxy, - Timeout:10*1000, - JustResponseCode:true, - });err != nil { - apilog.L(`W: `,`网络中断`,err) + Url: "https://www.bilibili.com", + Proxy: c.Proxy, + Timeout: 10 * 1000, + JustResponseCode: true, + }); err != nil { + apilog.L(`W: `, `网络中断`, err) return false } - apilog.L(`T: `,`已连接`) + apilog.L(`T: `, `已连接`) return true -} \ No newline at end of file +} -- 2.39.2