package project.user.internal;
|
|
import java.util.ArrayList;
|
import java.util.Arrays;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
|
import org.springframework.security.providers.encoding.PasswordEncoder;
|
|
import kernel.exception.BusinessException;
|
import kernel.util.StringUtils;
|
import kernel.web.ApplicationUtil;
|
import kernel.web.Page;
|
import project.party.PartyService;
|
import project.party.model.Party;
|
import project.party.recom.UserRecomService;
|
import project.tip.TipService;
|
import project.user.AdminUserSafewordApplyService;
|
import project.user.UserSafewordApply;
|
import project.user.UserSafewordApplyService;
|
import project.user.kyc.Kyc;
|
import project.user.kyc.KycService;
|
import security.SecUser;
|
import security.internal.SecUserService;
|
|
@SuppressWarnings("rawtypes")
|
public class AdminUserSafewordApplyServiceImpl implements AdminUserSafewordApplyService {
|
|
private TipService tipService;
|
|
protected KycService kycService;
|
|
protected PartyService partyService;
|
|
private SecUserService secUserService;
|
|
private PasswordEncoder passwordEncoder;
|
|
protected UserRecomService userRecomService;
|
|
protected UserSafewordApplyService userSafewordApplyService;
|
|
@Override
|
public Page pagedQuery(int pageNo, int pageSize, String name_para, Integer status_para, String rolename_para,String checkedPartyId, Integer operate) {
|
if (pageNo <= 0) pageNo = 1;
|
Page page = new Page(pageNo, pageSize, Integer.MAX_VALUE);
|
|
StringBuilder sqlBuilder=new StringBuilder("SELECT party.UUID partyId, party.USERCODE usercode, party.USERNAME username, party.ROLENAME rolename, party.USER_LEVEL user_level,");
|
sqlBuilder.append("kyc.UUID kyc_id, kyc.IDNAME kyc_idname, kyc.NAME kyc_name, kyc.IDIMG_1 kyc_idimg_1, kyc.IDIMG_2 kyc_idimg_2,kyc.IDIMG_3 kyc_idimg_3, kyc.STATUS kyc_status,");
|
sqlBuilder.append("apply.UUID id, apply.IDCARD_PATH_FRONT idimg_1, apply.IDCARD_PATH_BACK idimg_2, apply.IDCARD_PATH_HOLD idimg_3,apply.MSG msg, apply.STATUS status,");
|
sqlBuilder.append("apply.CREATE_TIME create_time, apply.OPERATE operate, apply.REMARK remark FROM T_USER_SAFEWORD_APPLY apply ");
|
sqlBuilder.append("LEFT JOIN T_KYC kyc ON kyc.PARTY_ID=apply.PARTY_ID LEFT JOIN PAT_PARTY party ON kyc.PARTY_ID=party.UUID WHERE 1=1 ");
|
ArrayList<Object> params=new ArrayList<Object>();
|
|
if (!StringUtils.isNullOrEmpty(checkedPartyId)) {
|
List<String> checkedList = this.userRecomService.findChildren(checkedPartyId);
|
checkedList.add(checkedPartyId);
|
sqlBuilder.append("AND FIND_IN_SET(party.UUID,?) ");
|
params.add(String.join(",",checkedList));
|
}
|
|
if (status_para != null) {
|
sqlBuilder.append("AND apply.STATUS=? ");
|
params.add(status_para);
|
}
|
|
if (!StringUtils.isNullOrEmpty(rolename_para)) {
|
sqlBuilder.append("AND party.ROLENAME=? ");
|
params.add(rolename_para);
|
}
|
|
if (!StringUtils.isNullOrEmpty(name_para)) {
|
sqlBuilder.append("AND (party.USERNAME LIKE ? OR party.USERCODE LIKE ?) ");
|
params.add("%"+name_para+"%");
|
params.add("%"+name_para+"%");
|
}
|
|
if (operate != null) {
|
sqlBuilder.append("AND apply.OPERATE=? ");
|
params.add(operate);
|
}
|
|
sqlBuilder.append("ORDER BY apply.CREATE_TIME DESC LIMIT ?,?");
|
params.add(page.getFirstElementNumber());
|
params.add(pageSize);
|
|
List<HashMap> list=ApplicationUtil.executeDQL(sqlBuilder.toString(),params.toArray(new Object[params.size()]),HashMap.class);
|
page.setElements(list);
|
return page;
|
}
|
|
@Override
|
public void savePassed(String id, String operatorUsername, String safeword) {
|
UserSafewordApply apply = this.userSafewordApplyService.findById(id);
|
|
if (null == apply) {
|
throw new BusinessException("申请不存在，或请刷新重试");
|
}
|
|
if (apply.getStatus() != 1) {
|
throw new BusinessException("当前申请已处理");
|
}
|
|
if (!Arrays.asList(0, 1, 2, 3).contains(apply.getOperate())) {
|
throw new BusinessException("操作类型不正确");
|
}
|
|
this.checkLoginSafeword(operatorUsername, safeword);
|
|
Kyc kyc = this.kycService.get(apply.getPartyId().toString());
|
if (null == kyc || kyc.getStatus() != 2) {
|
throw new BusinessException("认证尚未通过，无法重置");
|
}
|
|
apply.setApply_time(new Date());
|
apply.setStatus(2);
|
|
this.userSafewordApplyService.update(apply);
|
|
Party party = this.partyService.cachePartyBy(apply.getPartyId(), false);
|
|
// 操作类型 operate: 0/修改资金密码；1/取消谷歌绑定；2/取消手机绑定；3/取消邮箱绑定；
|
switch (apply.getOperate()) {
|
case 0:
|
party.setSafeword(apply.getSafeword());
|
this.partyService.update(party);
|
break;
|
case 1:
|
SecUser secUser = this.secUserService.findUserByLoginName(party.getUsername());
|
if (null == secUser) {
|
throw new BusinessException("用户不存在");
|
}
|
if (!secUser.isGoogle_auth_bind()) {
|
throw new BusinessException("用户未绑定，无需解绑");
|
}
|
secUser.setGoogle_auth_bind(false);
|
this.secUserService.update(secUser);
|
break;
|
case 2:
|
party.setPhone_authority(false);
|
this.partyService.update(party);
|
break;
|
case 3:
|
party.setEmail_authority(false);
|
this.partyService.update(party);
|
break;
|
}
|
|
this.tipService.deleteTip(apply.getId().toString());
|
}
|
|
@Override
|
public void saveFailed(String id, String msg) {
|
UserSafewordApply apply = this.userSafewordApplyService.findById(id);
|
|
if (null == apply) {
|
throw new BusinessException("申请不存在，或请刷新重试");
|
}
|
|
if (apply.getStatus() != 1) {
|
throw new BusinessException("当前申请已处理");
|
}
|
|
Kyc kyc = this.kycService.get(apply.getPartyId().toString());
|
if (null == kyc || kyc.getStatus() != 2) {
|
throw new BusinessException("认证尚未通过，无法重置");
|
}
|
|
apply.setApply_time(new Date());
|
apply.setStatus(3);
|
apply.setMsg(msg);
|
|
this.userSafewordApplyService.update(apply);
|
|
this.tipService.deleteTip(apply.getId().toString());
|
}
|
|
/**
|
* 验证登录人资金密码
|
*
|
* @param operatorUsername
|
* @param loginSafeword
|
*/
|
private void checkLoginSafeword(String operatorUsername, String loginSafeword) {
|
SecUser sec = this.secUserService.findUserByLoginName(operatorUsername);
|
String sysSafeword = sec.getSafeword();
|
String safeword_md5 = passwordEncoder.encodePassword(loginSafeword, operatorUsername);
|
if (!safeword_md5.equals(sysSafeword)) {
|
throw new BusinessException("登录人资金密码错误");
|
}
|
|
}
|
|
public void setPartyService(PartyService partyService) {
|
this.partyService = partyService;
|
}
|
|
public void setUserRecomService(UserRecomService userRecomService) {
|
this.userRecomService = userRecomService;
|
}
|
|
public void setKycService(KycService kycService) {
|
this.kycService = kycService;
|
}
|
|
public void setUserSafewordApplyService(UserSafewordApplyService userSafewordApplyService) {
|
this.userSafewordApplyService = userSafewordApplyService;
|
}
|
|
public void setPasswordEncoder(PasswordEncoder passwordEncoder) {
|
this.passwordEncoder = passwordEncoder;
|
}
|
|
public void setSecUserService(SecUserService secUserService) {
|
this.secUserService = secUserService;
|
}
|
|
public void setTipService(TipService tipService) {
|
this.tipService = tipService;
|
}
|
}
|
