TeamRateRepository.cs 30 KB

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