package com.cjs.site.biz.ec;

import java.text.DateFormat;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.cjs.site.dao.entrust.HisOtcEntrustDao;
import com.cjs.site.dao.entrust.HisOtcRealTimeDao;
import com.cjs.site.dao.entrust.OtcRealTimeDao;
import com.cjs.site.model.entrust.HisOtcEntrustInfo;
import com.cjs.site.model.user.account.UserInfo;
import com.cjs.site.util.lang.DateEnum;
import com.cjs.site.util.lang.DateUtil;
import com.cjs.site.util.lang.JsonUtil;
import com.cjs.site.util.lang.StringUtil;
import com.cjs.site.util.t2.T2Result;
import com.cjs.site.util.t2.T2Util;
import com.cjs.site.util.web.ActionUtil;
import com.cjs.site.util.web.PageUtils;

/**
 * 买入/卖出
 * 
 * @author tongyufu
 *
 */
@Service
public class EcEntrustBiz {

    Logger                    log        = LogManager.getLogger();
    @Autowired
    private OtcRealTimeDao    otcRealTimeDao;
    @Autowired
    private HisOtcRealTimeDao hisOtcRealTimeDao;
    @Autowired
    private HisOtcEntrustDao  hisOtcEntrustDao;
    private static DateFormat timeParse  = new SimpleDateFormat("HHmmss");
    private static DateFormat timeFormat = new SimpleDateFormat("HH:mm:ss");

    /**
     * 委托卖单
     * 
     * @param clientId 会员号
     * @param password 登录密码（未加密）
     * @param otcAccount 资产账号
     * @param otcCode 藏品代码
     * @param entrustAmount 委托数量
     * @param entrustPrice 委托价格
     */
    public Map<String, Object> sell(String clientId, String password, String otcAccount,
                                    String otcCode, Integer entrustAmount, Double entrustPrice) {
        T2Result result = this.entrust(clientId, password, otcAccount, otcCode, entrustAmount,
            entrustPrice, "0S0");
        log.info("委托卖单：" + result);
        Map<String, Object> outmap = new HashMap<String, Object>();
        if (0 == result.getCode()) {
            outmap.put("resultCode", 1);
            outmap.put("resultMsg", "委托成功");
        } else {
            outmap.put("resultCode", 0);
            outmap.put("resultMsg", "委托失败：" + result.getError().getErrorInfo());
        }
        return outmap;
    }

    /**
     * 委托买单
     * 
     * @param clientId 会员号
     * @param password 登录密码（未加密）
     * @param otcAccount 资产账号
     * @param otcCode 藏品代码
     * @param entrustAmount 委托数量
     * @param entrustPrice 委托价格
     */
    public Map<String, Object> buy(String clientId, String password, String otcAccount,
                                   String otcCode, Integer entrustAmount, Double entrustPrice) {
        T2Result result = this.entrust(clientId, password, otcAccount, otcCode, entrustAmount,
            entrustPrice, "0B0");
        log.info("委托买单：" + result);
        Map<String, Object> outmap = new HashMap<String, Object>();
        if (0 == result.getCode()) {
            outmap.put("resultCode", 1);
            outmap.put("resultMsg", "委托成功");
        } else {
            outmap.put("resultCode", 0);
            outmap.put("resultMsg", "委托失败：" + result.getError().getErrorInfo());
        }
        return outmap;
    }

    /**
     * 普通委托
     * 
     * @param clientId 会员号
     * @param password 登录密码（未加密）
     * @param otcAccount 资产账号
     * @param otcCode 藏品代码
     * @param entrustAmount 委托数量
     * @param entrustPrice 委托价格
     * @param otcProp 0B0:买；0S0:卖
     */
    private T2Result entrust(String clientId, String password, String otcAccount, String otcCode,
                             Integer entrustAmount, Double entrustPrice, String otcProp) {
        Map<String, Object> params = new HashMap<String, Object>();
        params.put("op_branch_no", "11");
        params.put("op_entrust_way", "7");
        params.put("op_station", "192168010062");
        params.put("branch_no", "11");
        params.put("client_id", clientId);
        params.put("fund_account", clientId);
        params.put("password", password);
        params.put("password_type", "");
        params.put("user_token", " ");
        params.put("otcexch_type", "O1");
        params.put("otc_account", otcAccount);
        params.put("otc_code", otcCode);
        params.put("entrust_amount", entrustAmount);
        params.put("entrust_price", entrustPrice);
        params.put("otc_prop", otcProp);
        params.put("batch_no", "11");

        return T2Util.request(params, "619003");
    }

