[6.8.0]

[fea]
[核销人数计算]

OCH/shuttle/driver_weaknet/src/main/java/com/mogo/och/weaknet/repository/writeoff/impl/WriteOffCacheRepository.kt

@@ -66,10 +66,20 @@ class WriteOffCacheRepository : IWriteOffRepository {
         siteId: Long
     ): Observable<Int>? {
         val queryWriteOffByTaskAndSiteId = WriteOffDb.queryWriteOffByTaskAndSiteId(taskId, siteId)
-        return Observable.just(queryWriteOffByTaskAndSiteId)
-            .flatMap {
-                return@flatMap Observable.just(it?.size ?:0)
+        queryWriteOffByTaskAndSiteId?.let {
+            var count4Persion = 0
+            it.forEach { wirteoffItem->
+                if (wirteoffItem.ticketSize == null || wirteoffItem.ticketSize!! < 1) {
+                    wirteoffItem.ticketSize=1
+                }
+                count4Persion+=(wirteoffItem.ticketSize?:1)
             }
+            return Observable.just(count4Persion)
+                .flatMap {
+                    return@flatMap Observable.just(it)
+                }
+        }
+        return Observable.just(0)
     }
 
     override fun writeOffEvent(writeOffDetialMsg: WriteOffDetialMsg): Observable<PassengerWriteOffResponse.Result>? {