更新 数据监控

bidding_listen/main.go

@@ -48,6 +48,7 @@ func specData() {
 
 //deleteData 删除数据
 func deleteData() {
+	defer utils.Catch()
 	now := time.Now()
 	if GF.Cron.Delete >= 0 {
 		log.Error("deleteData", zap.String("配置文件错误", "没有配置定时删除的delete"))
@@ -75,7 +76,7 @@ func deleteData() {
 		finalId = utils.IntAll((*lastInfo)[0]["id"])
 	}
 
-	log.Info("dealData", zap.Int("finalId", finalId))
+	log.Info("deleteData", zap.Int("finalId", finalId))
 	lastid, total := 0, 0
 
 	for {
@@ -94,17 +95,17 @@ SELECT
 		ctx := context.Background()
 		rows, err := Mysql.DB.QueryContext(ctx, query)
 		if err != nil {
-			log.Info("dealData", zap.Any("QueryContext err", err))
+			log.Info("deleteData", zap.Any("QueryContext err", err))
 		}
 
 		if finalId == lastid {
-			log.Info("dealData over", zap.Any("total", total), zap.Any("lastid", lastid))
+			log.Info("deleteData over", zap.Any("total", total), zap.Any("lastid", lastid))
 			break
 		}
 
 		columns, err := rows.Columns()
 		if err != nil {
-			log.Info("dealData", zap.Any("rows.Columns", err))
+			log.Info("deleteData", zap.Any("rows.Columns", err))
 		}
 
 		for rows.Next() {
@@ -118,7 +119,7 @@ SELECT
 
 			err = rows.Scan(scanArgs...)
 			if err != nil {
-				log.Info("dealData", zap.Any("rows.Scan", err))
+				log.Info("deleteData", zap.Any("rows.Scan", err))
 				break
 			}
 
@@ -132,7 +133,7 @@ SELECT
 
 			total++
 			if total%1000 == 0 {
-				log.Info("dealData", zap.Int("current total", total))
+				log.Info("deleteData", zap.Int("current total", total))
 			}
 			lastid = utils.IntAll(ret["id"])
 
@@ -147,12 +148,12 @@ SELECT
 		rows.Close()
 
 		if err := rows.Err(); err != nil {
-			log.Info("buyer", zap.Any("err", err))
+			log.Info("deleteData", zap.Any("err", err))
 		}
 
 	}
 
-	log.Info("dealData", zap.Int("结束，total：", total))
+	log.Info("deleteData", zap.Int("结束，total：", total))
 
 }