Merge branch 'dev_robotaxi-d_230412_2.15.0' of gitlab.zhidaoauto.com:SCA/L4HA/AndroidApp/MoGoEagleEye into dev_robotaxi-d_230412_2.15.0
This commit is contained in:
@@ -64,10 +64,22 @@ class FuncBizProvider : IMoGoFuncBizProvider {
|
||||
dispatchAutoPilotManager.affirm()
|
||||
}
|
||||
|
||||
override fun stopDispatchAffirm() {
|
||||
dispatchAutoPilotManager.stopAffirm()
|
||||
}
|
||||
|
||||
override fun dispatchCancel(manualTrigger: Boolean) {
|
||||
dispatchAutoPilotManager.cancel(manualTrigger)
|
||||
}
|
||||
|
||||
override fun stopDispatchCancel(manualTrigger: Boolean) {
|
||||
dispatchAutoPilotManager.stopCancel(manualTrigger)
|
||||
}
|
||||
|
||||
override fun restartDispatchAffirm() {
|
||||
dispatchAutoPilotManager.restartDispatch()
|
||||
}
|
||||
|
||||
override fun testDispatch(sceneType: Int) {
|
||||
dispatchAutoPilotManager.testDispatch(sceneType)
|
||||
}
|
||||
|
||||
@@ -3,8 +3,10 @@ package com.mogo.eagle.function.biz.dispatch
|
||||
import android.content.Context
|
||||
import android.os.Handler
|
||||
import android.os.Message
|
||||
import android.util.Log
|
||||
import com.mogo.aicloud.services.socket.IMogoOnMessageListener
|
||||
import com.mogo.aicloud.services.socket.MogoAiCloudSocketManager
|
||||
import com.mogo.commons.voice.AIAssist
|
||||
import com.mogo.eagle.core.data.autopilot.AutopilotControlParameters
|
||||
import com.mogo.eagle.core.data.autopilot.AutopilotRouteInfo
|
||||
import com.mogo.eagle.core.data.biz.dispatch.DispatchAdasAutoPilotLocReceiverBean
|
||||
@@ -21,19 +23,26 @@ import com.mogo.eagle.core.function.call.hmi.CallerHmiManager
|
||||
import com.mogo.eagle.core.utilcode.mogo.logger.CallerLogger
|
||||
import com.mogo.eagle.core.utilcode.mogo.logger.scene.SceneConstant
|
||||
import com.mogo.eagle.core.utilcode.util.CoordinateUtils
|
||||
import com.mogo.eagle.core.utilcode.util.ToastUtils
|
||||
import com.mogo.eagle.function.biz.dispatch.network.DispatchServiceModel.Companion.DISPATCH_COMPLETED
|
||||
import com.mogo.eagle.function.biz.dispatch.network.DispatchServiceModel.Companion.DISPATCH_RESULT_AFFIRM
|
||||
import com.mogo.eagle.function.biz.dispatch.network.DispatchServiceModel.Companion.DISPATCH_RESULT_MANUAL_CANCEL
|
||||
import com.mogo.eagle.function.biz.dispatch.network.DispatchServiceModel.Companion.DISPATCH_RESULT_TIMER_CANCEL
|
||||
import com.mogo.eagle.function.biz.dispatch.network.DispatchServiceModel.Companion.DISPATCH_STOP_AFFIRM
|
||||
import com.mogo.eagle.function.biz.dispatch.network.DispatchServiceModel.Companion.DISPATCH_STOP_MANUAL_CANCEL
|
||||
import com.mogo.eagle.function.biz.dispatch.network.DispatchServiceModel.Companion.DISPATCH_STOP_TIMER_CANCEL
|
||||
import com.mogo.eagle.function.biz.dispatch.network.DispatchServiceModel.Companion.dispatchServiceModel
|
||||
import com.zhjt.mogo.adas.data.bean.MogoReport
|
||||
import mogo.telematics.pad.MessagePad
|
||||
import mogo_msg.MogoReportMsg
|
||||
|
||||
|
||||
//负责监听自动驾驶状态并进行状态上报,自动驾驶路线上报,接收调度指令展示指令弹窗
|
||||
class DispatchAutoPilotManager private constructor() :
|
||||
IMogoOnMessageListener<DispatchAdasAutoPilotLocReceiverBean>,
|
||||
IMoGoCheckAutoPilotBtnListener,
|
||||
IMoGoPlanningRottingListener,
|
||||
IMoGoAutopilotStatusListener {
|
||||
IMogoOnMessageListener<DispatchAdasAutoPilotLocReceiverBean>,
|
||||
IMoGoCheckAutoPilotBtnListener,
|
||||
IMoGoPlanningRottingListener,
|
||||
IMoGoAutopilotStatusListener {
|
||||
|
||||
companion object {
|
||||
private const val TAG = "DispatchAutoPilotManager"
|
||||
@@ -110,6 +119,7 @@ class DispatchAutoPilotManager private constructor() :
|
||||
}
|
||||
|
||||
override fun onMsgReceived(adasAutoPilotLocReceiverBean: DispatchAdasAutoPilotLocReceiverBean?) {
|
||||
Log.i(TAG,"onMsgReceived 收到云调度长链接")
|
||||
if (adasAutoPilotLocReceiverBean != null && adasAutoPilotLocReceiverBean.startLat != 0.0 && adasAutoPilotLocReceiverBean.startLon != 0.0) {
|
||||
receiverBean = adasAutoPilotLocReceiverBean
|
||||
val message = Message()
|
||||
@@ -117,11 +127,52 @@ class DispatchAutoPilotManager private constructor() :
|
||||
message.obj = adasAutoPilotLocReceiverBean
|
||||
handler.sendMessage(message)
|
||||
}
|
||||
//同步调用路线下载逻辑
|
||||
adasAutoPilotLocReceiverBean?.let {
|
||||
if(it.type == 1){
|
||||
val mAutoPilotLine = AutopilotControlParameters.AutoPilotLine(it.lineId.toLong(),it.trajUrl,it.trajMd5,it.stopUrl,it.stopMd5,it.timestamp,
|
||||
it.vehicleModel,it.trajUrl_dpqp,it.trajMd5_dpqp,it.stopUrl_dpqp,it.stopMd5_dpqp,it.timestamp_dpqp)
|
||||
CallerAutoPilotControlManager.sendTrajectoryDownloadReq(mAutoPilotLine)
|
||||
Log.i(TAG,"调用路线下载逻辑")
|
||||
}
|
||||
}
|
||||
|
||||
adasAutoPilotLocReceiverBean?.let {
|
||||
Log.i(TAG,"taskId="+it.taskId)
|
||||
Log.i(TAG,"type="+it.type)
|
||||
Log.i(TAG,"source="+it.source)
|
||||
Log.i(TAG,"lineName="+it.lineName)
|
||||
Log.i(TAG,"stopMd5_dpqp="+it.stopMd5_dpqp)
|
||||
Log.i(TAG,"stopUrl_dpqp="+it.stopUrl_dpqp)
|
||||
Log.i(TAG,"trajMd5_dpqp="+it.trajMd5_dpqp)
|
||||
Log.i(TAG,"trajUrl_dpqp="+it.trajUrl_dpqp)
|
||||
Log.i(TAG,"stopMd5_dpqp="+it.stopMd5_dpqp)
|
||||
Log.i(TAG,"stopMd5="+it.stopMd5)
|
||||
Log.i(TAG,"stopUrl="+it.stopUrl)
|
||||
Log.i(TAG,"trajUrl="+it.trajUrl)
|
||||
Log.i(TAG,"trajMd5="+it.trajMd5)
|
||||
Log.i(TAG,"endLocAddress="+it.endLocAddress)
|
||||
Log.i(TAG,"flightInfo="+it.flightInfo)
|
||||
Log.i(TAG,"poiId="+it.poiId)
|
||||
Log.i(TAG,"startLocAddress="+it.startLocAddress)
|
||||
Log.i(TAG,"taskInfo="+it.taskInfo)
|
||||
Log.i(TAG,"taskTime="+it.taskTime)
|
||||
Log.i(TAG,"vehicleModel="+it.vehicleModel)
|
||||
Log.i(TAG,"endLat="+it.endLat)
|
||||
Log.i(TAG,"endLon="+it.endLon)
|
||||
Log.i(TAG,"lineId="+it.lineId)
|
||||
Log.i(TAG,"startLat="+it.startLat)
|
||||
Log.i(TAG,"startLon="+it.startLon)
|
||||
Log.i(TAG,"stopsList="+it.stopsList)
|
||||
Log.i(TAG,"timestamp="+it.timestamp)
|
||||
Log.i(TAG,"systemTime="+it.systemTime)
|
||||
Log.i(TAG,"timestamp_dpqp="+it.timestamp_dpqp)
|
||||
}
|
||||
}
|
||||
|
||||
private fun startAutoPilot() {
|
||||
val currentAutopilot = AutopilotControlParameters()
|
||||
currentAutopilot.isSpeakVoice = false
|
||||
// currentAutopilot.isSpeakVoice = false
|
||||
val wayLatLon: MutableList<AutopilotControlParameters.AutoPilotLonLat> = ArrayList()
|
||||
receiverBean?.let {
|
||||
if (it.stopsList != null) {
|
||||
@@ -134,6 +185,14 @@ class DispatchAutoPilotManager private constructor() :
|
||||
)
|
||||
}
|
||||
}
|
||||
val currentAutoPilotLine = AutopilotControlParameters.AutoPilotLine(it.lineId.toLong(),it.trajUrl,it.trajMd5,
|
||||
it.stopUrl,it.stopMd5,it.timestamp,it.vehicleModel,it.trajUrl_dpqp,it.trajMd5_dpqp,it.stopUrl_dpqp,
|
||||
it.stopMd5_dpqp,it.timestamp_dpqp)
|
||||
currentAutopilot.autoPilotLine = currentAutoPilotLine
|
||||
currentAutopilot.routeID = it.lineId
|
||||
currentAutopilot.routeName = it.lineName
|
||||
currentAutopilot.startName = it.startLocAddress
|
||||
currentAutopilot.endName = it.endLocAddress
|
||||
currentAutopilot.wayLatLons = wayLatLon
|
||||
currentAutopilot.startLatLon =
|
||||
AutopilotControlParameters.AutoPilotLonLat(it.startLat, it.startLon)
|
||||
@@ -141,20 +200,65 @@ class DispatchAutoPilotManager private constructor() :
|
||||
AutopilotControlParameters.AutoPilotLonLat(it.endLat, it.endLon)
|
||||
currentAutopilot.vehicleType = 10
|
||||
CallerLogger.d(SceneConstant.Companion.M_DISPATCH + TAG, "开启自动驾驶====$currentAutopilot")
|
||||
Log.i(TAG,"开启自动驾驶====$currentAutopilot")
|
||||
CallerAutoPilotControlManager.startAutoPilot(currentAutopilot)
|
||||
}
|
||||
}
|
||||
|
||||
fun affirm() {
|
||||
CallerHmiManager.dismissDispatchDialog()
|
||||
dispatchServiceModel.dispatchResultUpload(DISPATCH_RESULT_AFFIRM)
|
||||
receiverBean?.taskId?.let { it ->
|
||||
dispatchServiceModel.dispatchResultUpload(DISPATCH_RESULT_AFFIRM, it,
|
||||
onSuccess = {
|
||||
//调用工控机开启自动驾驶
|
||||
startAutoPilot()
|
||||
},onError = { error->
|
||||
ToastUtils.showShort("上报调度失败${error}")
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 停止调度确认
|
||||
*/
|
||||
fun stopAffirm(){
|
||||
CallerHmiManager.dismissDispatchDialog()
|
||||
receiverBean?.taskId?.let{
|
||||
dispatchServiceModel.dispatchResultUpload(DISPATCH_STOP_AFFIRM, it,
|
||||
onSuccess = {
|
||||
//取消自动驾驶
|
||||
CallerAutoPilotControlManager.cancelAutoPilot()
|
||||
Log.i(TAG,"stopAffirm 取消自动驾驶")
|
||||
}, onError = {})
|
||||
}
|
||||
}
|
||||
|
||||
fun cancel(manualTrigger: Boolean) {
|
||||
CallerHmiManager.dismissDispatchDialog()
|
||||
dispatchServiceModel.dispatchResultUpload(
|
||||
if (manualTrigger) DISPATCH_RESULT_MANUAL_CANCEL else DISPATCH_RESULT_TIMER_CANCEL
|
||||
)
|
||||
receiverBean?.taskId?.let {
|
||||
dispatchServiceModel.dispatchResultUpload(
|
||||
if (manualTrigger) DISPATCH_RESULT_MANUAL_CANCEL else DISPATCH_RESULT_TIMER_CANCEL, it)
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 停止调度取消
|
||||
*/
|
||||
fun stopCancel(manualTrigger: Boolean){
|
||||
CallerHmiManager.dismissDispatchDialog()
|
||||
receiverBean?.taskId?.let{
|
||||
dispatchServiceModel.dispatchResultUpload(
|
||||
if (manualTrigger) DISPATCH_STOP_MANUAL_CANCEL else DISPATCH_STOP_TIMER_CANCEL, it)
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 重启自驾
|
||||
*/
|
||||
fun restartDispatch(){
|
||||
CallerHmiManager.dismissDispatchDialog()
|
||||
//启动自动驾驶
|
||||
startAutoPilot()
|
||||
}
|
||||
|
||||
override fun onCheck(isChecked: Boolean) {
|
||||
@@ -197,7 +301,7 @@ class DispatchAutoPilotManager private constructor() :
|
||||
SceneConstant.Companion.M_DISPATCH + TAG,
|
||||
"onArriveAt data : $arrivalNotification"
|
||||
)
|
||||
|
||||
Log.i(TAG,"onArriveAt data : $arrivalNotification")
|
||||
if (arrivalNotification.endLocation == null) {
|
||||
return
|
||||
}
|
||||
@@ -211,10 +315,65 @@ class DispatchAutoPilotManager private constructor() :
|
||||
SceneConstant.Companion.M_DISPATCH + TAG,
|
||||
"onArriveAt cal distance : $distanceFromSelf"
|
||||
)
|
||||
Log.i(TAG,"onArriveAt cal distance : $distanceFromSelf")
|
||||
if (distanceFromSelf < 10) {
|
||||
CallerLogger.d(SceneConstant.Companion.M_DISPATCH + TAG, "onArriveAt end location")
|
||||
isDispatch = false
|
||||
isArriveEnd = true
|
||||
//到站,调度完成
|
||||
receiverBean?.let {
|
||||
//调度完成,同步云端,并且吐司提示
|
||||
dispatchServiceModel.dispatchResultUpload(DISPATCH_COMPLETED, it.taskId)
|
||||
ToastUtils.showLong("云调度完成,车辆已到达${it.endLocAddress}")
|
||||
//取消自动驾驶
|
||||
CallerAutoPilotControlManager.cancelAutoPilot()
|
||||
//语音提示到站
|
||||
AIAssist.getInstance(mContext).speakTTSVoice("云调度完成,车辆已到达${it.endLocAddress}")
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 接口MEC反馈的常规信息(MAP v2.5.0新增轨迹相关信息)
|
||||
* @param guardianInfo
|
||||
*/
|
||||
override fun onAutopilotGuardian(guardianInfo: MogoReportMsg.MogoReportMessage?) {
|
||||
if (guardianInfo == null || !guardianInfo.hasCode()) return
|
||||
Log.i(TAG,"onAutopilotGuardian "+guardianInfo.code)
|
||||
//掉自驾
|
||||
when(guardianInfo.code){
|
||||
MogoReport.Code.Error.EMAP.EXIT_AUTOPILOT_FOR_PLANNING,
|
||||
MogoReport.Code.Error.EMAP.EXIT_AUTOPILOT_FOR_LOCATION,
|
||||
MogoReport.Code.Error.EMAP.EXIT_AUTOPILOT_FOR_CHASSIS,
|
||||
MogoReport.Code.Error.EMAP.EXIT_AUTOPILOT_FOR_DISTANCE,
|
||||
MogoReport.Code.Error.EMAP.EXIT_AUTOPILOT_FOR_BRAKE,
|
||||
MogoReport.Code.Error.EMAP.EXIT_AUTOPILOT_FOR_ACCEL,
|
||||
MogoReport.Code.Error.EMAP.EXIT_AUTOPILOT_FOR_STEER,
|
||||
MogoReport.Code.Error.EMAP.EXIT_AUTOPILOT_FOR_GEAR_SWITCH,
|
||||
MogoReport.Code.Error.EMAP.EXIT_AUTOPILOT_FOR_CHASSIS_NO_RESPONSE,
|
||||
MogoReport.Code.Error.EMAP.EXIT_AUTOPILOT_FOR_CHASSIS_UNKNOWN,
|
||||
"IRECORDER_TASK_AUTO"//自动录包任务创建
|
||||
->{
|
||||
//如果到达终点,则不处理
|
||||
if(isArriveEnd){
|
||||
return
|
||||
}
|
||||
//处于云调度任务中且调度实体类不为空,弹出重启自驾弹窗
|
||||
if(isDispatch){
|
||||
receiverBean?.let { CallerHmiManager.showDispatchRestartDialog(it) }
|
||||
}
|
||||
}
|
||||
}
|
||||
if ("ISYS_INIT_TRAJECTORY_START".equals(guardianInfo.code)){
|
||||
Log.i(TAG,"onAutopilotGuardian ISYS_INIT_TRAJECTORY_START 轨迹管理_轨迹开始下载(本地已有对应轨迹也触发)")
|
||||
}else if ("ISYS_INIT_TRAJECTORY_SUCCESS".equals(guardianInfo.code)){
|
||||
Log.i(TAG,"onAutopilotGuardian ISYS_INIT_TRAJECTORY_SUCCESS 轨迹管理_轨迹下载成功(本地已有对应轨迹也触发)")
|
||||
}else if ("ISYS_INIT_TRAJECTORY_FAILURE".equals(guardianInfo.code)){
|
||||
Log.i(TAG,"onAutopilotGuardian ISYS_INIT_TRAJECTORY_FAILURE 轨迹管理_轨迹下载失败,本地无对应轨迹")
|
||||
}else if ("ISYS_INIT_TRAJECTORY_WARNING".equals(guardianInfo.code)){
|
||||
Log.i(TAG,"onAutopilotGuardian ISYS_INIT_TRAJECTORY_WARNING 轨迹管理_轨迹下载失败,本地有对应轨迹,认为成功")
|
||||
}else if ("ISYS_INIT_TRAJECTORY_TIMEOUT".equals(guardianInfo.code)){
|
||||
Log.i(TAG,"onAutopilotGuardian ISYS_INIT_TRAJECTORY_TIMEOUT 轨迹管理_轨迹下载超时")
|
||||
}
|
||||
}
|
||||
|
||||
@@ -243,7 +402,10 @@ class DispatchAutoPilotManager private constructor() :
|
||||
"AR453航班",
|
||||
"你车需执行编号ca1098次航班的引导任务,从A区A1到B区B1",
|
||||
System.currentTimeMillis(),
|
||||
ArrayList<MogoLatLng>()
|
||||
ArrayList<MogoLatLng>(),
|
||||
10,
|
||||
1,
|
||||
""
|
||||
)
|
||||
receiverBean = adasAutoPilotLocReceiverBean
|
||||
CallerHmiManager.showDispatchDialog(adasAutoPilotLocReceiverBean)
|
||||
@@ -265,7 +427,10 @@ class DispatchAutoPilotManager private constructor() :
|
||||
"",
|
||||
"",
|
||||
System.currentTimeMillis(),
|
||||
ArrayList<MogoLatLng>()
|
||||
ArrayList<MogoLatLng>(),
|
||||
10,
|
||||
1,
|
||||
""
|
||||
)
|
||||
receiverBean = adasAutoPilotLocReceiverBean
|
||||
CallerHmiManager.showDispatchDialog(adasAutoPilotLocReceiverBean)
|
||||
@@ -287,14 +452,19 @@ class DispatchAutoPilotManager private constructor() :
|
||||
"",
|
||||
"",
|
||||
System.currentTimeMillis(),
|
||||
ArrayList<MogoLatLng>()
|
||||
ArrayList<MogoLatLng>(),
|
||||
10,
|
||||
1,
|
||||
""
|
||||
)
|
||||
receiverBean = adasAutoPilotLocReceiverBean
|
||||
CallerHmiManager.showDispatchDialog(adasAutoPilotLocReceiverBean)
|
||||
}
|
||||
|
||||
private fun testDispatchResultUpload() {
|
||||
dispatchServiceModel.dispatchResultUpload(DISPATCH_RESULT_AFFIRM)
|
||||
receiverBean?.taskId?.let {
|
||||
dispatchServiceModel.dispatchResultUpload(DISPATCH_RESULT_AFFIRM, it)
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
@@ -23,6 +23,10 @@ class DispatchServiceModel private constructor() {
|
||||
const val DISPATCH_RESULT_AFFIRM = 0
|
||||
const val DISPATCH_RESULT_MANUAL_CANCEL = 1
|
||||
const val DISPATCH_RESULT_TIMER_CANCEL = 2
|
||||
const val DISPATCH_STOP_AFFIRM = 3 //云端终止指令-确认
|
||||
const val DISPATCH_STOP_TIMER_CANCEL = 4 //云端终止指令-超时拒绝
|
||||
const val DISPATCH_STOP_MANUAL_CANCEL = 5 //云端终止指令-手动拒绝
|
||||
const val DISPATCH_COMPLETED = 6 //调度完成
|
||||
|
||||
val dispatchServiceModel by lazy(LazyThreadSafetyMode.SYNCHRONIZED) {
|
||||
DispatchServiceModel()
|
||||
@@ -111,6 +115,7 @@ class DispatchServiceModel private constructor() {
|
||||
*/
|
||||
fun dispatchResultUpload(
|
||||
dispatchResultType: Int,
|
||||
taskId: Long,
|
||||
onSuccess: ((BaseData) -> Unit)? = null,
|
||||
onError: ((String) -> Unit)? = null
|
||||
) {
|
||||
@@ -118,7 +123,8 @@ class DispatchServiceModel private constructor() {
|
||||
val reportDispatchResult =
|
||||
ReportDispatchResult(
|
||||
sn,
|
||||
dispatchResultType
|
||||
dispatchResultType,
|
||||
taskId
|
||||
)
|
||||
val map: MutableMap<String, Any> = HashMap()
|
||||
map["sn"] = sn
|
||||
|
||||
@@ -221,6 +221,14 @@ class MoGoHmiProvider : IMoGoHmiProvider {
|
||||
}
|
||||
}
|
||||
|
||||
override fun showDispatchRestartDialog(msgData: DispatchAdasAutoPilotLocReceiverBean) {
|
||||
ThreadUtils.runOnUiThread {
|
||||
context?.let{
|
||||
DispatchDialogManager.getInstance(it).showRestartDialog(msgData)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
override fun showNoticeForTrafficWithData(pushData: NoticeTrafficStylePushData?) {
|
||||
pushData?.let {
|
||||
ThreadUtils.runOnUiThread {
|
||||
|
||||
@@ -3,17 +3,21 @@ package com.mogo.eagle.core.function.hmi.ui.notice;
|
||||
import android.app.Dialog;
|
||||
import android.content.Context;
|
||||
import android.os.Build;
|
||||
import android.view.Gravity;
|
||||
import android.view.ViewGroup;
|
||||
import android.view.WindowManager;
|
||||
import android.widget.FrameLayout;
|
||||
|
||||
import androidx.annotation.NonNull;
|
||||
|
||||
import com.mogo.eagle.core.data.biz.dispatch.DispatchAdasAutoPilotLocReceiverBean;
|
||||
import com.mogo.eagle.core.function.hmi.R;
|
||||
import com.mogo.eagle.core.utilcode.mogo.logger.CallerLogger;
|
||||
|
||||
public abstract class DispatchBaseDialog extends Dialog {
|
||||
|
||||
public DispatchBaseDialog(@NonNull Context context) {
|
||||
super(context, R.style.Base_AlertDialog_AppCompat);
|
||||
super(context,R.style.BaseFloatDialogStyle);
|
||||
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
|
||||
getWindow().setType(WindowManager.LayoutParams.TYPE_APPLICATION_OVERLAY);
|
||||
} else {
|
||||
@@ -26,4 +30,22 @@ public abstract class DispatchBaseDialog extends Dialog {
|
||||
|
||||
public abstract void showDialog(DispatchAdasAutoPilotLocReceiverBean dispatchContent);
|
||||
|
||||
@Override
|
||||
public void show() {
|
||||
super.show();
|
||||
setWindowSize();
|
||||
}
|
||||
private void setWindowSize(){
|
||||
WindowManager.LayoutParams attributes = getWindow().getAttributes();
|
||||
attributes.width = ViewGroup.LayoutParams.MATCH_PARENT;
|
||||
attributes.height = ViewGroup.LayoutParams.MATCH_PARENT;
|
||||
FrameLayout content = (FrameLayout)findViewById(android.R.id.content);
|
||||
if(content!=null){
|
||||
ViewGroup rootView = (ViewGroup) content.getChildAt(0);
|
||||
FrameLayout.LayoutParams layoutParams = (FrameLayout.LayoutParams) rootView.getLayoutParams();
|
||||
layoutParams.gravity = Gravity.CENTER;
|
||||
rootView.setLayoutParams(layoutParams);
|
||||
}
|
||||
getWindow().setAttributes(attributes);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -21,6 +21,10 @@ public class DispatchCarsDialog extends DispatchBaseDialog {
|
||||
|
||||
private final TextView tvTimer;
|
||||
private final TextView tvLoc;
|
||||
private final TextView tvAdasDispatchTitle;
|
||||
private final TextView tvAdasDispatchRemindContent;
|
||||
|
||||
private int dispatchType = 1;//调度类型:1:启动 2:停止
|
||||
|
||||
private final Handler handler = new Handler() {
|
||||
@Override
|
||||
@@ -44,21 +48,40 @@ public class DispatchCarsDialog extends DispatchBaseDialog {
|
||||
setCanceledOnTouchOutside(false);
|
||||
tvTimer = findViewById(R.id.module_adas_dispatch_remind_timer);
|
||||
tvLoc = findViewById(R.id.module_adas_dispatch_remind_loc);
|
||||
Button btnAffirm = (Button) findViewById(R.id.module_adas_dispatch_remind_affirm);
|
||||
Button btnCancel = (Button) findViewById(R.id.module_adas_dispatch_remind_cancel);
|
||||
tvAdasDispatchTitle = findViewById(R.id.tv_adas_dispatch_title);
|
||||
tvAdasDispatchRemindContent = findViewById(R.id.tv_adas_dispatch_remind_content);
|
||||
Button btnAffirm = findViewById(R.id.module_adas_dispatch_remind_affirm);
|
||||
Button btnCancel = findViewById(R.id.module_adas_dispatch_remind_cancel);
|
||||
tvTimer.setText(String.valueOf(TIMER));
|
||||
btnAffirm.setOnClickListener(v -> {
|
||||
CallerFuncBizManager.getBizProvider().dispatchAffirm();
|
||||
if(dispatchType == 1){
|
||||
//开始调度确认
|
||||
CallerFuncBizManager.getBizProvider().dispatchAffirm();
|
||||
}else if(dispatchType == 2){
|
||||
//停止调度确认
|
||||
CallerFuncBizManager.getBizProvider().stopDispatchAffirm();
|
||||
}
|
||||
dismissDialog();
|
||||
});
|
||||
btnCancel.setOnClickListener(v -> {
|
||||
CallerFuncBizManager.getBizProvider().dispatchCancel(true);
|
||||
if(dispatchType == 1){
|
||||
//开始调度手动取消
|
||||
CallerFuncBizManager.getBizProvider().dispatchCancel(true);
|
||||
}else if(dispatchType == 2){
|
||||
//停止调度手动取消
|
||||
CallerFuncBizManager.getBizProvider().stopDispatchCancel(true);
|
||||
}
|
||||
dismissDialog();
|
||||
});
|
||||
}
|
||||
|
||||
private void hideDialog() {
|
||||
CallerFuncBizManager.getBizProvider().dispatchCancel(false);
|
||||
if(dispatchType == 1){
|
||||
//开始调度自动取消
|
||||
CallerFuncBizManager.getBizProvider().dispatchCancel(false);
|
||||
}else if(dispatchType == 2){
|
||||
CallerFuncBizManager.getBizProvider().stopDispatchCancel(false);
|
||||
}
|
||||
dismissDialog();
|
||||
}
|
||||
|
||||
@@ -74,6 +97,12 @@ public class DispatchCarsDialog extends DispatchBaseDialog {
|
||||
return;
|
||||
}
|
||||
show();
|
||||
if(dispatchContent.getType() == 2){
|
||||
//取消调度
|
||||
tvAdasDispatchTitle.setText("调度取消确认");
|
||||
tvAdasDispatchRemindContent.setText("车辆将取消到以下位置的自动驾驶");
|
||||
}
|
||||
dispatchType = dispatchContent.getType();
|
||||
handler.sendEmptyMessage(MSG_TYPE_TIMER);
|
||||
tvLoc.setText(dispatchContent.getEndLocAddress());
|
||||
}
|
||||
|
||||
@@ -53,16 +53,38 @@ public class DispatchDialogManager {
|
||||
}
|
||||
}
|
||||
|
||||
private void dispatchHengYang(DispatchAdasAutoPilotLocReceiverBean msgData) {
|
||||
if (msgData.getType() == DISPATCH_TYPE_START) { //衡阳只有开始调度
|
||||
if (dialog != null && dialog.isShowing()) { //避免下发两次
|
||||
return;
|
||||
}
|
||||
if (dialog == null) {
|
||||
dialog = new DispatchCarsDialog(mContext);
|
||||
}
|
||||
dialog.showDialog(msgData);
|
||||
/**
|
||||
* 云调度重启自驾
|
||||
* @param msgData 长链下发实体
|
||||
*/
|
||||
public void showRestartDialog(DispatchAdasAutoPilotLocReceiverBean msgData){
|
||||
if(isShowing()){
|
||||
return;
|
||||
}
|
||||
if (msgData == null) {
|
||||
return;
|
||||
}
|
||||
if (dialog != null && dialog.isShowing()) { //避免下发两次
|
||||
return;
|
||||
}
|
||||
if(dialog == null){
|
||||
dialog = new DispatchRestartDialog(mContext);
|
||||
}
|
||||
dialog.showDialog(msgData);
|
||||
}
|
||||
|
||||
private void dispatchHengYang(DispatchAdasAutoPilotLocReceiverBean msgData) {
|
||||
// if (msgData.getType() == DISPATCH_TYPE_START) { //衡阳只有开始调度
|
||||
// }
|
||||
//开始、取消调度
|
||||
if (dialog != null && dialog.isShowing()) { //避免下发两次
|
||||
return;
|
||||
}
|
||||
if (dialog == null) {
|
||||
dialog = new DispatchCarsDialog(mContext);
|
||||
}
|
||||
dialog.showDialog(msgData);
|
||||
|
||||
}
|
||||
|
||||
private void dispatchEZhou(DispatchAdasAutoPilotLocReceiverBean msgData) {
|
||||
|
||||
@@ -0,0 +1,29 @@
|
||||
package com.mogo.eagle.core.function.hmi.ui.notice;
|
||||
|
||||
import android.content.Context;
|
||||
import android.widget.TextView;
|
||||
|
||||
import androidx.annotation.NonNull;
|
||||
|
||||
import com.mogo.eagle.core.data.biz.dispatch.DispatchAdasAutoPilotLocReceiverBean;
|
||||
import com.mogo.eagle.core.function.call.biz.CallerFuncBizManager;
|
||||
import com.mogo.eagle.core.function.hmi.R;
|
||||
|
||||
public class DispatchRestartDialog extends DispatchBaseDialog{
|
||||
|
||||
public DispatchRestartDialog(@NonNull Context context) {
|
||||
super(context);
|
||||
setContentView(R.layout.dialog_adas_dispatch_restart);
|
||||
setCanceledOnTouchOutside(false);
|
||||
TextView dispatchRestartEnter = findViewById(R.id.tv_dispatch_restart_enter);
|
||||
dispatchRestartEnter.setOnClickListener(v -> {
|
||||
//启动自动驾驶
|
||||
CallerFuncBizManager.getBizProvider().restartDispatchAffirm();
|
||||
});
|
||||
}
|
||||
|
||||
@Override
|
||||
public void showDialog(DispatchAdasAutoPilotLocReceiverBean dispatchContent) {
|
||||
show();
|
||||
}
|
||||
}
|
||||
@@ -19,6 +19,7 @@
|
||||
app:layout_constraintTop_toTopOf="parent" />
|
||||
|
||||
<TextView
|
||||
android:id="@+id/tv_adas_dispatch_title"
|
||||
android:layout_width="wrap_content"
|
||||
android:layout_height="wrap_content"
|
||||
android:layout_marginTop="@dimen/module_services_dispatch_cars_dialog_title_margin_top"
|
||||
@@ -30,6 +31,7 @@
|
||||
app:layout_constraintTop_toTopOf="parent" />
|
||||
|
||||
<TextView
|
||||
android:id="@+id/tv_adas_dispatch_remind_content"
|
||||
android:layout_width="wrap_content"
|
||||
android:layout_height="wrap_content"
|
||||
android:layout_marginTop="@dimen/module_services_dispatch_cars_dialog_content_margin_top"
|
||||
|
||||
@@ -0,0 +1,55 @@
|
||||
<?xml version="1.0" encoding="utf-8"?>
|
||||
<androidx.constraintlayout.widget.ConstraintLayout xmlns:android="http://schemas.android.com/apk/res/android"
|
||||
xmlns:app="http://schemas.android.com/apk/res-auto"
|
||||
android:layout_width="@dimen/module_services_dispatch_cars_dialog_width"
|
||||
android:layout_height="@dimen/module_services_dispatch_cars_dialog_height"
|
||||
android:background="@drawable/bg_dispatch_cars">
|
||||
|
||||
<TextView
|
||||
android:layout_width="wrap_content"
|
||||
android:layout_height="wrap_content"
|
||||
app:layout_constraintLeft_toLeftOf="parent"
|
||||
app:layout_constraintRight_toRightOf="parent"
|
||||
app:layout_constraintTop_toTopOf="parent"
|
||||
android:text="@string/dispatch_dialog_restart_title"
|
||||
android:textColor="@android:color/white"
|
||||
android:textSize="@dimen/dp_48"
|
||||
android:layout_marginTop="@dimen/module_services_dispatch_cars_dialog_title_margin_top"
|
||||
/>
|
||||
|
||||
<TextView
|
||||
android:layout_width="wrap_content"
|
||||
android:layout_height="wrap_content"
|
||||
app:layout_constraintLeft_toLeftOf="parent"
|
||||
app:layout_constraintRight_toRightOf="parent"
|
||||
app:layout_constraintTop_toTopOf="parent"
|
||||
android:layout_marginTop="@dimen/dp_200"
|
||||
android:gravity="center_horizontal"
|
||||
android:text="@string/dispatch_dialog_restart_content"
|
||||
android:textColor="@android:color/white"
|
||||
android:textSize="@dimen/dp_40"
|
||||
/>
|
||||
|
||||
<TextView
|
||||
android:id="@+id/tv_dispatch_restart_enter"
|
||||
android:layout_width="0dp"
|
||||
android:layout_height="@dimen/module_services_dispatch_cars_dialog_line_margin_bottom"
|
||||
app:layout_constraintLeft_toLeftOf="parent"
|
||||
app:layout_constraintRight_toRightOf="parent"
|
||||
app:layout_constraintBottom_toBottomOf="parent"
|
||||
android:text="@string/dispatch_dialog_restart_enter"
|
||||
android:textColor="@color/color_1F9BFE"
|
||||
android:textSize="@dimen/module_services_dispatch_cars_dialog_title_size"
|
||||
android:gravity="center"
|
||||
/>
|
||||
|
||||
<View
|
||||
android:layout_width="match_parent"
|
||||
android:layout_height="1dp"
|
||||
android:background="@color/color_66B8BFE8"
|
||||
app:layout_constraintBottom_toBottomOf="parent"
|
||||
app:layout_constraintBottom_toTopOf="@+id/tv_dispatch_restart_enter"
|
||||
app:layout_constraintLeft_toLeftOf="parent"
|
||||
app:layout_constraintRight_toRightOf="parent" />
|
||||
|
||||
</androidx.constraintlayout.widget.ConstraintLayout>
|
||||
@@ -64,6 +64,9 @@
|
||||
<string name="dispatch_dialog_flight_info">航班信息:</string>
|
||||
<string name="dispatch_dialog_affirm">接受任务</string>
|
||||
<string name="dispatch_cars_remind_title">调度确认</string>
|
||||
<string name="dispatch_dialog_restart_title">提示</string>
|
||||
<string name="dispatch_dialog_restart_content">当前车辆已退出自动驾驶,请点击下方按钮恢复</string>
|
||||
<string name="dispatch_dialog_restart_enter">进入自动驾驶</string>
|
||||
<string name="dispatch_cars_remind_content">车辆将开启自动驾驶,并行驶至:</string>
|
||||
<string name="dispatch_cars_affirm">确认</string>
|
||||
<string name="dispatch_cars_cancel">取消</string>
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
package com.mogo.eagle.core.function.business.ai.net
|
||||
|
||||
import com.mogo.cloud.passport.MoGoAiCloudClientConfig
|
||||
import com.mogo.commons.constants.HostConst.getEagleHost
|
||||
import com.mogo.commons.debug.DebugConfig
|
||||
import com.mogo.eagle.core.data.BaseResponse
|
||||
import com.mogo.eagle.core.function.business.ai.AiCloudIdentifyDataManager.Companion.END_METRE
|
||||
@@ -17,17 +18,7 @@ class AiCloudIdentifyNetWorkModel private constructor(){
|
||||
}
|
||||
}
|
||||
|
||||
private fun getHost(): String {
|
||||
var host = "http://dzt-city.zhidaozhixing.com"
|
||||
when (DebugConfig.getNetMode()) {
|
||||
DebugConfig.NET_MODE_DEV,
|
||||
DebugConfig.NET_MODE_QA -> host = "http://dzt-qa-city.zhidaozhixing.com"
|
||||
// DebugConfig.NET_MODE_QA -> host = "http://dzt-test.zhidaozhixing.com"
|
||||
}
|
||||
return host
|
||||
}
|
||||
|
||||
private fun getNetWorkApi(baseUrl: String = getHost()): IAiCloudIdentifyApiService {
|
||||
private fun getNetWorkApi(baseUrl: String = getEagleHost()): IAiCloudIdentifyApiService {
|
||||
return MoGoRetrofitFactory.getInstanceNoCallAdapter(baseUrl)
|
||||
.create(IAiCloudIdentifyApiService::class.java)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user