Merge branch 'fix/rule-dataflowmodal-bug' into 'main_dev'

fix: 修改数据流转的问题

See merge request yunteng/thingskit-front!734

@@ -52,6 +52,7 @@ export const modeMqttForm: FormSchema[] = [
     label: '主机',
     colProps: { span: 12 },
     component: 'Input',
+    required: true,
     componentProps: {
       maxLength: 255,
       placeholder: '请输入Host',

@@ -98,7 +98,26 @@
           getDataFlowParams?.clientProperties
         );
         const data = getValue(description, name, getDataFlowMethod, getDataFlowParams);
-        const rest = await postAddConvertApi({ ...restData.data, ...data });
+        const { caCertFileName, certFileName, privateKeyFileName } = getDataFlowParams.credentials;
+        const configuration = {
+          topicPattern: getDataFlowParams.topicPattern,
+          host: getDataFlowParams.host,
+          port: getDataFlowParams.port,
+          connectTimeoutSec: getDataFlowParams.connectTimeoutSec,
+          clientId: getDataFlowParams.clientId ? getDataFlowParams.clientId : null,
+          cleanSession: getDataFlowParams.cleanSession,
+          ssl: getDataFlowParams.ssl,
+          appendClientIdSuffix: getDataFlowParams.appendClientIdSuffix,
+          credentials: {
+            type: getDataFlowParams.type,
+            caCertFileName: caCertFileName ? caCertFileName : undefined,
+            certFileName: certFileName ? certFileName : undefined,
+            privateKeyFileName: privateKeyFileName ? privateKeyFileName : undefined,
+            username: getDataFlowParams.username ? getDataFlowParams.username : undefined,
+            password: getDataFlowParams.password ? getDataFlowParams.password : undefined,
+          },
+        };
+        const rest = await postAddConvertApi({ ...restData.data, ...data, configuration });
         if (rest) {
           closeModalAfterSuccess && createMessage.success(`${businessText.value}成功`);
           closeModalAfterSuccess && closeModal();