SignalR+事件总线推送前端

肖洋

2024-12-09 ad6f399066a747aeaba987360bce9ee40227302c

 Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs

@@ -599,7 +599,7 @@
                    PalletCode = input.PalletCode,
                    SourceAddress = stationManager.stationLocation,
                    TaskState = (int)TaskInStatusEnum.Line_InFinish,
                    TaskType = (int)TaskOutboundTypeEnum.OutNG,
                    TaskType = (int)TaskOutboundTypeEnum.InToOut,
                    TaskNum = await BaseDal.GetTaskNo(),
                    Creater = "Systeam"
                };
@@ -712,7 +712,7 @@
                    PalletCode = input.PalletCode,
                    SourceAddress = stationManager.stationLocation,
                    TaskState = (int)TaskInStatusEnum.Line_InFinish,
                    TaskType = (int)TaskOutboundTypeEnum.OutNG,
                    TaskType = (int)TaskOutboundTypeEnum.InToOut,
                    TaskNum = await BaseDal.GetTaskNo(),
                    Creater = "Systeam"
                };
@@ -763,8 +763,9 @@
            TaskNum = await BaseDal.GetTaskNo(),
            Creater = "Systeam"
        };

        ConsoleHelper.WriteSuccessLine($"修改前：" + locationInfo.LocationStatus.ToString());
        locationInfo.LocationStatus = (int)LocationEnum.FreeDisable;
        ConsoleHelper.WriteSuccessLine($"修改后：" + locationInfo.LocationStatus.ToString());
        await UpdateLocationAsync(locationInfo);

        return task;
@@ -789,7 +790,7 @@
            }
            else
            {
                locations = await _locationRepository.QueryDataAsync(x => x.LocationStatus == (int)LocationEnum.FreeDisable && x.RoadwayNo == requestTask.Roadways && x.EnalbeStatus == 1 && x.LocationType == 1);
                locations = await _locationRepository.QueryDataAsync(x => x.LocationStatus == (int)LocationEnum.Distribute && x.RoadwayNo == requestTask.Roadways && x.EnalbeStatus == 1 && x.LocationType == 1);
            }

            if (locations == null)
@@ -994,7 +995,8 @@

                var stockInfo = await QueryStockInfoForEmptyTrayAsync("CWSC1", new List<string>());


                if (stockInfo != null)
                {
                var task = CreateTask(stockInfo, taskDTO.Position, (int)TaskOutboundTypeEnum.OutTray);

                // 创建任务DTO
@@ -1002,7 +1004,7 @@

                // 更新库存位置状态为不可用
                stockInfo.LocationInfo.LocationStatus = (int)LocationEnum.InStockDisable;
                location.LocationStatus = (int)LocationEnum.FreeDisable;
                    location.LocationStatus = (int)LocationEnum.Distribute;
                await _unitOfWorkManage.UseTranAsync(async () =>
                {
                    await BaseDal.AddDataAsync(task);
@@ -1013,6 +1015,9 @@
                // 返回成功响应
                return content.OK(data: wmsTask);
            }
                else
                    content.Error("常温空托盘数量不足");
            }
        }
        catch (Exception ex)
        {