diff --git a/db/copy_data.go b/db/copy_data.go index ca8d433..46eeaef 100644 --- a/db/copy_data.go +++ b/db/copy_data.go @@ -10,7 +10,8 @@ import ( func copyOrders(db *gorm.DB, timeNow time.Time) { order := &data.Orders{} - db.Model(order).Where("create_time < ?", timeNow.Format("2006-01-02 15:04:05")).Order("create_time asc").First(order) + start := timeNow.Format("2006-01-02 15:04:05") + db.Debug().Where("create_time < ?", timeNow.Format("2006-01-02 15:04:05")).Order("create_time asc").First(order) parse, err := time.Parse("2006-01-02T15:04:05Z07:00", order.CreateTime) if err != nil { @@ -18,11 +19,11 @@ func copyOrders(db *gorm.DB, timeNow time.Time) { } format := parse.Format("2006-01-02 15:04:05") fmt.Println("copy orders from:", format) - db.Debug().Where("create_time >= ?", format).Delete(&data.OrdersCopy1{}) + db.Debug().Where("create_time >= ?", start).Delete(&data.OrdersCopy1{}) _execOrders(db, timeNow.Format("2006-01-02 15:04:05"), 0) - db.Debug().Where("create_time < ?", format).Delete(&data.Orders{}) + db.Debug().Where("create_time < ?", start).Delete(&data.Orders{}) } func _execOrders(db *gorm.DB, timeNow string, index int) { @@ -49,6 +50,7 @@ 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") db.Model(detail).Where("create_time < ?", timeNow.Format("2006-01-02 15:04:05")).Order("create_time asc").First(detail) parse, err := time.Parse("2006-01-02T15:04:05Z07:00", detail.CreateTime) @@ -57,11 +59,11 @@ func copyPayDetails(db *gorm.DB, timeNow time.Time) { } format := parse.Format("2006-01-02 15:04:05") fmt.Println("copy pay_details from:", format) - db.Debug().Where("create_time >= ?", format).Delete(&data.PayDetailsCopy1{}) + db.Debug().Where("create_time >= ?", start).Delete(&data.PayDetailsCopy1{}) _execPayDetails(db, timeNow.Format("2006-01-02 15:04:05"), 0) - db.Debug().Where("create_time < ?", format).Delete(&data.PayDetails{}) + db.Debug().Where("create_time < ?", start).Delete(&data.PayDetails{}) } func _execPayDetails(db *gorm.DB, timeNow string, index int) { @@ -88,6 +90,7 @@ 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") db.Model(detail).Where("create_time < ?", timeNow.Format("2006-01-02 15:04:05")).Order("create_time asc").First(detail) parse, err := time.Parse("2006-01-02T15:04:05Z07:00", detail.CreateTime) @@ -96,11 +99,11 @@ func copyUserMoneyDetails(db *gorm.DB, timeNow time.Time) { } format := parse.Format("2006-01-02 15:04:05") fmt.Println("copy pay_details from:", format) - db.Debug().Where("create_time >= ?", format).Delete(&data.UserMoneyDetailsCopy1{}) + db.Debug().Where("create_time >= ?", start).Delete(&data.UserMoneyDetailsCopy1{}) _execUserMoneyDetails(db, timeNow.Format("2006-01-02 15:04:05"), 0) - db.Debug().Where("create_time < ?", format).Delete(&data.UserMoneyDetails{}) + db.Debug().Where("create_time < ?", start).Delete(&data.UserMoneyDetails{}) } func _execUserMoneyDetails(db *gorm.DB, timeNow string, index int) { diff --git a/db/db_manager.go b/db/db_manager.go index 6ca3814..ce4f3c8 100644 --- a/db/db_manager.go +++ b/db/db_manager.go @@ -28,6 +28,8 @@ func CopyData() { format := timeNow.Format("2006-01-02") parse, _ := time.Parse("2006-01-02", format) + fmt.Println("Copy data from", parse) + for _, db := range dbList { copyOrders(db, parse) copyPayDetails(db, parse) diff --git a/db_config.yml b/db_config.yml index bfce4ee..6a49ab0 100644 --- a/db_config.yml +++ b/db_config.yml @@ -1,4 +1,4 @@ -env: dev +env: prod dev: host: rm-gc712o11yndj78x6a6o.mysql.cn-chengdu.rds.aliyuncs.com diff --git a/main.go b/main.go index dd6f9ca..b19488c 100644 --- a/main.go +++ b/main.go @@ -1,27 +1,26 @@ package main import ( - "fmt" - "github.com/robfig/cron/v3" "time" "video_data_copy/db" ) func main() { - 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 6f942a8..4ad2a6f 100755 Binary files a/video_data_copy_linux_amd64 and b/video_data_copy_linux_amd64 differ