package com.chinaztt.mes.warehouse.service.impl;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.chinaztt.mes.warehouse.dto.ReceivingMainDTO;
|
import com.chinaztt.mes.warehouse.dto.StockAddDTO;
|
import com.chinaztt.mes.warehouse.entity.*;
|
import com.chinaztt.mes.warehouse.mapper.*;
|
import com.chinaztt.mes.warehouse.service.ReceivingMainService;
|
import com.chinaztt.mes.warehouse.util.StockUtils;
|
import lombok.AllArgsConstructor;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
/**
|
* 收货主表
|
*
|
* @author cxf
|
* @date 2020-10-12 14:11:33
|
*/
|
@Service
|
@AllArgsConstructor
|
@Transactional(rollbackFor = Exception.class)
|
public class ReceivingMainServiceImpl extends ServiceImpl<ReceivingMainMapper, ReceivingMain> implements ReceivingMainService {
|
private ReceivingDetailMapper receivingDetailMapper;
|
private DeliveryDetailMapper deliveryDetailMapper;
|
private StockUtils stockUtils;
|
private ReceivingMainMapper receivingMainMapper;
|
private StockInCodeMapper stockInCodeMapper;
|
|
@Override
|
public boolean deleteById(Long id) {
|
baseMapper.deleteById(id);
|
receivingDetailMapper.delete(Wrappers.<ReceivingDetail>query().lambda().eq(ReceivingDetail::getReceivingMainId, id));
|
deliveryDetailMapper.delete(Wrappers.<DeliveryDetail>query().lambda().eq(DeliveryDetail::getReceivingMainId, id));
|
return true;
|
}
|
|
@Override
|
public IPage<List<ReceivingMainDTO>> getWarehouseReceivingMainPage(Page page, QueryWrapper<ReceivingMainDTO> gen, String date) {
|
return baseMapper.getWarehouseReceivingMainPage(page, gen, date);
|
}
|
|
@Override
|
public List<Stock> fullUpdate(Long mainId) {
|
List<Stock> stockList = new ArrayList<Stock>();
|
List<ReceivingDetail> receivingDetailList = receivingDetailMapper.selectList
|
(Wrappers.<ReceivingDetail>query().lambda().eq(ReceivingDetail::getReceivingMainId, mainId));
|
if (CollectionUtil.isNotEmpty(receivingDetailList)) {
|
ReceivingMain receivingMain = receivingMainMapper.selectById(mainId);
|
StockInCode stockInCode = stockInCodeMapper.selectById(receivingMain.getReceiveType());
|
for (ReceivingDetail receivingDetail : receivingDetailList) {
|
StockAddDTO stockAdd = new StockAddDTO();
|
stockAdd.setPartsId(receivingDetail.getPartId());
|
stockAdd.setNewLocationId(receivingDetail.getLocationId());
|
stockAdd.setNewPartBatchNo(receivingDetail.getPartBatchNo());
|
|
Stock stock = stockUtils.query(stockAdd);
|
stockUtils.updateById(stock.getId(), receivingDetail.getReceiveQty(), BigDecimal.ZERO, BigDecimal.ZERO, BigDecimal.ZERO, receivingMain.getPurchaseNo(), stockInCode.getStockCodeName());
|
stockList.add(stock);
|
}
|
receivingMain.setReceiveStatus(true);
|
receivingMainMapper.updateById(receivingMain);
|
}
|
return stockList;
|
}
|
|
}
|
