120 lines
4.9 KiB
Plaintext
120 lines
4.9 KiB
Plaintext
async def apv_callback_provider_settle(ns={}):
|
||
"""
|
||
供应商结算入账审批回调
|
||
:param ns:
|
||
:return:
|
||
"""
|
||
info(f"apv_callback_provider_settle_data::{ns}")
|
||
response = {"status": False}
|
||
apv_callback_data = {}
|
||
now_time = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
|
||
try:
|
||
apv_callback_data['apv_id'] = ns['apv_id']
|
||
apv_callback_data['status'] = ns['status']
|
||
except Exception as e:
|
||
response["msg"] = "args is error,please check:{}".format(e)
|
||
return response
|
||
status_type = {
|
||
"start": 1,
|
||
"agree": 2,
|
||
"refuse": 3,
|
||
"terminate": 4
|
||
}
|
||
provider_settle_type_dict = {
|
||
'折扣': '0',
|
||
'返佣': '1',
|
||
'低价': '2'
|
||
}
|
||
|
||
db = DBPools()
|
||
async with db.sqlorContext('kboss') as sor:
|
||
# 更新状态记录
|
||
apv_callback_data['update_time'] = datetime.datetime.now()
|
||
apv_callback_data['status'] = status_type.get(apv_callback_data['status'], -1)
|
||
sql = "update provider_settle_data set status = ${status}$,update_time = ${update_time}$ where apv_id = ${apv_id}$"
|
||
d = await sor.sqlExe(sql, apv_callback_data)
|
||
if not d:
|
||
response["msg"] = "更新失败"
|
||
return response
|
||
if apv_callback_data['status'] != 2:
|
||
response['msg'] = "审批未通过，不入账"
|
||
return response
|
||
# 拿到记账数据
|
||
provider_data = await sor.R('provider_settle_data', {'apv_id': apv_callback_data['apv_id'], "del_flg": 0})
|
||
if not provider_data:
|
||
response["msg"] = "未找到该供应商结算数据"
|
||
return response
|
||
for i in provider_data:
|
||
args = []
|
||
if i['settle_status'] == 1:
|
||
info("已经全部成功记账,不再重复记账")
|
||
continue
|
||
try:
|
||
i['money'] = round(i['money'] / 100, 2)
|
||
i['money_2'] = round(i['money_2'] / 100, 2)
|
||
i['money_1'] = round(i['money_1'] / 100, 2)
|
||
i['money_0'] = round(i['money_0'] / 100, 2)
|
||
except Exception as e:
|
||
info("总额计算失败:{}".format(e))
|
||
sql_data = {'settle_status': 2, 'id': i["id"], "update_time": now_time}
|
||
await sor.U('provider_settle_data', sql_data)
|
||
continue
|
||
if i['settle_status'] == 0:
|
||
if i['money_2'] != 0:
|
||
args.append([i['money_2'], '2'])
|
||
if i['money_1'] != 0:
|
||
args.append([i['money_1'], '1'])
|
||
if i['money_0'] != 0:
|
||
args.append([i['money_0'], '0'])
|
||
elif i['settle_status'] == 2:
|
||
if i['failure_id']:
|
||
failure_id = i['failure_id'].split(',')
|
||
for f in failure_id:
|
||
args.append([i['money_{}'.format(f)], f])
|
||
else:
|
||
info("失败记账状态异常failure_id:{}".format(i['failure_id']))
|
||
continue
|
||
else:
|
||
info("记账状态异常settle_status:{}".format(i['settle_status']))
|
||
continue
|
||
|
||
if not args:
|
||
sql_data = {'settle_status': 1, 'id': i["id"], "update_time": now_time}
|
||
await sor.U('provider_settle_data', sql_data)
|
||
continue
|
||
orgid = i['orgid']
|
||
provider_id = i['provider_id']
|
||
settle_mode = i['settle_mode']
|
||
failure_id = []
|
||
for a in args:
|
||
# 记账
|
||
try:
|
||
settle_log = {
|
||
'accounting_orgid': orgid,
|
||
'providerid': provider_id, # 供应商id
|
||
'settle_date': await get_business_date(sor=None),
|
||
'settle_mode': settle_mode, # 供应商 销售结算方式
|
||
'sale_mode': a[1], # 0：折扣， 1：返佣 2：低价
|
||
'settle_amt': a[0], # 金额
|
||
'business_op': 'SETTLE'
|
||
}
|
||
ai = SettleAccounting(settle_log)
|
||
rets = await ai.accounting(sor)
|
||
if isinstance(rets, bool):
|
||
info(f"记账成功:{i['id']},sale_mode:{a[1]}")
|
||
except Exception as e:
|
||
info(f"记账失败,供应商id:{i['id']},sale_mode:{a[1]},error:{e}")
|
||
failure_id.append(a[1])
|
||
if failure_id:
|
||
sql_data = {'settle_status': 2, 'failure_id': ','.join(failure_id), 'id': i["id"], "update_time": now_time}
|
||
else:
|
||
sql_data = {'settle_status': 1, 'failure_id': None, 'id': i["id"], "update_time": now_time}
|
||
await sor.U('provider_settle_data', sql_data)
|
||
return {"status": True, "msg": "success"}
|
||
response["msg"] = "sql error,please check"
|
||
return response
|
||
|
||
|
||
ret = await apv_callback_provider_settle(params_kw)
|
||
return ret
|