diff --git a/service/end_user.go b/service/end_user.go
index 5a15db1..b18fc0d 100644
--- a/service/end_user.go
+++ b/service/end_user.go
@@ -420,6 +420,7 @@ func (es _EndUserService) StatEndUserRecordInPeriod(requestUser, requestPark, st
 		ColumnExpr("sum(?) as valley", bun.Ident("eud.valley")).
 		ColumnExpr("sum(?) as valley_fee", bun.Ident("eud.valley_fee")).
 		ColumnExpr("sum(?) as final_diluted", bun.Ident("eud.final_diluted")).
+		Where("report.published = ?", true).
 		Group("eud.meter_04kv_id").
 		Scan(ctx, &endUserSums)
 	if err != nil {