MedicalInsurance/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 Newtonsoft.Json;
using GMCrypto.Lib;

namespace PTMedicalInsurance.Helper
{
    public class JsonHelper
    {

        public static string toJsonString(object obj,bool missingNull)
        {
            JsonSerializerSettings settings = new JsonSerializerSettings();
            if (missingNull)
            {
                settings.NullValueHandling = NullValueHandling.Ignore;
            }
            return JsonConvert.SerializeObject(obj, Formatting.Indented, settings);
        }

        public static string toJsonString(object obj)
        {
            return toJsonString(obj,true);
        }

        public static JObject toJObject(object obj)
        {
            string data = toJsonString(obj, true);
            return JObject.Parse(data);
        }

        public static object toObject(string json)
        {
            return JsonConvert.DeserializeObject(json);
        }

        public static T toObject<T>(JObject joObject)
        {
            return joObject.ToObject<T>();
        }

        /// <summary>
        /// 解析医保平台返回对象
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="response"></param>
        /// <returns></returns>
        public static T getOutput<T>(JObject response)
        {
            if (response.ContainsKey("output")) 
            {
                return response["output"].ToObject<T>();
            }

            return response.ToObject<T>();
        }
        
        /// <summary>
        /// 解析IRIS系统返回对象
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="response"></param>
        /// <returns></returns>
        public static T getResult<T>(JObject response)
        {
            Response resp = response.ToObject<Response>();
            if (resp.errorCode == "0")
            {
                if (resp.result?.GetType() == typeof(JObject))
                {
                    JObject ret = (JObject)resp.result;
                    JArray lists = ret.Value<JArray>("rows");
                    if (lists?.Count > 0)
                    {
                        return lists.ToObject<T>();
                    }
                    else {
                        return ret.ToObject<T>();
                    }
                }
                if (resp.result?.GetType() == typeof(JArray))
                {
                    JArray lists = (JArray)resp.result;
                    if (lists?.Count > 0)
                    {
                        return lists[0].ToObject<T>();
                    }
                }
            }

            return default;

        }

