package project.web.admin;

import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.providers.encoding.PasswordEncoder;
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.Page;
import kernel.web.PageActionSupport;
import project.Constants;
import project.log.LogService;
import project.miner.AdminMinerService;
import project.miner.MinerService;
import project.miner.model.Miner;
import project.party.PartyService;
import security.SecUser;
import security.internal.SecUserService;

/**
 * 矿机配置
 */
@RestController
public class AdminMinerController extends PageActionSupport {

	private Logger logger = LoggerFactory.getLogger(AdminMinerController.class);

	@Autowired
	protected AdminMinerService adminMinerService;
	@Autowired
	protected MinerService minerService;
	@Autowired
	protected PartyService partyService;
	@Autowired
	protected LogService logService;
	@Autowired
	protected SecUserService secUserService;
	@Autowired
	protected PasswordEncoder passwordEncoder;
	
	private final String action = "normal/adminMinerAction!";
	
	/**
	 * 获取 矿机配置 列表
	 */
	@RequestMapping(action + "list.action")
	public ModelAndView list(HttpServletRequest request) {
		int pageNo=checkAndSetPageNo(request.getParameter("pageNo"));
		String name_para = request.getParameter("name_para");
		String message = request.getParameter("message");
		String error = request.getParameter("error");
		Page page = this.adminMinerService.pagedQuery(pageNo, 300, name_para);
		for(Map<String,Object> data:(List<Map<String,Object>>) (page.getElements())) {
			if("N".equals(data.get("test"))) {
				data.put("cycle", null);
			}
		}
		ModelAndView model = new ModelAndView();
		model.addObject("pageNo", pageNo);
		model.addObject("pageSize", 300);
		model.addObject("page", page);
		model.addObject("name_para", name_para);
		model.addObject("message", message);
		model.addObject("error", error);
		model.setViewName("miner_list");
		return model;
	}

	public String toAdd() {
		return "add";
	}
	
