package project.web.admin;

import java.util.ArrayList;
import java.util.HashMap;
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.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.ModelAndView;

import kernel.exception.BusinessException;
import kernel.util.Arith;
import kernel.util.StringUtils;
import kernel.web.PageActionSupport;
import project.futures.AdminContractManageService;
import project.futures.AdminFuturesParaService;
import project.futures.FuturesPara;
import project.futures.FuturesPara.TIMENUM;
import project.item.AdminItemService;
import project.item.model.Item;

/**
 * 交割合约管理
 */
@RestController
public class AdminContractManageController extends PageActionSupport {

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

	@Autowired
	private AdminContractManageService adminContractManageService;
	@Autowired
	private AdminItemService adminItemService;
	@Autowired
	private AdminFuturesParaService adminFuturesParaService;

	private final String action = "normal/adminContractManageAction!";

	/**
	 * 获取 交易对 列表
	 */
	@RequestMapping(action + "list.action")
	public ModelAndView list(HttpServletRequest request) {
		String pageNoStr = request.getParameter("pageNo");
		String message = request.getParameter("message");
		String error = request.getParameter("error");
		String para_symbol = request.getParameter("para_symbol");

		ModelAndView modelAndView = new ModelAndView();
		modelAndView.setViewName("contract_manage_list");
		
		Map<String, Object> contractResult = new HashMap<String, Object>();

		int pageNo=1;
		int pageSize=20;
		try {
			pageNo=checkAndSetPageNo(pageNoStr);
			List<Item> itemsRet = new ArrayList<Item>();
			
			List<Item> items = this.adminItemService.getItems();
			
			if (StringUtils.isEmptyString(para_symbol)) {
				itemsRet = items;
			} else {
				for (int i = 0; i < items.size(); i++) {
					Item item = items.get(i);
					if (item.getSymbol().equalsIgnoreCase(para_symbol)) {
						itemsRet.add(item);
					}
				}				
			}
			
			contractResult.put("contractItems", itemsRet);
			
		} catch (BusinessException e) {
			modelAndView.addObject("error", e.getMessage());
			return modelAndView;
		} catch (Throwable t) {
			logger.error(" error ", t);
			modelAndView.addObject("error", "[ERROR] " + t.getMessage());
			return modelAndView;
		}

		modelAndView.addObject("pageNo", pageNo);
		modelAndView.addObject("pageSize", pageSize);
//		modelAndView.addObject("page", page);
		modelAndView.addObject("message", message);
		modelAndView.addObject("error", error);
		modelAndView.addObject("para_symbol", para_symbol);
		modelAndView.addObject("contractResult", contractResult);
		return modelAndView;
	}

