getAllEffectiveMachines();
-
/**
*
* Description: 获取有效机房
@@ -245,10 +230,16 @@ public interface MachineCenter {
*/
public Boolean isK8sMachine(String host);
+ public Map getAllMachineEnv(Date searchDate,int type);
+
+ public Map getExceptionMachineEnv(Date searchDate);
+
/**
* 获取机器列表的第一台机器资源
* @return
*/
public String getFirstMachineIp();
+ public List checkMachineModule(List machineStatsList);
+
}
diff --git a/cachecloud-web/src/main/java/com/sohu/cache/machine/impl/MachineCenterImpl.java b/cachecloud-web/src/main/java/com/sohu/cache/machine/impl/MachineCenterImpl.java
index 7ec5332a..e76eb1dd 100644
--- a/cachecloud-web/src/main/java/com/sohu/cache/machine/impl/MachineCenterImpl.java
+++ b/cachecloud-web/src/main/java/com/sohu/cache/machine/impl/MachineCenterImpl.java
@@ -7,6 +7,7 @@
import com.sohu.cache.async.KeyCallable;
import com.sohu.cache.constant.InstanceStatusEnum;
import com.sohu.cache.constant.MachineConstant;
+import com.sohu.cache.constant.MachineInfoEnum;
import com.sohu.cache.constant.MachineInfoEnum.TypeEnum;
import com.sohu.cache.dao.*;
import com.sohu.cache.entity.*;
@@ -16,6 +17,7 @@
import com.sohu.cache.protocol.MachineProtocol;
import com.sohu.cache.redis.RedisCenter;
import com.sohu.cache.redis.enums.DirEnum;
+import com.sohu.cache.ssh.SSHService;
import com.sohu.cache.ssh.SSHUtil;
import com.sohu.cache.stats.instance.InstanceStatsCenter;
import com.sohu.cache.task.BaseTask;
@@ -23,8 +25,10 @@
import com.sohu.cache.task.constant.ResourceEnum;
import com.sohu.cache.util.*;
import com.sohu.cache.web.enums.BooleanEnum;
+import com.sohu.cache.web.enums.CheckEnum;
import com.sohu.cache.web.enums.MachineMemoryDistriEnum;
-import com.sohu.cache.web.enums.RedisVersionEnum;
+import com.sohu.cache.web.enums.ModuleEnum;
+import com.sohu.cache.web.vo.MachineEnv;
import com.sohu.cache.web.vo.MachineStatsVo;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.collections.MapUtils;
@@ -45,8 +49,9 @@
import java.nio.file.Path;
import java.nio.file.Paths;
import java.text.DecimalFormat;
+import java.text.SimpleDateFormat;
import java.util.*;
-import java.util.concurrent.TimeUnit;
+import java.util.concurrent.*;
import java.util.stream.Collectors;
import static com.google.common.base.Preconditions.checkArgument;
@@ -76,14 +81,18 @@ public class MachineCenterImpl implements MachineCenter {
private ResourceDao resourceDao;
@Autowired
private MachineRoomDao machineRoomDao;
+ @Autowired
+ private SSHService sshService;
+ @Autowired
+ protected AsyncService asyncService;
+ @Autowired
+ private ForkJoinPool forkJoinPool;
/**
* 邮箱报警
*/
@Autowired
private EmailComponent emailComponent;
- @Autowired
- private AsyncService asyncService;
@PostConstruct
public void init() {
@@ -743,58 +752,6 @@ public Map getK8sMachineMap() {
return k8sMachineMaps;
}
- public List getMachineInstallRedisStat(List resourceList){
-
- List allMachines = machineDao.getAllMachines();
- //1.遍历机器安装情况
- Map installStats = new HashMap();
- if (allMachines != null && allMachines.size() > 0) {
- for (MachineInfo machine : allMachines) {
- String version_install = machine.getVersionInstall();
- if (!StringUtils.isEmpty(version_install)) {
- for (String installinfo : version_install.split(";")) {
- Integer count = MapUtils.getInteger(installStats, installinfo, 0) + 1;
- installStats.put(installinfo, count);
- }
- }
- }
- }
-
- //2. app stat
- List