Authored by qinchao

增加接口大数据上报

@@ -8,5 +8,5 @@ public interface BigDataKeyInfoMapper { @@ -8,5 +8,5 @@ public interface BigDataKeyInfoMapper {
8 /** 8 /**
9 * 写入influxdb 9 * 写入influxdb
10 */ 10 */
11 - void write(String name,String script,String status,String task_id,String count_name,double count); 11 + void write(String content,String name,String script,String status,String task_id,String count_name,double count);
12 } 12 }
@@ -23,7 +23,7 @@ public class BigDataKeyInfoMapperImpl implements BigDataKeyInfoMapper { @@ -23,7 +23,7 @@ public class BigDataKeyInfoMapperImpl implements BigDataKeyInfoMapper {
23 * 写入influxdb 23 * 写入influxdb
24 */ 24 */
25 @Override 25 @Override
26 - public void write(String name,String script,String status,String task_id,String count_name,double count){ 26 + public void write(String content,String name,String script,String status,String task_id,String count_name,double count){
27 Point point = Point.measurement("bigdata_key_info") 27 Point point = Point.measurement("bigdata_key_info")
28 .tag("name",name) 28 .tag("name",name)
29 .tag("script", script) 29 .tag("script", script)
@@ -31,6 +31,7 @@ public class BigDataKeyInfoMapperImpl implements BigDataKeyInfoMapper { @@ -31,6 +31,7 @@ public class BigDataKeyInfoMapperImpl implements BigDataKeyInfoMapper {
31 .tag("task_id",task_id) 31 .tag("task_id",task_id)
32 .tag("count_name",count_name) 32 .tag("count_name",count_name)
33 .addField("count",count) 33 .addField("count",count)
  34 + .addField("content",content)
34 .build(); 35 .build();
35 36
36 try{ 37 try{
@@ -60,7 +60,7 @@ public class BigdataCtrl { @@ -60,7 +60,7 @@ public class BigdataCtrl {
60 } 60 }
61 61
62 //上报给influxdb 62 //上报给influxdb
63 - bigDataKeyInfoMapper.write(name,script,status,task_id,count_name,count); 63 + bigDataKeyInfoMapper.write(jsonObject.toJSONString(),name,script,status,task_id,count_name,count);
64 return new BaseResponse(); 64 return new BaseResponse();
65 } 65 }
66 66