微信公众号支付接口网页开发示例

时间 2019-11-12

原文原文链接

微信公众号支付是指在微信内嵌浏览器进入到公众号以后，点击电商页面的支付接口，他使用了微信内嵌浏览器的支持，开发步骤以下：前端

（1）首先开通企业公众号帐户而且开通支付接口，详细步骤能够参考相关文档，这里再也不细数，这一步问题不大，主要是企业帐号等信息要设置准确，除了公众号还有企业商户号要设置。java

（2）将用户openid传递到支付连接的参数中，例如：数据库

<a href="/product/buy?id=productid&openid=user_openid">支付 </a>json

（3）先写好支付成功后的微信回调函数处理程序，成功的话微信会访问配置好的通知url（notify_url），会尝试8次直到咱们写回去success或者fail，示例代码以下：api

@RequestMapping(value = "/wxpaycallback", method = { RequestMethod.POST,
           RequestMethod.GET }, produces = { "application/json;charset=utf-8" })
   public String weixinNotify(HttpServletRequest request,
           HttpServletResponse response) {
       try {
           response.setCharacterEncoding("UTF-8");
           InputStream inStream = request.getInputStream();
           ByteArrayOutputStream outSteam = new ByteArrayOutputStream();
           byte[] buffer = new byte[1024];
           int len = 0;
           while ((len = inStream.read(buffer)) != -1) {
               outSteam.write(buffer, 0, len);
           }
           outSteam.close();
           inStream.close();
           String resultStr = new String(outSteam.toByteArray(), "utf-8");
           Map<String, String> resultMap =MessageUtil.parseXml(resultStr);
           String out_trade_no = resultMap.get("out_trade_no");//订单号
           String return_code = resultMap.get("return_code");
           String mch_id=resultMap.get("mch_id");
           if (return_code.contains("SUCCESS")) {
               // 此处就是你的逻辑代码
               if (mch_id.equals(WeixinUtil.MCH_ID)){
                    OrderLogic.finishOrder(out_trade_no);//处理该订单的状态
               }
           }
            //返回消息给微信服务器
           String retXml = "<xml> <return_code><![CDATA[SUCCESS]]></return_code> <return_msg><![CDATA[OK]]></return_msg></xml>";
           PrintWriter out = response.getWriter();
           out.print(retXml);
           out.close();
       } catch (Exception e) {
           e.printStackTrace();
       }
       return "success";//这句话能够不用吧？
   }浏览器

（4）Js端代码：服务器

商品页面增长如下代码就会调用支付流程：微信

（5）还须要预先调用预下单接口才行，这部分代码暂时找不到了，后面补充。dom

写的不是很流畅，第一次写，感受微信支付接口挺绕的，不如支付宝来的简洁。

附件：

微信用户在不一样的公众号里时候openid值是不同的，所以在支付的时候要先将用户的openid获取到传递给支付页面。获取openid一个方式是经过Oauth连接，就是说先进入Oauth地址，将H5页面url做为参数传递给Oauth连接，微信会回调这个url并将随机的code传给这个H5，经过code来查询微信api获取openid值。

public class WeixinLogic {
    private static final Logger logger = LoggerFactory
            .getLogger(WeixinLogic.class);
    private static Gson gson = MyGlobal.gson();

    /*
    * 生成并记录短信验证码到数据库
    */
    private static String genBindSmsCode(String mobile) {
        String code = "";
        DB db = MyMongo.getDB();
        if (db != null) {
            code = UserLogic.createRandom(true, 4);
            DBCollection collection = db.getCollection("wxsmscode");
            BasicDBObject cond = new BasicDBObject("mobile", mobile);
            DBObject obj = collection.findOne(cond);
            if (obj != null) {
                DBObject doc = new BasicDBObject("$set", new BasicDBObject(
                        "code", code));
                collection.update(cond, doc);
            } else {
                DBObject doc = new BasicDBObject().append("mobile", mobile)
                        .append("code", code);
                collection.insert(doc);
            }
        }
        return code;
    }

    /*
    * 发送短信验证码
    */
    public static void SendSmsCode(String mobile) {
        String code = genBindSmsCode(mobile);
        UserLogic.sendSmsCode(mobile, code);
    }

    /*
    * 绑定公众号和手机号成功返回true
    */
    public static boolean bindwx(String openid, String mobile, String code) {
        boolean ret = false;
        if (!isMobileExist(mobile)) {
            return false;
        }
        if (!checkSmsCode(mobile, code)) {
            return false;
        }
        String old = getbindmobile(openid);
        DB db = MyMongo.getDB();
        if (db != null) {
            DBCollection collection = db.getCollection("bindweixin");
            if (!old.equals("")) {
                collection.remove(new BasicDBObject("openid", openid));
            }
            try {
                BindWeixin info = new BindWeixin();
                DBObject doc = (DBObject) JSON.parse(gson.toJson(info));
                collection.insert(doc);
                return true;
            } catch (Exception e) {
                logger.error("bindwx" + e.getMessage());
                return false;
            }
        }
        return ret;
    }

    private static boolean isMobileExist(String mobile) {
        boolean ret = true;

        return ret;
    }

