yangyakun921/MoGoEagleEye
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[deqing]

Browse Source 
[站点介绍tts 添加]
This commit is contained in:
yangyakun
2024-08-07 15:48:30 +08:00
parent 85054bb8b8
commit e519886a58
15 changed files with 90 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
OCH/bus/driver/src/main/java/com/mogo/och/bus/bean/WriteOffPassenger.java
View File

@@ -11,4 +11,14 @@ public class WriteOffPassenger implements Serializable {
public String orderNo;
public int passengerSize;
public long writeOffTime;
@Override
public String toString() {
return "WriteOffPassenger{" +
"phone='" + phone + '\'' +
", orderNo='" + orderNo + '\'' +
", passengerSize=" + passengerSize +
", writeOffTime=" + writeOffTime +
'}';
}
}

9
OCH/bus/driver/src/main/java/com/mogo/och/bus/model/OrderModel.java
View File

@@ -47,6 +47,7 @@ import com.mogo.och.bus.util.BusTrajectoryManager;
import com.mogo.och.bus.util.BusVoiceManager;
import com.mogo.och.common.module.manager.autopilot.autopilot.OchAutoPilotManager;
import com.mogo.och.common.module.manager.autopilot.line.LineManager;
import com.mogo.och.common.module.manager.socket.cloud.IOchOnMessageListener;
import com.mogo.och.common.module.manager.socket.lan.ILanMessageListener;
import com.mogo.och.common.module.manager.socket.lan.LanSocketManager;
import com.mogo.och.common.module.manager.socket.lan.bean.AppConnectMsg;
@@ -278,8 +279,8 @@ public class OrderModel {
GsonUtils.toJson(data));
}
private final IMogoOnMessageListener<OCHOperationalMessage> mMogoOnMessageListener =
new IMogoOnMessageListener<OCHOperationalMessage>() {
private final IOchOnMessageListener<OCHOperationalMessage> mMogoOnMessageListener =
new IOchOnMessageListener<OCHOperationalMessage>() {
@Override
public Class<OCHOperationalMessage> target() {
return OCHOperationalMessage.class;
@@ -297,8 +298,8 @@ public class OrderModel {
}
};
private final IMogoOnMessageListener<WriteOffPassenger> mWriteOffPassengerOnMessageListener =
new IMogoOnMessageListener<WriteOffPassenger>() {
private final IOchOnMessageListener<WriteOffPassenger> mWriteOffPassengerOnMessageListener =
new IOchOnMessageListener<WriteOffPassenger>() {
@Override
public Class<WriteOffPassenger> target() {
return WriteOffPassenger.class;

11
OCH/charter/driver/src/main/java/com/magic/mogo/och/charter/model/DriverM1Model.kt
View File

@@ -52,6 +52,7 @@ import com.mogo.och.common.module.manager.device.LightAirconditionDoorStatusMana
import com.mogo.och.common.module.manager.logchainanalytic.OchChainLogManager
import com.mogo.och.common.module.manager.socket.cloud.AbnormalFactorsLoopManager.startLoopAbnormalFactors
import com.mogo.och.common.module.manager.socket.cloud.AbnormalFactorsLoopManager.stopLoopAbnormalFactors
import com.mogo.och.common.module.manager.socket.cloud.IOchOnMessageListener
import com.mogo.och.common.module.manager.socket.cloud.OCHSocketMessageManager
import com.mogo.och.common.module.manager.socket.cloud.OCHSocketMessageManager.pushAppOperationalMsgBox
import com.mogo.och.common.module.manager.socket.cloud.OCHSocketMessageManager.registerSocketMessageListener
@@ -251,7 +252,7 @@ class DriverM1Model {
}
private val mOnSystemMessageListener =
object : IMogoOnMessageListener<SystemMsg> {
object : IOchOnMessageListener<SystemMsg> {
override fun onMsgReceived(obj: SystemMsg) {
d(SceneConstant.M_CHARTER_D + TAG, "onMsgReceived = " + obj.context)
@@ -273,7 +274,7 @@ class DriverM1Model {
}
private val mOnDoorMessageListener =
object : IMogoOnMessageListener<OperateDoorMsg> {
object : IOchOnMessageListener<OperateDoorMsg> {
override fun onMsgReceived(obj: OperateDoorMsg) {
d(SceneConstant.M_CHARTER_D + TAG, "onMsgReceived = " + obj.message)
val doorStatus = LightAirconditionDoorStatusManager.doorStatus
@@ -290,7 +291,7 @@ class DriverM1Model {
}
private val mOnOrderClosedMessageListener =
object : IMogoOnMessageListener<OrderCloseMsg> {
object : IOchOnMessageListener<OrderCloseMsg> {
override fun onMsgReceived(obj: OrderCloseMsg) {
//订单结束
pushOperationalToMsgBox(DateTimeUtil.getCurrentTimeStamp(), obj.message
@@ -304,8 +305,8 @@ class DriverM1Model {
}
}
private val mWriteOffPassengerOnMessageListener: IMogoOnMessageListener<WriteOffPassenger> =
object : IMogoOnMessageListener<WriteOffPassenger> {
private val mWriteOffPassengerOnMessageListener =
object : IOchOnMessageListener<WriteOffPassenger> {
override fun target(): Class<WriteOffPassenger> {
return WriteOffPassenger::class.java
}

14
OCH/common/common/src/main/java/com/mogo/och/common/module/manager/socket/cloud/IOchOnMessageListener.java Normal file
View File

@@ -0,0 +1,14 @@
package com.mogo.och.common.module.manager.socket.cloud;
/**
* @author congtaowang
* @since 2019-12-31
* <p>
* 消息回调
*/
public interface IOchOnMessageListener< T > {
Class< T > target();
void onMsgReceived( T obj );
}

14
OCH/common/common/src/main/java/com/mogo/och/common/module/manager/socket/cloud/OCHSocketMessageManager.kt
View File

@@ -7,6 +7,7 @@ import com.mogo.eagle.core.data.msgbox.MsgBoxBean
import com.mogo.eagle.core.data.msgbox.MsgBoxType
import com.mogo.eagle.core.data.msgbox.OperationMsg
import com.mogo.eagle.core.function.call.msgbox.CallerMsgBoxManager
import com.mogo.och.common.module.manager.logchainanalytic.OchChainLogManager
/**
* 统一管理业务长链消息推送
@@ -22,9 +23,18 @@ object OCHSocketMessageManager {
const val OPERATION_ROAD_SIDE_TYPE: Int = 1 //靠边停车通知
fun <T> registerSocketMessageListener(msgType:Int,
mogoOnMessageListener :IMogoOnMessageListener<T>){
mogoOnMessageListener :IOchOnMessageListener<T>){
MogoAiCloudSocketManager.getInstance(AbsMogoApplication.getApp().applicationContext)
.registerOnMessageListener(msgType,mogoOnMessageListener)
.registerOnMessageListener(msgType,object :IMogoOnMessageListener<T>{
override fun target(): Class<T> {
return mogoOnMessageListener.target()
}
override fun onMsgReceived(obj: T) {
OchChainLogManager.writeChainLogLanSocket("收到服务端数据","obj:${obj}}","receive");
mogoOnMessageListener.onMsgReceived(obj)
}
})
}
fun releaseSocketMessageListener(msgType:Int){

5
OCH/offline/driver/src/main/java/com/mogo/och/offline/model/OrderModel.java
View File

@@ -23,6 +23,7 @@ import com.mogo.eagle.core.data.map.MogoLocation;
import com.mogo.eagle.core.utilcode.util.StringUtils;
import com.mogo.och.common.module.manager.autopilot.autopilot.OchAutoPilotManager;
import com.mogo.och.common.module.manager.distance.TrajectoryAndDistanceManager;
import com.mogo.och.common.module.manager.socket.cloud.IOchOnMessageListener;
import com.mogo.och.common.module.manager.socket.lan.LanSocketManager;
import com.mogo.och.common.module.manager.socket.lan.bean.BusinessType;
import com.mogo.och.common.module.voice.VoiceNotice;
@@ -206,8 +207,8 @@ public class OrderModel {
}
};
private final IMogoOnMessageListener<SystemMsg> mMogoOnMessageListener =
new IMogoOnMessageListener<SystemMsg>() {
private final IOchOnMessageListener<SystemMsg> mMogoOnMessageListener =
new IOchOnMessageListener<SystemMsg>() {
@Override
public Class<SystemMsg> target() {
return SystemMsg.class;

11
OCH/shuttle/driver/src/main/java/com/mogo/och/shuttle/bean/WriteOffPassenger.java
View File

@@ -12,4 +12,15 @@ public class WriteOffPassenger implements Serializable {
public String ticketName;
public int passengerSize;
public long writeOffTime;
@Override
public String toString() {
return "WriteOffPassenger{" +
"phone='" + phone + '\'' +
", orderNo='" + orderNo + '\'' +
", ticketName='" + ticketName + '\'' +
", passengerSize=" + passengerSize +
", writeOffTime=" + writeOffTime +
'}';
}
}

5
OCH/shuttle/driver/src/main/java/com/mogo/och/shuttle/model/OrderModel.java
View File

@@ -27,6 +27,7 @@ import com.mogo.och.common.module.manager.autopilot.autopilot.OchAutoPilotManage
import com.mogo.och.common.module.manager.autopilot.location.OchLocationManager;
import com.mogo.och.common.module.manager.autopilot.line.LineManager;
import com.mogo.och.common.module.manager.distance.TrajectoryAndDistanceManager;
import com.mogo.och.common.module.manager.socket.cloud.IOchOnMessageListener;
import com.mogo.och.common.module.manager.socket.lan.LanSocketManager;
import com.mogo.och.common.module.manager.socket.lan.bean.BusinessType;
import com.mogo.och.common.module.voice.VoiceNotice;
@@ -215,8 +216,8 @@ public class OrderModel {
}
};
private final IMogoOnMessageListener<SystemMsg> mMogoOnMessageListener =
new IMogoOnMessageListener<SystemMsg>() {
private final IOchOnMessageListener<SystemMsg> mMogoOnMessageListener =
new IOchOnMessageListener<SystemMsg>() {
@Override
public Class<SystemMsg> target() {
return SystemMsg.class;

3
OCH/shuttle/driver/src/main/java/com/mogo/och/shuttle/model/TicketModel.kt
View File

@@ -27,12 +27,13 @@ import com.mogo.och.common.module.constant.OchCommonConst
import com.mogo.och.common.module.network.OchCommonServiceCallback
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
import io.reactivex.Observable
import io.reactivex.ObservableEmitter
import io.reactivex.ObservableOnSubscribe
import io.reactivex.schedulers.Schedulers
object TicketModel : IReceivedMsgListener, IMogoOnMessageListener<WriteOffPassenger> {
object TicketModel : IReceivedMsgListener, IOchOnMessageListener<WriteOffPassenger> {
private val TAG = "TicketModel"

11
OCH/shuttle_weaknet/driver/src/main/java/com/mogo/och/shuttle/bean/WriteOffPassenger.java
View File

@@ -12,4 +12,15 @@ public class WriteOffPassenger implements Serializable {
public String ticketName;
public int passengerSize;
public long writeOffTime;
@Override
public String toString() {
return "WriteOffPassenger{" +
"phone='" + phone + '\'' +
", orderNo='" + orderNo + '\'' +
", ticketName='" + ticketName + '\'' +
", passengerSize=" + passengerSize +
", writeOffTime=" + writeOffTime +
'}';
}
}

5
OCH/shuttle_weaknet/driver/src/main/java/com/mogo/och/shuttle/model/OrderModel.java
View File

@@ -27,6 +27,7 @@ import com.mogo.och.common.module.manager.autopilot.autopilot.OchAutoPilotManage
import com.mogo.och.common.module.manager.autopilot.location.OchLocationManager;
import com.mogo.och.common.module.manager.autopilot.line.LineManager;
import com.mogo.och.common.module.manager.distance.TrajectoryAndDistanceManager;
import com.mogo.och.common.module.manager.socket.cloud.IOchOnMessageListener;
import com.mogo.och.common.module.manager.socket.lan.LanSocketManager;
import com.mogo.och.common.module.manager.socket.lan.bean.BusinessType;
import com.mogo.och.common.module.voice.VoiceNotice;
@@ -215,8 +216,8 @@ public class OrderModel {
}
};
private final IMogoOnMessageListener<SystemMsg> mMogoOnMessageListener =
new IMogoOnMessageListener<SystemMsg>() {
private final IOchOnMessageListener<SystemMsg> mMogoOnMessageListener =
new IOchOnMessageListener<SystemMsg>() {
@Override
public Class<SystemMsg> target() {
return SystemMsg.class;

3
OCH/shuttle_weaknet/driver/src/main/java/com/mogo/och/shuttle/model/TicketModel.kt
View File

@@ -27,12 +27,13 @@ import com.mogo.och.common.module.constant.OchCommonConst
import com.mogo.och.common.module.network.OchCommonServiceCallback
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
import io.reactivex.Observable
import io.reactivex.ObservableEmitter
import io.reactivex.ObservableOnSubscribe
import io.reactivex.schedulers.Schedulers
object TicketModel : IReceivedMsgListener, IMogoOnMessageListener<WriteOffPassenger> {
object TicketModel : IReceivedMsgListener, IOchOnMessageListener<WriteOffPassenger> {
private val TAG = "TicketModel"

5
OCH/sweeper/driver/src/main/java/com/mogo/och/sweeper/operate/model/SweeperOperateTaskModel.java
View File

@@ -35,6 +35,7 @@ import com.mogo.eagle.core.utilcode.util.NetworkUtils;
import com.mogo.eagle.core.utilcode.util.ToastUtils;
import com.mogo.och.common.module.manager.autopilot.autopilot.OchAutoPilotManager;
import com.mogo.och.common.module.manager.autopilot.location.OchLocationManager;
import com.mogo.och.common.module.manager.socket.cloud.IOchOnMessageListener;
import com.mogo.och.common.module.manager.socket.cloud.OCHSocketMessageManager;
import com.mogo.och.common.module.manager.socket.cloud.data.OCHOperationalMessage;
import com.mogo.och.common.module.network.OchCommonServiceCallback;
@@ -266,8 +267,8 @@ public class SweeperOperateTaskModel {
return sInstance;
}
private final IMogoOnMessageListener<OCHOperationalMessage> mMogoOnMessageListener =
new IMogoOnMessageListener<OCHOperationalMessage>() {
private final IOchOnMessageListener<OCHOperationalMessage> mMogoOnMessageListener =
new IOchOnMessageListener<OCHOperationalMessage>() {
@Override
public Class<OCHOperationalMessage> target() {
return OCHOperationalMessage.class;

5
OCH/taxi/driver/src/main/java/com/mogo/och/taxi/model/TaxiModel.java
View File

@@ -44,6 +44,7 @@ import com.mogo.och.common.module.manager.autopilot.autopilot.OchAutoPilotManage
import com.mogo.och.common.module.manager.autopilot.autopilot.OchAutoPilotStatusListenerManager;
import com.mogo.och.common.module.manager.autopilot.location.OchLocationManager;
import com.mogo.och.common.module.manager.autopilot.line.LineManager;
import com.mogo.och.common.module.manager.socket.cloud.IOchOnMessageListener;
import com.mogo.och.common.module.manager.socket.cloud.OCHSocketMessageManager;
import com.mogo.och.common.module.manager.socket.cloud.data.OCHOperationalMessage;
import com.mogo.och.common.module.biz.login.LoginStatusManager;
@@ -234,8 +235,8 @@ public class TaxiModel {
}
private final IMogoOnMessageListener<OCHOperationalMessage> mMogoOnMessageListener =
new IMogoOnMessageListener<OCHOperationalMessage>() {
private final IOchOnMessageListener<OCHOperationalMessage> mMogoOnMessageListener =
new IOchOnMessageListener<OCHOperationalMessage>() {
@Override
public Class<OCHOperationalMessage> target() {
return OCHOperationalMessage.class;

3
OCH/taxi/unmanned-driver/src/main/java/com/mogo/och/unmanned/taxi/ui/task/TaxiTaskModel.kt
View File

@@ -51,6 +51,7 @@ import com.mogo.och.common.module.manager.distance.IDistanceListener
import com.mogo.och.common.module.manager.distance.ITrajectoryListener
import com.mogo.och.common.module.manager.distance.TrajectoryAndDistanceManager
import com.mogo.och.common.module.manager.socket.cloud.AbnormalFactorsLoopManager
import com.mogo.och.common.module.manager.socket.cloud.IOchOnMessageListener
import com.mogo.och.common.module.manager.socket.cloud.OCHSocketMessageManager
import com.mogo.och.common.module.manager.socket.cloud.data.OCHOperationalMessage
import com.mogo.och.common.module.map.AmapNaviToDestinationModel
@@ -492,7 +493,7 @@ object TaxiTaskModel {
}
private val mMogoOnSocketMessageListener =
object : IMogoOnMessageListener<OCHOperationalMessage> {
object : IOchOnMessageListener<OCHOperationalMessage> {
override fun target(): Class<OCHOperationalMessage> {
return OCHOperationalMessage::class.java
}