feature: 流水线日志支持AI修复 #10913

src/frontend/devops-pipeline/package.json

@@ -14,7 +14,7 @@
         "public:external": "cross-env NODE_ENV=external npm run public --"
     },
     "dependencies": {
-        "@blueking/log": "2.1.5",
+        "@blueking/log": "2.2.0-beta.28",
         "@blueking/search-select": "0.0.1-beta.2",
         "@icon-cool/bk-icon-devops": "^0.2.1",
         "axios": "0.28.0",

src/frontend/devops-pipeline/src/components/ExecDetail/log/jobLog.vue

@@ -26,6 +26,12 @@
             :log-list="pluginList"
             @open-log="openLog"
             @tag-change="tagChange"
+            @praise-ai="handlePraiseAi"
+            @down-praise-ai="handleDownPraiseAi"
+            @load-ai-message="handleLoadAiMessage"
+            @reload-ai-message="handleReloadAiMessage"
+            @cancel-praise-ai="handleCancelPraiseAI"
+            @cancel-down-praise-ai="handleCancelDownPraiseAI"
         >
             <template slot-scope="log">
                 <status-icon
@@ -83,9 +89,96 @@
         methods: {
             ...mapActions('atom', [
                 'getInitLog',
-                'getAfterLog'
+                'getAfterLog',
+                'praiseAi',
+                'cancelPraiseAi',
+                'getPraiseAiInfo',
+                'getLogAIMessage'
             ]),
 
+            handlePraiseAi ({ id, item }) {
+                this.praiseAi({
+                    ...this.logPostData[id],
+                    score: true
+                }).then(() => {
+                    this.handleGetPraiseAiInfo({ id, item })
+                    this.$bkMessage({ theme: 'success', message: this.$t('successPraise') })
+                })
+            },
+
+            handleDownPraiseAi ({ id, item }) {
+                this.praiseAi({
+                    ...this.logPostData[id],
+                    score: false
+                }).then(() => {
+                    this.handleGetPraiseAiInfo({ id, item })
+                    this.$bkMessage({ theme: 'success', message: this.$t('successDownPraise') })
+                })
+            },
+
+            handleCancelPraiseAI ({ id, item }) {
+                this.cancelPraiseAi({
+                    ...this.logPostData[id],
+                    score: true
+                }).then(() => {
+                    this.handleGetPraiseAiInfo({ id, item })
+                    this.$bkMessage({ theme: 'success', message: this.$t('successCancelPraise') })
+                })
+            },
+
+            handleCancelDownPraiseAI ({ id, item }) {
+                this.cancelPraiseAi({
+                    ...this.logPostData[id],
+                    score: false
+                }).then(() => {
+                    this.handleGetPraiseAiInfo({ id, item })
+                    this.$bkMessage({ theme: 'success', message: this.$t('successCancelDownPraise') })
+                })
+            },
+
+            handleGetPraiseAiInfo ({ id, item }) {
+                const ref = this.$refs.multipleLog
+                this.getPraiseAiInfo({
+                    ...this.logPostData[id]
+                })
+                    .then((res) => {
+                        item.goodUsers = res.data.goodUsers
+                        item.badUsers = res.data.badUsers
+                        ref.setSingleLogData(item, id)
+                    })
+            },
+
+            handleLoadAiMessage ({ id, item }) {
+                item.aiMessage = ''
+                const ref = this.$refs.multipleLog
+                this.handleGetPraiseAiInfo({ id, item })
+                this.getLogAIMessage({
+                    ...this.logPostData[id],
+                    refresh: false,
+                    callBack (val) {
+                        item.aiMessage += val
+                        ref.setSingleLogData(item, id)
+                        ref.scrollAILogToBottom(id)
+                    }
+                })
+            },
+
+            handleReloadAiMessage ({ id, item }) {
+                item.aiMessage = ''
+                const ref = this.$refs.multipleLog
+                this.getLogAIMessage({
+                    ...this.logPostData[id],
+                    refresh: true,
+                    callBack (val) {
+                        item.aiMessage += val
+                        ref.setSingleLogData(item, id)
+                        ref.scrollAILogToBottom(id)
+                    }
+                }).then(() => {
+                    this.handleGetPraiseAiInfo({ id, item })
+                })
+            },
+
             toggleShowDebugLog () {
                 this.showDebug = !this.showDebug
                 this.clearAllLog()

src/frontend/devops-pipeline/src/components/ExecDetail/log/pluginLog.vue

@@ -24,7 +24,13 @@
             class="bk-log"
             ref="scroll"
             @tag-change="tagChange"
-        ></bk-log>
+            @praise-ai="handlePraiseAi"
+            @down-praise-ai="handleDownPraiseAi"
+            @load-ai-message="handleLoadAiMessage"
+            @reload-ai-message="handleReloadAiMessage"
+            @cancel-praise-ai="handleCancelPraiseAI"
+            @cancel-down-praise-ai="handleCancelDownPraiseAI"
+        />
     </section>
 </template>
 
@@ -156,9 +162,96 @@
                 'getInitLog',
                 'getAfterLog',
                 'getLogStatus',
-                'getDownloadLogFromArtifactory'
+                'getDownloadLogFromArtifactory',
+                'praiseAi',
+                'cancelPraiseAi',
+                'getPraiseAiInfo',
+                'getLogAIMessage'
             ]),
 
+            handlePraiseAi (item) {
+                this.praiseAi({
+                    ...this.postData,
+                    score: true
+                }).then(() => {
+                    this.handleGetPraiseAiInfo(item)
+                    this.$bkMessage({ theme: 'success', message: this.$t('successPraise') })
+                })
+            },
+
+            handleDownPraiseAi (item) {
+                this.praiseAi({
+                    ...this.postData,
+                    score: false
+                }).then(() => {
+                    this.handleGetPraiseAiInfo(item)
+                    this.$bkMessage({ theme: 'success', message: this.$t('successDownPraise') })
+                })
+            },
+
+            handleCancelPraiseAI (item) {
+                this.cancelPraiseAi({
+                    ...this.postData,
+                    score: true
+                }).then(() => {
+                    this.handleGetPraiseAiInfo(item)
+                    this.$bkMessage({ theme: 'success', message: this.$t('successCancelPraise') })
+                })
+            },
+
+            handleCancelDownPraiseAI (item) {
+                this.cancelPraiseAi({
+                    ...this.postData,
+                    score: false
+                }).then(() => {
+                    this.handleGetPraiseAiInfo(item)
+                    this.$bkMessage({ theme: 'success', message: this.$t('successCancelDownPraise') })
+                })
+            },
+
+            handleGetPraiseAiInfo (item) {
+                const scrollRef = this.$refs.scroll
+                this.getPraiseAiInfo({
+                    ...this.postData
+                })
+                    .then((res) => {
+                        item.goodUsers = res.data.goodUsers
+                        item.badUsers = res.data.badUsers
+                        scrollRef.setSingleLogData(item)
+                    })
+            },
+
+            handleLoadAiMessage (item) {
+                item.aiMessage = ''
+                const scrollRef = this.$refs.scroll
+                this.handleGetPraiseAiInfo(item)
+                this.getLogAIMessage({
+                    ...this.postData,
+                    refresh: false,
+                    callBack (val) {
+                        item.aiMessage += val
+                        scrollRef.setSingleLogData(item)
+                        scrollRef.scrollAILogToBottom()
+                    }
+                })
+            },
+
+            handleReloadAiMessage (item) {
+                item.aiMessage = ''
+                const scrollRef = this.$refs.scroll
+                this.getLogAIMessage({
+                    ...this.postData,
+                    refresh: true,
+                    callBack (val) {
+                        item.aiMessage += val
+                        scrollRef.setSingleLogData(item)
+                        scrollRef.scrollAILogToBottom()
+                    }
+                }).then(() => {
+                    this.handleGetPraiseAiInfo(item)
+                })
+            },
+
             getLog () {
                 const id = hashID()
                 this.getLog.id = id

src/frontend/devops-pipeline/src/store/modules/atom/actions.js

@@ -784,6 +784,61 @@ export default {
         })
     },
 
