package project.web.admin;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import kernel.bo.RecordObjectMapper;
import kernel.web.ApplicationUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.ModelAndView;

import kernel.exception.BusinessException;
import kernel.util.JsonUtils;
import kernel.util.StringUtils;
import kernel.web.Page;
import kernel.web.PageActionSupport;
import project.Constants;
import project.futures.AdminFuturesOrderService;
import project.futures.FuturesOrder;
import project.futures.FuturesOrderService;
import project.futures.FuturesRedisKeys;
import project.item.ItemService;
import project.item.model.Item;
import project.redis.RedisHandler;
import project.wallet.Wallet;

/**
 * 交割合约单
 */
@RestController
public class AdminFuturesOrderController extends PageActionSupport {

    @Autowired
    private ItemService itemService;

    @Autowired
    private FuturesOrderService futuresOrderService;

    protected RedisHandler redisHandler;

    @Autowired
    private AdminFuturesOrderService adminFuturesOrderService;

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

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

    /**
     * 获取 交割合约单 列表
     * <p>
     * symbol_para 币种
     * direction_para 方向
     * volume_para 下单金额
     * symbol_map 上线币种
     */
    @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 status_para = request.getParameter("status_para");
        String rolename_para = request.getParameter("rolename_para");
        String name_para = request.getParameter("name_para");
        String order_no_para = request.getParameter("order_no_para");
        String symbol_para = request.getParameter("symbol_para");
        String direction_para = request.getParameter("direction_para");
        String volume_para = request.getParameter("volume_para");

        ModelAndView modelAndView = new ModelAndView();
        modelAndView.setViewName("futures_order_list");

        Map<String, String> symbol_map = new HashMap<String, String>();

