/*
 * @Author: drowningwhale 351231768@qq.com
 * @Date: 2023-10-01 17:16:01
 * @LastEditors: drowningwhale 351231768@qq.com
 * @LastEditTime: 2023-10-03 19:43:46
 * @FilePath: \bluebell\dao\mysql\community.go
 * @Description: 这是默认设置,请设置`customMade`, 打开koroFileHeader查看配置 进行设置: https://github.com/OBKoro1/koro1FileHeader/wiki/%E9%85%8D%E7%BD%AE
 */
package mysql

import (
	"gitee.com/mq-go/bluebell/dao"
	"gitee.com/mq-go/bluebell/global"
	"gitee.com/mq-go/bluebell/models"
	"gorm.io/gorm"
	"gorm.io/gorm/clause"
)

func GetCommunityList() (CommunityList []models.CommunityList, err error) {

	result := global.DB.Model(&models.Community{}).Find(&CommunityList)
	if result.Error != nil {
		err = result.Error
		return
	}

	return
}

func GetCommunityDetailById(id int) (CommunityDetail models.CommunityDetail, err error) {
	result := global.DB.Model(&models.Community{}).Where(&models.Community{CommunityId: id}).Find(&CommunityDetail)
	if result.Error != nil {
		err = result.Error
		return
	}
	return
}

func CreatePost(post *models.Post) (err error) {
	post.PostId = int(dao.GenID())
	result := global.DB.Create(post)
	if result.Error != nil {
		err = result.Error
		return
	}
	return
}

func GetPostDetailForId(id int) (post models.Post, err error) {
	result := global.DB.Where(&models.Post{PostId: id}).First(&post)
	if result.Error != nil {
		err = result.Error
		return
	}

	return
}

// 查询帖子列表
func GetPostList(page, pageSize int) (posts []*models.Post, err error) {

	result := global.DB.Scopes(Paginate(page, pageSize)).Find(&posts)
	if result.Error != nil {
		err = result.Error
		return
	}
	return
}

// 根据ids查询
func GetPostListByIds(ids []string) (posts []*models.Post, err error) {
	result := global.DB.Where("post_id IN (?)", ids).Clauses(clause.OrderBy{
		Expression: clause.Expr{SQL: "FIELD(post_id,?)", Vars: []interface{}{ids}, WithoutParentheses: true},
	}).Find(&posts)
	err = result.Error
	return
}

// 分页
func Paginate(page, pageSize int) func(db *gorm.DB) *gorm.DB {
	return func(db *gorm.DB) *gorm.DB {
		if page <= 0 {
			page = 1
		}

		switch {
		case pageSize > 100:
			pageSize = 100
		case pageSize <= 0:
			pageSize = 10
		}

		offset := (page - 1) * pageSize
		return db.Offset(offset).Limit(pageSize)
	}
}