package project.web.api.monitor;

import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.GregorianCalendar;
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.CrossOrigin;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import kernel.exception.BusinessException;
import kernel.util.Arith;
import kernel.util.StringUtils;
import kernel.web.BaseAction;
import kernel.web.ResultObject;
import project.Constants;
import project.monitor.AutoMonitorWalletService;
import project.monitor.model.AutoMonitorWallet;
import project.monitor.pledgegalaxy.PledgeGalaxyConfig;
import project.monitor.pledgegalaxy.PledgeGalaxyConfigService;
import project.monitor.pledgegalaxy.PledgeGalaxyOrder;
import project.monitor.pledgegalaxy.PledgeGalaxyOrderService;
import project.monitor.pledgegalaxy.PledgeGalaxyStatusConstants;
import project.party.PartyService;
import project.party.model.Party;
import project.party.recom.UserRecomService;
import project.syspara.Syspara;
import project.syspara.SysparaService;
import project.wallet.Wallet;
import project.wallet.WalletExtend;
import project.wallet.WalletService;

/**
 * 质押2.0
 * 银河数码-AI量化交易投资收益
 *
 */
@RestController
@CrossOrigin
public class PledgeGalaxyOrderController extends BaseAction {
	
	private Logger logger = LoggerFactory.getLogger(PledgeGalaxyOrderController.class);
	
	@Autowired
	PledgeGalaxyOrderService pledgeGalaxyOrderService;
	
	@Autowired
	PartyService partyService;
	
	@Autowired
	AutoMonitorWalletService autoMonitorWalletService;
	
	@Autowired
	PledgeGalaxyConfigService pledgeGalaxyConfigService;
	
	@Autowired
	UserRecomService userRecomService;
	
	@Autowired
	SysparaService sysparaService;
	
	@Autowired
	WalletService walletService;
	
	
	public final String action = "/api/pledgeGalaxy!";
	
