OrderReportApplication.cs 119 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839
  1. using Hotline.Application.Orders;
  2. using Hotline.Caching.Interfaces;
  3. using Hotline.CallCenter.Calls;
  4. using Hotline.FlowEngine.WorkflowModules;
  5. using Hotline.FlowEngine.Workflows;
  6. using Hotline.Orders;
  7. using Hotline.Settings;
  8. using Hotline.Settings.Hotspots;
  9. using Hotline.Settings.TimeLimits;
  10. using Hotline.Share.Dtos.Order;
  11. using Hotline.Share.Enums.FlowEngine;
  12. using Hotline.Share.Enums.Order;
  13. using Hotline.Share.Requests;
  14. using MapsterMapper;
  15. using SqlSugar;
  16. using XF.Domain.Authentications;
  17. using XF.Domain.Dependency;
  18. using XF.Domain.Exceptions;
  19. using XF.Domain.Repository;
  20. namespace Hotline.Application.StatisticalReport
  21. {
  22. public class OrderReportApplication : IOrderReportApplication, IScopeDependency
  23. {
  24. private readonly IOrderRepository _orderRepository;
  25. private readonly IRepository<Hotspot> _hotspotTypeRepository;
  26. private readonly ISystemDicDataCacheManager _sysDicDataCacheManager;
  27. private readonly IRepository<OrderVisitDetail> _orderVisitDetailRepository;
  28. private readonly IRepository<OrderDelay> _orderDelayRepository;
  29. private readonly IMapper _mapper;
  30. private readonly IRepository<WorkflowCountersign> _workflowCountersignRepository;
  31. private readonly IRepository<OrderSpecial> _orderSpecialRepository;
  32. private readonly IRepository<OrderVisit> _orderVisitRepository;
  33. private readonly IRepository<TrCallRecord> _trCallRecordRepository;
  34. private readonly IRepository<OrderPublish> _orderPublishRepository;
  35. private readonly IRepository<SystemOrganize> _systemOrganizeRepository;
  36. private readonly IRepository<AiOrderVisitDetail> _aiOrderVisitDetailRepository;
  37. private readonly ISessionContext _sessionContext;
  38. private readonly ISystemSettingCacheManager _systemSettingCacheManager;
  39. private readonly IRepository<OrderSpecialDetail> _orderSpecialDetailRepository;
  40. private readonly IRepository<WorkflowTrace> _workflowTraceRepository;
  41. private readonly IRepository<OrderScreen> _orderScreenRepository;
  42. private readonly IOrderSecondaryHandlingApplication _orderSecondaryHandlingApplication;
  43. private readonly ITimeLimitDomainService _timeLimitDomainService;
  44. public OrderReportApplication(
  45. IOrderRepository orderRepository,
  46. IRepository<Hotspot> hotspotTypeRepository,
  47. ISystemDicDataCacheManager sysDicDataCacheManager,
  48. IRepository<OrderVisitDetail> orderVisitDetailRepository,
  49. IRepository<OrderDelay> orderDelayRepository,
  50. IRepository<WorkflowCountersign> workflowCountersignRepository,
  51. IRepository<OrderSpecial> orderSpecialRepository,
  52. IMapper mapper,
  53. IRepository<OrderVisit> orderVisitRepository,
  54. IRepository<TrCallRecord> trCallRecordRepository,
  55. IRepository<OrderPublish> orderPublishRepository,
  56. IRepository<SystemOrganize> systemOrganizeRepository,
  57. IRepository<AiOrderVisitDetail> aiOrderVisitDetailRepository,
  58. ISessionContext sessionContext,
  59. ISystemSettingCacheManager systemSettingCacheManager,
  60. IRepository<OrderSpecialDetail> orderSpecialDetailRepository,
  61. IRepository<WorkflowTrace> workflowTraceRepository,
  62. IRepository<OrderScreen> orderScreenRepository,
  63. IOrderSecondaryHandlingApplication orderSecondaryHandlingApplication,
  64. ITimeLimitDomainService timeLimitDomainService
  65. )
  66. {
  67. _orderRepository = orderRepository;
  68. _hotspotTypeRepository = hotspotTypeRepository;
  69. _sysDicDataCacheManager = sysDicDataCacheManager;
  70. _orderVisitDetailRepository = orderVisitDetailRepository;
  71. _orderDelayRepository = orderDelayRepository;
  72. _workflowCountersignRepository = workflowCountersignRepository;
  73. _orderSpecialRepository = orderSpecialRepository;
  74. _mapper = mapper;
  75. _orderVisitRepository = orderVisitRepository;
  76. _trCallRecordRepository = trCallRecordRepository;
  77. _orderPublishRepository = orderPublishRepository;
  78. _systemOrganizeRepository = systemOrganizeRepository;
  79. _aiOrderVisitDetailRepository = aiOrderVisitDetailRepository;
  80. _sessionContext = sessionContext;
  81. _systemSettingCacheManager = systemSettingCacheManager;
  82. _orderSpecialDetailRepository = orderSpecialDetailRepository;
  83. _workflowTraceRepository = workflowTraceRepository;
  84. _orderScreenRepository = orderScreenRepository;
  85. _orderSecondaryHandlingApplication = orderSecondaryHandlingApplication;
  86. _timeLimitDomainService = timeLimitDomainService;
  87. }
  88. /// <summary>
  89. /// 部门办件统计表---新
  90. /// </summary>
  91. /// <param name="dto"></param>
  92. /// <returns></returns>
  93. public async Task<List<DepartmentalProcessingStatisticsDataDto>> DepartmentalProcessingStatisticsNew(DepartmentalProcessingStatisticsRequest dto)
  94. {
  95. dto.EndTime = dto.EndTime.AddDays(1).AddSeconds(-1);
  96. var IsCenter = _sessionContext.OrgIsCenter;
  97. //信件总量:信件总量=已办件数+在办件数,工单需去重
  98. //已办件数:该部门已办理完成的工单总数(含参与会签的工单),若工单被部门多次办理,只统计一次
  99. //在办件数:该部门还未办理的工单数(若是一级部门,需包含中心向该部门发起回签的工单)。(特殊说明:部门或者中心发起了会签,会签中还未汇总,应算发起会签部门的在办里面)
  100. string strSql = @"select
  101. ""OrgCode""
  102. ,""Name"" ""OrgName""
  103. ,""OrgType""
  104. , ""YbOrderCountNum""
  105. , ""ZbOrderCountNum""
  106. ,""Archived""
  107. , ""ToBeArchived""
  108. , ""WaitPublished""
  109. ,""PublishedOpen""
  110. , ""PublishedNoOpen""
  111. ,""YbOverdue""
  112. , ""ZbOverdue""
  113. , ""HqzbOverdue""
  114. , ""HqybOverdue""
  115. , ""DelayEnd""
  116. , ""DelayWait""
  117. , ""OrderDelayCount""
  118. , ""ScreenCount""
  119. , ""ScreenApproval""
  120. , ""ScreenPass""
  121. ,""ScreenNotPass""
  122. ,""SatisfactionCount""
  123. ,""NotSatisfactionCount""
  124. , (""YbOrderCountNum""-""YbOverdue"" -""HqybOverdue"" ) ""CompleteOnTime""
  125. from (
  126. SELECT ""HandlerOrgId"" ""OrgCode""
  127. ,SUM(""YbOrderCountNum"") ""YbOrderCountNum""
  128. ,SUM(""ZbOrderCountNum"") ""ZbOrderCountNum""
  129. ,SUM(""Archived"") ""Archived""
  130. ,SUM(""ToBeArchived"") ""ToBeArchived""
  131. ,SUM(""WaitPublished"") ""WaitPublished""
  132. ,SUM(""PublishedOpen"") ""PublishedOpen""
  133. ,SUM(""PublishedNoOpen"") ""PublishedNoOpen""
  134. ,SUM(""YbOverdue"") ""YbOverdue""
  135. ,SUM(""ZbOverdue"") ""ZbOverdue""
  136. ,SUM(""HqzbOverdue"") ""HqzbOverdue""
  137. ,SUM(""HqybOverdue"") ""HqybOverdue""
  138. ,SUM(""DelayEnd"") ""DelayEnd""
  139. ,SUM(""DelayWait"") ""DelayWait""
  140. ,SUM(""OrderDelayCount"") ""OrderDelayCount""
  141. ,SUM(""ScreenCount"") ""ScreenCount""
  142. ,SUM(""ScreenApproval"") ""ScreenApproval""
  143. ,SUM(""ScreenPass"") ""ScreenPass""
  144. ,SUM(""ScreenNotPass"") ""ScreenNotPass""
  145. ,SUM(""SatisfactionCount"") ""SatisfactionCount""
  146. ,SUM(""NotSatisfactionCount"") ""NotSatisfactionCount""
  147. FROM (
  148. /*查询已办*/
  149. select ""HandlerOrgId"",SUM(( CASE WHEN ( ""HandlerOrgId"" IS NOT NULL ) THEN 1 ELSE 0 END )) AS ""YbOrderCountNum"",0 ""ZbOrderCountNum"",0 ""YbOverdue"",0 ""ZbOverdue"",0 ""HqybOverdue"",0 ""HqzbOverdue"",0 ""DelayEnd"",0 ""DelayWait"",0""Archived"" ,0 ""ToBeArchived"",0 ""WaitPublished"",0 ""PublishedOpen"",0 ""PublishedNoOpen"" ,0 ""OrderDelayCount"",0 ""ScreenCount"",0 ""ScreenApproval"", 0 ""ScreenPass"" , 0 ""ScreenNotPass"",0 ""SatisfactionCount"", 0 ""NotSatisfactionCount"" from(
  150. select ""o"".""Id"",SUBSTRING(""t"".""HandlerOrgId"",1,{3}) ""HandlerOrgId"" from ""workflow_trace"" ""t""
  151. left join ""order"" ""o"" on ""o"".""Id""=""t"".""ExternalId""
  152. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' and ""t"".""ModuleCode""='OrderHandle' and ""t"".""TraceState"" !=10 and ""t"".""Status"">=2 {2} --and ""t"".""CountersignPosition""<=1
  153. GROUP BY SUBSTRING(""t"".""HandlerOrgId"",1,{3}),""o"".""Id""
  154. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  155. GROUP BY ""HandlerOrgId""
  156. union ALL
  157. /*查询待办*/
  158. select ""HandlerOrgId"",0 ""YbOrderCountNum"",SUM(( CASE WHEN ( ""HandlerOrgId"" IS NOT NULL ) THEN 1 ELSE 0 END )) AS ""ZbOrderCountNum"",0 ""YbOverdue"",0 ""ZbOverdue"",0 ""HqybOverdue"",0 ""HqzbOverdue"",0 ""DelayEnd"",0 ""DelayWait"",0""Archived"",0 ""ToBeArchived"",0 ""WaitPublished"",0 ""PublishedOpen"",0 ""PublishedNoOpen"",0 ""OrderDelayCount"",0 ""ScreenCount"",0 ""ScreenApproval"", 0 ""ScreenPass"" , 0 ""ScreenNotPass"" ,0 ""SatisfactionCount"", 0 ""NotSatisfactionCount"" from(
  159. select ""o"".""Id"",SUBSTRING(""t"".""HandlerOrgId"",1,{3}) ""HandlerOrgId"" from ""workflow_trace"" ""t""
  160. left join ""order"" ""o"" on ""o"".""Id""=""t"".""ExternalId""
  161. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' and ""t"".""ModuleCode""='OrderHandle' and ""t"".""Status""<2 {2} --and ""t"".""CountersignPosition""<=1
  162. GROUP BY SUBSTRING(""t"".""HandlerOrgId"",1,{3}),""o"".""Id""
  163. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  164. GROUP BY ""HandlerOrgId""
  165. union ALL
  166. /*查询已办超期*/
  167. select ""HandlerOrgId"",0 ""YbOrderCountNum"",0 ""ZbOrderCountNum"",SUM(( CASE WHEN ( ""HandlerOrgId"" IS NOT NULL ) THEN 1 ELSE 0 END )) AS ""YbOverdue"" ,0 ""ZbOverdue"",0 ""HqybOverdue"",0 ""HqzbOverdue"",0 ""DelayEnd"",0 ""DelayWait"",0""Archived"",0 ""ToBeArchived"",0 ""WaitPublished"",0 ""PublishedOpen"",0 ""PublishedNoOpen"",0 ""OrderDelayCount"",0 ""ScreenCount"",0 ""ScreenApproval"", 0 ""ScreenPass"" , 0 ""ScreenNotPass"" ,0 ""SatisfactionCount"", 0 ""NotSatisfactionCount"" from(
  168. select ""o"".""Id"",SUBSTRING(""t"".""HandlerOrgId"",1,{3}) ""HandlerOrgId"" from ""workflow_trace"" ""t""
  169. left join ""order"" ""o"" on ""o"".""Id""=""t"".""ExternalId""
  170. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' and ""t"".""ModuleCode""='OrderHandle' and ""t"".""TraceState"" !=10 and ""t"".""Status"">=2 and ""HandleTime"">""StepExpiredTime"" and ""t"".""CountersignPosition""=0 {2}
  171. GROUP BY SUBSTRING(""t"".""HandlerOrgId"",1,{3}),""o"".""Id""
  172. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  173. GROUP BY ""HandlerOrgId""
  174. union ALL
  175. /*查询待办超期*/
  176. select ""HandlerOrgId"",0 ""YbOrderCountNum"",0 ""ZbOrderCountNum"",0 ""YbOverdue"",SUM(( CASE WHEN ( ""HandlerOrgId"" IS NOT NULL ) THEN 1 ELSE 0 END )) AS ""ZbOverdue"",0 ""HqybOverdue"",0 ""HqzbOverdue"",0 ""DelayEnd"",0 ""DelayWait"" ,0""Archived"",0 ""ToBeArchived"",0 ""WaitPublished"",0 ""PublishedOpen"",0 ""PublishedNoOpen"",0 ""OrderDelayCount"",0 ""ScreenCount"",0 ""ScreenApproval"", 0 ""ScreenPass"" , 0 ""ScreenNotPass"",0 ""SatisfactionCount"", 0 ""NotSatisfactionCount"" from(
  177. select ""o"".""Id"",SUBSTRING(""t"".""HandlerOrgId"",1,{3}) ""HandlerOrgId"" from ""workflow_trace"" ""t""
  178. left join ""order"" ""o"" on ""o"".""Id""=""t"".""ExternalId""
  179. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' and ""t"".""ModuleCode""='OrderHandle' and ""t"".""Status""<2 and (SELECT NOW())>""StepExpiredTime"" and ""t"".""CountersignPosition""=0 {2}
  180. GROUP BY SUBSTRING(""t"".""HandlerOrgId"",1,{3}),""o"".""Id""
  181. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  182. GROUP BY ""HandlerOrgId""
  183. union ALL
  184. /*查询会签已办超期*/
  185. select ""HandlerOrgId"",0 ""YbOrderCountNum"",0 ""ZbOrderCountNum"",0 ""YbOverdue"" ,0 ""ZbOverdue"",SUM(( CASE WHEN ( ""HandlerOrgId"" IS NOT NULL ) THEN 1 ELSE 0 END )) AS ""HqybOverdue"",0 ""HqzbOverdue"",0 ""DelayEnd"",0 ""DelayWait"",0""Archived"",0 ""ToBeArchived"",0 ""WaitPublished"",0 ""PublishedOpen"",0 ""PublishedNoOpen"",0 ""OrderDelayCount"",0 ""ScreenCount"",0 ""ScreenApproval"", 0 ""ScreenPass"" , 0 ""ScreenNotPass"" ,0 ""SatisfactionCount"", 0 ""NotSatisfactionCount"" from(
  186. select ""o"".""Id"",SUBSTRING(""t"".""HandlerOrgId"",1,{3}) ""HandlerOrgId"" from ""workflow_trace"" ""t""
  187. left join ""order"" ""o"" on ""o"".""Id""=""t"".""ExternalId""
  188. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' and ""t"".""ModuleCode""='OrderHandle' and ""t"".""TraceState"" !=10 and ""t"".""Status"">=2 and ""HandleTime"">""StepExpiredTime"" and ""CountersignPosition"">0 {2}
  189. GROUP BY SUBSTRING(""t"".""HandlerOrgId"",1,{3}),""o"".""Id""
  190. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  191. GROUP BY ""HandlerOrgId""
  192. union ALL
  193. /*查询会签待办超期*/
  194. select ""HandlerOrgId"",0 ""YbOrderCountNum"",0 ""ZbOrderCountNum"",0 ""YbOverdue"" ,0 ""ZbOverdue"",0 ""HqybOverdue"",SUM(( CASE WHEN ( ""HandlerOrgId"" IS NOT NULL ) THEN 1 ELSE 0 END )) AS ""HqzbOverdue"" ,0 ""DelayEnd"",0 ""DelayWait"" ,0""Archived"",0 ""ToBeArchived"",0 ""WaitPublished"",0 ""PublishedOpen"",0 ""PublishedNoOpen"",0 ""OrderDelayCount"",0 ""ScreenCount"",0 ""ScreenApproval"", 0 ""ScreenPass"" , 0 ""ScreenNotPass"",0 ""SatisfactionCount"", 0 ""NotSatisfactionCount"" from(
  195. select ""o"".""Id"",SUBSTRING(""t"".""HandlerOrgId"",1,{3}) ""HandlerOrgId"" from ""workflow_trace"" ""t""
  196. left join ""order"" ""o"" on ""o"".""Id""=""t"".""ExternalId""
  197. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' and ""t"".""ModuleCode""='OrderHandle' and ""t"".""Status""<2 and (SELECT NOW())>""StepExpiredTime""
  198. and ""CountersignPosition"">0 {2}
  199. GROUP BY SUBSTRING(""t"".""HandlerOrgId"",1,{3}),""o"".""Id""
  200. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  201. GROUP BY ""HandlerOrgId""
  202. union ALL
  203. /*查询会签已办*/
  204. select ""HandlerOrgId"",0 ""YbOrderCountNum"",0 ""ZbOrderCountNum"",0 ""YbOverdue"" ,0 ""ZbOverdue"",0 ""HqybOverdue"",0 ""HqzbOverdue"",SUM(( CASE WHEN ( ""HandlerOrgId"" IS NOT NULL ) THEN 1 ELSE 0 END )) AS ""DelayEnd"",0 ""DelayWait"" ,0""Archived"",0 ""ToBeArchived"",0 ""WaitPublished"",0 ""PublishedOpen"",0 ""PublishedNoOpen"",0 ""OrderDelayCount"",0 ""ScreenCount"",0 ""ScreenApproval"", 0 ""ScreenPass"" , 0 ""ScreenNotPass"" ,0 ""SatisfactionCount"", 0 ""NotSatisfactionCount"" from(
  205. select ""o"".""Id"",SUBSTRING(""t"".""HandlerOrgId"",1,{3}) ""HandlerOrgId"" from ""workflow_trace"" ""t""
  206. left join ""order"" ""o"" on ""o"".""Id""=""t"".""ExternalId""
  207. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' and ""t"".""ModuleCode""='OrderHandle' and ""t"".""TraceState"" !=10 and ""t"".""Status"">=2 and ""CountersignPosition"">0 {2}
  208. GROUP BY SUBSTRING(""t"".""HandlerOrgId"",1,{3}),""o"".""Id""
  209. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  210. GROUP BY ""HandlerOrgId""
  211. union ALL
  212. /*查询会签待办*/
  213. select ""HandlerOrgId"",0 ""YbOrderCountNum"",0 ""ZbOrderCountNum"",0 ""YbOverdue"" ,0 ""ZbOverdue"",0 ""HqybOverdue"",0 ""HqzbOverdue"",0 ""DelayEnd"",SUM(( CASE WHEN ( ""HandlerOrgId"" IS NOT NULL ) THEN 1 ELSE 0 END )) AS ""DelayWait"" ,0""Archived"",0 ""ToBeArchived"",0 ""WaitPublished"",0 ""PublishedOpen"",0 ""PublishedNoOpen"",0 ""OrderDelayCount"",0 ""ScreenCount"",0 ""ScreenApproval"", 0 ""ScreenPass"" , 0 ""ScreenNotPass"",0 ""SatisfactionCount"", 0 ""NotSatisfactionCount"" from(
  214. select ""o"".""Id"",SUBSTRING(""t"".""HandlerOrgId"",1,{3}) ""HandlerOrgId"" from ""workflow_trace"" ""t""
  215. left join ""order"" ""o"" on ""o"".""Id""=""t"".""ExternalId""
  216. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' and ""t"".""ModuleCode""='OrderHandle' and ""t"".""Status""<2 and ""CountersignPosition"">0 {2}
  217. GROUP BY SUBSTRING(""t"".""HandlerOrgId"",1,{3}),""o"".""Id""
  218. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  219. GROUP BY ""HandlerOrgId""
  220. UNION ALL
  221. /*已归档、 待发布、已发布公开、已发布不公开*/
  222. select ""HandlerOrgId"",0 ""YbOrderCountNum"",0 ""ZbOrderCountNum"",0 ""YbOverdue"" ,0 ""ZbOverdue"",0 ""HqybOverdue"",0 ""HqzbOverdue"",0 ""DelayEnd"",0 ""DelayWait""
  223. ,SUM(( CASE WHEN ( ""Status"">=300 ) THEN 1 ELSE 0 END )) AS ""Archived""
  224. ,0 ""ToBeArchived""
  225. ,SUM(( CASE WHEN ( ""Status""=300 ) THEN 1 ELSE 0 END )) AS ""WaitPublished""
  226. ,SUM(( CASE WHEN ( ""Status"">=400 and ""IsPublicity""=TRUE ) THEN 1 ELSE 0 END )) AS ""PublishedOpen""
  227. ,SUM(( CASE WHEN ( ""Status"">=400 and ""IsPublicity""=FALSE ) THEN 1 ELSE 0 END )) AS ""PublishedNoOpen""
  228. ,0 ""OrderDelayCount"",0 ""ScreenCount"",0 ""ScreenApproval"", 0 ""ScreenPass"" , 0 ""ScreenNotPass"" ,0 ""SatisfactionCount"", 0 ""NotSatisfactionCount"" from(
  229. select SUBSTRING(""o"".""ActualHandleOrgCode"",1,{3}) ""HandlerOrgId"", ""o"".""Status"", ""o"".""IsPublicity"" from ""order"" ""o""
  230. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' and ""o"".""Status"">=300 {2}
  231. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  232. GROUP BY ""HandlerOrgId""
  233. union ALL
  234. /*查询延期通过数量*/
  235. select ""HandlerOrgId"",0 ""YbOrderCountNum"",0 ""ZbOrderCountNum"",0 ""YbOverdue"" ,0 ""ZbOverdue"",0 ""HqybOverdue"",0 ""HqzbOverdue"",0 ""DelayEnd"",0 ""DelayWait"" ,0""Archived"",0 ""ToBeArchived"",0 ""WaitPublished"",0 ""PublishedOpen"",0 ""PublishedNoOpen"",SUM(( CASE WHEN ( ""HandlerOrgId"" IS NOT NULL ) THEN 1 ELSE 0 END )) AS ""OrderDelayCount"",0 ""ScreenCount"",0 ""ScreenApproval"", 0 ""ScreenPass"" , 0 ""ScreenNotPass"" ,0 ""SatisfactionCount"", 0 ""NotSatisfactionCount"" from(
  236. select SUBSTRING(""ApplyOrgCode"",1,{3}) ""HandlerOrgId"" from ""order_delay"" ""d""
  237. left join ""order"" ""o"" on ""d"".""OrderId""=""o"".""Id""
  238. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' and ""d"".""DelayState""=1 {2}
  239. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  240. GROUP BY ""HandlerOrgId""
  241. union all
  242. /*查询甄别*/
  243. select ""HandlerOrgId"",0 ""YbOrderCountNum"",0 ""ZbOrderCountNum"",0 ""YbOverdue"" ,0 ""ZbOverdue"",0 ""HqybOverdue"",0 ""HqzbOverdue"",0 ""DelayEnd"",0 ""DelayWait"" ,0""Archived"",0 ""ToBeArchived"",0 ""WaitPublished"",0 ""PublishedOpen"",0 ""PublishedNoOpen"",0 ""OrderDelayCount""
  244. ,SUM(( CASE WHEN ( ""HandlerOrgId"" IS NOT NULL ) THEN 1 ELSE 0 END )) AS ""ScreenCount""
  245. ,SUM(( CASE WHEN ( ""Status""<=1 ) THEN 1 ELSE 0 END )) AS ""ScreenApproval""
  246. ,SUM(( CASE WHEN ( ""Status""=2 ) THEN 1 ELSE 0 END )) AS ""ScreenPass""
  247. ,SUM(( CASE WHEN ( ""Status""=3 ) THEN 1 ELSE 0 END )) AS ""ScreenNotPass"",0 ""SatisfactionCount"", 0 ""NotSatisfactionCount""
  248. from(
  249. select SUBSTRING(""d"".""CreatorOrgId"",1,{3}) ""HandlerOrgId"",""d"".""Status"" from ""order_screen"" ""d""
  250. left join ""order"" ""o"" on ""d"".""OrderId""=""o"".""Id""
  251. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' {2}
  252. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  253. GROUP BY ""HandlerOrgId""
  254. union ALL
  255. /*查询满意度*/
  256. select ""HandlerOrgId"",0 ""YbOrderCountNum"",0 ""ZbOrderCountNum"",0 ""YbOverdue"" ,0 ""ZbOverdue"",0 ""HqybOverdue"",0 ""HqzbOverdue"",0 ""DelayEnd"",0 ""DelayWait"" ,0""Archived"",0 ""ToBeArchived"",0 ""WaitPublished"",0 ""PublishedOpen"",0 ""PublishedNoOpen"",0 ""OrderDelayCount"",0 ""ScreenCount"",0 ""ScreenApproval"", 0 ""ScreenPass"" , 0 ""ScreenNotPass""
  257. ,SUM(( CASE WHEN ( (""OrgProcessingResults""->>'Key')::VARCHAR != '2' ) THEN 1 ELSE 0 END )) AS ""SatisfactionCount""
  258. ,SUM(( CASE WHEN ( (""OrgProcessingResults""->>'Key')::VARCHAR = '2' ) THEN 1 ELSE 0 END )) AS ""NotSatisfactionCount""
  259. FROM(
  260. SELECT SUBSTRING(""VisitOrgCode"",1,{3}) ""HandlerOrgId"" ,""OrgProcessingResults"" from ""order_visit_detail"" ""d""
  261. left join ""order_visit"" ""v"" on ""v"".""Id""=""d"".""VisitId""
  262. left join ""order"" ""o"" on ""o"".""Id""=""v"".""OrderId""
  263. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' and ""d"".""VisitTarget""=20 and ""v"".""VisitState""=30 and ""d"".""VisitOrgCode"" is not NULL {2}
  264. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  265. GROUP BY ""HandlerOrgId""
  266. )""te""
  267. GROUP BY ""HandlerOrgId""
  268. ) ""su""
  269. left join ""system_organize"" ""so"" on ""so"".""Id""=""su"".""OrgCode""
  270. where 1=1 {5}
  271. order by ""su"".""OrgCode""";
  272. var orgLength = IsCenter == true ? 6 : _sessionContext.RequiredOrgId.Length + 3;
  273. var isOrg = IsCenter == false ? " and \"HandlerOrgId\" like concat('" + _sessionContext.RequiredOrgId + "','%') " : " ";
  274. var IsProvince = dto.IsProvince.HasValue && dto.IsProvince == true ? " and \"o\".\"Source\"=100 " : " ";
  275. var orgName = string.IsNullOrEmpty(dto.OrgName) == false ? " and \"OrgName\" like concat('%'," + dto.OrgName + ",'%')" : "";
  276. strSql = string.Format(strSql, dto.StartTime, dto.EndTime, IsProvince, orgLength, isOrg, orgName);
  277. return _orderRepository.DepartmentalProcessingStatisticsNew(strSql);
  278. }
  279. /// <summary>
  280. /// 部门办件统计表--子级---新
  281. /// </summary>
  282. /// <param name="dto"></param>
  283. /// <returns></returns>
  284. public async Task<List<DepartmentalProcessingStatisticsDataDto>> DepartmentalProcessingChildStatisticsNew(DepartmentalProcessingStatisticsRequest dto)
  285. {
  286. dto.EndTime = dto.EndTime.AddDays(1).AddSeconds(-1);
  287. //信件总量:信件总量=已办件数+在办件数,工单需去重
  288. //已办件数:该部门已办理完成的工单总数(含参与会签的工单),若工单被部门多次办理,只统计一次
  289. //在办件数:该部门还未办理的工单数(若是一级部门,需包含中心向该部门发起回签的工单)。(特殊说明:部门或者中心发起了会签,会签中还未汇总,应算发起会签部门的在办里面)
  290. string strSql = @"select
  291. ""OrgCode""
  292. ,""Name"" ""OrgName""
  293. ,""OrgType""
  294. , ""YbOrderCountNum""
  295. , ""ZbOrderCountNum""
  296. ,""Archived""
  297. , ""ToBeArchived""
  298. , ""WaitPublished""
  299. ,""PublishedOpen""
  300. , ""PublishedNoOpen""
  301. ,""YbOverdue""
  302. , ""ZbOverdue""
  303. , ""HqzbOverdue""
  304. , ""HqybOverdue""
  305. , ""DelayEnd""
  306. , ""DelayWait""
  307. , ""OrderDelayCount""
  308. , ""ScreenCount""
  309. , ""ScreenApproval""
  310. , ""ScreenPass""
  311. ,""ScreenNotPass""
  312. ,""SatisfactionCount""
  313. ,""NotSatisfactionCount""
  314. , (""YbOrderCountNum""-""YbOverdue"" -""HqybOverdue"" ) ""CompleteOnTime""
  315. from (
  316. SELECT ""HandlerOrgId"" ""OrgCode""
  317. ,SUM(""YbOrderCountNum"") ""YbOrderCountNum""
  318. ,SUM(""ZbOrderCountNum"") ""ZbOrderCountNum""
  319. ,SUM(""Archived"") ""Archived""
  320. ,SUM(""ToBeArchived"") ""ToBeArchived""
  321. ,SUM(""WaitPublished"") ""WaitPublished""
  322. ,SUM(""PublishedOpen"") ""PublishedOpen""
  323. ,SUM(""PublishedNoOpen"") ""PublishedNoOpen""
  324. ,SUM(""YbOverdue"") ""YbOverdue""
  325. ,SUM(""ZbOverdue"") ""ZbOverdue""
  326. ,SUM(""HqzbOverdue"") ""HqzbOverdue""
  327. ,SUM(""HqybOverdue"") ""HqybOverdue""
  328. ,SUM(""DelayEnd"") ""DelayEnd""
  329. ,SUM(""DelayWait"") ""DelayWait""
  330. ,SUM(""OrderDelayCount"") ""OrderDelayCount""
  331. ,SUM(""ScreenCount"") ""ScreenCount""
  332. ,SUM(""ScreenApproval"") ""ScreenApproval""
  333. ,SUM(""ScreenPass"") ""ScreenPass""
  334. ,SUM(""ScreenNotPass"") ""ScreenNotPass""
  335. ,SUM(""SatisfactionCount"") ""SatisfactionCount""
  336. ,SUM(""NotSatisfactionCount"") ""NotSatisfactionCount""
  337. FROM (
  338. /*查询已办*/
  339. select ""HandlerOrgId"",SUM(( CASE WHEN ( ""HandlerOrgId"" IS NOT NULL ) THEN 1 ELSE 0 END )) AS ""YbOrderCountNum"",0 ""ZbOrderCountNum"",0 ""YbOverdue"",0 ""ZbOverdue"",0 ""HqybOverdue"",0 ""HqzbOverdue"",0 ""DelayEnd"",0 ""DelayWait"",0""Archived"" ,0 ""ToBeArchived"",0 ""WaitPublished"",0 ""PublishedOpen"",0 ""PublishedNoOpen"" ,0 ""OrderDelayCount"",0 ""ScreenCount"",0 ""ScreenApproval"", 0 ""ScreenPass"" , 0 ""ScreenNotPass"",0 ""SatisfactionCount"", 0 ""NotSatisfactionCount"" from(
  340. select ""o"".""Id"",SUBSTRING(""t"".""HandlerOrgId"",1,{3}) ""HandlerOrgId"" from ""workflow_trace"" ""t""
  341. left join ""order"" ""o"" on ""o"".""Id""=""t"".""ExternalId""
  342. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' and ""t"".""ModuleCode""='OrderHandle' and ""t"".""TraceState"" !=10 and ""t"".""Status"">=2 {2} --and ""t"".""CountersignPosition""<=1
  343. GROUP BY SUBSTRING(""t"".""HandlerOrgId"",1,{3}),""o"".""Id""
  344. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  345. GROUP BY ""HandlerOrgId""
  346. union ALL
  347. /*查询待办*/
  348. select ""HandlerOrgId"",0 ""YbOrderCountNum"",SUM(( CASE WHEN ( ""HandlerOrgId"" IS NOT NULL ) THEN 1 ELSE 0 END )) AS ""ZbOrderCountNum"",0 ""YbOverdue"",0 ""ZbOverdue"",0 ""HqybOverdue"",0 ""HqzbOverdue"",0 ""DelayEnd"",0 ""DelayWait"",0""Archived"",0 ""ToBeArchived"",0 ""WaitPublished"",0 ""PublishedOpen"",0 ""PublishedNoOpen"",0 ""OrderDelayCount"",0 ""ScreenCount"",0 ""ScreenApproval"", 0 ""ScreenPass"" , 0 ""ScreenNotPass"" ,0 ""SatisfactionCount"", 0 ""NotSatisfactionCount"" from(
  349. select ""o"".""Id"",SUBSTRING(""t"".""HandlerOrgId"",1,{3}) ""HandlerOrgId"" from ""workflow_trace"" ""t""
  350. left join ""order"" ""o"" on ""o"".""Id""=""t"".""ExternalId""
  351. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' and ""t"".""ModuleCode""='OrderHandle' and ""t"".""Status""<2 {2} --and ""t"".""CountersignPosition""<=1
  352. GROUP BY SUBSTRING(""t"".""HandlerOrgId"",1,{3}),""o"".""Id""
  353. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  354. GROUP BY ""HandlerOrgId""
  355. union ALL
  356. /*查询已办超期*/
  357. select ""HandlerOrgId"",0 ""YbOrderCountNum"",0 ""ZbOrderCountNum"",SUM(( CASE WHEN ( ""HandlerOrgId"" IS NOT NULL ) THEN 1 ELSE 0 END )) AS ""YbOverdue"" ,0 ""ZbOverdue"",0 ""HqybOverdue"",0 ""HqzbOverdue"",0 ""DelayEnd"",0 ""DelayWait"",0""Archived"",0 ""ToBeArchived"",0 ""WaitPublished"",0 ""PublishedOpen"",0 ""PublishedNoOpen"",0 ""OrderDelayCount"",0 ""ScreenCount"",0 ""ScreenApproval"", 0 ""ScreenPass"" , 0 ""ScreenNotPass"" ,0 ""SatisfactionCount"", 0 ""NotSatisfactionCount"" from(
  358. select ""o"".""Id"",SUBSTRING(""t"".""HandlerOrgId"",1,{3}) ""HandlerOrgId"" from ""workflow_trace"" ""t""
  359. left join ""order"" ""o"" on ""o"".""Id""=""t"".""ExternalId""
  360. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' and ""t"".""ModuleCode""='OrderHandle' and ""t"".""TraceState"" !=10 and ""t"".""Status"">=2 and ""HandleTime"">""StepExpiredTime"" and ""t"".""CountersignPosition""=0 {2}
  361. GROUP BY SUBSTRING(""t"".""HandlerOrgId"",1,{3}),""o"".""Id""
  362. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  363. GROUP BY ""HandlerOrgId""
  364. union ALL
  365. /*查询待办超期*/
  366. select ""HandlerOrgId"",0 ""YbOrderCountNum"",0 ""ZbOrderCountNum"",0 ""YbOverdue"",SUM(( CASE WHEN ( ""HandlerOrgId"" IS NOT NULL ) THEN 1 ELSE 0 END )) AS ""ZbOverdue"",0 ""HqybOverdue"",0 ""HqzbOverdue"",0 ""DelayEnd"",0 ""DelayWait"" ,0""Archived"",0 ""ToBeArchived"",0 ""WaitPublished"",0 ""PublishedOpen"",0 ""PublishedNoOpen"",0 ""OrderDelayCount"",0 ""ScreenCount"",0 ""ScreenApproval"", 0 ""ScreenPass"" , 0 ""ScreenNotPass"",0 ""SatisfactionCount"", 0 ""NotSatisfactionCount"" from(
  367. select ""o"".""Id"",SUBSTRING(""t"".""HandlerOrgId"",1,{3}) ""HandlerOrgId"" from ""workflow_trace"" ""t""
  368. left join ""order"" ""o"" on ""o"".""Id""=""t"".""ExternalId""
  369. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' and ""t"".""ModuleCode""='OrderHandle' and ""t"".""Status""<2 and (SELECT NOW())>""StepExpiredTime"" and ""t"".""CountersignPosition""=0 {2}
  370. GROUP BY SUBSTRING(""t"".""HandlerOrgId"",1,{3}),""o"".""Id""
  371. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  372. GROUP BY ""HandlerOrgId""
  373. union ALL
  374. /*查询会签已办超期*/
  375. select ""HandlerOrgId"",0 ""YbOrderCountNum"",0 ""ZbOrderCountNum"",0 ""YbOverdue"" ,0 ""ZbOverdue"",SUM(( CASE WHEN ( ""HandlerOrgId"" IS NOT NULL ) THEN 1 ELSE 0 END )) AS ""HqybOverdue"",0 ""HqzbOverdue"",0 ""DelayEnd"",0 ""DelayWait"",0""Archived"",0 ""ToBeArchived"",0 ""WaitPublished"",0 ""PublishedOpen"",0 ""PublishedNoOpen"",0 ""OrderDelayCount"",0 ""ScreenCount"",0 ""ScreenApproval"", 0 ""ScreenPass"" , 0 ""ScreenNotPass"" ,0 ""SatisfactionCount"", 0 ""NotSatisfactionCount"" from(
  376. select ""o"".""Id"",SUBSTRING(""t"".""HandlerOrgId"",1,{3}) ""HandlerOrgId"" from ""workflow_trace"" ""t""
  377. left join ""order"" ""o"" on ""o"".""Id""=""t"".""ExternalId""
  378. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' and ""t"".""ModuleCode""='OrderHandle' and ""t"".""TraceState"" !=10 and ""t"".""Status"">=2 and ""HandleTime"">""StepExpiredTime"" and ""CountersignPosition"">0 {2}
  379. GROUP BY SUBSTRING(""t"".""HandlerOrgId"",1,{3}),""o"".""Id""
  380. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  381. GROUP BY ""HandlerOrgId""
  382. union ALL
  383. /*查询会签待办超期*/
  384. select ""HandlerOrgId"",0 ""YbOrderCountNum"",0 ""ZbOrderCountNum"",0 ""YbOverdue"" ,0 ""ZbOverdue"",0 ""HqybOverdue"",SUM(( CASE WHEN ( ""HandlerOrgId"" IS NOT NULL ) THEN 1 ELSE 0 END )) AS ""HqzbOverdue"" ,0 ""DelayEnd"",0 ""DelayWait"" ,0""Archived"",0 ""ToBeArchived"",0 ""WaitPublished"",0 ""PublishedOpen"",0 ""PublishedNoOpen"",0 ""OrderDelayCount"",0 ""ScreenCount"",0 ""ScreenApproval"", 0 ""ScreenPass"" , 0 ""ScreenNotPass"",0 ""SatisfactionCount"", 0 ""NotSatisfactionCount"" from(
  385. select ""o"".""Id"",SUBSTRING(""t"".""HandlerOrgId"",1,{3}) ""HandlerOrgId"" from ""workflow_trace"" ""t""
  386. left join ""order"" ""o"" on ""o"".""Id""=""t"".""ExternalId""
  387. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' and ""t"".""ModuleCode""='OrderHandle' and ""t"".""Status""<2 and (SELECT NOW())>""StepExpiredTime""
  388. and ""CountersignPosition"">0 {2}
  389. GROUP BY SUBSTRING(""t"".""HandlerOrgId"",1,{3}),""o"".""Id""
  390. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  391. GROUP BY ""HandlerOrgId""
  392. union ALL
  393. /*查询会签已办*/
  394. select ""HandlerOrgId"",0 ""YbOrderCountNum"",0 ""ZbOrderCountNum"",0 ""YbOverdue"" ,0 ""ZbOverdue"",0 ""HqybOverdue"",0 ""HqzbOverdue"",SUM(( CASE WHEN ( ""HandlerOrgId"" IS NOT NULL ) THEN 1 ELSE 0 END )) AS ""DelayEnd"",0 ""DelayWait"" ,0""Archived"",0 ""ToBeArchived"",0 ""WaitPublished"",0 ""PublishedOpen"",0 ""PublishedNoOpen"",0 ""OrderDelayCount"",0 ""ScreenCount"",0 ""ScreenApproval"", 0 ""ScreenPass"" , 0 ""ScreenNotPass"" ,0 ""SatisfactionCount"", 0 ""NotSatisfactionCount"" from(
  395. select ""o"".""Id"",SUBSTRING(""t"".""HandlerOrgId"",1,{3}) ""HandlerOrgId"" from ""workflow_trace"" ""t""
  396. left join ""order"" ""o"" on ""o"".""Id""=""t"".""ExternalId""
  397. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' and ""t"".""ModuleCode""='OrderHandle' and ""t"".""TraceState"" !=10 and ""t"".""Status"">=2 and ""CountersignPosition"">0 {2}
  398. GROUP BY SUBSTRING(""t"".""HandlerOrgId"",1,{3}),""o"".""Id""
  399. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  400. GROUP BY ""HandlerOrgId""
  401. union ALL
  402. /*查询会签待办*/
  403. select ""HandlerOrgId"",0 ""YbOrderCountNum"",0 ""ZbOrderCountNum"",0 ""YbOverdue"" ,0 ""ZbOverdue"",0 ""HqybOverdue"",0 ""HqzbOverdue"",0 ""DelayEnd"",SUM(( CASE WHEN ( ""HandlerOrgId"" IS NOT NULL ) THEN 1 ELSE 0 END )) AS ""DelayWait"" ,0""Archived"",0 ""ToBeArchived"",0 ""WaitPublished"",0 ""PublishedOpen"",0 ""PublishedNoOpen"",0 ""OrderDelayCount"",0 ""ScreenCount"",0 ""ScreenApproval"", 0 ""ScreenPass"" , 0 ""ScreenNotPass"",0 ""SatisfactionCount"", 0 ""NotSatisfactionCount"" from(
  404. select ""o"".""Id"",SUBSTRING(""t"".""HandlerOrgId"",1,{3}) ""HandlerOrgId"" from ""workflow_trace"" ""t""
  405. left join ""order"" ""o"" on ""o"".""Id""=""t"".""ExternalId""
  406. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' and ""t"".""ModuleCode""='OrderHandle' and ""t"".""Status""<2 and ""CountersignPosition"">0 {2}
  407. GROUP BY SUBSTRING(""t"".""HandlerOrgId"",1,{3}),""o"".""Id""
  408. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  409. GROUP BY ""HandlerOrgId""
  410. UNION ALL
  411. /*已归档、 待发布、已发布公开、已发布不公开*/
  412. select ""HandlerOrgId"",0 ""YbOrderCountNum"",0 ""ZbOrderCountNum"",0 ""YbOverdue"" ,0 ""ZbOverdue"",0 ""HqybOverdue"",0 ""HqzbOverdue"",0 ""DelayEnd"",0 ""DelayWait""
  413. ,SUM(( CASE WHEN ( ""Status"">=300 ) THEN 1 ELSE 0 END )) AS ""Archived""
  414. ,0 ""ToBeArchived""
  415. ,SUM(( CASE WHEN ( ""Status""=300 ) THEN 1 ELSE 0 END )) AS ""WaitPublished""
  416. ,SUM(( CASE WHEN ( ""Status"">=400 and ""IsPublicity""=TRUE ) THEN 1 ELSE 0 END )) AS ""PublishedOpen""
  417. ,SUM(( CASE WHEN ( ""Status"">=400 and ""IsPublicity""=FALSE ) THEN 1 ELSE 0 END )) AS ""PublishedNoOpen""
  418. ,0 ""OrderDelayCount"",0 ""ScreenCount"",0 ""ScreenApproval"", 0 ""ScreenPass"" , 0 ""ScreenNotPass"" ,0 ""SatisfactionCount"", 0 ""NotSatisfactionCount"" from(
  419. select SUBSTRING(""o"".""ActualHandleOrgCode"",1,{3}) ""HandlerOrgId"", ""o"".""Status"", ""o"".""IsPublicity"" from ""order"" ""o""
  420. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' and ""o"".""Status"">=300 {2}
  421. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  422. GROUP BY ""HandlerOrgId""
  423. union ALL
  424. /*查询延期通过数量*/
  425. select ""HandlerOrgId"",0 ""YbOrderCountNum"",0 ""ZbOrderCountNum"",0 ""YbOverdue"" ,0 ""ZbOverdue"",0 ""HqybOverdue"",0 ""HqzbOverdue"",0 ""DelayEnd"",0 ""DelayWait"" ,0""Archived"",0 ""ToBeArchived"",0 ""WaitPublished"",0 ""PublishedOpen"",0 ""PublishedNoOpen"",SUM(( CASE WHEN ( ""HandlerOrgId"" IS NOT NULL ) THEN 1 ELSE 0 END )) AS ""OrderDelayCount"",0 ""ScreenCount"",0 ""ScreenApproval"", 0 ""ScreenPass"" , 0 ""ScreenNotPass"" ,0 ""SatisfactionCount"", 0 ""NotSatisfactionCount"" from(
  426. select SUBSTRING(""ApplyOrgCode"",1,{3}) ""HandlerOrgId"" from ""order_delay"" ""d""
  427. left join ""order"" ""o"" on ""d"".""OrderId""=""o"".""Id""
  428. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' and ""d"".""DelayState""=1 {2}
  429. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  430. GROUP BY ""HandlerOrgId""
  431. union all
  432. /*查询甄别*/
  433. select ""HandlerOrgId"",0 ""YbOrderCountNum"",0 ""ZbOrderCountNum"",0 ""YbOverdue"" ,0 ""ZbOverdue"",0 ""HqybOverdue"",0 ""HqzbOverdue"",0 ""DelayEnd"",0 ""DelayWait"" ,0""Archived"",0 ""ToBeArchived"",0 ""WaitPublished"",0 ""PublishedOpen"",0 ""PublishedNoOpen"",0 ""OrderDelayCount""
  434. ,SUM(( CASE WHEN ( ""HandlerOrgId"" IS NOT NULL ) THEN 1 ELSE 0 END )) AS ""ScreenCount""
  435. ,SUM(( CASE WHEN ( ""Status""<=1 ) THEN 1 ELSE 0 END )) AS ""ScreenApproval""
  436. ,SUM(( CASE WHEN ( ""Status""=2 ) THEN 1 ELSE 0 END )) AS ""ScreenPass""
  437. ,SUM(( CASE WHEN ( ""Status""=3 ) THEN 1 ELSE 0 END )) AS ""ScreenNotPass"",0 ""SatisfactionCount"", 0 ""NotSatisfactionCount""
  438. from(
  439. select SUBSTRING(""d"".""CreatorOrgId"",1,{3}) ""HandlerOrgId"",""d"".""Status"" from ""order_screen"" ""d""
  440. left join ""order"" ""o"" on ""d"".""OrderId""=""o"".""Id""
  441. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' {2}
  442. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  443. GROUP BY ""HandlerOrgId""
  444. union ALL
  445. /*查询满意度*/
  446. select ""HandlerOrgId"",0 ""YbOrderCountNum"",0 ""ZbOrderCountNum"",0 ""YbOverdue"" ,0 ""ZbOverdue"",0 ""HqybOverdue"",0 ""HqzbOverdue"",0 ""DelayEnd"",0 ""DelayWait"" ,0""Archived"",0 ""ToBeArchived"",0 ""WaitPublished"",0 ""PublishedOpen"",0 ""PublishedNoOpen"",0 ""OrderDelayCount"",0 ""ScreenCount"",0 ""ScreenApproval"", 0 ""ScreenPass"" , 0 ""ScreenNotPass""
  447. ,SUM(( CASE WHEN ( (""OrgProcessingResults""->>'Key')::VARCHAR != '2' ) THEN 1 ELSE 0 END )) AS ""SatisfactionCount""
  448. ,SUM(( CASE WHEN ( (""OrgProcessingResults""->>'Key')::VARCHAR = '2' ) THEN 1 ELSE 0 END )) AS ""NotSatisfactionCount""
  449. FROM(
  450. SELECT SUBSTRING(""VisitOrgCode"",1,{3}) ""HandlerOrgId"" ,""OrgProcessingResults"" from ""order_visit_detail"" ""d""
  451. left join ""order_visit"" ""v"" on ""v"".""Id""=""d"".""VisitId""
  452. left join ""order"" ""o"" on ""o"".""Id""=""v"".""OrderId""
  453. where ""o"".""CreationTime"">='{0}' and ""o"".""CreationTime""<='{1}' and ""d"".""VisitTarget""=20 and ""v"".""VisitState""=30 and ""d"".""VisitOrgCode"" is not NULL {2}
  454. )""s"" where ""HandlerOrgId"" IS not NULL {4}
  455. GROUP BY ""HandlerOrgId""
  456. )""te""
  457. GROUP BY ""HandlerOrgId""
  458. ) ""su""
  459. left join ""system_organize"" ""so"" on ""so"".""Id""=""su"".""OrgCode""
  460. where 1=1 {5}
  461. order by ""su"".""OrgCode""";
  462. var IsProvince = dto.IsProvince.HasValue && dto.IsProvince == true ? " and \"o\".\"Source\"=100 " : " ";
  463. var orgLength = dto.OrgCode.Length + 3;
  464. var isOrg = dto.OrgCode == "001" ? " and \"HandlerOrgId\" ='001'" : " and \"HandlerOrgId\" like concat('" + dto.OrgCode + "','%') ";
  465. var orgName = string.IsNullOrEmpty(dto.OrgName) == false ? " and \"OrgName\" like concat('%'," + dto.OrgName + ",'%')" : "";
  466. strSql = string.Format(strSql, dto.StartTime, dto.EndTime, IsProvince, orgLength, isOrg, orgName);
  467. return _orderRepository.DepartmentalProcessingStatisticsNew(strSql);
  468. }
  469. /// <summary>
  470. /// 部门办件统计表--明细---新
  471. /// </summary>
  472. /// <param name="dto"></param>
  473. /// <returns></returns>
  474. public ISugarQueryable<SelectOrderId> GetDepartmentalProcessingStatisticsListNew(DepartmentalProcessingStatisticsRequest dto, CancellationToken cancellationToken)
  475. {
  476. dto.EndTime = dto.EndTime.AddDays(1).AddSeconds(-1);
  477. RefAsync<int> total = 0;
  478. ISugarQueryable<SelectOrderId> query = null;
  479. switch (dto.StatisticsType)
  480. {
  481. case EStatisticsType.YBOrderCountNum://工单已办
  482. query = _workflowTraceRepository.Queryable()
  483. .LeftJoin<Order>((t, o) => t.ExternalId == o.Id)
  484. .Where((t, o) => t.ModuleCode == WorkflowModuleConsts.OrderHandle && o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime
  485. && t.Status >= EWorkflowStepStatus.Handled)
  486. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (t, o) => o.Source == ESource.ProvinceStraight)
  487. .WhereIF(dto.OrgCode == "001", (t, o) => t.HandlerOrgId == dto.OrgCode)
  488. .WhereIF(dto.OrgCode != "001" && dto.OrgCode != dto.ParentOrgCode, (t, o) => t.HandlerOrgId.StartsWith(dto.OrgCode))
  489. .WhereIF(dto.OrgCode != "001" && dto.OrgCode == dto.ParentOrgCode, (t, o) => t.HandlerOrgId == dto.OrgCode)
  490. .GroupBy((t, o) => o.Id)
  491. .Select((t, o) => new SelectOrderId { Id = o.Id })
  492. .MergeTable();
  493. break;
  494. case EStatisticsType.ZBOrderCountNum://工单在办
  495. query = _workflowTraceRepository.Queryable()
  496. .LeftJoin<Order>((t, o) => t.ExternalId == o.Id)
  497. .Where((t, o) => t.ModuleCode == WorkflowModuleConsts.OrderHandle && o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime
  498. && t.Status < EWorkflowStepStatus.Handled)
  499. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (t, o) => o.Source == ESource.ProvinceStraight)
  500. .WhereIF(dto.OrgCode == "001", (t, o) => t.HandlerOrgId == dto.OrgCode)
  501. .WhereIF(dto.OrgCode != "001" && dto.OrgCode != dto.ParentOrgCode, (t, o) => t.HandlerOrgId.StartsWith(dto.OrgCode))
  502. .WhereIF(dto.OrgCode != "001" && dto.OrgCode == dto.ParentOrgCode, (t, o) => t.HandlerOrgId == dto.OrgCode)
  503. .GroupBy((t, o) => o.Id)
  504. .Select((t, o) => new SelectOrderId { Id = o.Id })
  505. .MergeTable();
  506. break;
  507. case EStatisticsType.OrderDelayCount://延期次数
  508. query = _orderDelayRepository.Queryable()
  509. .LeftJoin<Order>((d, o) => d.OrderId == o.Id)
  510. .Where((d, o) => o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime && d.DelayState == EDelayState.Pass)
  511. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (d, o) => o.Source == ESource.ProvinceStraight)
  512. .WhereIF(dto.OrgCode == "001", (d, o) => d.ApplyOrgCode == dto.OrgCode)
  513. .WhereIF(dto.OrgCode != "001" && dto.OrgCode != dto.ParentOrgCode, (d, o) => d.ApplyOrgCode.StartsWith(dto.OrgCode))
  514. .WhereIF(dto.OrgCode == "001" && dto.OrgCode == dto.ParentOrgCode, (d, o) => d.ApplyOrgCode == dto.OrgCode)
  515. .OrderByDescending((d, o) => o.CreationTime)
  516. .Select((d, o) => new SelectOrderId { Id = o.Id })
  517. .MergeTable();
  518. break;
  519. case EStatisticsType.YBOverdue://已办超期
  520. query = _workflowTraceRepository.Queryable()
  521. .LeftJoin<Order>((t, o) => t.ExternalId == o.Id)
  522. .Where((t, o) => t.ModuleCode == WorkflowModuleConsts.OrderHandle && o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime
  523. && t.Status >= EWorkflowStepStatus.Handled && t.HandleTime > t.StepExpiredTime && t.CountersignPosition == ECountersignPosition.None)
  524. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (t, o) => o.Source == ESource.ProvinceStraight)
  525. .WhereIF(dto.OrgCode == "001", (t, o) => t.HandlerOrgId == dto.OrgCode)
  526. .WhereIF(dto.OrgCode != "001" && dto.OrgCode != dto.ParentOrgCode, (t, o) => t.HandlerOrgId.StartsWith(dto.OrgCode))
  527. .WhereIF(dto.OrgCode != "001" && dto.OrgCode == dto.ParentOrgCode, (t, o) => t.HandlerOrgId == dto.OrgCode)
  528. .GroupBy((t, o) => o.Id)
  529. .Select((t, o) => new SelectOrderId { Id = o.Id })
  530. .MergeTable();
  531. break;
  532. case EStatisticsType.ZBOverdue://待办超期
  533. query = _workflowTraceRepository.Queryable()
  534. .LeftJoin<Order>((t, o) => t.ExternalId == o.Id)
  535. .Where((t, o) => t.ModuleCode == WorkflowModuleConsts.OrderHandle && o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime
  536. && t.Status < EWorkflowStepStatus.Handled && DateTime.Now > t.StepExpiredTime && t.CountersignPosition == ECountersignPosition.None)
  537. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (t, o) => o.Source == ESource.ProvinceStraight)
  538. .WhereIF(dto.OrgCode == "001", (t, o) => t.HandlerOrgId == dto.OrgCode)
  539. .WhereIF(dto.OrgCode != "001" && dto.OrgCode != dto.ParentOrgCode, (t, o) => t.HandlerOrgId.StartsWith(dto.OrgCode))
  540. .WhereIF(dto.OrgCode != "001" && dto.OrgCode == dto.ParentOrgCode, (t, o) => t.HandlerOrgId == dto.OrgCode)
  541. .GroupBy((t, o) => o.Id)
  542. .Select((t, o) => new SelectOrderId { Id = o.Id })
  543. .MergeTable();
  544. break;
  545. case EStatisticsType.HQYBOverdue://会签已办超期
  546. query = _workflowTraceRepository.Queryable()
  547. .LeftJoin<Order>((t, o) => t.ExternalId == o.Id)
  548. .Where((t, o) => t.ModuleCode == WorkflowModuleConsts.OrderHandle && o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime
  549. && t.Status >= EWorkflowStepStatus.Handled && t.HandleTime > t.StepExpiredTime && t.CountersignPosition > ECountersignPosition.None)
  550. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (t, o) => o.Source == ESource.ProvinceStraight)
  551. .WhereIF(dto.OrgCode == "001", (t, o) => t.HandlerOrgId == dto.OrgCode)
  552. .WhereIF(dto.OrgCode != "001" && dto.OrgCode != dto.ParentOrgCode, (t, o) => t.HandlerOrgId.StartsWith(dto.OrgCode))
  553. .WhereIF(dto.OrgCode != "001" && dto.OrgCode == dto.ParentOrgCode, (t, o) => t.HandlerOrgId == dto.OrgCode)
  554. .GroupBy((t, o) => o.Id)
  555. .Select((t, o) => new SelectOrderId { Id = o.Id })
  556. .MergeTable();
  557. break;
  558. case EStatisticsType.HQZBOverdue://会签待办超期
  559. query = _workflowTraceRepository.Queryable()
  560. .LeftJoin<Order>((t, o) => t.ExternalId == o.Id)
  561. .Where((t, o) => t.ModuleCode == WorkflowModuleConsts.OrderHandle && o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime
  562. && t.Status < EWorkflowStepStatus.Handled && DateTime.Now > t.StepExpiredTime && t.CountersignPosition > ECountersignPosition.None)
  563. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (t, o) => o.Source == ESource.ProvinceStraight)
  564. .WhereIF(dto.OrgCode == "001", (t, o) => t.HandlerOrgId == dto.OrgCode)
  565. .WhereIF(dto.OrgCode != "001" && dto.OrgCode != dto.ParentOrgCode, (t, o) => t.HandlerOrgId.StartsWith(dto.OrgCode))
  566. .WhereIF(dto.OrgCode != "001" && dto.OrgCode == dto.ParentOrgCode, (t, o) => t.HandlerOrgId == dto.OrgCode)
  567. .GroupBy((t, o) => o.Id)
  568. .Select((t, o) => new SelectOrderId { Id = o.Id })
  569. .MergeTable();
  570. break;
  571. case EStatisticsType.SubtotalOverdue://超期件数
  572. var cqybquery = _workflowTraceRepository.Queryable()
  573. .LeftJoin<Order>((t, o) => t.ExternalId == o.Id)
  574. .Where((t, o) => t.ModuleCode == WorkflowModuleConsts.OrderHandle && o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime
  575. && t.Status >= EWorkflowStepStatus.Handled && t.HandleTime > t.StepExpiredTime && t.CountersignPosition >= ECountersignPosition.None)
  576. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (t, o) => o.Source == ESource.ProvinceStraight)
  577. .WhereIF(dto.OrgCode == "001", (t, o) => t.HandlerOrgId == dto.OrgCode)
  578. .WhereIF(dto.OrgCode != "001" && dto.OrgCode != dto.ParentOrgCode, (t, o) => t.HandlerOrgId.StartsWith(dto.OrgCode))
  579. .WhereIF(dto.OrgCode != "001" && dto.OrgCode == dto.ParentOrgCode, (t, o) => t.HandlerOrgId == dto.OrgCode)
  580. .GroupBy((t, o) => o.Id)
  581. .Select((t, o) => new SelectOrderId { Id = o.Id })
  582. .MergeTable();
  583. var cqdbquery = _workflowTraceRepository.Queryable()
  584. .LeftJoin<Order>((t, o) => t.ExternalId == o.Id)
  585. .Where((t, o) => t.ModuleCode == WorkflowModuleConsts.OrderHandle && o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime
  586. && t.Status < EWorkflowStepStatus.Handled && DateTime.Now > t.StepExpiredTime && t.CountersignPosition >= ECountersignPosition.None)
  587. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (t, o) => o.Source == ESource.ProvinceStraight)
  588. .WhereIF(dto.OrgCode == "001", (t, o) => t.HandlerOrgId == dto.OrgCode)
  589. .WhereIF(dto.OrgCode != "001" && dto.OrgCode != dto.ParentOrgCode, (t, o) => t.HandlerOrgId.StartsWith(dto.OrgCode))
  590. .WhereIF(dto.OrgCode != "001" && dto.OrgCode == dto.ParentOrgCode, (t, o) => t.HandlerOrgId == dto.OrgCode)
  591. .GroupBy((t, o) => o.Id)
  592. .Select((t, o) => new SelectOrderId { Id = o.Id })
  593. .MergeTable();
  594. query = _orderRepository.UnionAll(cqybquery, cqdbquery).GroupBy(p => p.Id).MergeTable();
  595. break;
  596. case EStatisticsType.DelayEnd://会签已办
  597. query = _workflowTraceRepository.Queryable()
  598. .LeftJoin<Order>((t, o) => t.ExternalId == o.Id)
  599. .Where((t, o) => t.ModuleCode == WorkflowModuleConsts.OrderHandle && o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime
  600. && t.Status >= EWorkflowStepStatus.Handled && t.CountersignPosition > ECountersignPosition.None)
  601. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (t, o) => o.Source == ESource.ProvinceStraight)
  602. .WhereIF(dto.OrgCode == "001", (t, o) => t.HandlerOrgId == dto.OrgCode)
  603. .WhereIF(dto.OrgCode != "001" && dto.OrgCode != dto.ParentOrgCode, (t, o) => t.HandlerOrgId.StartsWith(dto.OrgCode))
  604. .WhereIF(dto.OrgCode != "001" && dto.OrgCode == dto.ParentOrgCode, (t, o) => t.HandlerOrgId == dto.OrgCode)
  605. .GroupBy((t, o) => o.Id)
  606. .Select((t, o) => new SelectOrderId { Id = o.Id })
  607. .MergeTable();
  608. break;
  609. case EStatisticsType.DelayWait://会签待办
  610. query = _workflowTraceRepository.Queryable()
  611. .LeftJoin<Order>((t, o) => t.ExternalId == o.Id)
  612. .Where((t, o) => t.ModuleCode == WorkflowModuleConsts.OrderHandle && o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime
  613. && t.Status < EWorkflowStepStatus.Handled && t.CountersignPosition > ECountersignPosition.None)
  614. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (t, o) => o.Source == ESource.ProvinceStraight)
  615. .WhereIF(dto.OrgCode == "001", (t, o) => t.HandlerOrgId == dto.OrgCode)
  616. .WhereIF(dto.OrgCode != "001" && dto.OrgCode != dto.ParentOrgCode, (t, o) => t.HandlerOrgId.StartsWith(dto.OrgCode))
  617. .WhereIF(dto.OrgCode != "001" && dto.OrgCode == dto.ParentOrgCode, (t, o) => t.HandlerOrgId == dto.OrgCode)
  618. .GroupBy((t, o) => o.Id)
  619. .Select((t, o) => new SelectOrderId { Id = o.Id })
  620. .MergeTable();
  621. break;
  622. case EStatisticsType.ToBeArchived://待归档没得数据
  623. query = _orderRepository.Queryable()
  624. .Where(o => o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime && o.Status < EOrderStatus.WaitForAccept)
  625. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, o => o.Source == ESource.ProvinceStraight)
  626. .WhereIF(dto.OrgCode == "001", o => o.ActualHandleOrgCode == dto.OrgCode)
  627. .WhereIF(dto.OrgCode != "001" && dto.OrgCode != dto.ParentOrgCode, o => o.ActualHandleOrgCode.StartsWith(dto.OrgCode))
  628. .WhereIF(dto.OrgCode != "001" && dto.OrgCode == dto.ParentOrgCode, o => o.ActualHandleOrgCode == dto.OrgCode)
  629. .Select(o => new SelectOrderId { Id = o.Id })
  630. .MergeTable();
  631. break;
  632. case EStatisticsType.Archived://已归档
  633. query = _orderRepository.Queryable()
  634. .Where(o => o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime && o.Status >= EOrderStatus.Filed)
  635. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, o => o.Source == ESource.ProvinceStraight)
  636. .WhereIF(dto.OrgCode == "001", o => o.ActualHandleOrgCode == dto.OrgCode)
  637. .WhereIF(dto.OrgCode != "001" && dto.OrgCode != dto.ParentOrgCode, o => o.ActualHandleOrgCode.StartsWith(dto.OrgCode))
  638. .WhereIF(dto.OrgCode != "001" && dto.OrgCode == dto.ParentOrgCode, o => o.ActualHandleOrgCode == dto.OrgCode)
  639. .Select(o => new SelectOrderId { Id = o.Id })
  640. .MergeTable();
  641. break;
  642. case EStatisticsType.WaitPublished://待发布
  643. query = _orderRepository.Queryable()
  644. .Where(o => o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime && o.Status == EOrderStatus.Filed)
  645. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, o => o.Source == ESource.ProvinceStraight)
  646. .WhereIF(dto.OrgCode == "001", o => o.ActualHandleOrgCode == dto.OrgCode)
  647. .WhereIF(dto.OrgCode != "001" && dto.OrgCode != dto.ParentOrgCode, o => o.ActualHandleOrgCode.StartsWith(dto.OrgCode))
  648. .WhereIF(dto.OrgCode != "001" && dto.OrgCode == dto.ParentOrgCode, o => o.ActualHandleOrgCode == dto.OrgCode)
  649. .Select(o => new SelectOrderId { Id = o.Id })
  650. .MergeTable();
  651. break;
  652. case EStatisticsType.PublishedOpen://发布公开
  653. query = _orderRepository.Queryable()
  654. .Where(o => o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime && o.Status >= EOrderStatus.Published && o.IsPublicity == true)
  655. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, o => o.Source == ESource.ProvinceStraight)
  656. .WhereIF(dto.OrgCode == "001", o => o.ActualHandleOrgCode == dto.OrgCode)
  657. .WhereIF(dto.OrgCode != "001" && dto.OrgCode != dto.ParentOrgCode, o => o.ActualHandleOrgCode.StartsWith(dto.OrgCode))
  658. .WhereIF(dto.OrgCode != "001" && dto.OrgCode == dto.ParentOrgCode, o => o.ActualHandleOrgCode == dto.OrgCode)
  659. .Select(o => new SelectOrderId { Id = o.Id })
  660. .MergeTable();
  661. break;
  662. case EStatisticsType.PublishedNoOpen://发布不公开
  663. query = _orderRepository.Queryable()
  664. .Where(o => o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime && o.Status >= EOrderStatus.Published && o.IsPublicity == false)
  665. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, o => o.Source == ESource.ProvinceStraight)
  666. .WhereIF(dto.OrgCode == "001", o => o.ActualHandleOrgCode == dto.OrgCode)
  667. .WhereIF(dto.OrgCode != "001" && dto.OrgCode != dto.ParentOrgCode, o => o.ActualHandleOrgCode.StartsWith(dto.OrgCode))
  668. .WhereIF(dto.OrgCode != "001" && dto.OrgCode == dto.ParentOrgCode, o => o.ActualHandleOrgCode == dto.OrgCode)
  669. .Select(o => new SelectOrderId { Id = o.Id })
  670. .MergeTable();
  671. break;
  672. case EStatisticsType.ScreenCount://甄别总量
  673. query = _orderScreenRepository.Queryable()
  674. .LeftJoin<Order>((d, o) => d.OrderId == o.Id)
  675. .Where((d, o) => o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime && o.Id != null)
  676. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (d, o) => o.Source == ESource.ProvinceStraight)
  677. .WhereIF(dto.OrgCode == "001", (d, o) => d.CreatorOrgId == dto.OrgCode)
  678. .WhereIF(dto.OrgCode != "001" && dto.OrgCode != dto.ParentOrgCode, (d, o) => d.CreatorOrgId.StartsWith(dto.OrgCode))
  679. .WhereIF(dto.OrgCode != "001" && dto.OrgCode == dto.ParentOrgCode, (d, o) => d.CreatorOrgId == dto.OrgCode)
  680. .Select((d, o) => new SelectOrderId { Id = o.Id })
  681. .MergeTable();
  682. break;
  683. case EStatisticsType.ScreenApproval://带甄别
  684. query = _orderScreenRepository.Queryable()
  685. .LeftJoin<Order>((d, o) => d.OrderId == o.Id)
  686. .Where((d, o) => o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime && o.Id != null
  687. && (d.Status == EScreenStatus.Approval || d.Status == EScreenStatus.Apply))
  688. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (d, o) => o.Source == ESource.ProvinceStraight)
  689. .WhereIF(dto.OrgCode == "001", (d, o) => d.CreatorOrgId == dto.OrgCode)
  690. .WhereIF(dto.OrgCode != "001" && dto.OrgCode != dto.ParentOrgCode, (d, o) => d.CreatorOrgId.StartsWith(dto.OrgCode))
  691. .WhereIF(dto.OrgCode != "001" && dto.OrgCode == dto.ParentOrgCode, (d, o) => d.CreatorOrgId == dto.OrgCode)
  692. .Select((d, o) => new SelectOrderId { Id = o.Id })
  693. .MergeTable();
  694. break;
  695. case EStatisticsType.ScreenPass://甄别通过
  696. query = _orderScreenRepository.Queryable()
  697. .LeftJoin<Order>((d, o) => d.OrderId == o.Id)
  698. .Where((d, o) => o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime && o.Id != null && d.Status == EScreenStatus.End)
  699. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (d, o) => o.Source == ESource.ProvinceStraight)
  700. .WhereIF(dto.OrgCode == "001", (d, o) => d.CreatorOrgId == dto.OrgCode)
  701. .WhereIF(dto.OrgCode != "001" && dto.OrgCode != dto.ParentOrgCode, (d, o) => d.CreatorOrgId.StartsWith(dto.OrgCode))
  702. .WhereIF(dto.OrgCode != "001" && dto.OrgCode == dto.ParentOrgCode, (d, o) => d.CreatorOrgId == dto.OrgCode)
  703. .Select((d, o) => new SelectOrderId { Id = o.Id })
  704. .MergeTable();
  705. break;
  706. case EStatisticsType.ScreenNotPass://甄别不通过
  707. query = _orderScreenRepository.Queryable()
  708. .LeftJoin<Order>((d, o) => d.OrderId == o.Id)
  709. .Where((d, o) => o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime && o.Id != null && d.Status == EScreenStatus.Refuse)
  710. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (d, o) => o.Source == ESource.ProvinceStraight)
  711. .WhereIF(dto.OrgCode == "001", (d, o) => d.CreatorOrgId == dto.OrgCode)
  712. .WhereIF(dto.OrgCode != "001" && dto.OrgCode != dto.ParentOrgCode, (d, o) => d.CreatorOrgId.StartsWith(dto.OrgCode))
  713. .WhereIF(dto.OrgCode != "001" && dto.OrgCode == dto.ParentOrgCode, (d, o) => d.CreatorOrgId == dto.OrgCode)
  714. .Select((d, o) => new SelectOrderId { Id = o.Id })
  715. .MergeTable();
  716. break;
  717. default:
  718. break;
  719. }
  720. return query;
  721. }
  722. /// <summary>
  723. /// 部门办件统计明细表
  724. /// </summary>
  725. /// <param name="dto"></param>
  726. /// <returns></returns>
  727. public ISugarQueryable<SelectOrderId> DepartmentalProcessingStatisticsDetailsList(DepartmentalProcessingStatisticsRequest dto)
  728. {
  729. var query = _workflowTraceRepository.Queryable()
  730. .LeftJoin<Order>((t, o) => t.ExternalId == o.Id)
  731. .Where((t, o) => t.ModuleCode == WorkflowModuleConsts.OrderHandle && o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime)
  732. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (t, o) => o.Source == ESource.ProvinceStraight)
  733. // .WhereIF(IsCenter, (t, o) => t.HandlerOrgId == dto.OrgCode)
  734. .WhereIF(!_sessionContext.OrgIsCenter, (t, o) => t.HandlerOrgId.StartsWith(dto.OrgCode))
  735. .GroupBy((t, o) => o.Id)
  736. .Select((t, o) => new SelectOrderId { Id = o.Id })
  737. .MergeTable();
  738. return query;
  739. }
  740. /// <summary>
  741. /// 部门办件统计表
  742. /// </summary>
  743. /// <param name="dto"></param>
  744. /// <returns></returns>
  745. public ISugarQueryable<DepartmentalProcessingStatisticsDataDto> DepartmentalProcessingStatistics(DepartmentalProcessingStatisticsRequest dto)
  746. {
  747. dto.EndTime = dto.EndTime.AddDays(1).AddSeconds(-1);
  748. var IsCenter = _sessionContext.OrgIsCenter;
  749. //工单 已办=归完档的工单数+会签已办数量
  750. #region 工单
  751. var queryOrder = _orderRepository.Queryable()
  752. .Where(it => it.CreationTime >= dto.StartTime && it.CreationTime <= dto.EndTime && it.Status > EOrderStatus.WaitForAccept)
  753. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, it => it.Source == ESource.ProvinceStraight)
  754. .Select(it => new
  755. {
  756. it.Id,
  757. OrgCode = IsCenter == true ? it.ActualHandleOrgCode.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6")) : it.ActualHandleOrgCode.Substring(0, _sessionContext.RequiredOrgId.Length + 3),
  758. it.ActualHandleOrgCode,
  759. it.Status,//工单状态
  760. it.ExpiredTime,//期满时间
  761. it.ActualHandleTime,//办理时间
  762. it.CounterSignType,//会签
  763. })
  764. .MergeTable()
  765. .WhereIF(IsCenter == false, it => it.OrgCode.StartsWith(_sessionContext.RequiredOrgId))
  766. .GroupBy(it => new
  767. {
  768. it.OrgCode
  769. })
  770. .Select(it => new DepartmentalProcessingStatisticsDataDto
  771. {
  772. OrgCode = it.OrgCode,
  773. // OrderCountNum = SqlFunc.AggregateCount(it.OrgCode),//总量
  774. YbOrderCountNum = SqlFunc.AggregateSum(SqlFunc.IIF(it.Status >= EOrderStatus.Filed, 1, 0)),//已办// SqlFunc.AggregateSum(SqlFunc.IIF(it.Status >= EOrderStatus.Filed, 1, 0)),//已办
  775. ZbOrderCountNum = 0, //ZbOrderCountNum = SqlFunc.AggregateSum(SqlFunc.IIF(it.Status < EOrderStatus.Filed, 1, 0)),//在办
  776. Archived = SqlFunc.AggregateSum(SqlFunc.IIF(it.Status >= EOrderStatus.Filed, 1, 0)),//已归档
  777. ToBeArchived = 0,
  778. WaitPublished = 0,
  779. PublishedOpen = 0,
  780. PublishedNoOpen = 0,
  781. YbOverdue = SqlFunc.AggregateSum(SqlFunc.IIF(it.Status >= EOrderStatus.Filed && it.ActualHandleTime > it.ExpiredTime, 1, 0)),//已办超期
  782. ZbOverdue = 0,// SqlFunc.AggregateSum(SqlFunc.IIF(it.Status < EOrderStatus.Filed && it.ExpiredTime < SqlFunc.GetDate(), 1, 0)),//待办超期
  783. CompleteOnTime = SqlFunc.AggregateSum(SqlFunc.IIF(it.Status >= EOrderStatus.Filed && it.ActualHandleTime <= it.ExpiredTime, 1, 0)),//按时办结
  784. HqybOverdue = 0,
  785. HqzbOverdue = 0,
  786. DelayEnd = 0,
  787. DelayWait = 0,
  788. OrderDelayCount = 0,
  789. ScreenCount = 0,
  790. ScreenApproval = 0,
  791. ScreenPass = 0,
  792. ScreenNotPass = 0,
  793. SatisfactionCount = 0,
  794. NotSatisfactionCount = 0
  795. })
  796. .MergeTable();
  797. #endregion
  798. #region 发布
  799. //发布
  800. var queryPublish = _orderPublishRepository.Queryable()
  801. .LeftJoin<Order>((x, o) => x.OrderId == o.Id)
  802. .Where((x, o) => x.CreationTime >= dto.StartTime && x.CreationTime <= dto.EndTime)
  803. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (x, o) => o.Source == ESource.ProvinceStraight)
  804. .Select((x, o) => new
  805. {
  806. o.Id,
  807. OrgCode = IsCenter == true ? o.ActualHandleOrgCode.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6")) : o.ActualHandleOrgCode.Substring(0, _sessionContext.RequiredOrgId.Length + 3),
  808. x.PublishState,
  809. o.Status
  810. })
  811. .MergeTable()
  812. .WhereIF(IsCenter == false, it => it.OrgCode.StartsWith(_sessionContext.RequiredOrgId))
  813. .GroupBy(it => new { it.OrgCode })
  814. .Select(it => new DepartmentalProcessingStatisticsDataDto
  815. {
  816. OrgCode = it.OrgCode,
  817. // OrderCountNum = 0,//总量
  818. YbOrderCountNum = 0,//已办
  819. ZbOrderCountNum = 0,//在办
  820. Archived = 0,
  821. ToBeArchived = 0,
  822. WaitPublished = SqlFunc.AggregateSum(SqlFunc.IIF(it.Status == EOrderStatus.Filed, 1, 0)),//待发布 --已归档的就是待发布
  823. PublishedOpen = SqlFunc.AggregateSum(SqlFunc.IIF(it.Status >= EOrderStatus.Published && it.PublishState, 1, 0)),//已发布公开
  824. PublishedNoOpen = SqlFunc.AggregateSum(SqlFunc.IIF(it.Status >= EOrderStatus.Published && !it.PublishState, 1, 0)),//已发布不公开
  825. YbOverdue = 0,
  826. ZbOverdue = 0,
  827. CompleteOnTime = 0,
  828. HqybOverdue = 0,
  829. HqzbOverdue = 0,
  830. DelayEnd = 0,
  831. DelayWait = 0,
  832. OrderDelayCount = 0,
  833. ScreenCount = 0,
  834. ScreenApproval = 0,
  835. ScreenPass = 0,
  836. ScreenNotPass = 0,
  837. SatisfactionCount = 0,
  838. NotSatisfactionCount = 0,
  839. })
  840. .MergeTable();
  841. #endregion
  842. #region 会签(已办超期、待办超期)
  843. //会签(已办超期、待办超期)
  844. //var queryCountersign = _workflowStepHandleRepository.Queryable()
  845. // .LeftJoin<WorkflowTrace>((x, o) => x.WorkflowStepId == o.StepId)
  846. var queryCountersign = _workflowTraceRepository.Queryable()
  847. .LeftJoin<Order>((t, o) => t.ExternalId == o.Id)
  848. .Where((t, o) => t.ModuleCode == WorkflowModuleConsts.OrderHandle && t.CreationTime >= dto.StartTime && t.CreationTime <= dto.EndTime)
  849. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (t, o) => o.Source == ESource.ProvinceStraight)
  850. .Select((t, o) => new
  851. {
  852. OrgCode = IsCenter == true ? t.HandlerOrgId.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6")) : t.HandlerOrgId.Substring(0, _sessionContext.RequiredOrgId.Length + 3),// d.OrgId,
  853. t.HandleTime,
  854. t.StepExpiredTime,
  855. t.Status,
  856. t.CountersignPosition,
  857. o.Id
  858. })
  859. .MergeTable()
  860. .WhereIF(IsCenter == false, it => it.OrgCode.StartsWith(_sessionContext.RequiredOrgId))
  861. .GroupBy(d => new { d.OrgCode })
  862. .Select(d => new DepartmentalProcessingStatisticsDataDto
  863. {
  864. OrgCode = d.OrgCode,
  865. //OrderCountNum = 0,//总量
  866. YbOrderCountNum = SqlFunc.AggregateSum(SqlFunc.IIF(d.CountersignPosition > ECountersignPosition.None && d.Status >= EWorkflowStepStatus.Handled, 1, 0)),// 0,//已办
  867. ZbOrderCountNum = SqlFunc.AggregateSum(SqlFunc.IIF(d.Status < EWorkflowStepStatus.Handled, 1, 0)),// 0,//在办
  868. Archived = 0,
  869. ToBeArchived = 0,
  870. WaitPublished = 0,
  871. PublishedOpen = 0,
  872. PublishedNoOpen = 0,
  873. YbOverdue = 0,
  874. ZbOverdue = SqlFunc.AggregateSum(SqlFunc.IIF(d.CountersignPosition == ECountersignPosition.None && d.Status < EWorkflowStepStatus.Handled && DateTime.Now >= d.StepExpiredTime, 1, 0)),// 0,
  875. CompleteOnTime = 0,
  876. HqybOverdue = SqlFunc.AggregateSum(SqlFunc.IIF(d.CountersignPosition > ECountersignPosition.None && d.Status >= EWorkflowStepStatus.Handled && d.HandleTime > d.StepExpiredTime, 1, 0)),
  877. HqzbOverdue = SqlFunc.AggregateSum(SqlFunc.IIF(d.CountersignPosition > ECountersignPosition.None && d.Status < EWorkflowStepStatus.Handled && DateTime.Now >= d.StepExpiredTime, 1, 0)),
  878. DelayEnd = SqlFunc.AggregateSum(SqlFunc.IIF(d.CountersignPosition > ECountersignPosition.None && d.Status >= EWorkflowStepStatus.Handled, 1, 0)),
  879. DelayWait = SqlFunc.AggregateSum(SqlFunc.IIF(d.CountersignPosition > ECountersignPosition.None && d.Status < EWorkflowStepStatus.Handled, 1, 0)),
  880. OrderDelayCount = 0,
  881. ScreenCount = 0,
  882. ScreenApproval = 0,
  883. ScreenPass = 0,
  884. ScreenNotPass = 0,
  885. SatisfactionCount = 0,
  886. NotSatisfactionCount = 0,
  887. })
  888. .MergeTable();
  889. #endregion
  890. #region 延期
  891. //延期
  892. var orderDelay = _orderDelayRepository.Queryable()
  893. .LeftJoin<Order>((x, o) => x.OrderId == o.Id)
  894. .Where((x, o) => x.CreationTime >= dto.StartTime && x.CreationTime <= dto.EndTime)
  895. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (x, o) => o.Source == ESource.ProvinceStraight)
  896. .Select((x, o) => new
  897. {
  898. OrgCode = IsCenter == true ? x.ApplyOrgCode.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6")) : x.ApplyOrgCode.Substring(0, _sessionContext.RequiredOrgId.Length + 3),
  899. x.DelayState
  900. })
  901. .MergeTable()
  902. .WhereIF(IsCenter == false, it => it.OrgCode.StartsWith(_sessionContext.RequiredOrgId))
  903. .GroupBy(x => new { x.OrgCode })
  904. .Select(x => new DepartmentalProcessingStatisticsDataDto
  905. {
  906. OrgCode = x.OrgCode,
  907. // OrderCountNum = 0,//总量
  908. YbOrderCountNum = 0,//已办
  909. ZbOrderCountNum = 0,//在办
  910. Archived = 0,
  911. ToBeArchived = 0,
  912. WaitPublished = 0,
  913. PublishedOpen = 0,
  914. PublishedNoOpen = 0,
  915. YbOverdue = 0,
  916. ZbOverdue = 0,
  917. CompleteOnTime = 0,
  918. HqybOverdue = 0,
  919. HqzbOverdue = 0,
  920. DelayEnd = 0,
  921. DelayWait = 0,
  922. OrderDelayCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.DelayState == EDelayState.Pass, 1, 0)),
  923. ScreenCount = 0,
  924. ScreenApproval = 0,
  925. ScreenPass = 0,
  926. ScreenNotPass = 0,
  927. SatisfactionCount = 0,
  928. NotSatisfactionCount = 0,
  929. })
  930. .MergeTable();
  931. #endregion
  932. #region 甄别
  933. //甄别
  934. var orderScreen = _orderScreenRepository.Queryable()
  935. .LeftJoin<Order>((x, o) => x.OrderId == o.Id)
  936. .Where((x, o) => x.CreationTime >= dto.StartTime && x.CreationTime <= dto.EndTime)
  937. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (x, o) => o.Source == ESource.ProvinceStraight)
  938. .WhereIF(!string.IsNullOrEmpty(dto.OrgName), (x, o) => x.CreatorOrgId.Contains(dto.OrgName))
  939. .Select((x, o) => new
  940. {
  941. x.Id,
  942. OrgCode = IsCenter == true ? x.CreatorOrgId.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6")) : x.CreatorOrgId.Substring(0, _sessionContext.RequiredOrgId.Length + 3),
  943. x.Status
  944. })
  945. .MergeTable()
  946. .WhereIF(IsCenter == false, it => it.OrgCode.StartsWith(_sessionContext.RequiredOrgId))
  947. .GroupBy(x => new { x.OrgCode })
  948. .Select(x => new DepartmentalProcessingStatisticsDataDto
  949. {
  950. OrgCode = x.OrgCode,
  951. // OrderCountNum = 0,//总量
  952. YbOrderCountNum = 0,//已办
  953. ZbOrderCountNum = 0,//在办
  954. Archived = 0,
  955. ToBeArchived = 0,
  956. WaitPublished = 0,
  957. PublishedOpen = 0,
  958. PublishedNoOpen = 0,
  959. YbOverdue = 0,
  960. ZbOverdue = 0,
  961. CompleteOnTime = 0,
  962. HqybOverdue = 0,
  963. HqzbOverdue = 0,
  964. DelayEnd = 0,
  965. DelayWait = 0,
  966. OrderDelayCount = 0,
  967. ScreenCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.Id != null, 1, 0)),
  968. ScreenApproval = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status == EScreenStatus.Approval || x.Status == EScreenStatus.Apply, 1, 0)),
  969. ScreenPass = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status == EScreenStatus.End, 1, 0)),
  970. ScreenNotPass = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status == EScreenStatus.Refuse, 1, 0)),
  971. SatisfactionCount = 0,
  972. NotSatisfactionCount = 0,
  973. })
  974. .MergeTable();
  975. #endregion
  976. #region 满意度
  977. //满意度
  978. var orderVisit = _orderVisitDetailRepository.Queryable()
  979. .LeftJoin<OrderVisit>((x, o) => x.VisitId == o.Id)
  980. .LeftJoin<Order>((x, o, p) => o.OrderId == p.Id)
  981. .Where((x, o, p) => x.OrderVisit.VisitTime >= dto.StartTime && x.OrderVisit.VisitTime <= dto.EndTime && x.VisitTarget == EVisitTarget.Org && x.OrderVisit.VisitState == EVisitState.Visited && !string.IsNullOrEmpty(x.VisitOrgCode))
  982. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (x, o, p) => p.Source == ESource.ProvinceStraight)
  983. .Select((x, o, p) => new
  984. {
  985. OrgCode = IsCenter == true ? x.VisitOrgCode.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6")) : x.VisitOrgCode.Substring(0, _sessionContext.RequiredOrgId.Length + 3),
  986. x.OrgProcessingResults
  987. })
  988. .MergeTable()
  989. .WhereIF(IsCenter == false, it => it.OrgCode.StartsWith(_sessionContext.RequiredOrgId))
  990. .GroupBy(x => new { x.OrgCode })
  991. .Select(x => new DepartmentalProcessingStatisticsDataDto
  992. {
  993. OrgCode = x.OrgCode,
  994. // OrderCountNum = 0,//总量
  995. YbOrderCountNum = 0,//已办
  996. ZbOrderCountNum = 0,//在办
  997. Archived = 0,
  998. ToBeArchived = 0,
  999. WaitPublished = 0,
  1000. PublishedOpen = 0,
  1001. PublishedNoOpen = 0,
  1002. YbOverdue = 0,
  1003. ZbOverdue = 0,
  1004. CompleteOnTime = 0,
  1005. HqybOverdue = 0,
  1006. HqzbOverdue = 0,
  1007. DelayEnd = 0,
  1008. DelayWait = 0,
  1009. OrderDelayCount = 0,
  1010. ScreenCount = 0,
  1011. ScreenApproval = 0,
  1012. ScreenPass = 0,
  1013. ScreenNotPass = 0,
  1014. SatisfactionCount = SqlFunc.AggregateSum(SqlFunc.IIF(SqlFunc.JsonField(x.OrgProcessingResults, "Key") != "2", 1, 0)),
  1015. NotSatisfactionCount = SqlFunc.AggregateSum(SqlFunc.IIF(SqlFunc.JsonField(x.OrgProcessingResults, "Key") == "2", 1, 0))
  1016. })
  1017. .MergeTable();
  1018. #endregion
  1019. //联合查询
  1020. return _orderRepository.OrderUnionAll(queryOrder, queryPublish, queryCountersign, orderDelay, orderScreen, orderVisit)
  1021. .LeftJoin<SystemOrganize>((p, o) => p.OrgCode == o.Id)
  1022. .Select((p, o) => new DepartmentalProcessingStatisticsDataDto
  1023. {
  1024. OrgCode = p.OrgCode,
  1025. OrgName = o.Name,
  1026. OrgType = o.OrgType,
  1027. //OrderCountNum = p.OrderCountNum,
  1028. YbOrderCountNum = p.YbOrderCountNum,
  1029. ZbOrderCountNum = p.ZbOrderCountNum,
  1030. Archived = p.Archived,
  1031. ToBeArchived = p.ToBeArchived,
  1032. WaitPublished = p.WaitPublished,
  1033. PublishedOpen = p.PublishedOpen,
  1034. PublishedNoOpen = p.PublishedNoOpen,
  1035. YbOverdue = p.YbOverdue,
  1036. ZbOverdue = p.ZbOverdue,
  1037. CompleteOnTime = p.CompleteOnTime,
  1038. HqybOverdue = p.HqybOverdue,
  1039. HqzbOverdue = p.HqzbOverdue,
  1040. DelayEnd = p.DelayEnd,
  1041. DelayWait = p.DelayWait,
  1042. OrderDelayCount = p.OrderDelayCount,
  1043. ScreenCount = p.ScreenCount,
  1044. ScreenApproval = p.ScreenApproval,
  1045. ScreenPass = p.ScreenPass,
  1046. ScreenNotPass = p.ScreenNotPass,
  1047. SatisfactionCount = p.SatisfactionCount,
  1048. NotSatisfactionCount = p.NotSatisfactionCount
  1049. })
  1050. .MergeTable()
  1051. .WhereIF(string.IsNullOrEmpty(dto.OrgName) == false, x => x.OrgName.Contains(dto.OrgName));
  1052. }
  1053. /// <summary>
  1054. /// 部门办件统计表--子级
  1055. /// </summary>
  1056. /// <param name="dto"></param>
  1057. /// <returns></returns>
  1058. public ISugarQueryable<DepartmentalProcessingStatisticsDataDto> DepartmentalProcessingChildStatistics(DepartmentalProcessingStatisticsRequest dto)
  1059. {
  1060. dto.EndTime = dto.EndTime.AddDays(1).AddSeconds(-1);
  1061. #region 工单
  1062. //工单
  1063. var queryOrder = _orderRepository.Queryable()
  1064. .Where(it => it.CreationTime >= dto.StartTime && it.CreationTime <= dto.EndTime && it.Status > EOrderStatus.WaitForAccept)
  1065. .WhereIF(dto.OrgCode == "001", it => it.ActualHandleOrgCode == dto.OrgCode)
  1066. .WhereIF(dto.OrgCode != "001", it => it.ActualHandleOrgCode.StartsWith(dto.OrgCode))
  1067. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, it => it.Source == ESource.ProvinceStraight)
  1068. .Select(it => new
  1069. {
  1070. it.Id,
  1071. OrgCode = it.ActualHandleOrgCode.Substring(0, dto.OrgCode.Length + 3),
  1072. it.ActualHandleOrgCode,
  1073. it.Status,//工单状态
  1074. it.ExpiredTime,//期满时间
  1075. it.ActualHandleTime,//办理时间
  1076. it.CounterSignType,//会签
  1077. })
  1078. .MergeTable()
  1079. .GroupBy(it => new
  1080. {
  1081. it.OrgCode
  1082. })
  1083. .Select(it => new DepartmentalProcessingStatisticsDataDto
  1084. {
  1085. OrgCode = it.OrgCode,
  1086. // OrderCountNum = SqlFunc.AggregateCount(it.OrgCode),//总量
  1087. YbOrderCountNum = 0,//SqlFunc.AggregateSum(SqlFunc.IIF(it.Status >= EOrderStatus.Filed, 1, 0)),//已办
  1088. ZbOrderCountNum = 0,// ZbOrderCountNum = SqlFunc.AggregateSum(SqlFunc.IIF(it.Status < EOrderStatus.Filed, 1, 0)),//在办
  1089. Archived = SqlFunc.AggregateSum(SqlFunc.IIF(it.Status >= EOrderStatus.Filed, 1, 0)),//已归档
  1090. ToBeArchived = 0,
  1091. WaitPublished = 0,
  1092. PublishedOpen = 0,
  1093. PublishedNoOpen = 0,
  1094. YbOverdue = SqlFunc.AggregateSum(SqlFunc.IIF(it.Status >= EOrderStatus.Filed && it.ActualHandleTime > it.ExpiredTime, 1, 0)),//已办超期
  1095. ZbOverdue = 0,// SqlFunc.AggregateSum(SqlFunc.IIF(it.Status < EOrderStatus.Filed && it.ExpiredTime < SqlFunc.GetDate(), 1, 0)),//待办超期
  1096. CompleteOnTime = SqlFunc.AggregateSum(SqlFunc.IIF(it.Status >= EOrderStatus.Filed && it.ActualHandleTime <= it.ExpiredTime, 1, 0)),//按时办结
  1097. HqybOverdue = 0,
  1098. HqzbOverdue = 0,
  1099. DelayEnd = 0,
  1100. DelayWait = 0,
  1101. OrderDelayCount = 0,
  1102. ScreenCount = 0,
  1103. ScreenApproval = 0,
  1104. ScreenPass = 0,
  1105. ScreenNotPass = 0,
  1106. SatisfactionCount = 0,
  1107. NotSatisfactionCount = 0
  1108. })
  1109. .MergeTable();
  1110. #endregion
  1111. #region 发布
  1112. //发布
  1113. var queryPublish = _orderPublishRepository.Queryable()
  1114. .LeftJoin<Order>((x, o) => x.OrderId == o.Id)
  1115. .Where((x, o) => x.CreationTime >= dto.StartTime && x.CreationTime <= dto.EndTime)
  1116. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (x, o) => o.Source == ESource.ProvinceStraight)
  1117. .WhereIF(dto.OrgCode == "001", (x, o) => o.ActualHandleOrgCode == dto.OrgCode)
  1118. .WhereIF(dto.OrgCode != "001", (x, o) => o.ActualHandleOrgCode.StartsWith(dto.OrgCode))
  1119. .Select((x, o) => new
  1120. {
  1121. o.Id,
  1122. OrgCode = o.ActualHandleOrgCode.Substring(0, dto.OrgCode.Length + 3),
  1123. PublishState = x.PublishState,
  1124. Status = o.Status
  1125. })
  1126. .MergeTable()
  1127. .GroupBy(it => new { it.OrgCode })
  1128. .Select(it => new DepartmentalProcessingStatisticsDataDto
  1129. {
  1130. OrgCode = it.OrgCode,
  1131. // OrderCountNum = 0,//总量
  1132. YbOrderCountNum = 0,//已办
  1133. ZbOrderCountNum = 0,//在办
  1134. Archived = 0,
  1135. ToBeArchived = 0,
  1136. WaitPublished = SqlFunc.AggregateSum(SqlFunc.IIF(it.Status == EOrderStatus.Filed, 1, 0)),//待发布 --已归档的就是待发布
  1137. PublishedOpen = SqlFunc.AggregateSum(SqlFunc.IIF(it.Status >= EOrderStatus.Published && it.PublishState, 1, 0)),//已发布公开
  1138. PublishedNoOpen = SqlFunc.AggregateSum(SqlFunc.IIF(it.Status >= EOrderStatus.Published && !it.PublishState, 1, 0)),//已发布不公开
  1139. YbOverdue = 0,
  1140. ZbOverdue = 0,
  1141. CompleteOnTime = 0,
  1142. HqybOverdue = 0,
  1143. HqzbOverdue = 0,
  1144. DelayEnd = 0,
  1145. DelayWait = 0,
  1146. OrderDelayCount = 0,
  1147. ScreenCount = 0,
  1148. ScreenApproval = 0,
  1149. ScreenPass = 0,
  1150. ScreenNotPass = 0,
  1151. SatisfactionCount = 0,
  1152. NotSatisfactionCount = 0,
  1153. })
  1154. .MergeTable();
  1155. #endregion
  1156. #region 会签(已办超期、待办超期)
  1157. //会签(已办超期、待办超期)
  1158. //var queryCountersign = _workflowStepHandleRepository.Queryable()
  1159. // .LeftJoin<WorkflowTrace>((x, o) => x.WorkflowStepId == o.StepId)
  1160. var queryCountersign = _workflowTraceRepository.Queryable()
  1161. .LeftJoin<Order>((t, o) => t.ExternalId == o.Id)
  1162. .Where((t, o) => t.ModuleCode == WorkflowModuleConsts.OrderHandle && t.CreationTime >= dto.StartTime && t.CreationTime <= dto.EndTime)
  1163. .WhereIF(dto.OrgCode == "001", (t, o) => t.HandlerOrgId == dto.OrgCode)
  1164. .WhereIF(dto.OrgCode != "001", (t, o) => t.HandlerOrgId.StartsWith(dto.OrgCode))
  1165. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (t, o) => o.Source == ESource.ProvinceStraight)
  1166. .Select((t, o) => new
  1167. {
  1168. OrgCode = t.HandlerOrgId.Substring(0, dto.OrgCode.Length + 3),
  1169. t.HandleTime,
  1170. t.StepExpiredTime,
  1171. t.Status,
  1172. t.CountersignPosition,
  1173. o.Id
  1174. })
  1175. .MergeTable()
  1176. .GroupBy(d => new { d.OrgCode })
  1177. .Select(d => new DepartmentalProcessingStatisticsDataDto
  1178. {
  1179. OrgCode = d.OrgCode,
  1180. // OrderCountNum = 0,//总量
  1181. YbOrderCountNum = SqlFunc.AggregateSum(SqlFunc.IIF(d.CountersignPosition > ECountersignPosition.None && d.Status >= EWorkflowStepStatus.Handled, 1, 0)),//已办
  1182. ZbOrderCountNum = SqlFunc.AggregateSum(SqlFunc.IIF(d.Status < EWorkflowStepStatus.Handled, 1, 0)),// 0,//在办
  1183. Archived = 0,
  1184. ToBeArchived = 0,
  1185. WaitPublished = 0,
  1186. PublishedOpen = 0,
  1187. PublishedNoOpen = 0,
  1188. YbOverdue = 0,
  1189. ZbOverdue = SqlFunc.AggregateSum(SqlFunc.IIF(d.Status < EWorkflowStepStatus.Handled && DateTime.Now >= d.StepExpiredTime, 1, 0)),// 0,
  1190. CompleteOnTime = 0,
  1191. HqybOverdue = SqlFunc.AggregateSum(SqlFunc.IIF(d.CountersignPosition > ECountersignPosition.None && d.Status >= EWorkflowStepStatus.Handled && d.HandleTime > d.StepExpiredTime, 1, 0)),
  1192. HqzbOverdue = SqlFunc.AggregateSum(SqlFunc.IIF(d.CountersignPosition > ECountersignPosition.None && d.Status < EWorkflowStepStatus.Handled && DateTime.Now >= d.StepExpiredTime, 1, 0)),
  1193. DelayEnd = SqlFunc.AggregateSum(SqlFunc.IIF(d.CountersignPosition > ECountersignPosition.None && d.Status >= EWorkflowStepStatus.Handled, 1, 0)),
  1194. DelayWait = SqlFunc.AggregateSum(SqlFunc.IIF(d.CountersignPosition > ECountersignPosition.None && d.Status < EWorkflowStepStatus.Handled, 1, 0)),
  1195. OrderDelayCount = 0,
  1196. ScreenCount = 0,
  1197. ScreenApproval = 0,
  1198. ScreenPass = 0,
  1199. ScreenNotPass = 0,
  1200. SatisfactionCount = 0,
  1201. NotSatisfactionCount = 0,
  1202. })
  1203. .MergeTable();
  1204. #endregion
  1205. #region 延期
  1206. //延期
  1207. var orderDelay = _orderDelayRepository.Queryable()
  1208. .LeftJoin<Order>((x, o) => x.OrderId == o.Id)
  1209. .Where((x, o) => x.CreationTime >= dto.StartTime && x.CreationTime <= dto.EndTime)
  1210. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (x, o) => o.Source == ESource.ProvinceStraight)
  1211. .WhereIF(dto.OrgCode == "001", (x, o) => x.ApplyOrgCode == dto.OrgCode)
  1212. .WhereIF(dto.OrgCode != "001", (x, o) => x.ApplyOrgCode.StartsWith(dto.OrgCode))
  1213. .Select((x, o) => new
  1214. {
  1215. OrgCode = x.ApplyOrgCode.Substring(0, dto.OrgCode.Length + 3),
  1216. x.DelayState
  1217. })
  1218. .MergeTable()
  1219. .GroupBy(x => new { x.OrgCode })
  1220. .Select(x => new DepartmentalProcessingStatisticsDataDto
  1221. {
  1222. OrgCode = x.OrgCode,
  1223. // OrderCountNum = 0,//总量
  1224. YbOrderCountNum = 0,//已办
  1225. ZbOrderCountNum = 0,//在办
  1226. Archived = 0,
  1227. ToBeArchived = 0,
  1228. WaitPublished = 0,
  1229. PublishedOpen = 0,
  1230. PublishedNoOpen = 0,
  1231. YbOverdue = 0,
  1232. ZbOverdue = 0,
  1233. CompleteOnTime = 0,
  1234. HqybOverdue = 0,
  1235. HqzbOverdue = 0,
  1236. DelayEnd = 0,
  1237. DelayWait = 0,
  1238. OrderDelayCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.DelayState == EDelayState.Pass, 1, 0)),
  1239. ScreenCount = 0,
  1240. ScreenApproval = 0,
  1241. ScreenPass = 0,
  1242. ScreenNotPass = 0,
  1243. SatisfactionCount = 0,
  1244. NotSatisfactionCount = 0,
  1245. })
  1246. .MergeTable();
  1247. #endregion
  1248. #region 甄别
  1249. //甄别
  1250. var orderScreen = _orderScreenRepository.Queryable()
  1251. .LeftJoin<Order>((x, o) => x.OrderId == o.Id)
  1252. .Where((x, o) => x.CreationTime >= dto.StartTime && x.CreationTime <= dto.EndTime)
  1253. .WhereIF(!string.IsNullOrEmpty(dto.OrgName), (x, o) => x.CreatorOrgId.Contains(dto.OrgName))
  1254. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (x, o) => o.Source == ESource.ProvinceStraight)
  1255. .WhereIF(dto.OrgCode == "001", (x, o) => x.CreatorOrgId == dto.OrgCode)
  1256. .WhereIF(dto.OrgCode != "001", (x, o) => x.CreatorOrgId.StartsWith(dto.OrgCode))
  1257. .Select((x, o) => new
  1258. {
  1259. x.Id,
  1260. OrgCode = x.CreatorOrgId.Substring(0, dto.OrgCode.Length + 3),
  1261. x.Status
  1262. })
  1263. .MergeTable()
  1264. .GroupBy(x => new { x.OrgCode })
  1265. .Select(x => new DepartmentalProcessingStatisticsDataDto
  1266. {
  1267. OrgCode = x.OrgCode,
  1268. // OrderCountNum = 0,//总量
  1269. YbOrderCountNum = 0,//已办
  1270. ZbOrderCountNum = 0,//在办
  1271. Archived = 0,
  1272. ToBeArchived = 0,
  1273. WaitPublished = 0,
  1274. PublishedOpen = 0,
  1275. PublishedNoOpen = 0,
  1276. YbOverdue = 0,
  1277. ZbOverdue = 0,
  1278. CompleteOnTime = 0,
  1279. HqybOverdue = 0,
  1280. HqzbOverdue = 0,
  1281. DelayEnd = 0,
  1282. DelayWait = 0,
  1283. OrderDelayCount = 0,
  1284. ScreenCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.Id != null, 1, 0)),
  1285. ScreenApproval = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status == EScreenStatus.Approval || x.Status == EScreenStatus.Apply, 1, 0)),
  1286. ScreenPass = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status == EScreenStatus.End, 1, 0)),
  1287. ScreenNotPass = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status == EScreenStatus.Refuse, 1, 0)),
  1288. SatisfactionCount = 0,
  1289. NotSatisfactionCount = 0,
  1290. })
  1291. .MergeTable();
  1292. #endregion
  1293. #region 满意度
  1294. //满意度
  1295. var orderVisit = _orderVisitDetailRepository.Queryable()
  1296. .LeftJoin<OrderVisit>((x, o) => x.VisitId == o.Id)
  1297. .LeftJoin<Order>((x, o, p) => o.OrderId == p.Id)
  1298. .Where((x, o) => x.OrderVisit.VisitTime >= dto.StartTime && x.OrderVisit.VisitTime <= dto.EndTime && x.VisitTarget == EVisitTarget.Org && x.OrderVisit.VisitState == EVisitState.Visited && !string.IsNullOrEmpty(x.VisitOrgCode))
  1299. .WhereIF(dto.OrgCode == "001", (x, o) => x.VisitOrgCode == dto.OrgCode)
  1300. .WhereIF(dto.OrgCode != "001", (x, o) => x.VisitOrgCode.StartsWith(dto.OrgCode))
  1301. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (x, o, p) => p.Source == ESource.ProvinceStraight)
  1302. .Select((x, o) => new
  1303. {
  1304. OrgCode = x.VisitOrgCode.Substring(0, dto.OrgCode.Length + 3),
  1305. x.OrgProcessingResults
  1306. })
  1307. .MergeTable()
  1308. .GroupBy(x => new { x.OrgCode })
  1309. .Select(x => new DepartmentalProcessingStatisticsDataDto
  1310. {
  1311. OrgCode = x.OrgCode,
  1312. // OrderCountNum = 0,//总量
  1313. YbOrderCountNum = 0,//已办
  1314. ZbOrderCountNum = 0,//在办
  1315. Archived = 0,
  1316. ToBeArchived = 0,
  1317. WaitPublished = 0,
  1318. PublishedOpen = 0,
  1319. PublishedNoOpen = 0,
  1320. YbOverdue = 0,
  1321. ZbOverdue = 0,
  1322. CompleteOnTime = 0,
  1323. HqybOverdue = 0,
  1324. HqzbOverdue = 0,
  1325. DelayEnd = 0,
  1326. DelayWait = 0,
  1327. OrderDelayCount = 0,
  1328. ScreenCount = 0,
  1329. ScreenApproval = 0,
  1330. ScreenPass = 0,
  1331. ScreenNotPass = 0,
  1332. SatisfactionCount = SqlFunc.AggregateSum(SqlFunc.IIF(SqlFunc.JsonField(x.OrgProcessingResults, "Key") != "2", 1, 0)),
  1333. NotSatisfactionCount = SqlFunc.AggregateSum(SqlFunc.IIF(SqlFunc.JsonField(x.OrgProcessingResults, "Key") == "2", 1, 0))
  1334. })
  1335. .MergeTable();
  1336. #endregion
  1337. //联合查询
  1338. return _orderRepository.OrderUnionAll(queryOrder, queryPublish, queryCountersign, orderDelay, orderScreen, orderVisit)
  1339. .LeftJoin<SystemOrganize>((p, o) => p.OrgCode == o.Id)
  1340. .Select((p, o) => new DepartmentalProcessingStatisticsDataDto
  1341. {
  1342. OrgCode = p.OrgCode,
  1343. OrgName = o.Name,
  1344. OrgType = o.OrgType,
  1345. //OrderCountNum = p.OrderCountNum,
  1346. YbOrderCountNum = p.YbOrderCountNum,
  1347. ZbOrderCountNum = p.ZbOrderCountNum,
  1348. Archived = p.Archived,
  1349. ToBeArchived = p.ToBeArchived,
  1350. WaitPublished = p.WaitPublished,
  1351. PublishedOpen = p.PublishedOpen,
  1352. PublishedNoOpen = p.PublishedNoOpen,
  1353. YbOverdue = p.YbOverdue,
  1354. ZbOverdue = p.ZbOverdue,
  1355. CompleteOnTime = p.CompleteOnTime,
  1356. HqybOverdue = p.HqybOverdue,
  1357. HqzbOverdue = p.HqzbOverdue,
  1358. DelayEnd = p.DelayEnd,
  1359. DelayWait = p.DelayWait,
  1360. OrderDelayCount = p.OrderDelayCount,
  1361. ScreenCount = p.ScreenCount,
  1362. ScreenApproval = p.ScreenApproval,
  1363. ScreenPass = p.ScreenPass,
  1364. ScreenNotPass = p.ScreenNotPass,
  1365. SatisfactionCount = p.SatisfactionCount,
  1366. NotSatisfactionCount = p.NotSatisfactionCount
  1367. })
  1368. .MergeTable()
  1369. .WhereIF(string.IsNullOrEmpty(dto.OrgName) == false, x => x.OrgName.Contains(dto.OrgName));
  1370. }
  1371. /// <summary>
  1372. /// 部门办件统计表--明细
  1373. /// </summary>
  1374. /// <param name="dto"></param>
  1375. /// <returns></returns>
  1376. public ISugarQueryable<SelectOrderId> GetDepartmentalProcessingStatisticsList(DepartmentalProcessingStatisticsRequest dto, CancellationToken cancellationToken)
  1377. {
  1378. dto.EndTime = dto.EndTime.AddDays(1).AddSeconds(-1);
  1379. RefAsync<int> total = 0;
  1380. string stye = "";
  1381. switch (dto.StatisticsType)
  1382. {
  1383. case EStatisticsType.YBOrderCountNum:
  1384. //工单
  1385. stye = "0";
  1386. break;
  1387. case EStatisticsType.ToBeArchived:
  1388. case EStatisticsType.Archived:
  1389. case EStatisticsType.YBOverdue:
  1390. //工单
  1391. stye = "1";
  1392. break;
  1393. case EStatisticsType.WaitPublished:
  1394. case EStatisticsType.PublishedOpen:
  1395. case EStatisticsType.PublishedNoOpen:
  1396. //发布
  1397. stye = "2";
  1398. break;
  1399. case EStatisticsType.OrderDelayCount:
  1400. //延期
  1401. stye = "3";
  1402. break;
  1403. case EStatisticsType.ScreenCount:
  1404. case EStatisticsType.ScreenApproval:
  1405. case EStatisticsType.ScreenPass:
  1406. case EStatisticsType.ScreenNotPass:
  1407. //甄别
  1408. stye = "4";
  1409. break;
  1410. case EStatisticsType.HQYBOverdue:
  1411. case EStatisticsType.HQZBOverdue:
  1412. case EStatisticsType.DelayEnd:
  1413. case EStatisticsType.DelayWait:
  1414. case EStatisticsType.ZBOrderCountNum:
  1415. case EStatisticsType.ZBOverdue:
  1416. //会签
  1417. stye = "5";
  1418. break;
  1419. case EStatisticsType.SubtotalOverdue:
  1420. //超期总数
  1421. stye = "6";
  1422. break;
  1423. default:
  1424. break;
  1425. }
  1426. #region 工单已办
  1427. if (stye == "0")
  1428. {
  1429. var ybQuery = _orderRepository.Queryable()
  1430. .Where(it => it.CreationTime >= dto.StartTime && it.CreationTime <= dto.EndTime && it.Status > EOrderStatus.WaitForAccept)
  1431. .WhereIF(dto.OrgCode == "001", it => it.ActualHandleOrgCode == dto.OrgCode)
  1432. .WhereIF(dto.OrgCode != "001", it => it.ActualHandleOrgCode.StartsWith(dto.OrgCode))
  1433. .WhereIF(dto.StatisticsType == EStatisticsType.YBOrderCountNum, it => it.Status >= EOrderStatus.Filed)//已办
  1434. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, it => it.Source == ESource.ProvinceStraight)
  1435. .Select(it => new SelectOrderId { Id = it.Id })
  1436. .MergeTable();
  1437. //var hqybquery = _workflowStepHandleRepository.Queryable()
  1438. // .LeftJoin<WorkflowTrace>((x, o) => x.WorkflowStepId == o.StepId)
  1439. var hqybquery = _workflowTraceRepository.Queryable()
  1440. .LeftJoin<Order>((t, o) => t.ExternalId == o.Id)
  1441. .Where((t, o) => t.ModuleCode == WorkflowModuleConsts.OrderHandle && t.CreationTime >= dto.StartTime && t.CreationTime <= dto.EndTime)
  1442. .WhereIF(dto.OrgCode == "001", (t, o) => t.HandlerOrgId == dto.OrgCode)
  1443. .WhereIF(dto.OrgCode != "001", (t, o) => t.HandlerOrgId.StartsWith(dto.OrgCode))
  1444. .WhereIF(dto.StatisticsType == EStatisticsType.YBOrderCountNum, (t, o) => t.Status >= EWorkflowStepStatus.Handled && t.CountersignPosition > ECountersignPosition.None)//会签已办
  1445. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (t, o) => o.Source == ESource.ProvinceStraight)
  1446. .Select((t, o) => new SelectOrderId { Id = o.Id })
  1447. .MergeTable();
  1448. var queryData = _orderRepository.OrderListUnionAll(ybQuery, hqybquery).GroupBy(p => p.Id).MergeTable();
  1449. return queryData;
  1450. }
  1451. #endregion
  1452. #region 工单
  1453. if (stye == "1")
  1454. {
  1455. //工单
  1456. var queryData = _orderRepository.Queryable()
  1457. .Where(o => o.CreationTime >= dto.StartTime && o.CreationTime <= dto.EndTime && o.Status > EOrderStatus.WaitForAccept)
  1458. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, o => o.Source == ESource.ProvinceStraight)
  1459. .WhereIF(dto.OrgCode == "001", o => o.ActualHandleOrgCode == dto.OrgCode)
  1460. .WhereIF(dto.OrgCode != "001", o => o.ActualHandleOrgCode.StartsWith(dto.OrgCode))
  1461. .WhereIF(dto.StatisticsType == EStatisticsType.Archived, o => o.Status >= EOrderStatus.Filed)//已归档
  1462. .WhereIF(dto.StatisticsType == EStatisticsType.ToBeArchived, o => o.Status < EOrderStatus.WaitForAccept)//待归档--没得待归档数据
  1463. .WhereIF(dto.StatisticsType == EStatisticsType.YBOverdue, o => o.Status >= EOrderStatus.Filed && o.ActualHandleTime > o.ExpiredTime)//已办超期
  1464. .OrderByDescending(o => o.CreationTime)
  1465. .Select(o => new SelectOrderId { Id = o.Id })
  1466. .MergeTable();
  1467. return queryData;
  1468. }
  1469. #endregion
  1470. #region 发布
  1471. if (stye == "2")
  1472. {
  1473. //发布
  1474. var queryPublish = _orderPublishRepository.Queryable()
  1475. .LeftJoin<Order>((x, o) => x.OrderId == o.Id)
  1476. .Where((x, o) => x.CreationTime >= dto.StartTime && x.CreationTime <= dto.EndTime)
  1477. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (x, o) => o.Source == ESource.ProvinceStraight)
  1478. .WhereIF(dto.OrgCode == "001", (x, o) => o.ActualHandleOrgCode == dto.OrgCode)
  1479. .WhereIF(dto.OrgCode != "001", (x, o) => o.ActualHandleOrgCode.StartsWith(dto.OrgCode))
  1480. .WhereIF(dto.StatisticsType == EStatisticsType.WaitPublished, (x, o) => o.Status == EOrderStatus.Filed)//待发布 --已归档的就是待发布
  1481. .WhereIF(dto.StatisticsType == EStatisticsType.PublishedOpen, (x, o) => o.Status >= EOrderStatus.Published && x.PublishState)//已发布公开
  1482. .WhereIF(dto.StatisticsType == EStatisticsType.PublishedNoOpen, (x, o) => o.Status == EOrderStatus.Published && !x.PublishState)//已发布不公开
  1483. .OrderByDescending((x, o) => o.CreationTime)
  1484. .Select((x, o) => new SelectOrderId { Id = o.Id })
  1485. .MergeTable();
  1486. return queryPublish;
  1487. }
  1488. #endregion
  1489. #region 延期
  1490. if (stye == "3")
  1491. {
  1492. //延期
  1493. var orderDelay = _orderDelayRepository.Queryable()
  1494. .LeftJoin<Order>((x, o) => x.OrderId == o.Id)
  1495. .Where((x, o) => x.CreationTime >= dto.StartTime && x.CreationTime <= dto.EndTime)
  1496. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (x, o) => o.Source == ESource.ProvinceStraight)
  1497. .WhereIF(dto.OrgCode == "001", (x, o) => x.ApplyOrgCode == dto.OrgCode)
  1498. .WhereIF(dto.OrgCode != "001", (x, o) => x.ApplyOrgCode.StartsWith(dto.OrgCode))
  1499. .WhereIF(dto.StatisticsType == EStatisticsType.OrderDelayCount, (x, o) => x.DelayState == EDelayState.Pass)//延期次数
  1500. .OrderByDescending((x, o) => o.CreationTime)
  1501. .Select((x, o) => new SelectOrderId { Id = o.Id })
  1502. .MergeTable();
  1503. return orderDelay;
  1504. }
  1505. #endregion
  1506. #region 甄别
  1507. if (stye == "4")
  1508. {
  1509. //甄别
  1510. var orderScreen = _orderScreenRepository.Queryable()
  1511. .LeftJoin<Order>((x, o) => x.OrderId == o.Id)
  1512. .Where((x, o) => x.CreationTime >= dto.StartTime && x.CreationTime <= dto.EndTime)
  1513. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (x, o) => o.Source == ESource.ProvinceStraight)
  1514. .WhereIF(dto.OrgCode == "001", (x, o) => x.CreatorOrgId == dto.OrgCode)
  1515. .WhereIF(dto.OrgCode != "001", (x, o) => x.CreatorOrgId.StartsWith(dto.OrgCode))
  1516. .WhereIF(dto.StatisticsType == EStatisticsType.ScreenCount, (x, o) => x.Id != null)//申请总量
  1517. .WhereIF(dto.StatisticsType == EStatisticsType.ScreenApproval, (x, o) => x.Status == EScreenStatus.Approval || x.Status == EScreenStatus.Apply)//待甄别
  1518. .WhereIF(dto.StatisticsType == EStatisticsType.ScreenPass, (x, o) => x.Status == EScreenStatus.End)//甄别通过
  1519. .WhereIF(dto.StatisticsType == EStatisticsType.ScreenNotPass, (x, o) => x.Status == EScreenStatus.Refuse)//甄别不通过
  1520. .OrderByDescending((x, o) => o.CreationTime)
  1521. .Select((x, o) => new SelectOrderId { Id = o.Id })
  1522. .MergeTable();
  1523. return orderScreen;
  1524. }
  1525. #endregion
  1526. #region 会签(已办超期、待办超期)
  1527. if (stye == "5")
  1528. {
  1529. //会签(已办超期、待办超期)
  1530. var queryCountersign = _workflowTraceRepository.Queryable()
  1531. .LeftJoin<Order>((t, o) => t.ExternalId == o.Id)
  1532. .Where((t, o) => t.ModuleCode == WorkflowModuleConsts.OrderHandle && t.CreationTime >= dto.StartTime && t.CreationTime <= dto.EndTime)
  1533. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (t, o) => o.Source == ESource.ProvinceStraight)
  1534. .WhereIF(dto.OrgCode == "001", (t, o) => t.HandlerOrgId == dto.OrgCode)
  1535. .WhereIF(dto.OrgCode != "001", (t, o) => t.HandlerOrgId.StartsWith(dto.OrgCode))
  1536. .WhereIF(dto.StatisticsType == EStatisticsType.HQYBOverdue, (t, o) => t.Status >= EWorkflowStepStatus.Handled && t.HandleTime > t.StepExpiredTime && t.CountersignPosition > ECountersignPosition.None)//会签已办超期
  1537. .WhereIF(dto.StatisticsType == EStatisticsType.HQZBOverdue, (t, o) => t.Status < EWorkflowStepStatus.Handled && DateTime.Now >= t.StepExpiredTime && t.CountersignPosition > ECountersignPosition.None)//会签待办超期
  1538. .WhereIF(dto.StatisticsType == EStatisticsType.DelayEnd, (t, o) => t.Status >= EWorkflowStepStatus.Handled && t.CountersignPosition > ECountersignPosition.None)//会签已办
  1539. .WhereIF(dto.StatisticsType == EStatisticsType.DelayWait, (t, o) => t.Status < EWorkflowStepStatus.Handled && t.CountersignPosition > ECountersignPosition.None)//会签待办
  1540. .WhereIF(dto.StatisticsType == EStatisticsType.ZBOrderCountNum, (t, o) => t.Status < EWorkflowStepStatus.Handled)//在办总量
  1541. .WhereIF(dto.StatisticsType == EStatisticsType.ZBOverdue, (t, o) => t.Status < EWorkflowStepStatus.Handled && DateTime.Now >= t.StepExpiredTime)//在办超期
  1542. .OrderByDescending((t, o) => o.CreationTime)
  1543. .Select((t, o) => new SelectOrderId { Id = o.Id })
  1544. .MergeTable()
  1545. .GroupBy(p => p.Id)
  1546. .MergeTable();
  1547. return queryCountersign;
  1548. }
  1549. #endregion
  1550. #region 超期件数
  1551. //超期件数
  1552. if (stye == "6")
  1553. {
  1554. var queryOrder = _orderRepository.Queryable()
  1555. .Where(it => it.CreationTime >= dto.StartTime && it.CreationTime <= dto.EndTime && it.Status > EOrderStatus.WaitForAccept)
  1556. .WhereIF(dto.OrgCode == "001", it => it.ActualHandleOrgCode == dto.OrgCode)
  1557. .WhereIF(dto.OrgCode != "001", it => it.ActualHandleOrgCode.StartsWith(dto.OrgCode))
  1558. .WhereIF(dto.StatisticsType == EStatisticsType.SubtotalOverdue, it => (it.Status >= EOrderStatus.Filed && it.ActualHandleTime > it.ExpiredTime))//已办超期
  1559. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, it => it.Source == ESource.ProvinceStraight)
  1560. .Select(it => new SelectOrderId { Id = it.Id })
  1561. .MergeTable();
  1562. //会签(已办超期、待办超期)
  1563. //var queryCountersign = _workflowStepHandleRepository.Queryable()
  1564. //.LeftJoin<WorkflowTrace>((x, o) => x.WorkflowStepId == o.StepId)
  1565. var queryCountersign = _workflowTraceRepository.Queryable()
  1566. .LeftJoin<Order>((t, o) => t.ExternalId == o.Id)
  1567. .Where((t, o) => t.ModuleCode == WorkflowModuleConsts.OrderHandle && t.CreationTime >= dto.StartTime && t.CreationTime <= dto.EndTime)
  1568. .WhereIF(dto.IsProvince.HasValue && dto.IsProvince == true, (t, o) => o.Source == ESource.ProvinceStraight)
  1569. .WhereIF(dto.OrgCode == "001", (t, o) => t.HandlerOrgId == dto.OrgCode)
  1570. .WhereIF(dto.OrgCode != "001", (t, o) => t.HandlerOrgId.StartsWith(dto.OrgCode))
  1571. .WhereIF(dto.StatisticsType == EStatisticsType.SubtotalOverdue, (t, o) => (t.Status >= EWorkflowStepStatus.Handled && t.CountersignPosition > ECountersignPosition.None && t.HandleTime > t.StepExpiredTime)
  1572. || (t.Status < EWorkflowStepStatus.Handled && t.CountersignPosition > ECountersignPosition.None && DateTime.Now >= t.StepExpiredTime)
  1573. || (t.Status < EWorkflowStepStatus.Handled && DateTime.Now >= t.StepExpiredTime))//会签已办超期/会签待办超期/待办超期
  1574. .Select((t, o) => new SelectOrderId { Id = o.Id })
  1575. .MergeTable();
  1576. var queryData = _orderRepository.OrderListUnionAll(queryOrder, queryCountersign).GroupBy(x => x.Id).MergeTable();
  1577. return queryData;
  1578. }
  1579. #endregion
  1580. return null;
  1581. }
  1582. /// <summary>
  1583. /// 部门延期统计
  1584. /// </summary>
  1585. /// <param name="dto"></param>
  1586. /// <returns></returns>
  1587. public ISugarQueryable<BiOrderDelayDataDto> QueryOrderDelayDataList(QueryOrderDelayDataListRequest dto)
  1588. {
  1589. if (!dto.StartTime.HasValue || !dto.EndTime.HasValue) throw UserFriendlyException.SameMessage("请选择时间!");
  1590. dto.EndTime = dto.EndTime.Value.AddDays(1).AddSeconds(-1);
  1591. var IsCenter = _sessionContext.OrgIsCenter;
  1592. return _orderDelayRepository.Queryable()
  1593. .LeftJoin<SystemOrganize>((x, o) => x.ApplyOrgCode == o.Id)
  1594. .WhereIF(dto.StartTime.HasValue, (x, o) => x.CreationTime >= dto.StartTime)
  1595. .WhereIF(dto.EndTime.HasValue, (x, o) => x.CreationTime <= dto.EndTime)
  1596. .WhereIF(!string.IsNullOrEmpty(dto.OrgName), x => x.ApplyOrgName.Contains(dto.OrgName))
  1597. .WhereIF(IsCenter == false, x => x.ApplyOrgCode.StartsWith(_sessionContext.RequiredOrgId))
  1598. .GroupBy(x => new { x.ApplyOrgCode, x.ApplyOrgName })
  1599. .Select(x => new BiOrderDelayDataDto
  1600. {
  1601. OrgName = x.ApplyOrgName,
  1602. OrgCode = x.ApplyOrgCode,
  1603. PassTotal = SqlFunc.AggregateSum(SqlFunc.IIF(x.DelayState == EDelayState.Pass, 1, 0)),
  1604. NoPassTotal = SqlFunc.AggregateSum(SqlFunc.IIF(x.DelayState == EDelayState.NoPass, 1, 0)),
  1605. ExaminingTotal = SqlFunc.AggregateSum(SqlFunc.IIF(x.DelayState == EDelayState.Examining, 1, 0)),
  1606. AllTotal = SqlFunc.AggregateSum(SqlFunc.IIF(x.DelayState == EDelayState.Pass, 1, 0)) + SqlFunc.AggregateSum(SqlFunc.IIF(x.DelayState == EDelayState.NoPass, 1, 0)) + SqlFunc.AggregateSum(SqlFunc.IIF(x.DelayState == EDelayState.Examining, 1, 0))
  1607. }).MergeTable();
  1608. }
  1609. /// <summary>
  1610. /// 部门延期统计明细
  1611. /// </summary>
  1612. /// <param name="dto"></param>
  1613. /// <returns></returns>
  1614. public ISugarQueryable<OrderDelay> QueryOrderDelayDataDetail(QueryOrderDelayDataDetailRequest dto)
  1615. {
  1616. if (!dto.StartTime.HasValue || !dto.EndTime.HasValue) throw UserFriendlyException.SameMessage("请选择时间!");
  1617. dto.EndTime = dto.EndTime.Value.AddDays(1).AddSeconds(-1);
  1618. return _orderDelayRepository.Queryable()
  1619. .Includes(x => x.Order)
  1620. .WhereIF(dto.StartTime.HasValue, x => x.CreationTime >= dto.StartTime)
  1621. .WhereIF(dto.EndTime.HasValue, x => x.CreationTime <= dto.EndTime)
  1622. .WhereIF(!string.IsNullOrEmpty(dto.OrgCode), x => x.ApplyOrgCode == dto.OrgCode)
  1623. .WhereIF(dto.Type is 1, x => x.DelayState == EDelayState.Pass)
  1624. .WhereIF(dto.Type is 2, x => x.DelayState == EDelayState.NoPass)
  1625. .WhereIF(dto.Type is 3, x => x.DelayState == EDelayState.Examining)
  1626. .WhereIF(dto.Type is 4, x => x.DelayState < EDelayState.Withdraw)
  1627. .MergeTable();
  1628. }
  1629. /// <summary>
  1630. /// 部门受理类型统计周期
  1631. /// </summary>
  1632. /// <param name="dto"></param>
  1633. /// <returns></returns>
  1634. public ISugarQueryable<DepartmentAcceptanceTypeStatisticsDto> DepartmentAcceptanceTypeStatistics(DepartmentKeyWordRequest dto)
  1635. {
  1636. dto.EndTime = dto.EndTime.AddDays(1).AddSeconds(-1);
  1637. var IsCenter = _sessionContext.OrgIsCenter;
  1638. var orderData = _orderRepository.Queryable()
  1639. .Where(it => it.CreationTime >= dto.StartTime && it.CreationTime <= dto.EndTime && it.Status >= EOrderStatus.Filed)
  1640. .Select(it => new
  1641. {
  1642. OrgCode = IsCenter == true ? it.ActualHandleOrgCode.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6")) : it.ActualHandleOrgCode.Substring(0, _sessionContext.RequiredOrgId.Length + 3),
  1643. AcceptTypeCode = it.AcceptTypeCode,
  1644. ProcessType = it.ProcessType,
  1645. AllTime = it.ProcessType == EProcessType.Zhiban ? it.CreationTimeHandleDurationWorkday : it.CenterToOrgHandleDurationWorkday
  1646. })
  1647. .MergeTable()
  1648. .LeftJoin<SystemOrganize>((it, o) => it.OrgCode == o.Id)
  1649. //.WhereIF(TypeCode == 1, (it, o) => it.OrgCode == "001")
  1650. //.WhereIF(TypeCode == 2, (it, o) => it.OrgCode != "001")
  1651. .WhereIF(dto.TypeCode == 1, (it, o) => it.ProcessType == EProcessType.Zhiban)
  1652. .WhereIF(dto.TypeCode == 2, (it, o) => it.ProcessType == EProcessType.Jiaoban)
  1653. .WhereIF(IsCenter == false, (it, o) => it.OrgCode.StartsWith(_sessionContext.RequiredOrgId))
  1654. .GroupBy((it, o) => new
  1655. {
  1656. it.OrgCode,
  1657. o.Name,
  1658. o.OrgType
  1659. })
  1660. .Select((it, o) => new DepartmentAcceptanceTypeStatisticsDto
  1661. {
  1662. OrgName = it.OrgCode == "001" ? "市民热线服务中心" : o.Name,
  1663. OrgCode = it.OrgCode,
  1664. OrgType = o.OrgType == EOrgType.County ? "区县部门" : "市直部门",
  1665. ZxAllCount = SqlFunc.AggregateSum(SqlFunc.IIF(it.AcceptTypeCode == "10", 1, 0)),
  1666. ZxAllTimes = SqlFunc.AggregateSum(SqlFunc.IIF(it.AcceptTypeCode == "10" && it.AllTime != null, it.AllTime, 0)),
  1667. ZxAcceptanceTypeCode = "10",
  1668. JyAllCount = SqlFunc.AggregateSum(SqlFunc.IIF(it.AcceptTypeCode == "15", 1, 0)),
  1669. JyAllTimes = SqlFunc.AggregateSum(SqlFunc.IIF(it.AcceptTypeCode == "15" && it.AllTime != null, it.AllTime, 0)),
  1670. JyAcceptanceTypeCode = "15",
  1671. QzAllCount = SqlFunc.AggregateSum(SqlFunc.IIF(it.AcceptTypeCode == "20", 1, 0)),
  1672. QzAllTimes = SqlFunc.AggregateSum(SqlFunc.IIF(it.AcceptTypeCode == "20" && it.AllTime != null, it.AllTime, 0)),
  1673. QzAcceptanceTypeCode = "20",
  1674. ByAllCount = SqlFunc.AggregateSum(SqlFunc.IIF(it.AcceptTypeCode == "25", 1, 0)),
  1675. ByAllTimes = SqlFunc.AggregateSum(SqlFunc.IIF(it.AcceptTypeCode == "25" && it.AllTime != null, it.AllTime, 0)),
  1676. ByAcceptanceTypeCode = "25",
  1677. JbAllCount = SqlFunc.AggregateSum(SqlFunc.IIF(it.AcceptTypeCode == "30", 1, 0)),
  1678. JbAllTimes = SqlFunc.AggregateSum(SqlFunc.IIF(it.AcceptTypeCode == "30" && it.AllTime != null, it.AllTime, 0)),
  1679. JbAcceptanceTypeCode = "30",
  1680. TsAllCount = SqlFunc.AggregateSum(SqlFunc.IIF(it.AcceptTypeCode == "35", 1, 0)),
  1681. TsAllTimes = SqlFunc.AggregateSum(SqlFunc.IIF(it.AcceptTypeCode == "35" && it.AllTime != null, it.AllTime, 0)),
  1682. TsAcceptanceTypeCode = "35",
  1683. QtAllCount = SqlFunc.AggregateSum(SqlFunc.IIF(it.AcceptTypeCode == "40", 1, 0)),
  1684. QtAllTimes = SqlFunc.AggregateSum(SqlFunc.IIF(it.AcceptTypeCode == "40" && it.AllTime != null, it.AllTime, 0)),
  1685. QtAcceptanceTypeCode = "40",
  1686. YjAllCount = SqlFunc.AggregateSum(SqlFunc.IIF(it.AcceptTypeCode == "1", 1, 0)),
  1687. YjAllTimes = SqlFunc.AggregateSum(SqlFunc.IIF(it.AcceptTypeCode == "1" && it.AllTime != null, it.AllTime, 0)),
  1688. YjAcceptanceTypeCode = "1"
  1689. }).MergeTable();
  1690. return orderData;
  1691. }
  1692. /// <summary>
  1693. /// 部门受理类型统计周期--明细列表
  1694. /// </summary>
  1695. /// <param name="dto"></param>
  1696. /// <returns></returns>
  1697. public ISugarQueryable<Order> DepartmentAcceptanceTypeOrderList(DepartmentKeyWordRequest dto)
  1698. {
  1699. dto.EndTime = dto.EndTime.AddDays(1).AddSeconds(-1);
  1700. return _orderRepository.Queryable()
  1701. .Where(p => p.CreationTime >= dto.StartTime && p.CreationTime <= dto.EndTime && p.Status >= EOrderStatus.Filed)
  1702. .WhereIF(!string.IsNullOrEmpty(dto.OrgCode) && dto.OrgCode == "001", p => p.ActualHandleOrgCode == dto.OrgCode)
  1703. .WhereIF(!string.IsNullOrEmpty(dto.OrgCode) && dto.OrgCode != "001" && _sessionContext.RequiredOrgId != dto.OrgCode, p => p.ActualHandleOrgCode.StartsWith(dto.OrgCode))
  1704. .WhereIF(!string.IsNullOrEmpty(dto.OrgCode) && dto.OrgCode != "001" && _sessionContext.RequiredOrgId == dto.OrgCode, p => p.ActualHandleOrgCode == dto.OrgCode)
  1705. .WhereIF(!string.IsNullOrEmpty(dto.AcceptTypeCode), p => p.AcceptTypeCode == dto.AcceptTypeCode)
  1706. .WhereIF(dto.TypeCode == 1, p => p.ProcessType == EProcessType.Zhiban)
  1707. .WhereIF(dto.TypeCode == 2, p => p.ProcessType == EProcessType.Jiaoban)
  1708. .OrderByDescending(d => d.CreationTime)
  1709. .MergeTable();
  1710. }
  1711. /// <summary>
  1712. /// 满意度明细
  1713. /// </summary>
  1714. /// <param name="dto"></param>
  1715. /// <returns></returns>
  1716. public ISugarQueryable<OrderVisitDetail> OrgVisitDetailList(OrgVisitDetailListReq dto)
  1717. {
  1718. var IsCenter = _sessionContext.OrgIsCenter;
  1719. return _orderVisitDetailRepository.Queryable()
  1720. .Includes(x => x.OrderVisit, x => x.Order, x => x.OrderScreens)
  1721. .Includes(x => x.OrderVisit, x => x.Employee)
  1722. .Where(x => x.OrderVisit.VisitState == EVisitState.Visited && x.VisitTarget == EVisitTarget.Org)
  1723. .WhereIF(IsCenter == false, x => x.VisitOrgCode.StartsWith(_sessionContext.RequiredOrgId))
  1724. .WhereIF(dto.OrgVisitStatisticsType.HasValue, x => x.OrderVisit.Order.ProcessType == (EProcessType)((int)dto.OrgVisitStatisticsType))
  1725. .WhereIF(!string.IsNullOrEmpty(dto.OrgProcessingResults), x => SqlFunc.JsonField(x.OrgProcessingResults, "Key") == dto.OrgProcessingResults)
  1726. .WhereIF(!string.IsNullOrEmpty(dto.VisitUser), x => x.OrderVisit.Employee.Name.Contains(dto.VisitUser))
  1727. .WhereIF(!string.IsNullOrEmpty(dto.No), x => x.OrderVisit.Order.No == dto.No)
  1728. .WhereIF(!string.IsNullOrEmpty(dto.Title), x => x.OrderVisit.Order.Title.Contains(dto.Title))
  1729. .WhereIF(dto.OrgCodes.Any(), x => dto.OrgCodes.Contains(x.VisitOrgCode))
  1730. .WhereIF(dto.HotspotIds.Any(), x => dto.HotspotIds.Contains(x.OrderVisit.Order.HotspotId))
  1731. .WhereIF(dto.Channels.Any(), x => dto.Channels.Contains(x.OrderVisit.Order.SourceChannelCode))
  1732. .WhereIF(dto.CreationTimeStart.HasValue, x => x.OrderVisit.Order.CreationTime >= dto.CreationTimeStart) //受理时间开始
  1733. .WhereIF(dto.CreationTimeEnd.HasValue, x => x.OrderVisit.Order.CreationTime <= dto.CreationTimeEnd) //受理时间结束
  1734. .WhereIF(dto.ActualHandleTimeStart.HasValue, x => x.OrderVisit.Order.ActualHandleTime >= dto.ActualHandleTimeStart) //办结时间开始
  1735. .WhereIF(dto.ActualHandleTimeEnd.HasValue, x => x.OrderVisit.Order.ActualHandleTime <= dto.ActualHandleTimeEnd)
  1736. .OrderBy(x => x.OrderVisit.VisitTime); //办结时间结束
  1737. }
  1738. }
  1739. }