+    praiseAi ({ commit }, { projectId, pipelineId, buildId, tag, currentExe, score }) {
+        let url = `/misc/api/user/gpt/script_error_analysis_score/${projectId}/${pipelineId}/${buildId}?taskId=${tag}&score=${score}`
+        if (currentExe) {
+            url += `&executeCount=${currentExe}`
+        }
+        return request.post(url)
+    },
+
+    cancelPraiseAi ({ commit }, { projectId, pipelineId, buildId, tag, currentExe, score }) {
+        let url = `/misc/api/user/gpt/script_error_analysis_score/${projectId}/${pipelineId}/${buildId}?taskId=${tag}&score=${score}`
+        if (currentExe) {
+            url += `&executeCount=${currentExe}`
+        }
+        return request.delete(url)
+    },
+
+    getPraiseAiInfo ({ commit }, { projectId, pipelineId, buildId, tag, currentExe }) {
+        let url = `/misc/api/user/gpt/script_error_analysis_score/${projectId}/${pipelineId}/${buildId}?taskId=${tag}&score=true`
+        if (currentExe) {
+            url += `&executeCount=${currentExe}`
+        }
+        return request.get(url)
+    },
+
+    getLogAIMessage ({ commit }, { projectId, pipelineId, buildId, tag, currentExe, refresh, callBack }) {
+        let url = `/misc/api/user/gpt/script_error_analysis/${projectId}/${pipelineId}/${buildId}?taskId=${tag}&refresh=${refresh}`
+        if (currentExe) {
+            url += `&executeCount=${currentExe}`
+        }
+        return window.fetch(url, {
+            method: 'post'
+        }).then((response) => {
+            const reader = response.body.getReader()
+            const decoder = new TextDecoder()
+
+            const readChunk = () => {
+                return reader.read().then(appendChunks)
+            }
+
+            const appendChunks = (result) => {
+                const chunk = decoder.decode(result.value || new Uint8Array(), {
+                    stream: !result.done
+                })
+                if (chunk) {
+                    callBack(chunk)
+                }
+                if (!result.done) {
+                    readChunk()
+                }
+            }
+
+            readChunk()
+        })
+    },
+
     getMacSysVersion () {
         return request.get(`${MACOS_API_URL_PREFIX}/user/systemVersions/v2`)
     },

