Merge pull request #186 from sj-distributor/enhance-order-inf-setting

Enhance order info setting

Author: happyshower

src/SmartTalk.Core/Constants/OpenAiToolConstants.cs

@@ -15,4 +15,5 @@ public static class OpenAiToolConstants
     public const string CheckOrderStatus = "check_order_status";
     public const string RequestOrderDelivery = "request_order_delivery";
     public const string ConfirmCustomerInformation = "confirm_customer_name_phone";
+    public const string ConfirmPickupTime = "confirm_pickup_time";
 }

src/SmartTalk.Core/DbUpFile/Scripts_2025/Script00014_add_order_comment_for_phone_order_record_table.sql

@@ -0,0 +1 @@
+alter table `phone_order_record` add column `comments` varchar(1024) null;

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

@@ -60,6 +60,9 @@ public class PhoneOrderRecord : IEntity
     [Column("customer_name"), StringLength(50)]
     public string CustomerName { get; set; }
 
+    [Column("comments")]
+    public string Comments { get; set; }
+    
     [NotMapped]
     public UserAccount UserAccount { get; set; }
 

src/SmartTalk.Core/Services/AiSpeechAssistant/AiSpeechAssistantProcessJobService.cs

@@ -63,7 +63,8 @@ public async Task RecordAiSpeechAssistantCallAsync(AiSpeechAssistantStreamContex
             CreatedDate = callResource.StartTime ?? DateTimeOffset.Now,
             OrderStatus = PhoneOrderOrderStatus.Pending,
             CustomerName = context.UserInfo.UserName,
-            PhoneNumber = context.UserInfo.PhoneNumber
+            PhoneNumber = context.UserInfo.PhoneNumber,
+            Comments = context.OrderItems.Comments
         };
 
         await _phoneOrderDataProvider.AddPhoneOrderRecordsAsync([record], cancellationToken: cancellationToken).ConfigureAwait(false);

src/SmartTalk.Core/Services/AiSpeechAssistant/AiSpeechAssistantService.cs

@@ -374,6 +374,10 @@ private async Task SendToTwilioAsync(WebSocket twilioWebSocket, WebSocket openAi
                                         case OpenAiToolConstants.ConfirmCustomerInformation:
                                             await ProcessRecordCustomerInformationAsync(openAiWebSocket, context, outputElement, cancellationToken).ConfigureAwait(false);
                                             break;
+                                        
+                                        case OpenAiToolConstants.ConfirmPickupTime:
+                                            await ProcessRecordOrderPickupTimeAsync(openAiWebSocket, context, outputElement, cancellationToken).ConfigureAwait(false);
+                                            break;
 
                                         case OpenAiToolConstants.Hangup:
                                             await ProcessHangupAsync(openAiWebSocket, context, outputElement, cancellationToken).ConfigureAwait(false);
@@ -451,6 +455,25 @@ private async Task ProcessRecordCustomerInformationAsync(WebSocket openAiWebSock
         await SendToWebSocketAsync(openAiWebSocket, recordSuccess);
         await SendToWebSocketAsync(openAiWebSocket, new { type = "response.create" });
     }
+
+    private async Task ProcessRecordOrderPickupTimeAsync(WebSocket openAiWebSocket, AiSpeechAssistantStreamContextDto context, JsonElement jsonDocument, CancellationToken cancellationToken)
+    {
+        var recordSuccess = new
+        {
+            type = "conversation.item.create",
+            item = new
+            {
+                type = "function_call_output",
+                call_id = jsonDocument.GetProperty("call_id").GetString(),
+                output = "Record the time when the customer pickup the order."
+            }
+        };
+        
+        context.OrderItems.Comments = JsonConvert.DeserializeObject<AiSpeechAssistantOrderDto>(jsonDocument.GetProperty("arguments").ToString())?.Comments ?? string.Empty;
+        
+        await SendToWebSocketAsync(openAiWebSocket, recordSuccess);
+        await SendToWebSocketAsync(openAiWebSocket, new { type = "response.create" });
+    }
 
     private async Task ProcessHangupAsync(WebSocket openAiWebSocket, AiSpeechAssistantStreamContextDto context, JsonElement jsonDocument, CancellationToken cancellationToken)
     {

src/SmartTalk.Core/Services/PhoneOrder/PhoneOrderService.OrderItem.cs

@@ -60,8 +60,8 @@ public async Task<PlaceOrderAndModifyItemResponse> PlaceOrderAndModifyItemsAsync
         var request = new PlaceOrderToEasyPosRequestDto
         {
             Type = 1,
-            IsTaxFree = true,
-            Notes = string.Empty,
+            IsTaxFree = false,
+            Notes = record.Comments,
             OrderItems = orderItems.Select(x => new PhoneCallOrderItem
             {
                 ProductId = x.ProductId ?? GetMenuItemByName(menuItems, x.FoodName)?.ProductId ?? 0,

src/SmartTalk.Messages/Dto/AiSpeechAssistant/AiSpeechAssistantStreamContxtDto.cs

@@ -53,6 +53,9 @@ public class AiSpeechAssistantUserInfoDto
 
 public class AiSpeechAssistantOrderDto
 {
+    [JsonProperty("comments")]
+    public string Comments { get; set; }
+    
     [JsonProperty("order_items")]
     public List<AiSpeechAssistantOrderItemDto> Order { get; set; }
 }

src/SmartTalk.Messages/Dto/PhoneOrder/PhoneOrderRecordDto.cs

@@ -32,4 +32,6 @@ public class PhoneOrderRecordDto
     public string PhoneNumber { get; set; }
 
     public string CustomerName { get; set; }
+    
+    public string Comments { get; set; }
 }