package com.cjs.site.action.user.account;

import java.io.UnsupportedEncodingException;
import java.net.URLDecoder;
import java.net.URLEncoder;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;

import com.cjs.site.biz.pub.CommonBiz;
import com.cjs.site.biz.user.account.HuifuAccountBiz;
import com.cjs.site.biz.user.account.PassportBiz;
import com.cjs.site.biz.user.account.RebindBiz;
import com.cjs.site.biz.user.active.ActiveBiz;
import com.cjs.site.dao.pub.SysDateDao;
import com.cjs.site.dao.user.OrganInfoDao;
import com.cjs.site.dao.user.account.ExBindCardLogDao;
import com.cjs.site.dao.user.account.PnrBindDao;
import com.cjs.site.dao.user.account.PnrRegisterDao;
import com.cjs.site.model.user.account.ExbindBankCardInfo;
import com.cjs.site.model.user.account.PnrRegisterInfo;
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.t2.T2Result;
import com.cjs.site.util.t2.T2Util;
import com.cjs.site.util.web.ActionUtil;

/**
 * 汇付天下账户相关接口操作
 * @author tongxiaochuan
 *
 */
@Controller
@RequestMapping("/pnr")
public class HuifuAccountAction {

    Logger log = LogManager.getLogger();

    @Autowired
    private HuifuAccountBiz  huifuAccountBiz;
    @Autowired
    private PnrRegisterDao   pnrRegisterDao;
    @Autowired
    private SysDateDao       sysDateDao;
    @Autowired
    private PnrBindDao       pnrBindDao;
    @Autowired
    private CommonBiz        commonBiz;
    @Autowired
    private ExBindCardLogDao exBindCardLog;
    @Autowired
    private RebindBiz        rebindBiz;
    @Autowired
    private PassportBiz      passportBiz;
    @Autowired
    private ActiveBiz        activeBiz;
    @Autowired
    private OrganInfoDao     organInfoDao;
    @Value("${${env}.host}")
    private String           host;

    /**
     * 汇付开户回调方法
     * @param session
     * @param params
     * @param model
     * @return 异步页面打印订单号
     */
    @RequestMapping("account/ret")
    public String openPnrAccountRet(@RequestParam Map<String, String> params, Model model) {
        try {
            params.put("resp_desc", URLDecoder.decode(params.get("resp_desc"), "UTF-8"));
            params.put("bg_ret_url", URLDecoder.decode(params.get("bg_ret_url"), "UTF-8"));
        } catch (UnsupportedEncodingException e) {
            log.info(e.getMessage());
        }
        log.info("异步回调返回信息：" + params);
        if (huifuAccountBiz.decodeRegister(params)) {
            model.addAttribute("resultMsg", "RECV_ORD_ID_" + params.get("order_id"));
        }
        return "user/pnr/openPnrRet.jsp";
    }

    /**
     * 通过订单号orderId获取快捷解绑/绑卡接口所需要的参数
     * @param orderId 订单号
     * @param request
     * @return 快捷绑卡接口参数
     */
    @SuppressWarnings("unchecked")
    @RequestMapping(value = "/bind/pre", method = RequestMethod.POST)
    public @ResponseBody String queryBindInfo(String orderId,
                                              HttpServletRequest request) throws Exception {
        Map<String, String> map = new LinkedHashMap<String, String>();
        map = (Map<String, String>) request.getSession().getAttribute(orderId);
        map.put("order_id", DateUtil.getNow(DateEnum.UNSIGNED_DATE) + sysDateDao.getOrderId());
        String checkValue = commonBiz.encrypt(map);
        map.put("check_value", checkValue);
        map.put("bg_ret_url", URLEncoder.encode(host + "pnr/bind/ret", "UTF-8"));
        if (!"102".equals(map.get("cmd_id"))) {
            pnrBindDao.save(map);
        }
        log.info("新页面请求信息:" + map);
        return JsonUtil.toJson(map);
    }

