message_bus.js
7.6 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
import http from './http.js'
let baseUrl = 'message-bus-service/bus'
// let baseUrl = 'http://127.0.0.1:9030/bus'
// MQ服务器,分页查询列表
export const selectBusServerList = params =>{return http.get(`${baseUrl}/server/list`, params);};
// MQ服务器,新增
export const insertBusServer = params =>{return http.post(`${baseUrl}/server/insert`, params);};
// MQ服务器,编辑
export const updateBusServer = params =>{return http.put(`${baseUrl}/server/update`, params);};
// MQ服务器,删除
export const deleteBusServer = params =>{return http.del(`${baseUrl}/server/delete`, params);};
// MQ服务器,批量删除
export const batchRemoveBusServer = params =>{return http.get(`${baseUrl}/server/batchRemove`, params);};
// MQ虚拟主机,分页查询列表
export const selectVirtualHostList = params =>{return http.get(`${baseUrl}/host/list`, params);};
// MQ虚拟主机,新增
export const insertVirtualHost = params =>{return http.post(`${baseUrl}/host/insert`, params);};
// MQ虚拟主机,编辑
export const updateVirtualHost = params =>{return http.put(`${baseUrl}/host/update`, params);};
// MQ虚拟主机,删除
export const deleteVirtualHost = params =>{return http.del(`${baseUrl}/host/delete`, params);};
// MQ虚拟主机,批量删除
export const batchRemoveVirtualHost = params =>{return http.get(`${baseUrl}/host/batchRemove`, params);};
// MQ交换机,分页查询列表
export const selectBusExchangeList = params =>{return http.get(`${baseUrl}/exchange/list`, params);};
// MQ交换机,新增
export const insertBusExchange = params =>{return http.post(`${baseUrl}/exchange/insert`, params);};
// MQ交换机,编辑
export const updateBusExchange = params =>{return http.put(`${baseUrl}/exchange/update`, params);};
// MQ交换机,删除
export const deleteBusExchange = params =>{return http.del(`${baseUrl}/exchange/delete`, params);};
// MQ交换机,批量删除
export const batchRemoveBusExchange = params =>{return http.get(`${baseUrl}/exchange/batchRemove`, params);};
// MQ路由键,分页查询列表
export const selectRoutingKeyList = params =>{return http.get(`${baseUrl}/routing/list`, params);};
// MQ路由键,新增
export const insertRoutingKey = params =>{return http.post(`${baseUrl}/routing/insert`, params);};
// MQ路由键,编辑
export const updateRoutingKey = params =>{return http.put(`${baseUrl}/routing/update`, params);};
// MQ路由键,删除
export const deleteRoutingKey = params =>{return http.del(`${baseUrl}/routing/delete`, params);};
// MQ路由键,批量删除
export const batchRemoveRoutingKey = params =>{return http.get(`${baseUrl}/routing/batchRemove`, params);};
// MQ消息队列,分页查询列表
export const selectBusQueueList = params =>{return http.get(`${baseUrl}/queue/list`, params);};
// MQ消息队列,新增
export const insertBusQueue = params =>{return http.post(`${baseUrl}/queue/insert`, params);};
// MQ消息队列,编辑
export const updateBusQueue = params =>{return http.put(`${baseUrl}/queue/update`, params);};
// MQ消息队列,删除
export const deleteBusQueue = params =>{return http.del(`${baseUrl}/queue/delete`, params);};
// MQ消息队列,批量删除
export const batchRemoveBusQueue = params =>{return http.get(`${baseUrl}/queue/batchRemove`, params);};
// ES消息搜索引擎,分页查询列表
export const selectMessageNoteList = params =>{return http.post(`${baseUrl}/es/search/wildmsg`, params);};
// ES消息收发记录,分页查询列表
export const selectMessageSearchList = params =>{return http.post(`${baseUrl}/es/search/term`, params);};
// MQ消息收发记录,新增
export const insertMessageNote = params =>{return http.post(`${baseUrl}/note/insert`, params);};
// MQ消息收发记录,编辑
export const updateMessageNote = params =>{return http.put(`${baseUrl}/note/update`, params);};
// MQ消息收发记录,删除
export const deleteMessageNote = params =>{return http.del(`${baseUrl}/note/delete`, params);};
// MQ消息收发记录,批量删除
export const batchRemoveMessageNote = params =>{return http.get(`${baseUrl}/note/batchRemove`, params);};
// MQ账户消息绑定配置,分页查询列表
export const selectUserMessageBindingList = params =>{return http.get(`${baseUrl}/umb/list`, params);};
// MQ账户消息绑定配置,新增
export const insertUserMessageBinding = params =>{return http.post(`${baseUrl}/umb/insert`, params);};
// MQ账户消息绑定配置,编辑
export const updateUserMessageBinding = params =>{return http.put(`${baseUrl}/umb/update`, params);};
// MQ账户消息绑定配置,删除
export const deleteUserMessageBinding = params =>{return http.del(`${baseUrl}/umb/delete`, params);};
// MQ账户消息绑定配置,批量删除
export const batchRemoveUserMessageBinding = params =>{return http.get(`${baseUrl}/umb/batchRemove`, params);};
// 级联查询
export const getServerList = params =>{return http.get(`${baseUrl}/cascade/server`, params);};
export const getHostList = params =>{return http.get(`${baseUrl}/cascade/host`, params);};
export const getExchangeList = params =>{return http.get(`${baseUrl}/cascade/exchange`, params);};
export const getQueueList = params =>{return http.get(`${baseUrl}/cascade/queue`, params);};
export const getRoutingKeyList = params =>{return http.get(`${baseUrl}/cascade/routing`, params);};
export const getServerAndHostList = params =>{return http.get(`${baseUrl}/cascade/server_host`, params);};
export const getServerAndHostAndExchangeList = params =>{return http.get(`${baseUrl}/cascade/server_host_exchange`, params);};
// 定时删除,消息记录
export const getDeleteTime = params =>{return http.get(`${baseUrl}/scheduling/get`, params);};
export const setDeleteTime = params =>{return http.get(`${baseUrl}/scheduling/set`, params);};
// 用户信息,获取用户信息列表
export const getUserInfoList = params =>{return http.get(`${baseUrl}/user/userList`, params);};
export const insertUserInfo = params =>{return http.post(`${baseUrl}/user/insert`, params);};
export const updateUserInfo = params =>{return http.put(`${baseUrl}/user/update`, params);};
export const selectUserInfoList = params =>{return http.get(`${baseUrl}/user/list`, params);};
export const deleteUserInfo = params =>{return http.del(`${baseUrl}/user/delete`, params);};
export const deleteUserRelation = params =>{return http.del(`${baseUrl}/user/deleteRelation`, params);};
// export const updatePassword = params =>{return http.put(`${baseUrl}/user/updatePassword`, params);};
// 批量删除用户
export const batchDeleteUser = params =>{return http.del(`${baseUrl}/user/batch_delete`, params);};
// 批量删除用户关系
export const batchDeleteUserRelation = params =>{return http.del(`${baseUrl}/user/batch_deleteRelation`, params);};
// 监控队列
export const selectQueueViewList = params =>{return http.get(`${baseUrl}/queue/monitor`, params);};
export const selectExchangeViewList = params =>{return http.get(`${baseUrl}/view/exchange/list`, params);};
export const selectElasticSearchList = params =>{return http.get(`${baseUrl}/es/page`, params);};
export const insertElasticSearchInfo = params =>{return http.post(`${baseUrl}/es/insert`, params);};
export const updateElasticSearchInfo = params =>{return http.put(`${baseUrl}/es/update`, params);};
export const deleteElasticSearchInfo = params =>{return http.del(`${baseUrl}/es/delete`, params);};
export const batchRemoveElasticSearchInfo = params =>{return http.del(`${baseUrl}/es/batchRemove`, params);};
//数据类型管理
//不分页获取所有类型
export const getAlltype = params =>{return http.get(`${baseUrl}/message/type/list`, params);};
export const getTypesPage = params =>{return http.post(`${baseUrl}/message/type/list`, params);};