cron

3 years ago · cf8dc4e529
parent ebed875c46
commit cf8dc4e529
1 changed files with 2 additions and 2 deletions
--- a/internal/cron_task/clear_msg.go
+++ b/internal/cron_task/clear_msg.go
@ -193,9 +193,9 @@ func checkMaxSeqWithMongo(operationID, ID string, diffusionType int) error {
 	}
 	seqMongo = msgPb.Seq
 	if math.Abs(float64(seqMongo-uint32(seqRedis))) > 10 {
-		log.NewWarn(operationID, utils.GetSelfFuncName(), seqMongo, seqRedis, "redis maxSeq is different with msg.Seq > 10", ID, diffusionType)
+		log.NewWarn(operationID, utils.GetSelfFuncName(), "seqMongo, seqRedis", seqMongo, seqRedis, ID, "redis maxSeq is different with msg.Seq > 10", "status: ", msgPb.Status, msg.SendTime)
 	} else {
-		log.NewInfo(operationID, utils.GetSelfFuncName(), diffusionType, ID, "seq and msg OK", seqMongo, seqRedis)
+		log.NewInfo(operationID, utils.GetSelfFuncName(), "seqMongo, seqRedis", seqMongo, seqRedis, ID, "seq and msg OK", "status: ", msgPb.Status, msg.SendTime)
 	}
 	return nil
 }