From 62b6a7fac3f2acde70b578431147c4a01f19c182 Mon Sep 17 00:00:00 2001 From: 黎星凯 <13949086503@163.com> Date: 星期一, 15 四月 2024 09:07:05 +0800 Subject: [PATCH] bug修改 --- consum-base/src/main/java/com/consum/base/service/LGoodsUserRecordCoreService.java | 45 +++++++++++++++++++++++++++------------------ 1 files changed, 27 insertions(+), 18 deletions(-) diff --git a/consum-base/src/main/java/com/consum/base/service/LGoodsUserRecordCoreService.java b/consum-base/src/main/java/com/consum/base/service/LGoodsUserRecordCoreService.java index 094eb08..eb7f64f 100644 --- a/consum-base/src/main/java/com/consum/base/service/LGoodsUserRecordCoreService.java +++ b/consum-base/src/main/java/com/consum/base/service/LGoodsUserRecordCoreService.java @@ -1,18 +1,22 @@ package com.consum.base.service; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; + +import javax.annotation.Resource; + +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; +import org.springframework.transaction.interceptor.TransactionAspectSupport; +import org.springframework.util.CollectionUtils; + +import com.consum.base.core.utils.IdUtil; import com.consum.base.core.utils.LockManage; import com.consum.model.po.LGoodsUserRecord; import com.consum.model.po.LWhFormTransfer; import com.consum.model.po.LWhProcureModelUser; import com.consum.model.po.LWhProcureModelUserRecord; -import com.walker.infrastructure.utils.NumberGenerator; -import java.util.ArrayList; -import java.util.List; -import javax.annotation.Resource; -import org.springframework.stereotype.Service; -import org.springframework.transaction.annotation.Transactional; -import org.springframework.transaction.interceptor.TransactionAspectSupport; -import org.springframework.util.CollectionUtils; /** * @ClassName LGoodsUserRecordCoreService @@ -25,7 +29,7 @@ public class LGoodsUserRecordCoreService { @Resource - private GoodsBaseServiceImpl goodsBaseService; + private GoodsBaseService goodsBaseService; @Resource private LWhGoodsService lWhGoodsService; @Resource @@ -39,7 +43,8 @@ * @return */ public boolean modifyGoodsUser(Long oldProcureModelUserRecordId, Long newProcureModelUserRecordId) { - LWhProcureModelUserRecord lWhProcureModelUserRecord = goodsBaseService.get(new LWhProcureModelUserRecord(newProcureModelUserRecordId)); + LWhProcureModelUserRecord lWhProcureModelUserRecord = + goodsBaseService.get(new LWhProcureModelUserRecord(newProcureModelUserRecordId)); if (lWhProcureModelUserRecord == null) { return false; } @@ -52,12 +57,16 @@ LWhFormTransfer whFormTransfer = goodsBaseService.get(new LWhFormTransfer(transBusinessId)); Integer inWarehouseType = whFormTransfer.getInWarehouseType(); Long inWarehouseId = whFormTransfer.getInWarehouseId(); - // 灏嗘墍鏈夌墿鍝佽缃负鏈垎鍙� - List<Long> srappedGoodsIds = lWhGoodsService.queryScrappedGoodsIds(inWarehouseType, inWarehouseId, transBusinessId, null, null, null, null); - lWhGoodsService.modGoodsTransfering(srappedGoodsIds, null, null, null, 3); + // 灏嗘墍鏈夊凡涓嬪彂鐗╁搧璁剧疆涓烘湭鍒嗗彂 濡傛灉鍙戠敓浜嗛��鍥烇紝姝ゆ椂鏁伴噺鍒欏皬浜庡垎鍙戞椂鐨勬暟閲�! + List<Long> srappedGoodsIds = lWhGoodsService.queryScrappedGoodsIds(inWarehouseType, inWarehouseId, + transBusinessId, null, null, (short)2, null); + lWhGoodsService.modGoodsTransfering(srappedGoodsIds, null, null, null, 1); + // 鍒犻櫎璇ヨ皟鎷ㄥ崟鏃ф湁浣跨敤璁板綍 + lGoodsUserRecordService.delete(new LGoodsUserRecord(), "where TRANS_BUSINESS_ID =" + transBusinessId, + new HashMap<>()); // 璁剧疆鏃х殑LAST_RECORD= 0 lGoodsUserRecordService.updSetNotLast(srappedGoodsIds); - //鎻掑叆鏂扮殑 + // 鎻掑叆鏂扮殑 LWhProcureModelUser modelUser = new LWhProcureModelUser(); modelUser.setProcureModelUserRecordId(newProcureModelUserRecordId); List<LWhProcureModelUser> modelUserList = goodsBaseService.select(modelUser); @@ -68,18 +77,18 @@ for (LWhProcureModelUser lWhProcureModelUser : modelUserList) { Long baseGoodsModelsId = lWhProcureModelUser.getBaseGoodsModelsId(); Integer goodsNum = lWhProcureModelUser.getGoodsNum(); - //閫氳繃LockManage鑾峰緱閿� + // 閫氳繃LockManage鑾峰緱閿� Object warehouseModelLockObj = LockManage.acquireLock(inWarehouseType, inWarehouseId, baseGoodsModelsId); synchronized (warehouseModelLockObj) { - List<Long> toUserGoodsIds = lWhGoodsService.queryScrappedGoodsIds(inWarehouseType, inWarehouseId, transBusinessId, null, baseGoodsModelsId, - (short) 1, goodsNum); + List<Long> toUserGoodsIds = lWhGoodsService.queryScrappedGoodsIds(inWarehouseType, inWarehouseId, + transBusinessId, null, baseGoodsModelsId, (short)1, goodsNum); if (CollectionUtils.isEmpty(toUserGoodsIds)) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); throw new RuntimeException("鎿嶄綔澶辫触!鍨嬪彿鏁伴噺涓嶈冻"); } for (Long toUserGoodsId : toUserGoodsIds) { LGoodsUserRecord tmp = new LGoodsUserRecord(); - tmp.setId(NumberGenerator.getLongSequenceNumber()); + //tmp.setId(IdUtil.generateId()); tmp.setWhGoodsId(toUserGoodsId); tmp.setRecordType(1); tmp.setTransBusinessId(transBusinessId); -- Gitblit v1.9.1