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