desc:传感器列表展示修改

app/src/main/java/com/yinuo/safetywatcher/watcher/App.kt

@@ -63,19 +63,8 @@ class App : CommonApplication() {
                     }
                 }
             }
-
-            // 初始时，所以串口连接状态都应该是未连接
-            val gasAsync = async(Dispatchers.IO) {
-                val gasTypeDao = DBUtils.gasTypeDao()
-                val all = gasTypeDao.getAll()
-                all.onEach { gasType ->
-                    gasType.status = GasPortStatus.OUTLINE
-                    gasTypeDao.insert(gasType)
-                }
-            }
             warningAsync.await()
             videoAsync.await()
-            gasAsync.await()
         }
     }
 

app/src/main/java/com/yinuo/safetywatcher/watcher/port/GasPortUtils.kt

@@ -1,8 +1,9 @@
 package com.yinuo.safetywatcher.watcher.port
 
+import android.os.Process
+import com.common.commonlib.db.DBUtils
 import com.common.serialport.ComMultiPortUtils
 import com.yinuo.safetywatcher.watcher.port.cmd.CMD
-import android.os.Process
 import com.yinuo.safetywatcher.watcher.port.cmd.CalibrationCmd
 
 object GasPortUtils {
@@ -37,6 +38,9 @@ object GasPortUtils {
             readGasMsgThread = Thread {
                 try {
                     Process.setThreadPriority(Process.THREAD_PRIORITY_BACKGROUND);
+                    // 删除老的传感器列表数据
+                    val gasTypeDao = DBUtils.gasTypeDao()
+                    gasTypeDao.deleteAll()
                     while (true) {
                         // 延时一段时间后，发送指令读取气体数据
                         Thread.sleep(READ_MSG_INTERVAL)

library-common/src/main/java/com/common/commonlib/db/dao/GasTypeDao.kt

@@ -27,4 +27,7 @@ interface GasTypeDao {
 
     @Delete
     suspend fun delete(gas: GasType)
+
+    @Query("DELETE FROM gas_type")
+    fun deleteAll()
 }