'commit'

dsDataexV1.1/Config/Config.ini

@@ -34,7 +34,6 @@ replication = 1
 process_no = 1
 enable = 1
 
-
 [elasticsearch]
 nodes = http://10.10.14.61:9200,http://10.10.14.62:9200,http://10.10.14.63:9200
 user = root
@@ -49,6 +48,11 @@ user = root
 pwd = DsideaL147258369
 enable = 1
 
+[gpsql]
+is_rand_data_num = 0
+rand_range_min = 0.8
+rand_range_max = 1
+
 [project]
 project_name = dsDataex
 project_port = 9009

dsDataexV1.1/MyReport/GPSql/GPSqlService/GPSqlService.go

@@ -2,11 +2,15 @@ package GPSqlService
 
 import (
 	"dsDataex/MyReport/GPSql/GPSqlDAO"
+	"dsDataex/Utils/ConfigUtil"
 	"dsDataex/Utils/ES7SqlUtil"
 	"dsDataex/Utils/GPUtil"
 	"encoding/json"
+	"fmt"
+	"math/rand"
 	"reflect"
 	"strconv"
+	"time"
 )
 
 /**
@@ -208,6 +212,26 @@ func ConvEcharts(result []map[string]interface{}, queryGroup []string, queryCoun
 			}
 		}
 
+		// 生成0.8~1随机数， 与data相乘
+		// Start
+		if ConfigUtil.GPSQLIsRandDataNum == 1 {
+			rand.Seed(time.Now().UnixNano())
+			randRangeMin := int((1 - ConfigUtil.GPSQLRandRangeMin) * 100)
+			randRangeMax := int(ConfigUtil.GPSQLRandRangeMax * 100)
+			randInt := rand.Intn(randRangeMax - randRangeMin)
+			randFloat := float64(randInt) / 100
+
+			for key, value := range data {
+				f, _ := strconv.ParseFloat(value,64)
+				r := f * randFloat
+				val, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", r), 64)
+				s := strconv.FormatFloat(val,'f',-1,64)
+
+				data[key] = s
+			}
+		}
+		// End
+
 		echarts.Groups = append(echarts.Groups, group)
 		echarts.Datas = append(echarts.Datas, data)
 		echarts.Datas2 = append(echarts.Datas2, data2)
@@ -465,6 +489,28 @@ func ConvEcharts(result []map[string]interface{}, queryGroup []string, queryCoun
 			}
 		}
 
+		// 生成0.8~1随机数， 与data相乘
+		// Start
+		if ConfigUtil.GPSQLIsRandDataNum == 1 {
+			rand.Seed(time.Now().UnixNano())
+			randRangeMin := int((1 - ConfigUtil.GPSQLRandRangeMin) * 100)
+			randRangeMax := int(ConfigUtil.GPSQLRandRangeMax * 100)
+			randInt := rand.Intn(randRangeMax - randRangeMin)
+			randFloat := float64(randInt) / 100
+
+			for key, value := range datas {
+				for k , v := range value {
+					f, _ := strconv.ParseFloat(v,64)
+					r := f * randFloat
+					val, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", r), 64)
+					s := strconv.FormatFloat(val,'f',-1,64)
+
+					datas[key][k] = s
+				}
+			}
+		}
+		// End
+
 		echarts.Datas = datas
 		if total2Index > -1 {
 			echarts.Datas2 = datas2

dsDataexV1.1/Utils/ConfigUtil/ConfigUtil.go

@@ -23,6 +23,11 @@ var (
 	GreenPlumDataBase string
 	GreenPlumEnable	  int64
 
+	// GP-SQL配置
+	GPSQLIsRandDataNum	int64
+	GPSQLRandRangeMin	float64
+	GPSQLRandRangeMax	float64
+
 	//要发布到的主机信息
 	DistributeIp         string
 	DistributePort       int32
@@ -128,6 +133,12 @@ func init() {
 	// 是否启用
 	GreenPlumEnable = iniParser.GetInt64("greenplum", "enable")
 
+	// 是否启用随机数
+	GPSQLIsRandDataNum = iniParser.GetInt64("gpsql", "is_rand_data_num")
+	// 随机数乘以的系数
+	GPSQLRandRangeMin = iniParser.GetFloat64("gpsql", "rand_range_min")
+	GPSQLRandRangeMax = iniParser.GetFloat64("gpsql", "rand_range_max")
+
 	//发布的远端IP
 	DistributeIp = iniParser.GetString("distribute", "ip")
 	//发布的远端端口