From 6c07624991d873607ab82fac18314621ea585167 Mon Sep 17 00:00:00 2001 From: yangyakun Date: Fri, 22 Nov 2024 11:05:08 +0800 Subject: [PATCH] =?UTF-8?q?[6.8.0]=20[fea]=20[=E6=A0=B8=E9=94=80=E4=BA=BA?= =?UTF-8?q?=E6=95=B0=E8=AE=A1=E7=AE=97]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../writeoff/impl/WriteOffCacheRepository.kt | 16 +++++++++++++--- 1 file changed, 13 insertions(+), 3 deletions(-) diff --git a/OCH/shuttle/driver_weaknet/src/main/java/com/mogo/och/weaknet/repository/writeoff/impl/WriteOffCacheRepository.kt b/OCH/shuttle/driver_weaknet/src/main/java/com/mogo/och/weaknet/repository/writeoff/impl/WriteOffCacheRepository.kt index 057f06f39a..b02e379e17 100644 --- a/OCH/shuttle/driver_weaknet/src/main/java/com/mogo/och/weaknet/repository/writeoff/impl/WriteOffCacheRepository.kt +++ b/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? { 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? {