| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049 |
- using AutoMapper;
- using Newtonsoft.Json;
- using Newtonsoft.Json.Linq;
- using OASystem.Domain;
- using OASystem.Domain.AesEncryption;
- using OASystem.Domain.Dtos.Groups;
- using OASystem.Domain.Entities.Customer;
- using OASystem.Domain.Entities.Financial;
- using OASystem.Domain.Entities.Groups;
- using OASystem.Domain.Entities.Resource;
- using OASystem.Domain.ViewModels.Groups;
- using System.Security.Cryptography;
- namespace OASystem.Infrastructure.Repositories.Groups;
- public class AirTicketResRepository : BaseRepository<Grp_AirTicketReservations, Grp_AirTicketReservations>
- {
- private readonly IMapper _mapper;
- private readonly DelegationInfoRepository _groupInfoRep;
- private readonly TeamRateRepository _groupRateRep;
- public AirTicketResRepository(SqlSugarClient sqlSugar, DelegationInfoRepository groupInfoRep, TeamRateRepository groupRateRep, IMapper mapper) : base(sqlSugar)
- {
- _mapper = mapper;
- _groupInfoRep = groupInfoRep;
- _groupRateRep = groupRateRep;
- }
-
- #region 旧版
- public async Task<Result> AirTicketResById(AirTicketResByIdDto dto)
- {
- var result = new Result() { Code = -2, Msg = "未知错误" };
- try
- {
- Grp_AirTicketReservations grp_AirTicket = _sqlSugar.Queryable<Grp_AirTicketReservations>().First(a => a.Id == dto.Id && a.IsDel == 0);
- if (grp_AirTicket == null)
- {
- return result = new Result() { Code = -1, Msg = "暂无数据" };
- }
- else
- {
- Grp_CreditCardPayment grp_CreditCard = _sqlSugar.Queryable<Grp_CreditCardPayment>().First(a => a.CId == grp_AirTicket.Id && a.IsDel == 0 && a.CTable == 85);
- if (grp_CreditCard == null) { return result = new Result() { Code = -1, Msg = "暂无数据" }; }
- return result = new Result()
- {
- Code = 0,
- Msg = "查询成功!",
- Data = new
- {
- AirTicket = grp_AirTicket,
- CreditCard = grp_CreditCard,
- }
- };
- }
- }
- catch (Exception)
- {
- return result = new Result() { Code = -2, Msg = "未知错误" };
- }
- }
- public async Task<Result> AirTicketResList(AirTicketResDto dto)
- {
- var result = new Result() { Code = -2, Msg = "未知错误" };
- Grp_DelegationInfo _DelegationInfo = _sqlSugar.Queryable<Grp_DelegationInfo>().First(it => it.Id == dto.DiId);
- if (_DelegationInfo != null)
- {
- string UserId = "";
- List<Grp_GroupsTaskAssignment> gtaUIdList = _sqlSugar.Queryable<Grp_GroupsTaskAssignment>().Where(a => a.DIId == dto.DiId && a.IsDel == 0 && a.CTId == 85).ToList();
- foreach (Grp_GroupsTaskAssignment gta in gtaUIdList)
- UserId += gta.UId + ",";
- if (!string.IsNullOrWhiteSpace(UserId))
- {
- UserId = UserId[..^1];
- }
- else
- {
- UserId = "0";
- }
- string sqlWhere = "";
- if (dto.IsPaySign != -1)
- {
- sqlWhere += string.Format(@" And ccp.IsPay = {0} ", dto.IsPaySign);
- }
- string sql = string.Format(@"Select atr.*,ccp.IsAuditGM,sd1.Name As CTypeName,sd2.Name As PreCurrencyStr,sd3.Name As CurrencyStr,ccp.IsPay
- From Grp_AirTicketReservations atr
- Left Join Grp_CreditCardPayment ccp On atr.Id = ccp.CId And atr.DIId = ccp.DIId And ccp.IsDel = 0
- Left Join Sys_SetData sd1 On sd1.Id = atr.ctype
- Left Join Sys_SetData sd2 On sd2.Id = atr.PreCurrency
- Left Join Sys_SetData sd3 On sd3.Id = atr.Currency
- Where atr.IsDel = 0 And atr.DIId={0} {1}
- Order By atr.FlightsDate Asc", dto.DiId, sqlWhere);
- List<AirTicketReservationsView> _AirTicketReservations = _sqlSugar.SqlQueryable<AirTicketReservationsView>(sql).ToList();
- foreach (var item in _AirTicketReservations)
- {
- if (item.FlightsDescription.Contains("\n"))
- {
- var spilitArr = Regex.Split(item.FlightsDescription, "\n");
- int rowindex = 1;
- foreach (var spilitItem in spilitArr)
- {
- try
- {
- var spDotandEmpty = spilitItem.Split('.')[1].Split(' ').Where(x => !string.IsNullOrEmpty(x)).ToList();
- var depCode = spDotandEmpty[3].Substring(0, 3);
- var arrCode = spDotandEmpty[3].Substring(3, 3);
- Res_ThreeCode depData = _sqlSugar.Queryable<Res_ThreeCode>().First(it => it.IsDel == 0 && it.Three == depCode);
- Res_ThreeCode arrData = _sqlSugar.Queryable<Res_ThreeCode>().First(it => it.IsDel == 0 && it.Three == arrCode);
- string day = spDotandEmpty[2].Substring(2, 2);//日
- string monthAbbreviations = spDotandEmpty[2].Substring(4, 3).ToUpper();//月份
- switch (monthAbbreviations)
- {
- case "JAN":
- monthAbbreviations = "1";
- break;
- case "FEB":
- monthAbbreviations = "2";
- break;
- case "MAR":
- monthAbbreviations = "3";
- break;
- case "APR":
- monthAbbreviations = "4";
- break;
- case "MAY":
- monthAbbreviations = "5";
- break;
- case "JUN":
- monthAbbreviations = "6";
- break;
- case "JUL":
- monthAbbreviations = "7";
- break;
- case "AUG":
- monthAbbreviations = "8";
- break;
- case "SEP":
- monthAbbreviations = "9";
- break;
- case "OCT":
- monthAbbreviations = "10";
- break;
- case "NOV":
- monthAbbreviations = "11";
- break;
- case "DEC":
- monthAbbreviations = "12";
- break;
- }
- string tate = $"{monthAbbreviations}月{day}日";
- item.FlightDescription += rowindex + ". " + depData.AirPort + " " + arrData.AirPort + " (" + tate + ")\r\n";
- }
- catch (Exception ex)
- {
- item.FlightDescription = "录入数据不规范!请检查";
- break;
- }
- rowindex++;
- }
- }
- else
- {
- try
- {
- var spDotandEmpty = item.FlightsDescription.Split('.')[1].Split(' ').Where(x => !string.IsNullOrEmpty(x)).ToList();
- var depCode = spDotandEmpty[3].Substring(0, 3);
- var arrCode = spDotandEmpty[3].Substring(3, 3);
- Res_ThreeCode depData = _sqlSugar.Queryable<Res_ThreeCode>().First(it => it.IsDel == 0 && it.Three == depCode);
- Res_ThreeCode arrData = _sqlSugar.Queryable<Res_ThreeCode>().First(it => it.IsDel == 0 && it.Three == arrCode);
- string day = spDotandEmpty[2].Substring(2, 2);//日
- string monthAbbreviations = spDotandEmpty[2].Substring(4, 3).ToUpper();//月份
- switch (monthAbbreviations)
- {
- case "JAN":
- monthAbbreviations = "1";
- break;
- case "FEB":
- monthAbbreviations = "2";
- break;
- case "MAR":
- monthAbbreviations = "3";
- break;
- case "APR":
- monthAbbreviations = "4";
- break;
- case "MAY":
- monthAbbreviations = "5";
- break;
- case "JUN":
- monthAbbreviations = "6";
- break;
- case "JUL":
- monthAbbreviations = "7";
- break;
- case "AUG":
- monthAbbreviations = "8";
- break;
- case "SEP":
- monthAbbreviations = "9";
- break;
- case "OCT":
- monthAbbreviations = "10";
- break;
- case "NOV":
- monthAbbreviations = "11";
- break;
- case "DEC":
- monthAbbreviations = "12";
- break;
- }
- string tate = $"{monthAbbreviations}月{day}日";
- item.FlightDescription += depData.AirPort + " " + arrData.AirPort + " (" + tate + ")\r\n";
- }
- catch (Exception)
- {
- item.FlightDescription = "录入数据不规范!请检查";
- }
- }
- }
- //团组成本预算表查询
- Grp_GroupCostParameter _GroupCostParameter = _sqlSugar.Queryable<Grp_GroupCostParameter>().First(a => a.DiId == dto.DiId && a.IsDel == 0 && a.CostType == "A" && a.IsShare == 1);
- AirGroupCostParameterView _AirgroupCostParameter = _mapper.Map<AirGroupCostParameterView>(_GroupCostParameter);
- for (int i = 0; i < _AirTicketReservations.Count; i++)
- {
- string[] ClientArr = _AirTicketReservations[i].ClientName.Split(',').Where(x => !string.IsNullOrWhiteSpace(x)).ToArray();
- foreach (var item in ClientArr)
- {
- bool isNumeric = int.TryParse(item, out _);
- if (isNumeric)
- {
- if (item == "-1")
- {
- _AirTicketReservations[i].ClientNameStr += "行程单,";
- }
- else
- {
- Crm_DeleClient DeleClient = _sqlSugar.Queryable<Crm_DeleClient>().Where(a => a.IsDel == 0 && a.Id == int.Parse(item)).First();
- EncryptionProcessor.DecryptProperties(DeleClient);
- _AirTicketReservations[i].ClientNameStr += DeleClient.Pinyin + ',';
- }
- }
- else
- {
- _AirTicketReservations[i].ClientNameStr += item;
- }
- }
- if (_AirTicketReservations[i].ClientNameStr is not null)
- {
- _AirTicketReservations[i].ClientNameStr = _AirTicketReservations[i].ClientNameStr.Substring(0, _AirTicketReservations[i].ClientNameStr.Length - 1);
- }
- }
- if (dto.PortType == 1)
- {
- var data = new
- {
- DelegationInfo = _DelegationInfo,
- AirTicketReservations = _AirTicketReservations,
- AirGroupCostParameter = _AirgroupCostParameter
- };
- return result = new Result() { Code = 0, Msg = "查询成功!", Data = data };
- }
- else if (dto.PortType == 2 || dto.PortType == 3)
- {
- int count = _AirTicketReservations.Count;
- float totalPage = (float)count / dto.PageSize;//总页数
- if (totalPage == 0) totalPage = 1;
- else totalPage = (int)Math.Ceiling((double)totalPage);
- var grp_AirTickets = new List<AirTicketReservationsView>();
- for (int i = 0; i < dto.PageSize; i++)
- {
- var RowIndex = i + (dto.PageIndex - 1) * dto.PageSize;
- if (RowIndex < _AirTicketReservations.Count)
- {
- grp_AirTickets.Add(_AirTicketReservations[RowIndex]);
- }
- else
- {
- break;
- }
- }
- var rst = new ListViewBase<AirTicketReservationsView>
- {
- DataList = grp_AirTickets,
- DataCount = count,
- CurrPageIndex = dto.PageIndex,
- CurrPageSize = dto.PageSize
- };
- var data = new
- {
- AirData = rst,
- AirGroupCostParameter = _AirgroupCostParameter
- };
- return new Result() { Code = 0, Msg = "查询成功!", Data = data };
- }
- else
- {
- return new Result() { Code = -1, Msg = "请传入PortType参数!1:Web,2:Android,3:IOS!" };
- }
- }
- else
- {
- return new Result() { Code = -1, Msg = "暂无团组数据!" };
- }
- }
- public async Task<Result> AirTicketResSelect(AirTicketResDto dto)
- {
- var result = new Result() { Code = -2, Msg = "未知错误" };
- try
- {
- if (dto.DiId < 1)
- {
- dto.DiId = -1;
- }
- #region 团组下拉框
- List<Grp_GroupsTaskAssignment> grp_GroupsTaskAssignment = Query<Grp_GroupsTaskAssignment>(a => a.IsDel == 0 && a.UId == dto.UserId && a.CTId == 85).ToList();
- var grp_NameView = new List<dynamic>();
- string DiId = "";
- foreach (var item in grp_GroupsTaskAssignment)
- {
- DiId += item.DIId + ",";
- }
- if (DiId.Length > 1)
- {
- DiId = DiId.Substring(0, DiId.Length - 1);
- string sql = string.Format(@"select * from Grp_DelegationInfo where Id in({0}) and IsDel={1} Order By VisitStartDate Desc", DiId, 0);
- List<Grp_DelegationInfo> grp_Delegations = _sqlSugar.SqlQueryable<Grp_DelegationInfo>(sql).ToList();
- if (grp_Delegations.Count == 0)
- {
- return result = new Result() { Code = -1, Msg = "查询失败!" };
- }
- foreach (var item in grp_Delegations)
- {
- var groupNameView = new
- {
- item.Id,
- item.TeamName
- };
- grp_NameView.Add(groupNameView);
- }
- }
- #endregion
- #region 其他下拉框查询
- //舱位类型
- List<Sys_SetData> TicketClass = _sqlSugar.Queryable<Sys_SetData>().Where(a => a.STid == 44 && a.IsDel == 0).ToList();
- List<SetDataInfoView> _TicketClassa = _mapper.Map<List<SetDataInfoView>>(TicketClass);
- //支付方式
- List<Sys_SetData> Payment = _sqlSugar.Queryable<Sys_SetData>().Where(a => a.STid == 14 && a.IsDel == 0).ToList();
- List<SetDataInfoView> _Payment = _mapper.Map<List<SetDataInfoView>>(Payment);
- //卡类型
- List<Sys_SetData> CardType = _sqlSugar.Queryable<Sys_SetData>().Where(a => a.STid == 15 && a.IsDel == 0).ToList();
- List<SetDataInfoView> _CardType = _mapper.Map<List<SetDataInfoView>>(CardType);
- //合作方资料
- List<Res_AirTicketAgent> _AirTicketAgents = _sqlSugar.Queryable<Res_AirTicketAgent>().Where(a => a.IsDel == 0).ToList();
- foreach (var item in _AirTicketAgents)
- {
- EncryptionProcessor.DecryptProperties(item);
- }
- #endregion
- #region 客人名单下拉框
- if (dto.DiId == -1)
- {
- var dele = _AirTicketAgents.FirstOrDefault();
- dto.DiId = dele != null ? dele.Id : dto.DiId;
- }
- 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);
- var clientArr = _sqlSugar.SqlQueryable<SimplClientInfo>(sqlClient).ToList();
- foreach (var item in clientArr) { EncryptionProcessor.DecryptProperties(item); }
- #endregion
- var data = new
- {
- TicketClass = _TicketClassa,
- Payment = _Payment,
- CardType = _CardType,
- GroupName = grp_NameView,
- AirTicketAgents = _AirTicketAgents,
- clientArr
- };
- return result = new Result() { Code = 0, Msg = "查询成功!", Data = data };
- }
- catch (Exception ex)
- {
- return result = new Result() { Code = -2, Msg = "程序错误" };
- }
- }
- public async Task<Result> OpAirTicketRes(AirTicketResOpDto dto, Func<int, int, int, Task<Result>> fn)
- {
- var result = new Result() { Code = -2, Msg = "未知错误" };
- try
- {
- BeginTran();
- int id = 0;
- var grp_AirTicket = _mapper.Map<Grp_AirTicketReservations>(dto.AirTicketResOpData);
- var clientName = string.Join(",", dto.AirTicketResOpData.ClientName);
- if (dto.Status == 1)
- {
- grp_AirTicket.FlightsDate = DateTime.Parse(grp_AirTicket.FlightsDate).ToString("yyyy-MM-dd");
- grp_AirTicket.ClientName = clientName;
- id = await AddAsyncReturnId(grp_AirTicket);
- if (id == 0)
- {
- result = new Result() { Code = -1, Msg = "添加失败!" };
- }
- else
- {
- result = new Result() { Code = 0, Msg = "添加成功!" };
- }
- // }
- if (result.Code == 0)
- {
- Grp_CreditCardPayment grp_CreditCard = _mapper.Map<Grp_CreditCardPayment>(dto.CardPaymentOpData);
- // 2025-04-07 第四次更改 PayDId == 72(刷卡) IsPay == 1
- if (grp_CreditCard.PayDId == 72) grp_CreditCard.IsPay = 1;
- else grp_CreditCard.IsPay = 0;
- //获取新汇率 int diId,int CId, int currencyId
- var rate = await fn(dto.AirTicketResOpData.DiId, 85, dto.AirTicketResOpData.Currency);
- if (rate.Code == 0)
- {
- var rateInfo = (rate.Data as CurrencyInfo);
- if (rateInfo is not null)
- {
- grp_CreditCard.DayRate = rateInfo.Rate;
- grp_CreditCard.RMBPrice = rateInfo.Rate * grp_CreditCard.PayMoney;
- }
- else
- {
- grp_CreditCard.DayRate = 1;
- grp_CreditCard.RMBPrice = grp_CreditCard.PayMoney;
- }
- }
- //换算
- #region 老汇率处理方式
- //Grp_TeamRate _TeamRate = _sqlSugar.Queryable<Grp_TeamRate>().First(a => a.DiId == grp_AirTicket.DIId && a.IsDel == 0 && a.CTable == 85);
- //if (_TeamRate != null)
- //{
- // if (grp_CreditCard.PaymentCurrency == 49)
- // {
- // grp_CreditCard.DayRate = _TeamRate.RateU;
- // grp_CreditCard.RMBPrice = grp_CreditCard.PayMoney * Convert.ToDecimal(_TeamRate.RateU);
- // //ccp.PayMoney = ccp.PayMoney * float.Parse(tr.RateU);
- // }
- // else if (grp_CreditCard.PaymentCurrency == 51)
- // {
- // grp_CreditCard.DayRate = _TeamRate.RateE;
- // grp_CreditCard.RMBPrice = grp_CreditCard.PayMoney * Convert.ToDecimal(_TeamRate.RateE);
- // //ccp.PayMoney = ccp.PayMoney * float.Parse(tr.RateE);
- // }
- // else
- // {
- // grp_CreditCard.DayRate = 1M;
- // grp_CreditCard.RMBPrice = grp_CreditCard.PayMoney;
- // }
- //}
- //else
- //{
- // grp_CreditCard.DayRate = 1M;
- // grp_CreditCard.RMBPrice = grp_CreditCard.PayMoney;
- //}
- #endregion
- //判断是否超出成本
- #region 自动审核(暂时屏蔽)
- //Grp_GroupCostParameter _GroupCostParameter = _sqlSugar.Queryable<Grp_GroupCostParameter>().First(a => a.DiId == grp_AirTicket.DIId && a.IsDel == 0);
- //if (grp_AirTicket.CType == 460)//经济舱
- //{
- // if (_GroupCostParameter != null)
- // {
- // if (Convert.ToDecimal(_GroupCostParameter.JJCCB) * Convert.ToDecimal(grp_AirTicket.ClientNum) > grp_CreditCard.RMBPrice)
- // {
- // grp_CreditCard.ExceedBudget = 0;// 超出预算比例 换算
- // grp_CreditCard.IsAuditGM = 3;//3 为自动审核
- // grp_CreditCard.AuditGMOperate = 0;
- // grp_CreditCard.AuditGMDate = "";
- // grp_CreditCard.IsPay = 0;
- // }
- // else
- // {
- // var a = grp_CreditCard.RMBPrice - Convert.ToDecimal(_GroupCostParameter.JJCCB);
- // var b = a / Convert.ToDecimal(_GroupCostParameter.JJCCB) * Convert.ToDecimal(grp_AirTicket.ClientNum);
- // grp_CreditCard.ExceedBudget = b;// 超出预算比例 换算
- // grp_CreditCard.IsAuditGM = 0;//3 为自动审核
- // grp_CreditCard.AuditGMOperate = 21;
- // grp_CreditCard.AuditGMDate = "";
- // grp_CreditCard.IsPay = 0;
- // }
- // }
- // else
- // {
- // grp_CreditCard.ExceedBudget = 0.00M;// 超出预算比例 换算
- // grp_CreditCard.IsAuditGM = 0;//3 为自动审核
- // grp_CreditCard.AuditGMOperate = 0;
- // grp_CreditCard.AuditGMDate = "";
- // grp_CreditCard.IsPay = 0;
- // }
- //}
- //else if (grp_AirTicket.CType == 458)
- //{
- // if (_GroupCostParameter != null)
- // {
- // if (Convert.ToDecimal(_GroupCostParameter.GWCB) * Convert.ToDecimal(grp_AirTicket.ClientNum) > grp_CreditCard.RMBPrice)
- // {
- // grp_CreditCard.ExceedBudget = 0;// 超出预算比例 换算
- // grp_CreditCard.IsAuditGM = 3;//3 为自动审核
- // grp_CreditCard.AuditGMOperate = 21;
- // grp_CreditCard.AuditGMDate = "";
- // grp_CreditCard.IsPay = 0;
- // }
- // else
- // {
- // var a = grp_CreditCard.RMBPrice - Convert.ToDecimal(_GroupCostParameter.GWCB);
- // var b = a / Convert.ToDecimal(_GroupCostParameter.GWCB) * Convert.ToDecimal(grp_AirTicket.ClientNum);
- // grp_CreditCard.ExceedBudget = b;// 超出预算比例 换算
- // grp_CreditCard.IsAuditGM = 0;//3 为自动审核
- // grp_CreditCard.AuditGMOperate = 21;
- // grp_CreditCard.AuditGMDate = "";
- // grp_CreditCard.IsPay = 0;
- // }
- // }
- // else
- // {
- // grp_CreditCard.ExceedBudget = 0.00M;// 超出预算比例 换算
- // grp_CreditCard.IsAuditGM = 0;//3 为自动审核
- // grp_CreditCard.AuditGMOperate = 21;
- // grp_CreditCard.AuditGMDate = "";
- // grp_CreditCard.IsPay = 0;
- // }
- //}
- //else
- //{
- // grp_CreditCard.ExceedBudget = 0.00M;// 超出预算比例 换算
- // grp_CreditCard.IsAuditGM = 0;//3 为自动审核
- // grp_CreditCard.AuditGMOperate = 0;
- // grp_CreditCard.AuditGMDate = "";
- // grp_CreditCard.IsPay = 0;
- //}
- #endregion
- grp_CreditCard.CId = id;
- grp_CreditCard.CTable = 85;
- grp_CreditCard.PayPercentage = 100;
- #region 查询上一次付款(注释)
- ////查询上一次付款信息
- //Grp_CreditCardPayment _CreditCardPayment = _sqlSugar.Queryable<Grp_CreditCardPayment>().OrderByDescending(x => x.CreateUserId).First(a => a.DIId == grp_AirTicket.DIId && a.IsDel == 0 && a.IsPay == 1);
- //if (_CreditCardPayment != null)
- //{
- // grp_CreditCard.PayPercentageOld = _CreditCardPayment.PayPercentageOld;// 上次付款百分比 查询并计算最近一次
- // grp_CreditCard.PayThenMoneyOld = _CreditCardPayment.PayMoney;// 上次付款金额 查询上一次
- // grp_CreditCard.UpdateDate = _CreditCardPayment.UpdateDate;// 上次付款时间 查询上一次
- //}
- //else
- //{
- // grp_CreditCard.PayPercentageOld = 0;// 上次付款百分比 查询并计算最近一次
- // grp_CreditCard.PayThenMoneyOld = 0;// 上次付款金额 查询上一次
- // grp_CreditCard.UpdateDate = "";// 上次付款时间 查询上一次
- //}
- #endregion
- id = await _sqlSugar.Insertable(grp_CreditCard).ExecuteReturnIdentityAsync();
- if (id == 0)
- {
- RollbackTran();
- return result = new Result() { Code = -1, Msg = "添加失败!" };
- }
- await UpdateAsync(a => a.Id == id, a => new Grp_AirTicketReservations
- {
- FlightsDescription = dto.AirTicketResOpData.FlightsDescription,
- });
- CommitTran();
- var data = new { ccpId = id, sign = 1, dataId = grp_CreditCard.CId };
- return result = new Result() { Code = 0, Msg = "添加成功!", Data = data };
- }
- else
- {
- RollbackTran();
- return result = new Result() { Code = -1, Msg = "添加失败!" };
- }
- }
- else if (dto.Status == 2)
- {
- id = dto.AirTicketResOpData.Id;
- bool res = await UpdateAsync(a => a.Id == dto.AirTicketResOpData.Id, a => new Grp_AirTicketReservations
- {
- CType = dto.AirTicketResOpData.CType,
- PrePrice = dto.AirTicketResOpData.PrePrice,
- PreCurrency = dto.AirTicketResOpData.PreCurrency,
- Price = dto.AirTicketResOpData.Price,
- Currency = dto.AirTicketResOpData.Currency,
- ClientNum = dto.AirTicketResOpData.ClientNum,
- ClientName = clientName,
- IsCheckIn = dto.AirTicketResOpData.IsCheckIn,
- IsSetSeat = dto.AirTicketResOpData.IsSetSeat,
- IsPackage = dto.AirTicketResOpData.IsPackage,
- IsBagHandle = dto.AirTicketResOpData.IsBagHandle,
- IsTrain = dto.AirTicketResOpData.IsTrain,
- FlightsCode = dto.AirTicketResOpData.FlightsCode,
- FlightsCity = dto.AirTicketResOpData.FlightsCity,
- FlightsDescription = dto.AirTicketResOpData.FlightsDescription,
- PriceDescription = dto.AirTicketResOpData.PriceDescription,
- TicketNumber = dto.AirTicketResOpData.TicketNumber,
- TicketCode = dto.AirTicketResOpData.TicketCode,
- Remark = dto.AirTicketResOpData.Remark,
- });
- if (!res) { result = new Result() { Code = -1, Msg = "修改失败!" }; }
- else { result = new Result() { Code = 0, Msg = "修改成功!" }; }
- if (result.Code == 0)
- {
- //C表操作
- Grp_CreditCardPayment grp_CreditCard = _mapper.Map<Grp_CreditCardPayment>(dto.CardPaymentOpData);
- //2025-04-07 第四次更改 PayDId == 72(刷卡) IsPay == 1
- if (grp_CreditCard.PayDId == 72) grp_CreditCard.IsPay = 1;
- else grp_CreditCard.IsPay = 0;
- //获取新汇率 int diId,int CId, int currencyId
- var rate = await fn(dto.AirTicketResOpData.DiId, 85, dto.AirTicketResOpData.Currency);
- if (rate.Code == 0)
- {
- var rateInfo = (rate.Data as CurrencyInfo);
- if (rateInfo is not null)
- {
- grp_CreditCard.DayRate = rateInfo.Rate;
- grp_CreditCard.RMBPrice = rateInfo.Rate * grp_CreditCard.PayMoney;
- }
- else
- {
- grp_CreditCard.DayRate = 1;
- grp_CreditCard.RMBPrice = grp_CreditCard.PayMoney;
- }
- }
- #region 老汇率修改(注释)
- //换算
- Grp_TeamRate _TeamRate = _sqlSugar.Queryable<Grp_TeamRate>().First(a => a.DiId == grp_AirTicket.DIId && a.IsDel == 0 && a.CTable == 85);
- //if (_TeamRate != null)
- //{
- // if (grp_CreditCard.PaymentCurrency == 49)
- // {
- // grp_CreditCard.DayRate = _TeamRate.RateU;
- // grp_CreditCard.RMBPrice = grp_CreditCard.PayMoney * Convert.ToDecimal(_TeamRate.RateU);
- // //ccp.PayMoney = ccp.PayMoney * float.Parse(tr.RateU);
- // }
- // else if (grp_CreditCard.PaymentCurrency == 51)
- // {
- // grp_CreditCard.DayRate = _TeamRate.RateE;
- // grp_CreditCard.RMBPrice = grp_CreditCard.PayMoney * Convert.ToDecimal(_TeamRate.RateE);
- // //ccp.PayMoney = ccp.PayMoney * float.Parse(tr.RateE);
- // }
- // else
- // {
- // grp_CreditCard.DayRate = 1M;
- // grp_CreditCard.RMBPrice = grp_CreditCard.PayMoney;
- // }
- //}
- //else
- //{
- // grp_CreditCard.DayRate = 1M;
- // grp_CreditCard.RMBPrice = grp_CreditCard.PayMoney;
- //}
- #endregion
- #region 自动审核(注释)
- //Grp_GroupCostParameter _GroupCostParameter = _sqlSugar.Queryable<Grp_GroupCostParameter>().First(a => a.DiId == grp_AirTicket.DIId && a.IsDel == 0);
- //if (grp_AirTicket.CType == 460)//经济舱
- //{
- // if (_GroupCostParameter != null)
- // {
- // if (Convert.ToDecimal(_GroupCostParameter.JJCCB) * Convert.ToDecimal(grp_AirTicket.ClientNum) > grp_CreditCard.RMBPrice)
- // {
- // grp_CreditCard.ExceedBudget = 0;// 超出预算比例 换算
- // grp_CreditCard.IsAuditGM = 3;//3 为自动审核
- // grp_CreditCard.AuditGMOperate = 0;
- // grp_CreditCard.AuditGMDate = "";
- // grp_CreditCard.IsPay = 1;
- // }
- // else
- // {
- // var a = grp_CreditCard.RMBPrice - Convert.ToDecimal(_GroupCostParameter.JJCCB);
- // var b = a / Convert.ToDecimal(_GroupCostParameter.JJCCB) * Convert.ToDecimal(grp_AirTicket.ClientNum);
- // grp_CreditCard.ExceedBudget = b;// 超出预算比例 换算
- // grp_CreditCard.IsAuditGM = 0;//3 为自动审核
- // grp_CreditCard.AuditGMOperate = 21;
- // grp_CreditCard.AuditGMDate = "";
- // grp_CreditCard.IsPay = 1;
- // }
- // }
- // else
- // {
- // grp_CreditCard.ExceedBudget = 0.00M;// 超出预算比例 换算
- // grp_CreditCard.IsAuditGM = 0;//3 为自动审核
- // grp_CreditCard.AuditGMOperate = 21;
- // grp_CreditCard.AuditGMDate = "";
- // grp_CreditCard.IsPay = 0;
- // }
- //}
- //else if (grp_AirTicket.CType == 458)
- //{
- // if (_GroupCostParameter != null)
- // {
- // if ((_GroupCostParameter != null ? _GroupCostParameter.GWCB : 0) * Convert.ToDecimal(grp_AirTicket.ClientNum) > grp_CreditCard.RMBPrice)
- // {
- // grp_CreditCard.ExceedBudget = 0;// 超出预算比例 换算
- // grp_CreditCard.IsAuditGM = 3;//3 为自动审核
- // grp_CreditCard.AuditGMOperate = 21;
- // grp_CreditCard.AuditGMDate = "";
- // grp_CreditCard.IsPay = 1;
- // }
- // else
- // {
- // var a = grp_CreditCard.RMBPrice - Convert.ToDecimal(_GroupCostParameter.GWCB);
- // var b = a / Convert.ToDecimal(_GroupCostParameter.GWCB) * Convert.ToDecimal(grp_AirTicket.ClientNum);
- // grp_CreditCard.ExceedBudget = b;// 超出预算比例 换算
- // grp_CreditCard.IsAuditGM = 0;//3 为自动审核
- // grp_CreditCard.AuditGMOperate = 21;
- // grp_CreditCard.AuditGMDate = "";
- // grp_CreditCard.IsPay = 1;
- // }
- // }
- // else
- // {
- // grp_CreditCard.ExceedBudget = 0.00M;// 超出预算比例 换算
- // grp_CreditCard.IsAuditGM = 0;//3 为自动审核
- // grp_CreditCard.AuditGMOperate = 21;
- // grp_CreditCard.AuditGMDate = "";
- // grp_CreditCard.IsPay = 0;
- // }
- //}
- #endregion
- grp_CreditCard.CId = id;
- grp_CreditCard.CTable = 85;
- grp_CreditCard.PayPercentage = 100;
- #region 查询上一次付款信息(注释)
- ////查询上一次付款信息
- //Grp_CreditCardPayment _CreditCardPayment = _sqlSugar.Queryable<Grp_CreditCardPayment>().OrderByDescending(x => x.CreateUserId).First(a => a.DIId == grp_AirTicket.DIId && a.IsDel == 0 && a.IsPay == 1);
- //if (_CreditCardPayment != null)
- //{
- // grp_CreditCard.PayPercentageOld = _CreditCardPayment.PayPercentageOld;// 上次付款百分比 查询并计算最近一次
- // grp_CreditCard.PayThenMoneyOld = _CreditCardPayment.PayMoney;// 上次付款金额 查询上一次
- // grp_CreditCard.UpdateDate = _CreditCardPayment.UpdateDate;// 上次付款时间 查询上一次
- //}
- //else
- //{
- // grp_CreditCard.PayPercentageOld = 0;// 上次付款百分比 查询并计算最近一次
- // grp_CreditCard.PayThenMoneyOld = 0;// 上次付款金额 查询上一次
- // grp_CreditCard.UpdateDate = "";// 上次付款时间 查询上一次
- //}
- #endregion
- int CTable = await _sqlSugar.Updateable<Grp_CreditCardPayment>().Where(a => a.Id == dto.CardPaymentOpData.Id).SetColumns(a => new Grp_CreditCardPayment
- {
- PayDId = grp_CreditCard.PayDId,
- ConsumptionPatterns = grp_CreditCard.ConsumptionPatterns,
- ConsumptionDate = grp_CreditCard.ConsumptionDate,
- CTDId = grp_CreditCard.CTDId,
- BankNo = grp_CreditCard.BankNo,
- CardholderName = grp_CreditCard.CardholderName,
- PayMoney = grp_CreditCard.PayMoney,
- PaymentCurrency = grp_CreditCard.PaymentCurrency,
- DayRate = grp_CreditCard.DayRate,
- CompanyBankNo = grp_CreditCard.CompanyBankNo,
- OtherBankName = grp_CreditCard.OtherBankName,
- OtherSideNo = grp_CreditCard.OtherSideNo,
- OtherSideName = grp_CreditCard.OtherSideName,
- IsAuditGM = grp_CreditCard.IsAuditGM,
- AuditGMOperate = grp_CreditCard.AuditGMOperate,
- AuditGMDate = grp_CreditCard.AuditGMDate,
- IsPay = grp_CreditCard.IsPay,
- PayPercentage = grp_CreditCard.PayPercentage,
- PayThenMoney = grp_CreditCard.PayThenMoney,
- PayPercentageOld = grp_CreditCard.PayPercentageOld,
- PayThenMoneyOld = grp_CreditCard.PayThenMoneyOld,
- UpdateDate = grp_CreditCard.UpdateDate,
- Payee = grp_CreditCard.Payee,
- RMBPrice = grp_CreditCard.RMBPrice,
- OrbitalPrivateTransfer = grp_CreditCard.OrbitalPrivateTransfer,
- ExceedBudget = grp_CreditCard.ExceedBudget,
- Remark = grp_CreditCard.Remark,
- }).ExecuteCommandAsync();
- if (CTable == 0)
- {
- RollbackTran();
- return result = new Result() { Code = -1, Msg = "修改失败!" };
- }
- else
- {
- Grp_CreditCardPayment ccp = Query<Grp_CreditCardPayment>(a => a.Id == dto.CardPaymentOpData.Id).First();
- var data = new { ccpId = ccp.Id, sign = 2, dataId = grp_CreditCard.CId };
- result = new Result() { Code = 0, Msg = "修改成功!", Data = data };
- }
- }
- else
- {
- result = new Result() { Code = -1, Msg = "修改失败!" };
- RollbackTran();
- }
- }
- CommitTran();
- }
- catch (Exception ex)
- {
- RollbackTran();
- return result = new Result() { Code = -2, Msg = "程序错误" };
- throw;
- }
- return result;
- }
- /// <summary>
- /// 导出机票费用报表
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- /// <exception cref="NotImplementedException"></exception>
- public async Task<Result> DeriveAirTicketRes(AirTicketResDto dto)
- {
- var result = new Result() { Code = -2, Msg = "未知错误" };
- try
- {
- 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
- From Grp_AirTicketReservations atr
- Left Join Grp_CreditCardPayment ccp On atr.Id = ccp.CId And atr.DIId = ccp.DIId And ccp.IsDel = 0
- Left Join Sys_SetData sd1 On sd1.Id = atr.ctype
- Left Join Sys_SetData sd2 On sd2.Id = atr.PreCurrency
- Left Join Sys_SetData sd3 On sd3.Id = atr.Currency
- left join Sys_SetData sd4 On sd4.Id = ccp.PayDId
- Where atr.IsDel = 0 And atr.DIId={0}
- Order By atr.FlightsDate Asc", dto.DiId);
- List<AirTicketReservationsPayView> _AirTicketReservations = _sqlSugar.SqlQueryable<AirTicketReservationsPayView>(sql).ToList();
- if (_AirTicketReservations.Count != 0)
- {
- Grp_DelegationInfo grp_Delegation = _sqlSugar.Queryable<Grp_DelegationInfo>().First(a => a.Id == dto.DiId && a.IsDel == 0);
- Sys_Users _Users = _sqlSugar.Queryable<Sys_Users>().First(a => a.Id == dto.UserId && a.IsDel == 0);
- return result = new Result() { Code = 0, Msg = "成功", Data = new { Delegation = grp_Delegation, AirTicketRes = _AirTicketReservations, Users = _Users } };
- }
- else
- {
- return result = new Result() { Code = -1, Msg = "暂无数据", Data = null };
- }
- }
- catch (Exception)
- {
- return result = new Result() { Code = -2, Msg = "未知错误" };
- }
- }
- public async Task<Result> ItineraryAirTicketRes(ItineraryAirTicketResDto dto)
- {
- try
- {
- string sql = string.Format(@"select a.*,c.IsAuditGM,(select Name from Sys_SetData where Id=a.cType) as 'CTypeName',(select Name from
- Sys_SetData where Id=a.PreCurrency) as 'PreCurrencyStr',(select Name from Sys_SetData where Id=a.Currency)
- as 'CurrencyStr' from Grp_AirTicketReservations a,Grp_CreditCardPayment c where a.id=c.CId and a.isdel={1}
- and a.DIId={0} Order By a.CreateTime desc", dto.DiId, 0);
- List<AirTicketReservationsView> _AirTicketReservations = _sqlSugar.SqlQueryable<AirTicketReservationsView>(sql).ToList();
- if (_AirTicketReservations.Count == 0)
- {
- return new Result() { Code = -1, Msg = "暂无数据", Data = null };
- }
- else
- {
- return new Result() { Code = 0, Msg = "查询成功", Data = _AirTicketReservations };
- }
- }
- catch (Exception)
- {
- return new Result() { Code = -2, Msg = "未知错误" };
- }
- }
- public async Task<List<TranslateResult>> ReTransBatch(List<string> list, string aimlanguage)
- {
- var reultStr = new List<TranslateResult>();
- if (list.Count < 0)
- {
- return reultStr;
- }
- //待翻译内容,必须是UTF-8编码
- string q = "";
- string Qtext = "";
- foreach (var item in list)
- {
- q += item;
- Qtext += "q=" + item + "&";
- }
- if (Qtext.Length > 0)
- {
- Qtext = Qtext[..^1];
- }
- var dic = new Dictionary<string, string>();
- string url = "https://openapi.youdao.com/v2/api";
- //应用ID
- string appKey = "0fe3bc01e109ed36";
- //应用应用密钥
- string appSecret = "1f2x9TrqJfSBEJ8iH9GEFGgTyaYGjEry";
- //UUID
- string salt = DateTime.Now.Millisecond.ToString();
- //源语言
- dic.Add("from", "zh-CHS");
- //目标语言
- dic.Add("to", aimlanguage);
- //签名类型
- dic.Add("signType", "v3");
- //时间戳
- string curtime = ((GetBeijingTime().ToUniversalTime().Ticks - 621355968000000000) / 10000000).ToString();
- dic.Add("curtime", curtime);
- string signStr = appKey + Truncate(q) + salt + curtime + appSecret; ;
- string sign = ComputeHash(signStr, SHA256.Create());
- dic.Add("q", Qtext);
- dic.Add("appKey", appKey);
- dic.Add("salt", salt);
- dic.Add("sign", sign);
- try
- {
- //Thread.Sleep(500);
- string jsonStr = await TransSync(url, dic);
- JObject trans = (JObject)JsonConvert.DeserializeObject(jsonStr);
- string errorCode = trans["errorCode"].ToString();
- if (errorCode == "0")
- {
- reultStr = JsonConvert.DeserializeObject<List<TranslateResult>>(trans["translateResults"].ToString());
- }
- return reultStr;
- }
- catch (Exception)
- {
- return reultStr;
- }
- }
- public string Processing(string str)//处理这段英文的方法
- {
- if (string.IsNullOrEmpty(str)) { return ""; }
- string[] strArray;
- if (str.Contains(" ")) strArray = str.Split(" ".ToCharArray());
- else if (str.Contains(",")) strArray = str.Split(",".ToCharArray());
- else if (str.Contains(" ") && str.Contains(",")) strArray = str.Split(",".ToCharArray());
- else strArray = new string[] { str };
- string result = string.Empty;//定义一个空字符串
- foreach (string s in strArray)//循环处理数组里面每一个字符串
- {
- //result += System.Threading.Thread.CurrentThread.CurrentCulture.TextInfo.ToTitleCase(s) + " ";
- result += string.Concat(s[..1].ToUpper(), s.AsSpan(1), " ");
- //.Substring(0, 1).ToUpper()把循环到的字符串第一个字母截取并转换为大写,并用s.Substring(1)得到循环到的字符串除第一个字符后的所有字符拼装到首字母后面。
- }
- return result;
- }
- protected static async Task<string> TransSync(string url, Dictionary<string, string> dic)
- {
- string result = "";
- using (var client = new HttpClient())
- {
- var content = new FormUrlEncodedContent(dic);
- HttpResponseMessage response = await client.PostAsync(url, content);
- response.EnsureSuccessStatusCode();
- if (response.Content.Headers.ContentType.MediaType.ToLower().Equals("audio/mp3"))
- {
- await SaveBinaryFile(response, "合成的音频存储路径");
- }
- else
- {
- result = await response.Content.ReadAsStringAsync();
- }
- }
- return result;
- }
- private static async Task<bool> SaveBinaryFile(HttpResponseMessage response, string FileName)
- {
- string FilePath = FileName + DateTime.Now.Millisecond.ToString() + ".mp3";
- bool Value = true;
- byte[] buffer = new byte[1024];
- try
- {
- if (File.Exists(FilePath))
- File.Delete(FilePath);
- using Stream outStream = File.Create(FilePath);
- using Stream inStream = await response.Content.ReadAsStreamAsync();
- int l;
- do
- {
- l = await inStream.ReadAsync(buffer);
- if (l > 0)
- await outStream.WriteAsync(buffer.AsMemory(0, l));
- }
- while (l > 0);
- }
- catch
- {
- Value = false;
- }
- return Value;
- }
- protected static string ComputeHash(string input, HashAlgorithm algorithm)
- {
- byte[] inputBytes = Encoding.UTF8.GetBytes(input);
- byte[] hashedBytes = algorithm.ComputeHash(inputBytes);
- return BitConverter.ToString(hashedBytes).Replace("-", "");
- }
- protected static string Truncate(string q)
- {
- if (q == null)
- {
- return null;
- }
- int len = q.Length;
- return len <= 20 ? q : q.Substring(0, 10) + len + q.Substring(len - 10, 10);
- }
- public static DateTime GetBeijingTime()
- {
- string datetime = string.Empty;
- try
- {
- using (var client = new HttpClient())
- {
- client.Timeout = TimeSpan.FromSeconds(3);
- HttpResponseMessage response = client.GetAsync("https://www.baidu.com").Result;
- response.EnsureSuccessStatusCode();
- datetime = response.Headers.Date?.ToString() ?? DateTime.Now.ToString();
- }
- return Convert.ToDateTime(datetime);
- }
- catch (Exception)
- {
- return DateTime.Now;
- }
- }
- public class TranslateResult
- {
- public string Query { get; set; }
- public string Translation { get; set; }
- public string Type { get; set; }
- public string VerifyResult { get; set; }
- }
- #endregion
- #region 2026版
- /// <summary>
- /// list 2026版
- /// </summary>
- /// <param name="dto">查询参数</param>
- /// <returns>机票费用列表</returns>
- public async Task<JsonView> ListAsync(AirTicketFeeListDto dto)
- {
- // 1. 参数校验
- if (!SharingStaticData.PortTypes.Contains(dto.PortType))
- return JsonView.Fail(MsgTips.Port);
- if (dto.DiId <= 0)
- return JsonView.Fail("团组ID无效");
- // 2. 获取团组信息
- var groupInfo = await _groupInfoRep.GetGroupAirInfo(dto.DiId);
- if (groupInfo == null)
- return JsonView.Fail("暂无团组数据!");
- // 3. 查询机票费用列表
- var airTicketFeeList = await _sqlSugar.Queryable<Grp_AirTicketReservations>()
- .InnerJoin<Grp_CreditCardPayment>((x, y) => x.Id == y.CId && x.DIId == y.DIId)
- .LeftJoin<Sys_SetData>((x, y, z) => x.CType == z.Id)
- .LeftJoin<Sys_SetData>((x, y, z, z1) => x.Currency == z1.Id)
- .LeftJoin<Sys_Users>((x, y, z, z1, u) => x.CreateUserId == u.Id)
- .Where((x, y, z, z1, u) => x.IsDel == 0 && y.IsDel == 0 && x.DIId == dto.DiId)
- .WhereIF(dto.IsPaySign != -1, (x, y, z, z1, u) => y.IsPay == dto.IsPaySign)
- .Select((x, y, z, z1, u) => new AirTicketFeeListView()
- {
- Id = x.Id,
- CabinName = z.Name,
- FlightDesc = x.FlightsDescription,
- ClientNameList = x.ClientName,
- ClientCount = x.ClientNum,
- TotalTicketPrice = x.Price,
- Currency = z1.Name,
- AuditStatus = y.IsAuditGM.ToString(),
- Remark = y.Remark,
- Applicant = u.CnName,
- ApplyTime = x.CreateTime.ToString("yyyy-MM-dd HH:mm:ss")
- })
- .ToListAsync();
- // 4. 获取黑屏代码(三字码映射)
- var threeCodes = await _sqlSugar.Queryable<Res_ThreeCode>()
- .Where(x => x.IsDel == 0)
- .ToDictionaryAsync(x => x.Three, x => x.AirPort);
- // 5. 获取团组成本预算
- var groupCostParameter = await _sqlSugar.Queryable<Grp_GroupCostParameter>()
- .FirstAsync(a => a.DiId == dto.DiId && a.IsDel == 0 && a.CostType == "A" && a.IsShare == 1);
- var airgroupCostParameter = _mapper.Map<AirGroupCostParameterView>(groupCostParameter);
- // 6. 获取客户信息映射
- var groupClientIds = await _sqlSugar.Queryable<Grp_TourClientList>()
- .Where(a => a.DiId == dto.DiId && a.IsDel == 0)
- .Select(x => x.ClientId)
- .ToListAsync();
- var clientInfoMap = new Dictionary<int, (string FirstName, string LastName, string Pinyin)>();
- if (groupClientIds.Any())
- {
- var encryptedClients = await _sqlSugar.Queryable<Crm_DeleClient>()
- .Where(a => a.IsDel == 0 && groupClientIds.Contains(a.Id))
- .Select(x => new { x.Id, x.FirstName, x.LastName, x.Pinyin })
- .ToListAsync();
- foreach (var client in encryptedClients)
- {
- clientInfoMap[client.Id] = (
- AesEncryptionHelper.Decrypt(client.FirstName),
- AesEncryptionHelper.Decrypt(client.LastName),
- AesEncryptionHelper.Decrypt(client.Pinyin)
- );
- }
- }
- // 7. 处理航班描述和客户名称
- foreach (var item in airTicketFeeList)
- {
- // 7.1 处理航班描述
- if (!string.IsNullOrWhiteSpace(item.FlightDesc))
- {
- var flightInfos = FlightParser.ParseFlights(item.FlightDesc);
- var flightDescBuilder = new StringBuilder();
- foreach (var flightInfo in flightInfos)
- {
- string departAirport = threeCodes.ContainsKey(flightInfo.DepartureAirport)
- ? threeCodes[flightInfo.DepartureAirport]?.ToString() ?? flightInfo.DepartureAirport
- : flightInfo.DepartureAirport;
- string arrivalAirport = threeCodes.ContainsKey(flightInfo.ArrivalAirport)
- ? threeCodes[flightInfo.ArrivalAirport]?.ToString() ?? flightInfo.ArrivalAirport
- : flightInfo.ArrivalAirport;
- string desc = $"{flightInfo.SequenceNo}.{departAirport}→{arrivalAirport}({flightInfo.DepartureDate})";
- flightDescBuilder.AppendLine(desc);
- }
- item.FlightDesc = flightDescBuilder.ToString().TrimEnd();
- }
- // 7.2 处理客户名称
- if (!string.IsNullOrWhiteSpace(item.ClientNameList))
- {
- var clientArr = item.ClientNameList.Split(',')
- .Where(x => !string.IsNullOrWhiteSpace(x))
- .ToArray();
- var clientNames = new List<string>();
- foreach (var clientItem in clientArr)
- {
- if (int.TryParse(clientItem, out int clientId))
- {
- if (clientId == -1)
- {
- clientNames.Add("行程单");
- }
- else if (clientInfoMap.TryGetValue(clientId, out var clientInfo))
- {
- clientNames.Add(clientInfo.Pinyin);
- }
- }
- else
- {
- clientNames.Add(clientItem);
- }
- }
- item.ClientNameList = clientNames.Any() ? string.Join(",", clientNames) : string.Empty;
- }
- }
- // 8. 根据端口类型返回数据
- if (dto.PortType == 1)
- {
- var data = new
- {
- DelegationInfo = groupInfo,
- AirTicketReservations = airTicketFeeList,
- AirGroupCostParameter = airgroupCostParameter
- };
- return JsonView.Success(data);
- }
- else if (dto.PortType == 2 || dto.PortType == 3)
- {
- int totalCount = airTicketFeeList.Count;
- int totalPages = (int)Math.Ceiling((double)totalCount / dto.PageSize);
- if (totalPages == 0) totalPages = 1;
- // 分页数据
- var pagedData = airTicketFeeList
- .Skip((dto.PageIndex - 1) * dto.PageSize)
- .Take(dto.PageSize)
- .ToList();
- var rst = new ListViewBase<AirTicketFeeListView>
- {
- DataList = pagedData,
- DataCount = totalCount,
- CurrPageIndex = dto.PageIndex,
- CurrPageSize = dto.PageSize
- };
- var data = new
- {
- AirData = rst,
- AirGroupCostParameter = airgroupCostParameter
- };
- return JsonView.Success(data);
- }
- return JsonView.Fail("暂无团组数据!");
- }
- /// <summary>
- /// 机票费用基础数据 2026版
- /// </summary>
- /// <returns></returns>
- public async Task<JsonView> BasicDataAsync(int userId)
- {
- var setDatas = _sqlSugar.Queryable<Sys_SetData>().Where(a => a.IsDel == 0).ToList();
- // 附加服务类型
- var additionalServiceTypes = setDatas
- .Where(a => a.STid == 139 && a.IsDel == 0)
- .Select(a => _mapper.Map<SetDataInfoView>(a))
- .OrderBy(x => x.RemarkSort)
- .ToList();
- // 舱位类型
- var ticketClass = setDatas
- .Where(a => a.STid == 44 && a.IsDel == 0)
- .Select(a => _mapper.Map<SetDataInfoView>(a))
- .ToList();
- // 支付方式
- var payments = setDatas
- .Where(a => a.STid == 14 && a.IsDel == 0)
- .Select(a => _mapper.Map<SetDataInfoView>(a))
- .ToList();
- // 卡类型
- var cardTypes = setDatas
- .Where(a => a.STid == 15 && a.IsDel == 0)
- .Select(a => _mapper.Map<SetDataInfoView>(a))
- .ToList();
- // 合作方资料
- var airTicketAgents = _sqlSugar.Queryable<Res_AirTicketAgent>().Where(a => a.IsDel == 0).ToList();
- foreach (var item in airTicketAgents)
- {
- EncryptionProcessor.DecryptProperties(item);
- }
- var airTicketAgentsView = airTicketAgents.Select(x => new
- {
- x.Id,
- x.Name,
- x.Account,
- x.Bank
- }).ToList();
- #region 团组下拉框
- var permGroupIds = Query<Grp_GroupsTaskAssignment>(a => a.IsDel == 0 && a.UId == userId && a.CTId == 85).Select(a => a.DIId).ToList();
- var teamNames = _sqlSugar.Queryable<Grp_DelegationInfo>()
- .Where(x => x.IsDel == 0 && permGroupIds.Contains(x.Id))
- .OrderByDescending(x => x.VisitDate)
- .Select(x => new
- {
- x.Id,
- x.TeamName
- })
- .ToList();
- #endregion
- // 获取第一个团组的基本信息
- var firstGroupInfo = await _groupInfoRep.GetGroupAirInfo(teamNames.FirstOrDefault()?.Id ?? 0);
- return JsonView.Success(new
- {
- additionalServiceTypes,
- ticketClass,
- payment = payments,
- cardType = cardTypes,
- airTicketAgents = airTicketAgentsView,
- firstGroupInfo,
- groupName = teamNames
- });
- }
- /// <summary>
- /// 详情 2026版
- /// </summary>
- /// <returns></returns>
- public async Task<JsonView> InfoAsync(int userId, int groupId)
- {
- var view = new AirTicketFeeInfoView()
- {
- CurrUserId = userId,
- GroupAirInfo = new GroupAirTicketInfo(),
- AirTicketFeeInfos = new List<AirTicketFeeInfo>()
- };
- if (userId < 1) return JsonView.Fail<AirTicketFeeInfoView>("用户ID无效");
- if (groupId < 1) return JsonView.Fail<AirTicketFeeInfoView>("团组ID无效");
- var groupVaild = Query<Grp_GroupsTaskAssignment>(a => a.IsDel == 0 && a.UId == userId && a.CTId == 85 && a.DIId == groupId).Any();
- if (!groupVaild) return JsonView.Fail<AirTicketFeeInfoView>("没有查看权限");
- // 获取第一个团组的基本信息
- var firstGroupInfo = await _groupInfoRep.GetGroupAirInfo(groupId);
- if (firstGroupInfo == null)
- return JsonView.Fail<AirTicketFeeInfoView>("团组信息不存在");
- // 团组公共信息
- var groupInfo = _mapper.Map<GroupAirTicketInfo>(firstGroupInfo);
- // 机票信息集合
- var airTicketFeeInfos = await _sqlSugar.Queryable<Grp_AirTicketReservations>()
- .InnerJoin<Grp_CreditCardPayment>((x, y) => x.Id == y.CId && x.DIId == y.DIId && y.CTable == 85)
- .Where((x, y) => x.IsDel == 0 && y.IsDel == 0 && x.DIId == groupId && x.RecordType == 0)
- .Select((x, y) => new AirTicketFeeInfo
- {
- // 机票信息
- Id = x.Id,
- FlightsDescription = x.FlightsDescription,
- AirTicketBasicInfos = x.AirTicketBasicInfos,
- ClientName = x.ClientName,
- CustTicketInfos = x.CustTicketInfos,
- PriceDescription = x.PriceDescription,
- // 支付信息
- PayDId = y.PayDId,
- ConsumptionPatterns = y.ConsumptionPatterns,
- ConsumptionDate = y.ConsumptionDate,
- PayMoney = y.PayMoney,
- PaymentCurrency = y.PaymentCurrency,
- CTDId = y.CTDId,
- BankNo = y.BankNo,
- CardholderName = y.CardholderName,
- DayRate = y.DayRate,
- CompanyBankNo = y.CompanyBankNo,
- OtherSideNo = y.OtherSideNo,
- OtherSideName = y.OtherSideName,
- Payee = y.Payee,
- OrbitalPrivateTransfer = y.OrbitalPrivateTransfer,
- Remark = y.Remark,
- IsAuditGM = y.IsAuditGM,
- AuditGMOperate = y.AuditGMOperate,
- AuditGMDate = y.AuditGMDate
- })
- .ToListAsync();
- // 如果没有数据,返回空结果
- if (!airTicketFeeInfos.Any())
- {
- groupInfo.FlightsDescription = string.Empty;
- return JsonView.Success(new AirTicketFeeInfoView()
- {
- CurrUserId = userId,
- GroupAirInfo = groupInfo,
- AirTicketFeeInfos = new List<AirTicketFeeInfo>()
- });
- }
- // 航班舱位类型
- var cabinTypes = await _sqlSugar.Queryable<Sys_SetData>().Where(x => x.IsDel == 0 && x.STid == 44).ToListAsync();
- // 分组统计一个航班行程的信息
- var groupedByFlights = airTicketFeeInfos
- .GroupBy(x => x.FlightsDescription)
- .Select(g =>
- {
- var first = g.First();
- // 合并航班基础信息(去重)
- var airTicketBasicInfos = g.SelectMany(x => x.AirTicketBasicInfos ?? new List<AirTicketBasicInfo>()).Distinct().ToList();
- // 合并客户名称(去重)
- var clientNames = string.Join(",", g.Select(x => x.ClientName).ToList());
- var clientNameIds = ParseToIntListSafe(clientNames);
- // 处理审核状态
- var auditsStr = new StringBuilder();
- foreach (var item in g)
- {
- var auditStatus = item.IsAuditGM switch
- {
- 0 => "未审核",
- 1 => "审核通过",
- 2 => "审核驳回",
- 3 => "自动审核",
- _ => "未知状态"
- };
- var cabinTypeName = cabinTypes.FirstOrDefault(c => c.Id == item.CustTicketInfos.FirstOrDefault()?.CType)?.Name ?? "未知舱位";
- auditsStr.Append($"{cabinTypeName}:{auditStatus};");
- }
- // 处理多舱位审核描述
- var newFlight = new AirTicketFeeInfo
- {
- Id = first.Id,
- FlightsDescription = g.Key,
- // 合并航班基础信息(去重)
- AirTicketBasicInfos = airTicketBasicInfos,
- // 合并客户人员
- ClientName = clientNames,
- ClientNameIds = clientNameIds,
- // 合并所有客户的机票信息
- CustTicketInfos = g.SelectMany(x => x.CustTicketInfos ?? new List<CustTicketInfo>()).ToList(),
- PriceDescription = first.PriceDescription,
- // 付款信息
- PayDId = first.PayDId,
- ConsumptionPatterns = first.ConsumptionPatterns,
- ConsumptionDate = first.ConsumptionDate,
- PayMoney = g.Sum(x => x.PayMoney),
- PaymentCurrency = first.PaymentCurrency,
- CTDId = first.CTDId,
- BankNo = first.BankNo,
- CardholderName = first.CardholderName,
- DayRate = first.DayRate,
- CompanyBankNo = first.CompanyBankNo,
- OtherSideNo = first.OtherSideNo,
- OtherSideName = first.OtherSideName,
- Payee = first.Payee,
- OrbitalPrivateTransfer = first.OrbitalPrivateTransfer,
- Remark = first.Remark,
- IsAuditGM = first.IsAuditGM,
- AuditGMOperate = first.AuditGMOperate,
- AuditGMDate = first.AuditGMDate,
- AuditStr = auditsStr.ToString().Trim()
- };
- return newFlight;
- })
- .ToList();
- // 按序号排序
- groupedByFlights = groupedByFlights
- .OrderBy(x => ExtractSequenceNo(x.FlightsDescription))
- .ToList();
- // 提取完整的航班行程信息
- var flightsDescAll = new StringBuilder();
- foreach (var item in groupedByFlights)
- {
- flightsDescAll.AppendLine(item.FlightsDescription);
- // 添加测试数据
- if (!item.AirTicketBasicInfos.Any())
- {
- item.AirTicketBasicInfos = FlightParser.ParseFlights(item.FlightsDescription)
- .Select(x => new AirTicketBasicInfo()
- {
- No = x.SequenceNo,
- FlightsCode = x.FlightNumber,
- FlightsCity = $"{x.DepartureAirport}/{x.ArrivalAirport}",
- FlightsDate = x.DepartureDate,
- FlightsTime = x.DepartureTime,
- ArrivedTime = x.ArrivalTime
- })
- .ToList();
- }
- // 添加测试费用数据(仅用于测试,生产环境应移除)
- if (!item.CustTicketInfos.Any())
- {
- item.CustTicketInfos = GetTestCustomerData();
- }
- }
- groupInfo.FlightsDescription = flightsDescAll.ToString();
- return JsonView.Success(new AirTicketFeeInfoView()
- {
- CurrUserId = userId,
- GroupAirInfo = groupInfo,
- AirTicketFeeInfos = groupedByFlights
- });
- }
- #region info 辅助方法
- /// <summary>
- /// 将逗号分隔的字符串解析为 List<int>(带错误处理)
- /// </summary>
- public static List<int> ParseToIntListSafe(string input)
- {
- if (string.IsNullOrWhiteSpace(input))
- return new List<int>();
- var result = new List<int>();
- var parts = input.Split(',');
- foreach (var part in parts)
- {
- if (int.TryParse(part.Trim(), out int value))
- {
- result.Add(value);
- }
- // 可选:记录解析失败的值
- }
- return result;
- }
- /// <summary>
- /// 提取序号辅助方法
- /// </summary>
- private static int ExtractSequenceNo(string flightsDescription)
- {
- if (string.IsNullOrWhiteSpace(flightsDescription))
- return int.MaxValue;
- var match = Regex.Match(flightsDescription, @"^(\d+)\.");
- return match.Success ? int.Parse(match.Groups[1].Value) : int.MaxValue;
- }
- /// <summary>
- /// 获取测试数据
- /// </summary>
- private static List<CustTicketInfo> GetTestCustomerData()
- {
- var testData = new CustTicketInfo()
- {
- ClientId = 1081,
- CType = 460,
- ActualPrice = 1000,
- TicketCode = "9991234567890",
- TicketNumber = "ABC123",
- SelectedServiceIds = new List<int> { 1561, 1563 },
- AdditionalServices = new List<AdditionalService>()
- {
- new AdditionalService() { ServiceTypeId = 1561, Amount = 100 },
- new AdditionalService() { ServiceTypeId = 1563, Amount = 50 }
- },
- TotalTicketPrice = 1150,
- IsRefund = true,
- RefundRecord = new RefundRecord()
- {
- RefundAmount = -200,
- NonRefundableTax = -100,
- RefundReason = "航班取消",
- RefundTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
- RefundAccount = 0,
- }
- };
- return new List<CustTicketInfo>
- {
- testData,
- new CustTicketInfo
- {
- ClientId = 1720,
- CType = 460,
- ActualPrice = 1000,
- TicketCode = "9991234567890",
- TicketNumber = "ABC123"
- },
- new CustTicketInfo
- {
- ClientId = 163,
- CType = 460,
- ActualPrice = 1000,
- TicketCode = "9991234567890",
- TicketNumber = "ABC123"
- }
- };
- }
- #endregion
- /// <summary>
- /// 保存 2026版
- /// </summary>
- /// <returns></returns>
- public async Task<JsonView<AppPushBodyView>> SaveAsync(AirTicketFeeSaveDto dto)
- {
- // 1. 基础字段设置
- var currUserId = dto.CurrUserId;
- var groupId = dto.GroupAirInfo?.Id ?? 0;
- var successMsg = new StringBuilder();
- var appPushBodyInfos = new List<AppPushBodyInfo>();
- var index = 1;
- // 2. 整理数据
- var airFeeRecords = await OrganizeAirTicketDataAsync(dto.AirTicketFeeInfos, groupId);
- if (airFeeRecords == null || !airFeeRecords.Any())
- {
- return JsonView<AppPushBodyView>.Success("没有需要保存的数据");
- }
- // 3. 开启事务
- BeginTran();
- try
- {
- foreach (var airInfo in airFeeRecords)
- {
- var airFeeInfo = _mapper.Map<Grp_AirTicketReservations>(airInfo);
- var cardPaymentInfo = _mapper.Map<Grp_CreditCardPayment>(airInfo);
- // 设置公共字段
- airFeeInfo.CreateUserId = currUserId;
- airFeeInfo.IsDel = 0;
- cardPaymentInfo.CreateUserId = currUserId;
- cardPaymentInfo.DIId = groupId;
- cardPaymentInfo.CTable = 85;
- cardPaymentInfo.UpdateDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
- cardPaymentInfo.IsPay = cardPaymentInfo.PayDId == 72 ? 1 : 0;
- cardPaymentInfo.PayThenMoney = cardPaymentInfo.PayMoney;
- cardPaymentInfo.RMBPrice = cardPaymentInfo.PayMoney * cardPaymentInfo.DayRate;
- cardPaymentInfo.IsDel = 0;
- // 判断是否存在(通过唯一键)
- var existingAir = await _sqlSugar.Queryable<Grp_AirTicketReservations>()
- .FirstAsync(x => x.DIId == groupId
- && x.FlightsDescription == airFeeInfo.FlightsDescription
- && x.CType == airFeeInfo.CType
- && x.RecordType == airFeeInfo.RecordType
- && x.IsDel == 0);
- int airId = 0;
- int cardId = 0;
- if (existingAir == null)
- {
- // ========== 新增 ==========
- var (Success, ErrorMessage, AirId, CardId) = await InsertNewRecord(airFeeInfo, cardPaymentInfo, index);
- if (!Success)
- {
- RollbackTran();
- return JsonView<AppPushBodyView>.Fail(ErrorMessage);
- }
- airId = AirId;
- cardId = CardId;
- appPushBodyInfos.Add(new AppPushBodyInfo()
- {
- OperationType = 1,
- AirTicketId = airId,
- CardId = cardId,
- CardCNYAmount = cardPaymentInfo.RMBPrice
- });
- }
- else
- {
- // ========== 修改 ==========
- var result = await UpdateExistingRecord(airFeeInfo, cardPaymentInfo, existingAir, groupId, index);
- if (!result.Success)
- {
- if (result.IsSkip)
- {
- successMsg.AppendLine(result.ErrorMessage);
- index++;
- continue;
- }
- RollbackTran();
- return JsonView<AppPushBodyView>.Fail(result.ErrorMessage);
- }
- airId = result.AirId;
- cardId = result.CardId;
- appPushBodyInfos.Add(new AppPushBodyInfo()
- {
- OperationType = 2,
- AirTicketId = airId,
- CardId = cardId,
- CardCNYAmount = cardPaymentInfo.RMBPrice
- });
- }
- index++;
- }
- CommitTran();
- var view = new AppPushBodyView()
- {
- GroupName = dto.GroupAirInfo.TeamName,
- AppPushBodyInfos = appPushBodyInfos
- };
- if (successMsg.Length > 0) successMsg.Append("其他新增成功!");
- else successMsg.Append("保存成功!");
- return JsonView<AppPushBodyView>.Success(successMsg.ToString(), view);
- }
- catch (Exception ex)
- {
- RollbackTran();
- return JsonView<AppPushBodyView>.Fail($"保存失败:{ex.Message}");
- }
- }
- #region 保存 辅助方法
- /// <summary>
- /// 整理数据(按舱位类型分组,分离退票和正常记录)
- /// </summary>
- /// <param name="airTicketFeeInfos"></param>
- /// <param name="groupId"></param>
- /// <returns></returns>
- private Task<List<AirTicketFeeInfo>> OrganizeAirTicketDataAsync(List<AirTicketFeeInfo> airTicketFeeInfos, int groupId)
- {
- var result = new List<AirTicketFeeInfo>();
- foreach (var airInfo in airTicketFeeInfos)
- {
- if (airInfo.CustTicketInfos == null || !airInfo.CustTicketInfos.Any())
- continue;
- // 按舱位类型分组
- var groupByCabinType = airInfo.CustTicketInfos
- .GroupBy(x => x.CType)
- .ToList();
- foreach (var cabinGroup in groupByCabinType)
- {
- var customers = cabinGroup.ToList();
- // 1. 正常记录(非退票客户)- 按舱位类型合并成一条数据
- var normalCustomers = customers.Where(x => !x.IsRefund).ToList();
- if (normalCustomers.Any())
- {
- var custRecord = _mapper.Map<AirTicketFeeOpInfo>(airInfo);
- custRecord.ClientNum = normalCustomers.Count;
- custRecord.ClientName = string.Join(",", normalCustomers.Select(x => x.ClientId));
- custRecord.CustTicketInfos = normalCustomers;
- custRecord.Price = normalCustomers.Sum(x => x.ActualPrice);
- custRecord.Currency = airInfo.PaymentCurrency;
- custRecord.PayMoney = normalCustomers.Sum(x => x.TotalTicketPrice);
- custRecord.RecordType = 0; // 正常记录
- result.Add(custRecord);
- }
- // 2. 退票记录 - 按舱位类型 + 退款卡类型 分组
- var refundCustomers = customers.Where(x => x.IsRefund).ToList();
- if (refundCustomers.Any())
- {
- // 按退款卡类型分组
- var groupByRefundAccount = refundCustomers
- .GroupBy(x => x.RefundRecord?.RefundAccount ?? 0)
- .ToList();
- foreach (var refundGroup in groupByRefundAccount)
- {
- var refundCustomersInGroup = refundGroup.ToList();
- var refundAccount = refundGroup.Key;
- var custRecord = _mapper.Map<AirTicketFeeOpInfo>(airInfo);
- custRecord.RecordType = 1; // 退票记录
- custRecord.OriginalReservationId = custRecord.Id; // 关联原始记录
- custRecord.ClientNum = refundCustomersInGroup.Count;
- custRecord.ClientName = string.Join(",", refundCustomersInGroup.Select(x => x.ClientId));
- custRecord.CustTicketInfos = refundCustomersInGroup;
- // 计算退款金额(负数)
- decimal totalRefundAmount = refundCustomersInGroup.Sum(x =>
- (x.RefundRecord?.RefundAmount ?? 0) + (x.RefundRecord?.NonRefundableTax ?? 0));
- custRecord.Price = totalRefundAmount;
- custRecord.Currency = airInfo.PaymentCurrency;
- custRecord.PayMoney = totalRefundAmount;
- custRecord.CTDId = refundAccount; // 退款账户
- result.Add(custRecord);
- }
- }
- }
- }
- return Task.FromResult(result);
- }
- /// <summary>
- /// 新增记录
- /// </summary>
- /// <param name="airFeeInfo"></param>
- /// <param name="cardPaymentInfo"></param>
- /// <param name="index"></param>
- /// <returns></returns>
- private async Task<(bool Success, string ErrorMessage, int AirId, int CardId)> InsertNewRecord(
- Grp_AirTicketReservations airFeeInfo,
- Grp_CreditCardPayment cardPaymentInfo,
- int index)
- {
- // 如果是退票记录,需要先获取关联的正常机票ID
- if (airFeeInfo.RecordType == 1)
- {
- // 根据唯一键查找关联的正常机票记录
- var normalAir = await _sqlSugar.Queryable<Grp_AirTicketReservations>()
- .FirstAsync(x => x.DIId == airFeeInfo.DIId
- && x.FlightsDescription == airFeeInfo.FlightsDescription
- && x.CType == airFeeInfo.CType
- && x.RecordType == 0
- && x.IsDel == 0);
- // 设置关联的正常机票ID
- airFeeInfo.OriginalReservationId = normalAir?.Id ?? 0;
- }
- // 插入机票信息
- var airIdLong = await _sqlSugar.Insertable(airFeeInfo).ExecuteReturnIdentityAsync();
- var airId = (int)airIdLong;
- if (airId < 1)
- {
- return (false, $"第{index}条,机票信息添加失败", 0, 0);
- }
- // 插入付款信息
- cardPaymentInfo.CId = airId;
- var cardIdLong = await _sqlSugar.Insertable(cardPaymentInfo).ExecuteReturnIdentityAsync();
- var cardId = (int)cardIdLong;
- if (cardId < 1)
- {
- return (false, $"第{index}条,机票付款信息添加失败", 0, 0);
- }
- return (true, string.Empty, airId, cardId);
- }
- /// <summary>
- /// 更新记录
- /// </summary>
- /// <param name="airFeeInfo"></param>
- /// <param name="cardPaymentInfo"></param>
- /// <param name="existingAir"></param>
- /// <param name="groupId"></param>
- /// <param name="index"></param>
- /// <returns></returns>
- private async Task<(bool Success, bool IsSkip, string ErrorMessage, int AirId, int CardId)> UpdateExistingRecord(
- Grp_AirTicketReservations airFeeInfo,
- Grp_CreditCardPayment cardPaymentInfo,
- Grp_AirTicketReservations existingAir,
- int groupId,
- int index)
- {
- var airId = existingAir.Id;
- airFeeInfo.Id = airId;
- // 如果是退票记录,需要关联正常机票ID
- if (airFeeInfo.RecordType == 1)
- {
- // 如果还没有关联正常机票ID,或者需要更新关联
- if (airFeeInfo.OriginalReservationId <= 0)
- {
- var normalAir1 = await _sqlSugar.Queryable<Grp_AirTicketReservations>()
- .FirstAsync(x => x.DIId == groupId
- && x.FlightsDescription == airFeeInfo.FlightsDescription
- && x.CType == airFeeInfo.CType
- && x.RecordType == 0
- && x.IsDel == 0);
- if (normalAir1 == null)
- {
- return (false, true, $"第{index}条,退票记录关联的正常机票不存在,请先添加正常机票", 0, 0);
- }
- airFeeInfo.OriginalReservationId = normalAir1.Id;
- }
- }
- // 获取付款信息
- var existingCard = await _sqlSugar.Queryable<Grp_CreditCardPayment>()
- .FirstAsync(x => x.CId == airId && x.DIId == groupId && x.CTable == 85 && x.IsDel == 0);
- // 审核验证
- if (existingCard != null)
- {
- if (existingCard.IsAuditGM == 1 || existingCard.IsAuditGM == 3)
- {
- return (false, true, $"第{index}条,机票费用已审核,不可操作!", 0, 0);
- }
- if (existingCard.IsPay == 1)
- {
- return (false, true, $"第{index}条,机票费用已付款,不可操作!", 0, 0);
- }
- }
- // 更新机票信息
- var airUpdateCount = await _sqlSugar.Updateable(airFeeInfo)
- .IgnoreColumns(ignoreAllNullColumns: true)
- .Where(x => x.Id == airId)
- .ExecuteCommandAsync();
- if (airUpdateCount < 1)
- {
- return (false, false, $"第{index}条,机票信息保存失败", 0, 0);
- }
- int cardId = 0;
- // 更新或新增付款信息
- if (existingCard != null)
- {
- cardPaymentInfo.Id = existingCard.Id;
- var cardUpdateCount = await _sqlSugar.Updateable(cardPaymentInfo)
- .IgnoreColumns(ignoreAllNullColumns: true)
- .Where(x => x.Id == existingCard.Id)
- .ExecuteCommandAsync();
- if (cardUpdateCount < 1)
- {
- return (false, false, $"第{index}条,机票费用信息保存失败", 0, 0);
- }
- cardId = existingCard.Id;
- }
- else
- {
- cardPaymentInfo.CId = airId;
- var cardIdLong = await _sqlSugar.Insertable(cardPaymentInfo).ExecuteReturnIdentityAsync();
- if (cardIdLong < 1)
- {
- return (false, false, $"第{index}条,机票费用信息保存失败", 0, 0);
- }
- cardId = (int)cardIdLong;
- }
- return (true, false, string.Empty, airId, cardId);
- }
- #endregion
- /// <summary>
- /// 单条删除 2026版
- /// </summary>
- /// <param name="userId"></param>
- /// <param name="id"></param>
- /// <returns></returns>
- public async Task<JsonView> SoftDelAsync(int userId, int id)
- {
- BeginTran();
- try
- {
- var ar_res = await SoftDeleteByIdAsync<Grp_AirTicketReservations>(id.ToString(), userId);
- if (!ar_res)
- {
- RollbackTran();
- return JsonView.Fail("删除失败!");
- }
- var ccp_res = await _sqlSugar.Updateable<Grp_CreditCardPayment>()
- .SetColumns(x => x.IsDel == 1)
- .SetColumns(x => x.DeleteUserId == userId)
- .SetColumns(x => x.DeleteTime == DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"))
- .Where(a => a.CId == id && a.CTable == 85)
- .ExecuteCommandAsync();
- if (ccp_res < 1)
- {
- RollbackTran();
- return JsonView.Fail("删除失败!");
- }
- CommitTran();
- return JsonView.Success("删除成功!");
- }
- catch (Exception ex)
- {
- RollbackTran();
- return JsonView.Fail("删除失败!Error:" + ex.Message);
- }
- }
- #endregion
- }
|