SuZhouGuanHong/ShanMeiXinNengYuan.git

			@@ -24,16 +24,19 @@
			private readonly IMesLogService _mesLogService;
			private readonly IMesService _mesService;
			private readonly ISys_DictionaryService _sysDictionaryService;
			private readonly IStockInfoService _stockInfoService;

			public StockInfoController(
			IStockInfoService service,
			IMesLogService mesLogService,
			IMesService mesService,
			ISys_DictionaryService sysDictionaryService) : base(service)
			ISys_DictionaryService sysDictionaryService,
			IStockInfoService stockInfoService) : base(service)
			{
			_mesLogService = mesLogService;
			_mesService = mesService;
			_sysDictionaryService = sysDictionaryService;
			_stockInfoService = stockInfoService;
			}

			/// <summary>
			@@ -57,7 +60,6 @@
			public async Task<WebResponseContent> InboundInContainer([FromBody] InboundInContainerRequestDto dto)
			{
			var response = new WebResponseContent();
			var stopwatch = Stopwatch.StartNew();

			try
			{
			@@ -91,47 +93,57 @@
			};

			string requestJson = System.Text.Json.JsonSerializer.Serialize(mesRequest);
			string palletCode = stockInfo.PalletCode;

			// 5. 调用MES接口（同步方法）
			var mesResult = _mesService.InboundInContainer(mesRequest);
			stopwatch.Stop();

			// 6. 记录日志
			await _mesLogService.LogAsync(new MesApiLogDto
			// 5. 异步执行MES调用（fire-and-forget）
			_ = Task.Run(async () =>
			{
			ApiType = "InboundInContainer",
			RequestJson = requestJson,
			ResponseJson = System.Text.Json.JsonSerializer.Serialize(mesResult),
			IsSuccess = mesResult.IsSuccess,
			ErrorMessage = mesResult.ErrorMessage,
			ElapsedMs = (int)stopwatch.ElapsedMilliseconds,
			Creator = App.User.UserName
			var localStopwatch = Stopwatch.StartNew();
			try
			{
			var result = _mesService.InboundInContainer(mesRequest);
			localStopwatch.Stop();

			bool isSuccess = result?.IsSuccess ?? false;
			int status = isSuccess
			? (int)MesUploadStatusEnum.进站上传成功
			: (int)MesUploadStatusEnum.进站上传失败;

			await _stockInfoService.UpdateMesUploadStatusAsync(palletCode, status);

			await _mesLogService.LogAsync(new MesApiLogDto
			{
			PalletCode = palletCode,
			ApiType = "InboundInContainer",
			RequestJson = requestJson,
			ResponseJson = System.Text.Json.JsonSerializer.Serialize(result),
			IsSuccess = isSuccess,
			ErrorMessage = result?.ErrorMessage ?? "未知错误",
			ElapsedMs = (int)localStopwatch.ElapsedMilliseconds,
			Creator = App.User.UserName
			});
			}
			catch (Exception ex)
			{
			localStopwatch.Stop();
			await _stockInfoService.UpdateMesUploadStatusAsync(palletCode, (int)MesUploadStatusEnum.进站上传失败);
			await _mesLogService.LogAsync(new MesApiLogDto
			{
			PalletCode = palletCode,
			ApiType = "InboundInContainer",
			IsSuccess = false,
			ErrorMessage = ex.Message,
			ElapsedMs = (int)localStopwatch.ElapsedMilliseconds,
			Creator = App.User.UserName
			});
			}
			});

			// 7. 返回结果
			if (mesResult.IsSuccess)
			{
			return response.OK("托盘进站成功");
			}
			else
			{
			return response.Error($"MES接口调用失败: {mesResult.ErrorMessage}");
			}
			// 6. 立即返回成功
			return response.OK("托盘进站成功");
			}
			catch (System.Exception ex)
			{
			stopwatch.Stop();

			// 记录错误日志
			await _mesLogService.LogAsync(new MesApiLogDto
			{
			ApiType = "InboundInContainer",
			IsSuccess = false,
			ErrorMessage = ex.Message,
			ElapsedMs = (int)stopwatch.ElapsedMilliseconds,
			Creator = App.User.UserName
			});

			return response.Error($"托盘进站失败: {ex.Message}");
			}
			}
			@@ -145,7 +157,6 @@
			public async Task<WebResponseContent> OutboundInContainer([FromBody] OutboundInContainerRequestDto dto)
			{
			var response = new WebResponseContent();
			var stopwatch = Stopwatch.StartNew();

			try
			{
			@@ -191,47 +202,57 @@
			};

			string requestJson = System.Text.Json.JsonSerializer.Serialize(mesRequest);
			string palletCode = stockInfo.PalletCode;

			// 5. 调用MES接口（同步方法）
			var mesResult = _mesService.OutboundInContainer(mesRequest);
			stopwatch.Stop();

			// 6. 记录日志
			await _mesLogService.LogAsync(new MesApiLogDto
			// 5. 异步执行MES调用（fire-and-forget）
			_ = Task.Run(async () =>
			{
			ApiType = "OutboundInContainer",
			RequestJson = requestJson,
			ResponseJson = System.Text.Json.JsonSerializer.Serialize(mesResult),
			IsSuccess = mesResult.IsSuccess,
			ErrorMessage = mesResult.ErrorMessage,
			ElapsedMs = (int)stopwatch.ElapsedMilliseconds,
			Creator = App.User.UserName
			var localStopwatch = Stopwatch.StartNew();
			try
			{
			var result = _mesService.OutboundInContainer(mesRequest);
			localStopwatch.Stop();

			bool isSuccess = result?.IsSuccess ?? false;
			int status = isSuccess
			? (int)MesUploadStatusEnum.出站上传成功
			: (int)MesUploadStatusEnum.出站上传失败;

			await _stockInfoService.UpdateMesUploadStatusAsync(palletCode, status);

			await _mesLogService.LogAsync(new MesApiLogDto
			{
			PalletCode = palletCode,
			ApiType = "OutboundInContainer",
			RequestJson = requestJson,
			ResponseJson = System.Text.Json.JsonSerializer.Serialize(result),
			IsSuccess = isSuccess,
			ErrorMessage = result?.ErrorMessage ?? "未知错误",
			ElapsedMs = (int)localStopwatch.ElapsedMilliseconds,
			Creator = App.User.UserName
			});
			}
			catch (Exception ex)
			{
			localStopwatch.Stop();
			await _stockInfoService.UpdateMesUploadStatusAsync(palletCode, (int)MesUploadStatusEnum.出站上传失败);
			await _mesLogService.LogAsync(new MesApiLogDto
			{
			PalletCode = palletCode,
			ApiType = "OutboundInContainer",
			IsSuccess = false,
			ErrorMessage = ex.Message,
			ElapsedMs = (int)localStopwatch.ElapsedMilliseconds,
			Creator = App.User.UserName
			});
			}
			});

			// 7. 返回结果
			if (mesResult.IsSuccess)
			{
			return response.OK("托盘出站成功");
			}
			else
			{
			return response.Error($"MES接口调用失败: {mesResult.ErrorMessage}");
			}
			// 6. 立即返回成功
			return response.OK("托盘出站成功");
			}
			catch (System.Exception ex)
			{
			stopwatch.Stop();

			// 记录错误日志
			await _mesLogService.LogAsync(new MesApiLogDto
			{
			ApiType = "OutboundInContainer",
			IsSuccess = false,
			ErrorMessage = ex.Message,
			ElapsedMs = (int)stopwatch.ElapsedMilliseconds,
			Creator = App.User.UserName
			});

			return response.Error($"托盘出站失败: {ex.Message}");
			}
			}