<script lang="ts" setup>
|
import { onMounted } from 'vue';
|
|
import { isEmpty } from '..\..\..\..\..\..\packages\utils\src';
|
|
import { useVModel } from '@vueuse/core';
|
import { Form, Input, InputNumber } from 'ant-design-vue';
|
|
import { IotDataSinkTypeEnum } from '#/api/iot/rule/data/sink';
|
|
const props = defineProps<{ modelValue: any }>();
|
const emit = defineEmits(['update:modelValue']);
|
const config = useVModel(props, 'modelValue', emit);
|
|
/** 移除当前 Redis Stream API 类型未声明的旧扩展字段 */
|
function removeUnsupportedFields() {
|
delete config.value.dataStructure;
|
delete config.value.hashField;
|
delete config.value.scoreField;
|
}
|
|
onMounted(() => {
|
if (!isEmpty(config.value)) {
|
removeUnsupportedFields();
|
return;
|
}
|
config.value = {
|
type: `${IotDataSinkTypeEnum.REDIS_STREAM}`,
|
host: '',
|
port: 6379,
|
password: '',
|
database: 0,
|
topic: '',
|
};
|
});
|
</script>
|
|
<template>
|
<Form.Item
|
:name="['config', 'host']"
|
:rules="[{ required: true, message: '主机地址不能为空', trigger: 'blur' }]"
|
label="主机地址"
|
>
|
<Input
|
v-model:value="config.host"
|
placeholder="请输入主机地址，如：localhost"
|
/>
|
</Form.Item>
|
<Form.Item
|
:name="['config', 'port']"
|
:rules="[
|
{ required: true, message: '端口不能为空', trigger: 'blur' },
|
{
|
type: 'number',
|
min: 1,
|
max: 65_535,
|
message: '端口号范围 1-65535',
|
trigger: 'blur',
|
},
|
]"
|
label="端口"
|
>
|
<InputNumber
|
v-model:value="config.port"
|
:max="65535"
|
:min="1"
|
placeholder="请输入端口"
|
class="w-full"
|
/>
|
</Form.Item>
|
<Form.Item
|
:name="['config', 'password']"
|
:rules="[{ required: true, message: '密码不能为空', trigger: 'blur' }]"
|
label="密码"
|
>
|
<Input.Password v-model:value="config.password" placeholder="请输入密码" />
|
</Form.Item>
|
<Form.Item
|
:name="['config', 'database']"
|
:rules="[
|
{ required: true, message: '数据库索引不能为空', trigger: 'blur' },
|
{
|
type: 'number',
|
min: 0,
|
message: '数据库索引必须是非负整数',
|
trigger: 'blur',
|
},
|
]"
|
label="数据库"
|
>
|
<InputNumber
|
v-model:value="config.database"
|
:max="15"
|
:min="0"
|
placeholder="请输入数据库索引"
|
class="w-full"
|
/>
|
</Form.Item>
|
<Form.Item
|
:name="['config', 'topic']"
|
:rules="[{ required: true, message: '主题不能为空', trigger: 'blur' }]"
|
label="主题"
|
>
|
<Input v-model:value="config.topic" placeholder="请输入主题" />
|
</Form.Item>
|
</template>
|
