JuHeApiService.cs 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396
  1. using Dm;
  2. using Newtonsoft.Json;
  3. using OASystem.Domain;
  4. using OASystem.Domain.Dtos.SmallFun;
  5. using OASystem.Domain.ViewModels.JuHeExchangeRate;
  6. using OASystem.Domain.ViewModels.SmallFun;
  7. using StackExchange.Redis;
  8. using System.DirectoryServices.Protocols;
  9. using System.Net.Http;
  10. using System.Net.Http.Json;
  11. using System.Text.Json;
  12. using Ubiety.Dns.Core;
  13. namespace OASystem.API.OAMethodLib.JuHeAPI
  14. {
  15. /// <summary>
  16. /// 聚合Api 服务
  17. /// </summary>
  18. public class JuHeApiService: IJuHeApiService
  19. {
  20. private readonly HttpClient _httpClient;
  21. private readonly string _appKey = "0f5429e9fbb8637c0ff3f14bbb42c732"; //配置您申请的appkey
  22. private readonly string _appkey_textTranslate = "59db9edbac297e30695973aa1d856391"; //文本翻译 appkey
  23. /// <summary>
  24. /// 初始化
  25. /// </summary>
  26. /// <param name="clientFactory"></param>
  27. public JuHeApiService(IHttpClientFactory clientFactory)
  28. {
  29. _httpClient = clientFactory.CreateClient("PublicJuHeApi"); ;
  30. }
  31. #region 汇率
  32. /// <summary>
  33. /// 获取汇率
  34. /// </summary>
  35. /// <returns></returns>
  36. public async Task<JuHeAPIResult> GetExchangeRateAsync()
  37. {
  38. var result = new JuHeAPIResult() { Resultcode = "-2", Reason = "未知错误" };
  39. string rateDataString = await RedisRepository.RedisFactory
  40. .CreateRedisRepository()
  41. .StringGetAsync<string>("JuHeApiExchangeRate");//string 取
  42. if (string.IsNullOrEmpty(rateDataString))
  43. {
  44. #region 请求接口并存入缓存
  45. string url = string.Format("/finance/exchange/rmbquot");
  46. try
  47. {
  48. var exchangeReq = await _httpClient.PostAsync(url,
  49. new FormUrlEncodedContent(new List<KeyValuePair<string, string>>()
  50. {
  51. new KeyValuePair<string, string>("key",_appKey),//你申请的key
  52. new KeyValuePair<string, string>("type","0"), //两种格式(0或者1,默认为0)
  53. new KeyValuePair<string, string>("bank","3") //(0:工商银行,1:招商银行,2:建设银行,3:中国银行,
  54. //4:交通银行,5:农业银行,默认为:0)
  55. }));
  56. if (exchangeReq.IsSuccessStatusCode)
  57. {
  58. var stringResponse = await exchangeReq.Content.ReadAsStringAsync();
  59. result = System.Text.Json.JsonSerializer.Deserialize<JuHeAPIResult>(stringResponse,
  60. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  61. if (result.Resultcode == "200")
  62. {
  63. List<ExchangeRateModel> rateList = new List<ExchangeRateModel>();
  64. #region 处理数据类型
  65. JArray jar = JArray.Parse(result.Result.ToJson());
  66. for (int i = 0; i < jar.Count; i++)
  67. {
  68. JObject j = JObject.Parse(jar[i].ToString());
  69. for (int x = 1; x < j.Count + 1; x++)
  70. {
  71. string rateName = "data" + x;
  72. string rateDataStr = j[rateName].ToString();
  73. if (!string.IsNullOrEmpty(rateDataStr))
  74. {
  75. ExchangeRateModel exchangeRate = JsonConvert.DeserializeObject<ExchangeRateModel>(rateDataStr);
  76. rateList.Add(exchangeRate);
  77. }
  78. }
  79. }
  80. #endregion
  81. TimeSpan ts = DateTime.Now.AddMinutes(120) - DateTime.Now; //设置redis 过期时间 120分钟
  82. await RedisRepository
  83. .RedisFactory
  84. .CreateRedisRepository()
  85. .StringSetAsync<string>("JuHeApiExchangeRate", rateList.ToJson(), ts);//string 存
  86. result.Result = rateList;
  87. }
  88. else
  89. {
  90. result.Reason = string.Format("聚合APIError[Error_Code:{0} Resultcode:{1} Msg:{2}]",
  91. result.Error_code, result.Resultcode, result.Result);
  92. }
  93. }
  94. else
  95. {
  96. result.Reason = "汇率接口请求失败!";
  97. }
  98. }
  99. catch (Exception ex)
  100. {
  101. result.Reason = ex.Message;
  102. }
  103. #endregion
  104. }
  105. else
  106. {
  107. result.Resultcode = "200";
  108. result.Result = JsonConvert.DeserializeObject<List<ExchangeRateModel>>(rateDataString);
  109. }
  110. return result;
  111. }
  112. /// <summary>
  113. /// 获取汇率 Single
  114. /// </summary>
  115. /// <param name="currencyCode">币种code</param>
  116. /// <returns></returns>
  117. public async Task<Result> GetSingleRateAsync(string currencyCode)
  118. {
  119. var result = new Result();
  120. if (currencyCode.ToUpper() == "CNY")
  121. {
  122. return result;
  123. }
  124. var resultData = await GetExchangeRateAsync();
  125. var rateCurrencyData = AppSettingsHelper.Get<RateCurrencyModel>("RateCurrency");
  126. var currencyModel = rateCurrencyData.Where(a => a.CurrencyCode == currencyCode).FirstOrDefault();
  127. if (currencyModel != null)
  128. {
  129. if (resultData.Resultcode == "200")
  130. {
  131. if (resultData.Result != null)
  132. {
  133. result.Code = 0;
  134. result.Data = ((List<ExchangeRateModel>)resultData.Result).Where(a => a.Name == currencyModel.CurrencyName).FirstOrDefault();
  135. }
  136. }
  137. else
  138. {
  139. result.Msg = resultData.Reason;
  140. }
  141. }
  142. return result;
  143. }
  144. /// <summary>
  145. /// 获取汇率 Single
  146. /// </summary>
  147. /// <param name="currencyCodes">币种codes</param>
  148. /// <returns></returns>
  149. public async Task<List<ExchangeRateModel>> PostItemRateAsync(string[] currencyCodes)
  150. {
  151. List<ExchangeRateModel> result = new List<ExchangeRateModel>();
  152. if (currencyCodes.Length <= 0)
  153. {
  154. return result;
  155. }
  156. var resultData = await GetExchangeRateAsync();
  157. var rateCurrencyData = AppSettingsHelper.Get<RateCurrencyModel>("RateCurrency");
  158. var currencyModel = rateCurrencyData.Where(a => currencyCodes.Any(b => a.CurrencyCode == b)).ToList();
  159. if (currencyModel.Count > 0)
  160. {
  161. if (resultData.Resultcode == "200")
  162. {
  163. if (resultData.Result != null)
  164. {
  165. var data = (List<ExchangeRateModel>)resultData.Result;
  166. foreach (var item in currencyModel)
  167. {
  168. ExchangeRateModel exchangeRateModel = data.Where(it => it.Name.Equals(item.CurrencyName)).FirstOrDefault();
  169. if (exchangeRateModel != null)
  170. {
  171. result.Add(exchangeRateModel);
  172. }
  173. }
  174. //result = ((List<ExchangeRateModel>)resultData.Result).Where(a => a.Name == currencyModel.CurrencyName).ToList();
  175. }
  176. }
  177. }
  178. return result;
  179. }
  180. /// <summary>
  181. /// 获取汇率转换结果
  182. /// </summary>
  183. /// <returns></returns>
  184. public async Task<Result> GetExchangeRateAsync(ExchangeRateDto dto)
  185. {
  186. var result = new Result() { Code = -2, Msg = "未知错误" };
  187. var rateCurrencyData = AppSettingsHelper.Get<RateCurrencyModel>("RateCurrency");
  188. if (dto.CurrencyCodePer.ToUpper() == "CNY")
  189. {
  190. var currencyModelSuf = rateCurrencyData.Where(a => a.CurrencyCode == dto.CurrencyCodeSuf).FirstOrDefault();
  191. if (currencyModelSuf == null)
  192. {
  193. result.Msg = "转换后币种未找到!";
  194. return result;
  195. }
  196. var rateModelSuf = await GetSingleRateAsync(currencyModelSuf.CurrencyCode);
  197. if (rateModelSuf.Code != 0)
  198. {
  199. result.Msg = rateModelSuf.Msg;
  200. return result;
  201. }
  202. if (string.IsNullOrEmpty(rateModelSuf.Data.FSellPri))
  203. {
  204. result.Msg = string.Format("{0}({1})暂无汇率!", currencyModelSuf.CurrencyName, currencyModelSuf.CurrencyCode);
  205. return result;
  206. }
  207. decimal moneySuf = Convert.ToDecimal(rateModelSuf.Data.FSellPri) / 100; //fSellPri
  208. decimal settlementMoney = dto.Money / moneySuf;
  209. var rateView = new ExchangeRateView
  210. {
  211. CurrencyCodePre = dto.CurrencyCodePer,
  212. CurrencyNamePre = "人民币",
  213. MoneyPre = dto.Money,
  214. CurrencyCodeSuf = dto.CurrencyCodeSuf,
  215. CurrencyNameSuf = currencyModelSuf.CurrencyName,
  216. MoneySuf = CommonFun.CutDecimalWithN(settlementMoney, 4),
  217. UpdateTime = string.Format("{0} {1}", rateModelSuf.Data.Date, rateModelSuf.Data.Time)
  218. };
  219. result.Code = 0;
  220. result.Msg = "成功!";
  221. result.Data = rateView;
  222. return result;
  223. }
  224. else
  225. {
  226. var currencyModelPre = rateCurrencyData.Where(a => a.CurrencyCode == dto.CurrencyCodePer).FirstOrDefault();
  227. if (currencyModelPre == null)
  228. {
  229. result.Msg = "转换前币种未找到!";
  230. return result;
  231. }
  232. var rateModelPre = await GetSingleRateAsync(currencyModelPre.CurrencyCode);
  233. if (rateModelPre.Code != 0)
  234. {
  235. result.Msg = rateModelPre.Msg;
  236. return result;
  237. }
  238. if (string.IsNullOrEmpty(rateModelPre.Data.FSellPri))
  239. {
  240. result.Msg = string.Format("{0}({1})暂无汇率!", currencyModelPre.CurrencyName, currencyModelPre.CurrencyCode);
  241. return result;
  242. }
  243. decimal moneyPre = (Convert.ToDecimal(rateModelPre.Data.FSellPri) / 100) * dto.Money; //fSellPri
  244. if (dto.CurrencyCodeSuf.ToUpper() == "CNY")
  245. {
  246. var rateView = new ExchangeRateView
  247. {
  248. CurrencyCodePre = dto.CurrencyCodePer,
  249. CurrencyNamePre = currencyModelPre.CurrencyName,
  250. MoneyPre = dto.Money,
  251. CurrencyCodeSuf = "CNY",
  252. CurrencyNameSuf = "人民币",
  253. MoneySuf = CommonFun.CutDecimalWithN(moneyPre, 4),
  254. UpdateTime = string.Format("{0} {1}", rateModelPre.Data.Date, rateModelPre.Data.Time)
  255. };
  256. result.Code = 0;
  257. result.Msg = "成功!";
  258. result.Data = rateView;
  259. }
  260. else
  261. {
  262. var currencyModelSuf = rateCurrencyData.Where(a => a.CurrencyCode == dto.CurrencyCodeSuf).FirstOrDefault();
  263. if (currencyModelSuf == null)
  264. {
  265. result.Msg = "转换后币种未找到!";
  266. return result;
  267. }
  268. var rateModelSuf = await GetSingleRateAsync(currencyModelSuf.CurrencyCode);
  269. if (rateModelSuf.Code != 0)
  270. {
  271. result.Msg = rateModelSuf.Msg;
  272. return result;
  273. }
  274. if (string.IsNullOrEmpty(rateModelSuf.Data.FSellPri))
  275. {
  276. result.Msg = string.Format("{0}({1})暂无汇率!", currencyModelSuf.CurrencyName, currencyModelSuf.CurrencyCode);
  277. return result;
  278. }
  279. decimal moneySuf = Convert.ToDecimal(rateModelSuf.Data.FSellPri) / 100; //fSellPri
  280. decimal settlementMoney = moneyPre / moneySuf;
  281. var rateView = new ExchangeRateView
  282. {
  283. CurrencyCodePre = dto.CurrencyCodePer,
  284. CurrencyNamePre = currencyModelPre.CurrencyName,
  285. MoneyPre = dto.Money,
  286. CurrencyCodeSuf = dto.CurrencyCodeSuf,
  287. CurrencyNameSuf = currencyModelSuf.CurrencyName,
  288. MoneySuf = CommonFun.CutDecimalWithN(settlementMoney, 4),
  289. UpdateTime = string.Format("{0} {1}", rateModelSuf.Data.Date, rateModelSuf.Data.Time)
  290. };
  291. result.Code = 0;
  292. result.Msg = "成功!";
  293. result.Data = rateView;
  294. }
  295. }
  296. return result;
  297. }
  298. #endregion
  299. #region 文本翻译
  300. /// <summary>
  301. /// 文本翻译
  302. /// </summary>
  303. /// <param name="source">原文,数据类型为字符串,也可为数组(元素必须为字符串类型);每次请求的字符串长度之和尽量不要超过 </param>
  304. /// <param name="trans_type">翻译方向:en2zh(英文-中文),zh2en(中文-英文),ja2zh(日文-中文),zh2ja(中文-日文),ko2zh(韩文-中文),zh2ko(中文-韩文)</param>
  305. /// <returns></returns>
  306. public async Task<JuHeAPIResult> GetTextTranslateAsync(string source,string trans_type = "zh2en")
  307. {
  308. var result = new JuHeAPIResult() { Resultcode = "10020", Reason = "接口维护" };
  309. #region 请求接口并存入缓存
  310. string url = string.Format("/finance/exchange/rmbquot");
  311. var exchangeReq = await _httpClient
  312. .PostAsync(url,
  313. new FormUrlEncodedContent(new List<KeyValuePair<string, string>>()
  314. {
  315. new KeyValuePair<string, string>("key",_appKey),//你申请的key
  316. new KeyValuePair<string, string>("source",source),
  317. new KeyValuePair<string, string>("trans_type",trans_type)
  318. }));
  319. if (exchangeReq.IsSuccessStatusCode)
  320. {
  321. var stringResponse = await exchangeReq.Content.ReadAsStringAsync();
  322. result = System.Text.Json.JsonSerializer.Deserialize<JuHeAPIResult>(stringResponse,
  323. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  324. if (result.Resultcode == "200")
  325. {
  326. string resStr = (string)result.Result.GetType().GetProperty("res").GetValue(result.Result, null);
  327. result.Result = resStr;
  328. }
  329. else
  330. {
  331. result.Reason = string.Format("聚合APIError[Error_Code:{0} Resultcode:{1} Msg:{2}]",
  332. result.Error_code, result.Resultcode, result.Result);
  333. }
  334. }
  335. else
  336. {
  337. result.Reason = "汇率接口请求失败!";
  338. }
  339. #endregion
  340. return result;
  341. }
  342. #endregion
  343. }
  344. }