消息

notify/message.go

@@ -117,7 +117,7 @@ func (p *NsqProducer) msgValidator(notifyMessage *NotifyMessage) (err error) {
 		if err = gconv.Struct(notifyMessage.Data, &msgData); err != nil {
 			return
 		}
-		if msgData.OrderSn == "" || msgData.Sku == 0 {
+		if msgData.OrderSn == "" {
 			err = errors.New(ErrMsgParamEmpty)
 			return
 		}