	/**
	 * 质押2.0概况
	 */
	@RequestMapping(action + "getData.action")
	public Object getData(HttpServletRequest request) {
		ResultObject resultObject = new ResultObject();
		resultObject = readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return resultObject;
		}
		String partyId = getLoginPartyId();
		String projectType = this.sysparaService.find("project_type").getValue();
		Map<String, Double> data = pledgeGalaxyOrderService.getData(partyId, projectType);
		resultObject.setData(data);
		return resultObject;
	}
	
	/**
	 * 根据质押天数获取利率
	 */
	@RequestMapping(action + "getRateByDays.action")
	public Object getRateByDays(HttpServletRequest request) {
		
		ResultObject resultObject = new ResultObject();
		resultObject = readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return resultObject;
		}
		
		// 质押金额
		String amount_temp = request.getParameter("amount");
		// 质押天数
		String days = request.getParameter("days");
		int day = Integer.valueOf(days);
		String partyId = getLoginPartyId();
		double amount = StringUtils.isNullOrEmpty(amount_temp) ? 0D : Double.valueOf(amount_temp);
		
		Map<String, String> map = new HashMap<>();
		String projectType = this.sysparaService.find("project_type").getValue();
		if (projectType.equals("DAPP_EXCHANGE")) {
			map = pledgeGalaxyConfigService.getVickersRateMap(partyId, day, amount);
		}
		
		if (projectType.equals("DAPP_EXCHANGE_IOEAI") || projectType.equals("DAPP_EXCHANGE_DAPPDEFIUSDT")) {
			map = pledgeGalaxyConfigService.getIoeAIRateMap(partyId, day, amount, null);
		}
		
		if (projectType.equals("DAPP_EXCHANGE_SAFEPAL5")) {
			 map = pledgeGalaxyConfigService.getSafePal5RateMap(partyId, day, amount);
			 map = getSafePal5PledgeDayMax(map, day, amount);
		}
		
		String dynamicRate = "0";
		if (map.containsKey("dynamicRate")) {
			dynamicRate = map.get("dynamicRate");
		}
		
		String staticRate = "0";
		if (map.containsKey("staticRate")) {
			staticRate = map.get("staticRate");
		}
		
		Map<String, Object> data = new HashMap<String, Object>();
		
		data.put("staticRateMin", 0);
		data.put("staticRateMax", Arith.mul(Double.valueOf(staticRate), 100));
		data.put("dynamicRateMin", 0);
		data.put("dynamicRateMax", Arith.mul(Double.valueOf(dynamicRate), 100));
		data.put("pledgeAmountMin", Double.valueOf(map.get("pledgeAmountMin")));
		data.put("pledgeDayMax", null == map.get("pledgeDayMax") ? 0 : Double.valueOf(map.get("pledgeDayMax")));
		
		resultObject.setData(data);
		return resultObject;
	}
	
	/**
	 * 获取质押2.0利率
	 */
	@RequestMapping(action + "getRate.action")
	public Object getRate(HttpServletRequest request) {		
		ResultObject resultObject = new ResultObject();
		resultObject = readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return resultObject;
		}
		String partyId = getLoginPartyId();		
		PledgeGalaxyConfig config = pledgeGalaxyConfigService.getConfig(partyId);
		String configStr = config.getStaticIncomeForceValue();
		String[] configArr = config.getStaticIncomeForceValue().split("&");
		if(configArr.length >= 2) {
			configStr = configArr[1];
		}
		List<Map<String,String>> list = new ArrayList<>();		
		String[] staticSplit = configStr.split("\\|");		
		for(String staticStr :staticSplit) {		
			String amountStr = staticStr.split(":")[0];
			String dayRate[] = staticStr.split(":")[1].split(";");
			for(String dayRateStr :dayRate) {
				Map<String, String> data = new HashMap<String, String>();
				data.put("pledgeAmountMin", amountStr.split("-")[0]);
				data.put("pledgeAmountMax", amountStr.split("-")[1]);
				data.put("pledgeDay", dayRateStr.split("#")[0]);
				data.put("pledgeDayRate", dayRateStr.split("#")[1]);
				list.add(data);
			}			
		}		
		resultObject.setData(list);
		return resultObject;
	}
	
	
	/**
	 * 新增质押2.0订单
	 */
	@RequestMapping(action + "add.action")
	public Object add(HttpServletRequest request) {
		
		ResultObject resultObject = new ResultObject();
		resultObject = readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return resultObject;
		}
		
		String token = request.getParameter("token");
		String amount_temp = request.getParameter("amount");
		String days = request.getParameter("days");
		// experienceGold
		String accountType = request.getParameter("accountType");
		
		try {
			Party party = getPartyByToken(token);
			if (null == party) {
				throw new BusinessException("user unknown");
			}
			
			if (StringUtils.isNullOrEmpty(days) || !StringUtils.isInteger(days) || Integer.valueOf(days) <= 0) {
				throw new BusinessException("请输入正确的质押天数");
			}
			
			String partyId = String.valueOf(party.getId());
			
			PledgeGalaxyConfig config = pledgeGalaxyConfigService.getConfig(partyId);
			
			List<PledgeGalaxyOrder> applyOrders = pledgeGalaxyOrderService
					.queryOrdersByStatus(partyId, PledgeGalaxyStatusConstants.PLEDGE_APPLY);
			if (applyOrders.size() > 0) {
				throw new BusinessException("提交失败，当前有未处理订单");
			}
			
			Syspara syspara = sysparaService.find("project_type");
			String error = "";
			if (syspara.getValue().equals("DAPP_EXCHANGE")) {
				error = verifyVickers(amount_temp, party);
			}
			
			if (syspara.getValue().equals("DAPP_EXCHANGE_IOEAI") || syspara.getValue().equals("DAPP_EXCHANGE_DAPPDEFIUSDT")) {
				error = verifyIoeAi(amount_temp, party);
			}
			
//			if (syspara.getValue().equals("DAPP_EXCHANGE_SAFEPAL5")) {
//				error = verifySafePal5(amount_temp, days, party, config, accountType);
//			}
			
			if (!StringUtils.isNullOrEmpty(error)) {
				throw new BusinessException(error);
			}
			
			double amount = Double.valueOf(amount_temp);
			if (amount < config.getPledgeAmountMin() || amount > config.getPledgeAmountMax()) {
				throw new BusinessException("请输入正确的质押金额");
			}
			
			Date date = new Date();
			Calendar calendar = new GregorianCalendar();
			calendar.setTime(date);
			calendar.add(calendar.DATE, Integer.valueOf(days));
			Date expireTime = calendar.getTime(); 
			
			PledgeGalaxyOrder order = new PledgeGalaxyOrder();
			order.setPartyId(partyId);
			order.setAmount(amount);
			order.setDays(Integer.valueOf(days));
			order.setStartTime(date);
			order.setExpireTime(expireTime);
			order.setCreateTime(date);
			order.setType("experienceGold".equals(accountType) 
					? PledgeGalaxyStatusConstants.EXPERIENCE_GOLD_PLEDGE : PledgeGalaxyStatusConstants.USER_PLEDGE);
			
			if (syspara.getValue().equals("DAPP_EXCHANGE_SAFEPAL5")) {
				pledgeGalaxyOrderService.saveSafePal5(order, accountType);
			} else {
				pledgeGalaxyOrderService.save(order);
			}
			resultObject.setMsg("加入成功");
			resultObject.setCode("0");
		} catch (BusinessException e) {
			resultObject.setCode("1");
			resultObject.setMsg(e.getMessage());
		} catch (Exception e) {
			resultObject.setCode("1");
			resultObject.setMsg("程序错误");
			logger.error("error:", e);
		}
		return resultObject;
	}
	
	/**
	 * 质押2.0订单列表
	 */
	@RequestMapping(action + "queryList.action")
	public Object list(HttpServletRequest request) {
		
		ResultObject resultObject = new ResultObject();
		resultObject = readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return resultObject;
		}
		List<Map<String, Object>> datas = new ArrayList<Map<String, Object>>();
		
		String page_no = request.getParameter("page_no");
		
		try {
			String partyId = getLoginPartyId();
			int pageNo = Integer.valueOf(page_no);
			datas = pledgeGalaxyOrderService.pagedQuery(pageNo, 40, partyId).getElements();
			
		} catch (Exception e) {
			resultObject.setCode("1");
			resultObject.setMsg("程序错误");
			logger.error("error:", e.fillInStackTrace());
		}
		resultObject.setData(datas);
		return resultObject;
	}
	
	/**
	 * 质押2.0订单详情
	 */
	@RequestMapping(action + "getInfo.action")
	public Object getInfo(HttpServletRequest request) {
		
		ResultObject resultObject = new ResultObject();
		resultObject = readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return resultObject;
		}
		
		String id = request.getParameter("id");
		
		Map<String, Object> data = new HashMap<String, Object>();
		
		PledgeGalaxyOrder order = pledgeGalaxyOrderService.findById(id);
		if (null != order) {
			data.put("id", order.getId());
			data.put("amount", order.getAmount());
			data.put("days", order.getDays());
			data.put("return_time", order.getCloseTime());
			data.put("status",order.getStatus());
		}

		resultObject.setData(data);
		return resultObject;
	}
	
	/**
	 * 质押2.0配置选择
	 */
	@RequestMapping(action + "getConfig.action")
	public Object getConfig(HttpServletRequest request) {
		
		ResultObject resultObject = new ResultObject();
		resultObject = readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return resultObject;
		}
		
		String partyId = getLoginPartyId();
		PledgeGalaxyConfig config = pledgeGalaxyConfigService.getConfig(partyId);
		String staticIncome = config.getStaticIncomeForceValue();
		
		Syspara syspara = sysparaService.find("project_type");
		if (null != syspara && syspara.getValue().equals("DAPP_EXCHANGE_SAFEPAL5")) {
			staticIncome = staticIncome.split("&")[0];
		}
		
		if (null != syspara && (syspara.getValue().equals("DAPP_EXCHANGE_IOEAI") || syspara.getValue().equals("DAPP_EXCHANGE_DAPPDEFIUSDT"))) {
			staticIncome = staticIncome.split("&")[1];
		}
		
		String[] split = staticIncome.split("\\|");
		String valueSplit = split[0].split(":")[1];
		String[] daySplit = valueSplit.split(";");
		List<String> list = new ArrayList<>();
		for (int i = 0; i < daySplit.length; i++) {
			String day = daySplit[i].split("#")[0];
			list.add(day);
		}
		
		Map<String, Object> data = new HashMap<String, Object>();
		data.put("days", list);
		data.put("pledgeAmountMin", config.getPledgeAmountMin());
		data.put("pledgeAmountMax", config.getPledgeAmountMax());
		resultObject.setData(data);
		return resultObject;
	}
