cms-server/service/service_event/checkin.go

package service_event

import (
	"context"
	"nixcn-cms/data"
	"nixcn-cms/internal/exception"
	"nixcn-cms/service/shared"
	"time"

	"github.com/google/uuid"
)

type CheckinData struct {
	EventId uuid.UUID `json:"event_id"`
}

type CheckinPayload struct {
	Context context.Context
	UserId  uuid.UUID
	Data    *CheckinData
}

type CheckinResponse struct {
	CheckinCode *string `json:"checkin_code"`
}

type CheckinResult struct {
	Common shared.CommonResult
	Data   *CheckinResponse
}

func (self *EventServiceImpl) Checkin(payload *CheckinPayload) (result *CheckinResult) {
	attendandeData, err := new(data.Attendance).
		GetAttendance(payload.Context, payload.UserId, payload.Data.EventId)
	if err != nil {
		result = &CheckinResult{
			Common: shared.CommonResult{
				HttpCode: 500,
				Exception: new(exception.Builder).
					SetStatus(exception.StatusServer).
					SetService(exception.ServiceEvent).
					SetEndpoint(exception.EndpointEventServiceCheckin).
					SetType(exception.TypeCommon).
					SetOriginal(exception.CommonErrorDatabase).
					SetError(err).
					Throw(payload.Context),
			},
		}
		return
	}

	if attendandeData == nil {
		result = &CheckinResult{
			Common: shared.CommonResult{
				HttpCode: 403,
				Exception: new(exception.Builder).
					SetStatus(exception.StatusUser).
					SetService(exception.ServiceEvent).
					SetEndpoint(exception.EndpointEventServiceCheckin).
					SetType(exception.TypeCommon).
					SetOriginal(exception.CommonErrorInvalidInput).
					Throw(payload.Context),
			},
		}
		return
	}

	eventData, err := new(data.Event).
		GetEventById(payload.Context, payload.Data.EventId)

	if err != nil || eventData == nil {
		code := 500
		if eventData == nil {
			code = 404
		}
		result = &CheckinResult{
			Common: shared.CommonResult{
				HttpCode: code,
				Exception: new(exception.Builder).
					SetStatus(exception.StatusUser).
					SetService(exception.ServiceEvent).
					SetEndpoint(exception.EndpointEventServiceCheckin).
					SetType(exception.TypeCommon).
					SetOriginal(exception.CommonErrorInvalidInput).
					SetError(err).
					Throw(payload.Context),
			},
		}
		return
	}

	if attendandeData.KycId == uuid.Nil && eventData.EnableKYC == true {
		result = &CheckinResult{
			Common: shared.CommonResult{
				HttpCode: 400,
				Exception: new(exception.Builder).
					SetStatus(exception.StatusUser).
					SetService(exception.ServiceEvent).
					SetEndpoint(exception.EndpointEventServiceCheckin).
					SetType(exception.TypeCommon).
					SetOriginal(exception.CommonErrorInvalidInput).
					SetError(err).
					Throw(payload.Context),
			},
		}
		return
	}

	attendance := &data.Attendance{UserId: payload.UserId}
	code, err := attendance.GenCheckinCode(payload.Context, payload.Data.EventId)
	if err != nil {
		result = &CheckinResult{
			Common: shared.CommonResult{
				HttpCode: 500,
				Exception: new(exception.Builder).
					SetStatus(exception.StatusServer).
					SetService(exception.ServiceEvent).
					SetEndpoint(exception.EndpointEventServiceCheckin).
					SetType(exception.TypeSpecific).
					SetOriginal(exception.EventCheckinGenCodeFailed).
					SetError(err).
					Throw(payload.Context),
			},
		}

		return
	}

	result = &CheckinResult{
		Common: shared.CommonResult{
			HttpCode: 200,
			Exception: new(exception.Builder).
				SetStatus(exception.StatusSuccess).
				SetService(exception.ServiceEvent).
				SetEndpoint(exception.EndpointEventServiceCheckin).
				SetType(exception.TypeCommon).
				SetOriginal(exception.CommonSuccess).
				Throw(payload.Context),
		},
		Data: &CheckinResponse{code},
	}

	return
}

