SmallChi
/
JT808
kopia lustrzana https://github.com/SmallChi/JT808.git
1
0
Forkuj 0
Kod Zgłoszenia 0 Wydania 53 Wiki Aktywność
Nie możesz wybrać więcej, niż 25 tematów Tematy muszą się zaczynać od litery lub cyfry, mogą zawierać myślniki ('-') i mogą mieć do 35 znaków.
104 Commity
1 Gałąź
97 MiB
 
Drzewo: c9225508b3
Gałęzie Tagi
${ item.name }
Utwórz gałąź ${ searchTerm }
z 'c9225508b3'
${ noResults }
JT808/src/JT808.Protocol/MessageBody/JT808_0x0200.cs

419 wiersze
21 KiB
Czysty Wina Historia 

  1. using JT808.Protocol.Enums;

  2. using JT808.Protocol.Exceptions;

  3. using JT808.Protocol.Extensions;

  4. using JT808.Protocol.Formatters;

  5. using JT808.Protocol.Interfaces;

  6. using JT808.Protocol.MessagePack;

  7. using System;

  8. using System.Collections.Generic;

  9. using System.Linq;

  10. using System.Text.Json;

  11. 

  12. namespace JT808.Protocol.MessageBody

  13. {

  14.     /// <summary>

  15.     /// 位置信息汇报

  16.     /// </summary>

  17.     public class JT808_0x0200 : JT808Bodies, IJT808MessagePackFormatter<JT808_0x0200>, IJT808Analyze

  18.     {

  19.         /// <summary>

  20.         /// 0x0200

  21.         /// </summary>

  22.         public override ushort MsgId { get; } = 0x0200;

  23.         /// <summary>

  24.         /// 位置信息汇报

  25.         /// </summary>

  26.         public override string Description => "位置信息汇报";

  27.         /// <summary>

  28.         /// 报警标志 

  29.         /// <see cref="JT808.Protocol.Enums.JT808Alarm"/>

  30.         /// </summary>

  31.         public uint AlarmFlag { get; set; }

  32.         /// <summary>

  33.         /// 状态位标志

  34.         /// <see cref="JT808.Protocol.Enums.JT808Status"/>

  35.         /// </summary>

  36.         public uint StatusFlag { get; set; }

  37.         /// <summary>

  38.         /// 纬度

  39.         /// 以度为单位的纬度值乘以 10 的 6 次方，精确到百万分之一度

  40.         /// </summary>

  41.         public int Lat { get; set; }

  42.         /// <summary>

  43.         /// 经度

  44.         /// 以度为单位的经度值乘以 10 的 6 次方，精确到百万分之一度

  45.         /// </summary>

  46.         public int Lng { get; set; }

  47.         /// <summary>

  48.         /// 高程

  49.         /// 海拔高度，单位为米（m）

  50.         /// </summary>

  51.         public ushort Altitude { get; set; }

  52.         /// <summary>

  53.         /// 速度 1/10km/h

  54.         /// </summary>

  55.         public ushort Speed { get; set; }

  56.         /// <summary>

  57.         /// 方向 0-359，正北为 0，顺时针

  58.         /// </summary>

  59.         public ushort Direction { get; set; }

  60.         /// <summary>

  61.         /// YY-MM-DD-hh-mm-ss（GMT+8 时间，本标准中之后涉及的时间均采用此时区）

  62.         /// </summary>

  63.         public DateTime GPSTime { get; set; }

  64.         /// <summary>

  65.         /// 位置附加信息

  66.         /// </summary>

  67.         public Dictionary<byte, JT808_0x0200_BodyBase> JT808LocationAttachData { get; set; }

  68.         /// <summary>

  69.         /// 存储未知的附加信息源数据

  70.         /// </summary>

  71.         public Dictionary<byte, byte[]> JT808UnknownLocationAttachOriginalData { get; set; }

  72.         /// <summary>

  73.         /// 自定义位置附加信息

  74.         /// 场景：

  75.         /// 一个设备厂商对应多个设备类型，不同设备类型可能存在相同的自定义位置附加信息Id，导致自定义附加信息Id冲突，无法解析。

  76.         /// 解决方式：

  77.         /// 1.凡是解析自定义附加信息Id协议的，先进行分割存储，然后在根据外部的设备类型进行统一处理。

  78.         /// 2.可以根据设备类型做个工厂，解耦对公共序列化器的依赖。

  79.         /// 缺点：

  80.         /// 依赖平台录入的设备类型

  81.         /// </summary>

  82.         public Dictionary<byte, JT808_0x0200_CustomBodyBase> JT808CustomLocationAttachData { get; set; }

  83.         /// <summary>

  84.         /// 

  85.         /// </summary>

  86.         /// <param name="reader"></param>

  87.         /// <param name="config"></param>

  88.         /// <returns></returns>

  89.         public JT808_0x0200 Deserialize(ref JT808MessagePackReader reader, IJT808Config config)

  90.         {

  91.             JT808_0x0200 jT808_0X0200 = new JT808_0x0200();

  92.             jT808_0X0200.AlarmFlag = reader.ReadUInt32();

  93.             jT808_0X0200.StatusFlag = reader.ReadUInt32();

  94.             if (((jT808_0X0200.StatusFlag >> 28) & 1) == 1)

  95.             {   //南纬 268435456 0x10000000

  96.                 jT808_0X0200.Lat = (int)reader.ReadUInt32();

  97.             }

  98.             else

  99.             {

  100.                 jT808_0X0200.Lat = reader.ReadInt32();

  101.             }

  102.             if (((jT808_0X0200.StatusFlag >> 27) & 1) == 1)

  103.             {   //西经 ‭134217728‬ 0x8000000

  104.                 jT808_0X0200.Lng = (int)reader.ReadUInt32();

  105.             }

  106.             else

  107.             {

  108.                 jT808_0X0200.Lng = reader.ReadInt32();

  109.             }

  110.             jT808_0X0200.Altitude = reader.ReadUInt16();

  111.             jT808_0X0200.Speed = reader.ReadUInt16();

  112.             jT808_0X0200.Direction = reader.ReadUInt16();

  113.             jT808_0X0200.GPSTime = reader.ReadDateTime6();

  114.             // 位置附加信息

  115.             jT808_0X0200.JT808LocationAttachData = new Dictionary<byte, JT808_0x0200_BodyBase>();

  116.             jT808_0X0200.JT808CustomLocationAttachData = new Dictionary<byte, JT808_0x0200_CustomBodyBase>();

  117.             jT808_0X0200.JT808UnknownLocationAttachOriginalData = new Dictionary<byte, byte[]>();

  118.             while (reader.ReadCurrentRemainContentLength() > 0)

  119.             {

  120.                 try

  121.                 {

  122.                     ReadOnlySpan<byte> attachSpan = reader.GetVirtualReadOnlySpan(2);

  123.                     byte attachId = attachSpan[0];

  124.                     byte attachLen = attachSpan[1];

  125.                     if (config.JT808_0X0200_Factory.Map.TryGetValue(attachId, out object jT808LocationAttachInstance))

  126.                     {

  127.                         dynamic attachImpl = JT808MessagePackFormatterResolverExtensions.JT808DynamicDeserialize(jT808LocationAttachInstance, ref reader, config);

  128.                         jT808_0X0200.JT808LocationAttachData.Add(attachImpl.AttachInfoId, attachImpl);

  129.                     }

  130.                     else if (config.JT808_0X0200_Custom_Factory.Map.TryGetValue(attachId,out object customAttachInstance))

  131.                     {

  132.                         dynamic attachImpl = JT808MessagePackFormatterResolverExtensions.JT808DynamicDeserialize(customAttachInstance, ref reader, config);

  133.                         jT808_0X0200.JT808CustomLocationAttachData.Add(attachImpl.AttachInfoId, attachImpl);

  134.                     }

  135.                     else

  136.                     {

  137.                         reader.Skip(2);

  138.                         jT808_0X0200.JT808UnknownLocationAttachOriginalData.Add(attachId, reader.ReadArray(reader.ReaderCount - 2, attachLen + 2).ToArray());

  139.                         reader.Skip(attachLen);

  140.                     }

  141.                 }

  142.                 catch

  143.                 {

  144.                     try

  145.                     {

  146.                         byte attachId = reader.ReadByte();

  147.                         byte attachLen = reader.ReadByte();

  148.                         jT808_0X0200.JT808UnknownLocationAttachOriginalData.Add(attachId, reader.ReadArray(reader.ReaderCount - 2, attachLen + 2).ToArray());

  149.                         reader.Skip(attachLen);

  150.                     }

  151.                     catch (Exception ex)

  152.                     {

  153.                         throw;

  154.                     }

  155.                 }

  156.             }

  157.             return jT808_0X0200;

  158.         }

  159.         /// <summary>

  160.         /// 

  161.         /// </summary>

  162.         /// <param name="writer"></param>

  163.         /// <param name="value"></param>

  164.         /// <param name="config"></param>

  165.         public void Serialize(ref JT808MessagePackWriter writer, JT808_0x0200 value, IJT808Config config)

  166.         {

  167.             writer.WriteUInt32(value.AlarmFlag);

  168.             writer.WriteUInt32(value.StatusFlag);

  169.             //0x10000000 南纬 134217728

  170.             //0x8000000  西经 ‭‬268435456

  171.             //0x18000000 南纬-西经 134217728+268435456

  172.             if (((value.StatusFlag >> 28) & 1) == 1)

  173.             {

  174.                 uint lat = (uint)value.Lat;

  175.                 writer.WriteUInt32(lat);

  176.             }

  177.             else

  178.             {

  179.                 if (value.Lat < 0)

  180.                 {

  181.                     throw new JT808Exception(JT808ErrorCode.LatOrLngError, $"Lat {nameof(JT808_0x0200.StatusFlag)} ({value.StatusFlag}>>28) !=1");

  182.                 }

  183.                 writer.WriteInt32(value.Lat);

  184.             }

  185.             if (((value.StatusFlag >> 27) & 1) == 1)

  186.             {

  187.                 uint lng = (uint)value.Lng;

  188.                 writer.WriteUInt32(lng);

  189.             }

  190.             else

  191.             {

  192.                 if (value.Lng < 0)

  193.                 {

  194.                     throw new JT808Exception(JT808ErrorCode.LatOrLngError, $"Lng {nameof(JT808_0x0200.StatusFlag)} ({value.StatusFlag}>>29) !=1");

  195.                 }

  196.                 writer.WriteInt32(value.Lng);

  197.             }

  198.             writer.WriteUInt16(value.Altitude);

  199.             writer.WriteUInt16(value.Speed);

  200.             writer.WriteUInt16(value.Direction);

  201.             writer.WriteDateTime6(value.GPSTime);

  202.             if (value.JT808LocationAttachData != null && value.JT808LocationAttachData.Count > 0)

  203.             {

  204.                 foreach (var item in value.JT808LocationAttachData)

  205.                 {

  206.                     try

  207.                     {

  208.                         JT808MessagePackFormatterResolverExtensions.JT808DynamicSerialize(item.Value, ref writer, item.Value, config);

  209.                     }

  210.                     catch(Exception ex)

  211.                     {

  212. 

  213.                     }

  214.                 }

  215.             }

  216.             if (value.JT808CustomLocationAttachData != null && value.JT808CustomLocationAttachData.Count > 0)

  217.             {

  218.                 foreach (var item in value.JT808CustomLocationAttachData)

  219.                 {

  220.                     JT808MessagePackFormatterResolverExtensions.JT808DynamicSerialize(item.Value, ref writer, item.Value, config);

  221.                 }

  222.             }

  223.         }

  224.         /// <summary>

  225.         /// 

  226.         /// </summary>

  227.         /// <param name="reader"></param>

  228.         /// <param name="writer"></param>

  229.         /// <param name="config"></param>

  230.         public void Analyze(ref JT808MessagePackReader reader, Utf8JsonWriter writer, IJT808Config config)

  231.         {

  232.             JT808_0x0200 value = new JT808_0x0200();

  233.             value.AlarmFlag = reader.ReadUInt32();

  234.             writer.WriteNumber($"[{value.AlarmFlag.ReadBinary().ToString()}]报警标志", value.AlarmFlag);

  235.             value.StatusFlag = reader.ReadUInt32();

  236.             var alarmFlagBits =Convert.ToString(value.AlarmFlag, 2).PadLeft(32, '0').AsSpan();

  237.             writer.WriteStartObject("报警标志对象");

  238.             if (reader.Version == JT808Version.JTT2019)

  239.             {

  240.                 writer.WriteString($"[bit31]保留", $"{alarmFlagBits[0]}");

  241.             }

  242.             else

  243.             {

  244.                 writer.WriteString($"[bit31]非法开门报警", $"{alarmFlagBits[0]}");

  245.             }

  246.             writer.WriteString($"[bit30]侧翻预警", $"{alarmFlagBits[1]}");

  247.             writer.WriteString($"[bit29]碰撞预警", $"{alarmFlagBits[2]}");

  248.             writer.WriteString($"[bit28]车辆非法位移", $"{alarmFlagBits[3]}");

  249.             writer.WriteString($"[bit27]车辆非法点火", $"{alarmFlagBits[4]}");

  250.             writer.WriteString($"[bit26]车辆被盗(通过车辆防盗器)", $"{alarmFlagBits[5]}");

  251.             writer.WriteString($"[bit25]车辆油量异常", $"{alarmFlagBits[6]}");

  252.             writer.WriteString($"[bit24]车辆VSS故障", $"{alarmFlagBits[7]}");

  253.             writer.WriteString($"[bit23]路线偏离报警", $"{alarmFlagBits[8]}");

  254.             writer.WriteString($"[bit22]路段行驶时间不足/过长", $"{alarmFlagBits[9]}");

  255.             writer.WriteString($"[bit21]进出路线", $"{alarmFlagBits[10]}");

  256.             writer.WriteString($"[bit20]进出区域", $"{alarmFlagBits[11]}");

  257.             writer.WriteString($"[bit19]超时停车", $"{alarmFlagBits[12]}");

  258.             writer.WriteString($"[bit18]当天累计驾驶超时", $"{alarmFlagBits[13]}");

  259.             if (reader.Version == JT808Version.JTT2019)

  260.             {

  261.                 writer.WriteString($"[bit17]右转盲区异常报警", $"{alarmFlagBits[14]}");

  262.                 writer.WriteString($"[bit16]胎压预警", $"{alarmFlagBits[15]}");

  263.                 writer.WriteString($"[bit15]违规行驶报警", $"{alarmFlagBits[16]}");

  264.             }

  265.             else

  266.             {

  267.                 writer.WriteString($"[bit15~bit17]保留", alarmFlagBits.Slice(14, 3).ToString());

  268.             }

  269.             writer.WriteString($"[bit14]疲劳驾驶预警", $"{alarmFlagBits[17]}");

  270.             writer.WriteString($"[bit13]超速预警", $"{alarmFlagBits[18]}");

  271.             writer.WriteString($"[bit12]道路运输证IC卡模块故障", $"{alarmFlagBits[19]}");

  272.             writer.WriteString($"[bit11]摄像头故障", $"{alarmFlagBits[20]}");

  273.             writer.WriteString($"[bit10]TTS模块故障", $"{alarmFlagBits[21]}");

  274.             writer.WriteString($"[bit9]终端LCD或显示器故障", $"{alarmFlagBits[22]}");

  275.             writer.WriteString($"[bit8]终端主电源掉电", $"{alarmFlagBits[23]}");

  276.             writer.WriteString($"[bit7]终端主电源欠压", $"{alarmFlagBits[24]}");

  277.             writer.WriteString($"[bit6]GNSS天线短路", $"{alarmFlagBits[25]}");

  278.             writer.WriteString($"[bit5]GNSS天线未接或被剪断", $"{alarmFlagBits[26]}");

  279.             writer.WriteString($"[bit4]GNSS模块发生故障", $"{alarmFlagBits[27]}");

  280.             writer.WriteString($"[bit3]危险预警", $"{alarmFlagBits[28]}");

  281.             writer.WriteString($"[bit2]疲劳驾驶", $"{alarmFlagBits[29]}");

  282.             writer.WriteString($"[bit1]超速报警", $"{alarmFlagBits[30]}");

  283.             writer.WriteString($"[bit0]紧急报警,触动报警开关后触发", $"{alarmFlagBits[31]}");

  284.             writer.WriteEndObject();

  285.             writer.WriteNumber($"[{value.StatusFlag.ReadBinary().ToString()}]状态位标志", value.StatusFlag);

  286.             var StatusFlagBits = Convert.ToString(value.StatusFlag, 2).PadLeft(32, '0').AsSpan();

  287.             writer.WriteStartObject("状态标志对象");

  288.             if (reader.Version == JT808Version.JTT2019)

  289.             {

  290.                 writer.WriteString($"[bit23~bit31]保留", StatusFlagBits.Slice(0, 9).ToString());

  291.                 writer.WriteString($"[{StatusFlagBits[9]}]bit22", StatusFlagBits[9] == '0' ? "车辆处于停止状态" : "车辆处于行驶状态");

  292.             }

  293.             else

  294.             {

  295.                 writer.WriteString($"[bit22~bit31]保留", StatusFlagBits.Slice(0, 10).ToString());

  296.             }

  297.             writer.WriteString($"[{StatusFlagBits[10]}]bit21", StatusFlagBits[10] == '0' ? "未使用Galileo卫星进行定位" : "使用Galileo卫星进行定位");

  298.             writer.WriteString($"[{StatusFlagBits[11]}]bit20", StatusFlagBits[11] == '0' ? "未使用GLONASS卫星进行定位" : "使用GLONASS卫星进行定位");

  299.             writer.WriteString($"[{StatusFlagBits[12]}]bit19", StatusFlagBits[12] == '0' ? "未使用北斗卫星进行定位" : "使用北斗卫星进行定位");

  300.             writer.WriteString($"[{StatusFlagBits[13]}]bit18", StatusFlagBits[13] == '0' ? "未使用GPS卫星进行定位" : "使用GPS卫星进行定位");

  301.             writer.WriteString($"[{StatusFlagBits[14]}]bit17", StatusFlagBits[14] == '0' ? "门5关" : "门5开");

  302.             writer.WriteString($"[{StatusFlagBits[15]}]bit16", StatusFlagBits[15] == '0' ? "门4关" : "门4开");

  303.             writer.WriteString($"[{StatusFlagBits[16]}]bit15", StatusFlagBits[16] == '0' ? "门3关" : "门3开");

  304.             writer.WriteString($"[{StatusFlagBits[17]}]bit14", StatusFlagBits[17] == '0' ? "门2关" : "门2开");

  305.             writer.WriteString($"[{StatusFlagBits[18]}]bit13", StatusFlagBits[18] == '0' ? "门1关" : "门1开");

  306.             writer.WriteString($"[{StatusFlagBits[19]}]bit12", StatusFlagBits[19] == '0' ? "车门解锁" : "车门加锁");

  307.             writer.WriteString($"[{StatusFlagBits[20]}]bit11", StatusFlagBits[20] == '0' ? "车辆电路正常" : "车辆电路断开");

  308.             writer.WriteString($"[{StatusFlagBits[21]}]bit10", StatusFlagBits[21] == '0' ? "车辆油路正常" : "车辆油路断开");

  309.             var bit8And9 = StatusFlagBits.Slice(22, 2).ToString();

  310.             switch (bit8And9)

  311.             {

  312.                 case "00":

  313.                     writer.WriteString($"[{bit8And9}]bit8~bit9", "空车");

  314.                     break;

  315.                 case "01":

  316.                     writer.WriteString($"[{bit8And9}]bit8~bit9", "半载");

  317.                     break;

  318.                 case "10":

  319.                     writer.WriteString($"[{bit8And9}]bit8~bit9", "保留");

  320.                     break;

  321.                 case "11":

  322.                     writer.WriteString($"[{bit8And9}]bit8~bit9", "满载");

  323.                     break;

  324.             }

  325.             writer.WriteString($"[bit6~bit7]保留", StatusFlagBits.Slice(24, 2).ToString());

  326.             writer.WriteString($"[{StatusFlagBits[26]}]bit5", StatusFlagBits[26] == '0' ? "经纬度未经保密插件加密" : "经纬度已经保密插件加密");

  327.             writer.WriteString($"[{StatusFlagBits[27]}]bit4", StatusFlagBits[27] == '0' ? "运营状态" : "停运状态");

  328.             writer.WriteString($"[{StatusFlagBits[28]}]bit3", StatusFlagBits[28] == '0' ? "东经" : "西经");

  329.             writer.WriteString($"[{StatusFlagBits[29]}]bit2", StatusFlagBits[29] == '0' ? "北纬" : "南纬");

  330.             writer.WriteString($"[{StatusFlagBits[30]}]bit1", StatusFlagBits[30] == '0' ? "未定位" : "定位");

  331.             writer.WriteString($"[{StatusFlagBits[31]}]bit0", StatusFlagBits[31] == '0' ? "ACC关" : "ACC开");

  332.             writer.WriteEndObject();

  333.             if (((value.StatusFlag >> 28) & 1) == 1)

  334.             {   //南纬 268435456 0x10000000

  335.                 value.Lat = (int)reader.ReadUInt32();

  336.                 writer.WriteNumber($"[{value.Lat.ReadNumber()}]纬度", value.Lat);

  337.             }

  338.             else

  339.             {

  340.                 value.Lat = reader.ReadInt32();

  341.                 writer.WriteNumber($"[{value.Lat.ReadNumber()}]纬度", value.Lat);

  342.             }

  343.             if (((value.StatusFlag >> 27) & 1) == 1)

  344.             {   //西经 ‭134217728‬ 0x8000000

  345.                 value.Lng = (int)reader.ReadUInt32();

  346.                 writer.WriteNumber($"[{value.Lng.ReadNumber()}]经度", value.Lng);

  347.             }

  348.             else

  349.             {

  350.                 value.Lng = reader.ReadInt32();

  351.                 writer.WriteNumber($"[{value.Lng.ReadNumber()}]经度", value.Lng);

  352.             }

  353.             value.Altitude = reader.ReadUInt16();

  354.             writer.WriteNumber($"[{value.Altitude.ReadNumber()}]高程", value.Altitude);

  355.             value.Speed = reader.ReadUInt16();

  356.             writer.WriteNumber($"[{value.Speed.ReadNumber()}]速度", value.Speed);

  357.             value.Direction = reader.ReadUInt16();

  358.             writer.WriteNumber($"[{value.Direction.ReadNumber()}]方向", value.Direction);

  359.             value.GPSTime = reader.ReadDateTime6();

  360.             writer.WriteString($"[{value.GPSTime.ToString("yyMMddHHmmss")}]定位时间", value.GPSTime.ToString("yyyy-MM-dd HH:mm:ss"));

  361.             // 位置附加信息

  362.             writer.WriteStartArray("附加信息列表");

  363.             while (reader.ReadCurrentRemainContentLength() > 0)

  364.             {

  365.                 try

  366.                 {

  367.                     ReadOnlySpan<byte> attachSpan = reader.GetVirtualReadOnlySpan(2);

  368.                     byte attachId = attachSpan[0];

  369.                     byte attachLen = attachSpan[1];

  370.                     if (config.JT808_0X0200_Factory.Map.TryGetValue(attachId, out object jT808LocationAttachInstance))

  371.                     {

  372.                         writer.WriteStartObject();

  373.                         jT808LocationAttachInstance.Analyze(ref reader, writer, config);

  374.                         writer.WriteEndObject();

  375.                     }

  376.                     else if (config.JT808_0X0200_Custom_Factory.Map.TryGetValue(attachId, out object customAttachInstance))

  377.                     {

  378.                         writer.WriteStartObject();

  379.                         customAttachInstance.Analyze(ref reader, writer, config);

  380.                         writer.WriteEndObject();

  381.                     }

  382.                     else

  383.                     {

  384.                         writer.WriteStartObject();

  385.                         reader.Skip(2);

  386.                         writer.WriteNumber($"[{attachId.ReadNumber()}]未知附加信息Id", attachId);

  387.                         writer.WriteNumber($"[{attachLen.ReadNumber()}]未知附加信息长度", attachLen);

  388.                         writer.WriteString($"未知附加信息", reader.ReadArray(reader.ReaderCount - 2, attachLen + 2).ToArray().ToHexString());

  389.                         reader.Skip(attachLen);

  390.                         writer.WriteEndObject();

  391.                     }

  392.                 }

  393.                 catch

  394.                 {

  395.                     writer.WriteStartObject();

  396.                     try

  397.                     {

  398.                         byte attachId = reader.ReadByte();

  399.                         byte attachLen = reader.ReadByte();

  400.                         writer.WriteNumber($"[{attachId.ReadNumber()}]未知附加信息Id", attachId);

  401.                         writer.WriteNumber($"[{attachLen.ReadNumber()}]未知附加信息长度", attachLen);

  402.                         writer.WriteString($"未知附加信息", reader.ReadArray(reader.ReaderCount - 2, attachLen + 2).ToArray().ToHexString());   

  403.                         reader.Skip(attachLen);

  404.                     }

  405.                     catch (Exception ex)

  406.                     {

  407.                         throw;

  408.                     }

  409.                     finally

  410.                     {

  411.                         writer.WriteEndObject();

  412.                     }

  413.                 }

  414.             }

  415.             writer.WriteEndArray();

  416.         }

  417.     }

  418. }