Esempio di gestione del codice dei prodotti
Questo esempio illustra come ottenere, aggiungere, aggiornare ed eliminare prodotti nello store specificato.
Per informazioni sulle classi correlate al prodotto usate da questo esempio, vedere Prodotti e prodotti.
In questo esempio viene usato Bing Ads SDK per l'autenticazione utente.
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Reflection;
using System.Security.Cryptography;
using System.ServiceModel;
using System.Text;
using System.Threading.Tasks;
using Microsoft.BingAds;
using Newtonsoft.Json;
namespace Products
{
public class ManageProductExample
{
private const string BaseUri = "https://content.api.bingads.microsoft.com/shopping/v9.1";
private const string BmcUri = BaseUri + "/bmc/{0}";
private const string ClientState = "ClientStateGoesHere";
private static string ClientId = "<CLIENTIDGOESHERE>";
private static string DeveloperToken = "<DEVELOPERTOKENGOESHERE>";
private static string RefreshToken = "<REFRESHTOKENGOESHERE>";
private static string MerchantId = "<STOREIDGOESHERE>";
private static OAuthDesktopMobileAuthCodeGrant OAuth;
public static void Main()
{
try
{
OAuth = AuthenticateWithOAuth();
// Get the default catalog.
// Note that getting catalog information is an expensive call and should be limited. The example
// includes this call simply to demonstrate using the call. If you don't specify a catalog, the
// product is automatically written to the default catalog, so getting the catalog ID is only useful
// if you're adding the product to a non-default catalog.
Catalog defaultCatalog = ListCatalogs().FirstOrDefault(cat => cat.IsDefault == true);
// Add a product to the catalog
Product testProduct = GetTestProduct("My Test Product ({0})");
// If catalog id is not specified, the product is added to the default catalog.
Product addedProduct = AddProduct(defaultCatalog.Id, testProduct);
Console.WriteLine("*** Added product to catalog (catalog.Id=" + defaultCatalog.Id + ", product.Id=" + addedProduct.Id + ")***");
Print(addedProduct);
Console.WriteLine("*** / End of added product (catalog.Id=" + defaultCatalog.Id + ", product.Id=" + addedProduct.Id + ")***");
Console.WriteLine();
// Retrieve a product by id
Product retrievedProduct = GetProduct(addedProduct.Id);
Console.WriteLine("*** Retrieved product (product.Id=" + retrievedProduct.Id + ")***");
Print(retrievedProduct);
Console.WriteLine("*** / End retrieved product (product.Id=" + retrievedProduct.Id + ")***");
Console.WriteLine();
// List products
Console.WriteLine("*** Listing products ***");
foreach (Product product in ListProducts())
{
Print(product);
}
Console.WriteLine("*** / End of listing products ***");
Console.WriteLine();
// Delete product
Console.WriteLine("*** Deleting Product (" + addedProduct.Id + ") ***");
DeleteProduct(addedProduct.Id);
Console.WriteLine("*** / Deleting Product Done (" + addedProduct.Id + ") ***");
}
// Catch authentication exceptions
catch (OAuthTokenRequestException ex)
{
OutputStatusMessage(string.Format("OAuthTokenRequestException Message:\n{0}", ex.Message));
if (ex.Details != null)
{
OutputStatusMessage(string.Format("OAuthTokenRequestException Details:\nError: {0}\nDescription: {1}",
ex.Details.Error, ex.Details.Description));
}
}
catch (HttpRequestException ex)
{
OutputStatusMessage(ex.Message);
}
Console.Write("Press enter to exit");
Console.ReadLine();
}
// List catalogs
public static string CatalogsUri = BmcUri + "/catalogs";
public static string CatalogUri = CatalogsUri + "/{1}";
public static IEnumerable<Catalog> ListCatalogs()
{
string url = string.Format(CatalogsUri, MerchantId);
CatalogCollection catalogs = Request<CatalogCollection>("GET", url);
return catalogs?.Catalogs ?? new List<Catalog>();
}
// List products
public static string ListUri = BmcUri + "/products";
public static string ListQueryString = "?max-results=2&alt=json"; // max-results set to 2 to test paging, this would be set to a higher value in a real world scenario based on your needs
public static string ListQueryStringWithStartToken = "?max-results=2&alt=json&start-token={1}";
public static IEnumerable<Product> ListProducts()
{
string url = string.Format(ListUri + ListQueryString, MerchantId);
while (!string.IsNullOrEmpty(url))
{
ProductCollection productCollection = Request<ProductCollection>("GET", url);
foreach (Product product in productCollection.Resources)
{
yield return product;
}
if (!string.IsNullOrEmpty(productCollection.nextPageToken))
{
url = string.Format(ListUri + ListQueryStringWithStartToken, MerchantId, productCollection.nextPageToken);
}
else
{
url = null;
}
}
}
// Add
public static string AddProductUri = BmcUri + "/products";
public static string AddProductQueryString = "?bmc-catalog-id={1}&alt=json";
public static Product AddProduct(ulong catalogId, Product product)
{
string url = string.Format(AddProductUri + AddProductQueryString, MerchantId, catalogId);
return Request<Product>("POST", url, product);
}
// Get
public static string GetUri = BmcUri + "/products/{1}";
public static string GetQueryString = "?alt=json";
public static Product GetProduct(string productId)
{
string url = string.Format(GetUri + GetQueryString, MerchantId, productId);
return Request<Product>("GET", url);
}
// Delete
public static string DeletetUri = BmcUri + "/products/{1}";
public static string DeleteQueryString = "?alt=json";
public static void DeleteProduct(string productId)
{
string url = string.Format(DeletetUri + DeleteQueryString, MerchantId, productId);
ContentError conentError = Request<ContentError>("DELETE", url);
if (conentError != null)
{
throw new Exception(conentError.Error.ToString());
}
}
private static Product GetTestProduct(string titleFormat)
{
string id = Guid.NewGuid().ToString();
return new Product()
{
Availability = "in stock",
Channel = ProductChannel.Online.ToString(),
Condition = ProductCondition.New.ToString(),
ContentLanguage = "en",
Link = "http://www.contoso.com/apperal/men/tshirts.htm",
ImageLink = "http://www.contoso.com/pics/tees.jpg",
OfferId = id,
Price = new Price()
{
Currency = "USD",
Value = (decimal)1205.00
},
TargetCountry = "US",
Title = string.Format(titleFormat, id),
IdentifierExists = false,
ExpirationDate = DateTime.UtcNow.AddDays(45).ToString("O")
};
}
/// <summary>
/// Use reflection to output the properties of the specified
/// value to the console
/// </summary>
/// <param name="value"></param>
private static void Print(object value)
{
Type type = value.GetType();
PropertyInfo[] properties = type.GetProperties();
foreach (PropertyInfo property in properties)
{
Console.WriteLine("\t{0}: {1}", property.Name, property.GetValue(value));
}
}
protected static T Request<T>(string method, string url, T instance = default(T))
{
try
{
HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);
request.Method = method;
request.Headers = new WebHeaderCollection
{
{ "AuthenticationToken", OAuth.OAuthTokens.AccessToken },
{ "DeveloperToken", DeveloperToken }
};
request.ContentType = "application/json";
if(instance != null)
{
string json = JsonConvert.SerializeObject(instance);
request.ContentLength = json.Length;
using (Stream requestStream = request.GetRequestStream())
{
StreamWriter writer = new StreamWriter(requestStream);
writer.Write(json);
writer.Close();
}
}
HttpWebResponse response = (HttpWebResponse)request.GetResponse();
T result = default(T);
using (Stream responseStream = response.GetResponseStream())
{
var reader = new StreamReader(responseStream);
var jsonOut = reader.ReadToEnd();
reader.Close();
result = JsonConvert.DeserializeObject<T>(jsonOut);
}
return result;
}
catch (WebException e)
{
HandleWebException(e);
return default(T);
}
}
private static void HandleWebException(WebException webException)
{
Console.WriteLine("\n" + webException.Message);
HttpWebResponse response = (HttpWebResponse)webException.Response;
// If the request is bad, the API returns the errors in the
// body of the request. For cases where the path may be valid, but
// the resource does not belong to the user, the API returns not found.
if (HttpStatusCode.BadRequest == response.StatusCode ||
HttpStatusCode.NotFound == response.StatusCode ||
HttpStatusCode.InternalServerError == response.StatusCode)
{
using (Stream stream = response.GetResponseStream())
{
StreamReader reader = new StreamReader(stream);
string json = reader.ReadToEnd();
reader.Close();
try
{
ContentError contentError = JsonConvert.DeserializeObject<ContentError>(json);
Console.WriteLine("HTTP status code: " + contentError.Error.Code);
foreach (Error error in contentError.Error.Errors)
{
Console.WriteLine("reason: {0}\nmessage: {1}\nlocation type: {2}\nlocation: {3}\n",
error.Reason, error.Message, error.LocationType, error.Location);
}
}
catch (Exception deserializeError)
{
// This case occurs when the path is not valid.
if (HttpStatusCode.NotFound == response.StatusCode)
{
Console.WriteLine("Path not found: " + response.ResponseUri);
}
else
{
Console.WriteLine(deserializeError.Message);
}
}
}
}
}
/// <summary>
/// Write to the console by default.
/// </summary>
/// <param name="msg">The message sent to console output.</param>
private static void OutputStatusMessage(String msg)
{
Console.WriteLine(msg);
}
private static OAuthDesktopMobileAuthCodeGrant AuthenticateWithOAuth()
{
var oAuthDesktopMobileAuthCodeGrant = new OAuthDesktopMobileAuthCodeGrant(ClientId);
// It is recommended that you specify a non guessable 'state' request parameter to help prevent
// cross site request forgery (CSRF).
oAuthDesktopMobileAuthCodeGrant.State = ClientState;
string refreshToken;
// If you have previously securely stored a refresh token, try to use it.
if (GetRefreshToken(out refreshToken))
{
AuthorizeWithRefreshTokenAsync(oAuthDesktopMobileAuthCodeGrant, refreshToken).Wait();
}
else
{
// You must request user consent at least once through a web browser control.
// Call the GetAuthorizationEndpoint method of the OAuthDesktopMobileAuthCodeGrant instance that you created above.
Console.WriteLine(string.Format(
"The Microsoft Advertising user must provide consent for your application to access their accounts.\n" +
"Open a new web browser and navigate to {0}.\n\n" +
"After the user has granted consent in the web browser for the application to access their accounts, " +
"please enter the response URI that includes the authorization 'code' parameter: \n", oAuthDesktopMobileAuthCodeGrant.GetAuthorizationEndpoint()));
// Request access and refresh tokens using the URI that you provided manually during program execution.
var responseUri = new Uri(Console.ReadLine());
if (oAuthDesktopMobileAuthCodeGrant.State != ClientState)
throw new HttpRequestException("The OAuth response state does not match the client request state.");
oAuthDesktopMobileAuthCodeGrant.RequestAccessAndRefreshTokensAsync(responseUri).Wait();
}
// It is important to save the most recent refresh token whenever new OAuth tokens are received.
// You will want to subscribe to the NewOAuthTokensReceived event handler.
// When calling Microsoft Advertising services with ServiceClient<TService>, BulkServiceManager, or ReportingServiceManager,
// each instance will refresh your access token automatically if they detect the AuthenticationTokenExpired (109) error code.
oAuthDesktopMobileAuthCodeGrant.NewOAuthTokensReceived +=
(sender, tokens) => SaveRefreshToken(tokens.NewRefreshToken);
return oAuthDesktopMobileAuthCodeGrant;
}
private static bool GetRefreshToken(out string refreshToken)
{
var protectedToken = RefreshToken;
if (string.IsNullOrEmpty(protectedToken))
{
refreshToken = null;
return false;
}
try
{
refreshToken = protectedToken.Unprotect();
return true;
}
catch (CryptographicException)
{
refreshToken = null;
return false;
}
catch (FormatException)
{
refreshToken = null;
return false;
}
}
private static Task<OAuthTokens> AuthorizeWithRefreshTokenAsync(OAuthDesktopMobileAuthCodeGrant authentication, string refreshToken)
{
return authentication.RequestAccessAndRefreshTokensAsync(refreshToken);
}
private static void SaveRefreshToken(string newRefreshtoken)
{
if (newRefreshtoken != null)
{
Settings.Default["RefreshToken"] = newRefreshtoken.Protect();
Settings.Default.Save();
}
}
}
/// <summary>
/// This static class can be used to access and protect a string.
/// </summary>
public static class StringProtection
{
public static string Protect(this string sourceString)
{
var sourceBytes = Encoding.Unicode.GetBytes(sourceString);
var encryptedBytes = ProtectedData.Protect(sourceBytes, null, DataProtectionScope.CurrentUser);
return Convert.ToBase64String(encryptedBytes);
}
public static string Unprotect(this string protectedString)
{
var protectedBytes = Convert.FromBase64String(protectedString);
var unprotectedBytes = ProtectedData.Unprotect(protectedBytes, null, DataProtectionScope.CurrentUser);
return Encoding.Unicode.GetString(unprotectedBytes);
}
}
// Data transfer objects
public class Catalog
{
[JsonProperty("id", DefaultValueHandling = DefaultValueHandling.Ignore)]
public ulong Id { get; set; }
[JsonProperty("name")]
public string Name { get; set; }
[JsonProperty("market", DefaultValueHandling = DefaultValueHandling.Ignore)]
public string Market { get; set; }
[JsonProperty("isPublishingEnabled")]
public Boolean IsPublishingEnabled { get; set; }
[JsonProperty("isDefault", DefaultValueHandling = DefaultValueHandling.IgnoreAndPopulate)]
public Boolean IsDefault { get; set; }
}
public class CatalogCollection
{
[JsonProperty("catalogs")]
public List<Catalog> Catalogs { get; set; }
}
public class ContentError
{
[JsonProperty("error")]
public ErrorCollection Error { get; set; }
}
public class Error
{
[JsonProperty("location")]
public string Location { get; set; }
[JsonProperty("locationType")]
public string LocationType { get; set; }
[JsonProperty("domain")]
public string Domain { get; set; }
[JsonProperty("message")]
public string Message { get; set; }
[JsonProperty("reason")]
public string Reason { get; set; }
public override string ToString()
{
return $"Location: {Location}, LocationType: {LocationType}, Domain: {Domain}, Message: {Message}, Reason: {Reason}";
}
}
public class ErrorCollection
{
[JsonProperty("code")]
public string Code { get; set; }
[JsonProperty("errors")]
public List<Error> Errors { get; set; }
[JsonProperty("message")]
public string Message { get; set; }
public override string ToString()
{
return string.Format("{0}: {1}\r\n{2}", Code, Message, string.Join("\r\n\t", (Errors ?? new List<Error>()).Select(e => e.ToString())));
}
}
public class Price
{
[JsonProperty("currency")]
public string Currency { get; set; }
[JsonProperty("value")]
public decimal? Value { get; set; }
}
public class Product
{
public Product() { }
[JsonProperty("additionalImageLinks")]
public List<string> AdditionalImageLinks { get; set; }
[JsonProperty("adult")]
public bool? IsAdult { get; set; }
[JsonProperty("adwordsGrouping")]
public string AdwordsGrouping { get; set; }
[JsonProperty("adwordsLabels")]
public List<string> AdwordsLabels { get; set; }
[JsonProperty("adwordsRedirect")]
public string AdwordsRedirect { get; set; }
[JsonProperty("ageGroup")]
public string AgeGroup { get; set; }
[JsonProperty("availability")]
public string Availability { get; set; }
[JsonProperty("availabilityDate")]
public string AvailabilityDate { get; set; }
[JsonProperty("brand")]
public string Brand { get; set; }
[JsonProperty("channel")]
public string Channel { get; set; }
[JsonProperty("color")]
public string Color { get; set; }
[JsonProperty("condition")]
public string Condition { get; set; }
[JsonProperty("contentLanguage")]
public string ContentLanguage { get; set; }
[JsonProperty("customAttributes")]
public List<ProductCustomAttribute> CustomAttributes { get; set; }
[JsonProperty("customGroups")]
public List<ProductCustomGroup> CustomGroups { get; set; }
[JsonProperty("customLabel0")]
public string CustomLabel0 { get; set; }
[JsonProperty("customLabel1")]
public string CustomLabel1 { get; set; }
[JsonProperty("customLabel2")]
public string CustomLabel2 { get; set; }
[JsonProperty("customLabel3")]
public string CustomLabel3 { get; set; }
[JsonProperty("customLabel4")]
public string CustomLabel4 { get; set; }
[JsonProperty("description")]
public string Description { get; set; }
[JsonProperty("destinations")]
public List<ProductDestination> Destinations { get; set; }
[JsonProperty("energyEfficiencyClass")]
public string EnergyEfficiencyClass { get; set; }
[JsonProperty("expirationDate")]
public string ExpirationDate { get; set; }
[JsonProperty("gender")]
public string Gender { get; set; }
[JsonProperty("googleProductCategory")]
public string GoogleProductCategory { get; set; }
[JsonProperty("gtin")]
public string Gtin { get; set; }
[JsonProperty("id")]
public string Id { get; set; }
[JsonProperty("identifierExists")]
public bool? IdentifierExists { get; set; }
[JsonProperty("imageLink")]
public string ImageLink { get; set; }
[JsonProperty("isBundle")]
public bool? IsBundle { get; set; }
[JsonProperty("itemGroupId")]
public string ItemGroupId { get; set; }
[JsonProperty("kind")] ////For example: "kind":"content#product"
public string Kind { get; set; }
[JsonProperty("link")]
public string Link { get; set; }
[JsonProperty("material")]
public string Material { get; set; }
[JsonProperty("multipack")]
public ulong? MerchantMultipackQuantity { get; set; }
[JsonProperty("mobileLink")]
public string MobileLink { get; set; }
[JsonProperty("mpn")]
public string Mpn { get; set; }
[JsonProperty("offerId")]
public string OfferId { get; set; }
[JsonProperty("onlineOnly")]
public bool? OnlineOnly { get; set; }
[JsonProperty("pattern")]
public string Pattern { get; set; }
[JsonProperty("price")]
public Price Price { get; set; }
[JsonProperty("productType")]
public string ProductType { get; set; }
[JsonProperty("salePrice")]
public Price SalePrice { get; set; }
[JsonProperty("salePriceEffectiveDate")]
public string SalePriceEffectiveDate { get; set; }
[JsonProperty("shipping")]
public List<ProductShipping> Shipping { get; set; }
[JsonProperty("shippingWeight")]
public ProductShippingWeight ShippingWeight { get; set; }
[JsonProperty("shippingLabel")]
public string ShippingLabel { get; set; }
[JsonProperty("sizes")]
public List<string> Sizes { get; set; }
[JsonProperty("sizeSystem")]
public string SizeSystem { get; set; }
[JsonProperty("sizeType")]
public string SizeType { get; set; }
[JsonProperty("targetCountry")]
public string TargetCountry { get; set; }
[JsonProperty("taxes")]
public List<ProductTax> Taxes { get; set; }
[JsonProperty("title")]
public string Title { get; set; }
[JsonProperty("unitPricingBaseMeasure")]
public UnitPricing UnitPricingBaseMeasure { get; set; }
[JsonProperty("unitPricingMeasure")]
public UnitPricing UnitPricingMeasure { get; set; }
[JsonProperty("validatedDestinations")]
public List<string> ValidatedDestinations { get; set; }
}
public enum ProductChannel
{
Online,
Local
}
public class ProductCollection
{
[JsonProperty("kind")] // Set to content#productsListResponse
public string Kind { get; set; }
[JsonProperty("nextPageToken")]
public string nextPageToken { get; set; }
[JsonProperty("resources")]
public List<Product> Resources { get; set; }
}
public enum ProductCondition
{
New,
Refurbished,
Used
}
public class ProductCustomAttribute
{
[JsonProperty("name")]
public string Name { get; set; }
[JsonProperty("type")]
public string Type { get; set; }
[JsonProperty("unit")]
public string Unit { get; set; }
[JsonProperty("value")]
public string Value { get; set; }
}
public class ProductCustomGroup
{
[JsonProperty("customGroups")]
public List<ProductCustomAttribute> Attributes { get; set; }
[JsonProperty("name")]
public string Name { get; set; }
}
public class ProductDestination
{
[JsonProperty("destinationName")]
public string DestinationName { get; set; }
[JsonProperty("intention")]
public string Intention { get; set; }
}
public class ProductShipping
{
[JsonProperty("country")]
public string Country { get; set; }
[JsonProperty("locationGroupName")]
public string LocationGroupName { get; set; }
[JsonProperty("locationId")]
public long? LocationId { get; set; }
[JsonProperty("postalCode")]
public string PostalCode { get; set; }
[JsonProperty("price")]
public Price Price { get; set; }
[JsonProperty("region")]
public string Region { get; set; }
[JsonProperty("service")]
public string Service { get; set; }
}
public class ProductShippingWeight
{
[JsonProperty("unit")]
public string Unit { get; set; }
[JsonProperty("value")]
public double? Value { get; set; }
}
public class ProductTax
{
[JsonProperty("country")]
public string Country { get; set; }
[JsonProperty("locationId")]
public long? LocationId { get; set; }
[JsonProperty("postalCode")]
public string PostalCode { get; set; }
[JsonProperty("rate")]
public double? Rate { get; set; }
[JsonProperty("region")]
public string Region { get; set; }
[JsonProperty("taxShip")]
public bool? TaxShip { get; set; }
}
public class UnitPricing
{
[JsonProperty("unit")]
public string Unit { get; set; }
[JsonProperty("value")]
public double Value { get; set; }
}
// -/ end Data transfer objects
}
package com.microsoft.contentapi.examples;
import com.fasterxml.jackson.databind.ObjectMapper;
import java.io.*;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.ProtocolException;
import java.net.URL;
import java.text.SimpleDateFormat;
import java.util.*;
import com.microsoft.contentapi.examples.datatransferobjects.*;
public class ManageProductsExample {
private static String BaseUri = "https://content.api.bingads.microsoft.com/shopping/v9.1";
private static String BmcUri = BaseUri + "/bmc/%s";
private static String ClientState = "ClientStateGoesHere";
private static String ClientId = "<CLIENTIDGOESHERE>";
private static String DeveloperToken = "<DEVELOPERTOKENGOESHERE>";
private static String MerchantId = "<STOREIDGOESHERE>";
private static String authenticationToken = "<AUTHENTICATIONTOKENGOESHERE>";
public static void main(String args[]) throws Exception {
try{
// Get the default catalog
Catalog defaultCatalog = retrieveDefaultCatalog();
// Add a product to catalog
Product testProduct = createTestProduct("My Test Product %s");
// if catalog id is not specified the product will be added to the default catalog, here we are specifying the default explicitly
Product addedProduct = AddProduct(defaultCatalog.getId(), testProduct);
System.out.println("*** Added product to catalog (catalog.Id=" + defaultCatalog.getId() + ", product.Id=" + addedProduct.getId() + ")***");
Print(addedProduct);
System.out.println("*** / End of added product (catalog.Id=" + defaultCatalog.getId() + ", product.Id=" + addedProduct.getId() + ")***");
System.out.println();
// Retrieve a product by id
Product retrievedProduct = GetProduct(addedProduct.getId());
System.out.println("*** Retrieved product (product.Id=" + retrievedProduct.getId() + ")***");
Print(retrievedProduct);
System.out.println("*** / End retreived product (product.Id=" + retrievedProduct.getId() + ")***");
System.out.println();
// List products
System.out.println("*** Listing products ***");
for (Product product : ListProducts())
{
Print(product);
}
System.out.println("*** / End of listing products ***");
System.out.println();
// Delete product
System.out.println("*** Deleting Product (" + addedProduct.getId() + ") ***");
DeleteProduct(addedProduct.getId());
System.out.println("*** / Deleting Product Done (" + addedProduct.getId() + ") ***");
}catch(Exception ex) {
System.out.println(ex.getMessage());
}
}
public static Catalog retrieveDefaultCatalog() throws IOException {
List<Catalog> catalogs = ListCatalogs();
for(Catalog catalog : catalogs){
if(catalog.getIsDefault() == true){
return catalog;
}
}
return null;
}
// List catalogs
public static String CatalogsUri = BmcUri + "/catalogs";
public static String CatalogUri = CatalogsUri + "/%s";
public static List<Catalog> ListCatalogs() throws IOException {
String url = String.format(CatalogsUri, MerchantId);
CatalogCollection catalogs = Request("GET", url, null, CatalogCollection.class);
return catalogs == null ? new LinkedList<Catalog>() : catalogs.getCatalogs();
}
// List products
public static String ListUri = BmcUri + "/products";
public static String ListQueryString = "?max-results=2&alt=json"; // max-results set to 2 to test paging, this would be set to a higher value in a real world scenario based on your needs
public static String ListQueryStringWithStartToken = "?max-results=2&alt=json&start-token=%s";
public static List<Product> ListProducts() throws IOException {
String url = String.format(ListUri + ListQueryString, MerchantId);
LinkedList results = new LinkedList();
while(url != null){
ProductCollection productCollection = Request("GET", url, null, ProductCollection.class);
results.addAll(productCollection.getResources());
if(productCollection.nextPageToken != null){
url = String.format(ListUri + ListQueryStringWithStartToken, MerchantId, productCollection.nextPageToken);
}else{
url = null;
}
}
return results;
}
// Add
public static String AddProductUri = BmcUri + "/products";
public static String AddProductQueryString = "?bmc-catalog-id=%s&alt=json";
public static Product AddProduct(long catalogId, Product product) throws IOException {
String url = String.format(AddProductUri + AddProductQueryString, MerchantId, catalogId);
return Request("POST", url, product, Product.class);
}
// Get
public static String GetUri = BmcUri + "/products/%s";
public static String GetQueryString = "?alt=json";
public static Product GetProduct(String productId) throws IOException {
String url = String.format(GetUri + GetQueryString, MerchantId, productId);
return Request("GET", url, null, Product.class);
}
// Delete
public static String DeletetUri = BmcUri + "/products/%s";
public static String DeleteQueryString = "?alt=json";
public static void DeleteProduct(String productId) throws Exception {
String url = String.format(DeletetUri + DeleteQueryString, MerchantId, productId);
ContentError contentError = Request("DELETE", url, null, ContentError.class);
if (contentError != null)
{
ErrorCollection error = contentError.getError();
throw new Exception(error.toString());
}
}
protected static Product createTestProduct(String titleFormat){
String id = UUID.randomUUID().toString();
Product product = new Product();
product.setAvailability("in stock");
product.setChannel("Online");
product.setCondition("New");
product.setContentLanguage("en");
product.setLink("http://www.contoso.com/apperal/men/tshirts.htm");
product.setImageLink("http://www.contoso.com/pics/tees.jpg");
product.setOfferId(id);
Price price = new Price();
price.setCurrency("USD");
price.setValue(1205.00);
product.setPrice(price);
product.setTargetCountry("US");
product.setTitle(String.format(titleFormat, id));
product.setIdentifierExists(false);
Calendar c = Calendar.getInstance();
c.setTime(new Date());
c.add(Calendar.DATE, 45);
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
String expiry = dateFormat.format(c.getTime()) + "T17:00:00.0000000Z";
product.setExpirationDate(expiry);
return product;
}
/***
* Use reflection to output the gettable properties of the
* specified value
* @param value
* @throws InvocationTargetException
* @throws IllegalAccessException
*/
protected static void Print(Object value) throws InvocationTargetException, IllegalAccessException {
Class<?> clazz = value.getClass();
Method[] methods = clazz.getDeclaredMethods();
for(Method method : methods){
String methodName = method.getName();
if(methodName.startsWith("get")){
Object propertyValue = method.invoke(value);
if(propertyValue != null){
System.out.println(methodName.substring(3, methodName.length()) + ": " + propertyValue.toString());
}
}
}
}
protected static <T> T Request(String method, String uri, T instance, Class<T> clazz) throws IOException {
T result = null;
ObjectMapper jsonSerializer = new ObjectMapper();
HttpURLConnection connection = null;
InputStream inputStream = null;
BufferedReader reader = null;
try{
URL url = new URL(uri);
connection = (HttpURLConnection)url.openConnection();
connection.setRequestMethod(method);
connection.setRequestProperty("AuthenticationToken", authenticationToken);
connection.setRequestProperty("DeveloperToken", DeveloperToken);
connection.setRequestProperty("Content-Type", "application/json");
connection.setDoOutput(true);
connection.setDoInput(true);
connection.setUseCaches(false);
if(instance != null){
String json = jsonSerializer.writeValueAsString(instance);
OutputStreamWriter outputStream = new OutputStreamWriter(connection.getOutputStream());
outputStream.write(json);
outputStream.close();
}
int statusCode = connection.getResponseCode();
if(statusCode >= HttpURLConnection.HTTP_BAD_REQUEST){
inputStream = connection.getErrorStream();
}else{
inputStream = connection.getInputStream();
}
StringBuffer response = new StringBuffer();
reader = new BufferedReader(new InputStreamReader(inputStream));
char[] buffer = new char[1024];
int length = 0;
while((length = reader.read(buffer)) != -1){
response.append(new String(buffer, 0, length));
}
if (statusCode >= HttpURLConnection.HTTP_BAD_REQUEST) {
if (statusCode < HttpURLConnection.HTTP_INTERNAL_ERROR) {
ContentError errors = jsonSerializer.readValue(response.toString(), ContentError.class);
throw new Exception(errors.getError().toString());
}
else {
throw new Exception(response.toString());
}
}
String responseJson = response.toString();
if(responseJson.length() > 0){
result = jsonSerializer.readValue(responseJson, clazz);
}
} catch (ProtocolException e) {
e.printStackTrace();
} catch (MalformedURLException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
} finally {
if (connection != null) {
connection.disconnect();
}
if (reader != null) {
reader.close();
}
if (inputStream != null) {
inputStream.close();
}
}
return result;
}
}
// Catalog.java
package com.microsoft.contentapi.examples.datatransferobjects;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
@JsonInclude(JsonInclude.Include.NON_DEFAULT)
public class Catalog
{
private long id;
private String name;
private String market;
@JsonDeserialize(using=StringBooleanDeserializer.class)
private Boolean isPublishingEnabled;
@JsonDeserialize(using=StringBooleanDeserializer.class)
private Boolean isDefault;
public long getId() { return this.id; }
public void setId(long value) { this.id = value; }
public String getName() { return this.name; }
public void setName(String value) { this.name = value; }
public String getMarket() { return this.market; }
public void setMarket(String value) { this.market = value; }
public Boolean getIsPublishingEnabled() { return this.isPublishingEnabled; }
public void setIsPublishingEnabled(Boolean value) { this.isPublishingEnabled = value; }
public Boolean getIsDefault() { return this.isDefault; }
public void setIsDefault(Boolean value) { this.isDefault = value; }
}
// CatalogCollection.java
package com.microsoft.contentapi.examples.datatransferobjects;
import java.util.List;
public class CatalogCollection
{
private List<Catalog> catalogs;
public List<Catalog> getCatalogs() { return this.catalogs; }
public void setCatalogs(List<Catalog> value) { this.catalogs = value; }
}
// ContentError.java
package com.microsoft.contentapi.examples.datatransferobjects;
public class ContentError
{
private ErrorCollection error;
public ErrorCollection getError() { return this.error; }
}
// Error.java
package com.microsoft.contentapi.examples.datatransferobjects;
public class Error
{
private String location;
private String locationType;
private String domain;
private String message;
private String reason;
public String getLocation() { return this.location; }
public String getLocationType() { return this.locationType; }
public String getDomain() { return this.domain; }
public String getMessage() { return this.message; }
public String getReason() { return this.reason; }
}
// ErrorCollection.java
package com.microsoft.contentapi.examples.datatransferobjects;
import java.util.List;
public class ErrorCollection
{
private List<Error> errors;
public List<Error> getErrors() { return this.errors; }
public String toString(){
String result = "";
for(int i = 0; i < errors.size(); i++){
if(i != 0){
result += ", ";
}
result += errors.get(i).getMessage();
}
return result;
}
}
// Price.java
package com.microsoft.contentapi.examples.datatransferobjects;
public class Price
{
private String currency;
private Double value;
public String getCurrency() { return this.currency; }
public void setCurrency(String value) { this.currency = value; }
public Double getValue() { return this.value; }
public void setValue(Double value) { this.value = value; }
}
// Product.java
package com.microsoft.contentapi.examples.datatransferobjects;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import java.util.List;
public class Product
{
private List<String> additionalImageLinks;
@JsonProperty("adult")
@JsonDeserialize(using=StringBooleanDeserializer.class)
private Boolean isAdult;
private String adwordsGrouping;
private List<String> adwordsLabels;
private String adwordsRedirect;
private String ageGroup;
private String availability;
private String availabilityDate;
private String brand;
private String channel;
private String color;
private String condition;
private String contentLanguage;
private List<ProductCustomAttribute> customAttributes;
private List<ProductCustomGroup> customGroups;
private String customLabel0;
private String customLabel1;
private String customLabel2;
private String customLabel3;
private String customLabel4;
private String description;
private List<ProductDestination> destinations;
private String energyEfficiencyClass;
private String expirationDate;
private String gender;
private String googleProductCategory;
private String gtin;
private String id;
@JsonDeserialize(using=StringBooleanDeserializer.class)
private Boolean identifierExists;
private String imageLink;
@JsonDeserialize(using=StringBooleanDeserializer.class)
private Boolean isBundle;
private String itemGroupId;
private String kind; //For example: "kind":"content#product"
private String link;
private String material;
@JsonProperty("multipack")
private Long multipackQuantity;
private String mobileLink;
private String mpn;
private String offerId;
@JsonDeserialize(using=StringBooleanDeserializer.class)
private Boolean onlineOnly;
private String pattern;
private Price price;
private String productType;
private Price salePrice;
private String salePriceEffectiveDate;
private List<ProductShipping> shipping;
private ProductShippingWeight shippingWeight;
private String shippingLabel;
private List<String> sizes;
private String sizeSystem;
private String sizeType;
private String targetCountry;
private List<ProductTax> taxes;
private String title;
private UnitPricing unitPricingBaseMeasure;
private UnitPricing unitPricingMeasure;
private List<String> validatedDestinations;
public List<String> getAdditionalImageLinks() { return this.additionalImageLinks; }
public void setAdditionalImageLinks(List<String> value) { this.additionalImageLinks = value; }
public Boolean getIsAdult() { return this.isAdult; }
public void setIsAdult(Boolean value) { this.isAdult = value; }
public String getAdwordsGrouping() { return this.adwordsGrouping; }
public void setAdwordsGrouping(String value) { this.adwordsGrouping = value; }
public List<String> getAdwordsLabels() { return this.adwordsLabels; }
public void setAdwordsLabels(List<String> value) { this.adwordsLabels = value; }
public String getAdwordsRedirect() { return this.adwordsRedirect; }
public void setAdwordsRedirect(String value) { this.adwordsRedirect = value; }
public String getAgeGroup() { return this.ageGroup; }
public void setAgeGroup(String value) { this.ageGroup = value; }
public String getAvailability() { return this.availability; }
public void setAvailability(String value) { this.availability = value; }
public String getAvailabilityDate() { return this.availabilityDate; }
public void setAvailabilityDate(String value) { this.availabilityDate = value; }
public String getBrand() { return this.brand; }
public void setBrand(String value) { this.brand = value; }
public String getChannel() { return this.channel; }
public void setChannel(String value) { this.channel = value; }
public String getColor() { return this.color; }
public void setColor(String value) { this.color = value; }
public String getCondition() { return this.condition; }
public void setCondition(String value) { this.condition = value; }
public String getContentLanguage() { return this.contentLanguage; }
public void setContentLanguage(String value) { this.contentLanguage = value; }
public List<ProductCustomAttribute> getCustomAttributes() { return this.customAttributes; }
public void setCustomAttributes(List<ProductCustomAttribute> value) { this.customAttributes = value; }
public List<ProductCustomGroup> getCustomGroups() { return this.customGroups; }
public void setCustomGroups(List<ProductCustomGroup> value) { this.customGroups = value; }
public String getCustomLabel0() { return this.customLabel0; }
public void setCustomLabel0(String value) { this.customLabel0 = value; }
public String getCustomLabel1() { return this.customLabel1; }
public void setCustomLabel1(String value) { this.customLabel1 = value; }
public String getCustomLabel2() { return this.customLabel2; }
public void setCustomLabel2(String value) { this.customLabel2 = value; }
public String getCustomLabel3() { return this.customLabel3; }
public void setCustomLabel3(String value) { this.customLabel3 = value; }
public String getCustomLabel4() { return this.customLabel4; }
public void setCustomLabel4(String value) { this.customLabel4 = value; }
public String getDescription() { return this.description; }
public void setDescription(String value) { this.description = value; }
public List<ProductDestination> getDestinations() { return this.destinations; }
public void setDestinations(List<ProductDestination> value) { this.destinations = value; }
public String getEnergyEfficiencyClass() { return this.energyEfficiencyClass; }
public void setEnergyEfficiencyClass(String value) { this.energyEfficiencyClass = value; }
public String getExpirationDate() { return this.expirationDate; }
public void setExpirationDate(String value) { this.expirationDate = value; }
public String getGender() { return this.gender; }
public void setGender(String value) { this.gender = value; }
public String getGoogleProductCategory() { return this.googleProductCategory; }
public void setGoogleProductCategory(String value) { this.googleProductCategory = value; }
public String getGtin() { return this.gtin; }
public void setGtin(String value) { this.gtin = value; }
public String getId() { return this.id; }
public void setId(String value) { this.id = value; }
public Boolean getIdentifierExists() { return this.identifierExists; }
public void setIdentifierExists(Boolean value) { this.identifierExists = value; }
public String getImageLink() { return this.imageLink; }
public void setImageLink(String value) { this.imageLink = value; }
public Boolean getIsBundle() { return this.isBundle; }
public void setIsBundle(Boolean value) { this.isBundle = value; }
public String getItemGroupId() { return this.itemGroupId; }
public void setItemGroupId(String value) { this.itemGroupId = value; }
public String getKind() { return this.kind; }
public void setKind(String value) { this.kind = value; }
public String getLink() { return this.link; }
public void setLink(String value) { this.link = value; }
public String getMaterial() { return this.material; }
public void setMaterial(String value) { this.material = value; }
public Long getMultipackQuantity() { return this.multipackQuantity; }
public void setMultipackQuantity(Long value) { this.multipackQuantity = value; }
public String getMobileLink() { return this.mobileLink; }
public void setMobileLink(String value) { this.mobileLink = value; }
public String getMpn() { return this.mpn; }
public void setMpn(String value) { this.mpn = value; }
public String getOfferId() { return this.offerId; }
public void setOfferId(String value) { this.offerId = value; }
public Boolean getOnlineOnly() { return this.onlineOnly; }
public void setOnlineOnly(Boolean value) { this.onlineOnly = value; }
public String getPattern() { return this.pattern; }
public void setPattern(String value) { this.pattern = value; }
public Price getPrice() { return this.price; }
public void setPrice(Price value) { this.price = value; }
public String getProductType() { return this.productType; }
public void setProductType(String value) { this.productType = value; }
public Price getSalePrice() { return this.salePrice; }
public void setSalePrice(Price value) { this.salePrice = value; }
public String getSalePriceEffectiveDate() { return this.salePriceEffectiveDate; }
public void setSalePriceEffectiveDate(String value) { this.salePriceEffectiveDate = value; }
public List<ProductShipping> getShipping() { return this.shipping; }
public void setShipping(List<ProductShipping> value) { this.shipping = value; }
public ProductShippingWeight getShippingWeight() { return this.shippingWeight; }
public void setShippingWeight(ProductShippingWeight value) { this.shippingWeight = value; }
public String getShippingLabel() { return this.shippingLabel; }
public void setShippingLabel(String value) { this.shippingLabel = value; }
public List<String> getSizes() { return this.sizes; }
public void setSizes(List<String> value) { this.sizes = value; }
public String getSizeSystem() { return this.sizeSystem; }
public void setSizeSystem(String value) { this.sizeSystem = value; }
public String getSizeType() { return this.sizeType; }
public void setSizeType(String value) { this.sizeType = value; }
public String getTargetCountry() { return this.targetCountry; }
public void setTargetCountry(String value) { this.targetCountry = value; }
public List<ProductTax> getTaxes() { return this.taxes; }
public void setTaxes(List<ProductTax> value) { this.taxes = value; }
public String getTitle() { return this.title; }
public void setTitle(String value) { this.title = value; }
public UnitPricing getUnitPricingBaseMeasure() { return this.unitPricingBaseMeasure; }
public void setUnitPricingBaseMeasure(UnitPricing value) { this.unitPricingBaseMeasure = value; }
public UnitPricing getUnitPricingMeasure() { return this.unitPricingMeasure; }
public void setUnitPricingMeasure(UnitPricing value) { this.unitPricingMeasure = value; }
public List<String> getValidatedDestinations() { return this.validatedDestinations; }
public void setValidatedDestinations(List<String> value) { this.validatedDestinations = value; }
}
// ProductCollection.java
package com.microsoft.contentapi.examples.datatransferobjects;
import java.util.List;
public class ProductCollection {
public String kind;
public String nextPageToken;
public List<Product> resources;
public List<Product> getResources(){
return resources;
}
public void setResources(List<Product> value){
resources = value;
}
}
// ProductCustomAttribute.java
package com.microsoft.contentapi.examples.datatransferobjects;
public class ProductCustomAttribute
{
private String name;
private String type;
private String unit;
private String value;
public String getName() { return this.name; }
public void setName(String value) { this.name = value; }
public String getType() { return this.type; }
public void setType(String value) { this.type = value; }
public String getUnit() { return this.unit; }
public void setUnit(String value) { this.unit = value; }
public String getValue() { return this.value; }
public void setValue(String value) { this.value = value; }
}
// ProductCustomGroup.java
package com.microsoft.contentapi.examples.datatransferobjects;
import com.fasterxml.jackson.annotation.JsonProperty;
import java.util.List;
public class ProductCustomGroup
{
@JsonProperty("customGroups")
private List<ProductCustomAttribute> attributes;
private String name;
public List<ProductCustomAttribute> getAttributes() { return this.attributes; }
public void setAttributes(List<ProductCustomAttribute> value) { this.attributes = value; }
public String getName() { return this.name; }
public void setName(String value) { this.name = value; }
}
// ProductDestination.java
package com.microsoft.contentapi.examples.datatransferobjects;
public class ProductDestination
{
private String destinationName;
private String intention;
public String getDestinationName() { return this.destinationName; }
public void setDestinationName(String value) { this.destinationName = value; }
public String getIntention() { return this.intention; }
public void setIntention(String value) { this.intention = value; }
}
// ProductShippingWeight.java
package com.microsoft.contentapi.examples.datatransferobjects;
public class ProductShippingWeight
{
private String unit;
private Double value;
public String getUnit() { return this.unit; }
public void setUnit(String value) { this.unit = value; }
public Double getValue() { return this.value; }
public void setValue(Double value) { this.value = value; }
}
// ProductTax.java
package com.microsoft.contentapi.examples.datatransferobjects;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
public class ProductTax
{
private String country;
private Long locationId;
private String postalCode;
private Double rate;
private String region;
@JsonDeserialize(using=StringBooleanDeserializer.class)
private Boolean taxShip;
public String getCountry() { return this.country; }
public void setCountry(String value) { this.country = value; }
public Long getLocationId() { return this.locationId; }
public void setLocationId(Long value) { this.locationId = value; }
public String getPostalCode() { return this.postalCode; }
public void setPostalCode(String value) { this.postalCode = value; }
public Double getRate() { return this.rate; }
public void setRate(Double value) { this.rate = value; }
public String getRegion() { return this.region; }
public void setRegion(String value) { this.region = value; }
public Boolean getTaxShip() { return this.taxShip; }
public void setTaxShip(Boolean value) { this.taxShip = value; }
}
// StringBooleanDeserializer.java
package com.microsoft.contentapi.examples.datatransferobjects;
import com.fasterxml.jackson.core.JsonParser;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.DeserializationContext;
import com.fasterxml.jackson.databind.JsonDeserializer;
import java.io.IOException;
public class StringBooleanDeserializer extends JsonDeserializer<Boolean> {
public Boolean deserialize(JsonParser parser, DeserializationContext context) throws IOException, JsonProcessingException {
return !"False".equals(parser.getText());
}
}
// UnitPricing.java
package com.microsoft.contentapi.examples.datatransferobjects;
public class UnitPricing
{
private String unit;
private Double value;
public String getUnit() { return this.unit; }
public void setUnit(String value) { this.unit = value; }
public Double getValue() { return this.value; }
public void setValue(Double value) { this.value = value; }
}
"""Content API Manage Products Example"""
import string
import random
from datetime import datetime, timedelta
import json
import requests
BASE_URI = 'https://content.api.bingads.microsoft.com/shopping/v9.1'
BMC_URI = BASE_URI + '/bmc/{0}'
CLIENT_ID = '<CLIENTIDGOESHERE>'
DEV_TOKEN = '<DEVELOPERTOKENGOESHERE>'
MERCHANT_ID = '<STOREIDGOESHERE>'
AUTHENTICATION_TOKEN = '<AUTHENTICATIONTOKENGOESHERE>'
AUTHENTICATION_HEADERS = {'DeveloperToken': DEV_TOKEN, 'AuthenticationToken': AUTHENTICATION_TOKEN}
def main():
"""The main entry point of this example"""
try:
# Get the default catalog
default_catalog = retrieve_default_catalog()
# Add a product to catalog
test_product = create_test_product("My Test Product")
# if catalog id is not specified the product will be added to the default catalog, here we are specifying the default explicitly
added_product = add_product(default_catalog['id'], test_product)
print("*** Added product to catalog (catalog.Id=" + str(default_catalog['id']) + ", product.Id=" + str(added_product['id']) + ")***")
print_json(added_product)
print("*** / End of added product (catalog.Id=" + str(default_catalog['id']) + ", product.Id=" + str(added_product['id']) + ")***")
print()
# Retrieve a product by id
retrieved_product = get_product(added_product['id'])
print("*** Retrieved product (product.Id=" + str(retrieved_product['id']) + ")***")
print_json(retrieved_product)
print("*** / End retrieved product (product.Id=" + str(retrieved_product['id']) + ")***")
print()
# List products
print("*** Listing products ***")
for product in list_products():
print_json(product)
print("*** / End listing producst ***")
print()
# Delete product
print("*** Deleting product (" + str(added_product['id']) + ")***")
delete_product(added_product['id'])
print("*** / Deleting product Done (" + str(added_product['id']) + ")***")
except Exception as ex:
raise ex
def retrieve_default_catalog():
"""Retrieve the default catalog"""
catalogs = list_catalogs()
for catalog in catalogs:
if catalog['isDefault']:
return catalog
return None
# List catalogs
CATALOGS_URI = BMC_URI + "/catalogs"
def list_catalogs():
"""list catalogs for the current merchant"""
url = CATALOGS_URI.format(MERCHANT_ID)
response = requests.get(url, headers=AUTHENTICATION_HEADERS)
response.raise_for_status()
return json.loads(response.text)['catalogs']
# List products
LIST_PRODUCTS_URI = BMC_URI + "/products"
# max-results set to 2 to test paging, this would be set to a
# higher value in a real world scenario based on your needs
LIST_PRODUCTS_QUERYSTRING = "?max-results=2&alt=json"
LIST_PRODUCST_START_TOKEN_QUERYSTRING = "?max-results=2&alt=json&start-token={1}"
def list_products(next_page_token=None):
"""List products"""
url = (LIST_PRODUCTS_URI + LIST_PRODUCTS_QUERYSTRING).format(MERCHANT_ID)
results = []
while url is not None:
response = requests.get(url, headers=AUTHENTICATION_HEADERS)
response.raise_for_status()
products_response = json.loads(response.text)
for product in products_response['resources']:
results.append(product)
if 'nextPageToken' in products_response:
url = (LIST_PRODUCTS_URI + LIST_PRODUCST_START_TOKEN_QUERYSTRING).format(MERCHANT_ID, products_response['nextPageToken'])
else:
url = None
return results
ADD_PRODUCT_URI = BMC_URI + "/products"
ADD_PRODUCT_QUERY_STRING = "?bmc-catalog-id={1}&alt=json"
def add_product(catalog_id, product):
"""Add a product"""
url = (ADD_PRODUCT_URI + ADD_PRODUCT_QUERY_STRING).format(MERCHANT_ID, catalog_id)
response = requests.post(url, headers=AUTHENTICATION_HEADERS, data=json.dumps(product))
response.raise_for_status()
return json.loads(response.text)
GET_PRODUCT_URI = BMC_URI + "/products/{1}"
GET_PRODUCT_QUERY_STRING = "?alt=json"
def get_product(product_id):
"""Get an existing product"""
url = (GET_PRODUCT_URI + GET_PRODUCT_QUERY_STRING).format(MERCHANT_ID, product_id)
response = requests.get(url, headers=AUTHENTICATION_HEADERS)
response.raise_for_status()
return json.loads(response.text)
DELETE_PRODUCT_URI = BMC_URI + "/products/{1}"
DELETE_PRODUCT_QUERY_STRING = "?alt=json"
def delete_product(product_id):
"""Delete a product"""
url = (DELETE_PRODUCT_URI + DELETE_PRODUCT_QUERY_STRING).format(MERCHANT_ID, product_id)
response = requests.delete(url, headers=AUTHENTICATION_HEADERS)
response.raise_for_status()
def print_json(obj):
"""Print the object as json"""
print(json.dumps(obj, sort_keys=True, indent=4, separators=(',', ': ')))
def create_test_product(title_prefix):
"""
Create and return an in memory product for testing.
You will want to set the values as appropriate for your purposes.
"""
return {
'offerId': 'YourUniqueId(' + random_string(16) + ')',
'title': title_prefix + '(' + random_string(4) + ')',
'availability': 'in stock',
'channel': 'Online',
'condition': 'New',
'contentLanguage': 'en',
'link': 'http://www.contoso.com/apperal/men/tshirts.htm',
'imageLink': 'http://www.contoso.com/pics/tees.jpg',
'price': {
'currency': 'USD',
'value': 1205.00
},
'targetCountry': 'US',
'identifierExists': False,
'expirationDate': (datetime.utcnow()+timedelta(days=45)).strftime("%Y-%m-%dT%H:%M:%SZ")
}
def random_string(length=6):
"""Get a random string of characters of the specified length"""
return ''.join(random.choices(string.ascii_uppercase + string.digits, k=length))
# Main execution
if __name__ == '__main__':
main()
<?php
$clientId = '<CLIENTIDGOESHERE>';
$devToken = '<DEVELOPERTOKENGOESHERE>';
$merchantId = '<STOREIDGOESHERE>';
$authenticationToken = '<AUTHENTICATIONTOKENGOESHERE>';
$baseUri = 'https://content.api.bingads.microsoft.com/shopping/v9.1';
$bmcUri = $baseUri . '/bmc/%s';
$catalogsUri = $bmcUri . "/catalogs";
$catalogUri = $catalogsUri . "/%s";
$productsUri = $bmcUri . '/products';
$productUri = $productsUri . '/%s';
$defaultCatalog = retrieve_default_catalog();
# Add a product to a catalog
$testProduct = create_test_product('My Test Product');
$addedProduct = add_product($defaultCatalog['id'], $testProduct);
echo("*** Added product to catalog (catalog id = " . $defaultCatalog['id'] . ", product id = " . $addedProduct['id'] . ")***\r\n");
printObject($addedProduct);
echo("*** / End of added product to catalog (catalog id = " . $defaultCatalog['id'] . ", product id = " . $addedProduct['id'] . ")***\r\n");
# Retrieve a product
$retrievedProduct = get_product($addedProduct['id']);
echo("*** Retrieved product (product id = " . $retrievedProduct['id'] . ")***\r\n");
printObject($retrievedProduct);
echo("*** / End of retrieved product (product id = " . $retrievedProduct['id'] . ")***\r\n");
# List products
$products = list_products();
echo("*** Listing products ***\r\n");
foreach ($products as $index => $value) {
printObject($value);
}
echo("*** / End of listing products ***\r\n");
echo("*** Deleting product (" . $addedProduct['id'] . ")***\r\n");
delete_product($addedProduct['id']);
echo("*** / Deleting product done (" . $addedProduct['id'] . ")***\r\n");
function retrieve_default_catalog(){
$catalogs = list_catalogs();
$count = count($catalogs);
for ($i = 0; $i < $count; ++$i){
$catalog = $catalogs[$i];
if ($catalog['isDefault']) {
return $catalog;
}
}
}
function list_catalogs(){
global $merchantId, $catalogsUri;
$url = sprintf($catalogsUri, $merchantId);
$result = request('GET', $url);
if ($result === FALSE) {
throw new Exception(var_dump($result));
} else {
$catalogs = json_decode($result, TRUE)["catalogs"];
return $catalogs;
}
}
function list_products($nextPageToken = null){
global $merchantId, $productsUri;
# max-results set to 2 to test paging, this would be set to a
# higher value in a real world scenario based on your needs.
$productsQueryString = '?max-results=2&alt=json';
$productsStartTokenQueryString = $productsQueryString . '&start-token=%s';
$url = sprintf($productsUri . $productsQueryString, $merchantId);
$results = array();
while ($url !== null) {
$result = request('GET', $url);
if ($result === FALSE) {
throw new Exception(var_dump($result));
}
$productsResponse = json_decode($result, TRUE);
foreach ($productsResponse['resources'] as $key => $value) {
array_push($results, $value);
}
if ($productsResponse !== null && array_key_exists('nextPageToken', $productsResponse)) {
$url = sprintf($productsUri . $productsStartTokenQueryString, $merchantId, $productsResponse['nextPageToken']);
} else {
$url = null;
}
}
return $results;
}
function add_product($catalogId, $product){
global $merchantId, $productsUri;
$url = sprintf($productsUri . '?bmc-catalog-id=%s&alt=json', $merchantId, $catalogId);
$result = request('POST', $url, $product);
if ($result === FALSE) {
throw new Exception(var_dump($result));
}
return json_decode($result, TRUE);
}
function get_product($productId){
global $merchantId, $productUri;
$url = sprintf($productUri . "?alt=json", $merchantId, $productId);
$result = request('GET', $url);
if ($result === FALSE) {
throw new Exception(var_dump($result));
}
return json_decode($result, TRUE);
}
function delete_product($productId){
global $merchantId, $productUri;
$url = sprintf($productUri . "?alt=json", $merchantId, $productId);
$result = request('DELETE', $url);
if ($result === FALSE) {
throw new Exception(var_dump($result));
}
}
function request($method, $url, $data = null){
global $devToken, $authenticationToken;
$options = array(
'http' => array(
'method' => $method,
'header' => "AuthenticationToken: $authenticationToken\r\n" .
"DeveloperToken: $devToken\r\n" .
"Content-type: application/json\r\n"
)
);
$json = null;
if($data !== null){
$json = json_encode($data);
$options['http']['content'] = $json;
}
$context = stream_context_create($options);
echo("requesting ($method): $url\r\n");
if($json !== null){
echo("json data: $json\r\n");
}
return file_get_contents($url, FALSE, $context);
}
function create_test_product($titlePrefix){
$expDate = date_add(new DateTime(), date_interval_create_from_date_string("45 days"));
return array(
'offerId' => "YourUniqueId(" . uniqid() . ")",
'title' => "$titlePrefix (" . uniqid() . ")",
'availability' => "in stock",
'channel' => "Online",
'condition' => "New",
'contentLanguage' => "en",
'link' => "http://www.contoso.com/apperal/men/tshirts.htm",
'imageLink' => "http://www.contoso.com/pics/tees.jpg",
'price' => array(
'currency' => 'USD',
'value' => 5.00,
),
'targetCountry' => 'US',
'identifierExists' => FALSE,
'expirationDate' => $expDate->format("Y-m-d\TH:i:s\Z")
);
}
function printObject($object){
foreach($object as $prop => $value){
echo("$prop: $value\r\n");
}
}