From 17080b28dc3fb0df12a5a4da76e10dd9203e5725 Mon Sep 17 00:00:00 2001 From: pang.jiabao <pang_jiabao@163.com> Date: 星期三, 08 十月 2025 11:07:48 +0800 Subject: [PATCH] 订单功能完善 --- src/main/java/com/zy/asrs/controller/MobileController.java | 389 +++++++++++++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 363 insertions(+), 26 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/MobileController.java b/src/main/java/com/zy/asrs/controller/MobileController.java index 55dc50c..e1c309e 100644 --- a/src/main/java/com/zy/asrs/controller/MobileController.java +++ b/src/main/java/com/zy/asrs/controller/MobileController.java @@ -1,27 +1,28 @@ package com.zy.asrs.controller; +import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.mapper.EntityWrapper; 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.GDYKConfirmGoodsParam; import com.zy.asrs.entity.param.MobileAdjustParam; +import com.zy.asrs.entity.param.OffSaleParam; import com.zy.asrs.entity.result.MobileAdjustResult; +import com.zy.asrs.mapper.ManLocDetlMapper; import com.zy.asrs.service.*; +import com.zy.common.model.WrkDto; import com.zy.common.web.BaseController; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.transaction.annotation.Transactional; -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.web.bind.annotation.*; -import java.util.Date; -import java.util.HashSet; -import java.util.List; -import java.util.Set; +import java.util.*; +import java.util.stream.Collectors; /** * 绉诲姩绔帴鍙f帶鍒跺櫒 @@ -40,6 +41,8 @@ @Autowired private OrderService orderService; @Autowired + private OrderDetlService orderDetlService; + @Autowired private DocTypeService docTypeService; @Autowired private WrkMastService wrkMastService; @@ -49,6 +52,152 @@ private BasDevpService basDevpService; @Autowired private PackService packService; + @Autowired + private ManLocDetlMapper manLocDetlMapper; + @Autowired + private WrkDetlLogService wrkDetlLogService; + + @PostMapping("/pda/OutOrder") + @ManagerAuth(memo = "鑾峰緱鍑哄簱鍗�") + @Transactional + public R OutOrder(@RequestParam String orderNo) { + List<Order> orders=new ArrayList<Order>(); + List<Order> OrderList=new ArrayList<Order>(); + if(Cools.isEmpty(orderNo)){ + orders= orderService.selectList(new EntityWrapper<Order>() + .in("settle",1,2) + ); + }else{ + orders= orderService.selectList(new EntityWrapper<Order>() + .like("order_no",orderNo) + .in("settle",1,2) + ); + } + if(Cools.isEmpty(orders)){ + return R.parse("鏃犳暟鎹�"); + } + for (Order o:orders + ) { + DocType docType=docTypeService.selectOne(new EntityWrapper<DocType>() + .eq("doc_id",o.getDocType())); + if(docType.getPakout()==1){ + OrderList.add(o); + } + } + + + return R.ok(OrderList); + } + + @PostMapping("/pda/OutLocNo") + @ManagerAuth(memo = "鑾峰緱骞冲簱鍑哄簱鐨勫搴斿簱浣嶅彿") + @Transactional + public R OutLocNo(@RequestParam Long orderId) { + List<OrderDetl> orderDetls = orderDetlService.selectList(new EntityWrapper<OrderDetl>() + .eq("order_id", orderId) + ); + if (Cools.isEmpty(orderDetls)) { + return R.error("璁㈠崟鏄庣粏涓嶅瓨鍦�"); + } + List<String> list = new ArrayList<>(); + for (OrderDetl o : orderDetls + ) { + if (o.getAnfme() <= o.getWorkQty()) { + continue; + } else { + //鏌ョ湅搴撲綅鏄庣粏涓湁鐨勭墿鏂� + List<ManLocDetl> locDetls = manLocDetlMapper.selectList(new EntityWrapper<ManLocDetl>() + .eq("matnr", o.getMatnr()).orderBy("modi_time",false) + ); + if (Cools.isEmpty(locDetls)) { + continue; + } else { + for (ManLocDetl l : locDetls + ) { + String s = l.getLocNo().substring(0, 2); + if (Integer.parseInt(s) > 8) { + list.add(l.getLocNo()); + } + } + } + } + } + List<String> myList = list.stream().distinct().collect(Collectors.toList()); + return R.ok(myList); + } + + @PostMapping("/pda/OrderDetlContrastLocDetl") + @ManagerAuth(memo = "鑾峰緱璁㈠崟鏄庣粏瀵瑰簲鐨勫簱瀛樻槑缁�") + @Transactional + public R OrderDetlContrastLocDetl(@RequestParam Long orderId, @RequestParam String locNo) { + List<ManLocDetl> locDetlList = new ArrayList<ManLocDetl>(); + List<OrderDetl> orderDetls = orderDetlService.selectList(new EntityWrapper<OrderDetl>() + .eq("order_id", orderId) + ); + if (Cools.isEmpty(orderDetls)) { + return R.error("璁㈠崟鏄庣粏涓嶅瓨鍦�"); + } + List<ManLocDetl> locDetls = manLocDetlMapper.selectList(new EntityWrapper<ManLocDetl>() + .eq("loc_no", locNo)); + if (Cools.isEmpty(locDetls)) { + return R.error("搴撲綅涓虹┖"); + } + for (OrderDetl o : orderDetls + ) { + if(o.getAnfme().equals(o.getQty())){ + continue; + } + for (ManLocDetl l : locDetls + ) { + if (o.getMatnr().equals(l.getMatnr())) { + if (o.getAnfme() - o.getWorkQty() >= l.getAnfme()) { + + } else { + l.setAnfme(o.getAnfme() - o.getWorkQty()); + } + locDetlList.add(l); + break; + } + } + } + return R.ok(locDetlList); + } + + /** + * 骞冲韩涓嬫灦 + */ + @RequestMapping("/pda/WarehouseOut") + @ManagerAuth + public R WarehouseOut(@RequestBody CombParam combParam) { + return mobileService.WarehouseOut(combParam, getUserId()); + } + + /** + * 骞冲韩涓婃灦 + */ + @RequestMapping("/pda/WarehouseIn") + @ManagerAuth + public R WarehouseIn(@RequestParam String locNo, @RequestParam String barcode) { + return mobileService.WarehouseIn(locNo, barcode, getUserId()); + } + + // 鍟嗗搧涓婃灦 + @RequestMapping("/mat/onSale/auth") + @ManagerAuth + public R matOnSale(@RequestBody CombParam combParam){ + mobileService.onSale(combParam, getUserId()); + return R.ok("涓婃灦鎴愬姛"); + } + + // 鍟嗗搧涓嬫灦 + @RequestMapping("/mat/offSale/auth") + //@ManagerAuth + public R matOffSale(@RequestBody OffSaleParam offSaleParam){ + mobileService.offSale(offSaleParam, getUserId()); + return R.ok("涓嬫灦鎴愬姛"); + } + + // 缁勬墭 ---------------------------------------------------------------------------------------------------- @@ -56,25 +205,69 @@ * 鏍规嵁鍗曞彿妫�绱㈠崟鎹暟鎹� * http://localhost:8081/jkwms/mobile/order/serach/orderNo/auth?orderNo=123123 */ +// @RequestMapping("/order/search/orderNo/auth") +// @ManagerAuth +// public R orderSearchByBarcode(@RequestParam String orderNo){ +// Order order = orderService.selectByNo(orderNo); +// if (order == null) { +// 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); +// } @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); + if (Cools.isEmpty(orders)){ return R.ok(); } - DocType docType = docTypeService.selectById(order.getDocType()); - if (docType.getPakin() == null || docType.getPakin() != 1) { - return R.ok(); + 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()); + 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()); + combMats.add(combMat); + } + combParam.setCombMats(combMats); + } + combParam.setOrderNo(order.getOrderNo()); + combParams.add(combParam); + } } - 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); + return R.ok().add(combParams); } @RequestMapping("/comb/auth") @@ -108,7 +301,8 @@ // 鍑哄簱 --------------------------------------------------------------------------------------------------- @RequestMapping("/pakout/query/auth") -// @ManagerAuth + @ManagerAuth + @Deprecated public R pakoutQuery(@RequestParam(required = false) String barcode, @RequestParam(required = false) Integer staNo, @RequestParam(required = false) String matnr){ @@ -128,18 +322,152 @@ return R.ok(); } + /** + * 鍑哄簱纭 - 鎵墭鐩樼爜 + * 1.鍏ㄦ澘 杩斿洖 101 + * 2.鎷f枡 杩斿洖 103 + */ + @RequestMapping("/pakout/confirm/barcode/auth") + @ManagerAuth + public R pakoutQueryByBarcode(@RequestParam(required = false) String barcode){ + if (Cools.isEmpty(barcode)) { + return R.ok(); + } + 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.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())); + if (Cools.isEmpty(orderDetl)){ + return R.error("鏈煡鍒版暟鎹�"); + } + if (!orderDetl.getQty$().equals("宸插畬鎴�")){ + return R.error("浠诲姟鏈畬鎴�"); + } + //澶嶆牳鏁� + orderDetl.setSource(1); + orderDetlService.updateById(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 + @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) { - wrkNos.add(wrkDetl.getWrkNo()); - wrkDetlService.updateInspect(wrkDetl.getWrkNo(), wrkDetl.getMatnr(), wrkDetl.getBatch()); + 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"))) { @@ -160,7 +488,7 @@ } } } - return R.ok(); + return R.ok("瀹屾垚纭"); } @@ -196,5 +524,14 @@ 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