低值易耗品管理系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
cy
2023-12-02 07ef5e332c8184c4fc6e6c02343eb1b49cbc07e3 
 consum-base/src/main/java/com/consum/base/service/LWhFormTransferCoreService.java


@@ -5,27 +5,23 @@


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


@@ -98,7 +94,7 @@


            return;


        }


        // 出库单 出库，返回 出库单流水Id


        Long lWarehouseFlowId = lWhFormOutputCoreService.outFormByTransId(outWarehouseFormId, businessEnum, currentUser, dealTime);


        Long lWarehouseFlowId = lWhFormOutputCoreService.outFormByTransId(outWarehouseFormId, businessEnum, currentUser, dealTime, whFormTransferId);




        // 更新调拨单


        lWhFormTransfer = new LWhFormTransfer(whFormTransferId);


@@ -183,6 +179,7 @@


            Long baseGoodsModelsId = whGoodsRecord.getBaseGoodsModelsId();


            allChangModelList.add(baseGoodsModelsId);


            whGoodsRecord.setId(IdUtil.generateId());


            whGoodsRecord.setWarehouseFlowId(inWarehouseFlowId);


            whGoodsRecord.setWarehouseType(inWarehouseType);


            whGoodsRecord.setWarehouseId(inWarehouseId);


            whGoodsRecord.setDealTime(dealTime);


@@ -208,56 +205,56 @@


            }


            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);