Ai order 1.3

src/SmartTalk.Api/Controllers/PhoneOrderController.cs

@@ -106,6 +106,15 @@ await _mediator.SendAsync(new ReceivePhoneOrderRecordCommand {
         return Ok();
     }
 
+    [HttpPost("aixvolink/call-ended")]
+    [ProducesResponseType(StatusCodes.Status200OK)]
+    public async Task<IActionResult> ReceiveAixvolinkCallEndedAsync([FromBody] ReceiveAixvolinkPhoneOrderRecordCommand command)
+    {
+        await _mediator.SendAsync(command).ConfigureAwait(false);
+
+        return Ok();
+    }
+
     [Route("manual/order"), HttpPost]
     [ProducesResponseType(StatusCodes.Status200OK, Type = typeof(AddOrUpdateManualOrderResponse))]
     public async Task<IActionResult> AddOrUpdateManualOrderAsync([FromBody] AddOrUpdateManualOrderCommand command)

src/SmartTalk.Api/appsettings.json

@@ -131,6 +131,10 @@
     "BaseUrl": "",
     "CompanyName": ""
   },
+  "Daovika": {
+    "ApiKey": "",
+    "BaseUrl": ""
+  },
   "SalesCustomerHabit": {
     "ApiKey": "",
     "BaseUrl": ""

src/SmartTalk.Core/Constants/PhoneOrderSourceProviders.cs

@@ -0,0 +1,6 @@
+namespace SmartTalk.Core.Constants;
+
+public static class PhoneOrderSourceProviders
+{
+    public const string Aixvolink = "AIXVOLINK";
+}

src/SmartTalk.Core/DbUpFile/Scripts_2026/Script0009_add_aixvolink_fields_to_phone_order_record.sql

@@ -0,0 +1,2 @@
+ALTER TABLE `phone_order_record`
+    ADD COLUMN `source_provider` VARCHAR(36) NULL AFTER `is_completed`;

src/SmartTalk.Core/Domain/PhoneOrder/PhoneOrderRecord.cs

@@ -116,4 +116,7 @@ public class PhoneOrderRecord : IEntity
 
     [Column("is_completed")]
     public bool IsCompleted { get; set; } = false;
-}
+
+    [Column("source_provider"), StringLength(36)]
+    public string SourceProvider { get; set; }
+}

src/SmartTalk.Core/Handlers/CommandHandlers/PhoneOrder/ReceiveAixvolinkPhoneOrderRecordCommandHandler.cs

@@ -0,0 +1,25 @@
+using Mediator.Net.Context;
+using Mediator.Net.Contracts;
+using SmartTalk.Core.Constants;
+using SmartTalk.Core.Services.Jobs;
+using SmartTalk.Core.Services.PhoneOrder;
+using SmartTalk.Messages.Commands.PhoneOrder;
+
+namespace SmartTalk.Core.Handlers.CommandHandlers.PhoneOrder;
+
+public class ReceiveAixvolinkPhoneOrderRecordCommandHandler : ICommandHandler<ReceiveAixvolinkPhoneOrderRecordCommand>
+{
+    private readonly ISmartTalkBackgroundJobClient _backgroundJobClient;
+
+    public ReceiveAixvolinkPhoneOrderRecordCommandHandler(ISmartTalkBackgroundJobClient backgroundJobClient)
+    {
+        _backgroundJobClient = backgroundJobClient;
+    }
+
+    public Task Handle(IReceiveContext<ReceiveAixvolinkPhoneOrderRecordCommand> context, CancellationToken cancellationToken)
+    {
+        _backgroundJobClient.Enqueue<IPhoneOrderService>(x => x.ReceiveAixvolinkPhoneOrderRecordAsync(context.Message, cancellationToken), HangfireConstants.InternalHostingPhoneOrder);
+
+        return Task.CompletedTask;
+    }
+}

src/SmartTalk.Core/Services/Http/Clients/CrmClient.cs

@@ -1,5 +1,6 @@
 using System.Text;
 using Newtonsoft.Json;
+using Serilog;
 using SmartTalk.Core.Ioc;
 using SmartTalk.Core.Settings.Crm;
 using SmartTalk.Messages.Dto.AutoTest;
@@ -17,15 +18,17 @@ public interface ICrmClient : IScopedDependency
 
     Task<List<GetCustomersPhoneNumberDataDto>> GetCustomersByPhoneNumberAsync(GetCustmoersByPhoneNumberRequestDto numberRequest, string token = null, CancellationToken cancellationToken = default);
 
