| | |
| | | from app.models.user_model import UserModel |
| | | from app.service.basic import BasicService |
| | | from app.service.bisheng import BishengService |
| | | from app.service.common.api_token import DfTokenDao |
| | | from app.service.difyService import DifyService |
| | | from app.service.ragflow import RagflowService |
| | | from app.service.service_token import get_ragflow_token, get_bisheng_token |
| | |
| | | # result = await service.paper_file_upload(chat_id, file.filename, file_content) |
| | | |
| | | elif agent.agent_type == AgentType.DIFY: |
| | | token = settings.dify_api_token |
| | | dify_service = DifyService(base_url=settings.dify_base_url) |
| | | if agent.type == "imageTalk": |
| | | token = DfTokenDao(db).get_token_by_id("image_and_text_conversion") |
| | | if not token: |
| | | raise HTTPException(status_code=500, detail="获取token失败,image_and_text_conversion!") |
| | | file = file[0] |
| | | # 读取上传的文件内容 |
| | | try: |
| | |
| | | except Exception as e: |
| | | raise HTTPException(status_code=500, detail=str(e)) |
| | | elif agent.type == "reportWorkflow": |
| | | token = DfTokenDao(db).get_token_by_id("document_to_report") |
| | | if not token: |
| | | raise HTTPException(status_code=500, detail="获取token失败,document_to_report!") |
| | | result = [] |
| | | for f in file: |
| | | try: |