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

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;

@@ -44,6 +46,8 @@
            .WhereIF(!string.IsNullOrWhiteSpace(input.TaskNo), u => u.TaskNo.Contains(input.TaskNo.Trim()))
            .WhereIF(input.TaskType.HasValue, u => u.TaskType == input.TaskType)
            .WhereIF(input.Status.HasValue, u => u.Status == input.Status)
            .WhereIF(!string.IsNullOrWhiteSpace(input.PalletNo), u => u.PalletNo.Contains(input.PalletNo.Trim()))
            .WhereIF(!string.IsNullOrWhiteSpace(input.Origin), u => u.Origin.Contains(input.Origin.Trim()))
            .Select<WcsTaskOutput>();
        return await query.OrderBuilder(input).ToPagedListAsync(input.Page, input.PageSize);
    }
@@ -71,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;
    }
@@ -179,12 +170,17 @@
            if (modTask.Status > TaskStatusEnum.Doing)
                throw Oops.Oh("任务状态异常");
            if (input.Status == TaskStatusEnum.Complete)
            {
                modTask.IsSuccess = TaskSuccessEnum.Success;
                modTask.FinishDate = DateTime.Now;//完成时间
            }
            else
            {
                modTask.IsSuccess = TaskSuccessEnum.Fail;
            modTask.FinishDate = DateTime.Now;
                modTask.CancelDate = DateTime.Now;//取消时间
            }
            modTask.Status = input.Status;
            await _wcsTaskRep.Context.Updateable(modTask).UpdateColumns(s => new { s.Status, s.IsSuccess, s.FinishDate, s.UpdateTime,s.UpdateUserId,s.UpdateUserName }).ExecuteCommandAsync();
            await _wcsTaskRep.Context.Updateable(modTask).UpdateColumns(s => new { s.Status, s.IsSuccess, s.FinishDate, s.CancelDate, s.UpdateTime, s.UpdateUserId, s.UpdateUserName }).ExecuteCommandAsync();
            //写入任务明细表
            WcsTaskMonitor modTaskMonitor = new WcsTaskMonitor()
            {
@@ -226,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任务完成";
        //}
    }
}