HuaYiZhongHeng/BaiBuLiKu.git

			@@ -1,8 +1,12 @@
			using log4net.Core;

			using log4net.Core;
			using Mapster;
			using Masuit.Tools;
			using Masuit.Tools.Models;
			using OfficeOpenXml.FormulaParsing.Excel.Functions.Math;
			using SixLabors.Fonts.Tables.AdvancedTypographic;
			using System.Diagnostics;
			using WIDESEA_Core.Const;
			using WIDESEA_DTO;
			using WIDESEA_DTO.MOM;
			using WIDESEA_DTO.WMS;
			@@ -14,7 +18,7 @@
			using WIDESEA_StoragIntegrationServices;
			using WIDESEAWCS_Model.Models;

			namespace WIDESEA_StorageOutTaskServices;
			namespace WIDESEA_StorageTaskServices;

			public partial class Dt_TaskService : ServiceBase<Dt_Task, IDt_TaskRepository>, IDt_TaskService
			{
			@@ -386,7 +390,7 @@
			}
			}

			// 创建一个TrayCellsStatusDto对象，并赋值
			//创建一个TrayCellsStatusDto对象，并赋值
			//TrayCellsStatusDto trayCells = new TrayCellsStatusDto()
			//{
			// Software = "WMS",
			@@ -395,13 +399,13 @@
			// EquipmentCode = input.EquiCodeMOM
			//};

			//// 调用GetTrayCellStatusAsync方法，获取整盘电芯
			// 调用GetTrayCellStatusAsync方法，获取整盘电芯
			//content = await GetTrayCellStatusAsync(trayCells);
			//// 如果状态为false，则返回content
			// 如果状态为false，则返回content
			//if (!content.Status) return content;

			//// 添加组盘信息
			//// 将content.Data转换为ResultTrayCellsStatus对象
			// 添加组盘信息
			// 将content.Data转换为ResultTrayCellsStatus对象
			//var result = JsonConvert.DeserializeObject<ResultTrayCellsStatus>(content.Data.ToString());
			//if (result.SerialNos.Count <= 0)
			// return content.Error(result.MOMMessage);
			@@ -413,8 +417,7 @@
			//// return content.Error("料框属性不存在");

			//// 调用CreateBoxingInfo方法，创建组盘信息

			//var boxing = await CreateBoxingInfo(result, input.PalletCode);
			//var boxing = CreateBoxingInfo(result, input.PalletCode);
			//if (boxing == null) return content.Error("组盘失败");

			//// 调用GetProcessApplyAsync方法，获取工艺路线
			@@ -634,6 +637,7 @@

			////// 调用GetProcessResponseAsync方法，获取工艺响应
			////var processResponse = await GetProcessResponseAsync(process, input.Position);
			var isBox = await _boxingInfoRepository.AddDataNavAsync(boxing);
			}

			var task = new Dt_Task
			@@ -741,7 +745,7 @@
			MaterialNo = "",
			NextAddress = input.Roadways,
			OrderNo = null,
			PalletCode = input.PalletCode,
			PalletCode = stockinfo.PalletCode,
			SourceAddress = stockinfo.LocationCode,
			TaskState = (int)TaskOutStatusEnum.OutNew,
			TaskType = (int)TaskOutboundTypeEnum.OutTray,
			@@ -757,7 +761,6 @@
			throw new Exception(ex.Message);
			}
			}


			#region 直接出库任务完成
			public async Task<WebResponseContent> CompleteInToOutTaskAsync(Dt_Task task)
			@@ -780,4 +783,130 @@
			}
			#endregion


			#region MyRegion
			//private async Task<bool> ExecuteTransaction(DtStockInfo stock, Dt_Task_Hty taskHty, DtLocationInfo locationInfo, int taskId)
			//{
			// _unitOfWorkManage.BeginTran();
			// try
			// {
			// var isUpdateStock = true;

			// // 添加历史任务
			// var isTaskHtyAdd = await _task_HtyRepository.AddDataAsync(taskHty) > 0;

			// // 修改移库前货位状态
			// var isUpdateLoc = _locationRepository.UpdateData(locationInfo);

			// // 删除任务数据
			// var isTaskDelete = await Delete(taskId);

			// // 提交或回滚事务
			// if (isUpdateStock && isTaskHtyAdd && isTaskDelete && isUpdateLoc)
			// {
			// LogFactory.GetLog("任务完成").InfoFormat(true, "任务完成", $"事务处理完成,提交事务。添加历史任务：{isTaskHtyAdd},删除任务数据：{isTaskDelete},更新或添加库存：{isUpdateStock},修改移库前货位状态：{isUpdateLoc}");
			// _unitOfWorkManage.CommitTran();
			// return true;
			// }
			// else
			// {
			// LogFactory.GetLog("任务完成").InfoFormat(true, "任务完成", $"数据处理失败,请检查数据是否正确,数据回滚。添加历史任务：{isTaskHtyAdd},删除任务数据：{isTaskDelete},更新库存：{isUpdateStock},修改移库前货位状态：{isUpdateLoc}");
			// _unitOfWorkManage.RollbackTran();
			// return false;
			// }
			// }
			// catch (Exception err)
			// {
			// LogFactory.GetLog("任务完成").InfoFormat(true, $"任务完成,系统异常，异常信息：{err.Message}", "无参数");
			// _unitOfWorkManage.RollbackTran();
			// throw; // 抛出异常以便外部捕获
			// }
			//}
			#endregion

			#region 检测高温库是否有可出库库存

			public WebResponseContent StockCheckingAsync()
			{

			WebResponseContent webResponseContent = new WebResponseContent();
			try
			{
			Task.Run(async () =>
			{
			while (true)
			{
			try
			{
			Thread.Sleep(10000);
			var area = await _areaInfoRepository.QueryFirstAsync(x => x.AreaCode == "GWSC1");

			var stockInfo = await _stockInfoRepository.Db.Queryable<DtStockInfo>()
			.Includes(x => x.LocationInfo) // 预加载LocationInfo
			.Includes(x => x.StockInfoDetails) // 预加载StockInfoDetails
			.Where(x => x.AreaCode == area.AreaCode && x.OutboundTime < DateTime.Now && x.IsFull == true) // 过滤条件
			.Where(x => x.LocationInfo.LocationStatus == (int)LocationEnum.InStock && x.LocationInfo.AreaId == area.AreaID) // 过滤条件
			.OrderBy(x => x.OutboundTime) // 排序
			.ToListAsync(); // 获取第一个元素

			if (stockInfo.Count <= 0) continue;
			foreach (var item in stockInfo)
			{

			var hasTask = BaseDal.QueryFirst(x => x.PalletCode == item.PalletCode);
			if (hasTask != null)
			{
			Console.WriteLine("已存在出库任务");
			continue;
			}

			string position = string.Empty;
			if (item.LocationInfo.RoadwayNo == "GWSC1")
			position = "1059";
			else
			position = "1065";

			var task = CreateTask(item, position, (int)TaskOutboundTypeEnum.Outbound);
			task.NextAddress = "002-000-002";
			// 创建任务DTO
			WMSTaskDTO taskDTO = CreateTaskDTO(task);


			var configs = _configService.GetConfigsByCategory(CateGoryConst.CONFIG_SYS_IPAddress);
			var wmsBase = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.WCSIPAddress)?.ConfigValue;
			var ipAddress = configs.FirstOrDefault(x => x.ConfigKey == SysConfigConst.ReceiveTask)?.ConfigValue;
			if (wmsBase == null \|\| ipAddress == null)
			{
			throw new InvalidOperationException("WMS IP 未配置");
			}
			var wmsIpAddress = wmsBase + ipAddress;

			var result = HttpHelper.PostAsync(wmsIpAddress, taskDTO.ToJsonString()).Result;
			var content = JsonConvert.DeserializeObject<WebResponseContent>(result);
			if (content.Status)
			{
			await BaseDal.AddDataAsync(task);
			// 更新库存位置状态为不可用
			item.LocationInfo.LocationStatus = (int)LocationEnum.InStockDisable;
			await _locationRepository.UpdateDataAsync(item.LocationInfo);
			}
			}
			}
			catch (Exception ex)
			{
			Console.WriteLine(ex.Message);
			}
			}
			});
			return webResponseContent.OK();
			}
			catch (Exception ex)
			{
			Console.WriteLine(ex.Message.ToString());
			return webResponseContent.Error(ex.Message);
			}
			}

			#endregion

			}