FirstApp2.git - Gitblit

			@@ -5,121 +5,97 @@
			import android.provider.Telephony
			import android.widget.Toast
			import androidx.activity.result.contract.ActivityResultContracts
			import com.google.android.material.bottomnavigation.BottomNavigationView
			import androidx.appcompat.app.AppCompatActivity
			import androidx.core.content.ContextCompat
			import androidx.navigation.findNavController
			import androidx.navigation.ui.AppBarConfiguration
			import androidx.navigation.ui.setupActionBarWithNavController
			import androidx.navigation.ui.setupWithNavController
			import com.example.firstapp.databinding.ActivityMainBinding
			import com.example.firstapp.receiver.SmsReceiver
			import android.Manifest
			import android.content.BroadcastReceiver
			import android.content.Context
			import android.content.Intent
			import android.net.Uri
			import androidx.lifecycle.ViewModelProvider
			import androidx.recyclerview.widget.LinearLayoutManager
			import androidx.recyclerview.widget.RecyclerView
			import androidx.work.ExistingPeriodicWorkPolicy
			import androidx.work.PeriodicWorkRequestBuilder
			import androidx.work.WorkManager
			import android.os.Build
			import androidx.annotation.RequiresApi
			import com.example.firstapp.activity.LoginActivity
			import com.example.firstapp.adapter.MyAdapter
			import com.example.firstapp.ui.home.HomeViewModel
			import com.example.firstapp.core.Core
			import com.example.firstapp.database.entity.Code
			import com.example.firstapp.database.entity.Msg
			import com.example.firstapp.database.service.RetrofitClient
			import com.example.firstapp.database.service.RetrofitModelClient
			import com.example.firstapp.utils.Log
			import com.example.firstapp.workers.KeywordUpdateWorker
			import kotlinx.coroutines.CoroutineScope
			import kotlinx.coroutines.Dispatchers
			import kotlinx.coroutines.launch
			import java.text.SimpleDateFormat
			import java.util.Calendar
			import java.util.concurrent.TimeUnit
			import java.util.Date
			import java.util.Locale

			class MainActivity : AppCompatActivity() {
			// 安全防护关键词数组
			private var securityKeywordsList = emptyList<String>()

			private lateinit var binding: ActivityMainBinding

			private var smsReceiver:SmsReceiver? = null
			private var smsReceiver: SmsReceiver? = null

			private lateinit var adapter: MyAdapter
			private lateinit var homeViewModel: HomeViewModel
			private val multiplePermissionRequest =
			registerForActivityResult(ActivityResultContracts.RequestMultiplePermissions()) { permissions ->
			when {
			permissions.getOrDefault(
			Manifest.permission.RECEIVE_SMS,
			false
			) && permissions.getOrDefault(Manifest.permission.READ_SMS, false) -> {
			// 两个权限都获得授权
			registerSmsReceiver()
			}


			// 权限请求代码
			private val permissionRequest = registerForActivityResult(ActivityResultContracts.RequestPermission()) { isGranted ->
			if (isGranted) {
			// 权限授予后注册短信监听器
			registerSmsReceiver()
			syncRecentSms()
			} else {
			// 权限拒绝，提示用户
			Toast.makeText(this, "Permission Denied", Toast.LENGTH_SHORT).show()
			else -> {
			// 有权限被拒绝
			Toast.makeText(
			this, "需要短信读取和接收权限才能正常使用功能", Toast.LENGTH_SHORT
			).show()
			}
			}
			}
			}

			private val syncLock = Object()

			@RequiresApi(Build.VERSION_CODES.O)
			override fun onCreate(savedInstanceState: Bundle?) {
			super.onCreate(savedInstanceState)

			binding = ActivityMainBinding.inflate(layoutInflater)
			setContentView(binding.root)
			setupViews()
			// binding.btnLogout.setOnClickListener {
			// logout()
			// }
			// 在此位置初始化 homeViewModel
			homeViewModel = ViewModelProvider(this).get(HomeViewModel::class.java)

			val navView: BottomNavigationView = binding.navView

			val navView = binding.navView
			val navController = findNavController(R.id.nav_host_fragment_activity_main)
			// Passing each menu ID as a set of Ids because each
			// menu should be considered as top level destinations.
			val appBarConfiguration = AppBarConfiguration(
			setOf(
			R.id.navigation_home, R.id.navigation_dashboard, R.id.navigation_notifications
			)
			)
			setupActionBarWithNavController(navController, appBarConfiguration)

			// 只保留底部导航的设置
			navView.setupWithNavController(navController)

			// 重置提醒计划并检查是否有错过的提醒
			resetReminders()

			// 检查权限
			if (ContextCompat.checkSelfPermission(this, Manifest.permission.READ_SMS) != android.content.pm.PackageManager.PERMISSION_GRANTED) {
			// 请求权限
			permissionRequest.launch(Manifest.permission.READ_SMS)
			syncRecentSms()
			if (ContextCompat.checkSelfPermission(
			this, Manifest.permission.RECEIVE_SMS
			) != android.content.pm.PackageManager.PERMISSION_GRANTED \|\| ContextCompat.checkSelfPermission(
			this, Manifest.permission.READ_SMS
			) != android.content.pm.PackageManager.PERMISSION_GRANTED
			) {
			// 同时请求两个权限
			multiplePermissionRequest.launch(
			arrayOf(
			Manifest.permission.RECEIVE_SMS, Manifest.permission.READ_SMS
			)
			)
			} else {
			// 权限已经授予，继续执行相关操作
			registerSmsReceiver()
			syncRecentSms()
			}
			val recyclerView = findViewById<RecyclerView>(R.id.recyclerView)
			recyclerView.layoutManager = LinearLayoutManager(this)

			// 初始化适配器
			adapter = MyAdapter()
			recyclerView.adapter = adapter

			// 观察 LiveData 数据
			homeViewModel.codeList.observe(this) { codeList ->
			// 如果 codeList 为 null，避免闪退
			if (codeList != null) {
			adapter.submitList(codeList)
			// 滚动到顶部
			recyclerView.scrollToPosition(0)
			} else {
			// 如果数据为空，可以显示空列表或其他处理
			Toast.makeText(this, "No data available", Toast.LENGTH_SHORT).show()
			}
			}

			// 注册广播接收器来监听数据更新
			val filter = IntentFilter("com.example.firstapp.DATA_UPDATED")
			registerReceiver(object : BroadcastReceiver() {
			override fun onReceive(context: Context, intent: Intent) {
			// 数据已更新，刷新 LiveData
			homeViewModel.loadData()
			}
			}, filter)

			}

			private fun registerSmsReceiver() {
			@@ -139,47 +115,55 @@
			registerReceiver(smsReceiver, filter)
			}

			private fun setupKeywordUpdate() {
			val updateRequest = PeriodicWorkRequestBuilder<KeywordUpdateWorker>(
			1, TimeUnit.HOURS, // 每小时更新一次
			15, TimeUnit.MINUTES // 灵活时间窗口
			).build()

			WorkManager.getInstance(this).enqueueUniquePeriodicWork(
			"keyword_update", ExistingPeriodicWorkPolicy.REPLACE, updateRequest
			)
			}

			private fun setupViews() {
			// 获取并显示当前登录的手机号
			val phone =
			getSharedPreferences("user_info", Context.MODE_PRIVATE).getString("phone", "") ?: ""

			// binding.apply {
			// tvPhone.text = "当前登录手机号：$phone"
			// }
			getSharedPreferences("user_info", Context.MODE_PRIVATE).getString("phone", "") ?: ""
			}

			private fun logout() {
			// 清除登录信息
			getSharedPreferences("user_info", Context.MODE_PRIVATE)
			.edit()
			.clear()
			.apply()
			getSharedPreferences("user_info", Context.MODE_PRIVATE).edit().clear().apply()

			// 跳转回登录页
			startActivity(Intent(this, LoginActivity::class.java))
			finish()
			}

			// 初始化禁用词
			@RequiresApi(Build.VERSION_CODES.O)
			private fun initializeSecurityKeywords() {
			CoroutineScope(Dispatchers.IO).launch {
			try {
			val response = RetrofitClient.apiService.getSecurityList()
			if (response.code == 200) {
			securityKeywordsList = response.data.map { it.keyword }
			android.util.Log.d(
			"MainActivity", "securityKeywordsList: $securityKeywordsList"
			)
			// 确保在主线程中调用 syncRecentSms
			runOnUiThread {
			syncRecentSms()
			}
			} else {
			android.util.Log.e(
			"MainActivity", "Failed to get security list: ${response.code}"
			)
			}
			} catch (e: Exception) {
			android.util.Log.e("MainActivity", "Error fetching security list", e)
			}
			}
			}

			@RequiresApi(Build.VERSION_CODES.O)
			private fun syncRecentSms() {
			try {
			val calendar = Calendar.getInstance()
			calendar.add(Calendar.DAY_OF_YEAR, -3) // 获取3天前的时间
			calendar.add(Calendar.DAY_OF_YEAR, -3)
			val threeDaysAgo = calendar.timeInMillis

			val cursor = contentResolver.query(
			Uri.parse("content://sms/sent"),
			Uri.parse("content://sms/inbox"),
			arrayOf("address", "body", "date"),
			"date >= ?",
			arrayOf(threeDaysAgo.toString()),
			@@ -188,21 +172,152 @@

			cursor?.use {
			while (cursor.moveToNext()) {
			val address = cursor.getString(cursor.getColumnIndexOrThrow("address"))
			val body = cursor.getString(cursor.getColumnIndexOrThrow("body"))
			val date = cursor.getLong(cursor.getColumnIndexOrThrow("date"))
			val messageBody = cursor.getString(cursor.getColumnIndexOrThrow("body"))
			val datetime = cursor.getLong(cursor.getColumnIndexOrThrow("date"))

			// 转换为 Date 对象
			val date = Date(datetime)
			val sdf = SimpleDateFormat("yyyy-MM-dd HH:mm:ss", Locale.getDefault())
			val dateString = sdf.format(date)

			// 使用正则表达式提取验证码
			val regex = "\\d{4,6}".toRegex()
			val matchResult = regex.find(body)
			matchResult?.let { result ->
			val code = result.value
			// 使用 ViewModel 保存到数据库
			println("address")
			println(address)
			println(code)
			println(date)
			// homeViewModel.saveCode(address, code, date)
			// 保存原始短信
			val msg = Msg(0, "1111", "111111", messageBody, 1, "111", 1, 1)
			val msgId = Core.msg.insert(msg)

			// 禁用关键词拦截
			// if (securityKeywordsList.any { it in messageBody }) {
			// android.util.Log.d("MainActivity", "历史短信含有禁用关键词，跳过处理")
			// continue
			// }

			// 使用协程处理API调用和数据库操作
			CoroutineScope(Dispatchers.IO).launch {
			try {
			val response = RetrofitModelClient.modelService.processSms(mapOf("content" to messageBody))

			synchronized(syncLock) {
			if (response.status == "success") {
			when (response.data.category) {
			"快递" -> {
			val pickupCode = response.data.details.pickupCode ?: ""
			if (pickupCode.isNotEmpty()) {
			val existingCode = Core.code.queryByTypeAndCodeAndDate(
			response.data.category,
			pickupCode,
			dateString
			)

			if (existingCode == null) {
			val code = Code(
			id = 0,
			category = response.data.category,
			categoryId = 1,
			typeId = 1,
			ruleId = 1,
			msgId = msgId,
			createTime = dateString,
			oneLevel = response.data.details.post ?: "",
			secondLevel = response.data.details.company ?: "",
			code = pickupCode,
			pickup = 0,
			pickupTime = "",
			overTime = "",
			address = response.data.details.address ?: "",
			remarks = response.data.details.time ?: "",
			)
			// if(code.oneLevel.isNotEmpty() && code.secondLevel.isNotEmpty() && code.code.isNotEmpty()) {
			if(code.oneLevel.isNotEmpty() && code.code.isNotEmpty()) {
			Core.code.insert(code)
			android.util.Log.d("MainActivity", "历史快递短信已保存: $pickupCode")
			}
			} else {
			android.util.Log.d("MainActivity", "发现重复快递短信，跳过保存: $pickupCode")
			}
			}
			}
			"还款" -> {
			val amount = response.data.details.amount ?: ""
			if (amount.isNotEmpty()) {
			val existingCode = Core.code.queryByTypeAndCodeAndDate(
			response.data.category,
			amount,
			dateString
			)

			if (existingCode == null) {
			val code = Code(
			id = 0,
			category = response.data.category,
			categoryId = 2,
			typeId = 1,
			ruleId = 2,
			msgId = msgId,
			createTime = dateString,
			oneLevel = response.data.details.type ?: "",
			secondLevel = response.data.details.bank ?: "",
			code = amount,
			pickup = 0,
			pickupTime = "",
			overTime = response.data.details.date ?: "",
			address = response.data.details.address ?: "",
			remarks = "最小还款金额${response.data.details.min_amount}还款卡号${response.data.details.number}"
			)
			if(code.oneLevel.isNotEmpty() && code.secondLevel.isNotEmpty() && code.code.isNotEmpty()) {
			Core.code.insert(code)
			android.util.Log.d("MainActivity", "历史还款短信已保存: $amount")
			}
			} else {
			android.util.Log.d("MainActivity", "发现重复还款短信，跳过保存: $amount")
			}
			}
			}
			"收入" -> {
			val amount = response.data.details.amount ?: ""
			if (amount.isNotEmpty()) {
			val existingCode = Core.code.queryByTypeAndCodeAndDate(
			response.data.category,
			amount,
			dateString
			)

			if (existingCode == null) {
			val code = Code(
			id = 0,
			category = response.data.category,
			categoryId = 3, // 3-收入类型
			typeId = 1, //暂时没有根据type分类
			ruleId = 2, //1-还款类型
			msgId = msgId,
			createTime = dateString,
			oneLevel = response.data.details.bank ?: "",
			secondLevel = response.data.details.bank ?: "",
			code = amount,
			pickup = 0, // 0-未取件，1-已取件
			pickupTime = "", // 取件时间为空
			overTime = response.data.details.datetime
			?: "", // 超时时间为空，暂时没有这块处理逻辑
			address = response.data.details.address ?: "",
			remarks = "余额" + response.data.details.balance ?: "",
			)
			if(code.oneLevel.isNotEmpty() && code.secondLevel.isNotEmpty() && code.code.isNotEmpty()) {
			Core.code.insert(code)
			android.util.Log.d("MainActivity", "历史还款短信已保存: $amount")
			}
			} else {
			android.util.Log.d("MainActivity", "发现重复还款短信，跳过保存: $amount")
			}
			}
			}
			}

			// 发送广播通知数据已更新
			val updateIntent = Intent("com.example.firstapp.DATA_UPDATED")
			sendBroadcast(updateIntent)
			}
			}
			} catch (e: Exception) {
			android.util.Log.e("MainActivity", "处理历史短信出错: ${e.message}", e)
			}
			}
			}
			}
			@@ -211,4 +326,25 @@
			Toast.makeText(this, "同步短信失败：${e.message}", Toast.LENGTH_SHORT).show()
			}
			}

			// 重置提醒计划
			private fun resetReminders() {
			try {
			// 取消所有现有的提醒任务
			androidx.work.WorkManager.getInstance(this).cancelAllWorkByTag("reminder_worker")

			// 清除旧的提醒偏好设置
			getSharedPreferences("reminder_prefs", Context.MODE_PRIVATE).edit().clear().apply()

			// 重新设置提醒任务
			(application as App).setupReminderWorker()

			// 检查是否有错过的提醒
			com.example.firstapp.service.ReminderWorker.checkMissedReminders(this)

			android.util.Log.d("MainActivity", "已重置提醒计划")
			} catch (e: Exception) {
			android.util.Log.e("MainActivity", "重置提醒计划失败: ${e.message}")
			}
			}
			}