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

import java.io.UnsupportedEncodingException;
import java.net.URLDecoder;
import java.net.URLEncoder;
import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpSession;

import org.apache.commons.lang3.StringUtils;
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.ServiceException;
import com.cjs.site.biz.pub.CommonBiz;
import com.cjs.site.biz.user.fund.PayBiz;
import com.cjs.site.dao.user.account.ClientInfoDao;
import com.cjs.site.dao.user.account.PnrRegisterDao;
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.DesUtil;

import chinapnr.SecureLink;

/**
 * 网银充值-用户资金
 * @author tongxiaochuan
 *
 */
@Controller
public class PayAction {

    @Autowired
    private PayBiz         payBiz;
    @Autowired
    private CommonBiz      commonBiz;
    @Autowired
    private ClientInfoDao  clientInfoDao;
    @Autowired
    private PnrRegisterDao pnrRegisterDao;
    @Value("${${env}.pnr.operId}")
    private String         operId;
    @Value("${${env}.pnr.pbKey}")
    private String         pbKey;
    @Value("${${env}.pnr.merchantNo}")
    private String         merchantNo;
    @Value("${${env}.host}")
    private String         host;
    Logger                 log = LogManager.getLogger(PayAction.class);

    /**
     * 检查交易时间
     * @return
     */
    @RequestMapping("/pay/checkOpenTime")
    public @ResponseBody String checkOpenTime() {
        String resultCode = commonBiz.checkOpenTime() ? "0" : "-1";
        return JsonUtil.toJson("resultCode", resultCode);
    }

    /**
     * 单笔充值订单页面-网银
     * @param model
     * @return
     */
    @RequestMapping("/user/pay/prePay")
    public String prePay(Model model, HttpSession session) {
        UserInfo userInfo = (UserInfo) session.getAttribute(UserInfo.USER);
        model.addAttribute("organ_flag", userInfo.getOrgan_flag());
        return "/pay/cyberBankIn.jsp";
    }

    /**
     * 单笔充值-信息确认
     * @param request
     * @param params
     * @param model
     * @return
     */
    @RequestMapping("/pay/orderEnsure")
    public String orderEnsure(HttpSession session, @RequestParam Map<String, Object> params,
                              Model model) throws Exception {
        UserInfo userInfo = (UserInfo) session.getAttribute(UserInfo.USER);
        Map<String, String> query = clientInfoDao.queryForPnr(userInfo.getClient_id());
        DecimalFormat df = new DecimalFormat("0.00");
        String OrdAmt = df.format(Double.parseDouble(params.get("OrdAmt").toString()));

        Map<String, String> inmap = new LinkedHashMap<String, String>();
        inmap.put("version", "10");
        inmap.put("cmd_id", "201");
        inmap.put("mer_cust_id", merchantNo);
        inmap.put("user_cust_id", query.get("BANK_ACCOUNT").substring(0, 16));
        inmap.put("order_date", DateUtil.getNow(DateEnum.UNSIGNED_DATE));

        //调用网银入金流水接口
        SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
        Map<String, Object> modelMap = new HashMap<String, Object>();
        modelMap.put("branch_no", "11");
        modelMap.put("init_date", sdf.format(new Date()));
        modelMap.put("bank_no", "99");
        modelMap.put("fund_account", userInfo.getFund_account());
        modelMap.put("money_type", "0");
        modelMap.put("occur_balance", params.get("OrdAmt"));
        T2Result tr = T2Util.request(modelMap, "25001");
        log.debug("---------" + tr);
        if (tr.getCode().toString().equals("0")) {
            inmap.put("order_id",
                StringUtils.leftPad(tr.getData().get(0).get("serial_no").toString(), 8, '0')
                                  + userInfo.getClient_id());
        } else {
            if (tr.getCode().toString().equals("150192")) {
                throw new ServiceException("当前非交易时间，不可充值，详情请联系客服");
            } else if (tr.getCode().toString().equals("150190")) {
                throw new ServiceException("银行状态停止，不可充值，详情请联系客服");
            }
            throw new Exception("操作异常，详情请联系客服");
        }

        Map<String, String> detail = new HashMap<String, String>();
        detail.put("div_acct_id", "1197");
        detail.put("div_amt", OrdAmt);
        String divDetail = "[" + JsonUtil.toJson(detail) + "]";
        log.info("转换为json格式:" + divDetail);

        inmap.put("trans_type", "02020101");
        inmap.put("recharge_type", params.get("rechargeType").toString());
        inmap.put("trans_amt", OrdAmt);
        //        inmap.put("bank_id", params.get("tstradio").toString());
        inmap.put("bank_id", "03090000");
        inmap.put("dc_flag", "D");
        inmap.put("in_cust_id", merchantNo);
        inmap.put("div_detail", divDetail);
        inmap.put("ret_url", host + "pay/ret");
        inmap.put("bg_ret_url", host + "pay/changeBalance");
        String checkValue = commonBiz.encrypt(inmap);
        inmap.put("check_value", checkValue);
        inmap.put("div_detail", URLEncoder.encode(divDetail, "UTF-8"));
        inmap.put("ret_url", URLEncoder.encode(host + "pay/ret", "UTF-8"));
        inmap.put("bg_ret_url", URLEncoder.encode(host + "pay/changeBalance", "UTF-8"));

        model.addAttribute("params", inmap);
        return "/pay/confirmCyberBankIn.jsp";
    }

