144 lines
5.1 KiB
Python
144 lines
5.1 KiB
Python
from flask import Flask, request, redirect, abort, session, jsonify, url_for
|
|
from utils import *
|
|
from FuiouPay import H5Main
|
|
# from WXPay import WXPay
|
|
import os, _thread, urllib
|
|
from flask_cors import CORS, cross_origin
|
|
|
|
|
|
|
|
app = Flask(__name__)
|
|
app.config['SECRET_KEY'] = os.urandom(24)
|
|
CORS(app, supports_credentials=True)
|
|
|
|
@app.route('/queryUser', methods=['GET'])
|
|
def queryUserApi():
|
|
# 获取支付明细
|
|
try:
|
|
id = request.args.get('user')
|
|
data = queryUser(id)
|
|
print("===================", data)
|
|
return data
|
|
except Exception as e:
|
|
return {}
|
|
|
|
@app.route('/page_notify', methods=['POST'])
|
|
@cross_origin()
|
|
def pageNotify():
|
|
"""处理 POST 请求并重定向为 GET 请求到 /redirect"""
|
|
try:
|
|
# 使用 303 See Other 状态码，将 POST 请求转换为 GET 请求的重定向
|
|
return redirect('/redirect', code=303)
|
|
except Exception as e:
|
|
print(f"Error occurred: {e}")
|
|
return jsonify({"error": "Internal Server Error"}), 500
|
|
|
|
@app.route('/redirect', methods=['GET'])
|
|
@cross_origin()
|
|
def redirectApi():
|
|
"""处理 GET 请求并重定向到外部 URL"""
|
|
try:
|
|
# 处理 GET 请求并重定向到外部 URL
|
|
return redirect('https://www.jiyuankeshang.com/f/66e412f9d396a07cd2c2662f', code=302)
|
|
except Exception as e:
|
|
print(f"Error occurred: {e}")
|
|
return jsonify({"error": "Internal Server Error"}), 500
|
|
|
|
|
|
@app.route('/getPaymentDetails', methods=['GET'])
|
|
def getPaymentDetails():
|
|
try:
|
|
id = request.args.get('user', '')
|
|
|
|
id = id.replace(" ", "")
|
|
|
|
if not id:
|
|
print("no id")
|
|
return {}
|
|
data = query_pay_details(id)
|
|
return data
|
|
except Exception as e:
|
|
print(e)
|
|
return {}
|
|
|
|
|
|
@app.route('/paymentCallBack', methods=['POST'])
|
|
def paymentCallBack():
|
|
# 充值成功后回调 {"pay_amount": 20000, "id": "18515367096"}
|
|
try:
|
|
print("====================================paymentCallBack=========================================")
|
|
msg = request.data.decode('UTF-8')
|
|
print("回调参数为====", msg)
|
|
msg = eval(msg)
|
|
print("eval参数为====", msg)
|
|
if msg['resp_desc'] == '成功':
|
|
print("=================================充值回调SUCCESS==========================================")
|
|
# rsa_key = RSA.importKey(open('priv_key.pem').read())
|
|
rsa_key = RSA.importKey(open('E:\YinJian\银建支付对接维护说明\DP\DP-enterprise-wechat-payment-push\priv_key.pem').read())
|
|
print("msg===",msg['message'])
|
|
print(rsa_key)
|
|
whp = rsa_long_decrypt(rsa_key, msg['message'])
|
|
print("报文已解密", whp)
|
|
whp_dict = json.loads(whp)
|
|
# 打印字典中的所有键
|
|
print("1111111",whp_dict.keys())
|
|
# 获取'order_id'键的值并取前18个字符
|
|
id = whp_dict['order_id'][:18]
|
|
# 查询机构、分司
|
|
res = filter_jdy_ht(id)
|
|
transaction_id = whp_dict['pay_ssn']
|
|
amount = float(whp_dict['order_amt'])
|
|
order_pay_type = whp_dict['order_pay_type']
|
|
# 判断支付类型
|
|
if order_pay_type[:2] == "We":
|
|
pay_type = "微信支付"
|
|
elif order_pay_type[:3] == "Ali":
|
|
pay_type = "支付宝支付"
|
|
elif order_pay_type == "0000000000":
|
|
pay_type = "云闪付支付"
|
|
else:
|
|
pay_type = "企微支付"
|
|
amount = amount / 100
|
|
payment_items = "承包金"
|
|
print("充值回调处理",{"pay_amount": amount, "id": id,
|
|
"sh": res[1], "base_company": res[0], "name": res[2], "transaction_id": transaction_id, "payment_items": payment_items, "pay_type": pay_type})
|
|
_thread.start_new_thread(add_payment, ({"pay_amount": amount, "id": id,
|
|
"sh": res[1], "base_company": res[0], "name": res[2], "transaction_id": transaction_id, "payment_items": payment_items, "pay_type": pay_type},))
|
|
return {"code": 200}
|
|
except Exception as e:
|
|
return jsonify(error=str(e)), 500
|
|
|
|
|
|
@app.route('/test', methods=['POST'])
|
|
def test():
|
|
# 新增未收付明细 {"pay_amount": 20000, "id": "18515367096"}
|
|
try:
|
|
data = request.data.decode("utf-8")
|
|
print(data)
|
|
return {}
|
|
except Exception as e:
|
|
print(e)
|
|
return {}
|
|
|
|
|
|
@app.route('/transactions', methods=['GET'])
|
|
def transactions():
|
|
# 调起h5支付
|
|
try:
|
|
print("开始支付")
|
|
id = request.args.get('user')
|
|
price = request.args.get('price')
|
|
print("金额", price)
|
|
price = float(price) * 100
|
|
fy = H5Main("0001000F8079871")
|
|
print("发起费用缴纳",f"{id}{int(time.time())}", int(price), "")
|
|
message = fy.unified_order(f"{id}{int(time.time())}", int(price), "订单支付")
|
|
return message
|
|
except Exception as e:
|
|
print("error", e)
|
|
return jsonify(error=str(e)), 500
|
|
|
|
|
|
if __name__ == '__main__':
|
|
app.run(host="0.0.0.0", port=3010, processes=True)
|