From cccaf417bc5cb4a9c3fa925d491ca7c1e5621a0c Mon Sep 17 00:00:00 2001
From: futian.liu <liufutianyoo@163.com>
Date: 星期一, 11 十二月 2023 11:12:39 +0800
Subject: [PATCH] 还原测试类

---
 consum-base/src/main/java/com/consum/base/controller/LWhFormTransferController.java |  106 +++++++++++++++++++++++++++++------------------------
 1 files changed, 58 insertions(+), 48 deletions(-)

diff --git a/consum-base/src/main/java/com/consum/base/controller/LWhFormTransferController.java b/consum-base/src/main/java/com/consum/base/controller/LWhFormTransferController.java
index 160179e..5dd5eae 100644
--- a/consum-base/src/main/java/com/consum/base/controller/LWhFormTransferController.java
+++ b/consum-base/src/main/java/com/consum/base/controller/LWhFormTransferController.java
@@ -6,7 +6,6 @@
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
-import java.util.Map.Entry;
 import java.util.Optional;
 import java.util.stream.Collectors;
 
@@ -132,7 +131,7 @@
             lWhFormTransferService.update(lWhFormTransfer);
             lWhFormTransferCoreService.doTransferOutPut(id, getCurrentUser());
 
-            lWhFormTransferCoreService.doTransferInPut(id, getCurrentUser());
+            lWhFormTransferCoreService.doTransferInPut(id, getCurrentUser(), param.getOperatorName());
         }
 
         return ResponseValue.success();
@@ -252,7 +251,7 @@
     @ApiImplicitParams({@ApiImplicitParam(name = "id", value = "璋冩嫧鍗昳d", required = true, dataType = "Long"),})
     @PostMapping("/income")
     public ResponseValue income(Long id) {
-        lWhFormTransferCoreService.doTransferInPut(id, getCurrentUser());
+        lWhFormTransferCoreService.doTransferInPut(id, getCurrentUser(), null);
         return ResponseValue.success();
     }
 
@@ -280,7 +279,8 @@
         lWhFormTransfer.setOutWarehouseId(wareHouseId);
         lWhFormTransfer.setOutWarehouseName(warehouseName);
         lWhFormTransferService.update(lWhFormTransfer);
-        lWhFormTransferCoreService.doTransferOutPut(id, getCurrentUser());
+        // lWhFormTransferCoreService.doTransferOutPut(id, getCurrentUser());
+        lWhFormTransferCoreService.doTransferOutPutNew(id, getCurrentUser());
         return ResponseValue.success();
     }
 
@@ -341,9 +341,13 @@
         CommonUtil.copyProperties(param, param2);
         param = param2;
 
-        S_user_core currentUser = this.getCurrentUser();
-        if (currentUser == null) {
+        FinSysTenantUser sysInfo = this.getSysInfo();
+        if (sysInfo == null) {
             return ResponseValue.error("鐧诲綍鐢ㄦ埛淇℃伅涓嶅瓨鍦�");
+        }
+        String tenantId = sysInfo.getTenantId();
+        if (param.getOutAgencyId() == null) {
+            param.setOutAgencyId(Long.valueOf(tenantId));
         }
         GenericPager<Map<String, Object>> transferInfoDetailsVoGenericPager =
             this.lWhFormTransferService.queryTransferInfo(param);
@@ -398,6 +402,12 @@
                     lWhProcureModelUser.setNowUserPhone(item.getPhone());
                     lWhProcureModelUser.setNowUserName(item.getUserName());
                     lWhProcureModelUser.setGoodsNum(item.getCount());
+
+                    // 璁剧疆涓�涓嬪湪鐢ㄦ暟閲�
+                    Long oldProcureModelId = item.getOldProcureModelId();
+                    LWhProcureModelUser oldInfo =
+                        lWhProcureModelUserService.get(new LWhProcureModelUser(oldProcureModelId));
+                    lWhProcureModelUser.setUseCount(oldInfo.getUseCount());
                     procureModelUserList.add(lWhProcureModelUser);
                 }
 