+    Task<List<GetCustomerIdByShopNameResponseDto>> GetCustomerIdsByShopNameAsync(string shopName, CancellationToken cancellationToken = default);
+
     Task<List<CrmContactDto>> GetCustomerContactsAsync(string customerId, string token = null, CancellationToken cancellationToken = default);
 
     Task<List<GetDeliveryInfoByPhoneNumberResponseDto>> GetDeliveryInfoByPhoneNumberAsync(string phoneNumber, CancellationToken cancellationToken = default);
 }
 
 public class CrmClient : ICrmClient
 {
+    private const string CustomerIdsByShopNamePath = "/api/external/get-customers-by-shop-name?shop_name={0}";
     private readonly CrmSetting _crmSetting;
-    private readonly Dictionary<string, string> _headers;
     private readonly ISmartTalkHttpClientFactory _httpClient;
 
     public CrmClient(ISmartTalkHttpClientFactory httpClient, CrmSetting crmSetting)
@@ -44,9 +47,9 @@ public async Task<string> GetCrmTokenAsync(CancellationToken cancellationToken)
             { "client_id", _crmSetting.ClientId },
             { "client_secret", _crmSetting.ClientSecret }
         };
-        
+
         var content = new StringContent(JsonConvert.SerializeObject(payload), Encoding.UTF8, "application/json");
-        
+
         var headers = new Dictionary<string, string>
         {
             { "Accept", "application/json" }
@@ -57,38 +60,46 @@ public async Task<string> GetCrmTokenAsync(CancellationToken cancellationToken)
         return response?.AccessToken;
     }
 
-    public async Task<List<CrmContactDto>> GetCustomerContactsAsync(string customerId,
-        CancellationToken cancellationToken)
+    public Task<List<CrmContactDto>> GetCustomerContactsAsync(string customerId, CancellationToken cancellationToken)
+    {
+        return GetCustomerContactsAsync(customerId, token: null, cancellationToken);
+    }
+
+    public async Task<List<GetCustomersPhoneNumberDataDto>> GetCustomersByPhoneNumberAsync(GetCustmoersByPhoneNumberRequestDto numberRequest, string token = null, CancellationToken cancellationToken = default)
     {
-        var token = await GetCrmTokenAsync(cancellationToken).ConfigureAwait(false);
+        token ??= await GetCrmTokenAsync(cancellationToken).ConfigureAwait(false);
 
         var headers = new Dictionary<string, string>
         {
             { "Accept", "application/json" },
-            { "Authorization", $"Bearer {token}" }
+            { "Authorization", $"Bearer {token}"}
         };
 
-        return await _httpClient
-            .GetAsync<List<CrmContactDto>>($"{_crmSetting.BaseUrl}/api/customer/{customerId}/contacts",
-                headers: headers, cancellationToken: cancellationToken).ConfigureAwait(false);
+        var url = $"{_crmSetting.BaseUrl}/api/customer/get-customers-by-phone-number?phone_number={numberRequest.PhoneNumber}";
+
+        var result = await _httpClient.GetAsync<List<GetCustomersPhoneNumberDataDto>>(url, headers: headers, cancellationToken: cancellationToken).ConfigureAwait(false) ?? [];
+
+        Log.Information("Found {Count} customers for phone {PhoneNumber}", result.Count, numberRequest.PhoneNumber);
+        return result;
     }
-
-
-    public async Task<List<GetCustomersPhoneNumberDataDto>> GetCustomersByPhoneNumberAsync(GetCustmoersByPhoneNumberRequestDto numberRequest, string token = null, CancellationToken cancellationToken = default)
+
+    public async Task<List<GetCustomerIdByShopNameResponseDto>> GetCustomerIdsByShopNameAsync(string shopName, CancellationToken cancellationToken = default)
     {
-        token ??= await GetCrmTokenAsync(cancellationToken).ConfigureAwait(false);
-
+        if (string.IsNullOrWhiteSpace(shopName))
+            return [];
+
         var headers = new Dictionary<string, string>
         {
             { "Accept", "application/json" },
-            { "Authorization", $"Bearer {token}"}
+            { "X-API-KEY", _crmSetting.ApiKey }
         };
-
-        var url = $"{_crmSetting.BaseUrl}/api/customer/get-customers-by-phone-number?phone_number={numberRequest.PhoneNumber}";
 
-        return await _httpClient
-            .GetAsync<List<GetCustomersPhoneNumberDataDto>>(url, headers: headers, cancellationToken: cancellationToken)
-            .ConfigureAwait(false);
+        var url = $"{_crmSetting.SyncBaseUrl}{string.Format(CustomerIdsByShopNamePath, Uri.EscapeDataString(shopName))}";
+
+        var result = await _httpClient.GetAsync<List<GetCustomerIdByShopNameResponseDto>>(url, headers: headers, cancellationToken: cancellationToken).ConfigureAwait(false) ?? [];
+
+        Log.Information("Found {Count} customer ids for shop {ShopName}", result.Count, shopName);
+        return result;
     }
 
     public async Task<List<AutoTestCallLogDto>> GetCallRecordsAsync(DateTime startTimeUtc, DateTime endTimeUtc, CancellationToken cancellationToken)
@@ -116,7 +127,12 @@ public async Task<List<CrmContactDto>> GetCustomerContactsAsync(string customerI
             { "Authorization", $"Bearer {token}" }
         };
 
