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


@@ -1,36 +1,31 @@


package com.ruoyi.purchase.service.impl;




import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.baomidou.mybatisplus.core.metadata.IPage;


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


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.bean.vo.ApproveProcessVO;


import com.ruoyi.approve.pojo.ApproveProcess;


import com.ruoyi.approve.service.impl.ApproveProcessServiceImpl;


import com.ruoyi.approve.vo.ApproveProcessVO;


import com.ruoyi.basic.enums.ApplicationTypeEnum;


import com.ruoyi.basic.enums.RecordTypeEnum;


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;


import com.ruoyi.basic.utils.FileUtil;


import com.ruoyi.common.enums.FileNameType;


import com.ruoyi.common.exception.base.BaseException;


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;


import com.ruoyi.procurementrecord.pojo.ProcurementRecordStorage;


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


@@ -38,14 +33,27 @@


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.mapper.PaymentRegistrationMapper;


import com.ruoyi.purchase.mapper.ProductRecordMapper;


import com.ruoyi.purchase.mapper.PurchaseLedgerMapper;


import com.ruoyi.purchase.mapper.TicketRegistrationMapper;


import com.ruoyi.purchase.pojo.PaymentRegistration;


import com.ruoyi.purchase.pojo.ProductRecord;


import com.ruoyi.purchase.pojo.PurchaseLedger;


import com.ruoyi.purchase.pojo.TicketRegistration;


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.quality.mapper.QualityInspectMapper;


import com.ruoyi.quality.mapper.QualityInspectParamMapper;


import com.ruoyi.quality.mapper.QualityTestStandardMapper;


import com.ruoyi.quality.mapper.QualityTestStandardParamMapper;


import com.ruoyi.quality.pojo.QualityInspect;


import com.ruoyi.quality.pojo.QualityInspectParam;


import com.ruoyi.quality.pojo.QualityTestStandard;


import com.ruoyi.quality.pojo.QualityTestStandardParam;


import com.ruoyi.sales.mapper.CommonFileMapper;


import com.ruoyi.sales.mapper.InvoiceRegistrationProductMapper;


import com.ruoyi.sales.mapper.SalesLedgerMapper;


import com.ruoyi.sales.mapper.SalesLedgerProductMapper;


import com.ruoyi.sales.pojo.CommonFile;


import com.ruoyi.sales.pojo.InvoiceRegistrationProduct;


import com.ruoyi.sales.pojo.SalesLedger;


@@ -53,23 +61,15 @@


import com.ruoyi.sales.service.impl.CommonFileServiceImpl;


import lombok.RequiredArgsConstructor;


import lombok.extern.slf4j.Slf4j;


import org.apache.commons.io.FilenameUtils;


import org.springframework.beans.BeanUtils;


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


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


import java.nio.file.StandardCopyOption;


import java.time.LocalDate;


import java.time.LocalDateTime;


import java.time.ZoneId;


@@ -86,72 +86,32 @@


 */


@Service


@Slf4j


