OrderRepository.cs 70 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377
  1. using Hotline.CallCenter.Calls;
  2. using Hotline.Orders;
  3. using Hotline.Repository.SqlSugar.DataPermissions;
  4. using Hotline.Repository.SqlSugar.Extensions;
  5. using Hotline.Settings;
  6. using Hotline.Settings.Hotspots;
  7. using Hotline.Share.Dtos.Bi;
  8. using Hotline.Share.Dtos.CallCenter;
  9. using Hotline.Share.Dtos.Order;
  10. using Hotline.Share.Enums.CallCenter;
  11. using Hotline.Share.Enums.Order;
  12. using Hotline.Share.Requests;
  13. using Hotline.Share.Tools;
  14. using Microsoft.EntityFrameworkCore.Storage.ValueConversion.Internal;
  15. using SqlSugar;
  16. using System.Data;
  17. using System.Linq;
  18. using System.Linq.Dynamic.Core;
  19. using System.Net;
  20. using System.Reflection;
  21. using System.Reflection.Emit;
  22. using XF.Domain.Authentications;
  23. using XF.Domain.Dependency;
  24. using XF.Domain.Repository;
  25. namespace Hotline.Repository.SqlSugar.Orders
  26. {
  27. public class OrderRepository : BaseRepositoryWorkflow<Order>, IOrderRepository, IScopeDependency
  28. {
  29. private readonly IDataPermissionFilterBuilder _dataPermissionFilterBuilder;
  30. private readonly IRepository<OrderSendBackAudit> _orderSendBackAuditRepository;
  31. private readonly IRepository<OrderVisit> _orderVisitRepository;
  32. private readonly IRepository<OrderVisitDetail> _orderVisitDetailRepository;
  33. private readonly ISessionContext _sessionContext;
  34. public OrderRepository(ISugarUnitOfWork<HotlineDbContext> uow,
  35. IDataPermissionFilterBuilder dataPermissionFilterBuilder,
  36. IRepository<OrderSendBackAudit> orderSendBackAuditRepository,
  37. IRepository<OrderVisit> orderVisitRepository,
  38. ISessionContext sessionContext,
  39. IRepository<OrderVisitDetail> orderVisitDetailRepository
  40. ) : base(uow, dataPermissionFilterBuilder)
  41. {
  42. _dataPermissionFilterBuilder = dataPermissionFilterBuilder;
  43. _orderSendBackAuditRepository = orderSendBackAuditRepository;
  44. _orderVisitRepository = orderVisitRepository;
  45. _sessionContext = sessionContext;
  46. _orderVisitDetailRepository = orderVisitDetailRepository;
  47. }
  48. public async Task<string> AddOrderNavAsync(Order order, CancellationToken cancellationToken)
  49. {
  50. //弥补AddNav方法没有自动指派到创建人
  51. order.AssignToCreator(_dataPermissionFilterBuilder.DataPermissionManager);
  52. await AddNav(order).Include(d => d.OrderExtension).ExecuteCommandAsync();
  53. return order.Id;
  54. }
  55. /// <summary>
  56. /// 工单词库批量删除
  57. /// </summary>
  58. /// <param name="ids"></param>
  59. /// <param name="cancellationToken"></param>
  60. /// <returns></returns>
  61. public async Task RemoveOrderWrodBatchAsync(List<string> ids, CancellationToken cancellationToken)
  62. {
  63. await Db.Deleteable<OrderWord>().In(x => x.Id, ids).ExecuteCommandAsync(cancellationToken);
  64. }
  65. /// <summary>
  66. /// 工单观察批量删除
  67. /// </summary>
  68. /// <param name="ids"></param>
  69. /// <param name="cancellationToken"></param>
  70. /// <returns></returns>
  71. public async Task RemoveOrderObserveBatchAsync(List<string> ids, CancellationToken cancellationToken)
  72. {
  73. await Db.Deleteable<OrderObserve>().In(x => x.Id, ids).ExecuteCommandAsync(cancellationToken);
  74. }
  75. /// <summary>
  76. /// 工单终结批量删除
  77. /// </summary>
  78. /// <param name="ids"></param>
  79. /// <param name="cancellationToken"></param>
  80. /// <returns></returns>
  81. public async Task RemoveOrderFinalityBatchAsync(List<string> ids, CancellationToken cancellationToken)
  82. {
  83. await Db.Deleteable<OrderFinality>().In(x => x.Id, ids).ExecuteCommandAsync(cancellationToken);
  84. }
  85. public async Task OrderScreenRevisionVisit(string VisitId, bool canHandle, CancellationToken cancellationToken)
  86. {
  87. await Db.Updateable<OrderVisit>().SetColumns(x => x.IsCanHandle == canHandle).Where(x => x.Id == VisitId).ExecuteCommandAsync(cancellationToken);
  88. }
  89. public async Task FileAsync(Order order, CancellationToken cancellationToken)
  90. {
  91. await Db.Updateable<Order>().SetColumns(x => x.FileJson == order.FileJson).Where(x => x.Id == order.Id).ExecuteCommandAsync(cancellationToken);
  92. }
  93. private static object GetPropertyValue(object obj, string property)
  94. {
  95. PropertyInfo propertyInfo = obj.GetType().GetProperty(property);
  96. return propertyInfo.GetValue(obj, null);
  97. }
  98. public async Task<object> HotPortJoinOrgStatistics(DateTime StartTime, DateTime EndTime, bool IsCenter, string? OrgCode)
  99. {
  100. //查询一级热点
  101. var hotSpotList = await Db.Queryable<Hotspot>().Where(x => string.IsNullOrEmpty(x.ParentId)).ToListAsync();
  102. List<dynamic>? listReturn = new List<dynamic>();
  103. foreach (var item in hotSpotList)
  104. {
  105. var table = await Db.Queryable<Order>()
  106. .LeftJoin<SystemOrganize>((it, o) => it.ActualHandleOrgCode.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6")) == o.Id)
  107. .Where((it, o) => it.CreationTime >= StartTime && it.CreationTime <= EndTime)
  108. .WhereIF(IsCenter == false, (it, o) => o.Id.StartsWith(OrgCode))
  109. .GroupBy((it, o) => new
  110. {
  111. CurrentHandleOrgCode = (it.ActualHandleOrgCode.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6"))),
  112. o.Name
  113. })
  114. .Select((it, o) => new
  115. {
  116. OrgCode = it.ActualHandleOrgCode.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6")),
  117. Count = SqlFunc.AggregateSum(SqlFunc.IIF(it.HotspotId.Substring(0, 2) == item.Id, 1, 0)),
  118. Key = item.Id,
  119. OrgName = o.Name,
  120. HotSorpName = item.HotSpotName
  121. }).ToPivotListAsync(x => x.Key, x => new { x.OrgCode, x.OrgName, x.HotSorpName }, x => x.Sum(x => x.Count));
  122. listReturn.AddRange(table);
  123. }
  124. return new { HotSpot = hotSpotList, Data = listReturn };
  125. }
  126. public ISugarQueryable<DepartmentalProcessingStatisticsDataDto> OrderUnionAll(ISugarQueryable<DepartmentalProcessingStatisticsDataDto> t1,
  127. ISugarQueryable<DepartmentalProcessingStatisticsDataDto> t2,
  128. ISugarQueryable<DepartmentalProcessingStatisticsDataDto> t3,
  129. ISugarQueryable<DepartmentalProcessingStatisticsDataDto> t4,
  130. ISugarQueryable<DepartmentalProcessingStatisticsDataDto> t5,
  131. ISugarQueryable<DepartmentalProcessingStatisticsDataDto> t6)
  132. {
  133. return Db.UnionAll(t1, t2, t3, t4, t5, t6)
  134. .GroupBy(p => new { p.OrgCode })
  135. .Select(p => new DepartmentalProcessingStatisticsDataDto
  136. {
  137. OrgCode = p.OrgCode,
  138. // OrderCountNum = SqlFunc.AggregateSum(p.OrderCountNum),
  139. YbOrderCountNum = SqlFunc.AggregateSum(p.YbOrderCountNum),
  140. ZbOrderCountNum = SqlFunc.AggregateSum(p.ZbOrderCountNum),
  141. Archived = SqlFunc.AggregateSum(p.Archived),
  142. ToBeArchived = SqlFunc.AggregateSum(p.ToBeArchived),
  143. WaitPublished = SqlFunc.AggregateSum(p.WaitPublished),
  144. PublishedOpen = SqlFunc.AggregateSum(p.PublishedOpen),
  145. PublishedNoOpen = SqlFunc.AggregateSum(p.PublishedNoOpen),
  146. YbOverdue = SqlFunc.AggregateSum(p.YbOverdue),
  147. ZbOverdue = SqlFunc.AggregateSum(p.ZbOverdue),
  148. CompleteOnTime = SqlFunc.AggregateSum(p.CompleteOnTime),
  149. HqybOverdue = SqlFunc.AggregateSum(p.HqybOverdue),
  150. HqzbOverdue = SqlFunc.AggregateSum(p.HqzbOverdue),
  151. DelayEnd = SqlFunc.AggregateSum(p.DelayEnd),
  152. DelayWait = SqlFunc.AggregateSum(p.DelayWait),
  153. OrderDelayCount = SqlFunc.AggregateSum(p.OrderDelayCount),
  154. ScreenCount = SqlFunc.AggregateSum(p.ScreenCount),
  155. ScreenApproval = SqlFunc.AggregateSum(p.ScreenApproval),
  156. ScreenPass = SqlFunc.AggregateSum(p.ScreenPass),
  157. ScreenNotPass = SqlFunc.AggregateSum(p.ScreenNotPass),
  158. SatisfactionCount = SqlFunc.AggregateSum(p.SatisfactionCount),
  159. NotSatisfactionCount = SqlFunc.AggregateSum(p.NotSatisfactionCount)
  160. })
  161. .MergeTable();
  162. }
  163. public ISugarQueryable<T> UnionAll<T>(params ISugarQueryable<T>[] queryables) where T : class
  164. {
  165. return Db.UnionAll(queryables);
  166. }
  167. /// <summary>
  168. /// 部门办件统计
  169. /// </summary>
  170. /// <param name="sql"></param>
  171. /// <returns></returns>
  172. public List<DepartmentalProcessingStatisticsDataDto> DepartmentalProcessingStatisticsNew(string sql)
  173. {
  174. return Db.Ado.SqlQuery<DepartmentalProcessingStatisticsDataDto>(sql);
  175. }
  176. /// <summary>
  177. /// 区域分时统计
  178. /// </summary>
  179. /// <param name="dto"></param>
  180. /// <returns></returns>
  181. public async Task<object> OrderAreaTime(TimeSharingPagedKeywordRequest dto)
  182. {
  183. List<int> dts = new List<int>();
  184. for (int i = 0; i < 24; i++)
  185. {
  186. dts.Add(i);
  187. }
  188. var listHour = Db.Reportable(dts).ToQueryable<int>();
  189. var listOrder = Db.Queryable<Order>()
  190. .Where(p => p.CreationTime >= dto.StartTime && p.CreationTime <= dto.EndTime)
  191. .WhereIF(dto.TypeId != null && dto.TypeId == 1, p => p.IdentityType == EIdentityType.Citizen)
  192. .WhereIF(dto.TypeId != null && dto.TypeId == 2, p => p.IdentityType == EIdentityType.Enterprise)
  193. .Select(p => new
  194. {
  195. AreaCode = p.AreaCode.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6")),
  196. Hour = p.CreationTime.Hour.ToString()
  197. })
  198. .MergeTable();
  199. var listOrg = Db.Queryable<SystemArea>()
  200. .LeftJoin(listOrder, (s, p) => s.Id == p.AreaCode)
  201. .Where((s, p) => s.Id.Length == 6 && s.Id != "510000")
  202. .GroupBy((s, p) => s.Id).GroupBy((s, p) => s.AreaName)
  203. .GroupBy((s, p) => p.Hour)
  204. .OrderBy((s, p) => s.Id)
  205. .Select((s, p) => new
  206. {
  207. count = SqlFunc.AggregateSum(SqlFunc.IIF(p.AreaCode != null && p.AreaCode != "", 1, 0)),
  208. AreaCode = s.Id,
  209. Hour = SqlFunc.IIF(p.Hour == null || p.Hour == "", "0", p.Hour),
  210. AreaName = s.AreaName
  211. })
  212. .MergeTable();
  213. var list = await listHour.LeftJoin(listOrg, (x, p) => x.ColumnName.ToString() == p.Hour)
  214. .OrderBy(x => x.ColumnName)
  215. .Select((x, p) => new
  216. {
  217. Hour = x.ColumnName.ToString() + ":00 - " + x.ColumnName.ToString() + ":59",
  218. p.AreaCode,
  219. p.count
  220. })
  221. .ToPivotListAsync(p => p.AreaCode, p => p.Hour, p => p.Sum(x => x.count));
  222. return list;
  223. }
  224. /// <summary>
  225. /// 区域分时统计--导出
  226. /// </summary>
  227. /// <param name="dto"></param>
  228. /// <returns></returns>
  229. public async Task<DataTable> OrderAreaTimeExport(TimeSharingPagedKeywordRequest dto)
  230. {
  231. List<int> dts = new();
  232. for (int i = 0; i < 24; i++)
  233. {
  234. dts.Add(i);
  235. }
  236. var listHour = Db.Reportable(dts).ToQueryable<int>();
  237. var listOrder = Db.Queryable<Order>()
  238. .Where(p => p.CreationTime >= dto.StartTime && p.CreationTime <= dto.EndTime)
  239. .WhereIF(dto.TypeId != null && dto.TypeId == 1, p => p.IdentityType == EIdentityType.Citizen)
  240. .WhereIF(dto.TypeId != null && dto.TypeId == 2, p => p.IdentityType == EIdentityType.Enterprise)
  241. .Select(p => new
  242. {
  243. AreaCode = p.AreaCode.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6")),
  244. Hour = p.CreationTime.Hour.ToString()
  245. })
  246. .MergeTable();
  247. var listOrg = Db.Queryable<SystemArea>()
  248. .LeftJoin(listOrder, (s, p) => s.Id == p.AreaCode)
  249. .Where((s, p) => s.Id.Length == 6 && s.Id != "510000")
  250. .GroupBy((s, p) => s.Id).GroupBy((s, p) => s.AreaName)
  251. .GroupBy((s, p) => p.Hour)
  252. .OrderBy((s, p) => s.Id)
  253. .Select((s, p) => new
  254. {
  255. count = SqlFunc.AggregateSum(SqlFunc.IIF(p.AreaCode != null && p.AreaCode != "", 1, 0)),
  256. AreaCode = s.Id,
  257. Hour = SqlFunc.IIF(p.Hour == null || p.Hour == "", "0", p.Hour),
  258. AreaName = s.AreaName
  259. })
  260. .MergeTable();
  261. var dt = await listHour.LeftJoin(listOrg, (x, p) => x.ColumnName.ToString() == p.Hour)
  262. .OrderBy(x => x.ColumnName)
  263. .Select((x, p) => new
  264. {
  265. Hour = x.ColumnName.ToString() + ":00 - " + x.ColumnName.ToString() + ":59",
  266. p.AreaName,
  267. p.count
  268. })
  269. .ToPivotTableAsync(p => p.AreaName, p => p.Hour, p => p.Sum(x => x.count));
  270. return InitDatatTable(dt, dto.AddColumnName);
  271. }
  272. /// <summary>
  273. /// 热点类型分时统计
  274. /// </summary>
  275. /// <param name="dto"></param>
  276. /// <returns></returns>
  277. public async Task<object> OrderHotspotTime(TimeSharingPagedKeywordRequest dto)
  278. {
  279. List<int> dts = new List<int>();
  280. for (int i = 0; i < 24; i++)
  281. {
  282. dts.Add(i);
  283. }
  284. var listHour = Db.Reportable(dts).ToQueryable<int>();
  285. var listOrder = Db.Queryable<Order>()
  286. .Where(p => p.CreationTime >= dto.StartTime && p.CreationTime <= dto.EndTime)
  287. .WhereIF(dto.TypeId != null && dto.TypeId == 1, p => p.IdentityType == EIdentityType.Citizen)
  288. .WhereIF(dto.TypeId != null && dto.TypeId == 2, p => p.IdentityType == EIdentityType.Enterprise)
  289. .Select(p => new
  290. {
  291. HotspotCode = p.HotspotId.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("2")),
  292. Hour = p.CreationTime.Hour.ToString()
  293. })
  294. .MergeTable();
  295. var listOrg = Db.Queryable<Hotspot>()
  296. .LeftJoin(listOrder, (s, p) => s.Id == p.HotspotCode)
  297. .Where((s, p) => s.Id.Length == 2 && (s.ParentId == null || s.ParentId == ""))
  298. .GroupBy((s, p) => s.Id).GroupBy((s, p) => s.HotSpotName)
  299. .GroupBy((s, p) => p.Hour)
  300. .OrderBy((s, p) => s.Id)
  301. .Select((s, p) => new
  302. {
  303. count = SqlFunc.AggregateSum(SqlFunc.IIF(p.HotspotCode != null && p.HotspotCode != "", 1, 0)),
  304. HotspotCode = s.Id,
  305. Hour = SqlFunc.IIF(p.Hour == null || p.Hour == "", "0", p.Hour),
  306. HotSpotName = s.HotSpotName
  307. })
  308. .MergeTable();
  309. var list = await listHour.LeftJoin(listOrg, (x, p) => x.ColumnName.ToString() == p.Hour)
  310. .OrderBy(x => x.ColumnName)
  311. .Select((x, p) => new
  312. {
  313. Hour = x.ColumnName.ToString() + ":00 - " + x.ColumnName.ToString() + ":59",
  314. p.HotspotCode,
  315. p.count
  316. })
  317. .ToPivotListAsync(p => p.HotspotCode, p => p.Hour, p => p.Sum(x => x.count));
  318. return list;
  319. }
  320. /// <summary>
  321. /// 热点类型分时统计---导出
  322. /// </summary>
  323. /// <param name="dto"></param>
  324. /// <returns></returns>
  325. public async Task<DataTable> OrderHotspotTimeExport(TimeSharingPagedKeywordRequest dto)
  326. {
  327. List<int> dts = new();
  328. for (int i = 0; i < 24; i++)
  329. {
  330. dts.Add(i);
  331. }
  332. var listHour = Db.Reportable(dts).ToQueryable<int>();
  333. var listOrder = Db.Queryable<Order>()
  334. .Where(p => p.CreationTime >= dto.StartTime && p.CreationTime <= dto.EndTime)
  335. .WhereIF(dto.TypeId != null && dto.TypeId == 1, p => p.IdentityType == EIdentityType.Citizen)
  336. .WhereIF(dto.TypeId != null && dto.TypeId == 2, p => p.IdentityType == EIdentityType.Enterprise)
  337. .Select(p => new
  338. {
  339. HotspotCode = p.HotspotId.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("2")),
  340. Hour = p.CreationTime.Hour.ToString()
  341. })
  342. .MergeTable();
  343. var listOrg = Db.Queryable<Hotspot>()
  344. .LeftJoin(listOrder, (s, p) => s.Id == p.HotspotCode)
  345. .Where((s, p) => s.Id.Length == 2 && (s.ParentId == null || s.ParentId == ""))
  346. .GroupBy((s, p) => s.Id).GroupBy((s, p) => s.HotSpotName)
  347. .GroupBy((s, p) => p.Hour)
  348. .OrderBy((s, p) => s.Id)
  349. .Select((s, p) => new
  350. {
  351. count = SqlFunc.AggregateSum(SqlFunc.IIF(p.HotspotCode != null && p.HotspotCode != "", 1, 0)),
  352. HotspotCode = s.Id,
  353. Hour = SqlFunc.IIF(p.Hour == null || p.Hour == "", "0", p.Hour),
  354. HotSpotName = s.HotSpotName
  355. })
  356. .MergeTable();
  357. var dt = await listHour.LeftJoin(listOrg, (x, p) => x.ColumnName.ToString() == p.Hour)
  358. .OrderBy(x => x.ColumnName)
  359. .Select((x, p) => new
  360. {
  361. Hour = x.ColumnName.ToString() + ":00 - " + x.ColumnName.ToString() + ":59",
  362. p.HotSpotName,
  363. p.count
  364. })
  365. .ToPivotTableAsync(p => p.HotSpotName, p => p.Hour, p => p.Sum(x => x.count));
  366. return InitDatatTable(dt, dto.AddColumnName);
  367. }
  368. /// <summary>
  369. /// 受理类型分时统计
  370. /// </summary>
  371. /// <param name="dto"></param>
  372. /// <returns></returns>
  373. public async Task<object> OrderAcceptanceTime(TimeSharingPagedKeywordRequest dto)
  374. {
  375. List<int> dts = new List<int>();
  376. for (int i = 0; i < 24; i++)
  377. {
  378. dts.Add(i);
  379. }
  380. var listHour = Db.Reportable(dts).ToQueryable<int>();
  381. var listOrder = Db.Queryable<Order>()
  382. .Where(p => p.CreationTime >= dto.StartTime && p.CreationTime <= dto.EndTime)
  383. .WhereIF(dto.TypeId != null && dto.TypeId == 1, p => p.IdentityType == EIdentityType.Citizen)
  384. .WhereIF(dto.TypeId != null && dto.TypeId == 2, p => p.IdentityType == EIdentityType.Enterprise)
  385. .Select(p => new
  386. {
  387. AcceptTypeCode = p.AcceptTypeCode,
  388. Hour = p.CreationTime.Hour.ToString()
  389. })
  390. .MergeTable();
  391. var listOrg = Db.Queryable<SystemDicData>()
  392. .LeftJoin(listOrder, (s, p) => s.DicDataValue == p.AcceptTypeCode)
  393. .Where((s, p) => s.DicTypeCode == "AcceptType")
  394. .GroupBy((s, p) => s.DicDataValue).GroupBy((s, p) => s.DicDataName)
  395. .GroupBy((s, p) => p.Hour)
  396. .OrderBy((s, p) => s.DicDataValue)
  397. .Select((s, p) => new
  398. {
  399. count = SqlFunc.AggregateSum(SqlFunc.IIF(p.AcceptTypeCode != null && p.AcceptTypeCode != "", 1, 0)),
  400. DicDataValue = s.DicDataValue,
  401. Hour = SqlFunc.IIF(p.Hour == null || p.Hour == "", "0", p.Hour),
  402. DicDataName = s.DicDataName
  403. })
  404. .MergeTable();
  405. var list = await listHour.LeftJoin(listOrg, (x, p) => x.ColumnName.ToString() == p.Hour)
  406. .OrderBy(x => x.ColumnName)
  407. .Select((x, p) => new
  408. {
  409. Hour = x.ColumnName.ToString() + ":00 - " + x.ColumnName.ToString() + ":59",
  410. p.DicDataValue,
  411. p.count
  412. })
  413. .ToPivotListAsync(p => p.DicDataValue, p => p.Hour, p => p.Sum(x => x.count));
  414. return list;
  415. }
  416. /// <summary>
  417. /// 受理类型分时统计---导出
  418. /// </summary>
  419. /// <param name="dto"></param>
  420. /// <returns></returns>
  421. public async Task<DataTable> OrderAcceptanceTimeExport(TimeSharingPagedKeywordRequest dto)
  422. {
  423. List<int> dts = new();
  424. for (int i = 0; i < 24; i++)
  425. {
  426. dts.Add(i);
  427. }
  428. var listHour = Db.Reportable(dts).ToQueryable<int>();
  429. var listOrder = Db.Queryable<Order>()
  430. .Where(p => p.CreationTime >= dto.StartTime && p.CreationTime <= dto.EndTime)
  431. .WhereIF(dto.TypeId != null && dto.TypeId == 1, p => p.IdentityType == EIdentityType.Citizen)
  432. .WhereIF(dto.TypeId != null && dto.TypeId == 2, p => p.IdentityType == EIdentityType.Enterprise)
  433. .Select(p => new
  434. {
  435. AcceptTypeCode = p.AcceptTypeCode,
  436. Hour = p.CreationTime.Hour.ToString()
  437. })
  438. .MergeTable();
  439. var listOrg = Db.Queryable<SystemDicData>()
  440. .LeftJoin(listOrder, (s, p) => s.DicDataValue == p.AcceptTypeCode)
  441. .Where((s, p) => s.DicTypeCode == "AcceptType")
  442. .GroupBy((s, p) => s.DicDataValue).GroupBy((s, p) => s.DicDataName)
  443. .GroupBy((s, p) => p.Hour)
  444. .OrderBy((s, p) => s.DicDataValue)
  445. .Select((s, p) => new
  446. {
  447. count = SqlFunc.AggregateSum(SqlFunc.IIF(p.AcceptTypeCode != null && p.AcceptTypeCode != "", 1, 0)),
  448. DicDataValue = s.DicDataValue,
  449. Hour = SqlFunc.IIF(p.Hour == null || p.Hour == "", "0", p.Hour),
  450. DicDataName = s.DicDataName
  451. })
  452. .MergeTable();
  453. var dt = await listHour.LeftJoin(listOrg, (x, p) => x.ColumnName.ToString() == p.Hour)
  454. .OrderBy(x => x.ColumnName)
  455. .Select((x, p) => new
  456. {
  457. Hour = x.ColumnName.ToString() + ":00 - " + x.ColumnName.ToString() + ":59",
  458. p.DicDataName,
  459. p.count
  460. })
  461. .ToPivotTableAsync(p => p.DicDataName, p => p.Hour, p => p.Sum(x => x.count));
  462. return InitDatatTable(dt, dto.AddColumnName);
  463. }
  464. /// <summary>
  465. /// 信件来源分时统计
  466. /// </summary>
  467. /// <param name="dto"></param>
  468. /// <returns></returns>
  469. public async Task<object> OrderSourceTime(TimeSharingPagedKeywordRequest dto)
  470. {
  471. List<int> dts = new List<int>();
  472. for (int i = 0; i < 24; i++)
  473. {
  474. dts.Add(i);
  475. }
  476. var listHour = Db.Reportable(dts).ToQueryable<int>();
  477. var listOrder = Db.Queryable<Order>()
  478. .Where(p => p.CreationTime >= dto.StartTime && p.CreationTime <= dto.EndTime)
  479. .WhereIF(dto.TypeId != null && dto.TypeId == 1, p => p.IdentityType == EIdentityType.Citizen)
  480. .WhereIF(dto.TypeId != null && dto.TypeId == 2, p => p.IdentityType == EIdentityType.Enterprise)
  481. .Select(p => new
  482. {
  483. SourceChannelCode = p.SourceChannelCode,
  484. Hour = p.CreationTime.Hour.ToString()
  485. })
  486. .MergeTable();
  487. var listOrg = Db.Queryable<SystemDicData>()
  488. .LeftJoin(listOrder, (s, p) => s.DicDataValue == p.SourceChannelCode)
  489. .Where((s, p) => s.DicTypeCode == "SourceChannel")
  490. .GroupBy((s, p) => new
  491. {
  492. DicDataValue = s.DicDataValue,
  493. DicDataName = s.DicDataName,
  494. Hour = p.Hour,
  495. })
  496. .OrderBy((s, p) => s.DicDataValue)
  497. .Select((s, p) => new
  498. {
  499. Count = SqlFunc.AggregateSum(SqlFunc.IIF(p.SourceChannelCode != null && p.SourceChannelCode != "", 1, 0)),
  500. DicDataValue = s.DicDataValue,
  501. Hour = SqlFunc.IIF(p.Hour == null || p.Hour == "", "0", p.Hour),
  502. DicDataName = s.DicDataName
  503. })
  504. .MergeTable();
  505. var list = await listHour.LeftJoin(listOrg, (x, p) => x.ColumnName.ToString() == p.Hour)
  506. .OrderBy(x => x.ColumnName)
  507. .Select((x, p) => new
  508. {
  509. Hour = x.ColumnName.ToString() + ":00 - " + x.ColumnName.ToString() + ":59",
  510. p.DicDataValue,
  511. p.Count
  512. })
  513. .ToPivotListAsync(p => p.DicDataValue, p => p.Hour, p => p.Sum(x => x.Count));
  514. return list;
  515. }
  516. /// <summary>
  517. /// 信件来源分时统计---导出
  518. /// </summary>
  519. /// <param name="dto"></param>
  520. /// <returns></returns>
  521. public async Task<DataTable> OrderSourceTimeExport(TimeSharingPagedKeywordRequest dto)
  522. {
  523. List<int> dts = new();
  524. for (int i = 0; i < 24; i++)
  525. {
  526. dts.Add(i);
  527. }
  528. var listHour = Db.Reportable(dts).ToQueryable<int>();
  529. var listOrder = Db.Queryable<Order>()
  530. .Where(p => p.CreationTime >= dto.StartTime && p.CreationTime <= dto.EndTime)
  531. .WhereIF(dto.TypeId != null && dto.TypeId == 1, p => p.IdentityType == EIdentityType.Citizen)
  532. .WhereIF(dto.TypeId != null && dto.TypeId == 2, p => p.IdentityType == EIdentityType.Enterprise)
  533. .Select(p => new
  534. {
  535. SourceChannelCode = p.SourceChannelCode,
  536. Hour = p.CreationTime.Hour.ToString()
  537. })
  538. .MergeTable();
  539. var listOrg = Db.Queryable<SystemDicData>()
  540. .LeftJoin(listOrder, (s, p) => s.DicDataValue == p.SourceChannelCode)
  541. .Where((s, p) => s.DicTypeCode == "SourceChannel")
  542. .GroupBy((s, p) => s.DicDataValue).GroupBy((s, p) => s.DicDataName)
  543. .GroupBy((s, p) => p.Hour)
  544. .OrderBy((s, p) => s.DicDataValue)
  545. .Select((s, p) => new
  546. {
  547. count = SqlFunc.AggregateSum(SqlFunc.IIF(p.SourceChannelCode != null && p.SourceChannelCode != "", 1, 0)),
  548. DicDataValue = s.DicDataValue,
  549. Hour = SqlFunc.IIF(p.Hour == null || p.Hour == "", "0", p.Hour),
  550. DicDataName = s.DicDataName
  551. })
  552. .MergeTable();
  553. var dt = await listHour.LeftJoin(listOrg, (x, p) => x.ColumnName.ToString() == p.Hour)
  554. .OrderBy(x => x.ColumnName)
  555. .Select((x, p) => new
  556. {
  557. Hour = x.ColumnName.ToString() + ":00 - " + x.ColumnName.ToString() + ":59",
  558. p.DicDataName,
  559. p.count
  560. })
  561. .ToPivotTableAsync(p => p.DicDataName, p => p.Hour, p => p.Sum(x => x.count));
  562. return InitDatatTable(dt, dto.AddColumnName);
  563. }
  564. /// <summary>
  565. /// 信件来源统计
  566. /// </summary>
  567. /// <param name="dto"></param>
  568. /// <returns></returns>
  569. public async Task<object> OrderSource(QueryOrderSourceRequest dto)
  570. {
  571. var listOrder = Db.Queryable<Order>()
  572. .Where(p => p.CreationTime >= dto.StartTime && p.CreationTime <= dto.EndTime)
  573. .WhereIF(dto.TypeId != null && dto.TypeId == 1, p => p.IdentityType == EIdentityType.Citizen)
  574. .WhereIF(dto.TypeId != null && dto.TypeId == 2, p => p.IdentityType == EIdentityType.Enterprise)
  575. .Select(p => new
  576. {
  577. SourceChannelCode = p.SourceChannelCode,
  578. Hour = p.CreationTime.ToString("yyyy-MM-dd")
  579. })
  580. .MergeTable();
  581. var listOrg = await Db.Queryable<SystemDicData>()
  582. .LeftJoin(listOrder, (s, p) => s.DicDataValue == p.SourceChannelCode)
  583. .Where((s, p) => s.DicTypeCode == "SourceChannel")
  584. .GroupBy((s, p) => s.DicDataValue).GroupBy((s, p) => s.DicDataName)
  585. .GroupBy((s, p) => p.Hour)
  586. .OrderBy((s, p) => p.Hour)
  587. .Select((s, p) => new
  588. {
  589. Hour = SqlFunc.IIF(p.Hour == null || p.Hour == "", "0", p.Hour),
  590. count = SqlFunc.AggregateSum(SqlFunc.IIF(p.SourceChannelCode != null && p.SourceChannelCode != "", 1, 0)),
  591. DicDataValue = s.DicDataValue,
  592. DicDataName = s.DicDataName
  593. })
  594. .ToPivotListAsync(p => p.DicDataValue, p => p.Hour, p => p.Sum(x => x.count));
  595. return listOrg;
  596. }
  597. /// <summary>
  598. /// 信件来源统计---导出
  599. /// </summary>
  600. /// <param name="dto"></param>
  601. /// <returns></returns>
  602. public async Task<DataTable> OrderSourceExport(QueryOrderSourceRequest dto)
  603. {
  604. var listOrder = Db.Queryable<Order>()
  605. .Where(p => p.CreationTime >= dto.StartTime && p.CreationTime <= dto.EndTime)
  606. .WhereIF(dto.TypeId != null && dto.TypeId == 1, p => p.IdentityType == EIdentityType.Citizen)
  607. .WhereIF(dto.TypeId != null && dto.TypeId == 2, p => p.IdentityType == EIdentityType.Enterprise)
  608. .Select(p => new
  609. {
  610. SourceChannelCode = p.SourceChannelCode,
  611. Hour = p.CreationTime.ToString("yyyy-MM-dd")
  612. })
  613. .MergeTable();
  614. var listOrg = await Db.Queryable<SystemDicData>()
  615. .LeftJoin(listOrder, (s, p) => s.DicDataValue == p.SourceChannelCode)
  616. .Where((s, p) => s.DicTypeCode == "SourceChannel")
  617. .GroupBy((s, p) => s.DicDataValue).GroupBy((s, p) => s.DicDataName)
  618. .GroupBy((s, p) => p.Hour)
  619. .OrderBy((s, p) => p.Hour)
  620. .Select((s, p) => new
  621. {
  622. Hour = SqlFunc.IIF(p.Hour == null || p.Hour == "", "0", p.Hour),
  623. count = SqlFunc.AggregateSum(SqlFunc.IIF(p.SourceChannelCode != null && p.SourceChannelCode != "", 1, 0)),
  624. DicDataValue = s.DicDataValue,
  625. DicDataName = s.DicDataName
  626. })
  627. .ToPivotTableAsync(p => p.DicDataName, p => p.Hour, p => p.Sum(x => x.count));
  628. listOrg.Columns["Hour"].ColumnName = "日期";
  629. if (listOrg.Rows[0][listOrg.Rows.Count - 1] == "0")
  630. listOrg.Rows[listOrg.Rows.Count - 1].Delete();
  631. return InitDatatTable(listOrg, dto.AddColumnName);
  632. }
  633. /// <summary>
  634. /// 处理导出数据
  635. /// </summary>
  636. /// <param name="dt"></param>
  637. /// <param name="AddColumnName"></param>
  638. /// <returns></returns>
  639. public DataTable InitDatatTable(DataTable dt, List<string> AddColumnName)
  640. {
  641. //修改列名
  642. if (dt.Columns.Contains("Hour"))
  643. dt.Columns["Hour"].ColumnName = "时间段";
  644. //增加小计
  645. DataColumn totalColumn = new DataColumn("小计", typeof(decimal));
  646. dt.Columns.Add(totalColumn);
  647. if (dt.Columns.Contains("Column1"))
  648. dt.Columns.Remove("Column1");
  649. //计算小计
  650. for (int i = 0; i < dt.Rows.Count; i++)
  651. {
  652. int sumcount = 0;
  653. for (int j = 1; j < dt.Columns.Count - 1; j++)
  654. {
  655. sumcount += Convert.ToInt32(dt.Rows[i][j].ToString());
  656. }
  657. dt.Rows[i][dt.Columns.Count - 1] = sumcount;
  658. }
  659. //增加合计
  660. DataRow totalRow = dt.NewRow();
  661. if (dt.Columns[0].ColumnName == "日期") totalRow["日期"] = "合计";
  662. else totalRow["时间段"] = "合计";
  663. for (int i = 1; i < dt.Columns.Count; i++)
  664. {
  665. int sumcount = 0;
  666. for (int j = 0; j < dt.Rows.Count; j++)
  667. {
  668. sumcount += Convert.ToInt32(dt.Rows[j][i].ToString());
  669. }
  670. totalRow[i] = sumcount;
  671. }
  672. dt.Rows.Add(totalRow);
  673. //创建新表
  674. DataTable dt2 = new DataTable();
  675. //添加表头
  676. foreach (var item in AddColumnName)
  677. {
  678. if (dt.Columns.Contains(item))
  679. dt2.Columns.Add(item);
  680. }
  681. //处理数据
  682. foreach (DataRow sourceRow in dt.Rows)
  683. {
  684. DataRow targetRow = dt2.NewRow();
  685. foreach (var item in AddColumnName)
  686. {
  687. targetRow[item] = sourceRow[item];
  688. }
  689. dt2.Rows.Add(targetRow);
  690. }
  691. return dt2;
  692. }
  693. /// <summary>
  694. /// 热点区域明细
  695. /// </summary>
  696. /// <param name="dto"></param>
  697. /// <returns></returns>
  698. public ISugarQueryable<HotspotAndAreaStatisticsDetailDto> HotspotAndAreaStatisticsDetail(HotspotAndAreaStatisticsDetailReq dto)
  699. {
  700. var query = Db.Queryable<Order>()
  701. //.Includes(x => x.OrderScreens.OrderByDescending(x => x.CreationTime).FirstOrDefault())
  702. .Where(x => x.HotspotId.StartsWith(dto.HotspotId) && x.CreationTime >= dto.StartTime && x.CreationTime < dto.EndTime)
  703. .WhereIF(!string.IsNullOrEmpty(dto.AreaCode), x => x.AreaCode.StartsWith(dto.AreaCode))
  704. .Select(x => new HotspotAndAreaStatisticsDetailDto
  705. {
  706. Id = x.Id,
  707. Status = x.Status,
  708. SourceChannel = x.SourceChannel,
  709. ActualHandleStepName = x.ActualHandleStepName,
  710. ReTransactNum = x.ReTransactNum,
  711. IsUrgent = x.IsUrgent,
  712. OrderScreenStatus = SqlFunc.Subqueryable<OrderScreen>().Where(d => d.OrderId == x.Id).OrderByDesc(d => d.CreationTime).Select(d => d.Status),
  713. No = x.No,
  714. CreationTime = x.CreationTime,
  715. Title = x.Title,
  716. ExpiredTime = x.ExpiredTime,
  717. ActualHandleOrgName = x.ActualHandleOrgName,
  718. FiledTime = x.FiledTime,
  719. ActualHandleTime = x.ActualHandleTime,
  720. AcceptType = x.AcceptType,
  721. HotspotName = x.HotspotName,
  722. AcceptorName = x.AcceptorName,
  723. NearlyExpiredTime = x.NearlyExpiredTime,
  724. NearlyExpiredTimeOne = x.NearlyExpiredTimeOne
  725. }).OrderByDescending(x => x.CreationTime);
  726. return query;
  727. }
  728. /// <summary>
  729. /// 受理类型明细
  730. /// </summary>
  731. /// <param name="dto"></param>
  732. /// <returns></returns>
  733. public ISugarQueryable<HotspotAndAreaStatisticsDetailDto> AcceptTypeStatisticsByDateDetail(AcceptTypeStatisticsByDateDetailReq dto)
  734. {
  735. string Date = dto.Date.ToString("yyyy-MM-dd");
  736. var query = Db.Queryable<Order>()
  737. //.Includes(x => x.OrderScreens.OrderByDescending(x => x.CreationTime).FirstOrDefault())
  738. .Where(x => x.AcceptTypeCode == dto.AcceptTypeCode && x.CreationTime.ToString("yyyy-MM-dd") == Date)
  739. .WhereIF(!string.IsNullOrEmpty(dto.No), x => x.No == dto.No)
  740. .WhereIF(!string.IsNullOrEmpty(dto.Title), x => x.Title.Contains(dto.Title))
  741. .WhereIF(!string.IsNullOrEmpty(dto.ActualHandleOrgName), x => x.ActualHandleOrgName.Contains(dto.ActualHandleOrgName))
  742. .Select(x => new HotspotAndAreaStatisticsDetailDto
  743. {
  744. Id = x.Id,
  745. Status = x.Status,
  746. SourceChannel = x.SourceChannel,
  747. ActualHandleStepName = x.ActualHandleStepName,
  748. ReTransactNum = x.ReTransactNum,
  749. IsUrgent = x.IsUrgent,
  750. OrderScreenStatus = SqlFunc.Subqueryable<OrderScreen>().Where(d => d.OrderId == x.Id).OrderByDesc(d => d.CreationTime).Select(d => d.Status),
  751. No = x.No,
  752. CreationTime = x.CreationTime,
  753. Title = x.Title,
  754. ExpiredTime = x.ExpiredTime,
  755. ActualHandleOrgName = x.ActualHandleOrgName,
  756. FiledTime = x.FiledTime,
  757. ActualHandleTime = x.ActualHandleTime,
  758. AcceptType = x.AcceptType,
  759. HotspotName = x.HotspotName,
  760. AcceptorName = x.AcceptorName,
  761. NearlyExpiredTime = x.NearlyExpiredTime,
  762. NearlyExpiredTimeOne = x.NearlyExpiredTimeOne
  763. }).OrderByDescending(x => x.CreationTime);
  764. return query;
  765. }
  766. /// <summary>
  767. /// 根据时间查询受理类型统计
  768. /// </summary>
  769. /// <param name="dto"></param>
  770. /// <returns></returns>
  771. public async Task<(List<SystemDicData> acceptType, object items)> AcceptTypeStatisticsByDate(AcceptTypeStatisticsByDateReq dto)
  772. {
  773. //处理时间
  774. var diffDays = (dto.EndTime - dto.StartTime).Days;
  775. List<string> dateList = new List<string>();
  776. for (int i = 0; i <= diffDays; i++)
  777. {
  778. dateList.Add(dto.StartTime.AddDays(i).ToString("yyyy-MM-dd"));
  779. }
  780. //第一列
  781. var dateQuery = Db.Reportable(dateList).ToQueryable<string>().MergeTable();
  782. //表头
  783. var acceptTypeList = Db.Queryable<SystemDicData>().Where(x => x.DicTypeCode == SysDicTypeConsts.AcceptType).MergeTable();
  784. //工单
  785. var orderList = Db.Queryable<Order>()
  786. .Where(x => x.CreationTime >= dto.StartTime && x.CreationTime < dto.EndTime)
  787. .WhereIF(dto.TypeId != null && dto.TypeId == 1, x => x.IdentityType == EIdentityType.Citizen)
  788. .WhereIF(dto.TypeId != null && dto.TypeId == 2, x => x.IdentityType == EIdentityType.Enterprise)
  789. .WhereIF(!string.IsNullOrEmpty(dto.Gateway), x => x.TransferPhone == dto.Gateway)
  790. .Select(x => new
  791. {
  792. Date = x.CreationTime.ToString("yyyy-MM-dd"),
  793. AcceptTypeCode = x.AcceptTypeCode,
  794. })
  795. .MergeTable();
  796. //时间关联工单
  797. var dateAndOrderList = dateQuery.LeftJoin(orderList, (it, o) => it.ColumnName == o.Date)
  798. .Where((it, o) => string.IsNullOrEmpty(o.AcceptTypeCode) == false)
  799. .GroupBy((it, o) => new
  800. {
  801. it.ColumnName,
  802. o.AcceptTypeCode,
  803. })
  804. .Select((it, o) => new
  805. {
  806. Date = it.ColumnName,
  807. AcceptTypeCode = o.AcceptTypeCode,
  808. Count = SqlFunc.AggregateCount(o.AcceptTypeCode)
  809. }).MergeTable();
  810. //类型关联工单
  811. var returnList = await acceptTypeList.LeftJoin(dateAndOrderList, (it, o) => it.DicDataValue == o.AcceptTypeCode)
  812. .Where((it, o) => o.Date != null)
  813. .GroupBy((it, o) => new
  814. {
  815. o.Date,
  816. it.DicDataValue,
  817. })
  818. .OrderBy((it, o) => o.Date)
  819. .Select((it, o) => new
  820. {
  821. Date = o.Date,
  822. AcceptTypeCode = it.DicDataValue,
  823. Count = SqlFunc.AggregateSum(o.Count)
  824. })
  825. .ToPivotListAsync(q => q.AcceptTypeCode, q => new { q.Date }, q => q.Sum(x => x.Count));
  826. //表头
  827. var acceptTypeTitleList = await Db.Queryable<SystemDicData>().Where(x => x.DicTypeCode == SysDicTypeConsts.AcceptType).ToListAsync();
  828. return (acceptTypeTitleList, returnList);
  829. }
  830. /// <summary>
  831. /// 根据时间查询受理类型统计-导出
  832. /// </summary>
  833. /// <param name="dto"></param>
  834. /// <returns></returns>
  835. public async Task<DataTable> AcceptTypeStatisticsByDateExport(AcceptTypeStatisticsByDateReq dto)
  836. {
  837. //处理时间
  838. var diffDays = (dto.EndTime - dto.StartTime).Days;
  839. List<string> dateList = new List<string>();
  840. for (int i = 0; i <= diffDays; i++)
  841. {
  842. dateList.Add(dto.StartTime.AddDays(i).ToString("yyyy-MM-dd"));
  843. }
  844. //第一列
  845. var dateQuery = Db.Reportable(dateList).ToQueryable<string>().MergeTable();
  846. //表头
  847. var acceptTypeList = Db.Queryable<SystemDicData>().Where(x => x.DicTypeCode == SysDicTypeConsts.AcceptType).MergeTable();
  848. //工单
  849. var orderList = Db.Queryable<Order>()
  850. .Where(x => x.CreationTime >= dto.StartTime && x.CreationTime < dto.EndTime)
  851. .WhereIF(dto.TypeId != null && dto.TypeId == 1, x => x.IdentityType == EIdentityType.Citizen)
  852. .WhereIF(dto.TypeId != null && dto.TypeId == 2, x => x.IdentityType == EIdentityType.Enterprise)
  853. .WhereIF(!string.IsNullOrEmpty(dto.Gateway), x => x.TransferPhone == dto.Gateway)
  854. .Select(x => new
  855. {
  856. Date = x.CreationTime.ToString("yyyy-MM-dd"),
  857. AcceptTypeCode = x.AcceptTypeCode,
  858. })
  859. .MergeTable();
  860. //时间关联工单
  861. var dateAndOrderList = dateQuery.LeftJoin(orderList, (it, o) => it.ColumnName == o.Date)
  862. .Where((it, o) => string.IsNullOrEmpty(o.AcceptTypeCode) == false)
  863. .GroupBy((it, o) => new
  864. {
  865. it.ColumnName,
  866. o.AcceptTypeCode,
  867. })
  868. .Select((it, o) => new
  869. {
  870. Date = it.ColumnName,
  871. AcceptTypeCode = o.AcceptTypeCode,
  872. Count = SqlFunc.AggregateCount(o.AcceptTypeCode)
  873. }).MergeTable();
  874. //类型关联工单
  875. var returnList = await acceptTypeList.LeftJoin(dateAndOrderList, (it, o) => it.DicDataValue == o.AcceptTypeCode)
  876. .Where((it, o) => o.Date != null)
  877. .GroupBy((it, o) => new
  878. {
  879. o.Date,
  880. it.DicDataValue,
  881. it.DicDataName
  882. })
  883. .OrderBy((it, o) => o.Date)
  884. .Select((it, o) => new
  885. {
  886. Date = o.Date,
  887. AcceptTypeCode = it.DicDataValue,
  888. AcceptType = it.DicDataName,
  889. Count = SqlFunc.AggregateSum(o.Count)
  890. })
  891. .ToPivotTableAsync(q => q.AcceptType, q => new { q.Date }, q => q.Sum(x => x.Count));
  892. return returnList;
  893. }
  894. public DataTable InitAcceptTypeTable(DataTable dt, List<string> AddColumnName)
  895. {
  896. //修改列名
  897. if (dt.Columns.Contains("Date"))
  898. dt.Columns["Date"].ColumnName = "日期";
  899. //增加小计
  900. DataColumn totalColumn = new DataColumn("小计", typeof(decimal));
  901. dt.Columns.Add(totalColumn);
  902. if (dt.Columns.Contains("Column1"))
  903. dt.Columns.Remove("Column1");
  904. //计算小计
  905. for (int i = 0; i < dt.Rows.Count; i++)
  906. {
  907. int sumcount = 0;
  908. for (int j = 1; j < dt.Columns.Count - 1; j++)
  909. {
  910. sumcount += Convert.ToInt32(dt.Rows[i][j].ToString());
  911. }
  912. dt.Rows[i][dt.Columns.Count - 1] = sumcount;
  913. }
  914. //增加合计
  915. DataRow totalRow = dt.NewRow();
  916. if (dt.Columns[0].ColumnName == "Date") totalRow["Date"] = "合计";
  917. else totalRow["日期"] = "合计";
  918. for (int i = 1; i < dt.Columns.Count; i++)
  919. {
  920. int sumcount = 0;
  921. for (int j = 0; j < dt.Rows.Count; j++)
  922. {
  923. sumcount += Convert.ToInt32(dt.Rows[j][i].ToString());
  924. }
  925. totalRow[i] = sumcount;
  926. }
  927. dt.Rows.Add(totalRow);
  928. //创建新表
  929. DataTable dt2 = new DataTable();
  930. //添加表头
  931. foreach (var item in AddColumnName)
  932. {
  933. dt2.Columns.Add(item);
  934. }
  935. //处理数据
  936. foreach (DataRow sourceRow in dt.Rows)
  937. {
  938. DataRow targetRow = dt2.NewRow();
  939. foreach (var item in AddColumnName)
  940. {
  941. try
  942. {
  943. targetRow[item] = sourceRow[item];
  944. }
  945. catch
  946. {
  947. targetRow[item] = 0;
  948. }
  949. }
  950. dt2.Rows.Add(targetRow);
  951. }
  952. return dt2;
  953. }
  954. /// <summary>
  955. /// 中心受理统计(时间段)
  956. /// </summary>
  957. /// <returns></returns>
  958. public ISugarQueryable<OrderCenterAcceptHourVo> OrderCenterAcceptHour(OrderCenterAcceptPagedRequest dto)
  959. {
  960. if (dto.EndTime.HasValue)
  961. dto.EndTime = dto.EndTime.Value.AddDays(1).AddSeconds(-1);
  962. var sendBack = _orderSendBackAuditRepository.Queryable()
  963. .Where(x => x.State == ESendBackAuditState.End)
  964. .GroupBy(x => x.OrderId).Select(x => new { OrderId = x.OrderId });
  965. List<int> dts = new();
  966. for (int i = 0; i < 24; i++)
  967. {
  968. dts.Add(i);
  969. }
  970. var listHour = Db.Reportable(dts).ToQueryable<int>();
  971. var data = Db.Queryable<Order>()
  972. .LeftJoin(sendBack, (d, s) => d.Id == s.OrderId)
  973. .WhereIF(dto.StartTime.HasValue && dto.EndTime.HasValue, d => d.CreationTime >= dto.StartTime && d.CreationTime <= dto.EndTime)
  974. .WhereIF(dto.TypeCode != null && dto.TypeCode == 1, d => d.IdentityType == EIdentityType.Citizen)
  975. .WhereIF(dto.TypeCode != null && dto.TypeCode == 2, d => d.IdentityType == EIdentityType.Enterprise)
  976. .GroupBy(d => d.CreationTime.Hour.ToString())
  977. .Select((d, s) => new OrderCenterAcceptHourVo
  978. {
  979. Hour = d.CreationTime.Hour.ToString(),
  980. AcceptNum = SqlFunc.AggregateCount(1),
  981. ValidNum = SqlFunc.AggregateSum(SqlFunc.IIF(d.AcceptType != "无效", 1, 0)),
  982. RepetitionNum = SqlFunc.AggregateSum(SqlFunc.IIF(d.DuplicateIds == null || SqlFunc.JsonArrayLength(d.DuplicateIds) > 0, 1, 0)),
  983. InvalidNum = SqlFunc.AggregateSum(SqlFunc.IIF(d.AcceptType == "无效", 1, 0)),
  984. HandleNum = SqlFunc.AggregateSum(SqlFunc.IIF(d.Status >= EOrderStatus.Filed, 1, 0)),
  985. NoHandleNum = SqlFunc.AggregateSum(SqlFunc.IIF(d.Status < EOrderStatus.Filed, 1, 0)),
  986. BackNum = SqlFunc.AggregateSum(SqlFunc.IIF(s.OrderId != null && s.OrderId != "", 1, 0)),
  987. DutyDeskNum = SqlFunc.AggregateDistinctCount(d.AcceptorId)
  988. });
  989. var query = listHour.LeftJoin(data, (h, d) => h.ColumnName.ToString() == d.Hour)
  990. .GroupBy((h,d)=> h.ColumnName)
  991. .OrderBy((h, d) => h.ColumnName)
  992. .Select((h, d) => new OrderCenterAcceptHourVo
  993. {
  994. Hour = h.ColumnName.ToString() + ":00 - " + h.ColumnName.ToString() + ":59",
  995. AcceptNum = SqlFunc.AggregateSum(d.AcceptNum),
  996. ValidNum = SqlFunc.AggregateSum(d.ValidNum),
  997. RepetitionNum = SqlFunc.AggregateSum(d.RepetitionNum),
  998. InvalidNum = SqlFunc.AggregateSum(d.InvalidNum),
  999. HandleNum = SqlFunc.AggregateSum(d.HandleNum),
  1000. NoHandleNum = SqlFunc.AggregateSum(d.NoHandleNum),
  1001. BackNum = SqlFunc.AggregateSum(d.BackNum),
  1002. DutyDeskNum = SqlFunc.AggregateSum(d.DutyDeskNum)
  1003. });
  1004. return query;
  1005. }
  1006. public ISugarQueryable<SelectOrderId> OrderListUnionAll(ISugarQueryable<SelectOrderId> t1, ISugarQueryable<SelectOrderId> t2)
  1007. {
  1008. return Db.UnionAll(t1, t2).Select(it => new SelectOrderId { Id = it.Id }).MergeTable();
  1009. }
  1010. /// <summary>
  1011. /// 数据清单
  1012. /// </summary>
  1013. /// <param name="dto"></param>
  1014. /// <returns></returns>
  1015. public ISugarQueryable<OrderDataInventoryRep> OrderDataInventory(OrderDataInventoryReq dto)
  1016. {
  1017. dto.EndTime = dto.EndTime.AddDays(1).AddSeconds(-1);
  1018. var result = Db.Queryable<Order>()
  1019. //.Includes(x => x.OrderScreens.OrderByDescending(x => x.CreationTime).FirstOrDefault(),it=>it.Status)
  1020. //.Includes(x => x.OrderVisits.Where(x => x.VisitState == EVisitState.Visited).FirstOrDefault(),it=>it.OrderVisitDetails)
  1021. .Where(x => x.CreationTime >= dto.StartTime) //开始时间
  1022. .Where(x => x.CreationTime <= dto.EndTime)//开始时间
  1023. .WhereIF(!string.IsNullOrEmpty(dto.No), x => x.No == dto.No) //工单编号
  1024. .WhereIF(!string.IsNullOrEmpty(dto.Title), x => x.Title.Contains(dto.Title)) //工单标题
  1025. .WhereIF(dto.OrderStatus.HasValue, x => x.Status == dto.OrderStatus) //工单状态
  1026. .WhereIF(!string.IsNullOrEmpty(dto.Channel), x => x.SourceChannelCode == dto.Channel) //来源渠道
  1027. .WhereIF(!string.IsNullOrEmpty(dto.TransferPhone), x => x.TransferPhone == dto.TransferPhone!) //转接号码
  1028. .WhereIF(!string.IsNullOrEmpty(dto.CurrentStepCode), x => x.CurrentStepCode.Contains(dto.CurrentStepCode)) //当前节点
  1029. .WhereIF(dto.ScreenStatus.HasValue, x => x.OrderScreens.Any(x => x.Status == dto.ScreenStatus)) //甄别状态
  1030. .WhereIF(!string.IsNullOrEmpty(dto.ProvinceNo), x => x.ProvinceNo == dto.ProvinceNo)//省工单编号
  1031. .WhereIF(dto.ExpiredTimeStart.HasValue, x => x.ExpiredTime >= dto.ExpiredTimeStart) //期满时间开始
  1032. .WhereIF(dto.ExpiredTimeEnd.HasValue, x => x.ExpiredTime <= dto.ExpiredTimeEnd.Value.AddDays(1).AddSeconds(-1)) //期满时间结束
  1033. .WhereIF(!string.IsNullOrEmpty(dto.OrgLevelOneName), x => x.OrgLevelOneName.Contains(dto.OrgLevelOneName))//一级部门名称
  1034. .WhereIF(!string.IsNullOrEmpty(dto.OrgLevelTwoName), x => x.OrgLevelTwoName.Contains(dto.OrgLevelTwoName)) //二级部门名称
  1035. .WhereIF(!string.IsNullOrEmpty(dto.CurrentHandleOrgId), x => x.CurrentHandleOrgId.Contains(dto.CurrentHandleOrgId)) //接办部门
  1036. .WhereIF(dto.FiledTimeStart.HasValue, x => x.FiledTime >= dto.FiledTimeStart) //办结时间开始
  1037. .WhereIF(dto.FiledTimeEnd.HasValue, x => x.FiledTime <= dto.FiledTimeEnd.Value.AddDays(1).AddSeconds(-1)) //办结时间结束
  1038. .WhereIF(!string.IsNullOrEmpty(dto.AcceptType), x => x.AcceptTypeCode == dto.AcceptType)//受理类型
  1039. .WhereIF(!string.IsNullOrEmpty(dto.Hotspot), x => x.HotspotSpliceName != null && x.HotspotSpliceName.Contains(dto.Hotspot)) //热点分类
  1040. .WhereIF(!string.IsNullOrEmpty(dto.AreaCode), x => x.AreaCode == dto.AreaCode)//区域
  1041. .WhereIF(!string.IsNullOrEmpty(dto.NameOrNo), x => x.AcceptorName == dto.NameOrNo! || x.AcceptorStaffNo == dto.NameOrNo!) //受理人/坐席
  1042. .WhereIF(!string.IsNullOrEmpty(dto.FromName), x => x.FromName.Contains(dto.FromName)) //来电人姓名
  1043. .WhereIF(!string.IsNullOrEmpty(dto.FromPhone), x => x.FromPhone == dto.FromPhone) //来电号码
  1044. .WhereIF(!string.IsNullOrEmpty(dto.PhoneNo), x => x.Contact == dto.PhoneNo!) //联系电话
  1045. .WhereIF(dto.IdentityType.HasValue, x => x.IdentityType == dto.IdentityType) //来电主体
  1046. .WhereIF(dto.FromGender.HasValue, x => x.FromGender == dto.FromGender) //来电性别
  1047. //.WhereIF(!string.IsNullOrEmpty(dto.PushTypeCode), x => x.PushTypeCode == dto.PushTypeCode)//推送分类
  1048. .WhereIF(!string.IsNullOrEmpty(dto.PushTypeCode), x => x.OrderPushTypes.Any(opt=>opt.PushTypeCode == dto.PushTypeCode))//推送分类
  1049. .WhereIF(dto.ExpiredStatus.HasValue && dto.ExpiredStatus == EExpiredStatusEx.Normal,x=> (x.ExpiredTime.HasValue && DateTime.Now < x.ExpiredTime && x.Status>= EOrderStatus.Filed) || (x.NearlyExpiredTime.HasValue && DateTime.Now < x.NearlyExpiredTime && x.Status< EOrderStatus.Filed)) //超期状态:正常
  1050. .WhereIF(dto.ExpiredStatus.HasValue && dto.ExpiredStatus == EExpiredStatusEx.GoingToExpired,x=> (x.Status< EOrderStatus.Filed && DateTime.Now> x.NearlyExpiredTime && DateTime.Now < x.ExpiredTime) || (x.Status >= EOrderStatus.Filed && x.FiledTime > x.NearlyExpiredTime && x.FiledTime< x.ExpiredTime)) // 超期状态:即将超期
  1051. .WhereIF(dto.ExpiredStatus.HasValue && dto.ExpiredStatus == EExpiredStatusEx.Expired,x=> (x.Status< EOrderStatus.Filed && DateTime.Now > x.ExpiredTime) || (x.Status>= EOrderStatus.Filed && x.FiledTime > x.ExpiredTime))
  1052. .Select(x => new OrderDataInventoryRep()
  1053. {
  1054. Id = x.Id,
  1055. OrderStatus = x.Status,
  1056. ActualHandleTime = x.ActualHandleTime,
  1057. NearlyExpiredTime = x.NearlyExpiredTime,
  1058. SourceChannel = x.SourceChannel,
  1059. TransferPhone = x.TransferPhone,
  1060. CurrentStepName = x.CurrentStepName,
  1061. ReTransactNum = x.ReTransactNum,
  1062. //甄别状态
  1063. OrderScreenStatus = SqlFunc.Subqueryable<OrderScreen>().Where(q=>q.OrderId == x.Id).OrderByDesc(q=>q.CreationTime).Select(q=>q.Status), //x.OrderScreens.FirstOrDefault().Status,
  1064. No = x.No,
  1065. ProvinceNo = x.ProvinceNo,
  1066. CreationTime = x.CreationTime,
  1067. Title = x.Title,
  1068. ExpiredTime = x.ExpiredTime,
  1069. OrgLevelOneName = x.OrgLevelOneName,
  1070. OrgLevelTwoName = x.OrgLevelTwoName,
  1071. CurrentHandleOrgName = x.CurrentHandleOrgName,
  1072. FiledTime = x.FiledTime,
  1073. AcceptType = x.AcceptType,
  1074. HotspotName = x.HotspotName,
  1075. HotspotSpliceName = x.HotspotSpliceName,
  1076. AreaName = SqlFunc.IIF(string.IsNullOrEmpty(x.Town) == false, x.Town, SqlFunc.IIF(string.IsNullOrEmpty(x.County) == false, x.County, x.City)),
  1077. FullAreaName = x.FullAddress,
  1078. AcceptorName = x.AcceptorName,
  1079. FromName = x.FromName,
  1080. Contact = x.Contact,
  1081. FromPhone = x.FromPhone,
  1082. Address = x.Street,
  1083. IdentityType = x.IdentityType,
  1084. FromGender = x.FromGender,
  1085. //坐席评价
  1086. SeatEvaluate = SqlFunc.Subqueryable<OrderVisitDetail>()
  1087. .Where(w => w.VisitId == SqlFunc.Subqueryable<OrderVisit>().Where(q => q.OrderId == x.Id && q.VisitState == EVisitState.Visited).Select(q => q.Id) && w.VisitTarget == EVisitTarget.Seat)
  1088. .Select(w =>w.SeatEvaluate),
  1089. //办结结果
  1090. OrgProcessingResults = SqlFunc.Subqueryable<OrderVisitDetail>()
  1091. .Where(w => w.VisitId == SqlFunc.Subqueryable<OrderVisit>().Where(q => q.OrderId == x.Id && q.VisitState == EVisitState.Visited).Select(q => q.Id) && w.VisitTarget == EVisitTarget.Org)
  1092. .Select(w =>SqlFunc.JsonField(w.OrgProcessingResults,"Value")),
  1093. PushType = x.PushType,
  1094. Content = x.Content,
  1095. ActualOpinion = x.ActualOpinion,
  1096. FileOpinion = x.FileOpinion,
  1097. }).OrderByDescending(x => x.CreationTime);
  1098. return result;
  1099. }
  1100. /// <summary>
  1101. /// 扭转列表
  1102. /// </summary>
  1103. /// <param name="dto"></param>
  1104. /// <returns></returns>
  1105. public ISugarQueryable<OrderVisit> VisitJudgeQuery(VisitJudgeQueryReq dto)
  1106. {
  1107. return _orderVisitRepository.Queryable()
  1108. .Includes(x => x.Order)
  1109. .Includes(x => x.Employee)
  1110. .Where(x => x.VisitState == EVisitState.Visited)
  1111. .WhereIF(!string.IsNullOrEmpty(dto.No), x => x.No == dto.No)
  1112. .WhereIF(!string.IsNullOrEmpty(dto.Title), x => x.Order.Title.Contains(dto.Title))
  1113. .WhereIF(!string.IsNullOrEmpty(dto.VisitUserName), x => x.Employee.Name.Contains(dto.VisitUserName))
  1114. .WhereIF(!string.IsNullOrEmpty(dto.AcceptType), d => d.Order.AcceptTypeCode == dto.AcceptType)//受理类型
  1115. .WhereIF(!string.IsNullOrEmpty(dto.Hotspot), d => d.Order.HotspotSpliceName != null && d.Order.HotspotSpliceName.Contains(dto.Hotspot))//热点类型
  1116. .WhereIF(!string.IsNullOrEmpty(dto.OrgId), d => d.Order.CurrentHandleOrgId == dto.OrgId)//接办部门
  1117. .WhereIF(!string.IsNullOrEmpty(dto.NameOrNo),
  1118. d => d.Order.AcceptorName.Contains(dto.NameOrNo!) || d.Order.AcceptorStaffNo.Contains(dto.NameOrNo!)) //受理人/坐席
  1119. .WhereIF(dto.CreationTimeStart.HasValue, d => d.CreationTime >= dto.CreationTimeStart) //受理时间开始
  1120. .WhereIF(dto.CreationTimeEnd.HasValue, d => d.CreationTime <= dto.CreationTimeEnd) //受理时间结束
  1121. .WhereIF(dto.ActualHandleTimeStart.HasValue, d => d.Order.ActualHandleTime >= dto.ActualHandleTimeStart) //办结时间开始
  1122. .WhereIF(dto.ActualHandleTimeEnd.HasValue, d => d.Order.ActualHandleTime <= dto.ActualHandleTimeEnd) //办结时间结束
  1123. .WhereIF(dto.VisitTimeStart.HasValue, d => d.VisitTime >= dto.VisitTimeStart) //回访开始时间
  1124. .WhereIF(dto.VisitTimeEnd.HasValue, d => d.VisitTime <= dto.VisitTimeEnd)
  1125. .WhereIF(dto.IsIng == true, d => d.JudgeState == EJudgeState.Judging)
  1126. .WhereIF(dto.IsIng == false, d => d.JudgeState != EJudgeState.Judging)
  1127. .WhereIF(dto.JudgeState != null, d => d.JudgeState == dto.JudgeState)
  1128. .WhereIF(dto.OrgJudge != null, d => d.OrgJudge == dto.OrgJudge)
  1129. .WhereIF(dto.SeatJudge != null, d => d.SeatJudge == dto.SeatJudge)
  1130. .WhereIF(dto.FiledType != null && dto.FiledType == FiledType.CenterFiled, d => d.Order.ProcessType == EProcessType.Zhiban)
  1131. .WhereIF(dto.FiledType != null && dto.FiledType == FiledType.OrgFiled, d => d.Order.ProcessType == EProcessType.Jiaoban)
  1132. .WhereIF(!string.IsNullOrEmpty(dto.TransferPhone), x => x.Order.TransferPhone == dto.TransferPhone)
  1133. .OrderByDescending(x => x.VisitTime);
  1134. }
  1135. /// <summary>
  1136. /// 满意度明细
  1137. /// </summary>
  1138. /// <param name="dto"></param>
  1139. /// <returns></returns>
  1140. public ISugarQueryable<OrgVisitDetailListResp> OrgVisitDetailList(OrgVisitDetailListReq dto)
  1141. {
  1142. var IsCenter = _sessionContext.OrgIsCenter;
  1143. return _orderVisitDetailRepository.Queryable()
  1144. .Includes(x => x.OrderVisit, x => x.Order)
  1145. .Includes(x => x.OrderVisit, x => x.Employee)
  1146. .Where(x => x.OrderVisit.VisitState == EVisitState.Visited && x.VisitTarget == EVisitTarget.Org)
  1147. .WhereIF(IsCenter == false, x => x.VisitOrgCode.StartsWith(_sessionContext.RequiredOrgId))
  1148. .WhereIF(dto.OrgVisitStatisticsType.HasValue, x => x.OrderVisit.Order.ProcessType == (EProcessType)((int)dto.OrgVisitStatisticsType))
  1149. .WhereIF(dto.Keyword.NotNullOrEmpty(), x => x.OrderVisit.Order.Title.Contains(dto.Keyword)) // 根据关键字匹配
  1150. .WhereIF(dto.TypeCode != 0, x => x.OrderVisit.Order.IdentityType == (EIdentityType)dto.TypeCode)
  1151. .WhereIF(!string.IsNullOrEmpty(dto.OrgProcessingResults), dto.AttitudeType == EAttitudeType.ProcessingResult ? x => SqlFunc.JsonField(x.OrgProcessingResults, "Key") == dto.OrgProcessingResults : x => SqlFunc.JsonField(x.OrgHandledAttitude, "Key") == dto.OrgProcessingResults)
  1152. .WhereIF(!string.IsNullOrEmpty(dto.VisitUser), x => x.OrderVisit.Employee.Name.Contains(dto.VisitUser))
  1153. .WhereIF(!string.IsNullOrEmpty(dto.No), x => x.OrderVisit.Order.No == dto.No)
  1154. .WhereIF(!string.IsNullOrEmpty(dto.Title), x => x.OrderVisit.Order.Title.Contains(dto.Title))
  1155. .WhereIF(!string.IsNullOrEmpty(dto.OrgId), x => x.VisitOrgCode == dto.OrgId)//接办部门
  1156. .WhereIF(!string.IsNullOrEmpty(dto.Hotspot), x => x.OrderVisit.Order.HotspotSpliceName != null && x.OrderVisit.Order.HotspotSpliceName.Contains(dto.Hotspot))//热点类型
  1157. .WhereIF(!string.IsNullOrEmpty(dto.Channel), x => x.OrderVisit.Order.SourceChannelCode == dto.Channel)//受理类型
  1158. .WhereIF(dto.CreationTimeStart.HasValue, x => x.OrderVisit.Order.CreationTime >= dto.CreationTimeStart) //受理时间开始
  1159. .WhereIF(dto.CreationTimeEnd.HasValue, x => x.OrderVisit.Order.CreationTime <= dto.CreationTimeEnd) //受理时间结束
  1160. .WhereIF(dto.ActualHandleTimeStart.HasValue, x => x.OrderVisit.Order.ActualHandleTime >= dto.ActualHandleTimeStart) //办结时间开始
  1161. .WhereIF(dto.ActualHandleTimeEnd.HasValue, x => x.OrderVisit.Order.ActualHandleTime <= dto.ActualHandleTimeEnd)//办结时间结束
  1162. .WhereIF(dto.VisitTimeStart.HasValue, x => x.OrderVisit.VisitTime >= dto.VisitTimeStart) //回访时间
  1163. .WhereIF(dto.VisitTimeEnd.HasValue, x => x.OrderVisit.VisitTime < dto.VisitTimeEnd) //回访时间
  1164. .OrderByIF(string.IsNullOrEmpty(dto.SortField),x=>x.OrderVisit.VisitTime,OrderByType.Desc)
  1165. .OrderByIF(dto is { SortField: "creationTime", SortRule:0 },x=>x.OrderVisit.Order.CreationTime,OrderByType.Asc) //受理时间升序
  1166. .OrderByIF(dto is { SortField: "creationTime", SortRule: 1 }, x => x.OrderVisit.Order.CreationTime, OrderByType.Desc) //受理时间降序
  1167. .OrderByIF(dto is { SortField: "visitTime", SortRule: 0 }, x => x.OrderVisit.VisitTime, OrderByType.Asc) //回访时间升序
  1168. .OrderByIF(dto is { SortField: "visitTime", SortRule: 1 }, x => x.OrderVisit.VisitTime, OrderByType.Desc) //回访时间降序
  1169. .OrderByIF(dto is { SortField: "filedTime", SortRule:0 },x=>x.OrderVisit.Order.FiledTime,OrderByType.Asc) //办结时间升序
  1170. .OrderByIF(dto is { SortField: "filedTime", SortRule: 1 }, x => x.OrderVisit.Order.FiledTime, OrderByType.Desc) //办结时间降序
  1171. .Select(x => new OrgVisitDetailListResp()
  1172. {
  1173. Id = x.OrderVisit.Order.Id,
  1174. VisitId = x.OrderVisit.Id,
  1175. No = x.OrderVisit.No,
  1176. ReTransactNum = x.OrderVisit.Order.ReTransactNum,
  1177. OrderScreenStatus = SqlFunc.Subqueryable<OrderScreen>().Where(q => q.OrderId == x.OrderVisit.OrderId && q.VisitDetailId == x.Id).OrderByDesc(q => q.CreationTime).Select(q => q.Status),
  1178. VisitContent = x.VisitContent,
  1179. HotspotSpliceName = x.OrderVisit.Order.HotspotSpliceName,
  1180. OrgLevelOneName = x.OrderVisit.Order.OrgLevelOneName,
  1181. CurrentHandleOrgName = x.OrderVisit.Order.CurrentHandleOrgName,
  1182. CreationTime = x.OrderVisit.Order.CreationTime,
  1183. Title = x.OrderVisit.Order.Title,
  1184. VisitUser = x.OrderVisit.Employee.Name,
  1185. VisitType = x.OrderVisit.VisitType,
  1186. VisitTime = x.OrderVisit.VisitTime,
  1187. OrgProcessingResults = dto.AttitudeType == EAttitudeType.ProcessingResult ? SqlFunc.JsonField(x.OrgProcessingResults, "Value")
  1188. : SqlFunc.JsonField(x.OrgHandledAttitude, "Value"),
  1189. Content = x.OrderVisit.Order.Content,
  1190. FileOpinion = x.OrderVisit.Order.FileOpinion,
  1191. FiledTime = x.OrderVisit.Order.FiledTime,
  1192. VisitOrgName = x.VisitOrgName,
  1193. ActualHandleOrgName = x.OrderVisit.Order.ActualHandleOrgName
  1194. });
  1195. }
  1196. /// <summary>
  1197. /// 部门满意度明细统计
  1198. /// </summary>
  1199. /// <param name="dto"></param>
  1200. /// <returns></returns>
  1201. public ISugarQueryable<OrgVisitDetailListResp> VisitAndOrgSatisfactionDetail(VisitAndOrgSatisfactionDetailDto dto)
  1202. {
  1203. bool IsCenter = _sessionContext.OrgIsCenter;
  1204. return _orderVisitDetailRepository.Queryable()
  1205. .Includes(x => x.OrderVisit, o => o.Order, d => d.CallRecord)
  1206. .Where(x => x.OrderVisit.VisitTime >= dto.StartTime && x.OrderVisit.VisitTime <= dto.EndTime && x.VisitTarget == EVisitTarget.Org && x.OrderVisit.VisitState == EVisitState.Visited)
  1207. .WhereIF(dto.OrgCode == "001", x => x.VisitOrgCode == dto.OrgCode)
  1208. .WhereIF(dto.TypeCode != null && dto.TypeCode == 1, x => x.OrderVisit.Order.IdentityType == EIdentityType.Citizen)
  1209. .WhereIF(dto.TypeCode != null && dto.TypeCode == 2, x => x.OrderVisit.Order.IdentityType == EIdentityType.Enterprise)
  1210. //.WhereIF(dto.OrgCode != "001", x => x.VisitOrgCode == dto.OrgCode).
  1211. .WhereIF(dto.IsOnlyMy == true, x => x.VisitOrgCode == dto.OrgCode)
  1212. .WhereIF(IsCenter == true && dto.IsOnlyMy == true, x => x.VisitOrgCode == dto.OrgCode)
  1213. .WhereIF(IsCenter == true && dto.IsOnlyMy == null, x => x.VisitOrgCode.StartsWith(dto.OrgCode))
  1214. .WhereIF(IsCenter == false, x => x.VisitOrgCode == dto.OrgCode)
  1215. .WhereIF(dto.TypeId is 1, x => SqlFunc.JsonField(x.OrgProcessingResults, "Key") == dto.DateValue)
  1216. .WhereIF(dto.TypeId is 2, x => SqlFunc.JsonField(x.OrgHandledAttitude, "Key") == dto.DateValue)
  1217. .WhereIF(!string.IsNullOrEmpty(dto.LineNum), x => x.OrderVisit.Order.CallRecord.Gateway == dto.LineNum)
  1218. .OrderByIF(string.IsNullOrEmpty(dto.SortField), x => x.OrderVisit.VisitTime, OrderByType.Desc)
  1219. .OrderByIF(dto is { SortField: "startTime", SortRule: 0 }, x => x.OrderVisit.Order.StartTime, OrderByType.Asc) //受理时间升序
  1220. .OrderByIF(dto is { SortField: "startTime", SortRule: 1 }, x => x.OrderVisit.Order.StartTime, OrderByType.Desc) //受理时间降序
  1221. .OrderByIF(dto is { SortField: "visitTime", SortRule: 0 }, x => x.OrderVisit.VisitTime, OrderByType.Asc) //回访时间升序
  1222. .OrderByIF(dto is { SortField: "visitTime", SortRule: 1 }, x => x.OrderVisit.VisitTime, OrderByType.Desc) //回访时间降序
  1223. .OrderByIF(dto is { SortField: "filedTime", SortRule: 0 }, x => x.OrderVisit.Order.FiledTime, OrderByType.Asc) //办结时间升序
  1224. .OrderByIF(dto is { SortField: "filedTime", SortRule: 1 }, x => x.OrderVisit.Order.FiledTime, OrderByType.Desc) //办结时间降序
  1225. .Select(x => new OrgVisitDetailListResp
  1226. {
  1227. Id = x.OrderVisit.Order.Id,
  1228. VisitId = x.OrderVisit.Id,
  1229. No = x.OrderVisit.No,
  1230. ReTransactNum = x.OrderVisit.Order.ReTransactNum,
  1231. OrderScreenStatus = SqlFunc.Subqueryable<OrderScreen>().Where(q => q.OrderId == x.OrderVisit.OrderId && q.VisitDetailId == x.Id).OrderByDesc(q => q.CreationTime).Select(q => q.Status),
  1232. VisitContent = x.VisitContent,
  1233. HotspotSpliceName = x.OrderVisit.Order.HotspotSpliceName,
  1234. OrgLevelOneName = x.OrderVisit.Order.OrgLevelOneName,
  1235. CurrentHandleOrgName = x.OrderVisit.Order.CurrentHandleOrgName,
  1236. CreationTime = x.CreationTime,
  1237. Title = x.OrderVisit.Order.Title,
  1238. VisitUser = x.OrderVisit.Employee.Name,
  1239. VisitType = x.OrderVisit.VisitType,
  1240. VisitTime = x.OrderVisit.VisitTime,
  1241. OrgProcessingResults = SqlFunc.JsonField(x.OrgProcessingResults, "Value"),
  1242. Content = x.OrderVisit.Order.Content,
  1243. FileOpinion = x.OrderVisit.Order.FileOpinion,
  1244. FiledTime = x.OrderVisit.Order.FiledTime,
  1245. VisitOrgName = x.VisitOrgName
  1246. });
  1247. }
  1248. }
  1249. public class OrderScreenRepository : BaseRepositoryWorkflow<OrderScreen>, IOrderScreenRepository, IScopeDependency
  1250. {
  1251. public OrderScreenRepository(ISugarUnitOfWork<HotlineDbContext> uow, IDataPermissionFilterBuilder dataPermissionFilterBuilder) : base(uow, dataPermissionFilterBuilder)
  1252. {
  1253. }
  1254. }
  1255. public class OrderTerminateRepository : BaseRepositoryWorkflow<OrderTerminate>, IOrderTerminateRepository, IScopeDependency
  1256. {
  1257. public OrderTerminateRepository(ISugarUnitOfWork<HotlineDbContext> uow, IDataPermissionFilterBuilder dataPermissionFilterBuilder) : base(uow, dataPermissionFilterBuilder)
  1258. {
  1259. }
  1260. }
  1261. public class OrderDelayRepository : BaseRepositoryWorkflow<OrderDelay>, IOrderDelayRepository, IScopeDependency
  1262. {
  1263. public OrderDelayRepository(ISugarUnitOfWork<HotlineDbContext> uow, IDataPermissionFilterBuilder dataPermissionFilterBuilder) : base(uow, dataPermissionFilterBuilder)
  1264. {
  1265. }
  1266. }
  1267. }