From 770531b9645ed712be426346148387f165d39773 Mon Sep 17 00:00:00 2001
From: 肖洋 <cathay_xy@163.com>
Date: 星期一, 23 十二月 2024 17:25:45 +0800
Subject: [PATCH] 添加日志功能，更新SignalR接口，优化前端日志展示逻辑
---
Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/AspNetCoreSchedule.cs | 24 +++++++++---------------
1 files changed, 9 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..b9093ab 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>
/// 鍒涘缓浠诲姟瀹炰緥
@@ -163,4 +157,4 @@
};
}
}
-}
+}
\ No newline at end of file
--
Gitblit v1.9.3