更新

@@ -28,6 +28,9 @@ func SyncBestshopOrder(message *sarama.ConsumerMessage) error {
 	}
 	}
 	srv := syncOrderSrv.NewOrderInfoService(nil)
 	srv := syncOrderSrv.NewOrderInfoService(nil)
 	err = srv.SyncOrderFromBestshop(cmd)
 	err = srv.SyncOrderFromBestshop(cmd)
-	e := fmt.Errorf("[Consumer][SyncBestshopOrder] %s", err)
-	return e
+	if err != nil {
+		e := fmt.Errorf("[Consumer][SyncBestshopOrder] %s", err)
+		return e
+	}
+	return err
 }
 }