任务管理新增功能增加分配拆垛工位功能

wxw

2024-09-14 9bd425125ca962cf44d292916fc7089d41015db8

 Admin.NET/WCS.Application/Service/WcsTask/WcsTaskService.cs

@@ -4,6 +4,7 @@
using Furion.DatabaseAccessor;
using Microsoft.AspNetCore.SignalR;
using WCS.Application.Entity;
using WCS.Application.Service.WcsTask.Dto;

namespace WCS.Application;

@@ -73,38 +74,25 @@
        }
        var entity = input.Adapt<WcsTask>();
        entity.Origin = "WCS";
        await _wcsTaskRep.InsertAsync(entity);

        #region 绑定垛机

        //物料品种信息
        var skuInfo = await _wcsMateialPzInfoRep.Context.Queryable<WcsMateialPzInfo>().Where(w => w.SkuNo == input.SkuNo).FirstAsync();
        if (skuInfo == null)
        {
            throw Oops.Oh("物料品种信息不存在");
        }
        #region 分配拆垛工位
        //分拣任务信息
        var checkTaskInfo = await _wcsCheckTaskRep.Context.Queryable<WcsCheckTask>().Where(w => w.Status == "0" && w.RoboatType == "0").OrderBy(o => o.LineNo).FirstAsync();
        if (checkTaskInfo == null)
        List<TaskPortDto> taskPortList = await _wcsCheckTaskRep.Context.Queryable<WcsCheckTask>().Where(w => w.RoboatType == PLCTypeEnum.StackingRobot).Select<TaskPortDto>().ToListAsync();
        if (taskPortList.Count<=0)
        {
            throw Oops.Oh("分拣任务信息不存在");
            throw Oops.Bah("拆垛工位异常");
        }
        if (checkTaskInfo.Status != "0")
        var taskList = await _wcsTaskRep.Context.Queryable<WcsTask>().Where(w => w.Status == 0 && w.IsBind == 0 && w.TaskType == TaskTypeEnum.Out).ToListAsync();
        foreach (var item in taskPortList)
        {
            throw Oops.Oh("该工位已绑定任务，请勿再次绑定");
            item.PortCount= taskList.Where(w=>w.StationNum==item.Port).Count();
        }
        checkTaskInfo.OrderNo = "";
        checkTaskInfo.TaskNo = entity.TaskNo;
        checkTaskInfo.LotNo = entity.LotNo;
        checkTaskInfo.SkuNo = entity.SkuNo;
        checkTaskInfo.SkuName = entity.SkuName;
        checkTaskInfo.BoxType = "";
        checkTaskInfo.Qty = entity.Qty;
        checkTaskInfo.Status = "1";//已绑定
        checkTaskInfo.PZNo = skuInfo.PZNo;
        //更新分拣任务
        await _wcsCheckTaskRep.AsUpdateable(checkTaskInfo).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
        var portInfo = taskPortList.OrderBy(o => o.PortCount).ThenBy(o => o.LineNO).First();
        //拆垛工位号
        entity.StationNum = portInfo.Port;
        #endregion

        await _wcsTaskRep.InsertAsync(entity);

        return entity.Id;
    }
@@ -232,7 +220,4 @@
            throw Oops.Oh("任务状态异常");
        }
    }



}