FJurmanovic/wallet-go-api
1
0
Fork 0
mirror of https://github.com/FJurmanovic/wallet-go-api.git synced 2026-02-06 06:08:16 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

added subscription end

Browse Source
This commit is contained in:
Fran Jurmanovic
2021-07-30 19:56:27 +02:00
parent f2bc3dc9fe
commit 3c2cd4710f
3 changed files with 34 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
pkg/controllers/subscriptions.go
View File

@@ -16,6 +16,7 @@ func NewSubscriptionController(as *services.SubscriptionService, s *gin.RouterGr
wc := new(SubscriptionController) wc := new(SubscriptionController)
wc.SubscriptionService = as wc.SubscriptionService = as
s.PUT("/end/:id", wc.End)
s.POST("", wc.New) s.POST("", wc.New)
s.PUT("/:id", wc.Edit) s.PUT("/:id", wc.Edit)
s.GET("", wc.GetAll) s.GET("", wc.GetAll)
@@ -56,7 +57,7 @@ func (wc *SubscriptionController) Get(c *gin.Context) {
body.Id = auth.(*models.Auth).Id body.Id = auth.(*models.Auth).Id
id := c.Param("id") id := c.Param("id")
embed, _ := c.GetQuery("embed") embed, _ := c.GetQuery("embed")
params.Embed = embed params.Embed = embed
@@ -65,6 +66,19 @@ func (wc *SubscriptionController) Get(c *gin.Context) {
c.JSON(200, fr) c.JSON(200, fr)
} }
func (wc *SubscriptionController) End(c *gin.Context) {
body := new(models.Auth)
auth := c.MustGet("auth")
body.Id = auth.(*models.Auth).Id
id := c.Param("id")
fr := wc.SubscriptionService.End(c, id)
c.JSON(200, fr)
}
func (wc *SubscriptionController) GetAll(c *gin.Context) { func (wc *SubscriptionController) GetAll(c *gin.Context) {
body := new(models.Auth) body := new(models.Auth)
auth := c.MustGet("auth") auth := c.MustGet("auth")

2
pkg/middleware/cors.go
View File

@@ -8,7 +8,7 @@ func CORSMiddleware() gin.HandlerFunc {
c.Writer.Header().Set("Access-Control-Allow-Credentials", "true") c.Writer.Header().Set("Access-Control-Allow-Credentials", "true")
c.Writer.Header().Set("Access-Control-Allow-Headers", "Content-Type, Content-Length, Accept-Encoding, X-CSRF-Token, Authorization, accept, origin, Cache-Control, X-Requested-With") c.Writer.Header().Set("Access-Control-Allow-Headers", "Content-Type, Content-Length, Accept-Encoding, X-CSRF-Token, Authorization, accept, origin, Cache-Control, X-Requested-With")
c.Writer.Header().Set("Access-Control-Allow-Methods", "POST, OPTIONS, GET, PUT") c.Writer.Header().Set("Access-Control-Allow-Methods", "POST, OPTIONS, GET, PUT")
if c.Request.Method == "OPTIONS" { if c.Request.Method == "OPTIONS" {
c.AbortWithStatus(204) c.AbortWithStatus(204)
return return

18
pkg/services/subscriptions.go
View File

@@ -114,6 +114,24 @@ func (as *SubscriptionService) Edit(ctx context.Context, body *models.Subscripti
return tm return tm
} }
func (as *SubscriptionService) End(ctx context.Context, id string) *models.Subscription {
db := as.Db.WithContext(ctx)
tm := new(models.Subscription)
tm.Id = id
tm.EndDate = time.Now()
tm.HasEnd = true
tx, _ := db.Begin()
defer tx.Rollback()
tx.Model(tm).WherePK().UpdateNotZero()
tx.Commit()
return tm
}
func (as *SubscriptionService) SubToTrans(subModel *models.Subscription, tx *pg.Tx) { func (as *SubscriptionService) SubToTrans(subModel *models.Subscription, tx *pg.Tx) {
now := time.Now() now := time.Now()