style:整理星图模块代码
This commit is contained in:
parent
165f9dd080
commit
cd63c0924b
@ -10,9 +10,8 @@ import 'package:star_lock/talk/startChart/proto/generic.pb.dart';
|
|||||||
|
|
||||||
import '../../start_chart_manage.dart';
|
import '../../start_chart_manage.dart';
|
||||||
|
|
||||||
class UdpBlePassThroughHandler extends ScpMessageBaseHandle implements ScpMessageHandler {
|
class UdpBlePassThroughHandler extends ScpMessageBaseHandle
|
||||||
|
implements ScpMessageHandler {
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleReq(ScpMessage scpMessage) {
|
void handleReq(ScpMessage scpMessage) {
|
||||||
final BleResp bleResp = scpMessage.Payload;
|
final BleResp bleResp = scpMessage.Payload;
|
||||||
@ -25,12 +24,8 @@ class UdpBlePassThroughHandler extends ScpMessageBaseHandle implements ScpMessag
|
|||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleInvalidReq(ScpMessage scpMessage) {
|
void handleInvalidReq(ScpMessage scpMessage) {}
|
||||||
// TODO: implement handleInvalidReq
|
|
||||||
}
|
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleRealTimeData(ScpMessage scpMessage) {
|
void handleRealTimeData(ScpMessage scpMessage) {}
|
||||||
// TODO: implement handleRealTimeData
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -6,9 +6,8 @@ import 'package:star_lock/talk/startChart/handle/scp_message_handle.dart';
|
|||||||
|
|
||||||
import '../../start_chart_manage.dart';
|
import '../../start_chart_manage.dart';
|
||||||
|
|
||||||
class UdpEchoTestHandler extends ScpMessageBaseHandle implements ScpMessageHandler {
|
class UdpEchoTestHandler extends ScpMessageBaseHandle
|
||||||
|
implements ScpMessageHandler {
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleReq(ScpMessage scpMessage) {
|
void handleReq(ScpMessage scpMessage) {
|
||||||
// TODO: 收到回声测试请求
|
// TODO: 收到回声测试请求
|
||||||
@ -21,12 +20,8 @@ class UdpEchoTestHandler extends ScpMessageBaseHandle implements ScpMessageHandl
|
|||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleInvalidReq(ScpMessage scpMessage) {
|
void handleInvalidReq(ScpMessage scpMessage) {}
|
||||||
// TODO: implement handleInvalidReq
|
|
||||||
}
|
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleRealTimeData(ScpMessage scpMessage) {
|
void handleRealTimeData(ScpMessage scpMessage) {}
|
||||||
// TODO: implement handleRealTimeData
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -27,11 +27,11 @@ class UdpGateWayResetHandler extends ScpMessageBaseHandle implements ScpMessageH
|
|||||||
|
|
||||||
@override
|
@override
|
||||||
void handleInvalidReq(ScpMessage scpMessage) {
|
void handleInvalidReq(ScpMessage scpMessage) {
|
||||||
// TODO: implement handleInvalidReq
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleRealTimeData(ScpMessage scpMessage) {
|
void handleRealTimeData(ScpMessage scpMessage) {
|
||||||
// TODO: implement handleRealTimeData
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -10,8 +10,6 @@ import '../../start_chart_manage.dart';
|
|||||||
|
|
||||||
class UdpGateWayTransferHandler extends ScpMessageBaseHandle
|
class UdpGateWayTransferHandler extends ScpMessageBaseHandle
|
||||||
implements ScpMessageHandler {
|
implements ScpMessageHandler {
|
||||||
|
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleReq(ScpMessage scpMessage) {
|
void handleReq(ScpMessage scpMessage) {
|
||||||
// TODO: 收到网关转移请求
|
// TODO: 收到网关转移请求
|
||||||
@ -27,12 +25,8 @@ class UdpGateWayTransferHandler extends ScpMessageBaseHandle
|
|||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleInvalidReq(ScpMessage scpMessage) {
|
void handleInvalidReq(ScpMessage scpMessage) {}
|
||||||
// TODO: implement handleInvalidReq
|
|
||||||
}
|
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleRealTimeData(ScpMessage scpMessage) {
|
void handleRealTimeData(ScpMessage scpMessage) {}
|
||||||
// TODO: implement handleRealTimeData
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -31,12 +31,8 @@ class UdpGoOnlineHandler extends ScpMessageBaseHandle
|
|||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleInvalidReq(ScpMessage scpMessage) {
|
void handleInvalidReq(ScpMessage scpMessage) {}
|
||||||
// TODO: implement handleInvalidReq
|
|
||||||
}
|
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleRealTimeData(ScpMessage scpMessage) {
|
void handleRealTimeData(ScpMessage scpMessage) {}
|
||||||
// TODO: implement handleRealTimeData
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -7,9 +7,8 @@ import 'package:star_lock/talk/startChart/handle/scp_message_handle.dart';
|
|||||||
|
|
||||||
import '../../start_chart_manage.dart';
|
import '../../start_chart_manage.dart';
|
||||||
|
|
||||||
class UdpHeartBeatHandler extends ScpMessageBaseHandle implements ScpMessageHandler {
|
class UdpHeartBeatHandler extends ScpMessageBaseHandle
|
||||||
|
implements ScpMessageHandler {
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleReq(ScpMessage scpMessage) {
|
void handleReq(ScpMessage scpMessage) {
|
||||||
// TODO: 收到心跳消息请求
|
// TODO: 收到心跳消息请求
|
||||||
@ -32,12 +31,8 @@ class UdpHeartBeatHandler extends ScpMessageBaseHandle implements ScpMessageHand
|
|||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleInvalidReq(ScpMessage scpMessage) {
|
void handleInvalidReq(ScpMessage scpMessage) {}
|
||||||
// TODO: implement handleInvalidReq
|
|
||||||
}
|
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleRealTimeData(ScpMessage scpMessage) {
|
void handleRealTimeData(ScpMessage scpMessage) {}
|
||||||
// TODO: implement handleRealTimeData
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -25,11 +25,11 @@ class UdpRemoteUnLockHandler extends ScpMessageBaseHandle implements ScpMessageH
|
|||||||
|
|
||||||
@override
|
@override
|
||||||
void handleInvalidReq(ScpMessage scpMessage) {
|
void handleInvalidReq(ScpMessage scpMessage) {
|
||||||
// TODO: implement handleInvalidReq
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleRealTimeData(ScpMessage scpMessage) {
|
void handleRealTimeData(ScpMessage scpMessage) {
|
||||||
// TODO: implement handleRealTimeData
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -42,12 +42,12 @@ class UdpTalkAcceptHandler extends ScpMessageBaseHandle
|
|||||||
|
|
||||||
@override
|
@override
|
||||||
void handleInvalidReq(ScpMessage scpMessage) {
|
void handleInvalidReq(ScpMessage scpMessage) {
|
||||||
// TODO: implement handleInvalidReq
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleRealTimeData(ScpMessage scpMessage) {
|
void handleRealTimeData(ScpMessage scpMessage) {
|
||||||
// TODO: implement handleRealTimeData
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// 启动通话保持
|
// 启动通话保持
|
||||||
@ -63,6 +63,7 @@ class UdpTalkAcceptHandler extends ScpMessageBaseHandle
|
|||||||
startChartManage.stopTalkPingMessageTimer();
|
startChartManage.stopTalkPingMessageTimer();
|
||||||
startChartManage.stopTalkExpectMessageTimer();
|
startChartManage.stopTalkExpectMessageTimer();
|
||||||
talkStatus.setNotTalkPing();
|
talkStatus.setNotTalkPing();
|
||||||
|
talkStatus.setEnd();
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -76,6 +77,7 @@ class UdpTalkAcceptHandler extends ScpMessageBaseHandle
|
|||||||
startChartManage.stopTalkPingMessageTimer();
|
startChartManage.stopTalkPingMessageTimer();
|
||||||
startChartManage.stopTalkExpectMessageTimer();
|
startChartManage.stopTalkExpectMessageTimer();
|
||||||
talkStatus.setNotTalkData();
|
talkStatus.setNotTalkData();
|
||||||
|
talkStatus.setEnd();
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -29,11 +29,11 @@ class UdpTalkExpectHandler extends ScpMessageBaseHandle
|
|||||||
|
|
||||||
@override
|
@override
|
||||||
void handleInvalidReq(ScpMessage scpMessage) {
|
void handleInvalidReq(ScpMessage scpMessage) {
|
||||||
// TODO: implement handleInvalidReq
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleRealTimeData(ScpMessage scpMessage) {
|
void handleRealTimeData(ScpMessage scpMessage) {
|
||||||
// TODO: implement handleRealTimeData
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -38,11 +38,11 @@ class UdpTalkHangUpHandler extends ScpMessageBaseHandle
|
|||||||
|
|
||||||
@override
|
@override
|
||||||
void handleInvalidReq(ScpMessage scpMessage) {
|
void handleInvalidReq(ScpMessage scpMessage) {
|
||||||
// TODO: implement handleInvalidReq
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleRealTimeData(ScpMessage scpMessage) {
|
void handleRealTimeData(ScpMessage scpMessage) {
|
||||||
// TODO: implement handleRealTimeData
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -6,7 +6,6 @@ import 'package:star_lock/talk/startChart/proto/generic.pb.dart';
|
|||||||
|
|
||||||
class UdpTalkPingHandler extends ScpMessageBaseHandle
|
class UdpTalkPingHandler extends ScpMessageBaseHandle
|
||||||
implements ScpMessageHandler {
|
implements ScpMessageHandler {
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleReq(ScpMessage scpMessage) {
|
void handleReq(ScpMessage scpMessage) {
|
||||||
// TODO: 收到通话保持请求
|
// TODO: 收到通话保持请求
|
||||||
@ -19,17 +18,12 @@ class UdpTalkPingHandler extends ScpMessageBaseHandle
|
|||||||
if (checkGenericRespSuccess(genericResp)) {
|
if (checkGenericRespSuccess(genericResp)) {
|
||||||
// 收到消息,重新触发定时器
|
// 收到消息,重新触发定时器
|
||||||
talkePingOverTimeTimerManager.receiveMessage();
|
talkePingOverTimeTimerManager.receiveMessage();
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleInvalidReq(ScpMessage scpMessage) {
|
void handleInvalidReq(ScpMessage scpMessage) {}
|
||||||
// TODO: implement handleInvalidReq
|
|
||||||
}
|
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleRealTimeData(ScpMessage scpMessage) {
|
void handleRealTimeData(ScpMessage scpMessage) {}
|
||||||
// TODO: implement handleRealTimeData
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -10,7 +10,6 @@ import '../../start_chart_manage.dart';
|
|||||||
|
|
||||||
class UdpTalkPushHandler extends ScpMessageBaseHandle
|
class UdpTalkPushHandler extends ScpMessageBaseHandle
|
||||||
implements ScpMessageHandler {
|
implements ScpMessageHandler {
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleReq(ScpMessage scpMessage) {
|
void handleReq(ScpMessage scpMessage) {
|
||||||
// TODO: 收到委托推送请求
|
// TODO: 收到委托推送请求
|
||||||
@ -24,13 +23,8 @@ class UdpTalkPushHandler extends ScpMessageBaseHandle
|
|||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleInvalidReq(ScpMessage scpMessage) {
|
void handleInvalidReq(ScpMessage scpMessage) {}
|
||||||
// TODO: implement handleInvalidReq
|
|
||||||
}
|
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleRealTimeData(ScpMessage scpMessage
|
void handleRealTimeData(ScpMessage scpMessage) {}
|
||||||
) {
|
|
||||||
// TODO: implement handleRealTimeData
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -24,11 +24,11 @@ class UdpTalkReceiverTransferHandler extends ScpMessageBaseHandle
|
|||||||
|
|
||||||
@override
|
@override
|
||||||
void handleInvalidReq(ScpMessage scpMessage) {
|
void handleInvalidReq(ScpMessage scpMessage) {
|
||||||
// TODO: implement handleInvalidReq
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleRealTimeData(ScpMessage scpMessage) {
|
void handleRealTimeData(ScpMessage scpMessage) {
|
||||||
// TODO: implement handleRealTimeData
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -13,7 +13,6 @@ class UdpTalkRejectHandler extends ScpMessageBaseHandle
|
|||||||
@override
|
@override
|
||||||
void handleReq(ScpMessage scpMessage) {
|
void handleReq(ScpMessage scpMessage) {
|
||||||
// 收到接听拒绝请求
|
// 收到接听拒绝请求
|
||||||
print('收到接听拒绝请求');
|
|
||||||
startChartManage.sendGenericRespSuccessMessage(
|
startChartManage.sendGenericRespSuccessMessage(
|
||||||
ToPeerId: scpMessage.FromPeerId!,
|
ToPeerId: scpMessage.FromPeerId!,
|
||||||
FromPeerId: scpMessage.ToPeerId!,
|
FromPeerId: scpMessage.ToPeerId!,
|
||||||
@ -23,25 +22,26 @@ class UdpTalkRejectHandler extends ScpMessageBaseHandle
|
|||||||
startChartManage.stopTalkExpectMessageTimer();
|
startChartManage.stopTalkExpectMessageTimer();
|
||||||
talkStatus.setRejected();
|
talkStatus.setRejected();
|
||||||
stopRingtone();
|
stopRingtone();
|
||||||
|
talkStatus.setEnd();
|
||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleResp(ScpMessage scpMessage) {
|
void handleResp(ScpMessage scpMessage) {
|
||||||
print('收到接听拒绝回复');
|
|
||||||
// 收到接听拒绝回复
|
// 收到接听拒绝回复
|
||||||
talkStatus.setRejected();
|
talkStatus.setRejected();
|
||||||
startChartManage.stopTalkPingMessageTimer();
|
startChartManage.stopTalkPingMessageTimer();
|
||||||
startChartManage.stopTalkExpectMessageTimer();
|
startChartManage.stopTalkExpectMessageTimer();
|
||||||
stopRingtone();
|
stopRingtone();
|
||||||
|
talkStatus.setEnd();
|
||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleInvalidReq(ScpMessage scpMessage) {
|
void handleInvalidReq(ScpMessage scpMessage) {
|
||||||
// TODO: implement handleInvalidReq
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void handleRealTimeData(ScpMessage scpMessage) {
|
void handleRealTimeData(ScpMessage scpMessage) {
|
||||||
// TODO: implement handleRealTimeData
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -30,15 +30,6 @@ class UdpTalkRequestHandler extends ScpMessageBaseHandle
|
|||||||
// 处理收到接听请求后的事件
|
// 处理收到接听请求后的事件
|
||||||
_talkRequestEvent(talkObjectName: talkReq.callerName);
|
_talkRequestEvent(talkObjectName: talkReq.callerName);
|
||||||
|
|
||||||
// Future.delayed(Duration(seconds: 1), () {
|
|
||||||
// startChartManage.sendTalkAcceptMessage();
|
|
||||||
// // startChartManage.sendTalkRejectMessage();
|
|
||||||
// });
|
|
||||||
//
|
|
||||||
// Future.delayed(Duration(seconds: 5), () {
|
|
||||||
// startChartManage.sendTalkHangupMessage();
|
|
||||||
// // startChartManage.sendTalkRejectMessage();
|
|
||||||
// });
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
@ -46,7 +37,7 @@ class UdpTalkRequestHandler extends ScpMessageBaseHandle
|
|||||||
// 收到对讲请求回复
|
// 收到对讲请求回复
|
||||||
final GenericResp genericResp = scpMessage.Payload;
|
final GenericResp genericResp = scpMessage.Payload;
|
||||||
if (genericResp.code == 0) {
|
if (genericResp.code == 0) {
|
||||||
print('发送对讲成功');
|
print('发送对讲成功,已经收到对方的回复');
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -106,6 +106,6 @@ class StartChartTalkStatus {
|
|||||||
/// 设置状态为结束
|
/// 设置状态为结束
|
||||||
void setEnd() {
|
void setEnd() {
|
||||||
_setStatus(TalkStatus.end);
|
_setStatus(TalkStatus.end);
|
||||||
// 可以在这里添加特定于 "error" 状态的逻辑
|
// 可以在这里添加特定于 "end" 状态的逻辑
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user