python flask 微信支付下单及支付结果回调处理代码笔记

本文主要是介绍python flask 微信支付下单及支付结果回调处理代码笔记，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

前言

因为微信支付下单的时候不允许同一个订单重复下单，所以在下单之前 对订单号加了三位随机字符串 在回调时 进行截取操作

@order_api.route('/user/wx_xcx_pay/notify', methods=['POST'])
def new_notify():headers = request.headers# print('headers', headers)wxpay = wx_pay_func()result = wxpay.callback(headers, request.data)if result and result.get('event_type') == 'TRANSACTION.SUCCESS':resp = result.get('resource')out_trade_no = resp.get('out_trade_no')  # 本系统订单号transaction_id = resp.get('transaction_id')  # 微信支付订单号first_character = out_trade_no[0]  # 获取开头字母 确定支付类型order_number = out_trade_no[:-3]  # 获取实际订单号success_time = resp.get('success_time')  # 支付完成时间payer = resp.get('payer')  # 付款人信息amount = resp.get('amount').get('total')  # 金额 单位分payment_amount = Decimal(amount) / Decimal(100)  # 实际支付金额 单位元# 上门取 或者 上门洗if first_character in ['X', 'Q']:return order_pay_callback(order_number, amount, success_time, transaction_id, resp)# 充值订单elif first_character == 'C':return recharge_pay_callback(order_number, transaction_id, payment_amount)# 补差价订单elif first_character == 'B':return price_difference_payment_callback(order_number, transaction_id, payment_amount)else:return reg_func(200, None, '支付失败')def load_private_key(file_name):# 获取当前文件的目录current_dir = os.path.dirname(__file__)# 构建完整的文件路径file_path = os.path.join(current_dir, file_name)try:# 安全地打开文件with open(file_path, 'r') as file:private_key = file.read()return private_keyexcept FileNotFoundError:print(f"Error: The file {file_name} was not found in the directory {current_dir}.")return Noneexcept Exception as e:print(f"An error occurred: {e}")return None# 初始化
def wx_pay_func():mch_id = get_config('wx_xcx_pay_mid')appid = get_config('wx_xcx_appid')APIV3_KEY = get_config('wx_xcx_pay_secret')# 日志记录器，记录web请求和回调细节logging.basicConfig(filename=os.path.join(os.getcwd(), 'demo.log'), level=logging.DEBUG, filemode='a',format='%(asctime)s - %(process)s - %(levelname)s: %(message)s')LOGGER = logging.getLogger("demo")# 代理设置，None或者{"https": "http://10.10.1.10:1080"}，详细格式参见https://requests.readthedocs.io/en/latest/user/advanced/#proxiesPROXY = None# 接入模式:False=直连商户模式，True=服务商模式PARTNER_MODE = FalseCERT_DIR = None# 请求超时时间配置TIMEOUT = (10, 30)  # 建立连接最大超时时间是10s，读取响应的最大超时时间是30sPRIVATE_KEY = load_private_key('apiclient_key.pem')CERT_SERIAL_NO = get_config('CERT_SERIAL_NO')api_url = get_config('api_domain')NOTIFY_URL = f'https://{api_url}/user/wx_xcx_pay/notify'print('NOTIFY_URL', NOTIFY_URL)wxpay = WeChatPay(wechatpay_type=WeChatPayType.NATIVE,mchid=mch_id,private_key=PRIVATE_KEY,cert_serial_no=CERT_SERIAL_NO,apiv3_key=APIV3_KEY,appid=appid,notify_url=NOTIFY_URL,cert_dir=CERT_DIR,logger=LOGGER,partner_mode=PARTNER_MODE,proxy=PROXY,timeout=TIMEOUT)return wxpaydef generate_random_string():# 字符集合，包括大写字母、小写字母和数字characters = string.ascii_letters + string.digits# 从字符集合中随机选择3个字符random_string = ''.join(random.choices(characters, k=3))return random_stringdef xcx_pay(openid, amount, order_number):wxpay = wx_pay_func()str1 = generate_random_string()out_trade_no = order_number + str1description = out_trade_nopayer = {'openid': openid}code, message = wxpay.pay(description=description,out_trade_no=out_trade_no,amount={'total': amount},pay_type=WeChatPayType.MINIPROG,payer=payer)result = json.loads(message)if code in range(200, 300):APPID = get_config('wx_xcx_appid')prepay_id = result.get('prepay_id')timestamp = str(int(time.time()))noncestr = str(uuid.uuid4()).replace('-', '')package = 'prepay_id=' + prepay_idsign = wxpay.sign(data=[APPID, timestamp, noncestr, package])signtype = 'RSA'result = {'appId': APPID,'timeStamp': timestamp,'nonceStr': noncestr,'package': 'prepay_id=%s' % prepay_id,'signType': signtype,'paySign': sign}return reg_func(200, result, '微信支付下单成功')else:return reg_func(500, result.get('code'), '微信支付下单失败')

代码解释

这段Python代码实现了一个处理微信支付通知的API端点。以下是详细解释：

路由定义与请求处理函数

@order_api.route('/user/wx_xcx_pay/notify', methods=['POST'])
def new_notify():

这段代码定义了一个Flask路由，当客户端以POST请求访问/user/wx_xcx_pay/notify时，会调用new_notify函数。

获取请求头和初始化微信支付对象

    headers = request.headerswxpay = wx_pay_func()

