phoenix EPG

app/src/main/java/com/lizongying/mytv/CardPresenter.kt

@@ -39,11 +39,11 @@ class CardPresenter(
         cardView.setBackgroundColor(Color.WHITE)
         cardView.setMainImageScaleType(ImageView.ScaleType.CENTER_INSIDE)
 
-        tvViewModel.program.observe(owner) { _ ->
+        val epg = tvViewModel.epg.value?.filter { it.beginTime < Utils.getDateTimestamp() }
-            val program = tvViewModel.getProgramOne()
+        if (!epg.isNullOrEmpty()) {
-            if (program != null) {
+            cardView.contentText = epg.last().title
-                cardView.contentText = program.name
+        } else {
-            }
+            cardView.contentText = ""
         }
     }
 

app/src/main/java/com/lizongying/mytv/InfoFragment.kt

@@ -2,6 +2,7 @@ package com.lizongying.mytv
 
 import android.os.Bundle
 import android.os.Handler
+import android.util.Log
 import android.view.LayoutInflater
 import android.view.View
 import android.view.ViewGroup
@@ -34,9 +35,12 @@ class InfoFragment : Fragment() {
             .load(tvViewModel.logo.value)
             .into(binding.infoLogo)
 
-        val program = tvViewModel.getProgramOne()
+        Log.i(TAG, "${tvViewModel.title.value} ${tvViewModel.epg.value}")
-        if (program != null) {
+        val epg = tvViewModel.epg.value?.filter { it.beginTime < Utils.getDateTimestamp() }
-            binding.infoDesc.text = program.name
+        if (!epg.isNullOrEmpty()) {
+            binding.infoDesc.text = epg.last().title
+        } else {
+            binding.infoDesc.text = ""
         }
 
         handler.removeCallbacks(removeRunnable)

app/src/main/java/com/lizongying/mytv/MainActivity.kt

@@ -36,16 +36,6 @@ class MainActivity : FragmentActivity(), Request.RequestListener {
     private val delayHideMain: Long = 10000
     private val delayHideSetting: Long = 10000
 
-//    init {
-//        lifecycleScope.launch(Dispatchers.IO) {
-//            val utilsJob = async(start = CoroutineStart.LAZY) { Utils.init() }
-//
-//            utilsJob.start()
-//
-//            utilsJob.await()
-//        }
-//    }
-
     override fun onCreate(savedInstanceState: Bundle?) {
         Log.i(TAG, "onCreate")
         super.onCreate(savedInstanceState)
@@ -459,5 +449,4 @@ class MainActivity : FragmentActivity(), Request.RequestListener {
     private companion object {
         const val TAG = "MainActivity"
     }
-
 }

app/src/main/java/com/lizongying/mytv/MainFragment.kt

@@ -34,9 +34,6 @@ class MainFragment : BrowseSupportFragment() {
 
     private var lastVideoUrl = ""
 
-    private val handler = Handler(Looper.getMainLooper())
-    private lateinit var mUpdateProgramRunnable: UpdateProgramRunnable
-
     override fun onCreate(savedInstanceState: Bundle?) {
         Log.i(TAG, "onCreate")
         super.onCreate(savedInstanceState)
@@ -57,9 +54,6 @@ class MainFragment : BrowseSupportFragment() {
 
         setupEventListeners()
 
-        mUpdateProgramRunnable = UpdateProgramRunnable()
-        handler.post(mUpdateProgramRunnable)
-
         tvListViewModel.tvListViewModel.value?.forEach { tvViewModel ->
             tvViewModel.errInfo.observe(viewLifecycleOwner) { _ ->
                 if (tvViewModel.errInfo.value != null
@@ -141,6 +135,8 @@ class MainFragment : BrowseSupportFragment() {
                 tvViewModel.setItemPosition(idx2)
                 tvListViewModel.addTVViewModel(tvViewModel)
                 listRowAdapter.add(tvViewModel)
+
+                updateEPG(tvViewModel)
             }
             tvListViewModel.maxNum.add(v.size)
             val header = HeaderItem(idx, k)
@@ -277,30 +273,11 @@ class MainFragment : BrowseSupportFragment() {
         }
     }
 
-    fun updateProgram(tvViewModel: TVViewModel) {
+    private fun updateEPG(tvViewModel: TVViewModel) {
-        val timestamp = getDateTimestamp()
+        if (tvViewModel.getTV().channel == "港澳台") {
-        if (timestamp - tvViewModel.programUpdateTime > 60) {
+            Request.fetchFEPG(tvViewModel)
-            if (tvViewModel.program.value!!.isEmpty()) {
-                tvViewModel.programUpdateTime = timestamp
-                Request.fetchProgram(tvViewModel)
         } else {
-                if (tvViewModel.program.value!!.last().et - timestamp < 600) {
+            Request.fetchYEPG(tvViewModel)
-                    tvViewModel.programUpdateTime = timestamp
-                    Request.fetchProgram(tvViewModel)
-                }
-            }
-        }
-    }
-
-    inner class UpdateProgramRunnable : Runnable {
-        override fun run() {
-            tvListViewModel.tvListViewModel.value?.filter { it.programId.value != null && it.programId.value != "" }
-                ?.forEach { tvViewModel ->
-                    updateProgram(
-                        tvViewModel
-                    )
-                }
-            handler.postDelayed(this, 60000)
         }
     }
 
@@ -313,18 +290,16 @@ class MainFragment : BrowseSupportFragment() {
         Log.i(TAG, "onStop")
         super.onStop()
         SP.itemPosition = itemPosition
-        Log.i(TAG, "position saved")
+        Log.i(TAG, "$POSITION $itemPosition saved")
     }
 
     override fun onDestroy() {
         Log.i(TAG, "onDestroy")
         super.onDestroy()
-        if (::mUpdateProgramRunnable.isInitialized) {
-            handler.removeCallbacks(mUpdateProgramRunnable)
-        }
     }
 
     companion object {
         private const val TAG = "MainFragment"
+        private const val POSITION = "position"
     }
 }

app/src/main/java/com/lizongying/mytv/Request.kt

@@ -10,6 +10,7 @@ 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.LiveInfo
@@ -400,7 +401,7 @@ object Request {
                     tvModel.allReady()
                     tvModel.tokenRetryTimes = 0
                 } else {
-                    Log.e(TAG, "auth status error")
+                    Log.e(TAG, "auth status error ${response.code()}")
                     if (tvModel.tokenRetryTimes < tvModel.tokenRetryMaxTimes) {
                         tvModel.tokenRetryTimes++
                         fetchFAuth(tvModel)
@@ -419,7 +420,6 @@ object Request {
     }
 
     fun fetchData(tvModel: TVViewModel) {
-        Log.d(TAG, "fetchData")
         if (tvModel.getTV().channel == "港澳台") {
             fetchFAuth(tvModel)
             return
@@ -463,20 +463,20 @@ object Request {
                             if (e != null) {
                                 handler.postDelayed(
                                     tokenRunnable,
-                                    max(600000, (e - 1500) * 1000).toLong()
+                                    max(30 * 60 * 1000, (e - 1500) * 1000).toLong()
                                 )
                             } else {
                                 Log.e(TAG, "e empty")
                                 handler.postDelayed(
                                     tokenRunnable,
-                                    600000
+                                    30 * 60 * 1000
                                 )
                             }
                         } else {
                             Log.e(TAG, "token empty")
                             handler.postDelayed(
                                 tokenRunnable,
-                                600000
+                                30 * 60 * 1000
                             )
                         }
                         if (!f.isNullOrEmpty()) {
@@ -491,7 +491,7 @@ object Request {
                         Log.e(TAG, "token status error")
                         handler.postDelayed(
                             tokenRunnable,
-                            600000
+                            30 * 60 * 1000
                         )
                     }
                     listener?.onRequestFinished()
@@ -501,7 +501,7 @@ object Request {
                     Log.e(TAG, "token request error $t")
                     handler.postDelayed(
                         tokenRunnable,
-                        600000
+                        30 * 60 * 1000
                     )
                     listener?.onRequestFinished()
                 }
@@ -521,27 +521,27 @@ object Request {
                             if (e != null) {
                                 handler.postDelayed(
                                     tokenRunnable,
-                                    max(600000, (e - 1500) * 1000).toLong()
+                                    max(30 * 60 * 1000, (e - 1500) * 1000).toLong()
                                 )
                             } else {
                                 Log.e(TAG, "e empty")
                                 handler.postDelayed(
                                     tokenRunnable,
-                                    600000
+                                    30 * 60 * 1000
                                 )
                             }
                         } else {
                             Log.e(TAG, "token empty")
                             handler.postDelayed(
                                 tokenRunnable,
-                                600000
+                                30 * 60 * 1000
                             )
                         }
                     } else {
                         Log.e(TAG, "token status error")
                         handler.postDelayed(
                             tokenRunnable,
-                            600000
+                            30 * 60 * 1000
                         )
                     }
                 }
@@ -550,7 +550,7 @@ object Request {
                     Log.e(TAG, "token request error $t")
                     handler.postDelayed(
                         tokenRunnable,
-                        600000
+                        30 * 60 * 1000
                     )
                 }
             })
@@ -632,7 +632,7 @@ object Request {
         })
     }
 
-    fun fetchProgram(tvViewModel: TVViewModel) {
+    fun fetchYEPG(tvViewModel: TVViewModel) {
         val title = tvViewModel.title.value
         yspProtoService.getProgram(tvViewModel.programId.value!!, getDateFormat("yyyyMMdd"))
             .enqueue(object : Callback<epgProgramModel.Response> {
@@ -643,7 +643,7 @@ object Request {
                     if (response.isSuccessful) {
                         val program = response.body()
                         if (program != null) {
-                            tvViewModel.addProgram(program.dataListList)
+                            tvViewModel.addYEPG(program.dataListList)
                             Log.d(TAG, "$title program ${program.dataListList.size}")
                         }
                     } else {
@@ -657,6 +657,31 @@ object Request {
             })
     }
 
+    fun fetchFEPG(tvViewModel: TVViewModel) {
+        val title = tvViewModel.title.value
+        fAuthService.getEPG(tvViewModel.pid.value!!, 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")

app/src/main/java/com/lizongying/mytv/TVList.kt

@@ -8,6 +8,11 @@ import kotlinx.coroutines.launch
 import java.io.IOException
 
 object TVList {
+    val list: Map<String, List<TV>> by lazy {
+        setup()
+    }
+
+    private fun setup(): Map<String, List<TV>> {
         var list = mapOf(
             "央视" to listOf(
                 TV(
@@ -637,7 +642,7 @@ object TVList {
                     ),
                     0,
                     "地方",
-                "https://resources.yangshipin.cn/assets/oms/image/202306/657651f411de2673d1770d9a78b44c1265704f7468cc41d4be7f51d630768494.png?imageMogr2/format/webp",
+                    R.drawable.chongqing,
                     "600002531",
                     "2000297803",
                     "600002531",
@@ -1022,6 +1027,17 @@ object TVList {
                 ),
             )
         )
+        var id = 0
+        list.forEach { (_, v) ->
+            v.forEach { v1 ->
+                v1.id = id
+                id++
+            }
+        }
+        val array = arrayOf("央视", "地方")
+//        list = list.filterKeys { it in array }
+        return list
+    }
 
     /**
      * 初始化
@@ -1074,7 +1090,7 @@ object TVList {
                 }
             }
             //保存频道列表
-            list = channelTVMap
+//            list = channelTVMap
             //保存版本号
             if (updateFromServer) {
                 ChannelUtils.updateLocalChannel(context, serverVersion, tvList)

app/src/main/java/com/lizongying/mytv/api/FAuthService.kt

@@ -3,6 +3,7 @@ package com.lizongying.mytv.api
 import retrofit2.Call
 import retrofit2.http.GET
 import retrofit2.http.Header
+import retrofit2.http.Path
 import retrofit2.http.Query
 
 interface FAuthService {
@@ -12,4 +13,11 @@ interface FAuthService {
         @Query("live_id") live_id: String = "",
         @Query("live_qa") live_qa: String = "",
     ): Call<FAuth>
+
+    @GET("api/v3/live/{liveId}/resources")
+    fun getEPG(
+        @Path("liveId") liveId: String,
+        @Query("date") date: String,
+        @Query("dir") dir: String = "asc"
+    ): Call<List<FEPG>>
 }

app/src/main/java/com/lizongying/mytv/api/FEPG.kt

@@ -0,0 +1,7 @@
+package com.lizongying.mytv.api
+
+
+data class FEPG(
+    val title: String,
+    val event_time: String,
+)

app/src/main/java/com/lizongying/mytv/models/EPG.kt

@@ -0,0 +1,7 @@
+package com.lizongying.mytv.models
+
+
+data class EPG(
+    val title: String,
+    val beginTime: Int,
+)

app/src/main/java/com/lizongying/mytv/models/TVViewModel.kt

@@ -11,8 +11,10 @@ import androidx.media3.common.util.UnstableApi
 import androidx.media3.datasource.DefaultHttpDataSource
 import androidx.media3.exoplayer.hls.HlsMediaSource
 import com.lizongying.mytv.TV
-import com.lizongying.mytv.Utils.getDateTimestamp
+import com.lizongying.mytv.api.FEPG
 import com.lizongying.mytv.proto.Ysp.cn.yangshipin.omstv.common.proto.programModel.Program
+import java.text.SimpleDateFormat
+import java.util.TimeZone
 
 class TVViewModel(private var tv: TV) : ViewModel() {
 
@@ -33,9 +35,9 @@ class TVViewModel(private var tv: TV) : ViewModel() {
     val programId: LiveData<String>
         get() = _programId
 
-    private var _program = MutableLiveData<MutableList<Program>>()
+    private var _epg = MutableLiveData<MutableList<EPG>>()
-    val program: LiveData<MutableList<Program>>
+    val epg: LiveData<MutableList<EPG>>
-        get() = _program
+        get() = _epg
 
     private val _id = MutableLiveData<Int>()
     val id: LiveData<Int>
@@ -120,10 +122,8 @@ class TVViewModel(private var tv: TV) : ViewModel() {
         _programId.value = tv.programId
         _pid.value = tv.pid
         _sid.value = tv.sid
-        _program.value = mutableListOf()
     }
 
-
     fun getRowPosition(): Int {
         return rowPosition
     }
@@ -152,37 +152,23 @@ class TVViewModel(private var tv: TV) : ViewModel() {
         return tv
     }
 
-    fun getProgramOne(): Program? {
+    fun addYEPG(p: MutableList<Program>) {
-        val programNew =
+        _epg.value = p.map { EPG(it.name, it.st.toInt()) }.toMutableList()
-            (_program.value?.filter { it.et > getDateTimestamp() })?.toMutableList()
-        if (programNew != null && _program.value != programNew) {
-            _program.value = programNew
-        }
-        if (_program.value!!.isEmpty()) {
-            return null
-        }
-        return _program.value?.first()
     }
 
-    fun addProgram(p: MutableList<Program>) {
+    private fun formatFTime(s: String): Int {
-        val timestamp = getDateTimestamp()
+        val dateFormat = SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss")
-
+        dateFormat.timeZone = TimeZone.getTimeZone("UTC")
-        // after now & not empty & different
+        val date = dateFormat.parse(s.substring(0, 19))
-        val p1 = (p.filter { it.et > timestamp }).toMutableList()
+        if (date != null) {
-        if (p1.isEmpty() || _program.value == p1) {
+            return (date.time / 1000).toInt()
-            return
+        }
+        return 0
     }
 
-        if (_program.value!!.isEmpty()) {
+    fun addFEPG(p: List<FEPG>) {
-            _program.value = p1
+        _epg.value = p.map { EPG(it.title, formatFTime(it.event_time)) }.toMutableList()
-        } else {
-            _program.value =
-                ((_program.value?.filter { it.et > timestamp && it.st < p1.first().st })?.plus(
-                    p1
-                ))?.toMutableList()
     }
-    }
-
 
     private var mHeaders: Map<String, String>? = mapOf()
 

app/src/main/res/raw/channels.json

@@ -130,7 +130,7 @@
     "programId": "600004078",
     "needToken": true,
     "mustToken": false,
-    "title": "CCTV9 纪录",
+    "title": "CCTV9 记录",
     "videoUrl": [
       "http://dbiptv.sn.chinamobile.com/PLTV/88888890/224/3221226197/index.m3u8"
     ]