出库修改

海波 张

23 小时以前 5321419f5fddb4e877fe90ccd90ebdc1a115af64

 process/TaskProcess.cs

@@ -210,10 +210,20 @@
            }
            if (state == 6)//卸货完成
            {
                //接驳位不绑定
                var safety = Settings.safetyLocations.Where(a => a.Area.Contains(mst.S_END_AREA)).FirstOrDefault();
                if (safety != null) {
                    if (safety.type==1)
                    {
                        return;
                    }
                }
                //退库任务不绑定
                if (!LocationHelper.GetErroArea(mst.S_END_AREA)) {
                    CacheBitUpdate(mst, false);
                }  
                if (LocationHelper.GetErroArea(mst.S_END_AREA)) {
                    return;
                }

                CacheBitUpdate(mst, false);
            }
            if (state == 7)
            {
@@ -543,14 +553,33 @@
                            return false;
                        }

                        if (wcsTask.S_B_STATE == "未执行")
                        if (wcsTask.S_B_STATE == "未执行" || wcsTask.S_B_STATE == "已推送")
                        {
                            LogHelper.Info($"推送任务{mst.S_CODE}，对应的Wcs出库任务未执行，暂不推送", "NDC");
                            return false;
                        }

                        //接驳位两个agv任务，a任务取货完成 推送b任务
                        var agvTask = LocationHelper.GetConnectionTask(wmsWork.CONNECTION,"agv");

                        LogHelper.Info($"推送任务{mst.S_CODE}，当前接驳位{wmsWork.CONNECTION}，第一个agv任务信息"+JsonConvert.SerializeObject(agvTask), "NDC");
                        //if (agvTask==null)
                        //{
                        //    LogHelper.Info($"推送任务{mst.S_CODE}，当前接驳位{wmsWork.CONNECTION}，agv任务没找到，暂不推送", "NDC");
                        //    return false;
                        //}

                        if (agvTask != null)
                        {
                            if (agvTask.S_B_STATE != "取货完成")
                            {
                                LogHelper.Info($"推送任务{mst.S_CODE}，当前接驳位{wmsWork.CONNECTION}，agv任务{agvTask.S_CODE},状态{agvTask.S_B_STATE}，暂不推送", "NDC");
                                return false;
                            }
                        }
                    }
                    //接驳位两个agv任务，a任务取货完成 推送b任务
                   


                }


