/****************************************************************************** * 文件名称: InvokeHelper.cs * 文件说明: 调用助手,调用方法的封装 * 当前版本: V1.0 * 创建日期: 2022-04-12 * * 2020-04-12: 增加 businessDLLInvoke 方法 * 2020-04-12: 增加 writeLog 方法 * 2020-04-14: 增加 businessDLLInvoke(重载) 方法 * 2020-04-14: 增加 irisServiceInvoke 方法 ******************************************************************************/ using Newtonsoft.Json.Linq; using System; using System.Collections.Generic; using System.IO; using System.Linq; using System.Net; using System.Text; using System.Threading.Tasks; using System.Windows.Forms; using PTMedicalInsurance.Helper; using Newtonsoft.Json; using PTMedicalInsurance.Common; using PTMedicalInsurance.Variables; using System.Runtime.InteropServices; using PTMedicalInsurance.Forms; namespace PTMedicalInsurance.Helper { public class InvokeHelper { private string serviceURL; private string authorization; public InvokeHelper() { } #region 内部服务调用 /// /// iris服务调用的封装 /// /// /// public JObject invokeIrisService(string data, string serviceDesc) { string rtn = "", url = ""; JObject joRtn = new JObject(); try { //先根据用户请求的uri构造请求地址 url = serviceURL; ServicePointManager.ServerCertificateValidationCallback = delegate { return true; }; ServicePointManager.SecurityProtocol = SecurityProtocolType.Ssl3 | SecurityProtocolType.Tls12 | SecurityProtocolType.Tls11 | SecurityProtocolType.Tls; //创建Web访问对象 HttpWebRequest myRequest = (HttpWebRequest)WebRequest.Create(url); //把用户传过来的数据转成“UTF-8”的字节流 byte[] buf = System.Text.Encoding.GetEncoding("UTF-8").GetBytes(data); //添加头部信息 myRequest.Method = "POST"; myRequest.ContentLength = buf.Length; myRequest.ContentType = "application/json"; myRequest.Headers.Add("Authorization", authorization); myRequest.MaximumAutomaticRedirections = 1; myRequest.AllowAutoRedirect = true; //发送请求 Stream stream = myRequest.GetRequestStream(); stream.Write(buf, 0, buf.Length); stream.Close(); //获取接口返回值 //通过Web访问对象获取响应内容 HttpWebResponse myResponse = (HttpWebResponse)myRequest.GetResponse(); rtn = getResponseData(myResponse); joRtn = JObject.Parse(rtn); return joRtn; } catch (Exception ex) { joRtn = JsonHelper.setExceptionJson(-1, serviceDesc, ex.Message); rtn = JsonConvert.SerializeObject(joRtn); return joRtn; } } /// /// HIS服务调用的封装 /// /// /// /// public JObject invokeHISService(string data, string serviceDesc) { JObject joRtn = new JObject(); try { //先根据用户请求的uri构造请求地址 serviceURL = string.Format("{0}/{1}", Global.hisConfig.ip, Global.hisConfig.url); authorization = Global.hisConfig.authorization; joRtn = invokeIrisService(data, serviceDesc); return joRtn; } catch (Exception ex) { joRtn = JsonHelper.setExceptionJson(-1, serviceDesc, ex.Message); return joRtn; } finally { Global.writeLog_Iris(serviceDesc + "(" + serviceURL + ")" + "Authorization:" + (authorization), JsonHelper.Compress(data), JsonHelper.Compress(joRtn)); } } /// /// 医保平台服务调用的封装 /// /// /// public JObject invokeInsuService(string data, string serviceDesc) { string rtn = ""; JObject joRtn = new JObject(); try { //先根据用户请求的uri构造请求地址 serviceURL = string.Format("{0}/{1}", Global.insuConfig.ip, Global.insuConfig.url); authorization = Global.insuConfig.authorization; joRtn = invokeIrisService(data, serviceDesc); rtn = JsonConvert.SerializeObject(joRtn); //if (serviceDesc == "插入签到信息") //{ // MessageBox.Show("插入签到信息入参:" + data +"|返回值:"+ rtn.ToString()+"|"+ Global.insuConfig.url); //} return joRtn; } catch (Exception ex) { joRtn = JsonHelper.setExceptionJson(-1, serviceDesc, ex.Message); rtn = JsonConvert.SerializeObject(joRtn); return joRtn; } finally { Global.writeLog_Iris(serviceDesc + "(" + serviceURL + ")" + "Authorization:" + (authorization), JsonHelper.Compress(data), rtn); } } private string getResponseData(HttpWebResponse response) { string data = ""; if (response != null) { Stream s = response.GetResponseStream(); StreamReader sRead = new StreamReader(s); data = sRead.ReadToEnd(); sRead.Close(); response.Close(); } return data; } #endregion #region 医保中心调用 /// /// 仅辅助交易、自定义交易使用 /// /// /// /// public JObject invokeCenterAgentService(string funNo, JObject joInput) { Global.curEvt.URL = Global.inf.centerURL; Global.curEvt.funNo = funNo; string data = JsonHelper.setCenterInpar(funNo, joInput); return invokeCenterService(data); } private JObject invokeCenterService(string data, ModeEnum mode = ModeEnum.REST) { JObject joRtn = new JObject(); try { IInvokeCenter center = new InvokeCenterFactory().create(mode); string outputData = ""; string errMsg = ""; int iInt = center.Init(ref errMsg); if (iInt == 0) { //Utils.LoadCoreAPIKey(); iInt = center.Business(data, ref outputData, ref errMsg); if (iInt == 0 && !string.IsNullOrEmpty(outputData)) { joRtn = JObject.Parse(outputData); if (Utils.LoadEncyptFlag(Global.curEvt.funNo)) { //解密 YinHaiEncrypt yhEncrypt = new YinHaiEncrypt(); if (JsonHelper.parseCenterReturnJson(joRtn, out errMsg) == 0) { string output = JsonHelper.getDestValue(joRtn, "output"); output = yhEncrypt.Decrypt(output); if (!string.IsNullOrEmpty(output) && !output.Equals("null")) { joRtn["output"] = JObject.Parse(output); } } } } else { joRtn.Add("infcode", iInt); joRtn.Add("err_msg", outputData); return joRtn; } return joRtn; } else { joRtn.Add("infcode", -1); joRtn.Add("err_msg", "医保动态库初始化失败invokeInitByDLL:" + errMsg); return joRtn; } } finally { Global.writeLog("调用中心:", JsonHelper.Compress(data), joRtn.ToString()); // 保存到服务器 this.saveCenterLog(JsonHelper.Compress(data),joRtn.ToString(), JsonHelper.Compress(data), joRtn.ToString()); } } private void prepareCallURI(TradeEnum trade) { string funNo = trade.GetCode() ; Global.curEvt.funNo = funNo; string prefix = Global.inf.centerURL; switch (trade) { case TradeEnum.FileUpload: prefix = Global.inf.uploadURL??Global.inf.centerURL; break; case TradeEnum.FileDownload: prefix = Global.inf.downURL; break; default: prefix = Global.inf.centerURL; break; } // 根据情况确实是否需要加funNo Global.curEvt.URL = prefix ; } /// /// 通过枚举转换要调用的接口 /// /// /// /// public JObject invokeCenterService(TradeEnum trade, JObject joInput) { string funNo = trade.GetCode(); // 入参统一转换 JObject request = Utils.ConvertRequest(trade,joInput); string data = JsonHelper.toJsonString(request); // 统一封装请求头 if (trade.GetMode() == ModeEnum.REST) { data = JsonHelper.setCenterInpar(funNo, request); } JObject joRtn = new JObject(); // 调试模式 //if (Global.curEvt.enabledDebug) //{ // CenterResult center = new CenterResult(); // center.setTradeNo(trade.GetCode(), data); // if (center.ShowDialog() == DialogResult.OK) // { // // 接口实际返回数据 // string outPar = center.returnData; // joRtn = JObject.Parse(outPar); // } //} //else { if (Global.curEvt.MustConvertURL) { prepareCallURI(trade); } joRtn = invokeCenterService(data, trade.GetMode()); } // 返回结果统一转换 joRtn = Utils.ConvertResponse(trade,joRtn); return joRtn; } /// /// 医保目录txt文件下载 /// /// /// public JObject DownloadCenterFile(string data, ModeEnum mode = ModeEnum.REST) { //download file IInvokeCenter center = new InvokeCenterFactory().create(mode); string outputMsg = ""; JObject joRtn = new JObject(); int rtnCode = center.DownloadFile(data, ref outputMsg); if(rtnCode==0) { joRtn = JObject.Parse(outputMsg); } else { joRtn.Add("infcode", -1); joRtn.Add("err_msg", "下载文件失败DownloadFile:" + outputMsg); } return joRtn; } #endregion #region 移动 /// /// 移动 /// /// /// /// public JObject invokeMPService(string funNO, string data) { return invokeMPService(funNO, JObject.Parse(data)); } public JObject invokeMPService(string funNO, JObject joInput) { JObject joRtn = new JObject(); String outPar = ""; try { string url = ""; switch (funNO) { case "6201": url = "/org/local/api/hos/uldFeeInfo"; break; case "6202": url = "/org/local/api/hos/pay_order"; break; case "6203": url = "/org/local/api/hos/refund_Order"; break; case "6301": url = "/org/local/api/hos/query_order_info"; break; case "6401": url = "/org/local/api/hos/revoke_order"; break; default: break; } Global.writeLog(Global.inf.MobilePay.url); EncryptHelper encrypt = new EncryptHelper(Global.inf.MobilePay.appid, Global.inf.MobilePay.secretKey, Global.inf.MobilePay.publicKey, Global.inf.MobilePay.privateKey); string data = JsonHelper.setMPCenterInpar(funNO, joInput); // 移动支付地址 Global.curEvt.URL = Global.inf.MobilePay.url + url; string outputData = "", errMsg = ""; // 动态调试模式 if (Global.curEvt.enabledDebug) { CenterResult center = new CenterResult(); center.setTradeNo(funNO,data); if (center.ShowDialog() == DialogResult.OK) { outPar = center.returnData; return JObject.Parse(outPar); } } try { InvokeRestCenter mobileCenter = new InvokeRestCenter(); //Utils.LoadMobileAPIKey(); int iInt = mobileCenter.Business(data, ref outputData, ref errMsg); joRtn = JObject.Parse(outputData); Global.writeLog(funNO + "【密文出参】:\r\n" + joRtn.ToString()); string encData = JsonHelper.getDestValue(joRtn, "encData"); string signData = JsonHelper.getDestValue(joRtn, "signData"); if (!string.IsNullOrEmpty(encData) && !string.IsNullOrEmpty(signData)) { joRtn.Remove("encData"); joRtn.Remove("signData"); joRtn.Remove("data"); //解密 string decData = encrypt.decrypt(encData); // 验签 JsonConvert.DefaultSettings = () => new JsonSerializerSettings { FloatParseHandling = FloatParseHandling.Decimal }; joRtn.Add("data", JToken.FromObject(JsonConvert.DeserializeObject(decData))); bool rtn = encrypt.verify(joRtn, signData); if (rtn) { Global.writeLog(funNO + "【明文出参】:\r\n" + decData); joRtn = JObject.Parse(decData); joRtn.Add("success", "True"); } else { Global.writeLog("验签失败,请核查!"); } } return joRtn; } finally { string plainData = data; data = JsonHelper.setCenterInpar(funNO,JObject.Parse(data)); this.saveCenterLog(JsonHelper.Compress(data), joRtn.ToString(), JsonHelper.Compress(plainData), joRtn.ToString()); } } catch (Exception ex) { if (joRtn["infcode"] == null) { joRtn.Add("infcode", -1); } if (joRtn["err_msg"] == null) { joRtn.Add("err_msg", "invokeCenterService(3):" + ex.Message); } outPar = JsonHelper.Compress(joRtn); return joRtn; } finally { Global.writeLog(funNO + "(" + Global.curEvt.URL + ")", joInput.ToString(), joRtn.ToString()); this.saveCenterLog(joInput.ToString(), joRtn.ToString(), joInput.ToString(), joRtn.ToString()); } } /// /// 保存中心交易日志到数据库 /// /// /// /// /// private void saveCenterLog(string inParam, string outParam, string inParamPlain, string outParamPlain) { dynamic joIris = new JObject(); string sRtn = ""; try { //解析postContent,插入医保交易日志表 JObject joInParam = new JObject(JObject.Parse(inParam)); //解包 JObject joIn = Utils.removeWrapper(joInParam); JObject joOut = new JObject(JObject.Parse(outParam)); JObject joInPlain = new JObject(JObject.Parse(inParamPlain)); JObject joOutPlain = new JObject(JObject.Parse(outParamPlain)); JArray jaParams = new JArray(); JObject joParam = new JObject(); joParam.Add("inParam", JObject.FromObject(joIn)); joParam.Add("outParam", JObject.FromObject(joOut)); joParam.Add("inParamPlain", JObject.FromObject(joInPlain)); joParam.Add("outParamPlain", JObject.FromObject(joOutPlain)); joParam.Add("HospitalDr", Global.inf.hospitalDr); joParam.Add("InterfaceDr", Global.inf.interfaceDr); joParam.Add("updateUserID", Global.user.ID); joParam.Add("psn_no", Global.pat.psn_no); jaParams.Add(joParam); joIris.code = "09010021"; joIris.Add("params", jaParams); //InvokeHelper invoker = new InvokeHelper(); sRtn = invokeInsuService(joIris.ToString(), "保存日志到数据库").ToString(); } catch (Exception ex) { sRtn = JsonHelper.setExceptionJson(-100, "保存日志异常", ex.Message).ToString(); Global.writeLog_Iris("保存日志异常:" + sRtn.ToString()); } } #endregion } }