    /**
     * 快捷绑卡异步响应
     * @param model
     * @param params
     * @return
     */
    @RequestMapping("bind/ret")
    public String bindCard(@RequestParam Map<String, Object> params, Model model) {
        try {
            params.put("resp_desc", URLDecoder.decode(params.get("resp_desc").toString(), "UTF-8"));
            params.put("bg_ret_url",
                URLDecoder.decode(params.get("bg_ret_url").toString(), "UTF-8"));
        } catch (UnsupportedEncodingException e) {
            log.info(e.getMessage());
        }
        log.info("快捷绑卡回调信息:" + params);
        if (huifuAccountBiz.decodeBind(params) && "103000".equals(params.get("resp_code"))) {
            Map<String, Object> query = new HashMap<String, Object>();
            query.put("user_cust_id", params.get("user_cust_id"));
            List<PnrRegisterInfo> list = pnrRegisterDao.queryByConditions(query);
            if (list.size() > 0) {
                PnrRegisterInfo pnr = list.get(0);
                log.info("绑卡前存储的数据：" + pnr);
                Map<String, Object> inmap = new HashMap<String, Object>();
                inmap.put("fund_account", pnr.getUserId());
                inmap.put("bank_account", pnr.getUserCustId() + pnr.getAcctId());
                inmap.put("card_no", params.get("card_no"));
                inmap.put("client_account", pnr.getUserId());
                inmap.put("holder_name", pnr.getUserName());
                inmap.put("password", pnr.getPassword());
                inmap.put("bk_password", pnr.getBkPassword());
                inmap.put("id_no", pnr.getIdNo());
                inmap.put("bank_code", params.get("bank_id"));
                inmap.put("province_code", pnr.getCardProv());
                inmap.put("city_code", pnr.getCardArea());
                inmap.put("id_kind", "0");
                huifuAccountBiz.openBankAccount(inmap);
            }
        }
        model.addAttribute("resultMsg", "RECV_ORD_ID_" + params.get("order_id"));
        return "user/pnr/pnrBindRet.jsp";
    }

    /**
     * 通过订单号orderId获取换绑需要参数
     * @param orderId
     * @param request
     * @return
     * @throws Exception
     */
    @SuppressWarnings("unchecked")
    @RequestMapping("/change/pre")
    public @ResponseBody String queryChangeBindInfo(String orderId,
                                                    HttpServletRequest request) throws Exception {
        Map<String, String> map = new LinkedHashMap<String, String>();
        map = (Map<String, String>) request.getSession().getAttribute(orderId);
        map.put("order_id", DateUtil.getNow(DateEnum.UNSIGNED_DATE) + sysDateDao.getOrderId());
        String checkValue = commonBiz.encrypt(map);
        map.put("check_value", checkValue);
        map.put("bg_ret_url", URLEncoder.encode(host + "/pnr/changeBind/ret", "UTF-8"));
        log.info("新页面请求信息:" + map);
        return JsonUtil.toJson(map);
    }

    /**
     * 快捷换绑卡异步响应
     * @param model
     * @param params
     * @return
     * @throws ClassNotFoundException 
     * @throws IllegalAccessException 
     * @throws InstantiationException 
     */
    @RequestMapping("/changeBind/ret")
    public String changeBindCard(@RequestParam Map<String, Object> params, Model model,
                                 HttpSession session) {
        log.info("快捷绑卡回调信息:" + params);
        model.addAttribute("resultMsg", "RECV_ORD_ID_" + params.get("order_id"));
        ExbindBankCardInfo bankCardInfo = exBindCardLog
            .queryById(Integer.parseInt(params.get("extension").toString()));
        Map<String, Object> exbindMap = new HashMap<String, Object>();
        if (bankCardInfo != null && bankCardInfo.getResult().equals("4")
            && huifuAccountBiz.decodeBind(params) && "103000".equals(params.get("resp_code"))) {
            //恒生换绑
            String hsBind = rebindBiz.hengShengBind(bankCardInfo);
            if (!hsBind.equals("0")) {
                exbindMap.put("remark", "恒生换绑失败");
                exbindMap.put("result", "0");
                exbindMap.put("id", bankCardInfo.getId());
                exBindCardLog.updateExBindResult(exbindMap);
                return "user/pnr/pnrChangeBindPre.jsp";
            }
            rebindBiz.updateRegFlag(bankCardInfo, "2");
            exbindMap.put("remark", "换绑成功");
            exbindMap.put("result", "0");
            exbindMap.put("id", bankCardInfo.getId());
            exBindCardLog.updateExBindResult(exbindMap);
        }
        return "user/pnr/pnrChangeBindPre.jsp";
    }