    /**
     * 查询用户持仓
     * @return
     */
    public List<Map<String, Object>> queryUserPosition(String otcCode) {
        UserInfo userInfo = ActionUtil.getUser();
        if (userInfo == null) {
            return null;
        }
        //持仓查询 619008
        Map<String, Object> params = new HashMap<String, Object>();
        params.put("op_branch_no", "11");
        params.put("op_entrust_way", "7");
        params.put("op_station", "192168010221");
        params.put("branch_no", "11");
        params.put("client_id", userInfo.getClient_id());
        params.put("fund_account", userInfo.getFund_account());
        params.put("password", userInfo.getPassword());
        params.put("user_token", " ");
        params.put("otcexch_type", "");
        params.put("otc_account", userInfo.getOtc_account());
        if (StringUtil.isBlank(otcCode)) {
            params.put("otc_code", "");
        } else {
            params.put("otc_code", otcCode);
        }
        params.put("position_str", "");
        params.put("request_num", "2000");

        T2Result result = T2Util.request(params, "619008");
        List<Map<String, Object>> list = result.getData();
        for (Map<String, Object> map : list) {
            String per = String.format(
                "%.2f",
                100 * (Double.parseDouble(map.get("last_price").toString())
                       - Double.parseDouble(map.get("cost_price").toString()))
                        / Double.parseDouble(map.get("cost_price").toString()));
            map.put("per", per);
        }
        log.info("持仓查询619008:" + list);

        return list;
    }

    /**
     * 当日委托信息查询
     * @return
     */
    public String queryUserEntrust() {
        UserInfo userInfo = ActionUtil.getUser();
        if (userInfo == null) {
            return null;
        }
        //当日订单查询 619006
        Map<String, Object> params = new HashMap<String, Object>();
        params.put("op_branch_no", "11");
        params.put("op_entrust_way", "7");
        params.put("op_station", "192168010221");
        params.put("branch_no", "11");
        params.put("client_id", userInfo.getClient_id());
        params.put("fund_account", userInfo.getFund_account());
        params.put("password", userInfo.getPassword());
        params.put("user_token", " ");
        params.put("otcexch_type", "");
        params.put("otc_account", "");
        params.put("otc_code", "");
        params.put("query_type", "1");
        params.put("request_num", "2000");
        params.put("position_str", "");

        T2Result result = T2Util.request(params, "619006");
        List<Map<String, Object>> list = result.getData();
        for (Map<String, Object> map : list) {
            if ("0B0".equals(map.get("otc_prop"))) {
                map.put("otc_prop", "普通买单");
            } else if ("0S0".equals(map.get("otc_prop"))) {
                map.put("otc_prop", "普通卖单");
            }
            if ("0".equals(map.get("entrust_status"))) {
                map.put("entrust_status", "未报");
            } else if ("1".equals(map.get("entrust_status"))) {
                map.put("entrust_status", "待报");
            } else if ("2".equals(map.get("entrust_status"))) {
                map.put("entrust_status", "已报");
            } else if ("3".equals(map.get("entrust_status"))) {
                map.put("entrust_status", "已报待撤");
            } else if ("4".equals(map.get("entrust_status"))) {
                map.put("entrust_status", "部成待撤");
            } else if ("5".equals(map.get("entrust_status"))) {
                map.put("entrust_status", "部撤");
            } else if ("6".equals(map.get("entrust_status"))) {
                map.put("entrust_status", "已撤");
            } else if ("7".equals(map.get("entrust_status"))) {
                map.put("entrust_status", "部成");
            } else if ("8".equals(map.get("entrust_status"))) {
                map.put("entrust_status", "已成");
            } else if ("9".equals(map.get("entrust_status"))) {
                map.put("entrust_status", "废单");
            } else if ("C".equals(map.get("entrust_status"))) {
                map.put("entrust_status", "正报");
            } else if ("W".equals(map.get("entrust_status"))) {
                map.put("entrust_status", "待确认");
            }
            String entrustTime = DateUtil.parseDate(
                DateUtil.parseDate(map.get("entrust_time").toString(), DateEnum.UNSIGNED_TIME),
                DateEnum.TIME);
            map.put("entrust_time", entrustTime);
        }
        log.info("当日委托信息查询619006:" + result.getData());
        return JsonUtil.toJson(result.getData());
    }

