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


@@ -6,6 +6,10 @@


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.basic.mapper.ProductMapper;


import com.ruoyi.basic.mapper.ProductModelMapper;


import com.ruoyi.basic.mapper.SupplierManageMapper;


@@ -20,6 +24,8 @@


import com.ruoyi.framework.security.LoginUser;


import com.ruoyi.other.mapper.TempFileMapper;


import com.ruoyi.other.pojo.TempFile;


import com.ruoyi.procurementrecord.dto.SimplePP;


import com.ruoyi.procurementrecord.service.ProcurementPriceManagementService;


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


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


import com.ruoyi.purchase.dto.PurchaseLedgerDto;


@@ -42,15 +48,18 @@


import org.springframework.beans.factory.annotation.Value;


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


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;




import java.io.IOException;


import java.math.BigDecimal;


import java.math.RoundingMode;


import java.nio.file.Files;


import java.nio.file.Path;


import java.nio.file.Paths;


import java.nio.file.StandardCopyOption;


import java.time.LocalDate;


import java.time.LocalDateTime;


import java.time.ZoneId;


import java.time.format.DateTimeFormatter;


import java.util.*;


import java.util.concurrent.TimeUnit;


@@ -66,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;


@@ -92,6 +101,8 @@




    private final StringRedisTemplate redisTemplate;




    private final ProcurementPriceManagementService procurementPriceManagementService;




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


    private String uploadDir;




@@ -103,8 +114,42 @@


        }


        return purchaseLedgerMapper.selectList(queryWrapper);


    }




    @Override


    @Transactional(rollbackFor = Exception.class)


    public int addPurchaseTemplate(PurchaseLedgerDto purchaseLedgerDto) {


        //录入人


        SysUser sysUser = userMapper.selectUserById(purchaseLedgerDto.getRecorderId());




        SupplierManage supplierManage = supplierManageMapper.selectById(purchaseLedgerDto.getSupplierId());




        PurchaseLedger purchaseLedger = new PurchaseLedger();


        purchaseLedgerDto.setApprovalStatus(3);


        BeanUtils.copyProperties(purchaseLedgerDto, purchaseLedger);


        LoginUser loginUser = SecurityUtils.getLoginUser();


        if(ObjectUtils.isNotEmpty(loginUser) && null != loginUser.getTenantId()) {


            purchaseLedger.setTenantId(loginUser.getTenantId());


        }


        purchaseLedger.setSupplierName(supplierManage.getSupplierName());


        purchaseLedger.setRecorderName(sysUser.getNickName());


        purchaseLedger.setPhoneNumber(sysUser.getPhonenumber());


        purchaseLedger.setPurchaseContractNumber("11111");


        purchaseLedger.setEntryDate(Date.from(LocalDate.now().atStartOfDay(ZoneId.systemDefault()).toInstant()));


        purchaseLedgerMapper.insert(purchaseLedger);




        // 4. 处理子表数据


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


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


            productList.forEach(product -> {


                product.setSalesLedgerId(purchaseLedger.getId());


                product.setType(purchaseLedgerDto.getType());


            });


            productList.forEach(salesLedgerProductMapper::insert);


        }




        return 1;


    }


    @Override


    @Transactional(rollbackFor = Exception.class)


    public int addOrEditPurchase(PurchaseLedgerDto purchaseLedgerDto) throws IOException {




        SalesLedger salesLedger = salesLedgerMapper.selectById(purchaseLedgerDto.getSalesLedgerId());


@@ -125,12 +170,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. 处理子表数据


@@ -151,7 +225,7 @@


        if (products == null || products.isEmpty()) {


            throw new BaseException("产品信息不存在");


        }




        PurchaseLedger ledger = purchaseLedgerMapper.selectById(salesLedgerId);


        // 提前收集所有需要查询的ID


        Set<Long> productIds = products.stream()


                .map(SalesLedgerProduct::getProductId)


@@ -197,7 +271,7 @@




        List<SalesLedgerProduct> updateList = partitionedProducts.get(true);


        List<SalesLedgerProduct> insertList = partitionedProducts.get(false);


        SalesLedger salesLedger = salesLedgerMapper.selectById(salesLedgerId);


        PurchaseLedger purchaseLedger = purchaseLedgerMapper.selectById(salesLedgerId);




        // 执行更新操作


        if (!updateList.isEmpty()) {


@@ -210,10 +284,35 @@


        if (!insertList.isEmpty()) {


            for (SalesLedgerProduct salesLedgerProduct : insertList) {


                salesLedgerProduct.setType(type);


                salesLedgerProduct.setRegisterDate(salesLedger.getEntryDate().toString());


                Date entryDate = purchaseLedger.getEntryDate();




                LocalDateTime localDateTime = entryDate.toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime();


                salesLedgerProduct.setRegisterDate(localDateTime);


                salesLedgerProductMapper.insert(salesLedgerProduct);


            }


        }




        updateList.addAll(insertList);


        updateList.forEach(it->{


            SimplePP simplePP = new SimplePP();


            simplePP.setProductId(it.getProductId());


            simplePP.setSupplierName(ledger.getSupplierName());


            simplePP.setSupplierId(ledger.getSupplierId());


            simplePP.setUnit(it.getUnit());


            simplePP.setProductName(it.getProductCategory());


            simplePP.setSpecification(it.getSpecificationModel());


            simplePP.setFinalPrice(it.getTaxInclusiveUnitPrice().divide(


                    BigDecimal.ONE.add(it.getTaxRate().divide(new BigDecimal("100"), 4, RoundingMode.HALF_UP)),


                    2,  // 保留4位（可根据业务调整）


                    RoundingMode.HALF_UP


            ));


            simplePP.setRemark(


                    "系统根据采购提交自动生成。采购合同号为:" + purchaseLedger.getPurchaseContractNumber() + "。"


            );


            procurementPriceManagementService.autoCreateRecord(simplePP);


        });








        // 计算总含税金额


        BigDecimal totalTaxInclusiveAmount = products.stream()


@@ -270,12 +369,15 @@




            try {


                // 执行文件迁移（使用原子操作确保安全性）


                Files.move(


                        Paths.get(tempFile.getTempPath()),


                        formalFilePath,


                        StandardCopyOption.REPLACE_EXISTING,


                        StandardCopyOption.ATOMIC_MOVE


                );


//                Files.move(


//                        Paths.get(tempFile.getTempPath()),


//                        formalFilePath,


//                        StandardCopyOption.REPLACE_EXISTING,


//                        StandardCopyOption.ATOMIC_MOVE


//                );


                // 原子移动失败，使用复制+删除


                Files.copy(Paths.get(tempFile.getTempPath()), formalFilePath, StandardCopyOption.REPLACE_EXISTING);


                Files.deleteIfExists(Paths.get(tempFile.getTempPath()));


                log.info("文件迁移成功: {} -> {}", tempFile.getTempPath(), formalFilePath);




                // 更新文件记录（关联到业务ID）


@@ -337,7 +439,8 @@




        // 3.查询上传文件


        LambdaQueryWrapper<CommonFile> salesLedgerFileWrapper = new LambdaQueryWrapper<>();


        salesLedgerFileWrapper.eq(CommonFile::getCommonId, purchaseLedger.getId());


        salesLedgerFileWrapper.eq(CommonFile::getCommonId, purchaseLedger.getId())


                .eq(CommonFile::getType,FileNameType.PURCHASE.getValue());


        List<CommonFile> salesLedgerFiles = commonFileMapper.selectList(salesLedgerFileWrapper);




        // 4. 转换 DTO