@RequiredArgsConstructor


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


    @Autowired


    private  AccountExpenseService accountExpenseService;


    @Autowired


    private  PurchaseLedgerMapper purchaseLedgerMapper;




    @Autowired


    private  SalesLedgerMapper salesLedgerMapper;


    @Autowired


    private  SalesLedgerProductMapper salesLedgerProductMapper;




    @Autowired


    private  SysUserMapper userMapper;




    @Autowired


    private  TempFileMapper tempFileMapper;




    @Autowired


    private  CommonFileMapper commonFileMapper;




    @Autowired


    private  SupplierManageMapper supplierManageMapper;




    @Autowired


    private  ProductMapper productMapper;




    @Autowired


    private  ProductModelMapper productModelMapper;




    @Autowired


    private  SysUserMapper sysUserMapper;




    @Autowired


    private  TicketRegistrationMapper ticketRegistrationMapper;




    @Autowired


    private  ProductRecordMapper productRecordMapper;




    @Autowired


    private  PaymentRegistrationMapper paymentRegistrationMapper;


    @Autowired


    private  InvoiceRegistrationProductMapper invoiceRegistrationProductMapper;


    @Autowired


    private  StringRedisTemplate redisTemplate;


    @Autowired


    private  QualityInspectMapper qualityInspectMapper;


    @Autowired


    private  CommonFileServiceImpl commonFileService;


    @Autowired


    private  QualityTestStandardBindingMapper qualityTestStandardBindingMapper;


    @Autowired


    private  QualityTestStandardParamMapper qualityTestStandardParamMapper;


    @Autowired


    private  QualityTestStandardMapper qualityTestStandardMapper;


    @Autowired


    private  QualityInspectParamMapper qualityInspectParamMapper;


    @Autowired


    private  ApproveProcessServiceImpl approveProcessService;


    @Autowired


    private  ProcurementRecordMapper procurementRecordStorageMapper;


    @Autowired


    private  PurchaseLedgerTemplateMapper purchaseLedgerTemplateMapper;


    @Autowired


    private  SalesLedgerProductTemplateMapper salesLedgerProductTemplateMapper;


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


    private String uploadDir;


    private final PurchaseLedgerMapper purchaseLedgerMapper;


    private final SalesLedgerMapper salesLedgerMapper;


    private final SalesLedgerProductMapper salesLedgerProductMapper;


    private final SysUserMapper userMapper;


    private final TempFileMapper tempFileMapper;


    private final CommonFileMapper commonFileMapper;


    private final SupplierManageMapper supplierManageMapper;


    private final ProductMapper productMapper;


    private final ProductModelMapper productModelMapper;


    private final SysUserMapper sysUserMapper;


    private final TicketRegistrationMapper ticketRegistrationMapper;


    private final ProductRecordMapper productRecordMapper;


    private final PaymentRegistrationMapper paymentRegistrationMapper;


    private final InvoiceRegistrationProductMapper invoiceRegistrationProductMapper;


    private final StringRedisTemplate redisTemplate;


    private final QualityInspectMapper qualityInspectMapper;


    private final CommonFileServiceImpl commonFileService;


    private final QualityTestStandardParamMapper qualityTestStandardParamMapper;


    private final QualityTestStandardMapper qualityTestStandardMapper;


    private final QualityInspectParamMapper qualityInspectParamMapper;


    private final ApproveProcessServiceImpl approveProcessService;


    private final ProcurementRecordMapper procurementRecordStorageMapper;


    private final FileUtil fileUtil;




    @Override


    public List<PurchaseLedger> selectPurchaseLedgerList(PurchaseLedger purchaseLedger) {


@@ -171,15 +131,23 @@


    @Override


    @Transactional(rollbackFor = Exception.class)


    public int addOrEditPurchase(PurchaseLedgerDto purchaseLedgerDto) throws Exception {




        PurchaseLedger purchaseLedger = new PurchaseLedger();


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


        //录入人


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


        if (ObjectUtils.isNotEmpty(sysUser)) {


            purchaseLedger.setRecorderName(sysUser.getNickName());


            purchaseLedger.setPhoneNumber(sysUser.getPhonenumber());


        }else {


            purchaseLedger.setRecorderName(SecurityUtils.getLoginUser().getNickName());


            SysUser sysUser1 = userMapper.selectUserById(SecurityUtils.getUserId());


            purchaseLedger.setPhoneNumber(sysUser1.getPhonenumber());


        }




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




        // DTO转Entity


        PurchaseLedger purchaseLedger = new PurchaseLedger();




        BeanUtils.copyProperties(purchaseLedgerDto, purchaseLedger);


        LoginUser loginUser = SecurityUtils.getLoginUser();


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


@@ -189,8 +157,7 @@


        purchaseLedger.setSalesLedgerId(ObjectUtils.isNotEmpty(salesLedger) ? salesLedger.getId() : -1);


        purchaseLedger.setSupplierName(supplierManage.getSupplierName());


        purchaseLedger.setRecorderId(purchaseLedgerDto.getRecorderId());


        purchaseLedger.setRecorderName(sysUser.getNickName());


        purchaseLedger.setPhoneNumber(sysUser.getPhonenumber());




        purchaseLedger.setApprovalStatus(1);


        // 3. 新增或更新主表


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


@@ -225,9 +192,7 @@


//            }


//        }


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


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


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


        }


        fileUtil.saveStorageAttachment(ApplicationTypeEnum.FILE, RecordTypeEnum.PURCHASE_LEDGER, purchaseLedger.getId(), purchaseLedgerDto.getStorageBlobDTOS());


        return 1;


    }




