特殊格式的 汇潮支付接口对接

  /**
     *  支付方式异步通知接口
     * @param getHcPayRequest 异步通知获得json字符串
     * @return  异步通知结果 success/fail
     */
    /*汇潮支付--支付方式异步通知接口*/
    public String notifyInfos(HcPayRequest getHcPayRequest) {
        logger.info("汇潮异步回调参数" + JSON.toJSONString(getHcPayRequest));
        ParserConfig.getGlobalInstance().setAutoTypeSupport(true);//针对fastjson解析 mq里面的redis获取值的解析，不然会出错

        String merchantOutOrderNo =getHcPayRequest.getMerchantOutOrderNo();;//商户订单号
        String merid = getHcPayRequest.getMerid();//商户号
        String msg =getHcPayRequest.getMsg();//订单的详细信息  msg->pay Money

        String res = null;
        try {
            res = URLDecoder.decode(msg,"UTF-8");
        } catch (UnsupportedEncodingException e) {
            logger.error("汇潮异步回调参数解码失败-" + JSON.toJSONString(msg));
            e.printStackTrace();
        }

        JSONObject jsonObject = JSON.parseObject(res);
        System.out.println(getHcPayRequest.toString());

        String orderNo =getHcPayRequest.getOrderNo();//平台订单号
        String orderMoney = (String)jsonObject.get( "payMoney" );// 支付金额

        /**
         * 通知参数样例：
         * 在汇潮的接口文档里面有这个
         * merchantOutOrderNo=2017091316410597&merid=
         * yft2017082500005&msg={"payMoney":"1.00"}&noncestr=adfasdfqwer&orderNo=20170913164
         * 1128501&payResult=1&sign= 078c2637c96d714880fdb3364d440b51
         */

            String trasactionId = orderNo;//平台订单编号 比如支付宝平台
            try {
                if (redisTemplate.hasKey(Constants.HC_PREFIX + trasactionId)) { //放进Redis
                    logger.info("hcpay有重复通知" + trasactionId);
                    return "success";
                } else {
                    redisTemplate.opsForValue().set(Constants.HC_PREFIX + trasactionId, "1", 2880, TimeUnit.MINUTES);
                }
            } catch (Exception e) {
                e.printStackTrace();
                logger.error("hcpay写redis出错" + e.getMessage());
            }

        HcPayRequest hcPayRequestnew = new HcPayRequest();
        hcPayRequestnew.setMerchantOutOrderNo(merchantOutOrderNo);
        hcPayRequestnew.setOrderNo(orderNo);
        hcPayRequestnew.setAmount(orderMoney);

        EvaFeeInfo evaFeeInfoNew =(EvaFeeInfo)redisTemplate.opsForValue().get(Constants.HC_PREFIX +Constants.PAY_PG+ merchantOutOrderNo);
        if(evaFeeInfoNew!=null){
            logger.info("hc汇潮支付redis获取的param" + JSON.toJSONString(evaFeeInfoNew));
            if (Constants.PAY_PG.equals(evaFeeInfoNew.getFlag())) {//评估费
                EvaFeeInfo evaFeeInfo = new EvaFeeInfo();
                evaFeeInfo.setEvaAmount(evaFeeInfoNew.getEvaAmount());//
                evaFeeInfo.setUserId(evaFeeInfoNew.getUserId());//
                evaFeeInfo.setMobile(evaFeeInfoNew.getMobile());//
                evaFeeInfo.setCouponId(evaFeeInfoNew.getCouponId());//
                evaFeeInfo.setRepayNo(orderNo);
                evaFeeInfo.setTradeNo(evaFeeInfoNew.getTradeNo());//商家唯一标示 订单号
                evaFeeInfo.setCurrentCash(evaFeeInfoNew.getCurrentCash());//
                evaFeeInfo.setIsUseCash(evaFeeInfoNew.getIsUseCash());//
                hcPayRequestnew.setFlag(Constants.PAY_PG);
                try {
                    logger.info("评估费发送rabbitmq");
                    rabbitmqProducerProxy.convertAndSend("evaFee.ibank", evaFeeInfo);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }

        RecFeeInfo recFeeInfoNew =(RecFeeInfo)redisTemplate.opsForValue().get(Constants.HC_PREFIX +Constants.PAY_TJ+merchantOutOrderNo);
        if(recFeeInfoNew!=null){
            logger.info("hc汇潮支付redis获取的param" + JSON.toJSONString(recFeeInfoNew));
            if (Constants.PAY_TJ.equals(recFeeInfoNew.getFlag())) {//推荐费
                RecFeeInfo recFeeInfo = new RecFeeInfo();
                recFeeInfo.setRecAmount(recFeeInfoNew.getRecAmount());//
                recFeeInfo.setUserId(recFeeInfoNew.getUserId());//
                recFeeInfo.setMobile(recFeeInfoNew.getMobile());//
                recFeeInfo.setBorrowPeriods(recFeeInfoNew.getBorrowPeriods());//借款周期//
                recFeeInfo.setLoanAmount(recFeeInfoNew.getLoanAmount());//
//                recFeeInfo.setType(hcPayRequest.getType());--------------------------------------------
                recFeeInfo.setRepayNo(orderNo);//
                recFeeInfo.setTradeNo(recFeeInfoNew.getTradeNo());//商家唯一标示 订单号
                recFeeInfo.setCouponId(recFeeInfoNew.getCouponId());//
                recFeeInfo.setAppCodeList(recFeeInfoNew.getAppCodeList());//
                recFeeInfo.setCurrentCash(recFeeInfoNew.getCurrentCash());//
                recFeeInfo.setIsUseCash(recFeeInfoNew.getIsUseCash());//
                hcPayRequestnew.setFlag(Constants.PAY_TJ);
                try {
                    logger.info("推荐费发送rabbitmq order");
                    rabbitmqProducerProxy.convertAndSend("recFee.ibank", recFeeInfo);
                    //去掉 发给 user的推荐费
//                        logger.info("推荐费发送rabbitmq user");
//                        rabbitmqProducerProxy.convertAndSend("recUser.ibank", recFeeInfo);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
        RechargeFeeInfo rechargeFeeInfoNew =(RechargeFeeInfo)redisTemplate.opsForValue().get(Constants.HC_PREFIX + Constants.PAY_XJ +merchantOutOrderNo);
        if(rechargeFeeInfoNew!=null){
            if(Constants.PAY_XJ.equals(rechargeFeeInfoNew.getFlag())){//充值现金券
                RechargeFeeInfo rechargeFeeInfo = new RechargeFeeInfo();
                rechargeFeeInfo.setAccountNumber(rechargeFeeInfoNew.getAccountNumber());//手机号//
                rechargeFeeInfo.setAmount(rechargeFeeInfoNew.getAmount());//
                rechargeFeeInfo.setCashId(rechargeFeeInfoNew.getCashId());//
                rechargeFeeInfo.setOperStatus(1);//     /**充值是否成功 0：失败  1：成功*/
                rechargeFeeInfo.setRechargeFlowNo(orderNo);
                rechargeFeeInfo.setTradeNo(rechargeFeeInfoNew.getTradeNo());//商家唯一标示 订单号
                rechargeFeeInfo.setStatusMsg("1");//汇潮支付 1 为成功(目前只有成功才通知)
                hcPayRequestnew.setFlag(Constants.PAY_XJ);
                try {
                    logger.info("hc汇潮支付充值现金券发送rabbitmq order");
                    rabbitmqProducerProxy.convertAndSend("rechargeFee.ibank", rechargeFeeInfo);
                } catch (Exception e) {
                    e.printStackTrace();
                    logger.error("hc汇潮支付现金券充值 异常", e);
                }
            }
        }

        payLogService.saveHcPay(hcPayRequestnew,Constants.REPAY_STATUS_ZERO );
        logger.info("汇潮支付支付成功" + orderNo);
            return "success";
    }

/**
 *  支付方式异步通知接口
 * @param getHcPayRequest 异步通知获得json字符串
 * @return  异步通知结果 success/fail
 */
/*汇潮支付--支付方式异步通知接口*/
@RequestMapping(value = "/notifyInfos",method = RequestMethod.POST)
public String notifyInfos( HcPayRequest getHcPayRequest){
   String toSuccessOrFail =  hcPayService.notifyInfos(getHcPayRequest);
   return toSuccessOrFail;
}