From f25bd904560faada2a00e93fbd8abab6be238f9c Mon Sep 17 00:00:00 2001 From: lsh <lsh@163.com> Date: 星期二, 15 四月 2025 15:44:31 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/controller/MobileController.java | 521 ++++++++++++++++++++++++++++++++++++++++++++++++++------- 1 files changed, 457 insertions(+), 64 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/MobileController.java b/src/main/java/com/zy/asrs/controller/MobileController.java index ef13ebd..42d7241 100644 --- a/src/main/java/com/zy/asrs/controller/MobileController.java +++ b/src/main/java/com/zy/asrs/controller/MobileController.java @@ -1,23 +1,27 @@ package com.zy.asrs.controller; +import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.mapper.EntityWrapper; +import com.baomidou.mybatisplus.mapper.Wrapper; import com.core.annotations.ManagerAuth; import com.core.common.BaseRes; import com.core.common.Cools; 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.*; +import com.zy.asrs.entity.result.MobileAdjustResult; +import com.zy.asrs.mapper.ManLocDetlMapper; import com.zy.asrs.service.*; -import com.zy.common.model.MobileLocDetlVo; +import com.zy.asrs.utils.OrderInAndOutUtil; +import com.zy.common.model.WrkDto; import com.zy.common.web.BaseController; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.web.bind.annotation.RequestBody; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RequestParam; -import org.springframework.web.bind.annotation.RestController; +import org.springframework.transaction.annotation.Transactional; +import org.springframework.web.bind.annotation.*; -import java.util.ArrayList; -import java.util.List; +import javax.annotation.Resource; +import java.util.*; /** * 绉诲姩绔帴鍙f帶鍒跺櫒 @@ -34,83 +38,472 @@ @Autowired private LocDetlService locDetlService; @Autowired - private OrderService orderService; - @Autowired private DocTypeService docTypeService; + @Autowired + private WrkMastService wrkMastService; + @Autowired + private WrkDetlService wrkDetlService; + @Autowired + private BasDevpService basDevpService; + @Autowired + private PackService packService; + @Autowired + private ManLocDetlMapper manLocDetlMapper; + @Autowired + private WrkDetlLogService wrkDetlLogService; - /** - * 鏍规嵁鍗曞彿妫�绱㈠崟鎹暟鎹� - * http://localhost:8081/jkwms/mobile/order/serach/orderNo/auth?orderNo=123123 - */ + @Resource + private StaDescService staDescService; + + @RequestMapping("/pda/WarehouseOut/v1") + @ManagerAuth(memo = "骞舵澘閫斾腑鎷f枡-鍙傝�冨康鍒�") + public R WarehouseOutV1(@RequestBody CombParam combParam) { + return mobileService.WarehouseOutV1(combParam, getHostId(), getUserId()); + } + + @RequestMapping("/pda/WarehouseOutPickMerge/v1") + @ManagerAuth(memo = "鎷f枡閫斾腑骞舵澘") + public R WarehouseOutPickMergeV1(@RequestBody WarehouseOutPickMergeParam param) { + if (Cools.isEmpty(param,param.getLocNo(),param.getBarcode(),param.getCombMats())) { + return R.parse("鍙傛暟涓嶈兘涓虹┖锛�"); + } + return mobileService.WarehouseOutPickMergeV1(param, getHostId(), getUserId()); + } + + @RequestMapping("/pick/in") + @ManagerAuth(memo = "骞舵澘鍏ュ簱") + public R pickConfirm(@RequestBody PickConfirmParam param) { + + if(Cools.isEmpty(param,param.getList(),param.getLocNo(),param.getStaNo())) { + return R.parse("鍙傛暟涓嶅畬鏁�"); + } + return mobileService.pickConfirm(param, getUserId()); + } + + @RequestMapping("/barcode/list/all") + @ManagerAuth(memo = "骞舵澘鍏ュ簱閫斾腑鎷f枡鍑哄簱鑾峰彇浠诲姟淇℃伅") + public R orderOutListOrder(@RequestParam(required = false) String barcode) { + return mobileService.orderOutListOrder(barcode, getUserId()); + } + + @RequestMapping("/barcode/list/pick") + @ManagerAuth(memo = "鎷f枡鍏ュ簱閫斾腑骞舵澘鑾峰彇浠诲姟淇℃伅") + public R orderOutListOrderPick(@RequestParam(required = false) String barcode) { + return mobileService.orderOutListOrderPick(barcode, getUserId()); + } + + @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, @RequestParam(required = false) String orderNo) { + return mobileService.pickMats(matnr, orderNo); + } + + // 鍟嗗搧涓婃灦 + @RequestMapping("/mat/onSale/auth") + @ManagerAuth + public R matOnSale(@RequestBody CombParam combParam){ + mobileService.onSale(combParam); + return R.ok("涓婃灦鎴愬姛"); + } + // 鍟嗗搧涓嬫灦 + @RequestMapping("/mat/offSale/auth") + //@ManagerAuth + public R matOffSale(@RequestBody OffSaleParam offSaleParam){ + mobileService.offSale(offSaleParam); + return R.ok("涓嬫灦鎴愬姛"); + } + @RequestMapping("/order/search/orderNo/auth") @ManagerAuth public R orderSearchByBarcode(@RequestParam String orderNo){ - Order order = orderService.selectByNo(orderNo); - if (order == null) { + if (Cools.isEmpty(orderNo)){ + orderNo=null; + } +// List<Order> orders = orderService.selectorderNoL(orderNo); + List<Order> orders = OrderInAndOutUtil.selectOrderNoL(null, orderNo); + if (Cools.isEmpty(orders)){ return R.ok(); } - DocType docType = docTypeService.selectById(order.getDocType()); - if (docType.getPakin() == null || docType.getPakin() != 1) { - return R.ok(); - } - if (order.getSettle() > 2) { - return R.ok(); - } - List<OrderDetl> orderDetls = orderService.selectWorkingDetls(order.getId()); - if (Cools.isEmpty(orderDetls)) { - return R.ok(); - } - return R.ok().add(orderDetls); - } + LinkedList<CombParam> combParams = new LinkedList<>(); + if (!Cools.isEmpty(orders)){ + for (Order order:orders){ + CombParam combParam=new CombParam(); + if (order == null) { + continue; + } + DocType docType = docTypeService.selectById(order.getDocType()); + if (docType.getPakin() == null || docType.getPakin() != 1) { + continue; + } + if (order.getSettle() > 2) { + continue; + } +// List<OrderDetl> orderDetls = orderService.selectWorkingDetls(order.getId()); + List<OrderDetl> orderDetls = OrderInAndOutUtil.selectWorkingDetls(order.getPakinPakoutStatus$(), order.getId()); + if (!Cools.isEmpty(orderDetls)) { + LinkedList<CombParam.CombMat> combMats = new LinkedList<>(); + for (OrderDetl orderDetl:orderDetls){ + CombParam.CombMat combMat = new CombParam.CombMat(); + combMat.setMatnr(orderDetl.getMatnr()); + combMat.setBatch(orderDetl.getBatch()); + combMat.setAnfme(orderDetl.getAnfme()-orderDetl.getWorkQty()); + combMat.setMaktx(orderDetl.getMaktx()); + combMat.setSpecs(orderDetl.getSpecs()); + combMat.setBrand(orderDetl.getBrand()); + combMat.setSku(orderDetl.getSku()); + combMat.setMemo(orderDetl.getMemo()); + combMat.setBoxType1(orderDetl.getBoxType1()); + combMat.setBoxType2(orderDetl.getBoxType2()); + combMat.setBoxType3(orderDetl.getBoxType3()); + combMat.setStandby1(orderDetl.getStandby1()); + combMat.setStandby2(orderDetl.getStandby2()); + combMat.setStandby3(orderDetl.getStandby3()); + combMats.add(combMat); + } + combParam.setCombMats(combMats); + } + combParam.setOrderNo(order.getOrderNo()); + return R.ok().add(combParam); +// combParams.add(combParam); + } + } + return R.ok().add(combParams); + } @RequestMapping("/comb/auth") @ManagerAuth(memo = "缁勬墭") public R comb(@RequestBody CombParam combParam){ +// mobileService.comb(combParam, getUserId()); mobileService.comb(combParam, getUserId()); return R.ok("缁勬墭鎴愬姛"); } + @RequestMapping("/kitting/query/auth") + @ManagerAuth(memo = "榻愬鍏ュ簱鏌ヨ") + public R kittingQuery(@RequestBody CombParam combParam){ + try { + return mobileService.kittingQuery(combParam, getUserId()); + } catch (Exception e){ + + } +// return R.ok("榻愬鍏ュ簱鏌ヨ鎴愬姛"); + return R.error("榻愬鍏ュ簱鏌ヨ澶辫触"); + } + + @RequestMapping("/kitting/call/auth") + @ManagerAuth(memo = "榻愬鍏ュ簱鍛煎彨") + public R kittingCall(@RequestParam("locNo") String locNo){ + mobileService.kittingCall(locNo, getUserId()); + return R.ok("榻愬鍏ュ簱鍛煎彨鎴愬姛"); + } + + @RequestMapping("/kitting/call/all/auth")//瀵� 鍓嶇鏀逛笉浜嗕竴鐐� + @ManagerAuth(memo = "榻愬鍏ュ簱鍛煎彨") + public R kittingCall(@RequestBody CombParam combParam){ + List<CombParam.CombMat> combMats = combParam.getCombMats(); + for (CombParam.CombMat locDetl : combMats) { + mobileService.kittingCall(locDetl.getMemo(), getUserId()); + } + return R.ok("榻愬鍏ュ簱鍛煎彨鎴愬姛"); + } + @RequestMapping("/loc/origin/query/auth") + @ManagerAuth(memo = "搴撳瓨鏌ヨ") + public R locOriginQuery(@RequestParam("barcode") String barcode){ + List<LocDetl> locDetlList = locDetlService.selectList(new EntityWrapper<LocDetl>().eq("zpallet", barcode)); + return R.ok("鍦ㄥ簱鏍囪淇敼鎴愬姛").add(locDetlList); + } + @RequestMapping("/loc/origin/in/out/auth") + @ManagerAuth(memo = "鍦ㄥ簱鏍囪淇敼") + public R locOriginInOut(@RequestBody LocDetl locDetl){ + return mobileService.locOriginInOut(locDetl, getUserId()); + } + + @RequestMapping("/pack/get/auth") + @ManagerAuth + public R packGet(@RequestParam String barcode){ + Pack pack = packService.selectByBarcode(barcode); + if (pack == null) { + return R.ok(); + } + if (pack.getSettle() == 1L) { + return R.ok().add(pack); + } + return R.ok("缁勬墭鎴愬姛"); + } + + @RequestMapping("/pack/comb/auth") + @ManagerAuth(memo = "涓嬬嚎缁勬墭") + public R packComb(@RequestBody CombParam combParam){ + mobileService.packComb(combParam, getUserId()); + return R.ok("缁勬墭鎴愬姛"); + } + + + // 鍑哄簱 --------------------------------------------------------------------------------------------------- + + @RequestMapping("/pakout/query/auth") + @ManagerAuth + @Deprecated + public R pakoutQuery(@RequestParam(required = false) String barcode, + @RequestParam(required = false) Integer staNo, + @RequestParam(required = false) String matnr){ + if (Cools.isEmpty(barcode) && Cools.isEmpty(matnr)) { + return R.ok(); + } + if (!Cools.isEmpty(barcode)) { + List<WrkDetl> wrkDetls = wrkDetlService.selectList(new EntityWrapper<WrkDetl>().eq("zpallet", barcode)); + return R.ok().add(wrkDetls); + } + if (!Cools.isEmpty(matnr)) { + if (!Cools.isEmpty(staNo)) { + List<WrkDetl> wrkDetls = wrkDetlService.selectPakoutQuery(staNo, matnr); + return R.ok().add(wrkDetls); + } + } + return R.ok(); + } /** - * 鏍规嵁搴撲綅鍙锋煡鎵惧簱瀛樻槑缁� + * 鍑哄簱纭 - 鎵墭鐩樼爜 + * 1.鍏ㄦ澘 杩斿洖 101 + * 2.鎷f枡 杩斿洖 103 */ - @RequestMapping("/locDetl") + @RequestMapping("/pakout/confirm/barcode/auth") @ManagerAuth - public R getLocDetl(@RequestParam(required = false)String locNo, - @RequestParam(required = false)String matNo){ - if (!Cools.isEmpty(locNo)) { - LocMast locMast = locMastService.selectById(locNo); - if (null == locMast || !"F".equals(locMast.getLocSts())) { - return R.parse(BaseRes.EMPTY); - } - List<LocDetl> locDetls = locDetlService.selectList(new EntityWrapper<LocDetl>() - .eq("loc_no", locNo).orderBy("appe_time", false)); - List<MobileLocDetlVo> res = new ArrayList<>(); - locDetls.forEach(locDetl -> { - MobileLocDetlVo vo = new MobileLocDetlVo(); - vo.setLocNo(locDetl.getLocNo()); - vo.setMatnr(locDetl.getMatnr()); - vo.setMaktx(locDetl.getMaktx()); - vo.setCount(locDetl.getAnfme()); - res.add(vo); - }); - return R.ok().add(res); + public R pakoutQueryByBarcode(@RequestParam(required = false) String barcode){ + if (Cools.isEmpty(barcode)) { + return R.ok(); } - if (!Cools.isEmpty(matNo)) { - List<LocDetl> locDetls = locDetlService.selectList(new EntityWrapper<LocDetl>() - .eq("matnr", matNo).orderBy("appe_time", false)); - List<MobileLocDetlVo> res = new ArrayList<>(); - locDetls.forEach(locDetl -> { - MobileLocDetlVo vo = new MobileLocDetlVo(); - vo.setLocNo(locDetl.getLocNo()); - vo.setMatnr(locDetl.getMatnr()); - vo.setMaktx(locDetl.getMaktx()); - vo.setCount(locDetl.getAnfme()); - res.add(vo); - }); - return R.ok().add(res); + WrkMast wrkMast = wrkMastService.selectByBarcode(barcode); + if (wrkMast != null) { + List<WrkDetl> wrkDetls = wrkDetlService.selectByWrkNo(wrkMast.getWrkNo()); + // 鍘婚櫎宸插嚭搴撶‘璁ょ殑鏄庣粏 + wrkDetls.removeIf(wrkDetl -> wrkDetl.getInspect() != null && wrkDetl.getInspect() != 0); + return R.ok().add(Cools.add("wrkNo", wrkMast.getWrkNo()).add("ioType", wrkMast.getIoType()).add("list", wrkDetls)); } - return R.parse(BaseRes.PARAM); + return R.ok(); } + + /** + * 鍑哄簱纭 - 鎵揣鐗� 骞垮痉瀹滅鐗� + * 1.鍏ㄦ澘 杩斿洖 101 + * 2.鎷f枡 杩斿洖 103 + */ + @RequestMapping("/pakout/confirm/goods/auth") //寰呭畬鍠� 鍘熷洜锛堝鎴锋湭缁欏嚭璇︾粏淇℃伅锛� + @ManagerAuth + public R pakoutQueryByGoods(@RequestBody GDYKConfirmGoodsParam combParam){ + if (Cools.isEmpty(combParam)) { + return R.ok(); + } +// List<Order> orders = orderService.selectorderNoL(batch); +// OrderDetl orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>().eq("matnr", combParam.getMatnr()).eq("batch", combParam.getBatch()).eq("order_no",combParam.getOrderNo())); + Order order = OrderInAndOutUtil.selectByNo(Boolean.FALSE, combParam.getOrderNo()); + List<OrderDetl> orderDetlList = OrderInAndOutUtil.selectByOrderId(Boolean.FALSE, order.getId()); + OrderDetl orderDetl = null; + for (OrderDetl orderDetl1 : orderDetlList){ + if (combParam.getMatnr().equals(orderDetl1.getMatnr()) && combParam.getBatch().equals(orderDetl1.getBatch())){ + orderDetl = orderDetl1; + break; + } + } + if (Cools.isEmpty(orderDetl)){ + return R.error("鏈煡鍒版暟鎹�"); + } + if (!orderDetl.getQty$().equals("宸插畬鎴�")){ + return R.error("浠诲姟鏈畬鎴�"); + } + //澶嶆牳鏁� + orderDetl.setSource(1); +// orderDetlService.updateById(orderDetl); + OrderInAndOutUtil.updateOrderDetl(Boolean.FALSE,order,orderDetl); + return R.ok(); + } + + // 鏍规嵁搴撲綅鐮佸拰鍟嗗搧鐮佹悳绱㈠晢鍝� + @RequestMapping("/mat/find/auth") + public R find(@RequestParam(required = false) String locNo + , @RequestParam(required = false) String matnr){ + //List<ManLocDetl> manLocDetls = manLocDetlMapper.selectItem0(locNo, matnr); + ManLocDetl manLocDetl = manLocDetlMapper.selectLocNo0(locNo, matnr); + return R.ok(manLocDetl); + //return R.ok(manLocDetlMapper.selectItem0(locNo, matnr)); + } + + /** + * 鍑哄簱纭 - 鎷f枡鍑哄簱 - 閫夋嫨鍏蜂綋鏉$爜鍟嗗搧 + */ + @RequestMapping("/pakout/confirm/pick/auth") + @ManagerAuth + public R pakoutQueryByBarcode(@RequestParam(required = false) Integer wrkNo + , @RequestParam(required = false) String matnr){ + if (Cools.isEmpty(wrkNo)) { + return R.ok(); + } + if (Cools.isEmpty(matnr)) { + return R.ok(); + } + WrkMast wrkMast = wrkMastService.selectById(wrkNo); + if (wrkMast == null) { + return R.ok(); + } + String orderNo = null; + List<WrkDetl> wrkDetls = wrkDetlService.selectByWrkNo(wrkMast.getWrkNo()); + for (WrkDetl wrkDetl : wrkDetls) { + if (Cools.isEmpty(orderNo)) { + orderNo = wrkDetl.getOrderNo(); + } + if ((wrkDetl.getMatnr() + "-" + wrkDetl.getBatch()).equals(matnr)) { + return R.ok().add(wrkDetl); + } + } + // 鏇挎崲 鏄庣粏 + List<LocDetl> locDetls = locDetlService.selectList(new EntityWrapper<LocDetl>().eq("loc_no", wrkMast.getSourceLocNo())); + for (LocDetl locDetl : locDetls) { + if ((locDetl.getMatnr() + "-" + locDetl.getBatch()).equals(matnr)) { + WrkDetl wrkDetl = new WrkDetl(); + wrkDetl.sync(locDetl); + wrkDetl.setOrderNo(orderNo); + wrkDetl.setIoTime(wrkMast.getIoTime()); + wrkDetl.setWrkNo(wrkNo); + return R.ok().add(wrkDetl); + } + } + return R.error("绯荤粺閿欒锛屾潯鐮佷笉瀛樺湪"); + } + + + @RequestMapping("/pakout/confirm/auth") + @ManagerAuth + @Transactional + public R pakoutConfirm(@RequestBody List<WrkDetl> list) { + if (Cools.isEmpty(list)) { + return R.ok(); + } + Set<Integer> wrkNos = new HashSet<>(); + List<WrkDto> dtos = new ArrayList<>(); + for (WrkDetl wrkDetl : list) { + if (wrkNos.contains(wrkDetl.getWrkNo())) { + for (WrkDto dto : dtos) { + if (dto.getWrkNo().equals(wrkDetl.getWrkNo())) { + dto.getWrkDetls().add(wrkDetl); + break; + } + } + } else { + wrkNos.add(wrkDetl.getWrkNo()); + dtos.add(new WrkDto(wrkDetl.getWrkNo(), wrkDetl)); + } + } + + for (WrkDto dto : dtos) { + WrkMast wrkMast = wrkMastService.selectById(dto.getWrkNo()); + if (wrkMast != null) { + // 101 + if (wrkMast.getIoType() == 101) { + for (WrkDetl wrkDetl : dto.getWrkDetls()) { + wrkDetlService.updateInspect(wrkDetl.getWrkNo(), wrkDetl.getMatnr(), wrkDetl.getBatch()); + } + } + // 103 + if (wrkMast.getIoType() == 103) { + if (!wrkDetlService.delete(new EntityWrapper<WrkDetl>().eq("wrk_no", wrkMast.getWrkNo()))) { + throw new CoolException("鎷f枡鍑哄簱纭澶辫触"); + } + for (WrkDetl wrkDetl : dto.getWrkDetls()) { + wrkDetl.setInspect(1); + if (!wrkDetlService.insert(wrkDetl)) { + throw new CoolException("鎷f枡鍑哄簱纭澶辫触"); + } + } + } + } + } + + for (Integer wrkNo : wrkNos) { + WrkMast wrkMast = wrkMastService.selectById(wrkNo); + if (wrkMast.getWrkSts() == 14 && (Cools.isEmpty(wrkMast.getInvWh()) || wrkMast.getInvWh().equals("N"))) { + List<WrkDetl> wrkDetls = wrkDetlService.selectByWrkNo(wrkNo); + boolean complete = true; + for (WrkDetl wrkDetl : wrkDetls) { + if (wrkDetl.getInspect() == null || wrkDetl.getInspect() == 0) { + complete = false; + break; + } + } + if (complete) { + wrkMast.setInvWh("Y"); + wrkMast.setModiTime(new Date()); + if (!wrkMastService.updateById(wrkMast)) { + throw new CoolException("淇敼宸ヤ綔妗�" + wrkNo + "澶辫触"); + } + } + } + } + return R.ok("瀹屾垚纭"); + } + + + // 鐩樼偣 ---------------------------------------------------------------------------------------------------- + + @RequestMapping("/checkDetl/auth") + @ManagerAuth + public R getCheckDetl(@RequestParam(required = false) Integer staNo) { + if (null == staNo || staNo == 0) { + return R.ok(); + } + BasDevp basDevp = basDevpService.selectById(staNo); + if (null != basDevp && basDevp.getWrkNo() != null) { + WrkMast wrkMast = wrkMastService.selectById(basDevp.getWrkNo()); + if (wrkMast != null && wrkMast.getIoType() == 107) { + List<WrkDetl> wrkDetls = wrkDetlService.selectByWrkNo(wrkMast.getWrkNo()); + if (!Cools.isEmpty(wrkDetls)) { + MobileAdjustResult result = new MobileAdjustResult(); + result.setStaNo(staNo); + result.setWrkNo(wrkMast.getWrkNo()); + result.setWrkDetls(wrkDetls); + return R.ok().add(result); + } + } + } + return R.ok(); + } + + @RequestMapping("/adjust/auth") + @ManagerAuth(memo = "鐩樼偣") + public R adjust(@RequestBody MobileAdjustParam combParam){ + mobileService.adjust(combParam, getUserId()); + return R.ok("鐩樼偣鎴愬姛"); + } + + @PostMapping("/order/out/pakout/auth") + @ManagerAuth(memo = "璁㈠崟鍑哄簱") + public synchronized R pakoutByOrder(@RequestBody JSONObject param) { + if(!param.containsKey("staNo") || !param.containsKey("orderNo")){ + return R.parse(BaseRes.PARAM); + } + mobileService.pakoutByOrder(param,getUserId()); + return R.ok("鍑哄簱鎴愬姛"); + } + } -- Gitblit v1.9.1