@@ -637,6 +666,15 @@
            }
            return result;
        }

        internal static LocationRecordsResult LocationRecords(LocationRecordsParme model) {
            var result = new LocationRecordsResult();
            var db = new SqlHelper<object>().GetInstance();
            
            return result;
        }

        

        internal static Result MesUdeItem(MesUdeItemParme model)
        {
@@ -955,33 +993,30 @@
            try
            {
                var task = TaskHelper.GetTaskByWorkNo(model.task_no, "agv");
                var wcsTask = TaskHelper.GetTaskByWorkNo(model.task_no,"wcs");
                if (task != null && wcsTask != null)

                var wcsTask = TaskHelper.GetTaskByWorkNo(model.task_no, "wcs");

                if (task != null)
                {
                    LogHelper.Info($"cancelTask1取消agv任务{task.S_CODE}：", "取消");
                    if (task.S_B_STATE.Trim() == "未执行")
                    {
                        //未执行直接修改状态为取消
                        LogHelper.Info("cancelTask1取消agv任务：", "取消");
                        TaskHelper.opMesTask(task, 3);
                        TaskHelper.Fail(task);
                        TaskProcess.CacheBitCancelUpdate(task);
                        
                        if (task.S_TYPE.Contains("入库") || task.S_TYPE.Contains("回库"))
                        {
                            ContainerHelper.delCntr(task.S_CNTR_CODE);
                            ContainerHelper.delCntrItem(task.S_CNTR_CODE);

                        }
                        else {
                           WcsTask.WcsCancellTask(wcsTask);
                        }
                        
                       
                        TaskHelper.Fail(wcsTask);
                        TaskProcess.OperateStatus(wcsTask, 7);
                        result.errCode = 0;
                        result.errMsg = "取消成功";
                        result.success = true;
                        return result;
                    }
                    else if (task.S_B_STATE.Trim() != "取消"  && task.S_B_STATE.Trim() != "失败")
                    else if (task.S_B_STATE.Trim() != "取消" && task.S_B_STATE.Trim() != "失败" && task.S_B_STATE.Trim() != "完成")
                    {
                        var db = new SqlHelper<object>().GetInstance();
                        var qhflag = db.Queryable<WmsTaskAction>().Where(a => a.S_TASK_CODE == task.S_CODE && a.S_ACTION == "4").First();
@@ -995,22 +1030,20 @@
                            result.success = false;
                            return result;
                        }

                        //已推送但是没有完成或者取消，通知hosttoagv
                        TaskHelper.Fail(task);
                        
                        NDCApi.CancelOrder(task.S_CODE.Trim());
                        TaskProcess.CacheBitCancelUpdate(task);
                        if (task.S_TYPE.Contains("入库") || task.S_TYPE.Contains("回库"))
                        {
                            ContainerHelper.delCntr(task.S_CNTR_CODE);
                            ContainerHelper.delCntrItem(task.S_CNTR_CODE);
                            ContainerHelper.delCntrLoc(task.S_CNTR_CODE);
                        }
                        else {
                            WcsTask.WcsCancellTask(wcsTask);
                        }
                        TaskHelper.Fail(wcsTask);
                        TaskProcess.OperateStatus(wcsTask, 7);

                        TaskHelper.opMesTask(task, 3);
                        //已推送但是没有完成或者取消，通知hosttoagv
                        TaskHelper.Fail(task);

                        NDCApi.CancelOrder(task.S_CODE.Trim());
                        TaskProcess.CacheBitCancelUpdate(task);

                        result.errCode = 0;
                        result.errMsg = "取消成功";
                        result.success = true;
@@ -1028,11 +1061,40 @@
                    result.errMsg = $"{model.task_no}任务不存在";
                    result.success = false;
                }

                if (wcsTask != null)
                {
                    LogHelper.Info($"cancelTask1取消Wcs任务{wcsTask.S_CODE}", "取消");
                    if (wcsTask.S_B_STATE.Trim() == "未执行")
                    {
                        //未执行直接修改状态为取消
                        if (wcsTask.S_TYPE.Contains("入库") || wcsTask.S_TYPE.Contains("回库"))
                        {
                            ContainerHelper.delCntr(wcsTask.S_CNTR_CODE);
                            ContainerHelper.delCntrItem(wcsTask.S_CNTR_CODE);
                        }
                        TaskHelper.Fail(wcsTask);
                        TaskProcess.OperateStatus(wcsTask, 7);
                        result.errCode = 0;
                        result.errMsg = "取消成功";
                        result.success = true;
                        return result;
                    }
                    else 
                    {
                            LogHelper.Info($"该任务{wcsTask.S_CODE}已经推送", "取消");
                            result.errCode = 1;
                            result.errMsg = "任务已经推送，不允许取消";
                            result.success = false;
                            return result;
                       
                    }
                }
            }
            catch (Exception ex)
            {

                LogHelper.Info("cancelTask1取消任务异常："+ex.Message, "取消");
                LogHelper.Info("cancelTask1取消任务异常：" + ex.Message, "取消");
                result.errCode = 1;
                result.errMsg = "取消任务异常";
                return result;
@@ -1340,7 +1402,262 @@

        }

       

        /// <summary>
        /// 添加mes任务
        /// </summary>
        internal static Result addMesTaskInWorkArea(InWorkAreaParme model)
        {
            var result = new Result();
            var TOOLSTYPE = "";
            try
            {
                if (string.IsNullOrEmpty(model.BUSI_TYPE.ToString()))
                {
                    LogHelper.Info("InWorkArea任务下发失败，缺少参数BUSI_TYPE。", "Mes任务下发");
                    throw new Exception("缺少参数BUSI_TYPE");
                }
                if (string.IsNullOrEmpty(model.PROD_NO))
                {
                    LogHelper.Info("InWorkArea任务下发失败，缺少参数PROD_NO。", "Mes任务下发");
                    throw new Exception("缺少参数PROD_NO");
                }
                if (string.IsNullOrEmpty(model.Location_To))
                {
                    LogHelper.Info("InWorkArea任务下发失败，终点为空。", "Mes任务下发");
                    throw new Exception("缺少终点Location_To");
                }
                if (string.IsNullOrEmpty(model.CHECK_INFO))
                {
                    LogHelper.Info("InWorkArea任务下发失败，缺少参数CHECK_INFO。", "Mes任务下发");
                    throw new Exception("缺少参数CHECK_INFO");
                }
                if (string.IsNullOrEmpty(model.task_no))
                {
                    LogHelper.Info("InWorkArea任务下发失败，缺少参数task_no。", "Mes任务下发");
                    throw new Exception("缺少参数task_no");
                }

                if (model.Task_type==2)
                {
                    //呼叫胶料出库



                  var   workFlow = TaskHelper.selectWorkFlowByType(model.BUSI_TYPE);

                  


                    if (workFlow == null)
                    {
                        LogHelper.Info($"InWorkArea任务下发失败，BUSI_TYpe:{model.BUSI_TYPE},没找到对应作业流程", "Mes任务下发");
                        throw new Exception($"BUSI_TYpe:{model.BUSI_TYPE},没找到对应作业流程");
                    }
                    else
                    {
                        LogHelper.Info($"作业流程信息" + JsonConvert.SerializeObject(workFlow), "Mes任务下发");
                    }

                    //出库任务

                    //接驳位
                    var connection = "";

                    //接驳位库区
                    var connectionArea = "";


                    //查找给定终点
                    var end = LocationHelper.GetLoc(model.Location_To);
                    LogHelper.Info($"InWorkArea出库任务下发终点信息" + JsonConvert.SerializeObject(end), "Mes任务下发");


                    if (end == null)
                    {
                        LogHelper.Info($"InWorkArea出库任务下发失败，终点:{model.Location_To},没找到", "Mes任务下发");
                        throw new Exception($"终点:{model.Location_To},没找到");
                    }


                    var unlimitedLocation = TaskHelper.GetMesKtLoc();

                    //标记终点货位是否可以无限制下任务
                    var endLocFlag = true;

                    foreach (var item in unlimitedLocation)
                    {
                        //出库终点货位在配置里 可以无限制下任务
                        if (item.Loc.Contains(model.Location_To))
                        {
                            endLocFlag = false;
                            break;
                        }
                    }

                    if (endLocFlag)
                    {
                        var endTask = TaskHelper.GetTaskByEndLoc(model.Location_To);
                        if (endTask != null)
                        {
                            LogHelper.Info($"InWorkArea出库任务下发失败，终点:{model.Location_To}有任务执行中，任务号:{endTask.S_CODE}", "Mes任务下发");
                            throw new Exception($"终点:{model.Location_To}有任务执行中，任务号:{endTask.S_CODE}");
                        }
                    }



                    //查找起点
                    List<Location> strrtList;

                    Location start = null;


                    if (!string.IsNullOrEmpty(workFlow.ZONECODE))
                    {
                        strrtList = LocationHelper.GetZoneLoc(workFlow.ZONECODE);
                    }
                    else
                    {
                        strrtList = LocationHelper.GetAllLocList2(workFlow.STARTAREA);
                    }



                    if (workFlow.FLOWCODE == "9")
                    {
                            //根据制品编号寻找立库区对应物料托盘
                            start = LocationHelper.FindStartcolByLoclistAndItem(strrtList, model.PROD_NO, workFlow.STARTAREA, workFlow.ROADWAY, workFlow.CONNECTION);
                            if (start == null)
                            {
                                strrtList = LocationHelper.GetAllLocList2(workFlow.STARTAREA);
                                var itemFlag = LocationHelper.FindStartcolByLoclistAndItemFlag(strrtList, model.PROD_NO, workFlow.STARTAREA);
                                LogHelper.Info($"InWorkArea满托出库任务没找到起点，校验是否有库存但是设备报警{itemFlag}", "Mes任务下发");
                                if (itemFlag)
                                {
                                    result.errMsg = "满托出库作业有库存但设备报警";
                                    result.errCode = 2001;
                                    result.success = true;
                                    return result;
                                }
                            }


                        LogHelper.Info($"InWorkArea出库任务下发起点信息" + JsonConvert.SerializeObject(start), "Mes任务下发");

                        if (start == null)
                        {
                            LogHelper.Info($"InWorkArea出库任务下发失败，起点库区{workFlow.STARTAREA},没找到起点", "Mes任务下发");
                            throw new Exception($"起点库区{workFlow.STARTAREA},没找到起点");
                        }




                        //获取托盘码
                        var cntrCode = LocationHelper.GetLocCntrCode(start.S_CODE);

                        if (workFlow.SENDWCS == "Y")
                        {

                            //正式代码，调用接口寻找可用接驳位
                            var connectionList = LocationHelper.GetConnectionList(workFlow.CONNECTION);
                                 
                            //根据接驳位任务数量获取均衡接驳位集合优先任务数少的接驳位
                            var balanceConnectionList = LocationHelper.GetBalanceConnectionList(connectionList);
                            foreach (var item in balanceConnectionList)
                            {
                                if (item.loc.CONNEC_ROADWAY == start.N_ROADWAY)
                                {
                                    connection = item.loc.S_CODE;
                                    connectionArea = item.loc.S_AREA_Name;
                                    LogHelper.Info($"InWorkArea出库任务下发寻找到可用接驳位{connection}", "Mes任务下发");
                                    break;
                                }
                            }

                            if (connection == "")
                            {
                                LogHelper.Info($"InWorkArea出库任务下发寻找接驳位失败", "Mes任务下发");
                                throw new Exception($"InWorkArea出库任务下发寻找接驳位失败");
                            }
                        }


                        //起点终点查找成功，创建作业

                        var taskType = int.Parse(workFlow.FLOWCODE);

                        var operation = new WmsWork
                        {
                            // 作业号
                            S_CODE = model.task_no,
                            // 作业类型
                            N_TYPE = taskType,
                            // 作业类型
                            S_TYPE = workFlow.FLOWNAME,
                            // 起点货位
                            S_START_LOC = start.S_CODE,
                            // 起点库区编码
                            S_START_AREA = start.S_AREA_CODE,
                            //接驳位
                            CONNECTION = connection,
                            // 终点货位
                            S_END_LOC = end.S_CODE,
                            // 终点库区编码
                            S_END_AREA = end.S_AREA_CODE,
                            // 容器编码
                            S_CNTR_CODE = cntrCode,
                            // 作业定义名称
                            S_OP_DEF_NAME = workFlow.FLOWNAME,
                            //优先级
                            N_PRIORITY = model.Priority,
                            //工装类型
                            TOOLSTYPE = TOOLSTYPE,
                            //起点库区名称
                            S_START_AREA_NAME = start.S_AREA_Name,
                            //起点库区名称
                            S_END_AREA_NAME = end.S_AREA_Name,
                            //起点库区名称
                            CONNECTION_AREA = connectionArea
                        };

                        //创建作业
                        if (WMSHelper.CreateWmsWork(operation))
                        {
                            if (connection != "")
                            {
                                LocationHelper.LockLoc(operation.S_START_LOC, "出库锁", 2);
                                LocationHelper.LockLoc(operation.S_END_LOC, "入库锁", 1);
                                LocationHelper.LockLoc(operation.CONNECTION, "入库锁", 1);
                            }


                            LogHelper.Info($"InWorkArea出库作业创建成功{operation.S_CODE}", "Mes任务下发");
                            result.errMsg = "出库作业创建成功";
                            result.errCode = 0;
                            result.success = true;
                            return result;
                        }
                        else
                        {
                            LogHelper.Info($"InWorkArea出库任务下发创建作业失败", "Mes任务下发");
                            throw new Exception($"InWorkArea出库任务下发创建作业失败");
                        }
                    }
                }
            }
            catch (Exception ex)
            {
                LogHelper.Info("InWorkArea任务下发异常" + ex.Message, "Mes任务下发");
                result.errMsg = "InWorkArea任务下发异常" + ex.Message;
                result.errCode = 1;
                result.success = false;
                throw;
            }

            return result;
        }


            /// <summary>
@@ -1433,15 +1750,35 @@
                var TOOLSTYPE = "";
                if (!string.IsNullOrEmpty(model.TOOLS_TPYE))
                {
                    TOOLSTYPE = model.TOOLS_TPYE;
                    
                    TOOLSTYPE = model.TOOLS_TPYE;  
                }

                workFlow = TaskHelper.selectWorkFlowByType(model.BUSI_TYPE, TOOLSTYPE);
               
                //入库按照工装和流程编号
                if (model.Task_type == 1) {
                    workFlow = TaskHelper.selectWorkFlowByType(model.BUSI_TYPE, TOOLSTYPE);
                }
                else if (model.Task_type == 2)
                {
                    //出库按照终点库区和流程编号

                    var end = LocationHelper.GetLoc(model.Location_To);
                    LogHelper.Info($"ZCSendTask出库任务下发终点信息" + JsonConvert.SerializeObject(end), "Mes任务下发");


                    if (end == null)
                    {
                        LogHelper.Info($"ZCSendTask出库任务下发失败，终点:{model.Location_To},没找到", "Mes任务下发");
                        throw new Exception($"终点:{model.Location_To},没找到");
                    }

                    workFlow = TaskHelper.selectWorkFlowByEndArea(model.BUSI_TYPE, end.S_AREA_CODE);
                    TOOLSTYPE = workFlow.TOOLSTYPE;
                }

                LogHelper.Info($"作业{model.task_no}，工装类型{TOOLSTYPE}", "Mes任务下发");

               


                if (workFlow == null) {
                    LogHelper.Info($"ZCSendTask任务下发失败，BUSI_TYpe:{model.BUSI_TYPE},没找到对应作业流程", "Mes任务下发");
                    throw new Exception($"BUSI_TYpe:{model.BUSI_TYPE},没找到对应作业流程");
@@ -1572,7 +1909,7 @@
                        //}


                        if (workFlow.FLOWCODE == "1" || workFlow.FLOWCODE == "2")
                        if (workFlow.FLOWCODE == "1" || workFlow.FLOWCODE == "2" || workFlow.FLOWCODE == "5" || workFlow.FLOWCODE == "8" || workFlow.FLOWCODE == "11")
                        {
                            //满托入

@@ -1587,7 +1924,7 @@
                            }

                        }
                        else if (workFlow.FLOWCODE == "3")
                        else if (workFlow.FLOWCODE == "3" || workFlow.FLOWCODE == "10")
                        {
                            //空托入立库区
                            cntrCount = 0;
@@ -1848,7 +2185,7 @@



                    if (workFlow.FLOWCODE == "9" || workFlow.FLOWCODE == "4")
                    if (workFlow.FLOWCODE == "9" || workFlow.FLOWCODE == "4" || workFlow.FLOWCODE == "6")
                    {
                        if (TOOLSTYPE == "85" || TOOLSTYPE == "95")
                        {