| | | 1 | | using OzonDomains; |
| | | 2 | | using Services.ApiServices.OpenRouterApi.Models; |
| | | 3 | | |
| | | 4 | | namespace Services.AiAssistant; |
| | | 5 | | |
| | | 6 | | /// <summary> |
| | | 7 | | /// Тексты шагов «Стас думает» в зависимости от распознанной задачи. |
| | | 8 | | /// </summary> |
| | | 9 | | public static class AiThinkingStepsBuilder |
| | | 10 | | { |
| | | 11 | | public static List<AiProcessStepDto> BuildPending(AiQueryIntent? intent, string userMessage) |
| | | 12 | | { |
| | 54 | 13 | | var tool = intent?.ToolName; |
| | 54 | 14 | | var taskSummary = SummarizeTask(intent, userMessage); |
| | | 15 | | |
| | 54 | 16 | | if (tool == "orders_filter") |
| | | 17 | | { |
| | 3 | 18 | | return |
| | 3 | 19 | | [ |
| | 3 | 20 | | new AiProcessStepDto |
| | 3 | 21 | | { |
| | 3 | 22 | | Key = "intent", |
| | 3 | 23 | | Label = taskSummary, |
| | 3 | 24 | | Done = false, |
| | 3 | 25 | | Status = "active" |
| | 3 | 26 | | }, |
| | 3 | 27 | | new AiProcessStepDto |
| | 3 | 28 | | { |
| | 3 | 29 | | Key = "studio", |
| | 3 | 30 | | Label = "Студия запроса: склад, клиент, период…", |
| | 3 | 31 | | Done = false, |
| | 3 | 32 | | Status = "pending" |
| | 3 | 33 | | }, |
| | 3 | 34 | | new AiProcessStepDto |
| | 3 | 35 | | { |
| | 3 | 36 | | Key = "db", |
| | 3 | 37 | | Label = GetDbStepLabel(intent), |
| | 3 | 38 | | Done = false, |
| | 3 | 39 | | Status = "pending" |
| | 3 | 40 | | }, |
| | 3 | 41 | | new AiProcessStepDto |
| | 3 | 42 | | { |
| | 3 | 43 | | Key = "ai", |
| | 3 | 44 | | Label = "Формирую ответ…", |
| | 3 | 45 | | Done = false, |
| | 3 | 46 | | Status = "pending" |
| | 3 | 47 | | } |
| | 3 | 48 | | ]; |
| | | 49 | | } |
| | | 50 | | |
| | 51 | 51 | | return |
| | 51 | 52 | | [ |
| | 51 | 53 | | new AiProcessStepDto |
| | 51 | 54 | | { |
| | 51 | 55 | | Key = "intent", |
| | 51 | 56 | | Label = taskSummary, |
| | 51 | 57 | | Done = false, |
| | 51 | 58 | | Status = "active" |
| | 51 | 59 | | }, |
| | 51 | 60 | | new AiProcessStepDto |
| | 51 | 61 | | { |
| | 51 | 62 | | Key = "db", |
| | 51 | 63 | | Label = GetDbStepLabel(intent), |
| | 51 | 64 | | Done = false, |
| | 51 | 65 | | Status = "pending" |
| | 51 | 66 | | }, |
| | 51 | 67 | | new AiProcessStepDto |
| | 51 | 68 | | { |
| | 51 | 69 | | Key = "ai", |
| | 51 | 70 | | Label = GetAiStepLabel(intent, userMessage), |
| | 51 | 71 | | Done = false, |
| | 51 | 72 | | Status = "pending" |
| | 51 | 73 | | } |
| | 51 | 74 | | ]; |
| | | 75 | | } |
| | | 76 | | |
| | | 77 | | public static List<AiProcessStepDto> BuildCompleted( |
| | | 78 | | AiQueryIntent? intent, |
| | | 79 | | string userMessage, |
| | | 80 | | int orderCount, |
| | | 81 | | bool dbRan) |
| | | 82 | | { |
| | 20 | 83 | | var pending = BuildPending(intent, userMessage); |
| | 20 | 84 | | pending[0].Done = true; |
| | 20 | 85 | | pending[0].Status = "done"; |
| | 20 | 86 | | pending[0].Label = intent != null |
| | 20 | 87 | | ? $"Распознано: {AiOrderAnalysisService.GetToolLabel(intent.ToolName)}" |
| | 20 | 88 | | : "Запрос понят"; |
| | | 89 | | |
| | 20 | 90 | | var dbStepIndex = intent?.ToolName == "orders_filter" ? 2 : 1; |
| | 20 | 91 | | var aiStepIndex = intent?.ToolName == "orders_filter" ? 3 : 2; |
| | | 92 | | |
| | 20 | 93 | | if (intent?.ToolName == "orders_filter" && pending.Count > 1) |
| | | 94 | | { |
| | 1 | 95 | | pending[1].Done = true; |
| | 1 | 96 | | pending[1].Status = "done"; |
| | 1 | 97 | | pending[1].Label = "Спецификация фильтра готова"; |
| | | 98 | | } |
| | | 99 | | |
| | 20 | 100 | | if (dbRan) |
| | | 101 | | { |
| | 18 | 102 | | pending[dbStepIndex].Done = true; |
| | 18 | 103 | | pending[dbStepIndex].Status = "done"; |
| | 18 | 104 | | if (intent?.ToolName == "order_detail" && orderCount > 0) |
| | 1 | 105 | | pending[dbStepIndex].Label = $"Загружен заказ + товар + остатки 1С + синхронизация + Ozon API ({orderCou |
| | 17 | 106 | | else if (orderCount > 0) |
| | 2 | 107 | | pending[dbStepIndex].Label = $"Данные загружены ({orderCount} заказ(ов))"; |
| | | 108 | | else |
| | 15 | 109 | | pending[dbStepIndex].Label = GetDbStepLabel(intent).TrimEnd('…') + " — готово"; |
| | | 110 | | } |
| | | 111 | | else |
| | | 112 | | { |
| | 2 | 113 | | pending[dbStepIndex].Done = true; |
| | 2 | 114 | | pending[dbStepIndex].Status = "done"; |
| | 2 | 115 | | pending[dbStepIndex].Label = intent != null |
| | 2 | 116 | | ? GetDbStepLabel(intent).TrimEnd('…') + " — готово" |
| | 2 | 117 | | : "Запрос к базе не требуется"; |
| | | 118 | | } |
| | | 119 | | |
| | 20 | 120 | | pending[aiStepIndex].Done = true; |
| | 20 | 121 | | pending[aiStepIndex].Status = "pending"; |
| | 20 | 122 | | pending[aiStepIndex].Label = "Формирую ответ…"; |
| | 20 | 123 | | return pending; |
| | | 124 | | } |
| | | 125 | | |
| | | 126 | | private static string SummarizeTask(AiQueryIntent? intent, string userMessage) |
| | | 127 | | { |
| | 54 | 128 | | if (intent == null) |
| | 5 | 129 | | return "Анализирую вопрос…"; |
| | | 130 | | |
| | 49 | 131 | | if (intent.OrderId.HasValue) |
| | 3 | 132 | | return $"Задача: заказ #{intent.OrderId.Value}"; |
| | | 133 | | |
| | 46 | 134 | | if (!string.IsNullOrWhiteSpace(intent.ShipmentNumber)) |
| | 1 | 135 | | return $"Задача: заказ {intent.ShipmentNumber}"; |
| | | 136 | | |
| | 45 | 137 | | var trimmed = userMessage.Trim(); |
| | 45 | 138 | | if (trimmed.Length > 72) |
| | 1 | 139 | | trimmed = trimmed[..72] + "…"; |
| | | 140 | | |
| | 45 | 141 | | return $"Задача: {trimmed}"; |
| | | 142 | | } |
| | | 143 | | |
| | 70 | 144 | | private static string GetDbStepLabel(AiQueryIntent? intent) => intent?.ToolName switch |
| | 70 | 145 | | { |
| | 7 | 146 | | "order_detail" => "Загружаю заказ, товар, остатки 1С, синхронизацию Ozon и Ozon API…", |
| | 4 | 147 | | "order_product" => "Товар, WarehouseStock и движения 1С…", |
| | 4 | 148 | | "order_history" => "Загрузка GetOrderHistory…", |
| | 4 | 149 | | "user_actions_today" => "Журнал изменений за сегодня…", |
| | 3 | 150 | | "order_history_recent" => "Последние записи orders_history…", |
| | 4 | 151 | | "orders_today" => "Заказы, принятые сегодня…", |
| | 3 | 152 | | "overdue_orders" => "Поиск просроченных заказов…", |
| | 3 | 153 | | "unprofitable_orders" => "Поиск невыгодных заказов…", |
| | 3 | 154 | | "cancelled_orders_today" => "Отменённые заказы за сегодня…", |
| | 3 | 155 | | "no_supplier_orders" => "Заказы без поставщика…", |
| | 3 | 156 | | "orders_filter" => "Поиск заказов по критериям…", |
| | 4 | 157 | | "orders_summary" => "Сводка по статусам…", |
| | 3 | 158 | | "transaction_types_info" => "Справочник типов транзакций…", |
| | 4 | 159 | | "bitrix_stock_article" => "Синхронизация Ozon и 1С…", |
| | 4 | 160 | | "ozon_live_product" => "Запрос к Ozon Seller API…", |
| | 14 | 161 | | _ => "Запрос к базе данных…" |
| | 70 | 162 | | }; |
| | | 163 | | |
| | | 164 | | private static string GetAiStepLabel(AiQueryIntent? intent, string userMessage) |
| | | 165 | | { |
| | 51 | 166 | | if (intent?.ToolName is "order_detail" or "order_product") |
| | 10 | 167 | | return "Анализирую заказ, движения 1С, данные Ozon API и формирую вывод…"; |
| | | 168 | | |
| | 41 | 169 | | if (intent?.ToolName == "order_history") |
| | 3 | 170 | | return "Анализирую историю изменений и формирую вывод…"; |
| | | 171 | | |
| | 38 | 172 | | if (intent?.ToolName == "bitrix_stock_article") |
| | 3 | 173 | | return "Анализирую остатки, цены и синхронизации Ozon…"; |
| | | 174 | | |
| | 35 | 175 | | if (intent?.ToolName == "ozon_live_product") |
| | 3 | 176 | | return "Запрашиваю актуальные остатки и цены у Ozon API…"; |
| | | 177 | | |
| | 32 | 178 | | if (intent?.ToolName == "user_actions_today") |
| | 3 | 179 | | return "Сводка по действиям пользователей…"; |
| | | 180 | | |
| | 29 | 181 | | return "Формирую ответ на ваш вопрос…"; |
| | | 182 | | } |
| | | 183 | | } |