@@ -24,15 +24,15 @@ object SweeperServiceManager {
*/
@JvmStatic
fun getCurrentTask ( context : Context , callback : OchCommonServiceCallback < BaseResponse < SweeperSubTaskBean > > ? ) {
val map = hashMapOf < String , String > ( )
map [ " serviceAppId " ] = MoGoAiCloudClientConfig . getInstance ( ) . s erviceAppId
map [ " token " ] = MoGoAiCloudClientConfig . getInstance ( ) . token
map [ " sn " ] = MoGoAiCloudClientConfig . getInstance ( ) . sn
val map = hashMapOf < String , String > ( )
map [ " serviceAppId " ] = getS erviceAppId( )
map [ " token " ] = getToken ( )
map [ " sn " ] = getCarSN ( )
d ( SceneConstant . M _SWEEPER + TAG , " getCurrentTask: " + GsonUtil . jsonFromObject ( map ) )
mService . getCurrentTask (
MoGoAiCloudClientConfig . getInstance ( ) . s erviceAppId,
MoGoAiCloudClientConfig . getInstance ( ) . token ,
MoGoAiCloudClientConfig . getInstance ( ) . sn
getS erviceAppId( ) ,
getToken ( ) ,
getCarSN ( )
)
. transformTry ( )
. subscribe ( OchCommonSubscribeImpl ( context , callback , " getCurrentTask " ) )
@@ -43,31 +43,32 @@ object SweeperServiceManager {
*/
@JvmStatic
fun getMainTaskList ( context : Context , callback : OchCommonServiceCallback < BaseResponse < MutableList < SweeperMainTaskBean > > > ? ) {
val map = hashMapOf < String , String > ( )
map [ " serviceAppId " ] = MoGoAiCloudClientConfig . getInstance ( ) . s erviceAppId
map [ " token " ] = MoGoAiCloudClientConfig . getInstance ( ) . token
map [ " sn " ] = MoGoAiCloudClientConfig . getInstance ( ) . sn
val map = hashMapOf < String , String > ( )
map [ " serviceAppId " ] = getS erviceAppId( )
map [ " token " ] = getToken ( )
map [ " sn " ] = getCarSN ( )
d ( SceneConstant . M _SWEEPER + TAG , " getMainTaskList: " + GsonUtil . jsonFromObject ( map ) )
mService . getMainTaskList (
MoGoAiCloudClientConfig . getInstance ( ) . s erviceAppId,
MoGoAiCloudClientConfig . getInstance ( ) . token ,
MoGoAiCloudClientConfig . getInstance ( ) . sn
getS erviceAppId( ) ,
getToken ( ) ,
getCarSN ( )
)
. transformTry ( )
. subscribe ( OchCommonSubscribeImpl ( context , callback , " getMainTaskList " ) )
}
/**
* 获取子任务列表
*/
@JvmStatic
fun getSubTaskList ( taskId : Int , context : Context , callback : OchCommonServiceCallback < BaseResponse < MutableList < SubInfo > > > ? ) {
val map = hashMapOf < String , String > ( )
map [ " carSn " ] = MoGoAiCloudClientConfig . getInstance ( ) . sn
val map = hashMapOf < String , String > ( )
map [ " carSn " ] = getCarSN ( )
map [ " taskId " ] = taskId . toString ( )
d ( SceneConstant . M _SWEEPER + TAG , " getSubTaskList: " + GsonUtil . jsonFromObject ( map ) )
mService . getSubTaskList (
MoGoAiCloudClientConfig . getInstance ( ) . s erviceAppId,
MoGoAiCloudClientConfig . getInstance ( ) . token ,
getS erviceAppId( ) ,
getToken ( ) ,
map
)
. transformTry ( )
@@ -79,13 +80,13 @@ object SweeperServiceManager {
*/
@JvmStatic
fun getSubTaskDetail ( subTaskId : Int , context : Context , callback : OchCommonServiceCallback < BaseResponse < SweeperSubTaskDetailBean > > ? ) {
val map = hashMapOf < String , String > ( )
map [ " carSn " ] = MoGoAiCloudClientConfig . getInstance ( ) . sn
val map = hashMapOf < String , String > ( )
map [ " carSn " ] = getCarSN ( )
map [ " taskId " ] = subTaskId . toString ( )
d ( SceneConstant . M _SWEEPER + TAG , " getSubTaskDetail: " + GsonUtil . jsonFromObject ( map ) )
mService . getSubTaskDetail (
MoGoAiCloudClientConfig . getInstance ( ) . s erviceAppId,
MoGoAiCloudClientConfig . getInstance ( ) . token ,
getS erviceAppId( ) ,
getToken ( ) ,
map
)
. transformTry ( )
@@ -96,12 +97,12 @@ object SweeperServiceManager {
* 子任务开始上报
*/
@JvmStatic
fun subTaskStart ( isFirst : Boolean , isEnd : Boolean , subTaskId : Int , context : Context , callback : OchCommonServiceCallback < BaseResponse < Boolean > > ? ) {
val subStartRequest = SubStartRequest ( MoGoAiCloudClientConfig . getInstance ( ) . sn , subTaskId , System . currentTimeMillis ( ) , isFirst , isEnd )
fun subTaskStart ( isFirst : Boolean , isEnd : Boolean , subTaskId : Int , context : Context , callback : OchCommonServiceCallback < BaseResponse < Boolean > > ? ) {
val subStartRequest = SubStartRequest ( getCarSN ( ) , subTaskId , System . currentTimeMillis ( ) , isFirst , isEnd )
d ( SceneConstant . M _SWEEPER + TAG , " subTaskStart: " + GsonUtil . jsonFromObject ( subStartRequest ) )
mService . subTaskStart (
MoGoAiCloudClientConfig . getInstance ( ) . s erviceAppId,
MoGoAiCloudClientConfig . getInstance ( ) . token ,
getS erviceAppId( ) ,
getToken ( ) ,
subStartRequest
)
. transformTry ( )
@@ -112,12 +113,12 @@ object SweeperServiceManager {
* 子任务结束上报
*/
@JvmStatic
fun subTaskEnd ( isFirst : Boolean , isEnd : Boolean , subTaskId : Int , context : Context , callback : OchCommonServiceCallback < BaseResponse < Boolean > > ? ) {
val subStartRequest = SubStartRequest ( MoGoAiCloudClientConfig . getInstance ( ) . sn , subTaskId , System . currentTimeMillis ( ) , isFirst , isEnd )
fun subTaskEnd ( isFirst : Boolean , isEnd : Boolean , subTaskId : Int , context : Context , callback : OchCommonServiceCallback < BaseResponse < Boolean > > ? ) {
val subStartRequest = SubStartRequest ( getCarSN ( ) , subTaskId , System . currentTimeMillis ( ) , isFirst , isEnd )
d ( SceneConstant . M _SWEEPER + TAG , " subTaskEnd: " + GsonUtil . jsonFromObject ( subStartRequest ) )
mService . subTaskEnd (
MoGoAiCloudClientConfig . getInstance ( ) . s erviceAppId,
MoGoAiCloudClientConfig . getInstance ( ) . token ,
getS erviceAppId( ) ,
getToken ( ) ,
subStartRequest
)
. transformTry ( )
@@ -128,12 +129,12 @@ object SweeperServiceManager {
* 子任务跳过上报
*/
@JvmStatic
fun subTaskSkip ( isFirst : Boolean , isEnd : Boolean , subTaskId : Int , context : Context , callback : OchCommonServiceCallback < BaseResponse < Boolean > > ? ) {
val subStartRequest = SubStartRequest ( MoGoAiCloudClientConfig . getInstance ( ) . sn , subTaskId , System . currentTimeMillis ( ) , isFirst , isEnd )
fun subTaskSkip ( isFirst : Boolean , isEnd : Boolean , subTaskId : Int , context : Context , callback : OchCommonServiceCallback < BaseResponse < Boolean > > ? ) {
val subStartRequest = SubStartRequest ( getCarSN ( ) , subTaskId , System . currentTimeMillis ( ) , isFirst , isEnd )
d ( SceneConstant . M _SWEEPER + TAG , " subTaskSkip: " + GsonUtil . jsonFromObject ( subStartRequest ) )
mService . subTaskSkip (
MoGoAiCloudClientConfig . getInstance ( ) . s erviceAppId,
MoGoAiCloudClientConfig . getInstance ( ) . token ,
getS erviceAppId( ) ,
getToken ( ) ,
subStartRequest
)
. transformTry ( )
@@ -144,17 +145,29 @@ object SweeperServiceManager {
* 主任务重置
*/
@JvmStatic
fun mainTaskReset ( taskId : Int , context : Context , callback : OchCommonServiceCallback < BaseResponse < Boolean > > ? ) {
val map = hashMapOf < String , String > ( )
map [ " carSn " ] = MoGoAiCloudClientConfig . getInstance ( ) . sn
fun mainTaskReset ( taskId : Int , context : Context , callback : OchCommonServiceCallback < BaseResponse < Boolean > > ? ) {
val map = hashMapOf < String , String > ( )
map [ " carSn " ] = getCarSN ( )
map [ " taskId " ] = taskId . toString ( )
d ( SceneConstant . M _SWEEPER + TAG , " mainTaskReset: " + GsonUtil . jsonFromObject ( map ) )
mService . mainTaskReset (
MoGoAiCloudClientConfig . getInstance ( ) . s erviceAppId,
MoGoAiCloudClientConfig . getInstance ( ) . token ,
getS erviceAppId( ) ,
getToken ( ) ,
map
)
. transformTry ( )
. subscribe ( OchCommonSubscribeImpl ( context , callback , " mainTaskReset " ) )
}
private fun getCarSN ( ) : String {
return MoGoAiCloudClientConfig . getInstance ( ) . sn
}
private fun getServiceAppId ( ) : String {
return MoGoAiCloudClientConfig . getInstance ( ) . serviceAppId
}
private fun getToken ( ) : String {
return MoGoAiCloudClientConfig . getInstance ( ) . token
}
}