package project.project.web.api;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.text.DecimalFormat;
import java.text.ParseException;
import java.text.SimpleDateFormat;
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.sessiontoken.SessionTokenService;
import kernel.util.Arith;
import kernel.util.DateUtils;
import kernel.util.StringUtils;
import kernel.util.ThreadUtils;
import kernel.web.BaseAction;
import kernel.web.ResultObject;
import project.Constants;
import project.finance.Finance;
import project.finance.FinanceOrder;
import project.finance.FinanceOrderLock;
import project.finance.FinanceOrderService;
import project.finance.FinanceService;
import project.party.PartyService;
import project.party.model.Party;
import util.DateUtil;
import util.RandomUtil;

/**
 * 理财订单
 *
 */
@RestController
@CrossOrigin
public class FinanceOrderController extends BaseAction {
	
	@Autowired
	protected PartyService partyService;
	
	@Autowired
	protected FinanceService financeService;
	
	@Autowired
	protected SessionTokenService sessionTokenService;
	
	@Autowired
	protected FinanceOrderService financeOrderService;

	private final String action = "/api/financeOrder!";
	
	private static final Logger logger = LoggerFactory.getLogger(FinanceOrderController.class);

	/**
	 * 托管订单
	 */
	@RequestMapping(action + "list.action")
	public Object list(HttpServletRequest request) {
		ResultObject resultObject = new ResultObject();
		resultObject = readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return resultObject;
		}
		try {
			List<FinanceOrder> data = null;
			String partyId = getLoginPartyId();
			
			if (StringUtils.isNullOrEmpty(partyId)) {
				resultObject.setData(data);
				resultObject.setCode("0");
				return resultObject;
			}
			String page_no = request.getParameter("page_no");
			int pageNo = 1;
			if (StringUtils.isNotEmpty(page_no)) {
				pageNo = Integer.valueOf(page_no);
			}
			// 状态。0.正常赎回， 1 托管中 ,2提前赎回 (违约)3.取消
			String state = request.getParameter("state");
			data = financeOrderService.pagedQuery(pageNo, 10, partyId, state).getElements();
			// 如果不为空 则从理财产品中获取日利率 图片
			if (data == null) {
				resultObject.setData(data);
				resultObject.setCode("0");
				return resultObject;
			}
			
			List<FinanceOrder> data1 = new ArrayList<>();
			FinanceOrder order = new FinanceOrder();
			List<Finance> finances = financeService.findAll();
			Finance finance = new Finance();
			
			for (int i = 0; i < data.size(); i++) {
				order = data.get(i);
				for (int j = 0; j < finances.size(); j++) {
					finance = finances.get(j);
					if (finance.getId().equals(order.getFinanceId())) {
						break;
					}
				}
				// 取时间
				Date date_now = new Date();
				int days = daysBetween(date_now, order.getStop_time());
				if (days < 0) {
					days = 0;
				}
				order.setFinanceName(finance.getName());
				order.setFinanceName_cn(finance.getName_cn());
				order.setFinanceName_en(finance.getName_en());
				order.setDays(days);
				order.setClose_timeStr(DateUtils.format(order.getClose_time(), DateUtils.DF_yyyyMMdd));
				order.setCreate_timeStr(DateUtils.format(order.getCreate_time(), DateUtils.DF_yyyyMMdd));
				order.setDaily_rate(finance.getDaily_rate() + " ~ " + finance.getDaily_rate_max());
				String path = Constants.WEB_URL + "/public/showimg!showImg.action?imagePath=" + finance.getImg();
				order.setImg(path);
				
				data1.add(order);
			}
			
			resultObject.setData(data1);
			resultObject.setCode("0");
		} catch (BusinessException e) {
			resultObject.setCode("1");
			resultObject.setMsg(e.getMessage());
		} catch (Throwable t) {
			resultObject.setCode("1");
			resultObject.setMsg("程序错误");
			logger.error("error:", t);
		}

