mirror of
https://gitee.com/pan648540858/wvp-GB28181-pro.git
synced 2026-05-24 05:57:49 +08:00
去除信息统计
This commit is contained in:
parent
8edd72fc23
commit
20939fcce8
@ -1,98 +0,0 @@
|
|||||||
package com.genersoft.iot.vmp.conf;
|
|
||||||
|
|
||||||
import com.alibaba.fastjson2.JSON;
|
|
||||||
import com.genersoft.iot.vmp.common.StatisticsInfo;
|
|
||||||
import com.genersoft.iot.vmp.utils.DateUtil;
|
|
||||||
import com.genersoft.iot.vmp.utils.GitUtil;
|
|
||||||
import com.genersoft.iot.vmp.utils.SystemInfoUtils;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import okhttp3.*;
|
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
|
||||||
import org.springframework.boot.CommandLineRunner;
|
|
||||||
import org.springframework.core.annotation.Order;
|
|
||||||
import org.springframework.data.redis.connection.RedisConnection;
|
|
||||||
import org.springframework.data.redis.core.RedisTemplate;
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
|
|
||||||
import javax.sql.DataSource;
|
|
||||||
import java.io.File;
|
|
||||||
import java.sql.DatabaseMetaData;
|
|
||||||
import java.util.Objects;
|
|
||||||
|
|
||||||
@Component
|
|
||||||
@Order(value=100)
|
|
||||||
@Slf4j
|
|
||||||
public class StatisticsInfoTask implements CommandLineRunner {
|
|
||||||
|
|
||||||
@Autowired
|
|
||||||
private GitUtil gitUtil;
|
|
||||||
|
|
||||||
@Autowired
|
|
||||||
private RedisTemplate<Object, Object> redisTemplate;
|
|
||||||
|
|
||||||
@Autowired
|
|
||||||
private DataSource dataSource;
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void run(String... args) throws Exception {
|
|
||||||
try {
|
|
||||||
StatisticsInfo statisticsInfo = new StatisticsInfo();
|
|
||||||
statisticsInfo.setDeviceId(SystemInfoUtils.getHardwareId());
|
|
||||||
statisticsInfo.setBranch(gitUtil.getBranch());
|
|
||||||
statisticsInfo.setGitCommitId(gitUtil.getGitCommitId());
|
|
||||||
statisticsInfo.setGitUrl(gitUtil.getGitUrl());
|
|
||||||
statisticsInfo.setVersion(gitUtil.getBuildVersion());
|
|
||||||
|
|
||||||
statisticsInfo.setOsName(System.getProperty("os.name"));
|
|
||||||
statisticsInfo.setArch(System.getProperty("os.arch"));
|
|
||||||
statisticsInfo.setJdkVersion(System.getProperty("java.version"));
|
|
||||||
|
|
||||||
statisticsInfo.setDocker(new File("/.dockerenv").exists());
|
|
||||||
try {
|
|
||||||
statisticsInfo.setRedisVersion(getRedisVersion());
|
|
||||||
}catch (Exception ignored) {}
|
|
||||||
try {
|
|
||||||
DatabaseMetaData metaData = dataSource.getConnection().getMetaData();
|
|
||||||
statisticsInfo.setSqlVersion(metaData.getDatabaseProductVersion());
|
|
||||||
statisticsInfo.setSqlType(metaData.getDriverName());
|
|
||||||
}catch (Exception ignored) {}
|
|
||||||
statisticsInfo.setTime(DateUtil.getNow());
|
|
||||||
sendPost(statisticsInfo);
|
|
||||||
|
|
||||||
|
|
||||||
}catch (Exception e) {
|
|
||||||
log.error("[获取信息失败] ", e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getRedisVersion() {
|
|
||||||
if (redisTemplate.getConnectionFactory() == null) {
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
RedisConnection connection = redisTemplate.getConnectionFactory().getConnection();
|
|
||||||
if (connection.info() == null) {
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
return connection.info().getProperty("redis_version");
|
|
||||||
}
|
|
||||||
|
|
||||||
public void sendPost(StatisticsInfo statisticsInfo) {
|
|
||||||
OkHttpClient.Builder httpClientBuilder = new OkHttpClient.Builder();
|
|
||||||
OkHttpClient client = httpClientBuilder.build();
|
|
||||||
|
|
||||||
RequestBody requestBodyJson = RequestBody.create(MediaType.parse("application/json; charset=utf-8"), JSON.toJSONString(statisticsInfo));
|
|
||||||
|
|
||||||
Request request = new Request.Builder()
|
|
||||||
.post(requestBodyJson)
|
|
||||||
.url("http://api.wvp-pro.cn:136/api/statistics/ping")
|
|
||||||
// .url("http://127.0.0.1:11236/api/statistics/ping")
|
|
||||||
.addHeader("Content-Type", "application/json")
|
|
||||||
.build();
|
|
||||||
try {
|
|
||||||
Response response = client.newCall(request).execute();
|
|
||||||
response.close();
|
|
||||||
Objects.requireNonNull(response.body()).close();
|
|
||||||
|
|
||||||
}catch (Exception ignored){}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Loading…
Reference in New Issue
Block a user