海波 张
2025-06-03 baf741a2c65777b70d96b6c5d60204170dd92626
process/TaskProcess.cs
@@ -59,7 +59,7 @@
            else
            {
                Console.WriteLine($"任务{mst.S_CODE} 货位{mst.S_END_LOC}卸货完成,终点绑定容器{mst.S_CNTR_CODE}");
                LogHelper.Info($"任务{mst.S_CODE} 货位{mst.S_END_LOC}卸货完成,起点解绑容器{mst.S_CNTR_CODE}");
                LogHelper.Info($"任务{mst.S_CODE} 货位{mst.S_END_LOC}卸货完成,终点绑定容器{mst.S_CNTR_CODE}");
                LocationHelper.BindingLoc(mst.S_END_LOC, mst.S_CNTR_CODE.Split(',').ToList());
            }
@@ -227,28 +227,32 @@
                        //查找给定终点
                        var end = LocationHelper.GetLoc(kt.Location_To);
                        //LogHelper.Info($"当前任务{task.S_CODE}改道终点信息" + JsonConvert.SerializeObject(end), "改道安全交互");
                        //if (end == null || end.S_LOCK_STATE != "无")
                        //{
                        //    LogHelper.Info($"当前任务{task.S_CODE}改道终点失败,终点:{kt.Location_To},没找到或有锁", "改道安全交互");
                        //}
                        TaskHelper.Fail(wcsTask);
                        TaskProcess.OperateStatus(wcsTask, 7);
                        LocationHelper.LockLoc(end.S_CODE, "入库锁", 1);
                        db.BeginTran();
                        //改一段任务终点
                        task.S_END_LOC = end.S_CODE;
                        task.S_END_AREA = end.S_AREA_CODE;
                        db.Updateable(task).UpdateColumns(it => new { it.S_END_LOC,it.S_END_AREA}).ExecuteCommand();
                        kt.Status = "Y";
                        db.Updateable(kt).UpdateColumns(it => new { it.Status }).ExecuteCommand();
                        db.CommitTran();
                        var site = LocationHelper.GetAgvSiteZc(end.S_CODE);
                        LogHelper.Info($"任务{task.S_CODE}改道成功,改参数2为{site},参数6为1,4为0", "改道安全交互");
                        NDCApi.ChangeOrderParam(task.S_CODE, 2, site);
                        NDCApi.ChangeOrderParam(task.S_CODE, 6, "1");
                        NDCApi.ChangeOrderParam(task.S_CODE, 4, "0");
                        return;
                        if (end.S_LOCK_STATE=="无" && end.N_CURRENT_NUM==0)
                        {
                            //LogHelper.Info($"当前任务{task.S_CODE}改道终点信息" + JsonConvert.SerializeObject(end), "改道安全交互");
                            //if (end == null || end.S_LOCK_STATE != "无")
                            //{
                            //    LogHelper.Info($"当前任务{task.S_CODE}改道终点失败,终点:{kt.Location_To},没找到或有锁", "改道安全交互");
                            //}
                            TaskHelper.Fail(wcsTask);
                            TaskProcess.OperateStatus(wcsTask, 7);
                            LocationHelper.LockLoc(end.S_CODE, "入库锁", 1);
                            db.BeginTran();
                            //改一段任务终点
                            task.S_END_LOC = end.S_CODE;
                            task.S_END_AREA = end.S_AREA_CODE;
                            db.Updateable(task).UpdateColumns(it => new { it.S_END_LOC, it.S_END_AREA }).ExecuteCommand();
                            kt.Status = "Y";
                            db.Updateable(kt).UpdateColumns(it => new { it.Status }).ExecuteCommand();
                            db.CommitTran();
                            var site = LocationHelper.GetAgvSiteZc(end.S_CODE);
                            LogHelper.Info($"任务{task.S_CODE}改道成功,改参数2为{site},参数6为1,4为0", "改道安全交互");
                            NDCApi.ChangeOrderParam(task.S_CODE, 2, site);
                            NDCApi.ChangeOrderParam(task.S_CODE, 6, "1");
                            NDCApi.ChangeOrderParam(task.S_CODE, 4, "0");
                            return;
                        }
                    }
                }
@@ -297,9 +301,9 @@
                            {
                                flag = false;
                                LogHelper.Info($"当前任务{task.S_CODE}接驳位{con.S_CODE}可用,不需要改道,直接修改参数6为1,4为0", "改道安全交互");
                                LogHelper.Info($"当前任务{task.S_CODE}接驳位{con.S_CODE}可用,不需要改道,直接修改参数6为1,4为1024", "改道安全交互");
                                NDCApi.ChangeOrderParam(task.S_CODE, 6, "1");
                                NDCApi.ChangeOrderParam(task.S_CODE, 4, "0");
                                NDCApi.ChangeOrderParam(task.S_CODE, 4, "1024");
                                break;
                            }
                        }
