title: kafka数据推送 v1.0.0language思维导图
title: kafka数据推送 v1.0.0language内容介绍
树图思维导图提供 title: kafka数据推送 v1.0.0language 在线思维导图免费制作，点击“编辑”按钮，可对 title: kafka数据推送 v1.0.0language 进行在线思维导图编辑，本思维导图属于思维导图模板主题，文件编号是：e227e2455f4e33e3156c12d50fd1169a
思维导图大纲
title: kafka数据推送 v1.0.0 language思维导图模板大纲
kafka数据推送
v1.0.0
Base URLs:
公司表接口
GET 修改订阅状态
GET /company/status
请求参数
|名称|位置|类型|必选|说明| |---|---|---|---|---| |topic|query|string| 否 |none| |status|query|string| 否 |none|
返回示例
成功
json { "code": 200, "message": "", "data": null }
返回结果
|状态码|状态码含义|说明|数据模型| |---|---|---|---| |200|
返回数据结构
状态码
|名称|类型|必选|约束|中文名|说明| |---|---|---|---|---|---| |» code|integer|true|none||none| |» message|string|true|none||none| |» data|null|true|none||none|
POST 添加公司
POST /company/addCompany
请求参数
|名称|位置|类型|必选|说明| |---|---|---|---|---| |corporatename|query|string| 否 |none| |topic|query|string| 否 |none|
返回示例
成功
json { "code": 200, "message": "添加完成", "data": null }
返回结果
|状态码|状态码含义|说明|数据模型| |---|---|---|---| |200|
返回数据结构
状态码
|名称|类型|必选|约束|中文名|说明| |---|---|---|---|---|---| |» code|integer|true|none||none| |» message|string|true|none||none| |» data|null|true|none||none|
POST 修改公司
POST /company/updateCompany
请求参数
|名称|位置|类型|必选|说明| |---|---|---|---|---| |corporatename|query|string| 否 |none| |id|query|string| 否 |none|
返回示例
成功
json { "code": 200, "message": "修改完成", "data": null }
返回结果
|状态码|状态码含义|说明|数据模型| |---|---|---|---| |200|
返回数据结构
状态码
|名称|类型|必选|约束|中文名|说明| |---|---|---|---|---|---| |» code|integer|true|none||none| |» message|string|true|none||none| |» data|null|true|none||none|
GET 菜单
GET /menu/getMenu
返回示例
成功
json { "code": 200, "message": null, "data": [ { "id": 1, "parentId": null, "name": "自动化码头", "childList": [ { "id": null, "parentId": 1, "name": "STS", "childList": [ { "id": 1, "parentId": null, "name": "STS101", "childList": null }, { "id": 7, "parentId": null, "name": "STS102", "childList": null } ] }, { "id": null, "parentId": 1, "name": "AGV", "childList": [ { "id": 2, "parentId": null, "name": "AGV382", "childList": null } ] }, { "id": null, "parentId": 1, "name": "ASC", "childList": [ { "id": 3, "parentId": null, "name": "AS233", "childList": null } ] }, { "id": null, "parentId": 1, "name": "岸桥", "childList": [ { "id": 6, "parentId": null, "name": "Q03", "childList": null } ] } ] }, { "id": 2, "parentId": null, "name": "QQCT", "childList": [ { "id": null, "parentId": 2, "name": "岸桥", "childList": [ { "id": 4, "parentId": null, "name": "Q01", "childList": null }, { "id": 5, "parentId": null, "name": "Q02", "childList": null } ] } ] }, { "id": 3, "parentId": null, "name": "前港干散货", "childList": [] } ] }
返回结果
|状态码|状态码含义|说明|数据模型| |---|---|---|---| |200|
返回数据结构
状态码
|名称|类型|必选|约束|中文名|说明| |---|---|---|---|---|---| |» code|integer|true|none||none| |» message|null|true|none||none| |» data|[object]|true|none||none| |»» id|integer|true|none||none| |»» parentId|null|true|none||none| |»» name|string|true|none||none| |»» childList|[object]|true|none||none| |»»» id|null|true|none||none| |»»» parentId|integer|true|none||none| |»»» name|string|true|none||none| |»»» childList|[object]|true|none||none| |»»»» id|integer|true|none||none| |»»»» parentId|null|true|none||none| |»»»» name|string|true|none||none| |»»»» childList|null|true|none||none|
GET 获取所有公司
GET /company/getAllCompany
返回示例
成功
json { "code": 200, "message": null, "data": [ { "id": 1, "corporatename": "自动化码头", "devicename": null, "status": null, "topic": null }, { "id": 2, "corporatename": "QQCT", "devicename": null, "status": null, "topic": null }, { "id": 3, "corporatename": "前港干散货", "devicename": null, "status": null, "topic": null } ] }
返回结果
|状态码|状态码含义|说明|数据模型| |---|---|---|---| |200|
返回数据结构
状态码
|名称|类型|必选|约束|中文名|说明| |---|---|---|---|---|---| |» code|integer|true|none||none| |» message|null|true|none||none| |» data|[object]|true|none||none| |»» id|integer|true|none||none| |»» corporatename|string|true|none||none| |»» devicename|null|true|none||none| |»» status|null|true|none||none| |»» topic|null|true|none||none|
公司系统表
GET 获取公司系统
GET /comsystem/getAllComSys
返回示例
成功
json { "code": 200, "message": null, "data": [ { "id": 1, "systemname": "测试", "companyid": 1, "companyname": "自动化码头", "topic": "test", "status": 0 }, { "id": 2, "systemname": "测试1", "companyid": 2, "companyname": "QQCT", "topic": "test2", "status": 0 }, { "id": 3, "systemname": "自动化码头4", "companyid": 1, "companyname": "自动化码头", "topic": "test1", "status": 0 }, { "id": 4, "systemname": "自动化码头2", "companyid": 1, "companyname": null, "topic": "zdhmt2", "status": 0 } ] }
返回结果
|状态码|状态码含义|说明|数据模型| |---|---|---|---| |200|
返回数据结构
状态码
|名称|类型|必选|约束|中文名|说明| |---|---|---|---|---|---| |» code|integer|true|none||none| |» message|null|true|none||none| |» data|[object]|true|none||none| |»» id|integer|true|none||none| |»» systemname|string|true|none||none| |»» companyid|integer|true|none||none| |»» companyname|string¦null|true|none||none| |»» topic|string|true|none||none| |»» status|integer|true|none||none|
POST 添加系统
POST /comsystem/addComSys
Body 请求参数
json { "systemname": "自动化码头6", "topic": "11234", "companyid": 1 }
请求参数
|名称|位置|类型|必选|说明| |---|---|---|---|---| |systemname|query|string| 是 |none| |topic|query|string| 是 |none| |companyid|query|string| 是 |none| |Content-Type|header|string| 否 |none| |body|body|object| 否 |none|
返回示例
成功
json { "code": 200, "message": "添加完成", "data": null }
返回结果
|状态码|状态码含义|说明|数据模型| |---|---|---|---| |200|
返回数据结构
状态码
|名称|类型|必选|约束|中文名|说明| |---|---|---|---|---|---| |» code|integer|true|none||none| |» message|string|true|none||none| |» data|null|true|none||none|
GET 修改订阅状态
GET /comsystem/status
请求参数
|名称|位置|类型|必选|说明| |---|---|---|---|---| |topic|query|string| 是 |none| |status|query|string| 是 |none|
返回示例
成功
json { "code": 200, "message": "已取消", "data": null }
返回结果
|状态码|状态码含义|说明|数据模型| |---|---|---|---| |200|
返回数据结构
状态码
|名称|类型|必选|约束|中文名|说明| |---|---|---|---|---|---| |» code|integer|true|none||none| |» message|string|true|none||none| |» data|null|true|none||none|
POST 修改系统
POST /comsystem/updateComSys
Body 请求参数
json { "id": 6, "systemname": "自动化码头5", "topic": "zdhmt5", "companyid": 1 }
请求参数
|名称|位置|类型|必选|说明| |---|---|---|---|---| |topic|query|string| 是 |none| |id|query|string| 是 |none| |systemname|query|string| 是 |none| |body|body|object| 否 |none|
返回示例
成功
json { "code": 200, "message": "修改完成", "data": null }
返回结果
|状态码|状态码含义|说明|数据模型| |---|---|---|---| |200|
返回数据结构
状态码
|名称|类型|必选|约束|中文名|说明| |---|---|---|---|---|---| |» code|integer|true|none||none| |» message|string|true|none||none| |» data|null|true|none||none|
POST 删除系统
POST /comsystem/delComSys
请求参数
|名称|位置|类型|必选|说明| |---|---|---|---|---| |ids|query|string| 否 |none|
返回示例
成功
返回结果
|状态码|状态码含义|说明|数据模型| |---|---|---|---| |200|
返回数据结构
GET 条件查询模糊查询
GET /comsystem/queryComSys
请求参数
|名称|位置|类型|必选|说明| |---|---|---|---|---| |sysName|query|string| 否 |none| |status|query|string| 否 |none|
返回示例
成功
json { "code": 200, "message": null, "data": [ { "id": 3, "systemname": "自动化码头4", "companyid": 1, "companyname": "自动化码头", "topic": "test1", "status": 1 }, { "id": 5, "systemname": "自动化码头2", "companyid": 1, "companyname": null, "topic": "zdhmt2", "status": 0 }, { "id": 6, "systemname": "自动化码头3", "companyid": 1, "companyname": "自动化码头", "topic": "zdhmt5", "status": 0 }, { "id": 9, "systemname": "前港测试", "companyid": 3, "companyname": "前港干散货", "topic": "qg1", "status": 0 } ] }
返回结果
|状态码|状态码含义|说明|数据模型| |---|---|---|---| |200|
返回数据结构
状态码
|名称|类型|必选|约束|中文名|说明| |---|---|---|---|---|---| |» code|integer|true|none||none| |» message|null|true|none||none| |» data|[object]|true|none||none| |»» id|integer|true|none||none| |»» systemname|string|true|none||none| |»» companyid|integer|true|none||none| |»» companyname|string¦null|true|none||none| |»» topic|string|true|none||none| |»» status|integer|true|none||none|
订阅功能
GET 已订阅信息查询
GET /Subscribe/getSubscribe
请求参数
|名称|位置|类型|必选|说明| |---|---|---|---|---| |sysId|query|integer| 否 |系统id|
返回示例
成功
json { "code": 200, "message": null, "data": [ { "id": 7715, "tagid": 14282, "tagvalue": null, "corporatename": "自动化码头", "devicename": "STS101", "tagname": "STS_STS101_mtLsSpdPosId", "systemname": "测试", "describe": null }, { "id": 7718, "tagid": 14285, "tagvalue": null, "corporatename": "自动化码头", "devicename": "STS101", "tagname": "STS_STS101_pfLsCntSize", "systemname": "测试", "describe": null } ] }
返回结果
|状态码|状态码含义|说明|数据模型| |---|---|---|---| |200|
返回数据结构
状态码
|名称|类型|必选|约束|中文名|说明| |---|---|---|---|---|---| |» code|integer|true|none||状态码| |» message|null|true|none||状态消息| |» data|[object]|true|none||数据集合,没有时为空| |»» id|integer|true|none||主键id| |»» tagid|integer|true|none||tagId| |»» tagvalue|string|true|none||tag点值| |»» corporatename|string|true|none||公司名称| |»» devicename|string|true|none||设备名称| |»» tagname|string|true|none||tag点名| |»» systemname|string|true|none||系统名称| |»» describe|string|true|none||描述|
POST 订阅属性
POST /Subscribe/addSubscribe
Body 请求参数
y
请求参数
|名称|位置|类型|必选|说明| |---|---|---|---|---| |body|body|object| 否 |none| |» comSysId|body|integer| 是 |none| |» tagIds|body|string| 是 |none|
返回示例
成功
json { "code": 200, "message": "订阅成功", "data": null }
返回结果
|状态码|状态码含义|说明|数据模型| |---|---|---|---| |200|
返回数据结构
状态码
|名称|类型|必选|约束|中文名|说明| |---|---|---|---|---|---| |» code|integer|true|none||状态码| |» message|string|true|none||消息| |» data|null|true|none||返回数据,没有返回数据为null|
GET 分页查询
GET /Subscribe/findByPage
Body 请求参数
json { "pageNum": 1, "pageSize": 3, "companyName": "", "devName": "" }
请求参数
|名称|位置|类型|必选|说明| |---|---|---|---|---| |pageNum|query|string| 是 |none| |pageSize|query|string| 是 |none| |companyName|query|string| 否 |none| |devName|query|string| 否 |none| |body|body|object| 否 |none|
返回示例
成功
json { "pages": 763, "pageSize": 3, "pageNum": 1, "list": [ { "id": 5249, "tagid": 13, "tagvalue": null, "corporatename": "QQCT", "devicename": "Q01", "tagname": "Analog_Q01_Hoist_100001" }, { "id": 5250, "tagid": 14, "tagvalue": null, "corporatename": "QQCT", "devicename": "Q01", "tagname": "Analog_Q01_Hoist_100002" }, { "id": 5251, "tagid": 15, "tagvalue": null, "corporatename": "QQCT", "devicename": "Q01", "tagname": "Analog_Q01_Hoist_100003" } ] }
返回结果
|状态码|状态码含义|说明|数据模型| |---|---|---|---| |200|
返回数据结构
状态码
|名称|类型|必选|约束|中文名|说明| |---|---|---|---|---|---| |» pages|integer|true|none||none| |» pageSize|integer|true|none||none| |» pageNum|integer|true|none||none| |» list|[object]|true|none||none| |»» id|integer|true|none||none| |»» tagid|integer|true|none||none| |»» tagvalue|null|true|none||none| |»» corporatename|string|true|none||none| |»» devicename|string|true|none||none| |»» tagname|string|true|none||none|
POST 取消订阅
POST /Subscribe/delSub
Body 请求参数
y
请求参数
|名称|位置|类型|必选|说明| |---|---|---|---|---| |body|body|object| 否 |none| |» ids|body|string| 否 |none|
返回示例
成功
json { "code": 200, "message": "已取消", "data": null }
返回结果
|状态码|状态码含义|说明|数据模型| |---|---|---|---| |200|
返回数据结构
状态码
|名称|类型|必选|约束|中文名|说明| |---|---|---|---|---|---| |» code|integer|true|none||none| |» message|string|true|none||none| |» data|null|true|none||none|
IHD配置接口
POST 添加ihd配置
POST /ihd/addIhd
请求参数
|名称|位置|类型|必选|说明| |---|---|---|---|---| |ip|query|string| 否 |none| |port|query|string| 否 |none| |companyname|query|string| 否 |none|
返回示例
成功
json { "code": 200, "message": "添加完成", "data": null }
返回结果
|状态码|状态码含义|说明|数据模型| |---|---|---|---| |200|
返回数据结构
状态码
|名称|类型|必选|约束|中文名|说明| |---|---|---|---|---|---| |» code|integer|true|none||none| |» message|string|true|none||none| |» data|null|true|none||none|
POST 修改IHD配置信息
POST /ihd/updateIhd
请求参数
|名称|位置|类型|必选|说明| |---|---|---|---|---| |ip|query|string| 否 |none| |port|query|string| 否 |none| |companyname|query|string| 否 |none| |id|query|string| 是 |none| |userName|query|string| 否 |none| |password|query|string| 否 |none|
返回示例
成功
json { "code": 200, "message": "该配置已存在", "data": null }
返回结果
|状态码|状态码含义|说明|数据模型| |---|---|---|---| |200|
返回数据结构
状态码
|名称|类型|必选|约束|中文名|说明| |---|---|---|---|---|---| |» code|integer|true|none||none| |» message|string|true|none||none| |» data|null|true|none||none|
GET 查询IHD
GET /ihd/getAll
返回示例
成功
json { "code": 200, "message": null, "data": [ { "id": 1, "ip": "10.205.81.68", "port": 5673, "userName": "admin", "password": "admin", "companyname": "qqct" }, { "id": 2, "ip": "10.205.81.68", "port": 5673, "userName": "admin", "password": "admin", "companyname": "zdhmt" }, { "id": 12, "ip": "10.206.22.212", "port": 5677, "userName": "admin", "password": "amdin1", "companyname": "测试公司" }, { "id": 13, "ip": "10.206.22.212", "port": 5676, "userName": "admin", "password": "123456", "companyname": "测试公司1" } ] }
返回结果
|状态码|状态码含义|说明|数据模型| |---|---|---|---| |200|
返回数据结构
状态码
|名称|类型|必选|约束|中文名|说明| |---|---|---|---|---|---| |» code|integer|true|none||none| |» message|null|true|none||none| |» data|[object]|true|none||none| |»» id|integer|true|none||none| |»» ip|string|true|none||none| |»» port|integer|true|none||none| |»» userName|string|true|none||none| |»» password|string|true|none||none| |»» companyname|string|true|none||none|
GET 删除配置
GET /ihd//delIhd/12
返回示例
成功
json { "code": 200, "message": "删除完成", "data": null }
返回结果
|状态码|状态码含义|说明|数据模型| |---|---|---|---| |200|
返回数据结构
状态码
|名称|类型|必选|约束|中文名|说明| |---|---|---|---|---|---| |» code|integer|true|none||none| |» message|string|true|none||none| |» data|null|true|none||none|
GET 模糊查询
GET /ihd/queryIhd
请求参数
|名称|位置|类型|必选|说明| |---|---|---|---|---| |name|query|string| 否 |none|
返回示例
成功
json { "code": 200, "message": null, "data": [ { "id": 1, "ip": "10.205.81.68", "port": 5673, "userName": "admin", "password": "admin", "companyName": "QQCT" }, { "id": 23, "ip": "10.211.178.1", "port": 5023, "userName": "root", "password": "111222", "companyName": "qqct2" } ] }
返回结果
|状态码|状态码含义|说明|数据模型| |---|---|---|---| |200|
返回数据结构
状态码
|名称|类型|必选|约束|中文名|说明| |---|---|---|---|---|---| |» code|integer|true|none||none| |» message|null|true|none||none| |» data|[object]|true|none||none| |»» id|integer|true|none||none| |»» ip|string|true|none||none| |»» port|integer|true|none||none| |»» userName|string|true|none||none| |»» password|string|true|none||none| |»» companyName|string|true|none||none|
数据模型
相关思维导图模板
树图思维导图提供 1113爆卡会总结会会议纪要 在线思维导图免费制作，点击“编辑”按钮，可对 1113爆卡会总结会会议纪要 进行在线思维导图编辑，本思维导图属于思维导图模板主题，文件编号是：aaf6c152a765d5821e8e1787f2b3226e
树图思维导图提供 埃隆·马斯克的商业版图 在线思维导图免费制作，点击“编辑”按钮，可对 埃隆·马斯克的商业版图 进行在线思维导图编辑，本思维导图属于思维导图模板主题，文件编号是：7464362ac911e8a334867bb3fc7a2346
沪公网安备 31011502019485号
上海工商