|
|
@@ -9,131 +9,140 @@ using MediatR;
|
|
|
using Hotline.Share.Dtos;
|
|
|
using XF.Domain.Repository;
|
|
|
using XF.Domain.Authentications;
|
|
|
+using Hotline.Configurations;
|
|
|
+using Microsoft.Extensions.Options;
|
|
|
|
|
|
namespace Hotline.Application.Orders.OrderScreenHandler;
|
|
|
public class OrderScreenEndWorkflowHandler : INotificationHandler<EndWorkflowNotify>
|
|
|
{
|
|
|
- private readonly IOrderRepository _orderRepository;
|
|
|
- private readonly ICapPublisher _capPublisher;
|
|
|
- private readonly IMapper _mapper;
|
|
|
- private readonly IRepository<OrderVisitDetail> _orderVisitedDetailRepository;
|
|
|
- private readonly IRepository<OrderScreen> _orderScreenRepository;
|
|
|
- private readonly IRepository<OrderVisit> _orderVisitRepository;
|
|
|
- private readonly ISessionContext _sessionContext;
|
|
|
- private readonly IRepository<OrderScreenDetail> _orderScreenDetailRepository;
|
|
|
+ private readonly IOrderRepository _orderRepository;
|
|
|
+ private readonly ICapPublisher _capPublisher;
|
|
|
+ private readonly IMapper _mapper;
|
|
|
+ private readonly IRepository<OrderVisitDetail> _orderVisitedDetailRepository;
|
|
|
+ private readonly IRepository<OrderScreen> _orderScreenRepository;
|
|
|
+ private readonly IRepository<OrderVisit> _orderVisitRepository;
|
|
|
+ private readonly ISessionContext _sessionContext;
|
|
|
+ private readonly IRepository<OrderScreenDetail> _orderScreenDetailRepository;
|
|
|
+ private readonly IOptionsSnapshot<AppConfiguration> _appOptions;
|
|
|
|
|
|
- public OrderScreenEndWorkflowHandler(
|
|
|
- IOrderRepository orderRepository,
|
|
|
- ICapPublisher capPublisher,
|
|
|
- IMapper mapper,
|
|
|
- IRepository<OrderVisitDetail> orderVisitedDetailRepository,
|
|
|
- IRepository<OrderScreen> orderScreenRepository,
|
|
|
- IRepository<OrderVisit> orderVisitRepository,
|
|
|
- ISessionContext sessionContext,
|
|
|
- IRepository<OrderScreenDetail> orderScreenDetailRepository)
|
|
|
- {
|
|
|
- _orderRepository = orderRepository;
|
|
|
- _capPublisher = capPublisher;
|
|
|
- _mapper = mapper;
|
|
|
- _orderScreenRepository = orderScreenRepository;
|
|
|
- _orderVisitedDetailRepository = orderVisitedDetailRepository;
|
|
|
- _orderVisitRepository = orderVisitRepository;
|
|
|
- _sessionContext = sessionContext;
|
|
|
- _orderScreenDetailRepository = orderScreenDetailRepository;
|
|
|
- }
|
|
|
+ public OrderScreenEndWorkflowHandler(
|
|
|
+ IOrderRepository orderRepository,
|
|
|
+ ICapPublisher capPublisher,
|
|
|
+ IMapper mapper,
|
|
|
+ IRepository<OrderVisitDetail> orderVisitedDetailRepository,
|
|
|
+ IRepository<OrderScreen> orderScreenRepository,
|
|
|
+ IRepository<OrderVisit> orderVisitRepository,
|
|
|
+ ISessionContext sessionContext,
|
|
|
+ IRepository<OrderScreenDetail> orderScreenDetailRepository,
|
|
|
+ IOptionsSnapshot<AppConfiguration> appOptions)
|
|
|
+ {
|
|
|
+ _orderRepository = orderRepository;
|
|
|
+ _capPublisher = capPublisher;
|
|
|
+ _mapper = mapper;
|
|
|
+ _orderScreenRepository = orderScreenRepository;
|
|
|
+ _orderVisitedDetailRepository = orderVisitedDetailRepository;
|
|
|
+ _orderVisitRepository = orderVisitRepository;
|
|
|
+ _sessionContext = sessionContext;
|
|
|
+ _orderScreenDetailRepository = orderScreenDetailRepository;
|
|
|
+ _appOptions = appOptions;
|
|
|
|
|
|
- /// <summary>Handles a notification</summary>
|
|
|
- /// <param name="notification">The notification</param>
|
|
|
- /// <param name="cancellationToken">Cancellation token</param>
|
|
|
- public async Task Handle(EndWorkflowNotify notification, CancellationToken cancellationToken)
|
|
|
- {
|
|
|
- if (notification.Workflow.ModuleCode == WorkflowModuleConsts.OrderScreen)
|
|
|
- {
|
|
|
- var workflow = notification.Workflow;
|
|
|
- //审批是否通过
|
|
|
- var isReviewPass = workflow.IsReviewPass();
|
|
|
+ }
|
|
|
|
|
|
- var screen = await _orderScreenRepository.GetAsync(workflow.ExternalId, cancellationToken);
|
|
|
- if (screen != null)
|
|
|
- {
|
|
|
- screen.Flowed(workflow.FlowedUserIds, workflow.FlowedOrgIds, workflow.HandlerUsers, workflow.HandlerOrgs);
|
|
|
- if (isReviewPass)
|
|
|
- {
|
|
|
- screen.Status = EScreenStatus.End;
|
|
|
- screen.ReplyContent = workflow.ActualOpinion;
|
|
|
- //await _orderScreenRepository.UpdateAsync(screen, cancellationToken);
|
|
|
- var visitDetail =
|
|
|
- await _orderVisitedDetailRepository.GetAsync(screen.VisitDetailId, cancellationToken);
|
|
|
- if (visitDetail != null)
|
|
|
- {
|
|
|
- if (screen.ScreenType == EOrderScreenType.Seat)
|
|
|
- {
|
|
|
- visitDetail.SeatEvaluate = ESeatEvaluate.DefaultSatisfied;
|
|
|
- await _orderVisitedDetailRepository.UpdateAsync(visitDetail, cancellationToken);
|
|
|
- }
|
|
|
- else {
|
|
|
- var screenSatisfy = new Kv() { Key = "-1", Value = "视为满意" };
|
|
|
- visitDetail.OrgProcessingResults = screenSatisfy;
|
|
|
- visitDetail.OrgNoSatisfiedReason = new List<Kv>();
|
|
|
- //visitDetail.OrgHandledAttitude = screenSatisfy;
|
|
|
- await _orderVisitedDetailRepository.UpdateAsync(visitDetail, cancellationToken);
|
|
|
- // 修改主表当前评价结果
|
|
|
- await _orderVisitRepository.Updateable().SetColumns(v => new OrderVisit() { NowEvaluate = screenSatisfy }).Where(v => v.Id == visitDetail.VisitId).ExecuteCommandAsync(cancellationToken);
|
|
|
- //获取回访信息
|
|
|
- var visit = await _orderVisitRepository.Queryable().Includes(x => x.Order)
|
|
|
- .Includes(x => x.OrderVisitDetails)
|
|
|
- .Where(x => x.Id == screen.VisitId).FirstAsync(cancellationToken);
|
|
|
- if (visit != null)
|
|
|
- {
|
|
|
- //获取回访明细
|
|
|
- var visitDe = visit.OrderVisitDetails.First(x => x.Id == screen.VisitDetailId);
|
|
|
- //推省上
|
|
|
- await _capPublisher.PublishAsync(Hotline.Share.Mq.EventNames.HotlineOrderScreenApplyed,
|
|
|
- new PublishVisitDto()
|
|
|
- {
|
|
|
- Order = _mapper.Map<OrderDto>(visit.Order),
|
|
|
- No = visit.No,
|
|
|
- VisitType = visit.VisitType,
|
|
|
- VisitName = visit.CreatorName,
|
|
|
- VisitTime = visit.VisitTime,
|
|
|
- VisitRemark = string.IsNullOrEmpty(visitDe.VisitContent) ? screenSatisfy.Value : visitDe.VisitContent,
|
|
|
- AreaCode = visit.Order.AreaCode!,
|
|
|
- SubjectResultSatifyCode = visitDe.OrgProcessingResults?.Key,
|
|
|
- FirstSatisfactionCode = visit.Order.FirstVisitResultCode!,
|
|
|
- ClientGuid = ""
|
|
|
- });
|
|
|
+ /// <summary>Handles a notification</summary>
|
|
|
+ /// <param name="notification">The notification</param>
|
|
|
+ /// <param name="cancellationToken">Cancellation token</param>
|
|
|
+ public async Task Handle(EndWorkflowNotify notification, CancellationToken cancellationToken)
|
|
|
+ {
|
|
|
+ if (notification.Workflow.ModuleCode == WorkflowModuleConsts.OrderScreen)
|
|
|
+ {
|
|
|
+ var workflow = notification.Workflow;
|
|
|
+ //审批是否通过
|
|
|
+ var isReviewPass = workflow.IsReviewPass();
|
|
|
|
|
|
- //推门户
|
|
|
- await _capPublisher.PublishAsync(Hotline.Share.Mq.EventNames.HotlineOrderVisitedWeb, new PublishVisitAllDto()
|
|
|
- {
|
|
|
- Id = visit.Id,
|
|
|
- Order = _mapper.Map<OrderDto>(visit.Order),
|
|
|
- OrderVisitDetails = _mapper.Map<List<VisitDetailDto>>(visit.OrderVisitDetails),
|
|
|
- VisitName = visit.CreatorName,
|
|
|
- VisitTime = visit.VisitTime,
|
|
|
- VisitType = visit.VisitType,
|
|
|
- VisitState = visit.VisitState,
|
|
|
- PublishTime = visit.PublishTime,
|
|
|
- }, cancellationToken: cancellationToken);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- screen.Status = EScreenStatus.Refuse;
|
|
|
- screen.ReplyContent = workflow.ActualOpinion;
|
|
|
- }
|
|
|
- await _orderRepository.OrderScreenRevisionVisit(screen.VisitId, true, cancellationToken);
|
|
|
- screen.NewestAuditTime = DateTime.Now;
|
|
|
- await _orderScreenRepository.UpdateAsync(screen, cancellationToken);
|
|
|
- OrderScreenDetail detail = new OrderScreenDetail
|
|
|
- {
|
|
|
- ScreenId = screen.Id
|
|
|
- };
|
|
|
- detail.Audit(_sessionContext.UserId, _sessionContext.UserName, _sessionContext.OrgId, _sessionContext.OrgName, 1);
|
|
|
- await _orderScreenDetailRepository.AddAsync(detail, cancellationToken);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
+ var screen = await _orderScreenRepository.GetAsync(workflow.ExternalId, cancellationToken);
|
|
|
+ if (screen != null)
|
|
|
+ {
|
|
|
+ screen.Flowed(workflow.FlowedUserIds, workflow.FlowedOrgIds, workflow.HandlerUsers, workflow.HandlerOrgs);
|
|
|
+ if (isReviewPass)
|
|
|
+ {
|
|
|
+ screen.Status = EScreenStatus.End;
|
|
|
+ screen.ReplyContent = workflow.ActualOpinion;
|
|
|
+ //await _orderScreenRepository.UpdateAsync(screen, cancellationToken);
|
|
|
+ var visitDetail =
|
|
|
+ await _orderVisitedDetailRepository.GetAsync(screen.VisitDetailId, cancellationToken);
|
|
|
+ if (visitDetail != null)
|
|
|
+ {
|
|
|
+ if (screen.ScreenType == EOrderScreenType.Seat)
|
|
|
+ {
|
|
|
+ visitDetail.SeatEvaluate = ESeatEvaluate.DefaultSatisfied;
|
|
|
+ await _orderVisitedDetailRepository.UpdateAsync(visitDetail, cancellationToken);
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ var screenSatisfy = new Kv() { Key = "-1", Value = "视为满意" };
|
|
|
+ visitDetail.OrgProcessingResults = screenSatisfy;
|
|
|
+ if (_appOptions.Value.IsYiBin)
|
|
|
+ visitDetail.OrgNoSatisfiedReason = new List<Kv>();
|
|
|
+
|
|
|
+ //visitDetail.OrgHandledAttitude = screenSatisfy;
|
|
|
+ await _orderVisitedDetailRepository.UpdateAsync(visitDetail, cancellationToken);
|
|
|
+ // 修改主表当前评价结果
|
|
|
+ await _orderVisitRepository.Updateable().SetColumns(v => new OrderVisit() { NowEvaluate = screenSatisfy }).Where(v => v.Id == visitDetail.VisitId).ExecuteCommandAsync(cancellationToken);
|
|
|
+ //获取回访信息
|
|
|
+ var visit = await _orderVisitRepository.Queryable().Includes(x => x.Order)
|
|
|
+ .Includes(x => x.OrderVisitDetails)
|
|
|
+ .Where(x => x.Id == screen.VisitId).FirstAsync(cancellationToken);
|
|
|
+ if (visit != null)
|
|
|
+ {
|
|
|
+ //获取回访明细
|
|
|
+ var visitDe = visit.OrderVisitDetails.First(x => x.Id == screen.VisitDetailId);
|
|
|
+ //推省上
|
|
|
+ await _capPublisher.PublishAsync(Hotline.Share.Mq.EventNames.HotlineOrderScreenApplyed,
|
|
|
+ new PublishVisitDto()
|
|
|
+ {
|
|
|
+ Order = _mapper.Map<OrderDto>(visit.Order),
|
|
|
+ No = visit.No,
|
|
|
+ VisitType = visit.VisitType,
|
|
|
+ VisitName = visit.CreatorName,
|
|
|
+ VisitTime = visit.VisitTime,
|
|
|
+ VisitRemark = string.IsNullOrEmpty(visitDe.VisitContent) ? screenSatisfy.Value : visitDe.VisitContent,
|
|
|
+ AreaCode = visit.Order.AreaCode!,
|
|
|
+ SubjectResultSatifyCode = visitDe.OrgProcessingResults?.Key,
|
|
|
+ FirstSatisfactionCode = visit.Order.FirstVisitResultCode!,
|
|
|
+ ClientGuid = ""
|
|
|
+ });
|
|
|
+
|
|
|
+ //推门户
|
|
|
+ await _capPublisher.PublishAsync(Hotline.Share.Mq.EventNames.HotlineOrderVisitedWeb, new PublishVisitAllDto()
|
|
|
+ {
|
|
|
+ Id = visit.Id,
|
|
|
+ Order = _mapper.Map<OrderDto>(visit.Order),
|
|
|
+ OrderVisitDetails = _mapper.Map<List<VisitDetailDto>>(visit.OrderVisitDetails),
|
|
|
+ VisitName = visit.CreatorName,
|
|
|
+ VisitTime = visit.VisitTime,
|
|
|
+ VisitType = visit.VisitType,
|
|
|
+ VisitState = visit.VisitState,
|
|
|
+ PublishTime = visit.PublishTime,
|
|
|
+ }, cancellationToken: cancellationToken);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ screen.Status = EScreenStatus.Refuse;
|
|
|
+ screen.ReplyContent = workflow.ActualOpinion;
|
|
|
+ }
|
|
|
+ await _orderRepository.OrderScreenRevisionVisit(screen.VisitId, true, cancellationToken);
|
|
|
+ screen.NewestAuditTime = DateTime.Now;
|
|
|
+ await _orderScreenRepository.UpdateAsync(screen, cancellationToken);
|
|
|
+ OrderScreenDetail detail = new OrderScreenDetail
|
|
|
+ {
|
|
|
+ ScreenId = screen.Id
|
|
|
+ };
|
|
|
+ detail.Audit(_sessionContext.UserId, _sessionContext.UserName, _sessionContext.OrgId, _sessionContext.OrgName, 1);
|
|
|
+ await _orderScreenDetailRepository.AddAsync(detail, cancellationToken);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|