		return resultObject;

	}

	/**
	 * 收益统计
	 * 
	 */
	@RequestMapping(action + "listSum.action")
	public Object listSum() {

		ResultObject resultObject = new ResultObject();

		try {
			String partyId = getLoginPartyId();
			List<FinanceOrder> data = financeOrderService.findByState(partyId, "1");
			FinanceOrder order;
			Map<String, Object> map = new HashMap<String, Object>();

			// 金额总数
			double amount_sum = 0;
			// 预计今日盈利
			double today_profit = 0;
			// 已获收益
			double aready_profit = 0;
			// 订单数
			double order_sum = 0;

			if (data != null) {
				Map<String, Finance> financeMap = financeService.findFinanceMap();
				for (int i = 0; i < data.size(); i++) {
					order = data.get(i);
					Finance finance = financeMap.get(order.getFinanceId());
					order_sum = Arith.add(order_sum, 1);
					amount_sum = Arith.add(amount_sum, order.getAmount());
					aready_profit = Arith.add(aready_profit, order.getProfit());
					if (finance.getId().equals(order.getFinanceId())) {
						double finance_profit = Arith.mul(finance.getDaily_rate(), 0.01);
						double get_profit = Arith.mul(finance_profit, order.getAmount());
						today_profit = Arith.add(today_profit, get_profit);
					}
				}
			}
			map.put("amount_sum", new BigDecimal(amount_sum).setScale(3, RoundingMode.FLOOR).toPlainString());
			map.put("amountSumValue",new BigDecimal(amount_sum).setScale(3, RoundingMode.FLOOR).toPlainString());
			map.put("today_profit",new BigDecimal(today_profit).setScale(3, RoundingMode.FLOOR).toPlainString());
			map.put("aready_profit",new BigDecimal(aready_profit).setScale(3, RoundingMode.FLOOR).toPlainString());
			map.put("order_sum",new BigDecimal(order_sum).setScale(3, RoundingMode.FLOOR).toPlainString());
			map.put("buyCurrency", "usdt");
			map.put("outputCurrency", "usdt");
			map.put("amountSumValue",new BigDecimal(amount_sum).setScale(3, RoundingMode.FLOOR).toPlainString());
			map.put("areadyProfitValue",new BigDecimal(aready_profit).setScale(3, RoundingMode.FLOOR).toPlainString());
			map.put("todayProfitValue",new BigDecimal(today_profit).setScale(3, RoundingMode.FLOOR).toPlainString());
			resultObject.setData(map);
			resultObject.setCode("0");
		} catch (BusinessException e) {
			resultObject.setCode("1");
			resultObject.setMsg(e.getMessage());
		} catch (Throwable t) {
			resultObject.setCode("1");
			resultObject.setMsg("程序错误");
			logger.error("error:", t);
		}

		return resultObject;
	}

	/**
	 * 理财托管订单-详情
	 */
	@RequestMapping(action + "get.action")
	public Object get(HttpServletRequest request) {

		ResultObject resultObject = new ResultObject();
		resultObject = readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return resultObject;
		}
		try {
			String order_no = request.getParameter("order_no");
			FinanceOrder data = financeOrderService.findByOrder_no(order_no);

			// 如果不为空 则从理财产品中获取日利率 图片
			resultObject.setData(bulidData(data));
			resultObject.setCode("0");
		} catch (BusinessException e) {
			resultObject.setCode("1");
			resultObject.setMsg(e.getMessage());
		} catch (Throwable t) {
			resultObject.setCode("1");
			resultObject.setMsg("程序错误");
			logger.error("error:", t);
		}

		return resultObject;
	}

	/**
	 * 创建买入理财产品订单
	 * 
	 */
	@RequestMapping(action + "open.action")
	public Object open(HttpServletRequest request) {

		ResultObject resultObject = new ResultObject();
		resultObject = readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return resultObject;
		}
		String partyId = this.getLoginPartyId();
		try {
			String session_token = request.getParameter("session_token");
			String financeId = request.getParameter("financeId");
			String amount = request.getParameter("amount");
			
			Object object = this.sessionTokenService.cacheGet(session_token);
			this.sessionTokenService.del(session_token);
			if ((object == null) || (!this.getLoginPartyId().equals((String) object))) {
				resultObject.setCode("1");
				resultObject.setMsg("请稍后再试");
				return resultObject;
			}
			Party party = this.partyService.cachePartyBy(partyId, false);
			if (!party.getEnabled()) {
				resultObject.setCode("506");
				resultObject.setMsg(error);
				return resultObject;
			}

			FinanceOrder order = new FinanceOrder();
			order.setPartyId(partyId);
			order.setFinanceId(financeId);
			order.setAmount(Double.valueOf(amount));
			order.setOrder_no(DateUtil.getToday("yyMMddHHmmss") + RandomUtil.getRandomNum(8));
			order.setState("1");

			this.financeOrderService.saveCreate(order);
			Map<String, Object> map = new HashMap<String, Object>();
			map.put("order_no", order.getOrder_no());
			resultObject.setData(map);
			resultObject.setCode("0");
		} catch (BusinessException e) {
			resultObject.setCode("1");
			resultObject.setMsg(e.getMessage());
		} catch (Throwable t) {
			resultObject.setCode("1");
			resultObject.setMsg("程序错误");
			logger.error("error:", t);
		}
		return resultObject;
	}

	/**
	 * 获取订单
	 * 
	 */
	@RequestMapping(action + "getOpen.action")
	public Object getOpen(HttpServletRequest request) {

		ResultObject resultObject = new ResultObject();
		resultObject = readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return resultObject;
		}
		try {
			
			String financeId = request.getParameter("financeId");
			String amount_temp = request.getParameter("amount");
			
			Finance finance = financeService.findById(financeId);

			if (StringUtils.isNullOrEmpty(amount_temp) 
					|| !StringUtils.isDouble(amount_temp) 
					|| Double.valueOf(amount_temp) < 0) {
				throw new BusinessException("金额错误");
			}
			
			Double amount = Double.valueOf(amount_temp);

			Map<String, Object> map = new HashMap<String, Object>();
			if (finance != null) {
				String path = Constants.WEB_URL + "/public/showimg!showImg.action?imagePath=" + finance.getImg();
				map.put("img", path);
			}

			map.put("finance_name", finance.getName());
			map.put("finance_name_en", finance.getName_en());
			map.put("finance_name_cn", finance.getName_cn());
			map.put("finance_name_kn", finance.getName_kn());
			map.put("finance_name_jn", finance.getName_jn());
			map.put("cycle", finance.getCycle());
			String partyId = getLoginPartyId();
			if (!StringUtils.isNullOrEmpty(partyId)) {
				String session_token = sessionTokenService.savePut(partyId);
				map.put("session_token", session_token);
			}

			map.put("amount", amount);
			// 取时间
			Date date = new Date();

			map.put("create_time", DateUtils.format(date, DateUtils.DF_yyyyMMddHHmmss));
			Calendar calendar = new GregorianCalendar();
			calendar.setTime(date);
			calendar.add(calendar.DATE, 1);// 把日期往后增加一天.整数往后推
			date = calendar.getTime(); //

			// 起息时间
			map.put("earn_time", DateUtils.format(date, DateUtils.DF_yyyyMMdd));

			// 截止时间
			calendar.add(calendar.DATE, finance.getCycle() - 1);// 把日期往后增加周期.整数往后推
			date = calendar.getTime();
			map.put("stop_time", DateUtils.format(date, DateUtils.DF_yyyyMMdd));

			// 区间
			map.put("investment_min", finance.getInvestment_min());
			map.put("investment_max", finance.getInvestment_max());
			DecimalFormat df = new DecimalFormat("#.##");
			map.put("daily_rate", df.format(finance.getDaily_rate()) + "~" + df.format(finance.getDaily_rate_max()));
			map.put("daily_rate_max", finance.getDaily_rate_max());
			map.put("financeId", financeId);
			double rate = Arith.mul(finance.getDaily_rate(), 0.01);
			double rateMax = Arith.mul(finance.getDaily_rate_max(), 0.01);
			map.put("profit_may", Arith.mul(amount, Arith.mul(rate, finance.getCycle())) + "~"
					+ Arith.mul(amount, Arith.mul(rateMax, finance.getCycle())));
			map.put("order_no", DateUtil.getToday("yyMMddHHmmss") + RandomUtil.getRandomNum(8));
			map.put("buyCurrency", finance.getBuyCurrency());
			map.put("outputCurrency", finance.getOutputCurrency());

			resultObject.setData(map);
			resultObject.setCode("0");
		} catch (BusinessException e) {
			resultObject.setCode("1");
			resultObject.setMsg(e.getMessage());
		} catch (Throwable t) {
			resultObject.setCode("1");
			resultObject.setMsg("程序错误");
			logger.error("error:", t);
		} 
		return resultObject;
	}

	/**
	 * 赎回理财产品订单
	 * 
	 */
	@RequestMapping(action + "closOrder.action")
	public Object closOrder(HttpServletRequest request) {

		ResultObject resultObject = new ResultObject();
		resultObject = readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return resultObject;
		}
		try {
			String id = request.getParameter("id");
			FinanceOrder order = financeOrderService.findById(id);
			CloseDelayThread lockDelayThread = new CloseDelayThread(id, order.getOrder_no(), financeOrderService);
			Thread t = new Thread(lockDelayThread);
			t.start();
		} catch (BusinessException e) {
			resultObject.setCode("1");
			resultObject.setMsg(e.getMessage());
		} catch (Throwable t) {
			resultObject.setCode("1");
			resultObject.setMsg("程序错误");
			logger.error("error:", t);
		}
		return resultObject;
	}

	/**
	 * 新线程处理，直接拿到订单锁处理完成后退出
	 *
	 */
	public class CloseDelayThread implements Runnable {
		private String id;
		private String order_no;
		private FinanceOrderService financeOrderService;

		public void run() {
			try {
				while (true) {
					if (FinanceOrderLock.add(order_no)) {
						/**
						 * 提前赎回理财产品需要支付违约金
						 */
						FinanceOrder order = financeOrderService.findById(id);
						Finance finance = financeService.findById(order.getFinanceId());
						// order.setDays(daysBetween(order.getEarn_time(), order.getStop_time()));
						if ("1".equals(order.getState())) {
							/**
							 * 扣除违约金
							 */
							Date date_now = new Date();// 取时间
							double last_days = daysBetween(date_now, order.getStop_time());
							if (last_days <= 0) {
								last_days = 1;
							}
							double default_ratio = Arith.mul(finance.getDefault_ratio(), 0.01);
							default_ratio = Arith.mul(default_ratio, last_days);
							double breach_amount = Arith.mul(order.getAmount(), default_ratio);
							order.setProfit(Arith.sub(0, breach_amount));
							order.setState("2");

							this.financeOrderService.saveClose(order);

						}
						/**
						 * 处理完退出
						 */
						break;
					}
					ThreadUtils.sleep(500);

				}

			} catch (Throwable t) {
				logger.error("error:", t);
			} finally {
				FinanceOrderLock.remove(order_no);
			}

		}

		public CloseDelayThread(String id, String order_no, FinanceOrderService financeOrderService) {
			this.id = id;
			this.order_no = order_no;
			this.financeOrderService = financeOrderService;
		}

	}

	public Map<String, Object> bulidData(FinanceOrder order) throws ParseException {
		Finance finance = new Finance();
		finance = financeService.findById(order.getFinanceId());

		DecimalFormat df = new DecimalFormat("#.##");
		Map<String, Object> map = new HashMap<String, Object>();
		map.put("img", Constants.WEB_URL + "/public/showimg!showImg.action?imagePath=" + finance.getImg());
		map.put("daily_rate", df.format(finance.getDaily_rate()) + "~" + df.format(finance.getDaily_rate_max()));
		map.put("daily_rate_min", finance.getDaily_rate());
		map.put("daily_rate_max", finance.getDaily_rate_max());
		map.put("create_timeStr", DateUtils.format(order.getCreate_time(), DateUtils.DF_yyyyMMddHHmmss));
		map.put("close_timeStr", DateUtils.format(order.getClose_time(), DateUtils.DF_yyyyMMddHHmmss));
		/**
		 * 此处将截止时间传回
		 */
		map.put("stop_timeStr", DateUtils.format(order.getClose_time(), DateUtils.DF_yyyyMMdd));
		map.put("earn_timeStr", DateUtils.format(order.getEarn_time(), DateUtils.DF_yyyyMMdd));
		Date date_now = new Date();// 取时间
		int days = daysBetween(date_now, order.getStop_time());
		if (days < 0) {
			days = 0;
		}
		map.put("days", days);
		double rate = Arith.mul(finance.getDaily_rate(), 0.01);
		double rateMax = Arith.mul(finance.getDaily_rate_max(), 0.01);
		map.put("profit_may", Arith.mul(order.getAmount(), Arith.mul(rate, finance.getCycle())) + "~"
				+ Arith.mul(order.getAmount(), Arith.mul(rateMax, finance.getCycle())));
		map.put("order_no", order.getOrder_no());
		map.put("amount", order.getAmount());
		map.put("cycle", order.getCycle());
		map.put("id", order.getId());
		map.put("name", finance.getName());
		map.put("name_en", finance.getName_en());
		map.put("name_cn", finance.getName_cn());
		map.put("name_kn", finance.getName_kn());
		map.put("name_jn", finance.getName_jn());
		map.put("buyCurrency", finance.getBuyCurrency());
		map.put("outputCurrency", finance.getOutputCurrency());

		map.put("state", order.getState());
		if ("1".equals(order.getState())) {

			map.put("profit", order.getProfit());

			double rate_order = Arith.mul(finance.getDefault_ratio(), 0.01);
			double last_days = daysBetween(date_now, order.getStop_time());
			if (last_days <= 0) {
				last_days = 1;
			}
			double default_amount = 0;
			default_amount = Arith.mul(order.getAmount(), Arith.mul(rate_order, last_days));
			map.put("default_amount", default_amount);
			double principal_amount = Arith.sub(order.getAmount(), default_amount);
			if (principal_amount < 0) {
				principal_amount = 0;
			}
			map.put("principal_amount", principal_amount);

		}
		if ("2".equals(order.getState())) {
			map.put("profit", 0);
			map.put("default_amount", df.format(Arith.sub(0, order.getProfit())));
			map.put("principal_amount", df.format(Arith.add(order.getAmount(), order.getProfit())));
		}
		if ("0".equals(order.getState())) {
			map.put("profit", order.getProfit());
			map.put("default_amount", 0);
			map.put("principal_amount", df.format(Arith.add(order.getAmount(), order.getProfit())));
		}

		return map;

	}

	public static int daysBetween(Date smdate, Date bdate) throws ParseException {
		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
		smdate = sdf.parse(sdf.format(smdate));
		bdate = sdf.parse(sdf.format(bdate));
		Calendar cal = Calendar.getInstance();
		cal.setTime(smdate);
		long time1 = cal.getTimeInMillis();
		cal.setTime(bdate);
		long time2 = cal.getTimeInMillis();
		long between_days = (time2 - time1) / (1000 * 3600 * 24);

		return Integer.parseInt(String.valueOf(between_days));
	}

}