feat: 【IoT 物联网】新增 Tcp 和 websocket config form

This commit is contained in:
puhui999
2026-01-13 15:33:11 +08:00
parent 423af80a82
commit 7f36c45774
6 changed files with 378 additions and 133 deletions

View File

@@ -24,6 +24,11 @@
</el-select>
</el-form-item>
<HttpConfigForm v-if="IotDataSinkTypeEnum.HTTP === formData.type" v-model="formData.config" />
<TcpConfigForm v-if="IotDataSinkTypeEnum.TCP === formData.type" v-model="formData.config" />
<WebSocketConfigForm
v-if="IotDataSinkTypeEnum.WEBSOCKET === formData.type"
v-model="formData.config"
/>
<MqttConfigForm v-if="IotDataSinkTypeEnum.MQTT === formData.type" v-model="formData.config" />
<RocketMQConfigForm
v-if="IotDataSinkTypeEnum.ROCKETMQ === formData.type"
@@ -69,7 +74,9 @@ import {
MqttConfigForm,
RabbitMQConfigForm,
RedisStreamConfigForm,
RocketMQConfigForm
RocketMQConfigForm,
TcpConfigForm,
WebSocketConfigForm
} from './config'
/** IoT 数据流转目的的表单 */
@@ -95,6 +102,15 @@ const formRules = reactive({
// HTTP 配置
'config.url': [{ required: true, message: '请求地址不能为空', trigger: 'blur' }],
'config.method': [{ required: true, message: '请求方法不能为空', trigger: 'blur' }],
// TCP 配置 (host 和 port 与 RabbitMQ/Redis 共用)
'config.connectTimeoutMs': [{ required: true, message: '连接超时时间不能为空', trigger: 'blur' }],
'config.readTimeoutMs': [{ required: true, message: '读取超时时间不能为空', trigger: 'blur' }],
'config.dataFormat': [{ required: true, message: '数据格式不能为空', trigger: 'change' }],
// WebSocket 配置
'config.serverUrl': [
{ required: true, message: 'WebSocket 服务器地址不能为空', trigger: 'blur' }
],
'config.sendTimeoutMs': [{ required: true, message: '发送超时时间不能为空', trigger: 'blur' }],
// MQTT 配置
'config.username': [{ required: true, message: '用户名不能为空', trigger: 'blur' }],
'config.password': [{ required: true, message: '密码不能为空', trigger: 'blur' }],