from datetime import datetime from Crypto.PublicKey import RSA import base64 from Crypto.Cipher import PKCS1_v1_5 import requests, time, json, uuid, datetime from flask import jsonify from config import * from dateutil.relativedelta import relativedelta import threading import urllib3 from Crypto.Cipher import AES from base64 import b64encode, b64decode import logging logger = logging.getLogger(__name__) urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning) lock = threading.Lock() def format_uct(origin_date_str): origin_date_str = origin_date_str.split('.')[0] utc_date = datetime.datetime.strptime(origin_date_str, "%Y-%m-%dT%H:%M:%S") local_date = utc_date + datetime.timedelta(hours=8) local_date_str = datetime.datetime.strftime(local_date, '%Y-%m-%d %H:%M:%S') return local_date_str def filter_jdy_ht(id): """筛选简道云合同表单中驾驶员对应信息""" url = f'{base_path}/api/v5/app/entry/data/list' filter_data = { "app_id": fu_app, "entry_id": ht_id, "limit": 100, "filter": { "rel": "and", "cond": [ { "field": "id", "method": "eq", "value": [id] } ] } } ht_detail = turn_page(url, filter_data) if not ht_detail: return [] ht_detail = ht_detail[0] # 机构 jg = ht_detail['jg'] # 分司 fs = ht_detail['ssbm'] # 商户号 sh = ht_detail['sh'] # 商户号证书 shzs = '38C5F89F06EC667D54936A4FF0DC93A227BFC128' # 姓名 name = ht_detail['name'] # 车牌号 hphm = ht_detail['hphm'] # 分司负责人 fsfz = ht_detail['fsfz']['dept_no'] if ht_detail['fsfz'] else "" shfid = ht_detail['shfid'] return [jg, fs, sh, shzs, name, hphm, fsfz, shfid] def queryUser(id): # 查询充值明细 # user = get_user_info(id) url = f'{base_path}/api/v5/app/entry/data/list' filter_data = { "app_id": pay_app, "entry_id": pay_details_id, "limit": 100, "filter": { "rel": "and", "cond": [ { "field": "pay_type", "method": "in", "value": ["微信支付","支付宝支付","云闪付支付"] }, { "field": "id_card", "method": "eq", "value": [id] } ] } } filter_data_lw = { "app_id": lw_pay_app, "entry_id": lw_pay_details_id, "limit": 100, "filter": { "rel": "and", "cond": [ { "field": "pay_type", "method": "in", "value": ["微信支付","支付宝支付","云闪付支付"] }, { "field": "id_card", "method": "eq", "value": [id] } ] } } pay_detail1 = turn_page(url, filter_data) pay_detail2 = turn_page(url, filter_data_lw) pay_detail = pay_detail1 + pay_detail2 for i in pay_detail: i['charge_time'] = format_uct(i['charge_time']) # 查询个人余额 info = { "app_id": pay_app, "entry_id": accout_id, "filter": {"rel": "and", "cond": [ { "field": "id_card", "method": "eq", "value": [id] }, { "field": "date", "method": "empty", } ]} } # 查询个人余额账户表 res = req_tool_jdy(url, info) balance = 0 if res['data']: balance = res['data'][0]['balance'] balance = float("%.2f" % balance) return {"balance": balance, "pay_detail": pay_detail} def querydpUser(id): # 查询充值明细 # user = get_user_info(id) url = f'{base_path}/api/v5/app/entry/data/list' filter_data = { "app_id": pay_app, "entry_id": pay_details_id, "limit": 100, "filter": { "rel": "and", "cond": [ { "field": "pay_type", "method": "in", "value": ["微信支付","支付宝支付","云闪付支付"] }, { "field": "id_card", "method": "eq", "value": [id] } ] } } pay_detail = turn_page(url, filter_data) for i in pay_detail: i['charge_time'] = format_uct(i['charge_time']) # 查询个人余额 info = { "app_id": pay_app, "entry_id": accout_id, "filter": {"rel": "and", "cond": [ { "field": "id_card", "method": "eq", "value": [id] }, { "field": "mode_type", "method": "eq", "value": ['DP'] }, { "field": "date", "method": "empty", } ]} } # 查询个人余额账户表 res = req_tool_jdy(url, info) balance = 0 if res['data']: balance = res['data'][0]['balance'] balance = float("%.2f" % balance) return {"balance": balance, "pay_detail": pay_detail} def get_last_8_hour(): _time = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time() - 8 * 60 * 60)) return _time def turn_page(url, data): """翻页查询""" info = [] while 1: try: res = req_tool_jdy(url, data) info += res['data'] if len(res['data']) < 100: return info data["data_id"] = res["data"][-1]["_id"] except Exception as e: logger.error(f"turn_page,e{e}, res{res}") def get_user_info(id, type=None): """获取用户信息""" url = f'{base_path}/api/v5/app/entry/data/list' if type: filter_data = { "app_id": fu_app, "entry_id": fu_id, "filter": { "rel": "and", "cond": [ { "field": "id_card", "method": "eq", "value": [id] } ] } } else: filter_data = { "app_id": fu_app, "entry_id": fu_id, "filter": { "rel": "and", "cond": [ { "field": "user", "method": "eq", "value": [id] } ] } } res = req_tool_jdy(url, filter_data) if res['data']: return res['data'][0] return '' def query_pay_details(id): # 查询某人未收付明细 url = f'{base_path}/api/v5/app/entry/data/list' filter_data = { "app_id": pay_app, "entry_id": uncollected_id, "limit": 100, "filter": { "rel": "and", "cond": [ { "field": "id_card", "method": "eq", "value": [id] }, { "field": "bill_type", "method": "eq", "value": "个人账单" }, { "field": "no_money", "method": "eq", "value": [id] }, ] } } filter_data_lw = { "app_id": lw_pay_app, "entry_id": lw_uncollected_id, "limit": 100, "filter": { "rel": "and", "cond": [ { "field": "id_card", "method": "eq", "value": [id] }, { "field": "no_money", "method": "eq", "value": [id] }, ] } } uncollected_data1 = turn_page(url, filter_data) for i in uncollected_data1: flag = False if i['bill_type'] == "个人账单": flag = True break uncollected_data2 = turn_page(url, filter_data_lw) uncollected_data = uncollected_data1 + uncollected_data2 _data = [] for i in uncollected_data: flag = False for j in ["收预收承包金", "承包金", "调度费", "保养费", "营运服务费", "费税收取-其他", "维修费", "违约金", "驾驶员履约服务费", "发票罚款", "停车费", "交通违法扣款", "车辆管理费"]: if j == i['fukuanshiyou']: flag = True break if not flag: continue i['money'] = float("%.2f" % i['money']) if i['money'] else 0 i['pay'] = float("%.2f" % i['pay']) if i['pay'] != None and i['pay'] != '' else 0 i['no_money'] = float("%.2f" % i['no_money']) if i['no_money'] != None and i['no_money'] != '' else 0 i['sort'] = 9999 for j in rule_sort: if j in i['fukuanshiyou']: i['sort'] = rule_sort[j] _data.append(i) uncollected_data = _data uncollected_data = sorted(uncollected_data, key=lambda x: x['createTime'], reverse=True) # 过滤已结清数据 uncollected_data = [i for i in uncollected_data if i['money'] != i['pay']] undata = {} # 按月份归类 uncollected_data for un in uncollected_data: if un['month1'] in undata.keys(): undata[un['month1']]['data'].append(un) else: undata[un['month1']] = {"data": []} undata[un['month1']]['data'] = [un] # # 按月查询增减项 flowState结束 amount = 0 for un in undata: _th_amount = 0 del_list = [] filter_data = { "app_id": hz_app, "entry_id": hz_id, "limit": 100, "filter": { "rel": "and", "cond": [ { "field": "id_card", "method": "eq", "value": [id] }, { "field": "month1", "method": "eq", "value": [un] }, ] } } hz_data_list = turn_page(url, filter_data) # 应付总额 承包金定额=应收承包金-增减项 zj_sum = sum(item['jine'] for item in hz_data_list) for index, j in enumerate(undata[un]['data']): j['no_money'] = j['no_money'] if j['no_money'] else j['money'] if '承包金' in j['fukuanshiyou'] and j['yewubiaodanmingcheng'] == '费税计划': if j['pay'] - zj_sum == j['money']: del_list.append(index) continue # 定额 de = 表单中的金额-增减 # 应付金额 money = 表单中的金额 # 未付金额 no_money = 应付金额-增减-已付金额 j['pay'] = j['pay'] if j['pay'] else 0 undata[un]['de'] = j['money'] - zj_sum # j['money'] = undata[un]['de'] + zj_sum j['no_money'] = j['money'] - j['pay'] amount += j['no_money'] if j['no_money'] else j['money'] _th_amount += j['no_money'] if j['no_money'] else j['money'] undata[un]['_th_amount'] = _th_amount undata[un]['hz'] = hz_data_list for d in del_list: undata[un]['data'].pop(d) undata['amount'] = float("%.2f" % amount) for i in list(undata.keys()): if i != 'amount' and not undata[i]['data']: del undata[i] return undata def query_dp_pay_details(id): # 查询某人未收付明细 url = f'{base_path}/api/v5/app/entry/data/list' filter_data = { "app_id": pay_app, "entry_id": uncollected_id, "limit": 100, "filter": { "rel": "and", "cond": [ { "field": "id_card", "method": "eq", "value": [id] }, { "field": "mode_type", "method": "eq", "value": ['DP'] }, { "field": "no_money", "method": "eq", "value": [id] }, ] } } logger.info(f"开始查询未收付明细, id_card: {id},filter_data: {filter_data} ") uncollected_data = turn_page(url, filter_data) _data = [] for i in uncollected_data: flag = False for j in ["收预收承包金", "承包金", "调度费", "保养费", "营运服务费", "费税收取-其他", "维修费", "违约金", "驾驶员履约服务费", "发票罚款", "停车费", "交通违法扣款", "车辆管理费"]: if j == i['fukuanshiyou']: if i['bill_type'] == "个人账单": flag = True break if not flag: continue i['money'] = float("%.2f" % i['money']) if i['money'] else 0 i['pay'] = float("%.2f" % i['pay']) if i['pay'] != None and i['pay'] != '' else 0 i['no_money'] = float("%.2f" % i['no_money']) if i['no_money'] != None and i['no_money'] != '' else 0 i['sort'] = 9999 for j in rule_sort: if j in i['fukuanshiyou']: i['sort'] = rule_sort[j] _data.append(i) uncollected_data = _data uncollected_data = sorted(uncollected_data, key=lambda x: x['createTime'], reverse=True) # 过滤已结清数据 uncollected_data = [i for i in uncollected_data if i['money'] != i['pay']] undata = {} # 按月份归类 uncollected_data for un in uncollected_data: if un['month1'] in undata.keys(): undata[un['month1']]['data'].append(un) else: undata[un['month1']] = {"data": []} undata[un['month1']]['data'] = [un] # # 按月查询增减项 flowState结束 amount = 0 for un in undata: _th_amount = 0 del_list = [] filter_data = { "app_id": hz_app, "entry_id": hz_id, "limit": 100, "filter": { "rel": "and", "cond": [ { "field": "id_card", "method": "eq", "value": [id] }, { "field": "mode_type", "method": "eq", "value": ['DP'] }, { "field": "month1", "method": "eq", "value": [un] }, ] } } hz_data_list = turn_page(url, filter_data) # 应付总额 承包金定额=应收承包金-增减项 zj_sum = sum(item['jine'] for item in hz_data_list) for index, j in enumerate(undata[un]['data']): j['no_money'] = j['no_money'] if j['no_money'] else j['money'] if '承包金' in j['fukuanshiyou'] and j['yewubiaodanmingcheng'] == '费税计划': if j['pay'] - zj_sum == j['money']: del_list.append(index) continue # 定额 de = 表单中的金额-增减 # 应付金额 money = 表单中的金额 # 未付金额 no_money = 应付金额-增减-已付金额 j['pay'] = j['pay'] if j['pay'] else 0 undata[un]['de'] = j['money'] - zj_sum # j['money'] = undata[un]['de'] + zj_sum j['no_money'] = j['money'] - j['pay'] amount += j['no_money'] if j['no_money'] else j['money'] _th_amount += j['no_money'] if j['no_money'] else j['money'] undata[un]['_th_amount'] = _th_amount undata[un]['hz'] = hz_data_list for d in del_list: undata[un]['data'].pop(d) undata['amount'] = float("%.2f" % amount) for i in list(undata.keys()): if i != 'amount' and not undata[i]['data']: del undata[i] return undata def query_lw_pay_details(id): # 查询某人未收付明细 url = f'{base_path}/api/v5/app/entry/data/list' filter_data_lw = { "app_id": lw_pay_app, "entry_id": lw_uncollected_id, "limit": 100, "filter": { "rel": "and", "cond": [ { "field": "id_card", "method": "eq", "value": [id] }, { "field": "no_money", "method": "eq", "value": [id] }, ] } } uncollected_data = turn_page(url, filter_data_lw) _data = [] for i in uncollected_data: flag = False for j in ["收预收承包金", "承包金", "调度费", "保养费", "营运服务费", "费税收取-其他", "维修费", "违约金", "驾驶员履约服务费", "交通违法扣款"]: if j == i['fukuanshiyou']: flag = True break if not flag: continue i['money'] = float("%.2f" % i['money']) if i['money'] else 0 i['pay'] = float("%.2f" % i['pay']) if i['pay'] != None and i['pay'] != '' else 0 i['no_money'] = float("%.2f" % i['no_money']) if i['no_money'] != None and i['no_money'] != '' else 0 i['sort'] = 9999 for j in rule_sort: if j in i['fukuanshiyou']: i['sort'] = rule_sort[j] _data.append(i) uncollected_data = _data uncollected_data = sorted(uncollected_data, key=lambda x: x['createTime'], reverse=True) # 过滤已结清数据 uncollected_data = [i for i in uncollected_data if i['money'] != i['pay']] undata = {} # 按月份归类 uncollected_data for un in uncollected_data: if un['month1'] in undata.keys(): undata[un['month1']]['data'].append(un) else: undata[un['month1']] = {"data": []} undata[un['month1']]['data'] = [un] # # 按月查询增减项 flowState结束 amount = 0 for un in undata: _th_amount = 0 del_list = [] filter_data = { "app_id": hz_app, "entry_id": hz_id, "limit": 100, "filter": { "rel": "and", "cond": [ { "field": "id_card", "method": "eq", "value": [id] }, { "field": "month1", "method": "eq", "value": [un] }, ] } } hz_data_list = turn_page(url, filter_data) # 应付总额 承包金定额=应收承包金-增减项 zj_sum = sum(item['jine'] for item in hz_data_list) for index, j in enumerate(undata[un]['data']): j['no_money'] = j['no_money'] if j['no_money'] else j['money'] if '承包金' in j['fukuanshiyou'] and j['yewubiaodanmingcheng'] == '费税计划': if j['pay'] - zj_sum == j['money']: del_list.append(index) continue # 定额 de = 表单中的金额-增减 # 应付金额 money = 表单中的金额 # 未付金额 no_money = 应付金额-增减-已付金额 j['pay'] = j['pay'] if j['pay'] else 0 undata[un]['de'] = j['money'] - zj_sum # j['money'] = undata[un]['de'] + zj_sum j['no_money'] = j['money'] - j['pay'] amount += j['no_money'] if j['no_money'] else j['money'] _th_amount += j['no_money'] if j['no_money'] else j['money'] undata[un]['_th_amount'] = _th_amount undata[un]['hz'] = hz_data_list for d in del_list: undata[un]['data'].pop(d) undata['amount'] = float("%.2f" % amount) for i in list(undata.keys()): if i != 'amount' and not undata[i]['data']: del undata[i] return undata def req_tool_jdy(url, data): headers = {"Authorization": f"Bearer {apikey}"} while 1: try: res = requests.post(url, headers=headers, json=data, timeout=20, verify=False).json() if "code" in res.keys(): logger.info(f"req_tool_jdy{res}") time.sleep(2) continue return res except Exception as e: logger.error(f"error, {e}") def req_tool_vx(url, data=None, flag=None): while 1: try: if not flag: res = requests.post(url, json=data, timeout=10, verify=False).json() else: res = requests.get(url, timeout=10, verify=False).json() return res except Exception as e: logger.error(f"error, {e}") def update_no_money(data): """更新未收付，添加已收付明细""" url = f'{base_path}/api/v5/app/entry/data/update' add_url = f'{base_path}/api/v5/app/entry/data/create' del_url = f'{base_path}/api/v1/app/{pay_app}/entry/{uncollected_id}/data_delete' for i in data: if 'amount' == i: continue for j in data[i]['data']: if j['fukuanshiyou'] == '驾驶员履约服务费': continue info = { "app_id": pay_app, "entry_id": uncollected_id, "data_id": j['_id'], "is_start_trigger": True, "is_start_workflow": True, "data": { "pay": {"value": j['pay']}, "no_money": {"value": j['no_money']} } } req_tool_jdy(url, info) now_time = get_last_8_hour() # 新增已收付明细 if 'flag' in j.keys() and float(j['flag_m']): if not j['flag_m'] or not float(j['flag_m']): continue fs_p = j['fs_p']['dept_no'] if j['fs_p'] else "" add_info = { "app_id": pay_app, "entry_id": received_id, "is_start_trigger": True, "is_start_workflow": True, "data": { "code": {"value": j['code']}, "type": {"value": "收款"}, "fukuanshiyou": {"value": j['fukuanshiyou']}, "month": {"value": j['month']}, "month1": {"value": j['month1']},"yewubiaodanmingcheng": {"value": j['yewubiaodanmingcheng']}, "yewubiaodanbianma": {"value": j['yewubiaodanbianma']}, "sijixingming": {"value": j['sijixingming']},"shfid": {"value": j['shfid']}, "id_card": {"value": j['id_card']},"pay_time": {"value": now_time}, "company_jc": {"value": j['company_jc']}, "xd": {"value": j['xd']}, "sijisuozaigongsi": {"value": j['sijisuozaigongsi']}, "fs": {"value": j['fs']}, "license_plate": {"value": j['license_plate']}, "money": {"value": j['money']}, "pay": {"value": j['flag_m']}, "hz_month": {"value": j['hz_month']}, "zjin_status": {"value": "未结算"}, "fs_p": {"value": fs_p}, "shgid": {"value": j['shgid']}, "mode_type": {"value": j['mode_type']}, "sy": {"value": "个人账户抵扣"},"ys": {"value": j['ys']},"lydunjiao": {"value": j['lydunjiao']},"bill_type": {"value": j['bill_type']}, "car_dept": {"value": j['car_dept']},"contract_num": {"value": j['contract_num']} } } logger.info(f"新增已收========={add_info}") req_tool_jdy(add_url, add_info) logger.info(f"删除========={j['pay']}, {j['money']}" ) if j['sijixingming'] == '姓名': logger.info(f"j,{j}") if j['pay'] == j['money']: # 未收付已清缴，删除未收付明细 del_info = { "data_id": j["_id"], "is_start_trigger": True } # 新增劳务佣金 # today_str = datetime.datetime.now().strftime('%Y-%m-%d') # if j['name'] == "承包金": # add_info = { # "app_id": pay_app, # "entry_id": uncollected_id, # "is_start_trigger": True, # "is_start_workflow": True, # "data": { # "type": {"value": "付款"}, # "name": {"value": "劳务佣金"}, "month": {"value": j['month']}, # "yewubiaodanmingcheng": {"value": "已收付表单"}, # "yewubiaodanbianma": {"value": j['yewubiaodanbianma']}, # "sijixingming": {"value": j['sijixingming']}, # "id_card": {"value": j['id_card']}, # "sijisuozaigongsi": {"value": j['sijisuozaigongsi']}, "fs": {"value": j['fs']}, # "_widget_1704357037281": {"value": j['_widget_1704357037281']}, # "abbreviation": {"value": j['abbreviation']}, "money": {"value": j['lw_money']}, # "pay": {"value": 0}, "no_money": {"value": j['lw_money']}, # "fs_p": {"value": fs_p}, "status1": {"value": "已清缴"}, # "lw_money": {"value": j['lw_money']},"hz_month": {"value": j['hz_month']}, # "ys": {"value": today_str}, "month1": {"value": j['month1']}, # "bill_type": {"value": "劳务"} # } # } # req_tool_jdy(add_url, add_info) logger.info(f"===========================未收付已清缴，删除未收付明细===============================") req_tool_jdy(del_url, del_info) def update_lw_no_money(data): """更新未收付，添加已收付明细""" url = f'{base_path}/api/v5/app/entry/data/update' add_url = f'{base_path}/api/v5/app/entry/data/create' del_url = f'{base_path}/api/v1/app/{lw_pay_app}/entry/{lw_uncollected_id}/data_delete' for i in data: if 'amount' == i: continue for j in data[i]['data']: if j['fukuanshiyou'] != '驾驶员履约服务费': continue info = { "app_id": lw_pay_app, "entry_id": lw_uncollected_id, "data_id": j['_id'], "is_start_trigger": True, "is_start_workflow": True, "data": { "pay": {"value": j['pay']}, "no_money": {"value": j['no_money']}, } } logger.info(f"更新未收{info}") req_tool_jdy(url, info) # 新增已收付明细 if 'flag' in j.keys() and float(j['flag_m']): if not j['flag_m'] or not float(j['flag_m']): continue fs_p = j['fs_p']['dept_no'] if j['fs_p'] else "" add_info = { "app_id": lw_pay_app, "entry_id": lw_received_id, "is_start_trigger": True, "is_start_workflow": True, "data": { "code": {"value": j['code']}, "type": {"value": "收款"}, "fukuanshiyou": {"value": j['fukuanshiyou']}, "month": {"value": j['month']}, "yewubiaodanmingcheng": {"value": j['yewubiaodanmingcheng']}, "yewubiaodanbianma": {"value": j['yewubiaodanbianma']}, "sijixingming": {"value": j['sijixingming']}, "sijishenfenzhenghao": {"value": j['id_card']},"shfid": {"value": j['shfid']}, "sijisuozaigongsi": {"value": j['sijisuozaigongsi']}, "fs": {"value": j['fs']}, "license_plate": {"value": j['car_num']},"abbreviation": {"value": j['abbreviation']}, "jine": {"value": j['money']}, "pay": {"value": j['flag_m']}, "fs_p": {"value": fs_p}, "status1": {"value": "已清缴"}, "status": {"value": "已收款"}, "month1": {"value": j['month1']} } } logger.info(f"=====================新增已收付{data}") req_tool_jdy(add_url, add_info) logger.info(f"删除========={j['pay']}, {j['money']}") if j['sijixingming'] == '姓名': logger.info(f"j,{j}") if j['pay'] == j['money']: # 未收付已清缴，删除未收付明细 del_info = { "data_id": j["_id"], "is_start_trigger": True } logger.info(f"===========================履约服务费已清缴，删除未收付明细===============================") req_tool_jdy(del_url, del_info) def update_info(cz, _balcace, balance, user_info): # 余额 = 累计充值金额-累计抵扣金额 # 本次抵扣=本次充值+本次余额-剩余金额 di = cz + balance - _balcace """更新个人账户余额""" # if pay_amount: # # 支付完有剩余余额可直接更新 # amount = pay_amount # else: # # 查询未收付历史数据 # details = query_pay_details(user_info['user']['username']) # amount = details['amount'] # amount *= -1 url = f'{base_path}/api/v5/app/entry/data/list' info = { "app_id": pay_app, "entry_id": accout_id, "filter": {"rel": "and", "cond": [ { "field": "id_card", "method": "eq", "value": [user_info['id']] }, { "field": "date", "method": "empty" }, ]} } # 查询个人余额账户表 没有新增，有更新 res = req_tool_jdy(url, info) if res['data']: # 更新 url = f'{base_path}/api/v5/app/entry/data/update' pay = res['data'][-1]['pay'] + cz di = di + (res['data'][-1]['deduction'] if res['data'][-1]['deduction'] else 0) amount = pay - di # 累计充值-累计抵扣 info = { "app_id": pay_app, "entry_id": accout_id, "data_id": res['data'][-1]["_id"], "is_start_workflow": True, "is_start_trigger": True, "data": { "pay": {"value": pay}, "balance": {"value": amount}, "deduction": {"value": di} } } else: # 新增 amount = cz - di # 本次充值-本次抵扣 if 'name' in user_info.keys(): name = user_info['name'] else: name = "" url = f'{base_path}/api/v5/app/entry/data/create' info = { "app_id": pay_app, "entry_id": accout_id, "is_start_workflow": True, "is_start_trigger": True, "data": { "id_card": {"value": user_info['id']}, "name": {"value": name}, "pay": {"value": cz}, "deduction": {"value": di}, "account_type": {"value": "预收款"}, "balance": {"value": amount}, "jg": {"value": user_info['jg']}, "mode_type": {"value": "DP"}, "car_dept": {"value": "DP"}, "fs": {"value": user_info['fs']}, "fsfz": {"value": user_info['fsfz']}, "hphm": {"value": user_info['hphm']}, "shfid": {"value": user_info['shfid']}, } } req_tool_jdy(url, info) def add_payment(data, type=None): lock.acquire() logger.info(f"开始========data{data}, type{type}") # user = get_user_info(data['id']) # 充值成功后 回写充值明细 now_month = datetime.datetime.now().strftime("%Y-%m") now_time = get_last_8_hour() url = f'{base_path}/api/v5/app/entry/data/create' if not type: # 查询是否已存在 query_url = f'{base_path}/api/v5/app/entry/data/list' _query_tmp = { "app_id": pay_app, "entry_id": pay_details_id, "filter": { "rel": "and", "cond": [ { "field": "transactionid", "method": "eq", "value": [data['transaction_id']] } ] } } res = req_tool_jdy(query_url, _query_tmp) if res['data']: logger.info(f"充值明细已存在========{data['transaction_id']}") lock.release() return info = { "app_id": pay_app, "entry_id": pay_details_id, "is_start_workflow": True, "is_start_trigger": True, "data": { "id_card": {"value": data['id']}, "name": {"value": data['name']}, "charge_amount": {"value": data['pay_amount']}, "pay_type": {"value": data['pay_type']}, "coll_type": {"value": "网银"}, "month": {"value": now_month},"fsfz": {"value": data['fsfz']}, "jg": {"value": data['jg']}, "fs": {"value": data['fs']},"mode_type": {"value": "DP"},"collect_pos": {"value": data['jg']}, "hphm": {"value": data['hphm']},"shfid":{"value": data['shfid']},"zhtype": {"value": "预收款"},"type": {"value": "转入"}, "charge_time": {"value": now_time}, "transactionid": {"value": data['transaction_id']} } } if data['fsfz']: info['data']["fsfz"] = {"value": data['fsfz']} req_tool_jdy(url, info) details = query_dp_pay_details(data['id']) dates = list(details.keys()) dates.sort() dates.remove('amount') pay_amount = data['pay_amount'] # 查询余额 balance = querydpUser(data['id']) pay_amount += balance['balance'] if pay_amount <= 0: logger.info(f"余额为0结束========{data}") lock.release() return logger.info(f"执行承包金add_payment{data}") next_month = (datetime.datetime.now().date() - relativedelta(months=-1)).strftime("%Y-%m") if next_month in dates: _tmp = details[next_month]['data'] _tmp = sorted(_tmp, key=lambda x: x['sort']) for i in _tmp: if pay_amount: i['flag'] = 1 if '承包金' in i['fukuanshiyou']: # 承包金实际需要缴纳的 if pay_amount < i['money'] - i['pay']: # 修改 i['pay'] 充值金额，推送修改 i['pay'] += pay_amount i['no_money'] = i['money'] - i['pay'] i['flag_m'] = pay_amount pay_amount = 0 else: pay_amount -= (i['money'] - i['pay']) i['flag_m'] = (i['money'] - i['pay']) i['pay'] = i['money'] i['no_money'] = 0 else: if i['money'] != i['pay']: # 根据未支付的金额，扣除总金额 df = i['money'] - i['pay'] if pay_amount < df: # 修改 i['pay'] 充值金额，推送修改 i['pay'] += pay_amount i['no_money'] = i['money'] - i['pay'] i['flag_m'] = pay_amount pay_amount = 0 else: pay_amount -= df i['pay'] = i['money'] i['no_money'] = 0 i['flag_m'] = df if now_month in dates: _tmp = details[now_month]['data'] _tmp = sorted(_tmp, key=lambda x: x['sort']) for i in _tmp: if pay_amount: i['flag'] = 1 if '承包金' in i['fukuanshiyou']: # 承包金实际需要缴纳的 if pay_amount < i['money'] - i['pay']: # 修改 i['pay'] 充值金额，推送修改 i['pay'] += pay_amount i['no_money'] = i['money'] - i['pay'] i['flag_m'] = pay_amount pay_amount = 0 else: pay_amount -= (i['money'] - i['pay']) i['flag_m'] = (i['money'] - i['pay']) i['pay'] = i['money'] i['no_money'] = 0 else: if i['money'] != i['pay']: # 根据未支付的金额，扣除总金额 df = i['money'] - i['pay'] if pay_amount < df: # 修改 i['pay'] 充值金额，推送修改 i['pay'] += pay_amount i['no_money'] = i['money'] - i['pay'] i['flag_m'] = pay_amount pay_amount = 0 else: pay_amount -= df i['pay'] = i['money'] i['no_money'] = 0 i['flag_m'] = df for i in dates: if i == next_month or i == now_month: continue _tmp = details[i]['data'] _tmp = sorted(_tmp, key=lambda x: x['sort']) for i in _tmp: if pay_amount: i['flag'] = 1 if '承包金' in i['fukuanshiyou']: # 承包金实际需要缴纳的 if pay_amount < i['money'] - i['pay']: # 修改 i['pay'] 充值金额，推送修改 i['pay'] += pay_amount i['no_money'] = i['money'] - i['pay'] i['flag_m'] = pay_amount pay_amount = 0 else: pay_amount -= (i['money'] - i['pay']) i['flag_m'] = (i['money'] - i['pay']) i['pay'] = i['money'] i['no_money'] = 0 else: if i['money'] != i['pay']: # 根据未支付的金额，扣除总金额 df = i['money'] - i['pay'] if pay_amount < df: # 修改 i['pay'] 充值金额，推送修改 i['pay'] += pay_amount i['no_money'] = i['money'] - i['pay'] i['flag_m'] = pay_amount pay_amount = 0 else: pay_amount -= df i['pay'] = i['money'] i['no_money'] = 0 i['flag_m'] = df # 根据抵扣规则，更新未支付的数据，将清缴数据新增至已收付明细 logger.info(f"更新未收付{details}") update_no_money(details) # 未收付更新完后，更新个人账户余额update_info logger.info(f"更新个人账户余额update_info") update_info(data['pay_amount'], pay_amount, balance['balance'], data) lock.release() logger.info(f"结束========") def add_payment_lw(data, type=None): lock.acquire() logger.info(f"开始========{data}") logger.info(f"data{data}, type{type}") # user = get_user_info(data['id']) # 充值成功后 回写充值明细 now_month = datetime.datetime.now().strftime("%Y-%m") now_time = get_last_8_hour() url = f'{base_path}/api/v5/app/entry/data/create' if not type: # 查询是否已存在 query_url = f'{base_path}/api/v5/app/entry/data/list' _query_tmp = { "app_id": lw_pay_app, "entry_id": lw_pay_details_id, "filter": { "rel": "and", "cond": [ { "field": "transactionid", "method": "eq", "value": [data['transaction_id']] } ] } } res = req_tool_jdy(query_url, _query_tmp) if res['data']: logger.info(f"充值明细已存在========{data}"['transaction_id']) lock.release() return info = { "app_id": lw_pay_app, "entry_id": lw_pay_details_id, "is_start_workflow": True, "is_start_trigger": True, "data": { "id_card": {"value": data['id']}, "name": {"value": data['name']}, "price": {"value": data['pay_amount']}, "pay_type": {"value": data['pay_type']}, "month": {"value": now_month},"shfid": {"value": data['shfid']}, "jg": {"value": data['jg']}, "fs": {"value": data['fs']}, "hphm": {"value": data['hphm']},"pay_status": {"value": "付款成功"}, "charge_time": {"value": now_time}, "transactionid": {"value": data['transaction_id']} } } if data['fsfz']: info['data']["fsfz"] = {"value": data['fsfz']} req_tool_jdy(url, info) details = query_lw_pay_details(data['id']) dates = list(details.keys()) dates.sort() dates.remove('amount') pay_amount = float(data['pay_amount']) logger.info(f"执行履约服务费add_payment{data}") next_month = (datetime.datetime.now().date() - relativedelta(months=-1)).strftime("%Y-%m") # if next_month in dates: # _tmp = details[next_month]['data'] # _tmp = sorted(_tmp, key=lambda x: x['sort']) # for i in _tmp: # if pay_amount: # i['flag'] = 1 # if '承包金' in i['name']: # # 承包金实际需要缴纳的 # if pay_amount < i['money'] - i['pay']: # # 修改 i['pay'] 充值金额，推送修改 # i['pay'] += pay_amount # i['no_money'] = i['money'] - i['pay'] # i['flag_m'] = pay_amount # pay_amount = 0 # else: # pay_amount -= (i['money'] - i['pay']) # i['flag_m'] = (i['money'] - i['pay']) # i['pay'] = i['money'] # i['no_money'] = 0 # # else: # if i['money'] != i['pay']: # # 根据未支付的金额，扣除总金额 # df = i['money'] - i['pay'] # if pay_amount < df: # # 修改 i['pay'] 充值金额，推送修改 # i['pay'] += pay_amount # i['no_money'] = i['money'] - i['pay'] # i['flag_m'] = pay_amount # pay_amount = 0 # else: # pay_amount -= df # i['pay'] = i['money'] # i['no_money'] = 0 # i['flag_m'] = df # if now_month in dates: # _tmp = details[now_month]['data'] # _tmp = sorted(_tmp, key=lambda x: x['sort']) # for i in _tmp: # if pay_amount: # i['flag'] = 1 # if '承包金' in i['name']: # # 承包金实际需要缴纳的 # if pay_amount < i['money'] - i['pay']: # # 修改 i['pay'] 充值金额，推送修改 # i['pay'] += pay_amount # i['no_money'] = i['money'] - i['pay'] # i['flag_m'] = pay_amount # pay_amount = 0 # else: # pay_amount -= (i['money'] - i['pay']) # i['flag_m'] = (i['money'] - i['pay']) # i['pay'] = i['money'] # i['no_money'] = 0 # # else: # if i['money'] != i['pay']: # # 根据未支付的金额，扣除总金额 # df = i['money'] - i['pay'] # if pay_amount < df: # # 修改 i['pay'] 充值金额，推送修改 # i['pay'] += pay_amount # i['no_money'] = i['money'] - i['pay'] # i['flag_m'] = pay_amount # pay_amount = 0 # else: # pay_amount -= df # i['pay'] = i['money'] # i['no_money'] = 0 # i['flag_m'] = df for i in dates: # if i == next_month or i == now_month: # continue _tmp = details[i]['data'] _tmp = sorted(_tmp, key=lambda x: x['sort']) for i in _tmp: if pay_amount: i['flag'] = 1 # if '承包金' in i['name']: # # 承包金实际需要缴纳的 # if pay_amount < i['money'] - i['pay']: # # 修改 i['pay'] 充值金额，推送修改 # i['pay'] += pay_amount # i['no_money'] = i['money'] - i['pay'] # i['flag_m'] = pay_amount # pay_amount = 0 # # else: # pay_amount -= (i['money'] - i['pay']) # i['flag_m'] = (i['money'] - i['pay']) # i['pay'] = i['money'] # i['no_money'] = 0 # # else: if i['money'] != i['pay']: # 根据未支付的金额，扣除总金额 df = i['money'] - i['pay'] if pay_amount < df: # 修改 i['pay'] 充值金额，推送修改 logger.info(f"==========================================================支付小于待付") i['pay'] += pay_amount i['no_money'] = i['money'] - i['pay'] i['flag_m'] = pay_amount pay_amount = 0 else: logger.info(f"==========================================================支付不小于待付") pay_amount -= df i['pay'] = i['money'] i['no_money'] = 0 i['flag_m'] = df # 根据抵扣规则，更新未支付的数据，将清缴数据新增至已收付明细 logger.info(f"更新未收付{details}") update_lw_no_money(details) lock.release() logger.info(f"结束========") def rsa_long_decrypt(priv_key, msg, length=256): """ 1024bit的证书用128，2048bit证书用256位 """ try: privobj = PKCS1_v1_5.new(priv_key) res = [] b64_msg = base64.b64decode(msg) for i in range(0, len(b64_msg), length): chunk = b64_msg[i:i + length] decrypted_chunk = privobj.decrypt(chunk, 'xyz').decode('GBK') res.append(decrypted_chunk) logger.info(f"解密回调完成：{res}") except Exception as e: logger.error(f"解密回调失败：{e}") return jsonify(error=str(e)), 500 return "".join(res) def decode_notify_data(res_json): try: ciphertext = res_json['resource']['ciphertext'] nonce = res_json['resource']['nonce'] associated_data = res_json['resource']['associated_data'] cipher = AES.new(v3_SECRET.encode(), AES.MODE_GCM, nonce=nonce.encode()) cipher.update(associated_data.encode()) en_data = b64decode(ciphertext.encode('utf-8')) auth_tag = en_data[-16:] _en_data = en_data[:-16] plaintext = cipher.decrypt_and_verify(_en_data, auth_tag) decodejson = json.loads(plaintext.decode()) except Exception as e: logger.error(f"解密回调失败：{e}") return None return decodejson def get_wx_token(): url = f'https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid={corpid}&corpsecret={SECRET}' res = req_tool_vx(url, flag=1) return res['access_token'] def get_zy_wx_token(): url = f'https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid={zy_corpid}&corpsecret={ZY_SECRET}' res = req_tool_vx(url, flag=1) return res['access_token'] def query_wx_fj_info(id): """查询企微中的附加信息""" token = get_wx_token() url = f'https://qyapi.weixin.qq.com/cgi-bin/user/get?access_token={token}&userid={id}' res = req_tool_vx(url, flag=1) val = "" logger.info(f"query_wx_fj_info,res{res},id{id}") for i in res['extattr']['attrs']: if i['name'] == '附加信息': val = i['value'] return val def query_wx_userid(code): """查询企微中的userid""" token = get_wx_token() url = f'https://qyapi.weixin.qq.com/cgi-bin/auth/getuserinfo?access_token={token}&code={code}' res = req_tool_vx(url, flag=1) return res['userid'] def query_zy_wx_fj_info(id): """查询企微中的附加信息""" token = get_zy_wx_token() url = f'https://qyapi.weixin.qq.com/cgi-bin/user/get?access_token={token}&userid={id}' res = req_tool_vx(url, flag=1) val = "" logger.info(f"query_wx_fj_info{res},{id}") for i in res['extattr']['attrs']: if i['name'] == '附加信息': val = i['value'] return val def query_zy_wx_userid(code): """查询企微中的userid""" token = get_zy_wx_token() url = f'https://qyapi.weixin.qq.com/cgi-bin/auth/getuserinfo?access_token={token}&code={code}' res = req_tool_vx(url, flag=1) return res['userid']