420 lines
17 KiB
Python
420 lines
17 KiB
Python
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)
|