MedicalInsurance/BeiJingMI/Helper/JsonHelper.cs

/******************************************************************************
  * 文件名称: JsonHelper.cs
 * 文件说明: Json业务的封装，处理JSON串的封装，解析等
 * 当前版本: V1.0
 * 创建日期: 2022-04-14
 *
 * 2020-04-14: 增加 setIrisInpar 方法
 * 2020-04-14: 增加 setIrisInpar（重载） 方法
 * 2020-04-14: 增加 getIrisExceptionJson 方法
 * 2020-04-14: 增加 parseBusinessJson 方法

 ******************************************************************************/
using Newtonsoft.Json.Linq;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using PTMedicalInsurance.Common;
using System.IO;
using PTMedicalInsurance.Variables;
using System.Windows.Forms;
using Org.BouncyCastle.Crypto;
using Org.BouncyCastle.Crypto.Parameters;
using Org.BouncyCastle.Crypto.Engines;
using Org.BouncyCastle.Crypto.Modes;
using Org.BouncyCastle.Crypto.Paddings;
using Org.BouncyCastle.Security;
using Org.BouncyCastle.Utilities;
using Org.BouncyCastle.Utilities.Encoders;
using Newtonsoft.Json;
using SM4Crypto.Lib;
using System.Text.RegularExpressions;

namespace PTMedicalInsurance.Helper
{
    class JsonHelper
    {      
        /// <summary>
        /// 根据JSonPath查找节点值，如果节点不存在则返回空值
        /// </summary>
        /// <param name="jo"></param>
        /// <param name="jsonPath"></param>
        /// <returns></returns>
        public static string getDestValue(JObject jo, string destPath)
        {
            JToken jt = jo.SelectToken("$." + destPath);
            if (jt != null)
            {
                return jt.ToString();
            }
            else
            {
                Global.writeLog(destPath + "的JToken属性值为空");
                return "";
            }
        }


        public static string getDestProperty(JObject jo, string propertyName)
        {
            JProperty jp = jo.Property(propertyName);
            if (jp != null)
            {
                string jpStr = jp.ToString();
                string rtnResult = "{ " + jpStr + "}";
                return rtnResult;
            }
            else
            {
                Global.writeLog(propertyName + "的JProperty属性值为空");
                return "";
            }
            
        }
        /// <summary>
        /// 压缩JSON，占用体积减小(重载)
        /// </summary>
        /// <param name="json"></param>
        /// <returns></returns>
        public static string Compress(string json)
  {
      StringBuilder sb = new StringBuilder();
      using (StringReader reader = new StringReader(json))
      {
          int ch = -1;
          int lastch = -1;
         bool isQuoteStart = false;
          while ((ch = reader.Read()) > -1)
         {
             if ((char) lastch != '\\' && (char) ch == '\"')
             {
                 if (!isQuoteStart)
                 {
                     isQuoteStart = true;
                 }
                 else
                 {
                     isQuoteStart = false;
                 }
             }
             if (!Char.IsWhiteSpace((char) ch) || isQuoteStart)
             {
                 sb.Append((char) ch);
             }
             lastch = ch;
         }
     }
     return sb.ToString();
 }
        public static string Compress(JObject jsonObj)
        {
            //https://blog.csdn.net/yangjiaosun/article/details/103717256
            return Newtonsoft.Json.JsonConvert.SerializeObject(jsonObj);
        }

        /// <summary>
        /// 组织异常JSON串
        /// </summary>
        /// <param name="errorCode"></param>
        /// <param name="errorMessage"></param>
        /// <returns></returns>
        public static JObject setExceptionJson(int errorCode, string eventName, string errorMessage)
        {
            dynamic joRtn = new JObject();
            joRtn.errorCode = errorCode;
            joRtn.errorMessage = eventName + "提示：" + errorMessage;
            return joRtn;
        }

        public static string GetinPar(string sInpar, int i)
        {
            string Str = "";
            if (i == 0)
            {
                Str = @"<?xml version=""1.0"" encoding=""UTF-16"" standalone=""yes"" ?><root version=""2.003"" sender=""capinfo"">";
                return Str + "<input>" + sInpar + "</input></root>";
            }
            else if (i == 1)
            {
                Str = @"<?xml version=""1.0"" encoding=""UTF-16"" standalone=""yes"" ?>";
                return Str + "<data>" + sInpar + "</data>";
            }
            else if (i == 2)
            {
                Str = @"<?xml version=""1.0"" encoding=""UTF-16"" standalone=""yes"" ?><root version=""2.003"" sender =""HFHSXXJS00002.100188"" > ";
                return Str + "<input>" + sInpar + "</input></root>";
            }
            else
            {
                return "";
            }
        }

