feat: 物模型新增导入功能

@@ -57,9 +57,7 @@ export interface GetModelTslParams {
 }
 
 export interface ImportModelOfMatterType {
-  attributeModels: any[];
-  eventModels: any[];
+  data: Recordable;
   functionType: string;
-  serviceModels: any[];
   tkDeviceProfileId: string;
 }

@@ -138,6 +138,7 @@
   import { OpenModelOfMatterModelParams, OpenModelMode } from './cpns/physical/types';
   import { ModelOfMatterParams } from '/@/api/device/model/modelOfMatterModel';
   import { ref } from 'vue';
+  import { isObject, isString } from '/@/utils/is';
   defineEmits(['register']);
 
   const props = defineProps<{
@@ -234,13 +235,33 @@
     }
   };
 
+  const paseJSON = (string: string) => {
+    let data = null;
+    let flag = false;
+    try {
+      if (!isString(string)) return { flag: false, data };
+      data = JSON.parse(string);
+      flag = true;
+      if (!isObject(data)) flag = false;
+    } catch (error) {}
+    return { flag, data };
+  };
+
   const handleImportModel = async (data: { file: File }) => {
     const fileReader = new FileReader();
 
-    fileReader.onload = () => {
-      console.log(fileReader.result);
+    fileReader.onload = async () => {
+      const { flag, data } = paseJSON(fileReader.result as string);
+      if (!flag) return;
+      const result = await importModelOfMatter({
+        tkDeviceProfileId: props.record.id,
+        data: data!,
+        functionType: 'all',
+      });
+
+      result ? createMessage.success('导入成功~') : createMessage.error('导入失败~');
 
-      importModelOfMatter({ tkDeviceProfileId: props.record.id });
+      result && reload();
     };
 
     fileReader.readAsText(data.file, 'utf-8');

+import { ref } from 'vue';
+import { DataSource } from '../../palette/types';
+import { sendCommandOneway } from '/@/api/dataBoard';
+import { useMessage } from '/@/hooks/web/useMessage';
+import { TransportTypeEnum } from '/@/views/device/profiles/components/TransportDescript/const';
+
+const { createMessage } = useMessage();
+export function useSendCommand() {
+  const loading = ref(false);
+
+  const error = () => {
+    createMessage.error('下发指令失败');
+    return false;
+  };
+  const sendCommand = async (record: DataSource, value: any) => {
+    if (!record) return error();
+    const { customCommand, attribute } = record;
+
+    const { deviceId } = record;
+    if (!deviceId) return error();
+    loading.value = true;
+    try {
+      let params: string | Recordable = {
+        [attribute!]: Number(value),
+      };
+
+      // 如果是TCP设备从物模型中获取下发命令(TCP网关子设备无物模型服务与事件)
+      if (customCommand?.transportType === TransportTypeEnum.TCP) {
+        params = customCommand.command!;
+      }
+
+      // 控制按钮下发命令为0 或 1
+      await sendCommandOneway({
+        deviceId,
+        value: {
+          params: params,
+          persistent: true,
+          additionalInfo: {
+            cmdType: 'API',
+          },
+          method: 'methodThingskit',
+        },
+      });
+      createMessage.success('命令下发成功');
+      return true;
+    } catch (msg) {
+      return error();
+    } finally {
+      loading.value = false;
+    }
+  };
+  return {
+    sendCommand,
+    loading,
+  };
+}