java实现微信支付结果通知

支付完成后,微信会把相关支付结果和用户信息发送给商户,商户需要接收处理,并返回应答。

对后台通知交互时,如果微信收到商户的应答不是成功或超时,微信认为通知失败,微信会通过一定的策略定期重新发起通知,尽可能提高通知的成功率,但微信不保证通知最终能成功。 (通知频率为15/15/30/180/1800/1800/1800/1800/3600,单位:秒)

注意:同样的通知可能会多次发送给商户系统。商户系统必须能够正确处理重复的通知。
推荐的做法是,当收到通知进行处理时,首先检查对应业务数据的状态,判断该通知是否已经处理过,如果没有处理过再进行处理,如果处理过直接返回结果成功。在对业务数据进行状态检查和处理之前,要采用数据锁进行并发控制,以避免函数重入造成的数据混乱。

特别提醒:商户系统对于支付结果通知的内容一定要做签名验证,防止数据泄漏导致出现“假通知”,造成资金损失。

//支付结果通知接口

  @RequestMapping("/qlydweixinotify.do")
  public void weixinotify(HttpServletRequest request,
      HttpServletResponse response) {
    PrintWriter out = null;
    StringBuffer xmlStr = new StringBuffer();
    try {
      BufferedReader reader = request.getReader();
      String line = null;
      while ((line = reader.readLine()) != null) {
        xmlStr.append(line);
      }
      Logger.getLogger(getClass()).debug("支付回调通知:"+xmlStr.toString());
      //检查xml是否有效
      boolean flag=Signature.checkIsSignValidFromResponseString(xmlStr.toString());
      WeixinNotifyResult result=null;
      if(flag){
        NotifyResData wxData=(NotifyResData) Util.getObjectFromXML(xmlStr.toString(),NotifyResData.class);
        if(wxData !=null){
          if("SUCCESS".equals(wxData.getReturn_code())&&"SUCCESS".equals(wxData.getResult_code())){
            OrderPayInfo orderPayInfo = new OrderPayInfo();
            orderPayInfo.setOrderNum(wxData.getOut_trade_no());
            orderPayInfo.setPayNum(wxData.getTransaction_id());
            orderPayInfo.setPayPrice((double)wxData.getTotal_fee()/100+"");
            orderPayInfo.setPaySource(wxData.getOpenid());
            orderPayInfo.setPayTime(wxData.getTime_end());
            orderPayInfo.setPayType("2");//1支付宝,2微信支付
            OrderMessage returnMessage = orderProductServer
                .completeProductOrder(orderPayInfo);
            if (OrderStatus.FAIL.equals(returnMessage
                .getOrderStatus())) {
              Logger.getLogger(getClass()).error("远程接口完成订单失败");
              result=new WeixinNotifyResult("FAIL");
              result.setReturn_msg("远程接口完成订单失败");
            } else {
              result=new WeixinNotifyResult("SUCCESS");
              result.setReturn_msg("成功");
            }
          }else{
            result=new WeixinNotifyResult("FAIL");
            result.setReturn_msg("失败");
          }
        }else{
          result=new WeixinNotifyResult("FAIL");
          result.setReturn_msg("解析参数格式失败");
        }
      }else{
        result=new WeixinNotifyResult("FAIL");
        result.setReturn_msg("签名失败");
      }
      response.getWriter().write(result.toString());
    } catch (Exception e) {
      Logger.getLogger(getClass()).error("qlydweixinotify.do", e);
      ResponeDeal.getInstance().sendResponseStr(response, "404", "连接超时");
    } finally {
      if (out != null) {
        out.close();
      }
    }
  }

模拟http请求工具类:

HttpsRequestUtil.java

package com.qlwb.weixin.util;

import java.io.IOException;

import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.HttpException;
import org.apache.commons.httpclient.methods.PostMethod;
import org.apache.commons.httpclient.methods.RequestEntity;
import org.apache.commons.httpclient.methods.StringRequestEntity;
import org.apache.log4j.Logger;

import com.qlwb.weixin.common.Configure;
import com.qlwb.weixin.common.Util;
import com.qlwb.weixin.protocol.pay_protocol.WxPayReqData;
import com.qlwb.weixin.protocol.payquery_protocol.PayQueryReqData;

