dao

package

v0.0.0-...-ca8b2fb Latest Latest Go to latest Published: Aug 7, 2025 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type MysqlManagerImpl struct {
	// contains filtered or unexported fields
}

func NewMysqlManager(db *gorm.DB) *MysqlManagerImpl

func (m *MysqlManagerImpl) CreateSummary(ctx context.Context, summary *model.Summary) error

func (m *MysqlManagerImpl) GetSummary(ctx context.Context, RoomId int64) (*model.Summary, error)

func (m *MysqlManagerImpl) IsSummaried(ctx context.Context, RoomId int64) int8

这里有点绕，如果是 false 并且 err == nil，表示我们是第一次来，需要创建结构体但是如果是 true 并且 err == nil，表示总结就结束了如果是 false 并且 err != nil 并且 false 则是其他错误，需要返回

func (m *MysqlManagerImpl) SetSummary(ctx context.Context, RoomId int64, summary string) error

这里表示总结完成之后，更新状态和智能纪要内容。

type RedisManagerImpl struct {
	// contains filtered or unexported fields
}

func NewRedisManager(client *redis.Client) *RedisManagerImpl

func (r *RedisManagerImpl) AppendMsg(ctx context.Context, msg *model.RedisHistory, roomId int64, userId int64) error

func (r *RedisManagerImpl) GetHistory(ctx context.Context, userId int64, roomId int64) ([]*model.RedisHistory, error)

历史消息存 redis 里面，

func (r *RedisManagerImpl) LockSummaryStarted(ctx context.Context, roomId int64) (bool, error)