refactor: code review

server/internal/msg/application/application.go

@@ -0,0 +1,13 @@
+package application
+
+import (
+	"mayfly-go/internal/msg/infrastructure/persistence"
+)
+
+var (
+	msgApp = newMsgApp(persistence.GetMsgRepo())
+)
+
+func GetMsgApp() Msg {
+	return msgApp
+}

server/internal/msg/application/msg.go

@@ -0,0 +1,43 @@
+package application
+
+import (
+	"mayfly-go/internal/msg/domain/entity"
+	"mayfly-go/internal/msg/domain/repository"
+	"mayfly-go/pkg/model"
+	"mayfly-go/pkg/ws"
+	"time"
+)
+
+type Msg interface {
+	GetPageList(condition *entity.Msg, pageParam *model.PageParam, toEntity any, orderBy ...string) *model.PageResult[any]
+
+	Create(msg *entity.Msg)
+
+	// 创建消息，并通过ws发送
+	CreateAndSend(la *model.LoginAccount, msg *ws.Msg)
+}
+
+func newMsgApp(msgRepo repository.Msg) Msg {
+	return &msgAppImpl{
+		msgRepo: msgRepo,
+	}
+}
+
+type msgAppImpl struct {
+	msgRepo repository.Msg
+}
+
+func (a *msgAppImpl) GetPageList(condition *entity.Msg, pageParam *model.PageParam, toEntity any, orderBy ...string) *model.PageResult[any] {
+	return a.msgRepo.GetPageList(condition, pageParam, toEntity)
+}
+
+func (a *msgAppImpl) Create(msg *entity.Msg) {
+	a.msgRepo.Insert(msg)
+}
+
+func (a *msgAppImpl) CreateAndSend(la *model.LoginAccount, wmsg *ws.Msg) {
+	now := time.Now()
+	msg := &entity.Msg{Type: 2, Msg: wmsg.Msg, RecipientId: int64(la.Id), CreateTime: &now, CreatorId: la.Id, Creator: la.Username}
+	a.msgRepo.Insert(msg)
+	ws.SendMsg(la.Id, wmsg)
+}