Add event join service and api endpoint

Signed-off-by: Asai Neko <sugar@sne.moe>

service/service_event/join_event.go

@@ -1,11 +1,24 @@
 package service_event
 
-import "nixcn-cms/service/shared"
+import (
+	"context"
+	"nixcn-cms/data"
+	"nixcn-cms/internal/exception"
+	"nixcn-cms/service/shared"
+
+	"github.com/google/uuid"
+)
 
 type EventJoinData struct {
+	EventId string `json:"event_id"`
+	UserId  string `json:"user_id"`
+	Role    string `json:"role"`
+	State   string `json:"state"`
 }
 
 type EventJoinPayload struct {
+	Context context.Context
+	Data    *EventJoinData
 }
 
 type EventJoinResult struct {
@@ -13,5 +26,93 @@ type EventJoinResult struct {
 }
 
 func (self *EventServiceImpl) JoinEvent(payload *EventJoinPayload) (result *EventJoinResult) {
+	var err error
+
+	attendenceData := new(data.Attendance)
+
+	eventId, err := uuid.Parse(payload.Data.EventId)
+	if err != nil {
+		exception := new(exception.Builder).
+			SetStatus(exception.StatusServer).
+			SetService(exception.ServiceEvent).
+			SetEndpoint(exception.EndpointEventServiceJoin).
+			SetType(exception.TypeCommon).
+			SetOriginal(exception.CommonErrorUuidParseFailed).
+			SetError(err).
+			Throw(payload.Context)
+
+		result = &EventJoinResult{
+			Common: shared.CommonResult{
+				HttpCode:  400,
+				Exception: exception,
+			},
+		}
+
+		return
+	}
+
+	userId, err := uuid.Parse(payload.Data.UserId)
+	if err != nil {
+		exception := new(exception.Builder).
+			SetStatus(exception.StatusServer).
+			SetService(exception.ServiceEvent).
+			SetEndpoint(exception.EndpointEventServiceJoin).
+			SetType(exception.TypeCommon).
+			SetOriginal(exception.CommonErrorUuidParseFailed).
+			SetError(err).
+			Throw(payload.Context)
+
+		result = &EventJoinResult{
+			Common: shared.CommonResult{
+				HttpCode:  400,
+				Exception: exception,
+			},
+		}
+
+		return
+	}
+
+	attendenceData.SetEventId(eventId)
+	attendenceData.SetUserId(userId)
+	attendenceData.SetRole("notmal")
+	attendenceData.SetState("success")
+
+	err = attendenceData.Create(payload.Context)
+	if err != nil {
+		exception := new(exception.Builder).
+			SetStatus(exception.StatusServer).
+			SetService(exception.ServiceEvent).
+			SetEndpoint(exception.EndpointEventServiceJoin).
+			SetType(exception.TypeCommon).
+			SetOriginal(exception.CommonErrorDatabase).
+			SetError(err).
+			Throw(payload.Context)
+
+		result = &EventJoinResult{
+			Common: shared.CommonResult{
+				HttpCode:  500,
+				Exception: exception,
+			},
+		}
+
+		return
+	}
+
+	exception := new(exception.Builder).
+		SetStatus(exception.StatusServer).
+		SetService(exception.ServiceEvent).
+		SetEndpoint(exception.EndpointEventServiceJoin).
+		SetType(exception.TypeCommon).
+		SetOriginal(exception.CommonSuccess).
+		SetError(nil).
+		Throw(payload.Context)
+
+	result = &EventJoinResult{
+		Common: shared.CommonResult{
+			HttpCode:  200,
+			Exception: exception,
+		},
+	}
+
 	return
 }