package com.shsening.autouploadvideos
|
|
import CookieHelper
|
import CookieHelper2
|
import SessionProfile
|
import SessionProfileManager
|
import android.graphics.Bitmap
|
import android.net.Uri
|
import android.os.Bundle
|
import android.os.Handler
|
import android.os.Looper
|
import android.util.Log
|
import android.view.View
|
import android.webkit.CookieManager
|
import android.webkit.ValueCallback
|
import android.webkit.WebChromeClient
|
import android.webkit.WebView
|
import android.webkit.WebViewClient
|
import android.widget.Button
|
import android.widget.TextView
|
import android.widget.Toast
|
import androidx.appcompat.app.AppCompatActivity
|
import androidx.core.content.FileProvider
|
import com.shsening.autouploadvideos.AppConfig.Companion.SESSION_PROFILE_PALTFORM_LISTS
|
import com.shsening.autouploadvideos.action.ActionDouyin
|
import com.shsening.autouploadvideos.action.ActionKuaishou
|
import com.shsening.autouploadvideos.action.ActionRedbook
|
import com.shsening.autouploadvideos.action.ActionShipinhao
|
import com.shsening.autouploadvideos.utils.DownloadHelper
|
import com.shsening.autouploadvideos.utils.Utils
|
import java.io.File
|
import java.util.LinkedList
|
import java.util.Queue
|
|
|
class UploadSessionActivity : AppCompatActivity() {
|
private var RedbooklUrl: String? = "https://creator.xiaohongshu.com/publish/publish?from=menu"
|
private var DingyuehaolUrl: String? = null
|
private lateinit var sessionProfileManager: SessionProfileManager
|
lateinit var sessionProfileWebView:SessionProfileWebView
|
|
private lateinit var uploadSessionText :TextView
|
private lateinit var downloadHelper:DownloadHelper
|
|
private val uploadTaskQueue: Queue<Utils.VideoUploadTaskInfo> = LinkedList() // 存储上传任务队列
|
|
private lateinit var sessionProfiles: java.util.ArrayList<SessionProfile>
|
|
private var last_uploaded_task_id:String = ""
|
|
private val threadHandler = Handler(Looper.getMainLooper())
|
|
private lateinit var activityReference: UploadSessionActivity
|
|
override fun onCreate(savedInstanceState: Bundle?) {
|
super.onCreate(savedInstanceState)
|
setContentView(R.layout.upload_session)
|
|
activityReference = this
|
// 初始化 SessionProfileManager
|
sessionProfileManager = SessionProfileManager(this)
|
//downloadReceiver = DownloadReceiver(this,)
|
uploadSessionText = findViewById(R.id.uploadSessionText)
|
sessionProfileWebView = findViewById(R.id.uploadSessionWebView)
|
// 获取传递的 SessionProfile 数组
|
sessionProfiles =
|
intent.getParcelableArrayListExtra<SessionProfile>("sessionProfiles")
|
?: arrayListOf()
|
if (sessionProfiles != null) {
|
for (profile in sessionProfiles) {
|
processProfile(profile)
|
}
|
} else {
|
Toast.makeText(this, "未接收到任何 Profile 数据", Toast.LENGTH_SHORT).show()
|
}
|
downloadHelper = DownloadHelper(this)
|
|
|
|
//sessionProfileWebView.setInitialScale(75) // 初始缩放比例
|
|
sessionProfileWebView.webViewClient = object : WebViewClient() {
|
override fun onPageStarted(
|
view: WebView?,
|
url: String?,
|
favicon: Bitmap?
|
) {
|
super.onPageStarted(view, url, favicon)
|
}
|
override fun onPageFinished(view: WebView?, url: String?) {
|
println("这是其他页面"+url)
|
super.onPageFinished(view, url)
|
view?.requestFocus() // 确保 WebView 获取焦点
|
//inject action
|
val currentTask = uploadTaskQueue.peek()
|
when (currentTask?.platform?.name) {
|
"抖音" -> {
|
val action =
|
ActionDouyin(activityReference, threadHandler, currentTask)
|
action.checkIfContentLoaded()
|
}
|
"快手" -> {
|
val action =
|
ActionKuaishou(activityReference, threadHandler, currentTask)
|
action.checkIfContentLoaded()
|
}
|
"小红书" -> {
|
val action =
|
ActionRedbook(activityReference, threadHandler, currentTask)
|
action.checkIfContentLoaded()
|
}
|
"视频号" -> {
|
val action =
|
ActionShipinhao(activityReference, threadHandler, currentTask)
|
action.checkIfContentLoaded()
|
}
|
}
|
url?.let{
|
Log.e("shsening", url)
|
try {
|
val cookies = CookieManager.getInstance().getCookie(url)
|
if (cookies != null) {
|
CookieHelper.saveSessionProfileUrlCookies(
|
activityReference,
|
currentTask.sessionProfileId!!,
|
url
|
)
|
} else {
|
Log.w("shsening", "No cookies found for URL: $url")
|
}
|
} catch (e: java.lang.Exception) {
|
Log.e("CookieHelper", "Failed to get cookies: ", e)
|
}
|
}
|
}
|
}
|
sessionProfileWebView.webChromeClient = object : WebChromeClient() {
|
override fun onShowFileChooser(
|
webView: WebView,
|
filePathCallback: ValueCallback<Array<Uri>>,
|
fileChooserParams: FileChooserParams
|
): Boolean {
|
try {
|
var mFilePathCallback: ValueCallback<Array<Uri>>? = filePathCallback
|
// 选择特定的文件
|
val currentTask = uploadTaskQueue.peek()
|
val download_dir = File(getExternalFilesDir(null), currentTask.sessionProfileId)
|
val file = File(download_dir, currentTask.filename + ".mp4")
|
val uri: Uri =
|
FileProvider.getUriForFile(activityReference, AppConfig.FILE_PROVIDER, file)
|
|
mFilePathCallback?.onReceiveValue(arrayOf(uri))
|
return true
|
}catch(e:Exception) {
|
return false
|
}
|
}
|
override fun onShowCustomView(view: View?, callback: CustomViewCallback?) {
|
super.onShowCustomView(view, callback)
|
view?.requestFocus()
|
}
|
}
|
sessionProfileWebView.isFocusableInTouchMode = true
|
|
findViewById<Button>(R.id.btn_upload_back).setOnClickListener {
|
finish()
|
}
|
}
|
|
private fun processProfile(profile:SessionProfile){
|
val downloadDir = File(getExternalFilesDir(null), profile.id) // 获取应用的外部存储目录，并指定 sessionid 子目录
|
|
Utils.fetchTasksBySessionProfile(profile, object:Utils.FetchTasksCallback {
|
override fun onTasksFetched(uploadTaskList: MutableList<Utils.VideoUploadTaskInfo>) {
|
uploadTaskList.forEach { task ->
|
downloadHelper.downloadSingleFile(task.videoUrl, File(downloadDir,task.filename+".mp4"))
|
downloadHelper.downloadSingleFile(task.coverUrl, File(downloadDir,task.filename+".png"))
|
profile.getValidProfileNames().forEach{ platform ->
|
var taskInfo = Utils.VideoUploadTaskInfo(task.taskId,
|
task.title,
|
task.description,
|
task.datetime,
|
task.videoUrl,
|
task.coverUrl,
|
task.filename,
|
profile.id,
|
profile.name,
|
SESSION_PROFILE_PALTFORM_LISTS.find { it.name == platform }
|
)
|
uploadTaskQueue.offer(taskInfo)
|
}
|
|
}
|
Handler(Looper.getMainLooper()).postDelayed({
|
checkAndStartNextTask() // 延时等待下载任务
|
}, 3000)
|
}
|
})
|
}
|
fun checkAndStartNextTask() {
|
if (uploadTaskQueue.isNotEmpty()) {
|
val nextTask = uploadTaskQueue.poll()
|
nextTask?.let {
|
nextTask.sessionProfileId?.let { sessionId ->
|
runOnUiThread {
|
if (last_uploaded_task_id != "" && last_uploaded_task_id != nextTask.taskId) {
|
Utils.sendVideoUploadedMessage(last_uploaded_task_id) { result, error ->
|
Handler(Looper.getMainLooper()).post {
|
Toast.makeText(
|
activityReference,
|
error?.message,
|
Toast.LENGTH_SHORT
|
)
|
}
|
}
|
} else {
|
last_uploaded_task_id = nextTask.taskId
|
}
|
nextTask.platform?.let {
|
sessionProfileWebView.loadSessionProfileCookies(sessionId)
|
sessionProfileWebView.loadUrl(it.url)
|
Handler(Looper.getMainLooper()).post {
|
uploadSessionText.text = "任务：${nextTask.sessionProfileName}. 剩余:${uploadTaskQueue.size+1} "
|
}
|
};
|
}
|
}
|
}
|
}else{
|
Handler(Looper.getMainLooper()).post {
|
uploadSessionText.text = "任务已结束。"
|
}
|
Handler(Looper.getMainLooper()).postDelayed({
|
if (sessionProfiles != null) {
|
for (profile in sessionProfiles) {
|
updateSessionProfileLastUploadTime(profile)
|
}
|
}
|
finish()
|
}, 2000)
|
|
}
|
}
|
|
|
private fun updateSessionProfileLastUploadTime(sessionProfile: SessionProfile) {
|
sessionProfile.lastUploadTime = Utils.getCurrentTimeString()
|
sessionProfileManager.addOrUpdateSessionProfile(sessionProfile)
|
sessionProfileManager.saveToFile()
|
}
|
|
override fun onDestroy() {
|
super.onDestroy()
|
}
|
}
|
