package models

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

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

type UserMsg struct {
	Id            int64     `orm:"column(id);pk" description:"消息表id"`
	CompanyId     int64     `orm:"column(company_id)" description:"公司编号"`
	ReceiveUserId int64     `orm:"column(receive_user_id)" description:"接收用户id"`
	MsgType       int       `orm:"column(msg_type)" description:"消息类型 1.公司公告 2.表彰通知 4.互动消息 8.机会审核"`
	Message       string    `orm:"column(message)" description:"消息内容"`
	SourceId      int64     `orm:"column(source_id)" description:"来源id （机会编号 /评论编号）"`
	SourceType    int       `orm:"column(source_type)"`
	IsPublic      int8      `orm:"column(is_public)" description:"1:公开 0:不公开"`
	IsRead        int8      `orm:"column(is_read)" description:"1:已读 0:未读"`
	CreateAt      time.Time `orm:"column(create_at);type(timestamp);auto_now" description:"创建时间"`
	ChanceId      int64     `orm:"column(chance_id)" description:"机会编号"`
	SenderUserId  int64     `orm:"column(sender_user_id)" description:"发送人用户id"`
	Data          string    `orm:"column(data)" description:"扩展数据"`
}

const (
	MsgTypeBulletin    = 1 //公告
	MsgTypeCommend     = 2 //表彰
	MsgTypeInteraction = 4 //互动消息
	MsgTypeAudit       = 8 //机会审核
)
const (
	SourceTypeChance   = 1
	SourceTypeComment  = 2
	SourceTypeBulletin = 3
)
const (
	//用户未读消息列表
	SqlUserMsgsUnRead = "select * from user_msg where company_id=? and receive_user_id=? and msg_type=? and is_read=0 order by create_at desc" //所有未读消息
	//用户未读消息列表
	SqlUserMsgsUnReadWithPublic = "select * from user_msg where company_id=? and receive_user_id=? and msg_type=? and is_read=0 and is_public=1 order by create_at desc" //所有未读消息
	//用户未读消息 - 单个
	SqlUserMsgUnRead = "select * from user_msg where source_id=? and company_id=? and receive_user_id=? and msg_type=? and is_read=0 order by create_at desc" //特定未读消息
	//用户消息 - 按 1.源id 2.接收者id 3.消息类型
	SqlUserMsg = "select * from user_msg where source_id=?  and receive_user_id=? and msg_type=? " //特定未读消息
	//删除消息
	SqlDeleteUserMsg = "delete from user_msg where source_id=? and source_type=?  and receive_user_id=?  and msg_type=? " //特定未读消息

	SqlBulletinUnRead = `select id,source_id from user_msg where msg_type=?  and is_read =0 and receive_user_id = ?`
)

func (t *UserMsg) TableName() string {
	return "user_msg"
}

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

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

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

