Merge remote-tracking branch 'origin/dev_minibus-d_230425_3.2.0' into dev_minibus-d_230425_3.2.0

core/function-impl/mogo-core-function-datacenter/src/main/java/com/mogo/eagle/core/function/msgbox/DataManager.kt

@@ -92,6 +92,22 @@ object DataManager {
         }
     }
 
+    fun delMsgTable(context: Context) {
+        if (Thread.currentThread() == Looper.getMainLooper().thread) {
+            scope.launch {
+                withContext(Dispatchers.Default) {
+                    MsgBoxDb.getDb(context)
+                        .monitorDao()
+                        .deleteMsgTable()
+                }
+            }
+        } else {
+            MsgBoxDb.getDb(context)
+                .monitorDao()
+                .deleteMsgTable()
+        }
+    }
+
     private fun realSaveMsg(msg: MsgBoxBean) {
         val type = msg.type
         msg.timestamp = System.currentTimeMillis()

core/function-impl/mogo-core-function-datacenter/src/main/java/com/mogo/eagle/core/function/msgbox/MsgBoxProvider.kt

@@ -34,6 +34,10 @@ class MsgBoxProvider : IMsgBoxProvider {
         DataManager.saveMsg(bean)
     }
 
+    override fun delMsgTable(context: Context) {
+        DataManager.delMsgTable(context)
+    }
+
     override fun getCachedNotifyData(): List<MsgBoxBean> {
         return DataManager.getNotifyData()
     }

core/function-impl/mogo-core-function-datacenter/src/main/java/com/mogo/eagle/core/function/msgbox/db/MsgBoxDao.kt

@@ -15,4 +15,7 @@ interface MsgBoxDao {
 
     @Query("SELECT * FROM t_msg_box")
     fun getAllCachedMessages(): List<MsgBoxInfo>
+
+    @Query("DELETE FROM t_msg_box")
+    fun deleteMsgTable()
 }

core/mogo-core-function-api/src/main/java/com/mogo/eagle/core/function/api/datacenter/msgbox/IMsgBoxProvider.kt

@@ -10,6 +10,8 @@ interface IMsgBoxProvider: IMoGoFunctionServerProvider {
 
     fun saveMsg(bean: MsgBoxBean)
 
+    fun delMsgTable(context: Context)
+
     /**
      * 获取本地数据库缓存的通知消息：V2X、云公告、运营信息
      */

core/mogo-core-function-call/src/main/java/com/mogo/eagle/core/function/call/msgbox/CallerMsgBoxManager.kt

@@ -28,6 +28,13 @@ object CallerMsgBoxManager {
         providerApi?.saveMsg(bean)
     }
 
+    /**
+     * 删除所有消息盒子中的数据
+     */
+    fun delMsgTable(context: Context) {
+        providerApi?.delMsgTable(context)
+    }
+
     /**
      * 通知消息：V2X、云公告、运营信息
      */