    /**
     * 网银充值同步返回方法
     * @param params
     * @param model
     * @return
     */
    @RequestMapping("/pay/ret")
    public String payRetUrl(@RequestParam Map<String, Object> params, Model model) {
        try {
            params.put("resp_desc", URLDecoder.decode(params.get("resp_desc").toString(), "UTF-8"));
            params.put("ret_url", URLDecoder.decode(params.get("ret_url").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);
        String build = params.get("cmd_id").toString() + params.get("resp_code")
                       + params.get("mer_cust_id") + params.get("user_cust_id")
                       + params.get("order_date") + params.get("order_id")
                       + params.get("platform_seq_id") + params.get("trans_type")
                       + params.get("recharge_type") + params.get("trans_amt")
                       + params.get("bank_id") + params.get("dc_flag") + params.get("sms_order_id")
                       + params.get("sign_seq_id") + params.get("in_cust_id")
                       + params.get("div_detail") + params.get("fee_amt")
                       + params.get("fee_cust_id") + params.get("fee_acct_id")
                       + params.get("ret_url") + params.get("bg_ret_url") + params.get("mer_priv")
                       + params.get("extension");
        build = DesUtil.MD5(build);
        String ChkValue = params.get("check_value").toString();
        String PgKeyFile = CommonBiz.class.getResource("/pay/").getFile() + pbKey;
        SecureLink secureLink = new SecureLink();
        int ret = secureLink.VeriSignMsg(PgKeyFile, build, ChkValue);
        if (ret != 0) {
            log.info("签名错误." + params.get("resp_desc"));
            model.addAttribute("resultMsg", "签名验证失败");
        } else {
            if ("201000".equals(params.get("resp_code"))) {
                model.addAttribute("orderId", params.get("order_id"));
            }
            model.addAttribute("resultMsg", params.get("resp_desc"));
            model.addAttribute("resultCode", params.get("resp_code"));
        }
        return "pay/cyberBankInResult.jsp";
    }

    /**
     * 网银充值提交汇付天下订单记录
     * @param params
     * @return
     * @throws Exception 
     */
    @RequestMapping("/pay/saveCyberBankInOrder")
    public @ResponseBody String saveCyberBankInOrder(@RequestParam Map<String, Object> params) {
        log.info(params);
        String result = payBiz.saveCyberBankInOrder(params) + "";
        return JsonUtil.toJson("resultCode", result);
    }

    /**
     * 单笔订单支付回掉
     * @param session
     * @param params
     * @param model
     * @return
     */
    @RequestMapping("/pay/changeBalance")
    public String changeBalance(HttpSession session, @RequestParam Map<String, Object> params,
                                Model model) {
        Map<String, Object> modelMap = new HashMap<String, Object>();
        try {
            params.put("resp_desc", URLDecoder.decode(params.get("resp_desc").toString(), "UTF-8"));
            params.put("ret_url", URLDecoder.decode(params.get("ret_url").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("the message is :" + params);
        String build = params.get("cmd_id").toString() + params.get("resp_code")
                       + params.get("mer_cust_id") + params.get("user_cust_id")
                       + params.get("order_date") + params.get("order_id")
                       + params.get("platform_seq_id") + params.get("trans_type")
                       + params.get("recharge_type") + params.get("trans_amt")
                       + params.get("bank_id") + params.get("dc_flag") + params.get("sms_order_id")
                       + params.get("sign_seq_id") + params.get("in_cust_id")
                       + params.get("div_detail") + params.get("fee_amt")
                       + params.get("fee_cust_id") + params.get("fee_acct_id")
                       + params.get("ret_url") + params.get("bg_ret_url") + params.get("mer_priv")
                       + params.get("extension");
        build = DesUtil.MD5(build);
        String ChkValue = params.get("check_value").toString();
        String PgKeyFile = CommonBiz.class.getResource("/pay/").getFile() + pbKey;
        SecureLink secureLink = new SecureLink();
        int ret = secureLink.VeriSignMsg(PgKeyFile, build, ChkValue);
        log.info("check the backInfo:" + ret);
        if (ret == 0) {
            if (params.get("resp_code").equals("201000")) {
                Map<String, Object> select = new HashMap<String, Object>();
                select.put("user_cust_id", params.get("user_cust_id"));
                List<PnrRegisterInfo> list = pnrRegisterDao.queryByConditions(select);
                String userId = list.get(0).getUserId();
                select.clear();
                select.put("fund_account", userId);
                select.put("client_id", userId);
                T2Result selectT = T2Util.request(select, "619832");
                modelMap.put("bOrganId", "99");
                modelMap.put("bAcctKind", "1");
                modelMap.put("sOrganId", "1");
                modelMap.put("sBranchId", "11");
                modelMap.put("sAcctKind", "1");
                modelMap.put("sAcctType", "");
                modelMap.put("sCustPwd", "********");
                modelMap.put("sCustPwd2", "********");
                modelMap.put("FunctionId", "23701");
                modelMap.put("ExSerial", params.get("order_id"));//汇付天下流水码
                modelMap.put("Name", selectT.getData().get(0).get("client_name"));
                modelMap.put("bCustAcct", params.get("order_id"));
                modelMap.put("sCustAcct", userId);//交易账号
                modelMap.put("MoneyType", "0");
                modelMap.put("OccurBala", params.get("trans_amt"));//传入金额
                modelMap.put("CardType", "");
                modelMap.put("Card", "");
                modelMap.put("bFrozenFlag", "");
                modelMap.put("ErrorNo", "");
                modelMap.put("ErrorInfo", "");
                modelMap.put("sSerial", params.get("platform_seq_id"));//接口生成的流水号
                modelMap.put("sEnableBala", "");
                modelMap.put("bEnableBala", "");
                modelMap.put("Nationality", "");
                modelMap.put("PostCode", "");
                modelMap.put("Address", "");
                modelMap.put("TelNo", "");
                modelMap.put("Email", "");
                modelMap.put("Summary", "汇付天下网关入金");//汇付天下网关入金
                boolean flag = payBiz.checkChangeStatus(modelMap);
                log.debug("the insert result is :" + flag);

                if (flag) {
                    log.debug("before T2 :" + modelMap);
                    T2Result tr = T2Util.request(modelMap, "23701");
                    log.debug("check the 23701:" + tr);
                    if (tr.getData().get(0).get("ErrorInfo").equals("0")) {
                        Map<String, Object> inMap = tr.getData().get(0);
                        payBiz.insertRujinResult(inMap);
                        model.addAttribute("resultMsg", "RECV_ORD_ID_" + params.get("order_id"));
                        return "/pay/result.jsp";
                    }
                } else {
                    //查询入金返回结果记录，错误则再次执行入金
                    Map<String, Object> errorMap = new HashMap<String, Object>();
                    errorMap.put("ExSerial", params.get("order_id"));
                    String errorMsg = payBiz.selectRujinResult(errorMap);
                    if (!errorMsg.equals("0")) {
                        T2Result tr = T2Util.request(modelMap, "23701");
                        log.debug("check the 23701 again:" + tr);
                        if (tr.getData().get(0).get("ErrorInfo").equals("0")) {
                            Map<String, Object> inMap = tr.getData().get(0);
                            payBiz.insertRujinResult(inMap);
                            model.addAttribute("resultMsg",
                                "RECV_ORD_ID_" + params.get("order_id"));
                            return "/pay/result.jsp";
                        }
                    }
                    model.addAttribute("resultMsg", "RECV_ORD_ID_" + params.get("order_id"));
                    return "/pay/result.jsp";
                }
            }

        }
        return "签名验证失败[" + build + "]";

    }

    /**
     * 自动扣款签约
     * @param session
     * @return
     */
    @RequestMapping("/pay/paymentSign")
    public String paymentSign(HttpSession session) {
        String Version = "10";
        String CmdId = "AutoPaySign";
        String MerId = operId;

        Date nowtime = new Date();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd HHmmss");
        String MerDate = sdf.format(nowtime).substring(0, 8);
        String MerTime = sdf.format(nowtime).substring(9);
        String BgRetUrl = host + "pay/paymentSignCallBack";

        String MerKeyFile = PayAction.class.getResource("/pay/").getFile() + "MerPrK" + operId
                            + ".key"; //商户私钥文件路径  请将MerPrK510010.key改为你的私钥文件名称
        String MerData = Version + CmdId + MerId + MerDate + MerTime + BgRetUrl;

        SecureLink sl = new SecureLink();
        int ret = sl.SignMsg(MerId, MerKeyFile, MerData);
        if (ret != 0) {
            Map<String, Object> outMap = new HashMap<String, Object>();
            outMap.put("resultCode", "-1");
            outMap.put("resultMsg", "验证签名失败");
            return "/pay/result.jsp";
        }

        String ChkValue = sl.getChkValue();
        String returnStr = "redirect:http://mas.chinapnr.com/gau/UnifiedServlet?Version=" + Version
                           + "&CmdId=" + CmdId + "&MerId=" + MerId + "&MerDate=" + MerDate
                           + "&MerTime=" + MerTime + "&BgRetUrl=" + BgRetUrl + "&ChkValue="
                           + ChkValue;

        return returnStr;
    }

    /**
     * 快捷充值页面信息查询
     * @return
     */
    @ResponseBody
    @RequestMapping(value = "/user/recharge/pre", method = RequestMethod.GET)
    public String rechargeView() {
        return payBiz.rechargePre();
    }

    /**
     * 快捷充值_短信发送
     * @return
     */
    @ResponseBody
    @RequestMapping(value = "/user/recharge/sms", method = RequestMethod.POST)
    public String hundsunSms() {
        return JsonUtil.toJson(payBiz.hundsunSms());
    }

    /**
     * 快捷充值
     * @param params
     * @return
     */
    @ResponseBody
    @RequestMapping(value = "/user/recharge", method = RequestMethod.POST)
    public String recharge(@RequestParam Map<String, Object> params) {
        return JsonUtil.toJson("resultCode", payBiz.recharge(params));
    }
}