소스 검색

1.升级JT808库

2.由于808的消息类型可以扩展,所以修改业务消息不依赖于枚举
tags/v1.0.0
SmallChi 6 년 전
부모
커밋
a46ab7f649
2개의 변경된 파일19개의 추가작업 그리고 19개의 파일을 삭제
  1. +1
    -1
      src/JT808.DotNetty/JT808.DotNetty.csproj
  2. +18
    -18
      src/JT808.DotNetty/JT808MsgIdHandlerBase.cs

+ 1
- 1
src/JT808.DotNetty/JT808.DotNetty.csproj 파일 보기

@@ -9,7 +9,7 @@
<PackageReference Include="DotNetty.Codecs" Version="0.6.0" />
<PackageReference Include="DotNetty.Handlers" Version="0.6.0" />
<PackageReference Include="DotNetty.Transport.Libuv" Version="0.6.0" />
<PackageReference Include="JT808" Version="1.0.0" />
<PackageReference Include="JT808" Version="1.0.1" />
<PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="2.1.1" />
<PackageReference Include="Microsoft.Extensions.Hosting.Abstractions" Version="2.1.1" />
<PackageReference Include="Microsoft.Extensions.Options" Version="2.1.1" />


+ 18
- 18
src/JT808.DotNetty/JT808MsgIdHandlerBase.cs 파일 보기

@@ -26,21 +26,20 @@ namespace JT808.DotNetty
protected JT808MsgIdHandlerBase(JT808SessionManager sessionManager)
{
this.sessionManager = sessionManager;
HandlerDict = new Dictionary<JT808MsgId, Func<JT808Request, JT808Response>>
HandlerDict = new Dictionary<ushort, Func<JT808Request, JT808Response>>
{
{JT808MsgId.终端通用应答, Msg0x0001},
{JT808MsgId.终端鉴权, Msg0x0102},
{JT808MsgId.终端心跳, Msg0x0002},
{JT808MsgId.终端注销, Msg0x0003},
{JT808MsgId.终端注册, Msg0x0100},
{JT808MsgId.位置信息汇报,Msg0x0200 },
{JT808MsgId.定位数据批量上传,Msg0x0704 },
{JT808MsgId.数据上行透传,Msg0x0900 }
{JT808MsgId.终端通用应答.ToUInt16Value(), Msg0x0001},
{JT808MsgId.终端鉴权.ToUInt16Value(), Msg0x0102},
{JT808MsgId.终端心跳.ToUInt16Value(), Msg0x0002},
{JT808MsgId.终端注销.ToUInt16Value(), Msg0x0003},
{JT808MsgId.终端注册.ToUInt16Value(), Msg0x0100},
{JT808MsgId.位置信息汇报.ToUInt16Value(),Msg0x0200 },
{JT808MsgId.定位数据批量上传.ToUInt16Value(),Msg0x0704 },
{JT808MsgId.数据上行透传.ToUInt16Value(),Msg0x0900 }
};

}

public Dictionary<JT808MsgId, Func<JT808Request, JT808Response>> HandlerDict { get; }
public Dictionary<ushort, Func<JT808Request, JT808Response>> HandlerDict { get; protected set; }
/// <summary>
/// 终端通用应答
/// </summary>
@@ -51,7 +50,7 @@ namespace JT808.DotNetty
{
return new JT808Response(JT808MsgId.平台通用应答.Create(request.Package.Header.TerminalPhoneNo, new JT808_0x8001()
{
MsgId = request.Package.Header.MsgId,
MsgId = (JT808MsgId)request.Package.Header.MsgId,
JT808PlatformResult = JT808PlatformResult.Success,
MsgNum = request.Package.Header.MsgNum
}));
@@ -67,7 +66,7 @@ namespace JT808.DotNetty
sessionManager.Heartbeat(request.Package.Header.TerminalPhoneNo);
return new JT808Response(JT808MsgId.平台通用应答.Create(request.Package.Header.TerminalPhoneNo, new JT808_0x8001()
{
MsgId = request.Package.Header.MsgId,
MsgId = (JT808MsgId)request.Package.Header.MsgId,
JT808PlatformResult = JT808PlatformResult.Success,
MsgNum = request.Package.Header.MsgNum
}));
@@ -80,9 +79,10 @@ namespace JT808.DotNetty
/// <returns></returns>
public virtual JT808Response Msg0x0003(JT808Request request)
{
# warning JT808MsgId
return new JT808Response(JT808MsgId.平台通用应答.Create(request.Package.Header.TerminalPhoneNo, new JT808_0x8001()
{
MsgId = request.Package.Header.MsgId,
MsgId = (JT808MsgId)request.Package.Header.MsgId,
JT808PlatformResult = JT808PlatformResult.Success,
MsgNum = request.Package.Header.MsgNum
}));
@@ -112,7 +112,7 @@ namespace JT808.DotNetty
{
return new JT808Response(JT808MsgId.平台通用应答.Create(request.Package.Header.TerminalPhoneNo, new JT808_0x8001()
{
MsgId = request.Package.Header.MsgId,
MsgId = (JT808MsgId)request.Package.Header.MsgId,
JT808PlatformResult = JT808PlatformResult.Success,
MsgNum = request.Package.Header.MsgNum
}));
@@ -127,7 +127,7 @@ namespace JT808.DotNetty
{
return new JT808Response(JT808MsgId.平台通用应答.Create(request.Package.Header.TerminalPhoneNo, new JT808_0x8001()
{
MsgId = request.Package.Header.MsgId,
MsgId = (JT808MsgId)request.Package.Header.MsgId,
JT808PlatformResult = JT808PlatformResult.Success,
MsgNum = request.Package.Header.MsgNum
}));
@@ -142,7 +142,7 @@ namespace JT808.DotNetty
{
return new JT808Response(JT808MsgId.平台通用应答.Create(request.Package.Header.TerminalPhoneNo, new JT808_0x8001()
{
MsgId = request.Package.Header.MsgId,
MsgId = (JT808MsgId)request.Package.Header.MsgId,
JT808PlatformResult = JT808PlatformResult.Success,
MsgNum = request.Package.Header.MsgNum
}));
@@ -157,7 +157,7 @@ namespace JT808.DotNetty
{
return new JT808Response(JT808MsgId.平台通用应答.Create(request.Package.Header.TerminalPhoneNo, new JT808_0x8001()
{
MsgId = request.Package.Header.MsgId,
MsgId =(JT808MsgId) request.Package.Header.MsgId,
JT808PlatformResult = JT808PlatformResult.Success,
MsgNum = request.Package.Header.MsgNum
}));


불러오는 중...
취소
저장