fix(publish): auto-sync llm to product on publish via env.sync_llm_product
This commit is contained in:
parent
b97a14d41d
commit
0c4bc661eb
@ -12,6 +12,20 @@ try:
|
|||||||
await sor.U('llm', {'id': record_id, 'status': action})
|
await sor.U('llm', {'id': record_id, 'status': action})
|
||||||
result['success'] = True
|
result['success'] = True
|
||||||
result['message'] = '上架成功' if action == 'published' else '下架成功'
|
result['message'] = '上架成功' if action == 'published' else '下架成功'
|
||||||
|
if action == 'published':
|
||||||
|
env = request._run_ns
|
||||||
|
sync_fn = getattr(env, 'sync_llm_product', None)
|
||||||
|
if sync_fn:
|
||||||
|
try:
|
||||||
|
sync_result = await sync_fn(record_id)
|
||||||
|
except Exception as sync_e:
|
||||||
|
sync_result = {'success': False, 'error': str(sync_e)}
|
||||||
|
if not sync_result:
|
||||||
|
result['message'] += ',已同步为产品'
|
||||||
|
elif sync_result.get('success'):
|
||||||
|
result['message'] += ',已同步为产品'
|
||||||
|
else:
|
||||||
|
result['message'] += ',但产品同步失败: ' + str(sync_result.get('error', '未知错误'))
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
result['message'] = str(e)
|
result['message'] = str(e)
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user