    /*
    * 短信码是否正确
    */
    private static boolean checkSmsCode(String mobile, String code) {
        boolean ret = false;
        DB db = MyMongo.getDB();
        if (db != null) {
            DBCollection collection = db.getCollection("wxsmscode");
            BasicDBObject cond = new BasicDBObject("mobile", mobile).append(
                    "code", code);
            DBObject obj = collection.findOne(cond);
            if (obj != null) {
                ret = true;
            }
        }
        return ret;
    }

    /*
    * 返回微信用户绑定的手机号
    */
    public static String getbindmobile(String openid) {
        String mobile = "";
        DB db = MyMongo.getDB();
        if (db != null) {
            DBCollection collection = db.getCollection("bindweixin");
            try {
                DBObject obj = collection.findOne(new BasicDBObject("openid",
                        openid));
                if (obj != null) {
                    BindWeixin info = gson.fromJson(obj.toString(),
                            BindWeixin.class);
                    mobile = info.mobile;
                }
            } catch (Exception e) {
                logger.error("getbindmobile:" + e.getMessage());
            }
        }
        return mobile;
    }


    public static void sendWXMonny(String re_openId, int money) {
        String URL = "https://api.mch.weixin.qq.com/mmpaymkttransfers/sendredpack";
        String mch_id =WeixinUtil.MCH_ID;
        SortedMap<Object, Object> parameters = new TreeMap<Object, Object>();
        parameters.put("wxappid",WeixinUtil.APPID);
        parameters.put("mch_id", mch_id);
        String nonscr = UUID.randomUUID().toString().toUpperCase()
                .replace("-", "");
        parameters.put("nonce_str", nonscr);// 随机字符串
        parameters.put("send_name", "中医管家");
        String billno = createBillNo(mch_id, "01");
        parameters.put("mch_billno",billno);
        parameters.put("re_openid", re_openId);//个人微信openid: "oW9-5s8Aecs_teXlIuwTwNbLQyHk"
        parameters.put("total_amount",money+"");
        parameters.put("total_num", "1");
        parameters.put("wishing", "中医管家");
        parameters.put("client_ip", "127.0.0.1");
        parameters.put("act_name", "测试红包用例");
        parameters.put("remark", "中医管家");

        // String sign = createSign("UTF-8", parameters);
        // parameters.put("sign", sign);
        sign(parameters);
        String requestXML = getRequestXml(parameters);
        String result = httpsRequest(URL, "POST", requestXML);
        System.out.println("result:" + result);
    }


    public static String unifiedOrder(String openid,String trade_no,int fee,String doctorName){
        //统一下单支付
        String unified_url="https://api.mch.weixin.qq.com/pay/unifiedorder";
        String notify_url="http://123.56.140.11/health/wxpaycallback";
//        trade_no=UUID.randomUUID().toString().replace("-","");
        try {
          //生成sign签名
          SortedMap<Object,Object> parameters = new TreeMap<Object,Object>();
          parameters.put("appid",WeixinUtil.APPID);
          parameters.put("attach", "中医管家");
          parameters.put("body",doctorName);
          parameters.put("mch_id",WeixinUtil.MCH_ID);
          String nonscr =trade_no;// UUID.randomUUID().toString().toUpperCase().replace("-", "");
          parameters.put("nonce_str", nonscr);
          parameters.put("notify_url",notify_url);
          parameters.put("out_trade_no", trade_no);
          parameters.put("total_fee",fee+"");
          parameters.put("trade_type", "JSAPI");
          parameters.put("spbill_create_ip","127.0.0.1");
          parameters.put("openid", openid);
          parameters.put("device_info", "WEB");
          sign(parameters);
            String requestXML = getRequestXml(parameters);
            String result =WeixinUtil. httpsRequest(unified_url, "POST", requestXML);
            System.out.println("result:" + result);
            return result;
        } catch (Exception e) {
          e.printStackTrace();
        }
        return "";
    }

    private static String getRandomNum(int length) {
        String val = "";
        Random random = new Random();
        for (int i = 0; i < length; i++) {
            val += String.valueOf(random.nextInt(10));
        }
        return val;
    }

    public static String createBillNo(String mch_id, String userId) {
        // 组成： mch_id+yyyymmdd+10位一天内不能重复的数字
        // 10位一天内不能重复的数字实现方法以下:
        // 由于每一个用户绑定了userId,他们的userId不一样,加上随机生成的(10-length(userId))可保证这10位数字不同
        Date dt = new Date();
        SimpleDateFormat df = new SimpleDateFormat("yyyymmdd");
        String nowTime = df.format(dt);
        int length = 10 - userId.length();
        return mch_id + nowTime + userId + getRandomNum(length);
    }


    public static void sign(SortedMap<Object, Object> params) {
        String KEY =WeixinUtil.APIKEY;
        Set<Entry<Object, Object>> entrys = params.entrySet();
        Iterator<Entry<Object, Object>> it = entrys.iterator();
        StringBuffer result = new StringBuffer();
        while (it.hasNext()) {
            Entry<Object, Object> entry = it.next();
            result.append(entry.getKey()).append("=").append(entry.getValue())
                    .append("&");
        }
        result.append("key=").append(KEY);
        params.put("sign", MD5Util.MD5Encode(result.toString(), "UTF-8")
                .toUpperCase());
    }
    /*
    * 发送红包接口示例
    */




