| | |
|---|
| | | 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.repository.KeywordRepository |
|---|
| | | import com.example.firstapp.entity.Rule |
|---|
| | | import com.example.firstapp.database.service.RetrofitClient |
|---|
| | | import com.example.firstapp.database.service.RetrofitModelClient |
|---|
| | | import kotlinx.coroutines.CoroutineScope |
|---|
| | | import kotlinx.coroutines.Dispatchers |
|---|
| | | import kotlinx.coroutines.launch |
|---|
| | | import java.text.SimpleDateFormat |
|---|
| | | import java.time.LocalDateTime |
|---|
| | | import java.time.format.DateTimeFormatter |
|---|
| | | import java.time.ZoneId |
|---|
| | | import java.util.Date |
|---|
| | | import java.util.Locale |
|---|
| | | |
|---|
| | | |
|---|
| | | class SmsReceiver : BroadcastReceiver() { |
|---|
| | | |
|---|
| | | // 安全防护关键词数组 |
|---|
| | | private var securityKeywordsList = emptyList<String>() |
|---|
| | | |
|---|
| | | @RequiresApi(Build.VERSION_CODES.O) |
|---|
| | | override fun onReceive(context: Context, intent: Intent) { |
|---|
| | | |
|---|
| | | // 检查广播的 Action 是否为短信接收 |
|---|
| | | if (Telephony.Sms.Intents.SMS_RECEIVED_ACTION == intent.action) { |
|---|
| | | // 获取短信内容 |
|---|
| | | val bundle: Bundle? = intent.extras |
|---|
| | | bundle?.let { |
|---|
| | | val pdus = it.get("pdus") as Array<*> |
|---|
| | |
|---|
| | | messageBody.append(messages[i]?.messageBody) |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 输出短信内容到控制台 |
|---|
| | | Log.d("SmsReceiver", "Received SMS: ${messageBody.toString()}") |
|---|
| | | val msg = Msg(0, "1111", "111111", messageBody.toString(),1, "111", 1, 1) |
|---|
| | | // 保存原始短信 |
|---|
| | | val msg = Msg(0, "1111", "111111", messageBody.toString(), 1, "111", 1, 1) |
|---|
| | | val msgId = Core.msg.insert(msg) |
|---|
| | | Log.d("SmsReceiver", "Received SMS msgId: ${msgId}") |
|---|
| | | |
|---|
| | | // 这里我要写个数组，并创建个对象存放一些内容，如这个对象的属性有匹配内容，正则表达式，并循环遍历 |
|---|
| | | val ruleList = listOf( |
|---|
| | | Rule("快递","京东","\\d{6}"), |
|---|
| | | Rule("快递","菜鸟驿站","\\d{1,2}-\\d{1,2}-\\d{4}") |
|---|
| | | ) |
|---|
| | | |
|---|
| | | CoroutineScope(Dispatchers.IO).launch { |
|---|
| | | Log.d("SmsReceiver", "CoroutineScope started") |
|---|
| | | // 获取最新的关键词配置 |
|---|
| | | val keywords = Core.keyword.getKeywords() |
|---|
| | | Log.d("keywords", keywords.toString()) |
|---|
| | | println(keywords) |
|---|
| | | // 保存匹配的短信 |
|---|
| | | //saveMessage(content) |
|---|
| | | // 这里需要查看消息是否含有securityKeywordsList这个列表中的关键词，如果含有，则不进行下一步操作 |
|---|
| | | if (securityKeywordsList.any { it in messageBody.toString() }) { |
|---|
| | | Log.d("SmsReceiver", "含有禁用关键词，${it}") |
|---|
| | | return |
|---|
| | | } |
|---|
| | | |
|---|
| | | Log.d("SmsReceiver", "运行到正则匹配") |
|---|
| | | |
|---|
| | | // kotlin 怎么创建一个类 |
|---|
| | | for (rule in ruleList) { |
|---|
| | | val code = rule.extractCodeFromMessage(messageBody.toString()) |
|---|
| | | // 调用API处理短信 |
|---|
| | | CoroutineScope(Dispatchers.IO).launch { |
|---|
| | | try { |
|---|
| | | val response = |
|---|
| | | RetrofitModelClient.modelService.processSms(mapOf("content" to messageBody.toString())) |
|---|
| | | |
|---|
| | | if (code!==null) { |
|---|
| | | Log.d("SmsReceiver", "Received SMS code: ${code}") |
|---|
| | | if (response.status == "success") { |
|---|
| | | // 获取当前时间 |
|---|
| | | val currentTime = LocalDateTime.now() |
|---|
| | | val date = |
|---|
| | | Date.from(currentTime.atZone(ZoneId.systemDefault()).toInstant()) |
|---|
| | | val sdf = SimpleDateFormat("yyyy-MM-dd HH:mm:ss", Locale.getDefault()) |
|---|
| | | val createtime = sdf.format(date) |
|---|
| | | |
|---|
| | | // 根据不同类型处理数据 |
|---|
| | | when (response.data.category) { |
|---|
| | | "快递" -> { |
|---|
| | | val code = Code( |
|---|
| | | id = 0, |
|---|
| | | category = response.data.category, |
|---|
| | | categoryId = 1, // 1-快递类型 |
|---|
| | | typeId = 1, //暂时没有根据type分类 |
|---|
| | | ruleId = 1, //1-快递类型 |
|---|
| | | msgId = msgId, |
|---|
| | | createTime = createtime, |
|---|
| | | oneLevel = response.data.details.post ?: "", |
|---|
| | | secondLevel = response.data.details.company ?: "", |
|---|
| | | code = response.data.details.pickupCode ?: "", |
|---|
| | | pickup = 0, // 0-未取件，1-已取件 |
|---|
| | | pickupTime = "", // 取件时间为空 |
|---|
| | | overTime = "", // 超时时间为空，暂时没有这块处理逻辑 |
|---|
| | | address = response.data.details.address ?: "", |
|---|
| | | remarks = response.data.details.time ?: "", |
|---|
| | | ) |
|---|
| | | if(code.oneLevel!="" && code.secondLevel!="" && code.code!="") { |
|---|
| | | Core.code.insert(code) |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 获取当前时间 |
|---|
| | | val currentTime = LocalDateTime.now() |
|---|
| | | // 加2小时 |
|---|
| | | val futureTime = currentTime.plusHours(2) |
|---|
| | | // 定义时间格式 |
|---|
| | | val formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss") |
|---|
| | | // 转换为字符串 |
|---|
| | | val overtime = futureTime.format(formatter) |
|---|
| | | // 封装成一个Code对象，并保存在数据库中 |
|---|
| | | val code = Code(0, rule.type,1, rule.content,1, 1, msgId, code, overtime) |
|---|
| | | Core.code.insert(code) |
|---|
| | | Log.d("SMS_DEBUG", "新短信已保存到数据库") |
|---|
| | | // 发送广播通知数据已更新 |
|---|
| | | //"com.example.firstapp.DATA_UPDATED" 是一个自定义的广播 Action，相当于一个标识符或者说是一个频道名称。这个名称是我们自己定义的，通常使用应用的包名作为前缀，以避免与其他应用的广播冲突。 |
|---|
| | | val updateIntent = Intent("com.example.firstapp.DATA_UPDATED") |
|---|
| | | context.sendBroadcast(updateIntent) |
|---|
| | | Log.d("SMS_DEBUG", "发送数据更新广播") |
|---|
| | | }else{ |
|---|
| | | Log.d("SmsReceiver", "Received SMS code: 没有匹配到内容") |
|---|
| | | "还款" -> { |
|---|
| | | val code = Code( |
|---|
| | | id = 0, |
|---|
| | | category = response.data.category, |
|---|
| | | categoryId = 2, // 2-还款类型 |
|---|
| | | typeId = 1, //暂时没有根据type分类 |
|---|
| | | ruleId = 2, //1-还款类型 |
|---|
| | | msgId = msgId, |
|---|
| | | createTime = createtime, |
|---|
| | | oneLevel = response.data.details.type ?: "", |
|---|
| | | secondLevel = response.data.details.bank ?: "", |
|---|
| | | code = response.data.details.amount ?: "", |
|---|
| | | pickup = 0, // 0-未取件，1-已取件 |
|---|
| | | pickupTime = "", // 取件时间为空 |
|---|
| | | overTime = response.data.details.date |
|---|
| | | ?: "", // 超时时间为空，暂时没有这块处理逻辑 |
|---|
| | | address = response.data.details.address ?: "", |
|---|
| | | remarks = "最小还款金额" + response.data.details.min_amount + "还款卡号" + response.data.details.number |
|---|
| | | ?: "", |
|---|
| | | ) |
|---|
| | | if(code.oneLevel!="" && code.secondLevel!="" && code.code!="") { |
|---|
| | | Core.code.insert(code) |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | "收入" -> { |
|---|
| | | val code = Code( |
|---|
| | | id = 0, |
|---|
| | | category = response.data.category, |
|---|
| | | categoryId = 3, // 3-收入类型 |
|---|
| | | typeId = 1, //暂时没有根据type分类 |
|---|
| | | ruleId = 2, //1-还款类型 |
|---|
| | | msgId = msgId, |
|---|
| | | createTime = createtime, |
|---|
| | | oneLevel = response.data.details.bank ?: "", |
|---|
| | | secondLevel = response.data.details.bank ?: "", |
|---|
| | | code = response.data.details.amount ?: "", |
|---|
| | | pickup = 0, // 0-未取件，1-已取件 |
|---|
| | | pickupTime = "", // 取件时间为空 |
|---|
| | | overTime = response.data.details.datetime |
|---|
| | | ?: "", // 超时时间为空，暂时没有这块处理逻辑 |
|---|
| | | address = response.data.details.address ?: "", |
|---|
| | | remarks = "余额" + response.data.details.balance ?: "", |
|---|
| | | ) |
|---|
| | | if(code.oneLevel!="" && code.secondLevel!="" && code.code!="") { |
|---|
| | | Core.code.insert(code) |
|---|
| | | } |
|---|
| | | } |
|---|
| | | "航班" -> { |
|---|
| | | val code = Code( |
|---|
| | | id = 0, |
|---|
| | | category = response.data.category, |
|---|
| | | categoryId = 4, // 4-航班类型 |
|---|
| | | typeId = 1, //暂时没有根据type分类 |
|---|
| | | ruleId = 2, //1-还款类型 |
|---|
| | | msgId = msgId, |
|---|
| | | createTime = createtime, |
|---|
| | | oneLevel = response.data.details.company ?: "", |
|---|
| | | secondLevel = response.data.details.start +response.data.details.end?: "", |
|---|
| | | code = response.data.details.seat ?: "", |
|---|
| | | pickup = 0, // 0-未取件，1-已取件 |
|---|
| | | pickupTime = "", // 取件时间为空 |
|---|
| | | overTime = response.data.details.time |
|---|
| | | ?: "", // 超时时间为空，暂时没有这块处理逻辑 |
|---|
| | | address = response.data.details.address ?: "", |
|---|
| | | remarks = response.data.details.seat ?: "", |
|---|
| | | ) |
|---|
| | | if(code.oneLevel!="" && code.secondLevel!="" && code.code!="") { |
|---|
| | | Core.code.insert(code) |
|---|
| | | } |
|---|
| | | } |
|---|
| | | "火车票" -> { |
|---|
| | | val code = Code( |
|---|
| | | id = 0, |
|---|
| | | category = response.data.category, |
|---|
| | | categoryId = 5, // 5-火车票类型 |
|---|
| | | typeId = 1, //暂时没有根据type分类 |
|---|
| | | ruleId = 2, //1-还款类型 |
|---|
| | | msgId = msgId, |
|---|
| | | createTime = createtime, |
|---|
| | | oneLevel = response.data.details.company ?: "", |
|---|
| | | secondLevel = response.data.details.company ?: "", |
|---|
| | | code = response.data.details.seat ?: "", |
|---|
| | | pickup = 0, // 0-未取件，1-已取件 |
|---|
| | | pickupTime = "", // 取件时间为空 |
|---|
| | | overTime = response.data.details.time |
|---|
| | | ?: "", // 超时时间为空，暂时没有这块处理逻辑 |
|---|
| | | address = response.data.details.address ?: "", |
|---|
| | | remarks = response.data.details.trips ?: "", |
|---|
| | | ) |
|---|
| | | if(code.oneLevel!="" && code.secondLevel!="" && code.code!="") { |
|---|
| | | Core.code.insert(code) |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 发送广播通知数据已更新 |
|---|
| | | val updateIntent = Intent("com.example.firstapp.DATA_UPDATED") |
|---|
| | | context.sendBroadcast(updateIntent) |
|---|
| | | Log.d("SMS_DEBUG", "新短信已保存到数据库") |
|---|
| | | } |
|---|
| | | } catch (e: Exception) { |
|---|
| | | Log.e("SmsReceiver", "Error processing SMS", e) |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
