mayiming/hldrCenter
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

添加speakerModel

Browse Source
This commit is contained in:
马懿铭
2025-10-29 11:09:25 +08:00
parent 4216dd341c
commit 2756036605
3 changed files with 200 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
server/internal/meetingspeaker/internal/meetingmodel/meetingmodel.go Normal file
View File

@@ -0,0 +1,31 @@
package model
import (
"github.com/zeromicro/go-zero/core/stores/sqlx"
)
var _ MeetingModel = (*customMeetingModel)(nil)
type (
// MeetingModel is an interface to be customized, add more methods here,
// and implement the added methods in customMeetingModel.
MeetingModel interface {
meetingModel
withSession(session sqlx.Session) MeetingModel
}
customMeetingModel struct {
*defaultMeetingModel
}
)
// NewMeetingModel returns a model for the database table.
func NewMeetingModel(conn sqlx.SqlConn) MeetingModel {
return &customMeetingModel{
defaultMeetingModel: newMeetingModel(conn),
}
}
func (m *customMeetingModel) withSession(session sqlx.Session) MeetingModel {
return NewMeetingModel(sqlx.NewSqlConnFromSession(session))
}

123
server/internal/meetingspeaker/internal/meetingmodel/meetingmodel_gen.go Normal file
View File

@@ -0,0 +1,123 @@
// Code generated by goctl. DO NOT EDIT.
// versions:
// goctl version: 1.9.2
package model
import (
"context"
"database/sql"
"fmt"
"strings"
"time"
"github.com/zeromicro/go-zero/core/stores/builder"
"github.com/zeromicro/go-zero/core/stores/sqlx"
"github.com/zeromicro/go-zero/core/stringx"
)
var (
meetingFieldNames = builder.RawFieldNames(&Meeting{})
meetingRows = strings.Join(meetingFieldNames, ",")
meetingRowsExpectAutoSet = strings.Join(stringx.Remove(meetingFieldNames, "`id`", "`create_at`", "`create_time`", "`created_at`", "`update_at`", "`update_time`", "`updated_at`"), ",")
meetingRowsWithPlaceHolder = strings.Join(stringx.Remove(meetingFieldNames, "`id`", "`create_at`", "`create_time`", "`created_at`", "`update_at`", "`update_time`", "`updated_at`"), "=?,") + "=?"
)
type (
meetingModel interface {
Insert(ctx context.Context, data *Meeting) (sql.Result, error)
FindOne(ctx context.Context, id int64) (*Meeting, error)
Update(ctx context.Context, data *Meeting) error
Delete(ctx context.Context, id int64) error
FindPage(ctx context.Context, page, pageSize int) ([]*Meeting, int64, error)
SoftDelete(ctx context.Context, id int64) error
}
defaultMeetingModel struct {
conn sqlx.SqlConn
table string
}
Meeting struct {
Id int64 `db:"id"` // 会议ID（主键）
Theme string `db:"theme"` // 会议主题
Subtitle string `db:"subtitle"` // 会议副标题（允许为空）
Intro sql.NullString `db:"intro"` // 会议简介（支持长文本，可存Markdown）
CoverUrl string `db:"cover_url"` // 会议封面图片URL（允许为空）
ScheduleImageUrl string `db:"schedule_image_url"` // 会议日程图片URL（允许为空，无日程图时存空字符串）
StartTime time.Time `db:"start_time"` // 会议开始时间
EndTime time.Time `db:"end_time"` // 会议结束时间
CreateTime time.Time `db:"create_time"` // 创建时间
UpdateTime time.Time `db:"update_time"` // 更新时间
IsDelete int64 `db:"is_delete"` // 软删除（0-未删，1-已删）
}
)
func newMeetingModel(conn sqlx.SqlConn) *defaultMeetingModel {
return &defaultMeetingModel{
conn: conn,
table: "`meeting`",
}
}
func (m *defaultMeetingModel) Delete(ctx context.Context, id int64) error {
query := fmt.Sprintf("delete from %s where `id` = ?", m.table)
_, err := m.conn.ExecCtx(ctx, query, id)
return err
}
func (m *defaultMeetingModel) FindOne(ctx context.Context, id int64) (*Meeting, error) {
query := fmt.Sprintf("select %s from %s where `id` = ? limit 1", meetingRows, m.table)
var resp Meeting
err := m.conn.QueryRowCtx(ctx, &resp, query, id)
switch err {
case nil:
return &resp, nil
case sqlx.ErrNotFound:
return nil, ErrNotFound
default:
return nil, err
}
}
func (m *defaultMeetingModel) Insert(ctx context.Context, data *Meeting) (sql.Result, error) {
query := fmt.Sprintf("insert into %s (%s) values (?, ?, ?, ?, ?, ?, ?, ?)", m.table, meetingRowsExpectAutoSet)
ret, err := m.conn.ExecCtx(ctx, query, data.Theme, data.Subtitle, data.Intro, data.CoverUrl, data.ScheduleImageUrl, data.StartTime, data.EndTime, data.IsDelete)
return ret, err
}
func (m *defaultMeetingModel) Update(ctx context.Context, data *Meeting) error {
query := fmt.Sprintf("update %s set %s where `id` = ?", m.table, meetingRowsWithPlaceHolder)
_, err := m.conn.ExecCtx(ctx, query, data.Theme, data.Subtitle, data.Intro, data.CoverUrl, data.ScheduleImageUrl, data.StartTime, data.EndTime, data.IsDelete, data.Id)
return err
}
func (m *defaultMeetingModel) FindPage(ctx context.Context, page, pageSize int) ([]*Meeting, int64, error) {
// 计算偏移量（分页公式：offset = (page-1) * pageSize）
offset := (page - 1) * pageSize
// 1. 查询当前页数据（过滤软删除，按创建时间倒序，最新的在前）
query := fmt.Sprintf("select %s from %s where is_delete = 0 order by create_time desc limit ?, ?", meetingRows, m.table)
var meetings []*Meeting
err := m.conn.QueryRowsCtx(ctx, &meetings, query, offset, pageSize)
if err != nil {
return nil, 0, err
}
// 2. 查询总条数（用于计算总页数）
countQuery := fmt.Sprintf("select count(1) from %s where is_delete = 0", m.table)
var total int64
err = m.conn.QueryRowCtx(ctx, &total, countQuery)
if err != nil {
return nil, 0, err
}
return meetings, total, nil
}
func (m *defaultMeetingModel) SoftDelete(ctx context.Context, id int64) error {
query := fmt.Sprintf("update %s set `is_delete` = 1 where `id` = ?", m.table)
_, err := m.conn.ExecCtx(ctx, query, id)
return err
}
func (m *defaultMeetingModel) tableName() string {
return m.table
}

