78 lines
2.0 KiB
Go
78 lines
2.0 KiB
Go
|
// Code generated by goctl. DO NOT EDIT.
|
||
|
|
package model
|
||
|
|
|
||
|
|
import (
|
||
|
|
"context"
|
||
|
|
"time"
|
||
|
|
|
||
|
|
"github.com/zeromicro/go-zero/core/stores/monc"
|
||
|
|
"go.mongodb.org/mongo-driver/bson"
|
||
|
|
"go.mongodb.org/mongo-driver/bson/primitive"
|
||
|
|
"go.mongodb.org/mongo-driver/mongo"
|
||
|
|
)
|
||
|
|
|
||
|
|
var prefixCommentCacheKey = "cache:comment:"
|
||
|
|
|
||
|
|
type commentModel interface {
|
||
|
|
Insert(ctx context.Context, data *Comment) error
|
||
|
|
FindOne(ctx context.Context, id string) (*Comment, error)
|
||
|
|
Update(ctx context.Context, data *Comment) (*mongo.UpdateResult, error)
|
||
|
|
Delete(ctx context.Context, id string) (int64, error)
|
||
|
|
}
|
||
|
|
|
||
|
|
type defaultCommentModel struct {
|
||
|
|
conn *monc.Model
|
||
|
|
}
|
||
|
|
|
||
|
|
func newDefaultCommentModel(conn *monc.Model) *defaultCommentModel {
|
||
|
|
return &defaultCommentModel{conn: conn}
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *defaultCommentModel) Insert(ctx context.Context, data *Comment) error {
|
||
|
|
if data.ID.IsZero() {
|
||
|
|
data.ID = primitive.NewObjectID()
|
||
|
|
data.CreateAt = time.Now()
|
||
|
|
data.UpdateAt = time.Now()
|
||
|
|
}
|
||
|
|
|
||
|
|
key := prefixCommentCacheKey + data.ID.Hex()
|
||
|
|
_, err := m.conn.InsertOne(ctx, key, data)
|
||
|
|
return err
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *defaultCommentModel) FindOne(ctx context.Context, id string) (*Comment, error) {
|
||
|
|
oid, err := primitive.ObjectIDFromHex(id)
|
||
|
|
if err != nil {
|
||
|
|
return nil, ErrInvalidObjectId
|
||
|
|
}
|
||
|
|
|
||
|
|
var data Comment
|
||
|
|
key := prefixCommentCacheKey + id
|
||
|
|
err = m.conn.FindOne(ctx, key, &data, bson.M{"_id": oid})
|
||
|
|
switch err {
|
||
|
|
case nil:
|
||
|
|
return &data, nil
|
||
|
|
case monc.ErrNotFound:
|
||
|
|
return nil, ErrNotFound
|
||
|
|
default:
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *defaultCommentModel) Update(ctx context.Context, data *Comment) (*mongo.UpdateResult, error) {
|
||
|
|
data.UpdateAt = time.Now()
|
||
|
|
key := prefixCommentCacheKey + data.ID.Hex()
|
||
|
|
res, err := m.conn.UpdateOne(ctx, key, bson.M{"_id": data.ID}, bson.M{"$set": data})
|
||
|
|
return res, err
|
||
|
|
}
|
||
|
|
|
||
|
|
func (m *defaultCommentModel) Delete(ctx context.Context, id string) (int64, error) {
|
||
|
|
oid, err := primitive.ObjectIDFromHex(id)
|
||
|
|
if err != nil {
|
||
|
|
return 0, ErrInvalidObjectId
|
||
|
|
}
|
||
|
|
key := prefixCommentCacheKey + id
|
||
|
|
res, err := m.conn.DeleteOne(ctx, key, bson.M{"_id": oid})
|
||
|
|
return res, err
|
||
|
|
}
|