MES 上传状态跟踪与异步上传设计

Date: 2026-04-20
Author: Claude

1. 目标

在库存表添加 MES 上传状态字段，通过异步方式上传 MES 数据，不干扰主业务逻辑，所有 MES 调用均记录详细日志。

2. 数据库变更

2.1 Dt_StockInfo 表新增字段

ALTER TABLE [dbo].[Dt_StockInfo] ADD [MesUploadStatus] TINYINT NOT NULL DEFAULT 0;
GO

2.2 枚举定义

在 WIDESEA_Common 项目新增枚举类 MesUploadStatusEnum。

3. 后端设计

3.1 核心异步方法

在 WIDESEA_TaskInfoService/TaskService.cs 中新增 MesUploadAsync 私有异步方法：

/// <summary>
/// 异步执行MES上传 - 不阻塞主业务逻辑
/// </summary>
/// <param name="palletCode">托盘号</param>
/// <param name="mesType">MES操作类型枚举</param>
/// <param name="uploadFunc">具体的MES调用函数</param>
private async Task MesUploadAsync(string palletCode, MesUploadStatusEnum mesType, Func<Task<HttpResponseResult<MesResponse>>> uploadFunc)
{
    var stopwatch = Stopwatch.StartNew();
    string requestJson = "";
    string responseJson = "";
    bool isSuccess = false;
    string errorMessage = "";

    try
    {
        // 记录请求日志
        var mesLog = new MesApiLogDto
        {
            PalletCode = palletCode,
            ApiType = mesType.ToString(),
            RequestTime = DateTime.Now
        };

        // 调用MES
        var result = await uploadFunc();

        stopwatch.Stop();
        isSuccess = result?.Data?.IsSuccess ?? false;
        errorMessage = result?.Data?.Msg ?? result?.ErrorMessage ?? "未知错误";
        responseJson = JsonConvert.SerializeObject(result);

        // 更新库存表状态
        var uploadStatus = isSuccess ? (int)mesType : (int)mesType + 1; // 奇数=成功，偶数=失败
        await _stockInfoService.UpdateMesUploadStatusAsync(palletCode, uploadStatus);

        // 记录日志
        mesLog.ResponseTime = DateTime.Now;
        mesLog.Duration = stopwatch.ElapsedMilliseconds;
        mesLog.RequestParams = requestJson;
        mesLog.ResponseResult = responseJson;
        mesLog.Status = isSuccess ? "成功" : "失败";
        mesLog.ErrorMessage = errorMessage;
        mesLog.CreateTime = DateTime.Now;

        _ = _mesLogService.LogAsync(mesLog); // 不等待
    }
    catch (Exception ex)
    {
        stopwatch.Stop();
        errorMessage = ex.Message;

        // 更新状态为失败
        var uploadStatus = (int)mesType + 1;
        _stockInfoService.UpdateMesUploadStatusAsync(palletCode, uploadStatus).ConfigureAwait(false);

        // 记录异常日志
        var mesLog = new MesApiLogDto
        {
            PalletCode = palletCode,
            ApiType = mesType.ToString(),
            RequestTime = DateTime.Now,
            ResponseTime = DateTime.Now,
            Duration = stopwatch.ElapsedMilliseconds,
            RequestParams = requestJson,
            ResponseResult = responseJson,
            Status = "失败",
            ErrorMessage = errorMessage,
            CreateTime = DateTime.Now
        };
        _ = _mesLogService.LogAsync(mesLog); // 不等待
    }
}

3.2 调用方式

在各个 MES 操作处统一使用 Task.Run + MesUploadAsync：

// 组盘确认
public async Task<WebResponseContent> GroupPalletConfirmAsync(string palletCode, string deviceName)
{
    // ... 业务逻辑 ...
    
    // 异步MES上传，不阻塞主逻辑
    _ = Task.Run(() => MesUploadAsync(palletCode, MesUploadStatusEnum.GroupPalletSuccess, async () =>
    {
        return await _mesService.BindContainerAsync(bindRequest, token);
    }));

    return content.OK("组盘成功");
}

// 拆盘确认
public async Task<WebResponseContent> SplitPalletConfirmAsync(string palletCode, string deviceName)
{
    // ... 业务逻辑 ...

    _ = Task.Run(() => MesUploadAsync(palletCode, MesUploadStatusEnum.SplitPalletSuccess, async () =>
    {
        return await _mesService.UnBindContainerAsync(unbindRequest, token);
    }));

    return content.OK("拆盘成功");
}

3.3 IStockInfoService 新增方法

在 IStockInfoService 接口新增：

/// <summary>
/// 更新MES上传状态
/// </summary>
/// <param name="palletCode">托盘号</param>
/// <param name="status">状态值</param>
Task<bool> UpdateMesUploadStatusAsync(string palletCode, int status);

在 StockInfoService 中实现该方法。

3.4 日志记录规范

所有 MES 调用统一记录以下字段：

4. 前端变更

4.1 库存页面操作列新增按钮

在 WMS/WIDESEA_WMSClient/src/extension/stock/stock.jsx 中扩展操作列：

let extension = {
  components: {
    gridHeader: "",
    gridBody: "",
    gridFooter: "",
    modelHeader: "",
    modelBody: "",
    modelFooter: "",
  },
  tableAction: "stock",
  buttons: {
    view: ["Export"],
    box: []
  },
  methods: {
    onInit() {
      return true;
    },
    onInited() {
      // 注入组盘/拆盘按钮
      this.editTableButtons = [
        { name: "组盘", onClick: this.onGroupPallet },
        { name: "拆盘", onClick: this.onSplitPallet }
      ];
      return true;
    },
    async onGroupPallet({ row }) {
      // 调用组盘接口
      let result = await this.$api.post("/Stock/GroupPalletConfirm", { palletCode: row.palletCode });
      if (result.status) {
        this.$Message.success("组盘成功");
        this.$refs.grid.search();
      } else {
        this.$Message.error(result.message || "组盘失败");
      }
    },
    async onSplitPallet({ row }) {
      // 调用拆盘接口
      let result = await this.$api.post("/Stock/SplitPalletConfirm", { palletCode: row.palletCode });
      if (result.status) {
        this.$Message.success("拆盘成功");
        this.$refs.grid.search();
      } else {
        this.$Message.error(result.message || "拆盘失败");
      }
    }
  },
};

export default extension;

4.2 库存列表新增状态列

在 WMS/WIDESEA_WMSClient/src/views/stock/stock.vue 的 columns 中新增：

{ field: "mesUploadStatus", title: "MES状态", type: "int", width: 120, bind: { key: "mesUploadStatusEnum", data: [] } }

4.3 字典配置

在 mesUploadStatusEnum 字典中添加：

5. 文件变更清单

6. 自检清单

• [ ] MesUploadStatusEnum 枚举值奇数为成功，偶数为失败，+1运算正确
• [ ] MesUploadAsync 方法内所有 MES 调用记录详细日志（请求JSON、响应JSON、耗时、错误原因）
• [ ] 组盘/拆盘/进站/出站/NG上报均通过 Task.Run 异步执行，不阻塞主逻辑
• [ ] 前端组盘/拆盘按钮调用 GroupPalletConfirmAsync / SplitPalletConfirmAsync
• [ ] 库存列表正确显示 mesUploadStatus 字段
• [ ] 所有 public 方法均有 XML 文档注释