[fea]
[detailId -> shiftsId]
This commit is contained in:
yangyakun
2024-12-17 17:10:36 +08:00
parent 60c13cab0c
commit a2fe4e1ccf
4 changed files with 14 additions and 10 deletions

View File

@@ -60,7 +60,7 @@ open class EventDataBase(val msgtype:String,var businessTime: Long?)
data class EventData(
var taskId: Long?,
var detailId: Long?,
var shiftsId: Long?,
var taskDate: Long?,
var businessTimeout: Long?,
var writeVersion: Long?,
@@ -73,7 +73,7 @@ data class EventData(
data class WriteOffEventData(
var msgId: String?,
var taskId: Long?,
var detailId: Long?,
var shiftsId: Long?,
var taskDate: Long?,
var siteId: Long?,
var driverId: Long?,

View File

@@ -16,7 +16,7 @@ data class TaskDataBean(
* 任务id
*/
@ColumnInfo(name = "task_id", typeAffinity = ColumnInfo.INTEGER, index = true)
@SerializedName("id", alternate = ["detailId"])
@SerializedName("id", alternate = ["shiftsId"])
var taskId: Long? = null,
/**

View File

@@ -177,12 +177,11 @@ class WeaknetRepository : ILineRepository {
val loginInfo = LoginStatusManager.getLoginInfo()
return Observable.just(loginInfo).flatMap {
// check数据 是否正在之心
val taskId = if(AppIdentityModeUtils.isBus(FunctionBuildConfig.appIdentityMode)||
AppIdentityModeUtils.isShuttle(FunctionBuildConfig.appIdentityMode)){
it.taskId
}else{
it.detailId
it.shiftsId
}
val taskDate = it.taskDate
val currentSiteId = it.currentSite
@@ -215,6 +214,11 @@ class WeaknetRepository : ILineRepository {
CallerLogger.d(TAG,"服务端正在执行${taskId},本地没有此任务")
OchChainLogManager.writeChainLogDb("错误信息","服务端正在执行${taskId},本地没有此任务")
return@flatMap Observable.just(false)
}else{
// 本地任务已经被执行
if(queryTaskById.status == TaskDataBean.used){
return@flatMap Observable.just(false)
}
}
// endregion