✨ 计划任务中断及清理.

orion-ops-ui/src/components/exec/job/selector/index.vue

@@ -0,0 +1,80 @@
+<template>
+  <a-select v-model:model-value="value as any"
+            :options="optionData"
+            :allow-search="true"
+            :loading="loading"
+            :disabled="loading"
+            :filter-option="labelFilter"
+            :allow-create="allowCreate"
+            placeholder="请选择计划任务" />
+</template>
+
+<script lang="ts">
+  export default {
+    name: 'execJobSelector'
+  };
+</script>
+
+<script lang="ts" setup>
+  import type { SelectOptionData } from '@arco-design/web-vue';
+  import { computed, onBeforeMount, ref } from 'vue';
+  import { useCacheStore } from '@/store';
+  import { labelFilter } from '@/types/form';
+  import useLoading from '@/hooks/loading';
+
+  const props = withDefaults(defineProps<Partial<{
+    modelValue: number;
+    name: string;
+    allowCreate: boolean;
+  }>>(), {
+    allowCreate: false,
+  });
+
+  const emits = defineEmits(['update:modelValue', 'update:name']);
+
+  const { loading, setLoading } = useLoading();
+  const cacheStore = useCacheStore();
+
+  const value = computed({
+    get() {
+      if (props.allowCreate) {
+        return props.modelValue || props.name;
+      } else {
+        return props.modelValue;
+      }
+    },
+    set(e) {
+      if (typeof e === 'string') {
+        emits('update:modelValue', null);
+        emits('update:name', e);
+      } else {
+        // 已有的值
+        emits('update:modelValue', e);
+        emits('update:name', null);
+      }
+    }
+  });
+  const optionData = ref<Array<SelectOptionData>>([]);
+
+  // 初始化选项
+  onBeforeMount(async () => {
+    setLoading(true);
+    try {
+      const dictKeys = await cacheStore.loadExecJobs();
+      optionData.value = dictKeys.map(s => {
+        return {
+          label: s.name,
+          value: s.id,
+        };
+      });
+    } catch (e) {
+    } finally {
+      setLoading(false);
+    }
+  });
+
+</script>
+
+<style lang="less" scoped>
+
+</style>

orion-ops-ui/src/components/exec/log/const.ts

