~hyx/PadAppServer.git

			@@ -92,131 +92,182 @@

			/// <summary>
			/// 更新机器时间并处理首检
			/// 变更说明：
			/// 1) 最新首检结果为“不合格”时：清空 MA_SHOUT_TIME（送检呼叫时间）
			/// 2) 若不存在首检单时或者首检单结果为“不合格”时：创建首检单
			/// 3) 首检合格且送检时间 >= 调机开始时间时：写入调机完成时间与开工时间
			/// </summary>
			/// <param name="entity">工单状态实体,包含机器时间信息</param>
			/// <returns>更新是否成功</returns>
			public bool ChangeMachineTime(MesOrderSta entity)
			{
			// 查询工单主表信息
			const string FirstCheckType = "首检";
			const string FirstCheckResultOK = "合格";
			const string FirstCheckResultNG = "不合格";

			var womdaa = Db.Queryable<Womdaa>()
			.Where(s => s.Id == entity.OrderId).First();
			if (womdaa == null) throw new Exception("工单不存在");

			// 如果标记为1,需要处理首检相关逻辑
			if (entity.Flag == 1)
			// 读取当前状态行
			var currentSta = Db.Queryable<MesOrderSta>()
			.Where(s => s.Id == entity.Id).First();

			// 行级锁：串行化首检重建
			Db.Ado.ExecuteCommand("SELECT ID FROM WOMDAA WHERE DAA001 = :BILL_NO FOR UPDATE",
			new SugarParameter("BILL_NO", womdaa.Daa001));

			// 最新首检
			var latestFirst = Db.Queryable<MesQaItemsDetect02>()
			.Where(s => s.Aufnr == womdaa.Daa001 && s.Ftype == FirstCheckType && (s.Fcancel == null \|\| s.Fcancel != "Y"))
			.OrderBy(s => s.CreateDate, OrderByType.Desc)
			.First();

			var latestResult = latestFirst?.FcheckResu?.Trim();
			var needRebuild = latestFirst == null \|\| string.Equals(latestResult, FirstCheckResultNG, StringComparison.OrdinalIgnoreCase);
			var clearMaShout = false;

			if (needRebuild)
			{
			//调用存储过程执行自动首检
			Db.Ado.ExecuteCommand(
			"BEGIN AUTOMATIC_IPQC_FIRST_CHECK(:BILL_NO); END;",
			new SugarParameter("BILL_NO", womdaa.Daa001, System.Data.DbType.String));
			var automaticIpqcFirstCheck =
			mesQaItemsDetect02Manager
			.AutomaticIpqcFirstCheck(womdaa.Daa001);
			if (!automaticIpqcFirstCheck)
			// 若已有首检且结果不合格 => 先清空送检时间
			if (latestFirst != null && string.Equals(latestResult, FirstCheckResultNG, StringComparison.OrdinalIgnoreCase))
			{
			Console.WriteLine($"自动首检失败，工单号：{womdaa.Daa001}");
			throw new Exception("首检生成失败");
			clearMaShout = true;
			entity.MaShoutTime = null;
			entity.remark = $"最新首检结果“{FirstCheckResultNG}”，已清空送检时间并重建首检单";
			}

			// 获取当前时间
			var s1 = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
			// 生成首检备注信息
			var remeke = "工控机于" + s1 + "自动创建的首检单";
			// 调用存储过程重建 / 首次创建
			Db.Ado.ExecuteCommand(
			"BEGIN AUTOMATIC_IPQC_FIRST_CHECK(:BILL_NO); END;",
			new SugarParameter("BILL_NO", womdaa.Daa001, System.Data.DbType.String));

			// 更新首检单备注信息
			Db.Updateable<MesQaItemsDetect02>()
			.SetColumns(s => s.Remeke == remeke)
			.Where(s => s.Ftype == "首检" && s.Aufnr == womdaa.Daa001)
			.ExecuteCommand();
			// 重取最新首检
			latestFirst = Db.Queryable<MesQaItemsDetect02>()
			.Where(s => s.Aufnr == womdaa.Daa001 && s.Ftype == FirstCheckType && (s.Fcancel == null \|\| s.Fcancel != "Y"))
			.OrderBy(s => s.CreateDate, OrderByType.Desc)
			.First();

			if (latestFirst != null)
			{
			var ts = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
			var remarkTag = latestResult == null ? "首次创建" : (latestResult == FirstCheckResultNG ? "不合格重建" : "重建");
			Db.Updateable<MesQaItemsDetect02>()
			.SetColumns(s => s.Remeke == $"工控机于{ts}自动创建的首检单({remarkTag})")
			.Where(s => s.Id == latestFirst.Id)
			.ExecuteCommand();
			}
			}
			else
			{
			// 不需要重建：如果前端主动清空(传空且原值有内容)也允许清空
			var requestWantClear = string.IsNullOrEmpty(entity.MaShoutTime) && !string.IsNullOrEmpty(currentSta?.MaShoutTime);
			if (requestWantClear)
			{
			clearMaShout = true;
			entity.MaShoutTime = null;
			entity.remark = "前端请求手动清空送检时间";
			}
			else
			{
			// 正常备注（保持最新结果说明）
			if (latestFirst != null)
			{
			var ts = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
			Db.Updateable<MesQaItemsDetect02>()
			.SetColumns(s => s.Remeke == $"工控机于{ts}首检结果：{latestFirst.FcheckResu}")
			.Where(s => s.Id == latestFirst.Id)
			.ExecuteCommand();
			}
			}
			}

			// 后续报工锚点逻辑保持
			var mesReporting = Db.Queryable<MesReporting>()
			.Where(s => s.BillNo == womdaa.Daa001)
			.OrderByDescending(s => s.Id)
			.First();


			var editDate = DateTime.Now.ToString("yyyy-MM-dd");

			// 发送HTTP请求到数据刷新接口
			MesNumerical mesNumerical = null;
			MesNumericalBycl mesNumerical = null;
			try
			{
			using (var httpClient = new HttpClient())
			using var httpClient = new HttpClient { Timeout = TimeSpan.FromSeconds(30) };
			var content = new StringContent(
			JsonConvert.SerializeObject(new { machineNo = entity.MachineNo }),
			Encoding.UTF8, "application/json");

			var response = httpClient.PostAsync("http://192.168.0.94:9095/Numerical/RefreshDevBycl", content)
			.GetAwaiter().GetResult();

			if (response.IsSuccessStatusCode)
			{
			httpClient.Timeout = TimeSpan.FromSeconds(30);

			var content = new StringContent(
			JsonConvert.SerializeObject(new
			{ machineNo = entity.MachineNo }),
			Encoding.UTF8,
			"application/json");

			var response = httpClient
			.PostAsync("http://192.168.0.94:9095/Numerical/RefreshDev",
			content).GetAwaiter().GetResult();

			if (response.IsSuccessStatusCode)
			var responseString = response.Content.ReadAsStringAsync().GetAwaiter().GetResult();
			var responseObj = JsonConvert.DeserializeObject<dynamic>(responseString);
			if (responseObj != null && responseObj.code == 200)
			{
			var responseString = response.Content.ReadAsStringAsync()
			.GetAwaiter().GetResult();
			var responseObj =
			JsonConvert.DeserializeObject<dynamic>(responseString);

			if (responseObj != null && responseObj.code == 200)
			{
			// 请求成功，获取MesNumerical数据
			mesNumerical = Db.Queryable<MesNumerical>()
			.Where(s => s.EditDate == editDate
			&& s.MachineNo == entity.MachineNo)
			.OrderByDescending(s => s.Id)
			.First();
			}
			mesNumerical = Db.Queryable<MesNumericalBycl>()
			.Where(s => s.EditDate == editDate && s.MachineNo == entity.MachineNo)
			.OrderByDescending(s => s.Id)
			.First();
			}
			}
			}
			catch (Exception ex)
			{
			// 记录异常但不阻止流程
			Console.WriteLine($"发送数据刷新请求时出错: {ex.Message}");
			}

			// 如果请求失败或获取数据失败，mesNumerical将保持为null

			Db.Deleteable<MesAnchors>()
			.Where(a => a.EditDate == editDate
			&& a.OrderId == womdaa.Id)
			.Where(a => a.EditDate == editDate && a.OrderId == womdaa.Id)
			.ExecuteCommand();

			MesAnchors eAnchors = new MesAnchors
			var eAnchors = new MesAnchors
			{
			OrderId = womdaa.Id,
			OrderNo = womdaa.Daa001,
			EditDate = editDate,
			Qty = mesReporting == null ? 0 : Int64.Parse(mesReporting.DyQty),
			Qty = mesReporting == null ? 0 : (long?)(mesReporting.DyQty ?? 0),
			InitialValue = mesNumerical == null ? 0 : mesNumerical.CjNum
			};
			Db.Insertable<MesAnchors>(eAnchors)
			.ExecuteCommand();
			Db.Insertable<MesAnchors>(eAnchors).ExecuteCommand();

			// 合格 & 调机逻辑
			if (!clearMaShout && !string.IsNullOrEmpty(entity.MaShoutTime))
			{
			if (DateTime.TryParse(entity.MaShoutTime, out var sjTime) &&
			DateTime.TryParse(entity.MaStartTime, out var startTime) &&
			sjTime >= startTime)
			{
			var sjRecord = latestFirst ??
			Db.Queryable<MesQaItemsDetect02>()
			.Where(x => x.Aufnr == womdaa.Daa001 && x.Ftype == FirstCheckType && (x.Fcancel == null \|\| x.Fcancel != "Y"))
			.OrderBy(x => x.CreateDate, OrderByType.Desc)
			.First();

			// 更新工单状态表
			return Db.Updateable<MesOrderSta>()
			// 如果有送检时间则更新
			.SetColumnsIF(entity.MaShoutTime != null,
			s => s.MaShoutTime == entity.MaShoutTime)
			// 如果有调机开始时间则更新
			.SetColumnsIF(entity.MaStartTime != null,
			s => s.MaStartTime == entity.MaStartTime)
			// 如果有调机完成时间则更新
			.SetColumnsIF(entity.MaEndTime != null,
			s => s.MaEndTime == entity.MaEndTime)
			// 如果标记为1则更新备注信息
			.SetColumnsIF(entity.Flag == 1,
			s => s.remark == "于" + entity.MaShoutTime + "时间有一次送检")
			// 根据ID匹配记录
			.Where(s => s.Id == entity.Id)
			// 执行更新并判断影响行数是否大于0
			.ExecuteCommand() > 0;
			if (sjRecord != null && string.Equals(sjRecord.FcheckResu?.Trim(), FirstCheckResultOK, StringComparison.OrdinalIgnoreCase))
			{
			QualifiedInspection(new OrderMachineDto
			{
			OrderId = entity.OrderId,
			orderNo = entity.OrderNo,
			machineNo = entity.MachineNo
			});
			entity.StartTime = entity.MaShoutTime;
			entity.MaEndTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
			}
			}
			}

			// 最终更新（优先清空）
			var upd = Db.Updateable<MesOrderSta>()
			.SetColumnsIF(clearMaShout, s => s.MaShoutTime == null)
			.SetColumnsIF(!clearMaShout && entity.MaShoutTime != null, s => s.MaShoutTime == entity.MaShoutTime)
			.SetColumnsIF(entity.MaStartTime != null, s => s.MaStartTime == entity.MaStartTime)
			.SetColumnsIF(entity.MaEndTime != null, s => s.MaEndTime == entity.MaEndTime)
			.SetColumnsIF(entity.StartTime != null, s => s.StartTime == entity.StartTime)
			.SetColumnsIF(entity.Flag == 1 && entity.remark != null, s => s.remark == entity.remark)
			.Where(s => s.Id == entity.Id);

			return upd.ExecuteCommand() > 0;
			}

			/// <summary>
			@@ -455,7 +506,7 @@
			// var reportingOkQty =
			// Convert.ToDecimal(vOrder.todayOutput) -
			// reporting.OkQty;
			var CjQty = Db.Queryable<MesNumerical>()
			var CjQty = Db.Queryable<MesNumericalBycl>()
			.Where(s => s.MachineNo == entity.MachineNo && s.EditDate == date)
			.OrderByDescending(s=>s.CjTiem)
			.Select<long?>(s=>s.CjNum).First();
			@@ -473,12 +524,12 @@
			MachineNo = womdaa.MachineNo,
			// BfQty = reportingOkQty,
			BfQty = 0,
			BlQty = reportingOkQty.ToString(),
			BlQty = reportingOkQty,
			OkQty = 0,
			ItemNo = womdaa.Daa002,
			BillNo = womdaa.Daa001,
			CjQty = CjQty.ToString(),
			DyQty = reporting.OkQty.ToString()
			CjQty = CjQty,
			DyQty = reporting.OkQty
			};

			// 插入报工记录