OrderApplicationTest.cs 2.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667
  1. using Hotline.Application.Orders;
  2. using Hotline.Caching.Interfaces;
  3. using Hotline.Orders;
  4. using Hotline.Push.FWMessage;
  5. using Hotline.Push.Notifies;
  6. using Hotline.Settings;
  7. using Hotline.Share.Dtos.FlowEngine;
  8. using Hotline.Share.Dtos.Order;
  9. using Hotline.Share.Enums.FlowEngine;
  10. using Hotline.Share.Enums.Order;
  11. using Mapster;
  12. using Shouldly;
  13. using System;
  14. using System.Collections.Generic;
  15. using System.Linq;
  16. using System.Text;
  17. using System.Threading.Tasks;
  18. using XF.Domain.Repository;
  19. namespace Hotline.Application.Tests.Application;
  20. public class OrderApplicationTest
  21. {
  22. private readonly IOrderApplication _orderApplication;
  23. private readonly ISystemDicDataCacheManager _systemDicDataCacheManager;
  24. private readonly IRepository<OrderVisit> _orderVisitRepository;
  25. private readonly IRepository<Order> _orderRepository;
  26. private readonly IRepository<Message> _messageRepository;
  27. public OrderApplicationTest(IOrderApplication orderApplication, IRepository<OrderVisit> orderVisitRepository, IRepository<Message> messageRepository, IRepository<Order> orderRepository, ISystemDicDataCacheManager systemDicDataCacheManager)
  28. {
  29. _orderApplication = orderApplication;
  30. _orderVisitRepository = orderVisitRepository;
  31. _orderRepository = orderRepository;
  32. _systemDicDataCacheManager = systemDicDataCacheManager;
  33. _messageRepository = messageRepository;
  34. }
  35. //[Fact]
  36. public async Task VisitPushSMS_Test()
  37. {
  38. var orderVisit = await _orderVisitRepository.Queryable()
  39. .Where(m => m.VisitState == EVisitState.WaitForVisit)
  40. .OrderByDescending(m => m.CreationTime)
  41. .FirstAsync();
  42. orderVisit.ShouldNotBeNull("缺少 回访单 (order_visit) VisitState = 10 的数据.");
  43. var dto = new VisitSmsInDto
  44. {
  45. Ids = new List<string> { orderVisit.Id }
  46. };
  47. await _orderApplication.VisitPushSMSAsync(dto, new CancellationToken());
  48. var visit = await _orderVisitRepository.Queryable().Where(m => m.Id == orderVisit.Id).FirstAsync();
  49. visit.VisitState.ShouldBe(EVisitState.SMSVisiting);
  50. visit.VisitType.ShouldBe(EVisitType.SmsVisit);
  51. }
  52. [Fact]
  53. public async Task MapConfig_Test()
  54. {
  55. var data = await _messageRepository.Queryable().OrderByDescending(m => m.CreationTime)
  56. .FirstAsync();
  57. var m = data.Adapt<ReceiveMessageNotify>();
  58. m.NotifyDto.Name.ShouldBe(data.Name);
  59. m.NotifyDto.PushBusiness.ShouldBe(data.PushBusiness);
  60. }
  61. }