|
|
|
@ -231,6 +231,13 @@ async def reply(person_id: str = Form(...),
|
|
|
|
|
"""
|
|
|
|
|
try:
|
|
|
|
|
logger.info(f"收到用户输入: {prompt}")
|
|
|
|
|
|
|
|
|
|
if not prompt:
|
|
|
|
|
return {
|
|
|
|
|
"code": 200,
|
|
|
|
|
"message": "请输入内容",
|
|
|
|
|
"success": False
|
|
|
|
|
}
|
|
|
|
|
# 从连接池中获取一个连接
|
|
|
|
|
connection = milvus_pool.get_connection()
|
|
|
|
|
|
|
|
|
@ -278,7 +285,7 @@ async def reply(person_id: str = Form(...),
|
|
|
|
|
model=MODEL_NAME,
|
|
|
|
|
messages=[
|
|
|
|
|
{"role": "system",
|
|
|
|
|
"content": "你是一个和你聊天人的好朋友,疏导情绪,让他开心,亲切一些。聊天的回复内容不要超过100字。"},
|
|
|
|
|
"content": "你是一个和你聊天人的好朋友,疏导情绪,让他开心,亲切一些,不要使用哎呀这样的语气词。聊天的回复内容不要超过100字。"},
|
|
|
|
|
{"role": "user", "content": f"历史对话记录:{history_prompt},本次用户问题: {prompt}"}
|
|
|
|
|
],
|
|
|
|
|
max_tokens=2000
|
|
|
|
@ -402,7 +409,7 @@ async def get_risk_chat_logs(
|
|
|
|
|
|
|
|
|
|
# 返回分页数据
|
|
|
|
|
return {
|
|
|
|
|
"success":True,
|
|
|
|
|
"success": True,
|
|
|
|
|
"message": "查询成功",
|
|
|
|
|
"data": {
|
|
|
|
|
"total": total,
|
|
|
|
@ -421,7 +428,7 @@ async def get_oss_upload_token(current_user: dict = Depends(get_current_user)):
|
|
|
|
|
# 获取 STS 临时凭证
|
|
|
|
|
sts_token = get_sts_token()
|
|
|
|
|
return {
|
|
|
|
|
"success":True,
|
|
|
|
|
"success": True,
|
|
|
|
|
"message": "获取上传凭证成功",
|
|
|
|
|
"data": {
|
|
|
|
|
"access_key_id": sts_token['AccessKeyId'],
|
|
|
|
|