Teams/sy_hx_pbl_backend
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

报警信息推送，料架表更新

Browse Source
This commit is contained in:
赵正易
2025-01-24 11:44:27 +08:00
parent 6a9823bc64
commit 3d1b605828
4 changed files with 160 additions and 71 deletions
Download Patch File Download Diff File Expand all files Collapse all files

150
DOAN.ServiceCore/DoanBackgroundService.cs
View File

@@ -1,35 +1,50 @@
using System;
using System.Security.Cryptography.X509Certificates;
using System.Collections.Generic;
using System.Linq;
using System.Text.Json;
using System.Threading;
using System.Threading.Tasks;
using DOAN.Infrastructure.PLC;
using DOAN.Model.PBL;
using DOAN.Model.System;
using DOAN.ServiceCore.Signalr;
using Microsoft.AspNetCore.SignalR;
using Microsoft.Extensions.Hosting;
using SqlSugar;
using SqlSugar.IOC;
namespace DOAN.ServiceCore
{
/// <summary>
/// 永驻线程
/// 功能：检测传感器信号，判断箱子数
/// </summary>
public class DoanBackgroundService : IHostedService, IDisposable
{
private readonly IHubContext<PBLhub> notificationHubContext;
private readonly CancellationTokenSource _cancellationTokenSource = new CancellationTokenSource();
private Task _executingTask;
private PLCTool pLCTool;
private List<Storagelocation> storagelocationList = new List<Storagelocation>();
private List<PlcAddressTable> pointPositionList = new List<PlcAddressTable>();
private Timer refreshTimer;
public DoanBackgroundService(IHubContext<PBLhub> hubContext)
{
notificationHubContext = hubContext;
}
public Task StartAsync(CancellationToken cancellationToken)
{
pLCTool = new PLCTool();
pLCTool.ConnectPLC();
// 当服务开始时，启动后台任务
// 初始化料架层和点位表数据
RefreshData(null);
// 启动后台任务
_executingTask = ExecuteAsync(_cancellationTokenSource.Token);
// 设置定时器每分钟刷新一次料架层和点位表
refreshTimer = new Timer(RefreshData, null, TimeSpan.Zero, TimeSpan.FromMinutes(1));
return _executingTask.IsCompleted ? _executingTask : Task.CompletedTask;
}
@@ -39,25 +54,24 @@ namespace DOAN.ServiceCore
// 请求取消后台任务
_cancellationTokenSource.Cancel();
// 停止定时器
refreshTimer?.Change(Timeout.Infinite, Timeout.Infinite);
refreshTimer?.Dispose();
// 等待后台任务完成
await Task.WhenAny(_executingTask, Task.Delay(Timeout.Infinite, cancellationToken));
}
private static bool GetInvertedBit(byte b, int position)
private static bool GetInvertedBit(byte b, int position)
{
if (position < 0 || position > 7)
{
throw new ArgumentOutOfRangeException(nameof(position), "Position must be between 0 and 7.");
}
// 创建一个掩码，其中只有要检查的那一位是1
byte mask = (byte)(1 << position);
// 使用按位与运算符(&)来检查该位是否为1
bool isSet = (b & mask) != 0;
// 返回取反后的值
return !isSet;
return !isSet; // 返回取反后的值
}
/// <summary>
@@ -71,64 +85,87 @@ namespace DOAN.ServiceCore
{
while (!stoppingToken.IsCancellationRequested)
{
// 读取PLC I/O状态 12个数组
byte[] plcSensorValues = pLCTool.ReadAllValue("VB100", 12);
// 读取PLC I/O状态（12个字节）
byte[] plcSensorValues;
try
{
plcSensorValues = pLCTool.ReadAllValue("VB100", 12);
}
catch (Exception ex)
{
Console.WriteLine($"读取PLC数据异常: {ex.Message}\n堆栈跟踪: {ex.StackTrace}");
continue;
}
// 获取所有料架层
List<Storagelocation> storagelocationList = await DbScoped.SugarScope.CopyNew().Queryable<Storagelocation>().ToListAsync();
var updateStoragelocationList = new List<Storagelocation>();
var inventoryLogs = new List<Inventorylog>();
// 获取点位表
List<PlcAddressTable> pointPositionList = await DbScoped.SugarScope.CopyNew().Queryable<PlcAddressTable>().ToListAsync();
List<Storagelocation> updateStoragelocationList = [];
List<Inventorylog> inventoryLogs = [];
foreach (Storagelocation layerItem in storagelocationList)
foreach (var layerItem in storagelocationList)
{
// 获取这个料架层的点位表
List<PlcAddressTable> layerPoints = pointPositionList.Where(it => it.FkStorageId == layerItem.Id).ToList();
var layerPoints = pointPositionList.Where(it => it.FkStorageId == layerItem.Id).ToList();
if (layerPoints != null && layerPoints.Count > 0)
if (layerPoints.Any())
{
int currentPackageCount = 0; // 默认最小值为0
foreach (PlcAddressTable point in layerPoints)
foreach (var point in layerPoints)
{
int row = point.ByteNum - 100;
int col = point.BitNum - 1;
if (plcSensorValues != null)
if (plcSensorValues != null && row >= 0 && row < plcSensorValues.Length)
{
currentPackageCount += GetInvertedBit(plcSensorValues[row], col) ? 1 : 0;
}
}
// 检查箱子数量变化并记录日志
if (currentPackageCount > layerItem.PackageNum)
int previousPackageCount = layerItem.PackageNum.GetValueOrDefault();
if (currentPackageCount > previousPackageCount)
{
UpdateAndLog(layerItem, currentPackageCount, 2, "补料", inventoryLogs);
UpdateAndLog(layerItem, currentPackageCount, 2, "出库", inventoryLogs);
updateStoragelocationList.Add(layerItem);
}
else if (currentPackageCount < layerItem.PackageNum)
else if (currentPackageCount < previousPackageCount)
{
UpdateAndLog(layerItem, currentPackageCount, 1, "出料", inventoryLogs);
UpdateAndLog(layerItem, currentPackageCount, 1, "入库", inventoryLogs);
updateStoragelocationList.Add(layerItem);
}
// 补料报警触发
if (layerItem.IsLackAlarm == 1 && currentPackageCount <= layerItem.AlarmNum.GetValueOrDefault())
{
var alarmData = new
{
RackCode = layerItem.RackCode,
LayerNum = layerItem.LayerNum,
CurrentPackageCount = currentPackageCount,
AlarmThreshold = layerItem.AlarmNum
};
string alarmMessage = System.Text.Json.JsonSerializer.Serialize(alarmData);
await notificationHubContext.Clients.All.SendAsync("PBL_lack_alarm", alarmMessage);
}
}
}
// 更新库存
if (updateStoragelocationList.Count > 0)
if (updateStoragelocationList.Any())
{
await DbScoped.SugarScope.CopyNew().Updateable(updateStoragelocationList).ExecuteCommandAsync();
}
// 插入库存变更日志
if (inventoryLogs.Count > 0)
if (inventoryLogs.Any())
{
await DbScoped.SugarScope.CopyNew().Insertable(inventoryLogs).ExecuteCommandAsync();
}
// 发送Socket通知
string changeMessage = "库存变动";
await notificationHubContext.Clients.All.SendAsync("PBL_storagelocation_change", changeMessage);
// 添加延迟以避免频繁查询
await Task.Delay(200, stoppingToken);
}
@@ -143,6 +180,27 @@ namespace DOAN.ServiceCore
}
}
/// <summary>
/// 刷新料架层和点位表数据
/// </summary>
/// <param name="state"></param>
private void RefreshData(object state)
{
try
{
using (var scope = DbScoped.SugarScope.CopyNew())
{
storagelocationList = scope.Queryable<Storagelocation>().ToListAsync().Result;
pointPositionList = scope.Queryable<PlcAddressTable>().ToListAsync().Result;
}
}
catch (Exception ex)
{
Console.WriteLine($"刷新数据异常: {ex.Message}\n堆栈跟踪: {ex.StackTrace}");
// 如果刷新失败，保持现有数据不变
}
}
/// <summary>
/// 更新料架位置的箱子数量并记录库存日志
/// </summary>
@@ -151,19 +209,24 @@ namespace DOAN.ServiceCore
/// <param name="operation">操作类型 (1-出库, 2-入库)</param>
/// <param name="operatorName">操作员名称</param>
/// <param name="inventoryLogs">库存日志列表</param>
private void UpdateAndLog(Storagelocation storageLocation, int newPackageCount, int operation, string operatorName, List<Inventorylog> inventoryLogs)
private void UpdateAndLog(
Storagelocation storageLocation,
int newPackageCount,
int operation,
string operatorName,
List<Inventorylog> inventoryLogs)
{
storageLocation.PackageNum = newPackageCount;
storageLocation.UpdatedBy = operatorName;
storageLocation.UpdatedTime = DateTime.Now;
Inventorylog inventoryLog = new Inventorylog
var inventoryLog = new Inventorylog
{
Id = SnowFlakeSingle.Instance.NextId().ToString(),
RackCode = storageLocation.RackCode,
Partnumber = storageLocation.Partnumber,
Operation = operation,
PackageNum = Math.Abs((int)(newPackageCount - storageLocation.PackageNum)),
PackageNum = Math.Abs(newPackageCount - storageLocation.PackageNum.GetValueOrDefault()),
CreatedBy = operatorName,
CreatedTime = DateTime.Now.ToLocalTime()
};
@@ -177,17 +240,18 @@ namespace DOAN.ServiceCore
{
pLCTool.ConnectClose();
_cancellationTokenSource.Cancel();
_executingTask.Wait();
_executingTask?.Wait();
_cancellationTokenSource.Dispose();
refreshTimer?.Change(Timeout.Infinite, Timeout.Infinite);
refreshTimer?.Dispose();
}
catch (Exception ex)
{
Console.WriteLine("DoanBackGround线程Dispose异常:" + ex.Message);
}
}
}
}