eta_bridge/controller/gn/user.go

package gn

import (
	"eta_gn/eta_bridge/controller/resp"
	gnLogic "eta_gn/eta_bridge/logic/gn"
	"github.com/gin-gonic/gin"
	"sync"
)

// XiangyuController 象屿指标
//type XiangyuController struct{}

// 同步用户锁，防止重复同步，不管是全量还是增量，都是同一时间只能一个同步
var lockSyncUser sync.Mutex

// SyncUser
// @Description: 全量同步用户
// @author: Roc
// @receiver xc
// @datetime 2024-01-22 15:51:25
// @param c *gin.Context
func (gc *GuoNengController) SyncUser(c *gin.Context) {
	lockSyncUser.Lock()
	defer func() {
		lockSyncUser.Unlock()
	}()
	err := gnLogic.SyncUser()
	if err != nil {
		resp.FailData("同步失败", err.Error(), c)
		return
	}
	resp.Ok("同步成功", c)
}

// PullUser
// @Description: 增量同步用户
// @author: Roc
// @receiver xc
// @datetime 2024-01-23 17:13:07
// @param c *gin.Context
//func (xc *GuoNengController) PullUser(c *gin.Context) {
//	lockSyncUser.Lock()
//	defer func() {
//		lockSyncUser.Unlock()
//	}()
//	err := xiangyu.PullUser()
//	if err != nil {
//		resp.FailData("同步失败", err.Error(), c)
//		return
//	}
//	resp.Ok("同步成功", c)
//
//	return
//}