JuHeApiService.cs 17 KB

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