@@ -437,6 +441,23 @@
                LogHelper.Info($"推送任务{mst.S_CODE}", "NDC");
                if (mst.S_TYPE.Contains("出库"))
                {
                    var wcsTask = TaskHelper.GetTaskByWork("wcs", mst.S_OP_CODE);
                    if (wcsTask == null) {
                        LogHelper.Info($"推送任务{mst.S_CODE},没找到作业:{mst.S_OP_CODE}对应的出库任务", "NDC");
                        return false;
                    }
                    if (wcsTask.S_B_STATE=="未执行")
                    {
                        LogHelper.Info($"推送任务{mst.S_CODE},对应的Wcs出库任务未执行,暂不推送", "NDC");
                        return false;
                    }
                }
                start = LocationHelper.GetAgvSiteZc(mst.S_START_LOC);
                end = LocationHelper.GetAgvSiteZc(mst.S_END_LOC);
@@ -446,7 +467,26 @@
                ndcParme.Add(new param() { name = "From", value = start.ToString() });
                ndcParme.Add(new param() { name = "To", value = end.ToString() });
                ndcParme.Add(new param() { name = "FUNC", value = "0" });
                ndcParme.Add(new param() { name = "DATA", value = "0" });
                var work = TaskHelper.GetWmsWork(mst.S_OP_CODE);
                if (work==null)
                {
                    LogHelper.Info($"推送任务{mst.S_CODE},没找到作业:{mst.S_OP_CODE}", "NDC");
                    return false;
                }
                if (string.IsNullOrEmpty(work.CONNECTION))
                {
                    ndcParme.Add(new param() { name = "DATA", value = "0" });
                }
                else {
                    ndcParme.Add(new param() { name = "DATA", value = "768" });
                }
                ndcParme.Add(new param() { name = "Ctype", value = "0" });
@@ -1094,7 +1134,7 @@
                    result.success = false;
                    return result;
                }
                var endTask = TaskHelper.GetTaskByStartLoc(zd);
                var endTask = TaskHelper.GetTaskByEndLoc(zd);
                if (endTask != null)
                {
                    result.errMsg = "终点有执行中任务";
@@ -1263,9 +1303,6 @@
                }
                //托盘明细数量
                var cntrCount = 1;
@@ -1326,23 +1363,6 @@
                    //如果需要下发wcs立库,则需要寻找可用接驳位
                    if (workFlow.SENDWCS == "Y") {
                        //测试默认取一个接驳位
                        //var connectionList = LocationHelper.GetAllLocList1(workFlow.CONNECTION);
                        //foreach (var item in connectionList)
                        //{
                        //    if (item.S_LOCK_STATE == "无" && item.N_CURRENT_NUM < 2)
                        //    {
                        //        connection = item.S_CODE;
                        //        LogHelper.Info($"ZCSendTask入库任务下发寻找到可用接驳位{connection}", "Mes任务下发");
                        //    }
                        //}
                        //if (connection=="")
                        //{
                        //    LogHelper.Info($"ZCSendTask任务下发寻找接驳位失败", "Mes任务下发");
                        //    throw new Exception($"ZCSendTask任务下发寻找接驳位失败");
                        //}
                        //正式代码,调用接口寻找可用接驳位
                        var connectionList = LocationHelper.GetConnectionList(workFlow.CONNECTION);
@@ -1581,11 +1601,38 @@
                    LogHelper.Info($"ZCSendTask出库任务下发终点信息" + JsonConvert.SerializeObject(end), "Mes任务下发");
                    if (end == null || end.S_LOCK_STATE != "无")
                    if (end == null)
                    {
                        LogHelper.Info($"ZCSendTask出库任务下发失败,终点:{model.Location_To},没找到或有锁", "Mes任务下发");
                        throw new Exception($"终点:{model.Location_To},没找到或有锁");
                        LogHelper.Info($"ZCSendTask出库任务下发失败,终点:{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($"ZCSendTask出库任务下发失败,终点:{model.Location_To}有任务执行中,任务号:{endTask.S_CODE}", "Mes任务下发");
                            throw new Exception($"终点:{model.Location_To}有任务执行中,任务号:{endTask.S_CODE}");
                        }
                    }
                    //查找起点
@@ -1625,6 +1672,10 @@
                                    result.errMsg = "满托出库作业有库存但设备报警";
                                    result.errCode = 2001;
                                    result.success = true;
                                    mesRes.errCode = result.errCode;
                                    mesRes.errMsg = result.errMsg;
                                    //保存mes记录
                                    CreatMesRes(mesRes);
                                    return result;
                                }
                            }
