AirTicketResRepository.cs 86 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049
  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. /// 单条删除 2026版
  1795. /// </summary>
  1796. /// <param name="userId"></param>
  1797. /// <param name="id"></param>
  1798. /// <returns></returns>
  1799. public async Task<JsonView> SoftDelAsync(int userId, int id)
  1800. {
  1801. BeginTran();
  1802. try
  1803. {
  1804. var ar_res = await SoftDeleteByIdAsync<Grp_AirTicketReservations>(id.ToString(), userId);
  1805. if (!ar_res)
  1806. {
  1807. RollbackTran();
  1808. return JsonView.Fail("删除失败!");
  1809. }
  1810. var ccp_res = await _sqlSugar.Updateable<Grp_CreditCardPayment>()
  1811. .SetColumns(x => x.IsDel == 1)
  1812. .SetColumns(x => x.DeleteUserId == userId)
  1813. .SetColumns(x => x.DeleteTime == DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"))
  1814. .Where(a => a.CId == id && a.CTable == 85)
  1815. .ExecuteCommandAsync();
  1816. if (ccp_res < 1)
  1817. {
  1818. RollbackTran();
  1819. return JsonView.Fail("删除失败!");
  1820. }
  1821. CommitTran();
  1822. return JsonView.Success("删除成功!");
  1823. }
  1824. catch (Exception ex)
  1825. {
  1826. RollbackTran();
  1827. return JsonView.Fail("删除失败!Error:" + ex.Message);
  1828. }
  1829. }
  1830. #endregion
  1831. }