From 5be319a2ddaebc288077f75c741e74d91dc1ed27 Mon Sep 17 00:00:00 2001
From: "SmallChi(Koike)" <564952747@qq.com>
Date: Thu, 30 Sep 2021 14:41:35 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=94=AF=E6=8C=81808?=
 =?UTF-8?q?=E7=A7=81=E6=9C=89=E5=8D=8F=E8=AE=AE=E6=89=A9=E5=B1=95=E5=BA=93?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/JTTools/Pages/Index.razor        |  1 +
 src/JTTools/Pages/JT808Analyze.razor | 78 +++++++++++++++++++++++++++-
 2 files changed, 78 insertions(+), 1 deletion(-)

diff --git a/src/JTTools/Pages/Index.razor b/src/JTTools/Pages/Index.razor
index c164729..14b686e 100644
--- a/src/JTTools/Pages/Index.razor
+++ b/src/JTTools/Pages/Index.razor
@@ -14,6 +14,7 @@
         <li>支持808（粤标）分析工具</li>
         <li>支持808的2011版本分析工具</li>
         <li>支持808多包解析</li>
+        <li>支持808私有协议扩展库</li>
     </ul>
 </Paragraph>
 <style>
diff --git a/src/JTTools/Pages/JT808Analyze.razor b/src/JTTools/Pages/JT808Analyze.razor
index eda6238..01ace0e 100644
--- a/src/JTTools/Pages/JT808Analyze.razor
+++ b/src/JTTools/Pages/JT808Analyze.razor
@@ -4,9 +4,12 @@
 @using JT808.Protocol.Extensions;
 @using JT808.Protocol.Exceptions;
 @using JTTools.Configs;
+@using System.IO;
+@using System.Reflection;
 @using System.Text;
 @using System.Text.Encodings.Web;
 @using System.Text.Unicode;
+@using JT808.Protocol.Interfaces;
 @inject IJT808Config  config
 @inject JT808_JT1078_Config  jT808_JT1078_Config
 @inject JT808_SuBiao_Config  jT808_SuBiao_Config
@@ -15,7 +18,7 @@
 
 <Space Direction="DirectionVHType.Vertical" Style="width:100%">
     <SpaceItem>
-        <Alert Type="@AlertType.Warning" ShowIcon="true" Closable Message="小技巧" Description="如有分包或多包，请换行(回车)区分。"/>
+        <Alert Type="@AlertType.Warning" ShowIcon="true" Closable Message="小技巧" Description="如有分包或多包，请换行(回车)区分。" />
     </SpaceItem>
     <SpaceItem>
         <Select TItemValue="string" TItem="string" DefaultValue="@("JT808")" @bind-Value="@protocolType" OnSelectedItemChanged="OnSelectProtocolType">
@@ -26,9 +29,25 @@
                 <SelectOption TItemValue="string" TItem="string" Label="国标扩展主动安全(粤标)" Value="@("JT808_YueBiao")" />
                 <SelectOption TItemValue="string" TItem="string" Label="公交扩展协议(锐明)" Value="@("JT808_JTRM")" />
                 <SelectOption TItemValue="string" TItem="string" Label="国标(强制使用2013版本解析)" Value="@("JT2013Force")" />
+                <SelectOption TItemValue="string" TItem="string" Label="国标扩展私有协议" Value="@("JTPrivate")" />
             </SelectOptions>
         </Select>
     </SpaceItem>
+    @if (protocolType == "JTPrivate")
+    {
+        <SpaceItem>
+            <Alert Type="@AlertType.Info" ShowIcon="true" Message="前置条件">
+                <div>1.必须通过【https://github.com/SmallChi/JT808】实现的扩展库才可以支持</div>
+                <div>2.上传的文件只在浏览器本地，服务器不会收集任何私有协议库</div>
+            </Alert>
+        </SpaceItem>
+        <InputFile OnChange="@LoadFiles" />
+        @*目前组件不支持 <Upload Name="files" Action="" OnSingleCompleted="OnJTPrivateSingleCompleted">
+                <Button Icon="upload">
+                    <span>上传私有协议库(.dll)</span>
+                </Button>
+            </Upload>*@
+    }
     <SpaceItem>
         <TextArea AllowClear="true" Rows="4" @bind-Value="@HexData" OnPressEnter="OnAreaTextPressEnter" />
     </SpaceItem>
