import pymysql import time import wave import requests from pyaudio import PyAudio, paInt16 from aip import AipSpeech import pyttsx3 from tkinter import * from tkinter import messagebox import speech_recognition as sr from tkinter import Text, Entry, Button framer = 16000 num_samples = 2000 channels = 1 sampwidth = 2 APP_ID = '78542969' API_KEY = 'B37LWVxLfoHixHx52OrNCPij' SECRET_KEY = 'bkNnbC37K3Ac6gI8kQ8phG1h5RIivMwj' client = AipSpeech(APP_ID, API_KEY, SECRET_KEY) audio_file = '../pythonProject6/myvoices.wav' # 用于处理音频录制和保存 class Speak(): def save_wave_file(self, filepath, data): wf = wave.open(filepath, 'wb') wf.setnchannels(channels) wf.setsampwidth(sampwidth) wf.setframerate(framer) wf.writeframes(b''.join(data)) wf.close() def my_record(self): pa = PyAudio() stream = pa.open(format=paInt16, channels=channels, rate=framer, input=True, frames_per_buffer=num_samples) my_buf = [] t_end = time.time() + 5 print('识别中...') while time.time() < t_end: string_audio_data = stream.read(num_samples) my_buf.append(string_audio_data) print('识别完成') self.save_wave_file(audio_file, my_buf) stream.close() class RobotSay(): def __init__(self): self.engine = pyttsx3.init() def say(self, msg): self.engine.say(msg) self.engine.runAndWait() class ReadWav(): def __init__(self): self.APP_ID = '78542969' self.API_KEY = 'B37LWVxLfoHixHx52OrNCPij' self.SECRET_KEY = 'bkNnbC37K3Ac6gI8kQ8phG1h5RIivMwj' self.client = AipSpeech(self.APP_ID, self.API_KEY, self.SECRET_KEY) def get_file_content(self, filePath): with open(filePath, 'rb') as fp: return fp.read() def predict(self): return client.asr(self.get_file_content('../pythonProject6/myvoices.wav'), 'wav', 16000, { 'dev_pid': 1537, }) # 定义登录窗口 class LoginWindow: def __init__(self, master): self.master = master self.master.title("登录") self.master.geometry("300x200") # Center align the login window self.screen_width = self.master.winfo_screenwidth() self.screen_height = self.master.winfo_screenheight() self.x_pos = (self.screen_width - 300) // 2 self.y_pos = (self.screen_height - 200) // 2 self.master.geometry(f"300x200+{self.x_pos}+{self.y_pos}") self.label_username = Label(master, text="账号") self.label_username.pack() self.entry_username = Entry(master) self.entry_username.pack() self.label_password = Label(master, text="密码") self.label_password.pack() self.entry_password = Entry(master, show="*") self.entry_password.pack() self.button_login = Button(master, text="登录", command=self.login) self.button_login.pack() def login(self): username = self.entry_username.get() password = self.entry_password.get() if username == "123" and password == "123": messagebox.showinfo("登陆成功", "恭喜你登陆成功") self.open_chat_window() else: messagebox.showerror("登录失败", "无效的用户名或密码") def open_chat_window(self): self.master.withdraw() chat_root = Toplevel(self.master) chat_window = ChatWindow(chat_root) chat_root.protocol("WM_DELETE_WINDOW", self.master.quit) class ChatWindow: def __init__(self, master): self.master = master self.master.title("开始聊天") self.master.geometry("700x500") self.screen_width = self.master.winfo_screenwidth() self.screen_height = self.master.winfo_screenheight() self.x_pos = (self.screen_width - 300) // 2 self.y_pos = (self.screen_height - 200) // 2 self.master.geometry(f"700x500+{self.x_pos}+{self.y_pos}") self.chat_text = Text(self.master) self.chat_text.pack() self.input_field = Entry(self.master) self.input_field.pack() self.send_button = Button(self.master, text="发送", command=self.send_message) self.send_button.pack() self.view_button = Button(self.master, text="查看聊天记录", command=self.view_chat_history) self.view_button.pack() self.delete_button = Button(self.master, text="删除聊天记录", command=self.delete_chat_history) self.delete_button.pack() self.recognizer = sr.Recognizer() self.engine = pyttsx3.init() self.connection = pymysql.connect(host="localhost", user="root", password="myroot", database="ai_chatter", port=3306) self.cursor = self.connection.cursor() self.chat_history = [] self.voice_button = Button(self.master, text="语音对话", command=self.start_voice_conversation) self.voice_button.pack() self.APP_ID = APP_ID self.API_KEY = API_KEY self.SECRET_KEY = SECRET_KEY self.client = AipSpeech(APP_ID, API_KEY, SECRET_KEY) ''' nltk.download('punkt') nltk.download('stopwords') nltk.download('wordnet') ''' def send_message(self): user_input = self.input_field.get() response = self.get_qingyunke_response(user_input) self.update_chat("你: " + user_input + "\n") self.update_chat("菲菲: " + response + "\n") self.speak(response) self.save_to_database(user_input, response) def start_voice_conversation(self): self.speak("开始语音对话，请说话...") speak_instance = Speak() speak_instance.my_record() text = self.transcribe_audio('../pythonProject6/myvoices.wav') self.update_chat("你说: " + text + "\n") response = self.get_qingyunke_response(text) self.update_chat("菲菲: " + response + "\n") self.speak(response) self.save_to_database(text, response) def get_qingyunke_response(self, message): api_url = "http://api.qingyunke.com/api.php?key=free&appid=0&msg=" + message response = requests.get(api_url) if response.status_code == 200: data = response.json() if data['result'] == 0: return data['content'] else: return "对不起，我不能理解." else: return "我目前无法处理您的请求." def update_chat(self, text): self.chat_text.insert(END, text) def speak(self, text): self.engine.say(text) self.engine.runAndWait() def transcribe_audio(self, audio_file): with open(audio_file, 'rb') as f: audio_data = f.read() result = self.client.asr(audio_data, 'wav', 16000, { 'dev_pid': 1537, # Use the model for Mandarin }) if 'result' in result: return result['result'][0] else: return "百度语音识别失败" #使用mysql数据库来保存 def save_to_database(self, user_message, bot_response): sql = "INSERT INTO chat_history (user_message, bot_response) VALUES (%s, %s)" text = (user_message, bot_response) self.connection.cursor().execute(sql, text) self.connection.commit() self.update_chat("聊天记录保存与数据库中\n") def view_chat_history(self): self.chat_text.delete('1.0', END) sql = "SELECT * FROM ai_chatter.chat_history" self.cursor.execute(sql) records = self.cursor.fetchall() for record in records: self.update_chat("你: " + record[1] + "\n") self.update_chat("菲菲: " + record[2] + "\n") if self.chat_history: self.update_chat("\n--- 聊天记录 ---\n") for message in self.chat_history: self.update_chat(message + "\n") else: self.update_chat("\n") def delete_chat_history(self): sql = "DELETE FROM chat_history" self.cursor.execute(sql) self.connection.commit() self.chat_text.delete('1.0', END) self.update_chat("聊天记录已删除。\n") if self.chat_history: self.chat_history.clear() self.update_chat("聊天记录已删除\n") else: self.update_chat("没有找到聊天记录\n") def close_connection(self): self.cursor.close() self.connection.close() #自然语言处理 #知识图谱模块 def fetch_knowledge_graph_info(self, query): # 使用Google知识图谱API api_key = '' base_url = 'https://kgsearch.googleapis.com/v1/entities:search' params = { 'query': query, 'key': api_key, 'limit': 1 } response = requests.get(base_url, params=params).json() if 'itemListElement' in response: item = response['itemListElement'][0] if 'result' in item: return item['result']['name'], item['result']['detailedDescription']['articleBody'] def main(): root = Tk() login_window = LoginWindow(root) root.mainloop() if __name__ == "__main__": main()