package project.web.admin;

import java.math.BigDecimal;
import java.text.MessageFormat;
import java.util.Date;
import java.util.HashMap;
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.JsonUtils;
import kernel.util.StringUtils;
import kernel.util.ThreadUtils;
import kernel.web.Page;
import kernel.web.PageActionSupport;
import project.Constants;
import project.contract.AdminMarketQuotationsService;
import project.data.AdjustmentValue;
import project.data.AdjustmentValueService;
import project.data.DataCache;
import project.data.DataService;
import project.data.model.Realtime;
import project.item.ItemService;
import project.item.model.Item;
import project.log.LogService;
import security.SecUser;
import security.internal.SecUserService;

/**
 * 行情数据
 *
 */
@RestController
public class AdminMarketQuotationsManageController extends PageActionSupport {
	
	@Autowired
	private LogService logService;
	
	@Autowired
	private ItemService itemService;
	
	@Autowired
	private DataService dataService;
	
	@Autowired
	private SecUserService secUserService;
	
	@Autowired
	private AdjustmentValueService adjustmentValueService;
	
	@Autowired
	private AdminMarketQuotationsService adminMarketQuotationsService;
	
	private final String action = "normal/adminMarketQuotationsManageAction!";
	
	private static final Logger logger = LoggerFactory.getLogger(AdminMarketQuotationsManageController.class);

	/**
	 * 列表
	 */
	@RequestMapping(action + "list.action")
	public ModelAndView list(HttpServletRequest request) {
		String message = request.getParameter("message");
		String error = request.getParameter("error");
		
		int pageSize = 30;
		int pageNo=checkAndSetPageNo(request.getParameter("pageNo"));
		Page page = this.adminMarketQuotationsService.pageQuery(pageNo, pageSize);
		
		ModelAndView model = new ModelAndView();
		model.addObject("pageNo", pageNo);
		model.addObject("pageSize", pageSize);
		model.addObject("page", page);
		model.addObject("message", message);
		model.addObject("error", error);
		model.setViewName("market_quotations_list");
		return model;
	}

	/**
	 * 行情管理-调整弹框显示
	 */
	@RequestMapping(action + "showModal.action")
	public String showModal(HttpServletRequest request) {
		
		String symbol = request.getParameter("symbol");
		
		Map<String, Object> resultMap = new HashMap<String, Object>();
		Realtime realtime = DataCache.getRealtime(symbol);
		if (realtime == null) {
			realtime = this.dataService.realtime(symbol).get(0);
		}
		Item item = this.itemService.cacheBySymbol(symbol, false);
		Double currentValues = this.adjustmentValueService.getCurrentValue(symbol);
		String currentValue = new BigDecimal(String.valueOf(currentValues)).toPlainString();
		if (currentValue == null) {
			resultMap.put("adjust_value", 0D);
		} else {
			resultMap.put("adjust_value", currentValue);
		}
		if (currentValue == null) {
			resultMap.put("new_price", realtime.getClose());
		} else {
			resultMap.put("new_price", Arith.sub(realtime.getClose(), currentValues));
		}

		resultMap.put("pips",new BigDecimal(String.valueOf(item.getPips())).toPlainString());
		resultMap.put("totalPrice",new BigDecimal(String.valueOf(realtime.getClose()+currentValues)).toPlainString());
		AdjustmentValue delayValue = this.adjustmentValueService.getDelayValue(symbol);

		if (delayValue != null) {
			resultMap.put("delay_value", delayValue.getValue());
			resultMap.put("delay_second", delayValue.getSecond());
		}
		return JsonUtils.getJsonString(resultMap);
	}

