fix: 修改数据流转、场景联动、看板选择组织逻辑

@@ -56,7 +56,10 @@
           return unref(orgList);
         }
       },
-      params: { ...params, _t: unref(timespan) },
+      params: {
+        ...params,
+        _t: unref(timespan),
+      },
       onChange: (...args: any[]) => {
         emit('change', ...args);
       },

@@ -31,9 +31,9 @@
   import { CredentialsEnum } from '../mqtt/enum';
 
   const credentialsFile = reactive({
-    caCertFileName: '',
-    certFileName: '',
-    privateKeyFileName: '',
+    caCertFileName: undefined,
+    certFileName: undefined,
+    privateKeyFileName: undefined,
   });
 
   const [register, { validateFields, setFieldsValue, resetFields }] = useForm({
@@ -50,6 +50,11 @@
   const getValue = async () => {
     const values = await validateFields();
     if (!values) return;
+    // if (values.type == 'anonymous' || values.type == 'basic') {
+    //   credentialsFile.caCertFileName = undefined;
+    //   credentialsFile.certFileName = undefined;
+    //   credentialsFile.privateKeyFileName = undefined;
+    // }
     const credentials = {
       type: values['type'],
       ...credentialsFile,

@@ -51,10 +51,16 @@
   const getValue = async () => {
     const values = await validateFields();
     if (!values) return;
+    if (values.type == 'anonymous' || values.type == 'basic') {
+      credentialsFile.caCertFileName = undefined;
+      credentialsFile.certFileName = undefined;
+      credentialsFile.privateKeyFileName = undefined;
+    }
     const credentials = {
       type: values['type'],
       ...credentialsFile,
     };
+
     const mergeValues = {
       ...values,
       ...{ credentials },
@@ -67,7 +73,12 @@
     if (credentials) {
       for (let i in credentials) Reflect.set(credentialsFile, i, credentials[i]);
     }
-    setFieldsValue({ ...value, type: credentials.type });
+    setFieldsValue({
+      ...value,
+      type: credentials.type,
+      username: credentials.username,
+      password: credentials.password,
+    });
   };
 
   const resetValue = () => resetFields();

@@ -18,7 +18,7 @@ class MqttFormPartialConfig {
     return [
       { label: 'Anonymous', value: 'anonymous' },
       { label: 'Basic', value: 'basic' },
-      { label: 'PEM', value: 'pem' },
+      { label: 'PEM', value: 'cert.PEM' },
     ];
   }
 }
@@ -138,9 +138,21 @@ export const modeMqttForm: FormSchema[] = [
     label: '凭据类型',
     colProps: { span: 12 },
     defaultValue: MqttFormPartialConfig.type,
-    componentProps: {
-      placeholder: '请选择Credentials',
-      options: MqttFormPartialConfig.getType(),
+    componentProps: ({ formActionType }) => {
+      const { setFieldsValue } = formActionType;
+      return {
+        placeholder: '请选择Credentials',
+        options: MqttFormPartialConfig.getType(),
+        onChange(e) {
+          if (e) {
+            console.log('执行');
+            setFieldsValue({
+              password: undefined,
+              username: undefined,
+            });
+          }
+        },
+      };
     },
   },
   {

@@ -6,7 +6,7 @@
 export enum CredentialsEnum {
   IS_ANONYMOUS = 'anonymous',
   IS_BASIC = 'basic',
-  IS_PEM = 'pem',
+  IS_PEM = 'cert.PEM',
 }
 
 export const isBasic = (type: string) => {

@@ -128,8 +128,9 @@
             : undefined,
           appendClientIdSuffix: getDataFlowParams.appendClientIdSuffix || undefined,
           type: undefined,
+          username: undefined,
+          password: undefined,
         };
-
         const rest = isRabbitmq(getDataFlowMethod?.type)
           ? await postAddConvertApi({ ...restData.data, ...data })
           : await postAddConvertApi({ ...restData.data, ...data, configuration });

@@ -755,6 +755,18 @@ export const actionSchema: FormSchema[] = [
     component: 'Select',
     label: '',
     show: ({ values }) => isAlarmOut(values.outTarget),
+    // dynamicRules: (params) => {
+    //   const { outTarget } = params.values;
+    //   return [
+    //     {
+    //       required: outTarget == 'MSG_NOTIFY' ? true : false,
+    //       validator: (_, value) => {
+    //         if (!value) return Promise.reject('请选择告警配置');
+    //         Promise.resolve();
+    //       },
+    //     },
+    //   ];
+    // },
     componentProps: {
       placeholder: '请选择告警等级',
       options: [

@@ -273,6 +273,10 @@
       if (validate.device == 'PART' && validate.deviceId == undefined)
         return createMessage.error('请选择设备');
     }
+    if (type === 'MSG_NOTIFY') {
+      if (!validate.alarm_config) return createMessage.error('请选择告警配置');
+      if (!validate.alarm_level) return createMessage.error('请选择告警等级');
+    }
     //ft-add-2022-11-22
     //TODO-fengtao-设备验证
     const value = getFieldsValue();

@@ -188,7 +188,9 @@
     if (hasDetailPermission) {
       const boardId = encode(record.id);
       const boardName = encode(record.name);
-      router.push(`/visual/board/detail/${boardId}/${boardName}`);
+      const organizationId = encode(record?.organizationId);
+
+      router.push(`/visual/board/detail/${boardId}/${boardName}/${organizationId}`);
     } else createMessage.warning('没有权限');
   };
 

@@ -90,6 +90,7 @@ export const commonDataSourceSchemas = (): FormSchema[] => {
   const isUpdate = unref(mode) === DataActionModeEnum.UPDATE;
   const selectWidgetKeys = useSelectWidgetKeys();
   const category = unref(selectWidgetKeys).categoryKey;
+
   return [
     {
       field: DataSourceField.IS_GATEWAY_DEVICE,
@@ -191,6 +192,9 @@ export const commonDataSourceSchemas = (): FormSchema[] => {
             });
           },
           showCreate: false,
+          apiTreeSelectProps: {
+            params: { organizationId: location?.pathname?.split('/')?.pop() || '' },
+          },
           getPopupContainer: () => document.body,
         };
       },