wangxinhui
2026-02-11 482ece71c06bcc49c38b0dc5d747b37a60d227fd
ÏîÄ¿´úÂë/WMS/WMSServices/WIDESEA_TaskInfoService/TaskService_Inbound.cs
@@ -1,6 +1,7 @@
using Autofac.Core;
using Microsoft.IdentityModel.Tokens;
using Newtonsoft.Json;
using OfficeOpenXml.FormulaParsing.Excel.Functions.Math;
using OfficeOpenXml.FormulaParsing.Excel.Functions.RefAndLookup;
using OfficeOpenXml.FormulaParsing.Excel.Operators;
using SqlSugar;
@@ -988,14 +989,20 @@
                    {
                        agvstation.IsOccupied = WhetherEnum.False.ObjToInt();
                    }
                    //叠盘任务单独完成
                    if (task.TaskType==TaskTypeEnum.EmptyStackPlate.ObjToInt())
                    //叠盘/冲切搬运至雾化 ä»»åŠ¡å•ç‹¬å®Œæˆ
                    if (task.TaskType==TaskTypeEnum.EmptyStackPlate.ObjToInt() || task.TaskType == TaskTypeEnum.PunchingInbound.ObjToInt())
                    {
                        task.TaskStatus = TaskStatusEnum.Finish.ObjToInt();
                        _unitOfWorkManage.BeginTran();
                        if (agvstation != null)
                        {
                            _basicRepository.AGVStationInfoRepository.UpdateData(agvstation);
                        }
                        if (task.ProductNo.IsNotEmptyOrNull())
                        {
                            Dt_MESProInOrderInfo mESProInOrderInfo = _inboundRepository.MESProInOrderInfoRepository.QueryFirst(x=>x.BarCode== task.ProductNo);
                            mESProInOrderInfo.MESProInStatus = InOrderStatusEnum.入库完成.ObjToInt();
                            _inboundRepository.MESProInOrderInfoRepository.UpdateData(mESProInOrderInfo);
                        }
                        BaseDal.DeleteAndMoveIntoHty(task, App.User.UserId > 0 ? WIDESEA_Core.Enums.OperateTypeEnum.人工完成 : WIDESEA_Core.Enums.OperateTypeEnum.自动完成);
                        _unitOfWorkManage.CommitTran();
@@ -1942,10 +1949,10 @@
                                PB_INV_PRODUCT_IN= pRODUCT_INItems
                            }) ?? throw new Exception("半成品入库接口请求失败");
                    //生成半成品入库
                    List<Dt_MESProInOrderInfo> semiProInOrderInfos = mESProInOrderInfos.Where(x => x.MESProInStatus == InOrderStatusEnum.未开始.ObjToInt()).ToList();
                    List<Dt_MESProInOrderInfo> semiProInOrderInfos = mESProInOrderInfos.Where(x => x.MESProInStatus == InOrderStatusEnum.未开始.ObjToInt() && x.WarehouseId==WarehouseEnum.LLDYL.ObjToInt()).ToList();
                    if (semiProInOrderInfos.Count>0)
                    {
                        WebResponseContent webResponse = SemiProInbound(AddMESProInOrders.Where(x => x.MESProOrderType == MaterielTypeEnum.半成品.ObjToInt()).ToList());
                        WebResponseContent webResponse = SemiProInbound(semiProInOrderInfos);
                        if (!webResponse.Status)
                        {
                            throw new Exception(webResponse.Message);
@@ -1956,6 +1963,7 @@
                        {
                            throw new Exception(taskResponse.Message);
                        }
                        _inboundRepository.MESProInOrderInfoRepository.UpdateData(mESProInOrderInfos);
                    }
                }
                List<Dt_MESProInOrderInfo> proInOrderInfos = AddMESProInOrders.Where(x => x.MESProOrderType == MaterielTypeEnum.成品.ObjToInt()).ToList();
