package com.ruoyi.sales.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ruoyi.production.mapper.*;
|
import com.ruoyi.production.pojo.*;
|
import com.ruoyi.purchase.mapper.PurchaseLedgerMapper;
|
import com.ruoyi.purchase.pojo.PurchaseLedger;
|
import com.ruoyi.sales.dto.InvoiceRegistrationProductDto;
|
import com.ruoyi.sales.mapper.InvoiceRegistrationProductMapper;
|
import com.ruoyi.sales.mapper.SalesLedgerMapper;
|
import com.ruoyi.sales.mapper.SalesLedgerProductMapper;
|
import com.ruoyi.sales.pojo.InvoiceRegistrationProduct;
|
import com.ruoyi.sales.pojo.SalesLedger;
|
import com.ruoyi.sales.pojo.SalesLedgerProduct;
|
import com.ruoyi.sales.service.ISalesLedgerProductService;
|
import lombok.AllArgsConstructor;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.CollectionUtils;
|
|
import java.lang.reflect.Field;
|
import java.math.BigDecimal;
|
import java.time.LocalDate;
|
import java.time.format.DateTimeFormatter;
|
import java.util.*;
|
import java.util.function.Function;
|
import java.util.stream.Collectors;
|
|
/**
|
* 产品信息Service业务层处理
|
*
|
* @author ruoyi
|
* @date 2025-05-08
|
*/
|
@Service
|
@AllArgsConstructor
|
public class SalesLedgerProductServiceImpl extends ServiceImpl<SalesLedgerProductMapper, SalesLedgerProduct> implements ISalesLedgerProductService {
|
|
private SalesLedgerProductMapper salesLedgerProductMapper;
|
|
private SalesLedgerMapper salesLedgerMapper;
|
|
private PurchaseLedgerMapper purchaseLedgerMapper;
|
|
private ProductOrderMapper productOrderMapper;
|
|
private ProcessRouteItemMapper processRouteItemMapper;
|
|
private ProductProcessRouteItemMapper productProcessRouteItemMapper;
|
|
private InvoiceRegistrationProductMapper invoiceRegistrationProductMapper;
|
|
private ProcessRouteMapper processRouteMapper;
|
|
private ProductWorkOrderMapper productWorkOrderMapper;
|
|
@Override
|
public SalesLedgerProduct selectSalesLedgerProductById(Long id) {
|
return salesLedgerProductMapper.selectById(id);
|
}
|
|
@Override
|
public List<SalesLedgerProduct> selectSalesLedgerProductList(SalesLedgerProduct salesLedgerProduct) {
|
// LambdaQueryWrapper<SalesLedgerProduct> queryWrapper = new LambdaQueryWrapper<>();
|
// queryWrapper.eq(SalesLedgerProduct::getSalesLedgerId, salesLedgerProduct.getSalesLedgerId())
|
// .eq(SalesLedgerProduct::getType, salesLedgerProduct.getType());
|
List<SalesLedgerProduct> salesLedgerProducts = salesLedgerProductMapper.selectSalesLedgerProductList(salesLedgerProduct);
|
if(!CollectionUtils.isEmpty(salesLedgerProducts)){
|
InvoiceRegistrationProductDto invoiceRegistrationProductDto = new InvoiceRegistrationProductDto();
|
invoiceRegistrationProductDto.setSalesLedgerId(salesLedgerProduct.getSalesLedgerId().intValue());
|
List<InvoiceRegistrationProductDto> invoiceRegistrationProductDtoList = invoiceRegistrationProductMapper.invoiceRegistrationProductList(invoiceRegistrationProductDto);
|
// 统计开票登记产品的已开票数/已开票金额
|
if (!CollectionUtils.isEmpty(invoiceRegistrationProductDtoList)) {
|
for (SalesLedgerProduct ledgerProduct : salesLedgerProducts) {
|
BigDecimal invoiceNum = BigDecimal.ZERO;
|
BigDecimal invoiceAmount = BigDecimal.ZERO;
|
for (InvoiceRegistrationProductDto registrationProductDto : invoiceRegistrationProductDtoList) {
|
if(ledgerProduct.getId().intValue() == registrationProductDto.getSalesLedgerProductId()){
|
invoiceNum = invoiceNum.add(registrationProductDto.getInvoiceNum());
|
invoiceAmount = invoiceAmount.add(registrationProductDto.getInvoiceAmount());
|
}
|
}
|
ledgerProduct.setInvoiceNum(invoiceNum);
|
ledgerProduct.setInvoiceAmount(invoiceAmount);
|
}
|
}
|
|
}
|
return salesLedgerProducts;
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public int deleteSalesLedgerProductByIds(Long[] ids) {
|
if (ids == null || ids.length == 0) {
|
return 0;
|
}
|
|
// 1. 先查询要删除的子表记录，获取对应的 salesLedgerId
|
List<SalesLedgerProduct> deletedProducts = salesLedgerProductMapper.selectBatchIds(Arrays.asList(ids));
|
if (deletedProducts.isEmpty()) {
|
return 0; // 没有可删除的数据
|
}
|
|
// 可能属于多个主表
|
Set<Long> mainIds = deletedProducts.stream()
|
.map(SalesLedgerProduct::getSalesLedgerId)
|
.filter(Objects::nonNull)
|
.collect(Collectors.toSet());
|
|
// 2. 执行删除操作
|
int result = salesLedgerProductMapper.deleteBatchIds(Arrays.asList(ids));
|
//删除对应的生产订单
|
//批量查询productOrder
|
List<ProductOrder> productOrders = productOrderMapper.selectList(
|
new LambdaQueryWrapper<ProductOrder>()
|
.in(ProductOrder::getProductModelId, ids)
|
);
|
|
if (!CollectionUtils.isEmpty(productOrders)) {
|
List<Long> orderIds = productOrders.stream()
|
.map(ProductOrder::getId)
|
.collect(Collectors.toList());
|
|
// 批量查询processRouteItems
|
List<ProductProcessRouteItem> allRouteItems = productProcessRouteItemMapper.selectList(
|
new LambdaQueryWrapper<ProductProcessRouteItem>()
|
.in(ProductProcessRouteItem::getRouteId, orderIds)
|
);
|
|
if (!CollectionUtils.isEmpty(allRouteItems)) {
|
List<Long> routeItemIds = allRouteItems.stream()
|
.map(ProductProcessRouteItem::getId)
|
.collect(Collectors.toList());
|
|
// 批量删除workOrder
|
productWorkOrderMapper.delete(new LambdaQueryWrapper<ProductWorkOrder>()
|
.in(ProductWorkOrder::getProductProcessRouteItemId, routeItemIds));
|
}
|
|
// 批量删除processRouteItem
|
productProcessRouteItemMapper.delete(new LambdaQueryWrapper<ProductProcessRouteItem>()
|
.in(ProductProcessRouteItem::getRouteId, orderIds));
|
|
// 批量删除productOrder
|
productOrderMapper.delete(new LambdaQueryWrapper<ProductOrder>()
|
.in(ProductOrder::getProductModelId, ids));
|
}
|
|
// 3. 对每个主表ID进行金额更新
|
for (Long salesLedgerId : mainIds) {
|
LambdaQueryWrapper<SalesLedgerProduct> wrapper = new LambdaQueryWrapper<>();
|
wrapper.eq(SalesLedgerProduct::getSalesLedgerId, salesLedgerId);
|
List<SalesLedgerProduct> remainingProducts = salesLedgerProductMapper.selectList(wrapper);
|
|
// 调用通用方法更新主表金额
|
updateMainContractAmount(
|
salesLedgerId,
|
remainingProducts,
|
SalesLedgerProduct::getTaxInclusiveTotalPrice,
|
salesLedgerMapper,
|
SalesLedger.class
|
);
|
}
|
return result;
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public int addOrUpdateSalesLedgerProduct(SalesLedgerProduct salesLedgerProduct) {
|
//未开票数量+金额
|
salesLedgerProduct.setNoInvoiceNum(salesLedgerProduct.getQuantity());
|
salesLedgerProduct.setNoInvoiceAmount(salesLedgerProduct.getTaxInclusiveTotalPrice());
|
int result;
|
Long salesLedgerId = salesLedgerProduct.getSalesLedgerId();
|
if (salesLedgerProduct.getId() == null) {
|
result = salesLedgerProductMapper.insert(salesLedgerProduct);
|
ProductOrder productOrder = new ProductOrder();
|
productOrder.setSalesLedgerId(salesLedgerProduct.getSalesLedgerId());
|
productOrder.setProductModelId(salesLedgerProduct.getId());
|
productOrder.setNpsNo("SC" + String.format("%08d", salesLedgerProduct.getId()));
|
productOrderMapper.insert(productOrder);
|
|
ProcessRoute processRoute = processRouteMapper.selectOne(new QueryWrapper<ProcessRoute>().lambda().eq(ProcessRoute::getProductModelId, salesLedgerProduct.getProductModelId()));
|
if (processRoute != null) {
|
List<ProcessRouteItem> processRouteItems = processRouteItemMapper.selectList(new QueryWrapper<ProcessRouteItem>().lambda().eq(ProcessRouteItem::getRouteId, processRoute.getId()));
|
// 生成当前日期的前缀：年月日
|
String datePrefix = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyyMMdd"));
|
for (ProcessRouteItem processRouteItem : processRouteItems) {
|
ProductProcessRouteItem productProcessRouteItem = new ProductProcessRouteItem();
|
productProcessRouteItem.setProductModelId(processRouteItem.getProductModelId());
|
productProcessRouteItem.setProcessId(processRouteItem.getProcessId());
|
productProcessRouteItem.setRouteId(productOrder.getId());
|
int insert = productProcessRouteItemMapper.insert(productProcessRouteItem);
|
if (insert > 0) {
|
// 查询今日已存在的最大工单号
|
QueryWrapper<ProductWorkOrder> queryWrapper = new QueryWrapper<>();
|
queryWrapper.likeRight("work_order_no", datePrefix)
|
.orderByDesc("work_order_no")
|
.last("LIMIT 1");
|
|
ProductWorkOrder lastWorkOrder = productWorkOrderMapper.selectOne(queryWrapper);
|
|
int sequenceNumber = 1; // 默认序号
|
if (lastWorkOrder != null && lastWorkOrder.getWorkOrderNo() != null) {
|
String lastNo = lastWorkOrder.getWorkOrderNo().toString();
|
if (lastNo.startsWith(datePrefix)) {
|
String seqStr = lastNo.substring(datePrefix.length());
|
try {
|
sequenceNumber = Integer.parseInt(seqStr) + 1;
|
} catch (NumberFormatException e) {
|
sequenceNumber = 1;
|
}
|
}
|
}
|
// 生成完整的工单号
|
String workOrderNoStr = String.format("%s%03d", datePrefix, sequenceNumber);
|
ProductWorkOrder productWorkOrder = new ProductWorkOrder();
|
productWorkOrder.setProductProcessRouteItemId(productProcessRouteItem.getId());
|
productWorkOrder.setProductOrderId(productOrder.getId());
|
productWorkOrder.setPlanQuantity(salesLedgerProduct.getQuantity());
|
productWorkOrder.setWorkOrderNo(workOrderNoStr);
|
productWorkOrder.setStatus(1);
|
|
productWorkOrderMapper.insert(productWorkOrder);
|
}
|
|
}
|
productOrder.setRouteId(processRoute.getId());
|
productOrderMapper.updateById(productOrder);
|
}
|
|
|
} else {
|
salesLedgerProduct.setFutureTickets(salesLedgerProduct.getQuantity());
|
result = salesLedgerProductMapper.updateById(salesLedgerProduct);
|
}
|
|
// 如果插入或更新成功，并且有 salesLedgerId，才继续更新主表金额
|
if (result > 0 && salesLedgerId != null) {
|
// 查询该主表下的所有子表数据
|
LambdaQueryWrapper<SalesLedgerProduct> wrapper = new LambdaQueryWrapper<>();
|
wrapper.eq(SalesLedgerProduct::getSalesLedgerId, salesLedgerId)
|
.eq(SalesLedgerProduct::getType, salesLedgerProduct.getType());
|
List<SalesLedgerProduct> productList = salesLedgerProductMapper.selectList(wrapper);
|
if (salesLedgerProduct.getType() == 1) {
|
// 调用通用方法更新主表金额
|
updateMainContractAmount(
|
salesLedgerId,
|
productList,
|
SalesLedgerProduct::getTaxInclusiveTotalPrice,
|
salesLedgerMapper,
|
SalesLedger.class
|
);
|
} else {
|
// 调用通用方法更新主表金额
|
updateMainContractAmount(
|
salesLedgerId,
|
productList,
|
SalesLedgerProduct::getTaxInclusiveTotalPrice,
|
purchaseLedgerMapper,
|
PurchaseLedger.class
|
);
|
}
|
}
|
return result;
|
}
|
|
/**
|
* 通用方法：根据主表ID和子表列表，更新主表的合同金额
|
*/
|
public <T, S> void updateMainContractAmount(
|
Long mainId,
|
List<T> subList,
|
Function<T, BigDecimal> amountGetter,
|
BaseMapper<S> mainMapper,
|
Class<S> mainEntityClass) {
|
|
if (mainId == null || subList == null || subList.isEmpty()) {
|
return;
|
}
|
|
BigDecimal totalAmount = subList.stream()
|
.map(amountGetter)
|
.filter(Objects::nonNull)
|
.reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
try {
|
S entity = mainEntityClass.getDeclaredConstructor().newInstance();
|
Field idField = mainEntityClass.getDeclaredField("id");
|
idField.setAccessible(true);
|
idField.set(entity, mainId);
|
|
Field amountField = mainEntityClass.getDeclaredField("contractAmount");
|
amountField.setAccessible(true);
|
amountField.set(entity, totalAmount);
|
|
mainMapper.updateById(entity);
|
} catch (Exception e) {
|
throw new RuntimeException("动态更新主表金额失败", e);
|
}
|
}
|
}
|
