产品供销存-后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
liyong
8 天以前 ca0565e53494417b3779759f8d3898e07bfd5929 
 src/main/java/com/ruoyi/procurementrecord/service/impl/ProcurementRecordServiceImpl.java


@@ -4,6 +4,8 @@


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


import com.baomidou.mybatisplus.extension.plugins.pagination.Page;


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


import com.ruoyi.basic.mapper.ProductModelMapper;


import com.ruoyi.basic.pojo.ProductModel;


import com.ruoyi.common.utils.OrderUtils;


import com.ruoyi.common.utils.SecurityUtils;


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


@@ -14,22 +16,23 @@


import com.ruoyi.procurementrecord.mapper.ProcurementRecordMapper;


import com.ruoyi.procurementrecord.mapper.ProcurementRecordOutMapper;


import com.ruoyi.procurementrecord.pojo.CustomStorage;


import com.ruoyi.procurementrecord.pojo.ProcurementRecordStorage;


import com.ruoyi.procurementrecord.pojo.ProcurementRecordOut;


import com.ruoyi.procurementrecord.pojo.ProcurementRecordStorage;


import com.ruoyi.procurementrecord.service.ProcurementRecordService;


import com.ruoyi.procurementrecord.utils.StockUtils;


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


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


import com.ruoyi.sales.mapper.SalesLedgerProductMapper;


import com.ruoyi.sales.pojo.SalesLedgerProduct;


import lombok.RequiredArgsConstructor;


import lombok.extern.slf4j.Slf4j;


import org.springframework.beans.BeanUtils;


import org.springframework.stereotype.Service;


import org.springframework.util.CollectionUtils;


import org.springframework.util.StringUtils;




import javax.servlet.http.HttpServletResponse;


import java.math.BigDecimal;


import java.time.LocalDate;


import java.time.LocalDateTime;


import java.time.format.DateTimeFormatter;


import java.util.*;


@@ -49,6 +52,8 @@


    private final ProcurementRecordOutMapper procurementRecordOutMapper;




    private final SalesLedgerProductMapper salesLedgerProductMapper;


    private final StockUtils stockUtils;


    private final ProductModelMapper productModelMapper;




    @Override


    public List<ProcurementDto> listProcurementBySalesLedgerId(ProcurementDto procurementDto) {


@@ -771,8 +776,12 @@


                    .createTime(LocalDateTime.now())


                    .createUser(loginUser.getUserId())


                    .updateTime(LocalDateTime.now())


                    .boxNum(detail.getBoxNum())


                    .cartonSpecifications(detail.getCartonSpecifications())


                    .dollarPrice(detail.getDollarPrice())


                    .updateUser(loginUser.getUserId())


                    .createBy(procurementDto.getNickName());


                    .createBy(procurementDto.getNickName())


                    .productModelId(detail.getProductModelId());


            this.save(procurementRecordBuilder.build());


            // 入库成功减掉采购数量


//            LambdaQueryWrapper<SalesLedgerProduct> salesLedgerProductLambdaQueryWrapper = new LambdaQueryWrapper<>();


@@ -827,6 +836,15 @@


        return procurementPageDtoIPage;


    }




    public List<Long> listCopyIds(String ids) {


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


        String[] split = ids.split(",");


        for (String s : split) {


            idsSet.add(Long.valueOf(s));


        }


        return idsSet;


    }




    @Override


    public IPage<ProcurementPageDtoCopy> listPageCopy(Page page, ProcurementPageDto procurementDto) {


        IPage<ProcurementPageDtoCopy> procurementPageDtoCopyIPage = procurementRecordMapper.listPageCopy(page, procurementDto);


@@ -856,9 +874,8 @@


                dto.setTotalInboundNum(BigDecimal.ZERO);


                continue;


            }




            // 计算已出库数量总和，并设置待出库数量


            BigDecimal totalInboundNum = collect1.stream()


            BigDecimal totalInboundNum = procurementRecords.stream()


                    .map(ProcurementRecordOut::getInboundNum)


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


            // 出库数量 = 总数量 - 待出库数量


@@ -872,5 +889,22 @@


        }


        return procurementPageDtoCopyIPage;


    }


    @Override


    public IPage<ProductModel> listPageProductionStock(Page page) {


        ProductModel productModel = new ProductModel();


        IPage<ProductModel> iPage = productModelMapper.listPageProductModel(page, productModel);


        iPage.getRecords().forEach(item -> {


            item.setInboundNum(stockUtils.getStockQuantity(item.getId()).get("inboundNum"));


            item.setOutboundNum(stockUtils.getStockQuantity(item.getId()).get("outboundNum"));


            item.setStockQuantity(stockUtils.getStockQuantity(item.getId()).get("stockQuantity"));


        });


        return iPage;


    }




    @Override


    public IPage<ProcurementPageDto> listPageByProductProduction(Page page, ProcurementPageDto procurementDto) {


        IPage<ProcurementPageDto> procurementPageDtoIPage = procurementRecordMapper.listPageByProductProduction(page, procurementDto);


        return procurementPageDtoIPage;


    }




}