type CheckinSubmitData struct {
	CheckinCode string `json:"checkin_code"`
}

type CheckinSubmitPayload struct {
	Context context.Context
	Data    *CheckinSubmitData
}

type CheckinSubmitResult struct {
	Common shared.CommonResult
}

func (self *EventServiceImpl) CheckinSubmit(payload *CheckinSubmitPayload) (result *CheckinSubmitResult) {
	attendanceData := new(data.Attendance)
	err := attendanceData.VerifyCheckinCode(payload.Context, payload.Data.CheckinCode)
	if err != nil {
		result = &CheckinSubmitResult{
			Common: shared.CommonResult{
				HttpCode: 400,
				Exception: new(exception.Builder).
					SetStatus(exception.StatusUser).
					SetService(exception.ServiceEvent).
					SetEndpoint(exception.EndpointEventServiceCheckinSubmit).
					SetType(exception.TypeCommon).
					SetOriginal(exception.CommonErrorInvalidInput).
					SetError(err).
					Throw(payload.Context),
			},
		}
		return
	}

	result = &CheckinSubmitResult{
		Common: shared.CommonResult{
			HttpCode: 200,
			Exception: new(exception.Builder).
				SetStatus(exception.StatusSuccess).
				SetService(exception.ServiceEvent).
				SetEndpoint(exception.EndpointEventServiceCheckinSubmit).
				SetType(exception.TypeCommon).
				SetOriginal(exception.CommonSuccess).
				Throw(payload.Context),
		},
	}
	return
}

type CheckinQueryData struct {
	EventId uuid.UUID `json:"event_id"`
}

type CheckinQueryPayload struct {
	Context context.Context
	UserId  uuid.UUID
	Data    *CheckinQueryData
}

type CheckinQueryResponse struct {
	CheckinAt *time.Time `json:"checkin_at"`
}

type CheckinQueryResult struct {
	Common shared.CommonResult
	Data   *CheckinQueryResponse
}

func (self *EventServiceImpl) CheckinQuery(payload *CheckinQueryPayload) (result *CheckinQueryResult) {
	attendanceData := new(data.Attendance)
	attendance, err := attendanceData.GetAttendance(payload.Context, payload.UserId, payload.Data.EventId)

	if err != nil {
		result = &CheckinQueryResult{
			Common: shared.CommonResult{
				HttpCode: 500,
				Exception: new(exception.Builder).
					SetStatus(exception.StatusServer).
					SetService(exception.ServiceEvent).
					SetEndpoint(exception.EndpointEventServiceCheckinQuery).
					SetType(exception.TypeCommon).
					SetOriginal(exception.CommonErrorDatabase).
					SetError(err).
					Throw(payload.Context),
			},
		}
		return
	}

	if attendance == nil {
		result = &CheckinQueryResult{
			Common: shared.CommonResult{
				HttpCode: 404,
				Exception: new(exception.Builder).
					SetStatus(exception.StatusUser).
					SetService(exception.ServiceEvent).
					SetEndpoint(exception.EndpointEventServiceCheckinQuery).
					SetType(exception.TypeSpecific).
					SetOriginal(exception.EventCheckinQueryRecordNotFound).
					Throw(payload.Context),
			},
		}
		return
	}

	var checkinAt *time.Time
	if !attendance.CheckinAt.IsZero() {
		checkinAt = &attendance.CheckinAt
	}

	result = &CheckinQueryResult{
		Common: shared.CommonResult{
			HttpCode: 200,
			Exception: new(exception.Builder).
				SetStatus(exception.StatusSuccess).
				SetService(exception.ServiceEvent).
				SetEndpoint(exception.EndpointEventServiceCheckinQuery).
				SetType(exception.TypeCommon).
				SetOriginal(exception.CommonSuccess).
				Throw(payload.Context),
		},
		Data: &CheckinQueryResponse{checkinAt},
	}
	return
}