package com.yami.trading.service.user.impl;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import cn.hutool.core.util.StrUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.yami.trading.bean.model.RiskClient;
|
import com.yami.trading.common.constants.RedisKeys;
|
import com.yami.trading.common.exception.BusinessException;
|
import com.yami.trading.common.util.RedisUtil;
|
import com.yami.trading.dao.user.RiskClientMapper;
|
import com.yami.trading.service.user.RiskClientService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
@Service
|
@Slf4j
|
public class RiskClientServiceImpl extends ServiceImpl<RiskClientMapper, RiskClient> implements RiskClientService {
|
|
public Page<RiskClient> pageListRiskClient(int status, int pageNum, int pageSize) {
|
if (pageNum <= 1) {
|
pageNum = 1;
|
}
|
if (pageSize <= 0) {
|
pageSize = 20;
|
}
|
|
QueryWrapper<RiskClient> queryWrapper = new QueryWrapper<RiskClient>();
|
if (status >= 0) {
|
queryWrapper.eq("status", status);
|
}
|
|
Page<RiskClient> pageInfo = new Page(pageNum, pageSize);
|
return this.getBaseMapper().selectPage(pageInfo, queryWrapper);
|
}
|
|
public RiskClient getRiskClient(String clientKey, String clientType, String type) {
|
if (StrUtil.isBlank(clientKey) || StrUtil.isBlank(clientType) || StrUtil.isBlank(type)) {
|
throw new BusinessException("缺失必须参数");
|
}
|
|
QueryWrapper<RiskClient> queryWrapper = new QueryWrapper<RiskClient>();
|
queryWrapper.eq("client_key", clientKey.trim());
|
queryWrapper.eq("client_type", clientType.trim());
|
queryWrapper.eq("type", type.trim());
|
|
return this.getBaseMapper().selectOne(queryWrapper);
|
}
|
|
}
|