// UpdateUserMsg updates UserMsg by Id and returns error if
// the record to be updated doesn't exist
func UpdateUserMsgById(m *UserMsg) (err error) {
	o := orm.NewOrm()
	v := UserMsg{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
}

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

//消息总数
func GetUserMsgTotals(userId int64, companyId int64, msgType int, v interface{}) (err error) {
	o := orm.NewOrm()
	sql := `select COUNT(*) as total,msg_type from user_msg 
where (msg_type & ?)>0 and receive_user_id = ?  and is_read=0 and company_id=? 
GROUP BY msg_type`
	if err = utils.ExecuteQueryAllWithOrmer(o, v, sql, msgType, userId, companyId); err == nil {
		return
	}
	return
}

//公告消息数量
func GetBulletinUserMsgTotals(userId int64, companyId int64, msgType int, v interface{}) (err error) {
	o := orm.NewOrm()
	sql := `select COUNT(*) as total from user_msg 
where msg_type=1 and receive_user_id = ?  and is_public=1 and is_read=0 and company_id=? 
GROUP BY msg_type`
	if err = utils.ExecuteQueryOneWithOrmer(o, v, sql, userId, companyId); err == nil {
		return
	}
	return
}

//标记消息已读
func UpdateUserMsgSetRead(userId int64, companyId int64, msgType int, msgId int64) (err error) {
	o := orm.NewOrm()
	sql := `update user_msg set is_read = 1
	where receive_user_id = ?  and company_id=?`
	if msgType > 0 {
		sql += fmt.Sprintf(" and (msg_type & %v)>0", msgType)
	}
	if msgId > 0 {
		sql += fmt.Sprintf(" and id=%v", msgId)
	}
	if _, err = o.Raw(sql, userId, companyId).Exec(); err != nil {
		return
	}
	return
}

//获取用户消息列表
func GetUserMsgs(userId, companyId int64, msgType int, sourceType int, lastId int64, pageSize int) (v []*UserMsg, total int, err error) {
	sql := mybeego.NewSqlExutor().Table("user_msg").Order("create_at desc")
	if lastId > 0 {
		sql.Where(fmt.Sprintf("id>%d", lastId))
	}
	if msgType > 0 {
		sql.Where(fmt.Sprintf("msg_type=%d", msgType))
	}
	sql.Where(fmt.Sprintf("receive_user_id=%d", userId))
	sql.Where(fmt.Sprintf("company_id=%d", companyId))
	if sourceType > 0 {
		sql.Where(fmt.Sprintf("source_type=%d", sourceType))
	}
	if pageSize > 0 {
		sql.Limit(0, pageSize)
	}
	if total, err = sql.Querys(&v); err == nil {
		return
	}
	return
}

//获取公告消息列表
func GetUserMsgsBulletin(userId, companyId int64, msgType int, lastId int64, pageSize int, v interface{}) (total int, err error) {
	sql := `select a.id msg_id,b.id,b.title,unix_timestamp(a.create_at)*1000 update_at,a.is_read `
	sqlCount := `select count(0) `
	where := `from user_msg a,bulletin b where a.receive_user_id =? and a.company_id=? and a.source_id = b.id and a.msg_type=? and a.is_public=1 and a.company_id=? and b.status=2 `
	sqlCount += where
	if err = utils.ExecuteQueryOne(&total, sqlCount, userId, companyId, msgType, companyId); err != nil {
		return
	}
	if lastId > 0 {
		where += fmt.Sprintf(` and b.id>%v`, lastId)
	}
	if v == nil {
		return
	}
	where += ` order by a.create_at desc`
	sql += where + " limit ?"
	if err = utils.ExecuteQueryAll(v, sql, userId, companyId, msgType, companyId, pageSize); err != nil {
		return
	}
	return
}

//获取机会消息
func GetChanceMsg(uid, lastId int64, pageSize int, msgType int, v interface{}) (total int, err error) {
	sql := `select a.*,b.images,b.speechs,b.videos from (
select a.*,b.source_content,b.enable_status,b.user_id chance_user_id,b.create_at,b.review_status,b.approve_data,b.status from (
select id,company_id,receive_user_id,message,source_id,is_read,chance_id,create_at msg_time,data,sender_user_id
from user_msg where receive_user_id=?  and source_type=1 and (?=0 or id<?) and msg_type=?
)a left outer join chance b on a.source_id = b.id
)a left outer join chance_data b on a.source_id =b.chance_id
order by a.msg_time desc
LIMIT ?`

	sqlCount := `select count(0)
from user_msg where receive_user_id=? and source_type=1  and msg_type=? `
	if err = utils.ExecuteQueryOne(&total, sqlCount, uid, msgType); err != nil {
		return
	}
	if v != nil {
		if err = utils.ExecuteQueryAll(v, sql, uid, lastId, lastId, msgType, pageSize); err != nil {
			return
		}
	}
	return
}

//获取机会评论消息
func GetChanceCommentMsg(uid, lastId int64, pageSize int, msgType int, v interface{}) (total int, err error) {
	sql := `select a.*,b.content commented_content,b.create_at commented_time,b.user_id commented_user_id from (
select a.*,b.images,b.speechs,b.videos from (
select a.*,b.source_content,b.enable_status,b.user_id chance_user_id,b.create_at,b.review_status,b.status from (
select id,message content,source_type,source_id,is_read,create_at comment_time,chance_id,receive_user_id,sender_user_id from user_msg
where receive_user_id =? and  (?=0 or id<?) and msg_type=? and sender_user_id<>0
)a left outer join chance b on a.source_id = b.id and source_type=1
)a left outer join chance_data b on a.source_id = b.chance_id and source_type = 1
)a left outer join comment b on a.source_id = b.id and a.source_type=2
order by a.comment_time desc
LIMIT ?`

	sqlCount := `select count(0)
from user_msg where receive_user_id=? and source_type=1  and msg_type=? and sender_user_id<>0`
	if err = utils.ExecuteQueryOne(&total, sqlCount, uid, msgType); err != nil {
		return
	}
	if v != nil {
		if err = utils.ExecuteQueryAll(v, sql, uid, lastId, lastId, msgType, pageSize); err != nil {
			return
		}
	}
	return
}

func GetChanceReviseMsg(uid, lastId int64, pageSize int, msgType int, v interface{}) (total int, err error) {
	sql := `select a.*,b.images,b.speechs,b.videos from (
select a.*,b.source_content,b.enable_status,b.user_id chance_user_id,b.create_at,b.review_status,b.status from (
select id msg_id,message content,source_type,source_id,is_read,create_at msg_time,chance_id,receive_user_id,sender_user_id from user_msg
where receive_user_id =? and  (?=0 or id<?) and msg_type=?
)a left outer join chance b on a.chance_id = b.id 
)a left outer join chance_data b on a.chance_id = b.chance_id 
order by msg_id desc
LIMIT ?`

	sqlCount := `select count(0)
from user_msg where receive_user_id=?  and msg_type=?`
	if err = utils.ExecuteQueryOne(&total, sqlCount, uid, msgType); err != nil {
		return
	}
	if v != nil {
		if err = utils.ExecuteQueryAll(v, sql, uid, lastId, lastId, msgType, pageSize); err != nil {
			return
		}
	}
	return
}