package project.user.internal;
|
|
import java.util.Arrays;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.apache.commons.collections.CollectionUtils;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
import org.springframework.security.providers.encoding.PasswordEncoder;
|
|
import kernel.bo.RecordObjectMapper;
|
import kernel.exception.BusinessException;
|
import kernel.util.DateUtils;
|
import kernel.util.StringUtils;
|
import kernel.web.ApplicationUtil;
|
import project.Constants;
|
import project.tip.TipConstants;
|
import project.tip.TipService;
|
import project.user.UserSafewordApply;
|
import project.user.UserSafewordApplyService;
|
import project.user.kyc.Kyc;
|
import project.user.kyc.KycService;
|
import security.SaltSigureUtils;
|
import util.Strings;
|
|
public class UserSafewordApplyServiceImpl implements UserSafewordApplyService {
|
|
private JdbcTemplate jdbcTemplate;
|
private PasswordEncoder passwordEncoder;
|
private KycService kycService;
|
private TipService tipService;
|
|
public void save(UserSafewordApply entity) {
|
Object[] jdbcParams = ApplicationUtil.getInsertStatement(entity);
|
String insertUserSql = (String)jdbcParams[0];
|
Object[] sqlParameters = (Object[])jdbcParams[1];
|
jdbcTemplate.update(insertUserSql, sqlParameters);
|
}
|
|
public void update(UserSafewordApply entity) {
|
Object[] jdbcParams = ApplicationUtil.getUpdateStatement(entity, "WHERE UUID=?", new Object[] {entity.getId()});
|
String updateUserSql = (String)jdbcParams[0];
|
Object[] sqlParameters = (Object[])jdbcParams[1];
|
jdbcTemplate.update(updateUserSql, sqlParameters);
|
}
|
|
public void delete(String id) {
|
UserSafewordApply entity = findById(id);
|
jdbcTemplate.update("DELETE FROM T_USER_SAFEWORD_APPLY WHERE UUID=?", entity.getId());
|
}
|
|
public UserSafewordApply findById(String id) {
|
List<UserSafewordApply> list = jdbcTemplate.query("SELECT * FROM T_USER_SAFEWORD_APPLY WHERE UUID=?",
|
RecordObjectMapper.newInstance(UserSafewordApply.class), id);
|
if (null != list && list.size() > 0) {
|
return list.get(0);
|
}
|
return null;
|
}
|
|
public List<UserSafewordApply> findByPartyId(String partyId) {
|
List<UserSafewordApply> list = jdbcTemplate.query("SELECT * FROM T_USER_SAFEWORD_APPLY WHERE PARTY_ID=? ORDER BY CREATE_TIME DESC ",
|
RecordObjectMapper.newInstance(UserSafewordApply.class), partyId);
|
return list;
|
}
|
|
/**
|
* 尚未通过的申请
|
*/
|
public UserSafewordApply findByPartyIdNoPass(String partyId, Integer operate) {
|
List<UserSafewordApply> list = jdbcTemplate.query("SELECT * FROM T_USER_SAFEWORD_APPLY WHERE PARTY_ID=? AND OPERATE =? AND STATUS = 2 ORDER BY CREATE_TIME DESC ",
|
RecordObjectMapper.newInstance(UserSafewordApply.class), partyId, operate);
|
return CollectionUtils.isEmpty(list) ? null : list.get(0);
|
}
|
|
/**
|
* 人工重置 操作类型 operate: 0/修改资金密码；1/取消谷歌绑定；2/取消手机绑定；3/取消邮箱绑定；
|
*/
|
public void saveApply(String partyId, String idcard_path_front, String idcard_path_back, String idcard_path_hold, String safeword,
|
String safeword_confirm, Integer operate, String remark) {
|
|
if (null == operate || !Arrays.asList(0, 1, 2, 3).contains(operate)) {
|
throw new BusinessException("操作类型不正确");
|
}
|
|
// 操作类型 operate: 0/修改资金密码；
|
if (0 == operate.intValue()) {
|
|
if (StringUtils.isEmptyString(safeword)) {
|
throw new BusinessException("资金密码不能为空");
|
}
|
|
if (safeword.length() != 6 || !Strings.isNumber(safeword)) {
|
throw new BusinessException("资金密码不符合设定");
|
}
|
|
if (StringUtils.isEmptyString(safeword_confirm)) {
|
throw new BusinessException("资金密码确认不能为空");
|
}
|
|
if (!safeword.equals(safeword_confirm)) {
|
throw new BusinessException("两次输入的资金密码不相同");
|
}
|
}
|
|
// if (StringUtils.isEmptyString(idcard_path_front)) {
|
// throw new BusinessException("请上传证件照正面");
|
// }
|
//
|
// if (StringUtils.isEmptyString(idcard_path_back)) {
|
// throw new BusinessException("请上传证件照反面");
|
// }
|
//
|
// if (StringUtils.isEmptyString(idcard_path_hold)) {
|
// throw new BusinessException("请上传手持证件照");
|
// }
|
|
// // 操作类型 operate: 0/修改资金密码；
|
// if (0 == operate.intValue()) {
|
Kyc kyc = this.kycService.get(partyId);
|
if (null == kyc || kyc.getStatus() != 2) {
|
throw new BusinessException(401, "实名认证尚未通过，无法重置");
|
}
|
// }
|
|
UserSafewordApply apply = this.findByPartyIdNoPass(partyId, operate);
|
if (null == apply) {
|
apply = new UserSafewordApply();
|
apply.setCreate_time(new Date());
|
} else if (apply.getStatus() == 0) {
|
throw new BusinessException("您的申请之前已提交过");
|
}
|
|
// 操作类型 operate: 0/修改资金密码；
|
if (0 == operate.intValue()) {
|
String safewordMd5 = this.passwordEncoder.encodePassword(safeword, SaltSigureUtils.saltfigure);
|
apply.setSafeword(safewordMd5);
|
} else {
|
apply.setSafeword("");
|
}
|
|
apply.setIdcard_path_front(idcard_path_front);
|
apply.setIdcard_path_back(idcard_path_back);
|
apply.setIdcard_path_hold(idcard_path_hold);
|
apply.setOperate(operate);
|
apply.setRemark(remark);
|
apply.setPartyId(partyId);
|
apply.setStatus(1);
|
|
if (null == apply.getId()) {
|
this.save(apply);
|
} else {
|
this.update(apply);
|
}
|
|
this.tipService.saveTip(apply.getId().toString(), TipConstants.USER_SAFEWORD_APPLY);
|
}
|
|
public Map<String, Object> bindOne(UserSafewordApply apply) {
|
|
Map<String, Object> result = new HashMap<String, Object>();
|
|
String idcard_path_front_path = "";
|
String idcard_path_back_path = "";
|
String idcard_path_hold_path = "";
|
|
if (!StringUtils.isNullOrEmpty(apply.getIdcard_path_front())) {
|
idcard_path_front_path = Constants.WEB_URL + "/public/showimg!showImg.action?imagePath="
|
+ apply.getIdcard_path_front();
|
}
|
result.put("idcard_path_front", apply.getIdcard_path_front());
|
result.put("idcard_path_front_path", idcard_path_front_path);
|
|
if (!StringUtils.isNullOrEmpty(apply.getIdcard_path_back())) {
|
idcard_path_back_path = Constants.WEB_URL + "/public/showimg!showImg.action?imagePath="
|
+ apply.getIdcard_path_back();
|
}
|
result.put("idcard_path_back", apply.getIdcard_path_back());
|
result.put("idcard_path_back_path", idcard_path_back_path);
|
|
if (!StringUtils.isNullOrEmpty(apply.getIdcard_path_hold())) {
|
idcard_path_hold_path = Constants.WEB_URL + "/public/showimg!showImg.action?imagePath="
|
+ apply.getIdcard_path_hold();
|
} else {
|
idcard_path_hold_path = Constants.WEB_URL + "/public/showimg!showImg.action?imagePath=qr/id_img3.jpg";
|
}
|
result.put("idcard_path_hold", apply.getIdcard_path_hold());
|
result.put("idcard_path_hold_path", idcard_path_hold_path);
|
|
result.put("id", apply.getId());
|
result.put("create_time", DateUtils.format(apply.getCreate_time(), DateUtils.DF_yyyyMMddHHmmss));
|
result.put("msg", apply.getMsg());
|
result.put("apply_time", DateUtils.format(apply.getApply_time(), DateUtils.DF_yyyyMMddHHmmss));
|
result.put("status", apply.getStatus());
|
result.put("operate", apply.getOperate());
|
result.put("remark", apply.getRemark());
|
|
return result;
|
}
|
|
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
|
this.jdbcTemplate = jdbcTemplate;
|
}
|
|
public void setPasswordEncoder(PasswordEncoder passwordEncoder) {
|
this.passwordEncoder = passwordEncoder;
|
}
|
|
public void setKycService(KycService kycService) {
|
this.kycService = kycService;
|
}
|
|
public void setTipService(TipService tipService) {
|
this.tipService = tipService;
|
}
|
|
}
|
