ZhongRui/ALDbanyunxiangmu.git

			@@ -1,12 +1,16 @@
			ï»¿using Microsoft.Extensions.Logging;
			ï»¿using Dm.filter;
			using MailKit.Search;
			using Microsoft.Extensions.Logging;
			using Newtonsoft.Json;
			using Org.BouncyCastle.Asn1.Ocsp;
			using SqlSugar;
			using System;
			using System.Collections.Concurrent;
			using System.Collections.Generic;
			using System.Linq;
			using System.Net;
			using System.Net.Http;
			using System.Reflection.Metadata;
			using System.Security.Policy;
			using System.Text;
			using System.Threading.Tasks;
			@@ -22,6 +26,7 @@
			using WIDESEA_IBasicService;
			using WIDESEA_IOutboundService;
			using WIDESEA_Model.Models;
			using WIDESEA_Model.Models.Outbound;

			namespace WIDESEA_BasicService
			{
			@@ -36,11 +41,19 @@
			private readonly IRepository<Dt_StockInfoDetail> _stockInfoDetailRepository;
			private readonly IRepository<Dt_StockInfo> _stockInfoRepository;
			private readonly IRepository<Dt_InboundOrder> _inboundOrderRepository;

			private readonly IRepository<Dt_PickingRecord> _pickingRecoreRepository;
			private readonly IMaterialUnitService _materialUnitService;
			private readonly IOutboundOrderService _outboundOrderService;
			private readonly IOutboundOrderDetailService _outboundOrderDetailService;
			private readonly IOutStockLockInfoService _outStockLockInfoService;
			public InvokeMESService(IHttpClientFactory httpClientFactory, ILogger<InvokeMESService> logger, IRepository<Dt_FeedbackToMes> feedbacktomesRepository, IRepository<Dt_StockInfoDetail> stockInfoDetailRepository, IRepository<Dt_StockInfo> stockInfoRepository, IRepository<Dt_InboundOrder> inboundOrderRepository, IOutboundOrderService outboundOrderService, IOutboundOrderDetailService outboundOrderDetailService, IOutStockLockInfoService outStockLockInfoService)
			private readonly IRepository<Dt_InterfaceLog> _interfacelogRepository;

			// åå¨èµæºIDåå¶å¯¹åºçéå¯¹è±¡ãä½¿ç¨ ConcurrentDictionary ç¡®ä¿å¯¹åå¸æä½æ¬èº«ççº¿ç¨å®å¨ã
			private static readonly ConcurrentDictionary<string, object> _resourceLocks = new ConcurrentDictionary<string, object>();

			// å¨å±éæéï¼ç¨äºä¿æ¤ _resourceLocks åå¸ä¸ GetOrAdd æ TryRemove æ¶çç«äº
			private static readonly object _globalLocker = new object();
			public InvokeMESService(IHttpClientFactory httpClientFactory, ILogger<InvokeMESService> logger, IRepository<Dt_FeedbackToMes> feedbacktomesRepository, IRepository<Dt_StockInfoDetail> stockInfoDetailRepository, IRepository<Dt_StockInfo> stockInfoRepository, IRepository<Dt_InboundOrder> inboundOrderRepository, IOutboundOrderService outboundOrderService, IOutboundOrderDetailService outboundOrderDetailService, IOutStockLockInfoService outStockLockInfoService, IMaterialUnitService materialUnitService, IRepository<Dt_PickingRecord> pickingRecoreRepository, IRepository<Dt_InterfaceLog> interfacelogRepository)
			{
			_httpClientFactory = httpClientFactory;
			_logger = logger;
			@@ -51,6 +64,9 @@
			_outboundOrderService = outboundOrderService;
			_outboundOrderDetailService = outboundOrderDetailService;
			_outStockLockInfoService = outStockLockInfoService;
			_materialUnitService = materialUnitService;
			_pickingRecoreRepository = pickingRecoreRepository;
			_interfacelogRepository = interfacelogRepository;
			}

			/// <summary>
			@@ -99,7 +115,7 @@
			_client.DefaultRequestHeaders.Clear();
			_client.DefaultRequestHeaders.Add("Accept", "application/json");

			_logger.LogInformation("InvokeMESService FeedbackOutbound : " + json);
			_logger.LogInformation("InvokeMESService FeedbackOutbound : " + model.orderNo + " , " + json);

			var response = await _client.PostAsync("AldMaterialOutbound/MaterialOutbound", content);
			string body = await response.Content.ReadAsStringAsync();
			@@ -109,7 +125,7 @@

			throw new HttpRequestException(body);
			}

			_logger.LogInformation("InvokeMESService FeedbackOutbound body: " + body);

			return JsonConvert.DeserializeObject<ResponseModel>(body);
			}
			@@ -218,6 +234,8 @@
			}
			}



			/// <summary>
			///
			/// </summary>
			@@ -226,314 +244,524 @@
			/// <returns></returns>
			public async Task<WebResponseContent> BatchOrderFeedbackToMes(List<string> orderNos, int inout)
			{
			if (inout == 1)
			{
			foreach (var orderNo in orderNos)
			try
			{

			if (inout == 1)
			{
			try
			foreach (var orderNo in orderNos)
			{
			var stockinfos = _stockInfoRepository.Db.Queryable<Dt_StockInfo>("info").Where(info => info.StockStatus == 6)
			.Where(it => SqlFunc.Subqueryable<Dt_StockInfoDetail>().Where(s => s.StockId == it.Id && s.OrderNo == orderNo).Any())
			.ToList();
			var feeds = _feedbacktomesRepository.Db.Queryable<Dt_FeedbackToMes>().Where(x => x.OrderNo == orderNo && x.ReportStatus == 1).Select(o => o.PalletCode).ToList();
			var unreports = stockinfos.Where(x => !feeds.Contains(x.PalletCode)).ToList();
			if (unreports != null && !unreports.Any())
			try
			{
			return WebResponseContent.Instance.Error("æ²¡æéè¦åä¼ çæ°æ®");
			}
			foreach (var item in unreports)
			{
			var lists = _stockInfoDetailRepository.Db.Queryable<Dt_StockInfoDetail>().Where(x => x.StockId == item.Id).ToList();
			if (lists.Any())
			var stockinfos = _stockInfoRepository.Db.Queryable<Dt_StockInfo>("info").Where(info => info.StockStatus == 6)
			.Where(it => SqlFunc.Subqueryable<Dt_StockInfoDetail>().Where(s => s.StockId == it.Id && s.OrderNo == orderNo).Any())
			.ToList();
			var feeds = _feedbacktomesRepository.Db.Queryable<Dt_FeedbackToMes>().Where(x => x.OrderNo == orderNo && x.ReportStatus == 1).Select(o => o.PalletCode).ToList();
			var unreports = stockinfos.Where(x => !feeds.Contains(x.PalletCode)).ToList();
			if (unreports != null && !unreports.Any())
			{
			var inboundOrder = _inboundOrderRepository.Db.Queryable<Dt_InboundOrder>().First(x => x.InboundOrderNo == lists.FirstOrDefault().OrderNo);
			if (inboundOrder != null)
			return WebResponseContent.Instance.Error("æ²¡æéè¦åä¼ çæ°æ®");
			}
			foreach (var item in unreports)
			{
			var lists = _stockInfoDetailRepository.Db.Queryable<Dt_StockInfoDetail>().Where(x => x.StockId == item.Id).ToList();
			if (lists.Any())
			{
			if (inboundOrder.OrderType == (int)InOrderTypeEnum.AllocatInbound)//è°æ¨å¥åº
			var inboundOrder = _inboundOrderRepository.Db.Queryable<Dt_InboundOrder>().First(x => x.InboundOrderNo == lists.FirstOrDefault().OrderNo);
			if (inboundOrder != null)
			{
			var allocate = SqlSugarHelper.DbWMS.Queryable<Dt_AllocateOrder>().Where(x => x.OrderNo == inboundOrder.InboundOrderNo).First();
			var allocatefeedmodel = new AllocateDto
			if (inboundOrder.OrderType == (int)InOrderTypeEnum.AllocatInbound)//è°æ¨å¥åº
			{
			ReqCode = Guid.NewGuid().ToString(),
			ReqTime = DateTime.Now.ToString(),
			BusinessType = "2",
			FactoryArea = inboundOrder.FactoryArea,
			OperationType = 1,
			Operator = inboundOrder.Operator,
			OrderNo = inboundOrder.UpperOrderNo,
			fromWarehouse = allocate?.FromWarehouse ?? "",
			toWarehouse = allocate?.ToWarehouse ?? "",
			Details = new List<AllocateDtoDetail>()
			var allocate = SqlSugarHelper.DbWMS.Queryable<Dt_AllocateOrder>().Where(x => x.OrderNo == inboundOrder.InboundOrderNo).First();
			var allocatefeedmodel = new AllocateDto
			{
			ReqCode = Guid.NewGuid().ToString(),
			ReqTime = DateTime.Now.ToString(),
			BusinessType = "2",
			FactoryArea = inboundOrder.FactoryArea,
			OperationType = 1,
			Operator = inboundOrder.Operator,
			OrderNo = inboundOrder.UpperOrderNo,
			fromWarehouse = allocate?.FromWarehouse ?? "",
			toWarehouse = allocate?.ToWarehouse ?? "",
			Details = new List<AllocateDtoDetail>()

			};
			};

			var groupedData = lists.GroupBy(item => new { item.MaterielCode, item.SupplyCode, item.BatchNo, item.InboundOrderRowNo, item.BarcodeUnit, item.WarehouseCode })
			.Select(group => new AllocateDtoDetail
			{
			MaterialCode = group.Key.MaterielCode,
			LineNo = group.Key.InboundOrderRowNo,
			WarehouseCode = group.Key.WarehouseCode,
			Qty = group.Sum(x => x.BarcodeQty),
			// warehouseCode= "1072",
			Unit = group.Key.BarcodeUnit,
			Barcodes = group.Select(row => new BarcodeInfo
			var groupedData = lists.GroupBy(item => new { item.MaterielCode, item.InboundOrderRowNo, item.BarcodeUnit, item.WarehouseCode })
			.Select(group => new AllocateDtoDetail
			{
			Barcode = row.Barcode,
			Qty = row.BarcodeQty,
			BatchNo = row.BatchNo,
			SupplyCode = row.SupplyCode,
			Unit = row.Unit
			}).ToList()
			}).ToList();
			allocatefeedmodel.Details = groupedData;
			MaterialCode = group.Key.MaterielCode,
			LineNo = group.Key.InboundOrderRowNo,
			WarehouseCode = group.Key.WarehouseCode,
			Qty = group.Sum(x => x.BarcodeQty),
			Unit = group.Key.BarcodeUnit,
			Barcodes = group.Select(row => new BarcodeInfo
			{
			Barcode = row.Barcode,
			Qty = row.BarcodeQty,
			BatchNo = row.BatchNo,
			SupplyCode = row.SupplyCode,
			Unit = row.BarcodeUnit
			}).ToList()
			}).ToList();
			allocatefeedmodel.Details = groupedData;

			var result = await FeedbackAllocate(allocatefeedmodel);
			if (result != null && result.code == 200)
			{
			_feedbacktomesRepository.Db.Insertable(new Dt_FeedbackToMes { OrderNo = orderNo, PalletCode = item.PalletCode, ReportStatus = 1 }).ExecuteCommand();
			var result = await FeedbackAllocate(allocatefeedmodel);
			if (result != null && result.code == 200)
			{
			_feedbacktomesRepository.Db.Insertable(new Dt_FeedbackToMes { OrderNo = orderNo, PalletCode = item.PalletCode, ReportStatus = 1 }).ExecuteCommand();
			}
			}
			}
			else
			{
			var feedmodel = new FeedbackInboundRequestModel
			else
			{
			reqCode = Guid.NewGuid().ToString(),
			reqTime = DateTime.Now.ToString(),
			business_type = inboundOrder.BusinessType,
			factoryArea = inboundOrder.FactoryArea,
			operationType = 1,
			Operator = inboundOrder.Operator,
			orderNo = inboundOrder.UpperOrderNo,
			status = inboundOrder.OrderStatus,
			details = new List<FeedbackInboundDetailsModel>()
			var feedmodel = new FeedbackInboundRequestModel
			{
			reqCode = Guid.NewGuid().ToString(),
			reqTime = DateTime.Now.ToString(),
			business_type = inboundOrder.BusinessType,
			factoryArea = inboundOrder.FactoryArea,
			operationType = 1,
			Operator = inboundOrder.Operator,
			orderNo = inboundOrder.UpperOrderNo,
			status = inboundOrder.OrderStatus,
			details = new List<FeedbackInboundDetailsModel>()

			};
			};

			var groupedData = lists.GroupBy(item => new { item.MaterielCode, item.SupplyCode, item.BatchNo, item.InboundOrderRowNo, item.BarcodeUnit, item.WarehouseCode })
			.Select(group => new FeedbackInboundDetailsModel
			{
			materialCode = group.Key.MaterielCode,
			supplyCode = group.Key.SupplyCode,
			batchNo = group.Key.BatchNo,
			lineNo = group.Key.InboundOrderRowNo,
			qty = group.Sum(x => x.BarcodeQty),
			// warehouseCode = group.Key.WarehouseCode=="0"?"1072": group.Key.WarehouseCode,
			warehouseCode = group.Key.WarehouseCode,
			unit = group.Key.BarcodeUnit,
			barcodes = group.Select(row => new FeedbackBarcodesModel
			var groupedData = lists.GroupBy(item => new { item.MaterielCode, item.SupplyCode, item.BatchNo, item.InboundOrderRowNo, item.BarcodeUnit, item.WarehouseCode })
			.Select(group => new FeedbackInboundDetailsModel
			{
			barcode = row.Barcode,
			qty = row.BarcodeQty
			}).ToList()
			}).ToList();
			feedmodel.details = groupedData;
			var result = await FeedbackInbound(feedmodel);
			if (result != null && result.code == 200)
			{
			_feedbacktomesRepository.Db.Insertable(new Dt_FeedbackToMes { OrderNo = orderNo, PalletCode = item.PalletCode, ReportStatus = 1 }).ExecuteCommand();
			materialCode = group.Key.MaterielCode,
			supplyCode = group.Key.SupplyCode,
			batchNo = group.Key.BatchNo,
			lineNo = group.Key.InboundOrderRowNo,
			qty = group.Sum(x => x.BarcodeQty),
			// warehouseCode = group.Key.WarehouseCode=="0"?"1072": group.Key.WarehouseCode,
			warehouseCode = group.Key.WarehouseCode,
			unit = group.Key.BarcodeUnit,
			barcodes = group.Select(row => new FeedbackBarcodesModel
			{
			barcode = row.Barcode,
			qty = row.BarcodeQty
			}).ToList()
			}).ToList();
			feedmodel.details = groupedData;
			var result = await FeedbackInbound(feedmodel);
			if (result != null && result.code == 200)
			{
			_feedbacktomesRepository.Db.Insertable(new Dt_FeedbackToMes { OrderNo = orderNo, PalletCode = item.PalletCode, ReportStatus = 1 }).ExecuteCommand();
			}
			}
			}
			}
			}
			}
			}
			catch (Exception ex)
			{
			_logger.LogInformation("InvokeMESService BatchOrderFeedbackToMes ååMESå¤±è´¥: " + ex.Message);
			return WebResponseContent.Instance.Error(ex.Message);
			}
			catch (Exception ex)
			{
			_logger.LogInformation("InvokeMESService BatchOrderFeedbackToMes ååMESå¤±è´¥: " + ex.Message);
			return WebResponseContent.Instance.Error(ex.Message);
			}

			}
			}
			}
			else if (inout == 2)
			{
			foreach (var orderNo in orderNos)
			else if (inout == 2)
			{
			var outboundOrder = await _outboundOrderService.Db.Queryable<Dt_OutboundOrder>().FirstAsync(x => x.OrderNo == orderNo);
			if (outboundOrder != null && outboundOrder.IsBatch == 0)
			foreach (var orderNo in orderNos)
			{
			await HandleOutboundOrderToMESCompletion(outboundOrder, orderNo);
			var outboundOrder = await _outboundOrderService.Db.Queryable<Dt_OutboundOrder>().FirstAsync(x => x.OrderNo == orderNo);
			if (outboundOrder != null && outboundOrder.IsBatch == 0)
			{
			var result = await HandleOutboundOrderToMESCompletion(outboundOrder, orderNo);
			return result;
			}
			else if (outboundOrder != null && outboundOrder.IsBatch == 1)
			{
			var result = await HandleOutboundOrderBatchToMESCompletion(outboundOrder, orderNo);
			return result;
			}
			}
			else if (outboundOrder != null && outboundOrder.IsBatch == 1)
			{
			await HandleOutboundOrderBatchToMESCompletion(outboundOrder, orderNo);
			}

			}

			//}
			//else
			//{
			// // æ¢éå¤±è´¥ï¼è¯´ææå¦ä¸ä¸ªçº¿ç¨ï¼WCSåè°æäººå·¥æä½ï¼æ£å¨å¤ç

			// return WebResponseContent.Instance.Error("WMSæ£å¨å¤çæ¤åä¼ ä»»å¡ï¼è¯·å¿éå¤æä½ã");
			//}
			}
			catch (Exception ex)
			{
			_logger.LogInformation("InvokeMESService BatchOrderFeedbackToMes : " + ex.Message);
			}
			finally
			{
			// 2. ãéæ¾ååéãæ è®ºæåå¤±è´¥ï¼å¿é¡»éæ¾
			// MemoryLockManager.ReleaseLock(orderNos[0]);
			}
			return WebResponseContent.Instance.OK();
			}
			private async Task HandleOutboundOrderBatchToMESCompletion(Dt_OutboundOrder outboundOrder, string orderNo)
			{

			private async Task<WebResponseContent> HandleOutboundOrderBatchToMESCompletion(Dt_OutboundOrder outboundOrder, string orderNo)
			{
			// å®ä¹é»è®¤è¿åï¼æåæï¼
			WebResponseContent response = WebResponseContent.Instance.OK("åä¼ MESå¤çå®æ");
			//0 = æªåä¼ ï¼1 = å·²åä¼ æåï¼2 = åä¼ å¤±è´¥
			try
			{
			if (outboundOrder.ReturnToMESStatus == 1)
			{
			return;
			}
			// æ ¡éªï¼å·²åä¼ ç´æ¥è¿åéè¯¯
			//if (outboundOrder.ReturnToMESStatus == 1)
			//{
			// return WebResponseContent.Instance.Error("è¯¥åå·²ç»åä¼ ï¼");
			//}

			// æ¥è¯¢è®¢åæç»ï¼ä»æ¥è¯¢æªåä¼ æåçï¼
			var orderDetails = await _outboundOrderDetailService.Db.Queryable<Dt_OutboundOrderDetail>()
			.LeftJoin<Dt_OutboundOrder>((o, item) => o.OrderId == item.Id)
			.Where((o, item) => item.OrderNo == orderNo && item.ReturnToMESStatus != 1)
			.Select((o, item) => o)
			.ToListAsync();

			var detailids = new List<int>();
			var allCompleted = true;
			foreach (var detail in orderDetails.Where(x => x.ReturnToMESStatus == 0).ToList())
			if (!orderDetails.Any())
			{
			if (detail.OverOutQuantity >= detail.NeedOutQuantity)
			return WebResponseContent.Instance.Error("ææ éè¦å¤ççè®¢åæç»");
			}


			var pickingRecords = await _pickingRecoreRepository.Db.Queryable<Dt_PickingRecord>().Where(x => x.OrderNo == orderNo && x.ReturnToMESStatus != 1 && !x.IsCancelled).ToListAsync();

			if (!pickingRecords.Any())
			return WebResponseContent.Instance.Error("æ²¡æéè¦åä¼ çåæ£è®°å½");


			var groups = pickingRecords.GroupBy(x => x.FeedBackMesDocumentNo).ToList();
			foreach (var group in groups)
			{

			List<Dt_PickingRecord> records = group.ToList(); // è¯¥åç»ä¸çææè®°å½
			if (string.IsNullOrEmpty(group.Key))
			{
			detailids.Add(detail.Id);
			var emptydocumentNo = UniqueValueGenerator.Generate();
			records.ForEach(x => { x.FeedBackMesDocumentNo = emptydocumentNo; });
			var result = await _pickingRecoreRepository.Db.Updateable(records).ExecuteCommandAsync();

			var interfacelog = new Dt_InterfaceLog
			{
			Content = JsonConvert.SerializeObject(records),
			DocumentNo = emptydocumentNo,
			OrderNo = orderNo,
			OrderType = "2",
			};
			_interfacelogRepository.AddData(interfacelog);

			if (result > 0)
			{
			(bool _flowControl, WebResponseContent _value) = await FeedBackBatchToMes(outboundOrder, orderNo, orderDetails, pickingRecords, emptydocumentNo);

			return _value;

			}
			}
			else
			{
			allCompleted = false;
			}
			}
			if (orderDetails.Any(x => x.ReturnToMESStatus == 2))
			{
			allCompleted = false;
			}

			int newStatus = allCompleted ? (int)OutOrderStatusEnum.åºåºå®æ : (int)OutOrderStatusEnum.åºåºä¸;

			if (outboundOrder.OrderStatus != newStatus)
			{
			await _outboundOrderService.Db.Updateable<Dt_OutboundOrder>()
			.SetColumns(x => x.OrderStatus == newStatus)
			.Where(x => x.OrderNo == orderNo)
			.ExecuteCommandAsync();

			}
			var documentno = UniqueValueGenerator.Generate();
			var feedmodel = new FeedbackOutboundRequestModel
			{
			reqCode = Guid.NewGuid().ToString(),
			reqTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
			business_type = outboundOrder.BusinessType,
			factoryArea = outboundOrder.FactoryArea,
			operationType = 1,
			Operator = outboundOrder.Operator,
			orderNo = outboundOrder.UpperOrderNo,
			documentsNO = documentno,
			status = outboundOrder.OrderStatus,
			details = new List<FeedbackOutboundDetailsModel>()
			};


			foreach (var detail in orderDetails.Where(x => detailids.Contains(x.Id)).ToList())
			{
			// è·åè¯¥æç»å¯¹åºçæ¡ç ä¿¡æ¯ï¼ä»éå®è®°å½ï¼
			var detailLocks = await _outStockLockInfoService.Db.Queryable<Dt_OutStockLockInfo>()
			.Where(x => x.OrderNo == orderNo && detailids.Contains(x.OrderDetailId) &&
			x.Status == (int)OutLockStockStatusEnum.æ£éå®æ)
			.ToListAsync();

			var detailModel = new FeedbackOutboundDetailsModel
			{
			materialCode = detail.MaterielCode,
			lineNo = detail.lineNo, // æ³¨æï¼è¿éå¯è½éè¦è°æ´åæ®µå
			warehouseCode = detail.WarehouseCode,
			qty = detail.OverOutQuantity, // ä½¿ç¨è®¢åæç»çå·²åºåºæ°é
			currentDeliveryQty = detail.OverOutQuantity,
			unit = detail.Unit,
			barcodes = detailLocks.Select(lockInfo => new WIDESEA_DTO.Outbound.BarcodesModel
			var ilog = _interfacelogRepository.QueryFirst(x => x.DocumentNo == group.Key);
			if (ilog == null)
			{
			barcode = lockInfo.CurrentBarcode,
			supplyCode = lockInfo.SupplyCode,
			batchNo = lockInfo.BatchNo,
			unit = lockInfo.Unit,
			qty = lockInfo.PickedQty // æ¡ç çº§å«çæ°éä»ç¨éå®è®°å½
			}).ToList()
			};

			feedmodel.details.Add(detailModel);
			}

			var result = await FeedbackOutbound(feedmodel);
			if (result != null && result.code == 200)
			{

			await _outboundOrderDetailService.Db.Updateable<Dt_OutboundOrderDetail>()
			.SetColumns(it => new Dt_OutboundOrderDetail
			{
			ReturnToMESStatus = 1,
			documentsNO = documentno,
			})
			.Where(x => detailids.Contains(x.Id))
			.ExecuteCommandAsync();

			if (allCompleted && newStatus == (int)OutOrderStatusEnum.åºåºå®æ)
			{
			await _outboundOrderService.Db.Updateable<Dt_OutboundOrder>()
			.SetColumns(x => x.ReturnToMESStatus == 1)
			.Where(x => x.OrderNo == orderNo)
			.ExecuteCommandAsync();
			}
			else
			{
			var dborderDetails = await _outboundOrderDetailService.Db.Queryable<Dt_OutboundOrderDetail>()
			.LeftJoin<Dt_OutboundOrder>((o, item) => o.OrderId == item.Id)
			.Where((o, item) => item.OrderNo == orderNo && item.ReturnToMESStatus != 1)
			.Select((o, item) => o)
			.ToListAsync();
			var secallCompleted = true;
			foreach (var detail in orderDetails.Where(x => x.ReturnToMESStatus == 0).ToList())
			{
			if (detail.OverOutQuantity < detail.NeedOutQuantity)
			var interfacelog = new Dt_InterfaceLog
			{
			secallCompleted = false;
			}
			Content = JsonConvert.SerializeObject(records),
			DocumentNo = group.Key,
			OrderNo = orderNo,
			OrderType = "2",
			};
			_interfacelogRepository.AddData(interfacelog);
			}
			if (secallCompleted)
			{
			await _outboundOrderService.Db.Updateable<Dt_OutboundOrder>()
			.SetColumns(it => new Dt_OutboundOrder
			{
			ReturnToMESStatus = 1,
			OrderStatus = OutOrderStatusEnum.åºåºå®æ.ObjToInt(),
			})
			.Where(x => x.OrderNo == orderNo)
			.ExecuteCommandAsync();
			}
			(bool _flowControl, WebResponseContent _value) = await FeedBackBatchToMes(outboundOrder, orderNo, orderDetails, pickingRecords, group.Key);

			return _value;

			}
			}
			else
			{
			await _outboundOrderDetailService.Db.Updateable<Dt_OutboundOrderDetail>()
			.SetColumns(it => new Dt_OutboundOrderDetail
			{
			ReturnToMESStatus = 2,
			documentsNO = documentno,
			})
			.Where(x => detailids.Contains(x.Id))
			.ExecuteCommandAsync();
			}


			//var documentNo = UniqueValueGenerator.Generate();

			//(bool flowControl, WebResponseContent value) = await FeedBackBatchToMes(outboundOrder, orderNo, orderDetails, pickingRecords, documentNo);
			//if (!flowControl)
			//{
			// return value;
			//}

			// åä¼ æåçæç»è¿å
			response = WebResponseContent.Instance.OK($"åä¼ MESæåï¼åæ®å·ï¼{orderNo}");
			}
			catch (Exception ex)
			{
			_logger.LogError($"CheckAndUpdateOrderStatuså¤±è´¥ - OrderNo: {orderNo}, Error: {ex.Message}");
			// å¨å±å¼å¸¸æè·ï¼è®°å½è¯¦ç»æ¥å¿ + è¿åéè¯¯
			string errorMsg = $"å¤çåºåºååä¼ MESæ¶åçå¼å¸¸ - OrderNo: {orderNo}, Error: {ex.Message}, StackTrace: {ex.StackTrace}";
			_logger.LogError(ex, errorMsg); // è®°å½å¸¦å¼å¸¸å æ çæ¥å¿

			// å¼å¸¸è¿åï¼ç»åç«¯çåå¥½æç¤ºï¼éèå æ ä¿¡æ¯ï¼
			response = WebResponseContent.Instance.Error("å¤çåä¼ MESæ¶åçå¼å¸¸ï¼è¯·èç³»ç®¡çå");
			}

			return response;
			}


			private async Task HandleOutboundOrderToMESCompletion(Dt_OutboundOrder outboundOrder, string orderNo)
			private async Task<(bool flowControl, WebResponseContent value)> FeedBackBatchToMes(Dt_OutboundOrder outboundOrder, string orderNo, List<Dt_OutboundOrderDetail> orderDetails, List<Dt_PickingRecord> pickingRecords, string documentNo)
			{
			var feedModel = new FeedbackOutboundRequestModel
			{
			reqCode = Guid.NewGuid().ToString(),
			reqTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
			business_type = outboundOrder.BusinessType,
			factoryArea = outboundOrder.FactoryArea,
			operationType = 1,
			Operator = outboundOrder.Operator != "" ? outboundOrder.Operator : App.User.UserName,
			orderNo = outboundOrder.UpperOrderNo,
			documentsNO = documentNo,
			status = outboundOrder.OrderStatus,
			details = new List<FeedbackOutboundDetailsModel>()
			};
			var detailIds = new List<int>();
			// å¡«åæç»åæ¡ç ä¿¡æ¯
			foreach (var detail in orderDetails)
			{
			// æ¥è¯¢è¯¥æç»å¯¹åºçéå®æ¡ç è®°å½
			var detailPicks = pickingRecords.Where(x => x.OrderNo == orderNo
			&& detail.Id == x.OrderDetailId).ToList();
			if (!detailPicks.Any())
			{
			continue;
			}
			var detailModel = new FeedbackOutboundDetailsModel
			{
			materialCode = detail.MaterielCode,
			lineNo = detail.lineNo,
			warehouseCode = detail.WarehouseCode,
			qty = detail.BarcodeQty,
			currentDeliveryQty = 0,
			unit = detail.BarcodeUnit,
			barcodes = new List<WIDESEA_DTO.Outbound.BarcodesModel>()
			};

			// å¡«åæ¡ç ä¿¡æ¯ï¼å«åä½è½¬æ¢ï¼
			foreach (var item in detailPicks)
			{
			if (item.PickQuantity <= 0)
			{
			continue;
			}
			var barModel = new WIDESEA_DTO.Outbound.BarcodesModel
			{
			barcode = item.Barcode,
			supplyCode = item.SupplyCode,
			batchNo = item.BatchNo,
			unit = item.BarcodeUnit,
			qty = item.PickQuantity
			};

			// åä½ä¸ä¸è´æ¶è½¬æ¢
			if (detail.BarcodeUnit != detail.Unit)
			{
			var convertResult = await _materialUnitService.ConvertAsync(
			item.MaterielCode, item.PickQuantity, detail.Unit, detail.BarcodeUnit);
			barModel.unit = convertResult.Unit;
			barModel.qty = convertResult.Quantity;
			}
			else
			{
			barModel.qty = item.PickQuantity;
			}
			detailModel.currentDeliveryQty += barModel.qty;
			detailModel.barcodes.Add(barModel);
			}
			detailIds.Add(detail.Id);
			feedModel.details.Add(detailModel);
			}

			feedModel.details = feedModel.details.GroupBy(item => new { item.materialCode, item.lineNo, item.warehouseCode, item.unit, item.qty }).Select(group => new FeedbackOutboundDetailsModel
			{
			materialCode = group.Key.materialCode,
			lineNo = group.Key.lineNo,
			warehouseCode = group.Key.warehouseCode,
			qty = group.Key.qty,
			currentDeliveryQty = group.Sum(x => x.currentDeliveryQty),
			unit = group.Key.unit,
			barcodes = group.SelectMany(x => x.barcodes.GroupBy(o => new { o.barcode, o.supplyCode, o.batchNo, o.unit }).Select(row => new WIDESEA_DTO.Outbound.BarcodesModel
			{
			barcode = row.Key.barcode,
			supplyCode = row.Key.supplyCode,
			batchNo = row.Key.batchNo,
			unit = row.Key.unit,
			qty = row.Sum(y => y.qty)
			})).ToList()
			}).ToList();

			var allCompleted = true;

			// çéå¾åä¼ çæç»ï¼ReturnToMESStatus=0ï¼
			var pendingDetails = orderDetails.Where(x => x.ReturnToMESStatus == 0).ToList();
			foreach (var detail in pendingDetails)
			{
			if (detail.OverOutQuantity < detail.NeedOutQuantity)
			{
			allCompleted = false;
			}
			}

			// åå¨åä¼ å¤±è´¥çæç»ï¼ReturnToMESStatus=2ï¼ï¼æ è®°æªå®æ
			if (orderDetails.Any(x => x.ReturnToMESStatus == 2))
			{
			allCompleted = false;
			}

			// æ´æ°è®¢åç¶æ
			int newStatus = allCompleted ? (int)OutOrderStatusEnum.åºåºå®æ : (int)OutOrderStatusEnum.åºåºä¸;
			if (allCompleted && outboundOrder.OrderStatus != newStatus)
			{

			int updateCount = await _outboundOrderService.Db.Updateable<Dt_OutboundOrder>()
			.SetColumns(x => x.OrderStatus == newStatus)
			.Where(x => x.OrderNo == orderNo)
			.ExecuteCommandAsync();

			if (updateCount <= 0)
			{
			_logger.LogWarning($"æ´æ°åºåºåç¶æå¤±è´¥ - OrderNo: {orderNo}, ç®æ ç¶æ: {newStatus}");

			}
			}


			// è°ç¨MESåä¼ æ¥å£
			var mesResult = await FeedbackOutbound(feedModel);
			if (mesResult == null \|\| mesResult.code != 200)
			{

			// æ´æ°æç»ä¸ºåä¼ å¤±è´¥ï¼ReturnToMESStatus=2ï¼
			await _outboundOrderDetailService.Db.Updateable<Dt_OutboundOrderDetail>()
			.SetColumns(it => new Dt_OutboundOrderDetail
			{
			ReturnToMESStatus = 2,
			documentsNO = documentNo,
			})
			.Where(x => detailIds.Contains(x.Id))
			.ExecuteCommandAsync();

			return (flowControl: false, value: WebResponseContent.Instance.Error($"åä¼ MESå¤±è´¥"));
			}
			foreach (var record in pickingRecords.Where(x => detailIds.Contains(x.OrderDetailId)).ToList())
			{
			record.ReturnToMESStatus = 1;
			}
			var updates = pickingRecords.Where(x => detailIds.Contains(x.OrderDetailId)).ToList();
			updates.ForEach(x =>
			{
			x.ReturnToMESStatus = 1;
			});
			await _pickingRecoreRepository.Db.Updateable(updates).ExecuteCommandAsync();
			await _interfacelogRepository.Db.Updateable<Dt_InterfaceLog>()
			.SetColumns(x => x.ReturnToMESStatus == 1)
			.Where(x => x.OrderNo == orderNo)
			.ExecuteCommandAsync();

			if (allCompleted)
			{
			//MESåä¼ æåï¼æ´æ°æç»ä¸ºåä¼ æåç¶æ
			await _outboundOrderDetailService.Db.Updateable<Dt_OutboundOrderDetail>()
			.SetColumns(it => new Dt_OutboundOrderDetail
			{
			ReturnToMESStatus = 1,
			documentsNO = documentNo,
			})
			.Where(x => detailIds.Contains(x.Id))
			.ExecuteCommandAsync();
			}
			// æ ¡éªæ¯å¦æææç»é½å®æï¼æ´æ°è®¢åæç»ç¶æ
			if (allCompleted && newStatus == (int)OutOrderStatusEnum.åºåºå®æ)
			{
			await _outboundOrderService.Db.Updateable<Dt_OutboundOrder>()
			.SetColumns(x => new Dt_OutboundOrder
			{
			ReturnToMESStatus = 1,
			OrderStatus = newStatus
			})
			.Where(x => x.OrderNo == orderNo)
			.ExecuteCommandAsync();
			}
			else
			{
			// äºæ¬¡æ ¡éªæ¯å¦æææªåä¼ æç»é½å·²å®æ
			var dbOrderDetails = await _outboundOrderDetailService.Db.Queryable<Dt_OutboundOrderDetail>()
			.LeftJoin<Dt_OutboundOrder>((o, item) => o.OrderId == item.Id)
			.Where((o, item) => item.OrderNo == orderNo && item.ReturnToMESStatus != 1)
			.Select((o, item) => o)
			.ToListAsync();

			var secAllCompleted = true;
			foreach (var detail in dbOrderDetails.Where(x => x.ReturnToMESStatus == 0).ToList())
			{
			if (detail.OverOutQuantity < detail.NeedOutQuantity)
			{
			secAllCompleted = false;
			break;
			}
			}

			if (secAllCompleted)
			{
			await _outboundOrderService.Db.Updateable<Dt_OutboundOrder>()
			.SetColumns(it => new Dt_OutboundOrder
			{
			ReturnToMESStatus = 1,
			OrderStatus = OutOrderStatusEnum.åºåºå®æ.ObjToInt(),
			})
			.Where(x => x.OrderNo == orderNo)
			.ExecuteCommandAsync();
			}
			}

			return (flowControl: true, value: null);
			}

			private async Task<WebResponseContent> HandleOutboundOrderToMESCompletion(Dt_OutboundOrder outboundOrder, string orderNo)
			{
			// åç½®åæ°æ ¡éªï¼ç©ºå¼ç´æ¥è¿åéè¯¯
			if (outboundOrder == null)
			{
			return WebResponseContent.Instance.Error("åºåºåå®ä½ä¸ºç©ºï¼æ æ³å¤çåä¼ MES");
			}

			if (string.IsNullOrWhiteSpace(orderNo))
			{
			return WebResponseContent.Instance.Error("è®¢åå·ä¸ºç©ºï¼æ æ³å¤çåä¼ MES");
			}

			try
			{

			if (outboundOrder.ReturnToMESStatus == 1)
			{
			return;
			return WebResponseContent.Instance.Error($"OrderNo: {orderNo}, è¯¥åå·²ç»åä¼ ï¼");
			}


			var orderDetails = await _outboundOrderDetailService.Db.Queryable<Dt_OutboundOrderDetail>()
			.LeftJoin<Dt_OutboundOrder>((o, item) => o.OrderId == item.Id)
			.Where((o, item) => item.OrderNo == orderNo)
			.Select((o, item) => o)
			.ToListAsync();

			// æ æç»åºæ¯è¿åè¦å
			if (!orderDetails.Any())
			{
			return WebResponseContent.Instance.Error($"OrderNo: {orderNo} æªæ¥è¯¢å°è®¢åæç»");
			}

			// å¤ææ¯å¦æææç»å®æåºåº
			bool allCompleted = true;
			foreach (var detail in orderDetails)
			{
			@@ -544,17 +772,17 @@
			}
			}

			// æ´æ°è®¢åç¶æï¼ä¿®æ£è¯æ³éè¯¯ï¼== â =ï¼
			int newStatus = allCompleted ? (int)OutOrderStatusEnum.åºåºå®æ : (int)OutOrderStatusEnum.åºåºä¸;

			if (outboundOrder.OrderStatus != newStatus)
			{
			await _outboundOrderService.Db.Updateable<Dt_OutboundOrder>()
			.SetColumns(x => x.OrderStatus == newStatus)
			.SetColumns(x => x.OrderStatus == newStatus) // å³é®ä¿®æ£ï¼èµå¼èéå¤æ
			.Where(x => x.OrderNo == orderNo)
			.ExecuteCommandAsync();

			}
			//åªææ£å¸¸åæ£å®ææ¶æåMESåé¦

			// ä»åæ£å®ææ¶åMESåé¦
			if (allCompleted && newStatus == (int)OutOrderStatusEnum.åºåºå®æ)
			{
			var feedmodel = new FeedbackOutboundRequestModel
			@@ -571,40 +799,47 @@
			details = new List<FeedbackOutboundDetailsModel>()
			};


			// æå»ºæç»æ°æ®
			foreach (var detail in orderDetails)
			{
			// è·åè¯¥æç»å¯¹åºçæ¡ç ä¿¡æ¯ï¼ä»éå®è®°å½ï¼
			var detailLocks = await _outStockLockInfoService.Db.Queryable<Dt_OutStockLockInfo>()
			.Where(x => x.OrderNo == orderNo &&
			x.OrderDetailId == detail.Id &&
			x.Status == (int)OutLockStockStatusEnum.æ£éå®æ)
			(x.Status == (int)OutLockStockStatusEnum.æ£éå®æ \|\| x.Status == (int)OutLockStockStatusEnum.å·²ååº))
			.ToListAsync();

			var detailModel = new FeedbackOutboundDetailsModel
			{
			materialCode = detail.MaterielCode,
			lineNo = detail.lineNo, // æ³¨æï¼è¿éå¯è½éè¦è°æ´åæ®µå
			warehouseCode = detail.WarehouseCode,
			qty = detail.OverOutQuantity, // ä½¿ç¨è®¢åæç»çå·²åºåºæ°é
			currentDeliveryQty = detail.OverOutQuantity,
			unit = detail.Unit,
			barcodes = detailLocks.Select(lockInfo => new WIDESEA_DTO.Outbound.BarcodesModel
			var groupdata = detailLocks.GroupBy(item => new { item.MaterielCode, item.lineNo, item.BarcodeUnit, item.WarehouseCode })
			.Select(group => new FeedbackOutboundDetailsModel
			{
			barcode = lockInfo.CurrentBarcode,
			supplyCode = lockInfo.SupplyCode,
			batchNo = lockInfo.BatchNo,
			unit = lockInfo.Unit,
			qty = lockInfo.PickedQty // æ¡ç çº§å«çæ°éä»ç¨éå®è®°å½
			}).ToList()
			};
			materialCode = group.Key.MaterielCode,
			lineNo = group.Key.lineNo,
			warehouseCode = group.Key.WarehouseCode,
			qty = group.Sum(x => x.PickedQty),
			currentDeliveryQty = group.Sum(x => x.PickedQty),
			unit = group.Key.BarcodeUnit,
			barcodes = group.Select(lockInfo => new WIDESEA_DTO.Outbound.BarcodesModel
			{
			barcode = lockInfo.CurrentBarcode,
			supplyCode = lockInfo.SupplyCode,
			batchNo = lockInfo.BatchNo,
			unit = lockInfo.BarcodeUnit,
			qty = lockInfo.PickedQty
			}).ToList()
			}).ToList();

			feedmodel.details.Add(detailModel);
			feedmodel.details.AddRange(groupdata);
			}

			// è°ç¨MESæ¥å£
			var result = await FeedbackOutbound(feedmodel);
			if (result != null && result.code == 200)
			if (result == null)
			{
			return WebResponseContent.Instance.Error($"OrderNo: {orderNo} MESåä¼ æ¥å£è¿åç©º");
			}

			if (result.code == 200)
			{
			// åä¼ æåï¼æ´æ°åä¼ ç¶æ
			await _outboundOrderDetailService.Db.Updateable<Dt_OutboundOrderDetail>()
			.SetColumns(x => x.ReturnToMESStatus == 1)
			.Where(x => x.OrderId == outboundOrder.Id)
			@@ -614,16 +849,31 @@
			.SetColumns(x => x.ReturnToMESStatus == 1)
			.Where(x => x.OrderNo == orderNo)
			.ExecuteCommandAsync();

			await _pickingRecoreRepository.Db.Updateable<Dt_PickingRecord>()
			.SetColumns(x => x.ReturnToMESStatus == 1)
			.Where(x => x.OrderNo == orderNo)
			.ExecuteCommandAsync();

			return WebResponseContent.Instance.OK("åä¼ MESæå");
			}
			else
			{
			var errorMsg = $"OrderNo: {orderNo} åä¼ MESå¤±è´¥ï¼éè¯¯ç ï¼{result.code}ï¼éè¯¯ä¿¡æ¯ï¼{result.message ?? "æ "}";
			_logger.LogError(errorMsg);
			return WebResponseContent.Instance.Error(errorMsg);
			}
			}
			return WebResponseContent.Instance.OK("è®¢åç¶æå·²æ´æ°ï¼æªå®å¨å®æåæ£æ éåä¼ MES");
			}
			catch (Exception ex)
			{
			_logger.LogError($"CheckAndUpdateOrderStatuså¤±è´¥ - OrderNo: {orderNo}, Error: {ex.Message}");
			// å¨å±å¼å¸¸æè·ï¼è¿åéè¯¯+è®°å½è¯¦ç»æ¥å¿
			var errorMsg = $"OrderNo: {orderNo} å¤çåä¼ MESæ¶åçå¼å¸¸ï¼{ex.Message}";
			_logger.LogError(ex, errorMsg); // è®°å½å æ ä¿¡æ¯ä¾¿äºææ¥
			return WebResponseContent.Instance.Error("å¤çåä¼ MESæ¶åçå¼å¸¸ï¼è¯·èç³»ç®¡çå");
			}

			}

			}

			public static class UniqueValueGenerator
			@@ -638,14 +888,214 @@
			public static string Generate()
			{
			var now = DateTime.Now;
			string datePart = now.ToString("yyyyMMdd");
			string datePart = now.ToString("MMdd");
			long ticksPart = now.Ticks;
			// æ¼æ¥ï¼è®¡æ°å¨è¡¥0ä¸º3ä½ï¼é¿åä½æ°ä¸ä¸è´ï¼
			return $"{datePart}{ticksPart}";
			}

			public static string GenerateCount()
			{
			var now = DateTime.Now;
			string datePart = now.ToString("yyyyMMddHHmmss");


			// ååéå¢è®¡æ°å¨ï¼åæ¨¡1000ï¼ç¡®ä¿è®¡æ°å¨ä»3ä½ï¼æ§å¶é¿åº¦ï¼
			long counterPart = Interlocked.Increment(ref _counter) % 1000;

			// æ¼æ¥ï¼è®¡æ°å¨è¡¥0ä¸º3ä½ï¼é¿åä½æ°ä¸ä¸è´ï¼
			return $"{datePart}{ticksPart}{counterPart:D3}";
			return $"{datePart}{counterPart:D3}";
			}
			}


			public static class MemoryLockManager
			{
			// åå¨èµæºéçåæ°æ®ï¼éå¯¹è±¡ãææçº¿ç¨ãå ç¨æ¶é´ãè¶æ¶æ¶é´ï¼
			private class LockMetadata
			{
			public object LockObject { get; } = new object();
			public int HoldingThreadId { get; set; } = -1; // ææéççº¿ç¨ID
			public DateTime AcquireTime { get; set; } // è·åéçæ¶é´
			public TimeSpan Timeout { get; set; } // éè¶æ¶æ¶é´
			public bool IsReleased { get; set; } // æ¯å¦å·²éæ¾
			}

			// èµæºID -> éåæ°æ®
			private static readonly ConcurrentDictionary<string, LockMetadata> _resourceLocks = new();
			// å¨å±éï¼ä¿æ¤éåæ°æ®çåå»º/å é¤ï¼
			private static readonly object _globalLocker = new();
			// éæºæ°çæå¨ï¼ç¨äºçæ3-5ç§éæºè¶æ¶ï¼
			private static readonly Random _random = new Random();

			/// <summary>
			/// å°è¯éå®èµæºï¼å¸¦è¶æ¶èªå¨éæ¾ï¼
			/// </summary>
			/// <param name="resourceId">èµæºID</param>
			/// <param name="timeoutSeconds">è¶æ¶æ¶é´ï¼é»è®¤3-5ç§éæºï¼</param>
			/// <returns>æ¯å¦æåè·åé</returns>
			public static bool TryAcquireLock(string resourceId, int? timeoutSeconds = null)
			{
			if (string.IsNullOrEmpty(resourceId))
			throw new ArgumentNullException(nameof(resourceId));

			// ç¡®å®è¶æ¶æ¶é´ï¼3-5ç§éæºï¼
			var timeout = TimeSpan.FromSeconds(timeoutSeconds ?? _random.Next(3, 6));
			var currentThreadId = Thread.CurrentThread.ManagedThreadId;

			LockMetadata lockMeta = null;
			lock (_globalLocker)
			{
			// è·åæåå»ºéåæ°æ®
			lockMeta = _resourceLocks.GetOrAdd(resourceId, key => new LockMetadata());

			// é²æ¢éå¤è·åï¼å½åçº¿ç¨å·²ææéï¼
			if (lockMeta.HoldingThreadId == currentThreadId && !lockMeta.IsReleased)
			return true; // çº¿ç¨å¯éå¥
			}

			// å°è¯è·åéï¼éé»å¡ï¼
			if (!Monitor.TryEnter(lockMeta.LockObject))
			return false;

			// æ è®°éææç¶æ
			lockMeta.HoldingThreadId = currentThreadId;
			lockMeta.AcquireTime = DateTime.Now;
			lockMeta.Timeout = timeout;
			lockMeta.IsReleased = false;

			// å¯å¨è¶æ¶èªå¨éæ¾ä»»å¡
			_ = Task.Delay(timeout).ContinueWith(_ =>
			{
			try
			{
			ReleaseLock(resourceId, force: true);
			}
			catch (Exception ex)
			{
			// è®°å½è¶æ¶éæ¾å¼å¸¸
			Console.WriteLine($"èµæº[{resourceId}]è¶æ¶èªå¨éæ¾å¤±è´¥ï¼{ex.Message}");
			}
			});

			return true;
			}

			/// <summary>
			/// éæ¾èµæºé
			/// </summary>
			/// <param name="resourceId">èµæºID</param>
			/// <param name="force">æ¯å¦å¼ºå¶éæ¾ï¼è¶æ¶èªå¨éæ¾æ¶ä½¿ç¨ï¼</param>
			public static void ReleaseLock(string resourceId, bool force = false)
			{
			if (string.IsNullOrEmpty(resourceId))
			throw new ArgumentNullException(nameof(resourceId));

			if (!_resourceLocks.TryGetValue(resourceId, out var lockMeta))
			return;

			var currentThreadId = Thread.CurrentThread.ManagedThreadId;

			// æ ¡éªéæ¾åæ³æ§ï¼ä»ææéççº¿ç¨æå¼ºå¶éæ¾å¯æ§è¡
			if (!force && lockMeta.HoldingThreadId != currentThreadId)
			{
			// éææçº¿ç¨å°è¯éæ¾ï¼æåºå¼å¸¸æè¿åï¼æ ¹æ®ä¸å¡éæ©ï¼
			throw new InvalidOperationException($"çº¿ç¨[{currentThreadId}]æ æéæ¾èµæº[{resourceId}]çéï¼å½åææçº¿ç¨ï¼{lockMeta.HoldingThreadId}ï¼");
			}

			// åéæ ¡éªéç¶æ
			lock (_globalLocker)
			{
			if (lockMeta.IsReleased)
			return;

			// ç¡®ä¿éè¢«å½åçº¿ç¨ææï¼å¼ºå¶éæ¾é¤å¤ï¼
			if (Monitor.IsEntered(lockMeta.LockObject))
			{
			try
			{
			Monitor.Exit(lockMeta.LockObject);
			}
			catch (SynchronizationLockException)
			{
			// å·²è¢«éæ¾ï¼å¿½ç¥
			return;
			}
			}

			// æ è®°éå·²éæ¾
			lockMeta.IsReleased = true;
			lockMeta.HoldingThreadId = -1;

			// å»¶è¿æ¸çéåæ°æ®ï¼é¿åå¹¶ååå»ºï¼
			// çå¾1ç§åæ¸çï¼é²æ¢åéæ¾å°±ææ°çº¿ç¨æ¢éå¯¼è´éå¤åå»º
			_ = Task.Delay(1000).ContinueWith(_ =>
			{
			lock (_globalLocker)
			{
			// ä»å½éæªè¢«éæ°ææä¸å·²éæ¾æ¶æ¸ç
			if (_resourceLocks.TryGetValue(resourceId, out var meta)
			&& meta.IsReleased
			&& meta.HoldingThreadId == -1)
			{
			_resourceLocks.TryRemove(resourceId, out var _resid);
			}
			}
			});
			}
			}

			/// <summary>
			/// æ£æ¥èµæºæ¯å¦è¢«éå®
			/// </summary>
			public static bool IsLocked(string resourceId)
			{
			if (!_resourceLocks.TryGetValue(resourceId, out var meta))
			return false;

			return !meta.IsReleased && meta.HoldingThreadId != -1;
			}

			public static void TestUsed()
			{
			string orderNo = "testt";
			bool lockAcquired = false;
			try
			{
			// å°è¯è·åéï¼èªå¨3-5ç§è¶æ¶ï¼
			lockAcquired = MemoryLockManager.TryAcquireLock(orderNo);
			if (lockAcquired)
			{
			// æ§è¡ä¸å¡é»è¾ï¼å¦å¤çè®¢åï¼
			Console.WriteLine($"çº¿ç¨[{Thread.CurrentThread.ManagedThreadId}]è·åéï¼{orderNo}");
			// æ¨¡æä¸å¡èæ¶ï¼æµè¯è¶æ¶éæ¾ï¼
			// Thread.Sleep(6000);
			}
			else
			{
			Console.WriteLine($"èµæº[{orderNo}]è¢«å ç¨ï¼è·åéå¤±è´¥");
			}
			}
			catch (Exception ex)
			{
			Console.WriteLine($"ä¸å¡å¤çå¼å¸¸ï¼{ex.Message}");
			}
			finally
			{
			// éæ¾éï¼ä»å½æåè·åæ¶ï¼
			if (lockAcquired)
			{
			try
			{
			MemoryLockManager.ReleaseLock(orderNo);
			Console.WriteLine($"çº¿ç¨[{Thread.CurrentThread.ManagedThreadId}]éæ¾éï¼{orderNo}");
			}
			catch (Exception ex)
			{
			Console.WriteLine($"éæ¾éå¤±è´¥ï¼{ex.Message}");
			}
			}
			}
			}
			}
			}