public class HttpsRequestUtil {

  /**
   *
   * @方法名称:sendWxPayRequest
   * @内容摘要: <发送统一下单请求>
   * @param body
   * @param outTradeNo
   * @param totalFee
   * @param spBillCreateIP
   * @return
   * String
   * @exception
   * @author:鹿伟伟
   * @创建日期:2016年2月19日-下午2:24:05
   */
  public String sendWxPayRequest(String body,String detail,String outTradeNo,int totalFee,String spBillCreateIP
      )

  {
    // 构造HTTP请求
    HttpClient httpclient = new HttpClient();

    PostMethod postMethod = new PostMethod(Configure.PAY_API);

    WxPayReqData wxdata = new WxPayReqData(body,detail,outTradeNo,totalFee,spBillCreateIP);

    String requestStr="";
    requestStr=Util.ConvertObj2Xml(wxdata);
    // 发送请求
    String strResponse = null;
    try {
      RequestEntity entity = new StringRequestEntity(
          requestStr.toString(), "text/xml", "UTF-8");
      postMethod.setRequestEntity(entity);
      httpclient.executeMethod(postMethod);
      strResponse = new String(postMethod.getResponseBody(), "utf-8");
      Logger.getLogger(getClass()).debug(strResponse);
    } catch (HttpException e) {
      Logger.getLogger(getClass()).error("sendWxPayRequest", e);
    } catch (IOException e) {
      Logger.getLogger(getClass()).error("sendWxPayRequest", e);
    } finally {
      postMethod.releaseConnection();
    }
    return strResponse;
  }
  /**
   *
   * @方法名称:orderQueryRequest
   * @内容摘要: <查询订单信息>
   * @param transaction_id 微信的订单号,优先使用
   * @return
   * String
   * @exception
   * @author:鹿伟伟
   * @创建日期:2016年2月19日-下午2:44:11
   */
  public String orderQueryRequest(String transactionID, String outTradeNo
      )

  {
    // 构造HTTP请求
    HttpClient httpclient = new HttpClient();

    PostMethod postMethod = new PostMethod(Configure.PAY_QUERY_API);

    PayQueryReqData wxdata = new PayQueryReqData(transactionID,outTradeNo);

    String requestStr="";
    requestStr=Util.ConvertObj2Xml(wxdata);
    // 发送请求
    String strResponse = null;
    try {
      RequestEntity entity = new StringRequestEntity(
          requestStr.toString(), "text/xml", "UTF-8");
      postMethod.setRequestEntity(entity);
      httpclient.executeMethod(postMethod);
      strResponse = new String(postMethod.getResponseBody(), "utf-8");

    } catch (HttpException e) {
      Logger.getLogger(getClass()).error("orderQueryRequest", e);
    } catch (IOException e) {
      Logger.getLogger(getClass()).error("orderQueryRequest", e);
    } finally {
      postMethod.releaseConnection();
    }
    return strResponse;
  }
}

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持我们。

(0)

