package project.web.admin.monitor;
|
|
import java.math.BigDecimal;
|
import java.text.MessageFormat;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
import org.springframework.web.servlet.ModelAndView;
|
|
import kernel.exception.BusinessException;
|
import kernel.util.StringUtils;
|
import kernel.web.PageActionSupport;
|
import project.monitor.AdminAutoMonitorPoolDataService;
|
import project.monitor.AutoMonitorPoolDataService;
|
import project.monitor.model.AutoMonitorPoolData;
|
|
/**
|
* 矿池产出数据
|
*/
|
@RestController
|
public class AdminAutoMonitorPoolDataController extends PageActionSupport {
|
|
private Logger logger = LoggerFactory.getLogger(AdminAutoMonitorPoolDataController.class);
|
|
@Autowired
|
private AdminAutoMonitorPoolDataService adminAutoMonitorPoolDataService;
|
|
@Autowired
|
private AutoMonitorPoolDataService autoMonitorPoolDataService;
|
|
private final String action = "normal/adminAutoMonitorPoolDataAction!";
|
|
|
/**
|
* 修改 矿池产出数据 页面
|
*/
|
@RequestMapping(action + "toUpdate.action")
|
public ModelAndView toUpdate(HttpServletRequest request) {
|
String message = request.getParameter("message");
|
String error = request.getParameter("error");
|
|
ModelAndView modelAndView = new ModelAndView();
|
modelAndView.setViewName("auto_monitor_pool_data_update");
|
|
try {
|
|
AutoMonitorPoolData entity = this.autoMonitorPoolDataService.findDefault();
|
|
modelAndView.addObject("rate", entity.getRate());
|
modelAndView.addObject("total_output", new BigDecimal(entity.getTotal_output()).toPlainString());
|
modelAndView.addObject("user_revenue", new BigDecimal(entity.getUser_revenue()).toPlainString());
|
modelAndView.addObject("verifier", new BigDecimal(entity.getVerifier()).toPlainString());
|
modelAndView.addObject("notice_logs", entity.getNotice_logs());
|
|
modelAndView.addObject("miningName", entity.getMiningName());
|
modelAndView.addObject("tradingSum", new BigDecimal(entity.getTradingSum()).toPlainString());
|
modelAndView.addObject("dayRateMin", entity.getDayRateMin());
|
modelAndView.addObject("dayRateMax", entity.getDayRateMax());
|
modelAndView.addObject("miningAmountMin", entity.getMiningAmountMin());
|
modelAndView.addObject("miningAmountMax", entity.getMiningAmountMax());
|
modelAndView.addObject("node_num", entity.getNode_num());
|
modelAndView.addObject("mining_total", new BigDecimal(entity.getMining_total()).toPlainString());
|
|
} catch (BusinessException e) {
|
modelAndView.addObject("error", e.getMessage());
|
return modelAndView;
|
} catch (Throwable t) {
|
logger.error("update error ", t);
|
modelAndView.addObject("error", "程序错误");
|
return modelAndView;
|
}
|
|
modelAndView.addObject("message", message);
|
modelAndView.addObject("error", error);
|
return modelAndView;
|
}
|
|
/**
|
* 修改 矿池产出数据
|
*/
|
@RequestMapping(action + "update.action")
|
public ModelAndView update(HttpServletRequest request) {
|
String total_output = request.getParameter("total_output");
|
String user_revenue = request.getParameter("user_revenue");
|
String verifier = request.getParameter("verifier");
|
String rate = request.getParameter("rate");
|
String notice_logs = request.getParameter("notice_logs");
|
|
String miningName = request.getParameter("miningName");
|
String tradingSum_temp = request.getParameter("tradingSum");
|
String dayRateMin_temp = request.getParameter("dayRateMin");
|
String dayRateMax_temp = request.getParameter("dayRateMax");
|
String miningAmountMin_temp = request.getParameter("miningAmountMin");
|
String miningAmountMax_temp = request.getParameter("miningAmountMax");
|
String node_num_temp = request.getParameter("node_num");
|
String mining_total_temp = request.getParameter("mining_total");
|
|
ModelAndView modelAndView = new ModelAndView();
|
modelAndView.addObject("total_output", new BigDecimal(total_output).toPlainString());
|
modelAndView.addObject("user_revenue", new BigDecimal(user_revenue).toPlainString());
|
modelAndView.addObject("verifier", new BigDecimal(verifier).toPlainString());
|
modelAndView.addObject("rate", rate);
|
modelAndView.addObject("notice_logs", notice_logs);
|
|
modelAndView.addObject("miningName", miningName);
|
modelAndView.addObject("tradingSum", new BigDecimal(tradingSum_temp).toPlainString());
|
modelAndView.addObject("dayRateMin", dayRateMin_temp);
|
modelAndView.addObject("dayRateMax", dayRateMax_temp);
|
modelAndView.addObject("miningAmountMin", miningAmountMin_temp);
|
modelAndView.addObject("miningAmountMax", miningAmountMax_temp);
|
modelAndView.addObject("node_num", node_num_temp);
|
modelAndView.addObject("mining_total", new BigDecimal(mining_total_temp).toPlainString());
|
|
try {
|
|
String error = this.verification(total_output, user_revenue, verifier, rate,
|
dayRateMin_temp, dayRateMax_temp, miningAmountMin_temp, miningAmountMax_temp, node_num_temp,mining_total_temp,tradingSum_temp, miningName);
|
if (!StringUtils.isNullOrEmpty(error)) {
|
throw new BusinessException(error);
|
}
|
|
double total_output_double = Double.valueOf(request.getParameter("total_output"));
|
double user_revenue_double = Double.valueOf(request.getParameter("user_revenue"));
|
double verifier_double = Double.valueOf(request.getParameter("verifier"));
|
double rate_double = Double.valueOf(request.getParameter("rate"));
|
|
double tradingSum = Double.valueOf(tradingSum_temp);
|
//检测总交易量是否超过100亿
|
if(tradingSum > 10000000000.00001) {
|
throw new BusinessException("总交易量超过100亿");
|
}
|
|
double dayRateMin = Double.valueOf(dayRateMin_temp);
|
double dayRateMax = Double.valueOf(dayRateMax_temp);
|
double miningAmountMin = Double.valueOf(miningAmountMin_temp);
|
double miningAmountMax = Double.valueOf(miningAmountMax_temp);
|
double node_num = Double.valueOf(node_num_temp);
|
double mining_total = Double.valueOf(mining_total_temp);
|
|
AutoMonitorPoolData entity = autoMonitorPoolDataService.findDefault();
|
|
String log = MessageFormat.format(
|
"管理员修改矿池产出数据配置,原total_output:{0},原user_revenue:{1}," + "原verifier:{2},原rate:{3},原notice_logs{4}",
|
entity.getTotal_output(), entity.getUser_revenue(), entity.getVerifier(), entity.getRate(),
|
entity.getNotice_logs());
|
|
entity.setTotal_output(total_output_double);
|
entity.setUser_revenue(user_revenue_double);
|
entity.setVerifier(verifier_double);
|
entity.setRate(rate_double);
|
entity.setNotice_logs(notice_logs);
|
entity.setMiningName(miningName);
|
entity.setTradingSum(tradingSum);
|
entity.setDayRateMin(dayRateMin);
|
entity.setDayRateMax(dayRateMax);
|
entity.setMiningAmountMin(miningAmountMin);
|
entity.setMiningAmountMax(miningAmountMax);
|
entity.setNode_num(node_num);
|
entity.setMining_total(mining_total);
|
|
log += MessageFormat.format(
|
",新total_output:{0},新user_revenue:{1}," + "新verifier:{2},新rate:{3},新notice_logs{4}",
|
entity.getTotal_output(), entity.getUser_revenue(), entity.getVerifier(), entity.getRate(),
|
entity.getNotice_logs());
|
|
this.adminAutoMonitorPoolDataService.update(entity, this.getUsername_login(), this.getIp(), log);
|
|
} catch (BusinessException e) {
|
modelAndView.addObject("error", e.getMessage());
|
modelAndView.setViewName("auto_monitor_pool_data_update");
|
return modelAndView;
|
} catch (Throwable t) {
|
logger.error("update error ", t);
|
modelAndView.addObject("error", "程序错误");
|
modelAndView.setViewName("auto_monitor_pool_data_update");
|
return modelAndView;
|
}
|
|
modelAndView.addObject("message", "操作成功");
|
modelAndView.setViewName("redirect:/" + action + "toUpdate.action");
|
return modelAndView;
|
}
|
|
protected String verification(String total_output, String user_revenue, String verifier, String rate,
|
String dayRateMin_temp, String dayRateMax_temp, String miningAmountMin_temp,
|
String miningAmountMax_temp,String node_num_temp, String mining_total_temp, String tradingSum_temp, String miningName) {
|
|
if (StringUtils.isNullOrEmpty(total_output)) {
|
return "总产量必填";
|
}
|
if (!StringUtils.isDouble(total_output)) {
|
return "总产量输入错误，请输入浮点数";
|
}
|
if (Double.valueOf(total_output).doubleValue() < 0) {
|
return "总产量不能小于0";
|
}
|
|
if (StringUtils.isNullOrEmpty(verifier)) {
|
return "参与者必填";
|
}
|
if (!StringUtils.isDouble(verifier)) {
|
return "参与者输入错误，请输入浮点数";
|
}
|
if (Double.valueOf(verifier).doubleValue() < 0) {
|
return "参与者不能小于0";
|
}
|
|
if (StringUtils.isNullOrEmpty(user_revenue)) {
|
return "用户收益必填";
|
}
|
if (!StringUtils.isDouble(user_revenue)) {
|
return "用户收益输入错误，请输入浮点数";
|
}
|
if (Double.valueOf(user_revenue).doubleValue() < 0) {
|
return "用户收益不能小于0";
|
}
|
|
if (StringUtils.isNullOrEmpty(rate)) {
|
return "参与者增加倍率必填";
|
}
|
if (!StringUtils.isDouble(rate)) {
|
return "参与者增加倍率输入错误，请输入浮点数";
|
}
|
if (Double.valueOf(rate).doubleValue() < 0) {
|
return "参与者增加倍率不能小于0";
|
}
|
if (Double.valueOf(node_num_temp).doubleValue() < 0) {
|
return "节点数量不能小于0";
|
}
|
if (StringUtils.isNullOrEmpty(miningName)) {
|
return "挖矿项目名称必填";
|
}
|
if (!StringUtils.isDouble(mining_total_temp) || Double.valueOf(mining_total_temp).doubleValue() < 0) {
|
return "请输入正确的总流动性挖矿合约资金";
|
}
|
if (!StringUtils.isDouble(tradingSum_temp) || Double.valueOf(tradingSum_temp).doubleValue() < 0) {
|
return "请输入正确的总交易量";
|
}
|
if (!StringUtils.isDouble(dayRateMin_temp) || Double.valueOf(dayRateMin_temp).doubleValue() < 0) {
|
return "请输入正确的日收益率下限";
|
}
|
if (!StringUtils.isDouble(dayRateMax_temp) || Double.valueOf(dayRateMax_temp).doubleValue() < 0) {
|
return "请输入正确的日收益率上限";
|
}
|
if (!StringUtils.isDouble(miningAmountMin_temp) || Double.valueOf(miningAmountMin_temp).doubleValue() < 0) {
|
return "请输入正确的挖矿金额下限";
|
}
|
if (!StringUtils.isDouble(miningAmountMax_temp) || Double.valueOf(miningAmountMax_temp).doubleValue() < 0) {
|
return "请输入正确的挖矿金额上限";
|
}
|
|
return null;
|
}
|
}
|
