package com.gk.firework.Service.ServiceImpl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.gk.firework.Domain.Exception.BusinessException;
import com.gk.firework.Domain.TransportCertificateArrivalRecord;
import com.gk.firework.Domain.UserInfo;
import com.gk.firework.Domain.Utils.StringUtils;
import com.gk.firework.Domain.Vo.TransportArrivalSum;
import com.gk.firework.Mapper.TransportCertificateArrivalRecordMapper;
import com.gk.firework.Service.TransportCertificateArrivalRecordService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import redis.clients.jedis.ZParams;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Service("transportCertificateArrivalRecordService")
public class TransportCertificateArrivalRecordServiceImpl extends ServiceImpl<TransportCertificateArrivalRecordMapper, TransportCertificateArrivalRecord> implements TransportCertificateArrivalRecordService {

    @Autowired
    TransportCertificateArrivalRecordMapper transportCertificateArrivalRecordMapper;
    @Override
    public IPage selectTransportArrivalPages(Page<TransportArrivalSum> page, UserInfo user) {

        Map<String, Object> params = new HashMap<>();
        params.put("enterprisenumber", user.getUsername());
        List<TransportArrivalSum> sums = transportCertificateArrivalRecordMapper.selectTransportArrivalPages(page, params);
        return page.setRecords(sums);
    }


    /**
    * @Description: 获取企业单位 在特定运输单的 到货记录
    * @date 2021/5/14 22:14
    */
    @Override
    public List<TransportCertificateArrivalRecord> getTransportArrivalDetail(String certificateCode, UserInfo user) {

        if (StringUtils.isBlank(certificateCode)) {
            throw new BusinessException("运输证单号不能为空");
        }
        LambdaQueryWrapper<TransportCertificateArrivalRecord> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.eq(TransportCertificateArrivalRecord::getValidflag, true)
                .eq(TransportCertificateArrivalRecord::getCertificatecode, certificateCode)
                .eq(TransportCertificateArrivalRecord::getCreatebyname,user.getUsername())
                .orderByDesc(TransportCertificateArrivalRecord::getCreatetime);
        return transportCertificateArrivalRecordMapper.selectList(queryWrapper);
    }
}