package domain

// SysMessageProduce
type SysMessageProduce struct {
	// 消息ID
	Id int64 `json:"id"`
	// 主题
	Topic string `json:"topic"`
	// 分区信息
	Partition int `json:"partition"`
	// 消息内容
	Value string `json:"value"`
	// 消息时间
	MsgTime int64 `json:"msgTime"`
	// 状态
	Status int64 `json:"status"`
}

type SysMessageProduceRepository interface {
	Save(dm *SysMessageProduce) (*SysMessageProduce, error)
	Remove(dm *SysMessageProduce) (*SysMessageProduce, error)
	FindOne(queryOptions map[string]interface{}) (*SysMessageProduce, error)
	Find(queryOptions map[string]interface{}) (int64, []*SysMessageProduce, error)
}

func (m *SysMessageProduce) Identify() interface{} {
	if m.Id == 0 {
		return nil
	}
	return m.Id
}