InvokeHelper.cs 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819
  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 JObject invokeCenterServicePresc(string data, ModeEnum mode = ModeEnum.REST)
  277. {
  278. JObject joRtn = new JObject();
  279. try
  280. {
  281. IInvokeCenter center = new InvokeCenterFactory().create(mode);
  282. string outputData = "";
  283. string errMsg = "";
  284. int iInt = center.Init(ref errMsg);
  285. if (iInt == 0)
  286. {
  287. LoadCoreAPIKey();
  288. iInt = center.Business(data, ref outputData, ref errMsg);
  289. if (iInt == 0 && !string.IsNullOrEmpty(outputData))
  290. {
  291. try
  292. {
  293. joRtn = JObject.Parse(outputData);
  294. }
  295. catch (Exception ex)
  296. {
  297. joRtn.Add("infcode", iInt);
  298. joRtn.Add("err_msg", "返回参数异常:" + outputData);
  299. }
  300. }
  301. else
  302. {
  303. joRtn.Add("infcode", iInt);
  304. joRtn.Add("err_msg", outputData);
  305. return joRtn;
  306. }
  307. return joRtn;
  308. }
  309. else
  310. {
  311. joRtn.Add("infcode", -1);
  312. joRtn.Add("err_msg", "医保动态库初始化失败invokeInitByDLL:" + errMsg);
  313. return joRtn;
  314. }
  315. }
  316. finally
  317. {
  318. Global.writeLog("secretKey:" + Global.inf.apiSecretKey + ",passid:" + Global.inf.passid);
  319. Global.writeLog(Global.curEvt.URL, JsonHelper.Compress(data), joRtn.ToString());
  320. // 保存到服务器
  321. this.saveCenterLog(JsonHelper.Compress(data), joRtn.ToString(), JsonHelper.Compress(data), joRtn.ToString());
  322. }
  323. }
  324. private void prepareCallURI(TradeEnum trade)
  325. {
  326. string funNo = trade.GetCode() ;
  327. Global.curEvt.funNo = funNo;
  328. if (Global.curEvt.testMode)
  329. {
  330. // 医保测试环境
  331. LoadCenterURL(true);
  332. }
  333. string prefix = Global.inf.centerURL;
  334. switch (trade)
  335. {
  336. case TradeEnum.FileUpload:
  337. prefix = Global.inf.uploadURL??Global.inf.centerURL;
  338. break;
  339. case TradeEnum.FileDownload:
  340. prefix = Global.inf.centerURL;
  341. break;
  342. default:
  343. prefix = Global.inf.centerURL;
  344. break;
  345. }
  346. // 根据情况确实是否需要加funNo
  347. Global.curEvt.URL = prefix + Global.curEvt.funNo;
  348. }
  349. /// <summary>
  350. /// 通过枚举转换要调用的接口
  351. /// </summary>
  352. /// <param name="trade"></param>
  353. /// <param name="data"></param>
  354. /// <returns></returns>
  355. public JObject invokeCenterService(TradeEnum trade, JObject joInput)
  356. {
  357. string funNo = trade.GetCode();
  358. Global.curEvt.funNo = funNo;
  359. // 入参统一转换
  360. JObject request = Utils.ConvertRequest<JObject>(trade,joInput);
  361. string data = JsonHelper.toJsonString(request);
  362. // 统一封装请求头
  363. if (trade.GetMode() == ModeEnum.REST)
  364. {
  365. data = JsonHelper.setCenterInpar(funNo, request);
  366. }
  367. JObject joRtn = new JObject();
  368. // 调试模式
  369. if (Global.curEvt.enabledDebug)
  370. {
  371. CenterResult center = new CenterResult();
  372. center.setTradeNo(trade.GetCode(), data);
  373. if (center.ShowDialog() == DialogResult.OK)
  374. {
  375. // 接口实际返回数据
  376. string outPar = center.returnData;
  377. joRtn = JObject.Parse(outPar);
  378. }
  379. }
  380. else
  381. {
  382. prepareCallURI(trade);
  383. joRtn = invokeCenterService(data, trade.GetMode());
  384. }
  385. // 返回结果统一转换
  386. joRtn = Utils.ConvertResponse<JObject>(trade,joRtn);
  387. return joRtn;
  388. }
  389. /// <summary>
  390. /// 医保目录txt文件下载
  391. /// </summary>
  392. /// <param name="data"></param>
  393. /// <returns></returns>
  394. public JObject DownloadCenterFile(string data, ModeEnum mode = ModeEnum.REST)
  395. {
  396. //download file
  397. IInvokeCenter center = new InvokeCenterFactory().create(mode);
  398. string outputMsg = "";
  399. JObject joRtn = new JObject();
  400. prepareCallURI(TradeEnum.FileDownload);
  401. int rtnCode = center.DownloadFile(data, ref outputMsg);
  402. if (rtnCode == 0)
  403. {
  404. joRtn = JObject.Parse(outputMsg);
  405. }
  406. else
  407. {
  408. joRtn.Add("infcode", -1);
  409. joRtn.Add("err_msg", "下载文件失败DownloadFile:" + outputMsg);
  410. }
  411. return joRtn;
  412. }
  413. #endregion
  414. #region 移动
  415. /// <summary>
  416. /// 移动
  417. /// </summary>
  418. /// <param name="funNO"></param>
  419. /// <param name="data"></param>
  420. /// <returns></returns>
  421. public JObject invokeMPService(string funNO, string data)
  422. {
  423. return invokeMPService(funNO, JObject.Parse(data));
  424. }
  425. public JObject invokeMPService(string funNO, JObject joInput)
  426. {
  427. JObject joRtn = new JObject();
  428. String outPar = "";
  429. try
  430. {
  431. string url = "";
  432. //switch (funNO)
  433. //{
  434. // case "6201":
  435. // url = "/org/local/api/hos/uldFeeInfo";
  436. // break;
  437. // case "6202":
  438. // url = "/org/local/api/hos/pay_order";
  439. // break;
  440. // case "6203":
  441. // url = "/org/local/api/hos/refund_Order";
  442. // break;
  443. // case "6301":
  444. // url = "/org/local/api/hos/query_order_info";
  445. // break;
  446. // case "6401":
  447. // url = "/org/local/api/hos/revoke_order";
  448. // break;
  449. // default:
  450. // break;
  451. //}
  452. EncryptHelper encrypt = new EncryptHelper();
  453. string data = JsonHelper.setMPCenterInpar(funNO, joInput);
  454. // 移动支付地址
  455. Global.curEvt.URL = Global.inf.mobilePayURL + funNO;
  456. string outputData = "", errMsg = "";
  457. // 动态调试模式
  458. if (Global.curEvt.enabledDebug)
  459. {
  460. CenterResult center = new CenterResult();
  461. center.setTradeNo(funNO,data);
  462. if (center.ShowDialog() == DialogResult.OK)
  463. {
  464. outPar = center.returnData;
  465. return JObject.Parse(outPar);
  466. }
  467. }
  468. try
  469. {
  470. InvokeRestCenter mobileCenter = new InvokeRestCenter();
  471. LoadMobileAPIKey();
  472. int iInt = mobileCenter.Business(data, ref outputData, ref errMsg);
  473. joRtn = JObject.Parse(outputData);
  474. Global.writeLog(funNO + "【密文出参】:\r\n" + joRtn.ToString());
  475. string encData = JsonHelper.getDestValue(joRtn, "encData");
  476. string signData = JsonHelper.getDestValue(joRtn, "signData");
  477. if (!string.IsNullOrEmpty(encData) && !string.IsNullOrEmpty(signData))
  478. {
  479. joRtn.Remove("encData");
  480. joRtn.Remove("signData");
  481. joRtn.Remove("data");
  482. //解密
  483. string decData = encrypt.decrypt(encData);
  484. // 验签
  485. JsonConvert.DefaultSettings = () => new JsonSerializerSettings
  486. {
  487. FloatParseHandling = FloatParseHandling.Decimal
  488. };
  489. joRtn.Add("data", JToken.FromObject(JsonConvert.DeserializeObject(decData)));
  490. bool rtn = encrypt.verify(joRtn, signData);
  491. if (rtn)
  492. {
  493. Global.writeLog(funNO + "【明文出参】:\r\n" + decData);
  494. joRtn = JObject.Parse(decData);
  495. joRtn.Add("success", "True");
  496. }
  497. else
  498. {
  499. Global.writeLog("验签失败,请核查!");
  500. }
  501. }
  502. return joRtn;
  503. }
  504. finally
  505. {
  506. string plainData = data;
  507. data = JsonHelper.setCenterInpar(funNO,JObject.Parse(data));
  508. this.saveCenterLog(JsonHelper.Compress(data), joRtn.ToString(), JsonHelper.Compress(plainData), joRtn.ToString());
  509. }
  510. }
  511. catch (Exception ex)
  512. {
  513. if (joRtn["infcode"] == null)
  514. { joRtn.Add("infcode", -1); }
  515. if (joRtn["err_msg"] == null)
  516. { joRtn.Add("err_msg", "invokeCenterService(3):" + ex.Message); }
  517. outPar = JsonHelper.Compress(joRtn);
  518. return joRtn;
  519. }
  520. finally
  521. {
  522. Global.writeLog(funNO + "(" + Global.curEvt.URL + ")", joInput.ToString(), joRtn.ToString());
  523. this.saveCenterLog(joInput.ToString(), joRtn.ToString(), joInput.ToString(), joRtn.ToString());
  524. }
  525. }
  526. /// <summary>
  527. /// 保存中心交易日志到数据库
  528. /// </summary>
  529. /// <param name="inParam"></param>
  530. /// <param name="outParam"></param>
  531. /// <param name="inParamPlain"></param>
  532. /// <param name="outParamPlain"></param>
  533. private void saveCenterLog(string inParam, string outParam, string inParamPlain, string outParamPlain)
  534. {
  535. dynamic joIris = new JObject();
  536. string sRtn = "";
  537. try
  538. {
  539. //解析postContent,插入医保交易日志表
  540. JObject joInParam = new JObject(JObject.Parse(inParam));
  541. //解包
  542. JObject joIn = Utils.removeWrapper(joInParam);
  543. JObject joOut = new JObject(JObject.Parse(outParam));
  544. JObject joInPlain = new JObject(JObject.Parse(inParamPlain));
  545. JObject joOutPlain = new JObject(JObject.Parse(outParamPlain));
  546. JArray jaParams = new JArray();
  547. JObject joParam = new JObject();
  548. joParam.Add("inParam", JObject.FromObject(joIn));
  549. joParam.Add("outParam", JObject.FromObject(joOut));
  550. joParam.Add("inParamPlain", JObject.FromObject(joInPlain));
  551. joParam.Add("outParamPlain", JObject.FromObject(joOutPlain));
  552. joParam.Add("HospitalDr", Global.inf.hospitalDr);
  553. joParam.Add("InterfaceDr", Global.inf.interfaceDr);
  554. joParam.Add("updateUserID", Global.user.ID);
  555. joParam.Add("psn_no", Global.pat.psn_no);
  556. jaParams.Add(joParam);
  557. joIris.code = "09010021";
  558. joIris.Add("params", jaParams);
  559. //InvokeHelper invoker = new InvokeHelper();
  560. sRtn = invokeInsuService(joIris.ToString(), "保存日志到数据库").ToString();
  561. }
  562. catch (Exception ex)
  563. {
  564. sRtn = JsonHelper.setExceptionJson(-100, "保存日志异常", ex.Message).ToString();
  565. Global.writeLog_Iris("保存日志异常:" + sRtn.ToString());
  566. }
  567. }
  568. #endregion
  569. #region 电子处方
  570. /// </summary>
  571. /// <param name="funNO"></param>
  572. /// <param name="data"></param>
  573. /// <returns></returns>
  574. public JObject invokeEPCenterService(string funNO, string data)
  575. {
  576. JObject joRtn = new JObject();
  577. string outPar = "";
  578. try
  579. {
  580. Global.curEvt.URL = Global.inf.centerURL;
  581. switch (funNO)
  582. {
  583. case "7101":
  584. {
  585. Global.curEvt.URL = Global.curEvt.URL + "CFYLJG001";
  586. break;
  587. }
  588. case "7102":
  589. {
  590. Global.curEvt.URL = Global.curEvt.URL + "CFYLJG002";
  591. break;
  592. }
  593. case "7103":
  594. {
  595. Global.curEvt.URL = Global.curEvt.URL + "CFYLJG003";
  596. break;
  597. }
  598. case "7104":
  599. {
  600. Global.curEvt.URL = Global.curEvt.URL + "CFYLJG004";
  601. break;
  602. }
  603. case "7105":
  604. {
  605. Global.curEvt.URL = Global.curEvt.URL + "CFYLJG005";
  606. break;
  607. }
  608. case "7106":
  609. {
  610. Global.curEvt.URL = Global.curEvt.URL + "CFYLJG006";
  611. break;
  612. }
  613. case "7107":
  614. {
  615. Global.curEvt.URL = Global.curEvt.URL + "CFYLJG007";
  616. break;
  617. }
  618. //case "7108":
  619. // {
  620. // Global.curEvt.URL = Global.curEvt.URL + "/fixmedins/rxChkInfoCallback";
  621. // break;
  622. // }
  623. //case "7109":
  624. // {
  625. // Global.curEvt.URL = Global.curEvt.URL + "/fixmedins/rxSetlInfoCallback";
  626. // break;
  627. // }
  628. }
  629. //Global.curEvt.URL = Global.inf.centerURL;
  630. joRtn = invokeCenterService(data);
  631. outPar = JsonHelper.Compress(joRtn);
  632. return joRtn;
  633. }
  634. catch (Exception ex)
  635. {
  636. if (joRtn["infcode"] == null)
  637. { joRtn.Add("infcode", -1); }
  638. if (joRtn["err_msg"] == null)
  639. { joRtn.Add("err_msg", "invokeCenterServicePresCir(3):" + ex.Message); }
  640. outPar = JsonHelper.Compress(joRtn);
  641. return joRtn;
  642. }
  643. finally
  644. {
  645. Global.writeLog(funNO + "(" + Global.curEvt.URL + ")", JsonHelper.Compress(data), joRtn.ToString());
  646. //this.saveCenterLog(JsonHelper.Compress(data), outPar, JsonHelper.Compress(data), outPar);
  647. }
  648. }
  649. /// <summary>
  650. /// 医保电子处方流转调用服务
  651. /// </summary>
  652. /// <param name="data"></param>
  653. /// <returns></returns>
  654. //private JObject invokeEPCenterService(string data)
  655. //{
  656. // string postContent = "";
  657. // JObject joRtn = new JObject();
  658. // try
  659. // {
  660. // string timestamp = TimeStamp.get13().ToString(); //当前时间戳(秒)
  661. // string nonce = Guid.NewGuid().ToString(); //非重复的随机字符串(十分钟内不能重复)
  662. // //内容类型
  663. // //Signer signer = new Signer();
  664. // //signer.Key = Global.inf.privateKey; //应用编码
  665. // //signer.Secret = Global.inf.secretKey; //secretKey 私钥
  666. // //HttpRequest Resquest = new HttpRequest("POST", new Uri(Global.curEvt.URL));
  667. // //Resquest.headers.Add("charset", "UTF-8");
  668. // //Resquest.headers.Add("x-hw-id", signer.Key);
  669. // //Resquest.headers.Add("x-tif-timestamp", timestamp);
  670. // //Resquest.headers.Add("x-tif-passid", signer.Key);
  671. // //Resquest.headers.Add("x-tif-nonce", nonce);
  672. // //Resquest.body = signData;
  673. // //HttpWebRequest req = signer.Sign(Resquest);
  674. // HttpWebRequest req = (HttpWebRequest)WebRequest.Create(Global.curEvt.URL);
  675. // req.Method = "POST";
  676. // req.ContentType = "application/json;charset=utf8";
  677. // req.Timeout = 5 * 10000;
  678. // try
  679. // {
  680. // var writer = new StreamWriter(req.GetRequestStream());
  681. // writer.Write(data);
  682. // writer.Flush();
  683. // HttpWebResponse resp = (HttpWebResponse)req.GetResponse();
  684. // StreamReader reader = new StreamReader(resp.GetResponseStream());
  685. // string RtnStr = reader.ReadToEnd();
  686. // joRtn = JObject.Parse(RtnStr);
  687. // // 解密返回值
  688. // EncryptHelper encrypt = new EncryptHelper(Global.inf.appId, Global.inf.secretKey, Global.inf.publicKey, Global.inf.privateKey);
  689. // string encData = JsonHelper.getDestValue(joRtn, "encData");
  690. // string signData = JsonHelper.getDestValue(joRtn, "signData");
  691. // if (!string.IsNullOrEmpty(encData) && !string.IsNullOrEmpty(signData))
  692. // {
  693. // joRtn.Remove("encData");
  694. // joRtn.Remove("signData");
  695. // joRtn.Remove("data");
  696. // //解密
  697. // string decData = encrypt.decrypt(encData);
  698. // // 验签
  699. // JsonConvert.DefaultSettings = () => new JsonSerializerSettings
  700. // {
  701. // FloatParseHandling = FloatParseHandling.Decimal
  702. // };
  703. // joRtn.Add("data", JToken.FromObject(JsonConvert.DeserializeObject(decData)));
  704. // bool rtn = encrypt.verify(joRtn, signData);
  705. // if (rtn)
  706. // {
  707. // Global.writeLog("【明文出参】:\r\n" + decData);
  708. // joRtn = JObject.Parse(decData);
  709. // joRtn.Add("code", 0);
  710. // joRtn.Add("message", "成功");
  711. // }
  712. // else
  713. // {
  714. // Global.writeLog("验签失败,请核查!");
  715. // }
  716. // }
  717. // return joRtn;
  718. // }
  719. // catch (WebException e)
  720. // {
  721. // HttpWebResponse resp = (HttpWebResponse)e.Response;
  722. // if (resp != null)
  723. // {
  724. // return JsonHelper.setExceptionJson(-99, "centerServeiceInvok中获得响应流异常(a)", new StreamReader(resp.GetResponseStream()).ReadToEnd() + "异常内容:" + e.Message);
  725. // }
  726. // else
  727. // {
  728. // return JsonHelper.setExceptionJson(-99, "centerServeiceInvok中获得响应流异常(b)", e.Message);
  729. // }
  730. // }
  731. // }
  732. // catch (Exception ex)
  733. // {
  734. // postContent = "调用中心服务异常" + ex.Message;
  735. // joRtn.Add("infcode", -1);
  736. // joRtn.Add("err_msg", "invokeCenterService(Exception_Last):" + ex.Message);
  737. // return joRtn;
  738. // }
  739. //}
  740. #endregion
  741. }
  742. }