import { ControlComponentValue } from './control.config';
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 error = () => {
    createMessage.error('下发指令失败');
    return false;
  };
  const sendCommand = async (record: ControlComponentValue, value: any) => {
    if (!record) return error();
    const { attribute } = record;
    const { dataSource } = record;
    const { customCommand } = dataSource || {};

    const { deviceId } = record;
    if (!deviceId) return error();
    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();
    }
  };
  return {
    sendCommand,
  };
}