/******************************************************************************
* 文件名称: 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());
}
}
}
}