zhaojiahui/enterprise-fuiou-payment-push
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

初始提交

Browse Source
This commit is contained in:
jefferyzhao
2025-07-30 18:43:53 +08:00
parent b23e3137f0
commit b5128aded8
27 changed files with 2192 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

419
app.py Normal file
View File

@ -0,0 +1,419 @@
from flask import Flask, request, redirect, abort, session, jsonify
from utils import *
from FuiouPay import H5Main
import logging
from logging.handlers import TimedRotatingFileHandler
import datetime
import os, _thread, urllib, re
from flask_cors import CORS
app = Flask(__name__)
app.config['SECRET_KEY'] = os.urandom(24)
CORS(app, supports_credentials=True)
def setup_logging():
"""配置日志系统，按天分割日志文件"""
# 创建日志目录
log_dir = "logs"
os.makedirs(log_dir, exist_ok=True)
# 设置日志格式
log_format = '%(asctime)s - %(name)s - %(levelname)s - %(message)s'
formatter = logging.Formatter(log_format)
# 创建按天轮转的文件处理器
file_handler = TimedRotatingFileHandler(
filename=os.path.join(log_dir, 'payapp.log'),
when='midnight', # 每天午夜轮转
interval=1, # 每天一个文件
backupCount=30, # 保留30天的日志
encoding='utf-8'
)
file_handler.setFormatter(formatter)
file_handler.setLevel(logging.INFO)
# 创建控制台处理器
console_handler = logging.StreamHandler()
console_handler.setFormatter(formatter)
console_handler.setLevel(logging.DEBUG)
# 获取根logger并配置
logger = logging.getLogger()
logger.setLevel(logging.DEBUG)
logger.addHandler(file_handler)
logger.addHandler(console_handler)
# 初始化日志配置
setup_logging()
# 获取当前模块的 logger
logger = logging.getLogger(__name__)
logger.info(f"PayApp started") # 会输出到文件和控制台
@app.route('/queryUserId', methods=['GET'])
def queryUserId():
# 获取支付明细
try:
code = request.args.get('code')
data = query_wx_userid(code)
if len(data) <= 13:
res = query_wx_fj_info(data)
data = res
logger.info(f'http://web.jiyuankeshang.com/#/pay?user={data}&appid={corpid}&agentid={agentid}')
return redirect(f'http://web.jiyuankeshang.com/#/pay?user={data}&appid={corpid}&agentid={agentid}')
except Exception as e:
logger.error("====================获取支付明细失败====================",e)
return jsonify(error=str(e)), 500
@app.route('/queryUser', methods=['GET'])
def queryUserApi():
# 获取支付明细
try:
id = request.args.get('user')
data = queryUser(id)
for item in data['pay_detail']:
if 'charge_amount' in item:
item['price'] = item.pop('charge_amount')
if 'charge_time' in item:
item['time'] = item.pop('charge_time')
logger.info(f"===================queryUserdata{data}")
return data
except Exception as e:
return {}
@app.route('/getZXPaymentDetails', methods=['GET'])
def getZXPaymentDetails():
try:
id = request.args.get('user','')
id = id.replace(" ", "")
if not id:
return {}
data = query_zxpay_details(id)
for item in data:
if item == "amount":
continue
for detail in data[item]['data']:
if 'month1' in detail:
detail['yuefen'] = detail.pop('month1')
if 'money' in detail:
detail['jine'] = detail.pop('money')
if 'no_money' in detail:
detail['unpay'] = detail.pop('no_money')
return data
except Exception as e:
logger.error(e)
return {}
@app.route('/getPaymentDetails', methods=['GET'])
def getPaymentDetails():
try:
id = request.args.get('user', '')
id = id.replace(" ", "")
if not id:
return {}
data = query_fzxpay_details(id)
for key in list(data.keys()):
if key != 'amount':
for detail in data[key]['data']:
if 'month1' in detail:
detail['yuefen'] = detail.pop('month1')
if 'money' in detail:
detail['jine'] = detail.pop('money')
if 'no_money' in detail:
detail['unpay'] = detail.pop('no_money')
data[key]['data'].sort(key=lambda x: x['sort'])
return data
except Exception as e:
logger.error(e)
return {}
@app.route('/getReasons', methods=['GET'])
def getReasons():
try:
reasons_data = query_reasons_for_payment()
# 使用字典推导式创建reason为键，dktype为值的字典
# 初始化字典，包含两个空列表作为值
dktype_to_reasons_dict = {
'非专项扣除': [],
'专项扣除': []
}
# 遍历数据，根据dktype的值将reason添加到对应的列表中
for item in reasons_data:
dktype = item['dktype']
reason = item['reason']
if dktype in dktype_to_reasons_dict:
dktype_to_reasons_dict[dktype].append(reason)
return dktype_to_reasons_dict
except Exception as e:
logger.error(e)
return {}
@app.route('/paymentCallBack', methods=['POST'])
def paymentCallBack():
# 充值成功后回调 {"pay_amount": 20000, "id": "18515367096"}
try:
logger.info(f"====================================paymentCallBack=========================================")
msg = request.data.decode('UTF-8')
logger.info(f"回调参数为===={msg}")
msg = eval(msg)
logger.info(f"eval参数为===={msg}")
if msg['resp_desc'] == '成功':
logger.info(f"=================================充值回调SUCCESS==========================================")
# rsa_key = RSA.importKey(open('E:/YinJian/银建支付对接维护说明/富友/enterprise-wechat-payment-push/priv_key.pem').read())
rsa_key = RSA.importKey(open('priv_key.pem').read())
logger.info(f"msg==={msg['message']}")
whp = rsa_long_decrypt(rsa_key, msg['message'])
logger.info(f"报文已解密{whp}")
whp_dict = json.loads(whp)
# 打印字典中的所有键
logger.info(f"1111111{whp_dict.keys()}")
# 获取'order_id'键的值并取前18个字符
id = whp_dict['order_id'][:18]
# 查询机构、分司
res = filter_jdy_ht(id)
logger.info(f"whp_dict{whp_dict}")
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 = "云闪付支付"
amount = amount / 100
#查询支付详情
query_url = f'{base_path}/api/v5/app/entry/data/list'
_query_tmp = {
"app_id": cw_app,
"entry_id": "67f38facbaccd58c66bd7db2",
"filter": {
"rel": "and",
"cond": [
{
"field": "order_id",
"method": "eq",
"value": [whp_dict['order_id']]
}
]
}
}
logger.info(f"开始查询支付信息{_query_tmp}")
res1 = req_tool_jdy(query_url, _query_tmp)
info1 = {"pay_amount": amount, "id": id,
"fs": res[1], "jg": res[0], "name": res[4],
"fsfz": res[6],"shfid": res[7],
"hphm": res[5], "transaction_id": transaction_id, "pay_type": pay_type,"paymentdetails": res1['data'][0]['paymentdetails']}
logger.info(f"充值回调处理{info1}")
if res1['data'][0]['paymentdetails'] == ["非专项"]:
_thread.start_new_thread(add_payment, ({"pay_amount": amount, "id": id,
"fs": res[1], "jg": res[0], "name": res[4],
"fsfz": res[6],"shfid": res[7],
"hphm": res[5], "transaction_id": transaction_id, "pay_type": pay_type, "paymentdetails": ""},))
else:
_thread.start_new_thread(add_payment, ({"pay_amount": amount, "id": id,
"fs": res[1], "jg": res[0], "name": res[4],
"fsfz": res[6], "shfid": res[7],
"hphm": res[5], "transaction_id": transaction_id,
"pay_type": pay_type,
"paymentdetails": res1['data'][0]['paymentdetails']},))
return {"code": 200}
except Exception as e:
logger.error(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:
logger.error(e)
return {}
@app.route('/addUnPayment', methods=['POST'])
def addUnPayment():
# 新增未收付明细 {"pay_amount": 20000, "id": "18515367096"}
try:
data = request.data.decode("utf-8")
data = data.replace("null", "None")
data = eval(data)
data = data['data']
if data['shgid'] == "" and data['mode_type'] == "自营" and data['lydunjiao'] != "趸交" and data['fukuanshiyou'] != "安全统筹":
res = filter_jdy_ht(data['id_card'])
_thread.start_new_thread(add_payment, ({"pay_amount": 0, "id": data['id_card'],
"fs": res[1], "jg": res[0], "name": res[4],
"fsfz": res[6],"shfid": res[7],
"hphm": res[5],"paymentdetails": []}, 1))
return {}
else:
return {}
except Exception as e:
logger.error(f"addUnPayment,e{e}, res{res}")
return {}
@app.route('/addPayment', methods=['POST'])
def addPayment():
# 新增充值明细 {"pay_amount": 20000, "id": "18515367096"}
try:
data = request.data.decode("utf-8")
logger.info(f"addPayment{data}")
data = data.replace("null", "None")
data = eval(data)
data = data['data']
if data['mode_type'] == "自营":
res = filter_jdy_ht(data['id_card'])
if not data['charge_amount']:
data['charge_amount'] = 0
if not res:
# 合同表单未有数据
fsfz = data['fsfz']['dept_no'] if data['fsfz'] else ""
_thread.start_new_thread(add_payment, ({"pay_amount": data['charge_amount'], "id": data['id_card'],"shfid":data['shfid'],
"fs": data['fs'], "jg": data['jg'], "name": data['name'],
"fsfz": fsfz, "hphm": data['hphm'],"paymentdetails": []}, 1))
else:
_thread.start_new_thread(add_payment, ({"pay_amount": data['charge_amount'], "id": data['id_card'],
"fs": res[1], "jg": res[0], "name": res[4],
"fsfz": res[6],"shfid": res[7],
"hphm": res[5],"paymentdetails": []}, 1))
return {}
else:
return {}
except Exception as e:
logger.error(f"addPayment,e{e}, data{data}")
return {}
@app.route('/transactions', methods=['GET'])
def transactions():
# 调起h5支付
try:
id = request.args.get('user')
price= request.args.get('price')
payment_details = request.args.get('paymentdetails')
if not payment_details:
return {}
else:
paymentdetails = payment_details.split(',')
add_url = f'{base_path}/api/v5/app/entry/data/create'
if not float(price):
res = filter_jdy_ht(id)
_thread.start_new_thread(add_payment, ({"pay_amount": 0, "id": id,
"fs": res[1], "jg": res[0], "name": res[4],
"fsfz": res[6],"shfid": res[7],
"hphm": res[5],"paymentdetails": paymentdetails}, 1))
return {}
else:
res = filter_jdy_ht(id)
if not res:
return "error"
# fy = H5Main(res[2]) 安全统筹修改
if any("安全统筹" in detail for detail in paymentdetails):
pattern = r"安全统筹\s*\d{4}-\d{2}"
paymentdetails = [payment for payment in paymentdetails if re.search(pattern, payment)]
if find_pay_details(id, paymentdetails) == 0:
return "paymentdetails is not exist"
fy = H5Main("0001000F7589577")
else:
fy = H5Main(res[2])
# 到此截止
price = float(price) * 100
# url = fy.unified_order(f"{id}{int(time.time())}", int(price), "订单支付").text
# url = eval(url)
order_id = f"{id}{int(time.time())}"
add_info = {
"app_id": cw_app,
"entry_id": "67f38facbaccd58c66bd7db2",
"is_start_trigger": True,
"is_start_workflow": True,
"data": {
"mode_type": {"value": "自营"},"name": {"value": res[4]}, "shfid": {"value": res[7]},
"id": {"value": id},"hphm": {"value": res[5]}, "jg": {"value": res[0]},
"fs": {"value": res[1]},"fsfz": {"value": res[6]}, "pay_amount": {"value": price},
"order_id": {"value": order_id},"paymentdetails": {"value": paymentdetails}
}
}
logger.info(f"add_info{add_info}")
req_tool_jdy(add_url, add_info)
message = fy.unified_order(order_id, int(price), "订单支付")
return message
except Exception as e:
if "could not convert string to float" in str(e):
err_str = "输入的金额必须为数字格式"
return jsonify(error=str(err_str)), 500
logger.error(f"error{e}")
return jsonify(error=str(e)), 500
@app.route('/paymentSuccess', methods=['POST'])
def paymentsuccess():
try:
logger.info(f"====================================machinepaymentSuccess=========================================")
msg = request.data.decode('UTF-8')
logger.info(f"机器返回回调参数为====",msg)
msg = eval(msg)
logger.info(f"=================================机器充值回调SUCCESS==========================================")
# 获取'order_id'键的值并取前18个字符
id = msg['id_card']
# 查询机构、分司
res = filter_jdy_ht(id)
transaction_id = msg['pay_ssn']
amount = float(msg['order_amt'])
order_pay_type = msg['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 = "云闪付支付"
elif order_pay_type == "JSAPI":
pay_type = "一体机支付"
amount = amount / 100
info2 = {"pay_amount": amount, "id": id,
"fs": res[1], "jg": res[0], "name": res[4],
"fsfz": res[6],"shfid": res[7],
"hphm": res[5], "transaction_id": transaction_id, "pay_type": pay_type,"paymentdetails": msg['paymentdetails']}
logger.info(f"充值回调处理{info2}")
if msg['paymentdetails'] == ["非专项"]:
_thread.start_new_thread(add_payment, ({"pay_amount": amount, "id": id,
"fs": res[1], "jg": res[0], "name": res[4],
"fsfz": res[6],"shfid": res[7],
"hphm": res[5], "transaction_id": transaction_id, "pay_type": pay_type, "paymentdetails": ""},))
else:
_thread.start_new_thread(add_payment, ({"pay_amount": amount, "id": id,
"fs": res[1], "jg": res[0], "name": res[4],
"fsfz": res[6], "shfid": res[7],
"hphm": res[5], "transaction_id": transaction_id,
"pay_type": pay_type,
"paymentdetails": msg['paymentdetails']},))
return {"code": 200}
except Exception as e:
logger.error(e)
return jsonify(error=str(e)), 500
if __name__ == '__main__':
app.run(host="0.0.0.0", port=3003, processes=True)