From 3e9a4b3480e6508f3c6f7ac8723509d8b1120d20 Mon Sep 17 00:00:00 2001
From: futian.liu <liufutianyoo@163.com>
Date: 星期五, 22 十二月 2023 11:26:33 +0800
Subject: [PATCH] 代码整理
---
consum-base/src/main/java/com/consum/base/service/core/DepUsingFormBackCoreService.java | 159 ++++++++++++++++++++++++++++------------------------
1 files changed, 86 insertions(+), 73 deletions(-)
diff --git a/consum-base/src/main/java/com/consum/base/core/DepUsingFormBackCoreServiceImpl.java b/consum-base/src/main/java/com/consum/base/service/core/DepUsingFormBackCoreService.java
similarity index 73%
rename from consum-base/src/main/java/com/consum/base/core/DepUsingFormBackCoreServiceImpl.java
rename to consum-base/src/main/java/com/consum/base/service/core/DepUsingFormBackCoreService.java
index 39cbf33..bd0b89b 100644
--- a/consum-base/src/main/java/com/consum/base/core/DepUsingFormBackCoreServiceImpl.java
+++ b/consum-base/src/main/java/com/consum/base/service/core/DepUsingFormBackCoreService.java
@@ -1,10 +1,23 @@
-package com.consum.base.core;
+package com.consum.base.service.core;
-import cn.hutool.core.convert.Convert;
-import com.consum.base.core.service.LWhWarningCoreServiceImpl;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+import javax.annotation.Resource;
+
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.interceptor.TransactionAspectSupport;
+
+import com.consum.base.core.WhBusinessEnum;
import com.consum.base.core.utils.IdUtil;
import com.consum.base.core.utils.LockManage;
-import com.consum.base.service.GoodsBaseServiceImpl;
+import com.consum.base.service.GoodsBaseService;
import com.consum.base.service.LWarehouseFlowService;
import com.consum.base.service.LWhGoodsRecordService;
import com.consum.base.service.LWhGoodsService;
@@ -16,19 +29,9 @@
import com.iplatform.model.po.S_user_core;
import com.walker.infrastructure.utils.CollectionUtils;
import com.walker.web.ResponseValue;
-import java.util.Arrays;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Propagation;
-import org.springframework.transaction.annotation.Transactional;
-import org.springframework.transaction.interceptor.TransactionAspectSupport;
-import javax.annotation.Resource;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.stream.Collectors;
+import cn.hutool.core.convert.Convert;
+import lombok.extern.slf4j.Slf4j;
/**
* @ClassName DepFormScrappedCoreServiceImpl
@@ -40,9 +43,9 @@
@Service
@Slf4j
@Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED)
-public class DepUsingFormBackCoreServiceImpl {
+public class DepUsingFormBackCoreService {
@Resource
- private GoodsBaseServiceImpl goodsBaseService;
+ private GoodsBaseService goodsBaseService;
@Resource
private LWhGoodsService lWhGoodsService;
@Resource
@@ -50,9 +53,9 @@
@Resource
private LWhGoodsRecordService lWhGoodsRecordServiceImpl;
@Resource
- private LWarehouseFlowService lWarehouseFlowService;
+ private LWarehouseFlowService lWarehouseFlowServiceImpl;
@Resource
- private LWhWarningCoreServiceImpl lWhWarningCoreService;
+ private LWhWarningCoreService lWhWarningCoreService;
/**
* 鏍规嵁鎶ュ簾鍗曟姤搴燂細淇敼璋冩嫧鍗曚腑鍙��鍥炴暟閲忥紱浠撳簱涓墿鍝佺姸鎬佽缃负鎶ュ簾;鐢熸垚涓�涓繚璐规祦姘达紱鏇存柊鎶ュ簾鍨嬪彿琛ㄤ腑锛岀墿鍝佷环鍊�
@@ -65,7 +68,7 @@
// 鏌ヨ鎶ュ簾鍗曠姸鎬�
UsingFormBack depFormScrapped = new UsingFormBack(lWhFormBackId);
depFormScrapped = goodsBaseService.get(depFormScrapped);
- //鐘舵�� 1=寰呮姤搴燂紱2=宸叉姤搴�
+ // 鐘舵�� 1=寰呮姤搴燂紱2=宸叉姤搴�
if (depFormScrapped == null || depFormScrapped.getStates() != 1) {
return ResponseValue.error("璇锋鏌ユ姤搴熷崟");
}
@@ -74,9 +77,11 @@
String nickName = currentUser.getNick_name();
// 鏍规嵁鎶ュ簾鍗� 鏌ヨ闇�瑕佹姤搴熺殑鍨嬪彿鏁伴噺
- List<Map<String, Object>> bfModelList = goodsBaseService.select("SELECT scrGoods.TRANS_OUT_WAREHOUSE_TYPE,scrGoods.TRANS_OUT_WAREHOUSE_ID,scrGoods.TRANS_BUSINESS_ID,scrGoods.BUSINESS_FORM_CODE,scrGoods.TRANS_OUT_WAREHOUSE_TYPE,scrGoods.TRANS_OUT_WAREHOUSE_ID,scrGoods.BASE_GOODS_TEMPLATE_ID,scrGoods.BASE_GOODS_TEMPLATE_NAME,goodsModel.id formScrappedModelId,goodsModel.BASE_GOODS_TEMPLATE_ID,goodsModel.BASE_GOODS_MODELS_ID,goodsModel.COUNTS,goodsModel.PROCURE_MODEL_USER_ID,goodsModel.GOODS_USER_NAME,goodsModel.BASE_GOODS_MODELS_NAME FROM USING_FORM_BACK_GOODS scrGoods LEFT JOIN USING_FORM_BACK_MODEL goodsModel ON scrgoods.id=goodsModel.USING_FORM_BACK_GOODS_ID WHERE scrGoods.USING_FORM_BACK_ID=?", new Object[]{lWhFormBackId});
- Map<Object, List<Map<String, Object>>> groupByModelIdMap = bfModelList.stream()
- .collect(Collectors.groupingBy(map -> map.get("BASE_GOODS_MODELS_ID")));
+ List<Map<String, Object>> bfModelList = goodsBaseService.select(
+ "SELECT scrGoods.TRANS_OUT_WAREHOUSE_TYPE,scrGoods.TRANS_OUT_WAREHOUSE_ID,scrGoods.TRANS_BUSINESS_ID,scrGoods.BUSINESS_FORM_CODE,scrGoods.TRANS_OUT_WAREHOUSE_TYPE,scrGoods.TRANS_OUT_WAREHOUSE_ID,scrGoods.BASE_GOODS_TEMPLATE_ID,scrGoods.BASE_GOODS_TEMPLATE_NAME,goodsModel.id formScrappedModelId,goodsModel.BASE_GOODS_TEMPLATE_ID,goodsModel.BASE_GOODS_MODELS_ID,goodsModel.COUNTS,goodsModel.PROCURE_MODEL_USER_ID,goodsModel.GOODS_USER_NAME,goodsModel.BASE_GOODS_MODELS_NAME FROM USING_FORM_BACK_GOODS scrGoods LEFT JOIN USING_FORM_BACK_MODEL goodsModel ON scrgoods.id=goodsModel.USING_FORM_BACK_GOODS_ID WHERE scrGoods.USING_FORM_BACK_ID=?",
+ new Object[] {lWhFormBackId});
+ Map<Object, List<Map<String, Object>>> groupByModelIdMap =
+ bfModelList.stream().collect(Collectors.groupingBy(map -> map.get("BASE_GOODS_MODELS_ID")));
Integer warehouseType = depFormScrapped.getOutWarehouseType();
Long warehouseId = depFormScrapped.getOutWarehouseId();
String warehouseName = depFormScrapped.getOutWarehouseName();
@@ -89,15 +94,15 @@
ArrayList<LWhGoodsRecord> lWhGoodsRecordList = new ArrayList<>();
- //閲囪喘銆佽皟鎷ㄣ�佸嚭搴撶瓑鐨勭墿鍝佸瀷鍙枫�怢_WH_PROCURE_MODEL銆戜腑 鏍规嵁璋冩嫧鍗�+鍨嬪彿 鏇存柊 鍦ㄧ敤鏁伴噺
+ // 閲囪喘銆佽皟鎷ㄣ�佸嚭搴撶瓑鐨勭墿鍝佸瀷鍙枫�怢_WH_PROCURE_MODEL銆戜腑 鏍规嵁璋冩嫧鍗�+鍨嬪彿 鏇存柊 鍦ㄧ敤鏁伴噺
Map<String, Integer> procureModelMap = new HashMap<>();
for (Object key : groupByModelIdMap.keySet()) {
Long modelTotalPrice = 0L;
- //瑕佹姤搴熺殑鎬绘暟閲�
+ // 瑕佹姤搴熺殑鎬绘暟閲�
int modelTotalNum = 0;
- Long baseGoodsModelsId = (Long) key;
+ Long baseGoodsModelsId = (Long)key;
List<Map<String, Object>> eachFfModelList = groupByModelIdMap.get(key);
Map<String, Object> eachFfModelBase = eachFfModelList.get(0);
Long tempGoodsId = Convert.toLong(eachFfModelBase.get("BASE_GOODS_TEMPLATE_ID"));
@@ -116,18 +121,19 @@
whGoodsRecord.setBaseGoodsModelsId(baseGoodsModelsId);
whGoodsRecord.setBaseGoodsModelsName(modelName);
whGoodsRecord.setDealTime(dealTime);
- //鏈璋冩暣绫诲瀷 1=璋冨锛�2=璋冨噺
+ // 鏈璋冩暣绫诲瀷 1=璋冨锛�2=璋冨噺
whGoodsRecord.setThisType(2);
- //閫氳繃LockManage鑾峰緱閿�
+ // 閫氳繃LockManage鑾峰緱閿�
Object warehouseModelLockObj = LockManage.acquireLock(warehouseType, warehouseId, baseGoodsModelsId);
int goodsModelNum = 0;
synchronized (warehouseModelLockObj) {
List<Long> warehouseIds = new ArrayList<>(Arrays.asList(warehouseId));
- goodsModelNum = lWhGoodsService.queryGoodsModelNum(warehouseType, warehouseIds, baseGoodsModelsId, 2, null);
+ goodsModelNum =
+ lWhGoodsService.queryGoodsModelNum(warehouseType, warehouseIds, baseGoodsModelsId, 2, null);
for (Map<String, Object> depFormScrappedModel : eachFfModelList) {
// 璋冩嫧鍗曚俊鎭�
- Long transBusinessId = (Long) depFormScrappedModel.get("TRANS_BUSINESS_ID");
+ Long transBusinessId = (Long)depFormScrappedModel.get("TRANS_BUSINESS_ID");
String nowUserName = Convert.toStr(depFormScrappedModel.get("GOODS_USER_NAME"));
Integer counts = Convert.toInt(depFormScrappedModel.get("COUNTS"));
Long formScrappedModelId = Convert.toLong(depFormScrappedModel.get("formScrappedModelId"));
@@ -135,7 +141,8 @@
modelTotalNum += counts;
// 鏍规嵁鍒嗗彂鍗曘�佸瀷鍙枫�佷娇鐢ㄤ汉淇℃伅鏌ヨ鐗╁搧淇℃伅
- List<Map<String, Object>> scrappedGoodsList = lWhGoodsService.queryScrappedGoods(warehouseType, warehouseId, transBusinessId, nowUserName, baseGoodsModelsId, (short) 2, counts);
+ List<Map<String, Object>> scrappedGoodsList = lWhGoodsService.queryScrappedGoods(warehouseType,
+ warehouseId, transBusinessId, nowUserName, baseGoodsModelsId, (short)2, counts);
if (CollectionUtils.isEmpty(scrappedGoodsList) || scrappedGoodsList.size() < counts) {
log.error("瑕侀��鍥炵殑鐗╁搧鏁伴噺涓嶈冻锛�");
// 鎵嬪姩鍥炴粴
@@ -145,21 +152,24 @@
// 鏀惧叆鐗╁搧ID绛変俊鎭�
depFormScrappedModel.put("scrappedGoodsList", scrappedGoodsList);
- Long formScrappedModelPrice = scrappedGoodsList.stream().mapToLong(map -> (long) map.get("price")).sum();
+ Long formScrappedModelPrice =
+ scrappedGoodsList.stream().mapToLong(map -> (long)map.get("price")).sum();
modelTotalPrice += formScrappedModelPrice;
// 鏇存柊 鎶ュ簾鍗曠墿鍝併�怐EP_FORM_SCRAPPED_MODEL銆戜腑 浠锋牸
modelTotalPriceMap.put(formScrappedModelId, formScrappedModelPrice);
- //閲囪喘銆佽皟鎷ㄣ�佸嚭搴撶瓑鐨勭墿鍝佸瀷鍙枫�怢_WH_PROCURE_MODEL銆戜腑 鍦ㄧ敤鏁伴噺
- Integer procureModelNum = Convert.toInt(procureModelMap.get(transBusinessId + "_" + baseGoodsModelsId), 0);
+ // 閲囪喘銆佽皟鎷ㄣ�佸嚭搴撶瓑鐨勭墿鍝佸瀷鍙枫�怢_WH_PROCURE_MODEL銆戜腑 鍦ㄧ敤鏁伴噺
+ Integer procureModelNum =
+ Convert.toInt(procureModelMap.get(transBusinessId + "_" + baseGoodsModelsId), 0);
procureModelMap.put(transBusinessId + "_" + baseGoodsModelsId, counts + procureModelNum);
// 姹囨�诲嚭闇�瑕佷慨鏀圭姸鎬佺殑鐗╁搧id
- List<Long> srappedGoodsIds = scrappedGoodsList.stream().map(map -> (Long) map.get("id")).collect(Collectors.toList());
+ List<Long> srappedGoodsIds =
+ scrappedGoodsList.stream().map(map -> (Long)map.get("id")).collect(Collectors.toList());
// 璁剧疆鐗╁搧涓烘姤搴熺姸鎬�
-// lWhGoodsService.modGoodsTransfering(srappedGoodsIds, null, null, null, 3);
+ // lWhGoodsService.modGoodsTransfering(srappedGoodsIds, null, null, null, 3);
// 鎵归噺鎻掑叆 杩涘嚭搴撴祦姘存槑缁哰L_WH_GOODS_RECORD_DETAILS]
- lWhGoodsRecordDetailsService.sameGoodsInsertMore(srappedGoodsIds, whGoodsRecordId, (short) 2);
+ lWhGoodsRecordDetailsService.sameGoodsInsertMore(srappedGoodsIds, whGoodsRecordId, (short)2);
}
}
@@ -167,7 +177,7 @@
whGoodsRecord.setEndCount(goodsModelNum - modelTotalNum);
whGoodsRecord.setThisCount(modelTotalNum);
whGoodsRecord.setTotalPrice(modelTotalPrice);
-// lWhGoodsRecordService.insert(whGoodsRecord);
+ // lWhGoodsRecordService.insert(whGoodsRecord);
lWhGoodsRecordList.add(whGoodsRecord);
}
@@ -184,7 +194,7 @@
warehouseFlow.setOperatorName(nickName);
warehouseFlow.setDealTime(dealTime);
// 鎻掑叆娴佹按鎬昏〃
- int flowInsertFlag = lWarehouseFlowService.insert(warehouseFlow);
+ int flowInsertFlag = lWarehouseFlowServiceImpl.insert(warehouseFlow);
if (flowInsertFlag == 0) {
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
return null;
@@ -209,19 +219,20 @@
}
goodsBaseService.execBatchUpdate("update DEP_FORM_SCRAPPED_MODEL set TOTAL_AMOUNT=? where id=?", parameterList);
- //濡傛灉鏄疉绫荤墿鍝侊紝鍒欐洿鏂� 鍒嗗彂鐗╁搧浣跨敤浜恒�怢_WH_PROCURE_MODEL_USER銆� 涓� 鏍规嵁id 鏇存柊 鍦ㄧ敤鏁伴噺(USE_COUNT)
+ // 濡傛灉鏄疉绫荤墿鍝侊紝鍒欐洿鏂� 鍒嗗彂鐗╁搧浣跨敤浜恒�怢_WH_PROCURE_MODEL_USER銆� 涓� 鏍规嵁id 鏇存柊 鍦ㄧ敤鏁伴噺(USE_COUNT)
List<Object[]> procureModelUserIdList = new ArrayList<>();
for (Map<String, Object> itemMap : bfModelList) {
Long procureModelUserId = Convert.toLong(itemMap.get("PROCURE_MODEL_USER_ID"));
- if (procureModelUserId==null){
+ if (procureModelUserId == null) {
continue;
}
Integer counts = Convert.toInt(itemMap.get("COUNTS"));
-// StringBuilder sb = new StringBuilder("update L_WH_PROCURE_MODEL_USER set USE_COUNT=USE_COUNT-").append(counts);
-// sb.append(" where id=").append(procureModelUserId);
-// sb.append(" and USE_COUNT-").append(counts).append(" >=0");
-// goodsBaseService.update(sb.toString());
+ // StringBuilder sb = new StringBuilder("update L_WH_PROCURE_MODEL_USER set
+ // USE_COUNT=USE_COUNT-").append(counts);
+ // sb.append(" where id=").append(procureModelUserId);
+ // sb.append(" and USE_COUNT-").append(counts).append(" >=0");
+ // goodsBaseService.update(sb.toString());
Object[] one = new Object[3];
one[0] = counts;
@@ -230,11 +241,12 @@
procureModelUserIdList.add(one);
}
if (!CollectionUtils.isEmpty(procureModelUserIdList)) {
- goodsBaseService.execBatchUpdate("update L_WH_PROCURE_MODEL_USER set USE_COUNT=USE_COUNT- ? where id= ? and USE_COUNT- ? >=0", procureModelUserIdList);
+ goodsBaseService.execBatchUpdate(
+ "update L_WH_PROCURE_MODEL_USER set USE_COUNT=USE_COUNT- ? where id= ? and USE_COUNT- ? >=0",
+ procureModelUserIdList);
}
-
- //閲囪喘銆佽皟鎷ㄣ�佸嚭搴撶瓑鐨勭墿鍝佸瀷鍙枫�怢_WH_PROCURE_MODEL銆戜腑 鏍规嵁璋冩嫧鍗�+鍨嬪彿 鏇存柊 鍦ㄧ敤鏁伴噺
+ // 閲囪喘銆佽皟鎷ㄣ�佸嚭搴撶瓑鐨勭墿鍝佸瀷鍙枫�怢_WH_PROCURE_MODEL銆戜腑 鏍规嵁璋冩嫧鍗�+鍨嬪彿 鏇存柊 鍦ㄧ敤鏁伴噺
List<Object[]> procureModelParameterList = new ArrayList<>();
for (Map.Entry<String, Integer> entry : procureModelMap.entrySet()) {
String key = entry.getKey();
@@ -255,13 +267,13 @@
sb.append(modelUseingNum).append(" >=0");
goodsBaseService.update(sb.toString());
}
-// goodsBaseService.execBatchUpdate("update L_WH_PROCURE_MODEL set USE_COUNT=USE_COUNT-? where BUSINESS_TYPE=4 and BUSINESS_ID=? and BASE_GOODS_MODELS_ID=? and USE_COUNT=USE_COUNT-? >0", parameterList);
-
+ // goodsBaseService.execBatchUpdate("update L_WH_PROCURE_MODEL set USE_COUNT=USE_COUNT-? where BUSINESS_TYPE=4
+ // and BUSINESS_ID=? and BASE_GOODS_MODELS_ID=? and USE_COUNT=USE_COUNT-? >0", parameterList);
// 鎿嶄綔鍏ュ簱锛屾鏃惰鎸夌墿鍝佹墍灞炰粨搴� 鐢熸垚涓嶅悓浠撳簱鍏ュ簱鐨勬祦姘�
- Map<String, List<Map<String, Object>>> groupByOutWarehouseIdMap = bfModelList.stream()
- .collect(Collectors.groupingBy(map -> map.get("TRANS_OUT_WAREHOUSE_TYPE") + "_" + map.get("TRANS_OUT_WAREHOUSE_ID")));
- //姣忎釜浠撳簱涓�涓祦姘磋〃
+ Map<String, List<Map<String, Object>>> groupByOutWarehouseIdMap = bfModelList.stream().collect(Collectors
+ .groupingBy(map -> map.get("TRANS_OUT_WAREHOUSE_TYPE") + "_" + map.get("TRANS_OUT_WAREHOUSE_ID")));
+ // 姣忎釜浠撳簱涓�涓祦姘磋〃
ArrayList<LWarehouseFlow> flowArrayList = new ArrayList<>();
ArrayList<LWhGoodsRecord> flowRecordArrayList = new ArrayList<>();
@@ -269,7 +281,7 @@
List<Map<String, Object>> eachWareHouseList = groupByOutWarehouseIdMap.get(outWarehouseTypeAndId);
Map<String, Object> eachWarehouseModelMap = eachWareHouseList.get(0);
-// Integer inWareHouseType = Convert.toInt(eachWarehouseModelMap.get("TRANS_OUT_WAREHOUSE_TYPE"));
+ // Integer inWareHouseType = Convert.toInt(eachWarehouseModelMap.get("TRANS_OUT_WAREHOUSE_TYPE"));
Long inWarehouseId = Convert.toLong(eachWarehouseModelMap.get("TRANS_OUT_WAREHOUSE_ID"));
String inWarehouseName = null;
BaseWarehouse baseWarehouse = goodsBaseService.get(new BaseWarehouse(inWarehouseId));
@@ -293,11 +305,11 @@
inWarehouseFlow.setDealTime(dealTime);
flowArrayList.add(inWarehouseFlow);
- //鎸夊瀷鍙峰垎 姣忎釜鍨嬪彿涓�涓� L_WH_GOODS_RECORD
- Map<Object, List<Map<String, Object>>> eachWareHouseModelMap = eachWareHouseList.stream()
- .collect(Collectors.groupingBy(map -> map.get("BASE_GOODS_MODELS_ID")));
+ // 鎸夊瀷鍙峰垎 姣忎釜鍨嬪彿涓�涓� L_WH_GOODS_RECORD
+ Map<Object, List<Map<String, Object>>> eachWareHouseModelMap =
+ eachWareHouseList.stream().collect(Collectors.groupingBy(map -> map.get("BASE_GOODS_MODELS_ID")));
for (Object key : eachWareHouseModelMap.keySet()) {
- Long baseGoodsModelsId = (Long) key;
+ Long baseGoodsModelsId = (Long)key;
List<Map<String, Object>> eachFfModelList = eachWareHouseModelMap.get(baseGoodsModelsId);
Map<String, Object> eachFfModelBase = eachFfModelList.get(0);
@@ -317,50 +329,51 @@
whGoodsRecord.setBaseGoodsModelsId(baseGoodsModelsId);
whGoodsRecord.setBaseGoodsModelsName(modelName);
whGoodsRecord.setDealTime(dealTime);
- //鏈璋冩暣绫诲瀷 1=璋冨锛�2=璋冨噺
+ // 鏈璋冩暣绫诲瀷 1=璋冨锛�2=璋冨噺
whGoodsRecord.setThisType(1);
- //閫氳繃LockManage鑾峰緱閿�
+ // 閫氳繃LockManage鑾峰緱閿�
Object warehouseModelLockObj = LockManage.acquireLock(0, inWarehouseId, baseGoodsModelsId);
int goodsModelNum = 0;
// 瀛樻斁鎵�鏈夌殑鐗╁搧id 浠锋牸绛変俊鎭�
List<Map<String, Object>> scrappedAllGoodsList = new ArrayList<>();
synchronized (warehouseModelLockObj) {
- //鏌ヨ鏈熷垵鏁伴噺
+ // 鏌ヨ鏈熷垵鏁伴噺
List<Long> warehouseIds = new ArrayList<>(Arrays.asList(inWarehouseId));
goodsModelNum = lWhGoodsService.queryGoodsModelNum(0, warehouseIds, baseGoodsModelsId, 1, null);
for (Map<String, Object> depFormScrappedModel : eachFfModelList) {
- scrappedAllGoodsList.addAll((List<Map<String, Object>>) depFormScrappedModel.get("scrappedGoodsList"));
+ scrappedAllGoodsList
+ .addAll((List<Map<String, Object>>)depFormScrappedModel.get("scrappedGoodsList"));
}
// 姹囨�诲嚭闇�瑕佷慨鏀圭姸鎬佺殑鐗╁搧id
- List<Long> srappedGoodsIds = scrappedAllGoodsList.stream().map(map -> (Long) map.get("id")).collect(Collectors.toList());
+ List<Long> srappedGoodsIds =
+ scrappedAllGoodsList.stream().map(map -> (Long)map.get("id")).collect(Collectors.toList());
// 璁剧疆鐗╁搧涓哄叆搴撴湭鍒嗗彂锛� 骞惰缃墍灞炰粨搴�
lWhGoodsService.modGoodsTransfering(srappedGoodsIds, 0, inWarehouseId, warehouseName, 1);
// 浣跨敤浜轰俊鎭�
// 鎵归噺鎻掑叆 杩涘嚭搴撴祦姘存槑缁哰L_WH_GOODS_RECORD_DETAILS]
- lWhGoodsRecordDetailsService.sameGoodsInsertMore(srappedGoodsIds, whGoodsRecordId, (short) 1);
+ lWhGoodsRecordDetailsService.sameGoodsInsertMore(srappedGoodsIds, whGoodsRecordId, (short)1);
}
// 涓婃柟鐗╁搧鐨勪环鏍�
- Long formScrappedModelPrice = scrappedAllGoodsList.stream().mapToLong(map -> (long) map.get("price")).sum();
+ Long formScrappedModelPrice =
+ scrappedAllGoodsList.stream().mapToLong(map -> (long)map.get("price")).sum();
whGoodsRecord.setInitialCount(goodsModelNum);
whGoodsRecord.setEndCount(goodsModelNum + scrappedAllGoodsList.size());
whGoodsRecord.setThisCount(scrappedAllGoodsList.size());
whGoodsRecord.setTotalPrice(formScrappedModelPrice);
- //lWhGoodsRecordService.insert(whGoodsRecord);
+ // lWhGoodsRecordService.insert(whGoodsRecord);
flowRecordArrayList.add(whGoodsRecord);
}
// 鎻愬彇baseGoodsModelsId骞舵斁鍏ユ柊鐨凩ist涓�
List<Long> allChangModelList = eachWareHouseList.stream()
- .map(map -> Convert.toLong(map.get("BASE_GOODS_MODELS_ID")))
- .distinct()
- .collect(Collectors.toList());
- //褰撳簱瀛樺彉鍔ㄦ椂璋冪敤璇ユ柟娉�
- lWhWarningCoreService.updateKuCun((short) 0, inWarehouseId, allChangModelList, null, dealTime);
+ .map(map -> Convert.toLong(map.get("BASE_GOODS_MODELS_ID"))).distinct().collect(Collectors.toList());
+ // 褰撳簱瀛樺彉鍔ㄦ椂璋冪敤璇ユ柟娉�
+ lWhWarningCoreService.updateKuCun((short)0, inWarehouseId, allChangModelList, null, dealTime);
}
// 鎻掑叆娴佹按鎬昏〃
- flowInsertFlag = lWarehouseFlowService.insertBatch(flowArrayList);
+ flowInsertFlag = lWarehouseFlowServiceImpl.insertBatch(flowArrayList);
if (flowInsertFlag == 0) {
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
return null;
--
Gitblit v1.9.1