WMSPrjInstance/HH-0121_DuShanZiShiHua.git

			@@ -1,6 +1,8 @@
			using System;
			using System.Collections.Generic;
			using System.Linq;
			using System.Net;
			using System.Net.Sockets;
			using System.Text;
			using System.Threading.Tasks;

			@@ -12,6 +14,8 @@
			using HH.WCS.Mobox3.DSZSH.wms;

			using Newtonsoft.Json;

			using Swashbuckle.Swagger;

			using static HH.WCS.Mobox3.DSZSH.api.ApiModel;

			@@ -449,5 +453,204 @@
			LogHelper.Info("暂无任务");
			}
			}

			// TCP 非轮询方式模拟产线下线的尝试

			public static void StartServer() {
			var ListenPort = 6000;
			TcpListener listener = new TcpListener(IPAddress.Any, ListenPort);
			listener.Start();
			Console.WriteLine($"后台服务已启动，监听端口 {ListenPort}...");

			while (true) {
			try {
			// 接受产线连接
			System.Net.Sockets.TcpClient client = listener.AcceptTcpClient();
			Console.WriteLine($"产线客户端已连接: {client.Client.RemoteEndPoint}");

			// 处理客户端请求（使用Task避免阻塞主线程）
			Task.Run(() => HandleClientRequest(client));
			}
			catch (Exception ex) {
			Console.WriteLine($"服务端异常: {ex.Message}");
			}
			}
			}

			public static void HandleClientRequest(System.Net.Sockets.TcpClient client) {
			var db = new SqlHelper<object>().GetInstance();
			using (client)
			using (NetworkStream stream = client.GetStream()) {
			try {
			// 读取产线消息
			byte[] buffer = new byte[1024];
			int bytesRead = stream.Read(buffer, 0, buffer.Length);
			string jsonMessage = Encoding.UTF8.GetString(buffer, 0, bytesRead);

			// 解析消息
			var message = JsonConvert.DeserializeObject<ProductCompletedMessage>(jsonMessage);
			//Console.WriteLine($"收到产品完成通知 - 物料：{message.ItemCode}；批次号：{message.BatchNo}；容器号：{message.CntrCode}");
			LogHelper.Info($"收到产品下线通知："+message);

			string startLocCode = "";

			// A. 如果是单个产线PLC，通过TCP传播，需要传递产线ID，根据ID计算起点货位
			//startLocCode = Settings.ProductionLines[message.Id].OffLoc[0]; // 理论上应该只有1个OffLoc，否则应该注明是哪一个

			// B. 如果是每条产线各一个客户端，更简单，直接根据IP地址确定终点货位
			// TODO 具体逻辑待后续确定时补完

			var success = CreateInboundTask(startLocCode, message.CntrCode).Value;

			// 发送响应
			string response = success ? "ACK: 机器人已调度" : "NAK: 调度失败";
			byte[] responseData = Encoding.UTF8.GetBytes(response);
			stream.Write(responseData, 0, responseData.Length);
			}
			catch (Exception ex) {
			Console.WriteLine($"处理客户端请求异常: {ex.Message}");
			}
			}
			}

			/// <summary>
			/// 入库作业创建只接收起点货位和容器号（物料信息待定、通过产线号计算起点的逻辑放在方法外）
			/// </summary>
			/// <param name="startLocCode"></param>
			/// <param name="cntrCode"></param>
			/// <returns></returns>
			public static Result<bool> CreateInboundTask(string startLocCode, string cntrCode) {
			var db = new SqlHelper<object>().GetInstance();
			var info = "";

			const string taskName = TaskName.T托盘_满托下线入库;
			const string startAreaName = AreaName.B包装区;
			const string endAreaName = AreaName.M满托货架区;
			const string cntrType = "托盘";

			try {
			var startLoc = db.Queryable<TN_Location>()
			.Where(l => l.S_CODE == startLocCode)
			.Where(l => Settings.AreaMap[startAreaName].Contains(l.S_AREA_CODE))
			.Where(l => l.N_LOCK_STATE == 0 && l.S_LOCK_STATE == "无" && l.C_ENABLE == "Y")
			//.Where(l => l.N_CURRENT_NUM == 0) // 绑定前
			.First();

			if (startLoc == null) {
			info = $"在'{startAreaName}'中没有找到起点货位'{startLocCode}'，或不满足要求：未上锁、当前容器数量=0";
			LogHelper.Info(info);
			return new Result<bool>(false, info);
			}

			var locCntrRelOld = db.Queryable<TN_Loc_Container>()
			.Where(c => c.S_CNTR_CODE == cntrCode).First();

			// 绑定货位和容器号
			var locCntrRel = new TN_Loc_Container {
			S_LOC_CODE = startLocCode,
			S_CNTR_CODE = cntrCode,
			S_CNTR_TYPE = cntrType,
			};

			startLoc.N_CURRENT_NUM = 1; // 绑定后

			var endLoc = db.Queryable<TN_Location>()
			.Where(a => Settings.AreaMap[endAreaName].Contains(a.S_AREA_CODE))
			.Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y") // 筛选：未上锁
			.Where(a => a.N_CURRENT_NUM == 0) // 筛选：空货位
			.OrderBy(l => l.N_LAYER)
			.First();

			if (endLoc == null) {
			info = $"在终点货区'{endAreaName}'中，没有找到合适的【终点货位】，需要满足要求：未上锁、当前容器数量=0";
			LogHelper.Info(info);
			return new Result<bool>(false, info);
			}

			var cntId = locCntrRel.S_CNTR_CODE;
			var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName);

			LocationHelper.LockStartLoc(ref startLoc); // 起点出库锁
			LocationHelper.LockEndLoc(ref endLoc); // 终点入库锁

			using (var tran = db.Ado.UseTran()) {
			if (locCntrRelOld != null) {
			if (db.Deleteable<TN_Loc_Container>(locCntrRelOld).ExecuteCommand() <= 0 &&
			db.Updateable<TN_Location>().SetColumns(l => l.N_CURRENT_NUM == 0).Where(l => l.S_CODE == locCntrRelOld.S_LOC_CODE).ExecuteCommand() <= 0) {
			tran.RollbackTran();
			info = $"删除旧货位容器关系表失败：货位编码{locCntrRelOld.S_LOC_CODE}，容器编码{locCntrRelOld.S_CNTR_CODE}";
			LogHelper.Info(info);
			return new Result<bool>(false, info);
			}
			}

			if (db.Insertable<TN_Loc_Container>(locCntrRel).ExecuteCommand() <= 0) {
			tran.RollbackTran();
			info = $"插入货位容器关系表失败：货位编码{locCntrRel.S_LOC_CODE}，容器编码{locCntrRel.S_CNTR_CODE}";
			LogHelper.Info(info);
			return new Result<bool>(false, info);
			}

			if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new {
			it.N_LOCK_STATE,
			it.S_LOCK_STATE,
			it.S_LOCK_OP,
			it.T_MODIFY,
			it.N_CURRENT_NUM, // 起点货位绑定后，将货位状态更新
			}).ExecuteCommand() <= 0) {
			tran.RollbackTran();
			info = $"生成任务'{taskName}'失败：更新起点货位{startLoc.S_CODE}锁状态失败";
			LogHelper.Info(info);
			return new Result<bool>(false, info);
			}

			if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new {
			it.N_LOCK_STATE,
			it.S_LOCK_STATE,
			it.S_LOCK_OP,
			it.T_MODIFY,
			}).ExecuteCommand() <= 0) {
			tran.RollbackTran();
			info = $"生成任务'{taskName}'失败：更新终点货位{endLoc.S_CODE}锁状态失败";
			LogHelper.Info(info);
			return new Result<bool>(false, info);
			}

			if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) {
			tran.RollbackTran();
			info = $"生成任务'{taskName}'失败，任务号={task.S_CODE}，容器号={cntId}，起点={startLoc.S_CODE}，终点={endLoc.S_CODE}";
			LogHelper.Info(info);
			return new Result<bool>(false, info);
			}

			tran.CommitTran();
			info = $"生成任务'{taskName}'成功，任务号={task.S_CODE}，容器号={cntId}，起点={startLoc.S_CODE}，终点={endLoc.S_CODE}";
			LogHelper.Info(info);
			return new Result<bool>(true, info);
			}
			}
			catch (Exception ex) {
			LogHelper.InfoEx(ex);
			return new Result<bool>(false, ex.Message);
			}
			}

			}

			public class ProductCompletedMessage {
			public int Id { get; set; }
			//public string ItemCode { get; set; }
			//public string BatchNo { get; set; }
			public string CntrCode { get; set; }
			}

			public class Result<T> {
			public T Value { get; set; }
			public string Content { get; set; }

			public Result(T value, string content) {
			Value = value;
			Content = content;
			}
			}
			}