	/**
	 * 验证基础信息
	 */
	protected String verifBase(String algorithm, String computing_power, String power, String product_factory,
			String product_size, String weight, String work_temperature_min, String work_temperature_max, String work_humidity_min,
			String work_humidity_max, String internet) {
		if (StringUtils.isEmptyString(algorithm)) {
			return "请选择适用算法";
		}
			
		if (StringUtils.isNullOrEmpty(computing_power) 
				|| !StringUtils.isDouble(computing_power)
				|| Double.valueOf(computing_power) < 0) {
			return "额定算力不能小于0";
		}
		
		if (StringUtils.isNullOrEmpty(power) 
				|| !StringUtils.isDouble(power)
				|| Double.valueOf(power) < 0) {
			return "功耗不能小于0";
		}
		
		if (StringUtils.isNullOrEmpty(product_factory)) {
			return "请输入生产厂家";
		}
			
		if (StringUtils.isNullOrEmpty(product_size)) {
			return "请输入外箱尺寸";
		}
		
		if (StringUtils.isNullOrEmpty(weight) 
				|| !StringUtils.isDouble(weight)
				|| Double.valueOf(weight) < 0) {
			return "整机重量不能小于0";
		}
		
		if (StringUtils.isNullOrEmpty(work_temperature_min) 
				|| !StringUtils.isDouble(work_temperature_min)) {
			return "工作温度区间最小值错误";
		}
		
		if (StringUtils.isNullOrEmpty(work_temperature_max) 
				|| !StringUtils.isDouble(work_temperature_max)
				|| Double.valueOf(work_temperature_max) == 0) {
			return "工作温度区间最大值错误";
		}
		
		if (Double.valueOf(work_temperature_max) <= Double.valueOf(work_temperature_min)) {
			return "工作温度区间错误";
		}
		
		if (StringUtils.isNullOrEmpty(work_humidity_min) 
				|| !StringUtils.isDouble(work_humidity_min)
				|| Double.valueOf(work_humidity_min) < 0) {
			return "工作湿度区间不能小于0";
		}
		
		if (StringUtils.isNullOrEmpty(work_humidity_max) 
				|| !StringUtils.isDouble(work_humidity_max)
				|| Double.valueOf(work_humidity_max) == 0) {
			return "工作温度区间最大值错误";
		}
		
		if (StringUtils.isNullOrEmpty(work_humidity_max) 
				|| !StringUtils.isDouble(work_humidity_max)
				|| Double.valueOf(work_humidity_max) == 0) {
			return "工作温度区间最大值错误";
		}
		
		if (Double.valueOf(work_humidity_max) <= Double.valueOf(work_humidity_min)) {
			return "工作温度区间错误";
		}
		
		if (StringUtils.isEmptyString(internet)) {
			return "请选择网络连接";
		}
			
		return null;
	}
	protected String verification(String name, String show_daily_rate, String daily_rate, String cycle_close, String investment_min, String investment_max,
			String algorithm, String computing_power, String power, String product_factory,
			String product_size, String weight, String work_temperature_min, String work_temperature_max, String work_humidity_min,
			String work_humidity_max, String internet) {
		
		String verifBase = verifBase(algorithm, computing_power, power, product_factory,
				product_size, weight, work_temperature_min, work_temperature_max, work_humidity_min,
				work_humidity_max, internet);
		
		if(StringUtils.isNotEmpty(verifBase)) {
			return verifBase;
		}
		if (StringUtils.isEmptyString(name)) {
			return "请输入产品名称";
		}
			
//		if (StringUtils.isEmptyString(this.img))
//			return "请上传产品图片";
//		if (this.cycle <= 0) {
//			return "周期不能小于等于0天";
//		}
//		if (this.daily_rate < 0.0D) {
//			return "日利率不能小于0";
//		}
		
		if (StringUtils.isNullOrEmpty(show_daily_rate) 
				|| !StringUtils.isDouble(show_daily_rate) 
				|| Double.valueOf(show_daily_rate) < 0) {
			return "日利率不能小于0";
		}
		
		if (StringUtils.isNullOrEmpty(daily_rate) 
				|| !StringUtils.isDouble(daily_rate) 
				|| Double.valueOf(daily_rate) < 0) {
			return "今日利率不能小于0";
		}

		if (StringUtils.isNullOrEmpty(cycle_close) 
				|| !StringUtils.isDouble(cycle_close) 
				|| Double.valueOf(cycle_close) < 0) {
			return "解锁周期不能小于0";
		}
		
		if (StringUtils.isNullOrEmpty(investment_min) 
				|| !StringUtils.isDouble(investment_min) 
				|| Double.valueOf(investment_min) < 0) {
			return "投资金额区间最小值不能小于0";
		}
		
		if (StringUtils.isNullOrEmpty(investment_max) 
				|| !StringUtils.isDouble(investment_max) 
				|| Double.valueOf(investment_max) < 0) {
			return "投资金额区间最大值不能小于0";
		}
		
		// max=0表示没有设置上限
		if (Double.valueOf(investment_max) < Double.valueOf(investment_min)) {
			return "投资金额区间错误";
		}
		return null;
	}

//	public String add() {
//		try {
//			this.error = verification();
//			if (!StringUtils.isNullOrEmpty(this.error))
//				return toAdd();
////      if (this.minerService.findByName(this.name) != null) {
////    	  this.error ="产品名称已存在";
////    	  return toAdd(); 
////		}
//			Miner miner = new Miner();
//			miner.setName(this.name);
//			miner.setName_en(this.name_en);
//			miner.setName_cn(this.name_cn);
////			miner.setImg(this.img);
////			miner.setCycle(this.cycle);
//			miner.setCycle_close(this.cycle_close);
//			miner.setDaily_rate(this.daily_rate);
//			miner.setShow_daily_rate(this.show_daily_rate);
//			miner.setInvestment_min(this.investment_min);
//			miner.setInvestment_max(this.investment_max);
//			miner.setState("1");
//			miner.setTest(false);
//			miner.setOn_sale(this.on_sale);
//			
//			//基础参数
//			miner.setAlgorithm(algorithm);
//			miner.setComputing_power(computing_power);
//			miner.setComputing_power_unit(computing_power_unit);
//			miner.setPower(power);
//			miner.setProduct_factory(product_factory);
//			miner.setProduct_size(product_size);
//			miner.setWeight(weight);
//			miner.setWork_temperature_min(work_temperature_min);
//			miner.setWork_temperature_max(work_temperature_max);
//			miner.setWork_humidity_min(work_humidity_min);
//			miner.setWork_humidity_max(work_humidity_max);
//			miner.setInternet(internet);
//
//			this.minerService.save(miner);
//			this.message = "操作成功";
//		} catch (BusinessException e) {
//			this.error = e.getMessage();
//			return toAdd();
//		} catch (Throwable t) {
//			logger.error("UserAction.register error ", t);
//			this.error = "[ERROR] " + t.getMessage();
//			return toAdd();
//		}
//		return list();
//	}

