### 微信小程序支付API在Python Flask后端的实现 为了实现在Python Flask后端调用微信小程序支付API的功能，需遵循一系列步骤来确保安全性和功能性。以下是具体方法： #### 创建Flask应用并配置必要的依赖库 首先，在`flask`环境中创建一个新的应用程序实例，并引入所需的模块用于处理HTTP请求、JSON解析以及与微信服务器通信。 ```python import flask from flask import request, jsonify from gevent.pywsgi import WSGIServer import requests import hashlib import time ``` #### 实现获取OpenID功能 根据描述[^2]，要完成支付流程前必须先获得用户的唯一标识符即`openid`。这通常通过接收来自客户端的小程序code参数并通过它向微信OAuth2.0授权接口发起请求得到。 ```python def get_openid(code): app_id = 'your_app_id' secret = 'your_secret_key' url = f'https://api.weixin.qq.com/sns/jscode2session?appid={app_id}&secret={secret}&js_code={code}&grant_type=authorization_code' response = requests.get(url).json() openid = response['openid'] return openid ``` #### 构建统一下单接口 接下来定义一个路由用来接受从前端传递过来的商品详情和其他必要信息，构建预付订单所需的数据包并向微信支付网关提交以获取交易号(`prepay_id`)。 ```python @app.route('/create_order', methods=['POST']) def create_order(): data = request.json # 组织下单参数 nonce_str = ''.join(random.sample(string.ascii_letters + string.digits, 32)) body = "商品名称" out_trade_no = str(int(time.time())) # 使用时间戳作为商户订单编号 total_fee = int(data['totalFee']) * 100 # 单位转换成分为整数形式 spbill_create_ip = request.remote_addr notify_url = "https://example.com/pay/notify" # 支付成功后的回调地址 trade_type = "JSAPI" params = { "appid": APP_ID, "mch_id": MCH_ID, "nonce_str": nonce_str, "body": body, "out_trade_no": out_trade_no, "total_fee": total_fee, "spbill_create_ip": spbill_create_ip, "notify_url": notify_url, "trade_type": trade_type, "openid": data["openid"] } sign = generate_sign(params) xml_data = dict_to_xml({**params, **{"sign": sign}}) resp = wechat_pay_request("/pay/unifiedorder", xml_data) result = parse_wechat_response(resp.content.decode('utf-8')) prepay_id = result.get("prepay_id") timestamp = str(int(time.time())) pay_params = { "appId": APP_ID, "timeStamp": timestamp, "nonceStr": nonce_str, "package": f'prepay_id={prepay_id}', "signType": "MD5", "paySign": generate_jsapi_signature(timestamp, nonce_str, prepay_id), } return jsonify(pay_params) def generate_sign(params_dict): """生成签名""" sorted_keys = sorted([k for k in params_dict.keys()]) unsigned_string = '&'.join(['='.join((str(k), str(params_dict[k]))) for k in sorted_keys]) unsigned_string += "&key=" + API_KEY signed_string = hashlib.md5(unsigned_string.encode()).hexdigest().upper() return signed_string def dict_to_xml(param_map): """字典转XML字符串""" items_list = [] for key in param_map: value = param_map[key] item = "<{0}>{1}</{0}>".format(key, value) items_list.append(item) s = '<xml>{items_list}</xml>'.format(items_list=''.join(items_list)) return s def wechat_pay_request(api_path, post_body): headers = {'Content-Type': 'application/xml'} r = requests.post(f"https://api.mch.weixin.qq.com{api_path}", data=post_body, headers=headers) return r def parse_wechat_response(xml_content): try: parsed_result = xmltodict.parse(xml_content)['xml'] err_code = parsed_result.get('return_code') if err_code != 'SUCCESS': raise Exception(parsed_result.get('err_msg') or 'Error occurred while processing WeChat Pay.') return parsed_result except KeyError as e: raise ValueError(f'Missing required field {e} in the XML response.') from None def generate_jsapi_signature(timestamp, nonce_str, package_value): raw_text = f'appId={APP_ID}&nonceStr={nonce_str}&package={package_value}&signType=MD5&timeStamp={timestamp}' raw_text += f"&key={API_KEY}" signature = hashlib.md5(raw_text.encode()).hexdigest().upper() return signature ``` 此部分代码实现了从接收到前端发来的支付请求直到返回给前端可用于唤起支付界面的信息的过程。注意这里假设了一些常量如`APP_ID`, `MCH_ID`(商家ID)，和`API_KEY`（密钥），这些都需要替换为你自己的实际值。