Pull request #9647: REPORT-126948 合并WebSocket的namespace和event FBP部分

Merge in DEC/decision-webui-dcm from ~HANS/decision-webui-dcm:research/mss-2.0 to research/mss-2.0

* commit 'f4140b1035a6c251e9576d168b711e34b9fd493a':
  REPORT-126948 合并WebSocket的namespace和event FBP部分 数据结构调整

assets/scripts/dec.js

@@ -16,6 +16,8 @@ window.DecCst = {
       EditStatusEvent: {
         OPEN: 'getConnectionStatus',
         SHUTDOWN: 'shutdownConnectionStatus',
+        CONNECTION_EDITED: 'connectionEdited',
+        CONNECTION_RELEASED: 'connectionReleased',
       }
     },
     Hyperlink: {

src/modules/constants/env.ts

@@ -9,10 +9,12 @@ export const connectionType: {
     JNDI: string;
 } = DecCst.Connect.ConnectionType;
 
-export const editStatusEvent: {
-    OPEN: string;
-    SHUTDOWN: string;
-} = DecCst.Connect.EditStatusEvent;
+export const editStatusEvent = {
+    OPEN: 'getConnectionStatus',
+    SHUTDOWN: 'shutdownConnectionStatus',
+    CONNECTION_EDITED: 'connectionEdited',
+    CONNECTION_RELEASED: 'connectionReleased',
+};
 
 export const errorCode: {
     CONNECTION_DELETED: string;

src/modules/crud/api.ts

@@ -75,6 +75,12 @@ export interface Api {
      */
     getConnectionStatus(name: string): Promise<SocketResult>;
 
+    /**
+     * 设置编辑状态
+     * @param name
+     */
+    setEditedConnectionStatus(name: string): void;
+
     /**
      * 关闭连接
      * @param name

src/modules/crud/decision.api.ts

@@ -50,7 +50,7 @@ export class DecisionApi implements Api {
 
     /**
      * 获取驱动加载路径
-     * @returns 
+     * @returns
      */
     getDriverLoadPath(data: Connection): Promise<ResultType<string>> {
         const form = {
@@ -82,11 +82,19 @@ export class DecisionApi implements Api {
     }
 
     getConnectionStatus(name: string): Promise<SocketResult> {
-        return this.sendEditStatusEvent(name, editStatusEvent.OPEN)
-            .then(re => {
-                if (re.errorCode) {
+        // TODO: 当前emit同步回调已无法执行
+        this.sendEditStatusEvent(name, editStatusEvent.OPEN);
+
+        if (!Dec.socket?.connected) {
+            return Promise.resolve({ data: 'success' });
+        }
+
+        return new Promise((resolve, rejected) => {
+            this.addEventListener(editStatusEvent.OPEN, data => {
+
+                if (data.errorCode) {
                     let errorMessage = '';
-                    switch (re.errorCode) {
+                    switch (data.errorCode) {
                         case errorCode.CONNECTION_DELETED:
                             errorMessage = 'Dec-Dcm_Connection_Deleted';
                             break;
@@ -94,29 +102,30 @@ export class DecisionApi implements Api {
                             errorMessage = 'Dec-Dcm_Connection_Is_Using';
                             break;
                         default:
-                            errorMessage = re.errorMsg;
+                            errorMessage = data.errorMessage;
                             break;
                     }
-                    BI.Msg.toast(BI.i18nText(errorMessage, re.errorMsg), {
+                    BI.Msg.toast(BI.i18nText(errorMessage, data.errorMessage), {
                         level: 'error',
                     });
-                    throw re;
+                    rejected(data);
                 } else {
-                    return re;
+                    resolve(data);
                 }
             });
+        });
+    }
+
+    setEditedConnectionStatus(name: string): Promise<SocketResult> {
+        return this.sendEditStatusEvent(name, editStatusEvent.CONNECTION_EDITED);
     }
 
     shutdownConnectionStatus(name: string): Promise<SocketResult> {
-        return this.sendEditStatusEvent(name, editStatusEvent.SHUTDOWN);
+        return this.sendEditStatusEvent(name, editStatusEvent.CONNECTION_RELEASED);
     }
 
     getSocketStatus(): boolean {
-        if (Dec) {
-            return Dec.socket.connected;
-        }
-
-        return false;
+        return !!Dec?.socket?.connected;
     }
 
     isDriverError(errorCode: string) {
@@ -164,8 +173,8 @@ export class DecisionApi implements Api {
 
     private sendEditStatusEvent(name: string, type: string): Promise<SocketResult> {
         return new Promise(resolve => {
-            if (Dec && Dec.socket.connected) {
-                Dec.socketEmit(type, BI.encode(name), (re: any) => {
+            if (Dec?.socket?.connected) {
+                Dec.socket.emit(type, BI.encode(name), (re: any) => {
                     resolve(re);
                 });
             } else {
@@ -173,4 +182,14 @@ export class DecisionApi implements Api {
             }
         });
     }
+
+    private addEventListener(name: string, callback: Function) {
+        if (!Dec.socket) return;
+
+        if (Dec.socket.hasListeners(name)) {
+            Dec.socket.removeListener(name);
+        }
+
+        Dec.socket.on(name, callback, false);
+    }
 }

src/modules/pages/maintain/maintain.ts

@@ -25,7 +25,7 @@ export class Maintain extends BI.Widget {
     render() {
         const { isEdit, databaseType } = this.getEditConnection();
         const titleText = getTextByDatabaseType(databaseType);
-        
+
         return {
             type: BI.VTapeLayout.xtype,
             hgap: 16,
@@ -81,11 +81,14 @@ export class Maintain extends BI.Widget {
             });
             this.socketTip.setVisible(true);
         }
+
+        this.model.connectionSelectedOne
+            && api.setEditedConnectionStatus(this.model.connectionSelectedOne.connectionName);
     }
 
     private renderItems() {
         const { type } = this.getEditConnection();
-        
+
         return [{
             type: MaintainForm.xtype,
             connectionType: type,
@@ -106,7 +109,7 @@ export class Maintain extends BI.Widget {
             const connectionJDBC = this.model.connectionSelectedOne.connectionData as ConnectionJDBC;
             databaseType = getJdbcDatabaseType(connectionJDBC.database, connectionJDBC.driver).databaseType;
         }
-        
+
         return {
             type: this.model.connectionSelectedOne.connectionType,
             text: this.model.connectionSelectedOne.connectionName,

types/globals.d.ts

@@ -11,6 +11,10 @@ declare const Dec: {
     fineServletURL: string;
     socket: {
         connected: boolean;
+        emit: Function;
+        on: Function;
+        hasListeners: Function;
+        removeListener: Function;
     };
     system: {};
     personal: {