diff --git a/consume/egg_energy_deal_user_ecpm.go b/consume/egg_energy_deal_user_ecpm.go
index c3f6a11..e6ea3d4 100644
--- a/consume/egg_energy_deal_user_ecpm.go
+++ b/consume/egg_energy_deal_user_ecpm.go
@@ -71,7 +71,7 @@ func handleEggEnergyDealUserECPMConsume(msgData []byte) error {
 
 	updateMap := make(map[string]interface{})
 	updateMap["ecpm"] = utils2.StrToFloat64(msg.Ecpm)
-	updateDocRet, err := es.UpdateDoc(index, id, m)
+	updateDocRet, err := es.UpdateDoc(index, id, updateMap)
 	if err != nil {
 		return err
 	}