From ddee2e82b3f9e6db2bb20bfc3d824a5eedae8628 Mon Sep 17 00:00:00 2001
From: aixianling <aixianling@sinoecare.com>
Date: Thu, 9 Feb 2023 11:53:35 +0800
Subject: [PATCH] =?UTF-8?q?=E5=85=88=E6=8F=90=E4=BA=A4=E4=B8=80=E4=B8=8B?=
 =?UTF-8?q?=E5=89=8D=E7=AB=AF=E7=9B=91=E6=8E=A7=E6=9C=BA=E5=99=A8=E4=BA=BA?=
 =?UTF-8?q?--=E8=A7=82=E5=AF=9F=E8=80=85?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../sentry/AppApiMonitor/AppApiMonitor.vue    | 65 +++++++++++++++----
 ui/lib/js/observer.js                         | 39 +++++++++++
 2 files changed, 91 insertions(+), 13 deletions(-)
 create mode 100644 ui/lib/js/observer.js

diff --git a/project/oms/apps/sentry/AppApiMonitor/AppApiMonitor.vue b/project/oms/apps/sentry/AppApiMonitor/AppApiMonitor.vue
index f5489ce1..fd808bf4 100644
--- a/project/oms/apps/sentry/AppApiMonitor/AppApiMonitor.vue
+++ b/project/oms/apps/sentry/AppApiMonitor/AppApiMonitor.vue
@@ -4,13 +4,21 @@
       <ai-title slot="title" :title="$options.label" isShowBottomBorder/>
       <template #blank>
         <el-row type="flex">
-          <ai-card title="接口异常分布"></ai-card>
+          <ai-card title="接口异常分布">
+            <ai-echart/>
+          </ai-card>
           <ai-card class="fill mar-l16" title="接口异常TOP10"></ai-card>
         </el-row>
-        <ai-card title="所有异常接口">
-          <ai-table :tableData="tableData" :colConfigs="columns">
-
-          </ai-table>
+        <ai-card panel>
+          <ai-search-bar>
+            <template #left>
+              <ai-select placeholder="状态码" v-model="search.status" :selectList="networkStatus" @change="page.current=1,getTableData()"/>
+            </template>
+            <template #right>
+              <el-input v-model="search.name" size="small" placeholder="搜索接口" clearable @change="page.current=1,getTableData()"/>
+            </template>
+          </ai-search-bar>
+          <ai-table :tableData="tableData" :colConfigs="columns" :pageConfig.sync="page" @getList="getTableData" :dict="dict"/>
         </ai-card>
       </template>
     </ai-list>
@@ -19,26 +27,57 @@
 </template>
 
 <script>
+import AiSearchBar from "dui/packages/layout/AiSearchBar";
+import AiSelect from "dui/packages/basic/AiSelect";
+
 export default {
   name: "AppApiMonitor",
+  components: {AiSelect, AiSearchBar},
   label: "接口监控",
+  props: {
+    instance: Function,
+    dict: Object,
+    permissions: Function
+  },
   data() {
     return {
       tableData: [],
+      page: {current: 1},
+      search: {},
       columns: [
         {label: "状态码", prop: "status"},
-        {label: "接口地址", prop: "status"},
-        {label: "错误信息", prop: "status"},
-        {label: "终端", prop: "status"},
-        {label: "页面", prop: "status"},
-        {label: "用户", prop: "status"},
-        {label: "环境", prop: "status"},
-        {label: "事件", prop: "status"},
+        {label: "接口地址", prop: "path"},
+        {label: "错误信息", prop: "error"},
+        {label: "终端", prop: "device"},
+        {label: "页面", prop: "url"},
+        {label: "用户", prop: "userName"},
+        {label: "环境", prop: "nodeProcess"},
+        {label: "创建时间", prop: "createTime"},
+      ],
+      networkStatus: [
+        {dictValue: 200, dictName: '200:成功'},
+        {dictValue: 500, dictName: '500:接口失败'},
+        {dictValue: 401, dictName: '401:token失效'},
+        {dictValue: 403, dictName: '403:未授权访问'},
+        {dictValue: 404, dictName: '404:无法找到接口'},
+        {dictValue: 504, dictName: '504:接口超时'},
       ]
     }
   },
-  methods: {},
+  methods: {
+    getTableData() {
+      this.instance.post("/node/monitorApi/list", null, {
+        params: {...this.page, ...this.search}
+      }).then(res => {
+        if (res?.data) {
+          this.tableData = res.data.records
+          this.page.total = res.data.total
+        }
+      })
+    }
+  },
   created() {
+    this.getTableData()
   }
 }
 </script>
diff --git a/ui/lib/js/observer.js b/ui/lib/js/observer.js
new file mode 100644
index 00000000..d899ab73
--- /dev/null
+++ b/ui/lib/js/observer.js
@@ -0,0 +1,39 @@
+/**
+ * 获取符合要求的请求
+ * @param entries 监测的请求对象
+ * @param type 设置满足条件的请求类型
+ * @returns {PerformanceEntry[]}
+ */
+const getRequests = (entries = performance.getEntriesByType('resource'), type = ['xmlhttprequest']) =>
+    entries?.filter(e => type.includes(e.initiatorType)) || []
+
+/**
+ * 观察者工具对象,用于前端接口监测
+ */
+class Observer {
+  constructor() {
+    this.saveLogs(getRequests())
+    this.ins = new PerformanceObserver((list, ob) => {
+      const watchLogs = getRequests(list.getEntriesByType("resource"))
+      this.saveLogs(watchLogs)
+    })
+    this.ins.observe({entryTypes: ["resource"]})
+  }
+
+  saveLogs(list = []) {
+    list.map(e => {
+      if (!/sockjs/.test(e.name)) {
+        const api = {
+          status: e.responseStatus,
+          path: e.name,
+          url: location.href,
+          nodeProcess: process.env.NODE_ENV,
+        }
+        console.log(api)
+        // http.post("/node/monitorApi/addOrUpdate", api)
+      }
+    })
+  }
+}
+
+export default Observer