mirror of
https://github.com/lizongying/my-tv.git
synced 2026-10-29 07:36:29 +08:00
Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
353dc0570f | ||
|
|
d7a60531ab | ||
|
|
764f2a1549 | ||
|
|
aa4d52681f | ||
|
|
8137515605 | ||
|
|
6c16408b90 | ||
|
|
44ab3a6669 | ||
|
|
917b245bbe | ||
|
|
dd4550cf4f | ||
|
|
4bdc625718 | ||
|
|
cda19995b2 | ||
|
|
1eb2f257b5 | ||
|
|
9feb0dc4bc | ||
|
|
46311036d6 | ||
|
|
1aade3a48d | ||
|
|
2528cf33db | ||
|
|
4364f66ec5 | ||
|
|
49cd7b3af2 |
@@ -1,83 +0,0 @@
|
||||
name: Bug 反馈
|
||||
description: 反馈一个 Bug
|
||||
labels: [ "bug" ]
|
||||
title: "[BUG] "
|
||||
body:
|
||||
- type: checkboxes
|
||||
id: checklist
|
||||
attributes:
|
||||
label: 检查清单
|
||||
description: 确保我们的错误报告表单适合您。
|
||||
options:
|
||||
- label: 之前没有人提交过类似或相同的 bug report。
|
||||
required: true
|
||||
- label: 我正在使用本软件的最新版本。
|
||||
required: true
|
||||
- type: dropdown
|
||||
id: version
|
||||
attributes:
|
||||
label: my-ty 版本
|
||||
description: 请选择正在使用的版本
|
||||
options:
|
||||
- 最新稳定版
|
||||
- 最新 CI 版
|
||||
validations:
|
||||
required: true
|
||||
- type: textarea
|
||||
id: bug
|
||||
attributes:
|
||||
label: Bug 描述
|
||||
description: 请描述 bug 详情
|
||||
placeholder: |
|
||||
e.g. Crashed when generating snapshot.
|
||||
validations:
|
||||
required: true
|
||||
- type: textarea
|
||||
id: expected
|
||||
attributes:
|
||||
label: 预期行为
|
||||
description: 你预期会发生什么?
|
||||
placeholder: |
|
||||
e.g. A New snapshot!
|
||||
validations:
|
||||
required: true
|
||||
- type: textarea
|
||||
id: actual
|
||||
attributes:
|
||||
label: 实际行为
|
||||
description: 反而发生了什么?
|
||||
placeholder: |
|
||||
e.g. Crashed.
|
||||
validations:
|
||||
required: true
|
||||
- type: textarea
|
||||
id: steps
|
||||
attributes:
|
||||
label: 复现步骤
|
||||
description: 如何复现这个 bug。
|
||||
placeholder: |
|
||||
1. Open the app
|
||||
2. Crashed
|
||||
|
||||
What an app.
|
||||
- type: input
|
||||
id: ui
|
||||
attributes:
|
||||
label: UI / OS
|
||||
description: 你的电视系统 UI 或 OS 或 品牌
|
||||
placeholder: TCL / XIAOMI / PHONE / etc.
|
||||
validations:
|
||||
required: true
|
||||
- type: input
|
||||
id: android
|
||||
attributes:
|
||||
label: Android 版本
|
||||
description: 你的 Android 版本
|
||||
placeholder: "12"
|
||||
validations:
|
||||
required: true
|
||||
- type: textarea
|
||||
id: additional
|
||||
attributes:
|
||||
label: 额外信息
|
||||
description: 任何你觉得值得说的。
|
||||
@@ -1,36 +0,0 @@
|
||||
name: 功能(新频道)请求
|
||||
description: 提出一个建议
|
||||
labels: [ "enhancement" ]
|
||||
title: "[FR] "
|
||||
body:
|
||||
- type: checkboxes
|
||||
id: checklist
|
||||
attributes:
|
||||
label: 检查清单
|
||||
description: 确保我们的错误报告表单适合您。
|
||||
options:
|
||||
- label: 之前没有人提交过类似或相同的功能请求。
|
||||
required: true
|
||||
- label: 这个建议不会背离 LibChecker 的初衷。
|
||||
required: true
|
||||
- type: textarea
|
||||
id: propose
|
||||
attributes:
|
||||
label: 改进目的
|
||||
description: 改进有什么用
|
||||
placeholder: |
|
||||
Show your idea here.
|
||||
validations:
|
||||
required: true
|
||||
- type: textarea
|
||||
id: solution
|
||||
attributes:
|
||||
label: 解决方案
|
||||
description: 你会怎么完成这个改进?
|
||||
placeholder: |
|
||||
How to do it on your opinion? Or left this blank
|
||||
- type: textarea
|
||||
id: addition
|
||||
attributes:
|
||||
label: 额外信息
|
||||
description: 任何你觉得值得说的。
|
||||
+1
-5
@@ -101,7 +101,7 @@ dependencies {
|
||||
implementation "androidx.media3:media3-exoplayer-hls:$media3_version"
|
||||
|
||||
// 21:2.9.0 17:2.6.4
|
||||
def retrofit2_version = "2.9.0"
|
||||
def retrofit2_version = "2.6.4"
|
||||
|
||||
implementation 'com.google.protobuf:protobuf-kotlin:3.25.1'
|
||||
implementation "com.squareup.retrofit2:converter-gson:$retrofit2_version"
|
||||
@@ -113,8 +113,4 @@ dependencies {
|
||||
implementation 'com.github.bumptech.glide:glide:4.11.0'
|
||||
implementation "androidx.lifecycle:lifecycle-runtime-ktx:2.6.2"
|
||||
implementation("org.jetbrains.kotlinx:kotlinx-coroutines-android:1.8.0-RC")
|
||||
|
||||
implementation 'com.google.android.exoplayer:exoplayer-ui:2.13.3'
|
||||
implementation 'com.google.android.exoplayer:exoplayer-core:2.13.3'
|
||||
implementation 'com.google.android.exoplayer:exoplayer-hls:2.13.3'
|
||||
}
|
||||
@@ -7,7 +7,6 @@
|
||||
android:name="android.software.leanback"
|
||||
android:required="true" />
|
||||
<uses-permission android:name="android.permission.INTERNET" />
|
||||
<uses-permission android:name="android.permission.RECEIVE_BOOT_COMPLETED" />
|
||||
<application
|
||||
android:allowBackup="true"
|
||||
android:largeHeap="true"
|
||||
@@ -30,13 +29,5 @@
|
||||
<category android:name="android.intent.category.LAUNCHER" />
|
||||
</intent-filter>
|
||||
</activity>
|
||||
<receiver
|
||||
android:name=".BootReceiver"
|
||||
android:exported="true">
|
||||
<intent-filter>
|
||||
<action android:name="android.intent.action.BOOT_COMPLETED" />
|
||||
<category android:name="android.intent.category.DEFAULT" />
|
||||
</intent-filter>
|
||||
</receiver>
|
||||
</application>
|
||||
</manifest>
|
||||
Binary file not shown.
Binary file not shown.
@@ -1,19 +0,0 @@
|
||||
package com.lizongying.mytv
|
||||
|
||||
import android.content.BroadcastReceiver
|
||||
import android.content.Context
|
||||
import android.content.Intent
|
||||
|
||||
class BootReceiver : BroadcastReceiver() {
|
||||
|
||||
override fun onReceive(context: Context, intent: Intent) {
|
||||
val sp = context.getSharedPreferences("MainActivity", Context.MODE_PRIVATE)
|
||||
if (sp.getBoolean(MainActivity.BOOT_STARTUP, true)) {
|
||||
context.startActivity(
|
||||
Intent(context, MainActivity::class.java)
|
||||
.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK)
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,124 @@
|
||||
package com.lizongying.mytv
|
||||
|
||||
import android.graphics.Color
|
||||
import android.view.ContextThemeWrapper
|
||||
import android.view.View
|
||||
import android.view.ViewGroup
|
||||
import android.view.animation.ScaleAnimation
|
||||
import android.widget.ImageView
|
||||
import androidx.leanback.widget.ImageCardView
|
||||
import androidx.lifecycle.LifecycleOwner
|
||||
import androidx.recyclerview.widget.RecyclerView
|
||||
import com.bumptech.glide.Glide
|
||||
import com.lizongying.mytv.models.TVListViewModel
|
||||
import com.lizongying.mytv.models.TVViewModel
|
||||
|
||||
|
||||
class CardAdapter(private val owner: LifecycleOwner, private var tvListViewModel: TVListViewModel) :
|
||||
RecyclerView.Adapter<CardAdapter.ViewHolder>() {
|
||||
|
||||
private var listener: ItemListener? = null
|
||||
|
||||
override fun onCreateViewHolder(parent: ViewGroup, viewType: Int): ViewHolder {
|
||||
val cardView = object :
|
||||
ImageCardView(ContextThemeWrapper(parent.context, R.style.CustomImageCardTheme)) {}
|
||||
startScaleAnimation(cardView, 1.0f, 0.9f)
|
||||
cardView.isFocusable = true
|
||||
cardView.isFocusableInTouchMode = true
|
||||
|
||||
return ViewHolder(cardView)
|
||||
}
|
||||
|
||||
private fun startScaleAnimation(view: View, fromScale: Float, toScale: Float) {
|
||||
val scaleAnimation = ScaleAnimation(
|
||||
fromScale, toScale,
|
||||
fromScale, toScale,
|
||||
ScaleAnimation.RELATIVE_TO_SELF, 0.5f,
|
||||
ScaleAnimation.RELATIVE_TO_SELF, 0.5f
|
||||
)
|
||||
scaleAnimation.duration = 200
|
||||
scaleAnimation.fillAfter = true
|
||||
|
||||
view.startAnimation(scaleAnimation)
|
||||
}
|
||||
|
||||
override fun onBindViewHolder(viewHolder: ViewHolder, position: Int) {
|
||||
val item = tvListViewModel.getTVViewModel(position)
|
||||
|
||||
val tvViewModel = item as TVViewModel
|
||||
val cardView = viewHolder.view as ImageCardView
|
||||
|
||||
cardView.setOnFocusChangeListener { _, hasFocus ->
|
||||
listener?.onItemFocusChange(item, hasFocus)
|
||||
if (hasFocus) {
|
||||
startScaleAnimation(cardView, 0.9f, 1.0f)
|
||||
} else {
|
||||
startScaleAnimation(cardView, 1.0f, 0.9f)
|
||||
}
|
||||
}
|
||||
|
||||
cardView.setOnClickListener { _ ->
|
||||
listener?.onItemClicked(item)
|
||||
}
|
||||
|
||||
cardView.titleText = tvViewModel.title.value
|
||||
cardView.tag = tvViewModel.videoUrl.value
|
||||
|
||||
when (tvViewModel.title.value) {
|
||||
"CCTV8K 超高清" -> Glide.with(viewHolder.view.context)
|
||||
.load(R.drawable.cctv8k)
|
||||
.centerInside()
|
||||
.into(cardView.mainImageView)
|
||||
|
||||
"天津卫视" -> Glide.with(viewHolder.view.context)
|
||||
.load(R.drawable.tianjin)
|
||||
.centerInside()
|
||||
.into(cardView.mainImageView)
|
||||
|
||||
"新疆卫视" -> Glide.with(viewHolder.view.context)
|
||||
.load(R.drawable.xinjiang)
|
||||
.centerInside()
|
||||
.into(cardView.mainImageView)
|
||||
|
||||
"兵团卫视" -> Glide.with(viewHolder.view.context)
|
||||
.load(R.drawable.bingtuan)
|
||||
.centerInside()
|
||||
.into(cardView.mainImageView)
|
||||
|
||||
else -> Glide.with(viewHolder.view.context)
|
||||
.load(tvViewModel.logo.value)
|
||||
.centerInside()
|
||||
.into(cardView.mainImageView)
|
||||
}
|
||||
|
||||
cardView.mainImageView.setBackgroundColor(Color.WHITE)
|
||||
cardView.setMainImageScaleType(ImageView.ScaleType.CENTER_INSIDE)
|
||||
|
||||
tvViewModel.program.observe(owner) { _ ->
|
||||
val program = tvViewModel.getProgramOne()
|
||||
if (program != null) {
|
||||
cardView.contentText = program.name
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
override fun getItemCount() = tvListViewModel.size()
|
||||
|
||||
class ViewHolder(itemView: View) : RecyclerView.ViewHolder(itemView) {
|
||||
val view = itemView
|
||||
}
|
||||
|
||||
interface ItemListener {
|
||||
fun onItemFocusChange(tvViewModel: TVViewModel, hasFocus: Boolean)
|
||||
fun onItemClicked(tvViewModel: TVViewModel)
|
||||
}
|
||||
|
||||
fun setItemListener(listener: ItemListener) {
|
||||
this.listener = listener
|
||||
}
|
||||
|
||||
companion object {
|
||||
private const val TAG = "CardAdapter"
|
||||
}
|
||||
}
|
||||
|
||||
@@ -47,6 +47,11 @@ class CardPresenter(
|
||||
.centerInside()
|
||||
.into(cardView.mainImageView)
|
||||
|
||||
"兵团卫视" -> Glide.with(viewHolder.view.context)
|
||||
.load(R.drawable.bingtuan)
|
||||
.centerInside()
|
||||
.into(cardView.mainImageView)
|
||||
|
||||
else -> Glide.with(viewHolder.view.context)
|
||||
.load(tvViewModel.logo.value)
|
||||
.centerInside()
|
||||
|
||||
@@ -1,157 +0,0 @@
|
||||
package com.lizongying.mytv
|
||||
|
||||
import android.content.Context
|
||||
import kotlinx.coroutines.Dispatchers
|
||||
import kotlinx.coroutines.withContext
|
||||
import java.io.File
|
||||
|
||||
/**
|
||||
*@author LeGend
|
||||
*@date 2024/2/4 22:42
|
||||
*/
|
||||
object ChannelUtils {
|
||||
/**
|
||||
* 获取服务器channel版本
|
||||
*
|
||||
* @param context Context
|
||||
*
|
||||
* @return 服务器channel版本
|
||||
*/
|
||||
suspend fun getServerVersion(context: Context): Int {
|
||||
return withContext(Dispatchers.IO) {
|
||||
val client = okhttp3.OkHttpClient.Builder().connectTimeout(500, java.util.concurrent.TimeUnit.MILLISECONDS)
|
||||
.readTimeout(1, java.util.concurrent.TimeUnit.SECONDS).build()
|
||||
client.newCall(okhttp3.Request.Builder().url(getServerVersionUrl(context)).build()).execute()
|
||||
.use { response ->
|
||||
if (!response.isSuccessful) throw java.io.IOException("Unexpected code $response")
|
||||
val body = response.body()
|
||||
body?.string()?.toInt() ?: 0
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取服务器channel
|
||||
*
|
||||
* @param url String 服务器地址
|
||||
*
|
||||
* @return Array<TV> 服务器channel
|
||||
*
|
||||
* @throws java.io.IOException 网络请求失败
|
||||
*/
|
||||
suspend fun getServerChannel(url: String): List<TV> {
|
||||
val result = withContext(Dispatchers.IO) {
|
||||
val client = okhttp3.OkHttpClient.Builder().connectTimeout(500, java.util.concurrent.TimeUnit.MILLISECONDS)
|
||||
.readTimeout(1, java.util.concurrent.TimeUnit.SECONDS).build()
|
||||
val request = okhttp3.Request.Builder().url(url).build()
|
||||
client.newCall(request).execute().use { response ->
|
||||
if (!response.isSuccessful) throw java.io.IOException("Unexpected code $response")
|
||||
val body = response.body()
|
||||
body?.string() ?: ""
|
||||
}
|
||||
}
|
||||
return withContext(Dispatchers.Default) {
|
||||
val type = object : com.google.gson.reflect.TypeToken<List<TV>>() {}.type
|
||||
com.google.gson.Gson().fromJson(result, type)
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取服务器地址
|
||||
*
|
||||
* @param context Context
|
||||
*
|
||||
* @return 服务器地址
|
||||
*/
|
||||
fun getServerUrl(context: Context): String {
|
||||
return context.resources.getString(R.string.server_url)
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取serverVersion的URL
|
||||
*
|
||||
* @param context Context
|
||||
*
|
||||
* @return serverVersionURL 服务器版本地址
|
||||
*/
|
||||
suspend fun getServerVersionUrl(context: Context): String {
|
||||
return withContext(Dispatchers.IO) {
|
||||
context.resources.getString(R.string.server_version_url)
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 获取本地channel版本
|
||||
*
|
||||
* @param context Context
|
||||
*
|
||||
* @return 本地channel
|
||||
*/
|
||||
suspend fun getLocalVersion(context: Context): Int {
|
||||
return withContext(Dispatchers.IO) {
|
||||
val file = File(getAppDirectory(context), "channels")
|
||||
//检查本地是否已经有保存的channels.json,若无保存的Channel.json则从读取assert中文件
|
||||
val savedVersion =
|
||||
context.getSharedPreferences("saved_version", Context.MODE_PRIVATE).getInt("version", Integer.MIN_VALUE)
|
||||
if (!file.exists() || savedVersion == Integer.MIN_VALUE) {
|
||||
context.resources.getInteger(R.integer.local_channel_version)
|
||||
} else {
|
||||
savedVersion
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取本地可读取的目录
|
||||
* @param context Context
|
||||
*
|
||||
* @return 可读取的目录
|
||||
*/
|
||||
private fun getAppDirectory(context: Context): File {
|
||||
return context.filesDir
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取本地channel
|
||||
*
|
||||
* @param context Context
|
||||
*
|
||||
* @return Array<TV> 本地channel
|
||||
*/
|
||||
suspend fun getLocalChannel(context: Context): List<TV> {
|
||||
val str = withContext(Dispatchers.IO) {
|
||||
if (File(getAppDirectory(context), "channels").exists()) {
|
||||
File(getAppDirectory(context), "channels").readText()
|
||||
} else {
|
||||
context.resources.openRawResource(R.raw.channels).bufferedReader().use { it.readText() }
|
||||
}
|
||||
}
|
||||
return withContext(Dispatchers.Default) {
|
||||
val type = object : com.google.gson.reflect.TypeToken<List<TV>>() {}.type
|
||||
com.google.gson.Gson().fromJson(str, type)
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 更新channels.json
|
||||
*
|
||||
* @param context Context
|
||||
*
|
||||
* @return 无
|
||||
*
|
||||
* @throws java.io.IOException 写入失败
|
||||
*/
|
||||
suspend fun updateLocalChannel(context: Context, version: Int, channels: List<TV>) {
|
||||
withContext(Dispatchers.IO) {
|
||||
val file = File(getAppDirectory(context), "channels")
|
||||
if (!file.exists()) {
|
||||
file.createNewFile()
|
||||
}
|
||||
file.writeText(com.google.gson.Gson().toJson(channels))
|
||||
context.getSharedPreferences("saved_version", Context.MODE_PRIVATE).edit().putInt(
|
||||
"version", version
|
||||
).apply()
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,36 @@
|
||||
package com.lizongying.mytv
|
||||
|
||||
import android.app.AlertDialog
|
||||
import android.app.Dialog
|
||||
import android.os.Bundle
|
||||
import androidx.fragment.app.DialogFragment
|
||||
|
||||
class ConfirmationDialogFragment(private val listener: ConfirmationDialogListener) :
|
||||
DialogFragment() {
|
||||
|
||||
override fun onCreateDialog(savedInstanceState: Bundle?): Dialog {
|
||||
return activity?.let {
|
||||
val builder = AlertDialog.Builder(it)
|
||||
builder.setTitle("确认")
|
||||
.setMessage("确认更新吗?")
|
||||
.setPositiveButton(
|
||||
"确定"
|
||||
) { _, _ ->
|
||||
listener.onConfirm()
|
||||
}
|
||||
.setNegativeButton(
|
||||
"取消"
|
||||
) { _, _ ->
|
||||
listener.onCancel()
|
||||
}
|
||||
// 创建并返回 AlertDialog 对象
|
||||
builder.create()
|
||||
} ?: throw IllegalStateException("Activity cannot be null")
|
||||
}
|
||||
|
||||
interface ConfirmationDialogListener {
|
||||
fun onConfirm()
|
||||
fun onCancel()
|
||||
}
|
||||
}
|
||||
|
||||
@@ -9,6 +9,8 @@ class Encryptor {
|
||||
|
||||
external fun hash(data: ByteArray): ByteArray?
|
||||
|
||||
external fun hash2(data: ByteArray): ByteArray?
|
||||
|
||||
companion object {
|
||||
init {
|
||||
System.loadLibrary("native")
|
||||
|
||||
@@ -29,10 +29,11 @@ import java.security.MessageDigest
|
||||
|
||||
class MainActivity : FragmentActivity() {
|
||||
|
||||
var playerFragment = PlayerFragment()
|
||||
private val mainFragment = MainFragment()
|
||||
private val infoFragment = InfoFragment()
|
||||
private val channelFragment = ChannelFragment()
|
||||
private var ready = 0
|
||||
private var playerFragment = PlayerFragment()
|
||||
private var mainFragment = MainFragment()
|
||||
private var infoFragment = InfoFragment()
|
||||
private var channelFragment = ChannelFragment()
|
||||
private lateinit var settingFragment: SettingFragment
|
||||
|
||||
private var doubleBackToExitPressedOnce = false
|
||||
@@ -46,7 +47,6 @@ class MainActivity : FragmentActivity() {
|
||||
lateinit var sharedPref: SharedPreferences
|
||||
private var channelReversal = false
|
||||
private var channelNum = true
|
||||
private var bootStartup = true
|
||||
|
||||
private var versionName = ""
|
||||
|
||||
@@ -83,10 +83,15 @@ class MainActivity : FragmentActivity() {
|
||||
sharedPref = getPreferences(Context.MODE_PRIVATE)
|
||||
channelReversal = sharedPref.getBoolean(CHANNEL_REVERSAL, channelReversal)
|
||||
channelNum = sharedPref.getBoolean(CHANNEL_NUM, channelNum)
|
||||
bootStartup = sharedPref.getBoolean(BOOT_STARTUP, bootStartup)
|
||||
|
||||
versionName = getPackageInfo().versionName
|
||||
settingFragment = SettingFragment(versionName, channelReversal, channelNum, bootStartup)
|
||||
val packageInfo = getPackageInfo()
|
||||
versionName = packageInfo.versionName
|
||||
val versionCode = if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.P) {
|
||||
packageInfo.longVersionCode
|
||||
} else {
|
||||
packageInfo.versionCode.toLong()
|
||||
}
|
||||
settingFragment = SettingFragment(versionName, versionCode, channelReversal, channelNum)
|
||||
}
|
||||
|
||||
fun showInfoFragment(tvViewModel: TVViewModel) {
|
||||
@@ -139,6 +144,7 @@ class MainActivity : FragmentActivity() {
|
||||
val transaction = supportFragmentManager.beginTransaction()
|
||||
|
||||
if (mainFragment.isHidden) {
|
||||
mainFragment.setPosition()
|
||||
transaction.show(mainFragment)
|
||||
keepRunnable()
|
||||
} else {
|
||||
@@ -172,7 +178,11 @@ class MainActivity : FragmentActivity() {
|
||||
}
|
||||
|
||||
fun fragmentReady() {
|
||||
mainFragment.fragmentReady()
|
||||
ready++
|
||||
Log.i(TAG, "ready $ready")
|
||||
if (ready == 4) {
|
||||
mainFragment.fragmentReady()
|
||||
}
|
||||
}
|
||||
|
||||
override fun onTouchEvent(event: MotionEvent?): Boolean {
|
||||
@@ -239,14 +249,6 @@ class MainActivity : FragmentActivity() {
|
||||
this.channelNum = channelNum
|
||||
}
|
||||
|
||||
fun saveBootStartup(bootStartup: Boolean) {
|
||||
with(sharedPref.edit()) {
|
||||
putBoolean(BOOT_STARTUP, bootStartup)
|
||||
apply()
|
||||
}
|
||||
this.bootStartup = bootStartup
|
||||
}
|
||||
|
||||
private fun showSetting() {
|
||||
if (!mainFragment.isHidden) {
|
||||
return
|
||||
@@ -520,7 +522,7 @@ class MainActivity : FragmentActivity() {
|
||||
override fun onResume() {
|
||||
Log.i(TAG, "onResume")
|
||||
super.onResume()
|
||||
if (!mainFragment.isHidden){
|
||||
if (!mainFragment.isHidden) {
|
||||
handler.postDelayed(hideMain, delayHideMain)
|
||||
}
|
||||
}
|
||||
@@ -535,6 +537,5 @@ class MainActivity : FragmentActivity() {
|
||||
private const val TAG = "MainActivity"
|
||||
private const val CHANNEL_REVERSAL = "channel_reversal"
|
||||
private const val CHANNEL_NUM = "channel_num"
|
||||
const val BOOT_STARTUP = "boot_startup"
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -5,30 +5,31 @@ import android.os.Bundle
|
||||
import android.os.Handler
|
||||
import android.os.Looper
|
||||
import android.util.Log
|
||||
import android.view.LayoutInflater
|
||||
import android.view.View
|
||||
import android.view.ViewGroup
|
||||
import android.widget.Toast
|
||||
import androidx.leanback.app.BrowseSupportFragment
|
||||
import androidx.leanback.widget.ArrayObjectAdapter
|
||||
import androidx.leanback.widget.HeaderItem
|
||||
import androidx.leanback.widget.ListRow
|
||||
import androidx.leanback.widget.ListRowPresenter
|
||||
import androidx.leanback.widget.ListRowPresenter.SelectItemViewHolderTask
|
||||
import androidx.leanback.widget.OnItemViewClickedListener
|
||||
import androidx.leanback.widget.OnItemViewSelectedListener
|
||||
import androidx.leanback.widget.Presenter
|
||||
import androidx.leanback.widget.Row
|
||||
import androidx.leanback.widget.RowPresenter
|
||||
import androidx.fragment.app.Fragment
|
||||
import androidx.lifecycle.lifecycleScope
|
||||
import androidx.recyclerview.widget.LinearLayoutManager
|
||||
import androidx.recyclerview.widget.RecyclerView
|
||||
import com.lizongying.mytv.Utils.dpToPx
|
||||
import com.lizongying.mytv.Utils.getDateTimestamp
|
||||
import com.lizongying.mytv.databinding.RowBinding
|
||||
import com.lizongying.mytv.databinding.ShowBinding
|
||||
import com.lizongying.mytv.models.TVListViewModel
|
||||
import com.lizongying.mytv.models.TVViewModel
|
||||
import kotlinx.coroutines.Dispatchers
|
||||
import kotlinx.coroutines.launch
|
||||
|
||||
class MainFragment : BrowseSupportFragment() {
|
||||
class MainFragment : Fragment(), CardAdapter.ItemListener {
|
||||
|
||||
private var itemPosition = 0
|
||||
|
||||
private var rowsAdapter: ArrayObjectAdapter? = null
|
||||
private var rowList: MutableList<View> = mutableListOf()
|
||||
|
||||
private var _binding: ShowBinding? = null
|
||||
private val binding get() = _binding!!
|
||||
|
||||
private var request = Request()
|
||||
|
||||
@@ -41,17 +42,12 @@ class MainFragment : BrowseSupportFragment() {
|
||||
private val handler = Handler(Looper.getMainLooper())
|
||||
private lateinit var mUpdateProgramRunnable: UpdateProgramRunnable
|
||||
|
||||
private var ready = 0
|
||||
|
||||
override fun onCreate(savedInstanceState: Bundle?) {
|
||||
Log.i(TAG, "onCreate")
|
||||
super.onCreate(savedInstanceState)
|
||||
headersState = HEADERS_DISABLED
|
||||
}
|
||||
|
||||
override fun onStart() {
|
||||
Log.i(TAG, "onStart")
|
||||
super.onStart()
|
||||
override fun onCreateView(
|
||||
inflater: LayoutInflater, container: ViewGroup?,
|
||||
savedInstanceState: Bundle?
|
||||
): View {
|
||||
_binding = ShowBinding.inflate(inflater, container, false)
|
||||
return binding.root
|
||||
}
|
||||
|
||||
override fun onActivityCreated(savedInstanceState: Bundle?) {
|
||||
@@ -60,171 +56,142 @@ class MainFragment : BrowseSupportFragment() {
|
||||
activity?.let { request.initYSP(it) }
|
||||
sharedPref = (activity as? MainActivity)?.sharedPref!!
|
||||
|
||||
loadRows()
|
||||
view?.post {
|
||||
val content = binding.content
|
||||
|
||||
setupEventListeners()
|
||||
var idx: Long = 0
|
||||
for ((k, v) in TVList.list) {
|
||||
val itemBinding: RowBinding =
|
||||
RowBinding.inflate(layoutInflater, content, false)
|
||||
|
||||
mUpdateProgramRunnable = UpdateProgramRunnable()
|
||||
handler.post(mUpdateProgramRunnable)
|
||||
|
||||
tvListViewModel.tvListViewModel.value?.forEach { tvViewModel ->
|
||||
tvViewModel.errInfo.observe(viewLifecycleOwner) { _ ->
|
||||
if (tvViewModel.errInfo.value != null
|
||||
&& tvViewModel.id.value == itemPosition
|
||||
) {
|
||||
Toast.makeText(context, tvViewModel.errInfo.value, Toast.LENGTH_SHORT).show()
|
||||
val tvListViewModelCurrent = TVListViewModel()
|
||||
for ((idx2, v1) in v.withIndex()) {
|
||||
val tvViewModel = TVViewModel(v1)
|
||||
tvViewModel.setRowPosition(idx.toInt())
|
||||
tvViewModel.setItemPosition(idx2)
|
||||
tvListViewModelCurrent.addTVViewModel(tvViewModel)
|
||||
tvListViewModel.addTVViewModel(tvViewModel)
|
||||
}
|
||||
}
|
||||
tvViewModel.ready.observe(viewLifecycleOwner) { _ ->
|
||||
tvListViewModel.maxNum.add(v.size)
|
||||
|
||||
// not first time && channel not change
|
||||
if (tvViewModel.ready.value != null
|
||||
&& tvViewModel.id.value == itemPosition
|
||||
&& check(tvViewModel)
|
||||
) {
|
||||
Log.i(TAG, "ready ${tvViewModel.title.value}")
|
||||
(activity as? MainActivity)?.play(tvViewModel)
|
||||
}
|
||||
val adapter = CardAdapter(viewLifecycleOwner, tvListViewModelCurrent)
|
||||
rowList.add(itemBinding.rowItems)
|
||||
|
||||
adapter.setItemListener(this)
|
||||
|
||||
itemBinding.rowHeader.text = k
|
||||
itemBinding.rowItems.adapter = adapter
|
||||
itemBinding.rowItems.layoutManager =
|
||||
LinearLayoutManager(context, LinearLayoutManager.HORIZONTAL, false)
|
||||
|
||||
val layoutParams = itemBinding.row.layoutParams as ViewGroup.MarginLayoutParams
|
||||
layoutParams.topMargin = dpToPx(11F)
|
||||
itemBinding.row.layoutParams = layoutParams
|
||||
content.addView(itemBinding.row)
|
||||
|
||||
idx++
|
||||
}
|
||||
tvViewModel.change.observe(viewLifecycleOwner) { _ ->
|
||||
if (tvViewModel.change.value != null) {
|
||||
val title = tvViewModel.title.value
|
||||
if (tvViewModel.pid.value != "") {
|
||||
Log.i(TAG, "request $title")
|
||||
lifecycleScope.launch(Dispatchers.IO) {
|
||||
tvViewModel.let { request.fetchData(it) }
|
||||
}
|
||||
(activity as? MainActivity)?.showInfoFragment(tvViewModel)
|
||||
setSelectedPosition(
|
||||
tvViewModel.getRowPosition(), true,
|
||||
SelectItemViewHolderTask(tvViewModel.getItemPosition())
|
||||
)
|
||||
} else {
|
||||
if (check(tvViewModel)) {
|
||||
(activity as? MainActivity)?.play(tvViewModel)
|
||||
|
||||
mUpdateProgramRunnable = UpdateProgramRunnable()
|
||||
handler.post(mUpdateProgramRunnable)
|
||||
|
||||
itemPosition = sharedPref.getInt(POSITION, 0)
|
||||
if (itemPosition >= tvListViewModel.size()) {
|
||||
itemPosition = 0
|
||||
}
|
||||
tvListViewModel.setItemPosition(itemPosition)
|
||||
setPosition()
|
||||
tvListViewModel.tvListViewModel.value?.forEach { tvViewModel ->
|
||||
tvViewModel.errInfo.observe(viewLifecycleOwner) { _ ->
|
||||
if (tvViewModel.errInfo.value != null
|
||||
&& tvViewModel.id.value == itemPosition
|
||||
) {
|
||||
Toast.makeText(context, tvViewModel.errInfo.value, Toast.LENGTH_SHORT)
|
||||
.show()
|
||||
}
|
||||
}
|
||||
tvViewModel.ready.observe(viewLifecycleOwner) { _ ->
|
||||
|
||||
// not first time && channel not change
|
||||
if (tvViewModel.ready.value != null
|
||||
&& tvViewModel.id.value == itemPosition
|
||||
&& check(tvViewModel)
|
||||
) {
|
||||
Log.i(TAG, "ready ${tvViewModel.title.value}")
|
||||
(activity as? MainActivity)?.play(tvViewModel)
|
||||
}
|
||||
}
|
||||
tvViewModel.change.observe(viewLifecycleOwner) { _ ->
|
||||
if (tvViewModel.change.value != null) {
|
||||
val title = tvViewModel.title.value
|
||||
Log.i(TAG, "switch $title")
|
||||
if (tvViewModel.pid.value != "") {
|
||||
Log.i(TAG, "request $title")
|
||||
lifecycleScope.launch(Dispatchers.IO) {
|
||||
tvViewModel.let { request.fetchData(it) }
|
||||
}
|
||||
(activity as? MainActivity)?.showInfoFragment(tvViewModel)
|
||||
setSelectedPosition(
|
||||
tvViewModel.getRowPosition(), true,
|
||||
SelectItemViewHolderTask(tvViewModel.getItemPosition())
|
||||
setPosition(
|
||||
tvViewModel.getRowPosition(), tvViewModel.getItemPosition()
|
||||
)
|
||||
} else {
|
||||
if (check(tvViewModel)) {
|
||||
(activity as? MainActivity)?.play(tvViewModel)
|
||||
(activity as? MainActivity)?.showInfoFragment(tvViewModel)
|
||||
setPosition(
|
||||
tvViewModel.getRowPosition(), tvViewModel.getItemPosition()
|
||||
)
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
fragmentReady()
|
||||
}
|
||||
|
||||
fun toLastPosition() {
|
||||
setSelectedPosition(
|
||||
selectedPosition, false,
|
||||
SelectItemViewHolderTask(tvListViewModel.maxNum[selectedPosition] - 1)
|
||||
)
|
||||
}
|
||||
|
||||
fun toFirstPosition() {
|
||||
setSelectedPosition(
|
||||
selectedPosition, false,
|
||||
SelectItemViewHolderTask(0)
|
||||
)
|
||||
}
|
||||
|
||||
override fun startHeadersTransition(withHeaders: Boolean) {
|
||||
}
|
||||
|
||||
private fun loadRows() {
|
||||
rowsAdapter = ArrayObjectAdapter(ListRowPresenter())
|
||||
|
||||
val cardPresenter = CardPresenter(viewLifecycleOwner)
|
||||
|
||||
var idx: Long = 0
|
||||
for ((k, v) in TVList.list) {
|
||||
val listRowAdapter = ArrayObjectAdapter(cardPresenter)
|
||||
for ((idx2, v1) in v.withIndex()) {
|
||||
val tvViewModel = TVViewModel(v1)
|
||||
tvViewModel.setRowPosition(idx.toInt())
|
||||
tvViewModel.setItemPosition(idx2)
|
||||
tvListViewModel.addTVViewModel(tvViewModel)
|
||||
listRowAdapter.add(tvViewModel)
|
||||
}
|
||||
tvListViewModel.maxNum.add(v.size)
|
||||
val header = HeaderItem(idx, k)
|
||||
rowsAdapter!!.add(ListRow(header, listRowAdapter))
|
||||
idx++
|
||||
}
|
||||
|
||||
adapter = rowsAdapter
|
||||
|
||||
itemPosition = sharedPref.getInt(POSITION, 0)
|
||||
if (itemPosition >= tvListViewModel.size()) {
|
||||
itemPosition = 0
|
||||
}
|
||||
tvListViewModel.setItemPosition(itemPosition)
|
||||
}
|
||||
|
||||
fun prevSource() {
|
||||
view?.post {
|
||||
val tvViewModel = tvListViewModel.getTVViewModel(itemPosition)
|
||||
if (tvViewModel != null) {
|
||||
if (tvViewModel.videoUrl.value!!.size > 1) {
|
||||
val videoIndex = tvViewModel.videoIndex.value?.minus(1)
|
||||
if (videoIndex == -1) {
|
||||
tvViewModel.setVideoIndex(tvViewModel.videoUrl.value!!.size - 1)
|
||||
}
|
||||
tvViewModel.changed()
|
||||
}
|
||||
}
|
||||
(activity as MainActivity).fragmentReady()
|
||||
}
|
||||
}
|
||||
|
||||
fun nextSource() {
|
||||
view?.post {
|
||||
val tvViewModel = tvListViewModel.getTVViewModel(itemPosition)
|
||||
if (tvViewModel != null) {
|
||||
if (tvViewModel.videoUrl.value!!.size > 1) {
|
||||
val videoIndex = tvViewModel.videoIndex.value?.plus(1)
|
||||
if (videoIndex == tvViewModel.videoUrl.value!!.size) {
|
||||
tvViewModel.setVideoIndex(0)
|
||||
}
|
||||
tvViewModel.changed()
|
||||
}
|
||||
}
|
||||
override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
|
||||
super.onViewCreated(view, savedInstanceState)
|
||||
}
|
||||
|
||||
override fun onItemFocusChange(tvViewModel: TVViewModel, hasFocus: Boolean) {
|
||||
if (hasFocus) {
|
||||
tvListViewModel.setItemPositionCurrent(tvViewModel.id.value!!)
|
||||
(activity as MainActivity).keepRunnable()
|
||||
}
|
||||
}
|
||||
|
||||
private fun setupEventListeners() {
|
||||
onItemViewClickedListener = ItemViewClickedListener()
|
||||
onItemViewSelectedListener = ItemViewSelectedListener()
|
||||
override fun onItemClicked(tvViewModel: TVViewModel) {
|
||||
if (this.isHidden) {
|
||||
(activity as? MainActivity)?.switchMainFragment()
|
||||
return
|
||||
}
|
||||
|
||||
if (itemPosition != tvViewModel.id.value!!) {
|
||||
itemPosition = tvViewModel.id.value!!
|
||||
tvListViewModel.setItemPosition(itemPosition)
|
||||
tvListViewModel.getTVViewModel(itemPosition)?.changed()
|
||||
}
|
||||
(activity as? MainActivity)?.switchMainFragment()
|
||||
}
|
||||
|
||||
private inner class ItemViewClickedListener : OnItemViewClickedListener {
|
||||
override fun onItemClicked(
|
||||
itemViewHolder: Presenter.ViewHolder,
|
||||
item: Any,
|
||||
rowViewHolder: RowPresenter.ViewHolder,
|
||||
row: Row
|
||||
) {
|
||||
if (item is TVViewModel) {
|
||||
if (itemPosition != item.id.value!!) {
|
||||
itemPosition = item.id.value!!
|
||||
tvListViewModel.setItemPosition(itemPosition)
|
||||
tvListViewModel.getTVViewModel(itemPosition)?.changed()
|
||||
}
|
||||
(activity as? MainActivity)?.switchMainFragment()
|
||||
}
|
||||
fun setPosition() {
|
||||
val tvViewModel = tvListViewModel.getTVViewModel(itemPosition)
|
||||
Log.i(TAG, "tvViewModel $tvViewModel")
|
||||
Log.i(TAG, "rowList ${rowList.size}")
|
||||
rowList[tvViewModel!!.getRowPosition()].post {
|
||||
((rowList[tvViewModel.getRowPosition()] as RecyclerView).layoutManager as LinearLayoutManager).findViewByPosition(
|
||||
tvViewModel.getItemPosition()
|
||||
)?.requestFocus()
|
||||
}
|
||||
}
|
||||
|
||||
private inner class ItemViewSelectedListener : OnItemViewSelectedListener {
|
||||
override fun onItemSelected(
|
||||
itemViewHolder: Presenter.ViewHolder?, item: Any?,
|
||||
rowViewHolder: RowPresenter.ViewHolder, row: Row
|
||||
) {
|
||||
if (item is TVViewModel) {
|
||||
tvListViewModel.setItemPositionCurrent(item.id.value!!)
|
||||
(activity as MainActivity).keepRunnable()
|
||||
}
|
||||
fun setPosition(rowPosition: Int, itemPosition: Int) {
|
||||
rowList[rowPosition].post {
|
||||
((rowList[rowPosition] as RecyclerView).layoutManager as LinearLayoutManager).findViewByPosition(
|
||||
itemPosition
|
||||
)?.requestFocus()
|
||||
}
|
||||
}
|
||||
|
||||
@@ -245,12 +212,8 @@ class MainFragment : BrowseSupportFragment() {
|
||||
}
|
||||
|
||||
fun fragmentReady() {
|
||||
ready++
|
||||
Log.i(TAG, "ready $ready")
|
||||
if (ready == 4) {
|
||||
// request.fetchPage()
|
||||
tvListViewModel.getTVViewModel(itemPosition)?.changed()
|
||||
}
|
||||
tvListViewModel.getTVViewModel(itemPosition)?.changed()
|
||||
}
|
||||
|
||||
fun play(itemPosition: Int) {
|
||||
@@ -332,7 +295,15 @@ class MainFragment : BrowseSupportFragment() {
|
||||
override fun onDestroy() {
|
||||
Log.i(TAG, "onDestroy")
|
||||
super.onDestroy()
|
||||
handler.removeCallbacks(mUpdateProgramRunnable)
|
||||
if (::mUpdateProgramRunnable.isInitialized) {
|
||||
handler.removeCallbacks(mUpdateProgramRunnable)
|
||||
}
|
||||
}
|
||||
|
||||
override fun onDestroyView() {
|
||||
Log.i(TAG, "onDestroyView")
|
||||
super.onDestroyView()
|
||||
_binding = null
|
||||
}
|
||||
|
||||
companion object {
|
||||
|
||||
@@ -3,8 +3,6 @@ package com.lizongying.mytv
|
||||
import android.os.Bundle
|
||||
import android.util.Log
|
||||
import android.view.LayoutInflater
|
||||
import android.view.SurfaceHolder
|
||||
import android.view.SurfaceView
|
||||
import android.view.View
|
||||
import android.view.ViewGroup
|
||||
import android.view.ViewTreeObserver
|
||||
@@ -17,39 +15,23 @@ import androidx.media3.common.VideoSize
|
||||
import androidx.media3.common.util.UnstableApi
|
||||
import androidx.media3.exoplayer.ExoPlayer
|
||||
import androidx.media3.ui.PlayerView
|
||||
import com.google.android.exoplayer2.SimpleExoPlayer
|
||||
import com.lizongying.mytv.databinding.PlayerBinding
|
||||
import com.lizongying.mytv.models.TVViewModel
|
||||
|
||||
|
||||
class PlayerFragment : Fragment(), SurfaceHolder.Callback {
|
||||
class PlayerFragment : Fragment() {
|
||||
|
||||
private var _binding: PlayerBinding? = null
|
||||
private var playerView: PlayerView? = null
|
||||
private var tvViewModel: TVViewModel? = null
|
||||
private val aspectRatio = 16f / 9f
|
||||
|
||||
|
||||
private lateinit var surfaceView: SurfaceView
|
||||
private lateinit var surfaceHolder: SurfaceHolder
|
||||
private var exoPlayer: SimpleExoPlayer? = null
|
||||
|
||||
override fun onCreateView(
|
||||
inflater: LayoutInflater, container: ViewGroup?,
|
||||
savedInstanceState: Bundle?
|
||||
): View {
|
||||
_binding = PlayerBinding.inflate(inflater, container, false)
|
||||
|
||||
if (Utils.isTmallDevice()) {
|
||||
_binding!!.playerView.visibility = View.GONE
|
||||
surfaceView = _binding!!.surfaceView
|
||||
surfaceHolder = surfaceView.holder
|
||||
surfaceHolder.addCallback(this)
|
||||
} else {
|
||||
_binding!!.surfaceView.visibility = View.GONE
|
||||
playerView = _binding!!.playerView
|
||||
}
|
||||
|
||||
playerView = _binding!!.playerView
|
||||
playerView?.viewTreeObserver?.addOnGlobalLayoutListener(object :
|
||||
ViewTreeObserver.OnGlobalLayoutListener {
|
||||
override fun onGlobalLayout() {
|
||||
@@ -80,6 +62,7 @@ class PlayerFragment : Fragment(), SurfaceHolder.Callback {
|
||||
super.onPlayerError(error)
|
||||
|
||||
Log.e(TAG, "PlaybackException $error")
|
||||
tvViewModel?.changed()
|
||||
}
|
||||
})
|
||||
}
|
||||
@@ -95,10 +78,6 @@ class PlayerFragment : Fragment(), SurfaceHolder.Callback {
|
||||
setMediaItem(MediaItem.fromUri(tvViewModel.getVideoUrlCurrent()))
|
||||
prepare()
|
||||
}
|
||||
exoPlayer?.run {
|
||||
setMediaItem(com.google.android.exoplayer2.MediaItem.fromUri(tvViewModel.getVideoUrlCurrent()))
|
||||
prepare()
|
||||
}
|
||||
}
|
||||
|
||||
override fun onStart() {
|
||||
@@ -107,10 +86,9 @@ class PlayerFragment : Fragment(), SurfaceHolder.Callback {
|
||||
if (playerView != null && playerView!!.player?.isPlaying == false) {
|
||||
Log.i(TAG, "replay")
|
||||
playerView!!.player?.prepare()
|
||||
}
|
||||
if (exoPlayer?.isPlaying == false) {
|
||||
Log.i(TAG, "replay")
|
||||
exoPlayer?.prepare()
|
||||
playerView!!.player?.play()
|
||||
} else {
|
||||
Log.i(TAG, "playing")
|
||||
}
|
||||
}
|
||||
|
||||
@@ -124,9 +102,6 @@ class PlayerFragment : Fragment(), SurfaceHolder.Callback {
|
||||
if (playerView != null && playerView!!.player?.isPlaying == true) {
|
||||
playerView!!.player?.stop()
|
||||
}
|
||||
if (exoPlayer?.isPlaying == true) {
|
||||
exoPlayer?.stop()
|
||||
}
|
||||
}
|
||||
|
||||
override fun onDestroy() {
|
||||
@@ -134,7 +109,6 @@ class PlayerFragment : Fragment(), SurfaceHolder.Callback {
|
||||
if (playerView != null) {
|
||||
playerView!!.player?.release()
|
||||
}
|
||||
exoPlayer?.release()
|
||||
}
|
||||
|
||||
override fun onDestroyView() {
|
||||
@@ -145,16 +119,4 @@ class PlayerFragment : Fragment(), SurfaceHolder.Callback {
|
||||
companion object {
|
||||
private const val TAG = "PlaybackVideoFragment"
|
||||
}
|
||||
|
||||
override fun surfaceCreated(holder: SurfaceHolder) {
|
||||
exoPlayer = SimpleExoPlayer.Builder(requireContext()).build()
|
||||
exoPlayer?.setVideoSurfaceHolder(surfaceHolder)
|
||||
exoPlayer?.playWhenReady = true
|
||||
}
|
||||
|
||||
override fun surfaceChanged(holder: SurfaceHolder, format: Int, width: Int, height: Int) {
|
||||
}
|
||||
|
||||
override fun surfaceDestroyed(holder: SurfaceHolder) {
|
||||
}
|
||||
}
|
||||
@@ -7,6 +7,8 @@ import android.util.Base64
|
||||
import android.util.Log
|
||||
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.Info
|
||||
import com.lizongying.mytv.api.LiveInfo
|
||||
import com.lizongying.mytv.api.LiveInfoRequest
|
||||
@@ -52,6 +54,84 @@ class Request {
|
||||
}
|
||||
|
||||
var call: Call<LiveInfo>? = null
|
||||
var callAuth: Call<Auth>? = null
|
||||
|
||||
private fun fetchAuth(tvModel: TVViewModel, cookie: String) {
|
||||
callAuth?.cancel()
|
||||
|
||||
val title = tvModel.title.value
|
||||
|
||||
val data = ysp?.getAuthData(tvModel)
|
||||
val request = data?.let { AuthRequest(it) }
|
||||
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 (tvModel.tokenRetryTimes == tvModel.tokenRetryMaxTimes) {
|
||||
if (!tvModel.getTV().mustToken) {
|
||||
fetchAuth(tvModel, cookie)
|
||||
}
|
||||
} else {
|
||||
token = ""
|
||||
fetchAuth(tvModel)
|
||||
}
|
||||
} else {
|
||||
fetchAuth(tvModel, cookie)
|
||||
}
|
||||
}
|
||||
}
|
||||
} else {
|
||||
Log.e(TAG, "$title auth status error")
|
||||
if (tvModel.retryTimes < tvModel.retryMaxTimes) {
|
||||
tvModel.retryTimes++
|
||||
if (tvModel.getTV().needToken) {
|
||||
if (tvModel.tokenRetryTimes == tvModel.tokenRetryMaxTimes) {
|
||||
if (!tvModel.getTV().mustToken) {
|
||||
fetchAuth(tvModel, cookie)
|
||||
}
|
||||
} else {
|
||||
token = ""
|
||||
fetchAuth(tvModel)
|
||||
}
|
||||
} 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 (tvModel.tokenRetryTimes == tvModel.tokenRetryMaxTimes) {
|
||||
if (!tvModel.getTV().mustToken) {
|
||||
fetchVideo(tvModel, cookie)
|
||||
}
|
||||
} else {
|
||||
token = ""
|
||||
fetchAuth(tvModel)
|
||||
}
|
||||
} else {
|
||||
fetchAuth(tvModel, cookie)
|
||||
}
|
||||
}
|
||||
}
|
||||
})
|
||||
}
|
||||
|
||||
fun fetchVideo(tvModel: TVViewModel, cookie: String) {
|
||||
call?.cancel()
|
||||
@@ -64,7 +144,7 @@ class Request {
|
||||
tvModel.seq = 0
|
||||
val data = ysp?.switch(tvModel)
|
||||
val request = data?.let { LiveInfoRequest(it) }
|
||||
call = request?.let { yspApiService.getLiveInfo("guid=${ysp?.getGuid()}; $cookie", it) }
|
||||
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>) {
|
||||
@@ -175,16 +255,63 @@ class Request {
|
||||
})
|
||||
}
|
||||
|
||||
fun fetchAuth(tvModel: TVViewModel) {
|
||||
if (token == "") {
|
||||
yspTokenService.getInfo()
|
||||
.enqueue(object : Callback<Info> {
|
||||
override fun onResponse(call: Call<Info>, response: Response<Info>) {
|
||||
if (response.isSuccessful) {
|
||||
token = response.body()?.data?.token!!
|
||||
Log.i(TAG, "info success $token")
|
||||
val cookie =
|
||||
"versionName=99.99.99; versionCode=999999; vplatform=109; platformVersion=Chrome; deviceModel=120; appid=1400421205; yspappid=519748109;yspopenid=vu0-8lgGV2LW9QjDeuBFsX8yMnzs37Q3_HZF6XyVDpGR_I; vusession=$token"
|
||||
fetchAuth(tvModel, cookie)
|
||||
} else {
|
||||
Log.e(TAG, "info status error")
|
||||
if (tvModel.tokenRetryTimes < tvModel.tokenRetryMaxTimes) {
|
||||
tvModel.tokenRetryTimes++
|
||||
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.tokenRetryTimes < tvModel.tokenRetryMaxTimes) {
|
||||
tvModel.tokenRetryTimes++
|
||||
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=vu0-8lgGV2LW9QjDeuBFsX8yMnzs37Q3_HZF6XyVDpGR_I; vusession=$token"
|
||||
fetchAuth(tvModel, cookie)
|
||||
}
|
||||
}
|
||||
|
||||
fun fetchVideo(tvModel: TVViewModel) {
|
||||
if (token == "") {
|
||||
yspTokenService.getInfo()
|
||||
.enqueue(object : Callback<Info> {
|
||||
override fun onResponse(call: Call<Info>, response: Response<Info>) {
|
||||
if (response.isSuccessful && response.body()?.data?.token != null) {
|
||||
if (response.isSuccessful) {
|
||||
token = response.body()?.data?.token!!
|
||||
Log.i(TAG, "info success $token")
|
||||
val cookie =
|
||||
"versionName=99.99.99; versionCode=999999; vplatform=109; platformVersion=Chrome; deviceModel=120; yspappid=519748109;yspopenid=vu0-8lgGV2LW9QjDeuBFsX8yMnzs37Q3_HZF6XyVDpGR_I; vusession=$token"
|
||||
"versionName=99.99.99; versionCode=999999; vplatform=109; platformVersion=Chrome; deviceModel=120; appid=1400421205; yspappid=519748109;yspopenid=vu0-8lgGV2LW9QjDeuBFsX8yMnzs37Q3_HZF6XyVDpGR_I; vusession=$token"
|
||||
fetchVideo(tvModel, cookie)
|
||||
} else {
|
||||
Log.e(TAG, "info status error")
|
||||
@@ -194,7 +321,7 @@ class Request {
|
||||
} else {
|
||||
if (!tvModel.getTV().mustToken) {
|
||||
val cookie =
|
||||
"versionName=99.99.99; versionCode=999999; vplatform=109; platformVersion=Chrome; deviceModel=120; yspappid=519748109"
|
||||
"versionName=99.99.99; versionCode=999999; vplatform=109; platformVersion=Chrome; deviceModel=120; appid=1400421205; yspappid=519748109"
|
||||
fetchVideo(tvModel, cookie)
|
||||
}
|
||||
}
|
||||
@@ -209,7 +336,7 @@ class Request {
|
||||
} else {
|
||||
if (!tvModel.getTV().mustToken) {
|
||||
val cookie =
|
||||
"versionName=99.99.99; versionCode=999999; vplatform=109; platformVersion=Chrome; deviceModel=120; yspappid=519748109"
|
||||
"versionName=99.99.99; versionCode=999999; vplatform=109; platformVersion=Chrome; deviceModel=120; appid=1400421205; yspappid=519748109"
|
||||
fetchVideo(tvModel, cookie)
|
||||
}
|
||||
}
|
||||
@@ -217,18 +344,20 @@ class Request {
|
||||
})
|
||||
} else {
|
||||
val cookie =
|
||||
"versionName=99.99.99; versionCode=999999; vplatform=109; platformVersion=Chrome; deviceModel=120; yspappid=519748109;yspopenid=vu0-8lgGV2LW9QjDeuBFsX8yMnzs37Q3_HZF6XyVDpGR_I; vusession=$token"
|
||||
"versionName=99.99.99; versionCode=999999; vplatform=109; platformVersion=Chrome; deviceModel=120; appid=1400421205; yspappid=519748109;yspopenid=vu0-8lgGV2LW9QjDeuBFsX8yMnzs37Q3_HZF6XyVDpGR_I; vusession=$token"
|
||||
fetchVideo(tvModel, cookie)
|
||||
}
|
||||
}
|
||||
|
||||
fun fetchData(tvModel: TVViewModel) {
|
||||
if (tvModel.getTV().needToken) {
|
||||
fetchVideo(tvModel)
|
||||
// fetchVideo(tvModel)
|
||||
fetchAuth(tvModel)
|
||||
} else {
|
||||
val cookie =
|
||||
"versionName=99.99.99; versionCode=999999; vplatform=109; platformVersion=Chrome; deviceModel=120; yspappid=519748109"
|
||||
fetchVideo(tvModel, cookie)
|
||||
"versionName=99.99.99; versionCode=999999; vplatform=109; platformVersion=Chrome; deviceModel=120; appid=1400421205"
|
||||
// fetchVideo(tvModel, cookie)
|
||||
fetchAuth(tvModel, cookie)
|
||||
}
|
||||
}
|
||||
|
||||
@@ -243,7 +372,7 @@ class Request {
|
||||
yspTokenService.getInfo()
|
||||
.enqueue(object : Callback<Info> {
|
||||
override fun onResponse(call: Call<Info>, response: Response<Info>) {
|
||||
if (response.isSuccessful && response.body()?.data?.token != null) {
|
||||
if (response.isSuccessful) {
|
||||
token = response.body()?.data?.token!!
|
||||
Log.i(TAG, "info success $token")
|
||||
} else {
|
||||
|
||||
@@ -1,23 +1,28 @@
|
||||
package com.lizongying.mytv
|
||||
|
||||
import android.os.Build
|
||||
import android.os.Bundle
|
||||
import android.view.LayoutInflater
|
||||
import android.view.View
|
||||
import android.view.ViewGroup
|
||||
import androidx.annotation.RequiresApi
|
||||
import androidx.fragment.app.DialogFragment
|
||||
import com.lizongying.mytv.databinding.DialogBinding
|
||||
|
||||
|
||||
class SettingFragment(private val versionName: String,
|
||||
private val channelReversal: Boolean,
|
||||
private val channelNum: Boolean,
|
||||
private val bootStartup: Boolean,
|
||||
) :
|
||||
class SettingFragment(
|
||||
private val versionName: String,
|
||||
private val versionCode: Long,
|
||||
private val channelReversal: Boolean,
|
||||
private val channelNum: Boolean,
|
||||
) :
|
||||
DialogFragment() {
|
||||
|
||||
private var _binding: DialogBinding? = null
|
||||
private val binding get() = _binding!!
|
||||
|
||||
private lateinit var updateManager: UpdateManager
|
||||
|
||||
override fun onCreate(savedInstanceState: Bundle?) {
|
||||
super.onCreate(savedInstanceState)
|
||||
setStyle(STYLE_NO_TITLE, 0)
|
||||
@@ -44,20 +49,33 @@ class SettingFragment(private val versionName: String,
|
||||
(activity as MainActivity).saveChannelNum(isChecked)
|
||||
}
|
||||
|
||||
val switchBootStartup = _binding?.switchBootStartup
|
||||
switchBootStartup?.isChecked = bootStartup
|
||||
switchBootStartup?.setOnCheckedChangeListener { _, isChecked ->
|
||||
(activity as MainActivity).saveBootStartup(isChecked)
|
||||
}
|
||||
updateManager = UpdateManager(context, this, versionCode)
|
||||
_binding?.checkVersion?.setOnClickListener(OnClickListenerCheckVersion(updateManager))
|
||||
|
||||
return binding.root
|
||||
}
|
||||
|
||||
fun setVersionName(versionName: String) {
|
||||
binding.versionName.text = versionName
|
||||
}
|
||||
|
||||
internal class OnClickListenerCheckVersion(private val updateManager: UpdateManager) :
|
||||
View.OnClickListener {
|
||||
override fun onClick(view: View?) {
|
||||
updateManager.checkAndUpdate()
|
||||
}
|
||||
}
|
||||
|
||||
override fun onDestroyView() {
|
||||
super.onDestroyView()
|
||||
_binding = null
|
||||
}
|
||||
|
||||
override fun onDestroy() {
|
||||
super.onDestroy()
|
||||
// updateManager.destroy()
|
||||
}
|
||||
|
||||
companion object {
|
||||
const val TAG = "SettingFragment"
|
||||
}
|
||||
|
||||
@@ -1,12 +1,5 @@
|
||||
package com.lizongying.mytv
|
||||
|
||||
import android.content.Context
|
||||
import android.util.Log
|
||||
import kotlinx.coroutines.CoroutineScope
|
||||
import kotlinx.coroutines.Dispatchers
|
||||
import kotlinx.coroutines.launch
|
||||
import java.io.IOException
|
||||
|
||||
object TVList {
|
||||
var list = mapOf(
|
||||
"央视频道" to listOf(
|
||||
@@ -859,10 +852,24 @@ object TVList {
|
||||
true,
|
||||
mustToken = false
|
||||
),
|
||||
TV(
|
||||
56,
|
||||
"兵团卫视",
|
||||
"兵团卫视",
|
||||
listOf(),
|
||||
0,
|
||||
"地方频道",
|
||||
"",
|
||||
"600170344",
|
||||
"2022606701",
|
||||
"",
|
||||
true,
|
||||
mustToken = false
|
||||
),
|
||||
),
|
||||
"国际频道" to listOf(
|
||||
TV(
|
||||
56,
|
||||
57,
|
||||
"CGTN",
|
||||
"CGTN",
|
||||
listOf("http://live.cgtn.com/1000/prog_index.m3u8"),
|
||||
@@ -876,7 +883,7 @@ object TVList {
|
||||
mustToken = false
|
||||
),
|
||||
TV(
|
||||
57,
|
||||
58,
|
||||
"CGTN 法语频道",
|
||||
"CGTN法语频道",
|
||||
listOf("https://livefr.cgtn.com/1000f/prog_index.m3u8"),
|
||||
@@ -890,7 +897,7 @@ object TVList {
|
||||
mustToken = false
|
||||
),
|
||||
TV(
|
||||
58,
|
||||
59,
|
||||
"CGTN 俄语频道",
|
||||
"CGTN俄语频道",
|
||||
listOf("http://liveru.cgtn.com/1000r/prog_index.m3u8"),
|
||||
@@ -904,7 +911,7 @@ object TVList {
|
||||
mustToken = false
|
||||
),
|
||||
TV(
|
||||
59,
|
||||
60,
|
||||
"CGTN 阿拉伯语频道",
|
||||
"CGTN阿拉伯语频道",
|
||||
listOf("http://livear.cgtn.com/1000a/prog_index.m3u8"),
|
||||
@@ -918,7 +925,7 @@ object TVList {
|
||||
mustToken = false
|
||||
),
|
||||
TV(
|
||||
60,
|
||||
61,
|
||||
"CGTN 西班牙语频道",
|
||||
"CGTN西班牙语频道",
|
||||
listOf(
|
||||
@@ -935,7 +942,7 @@ object TVList {
|
||||
mustToken = false
|
||||
),
|
||||
TV(
|
||||
61,
|
||||
62,
|
||||
"CGTN 纪录频道",
|
||||
"CGTN外语纪录频道",
|
||||
listOf("https://livedoc.cgtn.com/500d/prog_index.m3u8"),
|
||||
@@ -950,63 +957,4 @@ object TVList {
|
||||
),
|
||||
)
|
||||
)
|
||||
|
||||
/**
|
||||
* 初始化
|
||||
*
|
||||
* @param context Context
|
||||
*/
|
||||
fun init(context: Context) {
|
||||
CoroutineScope(Dispatchers.Default).launch {
|
||||
//获取本地版本号
|
||||
val localVersion = ChannelUtils.getLocalVersion(context)
|
||||
//获取服务器版本号
|
||||
val serverVersion = try {
|
||||
ChannelUtils.getServerVersion(context)
|
||||
} catch (e: IOException) {
|
||||
Log.e("TVList", "无法从服务器获取版本信息", e)
|
||||
Integer.MIN_VALUE
|
||||
}
|
||||
//频道列表
|
||||
val channelTVMap: MutableMap<String, MutableList<TV>> = mutableMapOf()
|
||||
//是否从服务器更新
|
||||
var updateFromServer = false
|
||||
//获取频道列表
|
||||
val tvList: List<TV> = if (localVersion < serverVersion) {
|
||||
//获取服务器地址
|
||||
val url = ChannelUtils.getServerUrl(context)
|
||||
//是否从服务器更新
|
||||
updateFromServer = true
|
||||
Log.i("TVList", "从服务器获取频道信息")
|
||||
try {
|
||||
ChannelUtils.getServerChannel(url)
|
||||
} catch (e: IOException) {
|
||||
Log.e("TVList", "无法从服务器获取频道信息", e)
|
||||
updateFromServer = false
|
||||
ChannelUtils.getLocalChannel(context)
|
||||
}
|
||||
} else {
|
||||
Log.i("TVList", "从本地获取频道信息")
|
||||
//获取本地频道
|
||||
ChannelUtils.getLocalChannel(context)
|
||||
}
|
||||
//按频道分类
|
||||
for (tv in tvList) {
|
||||
val key = tv.channel
|
||||
if (channelTVMap.containsKey(key)) {
|
||||
val list = channelTVMap[key]!!
|
||||
list.add(tv)
|
||||
channelTVMap[key] = list
|
||||
} else {
|
||||
channelTVMap[key] = mutableListOf(tv)
|
||||
}
|
||||
}
|
||||
//保存频道列表
|
||||
list = channelTVMap
|
||||
//保存版本号
|
||||
if (updateFromServer) {
|
||||
ChannelUtils.updateLocalChannel(context, serverVersion, tvList)
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -1,5 +1,189 @@
|
||||
package com.lizongying.mytv
|
||||
|
||||
class UpdateManager {
|
||||
import android.app.DownloadManager
|
||||
import android.app.DownloadManager.Request
|
||||
import android.content.BroadcastReceiver
|
||||
import android.content.Context
|
||||
import android.content.Intent
|
||||
import android.content.IntentFilter
|
||||
import android.database.Cursor
|
||||
import android.net.Uri
|
||||
import android.os.Build
|
||||
import android.os.Environment
|
||||
import android.os.Handler
|
||||
import android.os.Looper
|
||||
import android.util.Log
|
||||
import android.widget.Toast
|
||||
import com.lizongying.mytv.api.Release
|
||||
import com.lizongying.mytv.requests.MyRequest
|
||||
import kotlinx.coroutines.CoroutineScope
|
||||
import kotlinx.coroutines.Dispatchers
|
||||
import kotlinx.coroutines.launch
|
||||
import java.io.File
|
||||
|
||||
|
||||
class UpdateManager(
|
||||
private var context: Context?,
|
||||
private var settingFragment: SettingFragment,
|
||||
private var versionCode: Long
|
||||
) :
|
||||
ConfirmationDialogFragment.ConfirmationDialogListener {
|
||||
|
||||
private var myRequest = MyRequest()
|
||||
private var release: Release? = null
|
||||
|
||||
private var downloadReceiver: DownloadReceiver? = null
|
||||
|
||||
fun checkAndUpdate() {
|
||||
CoroutineScope(Dispatchers.Main).launch {
|
||||
try {
|
||||
release = myRequest.getRelease()
|
||||
updateUI(release)
|
||||
Log.i(TAG, "versionCode $versionCode ${release?.data?.versionCode}")
|
||||
if (release != null) {
|
||||
if (release?.data?.versionCode!! >= versionCode) {
|
||||
val dialog = ConfirmationDialogFragment(this@UpdateManager)
|
||||
dialog.show(settingFragment.fragmentManager, "ConfirmationDialogFragment")
|
||||
} else {
|
||||
Toast.makeText(context, "不需要更新", Toast.LENGTH_LONG)
|
||||
.show()
|
||||
}
|
||||
}
|
||||
} catch (e: Exception) {
|
||||
Log.e(TAG, "Error occurred: ${e.message}", e)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private fun updateUI(release: Release?) {
|
||||
if (release?.data?.versionName.isNullOrEmpty()) {
|
||||
settingFragment.setVersionName("版本获取失败")
|
||||
} else {
|
||||
settingFragment.setVersionName("最新版本:${release?.data?.versionName!!}")
|
||||
}
|
||||
}
|
||||
|
||||
private fun startDownload(release: Release) {
|
||||
val apkFileName = "my-tv-${release.data.versionName}.apk"
|
||||
Log.i(TAG, "apkFileName $apkFileName")
|
||||
val downloadManager =
|
||||
context!!.getSystemService(Context.DOWNLOAD_SERVICE) as DownloadManager
|
||||
val request = Request(Uri.parse(release.data.downloadUrl))
|
||||
Log.i(TAG, "url ${Uri.parse(release.data.downloadUrl)}")
|
||||
request.setDestinationInExternalPublicDir(Environment.DIRECTORY_DOWNLOADS, apkFileName)
|
||||
request.setTitle("New Version Download")
|
||||
request.setNotificationVisibility(Request.VISIBILITY_VISIBLE_NOTIFY_COMPLETED)
|
||||
|
||||
// 获取下载任务的引用
|
||||
val downloadReference = downloadManager.enqueue(request)
|
||||
|
||||
downloadReceiver = DownloadReceiver(context!!, apkFileName, downloadReference)
|
||||
|
||||
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
|
||||
context!!.registerReceiver(
|
||||
downloadReceiver,
|
||||
IntentFilter(DownloadManager.ACTION_DOWNLOAD_COMPLETE),
|
||||
Context.RECEIVER_NOT_EXPORTED,
|
||||
)
|
||||
} else {
|
||||
context!!.registerReceiver(
|
||||
downloadReceiver,
|
||||
IntentFilter(DownloadManager.ACTION_DOWNLOAD_COMPLETE)
|
||||
)
|
||||
}
|
||||
|
||||
getDownloadProgress(context!!, downloadReference) { progress ->
|
||||
println("Download progress: $progress%")
|
||||
}
|
||||
}
|
||||
|
||||
private fun getDownloadProgress(context: Context, downloadId: Long, progressListener: (Int) -> Unit) {
|
||||
val downloadManager = context.getSystemService(Context.DOWNLOAD_SERVICE) as DownloadManager
|
||||
val handler = Handler(Looper.getMainLooper())
|
||||
val intervalMillis: Long = 1000
|
||||
|
||||
handler.post(object : Runnable {
|
||||
override fun run() {
|
||||
Log.i(TAG, "search")
|
||||
val query = DownloadManager.Query().setFilterById(downloadId)
|
||||
val cursor: Cursor = downloadManager.query(query)
|
||||
cursor.use {
|
||||
if (it.moveToFirst()) {
|
||||
val bytesDownloadedIndex =
|
||||
it.getColumnIndex(DownloadManager.COLUMN_BYTES_DOWNLOADED_SO_FAR)
|
||||
val bytesTotalIndex =
|
||||
it.getColumnIndex(DownloadManager.COLUMN_TOTAL_SIZE_BYTES)
|
||||
|
||||
// 检查列名是否存在
|
||||
if (bytesDownloadedIndex != -1 && bytesTotalIndex != -1) {
|
||||
val bytesDownloaded = it.getInt(bytesDownloadedIndex)
|
||||
val bytesTotal = it.getInt(bytesTotalIndex)
|
||||
|
||||
if (bytesTotal != -1) {
|
||||
val progress = (bytesDownloaded * 100L / bytesTotal).toInt()
|
||||
progressListener(progress)
|
||||
if (progress == 100) {
|
||||
return
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// handler.postDelayed(this, intervalMillis)
|
||||
}
|
||||
})
|
||||
}
|
||||
|
||||
private class DownloadReceiver(
|
||||
private val context: Context,
|
||||
private val apkFileName: String,
|
||||
private val downloadReference: Long
|
||||
) : BroadcastReceiver() {
|
||||
override fun onReceive(context: Context, intent: Intent) {
|
||||
val reference = intent.getLongExtra(DownloadManager.EXTRA_DOWNLOAD_ID, -1)
|
||||
Log.i(TAG, "reference $reference")
|
||||
val progress = intent.getIntExtra("progress", 0)
|
||||
Log.i(TAG, "progress $progress")
|
||||
|
||||
// 检查是否是我们发起的下载
|
||||
if (reference == downloadReference) {
|
||||
// 下载完成,触发安装
|
||||
installNewVersion()
|
||||
}
|
||||
}
|
||||
|
||||
private fun installNewVersion() {
|
||||
val installIntent = Intent(Intent.ACTION_VIEW)
|
||||
val apkUri = Uri.fromFile(
|
||||
File(
|
||||
Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS),
|
||||
apkFileName
|
||||
)
|
||||
)
|
||||
installIntent.setDataAndType(apkUri, "application/vnd.android.package-archive")
|
||||
installIntent.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK)
|
||||
context.startActivity(installIntent)
|
||||
}
|
||||
}
|
||||
|
||||
companion object {
|
||||
private const val TAG = "UpdateManager"
|
||||
}
|
||||
|
||||
override fun onConfirm() {
|
||||
Log.i(TAG, "onConfirm $release")
|
||||
release?.let { startDownload(it) }
|
||||
}
|
||||
|
||||
override fun onCancel() {
|
||||
}
|
||||
|
||||
|
||||
fun destroy() {
|
||||
if (downloadReceiver != null) {
|
||||
context!!.unregisterReceiver(downloadReceiver)
|
||||
Log.i(TAG, "destroy downloadReceiver")
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -1,12 +1,13 @@
|
||||
package com.lizongying.mytv
|
||||
|
||||
import android.content.Context
|
||||
import android.content.res.Resources
|
||||
import android.os.Build
|
||||
import android.util.TypedValue
|
||||
import com.google.gson.Gson
|
||||
import com.lizongying.mytv.api.TimeResponse
|
||||
import kotlinx.coroutines.Dispatchers
|
||||
import kotlinx.coroutines.withContext
|
||||
import java.io.File
|
||||
import java.io.IOException
|
||||
import java.text.SimpleDateFormat
|
||||
import java.util.Date
|
||||
@@ -73,5 +74,48 @@ object Utils {
|
||||
).toInt()
|
||||
}
|
||||
|
||||
fun isTmallDevice() = Build.MANUFACTURER.equals("Tmall", ignoreCase = true)
|
||||
/**
|
||||
* 获取可读写的目录
|
||||
*
|
||||
* @param context 应用环境信息
|
||||
*
|
||||
* @return 可读写的目录
|
||||
*
|
||||
*/
|
||||
fun getAppDirectory(context: Context): File {
|
||||
return context.filesDir
|
||||
}
|
||||
|
||||
/**
|
||||
* 更新channels.json
|
||||
*
|
||||
* @param context 应用环境信息
|
||||
*
|
||||
* @return 无
|
||||
*
|
||||
* @throws IOException 网络请求失败
|
||||
*/
|
||||
fun updateChannel(context: Context) {
|
||||
val client = okhttp3.OkHttpClient()
|
||||
val request = okhttp3.Request.Builder().url(getServerUrl(context)).build()
|
||||
client.newCall(request).execute().use { response ->
|
||||
if (!response.isSuccessful) throw IOException("Unexpected code $response")
|
||||
val body = response.body()
|
||||
//覆盖channels.json
|
||||
val file = File(getAppDirectory(context), "channels.json")
|
||||
if (!file.exists()) {
|
||||
file.createNewFile()
|
||||
}
|
||||
file.writeText(body!!.string())
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 从res/values/server.xml获取服务器地址
|
||||
* @param context 应用环境信息
|
||||
* @return 服务器地址
|
||||
*/
|
||||
private fun getServerUrl(context: Context): String {
|
||||
return context.resources.getString(R.string.server_url)
|
||||
}
|
||||
}
|
||||
@@ -5,6 +5,8 @@ import okhttp3.OkHttpClient
|
||||
import retrofit2.Retrofit
|
||||
import retrofit2.converter.gson.GsonConverterFactory
|
||||
import retrofit2.converter.protobuf.ProtoConverterFactory
|
||||
import java.net.InetSocketAddress
|
||||
import java.net.Proxy
|
||||
import javax.net.ssl.SSLContext
|
||||
import javax.net.ssl.TrustManager
|
||||
import javax.net.ssl.X509TrustManager
|
||||
@@ -13,9 +15,11 @@ import javax.net.ssl.X509TrustManager
|
||||
class ApiClient {
|
||||
private val yspUrl = "https://player-api.yangshipin.cn/"
|
||||
private val myUrl = "https://lyrics.run/"
|
||||
private val devUrl = "http://10.0.2.2:8081/"
|
||||
private val protoUrl = "https://capi.yangshipin.cn/"
|
||||
private val traceUrl = "https://btrace.yangshipin.cn/"
|
||||
|
||||
|
||||
private var okHttpClient = getUnsafeOkHttpClient()
|
||||
|
||||
val yspApiService: YSPApiService by lazy {
|
||||
@@ -34,6 +38,14 @@ class ApiClient {
|
||||
.build().create(YSPTokenService::class.java)
|
||||
}
|
||||
|
||||
val releaseService: ReleaseService by lazy {
|
||||
Retrofit.Builder()
|
||||
.baseUrl(devUrl)
|
||||
.client(okHttpClient)
|
||||
.addConverterFactory(GsonConverterFactory.create())
|
||||
.build().create(ReleaseService::class.java)
|
||||
}
|
||||
|
||||
val yspProtoService: YSPProtoService by lazy {
|
||||
Retrofit.Builder()
|
||||
.baseUrl(protoUrl)
|
||||
|
||||
@@ -0,0 +1,37 @@
|
||||
package com.lizongying.mytv.api
|
||||
|
||||
import android.util.Log
|
||||
import okhttp3.MediaType
|
||||
import okhttp3.RequestBody
|
||||
import okio.BufferedSink
|
||||
import java.io.IOException
|
||||
|
||||
data class Auth(
|
||||
val code: Int,
|
||||
val msg: String,
|
||||
val data: AuthData,
|
||||
)
|
||||
|
||||
data class AuthData(
|
||||
val token: String,
|
||||
)
|
||||
|
||||
data class AuthRequest(
|
||||
var data: String,
|
||||
) : RequestBody() {
|
||||
override fun contentType(): MediaType? {
|
||||
return MediaType.parse("application/x-www-form-urlencoded;charset=UTF-8")
|
||||
}
|
||||
|
||||
override fun writeTo(sink: BufferedSink) {
|
||||
try {
|
||||
sink.writeUtf8(data)
|
||||
} catch (e: IOException) {
|
||||
Log.e(TAG, "$e")
|
||||
}
|
||||
}
|
||||
|
||||
companion object {
|
||||
private const val TAG = "AuthRequest"
|
||||
}
|
||||
}
|
||||
@@ -3,12 +3,25 @@ package com.lizongying.mytv.api
|
||||
data class Info(
|
||||
val code: Int?,
|
||||
val msg: String?,
|
||||
val data: InfoData,
|
||||
)
|
||||
val data: Data,
|
||||
) {
|
||||
data class Data(
|
||||
val token: String,
|
||||
)
|
||||
}
|
||||
|
||||
data class InfoData(
|
||||
val token: String,
|
||||
)
|
||||
data class Release(
|
||||
val code: Int?,
|
||||
val msg: String?,
|
||||
val data: Data,
|
||||
) {
|
||||
data class Data(
|
||||
val versionName: String,
|
||||
val versionCode: Int,
|
||||
val downloadUrl: String,
|
||||
val updateTime: Int,
|
||||
)
|
||||
}
|
||||
|
||||
data class TimeResponse(
|
||||
val data: Time
|
||||
|
||||
@@ -0,0 +1,11 @@
|
||||
package com.lizongying.mytv.api
|
||||
|
||||
import retrofit2.Call
|
||||
import retrofit2.http.GET
|
||||
|
||||
|
||||
interface ReleaseService {
|
||||
@GET("my-tv/v1/release")
|
||||
fun getRelease(
|
||||
): Call<Release>
|
||||
}
|
||||
@@ -50,6 +50,9 @@ class YSP(var context: Context) {
|
||||
|
||||
private var signature = ""
|
||||
|
||||
private var appid = "ysp_pc"
|
||||
var token = ""
|
||||
|
||||
private var encryptor: Encryptor? = null
|
||||
private lateinit var sharedPref: SharedPreferences
|
||||
|
||||
@@ -83,6 +86,19 @@ class YSP(var context: Context) {
|
||||
return """{"cnlid":"$cnlid","livepid":"$livepid","stream":"$stream","guid":"$guid","cKey":"$cKey","adjust":$adjust,"sphttps":"$sphttps","platform":"$platform","cmd":"$cmd","encryptVer":"$encryptVer","dtype":"$dtype","devid":"$devid","otype":"$otype","appVer":"$appVer","app_version":"$appVersion","rand_str":"$randStr","channel":"$channel","defn":"$defn","signature":"$signature"}"""
|
||||
}
|
||||
|
||||
fun getAuthData(tvModel: TVViewModel): String {
|
||||
livepid = tvModel.pid.value!!
|
||||
|
||||
randStr = getRand()
|
||||
|
||||
if (tvModel.retryTimes > 0) {
|
||||
guid = newGuid()
|
||||
}
|
||||
|
||||
signature = getAuthSignature()
|
||||
return """pid=$livepid&guid=$guid&appid=$appid&rand_str=$randStr&signature=$signature"""
|
||||
}
|
||||
|
||||
private fun getTimeStr(): String {
|
||||
return getDateTimestamp().toString()
|
||||
}
|
||||
@@ -131,6 +147,13 @@ class YSP(var context: Context) {
|
||||
return hashedData.let { it -> it.joinToString("") { "%02x".format(it) } }
|
||||
}
|
||||
|
||||
private fun getAuthSignature(): String {
|
||||
val e =
|
||||
"appid=${appid}&guid=${guid}&pid=${livepid}&rand_str=${randStr}".toByteArray()
|
||||
val hashedData = encryptor?.hash2(e) ?: return ""
|
||||
return hashedData.let { it -> it.joinToString("") { "%02x".format(it) } }
|
||||
}
|
||||
|
||||
companion object {
|
||||
private const val TAG = "YSP"
|
||||
}
|
||||
|
||||
@@ -13,9 +13,23 @@ interface YSPApiService {
|
||||
"content-type: application/json;charset=UTF-8",
|
||||
"referer: https://www.yangshipin.cn/",
|
||||
"yspappid: 519748109",
|
||||
"user-agent: Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36"
|
||||
)
|
||||
fun getLiveInfo(
|
||||
@Header("cookie") cookie: String,
|
||||
@Header("Yspplayertoken") token: String,
|
||||
@Body request: LiveInfoRequest,
|
||||
): Call<LiveInfo>
|
||||
|
||||
@POST("v1/player/auth")
|
||||
@Headers(
|
||||
"content-type: application/x-www-form-urlencoded;charset=UTF-8",
|
||||
"referer: https://www.yangshipin.cn/",
|
||||
"yspappid: 519748109",
|
||||
"user-agent: Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36"
|
||||
)
|
||||
fun getAuth(
|
||||
@Header("cookie") cookie: String,
|
||||
@Body request: AuthRequest,
|
||||
): Call<Auth>
|
||||
}
|
||||
@@ -0,0 +1,44 @@
|
||||
package com.lizongying.mytv.requests
|
||||
|
||||
import com.lizongying.mytv.api.ApiClient
|
||||
import com.lizongying.mytv.api.Release
|
||||
import kotlinx.coroutines.Dispatchers
|
||||
import kotlinx.coroutines.withContext
|
||||
import retrofit2.Call
|
||||
import retrofit2.Callback
|
||||
import retrofit2.Response
|
||||
import kotlin.coroutines.resume
|
||||
import kotlin.coroutines.suspendCoroutine
|
||||
|
||||
class MyRequest {
|
||||
private var releaseService = ApiClient().releaseService
|
||||
|
||||
suspend fun getRelease(): Release? {
|
||||
return withContext(Dispatchers.IO) {
|
||||
fetchRelease()
|
||||
}
|
||||
}
|
||||
|
||||
private suspend fun fetchRelease(): Release? {
|
||||
return suspendCoroutine { continuation ->
|
||||
releaseService.getRelease()
|
||||
.enqueue(object : Callback<Release> {
|
||||
override fun onResponse(call: Call<Release>, response: Response<Release>) {
|
||||
if (response.isSuccessful) {
|
||||
continuation.resume(response.body())
|
||||
} else {
|
||||
continuation.resume(null)
|
||||
}
|
||||
}
|
||||
|
||||
override fun onFailure(call: Call<Release>, t: Throwable) {
|
||||
continuation.resume(null)
|
||||
}
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
companion object {
|
||||
private const val TAG = "MyRequest"
|
||||
}
|
||||
}
|
||||
@@ -27,7 +27,31 @@
|
||||
android:layout_height="wrap_content"
|
||||
android:layout_marginTop="10dp"
|
||||
android:text="当前版本: $versionName\n获取最新: https://github.com/lizongying/my-tv/releases/"
|
||||
></TextView>
|
||||
/>
|
||||
<LinearLayout
|
||||
android:layout_width="300dp"
|
||||
android:layout_height="wrap_content"
|
||||
android:orientation="horizontal"
|
||||
>
|
||||
<Button
|
||||
android:id="@+id/check_version"
|
||||
android:layout_width="wrap_content"
|
||||
android:layout_height="wrap_content"
|
||||
android:layout_marginEnd="10dp"
|
||||
android:text="@string/check_version"
|
||||
/>
|
||||
<ProgressBar
|
||||
android:visibility="gone"
|
||||
android:layout_width="wrap_content"
|
||||
android:layout_height="wrap_content"
|
||||
/>
|
||||
<TextView
|
||||
android:id="@+id/version_name"
|
||||
android:text=""
|
||||
android:layout_width="wrap_content"
|
||||
android:layout_height="wrap_content" />
|
||||
</LinearLayout>
|
||||
|
||||
<Switch
|
||||
android:id="@+id/switch_channel_reversal"
|
||||
android:text="@string/title_channel_reversal"
|
||||
@@ -40,12 +64,6 @@
|
||||
android:layout_marginTop="10dp"
|
||||
android:layout_width="match_parent"
|
||||
android:layout_height="wrap_content" />
|
||||
<Switch
|
||||
android:id="@+id/switch_boot_startup"
|
||||
android:text="@string/title_boot_startup"
|
||||
android:layout_marginTop="10dp"
|
||||
android:layout_width="match_parent"
|
||||
android:layout_height="wrap_content" />
|
||||
</LinearLayout>
|
||||
<ImageView
|
||||
android:layout_width="300dp"
|
||||
|
||||
@@ -7,14 +7,6 @@
|
||||
android:background="@color/black"
|
||||
android:keepScreenOn="true">
|
||||
|
||||
<SurfaceView
|
||||
android:id="@+id/surface_view"
|
||||
android:layout_width="match_parent"
|
||||
android:layout_height="match_parent"
|
||||
android:layout_gravity="center"
|
||||
app:resize_mode="fill"
|
||||
app:use_controller="false" />
|
||||
|
||||
<androidx.media3.ui.PlayerView
|
||||
android:id="@+id/player_view"
|
||||
android:layout_width="match_parent"
|
||||
|
||||
@@ -0,0 +1,25 @@
|
||||
<?xml version="1.0" encoding="utf-8"?>
|
||||
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
|
||||
android:id="@+id/row"
|
||||
android:layout_width="match_parent"
|
||||
android:layout_height="match_parent"
|
||||
android:orientation="vertical">
|
||||
|
||||
<TextView
|
||||
android:id="@+id/row_header"
|
||||
android:layout_width="wrap_content"
|
||||
android:layout_height="wrap_content"
|
||||
android:layout_gravity="start"
|
||||
android:layout_marginTop="0dp"
|
||||
android:layout_marginStart="10dp"
|
||||
android:layout_marginBottom="5dp"
|
||||
android:gravity="start"
|
||||
android:textColor="#FFEEEEEE"
|
||||
android:textSize="22sp" />
|
||||
|
||||
<androidx.recyclerview.widget.RecyclerView
|
||||
android:id="@+id/row_items"
|
||||
android:layout_width="wrap_content"
|
||||
android:layout_height="wrap_content">
|
||||
</androidx.recyclerview.widget.RecyclerView>
|
||||
</LinearLayout>
|
||||
@@ -0,0 +1,17 @@
|
||||
<?xml version="1.0" encoding="utf-8"?>
|
||||
<FrameLayout xmlns:android="http://schemas.android.com/apk/res/android"
|
||||
android:id="@+id/show_fragment"
|
||||
android:layout_width="match_parent"
|
||||
android:layout_height="match_parent">
|
||||
<ScrollView
|
||||
android:id="@+id/scroll_view"
|
||||
android:layout_width="match_parent"
|
||||
android:layout_height="match_parent">
|
||||
<LinearLayout
|
||||
android:id="@+id/content"
|
||||
android:layout_width="match_parent"
|
||||
android:layout_height="wrap_content"
|
||||
android:orientation="vertical">
|
||||
</LinearLayout>
|
||||
</ScrollView>
|
||||
</FrameLayout>
|
||||
@@ -1,6 +1,4 @@
|
||||
<?xml version="1.0" encoding="utf-8"?>
|
||||
<resources>
|
||||
<integer name="local_channel_version">1</integer>
|
||||
<string name="server_version_url">https://fastly.jsdelivr.net/gh/LeGend-wLw/my-tv-json-utils@main/version.txt</string>
|
||||
<string name="server_url">https://fastly.jsdelivr.net/gh/LeGend-wLw/my-tv-json-utils@main/channels.json</string>
|
||||
</resources>
|
||||
<string name="server_url">http://localhost:8080</string>
|
||||
</resources>
|
||||
@@ -2,5 +2,5 @@
|
||||
<string name="app_name">我的电视</string>
|
||||
<string name="title_channel_reversal">换台反转</string>
|
||||
<string name="title_channel_num">数字选台</string>
|
||||
<string name="title_boot_startup">开机自启</string>
|
||||
<string name="check_version">检查更新</string>
|
||||
</resources>
|
||||
@@ -1,10 +1,25 @@
|
||||
<resources>
|
||||
|
||||
<style name="CustomImageCardViewStyle" parent="Widget.Leanback.ImageCardViewStyle">
|
||||
<item name="lbImageCardViewType">Title|Content</item>
|
||||
<item name="cardType">infoUnder</item>
|
||||
<item name="infoVisibility">always</item>
|
||||
<!-- In order to keep backward compatibility we have to create an icon on right. -->
|
||||
<item name="lbImageCardViewType">Title|Content|IconOnRight</item>
|
||||
<!-- Deprecated. Use 'Widget.Leanback.ImageCardView.InfoAreaStyle' instead. -->
|
||||
<item name="infoAreaBackground">@null</item>
|
||||
</style>
|
||||
|
||||
<style name="CustomImageCardViewImageStyle" parent="Widget.Leanback.ImageCardView.ImageStyle">
|
||||
<item name="android:layout_width">143dp</item>
|
||||
<item name="android:layout_height">50dp</item>
|
||||
<item name="android:adjustViewBounds">true</item>
|
||||
<item name="android:contentDescription">@null</item>
|
||||
<item name="android:scaleType">centerCrop</item>
|
||||
<item name="layout_viewType">main</item>
|
||||
</style>
|
||||
|
||||
<style name="CustomImageCardTheme" parent="Theme.Leanback">
|
||||
<item name="imageCardViewStyle">@style/CustomImageCardViewStyle</item>
|
||||
<item name="imageCardViewImageStyle">@style/CustomImageCardViewImageStyle</item>
|
||||
</style>
|
||||
</resources>
|
||||
Binary file not shown.
|
Before Width: | Height: | Size: 73 KiB |
Reference in New Issue
Block a user