liuyupeng/saas-houduan
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

权限控制增加

Browse Source 
优化ipv4、ipv6流量展示
This commit is contained in:
gaoyutao
2025-12-08 19:23:53 +08:00
parent cd8cafaf3f
commit 1f133e8c05
68 changed files with 452 additions and 611 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/InitialBandwidthTrafficController.java
+10 -11
View File
@@ -24,6 +24,7 @@ import java.util.Map;
*/
@RestController
@RequestMapping("/traffic")
@RequiresPermissions("rocketmq:traffic")
public class InitialBandwidthTrafficController extends BaseController
{
@Autowired
@@ -31,7 +32,6 @@ public class InitialBandwidthTrafficController extends BaseController
/**
* 查询初始带宽流量列表
*/
@RequiresPermissions("rocketmq:traffic:list")
@GetMapping("/list")
public TableDataInfo list(InitialBandwidthTraffic initialBandwidthTraffic)
{
@@ -43,7 +43,6 @@ public class InitialBandwidthTrafficController extends BaseController
/**
* 导出初始带宽流量列表
*/
@RequiresPermissions("rocketmq:traffic:export")
@Log(title = "初始带宽流量", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, InitialBandwidthTraffic initialBandwidthTraffic)
@@ -56,7 +55,6 @@ public class InitialBandwidthTrafficController extends BaseController
/**
* 获取初始带宽流量详细信息
*/
@RequiresPermissions("rocketmq:traffic:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -66,7 +64,6 @@ public class InitialBandwidthTrafficController extends BaseController
/**
* 新增初始带宽流量
*/
@RequiresPermissions("rocketmq:traffic:add")
@Log(title = "初始带宽流量", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody InitialBandwidthTraffic initialBandwidthTraffic)
@@ -77,7 +74,6 @@ public class InitialBandwidthTrafficController extends BaseController
/**
* 修改初始带宽流量
*/
@RequiresPermissions("rocketmq:traffic:edit")
@Log(title = "初始带宽流量", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody InitialBandwidthTraffic initialBandwidthTraffic)
@@ -88,7 +84,6 @@ public class InitialBandwidthTrafficController extends BaseController
/**
* 删除初始带宽流量
*/
@RequiresPermissions("rocketmq:traffic:remove")
@Log(title = "初始带宽流量", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
@@ -102,7 +97,6 @@ public class InitialBandwidthTrafficController extends BaseController
* @param initialBandwidthTraffic
* @return
*/
@RequiresPermissions("rocketmq:traffic:list")
@PostMapping("/netInterfaceDetailsMsg")
public AjaxResult netInterfaceDetailsMsg(@RequestBody InitialBandwidthTraffic initialBandwidthTraffic) {
InitialBandwidthTraffic netInterfaceDetailsMsg = initialBandwidthTrafficService.getNetInterfaceDetailsMsg(initialBandwidthTraffic);
@@ -112,7 +106,6 @@ public class InitialBandwidthTrafficController extends BaseController
/**
* 查询eth0流量信息并封装为多折线ECharts图表数据
*/
@RequiresPermissions("rocketmq:traffic:list")
@PostMapping("/netInterfaceTrafficEcharts")
public AjaxResult netInterfaceTrafficEcharts(@RequestBody InitialBandwidthTraffic initialBandwidthTraffic) {
Map<String, Object> echartsData = initialBandwidthTrafficService.netInterfaceTrafficEcharts(initialBandwidthTraffic);
@@ -121,7 +114,6 @@ public class InitialBandwidthTrafficController extends BaseController
/**
* 查询eth0 IPV4流量信息并封装为多折线ECharts图表数据
*/
@RequiresPermissions("rocketmq:traffic:list")
@PostMapping("/netInterfaceIpv4TrafficEcharts")
public AjaxResult netInterfaceIpv4TrafficEcharts(@RequestBody InitialBandwidthTraffic initialBandwidthTraffic) {
Map<String, Object> echartsData = initialBandwidthTrafficService.netInterfaceIpv4TrafficEcharts(initialBandwidthTraffic);
@@ -130,7 +122,6 @@ public class InitialBandwidthTrafficController extends BaseController
/**
* 查询eth0 IPV6流量信息并封装为多折线ECharts图表数据
*/
@RequiresPermissions("rocketmq:traffic:list")
@PostMapping("/netInterfaceIpv6TrafficEcharts")
public AjaxResult netInterfaceIpv6TrafficEcharts(@RequestBody InitialBandwidthTraffic initialBandwidthTraffic) {
Map<String, Object> echartsData = initialBandwidthTrafficService.netInterfaceIpv6TrafficEcharts(initialBandwidthTraffic);
@@ -142,11 +133,19 @@ public class InitialBandwidthTrafficController extends BaseController
* @param initialBandwidthTraffic
* @return
*/
@RequiresPermissions("rocketmq:traffic:list")
@PostMapping("/netInterfaceDroppedEcharts")
public AjaxResult netInterfaceDroppedEcharts(@RequestBody InitialBandwidthTraffic initialBandwidthTraffic) {
Map<String, Object> echartsData = initialBandwidthTrafficService.netInterfaceDroppedEcharts(initialBandwidthTraffic);
return success(echartsData);
}
/**
* 查询多个网卡流量信息并封装为多折线ECharts图表数据
*/
@PostMapping("/netBatchTrafficEcharts")
public AjaxResult netBatchTrafficEcharts(@RequestBody InitialBandwidthTraffic initialBandwidthTraffic) {
List<Map<String, Object>> echartsData = initialBandwidthTrafficService.netBatchTrafficEcharts(initialBandwidthTraffic);
return success(echartsData);
}
}
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/InitialBandwidthTrafficTempController.java
+10 -21
View File
@@ -1,25 +1,19 @@
package com.tongran.rocketmq.controller;
import java.util.List;
import javax.servlet.http.HttpServletResponse;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.tongran.common.core.utils.poi.ExcelUtil;
import com.tongran.common.core.web.controller.BaseController;
import com.tongran.common.core.web.domain.AjaxResult;
import com.tongran.common.core.web.page.TableDataInfo;
import com.tongran.common.log.annotation.Log;
import com.tongran.common.log.enums.BusinessType;
import com.tongran.common.security.annotation.RequiresPermissions;
import com.tongran.rocketmq.domain.InitialBandwidthTrafficTemp;
import com.tongran.rocketmq.service.IInitialBandwidthTrafficTempService;
import com.tongran.common.core.web.controller.BaseController;
import com.tongran.common.core.web.domain.AjaxResult;
import com.tongran.common.core.utils.poi.ExcelUtil;
import com.tongran.common.core.web.page.TableDataInfo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletResponse;
import java.util.List;
/**
* 初始带宽流量临时表Controller
@@ -29,6 +23,7 @@ import com.tongran.common.core.web.page.TableDataInfo;
*/
@RestController
@RequestMapping("/trafficTemp")
@RequiresPermissions("rocketmq:trafficTemp")
public class InitialBandwidthTrafficTempController extends BaseController
{
@Autowired
@@ -37,7 +32,6 @@ public class InitialBandwidthTrafficTempController extends BaseController
/**
* 查询初始带宽流量临时表列表
*/
@RequiresPermissions("rocketmq:trafficTemp:list")
@GetMapping("/list")
public TableDataInfo list(InitialBandwidthTrafficTemp initialBandwidthTrafficTemp)
{
@@ -49,7 +43,6 @@ public class InitialBandwidthTrafficTempController extends BaseController
/**
* 导出初始带宽流量临时表列表
*/
@RequiresPermissions("rocketmq:trafficTemp:export")
@Log(title = "初始带宽流量临时表", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, InitialBandwidthTrafficTemp initialBandwidthTrafficTemp)
@@ -62,7 +55,6 @@ public class InitialBandwidthTrafficTempController extends BaseController
/**
* 获取初始带宽流量临时表详细信息
*/
@RequiresPermissions("rocketmq:trafficTemp:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -72,7 +64,6 @@ public class InitialBandwidthTrafficTempController extends BaseController
/**
* 新增初始带宽流量临时表
*/
@RequiresPermissions("rocketmq:trafficTemp:add")
@Log(title = "初始带宽流量临时表", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody InitialBandwidthTrafficTemp initialBandwidthTrafficTemp)
@@ -83,7 +74,6 @@ public class InitialBandwidthTrafficTempController extends BaseController
/**
* 修改初始带宽流量临时表
*/
@RequiresPermissions("rocketmq:trafficTemp:edit")
@Log(title = "初始带宽流量临时表", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody InitialBandwidthTrafficTemp initialBandwidthTrafficTemp)
@@ -94,7 +84,6 @@ public class InitialBandwidthTrafficTempController extends BaseController
/**
* 删除初始带宽流量临时表
*/
@RequiresPermissions("rocketmq:trafficTemp:remove")
@Log(title = "初始带宽流量临时表", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/InitialCpuInfoController.java
+1 -8
View File
@@ -25,6 +25,7 @@ import java.util.Map;
*/
@RestController
@RequestMapping("/cpuInfo")
@RequiresPermissions("rocketmq:traffic")
public class InitialCpuInfoController extends BaseController
{
@Autowired
@@ -33,7 +34,6 @@ public class InitialCpuInfoController extends BaseController
/**
* 查询CPU监控信息列表
*/
@RequiresPermissions("rocketmq:cpuInfo:list")
@PostMapping("/list")
public TableDataInfo list(@RequestBody InitialCpuInfo initialCpuInfo)
{
@@ -48,7 +48,6 @@ public class InitialCpuInfoController extends BaseController
/**
* 导出CPU监控信息列表
*/
@RequiresPermissions("rocketmq:cpuInfo:export")
@Log(title = "CPU监控信息", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, InitialCpuInfo initialCpuInfo)
@@ -61,7 +60,6 @@ public class InitialCpuInfoController extends BaseController
/**
* 获取CPU监控信息详细信息
*/
@RequiresPermissions("rocketmq:cpuInfo:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -71,7 +69,6 @@ public class InitialCpuInfoController extends BaseController
/**
* 新增CPU监控信息
*/
@RequiresPermissions("rocketmq:cpuInfo:add")
@Log(title = "CPU监控信息", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody InitialCpuInfo initialCpuInfo)
@@ -82,7 +79,6 @@ public class InitialCpuInfoController extends BaseController
/**
* 修改CPU监控信息
*/
@RequiresPermissions("rocketmq:cpuInfo:edit")
@Log(title = "CPU监控信息", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody InitialCpuInfo initialCpuInfo)
@@ -93,7 +89,6 @@ public class InitialCpuInfoController extends BaseController
/**
* 删除CPU监控信息
*/
@RequiresPermissions("rocketmq:cpuInfo:remove")
@Log(title = "CPU监控信息", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
@@ -104,7 +99,6 @@ public class InitialCpuInfoController extends BaseController
/**
* 查询CPU监控信息列表并封装为多折线ECharts图表数据
*/
@RequiresPermissions("rocketmq:cpuInfo:list")
@PostMapping("/cpuLoadEcharts")
public AjaxResult cpuLoadEcharts(@RequestBody InitialCpuInfo initialCpuInfo) {
Map<String, Object> echartsData = initialCpuInfoService.cupLoadEcharts(initialCpuInfo);
@@ -113,7 +107,6 @@ public class InitialCpuInfoController extends BaseController
/**
* 查询CPU监控信息列表并封装为多折线ECharts图表数据
*/
@RequiresPermissions("rocketmq:cpuInfo:list")
@PostMapping("/cpuTimeEcharts")
public AjaxResult cpuTimeEcharts(@RequestBody InitialCpuInfo initialCpuInfo) {
Map<String, Object> echartsData = initialCpuInfoService.cpuTimeEcharts(initialCpuInfo);
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/InitialDiskInfoController.java
+1 -11
View File
@@ -25,6 +25,7 @@ import java.util.Map;
*/
@RestController
@RequestMapping("/diskInfo")
@RequiresPermissions("rocketmq:traffic")
public class InitialDiskInfoController extends BaseController
{
@Autowired
@@ -33,7 +34,6 @@ public class InitialDiskInfoController extends BaseController
/**
* 查询磁盘监控信息列表
*/
@RequiresPermissions("rocketmq:diskInfo:list")
@PostMapping("/list")
public TableDataInfo list(@RequestBody InitialDiskInfo initialDiskInfo)
{
@@ -48,7 +48,6 @@ public class InitialDiskInfoController extends BaseController
/**
* 导出磁盘监控信息列表
*/
@RequiresPermissions("rocketmq:diskInfo:export")
@Log(title = "磁盘监控信息", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, InitialDiskInfo initialDiskInfo)
@@ -61,7 +60,6 @@ public class InitialDiskInfoController extends BaseController
/**
* 获取磁盘监控信息详细信息
*/
@RequiresPermissions("rocketmq:diskInfo:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -71,7 +69,6 @@ public class InitialDiskInfoController extends BaseController
/**
* 新增磁盘监控信息
*/
@RequiresPermissions("rocketmq:diskInfo:add")
@Log(title = "磁盘监控信息", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody InitialDiskInfo initialDiskInfo)
@@ -82,7 +79,6 @@ public class InitialDiskInfoController extends BaseController
/**
* 修改磁盘监控信息
*/
@RequiresPermissions("rocketmq:diskInfo:edit")
@Log(title = "磁盘监控信息", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody InitialDiskInfo initialDiskInfo)
@@ -93,7 +89,6 @@ public class InitialDiskInfoController extends BaseController
/**
* 删除磁盘监控信息
*/
@RequiresPermissions("rocketmq:diskInfo:remove")
@Log(title = "磁盘监控信息", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
@@ -106,7 +101,6 @@ public class InitialDiskInfoController extends BaseController
* @param initialDiskInfo
* @return
*/
@RequiresPermissions("rocketmq:distInfo:list")
@PostMapping("/getDistDetailsMsg")
public AjaxResult distDetailsMsg(@RequestBody InitialDiskInfo initialDiskInfo){
return success(initialDiskInfoService.getDistDetailsMsg(initialDiskInfo));
@@ -117,7 +111,6 @@ public class InitialDiskInfoController extends BaseController
* @param initialDiskInfo
* @return
*/
@RequiresPermissions("rocketmq:distInfo:list")
@PostMapping("/rwSpeedEcharts")
public AjaxResult rwSpeedEcharts(@RequestBody InitialDiskInfo initialDiskInfo){
Map<String, Object> echartsData = initialDiskInfoService.rwSpeedEcharts(initialDiskInfo);
@@ -129,7 +122,6 @@ public class InitialDiskInfoController extends BaseController
* @param initialDiskInfo
* @return
*/
@RequiresPermissions("rocketmq:distInfo:list")
@PostMapping("/rwTimesEcharts")
public AjaxResult rwTimesEcharts(@RequestBody InitialDiskInfo initialDiskInfo){
Map<String, Object> echartsData = initialDiskInfoService.rwTimesEcharts(initialDiskInfo);
@@ -141,7 +133,6 @@ public class InitialDiskInfoController extends BaseController
* @param initialDiskInfo
* @return
*/
@RequiresPermissions("rocketmq:distInfo:list")
@PostMapping("/rwBytesEcharts")
public AjaxResult rwBytesEcharts(@RequestBody InitialDiskInfo initialDiskInfo){
Map<String, Object> echartsData = initialDiskInfoService.rwBytesEcharts(initialDiskInfo);
@@ -152,7 +143,6 @@ public class InitialDiskInfoController extends BaseController
* @param initialDiskInfo
* @return
*/
@RequiresPermissions("rocketmq:mountPointInfo:list")
@PostMapping("/getAllDistName")
public AjaxResult getAllDistName(@RequestBody InitialDiskInfo initialDiskInfo){
List<Map> list = initialDiskInfoService.getAllDistName(initialDiskInfo);
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/InitialDockerInfoController.java
+1 -11
View File
@@ -25,6 +25,7 @@ import java.util.Map;
*/
@RestController
@RequestMapping("/dockerInfo")
@RequiresPermissions("rocketmq:traffic")
public class InitialDockerInfoController extends BaseController
{
@Autowired
@@ -33,7 +34,6 @@ public class InitialDockerInfoController extends BaseController
/**
* 查询容器监控信息列表
*/
@RequiresPermissions("rocketmq:dockerInfo:list")
@PostMapping("/list")
public TableDataInfo list(@RequestBody InitialDockerInfo initialDockerInfo)
{
@@ -48,7 +48,6 @@ public class InitialDockerInfoController extends BaseController
/**
* 导出容器监控信息列表
*/
@RequiresPermissions("rocketmq:dockerInfo:export")
@Log(title = "容器监控信息", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, InitialDockerInfo initialDockerInfo)
@@ -61,7 +60,6 @@ public class InitialDockerInfoController extends BaseController
/**
* 获取容器监控信息详细信息
*/
@RequiresPermissions("rocketmq:dockerInfo:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -71,7 +69,6 @@ public class InitialDockerInfoController extends BaseController
/**
* 新增容器监控信息
*/
@RequiresPermissions("rocketmq:dockerInfo:add")
@Log(title = "容器监控信息", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody InitialDockerInfo initialDockerInfo)
@@ -82,7 +79,6 @@ public class InitialDockerInfoController extends BaseController
/**
* 修改容器监控信息
*/
@RequiresPermissions("rocketmq:dockerInfo:edit")
@Log(title = "容器监控信息", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody InitialDockerInfo initialDockerInfo)
@@ -93,7 +89,6 @@ public class InitialDockerInfoController extends BaseController
/**
* 删除容器监控信息
*/
@RequiresPermissions("rocketmq:dockerInfo:remove")
@Log(title = "容器监控信息", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
@@ -106,7 +101,6 @@ public class InitialDockerInfoController extends BaseController
* @param initialDockerInfo
* @return
*/
@RequiresPermissions("rocketmq:dockerInfo:list")
@PostMapping("/getDockerDetailsMsg")
public AjaxResult dockerDetailsMsg(@RequestBody InitialDockerInfo initialDockerInfo){
return success(initialDockerInfoService.getDockerDetailsMsg(initialDockerInfo));
@@ -117,7 +111,6 @@ public class InitialDockerInfoController extends BaseController
* @param initialDockerInfo
* @return
*/
@RequiresPermissions("rocketmq:dockerInfo:list")
@PostMapping("/cpuUtilEcharts")
public AjaxResult cpuUtilEcharts(@RequestBody InitialDockerInfo initialDockerInfo){
Map<String, Object> echartsData = initialDockerInfoService.cpuUtilEcharts(initialDockerInfo);
@@ -128,7 +121,6 @@ public class InitialDockerInfoController extends BaseController
* @param initialDockerInfo
* @return
*/
@RequiresPermissions("rocketmq:dockerInfo:list")
@PostMapping("/memUtilEcharts")
public AjaxResult memUtilEcharts(@RequestBody InitialDockerInfo initialDockerInfo){
Map<String, Object> echartsData = initialDockerInfoService.memUtilEcharts(initialDockerInfo);
@@ -140,7 +132,6 @@ public class InitialDockerInfoController extends BaseController
* @param initialDockerInfo
* @return
*/
@RequiresPermissions("rocketmq:dockerInfo:list")
@PostMapping("/netSpeedEcharts")
public AjaxResult netSpeedEcharts(@RequestBody InitialDockerInfo initialDockerInfo){
Map<String, Object> echartsData = initialDockerInfoService.netSpeedEcharts(initialDockerInfo);
@@ -151,7 +142,6 @@ public class InitialDockerInfoController extends BaseController
* @param initialDockerInfo
* @return
*/
@RequiresPermissions("rocketmq:mountPointInfo:list")
@PostMapping("/getAllDockerId")
public AjaxResult getAllDockerId(@RequestBody InitialDockerInfo initialDockerInfo){
List<Map> list = initialDockerInfoService.getAllDockerId(initialDockerInfo);
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/InitialMemoryInfoController.java
+1 -11
View File
@@ -25,6 +25,7 @@ import java.util.Map;
*/
@RestController
@RequestMapping("/memoryInfo")
@RequiresPermissions("rocketmq:traffic")
public class InitialMemoryInfoController extends BaseController
{
@Autowired
@@ -33,7 +34,6 @@ public class InitialMemoryInfoController extends BaseController
/**
* 查询内存监控信息列表
*/
@RequiresPermissions("rocketmq:memoryInfo:list")
@PostMapping("/list")
public TableDataInfo list(@RequestBody InitialMemoryInfo initialMemoryInfo)
{
@@ -48,7 +48,6 @@ public class InitialMemoryInfoController extends BaseController
/**
* 导出内存监控信息列表
*/
@RequiresPermissions("rocketmq:memoryInfo:export")
@Log(title = "内存监控信息", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, InitialMemoryInfo initialMemoryInfo)
@@ -61,7 +60,6 @@ public class InitialMemoryInfoController extends BaseController
/**
* 获取内存监控信息详细信息
*/
@RequiresPermissions("rocketmq:memoryInfo:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -71,7 +69,6 @@ public class InitialMemoryInfoController extends BaseController
/**
* 新增内存监控信息
*/
@RequiresPermissions("rocketmq:memoryInfo:add")
@Log(title = "内存监控信息", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody InitialMemoryInfo initialMemoryInfo)
@@ -82,7 +79,6 @@ public class InitialMemoryInfoController extends BaseController
/**
* 修改内存监控信息
*/
@RequiresPermissions("rocketmq:memoryInfo:edit")
@Log(title = "内存监控信息", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody InitialMemoryInfo initialMemoryInfo)
@@ -93,7 +89,6 @@ public class InitialMemoryInfoController extends BaseController
/**
* 删除内存监控信息
*/
@RequiresPermissions("rocketmq:memoryInfo:remove")
@Log(title = "内存监控信息", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
@@ -104,7 +99,6 @@ public class InitialMemoryInfoController extends BaseController
/**
* 查询交换空间可用量监控数据
*/
@RequiresPermissions("rocketmq:systemInfo:list")
@PostMapping("/swapSizeFreeEcharts")
public AjaxResult swapSizeFreeEcharts(@RequestBody InitialMemoryInfo initialMemoryInfo) {
Map<String, Object> echartsData = initialMemoryInfoService.swapSizeFreeEcharts(initialMemoryInfo);
@@ -114,7 +108,6 @@ public class InitialMemoryInfoController extends BaseController
/**
* 查询内存利用率监控数据
*/
@RequiresPermissions("rocketmq:systemInfo:list")
@PostMapping("/untilzationEcharts")
public AjaxResult untilzationEcharts(@RequestBody InitialMemoryInfo initialMemoryInfo) {
Map<String, Object> echartsData = initialMemoryInfoService.untilzationEcharts(initialMemoryInfo);
@@ -124,7 +117,6 @@ public class InitialMemoryInfoController extends BaseController
/**
* 查询内存可用量监控数据（KB）
*/
@RequiresPermissions("rocketmq:systemInfo:list")
@PostMapping("/availableMemoryEcharts")
public AjaxResult availableMemoryEcharts(@RequestBody InitialMemoryInfo initialMemoryInfo) {
Map<String, Object> echartsData = initialMemoryInfoService.availableMemoryEcharts(initialMemoryInfo);
@@ -134,7 +126,6 @@ public class InitialMemoryInfoController extends BaseController
/**
* 查询交换空间百分比监控数据
*/
@RequiresPermissions("rocketmq:systemInfo:list")
@PostMapping("/swapSizePercentEcharts")
public AjaxResult swapSizePercentEcharts(@RequestBody InitialMemoryInfo initialMemoryInfo) {
Map<String, Object> echartsData = initialMemoryInfoService.swapSizePercentEcharts(initialMemoryInfo);
@@ -144,7 +135,6 @@ public class InitialMemoryInfoController extends BaseController
/**
* 查询可用内存百分比监控数据
*/
@RequiresPermissions("rocketmq:systemInfo:list")
@PostMapping("/percentEcharts")
public AjaxResult percentEcharts(@RequestBody InitialMemoryInfo initialMemoryInfo) {
Map<String, Object> echartsData = initialMemoryInfoService.percentEcharts(initialMemoryInfo);
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/InitialMountPointInfoController.java
+1 -10
View File
@@ -25,6 +25,7 @@ import java.util.Map;
*/
@RestController
@RequestMapping("/mountPointInfo")
@RequiresPermissions("rocketmq:traffic")
public class InitialMountPointInfoController extends BaseController
{
@Autowired
@@ -33,7 +34,6 @@ public class InitialMountPointInfoController extends BaseController
/**
* 查询挂载点监控信息列表
*/
@RequiresPermissions("rocketmq:mountPointInfo:list")
@PostMapping("/list")
public TableDataInfo list(@RequestBody InitialMountPointInfo initialMountPointInfo)
{
@@ -48,7 +48,6 @@ public class InitialMountPointInfoController extends BaseController
/**
* 导出挂载点监控信息列表
*/
@RequiresPermissions("rocketmq:mountPointInfo:export")
@Log(title = "挂载点监控信息", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, InitialMountPointInfo initialMountPointInfo)
@@ -61,7 +60,6 @@ public class InitialMountPointInfoController extends BaseController
/**
* 获取挂载点监控信息详细信息
*/
@RequiresPermissions("rocketmq:mountPointInfo:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -71,7 +69,6 @@ public class InitialMountPointInfoController extends BaseController
/**
* 新增挂载点监控信息
*/
@RequiresPermissions("rocketmq:mountPointInfo:add")
@Log(title = "挂载点监控信息", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody InitialMountPointInfo initialMountPointInfo)
@@ -82,7 +79,6 @@ public class InitialMountPointInfoController extends BaseController
/**
* 修改挂载点监控信息
*/
@RequiresPermissions("rocketmq:mountPointInfo:edit")
@Log(title = "挂载点监控信息", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody InitialMountPointInfo initialMountPointInfo)
@@ -93,7 +89,6 @@ public class InitialMountPointInfoController extends BaseController
/**
* 删除挂载点监控信息
*/
@RequiresPermissions("rocketmq:mountPointInfo:remove")
@Log(title = "挂载点监控信息", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
@@ -103,7 +98,6 @@ public class InitialMountPointInfoController extends BaseController
/**
* 获取挂载点监控信息详细信息
*/
@RequiresPermissions("rocketmq:mountPointInfo:query")
@PostMapping(value = "/pointDetailsMsg")
public AjaxResult pointDetailsMsg(@RequestBody InitialMountPointInfo initialMountPointInfo)
{
@@ -113,7 +107,6 @@ public class InitialMountPointInfoController extends BaseController
/**
* 获取挂载文件系统/的空间图形
*/
@RequiresPermissions("rocketmq:mountPointInfo:query")
@PostMapping(value = "/spaceEcharts")
public AjaxResult spaceEcharts(@RequestBody InitialMountPointInfo initialMountPointInfo)
{
@@ -123,7 +116,6 @@ public class InitialMountPointInfoController extends BaseController
/**
* 获取挂载文件系统/的空间利用率图形
*/
@RequiresPermissions("rocketmq:mountPointInfo:query")
@PostMapping(value = "/spaceRateEcharts")
public AjaxResult spaceRateEcharts(@RequestBody InitialMountPointInfo initialMountPointInfo)
{
@@ -135,7 +127,6 @@ public class InitialMountPointInfoController extends BaseController
* @param initialMountPointInfo
* @return
*/
@RequiresPermissions("rocketmq:mountPointInfo:list")
@PostMapping("/getAllMountName")
public AjaxResult getAllMountName(@RequestBody InitialMountPointInfo initialMountPointInfo){
List<Map> list = initialMountPointInfoService.getAllMountName(initialMountPointInfo);
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/InitialSwitchFanInfoController.java
+1 -8
View File
@@ -24,6 +24,7 @@ import java.util.Map;
*/
@RestController
@RequestMapping("/switchFanInfo")
@RequiresPermissions("rocketmq:switchInfo")
public class InitialSwitchFanInfoController extends BaseController
{
@Autowired
@@ -32,7 +33,6 @@ public class InitialSwitchFanInfoController extends BaseController
/**
* 查询风扇信息列表
*/
@RequiresPermissions("rocketmq:info:list")
@GetMapping("/list")
public TableDataInfo list(InitialSwitchFanInfo initialSwitchFanInfo)
{
@@ -44,7 +44,6 @@ public class InitialSwitchFanInfoController extends BaseController
/**
* 导出风扇信息列表
*/
@RequiresPermissions("rocketmq:info:export")
@Log(title = "风扇信息", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, InitialSwitchFanInfo initialSwitchFanInfo)
@@ -57,7 +56,6 @@ public class InitialSwitchFanInfoController extends BaseController
/**
* 获取风扇信息详细信息
*/
@RequiresPermissions("rocketmq:info:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -67,7 +65,6 @@ public class InitialSwitchFanInfoController extends BaseController
/**
* 新增风扇信息
*/
@RequiresPermissions("rocketmq:info:add")
@Log(title = "风扇信息", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody InitialSwitchFanInfo initialSwitchFanInfo)
@@ -78,7 +75,6 @@ public class InitialSwitchFanInfoController extends BaseController
/**
* 修改风扇信息
*/
@RequiresPermissions("rocketmq:info:edit")
@Log(title = "风扇信息", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody InitialSwitchFanInfo initialSwitchFanInfo)
@@ -89,7 +85,6 @@ public class InitialSwitchFanInfoController extends BaseController
/**
* 删除风扇信息
*/
@RequiresPermissions("rocketmq:info:remove")
@Log(title = "风扇信息", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
@@ -102,7 +97,6 @@ public class InitialSwitchFanInfoController extends BaseController
* @param initialSwitchFanInfo
* @return
*/
@RequiresPermissions("rocketmq:info:list")
@PostMapping("/getAllFanName")
public AjaxResult getAllFanName(@RequestBody InitialSwitchFanInfo initialSwitchFanInfo){
List<Map> list = initialSwitchFanInfoService.getAllFanName(initialSwitchFanInfo);
@@ -113,7 +107,6 @@ public class InitialSwitchFanInfoController extends BaseController
* @param initialSwitchFanInfo
* @return
*/
@RequiresPermissions("rocketmq:info:list")
@PostMapping("/getFanMsg")
public AjaxResult getFanMsg(@RequestBody InitialSwitchFanInfo initialSwitchFanInfo){
List<InitialSwitchFanInfo> list = initialSwitchFanInfoService.getFanMsg(initialSwitchFanInfo);
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/InitialSwitchInfoController.java
+1 -11
View File
@@ -24,6 +24,7 @@ import java.util.Map;
*/
@RestController
@RequestMapping("/switchInfo")
@RequiresPermissions("rocketmq:switchInfo")
public class InitialSwitchInfoController extends BaseController
{
@Autowired
@@ -32,7 +33,6 @@ public class InitialSwitchInfoController extends BaseController
/**
* 查询交换机流量监控信息列表
*/
@RequiresPermissions("rocketmq:switchInfo:list")
@GetMapping("/list")
public TableDataInfo list(InitialSwitchInfo initialSwitchInfo)
{
@@ -44,7 +44,6 @@ public class InitialSwitchInfoController extends BaseController
/**
* 导出交换机流量监控信息列表
*/
@RequiresPermissions("rocketmq:switchInfo:export")
@Log(title = "交换机流量监控信息", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, InitialSwitchInfo initialSwitchInfo)
@@ -57,7 +56,6 @@ public class InitialSwitchInfoController extends BaseController
/**
* 获取交换机流量监控信息详细信息
*/
@RequiresPermissions("rocketmq:switchInfo:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -67,7 +65,6 @@ public class InitialSwitchInfoController extends BaseController
/**
* 新增交换机流量监控信息
*/
@RequiresPermissions("rocketmq:switchInfo:add")
@Log(title = "交换机流量监控信息", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody InitialSwitchInfo initialSwitchInfo)
@@ -78,7 +75,6 @@ public class InitialSwitchInfoController extends BaseController
/**
* 修改交换机流量监控信息
*/
@RequiresPermissions("rocketmq:switchInfo:edit")
@Log(title = "交换机流量监控信息", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody InitialSwitchInfo initialSwitchInfo)
@@ -89,7 +85,6 @@ public class InitialSwitchInfoController extends BaseController
/**
* 删除交换机流量监控信息
*/
@RequiresPermissions("rocketmq:switchInfo:remove")
@Log(title = "交换机流量监控信息", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
@@ -102,7 +97,6 @@ public class InitialSwitchInfoController extends BaseController
* @param initialSwitchInfo
* @return
*/
@RequiresPermissions("rocketmq:switchInfo:list")
@PostMapping("/getSwitchNetDetailsMsg")
public AjaxResult switchNetDetailsMsg(@RequestBody InitialSwitchInfo initialSwitchInfo){
return success(initialSwitchInfoService.getSwitchNetDetailsMsg(initialSwitchInfo));
@@ -113,7 +107,6 @@ public class InitialSwitchInfoController extends BaseController
* @param initialSwitchInfo
* @return
*/
@RequiresPermissions("rocketmq:switchInfo:list")
@PostMapping("/switchNetSpeedEcharts")
public AjaxResult switchNetSpeedEcharts(@RequestBody InitialSwitchInfo initialSwitchInfo){
Map<String, Object> echartsData = initialSwitchInfoService.switchNetSpeedEcharts(initialSwitchInfo);
@@ -124,7 +117,6 @@ public class InitialSwitchInfoController extends BaseController
* @param initialSwitchInfo
* @return
*/
@RequiresPermissions("rocketmq:switchInfo:list")
@PostMapping("/switchNetDiscardsEcharts")
public AjaxResult switchNetDiscardsEcharts(@RequestBody InitialSwitchInfo initialSwitchInfo){
Map<String, Object> echartsData = initialSwitchInfoService.switchNetDiscardsEcharts(initialSwitchInfo);
@@ -135,7 +127,6 @@ public class InitialSwitchInfoController extends BaseController
* @param initialSwitchInfo
* @return
*/
@RequiresPermissions("rocketmq:switchInfo:list")
@PostMapping("/switchNetTotalEcharts")
public AjaxResult switchNetTotalEcharts(@RequestBody InitialSwitchInfo initialSwitchInfo){
Map<String, Object> echartsData = initialSwitchInfoService.switchNetTotalEcharts(initialSwitchInfo);
@@ -146,7 +137,6 @@ public class InitialSwitchInfoController extends BaseController
* @param initialSwitchInfo
* @return
*/
@RequiresPermissions("rocketmq:switchInfo:list")
@PostMapping("/switchNetErrDiscardsEcharts")
public AjaxResult switchNetErrDiscardsEcharts(@RequestBody InitialSwitchInfo initialSwitchInfo){
Map<String, Object> echartsData = initialSwitchInfoService.switchNetErrDiscardsEcharts(initialSwitchInfo);
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/InitialSwitchInfoTempController.java
+10 -21
View File
@@ -1,25 +1,19 @@
package com.tongran.rocketmq.controller;
import java.util.List;
import javax.servlet.http.HttpServletResponse;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.tongran.common.core.utils.poi.ExcelUtil;
import com.tongran.common.core.web.controller.BaseController;
import com.tongran.common.core.web.domain.AjaxResult;
import com.tongran.common.core.web.page.TableDataInfo;
import com.tongran.common.log.annotation.Log;
import com.tongran.common.log.enums.BusinessType;
import com.tongran.common.security.annotation.RequiresPermissions;
import com.tongran.rocketmq.domain.InitialSwitchInfoTemp;
import com.tongran.rocketmq.service.IInitialSwitchInfoTempService;
import com.tongran.common.core.web.controller.BaseController;
import com.tongran.common.core.web.domain.AjaxResult;
import com.tongran.common.core.utils.poi.ExcelUtil;
import com.tongran.common.core.web.page.TableDataInfo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletResponse;
import java.util.List;
/**
* 交换机监控信息Controller
@@ -29,6 +23,7 @@ import com.tongran.common.core.web.page.TableDataInfo;
*/
@RestController
@RequestMapping("/temp")
@RequiresPermissions("rocketmq:switchInfo")
public class InitialSwitchInfoTempController extends BaseController
{
@Autowired
@@ -37,7 +32,6 @@ public class InitialSwitchInfoTempController extends BaseController
/**
* 查询交换机监控信息列表
*/
@RequiresPermissions("rocketmq:temp:list")
@GetMapping("/list")
public TableDataInfo list(InitialSwitchInfoTemp initialSwitchInfoTemp)
{
@@ -49,7 +43,6 @@ public class InitialSwitchInfoTempController extends BaseController
/**
* 导出交换机监控信息列表
*/
@RequiresPermissions("rocketmq:temp:export")
@Log(title = "交换机监控信息", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, InitialSwitchInfoTemp initialSwitchInfoTemp)
@@ -62,7 +55,6 @@ public class InitialSwitchInfoTempController extends BaseController
/**
* 获取交换机监控信息详细信息
*/
@RequiresPermissions("rocketmq:temp:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -72,7 +64,6 @@ public class InitialSwitchInfoTempController extends BaseController
/**
* 新增交换机监控信息
*/
@RequiresPermissions("rocketmq:temp:add")
@Log(title = "交换机监控信息", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody InitialSwitchInfoTemp initialSwitchInfoTemp)
@@ -83,7 +74,6 @@ public class InitialSwitchInfoTempController extends BaseController
/**
* 修改交换机监控信息
*/
@RequiresPermissions("rocketmq:temp:edit")
@Log(title = "交换机监控信息", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody InitialSwitchInfoTemp initialSwitchInfoTemp)
@@ -94,7 +84,6 @@ public class InitialSwitchInfoTempController extends BaseController
/**
* 删除交换机监控信息
*/
@RequiresPermissions("rocketmq:temp:remove")
@Log(title = "交换机监控信息", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/InitialSwitchMpuInfoController.java
+1 -11
View File
@@ -24,6 +24,7 @@ import java.util.Map;
*/
@RestController
@RequestMapping("/switchMpuInfo")
@RequiresPermissions("rocketmq:switchInfo")
public class InitialSwitchMpuInfoController extends BaseController
{
@Autowired
@@ -32,7 +33,6 @@ public class InitialSwitchMpuInfoController extends BaseController
/**
* 查询MPU信息列表
*/
@RequiresPermissions("rocketmq:info:list")
@GetMapping("/list")
public TableDataInfo list(InitialSwitchMpuInfo initialSwitchMpuInfo)
{
@@ -44,7 +44,6 @@ public class InitialSwitchMpuInfoController extends BaseController
/**
* 导出MPU信息列表
*/
@RequiresPermissions("rocketmq:info:export")
@Log(title = "MPU信息", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, InitialSwitchMpuInfo initialSwitchMpuInfo)
@@ -57,7 +56,6 @@ public class InitialSwitchMpuInfoController extends BaseController
/**
* 获取MPU信息详细信息
*/
@RequiresPermissions("rocketmq:info:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -67,7 +65,6 @@ public class InitialSwitchMpuInfoController extends BaseController
/**
* 新增MPU信息
*/
@RequiresPermissions("rocketmq:info:add")
@Log(title = "MPU信息", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody InitialSwitchMpuInfo initialSwitchMpuInfo)
@@ -78,7 +75,6 @@ public class InitialSwitchMpuInfoController extends BaseController
/**
* 修改MPU信息
*/
@RequiresPermissions("rocketmq:info:edit")
@Log(title = "MPU信息", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody InitialSwitchMpuInfo initialSwitchMpuInfo)
@@ -89,7 +85,6 @@ public class InitialSwitchMpuInfoController extends BaseController
/**
* 删除MPU信息
*/
@RequiresPermissions("rocketmq:info:remove")
@Log(title = "MPU信息", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
@@ -102,7 +97,6 @@ public class InitialSwitchMpuInfoController extends BaseController
* @param initialSwitchMpuInfo
* @return
*/
@RequiresPermissions("rocketmq:info:list")
@PostMapping("/getAllMpuName")
public AjaxResult getAllMpuName(@RequestBody InitialSwitchMpuInfo initialSwitchMpuInfo){
List<Map> list = initialSwitchMpuInfoService.getAllMpuName(initialSwitchMpuInfo);
@@ -113,7 +107,6 @@ public class InitialSwitchMpuInfoController extends BaseController
* @param initialSwitchMpuInfo
* @return
*/
@RequiresPermissions("rocketmq:info:list")
@PostMapping("/getMpuMsg")
public AjaxResult getMpuMsg(@RequestBody InitialSwitchMpuInfo initialSwitchMpuInfo){
List<InitialSwitchMpuInfo> list = initialSwitchMpuInfoService.getMpuMsg(initialSwitchMpuInfo);
@@ -124,7 +117,6 @@ public class InitialSwitchMpuInfoController extends BaseController
* @param initialSwitchMpuInfo
* @return
*/
@RequiresPermissions("rocketmq:info:list")
@PostMapping("/getMpuCpuUse")
public AjaxResult getMpuCpuUse(@RequestBody InitialSwitchMpuInfo initialSwitchMpuInfo){
Map<String, Object> echartsData = initialSwitchMpuInfoService.getMpuCpuUse(initialSwitchMpuInfo);
@@ -135,7 +127,6 @@ public class InitialSwitchMpuInfoController extends BaseController
* @param initialSwitchMpuInfo
* @return
*/
@RequiresPermissions("rocketmq:info:list")
@PostMapping("/getMpuMemUse")
public AjaxResult getMpuMemUse(@RequestBody InitialSwitchMpuInfo initialSwitchMpuInfo){
Map<String, Object> echartsData = initialSwitchMpuInfoService.getMpuMemUse(initialSwitchMpuInfo);
@@ -146,7 +137,6 @@ public class InitialSwitchMpuInfoController extends BaseController
* @param initialSwitchMpuInfo
* @return
*/
@RequiresPermissions("rocketmq:info:list")
@PostMapping("/getMpuTemperature")
public AjaxResult getMpuTemperature(@RequestBody InitialSwitchMpuInfo initialSwitchMpuInfo){
Map<String, Object> echartsData = initialSwitchMpuInfoService.getMpuTemperature(initialSwitchMpuInfo);
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/InitialSwitchOpticalModuleController.java
+1 -10
View File
@@ -24,6 +24,7 @@ import java.util.Map;
*/
@RestController
@RequestMapping("/switchOpticalModule")
@RequiresPermissions("rocketmq:switchInfo")
public class InitialSwitchOpticalModuleController extends BaseController
{
@Autowired
@@ -32,7 +33,6 @@ public class InitialSwitchOpticalModuleController extends BaseController
/**
* 查询光模块信息列表
*/
@RequiresPermissions("rocketmq:module:list")
@GetMapping("/list")
public TableDataInfo list(InitialSwitchOpticalModule initialSwitchOpticalModule)
{
@@ -44,7 +44,6 @@ public class InitialSwitchOpticalModuleController extends BaseController
/**
* 导出光模块信息列表
*/
@RequiresPermissions("rocketmq:module:export")
@Log(title = "光模块信息", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, InitialSwitchOpticalModule initialSwitchOpticalModule)
@@ -57,7 +56,6 @@ public class InitialSwitchOpticalModuleController extends BaseController
/**
* 获取光模块信息详细信息
*/
@RequiresPermissions("rocketmq:module:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -67,7 +65,6 @@ public class InitialSwitchOpticalModuleController extends BaseController
/**
* 新增光模块信息
*/
@RequiresPermissions("rocketmq:module:add")
@Log(title = "光模块信息", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody InitialSwitchOpticalModule initialSwitchOpticalModule)
@@ -78,7 +75,6 @@ public class InitialSwitchOpticalModuleController extends BaseController
/**
* 修改光模块信息
*/
@RequiresPermissions("rocketmq:module:edit")
@Log(title = "光模块信息", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody InitialSwitchOpticalModule initialSwitchOpticalModule)
@@ -89,7 +85,6 @@ public class InitialSwitchOpticalModuleController extends BaseController
/**
* 删除光模块信息
*/
@RequiresPermissions("rocketmq:module:remove")
@Log(title = "光模块信息", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
@@ -101,7 +96,6 @@ public class InitialSwitchOpticalModuleController extends BaseController
* 获取该交换机的所有光模块名称
* @return
*/
@RequiresPermissions("rocketmq:module:list")
@PostMapping("/getAllModuleName")
public AjaxResult getAllModuleName(@RequestBody InitialSwitchOpticalModule initialSwitchOpticalModule){
List<Map> list = initialSwitchOpticalModuleService.getAllModuleName(initialSwitchOpticalModule);
@@ -112,7 +106,6 @@ public class InitialSwitchOpticalModuleController extends BaseController
* @param initialSwitchOpticalModule
* @return
*/
@RequiresPermissions("rocketmq:module:list")
@PostMapping("/switchOpticalModuleMsg")
public AjaxResult switchOpticalModuleMsg(@RequestBody InitialSwitchOpticalModule initialSwitchOpticalModule){
@@ -124,7 +117,6 @@ public class InitialSwitchOpticalModuleController extends BaseController
* @param initialSwitchOpticalModule
* @return
*/
@RequiresPermissions("rocketmq:module:list")
@PostMapping("/opticalModuleLowThreshold")
public AjaxResult opticalModuleLowThreshold(@RequestBody InitialSwitchOpticalModule initialSwitchOpticalModule){
Map<String, Object> echartsData = initialSwitchOpticalModuleService.opticalModuleLowThreshold(initialSwitchOpticalModule);
@@ -135,7 +127,6 @@ public class InitialSwitchOpticalModuleController extends BaseController
* @param initialSwitchOpticalModule
* @return
*/
@RequiresPermissions("rocketmq:module:list")
@PostMapping("/opticalModulePower")
public AjaxResult opticalModulePower(@RequestBody InitialSwitchOpticalModule initialSwitchOpticalModule){
Map<String, Object> echartsData = initialSwitchOpticalModuleService.opticalModulePower(initialSwitchOpticalModule);
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/InitialSwitchOtherCollectDataController.java
+1 -10
View File
@@ -24,6 +24,7 @@ import java.util.Map;
*/
@RestController
@RequestMapping("/switchOtherData")
@RequiresPermissions("rocketmq:switchInfo")
public class InitialSwitchOtherCollectDataController extends BaseController
{
@Autowired
@@ -32,7 +33,6 @@ public class InitialSwitchOtherCollectDataController extends BaseController
/**
* 查询交换机系统其他信息采集数据列表
*/
@RequiresPermissions("rocketmq:switchOtherData:list")
@GetMapping("/list")
public TableDataInfo list(InitialSwitchOtherCollectData initialSwitchOtherCollectData)
{
@@ -44,7 +44,6 @@ public class InitialSwitchOtherCollectDataController extends BaseController
/**
* 导出交换机系统其他信息采集数据列表
*/
@RequiresPermissions("rocketmq:switchOtherData:export")
@Log(title = "交换机系统其他信息采集数据", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, InitialSwitchOtherCollectData initialSwitchOtherCollectData)
@@ -57,7 +56,6 @@ public class InitialSwitchOtherCollectDataController extends BaseController
/**
* 获取交换机系统其他信息采集数据详细信息
*/
@RequiresPermissions("rocketmq:switchOtherData:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -67,7 +65,6 @@ public class InitialSwitchOtherCollectDataController extends BaseController
/**
* 新增交换机系统其他信息采集数据
*/
@RequiresPermissions("rocketmq:switchOtherData:add")
@Log(title = "交换机系统其他信息采集数据", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody InitialSwitchOtherCollectData initialSwitchOtherCollectData)
@@ -78,7 +75,6 @@ public class InitialSwitchOtherCollectDataController extends BaseController
/**
* 修改交换机系统其他信息采集数据
*/
@RequiresPermissions("rocketmq:switchOtherData:edit")
@Log(title = "交换机系统其他信息采集数据", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody InitialSwitchOtherCollectData initialSwitchOtherCollectData)
@@ -89,7 +85,6 @@ public class InitialSwitchOtherCollectDataController extends BaseController
/**
* 删除交换机系统其他信息采集数据
*/
@RequiresPermissions("rocketmq:switchOtherData:remove")
@Log(title = "交换机系统其他信息采集数据", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
@@ -99,7 +94,6 @@ public class InitialSwitchOtherCollectDataController extends BaseController
/**
* 图形监控交换机监控项基础信息
*/
@RequiresPermissions("rocketmq:switchOtherData:list")
@PostMapping("/getSwitchMonitorMsg")
public AjaxResult getSwitchMonitorMsg(@RequestBody InitialSwitchOtherCollectData initialSwitchOtherCollectData)
{
@@ -109,7 +103,6 @@ public class InitialSwitchOtherCollectDataController extends BaseController
/**
* 图形监控交换机设备CPU使用率
*/
@RequiresPermissions("rocketmq:switchOtherData:list")
@PostMapping("/getSwitchCpuUseMsg")
public AjaxResult getSwitchCpuUseMsg(@RequestBody InitialSwitchOtherCollectData initialSwitchOtherCollectData)
{
@@ -119,7 +112,6 @@ public class InitialSwitchOtherCollectDataController extends BaseController
/**
* 图形监控交换机设备内存利用率
*/
@RequiresPermissions("rocketmq:switchOtherData:list")
@PostMapping("/getSwitchMemUseMsg")
public AjaxResult getSwitchMemUseMsg(@RequestBody InitialSwitchOtherCollectData initialSwitchOtherCollectData)
{
@@ -129,7 +121,6 @@ public class InitialSwitchOtherCollectDataController extends BaseController
/**
* 图形监控交换机设备系统功率
*/
@RequiresPermissions("rocketmq:switchOtherData:list")
@PostMapping("/getSwitchPowerMsg")
public AjaxResult getSwitchPowerMsg(@RequestBody InitialSwitchOtherCollectData initialSwitchOtherCollectData)
{
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/InitialSwitchPowerSupplyController.java
+1 -10
View File
@@ -24,6 +24,7 @@ import java.util.Map;
*/
@RestController
@RequestMapping("/switchPowerSupply")
@RequiresPermissions("rocketmq:switchInfo")
public class InitialSwitchPowerSupplyController extends BaseController
{
@Autowired
@@ -32,7 +33,6 @@ public class InitialSwitchPowerSupplyController extends BaseController
/**
* 查询电源信息列表
*/
@RequiresPermissions("rocketmq:supply:list")
@GetMapping("/list")
public TableDataInfo list(InitialSwitchPowerSupply initialSwitchPowerSupply)
{
@@ -44,7 +44,6 @@ public class InitialSwitchPowerSupplyController extends BaseController
/**
* 导出电源信息列表
*/
@RequiresPermissions("rocketmq:supply:export")
@Log(title = "电源信息", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, InitialSwitchPowerSupply initialSwitchPowerSupply)
@@ -57,7 +56,6 @@ public class InitialSwitchPowerSupplyController extends BaseController
/**
* 获取电源信息详细信息
*/
@RequiresPermissions("rocketmq:supply:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -67,7 +65,6 @@ public class InitialSwitchPowerSupplyController extends BaseController
/**
* 新增电源信息
*/
@RequiresPermissions("rocketmq:supply:add")
@Log(title = "电源信息", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody InitialSwitchPowerSupply initialSwitchPowerSupply)
@@ -78,7 +75,6 @@ public class InitialSwitchPowerSupplyController extends BaseController
/**
* 修改电源信息
*/
@RequiresPermissions("rocketmq:supply:edit")
@Log(title = "电源信息", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody InitialSwitchPowerSupply initialSwitchPowerSupply)
@@ -89,7 +85,6 @@ public class InitialSwitchPowerSupplyController extends BaseController
/**
* 删除电源信息
*/
@RequiresPermissions("rocketmq:supply:remove")
@Log(title = "电源信息", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
@@ -101,7 +96,6 @@ public class InitialSwitchPowerSupplyController extends BaseController
* @param initialSwitchPowerSupply
* @return
*/
@RequiresPermissions("rocketmq:supply:list")
@PostMapping("/getAllPwrName")
public AjaxResult getAllPwrName(@RequestBody InitialSwitchPowerSupply initialSwitchPowerSupply){
List<Map> list = initialSwitchPowerSupplyService.getAllPwrName(initialSwitchPowerSupply);
@@ -112,7 +106,6 @@ public class InitialSwitchPowerSupplyController extends BaseController
* @param initialSwitchPowerSupply
* @return
*/
@RequiresPermissions("rocketmq:supply:list")
@PostMapping("/getPwrMsg")
public AjaxResult getPwrMsg(@RequestBody InitialSwitchPowerSupply initialSwitchPowerSupply){
List<Map> list = initialSwitchPowerSupplyService.getPwrMsg(initialSwitchPowerSupply);
@@ -123,7 +116,6 @@ public class InitialSwitchPowerSupplyController extends BaseController
* @param initialSwitchPowerSupply
* @return
*/
@RequiresPermissions("rocketmq:supply:list")
@PostMapping("/getPwrCurrent")
public AjaxResult getPwrCurrent(@RequestBody InitialSwitchPowerSupply initialSwitchPowerSupply){
Map<String, Object> echartsData = initialSwitchPowerSupplyService.getPwrCurrent(initialSwitchPowerSupply);
@@ -134,7 +126,6 @@ public class InitialSwitchPowerSupplyController extends BaseController
* @param initialSwitchPowerSupply
* @return
*/
@RequiresPermissions("rocketmq:supply:list")
@PostMapping("/getPwrVoltage")
public AjaxResult getPwrVoltage(@RequestBody InitialSwitchPowerSupply initialSwitchPowerSupply){
Map<String, Object> echartsData = initialSwitchPowerSupplyService.getPwrVoltage(initialSwitchPowerSupply);
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/InitialSystemInfoController.java
+1 -9
View File
@@ -26,6 +26,7 @@ import java.util.Map;
*/
@RestController
@RequestMapping("/systemInfo")
@RequiresPermissions("rocketmq:traffic")
public class InitialSystemInfoController extends BaseController
{
@Autowired
@@ -34,7 +35,6 @@ public class InitialSystemInfoController extends BaseController
/**
* 查询系统监控信息列表
*/
@RequiresPermissions("rocketmq:systemInfo:list")
@PostMapping("/list")
public TableDataInfo list(@RequestBody InitialSystemInfo initialSystemInfo)
{
@@ -49,7 +49,6 @@ public class InitialSystemInfoController extends BaseController
/**
* 导出系统监控信息列表
*/
@RequiresPermissions("rocketmq:systemInfo:export")
@Log(title = "系统监控信息", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, InitialSystemInfo initialSystemInfo)
@@ -62,7 +61,6 @@ public class InitialSystemInfoController extends BaseController
/**
* 获取系统监控信息详细信息
*/
@RequiresPermissions("rocketmq:systemInfo:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -72,7 +70,6 @@ public class InitialSystemInfoController extends BaseController
/**
* 新增系统监控信息
*/
@RequiresPermissions("rocketmq:systemInfo:add")
@Log(title = "系统监控信息", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody InitialSystemInfo initialSystemInfo)
@@ -83,7 +80,6 @@ public class InitialSystemInfoController extends BaseController
/**
* 修改系统监控信息
*/
@RequiresPermissions("rocketmq:systemInfo:edit")
@Log(title = "系统监控信息", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody InitialSystemInfo initialSystemInfo)
@@ -94,7 +90,6 @@ public class InitialSystemInfoController extends BaseController
/**
* 删除系统监控信息
*/
@RequiresPermissions("rocketmq:systemInfo:remove")
@Log(title = "系统监控信息", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
@@ -106,7 +101,6 @@ public class InitialSystemInfoController extends BaseController
* @param initialSystemInfo
* @return
*/
@RequiresPermissions("rocketmq:systemInfo:list")
@PostMapping("/systemProcessEcharts")
public AjaxResult systemProcessEcharts(@RequestBody InitialSystemInfo initialSystemInfo) {
Map<String, Object> echartsData = initialSystemInfoService.systemProcessEcharts(initialSystemInfo);
@@ -117,7 +111,6 @@ public class InitialSystemInfoController extends BaseController
* @param initialSystemInfo
* @return
*/
@RequiresPermissions("rocketmq:systemInfo:list")
@PostMapping("/systemUserNumEcharts")
public AjaxResult systemUserNumEcharts(@RequestBody InitialSystemInfo initialSystemInfo) {
Map<String, Object> echartsData = initialSystemInfoService.systemUserNumEcharts(initialSystemInfo);
@@ -129,7 +122,6 @@ public class InitialSystemInfoController extends BaseController
* @param initialSystemInfo
* @return
*/
@RequiresPermissions("rocketmq:systemInfo:list")
@PostMapping("/systemDetailsMsg")
public AjaxResult systemDetailsMsg(@RequestBody InitialSystemInfo initialSystemInfo) {
SystemMsgVo systemDetailsMsg = initialSystemInfoService.getSystemDetailsMsg(initialSystemInfo);
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/InitialSystemOtherCollectDataController.java
+1 -14
View File
@@ -24,6 +24,7 @@ import java.util.Map;
*/
@RestController
@RequestMapping("/systemOtherCollectData")
@RequiresPermissions("rocketmq:traffic")
public class InitialSystemOtherCollectDataController extends BaseController
{
@Autowired
@@ -32,7 +33,6 @@ public class InitialSystemOtherCollectDataController extends BaseController
/**
* 查询交换机系统其他信息采集数据列表
*/
@RequiresPermissions("rocketmq:systemOtherCollectData:list")
@GetMapping("/list")
public TableDataInfo list(InitialSystemOtherCollectData initialSystemOtherCollectData)
{
@@ -44,7 +44,6 @@ public class InitialSystemOtherCollectDataController extends BaseController
/**
* 导出交换机系统其他信息采集数据列表
*/
@RequiresPermissions("rocketmq:systemOtherCollectData:export")
@Log(title = "交换机系统其他信息采集数据", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, InitialSystemOtherCollectData initialSystemOtherCollectData)
@@ -57,7 +56,6 @@ public class InitialSystemOtherCollectDataController extends BaseController
/**
* 获取交换机系统其他信息采集数据详细信息
*/
@RequiresPermissions("rocketmq:systemOtherCollectData:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -67,7 +65,6 @@ public class InitialSystemOtherCollectDataController extends BaseController
/**
* 新增交换机系统其他信息采集数据
*/
@RequiresPermissions("rocketmq:systemOtherCollectData:add")
@Log(title = "交换机系统其他信息采集数据", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody InitialSystemOtherCollectData initialSystemOtherCollectData)
@@ -78,7 +75,6 @@ public class InitialSystemOtherCollectDataController extends BaseController
/**
* 修改交换机系统其他信息采集数据
*/
@RequiresPermissions("rocketmq:systemOtherCollectData:edit")
@Log(title = "交换机系统其他信息采集数据", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody InitialSystemOtherCollectData initialSystemOtherCollectData)
@@ -89,7 +85,6 @@ public class InitialSystemOtherCollectDataController extends BaseController
/**
* 删除交换机系统其他信息采集数据
*/
@RequiresPermissions("rocketmq:systemOtherCollectData:remove")
@Log(title = "交换机系统其他信息采集数据", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
@@ -99,7 +94,6 @@ public class InitialSystemOtherCollectDataController extends BaseController
/**
* 查询系统其他信息基础数据
*/
@RequiresPermissions("rocketmq:systemOtherCollectData:list")
@PostMapping("/getMontiorMsg")
public AjaxResult getMontiorMsg(@RequestBody InitialSystemOtherCollectData initialSystemOtherCollectData)
{
@@ -111,7 +105,6 @@ public class InitialSystemOtherCollectDataController extends BaseController
* @param initialSystemOtherCollectData
* @return
*/
@RequiresPermissions("rocketmq:systemOtherCollectData:list")
@PostMapping("/systemUserNumEcharts")
public AjaxResult systemUserNumEcharts(@RequestBody InitialSystemOtherCollectData initialSystemOtherCollectData) {
Map<String, Object> echartsData = initialSystemOtherCollectDataService.systemUserNumEcharts(initialSystemOtherCollectData);
@@ -120,7 +113,6 @@ public class InitialSystemOtherCollectDataController extends BaseController
/**
* 查询交换卷文件的可用空间监控信息列表并封装为多折线ECharts图表数据
*/
@RequiresPermissions("rocketmq:systemOtherCollectData:list")
@PostMapping("/systemSwapSizeFreeEcharts")
public AjaxResult systemSwapSizeFreeEcharts(@RequestBody InitialSystemOtherCollectData initialSystemOtherCollectData) {
Map<String, Object> echartsData = initialSystemOtherCollectDataService.systemSwapSizeFreeEcharts(initialSystemOtherCollectData);
@@ -130,7 +122,6 @@ public class InitialSystemOtherCollectDataController extends BaseController
/**
* 查询内存利用率监控信息列表并封装为多折线ECharts图表数据
*/
@RequiresPermissions("rocketmq:systemOtherCollectData:list")
@PostMapping("/memoryUtilizationEcharts")
public AjaxResult memoryUtilizationEcharts(@RequestBody InitialSystemOtherCollectData initialSystemOtherCollectData) {
Map<String, Object> echartsData = initialSystemOtherCollectDataService.memoryUtilizationEcharts(initialSystemOtherCollectData);
@@ -140,7 +131,6 @@ public class InitialSystemOtherCollectDataController extends BaseController
/**
* 查询可用交换空间百分比监控信息列表并封装为多折线ECharts图表数据
*/
@RequiresPermissions("rocketmq:systemOtherCollectData:list")
@PostMapping("/systemSwapSizePercentEcharts")
public AjaxResult systemSwapSizePercentEcharts(@RequestBody InitialSystemOtherCollectData initialSystemOtherCollectData) {
Map<String, Object> echartsData = initialSystemOtherCollectDataService.systemSwapSizePercentEcharts(initialSystemOtherCollectData);
@@ -150,7 +140,6 @@ public class InitialSystemOtherCollectDataController extends BaseController
/**
* 查询可用内存监控信息列表并封装为多折线ECharts图表数据
*/
@RequiresPermissions("rocketmq:systemOtherCollectData:list")
@PostMapping("/memorySizeAvailableEcharts")
public AjaxResult memorySizeAvailableEcharts(@RequestBody InitialSystemOtherCollectData initialSystemOtherCollectData) {
Map<String, Object> echartsData = initialSystemOtherCollectDataService.memorySizeAvailableEcharts(initialSystemOtherCollectData);
@@ -160,7 +149,6 @@ public class InitialSystemOtherCollectDataController extends BaseController
/**
* 查询可用内存百分比监控信息列表并封装为多折线ECharts图表数据
*/
@RequiresPermissions("rocketmq:systemOtherCollectData:list")
@PostMapping("/memorySizePercentEcharts")
public AjaxResult memorySizePercentEcharts(@RequestBody InitialSystemOtherCollectData initialSystemOtherCollectData) {
Map<String, Object> echartsData = initialSystemOtherCollectDataService.memorySizePercentEcharts(initialSystemOtherCollectData);
@@ -171,7 +159,6 @@ public class InitialSystemOtherCollectDataController extends BaseController
/**
* 查询进程数监控信息列表并封装为多折线ECharts图表数据
*/
@RequiresPermissions("rocketmq:systemOtherCollectData:list")
@PostMapping("/procNumEcharts")
public AjaxResult procNumEcharts(@RequestBody InitialSystemOtherCollectData initialSystemOtherCollectData) {
Map<String, Object> echartsData = initialSystemOtherCollectDataService.procNumEcharts(initialSystemOtherCollectData);
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/RmAgentManagementController.java
+1 -6
View File
@@ -22,6 +22,7 @@ import java.util.List;
*/
@RestController
@RequestMapping("/agentManagement")
@RequiresPermissions("rocketmq:management")
public class RmAgentManagementController extends BaseController
{
@Autowired
@@ -30,7 +31,6 @@ public class RmAgentManagementController extends BaseController
/**
* 查询Agent管理列表
*/
@RequiresPermissions("rocketmq:management:list")
@PostMapping("/list")
public TableDataInfo list(@RequestBody RmAgentManagement rmAgentManagement)
{
@@ -45,7 +45,6 @@ public class RmAgentManagementController extends BaseController
/**
* 获取Agent管理详细信息
*/
@RequiresPermissions("rocketmq:management:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -55,7 +54,6 @@ public class RmAgentManagementController extends BaseController
/**
* 新增Agent管理
*/
@RequiresPermissions("rocketmq:management:add")
@Log(title = "Agent管理", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody RmAgentManagement rmAgentManagement)
@@ -66,7 +64,6 @@ public class RmAgentManagementController extends BaseController
/**
* 修改Agent管理
*/
@RequiresPermissions("rocketmq:management:edit")
@Log(title = "Agent管理", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody RmAgentManagement rmAgentManagement)
@@ -79,7 +76,6 @@ public class RmAgentManagementController extends BaseController
* @param rmAgentManagement
* @return
*/
@RequiresPermissions("rocketmq:management:edit")
@PostMapping("/updateAgentNow")
public AjaxResult updateAgentNow(@RequestBody RmAgentManagement rmAgentManagement){
rmAgentManagementService.updateAgentNow(rmAgentManagement);
@@ -89,7 +85,6 @@ public class RmAgentManagementController extends BaseController
/**
* 配置更新策略
*/
@RequiresPermissions("rocketmq:management:add")
@Log(title = "Agent管理", businessType = BusinessType.INSERT)
@PostMapping("/addUpdatePolicy")
public AjaxResult addUpdatePolicy(@RequestBody RmAgentManagement rmAgentManagement)
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/RmAlarmLogController.java
+1 -6
View File
@@ -24,6 +24,7 @@ import java.util.List;
*/
@RestController
@RequestMapping("/alarmLog")
@RequiresPermissions("rocketmq:alarmLog")
public class RmAlarmLogController extends BaseController
{
@Autowired
@@ -32,7 +33,6 @@ public class RmAlarmLogController extends BaseController
/**
* 查询客户端告警信息列表
*/
@RequiresPermissions("rocketmq:alarmLog:list")
@PostMapping("/list")
public TableDataInfo list(@RequestBody RmAlarmLog rmAlarmLog)
{
@@ -47,7 +47,6 @@ public class RmAlarmLogController extends BaseController
/**
* 导出客户端告警信息列表
*/
@RequiresPermissions("rocketmq:alarmLog:export")
@Log(title = "客户端告警信息", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, RmAlarmLog rmAlarmLog)
@@ -61,7 +60,6 @@ public class RmAlarmLogController extends BaseController
/**
* 获取客户端告警信息详细信息
*/
@RequiresPermissions("rocketmq:alarmLog:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -71,7 +69,6 @@ public class RmAlarmLogController extends BaseController
/**
* 新增客户端告警信息
*/
@RequiresPermissions("rocketmq:alarmLog:add")
@Log(title = "客户端告警信息", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody RmAlarmLog rmAlarmLog)
@@ -82,7 +79,6 @@ public class RmAlarmLogController extends BaseController
/**
* 修改客户端告警信息
*/
@RequiresPermissions("rocketmq:alarmLog:edit")
@Log(title = "客户端告警信息", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody RmAlarmLog rmAlarmLog)
@@ -93,7 +89,6 @@ public class RmAlarmLogController extends BaseController
/**
* 删除客户端告警信息
*/
@RequiresPermissions("rocketmq:alarmLog:remove")
@Log(title = "客户端告警信息", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/RmAlarmPushConfigController.java
+1 -6
View File
@@ -24,6 +24,7 @@ import java.util.List;
*/
@RestController
@RequestMapping("/alarmPushConfig")
@RequiresPermissions("rocketmq:alarmPushConfig")
public class RmAlarmPushConfigController extends BaseController
{
@Autowired
@@ -32,7 +33,6 @@ public class RmAlarmPushConfigController extends BaseController
/**
* 查询告警推送配置列表
*/
@RequiresPermissions("rocketmq:alarmPushConfig:list")
@PostMapping("/list")
public TableDataInfo list(@RequestBody RmAlarmPushConfig rmAlarmPushConfig)
{
@@ -47,7 +47,6 @@ public class RmAlarmPushConfigController extends BaseController
/**
* 导出告警推送配置列表
*/
@RequiresPermissions("rocketmq:alarmPushConfig:export")
@Log(title = "告警推送配置", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, RmAlarmPushConfig rmAlarmPushConfig)
@@ -61,7 +60,6 @@ public class RmAlarmPushConfigController extends BaseController
/**
* 获取告警推送配置详细信息
*/
@RequiresPermissions("rocketmq:alarmPushConfig:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -71,7 +69,6 @@ public class RmAlarmPushConfigController extends BaseController
/**
* 新增告警推送配置
*/
@RequiresPermissions("rocketmq:alarmPushConfig:add")
@Log(title = "告警推送配置", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody RmAlarmPushConfig rmAlarmPushConfig)
@@ -82,7 +79,6 @@ public class RmAlarmPushConfigController extends BaseController
/**
* 修改告警推送配置
*/
@RequiresPermissions("rocketmq:alarmPushConfig:edit")
@Log(title = "告警推送配置", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody RmAlarmPushConfig rmAlarmPushConfig)
@@ -93,7 +89,6 @@ public class RmAlarmPushConfigController extends BaseController
/**
* 删除告警推送配置
*/
@RequiresPermissions("rocketmq:alarmPushConfig:remove")
@Log(title = "告警推送配置", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/RmDeploymentPolicyController.java
+1 -7
View File
@@ -26,6 +26,7 @@ import java.util.List;
*/
@RestController
@RequestMapping("/policy")
@RequiresPermissions("rocketmq:policy")
public class RmDeploymentPolicyController extends BaseController
{
@Autowired
@@ -34,7 +35,6 @@ public class RmDeploymentPolicyController extends BaseController
/**
* 查询服务器脚本策略列表
*/
@RequiresPermissions("rocketmq:policy:list")
@PostMapping("/list")
public TableDataInfo list(@RequestBody RmDeploymentPolicy rmDeploymentPolicy)
{
@@ -49,7 +49,6 @@ public class RmDeploymentPolicyController extends BaseController
/**
* 导出服务器脚本策略列表
*/
@RequiresPermissions("rocketmq:policy:export")
@Log(title = "服务器脚本策略", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, @RequestBody RmDeploymentPolicy rmDeploymentPolicy)
@@ -63,7 +62,6 @@ public class RmDeploymentPolicyController extends BaseController
/**
* 获取服务器脚本策略详细信息
*/
@RequiresPermissions("rocketmq:policy:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -73,7 +71,6 @@ public class RmDeploymentPolicyController extends BaseController
/**
* 新增服务器脚本策略
*/
@RequiresPermissions("rocketmq:policy:add")
@Log(title = "服务器脚本策略", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody RmDeploymentPolicy rmDeploymentPolicy)
@@ -84,7 +81,6 @@ public class RmDeploymentPolicyController extends BaseController
/**
* 修改服务器脚本策略
*/
@RequiresPermissions("rocketmq:policy:edit")
@Log(title = "服务器脚本策略", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody RmDeploymentPolicy rmDeploymentPolicy)
@@ -95,7 +91,6 @@ public class RmDeploymentPolicyController extends BaseController
/**
* 删除服务器脚本策略
*/
@RequiresPermissions("rocketmq:policy:remove")
@Log(title = "服务器脚本策略", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
@@ -106,7 +101,6 @@ public class RmDeploymentPolicyController extends BaseController
/**
* 下发服务器脚本策略
*/
@RequiresPermissions("rocketmq:policy:list")
@GetMapping(value = "/issueDeploymentPolicy")
public AjaxResult issueDeploymentPolicy(Long id)
{
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/RmInitialMonitorItemController.java
-2
View File
@@ -2,7 +2,6 @@ package com.tongran.rocketmq.controller;
import com.tongran.common.core.web.controller.BaseController;
import com.tongran.common.core.web.domain.AjaxResult;
import com.tongran.common.security.annotation.RequiresPermissions;
import com.tongran.rocketmq.domain.RmInitialMonitorItem;
import com.tongran.rocketmq.service.IRmInitialMonitorItemService;
import org.springframework.beans.factory.annotation.Autowired;
@@ -30,7 +29,6 @@ public class RmInitialMonitorItemController extends BaseController
/**
* 查询监控项列表
*/
@RequiresPermissions("rocketmq:item:list")
@PostMapping("/list")
public AjaxResult list(@RequestBody RmInitialMonitorItem rmInitialMonitorItem)
{
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/RmMonitorPolicyController.java
+1 -10
View File
@@ -26,6 +26,7 @@ import java.util.List;
*/
@RestController
@RequestMapping("/monitorPolicy")
@RequiresPermissions("rocketmq:monitorPolicy")
public class RmMonitorPolicyController extends BaseController
{
@Autowired
@@ -34,7 +35,6 @@ public class RmMonitorPolicyController extends BaseController
/**
* 查询资源监控策略列表
*/
@RequiresPermissions("rocketmq:policy:list")
@PostMapping("/list")
public TableDataInfo list(@RequestBody RmMonitorPolicy rmMonitorPolicy)
{
@@ -49,7 +49,6 @@ public class RmMonitorPolicyController extends BaseController
/**
* 导出资源监控策略列表
*/
@RequiresPermissions("rocketmq:policy:export")
@Log(title = "资源监控策略", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, @RequestBody RmMonitorPolicy rmMonitorPolicy)
@@ -63,7 +62,6 @@ public class RmMonitorPolicyController extends BaseController
/**
* 获取资源监控策略详细信息
*/
@RequiresPermissions("rocketmq:policy:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -73,7 +71,6 @@ public class RmMonitorPolicyController extends BaseController
/**
* 新增资源监控策略
*/
@RequiresPermissions("rocketmq:policy:add")
@Log(title = "资源监控策略", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody RmMonitorPolicy rmMonitorPolicy)
@@ -88,7 +85,6 @@ public class RmMonitorPolicyController extends BaseController
/**
* 修改资源监控策略
*/
@RequiresPermissions("rocketmq:policy:edit")
@Log(title = "资源监控策略", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody RmMonitorPolicy rmMonitorPolicy)
@@ -102,7 +98,6 @@ public class RmMonitorPolicyController extends BaseController
/**
* 资源监控策略下发
*/
@RequiresPermissions("rocketmq:policy:edit")
@Log(title = "资源监控策略下发", businessType = BusinessType.UPDATE)
@GetMapping("/issuePolicy")
public AjaxResult issuePolicy(Long id)
@@ -112,7 +107,6 @@ public class RmMonitorPolicyController extends BaseController
/**
* 资源监控策略下发
*/
// @RequiresPermissions("rocketmq:policy:edit")
@Log(title = "issueSwitchPolicy", businessType = BusinessType.UPDATE)
@GetMapping("/issueSwitchPolicy")
public AjaxResult issueSwitchPolicy(Long id)
@@ -123,7 +117,6 @@ public class RmMonitorPolicyController extends BaseController
/**
* 删除监控模板
*/
@RequiresPermissions("rocketmq:policy:remove")
@Log(title = "资源监控策略", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
@@ -134,7 +127,6 @@ public class RmMonitorPolicyController extends BaseController
/**
* 新增交换机监控策略
*/
@RequiresPermissions("rocketmq:policy:add")
@Log(title = "资源监控策略", businessType = BusinessType.INSERT)
@PostMapping("/addResourcePolicy")
public AjaxResult addResourcePolicy(@RequestBody RmMonitorPolicy rmMonitorPolicy)
@@ -145,7 +137,6 @@ public class RmMonitorPolicyController extends BaseController
/**
* 修改交换机监控策略
*/
@RequiresPermissions("rocketmq:policy:update")
@Log(title = "资源监控策略", businessType = BusinessType.INSERT)
@PostMapping("/updateResourcePolicy")
public AjaxResult updateResourcePolicy(@RequestBody RmMonitorPolicy rmMonitorPolicy)
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/RmMonitorTemplateController.java
+1 -7
View File
@@ -26,6 +26,7 @@ import java.util.Map;
*/
@RestController
@RequestMapping("/template")
@RequiresPermissions("rocketmq:template")
public class RmMonitorTemplateController extends BaseController
{
@Autowired
@@ -34,7 +35,6 @@ public class RmMonitorTemplateController extends BaseController
/**
* 查询监控模板列表
*/
@RequiresPermissions("rocketmq:template:list")
@PostMapping("/list")
public TableDataInfo list(@RequestBody RmMonitorTemplate rmMonitorTemplate)
{
@@ -49,7 +49,6 @@ public class RmMonitorTemplateController extends BaseController
/**
* 导出监控模板列表
*/
@RequiresPermissions("rocketmq:template:export")
@Log(title = "监控模板", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, @RequestBody RmMonitorTemplate rmMonitorTemplate)
@@ -63,7 +62,6 @@ public class RmMonitorTemplateController extends BaseController
/**
* 获取监控模板详细信息
*/
@RequiresPermissions("rocketmq:template:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -73,7 +71,6 @@ public class RmMonitorTemplateController extends BaseController
/**
* 新增监控模板
*/
@RequiresPermissions("rocketmq:template:add")
@Log(title = "监控模板", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody RmMonitorTemplateVo rmMonitorTemplateVo)
@@ -84,7 +81,6 @@ public class RmMonitorTemplateController extends BaseController
/**
* 修改监控模板
*/
@RequiresPermissions("rocketmq:template:edit")
@Log(title = "监控模板", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody RmMonitorTemplateVo rmMonitorTemplateVo)
@@ -95,7 +91,6 @@ public class RmMonitorTemplateController extends BaseController
/**
* 删除监控模板
*/
@RequiresPermissions("rocketmq:template:remove")
@Log(title = "监控模板", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
@@ -105,7 +100,6 @@ public class RmMonitorTemplateController extends BaseController
/**
* 关联监控模板查询
*/
@RequiresPermissions("rocketmq:template:list")
@GetMapping("/getAllTemplate")
public AjaxResult getAllTemplate()
{
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/RmNetworkInterfaceController.java
+1 -6
View File
@@ -24,6 +24,7 @@ import java.util.List;
*/
@RestController
@RequestMapping("/networkInterface")
@RequiresPermissions("system:registration")
public class RmNetworkInterfaceController extends BaseController
{
@Autowired
@@ -32,7 +33,6 @@ public class RmNetworkInterfaceController extends BaseController
/**
* 查询客户端网络接口信息列表
*/
@RequiresPermissions("rocketmq:networkInterface:list")
@PostMapping("/list")
public AjaxResult list(@RequestBody RmNetworkInterface rmNetworkInterface)
{
@@ -43,7 +43,6 @@ public class RmNetworkInterfaceController extends BaseController
/**
* 导出客户端网络接口信息列表
*/
@RequiresPermissions("rocketmq:networkInterface:export")
@Log(title = "客户端网络接口信息", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, RmNetworkInterface rmNetworkInterface)
@@ -56,7 +55,6 @@ public class RmNetworkInterfaceController extends BaseController
/**
* 获取客户端网络接口信息详细信息
*/
@RequiresPermissions("rocketmq:networkInterface:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -66,7 +64,6 @@ public class RmNetworkInterfaceController extends BaseController
/**
* 新增客户端网络接口信息
*/
@RequiresPermissions("rocketmq:networkInterface:add")
@Log(title = "客户端网络接口信息", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody RmNetworkInterface rmNetworkInterface)
@@ -77,7 +74,6 @@ public class RmNetworkInterfaceController extends BaseController
/**
* 修改客户端网络接口信息
*/
@RequiresPermissions("rocketmq:networkInterface:edit")
@Log(title = "客户端网络接口信息", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody RmNetworkInterface rmNetworkInterface)
@@ -88,7 +84,6 @@ public class RmNetworkInterfaceController extends BaseController
/**
* 删除客户端网络接口信息
*/
@RequiresPermissions("rocketmq:networkInterface:remove")
@Log(title = "客户端网络接口信息", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/RmResourceRemoteController.java
+1 -2
View File
@@ -23,6 +23,7 @@ import java.util.List;
*/
@RestController
@RequestMapping("/remote")
@RequiresPermissions("rocketmq:remote")
public class RmResourceRemoteController extends BaseController
{
@Autowired
@@ -32,7 +33,6 @@ public class RmResourceRemoteController extends BaseController
/**
* 获取资源远程管理详细信息
*/
@RequiresPermissions("rocketmq:remote:query")
@PostMapping(value = "/getScriptResultBySn")
public AjaxResult getScriptResultBySn(@RequestBody RmResourceRemote rmResourceRemote)
{
@@ -42,7 +42,6 @@ public class RmResourceRemoteController extends BaseController
/**
* 获取资源远程管理详细信息 -- 分页
*/
@RequiresPermissions("rocketmq:remote:query")
@PostMapping(value = "/getScriptResultByScriptId")
public TableDataInfo getScriptResultByScriptId(@RequestBody RmResourceRemote rmResourceRemote)
{
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/RmTemplateLinuxController.java
+10 -21
View File
@@ -1,25 +1,19 @@
package com.tongran.rocketmq.controller;
import java.util.List;
import javax.servlet.http.HttpServletResponse;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.tongran.common.core.utils.poi.ExcelUtil;
import com.tongran.common.core.web.controller.BaseController;
import com.tongran.common.core.web.domain.AjaxResult;
import com.tongran.common.core.web.page.TableDataInfo;
import com.tongran.common.log.annotation.Log;
import com.tongran.common.log.enums.BusinessType;
import com.tongran.common.security.annotation.RequiresPermissions;
import com.tongran.rocketmq.domain.RmTemplateLinux;
import com.tongran.rocketmq.service.IRmTemplateLinuxService;
import com.tongran.common.core.web.controller.BaseController;
import com.tongran.common.core.web.domain.AjaxResult;
import com.tongran.common.core.utils.poi.ExcelUtil;
import com.tongran.common.core.web.page.TableDataInfo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletResponse;
import java.util.List;
/**
* Linux系统监控项Controller
@@ -29,6 +23,7 @@ import com.tongran.common.core.web.page.TableDataInfo;
*/
@RestController
@RequestMapping("/linux")
@RequiresPermissions("rocketmq:linux")
public class RmTemplateLinuxController extends BaseController
{
@Autowired
@@ -37,7 +32,6 @@ public class RmTemplateLinuxController extends BaseController
/**
* 查询Linux系统监控项列表
*/
@RequiresPermissions("rocketmq:linux:list")
@GetMapping("/list")
public TableDataInfo list(RmTemplateLinux rmTemplateLinux)
{
@@ -49,7 +43,6 @@ public class RmTemplateLinuxController extends BaseController
/**
* 导出Linux系统监控项列表
*/
@RequiresPermissions("rocketmq:linux:export")
@Log(title = "Linux系统监控项", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, RmTemplateLinux rmTemplateLinux)
@@ -62,7 +55,6 @@ public class RmTemplateLinuxController extends BaseController
/**
* 获取Linux系统监控项详细信息
*/
@RequiresPermissions("rocketmq:linux:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -72,7 +64,6 @@ public class RmTemplateLinuxController extends BaseController
/**
* 新增Linux系统监控项
*/
@RequiresPermissions("rocketmq:linux:add")
@Log(title = "Linux系统监控项", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody RmTemplateLinux rmTemplateLinux)
@@ -83,7 +74,6 @@ public class RmTemplateLinuxController extends BaseController
/**
* 修改Linux系统监控项
*/
@RequiresPermissions("rocketmq:linux:edit")
@Log(title = "Linux系统监控项", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody RmTemplateLinux rmTemplateLinux)
@@ -94,7 +84,6 @@ public class RmTemplateLinuxController extends BaseController
/**
* 删除Linux系统监控项
*/
@RequiresPermissions("rocketmq:linux:remove")
@Log(title = "Linux系统监控项", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
tongran-rocketmq/src/main/java/com/tongran/rocketmq/controller/RmTemplateSwitchController.java
+10 -21
View File
@@ -1,25 +1,19 @@
package com.tongran.rocketmq.controller;
import java.util.List;
import javax.servlet.http.HttpServletResponse;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.tongran.common.core.utils.poi.ExcelUtil;
import com.tongran.common.core.web.controller.BaseController;
import com.tongran.common.core.web.domain.AjaxResult;
import com.tongran.common.core.web.page.TableDataInfo;
import com.tongran.common.log.annotation.Log;
import com.tongran.common.log.enums.BusinessType;
import com.tongran.common.security.annotation.RequiresPermissions;
import com.tongran.rocketmq.domain.RmTemplateSwitch;
import com.tongran.rocketmq.service.IRmTemplateSwitchService;
import com.tongran.common.core.web.controller.BaseController;
import com.tongran.common.core.web.domain.AjaxResult;
import com.tongran.common.core.utils.poi.ExcelUtil;
import com.tongran.common.core.web.page.TableDataInfo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletResponse;
import java.util.List;
/**
* 交换机监控模板Controller
@@ -29,6 +23,7 @@ import com.tongran.common.core.web.page.TableDataInfo;
*/
@RestController
@RequestMapping("/switch")
@RequiresPermissions("rocketmq:switch")
public class RmTemplateSwitchController extends BaseController
{
@Autowired
@@ -37,7 +32,6 @@ public class RmTemplateSwitchController extends BaseController
/**
* 查询交换机监控模板列表
*/
@RequiresPermissions("rocketmq:switch:list")
@GetMapping("/list")
public TableDataInfo list(RmTemplateSwitch rmTemplateSwitch)
{
@@ -49,7 +43,6 @@ public class RmTemplateSwitchController extends BaseController
/**
* 导出交换机监控模板列表
*/
@RequiresPermissions("rocketmq:switch:export")
@Log(title = "交换机监控模板", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, RmTemplateSwitch rmTemplateSwitch)
@@ -62,7 +55,6 @@ public class RmTemplateSwitchController extends BaseController
/**
* 获取交换机监控模板详细信息
*/
@RequiresPermissions("rocketmq:switch:query")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -72,7 +64,6 @@ public class RmTemplateSwitchController extends BaseController
/**
* 新增交换机监控模板
*/
@RequiresPermissions("rocketmq:switch:add")
@Log(title = "交换机监控模板", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody RmTemplateSwitch rmTemplateSwitch)
@@ -83,7 +74,6 @@ public class RmTemplateSwitchController extends BaseController
/**
* 修改交换机监控模板
*/
@RequiresPermissions("rocketmq:switch:edit")
@Log(title = "交换机监控模板", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody RmTemplateSwitch rmTemplateSwitch)
@@ -94,7 +84,6 @@ public class RmTemplateSwitchController extends BaseController
/**
* 删除交换机监控模板
*/
@RequiresPermissions("rocketmq:switch:remove")
@Log(title = "交换机监控模板", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
tongran-rocketmq/src/main/java/com/tongran/rocketmq/domain/InitialBandwidthTraffic.java
+3
View File
@@ -6,6 +6,7 @@ import lombok.Data;
import java.math.BigDecimal;
import java.util.List;
import java.util.Map;
/**
* 初始带宽流量对象 initial_bandwidth_traffic
@@ -102,4 +103,6 @@ public class InitialBandwidthTraffic extends BaseEntity
private String totalIpv6InSpeed;
/** IPv6发送总流量 */
private String totalIpv6OutSpeed;
/** 多个clientId */
private Map<String, List<String>> clientInterfaces;
}
tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/IInitialBandwidthTrafficService.java
+7
View File
@@ -105,4 +105,11 @@ public interface IInitialBandwidthTrafficService
* @return
*/
Map<String, Object> netInterfaceIpv6TrafficEcharts(InitialBandwidthTraffic initialBandwidthTraffic);
/**
* 查询多个网卡流量信息并封装为多折线ECharts图表数据
* @param initialBandwidthTraffic
* @return
*/
List<Map<String, Object>> netBatchTrafficEcharts(InitialBandwidthTraffic initialBandwidthTraffic);
}
tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/impl/InitialBandwidthTrafficServiceImpl.java
+74 -13
View File
@@ -30,14 +30,14 @@ import java.util.stream.Collectors;
*/
@Service
@Slf4j
public class InitialBandwidthTrafficServiceImpl implements IInitialBandwidthTrafficService
public class InitialBandwidthTrafficServiceImpl implements IInitialBandwidthTrafficService
{
@Autowired
private InitialBandwidthTrafficMapper initialBandwidthTrafficMapper;
/**
* 查询初始带宽流量
*
*
* @param id 初始带宽流量主键
* @return 初始带宽流量
*/
@@ -49,7 +49,7 @@ public class InitialBandwidthTrafficServiceImpl implements IInitialBandwidthTraf
/**
* 查询初始带宽流量列表
*
*
* @param initialBandwidthTraffic 初始带宽流量
* @return 初始带宽流量
*/
@@ -61,7 +61,7 @@ public class InitialBandwidthTrafficServiceImpl implements IInitialBandwidthTraf
/**
* 新增初始带宽流量
*
*
* @param initialBandwidthTraffic 初始带宽流量
* @return 结果
*/
@@ -75,7 +75,7 @@ public class InitialBandwidthTrafficServiceImpl implements IInitialBandwidthTraf
/**
* 修改初始带宽流量
*
*
* @param initialBandwidthTraffic 初始带宽流量
* @return 结果
*/
@@ -88,7 +88,7 @@ public class InitialBandwidthTrafficServiceImpl implements IInitialBandwidthTraf
/**
* 批量删除初始带宽流量
*
*
* @param ids 需要删除的初始带宽流量主键
* @return 结果
*/
@@ -100,7 +100,7 @@ public class InitialBandwidthTrafficServiceImpl implements IInitialBandwidthTraf
/**
* 删除初始带宽流量信息
*
*
* @param id 初始带宽流量主键
* @return 结果
*/
@@ -236,12 +236,12 @@ public class InitialBandwidthTrafficServiceImpl implements IInitialBandwidthTraf
extractors.put("netInSpeedData", info ->
info != null && info.getInSpeed() != null ?
new BigDecimal(info.getInSpeed()).divide(divisor, 2, RoundingMode.HALF_UP) :
0);
null);
extractors.put("netOutSpeedData", info ->
info != null && info.getOutSpeed() != null ?
new BigDecimal(info.getOutSpeed()).divide(divisor, 2, RoundingMode.HALF_UP) :
0);
null);
Map<String, Object> resultMap = EchartsDataUtils.buildEchartsDataAutoPadding(
list, InitialBandwidthTraffic::getCreateTime, extractors,
initialBandwidthTraffic.getStartTime(), initialBandwidthTraffic.getEndTime()
@@ -294,12 +294,12 @@ public class InitialBandwidthTrafficServiceImpl implements IInitialBandwidthTraf
extractors.put("netInSpeedData", info ->
info != null && info.getIpv4InSpeed() != null ?
new BigDecimal(info.getIpv4InSpeed()).divide(divisor, 2, RoundingMode.HALF_UP) :
0);
null);
extractors.put("netOutSpeedData", info ->
info != null && info.getIpv4OutSpeed() != null ?
new BigDecimal(info.getIpv4OutSpeed()).divide(divisor, 2, RoundingMode.HALF_UP) :
0);
null);
Map<String, Object> resultMap = EchartsDataUtils.buildEchartsDataAutoPadding(
list, InitialBandwidthTraffic::getCreateTime, extractors,
initialBandwidthTraffic.getStartTime(), initialBandwidthTraffic.getEndTime()
@@ -326,12 +326,73 @@ public class InitialBandwidthTrafficServiceImpl implements IInitialBandwidthTraf
extractors.put("netInSpeedData", info ->
info != null && info.getIpv6InSpeed() != null ?
new BigDecimal(info.getIpv6InSpeed()).divide(divisor, 2, RoundingMode.HALF_UP) :
0);
null);
extractors.put("netOutSpeedData", info ->
info != null && info.getIpv6OutSpeed() != null ?
new BigDecimal(info.getIpv6OutSpeed()).divide(divisor, 2, RoundingMode.HALF_UP) :
0);
null);
Map<String, Object> resultMap = EchartsDataUtils.buildEchartsDataAutoPadding(
list, InitialBandwidthTraffic::getCreateTime, extractors,
initialBandwidthTraffic.getStartTime(), initialBandwidthTraffic.getEndTime()
);
resultMap.put("unit", unit);
return resultMap;
} catch (Exception e){
e.printStackTrace();
}
return new HashMap<>();
}
@Override
public List<Map<String, Object>> netBatchTrafficEcharts(InitialBandwidthTraffic initialBandwidthTraffic) {
List<Map<String, Object>> resultList = new ArrayList<>();
Map<String, List<String>> clientIdMap = initialBandwidthTraffic.getClientInterfaces();
if(clientIdMap == null){
return new ArrayList<>();
}
for (Map.Entry<String, List<String>> entry : clientIdMap.entrySet()) {
String clientId = entry.getKey();
List<String> interfaces = entry.getValue();
for (String interfaceName : interfaces) {
InitialBandwidthTraffic trafficData = new InitialBandwidthTraffic();
trafficData.setClientId(clientId);
trafficData.setName(interfaceName);
trafficData.setStartTime(initialBandwidthTraffic.getStartTime());
trafficData.setEndTime(initialBandwidthTraffic.getEndTime());
Map<String, Object> resultMap = getEchartsData(trafficData);
resultMap.put("interfaceName", interfaceName);
resultMap.put("clientId", clientId);
resultList.add(resultMap);
}
}
return resultList;
}
/**
* 构建echarts图表
* @param initialBandwidthTraffic
* @return
*/
public Map<String, Object> getEchartsData(InitialBandwidthTraffic initialBandwidthTraffic){
// 流量信息
List<InitialBandwidthTraffic> list = getListByTableName(initialBandwidthTraffic);
try {
String unit = SpeedUtils.calculateUnitWithStringTraffic(list, "inSpeed", "outSpeed");
if(initialBandwidthTraffic.getUnit() != null){
unit = initialBandwidthTraffic.getUnit();
}
BigDecimal divisor = SpeedUtils.getDivisor(unit);
Map<String, Function<InitialBandwidthTraffic, ?>> extractors = new LinkedHashMap<>();
extractors.put("netInSpeedData", info ->
info != null && info.getInSpeed() != null ?
new BigDecimal(info.getInSpeed()).divide(divisor, 2, RoundingMode.HALF_UP) :
null);
extractors.put("netOutSpeedData", info ->
info != null && info.getOutSpeed() != null ?
new BigDecimal(info.getOutSpeed()).divide(divisor, 2, RoundingMode.HALF_UP) :
null);
Map<String, Object> resultMap = EchartsDataUtils.buildEchartsDataAutoPadding(
list, InitialBandwidthTraffic::getCreateTime, extractors,
initialBandwidthTraffic.getStartTime(), initialBandwidthTraffic.getEndTime()
tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/impl/InitialSwitchInfoServiceImpl.java
+2 -2
View File
@@ -228,12 +228,12 @@ public class InitialSwitchInfoServiceImpl implements IInitialSwitchInfoService
extractors.put("netInSpeedData", info ->
info != null && info.getInSpeed() != null ?
info.getInSpeed().divide(divisor, 2, RoundingMode.HALF_UP) :
0);
null);
extractors.put("netOutSpeedData", info ->
info != null && info.getOutSpeed() != null ?
info.getOutSpeed().divide(divisor, 2, RoundingMode.HALF_UP) :
0);
null);
Map<String, Object> resultMap = EchartsDataUtils.buildEchartsDataAutoPadding(
list, InitialSwitchInfo::getCreateTime, extractors,
initialSwitchInfo.getStartTime(), initialSwitchInfo.getEndTime()
tongran-rocketmq/src/main/java/com/tongran/rocketmq/utils/DataProcessUtil.java
+1 -1
View File
@@ -213,7 +213,7 @@ public class DataProcessUtil {
*/
public String bytesToBits(String speed) {
if (speed == null || speed.trim().isEmpty()) {
return "0";
return null;
}
String cleanedSpeed = speed.trim();