	/**
	 * 页面计算
	 * 
	 */
	@RequestMapping(action + "getValue.action")
	public String getValue(HttpServletRequest request) {
		if (!StringUtils.isNullOrEmpty(getLoginPartyId())) {
			return "";
		}
		
		String symbol = request.getParameter("symbol");
		// 0增加一个pips 1减少一个pips 2直接修改调整值
		String type_temp = request.getParameter("type");
		String value_temp = request.getParameter("value");
		
		Double type = Double.valueOf(type_temp);
		Double value = Double.valueOf(value_temp);

		Map<String, Object> resultMap = new HashMap<String, Object>();

		Realtime realtime = null;

		if (realtime == null) {
			realtime = this.dataService.realtime(symbol).get(0);
		}
		Item item = this.itemService.cacheBySymbol(symbol, false);
		Double currentValue = this.adjustmentValueService.getCurrentValue(symbol);
		if (currentValue == null) {
			resultMap.put("new_price", realtime.getClose());
		} else {
			resultMap.put("new_price", Arith.sub(realtime.getClose(), currentValue));
		}

		double temp;
		if (type == 0) {
			temp = Arith.add(value, item.getPips());
			// 调整量
			resultMap.put("adjust_current_value",new BigDecimal(String.valueOf(temp)).toPlainString());
			// 调整后的值
			resultMap.put("adjust_value_after",new BigDecimal(String.valueOf(Arith.add(realtime.getClose(), temp))).toPlainString());
		} else if (type == 1) {
			temp = Arith.sub(value, item.getPips());

			resultMap.put("adjust_current_value", new BigDecimal(String.valueOf(temp)).toPlainString());
			resultMap.put("adjust_value_after",new BigDecimal(String.valueOf(Arith.add(realtime.getClose(), temp))).toPlainString());
		} else {
			temp = value;
			resultMap.put("adjust_current_value", new BigDecimal(String.valueOf(temp)).toPlainString());
			resultMap.put("adjust_value_after",new BigDecimal(String.valueOf(Arith.add(realtime.getClose(), temp))).toPlainString());
		}

		if (currentValue == null) {
			resultMap.put("adjust_value",new BigDecimal(String.valueOf(item.getPips())).toPlainString());
		} else {
			resultMap.put("adjust_value",new BigDecimal(String.valueOf(Arith.add(temp, currentValue))).toPlainString());
		}
		AdjustmentValue delayValue = this.adjustmentValueService.getDelayValue(symbol);

		if (delayValue != null) {
			resultMap.put("delay_value", delayValue.getValue());
			resultMap.put("delay_second", delayValue.getSecond());
		}

		return JsonUtils.getJsonString(resultMap);
	}

	/**
	 * 调整
	 */
	@RequestMapping(action + "adjust.action")
	public ModelAndView adjust(HttpServletRequest request) {
		ModelAndView model = new ModelAndView();
		String message = "";
		String error = "";
		
		// 调整值
		String value = request.getParameter("value");
		String symbol = request.getParameter("symbol");
		// 延迟秒
		String second = request.getParameter("second");
		
		if (StringUtils.isNullOrEmpty(value)) {
			throw new BusinessException("调整值不能为空!");
		}
		try {
			
			Double currentValue = this.adjustmentValueService.getCurrentValue(symbol);
			if (currentValue == null) {
				Realtime realtime =  this.dataService.realtime(symbol).get(0);;
				currentValue=realtime.getClose();
			} 
			SecUser sec = this.secUserService.findUserByLoginName(this.getUsername_login());
			String log = MessageFormat.format("ip:"+this.getIp()+",管理员调整行情,币种:{0},原值:{1},调整值:{2},调整时间:{3}", 
					symbol,new BigDecimal(currentValue).toPlainString(),new BigDecimal(value).toPlainString(),second);
			
			this.adjustmentValueService.adjust(symbol, Double.valueOf(value), Double.valueOf(second));
			saveLog(sec, this.getUsername_login(), log);
			
			ThreadUtils.sleep(1000);
			message = "操作成功";
		} catch (BusinessException e) {
		    error = e.getMessage();
		} catch (Exception e) {
			logger.error("error ", e);
			error = "程序错误";
		}
		model.addObject("message", message);
		model.addObject("error", error);
		model.setViewName("redirect:/" + action + "list.action");
	    return model;
	}

	public void saveLog(SecUser secUser, String operator,String context) {
		project.log.Log log = new project.log.Log();
		log.setCategory(Constants.LOG_CATEGORY_OPERATION);
		log.setOperator(operator);
		log.setUsername(secUser.getUsername());
		log.setPartyId(secUser.getPartyId());
		log.setLog(context);
		log.setCreateTime(new Date());
		logService.saveSync(log);
	}	
}