mes接口修改

海波 张

2025-07-10 46dc31d4e66e45cde693b9c909691a710fabfcee

 dispatch/WcsTask.cs

@@ -598,7 +598,6 @@

            try
            {
            
                var taskNo = "";
            
                if (string.IsNullOrEmpty(model.requestPk))
@@ -617,6 +616,13 @@
                    LogHelper.Info($"未查询到{taskNo}对应的任务", "Wcs任务执行通知");
                    throw new Exception("未查询到对应的任务");
                }

                if (transportTask.S_B_STATE == "完成" || transportTask.S_B_STATE == "取消")
                {
                    throw new Exception($"{transportTask}任务已{transportTask.S_B_STATE}，不允许操作");
                }



                TaskHelper.WcsAddActionRecord(model.requestPk, model.noticeType, "WCS");

@@ -716,6 +722,10 @@
                                    }
                                    newDb.CommitTran();
                                }
                                else {
                                    LogHelper.Info($"RFID校验失败，通知Wcs取消任务失败", "Wcs任务执行通知");
                                    throw new Exception($"RFID校验失败，通知Wcs取消任务失败");
                                }
                            }
                            newDb.BeginTran();
                            var R = newDb.Insertable(RfidChek).ExecuteCommand();
@@ -734,11 +744,6 @@

                    //7取消
                    case "7":
                        if (transportTask.S_B_STATE=="完成")
                        {
                            throw new Exception($"{transportTask}任务已完成，不允许取消");
                        }

                        LogHelper.Info($"任务号{transportTask.S_CODE},取消任务成功", "Wcs任务执行通知");
                        TaskHelper.Fail(transportTask);
                        TaskProcess.OperateStatus(transportTask, 7);
@@ -770,11 +775,13 @@
            }
            catch (Exception ex)
            {
                newDb.RollbackTran();
               

                LogHelper.Info("Wcs任务执行通知异常" + ex.Message, "Wcs任务执行通知");
                result.msg = "Wcs任务执行通知异常";
                result.code = "1";
                result.requestPk = model.requestPk;
                LogHelper.Info("Wcs任务执行通知异常" + ex.Message, "Wcs任务执行通知");
                newDb.RollbackTran();
                return result;
            }
            return result;
@@ -1020,6 +1027,13 @@
                        bit = mst.S_END_LOC;
                    }
                   
                    //退库取消发agv起点
                    if (LocationHelper.GetErroArea(mst.S_END_AREA))
                    {
                        bit = mst.S_START_LOC;
                    }


                    Meshod = "AgvRequestCancel";
                    break;
            }
@@ -1208,8 +1222,11 @@
                            var agvTask = TaskHelper.GetTaskByWorkNo(task.S_OP_CODE, "agv");
                            if (agvTask != null)
                            {
                                TaskHelper.Fail(agvTask);
                                if (agvTask.S_B_STATE!="未执行")
                                {
                                NDCApi.CancelOrder(agvTask.S_CODE.Trim());
                                }
                                TaskHelper.Fail(agvTask);
                                TaskProcess.CacheBitCancelUpdate(agvTask);
                            }
                        }
@@ -1248,8 +1265,10 @@
                        }
                    }

                       

                        result.msg = "Wcs放货有货/取货无货处理成功";
                        result.code = "0";
                        result.requestPk = model.requestPk;
                        return result;
                    }
                    catch (Exception ex)
                    {
@@ -1272,7 +1291,6 @@
            public static WcsWarningReurn agvResponse(agvResponseParme model) {
            var result = new WcsWarningReurn();
            var newDb = new SqlHelper<object>().GetInstance();

            try
            {
                newDb.BeginTran();
@@ -1308,8 +1326,6 @@
                return result;
            }
        }
        

    }