|
|
@ -9,10 +9,11 @@ import com.yinuo.safetywatcher.watcher.constant.CAMERA_GATEWAY
|
|
|
|
import com.yinuo.safetywatcher.watcher.constant.CAMERA_IP
|
|
|
|
import com.yinuo.safetywatcher.watcher.constant.CAMERA_IP
|
|
|
|
import com.yinuo.safetywatcher.watcher.constant.CAMERA_NETMASK
|
|
|
|
import com.yinuo.safetywatcher.watcher.constant.CAMERA_NETMASK
|
|
|
|
import com.yinuo.safetywatcher.watcher.port.cmd.GasPortStatus
|
|
|
|
import com.yinuo.safetywatcher.watcher.port.cmd.GasPortStatus
|
|
|
|
import com.yinuo.safetywatcher.watcher.utils.LztekUtil
|
|
|
|
import com.yinuo.safetywatcher.watcher.utils.PlatformUtils
|
|
|
|
import com.yinuo.safetywatcher.watcher.wifi.WiFiConfig
|
|
|
|
import com.yinuo.safetywatcher.watcher.wifi.WiFiConfig
|
|
|
|
import com.yinuo.safetywatcher.watcher.wifi.WiFiModule
|
|
|
|
import com.yinuo.safetywatcher.watcher.wifi.WiFiModule
|
|
|
|
import kotlinx.coroutines.DelicateCoroutinesApi
|
|
|
|
import kotlinx.coroutines.DelicateCoroutinesApi
|
|
|
|
|
|
|
|
import kotlinx.coroutines.Dispatchers
|
|
|
|
import kotlinx.coroutines.GlobalScope
|
|
|
|
import kotlinx.coroutines.GlobalScope
|
|
|
|
import kotlinx.coroutines.async
|
|
|
|
import kotlinx.coroutines.async
|
|
|
|
import kotlinx.coroutines.launch
|
|
|
|
import kotlinx.coroutines.launch
|
|
|
@ -38,14 +39,17 @@ class App : CommonApplication() {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
private fun ipConfig() {
|
|
|
|
private fun ipConfig() {
|
|
|
|
LztekUtil.getLztek()
|
|
|
|
// LztekUtil.getLztek()
|
|
|
|
?.setEthIpAddress(CAMERA_IP, CAMERA_NETMASK, CAMERA_GATEWAY, CAMERA_DNS)
|
|
|
|
// ?.setEthIpAddress(CAMERA_IP, CAMERA_NETMASK, CAMERA_GATEWAY, CAMERA_DNS)
|
|
|
|
|
|
|
|
PlatformUtils.setEthIpAddress(CAMERA_IP, CAMERA_NETMASK, CAMERA_GATEWAY, CAMERA_DNS)
|
|
|
|
|
|
|
|
PlatformUtils.hideNavigation()
|
|
|
|
|
|
|
|
PlatformUtils.hideStatusBar()
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
private fun tryFixDbData() {
|
|
|
|
private fun tryFixDbData() {
|
|
|
|
GlobalScope.launch {
|
|
|
|
GlobalScope.launch(Dispatchers.IO) {
|
|
|
|
// 修复告警数据
|
|
|
|
// 修复告警数据
|
|
|
|
async {
|
|
|
|
val warningAsync = async(Dispatchers.IO) {
|
|
|
|
val warningDao = DBUtils.warningDao()
|
|
|
|
val warningDao = DBUtils.warningDao()
|
|
|
|
val warningList = warningDao.queryWarningsNoEndTime()
|
|
|
|
val warningList = warningDao.queryWarningsNoEndTime()
|
|
|
|
warningList?.apply {
|
|
|
|
warningList?.apply {
|
|
|
@ -54,10 +58,10 @@ class App : CommonApplication() {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
warningDao.updateAll(warningList)
|
|
|
|
warningDao.updateAll(warningList)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}.await()
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// 修复视频数据
|
|
|
|
// 修复视频数据
|
|
|
|
async {
|
|
|
|
val videoAsync = async(Dispatchers.IO) {
|
|
|
|
val videoDao = DBUtils.videoDao()
|
|
|
|
val videoDao = DBUtils.videoDao()
|
|
|
|
val videoList = videoDao.getAll()
|
|
|
|
val videoList = videoDao.getAll()
|
|
|
|
videoList.onEach { video ->
|
|
|
|
videoList.onEach { video ->
|
|
|
@ -65,17 +69,20 @@ class App : CommonApplication() {
|
|
|
|
videoDao.delete(video)
|
|
|
|
videoDao.delete(video)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}.await()
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// 初始时,所以串口连接状态都应该是未连接
|
|
|
|
// 初始时,所以串口连接状态都应该是未连接
|
|
|
|
async {
|
|
|
|
val gasAsync = async(Dispatchers.IO) {
|
|
|
|
val gasTypeDao = DBUtils.gasTypeDao()
|
|
|
|
val gasTypeDao = DBUtils.gasTypeDao()
|
|
|
|
val all = gasTypeDao.getAll()
|
|
|
|
val all = gasTypeDao.getAll()
|
|
|
|
all.onEach { gasType ->
|
|
|
|
all.onEach { gasType ->
|
|
|
|
gasType.status = GasPortStatus.OUTLINE
|
|
|
|
gasType.status = GasPortStatus.OUTLINE
|
|
|
|
gasTypeDao.insert(gasType)
|
|
|
|
gasTypeDao.insert(gasType)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}.await()
|
|
|
|
}
|
|
|
|
|
|
|
|
warningAsync.await()
|
|
|
|
|
|
|
|
videoAsync.await()
|
|
|
|
|
|
|
|
gasAsync.await()
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|