20230201_145_upperpc/InSituLaboratory/Common/DataParsing.cs

using InSituLaboratory.Entities;
using InSituLaboratory.Service;
using Microsoft.EntityFrameworkCore;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace InSituLaboratory.Common
{
    /// <summary>
    /// 数据解析
    /// </summary>
    public class DataParsing
    {
        //连接钥匙
        private static readonly string ConnStr = System.Configuration.ConfigurationManager.ConnectionStrings["db"].ConnectionString;

        public DataParsingModelSqlSugar dataParsingModel = new DataParsingModelSqlSugar();

        //获取当前程序运行路径
        private string Save_Path = System.AppDomain.CurrentDomain.SetupInformation.ApplicationBase + @"数据记录\";

        //记录第一包数据的创建时间
        public static DateTime Record_firstCode = DateTime.Now;

        //标志位头
        byte flag = 0x7f;

        //应答流水号
        string ResponseNum = "";

        //应答ID
        string ResponID = "";

        //通用应答消息ID
        string MessageID = "1000";

        //crc
        static byte nr_crc = 0;

        /// <summary>
        /// 数据解析
        /// </summary>
        /// <param name="byteList"></param>
        public void ParsingData(List<byte> byteList)
        {
            //如果数组长度为0 舍弃
            if (byteList.Count() == 0)
                return;
            //将报文中的内容截取出来  并保存至本地TXT文件内
            string NR_TXT = "";
            for (int i = 0; i < byteList.Count; i++)
            {
                NR_TXT += byteList[i].ToString("X2") + " ";
            }

            tools.AddLgoToTXT("原始数据报文.txt", Save_Path + System.DateTime.Now.ToString("yyyy_MM_dd") + @"\", System.DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + " ---- " + NR_TXT + "\r\n");

            //SqlSugar配置文件
            ConnectionConfig connectionConfig = new ConnectionConfig()
            {
                ConnectionString = ConnStr,
                IsAutoCloseConnection = true,
                DbType = DbType.Sqlite
            };

            //转义
            int j = 0;
            for (int i = 0; i < byteList.Count; i++)
            {
                if (byteList[i] == 0x7e && byteList[i + 1] == 0x01)
                {
                    byteList[j] = 0x7e;
                    i++;

                }
                else if (byteList[i] == 0x7e && byteList[i + 1] == 0x02)
                {
                    byteList[j] = 0x7f;
                    i++;
                }
                else
                {
                    byteList[j] = byteList[i];
                }
                j++;
            }

            //定义转义后的byte数组
            byte[] dataTemp = new byte[j];
            for (int i = 0; i < j; i++)
            {
                dataTemp[i] = byteList[i];
            }

            //定义转义后的list数组
            List<byte> dataNew = new List<byte>();
            string Latter_TXT = "";
            for (int i = 0; i < dataTemp.Length; i++)
            {
                dataNew.Add(dataTemp[i]);
                Latter_TXT += dataTemp[i].ToString("X2") + " ";
            }

            //数据域数组
            List<byte> bytes = new List<byte>();
            for (int i = 1; i < dataTemp.Length - 2; i++)
            {
                bytes.Add(dataTemp[i]);
            }

            tools.AddLgoToTXT("转义后数据报文.txt", Save_Path + System.DateTime.Now.ToString("yyyy_MM_dd") + @"\", System.DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + " ---- " + Latter_TXT + "\r\n");

            nr_crc = tools.CRC(bytes.ToArray(), 0, bytes.Count);

            ///包头包尾 crc校验
            if (((dataNew[0] != flag) || (dataNew[byteList.Count - 1]) != flag) || dataNew[14] != nr_crc)
                return;


            //通用应答  消息ID：0x1000
            if (MessageID == dataNew[1].ToString("X2") + dataNew[2].ToString("X2"))
            {
                dataParsingModel.CreateTime = System.DateTime.Now;
                //应答流水号
                dataParsingModel.ResponseNum = dataNew[9].ToString("X2") + dataNew[10].ToString("X2");
                //应答ID                                            
                if (dataNew[11].ToString("X2") + dataNew[12].ToString("X2") == "9100")
                {
                    dataParsingModel.ResponseID = "9100-时序下发";
                }
                else if (dataNew[11].ToString("X2") + dataNew[12].ToString("X2") == "9201")
                {
                    dataParsingModel.ResponseID = "9201-局部控制开关";
                }
                //结果
                switch (dataNew[13])
                {
                    case 0x00:
                        dataParsingModel.ResponseResult = "成功/确认";
                        break;
                    case 0x01:
                        dataParsingModel.ResponseResult = "失败/不存在";
                        break;
                    case 0x02:
                        dataParsingModel.ResponseResult = "消息错误";
                        break;
                    case 0x03:
                        dataParsingModel.ResponseResult = "不支持";
                        break;
                    default:
                        break;
                }

                using (SqlSugarClient db = new SqlSugarClient(connectionConfig))
                {
                    db.Insertable<DataParsingModelSqlSugar>(dataParsingModel).ExecuteCommand();
                }
            }
        }



        #region 转义

        /// <summary>
        /// 转义
        /// </summary>
        /// <param name="tBuffer">没有头尾和校验的byte数组</param>
        /// <param name="code">校验码</param>
        /// <param name="flag">标志位</param>
        /// <returns></returns>
        public static List<byte> Transform(List<byte> tBuffer, byte code, byte flag)
        {
            int j = 0;
            tBuffer.Add(code);
            int length = tBuffer.ToArray().Length;
            byte[] newAnswer = tBuffer.ToArray();
            for (int i = 0; i < length; i++)
            {
                if (newAnswer[i] == 0x7e || newAnswer[i] == 0x7f)
                {
                    j++;
                }
            }
            byte[] newSendBuffer = new byte[length + j];
            for (int i = 0; i < length; i++)
            {
                newSendBuffer[i] = newAnswer[i];
            }
            for (int i = 0; i < length + j; i++)
            {
                if (newSendBuffer[i] == 0x7e)
                {
                    for (int k = length + j - 1; k > i + 1; k--)
                    {
                        newSendBuffer[k] = newSendBuffer[k - 1];
                    }
                    newSendBuffer[i + 1] = 0x01;
                }
                if (newSendBuffer[i] == 0x7f)
                {
                    newSendBuffer[i] = 0x7e;
                    for (int k = length + j - 1; k > i + 1; k--)
                    {
                        newSendBuffer[k] = newSendBuffer[k - 1];
                    }
                    newSendBuffer[i + 1] = 0x02;
                }
            }
            List<byte> buffer = new List<byte>();
            buffer.Add(flag);
            for (int i = 0; i < newSendBuffer.Length; i++)
            {
                buffer.Add(newSendBuffer[i]);
            }
            buffer.Add(flag);
            return buffer;
        }
        #endregion
    }
}