    /**
     * 用户当日成交查询
     * @return
     */
    public List<Map<String, Object>> queryUserTransaction() {
        UserInfo userInfo = ActionUtil.getUser();
        if (userInfo == null) {
            return null;
        }
        //当日成交查询 619007
        Map<String, Object> params = new HashMap<String, Object>();
        params.put("op_branch_no", "11");
        params.put("op_entrust_way", "7");
        params.put("op_station", "192168010221");
        params.put("branch_no", "11");
        params.put("client_id", userInfo.getClient_id());
        params.put("fund_account", userInfo.getFund_account());
        params.put("password", userInfo.getPassword());
        params.put("user_token", " ");
        params.put("otcexch_type", "");
        params.put("otc_account", "");
        params.put("otc_code", "");
        params.put("query_direction", "1");
        params.put("position_str", "");
        params.put("request_num", "2000");

        T2Result result = T2Util.request(params, "619007");
        log.info("当日订单查询619007:" + result);
        List<Map<String, Object>> list = result.getData();
        for (Map<String, Object> map : list) {
            if ("0B0".equals(map.get("otc_prop"))) {
                map.put("otc_prop", "普通买单");
            } else if ("0S0".equals(map.get("otc_prop"))) {
                map.put("otc_prop", "普通卖单");
            } else if ("0C2".equals(map.get("otc_prop"))) {
                map.put("otc_prop", "普通撤单");
            }
            if ("0".equals(map.get("real_status"))) {
                map.put("real_status", "成交");
            } else if ("2".equals(map.get("real_status"))) {
                map.put("real_status", "废单");
            } else if ("4".equals(map.get("real_status"))) {
                map.put("real_status", "确认");
            }
            String businessTime = DateUtil.parseDate(
                DateUtil.parseDate(map.get("business_time").toString(), DateEnum.UNSIGNED_TIME),
                DateEnum.TIME);
            map.put("business_time", businessTime);
        }
        return result.getData();
    }

    /**
     * 查询当日成交汇总
     * @return
     */
    public List<Map<String, Object>> queryUserTransactionTotal() {
        List<Map<String, Object>> list = this.queryUserTransaction();
        List<Map<String, Object>> oper = new ArrayList<Map<String, Object>>();
        Map<String, Object> omap = new HashMap<String, Object>();
        Map<String, Object> otcmap = new HashMap<String, Object>();
        double totalPrice;
        int total;
        for (Map<String, Object> map : list) {
            totalPrice = 0;
            total = 0;
            if (!StringUtil
                .isBlank(otcmap.get(map.get("otc_code").toString() + map.get("otc_prop")))) {
                continue;
            }
            otcmap.put(map.get("otc_code").toString() + map.get("otc_prop"), map.get("otc_code"));
            for (Map<String, Object> map1 : list) {
                if (map1.get("otc_code").equals(map.get("otc_code"))
                    && map1.get("otc_prop").equals(map.get("otc_prop"))) {
                    totalPrice += Double.parseDouble(map1.get("business_price").toString());
                    total += (int) Double.parseDouble(map1.get("business_amount").toString());
                }
            }
            if (total != 0) {
                omap.put("otc_code", map.get("otc_code"));
                omap.put("otc_name", map.get("otc_name"));
                omap.put("otc_prop", map.get("otc_prop"));
                omap.put("average_price", totalPrice / total);
                omap.put("total", total);
                oper.add(omap);
            }
        }
        return oper;
    }

    /**
     * 查询历史成交记录
     * @param params
     * @return
     */
    public String queryHisOtcRealTime(Map<String, Object> params) {
        params.put("rows", "15");
        PageUtils.processOralcePage(params);
        return JsonUtil.toJson(hisOtcRealTimeDao.search(params));
    }

