新增认证量统计

src/main/java/com/yingxin/prms/api/ReliabilityApi.java

@@ -106,5 +106,13 @@ public class ReliabilityApi {
     public Map saveTopology(@RequestBody String json) {
         return manager.saveTopology(json);
     }
+    /**
+     *  保存数据
+     * @return
+     */
+    @GetMapping("getStatistics")
+    public Map getStatistics() {
+        return manager.getStatistics();
+    }
 
 }

src/main/java/com/yingxin/prms/service/business/Manager.java

@@ -7,6 +7,7 @@ import com.yingxin.prms.service.asyncTask.QueryHostStatusTask;
 import com.yingxin.prms.service.dao.CassandraDaoImpl;
 import com.yingxin.prms.service.dao.FlowDaoImpl;
 import com.yingxin.prms.utils.CurveFittingMethod;
+import com.yingxin.prms.utils.SendHttpUtil;
 import com.yingxin.prms.utils.TimeUtil;
 import com.yingxin.prms.utils.TokenUtil;
 import net.sf.json.JSONObject;
@@ -243,6 +244,7 @@ public class Manager {
 
         /* 获取前六天数据 datapoints 具体时间段 数据 */
         List<DataPoint> dataPoints = getAgodataPoints(servicePath,flag);
+        /* 获取今天数据 */
         List<DataPoint> currDataPoint = getdataPoints(servicePath,flag);
 
         /* 获取当前需要展示的横坐标 */
@@ -267,7 +269,7 @@ public class Manager {
             double [] x=new double[dataPoints.size()];
             double [] y=new double[dataPoints.size()];
             for (int i=0;i<dataPoints.size();i++){
-                x[i]=dataPoints.get(i).getTimestamp();
+                x[i]= i+1;
             }
             for (int i=0;i<dataPoints.size();i++){
                 y[i]=Double.parseDouble(String.valueOf(dataPoints.get(i).getValue()) );
@@ -490,14 +492,11 @@ public class Manager {
         return result;
     }
 
-    public List<FlowLine> selectTopologyLine() {
 
-        List<FlowLine> flowLines = flowDao.findLineAll();
-        if(flowLines.size()>0){
-            return null;
-        }else {
-            return flowLines;
-        }
+    public Map getStatistics() {
+        Server_Host_Info serverHostInfo = cassandraDao.getStatisticsUri();
+        Map<String, String> map = SendHttpUtil.doGet(serverHostInfo.getService_path());
+        return map;
     }
 
     /*

src/main/java/com/yingxin/prms/service/dao/CassandraDaoImpl.java

@@ -91,4 +91,9 @@ public class CassandraDaoImpl {
         String cql ="select * from ctid_prof.server_host_info where service_path = '"+url+"' allow filtering;;";
         return template.selectOne(cql, Server_Host_Info.class);
     }
+
+    public Server_Host_Info getStatisticsUri() {
+        String cql = "select * from server_host_info where cluster_name = '平台业务实时统计服务' allow filtering";
+        return template.selectOne(cql, Server_Host_Info.class);
+    }
 }