JsonHelper.cs 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588
  1. /******************************************************************************
  2. * 文件名称: JsonHelper.cs
  3. * 文件说明: Json业务的封装,处理JSON串的封装,解析等
  4. * 当前版本: V1.0
  5. * 创建日期: 2022-04-14
  6. *
  7. * 2020-04-14: 增加 setIrisInpar 方法
  8. * 2020-04-14: 增加 setIrisInpar(重载) 方法
  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. using Newtonsoft.Json;
  22. using GMCrypto.Lib;
  23. namespace PTMedicalInsurance.Helper
  24. {
  25. public class JsonHelper
  26. {
  27. static EncryptHelper encrypt = new EncryptHelper();
  28. public static string toJsonString(object obj,bool missingNull)
  29. {
  30. JsonSerializerSettings settings = new JsonSerializerSettings();
  31. if (missingNull)
  32. {
  33. settings.NullValueHandling = NullValueHandling.Ignore;
  34. }
  35. return JsonConvert.SerializeObject(obj, Formatting.Indented, settings);
  36. }
  37. public static string toJsonString(object obj)
  38. {
  39. return toJsonString(obj,true);
  40. }
  41. public static JObject toJObject(object obj)
  42. {
  43. string data = toJsonString(obj, true);
  44. return JObject.Parse(data);
  45. }
  46. public static object toObject(string json)
  47. {
  48. return JsonConvert.DeserializeObject(json);
  49. }
  50. public static T toObject<T>(JObject joObject)
  51. {
  52. return joObject.ToObject<T>();
  53. }
  54. /// <summary>
  55. /// 解析医保平台返回对象
  56. /// </summary>
  57. /// <typeparam name="T"></typeparam>
  58. /// <param name="response"></param>
  59. /// <returns></returns>
  60. public static T getOutput<T>(JObject response)
  61. {
  62. if (response.ContainsKey("output"))
  63. {
  64. return response["output"].ToObject<T>();
  65. }
  66. return response.ToObject<T>();
  67. }
  68. /// <summary>
  69. /// 解析IRIS系统返回对象
  70. /// </summary>
  71. /// <typeparam name="T"></typeparam>
  72. /// <param name="response"></param>
  73. /// <returns></returns>
  74. public static T getResult<T>(JObject response)
  75. {
  76. Response resp = response.ToObject<Response>();
  77. if (resp.errorCode == "0")
  78. {
  79. if (resp.result?.GetType() == typeof(JObject))
  80. {
  81. JObject ret = (JObject)resp.result;
  82. JArray lists = ret.Value<JArray>("rows");
  83. if (lists?.Count > 0)
  84. {
  85. return lists.ToObject<T>();
  86. }
  87. else {
  88. return ret.ToObject<T>();
  89. }
  90. }
  91. if (resp.result?.GetType() == typeof(JArray))
  92. {
  93. JArray lists = (JArray)resp.result;
  94. if (lists?.Count > 0)
  95. {
  96. return lists[0].ToObject<T>();
  97. }
  98. }
  99. }
  100. return default;
  101. }
  102. /// <summary>
  103. /// 根据JSonPath查找节点值,如果节点不存在则返回空值
  104. /// </summary>
  105. /// <param name="jo"></param>
  106. /// <param name="jsonPath"></param>
  107. /// <returns></returns>
  108. public static string getDestValue(JObject jo, string destPath)
  109. {
  110. JToken jt = jo.SelectToken("$." + destPath);
  111. if (jt != null)
  112. {
  113. return jt.ToString();
  114. }
  115. else
  116. {
  117. Global.writeLog(destPath + "的JToken属性值为空");
  118. return "";
  119. }
  120. }
  121. /// <summary>
  122. /// 将指定的json内容转为对象
  123. /// </summary>
  124. /// <typeparam name="T"></typeparam>
  125. /// <param name="jo"></param>
  126. /// <param name="destPath"></param>
  127. /// <returns></returns>
  128. public static T parseObject<T>(JObject jo, string destPath)
  129. {
  130. JToken jt = jo.SelectToken("$." + destPath);
  131. if (jt != null)
  132. {
  133. return jt.ToObject<T>();
  134. }
  135. else
  136. {
  137. Global.writeLog(destPath + "的JToken属性值为空");
  138. return default;
  139. }
  140. }
  141. public static string getDestProperty(JObject jo, string propertyName)
  142. {
  143. JProperty jp = jo.Property(propertyName);
  144. if (jp != null)
  145. {
  146. string jpStr = jp.ToString();
  147. string rtnResult = "{ " + jpStr + "}";
  148. return rtnResult;
  149. }
  150. else
  151. {
  152. Global.writeLog(propertyName + "的JProperty属性值为空");
  153. return "";
  154. }
  155. }
  156. /// <summary>
  157. /// 压缩JSON,占用体积减小(重载)
  158. /// </summary>
  159. /// <param name="json"></param>
  160. /// <returns></returns>
  161. public static string Compress(string json)
  162. {
  163. StringBuilder sb = new StringBuilder();
  164. using (StringReader reader = new StringReader(json))
  165. {
  166. int ch = -1;
  167. int lastch = -1;
  168. bool isQuoteStart = false;
  169. while ((ch = reader.Read()) > -1)
  170. {
  171. if ((char) lastch != '\\' && (char) ch == '\"')
  172. {
  173. if (!isQuoteStart)
  174. {
  175. isQuoteStart = true;
  176. }
  177. else
  178. {
  179. isQuoteStart = false;
  180. }
  181. }
  182. if (!Char.IsWhiteSpace((char) ch) || isQuoteStart)
  183. {
  184. sb.Append((char) ch);
  185. }
  186. lastch = ch;
  187. }
  188. }
  189. return sb.ToString();
  190. }
  191. public static string Compress(JObject jsonObj)
  192. {
  193. //https://blog.csdn.net/yangjiaosun/article/details/103717256
  194. return Newtonsoft.Json.JsonConvert.SerializeObject(jsonObj);
  195. }
  196. /// <summary>
  197. /// 组织异常JSON串
  198. /// </summary>
  199. /// <param name="errorCode"></param>
  200. /// <param name="errorMessage"></param>
  201. /// <returns></returns>
  202. public static JObject setExceptionJson(int errorCode, string eventName, string errorMessage)
  203. {
  204. dynamic joRtn = new JObject();
  205. joRtn.errorCode = errorCode;
  206. joRtn.errorMessage = eventName + "提示:" + errorMessage;
  207. return joRtn;
  208. }
  209. /// <summary>
  210. /// 组织中心入参(明文)。部分代码是需要解析明文入参的,为了方便增加该方法
  211. /// </summary>
  212. /// <param name="infno"></param>
  213. /// <param name="input"></param>
  214. /// <returns></returns>
  215. public static string setCenterInpar_plain(string infno, string input)
  216. {
  217. return setCenterInpar_plain(infno, (JObject)Newtonsoft.Json.JsonConvert.DeserializeObject(input));
  218. }
  219. /// <summary>
  220. /// 组织中心入参(明文)。部分代码是需要解析明文入参的,为了方便增加该方法
  221. /// </summary>
  222. /// <param name="infno"></param>
  223. /// <param name="input"></param>
  224. /// <returns></returns>
  225. public static string setCenterInpar_plain(string infno, JObject joInput)
  226. {
  227. return setCenterInpar(infno, joInput);
  228. }
  229. /// <summary>
  230. /// 移动支付组织中心入参
  231. /// </summary>
  232. /// <param name="infno"></param>
  233. /// <param name="input"></param>
  234. /// <returns></returns>
  235. public static string setMPCenterInpar(string infno, JObject joInput)
  236. {
  237. return setMPCenterInpar(infno, joInput.ToString());
  238. }
  239. /// <summary>
  240. /// 移动支付组织中心入参
  241. /// </summary>
  242. /// <param name="infno"></param>
  243. /// <param name="input"></param>
  244. /// <returns></returns>
  245. public static string setMPCenterInpar(string infno, string txtData)
  246. {
  247. EncryptHelper encrypt = new EncryptHelper();
  248. string plainText = SignUtil.SortInput(JObject.Parse(txtData));
  249. Global.writeLog(infno + "【明文入参】:\r\n" + plainText);
  250. string signData = "";
  251. string output = encrypt.encrypt(txtData, ref signData);
  252. Global.writeLog(infno + "【密文入参】:\r\n" + output);
  253. return output;
  254. }
  255. /// <summary>
  256. /// 银海安全组件调用参数
  257. /// </summary>
  258. /// <param name="funNO"></param>
  259. /// <returns></returns>
  260. public static JObject setYinHaiSafe(string funNO)
  261. {
  262. string business_type = Global.businessType;
  263. JObject joInput = new JObject();
  264. dynamic joData = new JObject();
  265. joData.fixmedins_code = Global.inf.hospitalNO;
  266. joData.psn_no = Global.pat.psn_no;
  267. joData.mdtrtarea_admvs = Global.inf.areaCode;
  268. joData.local_type = "3";
  269. joData.out_type = "2";
  270. joData.opter = Global.user.ID;
  271. joData.opter_name = Global.user.name;
  272. joData.office = Global.user.officeID;
  273. joData.office_name = Global.user.officeName;
  274. joData.business_type = business_type;
  275. joData.device_type = "";
  276. joInput["data"] = JObject.FromObject(joData);
  277. joInput["tran_no"] = funNO;
  278. joInput["tran_time"] = DateTime.Now.ToString("yyyyMMddHHMMss");
  279. Global.writeLog(joInput.ToString());
  280. return joInput;
  281. }
  282. public static string setCenterInpar(string infno, JObject joInput)
  283. {
  284. dynamic Jo = new JObject();
  285. Jo.infno = infno;
  286. Global.curEvt.msgid = Global.inf.hospitalNO + DateTime.Now.ToString("yyyyMMddHHmmssffff");
  287. Jo.msgid = Global.curEvt.msgid;
  288. Global.pat.mdtrtarea_admvs = Global.inf.areaCode;
  289. // 参保地医保区划
  290. Jo.insuplc_admdvs = Global.pat.insuplc_admdvs??"";
  291. // 就医地
  292. Jo.mdtrtarea_admvs = Global.pat.mdtrtarea_admvs;
  293. string infTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  294. Jo.recer_sys_code = "SY";
  295. Jo.dev_no = "00FFF254308F";//设备编号
  296. Jo.dev_safe_info = "";
  297. Jo.signtype = "SM3withSM2"; ;
  298. Jo.infver = "v1.0";
  299. Jo.opter_type = Global.user.type ;
  300. Jo.opter = Global.user.ID ;
  301. Jo.opter_name = Global.user.name ;
  302. Jo.inf_time = infTime;
  303. Jo.fixmedins_code = Global.inf.hospitalNO;
  304. Jo.fixmedins_name = Global.inf.hospitalName;
  305. Jo.sign_no = Global.curEvt.signno;
  306. Jo.cainfo = "";
  307. if (joInput != null)
  308. {
  309. if (!Utils.LoadEncyptFlag(infno))
  310. {
  311. Jo.Add("input", JObject.FromObject(joInput));
  312. }
  313. else
  314. {
  315. //新增加密
  316. try
  317. {
  318. YinHaiEncrypt yhEncrypt = new YinHaiEncrypt();
  319. string caInfoSource = BuildCaInfo(infno, joInput.ToString(), infTime);
  320. Global.inf.cainfo = Global.inf.hospitalNO + "|104|" + yhEncrypt.Signature(caInfoSource);
  321. string encryptInput = yhEncrypt.Encrypt(joInput.ToString());
  322. Jo.cainfo = Global.inf.cainfo;
  323. Jo.input = encryptInput;
  324. }
  325. catch (Exception ex)
  326. {
  327. Global.writeLog("加密异常:"+ex.Message);
  328. }
  329. }
  330. }
  331. else
  332. {
  333. Jo.Add("input", "");
  334. }
  335. var request = Utils.Wrapper(Jo);
  336. return JsonHelper.toJsonString(request);
  337. }
  338. public static string BuildCaInfo(string infno, string input,string infTime)
  339. {
  340. string s = infno;
  341. s = s + "|" + Global.curEvt.msgid;
  342. s = s + "|" + Global.inf.areaCode;
  343. s = s + "|" + Global.pat.insuplc_admdvs;
  344. s = s + "|" + Global.inf.version;
  345. s = s + "|" + infTime;
  346. s = s + "|" + Global.inf.hospitalNO;
  347. s = s + "|" + Global.curEvt.signno;
  348. s = s + "|" + input.Trim();
  349. return s;
  350. }
  351. /// <summary>
  352. /// 组织Iris入参
  353. /// </summary>
  354. /// <param name="code"></param>
  355. /// <param name="joParam"></param>
  356. /// <returns></returns>
  357. public static JObject setIrisInpar(string code, JObject joParam)
  358. {
  359. try
  360. {
  361. dynamic joInparam = new JObject();
  362. joInparam.code = code;
  363. dynamic joTmp = new JObject();
  364. JArray jaParam = new JArray();
  365. // 去掉包装
  366. JObject joInput = Utils.removeWrapper(joParam);
  367. jaParam.Add(joInput);
  368. joInparam.Add("params", JArray.FromObject(jaParam));
  369. joInparam.Add("session", Global.curEvt.jaSession);
  370. return joInparam;
  371. }
  372. catch (Exception ex)
  373. {
  374. return setExceptionJson(-1, "setIrisInpar:", ex.Message);
  375. }
  376. }
  377. /// <summary>
  378. /// 组织Iris入参
  379. /// </summary>
  380. /// <param name="code"></param>
  381. /// <param name="joParam"></param>
  382. /// <returns></returns>
  383. public static JObject setIrisInpar(string code, JArray jaParams)
  384. {
  385. try
  386. {
  387. dynamic joInparam = new JObject();
  388. joInparam.code = code;
  389. dynamic joTmp = new JObject();
  390. joInparam.Add("params", jaParams);
  391. joInparam.Add("session", Global.curEvt.jaSession);
  392. return joInparam;
  393. }
  394. catch (Exception ex)
  395. {
  396. return setExceptionJson(-1, "setIrisInpar:", ex.Message);
  397. }
  398. }
  399. /// <summary>
  400. /// 解析中心返参
  401. /// </summary>
  402. /// <param name="joRtn"></param>
  403. /// <param name="errorMsg"></param>
  404. /// <returns></returns>
  405. public static int parseCenterRtnValue(JObject joRtn, out string errorMsg)
  406. {
  407. try
  408. {
  409. string errcode = getDestValue(joRtn, "errcode");
  410. string errorCode = getDestValue(joRtn, "errorCode");
  411. string resultCode = getDestValue(joRtn, "resultcode");
  412. if (!string.IsNullOrEmpty(errcode))
  413. {
  414. errorMsg = getDestValue(joRtn, "errmsg");
  415. return -1;
  416. }
  417. else if (!string.IsNullOrEmpty(errorCode))
  418. {
  419. errorMsg = getDestValue(joRtn, "errorMessage");
  420. return -2;
  421. }
  422. else if (!string.IsNullOrEmpty(resultCode))
  423. {
  424. errorMsg = getDestValue(joRtn, "resulttext");
  425. return -3;
  426. }
  427. else
  428. {
  429. errorMsg = getDestValue(joRtn, "err_msg");
  430. return int.Parse(getDestValue(joRtn, "infcode"));
  431. }
  432. }
  433. catch (Exception ex)
  434. {
  435. errorMsg = "解析中心返参发生异常:" + ex.Message;
  436. return -1;
  437. }
  438. }
  439. /// <summary>
  440. /// 解析移动返参
  441. /// </summary>
  442. /// <param name="joRtn"></param>
  443. /// <param name="errorMsg"></param>
  444. /// <returns></returns>
  445. public static int parseMPRtnValue(JObject joRtn, out string errorMsg)
  446. {
  447. try
  448. {
  449. string success = getDestValue(joRtn, "success");
  450. string message = getDestValue(joRtn, "message");
  451. string encData = getDestValue(joRtn, "encData");
  452. if (string.IsNullOrEmpty(message)) {
  453. message = getDestValue(joRtn, "errorMessage");
  454. }
  455. //Global.writeLog("success:" + success);
  456. if (success != "True")
  457. {
  458. errorMsg = message;
  459. return -1;
  460. }
  461. else
  462. {
  463. errorMsg = joRtn.ToString();
  464. return 0;
  465. }
  466. }
  467. catch (Exception ex)
  468. {
  469. errorMsg = "解析中心返参发生异常:" + ex.Message;
  470. return -1;
  471. }
  472. }
  473. /// <summary>
  474. /// 组织IRIS返参
  475. /// </summary>
  476. /// <param name="errorCode"></param>
  477. /// <param name="errorMessage"></param>
  478. /// <param name="joResult"></param>
  479. /// <returns></returns>
  480. public static JObject setIrisReturnValue(int errorCode, string errorMessage, JObject joResult)
  481. {
  482. try
  483. {
  484. dynamic joRtn = new JObject();
  485. joRtn.errorCode = errorCode;
  486. joRtn.errorMessage = errorMessage;
  487. joRtn.Add("result", joResult);
  488. return joRtn;
  489. }
  490. catch (Exception ex)
  491. {
  492. return setExceptionJson(-1, "setIrisReturnValue:", ex.Message);
  493. }
  494. }
  495. /// <summary>
  496. /// 解析IRIS返参
  497. /// </summary>
  498. /// <param name="joRtn"></param>
  499. /// <param name="errorMsg"></param>
  500. /// <returns></returns>
  501. ///
  502. public static int parseIrisRtnValue(JObject joRtn, out string errorMsg)
  503. {
  504. try
  505. {
  506. errorMsg = getDestValue(joRtn, "errorMessage");
  507. return int.Parse(getDestValue(joRtn, "errorCode"));
  508. }
  509. catch (Exception ex)
  510. {
  511. errorMsg = "解析Iris返参发生异常:" + ex.Message;
  512. return -1;
  513. }
  514. }
  515. /// <summary>
  516. /// 解析业务JSON串(业务串固定格式为{errorCode = ,errorMessage = ,result ={}})
  517. /// </summary>
  518. /// <param name="json"></param>
  519. /// <param name="errorMsg"></param>
  520. /// <returns></returns>
  521. public static int parseCenterReturnJson(JObject json, out string errorMsg)
  522. {
  523. try
  524. {
  525. errorMsg = "";
  526. if (int.Parse(json["infcode"].ToString()) != 0)
  527. {
  528. errorMsg = json["err_msg"].ToString();
  529. }
  530. return int.Parse(json["infcode"].ToString());
  531. }
  532. catch (Exception ex)
  533. {
  534. errorMsg = "parseCenterReturnJson" + ex.Message;
  535. return -1;
  536. }
  537. }
  538. }
  539. }