@@ -2057,7 +2065,10 @@
                        TaskStatus = TaskStatusEnum.New.ObjToInt(),
                        WarehouseId = materielInfo.WarehouseId,
                        PalletType = stockInfo.PalletType,
                        TaskLength = (int)item.Wide
                        TaskLength = (int)item.Wide,
                        WorkCentreCode=item.MakeCode,
                        MaterielCode = item.MaterialCode,
                        Quantity =item.ProQuantity
                    };
                    TaskTypeEnum taskTypeEnum = CheckPointCode.StationArea switch
                    {
@@ -2222,5 +2233,83 @@
            }
            return content;
        }
        /// <summary>
        /// åŠæˆå“æ‰˜ç›˜æ¬è¿å…¥åº“
        /// </summary>
        /// <returns></returns>
        public WebResponseContent SemiProIn(string barcode, string palletCode, string address)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                //获取当前半成品信息
                Dt_MESProInOrderInfo mESProInOrderInfo = _inboundRepository.MESProInOrderInfoRepository.QueryFirst(x=>x.BarCode==barcode) ?? throw new Exception($"半成品条码{barcode}信息不存在,请核对信息");
                //获取加工中心
                Dt_MakeCenterInfo makeCenterInfo = _basicRepository.MakeCenterInfoRepository.QueryFirst(x=>x.MakeCode==mESProInOrderInfo.MakeCode);
                if (makeCenterInfo.MakeArea!=StationAreaEnum.一楼分切.ObjToInt() && makeCenterInfo.MakeArea != StationAreaEnum.一楼冲切.ObjToInt() && makeCenterInfo.MakeArea != StationAreaEnum.一楼模切.ObjToInt()) throw new Exception($"半成品条码{barcode}不属于分切/冲切/模切加工");
                //判断任务
                Dt_Task? taskExist = BaseDal.QueryFirst(x=>x.PalletCode==palletCode) == null ? null: throw new Exception($"托盘{palletCode}任务已存在");
                //判断库存
                Dt_ProStockInfo? proStockInfoExist = BaseDal.Db.Queryable<Dt_ProStockInfo>().Where(x => x.PalletCode== palletCode).Includes(x => x.proStockInfoDetails).First() == null ? null : throw new Exception($"托盘{palletCode}库存已存在"); ;
                //判断地址
                Dt_AGVStationInfo StationInfoStart = _basicRepository.AGVStationInfoRepository.QueryFirst(x=>x.AGVStationCode==address) ?? throw new Exception($"地址码{address}不存在");
                Dt_AGVStationInfo? StationInfoEnd = null;
                Dt_Task? newTask = null;
                #region é€»è¾‘判断:分切&模切入成品(辅料)库;冲切搬运至二楼雾化中转区)
                if (makeCenterInfo.MakeArea == StationAreaEnum.一楼冲切.ObjToInt())
                {
                    //获取雾化中转区点位
                    StationInfoEnd = _basicRepository.AGVStationInfoRepository.QueryFirst(x=>x.StationArea== StationAreaEnum.二楼雾化.ToString() && x.IsOccupied==WhetherEnum.False.ObjToInt()) ?? throw new Exception($"二楼雾化可用点位不足");
                    //生成任务
                    newTask = new Dt_Task()
                    {
                        CurrentAddress = StationInfoStart.AGVStationCode,
                        Grade = 0,
                        NextAddress = StationInfoEnd.AGVStationCode,
                        PalletCode = palletCode,
                        Roadway = "AGV",
                        SourceAddress = StationInfoStart.AGVStationCode,
                        TargetAddress = StationInfoEnd.AGVStationCode,
                        TaskType = TaskTypeEnum.PunchingInbound.ObjToInt(),
                        TaskStatus = TaskStatusEnum.New.ObjToInt(),
                        WarehouseId = mESProInOrderInfo.WarehouseId,
                        PalletType = PalletTypeEnum.SmallPallet.ObjToInt(),
                        TaskLength = (int)mESProInOrderInfo.Wide,
                        WorkCentreCode = mESProInOrderInfo.MakeCode,
                        MaterielCode=mESProInOrderInfo.MaterialCode,
                        Quantity=mESProInOrderInfo.ProQuantity,
                        ProductNo=mESProInOrderInfo.BarCode
                    };
                    StationInfoEnd.IsOccupied = 1;
                }
                else
                {
                    return content.Error("暂时无法满足");
                }
                mESProInOrderInfo.MESProInStatus = InOrderStatusEnum.入库中.ObjToInt();
                //数据库操作并推送WCS任务
                _unitOfWorkManage.BeginTran();
                _basicRepository.AGVStationInfoRepository.UpdateData(StationInfoEnd);
                BaseDal.AddData(newTask);
                _inboundRepository.MESProInOrderInfoRepository.UpdateData(mESProInOrderInfo);
                WebResponseContent taskResponse = PushTasksToWCS(new List<Dt_Task>() { newTask });
                if (!taskResponse.Status)
                {
                    throw new Exception(taskResponse.Message);
                }
                _unitOfWorkManage.CommitTran();
                #endregion
                content.OK();
            }
            catch (Exception ex)
            {
                _unitOfWorkManage.RollbackTran();
                content.Error(ex.Message);
            }
            return content;
        }
    }
}