diff --git a/tongran-auth/src/main/resources/bootstrap.yml b/tongran-auth/src/main/resources/bootstrap.yml index efada91..9cf0ca2 100644 --- a/tongran-auth/src/main/resources/bootstrap.yml +++ b/tongran-auth/src/main/resources/bootstrap.yml @@ -13,9 +13,8 @@ spring: cloud: nacos: discovery: - server-addr: 172.16.15.52:8848 # 服务注册地址 -# server-addr: 172.16.15.103:8848 + server-addr: ${spring.cloud.nacos.config.server-addr} namespace: ${spring.cloud.nacos.config.namespace} username: ${spring.cloud.nacos.config.username} password: ${spring.cloud.nacos.config.password} @@ -23,8 +22,8 @@ spring: # 配置中心地址 server-addr: 172.16.15.52:8848 # server-addr: 172.16.15.103:8848 - namespace: public -# namespace: saas-local +# namespace: public + namespace: saas-local username: nacos password: nacos # 配置文件格式 diff --git a/tongran-gateway/src/main/resources/bootstrap.yml b/tongran-gateway/src/main/resources/bootstrap.yml index 50a2cc0..67041f1 100644 --- a/tongran-gateway/src/main/resources/bootstrap.yml +++ b/tongran-gateway/src/main/resources/bootstrap.yml @@ -13,9 +13,8 @@ spring: cloud: nacos: discovery: - server-addr: 172.16.15.52:8848 # 服务注册地址 -# server-addr: 172.16.15.103:8848 + server-addr: ${spring.cloud.nacos.config.server-addr} namespace: ${spring.cloud.nacos.config.namespace} username: ${spring.cloud.nacos.config.username} password: ${spring.cloud.nacos.config.password} @@ -23,8 +22,8 @@ spring: # 配置中心地址 server-addr: 172.16.15.52:8848 # server-addr: 172.16.15.103:8848 - namespace: public -# namespace: saas-local +# namespace: public + namespace: saas-local username: nacos password: nacos # 配置文件格式 diff --git a/tongran-modules/tongran-file/src/main/resources/bootstrap.yml b/tongran-modules/tongran-file/src/main/resources/bootstrap.yml index 87396c3..6988e29 100644 --- a/tongran-modules/tongran-file/src/main/resources/bootstrap.yml +++ b/tongran-modules/tongran-file/src/main/resources/bootstrap.yml @@ -14,17 +14,16 @@ spring: nacos: discovery: # 服务注册地址 - server-addr: 172.16.15.52:8848 -# server-addr: 172.16.15.103:8848 + server-addr: ${spring.cloud.nacos.config.server-addr} namespace: ${spring.cloud.nacos.config.namespace} username: ${spring.cloud.nacos.config.username} password: ${spring.cloud.nacos.config.password} config: # 配置中心地址 - server-addr: 172.16.15.52:8848 -# server-addr: 172.16.15.103:8848 - namespace: public -# namespace: saas-local +# server-addr: 172.16.15.52:8848 + server-addr: 172.16.15.103:8848 +# namespace: public + namespace: saas-prod username: nacos password: nacos # 配置文件格式 diff --git a/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/controller/RmMtrClientRegistrationController.java b/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/controller/RmMtrClientRegistrationController.java index 33bfe9d..0f28ea0 100644 --- a/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/controller/RmMtrClientRegistrationController.java +++ b/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/controller/RmMtrClientRegistrationController.java @@ -114,13 +114,13 @@ public class RmMtrClientRegistrationController extends BaseController return success(list); } /** - * 查询MTR客户端注册列表 + * 查询所有标识 */ @RequiresPermissions("mtragent:mtrClientRegistration:list") - @PostMapping("/getAllLogicalNode") - public AjaxResult getAllLogicalNode(@RequestBody RmMtrClientRegistration rmMtrClientRegistration) + @GetMapping("/getAllLogicalNode") + public AjaxResult getAllLogicalNode() { - List list = rmMtrClientRegistrationService.getAllLogicalNode(rmMtrClientRegistration); + List list = rmMtrClientRegistrationService.getAllLogicalNode(); return success(list); } /** diff --git a/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/domain/AllMtrClient.java b/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/domain/AllMtrClient.java index 124867e..69162db 100644 --- a/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/domain/AllMtrClient.java +++ b/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/domain/AllMtrClient.java @@ -1,9 +1,8 @@ package com.tongran.mtragent.domain; -import org.apache.commons.lang3.builder.ToStringBuilder; -import org.apache.commons.lang3.builder.ToStringStyle; import com.tongran.common.core.annotation.Excel; import com.tongran.common.core.web.domain.BaseEntity; +import lombok.Data; /** * mtr探测丢包clinetId记录对象 all_mtr_client @@ -11,6 +10,7 @@ import com.tongran.common.core.web.domain.BaseEntity; * @author gyt * @date 2025-11-24 */ +@Data public class AllMtrClient extends BaseEntity { private static final long serialVersionUID = 1L; @@ -29,58 +29,7 @@ public class AllMtrClient extends BaseEntity /** 公网IP地址 */ @Excel(name = "公网IP地址") private String publicIp; + /** 失败标志 0成功 1失败 */ + private Integer failFlag; - public void setId(Long id) - { - this.id = id; - } - - public Long getId() - { - return id; - } - - public void setMtrClientId(String mtrClientId) - { - this.mtrClientId = mtrClientId; - } - - public String getMtrClientId() - { - return mtrClientId; - } - - public void setClientId(String clientId) - { - this.clientId = clientId; - } - - public String getClientId() - { - return clientId; - } - - public void setPublicIp(String publicIp) - { - this.publicIp = publicIp; - } - - public String getPublicIp() - { - return publicIp; - } - - @Override - public String toString() { - return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE) - .append("id", getId()) - .append("mtrClientId", getMtrClientId()) - .append("clientId", getClientId()) - .append("publicIp", getPublicIp()) - .append("createTime", getCreateTime()) - .append("updateTime", getUpdateTime()) - .append("createBy", getCreateBy()) - .append("updateBy", getUpdateBy()) - .toString(); - } } diff --git a/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/domain/RmMtrClientRegistration.java b/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/domain/RmMtrClientRegistration.java index e8217e9..09a5349 100644 --- a/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/domain/RmMtrClientRegistration.java +++ b/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/domain/RmMtrClientRegistration.java @@ -89,4 +89,6 @@ public class RmMtrClientRegistration extends BaseEntity private String networkInfo; /** 部署设备 */ private String mtrClientIds; + /** 多条件 */ + private String queryName; } diff --git a/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/handler/MessageHandler.java b/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/handler/MessageHandler.java index 8845441..d91624b 100644 --- a/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/handler/MessageHandler.java +++ b/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/handler/MessageHandler.java @@ -93,27 +93,32 @@ public class MessageHandler { List rmMtrProbeResultList = new ArrayList<>(); List allMtrClientList = new ArrayList<>(); for (MtrResultVo mtrResultVo : mtrResultVoList) { - if(mtrResultVo.getFinalLossPercent() != -1.0){ - // 时间戳转换 - long timestamp = mtrResultVo.getTimestamp(); - long millis = timestamp * 1000; - Date createTime = new Date(millis / 1000 * 1000); // 去除毫秒 - RmMtrProbeResult rmMtrProbeResult = new RmMtrProbeResult(); - rmMtrProbeResult.setCreateTime(createTime); - rmMtrProbeResult.setClientId(mtrResultVo.getClientId()); - rmMtrProbeResult.setMtrClientId(mtrClientId); - rmMtrProbeResult.setPublicIp(mtrResultVo.getTargetIp()); - rmMtrProbeResult.setPacketLossRate(new BigDecimal(mtrResultVo.getFinalLossPercent())); - rmMtrProbeResultList.add(rmMtrProbeResult); - AllMtrClient allMtrClient = new AllMtrClient(); - BeanUtils.copyProperties(rmMtrProbeResult, allMtrClient); - allMtrClientList.add(allMtrClient); + // 时间戳转换 + long timestamp = mtrResultVo.getTimestamp(); + long millis = timestamp * 1000; + Date createTime = new Date(millis / 1000 * 1000); // 去除毫秒 + RmMtrProbeResult rmMtrProbeResult = new RmMtrProbeResult(); + rmMtrProbeResult.setCreateTime(createTime); + rmMtrProbeResult.setClientId(mtrResultVo.getClientId()); + rmMtrProbeResult.setMtrClientId(mtrClientId); + rmMtrProbeResult.setPublicIp(mtrResultVo.getTargetIp()); + rmMtrProbeResult.setPacketLossRate(new BigDecimal(mtrResultVo.getFinalLossPercent())); + rmMtrProbeResultList.add(rmMtrProbeResult); + AllMtrClient allMtrClient = new AllMtrClient(); + BeanUtils.copyProperties(rmMtrProbeResult, allMtrClient); + if(mtrResultVo.getFinalLossPercent() == -1.0){ + allMtrClient.setFailFlag(1); }else{ - log.debug("探测失败,失败原因:{}", mtrResultVo.getErrorMsg()); + allMtrClient.setFailFlag(0); } + allMtrClientList.add(allMtrClient); } RmMtrProbeResult insertData = new RmMtrProbeResult(); insertData.setList(rmMtrProbeResultList); + if(rmMtrProbeResultList.isEmpty()){ + log.warn("探测失败,原因可能为mtr命令没安装"); + return; + } // 结果批量入库 rmMtrProbeResultService.batchInsertRmMtrProbeResult(insertData); // 记录下发策略的clientId diff --git a/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/service/IRmMtrClientRegistrationService.java b/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/service/IRmMtrClientRegistrationService.java index 4e71ab1..aadca49 100644 --- a/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/service/IRmMtrClientRegistrationService.java +++ b/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/service/IRmMtrClientRegistrationService.java @@ -70,10 +70,9 @@ public interface IRmMtrClientRegistrationService /** * 获取所有标识 - * @param rmMtrClientRegistration * @return */ - List getAllLogicalNode(RmMtrClientRegistration rmMtrClientRegistration); + List getAllLogicalNode(); /** * 根据mtrClientId查询包含的clientId * @param rmMtrClientRegistration diff --git a/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/service/impl/RmMtrClientRegistrationServiceImpl.java b/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/service/impl/RmMtrClientRegistrationServiceImpl.java index 434160f..a89be4d 100644 --- a/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/service/impl/RmMtrClientRegistrationServiceImpl.java +++ b/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/service/impl/RmMtrClientRegistrationServiceImpl.java @@ -215,8 +215,8 @@ public class RmMtrClientRegistrationServiceImpl implements IRmMtrClientRegistrat } @Override - public List getAllLogicalNode(RmMtrClientRegistration rmMtrClientRegistration) { - List list = rmMtrClientRegistrationMapper.getAllLogicalNode(rmMtrClientRegistration); + public List getAllLogicalNode() { + List list = rmMtrClientRegistrationMapper.getAllLogicalNode(new RmMtrClientRegistration()); return list; } diff --git a/tongran-modules/tongran-mtragent/src/main/resources/bootstrap.yml b/tongran-modules/tongran-mtragent/src/main/resources/bootstrap.yml index a503098..2b1b7dd 100644 --- a/tongran-modules/tongran-mtragent/src/main/resources/bootstrap.yml +++ b/tongran-modules/tongran-mtragent/src/main/resources/bootstrap.yml @@ -23,8 +23,8 @@ spring: # 配置中心地址 server-addr: 172.16.15.52:8848 # server-addr: 172.16.15.103:8848 - namespace: public -# namespace: saas-local +# namespace: public + namespace: saas-local username: nacos password: nacos # 配置文件格式 diff --git a/tongran-modules/tongran-mtragent/src/main/resources/mapper/mtragent/AllMtrClientMapper.xml b/tongran-modules/tongran-mtragent/src/main/resources/mapper/mtragent/AllMtrClientMapper.xml index 4efba6a..bd296ce 100644 --- a/tongran-modules/tongran-mtragent/src/main/resources/mapper/mtragent/AllMtrClientMapper.xml +++ b/tongran-modules/tongran-mtragent/src/main/resources/mapper/mtragent/AllMtrClientMapper.xml @@ -3,12 +3,13 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> - + + @@ -16,18 +17,19 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" - select id, mtr_client_id, client_id, public_ip, create_time, update_time, create_by, update_by from all_mtr_client + select id, mtr_client_id, client_id, public_ip, fail_flag, create_time, update_time, create_by, update_by from all_mtr_client - + diff --git a/tongran-modules/tongran-mtragent/src/main/resources/mapper/mtragent/RmMtrProbeResultMapper.xml b/tongran-modules/tongran-mtragent/src/main/resources/mapper/mtragent/RmMtrProbeResultMapper.xml index f6b9f4c..3e71d9e 100644 --- a/tongran-modules/tongran-mtragent/src/main/resources/mapper/mtragent/RmMtrProbeResultMapper.xml +++ b/tongran-modules/tongran-mtragent/src/main/resources/mapper/mtragent/RmMtrProbeResultMapper.xml @@ -85,7 +85,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" - INSERT INTO ${tableName} + INSERT IGNORE INTO ${tableName} ( mtr_client_id, client_id, diff --git a/tongran-modules/tongran-system/src/main/java/com/tongran/system/controller/EpsServerRevenueConfigController.java b/tongran-modules/tongran-system/src/main/java/com/tongran/system/controller/EpsServerRevenueConfigController.java index 83e5d28..4c7b8fe 100644 --- a/tongran-modules/tongran-system/src/main/java/com/tongran/system/controller/EpsServerRevenueConfigController.java +++ b/tongran-modules/tongran-system/src/main/java/com/tongran/system/controller/EpsServerRevenueConfigController.java @@ -8,7 +8,6 @@ import com.tongran.common.core.web.page.PageDomain; 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.InnerAuth; import com.tongran.common.security.annotation.RequiresPermissions; import com.tongran.system.domain.EpsServerRevenueConfig; import com.tongran.system.service.IEpsServerRevenueConfigService; @@ -75,7 +74,7 @@ public class EpsServerRevenueConfigController extends BaseController /** * 流量相关数据入库 */ - @InnerAuth +// @InnerAuth @PostMapping("/autoSaveServiceTrafficData") public R autoSaveServiceTrafficData(@RequestBody EpsServerRevenueConfig epsServerRevenueConfig) { diff --git a/tongran-modules/tongran-system/src/main/java/com/tongran/system/controller/RmResourceRegistrationController.java b/tongran-modules/tongran-system/src/main/java/com/tongran/system/controller/RmResourceRegistrationController.java index a411018..3078d5f 100644 --- a/tongran-modules/tongran-system/src/main/java/com/tongran/system/controller/RmResourceRegistrationController.java +++ b/tongran-modules/tongran-system/src/main/java/com/tongran/system/controller/RmResourceRegistrationController.java @@ -108,28 +108,6 @@ public class RmResourceRegistrationController extends BaseController return toAjax(rmResourceRegistrationService.register(rmResourceRegistration)); } - /** - * 查询所有资源名称(包含设备使用) - * @return 资源注册集合 - */ - @RequiresPermissions("system:group:list") - @GetMapping("/selectAllResourceName") - public List selectAllResourceName() - { - List list = rmResourceRegistrationService.selectAllResourceName(); - return list; - } - /** - * 查询所有资源名称 - * @return 资源注册集合 - */ - @RequiresPermissions("system:group:list") - @PostMapping("/selectAllResourceNameByType") - public List selectAllResourceNameByType(@RequestBody RmResourceRegistration rmResourceRegistration) - { - List list = rmResourceRegistrationService.selectAllResourceNameByType(rmResourceRegistration); - return list; - } /** * 检测到服务器离线,修改状态为离线 @@ -249,5 +227,25 @@ public class RmResourceRegistrationController extends BaseController } return success(list); } + /** + * 添加标签 + */ + @RequiresPermissions("system:registration:edit") + @Log(title = "添加服务器标签", businessType = BusinessType.UPDATE) + @PostMapping("/addRemark") + public AjaxResult addRemark(@RequestBody RmResourceRegistration rmResourceRegistration) + { + return toAjax(rmResourceRegistrationService.addRemark(rmResourceRegistration)); + } + /** + * 添加标签 + */ + @RequiresPermissions("system:registration:edit") + @Log(title = "添加服务器标签", businessType = BusinessType.UPDATE) + @PostMapping("/updateRemark") + public AjaxResult updateRemark(@RequestBody RmResourceRegistration rmResourceRegistration) + { + return toAjax(rmResourceRegistrationService.updateRemark(rmResourceRegistration)); + } } diff --git a/tongran-modules/tongran-system/src/main/java/com/tongran/system/controller/SysUserOnlineController.java b/tongran-modules/tongran-system/src/main/java/com/tongran/system/controller/SysUserOnlineController.java index 1c78433..27d6808 100644 --- a/tongran-modules/tongran-system/src/main/java/com/tongran/system/controller/SysUserOnlineController.java +++ b/tongran-modules/tongran-system/src/main/java/com/tongran/system/controller/SysUserOnlineController.java @@ -1,15 +1,7 @@ package com.tongran.system.controller; -import java.util.ArrayList; -import java.util.Collection; -import java.util.Collections; -import java.util.List; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.web.bind.annotation.DeleteMapping; -import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.PathVariable; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; import com.tongran.common.core.constant.CacheConstants; import com.tongran.common.core.utils.StringUtils; import com.tongran.common.core.web.controller.BaseController; @@ -22,6 +14,13 @@ import com.tongran.common.security.annotation.RequiresPermissions; import com.tongran.system.api.model.LoginUser; import com.tongran.system.domain.SysUserOnline; import com.tongran.system.service.ISysUserOnlineService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.*; + +import java.util.ArrayList; +import java.util.Collection; +import java.util.Collections; +import java.util.List; /** * 在线用户监控 @@ -46,7 +45,12 @@ public class SysUserOnlineController extends BaseController List userOnlineList = new ArrayList(); for (String key : keys) { - LoginUser user = redisService.getCacheObject(key); + // 修复:安全地获取LoginUser对象 + LoginUser user = getLoginUserFromCache(key); + if (user == null) { + continue; // 跳过无效的用户数据 + } + if (StringUtils.isNotEmpty(ipaddr) && StringUtils.isNotEmpty(userName)) { userOnlineList.add(userOnlineService.selectOnlineByInfo(ipaddr, userName, user)); @@ -69,6 +73,36 @@ public class SysUserOnlineController extends BaseController return getDataTable(userOnlineList); } + /** + * 安全地从缓存中获取LoginUser对象 + */ + private LoginUser getLoginUserFromCache(String key) { + try { + Object userObj = redisService.getCacheObject(key); + if (userObj == null) { + return null; + } + + // 类型安全转换 + if (userObj instanceof LoginUser) { + return (LoginUser) userObj; + } + // 处理JSONObject情况 + else if (userObj instanceof JSONObject) { + return ((JSONObject) userObj).toJavaObject(LoginUser.class); + } + // 处理JSON字符串情况 + else if (userObj instanceof String) { + return JSON.parseObject((String) userObj, LoginUser.class); + } + + return null; + + } catch (Exception e) { + return null; + } + } + /** * 强退用户 */ diff --git a/tongran-modules/tongran-system/src/main/java/com/tongran/system/domain/RmResourceRegistration.java b/tongran-modules/tongran-system/src/main/java/com/tongran/system/domain/RmResourceRegistration.java index e3e9b97..39bbea3 100644 --- a/tongran-modules/tongran-system/src/main/java/com/tongran/system/domain/RmResourceRegistration.java +++ b/tongran-modules/tongran-system/src/main/java/com/tongran/system/domain/RmResourceRegistration.java @@ -34,89 +34,19 @@ public class RmResourceRegistration extends BaseEntity /** 资源类型 * 1 服务器,2 交换机*/ private String resourceType; - /** 资源名称 */ private String resourceName; - /** IP地址 */ - private String ipAddress; - - /** 端口1.162(SNMP),2.其他 */ - private String resourcePort; - - /**其他端口名称 */ - private String otherPortName; - /** agent版本 */ @Excel(name = "agent版本") private String agentVersion; - /** 协议 1.TCP,2.UDP */ - private String protocol; - - /** SNMP探测 0=否,1=是 */ - private String snmpDetect; - - /** 版本(1.SNMPv2,2.SNMPv3) */ - private String resourceVersion; - - /** 读写权限(1.RW,2.ReadOnly) */ - private String rwPermission; - - /** 团体名称 */ - private String teamName; - - /** SNMP采集地址 */ - private String snmpCollectAddr; - - /** SNMP采集端口 */ - private String snmpCollectPort; - - /** 安全级别(1.authPriv、2.authNoPriv,3.noAuthNoPriv) */ - private String securityLevel; - - /** 加密方式 1.md5,2.SHA */ - private String encryption; - - /** 用户名 */ - private String resourceUserName; - - /** 密码 */ - private String resourcePwd; - /** 注册状态 0-未注册,1-已注册 */ private String registrationStatus; /** 在线状态 0-离线,1-在线 */ @Excel(name = "在线状态", readConverterExp = "0=离线,1=在线") private String onlineStatus; - - private String switchOnlineStatus; - - /** 描述 */ - private String description; - - /** 设备业务客户id */ - private Long customerId; - - /** 设备业务客户名称 */ - private String customerName; - - /** 业务号 */ - private String serviceNumber; - - /** 创建人id */ - private Long creatorId; - - /** 创建人名称 */ - private String creatorName; - - /** 修改人id */ - private Long updaterId; - - /** 修改人名称 */ - private String updaterName; - /** 监控项 */ private String monitorItems; @@ -126,20 +56,6 @@ public class RmResourceRegistration extends BaseEntity /** 查询名称 */ private String queryName; - /** - * 运营商 - */ - private String operator; - - /** - * 省 - */ - private String province; - - /** - * 公网IP - */ - private String publicIp; /** * 业务名称 diff --git a/tongran-modules/tongran-system/src/main/java/com/tongran/system/mapper/RmResourceRegistrationMapper.java b/tongran-modules/tongran-system/src/main/java/com/tongran/system/mapper/RmResourceRegistrationMapper.java index 3c77cf1..3fe483c 100644 --- a/tongran-modules/tongran-system/src/main/java/com/tongran/system/mapper/RmResourceRegistrationMapper.java +++ b/tongran-modules/tongran-system/src/main/java/com/tongran/system/mapper/RmResourceRegistrationMapper.java @@ -61,22 +61,12 @@ public interface RmResourceRegistrationMapper */ public int deleteRmResourceRegistrationByIds(Long[] ids); - /** - * 查询所有资源名称([包含设备]功能使用) - * @return 资源注册集合 - */ - public List selectAllResourceName(); /** * 查询是否有此设备 * @param hardwareSn 资源sn * @return 结果 */ public int countBySn(String hardwareSn); - /** - * 查询所有资源名称 - * @return 资源注册集合 - */ - public List selectAllResourceNameByType(RmResourceRegistration resourceRegistration); /** * 检测到服务器离线,修改状态为离线 @@ -106,4 +96,18 @@ public interface RmResourceRegistrationMapper * @return */ List getRegistrationTableInfoList(RmResourceRegistration rmResourceRegistration); + + /** + * 添加服务器标签 + * @param rmResourceRegistration + * @return + */ + int addRemark(RmResourceRegistration rmResourceRegistration); + + /** + * 修改服务器标签 + * @param rmResourceRegistration + * @return + */ + int updateRemark(RmResourceRegistration rmResourceRegistration); } diff --git a/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/IRmResourceRegistrationService.java b/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/IRmResourceRegistrationService.java index 798bc44..fe0c6a8 100644 --- a/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/IRmResourceRegistrationService.java +++ b/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/IRmResourceRegistrationService.java @@ -74,16 +74,6 @@ public interface IRmResourceRegistrationService */ public int deleteRmResourceRegistrationById(Long id); - /** - * 查询所有资源名称(包含设备使用) - * @return 资源注册集合 - */ - public List selectAllResourceName(); - /** - * 查询所有资源名称 - * @return 资源注册集合 - */ - public List selectAllResourceNameByType(RmResourceRegistration resourceRegistration); /** * 检测到服务器离线,修改状态为离线 * @param rmResourceRegistration @@ -128,4 +118,18 @@ public interface IRmResourceRegistrationService * @return */ int bindBusinessByClientIds(RmResourceRegistration rmResourceRegistration); + + /** + * 添加标签 + * @param rmResourceRegistration + * @return + */ + int addRemark(RmResourceRegistration rmResourceRegistration); + + /** + * 修改标签 + * @param rmResourceRegistration + * @return + */ + int updateRemark(RmResourceRegistration rmResourceRegistration); } diff --git a/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/InitialSwitchInfoDetailsServiceImpl.java b/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/InitialSwitchInfoDetailsServiceImpl.java index a15bc2c..0859de6 100644 --- a/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/InitialSwitchInfoDetailsServiceImpl.java +++ b/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/InitialSwitchInfoDetailsServiceImpl.java @@ -3,7 +3,6 @@ package com.tongran.system.service.impl; import com.github.pagehelper.PageInfo; import com.tongran.common.core.domain.R; import com.tongran.common.core.utils.*; -import com.tongran.common.core.web.page.PageDomain; import com.tongran.system.domain.*; import com.tongran.system.enums.ReviewEnum; import com.tongran.system.mapper.*; @@ -27,8 +26,6 @@ import java.util.*; import java.util.function.Function; import java.util.stream.Collectors; -import static com.tongran.common.core.utils.PageUtils.startPage; - /** * 交换机监控信息Service业务层处理 * @@ -1063,10 +1060,6 @@ public class InitialSwitchInfoDetailsServiceImpl implements IInitialSwitchInfoDe // 查询流量信息 initialSwitchInfoDetails.setClientIds(clientIds); initialSwitchInfoDetails.setInterfaceNames(interfaceNames); - PageDomain pageDomain = new PageDomain(); - pageDomain.setPageNum(initialSwitchInfoDetails.getPageNum()); - pageDomain.setPageSize(initialSwitchInfoDetails.getPageSize()); - startPage(pageDomain); List list = getSwitchTrafficDetailsMsgSharding(initialSwitchInfoDetails); PageInfo pageInfo = PaginationUtil.paginate(list, initialSwitchInfoDetails.getPageNum(), initialSwitchInfoDetails.getPageSize()); return pageInfo; diff --git a/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/RmResourceRegistrationServiceImpl.java b/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/RmResourceRegistrationServiceImpl.java index 590e6d9..0b3dadf 100644 --- a/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/RmResourceRegistrationServiceImpl.java +++ b/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/RmResourceRegistrationServiceImpl.java @@ -306,8 +306,7 @@ public class RmResourceRegistrationServiceImpl implements IRmResourceRegistratio @Override public int insertRmResourceRegistration(RmResourceRegistration rmResourceRegistration) { - rmResourceRegistration.setCreatorId(SecurityUtils.getUserId()); - rmResourceRegistration.setCreatorName(SecurityUtils.getUsername()); + rmResourceRegistration.setCreateBy(SecurityUtils.getUsername()); rmResourceRegistration.setCreateTime(DateUtils.getNowDate()); // 查询此硬件sn是否已存在 int exits = rmResourceRegistrationMapper.countBySn(rmResourceRegistration.getHardwareSn()); @@ -327,8 +326,7 @@ public class RmResourceRegistrationServiceImpl implements IRmResourceRegistratio public int updateRmResourceRegistration(RmResourceRegistration rmResourceRegistration) { rmResourceRegistration.setUpdateTime(DateUtils.getNowDate()); - rmResourceRegistration.setUpdaterId(SecurityUtils.getUserId()); - rmResourceRegistration.setUpdaterName(SecurityUtils.getUsername()); + rmResourceRegistration.setUpdateBy(SecurityUtils.getUsername()); // 拿到需要修改的id Long id = rmResourceRegistration.getId(); // 根据id查询sn信息 @@ -380,16 +378,12 @@ public class RmResourceRegistrationServiceImpl implements IRmResourceRegistratio if ("1".equals(rmResourceRegistration.getRegistrationStatus())){ // 拿到需要修改的资源名称 String resourceName = rmResourceRegistration.getResourceName(); - // 拿到需要修改的描述 - String description = rmResourceRegistration.getDescription(); // 初始化 rmResourceRegistration = new RmResourceRegistration(); // id赋值 rmResourceRegistration.setId(id); // 可修改资源名称 rmResourceRegistration.setResourceName(resourceName); - // 可修改描述 - rmResourceRegistration.setDescription(description); } return rmResourceRegistrationMapper.updateRmResourceRegistration(rmResourceRegistration); @@ -405,8 +399,7 @@ public class RmResourceRegistrationServiceImpl implements IRmResourceRegistratio public int register(RmResourceRegistration rmResourceRegistration) { // 设置更新信息 rmResourceRegistration.setUpdateTime(DateUtils.getNowDate()); - rmResourceRegistration.setUpdaterId(SecurityUtils.getUserId()); - rmResourceRegistration.setUpdaterName(SecurityUtils.getUsername()); + rmResourceRegistration.setUpdateBy(SecurityUtils.getUsername()); // 处理服务器资源注册 if ("1".equals(rmResourceRegistration.getResourceType())) { @@ -428,7 +421,6 @@ public class RmResourceRegistrationServiceImpl implements IRmResourceRegistratio config.setNodeName(registration.getResourceName()); config.setCreateTime(DateUtils.getNowDate()); config.setRegistrationStatus(registration.getRegistrationStatus()); - config.setServerIp(registration.getIpAddress()); EpsServerRevenueConfig existing = epsServerRevenueConfigMapper.countBySn(config.getHardwareSn()); if (existing != null) { @@ -459,18 +451,6 @@ public class RmResourceRegistrationServiceImpl implements IRmResourceRegistratio */ private ResourceVo createResourceVo(RmResourceRegistration registration) { ResourceVo resourceVo = new ResourceVo(); - resourceVo.setClientIp(registration.getIpAddress()); - resourceVo.setClientPort(Integer.valueOf(registration.getResourcePort())); - - if (!"1".equals(registration.getResourceType())) { - if("1".equals(registration.getSnmpDetect())){ - Map switchMap = new HashMap<>(); - switchMap.put("community", registration.getTeamName()); - switchMap.put("ip", registration.getSnmpCollectAddr()); - switchMap.put("port", registration.getSnmpCollectPort()); - resourceVo.setSwitchBoard(JSONObject.toJSONString(switchMap)); - } - } return resourceVo; } @@ -506,16 +486,6 @@ public class RmResourceRegistrationServiceImpl implements IRmResourceRegistratio { return rmResourceRegistrationMapper.deleteRmResourceRegistrationById(id); } - @Override - public List selectAllResourceName() - { - return rmResourceRegistrationMapper.selectAllResourceName(); - } - @Override - public List selectAllResourceNameByType(RmResourceRegistration resourceRegistration) - { - return rmResourceRegistrationMapper.selectAllResourceNameByType(resourceRegistration); - } /** * 检测到服务器离线,修改状态为离线 @@ -826,5 +796,17 @@ public class RmResourceRegistrationServiceImpl implements IRmResourceRegistratio return 1; } + @Override + public int addRemark(RmResourceRegistration rmResourceRegistration) { + rmResourceRegistration.setDeployDevice(rmResourceRegistration.getDeployDevice().replace("\n",",")); + int rows = rmResourceRegistrationMapper.addRemark(rmResourceRegistration); + return rows; + } + @Override + public int updateRemark(RmResourceRegistration rmResourceRegistration) { + rmResourceRegistration.setDeployDevice(rmResourceRegistration.getDeployDevice().replace("\n",",")); + int rows = rmResourceRegistrationMapper.updateRemark(rmResourceRegistration); + return rows; + } } diff --git a/tongran-modules/tongran-system/src/main/resources/bootstrap.yml b/tongran-modules/tongran-system/src/main/resources/bootstrap.yml index 6a603c1..ad5c2bf 100644 --- a/tongran-modules/tongran-system/src/main/resources/bootstrap.yml +++ b/tongran-modules/tongran-system/src/main/resources/bootstrap.yml @@ -13,9 +13,7 @@ spring: cloud: nacos: discovery: - server-addr: 172.16.15.52:8848 - # 服务注册地址 -# server-addr: 172.16.15.103:8848 + server-addr: ${spring.cloud.nacos.config.server-addr} namespace: ${spring.cloud.nacos.config.namespace} username: ${spring.cloud.nacos.config.username} password: ${spring.cloud.nacos.config.password} @@ -24,8 +22,7 @@ spring: # 配置中心地址 # server-addr: 172.16.15.103:8848 # namespace: public - namespace: public -# namespace: saas-local + namespace: saas-local username: nacos password: nacos # 配置文件格式 diff --git a/tongran-modules/tongran-system/src/main/resources/mapper/system/RmResourceRegistrationMapper.xml b/tongran-modules/tongran-system/src/main/resources/mapper/system/RmResourceRegistrationMapper.xml index aa4d319..d674b02 100644 --- a/tongran-modules/tongran-system/src/main/resources/mapper/system/RmResourceRegistrationMapper.xml +++ b/tongran-modules/tongran-system/src/main/resources/mapper/system/RmResourceRegistrationMapper.xml @@ -6,99 +6,44 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - + + + + + + + + + + - select id, hardware_sn, resource_type, resource_name, ip_address, resource_port, other_port_name, - agent_version, protocol, resource_version, rw_permission, snmp_detect, team_name, snmp_collect_addr, - snmp_collect_port, security_level, encryption, resource_user_name, resource_pwd, registration_status, - online_status, switch_online_status, description, customer_id, customer_name, service_number, - create_time, update_time, creator_id, creator_name, updater_id, updater_name, client_id, operator, - province, public_ip, business_name, logical_node_id, multi_public_ip_status, heartbeat_count, - heartbeat_interval, onboard_time from rm_resource_registration + select id, client_id, hardware_sn, business_name, logical_node_id, multi_public_ip_status, registration_status, online_status, resource_type, agent_version, create_time, update_time, heartbeat_count, heartbeat_interval, onboard_time, remark, create_by, update_by from rm_resource_registration @@ -111,137 +56,65 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" insert into rm_resource_registration - hardware_sn, - resource_type, - resource_name, - ip_address, - resource_port, - other_port_name, - agent_version, - protocol, - resource_version, - rw_permission, - snmp_detect, - team_name, - snmp_collect_addr, - snmp_collect_port, - security_level, - encryption, - resource_user_name, - resource_pwd, - registration_status, - online_status, - switch_online_status, - description, - customer_id, - customer_name, - service_number, - create_time, - update_time, - creator_id, - creator_name, - updater_id, - updater_name, client_id, - operator, - province, - public_ip, + hardware_sn, business_name, logical_node_id, multi_public_ip_status, + registration_status, + online_status, + resource_type, + agent_version, + create_time, + update_time, heartbeat_count, heartbeat_interval, onboard_time, + remark, + create_by, + update_by, - #{hardwareSn}, - #{resourceType}, - #{resourceName}, - #{ipAddress}, - #{resourcePort}, - #{otherPortName}, - #{agentVersion}, - #{protocol}, - #{resourceVersion}, - #{rwPermission}, - #{snmpDetect}, - #{teamName}, - #{snmpCollectAddr}, - #{snmpCollectPort}, - #{securityLevel}, - #{encryption}, - #{resourceUserName}, - #{resourcePwd}, - #{registrationStatus}, - #{onlineStatus}, - #{switchOnlineStatus}, - #{description}, - #{customerId}, - #{customerName}, - #{serviceNumber}, - #{createTime}, - #{updateTime}, - #{creatorId}, - #{creatorName}, - #{updaterId}, - #{updaterName}, #{clientId}, - #{operator}, - #{province}, - #{publicIp}, + #{hardwareSn}, #{businessName}, #{logicalNodeId}, #{multiPublicIpStatus}, + #{registrationStatus}, + #{onlineStatus}, + #{resourceType}, + #{agentVersion}, + #{createTime}, + #{updateTime}, #{heartbeatCount}, #{heartbeatInterval}, #{onboardTime}, + #{remark}, + #{createBy}, + #{updateBy}, update rm_resource_registration - hardware_sn = #{hardwareSn}, - resource_type = #{resourceType}, - resource_name = #{resourceName}, - ip_address = #{ipAddress}, - resource_port = #{resourcePort}, - other_port_name = #{otherPortName}, - agent_version = #{agentVersion}, - protocol = #{protocol}, - resource_version = #{resourceVersion}, - rw_permission = #{rwPermission}, - snmp_detect = #{snmpDetect}, - team_name = #{teamName}, - snmp_collect_addr = #{snmpCollectAddr}, - snmp_collect_port = #{snmpCollectPort}, - security_level = #{securityLevel}, - encryption = #{encryption}, - resource_user_name = #{resourceUserName}, - resource_pwd = #{resourcePwd}, - registration_status = #{registrationStatus}, - online_status = #{onlineStatus}, - switch_online_status = #{switchOnlineStatus}, - description = #{description}, - customer_id = #{customerId}, - customer_name = #{customerName}, - service_number = #{serviceNumber}, - create_time = #{createTime}, - update_time = #{updateTime}, - creator_id = #{creatorId}, - creator_name = #{creatorName}, - updater_id = #{updaterId}, - updater_name = #{updaterName}, client_id = #{clientId}, - operator = #{operator}, - province = #{province}, - public_ip = #{publicIp}, + hardware_sn = #{hardwareSn}, business_name = #{businessName}, logical_node_id = #{logicalNodeId}, multi_public_ip_status = #{multiPublicIpStatus}, + registration_status = #{registrationStatus}, + online_status = #{onlineStatus}, + resource_type = #{resourceType}, + agent_version = #{agentVersion}, + create_time = #{createTime}, + update_time = #{updateTime}, heartbeat_count = #{heartbeatCount}, heartbeat_interval = #{heartbeatInterval}, onboard_time = #{onboardTime}, + remark = #{remark}, + create_by = #{createBy}, + update_by = #{updateBy}, where id = #{id} @@ -256,52 +129,6 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" #{id} - - - - + + update rm_resource_registration set remark = #{remark} + where client_id in + + #{clientId} + + + + update rm_resource_registration set remark = + CASE + WHEN remark IS NULL OR remark = '' THEN #{remark} + ELSE CONCAT(remark, ',', #{remark}) + END + where client_id in + + #{clientId} + + \ No newline at end of file diff --git a/tongran-rocketmq/src/main/resources/bootstrap.yml b/tongran-rocketmq/src/main/resources/bootstrap.yml index 2c101a9..afbe057 100644 --- a/tongran-rocketmq/src/main/resources/bootstrap.yml +++ b/tongran-rocketmq/src/main/resources/bootstrap.yml @@ -14,8 +14,7 @@ spring: nacos: discovery: # 服务注册地址 - server-addr: 172.16.15.52:8848 -# server-addr: 172.16.15.103:8848 + server-addr: ${spring.cloud.nacos.config.server-addr} namespace: ${spring.cloud.nacos.config.namespace} username: ${spring.cloud.nacos.config.username} password: ${spring.cloud.nacos.config.password} @@ -23,8 +22,8 @@ spring: # 配置中心地址 server-addr: 172.16.15.52:8848 # server-addr: 172.16.15.103:8848 -# namespace: saas-local - namespace: public + namespace: saas-local +# namespace: public username: nacos password: nacos # 配置文件格式