Skip to content

Commit 79507ae

Browse files
committed
【代码评审】IoT:数据桥梁的接入
1 parent 9ca5ffb commit 79507ae

File tree

5 files changed

+23
-17
lines changed

5 files changed

+23
-17
lines changed

src/api/iot/rule/databridge/index.ts

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
import request from '@/config/axios'
22

3-
//数据桥梁 VO
3+
// IoT 数据桥梁 VO
44
export interface DataBridgeVO {
55
id?: number // 桥梁编号
66
name?: string // 桥梁名称
@@ -80,6 +80,7 @@ export interface RedisStreamMQConfig extends Config {
8080
}
8181

8282
/** 数据桥梁类型 */
83+
// TODO @puhui999:枚举用 number 可以么?
8384
export const IoTDataBridgeConfigType = {
8485
HTTP: '1',
8586
TCP: '2',

src/views/iot/rule/databridge/IoTDataBridgeForm.vue

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -100,28 +100,28 @@ const formData = ref<DataBridgeVO>({
100100
config: {} as any
101101
})
102102
const formRules = reactive({
103-
/** 通用字段 */
103+
// 通用字段
104104
name: [{ required: true, message: '桥梁名称不能为空', trigger: 'blur' }],
105105
status: [{ required: true, message: '桥梁状态不能为空', trigger: 'blur' }],
106106
direction: [{ required: true, message: '桥梁方向不能为空', trigger: 'blur' }],
107107
type: [{ required: true, message: '桥梁类型不能为空', trigger: 'change' }],
108-
/** HTTP 配置 */
108+
// HTTP 配置
109109
'config.url': [{ required: true, message: '请求地址不能为空', trigger: 'blur' }],
110110
'config.method': [{ required: true, message: '请求方法不能为空', trigger: 'blur' }],
111-
/** MQTT 配置 */
111+
// MQTT 配置
112112
'config.username': [{ required: true, message: '用户名不能为空', trigger: 'blur' }],
113113
'config.password': [{ required: true, message: '密码不能为空', trigger: 'blur' }],
114114
'config.clientId': [{ required: true, message: '客户端ID不能为空', trigger: 'blur' }],
115115
'config.topic': [{ required: true, message: '主题不能为空', trigger: 'blur' }],
116-
/** RocketMQ 配置 */
116+
// RocketMQ 配置
117117
'config.nameServer': [{ required: true, message: 'NameServer 地址不能为空', trigger: 'blur' }],
118118
'config.accessKey': [{ required: true, message: 'AccessKey 不能为空', trigger: 'blur' }],
119119
'config.secretKey': [{ required: true, message: 'SecretKey 不能为空', trigger: 'blur' }],
120120
'config.group': [{ required: true, message: '消费组不能为空', trigger: 'blur' }],
121-
/** Kafka 配置 */
121+
// Kafka 配置
122122
'config.bootstrapServers': [{ required: true, message: '服务地址不能为空', trigger: 'blur' }],
123123
'config.ssl': [{ required: true, message: 'SSL 配置不能为空', trigger: 'change' }],
124-
/** RabbitMQ 配置 */
124+
// RabbitMQ 配置
125125
'config.host': [{ required: true, message: '主机地址不能为空', trigger: 'blur' }],
126126
'config.port': [
127127
{ required: true, message: '端口不能为空', trigger: 'blur' },
@@ -131,7 +131,7 @@ const formRules = reactive({
131131
'config.exchange': [{ required: true, message: '交换机不能为空', trigger: 'blur' }],
132132
'config.routingKey': [{ required: true, message: '路由键不能为空', trigger: 'blur' }],
133133
'config.queue': [{ required: true, message: '队列不能为空', trigger: 'blur' }],
134-
/** Redis Stream 配置 */
134+
// Redis Stream 配置
135135
'config.database': [
136136
{ required: true, message: '数据库索引不能为空', trigger: 'blur' },
137137
{ type: 'number', min: 0, message: '数据库索引必须是非负整数', trigger: 'blur' }
@@ -143,6 +143,7 @@ const showConfig = computed(() => (val: string) => {
143143
const dict = getDictObj(DICT_TYPE.IOT_DATA_BRIDGE_TYPE_ENUM, formData.value.type)
144144
return dict && dict.value + '' === val
145145
}) // 显示对应的 Config 配置项
146+
146147
/** 打开弹窗 */
147148
const open = async (type: string, id?: number) => {
148149
dialogVisible.value = true
@@ -195,6 +196,7 @@ const handleTypeChange = (val: number) => {
195196
/** 重置表单 */
196197
const resetForm = () => {
197198
formData.value = {
199+
// TODO @puhui999:换成枚举值哈
198200
status: 0,
199201
direction: 1,
200202
type: 1,

src/views/iot/rule/databridge/config/KafkaMQConfigForm.vue

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88
<el-form-item label="密码" prop="config.password">
99
<el-input v-model="config.password" placeholder="请输入密码" show-password type="password" />
1010
</el-form-item>
11-
<el-form-item label="启用SSL" prop="config.ssl">
11+
<el-form-item label="启用 SSL" prop="config.ssl">
1212
<el-switch v-model="config.ssl" />
1313
</el-form-item>
1414
<el-form-item label="主题" prop="config.topic">

src/views/iot/rule/databridge/config/RocketMQConfigForm.vue

Lines changed: 9 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,17 @@
11
<template>
2-
<el-form-item label="名称服务地址" prop="config.nameServer">
3-
<el-input v-model="config.nameServer" placeholder="请输入命名服务地址,如:127.0.0.1:9876" />
2+
<el-form-item label="NameServer" prop="config.nameServer">
3+
<el-input
4+
v-model="config.nameServer"
5+
placeholder="请输入 NameServer 地址,如:127.0.0.1:9876"
6+
/>
47
</el-form-item>
5-
<el-form-item label="Access Key" prop="config.accessKey">
6-
<el-input v-model="config.accessKey" placeholder="请输入Access Key" />
8+
<el-form-item label="AccessKey" prop="config.accessKey">
9+
<el-input v-model="config.accessKey" placeholder="请输入 AccessKey" />
710
</el-form-item>
8-
<el-form-item label="Secret Key" prop="config.secretKey">
11+
<el-form-item label="SecretKey" prop="config.secretKey">
912
<el-input
1013
v-model="config.secretKey"
11-
placeholder="请输入Secret Key"
14+
placeholder="请输入 SecretKey"
1215
show-password
1316
type="password"
1417
/>

src/views/iot/rule/databridge/config/components/KeyValueEditor.vue

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,8 +33,7 @@ const props = defineProps<{
3333
addButtonText: string
3434
}>()
3535
const emit = defineEmits(['update:modelValue'])
36-
/** 内部 key-value 项列表 */
37-
const items = ref<KeyValueItem[]>([])
36+
const items = ref<KeyValueItem[]>([]) // 内部 key-value 项列表
3837
3938
/** 添加项目 */
4039
const addItem = () => {
@@ -59,6 +58,7 @@ const updateModelValue = () => {
5958
emit('update:modelValue', result)
6059
}
6160
61+
// TODO @puhui999:有告警的地方,尽量用 cursor 处理下
6262
/** 监听项目变化 */
6363
watch(items, updateModelValue, { deep: true })
6464
watch(

0 commit comments

Comments
 (0)