InvokeHelper.cs 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416
  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 PTMedicalInsurance.Common;
  28. namespace PTMedicalInsurance.Helper
  29. {
  30. class InvokeHelper
  31. {
  32. private string serviceURL;
  33. private string authorization;
  34. public InvokeHelper()
  35. {
  36. IniFile ini = new IniFile(Global.curEvt.path + @"\CenterServiceURL.ini");
  37. Global.inf.centerURL = ini.ReadValue("CENTER", "url");
  38. Global.inf.uploadURL = ini.ReadValue("CENTER", "upload");
  39. Global.inf.downURL = ini.ReadValue("CENTER", "download");
  40. Global.inf.ecURL = ini.ReadValue("CENTER", "ecToken");
  41. }
  42. #region 内部服务调用
  43. /// <summary>
  44. /// iris服务调用的封装
  45. /// </summary>
  46. /// <param name="data"></param>
  47. /// <returns></returns>
  48. public JObject invokeIrisService(string data, string serviceDesc)
  49. {
  50. string rtn = "", url = "";
  51. JObject joRtn = new JObject();
  52. try
  53. {
  54. //先根据用户请求的uri构造请求地址
  55. url = serviceURL;
  56. ServicePointManager.ServerCertificateValidationCallback = delegate { return true; };
  57. ServicePointManager.SecurityProtocol = SecurityProtocolType.Ssl3 | SecurityProtocolType.Tls12 | SecurityProtocolType.Tls11 | SecurityProtocolType.Tls;
  58. //创建Web访问对象
  59. HttpWebRequest myRequest = (HttpWebRequest)WebRequest.Create(url);
  60. //把用户传过来的数据转成“UTF-8”的字节流
  61. byte[] buf = System.Text.Encoding.GetEncoding("UTF-8").GetBytes(data);
  62. //添加头部信息
  63. myRequest.Method = "POST";
  64. myRequest.ContentLength = buf.Length;
  65. myRequest.ContentType = "application/json";
  66. myRequest.Headers.Add("Authorization", authorization);
  67. myRequest.MaximumAutomaticRedirections = 1;
  68. myRequest.AllowAutoRedirect = true;
  69. //发送请求
  70. Stream stream = myRequest.GetRequestStream();
  71. stream.Write(buf, 0, buf.Length);
  72. stream.Close();
  73. //获取接口返回值
  74. //通过Web访问对象获取响应内容
  75. HttpWebResponse myResponse = (HttpWebResponse)myRequest.GetResponse();
  76. rtn = getResponseData(myResponse);
  77. joRtn = JObject.Parse(rtn);
  78. return joRtn;
  79. }
  80. catch (Exception ex)
  81. {
  82. joRtn = JsonHelper.setExceptionJson(-1, serviceDesc, ex.Message);
  83. rtn = JsonConvert.SerializeObject(joRtn);
  84. return joRtn;
  85. }
  86. }
  87. /// <summary>
  88. /// HIS服务调用的封装
  89. /// </summary>
  90. /// <param name="data"></param>
  91. /// <returns></returns>
  92. ///
  93. public JObject invokeHISService(string data, string serviceDesc)
  94. {
  95. JObject joRtn = new JObject();
  96. try
  97. {
  98. //先根据用户请求的uri构造请求地址
  99. serviceURL = string.Format("{0}/{1}", Global.hisConfig.ip, Global.hisConfig.url);
  100. authorization = Global.hisConfig.authorization;
  101. joRtn = invokeIrisService(data, serviceDesc);
  102. return joRtn;
  103. }
  104. catch (Exception ex)
  105. {
  106. joRtn = JsonHelper.setExceptionJson(-1, serviceDesc, ex.Message);
  107. return joRtn;
  108. }
  109. finally
  110. {
  111. Global.writeLog_Iris(serviceDesc + "(" + serviceURL + ")" + "Authorization:" + (authorization), JsonHelper.Compress(data), JsonHelper.Compress(joRtn));
  112. }
  113. }
  114. /// <summary>
  115. /// 医保平台服务调用的封装
  116. /// </summary>
  117. /// <param name="data"></param>
  118. /// <returns></returns>
  119. public JObject invokeInsuService(string data, string serviceDesc)
  120. {
  121. string rtn = "";
  122. JObject joRtn = new JObject();
  123. try
  124. {
  125. //先根据用户请求的uri构造请求地址
  126. serviceURL = string.Format("{0}/{1}", Global.insuConfig.ip, Global.insuConfig.url);
  127. authorization = Global.insuConfig.authorization;
  128. joRtn = invokeIrisService(data, serviceDesc);
  129. rtn = JsonConvert.SerializeObject(joRtn);
  130. //if (serviceDesc == "插入签到信息")
  131. //{
  132. // MessageBox.Show("插入签到信息入参:" + data +"|返回值:"+ rtn.ToString()+"|"+ Global.insuConfig.url);
  133. //}
  134. return joRtn;
  135. }
  136. catch (Exception ex)
  137. {
  138. joRtn = JsonHelper.setExceptionJson(-1, serviceDesc, ex.Message);
  139. rtn = JsonConvert.SerializeObject(joRtn);
  140. return joRtn;
  141. }
  142. finally
  143. {
  144. Global.writeLog_Iris(serviceDesc + "(" + serviceURL + ")" + "Authorization:" + (authorization), JsonHelper.Compress(data), rtn);
  145. }
  146. }
  147. private string getResponseData(HttpWebResponse response)
  148. {
  149. string data = "";
  150. if (response != null)
  151. {
  152. Stream s = response.GetResponseStream();
  153. StreamReader sRead = new StreamReader(s);
  154. data = sRead.ReadToEnd();
  155. sRead.Close();
  156. response.Close();
  157. }
  158. return data;
  159. }
  160. #endregion
  161. #region 医保中心调用
  162. private JObject invokeCenterService(string data)
  163. {
  164. JObject joRtn = new JObject();
  165. IInvokeCenter center = InvokeCenterFactory.create();
  166. string outputData = "";
  167. string errMsg = "";
  168. int iInt = center.Init(ref errMsg);
  169. if (iInt == 0)
  170. {
  171. iInt = center.Business(data, ref outputData, ref errMsg);
  172. joRtn = JObject.Parse(outputData);
  173. return joRtn;
  174. }
  175. else
  176. {
  177. joRtn.Add("infcode", -1);
  178. joRtn.Add("err_msg", "医保动态库初始化失败invokeInitByDLL:" + errMsg);
  179. return joRtn;
  180. }
  181. }
  182. private void prepareCallCenter(string funNo)
  183. {
  184. string prefix = Global.inf.centerURL;
  185. switch (funNo)
  186. {
  187. case "9101":
  188. prefix = Global.inf.uploadURL;
  189. break;
  190. case "9102":
  191. prefix = Global.inf.downURL;
  192. break;
  193. default:
  194. prefix = Global.inf.centerURL;
  195. break;
  196. }
  197. Global.curEvt.URL = prefix + funNo;
  198. }
  199. /// <summary>
  200. /// 这个是调用业务服务的invokeCenterService
  201. /// </summary>
  202. /// <param name="funNO"></param>
  203. /// <param name="data"></param>
  204. /// <returns></returns>
  205. public JObject invokeCenterService(string funNO, JObject data)
  206. {
  207. // 动态调试模式
  208. if (Global.curEvt.enabledDebug)
  209. {
  210. CenterResult center = new CenterResult();
  211. center.setTradeNo(funNO);
  212. if (center.ShowDialog() == DialogResult.OK)
  213. {
  214. string outPar = center.returnData;
  215. return JObject.Parse(outPar);
  216. }
  217. }
  218. prepareCallCenter(funNO);
  219. return invokeCenterService(JsonHelper.toJsonString(data));
  220. }
  221. /// <summary>
  222. /// 这个是下载目录用的invokeCenterService
  223. /// </summary>
  224. /// <param name="funNO"></param>
  225. /// <param name="data"></param>
  226. /// <returns></returns>
  227. public JObject invokeCenterService(string funNO, string data)
  228. {
  229. // 动态调试模式
  230. if (Global.curEvt.enabledDebug)
  231. {
  232. CenterResult center = new CenterResult();
  233. center.setTradeNo(funNO);
  234. if (center.ShowDialog() == DialogResult.OK)
  235. {
  236. string outPar = center.returnData;
  237. return JObject.Parse(outPar);
  238. }
  239. }
  240. prepareCallCenter(funNO);
  241. return invokeCenterService(data);
  242. }
  243. /// <summary>
  244. /// 医保目录txt文件下载
  245. /// </summary>
  246. /// <param name="data"></param>
  247. /// <returns></returns>
  248. public JObject DownloadCenterFile(string data)
  249. {
  250. //download file
  251. IInvokeCenter center = InvokeCenterFactory.create();
  252. string outputMsg = "";
  253. JObject joRtn = new JObject();
  254. int rtnCode = center.DownloadFile(data, ref outputMsg);
  255. if(rtnCode==0)
  256. {
  257. joRtn = JObject.Parse(outputMsg);
  258. }
  259. else
  260. {
  261. joRtn.Add("infcode", -1);
  262. joRtn.Add("err_msg", "下载文件失败DownloadFile:" + outputMsg);
  263. }
  264. return joRtn;
  265. }
  266. #endregion
  267. #region 移动
  268. /// <summary>
  269. /// 移动
  270. /// </summary>
  271. /// <param name="funNO"></param>
  272. /// <param name="data"></param>
  273. /// <returns></returns>
  274. public JObject invokeMPService(string funNO, string data)
  275. {
  276. return invokeMPService(funNO, JObject.Parse(data));
  277. }
  278. public JObject invokeMPService(string funNO, JObject joInput)
  279. {
  280. JObject joRtn = new JObject();
  281. String outPar = "";
  282. try
  283. {
  284. EncryptHelper encrypt = new EncryptHelper();
  285. string data = JsonHelper.setMPCenterInpar(funNO, joInput);
  286. // 移动支付地址
  287. Global.curEvt.URL = Global.inf.centerURL + funNO;
  288. joRtn = invokeCenterService(data);
  289. Global.writeLog(funNO + "【密文出参】:\r\n" + joRtn.ToString());
  290. string encData = JsonHelper.getDestValue(joRtn, "encData");
  291. string signData = JsonHelper.getDestValue(joRtn, "signData");
  292. if (!string.IsNullOrEmpty(encData) && !string.IsNullOrEmpty(signData))
  293. {
  294. joRtn.Remove("encData");
  295. joRtn.Remove("signData");
  296. joRtn.Remove("data");
  297. //解密
  298. string decData = encrypt.decrypt(encData);
  299. // 验签
  300. JsonConvert.DefaultSettings = () => new JsonSerializerSettings
  301. {
  302. FloatParseHandling = FloatParseHandling.Decimal
  303. };
  304. joRtn.Add("data", JToken.FromObject(JsonConvert.DeserializeObject(decData)));
  305. bool rtn = encrypt.verify(joRtn, signData);
  306. if (rtn)
  307. {
  308. Global.writeLog(funNO + "【明文出参】:\r\n" + decData);
  309. joRtn = JObject.Parse(decData);
  310. joRtn.Add("success", "True");
  311. }
  312. else
  313. {
  314. Global.writeLog("验签失败,请核查!");
  315. }
  316. }
  317. return joRtn;
  318. }
  319. catch (Exception ex)
  320. {
  321. if (joRtn["infcode"] == null)
  322. { joRtn.Add("infcode", -1); }
  323. if (joRtn["err_msg"] == null)
  324. { joRtn.Add("err_msg", "invokeCenterService(3):" + ex.Message); }
  325. outPar = JsonHelper.Compress(joRtn);
  326. return joRtn;
  327. }
  328. finally
  329. {
  330. Global.writeLog(funNO + "(" + Global.curEvt.URL + ")", joInput.ToString(), joRtn.ToString());
  331. this.saveCenterLog(joInput.ToString(), joRtn.ToString(), joInput.ToString(), joRtn.ToString());
  332. }
  333. }
  334. /// <summary>
  335. /// 保存中心交易日志到数据库
  336. /// </summary>
  337. /// <param name="inParam"></param>
  338. /// <param name="outParam"></param>
  339. /// <param name="inParamPlain"></param>
  340. /// <param name="outParamPlain"></param>
  341. private void saveCenterLog(string inParam, string outParam, string inParamPlain, string outParamPlain)
  342. {
  343. dynamic joIris = new JObject();
  344. string sRtn = "";
  345. try
  346. {
  347. //解析postContent,插入医保交易日志表
  348. JObject joInParam = new JObject(JObject.Parse(inParam));
  349. //解包
  350. JObject joIn = Utils.removeWrapper(joInParam);
  351. JObject joOut = new JObject(JObject.Parse(outParam));
  352. JObject joInPlain = new JObject(JObject.Parse(inParamPlain));
  353. JObject joOutPlain = new JObject(JObject.Parse(outParamPlain));
  354. JArray jaParams = new JArray();
  355. JObject joParam = new JObject();
  356. joParam.Add("inParam", JObject.FromObject(joIn));
  357. joParam.Add("outParam", JObject.FromObject(joOut));
  358. joParam.Add("inParamPlain", JObject.FromObject(joInPlain));
  359. joParam.Add("outParamPlain", JObject.FromObject(joOutPlain));
  360. joParam.Add("HospitalDr", Global.inf.hospitalDr);
  361. joParam.Add("InterfaceDr", Global.inf.interfaceDr);
  362. joParam.Add("updateUserID", Global.user.ID);
  363. joParam.Add("psn_no", Global.pat.psn_no);
  364. jaParams.Add(joParam);
  365. joIris.code = "09010021";
  366. joIris.Add("params", jaParams);
  367. //InvokeHelper invoker = new InvokeHelper();
  368. sRtn = invokeInsuService(joIris.ToString(), "保存日志到数据库").ToString();
  369. }
  370. catch (Exception ex)
  371. {
  372. sRtn = JsonHelper.setExceptionJson(-100, "保存日志异常", ex.Message).ToString();
  373. Global.writeLog_Iris("保存日志异常:" + sRtn.ToString());
  374. }
  375. }
  376. #endregion
  377. }
  378. }