Skip to content

Commit

Permalink
メイン画面と詳細画面で画面切り替えから戻ってきたとき（onResumeしたとき）リストの中身をアップデートするようにした。
Browse files Browse the repository at this point in the history
  • Loading branch information
daigorian committed Sep 25, 2021
1 parent 4e23f86 commit 1a0b18d
Show file tree
Hide file tree
Showing 4 changed files with 543 additions and 230 deletions.
177 changes: 173 additions & 4 deletions app/src/main/java/com/daigorian/epcltvapp/DeleteEnabledArrayObjectAdapter.kt
View file
Original file line number Diff line number Diff line change
@@ -1,9 +1,18 @@
package com.daigorian.epcltvapp

import androidx.leanback.widget.ArrayObjectAdapter
import androidx.leanback.widget.ListRow
import androidx.leanback.widget.Presenter
import androidx.leanback.widget.PresenterSelector
import android.content.Context
import android.util.Log
import android.widget.Toast
import androidx.leanback.widget.*
import com.daigorian.epcltvapp.epgstationcaller.EpgStation
import com.daigorian.epcltvapp.epgstationcaller.GetRecordedParam
import com.daigorian.epcltvapp.epgstationcaller.GetRecordedResponse
import com.daigorian.epcltvapp.epgstationv2caller.EpgStationV2
import com.daigorian.epcltvapp.epgstationv2caller.GetRecordedParamV2
import com.daigorian.epcltvapp.epgstationv2caller.Records
import retrofit2.Call
import retrofit2.Callback
import retrofit2.Response
import kotlin.reflect.typeOf

open class DeleteEnabledArrayObjectAdapter : ArrayObjectAdapter {
Expand Down Expand Up @@ -31,5 +40,165 @@ open class DeleteEnabledArrayObjectAdapter : ArrayObjectAdapter {
}

}
fun getListRowByHeaderId(headerId : Long):ListRow?{
var verticalIndex = 0
while(verticalIndex < size()) {
val row = get(verticalIndex)
if(row is ListRow){
if(row.headerItem.id == headerId){
return row
}
}
verticalIndex += 1
}
return null
}

fun updateContentsListRow(v1Pram: GetRecordedParam, v2Param: GetRecordedParamV2, title:String, id:Long,presenter:Presenter,context: Context){


// 同じIDを持つ行が存在するかどうか確認する
val listRow = getListRowByHeaderId(id)

// 既存の行があれば、それを取得する。なければ新たに作る。
val listRowAdapter = if(listRow==null)
ArrayObjectAdapter(presenter)
else
listRow.adapter as ArrayObjectAdapter

// 既存の行がなければ、新たに作った行を追加する。
if(listRow==null){
val header = HeaderItem( id ,title)
add(ListRow(header, listRowAdapter))
}

// すでにロードされている数。
val numOfLoaded = if (listRow==null)
0L
else
listRowAdapter.size().toLong()

// APIのコールバックでListRowの中身をセットするように仕掛ける
// EPGStation V1.x.x
EpgStation.api?.getRecorded(
limit = if(numOfLoaded>v1Pram.limit) numOfLoaded else v1Pram.limit,
offset = v1Pram.offset,
reverse = v1Pram.reverse,
rule = v1Pram.rule,
genre1 = v1Pram.genre1,
channel = v1Pram.channel,
keyword = v1Pram.keyword,
hasTs = v1Pram.hasTs,
recording = v1Pram.recording )?.enqueue(object : Callback<GetRecordedResponse> {

override fun onResponse(call: Call<GetRecordedResponse>, response: Response<GetRecordedResponse>) {
response.body()?.let { getRecordedResponse ->

//既存のリストにあって、レスポンスにないアイテムの削除
var horizontalIndex = 0
while(horizontalIndex < listRowAdapter.size()) {
var found = false
getRecordedResponse.recorded.forEach {
if(listRowAdapter.get(horizontalIndex).equals(it) ) found = true
}
if (!found) {
listRowAdapter.removeItems(horizontalIndex,1)
}else {
horizontalIndex += 1
}
}

//レスポンスにあって、既存のリストにないアイテムの追加
getRecordedResponse.recorded.forEachIndexed { index, it ->
if(listRowAdapter.indexOf(it) == -1){
listRowAdapter.add(index,it)
}
}

//続きがあるなら"次を読み込む"を置く。
val numOfItem = getRecordedResponse.recorded.count().toLong()
if (numOfItem < getRecordedResponse.total) {
listRowAdapter.add(
GetRecordedParam(limit = v1Pram.limit,
offset = numOfItem,
reverse = v1Pram.reverse,
rule = v1Pram.rule,
genre1 = v1Pram.genre1,
channel = v1Pram.channel,
keyword = v1Pram.keyword,
hasTs = v1Pram.hasTs,
recording = v1Pram.recording)
)
}

}
}
override fun onFailure(call: Call<GetRecordedResponse>, t: Throwable) {
Log.d(TAG,"updateContentsListRow() getRecorded API Failure")
Toast.makeText(context, context.getText(R.string.connect_epgstation_failed), Toast.LENGTH_LONG).show()
}
})
EpgStationV2.api?.getRecorded(
isHalfWidth = v2Param.isHalfWidth,
offset = v2Param.offset,
limit = if(numOfLoaded>v2Param.limit) numOfLoaded else v2Param.limit ,
isReverse = v2Param.isReverse,
ruleId = v2Param.ruleId,
channelId = v2Param.channelId,
genre = v2Param.genre,
keyword = v2Param.keyword,
hasOriginalFile = v2Param.hasOriginalFile )?.enqueue(object : Callback<Records> {
override fun onResponse(call: Call<Records>, response: Response<Records>) {
response.body()?.let { getRecordedResponse ->

//既存のリストにあって、レスポンスにないアイテムの削除
var horizontalIndex = 0
while(horizontalIndex < listRowAdapter.size()) {
var found = false
getRecordedResponse.records.forEach {
if(listRowAdapter.get(horizontalIndex).equals(it) ) found = true
}
if (!found) {
listRowAdapter.removeItems(horizontalIndex,1)
}else {
horizontalIndex += 1
}
}

//レスポンスにあって、既存のリストにないアイテムの追加
getRecordedResponse.records.forEachIndexed { index, it ->
if(listRowAdapter.indexOf(it) == -1){
listRowAdapter.add(index,it)
}
}
//続きがあるなら"次を読み込む"を置く。
val numOfItem = getRecordedResponse.records.count().toLong()
if (numOfItem < getRecordedResponse.total) {
listRowAdapter.add(
GetRecordedParamV2(
isHalfWidth = v2Param.isHalfWidth,
offset = numOfItem,
limit = v2Param.limit,
isReverse = v2Param.isReverse,
ruleId = v2Param.ruleId,
channelId = v2Param.channelId,
genre = v2Param.genre,
keyword = v2Param.keyword,
hasOriginalFile = v2Param.hasOriginalFile)
)
}
}
}
override fun onFailure(call: Call<Records>, t: Throwable) {
Log.d(TAG,"updateContentsListRow() getRecorded API Failure")
Toast.makeText(context, context.getText(R.string.connect_epgstation_failed), Toast.LENGTH_LONG).show()
}
})

}
companion object{
private const val TAG = "D.E.ArrayObjectAdapter"
}


}
Loading

0 comments on commit 1a0b18d

Please sign in to comment.