OrderDomainService.cs 39 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902
  1. using DotNetCore.CAP;
  2. using Hotline.Caching.Interfaces;
  3. using Hotline.Share.Dtos.Order;
  4. using Hotline.Share.Enums.Order;
  5. using MapsterMapper;
  6. using Microsoft.Extensions.Logging;
  7. using XF.Domain.Authentications;
  8. using XF.Domain.Cache;
  9. using XF.Domain.Dependency;
  10. using XF.Domain.Exceptions;
  11. using XF.Domain.Repository;
  12. using Hotline.CallCenter.Calls;
  13. using Hotline.File;
  14. using Hotline.FlowEngine.Workflows;
  15. using Hotline.Schedulings;
  16. using Hotline.SeedData;
  17. using Hotline.Users;
  18. using Hotline.Share.Dtos;
  19. using Hotline.Settings.Hotspots;
  20. using Hotline.Share.Dtos.FlowEngine;
  21. using Microsoft.AspNetCore.Http;
  22. using Hotline.Settings;
  23. using SqlSugar;
  24. using Hotline.Push.Notifies;
  25. using Hotline.Share.Enums.Push;
  26. using MediatR;
  27. using Hotline.Authentications;
  28. using Hotline.ContingencyManagement.Notifies;
  29. using Hotline.EventBus;
  30. using Hotline.Share.Enums.FlowEngine;
  31. using Mapster;
  32. using Microsoft.AspNetCore.Builder.Extensions;
  33. using Hotline.Configurations;
  34. using Microsoft.Extensions.Options;
  35. using Hotline.Share.Tools;
  36. using Hotline.Orders.Notifications;
  37. using Hotline.Share.Mq;
  38. namespace Hotline.Orders;
  39. public class OrderDomainService : IOrderDomainService, IScopeDependency
  40. {
  41. private readonly IOrderRepository _orderRepository;
  42. private readonly IRepository<OrderRedo> _orderRedoRepository;
  43. private readonly IRepository<OrderPublish> _orderPublishRepository;
  44. private readonly IRepository<OrderVisit> _orderVisitRepository;
  45. private readonly IRepository<OrderExtension> _orderExtensionRepository;
  46. private readonly IRepository<OrderComplement> _orderComplementRepository;
  47. private readonly ITypedCache<CacheOrderNO> _cacheOrderNo;
  48. private readonly ISessionContext _sessionContext;
  49. private readonly ICapPublisher _capPublisher;
  50. private readonly IRepository<OrderVisitDetail> _orderVisitDetailRepository;
  51. private readonly IMapper _mapper;
  52. private readonly ILogger<OrderDomainService> _logger;
  53. private readonly IFileRepository _fileRepository;
  54. private readonly IRepository<Scheduling> _schedulingRepository;
  55. private readonly Publisher _publisher;
  56. private readonly IOptionsSnapshot<AppConfiguration> _appOptions;
  57. private readonly IRepository<User> _userRepository;
  58. private readonly ISystemSettingCacheManager _systemSettingCacheManager;
  59. private readonly IWorkflowDomainService _workflowDomainService;
  60. private readonly IRepository<Hotspot> _hotspotRepository;
  61. private readonly IMediator _mediator;
  62. private readonly IRepository<WorkflowStep> _workflowStepRepository;
  63. private readonly ISystemLogRepository _systemLogRepository;
  64. public OrderDomainService(
  65. IOrderRepository orderRepository,
  66. IRepository<OrderRedo> orderRedoRepository,
  67. IRepository<OrderPublish> orderPublishRepository,
  68. IRepository<OrderVisit> orderVisitRepository,
  69. IRepository<OrderExtension> orderExtensionRepository,
  70. IRepository<OrderComplement> orderComplementRepository,
  71. ITypedCache<CacheOrderNO> cacheOrderNo,
  72. ISessionContext sessionContext,
  73. ICapPublisher capPublisher,
  74. IMapper mapper,
  75. ILogger<OrderDomainService> logger,
  76. IFileRepository fileRepository,
  77. IRepository<WexCallRecord> wexCallRecordRepository,
  78. IRepository<User> userRepository,
  79. ISystemSettingCacheManager systemSettingCacheManager,
  80. IRepository<Scheduling> schedulingRepository,
  81. IWorkflowDomainService workflowDomainService,
  82. IRepository<Hotspot> hotspotRepository,
  83. IMediator mediator,
  84. Publisher publisher,
  85. IRepository<OrderVisitDetail> orderVisitDetailRepository,
  86. IRepository<WorkflowStep> workflowStepRepository,
  87. ISystemLogRepository systemLogRepository,
  88. IOptionsSnapshot<AppConfiguration> appOptions)
  89. {
  90. _orderRepository = orderRepository;
  91. _orderRedoRepository = orderRedoRepository;
  92. _orderPublishRepository = orderPublishRepository;
  93. _orderVisitRepository = orderVisitRepository;
  94. _orderExtensionRepository = orderExtensionRepository;
  95. _orderComplementRepository = orderComplementRepository;
  96. _cacheOrderNo = cacheOrderNo;
  97. _sessionContext = sessionContext;
  98. _capPublisher = capPublisher;
  99. _mapper = mapper;
  100. _logger = logger;
  101. _fileRepository = fileRepository;
  102. _userRepository = userRepository;
  103. _schedulingRepository = schedulingRepository;
  104. _systemSettingCacheManager = systemSettingCacheManager;
  105. _workflowDomainService = workflowDomainService;
  106. _hotspotRepository = hotspotRepository;
  107. _mediator = mediator;
  108. _publisher = publisher;
  109. _orderVisitDetailRepository = orderVisitDetailRepository;
  110. _workflowStepRepository = workflowStepRepository;
  111. _systemLogRepository = systemLogRepository;
  112. _appOptions = appOptions;
  113. }
  114. /// <summary>
  115. /// 归档后自动发布
  116. /// </summary>
  117. /// <param name="order"></param>
  118. /// <param name="cancellationToken"></param>
  119. /// <returns></returns>
  120. public async Task OrderAutomaticPublishAsync(Order order, CancellationToken cancellationToken)
  121. {
  122. var name = "中心直办件归档后默认自动发布";
  123. var msg = $"OrderId: {order.Id}, No: {order.No}";
  124. try
  125. {
  126. if (_systemSettingCacheManager.AutomaticPublishOrder == false)
  127. {
  128. return;
  129. }
  130. var checkResult = order.AutoPublishCheck();
  131. if (checkResult.NotNullOrEmpty())
  132. {
  133. _systemLogRepository.Add(name, msg, checkResult);
  134. return;
  135. }
  136. if (order.FileOrgIsCenter == null || order.FileOrgIsCenter == false)
  137. {
  138. _systemLogRepository.Add(name, msg, "非中心直办件");
  139. return;
  140. }
  141. await OrderPublishAsync(order, cancellationToken);
  142. }
  143. catch (Exception e)
  144. {
  145. _systemLogRepository.Add(name, msg, $"系统异常: {e.Message}");
  146. }
  147. }
  148. public async Task OrderPublishAsync(Order order, CancellationToken cancellationToken)
  149. {
  150. OrderPublish orderPublish = new()
  151. {
  152. OrderId = order.Id,
  153. No = order.No,
  154. PublishState = false, //当前写死为false
  155. ArrangeTitle = order.Title,
  156. ArrangeContent = order.Content,
  157. ArrangeOpinion = order.FileOpinion,
  158. ProPublishState = false,
  159. FeedBackPhone = order.Contact,
  160. CreatorName = _sessionContext.UserName
  161. };
  162. var id = await _orderPublishRepository.AddAsync(orderPublish, cancellationToken);
  163. order.Publish(orderPublish.PublishState);
  164. await _orderRepository.UpdateAsync(order, cancellationToken);
  165. //推省上
  166. var publishPublishOrder = orderPublish.Adapt<PublishPublishOrderDto>();
  167. publishPublishOrder.Order = order.Adapt<OrderDto>();
  168. //查询实际办理附件
  169. if (!string.IsNullOrEmpty(order.ActualHandleStepId))
  170. {
  171. var actualHandleStep = await _workflowStepRepository.GetAsync(order.ActualHandleStepId, cancellationToken);
  172. publishPublishOrder.FileJsons = actualHandleStep?.FileJson;
  173. }
  174. await _capPublisher.PublishAsync(Hotline.Share.Mq.EventNames.HotlineOrderPublishOrder, publishPublishOrder, cancellationToken: cancellationToken);
  175. //推应急管理局
  176. //是否开启
  177. var isOpenContingencyManagement =
  178. _systemSettingCacheManager.GetSetting(SettingConstants.IsOpenContingencyManagement)?.SettingValue[0];
  179. if (isOpenContingencyManagement == "true")
  180. await _publisher.PublishAsync(new ContingencyManagementNotify(order, order.Title, order.Content, order.ActualOpinion),
  181. PublishStrategy.ParallelWhenAll, cancellationToken);
  182. // 取消发布的工单数量
  183. var orderPublishDeletedCount = await _orderPublishRepository.Queryable(includeDeleted: true)
  184. .Where(m => m.OrderId == order.Id && m.IsDeleted == true)
  185. .CountAsync(cancellationToken);
  186. var orderVisitVisitedCount = await _orderVisitRepository.Queryable()
  187. .Where(m => m.OrderId == order.Id && m.VisitState == EVisitState.Visited)
  188. .CountAsync(cancellationToken);
  189. // 若取消发布的工单,已经被回访过了,没有经过重新办理,再次发布后,自动跳过回访环节,展示取消发布前的回访结果
  190. if (orderPublishDeletedCount != 0 && orderVisitVisitedCount != 0)
  191. {
  192. return;
  193. }
  194. var orderVisit = new OrderVisit
  195. {
  196. No = order.No,
  197. OrderId = order.Id,
  198. VisitState = EVisitState.WaitForVisit,
  199. PublishTime = DateTime.Now,
  200. IsCanHandle = true,
  201. EmployeeId = _sessionContext.RequiredUserId
  202. };
  203. if (!order.IsProvince)
  204. {
  205. orderVisit.EmployeeId = _sessionContext.RequiredUserId;
  206. }
  207. if (_appOptions.Value.IsZiGong)
  208. {
  209. orderVisit.EmployeeId = string.Empty;
  210. }
  211. if (order is { FileOrgIsCenter:true, CounterSignType: null } && !order.IsProvince)
  212. {
  213. orderVisit.VisitState = EVisitState.Visited;
  214. orderVisit.VisitTime = DateTime.Now;
  215. orderVisit.VisitType = EVisitType.OtherVisit;
  216. orderVisit.NowEvaluate = new Kv() { Key = "4", Value = "满意" };
  217. if (_appOptions.Value.IsZiGong)
  218. {
  219. // 根据禅道 自贡需求 Id_361, 第一条, 3小条需求;
  220. // 直办件归档后自动回访量需统计在“胡玲”的默认回访量中;
  221. orderVisit.EmployeeId = _systemSettingCacheManager.DefaultVisitEmployeeId;
  222. }
  223. }
  224. if (order.CounterSignType != ECounterSignType.Center)
  225. {
  226. orderVisit.IsCanAiVisit = true;
  227. }
  228. string visitId = await _orderVisitRepository.AddAsync(orderVisit);
  229. //新增回访信息
  230. var visitedDetail = new List<OrderVisitDetail>();
  231. var seatDetail = new OrderVisitDetail();
  232. seatDetail.VisitId = visitId;
  233. seatDetail.VisitTarget = EVisitTarget.Seat;
  234. var orgDetail = new OrderVisitDetail();
  235. orgDetail.VisitId = visitId;
  236. orgDetail.VisitOrgCode = order.ActualHandleOrgCode;
  237. orgDetail.VisitOrgName = order.ActualHandleOrgName;
  238. orgDetail.VisitTarget = EVisitTarget.Org;
  239. if (order is { FileOrgIsCenter:true , CounterSignType: null, IsProvince: false })
  240. {
  241. var satisfy = new Kv() { Key = "4", Value = "满意" };
  242. orgDetail.OrgProcessingResults = satisfy;
  243. //orgDetail.OrgHandledAttitude = satisfy;
  244. }
  245. visitedDetail.Add(orgDetail);
  246. if (order is { FileOrgIsCenter:true, CounterSignType: null })
  247. {
  248. seatDetail.VoiceEvaluate = EVoiceEvaluate.Satisfied;
  249. seatDetail.SeatEvaluate = ESeatEvaluate.Satisfied;
  250. order.Visited("4", "满意");
  251. order.Status = EOrderStatus.Visited;
  252. await _orderRepository.UpdateAsync(order, cancellationToken);
  253. }
  254. visitedDetail.Add(seatDetail);
  255. await _orderVisitDetailRepository.AddRangeAsync(visitedDetail, cancellationToken);
  256. await _publisher.PublishAsync(new ContingencyManagementNotify(order, order.Title, order.Content, order.ActualOpinion),
  257. PublishStrategy.ParallelWhenAll, cancellationToken);
  258. //handle publish trace
  259. var acceptor = new UserInfo(orderPublish.CreatorId, orderPublish.CreatorName,
  260. orderPublish.CreatorOrgId, orderPublish.CreatorOrgName);
  261. var handler = new UserInfo(orderPublish.CreatorId, orderPublish.CreatorName,
  262. orderPublish.CreatorOrgId, orderPublish.CreatorOrgName);
  263. //上面回访人取值当前操作人,所以暂时可取值SessionContext,如需求有变需取值ordervisit中指定的回访人
  264. var visitAcceptor = string.IsNullOrEmpty(orderVisit.EmployeeId)
  265. ? new UserInfo()
  266. : new UserInfo(_sessionContext.UserId, _sessionContext.UserName, _sessionContext.OrgId,
  267. _sessionContext.OrgName, _sessionContext.OrgIsCenter);
  268. await _workflowDomainService.HandlePublishTraceAsync(order.WorkflowId, orderPublish.Id, acceptor, handler,
  269. orderPublish.CreationTime, visitAcceptor, orderVisit.Id, cancellationToken);
  270. //需求251 某些工单需自动发送短信
  271. //任何类型的省工单都不需要发送短信
  272. var isOpenSendEndSms = _systemSettingCacheManager.GetSetting(SettingConstants.IsOpenSendEndSms)?.SettingValue[0];
  273. if (isOpenSendEndSms == "true")
  274. {
  275. try
  276. {
  277. if (order.Source != ESource.ProvinceStraight && order.FileOrgIsCenter.Value == false)
  278. {
  279. var code = "";
  280. //受理类型为“投诉、举报”
  281. if ((order.AcceptTypeCode == "30" || order.AcceptTypeCode == "35") && orderVisit.VisitState != EVisitState.Visited)
  282. {
  283. code = "1017";
  284. orderVisit.VisitState = EVisitState.SMSVisiting;
  285. await _orderVisitRepository.UpdateAsync(orderVisit);
  286. }
  287. else
  288. code = "1018";
  289. //发送查询短信
  290. var messageDto = new Share.Dtos.Push.MessageDto
  291. {
  292. PushBusiness = EPushBusiness.SearchSms,
  293. ExternalId = visitId,
  294. OrderId = order.Id,
  295. PushPlatform = EPushPlatform.Sms,
  296. Remark = order.Title,
  297. Name = order.FromName,
  298. TemplateCode = code,
  299. Params = new List<string>() { order.No, order.Password },
  300. TelNumber = order.Contact,
  301. };
  302. await _mediator.Publish(new PushMessageNotify(messageDto), cancellationToken);
  303. // 发送短信后推送一个 48小时的延迟消息队列. 当消息队列收到消息时, 判断用户是否回复了, 如果未回复短信就 默认满意
  304. var delaySecond = _systemSettingCacheManager.DefaultVisitSmsDelaySecond;
  305. await _capPublisher.PublishDelayAsync(
  306. TimeSpan.FromSeconds(delaySecond),
  307. EventNames.UpdateVisitDelaySms,
  308. messageDto,
  309. cancellationToken: cancellationToken);
  310. }
  311. }
  312. catch (Exception)
  313. {
  314. }
  315. }
  316. if (order.IsProvince == false && orderVisit.VisitState == EVisitState.Visited)
  317. {
  318. //推省上
  319. await _capPublisher.PublishAsync(Hotline.Share.Mq.EventNames.HotlineOrderVisited,
  320. new PublishVisitDto()
  321. {
  322. Order = order.Adapt<OrderDto>(),
  323. No = orderVisit.No,
  324. VisitType = orderVisit.VisitType,
  325. VisitName = orderVisit.CreatorName,
  326. VisitTime = orderVisit.VisitTime,
  327. VisitRemark = orderVisit.NowEvaluate?.Value,
  328. AreaCode = order.AreaCode!,
  329. SubjectResultSatifyCode = orderVisit.NowEvaluate?.Key,
  330. FirstSatisfactionCode = orderVisit.NowEvaluate?.Key,
  331. ClientGuid = ""
  332. }, cancellationToken: cancellationToken);
  333. }
  334. //推门户
  335. await _capPublisher.PublishAsync(Hotline.Share.Mq.EventNames.HotlineOrderVisitedWeb, new PublishVisitAllDto()
  336. {
  337. Id = orderVisit.Id,
  338. Order = order.Adapt<OrderDto>(),
  339. OrderVisitDetails = orderVisit.OrderVisitDetails.Adapt<List<VisitDetailDto>>(),
  340. VisitName = _sessionContext.UserName,
  341. VisitTime = orderVisit.VisitTime,
  342. VisitType = orderVisit.VisitType,
  343. VisitState = orderVisit.VisitState,
  344. PublishTime = orderVisit.PublishTime,
  345. }, cancellationToken: cancellationToken);
  346. }
  347. /// <summary>
  348. /// 重办和退回工单时如果有取消发布的工单, 清除回访待办和回访列表中的数据
  349. /// </summary>
  350. /// <param name="orderId"></param>
  351. /// <param name="cancellationToken"></param>
  352. /// <returns></returns>
  353. public async Task VisitNoneByCancelPublishAsync(string orderId, CancellationToken cancellationToken)
  354. {
  355. var cancelPublishOrderEnabled = _systemSettingCacheManager.CancelPublishOrderEnabled;
  356. // 取消发布的工单数量
  357. var orderPublishDeletedCount = await _orderPublishRepository.Queryable(includeDeleted: true)
  358. .Where(m => m.OrderId == orderId && m.IsDeleted == true)
  359. .CountAsync(cancellationToken);
  360. if (orderPublishDeletedCount == 0 || cancelPublishOrderEnabled == false) return;
  361. var visit = await _orderVisitRepository.GetAsync(x => x.OrderId == orderId && x.VisitState != EVisitState.None, cancellationToken);
  362. if (visit != null)
  363. {
  364. visit.VisitState = EVisitState.None;
  365. await _orderVisitRepository.UpdateAsync(visit, cancellationToken);
  366. }
  367. }
  368. public async Task<Order> GetOrderAsync(string? orderId, bool withHotspot = false, bool withAcceptor = false,
  369. bool withExtension = false, CancellationToken cancellationToken = default)
  370. {
  371. if (string.IsNullOrEmpty(orderId))
  372. throw UserFriendlyException.SameMessage("无效工单编号");
  373. var query = _orderRepository.Queryable();
  374. if (withHotspot)
  375. query = query.Includes(d => d.Hotspot);
  376. if (withAcceptor)
  377. query = query.Includes(d => d.Acceptor);
  378. if (withExtension)
  379. query = query.Includes(d => d.OrderExtension);
  380. var order = await query.FirstAsync(d => d.Id == orderId, cancellationToken);
  381. if (order == null)
  382. throw new UserFriendlyException($"无效工单编号, orderId: {orderId}", "无效工单编号");
  383. return order;
  384. }
  385. public async Task<string> AddAsync(Order order, bool autoAccept = false, CancellationToken cancellationToken = default)
  386. {
  387. if (autoAccept)
  388. {
  389. order.AutoAccept(_sessionContext.RequiredUserId, _sessionContext.UserName, _sessionContext.StaffNo);
  390. order.Sign(_sessionContext.RequiredUserId, _sessionContext.UserName);
  391. }
  392. order.Init();
  393. order.No = GenerateNewOrderNo();
  394. if (order.Source == ESource.Police110)
  395. {
  396. order.Title = @"(非警情工单-" + order.No.Substring(order.No.Length - 6) + ")";
  397. }
  398. order.Password = Random.Shared.Next(100000, 1000000).ToString();
  399. order.ProvinceNo = string.IsNullOrEmpty(order.ProvinceNo) ? GenerateNewProvinceNo(order.No, order.SourceChannelCode) : order.ProvinceNo;
  400. return await _orderRepository.AddOrderNavAsync(order, cancellationToken);
  401. }
  402. /// <summary>
  403. /// 撤回或跳转前处理数据及校验
  404. /// <remarks>
  405. ///工单撤回时需校验工单当前是否存在待发布记录、待回访记录,若存在需删除对应记录(跳转同理)
  406. ///工单撤回时需校验工单是否存在甄别中记录,若存在不允许撤回当前工单(跳转同理)
  407. /// </remarks>
  408. /// </summary>
  409. public async Task ReadyToRecallAsync(string orderId, CancellationToken cancellationToken)
  410. {
  411. var order = await _orderRepository.Queryable()
  412. .Includes(d => d.OrderPublish)
  413. .Includes(d => d.OrderVisits.Where(d => d.VisitState == EVisitState.WaitForVisit))
  414. .Includes(d => d.OrderScreens)
  415. .FirstAsync(d => d.Id == orderId, cancellationToken);
  416. if (order.OrderScreens.Any())
  417. throw UserFriendlyException.SameMessage("已甄别工单无法撤回或跳转");
  418. //todo 需求调整:P72, 4,5,6,7,8,9,10
  419. if (order.OrderPublish is not null)
  420. await _orderPublishRepository.RemoveAsync(order.OrderPublish, cancellationToken: cancellationToken);
  421. if (order.OrderVisits.Any())
  422. await _orderVisitRepository.RemoveNav(order.OrderVisits)
  423. .Include(d => d.OrderVisitDetails)
  424. .ExecuteCommandAsync();
  425. }
  426. public Task<string> AddOrderRedoAsync(OrderRedo orderRedo, CancellationToken cancellationToken) =>
  427. _orderRedoRepository.AddAsync(orderRedo, cancellationToken);
  428. public Task RemoveOrderRedoAsync(string id, CancellationToken cancellationToken) =>
  429. _orderRedoRepository.RemoveAsync(id, cancellationToken: cancellationToken);
  430. public Task UpdateOrderRedoAsync(OrderRedo orderRedo, CancellationToken cancellationToken) =>
  431. _orderRedoRepository.UpdateAsync(orderRedo, cancellationToken);
  432. #region 工单扩展信息
  433. public async Task<OrderExtension?> GetOrderExtensionsAsync(string provinceNo, CancellationToken cancellationToken) =>
  434. await _orderExtensionRepository.GetAsync(d => d.ProvinceNo == provinceNo, cancellationToken);
  435. public Task UpdateExtensionAsync(OrderExtension orderExtension, CancellationToken cancellationToken) =>
  436. _orderExtensionRepository.UpdateAsync(orderExtension, cancellationToken);
  437. /// <summary>
  438. /// 新增工单扩展信息
  439. /// </summary>
  440. public async Task AddExtensionAsync(OrderExtension extension, CancellationToken cancellationToken) =>
  441. await _orderExtensionRepository.AddAsync(extension, cancellationToken);
  442. /// <summary>
  443. /// 新增工单补充信息
  444. /// </summary>
  445. public async Task<string> AddOrderComplementAsync(AddOrderComplementDto dto, CancellationToken cancellationToken)
  446. {
  447. var complement = _mapper.Map<OrderComplement>(dto);
  448. complement.InitId();
  449. if (dto.Files.Any()) complement.FileJson = await _fileRepository.AddFileAsync(dto.Files, complement.Id, "", cancellationToken);
  450. return await _orderComplementRepository.AddAsync(complement, cancellationToken);
  451. }
  452. #endregion
  453. /// <summary>
  454. /// 验证是否是管理员
  455. /// </summary>
  456. /// <returns></returns>
  457. public bool IsCheckAdmin()
  458. {
  459. var systemAdministrator = _systemSettingCacheManager.GetSetting(SettingConstants.SystemAdministrator)?.SettingValue[0];
  460. if (!string.IsNullOrEmpty(systemAdministrator) && (_sessionContext.Roles.Contains(systemAdministrator) || _sessionContext.Roles.Contains(RoleSeedData.AdminRole)))
  461. return true;
  462. else
  463. return false;
  464. }
  465. #region 平均派单
  466. /// <summary>
  467. /// 平均派单
  468. /// </summary>
  469. /// <returns></returns>
  470. public async Task<FlowStepHandler> AverageOrder(CancellationToken cancellationToken)
  471. {
  472. var time = DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd"));
  473. var scheduling = await _schedulingRepository.Queryable().Includes(x => x.SchedulingUser)
  474. .Where(x => x.SchedulingTime == time && x.WorkingTime <= DateTime.Now.TimeOfDay && x.OffDutyTime >= DateTime.Now.TimeOfDay && x.AtWork == true)
  475. .OrderBy(x => x.SendOrderNum).FirstAsync(cancellationToken);
  476. var centerOrgName = _systemSettingCacheManager.GetSetting(SettingConstants.CenterOrgName)?.SettingValue[0];
  477. var roleId = _systemSettingCacheManager.GetSetting(SettingConstants.RolePaiDan)?.SettingValue[0];
  478. if (scheduling is null)
  479. return new FlowStepHandler
  480. {
  481. Key = AppDefaults.SendPoolId,
  482. Value = "待派单池",
  483. UserId = AppDefaults.SendPoolId,
  484. Username = "待派单池",
  485. OrgId = OrgSeedData.CenterId,
  486. OrgName = centerOrgName,
  487. RoleId = roleId,
  488. RoleName = "派单员"
  489. };
  490. scheduling.SendOrderNum++;
  491. await _schedulingRepository.UpdateAsync(scheduling, cancellationToken);
  492. var user = scheduling.SchedulingUser;
  493. return new FlowStepHandler
  494. {
  495. Key = user.UserId,
  496. Value = user.UserName,
  497. UserId = user.UserId,
  498. Username = user.UserName,
  499. OrgId = user.OrgId,
  500. OrgName = user.OrgIdName,
  501. RoleId = roleId,
  502. RoleName = "派单员"
  503. };
  504. }
  505. /// <summary>
  506. /// 登录平均派单
  507. /// </summary>
  508. /// <param name="userId"></param>
  509. /// <returns></returns>
  510. public async Task LogAverageOrder(string userId, Scheduling scheduling, CancellationToken cancellationToken)
  511. {
  512. //1.获取默认派单员所属的工单
  513. //2.获取今天上班的人员
  514. //3.给当前这个用户平均派单
  515. var steps = await _workflowDomainService.GetStepsBelongsToAsync(AppDefaults.SendPoolId,
  516. cancellationToken);
  517. var roleId = _systemSettingCacheManager.GetSetting(SettingConstants.RolePaiDan)?.SettingValue[0];
  518. var user = await _userRepository.Queryable()
  519. .Includes(d => d.Organization)
  520. .FirstAsync(d => d.Id == userId, cancellationToken);
  521. var time = DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd"));
  522. var schedulings = await _schedulingRepository.Queryable().Includes(x => x.SchedulingUser)
  523. .Where(x => x.SchedulingTime == time).CountAsync(cancellationToken);
  524. if (schedulings > 0)
  525. {
  526. var sendNum = steps.Count / schedulings;
  527. scheduling.SendOrderNum += sendNum;
  528. if (!scheduling.LoginSendOrderNum.HasValue)
  529. {
  530. scheduling.LoginSendOrderNum = scheduling.LoginSendOrderNum.HasValue && scheduling.LoginSendOrderNum > sendNum ? scheduling.LoginSendOrderNum : sendNum;
  531. await _schedulingRepository.Updateable()
  532. .SetColumns(s => new Scheduling() { LoginSendOrderNum = scheduling.LoginSendOrderNum })
  533. .Where(s => s.SchedulingTime == scheduling.SchedulingTime).ExecuteCommandAsync(cancellationToken);
  534. }
  535. sendNum = scheduling.LoginSendOrderNum.Value;
  536. await _schedulingRepository.Updateable()
  537. .SetColumns(s => new Scheduling() { SendOrderNum = scheduling.SendOrderNum, AtWork = scheduling.AtWork })
  538. .Where(s => s.Id == scheduling.Id).ExecuteCommandAsync(cancellationToken);
  539. if (sendNum <= 0) return;
  540. var sendSteps = steps.Take(sendNum).ToList();
  541. await _orderRepository.Updateable().SetColumns(o => new Order()
  542. {
  543. CenterToOrgHandlerId = user.OrgId,
  544. CenterToOrgHandlerName = user.Name
  545. }).Where(o => sendSteps.Any(s => s.ExternalId == o.Id)).ExecuteCommandAsync(cancellationToken);
  546. await _workflowDomainService.ChangeHandlerBatchAsync(new List<(string userId, string username, string orgId, string orgName, string? roleId, string? roleName, ICollection<WorkflowStep> steps)>
  547. {
  548. new(user.Id, user.Name, user.OrgId, user.Organization.Name,roleId,"派单员", sendSteps)
  549. }, cancellationToken);
  550. }
  551. }
  552. /// <summary>
  553. /// 触发平均派单
  554. /// </summary>
  555. /// <returns></returns>
  556. public async Task TriggerAverageOrder(CancellationToken cancellationToken)
  557. {
  558. //1.从排班里面获取今天上班的人
  559. //2.获取默认派单员剩下的工单
  560. //3.平均分配剩下的工单给今天上班的人
  561. DateTime time = DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd"));
  562. var schedulings = await _schedulingRepository.Queryable().Includes(x => x.SchedulingUser)
  563. .Where(x => x.SchedulingTime!.Value == time && x.WorkingTime!.Value <= DateTime.Now.TimeOfDay && x.OffDutyTime!.Value >= DateTime.Now.TimeOfDay && x.AtWork == true)
  564. .OrderBy(x => x.SendOrderNum).ToListAsync(cancellationToken);
  565. var roleId = _systemSettingCacheManager.GetSetting(SettingConstants.RolePaiDan)?.SettingValue[0];
  566. if (schedulings.Any())
  567. {
  568. var steps = await _workflowDomainService.GetStepsBelongsToAsync(AppDefaults.SendPoolId,
  569. cancellationToken);
  570. if (steps.Any())
  571. {
  572. List<(string userId, string username, string orgId, string orgName, string? roleId, string? roleName, ICollection<WorkflowStep> steps)> handlers = new();
  573. var avg = steps.Count / schedulings.Count;
  574. var remaining = steps.Count % schedulings.Count;
  575. var skip = 0;
  576. for (var i = 0; i < schedulings.Count; i++)
  577. {
  578. var scheduling = schedulings[i];
  579. var size = avg + (i < remaining ? 1 : 0);
  580. if (size > 0)
  581. {
  582. var stSteps = steps.Skip(skip).Take(size).ToList();
  583. handlers.Add(new(
  584. scheduling.SchedulingUser.UserId,
  585. scheduling.SchedulingUser.UserName,
  586. scheduling.SchedulingUser.OrgId,
  587. scheduling.SchedulingUser.OrgIdName,
  588. roleId, "派单员",
  589. stSteps));
  590. skip += size;
  591. scheduling.SendOrderNum += size;
  592. await _schedulingRepository.Updateable()
  593. .SetColumns(s => new Scheduling() { SendOrderNum = scheduling.SendOrderNum })
  594. .Where(s => s.Id == scheduling.Id).ExecuteCommandAsync(cancellationToken);
  595. await _orderRepository.Updateable().SetColumns(o => new Order()
  596. {
  597. CenterToOrgHandlerId = scheduling.SchedulingUser.UserId,
  598. CenterToOrgHandlerName = scheduling.SchedulingUser.UserName
  599. })
  600. .Where(o => stSteps.Any(s => s.ExternalId == o.Id)).ExecuteCommandAsync(cancellationToken);
  601. }
  602. }
  603. if (handlers.Any())
  604. await _workflowDomainService.ChangeHandlerBatchAsync(handlers, cancellationToken);
  605. }
  606. }
  607. }
  608. #endregion
  609. #region 工单校验- 交通类工单
  610. /// <summary>
  611. /// 工单校验 - 交通类工单
  612. /// </summary>
  613. /// <returns></returns>
  614. public async Task<OrderValidation> OrderValidation(AddOrderDto dto, CancellationToken cancellationToken)
  615. {
  616. var valid = new OrderValidation { Validation = false, Result = "" };
  617. var hotspot = await _hotspotRepository.GetAsync(dto.HotspotId, cancellationToken);
  618. if (hotspot.TrunkNum.Equals(AppDefaults.TrafficTrunkNum))
  619. {
  620. switch (dto.AcceptTypeCode)
  621. {
  622. //投诉举报
  623. case "30":
  624. case "35":
  625. valid.Validation = dto.Title.Contains("意见") || dto.Title.Contains("建议") || dto.Title.Contains("咨询")
  626. || dto.Content.Contains("意见") || dto.Content.Contains("建议") || dto.Content.Contains("咨询");
  627. if (dto.Content.Length < 25)
  628. {
  629. valid.Validation = true;
  630. valid.Result = "保存失败,受理内容字数不足,需要至少25个字!";
  631. }
  632. break;
  633. // 意见
  634. case "1":
  635. valid.Validation = dto.Title.Contains("投诉") || dto.Title.Contains("举报") || dto.Title.Contains("咨询")
  636. || dto.Content.Contains("投诉") || dto.Content.Contains("举报") || dto.Content.Contains("咨询");
  637. if (dto.Content.Length < 5)
  638. {
  639. valid.Validation = true;
  640. valid.Result = "保存失败,受理内容字数不足,需要至少5个字!";
  641. }
  642. break;
  643. //建议求助
  644. case "15":
  645. case "20":
  646. valid.Validation = dto.Title.Contains("投诉") || dto.Title.Contains("举报") || dto.Title.Contains("咨询")
  647. || dto.Content.Contains("投诉") || dto.Content.Contains("举报") || dto.Content.Contains("咨询");
  648. if (dto.Content.Length < 25)
  649. {
  650. valid.Validation = true;
  651. valid.Result = "保存失败,受理内容字数不足,需要至少25个字!";
  652. }
  653. break;
  654. // 咨询
  655. case "10":
  656. valid.Validation = dto.Title.Contains("投诉") || dto.Title.Contains("举报") || dto.Title.Contains("意见")
  657. || dto.Title.Contains("建议") || dto.Content.Contains("投诉") || dto.Content.Contains("举报") || dto.Content.Contains("意见") || dto.Content.Contains("建议");
  658. if (dto.Content.Length < 5)
  659. {
  660. valid.Validation = true;
  661. valid.Result = "保存失败,受理内容字数不足,需要至少5个字!";
  662. }
  663. break;
  664. // 表扬
  665. case "25":
  666. if (dto.Content.Length < 25)
  667. {
  668. valid.Validation = true;
  669. valid.Result = "保存失败,受理内容字数不足,需要至少25个字!";
  670. }
  671. break;
  672. default:
  673. if (dto.Content.Length < 5)
  674. {
  675. valid.Validation = true;
  676. valid.Result = "保存失败,受理内容字数不足,需要至少5个字!";
  677. }
  678. break;
  679. }
  680. }
  681. if (valid.Validation && string.IsNullOrEmpty(valid.Result))
  682. valid.Result = "标题或受理内容出现限制词,请检查!";
  683. return valid;
  684. }
  685. #endregion
  686. #region 即将超期和超期短信
  687. /// <summary>
  688. /// 即将超期和超期短信
  689. /// </summary>
  690. /// <returns></returns>
  691. public async Task SendOverTimeSms(CancellationToken cancellationToken)
  692. {
  693. var now = DateTime.Now;
  694. var isSend = bool.Parse(_systemSettingCacheManager.GetSetting(SettingConstants.IsSendOverTimeSms).SettingValue[0]);
  695. if (!isSend)
  696. {
  697. return;
  698. }
  699. //查询即将超期和超期工单
  700. var orderList = await _orderRepository.Queryable()
  701. .Where(x => x.Status < EOrderStatus.Filed && !string.IsNullOrEmpty(x.CurrentHandleOrgId))
  702. .GroupBy(x => x.CurrentHandleOrgId)
  703. .Select(x => new OverTimeOrderDto
  704. {
  705. OrgId = x.CurrentHandleOrgId,
  706. NearlyOrderCount = SqlFunc.AggregateSum(SqlFunc.IIF(now >= x.NearlyExpiredTime && now < x.ExpiredTime, 1, 0)),
  707. ExpiredTimeOrderCount = SqlFunc.AggregateSum(SqlFunc.IIF(x.ExpiredTime < now, 1, 0))
  708. })
  709. .ToListAsync(cancellationToken);
  710. foreach (var item in orderList)
  711. {
  712. if (item.NearlyOrderCount == 0 && item.ExpiredTimeOrderCount == 0)
  713. {
  714. continue;
  715. }
  716. var acceptSmsRoleIds = _systemSettingCacheManager.GetSetting(SettingConstants.AcceptSmsRoleIds)?.SettingValue;
  717. //查询部门所有账号
  718. var userlist = await _userRepository.Queryable().Where(x =>
  719. x.OrgId == item.OrgId && !string.IsNullOrEmpty(x.PhoneNo) &&
  720. x.Roles.Any(d => acceptSmsRoleIds.Contains(d.Id))).ToListAsync();
  721. //发送短信
  722. foreach (var user in userlist)
  723. {
  724. var messageDto = new Share.Dtos.Push.MessageDto
  725. {
  726. PushBusiness = EPushBusiness.OrderExpire,
  727. PushPlatform = EPushPlatform.Sms,
  728. Name = user.Name,
  729. TemplateCode = "1009",
  730. Params = new List<string>() { item.NearlyOrderCount.ToString(), item.ExpiredTimeOrderCount.ToString() },
  731. TelNumber = user.PhoneNo,
  732. };
  733. await _mediator.Publish(new PushMessageNotify(messageDto), cancellationToken);
  734. }
  735. }
  736. }
  737. #endregion
  738. #region private
  739. private async Task<Order> GetOrderByFlowIdAsync(string workflowId, CancellationToken cancellationToken)
  740. {
  741. if (string.IsNullOrEmpty(workflowId))
  742. throw UserFriendlyException.SameMessage("无效流程编号");
  743. var order = await _orderRepository.Queryable()
  744. .Includes(d => d.Hotspot)
  745. .FirstAsync(d => d.WorkflowId == workflowId);
  746. if (order == null)
  747. throw new UserFriendlyException($"无效流程编号, workflowId: {workflowId}", "无效流程编号");
  748. return order;
  749. }
  750. private CacheOrderNO GetCurrentOrderNo()
  751. {
  752. var today = DateTime.Today;
  753. var cacheKey = today.ToString("yyyyMMdd");
  754. var cacheOrderNo = _cacheOrderNo.GetOrSet(cacheKey, f =>
  755. {
  756. var todayOrderCount = _orderRepository.Queryable(includeDeleted: true)
  757. .CountAsync(d => d.CreationTime.Date == today.Date)
  758. .GetAwaiter()
  759. .GetResult();
  760. return new CacheOrderNO { TotalCount = todayOrderCount };
  761. }, TimeSpan.FromDays(1));
  762. return cacheOrderNo;
  763. }
  764. public string GenerateNewOrderNo()
  765. {
  766. var today = DateTime.Today;
  767. var cacheKey = $"{today:yyyyMMdd}";
  768. var cacheOrderNo = _cacheOrderNo.GetOrSet(cacheKey, f =>
  769. {
  770. var todayOrderCount = _orderRepository.Queryable(true)
  771. .CountAsync(d => d.CreationTime.Date == today.Date)
  772. .GetAwaiter()
  773. .GetResult();
  774. return new CacheOrderNO { TotalCount = todayOrderCount };
  775. }, TimeSpan.FromDays(1));
  776. cacheOrderNo!.TotalCount += 1;
  777. var no = GenerateOrderNo(today, cacheOrderNo.TotalCount);
  778. _cacheOrderNo.Set(cacheKey, cacheOrderNo);
  779. return no;
  780. }
  781. private string GenerateNewProvinceNo(string no, string sourceChannelCode)
  782. {
  783. //诉求渠道+成员单位标识+行政区划代码+年月日+流水号
  784. //成员单位标识 99
  785. //宜宾市 511500 市级
  786. var today = DateTime.Today;
  787. //var count = no.Substring(no.Length - 5);
  788. var setting = _systemSettingCacheManager.GetSetting(SettingConstants.VersionsAreaCode);
  789. var versionsAreaCode = setting?.SettingValue[0];
  790. //todo 双系统并行暂时执行此方案
  791. var count = no.Substring(no.Length - 4);
  792. count = (Convert.ToInt32(count) + 50000).ToString();
  793. var provinceCodes = new[] { "RGDH", "WX", "WB", "AP", "WZ", "YJ", "SCZWFWW", "XCX", "QT" };
  794. var prefix = provinceCodes.Any(d => d.Equals(sourceChannelCode))
  795. ? sourceChannelCode
  796. : "QT";
  797. return $"{prefix}99{versionsAreaCode}{today:yyMMdd}{count}";
  798. }
  799. private string GenerateOrderNo(DateTime today, int count)
  800. {
  801. return $"{today:yyyyMMdd}{count:000000}";
  802. }
  803. #endregion
  804. }
  805. public class CacheOrderNO
  806. {
  807. public int TotalCount { get; set; }
  808. }
  809. public class OrderValidation
  810. {
  811. public bool Validation { get; set; }
  812. public string Result { get; set; }
  813. }