Skip to content

WGCLOUD
WGCLOUD

tianshiyeben / WGCLOUD

通知 3
Star 0
Fork 0
WGCLOUD
WGCLOUD

前往新版Gitcode，体验更适合开发者的 AI 搜索 >>

提交 3d05c8e1 编写于 作者: tianshiyeben's avatar tianshiyeben
浏览文件
操作

no message

上级 181044f3
展开全部 隐藏空白更改
内联 并排
Showing with 202297 addition and 0 deletion

要显示的变更太多。

To preserve performance only 1000 of 1000+ files are displayed.
文本差异 电子邮件补丁
.gitattributes 0 → 100644
浏览文件 @ 3d05c8e1
*.js linguist-language=java
*.css linguist-language=java
*.html linguist-language=java
README.md 0 → 100644
浏览文件 @ 3d05c8e1
## WGCLOUD
服务器集群监控，运维监控，网络吞吐率，服务器cpu监控，内存监控。
## **下载**
http://www.wgstart.com
![a.jpg](./demo/a.jpg)
![b.jpg](./demo/b.jpg)
![c.jpg](./demo/c.jpg)
![d.jpg](./demo/d.jpg)
## 运行环境
1.JDK1.8
2.tomcat8.5+
3.mysql5.6 或 5.7
4.CentOS6.4或以上，Red Hat6.4或以上，其他系统暂不支持
## 源码使用
在eclispe新建一个java web maven工程，使用src替换新建工程的src目录，使用pom.xml替换工程里的pom.xml，设置好jdk1.8即可。
sql文件夹里是数据库脚本，在mysql新建名为dats的数据库，然后执行dats.sql脚本初始化表。
application.properties，配置数据库链接等信息，里面有注释说明。
host.properties，配置被监控主机信息，格式为ip=端口//主机用户名//主机密码，可以配置多个，尽量不要使用root账号。
本应用会通过host.properties信息来读取被监控主机状态，所以被监控主机不需要安装WGCLOUD。
## 更新记录
- 2019.2.26
修复了清楚历史数据的任务机制
修复了应用监控的bug
删除多余的注释及其他优化
## 联系
QQ群：623503772
README_en.md 0 → 100644
浏览文件 @ 3d05c8e1
## WGCLOUD
Linux performance monitoring tools, operation and maintenance monitoring, network throughput, server CPU monitoring, memory monitoring
![a.jpg](./demo/a.jpg)
![b.jpg](./demo/b.jpg)
![c.jpg](./demo/c.jpg)
## Dependent environment
1.JDK1.8
2.tomcat8.5+
3.mysql5.6+
4.CentOS 6.4 or above, Red Hat 6.4 or above, not supported by other systems
5.Check whether the monitored HOST host has installed sysstat. The following information indicates that it has been installed. If not, please install it through Yum install sysstat.
```
[root@localhost ~]# mpstat
Linux 3.10.0-514.el7.x86_64 (localhost.localdomain) 2019年01月10日 _x86_64_ (4 CPU)
13时40分26秒 CPU %usr %nice %sys %iowait %irq %soft %steal %guest %gnice %idle
13时40分26秒 all 0.60 0.00 0.19 0.16 0.00 0.03 0.00 0.00 0.00 99.02
```
## Source code usage
To build a new web Maven project with eclispe, use SRC to replace the SRC directory of the new project, use pom. XML to replace the pom. XML in the new project, and set jdk.
SQL folder is the database creation script. Create a new database named dats in MySQL and execute the dats. SQL script
Application. properties, configure database link information
Host. properties, configure monitoring server information in the format of IP = port // username // password, you can configure more than one, try not to use root account
Because the application will get the running status from the target server by configuring the host. properties information, the monitored server does not need to install the application.
## Monitoring index
```
%usr: User CPU time (%)
%sys: core time (%)
%idle: idle time (%)
%iowait: IO wait time (%)
Rxpck/s: Packets received per second
Txpck/s: Packets sent per second
RxkB/s: KB received per second
TxkB/s: KB sent per second
Active/s: The number of locally initiated TCP connections per second, both created through connection calls
Pasve/s: Number of remotely initiated TCP connections per second, that is, TCP connections created through accept calls
%CPU: Process occupancy CPU utilization
%MEM: Percentage of physical and total memory used by processes
R/s, w/s, rkB/s, wkB/s: Represents the number of reads and writes per second and the amount of reads and writes per second (kilobytes), respectively. Excessive reading and writing may cause performance problems.
Await: The average waiting time for an IO operation in milliseconds. This is the time spent by applications interacting with disks, including IO waiting and actual operation.
If this value is too large, it may be that the hardware device has encountered bottlenecks or malfunctions.
Avgqu-sz: The average number of requests to the device. If this value is greater than 1, it may be that the hardware device is saturated (some front-end hardware devices support parallel writing).
%util: Equipment utilization. This value indicates the busyness of the device, and the empirical value is that if it exceeds 60, it may affect IO performance (referring to the average waiting time for IO operations).
If it reaches 100%, the hardware is saturated.
```
## How to delete the server information when the connection fails
The server empties the failed server information every three days, so you can't see the failed server information after three days. At present, manual operation is not supported, all of which are handled automatically by the system.
At the same time, the system will regularly clear the monitoring information 30 days ago.
## Warning prompt rule
The threshold of system memory usage is 99%. If it exceeds sending mail, it will not be repeated 24 hours.
The alarm percentage threshold of process memory monitoring is 99%. If the alarm percentage exceeds the sending mail, it will not be repeated 24 hours.
Process CPU usage monitoring alarm percentage threshold of 99%, more than sending mail, 24 hours will not be repeated.
If you don't want to receive alert notification, you can turn off the alert in applications. properties.
## Access address
http://localhost:9000/wgcloud
Login account/password：admin/111111
## contact
email：tianshiyeben@qq.com
mysql8对应配置/application.properties 0 → 100644
浏览文件 @ 3d05c8e1
jdbc.driver=com.mysql.cj.jdbc.Driver
jdbc.url=jdbc:mysql://192.168.1.12:3306/dats?useUnicode=true&characterEncoding=UTF-8
jdbc.username=root
jdbc.password=123456
#登陆账号admin的密码
admindPwd=111111
#是否发送邮件告警,1发送0不发送
sendMail=0
#sendMail=0时候，不需要配置下面参数
#发送邮箱的帐号
fromMailName=123456@qq.com
#发送邮箱的密码
fromPwd=123456
#发送邮箱的SMTP服务器
smtpHost=smtp.qq.com
#发送邮箱的SMTP端口,25或465
smtpPort=25
#发送邮箱是否启用安全链接(SSL),1启用,0不启用
smtpSSL=0
#接受告警信息的邮件
toMail=123456@qq.com
\ No newline at end of file
mysql8对应配置/pom.xml 0 → 100644
浏览文件 @ 3d05c8e1
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.wgcloud</groupId>
<artifactId>wgcloud</artifactId>
<packaging>war</packaging>
<version>0.0.1-SNAPSHOT</version>
<name>wgcloud Maven Webapp</name>
<url>http://maven.apache.org</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.build.java.version>1.8</project.build.java.version>
</properties>
<repositories>
<repository>
<id>nexus-aliyun</id>
<name>Nexus aliyun</name>
<url>http://maven.aliyun.com/nexus/content/groups/public</url>
<releases><enabled>true</enabled></releases>
<snapshots><enabled>false</enabled></snapshots>
</repository>
<repository>
<id>central-repos</id>
<name>Central Repository</name>
<url>http://repo.maven.apache.org/maven2</url>
</repository>
<repository>
<id>central-repos2</id>
<name>Central Repository 2</name>
<url>http://repo1.maven.org/maven2/</url>
</repository>
</repositories>
<pluginRepositories>
<pluginRepository>
<id>nexus-aliyun</id>
<name>Nexus aliyun</name>
<url>http://maven.aliyun.com/nexus/content/groups/public</url>
<releases><enabled>true</enabled></releases>
<snapshots><enabled>false</enabled></snapshots>
</pluginRepository>
<pluginRepository>
<id>central-repos</id>
<name>Central Repository</name>
<url>http://repo.maven.apache.org/maven2</url>
</pluginRepository>
<pluginRepository>
<id>central-repos2</id>
<name>Central Repository 2</name>
<url>http://repo1.maven.org/maven2/</url>
</pluginRepository>
</pluginRepositories>
<build>
<finalName>${project.artifactId}</finalName>
<sourceDirectory>src/main/java</sourceDirectory>
<resources>
<resource>
<directory>src/main/resources</directory>
<filtering>true</filtering>
<includes>
<include>*.*</include>
<include>**/*.xml</include>
</includes>
</resource>
</resources>
<defaultGoal>install</defaultGoal>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.1</version>
<configuration>
<source>${project.build.java.version}</source>
<target>${project.build.java.version}</target>
<encoding>${project.build.sourceEncoding}</encoding>
</configuration>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-war-plugin</artifactId>
<version>3.1.0</version>
<configuration>
<webXml>src\main\webapp\WEB-INF\web.xml</webXml>
<warSourceDirectory>src\main\webapp</warSourceDirectory>
<webResources>
<resource>
<directory>target/classes</directory>
<targetPath>WEB-INF/classes</targetPath>
</resource>
</webResources>
</configuration>
</plugin>
</plugins>
</build>
<dependencies>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>4.3.17.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
<version>4.3.17.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-tx</artifactId>
<version>4.3.17.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>4.3.17.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-orm</artifactId>
<version>4.3.17.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>4.3.17.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-commons</artifactId>
<version>1.9.1.RELEASE</version>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>javax.servlet-api</artifactId>
<version>3.1.0</version>
</dependency>
<dependency>
<groupId>javax.inject</groupId>
<artifactId>javax.inject</artifactId>
<version>1</version>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpcore</artifactId>
<version>4.3.1</version>
</dependency>
<dependency>
<groupId>commons-collections</groupId>
<artifactId>commons-collections</artifactId>
<version>3.2.1</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-email</artifactId>
<version>1.2</version>
</dependency>
<dependency>
<groupId>commons-codec</groupId>
<artifactId>commons-codec</artifactId>
<version>1.8</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.11</version>
</dependency>
<dependency>
<groupId>ch.ethz.ganymed</groupId>
<artifactId>ganymed-ssh2</artifactId>
<version>262</version>
</dependency>
<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
<version>17.0</version>
</dependency>
<dependency>
<groupId>math.geom2d</groupId>
<artifactId>javaGeom</artifactId>
<version>0.11.1</version>
</dependency>
<dependency>
<groupId>commons-fileupload</groupId>
<artifactId>commons-fileupload</artifactId>
<version>1.3</version>
</dependency>
<dependency>
<groupId>joda-time</groupId>
<artifactId>joda-time</artifactId>
<version>2.8.2</version>
</dependency>
<dependency>
<groupId>org.joda</groupId>
<artifactId>joda-convert</artifactId>
<version>1.2</version>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>jstl</artifactId>
<version>1.2</version>
</dependency>
<dependency>
<groupId>javax.mail</groupId>
<artifactId>javax.mail-api</artifactId>
<version>1.4.7</version>
</dependency>
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper</artifactId>
<version>5.1.8</version>
</dependency>
<dependency>
<groupId>commons-validator</groupId>
<artifactId>commons-validator</artifactId>
<version>1.4.0</version>
</dependency>
<dependency>
<groupId>net.sf.json-lib</groupId>
<artifactId>json-lib</artifactId>
<version>2.4</version>
<classifier>jdk15</classifier>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.7</version>
</dependency>
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis-spring</artifactId>
<version>1.3.2</version>
</dependency>
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>3.4.6</version>
</dependency>
<dependency>
<groupId>javax.servlet.jsp.jstl</groupId>
<artifactId>jstl</artifactId>
<version>1.2</version>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
<version>1.2.3</version>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
<version>1.2.3</version>
</dependency>
</dependencies>
</project>
\ No newline at end of file
pom.xml 0 → 100644
浏览文件 @ 3d05c8e1
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.wgcloud</groupId>
<artifactId>wgcloud</artifactId>
<packaging>war</packaging>
<version>0.0.1-SNAPSHOT</version>
<name>wgcloud Maven Webapp</name>
<url>http://maven.apache.org</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.build.java.version>1.8</project.build.java.version>
</properties>
<repositories>
<repository>
<id>nexus-aliyun</id>
<name>Nexus aliyun</name>
<url>http://maven.aliyun.com/nexus/content/groups/public</url>
<releases><enabled>true</enabled></releases>
<snapshots><enabled>false</enabled></snapshots>
</repository>
<repository>
<id>central-repos</id>
<name>Central Repository</name>
<url>http://repo.maven.apache.org/maven2</url>
</repository>
<repository>
<id>central-repos2</id>
<name>Central Repository 2</name>
<url>http://repo1.maven.org/maven2/</url>
</repository>
</repositories>
<pluginRepositories>
<pluginRepository>
<id>nexus-aliyun</id>
<name>Nexus aliyun</name>
<url>http://maven.aliyun.com/nexus/content/groups/public</url>
<releases><enabled>true</enabled></releases>
<snapshots><enabled>false</enabled></snapshots>
</pluginRepository>
<pluginRepository>
<id>central-repos</id>
<name>Central Repository</name>
<url>http://repo.maven.apache.org/maven2</url>
</pluginRepository>
<pluginRepository>
<id>central-repos2</id>
<name>Central Repository 2</name>
<url>http://repo1.maven.org/maven2/</url>
</pluginRepository>
</pluginRepositories>
<build>
<finalName>${project.artifactId}</finalName>
<sourceDirectory>src/main/java</sourceDirectory>
<resources>
<resource>
<directory>src/main/resources</directory>
<filtering>true</filtering>
<includes>
<include>*.*</include>
<include>**/*.xml</include>
</includes>
</resource>
</resources>
<defaultGoal>install</defaultGoal>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.1</version>
<configuration>
<source>${project.build.java.version}</source>
<target>${project.build.java.version}</target>
<encoding>${project.build.sourceEncoding}</encoding>
</configuration>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-war-plugin</artifactId>
<version>3.1.0</version>
<configuration>
<webXml>src\main\webapp\WEB-INF\web.xml</webXml>
<warSourceDirectory>src\main\webapp</warSourceDirectory>
<webResources>
<resource>
<directory>target/classes</directory>
<targetPath>WEB-INF/classes</targetPath>
</resource>
</webResources>
</configuration>
</plugin>
</plugins>
</build>
<dependencies>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>4.3.17.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
<version>4.3.17.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-tx</artifactId>
<version>4.3.17.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>4.3.17.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-orm</artifactId>
<version>4.3.17.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>4.3.17.RELEASE</version>
</dependency>
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-commons</artifactId>
<version>1.9.1.RELEASE</version>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>javax.servlet-api</artifactId>
<version>3.1.0</version>
</dependency>
<dependency>
<groupId>javax.inject</groupId>
<artifactId>javax.inject</artifactId>
<version>1</version>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpcore</artifactId>
<version>4.3.1</version>
</dependency>
<dependency>
<groupId>commons-collections</groupId>
<artifactId>commons-collections</artifactId>
<version>3.2.1</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-email</artifactId>
<version>1.2</version>
</dependency>
<dependency>
<groupId>commons-codec</groupId>
<artifactId>commons-codec</artifactId>
<version>1.8</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.30</version>
</dependency>
<dependency>
<groupId>ch.ethz.ganymed</groupId>
<artifactId>ganymed-ssh2</artifactId>
<version>262</version>
</dependency>
<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
<version>17.0</version>
</dependency>
<dependency>
<groupId>math.geom2d</groupId>
<artifactId>javaGeom</artifactId>
<version>0.11.1</version>
</dependency>
<dependency>
<groupId>commons-fileupload</groupId>
<artifactId>commons-fileupload</artifactId>
<version>1.3</version>
</dependency>
<dependency>
<groupId>joda-time</groupId>
<artifactId>joda-time</artifactId>
<version>2.8.2</version>
</dependency>
<dependency>
<groupId>org.joda</groupId>
<artifactId>joda-convert</artifactId>
<version>1.2</version>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>jstl</artifactId>
<version>1.2</version>
</dependency>
<dependency>
<groupId>javax.mail</groupId>
<artifactId>javax.mail-api</artifactId>
<version>1.4.7</version>
</dependency>
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper</artifactId>
<version>5.1.8</version>
</dependency>
<dependency>
<groupId>commons-validator</groupId>
<artifactId>commons-validator</artifactId>
<version>1.4.0</version>
</dependency>
<dependency>
<groupId>net.sf.json-lib</groupId>
<artifactId>json-lib</artifactId>
<version>2.4</version>
<classifier>jdk15</classifier>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.7</version>
</dependency>
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis-spring</artifactId>
<version>1.3.2</version>
</dependency>
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>3.4.6</version>
</dependency>
<dependency>
<groupId>javax.servlet.jsp.jstl</groupId>
<artifactId>jstl</artifactId>
<version>1.2</version>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
<version>1.2.3</version>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
<version>1.2.3</version>
</dependency>
</dependencies>
</project>
\ No newline at end of file
sql/dats.sql 0 → 100644
浏览文件 @ 3d05c8e1
/*
Navicat MySQL Data Transfer
Source Server : 127.0.0.1
Source Server Version : 50717
Source Host : localhost:3306
Source Database : dats
Target Server Type : MYSQL
Target Server Version : 50717
File Encoding : 65001
Date: 2019-01-03 09:38:43
*/
SET FOREIGN_KEY_CHECKS=0;
-- ----------------------------
-- Table structure for app_info
-- ----------------------------
DROP TABLE IF EXISTS `app_info`;
CREATE TABLE `app_info` (
`ID` char(32) NOT NULL,
`ACCOUNT_ID` char(32) DEFAULT NULL,
`ACCOUNT` char(30) DEFAULT NULL,
`HOST_NAME` char(30) DEFAULT NULL,
`APP_PID` char(15) DEFAULT NULL,
`CREATE_TIME` timestamp NULL DEFAULT NULL,
`APP_NAME` varchar(50) DEFAULT NULL,
PRIMARY KEY (`ID`),
KEY `APP_INFO_INDEX` (`ACCOUNT_ID`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of app_info
-- ----------------------------
-- ----------------------------
-- Table structure for app_state
-- ----------------------------
DROP TABLE IF EXISTS `app_state`;
CREATE TABLE `app_state` (
`ID` char(32) NOT NULL,
`APP_INFO_ID` char(32) DEFAULT NULL,
`CPU_PER` char(10) DEFAULT NULL,
`MEM_PER` char(10) DEFAULT NULL,
`CREATE_TIME` timestamp NULL DEFAULT NULL,
PRIMARY KEY (`ID`),
KEY `APP_STAT_INDEX` (`APP_INFO_ID`,`CREATE_TIME`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of app_state
-- ----------------------------
-- ----------------------------
-- Table structure for cpu_state
-- ----------------------------
DROP TABLE IF EXISTS `cpu_state`;
CREATE TABLE `cpu_state` (
`ID` char(32) NOT NULL,
`ACCOUNT_ID` char(32) DEFAULT NULL,
`ACCOUNT` char(30) DEFAULT NULL,
`HOST_NAME` char(30) DEFAULT NULL,
`USER` char(30) DEFAULT NULL,
`SYS` char(30) DEFAULT NULL,
`IDLE` char(30) DEFAULT NULL,
`IOWAIT` char(30) DEFAULT NULL,
`IRQ` char(30) DEFAULT NULL,
`SOFT` char(30) DEFAULT NULL,
`DATE_STR` char(30) DEFAULT NULL,
`CREATE_TIME` timestamp NULL DEFAULT NULL,
PRIMARY KEY (`ID`),
KEY `CPU_ACC_HOST_INDEX` (`ACCOUNT_ID`,`HOST_NAME`,`CREATE_TIME`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of cpu_state
-- ----------------------------
-- ----------------------------
-- Table structure for desk_state
-- ----------------------------
DROP TABLE IF EXISTS `desk_state`;
CREATE TABLE `desk_state` (
`ID` char(32) NOT NULL,
`ACCOUNT_ID` char(32) DEFAULT NULL,
`ACCOUNT` char(30) DEFAULT NULL,
`HOST_NAME` char(30) DEFAULT NULL,
`FILE_STSTEM` char(30) DEFAULT NULL,
`SIZE` char(30) DEFAULT NULL,
`USED` char(30) DEFAULT NULL,
`AVAIL` char(30) DEFAULT NULL,
`USE_PER` char(10) DEFAULT NULL,
`DATE_STR` char(30) DEFAULT NULL,
`CREATE_TIME` timestamp NULL DEFAULT NULL,
PRIMARY KEY (`ID`),
KEY `DESK_ACC_HOST_INDEX` (`ACCOUNT_ID`,`HOST_NAME`,`CREATE_TIME`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of desk_state
-- ----------------------------
-- ----------------------------
-- Table structure for diskio_state
-- ----------------------------
DROP TABLE IF EXISTS `diskio_state`;
CREATE TABLE `diskio_state` (
`ID` char(32) COLLATE utf8_unicode_ci NOT NULL,
`ACCOUNT_ID` char(32) COLLATE utf8_unicode_ci DEFAULT NULL,
`ACCOUNT` char(30) COLLATE utf8_unicode_ci DEFAULT NULL,
`HOST_NAME` char(30) COLLATE utf8_unicode_ci DEFAULT NULL,
`RS` char(30) COLLATE utf8_unicode_ci DEFAULT NULL,
`WS` char(30) COLLATE utf8_unicode_ci DEFAULT NULL,
`RKBS` char(30) COLLATE utf8_unicode_ci DEFAULT NULL,
`WKBS` char(30) COLLATE utf8_unicode_ci DEFAULT NULL,
`AWAIT` char(30) COLLATE utf8_unicode_ci DEFAULT NULL,
`AVGQUSZ` char(30) COLLATE utf8_unicode_ci DEFAULT NULL,
`UTIL` char(30) COLLATE utf8_unicode_ci DEFAULT NULL,
`CREATE_TIME` timestamp NULL DEFAULT NULL,
`DATE_STR` char(30) COLLATE utf8_unicode_ci DEFAULT NULL,
PRIMARY KEY (`ID`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;
-- ----------------------------
-- Records of diskio_state
-- ----------------------------
-- ----------------------------
-- Table structure for intrusion_info
-- ----------------------------
DROP TABLE IF EXISTS `intrusion_info`;
CREATE TABLE `intrusion_info` (
`ID` char(32) NOT NULL,
`ACCOUNT_ID` char(32) DEFAULT NULL,
`ACCOUNT` char(10) DEFAULT NULL,
`HOST_NAME` char(30) DEFAULT NULL,
`LSMOD` text,
`PASSWD_INFO` varchar(100) DEFAULT NULL,
`CRONTAB` text,
`PROMISC` varchar(100) DEFAULT NULL,
`RPCINFO` text,
`CREATE_TIME` timestamp NULL DEFAULT NULL,
PRIMARY KEY (`ID`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of intrusion_info
-- ----------------------------
-- ----------------------------
-- Table structure for log_info
-- ----------------------------
DROP TABLE IF EXISTS `log_info`;
CREATE TABLE `log_info` (
`ID` char(32) NOT NULL,
`ACCOUNT` char(50) DEFAULT NULL,
`HOST_NAME` char(30) DEFAULT NULL,
`INFO_CONTENT` varchar(500) DEFAULT NULL,
`STATE` char(1) DEFAULT NULL,
`CREATE_TIME` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
PRIMARY KEY (`ID`),
KEY `LOG_ACCOUNT_INDEX` (`ACCOUNT`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of log_info
-- ----------------------------
-- ----------------------------
-- Table structure for mem_state
-- ----------------------------
DROP TABLE IF EXISTS `mem_state`;
CREATE TABLE `mem_state` (
`ID` char(32) NOT NULL,
`ACCOUNT_ID` char(32) DEFAULT NULL,
`ACCOUNT` char(30) DEFAULT NULL,
`HOST_NAME` char(30) DEFAULT NULL,
`TOTAL` char(30) DEFAULT NULL,
`USED` char(30) DEFAULT NULL,
`FREE` char(30) DEFAULT NULL,
`USE_PER` char(10) DEFAULT NULL,
`DATE_STR` char(30) DEFAULT NULL,
`CREATE_TIME` timestamp NULL DEFAULT NULL,
PRIMARY KEY (`ID`),
KEY `MEM_ACC_HOST_INDEX` (`ACCOUNT_ID`,`HOST_NAME`,`CREATE_TIME`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of mem_state
-- ----------------------------
-- ----------------------------
-- Table structure for msg_info
-- ----------------------------
DROP TABLE IF EXISTS `msg_info`;
CREATE TABLE `msg_info` (
`ID` char(32) NOT NULL,
`ACCEPT_INFO` char(50) DEFAULT NULL,
`INFO_CONTENT` varchar(255) DEFAULT NULL,
`MSG_TITLE` varchar(100) DEFAULT NULL,
`CREATE_TIME` timestamp NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP,
`ACCOUNT_ID` char(32) DEFAULT NULL,
`ACCOUNT` char(30) DEFAULT NULL,
PRIMARY KEY (`ID`),
KEY `MSG_ACCOUNT_INDEX` (`ACCOUNT`) USING BTREE,
KEY `MSG_ACCEPT_INDEX` (`ACCEPT_INFO`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of msg_info
-- ----------------------------
-- ----------------------------
-- Table structure for netio_state
-- ----------------------------
DROP TABLE IF EXISTS `netio_state`;
CREATE TABLE `netio_state` (
`ID` char(32) NOT NULL,
`ACCOUNT_ID` char(32) DEFAULT NULL,
`ACCOUNT` char(30) DEFAULT NULL,
`HOST_NAME` char(30) DEFAULT NULL,
`RXPCK` char(30) DEFAULT NULL,
`TXPCK` char(30) DEFAULT NULL,
`RXBYT` char(30) DEFAULT NULL,
`TXBYT` char(30) DEFAULT NULL,
`RXCMP` char(30) DEFAULT NULL,
`TXCMP` char(30) DEFAULT NULL,
`RXMCST` char(30) DEFAULT NULL,
`DATE_STR` char(30) DEFAULT NULL,
`CREATE_TIME` timestamp NULL DEFAULT NULL,
PRIMARY KEY (`ID`),
KEY `NETIO_ACC_HOST_INDEX` (`ACCOUNT_ID`,`HOST_NAME`,`CREATE_TIME`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of netio_state
-- ----------------------------
-- ----------------------------
-- Table structure for system_info
-- ----------------------------
DROP TABLE IF EXISTS `system_info`;
CREATE TABLE `system_info` (
`ID` char(32) NOT NULL,
`ACCOUNT_ID` char(32) DEFAULT NULL,
`ACCOUNT` char(30) DEFAULT NULL,
`HOST_NAME` char(30) DEFAULT NULL,
`VERSION` char(100) DEFAULT NULL,
`VERSION_DETAIL` char(200) DEFAULT NULL,
`CPU_NUM` char(30) DEFAULT NULL,
`YX_DAYS` char(10) DEFAULT NULL,
`CPU_CORE_NUM` char(10) DEFAULT NULL,
`CREATE_TIME` timestamp NULL DEFAULT NULL,
`CPU_XH` char(150) DEFAULT NULL,
PRIMARY KEY (`ID`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of system_info
-- ----------------------------
-- ----------------------------
-- Table structure for sys_load_state
-- ----------------------------
DROP TABLE IF EXISTS `sys_load_state`;
CREATE TABLE `sys_load_state` (
`ID` char(32) NOT NULL,
`ACCOUNT_ID` char(32) DEFAULT NULL,
`ACCOUNT` char(30) DEFAULT NULL,
`HOST_NAME` char(30) DEFAULT NULL,
`ONE_LOAD` char(30) DEFAULT NULL,
`FIVE_LOAD` char(30) DEFAULT NULL,
`FIFTEEN_LOAD` char(30) DEFAULT NULL,
`USERS` char(10) DEFAULT NULL,
`DATE_STR` char(30) DEFAULT NULL,
`CREATE_TIME` timestamp NULL DEFAULT NULL,
PRIMARY KEY (`ID`),
KEY `LOAD_ACC_HOST_INDEX` (`ACCOUNT_ID`,`HOST_NAME`,`CREATE_TIME`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of sys_load_state
-- ----------------------------
-- ----------------------------
-- Table structure for tcp_state
-- ----------------------------
DROP TABLE IF EXISTS `tcp_state`;
CREATE TABLE `tcp_state` (
`ID` char(32) NOT NULL,
`ACCOUNT_ID` char(32) DEFAULT NULL,
`ACCOUNT` char(30) DEFAULT NULL,
`HOST_NAME` char(30) DEFAULT NULL,
`ACTIVE` char(30) DEFAULT NULL,
`PASSIVE` char(30) DEFAULT NULL,
`RETRANS` char(30) DEFAULT NULL,
`DATE_STR` char(30) DEFAULT NULL,
`CREATE_TIME` timestamp NULL DEFAULT NULL,
PRIMARY KEY (`ID`),
KEY `TCP_ACC_HOST_INDEX` (`ACCOUNT_ID`,`HOST_NAME`,`CREATE_TIME`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of tcp_state
-- ----------------------------
src/main/java/com/common/AppInit.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.common;
import java.util.Iterator;
import java.util.Set;
import java.util.Timer;
import java.util.TimerTask;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.core.timer.impl.BatchCommitJobImpl;
import com.core.timer.impl.MonitorDayJobImpl;
import com.util.HostInfo;
import com.util.MyDayTask;
import com.util.MyHourTask;
import com.util.MyMinTask;
import com.util.PropertyUtil;
import com.util.staticvar.StaticKeys;
/**
*
* @ClassName:AppInit.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: AppInit.java
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
public class AppInit implements ServletContextListener{
private static final Logger logger = LoggerFactory.getLogger(AppInit.class);
//邮件帐号
public static String fromMailName = "";
//邮件密码
public static String fromPwd = "";
//SMTP服务器
public static String smtpHost = "";
//SMTP端口
public static String smtpPort="";
//是否使用SSL，0不使用，1使用
public static String smtpSSL="";
//admin管理员密码
public static String admindPwd= "111111";
//是否发送邮件告警标识
public static String sendMail = "1";
//接受邮件的地址
public static String toMail = "";
/* (non-Javadoc)
* @see javax.servlet.ServletContextListener#contextDestroyed(javax.servlet.ServletContextEvent)
*/
@Override
public void contextDestroyed(ServletContextEvent arg0) {
// TODO Auto-generated method stub
}
/* (non-Javadoc)
* @see javax.servlet.ServletContextListener#contextInitialized(javax.servlet.ServletContextEvent)
*/
@Override
public void contextInitialized(ServletContextEvent arg0) {
//从配置文件读取邮箱用户名
fromMailName = PropertyUtil.get("application.properties", "fromMailName");
//从配置文件读取邮箱密码
fromPwd = PropertyUtil.get("application.properties", "fromPwd");
//从配置文件读取smtp服务器
smtpHost = PropertyUtil.get("application.properties", "smtpHost");
//从配置文件读取smtp端口
smtpPort = PropertyUtil.get("application.properties", "smtpPort");
//从配置文件读取smtpSSL标识
smtpSSL = PropertyUtil.get("application.properties", "smtpSSL");
//从配置文件读取管理员密码
admindPwd = PropertyUtil.get("application.properties", "admindPwd");
//是否发送邮件告警标识,1发送0不发送
sendMail = PropertyUtil.get("application.properties", "sendMail");
//接受邮件的地址
toMail = PropertyUtil.get("application.properties", "toMail");
TimerTask dayTask = new MonitorDayJobImpl();
TimerTask minTask = new BatchCommitJobImpl();
Timer timer = new Timer();
//1分钟后执行，之后每隔24小时执行
timer.schedule(dayTask, 60000,24*60*60*1000);
//10分钟后执行，之后每隔5分钟执行
timer.schedule(minTask, 600000,5*60*1000);
//从配置文件加载host信息
Set<String> set = PropertyUtil.getKeys(""+StaticKeys.HOST_PRO_FILE);
Iterator<String> iter = set.iterator();
while(iter.hasNext()){
HostInfo hostInfo = new HostInfo();
hostInfo.setHostname(iter.next());
String hostStr = PropertyUtil.get(""+StaticKeys.HOST_PRO_FILE, hostInfo.getHostname());
if(StringUtils.isEmpty(hostStr)){
break;
}
hostStr = hostStr.trim();
hostInfo.setSshPort(Integer.valueOf(hostStr.split("//")[0]));
hostInfo.setUsername(hostStr.split("//")[1]);
hostInfo.setPassword(hostStr.split("//")[2]);
StaticKeys.hostInfoList.add(hostInfo);
}
TimerTask dayClientTask = new MyDayTask();
TimerTask hourClientTask = new MyHourTask();
TimerTask minClientTask = new MyMinTask();
Timer timerClient = new Timer();
//2分钟后执行，之后每隔2小时执行
timerClient.schedule(hourClientTask, 120000,2*60*60*1000);
//9分钟后执行，之后每隔24小时执行
timerClient.schedule(dayClientTask, 540000,24*60*60*1000);
//16分钟后执行，之后每隔10分钟执行
timerClient.schedule(minClientTask, 960000,10*60*1000);
}
}
src/main/java/com/common/ApplicationContextHelper.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.common;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.stereotype.Component;
/**
*
* @ClassName:ApplicationContextHelper.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: ApplicationContextHelper.java
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
@Component
public class ApplicationContextHelper implements ApplicationContextAware {
private static ApplicationContext applicationContext;
@Override
public void setApplicationContext( ApplicationContext applicationContext1 ) throws BeansException {
applicationContext = applicationContext1;
}
public static ApplicationContext getApplicationContext(){
return applicationContext;
}
@SuppressWarnings("unchecked")
public static <T> T getBean(Class<T> clazz) {
return (T) applicationContext.getBean(clazz);
}
}
\ No newline at end of file
src/main/java/com/common/LoginInterceptor.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.common;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.springframework.web.servlet.HandlerInterceptor;
import org.springframework.web.servlet.ModelAndView;
import com.util.staticvar.StaticKeys;
/**
*
* @ClassName:LoginInterceptor.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: LoginInterceptor.java
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
public class LoginInterceptor implements HandlerInterceptor {
String[] static_resource = {"login/toLogin","login/login","sys/code",".css",".js",".jpg",".png",".ico",".gif","font"};
@Override
public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object o) throws Exception {
String uri = request.getRequestURI();
for (String ss : static_resource) {
if (uri.indexOf(ss) != -1) {
return true;
}
}
Object user = request.getSession().getAttribute(StaticKeys.LOGIN_KEY);
if (user != null) {
return true;
}
response.sendRedirect("/wgcloud/sys/login/toLogin");
return false;
}
@Override
public void postHandle(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, Object o, ModelAndView modelAndView) throws Exception {
}
@Override
public void afterCompletion(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, Object o, Exception e) throws Exception {
}
}
\ No newline at end of file
src/main/java/com/common/Page.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.common;
import java.io.Serializable;
import java.util.Collections;
import java.util.List;
/**
*
* @ClassName:Page.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: Page.java
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
@SuppressWarnings("serial")
public class Page implements Serializable {
public static final Page EMPTY_PAGE = new Page(Collections.EMPTY_LIST, 0, 0, 0);
@SuppressWarnings("rawtypes")
private List objects;
private int pageSize;
private int totalNumber;
private int totalPage;
private int currentPage;
private int viewCountPages;
public Page(){}
@SuppressWarnings({ "rawtypes" })
public Page(List objects, int pageSize, int totalNum, int currentPage) {
if (objects.equals(Collections.EMPTY_LIST)) {
this.objects = objects;
}else{
this.objects = objects;
this.totalNumber = totalNum;
this.currentPage = currentPage;
this.pageSize = pageSize;
this.totalPage = (totalNumber - 1) / pageSize + 1;
if((this.currentPage+5<10)&&(this.totalPage<10)){
this.viewCountPages = totalPage;
}else if((this.currentPage+5<10)&&(this.totalPage>=10)){
this.viewCountPages = 10;
}else if(this.currentPage+5>this.totalPage){
this.viewCountPages = this.totalPage;
}else{
this.viewCountPages = this.currentPage+5;
}
}
}
@SuppressWarnings("rawtypes")
public List getList() {
return objects;
}
public int getPageSize() {
return pageSize;
}
public int getTotalNumber() {
return totalNumber;
}
public int getTotalPage() {
return totalPage;
}
public int getCurrentPage() {
if(this.getTotalNumber()>0)
currentPage = currentPage<1?1:currentPage;
return currentPage;
}
@SuppressWarnings("rawtypes")
public void setList(List objects) {
this.objects = objects;
}
public String toString(){
StringBuffer sb=null;
if(objects!=null){
sb=new StringBuffer(500);
for(int i=0;i<objects.size();i++){
sb.append(objects.toString()).append(",");
}
}
return sb==null?"":sb.toString();
}
@SuppressWarnings("rawtypes")
public List getObjects() {
return objects;
}
/**
* @param objects the objects to set
*/
@SuppressWarnings("rawtypes")
public void setObjects(List objects) {
this.objects = objects;
}
/**
* @param pageSize the pageSize to set
*/
public void setPageSize(int pageSize) {
this.pageSize = pageSize;
}
/**
* @param totalNumber the totalNumber to set
*/
public void setTotalNumber(int totalNumber) {
this.totalNumber = totalNumber;
}
/**
* @param totalPage the totalPage to set
*/
public void setTotalPage(int totalPage) {
this.totalPage = totalPage;
}
/**
* @param currentPage the currentPage to set
*/
public void setCurrentPage(int currentPage) {
this.currentPage = currentPage;
}
public int getViewCountPages() {
return viewCountPages;
}
public void setViewCountPages(int viewCountPages) {
this.viewCountPages = viewCountPages;
}
}
src/main/java/com/controller/AppInfoController.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.controller;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.servlet.mvc.support.RedirectAttributes;
import com.common.Page;
import com.entity.app.AppInfo;
import com.entity.host.SystemInfo;
import com.entity.user.AccountInfo;
import com.service.app.AppInfoService;
import com.service.app.AppStateService;
import com.service.dash.DashboardService;
import com.service.host.SystemInfoService;
import com.service.log.LogInfoService;
import com.util.DateUtil;
import com.util.staticvar.HostKeys;
import com.util.staticvar.StaticKeys;
/**
*
* @ClassName:AppInfoController.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: AppInfoController.java
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
@Controller
@RequestMapping("/sys/app")
public class AppInfoController {
private static final Logger logger = LoggerFactory.getLogger(AppInfoController.class);
private String MENU_MARK = "app";//菜单标识
@Resource
private AppInfoService appInfoService;
@Resource
private AppStateService appStateService;
@Resource
private LogInfoService logInfoService;
@Resource
private DashboardService dashBoardService;
@Resource
private SystemInfoService systemInfoService;
@Resource
DashboardService dashboardService;
/**
* 根据条件查询app应用信息列表
* @param model
* @param request
* @return
*/
@RequestMapping(value="list")
public String AppInfoList(Model model,HttpServletRequest request) {
String curPage = request.getParameter(StaticKeys.CUR_PAGE);
if(StringUtils.isEmpty(curPage)){
curPage = "1";
}
Map<String, Object> params = new HashMap<String, Object>();
StringBuffer url = new StringBuffer();
Page page = null;
try {
page = appInfoService.selectByParams(params, Integer.valueOf(curPage), StaticKeys.PAGE_SIZE);
model.addAttribute("pageUrl", "/sys/app/list?1=1"+ url.toString());
model.addAttribute("page", page);
} catch (Exception e) {
logger.error("查询出错",e);
}
model.addAttribute(MENU_MARK, StaticKeys.MENU_ACTIVE);
return "app/list";
}
/**
* 转到添加页面
* @param AppInfo
* @param model
* @param request
* @return
*/
@RequestMapping(value="add")
public String addAppInfo( Model model,HttpServletRequest request) {
model.addAttribute(MENU_MARK, StaticKeys.MENU_ACTIVE);
try {
AccountInfo accountInfo = (AccountInfo) request.getSession().getAttribute(StaticKeys.LOGIN_KEY);
List<SystemInfo> sysInfoList = systemInfoService.selectByAccountId(accountInfo.getId());
model.addAttribute("sysInfoList", sysInfoList);
} catch (Exception e) {
logger.error("转到添加页面错误：",e);
}
return "app/add";
}
/**
* 保存应用监控信息
* @param AppInfo
* @param model
* @param request
* @return
*/
@RequestMapping(value="save")
public String saveAppInfo(AppInfo AppInfo, Model model,HttpServletRequest request) {
try {
AccountInfo accountInfo = (AccountInfo) request.getSession().getAttribute(StaticKeys.LOGIN_KEY);
Map<String, Object> params = new HashMap<String, Object>();
params.put("account", accountInfo.getAccount());
AppInfo.setAccount(accountInfo.getAccount());
AppInfo.setAccountId(accountInfo.getId());
appInfoService.save(AppInfo);
} catch (Exception e) {
logger.error("保存APP应用信息错误：",e);
}
return "redirect:/sys/app/list";
}
/**
* 查看APP应用信息
* @param AppInfo
* @param model
* @param request
* @return
*/
@RequestMapping(value="view")
public String viewAppInfo(Model model,HttpServletRequest request) {
String errorMsg = "转到查看APP应用页面错误：";
String id = request.getParameter("id");
AccountInfo accountInfo = (AccountInfo) request.getSession().getAttribute(StaticKeys.LOGIN_KEY);
model.addAttribute(MENU_MARK, StaticKeys.MENU_ACTIVE);
AppInfo AppInfo;
try {
AppInfo = appInfoService.selectById(id);
model.addAttribute("appInfo", AppInfo);
} catch (Exception e) {
logger.error(errorMsg,e);
logInfoService.save(accountInfo.getAccount(),"",errorMsg+e,StaticKeys.LOG_ERROR);
}
return "app/view";
}
/**
* 修改APP应用信息
* @param AppInfo
* @param model
* @param request
* @return
*/
@RequestMapping(value="edit")
public String editAppInfo(Model model,HttpServletRequest request) {
String errorMsg = "转到修改APP应用页面错误：";
String id = request.getParameter("id");
AccountInfo accountInfo = (AccountInfo) request.getSession().getAttribute(StaticKeys.LOGIN_KEY);
AppInfo AppInfo;
try {
AppInfo = appInfoService.selectById(id);
model.addAttribute("appInfo", AppInfo);
model.addAttribute(MENU_MARK, StaticKeys.MENU_ACTIVE);
List<SystemInfo> sysInfoList = systemInfoService.selectByAccountId(accountInfo.getId());
model.addAttribute("sysInfoList", sysInfoList);
} catch (Exception e) {
logger.error(errorMsg,e);
logInfoService.save(accountInfo.getAccount(),"",errorMsg+e,StaticKeys.LOG_ERROR);
}
return "app/edit";
}
/**
* 查看该应用统计图
* @param AppInfo
* @param model
* @param request
* @return
*/
@RequestMapping(value="viewChart")
public String viewChart(Model model,HttpServletRequest request) {
String errorMsg = "查看该应用统计图错误：";
String id = request.getParameter("id");
String date = request.getParameter("date");
String am = request.getParameter("am");
AccountInfo accountInfo = (AccountInfo) request.getSession().getAttribute(StaticKeys.LOGIN_KEY);
AppInfo AppInfo;
Page page = null;
try {
AppInfo = appInfoService.selectById(id);
Map<String, Object> params = new HashMap<String, Object>();
params.put("appInfoId", id);
if(StringUtils.isEmpty(date)){
date = DateUtil.getCurrentDate();
am = dashboardService.getDefaultAm();
}
dashboardService.setDateParam(am, date, params);
//组装日期查询字符串集合
model.addAttribute("dateList", dashBoardService.getDateList());
model.addAttribute("date", date);
model.addAttribute("am", am);
page = appStateService.selectByParams(params, 1, HostKeys.CHART_DATA_SIZE);
String appStateChart = dashBoardService.appStateChar(page.getObjects());
//echart图长度计算
if(page.getObjects().size()>HostKeys.BAR_SIZE){
model.addAttribute("chartWidth", ";width:"+page.getObjects().size()*HostKeys.BAR_WIDTH);
}
model.addAttribute("appInfo", AppInfo);
model.addAttribute("appStateChart", appStateChart);
model.addAttribute(MENU_MARK, StaticKeys.MENU_ACTIVE);
} catch (Exception e) {
logger.error(errorMsg,e);
logInfoService.save(accountInfo.getAccount(),"",errorMsg+e,StaticKeys.LOG_ERROR);
}
return "app/appState";
}
/**
* 修改APP应用信息
* @param AppInfo
* @param model
* @param request
* @return
*/
@RequestMapping(value="update")
public String updateAppInfo(AppInfo AppInfo, Model model,HttpServletRequest request) {
String errorMsg = "修改APP应用信息错误：";
AccountInfo accountInfo = (AccountInfo) request.getSession().getAttribute(StaticKeys.LOGIN_KEY);
try {
appInfoService.updateById(AppInfo);
} catch (Exception e) {
logger.error(errorMsg,e);
logInfoService.save(accountInfo.getAccount(),"",errorMsg+e,StaticKeys.LOG_ERROR);
}
return "redirect:/sys/app/list";
}
/**
* 删除APP应用信息
* @param id
* @param model
* @param request
* @param redirectAttributes
* @return
*/
@RequestMapping(value="del")
public String delete(Model model,HttpServletRequest request,RedirectAttributes redirectAttributes) {
String errorMsg = "删除app信息错误：";
AccountInfo accountInfo = (AccountInfo) request.getSession().getAttribute(StaticKeys.LOGIN_KEY);
try {
if(!StringUtils.isEmpty(request.getParameter("id"))){
appInfoService.deleteById(request.getParameter("id").split(","));
}
} catch (Exception e) {
logger.error(errorMsg,e);
logInfoService.save(accountInfo.getAccount(),"",errorMsg+e,StaticKeys.LOG_ERROR);
}
return "redirect:/sys/app/list";
}
}
src/main/java/com/controller/CodeController.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.controller;
import java.awt.Color;
import java.awt.Font;
import java.awt.Graphics;
import java.awt.image.BufferedImage;
import java.io.IOException;
import java.util.Random;
import javax.imageio.ImageIO;
import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import com.util.staticvar.StaticKeys;
/**
*
* @ClassName:CodeController.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: CodeController.java
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
@Controller
@RequestMapping(value="/sys/code")
public class CodeController {
private static final Logger logger = LoggerFactory.getLogger(CodeController.class);
private int codeCount = 4;//定义图片上显示验证码的个数
char[] codeSequence = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9' };
/**
* 获取验证码
* @param model
* @param request
* @return
*/
@RequestMapping(value="get")
public void hostInfoList(Model model,HttpServletRequest req, HttpServletResponse resp) {
int xx = 13;
int codeY = 22;
int width = 70;//定义图片的width
int height = 30;//定义图片的height
int fontHeight = 20;
// 定义图像buffer
BufferedImage buffImg = new BufferedImage(width, height,BufferedImage.TYPE_INT_RGB);
// Graphics2D gd = buffImg.createGraphics();
//Graphics2D gd = (Graphics2D) buffImg.getGraphics();
Graphics gd = buffImg.getGraphics();
// 创建一个随机数生成器类
Random random = new Random();
// 将图像填充为白色
gd.setColor(Color.getColor("#ef3f22"));
gd.fillRect(0, 0, width, height);
// 创建字体，字体的大小应该根据图片的高度来定。
Font font = new Font("ITALIC", 0, fontHeight);
// 设置字体。
gd.setFont(font);
// 画边框。
gd.setColor(Color.BLACK);
gd.drawRect(0, 0, width - 1, height - 1);
// randomCode用于保存随机产生的验证码，以便用户登录后进行验证。
StringBuilder randomCode = new StringBuilder();
int red = 0, green = 0, blue = 0;
Font font2 = new Font("Fixedsys", Font.BOLD, fontHeight);
// 设置字体。
gd.setFont(font2);
// 随机产生codeCount数字的验证码。
for (int i = 0; i < codeCount; i++) {
// 得到随机产生的验证码数字。
String code = String.valueOf(codeSequence[random.nextInt(codeSequence.length)]);
// 产生随机的颜色分量来构造颜色值，这样输出的每位数字的颜色值都将不同。
red = random.nextInt(255);
green = random.nextInt(255);
blue = random.nextInt(255);
// 用随机产生的颜色将验证码绘制到图像中。
//gd.setColor(new Color(red, green, blue));
gd.drawString(code, (i + 1) * xx, codeY);
// 将产生的四个随机数组合在一起。
randomCode.append(code);
}
// 将四位数字的验证码保存到Session中。
HttpSession session = req.getSession();
session.setAttribute(StaticKeys.SESSION_CODE, randomCode.toString());
// 禁止图像缓存。
resp.setHeader("Pragma", "no-cache");
resp.setHeader("Cache-Control", "no-cache");
resp.setDateHeader("Expires", 0);
resp.setContentType("image/jpeg");
// 将图像输出到Servlet输出流中。
ServletOutputStream sos;
try {
sos = resp.getOutputStream();
ImageIO.write(buffImg, "jpeg", sos);
sos.close();
} catch (IOException e) {
logger.error("生成验证码异常：",e);
}
}
}
\ No newline at end of file
src/main/java/com/controller/CommonCotroller.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.controller;
import javax.servlet.http.HttpServletRequest;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
/**
*
* @ClassName:CommonCotroller.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: CommonCotroller.java
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
@Controller
@RequestMapping(value="/common/error")
public class CommonCotroller {
/**
* 转向到404页面
* @param model
* @param request
* @return
*/
@RequestMapping("404")
public String to404(Model model,HttpServletRequest request) {
return "error/404";
}
/**
* 转向到500页面
* @param model
* @param request
* @return
*/
@RequestMapping("500")
public String to500(Model model,HttpServletRequest request) {
return "error/500";
}
}
\ No newline at end of file
src/main/java/com/controller/DashboardCotroller.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.controller;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import com.common.Page;
import com.entity.dash.DashboardView;
import com.entity.host.IntrusionInfo;
import com.entity.host.MemState;
import com.entity.host.SystemInfo;
import com.entity.user.AccountInfo;
import com.service.dash.DashboardService;
import com.service.host.CpuStateService;
import com.service.host.DeskStateService;
import com.service.host.DiskIoStateService;
import com.service.host.IntrusionInfoService;
import com.service.host.MemStateService;
import com.service.host.NetIoStateService;
import com.service.host.SysLoadStateService;
import com.service.host.SystemInfoService;
import com.service.host.TcpStateService;
import com.util.DateUtil;
import com.util.staticvar.HostKeys;
import com.util.staticvar.StaticKeys;
/**
*
* @ClassName:DashboardCotroller.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: DashboardCotroller.java
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
@Controller
@RequestMapping(value="/sys/dash")
public class DashboardCotroller {
private static final Logger logger = LoggerFactory.getLogger(DashboardCotroller.class);
@Resource
DashboardService dashboardService;
@Resource
CpuStateService cpuStateService;
@Resource
DeskStateService deskStateService;
@Resource
MemStateService memStateService;
@Resource
NetIoStateService netIoStateService;
@Resource
SysLoadStateService sysLoadStateService;
@Resource
TcpStateService tcpStateService;
@Resource
SystemInfoService systemInfoService;
@Resource
DiskIoStateService diskIoStateService;
@Resource
IntrusionInfoService intrusionInfoService;
/**
* 根据条件查询host列表
* @param model
* @param request
* @return
*/
@RequestMapping(value="main")
public String hostInfoList(Model model,HttpServletRequest request) {
List<DashboardView> dashboardList = new ArrayList();
AccountInfo accountInfo =(AccountInfo) request.getSession().getAttribute(StaticKeys.LOGIN_KEY);
List<SystemInfo> systemInfoList = null;
Map<String, Object> params = new HashMap<String, Object>();
Page page = null;
List<MemState> memStateList = null;
boolean isSetMemDate = false;//标识是否已经设置过最后获取内存时间
try {
systemInfoList = systemInfoService.selectByAccountId(accountInfo.getId());
for(int i = 0 ; i < systemInfoList.size(); i++){
SystemInfo systemInfo = systemInfoList.get(i);
params.put("accountId", accountInfo.getId());
params.put("hostname", systemInfo.getHostname());
if(StaticKeys.CONN_HOST_ERROR.equals(systemInfo.getVersion())){
DashboardView dashboardView = new DashboardView();
dashboardView.setHostname(systemInfo.getHostname());
dashboardView.setVersion(systemInfo.getVersion());
dashboardList.add(dashboardView);
continue;
}
page = memStateService.selectByParams(params, 1, 1);
memStateList = page.getObjects();
if(memStateList==null||memStateList.size()==0){
continue;
}
if(!isSetMemDate){
model.addAttribute("date", DateUtil.getDateTimeString(memStateList.get(0).getCreateTime()));
isSetMemDate = true;
}
DashboardView dashboardView = new DashboardView();
dashboardView.setHostname(systemInfo.getHostname());
dashboardView.setVersion(systemInfo.getVersion());
dashboardView.setYxDays(systemInfo.getYxDays());
dashboardView.setMemPer(Double.valueOf(memStateList.get(0).getUsePer()));
dashboardList.add(dashboardView);
}
} catch (Exception e) {
logger.error("主面板信息异常：",e);
}
model.addAttribute("list", dashboardList);
model.addAttribute("dashboard", StaticKeys.MENU_ACTIVE);
return "dash/dashboard";
}
/**
* 根据IP查询服务器详情信息
* @param model
* @param request
* @return
*/
@RequestMapping(value="detail")
public String hostDetail(Model model,HttpServletRequest request) {
//服务器名称
String hostname = request.getParameter("hostname");
String date = request.getParameter("date");
String am = request.getParameter("am");
AccountInfo accountInfo =(AccountInfo) request.getSession().getAttribute(StaticKeys.LOGIN_KEY);
model.addAttribute("dashboard", StaticKeys.MENU_ACTIVE);
Page page = null;
String returnView = "dash/dashdetail";
try {
if(!StringUtils.isEmpty(hostname)){
Map<String, Object> params = new HashMap<String, Object>();
params.put("accountId", accountInfo.getId());
params.put("hostname", hostname);
if(StringUtils.isEmpty(date)){
date = DateUtil.getCurrentDate();
am = dashboardService.getDefaultAm();
}
dashboardService.setDateParam(am, date, params);
//组装日期查询字符串集合
model.addAttribute("dateList", dashboardService.getDateList());
model.addAttribute("date", date);
model.addAttribute("am", am);
//加载服务器系统版本信息
SystemInfo systemInfo = systemInfoService.selectAllByParams(params).get(0);
//磁盘空间
model.addAttribute("systemInfo", systemInfo);
model.addAttribute("hostname", hostname);
page = deskStateService.selectByParams(params, 1, 1);
if( page.getObjects().size()>0){
model.addAttribute("deskState", page.getObjects().get(0));
}else{
return returnView;
}
//组装cpu占用情况图表字符串
page = cpuStateService.selectByParams(params, 1, HostKeys.CHART_DATA_SIZE);
model.addAttribute("cpu", dashboardService.cpuStateChar(page.getObjects()));
//echart图长度计算
if(page.getObjects().size()>HostKeys.BAR_SIZE){
model.addAttribute("chartWidth", ";width:"+page.getObjects().size()*HostKeys.BAR_WIDTH);
}
//组装内存使用情况图表字符串
page = memStateService.selectByParams(params, 1, HostKeys.CHART_DATA_SIZE);
model.addAttribute("mem", dashboardService.memStateChar(page.getObjects()));
//组装网络设备的吞吐率图表字符串
page = netIoStateService.selectByParams(params, 1, HostKeys.CHART_DATA_SIZE);
model.addAttribute("netio", dashboardService.netIoStateChar(page.getObjects()));
//组装TCP连接状态图表字符串
page = tcpStateService.selectByParams(params, 1, HostKeys.CHART_DATA_SIZE);
model.addAttribute("tcp", dashboardService.tcpStateChar(page.getObjects()));
//组装系统负载状态图表字符串
page = sysLoadStateService.selectByParams(params, 1, HostKeys.CHART_DATA_SIZE);
model.addAttribute("load", dashboardService.loadStateChar(page.getObjects()));
//组装磁盘使用情况图表字符串
page = diskIoStateService.selectByParams(params, 1, HostKeys.CHART_DATA_SIZE);
model.addAttribute("diskio", dashboardService.diskIoStateChar(page.getObjects()));
}
} catch (Exception e) {
logger.error(hostname+"--服务器详细信息异常：",e);
}
return returnView;
}
/**
* 入侵监控列表
* @param model
* @param request
* @return
*/
@RequestMapping(value="intrusionMain")
public String intrusionMain(Model model,HttpServletRequest request) {
AccountInfo accountInfo =(AccountInfo) request.getSession().getAttribute(StaticKeys.LOGIN_KEY);
List<IntrusionInfo> intrusionInfoList = null;
Map<String, Object> params = new HashMap<String, Object>();
try {
intrusionInfoList = intrusionInfoService.selectByAccountId(accountInfo.getId());
if(intrusionInfoList.size()>0){
model.addAttribute("date", DateUtil.getDateTimeString(intrusionInfoList.get(0).getCreateTime()));
}
} catch (Exception e) {
logger.error("入侵检测主面板信息异常：",e);
}
model.addAttribute("list", intrusionInfoList);
model.addAttribute("intrusion", StaticKeys.MENU_ACTIVE);
return "intrusion/dashboard";
}
/**
* 根据id查询服务器入侵监控详情信息
* @param model
* @param request
* @return
*/
@RequestMapping(value="intrusionDetail")
public String intrusionDetail(Model model,HttpServletRequest request) {
String id = request.getParameter("id");
AccountInfo accountInfo =(AccountInfo) request.getSession().getAttribute(StaticKeys.LOGIN_KEY);
model.addAttribute("intrusion", StaticKeys.MENU_ACTIVE);
String returnView = "intrusion/dashdetail";
try {
IntrusionInfo info = intrusionInfoService.selectById(id);
if(info!=null){
model.addAttribute("info", info);
}
} catch (Exception e) {
logger.error("--查看服务器入侵监控详情异常：",e);
}
return returnView;
}
}
\ No newline at end of file
src/main/java/com/controller/LogInfoController.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.controller;
import java.util.HashMap;
import java.util.Map;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.servlet.mvc.support.RedirectAttributes;
import com.common.Page;
import com.entity.log.LogInfo;
import com.service.log.LogInfoService;
import com.util.CodeUtil;
import com.util.staticvar.StaticKeys;
/**
*
* @ClassName:LogInfoController.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: LogInfoController.java
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
@Controller
@RequestMapping("/sys/log")
public class LogInfoController {
private static final Logger logger = LoggerFactory.getLogger(LogInfoController.class);
private String MENU_MARK = "logActive";//菜单标识
@Resource
private LogInfoService logInfoService;
/**
* 根据条件查询日志信息列表
* @param model
* @param request
* @return
*/
@RequestMapping(value="list")
public String LogInfoList(Model model,HttpServletRequest request) {
String curPage = request.getParameter(StaticKeys.CUR_PAGE);
if(StringUtils.isEmpty(curPage)){
curPage = "1";
}
String account = request.getParameter("account");
Map<String, Object> params = new HashMap<String, Object>();
StringBuffer url = new StringBuffer();
if(!StringUtils.isEmpty(account)) {
account = CodeUtil.unescape(account);
params.put("account", account);
url.append("&account=").append(CodeUtil.escape(account));
model.addAttribute("account", account);
}
Page page = null;
try {
page = logInfoService.selectByParams(params, Integer.valueOf(curPage), StaticKeys.PAGE_SIZE);
model.addAttribute("pageUrl", "/sys/log/list?1=1"+ url.toString());
model.addAttribute("page", page);
} catch (Exception e) {
logger.error("查询出错",e);
}
model.addAttribute(MENU_MARK, StaticKeys.MENU_ACTIVE);
return "log/list";
}
/**
* 查看日志信息
* @param LogInfo
* @param model
* @param request
* @return
*/
@RequestMapping(value="view")
public String viewLogInfo(Model model,HttpServletRequest request) {
model.addAttribute(MENU_MARK, StaticKeys.MENU_ACTIVE);
String id = request.getParameter("id");
LogInfo logInfo;
try {
logInfo = logInfoService.selectById(id);
model.addAttribute("logInfo", logInfo);
} catch (Exception e) {
logger.error("查看日志信息：",e);
}
return "log/view";
}
/**
* 删除
* @param id
* @param model
* @param request
* @param redirectAttributes
* @return
*/
@RequestMapping(value="del")
public String delete(Model model,HttpServletRequest request,RedirectAttributes redirectAttributes) {
Map<String,Object> map = new HashMap<String,Object>();
if(!StringUtils.isEmpty(request.getParameter("id"))){
try {
logInfoService.deleteById(request.getParameter("id").split(","));
} catch (Exception e) {
logger.error("删除日志异常：",e);
}
}
return "redirect:/sys/log/list";
}
}
src/main/java/com/controller/LoginCotroller.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.controller;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import com.common.AppInit;
import com.entity.user.AccountInfo;
import com.util.shorturl.MD5;
import com.util.staticvar.StaticKeys;
/**
*
* @ClassName:LoginCotroller.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: LoginCotroller.java
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
@Controller
@RequestMapping(value="/sys/login")
public class LoginCotroller {
private static final Logger logger = LoggerFactory.getLogger(LoginCotroller.class);
/**
* 转向到登录页面
* @param model
* @param request
* @return
*/
@RequestMapping("toLogin")
public String toLogin(Model model,HttpServletRequest request) {
return "login/login";
}
/**
* 登出系统
* @param model
* @param request
* @return
*/
@RequestMapping("loginOut")
public String loginOut(Model model,HttpServletRequest request){
HttpSession session = request.getSession();
session.invalidate();
return "redirect:/sys/host/toLogin";
}
/**
* 管理员登录验证
* @param model
* @param request
* @return
*/
@RequestMapping(value="login")
public String login(Model model,HttpServletRequest request) {
String userName = request.getParameter("userName");
String passwd = request.getParameter("md5pwd");
String code = request.getParameter(StaticKeys.SESSION_CODE);
HttpSession session = request.getSession();
try {
if(!StringUtils.isEmpty(userName)&&!StringUtils.isEmpty(passwd)&&!StringUtils.isEmpty(code)){
if(!code.equals(session.getAttribute(StaticKeys.SESSION_CODE))){
model.addAttribute("error", "验证码错误");
return "login/login";
}
AccountInfo accountInfo = new AccountInfo();
if(MD5.GetMD5Code(AppInit.admindPwd).equals(passwd)){
accountInfo.setAccount("admin");
accountInfo.setId("admin");
request.getSession().setAttribute(StaticKeys.LOGIN_KEY, accountInfo);
return "redirect:/sys/dash/main";
}
}
} catch (Exception e) {
logger.error("登录异常：",e);
}
model.addAttribute("error", "帐号或者密码错误");
return "login/login";
}
}
\ No newline at end of file
src/main/java/com/controller/MsgInfoController.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.controller;
import java.util.HashMap;
import java.util.Map;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.servlet.mvc.support.RedirectAttributes;
import com.common.Page;
import com.entity.msg.MsgInfo;
import com.service.msg.MsgInfoService;
import com.util.CodeUtil;
import com.util.staticvar.StaticKeys;
/**
*
* @ClassName:MsgInfoController.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: MsgInfoController.java
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
@Controller
@RequestMapping("/sys/msg")
public class MsgInfoController {
private static final Logger logger = LoggerFactory.getLogger(MsgInfoController.class);
private String MENU_MARK = "msgActive";//菜单标识
@Resource
private MsgInfoService msgInfoService;
/**
* 根据条件查询信息发送记录列表
* @param model
* @param request
* @return
*/
@RequestMapping(value="list")
public String msgInfoList(Model model,HttpServletRequest request) {
String curPage = request.getParameter(StaticKeys.CUR_PAGE);
if(StringUtils.isEmpty(curPage)){
curPage = "1";
}
String account = request.getParameter("account");
String acceptInfo = request.getParameter("acceptInfo");
Map<String, Object> params = new HashMap<String, Object>();
StringBuffer url = new StringBuffer();
if(!StringUtils.isEmpty(account)) {
account = CodeUtil.unescape(account);
params.put("account", account);
url.append("&account=").append(CodeUtil.escape(account));
model.addAttribute("account", account);
}
if(!StringUtils.isEmpty(acceptInfo)) {
acceptInfo = CodeUtil.unescape(acceptInfo);
params.put("acceptInfo", acceptInfo);
url.append("&acceptInfo=").append(CodeUtil.escape(acceptInfo));
model.addAttribute("acceptInfo", acceptInfo);
}
Page page = null;
try {
page = msgInfoService.selectByParams(params, Integer.valueOf(curPage), StaticKeys.PAGE_SIZE);
model.addAttribute("pageUrl", "/sys/msg/list?1=1"+ url.toString());
model.addAttribute("page", page);
} catch (Exception e) {
logger.error("查询出错",e);
}
model.addAttribute(MENU_MARK, StaticKeys.MENU_ACTIVE);
return "msg/list";
}
/**
* 查看信息发送记录
* @param LogInfo
* @param model
* @param request
* @return
*/
@RequestMapping(value="view")
public String viewLogInfo(Model model,HttpServletRequest request) {
model.addAttribute(MENU_MARK, StaticKeys.MENU_ACTIVE);
String id = request.getParameter("id");
MsgInfo logInfo;
try {
logInfo = msgInfoService.selectById(id);
model.addAttribute("msgInfo", logInfo);
} catch (Exception e) {
logger.error("查看信息发送记录：",e);
}
return "msg/view";
}
/**
* 删除
* @param id
* @param model
* @param request
* @param redirectAttributes
* @return
*/
@RequestMapping(value="del")
public String delete(Model model,HttpServletRequest request,RedirectAttributes redirectAttributes) {
if(!StringUtils.isEmpty(request.getParameter("id"))){
try {
msgInfoService.deleteById(request.getParameter("id").split(","));
} catch (Exception e) {
logger.error("删除日志异常：",e);
}
}
return "redirect:/sys/msg/list";
}
}
src/main/java/com/core/timer/impl/BatchCommitJobImpl.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.core.timer.impl;
import java.util.TimerTask;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.common.ApplicationContextHelper;
import com.service.app.AppStateService;
import com.service.host.CpuStateService;
import com.service.host.DiskIoStateService;
import com.service.host.IntrusionInfoService;
import com.service.host.MemStateService;
import com.service.host.NetIoStateService;
import com.service.host.SysLoadStateService;
import com.service.host.TcpStateService;
import com.util.DateUtil;
import com.util.staticvar.BatchData;
/**
*
* @ClassName:BatchCommitJobImpl.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: 每5分钟39秒时候批量提交监控数据
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
public class BatchCommitJobImpl extends TimerTask {
private static final Logger logger = LoggerFactory.getLogger(BatchCommitJobImpl.class);
@Override
public void run() {
timingTask();
}
public void timingTask(){
logger.info("批量提交监控数据任务开始----------"+DateUtil.getCurrentDateTime());
CpuStateService cpuStateService = (CpuStateService)ApplicationContextHelper.getBean(CpuStateService.class);
MemStateService memStateService = (MemStateService)ApplicationContextHelper.getBean(MemStateService.class);
NetIoStateService netIoStateService = (NetIoStateService)ApplicationContextHelper.getBean(NetIoStateService.class);
SysLoadStateService sysLoadStateService = (SysLoadStateService)ApplicationContextHelper.getBean(SysLoadStateService.class);
TcpStateService tcpStateService = (TcpStateService)ApplicationContextHelper.getBean(TcpStateService.class);
AppStateService appStateService = (AppStateService)ApplicationContextHelper.getBean(AppStateService.class);
DiskIoStateService diskIoStateService = (DiskIoStateService)ApplicationContextHelper.getBean(DiskIoStateService.class);
IntrusionInfoService intrusionInfoService = (IntrusionInfoService)ApplicationContextHelper.getBean(IntrusionInfoService.class);
try {
synchronized(BatchData.DISKIO_STATE_LIST) {
if(BatchData.DISKIO_STATE_LIST.size()>0){
diskIoStateService.saveRecord(BatchData.DISKIO_STATE_LIST);
BatchData.DISKIO_STATE_LIST.clear();
}
}
synchronized(BatchData.APP_STATE_LIST) {
if(BatchData.APP_STATE_LIST.size()>0){
appStateService.saveRecord(BatchData.APP_STATE_LIST);
BatchData.APP_STATE_LIST.clear();
}
}
synchronized(BatchData.CPU_STATE_LIST) {
if(BatchData.CPU_STATE_LIST.size()>0){
cpuStateService.saveRecord(BatchData.CPU_STATE_LIST);
BatchData.CPU_STATE_LIST.clear();
}
}
synchronized(BatchData.MEM_STATE_LIST) {
if(BatchData.MEM_STATE_LIST.size()>0){
memStateService.saveRecord(BatchData.MEM_STATE_LIST);
BatchData.MEM_STATE_LIST.clear();
}
}
synchronized(BatchData.NETIO_STATE_LIST) {
if(BatchData.NETIO_STATE_LIST.size()>0){
netIoStateService.saveRecord(BatchData.NETIO_STATE_LIST);
BatchData.NETIO_STATE_LIST.clear();
}
}
synchronized(BatchData.SYSLOAD_STATE_LIST) {
if(BatchData.SYSLOAD_STATE_LIST.size()>0){
sysLoadStateService.saveRecord(BatchData.SYSLOAD_STATE_LIST);
BatchData.SYSLOAD_STATE_LIST.clear();
}
}
synchronized(BatchData.TCP_STATE_LIST) {
if(BatchData.TCP_STATE_LIST.size()>0){
tcpStateService.saveRecord(BatchData.TCP_STATE_LIST);
BatchData.TCP_STATE_LIST.clear();
}
}
synchronized(BatchData.INTRUSION_INFO_LIST) {
if(BatchData.INTRUSION_INFO_LIST.size()>0){
intrusionInfoService.saveRecord(BatchData.INTRUSION_INFO_LIST);
BatchData.INTRUSION_INFO_LIST.clear();
}
}
} catch (Exception e) {
// TODO Auto-generated catch block
logger.error("批量提交监控数据异常----------",e);
}
logger.info("批量提交监控数据任务结束----------"+DateUtil.getCurrentDateTime());
}
}
src/main/java/com/core/timer/impl/MonitorDayJobImpl.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.core.timer.impl;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.TimerTask;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.common.ApplicationContextHelper;
import com.dao.app.AppInfoDao;
import com.dao.app.AppStateDao;
import com.dao.host.CpuStateDao;
import com.dao.host.DeskStateDao;
import com.dao.host.DiskIoStateDao;
import com.dao.host.IntrusionInfoDao;
import com.dao.host.MemStateDao;
import com.dao.host.NetIoStateDao;
import com.dao.host.SysLoadStateDao;
import com.dao.host.SystemInfoDao;
import com.dao.host.TcpStateDao;
import com.dao.log.LogInfoDao;
import com.dao.msg.MsgInfoDao;
import com.entity.app.AppInfo;
import com.util.DateUtil;
import com.util.msg.WarnPools;
import com.util.staticvar.StaticKeys;
/**
*
* @ClassName:MonitorDayJobImpl.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: 每天1点删除历史信息
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
public class MonitorDayJobImpl extends TimerTask {
private static final Logger logger = LoggerFactory.getLogger(MonitorDayJobImpl.class);
@Override
public void run() {
timingTask();
}
public void timingTask(){
logger.info("定时清空历史数据任务开始----------"+DateUtil.getCurrentDateTime());
WarnPools.clearOldData();//清空发告警邮件的记录
String nowTime = DateUtil.getCurrentDateTime();
//3天前时间
String oneDayBefore = DateUtil.getDateBefore(nowTime, 3);
//30天前时间
String sevenDayBefore = DateUtil.getDateBefore(nowTime, 30);
Map<String, Object> paramsDel = new HashMap<String,Object>();
SystemInfoDao systemInfoDao = (SystemInfoDao)ApplicationContextHelper.getBean(SystemInfoDao.class);
CpuStateDao cpuStateDao = (CpuStateDao)ApplicationContextHelper.getBean(CpuStateDao.class);
DeskStateDao deskStateDao = (DeskStateDao)ApplicationContextHelper.getBean(DeskStateDao.class);
MemStateDao memStateDao = (MemStateDao)ApplicationContextHelper.getBean(MemStateDao.class);
NetIoStateDao netIoStateDao = (NetIoStateDao)ApplicationContextHelper.getBean(NetIoStateDao.class);
SysLoadStateDao sysLoadStateDao = (SysLoadStateDao)ApplicationContextHelper.getBean(SysLoadStateDao.class);
TcpStateDao tcpStateDao = (TcpStateDao)ApplicationContextHelper.getBean(TcpStateDao.class);
AppInfoDao appInfoDao = (AppInfoDao)ApplicationContextHelper.getBean(AppInfoDao.class);
AppStateDao appStateDao = (AppStateDao)ApplicationContextHelper.getBean(AppStateDao.class);
DiskIoStateDao diskIoStateDao = (DiskIoStateDao)ApplicationContextHelper.getBean(DiskIoStateDao.class);
IntrusionInfoDao intrusionInfoDao = (IntrusionInfoDao)ApplicationContextHelper.getBean(IntrusionInfoDao.class);
List<AppInfo> appInfoList = null;
try {
appInfoList = appInfoDao.selectAllByParams(null);
paramsDel.put(StaticKeys.SEARCH_END_TIME,sevenDayBefore);
paramsDel.put("accountId",StaticKeys.ADMIN_ACCOUNT);
//执行删除操作begin
if(paramsDel.get(StaticKeys.SEARCH_END_TIME)!=null&&!"".equals(paramsDel.get(StaticKeys.SEARCH_END_TIME))){
cpuStateDao.deleteByAccountAndDate(paramsDel);//删除cpu监控信息
deskStateDao.deleteByAccountAndDate(paramsDel);//删除磁盘监控信息
memStateDao.deleteByAccountAndDate(paramsDel);//删除内存监控信息
netIoStateDao.deleteByAccountAndDate(paramsDel);//删除吞吐率监控信息
sysLoadStateDao.deleteByAccountAndDate(paramsDel);//删除负载状态监控信息
tcpStateDao.deleteByAccountAndDate(paramsDel);//删除tcp监控信息
diskIoStateDao.deleteByAccountAndDate(paramsDel);//删除磁盘IO监控信息
//删除进程监控信息
if(appInfoList.size()>0){
paramsDel.put("appInfoIds", getAppInfoIdList(appInfoList));
appStateDao.deleteByAppInfoIdsAndDate(paramsDel);
}
//删除3天前服务器系统信息和入侵检测信息
paramsDel.put(StaticKeys.SEARCH_END_TIME,oneDayBefore);
systemInfoDao.deleteByAccountAndDate(paramsDel);
intrusionInfoDao.deleteByAccountAndDate(paramsDel);
}
//执行删除操作end
//删除30天前的日志信息
LogInfoDao logInfoDao = (LogInfoDao)ApplicationContextHelper.getBean(LogInfoDao.class);
String thrityDayBefore = DateUtil.getDateBefore(nowTime, 30);
paramsDel.put(StaticKeys.SEARCH_END_TIME,thrityDayBefore);
logInfoDao.deleteByDate(paramsDel);
//删除30天前的信息发送记录
MsgInfoDao msgInfoDao = (MsgInfoDao)ApplicationContextHelper.getBean(MsgInfoDao.class);
msgInfoDao.deleteByDate(paramsDel);
} catch (Exception e) {
logger.info("定时清空历史数据任务出错：",e);
}
logger.info("定时清空历史数据任务结束----------"+DateUtil.getCurrentDateTime());
}
/**
* 取出AppInfo集合中的id
* @param list
* @return
*/
private List<String> getAppInfoIdList(List<AppInfo> list){
List<String> idList = new ArrayList<String>();
for(AppInfo info : list){
idList.add(info.getId());
}
return idList;
}
}
src/main/java/com/dao/app/AppInfoDao.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.dao.app;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Repository;
import com.entity.app.AppInfo;
/**
*
* @ClassName:AppInfoDao.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: AppInfoDao.java
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
@Repository
public interface AppInfoDao{
public List<AppInfo> selectAllByParams(Map<String,Object> map) throws Exception;
public List<AppInfo> selectByParams(Map<String,Object> params) throws Exception;
public AppInfo selectById(String id) throws Exception;
public List<AppInfo> selectByAccountId(String accountId) throws Exception;
public void save(AppInfo AppInfo) throws Exception;
public int deleteById(String[] id) throws Exception;
public AppInfo updateById(AppInfo AppInfo) throws Exception;
}
src/main/java/com/dao/app/AppStateDao.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.dao.app;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Repository;
import com.entity.app.AppState;
/**
*
* @ClassName:AppStateDao.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: AppStateDao.java
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
@Repository
public interface AppStateDao {
public List<AppState> selectAllByParams(Map<String,Object> map) throws Exception;
public List<AppState> selectByParams(Map<String,Object> params) throws Exception;
public AppState selectById(String id) throws Exception;
public int selectByParamsCount(Map<String,Object> map);
public void save(AppState AppState) throws Exception;
public void insertList(List<AppState> recordList) throws Exception;
public int deleteByAppInfoId(String appInfoId) throws Exception;
public int deleteByAppInfoIdsAndDate(Map<String,Object> map) throws Exception;
public int deleteById(String[] id) throws Exception;
}
src/main/java/com/dao/host/CpuStateDao.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.dao.host;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Repository;
import com.entity.host.CpuState;
/**
*
* @ClassName:CpuStateDao.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: CpuStateDao.java
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
@Repository
public interface CpuStateDao{
public List<CpuState> selectAllByParams(Map<String,Object> map) throws Exception ;
public List<CpuState> selectByParams(Map<String,Object> params) throws Exception;
public CpuState selectById(String id) throws Exception;
public int selectByParamsCount(Map<String,Object> map);
public void save(CpuState CpuState) throws Exception;
public void insertList(List<CpuState> recordList) throws Exception;
public int deleteByAccountAndDate(Map<String,Object> map) throws Exception;
public int deleteById(String[] id) throws Exception;
}
src/main/java/com/dao/host/DeskStateDao.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.dao.host;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Repository;
import com.entity.host.DeskState;
/**
*
* @ClassName:DeskStateDao.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: 查看磁盘大小使用信息
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
@Repository
public interface DeskStateDao{
public List<DeskState> selectAllByParams(Map<String,Object> map) throws Exception;
public List<DeskState> selectByParams(Map<String,Object> params) throws Exception;
public DeskState selectById(String id) throws Exception;
public void save(DeskState DeskState) throws Exception;
public int deleteByAccountAndDate(Map<String,Object> map) throws Exception;
public int deleteById(String[] id) throws Exception;
public int deleteByAccHname(Map<String,Object> map) throws Exception;
}
src/main/java/com/dao/host/DiskIoStateDao.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.dao.host;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Repository;
import com.entity.host.DiskIoState;
/**
*
* @ClassName:DiskIoStateDao.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: 查看磁盘IO使用情况
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
@Repository
public interface DiskIoStateDao{
public List<DiskIoState> selectAllByParams(Map<String,Object> map) throws Exception;
public List<DiskIoState> selectByParams(Map<String,Object> params) throws Exception;
public DiskIoState selectById(String id) throws Exception;
public void save(DiskIoState DiskIoState) throws Exception;
public void insertList(List<DiskIoState> recordList) throws Exception;
public int deleteByAccountAndDate(Map<String,Object> map) throws Exception;
public int deleteById(String[] id) throws Exception;
}
src/main/java/com/dao/host/IntrusionInfoDao.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.dao.host;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Repository;
import com.entity.host.IntrusionInfo;
/**
*
* @ClassName:IntrusionInfoDao.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: 查看系统入侵信息
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
@Repository
public interface IntrusionInfoDao {
public List<IntrusionInfo> selectAllByParams(Map<String,Object> map) throws Exception ;
public List<IntrusionInfo> selectByAccountId(String accountId) throws Exception ;
public List<IntrusionInfo> selectByParams(Map<String,Object> params) throws Exception;
public IntrusionInfo selectById(String id) throws Exception;
public void save(IntrusionInfo IntrusionInfo) throws Exception;
public void insertList(List<IntrusionInfo> recordList) throws Exception;
public int deleteById(String[] id) throws Exception;
public int deleteByAccountAndDate(Map<String,Object> map) throws Exception;
public int deleteByAccHname(Map<String,Object> map) throws Exception;
}
src/main/java/com/dao/host/MemStateDao.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.dao.host;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Repository;
import com.common.Page;
import com.entity.host.DeskState;
import com.entity.host.MemState;
/**
*
* @ClassName:MemStateDao.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: 查看内存使用情况
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
@Repository
public interface MemStateDao {
public List<MemState> selectAllByParams(Map<String,Object> map) throws Exception ;
public List<MemState> selectByParams(Map<String,Object> params) throws Exception;
public MemState selectById(String id) throws Exception;
public void save(MemState MemState) throws Exception;
public void insertList(List<MemState> recordList) throws Exception;
public int deleteByAccountAndDate(Map<String,Object> map) throws Exception;
public int deleteById(String[] id) throws Exception;
}
src/main/java/com/dao/host/NetIoStateDao.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.dao.host;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Repository;
import com.entity.host.NetIoState;
/**
*
* @ClassName:NetIoStateDao.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: 查看网络设备的吞吐率
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
@Repository
public interface NetIoStateDao{
public List<NetIoState> selectAllByParams(Map<String,Object> map) throws Exception;
public List<NetIoState> selectByParams(Map<String,Object> params) ;
public NetIoState selectById(String id) throws Exception;
public void save(NetIoState NetIoState) throws Exception;
public void insertList(List<NetIoState> recordList) throws Exception;
public int deleteByAccountAndDate(Map<String,Object> map) throws Exception;
public int deleteById(String[] id) throws Exception;
}
src/main/java/com/dao/host/SysLoadStateDao.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.dao.host;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Repository;
import com.entity.host.SysLoadState;
/**
*
* @ClassName:SysLoadStateDao.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: 查看uptime查看系统负载状态
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
@Repository
public interface SysLoadStateDao {
public List<SysLoadState> selectAllByParams(Map<String,Object> map) throws Exception;
public List<SysLoadState> selectByParams(Map<String,Object> params) throws Exception;
public SysLoadState selectById(String id) throws Exception;
public void save(SysLoadState SysLoadState) throws Exception;
public void insertList(List<SysLoadState> recordList) throws Exception;
public int deleteByAccountAndDate(Map<String,Object> map) throws Exception;
public int deleteById(String[] id) throws Exception;
}
src/main/java/com/dao/host/SystemInfoDao.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.dao.host;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Repository;
import com.entity.host.SystemInfo;
/**
*
* @ClassName:SystemInfoDao.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: 查看系统信息
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
@Repository
public interface SystemInfoDao {
public List<SystemInfo> selectAllByParams(Map<String,Object> map) throws Exception ;
public List<SystemInfo> selectByAccountId(String accountId) throws Exception ;
public List<SystemInfo> selectByParams(Map<String,Object> params);
public SystemInfo selectById(String id) throws Exception;
public void save(SystemInfo SystemInfo) throws Exception;
public int deleteById(String[] id) throws Exception;
public int deleteByAccountAndDate(Map<String,Object> map) throws Exception;
public int deleteByAccHname(Map<String,Object> map) throws Exception;
}
src/main/java/com/dao/host/TcpStateDao.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.dao.host;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Repository;
import com.entity.host.TcpState;
/**
*
* @ClassName:TcpStateDao.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: 查看TCP连接状态
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
@Repository
public interface TcpStateDao {
public List<TcpState> selectAllByParams(Map<String,Object> map) throws Exception;
public List<TcpState> selectByParams(Map<String,Object> params) throws Exception;
public TcpState selectById(String id) throws Exception;
public void save(TcpState TcpState) throws Exception;
public void insertList(List<TcpState> recordList) throws Exception;
public int deleteByAccountAndDate(Map<String,Object> map) throws Exception;
public int deleteById(String[] id) throws Exception;
}
src/main/java/com/dao/log/LogInfoDao.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.dao.log;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Repository;
import com.entity.log.LogInfo;
/**
*
* @ClassName:LogInfoDao.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: 查看日志信息
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
@Repository
public interface LogInfoDao{
public List<LogInfo> selectAllByParams(Map<String,Object> map);
public List<LogInfo> selectByParams(Map<String,Object> params) throws Exception;
public LogInfo selectById(String id) throws Exception;
public void save(LogInfo LogInfo) throws Exception;
public int deleteById(String[] id) throws Exception;
public int deleteByDate(Map<String,Object> map) throws Exception;
}
src/main/java/com/dao/msg/MsgInfoDao.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.dao.msg;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Repository;
import com.entity.msg.MsgInfo;
/**
*
* @ClassName:MsgInfoDao.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: 信息发送记录
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
@Repository
public interface MsgInfoDao {
public List<MsgInfo> selectAllByParams(Map<String,Object> map) throws Exception ;
public List<MsgInfo> selectByParams(Map<String,Object> params) throws Exception;
public MsgInfo selectById(String id) throws Exception;
public void save(MsgInfo MsgInfo) throws Exception;
public int deleteById(String[] id) throws Exception;
public int deleteByDate(Map<String,Object> map) throws Exception;
}
src/main/java/com/entity/app/AppInfo.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.entity.app;
import java.io.Serializable;
import java.util.Date;
/**
*
* @ClassName:AppInfo.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: app端口信息
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
public class AppInfo implements Serializable{
/**
*
*/
private static final long serialVersionUID = -2913111613773445949L;
/**
* 主键
*/
private String id;
/**
* 用户id
*/
private String accountId;
/**
* 用户帐号
*/
private String account;
/**
* host名称
*/
private String hostname;
/**
* 应用进程ID
*/
private String appPid;
/**
* 应用进程名称
*/
private String appName;
/**
* 创建时间
*/
private Date createTime;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id == null ? null : id.trim();
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
public String getAppPid() {
return appPid;
}
public void setAppPid(String appPid) {
this.appPid = appPid;
}
public String getAccountId() {
return accountId;
}
public void setAccountId(String accountId) {
this.accountId = accountId;
}
public String getAccount() {
return account;
}
public void setAccount(String account) {
this.account = account;
}
public String getHostname() {
return hostname;
}
public void setHostname(String hostname) {
this.hostname = hostname;
}
public String getAppName() {
return appName;
}
public void setAppName(String appName) {
this.appName = appName;
}
}
\ No newline at end of file
src/main/java/com/entity/app/AppState.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.entity.app;
import java.io.Serializable;
import java.util.Date;
import org.apache.commons.lang3.StringUtils;
import com.util.DateUtil;
/**
*
* @ClassName:AppState.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: app状态监控
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
public class AppState implements Serializable{
/**
*
*/
private static final long serialVersionUID = -2913111613773445949L;
/**
* 主键
*/
private String id;
/**
* 应用信息ID
*/
private String appInfoId;
/**
* %CPU
*/
private String cpuPer;
/**
* %MEM
*/
private String memPer;
/**
* 添加时间
* MM-dd hh:mm:ss
*/
private String dateStr;
/**
* 创建时间
*/
private Date createTime;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id == null ? null : id.trim();
}
public String getCpuPer() {
return cpuPer;
}
public void setCpuPer(String cpuPer) {
this.cpuPer = cpuPer;
}
public String getAppInfoId() {
return appInfoId;
}
public void setAppInfoId(String appInfoId) {
this.appInfoId = appInfoId;
}
public String getMemPer() {
return memPer;
}
public void setMemPer(String memPer) {
this.memPer = memPer;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
public String getDateStr() {
String str = DateUtil.getDateTimeString(createTime);
if(!StringUtils.isEmpty(str)&&str.length()>16){
return str.substring(5);
}
return dateStr;
}
public void setDateStr(String dateStr) {
this.dateStr = dateStr;
}
}
\ No newline at end of file
src/main/java/com/entity/dash/DashboardView.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.entity.dash;
import java.io.Serializable;
/**
*
* @ClassName:DashboardView.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: 主面板概要信息
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
public class DashboardView implements Serializable{
/**
*
*/
private static final long serialVersionUID = -1262528746414406709L;
/**
* 主键
*/
private String id;
/**
* host名称
*/
private String hostname;
/**
*系统版本信息
*/
private String version;
/**
*系统已经运行了多少天
*/
private String yxDays;
/**
* 内存已使用百分比
*/
private double memPer;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id == null ? null : id.trim();
}
public String getHostname() {
return hostname;
}
public void setHostname(String hostname) {
this.hostname = hostname;
}
public String getVersion() {
return version;
}
public void setVersion(String version) {
this.version = version;
}
public String getYxDays() {
return yxDays;
}
public void setYxDays(String yxDays) {
this.yxDays = yxDays;
}
public double getMemPer() {
return memPer;
}
public void setMemPer(double memPer) {
this.memPer = memPer;
}
}
\ No newline at end of file
src/main/java/com/entity/host/CpuState.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.entity.host;
import java.io.Serializable;
import java.util.Date;
import org.apache.commons.lang3.StringUtils;
/**
*
* @ClassName:CpuState.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: 查看CPU使用情况
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
public class CpuState implements Serializable{
/**
*
*/
private static final long serialVersionUID = -2913111613773445949L;
/**
* 主键
*/
private String id;
/**
* 用户id
*/
private String accountId;
/**
* 用户帐号
*/
private String account;
/**
* host名称
*/
private String hostname;
/**
* 用户态的CPU时间（%）
*/
private String user;
/**
* 系统（内核）时间（%）
*/
private String sys;
/**
* 空闲时间（idle）（%）
*/
private String idle;
/**
* IO等待时间（wait）（%）
*/
private String iowait;
/**
* 硬中断时间（%）
*/
private String irq;
/**
* 软中断时间（%）
*/
private String soft;
/**
* 添加时间
* MM-dd hh:mm:ss
*/
private String dateStr;
/**
* 创建时间
*/
private Date createTime;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id == null ? null : id.trim();
}
public String getUser() {
return user;
}
public void setUser(String user) {
this.user = user;
}
public String getSys() {
return sys;
}
public void setSys(String sys) {
this.sys = sys;
}
public String getIdle() {
return idle;
}
public void setIdle(String idle) {
this.idle = idle;
}
public String getIowait() {
return iowait;
}
public void setIowait(String iowait) {
this.iowait = iowait;
}
public String getIrq() {
return irq;
}
public void setIrq(String irq) {
this.irq = irq;
}
public String getSoft() {
return soft;
}
public void setSoft(String soft) {
this.soft = soft;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
public String getDateStr() {
if(!StringUtils.isEmpty(dateStr)&&dateStr.length()>16){
return dateStr.substring(5);
}
return dateStr;
}
public void setDateStr(String dateStr) {
this.dateStr = dateStr;
}
public String getAccountId() {
return accountId;
}
public void setAccountId(String accountId) {
this.accountId = accountId;
}
public String getAccount() {
return account;
}
public void setAccount(String account) {
this.account = account;
}
public String getHostname() {
return hostname;
}
public void setHostname(String hostname) {
this.hostname = hostname;
}
}
\ No newline at end of file
src/main/java/com/entity/host/DeskState.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.entity.host;
import java.io.Serializable;
import java.sql.Timestamp;
import java.util.Date;
import org.apache.commons.lang3.StringUtils;
/**
*
* @ClassName:DeskState.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: 查看磁盘大小使用信息
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
public class DeskState implements Serializable{
/**
*
*/
private static final long serialVersionUID = 879979812204191283L;
/**
* 主键
*/
private String id;
/**
* 用户id
*/
private String accountId;
/**
* 用户帐号
*/
private String account;
/**
* host名称
*/
private String hostname;
/**
* 磁盘分区
*/
private String fileSystem;
/**
*分区大小
*/
private String size;
/**
* 已使用
*/
private String used;
/**
* 未使用
*/
private String avail;
/**
* 已使用百分比
*/
private String usePer;
/**
* 添加时间
* yyyy-MM-dd hh:mm:ss
*/
private String dateStr;
/**
* 创建时间
*/
private Date createTime;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id == null ? null : id.trim();
}
public String getFileSystem() {
return fileSystem;
}
public void setFileSystem(String fileSystem) {
this.fileSystem = fileSystem;
}
public String getSize() {
return size;
}
public void setSize(String size) {
this.size = size;
}
public String getUsed() {
return used;
}
public void setUsed(String used) {
this.used = used;
}
public String getAvail() {
return avail;
}
public void setAvail(String avail) {
this.avail = avail;
}
public String getUsePer() {
return usePer;
}
public void setUsePer(String usePer) {
this.usePer = usePer;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
public String getDateStr() {
if(!StringUtils.isEmpty(dateStr)&&dateStr.length()>16){
return dateStr.substring(5);
}
return dateStr;
}
public void setDateStr(String dateStr) {
this.dateStr = dateStr;
}
public String getAccountId() {
return accountId;
}
public void setAccountId(String accountId) {
this.accountId = accountId;
}
public String getAccount() {
return account;
}
public void setAccount(String account) {
this.account = account;
}
public String getHostname() {
return hostname;
}
public void setHostname(String hostname) {
this.hostname = hostname;
}
}
\ No newline at end of file
src/main/java/com/entity/host/DiskIoState.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.entity.host;
import java.io.Serializable;
import java.util.Date;
import org.apache.commons.lang3.StringUtils;
/**
*
* @ClassName:DiskIoState.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: 查看磁盘IO使用情况
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
public class DiskIoState implements Serializable{
/**
*
*/
private static final long serialVersionUID = -8284741180883299533L;
/**
* 主键
*/
private String id;
/**
* 用户id
*/
private String accountId;
/**
* 用户帐号
*/
private String account;
/**
* host名称
*/
private String hostname;
/**
* 每秒读次数
*/
private String rs;
/**
* 每秒写次数
*/
private String ws;
/**
*每秒读数据量（千字节）
*/
private String rkBS;
/**
* 每秒写数据量（千字节）
*/
private String wkBS;
/**
* IO操作的平均等待时间，单位是毫秒。这是应用程序在和磁盘交互时，需要消耗的时间，包括IO等待和实际操作的耗时。如果这个数值过大，可能是硬件设备遇到了瓶颈或者出现故障
*/
private String await;
/**
* 向设备发出的请求平均数量。如果这个数值大于1，可能是硬件设备已经饱和（部分前端硬件设备支持并行写入）
*/
private String avgquSz;
/**
* 设备利用率。这个数值表示设备的繁忙程度，经验值是如果超过60，可能会影响IO性能（可以参照IO操作平均等待时间）。如果到达100%，说明硬件设备已经饱和
*/
private String util;
/**
* 添加时间
* MM-dd hh:mm:ss
*/
private String dateStr;
/**
* 创建时间
*/
private Date createTime;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id == null ? null : id.trim();
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
public String getDateStr() {
if(!StringUtils.isEmpty(dateStr)&&dateStr.length()>16){
return dateStr.substring(5);
}
return dateStr;
}
public void setDateStr(String dateStr) {
this.dateStr = dateStr;
}
public String getAccountId() {
return accountId;
}
public void setAccountId(String accountId) {
this.accountId = accountId;
}
public String getAccount() {
return account;
}
public void setAccount(String account) {
this.account = account;
}
public String getHostname() {
return hostname;
}
public void setHostname(String hostname) {
this.hostname = hostname;
}
public String getRs() {
return rs;
}
public void setRs(String rs) {
this.rs = rs;
}
public String getWs() {
return ws;
}
public void setWs(String ws) {
this.ws = ws;
}
public String getRkBS() {
return rkBS;
}
public void setRkBS(String rkBS) {
this.rkBS = rkBS;
}
public String getWkBS() {
return wkBS;
}
public void setWkBS(String wkBS) {
this.wkBS = wkBS;
}
public String getAwait() {
return await;
}
public void setAwait(String await) {
this.await = await;
}
public String getAvgquSz() {
return avgquSz;
}
public void setAvgquSz(String avgquSz) {
this.avgquSz = avgquSz;
}
public String getUtil() {
return util;
}
public void setUtil(String util) {
this.util = util;
}
}
\ No newline at end of file
src/main/java/com/entity/host/HostInfo.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.entity.host;
import java.io.Serializable;
import java.util.Date;
/**
*
* @ClassName:HostInfo.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: host的IP密码等信息
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
public class HostInfo implements Serializable{
/**
*
*/
private static final long serialVersionUID = 3875927332935900938L;
/**
* 主键
*/
private String id;
/**
* host名称
*/
private String hostname;
/**
* 用户
*/
private String username;
/**
* 密码
*/
private String password;
/**
* 创建时间
*/
private Date createTime;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id == null ? null : id.trim();
}
public String getHostname() {
return hostname;
}
public void setHostname(String hostname) {
this.hostname = hostname;
}
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
}
\ No newline at end of file
src/main/java/com/entity/host/IntrusionInfo.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.entity.host;
import java.io.Serializable;
import java.sql.Timestamp;
/**
*
* @ClassName:IntrusionInfo.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: 检查系统入侵信息
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
public class IntrusionInfo implements Serializable{
/**
*
*/
private static final long serialVersionUID = 879979812204191283L;
/**
* 主键
*/
private String id;
/**
* 用户id
*/
private String accountId;
/**
* 用户帐号
*/
private String account;
/**
* host名称
*/
private String hostname;
/**
* 系统内核模块
*/
private String lsmod;
/**
*查看passwd文件修改时间
*/
private String passwdInfo;
/**
* 查看系统计划任务
*/
private String crontab;
/**
* 检查网络，正常网卡不该在promisc模式，可能存在sniffer
*/
private String promisc;
/**
* 系统rpc服务
*/
private String rpcinfo;
/**
* 创建时间
*/
private Timestamp createTime;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id == null ? null : id.trim();
}
public Timestamp getCreateTime() {
return createTime;
}
public void setCreateTime(Timestamp createTime) {
this.createTime = createTime;
}
public String getAccountId() {
return accountId;
}
public void setAccountId(String accountId) {
this.accountId = accountId;
}
public String getAccount() {
return account;
}
public void setAccount(String account) {
this.account = account;
}
public String getHostname() {
return hostname;
}
public void setHostname(String hostname) {
this.hostname = hostname;
}
public String getLsmod() {
return lsmod;
}
public void setLsmod(String lsmod) {
this.lsmod = lsmod;
}
public String getPasswdInfo() {
return passwdInfo;
}
public void setPasswdInfo(String passwdInfo) {
this.passwdInfo = passwdInfo;
}
public String getCrontab() {
return crontab;
}
public void setCrontab(String crontab) {
this.crontab = crontab;
}
public String getPromisc() {
return promisc;
}
public void setPromisc(String promisc) {
this.promisc = promisc;
}
public String getRpcinfo() {
return rpcinfo;
}
public void setRpcinfo(String rpcinfo) {
this.rpcinfo = rpcinfo;
}
}
\ No newline at end of file
src/main/java/com/entity/host/MemState.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.entity.host;
import java.io.Serializable;
import java.util.Date;
import org.apache.commons.lang3.StringUtils;
/**
*
* @ClassName:MemState.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: 查看内存使用情况
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
public class MemState implements Serializable{
/**
*
*/
private static final long serialVersionUID = -1412473355088780549L;
/**
* 主键
*/
private String id;
/**
* 用户id
*/
private String accountId;
/**
* 用户帐号
*/
private String account;
/**
* host名称
*/
private String hostname;
/**
* 总计内存，M
*/
private String total;
/**
*已使用多少，M
*/
private String used;
/**
* 未使用，M
*/
private String free;
/**
* 已使用百分比%
*/
private String usePer;
/**
* 添加时间
* yyyy-MM-dd hh:mm:ss
*/
private String dateStr;
/**
* 创建时间
*/
private Date createTime;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id == null ? null : id.trim();
}
public String getTotal() {
return total;
}
public void setTotal(String total) {
this.total = total;
}
public String getUsed() {
return used;
}
public void setUsed(String used) {
this.used = used;
}
public String getFree() {
return free;
}
public void setFree(String free) {
this.free = free;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
public String getDateStr() {
if(!StringUtils.isEmpty(dateStr)&&dateStr.length()>16){
return dateStr.substring(5);
}
return dateStr;
}
public void setDateStr(String dateStr) {
this.dateStr = dateStr;
}
public String getAccountId() {
return accountId;
}
public void setAccountId(String accountId) {
this.accountId = accountId;
}
public String getAccount() {
return account;
}
public void setAccount(String account) {
this.account = account;
}
public String getHostname() {
return hostname;
}
public void setHostname(String hostname) {
this.hostname = hostname;
}
public String getUsePer() {
return usePer;
}
public void setUsePer(String usePer) {
this.usePer = usePer;
}
}
\ No newline at end of file
src/main/java/com/entity/host/NetIoState.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.entity.host;
import java.io.Serializable;
import java.util.Date;
import org.apache.commons.lang3.StringUtils;
/**
*
* @ClassName:NetIoState.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: 网络设备的吞吐率
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
public class NetIoState implements Serializable{
/**
*
*/
private static final long serialVersionUID = -8314012397341825158L;
/**
* 主键
*/
private String id;
/**
* 用户id
*/
private String accountId;
/**
* 用户帐号
*/
private String account;
/**
* host名称
*/
private String hostname;
/**
* 每秒钟接收的数据包,rxpck/s
*/
private String rxpck;
/**
* 每秒钟发送的数据包,txpck/s
*/
private String txpck;
/**
* 每秒钟接收的KB数,rxkB/s
*/
private String rxbyt;
/**
* 每秒钟发送的KB数,txkB/s
*/
private String txbyt;
/**
* 每秒钟接收的压缩数据包,rxcmp/s
*/
private String rxcmp;
/**
* 每秒钟发送的压缩数据包,txcmp/s
*/
private String txcmp;
/**
* 每秒钟接收的多播数据包,rxmcst/s
*/
private String rxmcst;
/**
* 添加时间
* yyyy-MM-dd hh:mm:ss
*/
private String dateStr;
/**
* 创建时间
*/
private Date createTime;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id == null ? null : id.trim();
}
public String getRxpck() {
return rxpck;
}
public void setRxpck(String rxpck) {
this.rxpck = rxpck;
}
public String getTxpck() {
return txpck;
}
public void setTxpck(String txpck) {
this.txpck = txpck;
}
public String getRxbyt() {
return rxbyt;
}
public void setRxbyt(String rxbyt) {
this.rxbyt = rxbyt;
}
public String getTxbyt() {
return txbyt;
}
public void setTxbyt(String txbyt) {
this.txbyt = txbyt;
}
public String getRxcmp() {
return rxcmp;
}
public void setRxcmp(String rxcmp) {
this.rxcmp = rxcmp;
}
public String getTxcmp() {
return txcmp;
}
public void setTxcmp(String txcmp) {
this.txcmp = txcmp;
}
public String getRxmcst() {
return rxmcst;
}
public void setRxmcst(String rxmcst) {
this.rxmcst = rxmcst;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
public String getDateStr() {
if(!StringUtils.isEmpty(dateStr)&&dateStr.length()>16){
return dateStr.substring(5);
}
return dateStr;
}
public void setDateStr(String dateStr) {
this.dateStr = dateStr;
}
public String getAccountId() {
return accountId;
}
public void setAccountId(String accountId) {
this.accountId = accountId;
}
public String getAccount() {
return account;
}
public void setAccount(String account) {
this.account = account;
}
public String getHostname() {
return hostname;
}
public void setHostname(String hostname) {
this.hostname = hostname;
}
}
\ No newline at end of file
src/main/java/com/entity/host/SysLoadState.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.entity.host;
import java.io.Serializable;
import java.util.Date;
import org.apache.commons.lang3.StringUtils;
/**
*
* @ClassName:SysLoadState.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: uptime查看系统负载状态
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
public class SysLoadState implements Serializable{
/**
*
*/
private static final long serialVersionUID = -4863071148000213553L;
/**
* 主键
*/
private String id;
/**
* 用户id
*/
private String accountId;
/**
* 用户帐号
*/
private String account;
/**
* host名称
*/
private String hostname;
/**
* 1分钟之前到现在的负载
*/
private String oneLoad;
/**
*5分钟之前到现在的负载
*/
private String fiveLoad;
/**
*15分钟之前到现在的负载
*/
private String fifteenLoad;
/**
* 登录用户数量
*/
private String users;
/**
* 添加时间
* yyyy-MM-dd hh:mm:ss
*/
private String dateStr;
/**
* 创建时间
*/
private Date createTime;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id == null ? null : id.trim();
}
public String getOneLoad() {
return oneLoad;
}
public void setOneLoad(String oneLoad) {
this.oneLoad = oneLoad;
}
public String getFiveLoad() {
return fiveLoad;
}
public void setFiveLoad(String fiveLoad) {
this.fiveLoad = fiveLoad;
}
public String getFifteenLoad() {
return fifteenLoad;
}
public void setFifteenLoad(String fifteenLoad) {
this.fifteenLoad = fifteenLoad;
}
public String getUsers() {
return users;
}
public void setUsers(String users) {
this.users = users;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
public String getDateStr() {
if(!StringUtils.isEmpty(dateStr)&&dateStr.length()>16){
return dateStr.substring(5);
}
return dateStr;
}
public void setDateStr(String dateStr) {
this.dateStr = dateStr;
}
public String getAccountId() {
return accountId;
}
public void setAccountId(String accountId) {
this.accountId = accountId;
}
public String getAccount() {
return account;
}
public void setAccount(String account) {
this.account = account;
}
public String getHostname() {
return hostname;
}
public void setHostname(String hostname) {
this.hostname = hostname;
}
}
\ No newline at end of file
src/main/java/com/entity/host/SystemInfo.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/entity/host/TcpState.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/entity/log/LogInfo.java 0 → 100644
浏览文件 @ 3d05c8e1
package com.entity.log;
import java.io.Serializable;
import java.util.Date;
/**
*
* @ClassName:LogInfo.java
* @version V1.0
* @author: http://www.wgstart.com
* @date: 2019年1月14日
* @Description: 日志信息
* @Copyright: 2019 wgcloud. All rights reserved.
*
*/
public class LogInfo implements Serializable{
/**
*
*/
private static final long serialVersionUID = 1565538727002722890L;
/**
* 主键
*/
private String id;
/**
* 用户帐号
*/
private String account;
/**
* host名称
*/
private String hostname;
/**
* 描述
*/
private String infoContent;
/**
* 0成功，1失败
*/
private String state;
/**
* 创建时间
*/
private Date createTime;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getAccount() {
return account;
}
public void setAccount(String account) {
this.account = account;
}
public String getHostname() {
return hostname;
}
public void setHostname(String hostname) {
this.hostname = hostname;
}
public String getInfoContent() {
return infoContent;
}
public void setInfoContent(String infoContent) {
this.infoContent = infoContent;
}
public String getState() {
return state;
}
public void setState(String state) {
this.state = state;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
}
\ No newline at end of file
src/main/java/com/entity/msg/MsgInfo.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/entity/user/AccountInfo.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/service/app/AppInfoService.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/service/app/AppStateService.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/service/dash/DashboardService.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/service/host/CpuStateService.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/service/host/DeskStateService.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/service/host/DiskIoStateService.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/service/host/MemStateService.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/service/host/NetIoStateService.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/service/host/SysLoadStateService.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/service/host/SystemInfoService.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/service/host/TcpStateService.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/service/log/LogInfoService.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/service/msg/MsgInfoService.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/service/remote/RemoteService.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/util/CodeUtil.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/util/CtrCommond.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/util/DateUtil.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/util/Encode.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/util/FormatUtil.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/util/HostInfo.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/util/LinuxCmd.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/util/MD5Utils.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/util/MyDayTask.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/util/MyHourTask.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/util/MyMinTask.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/util/PropertyUtil.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/util/UUIDUtil.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/util/linux/LinuxStrUtil.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/util/msg/EmailHandleThread.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/util/msg/WarnMailUtil.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/util/msg/WarnPools.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/util/shorturl/MD5.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/util/staticvar/BatchData.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/util/staticvar/HostKeys.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/java/com/util/staticvar/StaticKeys.java 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/resources/application.properties 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/resources/applicationContext.xml 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/resources/host.properties 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/resources/logback.xml 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/resources/mybatis/mapper/AppInfoMapper.xml 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/resources/mybatis/mapper/AppStateMapper.xml 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/resources/mybatis/mapper/CpuStateMapper.xml 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/resources/mybatis/mapper/DeskStateMapper.xml 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/resources/mybatis/mapper/DiskIoStateMapper.xml 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/resources/mybatis/mapper/LogInfoMapper.xml 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/resources/mybatis/mapper/MemStateMapper.xml 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/resources/mybatis/mapper/MsgInfoMapper.xml 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/resources/mybatis/mapper/NetIoStateMapper.xml 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/resources/mybatis/mapper/SystemInfoMapper.xml 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/resources/mybatis/mapper/TcpStateMapper.xml 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/resources/mybatis/mybatis-config.xml 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/resources/spring-mvc.xml 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/WEB-INF/web.xml 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/common/footer.jsp 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/common/header.jsp 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/common/menu.jsp 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/common/page.jsp 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/common/taglibs.jsp 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/AdminLTE/bootstrap/js/npm.js 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/AdminLTE/dist/css/AdminLTE.css 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/AdminLTE/dist/img/avatar.png 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/AdminLTE/dist/img/avatar04.png 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/AdminLTE/dist/img/avatar2.png 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/AdminLTE/dist/img/avatar3.png 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/AdminLTE/dist/img/avatar5.png 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/AdminLTE/dist/img/boxed-bg.jpg 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/AdminLTE/dist/img/boxed-bg.png 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/AdminLTE/dist/img/credit/visa.png 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/AdminLTE/dist/img/icons.png 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/AdminLTE/dist/img/photo1.png 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/AdminLTE/dist/img/photo2.png 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/AdminLTE/dist/img/photo3.jpg 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/AdminLTE/dist/img/photo4.jpg 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/AdminLTE/dist/js/app.js 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/AdminLTE/dist/js/app.min.js 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/AdminLTE/dist/js/demo.js 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/AdminLTE/plugins/iCheck/all.css 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/AdminLTE/plugins/pace/pace.css 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/AdminLTE/plugins/pace/pace.js 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/common/code.css 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/common/md5.js 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/echarts-2.2.7/doc/.DS_Store 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/echarts-2.2.7/doc/asset/.DS_Store 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/echarts-2.2.7/doc/asset/ico/k.png 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/echarts-2.2.7/doc/slide/.DS_Store 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/echarts-2.2.7/extension/.DS_Store 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/echarts-2.2.7/src/.DS_Store 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/echarts-2.2.7/src/chart.js 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/echarts-2.2.7/src/chart/bar.js 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/echarts-2.2.7/src/chart/base.js 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
src/main/webapp/static/echarts-2.2.7/src/chart/chord.js 0 → 100644
浏览文件 @ 3d05c8e1
此差异已折叠。
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或