微信公众号支付

app/utils/wxpay/wx_app_pay.py

@@ -37,7 +37,7 @@ def genNonce_str():
     return s
 
 class WXPay(object):
-    """微信H5支付."""
+    """微信APP支付."""
     def __init__(self, out_trade_no, body, total_fee, remote_addr, notify_url):
         """线上：tamper.tanpuyun.com
             测试：testtamper.tanpuyun.com"""

app/utils/wxpay/wx_jsapi_pay.py

+# -*- encoding: utf-8 -*-
+# -----------------------------------------------------------------------------
+# @File Name  : wx_jsapi_pay.py
+# @Time       : 2020/12/12 上午10:00
+# @Author     : X. Peng
+# @Email      : acepengxiong@163.com
+# @Software   : PyCharm
+# -----------------------------------------------------------------------------
+
+import requests
+import hashlib
+import time
+from xml.etree import cElementTree as etree
+import random
+from urllib import parse
+
+from app.api.engine import config, env
+
+
+def genNonce_str():
+    """."""
+    sss = 'ABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789'
+    s = ''
+    for i in range(32):
+        s = s + random.choice(sss)
+    return s
+
+class WXPay(object):
+    """微信公众号支付."""
+    def __init__(self, openid, out_trade_no, body, total_fee, remote_addr, notify_url):
+        """线上：tamper.tanpuyun.com
+            测试：testtamper.tanpuyun.com"""
+        print('notify_url', notify_url)
+        self.timeStamp = int(time.time())
+        self.req_url = 'https://api.mch.weixin.qq.com/pay/unifiedorder'
+        # self.appid = 'wx3ad4c5856975a2c4'
+        self.appid = 'wx8ea86a9521d25095'
+        self.mch_id = '1515329071'
+        self.openid = openid
+        self.nonce_str = genNonce_str()
+        self.sign = None
+        self.sign_type = 'MD5'
+        self.body = body
+        self.out_trade_no = out_trade_no
+        self.total_fee = int(total_fee)
+        self.spbill_create_ip = remote_addr
+        self.notify_url = notify_url
+        self.trade_type = 'JSAPI'
+        self.key = 'eqwor3wquevncz9384ssp438oarefskl'
+        self.getStringSign()
+        self.getData()
+        self.getPrepayId()
+        self.getPaySign()
+
+    def getStringSign(self):
+        """."""
+        self.string_sign_temp = 'appid={0}&body={1}&mch_id={2}&nonce_str={3}&notify_url={4}&openid={5}&out_trade_no={6}&sign_type={7}&spbill_create_ip={8}&total_fee={9}&trade_type={10}&key={11}'.format(
+            self.appid,
+            self.body,
+            self.mch_id,
+            self.nonce_str,
+            self.notify_url,
+            self.openid,
+            self.out_trade_no,
+            self.sign_type,
+            self.spbill_create_ip,
+            self.total_fee,
+            self.trade_type,
+            self.key
+        )
+
+    def getData(self):
+        """."""
+        self.sign = hashlib.md5(self.string_sign_temp.encode("utf-8")).hexdigest().upper()
+        self.data = {
+            'appid': self.appid,
+            'body': self.body,
+            'mch_id': self.mch_id,
+            'nonce_str': self.nonce_str,
+            'notify_url': self.notify_url,
+            'openid': self.openid,
+            'out_trade_no': self.out_trade_no,
+            'sign_type': self.sign_type,
+            'spbill_create_ip': self.spbill_create_ip,
+            'total_fee': self.total_fee,
+            'trade_type': self.trade_type,
+            'sign': self.sign
+        }
+
+    def dict2xml(self, dict_):
+        """将dict转为要发送到微信服务器的xml格式."""
+        s = ""
+        for k, v in dict_.items():
+            s += "<{0}>{1}</{0}>".format(k, v)
+        s = "<xml>{0}</xml>".format(s)
+        return s.encode("utf-8")
+
+    def xml2dict(self, content):
+        """将从微信服务器接收到的xml转为dict."""
+        raw = {}
+        root = etree.fromstring(content)
+        for child in root:
+            raw[child.tag] = child.text
+        return raw
+
+    def getPrepayId(self):
+        """."""
+        res = requests.post(self.req_url, data=self.dict2xml(self.data))
+        res = self.xml2dict(res.content)
+        self.prepay_id = res['prepay_id']
+
+    def getPaySign(self):
+        """."""
+        sign_string = 'appId={0}&nonceStr={1}&package=prepay_id={2}&signType={3}&timeStamp={4}&key={5}'.format(
+            self.appid, self.nonce_str, self.prepay_id, self.sign_type, self.timeStamp, self.key)
+        self.paySign = hashlib.md5(sign_string.encode("utf-8")).hexdigest().upper()
+
+    def getReturnParams(self):
+        """."""
+        params = {'appId': self.appid, 'timeStamp': self.timeStamp, 'nonceStr':self.nonce_str, 'package': 'prepay_id='+self.prepay_id,
+                  'signType': self.sign_type, 'paySign': self.paySign}
+        return params
+
+if __name__ == '__main__':
+    openid = 'oHyIO00TC3vwgxuJKLXeKFrpNnEI'
+    out_trade_no = '201812102324324134120'
+    body = '微信公众号支付测试'
+    total_fee = 1
+    remote_addr = '101.95.188.178'
+    notify_url = 'https://devtamper.tanpuyun.com/tamp_order/micro_shop/consumeOrderNotify'
+    wx = WXPay(openid, out_trade_no, body, total_fee, remote_addr, notify_url)
+    print(wx.getReturnParams())