最新 肥羊的4K/8K超高清IPTV直播源&&直播代码仓库
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 

191 lines
6.6 KiB

// Package Golang
// @Time:2024/02/19 11:30
// @File:main.go
// @SoftWare:Goland
// @Author:feiyang
// @Contact:TG@feiyangdigital
package main
import (
"Golang/list"
"Golang/liveurls"
"encoding/base64"
"encoding/json"
"fmt"
"github.com/forgoer/openssl"
"github.com/gin-gonic/gin"
"net/http"
"net/url"
"strconv"
"time"
)
func duanyan(adurl string, realurl any) string {
var liveurl string
if str, ok := realurl.(string); ok {
liveurl = str
} else {
liveurl = adurl
}
return liveurl
}
func getTestVideoUrl(c *gin.Context) {
TimeLocation, err := time.LoadLocation("Asia/Shanghai")
if err != nil {
TimeLocation = time.FixedZone("CST", 8*60*60)
}
str_time := time.Now().In(TimeLocation).Format("2006-01-02 15:04:05")
fmt.Fprintln(c.Writer, "#EXTM3U")
fmt.Fprintln(c.Writer, "#EXTINF:-1 tvg-name=\""+str_time+"\" tvg-logo=\"https://cdn.jsdelivr.net/gh/youshandefeiyang/IPTV/logo/tg.jpg\" group-title=\"列表更新时间\","+str_time)
fmt.Fprintln(c.Writer, "https://cdn.jsdelivr.net/gh/youshandefeiyang/testvideo/time/time.mp4")
fmt.Fprintln(c.Writer, "#EXTINF:-1 tvg-name=\"4K60PSDR-H264-AAC测试\" tvg-logo=\"https://cdn.jsdelivr.net/gh/youshandefeiyang/IPTV/logo/tg.jpg\" group-title=\"4K频道\",4K60PSDR-H264-AAC测试")
fmt.Fprintln(c.Writer, "http://159.75.85.63:5680/d/ad/h264/playad.m3u8")
fmt.Fprintln(c.Writer, "#EXTINF:-1 tvg-name=\"4K60PHLG-HEVC-EAC3测试\" tvg-logo=\"https://cdn.jsdelivr.net/gh/youshandefeiyang/IPTV/logo/tg.jpg\" group-title=\"4K频道\",4K60PHLG-HEVC-EAC3测试")
fmt.Fprintln(c.Writer, "http://159.75.85.63:5680/d/ad/playad.m3u8")
}
func getLivePrefix(c *gin.Context) string {
firstUrl := c.DefaultQuery("url", "https://www.goodiptv.club")
realUrl, _ := url.QueryUnescape(firstUrl)
return realUrl
}
func setupRouter(adurl string) *gin.Engine {
gin.SetMode(gin.ReleaseMode)
r := gin.Default()
r.HEAD("/", func(c *gin.Context) {
c.String(http.StatusOK, "请求成功!")
})
r.GET("/", func(c *gin.Context) {
c.String(http.StatusOK, "请求成功!")
})
r.GET("/huyayqk.m3u", func(c *gin.Context) {
yaobj := &list.HuyaYqk{}
res, _ := yaobj.HuYaYqk("https://live.cdn.huya.com/liveHttpUI/getLiveList?iGid=2135")
var result list.YaResponse
json.Unmarshal(res, &result)
pageCount := result.ITotalPage
pageSize := result.IPageSize
c.Writer.Header().Set("Content-Type", "application/octet-stream")
c.Writer.Header().Set("Content-Disposition", "attachment; filename=huyayqk.m3u")
getTestVideoUrl(c)
for i := 1; i <= pageCount; i++ {
apiRes, _ := yaobj.HuYaYqk(fmt.Sprintf("https://live.cdn.huya.com/liveHttpUI/getLiveList?iGid=2135&iPageNo=%d&iPageSize=%d", i, pageSize))
var res list.YaResponse
json.Unmarshal(apiRes, &res)
data := res.VList
for _, value := range data {
fmt.Fprintf(c.Writer, "#EXTINF:-1 tvg-logo=\"%s\" group-title=\"%s\", %s\n", value.SAvatar180, value.SGameFullName, value.SNick)
fmt.Fprintf(c.Writer, "%s/huya/%v\n", getLivePrefix(c), value.LProfileRoom)
}
}
})
r.GET("/douyuyqk.m3u", func(c *gin.Context) {
yuobj := &list.DouYuYqk{}
resAPI, _ := yuobj.Douyuyqk("https://www.douyu.com/gapi/rkc/directory/mixList/2_208/list")
var result list.DouYuResponse
json.Unmarshal(resAPI, &result)
pageCount := result.Data.Pgcnt
c.Writer.Header().Set("Content-Type", "application/octet-stream")
c.Writer.Header().Set("Content-Disposition", "attachment; filename=douyuyqk.m3u")
getTestVideoUrl(c)
for i := 1; i <= pageCount; i++ {
apiRes, _ := yuobj.Douyuyqk("https://www.douyu.com/gapi/rkc/directory/mixList/2_208/" + strconv.Itoa(i))
var res list.DouYuResponse
json.Unmarshal(apiRes, &res)
data := res.Data.Rl
for _, value := range data {
fmt.Fprintf(c.Writer, "#EXTINF:-1 tvg-logo=\"https://apic.douyucdn.cn/upload/%s_big.jpg\" group-title=\"%s\", %s\n", value.Av, value.C2name, value.Nn)
fmt.Fprintf(c.Writer, "%s/douyu/%v\n", getLivePrefix(c), value.Rid)
}
}
})
r.GET("/yylunbo.m3u", func(c *gin.Context) {
yylistobj := &list.Yylist{}
c.Writer.Header().Set("Content-Type", "application/octet-stream")
c.Writer.Header().Set("Content-Disposition", "attachment; filename=yylunbo.m3u")
getTestVideoUrl(c)
i := 1
for {
apiRes := yylistobj.Yylb(fmt.Sprintf("http://rubiks-ipad.yy.com/nav/other/idx/213?channel=appstore&ispType=0&model=iPad8,6&netType=2&os=iOS&osVersion=17.2&page=%d&uid=0&yyVersion=6.17.0", i))
var res list.ApiResponse
json.Unmarshal([]byte(apiRes), &res)
for _, value := range res.Data.Data {
fmt.Fprintf(c.Writer, "#EXTINF:-1 tvg-logo=\"%s\" group-title=\"%s\", %s\n", value.Avatar, value.Biz, value.Desc)
fmt.Fprintf(c.Writer, "%s/yy/%v\n", getLivePrefix(c), value.Sid)
}
if res.Data.IsLastPage == 1 {
break
}
i++
}
})
r.GET("/:path/:rid", func(c *gin.Context) {
path := c.Param("path")
rid := c.Param("rid")
switch path {
case "douyin":
douyinobj := &liveurls.Douyin{}
douyinobj.Rid = rid
douyinobj.Stream = c.DefaultQuery("stream", "flv")
c.Redirect(http.StatusMovedPermanently, duanyan(adurl, douyinobj.GetDouYinUrl()))
case "douyu":
douyuobj := &liveurls.Douyu{}
douyuobj.Rid = rid
douyuobj.Stream_type = c.DefaultQuery("stream", "flv")
c.Redirect(http.StatusMovedPermanently, duanyan(adurl, douyuobj.GetRealUrl()))
case "huya":
huyaobj := &liveurls.Huya{}
huyaobj.Rid = rid
huyaobj.Cdn = c.DefaultQuery("cdn", "hwcdn")
huyaobj.Media = c.DefaultQuery("media", "flv")
huyaobj.Type = c.DefaultQuery("type", "nodisplay")
if huyaobj.Type == "display" {
c.JSON(200, huyaobj.GetLiveUrl())
} else {
c.Redirect(http.StatusMovedPermanently, duanyan(adurl, huyaobj.GetLiveUrl()))
}
case "bilibili":
biliobj := &liveurls.BiliBili{}
biliobj.Rid = rid
biliobj.Platform = c.DefaultQuery("platform", "web")
biliobj.Quality = c.DefaultQuery("quality", "10000")
biliobj.Line = c.DefaultQuery("line", "first")
c.Redirect(http.StatusMovedPermanently, duanyan(adurl, biliobj.GetPlayUrl()))
case "youtube":
ytbObj := &liveurls.Youtube{}
ytbObj.Rid = rid
ytbObj.Quality = c.DefaultQuery("quality", "1080")
c.Redirect(http.StatusMovedPermanently, duanyan(adurl, ytbObj.GetLiveUrl()))
case "yy":
yyObj := &liveurls.Yy{}
yyObj.Rid = rid
yyObj.Quality = c.DefaultQuery("quality", "4")
c.Redirect(http.StatusMovedPermanently, duanyan(adurl, yyObj.GetLiveUrl()))
}
})
return r
}
func main() {
key := []byte("6354127897263145")
defstr, _ := base64.StdEncoding.DecodeString("NGrrC9lxtd9O7ezMt3Ux2ekGkOyBoF9ipw9yqKFuItF/MwEBuKVN7GFoMAtaISCb/ouyeQUklFlqsCqGYOZwBx54INVxoDeMgQuEWQqETsCfL497FXvdiMOgS0buq74L")
defurl, _ := openssl.AesECBDecrypt(defstr, key, openssl.PKCS7_PADDING)
r := setupRouter(string(defurl))
r.Run(":35455")
}