From 683cc1ec74abccc21bb38d2cef113714632b5b9a Mon Sep 17 00:00:00 2001
From: brian <zhangyp1015@163.com>
Date: Mon, 24 Jul 2023 10:29:54 +0800
Subject: [PATCH] =?UTF-8?q?=E6=99=BA=E8=83=BD=E5=88=86=E6=9E=90=EF=BC=88?=
 =?UTF-8?q?=E5=BC=82=E6=AD=A5=EF=BC=89?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 config/routes.ts                         |  6 ++
 src/pages/Chart/AddChart/index.tsx       |  3 +
 src/pages/Chart/AddChartAsync/index.tsx  | 93 ++++++++++++++++++++++++
 src/pages/Chart/MyChart/index.tsx        | 60 ++++++++++++---
 src/services/answerbi/chartController.ts | 36 +++++++++
 src/services/answerbi/typings.d.ts       |  8 ++
 6 files changed, 197 insertions(+), 9 deletions(-)
 create mode 100644 src/pages/Chart/AddChartAsync/index.tsx

diff --git a/config/routes.ts b/config/routes.ts
index ea00e5c..4f18f7c 100644
--- a/config/routes.ts
+++ b/config/routes.ts
@@ -13,6 +13,12 @@ export default [
     icon: 'barChart',
     component: './Chart/AddChart'
   },
