import gradio as gr import matplotlib.pyplot as plt import numpy as np from PIL import Image from io import BytesIO from main import run, add_to_queue,gradio_interface import io import sys import time import os import pandas as pd css = """#col-container {max-width: 90%; margin-left: auto; margin-right: auto; display: flex; flex-direction: column;} #header {text-align: center;} #col-chatbox {flex: 1; max-height: min(750px, 100%);} #label {font-size: 4em; padding: 0.5em; margin: 0;} .scroll-hide {overflow-y: scroll; max-height: 100px;} .wrap {max-height: 680px;} .message {font-size: 3em;} .message-wrap {max-height: min(700px, 100vh);} """ # plt.rcParams['font.sans-serif'] = ['Arial Unicode MS'] # plt.rcParams['axes.unicode_minus'] = False # plt.rcParams['font.sans-serif'] = ['WenQuanYi Zen Hei', 'Noto Sans CJK'] # plt.rcParams['axes.unicode_minus'] = False plt.rcParams['font.family'] = 'SimHei' example_stock =['给我画一下可孚医疗2022年年中到今天的股价','北向资金今年的每日流入和累计流入','看一下近三年宁德时代和贵州茅台的pb变化','画一下五粮液和泸州老窖从2019年年初到2022年年中的收益率走势','成都银行近一年的k线图和kdj指标','比较下沪深300,创业板指,中证1000指数今年的收益率','今年上证50所有成分股的收益率是多少'] example_economic =['中国过去十年的cpi走势是什么','过去五年中国的货币供应量走势,并且打印保存','我想看看现在的新闻或者最新的消息','我想看看中国近十年gdp的走势','预测中国未来12个季度的GDP增速'] example_fund =['易方达的张坤管理了几个基金','基金经理周海栋名下的所有基金今年的收益率情况','我想看看周海栋管理的华商优势行业的近三年来的的净值曲线','比较下华商优势行业和易方达蓝筹精选这两只基金的近三年的收益率'] example_company =['介绍下贵州茅台,这公司是干什么的,主营业务是什么','我想比较下工商银行和贵州茅台近十年的净资产回报率','今年一季度上证50的成分股的归母净利润同比增速分别是'] class Client: def __init__(self) -> None: self.OPENAI_KEY = '' self.OPENAI_API_BASED_AZURE = '' self.OPENAI_ENGINE_AZURE = '' self.OPENAI_API_KEY_AZURE = '' self.stop = False # 添加停止标志 # def set_key(self, openai_key, openai_key_azure, api_base_azure, engine_azure): # self.OPENAI_KEY = openai_key # self.OPENAI_API_BASED_AZURE = api_base_azure # self.OPENAI_API_KEY_AZURE = openai_key_azure # self.OPENAI_ENGINE_AZURE = engine_azure # return self.OPENAI_KEY, self.OPENAI_API_KEY_AZURE, self.OPENAI_API_BASED_AZURE, self.OPENAI_ENGINE_AZURE def run(self, messages): # self.stop = False self.OPENAI_KEY = os.getenv('OPENAI_API') self.OPENAI_API_KEY_AZURE = ''#os.getenv('OPENAI_API_KEY_AZURE') self.OPENAI_API_BASED_AZURE = os.getenv('OPENAI_API_BASED_AZURE') self.OPENAI_ENGINE_AZURE = os.getenv('OPENAI_ENGINE_AZURE') gen = gradio_interface(messages, self.OPENAI_KEY, self.OPENAI_API_KEY_AZURE, self.OPENAI_API_BASED_AZURE, self.OPENAI_ENGINE_AZURE) while not self.stop: # try: yield next(gen) except StopIteration: print("StopIteration") break # yield from gradio_interface(messages, self.OPENAI_KEY) #return finally_text, img, output, df with gr.Blocks() as demo: state = gr.State(value={"client": Client()}) def change_textbox(query): # 根据不同输入对输出控件进行更新 return gr.update(lines=2, visible=True, value=query) # 图片框显示 with gr.Row(): gr.Markdown( """ # Hello Data-Copilot ! 😀 A powerful AI system connects humans and data. ## The current version only supports **Chinese financial data**, in the future we will support for other country data ### 由于数据源和模型输入的限制，当前接入的数据源和设计功能较有限,资金有限接口速度很慢请谅解,欢迎合作 """) with gr.Row(): with gr.Column(scale=0.9): gr.Markdown( """ ### Step1-输入你的问题然后点击Start """) input_text = gr.inputs.Textbox(lines=1, placeholder='Please input your problem...', label='what do you want to find？ Then press Start ') with gr.Column(scale=0.1, min_width=0): start_btn = gr.Button("Start").style(full_height=True) # end_btn = gr.Button("Stop").style(full_height=True) gr.Markdown( """ # Try these examples ➡️➡️ """) with gr.Row(): example_selector1 = gr.Dropdown(choices=example_stock, interactive=True, label="查股票 Query stock:", show_label=True) example_selector2 = gr.Dropdown(choices=example_economic, interactive=True, label="查经济 Query Economy:", show_label=True) example_selector3 = gr.Dropdown(choices=example_company, interactive=True, label="查公司 Query Company:", show_label=True) example_selector4 = gr.Dropdown(choices=example_fund, interactive=True, label="查基金 Query Fund:", show_label=True) def run(state, chatbot): generator = state["client"].run(chatbot) for solving_step, img, res, df in generator: # if state["client"].stop: # print('Stopping generation') # break yield solving_step, img, res, df # def stop(state): # print('Stop signal received!') # state["client"].stop = True with gr.Row(): with gr.Column(scale=0.3, min_width="500px", max_width="500px", min_height="500px", max_height="500px"): Res = gr.Textbox(label="Summary and Result: ") with gr.Column(scale=0.7, min_width="500px", max_width="500px", min_height="500px", max_height="500px"): solving_step = gr.Textbox(label="Solving Step: ", lines=5) img = gr.outputs.Image(type='numpy') df = gr.outputs.Dataframe(type='pandas') with gr.Row(): gr.Markdown( """ [Tushare](https://tushare.pro/) provides financial data support for our Data-Copilot. [OpenAI](https://openai.com/) provides the powerful Chatgpt model for our Data-Copilot. """) outputs = [solving_step ,img, Res, df] #设置change事件 example_selector1.change(fn = change_textbox, inputs = example_selector1, outputs = input_text) example_selector2.change(fn = change_textbox, inputs = example_selector2, outputs = input_text) example_selector3.change(fn = change_textbox, inputs = example_selector3, outputs = input_text) example_selector4.change(fn = change_textbox, inputs = example_selector4, outputs = input_text) start_btn.click(fn = run, inputs = [state, input_text], outputs=outputs) # end_btn.click(stop, state) demo.queue() demo.launch()