package models

import (
	"fmt"
	"gitlab.fjmaimaimai.com/mmm-go/gocomm/pkg/log"
	"gitlab.fjmaimaimai.com/mmm-go/gocomm/pkg/mybeego"
	"time"

	"github.com/astaxie/beego/orm"
)

type Comment struct {
	Id           int64     `orm:"column(id);pk" description:"评论编号"`
	UserId       int64     `orm:"column(user_id)" description:"表user.id "`
	Content      string    `orm:"column(content);size(1024)" description:"评论内容"`
	ViewTotal    int       `orm:"column(view_total)" description:"浏览总数"`
	ZanTotal     int       `orm:"column(zan_total)" description:"点赞总数"`
	CommentTotal int       `orm:"column(comment_total)" description:"评论总数"`
	SourceType   int8      `orm:"column(source_type)" description:"来源类型 1:机会 2:评论"`
	SourceId     int64     `orm:"column(source_id)" description:"来源唯一编号"`
	CreateAt     time.Time `orm:"column(create_at);type(timestamp)" description:"创建时间"`
}

func (t *Comment) TableName() string {
	return "comment"
}

func init() {
	orm.RegisterModel(new(Comment))
}

// AddComment insert a new Comment into database and returns
// last inserted Id on success.
func AddComment(m *Comment) (id int64, err error) {
	o := orm.NewOrm()
	id, err = o.Insert(m)
	return
}

// GetCommentById retrieves Comment by Id. Returns error if
// Id doesn't exist
func GetCommentById(id int64) (v *Comment, err error) {
	o := orm.NewOrm()
	v = &Comment{Id: id}
	if err = o.Read(v); err == nil {
		return v, nil
	}
	return nil, err
}

// UpdateComment updates Comment by Id and returns error if
// the record to be updated doesn't exist
func UpdateCommentById(m *Comment) (err error) {
	o := orm.NewOrm()
	v := Comment{Id: m.Id}
	// ascertain id exists in the database
	if err = o.Read(&v); err == nil {
		var num int64
		if num, err = o.Update(m); err == nil {
			fmt.Println("Number of records updated in database:", num)
		}
	}
	return
}

// DeleteComment deletes Comment by Id and returns error if
// the record to be deleted doesn't exist
func DeleteComment(id int64) (err error) {
	o := orm.NewOrm()
	v := Comment{Id: id}
	// ascertain id exists in the database
	if err = o.Read(&v); err == nil {
		var num int64
		if num, err = o.Delete(&Comment{Id: id}); err == nil {
			fmt.Println("Number of records deleted in database:", num)
		}
	}
	return
}

//获取评论列表
func GetComments(userId int64, sourceType int, sourceId int64, lastId int64, pageSize int) (v []*Comment, total int, err error) {
	sql := mybeego.NewSqlExutor().Table("comment").Order("create_at desc")
	if userId > 0 {
		sql.Where(fmt.Sprintf("user_id=%d", userId))
	}
	if sourceId > 0 {
		sql.Where(fmt.Sprintf("source_id=%d", sourceId))
	}
	if sourceType > 0 {
		sql.Where(fmt.Sprintf("source_type=%d", sourceType))
	}
	if pageSize > 0 {
		sql.Limit(0, pageSize)
	}
	if lastId > 0 {
		sql.Where(fmt.Sprintf("id<%d", lastId))
	}
	if total, err = sql.Querys(&v); err == nil {
		if total == 0 {
			log.Debug(sql.Strings())
		}
		return
	}

	return
}