update

redis_service.py

@@ -98,14 +98,16 @@ async def redis_subscriber(redis_client, channel_name):
                                 "streaming": False
                             }
                             response1 = requests.post("https://tanbushi-adk-teams.hf.space/run", json=data)
-                            parts=response1.json()[0]['content']['parts']
-                            ret_text=''
-                            for part in parts:
-                                # if part['type']=='text':
-                                ret_text=ret_text+part['text']
-                                    # break
-                            # ret_text = response1.json()[0]['content']['parts'][0]['text']
-                            print(ret_text)
+                            response1_json=response1.json()
+                            print('\n\n\n\n\n\n\n\nresponse1_json: ',response1_json)
+                            # 引用自检索结果[6]
+                            if response1_json[0]["content"]["parts"][0].get("function_call"):
+                                function_call = response1_json[0]["content"]["parts"][0]["function_call"]
+                                print(f"函数调用: {function_call['name']}")
+                            else:
+                                text_content = "".join([part["text"] for part in response1_json[0]["content"]["parts"]])
+                                print(text_content)
+
                     else:
                         print("Successfully get session")
                         data = {
@@ -123,13 +125,16 @@ async def redis_subscriber(redis_client, channel_name):
                             "streaming": False
                         }
                         response1 = requests.post("https://tanbushi-adk-teams.hf.space/run", json=data)
-                        ret_text = response1.json()[0]['content']['parts'][0]['text']
-                        print(ret_text)
-
-
-
-
-                    content = {"text": ret_text}
+                        response1_json=response1.json()
+                        print('\n\n\n\n\n\n\n\nresponse1_json: ', response1_json)
+                        if response1_json[0]["content"]["parts"][0].get("function_call"):
+                            function_call = response1_json[0]["content"]["parts"][0]["function_call"]
+                            print(f"函数调用: {function_call['name']}")
+                        else:
+                            text_content = "".join([part["text"] for part in response1_json[0]["content"]["parts"]])
+                            print(text_content)
+
+                    content = {"text": text_content}
                     # Correctly extract msg_type from the original_msg_type field
                     msg_type = data_dict.get('original_msg_type')