kafka数据推送思维导图

U533854447

2024-06-19

浏览量: 3

kakfa集群

QQCT

GET

系统信息

kafka数据推送内容详述

树图思维导图提供《kafka数据推送》在线思维导图免费制作，点击“编辑”按钮，可对《kafka数据推送》进行在线思维导图编辑，本思维导图属于思维导图模板主题，文件编号是：867bf5f427f17655f65025ced956e056

思维导图大纲

GET 通过公司id查找设备名称

GET /devics/getDevicsByCompanyId

请求参数

|名称|位置|类型|必选|说明| |---|---|---|---|---| |companyId|query|string| 是 |公司id|

返回示例

成功

json [ { "id": 1, "name": "sts", "companyid": 1, "companyname": "自动化码头" }, { "id": 2, "name": "agv", "companyid": 1, "companyname": "自动化码头" }, { "id": 3, "name": "asc", "companyid": 1, "companyname": "自动化码头" } ]

返回结果

|状态码|状态码含义|说明|数据模型| |---|---|---|---| |200|

返回数据结构

状态码

|名称|类型|必选|约束|中文名|说明| |---|---|---|---|---|---| |» id|integer|true|none||none| |» name|string|true|none||none| |» companyid|integer|true|none||none| |» companyname|string|true|none||none|

GET 查询所有设备

GET /devics/getAllDevices

返回示例

成功

返回结果

|状态码|状态码含义|说明|数据模型| |---|---|---|---| |200|

返回数据结构

状态码

公司表接口

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|

公司系统表

POST 添加系统

POST /comsystem/addComSys

请求参数

|名称|位置|类型|必选|说明| |---|---|---|---|---| |systemname|query|string| 是 |none| |topic|query|string| 是 |none| |companyid|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 /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

请求参数

|名称|位置|类型|必选|说明| |---|---|---|---|---| |topic|query|string| 是 |none| |id|query|string| 是 |none| |systemname|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 /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": "自动化码头1", "companyid": 1, "companyname": "自动化码头", "topic": "zdhmt1", "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||系统名称| |»» companyid|integer|true|none||公司id| |»» companyname|string|true|none||公司名称| |»» topic|string|true|none||topic| |»» status|integer|true|none||状态0禁用,1启用|

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 请求参数

请求参数

|名称|位置|类型|必选|说明| |---|---|---|---|---| |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|

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|

返回数据结构

状态码

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|

属性

|名称|类型|必选|约束|中文名|说明| |---|---|---|---|---|---| |id|integer|true|none||none| |name|string|true|none||none| |companyid|integer|true|none||none| |companyname|string|true|none||none|