JsonHelper.cs 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393
  1. /******************************************************************************
  2. * 文件名称: JsonHelper.cs
  3. * 文件说明: Json业务的封装,处理JSON串的封装,解析等
  4. * 当前版本: V1.0
  5. * 创建日期: 2022-04-14
  6. *
  7. * 2020-04-14: 增加 getIrisServiceInparamBaseJson 方法
  8. * 2020-04-14: 增加 getIrisServiceInparamBaseJson(重载) 方法
  9. * 2020-04-14: 增加 getIrisExceptionJson 方法
  10. * 2020-04-14: 增加 parseBusinessJson 方法
  11. ******************************************************************************/
  12. using Newtonsoft.Json.Linq;
  13. using System;
  14. using System.Collections.Generic;
  15. using System.Linq;
  16. using System.Text;
  17. using System.Threading.Tasks;
  18. using PTMedicalInsurance.Common;
  19. using System.IO;
  20. using PTMedicalInsurance.Variables;
  21. namespace PTMedicalInsurance.Helper
  22. {
  23. class JsonHelper
  24. {
  25. /// <summary>
  26. /// 根据JSonPath查找节点值,如果节点不存在则返回空值
  27. /// </summary>
  28. /// <param name="jo"></param>
  29. /// <param name="jsonPath"></param>
  30. /// <returns></returns>
  31. public static string getDestValue(JObject jo, string destPath)
  32. {
  33. JToken jt = jo.SelectToken("$." + destPath);
  34. if (jt != null)
  35. {
  36. return jt.ToString();
  37. }
  38. else
  39. {
  40. //Global.writeLog(destPath + "的JToken属性值为空");
  41. return "";
  42. }
  43. }
  44. public static decimal getDecimalFee(JObject jo, string path)
  45. {
  46. try
  47. {
  48. string temp = JsonHelper.getDestValue(jo, path);
  49. if (temp == "")
  50. {
  51. return 0;
  52. }
  53. else
  54. {
  55. return decimal.Parse(temp);
  56. }
  57. }
  58. catch (Exception ex)
  59. {
  60. Global.writeLog("getFee异常:" + ex.Message);
  61. return 0;
  62. }
  63. }
  64. public static string getDestProperty(JObject jo, string propertyName)
  65. {
  66. JProperty jp = jo.Property(propertyName);
  67. if (jp != null)
  68. {
  69. string jpStr = jp.ToString();
  70. string rtnResult = "{ " + jpStr + "}";
  71. return rtnResult;
  72. }
  73. else
  74. {
  75. Global.writeLog(propertyName + "的JProperty属性值为空");
  76. return "";
  77. }
  78. }
  79. /// <summary>
  80. /// 压缩JSON,占用体积减小(重载)
  81. /// </summary>
  82. /// <param name="json"></param>
  83. /// <returns></returns>
  84. public static string Compress(string json)
  85. {
  86. StringBuilder sb = new StringBuilder();
  87. using (StringReader reader = new StringReader(json))
  88. {
  89. int ch = -1;
  90. int lastch = -1;
  91. bool isQuoteStart = false;
  92. while ((ch = reader.Read()) > -1)
  93. {
  94. if ((char) lastch != '\\' && (char) ch == '\"')
  95. {
  96. if (!isQuoteStart)
  97. {
  98. isQuoteStart = true;
  99. }
  100. else
  101. {
  102. isQuoteStart = false;
  103. }
  104. }
  105. if (!Char.IsWhiteSpace((char) ch) || isQuoteStart)
  106. {
  107. sb.Append((char) ch);
  108. }
  109. lastch = ch;
  110. }
  111. }
  112. return sb.ToString();
  113. }
  114. public static string Compress(JObject jsonObj)
  115. {
  116. //https://blog.csdn.net/yangjiaosun/article/details/103717256
  117. return Newtonsoft.Json.JsonConvert.SerializeObject(jsonObj);
  118. }
  119. /// <summary>
  120. /// 组织异常JSON串
  121. /// </summary>
  122. /// <param name="errorCode"></param>
  123. /// <param name="errorMessage"></param>
  124. /// <returns></returns>
  125. public static JObject setExceptionJson(int errorCode, string eventName, string errorMessage)
  126. {
  127. dynamic joRtn = new JObject();
  128. joRtn.errorCode = errorCode;
  129. joRtn.errorMessage = eventName + "提示:" + errorMessage;
  130. return joRtn;
  131. }
  132. /// <summary>
  133. /// 组织中心入参(明文)。部分代码是需要解析明文入参的,为了方便增加该方法
  134. /// </summary>
  135. /// <param name="infno"></param>
  136. /// <param name="input"></param>
  137. /// <returns></returns>
  138. public static string setCenterInpar_plain(string infno, string input)
  139. {
  140. dynamic Jo = new JObject();
  141. Jo.infno = infno;
  142. Global.curEvt.msgid = Global.inf.hospitalNO + DateTime.Now.ToString("yyyyMMddHHmmssffff");
  143. Jo.msgid = Global.curEvt.msgid;
  144. Jo.mdtrtarea_admvs = Global.inf.areaCode;
  145. Jo.insuplc_admdvs = Global.pat.insuplc_admdvs;
  146. Jo.recer_sys_code = Global.inf.recivedSystem;
  147. Jo.dev_safe_info = Global.inf.dev_safe_info; //设备编号
  148. Jo.cainfo = Global.inf.cainfo;//设备安全信息
  149. Jo.signtype = Global.inf.signatureType; ;
  150. Jo.infver = Global.inf.version; ;
  151. Jo.opter_type = Global.user.type; ;
  152. Jo.opter = Global.user.ID; ;
  153. Jo.opter_name = Global.user.name; ;
  154. Jo.inf_time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  155. Jo.fixmedins_code = Global.inf.hospitalNO;
  156. Jo.fixmedins_name = Global.inf.hospitalName;
  157. Jo.sign_no = Global.curEvt.signno;
  158. JObject joInput = (JObject)Newtonsoft.Json.JsonConvert.DeserializeObject(input);
  159. Jo.Add("input", JObject.FromObject(joInput));
  160. return Jo.ToString();
  161. }
  162. /// <summary>
  163. /// 组织中心入参
  164. /// </summary>
  165. /// <param name="infno"></param>
  166. /// <param name="input"></param>
  167. /// <returns></returns>
  168. public static string setCenterInpar(string infno, string input)
  169. {
  170. dynamic Jo = new JObject();
  171. Jo.infno = infno;
  172. Global.curEvt.msgid = Global.inf.hospitalNO + DateTime.Now.ToString("yyyyMMddHHmmssffff");
  173. Jo.msgid = Global.curEvt.msgid;
  174. Jo.mdtrtarea_admvs = Global.inf.areaCode;
  175. Jo.insuplc_admdvs = Global.pat.insuplc_admdvs;
  176. Jo.recer_sys_code = "ims";
  177. Jo.dev_safe_info = Global.inf.dev_safe_info; //设备编号
  178. Jo.cainfo = Global.inf.cainfo;//
  179. Jo.signtype = ""; ;
  180. Jo.infver = "v1.0";
  181. Jo.opter_type = Global.user.type; ;
  182. Jo.opter = Global.user.ID; ;
  183. Jo.opter_name = Global.user.name; ;
  184. Jo.inf_time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  185. Jo.fixmedins_code = Global.inf.hospitalNO;
  186. Jo.fixmedins_name = Global.inf.hospitalName;
  187. Jo.sign_no = Global.curEvt.signno;
  188. JObject joInput = (JObject)Newtonsoft.Json.JsonConvert.DeserializeObject(input);
  189. Jo.cainfo = "";
  190. Jo.Add("input", JObject.FromObject(joInput));
  191. return Jo.ToString();
  192. }
  193. /// <summary>
  194. /// 组织Iris入参
  195. /// </summary>
  196. /// <param name="code"></param>
  197. /// <param name="joParam"></param>
  198. /// <returns></returns>
  199. public static JObject setIrisInpar(string code, JObject joParam)
  200. {
  201. try
  202. {
  203. dynamic joInparam = new JObject();
  204. joInparam.code = code;
  205. joInparam.interfaceDr = Global.inf.interfaceDr;
  206. joInparam.HospitalDr = Global.inf.hospitalDr;
  207. dynamic joTmp = new JObject();
  208. JArray jaParam = new JArray();
  209. jaParam.Add(joParam);
  210. joInparam.Add("params", JArray.FromObject(jaParam));
  211. joInparam.Add("session", Global.curEvt.jaSession);
  212. return joInparam;
  213. }
  214. catch (Exception ex)
  215. {
  216. return setExceptionJson(-1, "setIrisInpar:", ex.Message);
  217. }
  218. }
  219. /// <summary>
  220. /// 组织Iris入参
  221. /// </summary>
  222. /// <param name="code"></param>
  223. /// <param name="joParam"></param>
  224. /// <returns></returns>
  225. public static JObject setIrisInpar(string code, JArray jaParams)
  226. {
  227. try
  228. {
  229. dynamic joInparam = new JObject();
  230. joInparam.code = code;
  231. dynamic joTmp = new JObject();
  232. joInparam.Add("HospitalDr", Global.inf.hospitalDr);
  233. joInparam.Add("InterfaceDr", Global.inf.interfaceDr);
  234. joInparam.Add("params", jaParams);
  235. joInparam.Add("session", Global.curEvt.jaSession);
  236. return joInparam;
  237. }
  238. catch (Exception ex)
  239. {
  240. return setExceptionJson(-1, "setIrisInpar:", ex.Message);
  241. }
  242. }
  243. /// <summary>
  244. /// 解析中心返参
  245. /// </summary>
  246. /// <param name="joRtn"></param>
  247. /// <param name="errorMsg"></param>
  248. /// <returns></returns>
  249. public static int parseCenterRtnValue(JObject joRtn, out string errorMsg)
  250. {
  251. try
  252. {
  253. string errcode = "";
  254. string errorCode = "";
  255. string code = "";
  256. if (joRtn["code"] != null)
  257. {
  258. code = getDestValue(joRtn, "code");
  259. }
  260. if (joRtn["errcode"] != null)
  261. {
  262. errcode = getDestValue(joRtn, "errcode");
  263. }
  264. if (joRtn["errorCode"] != null)
  265. {
  266. errorCode = getDestValue(joRtn, "errorCode");
  267. }
  268. if (errcode != "")
  269. {
  270. errorMsg = getDestValue(joRtn, "errmsg");
  271. return -1;
  272. }
  273. else if (errorCode != "")
  274. {
  275. errorMsg = getDestValue(joRtn, "errorMessage");
  276. return -2;
  277. }
  278. else if (code != "")
  279. {
  280. errorMsg = getDestValue(joRtn, "message");
  281. return -3;
  282. }
  283. else
  284. {
  285. errorMsg = getDestValue(joRtn, "err_msg");
  286. return int.Parse(getDestValue(joRtn, "infcode"));
  287. }
  288. }
  289. catch (Exception ex)
  290. {
  291. errorMsg = "解析中心返参发生异常:" + ex.Message;
  292. return -1;
  293. }
  294. }
  295. /// <summary>
  296. /// 解析中心返参
  297. /// </summary>
  298. /// <param name="joRtn"></param>
  299. /// <param name="errorMsg"></param>
  300. /// <returns></returns>
  301. public static int parseMPRtnValue(JObject joRtn, out string errorMsg)
  302. {
  303. try
  304. {
  305. string errcode = "";
  306. string errorCode = "";
  307. string code = "";
  308. if (joRtn["code"] != null)
  309. {
  310. code = getDestValue(joRtn, "code");
  311. if (code == "0")
  312. errorMsg = getDestValue(joRtn, "encData");
  313. else
  314. errorMsg = getDestValue(joRtn, "message");
  315. }
  316. else
  317. {
  318. errorMsg = "JSON格式不正确!";
  319. code = "-1";
  320. }
  321. return int.Parse(code);
  322. }
  323. catch (Exception ex)
  324. {
  325. errorMsg = "解析中心返参发生异常:" + ex.Message;
  326. return -1;
  327. }
  328. }
  329. /// <summary>
  330. /// 组织IRIS返参
  331. /// </summary>
  332. /// <param name="errorCode"></param>
  333. /// <param name="errorMessage"></param>
  334. /// <param name="joResult"></param>
  335. /// <returns></returns>
  336. public static JObject setIrisReturnValue(int errorCode, string errorMessage, JObject joResult)
  337. {
  338. try
  339. {
  340. dynamic joRtn = new JObject();
  341. joRtn.errorCode = errorCode;
  342. joRtn.errorMessage = errorMessage;
  343. joRtn.Add("result", joResult);
  344. return joRtn;
  345. }
  346. catch (Exception ex)
  347. {
  348. return setExceptionJson(-1, "setIrisReturnValue:", ex.Message);
  349. }
  350. }
  351. /// <summary>
  352. /// 解析IRIS返参
  353. /// </summary>
  354. /// <param name="joRtn"></param>
  355. /// <param name="errorMsg"></param>
  356. /// <returns></returns>
  357. public static int parseIrisRtnValue(JObject joRtn, out string errorMsg)
  358. {
  359. try
  360. {
  361. errorMsg = getDestValue(joRtn, "errorMessage");
  362. return int.Parse(getDestValue(joRtn, "errorCode"));
  363. }
  364. catch (Exception ex)
  365. {
  366. errorMsg = "解析Iris返参发生异常:" + ex.Message;
  367. return -1;
  368. }
  369. }
  370. }
  371. }