From 31eba6a8c6261adf5bfef4dafad4dc8efc1f66a2 Mon Sep 17 00:00:00 2001 From: huangxiaoqiang <huangxiaoqiang@hnkhzn.com> Date: 星期二, 18 二月 2025 18:57:54 +0800 Subject: [PATCH] 1 --- Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/AspNetCoreSchedule.cs | 27 ++++++++++++--------------- 1 files changed, 12 insertions(+), 15 deletions(-) diff --git a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/AspNetCoreSchedule.cs b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/AspNetCoreSchedule.cs index 0942e0a..2146ea2 100644 --- a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/AspNetCoreSchedule.cs +++ b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/AspNetCoreSchedule.cs @@ -1,17 +1,10 @@ 锘縰sing Masuit.Tools; using Microsoft.Extensions.Hosting; using Microsoft.Extensions.Logging; -using System; -using System.Collections.Generic; -using System.Linq; -using System.Text; -using System.Threading.Tasks; using WIDESEA_Core.Const; using WIDESEA_DTO.WMS; using WIDESEA_IServices; -using WIDESEA_Repository; using WIDESEAWCS_BasicInfoRepository; -using WIDESEA_Model; namespace WIDESEA_StorageTaskServices { @@ -26,6 +19,7 @@ private readonly ILocationInfoRepository _locationRepository; private Timer _timer; + public MyBackgroundService(ILogger<MyBackgroundService> logger, ILocationInfoRepository locationRepository, IStockInfoRepository stockInfoRepository, IDt_AreaInfoRepository areaInfoRepository, IDt_TaskRepository taskRepository, IDt_StationManagerRepository stationManagerRepository, ISys_ConfigService configService) { _logger = logger; @@ -36,18 +30,20 @@ _stationManagerRepository = stationManagerRepository; _configService = configService; } + public Task StartAsync(CancellationToken cancellationToken) { _timer = new Timer(DoWork, null, 0, 10000); return Task.CompletedTask; } + private void DoWork(object state) { try { - var area = _areaInfoRepository.QueryFirst(x => x.AreaCode == "GWSC1"); + if (area == null) { return; } var stockInfo = _stockInfoRepository.Db.Queryable<DtStockInfo>() .Includes(x => x.LocationInfo) // 棰勫姞杞絃ocationInfo .Includes(x => x.StockInfoDetails) // 棰勫姞杞絊tockInfoDetails @@ -59,7 +55,6 @@ if (stockInfo.Count <= 0) return; foreach (var item in stockInfo) { - var hasTask = _taskRepository.QueryFirst(x => x.PalletCode == item.PalletCode); if (hasTask != null) { @@ -77,7 +72,6 @@ task.NextAddress = "002-000-002"; // 鍒涘缓浠诲姟DTO WMSTaskDTO taskDTO = CreateTaskDTO(task); - var configs = _configService.GetConfigsByCategory(CateGoryConst.CONFIG_SYS_IPAddress); var wmsBase = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.WCSIPAddress)?.ConfigValue; @@ -98,25 +92,25 @@ _locationRepository.UpdateData(item.LocationInfo); } } - } catch (Exception ex) { - ConsoleHelper.WriteErrorLine(ex.Message); + ConsoleHelper.WriteErrorLine($"楂樻俯鍑哄簱閿欒锛岄敊璇俊鎭細" + ex.Message); } - ConsoleHelper.WriteSuccessLine(DateTime.Now.ToString()); + ConsoleHelper.WriteSuccessLine($"楂樻俯鍑哄簱璋冪敤锛�" + DateTime.Now.ToString()); } + public Task StopAsync(CancellationToken cancellationToken) { _logger.LogInformation("MyBackgroundService is stopping."); _timer?.Change(Timeout.Infinite, 0); return Task.CompletedTask; } + public void Dispose() { _timer?.Dispose(); } - /// <summary> /// 鍒涘缓浠诲姟瀹炰緥 @@ -141,6 +135,8 @@ Creater = "System", // 淇鎷煎啓閿欒 CreateDate = DateTime.Now, TaskId = 0, + ProductionLine= stockInfo.ProductionLine, + ProcessCode = stockInfo.ProcessCode, }; } @@ -160,7 +156,8 @@ TaskState = task.TaskState.Value, Id = 0, TaskType = task.TaskType, + ProductionLine = task.ProductionLine, }; } } -} +} \ No newline at end of file -- Gitblit v1.9.3