ZhongRui/ALDbanyunxiangmu.git

			@@ -1,6 +1,7 @@
			ï»¿using Microsoft.Extensions.Logging;
			using Newtonsoft.Json;
			using Org.BouncyCastle.Asn1.Ocsp;
			using SqlSugar;
			using System;
			using System.Collections.Generic;
			using System.Linq;
			@@ -9,10 +10,18 @@
			using System.Security.Policy;
			using System.Text;
			using System.Threading.Tasks;
			using WIDESEA_Common.OrderEnum;
			using WIDESEA_Common.StockEnum;
			using WIDESEA_Core;
			using WIDESEA_Core.BaseRepository;
			using WIDESEA_Core.Helper;
			using WIDESEA_DTO.Allocate;
			using WIDESEA_DTO.Basic;
			using WIDESEA_DTO.Inbound;
			using WIDESEA_DTO.Outbound;
			using WIDESEA_IBasicService;
			using WIDESEA_IOutboundService;
			using WIDESEA_Model.Models;

			namespace WIDESEA_BasicService
			{
			@@ -22,15 +31,40 @@
			private readonly ILogger<InvokeMESService> _logger;
			private string UserName = "12312";
			private string Password = "1";
			public InvokeMESService(IHttpClientFactory httpClientFactory, ILogger<InvokeMESService> logger)

			private readonly IRepository<Dt_FeedbackToMes> _feedbacktomesRepository;
			private readonly IRepository<Dt_StockInfoDetail> _stockInfoDetailRepository;
			private readonly IRepository<Dt_StockInfo> _stockInfoRepository;
			private readonly IRepository<Dt_InboundOrder> _inboundOrderRepository;

			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)
			{
			_httpClientFactory = httpClientFactory;
			_logger = logger;
			_feedbacktomesRepository = feedbacktomesRepository;
			_stockInfoDetailRepository = stockInfoDetailRepository;
			_stockInfoRepository = stockInfoRepository;
			_inboundOrderRepository = inboundOrderRepository;
			_outboundOrderService = outboundOrderService;
			_outboundOrderDetailService = outboundOrderDetailService;
			_outStockLockInfoService = outStockLockInfoService;
			}

			public async Task<ResponseModel> FeedbackInbound( FeedbackInboundRequestModel model)
			/// <summary>
			/// å¥åºåé¦
			/// </summary>
			/// <param name="model"></param>
			/// <returns></returns>
			/// <exception cref="HttpRequestException"></exception>
			public async Task<ResponseModel> FeedbackInbound(FeedbackInboundRequestModel model)
			{
			string json = JsonConvert.SerializeObject(model);
			string json = JsonConvert.SerializeObject(model, new JsonSerializerSettings
			{
			ContractResolver = new Newtonsoft.Json.Serialization.CamelCasePropertyNamesContractResolver()
			});
			var content = new StringContent(json, Encoding.UTF8, "application/json");
			var _client = _httpClientFactory.CreateClient("MESUrl");
			_client.DefaultRequestHeaders.Clear();
			@@ -45,16 +79,27 @@
			throw new HttpRequestException(body);
			}

			return JsonConvert.DeserializeObject<ResponseModel>(body);
			return JsonConvert.DeserializeObject<ResponseModel>(body);
			}

			public async Task FeedbackOutbound( FeedbackOutboundRequestModel model)
			/// <summary>
			/// åºåºåé¦
			/// </summary>
			/// <param name="model"></param>
			/// <returns></returns>
			/// <exception cref="HttpRequestException"></exception>
			public async Task<ResponseModel> FeedbackOutbound(FeedbackOutboundRequestModel model)
			{
			string json = JsonConvert.SerializeObject(model);
			string json = JsonConvert.SerializeObject(model, new JsonSerializerSettings
			{
			ContractResolver = new Newtonsoft.Json.Serialization.CamelCasePropertyNamesContractResolver()
			});
			var content = new StringContent(json, Encoding.UTF8, "application/json");
			var _client = _httpClientFactory.CreateClient("MESUrl");
			_client.DefaultRequestHeaders.Clear();
			_client.DefaultRequestHeaders.Add("Accept", "application/json");

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

			var response = await _client.PostAsync("AldMaterialOutbound/MaterialOutbound", content);
			string body = await response.Content.ReadAsStringAsync();
			@@ -65,12 +110,41 @@
			throw new HttpRequestException(body);
			}

			// JsonConvert.DeserializeObject<ResponseModel>(body);

			return JsonConvert.DeserializeObject<ResponseModel>(body);
			}

			public async Task<ResponseModel> FeedbackAllocate(AllocateDto model)
			{
			_logger.LogInformation($"InvokeMESService FeedbackAllocate åºååå: {JsonConvert.SerializeObject(model)}");
			string json = JsonConvert.SerializeObject(model, new JsonSerializerSettings
			{
			ContractResolver = new Newtonsoft.Json.Serialization.CamelCasePropertyNamesContractResolver(),
			NullValueHandling = NullValueHandling.Include
			});
			var content = new StringContent(json, Encoding.UTF8, "application/json");
			var _client = _httpClientFactory.CreateClient("MESUrl");
			_client.DefaultRequestHeaders.Clear();
			_client.DefaultRequestHeaders.Add("Accept", "application/json");
			_logger.LogInformation("InvokeMESService FeedbackAllocate : " + json);
			var response = await _client.PostAsync("AldAllocationOperation/AllocationOperation", content);
			string body = await response.Content.ReadAsStringAsync();
			_logger.LogInformation("InvokeMESService FeedbackAllocate body: " + body);
			if (!response.IsSuccessStatusCode)
			{

			throw new HttpRequestException(body);
			}

			return JsonConvert.DeserializeObject<ResponseModel>(body);
			}

			public async Task<ResponseModel> NewMaterielToMes(MaterielToMesDTO model)
			{
			string json = JsonConvert.SerializeObject(model);
			string json = JsonConvert.SerializeObject(model, new JsonSerializerSettings
			{
			ContractResolver = new Newtonsoft.Json.Serialization.CamelCasePropertyNamesContractResolver()
			});


			//string userDataEncoded = Uri.EscapeDataString(json);
			@@ -81,7 +155,7 @@

			var client = _httpClientFactory.CreateClient("MESUrl");
			// æ¼æ¥ URL åæ°
			// string url = $"{client.BaseAddress}UserTicket={userTicket}&API={api}&UserData={userDataEncoded}";
			// string url = $"{client.BaseAddress}UserTicket={userTicket}&API={api}&UserData={userDataEncoded}";


			client.DefaultRequestHeaders.Clear();
			@@ -91,8 +165,11 @@

			var content = new StringContent(json, Encoding.UTF8, "application/json");

			using var response = await client.PostAsync("", content);
			_logger.LogInformation("InvokeMESService NewMaterielToMes : " + json);

			using var response = await client.PostAsync("AldBarcodeInformation/BarcodeInformation", content);
			var responseText = await response.Content.ReadAsStringAsync();
			_logger.LogInformation("InvokeMESService NewMaterielToMes body: " + responseText);
			if (!response.IsSuccessStatusCode)
			{
			throw new HttpRequestException(responseText);
			@@ -141,6 +218,434 @@
			}
			}

			/// <summary>
			///
			/// </summary>
			/// <param name="orderNos"></param>
			/// <param name="inout">å¥åºä¼ 1 åºåºä¼ 2</param>
			/// <returns></returns>
			public async Task<WebResponseContent> BatchOrderFeedbackToMes(List<string> orderNos, int inout)
			{
			if (inout == 1)
			{
			foreach (var orderNo in orderNos)
			{
			try
			{
			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())
			{
			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 inboundOrder = _inboundOrderRepository.Db.Queryable<Dt_InboundOrder>().First(x => x.InboundOrderNo == lists.FirstOrDefault().OrderNo);
			if (inboundOrder != null)
			{
			if (inboundOrder.OrderType == (int)InOrderTypeEnum.AllocatInbound)//è°æ¨å¥åº
			{
			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
			{
			Barcode = row.Barcode,
			Qty = row.BarcodeQty,
			BatchNo = row.BatchNo,
			SupplyCode = row.SupplyCode,
			Unit = row.Unit
			}).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();
			}
			}
			else
			{
			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
			{
			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);
			}

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

			}
			return WebResponseContent.Instance.OK();
			}
			private async Task HandleOutboundOrderBatchToMESCompletion(Dt_OutboundOrder outboundOrder, string orderNo)
			{

			try
			{
			if (outboundOrder.ReturnToMESStatus == 1)
			{
			return;
			}
			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 (detail.OverOutQuantity >= detail.NeedOutQuantity)
			{
			detailids.Add(detail.Id);
			}
			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
			{
			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)
			{
			secallCompleted = false;
			}
			}
			if (secallCompleted)
			{
			await _outboundOrderService.Db.Updateable<Dt_OutboundOrder>()
			.SetColumns(it => new Dt_OutboundOrder
			{
			ReturnToMESStatus = 1,
			OrderStatus = OutOrderStatusEnum.åºåºå®æ.ObjToInt(),
			})
			.Where(x => x.OrderNo == orderNo)
			.ExecuteCommandAsync();
			}
			}
			}
			else
			{
			await _outboundOrderDetailService.Db.Updateable<Dt_OutboundOrderDetail>()
			.SetColumns(it => new Dt_OutboundOrderDetail
			{
			ReturnToMESStatus = 2,
			documentsNO = documentno,
			})
			.Where(x => detailids.Contains(x.Id))
			.ExecuteCommandAsync();
			}

			}
			catch (Exception ex)
			{
			_logger.LogError($"CheckAndUpdateOrderStatuså¤±è´¥ - OrderNo: {orderNo}, Error: {ex.Message}");
			}
			}


			private async Task HandleOutboundOrderToMESCompletion(Dt_OutboundOrder outboundOrder, string orderNo)
			{

			try
			{
			if (outboundOrder.ReturnToMESStatus == 1)
			{
			return;
			}
			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();

			bool allCompleted = true;
			foreach (var detail in orderDetails)
			{
			if (detail.OverOutQuantity < detail.NeedOutQuantity)
			{
			allCompleted = false;
			break;
			}
			}

			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();

			}
			//åªææ£å¸¸åæ£å®ææ¶æåMESåé¦
			if (allCompleted && newStatus == (int)OutOrderStatusEnum.åºåºå®æ)
			{
			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 = outboundOrder.OrderNo,
			status = outboundOrder.OrderStatus,
			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.æ£éå®æ)
			.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
			{
			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(x => x.ReturnToMESStatus == 1)
			.Where(x => x.OrderId == outboundOrder.Id)
			.ExecuteCommandAsync();

			await _outboundOrderService.Db.Updateable<Dt_OutboundOrder>()
			.SetColumns(x => x.ReturnToMESStatus == 1)
			.Where(x => x.OrderNo == orderNo)
			.ExecuteCommandAsync();
			}
			}
			}
			catch (Exception ex)
			{
			_logger.LogError($"CheckAndUpdateOrderStatuså¤±è´¥ - OrderNo: {orderNo}, Error: {ex.Message}");
			}

			}

			}

			public static class UniqueValueGenerator
			{
			// ååè®¡æ°å¨ï¼çº¿ç¨å®å¨ï¼æ¯æ¬¡éå¢1ï¼é¿ååä¸Tickséå¤ï¼
			private static long _counter = 0;

			/// <summary>
			/// çæå¯ä¸å¼ï¼æ¯æé«å¹¶åï¼
			/// </summary>
			/// <returns>æ ¼å¼ï¼yyyyMMdd + Ticks + 3ä½è®¡æ°å¨ï¼å¦2025112563867890123001ï¼</returns>
			public static string Generate()
			{
			var now = DateTime.Now;
			string datePart = now.ToString("yyyyMMdd");
			long ticksPart = now.Ticks;

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

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