Update - add log

NicoleRobin · Jul 26, 2021 · 854273f · 854273f
1 parent 7180827
commit 854273f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/job_log.go b/job_log.go
@@ -48,6 +48,7 @@ func GetJobLogById(id bson.ObjectId) (l *JobLog, err error) {
 var selectForJobLogList = bson.M{"command": 0, "output": 0}
 
 func GetJobLogList(query bson.M, page, size int, sort string) (list []*JobLog, total int, err error) {
+	log.Debugf("query:%+v, page:%d, size:%d, sort:%s", query, page, size, sort)
 	err = mgoDB.WithC(Coll_JobLog, func(c *mgo.Collection) error {
 		total, err = c.Find(query).Count()
 		if err != nil {
@@ -59,6 +60,7 @@ func GetJobLogList(query bson.M, page, size int, sort string) (list []*JobLog, t
 }
 
 func GetJobLatestLogList(query bson.M, page, size int, sort string) (list []*JobLatestLog, total int, err error) {
+	log.Debugf("query:%+v, page:%d, size:%d, sort:%s", query, page, size, sort)
 	err = mgoDB.WithC(Coll_JobLatestLog, func(c *mgo.Collection) error {
 		total, err = c.Find(query).Count()
 		if err != nil {

diff --git a/web/log_cleaner.go b/web/log_cleaner.go
@@ -10,6 +10,7 @@ import (
 )
 
 func RunLogCleaner(cleanPeriod, expiration time.Duration) (close chan struct{}) {
+	log.Debugf("cleanPeriod:%s, expiration:%s", cleanPeriod.String(), expiration.String())
 	t := time.NewTicker(cleanPeriod)
 	close = make(chan struct{})
 	go func() {
@@ -27,6 +28,7 @@ func RunLogCleaner(cleanPeriod, expiration time.Duration) (close chan struct{})
 }
 
 func cleanupLogs(expiration time.Duration) {
+	log.Debugf("expiration:%s", expiration.String())
 	err := cronsun.GetDb().WithC(cronsun.Coll_JobLog, func(c *mgo.Collection) error {
 		_, err := c.RemoveAll(bson.M{"$or": []bson.M{
 			bson.M{"$and": []bson.M{