You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
50 lines
1.2 KiB
50 lines
1.2 KiB
package service |
|
|
|
import ( |
|
"fmt" |
|
"go-common/app/interface/main/videoup/model/archive" |
|
"go-common/library/log" |
|
"go-common/library/queue/databus/report" |
|
"net" |
|
"strconv" |
|
"time" |
|
) |
|
|
|
// SendArchiveLog send to log service |
|
func (s *Service) SendArchiveLog(aid int64, build, buvid, action, platform string, ap *archive.ArcParam, videoerr error) { |
|
var ( |
|
LogType = archive.LogTypeSuccess |
|
index = []interface{}{ap.TypeID, ap.UpFrom, ap.OrderID, ap.Title, ap.BizFrom, strconv.Itoa(ap.MissionID), fmt.Sprint(videoerr)} |
|
) |
|
if videoerr != nil { |
|
LogType = archive.LogTypeFail |
|
} |
|
buildNum, _ := strconv.Atoi(build) |
|
ip := net.IP(ap.IPv6[:]).String() |
|
uInfo := &report.UserInfo{ |
|
Mid: ap.Mid, |
|
Platform: platform, |
|
Build: int64(buildNum), |
|
Buvid: buvid, |
|
Business: archive.ArchiveAddLogID, |
|
Type: LogType, |
|
Oid: aid, |
|
Action: action, |
|
Ctime: time.Now(), |
|
Index: index, |
|
IP: ip, |
|
} |
|
ap.Aid = aid |
|
|
|
// es 最多存32k,我们日志就最多记100p吧 |
|
if len(ap.Videos) > 100 { |
|
ap.Videos = ap.Videos[:100] |
|
} |
|
|
|
uInfo.Content = map[string]interface{}{ |
|
"content": ap, |
|
"errmsg": videoerr, |
|
} |
|
report.User(uInfo) |
|
log.Info("sendLog data(%+v)", uInfo) |
|
}
|
|
|