diff --git a/db/copy_data.go b/db/copy_data.go index 995863c..443da0a 100644 --- a/db/copy_data.go +++ b/db/copy_data.go @@ -11,22 +11,18 @@ import ( func copyOrders(db *gorm.DB, timeNow time.Time) { order := &data.Orders{} start := timeNow.Format("2006-01-02 15:04:05") - first := db.Debug().Where("create_time < ?", timeNow.Format("2006-01-02 15:04:05")).Order("create_time asc").First(order) + first := db.Debug().Where("create_time < ?", start).Order("create_time asc").First(order) if first.RowsAffected == 0 { fmt.Println("no orders data") return } - //parse, err := time.Parse("2006-01-02T15:04:05Z07:00", order.CreateTime) - //if err != nil { - // fmt.Println("parse order create_time error:", err) - //} - //deleteTime := parse.Format("2006-01-02 15:04:05") - //fmt.Println("copy orders from:", deleteTime) - // - //db.Debug().Where("create_time >= ?", deleteTime).Delete(&data.OrdersCopy1{}) + deleteTime := order.CreateTime + fmt.Println("copy orders from:", deleteTime) - _execOrders(db, timeNow.Format("2006-01-02 15:04:05"), 0) + db.Debug().Where("create_time >= ?", deleteTime).Delete(&data.OrdersCopy1{}) + + _execOrders(db, start, 0) db.Debug().Where("create_time < ?", start).Delete(&data.Orders{}) } @@ -56,22 +52,17 @@ func _execOrders(db *gorm.DB, timeNow string, index int) { func copyPayDetails(db *gorm.DB, timeNow time.Time) { detail := &data.PayDetails{} start := timeNow.Format("2006-01-02 15:04:05") - first := db.Model(detail).Where("create_time < ?", timeNow.Format("2006-01-02 15:04:05")).Order("create_time asc").First(detail) + first := db.Model(detail).Where("create_time < ?", start).Order("create_time asc").First(detail) if first.RowsAffected == 0 { fmt.Println("no pay_details data") return } - //parse, err := time.Parse("2006-01-02T15:04:05Z07:00", detail.CreateTime) - //if err != nil { - // fmt.Println("parse pay_details create_time error:", err) - //} - //deleteTime := parse.Format("2006-01-02 15:04:05") - //fmt.Println("copy pay_details from:", deleteTime) - // - //db.Debug().Where("create_time >= ?", deleteTime).Delete(&data.PayDetailsCopy1{}) + deleteTime := detail.CreateTime - _execPayDetails(db, timeNow.Format("2006-01-02 15:04:05"), 0) + db.Debug().Where("create_time >= ?", deleteTime).Delete(&data.PayDetailsCopy1{}) + + _execPayDetails(db, start, 0) db.Debug().Where("create_time < ?", start).Delete(&data.PayDetails{}) } @@ -101,22 +92,17 @@ func _execPayDetails(db *gorm.DB, timeNow string, index int) { func copyUserMoneyDetails(db *gorm.DB, timeNow time.Time) { detail := &data.UserMoneyDetails{} start := timeNow.Format("2006-01-02 15:04:05") - first := db.Model(detail).Where("create_time < ?", timeNow.Format("2006-01-02 15:04:05")).Order("create_time asc").First(detail) + first := db.Model(detail).Where("create_time < ?", start).Order("create_time asc").First(detail) if first.RowsAffected == 0 { fmt.Println("no user_money_details data") return } - //parse, err := time.Parse("2006-01-02T15:04:05Z07:00", detail.CreateTime) - //if err != nil { - // fmt.Println("parse pay_details create_time error:", err) - //} - //deleteTime := parse.Format("2006-01-02 15:04:05") - //fmt.Println("copy pay_details from:", deleteTime) - // - //db.Debug().Where("create_time >= ?", deleteTime).Delete(&data.UserMoneyDetailsCopy1{}) + deleteTime := detail.CreateTime - _execUserMoneyDetails(db, timeNow.Format("2006-01-02 15:04:05"), 0) + db.Debug().Where("create_time >= ?", deleteTime).Delete(&data.UserMoneyDetailsCopy1{}) + + _execUserMoneyDetails(db, start, 0) db.Debug().Where("create_time < ?", start).Delete(&data.UserMoneyDetails{}) } diff --git a/db/db_manager.go b/db/db_manager.go index ce4f3c8..a37858a 100644 --- a/db/db_manager.go +++ b/db/db_manager.go @@ -24,7 +24,7 @@ func CopyData() { panic("dbList is nil") } - timeNow := time.Now().Add(-30 * 24 * time.Hour) + timeNow := time.Now().Add(-7 * 24 * time.Hour) format := timeNow.Format("2006-01-02") parse, _ := time.Parse("2006-01-02", format) diff --git a/db_config.yml b/db_config.yml index 6a49ab0..3a4674b 100644 --- a/db_config.yml +++ b/db_config.yml @@ -12,14 +12,27 @@ dev: - duanju-3 - duanju-4 +#prod: +# host: rm-gc7xx913734hv5w5qxo.mysql.cn-chengdu.rds.aliyuncs.com +# name: video_user +# password: VideoUser@1 +# port: 3306 +# dbs: +# - duanju-0 +# - duanju-1 +# - duanju-2 +# - duanju-3 +# - duanju-4 + + prod: - host: rm-gc7xx913734hv5w5qxo.mysql.cn-chengdu.rds.aliyuncs.com - name: video_user - password: VideoUser@1 + host: localhost + name: root + password: gongyijieqp002 port: 3306 dbs: - duanju-0 - - duanju-1 - - duanju-2 - - duanju-3 - - duanju-4 +# - duanju-1 +# - duanju-2 +# - duanju-3 +# - duanju-4 diff --git a/main.go b/main.go index 80ba195..b19488c 100644 --- a/main.go +++ b/main.go @@ -1,28 +1,26 @@ package main import ( - "fmt" - "github.com/robfig/cron/v3" "time" "video_data_copy/db" ) func main() { - //_startCopyData() - c := cron.New() - _, err := c.AddFunc("0 4 * * *", func() { - fmt.Println("定时任务开始执行") - _startCopyData() - }) - if err != nil { - fmt.Printf("添加定时任务出错: %v\n", err) - return - } - - fmt.Println("定时任务启动成功") - c.Start() - - select {} + _startCopyData() + //c := cron.New() + //_, err := c.AddFunc("0 4 * * *", func() { + // fmt.Println("定时任务开始执行") + // _startCopyData() + //}) + //if err != nil { + // fmt.Printf("添加定时任务出错: %v\n", err) + // return + //} + // + //fmt.Println("定时任务启动成功") + //c.Start() + // + //select {} } func _startCopyData() { diff --git a/video_data_copy_linux_amd64 b/video_data_copy_linux_amd64 index 521ff16..6a9d6db 100755 Binary files a/video_data_copy_linux_amd64 and b/video_data_copy_linux_amd64 differ