    /**
     * 快捷解绑异步响应
     * @param session
     * @param params
     * @param model
     * @return 异步页面打印订单号
     */
    @RequestMapping("unBind/ret")
    public String unBind(@RequestParam Map<String, String> params, Model model) {
        log.info("解绑回调返回信息：" + params);
        model.addAttribute("resultMsg", "RECV_ORD_ID_" + params.get("order_id"));
        return "user/pnr/openPnrRet.jsp";
    }

    //    @RequestMapping("product/ret")
    //    public String product(Model model, @RequestParam Map<String, String> params) {
    //        log.info("产品录入接口回调信息:" + params);
    //        model.addAttribute("resultMsg", "RECV_ORD_ID_" + params.get("order_id"));
    //        return "user/pnr/productRet.jsp";
    //    }

    /**
     * 取现绑卡异步响应
     * @param model
     * @param params
     * @return
     */
    @RequestMapping("withdraw/ret")
    public String withdraw(Model model, @RequestParam Map<String, String> params) {
        try {
            params.put("resp_desc", URLDecoder.decode(params.get("resp_desc").toString(), "UTF-8"));
            params.put("bg_ret_url",
                URLDecoder.decode(params.get("bg_ret_url").toString(), "UTF-8"));
        } catch (UnsupportedEncodingException e) {
            log.info(e.getMessage());
        }
        log.info("取现绑卡回调信息:" + params);
        if (huifuAccountBiz.decodeWithdraw(params)) {
            model.addAttribute("resultMsg", "RECV_ORD_ID_" + params.get("order_id"));
        }
        return "user/pnr/withdrawRet.jsp";
    }

    /**
     * 绑卡状态检查
     * @return
     */
    @RequestMapping("bind/check")
    public @ResponseBody String checkBind() {
        return JsonUtil.toJson(passportBiz.checkBind());
    }

    /**
     * 汇付绑卡页面跳转
     * @param model
     * @return
     */
    @RequestMapping(value = "bind", method = RequestMethod.GET)
    public String pnrBindView(Model model) {
        UserInfo userInfo = ActionUtil.getUser();
        if ("1".equals(userInfo.getOrgan_flag())) {
            return "user/account/bindOrganBankCard.jsp";
        } else {
            Map<String, Object> params = new HashMap<String, Object>();
            params.put("client_id", userInfo.getClient_id());
            params.put("fund_account", userInfo.getFund_account());
            T2Result result = T2Util.request(params, "619829");
            String mobile_tel = result.getData().get(0).get("mobile_tel").toString();

            model.addAttribute("mobileTel", mobile_tel);
            model.addAttribute("resultMap", passportBiz.checkBind());
            return "user/account/bindBankCard.jsp";
        }
    }