    /**
     * 最大可买查询
     * @param otcCode
     * @return
     */
    public Map<String, Object> queryMaxBuyAmount(String otcCode, String sellPrice) {
        UserInfo userInfo = ActionUtil.getUser();
        Map<String, Object> params = new HashMap<String, Object>();
        //最大可买查询 619001
        params.put("op_branch_no", "11");
        params.put("op_entrust_way", "7");
        params.put("op_station", "192168010221");
        params.put("branch_no", "11");
        params.put("client_id", userInfo.getClient_id());
        params.put("fund_account", userInfo.getFund_account());
        params.put("password", userInfo.getPassword());
        params.put("user_token", " ");
        params.put("otcexch_type", "O1");
        params.put("otc_account", userInfo.getOtc_account());
        params.put("otc_code", otcCode);
        params.put("entrust_price", sellPrice);
        params.put("otc_prop", "0B0");

        T2Result result = T2Util.request(params, "619001");
        log.info("当日订单查询619001:" + result);

        return result.getData().get(0);
    }

    /**
     * 查询指定藏品的昨日收盘价
     * @param otcCode
     * @return
     */
    public String queryClosePrice(String otcCode) {
        Map<String, Object> params = new HashMap<String, Object>();
        params.put("mchexch_type", "O1");
        params.put("mch_code", ""); // 交易撮合代码
        params.put("check_str", "0");
        T2Result result = T2Util.request(params, "649015");
        List<Map<String, Object>> list = result.getData();
        for (Map<String, Object> map : list) {
            if (otcCode.equals(map.get("mch_code"))) {
                return map.get("mclose_price").toString();
            }
        }
        return null;
    }

    /**
     * 可撤订单查询
     * @param otcCode
     * @return
     */
    public String queryReversibility() {
        UserInfo userInfo = ActionUtil.getUser();
        Map<String, Object> params = new HashMap<String, Object>();
        //可撤订单查询 619005
        params.put("op_branch_no", "11");
        params.put("op_entrust_way", "7");
        params.put("op_station", "192168010221");
        params.put("branch_no", "11");
        params.put("client_id", userInfo.getClient_id());
        params.put("fund_account", userInfo.getFund_account());
        params.put("password", userInfo.getPassword());
        params.put("user_token", " ");
        params.put("otc_account", userInfo.getOtc_account());
        params.put("position_str", "");
        params.put("request_num", "2000");
        params.put("query_type", "1");
        params.put("otcexch_type", "");
        params.put("otc_code", "");

        T2Result result = T2Util.request(params, "619005");
        List<Map<String, Object>> list = result.getData();
        for (Map<String, Object> map : list) {
            if ("0B0".equals(map.get("otc_prop"))) {
                map.put("otc_prop", "普通买单");
            } else if ("0S0".equals(map.get("otc_prop"))) {
                map.put("otc_prop", "普通卖单");
            }
            char[] entrust_status = map.get("entrust_status").toString().toCharArray();
            switch (entrust_status[0]) {
                case '0':
                    map.put("entrust_status", "未报");
                    break;
                case '1':
                    map.put("entrust_status", "待报");
                    break;
                case '2':
                    map.put("entrust_status", "已报");
                    break;
                case '3':
                    map.put("entrust_status", "已报待撤");
                    break;
                case '4':
                    map.put("entrust_status", "部成待撤");
                    break;
                case '5':
                    map.put("entrust_status", "部撤");
                    break;
                case '6':
                    map.put("entrust_status", "已撤");
                    break;
                case '7':
                    map.put("entrust_status", "部成");
                    break;
                case '8':
                    map.put("entrust_status", "已成");
                    break;
                case '9':
                    map.put("entrust_status", "废单");
                    break;
                case 'C':
                    map.put("entrust_status", "正报");
                    break;
                case 'W':
                    map.put("entrust_status", "待确认");
                    break;
                default:
                    break;
            }

            String entrustTime = DateUtil.parseDate(
                DateUtil.parseDate(map.get("entrust_time").toString(), DateEnum.UNSIGNED_TIME),
                DateEnum.TIME);
            map.put("entrust_time", entrustTime);

        }
        log.info("可撤订单查询619005:" + result.getData());
        return JsonUtil.toJson(result.getData());
    }