@@ -1,3 +1,6 @@
+// 执行类型
+export type ExecType = 'BATCH' | 'JOB';
+
 // 批量执行状态
 export const execStatus = {
   // 等待中

orion-ops-ui/src/components/exec/log/panel-modal/index.vue

@@ -16,7 +16,9 @@
             :loading="loading">
       <div class="panel-wrapper">
         <!-- 日志面板 -->
-        <exec-log-panel ref="log" :visible-back="false" />
+        <exec-log-panel ref="log"
+                        :type="type"
+                        :visible-back="false" />
       </div>
     </a-spin>
   </a-modal>
@@ -29,12 +31,18 @@
 </script>
 
 <script lang="ts" setup>
+  import type { ExecType } from '../const';
   import useVisible from '@/hooks/visible';
   import useLoading from '@/hooks/loading';
   import { nextTick, ref } from 'vue';
   import { getExecCommandLog } from '@/api/exec/exec-command-log';
+  import { getExecJobLog } from '@/api/exec/exec-job-log';
   import ExecLogPanel from '../panel/index.vue';
 
+  const props = defineProps<{
+    type: ExecType;
+  }>();
+
   const { visible, setVisible } = useVisible();
   const { loading, setLoading } = useLoading();
 
@@ -46,7 +54,15 @@
     setLoading(true);
     try {
       // 获取执行日志
-      const { data } = await getExecCommandLog(id);
+      let detailGetter;
+      if (props.type === 'BATCH') {
+        // 批量执行日志
+        detailGetter = getExecCommandLog(id);
+      } else {
+        // 计划任务日志
+        detailGetter = getExecJobLog(id);
+      }
+      const { data } = await detailGetter;
       // 打开日志
       await nextTick(() => {
         setTimeout(() => {

orion-ops-ui/src/components/exec/log/panel/index.vue

@@ -10,8 +10,9 @@
     <!-- 日志容器 -->
     <log-view ref="logViewRef"
               class="log-view-container"
+              :type="type"
               :current="currentHostExecId"
-              :hosts="execLog.hosts"
+              :exec-log="execLog"
               :appender="appender" />
   </div>
 </template>
@@ -25,16 +26,19 @@
 <script lang="ts" setup>
   import type { ExecLogQueryResponse } from '@/api/exec/exec-log';
   import type { ILogAppender } from './appender-const';
+  import type { ExecType } from '../const';
   import { onUnmounted, ref, nextTick, onMounted } from 'vue';
   import { getExecCommandLogStatus } from '@/api/exec/exec-command-log';
+  import { getExecJobLogStatus } from '@/api/exec/exec-job-log';
   import { dictKeys, execHostStatus, execStatus } from '../const';
   import { useDictStore } from '@/store';
   import ExecHost from './exec-host.vue';
   import LogView from './log-view.vue';
-  import LogAppender from '@/components/exec/log/panel/log-appender';
+  import LogAppender from './log-appender';
 
   const props = defineProps<{
-    visibleBack: boolean
+    visibleBack: boolean;
+    type: ExecType;
   }>();
 
   const emits = defineEmits(['back']);
@@ -48,7 +52,7 @@
 
   // 打开
   const open = (record: ExecLogQueryResponse) => {
-    appender.value = new LogAppender({ execId: record.id });
+    appender.value = new LogAppender(props.type, { execId: record.id });
     execLog.value = record;
     currentHostExecId.value = record.hosts[0].id;
     // 定时查询执行状态
@@ -71,7 +75,15 @@
       return;
     }
     // 加载状态
-    const { data: { logList, hostList } } = await getExecCommandLogStatus([execLog.value.id]);
+    let statusGetter;
+    if (props.type === 'BATCH') {
+      // 批量执行日志状态
+      statusGetter = getExecCommandLogStatus([execLog.value.id]);
+    } else {
+      // 计划任务日志状态
+      statusGetter = getExecJobLogStatus([execLog.value.id]);
+    }
+    const { data: { logList, hostList } } = await statusGetter;
     if (logList.length) {
       execLog.value.status = logList[0].status;
       execLog.value.startTime = logList[0].startTime;

orion-ops-ui/src/components/exec/log/panel/log-appender.ts

@@ -1,7 +1,9 @@
 import type { ILogAppender, LogAddons, LogAppenderConf, LogDomRef } from './appender-const';
 import { LogAppenderOptions } from './appender-const';
+import type { ExecType } from '../const';
 import type { ExecLogTailRequest } from '@/api/exec/exec-log';
 import { getExecCommandLogTailToken } from '@/api/exec/exec-command-log';
+import { getExecJobLogTailToken } from '@/api/exec/exec-job-log';
 import { webSocketBaseUrl } from '@/utils/env';
 import { Message } from '@arco-design/web-vue';
 import { createWebSocket } from '@/utils';
@@ -29,8 +31,11 @@ export default class LogAppender implements ILogAppender {
 
   private readonly fitAllFn: () => {};
 
-  constructor(config: ExecLogTailRequest) {
+  private readonly type: ExecType;
+
+  constructor(type: ExecType, config: ExecLogTailRequest) {
     this.current = undefined as unknown as LogAppenderConf;
+    this.type = type;
     this.config = config;
     this.appenderRel = {};
     this.fitAllFn = useDebounceFn(this.fitAll).bind(this);
@@ -141,8 +146,16 @@ export default class LogAppender implements ILogAppender {
 
   // 初始化 client
   async openClient() {
+    let tokenMaker;
     // 获取 token
-    const { data } = await getExecCommandLogTailToken(this.config);
+    if (this.type === 'BATCH') {
+      // 获取批量执行日志 token
+      tokenMaker = getExecCommandLogTailToken(this.config);
+    } else {
+      // 获取计划任务日志 token
+      tokenMaker = getExecJobLogTailToken(this.config);
+    }
+    const { data } = await tokenMaker;
     // 打开会话
     try {
       this.client = await createWebSocket(`${webSocketBaseUrl}/exec/log/${data}`);

orion-ops-ui/src/components/exec/log/panel/log-item.vue

@@ -4,6 +4,10 @@
     <div class="log-header">
       <!-- 左侧信息 -->
       <a-space class="log-header-left" :size="12">
+        <!-- 执行序列 -->
+        <a-tag v-if="execLog.execSeq" color="green">
+          #{{ execLog.execSeq }}
+        </a-tag>
         <!-- 状态 -->
         <a-tag :color="getDictValue(execHostStatusKey, host.status, 'color')">
           {{ getDictValue(execHostStatusKey, host.status) }}
@@ -160,20 +164,24 @@
 </script>
 
 <script lang="ts" setup>
-  import type { ExecHostLogQueryResponse } from '@/api/exec/exec-log';
+  import type { ExecLogQueryResponse, ExecHostLogQueryResponse } from '@/api/exec/exec-log';
   import type { ILogAppender } from './appender-const';
+  import type { ExecType } from '../const';
   import { ref } from 'vue';
   import { execHostStatus, execHostStatusKey } from '../const';
   import { formatDuration } from '@/utils';
   import { useDictStore } from '@/store';
   import { downloadExecCommandLogFile } from '@/api/exec/exec-command-log';
+  import { downloadExecJobLogFile } from '@/api/exec/exec-job-log';
   import { downloadFile } from '@/utils/file';
   import XtermSearchModal from '@/components/xtrem/search-modal/index.vue';
   import 'xterm/css/xterm.css';
 
   const props = defineProps<{
+    type: ExecType;
+    execLog: ExecLogQueryResponse;
     host: ExecHostLogQueryResponse;
-    appender: ILogAppender
+    appender: ILogAppender;
   }>();
 
   const { getDictValue } = useDictStore();
@@ -204,7 +212,17 @@
 
   // 下载文件
   const downloadLogFile = async (id: number) => {
-    const data = await downloadExecCommandLogFile(id);
+    // 获取日志文件
+    let fileGetter;
+    if (props.type === 'BATCH') {
+      // 下载批量执行日志
+      fileGetter = downloadExecCommandLogFile(id);
+    } else {
+      // 下载计划任务日志
+      fileGetter = downloadExecJobLogFile(id);
+    }
+    // 瞎子啊
+    const data = await fileGetter;
     downloadFile(data);
   };
 

orion-ops-ui/src/components/exec/log/panel/log-view.vue

@@ -2,10 +2,12 @@
   <div class="container">
     <log-item class="log-item"
               v-show="current === host.id"
-              v-for="host in hosts"
+              v-for="host in execLog.hosts"
               :key="host.id"
               :ref="addRef as unknown as VNodeRef"
+              :type="type"
               :host="host"
+              :exec-log="execLog"
               :appender="appender" />
   </div>
 </template>
@@ -19,14 +21,16 @@
 <script lang="ts" setup>
   import type { VNodeRef } from 'vue';
   import type { LogDomRef, ILogAppender } from './appender-const';
-  import type { ExecHostLogQueryResponse } from '@/api/exec/exec-log';
+  import type { ExecLogQueryResponse } from '@/api/exec/exec-log';
+  import type { ExecType } from '../const';
   import { nextTick, ref, watch } from 'vue';
   import LogItem from './log-item.vue';
 
   const props = defineProps<{
     current: number;
-    hosts: Array<ExecHostLogQueryResponse>;
+    execLog: ExecLogQueryResponse;
     appender: ILogAppender;
+    type: ExecType;
   }>();
 
   const logRefs = ref<Array<LogDomRef>>([]);