CC/iWareCC_ASRS/ThreadService/01_BZ01¹¤Î»£¨Çå»Ò£¬Ï´°åºó¹¤Î»£©/DataProcess_BZ01.cs
@@ -168,7 +168,8 @@ private static bool IsAllloRunOutTaskMode(WmsDBModel wmsDB, mes_batchOrderUPI_new curUpiObj) { //é¦å æ¥è¯¢æ°æ®åºä¸æ¯å¦æ è¦åºåºçæ°æ® var isExistOutTaskForNewCreated = wmsDB.wms_rbline_task.Where(x => x.RbTaskType == (int)RbTaskTypeEnum.åºåºä»»å¡ var isExistOutTaskForNewCreated = wmsDB.wms_rbline_task.Where(x => (x.RbTaskType == (int)RbTaskTypeEnum.é½å åºåºä»»å¡ || x.RbTaskType == (int)RbTaskTypeEnum.强å¶åºåºä»»å¡) && x.TaskStatus == (int)TaskStatusEnum.æ°å»º ).Count(); if (isExistOutTaskForNewCreated == 0) CC/iWareCC_ASRS/ThreadService/02_BZ39¹¤Î»£¨²¹°åºó¹¤Î»£©/Outbound/1¡¢DataProcess_RobotBuffer_AutoQiTaoOutbound.cs
@@ -71,8 +71,8 @@ OrderId = x.OrderId, PackageCode = x.PackageCode, PlaceCode = x.PlaceCode, RbTaskType = (int)RbTaskTypeEnum.åºåºä»»å¡, RbTaskTypeEnumName = RbTaskTypeEnum.åºåºä»»å¡.ToString(), RbTaskType = (int)RbTaskTypeEnum.é½å åºåºä»»å¡, RbTaskTypeEnumName = RbTaskTypeEnum.é½å åºåºä»»å¡.ToString(), TaskStatus = (int)TaskStatusEnum.æ°å»º, TaskStatusName = TaskStatusEnum.æ°å»º.ToString(), TaskMsg = "åºåºä»»å¡", CC/iWareCC_ASRS/ThreadService/02_BZ39¹¤Î»£¨²¹°åºó¹¤Î»£©/Outbound/2¡¢DataProcess_RobotBuffer_IssueOutboundTask.cs
@@ -57,7 +57,7 @@ if (string.IsNullOrEmpty(FormCC.currHandlerPackageCodeForIssueOutboundTask)) { var firstTask = wmsDB.wms_rbline_task.Where(x => x.RbTaskType == (int)RbTaskTypeEnum.åºåºä»»å¡ (x.RbTaskType == (int)RbTaskTypeEnum.é½å åºåºä»»å¡ || x.RbTaskType == (int)RbTaskTypeEnum.强å¶åºåºä»»å¡) && x.TaskStatus == (int)TaskStatusEnum.æ°å»º).OrderBy(x => x.CreateTime).FirstOrDefault(); if (firstTask == null) { @@ -70,7 +70,7 @@ else { var firstTask = wmsDB.wms_rbline_task.Where(x => x.RbTaskType == (int)RbTaskTypeEnum.åºåºä»»å¡ (x.RbTaskType == (int)RbTaskTypeEnum.é½å åºåºä»»å¡ || x.RbTaskType == (int)RbTaskTypeEnum.强å¶åºåºä»»å¡) && x.TaskStatus == (int)TaskStatusEnum.æ°å»º && x.PackageCode == FormCC.currHandlerPackageCodeForIssueOutboundTask ).OrderBy(x => x.CreateTime).FirstOrDefault(); @@ -83,7 +83,7 @@ } var taskList = wmsDB.wms_rbline_task.Where(x => x.RbTaskType == (int)RbTaskTypeEnum.åºåºä»»å¡ (x.RbTaskType == (int)RbTaskTypeEnum.é½å åºåºä»»å¡ || x.RbTaskType == (int)RbTaskTypeEnum.强å¶åºåºä»»å¡) && x.TaskStatus == (int)TaskStatusEnum.æ°å»º).Where(x => x.PackageCode == FormCC.currHandlerPackageCodeForIssueOutboundTask).OrderBy(x => x.CreateTime).ToList(); if (taskList == null) { CC/iWareCC_ASRS/ThreadService/02_BZ39¹¤Î»£¨²¹°åºó¹¤Î»£©/Outbound/3¡¢DataProcess_RobotBuffer_FinishTaskForOutbound.cs
@@ -52,7 +52,7 @@ { var task = wmsDB.wms_rbline_task.Where(x => x.TaskNo == obj.R_Outbound_TaskID.ToString() && x.RbTaskType == (int)RbTaskTypeEnum.åºåºä»»å¡ && (x.RbTaskType == (int)RbTaskTypeEnum.é½å åºåºä»»å¡ || x.RbTaskType == (int)RbTaskTypeEnum.强å¶åºåºä»»å¡) ).OrderByDescending(x => x.Id).FirstOrDefault(); if (task == null) { @@ -79,6 +79,18 @@ SystemWarningMsg._lbl_Alert_DataProcess_RobotBuffer_FinishTaskForOutbound = $"{rgvLocation.ToString()},æ ¹æ®UPI:{upiCode}æ²¡ææ¾å°å¯¹è±¡ "; continue; } //æ´æ°æ¿ä»¶çç¶æååºå if (task.RbTaskType == (int)RbTaskTypeEnum.é½å åºåºä»»å¡) { upiObj.UpiStatus = (int)UpiStatusEnum.å·²é½å ; upiObj.AreaCode = (int)AreaCodeEnum.ç ååºå; } else if (task.RbTaskType == (int)RbTaskTypeEnum.强å¶åºåºä»»å¡) { upiObj.UpiStatus = (int)UpiStatusEnum.å·²ä¸çº¿; upiObj.AreaCode = (int)AreaCodeEnum.ä¸çº¿åºå; } //åºååå° wms_stock_quan qun = wmsDB.wms_stock_quan.Where(x => x.PlaceCode == task.PlaceCode).FirstOrDefault(); wmsDB.wms_stock_quan.Remove(qun); CC/iWareCC_ASRS/ThreadService/02_BZ39¹¤Î»£¨²¹°åºó¹¤Î»£©/Outbound/4¡¢DataProcess_RobotBuffer_ForceOutbound.cs
@@ -60,8 +60,8 @@ OrderId = x.OrderId, PackageCode = x.PackageCode, PlaceCode = x.PlaceCode, RbTaskType = (int)RbTaskTypeEnum.åºåºä»»å¡, RbTaskTypeEnumName = RbTaskTypeEnum.åºåºä»»å¡.ToString(), RbTaskType = (int)RbTaskTypeEnum.强å¶åºåºä»»å¡, RbTaskTypeEnumName = RbTaskTypeEnum.强å¶åºåºä»»å¡.ToString(), TaskStatus = (int)TaskStatusEnum.æ°å»º, TaskStatusName = TaskStatusEnum.æ°å»º.ToString(), TaskMsg = "人工强å¶å¾ åºåº", CC/iWareModel/EnumType/WMS/RbTaskTypeEnum.cs
@@ -18,22 +18,28 @@ å ¥åºä»»å¡ = 1, /// <summary> /// åºåºä»»å¡ /// é½å åºåºä»»å¡ /// </summary> [Description("åºåºä»»å¡")] åºåºä»»å¡ = 2, [Description("é½å åºåºä»»å¡")] é½å åºåºä»»å¡ = 2, /// <summary> /// 强å¶åºåºä»»å¡ /// </summary> [Description("强å¶åºåºä»»å¡")] 强å¶åºåºä»»å¡ = 3, /// <summary> /// ç æ¿ä»»å¡ /// </summary> [Description("ç æ¿ä»»å¡")] ç æ¿ä»»å¡ = 3, ç æ¿ä»»å¡ = 4, /// <summary> /// åå ä»»å¡ /// </summary> [Description("åå ä»»å¡")] åå ä»»å¡ = 4 åå ä»»å¡ = 5 } } CC/iWareSql/DataAccess/TaskHandler.cs
@@ -43,7 +43,7 @@ && ( x.RbTaskType == (int)RbTaskTypeEnum.å ¥åºä»»å¡ || x.RbTaskType == (int)RbTaskTypeEnum.åºåºä»»å¡ (x.RbTaskType == (int)RbTaskTypeEnum.é½å åºåºä»»å¡ || x.RbTaskType == (int)RbTaskTypeEnum.强å¶åºåºä»»å¡) ) && x.UPI == UPI ).ToList(); @@ -64,7 +64,7 @@ && ( x.RbTaskType == (int)RbTaskTypeEnum.å ¥åºä»»å¡ || x.RbTaskType == (int)RbTaskTypeEnum.åºåºä»»å¡ (x.RbTaskType == (int)RbTaskTypeEnum.é½å åºåºä»»å¡ || x.RbTaskType == (int)RbTaskTypeEnum.强å¶åºåºä»»å¡) ) ).ToList(); @@ -109,7 +109,7 @@ var isExist = wmsDB.wms_rbline_task.Where(x => x.TaskStatus != (int)TaskStatusEnum.已宿 && x.TaskStatus != (int)TaskStatusEnum.已忶 && ( x.RbTaskType == (int)RbTaskTypeEnum.åºåºä»»å¡ (x.RbTaskType == (int)RbTaskTypeEnum.é½å åºåºä»»å¡ || x.RbTaskType == (int)RbTaskTypeEnum.强å¶åºåºä»»å¡) ) ).ToList(); LA24030_LuLiPackageLine_Wms/Admin.NET.Application/Configuration/Database.json
@@ -26,11 +26,11 @@ "EnableUnderLine": false // å¯ç¨é©¼å³°è½¬ä¸å线 }, "TableSettings": { "EnableInitTable": false, // å¯ç¨è¡¨åå§å "EnableInitTable": true, // å¯ç¨è¡¨åå§å "EnableIncreTable": false // å¯ç¨è¡¨å¢éæ´æ°-ç¹æ§[IncreTable] }, "SeedSettings": { "EnableInitSeed": false, // å¯ç¨ç§ååå§å "EnableInitSeed": true, // å¯ç¨ç§ååå§å "EnableIncreSeed": false // å¯ç¨ç§åå¢éæ´æ°-ç¹æ§[IncreSeed] } } LA24030_LuLiPackageLine_Wms/Admin.NET.Application/Enum/ReportCenter/RbTaskTypeEnum.cs
@@ -15,21 +15,27 @@ å ¥åºä»»å¡ = 1, /// <summary> /// åºåºä»»å¡ /// é½å åºåºä»»å¡ /// </summary> [Description("åºåºä»»å¡")] åºåºä»»å¡ = 2, [Description("é½å åºåºä»»å¡")] é½å åºåºä»»å¡ = 2, /// <summary> /// 强å¶åºåºä»»å¡ /// </summary> [Description("强å¶åºåºä»»å¡")] 强å¶åºåºä»»å¡ = 3, /// <summary> /// ç æ¿ä»»å¡ /// </summary> [Description("ç æ¿ä»»å¡")] ç æ¿ä»»å¡ = 3, ç æ¿ä»»å¡ = 4, /// <summary> /// åå ä»»å¡ /// </summary> [Description("åå ä»»å¡")] åå ä»»å¡ = 4 åå ä»»å¡ = 5 } LA24030_LuLiPackageLine_Wms/Admin.NET.Application/Service/WmsOperationTask/WmsOperationTaskService.cs
@@ -54,6 +54,7 @@ [HttpPost] [ApiDescriptionSettings(Name = "ForceOutbound")] [Description("WmsOperationTask/ForceOutbound")] [UnitOfWork] public async Task ForceOutbound(ForceOutboundInput input) { if (input == null || input.PackageCodeList?.Count == 0) @@ -179,6 +180,7 @@ [HttpPost] [ApiDescriptionSettings(Name = "ValdateLabel")] [Description("WmsOperationTask/ValdateLabel")] [UnitOfWork] public async Task<Mes_Package_Gather> ValdateLabel(ValidateLabelInput input) { if (input == null || input.PackageCode == null || input.Upi == null) @@ -228,41 +230,63 @@ [HttpPost] [ApiDescriptionSettings(Name = "UnlineForNGPackage")] [Description("WmsOperationTask/UnlineForNGPackage")] [UnitOfWork] public async Task UnlineForNGPackage(UnlineForNGPackageInput input) { //if (input == null) //{ // throw Oops.Oh("åæ°ä¸è½ä¸ºç©º"); //} //if (string.IsNullOrEmpty(input.PackageCode)) //{ // throw Oops.Oh("å å·ä¸è½ä¸ºç©º"); //} //if (string.IsNullOrEmpty(input.Reason)) //{ // throw Oops.Oh("åå ä¸è½ä¸ºç©º"); //} //List<WmsStockQuan> updateQuanList = new List<WmsStockQuan>(); //foreach (var item in input.PackageCodeList) //{ // var quanList = await _wmsStockQuanRep.AsQueryable().Where(x => x.PackageCode == item).ToListAsync(); // var isExist = quanList.Where(x => x.StockStatus == StockStatusEnum.é½å å¾ åºåº).Count(); // if (isExist > 0) // { // throw Oops.Oh($"å {item}ä¸å ¶ä¸ææ¿ç¶ææ¯'{StockStatusEnum.é½å å¾ åºåº.ToString()}'ï¼ä¸å 许强å¶åºåº"); // } if (input == null) { throw Oops.Oh("åæ°ä¸è½ä¸ºç©º"); } if (string.IsNullOrEmpty(input.PackageCode)) { throw Oops.Oh("å å·ä¸è½ä¸ºç©º"); } if (string.IsNullOrEmpty(input.Reason)) { throw Oops.Oh("åå ä¸è½ä¸ºç©º"); } // æ´æ°ç¶æ // foreach (var quan in quanList) // { // quan.StockStatus = StockStatusEnum.人工强å¶å¾ åºåº; // quan.UpdateTime = DateTime.Now; // quan.OperReason = "人工强å¶å¾ åºåº"; // } // updateQuanList.AddRange(quanList); //} var singlePackage = await _mesPackageGatherRep.AsQueryable().Where(x => x.PackageCode == input.PackageCode).FirstAsync(); if (singlePackage == null) { throw Oops.Oh($"æ²¡ææ¾å°å å·{input.PackageCode}çæ±æ»æ°æ®"); } //await _wmsStockQuanRep.UpdateRangeAsync(updateQuanList); singlePackage.UpiFlag = UpiFlagEnum.NG; singlePackage.UpdateTime = DateTime.Now; singlePackage.UpiStatus = UpiStatusEnum.å·²ä¸çº¿; singlePackage.AreaCode = AreaCodeEnum.ä¸çº¿åºå; var upiList = await _mesBatchOrderUpiRep.AsQueryable().Where(x => x.PackageCode == input.PackageCode).ToListAsync(); if (upiList == null) { throw Oops.Oh($"æ²¡ææ¾å°å å·{input.PackageCode}çæ¿ä»¶æ°æ®"); } foreach (var item in upiList) { item.UpiFlag = UpiFlagEnum.NG; item.UpdateTime = DateTime.Now; item.UpiStatus = UpiStatusEnum.å·²ä¸çº¿; item.AreaCode = AreaCodeEnum.ä¸çº¿åºå; WmsRecordUpiProcess wmsRecordUpi = new WmsRecordUpiProcess(); wmsRecordUpi = item.Adapt<WmsRecordUpiProcess>(); wmsRecordUpi.CreateTime = DateTime.Now; wmsRecordUpi.Location = ""; wmsRecordUpi.OperRemark = "NGä¸çº¿"; await _wmsRecordUpiProcessRep.InsertAsync(wmsRecordUpi); } WmsRecordPackageProcess wmsRecordPackage = new WmsRecordPackageProcess(); wmsRecordPackage = singlePackage.Adapt<WmsRecordPackageProcess>(); wmsRecordPackage.Location = ""; wmsRecordPackage.OperRemark = "NGä¸çº¿"; await _wmsRecordPackageProcessRep.InsertAsync(wmsRecordPackage); await _mesPackageGatherRep.UpdateAsync(singlePackage); await _mesBatchOrderUpiRep.UpdateRangeAsync(upiList); }