package com.yuanchu.mom.service.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.yuanchu.mom.mapper.ConsignmentMapper; import com.yuanchu.mom.mapper.RepertoryMapper; import com.yuanchu.mom.pojo.Consignment; import com.yuanchu.mom.pojo.Repertory; import com.yuanchu.mom.pojo.dto.ConsignmentDto; import com.yuanchu.mom.pojo.dto.ConsignmentDto2; import com.yuanchu.mom.service.ConsignmentService; import com.yuanchu.mom.utils.MyUtil; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.util.List; /** * 成品发货表(Consignment)表服务实现类 * * @author zss * @since 2023-08-10 15:08:02 */ @Service public class ConsignmentServiceImpl extends ServiceImpl implements ConsignmentService { @Resource ConsignmentMapper consignmentMapper; @Resource RepertoryMapper repertoryMapper; //新增成品发货 @Override public String addCon(String name, ConsignmentDto consignmentDto) { //如果该订单已经发过货了不能再发货 List consignments = consignmentMapper.selectAll(); for (Consignment consignment : consignments) { if (consignment.getCustomerCode().equals(consignmentDto.getCustomerCode())) { return "该合同订单已发过货,无法再次发货!"; } else { /*新增成品发货*/ List messages = consignmentDto.getMessages(); for (ConsignmentDto2 message : messages) { //查询产品编码(通过在成品库存表中的产品名称,规格型号以及单位进行查找) LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); queryWrapper.eq(Repertory::getName, message.getName()) .eq(Repertory::getSpecifications, message.getSpecifications()) .eq(Repertory::getUnit, message.getUnit()) .eq(Repertory::getType, 0); Repertory repertory = repertoryMapper.selectOne(queryWrapper); //该成品的检验状态是已检验1才能进行发货 if (repertory.getCheckState() == 1) { //该成品库存的数量大于等于发货的数量才能进行发货 if (repertory.getNumber() >= message.getNumber()) { //构造成品发货实体类 Consignment consig = Consignment.builder() .customerCode(consignmentDto.getCustomerCode()) .escortCode(MyUtil.getTimeSixNumberCode("YY")) .orderCode(consignmentDto.getOrderCode()) .userName(name) .checkName(consignmentDto.getCheckName()) .fitName(consignmentDto.getFitName()) .name(message.getName()) .specifications(message.getSpecifications()) .unit(message.getUnit()) .number(message.getNumber()) .code(repertory.getCode()) .build(); consignmentMapper.insert(consig); /*减少对应的库存*/ repertory.setNumber(repertory.getNumber() - consig.getNumber()); repertoryMapper.updateById(repertory); } else return "库存不足,无法发货!"; } else return "该产品还未检验,不能发货!"; } } } return "发货成功!"; } }