diff --git a/script/cp_pairs_stat.go b/script/cp_pairs_stat.go index 18fa460b4c3a263975dd2d52ff38579462e4c721..d55a6267811f155ec8cc1585e337721b001fa6cf 100644 --- a/script/cp_pairs_stat.go +++ b/script/cp_pairs_stat.go @@ -81,13 +81,14 @@ type CpInfo struct { } type CpLevel struct { - CpId uint64 - Level uint64 + CpId uint64 + Level uint64 + CreatedTime time.Time } func main() { var cpInfos []*CpInfo - if err := mysql.ProdReadOnlyDB.Table("cp_relation").Select("id,user_id1,user_id2,created_time").Find(&cpInfos).Error; err != nil { + if err := mysql.ProdReadOnlyDB.Table("cp_relation").Select("id,user_id1,user_id2").Find(&cpInfos).Error; err != nil { panic(err) } var cpIds []uint64 @@ -95,7 +96,7 @@ func main() { cpIds = append(cpIds, v.Id) } var cpLevels []CpLevel - if err := mysql.ProdReadOnlyDB.Table("cp_level").Select("cp_id,level").Where("cp_id in ?", cpIds).Find(&cpLevels).Error; err != nil { + if err := mysql.ProdReadOnlyDB.Table("cp_level").Select("cp_id,level,created_time").Where("cp_id in ?", cpIds).Find(&cpLevels).Error; err != nil { panic(err) } var userIds []uint64 @@ -106,6 +107,7 @@ func main() { for _, v2 := range cpLevels { if v.Id == v2.CpId { cpInfos[i].Level = v2.Level + cpInfos[i].CreatedTime = v2.CreatedTime break } }