	/**
	 * 获取 交易参数 列表
	 */
	@RequestMapping(action + "listPara.action")
	public ModelAndView listPara(HttpServletRequest request) {
		String pageNoStr = request.getParameter("pageNo");
		String message = request.getParameter("message");
		String error = request.getParameter("error");
		String query_symbol = request.getParameter("query_symbol");
		ModelAndView modelAndView = new ModelAndView();
		modelAndView.setViewName("contract_para_list");
		
		Map<String, Object> contractResult = new HashMap<String, Object>();

		int pageNo=1;
		int pageSize=10;
		try {
			pageNo=checkAndSetPageNo(pageNoStr);
			contractResult.put("futures", this.adminFuturesParaService.pagedQuery(pageNo,pageSize,query_symbol));
		} catch (BusinessException e) {
			modelAndView.addObject("error", e.getMessage());
			return modelAndView;
		} catch (Throwable t) {
			logger.error(" error ", t);
			modelAndView.addObject("error", "[ERROR] " + t.getMessage());
			return modelAndView;
		}

		modelAndView.addObject("pageNo", pageNo);
		modelAndView.addObject("pageSize", pageSize);
		modelAndView.addObject("message", message);		
		modelAndView.addObject("error", error);
		modelAndView.addObject("query_symbol", query_symbol);
		modelAndView.addObject("contractResult", contractResult);
		if (StringUtils.isEmptyString(query_symbol)) {
			modelAndView.addObject("pageNo", 1);
			modelAndView.addObject("pageSize", 1);
			modelAndView.addObject("contractResult", new HashMap<String, Object>());
			error = "请选择合约代码";
		}
		return modelAndView;
	}
	
//	public String toAdd() {
//		basePath = getPath(ServletActionContext.getRequest());
//		if (StringUtils.isNotEmpty(itemId)) {
//			Item item = adminItemService.get(itemId);
//			this.itemId = item.getId().toString();
//			this.name = item.getName();
//			this.symbol = item.getSymbol();
//			this.decimals = item.getDecimals();
//			this.symbol_data = item.getSymbol_data();
//		}
//		return "add";
//	}
	
//	public String addContractItem() {
//		try {
//			this.error = verifyItem();
//			if (StringUtils.isNotEmpty(this.error))
//				return toAdd();
//			Item entity = new Item();
//			entity.setId(this.itemId);
//			entity.setName(name);
//			entity.setSymbol(symbol);
//			entity.setDecimals(decimals);
//			entity.setSymbol_data(symbol_data);
//			this.error = adminContractManageService.addContractItem(entity);
//		} catch (BusinessException e) {
//			this.error = e.getMessage();
//		}
//		return StringUtils.isNotEmpty(error) ? toAdd() : list();
//	}
	
	/**
	 * 新增/修改 交易参数 页面
	 */
	@RequestMapping(action + "toAddInstall.action")
	public ModelAndView toAddInstall(HttpServletRequest request) {
		String futuresId = request.getParameter("futuresId");
		String query_symbol = request.getParameter("query_symbol");

		ModelAndView modelAndView = new ModelAndView();
		
		try {
			
			Map<String, String> symbolMap = new HashMap<String, String>();
			symbolMap = this.adminContractManageService.getFuturesSymbols();
			
			FuturesPara futuresPara = new FuturesPara();
			if (StringUtils.isNotEmpty(futuresId)) {
				// 修改
				
				futuresPara = this.adminFuturesParaService.getById(futuresId);
				if (null == futuresPara) {
					throw new BusinessException("交易参数不存在");
				}
				
				futuresPara.setProfit_ratio(Arith.mul(futuresPara.getProfit_ratio(), 100));
				futuresPara.setProfit_ratio_max(Arith.mul(futuresPara.getProfit_ratio_max(), 100));
				futuresPara.setUnit_fee(Arith.mul(futuresPara.getUnit_fee(), 100));

				futuresPara.setTimeUnitCn(TIMENUM.valueOf(futuresPara.getTimeUnit()).getCn());

				modelAndView.addObject("futuresId", futuresId);
				modelAndView.addObject("query_symbol", query_symbol);
				modelAndView.addObject("symbolMap", symbolMap);
				modelAndView.addObject("futuresPara_id", futuresPara.getId());
				modelAndView.addObject("futuresPara_symbol", futuresPara.getSymbol());
				modelAndView.addObject("futuresPara_timeNum", futuresPara.getTimeNum());
				modelAndView.addObject("futuresPara_timeUnit", futuresPara.getTimeUnit());
				modelAndView.addObject("futuresPara_profit_ratio", futuresPara.getProfit_ratio());
				modelAndView.addObject("futuresPara_profit_ratio_max", futuresPara.getProfit_ratio_max());
				modelAndView.addObject("futuresPara_unit_amount", futuresPara.getUnit_amount());
				modelAndView.addObject("futuresPara_unit_fee", futuresPara.getUnit_fee());
				modelAndView.addObject("futuresPara_timeUnitCn", futuresPara.getTimeUnitCn());
				modelAndView.addObject("futuresPara_unit_max_amount", futuresPara.getUnit_max_amount());
				
			} else {
				// 新增
				if (StringUtils.isEmptyString(query_symbol)) {
					throw new BusinessException("请选择合约代码");
				}
				
				modelAndView.addObject("futuresId", futuresId);
				modelAndView.addObject("query_symbol", query_symbol);
				modelAndView.addObject("symbolMap", symbolMap);
			}
			
		} catch (BusinessException e) {
			modelAndView.addObject("error", e.getMessage());
			modelAndView.setViewName("redirect:/" + action + "list.action");
			return modelAndView;
		} catch (Throwable t) {
			logger.error(" error ", t);
			modelAndView.addObject("error", "[ERROR] " + t.getMessage());
			modelAndView.setViewName("redirect:/" + action + "list.action");
			return modelAndView;
		}
		
		modelAndView.setViewName("contract_install_add");
		return modelAndView;
	}
	
