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

2024-06-21 22:36

本文主要是介绍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 微信支付下单及支付结果回调处理代码笔记的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1082525

相关文章

问题:第一次世界大战的起止时间是 #其他#学习方法#微信

问题:第一次世界大战的起止时间是 A.1913 ~1918 年 B.1913 ~1918 年 C.1914 ~1918 年 D.1914 ~1919 年 参考答案如图所示

[职场] 护理专业简历怎么写 #经验分享#微信

护理专业简历怎么写   很多想成为一名护理方面的从业者,但是又不知道应该怎么制作一份简历,现在这里分享了一份护理方面的简历模板供大家参考。   蓝山山   年龄:24   号码:12345678910   地址:上海市 邮箱:jianli@jianli.com   教育背景   时间:2011-09到2015-06   学校:蓝山大学   专业:护理学   学历:本科

Tolua使用笔记(上)

目录   1.准备工作 2.运行例子 01.HelloWorld:在C#中,创建和销毁Lua虚拟机 和 简单调用。 02.ScriptsFromFile:在C#中,对一个lua文件的执行调用 03.CallLuaFunction:在C#中,对lua函数的操作 04.AccessingLuaVariables:在C#中,对lua变量的操作 05.LuaCoroutine:在Lua中,

AssetBundle学习笔记

AssetBundle是unity自定义的资源格式,通过调用引擎的资源打包接口对资源进行打包成.assetbundle格式的资源包。本文介绍了AssetBundle的生成,使用,加载,卸载以及Unity资源更新的一个基本步骤。 目录 1.定义: 2.AssetBundle的生成: 1)设置AssetBundle包的属性——通过编辑器界面 补充:分组策略 2)调用引擎接口API

大学湖北中医药大学法医学试题及答案,分享几个实用搜题和学习工具 #微信#学习方法#职场发展

今天分享拥有拍照搜题、文字搜题、语音搜题、多重搜题等搜题模式,可以快速查找问题解析,加深对题目答案的理解。 1.快练题 这是一个网站 找题的网站海量题库,在线搜题,快速刷题~为您提供百万优质题库,直接搜索题库名称,支持多种刷题模式:顺序练习、语音听题、本地搜题、顺序阅读、模拟考试、组卷考试、赶快下载吧! 2.彩虹搜题 这是个老公众号了 支持手写输入,截图搜题,详细步骤,解题必备

uniapp接入微信小程序原生代码配置方案(优化版)

uniapp项目需要把微信小程序原生语法的功能代码嵌套过来,无需把原生代码转换为uniapp,可以配置拷贝的方式集成过来 1、拷贝代码包到src目录 2、vue.config.js中配置原生代码包直接拷贝到编译目录中 3、pages.json中配置分包目录,原生入口组件的路径 4、manifest.json中配置分包,使用原生组件 5、需要把原生代码包里的页面修改成组件的方

公共筛选组件(二次封装antd)支持代码提示

如果项目是基于antd组件库为基础搭建,可使用此公共筛选组件 使用到的库 npm i antdnpm i lodash-esnpm i @types/lodash-es -D /components/CommonSearch index.tsx import React from 'react';import { Button, Card, Form } from 'antd'

《offer来了》第二章学习笔记

1.集合 Java四种集合:List、Queue、Set和Map 1.1.List:可重复 有序的Collection ArrayList: 基于数组实现,增删慢,查询快,线程不安全 Vector: 基于数组实现,增删慢,查询快,线程安全 LinkedList: 基于双向链实现,增删快,查询慢,线程不安全 1.2.Queue:队列 ArrayBlockingQueue:

17.用300行代码手写初体验Spring V1.0版本

1.1.课程目标 1、了解看源码最有效的方式,先猜测后验证,不要一开始就去调试代码。 2、浓缩就是精华,用 300行最简洁的代码 提炼Spring的基本设计思想。 3、掌握Spring框架的基本脉络。 1.2.内容定位 1、 具有1年以上的SpringMVC使用经验。 2、 希望深入了解Spring源码的人群,对 Spring有一个整体的宏观感受。 3、 全程手写实现SpringM

Python 字符串占位

在Python中,可以使用字符串的格式化方法来实现字符串的占位。常见的方法有百分号操作符 % 以及 str.format() 方法 百分号操作符 % name = "张三"age = 20message = "我叫%s,今年%d岁。" % (name, age)print(message) # 我叫张三,今年20岁。 str.format() 方法 name = "张三"age