Update level.go

domain/model/cp_m/level.go

@@ -316,7 +316,7 @@ func AddCpLevelPoints(model *domain.Model, cpRelation CpRelation, points mysql.N
 func ClearExpireCpPoints(model *domain.Model) error {
 	var cpLevels []*CpLevel
 	// 过期 + (积分 or level) 大于0
-	if err := model.DB().Table("cp_level l").Joins("cp_relation r ON l.cp_id = r.id").Where("l.expire_at < ? AND (l.points > 0 or l.level > 0) ", time.Now()).Find(&cpLevels).Error; err != nil {
+	if err := model.DB().Table("cp_level l").Joins("INNER JOIN cp_relation r ON l.cp_id = r.id").Where("l.expire_at < ? AND (l.points > 0 or l.level > 0) ", time.Now()).Find(&cpLevels).Error; err != nil {
 		return myerr.WrapErr(err)
 	}
 	for _, cpLevel := range cpLevels {