From 58652618b0776f3ebe271c6a0f585e4a0dc60877 Mon Sep 17 00:00:00 2001 From: dubin <bindu_bean@163.com> Date: 星期四, 25 九月 2025 16:43:16 +0800 Subject: [PATCH] 初始化 --- src/main/java/com/zy/asrs/controller/MobileController.java | 475 ++++++++++++++++++++++++++++++++++++++++++++++++++++++----- 1 files changed, 433 insertions(+), 42 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/MobileController.java b/src/main/java/com/zy/asrs/controller/MobileController.java index ba76d5c..254b39c 100644 --- a/src/main/java/com/zy/asrs/controller/MobileController.java +++ b/src/main/java/com/zy/asrs/controller/MobileController.java @@ -1,21 +1,29 @@ 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.MobileAdjustParam; +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.WrkDto; +import com.zy.common.service.CommonService; import com.zy.common.web.BaseController; +import com.zy.system.entity.license.AbstractServerInfos; +import org.apache.logging.log4j.LogManager; +import org.apache.logging.log4j.Logger; 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.*; import java.util.List; /** @@ -24,7 +32,7 @@ */ @RestController @RequestMapping("mobile") -public class MobileController extends BaseController { +public class MobileController extends BaseController { @Autowired private MobileService mobileService; @@ -35,6 +43,8 @@ @Autowired private OrderService orderService; @Autowired + private OrderDetlService orderDetlService; + @Autowired private DocTypeService docTypeService; @Autowired private WrkMastService wrkMastService; @@ -44,6 +54,36 @@ private BasDevpService basDevpService; @Autowired private PackService packService; + @Autowired + private ManLocDetlMapper manLocDetlMapper; + @Autowired + private WrkDetlLogService wrkDetlLogService; + @Autowired + private MatService matService; + @Autowired + private MatBarcodeService matBarcodeService; + @Autowired + private CommonService commonService; + + + private static Logger logger = LogManager.getLogger(MobileController.class); + + // 鍟嗗搧涓婃灦 + @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("涓嬫灦鎴愬姛"); + } + // 缁勬墭 ---------------------------------------------------------------------------------------------------- @@ -51,37 +91,107 @@ * 鏍规嵁鍗曞彿妫�绱㈠崟鎹暟鎹� * 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) { + public R orderSearchByBarcode(@RequestParam String orderNo) { + 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()); + combMat.setDetId(orderDetl.getDetId()); + combMat.setDetlId(orderDetl.getId()); + combMats.add(combMat); + } + combParam.setCombMats(combMats); + } + combParam.setBillNo(order.getOrderNo()); + 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") @ManagerAuth(memo = "缁勬墭") - public R comb(@RequestBody CombParam combParam){ + public R comb(@RequestBody CombParam combParam) { + logger.info("缁勬墭鍙傛暟锛歿}",combParam); + if (Cools.isEmpty(combParam.getOrderNo())) { + combParam.setOrderNo(combParam.getBillNo()); + } + List<CombParam.CombMat> combMats = combParam.getCombMats(); + combMats.forEach(elem -> { + if (Cools.isEmpty(elem.getBatch())) { + elem.setBatch(elem.getItemBatch()); + } + }); mobileService.comb(combParam, getUserId()); return R.ok("缁勬墭鎴愬姛"); } + @RequestMapping("/pickIn/auth") +// @ManagerAuth(memo="鐩樼偣鍏ュ簱") + public R pickIn(@RequestParam String barcode){ + WrkMast wrkMast = wrkMastService.selectByBarcode(barcode); + List<PickInParam> param = wrkDetlService.selectDetByBarcode(barcode); + for(PickInParam pickInParam : param){ + pickInParam.setStaNo(wrkMast.getStaNo()); + pickInParam.setWorkNo(wrkMast.getWrkNo()); + } + return R.ok().add(param); + } + + @RequestMapping("/pack/get/auth") @ManagerAuth - public R packGet(@RequestParam String barcode){ + public R packGet(@RequestParam String barcode) { Pack pack = packService.selectByBarcode(barcode); if (pack == null) { return R.ok(); @@ -92,39 +202,203 @@ return R.ok("缁勬墭鎴愬姛"); } - @RequestMapping("/pack/comb/auth") - @ManagerAuth(memo = "涓嬬嚎缁勬墭") - public R packComb(@RequestBody CombParam combParam){ - mobileService.packComb(combParam, getUserId()); - 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 - 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)) { + @Deprecated + public R pakoutQuery(@RequestParam String barcode) { + if (Cools.isEmpty(barcode)) { 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<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>().eq("sta_no", staNo).eq("wrk_sts", 14L)); - if (!Cools.isEmpty(wrkMasts)) { - WrkMast wrkMast = wrkMasts.get(0); - List<WrkDetl> wrkDetls = wrkDetlService.selectByWrkNo(wrkMast.getWrkNo()); - 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("/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 + @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枡鍑哄簱纭澶辫触"); + } + } } } } - return R.ok(); + + 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("瀹屾垚纭"); } @@ -155,10 +429,127 @@ @RequestMapping("/adjust/auth") @ManagerAuth(memo = "鐩樼偣") - public R adjust(@RequestBody MobileAdjustParam combParam){ + 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("鍑哄簱鎴愬姛"); + } + + /** + * 鏍规嵁閫氱煡鍗曟煡璇㈡槑缁� + */ + @RequestMapping("/bill/query1/auth") + @ManagerAuth(memo = "鏍规嵁閫氱煡鍗曟煡璇㈡槑缁�") + public R billQuery1(@RequestParam String billNo, @RequestParam String size) { + Order temp1 = orderService.selectOne(new EntityWrapper<Order>().eq("temp1", billNo)); + if (temp1 == null) { + throw new CoolException("璇ヨ鍗曚笉瀛樺湪"); + } + List<OrderDetl> waitMatins = orderDetlService.selectList(new EntityWrapper<OrderDetl>().eq("order_no", temp1.getOrderNo()).last("and anfme > work_qty")); + if (waitMatins == null || waitMatins.isEmpty()) { + throw new CoolException("璇ヨ鍗曢」涓嶅瓨鍦�"); + } + //濡傛灉閫氱煡鍗曞崟鍙蜂负绌猴紝鍒欐煡璇㈣皟鎷ㄥ崟鍙� +// if (Cools.isEmpty(waitMatins) || waitMatins.size() <= 0) { +// waitMatins = orderDetlService.selectList(new EntityWrapper<OrderDetl>().eq("temp1", billNo).like("size", size).last("and anfme > work_qty")); +// } + + List<CombBillQueryVo> vos = new ArrayList<>(); + if (!Cools.isEmpty(waitMatins)) { + for (OrderDetl waitMatin : waitMatins) { + CombBillQueryVo vo = new CombBillQueryVo(); + vo.setDetlId(waitMatin.getId()); + vo.setMatnr(waitMatin.getMatnr()); + vo.setMatName(waitMatin.getMaktx()); + vo.setQty(waitMatin.getAnfme() - waitMatin.getWorkQty()); + vo.setCount(waitMatin.getAnfme() - waitMatin.getWorkQty()); + vo.setBillNo(waitMatin.getOrderNo()); + vo.setSeqNo(waitMatin.getINo()); + vo.setUnit(waitMatin.getUnit()); + vo.setSpecs(waitMatin.getSpecs()); + vo.setSize(waitMatin.getModel()); + vo.setColor(waitMatin.getColor()); + vo.setItemBatch(waitMatin.getBatch()); + vo.setLuHao(waitMatin.getLuHao()); + vo.setOutOrderNo(waitMatin.getOutOrderNo()); + vo.setSPgNO(waitMatin.getSPgNO()); + vo.setProType(waitMatin.getProType()); + vo.setPacking(waitMatin.getPacking()); + //vo.setOveFlag(waitMatin.getOveFlag()); + vos.add(vo); + } + } + return R.ok().add(vos); + } + + @RequestMapping("/callBarcode") + @ManagerAuth(memo = "PDA鍛煎彨鎵樼洏鍑哄簱") + public R callBarcode(@RequestBody CombParam combParam) { + logger.info("PDA鍛煎彨鎵樼洏鍑哄簱"); + if (combParam == null){ + return R.parse(BaseRes.PARAM); + } + combParam.getCombMats().forEach(combMat -> { + Mat mat = matService.selectByMatnr(combMat.getMatnr()); + if (mat == null){ + throw new CoolException("鍟嗗搧妗f涓嶅瓨鍦�"); + } + MatBarcode matBarcode = matBarcodeService.selectbyMatnr(combMat.getMatnr()); + if (matBarcode == null){ + throw new CoolException("璇ョ墿鏂欐湭涓庢墭鐩樼粦瀹�"); + } + LocMast locMast=locMastService.selectByBarcode(matBarcode.getZpallet()); + if (locMast == null){ + throw new CoolException("鏈壘鍒颁笌璇ョ墿鏂欑粦瀹氱殑鎵樼洏"); + } + int wrkNo=commonService.getWorkNo(0); + Date now = new Date(); + //鐢熸垚宸ヤ綔妗� + WrkMast wrkMast=new WrkMast(); + wrkMast.setWrkNo(wrkNo); + wrkMast.setIoTime(new Date()); + wrkMast.setWrkSts(11L);//宸ヤ綔鐘舵�侊細鐢熸垚鍑哄簱ID + wrkMast.setIoType(101);//鍏ュ嚭搴撶姸鎬侊細骞舵澘鍑哄簱 + wrkMast.setIoPri(13D);//浼樺厛绾� + wrkMast.setCrnNo(locMast.getCrnNo()); +// wrkMast.setSourceStaNo(dto.getSourceStaNo());//婧愮珯 + wrkMast.setStaNo(101);// 鐩爣绔� + wrkMast.setSourceLocNo(locMast.getLocNo());// 婧愬簱浣� + wrkMast.setBarcode(matBarcode.getZpallet()); // 鎵樼洏鐮� + wrkMast.setFullPlt("Y"); // 婊℃澘锛歒 + wrkMast.setPicking("N"); // 鎷f枡 + wrkMast.setExitMk("N"); // 閫�鍑� + wrkMast.setEmptyMk("N"); // 绌烘澘 + wrkMast.setLinkMis("Y"); +// wrkMast.setScWeight(weight); + wrkMast.setCtnType(0); // 瀹瑰櫒绫诲瀷 + // 鎿嶄綔浜哄憳鏁版嵁 + wrkMast.setAppeTime(now); + wrkMast.setModiTime(now); + boolean res = wrkMastService.insert(wrkMast); + if (!res) { + throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�"); + } + if (locMast.getLocSts().equals("F")) { + locMast.setLocSts("R"); // R.鍑哄簱棰勭害 + locMast.setModiTime(now); + if (!locMastService.updateById(locMast)) { + throw new CoolException("鏀瑰彉搴撲綅鐘舵�佸け璐�"); + } + } else { + throw new CoolException(locMast.getLocNo() + "鐩爣搴撲綅鐘舵�佷笉涓篎"); + } + }); + return R.ok(); + } } -- Gitblit v1.9.1