package project.user.kyc.internal;
|
|
import java.text.MessageFormat;
|
import java.util.Date;
|
import java.util.List;
|
|
import kernel.exception.BusinessException;
|
import kernel.web.ApplicationUtil;
|
import project.redis.RedisHandler;
|
import project.syspara.SysparaService;
|
import project.user.UserRedisKeys;
|
import project.user.kyc.Kyc;
|
import project.user.kyc.KycService;
|
|
public class KycServiceImpl implements KycService {
|
|
private RedisHandler redisHandler;
|
|
private SysparaService sysparaService;
|
|
@Override
|
public Kyc get(String partyId) {
|
Kyc kyc = (Kyc) redisHandler.get(UserRedisKeys.KYC_PARTY_ID + partyId);
|
if (kyc != null) return kyc;
|
|
kyc = new Kyc();
|
kyc.setPartyId(partyId);
|
return kyc;
|
}
|
|
@Override
|
public void save(Kyc entity) {
|
Kyc kyc = get(entity.getPartyId().toString());
|
|
// 实名认证是否判断身份证号唯一（true:是，false:否）
|
Object obj = this.sysparaService.find("kyc_idnumber_only");
|
if (null != obj) {
|
if ("true".equals(this.sysparaService.find("kyc_idnumber_only").getValue())) {
|
List<Kyc> kycs = findByIdNumber(entity.getIdnumber().trim());
|
if (kycs != null) {
|
for (Kyc kyc_othde : kycs) {
|
if (kyc_othde.getStatus() == 2 && !kyc_othde.getPartyId().equals(entity.getPartyId())) {
|
throw new BusinessException("身份证号已实名过!");
|
}
|
}
|
}
|
}
|
}
|
|
if (kyc.getId() == null) {
|
entity.setApply_time(new Date());
|
entity.setId(ApplicationUtil.getCurrentTimeUUID());
|
this.insertKyc(entity);
|
redisHandler.setSync(UserRedisKeys.KYC_PARTY_ID + entity.getPartyId().toString(), entity);
|
} else {
|
kyc.setIdnumber(entity.getIdnumber());
|
kyc.setStatus(entity.getStatus());
|
kyc.setIdname(entity.getIdname());
|
kyc.setName(entity.getName());
|
kyc.setIdimg_1(entity.getIdimg_1());
|
kyc.setIdimg_2(entity.getIdimg_2());
|
kyc.setIdimg_3(entity.getIdimg_3());
|
kyc.setNationality(entity.getNationality());
|
if(entity.getStatus()==1) {
|
kyc.setApply_time(new Date());
|
}else {
|
kyc.setOperation_time(new Date());
|
}
|
kyc.setMsg(entity.getMsg());
|
this.updateKyc(kyc);
|
entity.setId(kyc.getId());
|
redisHandler.setSync(UserRedisKeys.KYC_PARTY_ID + kyc.getPartyId().toString(), kyc);
|
}
|
}
|
|
@Override
|
public void saveNoIdNumOnly(Kyc entity) {
|
Kyc kyc = get(entity.getPartyId().toString());
|
|
if (kyc.getId() == null) {
|
entity.setApply_time(new Date());
|
kyc.setId(ApplicationUtil.getCurrentTimeUUID());
|
this.insertKyc(entity);
|
redisHandler.setSync(UserRedisKeys.KYC_PARTY_ID + entity.getPartyId().toString(), entity);
|
} else {
|
kyc.setIdnumber(entity.getIdnumber());
|
kyc.setStatus(entity.getStatus());
|
kyc.setIdname(entity.getIdname());
|
kyc.setName(entity.getName());
|
kyc.setIdimg_1(entity.getIdimg_1());
|
kyc.setIdimg_2(entity.getIdimg_2());
|
kyc.setIdimg_3(entity.getIdimg_3());
|
kyc.setNationality(entity.getNationality());
|
|
if (entity.getStatus() == 1) {
|
kyc.setApply_time(new Date());
|
} else {
|
kyc.setOperation_time(new Date());
|
}
|
|
kyc.setMsg(entity.getMsg());
|
this.updateKyc(kyc);
|
entity.setId(kyc.getId());
|
redisHandler.setSync(UserRedisKeys.KYC_PARTY_ID + kyc.getPartyId().toString(), kyc);
|
}
|
}
|
|
/**
|
* 查询是否有多个实名用户
|
*
|
* @return
|
*/
|
public List<Kyc> findByIdNumber(String idNumber) {
|
List<Kyc> list = ApplicationUtil.executeSelect(Kyc.class,"WHERE IDNUMBER=?",new Object[] {idNumber});
|
return list.size()<=0?null:list;
|
}
|
|
/**
|
* 验证审核结果
|
*/
|
public String checkApplyResult(String partyId) throws BusinessException {
|
Kyc kyc = get(partyId);
|
if (null == kyc.getId())
|
return "";
|
String msg = "";
|
switch (kyc.getStatus()) {
|
case 0:
|
msg = "已经提交申请，请等待审核";
|
break;
|
case 1:
|
msg = "审核中";
|
break;
|
case 2:
|
msg = "审核已通过";
|
break;
|
case 3:
|
msg = MessageFormat.format("审核未通过,原因:{0}", kyc.getMsg());
|
break;
|
default:
|
msg = "审核状态异常请联系客服";
|
break;
|
}
|
if (kyc.getStatus() != 3) {
|
throw new BusinessException(msg);
|
} else {
|
return msg;
|
}
|
}
|
|
public boolean isPass(String partyId) {
|
Kyc kyc = get(partyId);
|
if (null == kyc)
|
return Boolean.FALSE;
|
return kyc.getStatus() == 2;
|
}
|
|
public void delete(String partyId) {
|
ApplicationUtil.executeDelete(Kyc.class,"WHERE PARTY_ID=?",new Object[] {partyId});
|
redisHandler.remove(UserRedisKeys.KYC_PARTY_ID + partyId);
|
}
|
|
public void insertKyc(Kyc kyc) {
|
ApplicationUtil.executeInsert(kyc);
|
}
|
|
public void updateKyc(Kyc kyc) {
|
ApplicationUtil.executeUpdate(kyc,"WHERE UUID=?", new Object[] {kyc.getId()});
|
}
|
|
public void setRedisHandler(RedisHandler redisHandler) {
|
this.redisHandler = redisHandler;
|
}
|
|
public void setSysparaService(SysparaService sysparaService) {
|
this.sysparaService = sysparaService;
|
}
|
}
|
