From 69d68078402cd2029336a9e25fd78e4501bf2a80 Mon Sep 17 00:00:00 2001 From: whycq <913841844@qq.com> Date: 星期日, 23 六月 2024 10:14:33 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/phpsasrs' into phpsasrs --- src/main/java/com/zy/asrs/controller/MobileController.java | 193 ++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 187 insertions(+), 6 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/MobileController.java b/src/main/java/com/zy/asrs/controller/MobileController.java index 232ba46..00dff10 100644 --- a/src/main/java/com/zy/asrs/controller/MobileController.java +++ b/src/main/java/com/zy/asrs/controller/MobileController.java @@ -9,15 +9,13 @@ import com.core.common.R; import com.core.exception.CoolException; import com.zy.asrs.entity.*; -import com.zy.asrs.entity.param.CombParam; -import com.zy.asrs.entity.param.MobileAdjustParam; -import com.zy.asrs.entity.param.OffSaleParam; +import com.zy.asrs.entity.param.*; import com.zy.asrs.entity.result.MobileAdjustResult; import com.zy.asrs.mapper.ManLocDetlMapper; import com.zy.asrs.service.*; -import com.zy.common.model.LocDto; -import com.zy.common.model.TaskDto; import com.zy.common.model.WrkDto; +import com.zy.common.model.enums.WorkNoType; +import com.zy.common.service.CommonService; import com.zy.common.web.BaseController; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.transaction.annotation.Transactional; @@ -55,7 +53,12 @@ private PackService packService; @Autowired private ManLocDetlMapper manLocDetlMapper; - + @Autowired + private StaDescService staDescService; + @Autowired + private CommonService commonService; + @Autowired + private MatService matService; // 鍟嗗搧涓婃灦 @RequestMapping("/mat/onSale/auth") @@ -358,4 +361,182 @@ return mobileService.manDetlOut(json); } + @RequestMapping("/loc/f/list") + @ManagerAuth(memo = "鑾峰彇鍦ㄥ簱搴撲綅") + public R locNoF(@RequestParam(required = false) String locNo){ + Wrapper<LocMast> wrapper = new EntityWrapper<LocMast>().eq("loc_sts", "F"); + if (!Cools.isEmpty(locNo)) { + wrapper.like("loc_no", locNo); + } + List<LocMast> list = locMastService.selectList(wrapper); + return R.ok().add(list); + } + + @RequestMapping("/pick/sta/list") + @ManagerAuth(memo = "鑾峰彇骞舵澘绔�") + public R pickSta(){ + List<StaDesc> list = staDescService.selectList(new EntityWrapper<StaDesc>().eq("type_no",104)); + return R.ok().add(list); + } + + @RequestMapping("/pick/mat/list") + @ManagerAuth(memo = "鑾峰彇骞舵澘鐗╂枡") + public R pickMats(@RequestParam(required = false) String matnr){ + List<DocType> docTypes = docTypeService.selectList(new EntityWrapper<DocType>().like("doc_name", "鍏ュ簱")); + ArrayList<Long> typeList = new ArrayList<>(); + for (DocType docType : docTypes) { + typeList.add(docType.getDocId()); + } + + EntityWrapper<Order> wrapper = new EntityWrapper<>(); + wrapper.eq("status", 1); + wrapper.in("doc_type", typeList); + List<Order> orders = orderService.selectList(wrapper); + + ArrayList<Long> orderIds = new ArrayList<>(); + for (Order order : orders) { + orderIds.add(order.getId()); + } + + //鎼滅储鏄庣粏 + Wrapper<OrderDetl> wrapper1 = new EntityWrapper<OrderDetl>(); + wrapper1.eq("status", 1); + wrapper1.in("order_id", orderIds); + if (!Cools.isEmpty(matnr)) { + wrapper1.like("matnr", matnr); + } + + List<OrderDetl> list = orderDetlService.selectList(wrapper1); + + ArrayList<PickMatParam> maps = new ArrayList<>(); + for (OrderDetl orderDetl : list) { + //鍓╀綑鍙敤鏁伴噺 + double count = orderDetl.getAnfme() - orderDetl.getWorkQty(); + if (count <= 0) { + continue; + } + + PickMatParam matParam = new PickMatParam(); + matParam.setMatnr(orderDetl.getMatnr()); + matParam.setBatch(orderDetl.getBatch()); + matParam.setOrderNo(orderDetl.getOrderNo()); + matParam.setOrderId(orderDetl.getOrderId()); + matParam.setCount(count); + matParam.setUseCount(0D); + maps.add(matParam); + } + return R.ok().add(maps); + } + + @RequestMapping("/pick/in") + @ManagerAuth(memo = "骞舵澘鍏ュ簱") + @Transactional + public R pickConfirm(@RequestBody PickConfirmParam param){ + LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", param.getLocNo())); + if (!locMast.getLocSts().equals("F")) { + return R.error("搴撲綅鐘舵�佷笉鏄湪搴�"); + } + + StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>() + .eq("type_no", 104) + .eq("stn_no", param.getStaNo())); + if (staDesc == null) { + return R.error("绔欑偣涓嶅瓨鍦�"); + } + + //妫�楠屼紶鍙傛槸鍚﹀拰璁㈠崟鏄庣粏鍖归厤 + for (PickMatParam matParam : param.getList()) { + Wrapper<OrderDetl> wrapper = new EntityWrapper<OrderDetl>() + .eq("order_no", matParam.getOrderNo()) + .eq("status", 1) + .eq("matnr", matParam.getMatnr()); + if (!Cools.isEmpty(matParam.getBatch())) { + wrapper.eq("batch", matParam.getBatch()); + } + OrderDetl orderDetl = orderDetlService.selectOne(wrapper); + if (orderDetl == null) { + return R.error("鐗╂枡鏁版嵁涓嶅瓨鍦�"); + } + + //鍓╀綑鍙敤鏁伴噺 + double count = orderDetl.getAnfme() - orderDetl.getWorkQty(); + if (matParam.getCount() != count) { + return R.error("鐗╂枡鏁版嵁宸茶繃鏈�"); + } + + if (matParam.getUseCount() > count) { + return R.error("鍙敤鏁伴噺涓嶈冻"); + } + } + + Date now = new Date(); + // 鐢熸垚宸ヤ綔鍙� + int workNo = commonService.getWorkNo(WorkNoType.getWorkNoType(104)); + // 鐢熸垚宸ヤ綔妗� + WrkMast wrkMast = new WrkMast(); + wrkMast.setWrkNo(workNo); + wrkMast.setIoTime(now); + wrkMast.setWrkSts(101L); // 宸ヤ綔鐘舵�侊細101.鐢熸垚鍑哄簱 + wrkMast.setIoType(104); // 鍏ュ嚭搴撶姸鎬� + wrkMast.setIoPri(13D); // 浼樺厛绾э細13 + wrkMast.setSourceStaNo(staDesc.getCrnStn()); // 婧愮珯 + wrkMast.setStaNo(staDesc.getStnNo()); // 鐩爣绔� + wrkMast.setSourceLocNo(param.getLocNo()); // 婧愬簱浣� + wrkMast.setFullPlt("Y"); // 婊℃澘锛歒 + wrkMast.setPicking("Y"); // 鎷f枡 + wrkMast.setExitMk("N"); // 閫�鍑� + wrkMast.setEmptyMk("N"); // 绌烘澘 + wrkMast.setBarcode(locMast.getBarcode()); + wrkMast.setAppeUser(getUserId()); // 鎿嶄綔浜哄憳鏁版嵁 + wrkMast.setAppeTime(now); + wrkMast.setModiUser(getUserId()); + wrkMast.setModiTime(now); + wrkMast.setCrnNo(staDesc.getCrnNo()); + if (!wrkMastService.insert(wrkMast)) { + throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐ワ紝鍑哄簱搴撲綅鍙凤細" + param.getLocNo()); + } + // 鐢熸垚宸ヤ綔妗f槑缁� + for (PickMatParam matParam : param.getList()) { + EntityWrapper<Mat> wrapper = new EntityWrapper<>(); + wrapper.eq("status", 1); + wrapper.eq("matnr", matParam.getMatnr()); + Mat mat = matService.selectOne(wrapper); + if (mat == null) { + throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐ワ紝鐗╂枡淇℃伅涓嶅瓨鍦細" + matParam.getMatnr()); + } + + WrkDetl wrkDetl = new WrkDetl(); + wrkDetl.sync(mat); + wrkDetl.setOrderNo(matParam.getOrderNo()); + wrkDetl.setWrkNo(workNo); + wrkDetl.setZpallet(wrkMast.getBarcode()); + wrkDetl.setIoTime(now); + wrkDetl.setAnfme(matParam.getUseCount()); // 鏁伴噺 + wrkDetl.setAppeTime(now); + wrkDetl.setAppeUser(getUserId()); + wrkDetl.setModiTime(now); + wrkDetl.setModiUser(getUserId()); + if (!wrkDetlService.insert(wrkDetl)) { + throw new CoolException("淇濆瓨宸ヤ綔妗f槑缁嗗け璐�"); + } + + //鏇存柊璁㈠崟宸ヤ綔鏁伴噺 + orderDetlService.increaseWorkQtyByOrderNo(matParam.getOrderNo(), matParam.getMatnr(), matParam.getBatch(), matParam.getUseCount()); + } + // 淇敼搴撲綅鐘舵��: F.鍦ㄥ簱 ====>>> R.鍑哄簱棰勭害/P.鎷f枡/鐩樼偣/骞舵澘鍑哄簱涓� + locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", param.getLocNo())); + if (locMast.getLocSts().equals("F")) { + locMast.setLocSts("P"); + locMast.setModiUser(getUserId()); + locMast.setModiTime(now); + if (!locMastService.updateById(locMast)) { + throw new CoolException("棰勭害搴撲綅鐘舵�佸け璐ワ紝搴撲綅鍙凤細" + param.getLocNo()); + } + } else { + throw new CoolException(param.getLocNo() + "搴撲綅涓嶆槸鍦ㄥ簱鐘舵��"); + } + + return R.ok(); + } + } -- Gitblit v1.9.1