        public static string setCenterInpar_SX(string infno, string input)
        {
            dynamic Jo = new JObject();
            Global.curEvt.msgid = "051550090100"
                                + DateTime.Now.ToString("yyyyMMddHHmmss")
                                + DateTime.Now.ToString("ffff");
            string sInput = Global.curEvt.msgid + infno + input;
            string base64String = EncryptCenterInPut(sInput, Global.inf.SK);
            Jo.MSG_NO = Global.curEvt.msgid;  //处理流水编号
            Jo.MSG_TYPE = infno;  //报文编号  
            Jo.INF_VER = "V1.0"; //接口版本号
            Jo.HOSP_CODE = "0515500901";  //院区编码 测试环境 0411000101
            Jo.Add("IN_DATA", base64String);  // //输入参数
            //Global.writeLog("交易码【" + infno + "】,加密后数据：" + "\n\r" + base64String);
            return Jo.ToString();
        }

        public static string EncryptCenterInPut(string sInput, string secretKey)
        {
            try
            {
                string encryptString = SM4EncryptECB(sInput, secretKey);
                byte[] encrypted = Hex.Decode(encryptString);
                string base64String = Convert.ToBase64String(encrypted);
                return base64String;
            }
            catch (Exception ex)
            {
                throw new Exception($"加密失败(1): {ex.Message}");
            }
        }

        public static string DecryptCenterOutPut(string sInput, string secretKey)
        {
            try
            {
                // Base64解码密文字符串
                byte[] encryptedData = Convert.FromBase64String(sInput);
                byte[] keyBytes = Encoding.UTF8.GetBytes(secretKey.Substring(0, 16));
                // SM4 ECB解密
                string decryptedData = SM4DecryptECB(encryptedData, keyBytes);
                // UTF8解码为明文字符串
                return decryptedData;
            }
            catch (Exception ex)
            {
                throw new Exception($"解密失败(1): {ex.Message}");
            }
        }

        public static string SM4EncryptECB(string plainText, string secretKey)
        {
            try
            {
                byte[] plaintext = Encoding.UTF8.GetBytes(plainText);
                byte[] keyBytes = Encoding.UTF8.GetBytes(secretKey.Substring(0, 16));
                IBufferedCipher inCipher = CipherUtilities.GetCipher("SM4/ECB/PKCS7Padding");
                KeyParameter key = ParameterUtilities.CreateKeyParameter("SM4", keyBytes);
                inCipher.Init(true, key);
                byte[] cipher = inCipher.DoFinal(plaintext);
                //加密结果数据格式Hex
                byte[] encrypted2 = Hex.Encode(cipher);
                return Encoding.UTF8.GetString(encrypted2).ToUpper();
            }
            catch (Exception ex)
            {
                throw new Exception($"加密失败: {ex.Message}");
            }
        }
      
        private static string SM4DecryptECB(byte[] encryptedData, byte[] secretKey)
        {
            try
            {
                // 创建SM4引擎
                var sm4Engine = new SM4Engine();
                // 创建ECB模式（无模式参数，因为ECB不需要IV）
                var cipher = new PaddedBufferedBlockCipher(sm4Engine, new Pkcs7Padding());
                // 初始化密钥参数（ECB模式不需要IV）
                var keyParam = new KeyParameter(secretKey);
                cipher.Init(false, keyParam); // false表示解密模式
                // 执行解密
                byte[] output = new byte[cipher.GetOutputSize(encryptedData.Length)];
                int length = cipher.ProcessBytes(encryptedData, 0, encryptedData.Length, output, 0);
                length += cipher.DoFinal(output, length);
                // 返回实际解密的数据（可能比output数组小）
                byte[] result = new byte[length];
                Array.Copy(output, 0, result, 0, length);
                return Encoding.UTF8.GetString(result);
            }
            catch (Exception ex)
            {
                throw new Exception($"解密失败: {ex.Message}");
            }
        }

        public static string ExtractJson(string input)
        {
            // 匹配从第一个 { 开始到最后一个 } 结束的JSON内容
            var pattern = @"\{.*\}";
            var match = Regex.Match(input, pattern);

            if (match.Success)
            
                return match.Value;
            else
                return string.Empty;
        }

