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,
  };
}