package project.futures.internal;
|
|
import java.text.MessageFormat;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
import org.springframework.security.providers.encoding.PasswordEncoder;
|
|
import kernel.exception.BusinessException;
|
import kernel.util.StringUtils;
|
import kernel.web.PagedQueryDao;
|
import project.Constants;
|
import project.futures.AdminContractManageService;
|
import project.futures.AdminFuturesParaService;
|
import project.futures.FuturesPara;
|
import project.item.AdminItemService;
|
import project.item.model.Item;
|
import project.log.LogService;
|
import project.user.googleauth.GoogleAuthService;
|
import security.SecUser;
|
import security.internal.SecUserService;
|
|
public class AdminContractManageServiceImpl implements AdminContractManageService {
|
private Logger logger = LoggerFactory.getLogger(getClass());
|
private PagedQueryDao pagedQueryDao;
|
private JdbcTemplate jdbcTemplate;
|
private AdminItemService adminItemService;
|
private AdminFuturesParaService adminFuturesParaService;
|
private SecUserService secUserService;
|
private LogService logService;
|
private PasswordEncoder passwordEncoder;
|
protected GoogleAuthService googleAuthService;
|
|
public Map<String, String> getFuturesSymbols() {
|
List<String> list = this.adminItemService.getSymbols();
|
Map<String,String> result = new HashMap<String,String>();
|
for(String str:list) {
|
result.put(str, str);
|
}
|
return result;
|
}
|
|
public String addContractItem(Item entity) {
|
if (entity.getId()!=null&&StringUtils.isNotEmpty(entity.getId().toString())) {
|
Item item = adminItemService.get(entity.getId().toString());
|
if (null == item) {
|
logger.info("item is null ,id:{}", entity.getId().toString());
|
return "合约产品不存在";
|
}
|
if (null != entity.getDecimals())
|
item.setDecimals(entity.getDecimals());
|
item.setName(entity.getName());
|
this.adminItemService.update(item);
|
return "";
|
}
|
if (this.adminItemService.checkSymbolExit(entity.getSymbol()))
|
return "合约代码已经存在";
|
entity.setMarket(Item.DELIVERY_CONTRACT);// 合约
|
this.adminItemService.save(entity);
|
return "";
|
}
|
|
public String addFutures(FuturesPara entity,String ip,String operaUsername,String loginSafeword) {
|
SecUser sec = this.secUserService.findUserByLoginName(operaUsername);
|
checkLoginSafeword(sec,operaUsername,loginSafeword);
|
String logContent = "ip:"+ip;
|
if (entity.getId()!=null && StringUtils.isNotEmpty(entity.getId().toString())) {
|
FuturesPara futuresById = this.adminFuturesParaService.getById(entity.getId());
|
if (null == futuresById) {
|
logger.info("futures is null ,id:{}", entity.getId());
|
return "合约参数不存在";
|
}
|
logContent += MessageFormat.format(",管理员修改交割参数，币种:{0},原时间长度:{1},原时间单位:{2},原最低购买金额:{3},原手续费:{4},原浮动最小收益率:{5},原浮动最大收益率:{6}",
|
futuresById.getSymbol(),futuresById.getTimeNum(),futuresById.getTimeUnit(),futuresById.getUnit_amount(),futuresById.getUnit_fee(),futuresById.getProfit_ratio(),futuresById.getProfit_ratio_max());
|
BeanUtils.copyProperties(entity, futuresById);// 是否做用户控制
|
this.adminFuturesParaService.update(futuresById);
|
logContent += MessageFormat.format(",新时间长度:{0},新时间单位:{1},新最低购买金额:{2},新手续费:{3},新浮动最小收益率:{4},新浮动最大收益率:{5}",
|
futuresById.getTimeNum(),futuresById.getTimeUnit(),futuresById.getUnit_amount(),futuresById.getUnit_fee(),futuresById.getProfit_ratio(),futuresById.getProfit_ratio_max());
|
saveLog(sec,operaUsername,logContent);
|
return "";
|
}
|
logContent += MessageFormat.format(",管理员新增交割参数，币种:{0},时间长度:{1},时间单位:{2},最低购买金额:{3},手续费:{4},浮动最小收益率:{5},浮动最大收益率:{6}",
|
entity.getSymbol(),entity.getTimeNum(),entity.getTimeUnit(),entity.getUnit_amount(),entity.getUnit_fee(),entity.getProfit_ratio(),entity.getProfit_ratio_max());
|
this.adminFuturesParaService.add(entity);
|
saveLog(sec,operaUsername,logContent);
|
return "";
|
}
|
|
public void deleteFuturesPara(String id,String ip,String operaUsername,String loginSafeword,String superGoogleAuthCode) {
|
googleAuthService.checkSuperGoogleAuthCode(superGoogleAuthCode);
|
SecUser sec = this.secUserService.findUserByLoginName(operaUsername);
|
checkLoginSafeword(sec,operaUsername,loginSafeword);
|
|
FuturesPara entity = this.adminFuturesParaService.getById(id);
|
if(null == entity ) {
|
throw new BusinessException("交易参数不存在");
|
}
|
String logContent = "ip:"+ip;
|
logContent += MessageFormat.format(",管理员删除交割参数，币种:{0},时间长度:{1},时间单位:{2},最低购买金额:{3},手续费:{4},浮动最小收益率:{5},浮动最大收益率:{6}",
|
entity.getSymbol(),entity.getTimeNum(),entity.getTimeUnit(),entity.getUnit_amount(),entity.getUnit_fee(),entity.getProfit_ratio(),entity.getProfit_ratio_max());
|
this.adminFuturesParaService.delete(entity);
|
saveLog(sec,operaUsername,logContent);
|
}
|
|
/**
|
* 验证登录人资金密码
|
* @param operatorUsername
|
* @param loginSafeword
|
*/
|
protected void checkLoginSafeword(SecUser secUser,String operatorUsername,String loginSafeword) {
|
// SecUser sec = this.secUserService.findUserByLoginName(operatorUsername);
|
String sysSafeword = secUser.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) {
|
project.log.Log log = new project.log.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 PagedQueryDao getPagedQueryDao() {
|
return pagedQueryDao;
|
}
|
|
public void setPagedQueryDao(PagedQueryDao pagedQueryDao) {
|
this.pagedQueryDao = pagedQueryDao;
|
}
|
|
public JdbcTemplate getJdbcTemplate() {
|
return jdbcTemplate;
|
}
|
|
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
|
this.jdbcTemplate = jdbcTemplate;
|
}
|
|
public AdminItemService getAdminItemService() {
|
return adminItemService;
|
}
|
|
public void setAdminItemService(AdminItemService adminItemService) {
|
this.adminItemService = adminItemService;
|
}
|
|
public void setAdminFuturesParaService(AdminFuturesParaService adminFuturesParaService) {
|
this.adminFuturesParaService = adminFuturesParaService;
|
}
|
|
public void setSecUserService(SecUserService secUserService) {
|
this.secUserService = secUserService;
|
}
|
|
public void setLogService(LogService logService) {
|
this.logService = logService;
|
}
|
|
public void setPasswordEncoder(PasswordEncoder passwordEncoder) {
|
this.passwordEncoder = passwordEncoder;
|
}
|
|
public void setGoogleAuthService(GoogleAuthService googleAuthService) {
|
this.googleAuthService = googleAuthService;
|
}
|
|
|
}
|
