[6.8.4]
[fix] [driver] [数据版本兼容]
This commit is contained in:
@@ -96,6 +96,8 @@ data class CarExecutableTaskResponse(val data: List<Result>?) : BaseData(){
|
||||
LineDb.checkAndUpdate(lineList)
|
||||
ContraiDb.addOrUpdate(contrailList)
|
||||
SiteDb.addOrUpdate(siteList)
|
||||
|
||||
TaskDb.resetShiftsIdDetail()
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -83,6 +83,7 @@ data class TaskDataBean(
|
||||
|
||||
if (taskId != other.taskId) return false
|
||||
if (lineId != other.lineId) return false
|
||||
if (shiftsId != other.shiftsId) return false
|
||||
|
||||
return true
|
||||
}
|
||||
|
||||
@@ -72,6 +72,9 @@ interface TaskDataDao {
|
||||
@Query("DELETE FROM ${TaskDataBean.tableName} WHERE task_get_time < :zeroTime")
|
||||
fun deleteObsoleteData(zeroTime: Long = DateTimeUtil.getCurrentDateZero()): Int
|
||||
|
||||
@Query("UPDATE ${TaskDataBean.tableName} SET shifts_id = 0 WHERE shifts_id is null")
|
||||
fun setShiftsIdDetail()
|
||||
|
||||
|
||||
//查询线路对应的轨迹信息 只要一个结果
|
||||
fun queryTaskByTaskIdOne(taskId: Long): TaskDataBean? {
|
||||
|
||||
@@ -217,5 +217,9 @@ object TaskDb : IDbRepository {
|
||||
}
|
||||
}
|
||||
|
||||
fun resetShiftsIdDetail(){
|
||||
taskDataDao?.setShiftsIdDetail()
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@@ -409,7 +409,7 @@ class WeaknetRepository : ILineRepository {
|
||||
// 设置到站任务
|
||||
LineManager.getLineInfo { lineInfo ->
|
||||
EventDb.saveEventTaskArriveSite(
|
||||
task.shiftsId!!,
|
||||
task.shiftsId?:0L,
|
||||
task.taskId!!,
|
||||
task.lineId!!,
|
||||
end.siteId.toLong(),
|
||||
|
||||
Reference in New Issue
Block a user