Update app.py

app.py

@@ -180,6 +180,57 @@ def process_function_call(tool_call):
     else:
         return None
 
+# @app.route('/api/wx', methods=['GET', 'POST'])
+# def wechatai():
+#     if request.method == 'GET':
+#         return verify_wechat(request)
+#     else:
+#         xml_str = request.data
+#         user_message_content, from_user_name, to_user_name = getUserMessageContentFromXML(xml_str)
+
+#         if from_user_name not in user_sessions:
+#             user_sessions[from_user_name] = {'messages': [], 'pending_response': []}
+
+#         session = user_sessions[from_user_name]
+
+#         if user_message_content.lower() == '继续':
+#             if session['pending_response']:
+#                 response_content = session['pending_response'].pop(0)
+#                 if session['pending_response']:
+#                     response_content += '\n\n回复"继续"获取下一部分。'
+#                 else:
+#                     response_content += '\n\n回复结束。'
+#             else:
+#                 response_content = "没有待发送的消息。"
+#         else:
+#             session['messages'].append({"role": "user", "content": user_message_content})
+            
+#             gpt_response = get_openai_response(session['messages'])
+
+#             if gpt_response.tool_calls:
+#                 for tool_call in gpt_response.tool_calls:
+#                     function_result = process_function_call(tool_call)
+#                     session['messages'].append({
+#                         "role": "function",
+#                         "name": tool_call.function.name,
+#                         "content": json.dumps(function_result)
+#                     })
+                
+#                 final_response = get_openai_response(session['messages'])
+#                 response_content = final_response.content
+#             else:
+#                 response_content = gpt_response.content
+
+#             session['messages'].append({"role": "assistant", "content": response_content})
+
+#             response_parts = split_message(response_content)
+#             if len(response_parts) > 1:
+#                 response_content = response_parts[0] + '\n\n回复"继续"获取下一部分。'
+#                 session['pending_response'] = response_parts[1:]
+#             else:
+#                 response_content = response_parts[0]
+
+#         return generate_response_xml(from_user_name, to_user_name, response_content)
 @app.route('/api/wx', methods=['GET', 'POST'])
 def wechatai():
     if request.method == 'GET':
@@ -216,8 +267,8 @@ def wechatai():
                         "content": json.dumps(function_result)
                     })
                 
-                final_response = get_openai_response(session['messages'])
-                response_content = final_response.content
+                # 直接使用 gpt_response 的内容，不再重新调用 API
+                response_content = gpt_response.content
             else:
                 response_content = gpt_response.content
 
@@ -231,6 +282,6 @@ def wechatai():
                 response_content = response_parts[0]
 
         return generate_response_xml(from_user_name, to_user_name, response_content)
-
+        
 if __name__ == '__main__':
     app.run(host='0.0.0.0', port=7860, debug=True)