From 75d0daa4f8dc2010ec92f35cac08a19d240ca45d Mon Sep 17 00:00:00 2001 From: ynhfasrs <ynhfasrs@qq.com> Date: 星期五, 27 六月 2025 14:23:37 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java | 122 ++++++++++++++++++++++++++++++---------- 1 files changed, 91 insertions(+), 31 deletions(-) diff --git a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java index cd5f403..4986366 100644 --- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java @@ -2,9 +2,12 @@ import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.core.common.Cools; +import com.core.common.R; import com.zy.asrs.domain.enums.TaskStatusType; import com.zy.asrs.domain.enums.WorkNoType; import com.zy.asrs.entity.*; +import com.zy.asrs.entity.param.CrnStatusParam; +import com.zy.asrs.entity.param.StationStatusParam; import com.zy.asrs.entity.param.TaskCreateInParam; import com.zy.asrs.entity.param.TaskCreateParam; import com.zy.asrs.service.*; @@ -23,15 +26,18 @@ private CommonService commonService; @Autowired private LocMastService locMastService; + @Autowired + private BasDevpService basDevpService; + @Autowired + private BasCrnpService basCrnpService; + @Autowired + private BasCrnErrorService basCrnErrorService; @Override - public HashMap<String, Object> taskCreate(TaskCreateParam param) { - HashMap<String,Object> map=new HashMap<>(); + public R taskCreate(TaskCreateParam param) { TaskWrk taskWrk = taskWrkService.selectByTaskNo(param.getTaskNo()); if (taskWrk != null) { - map.put("Code","0"); - map.put("Msg",param.getTaskNo()+"浠诲姟宸茬粡鐢熸垚锛�"); - return map; + return R.error(param.getTaskNo() + "浠诲姟宸茬粡鐢熸垚锛�"); } Date now = new Date(); @@ -42,14 +48,6 @@ taskWrk.setWrkNo(workNo1); taskWrk.setStatus(TaskStatusType.RECEIVE.id);//浠诲姟鐘舵�侊細鎺ユ敹 taskWrk.setCreateTime(now); - try { - if (param.getIoType() > 1) { - if (Utils.locNoRowBoolean(locMast.getRow1())) { - param.setTaskPriority(11); - } - } - } catch (Exception e) { - } taskWrk.setIoType(param.getIoType());//浠诲姟绫诲瀷 taskWrk.setIoPri(param.getTaskPriority());//浼樺厛绾� taskWrk.setBarcode(param.getBarcode());//鏉$爜 @@ -68,42 +66,60 @@ taskWrk.setTargetPoint(param.getTargetPoint()); } taskWrk.setTargetPoint(param.getTargetPoint()); + + locMast.setLocSts("R"); + locMast.setModiTime(new Date()); + locMastService.updateById(locMast); + } else if (param.getIoType() == 3) { taskWrk.setWrkSts(11); if (!Cools.isEmpty(param.getStartPoint())) { taskWrk.setStartPoint(param.getStartPoint());//璧风偣 taskWrk.setTargetPoint(param.getTargetPoint()); } - } + locMast.setLocSts("R"); + locMast.setModiTime(new Date()); + locMastService.updateById(locMast); + + LocMast locMast2 = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", param.getTargetPoint())); + locMast2.setLocSts("S"); + locMast2.setModiTime(new Date()); + locMastService.updateById(locMast2); + } if (!Cools.isEmpty(param.getMemo())) { taskWrk.setMemo(param.getMemo());//澶囨敞 } if (!taskWrkService.insert(taskWrk)) { - map.put("Code","0"); - map.put("Msg",param.getTaskNo()+"鍒涘缓浠诲姟澶辫触锛�"); - return map; + return R.error(param.getTaskNo() + "鍒涘缓浠诲姟澶辫触锛�"); } - map.put("Code","1"); - map.put("Msg","ok"); - return map; + return R.ok(); } @Override - public HashMap<String, Object> taskCreateIn(TaskCreateInParam param) { - HashMap<String, Object> map = new HashMap<>(); + public R taskCreateIn(TaskCreateInParam param) { TaskWrk taskWrk = taskWrkService.selectByTaskNo(param.getTaskNo()); if (taskWrk != null) { - map.put("Code","0"); - map.put("Msg", param.getTaskNo() + "浠诲姟宸茬粡鐢熸垚锛�"); - return map; + return R.error(param.getTaskNo() + "浠诲姟宸茬粡鐢熸垚锛�"); } Date now = new Date(); taskWrk = new TaskWrk(); LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", param.getTargetPoint())); + if (locMast == null) { + return R.error(param.getTaskNo() + "搴撲綅涓嶅瓨鍦紒"); + } + + if (!locMast.getLocSts().equals("O")) { + return R.error(param.getTaskNo() + "搴撲綅涓嶅浜庣┖搴撲綅锛�"); + } + + locMast.setLocSts("S"); + locMast.setModiTime(new Date()); + locMastService.updateById(locMast); + int workNo1 = commonService.getWorkNo(WorkNoType.PAKIN.type);//鑾峰彇鍏ュ簱宸ヤ綔鍙� taskWrk.setTaskNo(param.getTaskNo());//浠诲姟鍙� taskWrk.setWrkNo(workNo1); @@ -121,12 +137,56 @@ } if (!taskWrkService.insert(taskWrk)) { - map.put("Code", "0"); - map.put("Msg", param.getTaskNo() + "鍒涘缓浠诲姟澶辫触锛�"); - return map; + return R.error(param.getTaskNo() + "鍒涘缓浠诲姟澶辫触锛�"); } - map.put("Code","1"); - map.put("Msg","ok"); - return map; + return R.ok(); + } + + @Override + public List<StationStatusParam> getStationStatus() { + List<StationStatusParam> data = new ArrayList<>(); + List<BasDevp> list = basDevpService.selectList(new EntityWrapper<BasDevp>() + .in("dev_no", 102, 104, 106, 108, 203, 206, 209, 212)); + for (BasDevp basDevp : list) { + String taskNo = ""; + String barcode = ""; + if (basDevp.getWrkNo() > 0) { + TaskWrk taskWrk = taskWrkService.selectByWrkNo(basDevp.getWrkNo()); + if (taskWrk != null) { + taskNo = taskWrk.getTaskNo(); + barcode = taskWrk.getBarcode(); + } + } + + StationStatusParam param = new StationStatusParam(); + param.setStaNo(basDevp.getDevNo()); + param.setTaskNo(taskNo); + param.setLoading(basDevp.getLoading()); + param.setBarcode(barcode); + + data.add(param); + } + return data; + } + + @Override + public List<CrnStatusParam> getCrnStatus() { + List<CrnStatusParam> crnStatusParams = new ArrayList<>(); + List<BasCrnp> basCrnps = basCrnpService.selectList(new EntityWrapper<>()); + for (BasCrnp basCrnp:basCrnps){ + CrnStatusParam crnStatusParam=new CrnStatusParam(); + crnStatusParam.setCrnNo(basCrnp.getCrnNo()); + crnStatusParam.setCrnSts(basCrnp.getCrnSts()); + crnStatusParam.setErrorCode(basCrnp.getCrnErr()); + BasCrnError error=basCrnErrorService.selectOne(new EntityWrapper<BasCrnError>().eq("error_code",basCrnp.getCrnErr())); + if(Cools.isEmpty(error)){ + crnStatusParam.setErrorMsg(""); + }else { + crnStatusParam.setErrorMsg(error.getErrName()); + } + crnStatusParams.add(crnStatusParam); + } + + return crnStatusParams; } } -- Gitblit v1.9.1