SKMC.API-v3/SKMC.API/Device/Adapter/Vision/SKVisionProtocol.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace SKMC.Api.Device.Adapter.Vision
{
    /// <summary>
    /// SKVision通讯协议(V0)
    /// </summary>
    public class SKVisionProtocol
    {
        /// <summary>
        /// 协议头
        /// </summary>
        public string Protocol { get; } = "SKV0";

        /// <summary>
        /// 请求方向, 请求：T、响应：R
        /// </summary>
        public string Direction { get; set; }

        /// <summary>
        /// 模块码
        /// </summary>
        public string ModuleCode { get; set; }

        /// <summary>
        /// 功能码
        /// </summary>
        public string FuncCode { get; set; }

        /// <summary>
        /// 产品码或二维码
        /// </summary>
        public string ProductCode { get; set; }

        /// <summary>
        /// 时间戳, 格式为：yyMMddHHmmssfff
        /// </summary>
        public string Timestamp { get; set; }

        /// <summary>
        /// 请求设置码
        /// </summary>
        public string OptionCode { get; set; } = "0000";

        /// <summary>
        /// 响应结果码
        /// </summary>
        public string ResultCode { get; set; }

        /// <summary>
        /// 报文体内容字段集
        /// </summary>
        public List<string> BodyDomains { get; set; }

        /// <summary>
        /// SKVision通讯协议子对象
        /// </summary>
        public SKVisionProtocol SKVisionSubProtocol { get; set; }

        /// <summary>
        /// 创建请求报文
        /// </summary>
        /// <returns></returns>
        public string ToRequest()
        {
            string head = $"{Protocol},{Direction},{ModuleCode},{FuncCode},{ProductCode},{Timestamp},{OptionCode}";
            if (BodyDomains == null)
            {
                return $"{head},#,,$";
            }
            return $"{head},#,{string.Join(",", BodyDomains.ToArray())},$";
        }

        /// <summary>
        /// 解析响应报文并验证
        /// </summary>
        /// <param name="response"></param>
        /// <param name=""></param>
        /// <returns></returns>
        public SKVisionProtocol FromResponse(string response, bool validate = true)
        {
            response = response.Trim();
            int bodyStart = response.IndexOf("#,");
            int bodyEnd = response.IndexOf(",$");

            SKVisionProtocol skvpReponse = null;
            if (bodyStart > 0 && bodyEnd > 0)
            {
                string head = response.Substring(0, bodyStart);
                string body = response.Substring(bodyStart + 2, bodyEnd - bodyStart - 2);
                skvpReponse = ParseContent(head, body, validate); 
            }
            // 判断是否有粘包
            int subBodyEnd = response.IndexOf(",$", bodyEnd + 1);
            int subBodyStart = response.IndexOf("#,", bodyEnd + 1);
            if (subBodyStart > 0 && subBodyEnd > 0)
            {
                string subHead = response.Substring(bodyEnd + 1, subBodyStart - bodyEnd - 2);
                string subBody = response.Substring(subBodyStart + 2, subBodyEnd - subBodyStart - 2);
                skvpReponse.SKVisionSubProtocol = ParseContent(subHead, subBody, validate);
            }
            if (skvpReponse != null) return skvpReponse;
            throw new VisionException { Type = VisionException.Parse_Error, Detail = $"视觉系统返回数据格式异常" };
        }

        /// <summary>
        /// 内容解析
        /// </summary>
        /// <param name="head"></param>
        /// <param name="body"></param>
        /// <param name="validate"></param>
        /// <returns></returns>
        private SKVisionProtocol ParseContent(string head, string body, bool validate = true)
        {
            SKVisionProtocol skvpReponse = new SKVisionProtocol
            {
                BodyDomains = new List<string>()
            };
            try
            {
                string[] heads = head.Split(',');
                string[] parts = body.Split(',');
                skvpReponse.Direction = heads[1];
                skvpReponse.ModuleCode = heads[2];
                skvpReponse.FuncCode = heads[3];
                skvpReponse.ProductCode = heads[4];
                skvpReponse.Timestamp = heads[5];
                skvpReponse.ResultCode = heads[6];
                foreach (string part in parts)
                {
                    skvpReponse.BodyDomains.Add(part);
                }
            }
            catch (Exception e)
            {
                throw new VisionException { Type = VisionException.Parse_Error, Detail = $"视觉系统返回数据解析异常: {e.Message}" };
            }
            if (validate)
            {
                // if (!skvpReponse.Timestamp.Equals(Timestamp) || !skvpReponse.ModuleCode.Equals(ModuleCode) ||
                // !skvpReponse.FuncCode.Equals(FuncCode) || !skvpReponse.ProductCode.Equals(ProductCode))
                if (!skvpReponse.Timestamp.Equals(Timestamp) || !skvpReponse.ModuleCode.Equals(ModuleCode) ||
                !skvpReponse.FuncCode.Equals(FuncCode))
                {
                    throw new VisionException { Type = VisionException.Result_Error, Detail = $"视觉系统返回数据验证异常" };
                }
            }
            if (!skvpReponse.ResultCode.Equals("0000"))
            {
                throw new VisionException { Type = VisionException.Result_Error, Detail = $"视觉系统异常, Code: {skvpReponse.ResultCode}" };
            }
            return skvpReponse;
        }
    }
}