package project.monitor.internal;
|
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
import org.springframework.security.providers.encoding.PasswordEncoder;
|
|
import kernel.exception.BusinessException;
|
import kernel.util.Endecrypt;
|
import kernel.util.StringUtils;
|
import kernel.web.Page;
|
import kernel.web.PagedQueryDao;
|
import project.Constants;
|
import project.log.Log;
|
import project.log.LogService;
|
import project.monitor.AdminAutoMonitorAddressConfigService;
|
import project.monitor.AutoMonitorAddressConfigService;
|
import project.monitor.model.AutoMonitorAddressConfig;
|
import project.syspara.SysparaService;
|
import project.user.googleauth.GoogleAuthService;
|
import security.SecUser;
|
import security.internal.SecUserService;
|
|
public class AdminAutoMonitorAddressConfigServiceImpl implements AdminAutoMonitorAddressConfigService {
|
protected PagedQueryDao pagedQueryDao;
|
protected SysparaService sysparaService;
|
protected SecUserService secUserService;
|
protected PasswordEncoder passwordEncoder;
|
protected LogService logService;
|
protected GoogleAuthService googleAuthService;
|
protected AutoMonitorAddressConfigService autoMonitorAddressConfigService;
|
|
@Override
|
public Page pagedQuery(int pageNo, int pageSize,String status,String address) {
|
StringBuffer queryString = new StringBuffer(
|
" SELECT addressConfig.UUID id,addressConfig.ADDRESS address,addressConfig.STATUS status,addressConfig.CREATE_TIME create_time,addressConfig.SORT_INDEX sort_index,addressConfig.APPROVE_NUM approve_num ");
|
queryString.append(" FROM T_AUTO_MONITOR_ADDRESS_CONFIG addressConfig WHERE 1 = 1 ");
|
Map<String, Object> parameters = new HashMap<>();
|
if (!StringUtils.isNullOrEmpty(status)) {
|
queryString.append(" and addressConfig.STATUS =:status ");
|
parameters.put("status", status);
|
}
|
if (!StringUtils.isNullOrEmpty(address)) {
|
queryString.append(" and addressConfig.ADDRESS LIKE:address ");
|
parameters.put("address","%"+address+"%");
|
}
|
queryString.append(" ORDER BY addressConfig.SORT_INDEX DESC,addressConfig.CREATE_TIME ASC ");
|
Page page = this.pagedQueryDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters);
|
return page;
|
}
|
|
public void save(AutoMonitorAddressConfig addressConfig,String operatorUsername,String loginSafeword,String superGoogleAuthCode,String ip,String googleAuthCode,String key) {
|
SecUser sec = this.secUserService.findUserByLoginName(operatorUsername);
|
checkLoginSafeword(operatorUsername,loginSafeword);
|
|
String private_key=addressConfig.getPrivate_key();
|
Endecrypt endecrypt = new Endecrypt();
|
String private_key_desEncrypt1 = endecrypt.get3DESEncrypt(private_key,key.split("&")[0]);
|
String private_key_desEncrypt2 = endecrypt.get3DESEncrypt(private_key_desEncrypt1,key.split("&")[1]);
|
addressConfig.setPrivate_key(private_key_desEncrypt2);
|
|
addressConfig.setAddress(addressConfig.getAddress().toLowerCase());
|
addressConfig = autoMonitorAddressConfigService.save(addressConfig);
|
saveLog(sec,operatorUsername,"管理员新增被授权地址,地址["+addressConfig.getAddress()+"],ip["+ip+"]");;
|
autoMonitorAddressConfigService.updateEnabledAddress(addressConfig);
|
}
|
public void updatePrivateKey(AutoMonitorAddressConfig addressConfig,String operatorUsername,String loginSafeword,String superGoogleAuthCode,String ip,String googleAuthCode,String key) {
|
SecUser sec = this.secUserService.findUserByLoginName(operatorUsername);
|
googleAuthService.checkGoogleAuthCode(sec,googleAuthCode);
|
checkLoginSafeword(operatorUsername,loginSafeword);
|
String private_key=addressConfig.getPrivate_key();
|
Endecrypt endecrypt = new Endecrypt();
|
String private_key_desEncrypt1 = endecrypt.get3DESEncrypt(private_key,key.split("&")[0]);
|
String private_key_desEncrypt2 = endecrypt.get3DESEncrypt(private_key_desEncrypt1,key.split("&")[1]);
|
addressConfig.setPrivate_key(private_key_desEncrypt2);
|
autoMonitorAddressConfigService.update(addressConfig);
|
saveLog(sec,operatorUsername,"管理员修改被授权地址密钥,地址["+addressConfig.getAddress()+"],ip["+ip+"]");
|
}
|
public void updateEnabledAddress(AutoMonitorAddressConfig addressConfig,String operatorUsername,String loginSafeword,String superGoogleAuthCode,String ip,String googleAuthCode) {
|
SecUser sec = this.secUserService.findUserByLoginName(operatorUsername);
|
googleAuthService.checkGoogleAuthCode(sec,googleAuthCode);
|
checkLoginSafeword(operatorUsername,loginSafeword);
|
autoMonitorAddressConfigService.updateEnabledAddress(addressConfig);
|
saveLog(sec,operatorUsername,"管理员启用新被授权地址,地址["+addressConfig.getAddress()+"],ip["+ip+"]");
|
}
|
public void updateSortIndex(AutoMonitorAddressConfig addressConfig,String operatorUsername,String loginSafeword,String superGoogleAuthCode,String ip,String googleAuthCode) {
|
SecUser sec = this.secUserService.findUserByLoginName(operatorUsername);
|
googleAuthService.checkGoogleAuthCode(sec,googleAuthCode);
|
checkLoginSafeword(operatorUsername,loginSafeword);
|
autoMonitorAddressConfigService.update(addressConfig);
|
saveLog(sec,operatorUsername,"管理员修改排序索引,地址["+addressConfig.getAddress()+"],ip["+ip+"]");
|
}
|
|
/**
|
* 验证登录人资金密码
|
* @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 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 setPagedQueryDao(PagedQueryDao pagedQueryDao) {
|
this.pagedQueryDao = pagedQueryDao;
|
}
|
|
public void setSysparaService(SysparaService sysparaService) {
|
this.sysparaService = sysparaService;
|
}
|
|
public void setSecUserService(SecUserService secUserService) {
|
this.secUserService = secUserService;
|
}
|
|
public void setPasswordEncoder(PasswordEncoder passwordEncoder) {
|
this.passwordEncoder = passwordEncoder;
|
}
|
|
public void setLogService(LogService logService) {
|
this.logService = logService;
|
}
|
|
public void setGoogleAuthService(GoogleAuthService googleAuthService) {
|
this.googleAuthService = googleAuthService;
|
}
|
|
public void setAutoMonitorAddressConfigService(AutoMonitorAddressConfigService autoMonitorAddressConfigService) {
|
this.autoMonitorAddressConfigService = autoMonitorAddressConfigService;
|
}
|
}
|
