|
@@ -50,7 +50,7 @@ public class WorkflowEndHandler : INotificationHandler<EndWorkflowNotify>
|
|
|
private readonly ICalcExpireTime _expireTime;
|
|
|
private readonly IRepository<OrderTerminate> _orderTerminateRepository;
|
|
|
|
|
|
- public WorkflowEndHandler(
|
|
|
+ public WorkflowEndHandler(
|
|
|
IMapper mapper,
|
|
|
IKnowledgeDomainService knowledgeDomainService,
|
|
|
IOrderDomainService orderDomainService,
|
|
@@ -106,8 +106,8 @@ public class WorkflowEndHandler : INotificationHandler<EndWorkflowNotify>
|
|
|
case WorkflowModuleConsts.KnowledgeUpdate://修改知识库
|
|
|
case WorkflowModuleConsts.KnowledgeDelete://删除知识库
|
|
|
case WorkflowModuleConsts.KnowledgeOffshelf: //下架知识库
|
|
|
- //var knowledgeWork = await _knowledgeWorkFlowRepository.Queryable().Where(x => x.Id == workflow.ExternalId).FirstAsync(cancellationToken);
|
|
|
- var knowledge = await _knowledgeRepository.Queryable().Where(x => x.Id == workflow.ExternalId).FirstAsync(cancellationToken);
|
|
|
+ //var knowledgeWork = await _knowledgeWorkFlowRepository.Queryable().Where(x => x.Id == workflow.ExternalId).FirstAsync(cancellationToken);
|
|
|
+ var knowledge = await _knowledgeRepository.Queryable().Where(x => x.Id == workflow.ExternalId).FirstAsync(cancellationToken);
|
|
|
knowledge.Flowed(workflow.FlowedUserIds, workflow.FlowedOrgIds, workflow.HandlerUsers, workflow.HandlerOrgs);
|
|
|
await _knowledgeRepository.UpdateAsync(knowledge, cancellationToken);
|
|
|
if (isReviewPass)
|
|
@@ -230,6 +230,16 @@ public class WorkflowEndHandler : INotificationHandler<EndWorkflowNotify>
|
|
|
|
|
|
//这里需要判断是否是警情退回
|
|
|
orderFlowDto.IsNonPoliceReturn = notification.Dto.External == null ? false : notification.Dto.External.IsPoliceReturn;
|
|
|
+
|
|
|
+ //如果是泸州,这里需要查询是否有工单延期
|
|
|
+ if (_appOptions.Value.IsLuZhou)
|
|
|
+ {
|
|
|
+ var orderDelay = await _orderDelayRepository.Queryable().Where(p => p.OrderId == order.Id && p.DelayState == EDelayState.Pass)
|
|
|
+ .OrderByDescending(p => p.ApplyDelayTime)
|
|
|
+ .FirstAsync();
|
|
|
+ orderFlowDto.OrderSearchDelay = _mapper.Map<OrderSearchDelayDto>(orderDelay);
|
|
|
+ }
|
|
|
+
|
|
|
await _capPublisher.PublishAsync(Hotline.Share.Mq.EventNames.HotlineOrderFiled, orderFlowDto, cancellationToken: cancellationToken);
|
|
|
await _publisher.PublishAsync(new SnapshotOrderFiledNotification(order.Id), PublishStrategy.ParallelWhenAll, cancellationToken);
|
|
|
await _orderDomainService.OrderAutomaticPublishAsync(order, cancellationToken);
|