123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515 |
- /******************************************************************************
- * 文件名称: 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 内部服务调用
- /// <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 医保中心调用
- /// <summary>
- /// 仅辅助交易、自定义交易使用
- /// </summary>
- /// <param name="funNo"></param>
- /// <param name="joInput"></param>
- /// <returns></returns>
- 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 ;
- }
- /// <summary>
- /// 通过枚举转换要调用的接口
- /// </summary>
- /// <param name="trade"></param>
- /// <param name="data"></param>
- /// <returns></returns>
- public JObject invokeCenterService(TradeEnum trade, JObject joInput)
- {
- string funNo = trade.GetCode();
- // 入参统一转换
- JObject request = Utils.ConvertRequest<JObject>(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<JObject>(trade,joRtn);
- return joRtn;
- }
- /// <summary>
- /// 医保目录txt文件下载
- /// </summary>
- /// <param name="data"></param>
- /// <returns></returns>
- 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 移动
- /// <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
- {
- 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());
- }
- }
- /// <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
- }
- }
|