AirTicketResRepository.cs 90 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137
  1. using AutoMapper;
  2. using Newtonsoft.Json;
  3. using Newtonsoft.Json.Linq;
  4. using OASystem.Domain;
  5. using OASystem.Domain.AesEncryption;
  6. using OASystem.Domain.Dtos.Groups;
  7. using OASystem.Domain.Entities.Customer;
  8. using OASystem.Domain.Entities.Financial;
  9. using OASystem.Domain.Entities.Groups;
  10. using OASystem.Domain.Entities.Resource;
  11. using OASystem.Domain.ViewModels.Groups;
  12. using System.Security.Cryptography;
  13. namespace OASystem.Infrastructure.Repositories.Groups;
  14. public class AirTicketResRepository : BaseRepository<Grp_AirTicketReservations, Grp_AirTicketReservations>
  15. {
  16. private readonly IMapper _mapper;
  17. private readonly DelegationInfoRepository _groupInfoRep;
  18. private readonly TeamRateRepository _groupRateRep;
  19. public AirTicketResRepository(SqlSugarClient sqlSugar, DelegationInfoRepository groupInfoRep, TeamRateRepository groupRateRep, IMapper mapper) : base(sqlSugar)
  20. {
  21. _mapper = mapper;
  22. _groupInfoRep = groupInfoRep;
  23. _groupRateRep = groupRateRep;
  24. }
  25. #region 旧版
  26. public async Task<Result> AirTicketResById(AirTicketResByIdDto dto)
  27. {
  28. var result = new Result() { Code = -2, Msg = "未知错误" };
  29. try
  30. {
  31. Grp_AirTicketReservations grp_AirTicket = _sqlSugar.Queryable<Grp_AirTicketReservations>().First(a => a.Id == dto.Id && a.IsDel == 0);
  32. if (grp_AirTicket == null)
  33. {
  34. return result = new Result() { Code = -1, Msg = "暂无数据" };
  35. }
  36. else
  37. {
  38. Grp_CreditCardPayment grp_CreditCard = _sqlSugar.Queryable<Grp_CreditCardPayment>().First(a => a.CId == grp_AirTicket.Id && a.IsDel == 0 && a.CTable == 85);
  39. if (grp_CreditCard == null) { return result = new Result() { Code = -1, Msg = "暂无数据" }; }
  40. return result = new Result()
  41. {
  42. Code = 0,
  43. Msg = "查询成功!",
  44. Data = new
  45. {
  46. AirTicket = grp_AirTicket,
  47. CreditCard = grp_CreditCard,
  48. }
  49. };
  50. }
  51. }
  52. catch (Exception)
  53. {
  54. return result = new Result() { Code = -2, Msg = "未知错误" };
  55. }
  56. }
  57. public async Task<Result> AirTicketResList(AirTicketResDto dto)
  58. {
  59. var result = new Result() { Code = -2, Msg = "未知错误" };
  60. Grp_DelegationInfo _DelegationInfo = _sqlSugar.Queryable<Grp_DelegationInfo>().First(it => it.Id == dto.DiId);
  61. if (_DelegationInfo != null)
  62. {
  63. string UserId = "";
  64. List<Grp_GroupsTaskAssignment> gtaUIdList = _sqlSugar.Queryable<Grp_GroupsTaskAssignment>().Where(a => a.DIId == dto.DiId && a.IsDel == 0 && a.CTId == 85).ToList();
  65. foreach (Grp_GroupsTaskAssignment gta in gtaUIdList)
  66. UserId += gta.UId + ",";
  67. if (!string.IsNullOrWhiteSpace(UserId))
  68. {
  69. UserId = UserId[..^1];
  70. }
  71. else
  72. {
  73. UserId = "0";
  74. }
  75. string sqlWhere = "";
  76. if (dto.IsPaySign != -1)
  77. {
  78. sqlWhere += string.Format(@" And ccp.IsPay = {0} ", dto.IsPaySign);
  79. }
  80. string sql = string.Format(@"Select atr.*,ccp.IsAuditGM,sd1.Name As CTypeName,sd2.Name As PreCurrencyStr,sd3.Name As CurrencyStr,ccp.IsPay
  81. From Grp_AirTicketReservations atr
  82. Left Join Grp_CreditCardPayment ccp On atr.Id = ccp.CId And atr.DIId = ccp.DIId And ccp.IsDel = 0
  83. Left Join Sys_SetData sd1 On sd1.Id = atr.ctype
  84. Left Join Sys_SetData sd2 On sd2.Id = atr.PreCurrency
  85. Left Join Sys_SetData sd3 On sd3.Id = atr.Currency
  86. Where atr.IsDel = 0 And atr.DIId={0} {1}
  87. Order By atr.FlightsDate Asc", dto.DiId, sqlWhere);
  88. List<AirTicketReservationsView> _AirTicketReservations = _sqlSugar.SqlQueryable<AirTicketReservationsView>(sql).ToList();
  89. foreach (var item in _AirTicketReservations)
  90. {
  91. if (item.FlightsDescription.Contains("\n"))
  92. {
  93. var spilitArr = Regex.Split(item.FlightsDescription, "\n");
  94. int rowindex = 1;
  95. foreach (var spilitItem in spilitArr)
  96. {
  97. try
  98. {
  99. var spDotandEmpty = spilitItem.Split('.')[1].Split(' ').Where(x => !string.IsNullOrEmpty(x)).ToList();
  100. var depCode = spDotandEmpty[3].Substring(0, 3);
  101. var arrCode = spDotandEmpty[3].Substring(3, 3);
  102. Res_ThreeCode depData = _sqlSugar.Queryable<Res_ThreeCode>().First(it => it.IsDel == 0 && it.Three == depCode);
  103. Res_ThreeCode arrData = _sqlSugar.Queryable<Res_ThreeCode>().First(it => it.IsDel == 0 && it.Three == arrCode);
  104. string day = spDotandEmpty[2].Substring(2, 2);//日
  105. string monthAbbreviations = spDotandEmpty[2].Substring(4, 3).ToUpper();//月份
  106. switch (monthAbbreviations)
  107. {
  108. case "JAN":
  109. monthAbbreviations = "1";
  110. break;
  111. case "FEB":
  112. monthAbbreviations = "2";
  113. break;
  114. case "MAR":
  115. monthAbbreviations = "3";
  116. break;
  117. case "APR":
  118. monthAbbreviations = "4";
  119. break;
  120. case "MAY":
  121. monthAbbreviations = "5";
  122. break;
  123. case "JUN":
  124. monthAbbreviations = "6";
  125. break;
  126. case "JUL":
  127. monthAbbreviations = "7";
  128. break;
  129. case "AUG":
  130. monthAbbreviations = "8";
  131. break;
  132. case "SEP":
  133. monthAbbreviations = "9";
  134. break;
  135. case "OCT":
  136. monthAbbreviations = "10";
  137. break;
  138. case "NOV":
  139. monthAbbreviations = "11";
  140. break;
  141. case "DEC":
  142. monthAbbreviations = "12";
  143. break;
  144. }
  145. string tate = $"{monthAbbreviations}月{day}日";
  146. item.FlightDescription += rowindex + ". " + depData.AirPort + " " + arrData.AirPort + " (" + tate + ")\r\n";
  147. }
  148. catch (Exception ex)
  149. {
  150. item.FlightDescription = "录入数据不规范!请检查";
  151. break;
  152. }
  153. rowindex++;
  154. }
  155. }
  156. else
  157. {
  158. try
  159. {
  160. var spDotandEmpty = item.FlightsDescription.Split('.')[1].Split(' ').Where(x => !string.IsNullOrEmpty(x)).ToList();
  161. var depCode = spDotandEmpty[3].Substring(0, 3);
  162. var arrCode = spDotandEmpty[3].Substring(3, 3);
  163. Res_ThreeCode depData = _sqlSugar.Queryable<Res_ThreeCode>().First(it => it.IsDel == 0 && it.Three == depCode);
  164. Res_ThreeCode arrData = _sqlSugar.Queryable<Res_ThreeCode>().First(it => it.IsDel == 0 && it.Three == arrCode);
  165. string day = spDotandEmpty[2].Substring(2, 2);//日
  166. string monthAbbreviations = spDotandEmpty[2].Substring(4, 3).ToUpper();//月份
  167. switch (monthAbbreviations)
  168. {
  169. case "JAN":
  170. monthAbbreviations = "1";
  171. break;
  172. case "FEB":
  173. monthAbbreviations = "2";
  174. break;
  175. case "MAR":
  176. monthAbbreviations = "3";
  177. break;
  178. case "APR":
  179. monthAbbreviations = "4";
  180. break;
  181. case "MAY":
  182. monthAbbreviations = "5";
  183. break;
  184. case "JUN":
  185. monthAbbreviations = "6";
  186. break;
  187. case "JUL":
  188. monthAbbreviations = "7";
  189. break;
  190. case "AUG":
  191. monthAbbreviations = "8";
  192. break;
  193. case "SEP":
  194. monthAbbreviations = "9";
  195. break;
  196. case "OCT":
  197. monthAbbreviations = "10";
  198. break;
  199. case "NOV":
  200. monthAbbreviations = "11";
  201. break;
  202. case "DEC":
  203. monthAbbreviations = "12";
  204. break;
  205. }
  206. string tate = $"{monthAbbreviations}月{day}日";
  207. item.FlightDescription += depData.AirPort + " " + arrData.AirPort + " (" + tate + ")\r\n";
  208. }
  209. catch (Exception)
  210. {
  211. item.FlightDescription = "录入数据不规范!请检查";
  212. }
  213. }
  214. }
  215. //团组成本预算表查询
  216. Grp_GroupCostParameter _GroupCostParameter = _sqlSugar.Queryable<Grp_GroupCostParameter>().First(a => a.DiId == dto.DiId && a.IsDel == 0 && a.CostType == "A" && a.IsShare == 1);
  217. AirGroupCostParameterView _AirgroupCostParameter = _mapper.Map<AirGroupCostParameterView>(_GroupCostParameter);
  218. for (int i = 0; i < _AirTicketReservations.Count; i++)
  219. {
  220. string[] ClientArr = _AirTicketReservations[i].ClientName.Split(',').Where(x => !string.IsNullOrWhiteSpace(x)).ToArray();
  221. foreach (var item in ClientArr)
  222. {
  223. bool isNumeric = int.TryParse(item, out _);
  224. if (isNumeric)
  225. {
  226. if (item == "-1")
  227. {
  228. _AirTicketReservations[i].ClientNameStr += "行程单,";
  229. }
  230. else
  231. {
  232. Crm_DeleClient DeleClient = _sqlSugar.Queryable<Crm_DeleClient>().Where(a => a.IsDel == 0 && a.Id == int.Parse(item)).First();
  233. EncryptionProcessor.DecryptProperties(DeleClient);
  234. _AirTicketReservations[i].ClientNameStr += DeleClient.Pinyin + ',';
  235. }
  236. }
  237. else
  238. {
  239. _AirTicketReservations[i].ClientNameStr += item;
  240. }
  241. }
  242. if (_AirTicketReservations[i].ClientNameStr is not null)
  243. {
  244. _AirTicketReservations[i].ClientNameStr = _AirTicketReservations[i].ClientNameStr.Substring(0, _AirTicketReservations[i].ClientNameStr.Length - 1);
  245. }
  246. }
  247. if (dto.PortType == 1)
  248. {
  249. var data = new
  250. {
  251. DelegationInfo = _DelegationInfo,
  252. AirTicketReservations = _AirTicketReservations,
  253. AirGroupCostParameter = _AirgroupCostParameter
  254. };
  255. return result = new Result() { Code = 0, Msg = "查询成功!", Data = data };
  256. }
  257. else if (dto.PortType == 2 || dto.PortType == 3)
  258. {
  259. int count = _AirTicketReservations.Count;
  260. float totalPage = (float)count / dto.PageSize;//总页数
  261. if (totalPage == 0) totalPage = 1;
  262. else totalPage = (int)Math.Ceiling((double)totalPage);
  263. var grp_AirTickets = new List<AirTicketReservationsView>();
  264. for (int i = 0; i < dto.PageSize; i++)
  265. {
  266. var RowIndex = i + (dto.PageIndex - 1) * dto.PageSize;
  267. if (RowIndex < _AirTicketReservations.Count)
  268. {
  269. grp_AirTickets.Add(_AirTicketReservations[RowIndex]);
  270. }
  271. else
  272. {
  273. break;
  274. }
  275. }
  276. var rst = new ListViewBase<AirTicketReservationsView>
  277. {
  278. DataList = grp_AirTickets,
  279. DataCount = count,
  280. CurrPageIndex = dto.PageIndex,
  281. CurrPageSize = dto.PageSize
  282. };
  283. var data = new
  284. {
  285. AirData = rst,
  286. AirGroupCostParameter = _AirgroupCostParameter
  287. };
  288. return new Result() { Code = 0, Msg = "查询成功!", Data = data };
  289. }
  290. else
  291. {
  292. return new Result() { Code = -1, Msg = "请传入PortType参数!1:Web,2:Android,3:IOS!" };
  293. }
  294. }
  295. else
  296. {
  297. return new Result() { Code = -1, Msg = "暂无团组数据!" };
  298. }
  299. }
  300. public async Task<Result> AirTicketResSelect(AirTicketResDto dto)
  301. {
  302. var result = new Result() { Code = -2, Msg = "未知错误" };
  303. try
  304. {
  305. if (dto.DiId < 1)
  306. {
  307. dto.DiId = -1;
  308. }
  309. #region 团组下拉框
  310. List<Grp_GroupsTaskAssignment> grp_GroupsTaskAssignment = Query<Grp_GroupsTaskAssignment>(a => a.IsDel == 0 && a.UId == dto.UserId && a.CTId == 85).ToList();
  311. var grp_NameView = new List<dynamic>();
  312. string DiId = "";
  313. foreach (var item in grp_GroupsTaskAssignment)
  314. {
  315. DiId += item.DIId + ",";
  316. }
  317. if (DiId.Length > 1)
  318. {
  319. DiId = DiId.Substring(0, DiId.Length - 1);
  320. string sql = string.Format(@"select * from Grp_DelegationInfo where Id in({0}) and IsDel={1} Order By VisitStartDate Desc", DiId, 0);
  321. List<Grp_DelegationInfo> grp_Delegations = _sqlSugar.SqlQueryable<Grp_DelegationInfo>(sql).ToList();
  322. if (grp_Delegations.Count == 0)
  323. {
  324. return result = new Result() { Code = -1, Msg = "查询失败!" };
  325. }
  326. foreach (var item in grp_Delegations)
  327. {
  328. var groupNameView = new
  329. {
  330. item.Id,
  331. item.TeamName
  332. };
  333. grp_NameView.Add(groupNameView);
  334. }
  335. }
  336. #endregion
  337. #region 其他下拉框查询
  338. //舱位类型
  339. List<Sys_SetData> TicketClass = _sqlSugar.Queryable<Sys_SetData>().Where(a => a.STid == 44 && a.IsDel == 0).ToList();
  340. List<SetDataInfoView> _TicketClassa = _mapper.Map<List<SetDataInfoView>>(TicketClass);
  341. //支付方式
  342. List<Sys_SetData> Payment = _sqlSugar.Queryable<Sys_SetData>().Where(a => a.STid == 14 && a.IsDel == 0).ToList();
  343. List<SetDataInfoView> _Payment = _mapper.Map<List<SetDataInfoView>>(Payment);
  344. //卡类型
  345. List<Sys_SetData> CardType = _sqlSugar.Queryable<Sys_SetData>().Where(a => a.STid == 15 && a.IsDel == 0).ToList();
  346. List<SetDataInfoView> _CardType = _mapper.Map<List<SetDataInfoView>>(CardType);
  347. //合作方资料
  348. List<Res_AirTicketAgent> _AirTicketAgents = _sqlSugar.Queryable<Res_AirTicketAgent>().Where(a => a.IsDel == 0).ToList();
  349. foreach (var item in _AirTicketAgents)
  350. {
  351. EncryptionProcessor.DecryptProperties(item);
  352. }
  353. #endregion
  354. #region 客人名单下拉框
  355. if (dto.DiId == -1)
  356. {
  357. var dele = _AirTicketAgents.FirstOrDefault();
  358. dto.DiId = dele != null ? dele.Id : dto.DiId;
  359. }
  360. string sqlClient = string.Format("select b.Id,b.Pinyin,b.lastName,b.firstName,b.phone from Grp_TourClientList a, Crm_DeleClient b where a.clientid = b.id and a.isdel = 0 and a.diid = {0}", dto.DiId);
  361. var clientArr = _sqlSugar.SqlQueryable<SimplClientInfo>(sqlClient).ToList();
  362. foreach (var item in clientArr) { EncryptionProcessor.DecryptProperties(item); }
  363. #endregion
  364. var data = new
  365. {
  366. TicketClass = _TicketClassa,
  367. Payment = _Payment,
  368. CardType = _CardType,
  369. GroupName = grp_NameView,
  370. AirTicketAgents = _AirTicketAgents,
  371. clientArr
  372. };
  373. return result = new Result() { Code = 0, Msg = "查询成功!", Data = data };
  374. }
  375. catch (Exception ex)
  376. {
  377. return result = new Result() { Code = -2, Msg = "程序错误" };
  378. }
  379. }
  380. public async Task<Result> OpAirTicketRes(AirTicketResOpDto dto, Func<int, int, int, Task<Result>> fn)
  381. {
  382. var result = new Result() { Code = -2, Msg = "未知错误" };
  383. try
  384. {
  385. BeginTran();
  386. int id = 0;
  387. var grp_AirTicket = _mapper.Map<Grp_AirTicketReservations>(dto.AirTicketResOpData);
  388. var clientName = string.Join(",", dto.AirTicketResOpData.ClientName);
  389. if (dto.Status == 1)
  390. {
  391. grp_AirTicket.FlightsDate = DateTime.Parse(grp_AirTicket.FlightsDate).ToString("yyyy-MM-dd");
  392. grp_AirTicket.ClientName = clientName;
  393. id = await AddAsyncReturnId(grp_AirTicket);
  394. if (id == 0)
  395. {
  396. result = new Result() { Code = -1, Msg = "添加失败!" };
  397. }
  398. else
  399. {
  400. result = new Result() { Code = 0, Msg = "添加成功!" };
  401. }
  402. // }
  403. if (result.Code == 0)
  404. {
  405. Grp_CreditCardPayment grp_CreditCard = _mapper.Map<Grp_CreditCardPayment>(dto.CardPaymentOpData);
  406. // 2025-04-07 第四次更改 PayDId == 72(刷卡) IsPay == 1
  407. if (grp_CreditCard.PayDId == 72) grp_CreditCard.IsPay = 1;
  408. else grp_CreditCard.IsPay = 0;
  409. //获取新汇率 int diId,int CId, int currencyId
  410. var rate = await fn(dto.AirTicketResOpData.DiId, 85, dto.AirTicketResOpData.Currency);
  411. if (rate.Code == 0)
  412. {
  413. var rateInfo = (rate.Data as CurrencyInfo);
  414. if (rateInfo is not null)
  415. {
  416. grp_CreditCard.DayRate = rateInfo.Rate;
  417. grp_CreditCard.RMBPrice = rateInfo.Rate * grp_CreditCard.PayMoney;
  418. }
  419. else
  420. {
  421. grp_CreditCard.DayRate = 1;
  422. grp_CreditCard.RMBPrice = grp_CreditCard.PayMoney;
  423. }
  424. }
  425. //换算
  426. #region 老汇率处理方式
  427. //Grp_TeamRate _TeamRate = _sqlSugar.Queryable<Grp_TeamRate>().First(a => a.DiId == grp_AirTicket.DIId && a.IsDel == 0 && a.CTable == 85);
  428. //if (_TeamRate != null)
  429. //{
  430. // if (grp_CreditCard.PaymentCurrency == 49)
  431. // {
  432. // grp_CreditCard.DayRate = _TeamRate.RateU;
  433. // grp_CreditCard.RMBPrice = grp_CreditCard.PayMoney * Convert.ToDecimal(_TeamRate.RateU);
  434. // //ccp.PayMoney = ccp.PayMoney * float.Parse(tr.RateU);
  435. // }
  436. // else if (grp_CreditCard.PaymentCurrency == 51)
  437. // {
  438. // grp_CreditCard.DayRate = _TeamRate.RateE;
  439. // grp_CreditCard.RMBPrice = grp_CreditCard.PayMoney * Convert.ToDecimal(_TeamRate.RateE);
  440. // //ccp.PayMoney = ccp.PayMoney * float.Parse(tr.RateE);
  441. // }
  442. // else
  443. // {
  444. // grp_CreditCard.DayRate = 1M;
  445. // grp_CreditCard.RMBPrice = grp_CreditCard.PayMoney;
  446. // }
  447. //}
  448. //else
  449. //{
  450. // grp_CreditCard.DayRate = 1M;
  451. // grp_CreditCard.RMBPrice = grp_CreditCard.PayMoney;
  452. //}
  453. #endregion
  454. //判断是否超出成本
  455. #region 自动审核(暂时屏蔽)
  456. //Grp_GroupCostParameter _GroupCostParameter = _sqlSugar.Queryable<Grp_GroupCostParameter>().First(a => a.DiId == grp_AirTicket.DIId && a.IsDel == 0);
  457. //if (grp_AirTicket.CType == 460)//经济舱
  458. //{
  459. // if (_GroupCostParameter != null)
  460. // {
  461. // if (Convert.ToDecimal(_GroupCostParameter.JJCCB) * Convert.ToDecimal(grp_AirTicket.ClientNum) > grp_CreditCard.RMBPrice)
  462. // {
  463. // grp_CreditCard.ExceedBudget = 0;// 超出预算比例 换算
  464. // grp_CreditCard.IsAuditGM = 3;//3 为自动审核
  465. // grp_CreditCard.AuditGMOperate = 0;
  466. // grp_CreditCard.AuditGMDate = "";
  467. // grp_CreditCard.IsPay = 0;
  468. // }
  469. // else
  470. // {
  471. // var a = grp_CreditCard.RMBPrice - Convert.ToDecimal(_GroupCostParameter.JJCCB);
  472. // var b = a / Convert.ToDecimal(_GroupCostParameter.JJCCB) * Convert.ToDecimal(grp_AirTicket.ClientNum);
  473. // grp_CreditCard.ExceedBudget = b;// 超出预算比例 换算
  474. // grp_CreditCard.IsAuditGM = 0;//3 为自动审核
  475. // grp_CreditCard.AuditGMOperate = 21;
  476. // grp_CreditCard.AuditGMDate = "";
  477. // grp_CreditCard.IsPay = 0;
  478. // }
  479. // }
  480. // else
  481. // {
  482. // grp_CreditCard.ExceedBudget = 0.00M;// 超出预算比例 换算
  483. // grp_CreditCard.IsAuditGM = 0;//3 为自动审核
  484. // grp_CreditCard.AuditGMOperate = 0;
  485. // grp_CreditCard.AuditGMDate = "";
  486. // grp_CreditCard.IsPay = 0;
  487. // }
  488. //}
  489. //else if (grp_AirTicket.CType == 458)
  490. //{
  491. // if (_GroupCostParameter != null)
  492. // {
  493. // if (Convert.ToDecimal(_GroupCostParameter.GWCB) * Convert.ToDecimal(grp_AirTicket.ClientNum) > grp_CreditCard.RMBPrice)
  494. // {
  495. // grp_CreditCard.ExceedBudget = 0;// 超出预算比例 换算
  496. // grp_CreditCard.IsAuditGM = 3;//3 为自动审核
  497. // grp_CreditCard.AuditGMOperate = 21;
  498. // grp_CreditCard.AuditGMDate = "";
  499. // grp_CreditCard.IsPay = 0;
  500. // }
  501. // else
  502. // {
  503. // var a = grp_CreditCard.RMBPrice - Convert.ToDecimal(_GroupCostParameter.GWCB);
  504. // var b = a / Convert.ToDecimal(_GroupCostParameter.GWCB) * Convert.ToDecimal(grp_AirTicket.ClientNum);
  505. // grp_CreditCard.ExceedBudget = b;// 超出预算比例 换算
  506. // grp_CreditCard.IsAuditGM = 0;//3 为自动审核
  507. // grp_CreditCard.AuditGMOperate = 21;
  508. // grp_CreditCard.AuditGMDate = "";
  509. // grp_CreditCard.IsPay = 0;
  510. // }
  511. // }
  512. // else
  513. // {
  514. // grp_CreditCard.ExceedBudget = 0.00M;// 超出预算比例 换算
  515. // grp_CreditCard.IsAuditGM = 0;//3 为自动审核
  516. // grp_CreditCard.AuditGMOperate = 21;
  517. // grp_CreditCard.AuditGMDate = "";
  518. // grp_CreditCard.IsPay = 0;
  519. // }
  520. //}
  521. //else
  522. //{
  523. // grp_CreditCard.ExceedBudget = 0.00M;// 超出预算比例 换算
  524. // grp_CreditCard.IsAuditGM = 0;//3 为自动审核
  525. // grp_CreditCard.AuditGMOperate = 0;
  526. // grp_CreditCard.AuditGMDate = "";
  527. // grp_CreditCard.IsPay = 0;
  528. //}
  529. #endregion
  530. grp_CreditCard.CId = id;
  531. grp_CreditCard.CTable = 85;
  532. grp_CreditCard.PayPercentage = 100;
  533. #region 查询上一次付款(注释)
  534. ////查询上一次付款信息
  535. //Grp_CreditCardPayment _CreditCardPayment = _sqlSugar.Queryable<Grp_CreditCardPayment>().OrderByDescending(x => x.CreateUserId).First(a => a.DIId == grp_AirTicket.DIId && a.IsDel == 0 && a.IsPay == 1);
  536. //if (_CreditCardPayment != null)
  537. //{
  538. // grp_CreditCard.PayPercentageOld = _CreditCardPayment.PayPercentageOld;// 上次付款百分比 查询并计算最近一次
  539. // grp_CreditCard.PayThenMoneyOld = _CreditCardPayment.PayMoney;// 上次付款金额 查询上一次
  540. // grp_CreditCard.UpdateDate = _CreditCardPayment.UpdateDate;// 上次付款时间 查询上一次
  541. //}
  542. //else
  543. //{
  544. // grp_CreditCard.PayPercentageOld = 0;// 上次付款百分比 查询并计算最近一次
  545. // grp_CreditCard.PayThenMoneyOld = 0;// 上次付款金额 查询上一次
  546. // grp_CreditCard.UpdateDate = "";// 上次付款时间 查询上一次
  547. //}
  548. #endregion
  549. id = await _sqlSugar.Insertable(grp_CreditCard).ExecuteReturnIdentityAsync();
  550. if (id == 0)
  551. {
  552. RollbackTran();
  553. return result = new Result() { Code = -1, Msg = "添加失败!" };
  554. }
  555. await UpdateAsync(a => a.Id == id, a => new Grp_AirTicketReservations
  556. {
  557. FlightsDescription = dto.AirTicketResOpData.FlightsDescription,
  558. });
  559. CommitTran();
  560. var data = new { ccpId = id, sign = 1, dataId = grp_CreditCard.CId };
  561. return result = new Result() { Code = 0, Msg = "添加成功!", Data = data };
  562. }
  563. else
  564. {
  565. RollbackTran();
  566. return result = new Result() { Code = -1, Msg = "添加失败!" };
  567. }
  568. }
  569. else if (dto.Status == 2)
  570. {
  571. id = dto.AirTicketResOpData.Id;
  572. bool res = await UpdateAsync(a => a.Id == dto.AirTicketResOpData.Id, a => new Grp_AirTicketReservations
  573. {
  574. CType = dto.AirTicketResOpData.CType,
  575. PrePrice = dto.AirTicketResOpData.PrePrice,
  576. PreCurrency = dto.AirTicketResOpData.PreCurrency,
  577. Price = dto.AirTicketResOpData.Price,
  578. Currency = dto.AirTicketResOpData.Currency,
  579. ClientNum = dto.AirTicketResOpData.ClientNum,
  580. ClientName = clientName,
  581. IsCheckIn = dto.AirTicketResOpData.IsCheckIn,
  582. IsSetSeat = dto.AirTicketResOpData.IsSetSeat,
  583. IsPackage = dto.AirTicketResOpData.IsPackage,
  584. IsBagHandle = dto.AirTicketResOpData.IsBagHandle,
  585. IsTrain = dto.AirTicketResOpData.IsTrain,
  586. FlightsCode = dto.AirTicketResOpData.FlightsCode,
  587. FlightsCity = dto.AirTicketResOpData.FlightsCity,
  588. FlightsDescription = dto.AirTicketResOpData.FlightsDescription,
  589. PriceDescription = dto.AirTicketResOpData.PriceDescription,
  590. TicketNumber = dto.AirTicketResOpData.TicketNumber,
  591. TicketCode = dto.AirTicketResOpData.TicketCode,
  592. Remark = dto.AirTicketResOpData.Remark,
  593. });
  594. if (!res) { result = new Result() { Code = -1, Msg = "修改失败!" }; }
  595. else { result = new Result() { Code = 0, Msg = "修改成功!" }; }
  596. if (result.Code == 0)
  597. {
  598. //C表操作
  599. Grp_CreditCardPayment grp_CreditCard = _mapper.Map<Grp_CreditCardPayment>(dto.CardPaymentOpData);
  600. //2025-04-07 第四次更改 PayDId == 72(刷卡) IsPay == 1
  601. if (grp_CreditCard.PayDId == 72) grp_CreditCard.IsPay = 1;
  602. else grp_CreditCard.IsPay = 0;
  603. //获取新汇率 int diId,int CId, int currencyId
  604. var rate = await fn(dto.AirTicketResOpData.DiId, 85, dto.AirTicketResOpData.Currency);
  605. if (rate.Code == 0)
  606. {
  607. var rateInfo = (rate.Data as CurrencyInfo);
  608. if (rateInfo is not null)
  609. {
  610. grp_CreditCard.DayRate = rateInfo.Rate;
  611. grp_CreditCard.RMBPrice = rateInfo.Rate * grp_CreditCard.PayMoney;
  612. }
  613. else
  614. {
  615. grp_CreditCard.DayRate = 1;
  616. grp_CreditCard.RMBPrice = grp_CreditCard.PayMoney;
  617. }
  618. }
  619. #region 老汇率修改(注释)
  620. //换算
  621. Grp_TeamRate _TeamRate = _sqlSugar.Queryable<Grp_TeamRate>().First(a => a.DiId == grp_AirTicket.DIId && a.IsDel == 0 && a.CTable == 85);
  622. //if (_TeamRate != null)
  623. //{
  624. // if (grp_CreditCard.PaymentCurrency == 49)
  625. // {
  626. // grp_CreditCard.DayRate = _TeamRate.RateU;
  627. // grp_CreditCard.RMBPrice = grp_CreditCard.PayMoney * Convert.ToDecimal(_TeamRate.RateU);
  628. // //ccp.PayMoney = ccp.PayMoney * float.Parse(tr.RateU);
  629. // }
  630. // else if (grp_CreditCard.PaymentCurrency == 51)
  631. // {
  632. // grp_CreditCard.DayRate = _TeamRate.RateE;
  633. // grp_CreditCard.RMBPrice = grp_CreditCard.PayMoney * Convert.ToDecimal(_TeamRate.RateE);
  634. // //ccp.PayMoney = ccp.PayMoney * float.Parse(tr.RateE);
  635. // }
  636. // else
  637. // {
  638. // grp_CreditCard.DayRate = 1M;
  639. // grp_CreditCard.RMBPrice = grp_CreditCard.PayMoney;
  640. // }
  641. //}
  642. //else
  643. //{
  644. // grp_CreditCard.DayRate = 1M;
  645. // grp_CreditCard.RMBPrice = grp_CreditCard.PayMoney;
  646. //}
  647. #endregion
  648. #region 自动审核(注释)
  649. //Grp_GroupCostParameter _GroupCostParameter = _sqlSugar.Queryable<Grp_GroupCostParameter>().First(a => a.DiId == grp_AirTicket.DIId && a.IsDel == 0);
  650. //if (grp_AirTicket.CType == 460)//经济舱
  651. //{
  652. // if (_GroupCostParameter != null)
  653. // {
  654. // if (Convert.ToDecimal(_GroupCostParameter.JJCCB) * Convert.ToDecimal(grp_AirTicket.ClientNum) > grp_CreditCard.RMBPrice)
  655. // {
  656. // grp_CreditCard.ExceedBudget = 0;// 超出预算比例 换算
  657. // grp_CreditCard.IsAuditGM = 3;//3 为自动审核
  658. // grp_CreditCard.AuditGMOperate = 0;
  659. // grp_CreditCard.AuditGMDate = "";
  660. // grp_CreditCard.IsPay = 1;
  661. // }
  662. // else
  663. // {
  664. // var a = grp_CreditCard.RMBPrice - Convert.ToDecimal(_GroupCostParameter.JJCCB);
  665. // var b = a / Convert.ToDecimal(_GroupCostParameter.JJCCB) * Convert.ToDecimal(grp_AirTicket.ClientNum);
  666. // grp_CreditCard.ExceedBudget = b;// 超出预算比例 换算
  667. // grp_CreditCard.IsAuditGM = 0;//3 为自动审核
  668. // grp_CreditCard.AuditGMOperate = 21;
  669. // grp_CreditCard.AuditGMDate = "";
  670. // grp_CreditCard.IsPay = 1;
  671. // }
  672. // }
  673. // else
  674. // {
  675. // grp_CreditCard.ExceedBudget = 0.00M;// 超出预算比例 换算
  676. // grp_CreditCard.IsAuditGM = 0;//3 为自动审核
  677. // grp_CreditCard.AuditGMOperate = 21;
  678. // grp_CreditCard.AuditGMDate = "";
  679. // grp_CreditCard.IsPay = 0;
  680. // }
  681. //}
  682. //else if (grp_AirTicket.CType == 458)
  683. //{
  684. // if (_GroupCostParameter != null)
  685. // {
  686. // if ((_GroupCostParameter != null ? _GroupCostParameter.GWCB : 0) * Convert.ToDecimal(grp_AirTicket.ClientNum) > grp_CreditCard.RMBPrice)
  687. // {
  688. // grp_CreditCard.ExceedBudget = 0;// 超出预算比例 换算
  689. // grp_CreditCard.IsAuditGM = 3;//3 为自动审核
  690. // grp_CreditCard.AuditGMOperate = 21;
  691. // grp_CreditCard.AuditGMDate = "";
  692. // grp_CreditCard.IsPay = 1;
  693. // }
  694. // else
  695. // {
  696. // var a = grp_CreditCard.RMBPrice - Convert.ToDecimal(_GroupCostParameter.GWCB);
  697. // var b = a / Convert.ToDecimal(_GroupCostParameter.GWCB) * Convert.ToDecimal(grp_AirTicket.ClientNum);
  698. // grp_CreditCard.ExceedBudget = b;// 超出预算比例 换算
  699. // grp_CreditCard.IsAuditGM = 0;//3 为自动审核
  700. // grp_CreditCard.AuditGMOperate = 21;
  701. // grp_CreditCard.AuditGMDate = "";
  702. // grp_CreditCard.IsPay = 1;
  703. // }
  704. // }
  705. // else
  706. // {
  707. // grp_CreditCard.ExceedBudget = 0.00M;// 超出预算比例 换算
  708. // grp_CreditCard.IsAuditGM = 0;//3 为自动审核
  709. // grp_CreditCard.AuditGMOperate = 21;
  710. // grp_CreditCard.AuditGMDate = "";
  711. // grp_CreditCard.IsPay = 0;
  712. // }
  713. //}
  714. #endregion
  715. grp_CreditCard.CId = id;
  716. grp_CreditCard.CTable = 85;
  717. grp_CreditCard.PayPercentage = 100;
  718. #region 查询上一次付款信息(注释)
  719. ////查询上一次付款信息
  720. //Grp_CreditCardPayment _CreditCardPayment = _sqlSugar.Queryable<Grp_CreditCardPayment>().OrderByDescending(x => x.CreateUserId).First(a => a.DIId == grp_AirTicket.DIId && a.IsDel == 0 && a.IsPay == 1);
  721. //if (_CreditCardPayment != null)
  722. //{
  723. // grp_CreditCard.PayPercentageOld = _CreditCardPayment.PayPercentageOld;// 上次付款百分比 查询并计算最近一次
  724. // grp_CreditCard.PayThenMoneyOld = _CreditCardPayment.PayMoney;// 上次付款金额 查询上一次
  725. // grp_CreditCard.UpdateDate = _CreditCardPayment.UpdateDate;// 上次付款时间 查询上一次
  726. //}
  727. //else
  728. //{
  729. // grp_CreditCard.PayPercentageOld = 0;// 上次付款百分比 查询并计算最近一次
  730. // grp_CreditCard.PayThenMoneyOld = 0;// 上次付款金额 查询上一次
  731. // grp_CreditCard.UpdateDate = "";// 上次付款时间 查询上一次
  732. //}
  733. #endregion
  734. int CTable = await _sqlSugar.Updateable<Grp_CreditCardPayment>().Where(a => a.Id == dto.CardPaymentOpData.Id).SetColumns(a => new Grp_CreditCardPayment
  735. {
  736. PayDId = grp_CreditCard.PayDId,
  737. ConsumptionPatterns = grp_CreditCard.ConsumptionPatterns,
  738. ConsumptionDate = grp_CreditCard.ConsumptionDate,
  739. CTDId = grp_CreditCard.CTDId,
  740. BankNo = grp_CreditCard.BankNo,
  741. CardholderName = grp_CreditCard.CardholderName,
  742. PayMoney = grp_CreditCard.PayMoney,
  743. PaymentCurrency = grp_CreditCard.PaymentCurrency,
  744. DayRate = grp_CreditCard.DayRate,
  745. CompanyBankNo = grp_CreditCard.CompanyBankNo,
  746. OtherBankName = grp_CreditCard.OtherBankName,
  747. OtherSideNo = grp_CreditCard.OtherSideNo,
  748. OtherSideName = grp_CreditCard.OtherSideName,
  749. IsAuditGM = grp_CreditCard.IsAuditGM,
  750. AuditGMOperate = grp_CreditCard.AuditGMOperate,
  751. AuditGMDate = grp_CreditCard.AuditGMDate,
  752. IsPay = grp_CreditCard.IsPay,
  753. PayPercentage = grp_CreditCard.PayPercentage,
  754. PayThenMoney = grp_CreditCard.PayThenMoney,
  755. PayPercentageOld = grp_CreditCard.PayPercentageOld,
  756. PayThenMoneyOld = grp_CreditCard.PayThenMoneyOld,
  757. UpdateDate = grp_CreditCard.UpdateDate,
  758. Payee = grp_CreditCard.Payee,
  759. RMBPrice = grp_CreditCard.RMBPrice,
  760. OrbitalPrivateTransfer = grp_CreditCard.OrbitalPrivateTransfer,
  761. ExceedBudget = grp_CreditCard.ExceedBudget,
  762. Remark = grp_CreditCard.Remark,
  763. }).ExecuteCommandAsync();
  764. if (CTable == 0)
  765. {
  766. RollbackTran();
  767. return result = new Result() { Code = -1, Msg = "修改失败!" };
  768. }
  769. else
  770. {
  771. Grp_CreditCardPayment ccp = Query<Grp_CreditCardPayment>(a => a.Id == dto.CardPaymentOpData.Id).First();
  772. var data = new { ccpId = ccp.Id, sign = 2, dataId = grp_CreditCard.CId };
  773. result = new Result() { Code = 0, Msg = "修改成功!", Data = data };
  774. }
  775. }
  776. else
  777. {
  778. result = new Result() { Code = -1, Msg = "修改失败!" };
  779. RollbackTran();
  780. }
  781. }
  782. CommitTran();
  783. }
  784. catch (Exception ex)
  785. {
  786. RollbackTran();
  787. return result = new Result() { Code = -2, Msg = "程序错误" };
  788. throw;
  789. }
  790. return result;
  791. }
  792. /// <summary>
  793. /// 导出机票费用报表
  794. /// </summary>
  795. /// <param name="dto"></param>
  796. /// <returns></returns>
  797. /// <exception cref="NotImplementedException"></exception>
  798. public async Task<Result> DeriveAirTicketRes(AirTicketResDto dto)
  799. {
  800. var result = new Result() { Code = -2, Msg = "未知错误" };
  801. try
  802. {
  803. string sql = string.Format(@"Select atr.*,ccp.Payee,ccp.BankNo, sd4.Name as PayType ,ccp.IsAuditGM,sd1.Name As 'CTypeName',sd2.Name As 'PreCurrencyStr',sd3.Name As CurrencyStr
  804. From Grp_AirTicketReservations atr
  805. Left Join Grp_CreditCardPayment ccp On atr.Id = ccp.CId And atr.DIId = ccp.DIId And ccp.IsDel = 0
  806. Left Join Sys_SetData sd1 On sd1.Id = atr.ctype
  807. Left Join Sys_SetData sd2 On sd2.Id = atr.PreCurrency
  808. Left Join Sys_SetData sd3 On sd3.Id = atr.Currency
  809. left join Sys_SetData sd4 On sd4.Id = ccp.PayDId
  810. Where atr.IsDel = 0 And atr.DIId={0}
  811. Order By atr.FlightsDate Asc", dto.DiId);
  812. List<AirTicketReservationsPayView> _AirTicketReservations = _sqlSugar.SqlQueryable<AirTicketReservationsPayView>(sql).ToList();
  813. if (_AirTicketReservations.Count != 0)
  814. {
  815. Grp_DelegationInfo grp_Delegation = _sqlSugar.Queryable<Grp_DelegationInfo>().First(a => a.Id == dto.DiId && a.IsDel == 0);
  816. Sys_Users _Users = _sqlSugar.Queryable<Sys_Users>().First(a => a.Id == dto.UserId && a.IsDel == 0);
  817. return result = new Result() { Code = 0, Msg = "成功", Data = new { Delegation = grp_Delegation, AirTicketRes = _AirTicketReservations, Users = _Users } };
  818. }
  819. else
  820. {
  821. return result = new Result() { Code = -1, Msg = "暂无数据", Data = null };
  822. }
  823. }
  824. catch (Exception)
  825. {
  826. return result = new Result() { Code = -2, Msg = "未知错误" };
  827. }
  828. }
  829. public async Task<Result> ItineraryAirTicketRes(ItineraryAirTicketResDto dto)
  830. {
  831. try
  832. {
  833. string sql = string.Format(@"select a.*,c.IsAuditGM,(select Name from Sys_SetData where Id=a.cType) as 'CTypeName',(select Name from
  834. Sys_SetData where Id=a.PreCurrency) as 'PreCurrencyStr',(select Name from Sys_SetData where Id=a.Currency)
  835. as 'CurrencyStr' from Grp_AirTicketReservations a,Grp_CreditCardPayment c where a.id=c.CId and a.isdel={1}
  836. and a.DIId={0} Order By a.CreateTime desc", dto.DiId, 0);
  837. List<AirTicketReservationsView> _AirTicketReservations = _sqlSugar.SqlQueryable<AirTicketReservationsView>(sql).ToList();
  838. if (_AirTicketReservations.Count == 0)
  839. {
  840. return new Result() { Code = -1, Msg = "暂无数据", Data = null };
  841. }
  842. else
  843. {
  844. return new Result() { Code = 0, Msg = "查询成功", Data = _AirTicketReservations };
  845. }
  846. }
  847. catch (Exception)
  848. {
  849. return new Result() { Code = -2, Msg = "未知错误" };
  850. }
  851. }
  852. public async Task<List<TranslateResult>> ReTransBatch(List<string> list, string aimlanguage)
  853. {
  854. var reultStr = new List<TranslateResult>();
  855. if (list.Count < 0)
  856. {
  857. return reultStr;
  858. }
  859. //待翻译内容,必须是UTF-8编码
  860. string q = "";
  861. string Qtext = "";
  862. foreach (var item in list)
  863. {
  864. q += item;
  865. Qtext += "q=" + item + "&";
  866. }
  867. if (Qtext.Length > 0)
  868. {
  869. Qtext = Qtext[..^1];
  870. }
  871. var dic = new Dictionary<string, string>();
  872. string url = "https://openapi.youdao.com/v2/api";
  873. //应用ID
  874. string appKey = "0fe3bc01e109ed36";
  875. //应用应用密钥
  876. string appSecret = "1f2x9TrqJfSBEJ8iH9GEFGgTyaYGjEry";
  877. //UUID
  878. string salt = DateTime.Now.Millisecond.ToString();
  879. //源语言
  880. dic.Add("from", "zh-CHS");
  881. //目标语言
  882. dic.Add("to", aimlanguage);
  883. //签名类型
  884. dic.Add("signType", "v3");
  885. //时间戳
  886. string curtime = ((GetBeijingTime().ToUniversalTime().Ticks - 621355968000000000) / 10000000).ToString();
  887. dic.Add("curtime", curtime);
  888. string signStr = appKey + Truncate(q) + salt + curtime + appSecret; ;
  889. string sign = ComputeHash(signStr, SHA256.Create());
  890. dic.Add("q", Qtext);
  891. dic.Add("appKey", appKey);
  892. dic.Add("salt", salt);
  893. dic.Add("sign", sign);
  894. try
  895. {
  896. //Thread.Sleep(500);
  897. string jsonStr = await TransSync(url, dic);
  898. JObject trans = (JObject)JsonConvert.DeserializeObject(jsonStr);
  899. string errorCode = trans["errorCode"].ToString();
  900. if (errorCode == "0")
  901. {
  902. reultStr = JsonConvert.DeserializeObject<List<TranslateResult>>(trans["translateResults"].ToString());
  903. }
  904. return reultStr;
  905. }
  906. catch (Exception)
  907. {
  908. return reultStr;
  909. }
  910. }
  911. public string Processing(string str)//处理这段英文的方法
  912. {
  913. if (string.IsNullOrEmpty(str)) { return ""; }
  914. string[] strArray;
  915. if (str.Contains(" ")) strArray = str.Split(" ".ToCharArray());
  916. else if (str.Contains(",")) strArray = str.Split(",".ToCharArray());
  917. else if (str.Contains(" ") && str.Contains(",")) strArray = str.Split(",".ToCharArray());
  918. else strArray = new string[] { str };
  919. string result = string.Empty;//定义一个空字符串
  920. foreach (string s in strArray)//循环处理数组里面每一个字符串
  921. {
  922. //result += System.Threading.Thread.CurrentThread.CurrentCulture.TextInfo.ToTitleCase(s) + " ";
  923. result += string.Concat(s[..1].ToUpper(), s.AsSpan(1), " ");
  924. //.Substring(0, 1).ToUpper()把循环到的字符串第一个字母截取并转换为大写,并用s.Substring(1)得到循环到的字符串除第一个字符后的所有字符拼装到首字母后面。
  925. }
  926. return result;
  927. }
  928. protected static async Task<string> TransSync(string url, Dictionary<string, string> dic)
  929. {
  930. string result = "";
  931. using (var client = new HttpClient())
  932. {
  933. var content = new FormUrlEncodedContent(dic);
  934. HttpResponseMessage response = await client.PostAsync(url, content);
  935. response.EnsureSuccessStatusCode();
  936. if (response.Content.Headers.ContentType.MediaType.ToLower().Equals("audio/mp3"))
  937. {
  938. await SaveBinaryFile(response, "合成的音频存储路径");
  939. }
  940. else
  941. {
  942. result = await response.Content.ReadAsStringAsync();
  943. }
  944. }
  945. return result;
  946. }
  947. private static async Task<bool> SaveBinaryFile(HttpResponseMessage response, string FileName)
  948. {
  949. string FilePath = FileName + DateTime.Now.Millisecond.ToString() + ".mp3";
  950. bool Value = true;
  951. byte[] buffer = new byte[1024];
  952. try
  953. {
  954. if (File.Exists(FilePath))
  955. File.Delete(FilePath);
  956. using Stream outStream = File.Create(FilePath);
  957. using Stream inStream = await response.Content.ReadAsStreamAsync();
  958. int l;
  959. do
  960. {
  961. l = await inStream.ReadAsync(buffer);
  962. if (l > 0)
  963. await outStream.WriteAsync(buffer.AsMemory(0, l));
  964. }
  965. while (l > 0);
  966. }
  967. catch
  968. {
  969. Value = false;
  970. }
  971. return Value;
  972. }
  973. protected static string ComputeHash(string input, HashAlgorithm algorithm)
  974. {
  975. byte[] inputBytes = Encoding.UTF8.GetBytes(input);
  976. byte[] hashedBytes = algorithm.ComputeHash(inputBytes);
  977. return BitConverter.ToString(hashedBytes).Replace("-", "");
  978. }
  979. protected static string Truncate(string q)
  980. {
  981. if (q == null)
  982. {
  983. return null;
  984. }
  985. int len = q.Length;
  986. return len <= 20 ? q : q.Substring(0, 10) + len + q.Substring(len - 10, 10);
  987. }
  988. public static DateTime GetBeijingTime()
  989. {
  990. string datetime = string.Empty;
  991. try
  992. {
  993. using (var client = new HttpClient())
  994. {
  995. client.Timeout = TimeSpan.FromSeconds(3);
  996. HttpResponseMessage response = client.GetAsync("https://www.baidu.com").Result;
  997. response.EnsureSuccessStatusCode();
  998. datetime = response.Headers.Date?.ToString() ?? DateTime.Now.ToString();
  999. }
  1000. return Convert.ToDateTime(datetime);
  1001. }
  1002. catch (Exception)
  1003. {
  1004. return DateTime.Now;
  1005. }
  1006. }
  1007. public class TranslateResult
  1008. {
  1009. public string Query { get; set; }
  1010. public string Translation { get; set; }
  1011. public string Type { get; set; }
  1012. public string VerifyResult { get; set; }
  1013. }
  1014. #endregion
  1015. #region 2026版
  1016. /// <summary>
  1017. /// list 2026版
  1018. /// </summary>
  1019. /// <param name="dto">查询参数</param>
  1020. /// <returns>机票费用列表</returns>
  1021. public async Task<JsonView> ListAsync(AirTicketFeeListDto dto)
  1022. {
  1023. // 1. 参数校验
  1024. if (!SharingStaticData.PortTypes.Contains(dto.PortType))
  1025. return JsonView.Fail(MsgTips.Port);
  1026. if (dto.DiId <= 0)
  1027. return JsonView.Fail("团组ID无效");
  1028. // 2. 获取团组信息
  1029. var groupInfo = await _groupInfoRep.GetGroupAirInfo(dto.DiId);
  1030. if (groupInfo == null)
  1031. return JsonView.Fail("暂无团组数据!");
  1032. // 3. 查询机票费用列表
  1033. var airTicketFeeList = await _sqlSugar.Queryable<Grp_AirTicketReservations>()
  1034. .InnerJoin<Grp_CreditCardPayment>((x, y) => x.Id == y.CId && x.DIId == y.DIId)
  1035. .LeftJoin<Sys_SetData>((x, y, z) => x.CType == z.Id)
  1036. .LeftJoin<Sys_SetData>((x, y, z, z1) => x.Currency == z1.Id)
  1037. .LeftJoin<Sys_Users>((x, y, z, z1, u) => x.CreateUserId == u.Id)
  1038. .Where((x, y, z, z1, u) => x.IsDel == 0 && y.IsDel == 0 && x.DIId == dto.DiId)
  1039. .WhereIF(dto.IsPaySign != -1, (x, y, z, z1, u) => y.IsPay == dto.IsPaySign)
  1040. .Select((x, y, z, z1, u) => new AirTicketFeeListView()
  1041. {
  1042. Id = x.Id,
  1043. CabinName = z.Name,
  1044. FlightDesc = x.FlightsDescription,
  1045. ClientNameList = x.ClientName,
  1046. ClientCount = x.ClientNum,
  1047. TotalTicketPrice = x.Price,
  1048. Currency = z1.Name,
  1049. AuditStatus = y.IsAuditGM.ToString(),
  1050. Remark = y.Remark,
  1051. Applicant = u.CnName,
  1052. ApplyTime = x.CreateTime.ToString("yyyy-MM-dd HH:mm:ss")
  1053. })
  1054. .ToListAsync();
  1055. // 4. 获取黑屏代码(三字码映射)
  1056. var threeCodes = await _sqlSugar.Queryable<Res_ThreeCode>()
  1057. .Where(x => x.IsDel == 0)
  1058. .ToDictionaryAsync(x => x.Three, x => x.AirPort);
  1059. // 5. 获取团组成本预算
  1060. var groupCostParameter = await _sqlSugar.Queryable<Grp_GroupCostParameter>()
  1061. .FirstAsync(a => a.DiId == dto.DiId && a.IsDel == 0 && a.CostType == "A" && a.IsShare == 1);
  1062. var airgroupCostParameter = _mapper.Map<AirGroupCostParameterView>(groupCostParameter);
  1063. // 6. 获取客户信息映射
  1064. var groupClientIds = await _sqlSugar.Queryable<Grp_TourClientList>()
  1065. .Where(a => a.DiId == dto.DiId && a.IsDel == 0)
  1066. .Select(x => x.ClientId)
  1067. .ToListAsync();
  1068. var clientInfoMap = new Dictionary<int, (string FirstName, string LastName, string Pinyin)>();
  1069. if (groupClientIds.Any())
  1070. {
  1071. var encryptedClients = await _sqlSugar.Queryable<Crm_DeleClient>()
  1072. .Where(a => a.IsDel == 0 && groupClientIds.Contains(a.Id))
  1073. .Select(x => new { x.Id, x.FirstName, x.LastName, x.Pinyin })
  1074. .ToListAsync();
  1075. foreach (var client in encryptedClients)
  1076. {
  1077. clientInfoMap[client.Id] = (
  1078. AesEncryptionHelper.Decrypt(client.FirstName),
  1079. AesEncryptionHelper.Decrypt(client.LastName),
  1080. AesEncryptionHelper.Decrypt(client.Pinyin)
  1081. );
  1082. }
  1083. }
  1084. // 7. 处理航班描述和客户名称
  1085. foreach (var item in airTicketFeeList)
  1086. {
  1087. // 7.1 处理航班描述
  1088. if (!string.IsNullOrWhiteSpace(item.FlightDesc))
  1089. {
  1090. var flightInfos = FlightParser.ParseFlights(item.FlightDesc);
  1091. var flightDescBuilder = new StringBuilder();
  1092. foreach (var flightInfo in flightInfos)
  1093. {
  1094. string departAirport = threeCodes.ContainsKey(flightInfo.DepartureAirport)
  1095. ? threeCodes[flightInfo.DepartureAirport]?.ToString() ?? flightInfo.DepartureAirport
  1096. : flightInfo.DepartureAirport;
  1097. string arrivalAirport = threeCodes.ContainsKey(flightInfo.ArrivalAirport)
  1098. ? threeCodes[flightInfo.ArrivalAirport]?.ToString() ?? flightInfo.ArrivalAirport
  1099. : flightInfo.ArrivalAirport;
  1100. string desc = $"{flightInfo.SequenceNo}.{departAirport}→{arrivalAirport}({flightInfo.DepartureDate})";
  1101. flightDescBuilder.AppendLine(desc);
  1102. }
  1103. item.FlightDesc = flightDescBuilder.ToString().TrimEnd();
  1104. }
  1105. // 7.2 处理客户名称
  1106. if (!string.IsNullOrWhiteSpace(item.ClientNameList))
  1107. {
  1108. var clientArr = item.ClientNameList.Split(',')
  1109. .Where(x => !string.IsNullOrWhiteSpace(x))
  1110. .ToArray();
  1111. var clientNames = new List<string>();
  1112. foreach (var clientItem in clientArr)
  1113. {
  1114. if (int.TryParse(clientItem, out int clientId))
  1115. {
  1116. if (clientId == -1)
  1117. {
  1118. clientNames.Add("行程单");
  1119. }
  1120. else if (clientInfoMap.TryGetValue(clientId, out var clientInfo))
  1121. {
  1122. clientNames.Add(clientInfo.Pinyin);
  1123. }
  1124. }
  1125. else
  1126. {
  1127. clientNames.Add(clientItem);
  1128. }
  1129. }
  1130. item.ClientNameList = clientNames.Any() ? string.Join(",", clientNames) : string.Empty;
  1131. }
  1132. }
  1133. // 8. 根据端口类型返回数据
  1134. if (dto.PortType == 1)
  1135. {
  1136. var data = new
  1137. {
  1138. DelegationInfo = groupInfo,
  1139. AirTicketReservations = airTicketFeeList,
  1140. AirGroupCostParameter = airgroupCostParameter
  1141. };
  1142. return JsonView.Success(data);
  1143. }
  1144. else if (dto.PortType == 2 || dto.PortType == 3)
  1145. {
  1146. int totalCount = airTicketFeeList.Count;
  1147. int totalPages = (int)Math.Ceiling((double)totalCount / dto.PageSize);
  1148. if (totalPages == 0) totalPages = 1;
  1149. // 分页数据
  1150. var pagedData = airTicketFeeList
  1151. .Skip((dto.PageIndex - 1) * dto.PageSize)
  1152. .Take(dto.PageSize)
  1153. .ToList();
  1154. var rst = new ListViewBase<AirTicketFeeListView>
  1155. {
  1156. DataList = pagedData,
  1157. DataCount = totalCount,
  1158. CurrPageIndex = dto.PageIndex,
  1159. CurrPageSize = dto.PageSize
  1160. };
  1161. var data = new
  1162. {
  1163. AirData = rst,
  1164. AirGroupCostParameter = airgroupCostParameter
  1165. };
  1166. return JsonView.Success(data);
  1167. }
  1168. return JsonView.Fail("暂无团组数据!");
  1169. }
  1170. /// <summary>
  1171. /// 机票费用基础数据 2026版
  1172. /// </summary>
  1173. /// <returns></returns>
  1174. public async Task<JsonView> BasicDataAsync(int userId)
  1175. {
  1176. var setDatas = _sqlSugar.Queryable<Sys_SetData>().Where(a => a.IsDel == 0).ToList();
  1177. // 附加服务类型
  1178. var additionalServiceTypes = setDatas
  1179. .Where(a => a.STid == 139 && a.IsDel == 0)
  1180. .Select(a => _mapper.Map<SetDataInfoView>(a))
  1181. .OrderBy(x => x.RemarkSort)
  1182. .ToList();
  1183. // 舱位类型
  1184. var ticketClass = setDatas
  1185. .Where(a => a.STid == 44 && a.IsDel == 0)
  1186. .Select(a => _mapper.Map<SetDataInfoView>(a))
  1187. .ToList();
  1188. // 支付方式
  1189. var payments = setDatas
  1190. .Where(a => a.STid == 14 && a.IsDel == 0)
  1191. .Select(a => _mapper.Map<SetDataInfoView>(a))
  1192. .ToList();
  1193. // 卡类型
  1194. var cardTypes = setDatas
  1195. .Where(a => a.STid == 15 && a.IsDel == 0)
  1196. .Select(a => _mapper.Map<SetDataInfoView>(a))
  1197. .ToList();
  1198. // 合作方资料
  1199. var airTicketAgents = _sqlSugar.Queryable<Res_AirTicketAgent>().Where(a => a.IsDel == 0).ToList();
  1200. foreach (var item in airTicketAgents)
  1201. {
  1202. EncryptionProcessor.DecryptProperties(item);
  1203. }
  1204. var airTicketAgentsView = airTicketAgents.Select(x => new
  1205. {
  1206. x.Id,
  1207. x.Name,
  1208. x.Account,
  1209. x.Bank
  1210. }).ToList();
  1211. #region 团组下拉框
  1212. var permGroupIds = Query<Grp_GroupsTaskAssignment>(a => a.IsDel == 0 && a.UId == userId && a.CTId == 85).Select(a => a.DIId).ToList();
  1213. var teamNames = _sqlSugar.Queryable<Grp_DelegationInfo>()
  1214. .Where(x => x.IsDel == 0 && permGroupIds.Contains(x.Id))
  1215. .OrderByDescending(x => x.VisitDate)
  1216. .Select(x => new
  1217. {
  1218. x.Id,
  1219. x.TeamName
  1220. })
  1221. .ToList();
  1222. #endregion
  1223. // 获取第一个团组的基本信息
  1224. var firstGroupInfo = await _groupInfoRep.GetGroupAirInfo(teamNames.FirstOrDefault()?.Id ?? 0);
  1225. return JsonView.Success(new
  1226. {
  1227. additionalServiceTypes,
  1228. ticketClass,
  1229. payment = payments,
  1230. cardType = cardTypes,
  1231. airTicketAgents = airTicketAgentsView,
  1232. firstGroupInfo,
  1233. groupName = teamNames
  1234. });
  1235. }
  1236. /// <summary>
  1237. /// 详情 2026版
  1238. /// </summary>
  1239. /// <returns></returns>
  1240. public async Task<JsonView> InfoAsync(int userId, int groupId)
  1241. {
  1242. var view = new AirTicketFeeInfoView()
  1243. {
  1244. CurrUserId = userId,
  1245. GroupAirInfo = new GroupAirTicketInfo(),
  1246. AirTicketFeeInfos = new List<AirTicketFeeInfo>()
  1247. };
  1248. if (userId < 1) return JsonView.Fail<AirTicketFeeInfoView>("用户ID无效");
  1249. if (groupId < 1) return JsonView.Fail<AirTicketFeeInfoView>("团组ID无效");
  1250. var groupVaild = Query<Grp_GroupsTaskAssignment>(a => a.IsDel == 0 && a.UId == userId && a.CTId == 85 && a.DIId == groupId).Any();
  1251. if (!groupVaild) return JsonView.Fail<AirTicketFeeInfoView>("没有查看权限");
  1252. // 获取第一个团组的基本信息
  1253. var firstGroupInfo = await _groupInfoRep.GetGroupAirInfo(groupId);
  1254. if (firstGroupInfo == null)
  1255. return JsonView.Fail<AirTicketFeeInfoView>("团组信息不存在");
  1256. // 团组公共信息
  1257. var groupInfo = _mapper.Map<GroupAirTicketInfo>(firstGroupInfo);
  1258. // 机票信息集合
  1259. var airTicketFeeInfos = await _sqlSugar.Queryable<Grp_AirTicketReservations>()
  1260. .InnerJoin<Grp_CreditCardPayment>((x, y) => x.Id == y.CId && x.DIId == y.DIId && y.CTable == 85)
  1261. .Where((x, y) => x.IsDel == 0 && y.IsDel == 0 && x.DIId == groupId && x.RecordType == 0)
  1262. .Select((x, y) => new AirTicketFeeInfo
  1263. {
  1264. // 机票信息
  1265. Id = x.Id,
  1266. FlightsDescription = x.FlightsDescription,
  1267. AirTicketBasicInfos = x.AirTicketBasicInfos,
  1268. ClientName = x.ClientName,
  1269. CustTicketInfos = x.CustTicketInfos,
  1270. PriceDescription = x.PriceDescription,
  1271. // 支付信息
  1272. PayDId = y.PayDId,
  1273. ConsumptionPatterns = y.ConsumptionPatterns,
  1274. ConsumptionDate = y.ConsumptionDate,
  1275. PayMoney = y.PayMoney,
  1276. PaymentCurrency = y.PaymentCurrency,
  1277. CTDId = y.CTDId,
  1278. BankNo = y.BankNo,
  1279. CardholderName = y.CardholderName,
  1280. DayRate = y.DayRate,
  1281. CompanyBankNo = y.CompanyBankNo,
  1282. OtherSideNo = y.OtherSideNo,
  1283. OtherSideName = y.OtherSideName,
  1284. Payee = y.Payee,
  1285. OrbitalPrivateTransfer = y.OrbitalPrivateTransfer,
  1286. Remark = y.Remark,
  1287. IsAuditGM = y.IsAuditGM,
  1288. AuditGMOperate = y.AuditGMOperate,
  1289. AuditGMDate = y.AuditGMDate
  1290. })
  1291. .ToListAsync();
  1292. // 如果没有数据,返回空结果
  1293. if (!airTicketFeeInfos.Any())
  1294. {
  1295. groupInfo.FlightsDescription = string.Empty;
  1296. return JsonView.Success(new AirTicketFeeInfoView()
  1297. {
  1298. CurrUserId = userId,
  1299. GroupAirInfo = groupInfo,
  1300. AirTicketFeeInfos = new List<AirTicketFeeInfo>()
  1301. });
  1302. }
  1303. // 航班舱位类型
  1304. var cabinTypes = await _sqlSugar.Queryable<Sys_SetData>().Where(x => x.IsDel == 0 && x.STid == 44).ToListAsync();
  1305. // 分组统计一个航班行程的信息
  1306. var groupedByFlights = airTicketFeeInfos
  1307. .GroupBy(x => x.FlightsDescription)
  1308. .Select(g =>
  1309. {
  1310. var first = g.First();
  1311. // 合并航班基础信息(去重)
  1312. var airTicketBasicInfos = g.SelectMany(x => x.AirTicketBasicInfos ?? new List<AirTicketBasicInfo>()).Distinct().ToList();
  1313. // 合并客户名称(去重)
  1314. var clientNames = string.Join(",", g.Select(x => x.ClientName).ToList());
  1315. var clientNameIds = ParseToIntListSafe(clientNames);
  1316. // 处理审核状态
  1317. var auditsStr = new StringBuilder();
  1318. foreach (var item in g)
  1319. {
  1320. var auditStatus = item.IsAuditGM switch
  1321. {
  1322. 0 => "未审核",
  1323. 1 => "审核通过",
  1324. 2 => "审核驳回",
  1325. 3 => "自动审核",
  1326. _ => "未知状态"
  1327. };
  1328. var cabinTypeName = cabinTypes.FirstOrDefault(c => c.Id == item.CustTicketInfos.FirstOrDefault()?.CType)?.Name ?? "未知舱位";
  1329. auditsStr.Append($"{cabinTypeName}:{auditStatus};");
  1330. }
  1331. // 处理多舱位审核描述
  1332. var newFlight = new AirTicketFeeInfo
  1333. {
  1334. Id = first.Id,
  1335. FlightsDescription = g.Key,
  1336. // 合并航班基础信息(去重)
  1337. AirTicketBasicInfos = airTicketBasicInfos,
  1338. // 合并客户人员
  1339. ClientName = clientNames,
  1340. ClientNameIds = clientNameIds,
  1341. // 合并所有客户的机票信息
  1342. CustTicketInfos = g.SelectMany(x => x.CustTicketInfos ?? new List<CustTicketInfo>()).ToList(),
  1343. PriceDescription = first.PriceDescription,
  1344. // 付款信息
  1345. PayDId = first.PayDId,
  1346. ConsumptionPatterns = first.ConsumptionPatterns,
  1347. ConsumptionDate = first.ConsumptionDate,
  1348. PayMoney = g.Sum(x => x.PayMoney),
  1349. PaymentCurrency = first.PaymentCurrency,
  1350. CTDId = first.CTDId,
  1351. BankNo = first.BankNo,
  1352. CardholderName = first.CardholderName,
  1353. DayRate = first.DayRate,
  1354. CompanyBankNo = first.CompanyBankNo,
  1355. OtherSideNo = first.OtherSideNo,
  1356. OtherSideName = first.OtherSideName,
  1357. Payee = first.Payee,
  1358. OrbitalPrivateTransfer = first.OrbitalPrivateTransfer,
  1359. Remark = first.Remark,
  1360. IsAuditGM = first.IsAuditGM,
  1361. AuditGMOperate = first.AuditGMOperate,
  1362. AuditGMDate = first.AuditGMDate,
  1363. AuditStr = auditsStr.ToString().Trim()
  1364. };
  1365. return newFlight;
  1366. })
  1367. .ToList();
  1368. // 按序号排序
  1369. groupedByFlights = groupedByFlights
  1370. .OrderBy(x => ExtractSequenceNo(x.FlightsDescription))
  1371. .ToList();
  1372. // 提取完整的航班行程信息
  1373. var flightsDescAll = new StringBuilder();
  1374. foreach (var item in groupedByFlights)
  1375. {
  1376. flightsDescAll.AppendLine(item.FlightsDescription);
  1377. // 添加测试数据
  1378. if (!item.AirTicketBasicInfos.Any())
  1379. {
  1380. item.AirTicketBasicInfos = FlightParser.ParseFlights(item.FlightsDescription)
  1381. .Select(x => new AirTicketBasicInfo()
  1382. {
  1383. No = x.SequenceNo,
  1384. FlightsCode = x.FlightNumber,
  1385. FlightsCity = $"{x.DepartureAirport}/{x.ArrivalAirport}",
  1386. FlightsDate = x.DepartureDate,
  1387. FlightsTime = x.DepartureTime,
  1388. ArrivedTime = x.ArrivalTime
  1389. })
  1390. .ToList();
  1391. }
  1392. // 添加测试费用数据(仅用于测试,生产环境应移除)
  1393. if (!item.CustTicketInfos.Any())
  1394. {
  1395. item.CustTicketInfos = GetTestCustomerData();
  1396. }
  1397. }
  1398. groupInfo.FlightsDescription = flightsDescAll.ToString();
  1399. return JsonView.Success(new AirTicketFeeInfoView()
  1400. {
  1401. CurrUserId = userId,
  1402. GroupAirInfo = groupInfo,
  1403. AirTicketFeeInfos = groupedByFlights
  1404. });
  1405. }
  1406. #region info 辅助方法
  1407. /// <summary>
  1408. /// 将逗号分隔的字符串解析为 List<int>(带错误处理)
  1409. /// </summary>
  1410. public static List<int> ParseToIntListSafe(string input)
  1411. {
  1412. if (string.IsNullOrWhiteSpace(input))
  1413. return new List<int>();
  1414. var result = new List<int>();
  1415. var parts = input.Split(',');
  1416. foreach (var part in parts)
  1417. {
  1418. if (int.TryParse(part.Trim(), out int value))
  1419. {
  1420. result.Add(value);
  1421. }
  1422. // 可选:记录解析失败的值
  1423. }
  1424. return result;
  1425. }
  1426. /// <summary>
  1427. /// 提取序号辅助方法
  1428. /// </summary>
  1429. private static int ExtractSequenceNo(string flightsDescription)
  1430. {
  1431. if (string.IsNullOrWhiteSpace(flightsDescription))
  1432. return int.MaxValue;
  1433. var match = Regex.Match(flightsDescription, @"^(\d+)\.");
  1434. return match.Success ? int.Parse(match.Groups[1].Value) : int.MaxValue;
  1435. }
  1436. /// <summary>
  1437. /// 获取测试数据
  1438. /// </summary>
  1439. private static List<CustTicketInfo> GetTestCustomerData()
  1440. {
  1441. var testData = new CustTicketInfo()
  1442. {
  1443. ClientId = 1081,
  1444. CType = 460,
  1445. ActualPrice = 1000,
  1446. TicketCode = "9991234567890",
  1447. TicketNumber = "ABC123",
  1448. SelectedServiceIds = new List<int> { 1561, 1563 },
  1449. AdditionalServices = new List<AdditionalService>()
  1450. {
  1451. new AdditionalService() { ServiceTypeId = 1561, Amount = 100 },
  1452. new AdditionalService() { ServiceTypeId = 1563, Amount = 50 }
  1453. },
  1454. TotalTicketPrice = 1150,
  1455. IsRefund = true,
  1456. RefundRecord = new RefundRecord()
  1457. {
  1458. RefundAmount = -200,
  1459. NonRefundableTax = -100,
  1460. RefundReason = "航班取消",
  1461. RefundTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  1462. RefundAccount = 0,
  1463. }
  1464. };
  1465. return new List<CustTicketInfo>
  1466. {
  1467. testData,
  1468. new CustTicketInfo
  1469. {
  1470. ClientId = 1720,
  1471. CType = 460,
  1472. ActualPrice = 1000,
  1473. TicketCode = "9991234567890",
  1474. TicketNumber = "ABC123"
  1475. },
  1476. new CustTicketInfo
  1477. {
  1478. ClientId = 163,
  1479. CType = 460,
  1480. ActualPrice = 1000,
  1481. TicketCode = "9991234567890",
  1482. TicketNumber = "ABC123"
  1483. }
  1484. };
  1485. }
  1486. #endregion
  1487. /// <summary>
  1488. /// 保存 2026版
  1489. /// </summary>
  1490. /// <returns></returns>
  1491. public async Task<JsonView<AppPushBodyView>> SaveAsync(AirTicketFeeSaveDto dto)
  1492. {
  1493. // 1. 基础字段设置
  1494. var currUserId = dto.CurrUserId;
  1495. var groupId = dto.GroupAirInfo?.Id ?? 0;
  1496. var successMsg = new StringBuilder();
  1497. var appPushBodyInfos = new List<AppPushBodyInfo>();
  1498. var index = 1;
  1499. // 2. 整理数据
  1500. var airFeeRecords = await OrganizeAirTicketDataAsync(dto.AirTicketFeeInfos, groupId);
  1501. if (airFeeRecords == null || !airFeeRecords.Any())
  1502. {
  1503. return JsonView<AppPushBodyView>.Success("没有需要保存的数据");
  1504. }
  1505. // 3. 开启事务
  1506. BeginTran();
  1507. try
  1508. {
  1509. foreach (var airInfo in airFeeRecords)
  1510. {
  1511. var airFeeInfo = _mapper.Map<Grp_AirTicketReservations>(airInfo);
  1512. var cardPaymentInfo = _mapper.Map<Grp_CreditCardPayment>(airInfo);
  1513. // 设置公共字段
  1514. airFeeInfo.CreateUserId = currUserId;
  1515. airFeeInfo.IsDel = 0;
  1516. cardPaymentInfo.CreateUserId = currUserId;
  1517. cardPaymentInfo.DIId = groupId;
  1518. cardPaymentInfo.CTable = 85;
  1519. cardPaymentInfo.UpdateDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  1520. cardPaymentInfo.IsPay = cardPaymentInfo.PayDId == 72 ? 1 : 0;
  1521. cardPaymentInfo.PayThenMoney = cardPaymentInfo.PayMoney;
  1522. cardPaymentInfo.RMBPrice = cardPaymentInfo.PayMoney * cardPaymentInfo.DayRate;
  1523. cardPaymentInfo.IsDel = 0;
  1524. // 判断是否存在(通过唯一键)
  1525. var existingAir = await _sqlSugar.Queryable<Grp_AirTicketReservations>()
  1526. .FirstAsync(x => x.DIId == groupId
  1527. && x.FlightsDescription == airFeeInfo.FlightsDescription
  1528. && x.CType == airFeeInfo.CType
  1529. && x.RecordType == airFeeInfo.RecordType
  1530. && x.IsDel == 0);
  1531. int airId = 0;
  1532. int cardId = 0;
  1533. if (existingAir == null)
  1534. {
  1535. // ========== 新增 ==========
  1536. var (Success, ErrorMessage, AirId, CardId) = await InsertNewRecord(airFeeInfo, cardPaymentInfo, index);
  1537. if (!Success)
  1538. {
  1539. RollbackTran();
  1540. return JsonView<AppPushBodyView>.Fail(ErrorMessage);
  1541. }
  1542. airId = AirId;
  1543. cardId = CardId;
  1544. appPushBodyInfos.Add(new AppPushBodyInfo()
  1545. {
  1546. OperationType = 1,
  1547. AirTicketId = airId,
  1548. CardId = cardId,
  1549. CardCNYAmount = cardPaymentInfo.RMBPrice
  1550. });
  1551. }
  1552. else
  1553. {
  1554. // ========== 修改 ==========
  1555. var result = await UpdateExistingRecord(airFeeInfo, cardPaymentInfo, existingAir, groupId, index);
  1556. if (!result.Success)
  1557. {
  1558. if (result.IsSkip)
  1559. {
  1560. successMsg.AppendLine(result.ErrorMessage);
  1561. index++;
  1562. continue;
  1563. }
  1564. RollbackTran();
  1565. return JsonView<AppPushBodyView>.Fail(result.ErrorMessage);
  1566. }
  1567. airId = result.AirId;
  1568. cardId = result.CardId;
  1569. appPushBodyInfos.Add(new AppPushBodyInfo()
  1570. {
  1571. OperationType = 2,
  1572. AirTicketId = airId,
  1573. CardId = cardId,
  1574. CardCNYAmount = cardPaymentInfo.RMBPrice
  1575. });
  1576. }
  1577. index++;
  1578. }
  1579. CommitTran();
  1580. var view = new AppPushBodyView()
  1581. {
  1582. GroupName = dto.GroupAirInfo.TeamName,
  1583. AppPushBodyInfos = appPushBodyInfos
  1584. };
  1585. if (successMsg.Length > 0) successMsg.Append("其他新增成功!");
  1586. else successMsg.Append("保存成功!");
  1587. return JsonView<AppPushBodyView>.Success(successMsg.ToString(), view);
  1588. }
  1589. catch (Exception ex)
  1590. {
  1591. RollbackTran();
  1592. return JsonView<AppPushBodyView>.Fail($"保存失败:{ex.Message}");
  1593. }
  1594. }
  1595. #region 保存 辅助方法
  1596. /// <summary>
  1597. /// 整理数据(按舱位类型分组,分离退票和正常记录)
  1598. /// </summary>
  1599. /// <param name="airTicketFeeInfos"></param>
  1600. /// <param name="groupId"></param>
  1601. /// <returns></returns>
  1602. private Task<List<AirTicketFeeInfo>> OrganizeAirTicketDataAsync(List<AirTicketFeeInfo> airTicketFeeInfos, int groupId)
  1603. {
  1604. var result = new List<AirTicketFeeInfo>();
  1605. foreach (var airInfo in airTicketFeeInfos)
  1606. {
  1607. if (airInfo.CustTicketInfos == null || !airInfo.CustTicketInfos.Any())
  1608. continue;
  1609. // 按舱位类型分组
  1610. var groupByCabinType = airInfo.CustTicketInfos
  1611. .GroupBy(x => x.CType)
  1612. .ToList();
  1613. foreach (var cabinGroup in groupByCabinType)
  1614. {
  1615. var customers = cabinGroup.ToList();
  1616. // 1. 正常记录(非退票客户)- 按舱位类型合并成一条数据
  1617. var normalCustomers = customers.Where(x => !x.IsRefund).ToList();
  1618. if (normalCustomers.Any())
  1619. {
  1620. var custRecord = _mapper.Map<AirTicketFeeOpInfo>(airInfo);
  1621. custRecord.ClientNum = normalCustomers.Count;
  1622. custRecord.ClientName = string.Join(",", normalCustomers.Select(x => x.ClientId));
  1623. custRecord.CustTicketInfos = normalCustomers;
  1624. custRecord.Price = normalCustomers.Sum(x => x.ActualPrice);
  1625. custRecord.Currency = airInfo.PaymentCurrency;
  1626. custRecord.PayMoney = normalCustomers.Sum(x => x.TotalTicketPrice);
  1627. custRecord.RecordType = 0; // 正常记录
  1628. result.Add(custRecord);
  1629. }
  1630. // 2. 退票记录 - 按舱位类型 + 退款卡类型 分组
  1631. var refundCustomers = customers.Where(x => x.IsRefund).ToList();
  1632. if (refundCustomers.Any())
  1633. {
  1634. // 按退款卡类型分组
  1635. var groupByRefundAccount = refundCustomers
  1636. .GroupBy(x => x.RefundRecord?.RefundAccount ?? 0)
  1637. .ToList();
  1638. foreach (var refundGroup in groupByRefundAccount)
  1639. {
  1640. var refundCustomersInGroup = refundGroup.ToList();
  1641. var refundAccount = refundGroup.Key;
  1642. var custRecord = _mapper.Map<AirTicketFeeOpInfo>(airInfo);
  1643. custRecord.RecordType = 1; // 退票记录
  1644. custRecord.OriginalReservationId = custRecord.Id; // 关联原始记录
  1645. custRecord.ClientNum = refundCustomersInGroup.Count;
  1646. custRecord.ClientName = string.Join(",", refundCustomersInGroup.Select(x => x.ClientId));
  1647. custRecord.CustTicketInfos = refundCustomersInGroup;
  1648. // 计算退款金额(负数)
  1649. decimal totalRefundAmount = refundCustomersInGroup.Sum(x =>
  1650. (x.RefundRecord?.RefundAmount ?? 0) + (x.RefundRecord?.NonRefundableTax ?? 0));
  1651. custRecord.Price = totalRefundAmount;
  1652. custRecord.Currency = airInfo.PaymentCurrency;
  1653. custRecord.PayMoney = totalRefundAmount;
  1654. custRecord.CTDId = refundAccount; // 退款账户
  1655. result.Add(custRecord);
  1656. }
  1657. }
  1658. }
  1659. }
  1660. return Task.FromResult(result);
  1661. }
  1662. /// <summary>
  1663. /// 新增记录
  1664. /// </summary>
  1665. /// <param name="airFeeInfo"></param>
  1666. /// <param name="cardPaymentInfo"></param>
  1667. /// <param name="index"></param>
  1668. /// <returns></returns>
  1669. private async Task<(bool Success, string ErrorMessage, int AirId, int CardId)> InsertNewRecord(
  1670. Grp_AirTicketReservations airFeeInfo,
  1671. Grp_CreditCardPayment cardPaymentInfo,
  1672. int index)
  1673. {
  1674. // 如果是退票记录,需要先获取关联的正常机票ID
  1675. if (airFeeInfo.RecordType == 1)
  1676. {
  1677. // 根据唯一键查找关联的正常机票记录
  1678. var normalAir = await _sqlSugar.Queryable<Grp_AirTicketReservations>()
  1679. .FirstAsync(x => x.DIId == airFeeInfo.DIId
  1680. && x.FlightsDescription == airFeeInfo.FlightsDescription
  1681. && x.CType == airFeeInfo.CType
  1682. && x.RecordType == 0
  1683. && x.IsDel == 0);
  1684. // 设置关联的正常机票ID
  1685. airFeeInfo.OriginalReservationId = normalAir?.Id ?? 0;
  1686. }
  1687. // 插入机票信息
  1688. var airIdLong = await _sqlSugar.Insertable(airFeeInfo).ExecuteReturnIdentityAsync();
  1689. var airId = (int)airIdLong;
  1690. if (airId < 1)
  1691. {
  1692. return (false, $"第{index}条,机票信息添加失败", 0, 0);
  1693. }
  1694. // 插入付款信息
  1695. cardPaymentInfo.CId = airId;
  1696. var cardIdLong = await _sqlSugar.Insertable(cardPaymentInfo).ExecuteReturnIdentityAsync();
  1697. var cardId = (int)cardIdLong;
  1698. if (cardId < 1)
  1699. {
  1700. return (false, $"第{index}条,机票付款信息添加失败", 0, 0);
  1701. }
  1702. return (true, string.Empty, airId, cardId);
  1703. }
  1704. /// <summary>
  1705. /// 更新记录
  1706. /// </summary>
  1707. /// <param name="airFeeInfo"></param>
  1708. /// <param name="cardPaymentInfo"></param>
  1709. /// <param name="existingAir"></param>
  1710. /// <param name="groupId"></param>
  1711. /// <param name="index"></param>
  1712. /// <returns></returns>
  1713. private async Task<(bool Success, bool IsSkip, string ErrorMessage, int AirId, int CardId)> UpdateExistingRecord(
  1714. Grp_AirTicketReservations airFeeInfo,
  1715. Grp_CreditCardPayment cardPaymentInfo,
  1716. Grp_AirTicketReservations existingAir,
  1717. int groupId,
  1718. int index)
  1719. {
  1720. var airId = existingAir.Id;
  1721. airFeeInfo.Id = airId;
  1722. // 如果是退票记录,需要关联正常机票ID
  1723. if (airFeeInfo.RecordType == 1)
  1724. {
  1725. // 如果还没有关联正常机票ID,或者需要更新关联
  1726. if (airFeeInfo.OriginalReservationId <= 0)
  1727. {
  1728. var normalAir1 = await _sqlSugar.Queryable<Grp_AirTicketReservations>()
  1729. .FirstAsync(x => x.DIId == groupId
  1730. && x.FlightsDescription == airFeeInfo.FlightsDescription
  1731. && x.CType == airFeeInfo.CType
  1732. && x.RecordType == 0
  1733. && x.IsDel == 0);
  1734. if (normalAir1 == null)
  1735. {
  1736. return (false, true, $"第{index}条,退票记录关联的正常机票不存在,请先添加正常机票", 0, 0);
  1737. }
  1738. airFeeInfo.OriginalReservationId = normalAir1.Id;
  1739. }
  1740. }
  1741. // 获取付款信息
  1742. var existingCard = await _sqlSugar.Queryable<Grp_CreditCardPayment>()
  1743. .FirstAsync(x => x.CId == airId && x.DIId == groupId && x.CTable == 85 && x.IsDel == 0);
  1744. // 审核验证
  1745. if (existingCard != null)
  1746. {
  1747. if (existingCard.IsAuditGM == 1 || existingCard.IsAuditGM == 3)
  1748. {
  1749. return (false, true, $"第{index}条,机票费用已审核,不可操作!", 0, 0);
  1750. }
  1751. if (existingCard.IsPay == 1)
  1752. {
  1753. return (false, true, $"第{index}条,机票费用已付款,不可操作!", 0, 0);
  1754. }
  1755. }
  1756. // 更新机票信息
  1757. var airUpdateCount = await _sqlSugar.Updateable(airFeeInfo)
  1758. .IgnoreColumns(ignoreAllNullColumns: true)
  1759. .Where(x => x.Id == airId)
  1760. .ExecuteCommandAsync();
  1761. if (airUpdateCount < 1)
  1762. {
  1763. return (false, false, $"第{index}条,机票信息保存失败", 0, 0);
  1764. }
  1765. int cardId = 0;
  1766. // 更新或新增付款信息
  1767. if (existingCard != null)
  1768. {
  1769. cardPaymentInfo.Id = existingCard.Id;
  1770. var cardUpdateCount = await _sqlSugar.Updateable(cardPaymentInfo)
  1771. .IgnoreColumns(ignoreAllNullColumns: true)
  1772. .Where(x => x.Id == existingCard.Id)
  1773. .ExecuteCommandAsync();
  1774. if (cardUpdateCount < 1)
  1775. {
  1776. return (false, false, $"第{index}条,机票费用信息保存失败", 0, 0);
  1777. }
  1778. cardId = existingCard.Id;
  1779. }
  1780. else
  1781. {
  1782. cardPaymentInfo.CId = airId;
  1783. var cardIdLong = await _sqlSugar.Insertable(cardPaymentInfo).ExecuteReturnIdentityAsync();
  1784. if (cardIdLong < 1)
  1785. {
  1786. return (false, false, $"第{index}条,机票费用信息保存失败", 0, 0);
  1787. }
  1788. cardId = (int)cardIdLong;
  1789. }
  1790. return (true, false, string.Empty, airId, cardId);
  1791. }
  1792. #endregion
  1793. /// <summary>
  1794. /// 按ID删除机票记录 2026版
  1795. /// 验证费用状态和退票记录
  1796. /// </summary>
  1797. /// <param name="userId">操作用户ID</param>
  1798. /// <param name="airTicketId">机票记录ID</param>
  1799. /// <returns></returns>
  1800. public async Task<JsonView> DeleteByIdAsync(int userId, int airTicketId)
  1801. {
  1802. BeginTran();
  1803. try
  1804. {
  1805. // 1. 查询机票记录
  1806. var airTicket = await _sqlSugar.Queryable<Grp_AirTicketReservations>()
  1807. .Where(x => x.Id == airTicketId && x.IsDel == 0)
  1808. .FirstAsync();
  1809. if (airTicket == null)
  1810. {
  1811. RollbackTran();
  1812. return JsonView.Fail("机票费用记录不存在或已被删除!");
  1813. }
  1814. // 2. 验证费用状态
  1815. var cardPayment = await _sqlSugar.Queryable<Grp_CreditCardPayment>()
  1816. .Where(x => x.CId == airTicketId && x.CTable == 85 && x.IsDel == 0)
  1817. .FirstAsync();
  1818. if (cardPayment != null)
  1819. {
  1820. if (cardPayment.IsAuditGM == 1)
  1821. {
  1822. RollbackTran();
  1823. return JsonView.Fail($"删除失败:当前费用已审核,不可删除!(记录ID:{airTicketId})");
  1824. }
  1825. if (cardPayment.IsAuditGM == 3)
  1826. {
  1827. RollbackTran();
  1828. return JsonView.Fail($"删除失败:当前费用已自动审核,不可删除!(记录ID:{airTicketId})");
  1829. }
  1830. if (cardPayment.IsPay == 1)
  1831. {
  1832. RollbackTran();
  1833. return JsonView.Fail($"删除失败:当前费用已付款,不可删除!(记录ID:{airTicketId})");
  1834. }
  1835. }
  1836. // 3. 验证退票记录关联
  1837. if (airTicket.RecordType == 0) // 正常记录
  1838. {
  1839. // 检查是否有退票记录关联
  1840. var refundRecords = await _sqlSugar.Queryable<Grp_AirTicketReservations>()
  1841. .Where(x => x.OriginalReservationId == airTicketId
  1842. && x.RecordType == 1
  1843. && x.IsDel == 0)
  1844. .ToListAsync();
  1845. if (refundRecords.Any())
  1846. {
  1847. var refundIds = string.Join(",", refundRecords.Select(x => x.Id));
  1848. var refundNames = string.Join(",", refundRecords.Select(x => x.ClientName));
  1849. RollbackTran();
  1850. return JsonView.Fail($"删除失败:该记录存在关联的退票记录!请先删除以下退票记录ID:[{refundIds}],关联人员:[{refundNames}]");
  1851. }
  1852. }
  1853. else if (airTicket.RecordType == 1) // 退票记录
  1854. {
  1855. // 检查关联的正常机票是否存在
  1856. if (airTicket.OriginalReservationId > 0)
  1857. {
  1858. var normalTicket = await _sqlSugar.Queryable<Grp_AirTicketReservations>()
  1859. .Where(x => x.Id == airTicket.OriginalReservationId && x.IsDel == 0)
  1860. .FirstAsync();
  1861. if (normalTicket == null)
  1862. {
  1863. RollbackTran();
  1864. return JsonView.Fail($"删除失败:退票记录关联的正常机票不存在或已被删除!(关联ID:{airTicket.OriginalReservationId})");
  1865. }
  1866. }
  1867. }
  1868. // 4. 执行软删除
  1869. // 4.1 软删除机票记录
  1870. airTicket.IsDel = 1;
  1871. airTicket.DeleteUserId = userId;
  1872. airTicket.DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  1873. var airUpdateCount = await _sqlSugar.Updateable(airTicket)
  1874. .UpdateColumns(x => new { x.IsDel, x.DeleteUserId, x.DeleteTime })
  1875. .Where(x => x.Id == airTicketId)
  1876. .ExecuteCommandAsync();
  1877. if (airUpdateCount < 1)
  1878. {
  1879. RollbackTran();
  1880. return JsonView.Fail("删除失败:机票记录删除失败!");
  1881. }
  1882. // 4.2 软删除对应的费用记录
  1883. if (cardPayment != null)
  1884. {
  1885. cardPayment.IsDel = 1;
  1886. cardPayment.DeleteUserId = userId;
  1887. cardPayment.DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  1888. var cardUpdateCount = await _sqlSugar.Updateable(cardPayment)
  1889. .UpdateColumns(x => new { x.IsDel, x.DeleteUserId, x.DeleteTime })
  1890. .Where(x => x.Id == cardPayment.Id)
  1891. .ExecuteCommandAsync();
  1892. if (cardUpdateCount < 1)
  1893. {
  1894. RollbackTran();
  1895. return JsonView.Fail("删除失败:费用记录删除失败!");
  1896. }
  1897. }
  1898. CommitTran();
  1899. var recordTypeName = airTicket.RecordType == 0 ? "正常记录" : "退票记录";
  1900. return JsonView.Success($"删除成功!已删除{recordTypeName},ID:{airTicketId}");
  1901. }
  1902. catch (Exception ex)
  1903. {
  1904. RollbackTran();
  1905. return JsonView.Fail($"删除失败:{ex.Message}");
  1906. }
  1907. }
  1908. #endregion
  1909. }