From bb9b35b41b2a446866ccf22769b116d2631fa56b Mon Sep 17 00:00:00 2001 From: futian.liu <liufutianyoo@163.com> Date: 星期四, 07 十二月 2023 17:50:55 +0800 Subject: [PATCH] 部门分发详情去重 --- consum-base/src/main/java/com/consum/base/service/impl/LWhFormTransferServiceImpl.java | 67 ++++++++++++++++++++------------- 1 files changed, 41 insertions(+), 26 deletions(-) diff --git a/consum-base/src/main/java/com/consum/base/service/impl/LWhFormTransferServiceImpl.java b/consum-base/src/main/java/com/consum/base/service/impl/LWhFormTransferServiceImpl.java index 9a70d19..8bd2708 100644 --- a/consum-base/src/main/java/com/consum/base/service/impl/LWhFormTransferServiceImpl.java +++ b/consum-base/src/main/java/com/consum/base/service/impl/LWhFormTransferServiceImpl.java @@ -1,5 +1,20 @@ package com.consum.base.service.impl; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; +import java.util.Objects; +import java.util.Optional; +import java.util.stream.Collectors; + +import org.apache.commons.compress.utils.Lists; +import org.springframework.beans.BeanUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import org.springframework.transaction.interceptor.TransactionAspectSupport; +import org.springframework.util.CollectionUtils; + import com.consum.base.core.CodeGeneratorEnum; import com.consum.base.core.CodeGeneratorService; import com.consum.base.core.type.CategoryType; @@ -18,20 +33,26 @@ import com.consum.base.pojo.response.GoodsModelVO; import com.consum.base.pojo.response.GoodsTemplateInfoVO; import com.consum.base.pojo.response.LWHFromTransferExtendVO; -import com.consum.base.service.*; -import com.consum.model.po.*; +import com.consum.base.service.BaseWarehouseManagerService; +import com.consum.base.service.BaseWarehouseService; +import com.consum.base.service.FinSysTenantServiceImpl; +import com.consum.base.service.LWhFormTransferService; +import com.consum.base.service.LWhGoodsService; +import com.consum.base.service.LWhProcureModelService; +import com.consum.base.service.LWhProcureModelUserRecordService; +import com.consum.base.service.LWhProcureModelUserService; +import com.consum.model.po.BaseWarehouse; +import com.consum.model.po.BaseWarehouseManager; +import com.consum.model.po.FinSysTenant; +import com.consum.model.po.FinSysTenantUser; +import com.consum.model.po.LWhFormTransfer; +import com.consum.model.po.LWhProcureModel; +import com.consum.model.po.LWhProcureModelUser; +import com.consum.model.po.LWhProcureModelUserRecord; import com.walker.db.page.GenericPager; +import com.walker.infrastructure.utils.DateUtils; import com.walker.infrastructure.utils.StringUtils; import com.walker.jdbc.service.BaseServiceImpl; -import org.apache.commons.compress.utils.Lists; -import org.springframework.beans.BeanUtils; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Service; -import org.springframework.transaction.interceptor.TransactionAspectSupport; -import org.springframework.util.CollectionUtils; - -import java.util.*; -import java.util.stream.Collectors; /** * @Description 璋冩嫧绠$悊 @@ -60,10 +81,10 @@ @Autowired private BaseWarehouseManagerService baseWarehouseManagerService; - private static final String QUERY_FORM_TRANSFER_LIST = - "SELECT DISTINCT ft.* FROM l_wh_form_transfer ft " + "left join L_WH_PROCURE_MODEL pm on pm.BUSINESS_ID = ft.id " - + "LEFT JOIN BASE_GOODS_MODELS bgm ON pm.BASE_GOODS_MODELS_ID=bgm.ID " - + "LEFT JOIN BASE_GOODS_TEMPLATE bgt ON bgm.GOODS_TEMPLATES_ID=bgt.id WHERE 1 = 1 "; + private static final String QUERY_FORM_TRANSFER_LIST = "SELECT DISTINCT ft.* FROM l_wh_form_transfer ft " + + "left join L_WH_PROCURE_MODEL pm on pm.BUSINESS_ID = ft.id " + + "LEFT JOIN BASE_GOODS_MODELS bgm ON pm.BASE_GOODS_MODELS_ID=bgm.ID " + + "LEFT JOIN BASE_GOODS_TEMPLATE bgt ON bgm.GOODS_TEMPLATES_ID=bgt.id WHERE 1 = 1 "; /** * @Description 鏂板 @@ -202,12 +223,14 @@ // 3.褰撲笟鍔$被鍨嬩负閮ㄩ棬鍒嗗彂鏃� 娣诲姞閮ㄩ棬鍒嗗彂璁板綍鍜屼娇鐢ㄤ汉 // 鍗曟嵁绫诲瀷 1 閲囪喘2 璋冩嫧 3鍑哄簱4閮ㄩ棬鍒嗗彂 // 閮ㄩ棬鍒嗗彂绫诲瀷 - if (businessType == 1 && "A".equals(baseModelMap.get("type"))) { + if (businessType == 1 && CategoryType.TYPE_A.getValue().equals(baseModelMap.get("type"))) { + // TODO 閲嶅淇濆瓨 LWhProcureModelUserRecord lWhProcureModelUserRecord = new LWhProcureModelUserRecord(); lWhProcureModelUserRecord.setId(IdUtil.generateId()); lWhProcureModelUserRecord.setTransBusinessId(lWhFormTransferId); lWhProcureModelUserRecord.setOperatorId(sysInfo.getId()); lWhProcureModelUserRecord.setOperatorName(sysInfo.getUserName()); + lWhProcureModelUserRecord.setDealTime(DateUtils.getDateTimeNumber(System.currentTimeMillis())); lWhProcureModelUserRecordService.insert(lWhProcureModelUserRecord); List<LWhProcureModelUser> procureModelUserList = Lists.newArrayList(); @@ -229,7 +252,6 @@ log.error("鏂板鐗╁搧浣跨敤淇℃伅澶辫触"); TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); } - } modelList.add(lWhProcureModel); @@ -336,13 +358,6 @@ if (CollectionUtils.isEmpty(goodsModelInfo)) { return result; } - // 鏌ヨ閮ㄩ棬鐗╁搧浣跨敤淇℃伅 - Map<String, Object> paramMap = new HashMap<>(); - paramMap.put("id", result.getId()); - String queryRecord = - "SELECT * FROM l_wh_procure_model_user_record where TRANS_BUSINESS_ID = :id order by DEAL_TIME desc limit 1"; - LWhProcureModelUserRecord lWhProcureModelUserRecord = - lWhProcureModelUserRecordService.get(queryRecord, paramMap, new LWhProcureModelUserRecord()); Map<Long, List<GoodModelInfoDTO>> collect = goodsModelInfo.stream().filter(Objects::nonNull).filter(dto -> dto.getBaseGoodsTemplateId() != null) @@ -372,12 +387,12 @@ String type = goodsTemplateInfoVO.getType(); if (businessType == 1 && CategoryType.TYPE_A.getValue().equals(type)) { Long procureModelId = goodsModelVO.getId(); + LWhProcureModelUser lWhProcureModelUser = new LWhProcureModelUser(); lWhProcureModelUser.setWhProcureModelId(procureModelId); - - lWhProcureModelUser.setProcureModelUserRecordId(lWhProcureModelUserRecord.getId()); List<LWhProcureModelUser> procureModelUserList = this.lWhProcureModelUserService.select(lWhProcureModelUser); + if (!CollectionUtils.isEmpty(procureModelUserList)) { List<DepartGoodsUseInfo> departGoodsUseInfoList = Lists.newArrayList(); procureModelUserList.forEach(useInfo -> { -- Gitblit v1.9.1