123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811281228132814281528162817281828192820282128222823282428252826282728282829283028312832283328342835283628372838283928402841284228432844284528462847284828492850285128522853285428552856285728582859286028612862286328642865286628672868286928702871287228732874287528762877287828792880288128822883288428852886288728882889289028912892289328942895289628972898289929002901290229032904290529062907290829092910291129122913291429152916291729182919292029212922292329242925292629272928292929302931293229332934293529362937293829392940294129422943294429452946294729482949295029512952295329542955295629572958295929602961296229632964296529662967296829692970297129722973297429752976297729782979298029812982298329842985298629872988298929902991299229932994299529962997299829993000300130023003300430053006300730083009301030113012301330143015301630173018301930203021302230233024302530263027302830293030303130323033303430353036303730383039304030413042304330443045304630473048304930503051305230533054305530563057305830593060306130623063306430653066306730683069307030713072307330743075307630773078307930803081308230833084308530863087308830893090309130923093309430953096309730983099310031013102310331043105310631073108310931103111311231133114311531163117311831193120312131223123312431253126312731283129313031313132313331343135313631373138313931403141314231433144314531463147314831493150315131523153315431553156315731583159316031613162316331643165316631673168316931703171317231733174317531763177317831793180318131823183318431853186318731883189319031913192319331943195319631973198319932003201320232033204320532063207320832093210321132123213321432153216321732183219322032213222322332243225322632273228322932303231323232333234323532363237323832393240324132423243324432453246324732483249325032513252325332543255325632573258325932603261326232633264326532663267326832693270327132723273327432753276327732783279328032813282328332843285328632873288328932903291329232933294329532963297329832993300330133023303330433053306330733083309331033113312331333143315331633173318331933203321332233233324332533263327332833293330333133323333333433353336333733383339334033413342334333443345334633473348334933503351335233533354335533563357335833593360336133623363336433653366336733683369337033713372337333743375337633773378337933803381338233833384338533863387338833893390339133923393339433953396339733983399340034013402340334043405340634073408340934103411341234133414341534163417341834193420342134223423342434253426342734283429343034313432343334343435343634373438343934403441344234433444344534463447344834493450345134523453345434553456345734583459346034613462346334643465346634673468346934703471347234733474347534763477347834793480348134823483348434853486348734883489349034913492349334943495349634973498349935003501350235033504350535063507350835093510351135123513351435153516351735183519352035213522352335243525352635273528352935303531353235333534353535363537353835393540354135423543354435453546354735483549355035513552355335543555355635573558355935603561356235633564356535663567356835693570357135723573357435753576357735783579358035813582358335843585358635873588358935903591359235933594359535963597359835993600360136023603360436053606360736083609361036113612361336143615361636173618361936203621362236233624362536263627362836293630363136323633363436353636363736383639364036413642364336443645364636473648364936503651365236533654365536563657365836593660366136623663366436653666366736683669367036713672367336743675367636773678367936803681368236833684368536863687368836893690369136923693369436953696369736983699370037013702370337043705370637073708370937103711371237133714371537163717371837193720372137223723372437253726372737283729373037313732373337343735373637373738373937403741374237433744374537463747374837493750375137523753375437553756375737583759376037613762376337643765376637673768376937703771377237733774377537763777377837793780378137823783378437853786378737883789379037913792379337943795379637973798379938003801380238033804380538063807380838093810381138123813381438153816381738183819382038213822382338243825382638273828382938303831383238333834383538363837383838393840384138423843384438453846384738483849385038513852385338543855385638573858385938603861386238633864386538663867386838693870387138723873387438753876387738783879388038813882388338843885388638873888388938903891389238933894389538963897389838993900390139023903390439053906390739083909391039113912391339143915391639173918391939203921392239233924392539263927392839293930393139323933393439353936393739383939394039413942394339443945394639473948394939503951395239533954395539563957395839593960396139623963396439653966396739683969397039713972397339743975397639773978397939803981398239833984398539863987398839893990399139923993399439953996399739983999400040014002400340044005400640074008400940104011401240134014401540164017401840194020402140224023402440254026402740284029403040314032403340344035403640374038403940404041404240434044404540464047404840494050405140524053405440554056405740584059406040614062406340644065406640674068406940704071407240734074407540764077407840794080408140824083408440854086408740884089409040914092409340944095409640974098409941004101410241034104410541064107410841094110411141124113411441154116411741184119412041214122412341244125412641274128412941304131413241334134413541364137413841394140414141424143414441454146414741484149415041514152415341544155415641574158415941604161416241634164416541664167416841694170417141724173417441754176417741784179418041814182418341844185418641874188418941904191419241934194419541964197419841994200420142024203420442054206420742084209421042114212421342144215421642174218421942204221422242234224422542264227422842294230423142324233423442354236423742384239424042414242424342444245424642474248424942504251425242534254425542564257425842594260426142624263426442654266426742684269427042714272427342744275427642774278427942804281428242834284428542864287428842894290429142924293429442954296429742984299430043014302430343044305430643074308430943104311431243134314431543164317431843194320432143224323432443254326432743284329433043314332433343344335433643374338433943404341434243434344434543464347434843494350435143524353435443554356435743584359436043614362436343644365436643674368436943704371437243734374437543764377437843794380438143824383438443854386438743884389439043914392439343944395439643974398439944004401440244034404440544064407440844094410441144124413441444154416441744184419442044214422442344244425442644274428442944304431443244334434443544364437443844394440444144424443444444454446444744484449445044514452445344544455445644574458445944604461446244634464446544664467446844694470447144724473447444754476447744784479448044814482448344844485448644874488448944904491449244934494449544964497449844994500450145024503450445054506450745084509451045114512451345144515451645174518451945204521452245234524452545264527452845294530453145324533453445354536453745384539454045414542454345444545454645474548454945504551455245534554455545564557455845594560456145624563456445654566456745684569457045714572457345744575457645774578457945804581458245834584458545864587458845894590459145924593459445954596459745984599460046014602460346044605460646074608460946104611461246134614461546164617461846194620462146224623462446254626462746284629463046314632463346344635463646374638463946404641464246434644464546464647464846494650465146524653465446554656465746584659466046614662466346644665466646674668466946704671467246734674467546764677467846794680468146824683468446854686468746884689469046914692469346944695469646974698469947004701470247034704470547064707470847094710471147124713471447154716471747184719472047214722472347244725472647274728472947304731473247334734473547364737473847394740474147424743474447454746474747484749475047514752475347544755475647574758475947604761476247634764476547664767476847694770477147724773477447754776477747784779478047814782478347844785478647874788478947904791479247934794479547964797479847994800480148024803480448054806480748084809481048114812481348144815481648174818481948204821482248234824482548264827482848294830483148324833483448354836483748384839484048414842484348444845484648474848484948504851485248534854485548564857485848594860486148624863486448654866486748684869487048714872487348744875487648774878487948804881488248834884488548864887488848894890489148924893489448954896489748984899490049014902490349044905490649074908490949104911491249134914491549164917491849194920492149224923492449254926492749284929493049314932493349344935493649374938493949404941494249434944494549464947494849494950495149524953495449554956495749584959496049614962496349644965496649674968496949704971497249734974497549764977497849794980498149824983498449854986498749884989499049914992499349944995499649974998499950005001500250035004500550065007500850095010501150125013501450155016501750185019502050215022502350245025502650275028502950305031503250335034503550365037503850395040504150425043504450455046504750485049505050515052505350545055505650575058505950605061506250635064506550665067506850695070507150725073507450755076507750785079508050815082508350845085508650875088508950905091509250935094509550965097509850995100510151025103510451055106510751085109511051115112511351145115511651175118511951205121512251235124512551265127512851295130513151325133513451355136513751385139514051415142514351445145514651475148514951505151515251535154515551565157515851595160516151625163516451655166516751685169517051715172517351745175517651775178517951805181518251835184518551865187518851895190519151925193519451955196519751985199520052015202520352045205520652075208520952105211521252135214521552165217521852195220522152225223522452255226522752285229523052315232523352345235523652375238523952405241524252435244524552465247524852495250525152525253525452555256525752585259526052615262526352645265526652675268526952705271527252735274 |
- using Amazon.Runtime.Internal.Transform;
- using Hotline.Application.ExportExcel;
- using Hotline.Application.FlowEngine;
- using Hotline.Application.Orders;
- using Hotline.Application.StatisticalReport;
- using Hotline.Application.Systems;
- using Hotline.Caching.Interfaces;
- using Hotline.CallCenter.Calls;
- using Hotline.Configurations;
- using Hotline.FlowEngine.WorkflowModules;
- using Hotline.FlowEngine.Workflows;
- using Hotline.Orders;
- using Hotline.Repository.SqlSugar.Extensions;
- using Hotline.Schedulings;
- using Hotline.SeedData;
- using Hotline.Settings;
- using Hotline.Settings.Hotspots;
- using Hotline.Settings.TimeLimitDomain;
- using Hotline.Settings.TimeLimits;
- using Hotline.Share.Dtos;
- using Hotline.Share.Dtos.Bi;
- using Hotline.Share.Dtos.Bigscreen;
- using Hotline.Share.Dtos.CallCenter;
- using Hotline.Share.Dtos.Order;
- using Hotline.Share.Enums.CallCenter;
- using Hotline.Share.Enums.FlowEngine;
- using Hotline.Share.Enums.Order;
- using Hotline.Share.Requests;
- using Hotline.Tools;
- using MapsterMapper;
- using Microsoft.AspNetCore.Authorization;
- using Microsoft.AspNetCore.Mvc;
- using Microsoft.Extensions.Options;
- using Org.BouncyCastle.Utilities.Collections;
- using SqlSugar;
- using System.Data;
- using Hotline.Share.Dtos.WebPortal;
- using XF.Domain.Authentications;
- using XF.Domain.Exceptions;
- using XF.Domain.Filters;
- using XF.Domain.Repository;
- using XF.Utility.EnumExtensions;
- using DocumentFormat.OpenXml.Drawing;
- using DocumentFormat.OpenXml.Bibliography;
- using NPOI.SS.Formula.Functions;
- using Hotline.Share.Dtos.File;
- using Hotline.File;
- namespace Hotline.Api.Controllers.Bi
- {
- public class BiOrderController : BaseController
- {
- private readonly IExportApplication _exportApplication;
- private readonly BaseDataApplication _baseDataApplication;
- private readonly IOrderRepository _orderRepository;
- private readonly IRepository<Hotspot> _hotspotTypeRepository;
- private readonly ISystemDicDataCacheManager _sysDicDataCacheManager;
- private readonly IRepository<OrderVisitDetail> _orderVisitDetailRepository;
- private readonly IRepository<OrderDelay> _orderDelayRepository;
- private readonly IMapper _mapper;
- private readonly IRepository<WorkflowCountersign> _workflowCountersignRepository;
- private readonly IRepository<OrderSpecial> _orderSpecialRepository;
- private readonly IRepository<OrderVisit> _orderVisitRepository;
- private readonly IRepository<TrCallRecord> _trCallRecordRepository;
- private readonly IRepository<OrderPublish> _orderPublishRepository;
- private readonly ISystemOrganizeRepository _systemOrganizeRepository;
- private readonly IRepository<AiOrderVisitDetail> _aiOrderVisitDetailRepository;
- private readonly ISessionContext _sessionContext;
- private readonly ISystemSettingCacheManager _systemSettingCacheManager;
- private readonly IRepository<OrderSpecialDetail> _orderSpecialDetailRepository;
- private readonly IRepository<WorkflowTrace> _workflowTraceRepository;
- private readonly IRepository<WorkflowStep> _workflowStepRepository;
- private readonly IRepository<OrderScreen> _orderScreenRepository;
- private readonly IOrderSecondaryHandlingApplication _orderSecondaryHandlingApplication;
- private readonly IOrderApplication _orderApplication;
- private readonly IOrderVisitApplication _orderVisitApplication;
- //private readonly ITimeLimitDomainService _timeLimitDomainService;
- private readonly IOrderReportApplication _orderReportApplication;
- private readonly IRepository<SystemArea> _systemAreaRepository;
- private readonly IRepository<Hotspot> _hotspotRepository;
- private readonly IRepository<SystemDicData> _systemDicDataRepository;
- private readonly ISystemDicDataCacheManager _systemDicDataCacheManager;
- private readonly ICalcExpireTime _expireTime;
- private readonly IWorkflowApplication _workflowApplication;
- private readonly ISystemOrganizeRepository _organizeRepository;
- private readonly IRepository<CallNative> _callNativeRepository;
- private readonly IOptionsSnapshot<AppConfiguration> _appOptions;
- private readonly IRepository<OrderTsDetails> _orderTsDetailsRepository;
- public BiOrderController(
- IOrderRepository orderRepository,
- IRepository<Hotspot> hotspotTypeRepository,
- ISystemDicDataCacheManager sysDicDataCacheManager,
- IRepository<OrderVisitDetail> orderVisitDetailRepository,
- IRepository<OrderDelay> orderDelayRepository,
- IRepository<WorkflowCountersign> workflowCountersignRepository,
- IRepository<OrderSpecial> orderSpecialRepository,
- IMapper mapper,
- IRepository<OrderVisit> orderVisitRepository,
- IRepository<TrCallRecord> trCallRecordRepository,
- IRepository<OrderPublish> orderPublishRepository,
- ISystemOrganizeRepository systemOrganizeRepository,
- IRepository<AiOrderVisitDetail> aiOrderVisitDetailRepository,
- ISessionContext sessionContext,
- ISystemSettingCacheManager systemSettingCacheManager,
- IRepository<OrderSpecialDetail> orderSpecialDetailRepository,
- IRepository<WorkflowTrace> workflowTraceRepository,
- IRepository<OrderScreen> orderScreenRepository,
- IOrderSecondaryHandlingApplication orderSecondaryHandlingApplication,
- IOrderApplication orderApplication,
- //ITimeLimitDomainService timeLimitDomainService,
- IOrderReportApplication orderReportApplication,
- IRepository<SystemArea> systemAreaRepository,
- IRepository<Hotspot> hotspotRepository,
- IRepository<SystemDicData> systemDicDataRepository,
- ISystemDicDataCacheManager systemDicDataCacheManager,
- IRepository<WorkflowStep> workflowStepRepository,
- IWorkflowApplication workflowApplication,
- ICalcExpireTime expireTime,
- ISystemOrganizeRepository organizeRepository,
- BaseDataApplication baseDataApplication,
- IExportApplication exportApplication,
- IOrderVisitApplication orderVisitApplication,
- IRepository<CallNative> callNativeRepository,
- IOptionsSnapshot<AppConfiguration> appOptions,
- IRepository<OrderTsDetails> orderTsDetailsRepository)
- {
- _orderRepository = orderRepository;
- _hotspotTypeRepository = hotspotTypeRepository;
- _sysDicDataCacheManager = sysDicDataCacheManager;
- _orderVisitDetailRepository = orderVisitDetailRepository;
- _orderDelayRepository = orderDelayRepository;
- _workflowCountersignRepository = workflowCountersignRepository;
- _orderSpecialRepository = orderSpecialRepository;
- _mapper = mapper;
- _orderVisitRepository = orderVisitRepository;
- _trCallRecordRepository = trCallRecordRepository;
- _orderPublishRepository = orderPublishRepository;
- _systemOrganizeRepository = systemOrganizeRepository;
- _aiOrderVisitDetailRepository = aiOrderVisitDetailRepository;
- _sessionContext = sessionContext;
- _systemSettingCacheManager = systemSettingCacheManager;
- _orderSpecialDetailRepository = orderSpecialDetailRepository;
- _workflowTraceRepository = workflowTraceRepository;
- _orderScreenRepository = orderScreenRepository;
- _orderSecondaryHandlingApplication = orderSecondaryHandlingApplication;
- _orderApplication = orderApplication;
- //_timeLimitDomainService = timeLimitDomainService;
- _orderReportApplication = orderReportApplication;
- _systemAreaRepository = systemAreaRepository;
- _hotspotRepository = hotspotRepository;
- _systemDicDataRepository = systemDicDataRepository;
- _systemDicDataCacheManager = systemDicDataCacheManager;
- _workflowStepRepository = workflowStepRepository;
- _workflowApplication = workflowApplication;
- _expireTime = expireTime;
- _organizeRepository = organizeRepository;
- _baseDataApplication = baseDataApplication;
- _exportApplication = exportApplication;
- _orderVisitApplication = orderVisitApplication;
- _callNativeRepository = callNativeRepository;
- _appOptions = appOptions;
- _orderTsDetailsRepository = orderTsDetailsRepository;
- }
- /// <summary>
- /// 部门发布量统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("published/statistics/department")]
- public async Task<PagedDto<PublishedOrderStatisticsDto>> QueryPublishedOrderDepartmentAsync([FromQuery] QueryOrderPublishStatisticsAllDto dto)
- {
- var (total, items) = await _orderApplication.QueryPublishedOrderDepartmentAsync(dto, false);
- return new PagedDto<PublishedOrderStatisticsDto>(total, _mapper.Map<IReadOnlyList<PublishedOrderStatisticsDto>>(items));
- }
- /// <summary>
- /// 部门发布量统计-导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("published/statistics/department/export")]
- public async Task<FileStreamResult> ExportQueryPublishedOrderDepartmentAsync([FromBody] ExportExcelDto<QueryOrderPublishStatisticsAllDto> dto)
- {
- var (total, list) = await _orderApplication.QueryPublishedOrderDepartmentAsync(dto.QueryDto, dto.IsExportAll);
- if (list != null && list.Count > 0)
- {
- list.Add(new PublishedOrderStatisticsDto()
- {
- Name = "合计",
- PrivateCount = list.Sum(m => m.PrivateCount),
- // TotalCount = list.Sum(p => p.TotalCount),
- PublicCount = list.Sum(m => m.PublicCount),
- WaitCount = list.Sum(m => m.WaitCount)
- });
- }
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = list
- .Select(stu => _mapper.Map(stu, typeof(PublishedOrderStatisticsDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "部门发布量统计");
- }
- /// <summary>
- /// 发布量统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("published/statistics/user")]
- public async Task<PagedDto<PublishedOrderStatisticsDto>> QueryPublishedOrderUserAsync([FromQuery] QueryOrderPublishStatisticsDto dto)
- {
- var (total, list) = await _orderApplication.QueryPublishedOrderAsync(dto, false);
- return new PagedDto<PublishedOrderStatisticsDto>(total, _mapper.Map<IReadOnlyList<PublishedOrderStatisticsDto>>(list));
- }
- /// <summary>
- /// 发布量统计-导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("published/statistics/user/export")]
- public async Task<FileStreamResult> ExportQueryPublishedOrder([FromBody] ExportExcelDto<QueryOrderPublishStatisticsDto> dto)
- {
- var (total, list) = await _orderApplication.QueryPublishedOrderAsync(dto.QueryDto, dto.IsExportAll);
- if (list != null && list.Count > 0)
- {
- list.Add(new PublishedOrderStatisticsDto()
- {
- Name = "合计",
- PrivateCount = list.Sum(m => m.PrivateCount),
- //TotalCount = list.Sum(p => p.TotalCount),
- PublicCount = list.Sum(m => m.PublicCount),
- WaitCount = list.Sum(m => m.WaitCount)
- });
- }
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = list
- .Select(stu => _mapper.Map(stu, typeof(PublishedOrderStatisticsDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "发布量统计");
- }
- /// <summary>
- /// 发布量统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("published/statistics")]
- public async Task<PublishedOrderStatisticsDto> QueryPublishedOrderAsync([FromQuery] QueryOrderPublishStatisticsAllDto dto)
- {
- var waitCount = await _orderRepository.Queryable()
- .Where(order => order.CreationTime >= dto.StartTime && order.CreationTime <= dto.EndTime)
- .Where(order => order.Status == EOrderStatus.Filed)
- .Select(order => SqlFunc.AggregateCount(order.Id))
- .FirstAsync();
- var publicCount = await _orderPublishRepository.Queryable()
- .Where(publish => publish.CreationTime >= dto.StartTime && publish.CreationTime <= dto.EndTime)
- .Where(publish => publish.PublishState == true)
- .Select(publish => SqlFunc.AggregateCount(publish.Id))
- .FirstAsync();
- var privateCount = await _orderPublishRepository.Queryable()
- .Where(publish => publish.CreationTime >= dto.StartTime && publish.CreationTime <= dto.EndTime)
- .Where(publish => publish.PublishState == false)
- .Select(publish => SqlFunc.AggregateCount(publish.Id))
- .FirstAsync();
- return new PublishedOrderStatisticsDto
- {
- // TotalCount = totalCount,
- PrivateCount = privateCount,
- PublicCount = publicCount,
- WaitCount = waitCount
- };
- }
- /// <summary>
- /// 回访来源统计
- /// </summary>
- /// <returns></returns>
- [HttpGet("visit/source")]
- public async Task<IList<OrderVisitSourceChannelDto>> QueryOrderVisitSourceChannelAsync([FromQuery] QueryOrderVisitSourceChannelDto dto)
- => await _orderApplication.QueryOrderVisitSourceChannelAsync(dto);
- /// <summary>
- /// 回访来源统计--导出
- /// </summary>
- /// <returns></returns>
- [HttpPost("visit/source/export")]
- public async Task<FileStreamResult> QueryOrderVisitSourceChannelExportAsync([FromBody] ExportExcelDto<QueryOrderVisitSourceChannelDto> dto)
- {
- var list = await _orderApplication.QueryOrderVisitSourceChannelAsync(dto.QueryDto);
- return _exportApplication.GetExcelFile(dto, list, "回访来源统计", "SourceChannel");
- }
- /// <summary>
- /// 回访量统计
- /// </summary>
- /// <returns></returns>
- [HttpGet("visit/quantity")]
- public async Task<IList<OrderVisitQuantityOutDto>> QueryOrderVisitQuantityAsync([FromQuery] QueryOrderVisitQuantity dto)
- => await _orderVisitApplication.QueryOrderVisitQuantityAsync(dto);
- /// <summary>
- /// 回访量统计--导出
- /// </summary>
- /// <returns></returns>
- [HttpPost("visit/quantity/export")]
- public async Task<FileStreamResult> QueryOrderVisitQuantityExportAsync([FromBody] ExportExcelDto<QueryOrderVisitQuantity> dto)
- {
- var items = await _orderVisitApplication.QueryOrderVisitQuantityAsync(dto.QueryDto);
- return _exportApplication.GetExcelFile(dto, items, "回访量统计");
- }
- /// <summary>
- /// 部门超期统计明细
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("org_data_list_detail")]
- public async Task<PagedDto<OrderDto>> OrgDataListDetail([FromQuery] OrgDataListDetailRequest dto)
- {
- var quer = _orderApplication.QueryOrgDataListDetail(dto);
- var (total, items) = await quer.ToPagedListAsync(dto.PageIndex, dto.PageSize);
- return new PagedDto<OrderDto>(total, _mapper.Map<IReadOnlyList<OrderDto>>(items));
- }
- /// <summary>
- /// 部门超期统计明细导出
- /// </summary>
- /// <returns></returns>
- [HttpPost("org_data_list_detail/_export")]
- public async Task<FileStreamResult> OrgDataListDetailExport([FromBody] ExportExcelDto<OrgDataListDetailRequest> dto)
- {
- var query = _orderApplication.QueryOrgDataListDetail(dto.QueryDto);
- List<Order> data;
- if (dto.IsExportAll)
- {
- data = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- data = items;
- }
- var dataDtos = _mapper.Map<ICollection<OrderDto>>(data);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = dataDtos
- .Select(stu => _mapper.Map(stu, typeof(OrderDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "部门超期统计明细数据");
- }
- /// <summary>
- /// 全量部门超期统计明细
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("org_data_list_detail_all")]
- public async Task<PagedDto<OrderDto>> OrgDataListDetail([FromQuery] OrgDataListAllDetailRequest dto)
- {
- var quer = _orderApplication.QueryOrgDataListDetail(dto);
- var (total, items) = await quer.ToPagedListAsync(dto.PageIndex, dto.PageSize);
- return new PagedDto<OrderDto>(total, _mapper.Map<IReadOnlyList<OrderDto>>(items));
- }
- /// <summary>
- /// 部门超期统计明细导出
- /// </summary>
- /// <returns></returns>
- [HttpPost("org_data_list_detail_all/_export")]
- public async Task<FileStreamResult> OrgDataListDetailExport([FromBody] ExportExcelDto<OrgDataListAllDetailRequest> dto)
- {
- var query = _orderApplication.QueryOrgDataListDetail(dto.QueryDto);
- List<Order> data;
- if (dto.IsExportAll)
- {
- data = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- data = items;
- }
- var dataDtos = _mapper.Map<ICollection<OrderDto>>(data);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = dataDtos
- .Select(stu => _mapper.Map(stu, typeof(OrderDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "部门超期统计明细数据");
- }
- /// <summary>
- /// 列表页面基础数据
- /// </summary>
- /// <returns></returns>
- [HttpGet("org_data_list_detail_all/base-data")]
- public async Task<object> BaseData()
- {
- var rsp = new
- {
- OrderStatusOptions = EnumExts.GetDescriptions<EOrderStatus>()
- };
- return rsp;
- }
- /// <summary>
- /// 部门超期统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("org_data_list")]
- public async Task<PagedDto<OrderBiOrgDataListVo>> OrgDataList([FromQuery] ReportPagedRequest dto)
- {
- var query = _orderApplication.QueryOrgDataList(dto);
- var (total, items) = await query.ToPagedListAsync(dto, HttpContext.RequestAborted);
- items.Add(new OrderBiOrgDataListVo
- {
- OrgName = "合计",
- HandlerExtendedNum = items.Select(s => s.HandlerExtendedNum).Sum(),
- CounterHandlerExtendedNum = items.Select(s => s.CounterHandlerExtendedNum).Sum(),
- NoHandlerExtendedNum = items.Select(s => s.NoHandlerExtendedNum).Sum(),
- CounterNoHandlerExtendedNum = items.Select(s => s.CounterNoHandlerExtendedNum).Sum(),
- });
- return new PagedDto<OrderBiOrgDataListVo>(total, items);
- }
- /// <summary>
- /// 部门超期统计导出
- /// </summary>
- /// <returns></returns>
- [HttpPost("org_data_list/_export")]
- public async Task<FileStreamResult> OrgDataListExport([FromBody] ExportExcelDto<ReportPagedRequest> dto)
- {
- var query = _orderApplication.QueryOrgDataList(dto.QueryDto);
- List<OrderBiOrgDataListVo> data;
- data = await query.ToListAsync(HttpContext.RequestAborted);
- data.Add(new OrderBiOrgDataListVo
- {
- OrgName = "合计",
- HandlerExtendedNum = data.Select(s => s.HandlerExtendedNum).Sum(),
- CounterHandlerExtendedNum = data.Select(s => s.CounterHandlerExtendedNum).Sum(),
- NoHandlerExtendedNum = data.Select(s => s.NoHandlerExtendedNum).Sum(),
- CounterNoHandlerExtendedNum = data.Select(s => s.CounterNoHandlerExtendedNum).Sum(),
- });
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = data
- .Select(stu => _mapper.Map(stu, typeof(OrderBiOrgDataListVo), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "部门超期统计数据");
- }
- /// <summary>
- /// 话务员办件统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("centre_data_list")]
- public async Task<List<OrderBiCentreDataListVo>> CentreDataList([FromQuery] ReportPagedRequest dto)
- {
- var query = _orderApplication.CentreDataList(dto);
- var list = await query.Where(x => (x.CentreArchive + x.CentreCareOf + x.NoCentreCareOf + x.Invalid + x.Repeat) != 0).ToListAsync(HttpContext.RequestAborted);
- return list;
- }
- /// <summary>
- /// 话务员办件统计--导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("centre_data_list_export")]
- public async Task<FileStreamResult> CentreDataListExport([FromBody] ExportExcelDto<ReportPagedRequest> dto)
- {
- var query = _orderApplication.CentreDataList(dto.QueryDto);
- List<OrderBiCentreDataListVo> data = await query.Where(x => (x.CentreArchive + x.CentreCareOf + x.NoCentreCareOf + x.Invalid + x.Repeat) != 0).ToListAsync(HttpContext.RequestAborted);
- data.Add(new OrderBiCentreDataListVo
- {
- UserName = "合计",
- CentreArchive = data.Select(s => s.CentreArchive).Sum(),
- CentreCareOf = data.Select(s => s.CentreCareOf).Sum(),
- NoCentreCareOf = data.Select(s => s.NoCentreCareOf).Sum(),
- Invalid = data.Select(s => s.Invalid).Sum(),
- Repeat = data.Select(s => s.Repeat).Sum(),
- Subtotal = data.Select(s => s.Subtotal).Sum()
- });
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = data
- .Select(stu => _mapper.Map(stu, typeof(OrderBiCentreDataListVo), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "话务员办件统计");
- }
- /// <summary>
- /// 热点数据小计统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("hotspot_subtotal_data_list")]
- public async Task<PagedDto<HotspotDataLsitVo>> HotspotSubtotalDataLsit([FromQuery] HotspotSubtotalReportPagedRequest dto)
- {
- if (!dto.StartTime.HasValue || !dto.EndTime.HasValue) throw UserFriendlyException.SameMessage("请选择时间!");
- var query = _hotspotTypeRepository.Queryable(false, true)
- .LeftJoin<Order>((x, o) => o.HotspotSpliceName != null && (x.HotSpotFullName == o.HotspotSpliceName || o.HotspotSpliceName.Contains(x.HotSpotFullName)) && o.IsDeleted == false)
- .WhereIF(dto.StartTime.HasValue, (x, o) => o.CreationTime >= dto.StartTime)
- .WhereIF(dto.EndTime.HasValue, (x, o) => o.CreationTime <= dto.EndTime)
- .WhereIF(!string.IsNullOrEmpty(dto.Keyword), (x, o) => x.HotSpotName.Contains(dto.Keyword!))
- .Where((x, o) => x.ParentId == dto.Id)
- .Where((x, o) => x.IsDeleted == false)
- .GroupBy((x, o) => new { x.Id, x.HotSpotName })
- .Select((x, o) => new HotspotDataLsitVo
- {
- Id = x.Id,
- Name = x.HotSpotName,
- Num = SqlFunc.AggregateSum(SqlFunc.IIF(o.Id != null, 1, 0)),
- }).MergeTable();
- var (total, items) = await query.ToPagedListAsync(dto, HttpContext.RequestAborted);
- return new PagedDto<HotspotDataLsitVo>(total, items);
- }
- /// <summary>
- /// 热点数据统计导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("hotspot_data_list/export")]
- public async Task<FileStreamResult> HotspotDataLsitExprot([FromBody] ExportExcelDto<HotspotReportPagedRequest> dto)
- {
- if (!dto.QueryDto.StartTime.HasValue || !dto.QueryDto.EndTime.HasValue) throw UserFriendlyException.SameMessage("请选择时间!");
- if (dto.QueryDto.Type == 0 && (!dto.QueryDto.ChainStartTime.HasValue || !dto.QueryDto.ChainEndTime.HasValue)) throw UserFriendlyException.SameMessage("请选择环比时间!");
- dto.QueryDto.EndTime = dto.QueryDto.EndTime.Value.AddDays(1).AddSeconds(-1);
- var IsCenter = _sessionContext.OrgIsCenter;
- if (dto.QueryDto.Type == 0)
- {
- dto.QueryDto.ChainEndTime = dto.QueryDto.ChainEndTime.Value.AddDays(1).AddSeconds(-1);
- }
- var items = await _hotspotTypeRepository.Queryable(false, true)
- .LeftJoin<Order>((x, o) => o.HotspotSpliceName != null && (x.HotSpotName == o.HotspotSpliceName || o.HotspotSpliceName.Contains(x.HotSpotName)) && o.IsDeleted == false)
- .WhereIF(dto.QueryDto.StartTime.HasValue, (x, o) => o.CreationTime >= dto.QueryDto.StartTime)
- .WhereIF(dto.QueryDto.EndTime.HasValue, (x, o) => o.CreationTime <= dto.QueryDto.EndTime)
- .WhereIF(!string.IsNullOrEmpty(dto.QueryDto.Keyword), (x, o) => x.HotSpotName.Contains(dto.QueryDto.Keyword!))
- .WhereIF(IsCenter == false, (x, o) => o.ActualHandleOrgCode == _sessionContext.RequiredOrgId)
- .Where((x, o) => x.ParentId == dto.QueryDto.Id)
- .Where((x, o) => x.IsDeleted == false)
- .GroupBy((x, o) => new { x.Id, x.HotSpotName })
- .Select((x, o) => new HotspotDataLsitVo
- {
- Id = x.Id,
- Name = x.HotSpotName,
- Num = SqlFunc.AggregateSum(SqlFunc.IIF(o.Id != null, 1, 0)),
- Sublevel = SqlFunc.AggregateSum(SqlFunc.IIF(x.HotSpotName != o.HotspotName, 1, 0)) > 0,
- }).MergeTable().ToListAsync();
- var chainStartTime = dto.QueryDto.StartTime;
- var chainEndTime = dto.QueryDto.EndTime;
- switch (dto.QueryDto.Type)
- {
- case 1://日
- chainStartTime = dto.QueryDto.StartTime.Value.AddDays(-1);
- chainEndTime = dto.QueryDto.EndTime.Value.AddDays(-1);
- break;
- case 2://月
- chainStartTime = dto.QueryDto.StartTime.Value.AddMonths(-1);
- chainEndTime = dto.QueryDto.EndTime.Value.AddMonths(-1);
- break;
- case 3://年
- chainStartTime = dto.QueryDto.StartTime.Value.AddYears(-1);
- chainEndTime = dto.QueryDto.EndTime.Value.AddYears(-1);
- break;
- case 0:
- chainStartTime = dto.QueryDto.ChainStartTime.Value;
- chainEndTime = dto.QueryDto.ChainEndTime.Value;
- break;
- }
- var chainItems = await _hotspotTypeRepository.Queryable(false, true)
- .LeftJoin<Order>((x, o) => o.HotspotSpliceName != null && (x.HotSpotName == o.HotspotSpliceName || o.HotspotSpliceName.Contains(x.HotSpotName)) && o.IsDeleted == false)
- .WhereIF(dto.QueryDto.StartTime.HasValue, (x, o) => o.CreationTime >= chainStartTime)
- .WhereIF(dto.QueryDto.EndTime.HasValue, (x, o) => o.CreationTime <= chainEndTime)
- .WhereIF(!string.IsNullOrEmpty(dto.QueryDto.Keyword), (x, o) => x.HotSpotName.Contains(dto.QueryDto.Keyword!))
- .WhereIF(IsCenter == false, (x, o) => o.ActualHandleOrgCode == _sessionContext.RequiredOrgId)
- .Where((x, o) => x.ParentId == dto.QueryDto.Id)
- .Where((x, o) => x.IsDeleted == false)
- .GroupBy((x, o) => new { x.Id, x.HotSpotName })
- .Select((x, o) => new
- {
- Id = x.Id,
- ChainNum = SqlFunc.AggregateSum(SqlFunc.IIF(o.Id != null, 1, 0)),
- }).MergeTable().ToListAsync();
- var res = (from t1 in items
- join t2 in chainItems on t1.Id equals t2.Id into t1_t2
- from item in t1_t2.DefaultIfEmpty()
- select new HotspotDataLsitVo
- {
- Id = t1.Id,
- Name = t1.Name,
- Num = t1.Num,
- Sublevel = t1.Sublevel,
- Children = new List<HotspotDataLsitVo>(),
- ChainNum = t1_t2.Select(x => x.ChainNum).FirstOrDefault(),
- ChainRate = t1_t2.Select(x => x.ChainNum).FirstOrDefault() > 0 ?
- ((double.Parse(t1.Num.ToString()) - double.Parse(t1_t2.Select(x => x.ChainNum).FirstOrDefault().ToString())) / double.Parse(t1_t2.Select(x => x.ChainNum).FirstOrDefault().ToString()) * 100).ToString("F2") + "%" : "100.00%",
- }).ToList();
- var total = new HotspotDataLsitVo()
- {
- Id = "0",
- Name = "合计",
- Num = res.Sum(x => x.Num),
- Sublevel = false,
- Children = new List<HotspotDataLsitVo>(),
- ChainNum = res.Sum(x => x.ChainNum),
- ChainRate = res.Sum(x => x.ChainNum) > 0 ? ((double.Parse(res.Sum(x => x.Num).ToString()) - double.Parse(res.Sum(x => x.ChainNum).ToString())) / double.Parse(res.Sum(x => x.ChainNum).ToString()) * 100).ToString("F2") + "%" : "100.00%"
- };
- res.Add(total);
- List<HotspotDataLsitVo> data;
- data = res;
- var dataDtos = _mapper.Map<ICollection<HotspotDataLsitVo>>(data);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = dataDtos
- .Select(stu => _mapper.Map(stu, typeof(HotspotDataLsitVo), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "热点类型统计");
- //return new { List = res, Total = total };
- }
- /// <summary>
- /// 热点数据统计 TODO和前端沟通
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("hotspot_data_list")]
- public async Task<object> HotspotDataLsit([FromQuery] HotspotReportPagedRequest dto)
- {
- if (!dto.StartTime.HasValue || !dto.EndTime.HasValue) throw UserFriendlyException.SameMessage("请选择时间!");
- if (dto.Type == 0 && (!dto.ChainStartTime.HasValue || !dto.ChainEndTime.HasValue)) throw UserFriendlyException.SameMessage("请选择环比时间!");
- dto.EndTime = dto.EndTime.Value.AddDays(1).AddSeconds(-1);
- var IsCenter = _sessionContext.OrgIsCenter;
- if (dto.Type == 0)
- {
- dto.ChainEndTime = dto.ChainEndTime.Value.AddDays(1).AddSeconds(-1);
- }
- var items = await _hotspotTypeRepository.Queryable(false, true)
- .LeftJoin<Order>((x, o) => o.HotspotSpliceName != null && (x.HotSpotName == o.HotspotSpliceName || o.HotspotSpliceName.Contains(x.HotSpotName)) && o.IsDeleted == false)
- .WhereIF(dto.StartTime.HasValue, (x, o) => o.CreationTime >= dto.StartTime)
- .WhereIF(dto.EndTime.HasValue, (x, o) => o.CreationTime <= dto.EndTime)
- .WhereIF(!string.IsNullOrEmpty(dto.Keyword), (x, o) => x.HotSpotName.Contains(dto.Keyword!))
- .WhereIF(IsCenter == false, (x, o) => o.ActualHandleOrgCode == _sessionContext.RequiredOrgId)
- .Where((x, o) => x.ParentId == dto.Id)
- .Where((x, o) => x.IsDeleted == false)
- .GroupBy((x, o) => new { x.Id, x.HotSpotName })
- .Select((x, o) => new HotspotDataLsitVo
- {
- Id = x.Id,
- Name = x.HotSpotName,
- Num = SqlFunc.AggregateSum(SqlFunc.IIF(o.Id != null, 1, 0)),
- Sublevel = SqlFunc.AggregateSum(SqlFunc.IIF(x.HotSpotName != o.HotspotName, 1, 0)) > 0,
- }).MergeTable().ToListAsync();
- var chainStartTime = dto.StartTime;
- var chainEndTime = dto.EndTime;
- switch (dto.Type)
- {
- case 1://日
- chainStartTime = dto.StartTime.Value.AddDays(-1);
- chainEndTime = dto.EndTime.Value.AddDays(-1);
- break;
- case 2://月
- chainStartTime = dto.StartTime.Value.AddMonths(-1);
- chainEndTime = dto.EndTime.Value.AddMonths(-1);
- break;
- case 3://年
- chainStartTime = dto.StartTime.Value.AddYears(-1);
- chainEndTime = dto.EndTime.Value.AddYears(-1);
- break;
- case 0:
- chainStartTime = dto.ChainStartTime.Value;
- chainEndTime = dto.ChainEndTime.Value;
- break;
- }
- var chainItems = await _hotspotTypeRepository.Queryable(false, true)
- .LeftJoin<Order>((x, o) => o.HotspotSpliceName != null && (x.HotSpotName == o.HotspotSpliceName || o.HotspotSpliceName.Contains(x.HotSpotName)) && o.IsDeleted == false)
- .WhereIF(dto.StartTime.HasValue, (x, o) => o.CreationTime >= chainStartTime)
- .WhereIF(dto.EndTime.HasValue, (x, o) => o.CreationTime <= chainEndTime)
- .WhereIF(!string.IsNullOrEmpty(dto.Keyword), (x, o) => x.HotSpotName.Contains(dto.Keyword!))
- .WhereIF(IsCenter == false, (x, o) => o.ActualHandleOrgCode == _sessionContext.RequiredOrgId)
- .Where((x, o) => x.ParentId == dto.Id)
- .Where((x, o) => x.IsDeleted == false)
- .GroupBy((x, o) => new { x.Id, x.HotSpotName })
- .Select((x, o) => new
- {
- Id = x.Id,
- ChainNum = SqlFunc.AggregateSum(SqlFunc.IIF(o.Id != null, 1, 0)),
- }).MergeTable().ToListAsync();
- var res = (from t1 in items
- join t2 in chainItems on t1.Id equals t2.Id into t1_t2
- from item in t1_t2.DefaultIfEmpty()
- select new HotspotDataLsitVo()
- {
- Id = t1.Id,
- Name = t1.Name,
- Num = t1.Num,
- Sublevel = t1.Sublevel,
- Children = new List<HotspotDataLsitVo>(),
- ChainNum = t1_t2.Select(x => x.ChainNum).FirstOrDefault(),
- ChainRate = t1_t2.Select(x => x.ChainNum).FirstOrDefault() > 0 ?
- ((double.Parse(t1.Num.ToString()) - double.Parse(t1_t2.Select(x => x.ChainNum).FirstOrDefault().ToString())) / double.Parse(t1_t2.Select(x => x.ChainNum).FirstOrDefault().ToString()) * 100).ToString("F2") + "%" : "100.00%",
- }).ToList();
- var total = new HotspotDataLsitVo()
- {
- Id = "0",
- Name = "合计",
- Num = res.Sum(x => x.Num),
- Sublevel = false,
- Children = new List<HotspotDataLsitVo>(),
- ChainNum = res.Sum(x => x.ChainNum),
- ChainRate = res.Sum(x => x.ChainNum) > 0 ? ((double.Parse(res.Sum(x => x.Num).ToString()) - double.Parse(res.Sum(x => x.ChainNum).ToString())) / double.Parse(res.Sum(x => x.ChainNum).ToString()) * 100).ToString("F2") + "%" : "100.00%"
- };
- return new { List = res, Total = total };
- }
- /// <summary>
- /// 部门不满意统计--导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("visit-nosatisfied/export")]
- public async Task<FileStreamResult> ExportQueryVisitNoSatisfied([FromBody] QueryVisitNoSatisfiedDto dto)
- {
- if (!dto.StartTime.HasValue || !dto.EndTime.HasValue) throw UserFriendlyException.SameMessage("请选择时间!");
- if (dto.AddColumnName is null || dto.AddColumnName.Count == 0) throw UserFriendlyException.SameMessage("导出字段不能为空");
- if (dto.AddColumnName.FirstOrDefault() != "部门名称") throw UserFriendlyException.SameMessage("导出字段第一个必须是'部门名称'");
- var (dissatisfiedReason, list) = await _orderReportApplication.QueryVisitNoSatisfiedAsync(dto, _sessionContext.OrgIsCenter);
- var dataTable = await _orderReportApplication.ExportQueryVisitNoSatisfiedAsync(dissatisfiedReason, list, dto.AddColumnName);
- return ExcelStreamResult(ExcelHelper.CreateStream(dataTable), "回访不满意原因统计");
- }
- /// <summary>
- /// 部门不满意统计
- /// 已加验证部门
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("visit-nosatisfied")]
- public async Task<object> QueryVisitNoSatisfied([FromQuery] QueryVisitNoSatiisfiedRequest dto)
- {
- if (!dto.StartTime.HasValue || !dto.EndTime.HasValue) throw UserFriendlyException.SameMessage("请选择时间!");
- var (dissatisfiedReason, list) = await _orderReportApplication
- .QueryVisitNoSatisfiedAsync(_mapper.Map<QueryVisitNoSatisfiedDto>(dto), _sessionContext.OrgIsCenter);
- return new { DicReason = dissatisfiedReason, Data = list };
- }
- /// <summary>
- /// 部门不满意统计明细
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("visit-nosatisfied-detail")]
- public async Task<PagedDto<OrderVisitDetailDto>> BiQueryVisitNoSatisfiedDetail([FromQuery] BiQueryVisitNoSatisfiedDetailDto dto)
- {
- if (!dto.StartTime.HasValue || !dto.EndTime.HasValue) throw UserFriendlyException.SameMessage("请选择时间!");
- var IsCenter = _sessionContext.OrgIsCenter;
- var (total, items) = await _orderReportApplication.BiQueryVisitNoSatisfiedDetail(dto)
- .ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
- return new PagedDto<OrderVisitDetailDto>(total, _mapper.Map<IReadOnlyList<OrderVisitDetailDto>>(items));
- }
- /// <summary>
- /// 部门不满意统计明细--导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("visit-nosatisfied-detail-export")]
- public async Task<FileStreamResult> BiQueryVisitNoSatisfiedDetailExport([FromBody] ExportExcelDto<BiQueryVisitNoSatisfiedDetailDto> dto)
- {
- if (!dto.QueryDto.StartTime.HasValue || !dto.QueryDto.EndTime.HasValue) throw UserFriendlyException.SameMessage("请选择时间!");
- var query = _orderReportApplication.BiQueryVisitNoSatisfiedDetail(dto.QueryDto);
- List<OrderVisitDetail> data;
- if (dto.IsExportAll)
- {
- data = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- data = items;
- }
- var dataDtos = _mapper.Map<ICollection<OrderVisitDetailDto>>(data);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = dataDtos
- .Select(stu => _mapper.Map(stu, typeof(OrderVisitDetailDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "部门不满意统计明细");
- }
- /// <summary>
- /// 部门延期统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("order-delay-data-list")]
- public async Task<IReadOnlyList<BiOrderDelayDataDto>> QueryOrderDelayDataList([FromQuery] QueryOrderDelayDataListRequest dto)
- {
- return await _orderReportApplication.QueryOrderDelayDataList(dto).ToListAsync();
- }
- /// <summary>
- /// 部门延期统计---导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("order-delay-data-list-export")]
- public async Task<FileStreamResult> ExportQueryOrderDelayDataList([FromBody] ExportExcelDto<QueryOrderDelayDataListRequest> dto)
- {
- var query = _orderReportApplication.QueryOrderDelayDataList(dto.QueryDto);
- List<BiOrderDelayDataDto> list;
- if (dto.IsExportAll)
- {
- list = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- list = items;
- }
- list.Add(new BiOrderDelayDataDto()
- {
- OrgName = "合计",
- OrgCode = "",
- AllTotal = list.Sum(p => p.AllTotal),
- PassTotal = list.Sum(p => p.PassTotal),
- NoPassTotal = list.Sum(p => p.NoPassTotal),
- ExaminingTotal = list.Sum(p => p.ExaminingTotal)
- });
- var orderDtos = _mapper.Map<ICollection<BiOrderDelayDataDto>>(list);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = orderDtos
- .Select(stu => _mapper.Map(stu, typeof(BiOrderDelayDataDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "部门延期统计数据");
- }
- /// <summary>
- /// 部门延期统计明细
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("order-delay-data-detail")]
- public async Task<PagedDto<OrderDelayDto>> QueryOrderDelayDataDetail([FromQuery] QueryOrderDelayDataDetailRequest dto)
- {
- var (total, items) = await _orderReportApplication.QueryOrderDelayDataDetail(dto).ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
- return new PagedDto<OrderDelayDto>(total, _mapper.Map<IReadOnlyList<OrderDelayDto>>(items));
- }
- /// <summary>
- /// 部门延期统计明细--导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("order-delay-data-detail-export")]
- public async Task<FileStreamResult> ExportQueryOrderDelayDataDetail([FromBody] ExportExcelDto<QueryOrderDelayDataDetailRequest> dto)
- {
- var query = _orderReportApplication.QueryOrderDelayDataDetail(dto.QueryDto);
- List<OrderDelay> list;
- if (dto.IsExportAll)
- {
- list = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- list = items;
- }
- var orderDtos = _mapper.Map<ICollection<OrderDelayDto>>(list);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = orderDtos
- .Select(stu => _mapper.Map(stu, typeof(OrderDelayDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "部门延期统计明细数据");
- }
- /// <summary>
- /// 特提统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("special_data_list")]
- public async Task<PagedDto<OrderBiSpecialListVo>> SpecialDataList([FromQuery] ReportPagedRequest dto)
- {
- if (!dto.StartTime.HasValue || !dto.EndTime.HasValue) throw UserFriendlyException.SameMessage("请选择时间!");
- var IsCenter = _sessionContext.OrgIsCenter;
- var query = _orderSpecialRepository.Queryable()
- .WhereIF(dto.StartTime.HasValue, x => x.CreationTime >= dto.StartTime)
- .WhereIF(dto.EndTime.HasValue, x => x.CreationTime <= dto.EndTime)
- .WhereIF(IsCenter == false, x => x.OrgId.StartsWith(_sessionContext.RequiredOrgId))
- .GroupBy(x => new { x.Cause })
- .Select(x => new OrderBiSpecialListVo
- {
- Cause = x.Cause,
- OrderNum = SqlFunc.AggregateSum(SqlFunc.IIF(true, 1, 0)),
- MaxSpecialTime = SqlFunc.AggregateMax(x.CreationTime),
- })
- .MergeTable();
- switch (dto.SortField)
- {
- case "cause":
- query = dto.SortRule is 0 ? query.OrderBy(x => x.Cause) : query.OrderByDescending(x => x.Cause);
- break;
- case "orderNum":
- query = dto.SortRule is 0 ? query.OrderBy(x => x.OrderNum) : query.OrderByDescending(x => x.OrderNum);
- break;
- case "maxSpecialTime":
- query = dto.SortRule is 0 ? query.OrderBy(x => x.MaxSpecialTime) : query.OrderByDescending(x => x.MaxSpecialTime);
- break;
- }
- var (total, items) = await query.ToPagedListAsync(dto, HttpContext.RequestAborted);
- return new PagedDto<OrderBiSpecialListVo>(total, items);
- }
- /// <summary>
- /// 获取工单特提信息列表
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("special_data_list/list")]
- public async Task<PagedDto<OrderSpecialDto>> List([FromQuery] OrderSpecialListDto dto)
- {
- if (!dto.StartTime.HasValue || !dto.EndTime.HasValue) throw UserFriendlyException.SameMessage("请选择时间!");
- var IsCenter = _sessionContext.OrgIsCenter;
- var (total, items) = await _orderSpecialRepository.Queryable()
- .Includes(x => x.Order)
- .WhereIF(!string.IsNullOrEmpty(dto.Keyword),
- x => x.Order.No.Contains(dto.Keyword!) || x.Order.Title.Contains(dto.Keyword!))
- .WhereIF(!string.IsNullOrEmpty(dto.Cause),
- x => x.Cause != null && x.Cause.Equals(dto.Cause))
- .WhereIF(dto.StartTime.HasValue, x => x.CreationTime >= dto.StartTime)
- .WhereIF(dto.EndTime.HasValue, x => x.CreationTime <= dto.EndTime)
- .WhereIF(dto.State.HasValue, x => x.State == dto.State)
- .WhereIF(IsCenter == false, x => x.OrgId.StartsWith(_sessionContext.OrgId))
- .OrderByDescending(x => x.CreationTime)
- .ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
- return new PagedDto<OrderSpecialDto>(total, _mapper.Map<IReadOnlyList<OrderSpecialDto>>(items));
- }
- /// <summary>
- /// 受理类型前十
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("accept_type_top10_list")]
- public async Task<object> AcceptTypeTop10List([FromQuery] ReportPagedRequest dto)
- {
- var (areaList, returnList, data) = await _orderApplication.AcceptTypeTop10List(dto, false);
- return new { List = areaList, Data = returnList };
- }
- /// <summary>
- /// 受理类型前十导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("accept_type_top10_list-export")]
- public async Task<FileStreamResult> AcceptTypeTop10ListExport([FromBody] ExportExcelDto<ReportPagedRequest> dto)
- {
- var (areaList, returnList, data) = await _orderApplication.AcceptTypeTop10List(dto.QueryDto, true);
- var stream = ExcelHelper.CreateStream(data);
- return ExcelStreamResult(stream, "受理类型前十统计");
- }
- /// <summary>
- /// 热点类型部门统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("hotport-org-statistics")]
- public async Task<object> HotPortJoinOrgStatistics([FromQuery] HotPortJoinOrgStatisticsRequest dto)
- {
- var IsCenter = _sessionContext.OrgIsCenter;
- return await _orderRepository.HotPortJoinOrgStatistics(dto.StartTime, dto.EndTime, IsCenter, _sessionContext.OrgId);
- }
- /// <summary>
- /// 回访量统计导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("visit-measure-statistics-export")]
- [AllowAnonymous]
- public async Task<FileStreamResult> VisitMeasureStatisticsExport([FromBody] ExportExcelDto<VisitMeasureStatisticsRequest> dto)
- {
- var query = _orderVisitRepository.Queryable()
- .Includes(x => x.Employee)
- .Where(x => x.VisitTime >= dto.QueryDto.StartTime && x.VisitTime <= dto.QueryDto.EndTime && x.VisitState == EVisitState.Visited)
- .WhereIF(!string.IsNullOrEmpty(dto.QueryDto.VisitName), x => x.Employee.Name.Contains(dto.QueryDto.VisitName))
- .GroupBy(x => new { x.EmployeeId, x.Employee.Name })
- .Select(x => new VisitMeasureStatisticsModelDto()
- {
- VisitName = x.Employee.Name,
- CallVisitCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.VisitType == EVisitType.CallVisit, 1, 0)),
- ArtificialVisitCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.VisitType != EVisitType.CallVisit, 1, 0)),
- SumCount = SqlFunc.AggregateCount(x.EmployeeId)
- });
- var list = await query.ToListAsync();
- //合计
- var SumModel = new VisitMeasureStatisticsModelDto()
- {
- VisitName = "合计",
- CallVisitCount = list.Sum(x => x.CallVisitCount),
- ArtificialVisitCount = list.Sum(x => x.ArtificialVisitCount),
- SumCount = list.Sum(x => x.SumCount)
- };
- list.Add(SumModel);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = list
- .Select(stu => _mapper.Map(stu, typeof(VisitMeasureStatisticsModelDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "回访量统计");
- }
- /// <summary>
- /// 回访量统计
- /// </summary>
- /// <param name="StartTime"></param>
- /// <param name="EndTime"></param>
- /// <param name="VisitName"></param>
- /// <returns></returns>
- [HttpGet("visit-measure-statistics")]
- public async Task<VisitMeasureStatisticsDto> VisitMeasureStatistics([FromQuery] VisitMeasureStatisticsRequest dto)
- {
- var query = _orderVisitRepository.Queryable()
- .Includes(x => x.Employee)
- .Where(x => x.VisitTime >= dto.StartTime && x.VisitTime <= dto.EndTime && x.VisitState == EVisitState.Visited && x.EmployeeId != "" && x.EmployeeId != null)
- .WhereIF(!string.IsNullOrEmpty(dto.VisitName), x => x.Employee.Name.Contains(dto.VisitName))
- .GroupBy(x => new { x.EmployeeId, x.Employee.Name })
- .Select(x => new VisitMeasureStatisticsModelDto()
- {
- VisitName = x.Employee.Name,
- CallVisitCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.VisitType == EVisitType.CallVisit, 1, 0)),
- ArtificialVisitCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.VisitType != EVisitType.CallVisit, 1, 0)),
- SumCount = SqlFunc.AggregateCount(x.EmployeeId)
- });
- var list = await query.ToListAsync();
- var returnModel = new VisitMeasureStatisticsDto();
- returnModel.VisitMeasureStatisticsModelList = list;
- //查询AIVisit
- returnModel.AiVisitCount = await _aiOrderVisitDetailRepository.Queryable()
- .Where(x => x.AiVisitTime >= dto.StartTime && x.AiVisitTime <= dto.EndTime && x.IsSuccess != null).CountAsync();
- returnModel.AiVisitSatisfiedCount = await _aiOrderVisitDetailRepository.Queryable()
- //.Includes(x => x.OrderVisit)
- .Where(x => x.AiVisitTime >= dto.StartTime && x.AiVisitTime <= dto.EndTime && x.IsSuccess == true && SqlFunc.JsonField(x.AiOrgProcessingResults, "Key") == "4").CountAsync();
- returnModel.AiVisitNoSatisfiedCount = await _aiOrderVisitDetailRepository.Queryable()
- //.Includes(x => x.OrderVisit)
- .Where(x => x.AiVisitTime >= dto.StartTime && x.AiVisitTime <= dto.EndTime && x.IsSuccess == true && SqlFunc.JsonField(x.AiOrgProcessingResults, "Key") == "2").CountAsync();
- returnModel.AIVisitFailCount = await _aiOrderVisitDetailRepository.Queryable()
- .Where(x => x.AiVisitTime >= dto.StartTime && x.AiVisitTime <= dto.EndTime && x.IsSuccess == false).CountAsync();
- return returnModel;
- }
- /// <summary>
- /// 热点类型小类统计
- /// </summary>
- /// <param name="StartTime"></param>
- /// <param name="EndTime"></param>
- /// <param name="TypeId">0:全部 ,1:市民,2:企业</param>
- /// <returns></returns>
- [HttpGet("hotspot-statistics")]
- public async Task<object> HotspotStatistics([FromQuery] HotspotStatisticsRep dto)
- {
- var IsCenter = _sessionContext.OrgIsCenter;
- if (string.IsNullOrEmpty(dto.HotspotCode))
- {
- var list = await _hotspotTypeRepository.Queryable()
- .LeftJoin<Order>((it, o) => it.Id == o.HotspotId)
- .Where((it, o) => o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime && o.Id != null)
- .WhereIF(dto.TypeId == 1, (it, o) => o.IdentityType == EIdentityType.Citizen)
- .WhereIF(dto.TypeId == 2, (it, o) => o.IdentityType == EIdentityType.Enterprise)
- .WhereIF(IsCenter == false, (it, o) => o.ActualHandleOrgCode.StartsWith(_sessionContext.RequiredOrgId))
- .GroupBy((it, o) => new { Id = it.Id.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("2")) })
- .Select((it, o) => new
- {
- HotspotCode = it.Id.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("2")),
- SumCount = SqlFunc.AggregateCount(it.HotSpotName)
- })
- .MergeTable()
- .LeftJoin<Hotspot>((x, q) => x.HotspotCode == q.Id)
- .Select((x, q) => new
- {
- HotspotCode = x.HotspotCode,
- SumCount = x.SumCount,
- HotspotName = q.HotSpotName,
- HasChild = SqlFunc.Subqueryable<Hotspot>().Where(d => d.ParentId == x.HotspotCode).Any()
- })
- .ToListAsync();
- return list;
- }
- else
- {
- string count = (dto.HotspotCode.Length + 2).ToString();
- string countx = dto.HotspotCode.Length.ToString();
- var list = await _hotspotTypeRepository.Queryable()
- .LeftJoin<Order>((it, o) => it.Id == o.HotspotId)
- .Where((it, o) => o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime && it.ParentId.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>(countx)) == dto.HotspotCode)
- .WhereIF(dto.TypeId == 1, (it, o) => o.IdentityType == EIdentityType.Citizen)
- .WhereIF(dto.TypeId == 2, (it, o) => o.IdentityType == EIdentityType.Enterprise)
- .WhereIF(IsCenter == false, (it, o) => o.ActualHandleOrgCode.StartsWith(_sessionContext.RequiredOrgId))
- .GroupBy((it, o) => new { Id = it.Id.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>(count)) })
- .Select((it, o) => new
- {
- HotspotCode = it.Id.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>(count)),
- SumCount = SqlFunc.AggregateCount(it.HotSpotName)
- })
- .MergeTable()
- .LeftJoin<Hotspot>((x, q) => x.HotspotCode == q.Id)
- .Select((x, q) => new
- {
- HotspotCode = x.HotspotCode,
- SumCount = x.SumCount,
- HotspotName = q.HotSpotName,
- HasChild = SqlFunc.Subqueryable<Hotspot>().Where(d => d.ParentId == x.HotspotCode).Any()
- })
- .ToListAsync();
- return list;
- }
- }
- /// <summary>
- /// 热点类型小类统计导出
- /// </summary>
- /// <param name="StartTime"></param>
- /// <param name="EndTime"></param>
- /// <param name="TypeId">0:全部 ,1:市民,2:企业</param>
- /// <returns></returns>
- [HttpPost("hotspot-statistics/export")]
- public async Task<FileStreamResult> HotspotStatisticsExprot([FromBody] ExportExcelDto<HotspotStatisticsRep> dto)
- {
- var IsCenter = _sessionContext.OrgIsCenter;
- DataTable data = new DataTable();
- if (string.IsNullOrEmpty(dto.QueryDto.HotspotCode))
- {
- data = await _hotspotTypeRepository.Queryable()
- .LeftJoin<Order>((it, o) => it.Id == o.HotspotId)
- .Where((it, o) => o.CreationTime >= dto.QueryDto.StartTime && o.CreationTime <= dto.QueryDto.EndTime && o.Id != null)
- .WhereIF(dto.QueryDto.TypeId == 1, (it, o) => o.IdentityType == EIdentityType.Citizen)
- .WhereIF(dto.QueryDto.TypeId == 2, (it, o) => o.IdentityType == EIdentityType.Enterprise)
- .WhereIF(IsCenter == false, (it, o) => o.ActualHandleOrgCode.StartsWith(_sessionContext.RequiredOrgId))
- .GroupBy((it, o) => new { Id = it.Id.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("2")) })
- .Select((it, o) => new
- {
- HotspotCode = it.Id.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("2")),
- SumCount = SqlFunc.AggregateCount(it.HotSpotName)
- })
- .MergeTable()
- .LeftJoin<Hotspot>((x, q) => x.HotspotCode == q.Id)
- .Select((x, q) => new
- {
- SumCount = x.SumCount,
- HotspotName = q.HotSpotName
- })
- .ToDataTableAsync();
- }
- else
- {
- string count = (dto.QueryDto.HotspotCode.Length + 2).ToString();
- string countx = dto.QueryDto.HotspotCode.Length.ToString();
- data = await _hotspotTypeRepository.Queryable()
- .LeftJoin<Order>((it, o) => it.Id == o.HotspotId)
- .Where((it, o) => o.CreationTime >= dto.QueryDto.StartTime && o.CreationTime <= dto.QueryDto.EndTime && it.ParentId.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>(countx)) == dto.QueryDto.HotspotCode)
- .WhereIF(dto.QueryDto.TypeId == 1, (it, o) => o.IdentityType == EIdentityType.Citizen)
- .WhereIF(dto.QueryDto.TypeId == 2, (it, o) => o.IdentityType == EIdentityType.Enterprise)
- .WhereIF(IsCenter == false, (it, o) => o.ActualHandleOrgCode.StartsWith(_sessionContext.RequiredOrgId))
- .GroupBy((it, o) => new { Id = it.Id.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>(count)) })
- .Select((it, o) => new
- {
- HotspotCode = it.Id.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>(count)),
- SumCount = SqlFunc.AggregateCount(it.HotSpotName)
- })
- .MergeTable()
- .LeftJoin<Hotspot>((x, q) => x.HotspotCode == q.Id)
- .Select((x, q) => new
- {
- SumCount = x.SumCount,
- HotspotName = q.HotSpotName,
- })
- .ToDataTableAsync();
- }
- data.Columns["HotspotName"].SetOrdinal(0);
- data.Columns["SumCount"].ColumnName = "分类统计";
- data.Columns["HotspotName"].ColumnName = "热点名称";
- //合计
- DataRow sumRow = data.NewRow();
- sumRow["热点名称"] = "合计";
- decimal totalAmount = 0;
- foreach (DataRow row in data.Rows)
- {
- totalAmount += Convert.ToDecimal(row["分类统计"]);
- }
- sumRow["分类统计"] = totalAmount;
- data.Rows.Add(sumRow);
- var stream = ExcelHelper.CreateStream(data);
- return ExcelStreamResult(stream, "热点类型小类统计");
- }
- /// <summary>
- /// 热点类型小类统计明细
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("hotspot-statistics-detail")]
- public async Task<PagedDto<OrderDto>> HotspotStatisticsDetail([FromQuery] HotspotStatisticsRep dto)
- {
- var (total, items) = await _orderApplication.HotspotStatisticsDetail(dto)
- .ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
- return new PagedDto<OrderDto>(total, _mapper.Map<IReadOnlyList<OrderDto>>(items));
- }
- /// <summary>
- /// 热点类型小类统计明细导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("hotspot-statistics-detail/export")]
- public async Task<FileStreamResult> HotspotStatisticsDetailExport([FromBody] ExportExcelDto<HotspotStatisticsRep> dto)
- {
- var query = _orderApplication.HotspotStatisticsDetail(dto.QueryDto);
- List<Order> data;
- if (dto.IsExportAll)
- {
- data = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- data = items;
- }
- var orderDtos = _mapper.Map<IReadOnlyList<OrderDto>>(data);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = orderDtos
- .Select(stu => _mapper.Map(stu, typeof(OrderDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "热点类型小类统计明细");
- }
- /// <summary>
- /// 部门满意度统计表基础数据
- /// </summary>
- /// <returns></returns>
- [HttpGet("visit-org-satisfaction-statisticsBaseData")]
- public async Task<object> VisitAndOrgSatisfactionStatisticsBaseData()
- {
- return new
- {
- VisitType = EnumExts.GetDescriptions<EVisitType>(),
- };
- }
- /// <summary>
- /// 坐席总体满意度分析
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("seat-satisfaction-statistics")]
- public async Task<List<SeatSatisfactionStatisticsDto>> SeatSatisfactionStatistics([FromQuery] PagedKeywordRequest dto)
- {
- return await _orderApplication.SeatSatisfactionStatistics(dto).ToListAsync();
- }
- /// <summary>
- /// 坐席总体满意度分析导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("seat-satisfaction-statistics/export")]
- public async Task<FileStreamResult> SeatSatisfactionStatisticsExport([FromBody] ExportExcelDto<PagedKeywordRequest> dto)
- {
- var query = _orderApplication.SeatSatisfactionStatistics(dto.QueryDto);
- List<SeatSatisfactionStatisticsDto> data;
- if (dto.IsExportAll)
- {
- data = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- data = items;
- }
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = data
- .Select(stu => _mapper.Map(stu, typeof(SeatSatisfactionStatisticsDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "坐席总体满意度分析");
- }
- /// <summary>
- /// 坐席总体满意率分析
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("seat-satisfaction-statistics-rate")]
- public async Task<SeatSatisfactionStatisticsEvaluateDto> SeatSatisfactionStatisticsRate([FromQuery] PagedKeywordRequest dto)
- {
- var data = await _orderVisitDetailRepository.Queryable()
- .LeftJoin<OrderVisit>((od, ov) => od.VisitId == ov.Id)
- .LeftJoin<Order>((od, ov, o) => ov.OrderId == o.Id)
- .Where((od, ov, o) => ov.VisitTime >= dto.StartTime.Value && ov.VisitTime <= dto.EndTime.Value && ov.VisitState == EVisitState.Visited
- && od.SeatEvaluate != null && od.SeatEvaluate != ESeatEvaluate.VeryNoSatisfied && od.SeatEvaluate != ESeatEvaluate.Normal
- && od.VisitTarget == EVisitTarget.Seat && o.SourceChannelCode == "RGDH"
- )
- .Select((od, ov, o) => new SeatSatisfactionStatisticsEvaluateDto
- {
- Satisfied = SqlFunc.AggregateSum(SqlFunc.IIF(od.SeatEvaluate != ESeatEvaluate.NoSatisfied && od.SeatEvaluate != ESeatEvaluate.VeryNoSatisfied, 1, 0)),
- NoSatisfied = SqlFunc.AggregateSum(SqlFunc.IIF(od.SeatEvaluate == ESeatEvaluate.NoSatisfied || od.SeatEvaluate == ESeatEvaluate.VeryNoSatisfied, 1, 0))
- })
- .FirstAsync();
- return data;
- }
- /// <summary>
- /// 坐席满意度明细表
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("seat-satisfaction-statistics-list-detail")]
- public async Task<object> SeatSatisfactionStatisticsListDetail([FromQuery] PagedKeywordRequest dto)
- {
- var list = await _orderApplication.SeatSatisfactionStatisticsListDetail(dto).ToListAsync();
- var sumModel = new SeatSatisfactionStatisticsListDetailDto()
- {
- UserName = "合计",
- UserId = "",
- DefaultSatisfied = list.Sum(x => x.DefaultSatisfied),
- VeryNoSatisfied = list.Sum(x => x.VeryNoSatisfied),
- NoSatisfied = list.Sum(x => x.NoSatisfied),
- Normal = list.Sum(x => x.Normal),
- Satisfied = list.Sum(x => x.Satisfied),
- VerySatisfied = list.Sum(x => x.VerySatisfied),
- NoConnect = list.Sum(x => x.NoConnect),
- NoEvaluate = list.Sum(x => x.NoEvaluate),
- };
- return new { List = list, Total = sumModel };
- }
- /// <summary>
- /// 坐席总体满意度分析导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("seat-satisfaction-statistics-list-detail/export")]
- public async Task<FileStreamResult> SeatSatisfactionStatisticsListDetailExport([FromBody] ExportExcelDto<PagedKeywordRequest> dto)
- {
- var query = _orderApplication.SeatSatisfactionStatisticsListDetail(dto.QueryDto);
- List<SeatSatisfactionStatisticsListDetailDto> data;
- if (dto.IsExportAll)
- {
- data = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- data = items;
- }
- var sumModel = new SeatSatisfactionStatisticsListDetailDto()
- {
- UserName = "合计",
- UserId = "",
- DefaultSatisfied = data.Sum(x => x.DefaultSatisfied),
- VeryNoSatisfied = data.Sum(x => x.VeryNoSatisfied),
- NoSatisfied = data.Sum(x => x.NoSatisfied),
- Normal = data.Sum(x => x.Normal),
- Satisfied = data.Sum(x => x.Satisfied),
- VerySatisfied = data.Sum(x => x.VerySatisfied),
- NoConnect = data.Sum(x => x.NoConnect),
- NoEvaluate = data.Sum(x => x.NoEvaluate),
- };
- data.Add(sumModel);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = data
- .Select(stu => _mapper.Map(stu, typeof(SeatSatisfactionStatisticsListDetailDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "坐席满意度明细表");
- }
- /// <summary>
- /// 坐席满意度工单明细
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("query-seat-satisfaction-order-visit-list")]
- public async Task<PagedDto<OrderVisitDetailDto>> QuerySeatSatisfactionOrderVisitList([FromQuery] SeatSatisfactionOrderVisitRequest dto)
- {
- var (total, items) = await _orderApplication.QuerySeatSatisfactionOrderVisitList(dto).ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
- return new PagedDto<OrderVisitDetailDto>(total, _mapper.Map<IReadOnlyList<OrderVisitDetailDto>>(items));
- }
- /// <summary>
- /// 坐席满意度工单明细表基础数据
- /// </summary>
- /// <returns></returns>
- [HttpGet("query-seat-satisfaction-base-data")]
- public async Task<object> QuerySeatSatisfactionBaseData()
- {
- var seatEvaluate = EnumExts.GetDescriptions<ESeatEvaluate>();
- if (_appOptions.Value.IsZiGong == false)
- {
- seatEvaluate = seatEvaluate.Where(m => new int[] { 1, 3 }.Contains(m.Key) == false).ToList();
- }
- return new
- {
- SeatEvaluate = seatEvaluate
- };
- }
- /// <summary>
- /// 坐席满意度工单明细导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("query-seat-satisfaction-order-visit-list/export")]
- public async Task<FileStreamResult> ExportQuerySeatSatisfactionOrderVisitList([FromBody] ExportExcelDto<SeatSatisfactionOrderVisitRequest> dto)
- {
- var query = _orderApplication.QuerySeatSatisfactionOrderVisitList(dto.QueryDto);
- List<OrderVisitDetail> orders;
- if (dto.IsExportAll)
- {
- orders = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- orders = items;
- }
- var orderDtos = _mapper.Map<ICollection<OrderVisitDetailDto>>(orders);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = orderDtos
- .Select(stu => _mapper.Map(stu, typeof(OrderVisitDetailDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "坐席满意度工单明细");
- }
- /// <summary>
- /// 部门满意度统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("visit-org-satisfaction-statistics")]
- public async Task<VisitAndOrgSatisfactionStatisticsResultDto> VisitAndOrgSatisfactionStatistics([FromQuery] PagedKeywordSonRequest dto)
- {
- var data = await _orderApplication.VisitAndOrgSatisfactionStatistics(dto);
- var countySumModel = new VisitAndOrgSatisfactionStatisticsDto()
- {
- OrgName = "区县合计",
- TotalSumCount = data.Where(x => x.OrgType == EOrgType.County).Sum(x => x.TotalSumCount),
- VerySatisfiedCount = data.Where(x => x.OrgType == EOrgType.County).Sum(x => x.VerySatisfiedCount),
- SatisfiedCount = data.Where(x => x.OrgType == EOrgType.County).Sum(x => x.SatisfiedCount),
- RegardedAsSatisfiedCount = data.Where(x => x.OrgType == EOrgType.County).Sum(x => x.RegardedAsSatisfiedCount),
- DefaultSatisfiedCount = data.Where(x => x.OrgType == EOrgType.County).Sum(x => x.DefaultSatisfiedCount),
- NoSatisfiedCount = data.Where(x => x.OrgType == EOrgType.County).Sum(x => x.NoSatisfiedCount),
- NoEvaluateCount = data.Where(x => x.OrgType == EOrgType.County).Sum(x => x.NoEvaluateCount),
- NoPutThroughCount = data.Where(x => x.OrgType == EOrgType.County).Sum(x => x.NoPutThroughCount),
- NormalCount = data.Where(x => x.OrgType == EOrgType.County).Sum(x => x.NormalCount),
- VeryNoSatisfiedCount = data.Where(x => x.OrgType == EOrgType.County).Sum(x => x.VeryNoSatisfiedCount),
- };
- var citySumModel = new VisitAndOrgSatisfactionStatisticsDto()
- {
- OrgName = "市直合计",
- TotalSumCount = data.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(x => x.TotalSumCount),
- VerySatisfiedCount = data.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(x => x.VerySatisfiedCount),
- SatisfiedCount = data.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(x => x.SatisfiedCount),
- RegardedAsSatisfiedCount = data.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(x => x.RegardedAsSatisfiedCount),
- DefaultSatisfiedCount = data.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(x => x.DefaultSatisfiedCount),
- NoSatisfiedCount = data.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(x => x.NoSatisfiedCount),
- NoEvaluateCount = data.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(x => x.NoEvaluateCount),
- NoPutThroughCount = data.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(x => x.NoPutThroughCount),
- NormalCount = data.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(x => x.NormalCount),
- VeryNoSatisfiedCount = data.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(x => x.VeryNoSatisfiedCount),
- };
- var sumModel = new VisitAndOrgSatisfactionStatisticsDto()
- {
- OrgName = "总计",
- TotalSumCount = data.Sum(x => x.TotalSumCount),
- VerySatisfiedCount = data.Sum(x => x.VerySatisfiedCount),
- SatisfiedCount = data.Sum(x => x.SatisfiedCount),
- RegardedAsSatisfiedCount = data.Sum(x => x.RegardedAsSatisfiedCount),
- DefaultSatisfiedCount = data.Sum(x => x.DefaultSatisfiedCount),
- NoSatisfiedCount = data.Sum(x => x.NoSatisfiedCount),
- NoEvaluateCount = data.Sum(x => x.NoEvaluateCount),
- NoPutThroughCount = data.Sum(x => x.NoPutThroughCount),
- NormalCount = data.Sum(x => x.NormalCount),
- VeryNoSatisfiedCount = data.Sum(x => x.VeryNoSatisfiedCount),
- };
- return new VisitAndOrgSatisfactionStatisticsResultDto { DataList = data, CountySumModel = countySumModel, CitySumModel = citySumModel, SumModel = sumModel };
- }
- /// <summary>
- /// 部门满意度统计导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("visit-org-satisfaction-statistics/_export")]
- public async Task<FileStreamResult> VisitAndOrgSatisfactionStatisticsExport([FromBody] ExportExcelDto<PagedKeywordSonRequest> dto)
- {
- List<VisitAndOrgSatisfactionStatisticsDto> data = await _orderApplication.VisitAndOrgSatisfactionStatistics(dto.QueryDto);
- var countySumModel = new VisitAndOrgSatisfactionStatisticsDto()
- {
- OrgName = "区县合计",
- TotalSumCount = data.Where(x => x.OrgType == EOrgType.County).Sum(x => x.TotalSumCount),
- VerySatisfiedCount = data.Where(x => x.OrgType == EOrgType.County).Sum(x => x.VerySatisfiedCount),
- SatisfiedCount = data.Where(x => x.OrgType == EOrgType.County).Sum(x => x.SatisfiedCount),
- RegardedAsSatisfiedCount = data.Where(x => x.OrgType == EOrgType.County).Sum(x => x.RegardedAsSatisfiedCount),
- DefaultSatisfiedCount = data.Where(x => x.OrgType == EOrgType.County).Sum(x => x.DefaultSatisfiedCount),
- NoSatisfiedCount = data.Where(x => x.OrgType == EOrgType.County).Sum(x => x.NoSatisfiedCount),
- NoEvaluateCount = data.Where(x => x.OrgType == EOrgType.County).Sum(x => x.NoEvaluateCount),
- NoPutThroughCount = data.Where(x => x.OrgType == EOrgType.County).Sum(x => x.NoPutThroughCount),
- NormalCount = data.Where(x => x.OrgType == EOrgType.County).Sum(x => x.NormalCount),
- VeryNoSatisfiedCount = data.Where(x => x.OrgType == EOrgType.County).Sum(x => x.VeryNoSatisfiedCount),
- };
- var citySumModel = new VisitAndOrgSatisfactionStatisticsDto()
- {
- OrgName = "市直合计",
- TotalSumCount = data.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(x => x.TotalSumCount),
- VerySatisfiedCount = data.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(x => x.VerySatisfiedCount),
- SatisfiedCount = data.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(x => x.SatisfiedCount),
- RegardedAsSatisfiedCount = data.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(x => x.RegardedAsSatisfiedCount),
- DefaultSatisfiedCount = data.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(x => x.DefaultSatisfiedCount),
- NoSatisfiedCount = data.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(x => x.NoSatisfiedCount),
- NoEvaluateCount = data.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(x => x.NoEvaluateCount),
- NoPutThroughCount = data.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(x => x.NoPutThroughCount),
- NormalCount = data.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(x => x.NormalCount),
- VeryNoSatisfiedCount = data.Where(x => x.OrgType == EOrgType.City && x.OrgCode != "001").Sum(x => x.VeryNoSatisfiedCount),
- };
- var sumModel = new VisitAndOrgSatisfactionStatisticsDto()
- {
- OrgName = "总计",
- TotalSumCount = data.Sum(x => x.TotalSumCount),
- VerySatisfiedCount = data.Sum(x => x.VerySatisfiedCount),
- SatisfiedCount = data.Sum(x => x.SatisfiedCount),
- RegardedAsSatisfiedCount = data.Sum(x => x.RegardedAsSatisfiedCount),
- DefaultSatisfiedCount = data.Sum(x => x.DefaultSatisfiedCount),
- NoSatisfiedCount = data.Sum(x => x.NoSatisfiedCount),
- NoEvaluateCount = data.Sum(x => x.NoEvaluateCount),
- NoPutThroughCount = data.Sum(x => x.NoPutThroughCount),
- NormalCount = data.Sum(x => x.NormalCount),
- VeryNoSatisfiedCount = data.Sum(x => x.VeryNoSatisfiedCount),
- };
- data.Add(countySumModel);
- data.Add(citySumModel);
- data.Add(sumModel);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = data
- .Select(stu => _mapper.Map(stu, typeof(VisitAndOrgSatisfactionStatisticsDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "部门满意度统计数据");
- }
- /// <summary>
- /// 子部门满意度明细
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("visit-org-statisfaction-org-detail")]
- public async Task<VisitAndOrgSatisfactionStatisticsResultDto> VisitAndOrgStatisfactionOrgDetail([FromQuery] PagedKeywordSonRequest dto)
- {
- var list = await _orderApplication.VisitAndOrgStatisfactionOrgDetail(dto);
- var countySumModel = new VisitAndOrgSatisfactionStatisticsDto()
- {
- OrgName = "区县合计",
- TotalSumCount = list.Where(x => x.OrgType == EOrgType.County).Sum(x => x.TotalSumCount),
- VerySatisfiedCount = list.Where(x => x.OrgType == EOrgType.County).Sum(x => x.VerySatisfiedCount),
- SatisfiedCount = list.Where(x => x.OrgType == EOrgType.County).Sum(x => x.SatisfiedCount),
- RegardedAsSatisfiedCount = list.Where(x => x.OrgType == EOrgType.County).Sum(x => x.RegardedAsSatisfiedCount),
- DefaultSatisfiedCount = list.Where(x => x.OrgType == EOrgType.County).Sum(x => x.DefaultSatisfiedCount),
- NoSatisfiedCount = list.Where(x => x.OrgType == EOrgType.County).Sum(x => x.NoSatisfiedCount),
- NoEvaluateCount = list.Where(x => x.OrgType == EOrgType.County).Sum(x => x.NoEvaluateCount),
- NoPutThroughCount = list.Where(x => x.OrgType == EOrgType.County).Sum(x => x.NoPutThroughCount),
- NormalCount = list.Where(x => x.OrgType == EOrgType.County).Sum(x => x.NormalCount),
- VeryNoSatisfiedCount = list.Where(x => x.OrgType == EOrgType.County).Sum(x => x.VeryNoSatisfiedCount),
- };
- var citySumModel = new VisitAndOrgSatisfactionStatisticsDto()
- {
- OrgName = "市直合计",
- TotalSumCount = list.Where(x => x.OrgType == EOrgType.City).Sum(x => x.TotalSumCount),
- VerySatisfiedCount = list.Where(x => x.OrgType == EOrgType.City).Sum(x => x.VerySatisfiedCount),
- SatisfiedCount = list.Where(x => x.OrgType == EOrgType.City).Sum(x => x.SatisfiedCount),
- RegardedAsSatisfiedCount = list.Where(x => x.OrgType == EOrgType.City).Sum(x => x.RegardedAsSatisfiedCount),
- DefaultSatisfiedCount = list.Where(x => x.OrgType == EOrgType.City).Sum(x => x.DefaultSatisfiedCount),
- NoSatisfiedCount = list.Where(x => x.OrgType == EOrgType.City).Sum(x => x.NoSatisfiedCount),
- NoEvaluateCount = list.Where(x => x.OrgType == EOrgType.City).Sum(x => x.NoEvaluateCount),
- NoPutThroughCount = list.Where(x => x.OrgType == EOrgType.City).Sum(x => x.NoPutThroughCount),
- NormalCount = list.Where(x => x.OrgType == EOrgType.City).Sum(x => x.NormalCount),
- VeryNoSatisfiedCount = list.Where(x => x.OrgType == EOrgType.City).Sum(x => x.VeryNoSatisfiedCount),
- };
- var sumModel = new VisitAndOrgSatisfactionStatisticsDto()
- {
- OrgName = "总计",
- TotalSumCount = list.Sum(x => x.TotalSumCount),
- VerySatisfiedCount = list.Sum(x => x.VerySatisfiedCount),
- SatisfiedCount = list.Sum(x => x.SatisfiedCount),
- RegardedAsSatisfiedCount = list.Sum(x => x.RegardedAsSatisfiedCount),
- DefaultSatisfiedCount = list.Sum(x => x.DefaultSatisfiedCount),
- NoSatisfiedCount = list.Sum(x => x.NoSatisfiedCount),
- NoEvaluateCount = list.Sum(x => x.NoEvaluateCount),
- NoPutThroughCount = list.Sum(x => x.NoPutThroughCount),
- NormalCount = list.Sum(x => x.NormalCount),
- VeryNoSatisfiedCount = list.Sum(x => x.VeryNoSatisfiedCount),
- };
- return new VisitAndOrgSatisfactionStatisticsResultDto { DataList = list, CountySumModel = countySumModel, CitySumModel = citySumModel, SumModel = sumModel };
- }
- /// <summary>
- /// 部门满意度统计导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("visit-org-statisfaction-org-detail/_export")]
- public async Task<FileStreamResult> VisitAndOrgStatisfactionOrgDetailExport([FromBody] ExportExcelDto<PagedKeywordSonRequest> dto)
- {
- var list = await _orderApplication.VisitAndOrgStatisfactionOrgDetail(dto.QueryDto);
- var countySumModel = new VisitAndOrgSatisfactionStatisticsDto()
- {
- OrgName = "区县合计",
- TotalSumCount = list.Where(x => x.OrgType == EOrgType.County).Sum(x => x.TotalSumCount),
- VerySatisfiedCount = list.Where(x => x.OrgType == EOrgType.County).Sum(x => x.VerySatisfiedCount),
- SatisfiedCount = list.Where(x => x.OrgType == EOrgType.County).Sum(x => x.SatisfiedCount),
- RegardedAsSatisfiedCount = list.Where(x => x.OrgType == EOrgType.County).Sum(x => x.RegardedAsSatisfiedCount),
- DefaultSatisfiedCount = list.Where(x => x.OrgType == EOrgType.County).Sum(x => x.DefaultSatisfiedCount),
- NoSatisfiedCount = list.Where(x => x.OrgType == EOrgType.County).Sum(x => x.NoSatisfiedCount),
- NoEvaluateCount = list.Where(x => x.OrgType == EOrgType.County).Sum(x => x.NoEvaluateCount),
- NoPutThroughCount = list.Where(x => x.OrgType == EOrgType.County).Sum(x => x.NoPutThroughCount),
- NormalCount = list.Where(x => x.OrgType == EOrgType.County).Sum(x => x.NormalCount),
- VeryNoSatisfiedCount = list.Where(x => x.OrgType == EOrgType.County).Sum(x => x.VeryNoSatisfiedCount),
- };
- var citySumModel = new VisitAndOrgSatisfactionStatisticsDto()
- {
- OrgName = "市直合计",
- TotalSumCount = list.Where(x => x.OrgType == EOrgType.City).Sum(x => x.TotalSumCount),
- VerySatisfiedCount = list.Where(x => x.OrgType == EOrgType.City).Sum(x => x.VerySatisfiedCount),
- SatisfiedCount = list.Where(x => x.OrgType == EOrgType.City).Sum(x => x.SatisfiedCount),
- RegardedAsSatisfiedCount = list.Where(x => x.OrgType == EOrgType.City).Sum(x => x.RegardedAsSatisfiedCount),
- DefaultSatisfiedCount = list.Where(x => x.OrgType == EOrgType.City).Sum(x => x.DefaultSatisfiedCount),
- NoSatisfiedCount = list.Where(x => x.OrgType == EOrgType.City).Sum(x => x.NoSatisfiedCount),
- NoEvaluateCount = list.Where(x => x.OrgType == EOrgType.City).Sum(x => x.NoEvaluateCount),
- NoPutThroughCount = list.Where(x => x.OrgType == EOrgType.City).Sum(x => x.NoPutThroughCount),
- NormalCount = list.Where(x => x.OrgType == EOrgType.City).Sum(x => x.NormalCount),
- VeryNoSatisfiedCount = list.Where(x => x.OrgType == EOrgType.City).Sum(x => x.VeryNoSatisfiedCount),
- };
- var sumModel = new VisitAndOrgSatisfactionStatisticsDto()
- {
- OrgName = "总计",
- TotalSumCount = list.Sum(x => x.TotalSumCount),
- VerySatisfiedCount = list.Sum(x => x.VerySatisfiedCount),
- SatisfiedCount = list.Sum(x => x.SatisfiedCount),
- RegardedAsSatisfiedCount = list.Sum(x => x.RegardedAsSatisfiedCount),
- DefaultSatisfiedCount = list.Sum(x => x.DefaultSatisfiedCount),
- NoSatisfiedCount = list.Sum(x => x.NoSatisfiedCount),
- NoEvaluateCount = list.Sum(x => x.NoEvaluateCount),
- NoPutThroughCount = list.Sum(x => x.NoPutThroughCount),
- NormalCount = list.Sum(x => x.NormalCount),
- VeryNoSatisfiedCount = list.Sum(x => x.VeryNoSatisfiedCount),
- };
- list.Add(countySumModel);
- list.Add(citySumModel);
- list.Add(sumModel);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = list
- .Select(stu => _mapper.Map(stu, typeof(VisitAndOrgSatisfactionStatisticsDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "部门满意度统计数据");
- }
- /// <summary>
- /// 部门满意度明细
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("visit-org-satisfaction-detail")]
- public async Task<PagedDto<OrgVisitDetailListResp>> VisitAndOrgSatisfactionDetail([FromQuery] VisitAndOrgSatisfactionDetailDto dto)
- {
- //var (total, items) = await _orderApplication.VisitAndOrgSatisfactionDetail(dto)
- var (total, items) = await _orderRepository.VisitAndOrgSatisfactionDetail(dto)
- .ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
- return new PagedDto<OrgVisitDetailListResp>(total, _mapper.Map<IReadOnlyList<OrgVisitDetailListResp>>(items));
- }
- /// <summary>
- /// 部门满意度明细导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("visit-org-satisfaction-detail/_export")]
- public async Task<FileStreamResult> VisitAndOrgSatisfactionDetailExport([FromBody] ExportExcelDto<VisitAndOrgSatisfactionDetailDto> dto)
- {
- var query = _orderRepository.VisitAndOrgSatisfactionDetail(dto.QueryDto);
- List<OrgVisitDetailListResp> data;
- if (dto.IsExportAll)
- {
- data = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- data = items;
- }
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = data
- .Select(stu => _mapper.Map(stu, typeof(OrgVisitDetailListResp), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "部门满意度明细数据");
- }
- /// <summary>
- /// 中心报表统计--宜宾
- /// </summary>
- /// <param name="StartTime"></param>
- /// <param name="EndTime"></param>
- /// <returns></returns>
- [HttpGet("center_report_forms_statistics")]
- public async Task<CenterReportStatisticsDto> CenterReportFormsStatistics(DateTime StartTime, DateTime EndTime)
- {
- CenterReportStatisticsDto centerReportStatisticsDto = new();
- //信件总量
- int sourceChannelCount = await _orderRepository.Queryable().Where(p => p.CreationTime >= StartTime && p.CreationTime <= EndTime).CountAsync();
- #region 通话记录
- //通话记录
- var callData = await _trCallRecordRepository.Queryable()
- .Where(p => p.CreatedTime >= StartTime && p.CreatedTime <= EndTime && p.Gateway != "82826886" && SqlFunc.Length(p.Gateway) != 4)
- .Select(o => new CenterReportCallDto
- {
- EffectiveCount = SqlFunc.AggregateSum(SqlFunc.IIF(o.OnState == EOnState.On, 1, 0)),//有效
- InvalidCount = SqlFunc.AggregateSum(SqlFunc.IIF(o.OnState == EOnState.NoOn /*&& o.BeginIvrTime.HasValue && o.BeginQueueTime.HasValue && o.BeginRingTime.HasValue*/, 1, 0)), //无效(排除队列挂断和IVR挂断)
- QueueByeCount = SqlFunc.AggregateSum(SqlFunc.IIF(o.CallDirection == ECallDirection.In && o.QueueTims > 0 && o.RingTimes == 0 && o.OnState == EOnState.NoOn, 1, 0)), //队列挂断
- IvrByeCount = SqlFunc.AggregateSum(SqlFunc.IIF(o.CallDirection == ECallDirection.In && o.BeginIvrTime.HasValue && !o.BeginQueueTime.HasValue && !o.BeginRingTime.HasValue && o.OnState == EOnState.NoOn, 1, 0)), //IVR挂断
- })
- .FirstAsync();
- if (callData != null)
- callData.InvalidCount = callData.InvalidCount - callData.QueueByeCount - callData.IvrByeCount;
- centerReportStatisticsDto.CenterReportCall = callData;
- #endregion
- #region 语音分类
- var callTypeDto = await _trCallRecordRepository.Queryable()
- .Where(x => x.CreatedTime >= StartTime && x.CreatedTime <= EndTime && SqlFunc.Length(x.Gateway) > 4 && x.CallDirection == ECallDirection.In)
- .GroupBy(x => x.CreatedTime.ToString("yyyy-MM-dd"))
- .Select(x => new IVRCallTypeDto()
- {
- PersonCallInCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.IvrDtmf.Substring(x.IvrDtmf.Length - 1, 1) == "1", 1, 0)),
- EnterpriseCallInCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.IvrDtmf.Substring(x.IvrDtmf.Length - 1, 1) == "2", 1, 0)),
- AiCallInCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.Gateway == "82826886", 1, 0)),
- }).FirstAsync();
- centerReportStatisticsDto.iVRCallTypeDto = callTypeDto;
- #endregion
- #region 工单
- //工单 信件情况
- var orderData = await _orderRepository.Queryable()
- .LeftJoin<SystemOrganize>((x, so) => x.ActualHandleOrgCode == so.Id)
- .Where((x, so) => x.CreationTime >= StartTime && x.CreationTime <= EndTime)
- .Select((x, so) => new CenterReportOrderDto
- {
- EffectiveCount = SqlFunc.AggregateSum(SqlFunc.IIF(true, 1, 0)),
- InvalidCount = 0,
- CompletedCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status >= EOrderStatus.Filed, 1, 0)),
- InProgressCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status < EOrderStatus.Filed, 1, 0)),
- CityAccept = SqlFunc.AggregateSum(SqlFunc.IIF(so.OrgType == EOrgType.City, 1, 0)),
- CountyAccept = SqlFunc.AggregateSum(SqlFunc.IIF(so.OrgType == EOrgType.County, 1, 0)),
- CenterAccept = SqlFunc.AggregateSum(SqlFunc.IIF(so.IsCenter, 1, 0)),
- })
- .FirstAsync();
- centerReportStatisticsDto.CenterReportOrder = orderData;
- //工单按时办结情况
- var orderCompletedData = await _orderRepository.Queryable()
- .LeftJoin<SystemOrganize>((x, so) => x.FileUserOrgId == so.Id)
- .Where((x, so) => x.CreationTime >= StartTime && x.CreationTime <= EndTime && x.Status >= EOrderStatus.Filed)
- .Select((x, so) => new OrderCompletedDto
- {
- CompletedCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status >= EOrderStatus.Filed, 1, 0)),
- ExpiredTimeCompletedCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status >= EOrderStatus.Filed && x.ExpiredTime > x.ActualHandleTime, 1, 0)),//超期已办
- CityExpiredTimeCompletedCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status >= EOrderStatus.Filed && x.ExpiredTime > x.ActualHandleTime && so.OrgType == EOrgType.City, 1, 0)),//市级超期已办
- CountyExpiredTimeCompletedCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status >= EOrderStatus.Filed && x.ExpiredTime > x.ActualHandleTime && so.OrgType == EOrgType.County, 1, 0)),//区县超期已办
- CenterExpiredTimeCompletedCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status >= EOrderStatus.Filed && x.ExpiredTime > x.ActualHandleTime && so.IsCenter, 1, 0)),//中心超期已办
- CityCompletedCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status >= EOrderStatus.Filed && so.OrgType == EOrgType.City, 1, 0)),
- CountyCompletedCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status >= EOrderStatus.Filed && so.OrgType == EOrgType.County, 1, 0)),
- CenterCompletedCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status >= EOrderStatus.Filed && so.IsCenter, 1, 0)),
- })
- .FirstAsync();
- centerReportStatisticsDto.orderCompletedDto = orderCompletedData;
- //工单办理时效
- var orderAgingData = await _orderRepository.Queryable()
- .LeftJoin<SystemOrganize>((x, so) => x.FileUserOrgId == so.Id)
- .Where((x, so) => x.CreationTime >= StartTime && x.CreationTime <= EndTime && x.Status >= EOrderStatus.Filed)
- .Select((x, so) => new
- {
- FileOrgIsCenter = x.FileOrgIsCenter.Value,
- CreationTimeHandleDurationWorkday = x.CreationTimeHandleDurationWorkday.HasValue ? x.CreationTimeHandleDurationWorkday : 0,
- CenterToOrgHandleDurationWorkday = x.CenterToOrgHandleDurationWorkday.HasValue ? x.CenterToOrgHandleDurationWorkday : 0,
- OrgType = so.OrgType
- })
- .MergeTable()
- .Select(temp => new OrderAgingDto
- {
- OrderCount = SqlFunc.AggregateSum(SqlFunc.IIF(true, 1, 0)),
- CompletedAging = SqlFunc.AggregateSum(SqlFunc.IIF(temp.FileOrgIsCenter, temp.CreationTimeHandleDurationWorkday, temp.CenterToOrgHandleDurationWorkday)),
- CityOrderCount = SqlFunc.AggregateSum(SqlFunc.IIF(temp.FileOrgIsCenter == false && temp.OrgType == EOrgType.City, 1, 0)),//市级
- CityCompletedAging = SqlFunc.AggregateSum(SqlFunc.IIF(temp.FileOrgIsCenter == false && temp.OrgType == EOrgType.City, temp.CenterToOrgHandleDurationWorkday, 0)),
- CountyOrderCount = SqlFunc.AggregateSum(SqlFunc.IIF(temp.FileOrgIsCenter == false && temp.OrgType == EOrgType.County, 1, 0)),//区县
- CountyCompletedAging = SqlFunc.AggregateSum(SqlFunc.IIF(temp.FileOrgIsCenter == false && temp.OrgType == EOrgType.County, temp.CenterToOrgHandleDurationWorkday, 0)),
- CenterOrderCount = SqlFunc.AggregateSum(SqlFunc.IIF(temp.FileOrgIsCenter, 1, 0)),//中心
- CenterCompletedAging = SqlFunc.AggregateSum(SqlFunc.IIF(temp.FileOrgIsCenter, temp.CreationTimeHandleDurationWorkday, 0)),
- })
- .FirstAsync();
- centerReportStatisticsDto.orderAgingDto = orderAgingData;
- #endregion
- #region 信件来源
- //信件来源
- var sourceChannelData = await _orderRepository.Queryable()
- .Where(p => p.CreationTime >= StartTime && p.CreationTime <= EndTime)
- .Select(it => new
- {
- SourceChannelCode = SqlFunc.IIF(SqlFunc.IsNullOrEmpty(it.SourceChannelCode), "QT", it.SourceChannelCode)
- })
- .MergeTable()//将查询出来的结果合并成一个新表
- .GroupBy(it => new { it.SourceChannelCode })//对新表进行分组
- .Select(it => new CenterReportOrderSourceChannelDto
- {
- Code = it.SourceChannelCode,
- CountNum = SqlFunc.AggregateCount(it.SourceChannelCode)
- })
- .ToListAsync();
- List<CenterReportOrderSourceChannelDto> sourceChannel = new()
- {
- new CenterReportOrderSourceChannelDto
- {
- Name = "来源总量",
- Code = "All",
- CountNum = sourceChannelCount
- }
- };
- var sourceChannelDic = _sysDicDataCacheManager.GetSysDicDataCache(SysDicTypeConsts.SourceChannel);
- foreach (var item in sourceChannelDic)
- {
- sourceChannel.Add(new CenterReportOrderSourceChannelDto
- {
- Name = item.DicDataName,
- Code = item.DicTypeCode,
- CountNum = sourceChannelData.Find(p => p.Code == item.DicDataValue)?.CountNum ?? 0
- });
- }
- centerReportStatisticsDto.CenterReportOrderSourceChannels = sourceChannel;
- #endregion
- #region 信件分类
- //信件来源
- var acceptTypeData = await _orderRepository.Queryable(false, false, false)
- .Where(p => p.CreationTime >= StartTime && p.CreationTime <= EndTime)
- .Select(it => new
- {
- AcceptTypeCode = SqlFunc.IIF(SqlFunc.IsNullOrEmpty(it.AcceptTypeCode), "40", it.AcceptTypeCode),
- FileOrgIsCenter = it.FileOrgIsCenter.HasValue ? it.FileOrgIsCenter : true,
- CreationTimeHandleDurationWorkday = it.CreationTimeHandleDurationWorkday.HasValue ? it.CenterToOrgHandleDurationWorkday : 0,
- CenterToOrgHandleDurationWorkday = it.CenterToOrgHandleDurationWorkday.HasValue ? it.CenterToOrgHandleDurationWorkday : 0,
- })
- .MergeTable()//将查询出来的结果合并成一个新表
- .GroupBy(temp => new { temp.AcceptTypeCode })//对新表进行分组
- .Select(temp => new CenterReportOrderSourceChannelDto
- {
- Code = temp.AcceptTypeCode,
- CountNum = SqlFunc.AggregateCount(temp.AcceptTypeCode),
- CompletedAging = SqlFunc.AggregateSum(SqlFunc.IIF(temp.FileOrgIsCenter == true, temp.CreationTimeHandleDurationWorkday, temp.CenterToOrgHandleDurationWorkday))
- })
- .ToListAsync();
- List<CenterReportOrderSourceChannelDto> acceptType = new();
- var acceptTypeDic = _sysDicDataCacheManager.GetSysDicDataCache(SysDicTypeConsts.AcceptType);
- foreach (var item in acceptTypeDic)
- {
- acceptType.Add(new CenterReportOrderSourceChannelDto
- {
- AllCountNum = sourceChannelCount,
- Name = item.DicDataName,
- Code = item.DicTypeCode,
- CountNum = acceptTypeData.Find(p => p.Code == item.DicDataValue)?.CountNum ?? 0,
- CompletedAging = acceptTypeData.Find(p => p.Code == item.DicDataValue)?.CompletedAging ?? 0
- });
- }
- centerReportStatisticsDto.CenterReportOrderAcceptTypes = acceptType;
- #endregion
- #region 信件回访量
- //信件回访量
- CenterReportVisitdDto centerReportVisitd = new()
- {
- Visitd = await _orderVisitRepository.Queryable()
- .Where(x => x.VisitTime >= StartTime && x.VisitTime <= EndTime && x.VisitState == EVisitState.Visited).CountAsync(),
- WaitVisitd = await _orderVisitRepository.Queryable()
- .Where(x => x.VisitTime >= StartTime && x.VisitTime <= EndTime && x.VisitState != EVisitState.None && x.VisitState != EVisitState.Visited).CountAsync()
- };
- //
- var data = await _orderVisitDetailRepository.Queryable()
- .LeftJoin<OrderVisit>((it, o) => it.VisitId == o.Id)
- .LeftJoin<SystemOrganize>((it, o, so) => it.VisitOrgCode == so.Id)
- .Where((it, o, so) => it.VisitTarget == EVisitTarget.Org && o.VisitTime >= StartTime && o.VisitTime <= EndTime && o.VisitState == EVisitState.Visited)
- .Select((it, o, so) => new
- {
- Dissatisfied = SqlFunc.AggregateSum(SqlFunc.IIF(SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "1") || SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "2"), 1, 0)),
- Satisfied = SqlFunc.AggregateSum(SqlFunc.IIF(SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "1") || SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "2"), 0, 1)),
- CityDissatisfied = SqlFunc.AggregateSum(SqlFunc.IIF((SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "1") || SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "2")) && so.OrgType == EOrgType.City, 1, 0)),
- CitySatisfied = SqlFunc.AggregateSum(SqlFunc.IIF(!SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "1") && !SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "2") && so.OrgType == EOrgType.City, 1, 0)),
- CountyDissatisfied = SqlFunc.AggregateSum(SqlFunc.IIF((SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "1") || SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "2")) && so.OrgType == EOrgType.County, 1, 0)),
- CountySatisfied = SqlFunc.AggregateSum(SqlFunc.IIF(!SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "1") && !SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "2") && so.OrgType == EOrgType.County, 1, 0)),
- CenterDissatisfied = SqlFunc.AggregateSum(SqlFunc.IIF((SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "1") || SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "2")) && so.IsCenter, 1, 0)),
- CenterSatisfied = SqlFunc.AggregateSum(SqlFunc.IIF(!SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "1") && !SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "2") && so.IsCenter, 1, 0)),
- OrgDissatisfied = SqlFunc.AggregateSum(SqlFunc.IIF((SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "1") || SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "2")) && !so.IsCenter, 1, 0)),
- OrgSatisfied = SqlFunc.AggregateSum(SqlFunc.IIF(!SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "1") && !SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "2") && !so.IsCenter, 1, 0)),
- })
- .FirstAsync();
- if (data.Satisfied > 0)
- {
- var count = data.Satisfied + data.Dissatisfied;
- centerReportVisitd.AllRate = Math.Round((data.Satisfied / (double)count) * 100, 2);
- }
- if (data.OrgSatisfied > 0)
- {
- var count = data.OrgSatisfied + data.OrgDissatisfied;
- centerReportVisitd.OrgRate = Math.Round((data.OrgSatisfied / (double)count) * 100, 2);
- }
- if (data.CitySatisfied > 0)
- {
- var count = data.CitySatisfied + data.CityDissatisfied;
- centerReportVisitd.CityRate = Math.Round((data.CitySatisfied / (double)count) * 100, 2);
- }
- if (data.CountySatisfied > 0)
- {
- var count = data.CountySatisfied + data.CountyDissatisfied;
- centerReportVisitd.CountyRate = Math.Round((data.CountySatisfied / (double)count) * 100, 2);
- }
- if (data.CenterSatisfied > 0)
- {
- var count = data.CenterSatisfied + data.CenterDissatisfied;
- centerReportVisitd.CenterRate = Math.Round((data.CenterSatisfied / (double)count) * 100, 2);
- }
- centerReportVisitd.Dissatisfied = data.Dissatisfied;
- centerReportVisitd.CityDissatisfied = data.CityDissatisfied;
- centerReportVisitd.CountyDissatisfied = data.CountyDissatisfied;
- //部门
- //var listOrg = await _orderVisitDetailRepository.Queryable()
- // .LeftJoin<OrderVisit>((it, o) => it.VisitId == o.Id)
- // .Where((it, o) => it.VisitTarget == EVisitTarget.Org && o.VisitTime >= StartTime && o.VisitTime <= EndTime && o.VisitState == EVisitState.Visited)
- // .Select((it, o) => new Satisfaction
- // {
- // Dissatisfied = SqlFunc.AggregateSum(SqlFunc.IIF(SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "1") || SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "2"), 1, 0)),
- // Satisfied = SqlFunc.AggregateSum(SqlFunc.IIF(SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "1") || SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "2"), 0, 1)),
- // })
- // .ToListAsync();
- //if (listOrg != null && listOrg.Count > 0)
- //{
- // var SatisfiedCount = listOrg[0].Satisfied + listOrg[0].Satisfied;
- // if (SatisfiedCount > 0 && listOrg[0].Satisfied > 0)
- // centerReportVisitd.OrgRate = Math.Round((listOrg[0].Satisfied / (double)SatisfiedCount) * 100, 2);
- //}
- ////if (centerReportVisitd.Visitd > 0 && listOrg != null && listOrg.Count > 0 && listOrg[0].Satisfied > 0)
- ////centerReportVisitd.OrgRate = Math.Round((listOrg[0].Satisfied / (double)centerReportVisitd.Visitd) * 100, 2);
- ////坐席
- //var listSet = await _orderVisitDetailRepository.Queryable()
- // .LeftJoin<OrderVisit>((it, o) => it.VisitId == o.Id)
- // .Where((it, o) => it.VisitTarget == EVisitTarget.Seat && o.VisitTime >= StartTime && o.VisitTime <= EndTime && o.VisitState == EVisitState.Visited)
- // .Select((it, o) => new Satisfaction
- // {
- // Dissatisfied = SqlFunc.AggregateSum(SqlFunc.IIF(it.SeatEvaluate == ESeatEvaluate.NoSatisfied, 1, 0)),
- // Satisfied = SqlFunc.AggregateSum(SqlFunc.IIF(it.SeatEvaluate != ESeatEvaluate.NoSatisfied, 1, 0)),
- // }).ToListAsync();
- //if (listSet != null && listSet.Count > 0)
- //{
- // var SatisfiedCount = listSet[0].Satisfied + listSet[0].Satisfied;
- // if (SatisfiedCount > 0 && listSet[0].Satisfied > 0)
- // centerReportVisitd.OrgRate = Math.Round((listSet[0].Satisfied / (double)SatisfiedCount) * 100, 2);
- //}
- //if (centerReportVisitd.Visitd > 0 && listSet != null && listSet.Count > 0 && listSet[0].Satisfied > 0)
- // centerReportVisitd.SeatsRate = Math.Round((listSet[0].Satisfied / (double)centerReportVisitd.Visitd) * 100, 2);
- centerReportStatisticsDto.CenterReportVisitd = centerReportVisitd;
- #endregion
- #region 信件分布情况
- //市直部门
- var listOrgStatisticsCityAll = await _orderRepository.Queryable()
- .Where(o => o.CreationTime >= StartTime && o.CreationTime <= EndTime)
- .Select(o => new
- {
- OrgCode = o.ActualHandleOrgCode == null || o.ActualHandleOrgCode == "" ? "001" : o.ActualHandleOrgCode.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6")),
- })
- .MergeTable()
- .LeftJoin<SystemOrganize>((o, s) => o.OrgCode == s.Id)
- .Where((o, s) => s.OrgType == EOrgType.City || s.OrgType == EOrgType.Province)
- .GroupBy((o, s) => new
- {
- o.OrgCode,
- s.Name
- })
- .Select((o, s) => new OrgStatistics
- {
- CountNum = SqlFunc.AggregateCount(o.OrgCode),
- OrgName = s.Name
- }).ToListAsync();
- centerReportStatisticsDto.OrgStatisticsCityAll = new OrgStatisticsAll
- {
- OrgStatistics = listOrgStatisticsCityAll
- };
- //区县部门
- var listOrgStatisticsAreaAll = await _orderRepository.Queryable()
- .Where(o => o.CreationTime >= StartTime && o.CreationTime <= EndTime)
- .Select(o => new
- {
- OrgCode = o.ActualHandleOrgCode == null || o.ActualHandleOrgCode == "" ? "001" : o.ActualHandleOrgCode.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6")),
- })
- .MergeTable()
- .LeftJoin<SystemOrganize>((o, s) => o.OrgCode == s.Id)
- .Where((o, s) => s.OrgType == EOrgType.County)
- .GroupBy((o, s) => new
- {
- o.OrgCode,
- s.Name
- })
- .Select((o, s) => new OrgStatistics
- {
- CountNum = SqlFunc.AggregateCount(o.OrgCode),
- OrgName = s.Name
- }).ToListAsync();
- centerReportStatisticsDto.OrgStatisticsAreaAll = new OrgStatisticsAll
- {
- OrgStatistics = listOrgStatisticsAreaAll
- };
- #endregion
- #region 企业服务办件情况
- var enterpriseOrderDto = await _orderRepository.Queryable()
- .LeftJoin<SystemOrganize>((x, so) => x.ActualHandleOrgCode == so.Id)
- .Where((x, so) => x.CreationTime >= StartTime && x.CreationTime <= EndTime && x.IdentityType == EIdentityType.Enterprise)
- .Select((x, so) => new
- {
- FileOrgIsCenter = x.FileOrgIsCenter.Value,
- CreationTimeHandleDurationWorkday = x.CreationTimeHandleDurationWorkday.HasValue ? x.CreationTimeHandleDurationWorkday : 0,
- CenterToOrgHandleDurationWorkday = x.CenterToOrgHandleDurationWorkday.HasValue ? x.CenterToOrgHandleDurationWorkday : 0,
- OrgType = so.OrgType
- })
- .MergeTable()
- .Select(temp => new EnterpriseOrderDto
- {
- OrderCount = SqlFunc.AggregateSum(SqlFunc.IIF(true, 1, 0)),
- CompletedAging = SqlFunc.AggregateSum(SqlFunc.IIF(temp.FileOrgIsCenter, temp.CreationTimeHandleDurationWorkday, temp.CenterToOrgHandleDurationWorkday)),
- CityOrderCount = SqlFunc.AggregateSum(SqlFunc.IIF(temp.FileOrgIsCenter == false && temp.OrgType == EOrgType.City, 1, 0)),//市级
- CityCompletedAging = SqlFunc.AggregateSum(SqlFunc.IIF(temp.FileOrgIsCenter == false && temp.OrgType == EOrgType.City, temp.CenterToOrgHandleDurationWorkday, 0)),
- CountyOrderCount = SqlFunc.AggregateSum(SqlFunc.IIF(temp.FileOrgIsCenter == false && temp.OrgType == EOrgType.County, 1, 0)),//区县
- CountyCompletedAging = SqlFunc.AggregateSum(SqlFunc.IIF(temp.FileOrgIsCenter == false && temp.OrgType == EOrgType.County, temp.CenterToOrgHandleDurationWorkday, 0)),
- CenterOrderCount = SqlFunc.AggregateSum(SqlFunc.IIF(temp.FileOrgIsCenter, 1, 0)),//中心
- CenterCompletedAging = SqlFunc.AggregateSum(SqlFunc.IIF(temp.FileOrgIsCenter, temp.CreationTimeHandleDurationWorkday, 0)),
- })
- .FirstAsync();
- centerReportStatisticsDto.enterpriseOrderDto = enterpriseOrderDto;
- var enterpriseOrderDto2 = await _orderVisitDetailRepository.Queryable()
- .Includes(it => it.OrderVisit, ov => ov.Order)
- .LeftJoin<SystemOrganize>((it, so) => it.VisitOrgCode == so.Id)
- .Where((it, so) => it.VisitTarget == EVisitTarget.Org && it.OrderVisit.VisitTime >= StartTime && it.OrderVisit.VisitTime <= EndTime && it.OrderVisit.VisitState == EVisitState.Visited)
- .GroupBy((it, so) => it.Id)
- .Select((it, so) => new EnterpriseOrderDto
- {
- VisitdCount = SqlFunc.AggregateSum(SqlFunc.IIF(true, 1, 0)),
- Dissatisfied = SqlFunc.AggregateSum(SqlFunc.IIF(SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "1") || SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "2"), 1, 0)),
- Satisfied = SqlFunc.AggregateSum(SqlFunc.IIF(!SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "1") && !SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "2"), 1, 0)),
- CityDissatisfied = SqlFunc.AggregateSum(SqlFunc.IIF((SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "1") || SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "2")) && so.OrgType == EOrgType.City, 1, 0)),
- CitySatisfied = SqlFunc.AggregateSum(SqlFunc.IIF(!SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "1") && !SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "2") && so.OrgType == EOrgType.City, 1, 0)),
- CountyDissatisfied = SqlFunc.AggregateSum(SqlFunc.IIF((SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "1") || SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "2")) && so.OrgType == EOrgType.County, 1, 0)),
- CountySatisfied = SqlFunc.AggregateSum(SqlFunc.IIF(!SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "1") && !SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "2") && so.OrgType == EOrgType.County, 1, 0)),
- })
- .FirstAsync();
- centerReportStatisticsDto.enterpriseOrderDto.VisitdCount = enterpriseOrderDto2.VisitdCount;
- centerReportStatisticsDto.enterpriseOrderDto.Dissatisfied = enterpriseOrderDto2.Dissatisfied;
- centerReportStatisticsDto.enterpriseOrderDto.CityDissatisfied = enterpriseOrderDto2.CityDissatisfied;
- centerReportStatisticsDto.enterpriseOrderDto.CountyDissatisfied = enterpriseOrderDto2.CountyDissatisfied;
- centerReportStatisticsDto.enterpriseOrderDto.Satisfied = enterpriseOrderDto2.Satisfied;
- centerReportStatisticsDto.enterpriseOrderDto.CitySatisfied = enterpriseOrderDto2.CitySatisfied;
- centerReportStatisticsDto.enterpriseOrderDto.CountySatisfied = enterpriseOrderDto2.CountySatisfied;
- #endregion
- return centerReportStatisticsDto;
- }
- /// <summary>
- /// 中心报表统计--自贡
- /// </summary>
- /// <param name="StartTime"></param>
- /// <param name="EndTime"></param>
- /// <returns></returns>
- [HttpGet("center_report_forms_statistics_zg")]
- public async Task<CenterReportStatisticsDto> ZgCenterReportFormsStatistics(DateTime StartTime, DateTime EndTime)
- {
- CenterReportStatisticsDto centerReportStatisticsDto = new();
- //信件总量
- int sourceChannelCount = await _orderRepository.Queryable().Where(p => p.CreationTime >= StartTime && p.CreationTime <= EndTime).CountAsync();
- #region 1、通话记录
- //通话记录
- var callData = await _callNativeRepository.Queryable()
- .Where(p => p.CreationTime >= StartTime && p.CreationTime <= EndTime)
- // .Where(p => p.Gateway != "82826886" && SqlFunc.Length(p.Gateway) != 4)
- .Select(p => new CenterReportCallInfoDto
- {
- AllCallCount = SqlFunc.AggregateSum(1),//话务总量
- InTotal = SqlFunc.AggregateSum(SqlFunc.IIF(p.Direction == ECallDirection.In, 1, 0)),//呼入总量
- InConnectionQuantity = SqlFunc.AggregateSum(SqlFunc.IIF(p.Direction == ECallDirection.In && p.AnsweredTime != null, 1, 0)),//呼入接通量
- InHanguped = SqlFunc.AggregateSum(SqlFunc.IIF(p.Direction == ECallDirection.In && p.AnsweredTime == null, 1, 0)),//呼入未接通
- QueueByeCount = SqlFunc.AggregateSum(SqlFunc.IIF(p.Direction == ECallDirection.In && p.WaitDuration > 0 && p.RingDuration == 0 && p.AnsweredTime == null, 1, 0)), //队列挂断
- IvrByeCount = SqlFunc.AggregateSum(SqlFunc.IIF(p.Direction == ECallDirection.In && p.BeginIvrTime.HasValue && !p.BeginQueueTime.HasValue && !p.BeginRingTime.HasValue && p.AnsweredTime == null, 1, 0)), //IVR挂断
- OutTotal = SqlFunc.AggregateSum(SqlFunc.IIF(p.Direction == ECallDirection.Out, 1, 0)),//呼出总量
- OutConnectionQuantity = SqlFunc.AggregateSum(SqlFunc.IIF(p.TelNo != "0" && p.Direction == ECallDirection.Out && p.AnsweredTime != null, 1, 0)),//呼出接通量
- OutHanguped = SqlFunc.AggregateSum(SqlFunc.IIF(p.TelNo != "0" && p.Direction == ECallDirection.Out && p.AnsweredTime == null, 1, 0)),//呼出未接通
- })
- .FirstAsync();
- centerReportStatisticsDto.CenterReportCallInfoDto = callData;
- #endregion
- #region 2、信件回访量
- //信件回访量
- var centerReportVisitd = await _orderVisitRepository.Queryable()
- .Where(x => x.VisitTime >= StartTime && x.VisitTime <= EndTime)
- .Select(x => new CenterReportVisitdDto
- {
- Visitd = SqlFunc.AggregateSum(SqlFunc.IIF(x.VisitState == EVisitState.Visited, 1, 0)),//已回访
- CallVisitd = SqlFunc.AggregateSum(SqlFunc.IIF(x.VisitState == EVisitState.Visited && x.VisitType == EVisitType.CallVisit, 1, 0)),// 已回访--电话
- SmsVisitd = SqlFunc.AggregateSum(SqlFunc.IIF(x.VisitState == EVisitState.Visited && x.VisitType == EVisitType.SmsVisit, 1, 0)),//已回访--短信
- OtherVisitd = SqlFunc.AggregateSum(SqlFunc.IIF(x.VisitState == EVisitState.Visited && x.VisitType != EVisitType.CallVisit && x.VisitType != EVisitType.SmsVisit, 1, 0)),//其他回访
- WaitVisitd = SqlFunc.AggregateSum(SqlFunc.IIF(x.VisitState != EVisitState.None && x.VisitState != EVisitState.Visited, 1, 0)),//待回访
- }).FirstAsync();
- //部门
- var listOrg = await _orderVisitDetailRepository.Queryable()
- .LeftJoin<OrderVisit>((it, o) => it.VisitId == o.Id)
- .Where((it, o) => it.VisitTarget == EVisitTarget.Org && o.VisitTime >= StartTime && o.VisitTime <= EndTime && o.VisitState == EVisitState.Visited)
- .Select((it, o) => new Satisfaction
- {
- Dissatisfied = SqlFunc.AggregateSum(SqlFunc.IIF(SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "1") || SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "2"), 1, 0)),
- Satisfied = SqlFunc.AggregateSum(SqlFunc.IIF(SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "1") || SqlFunc.JsonListObjectAny(it.OrgProcessingResults, "key", "2"), 0, 1)),
- })
- .FirstAsync();
- //计算部门满意度
- if (listOrg != null)
- {
- var satisfiedCount = listOrg.Satisfied + listOrg.Dissatisfied;
- if (satisfiedCount > 0 && listOrg.Satisfied > 0)
- centerReportVisitd.OrgRate = Math.Round((listOrg.Satisfied / (double)satisfiedCount) * 100, 2);
- }
- //坐席
- var listSet = await _orderVisitDetailRepository.Queryable()
- .LeftJoin<OrderVisit>((it, o) => it.VisitId == o.Id)
- .Where((it, o) => it.VisitTarget == EVisitTarget.Seat && o.VisitTime >= StartTime && o.VisitTime <= EndTime && o.VisitState == EVisitState.Visited)
- .Select((it, o) => new Satisfaction
- {
- Dissatisfied = SqlFunc.AggregateSum(SqlFunc.IIF(it.SeatEvaluate == ESeatEvaluate.NoSatisfied, 1, 0)),
- Satisfied = SqlFunc.AggregateSum(SqlFunc.IIF(it.SeatEvaluate != ESeatEvaluate.NoSatisfied, 1, 0)),
- })
- .FirstAsync();
- //计算坐席满意度
- if (listSet != null)
- {
- var satisfiedCount = listSet.Satisfied + listSet.Dissatisfied;
- if (satisfiedCount > 0 && listSet.Satisfied > 0)
- centerReportVisitd.SeatsRate = Math.Round((listSet.Satisfied / (double)satisfiedCount) * 100, 2);
- }
- centerReportStatisticsDto.CenterReportVisitd = centerReportVisitd;
- #endregion
- #region 3、工单
- //工单
- var orderData = await _orderRepository.Queryable()
- .Where(p => p.CreationTime >= StartTime && p.CreationTime <= EndTime)
- .Select(x => new CenterReportOrderDto
- {
- EffectiveCount = SqlFunc.AggregateSum(SqlFunc.IIF(true, 1, 0)),//有效
- InvalidCount = 0,//无效
- CompletedCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status >= EOrderStatus.Filed, 1, 0)),//已办结
- OnTimeCompletedCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status >= EOrderStatus.Filed && x.ExpiredTime < x.ActualHandleTime, 1, 0)),//按时办结
- CenterCompletedCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status >= EOrderStatus.Filed && x.ProcessType == EProcessType.Zhiban, 1, 0)),//中心办结
- OrgCompletedCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status >= EOrderStatus.Filed && x.ProcessType == EProcessType.Jiaoban, 1, 0)),//部门办结
- InProgressCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status < EOrderStatus.Filed, 1, 0)),//在办
- CenterInProgressCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status < EOrderStatus.Filed && x.ProcessType == EProcessType.Zhiban, 1, 0)),//中心在办
- OrgInProgressCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status < EOrderStatus.Filed && x.ProcessType == EProcessType.Jiaoban, 1, 0))//部门在办
- })
- .FirstAsync();
- centerReportStatisticsDto.CenterReportOrder = orderData;
- #endregion
- #region 4、信件来源
- //信件来源
- var sourceChannelData = _orderRepository.Queryable()
- .Where(p => p.CreationTime >= StartTime && p.CreationTime <= EndTime)
- .Select(it => new
- {
- SourceChannelCode = SqlFunc.IIF(SqlFunc.IsNullOrEmpty(it.SourceChannelCode), "QT", it.SourceChannelCode)
- })
- .MergeTable()//将查询出来的结果合并成一个新表
- .GroupBy(it => new { it.SourceChannelCode })//对新表进行分组
- .Select(it => new CenterReportOrderSourceChannelDto
- {
- Code = it.SourceChannelCode,
- CountNum = SqlFunc.AggregateCount(it.SourceChannelCode)
- });
- var sourceData = await _systemDicDataRepository.Queryable()
- .LeftJoin(sourceChannelData, (s, p) => s.DicDataValue == p.Code)
- .Where((s, p) => s.DicTypeCode == "SourceChannel" && s.IsShow == true)
- .Select((s, p) => new CenterReportOrderSourceChannelDto
- {
- Code = s.DicDataValue,
- Name = s.DicDataName,
- CountNum = p.CountNum
- })
- .ToListAsync();
- centerReportStatisticsDto.CenterReportOrderSourceChannels = sourceData;
- #endregion
- #region 5、信件分类
- //信件来源 AcceptType
- var acceptTypeData = _orderRepository.Queryable(false, false, false)
- .Where(p => p.CreationTime >= StartTime && p.CreationTime <= EndTime)
- .Select(it => new
- {
- AcceptTypeCode = SqlFunc.IIF(SqlFunc.IsNullOrEmpty(it.AcceptTypeCode), "40", it.AcceptTypeCode)
- })
- .MergeTable()//将查询出来的结果合并成一个新表
- .GroupBy(it => new { it.AcceptTypeCode })//对新表进行分组
- .Select(it => new CenterReportOrderSourceChannelDto
- {
- Code = it.AcceptTypeCode,
- CountNum = SqlFunc.AggregateCount(it.AcceptTypeCode)
- });
- var acceptType = await _systemDicDataRepository.Queryable()
- .LeftJoin(acceptTypeData, (s, p) => s.DicDataValue == p.Code)
- .Where((s, p) => s.DicTypeCode == "AcceptType" && s.IsShow == true)
- .Select((s, p) => new CenterReportOrderSourceChannelDto
- {
- AllCountNum = sourceChannelCount,
- Code = s.DicDataValue,
- Name = s.DicDataName,
- CountNum = p.CountNum
- })
- .ToListAsync();
- centerReportStatisticsDto.CenterReportOrderAcceptTypes = acceptType;
- #endregion
- #region 信件分布情况
- //市直部门
- var listOrgStatisticsCityAll = await _orderRepository.Queryable()
- .Where(o => o.CreationTime >= StartTime && o.CreationTime <= EndTime)
- .Select(o => new
- {
- OrgCode = o.ActualHandleOrgCode == null || o.ActualHandleOrgCode == "" ? "001" : o.ActualHandleOrgCode.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6")),
- })
- .MergeTable()
- .LeftJoin<SystemOrganize>((o, s) => o.OrgCode == s.Id)
- .Where((o, s) => s.OrgType == EOrgType.City || s.OrgType == EOrgType.Province)
- .GroupBy((o, s) => new
- {
- o.OrgCode,
- s.Name
- })
- .Select((o, s) => new OrgStatistics
- {
- CountNum = SqlFunc.AggregateCount(o.OrgCode),
- OrgName = s.Name
- }).ToListAsync();
- centerReportStatisticsDto.OrgStatisticsCityAll = new OrgStatisticsAll
- {
- OrgStatistics = listOrgStatisticsCityAll
- };
- //区县部门
- var listOrgStatisticsAreaAll = await _orderRepository.Queryable()
- .Where(o => o.CreationTime >= StartTime && o.CreationTime <= EndTime)
- .Select(o => new
- {
- OrgCode = o.ActualHandleOrgCode == null || o.ActualHandleOrgCode == "" ? "001" : o.ActualHandleOrgCode.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6")),
- })
- .MergeTable()
- .LeftJoin<SystemOrganize>((o, s) => o.OrgCode == s.Id)
- .Where((o, s) => s.OrgType == EOrgType.County)
- .GroupBy((o, s) => new
- {
- o.OrgCode,
- s.Name
- })
- .Select((o, s) => new OrgStatistics
- {
- CountNum = SqlFunc.AggregateCount(o.OrgCode),
- OrgName = s.Name
- }).ToListAsync();
- centerReportStatisticsDto.OrgStatisticsAreaAll = new OrgStatisticsAll
- {
- OrgStatistics = listOrgStatisticsAreaAll
- };
- #endregion
- return centerReportStatisticsDto;
- }
- /// <summary>
- /// 部门受理类型统计周期
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("department_acceptance_type_statistics")]
- public async Task<object> DepartmentAcceptanceTypeStatistics([FromQuery] DepartmentKeyWordRequest dto)
- {
- var items = await _orderReportApplication.DepartmentAcceptanceTypeStatistics(dto).ToListAsync();
- foreach (var item in items)
- {
- item.ZxAllTimes = Math.Round(((double)item.ZxAllTimes / 3600), 2);
- item.JyAllTimes = Math.Round(((double)item.JyAllTimes / 3600), 2);
- item.QzAllTimes = Math.Round(((double)item.QzAllTimes / 3600), 2);
- item.ByAllTimes = Math.Round(((double)item.ByAllTimes / 3600), 2);
- item.JbAllTimes = Math.Round(((double)item.JbAllTimes / 3600), 2);
- item.TsAllTimes = Math.Round(((double)item.TsAllTimes / 3600), 2);
- item.QtAllTimes = Math.Round(((double)item.QtAllTimes / 3600), 2);
- item.YjAllTimes = Math.Round(((double)item.YjAllTimes / 3600), 2);
- }
- var total = new DepartmentAcceptanceTypeStatisticsDto
- {
- OrgName = "合计",
- OrgCode = "",
- OrgType = "",
- ZxAllCount = items.Sum(p => p.ZxAllCount),
- ZxAllTimes = Math.Round(items.Sum(p => p.ZxAllTimes).Value, 2),
- ZxAcceptanceTypeCode = "10",
- JyAllCount = items.Sum(p => p.JyAllCount),
- JyAllTimes = Math.Round(items.Sum(p => p.JyAllTimes).Value, 2),
- JyAcceptanceTypeCode = "15",
- QzAllCount = items.Sum(p => p.QzAllCount),
- QzAllTimes = Math.Round(items.Sum(p => p.QzAllTimes).Value, 2),
- QzAcceptanceTypeCode = "20",
- ByAllCount = items.Sum(p => p.ByAllCount),
- ByAllTimes = Math.Round(items.Sum(p => p.ByAllTimes).Value, 2),
- ByAcceptanceTypeCode = "25",
- JbAllCount = items.Sum(p => p.JbAllCount),
- JbAllTimes = Math.Round(items.Sum(p => p.JbAllTimes).Value, 2),
- JbAcceptanceTypeCode = "30",
- TsAllCount = items.Sum(p => p.TsAllCount),
- TsAllTimes = Math.Round(items.Sum(p => p.TsAllTimes).Value, 2),
- TsAcceptanceTypeCode = "35",
- QtAllCount = items.Sum(p => p.QtAllCount),
- QtAllTimes = Math.Round(items.Sum(p => p.QtAllTimes).Value, 2),
- QtAcceptanceTypeCode = "40",
- YjAllCount = items.Sum(p => p.YjAllCount),
- YjAllTimes = Math.Round(items.Sum(p => p.YjAllTimes).Value, 2),
- YjAcceptanceTypeCode = "1"
- };
- return new { List = items, Total = total };
- }
- /// <summary>
- /// 部门受理类型统计周期---导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("department_acceptance_type_statistics_export")]
- public async Task<FileStreamResult> ExportDepartmentAcceptanceTypeStatistics([FromBody] ExportExcelDto<DepartmentKeyWordRequest> dto)
- {
- var query = _orderReportApplication.DepartmentAcceptanceTypeStatistics(dto.QueryDto);
- List<DepartmentAcceptanceTypeStatisticsDto> list;
- if (dto.IsExportAll)
- {
- list = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- list = items;
- }
- foreach (var item in list)
- {
- item.ZxAllTimes = Math.Round(((double)item.ZxAllTimes / 3600), 2);
- item.JyAllTimes = Math.Round(((double)item.JyAllTimes / 3600), 2);
- item.QzAllTimes = Math.Round(((double)item.QzAllTimes / 3600), 2);
- item.ByAllTimes = Math.Round(((double)item.ByAllTimes / 3600), 2);
- item.JbAllTimes = Math.Round(((double)item.JbAllTimes / 3600), 2);
- item.TsAllTimes = Math.Round(((double)item.TsAllTimes / 3600), 2);
- item.QtAllTimes = Math.Round(((double)item.QtAllTimes / 3600), 2);
- item.YjAllTimes = Math.Round(((double)item.YjAllTimes / 3600), 2);
- }
- //增加合计
- list.Add(new DepartmentAcceptanceTypeStatisticsDto
- {
- OrgName = "合计",
- OrgCode = "",
- OrgType = "",
- ZxAllCount = list.Sum(p => p.ZxAllCount),
- ZxAllTimes = list.Sum(p => p.ZxAllTimes),
- ZxAcceptanceTypeCode = "10",
- JyAllCount = list.Sum(p => p.JyAllCount),
- JyAllTimes = list.Sum(p => p.JyAllTimes),
- JyAcceptanceTypeCode = "15",
- QzAllCount = list.Sum(p => p.QzAllCount),
- QzAllTimes = list.Sum(p => p.QzAllTimes),
- QzAcceptanceTypeCode = "20",
- ByAllCount = list.Sum(p => p.ByAllCount),
- ByAllTimes = list.Sum(p => p.ByAllTimes),
- ByAcceptanceTypeCode = "25",
- JbAllCount = list.Sum(p => p.JbAllCount),
- JbAllTimes = list.Sum(p => p.JbAllTimes),
- JbAcceptanceTypeCode = "30",
- TsAllCount = list.Sum(p => p.TsAllCount),
- TsAllTimes = list.Sum(p => p.TsAllTimes),
- TsAcceptanceTypeCode = "35",
- QtAllCount = list.Sum(p => p.QtAllCount),
- QtAllTimes = list.Sum(p => p.QtAllTimes),
- QtAcceptanceTypeCode = "40",
- YjAllCount = list.Sum(p => p.YjAllCount),
- YjAllTimes = list.Sum(p => p.YjAllTimes),
- YjAcceptanceTypeCode = "1"
- });
- var orderDtos = _mapper.Map<ICollection<DepartmentAcceptanceTypeStatisticsDto>>(list);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = orderDtos
- .Select(stu => _mapper.Map(stu, typeof(DepartmentAcceptanceTypeStatisticsDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "部门受理类型统计周期数据");
- }
- /// <summary>
- /// 部门受理类型统计周期--明细列表
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("department_acceptance_type_order_list")]
- public async Task<PagedDto<OrderDto>> DepartmentAcceptanceTypeOrderList([FromQuery] DepartmentKeyWordRequest dto)
- {
- var (total, items) = await _orderReportApplication.DepartmentAcceptanceTypeOrderList(dto)
- .ToPagedListAsync(dto, HttpContext.RequestAborted);
- return new PagedDto<OrderDto>(total, _mapper.Map<IReadOnlyList<OrderDto>>(items));
- }
- /// <summary>
- /// 部门受理类型统计周期--明细列表---导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("department_acceptance_type_order_list_export")]
- public async Task<FileStreamResult> ExportDepartmentAcceptanceTypeOrderList([FromBody] ExportExcelDto<DepartmentKeyWordRequest> dto)
- {
- var query = _orderReportApplication.DepartmentAcceptanceTypeOrderList(dto.QueryDto);
- List<Order> list;
- if (dto.IsExportAll)
- {
- list = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- list = items;
- }
- var orderDtos = _mapper.Map<ICollection<OrderDto>>(list);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = orderDtos
- .Select(stu => _mapper.Map(stu, typeof(OrderDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "部门受理类型统计周期数据");
- }
- /// <summary>
- /// 部门办件统计表
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("departmental_processing_statistics")]
- public async Task<object> DepartmentalProcessingStatistics([FromQuery] DepartmentalProcessingStatisticsRequest dto)
- {
- //联合查询
- //var items = await _orderReportApplication.DepartmentalProcessingStatistics(dto)
- // .ToListAsync();
- var items = await _orderReportApplication.DepartmentalProcessingStatisticsNew(dto);
- var total = new DepartmentalProcessingStatisticsDataDto
- {
- OrgCode = "",
- OrgName = "合计",
- OrgType = EOrgType.City,
- // OrderCountNum = items.Sum(p => p.OrderCountNum),
- YbOrderCountNum = items.Sum(p => p.YbOrderCountNum),
- ZbOrderCountNum = items.Sum(p => p.ZbOrderCountNum),
- Archived = items.Sum(p => p.Archived),
- ToBeArchived = items.Sum(p => p.ToBeArchived),
- WaitPublished = items.Sum(p => p.WaitPublished),
- PublishedOpen = items.Sum(p => p.PublishedOpen),
- PublishedNoOpen = items.Sum(p => p.PublishedNoOpen),
- YbOverdue = items.Sum(p => p.YbOverdue),
- ZbOverdue = items.Sum(p => p.ZbOverdue),
- CompleteOnTime = items.Sum(p => p.CompleteOnTime),
- HqybOverdue = items.Sum(p => p.HqybOverdue),
- HqzbOverdue = items.Sum(p => p.HqzbOverdue),
- DelayEnd = items.Sum(p => p.DelayEnd),
- DelayWait = items.Sum(p => p.DelayWait),
- OrderDelayCount = items.Sum(p => p.OrderDelayCount),
- ScreenCount = items.Sum(p => p.ScreenCount),
- ScreenApproval = items.Sum(p => p.ScreenApproval),
- ScreenPass = items.Sum(p => p.ScreenPass),
- ScreenNotPass = items.Sum(p => p.ScreenNotPass),
- SatisfactionCount = items.Sum(p => p.SatisfactionCount),
- NotSatisfactionCount = items.Sum(p => p.NotSatisfactionCount)
- };
- return new { List = items, Total = total };
- }
- /// <summary>
- /// 部门办件统计表--导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("departmental_processing_statistics_export")]
- public async Task<FileStreamResult> ExportDepartmentalProcessingStatistics([FromBody] ExportExcelDto<DepartmentalProcessingStatisticsRequest> dto)
- {
- var list = await _orderReportApplication.DepartmentalProcessingStatisticsNew(dto.QueryDto);
- //增加合计
- list.Add(new DepartmentalProcessingStatisticsDataDto
- {
- OrgCode = "",
- OrgName = "合计",
- OrgType = EOrgType.City,
- // OrderCountNum = items.Sum(p => p.OrderCountNum),
- YbOrderCountNum = list.Sum(p => p.YbOrderCountNum),
- ZbOrderCountNum = list.Sum(p => p.ZbOrderCountNum),
- Archived = list.Sum(p => p.Archived),
- ToBeArchived = list.Sum(p => p.ToBeArchived),
- WaitPublished = list.Sum(p => p.WaitPublished),
- PublishedOpen = list.Sum(p => p.PublishedOpen),
- PublishedNoOpen = list.Sum(p => p.PublishedNoOpen),
- YbOverdue = list.Sum(p => p.YbOverdue),
- ZbOverdue = list.Sum(p => p.ZbOverdue),
- CompleteOnTime = list.Sum(p => p.CompleteOnTime),
- HqybOverdue = list.Sum(p => p.HqybOverdue),
- HqzbOverdue = list.Sum(p => p.HqzbOverdue),
- DelayEnd = list.Sum(p => p.DelayEnd),
- DelayWait = list.Sum(p => p.DelayWait),
- OrderDelayCount = list.Sum(p => p.OrderDelayCount),
- ScreenCount = list.Sum(p => p.ScreenCount),
- ScreenApproval = list.Sum(p => p.ScreenApproval),
- ScreenPass = list.Sum(p => p.ScreenPass),
- ScreenNotPass = list.Sum(p => p.ScreenNotPass),
- SatisfactionCount = list.Sum(p => p.SatisfactionCount),
- NotSatisfactionCount = list.Sum(p => p.NotSatisfactionCount)
- });
- var orderDtos = _mapper.Map<ICollection<DepartmentalProcessingStatisticsDataDto>>(list);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = orderDtos
- .Select(stu => _mapper.Map(stu, typeof(DepartmentalProcessingStatisticsDataDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "部门办件统计表数据");
- }
- /// <summary>
- /// 部门办件统计表--子级
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("departmental_processing_child_statistics")]
- public async Task<object> DepartmentalProcessingChildStatistics([FromQuery] DepartmentalProcessingStatisticsRequest dto)
- {
- var items = await _orderReportApplication.DepartmentalProcessingChildStatisticsNew(dto);
- //计算合计
- var total = new DepartmentalProcessingStatisticsDataDto
- {
- OrgCode = "",
- OrgName = "合计",
- OrgType = EOrgType.City,
- // OrderCountNum = items.Sum(p => p.OrderCountNum),
- YbOrderCountNum = items.Sum(p => p.YbOrderCountNum),
- ZbOrderCountNum = items.Sum(p => p.ZbOrderCountNum),
- Archived = items.Sum(p => p.Archived),
- ToBeArchived = items.Sum(p => p.ToBeArchived),
- WaitPublished = items.Sum(p => p.WaitPublished),
- PublishedOpen = items.Sum(p => p.PublishedOpen),
- PublishedNoOpen = items.Sum(p => p.PublishedNoOpen),
- YbOverdue = items.Sum(p => p.YbOverdue),
- ZbOverdue = items.Sum(p => p.ZbOverdue),
- CompleteOnTime = items.Sum(p => p.CompleteOnTime),
- HqybOverdue = items.Sum(p => p.HqybOverdue),
- HqzbOverdue = items.Sum(p => p.HqzbOverdue),
- DelayEnd = items.Sum(p => p.DelayEnd),
- DelayWait = items.Sum(p => p.DelayWait),
- OrderDelayCount = items.Sum(p => p.OrderDelayCount),
- ScreenCount = items.Sum(p => p.ScreenCount),
- ScreenApproval = items.Sum(p => p.ScreenApproval),
- ScreenPass = items.Sum(p => p.ScreenPass),
- ScreenNotPass = items.Sum(p => p.ScreenNotPass),
- SatisfactionCount = items.Sum(p => p.SatisfactionCount),
- NotSatisfactionCount = items.Sum(p => p.NotSatisfactionCount)
- };
- return new { List = items, Total = total };
- }
- /// <summary>
- /// 部门办件统计表--子级--导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("departmental_processing_child_statistics_export")]
- public async Task<FileStreamResult> ExportDepartmentalProcessingChildStatistics([FromBody] ExportExcelDto<DepartmentalProcessingStatisticsRequest> dto)
- {
- var list = await _orderReportApplication.DepartmentalProcessingChildStatisticsNew(dto.QueryDto);
- //增加合计
- list.Add(new DepartmentalProcessingStatisticsDataDto
- {
- OrgCode = "",
- OrgName = "合计",
- OrgType = EOrgType.City,
- // OrderCountNum = items.Sum(p => p.OrderCountNum),
- YbOrderCountNum = list.Sum(p => p.YbOrderCountNum),
- ZbOrderCountNum = list.Sum(p => p.ZbOrderCountNum),
- Archived = list.Sum(p => p.Archived),
- ToBeArchived = list.Sum(p => p.ToBeArchived),
- WaitPublished = list.Sum(p => p.WaitPublished),
- PublishedOpen = list.Sum(p => p.PublishedOpen),
- PublishedNoOpen = list.Sum(p => p.PublishedNoOpen),
- YbOverdue = list.Sum(p => p.YbOverdue),
- ZbOverdue = list.Sum(p => p.ZbOverdue),
- CompleteOnTime = list.Sum(p => p.CompleteOnTime),
- HqybOverdue = list.Sum(p => p.HqybOverdue),
- HqzbOverdue = list.Sum(p => p.HqzbOverdue),
- DelayEnd = list.Sum(p => p.DelayEnd),
- DelayWait = list.Sum(p => p.DelayWait),
- OrderDelayCount = list.Sum(p => p.OrderDelayCount),
- ScreenCount = list.Sum(p => p.ScreenCount),
- ScreenApproval = list.Sum(p => p.ScreenApproval),
- ScreenPass = list.Sum(p => p.ScreenPass),
- ScreenNotPass = list.Sum(p => p.ScreenNotPass),
- SatisfactionCount = list.Sum(p => p.SatisfactionCount),
- NotSatisfactionCount = list.Sum(p => p.NotSatisfactionCount)
- });
- var orderDtos = _mapper.Map<ICollection<DepartmentalProcessingStatisticsDataDto>>(list);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = orderDtos
- .Select(stu => _mapper.Map(stu, typeof(DepartmentalProcessingStatisticsDataDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "部门办件统计表数据");
- }
- /// <summary>
- /// 部门办件统计表--明细
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("departmental_processing_statistics_list")]
- public async Task<PagedDto<OrderDto>> GetDepartmentalProcessingStatisticsList([FromQuery] DepartmentalProcessingStatisticsRequest dto)
- {
- RefAsync<int> total = 0;
- var queryData = await _orderReportApplication.GetDepartmentalProcessingStatisticsListNew(dto, HttpContext.RequestAborted)
- .LeftJoin<Order>((x, o) => x.Id == o.Id)
- .OrderByIF(string.IsNullOrEmpty(dto.SortField), (x, o) => o.CreationTime, OrderByType.Desc)
- .OrderByIF(dto is { SortField: "startTime", SortRule: 0 }, (x, o) => o.StartTime, OrderByType.Asc) //受理时间升序
- .OrderByIF(dto is { SortField: "startTime", SortRule: 1 }, (x, o) => o.StartTime, OrderByType.Desc) //受理时间降序
- .OrderByIF(dto is { SortField: "expiredTime", SortRule: 0 }, (x, o) => o.ExpiredTime, OrderByType.Asc) //工单期满时间升序
- .OrderByIF(dto is { SortField: "expiredTime", SortRule: 1 }, (x, o) => o.ExpiredTime, OrderByType.Desc) //工单期满时间降序
- .OrderByIF(dto is { SortField: "filedTime", SortRule: 0 }, (x, o) => o.FiledTime, OrderByType.Asc)// 办结时间升序
- .OrderByIF(dto is { SortField: "filedTime", SortRule: 1 }, (x, o) => o.FiledTime, OrderByType.Desc) //办结时间降序
- .Select((x, o) => new { o })
- .ToPageListAsync(dto.PageIndex, dto.PageSize, total, HttpContext.RequestAborted);
- var dtos = queryData.Select(d =>
- {
- var dto = _mapper.Map<OrderDto>(d.o);
- return dto;
- }).ToList();
- return new PagedDto<OrderDto>(total, dtos);
- }
- /// <summary>
- /// 部门办件统计表--明细--导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("departmental_processing_statistics_list_export")]
- public async Task<FileStreamResult> ExportGetDepartmentalProcessingStatisticsList([FromBody] ExportExcelDto<DepartmentalProcessingStatisticsRequest> dto)
- {
- var query = _orderReportApplication.GetDepartmentalProcessingStatisticsListNew(dto.QueryDto, HttpContext.RequestAborted)
- .LeftJoin<Order>((x, o) => x.Id == o.Id)
- .OrderByIF(string.IsNullOrEmpty(dto.QueryDto.SortField), (x, o) => o.CreationTime, OrderByType.Desc)
- .OrderByIF(dto.QueryDto is { SortField: "startTime", SortRule: 0 }, (x, o) => o.StartTime, OrderByType.Asc) //受理时间升序
- .OrderByIF(dto.QueryDto is { SortField: "startTime", SortRule: 1 }, (x, o) => o.StartTime, OrderByType.Desc) //受理时间降序
- .OrderByIF(dto.QueryDto is { SortField: "expiredTime", SortRule: 0 }, (x, o) => o.ExpiredTime, OrderByType.Asc) //工单期满时间升序
- .OrderByIF(dto.QueryDto is { SortField: "expiredTime", SortRule: 1 }, (x, o) => o.ExpiredTime, OrderByType.Desc) //工单期满时间降序
- .OrderByIF(dto.QueryDto is { SortField: "filedTime", SortRule: 0 }, (x, o) => o.FiledTime, OrderByType.Asc)// 办结时间升序
- .OrderByIF(dto.QueryDto is { SortField: "filedTime", SortRule: 1 }, (x, o) => o.FiledTime, OrderByType.Desc) //办结时间降序
- .Select((x, o) => new { o });
- List<OrderDto> list = new List<OrderDto>();
- if (dto.IsExportAll)
- {
- var listData = await query.ToListAsync(HttpContext.RequestAborted);
- list = listData.Select(d =>
- {
- var dto = _mapper.Map<OrderDto>(d.o);
- return dto;
- }).ToList();
- }
- else
- {
- RefAsync<int> total = 0;
- var listData = await query.ToPageListAsync(dto.QueryDto.PageIndex, dto.QueryDto.PageSize, total, HttpContext.RequestAborted);
- list = listData.Select(d =>
- {
- var dto = _mapper.Map<OrderDto>(d.o);
- return dto;
- }).ToList();
- }
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = list
- .Select(stu => _mapper.Map(stu, typeof(OrderDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "部门办件统计明细数据");
- }
- /// <summary>
- /// 部门办件统计明细表
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("departmental_processing_statistics_details_list")]
- public async Task<PagedDto<OrderDto>> DepartmentalProcessingStatisticsDetailsList([FromQuery] DepartmentalProcessingStatisticsRequest dto)
- {
- RefAsync<int> total = 0;
- var queryData = await _orderReportApplication.DepartmentalProcessingStatisticsDetailsList(dto)
- .LeftJoin<Order>((x, o) => x.Id == o.Id)
- .OrderByIF(string.IsNullOrEmpty(dto.SortField), (x, o) => o.CreationTime, OrderByType.Desc)
- .OrderByIF(dto is { SortField: "startTime", SortRule: 0 }, (x, o) => o.StartTime, OrderByType.Asc) //受理时间升序
- .OrderByIF(dto is { SortField: "startTime", SortRule: 1 }, (x, o) => o.StartTime, OrderByType.Desc) //受理时间降序
- .OrderByIF(dto is { SortField: "expiredTime", SortRule: 0 }, (x, o) => o.ExpiredTime, OrderByType.Asc) //工单期满时间升序
- .OrderByIF(dto is { SortField: "expiredTime", SortRule: 1 }, (x, o) => o.ExpiredTime, OrderByType.Desc) //工单期满时间降序
- .OrderByIF(dto is { SortField: "filedTime", SortRule: 0 }, (x, o) => o.FiledTime, OrderByType.Asc)// 办结时间升序
- .OrderByIF(dto is { SortField: "filedTime", SortRule: 1 }, (x, o) => o.FiledTime, OrderByType.Desc) //办结时间降序
- .Select((x, o) => new { o })
- .ToPageListAsync(dto.PageIndex, dto.PageSize, total, HttpContext.RequestAborted);
- var dtos = queryData.Select(d =>
- {
- var dto = _mapper.Map<OrderDto>(d.o);
- return dto;
- }).ToList();
- return new PagedDto<OrderDto>(total, dtos);
- }
- /// <summary>
- /// 部门办件统计明细表--导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("departmental_processing_statistics_details_list_export")]
- public async Task<FileStreamResult> ExportDepartmentalProcessingStatisticsDetailsList([FromBody] ExportExcelDto<DepartmentalProcessingStatisticsRequest> dto)
- {
- var query = _orderReportApplication.DepartmentalProcessingStatisticsDetailsList(dto.QueryDto)
- .LeftJoin<Order>((x, o) => x.Id == o.Id)
- .OrderByIF(string.IsNullOrEmpty(dto.QueryDto.SortField), (x, o) => o.CreationTime, OrderByType.Desc)
- .OrderByIF(dto.QueryDto is { SortField: "startTime", SortRule: 0 }, (x, o) => o.StartTime, OrderByType.Asc) //受理时间升序
- .OrderByIF(dto.QueryDto is { SortField: "startTime", SortRule: 1 }, (x, o) => o.StartTime, OrderByType.Desc) //受理时间降序
- .OrderByIF(dto.QueryDto is { SortField: "expiredTime", SortRule: 0 }, (x, o) => o.ExpiredTime, OrderByType.Asc) //工单期满时间升序
- .OrderByIF(dto.QueryDto is { SortField: "expiredTime", SortRule: 1 }, (x, o) => o.ExpiredTime, OrderByType.Desc) //工单期满时间降序
- .OrderByIF(dto.QueryDto is { SortField: "filedTime", SortRule: 0 }, (x, o) => o.FiledTime, OrderByType.Asc)// 办结时间升序
- .OrderByIF(dto.QueryDto is { SortField: "filedTime", SortRule: 1 }, (x, o) => o.FiledTime, OrderByType.Desc) //办结时间降序
- .Select((x, o) => new { o });
- var list = new List<OrderDto>();
- if (dto.IsExportAll)
- {
- var listData = await query.ToListAsync(HttpContext.RequestAborted);
- list = listData.Select(d =>
- {
- var dto = _mapper.Map<OrderDto>(d.o);
- return dto;
- }).ToList();
- }
- else
- {
- RefAsync<int> total = 0;
- var listData = await query.ToPageListAsync(dto.QueryDto.PageIndex, dto.QueryDto.PageSize, total, HttpContext.RequestAborted);
- list = listData.Select(d =>
- {
- var dto = _mapper.Map<OrderDto>(d.o);
- return dto;
- }).ToList();
- }
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = list
- .Select(stu => _mapper.Map(stu, typeof(OrderDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "部门办件统计明细表数据");
- }
- /// <summary>
- /// 高频来电统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("high_frequency_call_statistics")]
- public async Task<PagedDto<HighFrequencyCallStatisticsDto>> HighFrequencyCallStatistics([FromQuery] HighFrequencyCallStatisticsRequest dto)
- {
- if (!dto.StartTime.HasValue || !dto.EndTime.HasValue)
- throw UserFriendlyException.SameMessage("请选择时间!");
- int CallCount = 2;
- var HighFrequencyCallStatistics = _systemSettingCacheManager.GetSetting(SettingConstants.HighFrequencyCallStatistics)?.SettingValue[0];
- if (HighFrequencyCallStatistics != null)
- CallCount = int.Parse(HighFrequencyCallStatistics);
- var (total, items) = await _trCallRecordRepository.Queryable()
- .LeftJoin<Order>((p, o) => p.ExternalId == o.Id)
- .Where((p, o) => p.OverTime >= dto.StartTime && p.OverTime <= dto.EndTime)
- .Where((p, o) => p.CallOrderType == ECallOrderType.Order)
- .Where((p, o) => p.ExternalId != null && o.Id != null)
- .Where((p, o) => p.CallDirection == ECallDirection.In)
- .WhereIF(!string.IsNullOrEmpty(dto.PhoneNum), (p, o) => p.CPN == dto.PhoneNum)
- .Select((p, o) => new
- {
- p.CPN,
- p.ExternalId
- })
- .MergeTable()
- .GroupBy(p => p.CPN)
- .Select(p => new HighFrequencyCallStatisticsDto
- {
- Callnum = p.CPN,
- OrderCountNum = SqlFunc.AggregateCount(p.CPN),//总量
- })
- .MergeTable()
- .Where(p => p.OrderCountNum >= CallCount)
- .OrderByDescending(p => p.OrderCountNum)
- .ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
- return new PagedDto<HighFrequencyCallStatisticsDto>(total, _mapper.Map<IReadOnlyList<HighFrequencyCallStatisticsDto>>(items));
- }
- /// <summary>
- /// 高频来电统计列表详情
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("high_frequency_call_statistics_order_list")]
- public async Task<PagedDto<OrderDto>> HighFrequencyCallStatisticsOrderList([FromQuery] HighFrequencyCallStatisticsListRequest dto)
- {
- if (!dto.StartTime.HasValue || !dto.EndTime.HasValue)
- throw UserFriendlyException.SameMessage("请选择时间!");
- if (string.IsNullOrEmpty(dto.FromPhone))
- throw UserFriendlyException.SameMessage("号码不能为空!");
- var data = await _trCallRecordRepository.Queryable()
- .LeftJoin<Order>((p, o) => p.ExternalId == o.Id)
- .Where((p, o) => p.OverTime >= dto.StartTime && p.OverTime <= dto.EndTime)
- .Where((p, o) => p.CallOrderType == ECallOrderType.Order)
- .Where((p, o) => p.ExternalId != null && o.Id != null)
- .Where((p, o) => p.CPN == dto.FromPhone)
- .Where((p, o) => p.CallDirection == ECallDirection.In)
- .Select((p, o) =>
- p.ExternalId
- )
- .ToListAsync();
- var (total, items) = await _orderRepository.Queryable()
- .Includes(x => x.OrderScreens)
- .WhereIF(!string.IsNullOrEmpty(dto.Keyword), d => d.Title.StartsWith(dto.Keyword!)) //标题
- .WhereIF(!string.IsNullOrEmpty(dto.ProvinceNo), d => d.ProvinceNo == dto.ProvinceNo) //省本地编号
- .WhereIF(!string.IsNullOrEmpty(dto.No), d => d.No == dto.No) //工单编码
- .WhereIF(!string.IsNullOrEmpty(dto.AcceptType), d => d.AcceptTypeCode == dto.AcceptType)//受理类型
- //.WhereIF(dto.AcceptTypes.Any(), d => dto.AcceptTypes.Contains(d.AcceptTypeCode)) //受理类型
- .WhereIF(!string.IsNullOrEmpty(dto.Channel), d => d.SourceChannelCode == dto.Channel)
- //.WhereIF(dto.Channels.Any(), d => dto.Channels.Contains(d.SourceChannelCode)) //来源渠道
- //.WhereIF(dto.HotspotIds.Any(), d => dto.HotspotIds.Contains(d.HotspotId)) //热点类型
- .WhereIF(!string.IsNullOrEmpty(dto.Hotspot), d => d.HotspotSpliceName != null && d.HotspotSpliceName.Contains(dto.Hotspot))
- .WhereIF(!string.IsNullOrEmpty(dto.TransferPhone), d => d.TransferPhone == dto.TransferPhone!) //转接号码
- //.WhereIF(dto.OrgCodes.Any(), d => d.Workflow.Assigns.Any(s => dto.OrgCodes.Contains(s.OrgCode)))
- //.WhereIF(dto.OrgCodes.Any(), d => dto.OrgCodes.Contains(d.ActualHandleOrgCode)) //接办部门
- //.WhereIF(!string.IsNullOrEmpty(dto.OrgId), d => d.CurrentHandleOrgId == dto.OrgId)//接办部门
- .WhereIF(!string.IsNullOrEmpty(dto.OrgId), d => d.CurrentHandleOrgId == dto.OrgId)//接办部门
- .WhereIF(!string.IsNullOrEmpty(dto.NameOrNo), d => d.AcceptorName == dto.NameOrNo! || d.AcceptorStaffNo == dto.NameOrNo!) //受理人/坐席
- .WhereIF(dto.CreationTimeStart.HasValue, d => d.CreationTime >= dto.CreationTimeStart) //受理时间开始
- .WhereIF(dto.CreationTimeEnd.HasValue, d => d.CreationTime <= dto.CreationTimeEnd) //受理时间结束
- //.WhereIF(dto.EmergencyLevels.Any(), d => dto.EmergencyLevels.Contains(d.EmergencyLevel)) //紧急程度
- .WhereIF(!string.IsNullOrEmpty(dto.FromPhone), d => d.FromPhone == dto.FromPhone) //来电号码
- .WhereIF(!string.IsNullOrEmpty(dto.PhoneNo), d => d.Contact == dto.PhoneNo!) //联系电话
- //.WhereIF(!string.IsNullOrEmpty(dto.PushTypeCode), d => d.PushTypeCode == dto.PushTypeCode) //推送分类
- .WhereIF(!string.IsNullOrEmpty(dto.PushTypeCode), d => d.OrderPushTypes.Any(opt => opt.PushTypeCode == dto.PushTypeCode)) //推送分类
- .WhereIF(dto.ExpiredTimeStart.HasValue, d => d.ExpiredTime >= dto.ExpiredTimeStart) //超期时间开始
- .WhereIF(dto.ExpiredTimeEnd.HasValue, d => d.ExpiredTime <= dto.ExpiredTimeEnd) //超期时间结束
- //.WhereIF(dto.Statuses.Any(), d => dto.Statuses.Contains(d.Status)) //工单状态
- .WhereIF(dto.Status.HasValue, d => d.Status == dto.Status)//工单状态
- //.WhereIF(dto.Statuses.Any(d => d == EOrderStatus.SpecialToUnAccept), d => d.Status <= EOrderStatus.SpecialToUnAccept)
- .WhereIF(!string.IsNullOrEmpty(dto.ActualHandlerName), d => d.ActualHandlerName == dto.ActualHandlerName) //接办人
- .WhereIF(dto.IsScreen == true, d => d.OrderScreens.Any(x => x.Status != EScreenStatus.Refuse)) //有甄别
- .WhereIF(dto.IsScreen == false, d => !d.OrderScreens.Any(x => x.Status != EScreenStatus.Refuse)) //无甄别
- .WhereIF(!string.IsNullOrEmpty(dto.CurrentStepCode), d => d.ActualHandleStepCode == dto.CurrentStepCode) //当前办理节点
- .WhereIF(dto.ActualHandleTimeStart.HasValue, d => d.ActualHandleTime >= dto.ActualHandleTimeStart) //办结时间开始
- .WhereIF(dto.ActualHandleTimeEnd.HasValue, d => d.ActualHandleTime <= dto.ActualHandleTimeEnd) //办结时间结束
- .WhereIF(dto.IsOverTime == true, d => (d.ExpiredTime < DateTime.Now && d.Status < EOrderStatus.Filed) || (d.ExpiredTime < d.ActualHandleTime && d.Status >= EOrderStatus.Filed)) //是 超期
- .WhereIF(dto.IsOverTime == false, d => (d.ExpiredTime > DateTime.Now && d.Status < EOrderStatus.Filed) || (d.ExpiredTime > d.ActualHandleTime && d.Status >= EOrderStatus.Filed)) //否 超期
- .WhereIF(dto.IdentityType != null, d => d.IdentityType == dto.IdentityType) //来电主体
- .WhereIF(!string.IsNullOrEmpty(dto.FromName), d => d.FromName == dto.FromName) //来电人姓名
- //.WhereIF(dto.AreaCodes.Any(), d => dto.AreaCodes.Contains(d.AreaCode)) //区域
- .WhereIF(!string.IsNullOrEmpty(dto.AreaCode), d => d.AreaCode == dto.AreaCode)//区域
- .WhereIF(dto.IsProvinceOrder.HasValue && dto.IsProvinceOrder == true, x => x.IsProvince == true)
- .WhereIF(dto.IsProvinceOrder.HasValue && dto.IsProvinceOrder == false, x => x.IsProvince == false)
- .OrderByDescending(d => d.CreationTime)
- .ToPagedListAsync(dto, HttpContext.RequestAborted);
- return new PagedDto<OrderDto>(total, _mapper.Map<IReadOnlyList<OrderDto>>(items));
- }
- /// <summary>
- /// 高频事项预警
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("highmatter-warning")]
- public async Task<PagedDto<HighMatterWarningDto>> HighMatterWarning([FromQuery] HighMatterWarningRequest dto)
- {
- List<string> filterTitle = new List<string>();
- filterTitle.Add("无声");
- filterTitle.Add("骚扰");
- filterTitle.Add("错拨");
- filterTitle.Add("测试");
- var (total, items) = await _orderRepository.Queryable()
- .Where(x => x.CreationTime >= dto.StartTime && x.CreationTime <= dto.EndTime)
- .Where(x => filterTitle.Any(s => x.Title.Contains(s)) == false)
- .LeftJoin<SystemArea>((it, o) => it.AreaCode.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6")) == o.Id)
- .WhereIF(!string.IsNullOrEmpty(dto.AcceptType), x => x.AcceptTypeCode == dto.AcceptType)//受理类型
- .WhereIF(!string.IsNullOrEmpty(dto.Hotspot), x => x.HotspotSpliceName != null && x.HotspotSpliceName.Contains(dto.Hotspot))//热点类型
- .WhereIF(!string.IsNullOrEmpty(dto.AreaCode), x => x.AreaCode == dto.AreaCode)//区域
- .GroupBy((it, o) => new
- {
- it.AcceptTypeCode,
- it.AcceptType,
- it.HotspotId,
- it.HotspotName,
- AreaCode = it.AreaCode.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6")),
- o.AreaName,
- })
- .Having((it, o) => SqlFunc.AggregateCount(it.HotspotName) >= 5)
- .Select((it, o) => new HighMatterWarningDto()
- {
- AcceptTypeCode = it.AcceptTypeCode,
- AcceptType = it.AcceptType,
- AreaName = o.AreaName,
- HotspotName = it.HotspotName,
- HotspotId = it.HotspotId,
- SumCount = SqlFunc.AggregateCount(it.HotspotName),
- Id = SqlFunc.AggregateMin(it.Id),
- AreaCode = it.AreaCode.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6"))
- })
- .MergeTable()
- .LeftJoin<Order>((x, d) => x.Id == d.Id)
- .Select((x, d) => new HighMatterWarningDto()
- {
- AreaName = x.AreaName,
- HotspotName = x.HotspotName,
- HotspotId = x.HotspotId,
- Title = d.Title,
- SumCount = x.SumCount,
- Id = d.Id,
- AcceptTypeCode = x.AcceptTypeCode,
- AcceptType = x.AcceptType,
- AreaCode = x.AreaCode
- })
- .MergeTable()
- .OrderByDescending(d => d.SumCount).ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
- return new PagedDto<HighMatterWarningDto>(total, _mapper.Map<IReadOnlyList<HighMatterWarningDto>>(items));
- }
- /// <summary>
- /// 高频事项预警明细
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("highmatter-warning-detail")]
- public async Task<PagedDto<OrderDto>> HighMatterWarningDetail([FromQuery] HighMatterWarningDetailRequest dto)
- {
- List<string> filterTitle = new List<string>();
- filterTitle.Add("无声");
- filterTitle.Add("骚扰");
- filterTitle.Add("错拨");
- filterTitle.Add("测试");
- var (total, items) = await _orderRepository.Queryable()
- .Includes(x => x.OrderScreens)
- .Where(d => d.AcceptTypeCode == dto.AcceptTypeCode) //受理类型
- .Where(d => d.HotspotId == dto.HotspotId) //热点类型
- .Where(d => d.CreationTime >= dto.StartTime) //受理时间开始
- .Where(d => d.CreationTime <= dto.EndTime) //受理时间结束
- .Where(d => d.AreaCode == dto.AreaCode) //区域
- .Where(x => filterTitle.Any(s => x.Title.Contains(s)) == false)
- .OrderByDescending(d => d.CreationTime)
- .ToPagedListAsync(dto, HttpContext.RequestAborted);
- return new PagedDto<OrderDto>(total, _mapper.Map<IReadOnlyList<OrderDto>>(items));
- }
- /// <summary>
- /// 回退错件
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("reTransact")]
- public async Task<PagedDto<OrderReTransactVo>> OrderReTransact([FromQuery] QueryOrderReTransactRequest dto)
- {
- if (!dto.StartTime.HasValue || !dto.EndTime.HasValue)
- throw UserFriendlyException.SameMessage("请选择时间!");
- var query = _orderApplication.OrderReTransact(dto);
- var (total, items) = await query
- .ToPagedListAsync(dto, HttpContext.RequestAborted);
- items.Add(new OrderReTransactVo
- {
- OrgName = "合计",
- Num = items.Select(s => s.Num).Sum(),
- });
- return new PagedDto<OrderReTransactVo>(total, _mapper.Map<IReadOnlyList<OrderReTransactVo>>(items));
- }
- /// <summary>
- /// 回退错件导出
- /// </summary>
- /// <returns></returns>
- [HttpPost("reTransact/_export")]
- public async Task<FileStreamResult> OrderReTransactExport([FromBody] ExportExcelDto<QueryOrderReTransactRequest> dto)
- {
- var query = _orderApplication.OrderReTransact(dto.QueryDto);
- List<OrderReTransactVo> data;
- data = await query.ToListAsync(HttpContext.RequestAborted);
- data.Add(new OrderReTransactVo
- {
- OrgName = "合计",
- Num = data.Select(s => s.Num).Sum(),
- });
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = data
- .Select(stu => _mapper.Map(stu, typeof(OrderReTransactVo), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "回退错件统计数据");
- }
- /// <summary>
- /// 回退错件明细
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("reTransact_detail")]
- public async Task<PagedDto<OrderSpecialDetailDto>> OrderReTransactDetail([FromQuery] QueryOrderReTransactDetailRequest dto)
- {
- var query = _orderApplication.QueryOrderSourceDetail(dto);
- var (total, items) = await
- query.ToPagedListAsync(dto, HttpContext.RequestAborted);
- return new PagedDto<OrderSpecialDetailDto>(total, _mapper.Map<IReadOnlyList<OrderSpecialDetailDto>>(items));
- }
- /// <summary>
- /// 回退错件明细导出
- /// </summary>
- /// <returns></returns>
- [HttpPost("reTransact_detail/_export")]
- public async Task<FileStreamResult> OrderReTransactDetailExport([FromBody] ExportExcelDto<QueryOrderReTransactDetailRequest> dto)
- {
- var query = _orderApplication.QueryOrderSourceDetail(dto.QueryDto);
- List<OrderSpecialDetail> data;
- if (dto.IsExportAll)
- {
- data = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- data = items;
- }
- var dataDtos = _mapper.Map<ICollection<OrderSpecialDetailDto>>(data);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = dataDtos
- .Select(stu => _mapper.Map(stu, typeof(OrderSpecialDetailDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "回退错件明细列表数据");
- }
- /// <summary>
- /// 获取基本信息
- /// </summary>
- /// <param name="id"></param>
- /// <returns></returns>
- [HttpGet("reTransact_base")]
- public async Task<object> ReTransactBaseData()
- {
- var rsp = new
- {
- ReTransactErrorType = _sysDicDataCacheManager.GetSysDicDataCache(SysDicTypeConsts.ReTransactErrorType),
- };
- return rsp;
- }
- /// <summary>
- /// 派单量统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("send_order_report")]
- public async Task<List<SendOrderReportOutDto>> SendOrderReport([FromQuery] QuerySendOrderRequest dto)
- {
- if (!dto.StartTime.HasValue || !dto.EndTime.HasValue)
- throw UserFriendlyException.SameMessage("请选择时间!");
- return await _orderApplication.SendOrderReportAsync(dto);
- }
- /// <summary>
- /// 派单量统计-导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("send_order_report/export")]
- public async Task<FileStreamResult> ExportSendOrderReport([FromBody] ExportExcelDto<QuerySendOrderRequest> dto)
- {
- if (!dto.QueryDto.StartTime.HasValue || !dto.QueryDto.EndTime.HasValue)
- throw UserFriendlyException.SameMessage("请选择时间!");
- var list = await _orderApplication.SendOrderReportAsync(dto.QueryDto);
- if (list != null && list.Count > 0)
- {
- list.Add(new SendOrderReportOutDto()
- {
- UserName = "合计",
- SendOrderNum = list.Sum(p => p.SendOrderNum),
- NoSendOrderNum = list.Sum(p => p.NoSendOrderNum),
- ReSendOrderNum = list.Sum(p => p.ReSendOrderNum),
- });
- }
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = list
- .Select(stu => _mapper.Map(stu, typeof(SendOrderReportOutDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "派单量统计");
- }
- /// <summary>
- /// 派单量统计明细
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("send_order_detail_report")]
- public async Task<PagedDto<OrderDto>> QuerySendOrderDetail([FromQuery] QuerySendOrderDetailRequest dto)
- {
- if (!dto.StartTime.HasValue || !dto.EndTime.HasValue)
- throw UserFriendlyException.SameMessage("请选择时间!");
- var (total, items) = await _workflowTraceRepository.Queryable()
- //.LeftJoin<Workflow>((x, w) => x.WorkflowId == w.Id)
- .InnerJoin<SchedulingUser>((x, su) => x.HandlerId == su.UserId)
- .Where((x, su) => x.ModuleCode == "OrderHandle" && x.BusinessType == EBusinessType.Send)
- .Where((x, su) => x.CreationTime >= dto.StartTime.Value && x.CreationTime <= dto.EndTime.Value && su.UserId == dto.UserId)
- .WhereIF(dto.TitleCode.ToUpper() == "NOSENDORDERNUM", (x, su) => x.Status != EWorkflowStepStatus.Handled)
- .WhereIF(dto.TitleCode.ToUpper() == "SENDORDERNUM", (x, su) => x.Status == EWorkflowStepStatus.Handled)
- .GroupBy((x, su) => x.ExternalId)
- .Select((x, su) => new { Id = x.ExternalId })
- .MergeTable()
- .LeftJoin<Order>((a, b) => a.Id == b.Id)
- .Select((a, b) => b)
- .ToPagedListAsync(dto, HttpContext.RequestAborted);
- if (dto.TitleCode.ToUpper() == "RESENDORDERNUM")
- {
- (total, items) = await _workflowTraceRepository.Queryable()
- .LeftJoin<Workflow>((x, w) => x.WorkflowId == w.Id)
- //.LeftJoin<WorkflowStepHandler>((x, w, wfsh) => x.StepId == wfsh.WorkflowStepId && wfsh.IsActualHandler == true)
- .InnerJoin<SchedulingUser>((x, w, su) => x.HandlerId == su.UserId)
- .Where((x, w, su) => w.ModuleCode == "OrderHandle" && x.BusinessType == EBusinessType.Send && x.Status == EWorkflowStepStatus.Handled
- && !string.IsNullOrEmpty(x.NextMainHandler) && x.NextMainHandler != OrgSeedData.CenterId)
- .Where((x, w, su) => x.CreationTime >= dto.StartTime.Value)
- .Where((x, w, su) => x.CreationTime <= dto.EndTime.Value)
- .GroupBy((x, w, su) => x.WorkflowId)
- .Having((x, w, su) => SqlFunc.AggregateCount(x.WorkflowId) > 1)
- .Select((x, w, su) => new { Id = x.WorkflowId, CreationTime = SqlFunc.AggregateMin(x.CreationTime) })
- .MergeTable()
- .LeftJoin<WorkflowTrace>((a, wt) => a.Id == wt.WorkflowId)
- .LeftJoin<Workflow>((a, wt, wf) => wt.WorkflowId == wf.Id)
- //.LeftJoin<WorkflowStepHandler>((a, wt, wf, wsh) => wt.StepId == wsh.WorkflowStepId && wsh.CreationTime == a.CreationTime)
- .InnerJoin<SchedulingUser>((a, wt, wf, su) => wt.HandlerId == su.UserId)
- .Where((a, wt, wf, su) => su.UserId == dto.UserId)
- .GroupBy((a, wt, wf, su) => wf.ExternalId)
- .Select((a, wt, wf, su) => new { Id = wf.ExternalId })
- .MergeTable()
- .LeftJoin<Order>((a, b) => a.Id == b.Id)
- .Select((a, b) => b)
- .ToPagedListAsync(dto, HttpContext.RequestAborted);
- }
- return new PagedDto<OrderDto>(total, _mapper.Map<IReadOnlyList<OrderDto>>(items));
- }
- /// <summary>
- /// 二次办理统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("secondary_handling_report")]
- public async Task<List<SecondaryHandlingVo>> SecondaryHandlingReport([FromQuery] QuerySecondaryHandlingRequest dto)
- {
- var query = _orderSecondaryHandlingApplication.SecondaryHandlingReport(dto, HttpContext.RequestAborted);
- return await query.ToListAsync();
- }
- /// <summary>
- /// 二次办理统计导出
- /// </summary>
- /// <returns></returns>
- [HttpPost("secondary_handling_report/_export")]
- public async Task<FileStreamResult> SecondaryHandlingReportExport([FromBody] ExportExcelDto<QuerySecondaryHandlingRequest> dto)
- {
- var query = _orderSecondaryHandlingApplication.SecondaryHandlingReport(dto.QueryDto, HttpContext.RequestAborted);
- List<SecondaryHandlingVo> secondaryHandling;
- secondaryHandling = await query.ToListAsync(HttpContext.RequestAborted);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = secondaryHandling
- .Select(stu => _mapper.Map(stu, typeof(SecondaryHandlingVo), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "二次办理统计数据");
- }
- /// <summary>
- /// 二次办理明细
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("secondary_handling_detail_report")]
- public async Task<PagedDto<OrderSecondaryHandlingDto>> SecondaryHandlingDetailReport([FromQuery] QuerySecondaryHandlingRequest dto)
- {
- var query = _orderSecondaryHandlingApplication.SecondaryHandlingDetailReport(dto, HttpContext.RequestAborted);
- var (total, items) = await query.ToPagedListAsync(dto, HttpContext.RequestAborted);
- return new PagedDto<OrderSecondaryHandlingDto>(total, _mapper.Map<IReadOnlyList<OrderSecondaryHandlingDto>>(items));
- }
- /// <summary>
- /// 二次办理明细导出
- /// </summary>
- /// <returns></returns>
- [HttpPost("secondary_handling_detail_report/_export")]
- public async Task<FileStreamResult> SecondaryHandlingDetailReportExport([FromBody] ExportExcelDto<QuerySecondaryHandlingRequest> dto)
- {
- var query = _orderSecondaryHandlingApplication.SecondaryHandlingDetailReport(dto.QueryDto, HttpContext.RequestAborted);
- List<OrderSecondaryHandling> secondaryHandling;
- if (dto.IsExportAll)
- {
- secondaryHandling = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- secondaryHandling = items;
- }
- var secondaryHandlingDtos = _mapper.Map<ICollection<OrderSecondaryHandlingDto>>(secondaryHandling);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = secondaryHandlingDtos
- .Select(stu => _mapper.Map(stu, typeof(OrderSecondaryHandlingDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "二次办理列表数据");
- }
- /// <summary>
- /// 二次办理满意度统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("secondary_handling_satisfaction_report")]
- public async Task<List<SecondaryHandlingSatisfactionVo>> SecondaryHandlingSatisfactionReport([FromQuery] QuerySecondaryHandlingRequest dto)
- {
- var query = _orderSecondaryHandlingApplication.SecondaryHandlingSatisfactionReport(dto, HttpContext.RequestAborted);
- var list = await query.ToListAsync();
- //总计
- var total = new SecondaryHandlingSatisfactionVo
- {
- OrgId = "0",
- OrgName = "总计",
- TotalSumCount = list.Select(x => x.TotalSumCount).Sum(),
- VerySatisfiedCount = list.Select(x => x.VerySatisfiedCount).Sum(),
- SatisfiedCount = list.Select(x => x.SatisfiedCount).Sum(),
- RegardedAsSatisfiedCount = list.Select(x => x.RegardedAsSatisfiedCount).Sum(),
- DefaultSatisfiedCount = list.Select(x => x.DefaultSatisfiedCount).Sum(),
- NoSatisfiedCount = list.Select(x => x.NoSatisfiedCount).Sum(),
- NoEvaluateCount = list.Select(x => x.NoEvaluateCount).Sum(),
- NoPutThroughCount = list.Select(x => x.NoPutThroughCount).Sum(),
- NormalCount = list.Select(x => x.NormalCount).Sum(),//未接通
- VeryNoSatisfiedCount = list.Select(x => x.NormalCount).Sum(),//非常不满意
- };
- list.Add(total);
- //区县合计
- var countyList = list.Where(x => x.OrgType == EOrgType.County).ToList();
- var countyTotal = new SecondaryHandlingSatisfactionVo
- {
- OrgId = "0",
- OrgName = "区县合计",
- TotalSumCount = countyList.Select(x => x.TotalSumCount).Sum(),
- VerySatisfiedCount = countyList.Select(x => x.VerySatisfiedCount).Sum(),
- SatisfiedCount = countyList.Select(x => x.SatisfiedCount).Sum(),
- RegardedAsSatisfiedCount = countyList.Select(x => x.RegardedAsSatisfiedCount).Sum(),
- DefaultSatisfiedCount = countyList.Select(x => x.DefaultSatisfiedCount).Sum(),
- NoSatisfiedCount = countyList.Select(x => x.NoSatisfiedCount).Sum(),
- NoEvaluateCount = countyList.Select(x => x.NoEvaluateCount).Sum(),
- NoPutThroughCount = countyList.Select(x => x.NoPutThroughCount).Sum(),
- NormalCount = countyList.Select(x => x.NormalCount).Sum(),//未接通
- VeryNoSatisfiedCount = countyList.Select(x => x.NormalCount).Sum(),//非常不满意
- };
- list.Add(countyTotal);
- //市直合计
- var cityList = list.Where(x => x.OrgType == EOrgType.City).ToList();
- var cityTotal = new SecondaryHandlingSatisfactionVo
- {
- OrgId = "0",
- OrgName = "市直合计",
- TotalSumCount = cityList.Select(x => x.TotalSumCount).Sum(),
- VerySatisfiedCount = cityList.Select(x => x.VerySatisfiedCount).Sum(),
- SatisfiedCount = cityList.Select(x => x.SatisfiedCount).Sum(),
- RegardedAsSatisfiedCount = cityList.Select(x => x.RegardedAsSatisfiedCount).Sum(),
- DefaultSatisfiedCount = cityList.Select(x => x.DefaultSatisfiedCount).Sum(),
- NoSatisfiedCount = cityList.Select(x => x.NoSatisfiedCount).Sum(),
- NoEvaluateCount = cityList.Select(x => x.NoEvaluateCount).Sum(),
- NoPutThroughCount = cityList.Select(x => x.NoPutThroughCount).Sum(),
- NormalCount = cityList.Select(x => x.NormalCount).Sum(),//未接通
- VeryNoSatisfiedCount = cityList.Select(x => x.NormalCount).Sum(),//非常不满意
- };
- list.Add(cityTotal);
- return list;
- }
- /// <summary>
- /// 二次办理满意度统计导出
- /// </summary>
- /// <returns></returns>
- [HttpPost("secondary_handling_satisfaction_report/_export")]
- public async Task<FileStreamResult> SecondaryHandlingSatisfactionReportExport([FromBody] ExportExcelDto<QuerySecondaryHandlingRequest> dto)
- {
- var query = _orderSecondaryHandlingApplication.SecondaryHandlingSatisfactionReport(dto.QueryDto, HttpContext.RequestAborted);
- List<SecondaryHandlingSatisfactionVo> secondaryHandling;
- secondaryHandling = await query.ToListAsync(HttpContext.RequestAborted);
- //总计
- var total = new SecondaryHandlingSatisfactionVo
- {
- OrgId = "0",
- OrgName = "总计",
- TotalSumCount = secondaryHandling.Select(x => x.TotalSumCount).Sum(),
- VerySatisfiedCount = secondaryHandling.Select(x => x.VerySatisfiedCount).Sum(),
- SatisfiedCount = secondaryHandling.Select(x => x.SatisfiedCount).Sum(),
- RegardedAsSatisfiedCount = secondaryHandling.Select(x => x.RegardedAsSatisfiedCount).Sum(),
- DefaultSatisfiedCount = secondaryHandling.Select(x => x.DefaultSatisfiedCount).Sum(),
- NoSatisfiedCount = secondaryHandling.Select(x => x.NoSatisfiedCount).Sum(),
- NoEvaluateCount = secondaryHandling.Select(x => x.NoEvaluateCount).Sum(),
- NoPutThroughCount = secondaryHandling.Select(x => x.NoPutThroughCount).Sum()
- };
- secondaryHandling.Add(total);
- //区县合计
- var countyList = secondaryHandling.Where(x => x.OrgType == EOrgType.County).ToList();
- var countyTotal = new SecondaryHandlingSatisfactionVo
- {
- OrgId = "0",
- OrgName = "区县合计",
- TotalSumCount = countyList.Select(x => x.TotalSumCount).Sum(),
- VerySatisfiedCount = countyList.Select(x => x.VerySatisfiedCount).Sum(),
- SatisfiedCount = countyList.Select(x => x.SatisfiedCount).Sum(),
- RegardedAsSatisfiedCount = countyList.Select(x => x.RegardedAsSatisfiedCount).Sum(),
- DefaultSatisfiedCount = countyList.Select(x => x.DefaultSatisfiedCount).Sum(),
- NoSatisfiedCount = countyList.Select(x => x.NoSatisfiedCount).Sum(),
- NoEvaluateCount = countyList.Select(x => x.NoEvaluateCount).Sum(),
- NoPutThroughCount = countyList.Select(x => x.NoPutThroughCount).Sum()
- };
- secondaryHandling.Add(countyTotal);
- //市直合计
- var cityList = secondaryHandling.Where(x => x.OrgType == EOrgType.City).ToList();
- var cityTotal = new SecondaryHandlingSatisfactionVo
- {
- OrgId = "0",
- OrgName = "市直合计",
- TotalSumCount = cityList.Select(x => x.TotalSumCount).Sum(),
- VerySatisfiedCount = cityList.Select(x => x.VerySatisfiedCount).Sum(),
- SatisfiedCount = cityList.Select(x => x.SatisfiedCount).Sum(),
- RegardedAsSatisfiedCount = cityList.Select(x => x.RegardedAsSatisfiedCount).Sum(),
- DefaultSatisfiedCount = cityList.Select(x => x.DefaultSatisfiedCount).Sum(),
- NoSatisfiedCount = cityList.Select(x => x.NoSatisfiedCount).Sum(),
- NoEvaluateCount = cityList.Select(x => x.NoEvaluateCount).Sum(),
- NoPutThroughCount = cityList.Select(x => x.NoPutThroughCount).Sum()
- };
- secondaryHandling.Add(cityTotal);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = secondaryHandling
- .Select(stu => _mapper.Map(stu, typeof(SecondaryHandlingSatisfactionVo), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "二次办理满意度统计数据");
- }
- /// <summary>
- /// 二次办理满意度明细
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("secondary_handling_satisfaction_detail_report")]
- public async Task<PagedDto<OrderSecondaryHandlingDto>> SecondaryHandlingSatisfactionDetailReport([FromQuery] QuerySecondaryHandlingRequest dto)
- {
- var query = _orderSecondaryHandlingApplication.SecondaryHandlingSatisfactionDetailReport(dto, HttpContext.RequestAborted);
- var (total, items) = await query.ToPagedListAsync(dto, HttpContext.RequestAborted);
- return new PagedDto<OrderSecondaryHandlingDto>(total, _mapper.Map<IReadOnlyList<OrderSecondaryHandlingDto>>(items));
- }
- /// <summary>
- /// 二次办理满意度明细导出
- /// </summary>
- /// <returns></returns>
- [HttpPost("secondary_handling_satisfaction_detail_report/_export")]
- public async Task<FileStreamResult> SecondaryHandlingSatisfactionDetailReport([FromBody] ExportExcelDto<QuerySecondaryHandlingRequest> dto)
- {
- var query = _orderSecondaryHandlingApplication.SecondaryHandlingSatisfactionDetailReport(dto.QueryDto, HttpContext.RequestAborted);
- List<OrderSecondaryHandling> secondaryHandling;
- if (dto.IsExportAll)
- {
- secondaryHandling = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- secondaryHandling = items;
- }
- var secondaryHandlingDtos = _mapper.Map<ICollection<OrderSecondaryHandlingDto>>(secondaryHandling);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = secondaryHandlingDtos
- .Select(stu => _mapper.Map(stu, typeof(OrderSecondaryHandlingDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "二次办理满意度列表数据");
- }
- /// <summary>
- /// 未签收统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("unsigned_order_report")]
- public async Task<PagedDto<UnsignedOrderDto>> UnsignedOrderReport([FromQuery] QueryUnsignedOrdersRequest dto)
- {
- var query = _orderApplication.QueryUnsignedOrders(dto);
- var (total, items) = await query.Select((x, ws) => new UnsignedOrder { Order = x, WorkflowStep = ws }).ToPagedListAsync(dto, HttpContext.RequestAborted);
- var itemsVo = _mapper.Map<IReadOnlyList<UnsignedOrderDto>>(items);
- foreach (var item in itemsVo)
- {
- // item.UnsignedTime = _timeLimitDomainService.CalcWorkTimeToHour(item.WorkflowStep.CreationTime, item.WorkflowStep.Status != EWorkflowStepStatus.WaitForAccept && item.WorkflowStep.AcceptTime.HasValue ? item.WorkflowStep.AcceptTime!.Value : DateTime.Now, false);
- item.UnsignedTime = await _expireTime.CalcWorkTimeToHour(item.WorkflowStep.CreationTime, item.WorkflowStep.Status != EWorkflowStepStatus.WaitForAccept && item.WorkflowStep.AcceptTime.HasValue ? item.WorkflowStep.AcceptTime!.Value : DateTime.Now, false);
- }
- return new PagedDto<UnsignedOrderDto>(total, itemsVo);
- }
- /// <summary>
- /// 未签收统计导出
- /// </summary>
- /// <returns></returns>
- [HttpPost("unsigned_order_report/_export")]
- public async Task<FileStreamResult> UnsignedOrdersReport([FromBody] ExportExcelDto<QueryUnsignedOrdersRequest> dto)
- {
- var query = _orderApplication.QueryUnsignedOrders(dto.QueryDto).Select((x, ws) => new UnsignedOrder { Order = x, WorkflowStep = ws });
- List<UnsignedOrder> unsignedOrders;
- if (dto.IsExportAll)
- {
- unsignedOrders = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- unsignedOrders = items;
- }
- var unsignedOrderDtos = _mapper.Map<ICollection<UnsignedOrderDto>>(unsignedOrders);
- foreach (var item in unsignedOrderDtos)
- {
- // item.UnsignedTime = _timeLimitDomainService.CalcWorkTimeToHour(
- item.UnsignedTime = await _expireTime.CalcWorkTimeToHour(
- item.WorkflowStep.CreationTime, item.WorkflowStep.Status == EWorkflowStepStatus.WaitForAccept ? DateTime.Now : item.WorkflowStep.AcceptTime!.Value, false);
- }
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = unsignedOrderDtos
- .Select(stu => _mapper.Map(stu, typeof(UnsignedOrderDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "未签收统计列表数据");
- }
- /// <summary>
- /// 信件来源统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("order_source_report")]
- public async Task<IReadOnlyList<OrderSourceVo>> QueryOrderSourceReport([FromQuery] QueryOrderSourceRequest dto)
- {
- //var count = await _orderApplication.QueryOrderSource(dto).CountAsync();
- var query = _orderApplication.QueryOrderSource(dto);
- var items = await query.GroupBy(d => d.SourceChannel).Select(d => new OrderSourceVo { Source = d.SourceChannel, Num = SqlFunc.AggregateCount(d.Id) }).ToListAsync(HttpContext.RequestAborted);
- var count = items.Sum(x => x.Num);
- items.ForEach(x => x.TotalSumCount = count);
- items.Add(new OrderSourceVo { Source = "合计", Num = count, TotalSumCount = count });
- return items;
- }
- /// <summary>
- /// 信件来源统计导出
- /// </summary>
- /// <returns></returns>
- [HttpPost("order_source/_export")]
- public async Task<FileStreamResult> QueryOrderSourceReport([FromBody] ExportExcelDto<QueryOrderSourceRequest> dto)
- {
- //var count = await _orderApplication.QueryOrderSource(dto.QueryDto).CountAsync();
- var query = _orderApplication.QueryOrderSource(dto.QueryDto).GroupBy(d => d.SourceChannel).Select(d => new OrderSourceVo { Source = d.SourceChannel, Num = SqlFunc.AggregateCount(d.Id) });
- List<OrderSourceVo> orderSources;
- if (dto.IsExportAll)
- {
- orderSources = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- orderSources = items;
- }
- var count = orderSources.Sum(x => x.Num);
- orderSources.ForEach(x => x.TotalSumCount = count);
- orderSources.Add(new OrderSourceVo { Source = "合计", Num = count, TotalSumCount = count });
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = orderSources
- .Select(stu => _mapper.Map(stu, typeof(OrderSourceVo), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "信件来源统计数据");
- }
- /// <summary>
- /// 信件来源统计列表
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("order_source_report_list")]
- public async Task<Object> QueryOrderSourceReportList([FromQuery] QueryOrderSourceRequest dto)
- {
- var item = await _orderRepository.OrderSource(dto);
- var titleData = await _systemDicDataRepository.Queryable()
- .Where(p => p.DicTypeCode == "SourceChannel")
- .Select(p => new
- {
- Key = p.DicDataValue,
- Value = p.DicDataName
- }).ToListAsync();
- return new { Item = item, TitleData = titleData };
- }
- /// <summary>
- /// 信件来源统计导出
- /// </summary>
- /// <returns></returns>
- [HttpPost("order_source_list/_export")]
- public async Task<FileStreamResult> QueryOrderSourceListExport([FromBody] QueryOrderSourceRequest dto)
- {
- var dataTable = await _orderRepository.OrderSourceExport(dto);
- var stream = ExcelHelper.CreateStream(dataTable);
- return ExcelStreamResult(stream, "信件来源统计数据");
- }
- /// <summary>
- /// 信件来源统计明细
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("order_source_detail_report")]
- public async Task<PagedDto<OrderDto>> QueryOrderSourceDetailReport([FromQuery] QueryOrderSourceDetailRequest dto)
- {
- var (total, items) = await _orderApplication.QueryOrderSourceDetail(dto).ToPagedListAsync(dto, HttpContext.RequestAborted);
- return new PagedDto<OrderDto>(total, _mapper.Map<IReadOnlyList<OrderDto>>(items));
- }
- /// <summary>
- /// 信件来源统计明细导出
- /// </summary>
- /// <returns></returns>
- [HttpPost("order_source_detail/_export")]
- public async Task<FileStreamResult> QueryOrderSourceDetailReport([FromBody] ExportExcelDto<QueryOrderSourceDetailRequest> dto)
- {
- var query = _orderApplication.QueryOrderSourceDetail(dto.QueryDto);
- List<Order> orders;
- if (dto.IsExportAll)
- {
- orders = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- orders = items;
- }
- var ordersDtos = _mapper.Map<ICollection<OrderDto>>(orders);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = ordersDtos
- .Select(stu => _mapper.Map(stu, typeof(OrderDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "信件来源统计明细数据");
- }
- /// <summary>
- /// 区域分时统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("order_area_time")]
- public async Task<object> OrderAreaTime([FromQuery] TimeSharingPagedKeywordRequest dto)
- {
- var item = await _orderRepository.OrderAreaTime(dto);
- var titleData = await _systemAreaRepository.Queryable()
- .Where(p => p.Id.Length == 6 && p.Id != "510000")
- .Select(p => new
- {
- Key = p.Id,
- Value = p.AreaName
- }).ToListAsync();
- return new { Item = item, TitleData = titleData };
- }
- /// <summary>
- /// 区域分时统计-导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("order_area_time_export")]
- public async Task<FileStreamResult> OrderAreaTimeExport([FromBody] TimeSharingPagedKeywordRequest dto)
- {
- var dataTable = await _orderRepository.OrderAreaTimeExport(dto);
- var stream = ExcelHelper.CreateStream(dataTable);
- return ExcelStreamResult(stream, "区域分时统计数据");
- }
- /// <summary>
- /// 热点类型分时统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("order_hotspot_time")]
- public async Task<object> OrderHotspotTime([FromQuery] TimeSharingPagedKeywordRequest dto)
- {
- var item = await _orderRepository.OrderHotspotTime(dto);
- var titleData = await _hotspotRepository.Queryable()
- .Where(p => p.Id.Length == 2 && (p.ParentId == null || p.ParentId == ""))
- .Select(p => new
- {
- Key = p.Id,
- Value = p.HotSpotName
- }).ToListAsync();
- return new { Item = item, TitleData = titleData };
- }
- /// <summary>
- /// 热点类型分时统计-导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("order_hotspot_time_export")]
- public async Task<FileStreamResult> OrderHotspotTimeExport([FromBody] TimeSharingPagedKeywordRequest dto)
- {
- var dataTable = await _orderRepository.OrderHotspotTimeExport(dto);
- var stream = ExcelHelper.CreateStream(dataTable);
- return ExcelStreamResult(stream, "热点类型分时统计数据");
- }
- /// <summary>
- /// 受理类型分时统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("order_acceptance_time")]
- public async Task<object> OrderAcceptanceTime([FromQuery] TimeSharingPagedKeywordRequest dto)
- {
- var titleData = await _systemDicDataRepository.Queryable()
- .Where(p => p.DicTypeCode == "AcceptType")
- .Select(p => new Kv()
- {
- Key = p.DicDataValue,
- Value = p.DicDataName
- }).OrderBy(p => p.Key).ToListAsync();
- var item = await _orderRepository.OrderAcceptanceTime(dto);
- var res = new { Item = item, TitleData = titleData };
- return res;
- }
- /// <summary>
- /// 受理类型分时统计-导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("order_acceptance_time_export")]
- public async Task<FileStreamResult> OrderAcceptanceTimeExport([FromBody] TimeSharingPagedKeywordRequest dto)
- {
- var titleData = await _systemDicDataRepository.Queryable()
- .Where(p => p.DicTypeCode == "AcceptType")
- .Select(p => new Kv()
- {
- Key = p.DicDataValue,
- Value = p.DicDataName
- }).OrderBy(p => p.Key).ToListAsync();
- var dataTable = await _orderRepository.OrderAcceptanceTimeExport(dto, titleData);
- var stream = ExcelHelper.CreateStream(dataTable);
- return ExcelStreamResult(stream, "受理类型分时统计数据");
- }
- /// <summary>
- /// 信件来源分时统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("order_source_time")]
- public async Task<object> OrderSourceTime([FromQuery] TimeSharingPagedKeywordRequest dto)
- {
- var item = await _orderRepository.OrderSourceTime(dto);
- var titleData = await _systemDicDataRepository.Queryable()
- .Where(p => p.DicTypeCode == "SourceChannel")
- .Select(p => new
- {
- Key = p.DicDataValue,
- Value = p.DicDataName
- }).ToListAsync();
- return new { Item = item, TitleData = titleData };
- }
- /// <summary>
- /// 信件来源分时统计-导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("order_source_time_export")]
- public async Task<FileStreamResult> OrderSourceTimeExport([FromBody] TimeSharingPagedKeywordRequest dto)
- {
- var dataTable = await _orderRepository.OrderSourceTimeExport(dto);
- var stream = ExcelHelper.CreateStream(dataTable);
- return ExcelStreamResult(stream, "信件来源分时统计数据");
- }
- /// <summary>
- /// 部门满意度明细
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("org-visitdetail-list")]
- public async Task<PagedDto<OrgVisitDetailListResp>> OrgVisitDetailList([FromQuery] OrgVisitDetailListReq dto)
- {
- //var query = _orderReportApplication.OrgVisitDetailList(dto);
- var query = _orderRepository.OrgVisitDetailList(dto);
- Console.Write(query.ToSqlString());
- var (total, items) = await query.ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
- return new PagedDto<OrgVisitDetailListResp>(total, _mapper.Map<IReadOnlyList<OrgVisitDetailListResp>>(items));
- }
- /// <summary>
- /// 部门满意度明细页面基础数据
- /// </summary>
- /// <returns></returns>
- [HttpGet("org-visitdetail-list-basedata")]
- public async Task<Dictionary<string, dynamic>> OrgVisitDetailListBaseData()
- {
- IReadOnlyList<SystemOrganize> items;
- if (_sessionContext.OrgIsCenter)
- items = await _systemOrganizeRepository.GetOrgJson();
- else
- items = await _systemOrganizeRepository.GetOrgJsonForUser(_sessionContext.RequiredOrgId); ;
- var wfModule = await _workflowApplication.GetWorkflowModuleAsync(WorkflowModuleConsts.OrderHandle, HttpContext.RequestAborted);
- var definition = wfModule.Definition;
- return new Dictionary<string, dynamic>
- {
- { "visitSatisfaction", _systemDicDataCacheManager.GetVisitSatisfaction() },
- { "orgsOptions", items },
- { "attitudeType", EnumExts.GetDescriptions<EAttitudeType>() },
- { "visitType",EnumExts.GetDescriptions<EVisitType>() },
- { "channelOptions",_sysDicDataCacheManager.GetSysDicDataCache(TimeLimitBaseDataConsts.SourceChannel) },
- { "acceptTypeOptions",_sysDicDataCacheManager.GetSysDicDataCache(SysDicTypeConsts.AcceptType)},
- { "orderStatusOptions", EnumExts.GetDescriptions<EOrderStatus>()},
- { "currentStepOptions",definition?.Steps.Select(x => new Kv(x.Code, x.Name))},
- { "visitMananer", _sysDicDataCacheManager.GetSysDicDataCache(SysDicTypeConsts.VisitManner) },
- };
- }
- /// <summary>
- /// 部门满意度明细导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("org-visitdetail-list-export")]
- public async Task<FileStreamResult> OrgVisitDetailListExport([FromBody] ExportExcelDto<OrgVisitDetailListReq> dto)
- {
- var query = _orderRepository.OrgVisitDetailList(dto.QueryDto);
- List<OrgVisitDetailListResp> orders;
- if (dto.IsExportAll)
- {
- orders = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- orders = items;
- }
- //var ordersDtos = _mapper.Map<ICollection<OrgVisitDetailListResp>>(orders);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = orders
- .Select(stu => _mapper.Map(stu, typeof(OrgVisitDetailListResp), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "部门满意度明细");
- }
- /// <summary>
- /// 热点区域统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("hotspot-area-statistics")]
- public async Task<object> HotspotAndAreaStatistics([FromQuery] HotspotAndAreaStatisticsReq dto)
- {
- var (areaList, returnList) = await _orderApplication.HotspotAndAreaStatistics(dto);
- return new { AreaList = areaList, Data = returnList };
- }
- /// <summary>
- /// 热点区域统计导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("hotspot-area-statistics-export")]
- public async Task<FileStreamResult> HotspotAndAreaStatisticsExport([FromBody] HotspotAndAreaStatisticsReq dto)
- {
- var returnList = await _orderApplication.HotspotAndAreaStatisticsExport(dto);
- var table = _orderApplication.InitHotspotTable(returnList, dto.AddColumnName, dto.HotspotLevel);
- var stream = ExcelHelper.CreateStream(table);
- return ExcelStreamResult(stream, "热点区域统计");
- }
- /// <summary>
- /// 热点区域明细
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("hotspot-area-statistics-detail")]
- public async Task<PagedDto<HotspotAndAreaStatisticsDetailDto>> HotspotAndAreaStatisticsDetail([FromQuery] HotspotAndAreaStatisticsDetailReq dto)
- {
- var (total, items) = await _orderRepository.HotspotAndAreaStatisticsDetail(dto).ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
- return new PagedDto<HotspotAndAreaStatisticsDetailDto>(total, items);
- }
- /// <summary>
- /// 受理类型明细
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("accepttype-statistics-bydate-detail")]
- public async Task<PagedDto<HotspotAndAreaStatisticsDetailDto>> AcceptTypeStatisticsByDateDetail([FromQuery] AcceptTypeStatisticsByDateDetailReq dto)
- {
- var (total, items) = await _orderRepository.AcceptTypeStatisticsByDateDetail(dto).ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
- return new PagedDto<HotspotAndAreaStatisticsDetailDto>(total, items);
- }
- /// <summary>
- /// 受理类型明细导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("accepttype-statistics-bydate-detail-export")]
- public async Task<FileStreamResult> AcceptTypeStatisticsByDateDetailExport([FromBody] ExportExcelDto<AcceptTypeStatisticsByDateDetailReq> dto)
- {
- var query = _orderRepository.AcceptTypeStatisticsByDateDetail(dto.QueryDto);
- List<HotspotAndAreaStatisticsDetailDto> orders;
- if (dto.IsExportAll)
- {
- orders = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- orders = items;
- }
- var ordersDtos = _mapper.Map<ICollection<HotspotAndAreaStatisticsDetailDto>>(orders);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = ordersDtos
- .Select(stu => _mapper.Map(stu, typeof(HotspotAndAreaStatisticsDetailDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "受理类型明细");
- }
- /// <summary>
- /// 热点区域明细导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("hotspot-area-statistics-detail-export")]
- public async Task<FileStreamResult> HotspotAndAreaStatisticsDetailExport([FromBody] ExportExcelDto<HotspotAndAreaStatisticsDetailReq> dto)
- {
- var query = _orderRepository.HotspotAndAreaStatisticsDetail(dto.QueryDto);
- List<HotspotAndAreaStatisticsDetailDto> orders;
- if (dto.IsExportAll)
- {
- orders = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- orders = items;
- }
- var ordersDtos = _mapper.Map<ICollection<HotspotAndAreaStatisticsDetailDto>>(orders);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = ordersDtos
- .Select(stu => _mapper.Map(stu, typeof(HotspotAndAreaStatisticsDetailDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "热点区域明细");
- }
- /// <summary>
- /// 受理类型统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("accepttype-statistics")]
- public async Task<List<AcceptTypeStatisticsDto>> AcceptTypeStatistics([FromQuery] AcceptTypeStatisticsReq dto)
- {
- var list = await _orderReportApplication.AcceptTypeStatistics(dto).ToListAsync();
- int SumCount = list.Sum(x => x.SumCount);
- list.Add(new AcceptTypeStatisticsDto()
- {
- AcceptType = "合计",
- SumCount = SumCount,
- CompletionCount = list.Sum(x => x.CompletionCount),
- VisitCount = list.Sum(x => x.VisitCount)
- });
- list.ForEach(x =>
- {
- x.SumCountRate = SumCount > 0 ? Math.Round((double)x.SumCount / (double)SumCount * 100, digits: 3) + "%" : 0.000 + "%";
- });
- return list;
- }
- /// <summary>
- /// 受理类型统计-导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("accepttype-statistics-export")]
- public async Task<FileStreamResult> AcceptTypeStatisticsExport([FromBody] ExportExcelDto<AcceptTypeStatisticsReq> dto)
- {
- var list = await _orderReportApplication.AcceptTypeStatistics(dto.QueryDto).ToListAsync();
- int SumCount = list.Sum(x => x.SumCount);
- list.Add(new AcceptTypeStatisticsDto()
- {
- AcceptType = "合计",
- SumCount = SumCount,
- CompletionCount = list.Sum(x => x.CompletionCount),
- VisitCount = list.Sum(x => x.VisitCount)
- });
- list.ForEach(x =>
- {
- x.SumCountRate = SumCount > 0 ? Math.Round((double)x.SumCount / (double)SumCount * 100, digits: 3) + "%" : 0.000 + "%";
- });
- var orderDtos = _mapper.Map<ICollection<AcceptTypeStatisticsDto>>(list);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = orderDtos
- .Select(stu => _mapper.Map(stu, typeof(AcceptTypeStatisticsDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "受理类型统计表数据");
- }
- /// <summary>
- /// 根据时间查询受理类型统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("accepttype-statistics-bydate")]
- public async Task<object> AcceptTypeStatisticsByDate([FromQuery] AcceptTypeStatisticsByDateReq dto)
- {
- var (acceptList, items) = await _orderRepository.AcceptTypeStatisticsByDate(dto);
- return new { AcceptType = acceptList, Data = items };
- }
- /// <summary>
- /// 根据时间查询受理类型统计导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("accepttype-statistics-bydate-export")]
- public async Task<FileStreamResult> AcceptTypeStatisticsByDateExport([FromBody] AcceptTypeStatisticsByDateReq dto)
- {
- var returnList = await _orderRepository.AcceptTypeStatisticsByDateExport(dto);
- var table = _orderRepository.InitAcceptTypeTable(returnList, dto.AddColumnName);
- var stream = ExcelHelper.CreateStream(table);
- return ExcelStreamResult(stream, "受理类型时间统计");
- }
- /// <summary>
- /// 下级区域统计
- /// </summary>
- /// <param name="StartTime">开始时间</param>
- /// <param name="EndTime">结束时间</param>
- /// <param name="TypeId">0:全部 ,1:市民,2:企业</param>
- /// <param name="AreaCode">上级区域Id</param>
- /// <param name="Line">线路号</param>
- /// <returns></returns>
- [HttpGet("area_subordinate")]
- public async Task<object> AreaSubordinate(DateTime StartTime, DateTime EndTime, int? TypeId, string? AreaCode, string? Line)
- {
- string count = "6";
- if (!string.IsNullOrEmpty(AreaCode) && AreaCode != "511500")
- count = (AreaCode.Length + 2).ToString();
- if (string.IsNullOrEmpty(AreaCode))
- AreaCode = "510000";
- if (AreaCode == "510000")
- {
- var query = _orderRepository.Queryable()
- .Where(p => p.CreationTime >= StartTime && p.CreationTime <= EndTime)
- .WhereIF(TypeId != null && TypeId == 1, p => p.IdentityType == EIdentityType.Citizen)
- .WhereIF(TypeId != null && TypeId == 2, p => p.IdentityType == EIdentityType.Enterprise)
- .WhereIF(!string.IsNullOrEmpty(Line), p => p.TransferPhone == Line)
- .Select(p => new
- {
- AreaCode = p.AreaCode.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>(count)),
- })
- .MergeTable()
- .Select(p => new
- {
- AreaCode = SqlFunc.IIF(p.AreaCode != "519800" && p.AreaCode != "519900", "511500", p.AreaCode)
- }
- ).MergeTable()
- .GroupBy(p => p.AreaCode)
- .Select(p => new
- {
- AreaCode = p.AreaCode,
- SumCount = SqlFunc.AggregateCount(p.AreaCode)
- }
- ).MergeTable();
- var list = await _systemAreaRepository.Queryable()
- .LeftJoin(query, (s, o) => s.Id == o.AreaCode)
- .Where((s, o) => s.ParentId == AreaCode)
- .Select((s, o) => new
- {
- AreaCode = s.Id,
- SumCount = o.SumCount,
- AreaName = s.AreaName,
- HasChild = SqlFunc.Subqueryable<SystemArea>().Where(d => d.ParentId == o.AreaCode).Any()
- })
- .ToListAsync();
- return list;
- }
- else
- {
- var query = _orderRepository.Queryable()
- .Where(p => p.CreationTime >= StartTime && p.CreationTime <= EndTime)
- .WhereIF(TypeId != null && TypeId == 1, p => p.IdentityType == EIdentityType.Citizen)
- .WhereIF(TypeId != null && TypeId == 2, p => p.IdentityType == EIdentityType.Enterprise)
- .WhereIF(!string.IsNullOrEmpty(Line), p => p.TransferPhone == Line)
- .GroupBy(p => new { Id = p.AreaCode.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>(count)) })
- .Select(p => new
- {
- AreaCode = p.AreaCode.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>(count)),
- SumCount = SqlFunc.AggregateCount(p.AreaCode)
- })
- .MergeTable();
- var list = await _systemAreaRepository.Queryable()
- .LeftJoin(query, (s, o) => s.Id == o.AreaCode)
- .Where((s, o) => s.ParentId == AreaCode)
- .Select((s, o) => new
- {
- AreaCode = s.Id,
- SumCount = o.SumCount,
- AreaName = s.AreaName,
- HasChild = SqlFunc.Subqueryable<SystemArea>().Where(d => d.ParentId == o.AreaCode).Any()
- })
- .ToListAsync();
- return list;
- }
- }
- /// <summary>
- /// 热点满意度统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("visit-hotspot-satisfaction-statistics")]
- public async Task<Object> VisitAndHotspotSatisfactionStatistics([FromQuery] VisitAndHotspotPagedKeywordRequest dto)
- {
- var data = await _orderApplication.VisitAndHotspotSatisfactionStatistics(dto);
- var sumModel = new VisitAndHotspotSatisfactionStatisticsDto()
- {
- HotspotName = "总计",
- TotalSumCount = data.Sum(x => x.TotalSumCount),
- VerySatisfiedCount = data.Sum(x => x.VerySatisfiedCount),
- SatisfiedCount = data.Sum(x => x.SatisfiedCount),
- RegardedAsSatisfiedCount = data.Sum(x => x.RegardedAsSatisfiedCount),
- DefaultSatisfiedCount = data.Sum(x => x.DefaultSatisfiedCount),
- NoSatisfiedCount = data.Sum(x => x.NoSatisfiedCount),
- NoEvaluateCount = data.Sum(x => x.NoEvaluateCount),
- NoPutThroughCount = data.Sum(x => x.NoPutThroughCount),
- };
- return new { DataList = data, SumModel = sumModel };
- }
- /// <summary>
- /// 热点满意度统计导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("visit-hotspot-satisfaction-statistics/_export")]
- public async Task<FileStreamResult> VisitAndHotspotSatisfactionStatisticsExport([FromBody] ExportExcelDto<VisitAndHotspotPagedKeywordRequest> dto)
- {
- List<VisitAndHotspotSatisfactionStatisticsDto> data = await _orderApplication.VisitAndHotspotSatisfactionStatistics(dto.QueryDto);
- var sumModel = new VisitAndHotspotSatisfactionStatisticsDto()
- {
- HotspotName = "总计",
- TotalSumCount = data.Sum(x => x.TotalSumCount),
- VerySatisfiedCount = data.Sum(x => x.VerySatisfiedCount),
- SatisfiedCount = data.Sum(x => x.SatisfiedCount),
- RegardedAsSatisfiedCount = data.Sum(x => x.RegardedAsSatisfiedCount),
- DefaultSatisfiedCount = data.Sum(x => x.DefaultSatisfiedCount),
- NoSatisfiedCount = data.Sum(x => x.NoSatisfiedCount),
- NoEvaluateCount = data.Sum(x => x.NoEvaluateCount),
- NoPutThroughCount = data.Sum(x => x.NoPutThroughCount),
- };
- data.Add(sumModel);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = data
- .Select(stu => _mapper.Map(stu, typeof(VisitAndHotspotSatisfactionStatisticsDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "热点满意度统计数据");
- }
- /// <summary>
- /// 热点满意度明细
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("visit-hotspot-satisfaction-detail")]
- public async Task<PagedDto<OrderVisitDetailDto>> VisitAndHotspotSatisfactionDetail([FromQuery] VisitAndHotspotPagedKeywordRequest dto)
- {
- var (total, items) = await _orderApplication.VisitAndHotspotSatisfactionDetail(dto)
- .ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
- return new PagedDto<OrderVisitDetailDto>(total, _mapper.Map<IReadOnlyList<OrderVisitDetailDto>>(items));
- }
- /// <summary>
- /// 热点满意度明细导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("visit-hotspot-satisfaction-detail/_export")]
- public async Task<FileStreamResult> VisitAndHotspotSatisfactionDetailExport([FromBody] ExportExcelDto<VisitAndHotspotPagedKeywordRequest> dto)
- {
- var query = _orderApplication.VisitAndHotspotSatisfactionDetail(dto.QueryDto);
- List<OrderVisitDetail> data;
- if (dto.IsExportAll)
- {
- data = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- data = items;
- }
- var dataDtos = _mapper.Map<ICollection<OrderVisitDetailDto>>(data);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = dataDtos
- .Select(stu => _mapper.Map(stu, typeof(OrderVisitDetailDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "热点满意度明细数据");
- }
- /// <summary>
- /// 热点受理类型统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("hotspot-accepttype-statistics")]
- public async Task<object> HotspotAndAcceptTypeStatistics([FromQuery] HotspotAndAcceptTypeStatisticsReq dto)
- {
- var (areaList, returnList) = await _orderApplication.HotspotAndAcceptTypeStatistics(dto);
- return new { AreaList = areaList, Data = returnList };
- }
- /// <summary>
- /// 热点受理类型统计导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("hotspot-accepttype-statistics-export")]
- public async Task<FileStreamResult> HotspotAndAcceptTypeStatisticsExport([FromBody] HotspotAndAcceptTypeStatisticsReq dto)
- {
- var returnList = await _orderApplication.HotspotAndAcceptTypeStatisticsExport(dto);
- var table = _orderApplication.InitHotspotTable(returnList, dto.AddColumnName, dto.HotspotLevel);
- var stream = ExcelHelper.CreateStream(table);
- return ExcelStreamResult(stream, "热点受理类型统计");
- }
- /// <summary>
- /// 热点受理类型明细
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("hotspot-accepttype-statistics-detail")]
- public async Task<PagedDto<OrderDto>> HotspotAndAcceptTypeStatisticsDetail([FromQuery] HotspotAndAcceptTypeStatisticsDetailReq dto)
- {
- var (total, items) = await _orderApplication.HotspotAndAcceptTypeStatisticsDetail(dto).ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
- return new PagedDto<OrderDto>(total, _mapper.Map<IReadOnlyList<OrderDto>>(items));
- }
- /// <summary>
- /// 热点受理类型明细导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("hotspot-accepttype-statistics-detail-export")]
- public async Task<FileStreamResult> HotspotAndAcceptTypeStatisticsDetailExport([FromBody] ExportExcelDto<HotspotAndAcceptTypeStatisticsDetailReq> dto)
- {
- var query = _orderApplication.HotspotAndAcceptTypeStatisticsDetail(dto.QueryDto);
- List<Order> orders;
- if (dto.IsExportAll)
- {
- orders = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- orders = items;
- }
- var ordersDtos = _mapper.Map<ICollection<OrderDto>>(orders);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = ordersDtos
- .Select(stu => _mapper.Map(stu, typeof(OrderDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "热点受理类型明细");
- }
- /// <summary>
- /// 甄别申请统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("screen-apply")]
- public async Task<PagedDto<OrderScreenApplyVo>> OrderScreenApply([FromQuery] OrderScreenApplyPagedRequest dto)
- {
- var (total, items) = await _orderApplication.OrderScreenApply(dto).ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
- return new PagedDto<OrderScreenApplyVo>(total, items);
- }
- /// <summary>
- /// 甄别申请统计导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("screen-apply-export")]
- public async Task<FileStreamResult> OrderScreenApplyExport([FromBody] ExportExcelDto<OrderScreenApplyPagedRequest> dto)
- {
- var query = _orderApplication.OrderScreenApply(dto.QueryDto);
- List<OrderScreenApplyVo> datas;
- if (dto.IsExportAll)
- {
- datas = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- datas = items;
- }
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = datas
- .Select(stu => _mapper.Map(stu, typeof(OrderScreenApplyVo), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "甄别申请统计");
- }
- /// <summary>
- /// 甄别审批统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("screen-audit")]
- public async Task<PagedDto<OrderScreenAuditVo>> OrderScreenAudit([FromQuery] OrderScreenAuditPagedRequest dto)
- {
- var (total, items) = await _orderApplication.OrderScreenAudit(dto).ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
- return new PagedDto<OrderScreenAuditVo>(total, items);
- }
- /// <summary>
- /// 甄别审批统计导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("screen-audit-export")]
- public async Task<FileStreamResult> OrderScreenAuditExport([FromBody] ExportExcelDto<OrderScreenAuditPagedRequest> dto)
- {
- var query = _orderApplication.OrderScreenAudit(dto.QueryDto);
- List<OrderScreenAuditVo> datas;
- if (dto.IsExportAll)
- {
- datas = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- datas = items;
- }
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = datas
- .Select(stu => _mapper.Map(stu, typeof(OrderScreenAuditVo), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "甄别审批统计");
- }
- /// <summary>
- /// 未签收统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("get_order_nosigen")]
- public async Task<object> GetOrderNoSigen([FromQuery] OrderNoSigenRequestDto dto)
- {
- var items = await _orderReportApplication.GetOrderNoSigen(dto);
- var total = new OrderNoSigenDto
- {
- OrgName = "合计",
- OrgCode = "",
- OrderNoSigen = items.Sum(p => p.OrderNoSigen),
- CounterNoSign = items.Sum(p => p.CounterNoSign)
- };
- return new { List = items, Total = total };
- }
- /// <summary>
- /// 未签收统计--导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("get_order_nosigen_export")]
- public async Task<FileStreamResult> ExportGetOrderNoSigen([FromBody] ExportExcelDto<OrderNoSigenRequestDto> dto)
- {
- var list = await _orderReportApplication.GetOrderNoSigen(dto.QueryDto);
- //增加合计
- list.Add(new OrderNoSigenDto
- {
- OrgName = "合计",
- OrgCode = "",
- OrderNoSigen = list.Sum(p => p.OrderNoSigen),
- CounterNoSign = list.Sum(p => p.CounterNoSign)
- });
- var orderDtos = _mapper.Map<ICollection<OrderNoSigenDto>>(list);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = orderDtos
- .Select(stu => _mapper.Map(stu, typeof(OrderNoSigenDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "未签收统计数据");
- }
- /// <summary>
- /// 未签收统计--明细
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("get_order_nosigen_detail")]
- public async Task<PagedDto<OrderDto>> GetOrderNoSigenDetail([FromQuery] OrderNoSigenRequestDto dto)
- {
- RefAsync<int> total = 0;
- var queryData = await _orderReportApplication.GetOrderNoSigenDetail(dto)
- .Select(o => new { o })
- .ToPageListAsync(dto.PageIndex, dto.PageSize, total, HttpContext.RequestAborted);
- var dtos = queryData.Select(d =>
- {
- var dto = _mapper.Map<OrderDto>(d.o);
- return dto;
- }).ToList();
- return new PagedDto<OrderDto>(total, dtos);
- }
- /// <summary>
- /// 未签收统计--明细--导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("get_order_nosigen_detail_export")]
- public async Task<FileStreamResult> ExportGetOrderNoSigenDetail([FromBody] ExportExcelDto<OrderNoSigenRequestDto> dto)
- {
- var query = _orderReportApplication.GetOrderNoSigenDetail(dto.QueryDto).Select(o => new { o });
- List<OrderDto> list = new();
- if (dto.IsExportAll)
- {
- var listData = await query.ToListAsync(HttpContext.RequestAborted);
- list = listData.Select(d =>
- {
- var dto = _mapper.Map<OrderDto>(d.o);
- return dto;
- }).ToList();
- }
- else
- {
- RefAsync<int> total = 0;
- var listData = await query.ToPageListAsync(dto.QueryDto.PageIndex, dto.QueryDto.PageSize, total, HttpContext.RequestAborted);
- list = listData.Select(d =>
- {
- var dto = _mapper.Map<OrderDto>(d.o);
- return dto;
- }).ToList();
- }
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = list
- .Select(stu => _mapper.Map(stu, typeof(OrderDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "未签收统计明细数据");
- }
- /// <summary>
- /// 企业专席信件统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("get_enterprise_seats_report")]
- public async Task<object> GetEnterpriseSeatsReport([FromQuery] EnterpriseSeatsReportRequestDto dto)
- {
- var items = await _orderReportApplication.GetEnterpriseSeatsReport(dto);
- var total = new EnterpriseSeatsReportDto
- {
- UserName = "合计",
- UserId = "",
- UserNo = "",
- TelCallNum = items.Sum(p => p.TelCallNum),
- OrderNum = items.Sum(p => p.OrderNum),
- };
- return new { List = items, Total = total };
- }
- /// <summary>
- /// 企业专席信件统计--导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("get_enterprise_seats_report_export")]
- public async Task<FileStreamResult> ExportGetEnterpriseSeatsReport([FromBody] ExportExcelDto<EnterpriseSeatsReportRequestDto> dto)
- {
- var list = await _orderReportApplication.GetEnterpriseSeatsReport(dto.QueryDto);
- //增加合计
- list.Add(new EnterpriseSeatsReportDto
- {
- UserName = "合计",
- UserId = "",
- UserNo = "",
- TelCallNum = list.Sum(p => p.TelCallNum),
- OrderNum = list.Sum(p => p.OrderNum),
- });
- var orderDtos = _mapper.Map<ICollection<EnterpriseSeatsReportDto>>(list);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = orderDtos
- .Select(stu => _mapper.Map(stu, typeof(EnterpriseSeatsReportDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "企业专席信件统计");
- }
- /// <summary>
- /// 企业专席信件统计--明细
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("get_enterprise_seats_report_detail")]
- public async Task<PagedDto<OrderDto>> GetEnterpriseSeatsReportDetail([FromQuery] EnterpriseSeatsReportRequestDto dto)
- {
- RefAsync<int> total = 0;
- var queryData = await _orderReportApplication.GetEnterpriseSeatsReportDetail(dto)
- .ToPageListAsync(dto.PageIndex, dto.PageSize, total, HttpContext.RequestAborted);
- return new PagedDto<OrderDto>(total, _mapper.Map<List<OrderDto>>(queryData));
- }
- /// <summary>
- /// 企业专席信件统计--明细--导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("get_enterprise_seats_report_detail_export")]
- public async Task<FileStreamResult> ExportGetEnterpriseSeatsReportDetail([FromBody] ExportExcelDto<EnterpriseSeatsReportRequestDto> dto)
- {
- var query = _orderReportApplication.GetEnterpriseSeatsReportDetail(dto.QueryDto);
- List<OrderDto> list = new();
- if (dto.IsExportAll)
- {
- var listData = await query.ToListAsync(HttpContext.RequestAborted);
- list = _mapper.Map<List<OrderDto>>(listData);
- }
- else
- {
- RefAsync<int> total = 0;
- var listData = await query.ToPageListAsync(dto.QueryDto.PageIndex, dto.QueryDto.PageSize, total, HttpContext.RequestAborted);
- list = _mapper.Map<List<OrderDto>>(listData);
- }
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = list
- .Select(stu => _mapper.Map(stu, typeof(OrderDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "企业专席信件统计");
- }
- /// <summary>
- /// 中心受理统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("center-accept")]
- public async Task<List<OrderCenterAcceptVo>> OrderCenterAccept([FromQuery] OrderCenterAcceptPagedRequest dto)
- {
- var items = await _orderApplication.OrderCenterAccept(dto).ToListAsync(HttpContext.RequestAborted);
- items.Add(new OrderCenterAcceptVo
- {
- Time = "合计",
- AcceptNum = items.Sum(p => p.AcceptNum),
- ValidNum = items.Sum(p => p.ValidNum),
- RepetitionNum = items.Sum(p => p.RepetitionNum),
- InvalidNum = items.Sum(p => p.InvalidNum),
- HandleNum = items.Sum(p => p.HandleNum),
- NoHandleNum = items.Sum(p => p.NoHandleNum),
- BackNum = items.Sum(p => p.BackNum),
- DutyDeskNum = items.Sum(p => p.DutyDeskNum),
- });
- return items;
- }
- /// <summary>
- /// 中心受理统计导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("center-accept-export")]
- public async Task<FileStreamResult> OrderCenterAcceptExport([FromBody] ExportExcelDto<OrderCenterAcceptPagedRequest> dto)
- {
- var query = _orderApplication.OrderCenterAccept(dto.QueryDto);
- List<OrderCenterAcceptVo> datas;
- if (dto.IsExportAll)
- {
- datas = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- datas = items;
- }
- datas.Add(new OrderCenterAcceptVo
- {
- Time = "合计",
- AcceptNum = datas.Sum(p => p.AcceptNum),
- ValidNum = datas.Sum(p => p.ValidNum),
- RepetitionNum = datas.Sum(p => p.RepetitionNum),
- InvalidNum = datas.Sum(p => p.InvalidNum),
- HandleNum = datas.Sum(p => p.HandleNum),
- NoHandleNum = datas.Sum(p => p.NoHandleNum),
- BackNum = datas.Sum(p => p.BackNum),
- DutyDeskNum = datas.Sum(p => p.DutyDeskNum),
- });
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = datas
- .Select(stu => _mapper.Map(stu, typeof(OrderCenterAcceptVo), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "中心受理统计");
- }
- /// <summary>
- /// 中心受理值班坐席统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("center-accept-user")]
- public async Task<PagedDto<OrderCenterAcceptUserVo>> OrderCenterAcceptUser([FromQuery] OrderCenterAcceptPagedRequest dto)
- {
- var (total, items) = await _orderApplication.OrderCenterAcceptUser(dto).ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
- return new PagedDto<OrderCenterAcceptUserVo>(total, items);
- }
- /// <summary>
- /// 中心受理值班坐席统计导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("center-accept-user-export")]
- public async Task<FileStreamResult> OrderCenterAcceptUserExport([FromBody] ExportExcelDto<OrderCenterAcceptPagedRequest> dto)
- {
- var query = _orderApplication.OrderCenterAcceptUser(dto.QueryDto);
- List<OrderCenterAcceptUserVo> datas;
- if (dto.IsExportAll)
- {
- datas = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- datas = items;
- }
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = datas
- .Select(stu => _mapper.Map(stu, typeof(OrderCenterAcceptUserVo), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "中心受理值班坐席统计");
- }
- /// <summary>
- /// 中心受理时间段统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("center-accept-hour")]
- public async Task<List<OrderCenterAcceptHourVo>> OrderCenterAcceptHour([FromQuery] OrderCenterAcceptPagedRequest dto)
- {
- var items = await _orderRepository.OrderCenterAcceptHour(dto).ToListAsync(HttpContext.RequestAborted);
- return items;
- }
- /// <summary>
- /// 中心受理时间段统计导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("center-accept-hour-export")]
- public async Task<FileStreamResult> OrderCenterAcceptHourExport([FromBody] ExportExcelDto<OrderCenterAcceptPagedRequest> dto)
- {
- var query = _orderRepository.OrderCenterAcceptHour(dto.QueryDto);
- List<OrderCenterAcceptHourVo> datas;
- if (dto.IsExportAll)
- {
- datas = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- datas = items;
- }
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = datas
- .Select(stu => _mapper.Map(stu, typeof(OrderCenterAcceptHourVo), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "中心受理时间段统计");
- }
- /// <summary>
- /// 数据清单基础数据
- /// </summary>
- /// <returns></returns>
- [HttpGet("order-data-inventory-basedata")]
- public async Task<object> OrderDataInventoryBaseData()
- {
- var wfModule = await _workflowApplication.GetWorkflowModuleAsync(WorkflowModuleConsts.OrderHandle, HttpContext.RequestAborted);
- var definition = wfModule.Definition;
- return new
- {
- OrderStatusOptions = EnumExts.GetDescriptions<EOrderStatus>(),
- ChannelOptions = _sysDicDataCacheManager.GetSysDicDataCache(TimeLimitBaseDataConsts.SourceChannel),
- ScreenStatusOptions = EnumExts.GetDescriptions<EScreenStatus>(),
- AcceptTypeOptions = _sysDicDataCacheManager.GetSysDicDataCache(SysDicTypeConsts.AcceptType),
- IdentityTypeOptions = EnumExts.GetDescriptions<EIdentityType>(),
- FromGenderOptions = EnumExts.GetDescriptions<EGender>(),
- ExpiredStatusOptions = EnumExts.GetDescriptions<EExpiredStatusEx>(),
- PushTypeOptions = _sysDicDataCacheManager.GetSysDicDataCache(SysDicTypeConsts.PushType),
- CurrentStepOptions = definition?.Steps.Select(x => new Kv(x.Code, x.Name)),
- OrgsOptions = await _organizeRepository.GetOrgJson(),
- GenderOptions = EnumExts.GetDescriptions<EGender>(),
- };
- }
- /// <summary>
- /// 数据清单
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("order-data-inventory")]
- public async Task<PagedDto<OrderDataInventoryRep>> OrderDataInventory([FromQuery] OrderDataInventoryReq dto)
- {
- var (total, items) = await _orderRepository.OrderDataInventory(dto).ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
- return new PagedDto<OrderDataInventoryRep>() { Total = total, Items = items };
- }
- /// <summary>
- /// 数据清单导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("order-data-inventory-export")]
- public async Task<FileStreamResult> OrderDataInventoryExport([FromBody] ExportExcelDto<OrderDataInventoryReq> dto)
- {
- var query = _orderRepository.OrderDataInventory(dto.QueryDto);
- List<OrderDataInventoryRep> orders;
- if (dto.IsExportAll)
- {
- orders = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- orders = items;
- }
- var ordersDtos = _mapper.Map<ICollection<OrderDataInventoryRep>>(orders);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = ordersDtos
- .Select(stu => _mapper.Map(stu, typeof(OrderDataInventoryRep), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "数据清单明细");
- }
- #region 智能回访统计
- /// <summary>
- /// 智能回访数据统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("aivisit-statistics")]
- public async Task<QueryAiVisitStatisticsResp> QueryAiVisitStatistics([FromQuery] QueryAiVisitStatisticsRequest dto)
- {
- var model = await _orderRepository.QueryAiVisitStatistics(dto);
- return model;
- }
- /// <summary>
- /// 智能回访有效性分析
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("aivisit-effective-analysis")]
- public async Task<QueryAiVisitEffectiveAnalysisResp> QueryAiVisitEffectiveAnalysis([FromQuery] QueryAiVisitStatisticsRequest dto)
- {
- var model = await _orderRepository.QueryAiVisitEffectiveAnalysis(dto);
- return model;
- }
- #endregion
- /// <summary>
- /// 扭转信件统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("ordervisit-jude-statistics")]
- public async Task<List<OrderVisitJudeStatisticsRep>> OrderVisitJudeStatistics([FromQuery] OrderVisitJudeStatisticsReq dto)
- {
- var list = await _orderApplication.OrderVisitJudeStatistics(dto).ToListAsync();
- return list;
- }
- /// <summary>
- /// 扭转信件统计
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("ordervisit-jude-statistics-export")]
- public async Task<FileStreamResult> OrderVisitJudeStatisticsExport([FromBody] ExportExcelDto<OrderVisitJudeStatisticsReq> dto)
- {
- var query = _orderApplication.OrderVisitJudeStatistics(dto.QueryDto);
- List<OrderVisitJudeStatisticsRep> exportList;
- exportList = await query.ToListAsync(HttpContext.RequestAborted);
- var ordersDtos = _mapper.Map<ICollection<OrderVisitJudeStatisticsRep>>(exportList);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = ordersDtos
- .Select(stu => _mapper.Map(stu, typeof(OrderVisitJudeStatisticsRep), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "扭转信件统计");
- }
- /// <summary>
- /// 部门延期统计明细-单独菜单
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("order_delay_detail")]
- public async Task<PagedDto<OrderDelayDto>> QueryOrderDelayDataDetailAsync([FromQuery] QueryOrderDelayDataDetailRequest dto)
- {
- var query = _orderDelayRepository.Queryable()
- .Includes(x => x.Order)
- .WhereIF(dto.StartTime.HasValue, x => x.CreationTime >= dto.StartTime)
- .WhereIF(dto.EndTime.HasValue, x => x.CreationTime <= dto.EndTime)
- .WhereIF(dto.TypeId != null && dto.TypeId == 1, x => x.Order.IdentityType == EIdentityType.Citizen)
- .WhereIF(dto.TypeId != null && dto.TypeId == 2, x => x.Order.IdentityType == EIdentityType.Enterprise)
- .WhereIF(dto.Type is 1, x => x.DelayState == EDelayState.Pass)
- .WhereIF(dto.Type is 2, x => x.DelayState == EDelayState.NoPass)
- .WhereIF(dto.Type is 3, x => x.DelayState == EDelayState.Examining)
- .WhereIF(dto.Type is 4, x => x.DelayState < EDelayState.Withdraw)
- .MergeTable();
- if (_sessionContext.OrgIsCenter == false)
- query = query.Where(x => x.ApplyOrgCode.StartsWith(_sessionContext.OrgId));
- var (total, items) = await query.ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
- return new PagedDto<OrderDelayDto>(total, _mapper.Map<IReadOnlyList<OrderDelayDto>>(items));
- }
- /// <summary>
- /// 工单热词分析
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpGet("query_order_ts_details_list")]
- public async Task<PagedDto<OrderTsDetailsDto>> QueryOrderTsDetailsList([FromQuery] PagedKeywordRequest dto)
- {
- var (total, items) = await _orderApplication.QueryOrderTsDetailslList(dto).ToPagedListAsync(dto, HttpContext.RequestAborted);
- return new PagedDto<OrderTsDetailsDto>(total, _mapper.Map<IReadOnlyList<OrderTsDetailsDto>>(items));
- }
- /// <summary>
- /// 工单热词分析导出
- /// </summary>
- /// <param name="dto"></param>
- /// <returns></returns>
- [HttpPost("query_order_ts_details_list/export")]
- public async Task<FileStreamResult> ExportQueryOrderTsDetailsList([FromQuery] ExportExcelDto<PagedKeywordRequest> dto)
- {
- var query = _orderApplication.QueryOrderTsDetailslList(dto.QueryDto);
- List<OrderTsDetailsDto> lists;
- if (dto.IsExportAll)
- {
- lists = await query.ToListAsync(HttpContext.RequestAborted);
- }
- else
- {
- var (_, items) = await query.ToPagedListAsync(dto.QueryDto, HttpContext.RequestAborted);
- lists = items;
- }
- var listDtos = _mapper.Map<ICollection<OrderTsDetailsDto>>(lists);
- dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass(dto.ColumnInfos);
- var dtos = listDtos
- .Select(stu => _mapper.Map(stu, typeof(OrderTsDetailsDto), dynamicClass))
- .Cast<object>()
- .ToList();
- var stream = ExcelHelper.CreateStream(dtos);
- return ExcelStreamResult(stream, "工单热词分析数据");
- }
- /// <summary>
- /// 根据热词查询工单
- /// </summary>
- /// <param name="KeyWord"></param>
- /// <returns></returns>
- [HttpGet("get_query_order_ts_details_order_list")]
- public async Task<List<OrderTsDetails>> GetQueryOrderTsDetailslOrderList(string KeyWord)
- {
- return await _orderTsDetailsRepository.Queryable()
- .Where(p => p.Terms == KeyWord)
- .ToListAsync(HttpContext.RequestAborted);
- }
- }
- }
|