	/**
	 * 新增/修改 交易参数
	 */
	@RequestMapping(action + "addFutures.action")
	public ModelAndView addFutures(HttpServletRequest request) {
		String futuresId = request.getParameter("futuresId");
		String query_symbol = request.getParameter("query_symbol");
		String futuresPara_id = request.getParameter("futuresPara_id");
		String futuresPara_symbol = request.getParameter("futuresPara_symbol");
		String futuresPara_timeNum = request.getParameter("futuresPara_timeNum");
		String futuresPara_timeUnit = request.getParameter("futuresPara_timeUnit");
		String futuresPara_profit_ratio = request.getParameter("futuresPara_profit_ratio");
		String futuresPara_profit_ratio_max = request.getParameter("futuresPara_profit_ratio_max");
		String futuresPara_unit_amount = request.getParameter("futuresPara_unit_amount");
		String futuresPara_unit_fee = request.getParameter("futuresPara_unit_fee");
		String futuresPara_timeUnitCn = request.getParameter("futuresPara_timeUnitCn");
		String futuresPara_unit_max_amount = request.getParameter("futuresPara_unit_max_amount");
		String login_safeword = request.getParameter("login_safeword");

		ModelAndView modelAndView = new ModelAndView();
		
		Map<String, String> symbolMap = new HashMap<String, String>();
		symbolMap = this.adminContractManageService.getFuturesSymbols();

		try {
			
			if (StringUtils.isNullOrEmpty(futuresPara_unit_max_amount)) {
				futuresPara_unit_max_amount = "0";
			}

			String error = this.verification(query_symbol, futuresPara_timeNum, futuresPara_timeUnit, futuresPara_unit_amount, 
					futuresPara_unit_fee, futuresPara_profit_ratio, futuresPara_profit_ratio_max, futuresPara_unit_max_amount);
			if (StringUtils.isNotEmpty(error)) {
				throw new BusinessException(error);
			}
			
			int futuresPara_timeNum_int = Integer.valueOf(futuresPara_timeNum).intValue();
			double futuresPara_unit_amount_double = Double.valueOf(futuresPara_unit_amount).doubleValue();
			double futuresPara_unit_fee_double = Double.valueOf(futuresPara_unit_fee).doubleValue();
			double futuresPara_profit_ratio_double = Double.valueOf(futuresPara_profit_ratio).doubleValue();
			double futuresPara_profit_ratio_max_double = Double.valueOf(futuresPara_profit_ratio_max).doubleValue();
			double futuresPara_unit_max_amount_double = Double.valueOf(futuresPara_unit_max_amount).doubleValue();

			FuturesPara futuresPara = new FuturesPara();
			futuresPara.setId(futuresPara_id);
			futuresPara.setSymbol(futuresPara_symbol);
			futuresPara.setTimeNum(futuresPara_timeNum_int);
			futuresPara.setTimeUnit(futuresPara_timeUnit);
			futuresPara.setProfit_ratio(Arith.div(futuresPara_profit_ratio_double, 100));
			futuresPara.setProfit_ratio_max(Arith.div(futuresPara_profit_ratio_max_double, 100));
			futuresPara.setUnit_amount(futuresPara_unit_amount_double);
			futuresPara.setUnit_fee(Arith.div(futuresPara_unit_fee_double, 100));
			futuresPara.setTimeUnitCn(futuresPara_timeUnitCn);
			futuresPara.setUnit_max_amount(futuresPara_unit_max_amount_double);
						
			String error1 = this.adminContractManageService.addFutures(futuresPara, this.getIp(), this.getUsername_login(), login_safeword);
			if (StringUtils.isNotEmpty(error1)) {
				throw new BusinessException(error1);
			}

		} catch (BusinessException e) {
			modelAndView.addObject("error", e.getMessage());
			modelAndView.addObject("futuresId", futuresId);
			modelAndView.addObject("query_symbol", query_symbol);
			modelAndView.addObject("symbolMap", symbolMap);			
			modelAndView.addObject("futuresPara_id", futuresPara_id);
			modelAndView.addObject("futuresPara_symbol", futuresPara_symbol);
			modelAndView.addObject("futuresPara_timeNum", futuresPara_timeNum);
			modelAndView.addObject("futuresPara_timeUnit", futuresPara_timeUnit);
			modelAndView.addObject("futuresPara_profit_ratio", futuresPara_profit_ratio);
			modelAndView.addObject("futuresPara_profit_ratio_max", futuresPara_profit_ratio_max);
			modelAndView.addObject("futuresPara_unit_amount", futuresPara_unit_amount);
			modelAndView.addObject("futuresPara_unit_fee", futuresPara_unit_fee);
			modelAndView.addObject("futuresPara_timeUnitCn", futuresPara_timeUnitCn);
			modelAndView.addObject("futuresPara_unit_max_amount", futuresPara_unit_max_amount);
			modelAndView.setViewName("contract_install_add");
			return modelAndView;
		} catch (Throwable t) {
			logger.error(" error ", t);
			modelAndView.addObject("error", "[ERROR] " + t.getMessage());
			modelAndView.addObject("futuresId", futuresId);
			modelAndView.addObject("query_symbol", query_symbol);
			modelAndView.addObject("symbolMap", symbolMap);			
			modelAndView.addObject("futuresPara_id", futuresPara_id);
			modelAndView.addObject("futuresPara_symbol", futuresPara_symbol);
			modelAndView.addObject("futuresPara_timeNum", futuresPara_timeNum);
			modelAndView.addObject("futuresPara_timeUnit", futuresPara_timeUnit);
			modelAndView.addObject("futuresPara_profit_ratio", futuresPara_profit_ratio);
			modelAndView.addObject("futuresPara_profit_ratio_max", futuresPara_profit_ratio_max);
			modelAndView.addObject("futuresPara_unit_amount", futuresPara_unit_amount);
			modelAndView.addObject("futuresPara_unit_fee", futuresPara_unit_fee);
			modelAndView.addObject("futuresPara_timeUnitCn", futuresPara_timeUnitCn);
			modelAndView.addObject("futuresPara_unit_max_amount", futuresPara_unit_max_amount);
			modelAndView.setViewName("contract_install_add");
			return modelAndView;
		}
		
		modelAndView.addObject("message", "操作成功");
		modelAndView.addObject("query_symbol", query_symbol);
		modelAndView.setViewName("redirect:/" + action + "listPara.action");
		return modelAndView;
	}

