czg_team/data_copy
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

删除数据bug 修复

Browse Source
This commit is contained in:
GYJ
2025-03-24 15:04:31 +08:00
parent 9cf4e456f3
commit ca62f9b361
5 changed files with 52 additions and 55 deletions
Download Patch File Download Diff File Expand all files Collapse all files

46
db/copy_data.go
View File

@@ -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{})
}

2
db/db_manager.go
View File

@@ -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)

27
db_config.yml
View File

@@ -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

32
main.go
View File

@@ -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() {

BIN
video_data_copy_linux_amd64
View File

Binary file not shown.