magic_server/commons/services/stak_handler.go

package services

import (
	"app/commons/core"
	"app/commons/core/redisclient"
)

// todo:质押OPS订单处理

func (s *CommonService) StakeHandler() {
	// 获取分布式 异步任务锁
	lockKey := "AsynchronousTask"
	lock, err := redisclient.LockWithTime(lockKey, 30)
	if err != nil {
		core.Log.Infof("lockKey:%s 异步任务锁竞取失败:%s", lockKey, err.Error())
		return
	}
	defer func() {
		err = redisclient.UnlockSafe(lock)
		if err != nil {
			core.Log.Error(err)
		}
		core.Log.Infof("用户ID：%s 异步任务锁释放完成", lockKey)
	}()

	// todo:  个人业绩增加  -- 等级更新

	// todo: 上级业绩更新  -- 等级更新

}