@@ -103,12 +122,16 @@
 
     private JT808Serializer JT1078Serializer;
 
+    private JT808Serializer JTPrivateSerializer;
+
     string protocolType = "JT808";
 
     private List<JT808HeaderPackage> JT808HeaderPackages;
 
     private List<JT808PackageInfo> JT808Packages;
 
+    private IJT808Config JT808PrivateConfig;
+
     private string HexData = HexDataTmp;
 
     private static string HexDataTmp = "7E 02 00 00 26 12 34 56 78 90 12 00 7D 02 00 00 00 01 00 00 00 02 00 BA 7F 0E 07 E4 F1 1C 00 28 00 3C 00 00 18 10 15 10 10 10 01 04 00 00 00 64 02 02 00 7D 01 13 7E";
@@ -148,16 +171,52 @@
         HexData += "\n";
     }
 
+    private async void LoadFiles(InputFileChangeEventArgs e)
+    {
+        try
+        {
+            using var memoryStream = new MemoryStream();
+            Stream fs = e.File.OpenReadStream();
+            await fs.CopyToAsync(memoryStream);
+            Assembly assembly = Assembly.Load(memoryStream.ToArray());
+            JT808PrivateConfig.Register(assembly);
+            JTPrivateSerializer = new JT808Serializer(JT808PrivateConfig);
+        }
+        catch (Exception ex)
+        {
+            ErrerMessage = ex.StackTrace;
+        }
+    }
+
     protected override void OnInitialized()
     {
         Serializer = config.GetSerializer();
         JT1078Serializer = jT808_JT1078_Config.GetSerializer();
         JTSuBiao_Serializer = jT808_SuBiao_Config.GetSerializer();
         JTRM_Serializer = jT808_Streamax_Config.GetSerializer();
+        JT808PrivateConfig = new LocalLodingConfig();
     }
 
     string Json = "";
 
+    //暂不支持
+    //private void OnJTPrivateSingleCompleted(AntDesign.UploadInfo uploadInfo)
+    //{
+    //    try
+    //    {
+    //        byte[] fs = File.ReadAllBytes(uploadInfo.File.ObjectURL);
+    //        if (uploadInfo.FileList.Count > 1)
+    //        {
+    //            uploadInfo.FileList.RemoveAt(0);
+    //        }
+    //    }
+    //    catch (Exception ex)
+    //    {
+
+    //    }
+
+    //}
+
     private void Query()
     {
         try
@@ -201,6 +260,12 @@
                             case "JT2013Force":
                                 JT808Packages.Add(new JT808PackageInfo { Order = i, Json = Serializer.Analyze(data, JT808.Protocol.Enums.JT808Version.JTT2013Force, options: JTJsonWriterOptions.Instance) });
                                 break;
+                            case "JTPrivate":
+                                if (JTPrivateSerializer != null)
+                                {
+                                    JT808Packages.Add(new JT808PackageInfo { Order = i, Json = JTPrivateSerializer.Analyze(data, options: JTJsonWriterOptions.Instance) });
+                                }
+                                break;
                         }
                     }
                 }
@@ -233,6 +298,12 @@
                             case "JT2013Force":
                                 Json = Serializer.Analyze(msgid, bodies.ToArray(), JT808.Protocol.Enums.JT808Version.JTT2013Force, options: JTJsonWriterOptions.Instance);
                                 break;
+                            case "JTPrivate":
+                                if (JTPrivateSerializer != null)
+                                {
+                                    Json = JTPrivateSerializer.Analyze(msgid, bodies.ToArray(), options: JTJsonWriterOptions.Instance);
+                                }
+                                break;
                         }
                     }
                     else
@@ -254,6 +325,11 @@
         }
     }
 
+    public class LocalLodingConfig : GlobalConfigBase
+    {
+        public override string ConfigId { get; protected set; } = "LocalConfig";
+    }
+
     public class JT808PackageInfo
     {
         public int Order { get; set; }