46
server/internal/meetingspeaker/internal/model/meetingspeakermodel_gen.go
View File

@@ -28,6 +28,8 @@ type (
FindOne(ctx context.Context, id int64) (*MeetingSpeaker, error)
Update(ctx context.Context, data *MeetingSpeaker) error
Delete(ctx context.Context, id int64) error
SoftDelete(ctx context.Context, id int64) (int64, error)
ListByMeetingId(ctx context.Context, meetingId int64, page, pageSize int) ([]*MeetingSpeaker, int64, error)
}
defaultMeetingSpeakerModel struct {
@@ -85,6 +87,50 @@ func (m *defaultMeetingSpeakerModel) Update(ctx context.Context, data *MeetingSp
return err
}
func (m *defaultMeetingSpeakerModel) SoftDelete(ctx context.Context, id int64) (int64, error) {
query := fmt.Sprintf(`
update %s
set is_delete=1
where id=? and is_delete=0`, m.table)
result, err := m.conn.ExecCtx(ctx, query, id)
if err != nil {
return 0, err
}
return result.RowsAffected() // 返回受影响行数，判断是否删除成功
}
func (m *defaultMeetingSpeakerModel) ListByMeetingId(ctx context.Context, meetingId int64, page, pageSize int) ([]*MeetingSpeaker, int64, error) {
// 分页参数计算
offset := (page - 1) * pageSize
if offset < 0 {
offset = 0
}
// 1. 查询当前页嘉宾数据（过滤软删除，按Sort升序，相同Sort按ID升序）
query := fmt.Sprintf(`
select %s from %s
where meeting_id = ? and is_delete = 0
order by sort asc, id asc
limit ?, ?`, meetingSpeakerRows, m.table)
var speakers []*MeetingSpeaker
err := m.conn.QueryRowsCtx(ctx, &speakers, query, meetingId, offset, pageSize)
if err != nil {
return nil, 0, err
}
// 2. 查询该会议下未删除的嘉宾总条数（用于分页计算）
countQuery := fmt.Sprintf(`
select count(1) from %s
where meeting_id = ? and is_delete = 0`, m.table)
var total int64
err = m.conn.QueryRowCtx(ctx, &total, countQuery, meetingId)
if err != nil {
return nil, 0, err
}
return speakers, total, nil
}
func (m *defaultMeetingSpeakerModel) tableName() string {
return m.table
}