内部消息推送（订单推商品）

notify/message.go

@@ -26,6 +26,9 @@ const (
 	ApiRequestTopic = "apiRequest"
 	//通知消息系统topic
 	SingleTopic = "singleMessage"
+	//内部消息通知
+	MsgGoodsUpdateTopic = "goodsUpdate"
+
 
 	//消息类型
 
@@ -65,6 +68,9 @@ const (
 	GoodsStorageAdd    = 501 //添加选品库
 	GoodsStorageRemove = 502 //移除选品库
 
+	//内部修改商品消息
+	GoodsSaleUpdate         = 10000 //修1改销量
+
 	ErrMsgParamEmpty = "该类型消息对应字段不能为空"
 	ErrMsgAppIDEmpty = "该类型消息appid字段不能为空"
 	ErrMsgTpye       = "错误的消息类型"

notify/model.go

@@ -79,3 +79,13 @@ type NotifyApiLog struct {
 	ResponseBody interface{} `json:"response_body"` //响应参数
 	Error        interface{} `json:"error"`         //错误信息
 }
+//内部推送商品更新消息
+type NotifyGoodsUpdateServer struct {
+	Type     int         `json:"type"`
+	MsgData    []GoodsData  `json:"msg_data"`
+	MsgSendTime int64       `json:"msg_send_time"`
+}
+type GoodsData struct {
+	GoodsId int64 `json:"goods_id"`
+	RealSale int64 `json:"real_sale"`
+}
\ No newline at end of file