	protected String verificationUpdate(String name, String show_daily_rate, String daily_rate, String cycle_close, String investment_min, String investment_max,
			String algorithm, String computing_power, String power, String product_factory,
			String product_size, String weight, String work_temperature_min, String work_temperature_max, String work_humidity_min,
			String work_humidity_max, String internet) {
		String verifBase = verifBase(algorithm, computing_power, power, product_factory,
				product_size, weight, work_temperature_min, work_temperature_max, work_humidity_min,
				work_humidity_max, internet);
		if(StringUtils.isNotEmpty(verifBase)) {
			return verifBase;
		}
		if (StringUtils.isEmptyString(name))
			return "请输入产品名称";
//		if (StringUtils.isEmptyString(this.img))
//			return "请上传产品图片";
//		if (this.cycle <= 0) {
//			return "周期不能小于等于0天";
//		}
		if (StringUtils.isNullOrEmpty(show_daily_rate) 
				|| !StringUtils.isDouble(show_daily_rate) 
				|| Double.valueOf(show_daily_rate) < 0) {
			return "日利率不能小于0";
		}
		
		if (StringUtils.isNullOrEmpty(daily_rate) 
				|| !StringUtils.isDouble(daily_rate) 
				|| Double.valueOf(daily_rate) < 0) {
			return "今日利率不能小于0";
		}

		if (StringUtils.isNullOrEmpty(cycle_close) 
				|| !StringUtils.isDouble(cycle_close) 
				|| Double.valueOf(cycle_close) < 0) {
			return "解锁周期不能小于0";
		}
		
		if (StringUtils.isNullOrEmpty(investment_min) 
				|| !StringUtils.isDouble(investment_min) 
				|| Double.valueOf(investment_min) < 0) {
			return "投资金额区间最小值不能小于0";
		}
		
		if (StringUtils.isNullOrEmpty(investment_max) 
				|| !StringUtils.isDouble(investment_max) 
				|| Double.valueOf(investment_max) < 0) {
			return "投资金额区间最大值不能小于0";
		}
		
		// max=0表示没有设置上限
		if (Double.valueOf(investment_max) < Double.valueOf(investment_min)) {
			return "投资金额区间错误";
		}

		return null;
	}

	@RequestMapping(action + "toUpdate.action")
	public ModelAndView toUpdate(HttpServletRequest request) {
		String id = request.getParameter("id");
		Miner miner = this.minerService.findById(id);
		double investment_max = !miner.getTest() && miner.getInvestment_max() == 0 ? 0 : miner.getInvestment_max();
		ModelAndView model = new ModelAndView();
		model.addObject("id", id);
		model.addObject("name", miner.getName());
		model.addObject("name_en", miner.getName_en());
		model.addObject("name_cn", miner.getName_cn());
		model.addObject("cycle_close", miner.getCycle_close());
		model.addObject("daily_rate", miner.getDaily_rate());
		model.addObject("investment_min", miner.getInvestment_min());
		model.addObject("investment_max", investment_max);
		model.addObject("show_daily_rate", miner.getShow_daily_rate());
		model.addObject("test", miner.getTest() ? "Y" : "N");
		model.addObject("on_sale", miner.getOn_sale());
		model.addObject("algorithm", miner.getAlgorithm());
		model.addObject("computing_power", miner.getComputing_power());
		model.addObject("computing_power_unit", miner.getComputing_power_unit());
		model.addObject("power", miner.getPower());
		model.addObject("product_factory", miner.getProduct_factory());
		model.addObject("product_size", miner.getProduct_size());
		model.addObject("weight", miner.getWeight());
		model.addObject("work_temperature_min", miner.getWork_temperature_min());
		model.addObject("work_temperature_max", miner.getWork_temperature_max());
		model.addObject("work_humidity_min", miner.getWork_humidity_min());
		model.addObject("work_humidity_max", miner.getWork_humidity_max());
		model.addObject("internet", miner.getInternet());
		model.addObject("buyCurrency", miner.getBuyCurrency());
		model.addObject("outputCurrency", miner.getOutputCurrency());
		model.setViewName("miner_update");
		return model;
	}

