zmy 1 day ago
parent
commit
3cad4d0e9e
3 changed files with 78 additions and 60 deletions
  1. 61
    58
      api/pub/bind_tag.go
  2. 5
    0
      models/tag_enterprise.go
  3. 12
    2
      routers/router.go

+ 61
- 58
api/pub/bind_tag.go View File

@@ -22,35 +22,38 @@ func TagUserBind(c *gin.Context) {
return
}

var uid int64 = 1

// userInfo := baapi.GetModAuthor(c)
// uid := userInfo.ID
// userOne := models.TagUserOne("uid = ?", uid)
// if userOne.Id < 1 {
// //添加
// info := make(map[string]interface{})
// info["uid"] = uid
// info["phone"] = userInfo.Phone
// info["nickname"] = userInfo.Nickname
// info["account"] = userInfo.Account
// _, err := models.InsertTagUser(info)
// if err != nil {
// baapi.JSONReply(c, "error", err, nil)
// return
// }
// } else {
// info := make(map[string]interface{})
// info["phone"] = userInfo.Phone
// info["nickname"] = userInfo.Nickname
// info["account"] = userInfo.Account
// //更新
// err := models.UpdateTagUser("uid = ?", info, userOne.UID)
// if err != nil {
// baapi.JSONReply(c, "error", err, nil)
// return
// }
// }
// var uid int64 = 1
userInfo := baapi.GetModAuthor(c)
if userInfo == nil {
baapi.JSONReply(c, "error", "用户信息不存在", nil)
return
}
uid := userInfo.ID
userOne := models.TagUserOne("uid = ?", uid)
if userOne.Id < 1 {
//添加
info := make(map[string]interface{})
info["uid"] = uid
info["phone"] = userInfo.Phone
info["nickname"] = userInfo.Nickname
info["account"] = userInfo.Account
_, err := models.InsertTagUser(info)
if err != nil {
baapi.JSONReply(c, "error", err, nil)
return
}
} else {
info := make(map[string]interface{})
info["phone"] = userInfo.Phone
info["nickname"] = userInfo.Nickname
info["account"] = userInfo.Account
//更新
err := models.UpdateTagUser("uid = ?", info, userOne.Uid)
if err != nil {
baapi.JSONReply(c, "error", err, nil)
return
}
}

//解析数据
arrA := make([]interface{}, 0)
@@ -227,35 +230,35 @@ func TagEntBind(c *gin.Context) {
return
}

var eid int64 = 1
// userInfo := baapi.GetModAuthor(c)
// uid := userInfo.ID
// userOne := models.TagUserOne("uid = ?", uid)
// if userOne.Id < 1 {
// //添加
// info := make(map[string]interface{})
// info["uid"] = uid
// info["phone"] = userInfo.Phone
// info["nickname"] = userInfo.Nickname
// info["account"] = userInfo.Account
// _, err := models.InsertTagUser(info)
// if err != nil {
// baapi.JSONReply(c, "error", err, nil)
// return
// }
// } else {
// info := make(map[string]interface{})
// info["phone"] = userInfo.Phone
// info["nickname"] = userInfo.Nickname
// info["account"] = userInfo.Account
// //更新
// err := models.UpdateTagUser("uid = ?", info, userOne.UID)
// if err != nil {
// baapi.JSONReply(c, "error", err, nil)
// return
// }
// }
// var eid int64 = 1
userInfo := baapi.GetModAuthor(c)
eid := userInfo.ID
userOne := models.TagEntOne("eid = ?", eid)
if userOne.Id < 1 {
//添加
info := make(map[string]interface{})
info["eid"] = eid
info["phone"] = userInfo.Phone
info["nickname"] = userInfo.Nickname
info["account"] = userInfo.Account
_, err := models.InsertTagUser(info)
if err != nil {
baapi.JSONReply(c, "error", err, nil)
return
}
} else {
info := make(map[string]interface{})
info["phone"] = userInfo.Phone
info["nickname"] = userInfo.Nickname
info["account"] = userInfo.Account
//更新
err := models.UpdateTagEnt("eid = ?", info, userOne.Eid)
if err != nil {
baapi.JSONReply(c, "error", err, nil)
return
}
}

//解析数据
arrA := make([]interface{}, 0)

+ 5
- 0
models/tag_enterprise.go View File

@@ -30,3 +30,8 @@ func TagEntList(wh string, args ...interface{}) []TagEnterprise {
Db.Table("tag_enterprise").Where(wh, args...).Order("id ASC").Find(&res)
return res
}

func UpdateTagEnt(wh string, data map[string]interface{}, args ...interface{}) error {
result := Db.Table("tag_enterprise").Where(wh, args...).Updates(data)
return result.Error
}

+ 12
- 2
routers/router.go View File

@@ -73,8 +73,6 @@ func SetupRouter(router *gin.Engine) {
apiGroup.GET("/test", api.Test)
apiGroup.POST("/login", authMiddleware.LoginHandler)
apiGroup.POST("/upfile", pub.UpFile)
apiGroup.POST("/tag_user_md", pub.TagUserBind) //埋点(用户)
apiGroup.POST("/tag_ent_md", pub.TagEntBind) //埋点(商户)

apiGroup.POST("/test_uiuiui", master.Adf)
apiGroup.POST("/test_md", pub.TagUserBind) //测试埋点(用户)
@@ -132,6 +130,18 @@ func SetupRouter(router *gin.Engine) {
v1Master.POST("/tag_search_ent_and", master.TagSearchEntAnd) //根据标签搜索商户(并且)
v1Master.GET("/tag_bindent_list", master.TagEntBindList) //商户绑定标签列表
}
//用户接口
v1User := router.Group(baapi.RouteApiUser)
v1User.Use(authMiddleware.MiddlewareFunc())
{
v1User.POST("/tag_user_md", pub.TagUserBind) //埋点(用户)
}
//商户接口
v1Ent := router.Group(baapi.RouteApiEnterprise)
v1Ent.Use(authMiddleware.MiddlewareFunc())
{
v1Ent.POST("/tag_ent_md", pub.TagEntBind) //埋点(商户)
}
// 短信回调
router.StaticFS("/img", newStaticDir(("/img"), lib.EnsureDir("./img"), ""))
router.StaticFS("/fe", newStaticDir(("/fe"), lib.EnsureDir("./web/fe"), ""))

Loading…
Cancel
Save