openbilibili/app/job/live-userexp/service/exp.go

package service

import (
	"context"
	"encoding/json"

	"go-common/app/job/live-userexp/model"
	"go-common/library/log"
)

func (s *Service) levelCacheUpdate(nwMsg []byte, oldMsg []byte) {
	exp := &model.Exp{}
	if err := json.Unmarshal(nwMsg, exp); err != nil {
		log.Error("json.Unmarshal(%s) error(%v)", string(nwMsg), err)
		return
	}
	level := model.FormatLevel(exp)
	s.dao.SetLevelCache(context.TODO(), level)
}