        /// <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 "";
            }
        }

        /// <summary>
        /// 将指定的json内容转为对象
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="jo"></param>
        /// <param name="destPath"></param>
        /// <returns></returns>
        public static T parseObject<T>(JObject jo, string destPath)
        {
            JToken jt = jo.SelectToken("$." + destPath);
            if (jt != null)
            {
                return jt.ToObject<T>();
            }
            else
            {
                Global.writeLog(destPath + "的JToken属性值为空");
                return default;
            }
        }


        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;
        }

        /// <summary>
        /// 组织中心入参(明文)。部分代码是需要解析明文入参的，为了方便增加该方法
        /// </summary>
        /// <param name="infno"></param>
        /// <param name="input"></param>
        /// <returns></returns>
        public static string setCenterInpar_plain(string infno, string input)
        {
            return setCenterInpar_plain(infno, (JObject)Newtonsoft.Json.JsonConvert.DeserializeObject(input));
        }

        /// <summary>
        /// 组织中心入参(明文)。部分代码是需要解析明文入参的，为了方便增加该方法
        /// </summary>
        /// <param name="infno"></param>
        /// <param name="input"></param>
        /// <returns></returns>
        public static string setCenterInpar_plain(string infno, JObject joInput)
        {
            return setCenterInpar(infno, joInput);
        }

        /// <summary>
        /// 移动支付组织中心入参
        /// </summary>
        /// <param name="infno"></param>
        /// <param name="input"></param>
        /// <returns></returns>
        public static string setMPCenterInpar(string infno, JObject joInput)
        {
            return setMPCenterInpar(infno, joInput.ToString());
        }

        /// <summary>
        /// 移动支付组织中心入参
        /// </summary>
        /// <param name="infno"></param>
        /// <param name="input"></param>
        /// <returns></returns>
        public static string setMPCenterInpar(string infno, string txtData)
        {
            EncryptHelper encrypt = new EncryptHelper(Global.inf.MobilePay.appid, Global.inf.MobilePay.secretKey, Global.inf.MobilePay.publicKey, Global.inf.MobilePay.privateKey);

            string plainText = SignUtil.SortInput(JObject.Parse(txtData));

            Global.writeLog(infno + "【明文入参】:\r\n" + plainText);

            string signData = "";


            string output = encrypt.encrypt(txtData, ref signData);

            Global.writeLog(infno + "【密文入参】:\r\n" + output);

            return output;
        }
        /// <summary>
        /// 银海安全组件调用参数
        /// </summary>
        /// <param name="funNO"></param>
        /// <returns></returns>
        public static JObject setYinHaiSafe(string funNO)
        {
            string business_type = Global.businessType;
            JObject joInput = new JObject();
                dynamic joData = new JObject();
                joData.fixmedins_code = Global.inf.hospitalNO;
                joData.psn_no = Global.pat.psn_no;
                joData.mdtrtarea_admvs = Global.inf.areaCode;
                joData.local_type = "3";
                joData.out_type = "2";
                joData.opter = Global.user.ID;
                joData.opter_name = Global.user.name;
                joData.office = Global.user.officeID;
                joData.office_name = Global.user.officeName;
                joData.business_type = business_type;
                joData.device_type = "";
            joInput["data"] = JObject.FromObject(joData);
            joInput["tran_no"] = funNO;
            joInput["tran_time"] = DateTime.Now.ToString("yyyyMMddHHMMss");
            return joInput;
        }

        public static string setCenterInpar(string infno, JObject joInput)
        {
            return setCenterInpar(infno,joInput,true);
        }
        public static string setCenterInpar(string infno, JObject joInput,bool encyptFlag)
        {
            dynamic Jo = new JObject();
            Jo.infno = infno;
            Global.curEvt.msgid = Global.inf.hospitalNO + DateTime.Now.ToString("yyyyMMddHHmmssffff");
            Jo.msgid = Global.curEvt.msgid;
            Global.pat.mdtrtarea_admvs = Global.inf.areaCode;

            // 参保地医保区划
            Jo.insuplc_admdvs = Global.pat.insuplc_admdvs??"";
            // 就医地
            Jo.mdtrtarea_admvs = Global.pat.mdtrtarea_admvs;
            string infTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");

            Jo.recer_sys_code = "SY";
            Jo.dev_no = "00FFF254308F";//设备编号
            Jo.dev_safe_info = ""; 
            Jo.signtype = "SM3withSM2"; ;
            Jo.infver = "v1.0";
            Jo.opter_type = Global.user.type ;
            Jo.opter = Global.user.ID ;
            Jo.opter_name = Global.user.name ;
            Jo.inf_time = infTime;
            Jo.fixmedins_code = Global.inf.hospitalNO;
            Jo.fixmedins_name = Global.inf.hospitalName;
            Jo.sign_no = Global.curEvt.signno;
            Jo.cainfo = "";
            if (joInput != null)
            {
                if (encyptFlag && Utils.LoadEncyptFlag(infno))
                {
                    //新增加密
                    try
                    {
                        YinHaiEncrypt yhEncrypt = new YinHaiEncrypt();
                        string caInfoSource = BuildCaInfo(infno, joInput.ToString(), infTime);
                        Global.inf.cainfo = Global.inf.hospitalNO + "|104|" + yhEncrypt.Signature(caInfoSource);
                        string encryptInput = yhEncrypt.Encrypt(joInput.ToString());

                        Jo.cainfo = Global.inf.cainfo;
                        Jo.input = encryptInput;
                    }
                    catch (Exception ex)
                    {
                        Global.writeLog("加密异常:" + ex.Message);
                    }
                }
                else
                {
                    // 不要求加密
                    Jo.Add("input", JObject.FromObject(joInput));
                }
            }
            else
            {
                Jo.Add("input", "");
            }

            var request = Utils.Wrapper(Jo);

            return JsonHelper.toJsonString(request);
        }

        public static string BuildCaInfo(string infno, string input,string infTime)
        {
            string s = infno;
            s = s + "|" + Global.curEvt.msgid;
            s = s + "|" + Global.inf.areaCode;
            s = s + "|" + Global.pat.insuplc_admdvs;
            s = s + "|" + Global.inf.version;
            s = s + "|" + infTime;
            s = s + "|" + Global.inf.hospitalNO;
            s = s + "|" + Global.curEvt.signno;
            s = s + "|" + input.Trim();
            return s;
        }

        /// <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;
                dynamic joTmp = new JObject();

                JArray jaParam = new JArray();
                // 去掉包装
                JObject joInput = Utils.removeWrapper(joParam);
                jaParam.Add(joInput);
                if (!joInparam.ContainsKey("HospitalDr"))
                {
                    joInparam.Add("HospitalDr", Global.inf.hospitalDr);
                }
                if (!joInparam.ContainsKey("InterfaceDr"))
                {
                    joInparam.Add("InterfaceDr", Global.inf.interfaceDr);
                }

                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;
                joInparam.Add("HospitalDr", Global.inf.hospitalDr);
                joInparam.Add("InterfaceDr", Global.inf.interfaceDr);
                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");
                string resultCode = getDestValue(joRtn, "resultcode");
                if (!string.IsNullOrEmpty(errcode))
                {
                    errorMsg = getDestValue(joRtn, "errmsg");
                    return -1;
                }
                else if (!string.IsNullOrEmpty(errorCode))
                {
                    errorMsg = getDestValue(joRtn, "errorMessage");
                    return -2;
                }
                else if (!string.IsNullOrEmpty(resultCode))
                {
                    errorMsg = getDestValue(joRtn, "resulttext");
                    return -3;
                }
                else
                {
                    errorMsg = getDestValue(joRtn, "err_msg");
                    return int.Parse(getDestValue(joRtn, "infcode"));
                }
            }
            catch (Exception ex)
            {
                errorMsg = "解析中心返参发生异常：" + ex.Message;
                return -1;
            }
        }

        /// <summary>
        /// 解析移动返参
        /// </summary>
        /// <param name="joRtn"></param>
        /// <param name="errorMsg"></param>
        /// <returns></returns>
        public static int parseMPRtnValue(JObject joRtn, out string errorMsg)
        {
            try
            {
                string success = getDestValue(joRtn, "success");
                string message = getDestValue(joRtn, "message");
                string encData = getDestValue(joRtn, "encData");
                if (string.IsNullOrEmpty(message)) {
                    message = getDestValue(joRtn, "errorMessage");
                }

                //Global.writeLog("success:" + success);
                if (success != "True")
                {
                    errorMsg = message;
                    return -1;
                }
                else
                {
                    errorMsg = joRtn.ToString();
                    return 0;
                }
            }
            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="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;
            }

        }
    }
}