[6.8.0]

[fix]
[核销顺序]

OCH/shuttle/driver_weaknet/src/main/java/com/mogo/och/weaknet/model/EventModel.kt

@@ -97,6 +97,13 @@ object EventModel {
                         updateEvent()
                         return
                     }
+
+                    val queryWaitUpdateWriteOffCount = WriteOffDb.queryWaitUpdateWriteOffCount()
+                    if(queryWaitUpdateWriteOffCount!=null&&queryWaitUpdateWriteOffCount>0){
+                        updateEvent()
+                        return
+                    }
+
                     BizLoopManager.postDelayed(loopUpdateInfo,2*60*1000)
                 }
 

OCH/shuttle/driver_weaknet/src/main/java/com/mogo/och/weaknet/repository/db/dao/WriteOffDataDao.kt

@@ -36,5 +36,8 @@ interface WriteOffDataDao {
     @Query("SELECT * FROM ${WriteOffDataBean.writeoffDataTable} WHERE event_save_time > :zeroTime and task_id = :taskId and site_id = :siteId")
     fun queryWriteOffByTaskAndSiteId(taskId: Long, siteId: Long,zeroTime: Long = DateTimeUtil.getCurrentDateZero()):List<WriteOffDataBean>?
 
+    @Query("SELECT count(1) FROM ${WriteOffDataBean.writeoffDataTable} WHERE update_status = ${WriteOffDataBean.notUpdate}")
+    fun queryWriteOffByStatusWithPageCount(): Int
+
 
 }

OCH/shuttle/driver_weaknet/src/main/java/com/mogo/och/weaknet/repository/db/repository/WriteOffDb.kt

@@ -69,5 +69,9 @@ object WriteOffDb: IDbRepository {
         }
     }
 
+    fun queryWaitUpdateWriteOffCount():Int?{
+        return writeOffDataDao?.queryWriteOffByStatusWithPageCount()
+    }
+
 
 }