        /// <summary>
        /// 组织中心入参(明文)。部分代码是需要解析明文入参的，为了方便增加该方法
        /// </summary>
        /// <param name="infno"></param>
        /// <param name="input"></param>
        /// <returns></returns>
        public static string setCenterInpar_plain(string infno, string input)
        {
            dynamic Jo = new JObject();
            Jo.infno = infno;
            Global.curEvt.msgid = Global.inf.hospitalNO + DateTime.Now.ToString("yyyyMMddHHmmssffff");
            Jo.msgid = Global.curEvt.msgid;

            Jo.mdtrtarea_admvs = "110100";   
            Global.pat.mdtrtarea_admvs = "110100";

            Jo.insuplc_admdvs = Global.pat.insuplc_admdvs;
            Jo.recer_sys_code = Global.inf.recivedSystem;
            Jo.dev_safe_info = Global.inf.dev_safe_info; //设备编号
            Jo.cainfo = Global.inf.cainfo;//设备安全信息
            Jo.signtype = Global.inf.signatureType; ;
            Jo.infver = Global.inf.version; ;
            Jo.opter_type = Global.user.type; ;
            Jo.opter = Global.user.ID; ;
            Jo.opter_name = Global.user.name; ;
            Jo.inf_time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
            Jo.fixmedins_code = Global.inf.hospitalNO;
            Jo.fixmedins_name = Global.inf.hospitalName;
            Jo.sign_no = Global.curEvt.signno;
            JObject joInput = (JObject)Newtonsoft.Json.JsonConvert.DeserializeObject(input);
            Jo.Add("input", JObject.FromObject(joInput));
            return Jo.ToString();
        }

        /// <summary>
        /// 组织中心入参(明文)。部分代码是需要解析明文入参的，为了方便增加该方法
        /// </summary>
        /// <param name="infno"></param>
        /// <param name="input"></param>
        /// <returns></returns>
        public static string setCenterInpar_plain(string infno, JObject joInput)
        {
            dynamic Jo = new JObject();
            Jo.infno = infno;
            Global.curEvt.msgid = Global.inf.hospitalNO + DateTime.Now.ToString("yyyyMMddHHmmssffff");
            Jo.msgid = Global.curEvt.msgid;

            Jo.insuplc_admdvs = Global.pat.insuplc_admdvs;
            Jo.mdtrtarea_admvs = "419900";
            Global.pat.mdtrtarea_admvs = "419900";
            Jo.recer_sys_code = Global.inf.recivedSystem;
            Jo.dev_no = Global.inf.dev_no;
            Jo.dev_safe_info = Global.inf.dev_safe_info; //设备编号
            Jo.cainfo = Global.inf.cainfo;//设备安全信息
            Jo.signtype = Global.inf.signatureType; ;
            Jo.infver = Global.inf.version; ;
            Jo.opter_type = Global.user.type; ;
            Jo.opter = Global.user.ID; ;
            Jo.opter_name = Global.user.name; ;
            Jo.inf_time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
            Jo.fixmedins_code = Global.inf.hospitalNO;
            Jo.fixmedins_name = Global.inf.hospitalName;
            Jo.sign_no = Global.curEvt.signno;
            Jo.Add("input", joInput);
            return Jo.ToString();
        }

        /// <summary>
        /// 组织中心入参--签到
        /// </summary>
        /// <param name="infno"></param>
        /// <param name="input"></param>
        /// <returns></returns>
        public static string setCenterInpar(string infno, string input)
        {
            dynamic Jo = new JObject();
            Jo.infno = infno;
            Global.curEvt.msgid = Global.inf.hospitalNO + DateTime.Now.ToString("yyyyMMddHHmmssffff");
            Jo.msgid = Global.curEvt.msgid;

            if (Global.inf.areaCode == "")
            {
                Global.inf.areaCode = "419900";
            }

            if (Global.pat.insuplc_admdvs == "")
            {
                Global.pat.insuplc_admdvs = Global.inf.areaCode;
            }          

            Jo.insuplc_admdvs = Global.pat.insuplc_admdvs;
            Jo.mdtrtarea_admvs = "419900";   //郑州 市医保、省内异地、跨省异地就医地都传419900  
            Global.pat.mdtrtarea_admvs = "419900";
            Jo.recer_sys_code = "HeNan";
            Jo.dev_no = Global.curEvt.mac;
            Jo.dev_safe_info = Global.inf.dev_safe_info; //设备编号
            Jo.cainfo = Global.inf.cainfo ;//
            Jo.signtype = "SM3"; ;
            Jo.infver = "v1.0";
            Jo.opter_type = Global.user.type; ;
            Jo.opter = Global.user.ID; ;
            Jo.opter_name = Global.user.name; ;
            Jo.inf_time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
            Jo.fixmedins_code = Global.inf.hospitalNO;
            Jo.fixmedins_name = Global.inf.hospitalName;
            Jo.sign_no = Global.curEvt.signno;

            if (input != "")
            {
                JObject joInput = (JObject)Newtonsoft.Json.JsonConvert.DeserializeObject(input);
                Jo.cainfo = "";
                Jo.Add("input", JObject.FromObject(joInput));
            }
            else
            {
                Jo.cainfo = "";
                Jo.Add("input", "");
            }

            return Jo.ToString();
        }

