TeamRateRepository.cs 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785
  1. using Newtonsoft.Json;
  2. using OASystem.Domain;
  3. using OASystem.Domain.Dtos.Financial;
  4. using OASystem.Domain.Dtos.Groups;
  5. using OASystem.Domain.Entities.Financial;
  6. using OASystem.Domain.Entities.Groups;
  7. using OASystem.Domain.ViewModels.Financial;
  8. using OASystem.Domain.ViewModels.Groups;
  9. using OASystem.Infrastructure.Repositories.System;
  10. using Serilog;
  11. using SqlSugar;
  12. using System;
  13. using System.Collections.Generic;
  14. using System.Linq;
  15. using System.Text;
  16. using System.Threading.Tasks;
  17. namespace OASystem.Infrastructure.Repositories.Groups
  18. {
  19. /// <summary>
  20. /// 团组汇率 仓库
  21. /// </summary>
  22. public class TeamRateRepository : BaseRepository<Grp_TeamRate, TeamRateView>
  23. {
  24. private readonly SetDataRepository _setDataRep;
  25. private readonly DelegationInfoRepository _deleInfoRep;
  26. public TeamRateRepository(SqlSugarClient sqlSugar, SetDataRepository setDataRep, DelegationInfoRepository deleInfoRep)
  27. : base(sqlSugar)
  28. {
  29. _setDataRep = setDataRep;
  30. _deleInfoRep = deleInfoRep;
  31. }
  32. /// <summary>
  33. /// 团组汇率 Rep
  34. /// </summary>
  35. /// <param name="dto"></param>
  36. /// <returns></returns>
  37. public async Task<Result> GetGroupRateDataSource(TeamRateDto dto)
  38. {
  39. Result result = new() { Code = -2 };
  40. GroupNameDto groupNameDto = new GroupNameDto() { PortType = dto.PortType };
  41. var groups = await _deleInfoRep.GetGroupNameList(groupNameDto);
  42. var teamRateDatas = await _setDataRep.GetSetDataBySTId(_setDataRep, 66); // STid=66 全球币种
  43. dynamic _data = null;
  44. if (dto.PortType == 1)
  45. {
  46. //List<Sys_SetData> sys_SetDatas = new List<Sys_SetData>();
  47. //sys_SetDatas = JsonConvert.DeserializeObject<List<Sys_SetData>>(JsonConvert.SerializeObject(teamRateDatas.Data));
  48. //List<TeamRateDescView> teamRateDescViews = new List<TeamRateDescView>();
  49. //teamRateDescViews = sys_SetDatas.Select(it => new TeamRateDescView() { CurrencyName = it.Remark, CurrencyCode = it.Name, Rate = 0.0000M }).ToList();
  50. ///*
  51. // * 放在首位币种
  52. // * 人名币 CNY Rate = 1,美元 USD,欧元 EUR,港币 HKD,日元 JPY ,澳大利 AUD,英镑 GBP
  53. // * 依次排序
  54. // */
  55. ////人名币
  56. //var cnyData = teamRateDescViews.Find(it => it.CurrencyCode.Equals("CNY"));
  57. //if (cnyData != null) { teamRateDescViews.Remove(cnyData); cnyData.Rate = 1.0000M; teamRateDescViews.Insert(0, cnyData); }
  58. ////美元
  59. //var usdData = teamRateDescViews.Find(it => it.CurrencyCode.Equals("USD"));
  60. //if (usdData != null) { teamRateDescViews.Remove(usdData); teamRateDescViews.Insert(1, usdData); }
  61. ////欧元
  62. //var eurData = teamRateDescViews.Find(it => it.CurrencyCode.Equals("EUR"));
  63. //if (eurData != null) { teamRateDescViews.Remove(eurData); teamRateDescViews.Insert(2, eurData); }
  64. ////港币
  65. //var hkdData = teamRateDescViews.Find(it => it.CurrencyCode.Equals("HKD"));
  66. //if (hkdData != null) { teamRateDescViews.Remove(hkdData); teamRateDescViews.Insert(3, hkdData); }
  67. ////日元
  68. //var jpyData = teamRateDescViews.Find(it => it.CurrencyCode.Equals("JPY"));
  69. //if (jpyData != null) { teamRateDescViews.Remove(jpyData); teamRateDescViews.Insert(4, jpyData); }
  70. ////澳大利
  71. //var audData = teamRateDescViews.Find(it => it.CurrencyCode.Equals("AUD"));
  72. //if (audData != null) { teamRateDescViews.Remove(audData); teamRateDescViews.Insert(5, audData); }
  73. ////英镑
  74. //var gbpData = teamRateDescViews.Find(it => it.CurrencyCode.Equals("GBP"));
  75. //if (gbpData != null) { teamRateDescViews.Remove(gbpData); teamRateDescViews.Insert(6, gbpData); }
  76. _data = new { GroupData = groups.Data, TeamRateData = PostGroupTeamRateHot() };
  77. }
  78. else if (dto.PortType == 2)
  79. {
  80. }
  81. else if (dto.PortType == 3)
  82. {
  83. }
  84. result.Code = 0;
  85. result.Msg = "查询成功!";
  86. result.Data = _data;
  87. return result;
  88. }
  89. /// <summary>
  90. /// 团组汇率 更改数据
  91. /// </summary>
  92. /// <param name="dto"></param>
  93. /// <returns></returns>
  94. public async Task<Result> GetGroupRateChangeData()
  95. {
  96. Result result = new() { Code = -2 };
  97. string teamRateInfoSql = string.Format(@"Select * From Grp_TeamRate tr Where tr.IsDel = 0");
  98. var teamRateInfo = await _sqlSugar.SqlQueryable<Grp_TeamRate>(teamRateInfoSql).ToListAsync();
  99. dynamic _data = null;
  100. #region 团组汇率 - 详细汇率信息
  101. List<SetDataInfoView> otherCurrencyData1 = new List<SetDataInfoView>();
  102. var otherCurrencyData = await _setDataRep.GetSetDataBySTId(_setDataRep, 13);
  103. if (otherCurrencyData.Code == 0 && otherCurrencyData.Data != null)
  104. {
  105. string otherCurrencyStr = JsonConvert.SerializeObject(otherCurrencyData.Data);
  106. otherCurrencyData1 = JsonConvert.DeserializeObject<List<SetDataInfoView>>(otherCurrencyStr);
  107. //var otherCurrency = otherCurrencyData1
  108. }
  109. foreach (Grp_TeamRate item1 in teamRateInfo)
  110. {
  111. string rateStr = string.Empty;
  112. if (item1.RateU != 0) rateStr += "美元(USD):" + item1.RateU + "|";
  113. if (item1.RateE != 0) rateStr += "欧元(EUR):" + item1.RateE + "|";
  114. if (item1.RateJ != 0)
  115. rateStr += "日元(JPY):" + item1.RateJ + "|";
  116. if (item1.RateH != 0)
  117. rateStr += "港币(HKD):" + item1.RateH + "|";
  118. if (item1.RateN != 0)
  119. rateStr += "新西兰元(NZD):" + item1.RateN + "|";
  120. if (item1.RateS != 0)
  121. rateStr += "新加坡币(SGD):" + item1.RateS + "|";
  122. if (item1.RateA != 0)
  123. rateStr += "澳大利亚元(AUD):" + item1.RateA + "|";
  124. if (item1.RateC != 0)
  125. rateStr += "加拿大元(CAD):" + item1.RateC + "|";
  126. if (item1.RateT != 0)
  127. rateStr += "泰国铢(THB):" + item1.RateT + "|";
  128. if (item1.RateBL != 0)
  129. rateStr += "波兰兹罗提(PLN):" + item1.RateBL + "|";
  130. if (item1.RateHB != 0)
  131. rateStr += "韩国元(KRW):" + item1.RateHB + "|";
  132. if (item1.RateFJD != 0)
  133. rateStr += "斐济元(FJD):" + item1.RateFJD + "|";
  134. if (item1.RateTL != 0)
  135. rateStr += "土耳其里拉(TRY):" + item1.RateTL + "|";
  136. if (item1.RateRP != 0)
  137. rateStr += "印度尼西亚卢比(IDR):" + item1.RateRP + "|";
  138. if (item1.RatePeso != 0)
  139. rateStr += "菲律宾比索(PHP):" + item1.RatePeso + "|";
  140. if (item1.RateMYR != 0)
  141. rateStr += "林吉特(MYR):" + item1.RateMYR + "|";
  142. if (item1.RateCZK != 0)
  143. rateStr += "捷克货币(CZK):" + item1.RateCZK + "|";
  144. if (item1.RateMXN != 0)
  145. rateStr += "墨西哥比索(MXN):" + item1.RateMXN + "|";
  146. if (item1.RateMOP != 0)
  147. rateStr += "澳门元(MOP):" + item1.RateMOP + "|";
  148. if (item1.RateARS != 0)
  149. rateStr += "阿根廷比索(ARS):" + item1.RateARS + "|";
  150. if (item1.RateHUF != 0)
  151. rateStr += "匈牙利福林(HUF):" + item1.RateHUF + "|";
  152. if (item1.RateRUB != 0)
  153. rateStr += "卢布(RUB):" + item1.RateRUB + "|";
  154. if (!string.IsNullOrEmpty(item1.OtherRateCode))
  155. {
  156. rateStr += $"{otherCurrencyData1.Find(it => it.Name.Equals(item1.OtherRateCode))?.Remark ?? "Unknown"}({item1.OtherRateCode}):{item1.OtherPrice}|";
  157. }
  158. if (!rateStr.Contains("CNY"))
  159. {
  160. rateStr += "人名币(CNY):1.0000|";
  161. }
  162. if (rateStr.Length > 0)
  163. {
  164. rateStr = rateStr.Substring(0, rateStr.Length - 1);
  165. }
  166. item1.Remark = rateStr;
  167. }
  168. #endregion
  169. try
  170. {
  171. var _result = _sqlSugar.Updateable(teamRateInfo)
  172. .UpdateColumns(it => new { it.Remark }) //更新列
  173. .WhereColumns(it => new { it.DiId, it.CTable }) //更新条件
  174. .ExecuteCommand();
  175. result.Code = 0;
  176. result.Msg = "数据修改成功!";
  177. result.Data = _data;
  178. }
  179. catch (Exception ex)
  180. {
  181. result.Msg = ex.Message;
  182. }
  183. return result;
  184. }
  185. /// <summary>
  186. /// 团组汇率 Rep
  187. /// </summary>
  188. /// <param name="dto"></param>
  189. /// <returns></returns>
  190. public async Task<Result> GetGroupRateInfoByDiid(TeamRateInfoDto dto)
  191. {
  192. Result result = new() { Code = -2 };
  193. GroupInfoDto groupInfoDto = new GroupInfoDto() { Id = dto.Diid, PortType = dto.PortType, PageIndex = dto.PageIndex, PageSize = dto.PageSize };
  194. var groupInfo = await _deleInfoRep.GetGroupInfo(groupInfoDto);
  195. string teamRateInfoSql = string.Format(@"Select sd.Name,tr.* From Grp_TeamRate tr
  196. Left Join Sys_SetData sd On sd.IsDel=0 And sd.STid=16 And tr.CTable = sd.Id
  197. Where tr.DiId = {0} And tr.IsDel = 0", dto.Diid);
  198. var teamRateInfo = await _sqlSugar.SqlQueryable<TeamRateInfoView>(teamRateInfoSql).ToListAsync();
  199. dynamic _data = null;
  200. if (dto.PortType == 1)
  201. {
  202. #region 团组汇率
  203. List<TeamRateModelView> teamRateModels = new List<TeamRateModelView>();
  204. foreach (TeamRateInfoView item in teamRateInfo)
  205. {
  206. TeamRateModelView teamRateModelInfo = new TeamRateModelView();
  207. teamRateModelInfo.Id = item.Id;
  208. teamRateModelInfo.CTableId = item.CTable;
  209. teamRateModelInfo.CTableName = item.Name;
  210. List<TeamRateDescView> teamRateDescViews = new List<TeamRateDescView>();
  211. #region 拆分remark里的汇率
  212. if (item.Remark.Contains("|"))
  213. {
  214. string[] currencyArr = item.Remark.Split("|");
  215. foreach (string currency in currencyArr)
  216. {
  217. string[] currency1 = currency.Split(":");
  218. string[] currency2 = currency1[0].Split("(");
  219. TeamRateDescView rateDescView = new TeamRateDescView()
  220. {
  221. CurrencyCode = currency2[1].Replace(")", "").TrimEnd(),
  222. CurrencyName = currency2[0],
  223. Rate = decimal.Parse(currency1[1]),
  224. };
  225. teamRateDescViews.Add(rateDescView);
  226. }
  227. }
  228. else
  229. {
  230. if (!string.IsNullOrEmpty(item.Remark))
  231. {
  232. string[] currency1 = item.Remark.Split(":");
  233. string[] currency2 = currency1[0].Split("(");
  234. TeamRateDescView rateDescView = new TeamRateDescView()
  235. {
  236. CurrencyCode = currency2[1].Replace(")", "").TrimEnd(),
  237. CurrencyName = currency2[0],
  238. Rate = decimal.Parse(currency1[1]),
  239. };
  240. teamRateDescViews.Add(rateDescView);
  241. }
  242. }
  243. #endregion
  244. teamRateModelInfo.TeamRates = teamRateDescViews;
  245. teamRateModels.Add(teamRateModelInfo);
  246. }
  247. #endregion
  248. _data = new { GroupInfo = groupInfo.Data, TeamRateData = teamRateModels };
  249. }
  250. else if (dto.PortType == 2)
  251. {
  252. }
  253. else if (dto.PortType == 3)
  254. {
  255. }
  256. result.Code = 0;
  257. result.Msg = "查询成功!";
  258. result.Data = _data;
  259. return result;
  260. }
  261. /// <summary>
  262. /// 团组汇率 更新 or 添加
  263. /// </summary>
  264. /// <param name="dto"></param>
  265. /// <returns></returns>
  266. public async Task<Result> PostGroupRateUpdate(TeamRateUpdateDto dto)
  267. {
  268. Result result = new() { Code = -2 };
  269. int addCount = 0, updateCount = 0;
  270. if (dto.PortType == 1)
  271. {
  272. try
  273. {
  274. _sqlSugar.BeginTran();
  275. int res = -1;
  276. foreach (TeamRateUpdateInfo item in dto.teamRateUpdateInfos)
  277. {
  278. Grp_TeamRate teamRateInfo = new Grp_TeamRate();
  279. string currencyStr = string.Empty;
  280. foreach (TeamRateDescView currency in item.teamRates)
  281. {
  282. currencyStr += string.Format(@"{0}({1}):{2}|", currency.CurrencyName, currency.CurrencyCode, currency.Rate);
  283. }
  284. if (currencyStr.Length > 0)
  285. {
  286. currencyStr = currencyStr.Substring(0, currencyStr.Length - 1);
  287. }
  288. teamRateInfo.DiId = dto.DiId;
  289. teamRateInfo.CreateUserId = dto.CreateUserId;
  290. teamRateInfo.Id = item.Id;
  291. teamRateInfo.CreateTime = DateTime.Now;
  292. teamRateInfo.CTable = item.CTable;
  293. teamRateInfo.Remark = currencyStr;
  294. var teamRateDetails = _sqlSugar.Queryable<Grp_TeamRate>().Where(it => it.DiId == dto.DiId && it.CTable == item.CTable).First();
  295. if (teamRateDetails == null) //添加
  296. {
  297. res = await _sqlSugar.Insertable(teamRateInfo).ExecuteCommandAsync();
  298. if (res > 0)
  299. {
  300. addCount++;
  301. }
  302. }
  303. else //修改
  304. {
  305. teamRateInfo.Id = teamRateDetails.Id;
  306. res = await _sqlSugar.Updateable(teamRateInfo)
  307. .UpdateColumns(it => it.Remark)
  308. .WhereColumns(it => new { it.DiId, it.CTable })
  309. .ExecuteCommandAsync();
  310. if (res > 0)
  311. {
  312. updateCount++;
  313. }
  314. }
  315. if (res < 1)
  316. {
  317. _sqlSugar.RollbackTran();
  318. result.Msg = "操作失败!";
  319. break;
  320. }
  321. }
  322. if (res > 0)
  323. {
  324. _sqlSugar.CommitTran();
  325. result.Code = 0;
  326. result.Msg = "操作成功";
  327. }
  328. }
  329. catch (Exception ex)
  330. {
  331. result.Msg = ex.Message;
  332. }
  333. }
  334. else if (dto.PortType == 2)
  335. {
  336. }
  337. else if (dto.PortType == 3)
  338. {
  339. }
  340. result.Code = 0;
  341. result.Msg = string.Format(@"操作成功!添加:{0}条;更新:{1};", addCount, updateCount);
  342. return result;
  343. }
  344. /// <summary>
  345. /// 团组汇率 Rep
  346. /// 根据团组Id 查询汇率
  347. /// </summary>
  348. /// <param name="dto"></param>
  349. /// <returns></returns>
  350. public async Task<List<TeamRateModelView>> PostGroupRateInfoByDiId(int diId)
  351. {
  352. List<TeamRateModelView> teamRateModels = new List<TeamRateModelView>();
  353. string teamRateInfoSql = string.Format(@"Select sd.Name,tr.* From Grp_TeamRate tr
  354. Left Join Sys_SetData sd On sd.IsDel=0 And sd.STid=16 And tr.CTable = sd.Id
  355. Where tr.DiId = {0} And tr.IsDel = 0", diId);
  356. var teamRateInfo = await _sqlSugar.SqlQueryable<TeamRateInfoView>(teamRateInfoSql).ToListAsync();
  357. #region 团组汇率
  358. foreach (TeamRateInfoView item in teamRateInfo)
  359. {
  360. TeamRateModelView teamRateModelInfo = new TeamRateModelView();
  361. teamRateModelInfo.Id = item.Id;
  362. teamRateModelInfo.CTableId = item.CTable;
  363. teamRateModelInfo.CTableName = item.Name;
  364. List<TeamRateDescView> teamRateDescViews = new List<TeamRateDescView>();
  365. #region 拆分remark里的汇率
  366. if (item.Remark.Contains("|"))
  367. {
  368. string[] currencyArr = item.Remark.Split("|");
  369. foreach (string currency in currencyArr)
  370. {
  371. string[] currency1 = currency.Split(":");
  372. string[] currency2 = currency1[0].Split("(");
  373. TeamRateDescView rateDescView = new TeamRateDescView()
  374. {
  375. CurrencyCode = currency2[1].Replace(")", "").TrimEnd(),
  376. CurrencyName = currency2[0],
  377. Rate = decimal.Parse(currency1[1]),
  378. };
  379. teamRateDescViews.Add(rateDescView);
  380. }
  381. }
  382. #endregion
  383. teamRateModelInfo.TeamRates = teamRateDescViews;
  384. teamRateModels.Add(teamRateModelInfo);
  385. }
  386. #endregion
  387. return teamRateModels;
  388. }
  389. /// <summary>
  390. /// 团组汇率 币种 Item (来源:团组汇率)
  391. /// 根据 团组Id And 业务类型(CTable)Id
  392. /// api处理CTable = 285,默认返回CNY
  393. /// </summary>
  394. /// <param name="portType"></param>
  395. /// <param name="diId"></param>
  396. /// <param name="cTable"></param>
  397. /// <returns></returns>
  398. public async Task<TeamRateModelGeneralView> PostGroupTeamRateByDiIdAndCTableId(int portType, int diId, int cTable)
  399. {
  400. TeamRateModelGeneralView _view = new TeamRateModelGeneralView();
  401. if (diId < 1)
  402. {
  403. return _view;
  404. }
  405. if (cTable < 1)
  406. {
  407. return _view;
  408. }
  409. if (portType == 1 || portType == 2 || portType == 3)
  410. {
  411. string teamRateInfoSql = string.Format(@"Select sd.Name,tr.* From Grp_TeamRate tr
  412. Left Join Sys_SetData sd On sd.IsDel=0 And sd.STid=16 And tr.CTable = sd.Id
  413. Where tr.IsDel = 0 And tr.DiId = {0} And tr.CTable = {1}", diId, cTable);
  414. var teamRateInfo = _sqlSugar.SqlQueryable<TeamRateInfoView>(teamRateInfoSql).ToList();
  415. #region 团组汇率
  416. #region 单独处理Ctable 币种汇率 默认 为CNY
  417. if (cTable == 285)
  418. {
  419. _view = new TeamRateModelGeneralView()
  420. {
  421. Id = 0,
  422. CTableId = 285,
  423. CTableName = "其他款项与收款退还",
  424. TeamRates = new List<TeamRateDescAddCurrencyIdView>() {
  425. new TeamRateDescAddCurrencyIdView()
  426. {
  427. CurrencyId = 836,
  428. CurrencyCode = "CNY",
  429. CurrencyName = "人民币",
  430. Rate = 1.0000M,
  431. }
  432. }
  433. };
  434. return _view;
  435. }
  436. #endregion
  437. List<SetDataInfoView> currencyDatas = new List<SetDataInfoView>();
  438. #region 获取所有币种
  439. string sql = string.Format(@"select * from Sys_SetData where STid = {0} and isdel = 0", 66);
  440. var DBdata = _setDataRep.GetListBySqlWithNolock(sql);
  441. if (DBdata == null || DBdata.Count == 0)
  442. {
  443. return _view;
  444. }
  445. currencyDatas = DBdata.Select(x => new SetDataInfoView
  446. {
  447. Name = x.Name,
  448. Id = x.Id,
  449. Remark = x.Remark,
  450. }).ToList();
  451. #endregion
  452. foreach (TeamRateInfoView item in teamRateInfo)
  453. {
  454. TeamRateModelGeneralView teamRateModelInfo = new TeamRateModelGeneralView();
  455. teamRateModelInfo.Id = item.Id;
  456. teamRateModelInfo.CTableId = item.CTable;
  457. teamRateModelInfo.CTableName = item.Name;
  458. List<TeamRateDescAddCurrencyIdView> teamRateDescViews = new List<TeamRateDescAddCurrencyIdView>();
  459. #region 拆分remark里的汇率
  460. if (item.Remark.Contains("|"))
  461. {
  462. string[] currencyArr = item.Remark.Split("|");
  463. foreach (string currency in currencyArr)
  464. {
  465. string[] currency1 = currency.Split(":");
  466. string[] currency2 = currency1[0].Split("(");
  467. string currencyCode = currency2[1].Replace(")", "").TrimEnd();
  468. SetDataInfoView dataInfoView = new SetDataInfoView();
  469. dataInfoView = currencyDatas.Where(it => it.Name == currencyCode).FirstOrDefault();
  470. int currencyId = currencyDatas.Where(it => it.Name == currencyCode).FirstOrDefault().Id;
  471. TeamRateDescAddCurrencyIdView rateDescView = new TeamRateDescAddCurrencyIdView()
  472. {
  473. CurrencyId = dataInfoView.Id,
  474. CurrencyCode = currencyCode,
  475. CurrencyName = currency2[0],
  476. Rate = decimal.Parse(currency1[1]),
  477. };
  478. teamRateDescViews.Add(rateDescView);
  479. }
  480. }
  481. else
  482. {
  483. if (!string.IsNullOrEmpty(item.Remark))
  484. {
  485. string[] currency1 = item.Remark.Split(":");
  486. string[] currency2 = currency1[0].Split("(");
  487. string currencyCode = currency2[1].Replace(")", "").TrimEnd();
  488. SetDataInfoView dataInfoView = new SetDataInfoView();
  489. dataInfoView = currencyDatas.Where(it => it.Name == currencyCode).FirstOrDefault();
  490. int currencyId = currencyDatas.Where(it => it.Name == currencyCode).FirstOrDefault().Id;
  491. TeamRateDescAddCurrencyIdView rateDescView = new TeamRateDescAddCurrencyIdView()
  492. {
  493. CurrencyId = dataInfoView.Id,
  494. CurrencyCode = currencyCode,
  495. CurrencyName = currency2[0],
  496. Rate = decimal.Parse(currency1[1]),
  497. };
  498. teamRateDescViews.Add(rateDescView);
  499. }
  500. }
  501. #endregion
  502. if (teamRateDescViews.Count > 0)
  503. {
  504. teamRateDescViews = teamRateDescViews.OrderBy(it => it.CurrencyId).ToList();
  505. }
  506. teamRateModelInfo.TeamRates = teamRateDescViews;
  507. _view = teamRateModelInfo;
  508. }
  509. if (_view.TeamRates == null)
  510. {
  511. _view.TeamRates = new List<TeamRateDescAddCurrencyIdView>();
  512. }
  513. #endregion
  514. }
  515. return _view;
  516. }
  517. /// <summary>
  518. /// 获取团组相关模块的currencyList
  519. /// </summary>
  520. /// <param name="portType"></param>
  521. /// <param name="diId"></param>
  522. /// <param name="cTable"></param>
  523. /// <returns></returns>
  524. public async Task<List<TeamRateDescAddCurrencyIdView>> PostGroupTeamRateItemByDiIdAndCTableId(int portType, int diId, int cTable)
  525. {
  526. List<TeamRateDescAddCurrencyIdView> teamRateDescAddCurrencyIdViews = new List<TeamRateDescAddCurrencyIdView>();
  527. TeamRateModelGeneralView teamRateModelGeneralView = await PostGroupTeamRateByDiIdAndCTableId(portType, diId, cTable);
  528. teamRateDescAddCurrencyIdViews = teamRateModelGeneralView.TeamRates;
  529. return teamRateDescAddCurrencyIdViews;
  530. }
  531. /// <summary>
  532. /// 获取团组汇率 币种使用次数
  533. /// </summary>
  534. /// <returns></returns>
  535. public async Task<List<CurrencyHot>> PostGroupTeamRateHot()
  536. {
  537. List<CurrencyHot> _view = new List<CurrencyHot>();
  538. string teamRateInfoSql = string.Format(@"Select sd.Name,tr.* From Grp_TeamRate tr
  539. Left Join Sys_SetData sd On sd.IsDel=0 And sd.STid=16 And tr.CTable = sd.Id
  540. Where tr.IsDel = 0 ");
  541. var teamRateInfo = _sqlSugar.SqlQueryable<TeamRateInfoView>(teamRateInfoSql).ToList();
  542. List<SetDataInfoView> currencyDatas = new List<SetDataInfoView>();
  543. #region 获取所有币种
  544. string sql = string.Format(@"Select * From Sys_SetData Where STid = {0} And IsDel = 0", 66);
  545. var DBdata = _setDataRep.GetListBySqlWithNolock(sql);
  546. if (DBdata == null || DBdata.Count == 0)
  547. {
  548. return _view;
  549. }
  550. currencyDatas = DBdata.Select(x => new SetDataInfoView
  551. {
  552. Name = x.Name,
  553. Id = x.Id,
  554. Remark = x.Remark,
  555. }).ToList();
  556. _view = currencyDatas.Select(it => new CurrencyHot() { CurrencyId = it.Id, CurrencyCode = it.Name, CurrencyName = it.Remark}).ToList();
  557. #endregion
  558. List<TeamRateDescAddCurrencyIdView> teamRateDatas = new List<TeamRateDescAddCurrencyIdView>();
  559. foreach (TeamRateInfoView item in teamRateInfo)
  560. {
  561. List<TeamRateDescAddCurrencyIdView> teamRateDescViews = new List<TeamRateDescAddCurrencyIdView>();
  562. #region 拆分remark里的汇率
  563. if (item.Remark.Contains("|"))
  564. {
  565. string[] currencyArr = item.Remark.Split("|");
  566. foreach (string currency in currencyArr)
  567. {
  568. string[] currency1 = currency.Split(":");
  569. string[] currency2 = currency1[0].Split("(");
  570. string currencyCode = currency2[1].Replace(")", "").TrimEnd();
  571. SetDataInfoView dataInfoView = new SetDataInfoView();
  572. dataInfoView = currencyDatas.Where(it => it.Name == currencyCode).FirstOrDefault();
  573. int currencyId = currencyDatas.Where(it => it.Name == currencyCode).FirstOrDefault().Id;
  574. TeamRateDescAddCurrencyIdView rateDescView = new TeamRateDescAddCurrencyIdView()
  575. {
  576. CurrencyId = dataInfoView.Id,
  577. CurrencyCode = currencyCode,
  578. CurrencyName = currency2[0],
  579. Rate = decimal.Parse(currency1[1]),
  580. };
  581. teamRateDescViews.Add(rateDescView);
  582. }
  583. }
  584. else
  585. {
  586. if (!string.IsNullOrEmpty(item.Remark))
  587. {
  588. string[] currency1 = item.Remark.Split(":");
  589. string[] currency2 = currency1[0].Split("(");
  590. string currencyCode = currency2[1].Replace(")", "").TrimEnd();
  591. SetDataInfoView dataInfoView = new SetDataInfoView();
  592. dataInfoView = currencyDatas.Where(it => it.Name == currencyCode).FirstOrDefault();
  593. int currencyId = currencyDatas.Where(it => it.Name == currencyCode).FirstOrDefault().Id;
  594. TeamRateDescAddCurrencyIdView rateDescView = new TeamRateDescAddCurrencyIdView()
  595. {
  596. CurrencyId = dataInfoView.Id,
  597. CurrencyCode = currencyCode,
  598. CurrencyName = currency2[0],
  599. Rate = decimal.Parse(currency1[1]),
  600. };
  601. teamRateDescViews.Add(rateDescView);
  602. }
  603. }
  604. #endregion
  605. if (teamRateDescViews.Count > 0)
  606. {
  607. teamRateDescViews = teamRateDescViews.OrderBy(it => it.CurrencyId).ToList();
  608. teamRateDatas.AddRange(teamRateDescViews);
  609. }
  610. }
  611. foreach (var item in _view)
  612. {
  613. if (item.CurrencyId == 836) // 人名币
  614. {
  615. item.Rate = 1.0000M;
  616. }
  617. item.Number = teamRateDatas.Where(it => item.CurrencyId == it.CurrencyId).ToList().Count;
  618. }
  619. if (_view.Count > 0)
  620. {
  621. _view = _view.OrderByDescending(it => it.Number).ToList();
  622. }
  623. return _view;
  624. }
  625. }
  626. }