yumoqing/kboss
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
ping 2026-07-22 16:20:06 +08:00
parent cbbdac9adc
commit f0f32b9239
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
b/cntoai/sync_model_to_llm.dspy
View File

@ -37,7 +37,7 @@ async def sync_model_to_llm(ns={}):
exist_org_li = await sor.R('organization', {'orgcode': provider_orgcode, 'del_flg': '0'}) exist_org_li = await sor.R('organization', {'orgcode': provider_orgcode, 'del_flg': '0'})
if exist_org_li: if exist_org_li:
provider_orgid = exist_org_li[0].get('id') provider_orgid = exist_org_li[0].get('id')
await sor.U('organization', {'id': provider_orgid}, { await sor.U('organization', {
'id': provider_orgid, 'id': provider_orgid,
'orgname': provider_name, 'orgname': provider_name,
'orgcode': provider_orgcode, 'orgcode': provider_orgcode,
@ -78,7 +78,7 @@ async def sync_model_to_llm(ns={}):
if provider_li: if provider_li:
provider_id = provider_li[0].get('id') provider_id = provider_li[0].get('id')
provider_data['id'] = provider_id provider_data['id'] = provider_id
await sor.U('provider', {'id': provider_id}, provider_data) await sor.U('provider', provider_data)
else: else:
provider_id = uuid() provider_id = uuid()
provider_data['id'] = provider_id provider_data['id'] = provider_id
@ -87,7 +87,7 @@ async def sync_model_to_llm(ns={}):
protocol_li = await sor.R('saleprotocol', {'offer_orgid': provider_orgid, 'bid_orgid': sync_orgid, 'del_flg': '0'}) protocol_li = await sor.R('saleprotocol', {'offer_orgid': provider_orgid, 'bid_orgid': sync_orgid, 'del_flg': '0'})
if protocol_li: if protocol_li:
protocolid = protocol_li[0].get('id') protocolid = protocol_li[0].get('id')
await sor.U('saleprotocol', {'id': protocolid}, { await sor.U('saleprotocol', {
'id': protocolid, 'id': protocolid,
'offer_orgid': provider_orgid, 'offer_orgid': provider_orgid,
'bid_orgid': sync_orgid, 'bid_orgid': sync_orgid,
@ -121,7 +121,7 @@ async def sync_model_to_llm(ns={}):
'providerid': provider_orgid, 'providerid': provider_orgid,
'providerpid': item.get('id'), 'providerpid': item.get('id'),
'name': item.get('name'), 'name': item.get('name'),
'description': item.get('description') or '', # 'description': item.get('description') or '',
'ptype': '21', 'ptype': '21',
'state': '1', 'state': '1',
'salemode': '0', 'salemode': '0',
@ -129,7 +129,7 @@ async def sync_model_to_llm(ns={}):
'reseller_orgid': sync_orgid, 'reseller_orgid': sync_orgid,
'classify': 'A', 'classify': 'A',
'label': item.get('catelogname') or category_list.get('catelogname'), 'label': item.get('catelogname') or category_list.get('catelogname'),
'productgroup': item.get('catelog_id') or item.get('catelogid') or category_list.get('catelogid'), # 'productgroup': item.get('catelog_id') or item.get('catelogid') or category_list.get('catelogid'),
'product_area': '北京', 'product_area': '北京',
'effect_date': '2026-07-01', 'effect_date': '2026-07-01',
'expire_date': '9999-12-31' 'expire_date': '9999-12-31'
@ -138,7 +138,7 @@ async def sync_model_to_llm(ns={}):
if product_li: if product_li:
product_id = product_li[0].get('id') product_id = product_li[0].get('id')
product_data['id'] = product_id product_data['id'] = product_id
await sor.U('product', {'id': product_id}, product_data) await sor.U('product', product_data)
product_action = 'update' product_action = 'update'
else: else:
product_id = uuid() product_id = uuid()
@ -161,7 +161,7 @@ async def sync_model_to_llm(ns={}):
}) })
if product_salemode_li: if product_salemode_li:
salemode_data['id'] = product_salemode_li[0].get('id') salemode_data['id'] = product_salemode_li[0].get('id')
await sor.U('product_salemode', {'id': salemode_data['id']}, salemode_data) await sor.U('product_salemode', salemode_data)
else: else:
salemode_data['id'] = uuid() salemode_data['id'] = uuid()
await sor.C('product_salemode', salemode_data) await sor.C('product_salemode', salemode_data)
@ -173,7 +173,7 @@ async def sync_model_to_llm(ns={}):
exist_llm = await sor.R('llm', {'model': item.get('model')}) exist_llm = await sor.R('llm', {'model': item.get('model')})
if exist_llm: if exist_llm:
llm_data['id'] = exist_llm[0].get('id') llm_data['id'] = exist_llm[0].get('id')
await sor.U('llm', {'id': llm_data['id']}, llm_data) await sor.U('llm', llm_data)
return 'update' return 'update'
await sor.C('llm', llm_data) await sor.C('llm', llm_data)
return 'insert' return 'insert'
@ -285,7 +285,7 @@ async def sync_model_to_llm(ns={}):
for exist_llm in exist_llm_li: for exist_llm in exist_llm_li:
exist_model = exist_llm.get('model') exist_model = exist_llm.get('model')
if exist_model and exist_model not in current_model_set and exist_llm.get('status') != 'unpublished': if exist_model and exist_model not in current_model_set and exist_llm.get('status') != 'unpublished':
await sor.U('llm', {'id': exist_llm.get('id')}, { await sor.U('llm', {
'id': exist_llm.get('id'), 'id': exist_llm.get('id'),
'status': 'unpublished' 'status': 'unpublished'
}) })