update ticket scanner ready for ibu profesional

cmd/app/main.go

@@ -86,9 +86,9 @@ func main() {
 		RegisterDataHub(hub, "default")
 
 	s.RegisterModel(&engine.Checklog{}, "checklog")
-	// s.RegisterModel(&engine.Checkin{}, "checkin")
+	s.RegisterModel(&engine.Sync{}, "sync")
 	// s.RegisterModel(&engine.Gate{}, "gate")
-	// s.RegisterModel(&engine.Ticket{}, "ticket")
+	s.RegisterModel(&engine.Ticket{}, "ticket")
 
 	// muxss
 	mux := http.NewServeMux()

pkg/engine/checkin.go

@@ -4,7 +4,9 @@ import (
 	"time"
 
 	"git.kanosolution.net/expo/ticket-scanner/pkg/services"
+	"git.kanosolution.net/kano/dbflex"
 	"git.kanosolution.net/kano/kaos"
+	"github.com/eaciit/toolkit"
 )
 
 type Checklog struct{}
@@ -15,11 +17,16 @@ type CheckinRequest struct {
 }
 
 type CheckinResponse struct {
-	Message string `json:"message"`
+	Message string    `json:"message"`
+	Data    toolkit.M `json:"data"`
 }
 
 func (o *Checklog) Checkin(ctx *kaos.Context, req *CheckinRequest) (*CheckinResponse, error) {
-	res := new(CheckinResponse)
+	res := &CheckinResponse{
+		Data: toolkit.M{},
+	}
+
+	res.Data.Set("StatusCode", 200)
 
 	checkinResponse := services.NewCheckin(services.NewCheckinParam{}).
 		Checkin(services.CheckinParam{
@@ -27,18 +34,81 @@ func (o *Checklog) Checkin(ctx *kaos.Context, req *CheckinRequest) (*CheckinResp
 			TicketCode:  req.TicketCode,
 		})
 
+	res.Data.Set("Ticket", checkinResponse.Ticket)
 	if false == checkinResponse.IsCheckinError {
 		//if system error
 		if checkinResponse.E != nil {
 			res.Message = checkinResponse.E.Error()
+			res.Data.Set("StatusCode", 500)
 		}
-
-		return res, checkinResponse.E
 	} else if true == checkinResponse.IsCheckinError && checkinResponse.E != nil {
 		//if failed checkin
 		res.Message = checkinResponse.E.Error()
-		return res, checkinResponse.E
+		res.Data.Set("StatusCode", 500)
+	}
+
+	return res, nil
+}
+
+type LogsRequest struct {
+	BaseGetsRequest
+}
+type LogsResponse struct {
+	BaseGetsResponse
+}
+
+func (o *Checklog) Logs(ctx *kaos.Context, req *LogsRequest) (*LogsResponse, error) {
+	res := new(LogsResponse)
+
+	param := dbflex.NewQueryParam().SetTake(req.Take).SetSkip(req.Skip).SetSort("-updated_at")
+	checklogResponse, total, e := new(services.Checklog).Gets(param)
+	if e != nil {
+		return res, e
+	}
+
+	res.Data = checklogResponse
+	res.Total = total
+
+	return res, nil
+}
+
+type TotalCheckinResponse struct {
+	BaseGetsResponse
+}
+
+func (o *Checklog) TotalCheckin(ctx *kaos.Context, req EmptyRequest) (*TotalCheckinResponse, error) {
+	res := new(TotalCheckinResponse)
+
+	totalCheckin, e := services.NewCheckin(services.NewCheckinParam{}).TotalCheckin()
+	if e != nil {
+		return res, e
+	}
+
+	res.Total = totalCheckin
+	return res, nil
+}
+
+type GetsNotSyncedRequest struct {
+	BaseGetsRequest
+}
+
+type GetsNotSyncedResponse struct {
+	BaseGetsResponse
+}
+
+func (o *Checklog) GetsNotSynced(ctx *kaos.Context, req *BaseGetsRequest) (*GetsNotSyncedResponse, error) {
+	res := new(GetsNotSyncedResponse)
+
+	params := dbflex.NewQueryParam().SetSkip(req.Skip).SetTake(req.Take).SetWhere(
+		dbflex.Eq("is_synced", false),
+	)
+	checkins, total, e := services.NewCheckin(services.NewCheckinParam{}).Gets(params)
+	if e != nil {
+		return res, e
 	}
 
+	res.Data = checkins
+	res.Total = total
+
 	return res, nil
 }

pkg/engine/request.go

+package engine
+
+type BaseGetsRequest struct {
+	EventID string `json:"event_id"`
+	Take    int    `json:"take"`
+	Skip    int    `json:"skip"`
+}

pkg/engine/response.go

+package engine
+
+// OK return success
+func OK() string {
+	return "OK"
+}
+
+// NOK return not success
+func NOK() string {
+	return "NOK"
+}
+
+type BaseGetsResponse struct {
+	Data  interface{} `json:"data"`
+	Total int         `json:"total"`
+}

pkg/engine/sync.go

+package engine
+
+import (
+	"git.kanosolution.net/expo/ticket-scanner/pkg/helper"
+	"git.kanosolution.net/expo/ticket-scanner/pkg/services/sync"
+	"git.kanosolution.net/kano/kaos"
+)
+
+type Sync struct{}
+
+func (o *Sync) Ticket(ctx *kaos.Context, req EmptyRequest) (string, error) {
+	eventID := helper.EventID()
+	e := sync.NewTicket(nil).Sync(eventID)
+	if e != nil {
+		return NOK(), e
+	}
+
+	return OK(), nil
+}
+
+func (o *Sync) Checkin(ctx *kaos.Context, req EmptyRequest) (string, error) {
+	eventID := helper.EventID()
+	e := sync.NewCheckin(nil).Sync(eventID)
+	if e != nil {
+		return NOK(), e
+	}
+
+	return OK(), nil
+}