首先获取请求的头信息，然后调用wx_pay_func函数初始化微信支付对象。

处理微信支付回调

    result = wxpay.callback(headers, request.data)

使用微信支付对象的callback方法处理回调数据，返回结果存储在result变量中。

判断支付是否成功并提取相关信息

    if result and result.get('event_type') == 'TRANSACTION.SUCCESS':resp = result.get('resource')out_trade_no = resp.get('out_trade_no')transaction_id = resp.get('transaction_id')first_character = out_trade_no[0]order_number = out_trade_no[:-3]success_time = resp.get('success_time')payer = resp.get('payer')amount = resp.get('amount').get('total')payment_amount = Decimal(amount) / Decimal(100)

检查支付结果是否成功，若成功，则从回调结果中提取相关信息，包括系统订单号、微信支付订单号、支付类型标识、实际订单号、支付完成时间、付款人信息以及支付金额。

根据支付类型调用不同的处理函数

        if first_character in ['X', 'Q']:return order_pay_callback(order_number, amount, success_time, transaction_id, resp)elif first_character == 'C':return recharge_pay_callback(order_number, transaction_id, payment_amount)elif first_character == 'B':return price_difference_payment_callback(order_number, transaction_id, payment_amount)else:return reg_func(200, None, '支付失败')

根据订单号的第一个字符判断支付类型，并调用相应的处理函数。

初始化微信支付对象函数

def wx_pay_func():mch_id = get_config('wx_xcx_pay_mid')appid = get_config('wx_xcx_appid')APIV3_KEY = get_config('wx_xcx_pay_secret')logging.basicConfig(filename=os.path.join(os.getcwd(), 'demo.log'), level=logging.DEBUG, filemode='a', format='%(asctime)s - %(process)s - %(levelname)s: %(message)s')LOGGER = logging.getLogger("demo")PROXY = NonePARTNER_MODE = FalseCERT_DIR = NoneTIMEOUT = (10, 30)PRIVATE_KEY = load_private_key('apiclient_key.pem')CERT_SERIAL_NO = get_config('CERT_SERIAL_NO')api_url = get_config('api_domain')NOTIFY_URL = f'https://{api_url}/user/wx_xcx_pay/notify'wxpay = WeChatPay(wechatpay_type=WeChatPayType.NATIVE,mchid=mch_id,private_key=PRIVATE_KEY,cert_serial_no=CERT_SERIAL_NO,apiv3_key=APIV3_KEY,appid=appid,notify_url=NOTIFY_URL,cert_dir=CERT_DIR,logger=LOGGER,partner_mode=PARTNER_MODE,proxy=PROXY,timeout=TIMEOUT)return wxpay

该函数初始化并返回一个微信支付对象，包含商户号、应用ID、API密钥等必要的配置，以及日志记录器和请求超时设置等。

函数解释

生成随机字符串函数

def generate_random_string():# 字符集合，包括大写字母、小写字母和数字characters = string.ascii_letters + string.digits# 从字符集合中随机选择3个字符random_string = ''.join(random.choices(characters, k=3))return random_string

• 功能：生成一个包含大写字母、小写字母和数字的随机字符串，长度为3。
• 步骤：
  • 定义字符集合，包括所有字母和数字。
  • 随机选择3个字符，并组合成一个字符串返回。

小程序支付函数

def xcx_pay(openid, amount, order_number):wxpay = wx_pay_func()str1 = generate_random_string()out_trade_no = order_number + str1description = out_trade_nopayer = {'openid': openid}code, message = wxpay.pay(description=description,out_trade_no=out_trade_no,amount={'total': amount},pay_type=WeChatPayType.MINIPROG,payer=payer)result = json.loads(message)if code in range(200, 300):APPID = get_config('wx_xcx_appid')prepay_id = result.get('prepay_id')timestamp = str(int(time.time()))noncestr = str(uuid.uuid4()).replace('-', '')package = 'prepay_id=' + prepay_idsign = wxpay.sign(data=[APPID, timestamp, noncestr, package])signtype = 'RSA'result = {'appId': APPID,'timeStamp': timestamp,'nonceStr': noncestr,'package': 'prepay_id=%s' % prepay_id,'signType': signtype,'paySign': sign}return reg_func(200, result, '微信支付下单成功')else:return reg_func(500, result.get('code'), '微信支付下单失败')

• 功能：为微信小程序生成支付订单，并返回支付参数给前端。

• 参数：

  • openid：用户的微信OpenID。
  • amount：支付金额（单位为分）。
  • order_number：订单号。

• 步骤：

  1. 初始化微信支付对象。
  2. 生成随机字符串并附加到订单号后面，形成新的商户订单号（out_trade_no）。
  3. 调用微信支付对象的pay方法，传入支付描述、商户订单号、支付金额、支付类型和付款人信息。
  4. 解析支付请求的返回结果。
  5. 如果请求成功（状态码在200到299之间）：
     • 获取应用ID和预支付交易会话标识（prepay_id）。
     • 生成当前时间戳、随机字符串和支付签名。
     • 构建支付参数并返回成功信息。
  6. 如果请求失败，返回错误信息。

总结

1. generate_random_string 函数用于生成一个长度为3的随机字符串，以增强订单号的唯一性。
2. xcx_pay 函数用于处理微信小程序支付请求，生成支付订单并返回支付参数给前端。

中文解释由chatgpt协助整理

这篇关于python flask 微信支付下单及支付结果回调处理代码笔记的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---