From 4c4bf4cc32a99435777f06bc281fe8e942f7c323 Mon Sep 17 00:00:00 2001
From: futian.liu <liufutianyoo@163.com>
Date: 星期四, 14 十二月 2023 12:03:24 +0800
Subject: [PATCH] 修改规约
---
consum-base/src/main/java/com/consum/base/core/DepUsingFormBackCoreServiceImpl.java | 50 +++++++++++++++++++++++++++++++++++++++++---------
1 files changed, 41 insertions(+), 9 deletions(-)
diff --git a/consum-base/src/main/java/com/consum/base/core/DepUsingFormBackCoreServiceImpl.java b/consum-base/src/main/java/com/consum/base/core/DepUsingFormBackCoreServiceImpl.java
index 171a064..c0c25fd 100644
--- a/consum-base/src/main/java/com/consum/base/core/DepUsingFormBackCoreServiceImpl.java
+++ b/consum-base/src/main/java/com/consum/base/core/DepUsingFormBackCoreServiceImpl.java
@@ -4,8 +4,15 @@
import com.consum.base.core.service.LWhWarningCoreServiceImpl;
import com.consum.base.core.utils.IdUtil;
import com.consum.base.core.utils.LockManage;
-import com.consum.base.service.*;
-import com.consum.model.po.*;
+import com.consum.base.service.GoodsBaseServiceImpl;
+import com.consum.base.service.LWarehouseFlowService;
+import com.consum.base.service.LWhGoodsRecordService;
+import com.consum.base.service.LWhGoodsService;
+import com.consum.base.service.impl.LWhGoodsRecordDetailsService;
+import com.consum.model.po.BaseWarehouse;
+import com.consum.model.po.LWarehouseFlow;
+import com.consum.model.po.LWhGoodsRecord;
+import com.consum.model.po.UsingFormBack;
import com.iplatform.model.po.S_user_core;
import com.walker.infrastructure.utils.CollectionUtils;
import com.walker.web.ResponseValue;
@@ -40,7 +47,7 @@
@Resource
private LWhGoodsRecordDetailsService lWhGoodsRecordDetailsService;
@Resource
- private LWhGoodsRecordService lWhGoodsRecordService;
+ private LWhGoodsRecordService lWhGoodsRecordServiceImpl;
@Resource
private LWarehouseFlowService lWarehouseFlowService;
@Resource
@@ -85,7 +92,7 @@
Map<String, Integer> procureModelMap = new HashMap<>();
for (Object key : groupByModelIdMap.keySet()) {
- Long modelTotalPrice = 0l;
+ Long modelTotalPrice = 0L;
//瑕佹姤搴熺殑鎬绘暟閲�
int modelTotalNum = 0;
@@ -128,7 +135,7 @@
// 鏍规嵁鍒嗗彂鍗曘�佸瀷鍙枫�佷娇鐢ㄤ汉淇℃伅鏌ヨ鐗╁搧淇℃伅
List<Map<String, Object>> scrappedGoodsList = lWhGoodsService.queryScrappedGoods(warehouseType, warehouseId, transBusinessId, nowUserName, baseGoodsModelsId, (short) 2, counts);
if (CollectionUtils.isEmpty(scrappedGoodsList) || scrappedGoodsList.size() < counts) {
- log.error("瑕佹姤搴熺殑鐗╁搧鏁伴噺涓嶈冻锛�");
+ log.error("瑕侀��鍥炵殑鐗╁搧鏁伴噺涓嶈冻锛�");
// 鎵嬪姩鍥炴粴
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
throw new RuntimeException("鎶ュ簾澶辫触!鍨嬪彿鏁伴噺涓嶈冻");
@@ -169,7 +176,7 @@
warehouseFlow.setWarehouseId(warehouseId);
warehouseFlow.setWarehouseName(warehouseName);
warehouseFlow.setThisType(2);
- warehouseFlow.setBusinessType(WhBusinessEnum.BAOFEI.getValue() + 0);
+ warehouseFlow.setBusinessType(WhBusinessEnum.BUMENTUIHUI.getValue() + 0);
warehouseFlow.setBusinessFormId(lWhFormBackId);
warehouseFlow.setOperatorId(userId);
warehouseFlow.setOperatorName(nickName);
@@ -181,7 +188,7 @@
return null;
}
// 鎵归噺鎻掑叆 鍚勮鏍肩墿鍝佺殑杩涘嚭搴撱�怢_WH_GOODS_RECORD銆�
- lWhGoodsRecordService.insertBatch(lWhGoodsRecordList);
+ lWhGoodsRecordServiceImpl.insertBatch(lWhGoodsRecordList);
// 鏇存柊鎶ュ簾鍗�
depFormScrapped = new UsingFormBack(lWhFormBackId);
@@ -199,6 +206,31 @@
parameterList.add(one);
}
goodsBaseService.execBatchUpdate("update DEP_FORM_SCRAPPED_MODEL set TOTAL_AMOUNT=? where id=?", parameterList);
+
+ //濡傛灉鏄疉绫荤墿鍝侊紝鍒欐洿鏂� 鍒嗗彂鐗╁搧浣跨敤浜恒�怢_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){
+ 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());
+
+ Object[] one = new Object[3];
+ one[0] = counts;
+ one[1] = procureModelUserId;
+ one[2] = counts;
+ 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);
+ }
+
//閲囪喘銆佽皟鎷ㄣ�佸嚭搴撶瓑鐨勭墿鍝佸瀷鍙枫�怢_WH_PROCURE_MODEL銆戜腑 鏍规嵁璋冩嫧鍗�+鍨嬪彿 鏇存柊 鍦ㄧ敤鏁伴噺
List<Object[]> procureModelParameterList = new ArrayList<>();
@@ -252,7 +284,7 @@
inWarehouseFlow.setWarehouseId(inWarehouseId);
inWarehouseFlow.setWarehouseName(inWarehouseName);
inWarehouseFlow.setThisType(1);
- inWarehouseFlow.setBusinessType(WhBusinessEnum.BAOFEI.getValue() + 0);
+ inWarehouseFlow.setBusinessType(WhBusinessEnum.BUMENTUIHUI.getValue() + 0);
inWarehouseFlow.setBusinessFormId(lWhFormBackId);
inWarehouseFlow.setOperatorId(userId);
inWarehouseFlow.setOperatorName(nickName);
@@ -331,7 +363,7 @@
return null;
}
// 鎵归噺鎻掑叆 鍚勮鏍肩墿鍝佺殑杩涘嚭搴撱�怢_WH_GOODS_RECORD銆�
- lWhGoodsRecordService.insertBatch(flowRecordArrayList);
+ lWhGoodsRecordServiceImpl.insertBatch(flowRecordArrayList);
return null;
}
--
Gitblit v1.9.1