    /**
     * 汇付绑卡
     * @param request
     * @param session
     * @param params
     * @param model
     * @return
     */
    @RequestMapping(value = "bind", method = RequestMethod.POST)
    public @ResponseBody String bind(HttpServletRequest request, HttpSession session,
                                     @RequestParam Map<String, Object> params, Model model) {
        log.info("绑卡页面提交信息:" + params);
        UserInfo userInfo = ActionUtil.getUser();

        //检查时间限制
        Map<String, Object> outmap = new HashMap<String, Object>();
        if (!commonBiz.checkOpenTime()) {
            outmap.put("resultCode", "0");
            outmap.put("resultMsg", "非交易时间，不可绑卡。");
            return JsonUtil.toJson(outmap);
        }

        //验证提交的参数格式正否正确
        Map<String, String> checkMap = rebindBiz.valiadateParams(params, session);
        if (checkMap.get("resultCode").equals("1")) {
            outmap.put("resultCode", "0");
            outmap.put("resultMsg", checkMap.get("resultMsg"));
            return JsonUtil.toJson(outmap);
        }

        //验证是否可进行绑卡操作
        outmap.clear();
        outmap.put("client_name", userInfo.getClient_name());
        Map<String, Object> userInfomation = new HashMap<String, Object>();

        if ("0".equals(userInfo.getOrgan_flag())) {
            outmap.put("id_kind", "0");
            userInfomation = rebindBiz.getUserInfomation(userInfo.getFund_account());
            outmap.put("id_no", userInfomation.get("id_no").toString());
        } else if ("1".equals(userInfo.getOrgan_flag())) {
            outmap.put("id_kind", "P");
            Map<String, String> query = organInfoDao.search(userInfo.getFund_account());
            outmap.put("id_no", query.get("ORGAN_CODE"));
        }

        T2Result result = T2Util.request(outmap, "619852");
        if ("0".equals(result.getData().get(0).get("result_code").toString())) {
            outmap.put("resultCode", "0");
            outmap.put("resultMsg", "账户已经绑定银行卡，不可再次绑定。");
            return JsonUtil.toJson(outmap);
        }

        //查询用户是否已经发放过开户发放积分的奖励
        if ("0".equals(activeBiz.checkRecordExist())) {
            request.getSession().setAttribute("pointRecord", "0");
        } else {
            request.getSession().setAttribute("pointRecord", "1");
        }

        if ("1".equals(userInfo.getOrgan_flag())) {
            outmap.put("resultCode", "1");
            outmap.put("orderId",
                huifuAccountBiz.companyOpenAccount(params, session).get("orderId"));
            return JsonUtil.toJson(outmap);
        }

        Map<String, Object> query = new HashMap<String, Object>();
        query.put("client_id", userInfo.getClient_id());
        List<PnrRegisterInfo> list = pnrRegisterDao.queryByConditions(query);
        PnrRegisterInfo pnr = list.get(0);
        log.info("查询到汇付历史开户记录:" + pnr);

        Map<String, String> inmap = new HashMap<String, String>();
        inmap.put("user_cust_id", pnr.getUserCustId());
        inmap.put("order_id", DateUtil.getNow(DateEnum.UNSIGNED_DATE) + sysDateDao.getOrderId());
        inmap.put("bank_id", params.get("open_bank_code").toString());
        inmap.put("card_no", params.get("fund_card").toString());
        inmap.put("card_mobile", userInfomation.get("mobile_tel").toString());
        inmap.put("card_prov", params.get("province_code").toString());
        inmap.put("card_area", params.get("city_code").toString());
        pnrRegisterDao.updateBindInfo(inmap);

        outmap.put("resultCode", "1");
        outmap.put("orderId", huifuAccountBiz.bindPnr(inmap, session).get("orderId"));
        return JsonUtil.toJson(outmap);
    }

    /**
     * 页面弹窗_立即验证
     * @param orderId
     * @param model
     * @return
     */
    @RequestMapping("check/now")
    public String checkNow(String orderId, Model model) {
        log.info("绑卡结果检验:" + orderId);
        model.addAttribute("orderId", orderId);
        return "user/pnr/pnrBindPre.jsp";
    }

    /**
     * 汇付绑卡结果检查
     * @return
     */
    @RequestMapping("bind/result/check")
    public @ResponseBody String bindResultCheck() {
        Map<String, Object> outmap = new HashMap<String, Object>();
        if ("0".equals(passportBiz.checkUserAccount())) {
            outmap.put("resultCode", "1");
        } else {
            outmap.put("resultCode", "0");
        }
        return JsonUtil.toJson(outmap);
    }