        /// <summary>
        /// 组织中心入参
        /// </summary>
        /// <param name="infno"></param>
        /// <param name="input"></param>
        /// <returns></returns>
        public static string setCenterInpar(string infno, JObject joInput)
        {
            dynamic Jo = new JObject();
            Jo.infno = infno;
            Global.curEvt.msgid = Global.inf.hospitalNO + DateTime.Now.ToString("yyyyMMddHHmmssffff");
            Jo.msgid = Global.curEvt.msgid;

            if (Global.pat.insuplc_admdvs == "")
            {
                Global.pat.insuplc_admdvs = Global.inf.areaCode;      
            }
            Jo.insuplc_admdvs = Global.pat.insuplc_admdvs;
            Jo.mdtrtarea_admvs = "419900";   //郑州 市医保、省内异地、跨省异地就医地都传419900
            Global.pat.mdtrtarea_admvs = "419900";
            Jo.recer_sys_code = "HeNan";
            Jo.dev_no = Global.curEvt.mac; 
            Jo.dev_safe_info = Global.inf.dev_safe_info; //设备编号
            Jo.cainfo = Global.inf.cainfo;//
            Jo.signtype = "asn1"; ;
            Jo.infver = "v1.0";
            Jo.opter_type = Global.user.type; ;
            Jo.opter = Global.user.ID; 
            Jo.opter_name = Global.user.name; ;
            Jo.inf_time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
            Jo.fixmedins_code = Global.inf.hospitalNO;
            Jo.fixmedins_name = Global.inf.hospitalName;
            Jo.sign_no = Global.curEvt.signno;                      
            Jo.cainfo = "";
            Jo.Add("input", JObject.FromObject(joInput));

            return Jo.ToString();
        }

        /// <summary>
        /// 组织中心入参-电子发票上传
        /// </summary>
        /// <param name="infno"></param>
        /// <param name="input"></param>
        /// <returns></returns>
        public static string setCenterInpar_InvNO(string infno, JObject joInput)
        {
            dynamic Jo = new JObject();
            Global.curEvt.msgid = "01" + DateTime.Now.ToString("yyyyMMddHHmmssffff");
            Jo.INF_VER = "v1.0";
            Jo.HOSP_CODE = Global.inf.hospitalNO + "01";
            Jo.MSG_NO = Global.curEvt.msgid;
            Jo.MSG_TYPE = infno;
            Jo.Add("IN_DATA", JObject.FromObject(joInput));

            return Jo.ToString();
        }

        /// <summary>
        /// 组织Iris入参
        /// </summary>
        /// <param name="code"></param>
        /// <param name="joParam"></param>
        /// <returns></returns>
        public static JObject setIrisInpar(string code, JObject joParam)
        {
            try
            {
                //dynamic joInparam = new JObject();
                //joInparam.code = code;

                JObject joInparam = new JObject();
                joInparam.Add("code", code);
                if (!joInparam.ContainsKey("interfaceDr"))
                {
                    joInparam.Add("interfaceDr", Global.inf.interfaceDr);
                }

                if (!joInparam.ContainsKey("hospitalDr"))
                {
                    joInparam.Add("hospitalDr", Global.inf.hospitalDr);
                }

                dynamic joTmp = new JObject();
                JArray jaParam = new JArray();
                jaParam.Add(joParam);
                joInparam.Add("params", JArray.FromObject(jaParam));
                joInparam.Add("session", Global.curEvt.jaSession);
                return joInparam;
            }
            catch (Exception ex)
            {
                return setExceptionJson(-1, "setIrisInpar:", ex.Message);
            }

        }

