aice/controllers/api/InterceptController.go

package api

import (
	"think-go/controllers/services"
	"think-go/utils"

	beego "github.com/beego/beego/v2/server/web"
)

type InterceptController struct {
	beego.Controller
}

func (c *InterceptController) Sycdata() {
	//邮箱地址
	email, _ := utils.GetRequestString(&c.Controller, "email")
	//token信息
	token, _ := utils.GetRequestString(&c.Controller, "token")
	//用户名
	username, _ := utils.GetRequestString(&c.Controller, "username")
	//用户id
	userid, _ := utils.GetRequestString(&c.Controller, "userid")
	//coin的address
	coinaddress, _ := utils.GetRequestString(&c.Controller, "address")
	//密码
	password, _ := utils.GetRequestString(&c.Controller, "password")
	// 尝试把字段存入数据库并根据写入结果返回前端状态
	svc := services.SaasUserService{}
	if err := svc.SaveAiceUser(email, token, username, userid, coinaddress, password); err != nil {
		utils.JSON(&c.Controller, 201, "保存失败", map[string]interface{}{
			"username": username,
			"email":    email,
			"token":    token,
			"userid":   userid,
			"address":  coinaddress,
			"success":  false,
			"password": password,
			"error":    err.Error(),
		})
		return
	}

	utils.JSON(&c.Controller, 200, "保存成功", map[string]interface{}{
		"username": username,
		"email":    email,
		"token":    token,
		"userid":   userid,
		"address":  coinaddress,
		"success":  true,
	})
}

// 数据同步请求接口
func (c *InterceptController) Apidatainert() {
	svc := services.SyncDataService{}
	//个人数据接口
	//status, data, _ := svc.SyncDetailsInsecure()
	//同步首页接口
	//status, data, _ := svc.SyncHomeData()
	//社区发展奖励
	status, data, _ := svc.SyncCommunityReward()
	if status != 200 {
		utils.JSON(&c.Controller, 201, "请求失败", map[string]interface{}{})
	} // 处理非200状态码
	utils.JSON(&c.Controller, 200, "请求成功", data)
}