From a1d7e81859f554f3a53680cc35f0f49bf1f77098 Mon Sep 17 00:00:00 2001
From: wwf <1971391498@qq.com>
Date: 星期四, 14 五月 2026 14:37:02 +0800
Subject: [PATCH] 导入项目
---
src/views/iot/rule/data/sink/DataSinkForm.vue | 188 +++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 188 insertions(+), 0 deletions(-)
diff --git a/src/views/iot/rule/data/sink/DataSinkForm.vue b/src/views/iot/rule/data/sink/DataSinkForm.vue
new file mode 100644
index 0000000..a497457
--- /dev/null
+++ b/src/views/iot/rule/data/sink/DataSinkForm.vue
@@ -0,0 +1,188 @@
+<template>
+ <Dialog v-model="dialogVisible" :title="dialogTitle">
+ <el-form
+ ref="formRef"
+ v-loading="formLoading"
+ :model="formData"
+ :rules="formRules"
+ label-width="120px"
+ >
+ <el-form-item label="鐩殑鍚嶇О" prop="name">
+ <el-input v-model="formData.name" placeholder="璇疯緭鍏ョ洰鐨勫悕绉�" />
+ </el-form-item>
+ <el-form-item label="鐩殑鎻忚堪" prop="description">
+ <el-input v-model="formData.description" height="150px" type="textarea" />
+ </el-form-item>
+ <el-form-item label="鐩殑绫诲瀷" prop="type">
+ <el-select v-model="formData.type" @change="handleTypeChange">
+ <el-option
+ v-for="item in getIntDictOptions(DICT_TYPE.IOT_DATA_SINK_TYPE_ENUM)"
+ :key="item.value"
+ :label="item.label"
+ :value="item.value"
+ />
+ </el-select>
+ </el-form-item>
+ <HttpConfigForm v-if="IotDataSinkTypeEnum.HTTP === formData.type" v-model="formData.config" />
+ <MqttConfigForm v-if="IotDataSinkTypeEnum.MQTT === formData.type" v-model="formData.config" />
+ <RocketMQConfigForm
+ v-if="IotDataSinkTypeEnum.ROCKETMQ === formData.type"
+ v-model="formData.config"
+ />
+ <KafkaMQConfigForm
+ v-if="IotDataSinkTypeEnum.KAFKA === formData.type"
+ v-model="formData.config"
+ />
+ <RabbitMQConfigForm
+ v-if="IotDataSinkTypeEnum.RABBITMQ === formData.type"
+ v-model="formData.config"
+ />
+ <RedisStreamConfigForm
+ v-if="IotDataSinkTypeEnum.REDIS_STREAM === formData.type"
+ v-model="formData.config"
+ />
+ <el-form-item label="鐩殑鐘舵��" prop="status">
+ <el-radio-group v-model="formData.status">
+ <el-radio
+ v-for="dict in getIntDictOptions(DICT_TYPE.COMMON_STATUS)"
+ :key="dict.value"
+ :label="dict.value"
+ >
+ {{ dict.label }}
+ </el-radio>
+ </el-radio-group>
+ </el-form-item>
+ </el-form>
+ <template #footer>
+ <el-button :disabled="formLoading" type="primary" @click="submitForm">纭� 瀹�</el-button>
+ <el-button @click="dialogVisible = false">鍙� 娑�</el-button>
+ </template>
+ </Dialog>
+</template>
+<script lang="ts" setup>
+import { DICT_TYPE, getIntDictOptions } from '@/utils/dict'
+import { CommonStatusEnum } from '@/utils/constants'
+import { DataSinkApi, DataSinkVO, IotDataSinkTypeEnum } from '@/api/iot/rule/data/sink'
+import {
+ HttpConfigForm,
+ KafkaMQConfigForm,
+ MqttConfigForm,
+ RabbitMQConfigForm,
+ RedisStreamConfigForm,
+ RocketMQConfigForm
+} from './config'
+
+/** IoT 鏁版嵁娴佽浆鐩殑鐨勮〃鍗� */
+defineOptions({ name: 'IoTDataSinkForm' })
+
+const { t } = useI18n() // 鍥介檯鍖�
+const message = useMessage() // 娑堟伅寮圭獥
+
+const dialogVisible = ref(false) // 寮圭獥鐨勬槸鍚﹀睍绀�
+const dialogTitle = ref('') // 寮圭獥鐨勬爣棰�
+const formLoading = ref(false) // 琛ㄥ崟鐨勫姞杞戒腑锛�1锛変慨鏀规椂鐨勬暟鎹姞杞斤紱2锛夋彁浜ょ殑鎸夐挳绂佺敤
+const formType = ref('') // 琛ㄥ崟鐨勭被鍨嬶細create - 鏂板锛泆pdate - 淇敼
+const formData = ref<DataSinkVO>({
+ status: CommonStatusEnum.ENABLE,
+ type: IotDataSinkTypeEnum.HTTP,
+ config: {} as any
+})
+const formRules = reactive({
+ // 閫氱敤瀛楁
+ name: [{ required: true, message: '鐩殑鍚嶇О涓嶈兘涓虹┖', trigger: 'blur' }],
+ status: [{ required: true, message: '鐩殑鐘舵�佷笉鑳戒负绌�', trigger: 'blur' }],
+ type: [{ required: true, message: '鐩殑绫诲瀷涓嶈兘涓虹┖', trigger: 'change' }],
+ // HTTP 閰嶇疆
+ 'config.url': [{ required: true, message: '璇锋眰鍦板潃涓嶈兘涓虹┖', trigger: 'blur' }],
+ 'config.method': [{ required: true, message: '璇锋眰鏂规硶涓嶈兘涓虹┖', trigger: 'blur' }],
+ // MQTT 閰嶇疆
+ 'config.username': [{ required: true, message: '鐢ㄦ埛鍚嶄笉鑳戒负绌�', trigger: 'blur' }],
+ 'config.password': [{ required: true, message: '瀵嗙爜涓嶈兘涓虹┖', trigger: 'blur' }],
+ 'config.clientId': [{ required: true, message: '瀹㈡埛绔� ID 涓嶈兘涓虹┖', trigger: 'blur' }],
+ 'config.topic': [{ required: true, message: '涓婚涓嶈兘涓虹┖', trigger: 'blur' }],
+ // RocketMQ 閰嶇疆
+ 'config.nameServer': [{ required: true, message: 'NameServer 鍦板潃涓嶈兘涓虹┖', trigger: 'blur' }],
+ 'config.accessKey': [{ required: true, message: 'AccessKey 涓嶈兘涓虹┖', trigger: 'blur' }],
+ 'config.secretKey': [{ required: true, message: 'SecretKey 涓嶈兘涓虹┖', trigger: 'blur' }],
+ 'config.group': [{ required: true, message: '娑堣垂缁勪笉鑳戒负绌�', trigger: 'blur' }],
+ // Kafka 閰嶇疆
+ 'config.bootstrapServers': [{ required: true, message: '鏈嶅姟鍦板潃涓嶈兘涓虹┖', trigger: 'blur' }],
+ 'config.ssl': [{ required: true, message: 'SSL 閰嶇疆涓嶈兘涓虹┖', trigger: 'change' }],
+ // RabbitMQ 閰嶇疆
+ 'config.host': [{ required: true, message: '涓绘満鍦板潃涓嶈兘涓虹┖', trigger: 'blur' }],
+ 'config.port': [
+ { required: true, message: '绔彛涓嶈兘涓虹┖', trigger: 'blur' },
+ { type: 'number', min: 1, max: 65535, message: '绔彛鍙疯寖鍥� 1-65535', trigger: 'blur' }
+ ],
+ 'config.virtualHost': [{ required: true, message: '铏氭嫙涓绘満涓嶈兘涓虹┖', trigger: 'blur' }],
+ 'config.exchange': [{ required: true, message: '浜ゆ崲鏈轰笉鑳戒负绌�', trigger: 'blur' }],
+ 'config.routingKey': [{ required: true, message: '璺敱閿笉鑳戒负绌�', trigger: 'blur' }],
+ 'config.queue': [{ required: true, message: '闃熷垪涓嶈兘涓虹┖', trigger: 'blur' }],
+ // Redis Stream 閰嶇疆
+ 'config.database': [
+ { required: true, message: '鏁版嵁搴撶储寮曚笉鑳戒负绌�', trigger: 'blur' },
+ { type: 'number', min: 0, message: '鏁版嵁搴撶储寮曞繀椤绘槸闈炶礋鏁存暟', trigger: 'blur' }
+ ]
+})
+
+const formRef = ref() // 琛ㄥ崟 Ref
+
+/** 鎵撳紑寮圭獥 */
+const open = async (type: string, id?: number) => {
+ dialogVisible.value = true
+ dialogTitle.value = t('action.' + type)
+ formType.value = type
+ resetForm()
+ // 淇敼鏃讹紝璁剧疆鏁版嵁
+ if (id) {
+ formLoading.value = true
+ try {
+ formData.value = await DataSinkApi.getDataSink(id)
+ } finally {
+ formLoading.value = false
+ }
+ }
+}
+defineExpose({ open }) // 鎻愪緵 open 鏂规硶锛岀敤浜庢墦寮�寮圭獥
+
+/** 鎻愪氦琛ㄥ崟 */
+const emit = defineEmits(['success']) // 瀹氫箟 success 浜嬩欢锛岀敤浜庢搷浣滄垚鍔熷悗鐨勫洖璋�
+const submitForm = async () => {
+ // 鏍￠獙琛ㄥ崟
+ await formRef.value.validate()
+ // 鎻愪氦璇锋眰
+ formLoading.value = true
+ try {
+ const data = formData.value as unknown as DataSinkVO
+ if (formType.value === 'create') {
+ await DataSinkApi.createDataSink(data)
+ message.success(t('common.createSuccess'))
+ } else {
+ await DataSinkApi.updateDataSink(data)
+ message.success(t('common.updateSuccess'))
+ }
+ dialogVisible.value = false
+ // 鍙戦�佹搷浣滄垚鍔熺殑浜嬩欢
+ emit('success')
+ } finally {
+ formLoading.value = false
+ }
+}
+
+/** 澶勭悊绫诲瀷鍒囨崲浜嬩欢 */
+const handleTypeChange = (type: number) => {
+ formData.value.type = type
+ // 鍒囨崲绫诲瀷鏃堕噸缃厤缃�
+ formData.value.config = {} as any
+}
+
+/** 閲嶇疆琛ㄥ崟 */
+const resetForm = () => {
+ formData.value = {
+ status: CommonStatusEnum.ENABLE,
+ type: IotDataSinkTypeEnum.HTTP,
+ config: {} as any
+ }
+ formRef.value?.resetFields()
+}
+</script>
--
Gitblit v1.8.0