src/frontend/locale/pipeline/en-US.json

@@ -149,6 +149,10 @@
   "downloadLog": "Download Log",
   "hideDebugLog": "Hide Debug Log",
   "showDebugLog": "Show Debug Log",
+  "successPraise": "Like Success",
+  "successDownPraise": "Down Like Success",
+  "successCancelPraise": "Cancel Like",
+  "successCancelDownPraise": "Cancel Down Like",
   "stageReview": {
     "stageInConditions": "Stage-In conditions",
     "approvalFlow": "Approval flow",
@@ -601,7 +605,7 @@
     "downloading": "Downloading ",
     "copySuc": " Copy {0} to custom artifactory successfully",
     "buildMsg": "Build Message"
-},
+  },
   "preview": {
     "build": "Build",
     "introVersion": "Recommended Version",
@@ -1578,4 +1582,4 @@
   "debugHint": "Debugging and execution do not share build numbers, but they share concurrency control. Debug records are only valid during the draft version debugging period and will be automatically cleared after the version is released.",
   "templateRollbackBackTips": "The current pipeline is in constraint mode (template instance). You need to jump to the template to roll back the version.",
   "versionNotMatch": "The current version is not the latest version and cannot be executed"
-}
+}

src/frontend/locale/pipeline/zh-CN.json

@@ -149,6 +149,10 @@
   "downloadLog": "下载日志",
   "hideDebugLog": "隐藏调试日志",
   "showDebugLog": "展示调试日志",
+  "successPraise": "已赞",
+  "successDownPraise": "已踩",
+  "successCancelPraise": "取消赞",
+  "successCancelDownPraise": "取消踩",
   "stageReview": {
     "stageInConditions": "准入规则",
     "approvalFlow": "审核流",