-        return await _httpClient.GetAsync<List<CrmContactDto>>($"{_crmSetting.BaseUrl}/api/customer/{customerId}/contacts", headers: headers, cancellationToken: cancellationToken).ConfigureAwait(false);
+        Log.Information("Fetching contacts for customer {CustomerId}", customerId);
+
+        var contacts = await _httpClient.GetAsync<List<CrmContactDto>>($"{_crmSetting.BaseUrl}/api/customer/{customerId}/contacts", headers: headers, cancellationToken: cancellationToken).ConfigureAwait(false) ?? [];
+        Log.Information("Found {Count} contacts for customer {CustomerId}", contacts.Count, customerId);
+
+        return contacts;
     }
 
     public async Task<List<GetDeliveryInfoByPhoneNumberResponseDto>> GetDeliveryInfoByPhoneNumberAsync(string phoneNumber, CancellationToken cancellationToken = default)
@@ -134,4 +150,4 @@ public async Task<List<GetDeliveryInfoByPhoneNumberResponseDto>> GetDeliveryInfo
 
         return await _httpClient.GetAsync<List<GetDeliveryInfoByPhoneNumberResponseDto>>(url, cancellationToken: cancellationToken, headers: headers).ConfigureAwait(false);
     }
-}
+}

src/SmartTalk.Core/Services/Http/Clients/DaovikaClient.cs

@@ -0,0 +1,48 @@
+using SmartTalk.Core.Ioc;
+using SmartTalk.Core.Settings.Daovika;
+using SmartTalk.Messages.Dto.Daovika;
+
+namespace SmartTalk.Core.Services.Http.Clients;
+
+public interface IDaovikaClient : IScopedDependency
+{
+    Task<string> GetSalesGroupByPhoneNumberAsync(string phoneNumber, CancellationToken cancellationToken);
+}
+
+public class DaovikaClient : IDaovikaClient
+{
+    private const string SalesGroupTableId = "fc7a74fc-ea1f-4be1-93c3-03ed190a2c56";
+
+    private readonly DaovikaSetting _daovikaSetting;
+    private readonly ISmartTalkHttpClientFactory _httpClientFactory;
+
+    public DaovikaClient(DaovikaSetting daovikaSetting, ISmartTalkHttpClientFactory httpClientFactory)
+    {
+        _daovikaSetting = daovikaSetting;
+        _httpClientFactory = httpClientFactory;
+    }
+
+    public async Task<string> GetSalesGroupByPhoneNumberAsync(string phoneNumber, CancellationToken cancellationToken)
+    {
+        if (string.IsNullOrWhiteSpace(phoneNumber))
+            return string.Empty;
+
+        var queryPhoneNumber = phoneNumber.Trim();
+        var url = $"{_daovikaSetting.BaseUrl}/api/external/table/query"
+                  + $"?tableId={SalesGroupTableId}"
+                  + $"&apiKey={Uri.EscapeDataString(_daovikaSetting.ApiKey)}"
+                  + "&field=phoneNumber&op=eq"
+                  + $"&value={Uri.EscapeDataString(queryPhoneNumber)}"
+                  + "&limit=1000&offset=0";
+
+        var headers = new Dictionary<string, string>
+        {
+            { "accept", "application/json" },
+            { "x-api-key", _daovikaSetting.ApiKey }
+        };
+
+        var response = await _httpClientFactory.GetAsync<GetSalesGroupByPhoneNumberResponseDto>(url, headers: headers, cancellationToken: cancellationToken).ConfigureAwait(false);
+
+        return response?.Rows?.FirstOrDefault()?.SalesGroup?.Trim() ?? string.Empty;
+    }
+}

src/SmartTalk.Core/Services/Http/Clients/SalesClient.cs

@@ -50,13 +50,11 @@ public async Task<GetAskInfoDetailListByCustomerResponseDto> GetAskInfoDetailLis
     {
         if (request.CustomerNumbers == null || request.CustomerNumbers.Count == 0)
             throw new ArgumentException("CustomerNumbers cannot be null or empty.");
-        
+
         var queryString = new StringBuilder("?");
 
         foreach (var customerNumber in request.CustomerNumbers)
-        {
             queryString.Append("CustomerNumbers=").Append(Uri.EscapeDataString(customerNumber)).Append('&');
-        }
 
         var url = $"{_salesSetting.BaseUrl}/api/SalesOrder/GetAskInfoDetailListByCustomer" + queryString.ToString().TrimEnd('&');
 
@@ -126,4 +124,5 @@ public async Task<GetAiOrderItemsByDeliveryDateResponseDto> GetAiOrderItemsByDel
 
         return await _httpClientFactory.GetAsync<GetAiOrderItemsByDeliveryDateResponseDto>(url, headers: _headers, cancellationToken: cancellationToken).ConfigureAwait(false);
     }
-}
+
+}