├─src
  ├─GWSTHJJ.STD
    ├─GWSTHJJ.STD
      ├─bin（编译文件）
      │CEquip.cs（插件入口类）
      │MessageAnalysis.cs（消息协议解析类）
      │SocketFilter.cs（Socket过滤器,用于解析byte[]流）
      │SocketServer.cs（Socket服务端帮助类）

var serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
serverSocket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);//端口复用
// 绑定
serverSocket.Bind(new IPEndPoint(IPAddress.Any, port));
// 监听
serverSocket.Listen(20);
serverSocket.BeginAccept(AcceptCallback, serverSocket);//获取连接

var temLen = Convert.ToInt32(dataStr.Substring(2, 4));//数据段长度
var crcStr = dataStr.Substring(6, temLen);
var crcResult = CalculateCrc(crcStr);//CRC校验结果
var crcExcept = dataStr.Substring(dataStr.LastIndexOf("&&", StringComparison.OrdinalIgnoreCase) + 2);
if (crcResult != crcExcept)
{
    // crc校验不成功
    return false;
}

var parseModel =  FInterpreterInternal(crcStr);
if (parseModel == null || string.IsNullOrEmpty(parseModel.Cn))
{
    return false;
}

// 将解析出的数据模型加入到缓存
AddAnalysisModelToDic(parseModel);
var cmdStr = parseModel.Cn switch
{
    "1013" => SendCmdStr("9013", parseModel),
    "2011" => SendCmdStr("9014", parseModel),
    "2021" => SendCmdStr("9014", parseModel),
    _ => ""
};

// 响应下层设备的字节数组
cmdArray = Encoding.UTF8.GetBytes(cmdStr);

public override bool GetYX(YxpTableRow r)
{
   var analysisCollection = MessageAnalysis.AnalysisModelDic[_terminalNo].OrderBy(m => m.ReportDataTime).ToList();
   if (analysisCollection.Any())
   {
       var analysis = analysisCollection[^1];
       var dataItem = analysis.DataItems.FirstOrDefault(d => d.Pairs.Any(p => p.Key.Contains(r.main_instruction)));
       if (dataItem != null)
       {
           var state = dataItem.Pairs.FirstOrDefault(p => p.Key.Contains(r.main_instruction + "-Flag"));
           if (state.Value == Flag.正常)
           {
               SetYXData(r, false);//不报警
           }
           else
           {
               SetYXData(r, state.Value);
           }
       }
   }

    return true;
}

public override bool GetYC(YcpTableRow r)
{
    var analysisCollection = MessageAnalysis.AnalysisModelDic[_terminalNo].OrderBy(m => m.ReportDataTime).ToList();
    if (analysisCollection.Any())
    {
    var analysis = analysisCollection[^1];　//获取最后一项的数据包
    var dataItem = analysis.DataItems.FirstOrDefault(d => d.Pairs.Any(p => p.Key.Contains(r.main_instruction)));
    if (dataItem != null)
    {
    var key = r.minor_instruction.EndsWith("-") ? r.main_instruction : r.main_instruction + "-" + r.minor_instruction;
    var state = dataItem.Pairs.FirstOrDefault(p => p.Key.Contains(key));
    
               var parseDouble = double.TryParse(state.Value, out var stateDouble);
               if (parseDouble)
               {
                   SetYCData(r, stateDouble);
               }
               else
               {
                   SetYCData(r, state.Value);
               }
           }
    }
    
    return true;
}