+  {
+    name: '智能分析(异步)',
+    path: '/analyze/async',
+    icon: 'barChart',
+    component: './Chart/AddChartAsync'
+  },
   {
     name: '我的图表',
     path: '/my_chart',
diff --git a/src/pages/Chart/AddChart/index.tsx b/src/pages/Chart/AddChart/index.tsx
index f5f0f89..dcbec25 100644
--- a/src/pages/Chart/AddChart/index.tsx
+++ b/src/pages/Chart/AddChart/index.tsx
@@ -56,6 +56,9 @@ const AddChart: React.FC = () => {
           <Card title="智能分析">
             <Form
               name="addChart"
+              labelAlign='left'
+              labelCol={{span : 4}}
+              wrapperCol={{span : 16}}
               onFinish={onFinish}
               initialValues={{  }}
             >
diff --git a/src/pages/Chart/AddChartAsync/index.tsx b/src/pages/Chart/AddChartAsync/index.tsx
new file mode 100644
index 0000000..c0f34fe
--- /dev/null
+++ b/src/pages/Chart/AddChartAsync/index.tsx
@@ -0,0 +1,93 @@
+import { genChartByAiAsyncUsingPOST } from '@/services/answerbi/chartController';
+import { UploadOutlined } from '@ant-design/icons';
+import { Button, Card, Form, Input, Select, Space, Upload, message } from 'antd';
+import { useForm } from 'antd/es/form/Form';
+import TextArea from 'antd/es/input/TextArea';
+import React, { useState } from 'react';
+
+
+const AddChartAsync: React.FC = () => {
+  //定义状态，用来接收后端返回值，让它实时展示再页面上
+  const [form] = useForm();
+  const [submitting, setSubmitting] = useState<boolean>(false);
+
+
+  const onFinish = async (values: any) => {
+    if(submitting) return;
+    setSubmitting(true);
+    //对接后端，上传数据
+    const params = {
+      ...values,
+      file: undefined,
+    };
+    try{
+      //需要取到上传的原始数据 file->file->originFileObj
+      const res = await genChartByAiAsyncUsingPOST(params, {}, values.file.file.originFileObj);
+      //正常情况下，如果没有返回值就分析失败，有就分析成功
+      if(!res?.data){
+        message.error('分析失败');
+      }else{
+        message.success('分析任务提交成功，稍后请在我的图表页面查看');
+        form.resetFields();
+      }
+    }catch(e: any){
+      //异常情况下，提示分析失败+具体失败原因
+      message.error('分析失败,' + e.message);
+    }
+    setSubmitting(false);
+  };
+  
+  return (
+    <div className='add-chart-async'>
+      <Card title="智能分析">
+        <Form
+          name="addChart"
+          labelAlign='left'
+          labelCol={{span : 4}}
+          wrapperCol={{span : 16}}
+          onFinish={onFinish}
+          initialValues={{  }}
+        >
+          <Form.Item 
+            name="goal"
+            label="分析目标"
+            rules={[{ required: true, message: '请输入分析目标!' }]}
+          >
+            <TextArea placeholder='请输入你的分析需求，比如：分析网站用户的增长情况'/>
+          </Form.Item>
+
+          <Form.Item name="chartName" label="图表名称">
+            <Input placeholder='请输入图表名称'/>
+          </Form.Item>
+
+          <Form.Item name="chartType" label="图表类型">
+            <Select 
+              placeholder="请选择图表类型"
+              options={[
+                {value: '折线图', label: '折线图'},
+                {value: '柱状图', label: '柱状图'},
+                {value: '堆叠图', label: '堆叠图'},
+                {value: '饼图', label: '饼图'},
+                {value: '雷达图', label: '雷达图'},
+              ]}
+            />            
+          </Form.Item>
+
+          <Form.Item name="file" label="上传原始数据">
+            <Upload name="file">
+              <Button icon={<UploadOutlined />}>上传EXCEL文件</Button>
+            </Upload>
+          </Form.Item>
+
+          <Form.Item wrapperCol={{ span: 12, offset: 6 }}>
+            <Space>
+              <Button type="primary" htmlType="submit">提交</Button>
+              <Button htmlType="reset">重置</Button>
+            </Space>
+          </Form.Item>
+        </Form>
+      </Card>
+    </div>
+  );
+};
+export default AddChartAsync;
diff --git a/src/pages/Chart/MyChart/index.tsx b/src/pages/Chart/MyChart/index.tsx
index 668fe99..6d95d42 100644
--- a/src/pages/Chart/MyChart/index.tsx
+++ b/src/pages/Chart/MyChart/index.tsx
@@ -1,6 +1,6 @@
 import { listMyChartByPageUsingPOST } from '@/services/answerbi/chartController';
 import { useModel } from '@umijs/max';
-import { Avatar, Card, List, message } from 'antd';
+import { Avatar, Card, List, Result, message } from 'antd';
 import Search from 'antd/es/input/Search';
 import ReactECharts from 'echarts-for-react';
 import React, { useEffect, useState } from 'react';
@@ -10,6 +10,8 @@ const MyChartPage: React.FC = () => {
   const initSearchParams = {
     current: 1,
     pageSize: 4,
+    sortField: 'created_time',
+    sortOrder: 'desc',
   }
 
   const [searchParams, setSearchParams] = useState<API.ChartQueryRequest>({...initSearchParams});
@@ -34,9 +36,11 @@ const MyChartPage: React.FC = () => {
         //去除图表标题
         if(res.data.records){
           res.data.records.forEach(data => {
-            const chartOption = JSON.parse(data.genChart ?? '{}');
-            chartOption.title = undefined;
-            data.genChart = JSON.stringify(chartOption);
+            if(data.status === 'succeed'){
+              const chartOption = JSON.parse(data.genChart ?? '{}');
+              chartOption.title = undefined;
+              data.genChart = JSON.stringify(chartOption);
+            }
           })
         }
       }else{
@@ -51,7 +55,10 @@ const MyChartPage: React.FC = () => {
   //首次加载页面时，触发加载数据
   useEffect(() => {
     //这个页面首次渲染的时候，以及这个数组中的搜索条件发生变化的时候，会执行loadData方法，自动触发重新搜索
-    loadData();
+    const timer = setInterval(() => {
+      loadData();
+    }, 5000);
+    return () => clearInterval(timer);    
   },[searchParams]);
 
 
@@ -107,10 +114,45 @@ const MyChartPage: React.FC = () => {
                 title={item.chartName}
                 description={item.chartType ? '图表类型：' + item.chartType : undefined}
               />
-              <div style={{ marginBottom: 16 }} />
-              {'分析目标：' + item.goal}
-              <div style={{ marginBottom: 16 }} />
-              <ReactECharts option={JSON.parse(item.genChart ?? '{}')}></ReactECharts>
+              <>
+                {
+                  item.status === 'wait' && <>
+                    <Result
+                      status="warning"
+                      title="待生成"
+                      subTitle={item.execMessage ?? '当前图表生成队列繁忙，请耐心等候'}
+                    />
+                  </>
+                }
+                {
+                  item.status === 'running' && <>
+                    <Result
+                      status="info"
+                      title="图表生成中"
+                      subTitle={item.execMessage}
+                    />
+                  </>
+                }
+                {
+                  item.status === 'succeed' && <>
+                    <div style={{ marginBottom: 16 }} />
+                    <p>{'分析目标：' + item.goal}</p>
+                    <div style={{ marginBottom: 16 }} />
+                    <ReactECharts option={item.genChart && JSON.parse(item.genChart)} />
+                    <div style={{ marginBottom: 16 }} />
+                    <p>{'分析结论：' + item.genResult}</p>
+                  </>
+                }
+                {
+                  item.status === 'failed' && <>
+                    <Result
+                      status="error"
+                      title="图表生成失败"
+                      subTitle={item.execMessage}
+                    />
+                  </>
+                }
+              </>
             </Card>
           </List.Item>
         )}
diff --git a/src/services/answerbi/chartController.ts b/src/services/answerbi/chartController.ts
index 9d48118..16ae598 100644
--- a/src/services/answerbi/chartController.ts
+++ b/src/services/answerbi/chartController.ts
@@ -83,6 +83,42 @@ export async function genChartByAiUsingPOST(
   });
 }
 
+/** genChartByAiAsync POST /api/chart/gen/async */
+export async function genChartByAiAsyncUsingPOST(
+  // 叠加生成的Param类型 (非body参数swagger默认没有生成对象)
+  params: API.genChartByAiAsyncUsingPOSTParams,
+  body: {},
+  file?: File,
+  options?: { [key: string]: any },
+) {
+  const formData = new FormData();
+
+  if (file) {
+    formData.append('file', file);
+  }
+
+  Object.keys(body).forEach((ele) => {
+    const item = (body as any)[ele];
+
+    if (item !== undefined && item !== null) {
+      formData.append(
+        ele,
+        typeof item === 'object' && !(item instanceof File) ? JSON.stringify(item) : item,
+      );
+    }
+  });
+
+  return request<API.CommonResponseBiResponse_>('/api/chart/gen/async', {
+    method: 'POST',
+    params: {
+      ...params,
+    },
+    data: formData,
+    requestType: 'form',
+    ...(options || {}),
+  });
+}
+
 /** getChartById GET /api/chart/get */
 export async function getChartByIdUsingGET(
   // 叠加生成的Param类型 (非body参数swagger默认没有生成对象)
diff --git a/src/services/answerbi/typings.d.ts b/src/services/answerbi/typings.d.ts
index 8c2bd6c..ab7eeae 100644
--- a/src/services/answerbi/typings.d.ts
+++ b/src/services/answerbi/typings.d.ts
@@ -11,10 +11,12 @@ declare namespace API {
     chartType?: string;
     createdTime?: string;
     deletedFlag?: number;
+    execMessage?: string;
     genChart?: string;
     genResult?: string;
     goal?: string;
     id?: number;
+    status?: string;
     updatedTime?: string;
     userId?: number;
   };
@@ -147,6 +149,12 @@ declare namespace API {
     id?: number;
   };
 
+  type genChartByAiAsyncUsingPOSTParams = {
+    chartName?: string;
+    chartType?: string;
+    goal?: string;
+  };
+
   type genChartByAiUsingPOSTParams = {
     chartName?: string;
     chartType?: string;