mirror of
https://github.com/lizongying/my-tv.git
synced 2026-10-26 14:16:29 +08:00
839 lines
41 KiB
Kotlin
839 lines
41 KiB
Kotlin
package com.lizongying.mytv
|
|
|
|
import android.os.Handler
|
|
import android.os.Looper
|
|
import android.util.Base64
|
|
import android.util.Log
|
|
import com.google.gson.Gson
|
|
import java.net.URLDecoder
|
|
import com.lizongying.mytv.Utils.getDateFormat
|
|
import com.lizongying.mytv.api.ApiClient
|
|
import com.lizongying.mytv.api.Auth
|
|
import com.lizongying.mytv.api.AuthRequest
|
|
import com.lizongying.mytv.api.FAuth
|
|
import com.lizongying.mytv.api.FAuthService
|
|
import com.lizongying.mytv.api.FEPG
|
|
import com.lizongying.mytv.api.Info
|
|
import com.lizongying.mytv.api.InfoV2
|
|
import com.lizongying.mytv.api.KvcollectRequest
|
|
import com.lizongying.mytv.api.KvcollectRequest2
|
|
import com.lizongying.mytv.api.LiveInfo
|
|
import com.lizongying.mytv.api.LiveInfoRequest
|
|
import com.lizongying.mytv.api.YSP
|
|
import com.lizongying.mytv.api.YSPApiService
|
|
import com.lizongying.mytv.api.YSPBtraceService
|
|
import com.lizongying.mytv.api.YSPJceService
|
|
import com.lizongying.mytv.api.YSPProtoService
|
|
import com.lizongying.mytv.api.YSPTokenService
|
|
import com.lizongying.mytv.models.TVViewModel
|
|
import com.lizongying.mytv.proto.Ysp.cn.yangshipin.oms.common.proto.pageModel
|
|
import com.lizongying.mytv.proto.Ysp.cn.yangshipin.omstv.common.proto.epgProgramModel
|
|
import com.tencent.videolite.android.datamodel.cctvjce.TVTimeShiftProgramRequest
|
|
import com.tencent.videolite.android.datamodel.cctvjce.TVTimeShiftProgramResponse
|
|
import retrofit2.Call
|
|
import retrofit2.Callback
|
|
import retrofit2.Response
|
|
import javax.crypto.Cipher
|
|
import javax.crypto.spec.IvParameterSpec
|
|
import javax.crypto.spec.SecretKeySpec
|
|
import kotlin.random.Random
|
|
|
|
|
|
object Request {
|
|
private const val TAG = "Request"
|
|
private var yspTokenService: YSPTokenService = ApiClient().yspTokenService
|
|
private var yspApiService: YSPApiService = ApiClient().yspApiService
|
|
private var yspBtraceService: YSPBtraceService = ApiClient().yspBtraceService
|
|
private var yspBtraceService2: YSPBtraceService = ApiClient().yspBtraceService2
|
|
private var yspBtraceService3: YSPBtraceService = ApiClient().yspBtraceService3
|
|
private var yspProtoService: YSPProtoService = ApiClient().yspProtoService
|
|
private var yspJceService: YSPJceService = ApiClient().yspJceService
|
|
private var fAuthService: FAuthService = ApiClient().fAuthService
|
|
|
|
private var openid = ""
|
|
private var token = ""
|
|
private var tokenFH = ""
|
|
|
|
private var needAuth = false
|
|
private var needToken = false
|
|
|
|
private val handler = Handler(Looper.getMainLooper())
|
|
private lateinit var btraceRunnable: BtraceRunnable
|
|
|
|
private val regex = Regex("""des_key = "([^"]+).+var des_iv = "([^"]+)""")
|
|
private val input =
|
|
"""{"mver":"1","subver":"1.2","host":"www.yangshipin.cn/#/tv/home?pid=","referer":"","canvas":"YSPANGLE(Apple,ANGLEMetalRenderer:AppleM1Pro,UnspecifiedVersion)"}""".toByteArray()
|
|
|
|
private var listener: RequestListener? = null
|
|
|
|
private var initRetryTimes = 0
|
|
private var initRetryMaxTimes = 0
|
|
|
|
fun onDestroy() {
|
|
Log.i(TAG, "onDestroy")
|
|
}
|
|
|
|
private var call: Call<LiveInfo>? = null
|
|
private var callAuth: Call<Auth>? = null
|
|
private var callInfo: Call<Info>? = null
|
|
private var callFAuth: Call<FAuth>? = null
|
|
private var callPage: Call<pageModel.Response>? = null
|
|
|
|
private var callBtracePage: Call<Void>? = null
|
|
|
|
private fun cancelCall() {
|
|
call?.cancel()
|
|
callAuth?.cancel()
|
|
callInfo?.cancel()
|
|
callFAuth?.cancel()
|
|
callPage?.cancel()
|
|
}
|
|
|
|
private fun fetchAuth(tvModel: TVViewModel, cookie: String) {
|
|
cancelCall()
|
|
|
|
val title = tvModel.getTV().title
|
|
|
|
val data = YSP.getAuthData(tvModel)
|
|
val request = AuthRequest(data)
|
|
callAuth = request.let { yspApiService.getAuth("guid=${YSP.getGuid()}; $cookie", it) }
|
|
callAuth?.enqueue(object : Callback<Auth> {
|
|
override fun onResponse(call: Call<Auth>, response: Response<Auth>) {
|
|
if (response.isSuccessful) {
|
|
val liveInfo = response.body()
|
|
|
|
if (liveInfo?.data?.token != null) {
|
|
Log.i(TAG, "token ${liveInfo.data.token}")
|
|
YSP.token = liveInfo.data.token
|
|
fetchVideo(tvModel, cookie)
|
|
} else {
|
|
Log.e(TAG, "$title token error")
|
|
if (tvModel.retryTimes < tvModel.retryMaxTimes) {
|
|
tvModel.retryTimes++
|
|
if (tvModel.getTV().needToken) {
|
|
if (needToken && tvModel.tokenYSPRetryTimes < tvModel.tokenYSPRetryMaxTimes) {
|
|
tvModel.tokenYSPRetryTimes++
|
|
tvModel.needGetToken = true
|
|
fetchAuth(tvModel)
|
|
} else {
|
|
if (!tvModel.getTV().mustToken) {
|
|
fetchAuth(tvModel, cookie)
|
|
}
|
|
}
|
|
} else {
|
|
fetchAuth(tvModel, cookie)
|
|
}
|
|
}
|
|
}
|
|
} else {
|
|
Log.e(TAG, "$title auth status error")
|
|
if (tvModel.retryTimes < tvModel.retryMaxTimes) {
|
|
tvModel.retryTimes++
|
|
if (tvModel.getTV().needToken) {
|
|
if (needToken && tvModel.tokenYSPRetryTimes < tvModel.tokenYSPRetryMaxTimes) {
|
|
tvModel.tokenYSPRetryTimes++
|
|
tvModel.needGetToken = true
|
|
fetchAuth(tvModel)
|
|
} else {
|
|
if (!tvModel.getTV().mustToken) {
|
|
fetchAuth(tvModel, cookie)
|
|
}
|
|
}
|
|
} else {
|
|
fetchAuth(tvModel, cookie)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
override fun onFailure(call: Call<Auth>, t: Throwable) {
|
|
Log.e(TAG, "$title auth request error $t")
|
|
if (tvModel.retryTimes < tvModel.retryMaxTimes) {
|
|
tvModel.retryTimes++
|
|
if (tvModel.getTV().needToken) {
|
|
if (needToken && tvModel.tokenYSPRetryTimes < tvModel.tokenYSPRetryMaxTimes) {
|
|
tvModel.tokenYSPRetryTimes++
|
|
tvModel.needGetToken = true
|
|
fetchAuth(tvModel)
|
|
} else {
|
|
if (!tvModel.getTV().mustToken) {
|
|
fetchAuth(tvModel, cookie)
|
|
}
|
|
}
|
|
} else {
|
|
fetchAuth(tvModel, cookie)
|
|
}
|
|
}
|
|
}
|
|
})
|
|
}
|
|
|
|
private fun fetchVideo(tvModel: TVViewModel, cookie: String) {
|
|
cancelCall()
|
|
|
|
if (::btraceRunnable.isInitialized) {
|
|
handler.removeCallbacks(btraceRunnable)
|
|
}
|
|
|
|
val title = tvModel.getTV().title
|
|
|
|
tvModel.seq = 0
|
|
val data = YSP.switch(tvModel)
|
|
val request = LiveInfoRequest(data)
|
|
call = request.let {
|
|
yspApiService.getLiveInfo(
|
|
"guid=${YSP.getGuid()}; $cookie",
|
|
YSP.token,
|
|
it
|
|
)
|
|
}
|
|
|
|
call?.enqueue(object : Callback<LiveInfo> {
|
|
override fun onResponse(call: Call<LiveInfo>, response: Response<LiveInfo>) {
|
|
if (response.isSuccessful) {
|
|
val liveInfo = response.body()
|
|
|
|
if (liveInfo?.data?.playurl != null) {
|
|
val chanll = liveInfo.data.chanll
|
|
val decodedBytes = Base64.decode(
|
|
chanll.substring(9, chanll.length - 3),
|
|
Base64.DEFAULT
|
|
)
|
|
val decodedString = String(decodedBytes)
|
|
val matchResult = regex.find(decodedString)
|
|
if (matchResult != null) {
|
|
val (key, iv) = matchResult.destructured
|
|
val keyBytes = Base64.decode(key, Base64.DEFAULT)
|
|
val ivBytes = Base64.decode(iv, Base64.DEFAULT)
|
|
val url = liveInfo.data.playurl + "&revoi=" + encryptTripleDES(
|
|
keyBytes + byteArrayOf(0, 0, 0, 0, 0, 0, 0, 0),
|
|
ivBytes
|
|
).uppercase() + liveInfo.data.extended_param
|
|
Log.d(TAG, "$title url $url")
|
|
tvModel.addVideoUrl(url)
|
|
tvModel.allReady()
|
|
tvModel.retryTimes = 0
|
|
btraceRunnable = BtraceRunnable(tvModel)
|
|
handler.post(btraceRunnable)
|
|
} else {
|
|
Log.e(TAG, "$title key error")
|
|
if (tvModel.retryTimes < tvModel.retryMaxTimes) {
|
|
tvModel.retryTimes++
|
|
if (tvModel.getTV().needToken) {
|
|
if (needToken && tvModel.tokenYSPRetryTimes < tvModel.tokenYSPRetryMaxTimes) {
|
|
tvModel.tokenYSPRetryTimes++
|
|
tvModel.needGetToken = true
|
|
fetchVideo(tvModel)
|
|
// fetchAuth(tvModel)
|
|
} else {
|
|
if (!tvModel.getTV().mustToken) {
|
|
fetchVideo(tvModel, cookie)
|
|
// fetchAuth(tvModel, cookie)
|
|
}
|
|
}
|
|
} else {
|
|
fetchVideo(tvModel, cookie)
|
|
// fetchAuth(tvModel, cookie)
|
|
}
|
|
}
|
|
}
|
|
} else {
|
|
if (liveInfo?.data?.errinfo != null && liveInfo.data.errinfo == "应版权方要求，暂停提供直播信号，请点击观看其他精彩节目") {
|
|
Log.e(TAG, "$title error ${liveInfo.data.errinfo}")
|
|
tvModel.setErrInfo(liveInfo.data.errinfo)
|
|
} else {
|
|
Log.e(TAG, "$title url error $request $liveInfo")
|
|
if (tvModel.retryTimes < tvModel.retryMaxTimes) {
|
|
tvModel.retryTimes++
|
|
if (tvModel.getTV().needToken) {
|
|
if (needToken && tvModel.tokenYSPRetryTimes < tvModel.tokenYSPRetryMaxTimes) {
|
|
tvModel.tokenYSPRetryTimes++
|
|
tvModel.needGetToken = true
|
|
fetchVideo(tvModel)
|
|
// fetchAuth(tvModel)
|
|
} else {
|
|
if (!tvModel.getTV().mustToken) {
|
|
fetchVideo(tvModel, cookie)
|
|
// fetchAuth(tvModel, cookie)
|
|
}
|
|
}
|
|
} else {
|
|
fetchVideo(tvModel, cookie)
|
|
// fetchAuth(tvModel, cookie)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
} else {
|
|
Log.e(TAG, "$title status error $data")
|
|
if (tvModel.retryTimes < tvModel.retryMaxTimes) {
|
|
tvModel.retryTimes++
|
|
if (tvModel.getTV().needToken) {
|
|
if (needToken && tvModel.tokenYSPRetryTimes < tvModel.tokenYSPRetryMaxTimes) {
|
|
tvModel.tokenYSPRetryTimes++
|
|
tvModel.needGetToken = true
|
|
fetchVideo(tvModel)
|
|
// fetchAuth(tvModel)
|
|
} else {
|
|
if (!tvModel.getTV().mustToken) {
|
|
fetchVideo(tvModel, cookie)
|
|
// fetchAuth(tvModel, cookie)
|
|
}
|
|
}
|
|
} else {
|
|
fetchVideo(tvModel, cookie)
|
|
// fetchAuth(tvModel, cookie)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
override fun onFailure(call: Call<LiveInfo>, t: Throwable) {
|
|
Log.e(TAG, "$title fetchVideo request error $t")
|
|
if (tvModel.retryTimes < tvModel.retryMaxTimes) {
|
|
tvModel.retryTimes++
|
|
if (tvModel.getTV().needToken) {
|
|
if (needToken && tvModel.tokenYSPRetryTimes < tvModel.tokenYSPRetryMaxTimes) {
|
|
tvModel.tokenYSPRetryTimes++
|
|
tvModel.needGetToken = true
|
|
fetchVideo(tvModel)
|
|
} else {
|
|
if (!tvModel.getTV().mustToken) {
|
|
fetchVideo(tvModel, cookie)
|
|
}
|
|
}
|
|
} else {
|
|
fetchVideo(tvModel, cookie)
|
|
}
|
|
}
|
|
}
|
|
})
|
|
}
|
|
|
|
private fun fetchAuth(tvModel: TVViewModel) {
|
|
cancelCall()
|
|
if (tvModel.needGetToken) {
|
|
callInfo = yspTokenService.getInfo("")
|
|
callInfo?.enqueue(object : Callback<Info> {
|
|
override fun onResponse(call: Call<Info>, response: Response<Info>) {
|
|
if (response.isSuccessful && response.body()?.data?.token != null) {
|
|
token = response.body()?.data?.token!!
|
|
Log.i(TAG, "info success $token")
|
|
tvModel.needGetToken = false
|
|
tvModel.tokenYSPRetryTimes = 0
|
|
val cookie =
|
|
"versionName=99.99.99; versionCode=999999; vplatform=109; platformVersion=Chrome; deviceModel=120; appid=1400421205; yspappid=519748109;yspopenid=$openid; vusession=$token"
|
|
fetchAuth(tvModel, cookie)
|
|
} else if (response.code() == 304) {
|
|
tvModel.needGetToken = false
|
|
tvModel.tokenYSPRetryTimes = 0
|
|
val cookie =
|
|
"versionName=99.99.99; versionCode=999999; vplatform=109; platformVersion=Chrome; deviceModel=120; appid=1400421205; yspappid=519748109; yspopenid=$openid; vusession=$token"
|
|
fetchVideo(tvModel, cookie)
|
|
} else {
|
|
Log.e(TAG, "info status error")
|
|
if (tvModel.tokenYSPRetryTimes < tvModel.tokenYSPRetryMaxTimes) {
|
|
tvModel.tokenYSPRetryTimes++
|
|
fetchAuth(tvModel)
|
|
} else {
|
|
if (!tvModel.getTV().mustToken) {
|
|
val cookie =
|
|
"versionName=99.99.99; versionCode=999999; vplatform=109; platformVersion=Chrome; deviceModel=120; appid=1400421205; yspappid=519748109"
|
|
fetchAuth(tvModel, cookie)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
override fun onFailure(call: Call<Info>, t: Throwable) {
|
|
Log.e(TAG, "info request error $t")
|
|
if (tvModel.tokenYSPRetryTimes < tvModel.tokenYSPRetryMaxTimes) {
|
|
tvModel.tokenYSPRetryTimes++
|
|
fetchVideo(tvModel)
|
|
} else {
|
|
if (!tvModel.getTV().mustToken) {
|
|
val cookie =
|
|
"versionName=99.99.99; versionCode=999999; vplatform=109; platformVersion=Chrome; deviceModel=120; appid=1400421205; yspappid=519748109"
|
|
fetchAuth(tvModel, cookie)
|
|
}
|
|
}
|
|
}
|
|
})
|
|
} else {
|
|
val cookie =
|
|
"versionName=99.99.99; versionCode=999999; vplatform=109; platformVersion=Chrome; deviceModel=120; appid=1400421205; yspappid=519748109;yspopenid=$openid; vusession=$token"
|
|
fetchAuth(tvModel, cookie)
|
|
}
|
|
}
|
|
|
|
private fun fetchVideo(tvModel: TVViewModel) {
|
|
cancelCall()
|
|
Log.d(TAG, "fetchVideo")
|
|
if (tvModel.needGetToken) {
|
|
callInfo = yspTokenService.getInfo("")
|
|
callInfo?.enqueue(object : Callback<Info> {
|
|
override fun onResponse(call: Call<Info>, response: Response<Info>) {
|
|
if (response.isSuccessful && response.body()?.data?.token != null) {
|
|
token = response.body()?.data?.token!!
|
|
Log.i(TAG, "info success $token")
|
|
tvModel.needGetToken = false
|
|
tvModel.tokenYSPRetryTimes = 0
|
|
val cookie =
|
|
"versionName=99.99.99; versionCode=999999; vplatform=109; platformVersion=Chrome; deviceModel=120; appid=1400421205; yspappid=519748109; yspopenid=$openid; vusession=$token"
|
|
fetchVideo(tvModel, cookie)
|
|
} else if (response.code() == 304) {
|
|
tvModel.needGetToken = false
|
|
tvModel.tokenYSPRetryTimes = 0
|
|
val cookie =
|
|
"versionName=99.99.99; versionCode=999999; vplatform=109; platformVersion=Chrome; deviceModel=120; appid=1400421205; yspappid=519748109; yspopenid=$openid; vusession=$token"
|
|
fetchVideo(tvModel, cookie)
|
|
} else {
|
|
Log.e(TAG, "info status error")
|
|
if (tvModel.tokenYSPRetryTimes < tvModel.tokenYSPRetryMaxTimes) {
|
|
tvModel.tokenYSPRetryTimes++
|
|
fetchVideo(tvModel)
|
|
} else {
|
|
if (!tvModel.getTV().mustToken) {
|
|
val cookie =
|
|
"versionName=99.99.99; versionCode=999999; vplatform=109; platformVersion=Chrome; deviceModel=120; appid=1400421205; yspappid=519748109"
|
|
fetchVideo(tvModel, cookie)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
override fun onFailure(call: Call<Info>, t: Throwable) {
|
|
Log.e(TAG, "info request error $t")
|
|
if (tvModel.tokenYSPRetryTimes < tvModel.tokenYSPRetryMaxTimes) {
|
|
tvModel.tokenYSPRetryTimes++
|
|
fetchVideo(tvModel)
|
|
} else {
|
|
if (!tvModel.getTV().mustToken) {
|
|
val cookie =
|
|
"versionName=99.99.99; versionCode=999999; vplatform=109; platformVersion=Chrome; deviceModel=120; appid=1400421205; yspappid=519748109"
|
|
fetchVideo(tvModel, cookie)
|
|
}
|
|
}
|
|
}
|
|
})
|
|
} else {
|
|
val cookie =
|
|
"versionName=99.99.99; versionCode=999999; vplatform=109; platformVersion=Chrome; deviceModel=120; appid=1400421205; yspappid=519748109; yspopenid=$openid; vusession=$token"
|
|
fetchVideo(tvModel, cookie)
|
|
}
|
|
}
|
|
|
|
private fun fetchFAuth(tvModel: TVViewModel) {
|
|
cancelCall()
|
|
|
|
val title = tvModel.getTV().title
|
|
|
|
var qa = "HD"
|
|
if (tokenFH != "") {
|
|
qa = "FHD"
|
|
}
|
|
|
|
callFAuth = fAuthService.getAuth(tokenFH, tvModel.getTV().pid, qa)
|
|
callFAuth?.enqueue(object : Callback<FAuth> {
|
|
override fun onResponse(call: Call<FAuth>, response: Response<FAuth>) {
|
|
if (response.isSuccessful && response.body()?.data?.live_url != null) {
|
|
val url = response.body()?.data?.live_url!!
|
|
// Log.d(TAG, "$title url $url")
|
|
tvModel.addVideoUrl(url)
|
|
tvModel.allReady()
|
|
tvModel.tokenFHRetryTimes = 0
|
|
} else {
|
|
Log.e(TAG, "auth status error ${response.code()}")
|
|
if (tvModel.tokenFHRetryTimes < tvModel.tokenFHRetryMaxTimes) {
|
|
tvModel.tokenFHRetryTimes++
|
|
fetchFAuth(tvModel)
|
|
}
|
|
}
|
|
}
|
|
|
|
override fun onFailure(call: Call<FAuth>, t: Throwable) {
|
|
Log.e(TAG, "auth request error $t")
|
|
if (tvModel.tokenFHRetryTimes < tvModel.tokenFHRetryMaxTimes) {
|
|
tvModel.tokenFHRetryTimes++
|
|
fetchFAuth(tvModel)
|
|
}
|
|
}
|
|
})
|
|
}
|
|
|
|
fun fetchData(tvModel: TVViewModel) {
|
|
if (tvModel.getTV().channel == "港澳台") {
|
|
fetchFAuth(tvModel)
|
|
return
|
|
}
|
|
|
|
if (needToken && tvModel.getTV().needToken) {
|
|
if (token == "") {
|
|
tvModel.needGetToken = true
|
|
}
|
|
if (needAuth) {
|
|
fetchAuth(tvModel)
|
|
} else {
|
|
fetchVideo(tvModel)
|
|
}
|
|
} else {
|
|
val cookie =
|
|
"versionName=99.99.99; versionCode=999999; vplatform=109; platformVersion=Chrome; updateProtocol=1; deviceModel=120"
|
|
if (needAuth) {
|
|
fetchAuth(tvModel, cookie)
|
|
} else {
|
|
fetchVideo(tvModel, cookie)
|
|
}
|
|
}
|
|
}
|
|
|
|
private fun fetchInfoV2() {
|
|
yspTokenService.getInfoV2()
|
|
.enqueue(object : Callback<InfoV2> {
|
|
override fun onResponse(call: Call<InfoV2>, response: Response<InfoV2>) {
|
|
if (response.isSuccessful) {
|
|
val o = response.body()?.o
|
|
val t = response.body()?.t
|
|
val f = response.body()?.f
|
|
val e = response.body()?.e
|
|
val c = response.body()?.c
|
|
if (!o.isNullOrEmpty()) {
|
|
openid = o
|
|
}
|
|
if (!t.isNullOrEmpty()) {
|
|
token = t
|
|
Log.i(TAG, "token success $token")
|
|
}
|
|
if (!f.isNullOrEmpty()) {
|
|
tokenFH = f
|
|
Log.i(TAG, "tokenFH success $tokenFH")
|
|
}
|
|
if (c != null) {
|
|
Utils.setBetween(c * 1000L)
|
|
Log.i(TAG, "current time $c")
|
|
}
|
|
listener?.onRequestFinished(null)
|
|
} else {
|
|
Log.e(TAG, "token status error")
|
|
if (initRetryTimes < initRetryMaxTimes) {
|
|
initRetryTimes++
|
|
fetchInfoV2()
|
|
} else {
|
|
listener?.onRequestFinished("状态错误")
|
|
}
|
|
}
|
|
}
|
|
|
|
override fun onFailure(call: Call<InfoV2>, t: Throwable) {
|
|
Log.e(TAG, "token request error $t")
|
|
if (initRetryTimes < initRetryMaxTimes) {
|
|
initRetryTimes++
|
|
fetchInfoV2()
|
|
} else {
|
|
listener?.onRequestFinished("网络错误")
|
|
}
|
|
}
|
|
})
|
|
}
|
|
|
|
class BtraceRunnable(private val tvModel: TVViewModel) : Runnable {
|
|
override fun run() {
|
|
fetchBtrace3(tvModel)
|
|
}
|
|
}
|
|
|
|
fun fetchBtrace(tvModel: TVViewModel) {
|
|
callBtracePage?.cancel()
|
|
val title = tvModel.getTV().title
|
|
|
|
val guid = YSP.getGuid()
|
|
val pid = tvModel.getTV().pid
|
|
val sid = tvModel.getTV().sid
|
|
callBtracePage = yspBtraceService.kvcollect(
|
|
c_timestamp = YSP.generateGuid(),
|
|
guid = guid,
|
|
c_guid = guid,
|
|
prog = sid,
|
|
viewid = sid,
|
|
fpid = pid,
|
|
livepid = pid,
|
|
sUrl = "https://www.yangshipin.cn/#/tv/home?pid=$pid",
|
|
playno = YSP.getRand(),
|
|
ftime = getDateFormat("yyyy-MM-dd HH:mm:ss"),
|
|
seq = tvModel.seq.toString(),
|
|
)
|
|
callBtracePage?.enqueue(object : Callback<Void> {
|
|
override fun onResponse(call: Call<Void>, response: Response<Void>) {
|
|
if (response.isSuccessful) {
|
|
Log.d(TAG, "$title kvcollect success")
|
|
} else {
|
|
Log.e(TAG, "$title kvcollect status error")
|
|
}
|
|
handler.postDelayed(btraceRunnable, 60 * 1000)
|
|
}
|
|
|
|
override fun onFailure(call: Call<Void>, t: Throwable) {
|
|
Log.e(TAG, "$title kvcollect request error")
|
|
handler.postDelayed(btraceRunnable, 60 * 1000)
|
|
}
|
|
})
|
|
tvModel.seq++
|
|
}
|
|
|
|
fun fetchBtrace2(tvModel: TVViewModel) {
|
|
callBtracePage?.cancel()
|
|
val title = tvModel.getTV().title
|
|
|
|
val guid = YSP.getGuid()
|
|
val pid = tvModel.getTV().pid
|
|
val sid = tvModel.getTV().sid
|
|
val randomNumber = Random.nextDouble()
|
|
val url = tvModel.getTV().videoUrl.first()
|
|
|
|
var r = KvcollectRequest(
|
|
guid = guid,
|
|
prog = sid,
|
|
viewid = sid,
|
|
livepid = pid,
|
|
sUrl = "https://www.yangshipin.cn/#/tv/home?pid=$pid",
|
|
playno = YSP.getRand(),
|
|
rand_str = YSP.getRand(),
|
|
ftime = getDateFormat("yyyy-MM-dd HH:mm:ss"),
|
|
seq = tvModel.seq,
|
|
durl = url,
|
|
url = url,
|
|
_dc = randomNumber,
|
|
)
|
|
|
|
var e =
|
|
"BossId=${r.BossId}&Pwd=${r.Pwd}&_dc=${r._dc}&cdn=${r.cdn}&cmd=${r.cmd}&defn=${r.defn}&downspeed=${r.downspeed}&durl=${r.durl}&errcode=${r.errcode}&fact1=${r.fact1}&firstreport=${r.firstreport}&fplayerver=${r.fplayerver}&ftime=${r.ftime}&geturltime=6&guid=${r.guid}&hc_openid=${r.hc_openid}&hh_ua=${r.hh_ua}&live_type=${r.live_type}&livepid=${r.livepid}&login_type=${r.login_type}&open_id=&openid=${r.openid}&platform=${r.platform}&playno=${r.playno}&prd=${r.prd}&prog=${r.prog}&rand_str=${r.rand_str}&sRef=${r.sRef}&sUrl=${r.sUrl}&sdtfrom=${r.sdtfrom}&seq=${r.seq}&url=${r.url}&viewid=${r.viewid}"
|
|
println(e)
|
|
r.signature = YSP.getAuthSignature(e)
|
|
println(r.signature)
|
|
|
|
// val ttt = """{"BossId":2727,"Pwd":1424084450,"prog":"2022576801","playno":"BEoZw3cpZh","guid":"luccvoyr_58va8i3cqw6","hh_ua":"Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/123.0.0.0 Safari/537.36","cdn":"waibao","sdtfrom":"ysp_pc_01","prd":60000,"platform":"5910204","errcode":"","durl":"https://outlivecloud-cdn.ysp.cctv.cn/906028A94D533483FE8BAC5CF4DB6CC70753E25A93EF3EC50988538DEDBF10161D1EA8F67C916EE41BA9D891D7893C69500B3F1A37CA814D2EE19341197360196CD9CCF327949104097C904643D493EB5A9B588EC28A2FAC1C8E30F8EE330DB2364B0DEC0124F6990A83773FF283489A/2022576803.m3u8?from=player&svrtime=1713365896&pid=600001859&cdn=5401&revoi=6E400EC7436C79D49BA06E61333D31FB8915F3484D9426FE4CCC4DE01CB8FD1DF473A8F416EF1107B669B0A9447F913272789A827EDD3DC0FE88534D9B59A35669678946589AA4D246F8F248F7C33AB08CE72FA0A73FE7F1F9FD2091D30176895CB8BD44A5B85FAD9579C700CB2AFD8D0939574B2A3EFF4C1B237DFF3E0CD3E194662F9FDEE48D1ACD7BDFAB01868B220743021C40E0EA5514ECCF396B509DA1&app_id=519748109&guid=luccvoyr_58va8i3cqw6&ysign=bb79232986c5429600d76cfedb1d5978&ytime=1713365896&ytype=1","firstreport":1,"sUrl":"https://www.yangshipin.cn/#/tv/home?pid=600001859","sRef":"","fplayerver":"100","livepid":"600001859","viewid":"2022576801","seq":0,"cmd":263,"login_type":"","geturltime":6,"downspeed":1.75,"hc_openid":"","open_id":"","defn":"fhd","fact1":"ysp_pc_live_b","openid":"","_dc":0.7140416315131102,"live_type":"","ftime":"2024-04-17 22:58:31","url":"https://outlivecloud-cdn.ysp.cctv.cn/906028A94D533483FE8BAC5CF4DB6CC70753E25A93EF3EC50988538DEDBF10161D1EA8F67C916EE41BA9D891D7893C69500B3F1A37CA814D2EE19341197360196CD9CCF327949104097C904643D493EB5A9B588EC28A2FAC1C8E30F8EE330DB2364B0DEC0124F6990A83773FF283489A/2022576803.m3u8?from=player&svrtime=1713365896&pid=600001859&cdn=5401&revoi=6E400EC7436C79D49BA06E61333D31FB8915F3484D9426FE4CCC4DE01CB8FD1DF473A8F416EF1107B669B0A9447F913272789A827EDD3DC0FE88534D9B59A35669678946589AA4D246F8F248F7C33AB08CE72FA0A73FE7F1F9FD2091D30176895CB8BD44A5B85FAD9579C700CB2AFD8D0939574B2A3EFF4C1B237DFF3E0CD3E194662F9FDEE48D1ACD7BDFAB01868B220743021C40E0EA5514ECCF396B509DA1&app_id=519748109&guid=luccvoyr_58va8i3cqw6&ysign=bb79232986c5429600d76cfedb1d5978&ytime=1713365896&ytype=1","rand_str":"oKkkZs8lON"}"""
|
|
// val gson = Gson()
|
|
// r = gson.fromJson(ttt, KvcollectRequest::class.java)
|
|
//
|
|
// e =
|
|
// "BossId=${r.BossId}&Pwd=${r.Pwd}&_dc=${r._dc}&cdn=${r.cdn}&cmd=${r.cmd}&defn=${r.defn}&downspeed=${r.downspeed}&durl=${r.durl}&errcode=${r.errcode}&fact1=${r.fact1}&firstreport=${r.firstreport}&fplayerver=${r.fplayerver}&ftime=${r.ftime}&geturltime=6&guid=${r.guid}&hc_openid=${r.hc_openid}&hh_ua=${r.hh_ua}&live_type=${r.live_type}&livepid=${r.livepid}&login_type=${r.login_type}&open_id=&openid=${r.openid}&platform=${r.platform}&playno=${r.playno}&prd=${r.prd}&prog=${r.prog}&rand_str=${r.rand_str}&sRef=${r.sRef}&sUrl=${r.sUrl}&sdtfrom=${r.sdtfrom}&seq=${r.seq}&url=${r.url}&viewid=${r.viewid}"
|
|
// println(e)
|
|
// e = "BossId=2727&Pwd=1424084450&_dc=0.7140416315131102&cdn=waibao&cmd=263&defn=fhd&downspeed=1.75&durl=https://outlivecloud-cdn.ysp.cctv.cn/906028A94D533483FE8BAC5CF4DB6CC70753E25A93EF3EC50988538DEDBF10161D1EA8F67C916EE41BA9D891D7893C69500B3F1A37CA814D2EE19341197360196CD9CCF327949104097C904643D493EB5A9B588EC28A2FAC1C8E30F8EE330DB2364B0DEC0124F6990A83773FF283489A/2022576803.m3u8?from=player&svrtime=1713365896&pid=600001859&cdn=5401&revoi=6E400EC7436C79D49BA06E61333D31FB8915F3484D9426FE4CCC4DE01CB8FD1DF473A8F416EF1107B669B0A9447F913272789A827EDD3DC0FE88534D9B59A35669678946589AA4D246F8F248F7C33AB08CE72FA0A73FE7F1F9FD2091D30176895CB8BD44A5B85FAD9579C700CB2AFD8D0939574B2A3EFF4C1B237DFF3E0CD3E194662F9FDEE48D1ACD7BDFAB01868B220743021C40E0EA5514ECCF396B509DA1&app_id=519748109&guid=luccvoyr_58va8i3cqw6&ysign=bb79232986c5429600d76cfedb1d5978&ytime=1713365896&ytype=1&errcode=&fact1=ysp_pc_live_b&firstreport=1&fplayerver=100&ftime=2024-04-17 22:58:31&geturltime=6&guid=luccvoyr_58va8i3cqw6&hc_openid=&hh_ua=Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/123.0.0.0 Safari/537.36&live_type=&livepid=600001859&login_type=&open_id=&openid=&platform=5910204&playno=BEoZw3cpZh&prd=60000&prog=2022576801&rand_str=oKkkZs8lON&sRef=&sUrl=https://www.yangshipin.cn/#/tv/home?pid=600001859&sdtfrom=ysp_pc_01&seq=0&url=https://outlivecloud-cdn.ysp.cctv.cn/906028A94D533483FE8BAC5CF4DB6CC70753E25A93EF3EC50988538DEDBF10161D1EA8F67C916EE41BA9D891D7893C69500B3F1A37CA814D2EE19341197360196CD9CCF327949104097C904643D493EB5A9B588EC28A2FAC1C8E30F8EE330DB2364B0DEC0124F6990A83773FF283489A/2022576803.m3u8?from=player&svrtime=1713365896&pid=600001859&cdn=5401&revoi=6E400EC7436C79D49BA06E61333D31FB8915F3484D9426FE4CCC4DE01CB8FD1DF473A8F416EF1107B669B0A9447F913272789A827EDD3DC0FE88534D9B59A35669678946589AA4D246F8F248F7C33AB08CE72FA0A73FE7F1F9FD2091D30176895CB8BD44A5B85FAD9579C700CB2AFD8D0939574B2A3EFF4C1B237DFF3E0CD3E194662F9FDEE48D1ACD7BDFAB01868B220743021C40E0EA5514ECCF396B509DA1&app_id=519748109&guid=luccvoyr_58va8i3cqw6&ysign=bb79232986c5429600d76cfedb1d5978&ytime=1713365896&ytype=1&viewid=2022576801"
|
|
// println(e)
|
|
// r.signature = YSP.getAuthSignature(e)
|
|
// println(r.signature)
|
|
|
|
callBtracePage = yspBtraceService2.kvcollect2(
|
|
r
|
|
)
|
|
callBtracePage?.enqueue(object : Callback<Void> {
|
|
override fun onResponse(call: Call<Void>, response: Response<Void>) {
|
|
if (response.isSuccessful) {
|
|
Log.d(TAG, "$title kvcollect success")
|
|
} else {
|
|
Log.e(TAG, "$title kvcollect status error")
|
|
}
|
|
handler.postDelayed(btraceRunnable, 60 * 1000)
|
|
}
|
|
|
|
override fun onFailure(call: Call<Void>, t: Throwable) {
|
|
Log.e(TAG, "$title kvcollect request error")
|
|
handler.postDelayed(btraceRunnable, 60 * 1000)
|
|
}
|
|
})
|
|
tvModel.seq++
|
|
}
|
|
|
|
fun fetchBtrace3(tvModel: TVViewModel) {
|
|
callBtracePage?.cancel()
|
|
val title = tvModel.getTV().title
|
|
|
|
val guid = YSP.getGuid()
|
|
val pid = tvModel.getTV().pid
|
|
val sid = tvModel.getTV().sid
|
|
val randomNumber = Random.nextDouble()
|
|
val url = tvModel.getTV().videoUrl.first()
|
|
|
|
val r = KvcollectRequest2(
|
|
guid = guid,
|
|
prog = sid,
|
|
viewid = sid,
|
|
livepid = pid,
|
|
sUrl = "https://www.yangshipin.cn/#/tv/home?pid=$pid",
|
|
playno = YSP.getRand(),
|
|
rand_str = YSP.getRand(),
|
|
ftime = getDateFormat("yyyy-MM-dd HH:mm:ss"),
|
|
seq = tvModel.seq,
|
|
durl = url,
|
|
url = url,
|
|
_dc = randomNumber,
|
|
)
|
|
|
|
val e =
|
|
"BossId=${r.BossId}&Pwd=${r.Pwd}&_dc=${r._dc}&cdn=${r.cdn}&cmd=${r.cmd}&defn=${r.defn}&downspeed=${r.downspeed}&durl=${r.durl}&errcode=${r.errcode}&fact1=${r.fact1}&firstreport=${r.firstreport}&fplayerver=${r.fplayerver}&ftime=${r.ftime}&geturltime=${r.geturltime}&guid=${r.guid}&hc_openid=${r.hc_openid}&hh_ua=${r.hh_ua}&live_type=${r.live_type}&livepid=${r.livepid}&login_type=${r.login_type}&open_id=${r.open_id}&openid=${r.openid}&platform=${r.platform}&playno=${r.playno}&prd=${r.prd}&prog=${r.prog}&rand_str=${r.rand_str}&sRef=${r.sRef}&sUrl=${r.sUrl}&sdtfrom=${r.sdtfrom}&seq=${r.seq}&url=${r.url}&viewid=${r.viewid}"
|
|
r.signature = YSP.getAuthSignature(e)
|
|
|
|
callBtracePage = yspBtraceService3.kvcollect3(
|
|
guid = r.guid,
|
|
prog = r.prog,
|
|
viewid = r.viewid,
|
|
livepid = r.livepid,
|
|
sUrl = r.sUrl,
|
|
playno = r.playno,
|
|
rand_str = r.rand_str,
|
|
ftime = r.ftime,
|
|
seq = "${r.seq}",
|
|
durl = r.durl,
|
|
url = r.url,
|
|
_dc = "${r._dc}",
|
|
signature = r.signature
|
|
)
|
|
callBtracePage?.enqueue(object : Callback<Void> {
|
|
override fun onResponse(call: Call<Void>, response: Response<Void>) {
|
|
if (response.isSuccessful) {
|
|
Log.d(TAG, "$title kvcollect success")
|
|
} else {
|
|
Log.e(TAG, "$title kvcollect status error")
|
|
}
|
|
handler.postDelayed(btraceRunnable, 60 * 1000)
|
|
}
|
|
|
|
override fun onFailure(call: Call<Void>, t: Throwable) {
|
|
Log.e(TAG, "$title kvcollect request error")
|
|
handler.postDelayed(btraceRunnable, 60 * 1000)
|
|
}
|
|
})
|
|
tvModel.seq++
|
|
}
|
|
|
|
fun fetchPage() {
|
|
callPage = yspProtoService.getPage()
|
|
callPage?.enqueue(object : Callback<pageModel.Response> {
|
|
override fun onResponse(
|
|
call: Call<pageModel.Response>,
|
|
response: Response<pageModel.Response>
|
|
) {
|
|
if (response.isSuccessful) {
|
|
val body = response.body()
|
|
if (body?.data?.feedModuleListCount == 1) {
|
|
for (item in body.data?.feedModuleListList!![0]?.dataTvChannelListList!!) {
|
|
Log.d(
|
|
TAG,
|
|
"${item.channelName},${item.pid},${item.streamId}"
|
|
)
|
|
|
|
for ((_, v) in TVList.list) {
|
|
for (v2 in v) {
|
|
if (v2.title == item.channelName || v2.alias == item.channelName) {
|
|
v2.pid = item.pid
|
|
v2.sid = item.streamId
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
override fun onFailure(call: Call<pageModel.Response>, t: Throwable) {
|
|
Log.e(TAG, "Page request failed", t)
|
|
}
|
|
})
|
|
}
|
|
|
|
fun fetchYJceEPG(tvViewModel: TVViewModel) {
|
|
val title = tvViewModel.getTV().title
|
|
yspJceService.getProgram(TVTimeShiftProgramRequest(tvViewModel.getTV().pid))
|
|
.enqueue(object : Callback<TVTimeShiftProgramResponse> {
|
|
override fun onResponse(
|
|
call: Call<TVTimeShiftProgramResponse>,
|
|
response: Response<TVTimeShiftProgramResponse>
|
|
) {
|
|
if (response.isSuccessful) {
|
|
val program = response.body()
|
|
if (program != null) {
|
|
tvViewModel.addYJceEPG(program.programs)
|
|
Log.d(TAG, "$title program ${program.programs.size}")
|
|
}
|
|
} else {
|
|
Log.w(TAG, "$title program error")
|
|
}
|
|
}
|
|
|
|
override fun onFailure(call: Call<TVTimeShiftProgramResponse>, t: Throwable) {
|
|
Log.e(TAG, "$title program request failed $t")
|
|
}
|
|
})
|
|
}
|
|
|
|
fun fetchYProtoEPG(tvViewModel: TVViewModel) {
|
|
val title = tvViewModel.getTV().title
|
|
yspProtoService.getProgram(tvViewModel.getTV().pid, getDateFormat("yyyyMMdd"))
|
|
.enqueue(object : Callback<epgProgramModel.Response> {
|
|
override fun onResponse(
|
|
call: Call<epgProgramModel.Response>,
|
|
response: Response<epgProgramModel.Response>
|
|
) {
|
|
if (response.isSuccessful) {
|
|
val program = response.body()
|
|
if (program != null) {
|
|
tvViewModel.addYEPG(program.dataListList)
|
|
Log.d(TAG, "$title program ${program.dataListList.size}")
|
|
}
|
|
} else {
|
|
Log.w(TAG, "$title program error")
|
|
}
|
|
}
|
|
|
|
override fun onFailure(call: Call<epgProgramModel.Response>, t: Throwable) {
|
|
Log.e(TAG, "$title program request failed $t")
|
|
}
|
|
})
|
|
}
|
|
|
|
fun fetchFEPG(tvViewModel: TVViewModel) {
|
|
val title = tvViewModel.getTV().title
|
|
fAuthService.getEPG(tvViewModel.getTV().pid, getDateFormat("yyyyMMdd"))
|
|
.enqueue(object : Callback<List<FEPG>> {
|
|
override fun onResponse(
|
|
call: Call<List<FEPG>>,
|
|
response: Response<List<FEPG>>
|
|
) {
|
|
if (response.isSuccessful) {
|
|
val program = response.body()
|
|
if (program != null) {
|
|
tvViewModel.addFEPG(program)
|
|
Log.d(TAG, "$title program ${program.size}")
|
|
}
|
|
} else {
|
|
Log.w(TAG, "$title program error")
|
|
}
|
|
}
|
|
|
|
override fun onFailure(call: Call<List<FEPG>>, t: Throwable) {
|
|
Log.e(TAG, "$title program request failed $t")
|
|
}
|
|
})
|
|
}
|
|
|
|
private fun encryptTripleDES(key: ByteArray, iv: ByteArray): String {
|
|
return try {
|
|
val keySpec = SecretKeySpec(key, "DESede")
|
|
val ivSpec = IvParameterSpec(iv)
|
|
val cipher = Cipher.getInstance("DESede/CBC/PKCS5Padding")
|
|
cipher.init(Cipher.ENCRYPT_MODE, keySpec, ivSpec)
|
|
return cipher.doFinal(input).let { it -> it.joinToString("") { "%02x".format(it) } }
|
|
} catch (e: Exception) {
|
|
e.printStackTrace()
|
|
""
|
|
}
|
|
}
|
|
|
|
interface RequestListener {
|
|
fun onRequestFinished(message: String?)
|
|
}
|
|
|
|
fun setRequestListener(listener: RequestListener) {
|
|
this.listener = listener
|
|
}
|
|
} |