AirTicketResRepository.cs 92 KB

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