	@RequestMapping(action + "update.action")
	public ModelAndView update(HttpServletRequest request) {

		String error = "";
		String id = request.getParameter("id");
		String name = request.getParameter("name");
		String show_daily_rate = request.getParameter("show_daily_rate"); 
		String daily_rate = request.getParameter("daily_rate");
		String cycle_close = request.getParameter("cycle_close");
		String investment_min = request.getParameter("investment_min");
		String investment_max = request.getParameter("investment_max");
		String algorithm = request.getParameter("algorithm");
		String computing_power = request.getParameter("computing_power");
		String power = request.getParameter("power");
		String product_factory = request.getParameter("product_factory");
		String product_size = request.getParameter("product_size");
		String weight = request.getParameter("weight");
		String work_temperature_min = request.getParameter("work_temperature_min");
		String work_temperature_max = request.getParameter("work_temperature_max");
		String work_humidity_min = request.getParameter("work_humidity_min");
		String work_humidity_max = request.getParameter("work_humidity_max");
		String internet = request.getParameter("internet");
		String buyCurrency = request.getParameter("buyCurrency");
		String outputCurrency = request.getParameter("outputCurrency");
		
		String name_en = request.getParameter("name_en");
		String name_cn = request.getParameter("name_cn");
		String test = request.getParameter("test");
		String on_sale = request.getParameter("on_sale");
		String login_safeword = request.getParameter("login_safeword");
		String computing_power_unit = request.getParameter("computing_power_unit");
		
		ModelAndView model = new ModelAndView();
		model.addObject("id", id);
		model.addObject("name", name);
		model.addObject("name_en", name_en);
		model.addObject("name_cn", name_cn);
		model.addObject("cycle_close", cycle_close);
		model.addObject("daily_rate", daily_rate);
		model.addObject("investment_min", investment_min);
		model.addObject("investment_max", investment_max);
		model.addObject("show_daily_rate", show_daily_rate);
		model.addObject("test", test);
		model.addObject("on_sale", on_sale);
		model.addObject("algorithm", algorithm);
		model.addObject("computing_power", computing_power);
		model.addObject("computing_power_unit", computing_power_unit);
		model.addObject("power", power);
		model.addObject("product_factory", product_factory);
		model.addObject("product_size", product_size);
		model.addObject("weight", weight);
		model.addObject("work_temperature_min", work_temperature_min);
		model.addObject("work_temperature_max", work_temperature_max);
		model.addObject("work_humidity_min", work_humidity_min);
		model.addObject("work_humidity_max", work_humidity_max);
		model.addObject("internet", internet);
		model.addObject("buyCurrency", buyCurrency);
		model.addObject("outputCurrency", outputCurrency);
		
		Miner miner = this.minerService.findById(id);
		try {
			error = verificationUpdate(name, show_daily_rate, daily_rate, cycle_close, investment_min, investment_max,
					algorithm, computing_power, power, product_factory,
					product_size, weight, work_temperature_min, work_temperature_max, work_humidity_min,
					work_humidity_max, internet);
			if (!StringUtils.isNullOrEmpty(error)) {
				model.addObject("error", error);
				model.setViewName("miner_update");
				return model;
			}
			
			SecUser sec = this.secUserService.findUserByLoginName(this.getUsername_login());
			checkLoginSafeword(sec,this.getUsername_login(), login_safeword);
			
			miner.setName(name);
			miner.setName_en(name_en);
			miner.setName_cn(name_cn);
			miner.setDaily_rate(Double.valueOf(daily_rate));
			miner.setInvestment_min(Double.valueOf(investment_min));
			miner.setInvestment_max(investment_max == null ? 0 : Double.valueOf(investment_max));
			miner.setOn_sale(on_sale);
			miner.setShow_daily_rate(Double.valueOf(show_daily_rate));
			
			//基础参数
			miner.setAlgorithm(algorithm);
			miner.setComputing_power(Double.valueOf(computing_power));
			miner.setComputing_power_unit(computing_power_unit);
			miner.setPower(Double.valueOf(power));
			miner.setProduct_factory(product_factory);
			miner.setProduct_size(product_size);
			miner.setWeight(Double.valueOf(weight));
			miner.setWork_temperature_min(Double.valueOf(work_temperature_min));
			miner.setWork_temperature_max(Double.valueOf(work_temperature_max));
			miner.setWork_humidity_min(Double.valueOf(work_humidity_min));
			miner.setWork_humidity_max(Double.valueOf(work_humidity_max));
			miner.setInternet(internet);
			miner.setCycle_close(Integer.valueOf(cycle_close));
			miner.setBuyCurrency(buyCurrency.toLowerCase());
			miner.setOutputCurrency(outputCurrency.toLowerCase());
			
			this.minerService.update(miner);

			project.log.Log log = new project.log.Log();
			log.setCategory(Constants.LOG_CATEGORY_OPERATION);
			log.setUsername(this.getUsername_login());
			log.setOperator(this.getUsername_login());
			log.setLog("管理员手动修改矿机配置,ip:["+this.getIp(getRequest())+"]");
			logService.saveSync(log);

			model.addObject("message", "操作成功");
			model.setViewName("redirect:/" + action + "list.action");
			return model;
		} catch (BusinessException e) {
			model.addObject("error", e.getMessage());
			model.setViewName("miner_update");
			return model;
		} catch (Throwable t) {
			logger.error("update error ", t);
			model.addObject("error", "程序错误");
			model.setViewName("miner_update");
			return model;
		}
	}
	
	/**
	 * 验证登录人资金密码
	 * @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 String toDelete() {
//		try {
//
//			this.minerService.delete(this.id);
//			this.message = "操作成功";
//			return list();
//		} catch (BusinessException e) {
//			this.error = e.getMessage();
//			return list();
//		} catch (Throwable t) {
//			logger.error("update error ", t);
//			this.error = "程序错误";
//			return list();
//		}
//	}
}