eta_data_init/controllers/xiangyu/index.go

package xiangyu

import (
	"eta/eta_data_init/models"
	"eta/eta_data_init/services/eta_bridge"
	beego "github.com/beego/beego/v2/server/web"
)

// XyController 客户
type XyController struct {
	beego.Controller
}

// SyncClassifyList
// @Description: 同步分类列表
// @author: Roc
// @receiver c
// @datetime 2024-03-14 10:23:11
// @Success Ret=200
// @router /sync/classify [get]
func (c *XyController) SyncClassifyList() {
	br := new(models.BaseResponse).Init()
	defer func() {
		c.Data["json"] = br
		c.ServeJSON()
	}()

	num, err := c.GetInt("num", 0)
	if err != nil {
		br.Msg = "num数量获取失败"
		br.ErrMsg = "num数量获取失败,err:" + err.Error()
		return
	}

	err = eta_bridge.SyncClassifyList(num)
	if err != nil {
		br.Msg = "同步分类列表失败"
		br.ErrMsg = "同步分类列表失败,err:" + err.Error()
		return
	}

	br.Ret = 200
	br.Msg = "同步分类成功"
}

// SyncIndexList
// @Description: 同步指标列表
// @author: Roc
// @receiver c
// @datetime 2024-03-14 10:23:11
// @Success Ret=200
// @router /sync/index [get]
func (c *XyController) SyncIndexList() {
	br := new(models.BaseResponse).Init()
	defer func() {
		c.Data["json"] = br
		c.ServeJSON()
	}()

	num, err := c.GetInt("num", 0)
	if err != nil {
		br.Msg = "num数量获取失败"
		br.ErrMsg = "num数量获取失败,err:" + err.Error()
		return
	}

	err = eta_bridge.SyncIndexList(num)
	if err != nil {
		br.Msg = "同步指标列表失败"
		br.ErrMsg = "同步指标列表失败,err:" + err.Error()
		return
	}

	br.Ret = 200
	br.Msg = "同步指标成功"
}

// SyncUser
// @Description: 同步指标列表
// @author: Roc
// @receiver c
// @datetime 2024-03-14 10:23:11
// @Success Ret=200
// @router /sync/user [get]
func (c *XyController) SyncUser() {
	br := new(models.BaseResponse).Init()
	defer func() {
		c.Data["json"] = br
		c.ServeJSON()
	}()

	err := eta_bridge.SyncUser()
	if err != nil {
		br.Msg = "同步用户列表失败"
		br.ErrMsg = "同步用户列表失败,err:" + err.Error()
		return
	}

	br.Ret = 200
	br.Msg = "同步用户成功"
}