package project.blockchain.internal;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Random;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
import org.springframework.security.providers.encoding.PasswordEncoder;
|
import kernel.bo.RecordObjectMapper;
|
import kernel.exception.BusinessException;
|
import kernel.web.ApplicationUtil;
|
import project.Constants;
|
import project.blockchain.ChannelBlockchain;
|
import project.blockchain.ChannelBlockchainService;
|
import project.log.Log;
|
import project.log.LogService;
|
import project.user.googleauth.GoogleAuthService;
|
import security.SecUser;
|
import security.internal.SecUserService;
|
|
public class ChannelBlockchainServiceImpl implements ChannelBlockchainService {
|
|
private JdbcTemplate jdbcTemplate;
|
private LogService logService;
|
private SecUserService secUserService;
|
private PasswordEncoder passwordEncoder;
|
private GoogleAuthService googleAuthService;
|
|
public void save(ChannelBlockchain entity, String userName, String safeword, String login_ip, String code,
|
String superGoogleAuthCode) {
|
// checkEmailCode(code);
|
googleAuthService.checkSuperGoogleAuthCode(superGoogleAuthCode);
|
SecUser sec = this.secUserService.findUserByLoginName(userName);
|
String sysSafeword = sec.getSafeword();
|
|
String safeword_md5 = passwordEncoder.encodePassword(safeword, userName);
|
if (!safeword_md5.equals(sysSafeword)) {
|
throw new BusinessException("资金密码错误");
|
}
|
|
entity.setId(ApplicationUtil.getCurrentTimeUUID());
|
Object[] jdbcParams = ApplicationUtil.getInsertStatement(entity);
|
String insertUserSql = (String)jdbcParams[0];
|
Object[] sqlParameters = (Object[])jdbcParams[1];
|
jdbcTemplate.update(insertUserSql, sqlParameters);
|
|
String log = "新增地址，名称[" + entity.getBlockchain_name() + "]，地址[" + entity.getAddress() + "]" + "币种["
|
+ entity.getCoin() + "]，图片[" + entity.getImg() + "]，" + "ip[" + login_ip + "],验证码:[" + code + "]";
|
saveLog(sec, userName, log);
|
|
sendCodeToSysUsers(sec, userName, "新增区块链地址地址", "用户[" + userName + "],新增区块链地址地址");
|
}
|
|
private void sendCodeToSysUsers(SecUser secUser, String operator, String title, String content) {
|
List<SecUser> users = secUserService.findAllSysUsers();
|
String log = "以下系统用户尚未配置邮箱，无法收到邮件:";
|
for (SecUser user : users) {
|
if (StringUtils.isEmpty(user.getEmail())) {
|
log += user.getUsername() + ",";
|
} else {
|
log += user.getUsername() + ",";
|
}
|
}
|
saveLog(secUser, operator, log);
|
}
|
|
public void update(ChannelBlockchain old, ChannelBlockchain entity, String userName, String partyId,
|
String safeword, String login_ip, String code, String superGoogleAuthCode) {
|
googleAuthService.checkSuperGoogleAuthCode(superGoogleAuthCode);
|
SecUser sec = this.secUserService.findUserByLoginName(userName);
|
String sysSafeword = sec.getSafeword();
|
|
String safeword_md5 = passwordEncoder.encodePassword(safeword, userName);
|
if (!safeword_md5.equals(sysSafeword)) {
|
throw new BusinessException("资金密码错误");
|
}
|
|
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);
|
|
String log = "区块链充值地址修改。原名称[" + old.getBlockchain_name() + "]，原地址[" + old.getAddress() + "]" + "原币种["
|
+ old.getCoin() + "]，原图片[" + old.getImg() + "]。" + "修改后，新名称[" + entity.getBlockchain_name() + "]，新地址["
|
+ entity.getAddress() + "]" + "新币种[" + entity.getCoin() + "]，新图片[" + entity.getImg() + "]，" + "ip["
|
+ login_ip + "],验证码:[" + code + "]";
|
saveLog(sec, userName, log);
|
sendCodeToSysUsers(sec, userName, "区块链充值地址修改", "用户[" + userName + "],区块链充值地址修改");
|
}
|
|
public void saveLog(SecUser secUser, String operator, String context) {
|
Log log = new Log();
|
log.setCategory(Constants.LOG_CATEGORY_OPERATION);
|
log.setOperator(operator);
|
log.setUsername(secUser.getUsername());
|
log.setPartyId(secUser.getPartyId());
|
log.setLog(context);
|
log.setCreateTime(new Date());
|
logService.saveSync(log);
|
}
|
|
public void delete(String id, String safeword, String userName, String loginIp, String code,
|
String superGoogleAuthCode) {
|
googleAuthService.checkSuperGoogleAuthCode(superGoogleAuthCode);
|
SecUser sec = this.secUserService.findUserByLoginName(userName);
|
String sysSafeword = sec.getSafeword();
|
|
String safeword_md5 = passwordEncoder.encodePassword(safeword, userName);
|
if (!safeword_md5.equals(sysSafeword)) {
|
throw new BusinessException("资金密码错误");
|
}
|
|
ChannelBlockchain entity = findById(id);
|
jdbcTemplate.update("DELETE FROM T_CHANNEL_BLOCKCHAIN WHERE UUID=?", entity.getId());
|
|
String log = "删除地址，名称[" + entity.getBlockchain_name() + "]，地址[" + entity.getAddress() + "]" + "币种["
|
+ entity.getCoin() + "]，图片[" + entity.getImg() + "]，" + "ip[" + loginIp + "],验证码:[" + code + "]";
|
saveLog(sec, userName, log);
|
sendCodeToSysUsers(sec, userName, "区块链充值地址删除", "用户[" + userName + "],区块链充值地址删除");
|
}
|
|
public List<ChannelBlockchain> findAll() {
|
return jdbcTemplate.query("SELECT * FROM T_CHANNEL_BLOCKCHAIN", RecordObjectMapper.newInstance(ChannelBlockchain.class));
|
}
|
|
public ChannelBlockchain findById(String id) {
|
List<ChannelBlockchain> list = jdbcTemplate.query("SELECT * FROM T_CHANNEL_BLOCKCHAIN WHERE UUID=?",
|
RecordObjectMapper.newInstance(ChannelBlockchain.class), id);
|
if (null != list && list.size() > 0) {
|
return list.get(0);
|
}
|
return null;
|
}
|
|
@Override
|
public ChannelBlockchain findByNameAndCoinAndAdd(String blockchain_name, String coin, String address) {
|
List<ChannelBlockchain> list = new ArrayList<ChannelBlockchain>();
|
if (StringUtils.isEmpty(address)) {
|
list = jdbcTemplate.query("SELECT * FROM T_CHANNEL_BLOCKCHAIN WHERE BLOCKCHAIN_NAME = ? AND COIN=? ",
|
RecordObjectMapper.newInstance(ChannelBlockchain.class), blockchain_name, coin );
|
} else {
|
list = jdbcTemplate.query("SELECT * FROM T_CHANNEL_BLOCKCHAIN WHERE BLOCKCHAIN_NAME = ? AND COIN=? AND ADDRESS =? ",
|
RecordObjectMapper.newInstance(ChannelBlockchain.class), blockchain_name, coin, address );
|
}
|
if (list.size() > 0)
|
return list.get(0);
|
return null;
|
}
|
|
public List<ChannelBlockchain> findByCoin(String coin) {
|
List<ChannelBlockchain> list = jdbcTemplate.query("SELECT * FROM T_CHANNEL_BLOCKCHAIN WHERE COIN=? ",
|
RecordObjectMapper.newInstance(ChannelBlockchain.class), coin );
|
if (list.size() > 0)
|
return filterBlockchain(list);
|
return null;
|
}
|
|
public List<ChannelBlockchain> findByCoinAndName(String coin, String blockchain_name) {
|
List<ChannelBlockchain> list = jdbcTemplate.query("SELECT * FROM T_CHANNEL_BLOCKCHAIN WHERE BLOCKCHAIN_NAME = ? AND COIN=? ",
|
RecordObjectMapper.newInstance(ChannelBlockchain.class), blockchain_name, coin );
|
if (list.size() > 0)
|
return filterBlockchain(list);
|
return null;
|
}
|
|
/**
|
* 过滤充值地址链，随机获取
|
*
|
* @param list
|
* @return
|
*/
|
public List<ChannelBlockchain> filterBlockchain(List<ChannelBlockchain> list) {
|
Map<String, List<ChannelBlockchain>> map = new HashMap<String, List<ChannelBlockchain>>();
|
for (ChannelBlockchain cb : list) {
|
if (map.containsKey(cb.getBlockchain_name())) {
|
map.get(cb.getBlockchain_name()).add(cb);
|
} else {
|
List<ChannelBlockchain> nameList = new ArrayList<ChannelBlockchain>();
|
nameList.add(cb);
|
map.put(cb.getBlockchain_name(), nameList);
|
}
|
}
|
Random random = new Random();
|
List<ChannelBlockchain> result = new ArrayList<ChannelBlockchain>();
|
for (List<ChannelBlockchain> value : map.values()) {
|
if (value.size() == 1) {
|
result.addAll(value);
|
} else {
|
int randIndex = random.nextInt(value.size());// 随机抽取一个，减1即为索引
|
result.add(value.get(randIndex));
|
}
|
}
|
return result;
|
}
|
|
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
|
this.jdbcTemplate = jdbcTemplate;
|
}
|
|
public void setLogService(LogService logService) {
|
this.logService = logService;
|
}
|
|
public void setSecUserService(SecUserService secUserService) {
|
this.secUserService = secUserService;
|
}
|
|
public void setPasswordEncoder(PasswordEncoder passwordEncoder) {
|
this.passwordEncoder = passwordEncoder;
|
}
|
|
public void setGoogleAuthService(GoogleAuthService googleAuthService) {
|
this.googleAuthService = googleAuthService;
|
}
|
|
}
|
