From a484168b903a919b24d65a5d95dea88a04d8f34c Mon Sep 17 00:00:00 2001 From: zjj <3272660260@qq.com> Date: 星期四, 26 十二月 2024 13:50:33 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/jxgtasrs' into jxgtasrs --- src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java | 273 +++++++++++++++++++++++++++++++++++++----------------- 1 files changed, 188 insertions(+), 85 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 bbd7895..aff9cec 100644 --- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java @@ -114,7 +114,8 @@ List<DetlDto> list = new ArrayList<>(); List<DetlDto> orderDetails = param.getOrderDetails(); for (DetlDto detail : orderDetails) { - DetlDto dto = new DetlDto(detail.getMatnr(), detail.getBatch(), detail.getAnfme()); + DetlDto dto = new DetlDto(detail.getMatnr(), detail.getBatch(), detail.getAnfme(),detail.getFromOrderNo() + , detail.getMark(),detail.getCustomer(),detail.getSuppName(),detail.getTemp1(),detail.getTemp2(),detail.getTemp3(),detail.getTemp4()); if (DetlDto.has(list, dto)) { DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch()); assert detlDto != null; @@ -144,6 +145,12 @@ orderDetl.setSuppCode(detlDto.getFromOrderNo()); orderDetl.setMemo(detlDto.getMemo()); orderDetl.setManu(detlDto.getMark()); + orderDetl.setSupp(detlDto.getSuppName()); //渚涘簲鍟� + orderDetl.setSku(detlDto.getCustomer()); + orderDetl.setTemp1(detlDto.getTemp1()); + orderDetl.setTemp2(detlDto.getTemp2()); + orderDetl.setTemp3(detlDto.getTemp3()); + orderDetl.setTemp4(detlDto.getTemp4()); if (!orderDetlService.insert(orderDetl)) { throw new CoolException("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�"); } @@ -253,7 +260,8 @@ List<DetlDto> list = new ArrayList<>(); List<DetlDto> orderDetails = param.getOrderDetails(); for (DetlDto detail : orderDetails) { - DetlDto dto = new DetlDto(detail.getMatnr(), detail.getBatch(), detail.getAnfme()); + DetlDto dto = new DetlDto(detail.getMatnr(), detail.getBatch(), detail.getAnfme(),detail.getFromOrderNo() + , detail.getMark(),detail.getCustomer(),detail.getSuppName(),detail.getTemp1(),detail.getTemp2(),detail.getTemp3(),detail.getTemp4()); if (DetlDto.has(list, dto)) { DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch()); assert detlDto != null; @@ -283,6 +291,12 @@ orderDetl.setSuppCode(detlDto.getFromOrderNo()); orderDetl.setMemo(detlDto.getMemo()); orderDetl.setManu(detlDto.getMark()); + orderDetl.setSupp(detlDto.getSuppName()); + orderDetl.setSku(detlDto.getCustomer()); + orderDetl.setTemp1(detlDto.getTemp1()); + orderDetl.setTemp2(detlDto.getTemp2()); + orderDetl.setTemp3(detlDto.getTemp3()); + orderDetl.setTemp4(detlDto.getTemp4()); if (!orderDetlService.insert(orderDetl)) { throw new CoolException("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�"); } @@ -472,81 +486,19 @@ // 鍒嗙被 Long tagId; // 涓�绾у垎绫� - if (!Cools.isEmpty(matParam.getGroupCode()) && !Cools.isEmpty(matParam.getGroupName())) { - Tag priTag = tagService.selectByName(matParam.getGroupCode(), 1); - if (priTag == null) { - Tag top = tagService.getTop(); - NodeUtils nodeUtils = new NodeUtils(); - nodeUtils.executePath(top.getId()); - priTag = new Tag( - null, // 缂栧彿 - matParam.getGroupCode(), // 鍚嶇О - top.getId(), // 鐖剁骇 - top.getName(), // 鐖剁骇鍚嶇О - nodeUtils.path.toString(), // 鍏宠仈璺緞 - nodeUtils.pathName.toString(), // 鍏宠仈璺緞鍚� - 0, // 绫诲瀷 - null, // 璐熻矗浜� - null, // 鍥剧墖 - null, // 绠�瑕佹弿杩� - null, // 鏁伴噺 - 2, // 绛夌骇 - null, // 鎺掑簭 - 1, // 鐘舵�� - now, // 娣诲姞鏃堕棿 - null, // 娣诲姞浜哄憳 - now, // 淇敼鏃堕棿 - null, // 淇敼浜哄憳 - null // 澶囨敞 - ); - if (tagMapper.insert(priTag) == 0) { - throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳"); - } - } - // 浜岀骇鍒嗙被 - Tag secTag = tagService.selectByName(matParam.getGroupName(), 2); - if (secTag == null) { - NodeUtils nodeUtils = new NodeUtils(); - nodeUtils.executePath(priTag.getId()); - secTag = new Tag( - null, // 缂栧彿 - matParam.getGroupName(), // 鍚嶇О - priTag.getId(), // 鐖剁骇 - priTag.getName(), // 鐖剁骇鍚嶇О - nodeUtils.path.toString(), // 鍏宠仈璺緞 - nodeUtils.pathName.toString(), // 鍏宠仈璺緞鍚� - 0, // 绫诲瀷 - null, // 璐熻矗浜� - null, // 鍥剧墖 - null, // 绠�瑕佹弿杩� - null, // 鏁伴噺 - 2, // 绛夌骇 - null, // 鎺掑簭 - 1, // 鐘舵�� - now, // 娣诲姞鏃堕棿 - null, // 娣诲姞浜哄憳 - now, // 淇敼鏃堕棿 - null, // 淇敼浜哄憳 - null // 澶囨敞 - ); - if (tagMapper.insert(secTag) == 0) { - throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳"); - } - } - tagId = secTag.getId(); - } else { - tagId = tagService.getTop().getId(); + Tag tag = tagService.selectOne(new EntityWrapper<Tag>().eq("memo", matParam.getGroupCode())); + if (tag == null) { + throw new CoolException("鍑洪敊锛屾湭鎵惧埌鍒嗙被"); } if (mat == null) { mat = new Mat(); - mat.sync(matParam); // mat.setMatnr(param.getMatnr()); // mat.setMaktx(param.getMaktx()); // mat.setSpecs(param.getSpecs()); // mat.setModel(param.getModel()); - mat.setTagId(tagId); + mat.setTagId(tag.getId()); mat.setStatus(1); mat.setCreateTime(now); mat.setUpdateTime(now); @@ -557,7 +509,7 @@ } } else { mat.sync(matParam); - mat.setTagId(tagId); + mat.setTagId(tag.getId()); if (!matService.update(mat, new EntityWrapper<Mat>().eq("matnr",matParam.getMatnr()))) { throw new CoolException("鏇存柊宸插瓨鍦ㄥ晢鍝佷俊鎭け璐ワ紝璇疯仈绯荤鐞嗗憳"); } @@ -571,29 +523,32 @@ public List<LocDetlByTimeDTO> selectTimeLocDetl(TimeSelectParam param) { ArrayList<LocDetlByTimeDTO> locDetlByTimeDTOS = new ArrayList<>(); EntityWrapper<WrkMastLog> wrkMastLogEntityWrapper = new EntityWrapper<>(); - wrkMastLogEntityWrapper.ge("appe_time",param.getStartTime()); - wrkMastLogEntityWrapper.le("appe_time",param.getEndTime()); + wrkMastLogEntityWrapper.ge("modi_time",param.getStartTime()); + wrkMastLogEntityWrapper.le("modi_time",param.getEndTime()); // wrkMastLogEntityWrapper.isNotNull("sheet_no"); wrkMastLogService.selectList(wrkMastLogEntityWrapper).forEach(wrkMastLog -> { if (wrkMastLog.getWrkSts() == 5 || wrkMastLog.getWrkSts() == 15) { List<WrkDetlLog> wrkDetlLogs = wrkDetlLogService.selectList(new EntityWrapper<WrkDetlLog>() .eq("wrk_no", wrkMastLog.getWrkNo()).eq("zpallet", wrkMastLog.getBarcode())); wrkDetlLogs.forEach(wrkDetlLog -> { - LocDetlByTimeDTO locDetlByTimeDTO = new LocDetlByTimeDTO(); - if (!Cools.isEmpty(wrkDetlLog.getOrderNo())){ - Order order = orderService.selectByNo(wrkDetlLog.getOrderNo()); - if (!Cools.isEmpty(order)) { - locDetlByTimeDTO.setDate(order.getOrderTime()); - locDetlByTimeDTO.setWarehouse(order.getItemName()); - locDetlByTimeDTO.setOrderType(order.getDocType().toString()); + if (wrkDetlLog.getOrderNo() != null && !wrkDetlLog.getOrderNo().isEmpty()) { + LocDetlByTimeDTO locDetlByTimeDTO = new LocDetlByTimeDTO(); + if (!Cools.isEmpty(wrkDetlLog.getOrderNo())){ + Order order = orderService.selectByNo(wrkDetlLog.getOrderNo()); + if (!Cools.isEmpty(order)) { + locDetlByTimeDTO.setDate(order.getOrderTime()); + locDetlByTimeDTO.setWarehouse(order.getItemName()); + locDetlByTimeDTO.setOrderType(order.getDocType$()); + } + locDetlByTimeDTO.setMatnr(wrkDetlLog.getMatnr()); + locDetlByTimeDTO.setLocNo(wrkMastLog.getIoType() <100? wrkMastLog.getLocNo(): wrkMastLog.getSourceLocNo()); + locDetlByTimeDTO.setBatch(wrkDetlLog.getBatch()); + locDetlByTimeDTO.setAnfme(wrkDetlLog.getAnfme()); + locDetlByTimeDTO.setOrderNo(wrkDetlLog.getOrderNo()); + locDetlByTimeDTO.setMark(wrkDetlLog.getManu()); + locDetlByTimeDTO.setWorkNo(wrkDetlLog.getWrkNo().toString()); + locDetlByTimeDTOS.add(locDetlByTimeDTO); } - locDetlByTimeDTO.setMatnr(wrkDetlLog.getMatnr()); - locDetlByTimeDTO.setLocNo(wrkMastLog.getIoType() <100? wrkMastLog.getLocNo(): wrkMastLog.getSourceLocNo()); - locDetlByTimeDTO.setBatch(wrkDetlLog.getBatch()); - locDetlByTimeDTO.setAnfme(wrkDetlLog.getAnfme()); - locDetlByTimeDTO.setOrderNo(wrkDetlLog.getOrderNo()); - locDetlByTimeDTO.setMark(wrkDetlLog.getManu()); - locDetlByTimeDTOS.add(locDetlByTimeDTO); } }); @@ -632,4 +587,152 @@ return true; } + @Override + @Transactional + public void syncTag(List<TagParam> param) { + + param.forEach(tag-> { + // 鍒嗙被 + Long tagId; + Date now = new Date(); + if (Cools.isEmpty(tag.getParentItemClassId())){ + Tag priTag = tagService.selectByName("鍏ㄩ儴", 1); + + // 浜岀骇鍒嗙被 + Tag secTag = tagService.selectByName(tag.getName(), 2); + if (secTag == null) { + NodeUtils nodeUtils = new NodeUtils(); + nodeUtils.executePath(priTag.getId()); + secTag = new Tag( + null, // 缂栧彿 + tag.getName(), // 鍚嶇О + priTag.getId(), // 鐖剁骇 + priTag.getName(), // 鐖剁骇鍚嶇О + nodeUtils.path.toString(), // 鍏宠仈璺緞 + nodeUtils.pathName.toString(), // 鍏宠仈璺緞鍚� + 0, // 绫诲瀷 + null, // 璐熻矗浜� + null, // 鍥剧墖 + null, // 绠�瑕佹弿杩� + null, // 鏁伴噺 + 2, // 绛夌骇 + null, // 鎺掑簭 + 1, // 鐘舵�� + now, // 娣诲姞鏃堕棿 + null, // 娣诲姞浜哄憳 + now, // 淇敼鏃堕棿 + null, // 淇敼浜哄憳 + tag.getItemClassId() // 澶囨敞 + ); + if (tagMapper.insert(secTag) == 0) { + throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳"); + } + } + }else { + Tag priTag =tagService.selectOne(new EntityWrapper<Tag>().eq("memo", tag.getParentItemClassId())); + if (priTag == null) { + Tag top = tagService.getTop(); + NodeUtils nodeUtils = new NodeUtils(); + nodeUtils.executePath(top.getId()); + priTag = new Tag( + null, // 缂栧彿 + tag.getParentName(), // 鍚嶇О + top.getId(), // 鐖剁骇 + top.getName(), // 鐖剁骇鍚嶇О + nodeUtils.path.toString(), // 鍏宠仈璺緞 + nodeUtils.pathName.toString(), // 鍏宠仈璺緞鍚� + 0, // 绫诲瀷 + null, // 璐熻矗浜� + null, // 鍥剧墖 + null, // 绠�瑕佹弿杩� + null, // 鏁伴噺 + 2, // 绛夌骇 + null, // 鎺掑簭 + 1, // 鐘舵�� + now, // 娣诲姞鏃堕棿 + null, // 娣诲姞浜哄憳 + now, // 淇敼鏃堕棿 + null, // 淇敼浜哄憳 + tag.getParentItemClassId() // 澶囨敞 + ); + if (tagMapper.insert(priTag) == 0) { + throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳"); + } + } + + // 浜岀骇鍒嗙被 + Tag secTag = tagService.selectOne(new EntityWrapper<Tag>().eq("memo", tag.getItemClassId())); + NodeUtils nodeUtils = new NodeUtils(); + nodeUtils.executePath(priTag.getId()); + if (secTag == null) { + secTag = new Tag( + null, // 缂栧彿 + tag.getName(), // 鍚嶇О + priTag.getId(), // 鐖剁骇 + priTag.getName(), // 鐖剁骇鍚嶇О + nodeUtils.path.toString(), // 鍏宠仈璺緞 + nodeUtils.pathName.toString(), // 鍏宠仈璺緞鍚� + 0, // 绫诲瀷 + null, // 璐熻矗浜� + null, // 鍥剧墖 + null, // 绠�瑕佹弿杩� + null, // 鏁伴噺 + 2, // 绛夌骇 + null, // 鎺掑簭 + 1, // 鐘舵�� + now, // 娣诲姞鏃堕棿 + null, // 娣诲姞浜哄憳 + now, // 淇敼鏃堕棿 + null, // 淇敼浜哄憳 + tag.getItemClassId() // 澶囨敞 + ); + if (tagMapper.insert(secTag) == 0) { + throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳"); + } + }else { + secTag.setName(tag.getName()); + secTag.setParentId(priTag.getId()); + secTag.setParentName(priTag.getName()); + secTag.setPath(nodeUtils.path.toString()); + secTag.setPathName(nodeUtils.pathName.toString()); + if (tagMapper.updateById(secTag) == 0) { + throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳"); + } + + List<Tag> tags = tagService.selectList(new EntityWrapper<Tag>().eq("parent_id", secTag.getId())); + if (!Cools.isEmpty(tags)) { + for (Tag tag1 : tags) { + tag1.setPath(nodeUtils.path.toString()+","+secTag.getId()); + tag1.setPathName(nodeUtils.pathName.toString()+","+secTag.getName()); + if (tagMapper.updateById(tag1) == 0) { + throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳"); + } + } + } + + + + + } + + + } + }); + } + @Transactional + @Override + public void orderDelete(String orderNo) { + Order order = orderService.selectByNo(orderNo); + if (order == null) { + throw new CoolException("鏈煡璇㈠埌瀵瑰簲璁㈠崟淇℃伅"); + } + if (order.getSettle() != 1){ + throw new CoolException("璇ヨ鍗曞凡鏈夊搴斾换鍔★紝绂佹鍒犻櫎"); + } + List<OrderDetl> OrderDetl = orderDetlService.selectList(new EntityWrapper<OrderDetl>().eq("order_no", orderNo)); + if (!Cools.isEmpty(OrderDetl)) { + orderDetlService.delete(new EntityWrapper<OrderDetl>().eq("order_no", orderNo)); + } + orderService.delete(new EntityWrapper<Order>().eq("order_no", orderNo)); + } } -- Gitblit v1.9.1