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