diff --git a/tongran-modules/tongran-system/src/main/java/com/tongran/system/controller/RmSwitchManagementController.java b/tongran-modules/tongran-system/src/main/java/com/tongran/system/controller/RmSwitchManagementController.java index 796c78f..96b7b60 100644 --- a/tongran-modules/tongran-system/src/main/java/com/tongran/system/controller/RmSwitchManagementController.java +++ b/tongran-modules/tongran-system/src/main/java/com/tongran/system/controller/RmSwitchManagementController.java @@ -51,7 +51,7 @@ public class RmSwitchManagementController extends BaseController */ @Log(title = "交换机管理", businessType = BusinessType.EXPORT) @PostMapping("/export") - public void export(HttpServletResponse response, RmSwitchManagement rmSwitchManagement) + public void export(HttpServletResponse response, @RequestBody RmSwitchManagement rmSwitchManagement) { List list = rmSwitchManagementService.selectRmSwitchManagementList(rmSwitchManagement); ExcelUtil util = new ExcelUtil(RmSwitchManagement.class); @@ -103,6 +103,7 @@ public class RmSwitchManagementController extends BaseController @PostMapping("/getAllSwitchName") public AjaxResult getAllSwitchName(@RequestBody RmSwitchManagement rmSwitchManagement) { + rmSwitchManagement.setDelFlag(0); List list = rmSwitchManagementService.selectRmSwitchManagementList(rmSwitchManagement); return success(list); } @@ -113,6 +114,7 @@ public class RmSwitchManagementController extends BaseController @PostMapping("/getSwitchNameByClientId") public R> getSwitchNameByClientId(@RequestBody RmSwitchManagement rmSwitchManagement) { + rmSwitchManagement.setDelFlag(0); List list = rmSwitchManagementService.selectRmSwitchManagementList(rmSwitchManagement); return R.ok(list); } @@ -134,4 +136,14 @@ public class RmSwitchManagementController extends BaseController { return R.ok(rmSwitchManagementService.updateRmSwitchManagement(rmSwitchManagement)); } + + /** + * 下架 + */ + @Log(title = "下架", businessType = BusinessType.UPDATE) + @PostMapping("/removeSwitch") + public AjaxResult removeSwitch(@RequestBody RmSwitchManagement rmSwitchManagement) + { + return toAjax(rmSwitchManagementService.removeSwitch(rmSwitchManagement.getIds())); + } } diff --git a/tongran-modules/tongran-system/src/main/java/com/tongran/system/domain/RmSwitchManagement.java b/tongran-modules/tongran-system/src/main/java/com/tongran/system/domain/RmSwitchManagement.java index c64aa42..bf04adb 100644 --- a/tongran-modules/tongran-system/src/main/java/com/tongran/system/domain/RmSwitchManagement.java +++ b/tongran-modules/tongran-system/src/main/java/com/tongran/system/domain/RmSwitchManagement.java @@ -38,9 +38,10 @@ public class RmSwitchManagement extends BaseEntity private Long snmpPort; /** 在线状态(0-离线,1-在线) */ - @Excel(name = "在线状态(0-离线,1-在线)") + @Excel(name = "在线状态", readConverterExp = "0=离线,1=在线") private String onlineStatus; /** 上机时间 */ + @Excel(name = "上机时间") private Date upTime; /** 心跳监测次数 */ @Excel(name = "心跳监测次数") @@ -55,19 +56,19 @@ public class RmSwitchManagement extends BaseEntity private String heartbeatOid; /** SNMP版本(v1/v2c/v3) */ - @Excel(name = "SNMP版本(v1/v2c/v3)") + @Excel(name = "SNMP版本", readConverterExp = "1=华为SNMPv2,2=华为SNMPv3") private String snmpVersion; /** 读写权限 */ - @Excel(name = "读写权限") + @Excel(name = "读写权限", readConverterExp = "1=只读,2=可读可写") private String readWritePermission; /** 安全级别 */ - @Excel(name = "安全级别") + @Excel(name = "安全级别", readConverterExp = "1=noAuthNoPriv,2=authNoPriv,3=authPriv") private String securityLevel; /** 加密方式 */ - @Excel(name = "加密方式") + @Excel(name = "加密方式", readConverterExp = "1=MD5,2=SHA") private String encryptionMethod; /** 团体名称 */ @@ -78,12 +79,15 @@ public class RmSwitchManagement extends BaseEntity @Excel(name = "密码") private String switchPassword; /** 交换机类型 */ + @Excel(name = "交换机类型", readConverterExp = "1=华为") private String switchType; /** 用户名 */ + @Excel(name = "用户名") private String switchUser; /** 端口备注列表 */ private List switchInterfaceInfoList; /** 自动生成客户端id(uuid) */ + @Excel(name = "唯一标识") private String clientId; /** 查询条件 */ private String queryName; @@ -93,5 +97,9 @@ public class RmSwitchManagement extends BaseEntity private Long value; /** 前端需要 name 别名 */ private String label; + /** 下架标识(0未下架,1已下架) */ + private Integer delFlag; + + private Long[] ids; } diff --git a/tongran-modules/tongran-system/src/main/java/com/tongran/system/mapper/RmSwitchManagementMapper.java b/tongran-modules/tongran-system/src/main/java/com/tongran/system/mapper/RmSwitchManagementMapper.java index 55cc4d8..24539a6 100644 --- a/tongran-modules/tongran-system/src/main/java/com/tongran/system/mapper/RmSwitchManagementMapper.java +++ b/tongran-modules/tongran-system/src/main/java/com/tongran/system/mapper/RmSwitchManagementMapper.java @@ -1,8 +1,9 @@ package com.tongran.system.mapper; -import java.util.List; import com.tongran.system.domain.RmSwitchManagement; +import java.util.List; + /** * 交换机管理Mapper接口 * @@ -58,4 +59,6 @@ public interface RmSwitchManagementMapper * @return 结果 */ public int deleteRmSwitchManagementByIds(Long[] ids); + + int removeSwitch(Long[] ids); } diff --git a/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/IRmSwitchManagementService.java b/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/IRmSwitchManagementService.java index 346f0c2..c0387e3 100644 --- a/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/IRmSwitchManagementService.java +++ b/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/IRmSwitchManagementService.java @@ -65,4 +65,6 @@ public interface IRmSwitchManagementService * @return */ List getAllSwitchNameTree(); + + int removeSwitch(Long[] ids); } diff --git a/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/RmSwitchManagementServiceImpl.java b/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/RmSwitchManagementServiceImpl.java index 930a561..e42905c 100644 --- a/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/RmSwitchManagementServiceImpl.java +++ b/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/RmSwitchManagementServiceImpl.java @@ -160,7 +160,9 @@ public class RmSwitchManagementServiceImpl implements IRmSwitchManagementService */ @Override public List getAllSwitchNameTree() { - List list = rmSwitchManagementMapper.selectRmSwitchManagementList(new RmSwitchManagement()); + RmSwitchManagement queryCondition = new RmSwitchManagement(); + queryCondition.setDelFlag(0); + List list = rmSwitchManagementMapper.selectRmSwitchManagementList(queryCondition); // 构建树形结构结果 for (RmSwitchManagement switchManagement : list) { switchManagement.setValue(switchManagement.getId()); @@ -197,4 +199,9 @@ public class RmSwitchManagementServiceImpl implements IRmSwitchManagementService } return list; } + + @Override + public int removeSwitch(Long[] ids) { + return rmSwitchManagementMapper.removeSwitch(ids); + } } diff --git a/tongran-modules/tongran-system/src/main/resources/mapper/system/RmSwitchManagementMapper.xml b/tongran-modules/tongran-system/src/main/resources/mapper/system/RmSwitchManagementMapper.xml index c4ea811..070d21a 100644 --- a/tongran-modules/tongran-system/src/main/resources/mapper/system/RmSwitchManagementMapper.xml +++ b/tongran-modules/tongran-system/src/main/resources/mapper/system/RmSwitchManagementMapper.xml @@ -28,15 +28,17 @@ + - select id, switch_type, switch_name, hardware_sn, snmp_address, snmp_port, online_status, heartbeat_count, heartbeat_interval, heartbeat_oid, snmp_version, up_time, read_write_permission, security_level, encryption_method, community_name, switch_user, switch_password, create_time, update_time, create_by, update_by, client_id from rm_switch_management + select id, switch_type, switch_name, hardware_sn, snmp_address, snmp_port, online_status, heartbeat_count, heartbeat_interval, heartbeat_oid, snmp_version, up_time, read_write_permission, security_level, encryption_method, community_name, switch_user, switch_password, create_time, update_time, create_by, update_by, client_id, del_flag from rm_switch_management @@ -92,6 +94,7 @@ create_by, update_by, client_id, + del_flag, #{switchType}, @@ -116,6 +119,7 @@ #{createBy}, #{updateBy}, #{clientId}, + #{delFlag}, @@ -143,6 +147,7 @@ update_time = #{updateTime}, create_by = #{createBy}, update_by = #{updateBy}, + del_flag = #{delFlag}, @@ -169,4 +174,10 @@ #{id} + + update rm_switch_management set del_flag=1 where id in + + #{id} + + \ No newline at end of file diff --git a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/impl/InitialBandwidthTrafficServiceImpl.java b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/impl/InitialBandwidthTrafficServiceImpl.java index 371715d..097d040 100644 --- a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/impl/InitialBandwidthTrafficServiceImpl.java +++ b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/service/impl/InitialBandwidthTrafficServiceImpl.java @@ -454,8 +454,10 @@ public class InitialBandwidthTrafficServiceImpl implements IInitialBandwidthTraf Map showRealation = new HashMap<>(); interfaceDataMap.put(name, mainList); String ipv4 = ""; + String ipv6 = ""; if(mainList != null && !mainList.isEmpty()){ ipv4 = mainList.get(0).getIpV4(); + ipv6 = mainList.get(0).getIpV6(); } showRealation.put(name+"netInTraffic", name+"入站流量" + " IPv4: "+ipv4); showRealation.put(name+"netOutTraffic", name+"出站流量" + " IPv4: "+ipv4); @@ -490,8 +492,10 @@ public class InitialBandwidthTrafficServiceImpl implements IInitialBandwidthTraf needAddIpv4Ipv6 = true; showRealation.put(name+"netInTrafficIPv4", name+"IPv4入站流量" + " IPv4: "+ipv4); showRealation.put(name+"netOutTrafficIPv4", name+"IPv4出站流量" + " IPv4: "+ipv4); - showRealation.put(name+"netInTrafficIPv6", name+"IPv6入站流量" + " IPv4: "+ipv4); - showRealation.put(name+"netOutTrafficIPv6", name+"IPv6出站流量" + " IPv4: "+ipv4); + if(!"N/A".equals(ipv6) && StringUtils.isNoneBlank(ipv6)){ + showRealation.put(name+"netInTrafficIPv6", name+"IPv6入站流量" + " IPv6: "+ipv6); + showRealation.put(name+"netOutTrafficIPv6", name+"IPv6出站流量" + " IPv6: "+ipv6); + } } } @@ -702,10 +706,12 @@ public class InitialBandwidthTrafficServiceImpl implements IInitialBandwidthTraf displayName + " IPv4入站流量"); showRealation.put("business_" + businessPrefix + "_netIpv4OutSpeedData", displayName + " IPv4出站流量"); - showRealation.put("business_" + businessPrefix + "_netIpv6InSpeedData", - displayName + " IPv6入站流量"); - showRealation.put("business_" + businessPrefix + "_netIpv6OutSpeedData", - displayName + " IPv6出站流量"); + if(!"N/A".equals(ipv6) && StringUtils.isNoneBlank(ipv6)){ + showRealation.put("business_" + businessPrefix + "_netIpv6InSpeedData", + displayName + " IPv6入站流量"); + showRealation.put("business_" + businessPrefix + "_netIpv6OutSpeedData", + displayName + " IPv6出站流量"); + } } } } catch (Exception e) { @@ -860,12 +866,12 @@ public class InitialBandwidthTrafficServiceImpl implements IInitialBandwidthTraf // 展示关系 Map showRealation = new HashMap<>(); interfaceDataMap.put(name, mainList); - String ipv4 = ""; + String ipv6 = ""; if(mainList != null && !mainList.isEmpty()){ - ipv4 = mainList.get(0).getIpV4(); + ipv6 = mainList.get(0).getIpV6(); } - showRealation.put(name + "netInTraffic", name + "IPv6入站流量" + " IPv4: "+ipv4); - showRealation.put(name + "netOutTraffic", name + "IPv6出站流量" + " IPv4: "+ipv4); + showRealation.put(name + "netInTraffic", name + "IPv6入站流量" + " ipv6: "+ipv6); + showRealation.put(name + "netOutTraffic", name + "IPv6出站流量" + " ipv6: "+ipv6); boolean hasSubInterface = false; // 收集所有需要计算单位的流量数据 List allTrafficData = new ArrayList<>(); @@ -887,8 +893,8 @@ public class InitialBandwidthTrafficServiceImpl implements IInitialBandwidthTraf if (childTrafficList != null && !childTrafficList.isEmpty()) { allTrafficData.addAll(childTrafficList); interfaceDataMap.put(child.getInterfaceName(), childTrafficList); - showRealation.put(child.getInterfaceName() + "netInTraffic", child.getInterfaceName() + "IPv6入站流量" + " IPv4: "+child.getIpv4Address()); - showRealation.put(child.getInterfaceName() + "netOutTraffic", child.getInterfaceName() + "IPv6出站流量" + " IPv4: "+child.getIpv4Address()); + showRealation.put(child.getInterfaceName() + "netInTraffic", child.getInterfaceName() + "IPv6入站流量" + " ipv6: "+child.getIpv6Address()); + showRealation.put(child.getInterfaceName() + "netOutTraffic", child.getInterfaceName() + "IPv6出站流量" + " ipv6: "+child.getIpv6Address()); } } } @@ -917,8 +923,8 @@ public class InitialBandwidthTrafficServiceImpl implements IInitialBandwidthTraf resultMap.put("unit", unit); if (!showRealation.isEmpty() && hasSubInterface) { - showRealation.put("totalNetInTraffic", name + "IPv6总入站流量" + " IPv4: "+ipv4); - showRealation.put("totalNetOutTraffic", name + "IPv6总出站流量" + " IPv4: "+ipv4); + showRealation.put("totalNetInTraffic", name + "IPv6总入站流量" + " ipv6: "+ipv6); + showRealation.put("totalNetOutTraffic", name + "IPv6总出站流量" + " ipv6: "+ipv6); } Map sortedShowRealation = EchartsMoreDataUtils.sortInterfaceMap(showRealation, name, hasSubInterface); resultMap.put("showRealation", sortedShowRealation);