| | | 1 | | using System.Text; |
| | | 2 | | using Hangfire; |
| | | 3 | | using Hangfire.Storage; |
| | | 4 | | using Hangfire.Storage.Monitoring; |
| | | 5 | | using Microsoft.AspNetCore.Authorization; |
| | | 6 | | using Microsoft.AspNetCore.Mvc; |
| | | 7 | | using Microsoft.EntityFrameworkCore; |
| | | 8 | | using Microsoft.IdentityModel.Tokens; |
| | | 9 | | using Newtonsoft.Json; |
| | | 10 | | using OzonDomains; |
| | | 11 | | using OzonDomains.Models; |
| | | 12 | | using OzonDomains.Models.OrderCarts; |
| | | 13 | | using OzonOrdersWeb.ViewModels.JobViewModels; |
| | | 14 | | using OzonRepositories.Context; |
| | | 15 | | using OzonRepositories.Data; |
| | | 16 | | using Services.ApiServices.DropBoxApi; |
| | | 17 | | using Services.ApiServices.OzonApi; |
| | | 18 | | using Services.ApiServices.YandexApi; |
| | | 19 | | using Services.YandexServices; |
| | | 20 | | using Services.CacheServices.Cache.OzonOrdersCache; |
| | | 21 | | using Services.DataServices; |
| | | 22 | | using Services.ParserServices; |
| | | 23 | | using Services.ParserServices.FielParsers; |
| | | 24 | | using Services.ParserServices.HelpDictEnum; |
| | | 25 | | using Services.ReleasServices.ReleaseManager; |
| | | 26 | | using Microsoft.AspNetCore.SignalR; |
| | | 27 | | using Services.SignalRServices; |
| | | 28 | | using OzonOrdersWeb.Areas.Studio2.ViewModels.HangfireQueue; |
| | | 29 | | using Services.HangfireService; |
| | | 30 | | using AppRepository.ApiServices.OzonApi; |
| | | 31 | | using AppRepository.ApiServices.OzonApi.Filters; |
| | | 32 | | using OzonOrdersWeb.Areas.Studio2.Controllers; |
| | | 33 | | using Services.OzonWebhookServices; |
| | | 34 | | using Services.OzonReturnsServices; |
| | | 35 | | using Services.BackgroundJobsServices; |
| | | 36 | | |
| | | 37 | | namespace OzonOrdersWeb.Controllers |
| | | 38 | | { |
| | | 39 | | [Authorize(Roles = "Admin")] |
| | | 40 | | [Area("Studio2")] |
| | | 41 | | public class JobController : Controller |
| | | 42 | | { |
| | | 43 | | private readonly OrdersDataServices _orderRepository; |
| | | 44 | | private readonly OrderCaster _orderCaster; |
| | | 45 | | private readonly OzonJsonDataBuilder _jsonDataBuilder; |
| | | 46 | | private readonly ReleaseManager _releaseManager; |
| | | 47 | | private readonly DuplicateOrdersServices _duplicateOrdersServices; |
| | | 48 | | private readonly OzonClientServices _ozonClientServices; |
| | | 49 | | private readonly YandexDataManager _yandexDataManager; |
| | | 50 | | private readonly IYandexOrderStatusSyncService _yandexOrderStatusSyncService; |
| | | 51 | | private readonly ApplicationDbContext _context; |
| | | 52 | | private readonly OrdersDataServices _orderDataServices; |
| | | 53 | | private readonly OrderItemRepository _orderItemRepository; |
| | | 54 | | private readonly ClientStatusDataServices _clientStatusServices; |
| | | 55 | | private readonly OrderCache _cache; |
| | | 56 | | private readonly IHubContext<JobProgressHub> _jobProgressHub; |
| | | 57 | | private readonly IHangfireService _hangfireService; |
| | | 58 | | private readonly IHttpClientFactory _httpClientFactory; |
| | | 59 | | private readonly IServiceScopeFactory _serviceScopeFactory; |
| | | 60 | | private readonly IOzonPostingCancellationService _postingCancellationService; |
| | | 61 | | |
| | 0 | 62 | | public JobController(OrdersDataServices ordersDataServices, |
| | 0 | 63 | | OrderCaster orderCaster, |
| | 0 | 64 | | OzonJsonDataBuilder jsonDataBuilder, |
| | 0 | 65 | | ReleaseManager releaseManager, |
| | 0 | 66 | | DuplicateOrdersServices duplicateOrdersServices, |
| | 0 | 67 | | OzonClientServices ozonClientServices, |
| | 0 | 68 | | YandexDataManager yandexDataManager, |
| | 0 | 69 | | IYandexOrderStatusSyncService yandexOrderStatusSyncService, |
| | 0 | 70 | | ApplicationDbContext context, |
| | 0 | 71 | | OrdersDataServices orderDataServices, |
| | 0 | 72 | | OrderItemRepository orderItemRepository, |
| | 0 | 73 | | ClientStatusDataServices clientStatusServices, |
| | 0 | 74 | | OrderCache cache, |
| | 0 | 75 | | IHubContext<JobProgressHub> jobProgressHub, |
| | 0 | 76 | | IHangfireService hangfireService, |
| | 0 | 77 | | IHttpClientFactory httpClientFactory, |
| | 0 | 78 | | IServiceScopeFactory serviceScopeFactory, |
| | 0 | 79 | | IOzonPostingCancellationService postingCancellationService) |
| | | 80 | | { |
| | 0 | 81 | | _orderRepository = ordersDataServices; |
| | 0 | 82 | | _orderCaster = orderCaster; |
| | 0 | 83 | | _jsonDataBuilder = jsonDataBuilder; |
| | 0 | 84 | | _releaseManager = releaseManager; |
| | 0 | 85 | | _duplicateOrdersServices = duplicateOrdersServices; |
| | 0 | 86 | | _ozonClientServices = ozonClientServices; |
| | 0 | 87 | | _yandexDataManager = yandexDataManager; |
| | 0 | 88 | | _yandexOrderStatusSyncService = yandexOrderStatusSyncService; |
| | 0 | 89 | | _context = context; |
| | 0 | 90 | | _orderDataServices = orderDataServices; |
| | 0 | 91 | | _orderItemRepository = orderItemRepository; |
| | 0 | 92 | | _clientStatusServices = clientStatusServices; |
| | 0 | 93 | | _cache = cache; |
| | 0 | 94 | | _jobProgressHub = jobProgressHub; |
| | 0 | 95 | | _hangfireService = hangfireService; |
| | 0 | 96 | | _httpClientFactory = httpClientFactory; |
| | 0 | 97 | | _serviceScopeFactory = serviceScopeFactory; |
| | 0 | 98 | | _postingCancellationService = postingCancellationService; |
| | 0 | 99 | | } |
| | | 100 | | |
| | | 101 | | public IActionResult Index(string pageTab = "schedules", string queueName = "main", |
| | | 102 | | string queueTab = "enqueued") |
| | | 103 | | { |
| | 0 | 104 | | var api = JobStorage.Current.GetMonitoringApi(); |
| | 0 | 105 | | JobList<SucceededJobDto> succeededJobs = api.SucceededJobs(0, 50); |
| | | 106 | | |
| | 0 | 107 | | var jobResult = new JobResultViewModel |
| | 0 | 108 | | { |
| | 0 | 109 | | Schedules = BuildScheduleStatuses(), |
| | 0 | 110 | | ActivePageTab = string.IsNullOrWhiteSpace(pageTab) ? "schedules" : pageTab |
| | 0 | 111 | | }; |
| | | 112 | | |
| | | 113 | | // Состояние разового обновления статусов по периоду (чтобы показать "выполняется") |
| | 0 | 114 | | TryGetPeriodStatusUpdateState(api, out var state, out var jobId, out var startedAtUtc); |
| | 0 | 115 | | jobResult.PeriodStatusUpdateState = state ?? string.Empty; |
| | 0 | 116 | | jobResult.PeriodStatusUpdateJobId = jobId ?? string.Empty; |
| | 0 | 117 | | jobResult.PeriodStatusUpdateStartedAtUtc = startedAtUtc; |
| | | 118 | | |
| | | 119 | | // Данные для вкладки очереди Hangfire (как /HangfireQueue) |
| | | 120 | | try |
| | | 121 | | { |
| | 0 | 122 | | var queues = _hangfireService.GetAvailableQueues()?.ToList() ?? new List<string>(); |
| | 0 | 123 | | if (queues.Count == 0) |
| | | 124 | | { |
| | 0 | 125 | | queues.Add("main"); |
| | | 126 | | } |
| | | 127 | | |
| | 0 | 128 | | if (string.IsNullOrWhiteSpace(queueName) || !queues.Contains(queueName)) |
| | 0 | 129 | | queueName = queues.First(); |
| | | 130 | | |
| | 0 | 131 | | var hModel = new HangfireJobsViewModel |
| | 0 | 132 | | { |
| | 0 | 133 | | QueueName = queueName, |
| | 0 | 134 | | ActiveTab = string.IsNullOrWhiteSpace(queueTab) ? "enqueued" : queueTab, |
| | 0 | 135 | | AvailableQueues = queues, |
| | 0 | 136 | | EnqueuedJobs = _hangfireService.GetEnqueuedJobs(queueName), |
| | 0 | 137 | | ProcessingJobs = _hangfireService.GetProcessingJobs(queueName), |
| | 0 | 138 | | SucceededJobs = _hangfireService.GetSucceededJobs(), |
| | 0 | 139 | | DeletedJobs = _hangfireService.GetDeletedJobs() |
| | 0 | 140 | | }; |
| | | 141 | | |
| | 0 | 142 | | jobResult.HangfireQueue = hModel; |
| | 0 | 143 | | } |
| | 0 | 144 | | catch |
| | | 145 | | { |
| | 0 | 146 | | jobResult.HangfireQueue = new HangfireJobsViewModel(); |
| | 0 | 147 | | } |
| | | 148 | | |
| | | 149 | | // Проверка на null или пустоту |
| | 0 | 150 | | if (succeededJobs == null || succeededJobs.Count == 0) |
| | | 151 | | { |
| | 0 | 152 | | return View(jobResult); |
| | | 153 | | } |
| | | 154 | | |
| | 0 | 155 | | var results = new List<dynamic>(); |
| | | 156 | | |
| | 0 | 157 | | foreach (var job in succeededJobs) |
| | | 158 | | { |
| | 0 | 159 | | if (job.Value.Result != null) |
| | | 160 | | { |
| | | 161 | | try |
| | | 162 | | { |
| | 0 | 163 | | var result = JsonConvert.DeserializeObject<dynamic>((string)job.Value.Result); |
| | 0 | 164 | | if (result != null) |
| | 0 | 165 | | results.Add(result); |
| | 0 | 166 | | } |
| | 0 | 167 | | catch (JsonException ex) |
| | | 168 | | { |
| | 0 | 169 | | results.Add($"Error deserializing result for job {job.Key}: {ex.Message}"); |
| | 0 | 170 | | } |
| | | 171 | | } |
| | | 172 | | } |
| | | 173 | | |
| | | 174 | | // Обработка результатов |
| | 0 | 175 | | foreach (var result in results) |
| | | 176 | | { |
| | 0 | 177 | | if (result is string) |
| | | 178 | | { |
| | 0 | 179 | | jobResult.Results.Add((string)result); |
| | | 180 | | } |
| | | 181 | | } |
| | | 182 | | |
| | 0 | 183 | | return View(jobResult); |
| | | 184 | | } |
| | | 185 | | |
| | | 186 | | private const string PeriodStatusUpdateLockKey = "locks:statusUpdateByPeriod"; |
| | | 187 | | |
| | | 188 | | private void TryGetPeriodStatusUpdateState( |
| | | 189 | | IMonitoringApi api, |
| | | 190 | | out string? state, |
| | | 191 | | out string? jobId, |
| | | 192 | | out DateTime? startedAtUtc) |
| | | 193 | | { |
| | 0 | 194 | | state = null; |
| | 0 | 195 | | jobId = null; |
| | 0 | 196 | | startedAtUtc = null; |
| | | 197 | | |
| | | 198 | | try |
| | | 199 | | { |
| | | 200 | | // Processing |
| | 0 | 201 | | var processing = api.ProcessingJobs(0, 2000); |
| | 0 | 202 | | foreach (var p in processing) |
| | | 203 | | { |
| | 0 | 204 | | var j = p.Value?.Job; |
| | 0 | 205 | | if (j?.Method?.Name == nameof(UpdateStatusesByProcessingDateBackground)) |
| | | 206 | | { |
| | 0 | 207 | | state = "processing"; |
| | 0 | 208 | | jobId = p.Key; |
| | 0 | 209 | | startedAtUtc = p.Value?.StartedAt; |
| | 0 | 210 | | return; |
| | | 211 | | } |
| | | 212 | | } |
| | | 213 | | |
| | | 214 | | // Enqueued (во всех очередях) |
| | 0 | 215 | | foreach (var q in api.Queues()) |
| | | 216 | | { |
| | 0 | 217 | | var enq = api.EnqueuedJobs(q.Name, 0, 2000); |
| | 0 | 218 | | foreach (var e in enq) |
| | | 219 | | { |
| | 0 | 220 | | var j = e.Value?.Job; |
| | 0 | 221 | | if (j?.Method?.Name == nameof(UpdateStatusesByProcessingDateBackground)) |
| | | 222 | | { |
| | 0 | 223 | | state = "enqueued"; |
| | 0 | 224 | | jobId = e.Key; |
| | 0 | 225 | | startedAtUtc = e.Value?.EnqueuedAt; |
| | 0 | 226 | | return; |
| | | 227 | | } |
| | | 228 | | } |
| | | 229 | | } |
| | 0 | 230 | | } |
| | 0 | 231 | | catch |
| | | 232 | | { |
| | | 233 | | // ignore |
| | 0 | 234 | | } |
| | 0 | 235 | | } |
| | | 236 | | |
| | | 237 | | private List<JobScheduleViewModel> BuildScheduleStatuses() |
| | | 238 | | { |
| | | 239 | | try |
| | | 240 | | { |
| | 0 | 241 | | using var connection = JobStorage.Current.GetConnection(); |
| | 0 | 242 | | var recurring = connection.GetRecurringJobs() ?? new List<RecurringJobDto>(); |
| | | 243 | | |
| | | 244 | | JobScheduleViewModel Map( |
| | | 245 | | string key, |
| | | 246 | | string title, |
| | | 247 | | string? matchRecurringId = null, |
| | | 248 | | string? matchMethodName = null) |
| | | 249 | | { |
| | 0 | 250 | | var r = !string.IsNullOrEmpty(matchRecurringId) |
| | 0 | 251 | | ? recurring.FirstOrDefault(x => x.Id == matchRecurringId) |
| | 0 | 252 | | : null; |
| | | 253 | | |
| | 0 | 254 | | r ??= !string.IsNullOrEmpty(matchMethodName) |
| | 0 | 255 | | ? recurring.FirstOrDefault(x => x.Job?.Method?.Name == matchMethodName) |
| | 0 | 256 | | : null; |
| | | 257 | | |
| | 0 | 258 | | if (r == null) |
| | | 259 | | { |
| | 0 | 260 | | return new JobScheduleViewModel |
| | 0 | 261 | | { |
| | 0 | 262 | | Key = key, |
| | 0 | 263 | | Title = title, |
| | 0 | 264 | | IsConfigured = false |
| | 0 | 265 | | }; |
| | | 266 | | } |
| | | 267 | | |
| | 0 | 268 | | return new JobScheduleViewModel |
| | 0 | 269 | | { |
| | 0 | 270 | | Key = key, |
| | 0 | 271 | | Title = title, |
| | 0 | 272 | | IsConfigured = true, |
| | 0 | 273 | | RecurringJobId = r.Id, |
| | 0 | 274 | | Cron = r.Cron, |
| | 0 | 275 | | LastExecutionUtc = r.LastExecution, |
| | 0 | 276 | | NextExecutionUtc = r.NextExecution, |
| | 0 | 277 | | LastJobId = r.LastJobId, |
| | 0 | 278 | | LastJobState = r.LastJobState, |
| | 0 | 279 | | Args = r.Job?.Args?.ToArray() ?? Array.Empty<object>() |
| | 0 | 280 | | }; |
| | | 281 | | } |
| | | 282 | | |
| | 0 | 283 | | return new List<JobScheduleViewModel> |
| | 0 | 284 | | { |
| | 0 | 285 | | Map("UpdateStatusesRecurring", "Обновление статусов (последние заказы)", |
| | 0 | 286 | | matchRecurringId: "StatusUpdateJob"), |
| | 0 | 287 | | Map("EverydayUpdate", "Ежедневное обновление заказов (OZON)", |
| | 0 | 288 | | matchMethodName: nameof(EverydayUpdate)), |
| | 0 | 289 | | Map("UploadingOzon", "Периодическое обновление заказов (OZON)", matchMethodName: "UploadingOzon"), |
| | 0 | 290 | | Map("UploadingYandex", "Периодическое обновление заказов (YANDEX)", |
| | 0 | 291 | | matchMethodName: "UploadingYandex"), |
| | 0 | 292 | | Map("OzonChatSync", "Синхронизация чатов Ozon", matchRecurringId: "OzonChatSync"), |
| | 0 | 293 | | Map(LoadOzonReturnsJob.IncrementalJobId, "Загрузка возвратов Ozon (инкрементально)", |
| | 0 | 294 | | matchRecurringId: LoadOzonReturnsJob.IncrementalJobId), |
| | 0 | 295 | | Map(LoadOzonReturnsJob.FullWindowJobId, "Загрузка возвратов Ozon (полная сверка)", |
| | 0 | 296 | | matchRecurringId: LoadOzonReturnsJob.FullWindowJobId) |
| | 0 | 297 | | }; |
| | | 298 | | } |
| | 0 | 299 | | catch |
| | | 300 | | { |
| | | 301 | | // Hangfire storage может быть недоступен (например, при старте) — не ломаем страницу. |
| | 0 | 302 | | return new List<JobScheduleViewModel>(); |
| | | 303 | | } |
| | 0 | 304 | | } |
| | | 305 | | |
| | | 306 | | [HttpPost] |
| | | 307 | | public IActionResult SetOzonRecurring(int delay) |
| | | 308 | | { |
| | 0 | 309 | | string cronExp = $"*/{delay} * * * *"; |
| | 0 | 310 | | RecurringJob.AddOrUpdate("UploadingOzon", "main", () => UploadingOzon(1), cronExp); |
| | | 311 | | |
| | 0 | 312 | | return Redirect("/Hangfire"); |
| | | 313 | | } |
| | | 314 | | |
| | | 315 | | |
| | | 316 | | [HttpPost] |
| | | 317 | | public IActionResult SetYandexRecurring(int delay) |
| | | 318 | | { |
| | 0 | 319 | | string cronExp = $"*/{delay} * * * *"; |
| | 0 | 320 | | RecurringJob.AddOrUpdate("UploadingYandex", "main", () => UploadingYandex(1), cronExp); |
| | | 321 | | |
| | 0 | 322 | | return Redirect("/Hangfire"); |
| | | 323 | | } |
| | | 324 | | |
| | | 325 | | [HttpPost] |
| | | 326 | | public async Task<IActionResult> SetEverydayUpdate(int monthsCount, int updateHour, int updateMinute) |
| | | 327 | | { |
| | 0 | 328 | | await Task.CompletedTask; |
| | 0 | 329 | | string cronExp = $"{updateMinute} {updateHour} * * *"; |
| | 0 | 330 | | RecurringJob.AddOrUpdate("EverydayUpdate", "main", () => EverydayUpdate(monthsCount), cronExp); |
| | | 331 | | |
| | 0 | 332 | | return Redirect("/Hangfire"); |
| | 0 | 333 | | } |
| | | 334 | | |
| | | 335 | | [HttpPost] |
| | | 336 | | public IActionResult SetLoadReturnsRecurring(int monthsCount, int delay) |
| | | 337 | | { |
| | | 338 | | // Держим параметры в безопасных границах UI. |
| | 0 | 339 | | if (monthsCount < 1) monthsCount = 1; |
| | 0 | 340 | | if (monthsCount > 12) monthsCount = 12; |
| | 0 | 341 | | if (delay < 1) delay = 1; |
| | 0 | 342 | | if (delay > 60) delay = 60; |
| | | 343 | | |
| | 0 | 344 | | string cronExp = $"*/{delay} * * * *"; |
| | | 345 | | |
| | | 346 | | // Запускаем тот же pipeline, что и на /OrderReturns: |
| | | 347 | | // LoadOzonReturnsJob.RunIncrementalAsync -> OzonReturnsSyncService.LoadAsync -> |
| | | 348 | | // OzonApiDataManager.GetReturnsListAsync(/v1/returns/list) + SyncFromApiResponseAsync(upsert). |
| | | 349 | | // Частый прогон — инкрементальный: читает период от последнего загруженного возврата, |
| | | 350 | | // а не весь monthsCount заново на каждом тике. |
| | | 351 | | // |
| | | 352 | | // Очередь параметром AddOrUpdate не задаём: эта перегрузка требует от хранилища фичу |
| | | 353 | | // Job.Queue, которой в Hangfire.MySqlStorage 2.0.3 нет |
| | | 354 | | // (docs/hangfire-recurring-job-registration.md). Маршрутизацию обеспечивает атрибут |
| | | 355 | | // [Queue] на самих методах. Здесь регистрируем ровно так же, как это делает |
| | | 356 | | // HangfireStartupHostedService, иначе рестарт и форма переписывали бы запись |
| | | 357 | | // по-разному. |
| | 0 | 358 | | RecurringJob.AddOrUpdate<LoadOzonReturnsJob>(LoadOzonReturnsJob.IncrementalJobId, |
| | 0 | 359 | | j => j.RunIncrementalAsync(monthsCount), cronExp); |
| | | 360 | | |
| | | 361 | | // Полное окно раз в сутки ночью — страховка от правок Ozon задним числом |
| | | 362 | | // и от периодов, выпавших из-за недоступности API. |
| | 0 | 363 | | RecurringJob.AddOrUpdate<LoadOzonReturnsJob>(LoadOzonReturnsJob.FullWindowJobId, |
| | 0 | 364 | | j => j.RunFullWindowAsync(monthsCount), LoadOzonReturnsJob.DefaultFullWindowCron, |
| | 0 | 365 | | new RecurringJobOptions { TimeZone = RussianTimeZoneHelper.Zone }); |
| | | 366 | | |
| | 0 | 367 | | TempData["Message"] = |
| | 0 | 368 | | $"Загрузка возвратов (как в /OrderReturns) установлена: инкрементально каждые {delay} мин., " + |
| | 0 | 369 | | $"полная сверка за {monthsCount} мес. — ежедневно в 04:00."; |
| | 0 | 370 | | return Redirect("/Hangfire"); |
| | | 371 | | } |
| | | 372 | | |
| | | 373 | | |
| | | 374 | | [HttpPost] |
| | | 375 | | public IActionResult SetStatusUpdateRecurring(int delay, int count) |
| | | 376 | | { |
| | 0 | 377 | | string cronExp = $"*/{delay} * * * *"; |
| | 0 | 378 | | RecurringJob.AddOrUpdate( |
| | 0 | 379 | | "StatusUpdateJob", |
| | 0 | 380 | | "main", |
| | 0 | 381 | | () => UpdateCartItemsStatusAsync(count), |
| | 0 | 382 | | cronExp); |
| | | 383 | | |
| | 0 | 384 | | TempData["Message"] = $"Фоновое обновление статусов установлено с периодом {delay} минут"; |
| | 0 | 385 | | return Redirect("/Hangfire"); |
| | | 386 | | } |
| | | 387 | | |
| | | 388 | | [HttpPost] |
| | | 389 | | public async Task<Dictionary<string, int[]>> EverydayUpdate(int monthsCount) |
| | | 390 | | { |
| | 0 | 391 | | var periods = GetDateRanges(monthsCount); |
| | 0 | 392 | | List<OzonClient> ozonClients = (await _ozonClientServices.GetOzonClients()) |
| | 0 | 393 | | .Where(c => c.ClientType == ClientType.OZON).ToList(); |
| | 0 | 394 | | Dictionary<string, int[]> result = new Dictionary<string, int[]>(); |
| | | 395 | | |
| | 0 | 396 | | foreach (var period in periods) |
| | | 397 | | { |
| | 0 | 398 | | int timeZone = _releaseManager.GetTimeZone(); |
| | | 399 | | |
| | | 400 | | |
| | 0 | 401 | | foreach (var client in ozonClients) |
| | | 402 | | { |
| | | 403 | | try |
| | | 404 | | { |
| | 0 | 405 | | if (string.IsNullOrEmpty(client.DecryptClientId) || string.IsNullOrEmpty(client.DecryptApiKey)) |
| | 0 | 406 | | continue; |
| | | 407 | | |
| | 0 | 408 | | _jsonDataBuilder.SetClient(client.DecryptClientId, client.DecryptApiKey); |
| | 0 | 409 | | var jsonData = await _jsonDataBuilder.BuildData(period.Item1, period.Item2); |
| | 0 | 410 | | var orders = await _orderCaster.JsonToOrders(jsonData); |
| | 0 | 411 | | orders = orders.Select(order => |
| | 0 | 412 | | { |
| | 0 | 413 | | order.OzonClient = client; |
| | 0 | 414 | | return order; |
| | 0 | 415 | | }).ToList(); |
| | 0 | 416 | | var uploadResult = await _orderRepository.AddOrders(orders); |
| | 0 | 417 | | result.Add(client.Name, uploadResult); |
| | 0 | 418 | | } |
| | 0 | 419 | | catch (Exception) |
| | | 420 | | { |
| | 0 | 421 | | continue; |
| | | 422 | | } |
| | 0 | 423 | | } |
| | | 424 | | } |
| | | 425 | | |
| | 0 | 426 | | return result; |
| | 0 | 427 | | } |
| | | 428 | | |
| | | 429 | | public async Task<string> UploadingOzon(int period) |
| | | 430 | | { |
| | 0 | 431 | | List<OzonClient> ozonClients = (await _ozonClientServices.GetOzonClients()) |
| | 0 | 432 | | .Where(c => c.ClientType == ClientType.OZON) |
| | 0 | 433 | | .ToList(); |
| | | 434 | | |
| | 0 | 435 | | Dictionary<string, int[]> result = new Dictionary<string, int[]>(); |
| | 0 | 436 | | int totalUploaded = 0; |
| | 0 | 437 | | int totalUpdated = 0; |
| | | 438 | | |
| | 0 | 439 | | int timeZone = _releaseManager.GetTimeZone(); |
| | 0 | 440 | | var start = DateTime.Now.AddHours(-period * 12 + timeZone); |
| | 0 | 441 | | var end = DateTime.Now.AddHours(timeZone); |
| | 0 | 442 | | string clientStatus = "Результат загрузки по Ozon клиентам<br>"; |
| | | 443 | | |
| | 0 | 444 | | foreach (var client in ozonClients) |
| | | 445 | | { |
| | | 446 | | try |
| | | 447 | | { |
| | 0 | 448 | | if (string.IsNullOrEmpty(client.DecryptClientId) || string.IsNullOrEmpty(client.DecryptApiKey)) |
| | | 449 | | { |
| | 0 | 450 | | clientStatus += $" {client.Name}: отсутствуют API ключи<br>"; |
| | 0 | 451 | | continue; |
| | | 452 | | } |
| | | 453 | | |
| | 0 | 454 | | _jsonDataBuilder.SetClient(client.DecryptClientId, client.DecryptApiKey); |
| | 0 | 455 | | var jsonData = await _jsonDataBuilder.BuildData(start, end); |
| | 0 | 456 | | var orders = await _orderCaster.JsonToOrders(jsonData); |
| | 0 | 457 | | orders = orders.Select(order => |
| | 0 | 458 | | { |
| | 0 | 459 | | order.OzonClient = client; |
| | 0 | 460 | | return order; |
| | 0 | 461 | | }).ToList(); |
| | | 462 | | |
| | 0 | 463 | | var updatingStatusCount = await ProcessOrdersForStatusUpdate(orders); |
| | 0 | 464 | | var uploadResult = await _orderRepository.AddOrders(orders); |
| | 0 | 465 | | result.Add(client.Name, uploadResult); |
| | | 466 | | |
| | 0 | 467 | | totalUploaded += uploadResult[0]; |
| | 0 | 468 | | totalUpdated += uploadResult[1]; |
| | | 469 | | |
| | 0 | 470 | | clientStatus += |
| | 0 | 471 | | $" {client.Name}: отчёт успешно создан (обновлено {updatingStatusCount} с |
| | 0 | 472 | | } |
| | 0 | 473 | | catch (Exception ex) |
| | | 474 | | { |
| | 0 | 475 | | clientStatus += $" {client.Name}: {ex.Message}<br>"; |
| | 0 | 476 | | } |
| | 0 | 477 | | } |
| | | 478 | | |
| | | 479 | | int? duplicateCount; |
| | | 480 | | int? deletedRowsCount; |
| | 0 | 481 | | (duplicateCount, deletedRowsCount) = _duplicateOrdersServices.DeleteDuplicateOrders(); |
| | | 482 | | |
| | 0 | 483 | | await NotificationService.NotifyAsync("Ozon", "#D97706", |
| | 0 | 484 | | $"Синхронизация завершена: добавлено {totalUploaded}, обновлено {totalUpdated}."); |
| | | 485 | | |
| | 0 | 486 | | return GetJobResultString(result, start, end, clientStatus, duplicateCount, deletedRowsCount); |
| | 0 | 487 | | } |
| | | 488 | | |
| | | 489 | | |
| | | 490 | | private async Task<int> ProcessOrdersForStatusUpdate(List<Order> orders) |
| | | 491 | | { |
| | 0 | 492 | | int updatingCount = 0; |
| | | 493 | | |
| | | 494 | | async Task ProcessOrder(Order order) |
| | | 495 | | { |
| | 0 | 496 | | order.OzonClient ??= await _ozonClientServices.GetOzonClientAsync(order.OzonClient?.Id ?? 0); |
| | 0 | 497 | | if (order.OzonClient != null && order.OzonClient.ClientType == ClientType.OZON) |
| | | 498 | | { |
| | 0 | 499 | | if (string.IsNullOrEmpty(order.OzonClient.DecryptClientId) || |
| | 0 | 500 | | string.IsNullOrEmpty(order.OzonClient.DecryptApiKey) || |
| | 0 | 501 | | string.IsNullOrEmpty(order.ShipmentNumber)) |
| | 0 | 502 | | return; |
| | | 503 | | |
| | 0 | 504 | | _jsonDataBuilder.SetClient(order.OzonClient.DecryptClientId, order.OzonClient.DecryptApiKey); |
| | | 505 | | |
| | 0 | 506 | | string newStatus = await _jsonDataBuilder.GetProductSatatus(order.ShipmentNumber); |
| | 0 | 507 | | if (!string.IsNullOrEmpty(newStatus) && |
| | 0 | 508 | | !string.Equals(order.Status, OzonStatus.OrderStatuses[newStatus], StringComparison.OrdinalIgnore |
| | | 509 | | { |
| | 0 | 510 | | order.Status = OzonStatus.OrderStatuses[newStatus]; |
| | 0 | 511 | | updatingCount++; |
| | | 512 | | } |
| | | 513 | | } |
| | 0 | 514 | | } |
| | | 515 | | |
| | 0 | 516 | | var tasks = orders.Select(order => ProcessOrder(order)); |
| | 0 | 517 | | await Task.WhenAll(tasks); |
| | 0 | 518 | | return updatingCount; |
| | 0 | 519 | | } |
| | | 520 | | |
| | | 521 | | |
| | | 522 | | public async Task<string> UploadingYandex(int period) |
| | | 523 | | { |
| | 0 | 524 | | List<OzonClient> ozonClients = (await _ozonClientServices.GetOzonClients()) |
| | 0 | 525 | | .Where(c => c.ClientType == ClientType.YANDEX) |
| | 0 | 526 | | .ToList(); |
| | | 527 | | |
| | 0 | 528 | | Dictionary<string, int[]> result = new Dictionary<string, int[]>(); |
| | 0 | 529 | | int totalUploaded = 0; |
| | 0 | 530 | | int totalUpdated = 0; |
| | 0 | 531 | | int totalStatusUpdated = 0; |
| | 0 | 532 | | int totalCancellations = 0; |
| | | 533 | | |
| | 0 | 534 | | int timeZone = _releaseManager.GetTimeZone(); |
| | | 535 | | // Окно теперь по дате ОБНОВЛЕНИЯ заказа (см. YandexDataManager.GetOrders), |
| | | 536 | | // поэтому в выгрузку попадают и отмены заказов, созданных раньше. |
| | 0 | 537 | | var start = DateTime.Now.AddHours(-period * 12 + timeZone); |
| | 0 | 538 | | var end = DateTime.Now.AddHours(timeZone); |
| | 0 | 539 | | string clientStatus = "Результат загрузки по Yandex клиентам<br>"; |
| | | 540 | | |
| | 0 | 541 | | foreach (var client in ozonClients) |
| | | 542 | | { |
| | | 543 | | try |
| | | 544 | | { |
| | 0 | 545 | | if (string.IsNullOrEmpty(client.DecryptClientId) || string.IsNullOrEmpty(client.DecryptApiKey)) |
| | | 546 | | { |
| | 0 | 547 | | clientStatus += $" {client.Name}: отсутствуют API ключи<br>"; |
| | 0 | 548 | | continue; |
| | | 549 | | } |
| | | 550 | | |
| | 0 | 551 | | _yandexDataManager.SetClient(client.DecryptClientId, client.DecryptApiKey); |
| | 0 | 552 | | var jsonData = await _yandexDataManager.GetOrders(start, end); |
| | | 553 | | |
| | 0 | 554 | | if (jsonData.Count == 0 && _yandexDataManager.LastError != null) |
| | | 555 | | { |
| | 0 | 556 | | clientStatus += $" {client.Name}: " + |
| | 0 | 557 | | $"{_yandexDataManager.LastError}<br>"; |
| | 0 | 558 | | continue; |
| | | 559 | | } |
| | | 560 | | |
| | 0 | 561 | | var orders = await _orderCaster.YandexToOrders(jsonData); |
| | 0 | 562 | | orders = orders.Select(order => |
| | 0 | 563 | | { |
| | 0 | 564 | | order.OzonClient = client; |
| | 0 | 565 | | return order; |
| | 0 | 566 | | }).ToList(); |
| | | 567 | | |
| | 0 | 568 | | var uploadResult = await _orderRepository.AddOrders(orders); |
| | 0 | 569 | | result.Add(client.Name, uploadResult); |
| | | 570 | | |
| | 0 | 571 | | totalUploaded += uploadResult[0]; |
| | 0 | 572 | | totalUpdated += uploadResult[1]; |
| | | 573 | | |
| | | 574 | | // Статусы и причины отмены — отдельным шагом: рефлексия в AddOrders навигационный |
| | | 575 | | // ClientStatus существующего заказа не обновляет. |
| | 0 | 576 | | var statusSync = await _yandexOrderStatusSyncService.SyncAsync(client, jsonData); |
| | 0 | 577 | | totalStatusUpdated += statusSync.ClientStatusUpdated; |
| | 0 | 578 | | totalCancellations += statusSync.CancellationsRecorded; |
| | | 579 | | |
| | 0 | 580 | | clientStatus += $" {client.Name}: отчёт успешно создан" + |
| | 0 | 581 | | $" (статусов обновлено: {statusSync.ClientStatusUpdated}," + |
| | 0 | 582 | | $" отмен зафиксировано: {statusSync.CancellationsRecorded})<br>"; |
| | 0 | 583 | | } |
| | 0 | 584 | | catch (Exception ex) |
| | | 585 | | { |
| | 0 | 586 | | clientStatus += $" {client.Name}: {ex.Message}<br>"; |
| | 0 | 587 | | continue; |
| | | 588 | | } |
| | 0 | 589 | | } |
| | | 590 | | |
| | | 591 | | int? duplicateCount; |
| | | 592 | | int? deletedRowsCount; |
| | 0 | 593 | | (duplicateCount, deletedRowsCount) = _duplicateOrdersServices.DeleteDuplicateOrders(); |
| | | 594 | | |
| | 0 | 595 | | await NotificationService.NotifyAsync("Yandex", "#0EA5E9", |
| | 0 | 596 | | $"Синхронизация завершена: добавлено {totalUploaded}, обновлено {totalUpdated}, " + |
| | 0 | 597 | | $"статусов изменено {totalStatusUpdated}, отмен {totalCancellations}."); |
| | | 598 | | |
| | 0 | 599 | | return GetJobResultString(result, start, end, clientStatus, duplicateCount, deletedRowsCount); |
| | 0 | 600 | | } |
| | | 601 | | |
| | | 602 | | |
| | | 603 | | |
| | | 604 | | private string GetJobResultString(Dictionary<string, int[]> result, DateTime start, DateTime end, |
| | | 605 | | string clientStatus, int? duplicateCount, int? deletedRowsCount) |
| | | 606 | | { |
| | 0 | 607 | | string jobResult = ""; |
| | | 608 | | |
| | 0 | 609 | | jobResult += |
| | 0 | 610 | | $"Период: {start.ToString("dd.MM.yyyy HH:mm:ss")} - {end.ToString("dd.MM.yyyy HH:mm:ss")}<br/>"; |
| | 0 | 611 | | foreach (var kvp in result) |
| | | 612 | | { |
| | 0 | 613 | | jobResult += |
| | 0 | 614 | | $" Клиент: {kvp.Key} - загружено {kvp.Value[0]}, обновлено {kvp.Value[1]}<br/ |
| | | 615 | | } |
| | | 616 | | |
| | 0 | 617 | | jobResult += clientStatus; |
| | | 618 | | |
| | 0 | 619 | | jobResult += $"Удалено дублей {deletedRowsCount} из {duplicateCount}"; |
| | | 620 | | |
| | | 621 | | |
| | 0 | 622 | | return jobResult; |
| | | 623 | | } |
| | | 624 | | |
| | | 625 | | public List<(DateTime, DateTime)> GetDateRanges(int months) |
| | | 626 | | { |
| | 0 | 627 | | List<(DateTime, DateTime)> dateRanges = new List<(DateTime, DateTime)>(); |
| | | 628 | | |
| | 0 | 629 | | DateTime endDate = DateTime.Today; |
| | | 630 | | |
| | 0 | 631 | | DateTime startDate = endDate.AddMonths(-months); |
| | | 632 | | |
| | 0 | 633 | | while (startDate < endDate) |
| | | 634 | | { |
| | 0 | 635 | | DateTime weekStart = startDate; |
| | 0 | 636 | | DateTime weekEnd = startDate.AddDays(6); |
| | 0 | 637 | | if (weekEnd > endDate) |
| | | 638 | | { |
| | 0 | 639 | | weekEnd = endDate; |
| | | 640 | | } |
| | | 641 | | |
| | 0 | 642 | | dateRanges.Add((weekStart, weekEnd)); |
| | 0 | 643 | | startDate = startDate.AddDays(7); |
| | | 644 | | } |
| | | 645 | | |
| | 0 | 646 | | return dateRanges; |
| | | 647 | | } |
| | | 648 | | |
| | | 649 | | /// <summary> |
| | | 650 | | /// Настройка периодической синхронизации чатов Ozon с заказами |
| | | 651 | | /// </summary> |
| | | 652 | | [HttpPost] |
| | | 653 | | public IActionResult SetChatSyncRecurring(int delay) |
| | | 654 | | { |
| | 0 | 655 | | string cronExp = $"*/{delay} * * * *"; |
| | 0 | 656 | | RecurringJob.AddOrUpdate("OzonChatSync", "main", () => SyncOzonChatOrders(), cronExp); |
| | | 657 | | |
| | 0 | 658 | | TempData["Message"] = $"Синхронизация чатов Ozon установлена с периодом {delay} минут"; |
| | 0 | 659 | | return Redirect("/Hangfire"); |
| | | 660 | | } |
| | | 661 | | |
| | | 662 | | /// <summary> |
| | | 663 | | /// Синхронизация чатов Ozon с заказами (фоновая задача). |
| | | 664 | | /// Получает все чаты для всех OZON клиентов и связывает их с заказами в базе данных. |
| | | 665 | | /// </summary> |
| | | 666 | | public async Task<string> SyncOzonChatOrders() |
| | | 667 | | { |
| | 0 | 668 | | var result = new StringBuilder(); |
| | 0 | 669 | | int totalChatsProcessed = 0; |
| | 0 | 670 | | int totalLinksCreated = 0; |
| | 0 | 671 | | int totalLinksUpdated = 0; |
| | | 672 | | |
| | | 673 | | try |
| | | 674 | | { |
| | 0 | 675 | | result.AppendLine("=== Синхронизация чатов Ozon с заказами ===<br>"); |
| | | 676 | | |
| | | 677 | | // Получаем всех OZON клиентов |
| | 0 | 678 | | var ozonClients = await _ozonClientServices.GetOzonClients(); |
| | 0 | 679 | | var validClients = ozonClients |
| | 0 | 680 | | .Where(c => !string.IsNullOrEmpty(c.ClientId) && !string.IsNullOrEmpty(c.ApiKey) && |
| | 0 | 681 | | c.ClientType == ClientType.OZON).ToList(); |
| | | 682 | | |
| | 0 | 683 | | if (!validClients.Any()) |
| | | 684 | | { |
| | 0 | 685 | | result.AppendLine("Нет настроенных клиентов OZON<br>"); |
| | 0 | 686 | | return result.ToString(); |
| | | 687 | | } |
| | | 688 | | |
| | 0 | 689 | | result.AppendLine($"Найдено клиентов: {validClients.Count}<br><br>"); |
| | | 690 | | |
| | 0 | 691 | | foreach (var client in validClients) |
| | | 692 | | { |
| | | 693 | | try |
| | | 694 | | { |
| | 0 | 695 | | result.AppendLine($"<b>Клиент: {client.Name}</b><br>"); |
| | | 696 | | |
| | 0 | 697 | | if (string.IsNullOrEmpty(client.DecryptClientId) || string.IsNullOrEmpty(client.DecryptApiKey)) |
| | | 698 | | { |
| | 0 | 699 | | result.AppendLine(" Ошибка: отсутствуют API ключи<br>"); |
| | 0 | 700 | | continue; |
| | | 701 | | } |
| | | 702 | | |
| | 0 | 703 | | var chatManager = new OzonChatManager(_httpClientFactory, client.DecryptClientId, |
| | 0 | 704 | | client.DecryptApiKey); |
| | | 705 | | |
| | | 706 | | // Получаем все чаты с пагинацией (по 100 за проход) |
| | 0 | 707 | | var allChats = new List<ChatItem>(); |
| | 0 | 708 | | string? cursor = null; |
| | 0 | 709 | | int pageNumber = 0; |
| | | 710 | | const int pageSize = 100; |
| | | 711 | | const int maxPages = 5; // Защита от бесконечного цикла (макс 5000 чатов) |
| | | 712 | | |
| | | 713 | | do |
| | | 714 | | { |
| | 0 | 715 | | pageNumber++; |
| | 0 | 716 | | var request = new ChatListRequest |
| | 0 | 717 | | { |
| | 0 | 718 | | Filter = new ChatFilter |
| | 0 | 719 | | { |
| | 0 | 720 | | ChatStatus = "Opened", |
| | 0 | 721 | | UnreadOnly = false |
| | 0 | 722 | | }, |
| | 0 | 723 | | Limit = pageSize, |
| | 0 | 724 | | Cursor = cursor |
| | 0 | 725 | | }; |
| | | 726 | | |
| | 0 | 727 | | var response = await chatManager.GetChatListAsync(request); |
| | 0 | 728 | | var chatsPage = response?.Chats ?? new List<ChatItem>(); |
| | 0 | 729 | | allChats.AddRange(chatsPage); |
| | | 730 | | |
| | | 731 | | // Обновляем cursor для следующей страницы |
| | 0 | 732 | | cursor = response?.Cursor; |
| | 0 | 733 | | var hasNext = response?.HasNext ?? false; |
| | | 734 | | |
| | 0 | 735 | | if (!hasNext || string.IsNullOrEmpty(cursor) || pageNumber >= maxPages) |
| | | 736 | | break; |
| | | 737 | | |
| | | 738 | | // Небольшая задержка между запросами для снижения нагрузки на API |
| | 0 | 739 | | await Task.Delay(100); |
| | 0 | 740 | | } while (true); |
| | | 741 | | |
| | 0 | 742 | | result.AppendLine($" Найдено чатов: {allChats.Count} (страниц: {pageNumber})<br>"); |
| | | 743 | | |
| | 0 | 744 | | if (!allChats.Any()) |
| | 0 | 745 | | continue; |
| | | 746 | | |
| | | 747 | | // Обрабатываем каждый чат |
| | 0 | 748 | | foreach (var chatItem in allChats) |
| | | 749 | | { |
| | | 750 | | try |
| | | 751 | | { |
| | 0 | 752 | | totalChatsProcessed++; |
| | | 753 | | |
| | | 754 | | // Получить сервисы в этом scope |
| | 0 | 755 | | using var scope = _serviceScopeFactory.CreateScope(); |
| | 0 | 756 | | var chatOrderService = |
| | 0 | 757 | | scope.ServiceProvider.GetRequiredService<OzonChatOrderDataServices>(); |
| | 0 | 758 | | var orderRepository = scope.ServiceProvider.GetRequiredService<OrderRepository>(); |
| | | 759 | | |
| | | 760 | | // Проверяем, есть ли уже связь для этого чата |
| | 0 | 761 | | var existingLinks = await chatOrderService.GetByChatIdAsync(chatItem.Chat.ChatId ?? stri |
| | | 762 | | |
| | 0 | 763 | | if (existingLinks.Any()) |
| | | 764 | | { |
| | | 765 | | // Обновляем существующие связи |
| | 0 | 766 | | foreach (var link in existingLinks) |
| | | 767 | | { |
| | 0 | 768 | | link.ChatStatus = chatItem.Chat.ChatStatus; |
| | 0 | 769 | | link.ChatType = chatItem.Chat.ChatType; |
| | 0 | 770 | | link.UnreadMessagesCount = chatItem.UnreadCount; |
| | 0 | 771 | | await chatOrderService.Update(link); |
| | 0 | 772 | | totalLinksUpdated++; |
| | | 773 | | } |
| | | 774 | | |
| | 0 | 775 | | continue; |
| | | 776 | | } |
| | | 777 | | |
| | | 778 | | // Если нет связей - пытаемся создать новые |
| | | 779 | | // Получаем историю чата для извлечения order_number |
| | 0 | 780 | | if ((chatItem.Chat.ChatType == "BUYER_SELLER" || chatItem.UnreadCount > 0) && |
| | 0 | 781 | | !string.IsNullOrEmpty(chatItem.Chat.ChatId)) |
| | | 782 | | { |
| | 0 | 783 | | var history = await chatManager.GetChatHistoryAsync( |
| | 0 | 784 | | chatItem.Chat.ChatId, |
| | 0 | 785 | | limit: 50, |
| | 0 | 786 | | fromMessageId: null |
| | 0 | 787 | | ); |
| | | 788 | | |
| | 0 | 789 | | if (history?.Messages != null && history.Messages.Any()) |
| | | 790 | | { |
| | | 791 | | // Ищем сообщение с order_number или SKU |
| | 0 | 792 | | var messageWithOrder = history.Messages |
| | 0 | 793 | | .FirstOrDefault(m => !string.IsNullOrEmpty(m.Context?.OrderNumber) || |
| | 0 | 794 | | !string.IsNullOrEmpty(m.Context?.Sku)); |
| | | 795 | | |
| | 0 | 796 | | if (messageWithOrder != null) |
| | | 797 | | { |
| | 0 | 798 | | var orderNumber = messageWithOrder.Context!.OrderNumber; |
| | 0 | 799 | | var sku = messageWithOrder.Context!.Sku; |
| | | 800 | | |
| | 0 | 801 | | var ordersToLink = new List<Order>(); |
| | | 802 | | |
| | | 803 | | // Сначала пытаемся найти заказ по номеру отправления |
| | 0 | 804 | | if (!string.IsNullOrEmpty(orderNumber)) |
| | | 805 | | { |
| | 0 | 806 | | var order = await orderRepository.GetOrderByShipmentNumberAsync( |
| | 0 | 807 | | orderNumber!, client.Id); |
| | 0 | 808 | | if (order != null) |
| | 0 | 809 | | ordersToLink.Add(order); |
| | | 810 | | } |
| | | 811 | | |
| | | 812 | | // Если не нашли по номеру, пытаемся найти по SKU |
| | 0 | 813 | | if (!ordersToLink.Any() && !string.IsNullOrEmpty(sku)) |
| | | 814 | | { |
| | 0 | 815 | | var ordersBySku = |
| | 0 | 816 | | await orderRepository.GetOrdersBySkuAsync(sku!, client.Id); |
| | 0 | 817 | | ordersToLink.AddRange(ordersBySku); |
| | | 818 | | } |
| | | 819 | | |
| | 0 | 820 | | if (ordersToLink.Any()) |
| | | 821 | | { |
| | 0 | 822 | | foreach (var order in ordersToLink) |
| | | 823 | | { |
| | 0 | 824 | | var postingNumber = !string.IsNullOrEmpty(orderNumber) |
| | 0 | 825 | | ? orderNumber |
| | 0 | 826 | | : order.ShipmentNumber; |
| | | 827 | | |
| | 0 | 828 | | await chatOrderService.CreateOrUpdateAsync( |
| | 0 | 829 | | chatId: chatItem.Chat.ChatId, |
| | 0 | 830 | | orderId: order.Id, |
| | 0 | 831 | | clientId: client.Id, |
| | 0 | 832 | | postingNumber: postingNumber, |
| | 0 | 833 | | unreadCount: chatItem.UnreadCount, |
| | 0 | 834 | | chatStatus: chatItem.Chat.ChatStatus, |
| | 0 | 835 | | chatType: chatItem.Chat.ChatType |
| | 0 | 836 | | ); |
| | | 837 | | |
| | | 838 | | // Обновляем информацию о последнем сообщении |
| | 0 | 839 | | var lastMessage = history.Messages.First(); |
| | 0 | 840 | | var messageText = lastMessage.Data != null && lastMessage.Data.Any() |
| | 0 | 841 | | ? string.Join(" ", lastMessage.Data) |
| | 0 | 842 | | : string.Empty; |
| | | 843 | | |
| | 0 | 844 | | var lastMessageFromCustomer = lastMessage.User?.Type? |
| | 0 | 845 | | .Equals("Customer", StringComparison.OrdinalIgnoreCase) == true; |
| | | 846 | | |
| | 0 | 847 | | await chatOrderService.UpdateLastMessageAsync( |
| | 0 | 848 | | chatId: chatItem.Chat.ChatId, |
| | 0 | 849 | | orderId: order.Id, |
| | 0 | 850 | | messageDate: lastMessage.CreatedAt.ToUniversalTime(), |
| | 0 | 851 | | messageText: messageText, |
| | 0 | 852 | | fromCustomer: lastMessageFromCustomer |
| | 0 | 853 | | ); |
| | | 854 | | |
| | 0 | 855 | | totalLinksCreated++; |
| | 0 | 856 | | result.AppendLine( |
| | 0 | 857 | | $" + Чат {chatItem.Chat.ChatId} → заказ { |
| | 0 | 858 | | } |
| | | 859 | | } |
| | 0 | 860 | | } |
| | | 861 | | } |
| | 0 | 862 | | } |
| | 0 | 863 | | } |
| | 0 | 864 | | catch (Exception ex) |
| | | 865 | | { |
| | 0 | 866 | | result.AppendLine( |
| | 0 | 867 | | $" Ошибка чата {chatItem.Chat.ChatId}: {ex.Message}<br>"); |
| | 0 | 868 | | } |
| | 0 | 869 | | } |
| | | 870 | | |
| | 0 | 871 | | result.AppendLine("<br>"); |
| | 0 | 872 | | } |
| | 0 | 873 | | catch (Exception ex) |
| | | 874 | | { |
| | 0 | 875 | | result.AppendLine($" Ошибка клиента {client.Name}: {ex.Message}<br><br>"); |
| | 0 | 876 | | } |
| | 0 | 877 | | } |
| | | 878 | | |
| | 0 | 879 | | result.AppendLine($"<b>Итого:</b><br>"); |
| | 0 | 880 | | result.AppendLine($" Обработано чатов: {totalChatsProcessed}<br>"); |
| | 0 | 881 | | result.AppendLine($" Создано связей: {totalLinksCreated}<br>"); |
| | 0 | 882 | | result.AppendLine($" Обновлено связей: {totalLinksUpdated}<br>"); |
| | | 883 | | |
| | 0 | 884 | | await NotificationService.NotifyAllAsync( |
| | 0 | 885 | | $"Синхронизация чатов: обработано {totalChatsProcessed}, создано {totalLinksCreated}, обновлено {tot |
| | | 886 | | |
| | 0 | 887 | | return result.ToString(); |
| | | 888 | | } |
| | 0 | 889 | | catch (Exception ex) |
| | | 890 | | { |
| | 0 | 891 | | return $"Ошибка синхронизации чатов: {ex.Message}"; |
| | | 892 | | } |
| | 0 | 893 | | } |
| | | 894 | | |
| | | 895 | | /// <summary> |
| | | 896 | | /// Обновляет статусы заказов (ClientStatus) по логике ProcessOrdersStatusUpdate в OrdersController: |
| | | 897 | | /// берёт последние count заказов и получает статус из API Ozon. |
| | | 898 | | /// </summary> |
| | | 899 | | public async Task<string> UpdateCartItemsStatusAsync(int count) |
| | | 900 | | { |
| | | 901 | | try |
| | | 902 | | { |
| | 0 | 903 | | var orderIds = await _context.Orders |
| | 0 | 904 | | .AsNoTracking() |
| | 0 | 905 | | .Where(o => o.OrderArchive == null) |
| | 0 | 906 | | .OrderByDescending(o => o.ProcessingDate) |
| | 0 | 907 | | .Take(count) |
| | 0 | 908 | | .Select(o => o.Id) |
| | 0 | 909 | | .ToListAsync(); |
| | | 910 | | |
| | 0 | 911 | | if (orderIds == null || !orderIds.Any()) |
| | 0 | 912 | | return "<p>Ошибка: Нет доступных заказов для обновления</p>"; |
| | | 913 | | |
| | | 914 | | // Загрузка с трэкингом для последующего обновления и SaveChanges |
| | 0 | 915 | | var ordersToUpdate = |
| | 0 | 916 | | await _orderDataServices.GetOrdersByIdsTracked(orderIds, includeArchived: false); |
| | | 917 | | |
| | 0 | 918 | | return await UpdateClientStatusesForOrdersAsync(ordersToUpdate, "за последние заказы"); |
| | | 919 | | } |
| | 0 | 920 | | catch (Exception ex) |
| | | 921 | | { |
| | 0 | 922 | | return $"<p>Ошибка при обновлении статусов заказов: {ex.Message}</p>"; |
| | | 923 | | } |
| | 0 | 924 | | } |
| | | 925 | | |
| | | 926 | | /// <summary> |
| | | 927 | | /// POST из UI: ставит в очередь фоновую задачу обновления статусов по ProcessingDate. |
| | | 928 | | /// </summary> |
| | | 929 | | [HttpPost] |
| | | 930 | | public IActionResult UpdateStatusesByProcessingDate(DateTime from, DateTime to) |
| | | 931 | | { |
| | 0 | 932 | | var api = JobStorage.Current.GetMonitoringApi(); |
| | 0 | 933 | | TryGetPeriodStatusUpdateState(api, out var state, out var existingJobId, out _); |
| | 0 | 934 | | if (state == "processing") |
| | | 935 | | { |
| | 0 | 936 | | TempData["Message"] = $"Обновление статусов по периоду уже выполняется (JobId: {existingJobId})."; |
| | 0 | 937 | | return RedirectToAction(nameof(Index), new { pageTab = "schedules" }); |
| | | 938 | | } |
| | | 939 | | |
| | | 940 | | // Если в очереди уже есть задача — не блокируем запуск. |
| | | 941 | | // Чтобы избежать дубликатов, пробуем удалить предыдущую enqueued-задачу. |
| | 0 | 942 | | if (state == "enqueued" && !string.IsNullOrWhiteSpace(existingJobId)) |
| | | 943 | | { |
| | | 944 | | try |
| | | 945 | | { |
| | 0 | 946 | | BackgroundJob.Delete(existingJobId); |
| | 0 | 947 | | } |
| | 0 | 948 | | catch |
| | | 949 | | { |
| | | 950 | | /* ignore */ |
| | 0 | 951 | | } |
| | | 952 | | } |
| | | 953 | | |
| | 0 | 954 | | HangfireJobClientExtensions.EnqueueMain(() => UpdateStatusesByProcessingDateBackground(from, to, null)); |
| | 0 | 955 | | TempData["Message"] = |
| | 0 | 956 | | $"Задача обновления статусов по периоду {from:dd.MM.yyyy} - {to:dd.MM.yyyy} поставлена в очередь."; |
| | 0 | 957 | | return RedirectToAction(nameof(Index)); |
| | | 958 | | } |
| | | 959 | | |
| | | 960 | | /// <summary> |
| | | 961 | | /// Запуск обновления статусов по периоду с передачей прогресса в SignalR (jobId). |
| | | 962 | | /// Возвращает JSON для вызова из модального окна. |
| | | 963 | | /// </summary> |
| | | 964 | | [HttpPost] |
| | | 965 | | public IActionResult StartStatusUpdateByPeriod(DateTime from, DateTime to, [FromForm] string jobId) |
| | | 966 | | { |
| | 0 | 967 | | if (string.IsNullOrWhiteSpace(jobId)) |
| | 0 | 968 | | return BadRequest(new { error = "jobId обязателен" }); |
| | | 969 | | |
| | 0 | 970 | | var api = JobStorage.Current.GetMonitoringApi(); |
| | 0 | 971 | | TryGetPeriodStatusUpdateState(api, out var state, out var existingJobId, out var startedAtUtc); |
| | 0 | 972 | | if (state == "processing") |
| | | 973 | | { |
| | 0 | 974 | | var msg = |
| | 0 | 975 | | $"Уже выполняется обновление статусов по периоду (JobId: {existingJobId}, старт: {startedAtUtc?.ToLo |
| | 0 | 976 | | return StatusCode(409, new { success = false, state, jobId = existingJobId, message = msg }); |
| | | 977 | | } |
| | | 978 | | |
| | | 979 | | // Разрешаем повторный запуск, даже если задача уже enqueued. |
| | | 980 | | // Чтобы не плодить дубликаты, пробуем удалить предыдущую enqueued-задачу. |
| | 0 | 981 | | if (state == "enqueued" && !string.IsNullOrWhiteSpace(existingJobId)) |
| | | 982 | | { |
| | | 983 | | try |
| | | 984 | | { |
| | 0 | 985 | | BackgroundJob.Delete(existingJobId); |
| | 0 | 986 | | } |
| | 0 | 987 | | catch |
| | | 988 | | { |
| | | 989 | | /* ignore */ |
| | 0 | 990 | | } |
| | | 991 | | } |
| | | 992 | | |
| | 0 | 993 | | HangfireJobClientExtensions.EnqueueMain(() => UpdateStatusesByProcessingDateBackground(from, to, jobId.Trim( |
| | 0 | 994 | | return Json(new { success = true, jobId = jobId.Trim() }); |
| | | 995 | | } |
| | | 996 | | |
| | | 997 | | /// <summary> |
| | | 998 | | /// Фоновая задача: обновляет статусы заказов (ClientStatus) для всех заказов |
| | | 999 | | /// в указанном периоде по ProcessingDate (включительно). |
| | | 1000 | | /// Если передан jobId — прогресс и логи отправляются в SignalR-группу jobId. |
| | | 1001 | | /// </summary> |
| | | 1002 | | [Queue(HangfireQueueNames.Main)] |
| | | 1003 | | public async Task<string> UpdateStatusesByProcessingDateBackground(DateTime from, DateTime to, |
| | | 1004 | | string? jobId = null) |
| | | 1005 | | { |
| | 0 | 1006 | | var fromDate = from.Date; |
| | 0 | 1007 | | var toDate = to.Date.AddDays(1).AddTicks(-1); |
| | 0 | 1008 | | var hubJobId = jobId?.Trim(); |
| | 0 | 1009 | | var hasHub = !string.IsNullOrEmpty(hubJobId); |
| | 0 | 1010 | | IStorageConnection? lockConnection = null; |
| | 0 | 1011 | | IDisposable? distLock = null; |
| | | 1012 | | |
| | | 1013 | | async Task SendLog(string message) |
| | | 1014 | | { |
| | 0 | 1015 | | if (hasHub) |
| | 0 | 1016 | | await _jobProgressHub.Clients.Group(hubJobId!).SendAsync("Log", message); |
| | 0 | 1017 | | } |
| | | 1018 | | |
| | | 1019 | | async Task SendProgress(int current, int total, string? statusText = null) |
| | | 1020 | | { |
| | 0 | 1021 | | if (hasHub) |
| | 0 | 1022 | | await _jobProgressHub.Clients.Group(hubJobId!).SendAsync("Progress", current, total, statusText ?? " |
| | 0 | 1023 | | } |
| | | 1024 | | |
| | | 1025 | | async Task SendComplete(bool success, string report) |
| | | 1026 | | { |
| | 0 | 1027 | | if (hasHub) |
| | 0 | 1028 | | await _jobProgressHub.Clients.Group(hubJobId!).SendAsync("Complete", success, report ?? ""); |
| | 0 | 1029 | | } |
| | | 1030 | | |
| | | 1031 | | async Task SendError(string message) |
| | | 1032 | | { |
| | 0 | 1033 | | if (hasHub) |
| | 0 | 1034 | | await _jobProgressHub.Clients.Group(hubJobId!).SendAsync("Error", message); |
| | 0 | 1035 | | } |
| | | 1036 | | |
| | | 1037 | | try |
| | | 1038 | | { |
| | | 1039 | | // Глобальная защита от параллельного выполнения (на уровне Hangfire storage) |
| | | 1040 | | try |
| | | 1041 | | { |
| | 0 | 1042 | | lockConnection = JobStorage.Current.GetConnection(); |
| | 0 | 1043 | | distLock = lockConnection.AcquireDistributedLock(PeriodStatusUpdateLockKey, |
| | 0 | 1044 | | TimeSpan.FromMilliseconds(1)); |
| | 0 | 1045 | | } |
| | 0 | 1046 | | catch (DistributedLockTimeoutException) |
| | | 1047 | | { |
| | 0 | 1048 | | var msg = "Обновление статусов по периоду уже выполняется. Повторный запуск отменён."; |
| | 0 | 1049 | | await SendLog(msg); |
| | 0 | 1050 | | await SendComplete(false, msg); |
| | 0 | 1051 | | return msg; |
| | | 1052 | | } |
| | | 1053 | | |
| | 0 | 1054 | | await SendLog($"Период: {fromDate:dd.MM.yyyy} — {toDate:dd.MM.yyyy}. Поиск заказов..."); |
| | | 1055 | | |
| | 0 | 1056 | | var orderIds = await _context.Orders |
| | 0 | 1057 | | .AsNoTracking() |
| | 0 | 1058 | | .Where(o => o.OrderArchive == null && |
| | 0 | 1059 | | o.ProcessingDate >= fromDate && |
| | 0 | 1060 | | o.ProcessingDate <= toDate) |
| | 0 | 1061 | | .OrderBy(o => o.ProcessingDate) |
| | 0 | 1062 | | .Select(o => o.Id) |
| | 0 | 1063 | | .ToListAsync(); |
| | | 1064 | | |
| | 0 | 1065 | | if (orderIds == null || !orderIds.Any()) |
| | | 1066 | | { |
| | 0 | 1067 | | var msg = "Нет заказов для обновления статусов в указанном периоде."; |
| | 0 | 1068 | | await SendLog(msg); |
| | 0 | 1069 | | await SendComplete(false, msg); |
| | 0 | 1070 | | return msg; |
| | | 1071 | | } |
| | | 1072 | | |
| | 0 | 1073 | | await SendLog($"Найдено заказов: {orderIds.Count}. Загрузка данных..."); |
| | 0 | 1074 | | await SendProgress(0, orderIds.Count, "Загрузка заказов..."); |
| | | 1075 | | |
| | 0 | 1076 | | var ordersToUpdate = |
| | 0 | 1077 | | await _orderDataServices.GetOrdersByIdsTracked(orderIds, includeArchived: false); |
| | | 1078 | | |
| | 0 | 1079 | | await SendLog($"Загружено {ordersToUpdate.Count} заказов. Обновление статусов через API..."); |
| | | 1080 | | |
| | 0 | 1081 | | var report = await UpdateClientStatusesForOrdersAsync( |
| | 0 | 1082 | | ordersToUpdate, |
| | 0 | 1083 | | $"за период {fromDate:dd.MM.yyyy} - {toDate:dd.MM.yyyy}", |
| | 0 | 1084 | | sendLog: hasHub ? (async (msg) => await SendLog(msg)) : null, |
| | 0 | 1085 | | sendProgress: hasHub ? (async (cur, tot, text) => await SendProgress(cur, tot, text)) : null); |
| | | 1086 | | |
| | 0 | 1087 | | await SendProgress(orderIds.Count, orderIds.Count, "Готово"); |
| | 0 | 1088 | | await SendComplete(true, report); |
| | 0 | 1089 | | return report; |
| | | 1090 | | } |
| | 0 | 1091 | | catch (Exception ex) |
| | | 1092 | | { |
| | 0 | 1093 | | var errMsg = $"Ошибка: {ex.Message}"; |
| | 0 | 1094 | | await SendError(errMsg); |
| | 0 | 1095 | | return errMsg; |
| | | 1096 | | } |
| | | 1097 | | finally |
| | | 1098 | | { |
| | 0 | 1099 | | HangfireDistributedLockHelper.SafeDispose(ref distLock, ref lockConnection); |
| | | 1100 | | } |
| | 0 | 1101 | | } |
| | | 1102 | | |
| | | 1103 | | /// <summary> |
| | | 1104 | | /// Общая реализация обновления ClientStatus для набора заказов Ozon с батчевой обработкой. |
| | | 1105 | | /// </summary> |
| | | 1106 | | private async Task<string> UpdateClientStatusesForOrdersAsync( |
| | | 1107 | | List<Order> ordersToUpdate, |
| | | 1108 | | string contextInfo, |
| | | 1109 | | Func<string, Task>? sendLog = null, |
| | | 1110 | | Func<int, int, string, Task>? sendProgress = null) |
| | | 1111 | | { |
| | | 1112 | | static async Task SafeSendLog(Func<string, Task>? logFn, string message) |
| | | 1113 | | { |
| | 0 | 1114 | | if (logFn == null) return; |
| | | 1115 | | try |
| | | 1116 | | { |
| | 0 | 1117 | | var t = logFn(message); |
| | 0 | 1118 | | if (t != null) await t; |
| | 0 | 1119 | | } |
| | 0 | 1120 | | catch |
| | | 1121 | | { |
| | | 1122 | | // ignore logging errors |
| | 0 | 1123 | | } |
| | 0 | 1124 | | } |
| | | 1125 | | |
| | | 1126 | | static async Task SafeSendProgress(Func<int, int, string, Task>? progressFn, int current, int total, |
| | | 1127 | | string text) |
| | | 1128 | | { |
| | 0 | 1129 | | if (progressFn == null) return; |
| | | 1130 | | try |
| | | 1131 | | { |
| | 0 | 1132 | | var t = progressFn(current, total, text); |
| | 0 | 1133 | | if (t != null) await t; |
| | 0 | 1134 | | } |
| | 0 | 1135 | | catch |
| | | 1136 | | { |
| | | 1137 | | // ignore progress errors |
| | 0 | 1138 | | } |
| | 0 | 1139 | | } |
| | | 1140 | | |
| | 0 | 1141 | | if (ordersToUpdate == null || ordersToUpdate.Count == 0) |
| | 0 | 1142 | | return "<p>Ошибка: Нет доступных заказов для обновления</p>"; |
| | | 1143 | | |
| | | 1144 | | const int batchSize = 10; // Размер батча |
| | 0 | 1145 | | int totalUpdated = 0; |
| | 0 | 1146 | | var updateInfoBuilder = new StringBuilder(); |
| | 0 | 1147 | | var total = ordersToUpdate.Count; |
| | 0 | 1148 | | var processedCount = 0; |
| | | 1149 | | |
| | 0 | 1150 | | await SafeSendLog(sendLog, $"Начало обработки {total} заказов, размер батча: {batchSize}"); |
| | | 1151 | | |
| | | 1152 | | // Чтобы в логах не было "тишины" при отсутствии изменений |
| | 0 | 1153 | | var heartbeat = System.Diagnostics.Stopwatch.StartNew(); |
| | 0 | 1154 | | var lastProgress = System.Diagnostics.Stopwatch.StartNew(); |
| | | 1155 | | |
| | | 1156 | | // Обрабатываем заказы батчами |
| | 0 | 1157 | | for (int batchStart = 0; batchStart < total; batchStart += batchSize) |
| | | 1158 | | { |
| | 0 | 1159 | | var batch = ordersToUpdate |
| | 0 | 1160 | | .Skip(batchStart) |
| | 0 | 1161 | | .Take(batchSize) |
| | 0 | 1162 | | .ToList(); |
| | | 1163 | | |
| | 0 | 1164 | | var batchUpdates = new List<(Order Order, ClientStatus NewStatus)>(); |
| | 0 | 1165 | | var batchLogs = new StringBuilder(); |
| | 0 | 1166 | | var batchNumber = batchStart / batchSize + 1; |
| | | 1167 | | |
| | 0 | 1168 | | await SafeSendLog(sendLog, |
| | 0 | 1169 | | $"▶️ Батч {batchNumber}: заказы {batchStart + 1}-{Math.Min(batchStart + batchSize, total)} из {total |
| | | 1170 | | |
| | | 1171 | | // Шаг 1: Получаем статусы для всех заказов в батче |
| | 0 | 1172 | | foreach (var order in batch) |
| | | 1173 | | { |
| | 0 | 1174 | | processedCount++; |
| | | 1175 | | |
| | | 1176 | | // Throttle прогресса, чтобы не забивать SignalR и не стопорить обработку |
| | 0 | 1177 | | if (sendProgress != null && (processedCount == 1 || processedCount % 10 == 0 || |
| | 0 | 1178 | | lastProgress.ElapsedMilliseconds >= 1000)) |
| | | 1179 | | { |
| | 0 | 1180 | | lastProgress.Restart(); |
| | 0 | 1181 | | _ = SafeSendProgress(sendProgress, processedCount, total, |
| | 0 | 1182 | | $"Обработка {order.ShipmentNumber}..."); |
| | | 1183 | | } |
| | | 1184 | | |
| | | 1185 | | // Heartbeat в лог (если долго нет сообщений об изменениях) |
| | 0 | 1186 | | if (heartbeat.ElapsedMilliseconds >= 5000) |
| | | 1187 | | { |
| | 0 | 1188 | | heartbeat.Restart(); |
| | 0 | 1189 | | await SafeSendLog(sendLog, $"… обработано {processedCount}/{total}"); |
| | | 1190 | | } |
| | | 1191 | | |
| | | 1192 | | try |
| | | 1193 | | { |
| | 0 | 1194 | | order.OzonClient = await _ozonClientServices.GetOzonClientAsync(order.OzonClient?.Id ?? 0); |
| | | 1195 | | |
| | 0 | 1196 | | if (order.OzonClient == null) |
| | | 1197 | | { |
| | 0 | 1198 | | await SafeSendLog(sendLog, $"Пропуск {order.ShipmentNumber}: клиент не найден"); |
| | 0 | 1199 | | continue; |
| | | 1200 | | } |
| | | 1201 | | |
| | 0 | 1202 | | ClientStatus? newClientStatus = null; |
| | 0 | 1203 | | string? newStatusName = null; |
| | | 1204 | | |
| | 0 | 1205 | | if (order.OzonClient.ClientType == ClientType.OZON) |
| | | 1206 | | { |
| | 0 | 1207 | | if (string.IsNullOrEmpty(order.OzonClient.DecryptClientId) || |
| | 0 | 1208 | | string.IsNullOrEmpty(order.OzonClient.DecryptApiKey) || |
| | 0 | 1209 | | string.IsNullOrEmpty(order.ShipmentNumber)) |
| | 0 | 1210 | | continue; |
| | | 1211 | | |
| | 0 | 1212 | | _jsonDataBuilder.SetClient(order.OzonClient.DecryptClientId, |
| | 0 | 1213 | | order.OzonClient.DecryptApiKey); |
| | | 1214 | | |
| | 0 | 1215 | | string newStatus = await _jsonDataBuilder.GetProductSatatus(order.ShipmentNumber); |
| | 0 | 1216 | | if (string.IsNullOrEmpty(newStatus)) |
| | 0 | 1217 | | continue; |
| | | 1218 | | |
| | 0 | 1219 | | newStatusName = OzonStatus.OrderStatuses.TryGetValue(newStatus, out var name) |
| | 0 | 1220 | | ? name |
| | 0 | 1221 | | : newStatus; |
| | | 1222 | | } |
| | 0 | 1223 | | if (string.IsNullOrEmpty(newStatusName)) |
| | 0 | 1224 | | continue; |
| | | 1225 | | |
| | | 1226 | | // Проверяем, изменился ли статус |
| | 0 | 1227 | | if (order.ClientStatus?.Name?.Equals(newStatusName, StringComparison.OrdinalIgnoreCase) == true) |
| | 0 | 1228 | | continue; |
| | | 1229 | | |
| | | 1230 | | // Получаем или создаем статус |
| | 0 | 1231 | | newClientStatus = await _clientStatusServices.GetClientStatusByNameAsync(newStatusName); |
| | 0 | 1232 | | if (newClientStatus == null) |
| | | 1233 | | { |
| | 0 | 1234 | | newClientStatus = new ClientStatus { Name = newStatusName }; |
| | 0 | 1235 | | await _clientStatusServices.AddClientStatus(newClientStatus); |
| | | 1236 | | // Сохраняем новый статус сразу, чтобы получить ID |
| | 0 | 1237 | | await _orderDataServices.SaveChangesAsync(); |
| | | 1238 | | } |
| | | 1239 | | |
| | 0 | 1240 | | batchUpdates.Add((order, newClientStatus)); |
| | | 1241 | | |
| | 0 | 1242 | | var logLine = $"• {order.ShipmentNumber}: {order.ClientStatus?.Name ?? ""} → {newStatusName}"; |
| | 0 | 1243 | | batchLogs.AppendLine( |
| | 0 | 1244 | | $"<b>{order.ShipmentNumber}</b>: {order.ClientStatus?.Name ?? ""} → {newStatusName}"); |
| | 0 | 1245 | | await SafeSendLog(sendLog, logLine); |
| | 0 | 1246 | | } |
| | 0 | 1247 | | catch (Exception ex) |
| | | 1248 | | { |
| | 0 | 1249 | | await SafeSendLog(sendLog, $"Ошибка при обработке {order.ShipmentNumber}: {ex.Message}"); |
| | | 1250 | | // Продолжаем обработку следующих заказов |
| | | 1251 | | } |
| | 0 | 1252 | | } |
| | | 1253 | | |
| | | 1254 | | // Шаг 2: Применяем изменения в батче |
| | 0 | 1255 | | if (batchUpdates.Any()) |
| | | 1256 | | { |
| | | 1257 | | // MySqlRetryingExecutionStrategy не поддерживает "ручные" транзакции, |
| | | 1258 | | // если они не выполняются внутри execution strategy. |
| | 0 | 1259 | | var strategy = _context.Database.CreateExecutionStrategy(); |
| | 0 | 1260 | | await strategy.ExecuteAsync(async () => |
| | 0 | 1261 | | { |
| | 0 | 1262 | | await using var transaction = await _context.Database.BeginTransactionAsync(); |
| | 0 | 1263 | | try |
| | 0 | 1264 | | { |
| | 0 | 1265 | | // Обновляем статусы |
| | 0 | 1266 | | foreach (var (order, newStatus) in batchUpdates) |
| | 0 | 1267 | | { |
| | 0 | 1268 | | order.ClientStatus = newStatus; |
| | 0 | 1269 | | order.ClientStatusId = newStatus.Id; |
| | 0 | 1270 | | // Навигация ClientStatus — это reference, не scalar property. |
| | 0 | 1271 | | // Для сохранения достаточно обновить FK. |
| | 0 | 1272 | | _context.Entry(order).Property(o => o.ClientStatusId).IsModified = true; |
| | 0 | 1273 | | } |
| | 0 | 1274 | | |
| | 0 | 1275 | | // Сохраняем батч |
| | 0 | 1276 | | var saved = await _context.SaveChangesAsync(); |
| | 0 | 1277 | | totalUpdated += saved; |
| | 0 | 1278 | | |
| | 0 | 1279 | | await transaction.CommitAsync(); |
| | 0 | 1280 | | |
| | 0 | 1281 | | updateInfoBuilder.Append(batchLogs.ToString()); |
| | 0 | 1282 | | await SafeSendLog(sendLog, |
| | 0 | 1283 | | $"✅ Батч {batchNumber}: изменений {batchUpdates.Count}, сохранено {saved}"); |
| | 0 | 1284 | | } |
| | 0 | 1285 | | catch (Exception ex) |
| | 0 | 1286 | | { |
| | 0 | 1287 | | try |
| | 0 | 1288 | | { |
| | 0 | 1289 | | if (_context.Database.GetDbConnection().State == System.Data.ConnectionState.Open) |
| | 0 | 1290 | | { |
| | 0 | 1291 | | await transaction.RollbackAsync(); |
| | 0 | 1292 | | } |
| | 0 | 1293 | | } |
| | 0 | 1294 | | catch |
| | 0 | 1295 | | { |
| | 0 | 1296 | | // Игнорируем ошибку отката при разорванном соединении |
| | 0 | 1297 | | } |
| | 0 | 1298 | | |
| | 0 | 1299 | | await SafeSendLog(sendLog, $"❌ Ошибка при сохранении батча {batchNumber}: {ex.Message}"); |
| | 0 | 1300 | | throw; // Пробрасываем исключение для повторной попытки |
| | 0 | 1301 | | } |
| | 0 | 1302 | | }); |
| | | 1303 | | } |
| | | 1304 | | else |
| | | 1305 | | { |
| | 0 | 1306 | | await SafeSendLog(sendLog, $"✅ Батч {batchNumber}: изменений нет"); |
| | | 1307 | | } |
| | | 1308 | | |
| | | 1309 | | // Небольшая задержка между батчами для снижения нагрузки |
| | 0 | 1310 | | if (batchStart + batchSize < total) |
| | | 1311 | | { |
| | 0 | 1312 | | await Task.Delay(100); |
| | | 1313 | | } |
| | 0 | 1314 | | } |
| | | 1315 | | |
| | | 1316 | | // Обновляем кэш после всех батчей |
| | 0 | 1317 | | await _cache.Update(); |
| | 0 | 1318 | | await _postingCancellationService.LinkOrdersAsync(ordersToUpdate); |
| | | 1319 | | |
| | | 1320 | | // Формируем отчет |
| | 0 | 1321 | | var report = new StringBuilder(); |
| | 0 | 1322 | | report.Append("<h4>=== Отчет об обновлении статусов заказов ===</h4>"); |
| | 0 | 1323 | | report.Append(totalUpdated > 0 |
| | 0 | 1324 | | ? $"<p>Обновлено <b>{totalUpdated}</b> статусов ({contextInfo}).</p><p>{updateInfoBuilder}</p>" |
| | 0 | 1325 | | : "<p>Нет изменений в статусах заказов.</p>"); |
| | 0 | 1326 | | report.Append($"<p>Время обработки: {DateTime.Now:yyyy-MM-dd HH:mm:ss}</p>"); |
| | | 1327 | | |
| | 0 | 1328 | | await NotificationService.NotifyAllAsync(totalUpdated > 0 |
| | 0 | 1329 | | ? $"Обновлено {totalUpdated} статусов заказов ({contextInfo})" |
| | 0 | 1330 | | : "Нет изменений в статусах заказов"); |
| | | 1331 | | |
| | 0 | 1332 | | return report.ToString(); |
| | 0 | 1333 | | } |
| | | 1334 | | } |
| | | 1335 | | } |