package project.party.internal;
|
|
import java.io.Serializable;
|
import java.util.Date;
|
import java.util.List;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
import org.springframework.security.providers.encoding.PasswordEncoder;
|
import org.springframework.util.ObjectUtils;
|
|
import kernel.bo.RecordObjectMapper;
|
import kernel.cache.RedisLocalCache;
|
import kernel.web.ApplicationUtil;
|
import project.party.PartyRedisKeys;
|
import project.party.PartyService;
|
import project.party.model.Party;
|
import project.redis.RedisHandler;
|
import security.SaltSigureUtils;
|
import security.SecUser;
|
import security.internal.SecUserService;
|
|
/**
|
* @author GORGE
|
* @description 用户持久层
|
*/
|
public class PartyServiceImpl implements PartyService {
|
/**
|
* Redis工具
|
*/
|
private RedisHandler redisHandler;
|
|
/**
|
* 系统用户持久层
|
*/
|
private SecUserService secUserService;
|
|
/**
|
* 密码工具
|
*/
|
private PasswordEncoder passwordEncoder;
|
|
/**
|
* 本地Redis工具(先取本地缓存再取Redis缓存)
|
*/
|
private RedisLocalCache redisLocalCache;
|
|
/**
|
* 日志组件
|
*/
|
private static final Logger logger=LoggerFactory.getLogger(PartyServiceImpl.class);
|
|
/**
|
* 获取用户认证等级: 1/新注册; 2/邮箱谷歌手机其中有一个已验证; 3/用户实名认证; 4/用户高级认证
|
* @param party 用户对象
|
* @return 认证等级
|
*/
|
public int getUserLevelByAuth(Party party) {
|
SecUser secUser = this.secUserService.findUserByPartyId(party.getId().toString());
|
int userLevel = 1;
|
if (party.getEmail_authority() || party.getPhone_authority() || secUser.isGoogle_auth_bind()) {
|
if (party.getKyc_authority()) {
|
userLevel=party.isKyc_highlevel_authority()?4:3;
|
} else {
|
userLevel = 2;
|
}
|
} else {
|
userLevel = 1;
|
}
|
return userLevel;
|
}
|
|
/**
|
* @param partyId 用户ID
|
* @param localcache 是否需要先读取本地缓存'
|
* @return 用户对象
|
*/
|
public Party cachePartyBy(Serializable partyId, boolean localcache) {
|
Party party = null;
|
|
if (localcache) { //先读本地缓存，再读Redis缓存
|
party = (Party) redisLocalCache.get(PartyRedisKeys.PARTY_ID + partyId);
|
} else { //仅读取Redis缓存
|
party = (Party) redisHandler.get(PartyRedisKeys.PARTY_ID + partyId);
|
}
|
|
return party;
|
}
|
|
/**
|
* @param entity 用户对象
|
* @return 用户对象
|
*/
|
public Party save(Party entity) {
|
if(null==entity) return null;
|
JdbcTemplate jdbcTemplate=ApplicationUtil.getBean(JdbcTemplate.class);
|
entity.setCreateTime(new Date());
|
if(null==entity.getId()) entity.setId(ApplicationUtil.getCurrentTimeUUID());
|
|
Object[] jdbcParams=ApplicationUtil.getInsertStatement(entity);
|
jdbcTemplate.update((String)jdbcParams[0],(Object[])jdbcParams[1]);
|
|
redisHandler.setSync(PartyRedisKeys.PARTY_ID + entity.getId(), entity);
|
redisHandler.setSync(PartyRedisKeys.PARTY_USERNAME + entity.getUsername(), entity);
|
|
return entity;
|
}
|
|
/**
|
* 修改或保存实体对象
|
* @param entity 用户对象
|
*/
|
public void update(Party entity) {
|
if(null==entity) return;
|
JdbcTemplate jdbcTemplate=ApplicationUtil.getBean(JdbcTemplate.class);
|
|
//执行update
|
Object[] jdbcParams=ApplicationUtil.getUpdateStatement(entity, "WHERE UUID=?", new Object[] {entity.getId()});
|
int count=jdbcTemplate.update((String)jdbcParams[0],(Object[])jdbcParams[1]);
|
if(count<=0) { //执行insert
|
jdbcParams=ApplicationUtil.getInsertStatement(entity);
|
jdbcTemplate.update((String)jdbcParams[0],(Object[])jdbcParams[1]);
|
}
|
redisHandler.setSync(PartyRedisKeys.PARTY_ID + entity.getId(), entity);
|
redisHandler.setSync(PartyRedisKeys.PARTY_USERNAME + entity.getUsername(), entity);
|
}
|
|
|
|
|
public void updateOpenBlack(String id,String openBlack){
|
JdbcTemplate jdbcTemplate=ApplicationUtil.getBean(JdbcTemplate.class);
|
String sql = "DELETE FROM PAT_PARTY SET UUID =? ";
|
jdbcTemplate.update(sql,new Object[]{openBlack,id} );
|
}
|
|
|
/**
|
* 通过用户名查找用户
|
* @param username 用户名
|
* @return 用户对象
|
*/
|
public Party findPartyByUsername(String username) {
|
if(null==username) return null;
|
JdbcTemplate jdbcTemplate=ApplicationUtil.getBean(JdbcTemplate.class);
|
|
Object[] jdbcParams=ApplicationUtil.getSelectStatement(Party.class, "WHERE USERNAME=?", new Object[] {username});
|
List<Party> list=jdbcTemplate.query((String)jdbcParams[0],RecordObjectMapper.newInstance(Party.class),(Object[])jdbcParams[1]);
|
|
return list.size() > 0?list.get(0):null;
|
}
|
|
/**
|
* 根据已验证的电话号码获取Party对象
|
* @param phone 电话号码
|
* @return 用户对象
|
*/
|
@Override
|
public Party findPartyByVerifiedPhone(String phone) {
|
if(null==phone) return null;
|
JdbcTemplate jdbcTemplate=ApplicationUtil.getBean(JdbcTemplate.class);
|
Object[] jdbcParams=ApplicationUtil.getSelectStatement(Party.class, "WHERE PHONE=? AND PHONE_AUTHORITY='Y'", new Object[] {phone});
|
List<Party> list=jdbcTemplate.query((String)jdbcParams[0],RecordObjectMapper.newInstance(Party.class),(Object[])jdbcParams[1]);
|
|
return list.size() > 0?list.get(0):null;
|
}
|
|
/**
|
* 根据已验证的邮箱获取Party对象
|
* @param email 电子邮件
|
* @return 用户对象
|
*/
|
@Override
|
public Party findPartyByVerifiedEmail(String email) {
|
if(null==email) return null;
|
JdbcTemplate jdbcTemplate=ApplicationUtil.getBean(JdbcTemplate.class);
|
|
Object[] jdbcParams=ApplicationUtil.getSelectStatement(Party.class, "WHERE EMAIL=? AND EMAIL_AUTHORITY='Y'", new Object[] {email});
|
List<Party> list=jdbcTemplate.query((String)jdbcParams[0],RecordObjectMapper.newInstance(Party.class),(Object[])jdbcParams[1]);
|
|
return list.size() > 0?list.get(0):null;
|
}
|
|
/**
|
* 获取所有用户
|
* @return 用户列表
|
*/
|
public List<Party> getAll() {
|
Object[] jdbcParams=ApplicationUtil.getSelectStatement(Party.class);
|
return ApplicationUtil.getBean(JdbcTemplate.class).query((String)jdbcParams[0],RecordObjectMapper.newInstance(Party.class),(Object[])jdbcParams[1]);
|
}
|
|
/**
|
* 根据用户码获取用户
|
* @param usercode 用户码
|
* @return 用户对象
|
*/
|
@Override
|
public Party findPartyByUsercode(String usercode) {
|
if(null==usercode) return null;
|
|
Object[] jdbcParams=ApplicationUtil.getSelectStatement(Party.class, "WHERE USERCODE=?", new Object[] {usercode});
|
List<Party> list=ApplicationUtil.getBean(JdbcTemplate.class).query((String)jdbcParams[0],RecordObjectMapper.newInstance(Party.class),(Object[])jdbcParams[1]);
|
|
return list.size() > 0?list.get(0):null;
|
}
|
|
/**
|
* 修改资金密码
|
* @param party 用户对象
|
* @param safeword 资金密码
|
*/
|
public void updateSafeword(Party party, String safeword) {
|
String safeword_md5 = passwordEncoder.encodePassword(safeword, SaltSigureUtils.saltfigure);
|
party.setSafeword(safeword_md5);
|
this.update(party);
|
|
}
|
|
/**
|
* 检查资金密码是否正确
|
* @param safeword 资金密码
|
* @param partyId 用户ID
|
* @return 资金密码是否正确
|
*/
|
public boolean checkSafeword(String safeword, String partyId) {
|
if (ObjectUtils.isEmpty(safeword)) return Boolean.FALSE;
|
|
Party party = this.cachePartyBy(partyId, false);
|
if (null==party) {
|
logger.error("party is null,id:{}", partyId);
|
return Boolean.FALSE;
|
}
|
|
if (ObjectUtils.isEmpty(party.getSafeword())) return Boolean.FALSE;
|
|
String md5 = passwordEncoder.encodePassword(safeword, SaltSigureUtils.saltfigure);
|
return md5.equals(party.getSafeword());
|
}
|
|
public void setPasswordEncoder(PasswordEncoder passwordEncoder) {
|
this.passwordEncoder = passwordEncoder;
|
}
|
|
public void setRedisHandler(RedisHandler redisHandler) {
|
this.redisHandler = redisHandler;
|
}
|
|
public void setRedisLocalCache(RedisLocalCache redisLocalCache) {
|
this.redisLocalCache = redisLocalCache;
|
}
|
|
public void setSecUserService(SecUserService secUserService) {
|
this.secUserService = secUserService;
|
}
|
}
|
