产品供销存-后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
gongchunyi
2 天以前 1729474b4c7ffacb1790bb70981e64e7744bffb2 
 src/main/java/com/ruoyi/purchase/service/impl/PurchaseLedgerServiceImpl.java


@@ -17,6 +17,7 @@


import com.ruoyi.basic.mapper.ProductMapper;


import com.ruoyi.basic.mapper.ProductModelMapper;


import com.ruoyi.basic.mapper.SupplierManageMapper;


import com.ruoyi.basic.pojo.Customer;


import com.ruoyi.basic.pojo.Product;


import com.ruoyi.basic.pojo.ProductModel;


import com.ruoyi.basic.pojo.SupplierManage;


@@ -25,7 +26,9 @@


import com.ruoyi.common.utils.DateUtils;


import com.ruoyi.common.utils.SecurityUtils;


import com.ruoyi.common.utils.StringUtils;


import com.ruoyi.common.utils.poi.ExcelUtil;


import com.ruoyi.framework.security.LoginUser;


import com.ruoyi.framework.web.domain.AjaxResult;


import com.ruoyi.other.mapper.TempFileMapper;


import com.ruoyi.other.pojo.TempFile;


import com.ruoyi.procurementrecord.mapper.ProcurementRecordMapper;


@@ -33,11 +36,15 @@


import com.ruoyi.project.system.domain.SysUser;


import com.ruoyi.project.system.mapper.SysUserMapper;


import com.ruoyi.purchase.dto.PurchaseLedgerDto;


import com.ruoyi.purchase.dto.PurchaseLedgerImportDto;


import com.ruoyi.purchase.dto.PurchaseLedgerProductImportDto;


import com.ruoyi.purchase.mapper.*;


import com.ruoyi.purchase.pojo.*;


import com.ruoyi.purchase.service.IPurchaseLedgerService;


import com.ruoyi.quality.mapper.*;


import com.ruoyi.quality.pojo.*;


import com.ruoyi.sales.dto.SalesLedgerImportDto;


import com.ruoyi.sales.dto.SalesLedgerProductImportDto;


import com.ruoyi.sales.mapper.*;


import com.ruoyi.sales.pojo.CommonFile;


import com.ruoyi.sales.pojo.InvoiceRegistrationProduct;


@@ -51,9 +58,12 @@


import org.springframework.data.redis.core.StringRedisTemplate;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.web.multipart.MultipartFile;




import java.io.IOException;


import java.io.InputStream;


import java.math.BigDecimal;


import java.math.RoundingMode;


import java.nio.file.Files;


import java.nio.file.Path;


import java.nio.file.Paths;


@@ -93,6 +103,8 @@


    private final ProductMapper productMapper;




    private final ProductModelMapper productModelMapper;




    private final SysUserMapper sysUserMapper;




    private final TicketRegistrationMapper ticketRegistrationMapper;




