任务管理新增功能增加分配拆垛工位功能；调整分拣码垛页面，更改拆垛机器人属性

wxw

2024-09-14 d239f2cccb5b84d52c8c202557ea8e75cc6ab984

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

@@ -1,9 +1,11 @@

using AngleSharp.Dom;
using COSXML.Network;
using Elastic.Clients.Elasticsearch.Tasks;
using Furion.DatabaseAccessor;
using Microsoft.AspNetCore.SignalR;
using WCS.Application.Entity;
using WCS.Application.Service.WcsTask.Dto;

namespace WCS.Application;

@@ -73,38 +75,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")
        {
            throw Oops.Oh("该工位已绑定任务，请勿再次绑定");
        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)
        { 
            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;
    }
@@ -233,6 +222,30 @@
        }
    }



    public async Task UploadTask(UpdateWcsTaskInput input)
    {
        var modTask = await _wcsTaskRep.GetByIdAsync(input.Id);
        if (modTask.Status != TaskStatusEnum.Complete)
        {
            throw Oops.Oh("任务状态异常");
        }
        if (modTask.Origin != "WMS")
        {
            throw Oops.Oh("该任务来源不是WMS");
        }
        // 反馈WMS
        //var requestMode = new TaskRequest()
        //{
        //    TaskNo = modTask.TaskNo,
        //    PalletNo = modTask.PalletNo,
        //    TaskType = (TaskTypeEnum)modTask.TaskType,//TaskTypeEnum.In,
        //    TaskStatus = TaskStatusEnum.Complete
        //};
        //HttpService httpService = new HttpService();
        //var modResponseTask = httpService.RequestTask(requestMode).Result;
        //if (modResponseTask.StatusCode == "0")
        //{
        //    modcTaskMonitor.InteractiveMsg = "任务完成，返回给WMS任务完成";
        //}
    }
}