/******************************************************************************
* 文件名称: 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;
using PTMedicalInsurance.Common;
namespace PTMedicalInsurance.Helper
{
class InvokeHelper
{
private string serviceURL;
private string authorization;
public InvokeHelper()
{
IniFile ini = new IniFile(Global.curEvt.path + @"\CenterServiceURL.ini");
Global.inf.centerURL = ini.ReadValue("CENTER", "url");
Global.inf.uploadURL = ini.ReadValue("CENTER", "upload");
Global.inf.downURL = ini.ReadValue("CENTER", "download");
Global.inf.ecURL = ini.ReadValue("CENTER", "ecToken");
}
#region 内部服务调用
/// <summary>
/// iris服务调用的封装
/// </summary>
/// <param name="data"></param>
/// <returns></returns>
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;
}
}
/// <summary>
/// HIS服务调用的封装
/// </summary>
/// <param name="data"></param>
/// <returns></returns>
///
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));
}
}
/// <summary>
/// 医保平台服务调用的封装
/// </summary>
/// <param name="data"></param>
/// <returns></returns>
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 医保中心调用
private JObject invokeCenterService(string data)
{
JObject joRtn = new JObject();
IInvokeCenter center = InvokeCenterFactory.create();
string outputData = "";
string errMsg = "";
int iInt = center.Init(ref errMsg);
if (iInt == 0)
{
iInt = center.Business(data, ref outputData, ref errMsg);
joRtn = JObject.Parse(outputData);
return joRtn;
}
else
{
joRtn.Add("infcode", -1);
joRtn.Add("err_msg", "医保动态库初始化失败invokeInitByDLL:" + errMsg);
return joRtn;
}
}
private void prepareCallCenter(string funNo)
{
string prefix = Global.inf.centerURL;
switch (funNo)
{
case "9101":
prefix = Global.inf.uploadURL;
break;
case "9102":
prefix = Global.inf.downURL;
break;
default:
prefix = Global.inf.centerURL;
break;
}
Global.curEvt.URL = prefix + funNo;
}
/// <summary>
/// 这个是调用业务服务的invokeCenterService
/// </summary>
/// <param name="funNO"></param>
/// <param name="data"></param>
/// <returns></returns>
public JObject invokeCenterService(string funNO, JObject data)
{
// 动态调试模式
if (Global.curEvt.enabledDebug)
{
CenterResult center = new CenterResult();
center.setTradeNo(funNO);
if (center.ShowDialog() == DialogResult.OK)
{
string outPar = center.returnData;
return JObject.Parse(outPar);
}
}
prepareCallCenter(funNO);
return invokeCenterService(JsonHelper.toJsonString(data));
}
/// <summary>
/// 这个是下载目录用的invokeCenterService
/// </summary>
/// <param name="funNO"></param>
/// <param name="data"></param>
/// <returns></returns>
public JObject invokeCenterService(string funNO, string data)
{
// 动态调试模式
if (Global.curEvt.enabledDebug)
{
CenterResult center = new CenterResult();
center.setTradeNo(funNO);
if (center.ShowDialog() == DialogResult.OK)
{
string outPar = center.returnData;
return JObject.Parse(outPar);
}
}
prepareCallCenter(funNO);
return invokeCenterService(data);
}
/// <summary>
/// 医保目录txt文件下载
/// </summary>
/// <param name="data"></param>
/// <returns></returns>
public JObject DownloadCenterFile(string data)
{
//download file
IInvokeCenter center = InvokeCenterFactory.create();
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 移动
/// <summary>
/// 移动
/// </summary>
/// <param name="funNO"></param>
/// <param name="data"></param>
/// <returns></returns>
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
{
EncryptHelper encrypt = new EncryptHelper();
string data = JsonHelper.setMPCenterInpar(funNO, joInput);
// 移动支付地址
Global.curEvt.URL = Global.inf.centerURL + funNO;
joRtn = invokeCenterService(data);
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;
}
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());
}
}
/// <summary>
/// 保存中心交易日志到数据库
/// </summary>
/// <param name="inParam"></param>
/// <param name="outParam"></param>
/// <param name="inParamPlain"></param>
/// <param name="outParamPlain"></param>
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
}
}