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.baomidou.mybatisplus.extension.toolkit.SqlHelper;
|
import com.chinaztt.mes.basic.entity.Part;
|
import com.chinaztt.mes.basic.mapper.PartMapper;
|
import com.chinaztt.mes.warehouse.dto.DeliveryDetailDTO;
|
import com.chinaztt.mes.warehouse.entity.DeliveryDetail;
|
import com.chinaztt.mes.warehouse.mapper.DeliveryDetailMapper;
|
import com.chinaztt.mes.warehouse.service.DeliveryDetailService;
|
import com.chinaztt.ztt.common.core.util.R;
|
import lombok.AllArgsConstructor;
|
import org.springframework.security.core.parameters.P;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.math.BigDecimal;
|
import java.util.List;
|
|
/**
|
* 送货清单表
|
*
|
* @author cxf
|
* @date 2020-10-12 14:11:40
|
*/
|
@Service
|
@AllArgsConstructor
|
@Transactional(rollbackFor = Exception.class)
|
public class DeliveryDetailServiceImpl extends ServiceImpl<DeliveryDetailMapper, DeliveryDetail> implements DeliveryDetailService {
|
private PartMapper partMapper;
|
@Override
|
public IPage<List<DeliveryDetailDTO>> getDeliveryDetailPage(Page page, QueryWrapper<DeliveryDetailDTO> gen) {
|
return baseMapper.getDeliveryDetailPage(page, gen);
|
}
|
|
@Override
|
public DeliveryDetailDTO getDeliveryDetailById(Long id) {
|
return baseMapper.getDeliveryDetailById(id);
|
}
|
|
@Override
|
public boolean deleteById(Long id) {
|
DeliveryDetail deliveryDetail = baseMapper.selectById(id);
|
if (deliveryDetail.getReceiveQty() != null && deliveryDetail.getReceiveQty().compareTo(BigDecimal.ZERO) == 1) {
|
throw new RuntimeException("已收料，无法删除");
|
}
|
return SqlHelper.retBool(baseMapper.deleteById(id));
|
}
|
|
@Override
|
public List<DeliveryDetail> auditDeliveryDetail(Long mainId) {
|
//接收数量的过滤
|
List<DeliveryDetail> deliveryDetail = baseMapper.auditDelivery(mainId);
|
if (CollectionUtil.isNotEmpty(deliveryDetail)) {
|
StringBuilder string = new StringBuilder();
|
for (int i = 0; i<deliveryDetail.size(); i++) {
|
Part part = new Part();
|
part = partMapper.selectById(deliveryDetail.get(i).getPartId());
|
string.append(part.getPartNo());
|
string.append(",");
|
}
|
string.deleteCharAt(string.length()-1);
|
throw new RuntimeException("请确认收料，"+string+"在收料明细中不存在");
|
}
|
//差异数量的过滤
|
List<DeliveryDetail> deliveryDetailList = baseMapper.auditDeliveryDetail(mainId);
|
return deliveryDetailList;
|
}
|
|
@Override
|
public boolean save(DeliveryDetail deliveryDetail) {
|
List<DeliveryDetail> list = baseMapper.selectList(Wrappers.<DeliveryDetail>query().lambda().eq(DeliveryDetail::getReceivingMainId, deliveryDetail.getReceivingMainId())
|
.eq(DeliveryDetail::getPartId, deliveryDetail.getPartId()).eq(DeliveryDetail::getPartBatchNo, deliveryDetail.getPartBatchNo()));
|
if (CollectionUtil.isNotEmpty(list)) {
|
throw new RuntimeException("零件已存在，请勿重复添加");
|
}
|
return SqlHelper.retBool(baseMapper.insert(deliveryDetail));
|
}
|
|
@Override
|
public boolean updateById(DeliveryDetail deliveryDetail) {
|
if (deliveryDetail.getReceiveQty() != null) {
|
deliveryDetail.setDifferenceQty(deliveryDetail.getDeliveryQty().subtract(deliveryDetail.getReceiveQty()));
|
}
|
return SqlHelper.retBool(baseMapper.updateById(deliveryDetail));
|
}
|
}
|
