egg_mq_consume/consume/egg_energy_deal_user_ecpm_test.go

package consume

import (
	"code.fnuoos.com/EggPlanet/egg_system_rules.git/md"
	"code.fnuoos.com/go_rely_warehouse/zyos_go_es.git/es"
	"encoding/json"
	"fmt"
	"testing"
)

func TestHandleEggEnergyDealUserECPMConsume(t *testing.T) {

	es.Init("http://123.57.140.192:9200", "elastic", "fnuo123")
	m := md.DealUserEcpmReq{
		Uid:  18,
		Ecpm: "101.4",
	}
	bytes, err := json.Marshal(m)
	err = handleTemporaryEggEnergyDealUserECPMConsume(bytes, nil)
	if err != nil {
		fmt.Println(err)
		return
	}
}