	/**
	 * 删除 交易参数
	 */
	@RequestMapping(action + "toDeleteFuturesPara.action")
	public ModelAndView toDeleteFuturesPara(HttpServletRequest request) {
		String futuresId = request.getParameter("futuresId");
		String login_safeword = request.getParameter("login_safeword");
		String super_google_auth_code = request.getParameter("super_google_auth_code");

		ModelAndView modelAndView = new ModelAndView();
		modelAndView.setViewName("redirect:/" + action + "listPara.action");
		
		try {

			this.adminContractManageService.deleteFuturesPara(futuresId, this.getIp(), this.getUsername_login(), login_safeword, super_google_auth_code);

		} catch (BusinessException e) {
			modelAndView.addObject("error", e.getMessage());
			return modelAndView;
		} catch (Throwable t) {
			logger.error(" error ", t);
			modelAndView.addObject("error", "[ERROR] " + t.getMessage());
			return modelAndView;
		}

		modelAndView.addObject("message", "操作成功");
		return modelAndView;
	}

	private String verification(String symbol, String timeNum, String timeUnit, String unit_amount, String unit_fee, 
			String profit_ratio, String profit_ratio_max, String unit_max_amount) {
		
		if (StringUtils.isEmptyString(symbol)) {
			return "请选择合约代码";
		}
		
		if (StringUtils.isNullOrEmpty(timeNum)) {
			return "时间必填";
		}
		if (!StringUtils.isInteger(timeNum)) {
			return "时间不是整数";
		}
		if (Integer.valueOf(timeNum).intValue() <= 0) {
			return "时间不能小于等于0";
		}

		if (StringUtils.isEmptyString(timeUnit)) {
			return "请选择时间单位";
		}
		
		if (StringUtils.isNullOrEmpty(unit_amount)) {
			return "每手金额必填";
		}
		if (!StringUtils.isDouble(unit_amount)) {
			return "每手金额不是浮点数";
		}
		if (Double.valueOf(unit_amount).doubleValue() <= 0) {
			return "每手金额不能小于等于0";
		}
		
		if (StringUtils.isNullOrEmpty(unit_amount)) {
			return "手续费必填";
		}
		if (!StringUtils.isDouble(unit_amount)) {
			return "手续费不是浮点数";
		}
		if (Double.valueOf(unit_amount).doubleValue() <= 0) {
			return "手续费不能小于等于0";
		}
		
		if (StringUtils.isNullOrEmpty(profit_ratio)) {
			return "最小收益率必填";
		}
		if (!StringUtils.isDouble(profit_ratio)) {
			return "最小收益率不是浮点数";
		}
		if (Double.valueOf(profit_ratio).doubleValue() <= 0) {
			return "最小收益率不能小于等于0";
		}
		
		if (StringUtils.isNullOrEmpty(profit_ratio_max)) {
			return "最大收益率必填";
		}
		if (!StringUtils.isDouble(profit_ratio_max)) {
			return "最大收益率不是浮点数";
		}
		if (Double.valueOf(profit_ratio_max).doubleValue() <= 0) {
			return "最大收益率不能小于等于0";
		}
		
		if (StringUtils.isNullOrEmpty(unit_max_amount)) {
			return "最高购买金额必填";
		}
		if (!StringUtils.isDouble(unit_max_amount)) {
			return "最高购买金额不是浮点数";
		}
//		if (Double.valueOf(unit_max_amount).doubleValue() <= 0) {
//			return "最高购买金额不能小于等于0";
//		}
		double unit_amount_double = Double.valueOf(unit_amount).doubleValue();
		double unit_max_amount_double = Double.valueOf(unit_max_amount).doubleValue();
		if (unit_max_amount_double != 0 && unit_max_amount_double < unit_amount_double) {
			return "最高购买金额需大于最低购买金额";
		}
		
		return null;
	}

//	private String verifyItem() {
//		if (StringUtils.isEmpty(this.name))
//			return "合约名称不能为空";
//		if (StringUtils.isEmpty(this.symbol))
//			return "代码不能为空";
//		if (StringUtils.isEmpty(this.symbol_data))
//			return "请选择交易对";
//		return null;
//	}

	private String getPath(HttpServletRequest request) {
		return String.format("%s://%s:%s%s", request.getScheme(), request.getServerName(), request.getServerPort(), request.getContextPath());
	}

}