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


@@ -6,6 +6,13 @@


import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;


import com.baomidou.mybatisplus.core.toolkit.Wrappers;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import com.ruoyi.account.pojo.AccountExpense;


import com.ruoyi.account.pojo.AccountIncome;


import com.ruoyi.account.service.AccountExpenseService;


import com.ruoyi.account.service.AccountIncomeService;


import com.ruoyi.approve.pojo.ApproveProcess;


import com.ruoyi.approve.service.IApproveProcessService;


import com.ruoyi.approve.vo.ApproveProcessVO;


import com.ruoyi.basic.mapper.ProductMapper;


import com.ruoyi.basic.mapper.ProductModelMapper;


import com.ruoyi.basic.mapper.SupplierManageMapper;


@@ -68,7 +75,7 @@


@RequiredArgsConstructor


@Slf4j


public class PurchaseLedgerServiceImpl extends ServiceImpl<PurchaseLedgerMapper, PurchaseLedger> implements IPurchaseLedgerService {




    private final AccountExpenseService accountExpenseService;


    private final PurchaseLedgerMapper purchaseLedgerMapper;




    private final SalesLedgerMapper salesLedgerMapper;


@@ -93,6 +100,8 @@


    private final InvoiceRegistrationProductMapper invoiceRegistrationProductMapper;




    private final StringRedisTemplate redisTemplate;




    private final IApproveProcessService approveProcessService;




    @Value("${file.upload-dir}")


    private String uploadDir;


@@ -128,12 +137,41 @@


        purchaseLedger.setRecorderId(purchaseLedgerDto.getRecorderId());


        purchaseLedger.setRecorderName(sysUser.getNickName());


        purchaseLedger.setPhoneNumber(sysUser.getPhonenumber());


        // 2. 处理账户收入


        AccountExpense accountExpense = new AccountExpense();


        accountExpense.setExpenseDate(purchaseLedger.getEntryDate());


        accountExpense.setExpenseType("0");


        accountExpense.setSupplierName(purchaseLedger.getSupplierName());


        accountExpense.setExpenseMoney(purchaseLedger.getContractAmount());


        accountExpense.setExpenseDescribed("采购合同：" + purchaseLedger.getPurchaseContractNumber());


        accountExpense.setExpenseMethod("0");


        accountExpense.setInvoiceNumber(purchaseLedger.getPurchaseContractNumber());


        accountExpense.setInputTime(new Date());


        accountExpense.setInputUser(loginUser.getNickName());






        // 3. 新增或更新主表


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


            purchaseLedgerMapper.insert(purchaseLedger);


//            accountIncomeService.save(accountIncome);


            accountExpenseService.save(accountExpense);


        } else {


            purchaseLedgerMapper.updateById(purchaseLedger);


            PurchaseLedger purchaseLedgerDB = purchaseLedgerMapper.selectById(purchaseLedger.getId());


            List<AccountExpense> accountExpenseDBs = accountExpenseService.getByInvoiceNumberList(purchaseLedger.getPurchaseContractNumber());


            if (!CollectionUtils.isEmpty(accountExpenseDBs)) {


                accountExpenseDBs.forEach(accountExpenseDB ->{


                    accountExpenseDB.setExpenseDate(purchaseLedgerDB.getEntryDate());


                    accountExpenseDB.setExpenseType("0");


                    accountExpenseDB.setSupplierName(purchaseLedgerDB.getSupplierName());


                    accountExpenseDB.setExpenseMoney(purchaseLedgerDB.getContractAmount());


                    accountExpenseDB.setExpenseDescribed("采购合同：" + purchaseLedgerDB.getPurchaseContractNumber());


                    accountExpenseDB.setExpenseMethod("0");


                    accountExpenseDB.setInvoiceNumber(purchaseLedgerDB.getPurchaseContractNumber());


                    accountExpenseService.updateById(accountExpenseDB);


                });


            }




        }




        // 4. 处理子表数据


