完成会议管理
This commit is contained in:
@@ -0,0 +1,50 @@
|
||||
// Code scaffolded by goctl. Safe to edit.
|
||||
// goctl 1.9.1
|
||||
|
||||
package meeting_speaker
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"net/http"
|
||||
|
||||
"github.com/JACKYMYPERSON/hldrCenter/config"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/logic/meeting_speaker"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/model"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/types"
|
||||
"github.com/zeromicro/go-zero/core/stores/sqlx"
|
||||
"github.com/zeromicro/go-zero/rest/httpx"
|
||||
)
|
||||
|
||||
func CreateSpeakerHandler(cfg *config.Config) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
var req types.CreateSpeakerReq
|
||||
if err := httpx.Parse(r, &req); err != nil {
|
||||
httpx.ErrorCtx(r.Context(), w, err)
|
||||
return
|
||||
}
|
||||
|
||||
mysqlCfg := cfg.MySQL
|
||||
dsn := fmt.Sprintf(
|
||||
"%s:%s@tcp(%s:%d)/%s?charset=%s&parseTime=true&loc=Local",
|
||||
mysqlCfg.Username,
|
||||
mysqlCfg.Password,
|
||||
mysqlCfg.Host,
|
||||
mysqlCfg.Port,
|
||||
mysqlCfg.Database,
|
||||
mysqlCfg.Charset,
|
||||
)
|
||||
fmt.Println("接收到articlePost请求")
|
||||
|
||||
conn := sqlx.NewSqlConn("mysql", dsn)
|
||||
|
||||
speakerModel := model.NewMeetingSpeakerModel(conn)
|
||||
|
||||
l := meeting_speaker.NewCreateSpeakerLogic(r.Context(), cfg, speakerModel)
|
||||
resp, err := l.CreateSpeaker(&req)
|
||||
if err != nil {
|
||||
httpx.ErrorCtx(r.Context(), w, err)
|
||||
} else {
|
||||
httpx.OkJsonCtx(r.Context(), w, resp)
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,49 @@
|
||||
// Code scaffolded by goctl. Safe to edit.
|
||||
// goctl 1.9.1
|
||||
|
||||
package meeting_speaker
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"net/http"
|
||||
|
||||
"github.com/JACKYMYPERSON/hldrCenter/config"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/logic/meeting_speaker"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/model"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/types"
|
||||
"github.com/zeromicro/go-zero/core/stores/sqlx"
|
||||
"github.com/zeromicro/go-zero/rest/httpx"
|
||||
)
|
||||
|
||||
func DeleteSpeakerHandler(cfg *config.Config) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
var req types.DeleteSpeakerReq
|
||||
if err := httpx.Parse(r, &req); err != nil {
|
||||
httpx.ErrorCtx(r.Context(), w, err)
|
||||
return
|
||||
}
|
||||
|
||||
mysqlCfg := cfg.MySQL
|
||||
dsn := fmt.Sprintf(
|
||||
"%s:%s@tcp(%s:%d)/%s?charset=%s&parseTime=true&loc=Local",
|
||||
mysqlCfg.Username,
|
||||
mysqlCfg.Password,
|
||||
mysqlCfg.Host,
|
||||
mysqlCfg.Port,
|
||||
mysqlCfg.Database,
|
||||
mysqlCfg.Charset,
|
||||
)
|
||||
fmt.Println("接收到articlePost请求")
|
||||
|
||||
conn := sqlx.NewSqlConn("mysql", dsn)
|
||||
speakerModel := model.NewMeetingSpeakerModel(conn)
|
||||
|
||||
l := meeting_speaker.NewDeleteSpeakerLogic(r.Context(), cfg, speakerModel)
|
||||
resp, err := l.DeleteSpeaker(&req)
|
||||
if err != nil {
|
||||
httpx.ErrorCtx(r.Context(), w, err)
|
||||
} else {
|
||||
httpx.OkJsonCtx(r.Context(), w, resp)
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,50 @@
|
||||
// Code scaffolded by goctl. Safe to edit.
|
||||
// goctl 1.9.1
|
||||
|
||||
package meeting_speaker
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"net/http"
|
||||
|
||||
"github.com/JACKYMYPERSON/hldrCenter/config"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/logic/meeting_speaker"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/model"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/types"
|
||||
"github.com/zeromicro/go-zero/core/stores/sqlx"
|
||||
"github.com/zeromicro/go-zero/rest/httpx"
|
||||
)
|
||||
|
||||
func GetSpeakerHandler(cfg *config.Config) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
var req types.GetSpeakerReq
|
||||
if err := httpx.Parse(r, &req); err != nil {
|
||||
httpx.ErrorCtx(r.Context(), w, err)
|
||||
return
|
||||
}
|
||||
|
||||
mysqlCfg := cfg.MySQL
|
||||
dsn := fmt.Sprintf(
|
||||
"%s:%s@tcp(%s:%d)/%s?charset=%s&parseTime=true&loc=Local",
|
||||
mysqlCfg.Username,
|
||||
mysqlCfg.Password,
|
||||
mysqlCfg.Host,
|
||||
mysqlCfg.Port,
|
||||
mysqlCfg.Database,
|
||||
mysqlCfg.Charset,
|
||||
)
|
||||
fmt.Println("接收到articlePost请求")
|
||||
|
||||
conn := sqlx.NewSqlConn("mysql", dsn)
|
||||
|
||||
speakerModel := model.NewMeetingSpeakerModel(conn)
|
||||
|
||||
l := meeting_speaker.NewGetSpeakerLogic(r.Context(), cfg, speakerModel)
|
||||
resp, err := l.GetSpeaker(&req)
|
||||
if err != nil {
|
||||
httpx.ErrorCtx(r.Context(), w, err)
|
||||
} else {
|
||||
httpx.OkJsonCtx(r.Context(), w, resp)
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,50 @@
|
||||
// Code scaffolded by goctl. Safe to edit.
|
||||
// goctl 1.9.1
|
||||
|
||||
package meeting_speaker
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"net/http"
|
||||
|
||||
"github.com/JACKYMYPERSON/hldrCenter/config"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/logic/meeting_speaker"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/model"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/types"
|
||||
"github.com/zeromicro/go-zero/core/stores/sqlx"
|
||||
"github.com/zeromicro/go-zero/rest/httpx"
|
||||
)
|
||||
|
||||
func ListSpeakersByMeetingHandler(cfg *config.Config) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
var req types.ListSpeakersByMeetingReq
|
||||
if err := httpx.Parse(r, &req); err != nil {
|
||||
httpx.ErrorCtx(r.Context(), w, err)
|
||||
return
|
||||
}
|
||||
|
||||
mysqlCfg := cfg.MySQL
|
||||
dsn := fmt.Sprintf(
|
||||
"%s:%s@tcp(%s:%d)/%s?charset=%s&parseTime=true&loc=Local",
|
||||
mysqlCfg.Username,
|
||||
mysqlCfg.Password,
|
||||
mysqlCfg.Host,
|
||||
mysqlCfg.Port,
|
||||
mysqlCfg.Database,
|
||||
mysqlCfg.Charset,
|
||||
)
|
||||
fmt.Println("接收到articlePost请求")
|
||||
|
||||
conn := sqlx.NewSqlConn("mysql", dsn)
|
||||
|
||||
speakerModel := model.NewMeetingSpeakerModel(conn)
|
||||
|
||||
l := meeting_speaker.NewListSpeakersByMeetingLogic(r.Context(), cfg, speakerModel)
|
||||
resp, err := l.ListSpeakersByMeeting(&req)
|
||||
if err != nil {
|
||||
httpx.ErrorCtx(r.Context(), w, err)
|
||||
} else {
|
||||
httpx.OkJsonCtx(r.Context(), w, resp)
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,50 @@
|
||||
// Code scaffolded by goctl. Safe to edit.
|
||||
// goctl 1.9.1
|
||||
|
||||
package meeting_speaker
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"net/http"
|
||||
|
||||
"github.com/JACKYMYPERSON/hldrCenter/config"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/logic/meeting_speaker"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/model"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/types"
|
||||
"github.com/zeromicro/go-zero/core/stores/sqlx"
|
||||
"github.com/zeromicro/go-zero/rest/httpx"
|
||||
)
|
||||
|
||||
func UpdateSpeakerHandler(cfg *config.Config) http.HandlerFunc {
|
||||
return func(w http.ResponseWriter, r *http.Request) {
|
||||
var req types.UpdateSpeakerReq
|
||||
if err := httpx.Parse(r, &req); err != nil {
|
||||
httpx.ErrorCtx(r.Context(), w, err)
|
||||
return
|
||||
}
|
||||
|
||||
mysqlCfg := cfg.MySQL
|
||||
dsn := fmt.Sprintf(
|
||||
"%s:%s@tcp(%s:%d)/%s?charset=%s&parseTime=true&loc=Local",
|
||||
mysqlCfg.Username,
|
||||
mysqlCfg.Password,
|
||||
mysqlCfg.Host,
|
||||
mysqlCfg.Port,
|
||||
mysqlCfg.Database,
|
||||
mysqlCfg.Charset,
|
||||
)
|
||||
fmt.Println("接收到articlePost请求")
|
||||
|
||||
conn := sqlx.NewSqlConn("mysql", dsn)
|
||||
|
||||
speakerModel := model.NewMeetingSpeakerModel(conn)
|
||||
|
||||
l := meeting_speaker.NewUpdateSpeakerLogic(r.Context(), cfg, speakerModel)
|
||||
resp, err := l.UpdateSpeaker(&req)
|
||||
if err != nil {
|
||||
httpx.ErrorCtx(r.Context(), w, err)
|
||||
} else {
|
||||
httpx.OkJsonCtx(r.Context(), w, resp)
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,36 @@
|
||||
// Code scaffolded by goctl. Safe to edit.
|
||||
// goctl 1.9.1
|
||||
|
||||
package meeting_speaker
|
||||
|
||||
import (
|
||||
"context"
|
||||
|
||||
"github.com/JACKYMYPERSON/hldrCenter/config"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/model"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/types"
|
||||
|
||||
"github.com/zeromicro/go-zero/core/logx"
|
||||
)
|
||||
|
||||
type CreateSpeakerLogic struct {
|
||||
logx.Logger
|
||||
ctx context.Context
|
||||
cfg *config.Config
|
||||
model model.MeetingSpeakerModel
|
||||
}
|
||||
|
||||
func NewCreateSpeakerLogic(ctx context.Context, cfg *config.Config, model model.MeetingSpeakerModel) *CreateSpeakerLogic {
|
||||
return &CreateSpeakerLogic{
|
||||
Logger: logx.WithContext(ctx),
|
||||
ctx: ctx,
|
||||
cfg: cfg,
|
||||
model: model,
|
||||
}
|
||||
}
|
||||
|
||||
func (l *CreateSpeakerLogic) CreateSpeaker(req *types.CreateSpeakerReq) (resp *types.CreateSpeakerResp, err error) {
|
||||
// todo: add your logic here and delete this line
|
||||
|
||||
return
|
||||
}
|
||||
@@ -0,0 +1,36 @@
|
||||
// Code scaffolded by goctl. Safe to edit.
|
||||
// goctl 1.9.1
|
||||
|
||||
package meeting_speaker
|
||||
|
||||
import (
|
||||
"context"
|
||||
|
||||
"github.com/JACKYMYPERSON/hldrCenter/config"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/model"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/types"
|
||||
|
||||
"github.com/zeromicro/go-zero/core/logx"
|
||||
)
|
||||
|
||||
type DeleteSpeakerLogic struct {
|
||||
logx.Logger
|
||||
ctx context.Context
|
||||
cfg *config.Config
|
||||
model model.MeetingSpeakerModel
|
||||
}
|
||||
|
||||
func NewDeleteSpeakerLogic(ctx context.Context, cfg *config.Config, model model.MeetingSpeakerModel) *DeleteSpeakerLogic {
|
||||
return &DeleteSpeakerLogic{
|
||||
Logger: logx.WithContext(ctx),
|
||||
ctx: ctx,
|
||||
cfg: cfg,
|
||||
model: model,
|
||||
}
|
||||
}
|
||||
|
||||
func (l *DeleteSpeakerLogic) DeleteSpeaker(req *types.DeleteSpeakerReq) (resp *types.DeleteSpeakerResp, err error) {
|
||||
// todo: add your logic here and delete this line
|
||||
|
||||
return
|
||||
}
|
||||
@@ -0,0 +1,36 @@
|
||||
// Code scaffolded by goctl. Safe to edit.
|
||||
// goctl 1.9.1
|
||||
|
||||
package meeting_speaker
|
||||
|
||||
import (
|
||||
"context"
|
||||
|
||||
"github.com/JACKYMYPERSON/hldrCenter/config"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/model"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/types"
|
||||
|
||||
"github.com/zeromicro/go-zero/core/logx"
|
||||
)
|
||||
|
||||
type GetSpeakerLogic struct {
|
||||
logx.Logger
|
||||
ctx context.Context
|
||||
cfg *config.Config
|
||||
model model.MeetingSpeakerModel
|
||||
}
|
||||
|
||||
func NewGetSpeakerLogic(ctx context.Context, cfg *config.Config, model model.MeetingSpeakerModel) *GetSpeakerLogic {
|
||||
return &GetSpeakerLogic{
|
||||
Logger: logx.WithContext(ctx),
|
||||
ctx: ctx,
|
||||
cfg: cfg,
|
||||
model: model,
|
||||
}
|
||||
}
|
||||
|
||||
func (l *GetSpeakerLogic) GetSpeaker(req *types.GetSpeakerReq) (resp *types.GetSpeakerResp, err error) {
|
||||
// todo: add your logic here and delete this line
|
||||
|
||||
return
|
||||
}
|
||||
@@ -0,0 +1,36 @@
|
||||
// Code scaffolded by goctl. Safe to edit.
|
||||
// goctl 1.9.1
|
||||
|
||||
package meeting_speaker
|
||||
|
||||
import (
|
||||
"context"
|
||||
|
||||
"github.com/JACKYMYPERSON/hldrCenter/config"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/model"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/types"
|
||||
|
||||
"github.com/zeromicro/go-zero/core/logx"
|
||||
)
|
||||
|
||||
type ListSpeakersByMeetingLogic struct {
|
||||
logx.Logger
|
||||
ctx context.Context
|
||||
cfg *config.Config
|
||||
model model.MeetingSpeakerModel
|
||||
}
|
||||
|
||||
func NewListSpeakersByMeetingLogic(ctx context.Context, cfg *config.Config, model model.MeetingSpeakerModel) *ListSpeakersByMeetingLogic {
|
||||
return &ListSpeakersByMeetingLogic{
|
||||
Logger: logx.WithContext(ctx),
|
||||
ctx: ctx,
|
||||
cfg: cfg,
|
||||
model: model,
|
||||
}
|
||||
}
|
||||
|
||||
func (l *ListSpeakersByMeetingLogic) ListSpeakersByMeeting(req *types.ListSpeakersByMeetingReq) (resp *types.ListSpeakersByMeetingResp, err error) {
|
||||
// todo: add your logic here and delete this line
|
||||
|
||||
return
|
||||
}
|
||||
@@ -0,0 +1,36 @@
|
||||
// Code scaffolded by goctl. Safe to edit.
|
||||
// goctl 1.9.1
|
||||
|
||||
package meeting_speaker
|
||||
|
||||
import (
|
||||
"context"
|
||||
|
||||
"github.com/JACKYMYPERSON/hldrCenter/config"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/model"
|
||||
"github.com/JACKYMYPERSON/hldrCenter/internal/meetingspeaker/internal/types"
|
||||
|
||||
"github.com/zeromicro/go-zero/core/logx"
|
||||
)
|
||||
|
||||
type UpdateSpeakerLogic struct {
|
||||
logx.Logger
|
||||
ctx context.Context
|
||||
cfg *config.Config
|
||||
model model.MeetingSpeakerModel
|
||||
}
|
||||
|
||||
func NewUpdateSpeakerLogic(ctx context.Context, cfg *config.Config, model model.MeetingSpeakerModel) *UpdateSpeakerLogic {
|
||||
return &UpdateSpeakerLogic{
|
||||
Logger: logx.WithContext(ctx),
|
||||
ctx: ctx,
|
||||
cfg: cfg,
|
||||
model: model,
|
||||
}
|
||||
}
|
||||
|
||||
func (l *UpdateSpeakerLogic) UpdateSpeaker(req *types.UpdateSpeakerReq) (resp *types.UpdateSpeakerResp, err error) {
|
||||
// todo: add your logic here and delete this line
|
||||
|
||||
return
|
||||
}
|
||||
@@ -0,0 +1,29 @@
|
||||
package model
|
||||
|
||||
import "github.com/zeromicro/go-zero/core/stores/sqlx"
|
||||
|
||||
var _ MeetingSpeakerModel = (*customMeetingSpeakerModel)(nil)
|
||||
|
||||
type (
|
||||
// MeetingSpeakerModel is an interface to be customized, add more methods here,
|
||||
// and implement the added methods in customMeetingSpeakerModel.
|
||||
MeetingSpeakerModel interface {
|
||||
meetingSpeakerModel
|
||||
withSession(session sqlx.Session) MeetingSpeakerModel
|
||||
}
|
||||
|
||||
customMeetingSpeakerModel struct {
|
||||
*defaultMeetingSpeakerModel
|
||||
}
|
||||
)
|
||||
|
||||
// NewMeetingSpeakerModel returns a model for the database table.
|
||||
func NewMeetingSpeakerModel(conn sqlx.SqlConn) MeetingSpeakerModel {
|
||||
return &customMeetingSpeakerModel{
|
||||
defaultMeetingSpeakerModel: newMeetingSpeakerModel(conn),
|
||||
}
|
||||
}
|
||||
|
||||
func (m *customMeetingSpeakerModel) withSession(session sqlx.Session) MeetingSpeakerModel {
|
||||
return NewMeetingSpeakerModel(sqlx.NewSqlConnFromSession(session))
|
||||
}
|
||||
@@ -0,0 +1,90 @@
|
||||
// Code generated by goctl. DO NOT EDIT.
|
||||
// versions:
|
||||
// goctl version: 1.9.1
|
||||
|
||||
package model
|
||||
|
||||
import (
|
||||
"context"
|
||||
"database/sql"
|
||||
"fmt"
|
||||
"strings"
|
||||
|
||||
"github.com/zeromicro/go-zero/core/stores/builder"
|
||||
"github.com/zeromicro/go-zero/core/stores/sqlx"
|
||||
"github.com/zeromicro/go-zero/core/stringx"
|
||||
)
|
||||
|
||||
var (
|
||||
meetingSpeakerFieldNames = builder.RawFieldNames(&MeetingSpeaker{})
|
||||
meetingSpeakerRows = strings.Join(meetingSpeakerFieldNames, ",")
|
||||
meetingSpeakerRowsExpectAutoSet = strings.Join(stringx.Remove(meetingSpeakerFieldNames, "`id`", "`create_at`", "`create_time`", "`created_at`", "`update_at`", "`update_time`", "`updated_at`"), ",")
|
||||
meetingSpeakerRowsWithPlaceHolder = strings.Join(stringx.Remove(meetingSpeakerFieldNames, "`id`", "`create_at`", "`create_time`", "`created_at`", "`update_at`", "`update_time`", "`updated_at`"), "=?,") + "=?"
|
||||
)
|
||||
|
||||
type (
|
||||
meetingSpeakerModel interface {
|
||||
Insert(ctx context.Context, data *MeetingSpeaker) (sql.Result, error)
|
||||
FindOne(ctx context.Context, id int64) (*MeetingSpeaker, error)
|
||||
Update(ctx context.Context, data *MeetingSpeaker) error
|
||||
Delete(ctx context.Context, id int64) error
|
||||
}
|
||||
|
||||
defaultMeetingSpeakerModel struct {
|
||||
conn sqlx.SqlConn
|
||||
table string
|
||||
}
|
||||
|
||||
MeetingSpeaker struct {
|
||||
Id int64 `db:"id"` // 嘉宾ID(主键)
|
||||
MeetingId int64 `db:"meeting_id"` // 关联会议ID(对应meeting表id)
|
||||
Name string `db:"name"` // 嘉宾姓名
|
||||
Title string `db:"title"` // 嘉宾头衔(如:XX公司技术总监)
|
||||
Avatar string `db:"avatar"` // 嘉宾头像URL
|
||||
Intro sql.NullString `db:"intro"` // 嘉宾简介
|
||||
Sort int64 `db:"sort"` // 嘉宾排序(数字越小越靠前)
|
||||
}
|
||||
)
|
||||
|
||||
func newMeetingSpeakerModel(conn sqlx.SqlConn) *defaultMeetingSpeakerModel {
|
||||
return &defaultMeetingSpeakerModel{
|
||||
conn: conn,
|
||||
table: "`meeting_speaker`",
|
||||
}
|
||||
}
|
||||
|
||||
func (m *defaultMeetingSpeakerModel) 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 *defaultMeetingSpeakerModel) FindOne(ctx context.Context, id int64) (*MeetingSpeaker, error) {
|
||||
query := fmt.Sprintf("select %s from %s where `id` = ? limit 1", meetingSpeakerRows, m.table)
|
||||
var resp MeetingSpeaker
|
||||
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 *defaultMeetingSpeakerModel) Insert(ctx context.Context, data *MeetingSpeaker) (sql.Result, error) {
|
||||
query := fmt.Sprintf("insert into %s (%s) values (?, ?, ?, ?, ?, ?)", m.table, meetingSpeakerRowsExpectAutoSet)
|
||||
ret, err := m.conn.ExecCtx(ctx, query, data.MeetingId, data.Name, data.Title, data.Avatar, data.Intro, data.Sort)
|
||||
return ret, err
|
||||
}
|
||||
|
||||
func (m *defaultMeetingSpeakerModel) Update(ctx context.Context, data *MeetingSpeaker) error {
|
||||
query := fmt.Sprintf("update %s set %s where `id` = ?", m.table, meetingSpeakerRowsWithPlaceHolder)
|
||||
_, err := m.conn.ExecCtx(ctx, query, data.MeetingId, data.Name, data.Title, data.Avatar, data.Intro, data.Sort, data.Id)
|
||||
return err
|
||||
}
|
||||
|
||||
func (m *defaultMeetingSpeakerModel) tableName() string {
|
||||
return m.table
|
||||
}
|
||||
5
server/internal/meetingspeaker/internal/model/vars.go
Normal file
5
server/internal/meetingspeaker/internal/model/vars.go
Normal file
@@ -0,0 +1,5 @@
|
||||
package model
|
||||
|
||||
import "github.com/zeromicro/go-zero/core/stores/sqlx"
|
||||
|
||||
var ErrNotFound = sqlx.ErrNotFound
|
||||
72
server/internal/meetingspeaker/internal/types/types.go
Normal file
72
server/internal/meetingspeaker/internal/types/types.go
Normal file
@@ -0,0 +1,72 @@
|
||||
// Code generated by goctl. DO NOT EDIT.
|
||||
// goctl 1.9.1
|
||||
|
||||
package types
|
||||
|
||||
type CreateSpeakerReq struct {
|
||||
MeetingId int64 `json:"meeting_id" validate:"required,min=1"` // 关联会议ID(必填,需存在对应的会议)
|
||||
Name string `json:"name" validate:"required,min=1,max=100"` // 嘉宾姓名(必填,长度限制)
|
||||
Title string `json:"title,omitempty" validate:"max=200"` // 嘉宾头衔(可选,最长200字)
|
||||
Avatar string `json:"avatar,omitempty" validate:"max=512"` // 头像URL(可选,最长512字符)
|
||||
Intro string `json:"intro,omitempty"` // 嘉宾简介(可选,长文本)
|
||||
Sort int `json:"sort,omitempty" validate:"min=0"` // 排序(可选,默认0,非负整数)
|
||||
}
|
||||
|
||||
type CreateSpeakerResp struct {
|
||||
Msg string `json:"message"` // 操作提示(如:"嘉宾创建成功")
|
||||
SpeakerId int64 `json:"speaker_id"` // 新增嘉宾的ID
|
||||
}
|
||||
|
||||
type DeleteSpeakerReq struct {
|
||||
Id int64 `path:"id" validate:"required,min=1"` // 嘉宾ID(从路径参数获取,必填)
|
||||
}
|
||||
|
||||
type DeleteSpeakerResp struct {
|
||||
Msg string `json:"message"` // 操作提示(如:"嘉宾已删除")
|
||||
}
|
||||
|
||||
type GetSpeakerReq struct {
|
||||
Id int64 `path:"id" validate:"required,min=1"` // 嘉宾ID(从路径参数获取,必填)
|
||||
}
|
||||
|
||||
type GetSpeakerResp struct {
|
||||
Msg string `json:"message"` // 操作提示
|
||||
Speaker *SpeakerDetail `json:"speaker"` // 嘉宾详情(查询成功返回)
|
||||
}
|
||||
|
||||
type ListSpeakersByMeetingReq struct {
|
||||
MeetingId int64 `path:"meetingId" validate:"required,min=1"` // 会议ID(从路径参数获取,必填)
|
||||
Page int `query:"page" validate:"min=1"` // 页码(默认1)
|
||||
PageSize int `query:"page_size" validate:"min=1,max=100"` // 每页条数(默认10,最大100)
|
||||
}
|
||||
|
||||
type ListSpeakersByMeetingResp struct {
|
||||
Msg string `json:"message"` // 操作提示
|
||||
Total int64 `json:"total"` // 该会议下的嘉宾总数
|
||||
Speakers []*SpeakerDetail `json:"speakers"` // 嘉宾列表(当前页数据,按sort升序排列)
|
||||
}
|
||||
|
||||
type SpeakerDetail struct {
|
||||
Id int64 `json:"id"` // 嘉宾ID(主键)
|
||||
MeetingId int64 `json:"meeting_id"` // 关联会议ID(外键)
|
||||
Name string `json:"name"` // 嘉宾姓名
|
||||
Title string `json:"title"` // 嘉宾头衔
|
||||
Avatar string `json:"avatar"` // 嘉宾头像URL
|
||||
Intro string `json:"intro"` // 嘉宾简介
|
||||
Sort int `json:"sort"` // 排序(数字越小越靠前)
|
||||
IsDelete int `json:"is_delete"` // 软删除标识(0-未删,1-已删)
|
||||
}
|
||||
|
||||
type UpdateSpeakerReq struct {
|
||||
Id int64 `json:"id" validate:"required,min=1"` // 嘉宾ID(必填,定位要更新的记录)
|
||||
MeetingId int64 `json:"meeting_id,omitempty" validate:"min=1"` // 关联会议ID(可选,不填则不更新)
|
||||
Name string `json:"name,omitempty" validate:"min=1,max=100"` // 嘉宾姓名(可选,更新时需非空)
|
||||
Title string `json:"title,omitempty" validate:"max=200"` // 嘉宾头衔(可选)
|
||||
Avatar string `json:"avatar,omitempty" validate:"max=512"` // 头像URL(可选)
|
||||
Intro string `json:"intro,omitempty"` // 嘉宾简介(可选)
|
||||
Sort int `json:"sort,omitempty" validate:"min=0"` // 排序(可选)
|
||||
}
|
||||
|
||||
type UpdateSpeakerResp struct {
|
||||
Msg string `json:"message"` // 操作提示(如:"嘉宾信息更新成功")
|
||||
}
|
||||
Reference in New Issue
Block a user