valhalla / fw-valhalla

  package cn.fw.valhalla.service.data.impl;
  

  import cn.fw.valhalla.dao.mapper.CustomerMapper;

  import cn.fw.valhalla.domain.db.customer.Customer;

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

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

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

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

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

  import cn.fw.valhalla.domain.vo.customer.CustomerListVO;

  import cn.fw.valhalla.sdk.param.CusCntReq;

  import cn.fw.valhalla.sdk.result.BasicsCustomerDTO;

  import cn.fw.valhalla.sdk.result.CusCntResult;

  import cn.fw.valhalla.service.data.CustomerService;

  import com.baomidou.mybatisplus.core.toolkit.Wrappers;

  import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  import lombok.extern.slf4j.Slf4j;

  import org.springframework.lang.NonNull;
  import org.springframework.lang.Nullable;

  import org.springframework.stereotype.Service;

  import org.springframework.transaction.annotation.Transactional;

  import org.springframework.util.CollectionUtils;

  
  import java.util.ArrayList;
  import java.util.List;

  import java.util.Optional;

  
  /**
   * @author : kurisu
   * @className : CustomerServiceImpl
   * @description : 档案
   * @date: 2020-08-12 11:20
   */
  @Service
  @Slf4j
  public class CustomerServiceImpl extends ServiceImpl<CustomerMapper, Customer> implements CustomerService {

      @Override
      public List<CustomerListVO> getAppPageList(Integer startIndex, Integer pageSize, CustomerQueryVO queryVO) {
          List<CustomerListVO> appPageList = getBaseMapper().getAppPageList(startIndex, queryVO.getPageSize(), queryVO);
          return CollectionUtils.isEmpty(appPageList) ? new ArrayList<>() : appPageList;
      }
  
      @Override
      public Customer queryById(Long id) {
          return this.getBaseMapper().selectOne(Wrappers.<Customer>lambdaQuery()
                  .eq(Customer::getId, id)
                  .eq(Customer::getYn, Boolean.TRUE)
                  .last("limit 1"));
      }
  
      @Override

      public Customer queryByIdWithInvalid(Long id) {
          return this.getBaseMapper().selectOne(Wrappers.<Customer>lambdaQuery()
                  .eq(Customer::getId, id)
                  .last("limit 1"));
      }
  
      @Override

      public Customer queryByPlateNo(String plateNo, Long groupId) {

          return this.getBaseMapper().selectOne(Wrappers.<Customer>lambdaQuery()
                  .eq(Customer::getPlateNo, plateNo)
                  .eq(Customer::getYn, Boolean.TRUE)

                  .eq(Customer::getGroupId, groupId)

                  .orderByDesc(Customer::getUpdateTime)

                  .last("limit 1"));
      }
  
      @Override

      public Customer queryByFrameNo(String frameNo, Long groupId) {

          return this.getBaseMapper().selectOne(Wrappers.<Customer>lambdaQuery()
                  .eq(Customer::getFrameNo, frameNo)
                  .eq(Customer::getYn, Boolean.TRUE)

                  .eq(Customer::getGroupId, groupId)

                  .orderByDesc(Customer::getUpdateTime)

                  .last("limit 1"));
      }

  
      @Override

      public Customer queryByEngineNo(String engineNo, Long groupId) {
          return this.getBaseMapper().selectOne(Wrappers.<Customer>lambdaQuery()
                  .eq(Customer::getEngineNo, engineNo)
                  .eq(Customer::getYn, Boolean.TRUE)
                  .eq(Customer::getGroupId, groupId)
                  .orderByDesc(Customer::getUpdateTime)
                  .last("limit 1"));
      }
  
      @Override

      public List<Customer> queryByBaseId(Long baseId) {
          return this.list(Wrappers.<Customer>lambdaQuery()
                  .eq(Customer::getBaseId, baseId)
                  .eq(Customer::getYn, Boolean.TRUE)
          );
      }
  
      @Override

      public void forbidden(Long customerId) {
          this.update(Wrappers.<Customer>lambdaUpdate()
                  .set(Customer::getYn, Boolean.FALSE)
                  .eq(Customer::getId, customerId)
          );
      }

  
      @Override

      public void forbiddenPlate(String plateNo) {
          this.update(Wrappers.<Customer>lambdaUpdate()
                  .set(Customer::getYn, Boolean.FALSE)
                  .eq(Customer::getPlateNo, plateNo)
                  .eq(Customer::getYn, Boolean.TRUE)
          );

      }

  
      @Override
      @Nullable
      public List<Customer> queryByAdviserId(@NonNull Long adviserId) {
          return this.list(Wrappers.<Customer>lambdaQuery()
                  .eq(Customer::getAdviserId, adviserId)
                  .eq(Customer::getYn, Boolean.TRUE)
          );
      }

  
      @Override
      public List<StammkundeAnalyseDTO> analyseList(final StammkundeAnalyseQueryVO queryVO) {
          List<StammkundeAnalyseDTO> list = this.getBaseMapper().analyseList(queryVO);
          return Optional.ofNullable(list).orElse(new ArrayList<>());
      }

  
      @Override
      public List<CustomerDetailDto> queryCustomList(CustomCustomerQuery query) {
          return Optional.ofNullable(getBaseMapper().queryCustomList(query)).orElse(new ArrayList<>());
      }

  
      @Override
      public Long queryCustomListCount(CustomCustomerQuery query) {
          return Optional.ofNullable(getBaseMapper().queryCustomCount(query)).orElse(0L);
      }

  
      @Override
      public List<BasicsCustomerDTO> queryByKeyword(String keyword, Long groupId) {
          return Optional.ofNullable(this.getBaseMapper().queryByKeyword(keyword, groupId)).orElse(new ArrayList<>());
      }

  
      @Override
      @Transactional(rollbackFor = Exception.class)
      public void afterDistributePubClue(final List<String> vinList, final Long userId, final Long shopId, final Long groupId) {
          update(Wrappers.<Customer>lambdaUpdate()
                  .set(Customer::getAdviserId, userId)
                  .set(Customer::getShopId, shopId)

                  .set(Customer::getTemporary, Boolean.TRUE)

                  .eq(Customer::getYn, Boolean.TRUE)
                  .eq(Customer::getGroupId, groupId)
                  .in(Customer::getFrameNo, vinList)
                  .isNull(Customer::getAdviserId)
          );
      }

  
      @Override
      public List<CusCntResult> queryCusCnt(final CusCntReq req) {
          if(!CollectionUtils.isEmpty(req.getShopIds())){
              return getBaseMapper().queryShopCusCnt(req);
          }
          return getBaseMapper().queryAdviserCusCnt(req);
      }

  }