    /**
     * 汇付绑卡结果页跳转
     * @param request
     * @param model
     * @return
     */
    @RequestMapping("/bind/result")
    public String bindResult(HttpServletRequest request, Model model) {
        request.getSession().setAttribute("bindMsg", "");
        Map<String, Object> outmap = new HashMap<String, Object>();
        if ("0".equals(passportBiz.checkUserAccount())) {
            if ("1".equals(activeBiz.checkRecordExist())
                && "0".equals(request.getSession().getAttribute("pointRecord"))) {
                outmap.put("pointCode", "1");
            }
            outmap.put("resultCode", "1");
            outmap.put("resultMsg", "尊敬的用户，您已成功绑定银行卡");
        }
        model.addAttribute("resultMap", outmap);
        return "user/pnr/pnrBindResult.jsp";
    }

    /**
     * 汇付企业用户开户回调
     * @param params
     * @param model
     * @return
     */
    @RequestMapping("organ/ret")
    public String openOrganAccountRet(@RequestParam Map<String, String> params,
                                      Model model) throws Exception {
        try {
            log.info("----------------" + params);
            params.put("resp_desc", URLDecoder.decode(params.get("resp_desc"), "UTF-8"));
            params.put("corp_name", URLDecoder.decode(params.get("corp_name"), "UTF-8"));
            params.put("bg_ret_url", URLDecoder.decode(params.get("bg_ret_url"), "UTF-8"));
        } catch (UnsupportedEncodingException e) {
            log.info(e.getMessage());
        }
        log.info("企业用户开户回调信息：" + params);
        if (huifuAccountBiz.decodeOrgan(params) && "02000104".equals(params.get("audit_status"))) {
            huifuAccountBiz.bindWithdraw(params);
        }
        model.addAttribute("resultMsg", "RECV_ORD_ID_" + params.get("order_id"));
        return "user/pnr/openPnrRet.jsp";
    }

    /**
     * 企业用户开户_页面跳转
     * @param orderId
     * @param model
     * @return
     */
    @RequestMapping("organ")
    public String bindWithdraw(String orderId, Model model) {
        model.addAttribute("orderId", orderId);
        return "user/pnr/organAccount.jsp";
    }

    /**
     * 企业用户开户_参数获取处理
     * @param orderId
     * @param request
     * @return
     */
    @SuppressWarnings("unchecked")
    @RequestMapping("organ/pre")
    public @ResponseBody String organAccountPre(String orderId, HttpServletRequest request) {
        Map<String, String> inmap = new LinkedHashMap<String, String>();
        inmap = (Map<String, String>) request.getSession().getAttribute(orderId);
        Map<String, String> map = (Map<String, String>) request.getSession()
            .getAttribute(orderId + "params");
        inmap.put("order_id", DateUtil.getNow(DateEnum.UNSIGNED_DATE) + sysDateDao.getOrderId());
        String checkValue = commonBiz.encrypt(inmap);
        inmap.put("check_value", checkValue);
        try {
            inmap.put("corp_name", URLEncoder.encode(map.get("corp_name"), "UTF-8"));
            inmap.put("corp_business_address",
                URLEncoder.encode(map.get("corp_business_address"), "UTF-8"));//企业经营地址
            inmap.put("corp_reg_address", URLEncoder.encode(map.get("corp_reg_address"), "UTF-8"));//企业注册地址
            inmap.put("business_scope", URLEncoder.encode(map.get("business_scope"), "UTF-8"));//经营范围
            inmap.put("controlling_shareholder",
                URLEncoder.encode(map.get("controlling_shareholder"), "UTF-8"));//控股股东
            inmap.put("legal_name", URLEncoder.encode(map.get("legal_name"), "UTF-8"));//法人代表姓名
            inmap.put("contact_name", URLEncoder.encode(map.get("contact_name"), "UTF-8"));//企业联系人姓名
            inmap.put("bank_acct_name", URLEncoder.encode(map.get("bank_acct_name"), "UTF-8"));
            inmap.put("bank_branch", URLEncoder.encode(map.get("bank_branch"), "UTF-8"));//开户银行支行名称
            inmap.put("bg_ret_url", URLEncoder.encode(host + "pnr/organ/ret", "UTF-8"));
        } catch (UnsupportedEncodingException e) {
            log.info(e.getMessage());
        }
        log.info("企业用户开户请求信息:" + inmap);
        return JsonUtil.toJson(inmap);
    }
}