From 37f97c17a695aacd4f658eb86483558ba62374cd Mon Sep 17 00:00:00 2001 From: lsh <lsh@163.com> Date: 星期五, 31 五月 2024 17:56:13 +0800 Subject: [PATCH] #1 --- src/main/java/com/zy/asrs/controller/AgvOpenController.java | 58 +++++++++++++++++++++++++++++++++++++++++----------------- 1 files changed, 41 insertions(+), 17 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/AgvOpenController.java b/src/main/java/com/zy/asrs/controller/AgvOpenController.java index f6439dd..bb077b8 100644 --- a/src/main/java/com/zy/asrs/controller/AgvOpenController.java +++ b/src/main/java/com/zy/asrs/controller/AgvOpenController.java @@ -6,7 +6,10 @@ import com.core.annotations.AppAuth; import com.core.common.Cools; import com.core.common.R; +import com.zy.asrs.entity.AgvBasDevp; +import com.zy.asrs.entity.AgvLocMast; import com.zy.asrs.entity.AgvWrkMast; +import com.zy.asrs.entity.WrkMastExecute; import com.zy.asrs.entity.param.AgvTaskCallBackParam; import com.zy.asrs.service.*; import com.zy.asrs.utils.AppAuthUtil; @@ -53,6 +56,10 @@ AgvWrkMastService agvWrkMastService; @Autowired ApiLogService apiLogService; + @Autowired + private WrkMastExecuteService wrkMastExecuteService; + @Autowired + private AgvBasDevpService agvBasDevpService; @PostMapping("/task/event/status") @AppAuth(memo = "ESS浠诲姟鍥炶皟") @@ -83,24 +90,41 @@ return R.error("浠诲姟缂栧彿閿欒"); } } + if (agvWrkMast.getIoType().equals(121)){ + try{ + if (agvWrkMast.getWrkSts().equals(12L)){ + WrkMastExecute wrkMastExecute = wrkMastExecuteService.selectOne(new EntityWrapper<WrkMastExecute>().eq("wrk_no", wrkNo)); + if (Cools.isEmpty(wrkMastExecute) || wrkMastExecute.getWrkSts()!=1){ + return R.error("浠诲姟鐘舵�乄rkSts鍙傛暟鏈夎,WrkSts:"+wrkMastExecute.getWrkSts$()); + } else { + wrkMastExecute.setWrkSts(wrkMastExecute.getWrkStsCode()); + wrkMastExecuteService.updateById(wrkMastExecute); + } + }else { + return R.error("浠诲姟寮傚父"); + } + }catch (Exception e){ + return R.error(""+e.getMessage()); + } + }else { + if(agvWrkMast.getWrkSts() >= 205){ + return R.error("褰撳墠浠诲姟宸插畬鎴�"); + } - if(agvWrkMast.getWrkSts() >= 205){ - return R.error("褰撳墠浠诲姟宸插畬鎴�"); - } - - AgvTask agvTask = AgvTask.valueOf(param.getMethod()); - Class<AgvTask> clz = AgvTask.class; - try { - Method method = clz.getDeclaredMethod("success", AgvWrkMast.class, AgvTaskCallBackParam.class); - method.invoke(agvTask,agvWrkMast,param); - } catch (NoSuchMethodException e) { - return R.error("浠诲姟鐘舵�乻tatus鍙傛暟鏈夎"); - } catch (InvocationTargetException e) { - log.error(e.getMessage()); - return R.error(); - } catch (IllegalAccessException e) { - log.error(e.getMessage()); - return R.error(); + AgvTask agvTask = AgvTask.valueOf(param.getMethod()); + Class<AgvTask> clz = AgvTask.class; + try { + Method method = clz.getDeclaredMethod("success", AgvWrkMast.class, AgvTaskCallBackParam.class); + method.invoke(agvTask,agvWrkMast,param); + } catch (NoSuchMethodException e) { + return R.error("浠诲姟鐘舵�乻tatus鍙傛暟鏈夎"); + } catch (InvocationTargetException e) { + log.error(e.getMessage()); + return R.error(); + } catch (IllegalAccessException e) { + log.error(e.getMessage()); + return R.error(); + } } return new R(0, "鎴愬姛"); } -- Gitblit v1.9.1