| | |
| | | import com.consum.base.core.service.LWhWarningCoreServiceImpl; |
| | | 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.LWarehouseFlow; |
| | | import com.consum.model.po.LWhFormTransfer; |
| | | import com.consum.model.po.LWhGoodsRecord; |
| | | import com.consum.model.po.LWhGoodsRecordDetails; |
| | | import com.consum.model.po.LWhProcureModelUser; |
| | | import com.consum.model.po.*; |
| | | import com.iplatform.model.po.S_user_core; |
| | | import com.walker.infrastructure.utils.CollectionUtils; |
| | | import com.walker.infrastructure.utils.DateUtils; |
| | | import com.walker.infrastructure.utils.NumberGenerator; |
| | | import java.util.ArrayList; |
| | | import java.util.HashMap; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.stream.Collectors; |
| | | import javax.annotation.Resource; |
| | | 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; |
| | | |
| | | /** |
| | | * @ClassName LWhFormTransferCoreService |
| | |
| | | return; |
| | | } |
| | | // 出库单 出库,返回 出库单流水Id |
| | | Long lWarehouseFlowId = lWhFormOutputCoreService.outFormByTransId(outWarehouseFormId, businessEnum, currentUser, dealTime); |
| | | Long lWarehouseFlowId = lWhFormOutputCoreService.outFormByTransId(outWarehouseFormId, businessEnum, currentUser, dealTime, whFormTransferId); |
| | | |
| | | // 更新调拨单 |
| | | lWhFormTransfer = new LWhFormTransfer(whFormTransferId); |
| | |
| | | Long baseGoodsModelsId = whGoodsRecord.getBaseGoodsModelsId(); |
| | | allChangModelList.add(baseGoodsModelsId); |
| | | whGoodsRecord.setId(IdUtil.generateId()); |
| | | whGoodsRecord.setWarehouseFlowId(inWarehouseFlowId); |
| | | whGoodsRecord.setWarehouseType(inWarehouseType); |
| | | whGoodsRecord.setWarehouseId(inWarehouseId); |
| | | whGoodsRecord.setDealTime(dealTime); |
| | |
| | | } |
| | | if (businessType == 1) { |
| | | // List<Map<String, Object>> modelInfo = baseGoodsModelsService.queryGoodsModelInfo(baseGoodsModelsId); |
| | | |
| | | // 1部门分发 此时要往 物品使用记录【L_GOODS_USER_RECORD】添加数据 |
| | | //查询部门分发使用人 |
| | | LWhProcureModelUser lWhProcureModelUser = new LWhProcureModelUser(); |
| | | lWhProcureModelUser.setTransBusinessId(whFormTransferId); |
| | | lWhProcureModelUser.setBaseGoodsModelsId(baseGoodsModelsId); |
| | | List<LWhProcureModelUser> goodsUserInfo = goodsBaseService.select(lWhProcureModelUser); |
| | | if (CollectionUtils.isEmpty(goodsUserInfo)) { |
| | | continue; |
| | | } |
| | | int totalGoodsNum = goodsUserInfo.stream().filter(item -> item.getGoodsNum() != null).mapToInt(LWhProcureModelUser::getGoodsNum).sum(); |
| | | if (totalGoodsNum != outGoodsIds.size()) { |
| | | TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); |
| | | throw new RuntimeException("入库单失败,使用人使用数量与物品数量不一致"); |
| | | // log.error("创建入库单失败"); |
| | | } |
| | | //将物品型号以前的使用记录设置为非最新 |
| | | lGoodsUserRecordService.updSetNotLast(outGoodsIds); |
| | | ArrayList<LGoodsUserRecord> goodsUserRecordList = new ArrayList<>(); |
| | | int startIndex = 0; |
| | | for (LWhProcureModelUser whProcureModelUser : goodsUserInfo) { |
| | | Integer goodsNum = whProcureModelUser.getGoodsNum(); |
| | | String nowUserName = whProcureModelUser.getNowUserName(); |
| | | Long nowUserPhone = whProcureModelUser.getNowUserPhone(); |
| | | Long procureModelUserRecordId = whProcureModelUser.getProcureModelUserRecordId(); |
| | | List<Long> goodsIds = outGoodsIds.subList(startIndex, startIndex + goodsNum); |
| | | for (Long goodsId : goodsIds) { |
| | | LGoodsUserRecord tmp = new LGoodsUserRecord(); |
| | | tmp.setWhGoodsId(goodsId); |
| | | tmp.setRecordType(recordType); |
| | | tmp.setTransBusinessId(whFormTransferId); |
| | | if (businessType == 1) { |
| | | tmp.setNowUserName(nowUserName); |
| | | tmp.setNowUserPhone(nowUserPhone); |
| | | } else if (businessType == 2) { |
| | | tmp.setNowUserName(null); |
| | | tmp.setNowUserPhone(null); |
| | | } |
| | | tmp.setProcureModelUserRecordId(procureModelUserRecordId); |
| | | tmp.setOperatorId(userId); |
| | | tmp.setOperatorName(nickName); |
| | | tmp.setDealTime(dealTime); |
| | | tmp.setLastRecord(1); |
| | | goodsUserRecordList.add(tmp); |
| | | if (!CollectionUtils.isEmpty(goodsUserInfo)) { |
| | | //认为是A类物品 |
| | | int totalGoodsNum = goodsUserInfo.stream().filter(item -> item.getGoodsNum() != null).mapToInt(LWhProcureModelUser::getGoodsNum).sum(); |
| | | if (totalGoodsNum != outGoodsIds.size()) { |
| | | TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); |
| | | throw new RuntimeException("入库单失败,使用人使用数量与物品数量不一致"); |
| | | // log.error("创建入库单失败"); |
| | | } |
| | | // 更新下标位置 |
| | | startIndex += goodsNum; |
| | | |
| | | ArrayList<LGoodsUserRecord> goodsUserRecordList = new ArrayList<>(); |
| | | int startIndex = 0; |
| | | for (LWhProcureModelUser whProcureModelUser : goodsUserInfo) { |
| | | Integer goodsNum = whProcureModelUser.getGoodsNum(); |
| | | String nowUserName = whProcureModelUser.getNowUserName(); |
| | | Long nowUserPhone = whProcureModelUser.getNowUserPhone(); |
| | | Long procureModelUserRecordId = whProcureModelUser.getProcureModelUserRecordId(); |
| | | List<Long> goodsIds = outGoodsIds.subList(startIndex, startIndex + goodsNum); |
| | | for (Long goodsId : goodsIds) { |
| | | LGoodsUserRecord tmp = new LGoodsUserRecord(); |
| | | tmp.setWhGoodsId(goodsId); |
| | | tmp.setRecordType(recordType); |
| | | tmp.setTransBusinessId(whFormTransferId); |
| | | if (businessType == 1) { |
| | | tmp.setNowUserName(nowUserName); |
| | | tmp.setNowUserPhone(nowUserPhone); |
| | | } else if (businessType == 2) { |
| | | tmp.setNowUserName(null); |
| | | tmp.setNowUserPhone(null); |
| | | } |
| | | tmp.setProcureModelUserRecordId(procureModelUserRecordId); |
| | | tmp.setOperatorId(userId); |
| | | tmp.setOperatorName(nickName); |
| | | tmp.setDealTime(dealTime); |
| | | tmp.setLastRecord(1); |
| | | goodsUserRecordList.add(tmp); |
| | | } |
| | | // 更新下标位置 |
| | | startIndex += goodsNum; |
| | | } |
| | | //批量插入使用人记录 |
| | | lGoodsUserRecordService.insertBatch(goodsUserRecordList); |
| | | } |
| | | //批量插入使用人记录 |
| | | lGoodsUserRecordService.insertBatch(goodsUserRecordList); |
| | | } |
| | | //将保管仓库信息更新到 物品仓库保管记录【L_GOODS_WH_RECORD】 |
| | | lGoodsWhRecordService.insertNewRecord(outGoodsIds, inWarehouseFlowId, dealTime); |