From fe77f3c9d11e3087c1efa56fd6205ffc10e39991 Mon Sep 17 00:00:00 2001 From: helongyang <647556386@qq.com> Date: 星期四, 05 六月 2025 18:45:23 +0800 Subject: [PATCH] 更新 --- 代码管理/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/MesTaskService.cs | 248 ++----------------------------------------------- 1 files changed, 13 insertions(+), 235 deletions(-) diff --git "a/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/MesTaskService.cs" "b/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/MesTaskService.cs" index 5039413..0df30d5 100644 --- "a/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/MesTaskService.cs" +++ "b/\344\273\243\347\240\201\347\256\241\347\220\206/WMS/WIDESEA_WMSServer/WIDESEA_TaskInfoService/MesTaskService.cs" @@ -295,46 +295,6 @@ return content; } /// <summary> - /// WMS鍚屾鎴愬搧鍑哄簱鑷矼ES - /// </summary> - /// <param name="model"></param> - /// <returns></returns> - public WebResponseContent ShipmentOrderSync(MesShipmentOrderSync model) - { - WebResponseContent content = new WebResponseContent(); - try - { - Dt_ApiInfo apiInfo = _apiInfoRepository.QueryFirst(x => x.ApiCode == APIEnum.WMS_MES_ShipmentOrderSync.ToString()); - MESRoot<MesShipmentOrderSync> root = new MESRoot<MesShipmentOrderSync>() - { - From = "WMS", - DateTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"), - Content = model - }; - JsonSerializerSettings settings = new JsonSerializerSettings - { - ContractResolver = new CamelCasePropertyNamesContractResolver() - }; - string request = JsonConvert.SerializeObject(root, settings); - string response = HttpMesHelper.Post(apiInfo.ApiAddress, request); - MesResponseContent mesResponseContent = response.DeserializeObject<MesResponseContent>(); - //璋冪敤鎺ュ彛 - if (mesResponseContent.BSucc == true) - { - content.OK(mesResponseContent.StrMsg); - } - else - { - content.Error(mesResponseContent.StrMsg); - } - } - catch (Exception ex) - { - content.Error(ex.Message); - } - return content; - } - /// <summary> /// /// </summary> /// <param name="stockInfo"></param> @@ -442,6 +402,7 @@ tasks.ForEach(x => { x.TargetAddress = model.Line; + x.OrderNo = mesOutboundOrder.TaskNo; }); _unitOfWorkManage.BeginTran(); @@ -497,11 +458,12 @@ Dt_StockInfoDetail stockInfoDetail = new Dt_StockInfoDetail() { + MaterielSpec = stockInfoDetail_Hty.MaterielSpec, BatchNo = stockInfoDetail_Hty?.BatchNo ?? "", EffectiveDate = model.ExpirationDate, MaterielCode = model.MaterialCode, InboundOrderRowNo = stockInfoDetail_Hty?.InboundOrderRowNo ?? 0, - MaterielName = model.MaterialCode, + MaterielName = stockInfoDetail_Hty.MaterielName, ProductionDate = model.ProductionDate, OrderNo = stockInfoDetail_Hty?.OrderNo ?? "", OutboundQuantity = 0, @@ -654,11 +616,14 @@ //} #endregion + _unitOfWorkManage.BeginTran(); Db.InsertNav(mesOutboundOrder).Include(x => x.Details).ExecuteCommand(); + _unitOfWorkManage.CommitTran(); return MesResponseContent.Instance.OK(); } catch (Exception ex) { + _unitOfWorkManage.RollbackTran(); return MesResponseContent.Instance.Error(ex.Message); } @@ -774,6 +739,7 @@ { try { + //涓�娆″彧鍙戜竴鍗风墿鏂欏叆搴撴槑缁� foreach (var item in model.MaterialLotInfo) { //鑾峰彇鐗╂枡淇℃伅 @@ -900,7 +866,9 @@ TaskType = TaskTypeEnum.Inbound.ObjToInt(), TaskStatus = TaskStatusEnum.New.ObjToInt(), WarehouseId = stockInfo.WarehouseId, - PalletType = stockInfo.PalletType + PalletType = stockInfo.PalletType, + MaterielCode = stockInfo.Details.Where(x => x.StockId == stockInfo.Id).FirstOrDefault()?.MaterielCode, + Quantity = (float)stockInfo.Details.Where(x => x.StockId == stockInfo.Id).FirstOrDefault()?.StockQuantity, }; LocationStatusEnum lastStatus = (LocationStatusEnum)locationInfo.LocationStatus; _unitOfWorkManage.BeginTran(); @@ -962,199 +930,8 @@ return MesResponseContent.Instance.Error(ex.Message); } } - /// <summary> - /// MES鎴愬搧鍏ュ簱鍗曟帴鏀� - /// </summary> - /// <returns></returns> - public MesResponseContent BagInfoSync(MesBagInfoModel bagInfoModel) - { - MesResponseContent content = new MesResponseContent(); - try - { - Dt_Warehouse warehouse = _basicRepository.WarehouseRepository.QueryFirst(x => x.WarehouseCode == bagInfoModel.WarehouseCode); - if (warehouse == null) - { - return content.Error("鏈壘鍒颁粨搴撲俊鎭�"); - } - Dt_LocationInfo locationInfo = _basicRepository.LocationInfoRepository.QueryFirst(x => x.WarehouseId == warehouse.WarehouseId); - if (locationInfo==null) - { - return content.Error($"鏈壘鍒皗warehouse.WarehouseCode}璐т綅淇℃伅"); - } - //鍐呭寘淇℃伅缁勭洏 - List<Dt_MesProInOrderDetail> mesProInOrderDetails = new List<Dt_MesProInOrderDetail>(); - foreach (var item in bagInfoModel.BagDetails) - { - foreach (var child in item.BagItems) - { - Dt_MesProInOrderDetail mesProInOrderDetail = new Dt_MesProInOrderDetail() - { - BagNo = item.BagNo, - ProductCode = item.ProductCode, - ProductVersion = item.ProductVersion, - SETQty = child.SETQty, - OKPCSQTY = child.OKPCSQTY, - DateCode = item.DateCode, - XQty = child.XQty, - XSite = child.XSite, - Weight = item.Weight, - PackingDate = item.PackingDate, - LotNumber = child.LotNumber, - ERPOrder = child.ERPOrder, - SaleOrder = child.SaleOrder, - MoNumber = child.MoNumber, - }; - mesProInOrderDetails.Add(mesProInOrderDetail); - } - } - List<Dt_ProStockInfoDetail> proStockInfoDetails = new List<Dt_ProStockInfoDetail>(); - foreach (var item in mesProInOrderDetails) - { - proStockInfoDetails.Add(_mapper.Map<Dt_ProStockInfoDetail>(item)); - } - Dt_MesProInOrder mesProInOrder = new Dt_MesProInOrder() - { - WarehouseId = warehouse.WarehouseId, - BatchNo = bagInfoModel.BatchNo, - WorkCenter = bagInfoModel.WorkCenter, - MesProStatus = InOrderStatusEnum.鏈紑濮�.ObjToInt(), - UnPackStock = bagInfoModel.UnPackStock, - Details = mesProInOrderDetails - }; - Dt_ProStockInfo proStockInfo = new Dt_ProStockInfo() - { - PalletCode = bagInfoModel.BatchNo, - PalletType = 1, - WarehouseId = warehouse.WarehouseId, - StockStatus = StockStatusEmun.鍏ュ簱纭.ObjToInt(), - proStockInfoDetails = proStockInfoDetails - }; - //鍒嗛厤璐т綅 - locationInfo = _basicService.LocationInfoService.AssignLocation(locationInfo.RoadwayNo, ((PalletTypeEnum)proStockInfo.PalletType).ObjToInt(), proStockInfo.WarehouseId); - Dt_Task newTask = new Dt_Task() - { - CurrentAddress = bagInfoModel.WorkCenter, - Grade = 0, - NextAddress = locationInfo.LocationCode, - PalletCode = proStockInfo.PalletCode, - Roadway = locationInfo.RoadwayNo, - SourceAddress = bagInfoModel.WorkCenter, - TargetAddress = locationInfo.LocationCode, - TaskType = TaskTypeEnum.InProduct.ObjToInt(), - TaskStatus = TaskStatusEnum.New.ObjToInt(), - WarehouseId = warehouse.WarehouseId, - PalletType = proStockInfo.PalletType - }; - locationInfo.LocationStatus = LocationStatusEnum.Lock.ObjToInt(); - - _unitOfWorkManage.BeginTran(); - int taskId = BaseDal.AddData(newTask); - newTask.TaskId = taskId; - _basicRepository.LocationInfoRepository.UpdateData(locationInfo); - Db.InsertNav(mesProInOrder).Include(x => x.Details).ExecuteCommand(); - Db.InsertNav(proStockInfo).Include(x => x.proStockInfoDetails).ExecuteCommand(); - _unitOfWorkManage.CommitTran(); - //鎺ㄩ�佷换鍔� - PushTasksToWCS(new List<Dt_Task> { newTask }); - return content.OK("鎺ユ敹鎴愬姛"); - } - catch (Exception ex) - { - _unitOfWorkManage.RollbackTran(); - content.Error(ex.Message); - } - return content; - } - public MesResponseContent BoxStockin(MesBoxInfoModel boxInfoModel) - { - MesResponseContent content = new MesResponseContent(); - try - { - Dt_Warehouse warehouse = _basicRepository.WarehouseRepository.QueryFirst(x => x.WarehouseCode == WarehouseEnum.HA101.ToString()); - //鑾峰彇MES鍐呭寘淇℃伅 - List<Dt_MesProInOrderDetail> mesProInOrderDetails = new List<Dt_MesProInOrderDetail>(); - foreach (var item in boxInfoModel.Bags) - { - foreach (var child in item.BagItems) - { - Dt_MesProInOrderDetail mesProInOrderDetail = new Dt_MesProInOrderDetail() - { - BagNo = item.BagNo, - ProductCode = item.ProductCode, - ProductVersion = item.ProductVersion, - SETQty = child.SETQty, - OKPCSQTY = child.OKPCSQTY, - DateCode = item.DateCode, - XQty = child.XQty, - XSite = child.XSite, - Weight = item.Weight, - PackingDate = item.PackingDate, - LotNumber = child.LotNumber, - ERPOrder = child.ERPOrder, - SaleOrder = child.SaleOrder, - MoNumber = child.MoNumber, - }; - mesProInOrderDetails.Add(mesProInOrderDetail); - } - } - List<Dt_ProStockInfoDetail> proStockInfoDetails = new List<Dt_ProStockInfoDetail>(); - foreach (var item in mesProInOrderDetails) - { - proStockInfoDetails.Add(_mapper.Map<Dt_ProStockInfoDetail>(item)); - } - Dt_ProStockInfo proStockInfo = new Dt_ProStockInfo() - { - PalletCode = boxInfoModel.BoxNo, - PalletType = 0, - WarehouseId = warehouse.WarehouseId, - ShipmentOrder = boxInfoModel.ShipmentOrder, - StockStatus = StockStatusEmun.鍏ュ簱瀹屾垚.ObjToInt(), - proStockInfoDetails = proStockInfoDetails - }; - _unitOfWorkManage.BeginTran(); - Db.InsertNav(proStockInfo).Include(x => x.proStockInfoDetails).ExecuteCommand(); - _unitOfWorkManage.CommitTran(); - return content.OK("澶栧寘鎺ユ敹鎴愬姛"); - } - catch (Exception ex) - { - content.Error(ex.Message); - } - return content; - } - /// <summary> - /// 鎴愬搧杩斿伐鎻愬簱 - /// </summary> - /// <param name="model"></param> - /// <returns></returns> - public MesResponseContent RworkTask(RworkTaskModel model) - { - try - { - Dt_Warehouse warehouse = _basicRepository.WarehouseRepository.QueryFirst(x => x.WarehouseCode == WarehouseEnum.HA72.ToString()); - //鑾峰彇搴撳瓨璁板綍 - List<Dt_StockInfo> stockInfos = _stockRepository.StockInfoRepository.Db.Queryable<Dt_StockInfo>().Where(x => - x.WarehouseId == warehouse.WarehouseId && - x.StockStatus == (int)StockStatusEmun.鍏ュ簱瀹屾垚).Includes(x => x.Details).ToList(); - Dt_StockInfo? stockInfo = stockInfos.FirstOrDefault(x => x.Details.Any(x => x.BatchNo == model.ProductVersion)); - if (stockInfo == null) - { - return MesResponseContent.Instance.Error($"灏炬暟浠�:{model.ProductVersion}鏃犲彲鐢ㄥ簱瀛�"); - } - Dt_Task exsit2 = Repository.QueryFirst(x => x.PalletCode == stockInfo.PalletCode); - - - } - catch (Exception ex) - { - - throw; - } - return MesResponseContent.Instance.OK(); - } - - - + + /// <summary> /// 鐢熸垚PP澶у嵎鍑哄簱浠诲姟 @@ -1647,5 +1424,6 @@ return WebResponseContent.Instance.Error(ex.Message); } } + } } -- Gitblit v1.9.3