| | |
|---|
| | | chat = ChatBaseApply() |
|---|
| | | token = await get_chat_token(db, dialog_id) |
|---|
| | | if not token: |
|---|
| | | workflow = await get_app_token(db, workflow_server) |
|---|
| | | if workflow: |
|---|
| | | access_token = await get_app_token(db, workflow_server) |
|---|
| | | # print(workflow) |
|---|
| | | if access_token: |
|---|
| | | url = settings.dify_base_url + DF_CHAT_API_KEY.format(dialog_id) |
|---|
| | | param = await chat.chat_get(url, {}, await chat.get_headers(workflow.access_token)) |
|---|
| | | param = await chat.chat_get(url, {}, await chat.get_headers(access_token)) |
|---|
| | | if param and param.get("data"): |
|---|
| | | token = param.get("data", [{}])[0].get("token") |
|---|
| | | token_id = param.get("data", [{}])[0].get("id") |
|---|
| | | await add_chat_token(db, {"id":token_id, "app_id": dialog_id, "type":"app", "token": token}) |
|---|
| | | # dialog.parameters = json.dumps(param) |
|---|
| | | else: |
|---|
| | | param = await chat.chat_post(url, {}, await chat.get_headers(workflow.access_token)) |
|---|
| | | param = await chat.chat_post(url, {}, await chat.get_headers(access_token)) |
|---|
| | | if param: |
|---|
| | | token = param.get("token") |
|---|
| | | token_id = param.get("id") |
|---|