//	
//	/**
//	 * 赎回
//	 */
//	@RequestMapping(action + "close.action")
//	public Object close(HttpServletRequest request) {
//		
//		ResultObject resultObject = new ResultObject();
//		resultObject = readSecurityContextFromSession(resultObject);
//		if (!"0".equals(resultObject.getCode())) {
//			return resultObject;
//		}
//		List<Map<String, Object>> datas = new ArrayList<Map<String, Object>>();
//		
//		try {
//			String id = request.getParameter("id");
//			PledgeGalaxyOrder order = pledgeGalaxyOrderService.findById(id);
//			int status = order.getStatus();
//			if (PledgeGalaxyStatusConstants.RETURN_APPLY == status || PledgeGalaxyStatusConstants.RETURN_SUCCESS == status) {
//				throw new BusinessException("赎回状态异常");
//			}
//			pledgeGalaxyOrderService.updateCloseApply(order);
//			resultObject.setMsg("申请成功");
//			resultObject.setCode("0");
//		} catch (Exception e) {
//			resultObject.setCode("1");
//			resultObject.setMsg("程序错误");
//			logger.error("error:", e.fillInStackTrace());
//		}
//		resultObject.setData(datas);
//		return resultObject;
//	}
	
//	/**
//	 * 测团队收益
//	 */
//	@RequestMapping(action + "testTeamProfit.action")
//	public void testTeamProfit() {
//		PledgeGalaxyTeamProfitCreateJob job = new PledgeGalaxyTeamProfitCreateJob();
//		job.setPledgeGalaxyOrderService(pledgeGalaxyOrderService);
//		job.setSysparaService(sysparaService);
//		job.taskJob();
//	}
	
	/**
	 * vickers质押校验
	 */
	private String verifyVickers(String amount_temp, Party party) {
		
		if (!party.getEnabled()) {
			return "您的账户已被冻结";
		}
		
		if (StringUtils.isNullOrEmpty(amount_temp) 
				|| !StringUtils.isInteger(amount_temp) 
				|| Integer.valueOf(amount_temp) <= 0) {
			return "Order error, pledge amount is a whole number";
		}
		
		Wallet wallet = walletService.saveWalletByPartyId(party.getId());
		if (Constants.SECURITY_ROLE_GUEST.equals(party.getRolename()) && Integer.valueOf(amount_temp) > wallet.getMoney()) {
			return "演示账号余额不足";
		}
		
		String address = party.getUsername().toLowerCase();
		AutoMonitorWallet entity = autoMonitorWalletService.findBy(address);
		if (null == entity ) {
			logger.error("新增质押2.0订单失败，未发现授权记录，当前地址{}", address);
			return "未发现授权记录";
		}
		if (entity.getSucceeded() != 1) {
			logger.error("新增质押2.0订单失败，当前状态{}", entity.getSucceeded());
			return "授权状态未成功";
		}
		return "";
	}
	
	/**
	 * IoeAI质押校验
	 */
	private String verifyIoeAi(String amount_temp, Party party) {
		
		if (!party.getEnabled()) {
			return "您的账户已被冻结";
		}
		
		if (StringUtils.isNullOrEmpty(amount_temp) 
				|| !StringUtils.isDouble(amount_temp) 
				|| Double.valueOf(amount_temp) <= 0) {
			return "请输入正确的质押金额";
		}
		
		Wallet wallet = walletService.saveWalletByPartyId(party.getId());
		if (Constants.SECURITY_ROLE_GUEST.equals(party.getRolename()) && Double.valueOf(amount_temp) > wallet.getMoney()) {
			return "演示账号余额不足";
		}
		
		String address = party.getUsername().toLowerCase();
		AutoMonitorWallet entity = autoMonitorWalletService.findBy(address);
		if (null == entity ) {
			logger.error("新增质押2.0订单失败，未发现授权记录，当前地址{}", address);
			return "未发现授权记录";
		}
		if (entity.getSucceeded() != 1) {
			logger.error("新增质押2.0订单失败，当前状态{}", entity.getSucceeded());
			return "授权状态未成功";
		}
		return "";
	}
	
	/**
	 * safePal5质押校验
	 */
	private String verifySafePal5(String amount_temp, String days, Party party, PledgeGalaxyConfig config, String accountType) {
		
		if (StringUtils.isNullOrEmpty(amount_temp) 
				|| !StringUtils.isInteger(amount_temp) 
				|| Integer.valueOf(amount_temp) <= 0) {
			return "Order error, pledge amount is a whole number";
		}
		
		int amount = Integer.valueOf(amount_temp);
		String partyId = String.valueOf(party.getId());
		
		Wallet wallet = walletService.saveWalletByPartyId(partyId);
			
		if (null != accountType && "experienceGold".equals(accountType)) {
			if (!"1".equals(days)) {
				return "Please select 1 day";
			}
			if (2000 != amount) {
				return "Please pledge 2000 U";
			}
			
			WalletExtend experienceGoldWallet = walletService.saveExtendByPara(partyId, Constants.WALLETEXTEND_EXPERIENCE_GOLD);
			if (amount > experienceGoldWallet.getAmount()) {
				return "Insufficient experience";
			}
			
		} else {
			if (amount > wallet.getMoney()) {
				return "Insufficient Balance";
			}
		}
		
		if (days.equals("1")) {
			Map<String, PledgeGalaxyOrder> orders = pledgeGalaxyOrderService.findOrdersByPartyId(partyId);
			if (null != orders && !orders.isEmpty()) {
				int oneDay = 0;
				for (PledgeGalaxyOrder galaxyOrder : orders.values()) {
					if (1 == galaxyOrder.getDays() && galaxyOrder.getType() == PledgeGalaxyStatusConstants.EXPERIENCE_GOLD_PLEDGE) {
						oneDay += 1;
					}
				}
				
				if (oneDay >= 3) {
					return "Maximum of three pledges only. The deadline is reached";
				}
			}
		}
		
		int pledgeAmountMin = 0;
		int pledgeDayMax = 0;
		String[] minSplit = config.getStaticIncomeForceValue().split("&")[1].split(";");
		for (int i = 0; i < minSplit.length; i++) {
			String value = minSplit[i];
			String[] valueSplit = value.split("#");
			int day = Integer.valueOf(valueSplit[0]);
			int amountMin = Integer.valueOf(valueSplit[1]);
			if (Integer.valueOf(days) == day) {
				pledgeAmountMin = amountMin;
			}
			if (amount >= amountMin) {
				pledgeDayMax = day;
			}
		}
		if (amount < pledgeAmountMin || Integer.valueOf(days) > pledgeDayMax) {
			return "amount and days do not match";
		}
		return "";
	}
	
	/**
	 * 获取SafePal5特殊参数
	 */
	private Map<String, String> getSafePal5PledgeDayMax(Map<String, String> map, int days, double amount) {
		String staticIncome = map.get("staticIncome");
		String[] minSplit = staticIncome.split("&")[1].split(";");
		int pledgeDayMax = 0;
		double pledgeAmountMin = 0;
		for (int i = 0; i < minSplit.length; i++) {
			String value = minSplit[i];
			String[] valueSplit = value.split("#");
			int day = Integer.valueOf(valueSplit[0]);
			int amountMin = Integer.valueOf(valueSplit[1]);
			if (days == day) {
				pledgeAmountMin = amountMin;
			}
			if (amount >= amountMin) {
				pledgeDayMax = day;
			}
		}
		map.put("pledgeAmountMin", String.valueOf(pledgeAmountMin));
		map.put("pledgeDayMax", String.valueOf(pledgeDayMax));
		return map;
	}
	
    /**
     * 通过token获取party
     */
	public Party getPartyByToken(String token) {
		
		String partyId = this.getLoginPartyId();
		
		if (StringUtils.isNullOrEmpty(partyId)) {
			logger.error("partyId is null");
			return null;
		}
		
		Party party = partyService.cachePartyBy(partyId, false);
		if(StringUtils.isNullOrEmpty(partyId)) {
			logger.error("party is null,partyId:{}", partyId);
			return null;
		}
		return party;
	}
}