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 | 465 +++++++++++++++++++++++++++++++++++++++++++++++++++++---- 1 files changed, 426 insertions(+), 39 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 2992414..aff9cec 100644 --- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java @@ -6,19 +6,21 @@ import com.core.common.SnowflakeIdWorker; import com.core.exception.CoolException; import com.zy.asrs.entity.*; -import com.zy.asrs.entity.param.OpenOrderCompleteParam; -import com.zy.asrs.entity.param.OpenOrderPakinParam; -import com.zy.asrs.entity.param.OpenOrderPakoutParam; +import com.zy.asrs.entity.param.*; import com.zy.asrs.entity.result.OpenOrderCompeteResult; import com.zy.asrs.entity.result.StockVo; +import com.zy.asrs.mapper.TagMapper; import com.zy.asrs.service.*; +import com.zy.asrs.utils.MatUtils; import com.zy.common.model.DetlDto; +import com.zy.common.utils.NodeUtils; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.ArrayList; +import java.util.Collections; import java.util.Date; import java.util.List; @@ -45,13 +47,26 @@ private PackService packService; @Autowired private TagService tagService; + @Autowired + private TagMapper tagMapper; + @Autowired + private WrkMastService wrkMastService; + @Autowired + private WrkMastLogServiceImpl wrkMastLogService; + @Autowired + private WrkDetlLogServiceImpl wrkDetlLogService; @Override @Transactional public void pakinOrderCreate(OpenOrderPakinParam param) { Order order = orderService.selectByNo(param.getOrderNo()); + if (!Cools.isEmpty(order) && order.getSettle() !=1) { + throw new CoolException(param.getOrderNo() + "鍗曟嵁宸叉湁宸ヤ綔浠诲姟"); + } if (!Cools.isEmpty(order)) { - throw new CoolException(param.getOrderNo() + "鍗曟嵁宸插瓨鍦紝璇峰嬁閲嶅鎻愪氦"); + boolean orderNo = orderService.delete(new EntityWrapper<Order>().eq("order_no", param.getOrderNo())); + boolean orderNo1 = orderDetlService.delete(new EntityWrapper<OrderDetl>().eq("order_no", param.getOrderNo())); + } DocType docType = docTypeService.selectOrAdd(param.getOrderType(), Boolean.TRUE); Date now = new Date(); @@ -59,30 +74,30 @@ order = new Order( String.valueOf(snowflakeIdWorker.nextId()), // 缂栧彿[闈炵┖] param.getOrderNo(), // 璁㈠崟缂栧彿 - DateUtils.convert(now), // 鍗曟嵁鏃ユ湡 + param.getInboundDate(), // 鍗曟嵁鏃ユ湡 docType.getDocId(), // 鍗曟嵁绫诲瀷 null, // 椤圭洰缂栧彿 - null, // + param.getWarehouse(), //浠撳簱 itemName null, // 璋冩嫧椤圭洰缂栧彿 - null, // 鍒濆绁ㄦ嵁鍙� - null, // 绁ㄦ嵁鍙� + param.getOriginWarehouse(), // 鍒濆绁ㄦ嵁鍙� 鏉ユ簮浠撳簱 + param.getDepartment(), // 绁ㄦ嵁鍙� null, // 瀹㈡埛缂栧彿 - null, // 瀹㈡埛 + param.getSuppliers(), // 渚涘簲鍟� cstmrName null, // 鑱旂郴鏂瑰紡 - null, // 鎿嶄綔浜哄憳 + param.getUser(), // 鍒跺崟浜� null, // 鍚堣閲戦 null, // 浼樻儬鐜� null, // 浼樻儬閲戦 null, // 閿�鍞垨閲囪喘璐圭敤鍚堣 null, // 瀹炰粯閲戦 null, // 浠樻绫诲瀷 - null, // 涓氬姟鍛� + param.getSalesman(), // 涓氬姟鍛� null, // 缁撶畻澶╂暟 null, // 閭垂鏀粯绫诲瀷 null, // 閭垂 null, // 浠樻鏃堕棿 null, // 鍙戣揣鏃堕棿 - null, // 鐗╂祦鍚嶇О + param.getBusinessType(), // 鐗╂祦鍚嶇О null, // 鐗╂祦鍗曞彿 1L, // 璁㈠崟鐘舵�� 1, // 鐘舵�� @@ -99,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; @@ -125,6 +141,16 @@ orderDetl.setUpdateTime(now); orderDetl.setStatus(1); orderDetl.setQty(0.0D); + orderDetl.setThreeCode(detlDto.getOrderNo()); + 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("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�"); } @@ -178,10 +204,15 @@ } @Override + @Transactional public void pakoutOrderCreate(OpenOrderPakoutParam param) { Order order = orderService.selectByNo(param.getOrderNo()); + // 濡傛灉鍗曟嵁涓嶅瓨鍦ㄥ垯娣诲姞锛涘鏋滃崟鎹瓨鍦紝浣滀笟涓棤娉曚慨鏀癸紝鍙嶄箣鍒欎慨鏀瑰崟鎹� if (!Cools.isEmpty(order)) { - throw new CoolException(param.getOrderNo() + "鍗曟嵁宸插瓨鍦紝璇峰嬁閲嶅鎻愪氦"); + if (order.getSettle() > 1L) { + throw new CoolException(param.getOrderNo() + "姝e湪鍑哄簱锛屾棤娉曚慨鏀瑰崟鎹�"); + } + orderService.remove(order.getId()); } DocType docType = docTypeService.selectOrAdd(param.getOrderType(), Boolean.FALSE); Date now = new Date(); @@ -189,30 +220,30 @@ order = new Order( String.valueOf(snowflakeIdWorker.nextId()), // 缂栧彿[闈炵┖] param.getOrderNo(), // 璁㈠崟缂栧彿 - DateUtils.convert(now), // 鍗曟嵁鏃ユ湡 + param.getInboundDate(), // 鍗曟嵁鏃ユ湡 docType.getDocId(), // 鍗曟嵁绫诲瀷 null, // 椤圭洰缂栧彿 - null, // + param.getWarehouse(), //浠撳簱 itemName null, // 璋冩嫧椤圭洰缂栧彿 - null, // 鍒濆绁ㄦ嵁鍙� - null, // 绁ㄦ嵁鍙� + param.getOriginWarehouse(), // 鍒濆绁ㄦ嵁鍙� 鏉ユ簮浠撳簱 + param.getDepartment(), // 绁ㄦ嵁鍙� null, // 瀹㈡埛缂栧彿 - null, // 瀹㈡埛 + param.getSuppliers(), // 渚涘簲鍟� cstmrName null, // 鑱旂郴鏂瑰紡 - null, // 鎿嶄綔浜哄憳 + param.getUser(), // 鍒跺崟浜� null, // 鍚堣閲戦 null, // 浼樻儬鐜� null, // 浼樻儬閲戦 null, // 閿�鍞垨閲囪喘璐圭敤鍚堣 null, // 瀹炰粯閲戦 null, // 浠樻绫诲瀷 - null, // 涓氬姟鍛� + param.getSalesman(), // 涓氬姟鍛� null, // 缁撶畻澶╂暟 null, // 閭垂鏀粯绫诲瀷 null, // 閭垂 null, // 浠樻鏃堕棿 null, // 鍙戣揣鏃堕棿 - null, // 鐗╂祦鍚嶇О + param.getBusinessType(), // 鐗╂祦鍚嶇О null, // 鐗╂祦鍗曞彿 1L, // 璁㈠崟鐘舵�� 1, // 鐘舵�� @@ -229,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; @@ -255,6 +287,16 @@ orderDetl.setUpdateTime(now); orderDetl.setStatus(1); orderDetl.setQty(0.0D); + orderDetl.setThreeCode(detlDto.getOrderNo()); + 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("鐢熸垚鍗曟嵁鏄庣粏澶辫触锛岃鑱旂郴绠$悊鍛�"); } @@ -314,17 +356,20 @@ @Override @Transactional - public void packageUp(String barcode) { - Pack pack = packService.selectByBarcode(barcode); + public void packageUp(PackParam param) { + if (Cools.isEmpty(param.getBarcode())) { + throw new CoolException("barcode涓嶈兘涓虹┖"); + } + Mat analyse = MatUtils.analyseMat(param.getBarcode()); + Pack pack = packService.selectByBarcode(param.getBarcode()); if (null != pack) { - throw new CoolException(barcode + "閲嶅鎻愪氦"); + throw new CoolException(param.getBarcode() + "閲嶅鎻愪氦"); } Date now = new Date(); - // todo:luxiaotao 瑙f瀽鏉$爜瑙勫垯锛岃幏鍙栫墿鏂欎唬鐮� pack = new Pack( - barcode, // 鏉$爜[闈炵┖] - null, // 鍟嗗搧缂栧彿 - null, // 鎵瑰彿 + param.getBarcode(), // 鏉$爜[闈炵┖] + analyse.getMatnr(), // 鍟嗗搧缂栧彿 + analyse.getBarcode(), // 搴忓垪鐮� 1L, // 璁㈠崟鐘舵�� 1, // 鐘舵�� now, // 娣诲姞鏃堕棿 @@ -336,16 +381,358 @@ if (!packService.insert(pack)) { throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳"); } - Mat mat = new Mat(); - mat.setTagId(tagService.getTop().getId()); - mat.setMatnr(barcode); - mat.setMaktx(barcode); - mat.setStatus(1); - mat.setCreateTime(now); - mat.setUpdateTime(now); - if (!matService.insert(mat)) { - throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳"); + + Mat mat = matService.selectByMatnr(analyse.getMatnr()); + if (mat == null) { + mat = new Mat(); + // 鍒嗙被 + Long tagId; + // 涓�绾у垎绫� + if (!Cools.isEmpty(param.getGroupCode()) && !Cools.isEmpty(param.getGroupName())) { + Tag priTag = tagService.selectByName(param.getGroupCode(), 2); + if (priTag == null) { + Tag top = tagService.getTop(); + NodeUtils nodeUtils = new NodeUtils(); + nodeUtils.executePath(top.getId()); + priTag = new Tag( + null, // 缂栧彿 + param.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(param.getGroupName(), 3); + if (secTag == null) { + NodeUtils nodeUtils = new NodeUtils(); + nodeUtils.executePath(priTag.getId()); + secTag = new Tag( + null, // 缂栧彿 + param.getGroupName(), // 鍚嶇О + priTag.getId(), // 鐖剁骇 + priTag.getName(), // 鐖剁骇鍚嶇О + nodeUtils.path.toString(), // 鍏宠仈璺緞 + nodeUtils.pathName.toString(), // 鍏宠仈璺緞鍚� + 0, // 绫诲瀷 + null, // 璐熻矗浜� + null, // 鍥剧墖 + null, // 绠�瑕佹弿杩� + null, // 鏁伴噺 + 3, // 绛夌骇 + null, // 鎺掑簭 + 1, // 鐘舵�� + now, // 娣诲姞鏃堕棿 + null, // 娣诲姞浜哄憳 + now, // 淇敼鏃堕棿 + null, // 淇敼浜哄憳 + null // 澶囨敞 + ); + if (tagMapper.insert(secTag) == 0) { + throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳"); + } + } + tagId = secTag.getId(); + } else { + tagId = tagService.getTop().getId(); + } + mat.setTagId(tagId); + mat.setMatnr(analyse.getMatnr()); + mat.setMaktx(param.getMaterialName()); + mat.setSpecs(param.getConfigureDesc()); + mat.setModel(analyse.getModel()); + mat.setStatus(1); + mat.setCreateTime(now); + mat.setUpdateTime(now); + if (!matService.insert(mat)) { + throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳"); + } else { + log.info("鎵撳寘涓婄嚎娣诲姞鏂扮墿鏂橻鍟嗗搧缂栧彿锛歿}]", mat.getMatnr()); + } } } + @Override + @Transactional + public void syncMat(MatSyncParam param) { + if (Cools.isEmpty(param.getMatDetails()) || param.getMatDetails().size() <=0 ) { + throw new CoolException("鍟嗗搧鏁版嵁涓虹┖"); + } + + for(MatSyncParam.MatParam matParam : param.getMatDetails()){ + if(Cools.isEmpty(matParam.getMatnr())){ + throw new CoolException("鍟嗗搧缂栫爜涓嶈兘涓虹┖"); + } + + Date now = new Date(); + Mat mat = matService.selectByMatnr(matParam.getMatnr()); + // 鍒嗙被 + Long tagId; + // 涓�绾у垎绫� + 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(tag.getId()); + mat.setStatus(1); + mat.setCreateTime(now); + mat.setUpdateTime(now); + if (!matService.insert(mat)) { + throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳"); + } else { + log.info("鍚屾鏂扮墿鏂橻鍟嗗搧缂栧彿锛歿}]", mat.getMatnr()); + } + } else { + mat.sync(matParam); + mat.setTagId(tag.getId()); + if (!matService.update(mat, new EntityWrapper<Mat>().eq("matnr",matParam.getMatnr()))) { + throw new CoolException("鏇存柊宸插瓨鍦ㄥ晢鍝佷俊鎭け璐ワ紝璇疯仈绯荤鐞嗗憳"); + } + } + } + + } + + + @Override + public List<LocDetlByTimeDTO> selectTimeLocDetl(TimeSelectParam param) { + ArrayList<LocDetlByTimeDTO> locDetlByTimeDTOS = new ArrayList<>(); + EntityWrapper<WrkMastLog> wrkMastLogEntityWrapper = new EntityWrapper<>(); + 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 -> { + 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); + } + } + + }); + } + + }); +// if (!Cools.isEmpty(locDetls)) { +// for (LocDetl locDetl : locDetls) { +// +// if (!Cools.isEmpty(locDetl.getOrderNo())){ +// Order order = orderService.selectByNo(locDetl.getOrderNo()); +// if (!Cools.isEmpty(order)) { +// locDetlByTimeDTO.setDate(order.getOrderTime()); +// locDetlByTimeDTO.setWarehouse(order.getItemName()); +// locDetlByTimeDTO.setOrderType(order.getDocType().toString()); +// } +// } +// +// locDetlByTimeDTO.setMatnr(locDetl.getMatnr()); +// locDetlByTimeDTO.setLocNo(locDetl.getLocNo()); +// locDetlByTimeDTO.setBatch(locDetl.getBatch()); +// locDetlByTimeDTO.setAnfme(locDetl.getAnfme()); +// locDetlByTimeDTO.setOrderNo(locDetl.getOrderNo()); +// locDetlByTimeDTOS.add(locDetlByTimeDTO); +// } +// } + return locDetlByTimeDTOS; + } + + @Override + @Transactional + public boolean agvHaiKang(String wrkNo) { + WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", Long.parseLong(wrkNo))); + wrkMast.setWrkSts(wrkMast.getWrkStsComplete()); + wrkMastService.updateById(wrkMast); + 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