|
@@ -0,0 +1,377 @@
|
|
|
+using Hotline.JudicialManagement;
|
|
|
+using Hotline.KnowledgeBase;
|
|
|
+using Hotline.Orders;
|
|
|
+using Hotline.Repository.SqlSugar.Orders;
|
|
|
+using Hotline.Settings;
|
|
|
+using Hotline.Settings.Hotspots;
|
|
|
+using Hotline.Share.Dtos.Bigscreen;
|
|
|
+using Hotline.Share.Dtos.JudicialManagement;
|
|
|
+using Hotline.Share.Dtos.Order;
|
|
|
+using Hotline.Share.Enums.KnowledgeBase;
|
|
|
+using Hotline.Share.Enums.Order;
|
|
|
+using MapsterMapper;
|
|
|
+using Microsoft.AspNetCore.Authorization;
|
|
|
+using Microsoft.AspNetCore.Mvc;
|
|
|
+using SqlSugar;
|
|
|
+using XF.Domain.Repository;
|
|
|
+
|
|
|
+namespace Hotline.Api.Controllers.Bigscreen
|
|
|
+{
|
|
|
+ /// <summary>
|
|
|
+ /// 司法行政监督管理大屏
|
|
|
+ /// </summary>
|
|
|
+ public class EnforcementScreenController : BaseController
|
|
|
+ {
|
|
|
+ private readonly IRepository<EnforcementOrders> _enforcementOrdersRepository;
|
|
|
+ private readonly IRepository<JudicialComplaintsEventType> _judicialComplaintsEventTypeRepository;
|
|
|
+ private readonly IRepository<EnforcementHotspot> _enforcementHotspotRepository;
|
|
|
+ private readonly IOrderRepository _orderRepository;
|
|
|
+ private readonly IRepository<OrderDelay> _orderDelayRepository;
|
|
|
+ private readonly IRepository<OrderVisit> _orderVisitRepository;
|
|
|
+ private readonly IRepository<Knowledge> _knowledgeRepository;
|
|
|
+ private readonly IRepository<KnowledgePv> _knowledgePvRepository;
|
|
|
+ private readonly IMapper _mapper;
|
|
|
+ private readonly IRepository<OrderVisitDetail> _orderVisitDetailRepository;
|
|
|
+ private readonly IRepository<SystemArea> _systemAreaRepository;
|
|
|
+
|
|
|
+ public EnforcementScreenController(IRepository<EnforcementOrders> enforcementOrdersRepository,
|
|
|
+ IRepository<JudicialComplaintsEventType> judicialComplaintsEventTypeRepository,
|
|
|
+ IRepository<EnforcementHotspot> enforcementHotspotRepository,
|
|
|
+ IOrderRepository orderRepository,
|
|
|
+ IRepository<OrderVisit> orderVisitRepository,
|
|
|
+ IRepository<OrderDelay> orderDelayRepository,
|
|
|
+ IRepository<Knowledge> knowledgeRepository,
|
|
|
+ IRepository<KnowledgePv> knowledgePvRepository,
|
|
|
+ IMapper mapper,
|
|
|
+ IRepository<OrderVisitDetail> orderVisitDetailRepository,
|
|
|
+ IRepository<SystemArea> systemAreaRepository)
|
|
|
+ {
|
|
|
+ _enforcementOrdersRepository = enforcementOrdersRepository;
|
|
|
+ _judicialComplaintsEventTypeRepository = judicialComplaintsEventTypeRepository;
|
|
|
+ _enforcementHotspotRepository = enforcementHotspotRepository;
|
|
|
+ _orderRepository = orderRepository;
|
|
|
+ _orderVisitRepository = orderVisitRepository;
|
|
|
+ _orderDelayRepository = orderDelayRepository;
|
|
|
+ _knowledgeRepository = knowledgeRepository;
|
|
|
+ _knowledgePvRepository = knowledgePvRepository;
|
|
|
+ _mapper = mapper;
|
|
|
+ _orderVisitDetailRepository = orderVisitDetailRepository;
|
|
|
+ _systemAreaRepository = systemAreaRepository;
|
|
|
+ }
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 左上工单数据模块
|
|
|
+ /// </summary>
|
|
|
+ /// <returns></returns>
|
|
|
+ [AllowAnonymous]
|
|
|
+ [HttpGet("order-module-statistics")]
|
|
|
+ public async Task<OrderModuleDto> GetOrderModuleStatisticsAsync(DateTime StartDate, DateTime EndDate)
|
|
|
+ {
|
|
|
+ EndDate = EndDate.AddDays(1).AddSeconds(-1);
|
|
|
+ var dto = new OrderModuleDto();
|
|
|
+
|
|
|
+ var data = await _enforcementOrdersRepository.Queryable()
|
|
|
+ .LeftJoin<Order>((x, o) => x.Id == o.Id)
|
|
|
+ .Where((x, o) => o.Id != null)
|
|
|
+ .Where((x, o) => o.StartTime >= StartDate && o.StartTime <= EndDate)
|
|
|
+ .Select((x, o) => new
|
|
|
+ {
|
|
|
+ x.Id,
|
|
|
+ x.IsEnforcementOrder,
|
|
|
+ x.IsTheClueTrue,
|
|
|
+ x.IsPassTheBuckOrder
|
|
|
+ })
|
|
|
+ .MergeTable()
|
|
|
+ .Select(d => new OrderModuleDto
|
|
|
+ {
|
|
|
+ OrderCountNum = SqlFunc.AggregateSum(SqlFunc.IIF(d.Id != null, 1, 0)),
|
|
|
+ EnforcementOrderNum = SqlFunc.AggregateSum(SqlFunc.IIF(d.IsEnforcementOrder, 1, 0)),
|
|
|
+ TheClueIsTrueNum = SqlFunc.AggregateSum(SqlFunc.IIF(d.IsTheClueTrue.HasValue && d.IsTheClueTrue.Value == true, 1, 0)),
|
|
|
+ TheClueIsNotTrueNum = SqlFunc.AggregateSum(SqlFunc.IIF(d.IsTheClueTrue.HasValue && d.IsTheClueTrue.Value == false, 1, 0)),
|
|
|
+ PassTheBuckOrderNum = SqlFunc.AggregateSum(SqlFunc.IIF(d.IsPassTheBuckOrder, 1, 0))
|
|
|
+ })
|
|
|
+ .ToListAsync();
|
|
|
+ if (data != null && data.Count > 0)
|
|
|
+ {
|
|
|
+ dto.OrderCountNum = data[0].OrderCountNum;
|
|
|
+ dto.EnforcementOrderNum = data[0].EnforcementOrderNum;
|
|
|
+ dto.TheClueIsTrueNum = data[0].TheClueIsTrueNum;
|
|
|
+ dto.TheClueIsNotTrueNum = data[0].TheClueIsNotTrueNum;
|
|
|
+ dto.PassTheBuckOrderNum = data[0].PassTheBuckOrderNum;
|
|
|
+ }
|
|
|
+
|
|
|
+ dto.SatisfiedCount = await _enforcementOrdersRepository.Queryable()
|
|
|
+ .LeftJoin<OrderVisit>((x, o) => x.Id == o.OrderId)
|
|
|
+ .LeftJoin<OrderVisitDetail>((x, o, p) => o.Id == p.VisitId)
|
|
|
+ .Where((x, o, p) => o.VisitTime >= StartDate && o.VisitTime <= EndDate && p.VisitTarget == EVisitTarget.Org)
|
|
|
+ .Where((x, o, p) => o.VisitState == EVisitState.Visited && !string.IsNullOrEmpty(p.VisitOrgCode))
|
|
|
+ .Where((x, o, p) => SqlFunc.JsonField(o.NowEvaluate, "Key") != "1" && SqlFunc.JsonField(o.NowEvaluate, "Key") != "2")
|
|
|
+ .CountAsync();
|
|
|
+
|
|
|
+ return dto;
|
|
|
+ }
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 左中受理类型
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="StartDate"></param>
|
|
|
+ /// <param name="EndDate"></param>
|
|
|
+ /// <returns></returns>
|
|
|
+ [AllowAnonymous]
|
|
|
+ [HttpGet("order-accept-type-statistics")]
|
|
|
+ public async Task<List<OrderAcceptTypeStatisticsDto>> GetOrderAcceptTypeStatisticsAsync(DateTime StartDate, DateTime EndDate)
|
|
|
+ {
|
|
|
+ EndDate = EndDate.AddDays(1).AddSeconds(-1);
|
|
|
+
|
|
|
+ var list = await _enforcementOrdersRepository.Queryable()
|
|
|
+ .LeftJoin<Order>((x, o) => x.Id == o.Id)
|
|
|
+ .Where((x, o) => o.Id != null && o.Status > EOrderStatus.Handling && !string.IsNullOrEmpty(o.AcceptType))
|
|
|
+ .Where((x, o) => o.StartTime >= StartDate && o.StartTime <= EndDate)
|
|
|
+ .Select((x, o) => new
|
|
|
+ {
|
|
|
+ x.Id,
|
|
|
+ o.AcceptType,
|
|
|
+ o.Status,
|
|
|
+ o.ExpiredStatus
|
|
|
+ })
|
|
|
+ .MergeTable()
|
|
|
+ .GroupBy(x => x.AcceptType)
|
|
|
+ .Select(x => new OrderAcceptTypeStatisticsDto
|
|
|
+ {
|
|
|
+ AcceptType = x.AcceptType,
|
|
|
+ SumCount = SqlFunc.AggregateCount(x.Id),
|
|
|
+ HandlingCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status >= EOrderStatus.Handling && x.Status < EOrderStatus.Filed, 1, 0)),
|
|
|
+ FiledCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.Status >= EOrderStatus.Filed, 1, 0)),
|
|
|
+ OverTimeCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.ExpiredStatus == EExpiredStatus.Expired, 1, 0))
|
|
|
+ }).ToListAsync();
|
|
|
+
|
|
|
+ return list;
|
|
|
+ }
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 左下高频事项统计
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="StartDate"></param>
|
|
|
+ /// <param name="EndDate"></param>
|
|
|
+ /// <param name="AreaCode"></param>
|
|
|
+ /// <returns></returns>
|
|
|
+ [AllowAnonymous]
|
|
|
+ [HttpGet("order-event-type-statistics")]
|
|
|
+ public async Task<List<OrderEventTypeStatisticsDto>> GetOrderEventTypeStatisticsAsync(DateTime StartDate, DateTime EndDate, string AreaCode)
|
|
|
+ {
|
|
|
+ EndDate = EndDate.AddDays(1).AddSeconds(-1);
|
|
|
+ if (AreaCode.Length == 6 && AreaCode.IndexOf("00") == 4)
|
|
|
+ AreaCode = AreaCode.Remove(4);
|
|
|
+
|
|
|
+ var list = await _enforcementOrdersRepository.Queryable()
|
|
|
+ .LeftJoin<Order>((x, o) => x.Id == o.Id)
|
|
|
+ .LeftJoin<JudicialComplaintsEventType>((x, o, j) => x.EventTypeOneLevelId == j.Id)
|
|
|
+ .Where((x, o, j) => o.Id != null && x.EventTypeOneLevelId != null && j.Id != null)
|
|
|
+ .Where((x, o, j) => o.StartTime >= StartDate && o.StartTime <= EndDate && o.AreaCode.StartsWith(AreaCode))
|
|
|
+ .Select((x, o, j) => new
|
|
|
+ {
|
|
|
+ x.Id,
|
|
|
+ EventTypeId = x.EventTypeOneLevelId,
|
|
|
+ j.EventTypeName
|
|
|
+ })
|
|
|
+ .MergeTable()
|
|
|
+ .GroupBy(p => new { p.EventTypeId, p.EventTypeName })
|
|
|
+ .Select(p => new OrderEventTypeStatisticsDto
|
|
|
+ {
|
|
|
+ EventTypeId = p.EventTypeId,
|
|
|
+ EventTypeName = p.EventTypeName,
|
|
|
+ SumCount = SqlFunc.AggregateCount(p.Id)
|
|
|
+ })
|
|
|
+ .OrderByDescending(p => p.SumCount)
|
|
|
+ .Take(5)
|
|
|
+ .ToListAsync();
|
|
|
+
|
|
|
+ return list;
|
|
|
+ }
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 区域地图数据
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="StartDate"></param>
|
|
|
+ /// <param name="EndDate"></param>
|
|
|
+ /// <returns></returns>
|
|
|
+ [AllowAnonymous]
|
|
|
+ [HttpGet("order-area-query")]
|
|
|
+ public async Task<List<OrderAreaQueryDto>> GetOrderAreaQueryAsync(DateTime StartDate, DateTime EndDate)
|
|
|
+ {
|
|
|
+ EndDate = EndDate.AddDays(1).AddSeconds(-1);
|
|
|
+
|
|
|
+ var areaList = await _systemAreaRepository.Queryable()
|
|
|
+ .Where(x => !x.Id.EndsWith("00"))
|
|
|
+ .GroupBy(x => new
|
|
|
+ {
|
|
|
+ Id = x.Id.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6")),
|
|
|
+ })
|
|
|
+ .Select(x => new
|
|
|
+ {
|
|
|
+ Id = x.Id.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6")),
|
|
|
+ })
|
|
|
+ .MergeTable()
|
|
|
+ .LeftJoin<SystemArea>((it, o) => it.Id == o.Id)
|
|
|
+ .Select((it, o) => new
|
|
|
+ {
|
|
|
+ it.Id,
|
|
|
+ Name = o.AreaName
|
|
|
+ })
|
|
|
+ .ToListAsync();
|
|
|
+
|
|
|
+ var list = new List<OrderAreaQueryDto>();
|
|
|
+
|
|
|
+ foreach (var item in areaList)
|
|
|
+ {
|
|
|
+ #region 单个获取
|
|
|
+
|
|
|
+ var dto = new OrderAreaQueryDto
|
|
|
+ {
|
|
|
+ AreaCode = item.Id,
|
|
|
+ AreaName = item.Name
|
|
|
+ };
|
|
|
+
|
|
|
+ var data = await _enforcementOrdersRepository.Queryable()
|
|
|
+ .LeftJoin<Order>((x, o) => x.Id == o.Id)
|
|
|
+ .Where((x, o) => o.Id != null)
|
|
|
+ .Where((x, o) => o.StartTime >= StartDate && o.StartTime <= EndDate && o.AreaCode == item.Id)
|
|
|
+ .Select((x, o) => new
|
|
|
+ {
|
|
|
+ x.Id,
|
|
|
+ x.IsEnforcementOrder,
|
|
|
+ x.IsTheClueTrue,
|
|
|
+ x.IsPassTheBuckOrder
|
|
|
+ })
|
|
|
+ .MergeTable()
|
|
|
+ .Select(d => new OrderModuleDto
|
|
|
+ {
|
|
|
+ OrderCountNum = SqlFunc.AggregateSum(SqlFunc.IIF(d.Id != null, 1, 0)),
|
|
|
+ EnforcementOrderNum = SqlFunc.AggregateSum(SqlFunc.IIF(d.IsEnforcementOrder, 1, 0)),
|
|
|
+ TheClueIsTrueNum = SqlFunc.AggregateSum(SqlFunc.IIF(d.IsTheClueTrue.HasValue && d.IsTheClueTrue.Value == true, 1, 0)),
|
|
|
+ TheClueIsNotTrueNum = SqlFunc.AggregateSum(SqlFunc.IIF(d.IsTheClueTrue.HasValue && d.IsTheClueTrue.Value == false, 1, 0)),
|
|
|
+ PassTheBuckOrderNum = SqlFunc.AggregateSum(SqlFunc.IIF(d.IsPassTheBuckOrder, 1, 0))
|
|
|
+ })
|
|
|
+ .ToListAsync();
|
|
|
+ if (data != null && data.Count > 0)
|
|
|
+ {
|
|
|
+ dto.OrderCountNum = data[0].OrderCountNum;
|
|
|
+ dto.EnforcementOrderNum = data[0].EnforcementOrderNum;
|
|
|
+ dto.TheClueIsTrueNum = data[0].TheClueIsTrueNum;
|
|
|
+ dto.TheClueIsNotTrueNum = data[0].TheClueIsNotTrueNum;
|
|
|
+ dto.PassTheBuckOrderNum = data[0].PassTheBuckOrderNum;
|
|
|
+ }
|
|
|
+
|
|
|
+ list.Add(dto);
|
|
|
+
|
|
|
+ #endregion
|
|
|
+ }
|
|
|
+ return list;
|
|
|
+ }
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 办理中工单概览
|
|
|
+ /// </summary>
|
|
|
+ /// <returns></returns>
|
|
|
+ [AllowAnonymous]
|
|
|
+ [HttpGet("order-handling-query")]
|
|
|
+ public async Task<List<EnforcementOrderListDto>> OrderHandlingDetailQuery()
|
|
|
+ {
|
|
|
+ var list = await _enforcementOrdersRepository.Queryable()
|
|
|
+ .Includes(d => d.Order)
|
|
|
+ .Where(d => d.Order.Id != null)
|
|
|
+ .Where(d => d.Order.Status > EOrderStatus.WaitForAccept && d.Order.StartTime.Value.Date == DateTime.Now.Date)
|
|
|
+ .OrderByDescending(d => d.Order.StartTime)
|
|
|
+ .Take(50)
|
|
|
+ .ToListAsync();
|
|
|
+
|
|
|
+ return _mapper.Map<List<EnforcementOrderListDto>>(list);
|
|
|
+ }
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 部门满意度排行榜
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="StartDate"></param>
|
|
|
+ /// <param name="EndDate"></param>
|
|
|
+ /// <returns></returns>
|
|
|
+ [AllowAnonymous]
|
|
|
+ [HttpGet("order-visitorg-statistics")]
|
|
|
+ public async Task<List<OrderVisitOrgStatisticsDto>> GetOrderVisitOrgStatisticsAsync(DateTime StartDate, DateTime EndDate)
|
|
|
+ {
|
|
|
+ EndDate = EndDate.AddDays(1).AddSeconds(-1);
|
|
|
+
|
|
|
+ var list = await _enforcementOrdersRepository.Queryable()
|
|
|
+ .LeftJoin<OrderVisit>((x, o) => x.Id == o.OrderId)
|
|
|
+ .LeftJoin<OrderVisitDetail>((x, o, p) => o.Id == p.VisitId)
|
|
|
+ .Where((x, o, p) => o.VisitTime >= StartDate && o.VisitTime <= EndDate && p.VisitTarget == EVisitTarget.Org &&
|
|
|
+ o.VisitState == EVisitState.Visited && !string.IsNullOrEmpty(p.VisitOrgCode) && p.VisitOrgCode.Length >= 6)
|
|
|
+ .Select((x, o, p) => new
|
|
|
+ {
|
|
|
+ p.VisitOrgCode,
|
|
|
+ p.VisitOrgName,
|
|
|
+ p.OrgProcessingResults
|
|
|
+ })
|
|
|
+ .MergeTable()
|
|
|
+ .GroupBy(x => new
|
|
|
+ {
|
|
|
+ VisitOrgCode = x.VisitOrgCode.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6")),
|
|
|
+ x.VisitOrgName
|
|
|
+ })
|
|
|
+ .Select(x => new OrderVisitOrgStatisticsDto()
|
|
|
+ {
|
|
|
+ VisitOrgCode = x.VisitOrgCode.Substring(SqlFunc.MappingColumn<int>("0"), SqlFunc.MappingColumn<int>("6")),
|
|
|
+ VisitOrgName = x.VisitOrgName,
|
|
|
+ SatisfiedCount = SqlFunc.AggregateSum(SqlFunc.IIF(SqlFunc.JsonField(x.OrgProcessingResults, "Key") != "1" && SqlFunc.JsonField(x.OrgProcessingResults, "Key") != "2", 1, 0)),
|
|
|
+ VisitCount = SqlFunc.AggregateCount(x.VisitOrgName)
|
|
|
+ }).MergeTable().OrderByDescending(x => x.SatisfiedCount).Take(10).ToListAsync();
|
|
|
+
|
|
|
+ return list;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ /// <summary>
|
|
|
+ /// 占比分析
|
|
|
+ /// </summary>
|
|
|
+ /// <param name="StartDate"></param>
|
|
|
+ /// <param name="EndDate"></param>
|
|
|
+ /// <param name="IsSource"></param>
|
|
|
+ /// <returns></returns>
|
|
|
+ [AllowAnonymous]
|
|
|
+ [HttpGet("order-source-accepttype-statistics")]
|
|
|
+ public async Task<List<OrderSourceAndAcceptTtoeStatisticsDto>> OrderSourceAndAcceptTtoeStatistics(DateTime StartDate, DateTime EndDate, bool IsSource)
|
|
|
+ {
|
|
|
+ EndDate = EndDate.AddDays(1).AddSeconds(-1);
|
|
|
+
|
|
|
+ int SumCount = await _orderRepository.Queryable(false, false, false)
|
|
|
+ .Where(x => x.StartTime >= StartDate && x.StartTime <= EndDate && x.Status > EOrderStatus.WaitForAccept).CountAsync();
|
|
|
+ if (IsSource)
|
|
|
+ {
|
|
|
+ var list = await _orderRepository.Queryable(false, false, false)
|
|
|
+ .Where(x => x.StartTime >= StartDate && x.StartTime <= EndDate && x.Status > EOrderStatus.WaitForAccept)
|
|
|
+ .GroupBy(x => new { x.SourceChannelCode, x.SourceChannel })
|
|
|
+ .Select(x => new OrderSourceAndAcceptTtoeStatisticsDto()
|
|
|
+ {
|
|
|
+ Name = x.SourceChannel,
|
|
|
+ SumCount = SumCount,
|
|
|
+ HasCount = SqlFunc.AggregateCount(x.SourceChannel)
|
|
|
+ }).ToListAsync();
|
|
|
+ return list;
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ var list = await _orderRepository.Queryable(false, false, false)
|
|
|
+ .Where(x => x.StartTime >= StartDate && x.StartTime <= EndDate && x.Status > EOrderStatus.WaitForAccept)
|
|
|
+ .GroupBy(x => new { x.AcceptTypeCode, x.AcceptType })
|
|
|
+ .Select(x => new OrderSourceAndAcceptTtoeStatisticsDto()
|
|
|
+ {
|
|
|
+ Name = x.AcceptType,
|
|
|
+ SumCount = SumCount,
|
|
|
+ HasCount = SqlFunc.AggregateCount(x.AcceptTypeCode),
|
|
|
+ }).ToListAsync();
|
|
|
+ return list;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+}
|