[fea]
[站点id查询核销人数]
This commit is contained in:
yangyakun
2024-10-18 16:24:59 +08:00
parent 931404ea6b
commit 983dfab7ea

View File

@@ -12,6 +12,7 @@ import com.mogo.eagle.core.utilcode.mogo.logger.CallerLogger.d
import com.mogo.eagle.core.utilcode.mogo.logger.CallerLogger.i
import com.mogo.eagle.core.utilcode.mogo.logger.scene.SceneConstant
import com.mogo.och.common.module.manager.autopilot.line.LineManager
import com.mogo.och.common.module.manager.logchainanalytic.OchChainLogManager
import com.mogo.och.common.module.manager.loop.BizLoopManager
import com.mogo.och.common.module.manager.loop.LoopInfo
import com.mogo.och.common.module.manager.socket.cloud.IOchOnMessageListener
@@ -97,16 +98,17 @@ object TicketModel : IOchOnMessageListener<WriteOffPassenger>{
}
private fun selectWriteOffCount(){
LineManager.getStations().second?.let { endStation->
LineManager.getStations().first?.let { firstStation->
LineModel.currentTask?.let { currentTask->
ShuttleSaasServiceManager.queryBusTaskByLineId(AbsMogoApplication.getApp(),
"${currentTask.taskId}",
"${endStation.siteId}",
"${firstStation.siteId}",
object : OchCommonServiceCallback<WriteOffCountResponse> {
override fun onSuccess(data: WriteOffCountResponse?) {
data?.data?.let {
emitterMain?.onNext(it)
d(SceneConstant.M_BUS + TAG, "${endStation.name}核销人数:${it}")
d(SceneConstant.M_BUS + TAG, "${firstStation.name}核销人数:${it}")
OchChainLogManager.writeChainLog("核销人数","任务:${currentTask.taskId} zhan'dian")
}
}