update

consume/canal_guide_order_consume.go

@@ -83,6 +83,7 @@ func handleGuideOrdTable(msg []byte) error {
 				Uid:                   data.Uid,
 				BuyerPhone:            user.Phone,
 				CostPrice:             utils.StrToFloat64(data.CostPrice),
+				Gmv:                   utils.StrToFloat64(data.CostPrice) * float64(utils.StrToInt(data.ItemNum)),
 				State:                 int32(utils.StrToInt(data.State)),
 				StateZh:               md.CanalGuideOrderState(int32(utils.StrToInt(data.State))).String(),
 				GoodsNum:              utils.StrToInt(data.ItemNum),

consume/canal_order_consume.go

@@ -110,6 +110,7 @@ func handleMallOrdTable(msg []byte) error {
 				Uid:                   data.Uid,
 				BuyerPhone:            data.BuyerPhone,
 				CostPrice:             utils.StrToFloat64(data.CostPrice),
+				Gmv:                   utils.StrToFloat64(data.CostPrice) * float64(goodsNum),
 				State:                 int32(utils.StrToInt(data.State)),
 				StateZh:               md.CanalOrderState(int32(utils.StrToInt(data.State))).String(),
 				PayChannel:            int32(utils.StrToInt(data.PayChannel)),

es/md/es_struct.go

@@ -10,6 +10,7 @@ type ZhiosOrdersEs struct {
 	Uid                   string      `json:"uid"`
 	BuyerPhone            string      `json:"buyer_phone"`
 	CostPrice             float64     `json:"cost_price"`
+	Gmv                   float64     `json:"gmv"`
 	State                 int32       `json:"state"`
 	StateZh               string      `json:"state_zh"`
 	PayTime               interface{} `json:"pay_time"`