zensol
/
llm_hub
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

调整销售阶段分析追加信息题词，着重分析新增信息所造成的变化

This commit is contained in:
Tiger Ren 2024-10-20 20:42:11 +08:00
parent f9b72c82e0
commit e381e88ee2
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
app/api/v2/zhipu_controller_v2.py
View File

@ -111,7 +111,7 @@ def analysis_stream():
message = data.get('message', '') message = data.get('message', '')
knowledge_id = data.get('knowledge_id', '') knowledge_id = data.get('knowledge_id', '')
intent_categories =["analyze_sales","provide_sales_info"] intent_categories =["analyze_sales","provide_sales_update_info"]
classification_result_str = zhipu_alltool_service.func_call_classify(message, intent_categories) classification_result_str = zhipu_alltool_service.func_call_classify(message, intent_categories)
print(f'classification_result: {classification_result_str}') print(f'classification_result: {classification_result_str}')
@ -122,7 +122,7 @@ def analysis_stream():
if classification_result.get('category') == 'analyze_sales': if classification_result.get('category') == 'analyze_sales':
# do analyze sales as before # do analyze sales as before
pass pass
elif classification_result.get('category') == 'provide_sales_info': elif classification_result.get('category') == 'provide_sales_update_info':
contain_project_info = zhipu_alltool_service.func_call_yes_or_no(message, "是否包含项目信息") contain_project_info = zhipu_alltool_service.func_call_yes_or_no(message, "是否包含项目信息")
print(f'contain_project_info: {contain_project_info}') print(f'contain_project_info: {contain_project_info}')
contain_project_info = json.loads(contain_project_info) contain_project_info = json.loads(contain_project_info)
@ -153,14 +153,14 @@ def analysis_stream():
if additional_business_info and additional_business_info != "": if additional_business_info and additional_business_info != "":
prompt_analysis += f""" prompt_analysis += f"""
同时，请考虑以下额外的商机信息： 同时，请考虑以下额外的销售进展信息
{additional_business_info} {additional_business_info}
""" """
prompt_analysis += f""" prompt_analysis += f"""
根据如下各销售阶段的销售阶段任务、销售关键动作、阶段转化标准: 根据如下各销售阶段的销售阶段任务、销售关键动作、阶段转化标准:
{analysis_rule} {analysis_rule}
结合上述商机信息的对应阶段，分析并判断其销售动作是否完成了前一阶段的准出标准，以及是否支持将销售阶段转化到当前阶段 结合上述商机信息的对应阶段，按照下面的要点，请着重分析新增的销售进展是否会改变上述分析结果，如果会改变，请给出分析结果，如果不会改变，请给出分析结果
1. **销售阶段分析** 1. **销售阶段分析**
2. **销售动作日志分析** 2. **销售动作日志分析**
3. **销售动作与销售阶段的关系** 3. **销售动作与销售阶段的关系**
@ -172,11 +172,15 @@ def analysis_stream():
""" """
def event_stream(): def event_stream():
accumulated_result = ""
for chunk in zhipu_service.talk_to_zhipu_sse(prompt_analysis): for chunk in zhipu_service.talk_to_zhipu_sse(prompt_analysis):
if chunk: if chunk:
accumulated_result += chunk
chunk_out = format_chunk(chunk, None, None) chunk_out = format_chunk(chunk, None, None)
yield json.dumps(chunk_out) + '\n' yield json.dumps(chunk_out) + '\n'
yield json.dumps(format_chunk("", "日报缺乏来源信息", "请补充日报缺乏的信息")) + '\n'
yield json.dumps(format_chunk("", "如有新的销售进展，请补充相关信息，我会为您做进一步分析", "")) + '\n'
print(f'accumulated_result: {accumulated_result}')
return Response(event_stream(), mimetype='text/event-stream', headers=response_headers) return Response(event_stream(), mimetype='text/event-stream', headers=response_headers)