@@ -1634,36 +1685,36 @@
                    }
                    else if (workFlow.FLOWCODE == "7") {
                        //寻找立库区空托
                        start = LocationHelper.FindStartcolByLoclistAndcntr(strrtList, workFlow.STARTAREA);
                        if (start == null)
                        {
                            strrtList = LocationHelper.GetAllLocList2(workFlow.STARTAREA);
                            var itemFlag = LocationHelper.FindStartcolByLoclistAndcntrFlag(strrtList, workFlow.STARTAREA);
                            LogHelper.Info($"ZCSendTask空托出库任务没找到起点,校验是否有库存但是设备报警{itemFlag}", "Mes任务下发");
                        //start = LocationHelper.FindStartcolByLoclistAndcntr(strrtList, workFlow.STARTAREA);
                        //if (start == null)
                        //{
                        //    strrtList = LocationHelper.GetAllLocList2(workFlow.STARTAREA);
                        //    var itemFlag = LocationHelper.FindStartcolByLoclistAndcntrFlag(strrtList, workFlow.STARTAREA);
                        //    LogHelper.Info($"ZCSendTask空托出库任务没找到起点,校验是否有库存但是设备报警{itemFlag}", "Mes任务下发");
                            if (itemFlag)
                        //    if (itemFlag)
                        //    {
                        //        result.errMsg = "空托出库作业有库存但设备报警";
                        //        result.errCode = 2001;
                        //        result.success = true;
                        //        return result;
                        //    }
                        //}
                        //空托出先缓存到空托表
                        //先查询有没有同终点缓存的记录
                        if (endLocFlag) {
                            var ktTask = TaskHelper.GetMesKtTask(end.S_CODE);
                            if (ktTask != null)
                            {
                                result.errMsg = "空托出库作业有库存但设备报警";
                                result.errCode = 2001;
                                result.success = true;
                                return result;
                                LogHelper.Info($"ZCSendTask空托出缓存失败,终点{end.S_CODE}已有缓存", "Mes任务下发");
                                throw new Exception($"ZCSendTask空托出缓存失败,终点{end.S_CODE}已有缓存");
                            }
                        }
                    }
                    LogHelper.Info($"ZCSendTask出库任务下发起点信息" + JsonConvert.SerializeObject(start), "Mes任务下发");
                    if (workFlow.FLOWCODE == "7" && start == null)
                    {
                        //空托出没找到起点,先缓存到空托表
                        //先查询有没有同终点未缓存的记录
                        var ktTask = TaskHelper.GetMesKtTask(end.S_CODE);
                        if (ktTask != null) {
                            throw new Exception($"ZCSendTask空托出缓存失败,终点{end.S_CODE}已有缓存");
                        }
                        MesKtTask req = new MesKtTask()
                        {
@@ -1672,7 +1723,8 @@
                            Priority = model.Priority,
                            CreateDate = DateTime.Now,
                            BUSI_TYPE = model.BUSI_TYPE,
                            TOOLS_TPYE = model.TOOLS_TPYE,
                            TOOLS_TPYE = TOOLSTYPE,
                            task_no=model.task_no,
                            Status = "N"
                        };
@@ -1682,6 +1734,10 @@
                            result.errMsg = "空托出库缓存成功";
                            result.errCode = 0;
                            result.success = true;
                            mesRes.errCode = result.errCode;
                            mesRes.errMsg = result.errMsg;
                            //保存mes记录
                            CreatMesRes(mesRes);
                            return result;
                        }
                        else
@@ -1689,17 +1745,17 @@
                            LogHelper.Info($"ZCSendTask空托出缓存失败", "Mes任务下发");
                            throw new Exception($"ZCSendTask空托出缓存失败");
                        }
                    }
                    else {
                        LogHelper.Info($"ZCSendTask出库任务下发起点信息" + JsonConvert.SerializeObject(start), "Mes任务下发");
                        if (start == null)
                        {
                            LogHelper.Info($"ZCSendTask出库任务下发失败,起点库区{workFlow.STARTAREA},没找到起点", "Mes任务下发");
                            throw new Exception($"起点库区{workFlow.STARTAREA},没找到起点");
                        }
                    }
                    
@@ -1708,23 +1764,6 @@
                    if (workFlow.SENDWCS == "Y")
                    {
                        //测试默认取一个接驳位
                        //var connectionList = LocationHelper.GetAllLocList1(workFlow.CONNECTION);
                        //foreach (var item in connectionList)
                        //{
                        //    if (item.S_LOCK_STATE == "无" && item.N_CURRENT_NUM < 2)
                        //    {
                        //        connection = item.S_CODE;
                        //        LogHelper.Info($"ZCSendTask入库任务下发寻找到可用接驳位{connection}", "Mes任务下发");
                        //    }
                        //}
                        //if (connection == "")
                        //{
                        //    LogHelper.Info($"ZCSendTask任务下发寻找接驳位失败", "Mes任务下发");
                        //    throw new Exception($"ZCSendTask任务下发寻找接驳位失败");
                        //}
                        //正式代码,调用接口寻找可用接驳位
                        var connectionList = LocationHelper.GetConnectionList(workFlow.CONNECTION);