@@ -347,80 +312,6 @@


        }


    }




    /**


     * 将临时文件迁移到正式目录


     *


     * @param businessId  业务ID（销售台账ID）


     * @param tempFileIds 临时文件ID列表


     * @throws IOException 文件操作异常


     */


    private void migrateTempFilesToFormal(Long businessId, List<String> tempFileIds) throws IOException {


        if (CollectionUtils.isEmpty(tempFileIds)) {


            return;


        }




        // 构建正式目录路径（按业务类型和日期分组）


        String formalDir = uploadDir + LocalDate.now().format(DateTimeFormatter.ISO_LOCAL_DATE);




        Path formalDirPath = Paths.get(formalDir);




        // 确保正式目录存在（递归创建）


        if (!Files.exists(formalDirPath)) {


            Files.createDirectories(formalDirPath);


        }




        for (String tempFileId : tempFileIds) {


            // 查询临时文件记录


            TempFile tempFile = tempFileMapper.selectById(tempFileId);


            if (tempFile == null) {


                log.warn("临时文件不存在，跳过处理: {}", tempFileId);


                continue;


            }




            // 构建正式文件名（包含业务ID和时间戳，避免冲突）


            String originalFilename = tempFile.getOriginalName();


            String fileExtension = FilenameUtils.getExtension(originalFilename);


            String formalFilename = businessId + "_" +


                    System.currentTimeMillis() + "_" +


                    UUID.randomUUID().toString().substring(0, 8) +


                    (StringUtils.hasText(fileExtension) ? "." + fileExtension : "");




            Path formalFilePath = formalDirPath.resolve(formalFilename);




            try {


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


//                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）


                CommonFile fileRecord = new CommonFile();


                fileRecord.setCommonId(businessId);


                fileRecord.setName(originalFilename);


                fileRecord.setUrl(formalFilePath.toString());


                fileRecord.setCreateTime(LocalDateTime.now());


                fileRecord.setType(FileNameType.PURCHASE.getValue());


                commonFileMapper.insert(fileRecord);




                // 删除临时文件记录


                tempFileMapper.deleteById(tempFile);




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


            } catch (IOException e) {


                log.error("文件迁移失败: {}", tempFile.getTempPath(), e);


                // 可选择回滚事务或记录失败文件


                throw new IOException("文件迁移异常", e);


            }


        }


    }




    @Override


    @Transactional(rollbackFor = Exception.class)


    public int deletePurchaseLedgerByIds(Long[] ids) {


@@ -518,11 +409,6 @@


                .eq(SalesLedgerProduct::getType, purchaseLedgerDto.getType());


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




        // 3.查询上传文件


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


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


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


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




        // 4. 转换 DTO


        PurchaseLedgerDto resultDto = new PurchaseLedgerDto();


@@ -530,7 +416,7 @@


        if (!products.isEmpty()) {


            resultDto.setHasChildren(true);


            resultDto.setProductData(products);


            resultDto.setSalesLedgerFiles(salesLedgerFiles);


            resultDto.setStorageBlobVOS(fileUtil.getStorageBlobVOsByApplicationAndRecordTypeAndRecordId(ApplicationTypeEnum.FILE, RecordTypeEnum.PURCHASE_LEDGER, purchaseLedger.getId()));


        }


        return resultDto;


    }