    public static String getRequestXml(SortedMap<Object, Object> parameters) {
        StringBuffer sb = new StringBuffer();
        sb.append("<xml>");
        Set<Entry<Object, Object>> es = parameters.entrySet();
        Iterator<Entry<Object, Object>> it = es.iterator();
        while (it.hasNext()) {
            @SuppressWarnings("rawtypes")
            Map.Entry entry = (Map.Entry) it.next();
            String k = (String) entry.getKey();
            String v = String.valueOf(entry.getValue());
            if ("attach".equalsIgnoreCase(k) || "body".equalsIgnoreCase(k)
                    || "sign".equalsIgnoreCase(k)) {
                sb.append("<" + k + ">" + "<![CDATA[" + v + "]]></" + k + ">");
            } else {
                sb.append("<" + k + ">" + v + "</" + k + ">");
            }
        }
        sb.append("</xml>");
        return sb.toString();
    }

    /**
    * 发送https请求
    *
    * @param requestUrl
    *            请求地址
    * @param requestMethod
    *            请求方式（GET、POST）
    * @param outputStr     *            提交的数据     * @return 返回微信服务器响应的信息     */     public static String httpsRequest(String requestUrl, String requestMethod,             String outputStr) {         try {             String result = "";             // // 建立SSLContext对象，并使用咱们指定的信任管理器初始化             // TrustManager[] tm = { new MyX509TrustManager() };             // SSLContext sslContext = SSLContext.getInstance("SSL", "SunJSSE");             // sslContext.init(null, tm, new java.security.SecureRandom());             // // 从上述SSLContext对象中获得SSLSocketFactory对象             // SSLSocketFactory ssf = sslContext.getSocketFactory();             // 指定读取证书格式为PKCS12             KeyStore keyStore = KeyStore.getInstance("PKCS12");             // 读取本机存放的PKCS12证书文件             FileInputStream instream = new FileInputStream(new File(                     "/root/apiclient_cert.p12"));             try {                 // 指定PKCS12的密码(商户ID)                 keyStore.load(instream,WeixinUtil.MCH_ID.toCharArray());             } finally {                 instream.close();             }             SSLContext sslcontext = SSLContexts.custom()                     .loadKeyMaterial(keyStore, WeixinUtil.MCH_ID.toCharArray())                     .build();             // 指定TLS版本             SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(                     sslcontext,                     new String[] { "TLSv1" },                     null,                     SSLConnectionSocketFactory.BROWSER_COMPATIBLE_HOSTNAME_VERIFIER);             CloseableHttpClient httpclient = HttpClients.custom()                     .setSSLSocketFactory(sslsf).build();             //URL url = new URL(requestUrl);             HttpPost httpPost = new HttpPost(requestUrl);             StringEntity reqEntity = new StringEntity(outputStr, "utf-8"); // 若是此处编码不对，可能致使客户端签名跟微信的签名不一致             reqEntity.setContentType("application/x-www-form-urlencoded");             httpPost.setEntity(reqEntity);             CloseableHttpResponse response = httpclient.execute(httpPost);             try {                 HttpEntity entity = response.getEntity();                 if (entity != null) {                     BufferedReader bufferedReader = new BufferedReader(                             new InputStreamReader(entity.getContent(), "UTF-8"));                     String text;                     while ((text = bufferedReader.readLine()) != null) {                         result += text;                     }                 }                 EntityUtils.consume(entity);             } finally {                 response.close();             }             return result;             // HttpsURLConnection conn =             // (HttpsURLConnection)httpclient.execute(httpPost);//             // url.openConnection();             // conn.setSSLSocketFactory(sslsf);             // conn.setDoOutput(true);             // conn.setDoInput(true);             // conn.setUseCaches(false);             // // 设置请求方式（GET/POST）             // conn.setRequestMethod(requestMethod);             // conn.setRequestProperty("content-type",             // "application/x-www-form-urlencoded");             // // 当outputStr不为null时向输出流写数据             // if (null != outputStr) {             // OutputStream outputStream = conn.getOutputStream();             // // 注意编码格式             // outputStream.write(outputStr.getBytes("UTF-8"));             // outputStream.close();             // }             // // 从输入流读取返回内容             // InputStream inputStream = conn.getInputStream();             // InputStreamReader inputStreamReader = new InputStreamReader(             // inputStream, "utf-8");             // BufferedReader bufferedReader = new BufferedReader(             // inputStreamReader);             // String str = null;             // StringBuffer buffer = new StringBuffer();             // while ((str = bufferedReader.readLine()) != null) {             // buffer.append(str);             // }             // // 释放资源             // bufferedReader.close();             // inputStreamReader.close();             // inputStream.close();             // inputStream = null;             // conn.disconnect();             // return buffer.toString();         } catch (ConnectException ce) {             logger.error("链接超时：{}", ce);         } catch (Exception e) {             logger.error("https请求异常：{}", e);         }         return null;     } }