package com.chinaztt.mes.warehouse.service.impl;

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.warehouse.dto.ReceivingDetailDTO;
import com.chinaztt.mes.warehouse.entity.DeliveryDetail;
import com.chinaztt.mes.warehouse.entity.ReceivingDetail;
import com.chinaztt.mes.warehouse.mapper.DeliveryDetailMapper;
import com.chinaztt.mes.warehouse.mapper.ReceivingDetailMapper;
import com.chinaztt.mes.warehouse.service.ReceivingDetailService;
import lombok.AllArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.util.List;

/**
 * 收货明细表
 *
 * @author cxf
 * @date 2020-10-12 14:11:38
 */
@Service
@AllArgsConstructor
@Transactional(rollbackFor = Exception.class)
public class ReceivingDetailServiceImpl extends ServiceImpl<ReceivingDetailMapper, ReceivingDetail> implements ReceivingDetailService {
    private final DeliveryDetailMapper deliveryDetailMapper;

    @Override
    public IPage<List<ReceivingDetailDTO>> getReceivingDetailPage(Page page, QueryWrapper<ReceivingDetailDTO> gen) {
        return baseMapper.getReceivingDetailPage(page, gen);
    }

    @Override
    public List<ReceivingDetailDTO> getReceivingDetail(QueryWrapper<ReceivingDetailDTO> gen) {
        return baseMapper.getReceivingDetail(gen);
    }

    @Override
    public ReceivingDetailDTO getReceivingDetailById(Long id) {
        return baseMapper.getReceivingDetailById(id);
    }

    @Override
    public boolean save(ReceivingDetail receivingDetail) {
        receivingDetail.setReceiptTime(LocalDateTime.now());
        checkDifference(receivingDetail);
        return SqlHelper.retBool(baseMapper.insert(receivingDetail));
    }

    @Override
    public boolean updateById(ReceivingDetail receivingDetail) {
        receivingDetail.setReceiptTime(LocalDateTime.now());
        ReceivingDetail receivingDetailOld = baseMapper.selectById(receivingDetail.getId());
        // 1.根据老的明细数据量清除送货清单的接受数量
        receivingDetailOld.setReceiveQty(receivingDetailOld.getReceiveQty().negate());
        checkDifference(receivingDetailOld);
        // 2.根据新的明细增加对应送货清单的接收数量
        checkDifference(receivingDetail);
        return SqlHelper.retBool(baseMapper.updateById(receivingDetail));
    }

    @Override
    public boolean deleteById(Long id) {
        ReceivingDetail receivingDetail = baseMapper.selectById(id);
        receivingDetail.setReceiveQty(receivingDetail.getReceiveQty().negate());
        checkDifference(receivingDetail);
        return SqlHelper.retBool(baseMapper.deleteById(id));
    }

    /**
     * 计算差异数据（可以上数据库锁）
     *
     * @param receivingDetail
     */
    public synchronized void checkDifference(ReceivingDetail receivingDetail) {
        DeliveryDetail deliveryDetail = deliveryDetailMapper.selectOne(Wrappers.<DeliveryDetail>query().lambda().eq(DeliveryDetail::getReceivingMainId, receivingDetail.getReceivingMainId())
                .eq(DeliveryDetail::getPartId, receivingDetail.getPartId()));
        if (deliveryDetail != null) {
            // 1.存在
            BigDecimal receiveQty = deliveryDetail.getReceiveQty() == null ? BigDecimal.ZERO : deliveryDetail.getReceiveQty();
            deliveryDetail.setReceiveQty(receiveQty.add(receivingDetail.getReceiveQty()));
            deliveryDetail.setDifferenceQty(deliveryDetail.getDeliveryQty().subtract(deliveryDetail.getReceiveQty()));
            deliveryDetailMapper.updateById(deliveryDetail);
        } else {
            // 2.不存在
            deliveryDetail = new DeliveryDetail();
            deliveryDetail.setReceivingMainId(receivingDetail.getReceivingMainId());
            deliveryDetail.setPartId(receivingDetail.getPartId());
            deliveryDetail.setDeliveryQty(BigDecimal.ZERO);
            deliveryDetail.setReceiveQty(receivingDetail.getReceiveQty());
            deliveryDetail.setDifferenceQty(deliveryDetail.getDeliveryQty().subtract(deliveryDetail.getReceiveQty()));
            deliveryDetailMapper.insert(deliveryDetail);
        }
    }
}