/******************************************************************************
* 文件名称: 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 SM2Crypto.Lib;
using Newtonsoft.Json;
namespace PTMedicalInsurance.Helper
{
class JsonHelper
{
///
/// 根据JSonPath查找节点值,如果节点不存在则返回空值
///
///
///
///
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 "";
}
}
///
/// 压缩JSON,占用体积减小(重载)
///
///
///
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);
}
///
/// 组织异常JSON串
///
///
///
///
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 setCenterInparDRG(string sJYM, string sYWZQH, string DataInput)
{
Global.inf.Info = sJYM;
Global.inf.InsuHosNo = "H22010402422";
Global.inf.BusinessID = sYWZQH;
string OpterNo = "CM01";
Global.inf.BusinessLSH = Global.inf.InsuHosNo + "-0000-" + DateTime.Now.ToString("yyyyMMddHHmmss");
return sJYM + "^" + Global.inf.InsuHosNo + "^" + OpterNo + "^" + Global.inf.BusinessID + "^" + Global.inf.BusinessLSH + "^0000" + "^" + DataInput + "^1^";
}
///
/// 组织中心入参(明文)。部分代码是需要解析明文入参的,为了方便增加该方法
///
///
///
///
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 = Global.inf.areaCode;
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();
}
///
/// 组织中心入参(明文)。部分代码是需要解析明文入参的,为了方便增加该方法
///
///
///
///
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.mdtrtarea_admvs = Global.inf.areaCode;
Jo.insuplc_admdvs = Global.pat.insuplc_admdvs;
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();
}
///
/// 组织中心入参
///
///
///
///
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 = "220100";
}
Jo.insuplc_admdvs = Global.pat.insuplc_admdvs;
Jo.mdtrtarea_admvs = "220100";
if (Global.inf.interfaceDr == 9)
{
Jo.mdtrtarea_admvs = "220100"; //长春市
}
if (Global.inf.interfaceDr == 20)
{
Jo.mdtrtarea_admvs = "229900";//长春省直异地用229900
}
Jo.recer_sys_code = "MBS_LOCAL";
Jo.dev_safe_info = Global.inf.dev_safe_info; //设备编号
Jo.dev_no = "";
Jo.cainfo = Global.inf.cainfo ;//
Jo.signtype = ""; ;
Jo.infver = "V1.0";
//Jo.opter_type = Global.user.type; ;
Jo.opter_type = 1;
Jo.opter = Global.user.ID; ;
//Jo.opter = "22010402422";
Jo.opter_name = Global.user.name; ;
//Jo.opter_name = "CM";
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.fixmedins_name = "长春市朝阳区普瑞眼科医院有限责任公司";
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", "");
}
// Jo.Token = Global.curEvt.token; //获取Token
return Jo.ToString();
}
///
/// 组织中心入参
///
///
///
///
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;
//Jo.mdtrtarea_admvs = Global.inf.areaCode;
//if (Global.pat.insuplc_admdvs == "")
//{
// Global.pat.insuplc_admdvs = Global.inf.areaCode;
//}
Jo.insuplc_admdvs = Global.pat.insuplc_admdvs;
if (Global.pat.insuplc_admdvs == "")
{
Jo.insuplc_admdvs = "220100";
}
//Global.pat.insuplc_admdvs;
/*if (Global.pat.insuplc_admdvs.Substring(0, 4) != "2201")
{
Jo.recer_admdvs = "220100";//长春省直异地用229900
}*/
//if (Global.pat.insuplc_admdvs.Substring(0, 4) != "2201")
//{
// Jo.mdtrtarea_admvs = "229900";//长春省直异地用229900
//}
//else {
// Jo.mdtrtarea_admvs = "220100";
//}
Jo.mdtrtarea_admvs = "220100";
if (Global.inf.interfaceDr == 9)
{
Jo.mdtrtarea_admvs = "220100";
}
if (Global.inf.interfaceDr == 20)
{
Jo.mdtrtarea_admvs = "229900";
}
Jo.recer_sys_code = "MBS_LOCAL";
Jo.dev_no = "";// Global.curEvt.mac;
Jo.dev_safe_info = Global.inf.dev_safe_info; //设备编号
Jo.cainfo = "";// Global.inf.cainfo;//
Jo.signtype = ""; ;
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;
string nonce = Guid.NewGuid().ToString(); //非重复的随机字符串(十分钟内不能重复)
string timestamp = TimeStamp.get13().ToString(); //当前时间戳(秒)
string BusinessID = Global.inf.BusinessID; //服务商ID
string InsuHosID = Global.inf.hospitalNO; //医疗机构ID
string CreditID = Global.inf.CreditID; //服务商统一社会信用代码
//昆明增加头部信息
string sTemp = timestamp + BusinessID + nonce;
//Sha256 加密生成的签名 sha256(hsf_timestamp + infosyssign + hsf_nonce)
string cainfo = "";//Encrypt.SHA256EncryptStr(sTemp);
Jo.cainfo = cainfo;
Jo.Add("input", JObject.FromObject(joInput));
return Jo.ToString();
}
///
/// 组织Iris入参
///
///
///
///
public static JObject setIrisInpar(string code, JObject joParam)
{
try
{
dynamic joInparam = new JObject();
joInparam.code = code;
dynamic joTmp = new JObject();
JArray jaParam = new JArray();
jaParam.Add(joParam);
joInparam.Add("HospitalDr", Global.inf.hospitalDr);
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);
}
}
///
/// 组织Iris入参
///
///
///
///
public static JObject setIrisInpar(string code, JArray jaParams)
{
try
{
dynamic joInparam = new JObject();
joInparam.code = code;
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);
}
}
///
/// 解析中心返参
///
///
///
///
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;
}
}
///
/// 组织IRIS返参
///
///
///
///
///
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);
}
}
///
/// 解析IRIS返参
///
///
///
///
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;
}
}
///
/// 解析业务JSON串(业务串固定格式为{errorCode = ,errorMessage = ,result ={}})
///
///
///
///
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;
}
}
#region 处方流转
///
/// 组织中心入参-医保电子处方流转
///
///
///
///
public static string setCenterInparPresCirNew(JObject data)
{
#region【测试环境】
////应用ID
//Global.inf.appId = "FA70F8091A534E7DB3D12766F9CAE199";
////Global.inf.appId = "57E2D561E97141A3871DEFB410ADD920";
////应用秘钥
//Global.inf.Secret = "2DCA1A6F04EE4314941ABE2A6C592DF6";
////Global.inf.Secret = "F30D0D261BA04063A0BCAEF19F8ADBCC";
////应用私钥
//Global.inf.privateKey = "cr8HO5r701/d+AsOgxFS2cwtQRF1KMEiw/OR7sddI5M="; //中心邮件下发
////Global.inf.privateKey = "AKyhfvPbT+tIJHJkZSDILrw7t+FOG1U58UcupYYTzCOj"; //中心Demo
////应用公钥
////Global.inf.publicKey = "BKRejz4MwM8G8Krc4hyIIvhphvwrQpnHIsGWTd0sn0TJYr2eKJGAv87AKnrT8pL50H6hdVHdU0FFaL18GApDEbU"; //中心邮件下发
//Global.inf.publicKey = "BIRfPWjNpLsi3lZ6H91EfG6p09L0mmLZMNMjt/jcn8P9L5peCheEgxMtPe+dNtzhQ9x40xxi6lD3Q0xA31/hXFE="; //中心Demo
////Global.inf.cardURL = "http://10.126.105.66/hsa-hgs-adapt/api/card/initDll"; //测试环境
//Global.inf.presCenterURL = "http://10.49.24.54:8080/epc/api";
#endregion
#region【正式环境】
// //应用ID密钥id
Global.inf.appId = "CBBDEB9E72BC42D1A4C20A3206B1E6F4";
// //应用秘钥密钥key
Global.inf.Secret = "025631D740774B838C3CBAD1199514A7";
//应用私钥定点医药机构私钥
Global.inf.privateKey = "ArOPNBtbxNQrNNwvO/YUhn43UR9Bjp24E/C/PgYs5dE=";
// //应用公钥 医保电子处方中心公钥
Global.inf.publicKey = "BHTbGNrSN9jgidrQY8C57RvcAlAZu1N2cgX88P3mOFvNibSa0wpmEWiyisSXblp/bp/DfaXdTjw/LKZMt8yxN0Y=";
Global.inf.presCenterURL = "http://10.49.24.194:8080/epc/api";
#endregion
Global.writeLog("密钥id:" + Global.inf.appId);
Global.writeLog("密钥key:" + Global.inf.Secret);
Global.writeLog("定点医药机构私钥:" + Global.inf.privateKey);
Global.writeLog("医保电子处方中心公钥:" + Global.inf.publicKey);
//Global.curEvt.msgid = Global.inf.hospitalNO + DateTime.Now.ToString("yyyyMMddHHmmssffff");
string timestamp = ((long)(DateTime.UtcNow - new DateTime(1970, 1, 1, 0, 0, 0, DateTimeKind.Utc)).TotalMilliseconds).ToString();
Global.curEvt.msgid = timestamp;
JObject requestData = new JObject();
requestData.Add("appId", Global.inf.appId);
//requestData.Add("version", "2.0.1");
requestData.Add("encType", "SM4");
requestData.Add("signType", "SM2");
requestData.Add("timestamp", timestamp);
//加密
String encData = SMUtil.encrypt(JsonConvert.SerializeObject(data, Formatting.None), Global.inf.appId, Global.inf.Secret);
//Global.writeLog("入参加密前:" + "\r\n" + JsonConvert.DeserializeObject(data.ToString()) + "\r\n" + "入参加密后:" + "\r\n" + encData);
JObject signDto = (JObject)JObject.Parse(JsonConvert.SerializeObject(requestData, Formatting.None));
signDto.Add("data", data);
//加签
String signData = SMUtil.sign(signDto, Global.inf.Secret, Global.inf.privateKey);
Global.writeLog("签名结果:" + "\r\n" + signData);
//报文
requestData.Add("encData", encData);
requestData.Add("signData", signData);
dynamic Jo = new JObject();
Jo.appId = Global.inf.appId;
//Jo.version = "2.0.1";
Jo.timestamp = timestamp;
Jo.encType = "SM4";
Jo.signType = "SM2";
Jo.signData = signDto.ToString();
Jo.encData = data.ToString();
Global.writeLog(data.ToString());
Global.writeLog("加密前报文:" + "\r\n" + Jo.ToString() + "\r\n" + "加密后报文:" + "\r\n" + JsonConvert.SerializeObject(requestData, Formatting.None));
//本地解密
//String decData = SMUtil.decrypt(encData, Global.inf.appId, Global.inf.Secret);
//Global.writeLog("解密:" + decData);
//使用应用公钥(publicKey示例默认值)对本地自签名的数据进行验签示例
//Boolean isVerify = SMUtil.verify(signDto, Global.inf.Secret, Global.inf.publicKey, signData);
//Global.writeLog("验签:" + isVerify);
return requestData.ToString();
}
///
/// 解析中心返参
///
///
///
///
public static int parseCenterRtnValuePresCir(JObject joRtn, out string errorMsg)
{
try
{
string errcode = getDestValue(joRtn, "errcode");
string errorCode = getDestValue(joRtn, "errorCode");
if (errcode != "")
{
errorMsg = getDestValue(joRtn, "message");
return -1;
}
else if (errorCode != "")
{
errorMsg = getDestValue(joRtn, "errorMessage");
return -2;
}
else
{
errorMsg = getDestValue(joRtn, "message");
return int.Parse(getDestValue(joRtn, "code"));
}
}
catch (Exception ex)
{
errorMsg = "解析中心返参发生异常:" + ex.Message;
return -1;
}
}
#endregion
}
}