valhalla / fw-valhalla

  package cn.fw.valhalla.service.data.impl;
  
  import cn.fw.valhalla.dao.mapper.PublicPoolMapper;

  import cn.fw.valhalla.domain.db.pool.PublicPool;

  import cn.fw.valhalla.domain.dto.PublicPoolDTO;

  import cn.fw.valhalla.domain.dto.PublicPoolReportDTO;
  import cn.fw.valhalla.domain.dto.PublicPoolReportQueryDTO;

  import cn.fw.valhalla.domain.query.PublicPoolQueryVO;

  import cn.fw.valhalla.service.data.PublicPoolService;
  import com.baomidou.mybatisplus.core.toolkit.Wrappers;
  import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  import lombok.extern.slf4j.Slf4j;
  import org.springframework.stereotype.Service;

  import org.springframework.transaction.annotation.Transactional;

  import org.springframework.util.CollectionUtils;

  import java.util.ArrayList;

  import java.util.Collections;

  import java.util.List;

  import java.util.Optional;
  
  /**
   * @author : kurisu
   * @className : PublicPoolServiceImpl
   * @description : 公共池
   * @date: 2020-08-12 11:22
   */
  @Slf4j
  @Service
  public class PublicPoolServiceImpl extends ServiceImpl<PublicPoolMapper, PublicPool> implements PublicPoolService {

      @Override

      public PublicPool queryByVin(final String vin, final Long groupId) {
          return getOne(Wrappers.<PublicPool>lambdaQuery()

                  .eq(PublicPool::getGroupId, groupId)

                  .eq(PublicPool::getFrameNo, vin)

                  .last("limit 1")
          );

      }

      @Transactional(rollbackFor = Exception.class)

      @Override
      public void removeByCustomerId(Long customerId, Long groupId) {
          remove(Wrappers.<PublicPool>lambdaQuery()
                  .eq(PublicPool::getCustomerId, customerId)
                  .eq(PublicPool::getGroupId, groupId)
          );
      }

      @Transactional(rollbackFor = Exception.class)
      @Override
      public void removeByVin(final String vin, final Long groupId) {
          remove(Wrappers.<PublicPool>lambdaQuery()
                  .eq(PublicPool::getFrameNo, vin)
                  .eq(PublicPool::getGroupId, groupId)
          );
      }
  

      @Override

      @Transactional(rollbackFor = Exception.class)
      public void removeBatchByVin(final List<String> vinList, final Long groupId) {
          if (CollectionUtils.isEmpty(vinList)) {
              return;
          }
          remove(Wrappers.<PublicPool>lambdaQuery()
                  .in(PublicPool::getFrameNo, vinList)
                  .eq(PublicPool::getGroupId, groupId)
          );
      }
  
      @Override

      public List<PublicPoolDTO> publicList(PublicPoolQueryVO queryVO) {
          Integer current = queryVO.getCurrent();
          Integer pageSize = queryVO.getPageSize();
          Integer startIndex = (current - 1) * pageSize;
          return Optional.ofNullable(getBaseMapper().publicList(startIndex, pageSize, queryVO)).orElse(new ArrayList<>());
      }
  
      @Override
      public Long publicListCount(PublicPoolQueryVO queryVO) {
          return Optional.ofNullable(getBaseMapper().publicListCount(queryVO)).orElse(0L);
      }

  
      @Override
      public List<String> queryIdListByShops(final List<Long> shopIds) {
          if (CollectionUtils.isEmpty(shopIds)) {
              return Collections.emptyList();
          }
          // mybatis plus 性能有问题 不使用
          return Optional.ofNullable(this.getBaseMapper().queryIdListByShops(shopIds)).orElse(Collections.emptyList());
      }

  
      @Override
      public List<PublicPoolReportDTO> countPublicPoolList(PublicPoolReportQueryDTO dto) {
          return Optional.ofNullable(this.getBaseMapper().countPublicPoolList(dto)).orElse(Collections.emptyList());
      }

  }