更新 统计

data_indicators/main.go

@@ -181,8 +181,8 @@ func getIndicators() {
 	query := sessB.DB("qfw").C("bidding").Find(whereBidding).Select(fd).Iter()
 
 	biddingRealCount := 0
-	comein_publish_totaltime := int64(0) //comeintime 和 生索引 publish 时间 差值的总和
-	pici_comein_totaltime := int64(0)    //publishtime 和 生索引 pici 时间 差值的总和
+	pici_publish_totaltime := int64(0) //comeintime 和 生索引 publish 时间 差值的总和
+	pici_comein_totaltime := int64(0)  //publishtime 和 生索引 pici 时间 差值的总和
 	for tmp := make(map[string]interface{}); query.Next(tmp); {
 		if utils.IntAll(tmp["extracttype"]) != -1 && utils.ObjToString(tmp["sensitive"]) != "测试" && utils.IntAll(tmp["dataging"]) != 1 && utils.Float64All(tmp["infoformat"]) != 3 {
 			comeintime := utils.Int64All(tmp["comeintime"])
@@ -190,22 +190,20 @@ func getIndicators() {
 			pici := utils.Int64All(tmp["pici"])
 			if (comeintime-publishtime) < 12*60*60 && pici > 0 {
 				biddingRealCount++
-				diff1 := comeintime - publishtime
+				diff1 := pici - publishtime
 				diff2 := pici - comeintime
-				comein_publish_totaltime += diff1
+				pici_publish_totaltime += diff1
 				pici_comein_totaltime += diff2
 			}
 		}
 	}
 
 	if biddingRealCount > 0 {
-		comein_publish_avgtime := comein_publish_totaltime / int64(biddingRealCount)
+		pici_publish_avgtime := pici_publish_totaltime / int64(biddingRealCount)
 		pici_comein_avgtime := pici_comein_totaltime / int64(biddingRealCount)
-		Rest["数据整体流程均耗时（分钟）"] = comein_publish_avgtime / 60
-		Rest["数据处理均耗时（分钟）"] = pici_comein_avgtime / 60
-
-		log.Info("getIndicators", zap.Any("数据整体流程均耗时（分钟）", comein_publish_avgtime/60))
-		log.Info("getIndicators", zap.Any("数据处理均耗时（分钟）", pici_comein_avgtime/60))
+		Rest["数据整体流程均耗时（分钟）"] = fmt.Sprintf("%.2f", float64(pici_publish_avgtime)/float64(60))
+		Rest["数据处理均耗时（分钟）"] = fmt.Sprintf("%.2f", float64(pici_comein_avgtime)/float64(60))
+		Rest["数据采集均耗时（分钟）"] = fmt.Sprintf("%.2f", float64(pici_publish_avgtime-pici_comein_avgtime)/float64(60))
 	}
 
 	//7.数据行质量合格率,暂时写死
@@ -213,4 +211,5 @@ func getIndicators() {
 
 	MgoB.Save("bidding_zhibiao", Rest)
 
+	fmt.Println("over")
 }