    /**
     * 撤单委托
     * @param entrustNo
     * @return
     */
    public String withdraw(String entrustNo) {
        UserInfo userInfo = ActionUtil.getUser();
        Map<String, Object> params = new HashMap<String, Object>();
        //撤单委托 619004
        params.put("op_branch_no", "11");
        params.put("op_station", "192168010119");
        params.put("op_entrust_way", "7");
        params.put("branch_no", "11");
        params.put("client_id", userInfo.getClient_id());
        params.put("fund_account", userInfo.getFund_account());
        params.put("password", userInfo.getPassword());
        params.put("user_token", " ");
        params.put("otcexch_type", "O1");
        params.put("entrust_no", entrustNo);
        params.put("sysnode_id", "2");

        T2Result result = T2Util.request(params, "619004");
        log.info("撤单委托619004:" + result);
        return result.getCode().toString();
    }

    /**
     * 查询指定藏品当日所有成交记录
     * @param otcCode
     * @return
     */
    public String queryAllTransactionToday(String otcCode) {
        List<Map<String, Object>> trans = otcRealTimeDao.queryByOtcCode(otcCode);
        try {
            for (Map<String, Object> tran : trans) {
                String time = tran.get("CURR_TIME").toString();
                if (time.indexOf(":") > 0) {
                    continue;
                }
                time = timeFormat.format(timeParse.parse(time));
                tran.put("CURR_TIME", time);
            }
        } catch (ParseException e) {
            log.error("成交记录日期格式化出错", e);
        }
        return JsonUtil.toJson(trans);
    }

    /**
     * 查询用户历史委托订单
     * @return
     */
    public List<HisOtcEntrustInfo> queryUserHisTransaction(Map<String, Object> params) {
        UserInfo userInfo = ActionUtil.getUser();
        params.put("clientId", userInfo.getClient_id());
        List<HisOtcEntrustInfo> list = hisOtcEntrustDao.search(params);

        for (HisOtcEntrustInfo info : list) {
            char[] str = info.getEntrustStatus().toCharArray();
            switch (str[0]) {
                case '0':
                    info.setEntrustStatus("未报");
                    break;
                case '1':
                    info.setEntrustStatus("待报");
                    break;
                case '2':
                    info.setEntrustStatus("已报");
                    break;
                case '3':
                    info.setEntrustStatus("已报待撤");
                    break;
                case '4':
                    info.setEntrustStatus("部成待撤");
                    break;
                case '5':
                    info.setEntrustStatus("部撤");
                    break;
                case '6':
                    info.setEntrustStatus("已撤");
                    break;
                case '7':
                    info.setEntrustStatus("部成");
                    break;
                case '8':
                    info.setEntrustStatus("已成");
                    break;
                case '9':
                    info.setEntrustStatus("废单");
                    break;
                case 'C':
                    info.setEntrustStatus("正报");
                    break;
                case 'W':
                    info.setEntrustStatus("待确认");
                    break;
                default:
                    break;
            }
            if ("0B0".equals(info.getOtcProp())) {
                info.setOtcProp("普通买单");
            } else if ("0S0".equals(info.getOtcProp())) {
                info.setOtcProp("普通卖单");
            } else if ("0C2".equals(info.getOtcProp())) {
                info.setOtcProp("普通撤单");
            }
        }

        return list;

        //历史订单（历史委托）查询 619903
        //        Map<String, Object> params = new HashMap<String, Object>();
        //        params.put("op_branch_no", "11");
        //        params.put("op_entrust_way", "7");
        //        params.put("op_station", "192168010221");
        //        params.put("branch_no", "11");
        //        params.put("client_id", userInfo.getClient_id());
        //        params.put("fund_account", userInfo.getFund_account());
        //        params.put("password", userInfo.getPassword());
        //        params.put("user_token", " ");
        //        params.put("otcexch_type", "");
        //        params.put("otc_account", userInfo.getOtc_account());
        //        params.put("otc_code", "");
        //        params.put("start_date", map.get("start_date"));
        //        params.put("end_date", map.get("end_date"));
        //        params.put("request_num", "2000");
        //        params.put("position_str", "");
        //        T2Result result = T2Util.request(params, "619903");
        //        log.info("历史委托订单查询619903:" + result);
        //        return result.getData();
    }
}