@@ -145,6 +183,26 @@


        // 5. 迁移临时文件到正式目录


        if (purchaseLedgerDto.getTempFileIds() != null && !purchaseLedgerDto.getTempFileIds().isEmpty()) {


            migrateTempFilesToFormal(purchaseLedger.getId(), purchaseLedgerDto.getTempFileIds());


        }




        //6.采购需要审批


        //新增审批数据approve_proces


        ApproveProcessVO approveProcessVO = new ApproveProcessVO();


        approveProcessVO.setApproveDeptId(purchaseLedger.getTenantId());


        //审批理由是采购合同号用这个来关联


        approveProcessVO.setApproveReason(purchaseLedger.getPurchaseContractNumber());


        DateTimeFormatter dateFormat = DateTimeFormatter.ofPattern("yyyy-MM-dd");


        approveProcessVO.setApproveTime(LocalDate.now().format(dateFormat));


        //5是采购申请


        approveProcessVO.setApproveType(5);


        //录入人=申请人


        approveProcessVO.setApproveUser(purchaseLedger.getRecorderId());


        //审批人


        approveProcessVO.setApproveUserIds(purchaseLedgerDto.getApproveUserIds());


        try {


            approveProcessService.addApprove(approveProcessVO);


        } catch (Exception e) {


            e.printStackTrace();


        }




        return 1;


@@ -326,6 +384,25 @@


        LambdaQueryWrapper<ProductRecord> productRecordLambdaQueryWrapper = new LambdaQueryWrapper<>();


        productRecordLambdaQueryWrapper.in(ProductRecord::getPurchaseLedgerId,ids);


        productRecordMapper.delete(productRecordLambdaQueryWrapper);




        // 删除关联的审批表


        List<String> strings = purchaseLedgerMapper.selectBatchIds(Arrays.asList(ids)).stream()


                .map(PurchaseLedger::getPurchaseContractNumber)


                .distinct()


                .collect(Collectors.toList());


        List<ApproveProcess> list = approveProcessService.list(Wrappers.<ApproveProcess>lambdaQuery().eq(ApproveProcess::getApproveType, 5)                                         .in(ApproveProcess::getApproveReason, strings));


        if (CollectionUtils.isNotEmpty(list)){


            List<String> approveIds = list.stream()


                    .map(ApproveProcess::getApproveId)


                    .distinct()


                    .collect(Collectors.toList());


            Long[] ides = approveIds.stream()


                    .filter(s -> s != null && !s.isEmpty())


                    .map(Long::valueOf)


                    .toArray(Long[]::new);


            approveProcessService.delApprove(ides);


        }




        // 批量删除采购台账


        return purchaseLedgerMapper.deleteBatchIds(Arrays.asList(ids));


    }


@@ -480,6 +557,26 @@


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


    }




    @Override


    public PurchaseLedgerDto getPurchaseByCode(PurchaseLedgerDto purchaseLedgerDto) {


        // 1. 查询主表


        PurchaseLedger purchaseLedger = purchaseLedgerMapper.selectOne(new LambdaQueryWrapper<PurchaseLedger>()            .eq(PurchaseLedger::getPurchaseContractNumber, purchaseLedgerDto.getPurchaseContractNumber())            .last("LIMIT 1"));


        if (purchaseLedger == null) {


            throw new BaseException("采购台账不存在");


        }


        // 2. 查询子表


        LambdaQueryWrapper<SalesLedgerProduct> productWrapper = new LambdaQueryWrapper<>();


        productWrapper.eq(SalesLedgerProduct::getSalesLedgerId, purchaseLedger.getId())            .eq(SalesLedgerProduct::getType, 2);


        List<SalesLedgerProduct> products = salesLedgerProductMapper.selectList(productWrapper);


        // 4. 转换 DTO


        PurchaseLedgerDto resultDto = new PurchaseLedgerDto();    BeanUtils.copyProperties(purchaseLedger, resultDto);


        if (!products.isEmpty()) {


            resultDto.setHasChildren(true);


            resultDto.setProductData(products);


        }


        return resultDto;


    }




    /**


     * 下划线命名转驼峰命名


     */