|
|
@ -54,7 +54,9 @@ object GasUtils {
|
|
|
|
private fun updateGasTypeDb(gasName: Byte, port: String, online: Boolean) {
|
|
|
|
private fun updateGasTypeDb(gasName: Byte, port: String, online: Boolean) {
|
|
|
|
GlobalScope.launch {
|
|
|
|
GlobalScope.launch {
|
|
|
|
val typeDao = DBUtils.gasTypeDao()
|
|
|
|
val typeDao = DBUtils.gasTypeDao()
|
|
|
|
typeDao.insert(GasType(gasName.toString(), port, online))
|
|
|
|
val gasType = typeDao.getByName(gasName.toString())
|
|
|
|
|
|
|
|
gasType?.online = online
|
|
|
|
|
|
|
|
typeDao.insert(gasType ?: GasType(gasName.toString(), port, online))
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -65,10 +67,11 @@ object GasUtils {
|
|
|
|
mPortRunnable[index] = flagRunnable
|
|
|
|
mPortRunnable[index] = flagRunnable
|
|
|
|
}
|
|
|
|
}
|
|
|
|
mHandler.removeCallbacks(flagRunnable)
|
|
|
|
mHandler.removeCallbacks(flagRunnable)
|
|
|
|
mPortFlags[index] = true
|
|
|
|
|
|
|
|
updateGasTypeDb(gasName, port, true)
|
|
|
|
|
|
|
|
// 如果一段时间内没有收到消息,认为连接断开
|
|
|
|
// 如果一段时间内没有收到消息,认为连接断开
|
|
|
|
mHandler.postDelayed(flagRunnable, CHECK_TIME)
|
|
|
|
mHandler.postDelayed(flagRunnable, CHECK_TIME)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
mPortFlags[index] = true
|
|
|
|
|
|
|
|
updateGasTypeDb(gasName, port, true)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// 监控串口状态
|
|
|
|
// 监控串口状态
|
|
|
|