feat: 激活极光

internal/v2/controller/app/push/push.go

@@ -0,0 +1,59 @@
+package push
+
+import (
+	"recook/internal/back"
+	"recook/internal/v2/lib/common"
+	"recook/internal/v2/model/jpush"
+	"recook/tools"
+
+	"git.oa00.com/go/mysql"
+	"github.com/gin-gonic/gin"
+	"github.com/jinzhu/gorm"
+)
+
+type Proxy struct {
+}
+
+type PusherActivity struct {
+	RegisterID string `json:"register_id"`
+	Type       int    `json:"int" binding:"oneof=1 2"`
+}
+
+func (o Proxy) Active(c *gin.Context) {
+	id, err := common.GetAppUserId(c)
+	if err != nil {
+		back.Fail(c, err.Error())
+		return
+	}
+	var args PusherActivity
+	if err := tools.ParseParams(&args, c); err != nil {
+		back.Err(c, err.Error())
+		return
+	}
+	var ju jpush.JPush
+	if err := mysql.Db.First(&ju, "user_id = ?", id).Error; err != nil {
+		if err != gorm.ErrRecordNotFound {
+			back.Err(c, err.Error())
+			return
+		} else {
+			// create
+			if err := mysql.Db.Create(&jpush.JPush{
+				UserId:         id,
+				RegistrationId: args.RegisterID,
+				Type:           args.Type,
+			}).Error; err != nil {
+				back.Err(c, err.Error())
+				return
+			}
+		}
+	} else {
+		if err := mysql.Db.Model(&ju).Updates(jpush.JPush{
+			RegistrationId: args.RegisterID,
+			Type:           args.Type,
+		}).Error; err != nil {
+			back.Err(c, err.Error())
+			return
+		}
+	}
+
+}

internal/v2/lib/common/function.go

@@ -3,8 +3,6 @@ package common
 import (
 	"errors"
 	"fmt"
-	"github.com/gin-gonic/gin"
-	"github.com/shopspring/decimal"
 	"image"
 	_ "image/gif"
 	_ "image/jpeg"
@@ -20,6 +18,9 @@ import (
 	"recook/tools"
 	"reflect"
 	"time"
+
+	"github.com/gin-gonic/gin"
+	"github.com/shopspring/decimal"
 )
 
 // @Style 获取登录管理账号信息

internal/v2/router/app.go

@@ -12,6 +12,7 @@ import (
 	"recook/internal/v2/controller/app/operate"
 	"recook/internal/v2/controller/app/order"
 	"recook/internal/v2/controller/app/productportrait"
+	"recook/internal/v2/controller/app/push"
 	"recook/internal/v2/controller/app/seckill"
 	"recook/internal/v2/controller/app/shoppingcart"
 	"recook/internal/v2/controller/app/upgrade"
@@ -271,5 +272,12 @@ func routerApp(appRouter *gin.RouterGroup) {
 			vipController.POST("is_used", proxy.VipIsUsed)
 		}
 	}
+	pushController := appRouter.Group("push", authorize)
+	{
+		proxy := push.Proxy{}
+		{
+			pushController.POST("active", proxy.Active)
+		}
+	}
 
 }