InvokeHelper.cs 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767
  1. /******************************************************************************
  2. * 文件名称: InvokeHelper.cs
  3. * 文件说明: 调用助手,调用方法的封装
  4. * 当前版本: V1.0
  5. * 创建日期: 2022-04-12
  6. *
  7. * 2020-04-12: 增加 businessDLLInvoke 方法
  8. * 2020-04-12: 增加 writeLog 方法
  9. * 2020-04-14: 增加 businessDLLInvoke(重载) 方法
  10. * 2020-04-14: 增加 irisServiceInvoke 方法
  11. ******************************************************************************/
  12. using Newtonsoft.Json.Linq;
  13. using System;
  14. using System.Collections.Generic;
  15. using System.IO;
  16. using System.Linq;
  17. using System.Net;
  18. using System.Text;
  19. using System.Threading.Tasks;
  20. using System.Windows.Forms;
  21. using PTMedicalInsurance.Helper;
  22. using Newtonsoft.Json;
  23. using PTMedicalInsurance.Common;
  24. using PTMedicalInsurance.Variables;
  25. using System.Runtime.InteropServices;
  26. using PTMedicalInsurance.Forms;
  27. using System.Security.Cryptography;
  28. using Org.BouncyCastle.Utilities.Encoders;
  29. namespace PTMedicalInsurance.Helper
  30. {
  31. public class InvokeHelper
  32. {
  33. private string serviceURL;
  34. private string authorization;
  35. public InvokeHelper()
  36. {
  37. LoadCenterURL(false);
  38. }
  39. private void LoadCenterURL(bool reloadFromCfgFile)
  40. {
  41. //IniFile ini = new IniFile(Global.curEvt.path + @"\CenterServiceURL.ini");
  42. //// 默认采用的是后台配置的地址
  43. //if (reloadFromCfgFile)
  44. //{
  45. // Global.inf.centerURL = ini.ReadValue("CENTER", "url");
  46. // Global.inf.uploadURL = ini.ReadValue("CENTER", "upload");
  47. // Global.inf.downURL = ini.ReadValue("CENTER", "download");
  48. // Global.inf.ecURL = ini.ReadValue("CENTER", "ecToken");
  49. //}
  50. //Global.inf.mobilePayURL = ini.ReadValue("CENTER", "mobilePay");
  51. //Global.inf.ecPrescURL = ini.ReadValue("CENTER", "prescription");
  52. //// 移动支付
  53. //if (string.IsNullOrEmpty(Global.inf.mobilePayURL))
  54. //{
  55. // Global.inf.mobilePayURL = "http://10.77.224.18:9001/CSB/hsa-fsi-no";
  56. //}
  57. //// 电子处方
  58. //if (string.IsNullOrEmpty(Global.inf.ecPrescURL))
  59. //{
  60. // Global.inf.ecPrescURL = "http://10.77.245.22:9001/epc/api";
  61. //}
  62. }
  63. /// <summary>
  64. /// API密钥
  65. /// </summary>
  66. private void LoadAPIKey(string prefix)
  67. {
  68. //获取AK,SK(可配置)
  69. if (prefix == "MOBILE")
  70. {
  71. Global.inf.passid = Global.inf.MobilePay.passid;
  72. Global.inf.apiSecretKey = Global.inf.MobilePay.apiSecretKey;
  73. }
  74. else
  75. {
  76. byte[] b = Base64.Decode(Global.inf.centerURL2);
  77. string centerURL2 = System.Text.Encoding.UTF8.GetString(b);
  78. JObject joCenterURL2 = JObject.Parse(centerURL2);
  79. Global.inf.passid = JsonHelper.getDestValue(joCenterURL2, "core.passid");
  80. Global.inf.apiSecretKey = JsonHelper.getDestValue(joCenterURL2, "core.apiSecretKey");
  81. }
  82. }
  83. /// <summary>
  84. /// 核心接口密钥
  85. /// </summary>
  86. private void LoadCoreAPIKey()
  87. {
  88. LoadAPIKey("KEY");
  89. }
  90. /// <summary>
  91. /// 移动支付密钥
  92. /// </summary>
  93. private void LoadMobileAPIKey()
  94. {
  95. LoadAPIKey("MOBILE");
  96. }
  97. #region 内部服务调用
  98. /// <summary>
  99. /// iris服务调用的封装
  100. /// </summary>
  101. /// <param name="data"></param>
  102. /// <returns></returns>
  103. public JObject invokeIrisService(string data, string serviceDesc)
  104. {
  105. string rtn = "", url = "";
  106. JObject joRtn = new JObject();
  107. try
  108. {
  109. //先根据用户请求的uri构造请求地址
  110. url = serviceURL;
  111. ServicePointManager.ServerCertificateValidationCallback = delegate { return true; };
  112. ServicePointManager.SecurityProtocol = SecurityProtocolType.Ssl3 | SecurityProtocolType.Tls12 | SecurityProtocolType.Tls11 | SecurityProtocolType.Tls;
  113. //创建Web访问对象
  114. HttpWebRequest myRequest = (HttpWebRequest)WebRequest.Create(url);
  115. //把用户传过来的数据转成“UTF-8”的字节流
  116. byte[] buf = System.Text.Encoding.GetEncoding("UTF-8").GetBytes(data);
  117. //添加头部信息
  118. myRequest.Method = "POST";
  119. myRequest.ContentLength = buf.Length;
  120. myRequest.ContentType = "application/json";
  121. myRequest.Headers.Add("Authorization", authorization);
  122. myRequest.MaximumAutomaticRedirections = 1;
  123. myRequest.AllowAutoRedirect = true;
  124. //发送请求
  125. Stream stream = myRequest.GetRequestStream();
  126. stream.Write(buf, 0, buf.Length);
  127. stream.Close();
  128. //获取接口返回值
  129. //通过Web访问对象获取响应内容
  130. HttpWebResponse myResponse = (HttpWebResponse)myRequest.GetResponse();
  131. rtn = getResponseData(myResponse);
  132. joRtn = JObject.Parse(rtn);
  133. return joRtn;
  134. }
  135. catch (Exception ex)
  136. {
  137. joRtn = JsonHelper.setExceptionJson(-1, serviceDesc, ex.Message);
  138. rtn = JsonConvert.SerializeObject(joRtn);
  139. return joRtn;
  140. }
  141. }
  142. /// <summary>
  143. /// HIS服务调用的封装
  144. /// </summary>
  145. /// <param name="data"></param>
  146. /// <returns></returns>
  147. ///
  148. public JObject invokeHISService(string data, string serviceDesc)
  149. {
  150. JObject joRtn = new JObject();
  151. try
  152. {
  153. //先根据用户请求的uri构造请求地址
  154. serviceURL = string.Format("{0}/{1}", Global.hisConfig.ip, Global.hisConfig.url);
  155. authorization = Global.hisConfig.authorization;
  156. joRtn = invokeIrisService(data, serviceDesc);
  157. return joRtn;
  158. }
  159. catch (Exception ex)
  160. {
  161. joRtn = JsonHelper.setExceptionJson(-1, serviceDesc, ex.Message);
  162. return joRtn;
  163. }
  164. finally
  165. {
  166. Global.writeLog_Iris(serviceDesc + "(" + serviceURL + ")" + "Authorization:" + (authorization), JsonHelper.Compress(data), JsonHelper.Compress(joRtn));
  167. }
  168. }
  169. /// <summary>
  170. /// 医保平台服务调用的封装
  171. /// </summary>
  172. /// <param name="data"></param>
  173. /// <returns></returns>
  174. public JObject invokeInsuService(string data, string serviceDesc)
  175. {
  176. string rtn = "";
  177. JObject joRtn = new JObject();
  178. try
  179. {
  180. //先根据用户请求的uri构造请求地址
  181. serviceURL = string.Format("{0}/{1}", Global.insuConfig.ip, Global.insuConfig.url);
  182. authorization = Global.insuConfig.authorization;
  183. joRtn = invokeIrisService(data, serviceDesc);
  184. rtn = JsonConvert.SerializeObject(joRtn);
  185. //if (serviceDesc == "插入签到信息")
  186. //{
  187. // MessageBox.Show("插入签到信息入参:" + data +"|返回值:"+ rtn.ToString()+"|"+ Global.insuConfig.url);
  188. //}
  189. return joRtn;
  190. }
  191. catch (Exception ex)
  192. {
  193. joRtn = JsonHelper.setExceptionJson(-1, serviceDesc, ex.Message);
  194. rtn = JsonConvert.SerializeObject(joRtn);
  195. return joRtn;
  196. }
  197. finally
  198. {
  199. Global.writeLog_Iris(serviceDesc + "(" + serviceURL + ")" + "Authorization:" + (authorization), JsonHelper.Compress(data), rtn);
  200. }
  201. }
  202. private string getResponseData(HttpWebResponse response)
  203. {
  204. string data = "";
  205. if (response != null)
  206. {
  207. Stream s = response.GetResponseStream();
  208. StreamReader sRead = new StreamReader(s);
  209. data = sRead.ReadToEnd();
  210. sRead.Close();
  211. response.Close();
  212. }
  213. return data;
  214. }
  215. #endregion
  216. #region 医保中心调用
  217. /// <summary>
  218. /// 仅辅助交易、自定义交易使用
  219. /// </summary>
  220. /// <param name="funNo"></param>
  221. /// <param name="joInput"></param>
  222. /// <returns></returns>
  223. public JObject invokeCenterAgentService(string funNo, JObject joInput)
  224. {
  225. if (Global.curEvt.testMode)
  226. {
  227. // 医保测试环境
  228. LoadCenterURL(true);
  229. }
  230. Global.curEvt.URL = Global.inf.centerURL + funNo;
  231. string data = JsonHelper.setCenterInpar(funNo, joInput);
  232. return invokeCenterService(data);
  233. }
  234. private JObject invokeCenterService(string data, ModeEnum mode = ModeEnum.REST)
  235. {
  236. JObject joRtn = new JObject();
  237. try
  238. {
  239. IInvokeCenter center = new InvokeCenterFactory().create(mode);
  240. string outputData = "";
  241. string errMsg = "";
  242. int iInt = center.Init(ref errMsg);
  243. if (iInt == 0)
  244. {
  245. LoadCoreAPIKey();
  246. iInt = center.Business(data, ref outputData, ref errMsg);
  247. if (iInt == 0 && !string.IsNullOrEmpty(outputData))
  248. {
  249. try
  250. {
  251. joRtn = JObject.Parse(outputData);
  252. }
  253. catch (Exception ex)
  254. {
  255. joRtn.Add("infcode", iInt);
  256. joRtn.Add("err_msg", "返回参数异常:" + outputData);
  257. }
  258. }
  259. else
  260. {
  261. joRtn.Add("infcode", iInt);
  262. joRtn.Add("err_msg", outputData);
  263. return joRtn;
  264. }
  265. return joRtn;
  266. }
  267. else
  268. {
  269. joRtn.Add("infcode", -1);
  270. joRtn.Add("err_msg", "医保动态库初始化失败invokeInitByDLL:" + errMsg);
  271. return joRtn;
  272. }
  273. }
  274. finally
  275. {
  276. Global.writeLog(Global.curEvt.URL, JsonHelper.Compress(data), joRtn.ToString());
  277. // 保存到服务器
  278. this.saveCenterLog(JsonHelper.Compress(data),joRtn.ToString(), JsonHelper.Compress(data), joRtn.ToString());
  279. }
  280. }
  281. private void prepareCallURI(TradeEnum trade)
  282. {
  283. string funNo = trade.GetCode() ;
  284. Global.curEvt.funNo = funNo;
  285. if (Global.curEvt.testMode)
  286. {
  287. // 医保测试环境
  288. //LoadCenterURL(true);
  289. }
  290. string prefix = Global.inf.centerURL;
  291. switch (trade)
  292. {
  293. case TradeEnum.FileUpload:
  294. prefix = Global.inf.uploadURL??Global.inf.centerURL;
  295. break;
  296. case TradeEnum.FileDownload:
  297. prefix = Global.inf.centerURL;
  298. break;
  299. default:
  300. prefix = Global.inf.centerURL;
  301. break;
  302. }
  303. // 根据情况确实是否需要加funNo
  304. Global.curEvt.URL = prefix + Global.curEvt.funNo;
  305. }
  306. /// <summary>
  307. /// 通过枚举转换要调用的接口
  308. /// </summary>
  309. /// <param name="trade"></param>
  310. /// <param name="data"></param>
  311. /// <returns></returns>
  312. public JObject invokeCenterService(TradeEnum trade, JObject joInput)
  313. {
  314. string funNo = trade.GetCode();
  315. // 入参统一转换
  316. JObject request = Utils.ConvertRequest<JObject>(trade,joInput);
  317. string data = JsonHelper.toJsonString(request);
  318. // 统一封装请求头
  319. if (trade.GetMode() == ModeEnum.REST)
  320. {
  321. data = JsonHelper.setCenterInpar(funNo, request);
  322. }
  323. JObject joRtn = new JObject();
  324. // 调试模式
  325. if (Global.curEvt.enabledDebug)
  326. {
  327. CenterResult center = new CenterResult();
  328. center.setTradeNo(trade.GetCode(), data);
  329. if (center.ShowDialog() == DialogResult.OK)
  330. {
  331. // 接口实际返回数据
  332. string outPar = center.returnData;
  333. joRtn = JObject.Parse(outPar);
  334. }
  335. }
  336. else
  337. {
  338. prepareCallURI(trade);
  339. joRtn = invokeCenterService(data, trade.GetMode());
  340. }
  341. // 返回结果统一转换
  342. joRtn = Utils.ConvertResponse<JObject>(trade,joRtn);
  343. return joRtn;
  344. }
  345. /// <summary>
  346. /// 医保目录txt文件下载
  347. /// </summary>
  348. /// <param name="data"></param>
  349. /// <returns></returns>
  350. public JObject DownloadCenterFile(string data, ModeEnum mode = ModeEnum.REST)
  351. {
  352. //download file
  353. IInvokeCenter center = new InvokeCenterFactory().create(mode);
  354. string outputMsg = "";
  355. JObject joRtn = new JObject();
  356. prepareCallURI(TradeEnum.FileDownload);
  357. int rtnCode = center.DownloadFile(data, ref outputMsg);
  358. if(rtnCode==0)
  359. {
  360. joRtn = JObject.Parse(outputMsg);
  361. }
  362. else
  363. {
  364. joRtn.Add("infcode", -1);
  365. joRtn.Add("err_msg", "下载文件失败DownloadFile:" + outputMsg);
  366. }
  367. return joRtn;
  368. }
  369. #endregion
  370. #region 移动
  371. /// <summary>
  372. /// 移动
  373. /// </summary>
  374. /// <param name="funNO"></param>
  375. /// <param name="data"></param>
  376. /// <returns></returns>
  377. public JObject invokeMPService(string funNO, string data)
  378. {
  379. return invokeMPService(funNO, JObject.Parse(data));
  380. }
  381. public JObject invokeMPService(string funNO, JObject joInput)
  382. {
  383. JObject joRtn = new JObject();
  384. String outPar = "";
  385. string decData = "";
  386. string encInput = "";
  387. string outputData = "", errMsg = "";
  388. try
  389. {
  390. string url = "";
  391. switch (funNO)
  392. {
  393. case "6201":
  394. url = "/org/local/api/hos/uldFeeInfo";
  395. break;
  396. case "6202":
  397. url = "/org/local/api/hos/pay_order";
  398. break;
  399. case "6203":
  400. url = "/org/local/api/hos/refund_Order";
  401. break;
  402. case "6301":
  403. url = "/org/local/api/hos/query_order_info";
  404. break;
  405. case "6401":
  406. url = "/org/local/api/hos/revoke_order";
  407. break;
  408. default:
  409. break;
  410. }
  411. EncryptHelper encrypt = new EncryptHelper(Global.inf.MobilePay.appid, Global.inf.MobilePay.secretKey, Global.inf.MobilePay.publicKey, Global.inf.MobilePay.privateKey);
  412. encInput = JsonHelper.setMPCenterInpar(funNO, joInput);
  413. // 移动支付地址
  414. Global.curEvt.URL = Global.inf.MobilePay.url + url;
  415. // 动态调试模式
  416. if (Global.curEvt.enabledDebug)
  417. {
  418. CenterResult center = new CenterResult();
  419. center.setTradeNo(funNO, encInput);
  420. if (center.ShowDialog() == DialogResult.OK)
  421. {
  422. outPar = center.returnData;
  423. return JObject.Parse(outPar);
  424. }
  425. }
  426. try
  427. {
  428. InvokeRestCenter mobileCenter = new InvokeRestCenter();
  429. LoadMobileAPIKey();
  430. int iInt = mobileCenter.Business(encInput, ref outputData, ref errMsg);
  431. joRtn = JObject.Parse(outputData);
  432. string encData = JsonHelper.getDestValue(joRtn, "encData");
  433. string signData = JsonHelper.getDestValue(joRtn, "signData");
  434. if (!string.IsNullOrEmpty(encData) && !string.IsNullOrEmpty(signData))
  435. {
  436. joRtn.Remove("encData");
  437. joRtn.Remove("signData");
  438. joRtn.Remove("data");
  439. //解密
  440. decData = encrypt.decrypt(encData);
  441. // 验签
  442. JsonConvert.DefaultSettings = () => new JsonSerializerSettings
  443. {
  444. FloatParseHandling = FloatParseHandling.Decimal
  445. };
  446. joRtn.Add("data", JToken.FromObject(JsonConvert.DeserializeObject(decData)));
  447. bool rtn = encrypt.verify(joRtn, signData);
  448. if (rtn)
  449. {
  450. joRtn = JObject.Parse(decData);
  451. joRtn.Add("success", "True");
  452. }
  453. else
  454. {
  455. Global.writeLog("验签失败,请核查!");
  456. }
  457. }
  458. return joRtn;
  459. }
  460. finally
  461. {
  462. string plainData = encInput;
  463. this.saveCenterLog(JsonHelper.Compress(encInput), joRtn.ToString(), JsonHelper.Compress(plainData), joRtn.ToString());
  464. }
  465. }
  466. catch (Exception ex)
  467. {
  468. if (joRtn["infcode"] == null)
  469. { joRtn.Add("infcode", -1); }
  470. if (joRtn["err_msg"] == null)
  471. { joRtn.Add("err_msg", "invokeCenterService(3):" + ex.Message); }
  472. outPar = JsonHelper.Compress(joRtn);
  473. return joRtn;
  474. }
  475. finally
  476. {
  477. Global.writeLog(funNO + "(密文)(" + Global.curEvt.URL + ")", encInput, outputData);
  478. Global.writeLog(funNO + "(明文)(" + Global.curEvt.URL + ")", joInput.ToString(), joRtn.ToString());
  479. this.saveCenterLog(joInput.ToString(), joRtn.ToString(), joInput.ToString(), joRtn.ToString());
  480. }
  481. }
  482. /// <summary>
  483. /// 保存中心交易日志到数据库
  484. /// </summary>
  485. /// <param name="inParam"></param>
  486. /// <param name="outParam"></param>
  487. /// <param name="inParamPlain"></param>
  488. /// <param name="outParamPlain"></param>
  489. private void saveCenterLog(string inParam, string outParam, string inParamPlain, string outParamPlain)
  490. {
  491. dynamic joIris = new JObject();
  492. string sRtn = "";
  493. try
  494. {
  495. //解析postContent,插入医保交易日志表
  496. JObject joInParam = new JObject(JObject.Parse(inParam));
  497. //解包
  498. JObject joIn = Utils.removeWrapper(joInParam);
  499. JObject joOut = new JObject(JObject.Parse(outParam));
  500. JObject joInPlain = new JObject(JObject.Parse(inParamPlain));
  501. JObject joOutPlain = new JObject(JObject.Parse(outParamPlain));
  502. JArray jaParams = new JArray();
  503. JObject joParam = new JObject();
  504. joParam.Add("inParam", JObject.FromObject(joIn));
  505. joParam.Add("outParam", JObject.FromObject(joOut));
  506. joParam.Add("inParamPlain", JObject.FromObject(joInPlain));
  507. joParam.Add("outParamPlain", JObject.FromObject(joOutPlain));
  508. joParam.Add("HospitalDr", Global.inf.hospitalDr);
  509. joParam.Add("InterfaceDr", Global.inf.interfaceDr);
  510. joParam.Add("updateUserID", Global.user.ID);
  511. joParam.Add("psn_no", Global.pat.psn_no);
  512. jaParams.Add(joParam);
  513. joIris.code = "09010021";
  514. joIris.Add("params", jaParams);
  515. //InvokeHelper invoker = new InvokeHelper();
  516. sRtn = invokeInsuService(joIris.ToString(), "保存日志到数据库").ToString();
  517. }
  518. catch (Exception ex)
  519. {
  520. sRtn = JsonHelper.setExceptionJson(-100, "保存日志异常", ex.Message).ToString();
  521. Global.writeLog_Iris("保存日志异常:" + sRtn.ToString());
  522. }
  523. }
  524. #endregion
  525. #region 电子处方
  526. /// </summary>
  527. /// <param name="funNO"></param>
  528. /// <param name="data"></param>
  529. /// <returns></returns>
  530. public JObject invokeEPCenterService(string funNO, string data)
  531. {
  532. JObject joRtn = new JObject();
  533. string outPar = "";
  534. try
  535. {
  536. Global.curEvt.URL = Global.inf.centerURL;
  537. switch (funNO)
  538. {
  539. case "7101":
  540. {
  541. Global.curEvt.URL = Global.curEvt.URL + "CFYLJG001";
  542. break;
  543. }
  544. case "7102":
  545. {
  546. Global.curEvt.URL = Global.curEvt.URL + "CFYLJG002";
  547. break;
  548. }
  549. case "7103":
  550. {
  551. Global.curEvt.URL = Global.curEvt.URL + "CFYLJG003";
  552. break;
  553. }
  554. case "7104":
  555. {
  556. Global.curEvt.URL = Global.curEvt.URL + "CFYLJG004";
  557. break;
  558. }
  559. case "7105":
  560. {
  561. Global.curEvt.URL = Global.curEvt.URL + "CFYLJG005";
  562. break;
  563. }
  564. case "7106":
  565. {
  566. Global.curEvt.URL = Global.curEvt.URL + "CFYLJG006";
  567. break;
  568. }
  569. case "7107":
  570. {
  571. Global.curEvt.URL = Global.curEvt.URL + "CFYLJG007";
  572. break;
  573. }
  574. //case "7108":
  575. // {
  576. // Global.curEvt.URL = Global.curEvt.URL + "/fixmedins/rxChkInfoCallback";
  577. // break;
  578. // }
  579. //case "7109":
  580. // {
  581. // Global.curEvt.URL = Global.curEvt.URL + "/fixmedins/rxSetlInfoCallback";
  582. // break;
  583. // }
  584. }
  585. //Global.curEvt.URL = Global.inf.centerURL;
  586. joRtn = invokeCenterService(data);
  587. outPar = JsonHelper.Compress(joRtn);
  588. return joRtn;
  589. }
  590. catch (Exception ex)
  591. {
  592. if (joRtn["infcode"] == null)
  593. { joRtn.Add("infcode", -1); }
  594. if (joRtn["err_msg"] == null)
  595. { joRtn.Add("err_msg", "invokeCenterServicePresCir(3):" + ex.Message); }
  596. outPar = JsonHelper.Compress(joRtn);
  597. return joRtn;
  598. }
  599. finally
  600. {
  601. Global.writeLog(funNO + "(" + Global.curEvt.URL + ")", JsonHelper.Compress(data), joRtn.ToString());
  602. //this.saveCenterLog(JsonHelper.Compress(data), outPar, JsonHelper.Compress(data), outPar);
  603. }
  604. }
  605. /// <summary>
  606. /// 医保电子处方流转调用服务
  607. /// </summary>
  608. /// <param name="data"></param>
  609. /// <returns></returns>
  610. //private JObject invokeEPCenterService(string data)
  611. //{
  612. // string postContent = "";
  613. // JObject joRtn = new JObject();
  614. // try
  615. // {
  616. // string timestamp = TimeStamp.get13().ToString(); //当前时间戳(秒)
  617. // string nonce = Guid.NewGuid().ToString(); //非重复的随机字符串(十分钟内不能重复)
  618. // //内容类型
  619. // //Signer signer = new Signer();
  620. // //signer.Key = Global.inf.privateKey; //应用编码
  621. // //signer.Secret = Global.inf.secretKey; //secretKey 私钥
  622. // //HttpRequest Resquest = new HttpRequest("POST", new Uri(Global.curEvt.URL));
  623. // //Resquest.headers.Add("charset", "UTF-8");
  624. // //Resquest.headers.Add("x-hw-id", signer.Key);
  625. // //Resquest.headers.Add("x-tif-timestamp", timestamp);
  626. // //Resquest.headers.Add("x-tif-passid", signer.Key);
  627. // //Resquest.headers.Add("x-tif-nonce", nonce);
  628. // //Resquest.body = signData;
  629. // //HttpWebRequest req = signer.Sign(Resquest);
  630. // HttpWebRequest req = (HttpWebRequest)WebRequest.Create(Global.curEvt.URL);
  631. // req.Method = "POST";
  632. // req.ContentType = "application/json;charset=utf8";
  633. // req.Timeout = 5 * 10000;
  634. // try
  635. // {
  636. // var writer = new StreamWriter(req.GetRequestStream());
  637. // writer.Write(data);
  638. // writer.Flush();
  639. // HttpWebResponse resp = (HttpWebResponse)req.GetResponse();
  640. // StreamReader reader = new StreamReader(resp.GetResponseStream());
  641. // string RtnStr = reader.ReadToEnd();
  642. // joRtn = JObject.Parse(RtnStr);
  643. // // 解密返回值
  644. // EncryptHelper encrypt = new EncryptHelper(Global.inf.appId, Global.inf.secretKey, Global.inf.publicKey, Global.inf.privateKey);
  645. // string encData = JsonHelper.getDestValue(joRtn, "encData");
  646. // string signData = JsonHelper.getDestValue(joRtn, "signData");
  647. // if (!string.IsNullOrEmpty(encData) && !string.IsNullOrEmpty(signData))
  648. // {
  649. // joRtn.Remove("encData");
  650. // joRtn.Remove("signData");
  651. // joRtn.Remove("data");
  652. // //解密
  653. // string decData = encrypt.decrypt(encData);
  654. // // 验签
  655. // JsonConvert.DefaultSettings = () => new JsonSerializerSettings
  656. // {
  657. // FloatParseHandling = FloatParseHandling.Decimal
  658. // };
  659. // joRtn.Add("data", JToken.FromObject(JsonConvert.DeserializeObject(decData)));
  660. // bool rtn = encrypt.verify(joRtn, signData);
  661. // if (rtn)
  662. // {
  663. // Global.writeLog("【明文出参】:\r\n" + decData);
  664. // joRtn = JObject.Parse(decData);
  665. // joRtn.Add("code", 0);
  666. // joRtn.Add("message", "成功");
  667. // }
  668. // else
  669. // {
  670. // Global.writeLog("验签失败,请核查!");
  671. // }
  672. // }
  673. // return joRtn;
  674. // }
  675. // catch (WebException e)
  676. // {
  677. // HttpWebResponse resp = (HttpWebResponse)e.Response;
  678. // if (resp != null)
  679. // {
  680. // return JsonHelper.setExceptionJson(-99, "centerServeiceInvok中获得响应流异常(a)", new StreamReader(resp.GetResponseStream()).ReadToEnd() + "异常内容:" + e.Message);
  681. // }
  682. // else
  683. // {
  684. // return JsonHelper.setExceptionJson(-99, "centerServeiceInvok中获得响应流异常(b)", e.Message);
  685. // }
  686. // }
  687. // }
  688. // catch (Exception ex)
  689. // {
  690. // postContent = "调用中心服务异常" + ex.Message;
  691. // joRtn.Add("infcode", -1);
  692. // joRtn.Add("err_msg", "invokeCenterService(Exception_Last):" + ex.Message);
  693. // return joRtn;
  694. // }
  695. //}
  696. #endregion
  697. }
  698. }