InvokeRestCenter.cs 8.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220
  1. using Newtonsoft.Json.Linq;
  2. using PTMedicalInsurance.Common;
  3. using PTMedicalInsurance.Variables;
  4. using System;
  5. using System.Collections.Generic;
  6. using System.IO;
  7. using System.Linq;
  8. using System.Net;
  9. using System.Text;
  10. using System.Threading.Tasks;
  11. namespace PTMedicalInsurance.Helper
  12. {
  13. class InvokeRestCenter : IInvokeCenter
  14. {
  15. public int Business(string inputData, ref string outputData, ref string pErrMsg)
  16. {
  17. outputData = "";
  18. pErrMsg = "";
  19. JObject joRtn = new JObject();
  20. try
  21. {
  22. //创建一个HTTP请求
  23. HttpWebRequest request = (HttpWebRequest)WebRequest.Create(Global.curEvt.URL);
  24. //Post请求方式
  25. request.Method = "POST";
  26. //内容类型
  27. request.ContentType = "application/json";
  28. //设置参数,并进行URL编码
  29. string paraUrlCoded = inputData;//System.Web.HttpUtility.UrlEncode(jsonParas);
  30. byte[] payload;
  31. //将Json字符串转化为字节
  32. payload = System.Text.Encoding.UTF8.GetBytes(paraUrlCoded);
  33. //设置请求的ContentLength
  34. request.ContentLength = payload.Length;
  35. //发送请求,获得请求流
  36. Stream writer;
  37. writer = request.GetRequestStream();//获取用于写入请求数据的Stream对象
  38. //将请求参数写入流
  39. writer.Write(payload, 0, payload.Length);
  40. writer.Close();//关闭请求流
  41. HttpWebResponse response = null;
  42. try
  43. {
  44. //获得响应流
  45. response = (HttpWebResponse)request.GetResponse();
  46. }
  47. catch (WebException ex)
  48. {
  49. HttpWebResponse res = (HttpWebResponse)ex.Response;
  50. Stream myResponseStream = res.GetResponseStream();
  51. StreamReader myStreamReader = new StreamReader(myResponseStream, Encoding.UTF8);
  52. string retString = myStreamReader.ReadToEnd();
  53. outputData = JsonHelper.setExceptionJson(-99, "异常返回", retString).ToString();
  54. return -1;
  55. }
  56. outputData = getResponseData(response);
  57. joRtn = JObject.Parse(outputData);//返回Json数据
  58. if (joRtn.ContainsKey("body"))
  59. {
  60. joRtn = (JObject)joRtn.GetValue("body");
  61. outputData = JsonHelper.toJsonString(joRtn);
  62. }
  63. return 0;
  64. }
  65. catch (Exception ex)
  66. {
  67. joRtn.Add("infcode", -1);
  68. joRtn.Add("err_msg", "调用中心服务异常invokeCenterService(1):" + ex.Message);
  69. outputData = JsonHelper.toJsonString(joRtn);
  70. return -1;
  71. }
  72. }
  73. public int BusinessExt(string inputData, ref string outputData, ref string pErrMsg)
  74. {
  75. return this.Business(inputData, ref outputData, ref pErrMsg);
  76. }
  77. public int DownloadFile(string inputData, ref string outputData)
  78. {
  79. outputData = "";
  80. string error = string.Empty; int errorCode = 0;
  81. try
  82. {
  83. JObject jsonInParam = JObject.Parse(inputData);
  84. // 去除外wrapper层便于通用
  85. Utils.removeWrapper(jsonInParam);
  86. string fileName = (string)jsonInParam["input"]["fsDownloadIn"]["filename"];
  87. string filePath = Global.curEvt.path + "\\Download\\" + fileName;
  88. //如果不存在目录,则创建目录
  89. if (!Directory.Exists(Global.curEvt.path + "\\Download"))
  90. {
  91. //创建文件夹
  92. DirectoryInfo dirInfo = Directory.CreateDirectory(Global.curEvt.path + "\\Download");
  93. }
  94. if (File.Exists(filePath))
  95. {
  96. File.Delete(filePath);
  97. }
  98. FileStream fs = new FileStream(filePath, FileMode.Append, FileAccess.Write, FileShare.ReadWrite);
  99. //创建一个HTTP请求
  100. Global.curEvt.URL = Global.inf.centerURL;
  101. HttpWebRequest request = (HttpWebRequest)WebRequest.Create(Global.curEvt.URL);
  102. //Post请求方式
  103. request.Method = "POST";
  104. String stamp = TimeStamp.get13().ToString();
  105. string apiName = Global.curEvt.URL.Substring(Global.curEvt.URL.Length - 12);
  106. //南昌增加头部信息
  107. //string sTemp = "_api_access_key=" + Global.inf.AK
  108. // + "&_api_name=" + apiName
  109. // + "&_api_timestamp=" + stamp
  110. // + "&_api_version=" + "1.0.0";
  111. //string signature = Encrypt.ToBase64hmac(sTemp, Global.inf.SK);
  112. //内容类型
  113. request.ContentType = "application/json";
  114. //request.Headers.Add("_api_version", "1.0.0");
  115. //request.Headers.Add("_api_timestamp", stamp);
  116. //request.Headers.Add("_api_name", apiName);
  117. //request.Headers.Add("_api_signature", signature);
  118. //request.Headers.Add("_api_access_key", Global.inf.AK);
  119. //设置参数,并进行URL编码
  120. string paraUrlCoded = JsonHelper.toJsonString(jsonInParam);
  121. byte[] payload;
  122. //将Json字符串转化为字节
  123. payload = System.Text.Encoding.UTF8.GetBytes(paraUrlCoded);
  124. //设置请求的ContentLength
  125. request.ContentLength = payload.Length;
  126. Stream writer;
  127. try
  128. {
  129. writer = request.GetRequestStream();//获取用于写入请求数据的Stream对象
  130. }
  131. catch (Exception)
  132. {
  133. writer = null;
  134. errorCode = -100;
  135. error = "连接服务器失败!";
  136. }
  137. //将请求参数写入流
  138. writer.Write(payload, 0, payload.Length);
  139. writer.Close();//关闭请求流
  140. // String strValue = "";//strValue为http响应所返回的字符流
  141. //发送请求并获取相应回应数据
  142. HttpWebResponse response = request.GetResponse() as HttpWebResponse;
  143. //直到request.GetResponse()程序才开始向目标网页发送Post请求
  144. Stream responseStream = response.GetResponseStream();
  145. //创建本地文件写入流
  146. byte[] bArr = new byte[1024];
  147. int iTotalSize = 0;
  148. int size = responseStream.Read(bArr, 0, (int)bArr.Length);
  149. while (size > 0)
  150. {
  151. iTotalSize += size;
  152. fs.Write(bArr, 0, size);
  153. size = responseStream.Read(bArr, 0, (int)bArr.Length);
  154. }
  155. fs.Close();
  156. responseStream.Close();
  157. dynamic joReturn = new JObject();
  158. joReturn.errorCode = errorCode;
  159. joReturn.errorMessage = error;
  160. joReturn.filePath = filePath;
  161. outputData = joReturn.ToString();
  162. }
  163. catch (Exception ex)
  164. {
  165. errorCode = -100;
  166. error = ex.Message;
  167. dynamic joReturn = new JObject();
  168. joReturn.errorCode = errorCode;
  169. joReturn.errorMessage = error;
  170. outputData = joReturn.ToString();
  171. return -1;
  172. }
  173. finally
  174. {
  175. Global.writeLog("DownloadCenterFile" + "(" + Global.curEvt.URL + ")", inputData, outputData);
  176. }
  177. return 0;
  178. }
  179. public int Init(ref string pErrMsg)
  180. {
  181. return 0;
  182. }
  183. public int UploadFile(string inputData, ref string outputData, ref string pErrMsg)
  184. {
  185. throw new NotImplementedException();
  186. }
  187. private string getResponseData(HttpWebResponse response)
  188. {
  189. string data = "";
  190. if (response != null)
  191. {
  192. Stream s = response.GetResponseStream();
  193. StreamReader sRead = new StreamReader(s,Encoding.GetEncoding("UTF-8"));
  194. data = sRead.ReadToEnd();
  195. sRead.Close();
  196. response.Close();
  197. }
  198. return data;
  199. }
  200. }
  201. }