JsonHelper.cs 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925
  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;
  13. using Newtonsoft.Json.Linq;
  14. using Org.BouncyCastle.Asn1.Ocsp;
  15. using PTMedicalInsurance.Common;
  16. using PTMedicalInsurance.Common.SMLib;
  17. using PTMedicalInsurance.Entity;
  18. using PTMedicalInsurance.Variables;
  19. using SM2Crypto.Lib;
  20. using System;
  21. using System.Collections.Generic;
  22. using System.IO;
  23. using System.Linq;
  24. using System.Net;
  25. using System.Text;
  26. using System.Threading.Tasks;
  27. using System.Windows.Forms;
  28. namespace PTMedicalInsurance.Helper
  29. {
  30. class JsonHelper
  31. {
  32. private string serviceURL;
  33. private string authorization;
  34. public static string toJsonString(object obj, bool missingNull)
  35. {
  36. JsonSerializerSettings settings = new JsonSerializerSettings();
  37. if (missingNull)
  38. {
  39. settings.NullValueHandling = NullValueHandling.Ignore;
  40. }
  41. return JsonConvert.SerializeObject(obj, Formatting.Indented, settings);
  42. }
  43. public static string toJsonString(object obj)
  44. {
  45. return toJsonString(obj, true);
  46. }
  47. public static T toObject<T>(JObject joObject)
  48. {
  49. return joObject.ToObject<T>();
  50. }
  51. /// <summary>
  52. /// iris服务调用的封装
  53. /// </summary>
  54. /// <param name="data"></param>
  55. /// <returns></returns>
  56. public JObject invokeIrisService(string data, string serviceDesc)
  57. {
  58. string rtn = "", url = "";
  59. JObject joRtn = new JObject();
  60. try
  61. {
  62. //先根据用户请求的uri构造请求地址
  63. url = serviceURL;
  64. ServicePointManager.ServerCertificateValidationCallback = delegate { return true; };
  65. ServicePointManager.SecurityProtocol = SecurityProtocolType.Ssl3 | SecurityProtocolType.Tls12 | SecurityProtocolType.Tls11 | SecurityProtocolType.Tls;
  66. //创建Web访问对象
  67. HttpWebRequest myRequest = (HttpWebRequest)WebRequest.Create(url);
  68. //把用户传过来的数据转成“UTF-8”的字节流
  69. byte[] buf = System.Text.Encoding.GetEncoding("UTF-8").GetBytes(data);
  70. //添加头部信息
  71. myRequest.Method = "POST";
  72. myRequest.ContentLength = buf.Length;
  73. myRequest.ContentType = "application/json";
  74. myRequest.Headers.Add("Authorization", authorization);
  75. myRequest.MaximumAutomaticRedirections = 1;
  76. myRequest.AllowAutoRedirect = true;
  77. //发送请求
  78. Stream stream = myRequest.GetRequestStream();
  79. stream.Write(buf, 0, buf.Length);
  80. stream.Close();
  81. //获取接口返回值
  82. //通过Web访问对象获取响应内容
  83. HttpWebResponse myResponse = (HttpWebResponse)myRequest.GetResponse();
  84. //通过响应内容流创建StreamReader对象,因为StreamReader更高级更快
  85. StreamReader reader = new StreamReader(myResponse.GetResponseStream(), Encoding.UTF8);
  86. //string rtn = HttpUtility.UrlDecode(reader.ReadToEnd());//如果有编码问题就用这个方法
  87. rtn = reader.ReadToEnd();//利用StreamReader就可以从响应内容从头读到尾
  88. reader.Close();
  89. myResponse.Close();
  90. joRtn = JObject.Parse(rtn);
  91. return joRtn;
  92. }
  93. catch (Exception ex)
  94. {
  95. joRtn = JsonHelper.setExceptionJson(-1, serviceDesc, ex.Message);
  96. rtn = JsonConvert.SerializeObject(joRtn);
  97. return joRtn;
  98. }
  99. }
  100. /// <summary>
  101. /// 根据JSonPath查找节点值,如果节点不存在则返回空值
  102. /// </summary>
  103. /// <param name="jo"></param>
  104. /// <param name="jsonPath"></param>
  105. /// <returns></returns>
  106. public static string getDestValue(JObject jo, string destPath)
  107. {
  108. JToken jt = jo.SelectToken("$." + destPath);
  109. if (jt != null)
  110. {
  111. return jt.ToString();
  112. }
  113. else
  114. {
  115. Global.writeLog(destPath + "的JToken属性值为空");
  116. return "";
  117. }
  118. }
  119. /// <summary>
  120. /// 解析医保平台返回对象
  121. /// </summary>
  122. /// <typeparam name="T"></typeparam>
  123. /// <param name="response"></param>
  124. /// <returns></returns>
  125. public static T getOutput<T>(JObject response)
  126. {
  127. if (response.ContainsKey("output"))
  128. {
  129. return response["output"].ToObject<T>();
  130. }
  131. return response.ToObject<T>();
  132. }
  133. /// <summary>
  134. /// 医保平台服务调用的封装
  135. /// </summary>
  136. /// <param name="data"></param>
  137. /// <returns></returns>
  138. public JObject invokeInsuService(string data, string serviceDesc)
  139. {
  140. string rtn = "";
  141. JObject joRtn = new JObject();
  142. try
  143. {
  144. //先根据用户请求的uri构造请求地址
  145. serviceURL = string.Format("{0}/{1}", Global.insuConfig.ip, Global.insuConfig.url);
  146. authorization = Global.insuConfig.authorization;
  147. joRtn = invokeIrisService(data, serviceDesc);
  148. rtn = JsonConvert.SerializeObject(joRtn);
  149. return joRtn;
  150. }
  151. catch (Exception ex)
  152. {
  153. joRtn = JsonHelper.setExceptionJson(-1, serviceDesc, ex.Message);
  154. rtn = JsonConvert.SerializeObject(joRtn);
  155. return joRtn;
  156. }
  157. finally
  158. {
  159. Global.writeLog_Iris(serviceDesc + "(" + serviceURL + ")" + "Authorization:" + (authorization), JsonHelper.Compress(data), rtn);
  160. }
  161. }
  162. public static string getDestProperty(JObject jo, string propertyName)
  163. {
  164. JProperty jp = jo.Property(propertyName);
  165. if (jp != null)
  166. {
  167. string jpStr = jp.ToString();
  168. string rtnResult = "{ " + jpStr + "}";
  169. return rtnResult;
  170. }
  171. else
  172. {
  173. Global.writeLog(propertyName + "的JProperty属性值为空");
  174. return "";
  175. }
  176. }
  177. /// <summary>
  178. /// 压缩JSON,占用体积减小(重载)
  179. /// </summary>
  180. /// <param name="json"></param>
  181. /// <returns></returns>
  182. public static string Compress(string json)
  183. {
  184. StringBuilder sb = new StringBuilder();
  185. using (StringReader reader = new StringReader(json))
  186. {
  187. int ch = -1;
  188. int lastch = -1;
  189. bool isQuoteStart = false;
  190. while ((ch = reader.Read()) > -1)
  191. {
  192. if ((char) lastch != '\\' && (char) ch == '\"')
  193. {
  194. if (!isQuoteStart)
  195. {
  196. isQuoteStart = true;
  197. }
  198. else
  199. {
  200. isQuoteStart = false;
  201. }
  202. }
  203. if (!Char.IsWhiteSpace((char) ch) || isQuoteStart)
  204. {
  205. sb.Append((char) ch);
  206. }
  207. lastch = ch;
  208. }
  209. }
  210. return sb.ToString();
  211. }
  212. public static string Compress(JObject jsonObj)
  213. {
  214. //https://blog.csdn.net/yangjiaosun/article/details/103717256
  215. return Newtonsoft.Json.JsonConvert.SerializeObject(jsonObj);
  216. }
  217. /// <summary>
  218. /// 组织异常JSON串
  219. /// </summary>
  220. /// <param name="errorCode"></param>
  221. /// <param name="errorMessage"></param>
  222. /// <returns></returns>
  223. public static JObject setExceptionJson(int errorCode, string eventName, string errorMessage)
  224. {
  225. dynamic joRtn = new JObject();
  226. joRtn.errorCode = errorCode;
  227. joRtn.errorMessage = eventName + "提示:" + errorMessage;
  228. return joRtn;
  229. }
  230. /// <summary>
  231. /// 组织中心入参(明文)。部分代码是需要解析明文入参的,为了方便增加该方法
  232. /// </summary>
  233. /// <param name="infno"></param>
  234. /// <param name="input"></param>
  235. /// <returns></returns>
  236. public static string setCenterInpar_plain(string infno, string input)
  237. {
  238. dynamic Jo = new JObject();
  239. Jo.infno = infno;
  240. Global.curEvt.msgid = Global.inf.hospitalNO + DateTime.Now.ToString("yyyyMMddHHmmssffff");
  241. Jo.msgid = Global.curEvt.msgid;
  242. //Jo.mdtrtarea_admvs = "419900"; //郑州 市医保、省内异地、跨省异地就医地都传419900
  243. //Global.pat.mdtrtarea_admvs = "419900";
  244. if (Global.pat.insuplc_admdvs == "419900")
  245. {
  246. Jo.mdtrtarea_admvs = "419900"; //郑州 市医保、省内异地、跨省异地就医地都传419900
  247. Global.pat.mdtrtarea_admvs = "419900";
  248. }
  249. else
  250. {
  251. Jo.mdtrtarea_admvs = "410100";
  252. Global.pat.mdtrtarea_admvs = "410100";
  253. }
  254. Jo.insuplc_admdvs = Global.pat.insuplc_admdvs;
  255. Jo.recer_sys_code = Global.inf.recivedSystem;
  256. Jo.dev_safe_info = Global.inf.dev_safe_info; //设备编号
  257. Jo.cainfo = Global.inf.cainfo;//设备安全信息
  258. Jo.signtype = Global.inf.signatureType; ;
  259. Jo.infver = Global.inf.version; ;
  260. Jo.opter_type = Global.user.type; ;
  261. Jo.opter = Global.user.ID; ;
  262. Jo.opter_name = Global.user.name; ;
  263. Jo.inf_time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  264. Jo.fixmedins_code = Global.inf.hospitalNO;
  265. Jo.fixmedins_name = Global.inf.hospitalName;
  266. Jo.sign_no = Global.curEvt.signno;
  267. JObject joInput = (JObject)Newtonsoft.Json.JsonConvert.DeserializeObject(input);
  268. Jo.Add("input", JObject.FromObject(joInput));
  269. return Jo.ToString();
  270. }
  271. /// <summary>
  272. /// 组织中心入参(明文)。部分代码是需要解析明文入参的,为了方便增加该方法
  273. /// </summary>
  274. /// <param name="infno"></param>
  275. /// <param name="input"></param>
  276. /// <returns></returns>
  277. public static string setCenterInpar_plain(string infno, JObject joInput)
  278. {
  279. dynamic Jo = new JObject();
  280. Jo.infno = infno;
  281. Global.curEvt.msgid = Global.inf.hospitalNO + DateTime.Now.ToString("yyyyMMddHHmmssffff");
  282. Jo.msgid = Global.curEvt.msgid;
  283. Jo.insuplc_admdvs = Global.pat.insuplc_admdvs;
  284. //Jo.mdtrtarea_admvs = "419900";
  285. //Global.pat.mdtrtarea_admvs = "419900";
  286. if (Global.pat.insuplc_admdvs == "419900")
  287. {
  288. Jo.mdtrtarea_admvs = "419900";
  289. Global.pat.mdtrtarea_admvs = "419900";
  290. }
  291. else
  292. {
  293. Jo.mdtrtarea_admvs = "410100";
  294. Global.pat.mdtrtarea_admvs = "410100";
  295. }
  296. Jo.recer_sys_code = Global.inf.recivedSystem;
  297. Jo.dev_no = Global.inf.dev_no;
  298. Jo.dev_safe_info = Global.inf.dev_safe_info; //设备编号
  299. Jo.cainfo = Global.inf.cainfo;//设备安全信息
  300. Jo.signtype = Global.inf.signatureType; ;
  301. Jo.infver = Global.inf.version; ;
  302. Jo.opter_type = Global.user.type; ;
  303. Jo.opter = Global.user.ID; ;
  304. Jo.opter_name = Global.user.name; ;
  305. Jo.inf_time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  306. Jo.fixmedins_code = Global.inf.hospitalNO;
  307. Jo.fixmedins_name = Global.inf.hospitalName;
  308. Jo.sign_no = Global.curEvt.signno;
  309. Jo.Add("input", joInput);
  310. return Jo.ToString();
  311. }
  312. /// <summary>
  313. /// 组织中心入参--签到
  314. /// </summary>
  315. /// <param name="infno"></param>
  316. /// <param name="input"></param>
  317. /// <returns></returns>
  318. public static string setCenterInpar(string infno, string input)
  319. {
  320. dynamic Jo = new JObject();
  321. Jo.infno = infno;
  322. Global.curEvt.msgid = Global.inf.hospitalNO + DateTime.Now.ToString("yyyyMMddHHmmssffff");
  323. Jo.msgid = Global.curEvt.msgid;
  324. if (Global.inf.areaCode == "")
  325. {
  326. //Global.inf.areaCode = "419900";
  327. Global.inf.areaCode = "410100";
  328. }
  329. if (string.IsNullOrEmpty(Global.pat.insuplc_admdvs))
  330. {
  331. Global.pat.insuplc_admdvs = Global.inf.areaCode;
  332. }
  333. Jo.insuplc_admdvs = Global.pat.insuplc_admdvs;
  334. //Jo.mdtrtarea_admvs = "419900"; //郑州 市医保、省内异地、跨省异地就医地都传419900
  335. //Global.pat.mdtrtarea_admvs = "419900";
  336. if (Global.pat.insuplc_admdvs == "419900")
  337. {
  338. Jo.mdtrtarea_admvs = "419900"; //郑州 市医保、省内异地、跨省异地就医地都传419900
  339. Global.pat.mdtrtarea_admvs = "419900";
  340. }
  341. else
  342. {
  343. Jo.mdtrtarea_admvs = "410100"; //郑州 市医保、省内异地、跨省异地就医地都传419900
  344. Global.pat.mdtrtarea_admvs = "410100";
  345. }
  346. Jo.recer_sys_code = "HeNan";
  347. Jo.dev_no = Global.curEvt.mac;
  348. Jo.dev_safe_info = Global.inf.dev_safe_info; //设备编号
  349. Jo.cainfo = Global.inf.cainfo ;//
  350. Jo.signtype = "SM3"; ;
  351. Jo.infver = "v1.0";
  352. Jo.opter_type = Global.user.type; ;
  353. Jo.opter = Global.user.ID; ;
  354. Jo.opter_name = Global.user.name; ;
  355. Jo.inf_time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  356. Jo.fixmedins_code = Global.inf.hospitalNO;
  357. Jo.fixmedins_name = Global.inf.hospitalName;
  358. Jo.sign_no = Global.curEvt.signno;
  359. if (input != "")
  360. {
  361. JObject joInput = (JObject)Newtonsoft.Json.JsonConvert.DeserializeObject(input);
  362. Jo.cainfo = "";
  363. Jo.Add("input", JObject.FromObject(joInput));
  364. }
  365. else
  366. {
  367. Jo.cainfo = "";
  368. Jo.Add("input", "");
  369. }
  370. return Jo.ToString();
  371. }
  372. /// <summary>
  373. /// 组织中心入参
  374. /// </summary>
  375. /// <param name="infno"></param>
  376. /// <param name="input"></param>
  377. /// <returns></returns>
  378. public static string setCenterInpar(string infno, JObject joInput)
  379. {
  380. dynamic Jo = new JObject();
  381. Jo.infno = infno;
  382. Global.curEvt.msgid = Global.inf.hospitalNO + DateTime.Now.ToString("yyyyMMddHHmmssffff");
  383. Jo.msgid = Global.curEvt.msgid;
  384. if (Global.pat.insuplc_admdvs == "")
  385. {
  386. Global.pat.insuplc_admdvs = Global.inf.areaCode;
  387. }
  388. Jo.insuplc_admdvs = Global.pat.insuplc_admdvs;
  389. //Jo.mdtrtarea_admvs = "419900"; //郑州 市医保、省内异地、跨省异地就医地都传419900
  390. //Global.pat.mdtrtarea_admvs = "419900";
  391. if (Global.pat.insuplc_admdvs == "419900")
  392. {
  393. Jo.mdtrtarea_admvs = "419900"; //郑州 市医保、省内异地、跨省异地就医地都传419900
  394. Global.pat.mdtrtarea_admvs = "419900";
  395. }
  396. else
  397. {
  398. Jo.mdtrtarea_admvs = "410100"; //郑州 市医保、省内异地、跨省异地就医地都传419900
  399. Global.pat.mdtrtarea_admvs = "410100";
  400. }
  401. Jo.recer_sys_code = "HeNan";
  402. Jo.dev_no = Global.curEvt.mac;
  403. Jo.dev_safe_info = Global.inf.dev_safe_info; //设备编号
  404. Jo.cainfo = Global.inf.cainfo;//
  405. Jo.signtype = "asn1"; ;
  406. Jo.infver = "v1.0";
  407. Jo.opter_type = Global.user.type; ;
  408. Jo.opter = Global.user.ID;
  409. Jo.opter_name = Global.user.name; ;
  410. Jo.inf_time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  411. Jo.fixmedins_code = Global.inf.hospitalNO;
  412. Jo.fixmedins_name = Global.inf.hospitalName;
  413. Jo.sign_no = Global.curEvt.signno;
  414. Jo.cainfo = "";
  415. Jo.Add("input", JObject.FromObject(joInput));
  416. return Jo.ToString();
  417. }
  418. /// <summary>
  419. /// 组织中心入参-医保电子处方流转
  420. /// </summary>
  421. /// <param name="infno"></param>
  422. /// <param name="input"></param>
  423. /// <returns></returns>
  424. public static string setCenterInparPresCirNew(string infno, JObject data)
  425. {
  426. #region【测试环境】
  427. //应用ID
  428. Global.inf.appId = "FEC5EF000EBD47BA9B638C648D81388B";
  429. //Global.inf.appId = "57E2D561E97141A3871DEFB410ADD920";
  430. //应用秘钥
  431. Global.inf.Secret = "433A9350CAFF4C6CB0EBDDBCDEE9BA59";
  432. //Global.inf.Secret = "F30D0D261BA04063A0BCAEF19F8ADBCC";
  433. //应用私钥
  434. Global.inf.privateKey = "ALWdNy5FNoRU9tdw9lDySEZXPXvdiWQ/DACMm4fd4Ozi"; //中心邮件下发
  435. //Global.inf.privateKey = "AKyhfvPbT+tIJHJkZSDILrw7t+FOG1U58UcupYYTzCOj"; //中心Demo
  436. //应用公钥
  437. //Global.inf.publicKey = "BKRejz4MwM8G8Krc4hyIIvhphvwrQpnHIsGWTd0sn0TJYr2eKJGAv87AKnrT8pL50H6hdVHdU0FFaL18GApDEbU"; //中心邮件下发
  438. Global.inf.publicKey = "BJVX/49gz0XfPJsPkk+QCXBYF/SPpjOnFsTDz0bQvBllDR2NbOOQ2HvzjqpHMke1HRjkrhvO/EtVaY/sqcxbqgc="; //中心Demo
  439. //Global.inf.cardURL = "http://10.126.105.66/hsa-hgs-adapt/api/card/initDll"; //测试环境
  440. Global.inf.presCenterURL = "http://10.85.254.46:8000/hss-callEncService";
  441. #endregion
  442. #region【正式环境】
  443. /*
  444. if (Global.inf.interfaceDr == 21) //兰2
  445. {
  446. //应用ID
  447. Global.inf.appId = "4D967CAB5DA44E3583F4246D7FE897F0";
  448. //应用秘钥
  449. Global.inf.Secret = "586BD24D03E5481C8AE4FE9DD8424FFE";
  450. //应用私钥
  451. Global.inf.privateKey = "XTbX+Tt1np5Fma0+twhYi+vtM4J0UJ8VX5fFEZ7t/ro=";
  452. //应用公钥
  453. Global.inf.publicKey = "BIFd2+2CgjuPAj5FMj5L/L3azTWu86suPtlIJkCo8zjQ44R7SQUUkTgZGdVelRQCM5pW+x9tZGzDPaUNbfD499w=";
  454. }
  455. else if (Global.inf.interfaceDr == 25) //兰1
  456. {
  457. //应用ID
  458. Global.inf.appId = "6C9B786AF7E848B29B0EF5783D630263";
  459. //应用秘钥
  460. Global.inf.Secret = "6055AE5A9CAD4D9BA8A98EB20431364E";
  461. //应用私钥
  462. Global.inf.privateKey = "AKReZmOYcTOdbrnlZZFIXn8LQSHPzdAK1Q0CXDnE4Jhk";
  463. //应用公钥
  464. Global.inf.publicKey = "BIFd2+2CgjuPAj5FMj5L/L3azTWu86suPtlIJkCo8zjQ44R7SQUUkTgZGdVelRQCM5pW+x9tZGzDPaUNbfD499w=";
  465. }
  466. Global.inf.presCenterURL = "http://10.126.34.36:8080/epc/api";
  467. */
  468. #endregion
  469. Global.writeLog("密钥id:" + Global.inf.appId);
  470. Global.writeLog("密钥key:" + Global.inf.Secret);
  471. Global.writeLog("定点医药机构私钥:" + Global.inf.privateKey);
  472. Global.writeLog("医保电子处方中心公钥:" + Global.inf.publicKey);
  473. //加密
  474. String encData = SMUtil.encrypt(JsonConvert.SerializeObject(data, Formatting.None), Global.inf.appId, Global.inf.Secret);
  475. //Global.curEvt.msgid = Global.inf.hospitalNO + DateTime.Now.ToString("yyyyMMddHHmmssffff");
  476. string timestamp = ((long)(DateTime.UtcNow - new DateTime(1970, 1, 1, 0, 0, 0, DateTimeKind.Utc)).TotalMilliseconds).ToString();
  477. Global.curEvt.msgid = timestamp;
  478. JObject requestData = new JObject();
  479. requestData.Add("appId", Global.inf.appId);
  480. requestData.Add("version", "2.0.1");
  481. requestData.Add("encType", "SM4");
  482. requestData.Add("signType", "SM2");
  483. requestData.Add("timestamp", timestamp);
  484. JObject signDto = (JObject)JObject.Parse(JsonConvert.SerializeObject(requestData, Formatting.None));
  485. signDto.Add("data", data);
  486. //加签
  487. //String signData = "";
  488. //SignUtils.encryptMsg(Global.inf.appId, Global.inf.Secret, Global.inf.privateKey, signDto.ToString(), ref signData);
  489. String signData = SMUtil.sign(signDto, Global.inf.Secret, Global.inf.privateKey);
  490. Global.writeLog("签名结果:" + "\r\n" + signData);
  491. //报文
  492. requestData.Add("encData", encData);
  493. requestData.Add("signData", signData);
  494. requestData.Add("infno", infno);
  495. dynamic Jo = new JObject();
  496. Jo.infno = infno;
  497. Jo.appId = Global.inf.appId;
  498. Jo.version = "2.0.1";
  499. Jo.timestamp = timestamp;
  500. Jo.encType = "SM4";
  501. Jo.signType = "SM2";
  502. Jo.signData = signDto;
  503. Jo.encData = data;
  504. Global.writeLog("加密前报文:" + "\r\n" + Jo + "\r\n" + "加密后报文:" + "\r\n" + JsonConvert.SerializeObject(requestData, Formatting.None));
  505. return requestData.ToString();
  506. }
  507. /// <summary>
  508. /// 组织Iris入参
  509. /// </summary>
  510. /// <param name="code"></param>
  511. /// <param name="joParam"></param>
  512. /// <returns></returns>
  513. public static JObject setIrisInpar(string code, JObject joParam)
  514. {
  515. try
  516. {
  517. dynamic joInparam = new JObject();
  518. joInparam.code = code;
  519. dynamic joTmp = new JObject();
  520. JArray jaParam = new JArray();
  521. jaParam.Add(joParam);
  522. joInparam.Add("params", JArray.FromObject(jaParam));
  523. joInparam.Add("session", Global.curEvt.jaSession);
  524. return joInparam;
  525. }
  526. catch (Exception ex)
  527. {
  528. return setExceptionJson(-1, "setIrisInpar:", ex.Message);
  529. }
  530. }
  531. /// <summary>
  532. /// 组织Iris入参
  533. /// </summary>
  534. /// <param name="code"></param>
  535. /// <param name="joParam"></param>
  536. /// <returns></returns>
  537. public static JObject setIrisInpar(string code, JArray jaParams)
  538. {
  539. try
  540. {
  541. dynamic joInparam = new JObject();
  542. joInparam.code = code;
  543. dynamic joTmp = new JObject();
  544. joInparam.Add("params", jaParams);
  545. joInparam.Add("session", Global.curEvt.jaSession);
  546. return joInparam;
  547. }
  548. catch (Exception ex)
  549. {
  550. return setExceptionJson(-1, "setIrisInpar:", ex.Message);
  551. }
  552. }
  553. /// <summary>
  554. /// 解析中心返参
  555. /// </summary>
  556. /// <param name="joRtn"></param>
  557. /// <param name="errorMsg"></param>
  558. /// <returns></returns>
  559. public static int parseCenterRtnValue(JObject joRtn, out string errorMsg)
  560. {
  561. try
  562. {
  563. string errcode = getDestValue(joRtn, "errcode");
  564. string errorCode = getDestValue(joRtn, "errorCode");
  565. if (errcode != "")
  566. {
  567. errorMsg = getDestValue(joRtn, "errmsg");
  568. return -1;
  569. }
  570. else if (errorCode != "")
  571. {
  572. errorMsg = getDestValue(joRtn, "errorMessage");
  573. return -2;
  574. }
  575. else
  576. {
  577. errorMsg = getDestValue(joRtn, "err_msg");
  578. return int.Parse(getDestValue(joRtn, "infcode"));
  579. }
  580. }
  581. catch (Exception ex)
  582. {
  583. errorMsg = "解析中心返参发生异常:" + ex.Message;
  584. return -1;
  585. }
  586. }
  587. /// <summary>
  588. /// 组织IRIS返参
  589. /// </summary>
  590. /// <param name="errorCode"></param>
  591. /// <param name="errorMessage"></param>
  592. /// <param name="joResult"></param>
  593. /// <returns></returns>
  594. public static JObject setIrisReturnValue(int errorCode, string errorMessage, JObject joResult)
  595. {
  596. try
  597. {
  598. dynamic joRtn = new JObject();
  599. joRtn.errorCode = errorCode;
  600. joRtn.errorMessage = errorMessage;
  601. joRtn.Add("result", joResult);
  602. return joRtn;
  603. }
  604. catch (Exception ex)
  605. {
  606. return setExceptionJson(-1, "setIrisReturnValue:", ex.Message);
  607. }
  608. }
  609. /// <summary>
  610. /// 解析中心返参
  611. /// </summary>
  612. /// <param name="joRtn"></param>
  613. /// <param name="errorMsg"></param>
  614. /// <returns></returns>
  615. public static int parseCenterRtnValuePresCir(JObject joRtn, out string errorMsg)
  616. {
  617. try
  618. {
  619. string errcode = getDestValue(joRtn, "errcode");
  620. string errorCode = getDestValue(joRtn, "errorCode");
  621. if (errcode != "")
  622. {
  623. errorMsg = getDestValue(joRtn, "message");
  624. return -1;
  625. }
  626. else if (errorCode != "")
  627. {
  628. errorMsg = getDestValue(joRtn, "errorMessage");
  629. return -2;
  630. }
  631. else
  632. {
  633. errorMsg = getDestValue(joRtn, "message");
  634. return int.Parse(getDestValue(joRtn, "code"));
  635. }
  636. }
  637. catch (Exception ex)
  638. {
  639. errorMsg = "解析中心返参发生异常:" + ex.Message;
  640. return -1;
  641. }
  642. }
  643. /// <summary>
  644. /// 解析IRIS返参
  645. /// </summary>
  646. /// <param name="joRtn"></param>
  647. /// <param name="errorMsg"></param>
  648. /// <returns></returns>
  649. public static int parseIrisRtnValue(JObject joRtn, out string errorMsg)
  650. {
  651. try
  652. {
  653. errorMsg = getDestValue(joRtn, "errorMessage");
  654. return int.Parse(getDestValue(joRtn, "errorCode"));
  655. }
  656. catch (Exception ex)
  657. {
  658. errorMsg = "解析Iris返参发生异常:" + ex.Message;
  659. return -1;
  660. }
  661. }
  662. /// <summary>
  663. /// 解析业务JSON串(业务串固定格式为{errorCode = ,errorMessage = ,result ={}})
  664. /// </summary>
  665. /// <param name="json"></param>
  666. /// <param name="errorMsg"></param>
  667. /// <returns></returns>
  668. public static int parseCenterReturnJson(JObject json, out string errorMsg)
  669. {
  670. try
  671. {
  672. errorMsg = "";
  673. if (int.Parse(json["infcode"].ToString()) != 0)
  674. {
  675. errorMsg = json["err_msg"].ToString();
  676. }
  677. return int.Parse(json["infcode"].ToString());
  678. }
  679. catch (Exception ex)
  680. {
  681. errorMsg = "parseCenterReturnJson" + ex.Message;
  682. return -1;
  683. }
  684. }
  685. /// <summary>
  686. /// 保存中心交易日志到数据库
  687. /// </summary>
  688. /// <param name="inParam"></param>
  689. /// <param name="outParam"></param>
  690. /// <param name="inParamPlain"></param>
  691. /// <param name="outParamPlain"></param>
  692. private void saveCenterLog(string inParam, string outParam, string inParamPlain, string outParamPlain)
  693. {
  694. dynamic joIris = new JObject();
  695. string sRtn = "";
  696. try
  697. {
  698. //解析postContent,插入医保交易日志表
  699. JObject joIn = new JObject(JObject.Parse(inParam));
  700. JObject joOut = new JObject(JObject.Parse(outParam));
  701. JObject joInPlain = new JObject(JObject.Parse(inParamPlain));
  702. JObject joOutPlain = new JObject(JObject.Parse(outParamPlain));
  703. JArray jaParams = new JArray();
  704. JObject joParam = new JObject();
  705. joParam.Add("inParam", JObject.FromObject(joIn));
  706. joParam.Add("outParam", JObject.FromObject(joOut));
  707. joParam.Add("inParamPlain", JObject.FromObject(joInPlain));
  708. joParam.Add("outParamPlain", JObject.FromObject(joOutPlain));
  709. joParam.Add("HospitalDr", Global.inf.hospitalDr);
  710. joParam.Add("InterfaceDr", Global.inf.interfaceDr);
  711. joParam.Add("updateUserID", Global.user.ID);
  712. joParam.Add("psn_no", Global.pat.psn_no);
  713. jaParams.Add(joParam);
  714. joIris.code = "09010021";
  715. joIris.Add("params", jaParams);
  716. //InvokeHelper invoker = new InvokeHelper();
  717. sRtn = invokeInsuService(joIris.ToString(), "保存日志到数据库").ToString();
  718. }
  719. catch (Exception ex)
  720. {
  721. sRtn = JsonHelper.setExceptionJson(-100, "保存日志异常", ex.Message).ToString();
  722. Global.writeLog_Iris("保存日志异常:" + sRtn.ToString());
  723. }
  724. }
  725. /// <summary>
  726. /// 移动支付组织中心入参
  727. /// </summary>
  728. /// <param name="infno"></param>
  729. /// <param name="input"></param>
  730. /// <returns></returns>
  731. public static string setMPCenterInpar(string infno, string txtData)
  732. {
  733. EncryptHelper encrypt = new EncryptHelper();
  734. string plainText = SignUtil.SortInput(JObject.Parse(txtData));
  735. string signData = "";
  736. string output = encrypt.encrypt(txtData, ref signData);
  737. return output;
  738. }
  739. public static string setMPCenterInpar(string infno, JObject joInput)
  740. {
  741. return setMPCenterInpar(infno, joInput.ToString());
  742. }
  743. /// <summary>
  744. /// 解析移动返参
  745. /// </summary>
  746. /// <param name="joRtn"></param>
  747. /// <param name="errorMsg"></param>
  748. /// <returns></returns>
  749. public static int parseMPRtnValue(JObject joRtn, out string errorMsg)
  750. {
  751. try
  752. {
  753. string success = getDestValue(joRtn, "success");
  754. string message = getDestValue(joRtn, "message");
  755. string encData = getDestValue(joRtn, "encData");
  756. //Global.writeLog("success:" + success);
  757. if (success != "True")
  758. {
  759. errorMsg = message;
  760. return -1;
  761. }
  762. else
  763. {
  764. errorMsg = joRtn.ToString();
  765. return 0;
  766. }
  767. }
  768. catch (Exception ex)
  769. {
  770. errorMsg = "解析中心返参发生异常:" + ex.Message;
  771. return -1;
  772. }
  773. }
  774. #region 一码付入参
  775. /// <summary>
  776. /// 一码付组织中心入参
  777. /// </summary>
  778. /// <param name="infno"></param>
  779. /// <param name="input"></param>
  780. /// <returns></returns>
  781. public static string setOneCodePayInpar(string jsonStr)
  782. {
  783. if (string.IsNullOrWhiteSpace(jsonStr))
  784. throw new ArgumentException("输入的 JSON 字符串不能为空", nameof(jsonStr));
  785. // 1. 获取时间戳
  786. string timestamp = SignUtils.CurrentTimeStamp().ToString();
  787. // 2. 若不确定,可在此处压缩:
  788. var compactJson = JsonConvert.SerializeObject(JsonConvert.DeserializeObject(jsonStr), Formatting.None);
  789. //Global.inf.OneCodePay.businessSystemKey = "AC1BE7966FFEAFA8";
  790. string encData = OneCodePayEncryptUtil.encrypt(compactJson, Global.inf.OneCodePay.businessSystemKey);
  791. // 3. 构建外层请求对象
  792. var request = new JObject
  793. {
  794. ["reqtType"] = "sys&350000",
  795. ["encData"] = encData,
  796. ["orgId"] = Global.inf.OneCodePay.businessSystemNO, //"hnddyyjgxxxt",
  797. ["timestamp"] = timestamp,
  798. ["version"] = "1.0.0"
  799. };
  800. // 4. 输出紧凑 JSON(医保接口要求无空格)
  801. return request.ToString(Formatting.None);
  802. }
  803. public static string setOneCodePayInpar(JObject joInput)
  804. {
  805. return setOneCodePayInpar(joInput.ToString());
  806. }
  807. /// <summary>
  808. /// 解析一码付返参
  809. /// </summary>
  810. /// <param name="joRtn"></param>
  811. /// <param name="errorMsg"></param>
  812. /// {
  813. /// "code": 0,
  814. /// "type": "success",
  815. /// "message": "成功",
  816. /// "data": {
  817. /// "encData": "FD2C1AB3770A04FC7C833D52F2559D6DD8544BC9A6E677D474BF5FE8104B51E2EE106024829CE4765EAAEAF413EEE62F69A15618D90BB90145BA86367EA8F"
  818. /// }
  819. //}
  820. /// <returns></returns>
  821. public static int parseOneCodePayRtnValue(JObject joRtn, out string errorMsg)
  822. {
  823. try
  824. {
  825. string type = getDestValue(joRtn, "type");
  826. string code = getDestValue(joRtn, "code");
  827. string message = getDestValue(joRtn, "message");
  828. string encData = getDestValue(joRtn, "data.encData");
  829. if (code != "0")
  830. {
  831. errorMsg = message;
  832. return -1;
  833. }
  834. else
  835. {
  836. errorMsg = joRtn.ToString();
  837. return 0;
  838. }
  839. }
  840. catch (Exception ex)
  841. {
  842. errorMsg = "解析中心返参发生异常:" + ex.Message;
  843. return -1;
  844. }
  845. }
  846. #endregion
  847. }
  848. }