#!/usr/bin/env python # -*- coding: utf-8 -*- """ 独立的微信支付脚本（绕过 eventlet DNS 问题）使用方式： # 创建订单 python wechat_pay_worker.py create [product_id] # 查询订单 python wechat_pay_worker.py query # 检查配置 python wechat_pay_worker.py check 返回值：成功返回 0，失败返回 1 输出 JSON 格式的结果 """ import sys import json import os # 添加当前目录到路径 sys.path.insert(0, os.path.dirname(os.path.abspath(__file__))) def create_order(order_no, total_fee, body, product_id=None): """创建微信支付订单""" try: from wechat_pay import create_wechat_pay_instance wechat_pay = create_wechat_pay_instance() result = wechat_pay.create_native_order( order_no=order_no, total_fee=float(total_fee), body=body, product_id=product_id ) print(json.dumps(result, ensure_ascii=False)) return result.get('success', False) except Exception as e: print(json.dumps({ 'success': False, 'error': f'{type(e).__name__}: {str(e)}' }, ensure_ascii=False)) return False def query_order(order_no): """查询订单状态""" try: from wechat_pay import create_wechat_pay_instance wechat_pay = create_wechat_pay_instance() result = wechat_pay.query_order(order_no=order_no) print(json.dumps(result, ensure_ascii=False)) return result.get('success', False) except Exception as e: print(json.dumps({ 'success': False, 'error': f'{type(e).__name__}: {str(e)}' }, ensure_ascii=False)) return False def check_config(): """检查微信支付配置""" try: from wechat_pay import check_wechat_pay_ready is_ready, msg = check_wechat_pay_ready() result = { 'success': is_ready, 'message': msg } print(json.dumps(result, ensure_ascii=False)) return is_ready except Exception as e: print(json.dumps({ 'success': False, 'error': f'{type(e).__name__}: {str(e)}' }, ensure_ascii=False)) return False if __name__ == "__main__": if len(sys.argv) < 2: print(json.dumps({ 'success': False, 'error': 'Usage: python wechat_pay_worker.py [args...]' })) sys.exit(1) command = sys.argv[1] if command == 'create': if len(sys.argv) < 5: print(json.dumps({ 'success': False, 'error': 'Usage: python wechat_pay_worker.py create [product_id]' })) sys.exit(1) order_no = sys.argv[2] total_fee = sys.argv[3] body = sys.argv[4] product_id = sys.argv[5] if len(sys.argv) > 5 else None success = create_order(order_no, total_fee, body, product_id) sys.exit(0 if success else 1) elif command == 'query': if len(sys.argv) < 3: print(json.dumps({ 'success': False, 'error': 'Usage: python wechat_pay_worker.py query ' })) sys.exit(1) order_no = sys.argv[2] success = query_order(order_no) sys.exit(0 if success else 1) elif command == 'check': success = check_config() sys.exit(0 if success else 1) else: print(json.dumps({ 'success': False, 'error': f'Unknown command: {command}' })) sys.exit(1)