@@ -420,57 +430,57 @@
     @ApiImplicitParams({@ApiImplicitParam(name = "transferOrderId", value = "璋冩嫧鍗昳d", required = true)})
     @GetMapping("/use/record")
     public ResponseValue useRecord(Long transferOrderId) {
-
         S_user_core currentUser = this.getCurrentUser();
         if (currentUser == null) {
             return ResponseValue.error("鐧诲綍鐢ㄦ埛淇℃伅涓嶅瓨鍦�");
         }
+
         List<UseRecordDTO> useRecordDTOList = lWhProcureModelUserService.selectUseRecord(transferOrderId);
         if (CollectionUtils.isEmpty(useRecordDTOList)) {
             return ResponseValue.error("鏈煡璇㈠埌浣跨敤璁板綍");
         }
-        List<GoodsUseRecordVO> goodsUseRecordList = Lists.newArrayList();
-        // 鍒嗙粍
-        Map<Long, List<UseRecordDTO>> groupedRecords =
-            useRecordDTOList.stream().collect(Collectors.groupingBy(UseRecordDTO::getId));
-        for (Entry<Long, List<UseRecordDTO>> entry : groupedRecords.entrySet()) {
-            Long id = entry.getKey();
-            List<UseRecordDTO> useRecordList = entry.getValue();
-            UseRecordDTO useRecordDto = useRecordList.get(0);
-            // 寮�濮嬪惊鐜痸alue
-            GoodsUseRecordVO goodsUseRecordVO = new GoodsUseRecordVO();
-            goodsUseRecordVO.setId(id);
-            goodsUseRecordVO.setUpdateUserName(useRecordDto.getUpdateUserName());
-            goodsUseRecordVO.setUpdateTime(useRecordDto.getUpdateTime());
-            List<UseRecordSkuVO> useRecordSkuList = Lists.newArrayList();
-            useRecordList.stream().collect(Collectors.groupingBy(UseRecordDTO::getProcureModelId))
-                .forEach((key, recordList) -> {
-                    UseRecordDTO useRecordDTO = recordList.get(0);
-                    UseRecordSkuVO useRecordSkuVO = new UseRecordSkuVO();
-                    useRecordSkuVO.setBaseGoodModelId(useRecordDTO.getBaseGoodsModelsId());
-                    useRecordSkuVO.setBaseGoodModelName(useRecordDTO.getBaseGoodsModelsName());
-                    useRecordSkuVO.setUnit(useRecordDTO.getUnit());
-                    useRecordSkuVO.setProcureModelId(useRecordDTO.getProcureModelId());
-                    List<RecordUserInfoVO> recordUserInfoList = Lists.newArrayList();
-                    for (UseRecordDTO userInfo : recordList) {
-                        RecordUserInfoVO recordUserInfoVO = new RecordUserInfoVO();
-                        recordUserInfoVO.setUseName(userInfo.getUseName());
-                        recordUserInfoVO.setPhone(userInfo.getPhone());
-                        recordUserInfoVO.setNum(userInfo.getNum());
-                        recordUserInfoList.add(recordUserInfoVO);
-                    }
-                    useRecordSkuVO.setRecordUserInfos(recordUserInfoList);
-                    useRecordSkuList.add(useRecordSkuVO);
-                });
-            goodsUseRecordVO.setRecordSkuDtoList(useRecordSkuList);
-            goodsUseRecordList.add(goodsUseRecordVO);
-        }
-        // 鍒嗙粍涔嬪悗閲嶆柊鎺掑簭
-        List<GoodsUseRecordVO> result = goodsUseRecordList
-            .stream().sorted(Comparator
-                .comparing(GoodsUseRecordVO::getUpdateTime, Comparator.nullsFirst(Long::compareTo)).reversed())
+
+        List<GoodsUseRecordVO> goodsUseRecordList = useRecordDTOList.stream()
+            .collect(Collectors.groupingBy(UseRecordDTO::getId)).entrySet().stream().map(entry -> {
+                Long id = entry.getKey();
+                List<UseRecordDTO> useRecordList = entry.getValue();
+                UseRecordDTO useRecordDto = useRecordList.get(0);
+
+                GoodsUseRecordVO goodsUseRecordVO = new GoodsUseRecordVO();
+                goodsUseRecordVO.setId(id);
+                goodsUseRecordVO.setUpdateUserName(useRecordDto.getUpdateUserName());
+                goodsUseRecordVO.setUpdateTime(useRecordDto.getUpdateTime());
+
+                List<UseRecordSkuVO> useRecordSkuList =
+                    useRecordList.stream().collect(Collectors.groupingBy(UseRecordDTO::getProcureModelId)).values()
+                        .stream().map(recordList -> {
+                            UseRecordDTO useRecordDTO = recordList.get(0);
+                            UseRecordSkuVO useRecordSkuVO = new UseRecordSkuVO();
+                            useRecordSkuVO.setBaseGoodModelId(useRecordDTO.getBaseGoodsModelsId());
+                            useRecordSkuVO.setBaseGoodModelName(useRecordDTO.getBaseGoodsModelsName());
+                            useRecordSkuVO.setUnit(useRecordDTO.getUnit());
+                            useRecordSkuVO.setProcureModelId(useRecordDTO.getProcureModelId());
+
+                            List<RecordUserInfoVO> recordUserInfoList = recordList.stream().map(userInfo -> {
+                                RecordUserInfoVO recordUserInfoVO = new RecordUserInfoVO();
+                                recordUserInfoVO.setOldProcureModelId(userInfo.getOldProcureModelId());
+                                recordUserInfoVO.setUseName(userInfo.getUseName());
+                                recordUserInfoVO.setPhone(userInfo.getPhone());
+                                recordUserInfoVO.setNum(userInfo.getNum());
+                                return recordUserInfoVO;
+                            }).collect(Collectors.toList());
+
+                            useRecordSkuVO.setRecordUserInfos(recordUserInfoList);
+                            return useRecordSkuVO;
+                        }).collect(Collectors.toList());
+
+                goodsUseRecordVO.setRecordSkuDtoList(useRecordSkuList);
+                return goodsUseRecordVO;
+            }).sorted(Comparator.comparing(GoodsUseRecordVO::getUpdateTime, Comparator.nullsFirst(Long::compareTo))
+                .reversed())
             .collect(Collectors.toList());
-        return ResponseValue.success(result);
+
+        return ResponseValue.success(goodsUseRecordList);
     }
 
     @ApiOperation(value = "鏌ヨ閮ㄩ棬涓嬬殑鍒嗗彂鍗�", notes = "鏌ヨ閮ㄩ棬涓嬬殑鍒嗗彂鍗�")

--
Gitblit v1.9.1