        int pageNo = 1;
        Page page = null;
        int pageSize = 30;
        try {
            List<Item> items = this.itemService.cacheGetAll();
            for (Item item : items) {
                symbol_map.put(item.getSymbol(), item.getSymbol());
            }

            pageNo = checkAndSetPageNo(pageNoStr);

            Double volume_para_double = null;
            if (StringUtils.isNullOrEmpty(volume_para)) {
                volume_para_double = null;
            } else {
                if (!StringUtils.isDouble(volume_para)) {
                    throw new BusinessException("下单金额不是浮点数");
                }
                if (Double.valueOf(volume_para).doubleValue() < 0) {
                    throw new BusinessException("下单金额不能小于0");
                }

                volume_para_double = Double.valueOf(volume_para).doubleValue();
            }

            String loginPartyId = this.getLoginPartyId();
            page = this.adminFuturesOrderService.pagedQuery(pageNo, pageSize, status_para,
                    rolename_para, loginPartyId, name_para, order_no_para, symbol_para, direction_para, volume_para_double);

            List<Map> list = page.getElements();
            for (int i = 0; i < list.size(); i++) {
                Map map = list.get(i);
                if (null == map.get("rolename")) {
                    map.put("roleNameDesc", "");
                } else {
                    String roleName = map.get("rolename").toString();
                    map.put("roleNameDesc", Constants.ROLE_MAP.containsKey(roleName) ? Constants.ROLE_MAP.get(roleName) : roleName);
                }
            }

        } 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("status_para", status_para);
        modelAndView.addObject("rolename_para", rolename_para);
        modelAndView.addObject("name_para", name_para);
        modelAndView.addObject("order_no_para", order_no_para);
        modelAndView.addObject("symbol_para", symbol_para);
        modelAndView.addObject("direction_para", direction_para);
        modelAndView.addObject("volume_para", volume_para);
        modelAndView.addObject("symbol_map", symbol_map);
        return modelAndView;
    }

    @RequestMapping(action + "saveRemark.action")
    public ModelAndView saveRemark(HttpServletRequest request) {
        String orderNo = request.getParameter("orderNo");
        String remark = request.getParameter("remark");
        ModelAndView modelAndView = new ModelAndView();
        modelAndView.setViewName("futures_order_list");

        try {
            FuturesOrder byOrderNo = futuresOrderService.findByOrderNo(orderNo);

            if(null != byOrderNo){
                List<FuturesOrder> query = futuresOrderService.findByPartyId(byOrderNo.getPartyId().toString());
                for (FuturesOrder f : query) {
                    System.out.println("修改之前==="+f);
                    f.setRemark(remark);
                    ApplicationUtil.executeUpdate(f);
                    System.out.println("修改之后==="+f);
                    futuresOrderService.updateCache(f.getOrder_no(), f);
                    redisHandler.setSync(FuturesRedisKeys.FUTURES_SUBMITTED_ORDERNO + f.getOrder_no(),f);
                }
            }
        } 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;
        }

        return modelAndView;
    }

    /**
     * 获取 交割合约单 列表
     * <p>
     * symbol_para 币种
     * direction_para 方向
     * volume_para 下单金额
     */
    @RequestMapping(action + "holdings_list.action")
    public ModelAndView holdings_list(HttpServletRequest request) {
        String pageNoStr = request.getParameter("pageNo");
        String message = request.getParameter("message");
        String error = request.getParameter("error");
        String rolename_para = request.getParameter("rolename_para");
        String name_para = request.getParameter("name_para");
        String order_no_para = request.getParameter("order_no_para");
        String symbol_para = request.getParameter("symbol_para");
        String direction_para = request.getParameter("direction_para");
        String volume_para = request.getParameter("volume_para");

        ModelAndView modelAndView = new ModelAndView();
        modelAndView.setViewName("futures_holdings_list");

        int pageNo = 1;
        int pageSize = 30;
        try {
            pageNo = checkAndSetPageNo(pageNoStr);
            if (StringUtils.isNullOrEmpty(volume_para)) {
                throw new BusinessException("下单金额必填");
            }
            if (!StringUtils.isDouble(volume_para)) {
                throw new BusinessException("下单金额不是浮点数");
            }
            if (Double.valueOf(volume_para).doubleValue() <= 0) {
                throw new BusinessException("下单金额不能小于等于0");
            }

            double volume_para_double = Double.valueOf(volume_para).doubleValue();

            String loginPartyId = this.getLoginPartyId();
            page = this.adminFuturesOrderService.pagedQuery(pageNo, pageSize, "submitted",
                    rolename_para, loginPartyId, name_para, order_no_para, symbol_para, direction_para, volume_para_double);

            List<Map> list = page.getElements();
            for (int i = 0; i < list.size(); i++) {
                Map map = list.get(i);
                if (null == map.get("rolename")) {
                    map.put("roleNameDesc", "");
                } else {
                    String roleName = map.get("rolename").toString();
                    map.put("roleNameDesc",
                            Constants.ROLE_MAP.containsKey(roleName) ? Constants.ROLE_MAP.get(roleName) : roleName);
                }
            }

        } 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("rolename_para", rolename_para);
        modelAndView.addObject("name_para", name_para);
        modelAndView.addObject("order_no_para", order_no_para);
        modelAndView.addObject("symbol_para", symbol_para);
        modelAndView.addObject("direction_para", direction_para);
        modelAndView.addObject("volume_para", volume_para);
        return modelAndView;
    }

    /**
     * ajax定时获取表
     * <p>
     * symbol_para 币种
     * direction_para 方向
     * volume_para 下单金额
     */
    @RequestMapping(action + "getValue.action")
    public String getValue(HttpServletRequest request) {
        String pageNoStr = request.getParameter("pageNo");
        String rolename_para = request.getParameter("rolename_para");
        String name_para = request.getParameter("name_para");
        String order_no_para = request.getParameter("order_no_para");
        String symbol_para = request.getParameter("symbol_para");
        String direction_para = request.getParameter("direction_para");
        String volume_para = request.getParameter("volume_para");

        int pageNo = 1;
        Page page = null;
        int pageSize = 30;
        try {
            pageNo = checkAndSetPageNo(pageNoStr);
            if (StringUtils.isNullOrEmpty(volume_para)) {
                throw new BusinessException("下单金额必填");
            }
            if (!StringUtils.isDouble(volume_para)) {
                throw new BusinessException("下单金额不是浮点数");
            }
            if (Double.valueOf(volume_para).doubleValue() <= 0) {
                throw new BusinessException("下单金额不能小于等于0");
            }

            double volume_para_double = Double.valueOf(volume_para).doubleValue();

            String loginPartyId = this.getLoginPartyId();
            page = this.adminFuturesOrderService.pagedQuery(pageNo, pageSize, "submitted",
                    rolename_para, loginPartyId, name_para, order_no_para, symbol_para, direction_para, volume_para_double);

        } catch (BusinessException e) {
            return JsonUtils.getJsonString(new ArrayList());
        } catch (Throwable t) {
            logger.error(" error ", t);
            return JsonUtils.getJsonString(new ArrayList());
        }

        return JsonUtils.getJsonString(page.getElements());
    }

    /**
     * orderProfitLoss
     * <p>
     * profit_loss 盈利还是亏损
     */
    @RequestMapping(action + "orderProfitLoss.action")
    public ModelAndView orderProfitLoss(HttpServletRequest request) {
        String order_no = request.getParameter("order_no");
        String profit_loss = request.getParameter("profit_loss");

        ModelAndView modelAndView = new ModelAndView();
        modelAndView.setViewName("redirect:/" + action + "list.action");

        try {
            String error = this.futuresOrderService.saveOrderPorfitOrLoss(order_no, profit_loss, this.getUsername_login());
            if (StringUtils.isNotEmpty(error)) {
                throw new BusinessException(error);
            }
        } 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;
    }

    /**
     * 交割合约一键场控
     * <p>
     * profit_loss 盈利还是亏损
     */
    @RequestMapping(action + "orderProfitLossList.action")
    public ModelAndView orderProfitLossList(HttpServletRequest request) {
        ModelAndView modelAndView = new ModelAndView();
        modelAndView.setViewName("redirect:/" + action + "list.action");
        String stringOrderNo = request.getParameter("orderNos");
        String action = request.getParameter("action");
        logger.info("orderNos:"+stringOrderNo.toString()+"-----action:"+action);
        String[] orderNos = stringOrderNo.split(",");
        List<String> errorList = new ArrayList<>();
        try {
            for (String orderNo : orderNos) {
                logger.info("------->"+orderNo);
                String error = this.futuresOrderService.saveOrderPorfitOrLoss(orderNo, action, this.getUsername_login());
                if (StringUtils.isNotEmpty(error)) {
                    error = "订单号："+orderNo+",原因："+error;
                    errorList.add(error);
                }
            }
            if(errorList.size() > 0){
                throw new BusinessException("部分订单操作失败："+errorList.toString());
            }
        } 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;
    }

}