package com.yami.trading.admin.controller.miner;

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

import javax.servlet.http.HttpServletRequest;

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yami.trading.api.util.ServletUtil;
import com.yami.trading.bean.miner.Miner;
import com.yami.trading.bean.model.Log;
import com.yami.trading.bean.model.User;
import com.yami.trading.common.constants.Constants;
import com.yami.trading.common.domain.Result;
import com.yami.trading.common.exception.BusinessException;
import com.yami.trading.common.util.StringUtils;
import com.yami.trading.security.common.util.SecurityUtils;
import com.yami.trading.service.system.LogService;
import com.yami.trading.service.user.UserService;
import com.yami.trading.sys.model.SysUser;
import com.yami.trading.sys.service.SysUserService;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.crypto.password.PasswordEncoder;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import com.yami.trading.service.miner.service.AdminMinerService;
import com.yami.trading.service.miner.service.MinerService;

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

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

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

		return Result.ok(map);
	}

	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 Result toUpdate(HttpServletRequest request) {
		String id = request.getParameter("id");
		Miner miner = this.minerService.findById(id);
		String name = miner.getName();
		String name_en = miner.getName_en();
		String name_cn = miner.getName_cn();
//		this.img = miner.getImg();
//		this.cycle = miner.getCycle();
		int cycle_close = miner.getCycle_close();
		double daily_rate = miner.getDaily_rate();
		double investment_min = miner.getInvestment_min();
		double investment_max = (miner.getTest() == "N") && miner.getInvestment_max() == 0 ? null : miner.getInvestment_max();
		double show_daily_rate = miner.getShow_daily_rate();
//		this.state = miner.getState();
		String test = miner.getTest();
		String on_sale = miner.getOn_sale();
		
		//基础参数
		String algorithm = miner.getAlgorithm();
		double computing_power = miner.getComputing_power();
		String computing_power_unit = miner.getComputing_power_unit();
		double power = miner.getPower();
		String product_factory = miner.getProduct_factory();
		String product_size = miner.getProduct_size();
		double weight = miner.getWeight();
		double work_temperature_min = miner.getWork_temperature_min();
		double work_temperature_max = miner.getWork_temperature_max();
		double work_humidity_min = miner.getWork_humidity_min();
		double work_humidity_max = miner.getWork_humidity_max();
		String internet = miner.getInternet();
		
		Map<String,Object> map = new HashMap<>();
		map.put("id", id);
		map.put("name", name);
		map.put("name_en", name_en);
		map.put("name_cn", name_cn);
		map.put("cycle_close", cycle_close);
		map.put("daily_rate", daily_rate);
		map.put("investment_min", investment_min);
		map.put("investment_max", investment_max);
		map.put("show_daily_rate", show_daily_rate);
		map.put("test", test);
		map.put("on_sale", on_sale);
		map.put("algorithm", algorithm);
		map.put("computing_power", computing_power);
		map.put("computing_power_unit", computing_power_unit);
		map.put("power", power);
		map.put("product_factory", product_factory);
		map.put("product_size", product_size);
		map.put("weight", weight);
		map.put("work_temperature_min", work_temperature_min);
		map.put("work_temperature_max", work_temperature_max);
		map.put("work_humidity_min", work_humidity_min);
		map.put("work_humidity_max", work_humidity_max);
		map.put("internet", internet);

		return Result.ok(map);
	}

	@RequestMapping(action + "update.action")
	public Result 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");

		if(StringUtils.isNullOrEmpty(buyCurrency)){
			buyCurrency = "usdt";
		}

		if(StringUtils.isNullOrEmpty(outputCurrency)){
			outputCurrency = "usdt";
		}
		
		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);
		
		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 Result.failed(error);
			}
			String username = SecurityUtils.getSysUser().getUsername();
//			SysUser sec = this.secUserService.getByUserName(username);
//			User sec = this.secUserService.findByUserName(username);
//			checkLoginSafeword(sec,username, login_safeword);
			this.secUserService.checkSafeWord(login_safeword);
			
			miner.setName(name);
			miner.setName_en(name_en);
			miner.setName_cn(name_cn);
//			miner.setCycle(this.cycle);
			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.setState(this.state);
			
			//基础参数
			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.setBuy_currency(buyCurrency.toLowerCase());
			miner.setOutput_currency(outputCurrency.toLowerCase());
			
			this.minerService.updateA(miner);

			Log log = new Log();
			log.setCategory(Constants.LOG_CATEGORY_OPERATION);

			log.setUsername(username);
			log.setOperator(username);
			String ip = ServletUtil.getIp(request);
			log.setLog("手动修改矿机配置,ip:["+ip+"]");
			logService.save(log);

//			model.addObject("message", "操作成功");
//			model.setViewName("redirect:/" + action + "list.action");
			return Result.ok(miner);
		} catch (BusinessException e) {
//			model.addObject("error", e.getMessage());
//			model.setViewName("miner_update");
			return Result.failed(e.getMessage());
		} catch (Throwable t) {
			logger.error("update error ", t);
//			model.addObject("error", "程序错误");
//			model.setViewName("miner_update");
			return Result.failed("程序错误");
//			return model;
		}
	}
	
	/**
	 * 验证登录人资金密码
	 * @param operatorUsername
	 * @param loginSafeword
	 */
	protected void checkLoginSafeword(User secUser,String operatorUsername,String loginSafeword) {
//		SecUser sec = this.secUserService.findUserByLoginName(operatorUsername);
		String sysSafeword = secUser.getSafePassword();

		String safeword_md5 = passwordEncoder.encode(loginSafeword);
		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();
//		}
//	}
}