@@ -155,7 +167,7 @@


        if (purchaseLedger.getId() == null) {


            purchaseLedgerMapper.insert(purchaseLedger);


        } else {


            // 删除采购审批，重新提交


            // 删除采购审核，重新提交


            ApproveProcess one = approveProcessService.getOne(new LambdaQueryWrapper<ApproveProcess>()


                    .eq(ApproveProcess::getApproveType, 5)


                    .eq(ApproveProcess::getApproveReason, purchaseLedger.getPurchaseContractNumber())


@@ -166,15 +178,9 @@


            }


            purchaseLedgerMapper.updateById(purchaseLedger);


        }


        // 6.采购审批新增


        ApproveProcessVO approveProcessVO = new ApproveProcessVO();


        approveProcessVO.setApproveType(5);


        approveProcessVO.setApproveDeptId(loginUser.getCurrentDeptId());


        approveProcessVO.setApproveReason(purchaseLedger.getPurchaseContractNumber());


        approveProcessVO.setApproveUserIds(purchaseLedgerDto.getApproveUserIds());


        approveProcessVO.setApproveUser(loginUser.getUserId());


        approveProcessVO.setApproveTime(LocalDate.now().toString());


        approveProcessService.addApprove(approveProcessVO);


        // 6.采购审核新增


        addApproveByPurchase(loginUser, purchaseLedger);




        // 4. 处理子表数据


        List<SalesLedgerProduct> productList = purchaseLedgerDto.getProductData();


        if (productList != null && !productList.isEmpty()) {


@@ -610,6 +616,125 @@


        return purchaseNo + String.format("%03d", sequence);


    }




    @Override


    @Transactional(rollbackFor = Exception.class)


    public AjaxResult importData(MultipartFile file) {


        LoginUser loginUser = SecurityUtils.getLoginUser();


        try {


            InputStream inputStream = file.getInputStream();


            ExcelUtil<PurchaseLedgerImportDto> salesLedgerImportDtoExcelUtil = new ExcelUtil<>(PurchaseLedgerImportDto.class);


            Map<String, List<PurchaseLedgerImportDto>> stringListMap = salesLedgerImportDtoExcelUtil.importExcelMultiSheet(Arrays.asList("采购台账数据", "采购产品数据"), inputStream, 0);


            if (CollectionUtils.isEmpty(stringListMap)) return AjaxResult.error("采购表格为空！");


            // 业务层合并


            List<PurchaseLedgerImportDto> salesLedgerImportDtoList = stringListMap.get("采购台账数据");


            if (CollectionUtils.isEmpty(salesLedgerImportDtoList)) return AjaxResult.error("采购台账数据为空！");


            List<PurchaseLedgerImportDto> salesLedgerProductImportDtoList = stringListMap.get("采购产品数据");


            if (CollectionUtils.isEmpty(salesLedgerProductImportDtoList)) return AjaxResult.error("采购产品数据为空！");


            // 供应商数据


            List<SupplierManage> customers = supplierManageMapper.selectList(new LambdaQueryWrapper<SupplierManage>().in(SupplierManage::getSupplierName,


                    salesLedgerImportDtoList.stream().map(PurchaseLedgerImportDto::getSupplierName).collect(Collectors.toList())));


            List<Map<String,Object>> list = productModelMapper.getProductAndModelList();


            // 录入人数据


            List<SysUser> sysUsers = sysUserMapper.selectList(new LambdaQueryWrapper<SysUser>().in(SysUser::getNickName,


                    salesLedgerImportDtoList.stream().map(PurchaseLedgerImportDto::getRecorderName).collect(Collectors.toList())));


            for (PurchaseLedgerImportDto salesLedgerImportDto : salesLedgerImportDtoList) {


                PurchaseLedger salesLedger = new PurchaseLedger();


                BeanUtils.copyProperties(salesLedgerImportDto, salesLedger);


                // 通过供应商名称查询ID


                salesLedger.setSupplierId(customers.stream()


                        .filter(customer -> customer.getSupplierName().equals(salesLedger.getSupplierName()))


                        .findFirst()


                        .map(SupplierManage::getId)


                        .orElse(null));


                Long aLong = sysUsers.stream()


                        .filter(sysUser -> sysUser.getNickName().equals(salesLedger.getRecorderName()))


                        .findFirst()


                        .map(SysUser::getUserId)


                        .orElse(null);


                if (aLong == null)


                    throw new RuntimeException("录入人:" + salesLedger.getRecorderName() + ",无对应用户！");


                salesLedger.setRecorderId(aLong);


                // 采购产品数据绑定，通过采购单号获取对应采购产品数据


                List<PurchaseLedgerProductImportDto> salesLedgerProductImportDtos = salesLedgerProductImportDtoList.stream()


                        .filter(salesLedgerProductImportDto -> salesLedgerProductImportDto.getPurchaseContractNumber().equals(salesLedger.getPurchaseContractNumber()))


                        .collect(Collectors.toList());


                if (CollectionUtils.isEmpty(salesLedgerProductImportDtos))


                    throw new RuntimeException("采购单号:" + salesLedgerImportDto.getPurchaseContractNumber() + ",无对应产品数据！");


                salesLedger.setContractAmount(salesLedgerProductImportDtos.stream()


                        .map(PurchaseLedgerProductImportDto::getTaxInclusiveTotalPrice)


                        .reduce(BigDecimal.ZERO,BigDecimal::add));


                // 通过销售单号绑定销售


                SalesLedger salesLedger1 = salesLedgerMapper.selectOne(new LambdaQueryWrapper<SalesLedger>()


                        .eq(SalesLedger::getSalesContractNo, salesLedger.getSalesContractNo())


                        .last("LIMIT 1"));


                if(salesLedger1 != null){


                    salesLedger.setSalesLedgerId(salesLedger1.getId());


                }


                // 采购审核


                // 通过昵称获取用户ID


                String[] split = salesLedger.getApproveUserIds().split("，");


                List<Long> ids = new ArrayList<>();


                for (int i = 0; i < split.length; i++) {


                    SysUser sysUser = sysUserMapper.selectOne(new LambdaQueryWrapper<SysUser>().eq(SysUser::getNickName, split[i])


                            .last("LIMIT 1"));


                    if (sysUser != null) {


                        ids.add(sysUser.getUserId());


                    }


                }


                // 将集合转为字符串，隔开


                String collect = ids.stream().map(Object::toString).collect(Collectors.joining(","));


                salesLedger.setApproveUserIds(collect);


                purchaseLedgerMapper.insert(salesLedger);




                for (PurchaseLedgerProductImportDto salesLedgerProductImportDto : salesLedgerProductImportDtos) {


                    SalesLedgerProduct salesLedgerProduct = new SalesLedgerProduct();


                    BeanUtils.copyProperties(salesLedgerProductImportDto, salesLedgerProduct);


                    salesLedgerProduct.setSalesLedgerId(salesLedger.getId());


                    salesLedgerProduct.setType(2);


                    // 计算不含税总价


                    salesLedgerProduct.setTaxExclusiveTotalPrice(salesLedgerProduct.getTaxInclusiveTotalPrice().divide(new BigDecimal(1).add(salesLedgerProduct.getTaxRate().divide(new BigDecimal(100))), 2, RoundingMode.HALF_UP));


                    salesLedgerProduct.setFutureTickets(salesLedgerProduct.getQuantity());


                    salesLedgerProduct.setFutureTicketsAmount(salesLedgerProduct.getTaxExclusiveTotalPrice());


                    list.stream()


                            .filter(map -> map.get("productName").equals(salesLedgerProduct.getProductCategory()) && map.get("model").equals(salesLedgerProduct.getSpecificationModel()))


                            .findFirst()


                            .ifPresent(map -> {


                                salesLedgerProduct.setProductModelId(Long.parseLong(map.get("modelId").toString()));


                                salesLedgerProduct.setProductId(Long.parseLong(map.get("id").toString()));


                            });


                    salesLedgerProduct.setRegister(loginUser.getNickName());


                    salesLedgerProduct.setRegisterDate(LocalDateTime.now());


                    salesLedgerProduct.setApproveStatus(0);


                    salesLedgerProduct.setPendingTicketsTotal(salesLedgerProductImportDto.getTaxInclusiveTotalPrice());


                    // 是否质检判断


                    salesLedgerProduct.setIsChecked(salesLedgerProductImportDto.getIsChecked() == 1);


                    if(salesLedgerProductImportDto.getIsChecked() == 1){


                        addQualityInspect(salesLedger, salesLedgerProduct);


                    }


                    salesLedgerProductMapper.insert(salesLedgerProduct);


                }


                // 采购审核


                addApproveByPurchase(loginUser,salesLedger);


            }




            return AjaxResult.success("导入成功");


        } catch (Exception e) {


            e.printStackTrace();


        }


        return AjaxResult.success("导入失败");


    }




    public void addApproveByPurchase(LoginUser loginUser,PurchaseLedger purchaseLedger) throws Exception {


        ApproveProcessVO approveProcessVO = new ApproveProcessVO();


        approveProcessVO.setApproveType(5);


        approveProcessVO.setApproveDeptId(loginUser.getCurrentDeptId());


        approveProcessVO.setApproveReason(purchaseLedger.getPurchaseContractNumber());


        approveProcessVO.setApproveUserIds(purchaseLedger.getApproveUserIds());


        approveProcessVO.setApproveUser(loginUser.getUserId());


        approveProcessVO.setApproveTime(LocalDate.now().toString());


        approveProcessService.addApprove(approveProcessVO);


    }




    /**


     * 下划线命名转驼峰命名


     */