        /// <summary>
        /// 组织Iris入参
        /// </summary>
        /// <param name="code"></param>
        /// <param name="joParam"></param>
        /// <returns></returns>
        public static JObject setIrisInpar(string code, JArray jaParams)
        {
            try
            {
                dynamic joInparam = new JObject();
                joInparam.code = code;
                if (!joInparam.ContainsKey("interfaceDr"))
                {
                    joInparam.Add("interfaceDr", Global.inf.interfaceDr);
                }

                if (!joInparam.ContainsKey("hospitalDr"))
                {
                    joInparam.Add("hospitalDr", Global.inf.hospitalDr);
                }
                dynamic joTmp = new JObject();
                joInparam.Add("params", jaParams);
                joInparam.Add("session", Global.curEvt.jaSession);
                return joInparam;
            }
            catch (Exception ex)
            {
                return setExceptionJson(-1, "setIrisInpar:", ex.Message);
            }

        }

        /// <summary>
        /// 解析中心返参
        /// </summary>
        /// <param name="joRtn"></param>
        /// <param name="errorMsg"></param>
        /// <returns></returns>
        public static int parseCenterRtnValue(JObject joRtn,  out string errorMsg)
        {
            try
            {
                string errcode = getDestValue(joRtn, "errcode");
                string errorCode = getDestValue(joRtn, "errorCode");
                if (errcode != "")
                {
                    errorMsg = getDestValue(joRtn, "errmsg");
                    return -1;
                }
                else if (errorCode != "")
                {
                    errorMsg = getDestValue(joRtn, "errorMessage");
                    return -2;
                }
                else
                {
                    errorMsg = getDestValue(joRtn, "err_msg");
                    return int.Parse(getDestValue(joRtn, "infcode"));
                }
            }
            catch (Exception ex)
            {
                errorMsg = "解析中心返参发生异常：" + ex.Message;
                return -1;
            }
        }

        /// <summary>
        /// 组织IRIS返参
        /// </summary>
        /// <param name="errorCode"></param>
        /// <param name="errorMessage"></param>
        /// <param name="joResult"></param>
        /// <returns></returns>
        public static JObject setIrisReturnValue(int errorCode, string errorMessage, JObject joResult)
        {
            try
            {
                dynamic joRtn = new JObject();
                joRtn.errorCode = errorCode;
                joRtn.errorMessage = errorMessage;
                joRtn.Add("result", joResult);
                return joRtn;
            }
            catch (Exception ex)
            {
                return setExceptionJson(-1, "setIrisReturnValue:", ex.Message);
            }
        }

        /// <summary>
        /// 组织IRIS返参
        /// </summary>
        /// <param name="errorCode"></param>
        /// <param name="errorMessage"></param>
        /// <param name="joResult"></param>
        /// <returns></returns>
        public static JObject setIrisReturnValueNew(int errorCode, string errorMessage, string sResult)
        {
            try
            {
                dynamic joRtn = new JObject();
                joRtn.errorCode = errorCode;
                joRtn.errorMessage = errorMessage;
                joRtn.Add("result", sResult);
                return joRtn;
            }
            catch (Exception ex)
            {
                return setExceptionJson(-1, "setIrisReturnValueNew:", ex.Message);
            }
        }

        /// <summary>
        /// 解析IRIS返参
        /// </summary>
        /// <param name="joRtn"></param>
        /// <param name="errorMsg"></param>
        /// <returns></returns>
        public static int parseIrisRtnValue(JObject joRtn, out string errorMsg)
        {
            try
            {
                errorMsg = getDestValue(joRtn, "errorMessage");
                return int.Parse(getDestValue(joRtn, "errorCode"));
            }
            catch (Exception ex)
            {
                errorMsg = "解析Iris返参发生异常：" + ex.Message;
                return -1;
            }
        }

        /// <summary>
        /// 解析业务JSON串（业务串固定格式为{errorCode = ,errorMessage = ,result ={}}）
        /// </summary>
        /// <param name="json"></param>
        /// <param name="errorMsg"></param>
        /// <returns></returns>
        public static int parseCenterReturnJson(JObject json, out string errorMsg)
        {
            try
            {
                errorMsg = "";
                if (int.Parse(json["infcode"].ToString()) != 0)
                {
                    errorMsg = json["err_msg"].ToString();
                }
                return int.Parse(json["infcode"].ToString());
            }
            catch (Exception ex)
            {
                errorMsg = "parseCenterReturnJson" + ex.Message;
                return -1;
            }

        }
    }
}