openbilibili/app/job/main/sms/service/log.go

package service

import (
	"strings"
	"time"

	smsmdl "go-common/app/service/main/sms/model"
	"go-common/library/log"
	"go-common/library/queue/databus/report"
)

const (
	_reportType = 111
)

func (s *Service) sendUserActionLog(l *smsmdl.ModelUserActionLog) {
	if l.Mobile == "" {
		log.Warn("sendUserActionLog mobile is empty, log(%+v)", l)
		return
	}
	for _, mobile := range strings.Split(l.Mobile, ",") {
		r := &report.UserInfo{
			Business: _reportType,
			Ctime:    time.Unix(l.Ts, 0),
			Index:    []interface{}{mobile},
			Content: map[string]interface{}{
				"msgid":    l.MsgID,
				"content":  l.Content,
				"status":   l.Status,
				"desc":     l.Desc,
				"provider": l.Provider,
				"type":     l.Type,
				"action":   l.Action,
			},
		}
		log.Info("sendUserActionLog(%+v)", r)
		report.User(r)
	}
}