| | |
|---|
| | | @Override |
|---|
| | | public void calculate(List<MonitorQualifyResult> list) { |
|---|
| | | //获取分区域的指标数量 |
|---|
| | | Map<String, MonitorQualifyCalculation.AreaStats> areaStatsMap = getAreaStatsMap(list); |
|---|
| | | Map<String, MonitorQualifyCalculation.AreaStats> areaStatsMap = getAreaStatsMap(list,Boolean.TRUE); |
|---|
| | | if (areaStatsMap == null) return; |
|---|
| | | |
|---|
| | | // 查询是否index表已经存在今日数据 |
|---|
| | |
|---|
| | | //返回对象的引用，如果不存在会放入新的key,value |
|---|
| | | AreaStats stats = areaStatsMap.computeIfAbsent(key, k -> new AreaStats()); |
|---|
| | | stats.totalMonitors++; |
|---|
| | | if (result != null && correct(result)){ |
|---|
| | | if (result != null && MonitorQualifyResult.correct(result)){ |
|---|
| | | stats.qualifyMonitor++; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | //全对返ture |
|---|
| | | private boolean correct(MonitorQualifyResult result) { |
|---|
| | | return checkError(result.getName()) && |
|---|
| | | checkError(result.getCivilCode()) && |
|---|
| | | checkError(result.getIp()) && |
|---|
| | | checkError(result.getSerialNumber()) && |
|---|
| | | checkError(result.getMacdz()) && |
|---|
| | | checkError(result.getLatitude()) && |
|---|
| | | checkError(result.getLongitude()) && |
|---|
| | | checkError(result.getSbzt()) && |
|---|
| | | checkError(result.getSxjcjqy()) && |
|---|
| | | checkError(result.getSxjgnlx()) && |
|---|
| | | checkError(result.getJkdwlx()) && |
|---|
| | | checkError(result.getIntegrated_device()) |
|---|
| | | ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | //检查指标，正常返回true |
|---|
| | | private boolean checkError(MonitorQualifyResult.QualifyResult result) { |
|---|
| | | return result.getError() != null && !result.getError(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
