增强原材料卡片管理功能,新增免密接口和数据处理逻辑,支持原材料卡片的增删改查操作。更新前端视图以支持多行拆码明细拼接,优化用户体验和系统实时数据同步能力。

This commit is contained in:
geht
2026-05-11 14:32:44 +08:00
parent 936375bb2c
commit cffe32d896
49 changed files with 4594 additions and 390 deletions

View File

@@ -0,0 +1,85 @@
using Prism.Events;
using System.Text.Json;
using YY.Admin.Core;
using YY.Admin.Core.Events;
using YY.Admin.Core.Services;
namespace YY.Admin.Services.Service.RawMaterialCard;
/// <summary>
/// 监听 STOMP 收到的原材料卡片变更信号,转发为 Prism 事件,触发列表刷新。
/// </summary>
public class RawMaterialCardSyncCoordinator : ISingletonDependency
{
private readonly IEventAggregator _eventAggregator;
private readonly ILoggerService _logger;
private SubscriptionToken? _remoteCommandToken;
private SubscriptionToken? _networkStatusToken;
public RawMaterialCardSyncCoordinator(
IEventAggregator eventAggregator,
SyncPollManager pollManager,
ILoggerService logger)
{
_eventAggregator = eventAggregator;
_logger = logger;
_remoteCommandToken = _eventAggregator
.GetEvent<RemoteCommandReceivedEvent>()
.Subscribe(OnRemoteCommand, ThreadOption.BackgroundThread);
_networkStatusToken = _eventAggregator
.GetEvent<NetworkStatusChangedEvent>()
.Subscribe(OnNetworkStatusChanged, ThreadOption.BackgroundThread);
pollManager.Register("原材料卡片", () =>
{
_eventAggregator.GetEvent<RawMaterialCardChangedEvent>()
.Publish(new RawMaterialCardChangedPayload { Action = "poll" });
return Task.CompletedTask;
});
_logger.Information("[原材料卡片推送] RawMaterialCardSyncCoordinator 已启动");
}
private void OnNetworkStatusChanged(NetworkStatusChangedPayload payload)
{
if (!payload.IsOnline) return;
_logger.Information("[原材料卡片推送] 网络恢复,触发补偿刷新");
_eventAggregator.GetEvent<RawMaterialCardChangedEvent>()
.Publish(new RawMaterialCardChangedPayload { Action = "reconnect" });
}
private void OnRemoteCommand(RemoteCommandPayload payload)
{
try
{
var json = payload.CommandJson ?? string.Empty;
if (string.IsNullOrWhiteSpace(json)) return;
using var doc = JsonDocument.Parse(json);
if (!doc.RootElement.TryGetProperty("cmd", out var cmdEl)) return;
var cmd = cmdEl.GetString() ?? string.Empty;
if (!cmd.Equals("RAW_MATERIAL_CARD_CHANGED", StringComparison.OrdinalIgnoreCase))
{
_logger.Information($"[原材料卡片推送] 非原材料卡片命令 cmd={cmd},忽略");
return;
}
doc.RootElement.TryGetProperty("action", out var actionEl);
doc.RootElement.TryGetProperty("cardId", out var idEl);
var changedPayload = new RawMaterialCardChangedPayload
{
Action = actionEl.GetString() ?? string.Empty,
CardId = idEl.ValueKind == JsonValueKind.String ? idEl.GetString() : null
};
_logger.Information($"[原材料卡片推送] 收到变更信号: action={changedPayload.Action}, cardId={changedPayload.CardId}");
_eventAggregator.GetEvent<RawMaterialCardChangedEvent>().Publish(changedPayload);
}
catch (Exception ex)
{
_logger.Warning($"[原材料卡片推送] 处理 STOMP 信号失败: {ex.Message}");
}
}
}