def _stream_query(self, model_name, question):        """流式查询模型"""        reasoning_content = ""        answer_content = ""        is_answering = False                completion = self.client.chat.completions.create(            model=model_name,            messages=[{"role": "user", "content": question}],            stream=True        )                self.console.print(Panel.fit(            "[bold blue]思考过程[/bold blue]",             border_style="blue",            padding=(1, 2)        ))                for chunk in completion:            if not chunk.choices:                continue                        delta = chunk.choices[0].delta            if hasattr(delta, 'reasoning_content') and delta.reasoning_content is not None:                self.console.print(delta.reasoning_content, end='', highlight=False)                reasoning_content += delta.reasoning_content            else:                if delta.content != "" and is_answering is False:                    self.console.print(Panel.fit(                        "[bold green]完整回复[/bold green]",                         border_style="green",                        padding=(1, 2)                    ))                    is_answering = True                                self.console.print(delta.content, end='', highlight=False)                answer_content += delta.content