相关推荐

  • Java异常处理与throws关键字用法分析

    本文实例讲述了Java异常处理与throws关键字用法.分享给大家供大家参考,具体如下: Java异常处理 认识异常: 1.异常是导致程序中断运行的一种指令流,如果不对异常进行正确处理,则可能导致程序的中断执行,造成不必要的损失. 2.异常范例 空指针异常 Exc e=null; System.out.println(e.i); 除0异常 int a=10; int b=0; System.out.println(a/b); 3.处理异常 异常格式: try{ 异常语句: } catch(Exc

  • Java内存泄漏问题处理方法经验总结

    JVM问题,一般会有三种情况,目前遇到了两种,线程溢出和JVM不够用 1.线程溢出:unable to create new native thread 1.1问题描述: 系统在1月4号左右,突然发现会产生内存溢出问题,从日志上看,错误信息为: 导致系统不能使用,对外不能相应,但是观察gc等又处于正常情况,free 系统内存也正常.开始重启机器进行解决,真正的原因查找,过程比较坎坷,经历也比较痛苦. 1.2 问题解决 pstree查看线程数,发现系统线程数不断增长,直到OOM. 命令:pstre

  • Java模拟扑克牌洗牌实现生成52张扑克的方法示例

    本文实例讲述了Java模拟扑克牌洗牌实现生成52张扑克的方法.分享给大家供大家参考,具体如下: 要求: 生成52张扑克,模拟扑克牌洗牌,并输出. 实现代码: package com.NCU.ZHANGhuirong; import java.util.ArrayList; import java.util.Collections; public class Card { public String poker(int num) { String str = ""; String[] f

  • Java数组的定义、初始化、及二维数组用法分析

    本文实例讲述了Java数组的定义.初始化.及二维数组用法.分享给大家供大家参考,具体如下: 数组的定义 1.数组是有序数据的集合,数组中的每个元素具有相同的数组名和下标来做唯一标识. 数组的分类 一维数组 二维数组 多维数组 数组的优点: 例如:定义100个整型变量.用数组很方便. 数组声明: 1.int [] array; 2.int array []; 数组的声明以及内存的分配 1.为数组分配内存空间,如果不分配内存,将不能访问它的任何元素.我们使用new关键字来为数组分配内存空间. int

  • Java基础高级综合练习题扑克牌的创建

    最近学了很多的知识,脑容量小,记不清,还是得做做练习! 今天就做了一个扑克牌的练习 首先呢..这个逻辑一定要非常清楚,我们要想做出一副扑克牌,必定要弄清楚每一张牌和整的一副牌 首先分析 一张扑克 一张牌里面有什么?相信大家看图(图不是我写的)就应该懂了,一张扑克有属于它自己的花色(红桃,黑桃,梅花,方块) 以及自己的点数(A,2,3-..J,Q,K)就这两种属性,对吧! 那么花色符号,点数符号是个啥? 花色符号就是来代替我们的花色的,我们不可能拿着"红桃"这种文字写进程序吧!所以我们可

  • JavaScript创建对象的四种常用模式实例分析

    本文实例讲述了JavaScript创建对象的四种常用模式.分享给大家供大家参考,具体如下: 这里介绍了javascript中创建对象常用的几种模式,包括:工厂模式,构造函数模式,原型模式,组合构造函数与原型的模式,动态原型模式. 一.工厂模式 看如下代码: function getMySon(name,sex){ var o={}; o.name=name; o.sex=sex; o.sayName = function(){ alert(this.name); } return o; } so

  • Java中字符串常见题之String相关讲解

    今天给大家带来的是在面试中经常被问到的一道题: 无论在Java还是Android中,String是一个很常见的类,但是大家真的很了解吗,我这里有几个题: 1. String str1 = "abc"; String str2 = new String("abc"); 这两种创建String对象的方法有什么不同? 2. String s = "a" + "b" + "c" + "d"; 这

  • Java LinkedList的实现原理图文详解

    一.概述 先来看看源码中的这一段注释,我们先尝试从中提取一些信息: Doubly-linked list implementation of the List and Deque interfaces. Implements all optional list operations, and permits all elements (including null).All of the operations perform as could be expected for a doubly-l

  • 基于idea 的 Java中的get/set方法之优雅的写法

    曾几何时,我们写代码的时候,每次写Bean的时候都会使用快捷键生成get/set方法,有时候我经常会想,既然每一个Bean我们都会给其提供get/set方法,那么为什么还有会这个东西哪?(当然这只是一个问题,毕竟还是很有用的,这一点就是Java语言中的private.public等作用域) 今天说的当然不是这个,我们讨论的是希望有一种优雅的方式编写我们的get/set方法或者说是一种优雅的简化.那我们就说一下今天的主角吧! Lombok Java代码简化神器!就是如此美妙! Lombok是一个可

  • JAVA collection集合之扑克牌游戏实例

    Collection 层次结构中的根接口.Collection表示一组对象,这些对象也称为collection的元素.一些 collection 允许有重复的元素,而另一些则不允许.一些 collection 是有序的,而另一些则是无序的.JDK 不提供此接口的任何直接 实现:它提供更具体的子接口(如 Set 和 List)实现.此接口通常用来传递 collection,并在需要最大普遍性的地方操作这些 collection. 主要内容:这里使用collection集合,模拟香港电影中大佬们玩的

随机推荐