Update app.py

app.py

@@ -15,35 +15,72 @@ app = Flask(__name__)
 
 # 配置
 TOKEN = os.getenv('TOKEN')
-API_KEY = os.getenv("OPENAI_API_KEY")
+API_KEY = os.getenv("API_KEY")
 BASE_URL = os.getenv("OPENAI_BASE_URL")
 client = OpenAI(api_key=API_KEY, base_url=BASE_URL)
 
 # 定义可用的模型列表
 AVAILABLE_MODELS = {
     'gpt-3.5-turbo': 'GPT-3.5 Turbo',
-    'gpt-4': 'GPT-4',
-    'gpt-4-turbo': 'GPT-4 Turbo',
+    'gpt-4o': 'GPT-4o',
+    'gpt-4o-mini': 'GPT-4o-mini',
 }
 
 # 存储用户会话信息
 user_sessions = {}
 
 def verify_wechat(request):
-    # 验证逻辑保持不变
-    ...
+    # 获取微信服务器发送过来的参数
+    data = request.args
+    signature = data.get('signature')
+    timestamp = data.get('timestamp')
+    nonce = data.get('nonce')
+    echostr = data.get('echostr')
+    
+    # 对参数进行字典排序，拼接字符串
+    temp = [timestamp, nonce, TOKEN]
+    temp.sort()
+    temp = ''.join(temp)
+    
+    # 加密
+    if (hashlib.sha1(temp.encode('utf8')).hexdigest() == signature):
+        return echostr
+    else:
+        return 'error', 403
 
 def getUserMessageContentFromXML(xml_content):
-    # XML解析逻辑保持不变
-    ...
+    # 解析XML字符串
+    root = ET.fromstring(xml_content)
+    # 提取数据
+    content = root.find('Content').text
+    from_user_name = root.find('FromUserName').text
+    to_user_name = root.find('ToUserName').text
+    return content, from_user_name, to_user_name
 
 def generate_response_xml(from_user_name, to_user_name, output_content):
-    # XML生成逻辑保持不变
-    ...
-
-def get_openai_response(messages, model="gpt-3.5-turbo"):
-    # OpenAI API调用逻辑保持不变
-    ...
+    output_xml = '''
+    <xml>
+        <ToUserName><![CDATA[%s]]></ToUserName>
+        <FromUserName><![CDATA[%s]]></FromUserName>
+        <CreateTime>%s</CreateTime>
+        <MsgType><![CDATA[text]]></MsgType>
+        <Content><![CDATA[%s]]></Content>
+    </xml>'''
+    
+    response = make_response(output_xml % (from_user_name, to_user_name, str(int(time.time())), output_content))
+    response.content_type = 'application/xml'
+    return response
+
+def get_openai_response(messages, model="gpt-4o-mini"):
+    try:
+        response = client.chat.completions.create(
+            model=model,
+            messages=messages
+        )
+        return response.choices[0].message.content
+    except Exception as e:
+        print(f"调用OpenAI API时出错: {str(e)}")
+        return "抱歉，我遇到了一些问题，无法回答您的问题。"
 
 def split_message(message, max_length=500):
     return [message[i:i+max_length] for i in range(0, len(message), max_length)]
@@ -81,7 +118,7 @@ def wechatai():
                 response_content = "没有待发送的消息。"
         else:
             if from_user_name not in user_sessions:
-                user_sessions[from_user_name] = {'model': 'gpt-3.5-turbo', 'messages': [], 'pending_response': []}
+                user_sessions[from_user_name] = {'model': 'gpt-4o-mini', 'messages': [], 'pending_response': []}
 
             session = user_sessions[from_user_name]
             session['messages'].append({"role": "user", "content": user_message_content})
@@ -98,6 +135,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)