/****************************************************************************** * 文件名称: 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 Newtonsoft.Json; 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 PTMedicalInsurance.Common; using PTMedicalInsurance.Variables; using System.Runtime.InteropServices; using System.Reflection; namespace PTMedicalInsurance.Helper { class InvokeHelper { private string serviceURL; private string authorization; public int yh_hb_call(string infno, string input, out string output) { try { Type YinHaiComType = System.Type.GetTypeFromProgID("yinhai.yh_hb_sctr"); if (YinHaiComType != null) { //创建实例,不能再次创建,否则会提示没有初始化 object YinHaiComInstance = System.Activator.CreateInstance(YinHaiComType); if (YinHaiComInstance != null) { Global.writeLog("实例创建成功,准备调用yh_hb_call服务"); } else { output = "实例不存在!"; Global.writeLog("实例不存在"); return -1; } //GlobalVariables.writeLog("入参infno:" + infno); //GlobalVariables.writeLog("入参input:" + input); //设置需要设置的参数值 object[] ParamArray = new object[3]; ParamArray[0] = infno; ParamArray[1] = input; ParamArray[2] = ""; ParameterModifier[] ParamMods = new ParameterModifier[1]; ParamMods[0] = new ParameterModifier(3); // 初始化为接口参数的个数 //ParamMods[0][0] = false; //ParamMods[0][1] = false; ParamMods[0][2] = true; YinHaiComType.InvokeMember("yh_hb_call", // 接口函数名 BindingFlags.Default | BindingFlags.InvokeMethod, null, YinHaiComInstance, // 调用的COM组件 ParamArray, // 参数数组 ParamMods, // 指定返回参数的ParameterModifier数组 null, null); output = ParamArray[2].ToString(); Global.writeLog("Com输出:" + output); return 0; } else { output = "COM加载失败!"; Global.writeLog("COM加载失败!"); return -1; } } catch (Exception ex) { output = ex.Message; Global.writeLog("COM加载失败!" + output); return -1; } } /// /// 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(); //通过响应内容流创建StreamReader对象,因为StreamReader更高级更快 StreamReader reader = new StreamReader(myResponse.GetResponseStream(), Encoding.UTF8); //string rtn = HttpUtility.UrlDecode(reader.ReadToEnd());//如果有编码问题就用这个方法 rtn = reader.ReadToEnd();//利用StreamReader就可以从响应内容从头读到尾 reader.Close(); myResponse.Close(); 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); } } /// /// 医保中心Post服务调用封装 /// /// /// private JObject invokeCenterService(string data) { string postContent = ""; JObject joRtn = new JObject(); try { //创建一个HTTP请求 HttpWebRequest request = (HttpWebRequest)WebRequest.Create(Global.curEvt.URL); //Post请求方式 request.Method = "POST"; //内容类型 request.ContentType = "application/json"; request.Headers.Add("apikey", "fa8kQMIF6LB0D7c6UGQoZc6TCcZO2G6O"); request.Accept = "text/html, application/xhtml+xml, */*"; //昆明增加头部信息 /* string nonce = Guid.NewGuid().ToString(); //非重复的随机字符串(十分钟内不能重复) string timestamp = TimeStamp.get13().ToString(); //当前时间戳(秒) string BusinessID = Global.inf.BusinessID; //服务商ID string InsuHosID = Global.inf.hospitalNO; //医疗机构ID string CreditID = Global.inf.CreditID; //服务商统一社会信用代码 string sTemp = timestamp + BusinessID + nonce; //Sha256 加密生成的签名 signature = sha256(hsf_timestamp + infosyssign + hsf_nonce) string signature = Encrypt.SHA256EncryptStr(sTemp); request.Headers.Add("hsf_signature", signature); request.Headers.Add("hsf_timestamp", timestamp); request.Headers.Add("hsf_nonce", nonce); request.Headers.Add("fixmedins_code", InsuHosID); request.Headers.Add("infosyscode", CreditID); */ //设置参数,并进行URL编码 string paraUrlCoded = data;//System.Web.HttpUtility.UrlEncode(jsonParas); byte[] payload; //将Json字符串转化为字节 payload = System.Text.Encoding.UTF8.GetBytes(paraUrlCoded); //设置请求的ContentLength request.ContentLength = payload.Length; //发送请求,获得请求流 Stream writer; writer = request.GetRequestStream();//获取用于写入请求数据的Stream对象 //将请求参数写入流 writer.Write(payload, 0, payload.Length); writer.Close();//关闭请求流 // String strValue = "";//strValue为http响应所返回的字符流 HttpWebResponse response; try { //获得响应流 response = (HttpWebResponse)request.GetResponse(); } catch (WebException ex) { response = ex.Response as HttpWebResponse; return JsonHelper.setExceptionJson(-99, "centerServeiceInvok中获得响应流异常", ex.Message); } Stream s = response.GetResponseStream(); StreamReader sRead = new StreamReader(s); postContent = sRead.ReadToEnd(); sRead.Close(); joRtn = JObject.Parse(postContent);//返回Json数据 return joRtn; } catch (Exception ex) { postContent = "调用中心服务异常" + ex.Message; joRtn.Add("infcode", -1); joRtn.Add("err_msg", "invokeCenterService(1):" + ex.Message); return joRtn; } } /// /// 这个是调用业务服务的invokeCenterService /// /// /// /// public JObject invokeCenterServiceApi(string funNO, JObject data) { JObject joRtn = new JObject(); string outPar = ""; Boolean bDownLoad = false; int iInt = 0; try { Global.curEvt.URL = Global.inf.centerURL; joRtn = invokeCenterService(data.ToString()); outPar = JsonHelper.Compress(joRtn); return joRtn; } catch (Exception ex) { if (joRtn["infcode"] == null) { joRtn.Add("infcode", -1); } if (joRtn["err_msg"] == null) { joRtn.Add("err_msg", "invokeCenterService(2):" + ex.Message); } outPar = JsonHelper.Compress(joRtn); return joRtn; } finally { Global.writeLog(funNO + "(" + Global.curEvt.URL + ")", JsonHelper.Compress(data), joRtn.ToString()); this.saveCenterLog(JsonHelper.Compress(data), outPar, JsonHelper.Compress(data), outPar); } } /// /// 这个是下载目录用的invokeCenterService /// /// /// /// public JObject invokeCenterServiceApi(string funNO, string data) { JObject joRtn = new JObject(); int iInt = 0; String outPar = ""; Boolean bDownLoad = false; try { Global.curEvt.URL = Global.inf.centerURL; joRtn = invokeCenterService(data); outPar = JsonHelper.Compress(joRtn); return joRtn; } 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 + ")", JsonHelper.Compress(data), outPar); this.saveCenterLog(JsonHelper.Compress(data), outPar, JsonHelper.Compress(data), outPar); } } /// /// 调用银海COM组件invokeCenterService /// /// /// /// public JObject invokeCenterService(string funNO, JObject data) { JObject joRtn = new JObject(); string outPar = ""; try { int iRes = yh_hb_call(funNO, data.ToString(), out outPar); if (iRes == 0) { joRtn = JObject.Parse(outPar); } else { joRtn.Add("infcode", -1); joRtn.Add("err_msg", outPar); outPar = JsonHelper.Compress(joRtn); } return joRtn; } catch (Exception ex) { if (joRtn["infcode"] == null) { joRtn.Add("infcode", -1); } if (joRtn["err_msg"] == null) { joRtn.Add("err_msg", "invokeCenterService(COM):" + ex.Message); } outPar = JsonHelper.Compress(joRtn); return joRtn; } finally { Global.writeLog(funNO + "(" + Global.curEvt.URL + ")", JsonHelper.Compress(data), outPar); this.saveCenterLog(JsonHelper.Compress(data), outPar, JsonHelper.Compress(data), outPar); } } /// /// 调用银海COM组件invokeCenterService /// /// /// /// public JObject invokeCenterService(string funNO, string data) { JObject joRtn = new JObject(); string outPar = ""; try { int iRes = yh_hb_call(funNO, data, out outPar); if (funNO != "YH03") { if (iRes == 0) { joRtn = JObject.Parse(outPar); } else { joRtn.Add("infcode", -1); joRtn.Add("err_msg", outPar); outPar = JsonHelper.Compress(joRtn); } } else //打印交易不做处理 { joRtn.Add("infcode", 0); joRtn.Add("err_msg", ""); outPar = JsonHelper.Compress(joRtn); } return joRtn; } catch (Exception ex) { if (joRtn["infcode"] == null) { joRtn.Add("infcode", -1); } if (joRtn["err_msg"] == null) { joRtn.Add("err_msg", "invokeCenterService(COM):" + ex.Message); } outPar = JsonHelper.Compress(joRtn); return joRtn; } finally { Global.writeLog(funNO + "(" + Global.curEvt.URL + ")", JsonHelper.Compress(data), outPar); this.saveCenterLog(JsonHelper.Compress(data), outPar, JsonHelper.Compress(data), outPar); } } /// /// 医保目录txt文件下载 /// /// /// public JObject DownloadCenterFile(string data) { string error = string.Empty; int errorCode = 0; string sRtn = ""; try { JObject jsonInParam = JObject.Parse(data); string fileName = (string)jsonInParam["input"]["fsDownloadIn"]["filename"]; string filePath = Global.curEvt.path + "\\Download\\" + fileName; //MessageBox.Show("9102下载文件入参:"+jsonInParam.ToString()); //如果不存在目录,则创建目录 if (!Directory.Exists(Global.curEvt.path + "\\Download")) { //创建文件夹 DirectoryInfo dirInfo = Directory.CreateDirectory(Global.curEvt.path + "\\Download"); } if (File.Exists(filePath)) { File.Delete(filePath); } FileStream fs = new FileStream(filePath, FileMode.Append, FileAccess.Write, FileShare.ReadWrite); //创建一个HTTP请求 //Global.curEvt.URL = Global.inf.centerURL + "/hsa-fsi-9102"; Global.curEvt.URL = Global.inf.centerURL; HttpWebRequest request = (HttpWebRequest)WebRequest.Create(Global.curEvt.URL); //Post请求方式 request.Method = "POST"; //内容类型 request.ContentType = "application/json"; request.Headers.Add("apikey", "fa8kQMIF6LB0D7c6UGQoZc6TCcZO2G6O"); request.Accept = "text/html, application/xhtml+xml, */*"; /* //昆明增加头部信息 string timestamp = TimeStamp.get13().ToString(); //当前时间戳(秒) string nonce = Guid.NewGuid().ToString(); //非重复的随机字符串(十分钟内不能重复) string InsuHosID = Global.inf.hospitalNO; //医疗机构ID string CreditID = Global.inf.CreditID; //服务商统一社会信用代码 string BusinessID = Global.inf.BusinessID; //服务商ID string sTemp = timestamp + BusinessID + nonce; //Sha256 加密生成的签名 signature = sha256(hsf_timestamp + infosyssign + hsf_nonce) string signature = Encrypt.SHA256EncryptStr(sTemp); request.Headers.Add("hsf_signature", signature); request.Headers.Add("hsf_timestamp", timestamp); request.Headers.Add("hsf_nonce", nonce); request.Headers.Add("fixmedins_code", InsuHosID); request.Headers.Add("infosyscode", CreditID); */ //设置参数,并进行URL编码 string paraUrlCoded = data;//System.Web.HttpUtility.UrlEncode(jsonParas); byte[] payload; //将Json字符串转化为字节 payload = System.Text.Encoding.UTF8.GetBytes(paraUrlCoded); //设置请求的ContentLength request.ContentLength = payload.Length; Stream writer; try { writer = request.GetRequestStream();//获取用于写入请求数据的Stream对象 } catch (Exception) { writer = null; errorCode = -100; error = "连接服务器失败!"; } //将请求参数写入流 writer.Write(payload, 0, payload.Length); writer.Close();//关闭请求流 // String strValue = "";//strValue为http响应所返回的字符流 //发送请求并获取相应回应数据 HttpWebResponse response = request.GetResponse() as HttpWebResponse; //直到request.GetResponse()程序才开始向目标网页发送Post请求 Stream responseStream = response.GetResponseStream(); //创建本地文件写入流 byte[] bArr = new byte[1024]; int iTotalSize = 0; int size = responseStream.Read(bArr, 0, (int)bArr.Length); while (size > 0) { iTotalSize += size; fs.Write(bArr, 0, size); size = responseStream.Read(bArr, 0, (int)bArr.Length); } fs.Close(); responseStream.Close(); dynamic joReturn = new JObject(); joReturn.errorCode = errorCode; joReturn.errorMessage = error; joReturn.filePath = filePath; sRtn = joReturn.ToString(); return joReturn; } catch (Exception ex) { errorCode = -100; error = ex.Message; dynamic joReturn = new JObject(); joReturn.errorCode = errorCode; joReturn.errorMessage = error; sRtn = joReturn.ToString(); return joReturn; } finally { Global.writeLog("DownloadCenterFile" +"(" + Global.curEvt.URL + ")", data, sRtn); } } /// /// 保存中心交易日志到数据库 /// /// /// /// /// private void saveCenterLog(string inParam, string outParam, string inParamPlain, string outParamPlain) { dynamic joIris = new JObject(); string sRtn = ""; try { //解析postContent,插入医保交易日志表 JObject joIn = new JObject(JObject.Parse(inParam)); 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()); } } } }