Web API 基本作業範例 (C#)
發行︰ 2017年1月
適用於： Dynamics 365 (online)、Dynamics 365 (on-premises)、Dynamics CRM 2016、Dynamics CRM Online
此範例示範如何在 Dynamics 365 實體執行個體上執行基本 CRUD (建立、擷取、更新和刪除) 和關聯及取消關聯作業，使用 Dynamics 365 Web API。
注意
此範例實作 Web API 基本作業範例中詳述的 Dynamics 365 作業和主控台輸出，並使用 Web API 範例 (C#) 中所述的一般 C# 結構。
本主題內容
先決條件
執行此範例
程式碼清單
先決條件
所有 Dynamics 365 Web API C# 範例的先決條件在上層主題 Web API 範例 (C#) 的 66e26684-819e-45f7-bec4-c250be4d6fed#bkmk_prerequisites 一節中詳述。
執行此範例
首先前往 Microsoft CRM Web API 基本作業範例 (C#)，下載範例封存檔案 Microsoft CRM Web API Basic Operations Sample (CS).zip，並將其內容解壓縮至本機資料夾。 此資料夾中應包含下列檔案：
檔案 |
用途/描述 |
|---|---|
Program.cs |
包含此範例的主要原始程式碼。 |
App.config |
應用程式設定檔，包含預留位置 Dynamics 365 伺服器連線資訊。 |
Authentication.cs |
位於 [Web API Helper 程式碼] 資料夾中，這些檔案組成補充程式碼，於 使用 Microsoft Dynamics 365 Web API Helper 程式庫 (C#) 中詳述。 |
BasicOperations.sln |
此範例的標準 Microsoft Visual Studio 2015 解決方案、專案、NuGet 套件設定及組件資訊檔案。 |
接著，使用下列程序執行此範例。
尋找解決方案檔案 BasicOperations.sln 並按兩下，將解決方案載入 Visual Studio 中。 建置 BasicOperations 解決方案。 這樣應該會自動下載和安裝所有遺漏或需要更新的必要 NuGet 套件。
編輯應用程式設定檔 App.config，指定 Dynamics 365 伺服器的連線資訊。 如需詳細資訊，請參閱Web API Helper 程式碼︰組態類別。
執行 BasicOperations 專案，從 Visual Studio 中。 根據預設，所有範例解決方案都設定為以偵錯模式執行。
程式碼清單
此檔案的最新來源可在範例下載套件中找到。
Program.cs
using Microsoft.Crm.Sdk.Samples.HelperCode;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System;
using System.Text;
using System.Collections.Generic;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Threading.Tasks;
using System.Linq;
using System.Net;
namespace Microsoft.Crm.Sdk.Samples
{
/// <summary>
/// This program performs basic create, retrieve, update, and delete (CRUD) and related
/// operations against a CRM Online 2016 or later organization using the Web API.
/// </summary>
/// <remarks>
/// Before building this application, you must first modify the following configuration
/// information in the app.config file:
/// - All deployments: Provide connection string service URL's for your organization.
/// - CRM Online: Replace the app settings with the correct values for your Azure
/// application registration.
/// See the provided app.config file for more information.
/// </remarks>
class BasicOperations
{
//Provides a persistent client-to-CRM server communication channel.
private HttpClient httpClient;
//Start with base version and update with actual version later.
private Version webAPIVersion = new Version(8, 0);
private string getVersionedWebAPIPath()
{
return string.Format("v{0}/", webAPIVersion.ToString(2));
}
public async Task getWebAPIVersion()
{
HttpRequestMessage RetrieveVersionRequest =
new HttpRequestMessage(HttpMethod.Get, getVersionedWebAPIPath() + "RetrieveVersion");
HttpResponseMessage RetrieveVersionResponse =
await httpClient.SendAsync(RetrieveVersionRequest);
if (RetrieveVersionResponse.StatusCode == HttpStatusCode.OK) //200
{
JObject RetrievedVersion = JsonConvert.DeserializeObject<JObject>(
await RetrieveVersionResponse.Content.ReadAsStringAsync());
//Capture the actual version available in this organization
webAPIVersion = Version.Parse((string)RetrievedVersion.GetValue("Version"));
}
else
{
Console.WriteLine("Failed to retrieve the version for reason: {0}",
RetrieveVersionResponse.ReasonPhrase);
throw new CrmHttpResponseException(RetrieveVersionResponse.Content);
}
}
//Centralized collection of entity URIs used to manage lifetimes.
List<string> entityUris = new List<string>();
//A set of variables to hold the state of and URIs for primary entity instances.
private JObject contact1 = new JObject(), contact2 = new JObject(),
retrievedContact1, retrievedContact2;
private string contact1Uri;
private JObject account1 = new JObject(), account2 = new JObject(),
retrievedAccount1, retrievedAccount2;
private string account1Uri, account2Uri;
/// <summary>
/// Demonstrates basic create, update, and retrieval operations for entity instances and
/// single properties.
/// </summary>
public async Task BasicCreateAndUpdatesAsync()
{
Console.WriteLine("--Section 1 started--");
string queryOptions; //select, expand and filter clauses
//First create a new contact instance, then add additional property values and update
// several properties.
//Local representation of CRM Contact instance
contact1.Add("firstname", "Peter");
contact1.Add("lastname", "Cambel");
HttpRequestMessage createRequest1 =
new HttpRequestMessage(HttpMethod.Post, getVersionedWebAPIPath() + "contacts");
createRequest1.Content = new StringContent(contact1.ToString(),
Encoding.UTF8, "application/json");
HttpResponseMessage createResponse1 =
await httpClient.SendAsync(createRequest1);
if (createResponse1.StatusCode == HttpStatusCode.NoContent) //204
{
Console.WriteLine("Contact '{0} {1}' created.",
contact1.GetValue("firstname"), contact1.GetValue("lastname"));
contact1Uri = createResponse1.Headers.
GetValues("OData-EntityId").FirstOrDefault();
entityUris.Add(contact1Uri);
Console.WriteLine("Contact URI: {0}", contact1Uri);
}
else
{
Console.WriteLine("Failed to create contact for reason: {0}",
createResponse1.ReasonPhrase);
throw new CrmHttpResponseException(createResponse1.Content);
}
//Add additional property values to the existing contact. As a general
// rule, only transmit a minimum working set of properties.
JObject contact1Add = new JObject();
contact1Add.Add("annualincome", 80000);
contact1Add.Add("jobtitle", "Junior Developer");
HttpRequestMessage updateRequest1 = new HttpRequestMessage(
new HttpMethod("PATCH"), contact1Uri);
updateRequest1.Content = new StringContent(contact1Add.ToString(),
Encoding.UTF8, "application/json");
HttpResponseMessage updateResponse1 =
await httpClient.SendAsync(updateRequest1);
if (updateResponse1.StatusCode == HttpStatusCode.NoContent) //204
{
Console.WriteLine("Contact '{0} {1}' updated with job title" +
" and annual income.", contact1.GetValue("firstname"),
contact1.GetValue("lastname"));
}
else
{
Console.WriteLine("Failed to update contact for reason: {0}",
updateResponse1.ReasonPhrase);
throw new CrmHttpResponseException(updateResponse1.Content);
}
//Retrieve the contact with its explicitly initialized properties.
//fullname is a read-only calculated value.
queryOptions = "?$select=fullname,annualincome,jobtitle,description";
HttpResponseMessage retrieveResponse1 = await httpClient.GetAsync(
contact1Uri + queryOptions);
if (retrieveResponse1.StatusCode == HttpStatusCode.OK) //200
{
retrievedContact1 = JsonConvert.DeserializeObject<JObject>(
await retrieveResponse1.Content.ReadAsStringAsync());
Console.WriteLine("Contact '{0}' retrieved: \n\tAnnual income: {1}" +
"\n\tJob title: {2} \n\tDescription: {3}.",
// Can use either indexer or GetValue method (or a mix of two)
retrievedContact1.GetValue("fullname"),
retrievedContact1["annualincome"],
retrievedContact1["jobtitle"],
retrievedContact1["description"]); //description is initialized empty.
}
else
{
Console.WriteLine("Failed to retrieve contact for reason: {0}",
retrieveResponse1.ReasonPhrase);
throw new CrmHttpResponseException(retrieveResponse1.Content);
}
//Modify specific properties and then update entity instance.
JObject contact1Update = new JObject();
contact1Update.Add("jobtitle", "Senior Developer");
contact1Update.Add("annualincome", 95000);
contact1Update.Add("description", "Assignment to-be-determined");
HttpRequestMessage updateRequest2 = new HttpRequestMessage(
new HttpMethod("PATCH"), contact1Uri);
updateRequest2.Content = new StringContent(contact1Update.ToString(),
Encoding.UTF8, "application/json");
HttpResponseMessage updateResponse2 =
await httpClient.SendAsync(updateRequest2);
if (updateResponse2.StatusCode == HttpStatusCode.NoContent)
{
Console.WriteLine("Contact '{0}' updated:", retrievedContact1["fullname"]);
Console.WriteLine("\tJob title: {0}", contact1Update["jobtitle"]);
Console.WriteLine("\tAnnual income: {0}", contact1Update["annualincome"]);
Console.WriteLine("\tDescription: {0}", contact1Update["description"]);
}
else
{
Console.WriteLine("Failed to update contact for reason: {0}",
updateResponse2.ReasonPhrase);
throw new CrmHttpResponseException(updateResponse2.Content);
}
// Change just one property
string phone1 = "555-0105";
// Create unique identifier by appending property name
string contactPhoneUri =
string.Format("{0}/{1}", contact1Uri, "telephone1");
JObject phoneValue = new JObject();
phoneValue.Add("value", phone1); //Updates must use keyword "value".
HttpRequestMessage updateRequest3 =
new HttpRequestMessage(HttpMethod.Put, contactPhoneUri);
updateRequest3.Content = new StringContent(phoneValue.ToString(),
Encoding.UTF8, "application/json");
HttpResponseMessage updateResponse3 =
await httpClient.SendAsync(updateRequest3);
if (updateResponse3.StatusCode == HttpStatusCode.NoContent)
{
Console.WriteLine("Contact '{0}' phone number updated.",
retrievedContact1["fullname"]);
}
else
{
Console.WriteLine("Failed to update the contact phone number for reason: {0}.",
updateResponse3.ReasonPhrase);
throw new CrmHttpResponseException(updateResponse3.Content);
}
//Now retrieve just the single property.
JObject retrievedProperty1;
HttpResponseMessage retrieveResponse2 =
await httpClient.GetAsync(contactPhoneUri);
if (retrieveResponse2.StatusCode == HttpStatusCode.OK)
{
retrievedProperty1 = JsonConvert.DeserializeObject<JObject>(
await retrieveResponse2.Content.ReadAsStringAsync());
Console.WriteLine("Contact's telephone# is: {0}.",
retrievedProperty1["value"]);
}
else
{
Console.WriteLine("Failed to retrieve the contact phone number for reason: {0}.",
retrieveResponse2.ReasonPhrase);
throw new CrmHttpResponseException(retrieveResponse2.Content);
}
//The following capabilities require version 8.2 or higher
if (webAPIVersion >= Version.Parse("8.2"))
{
//Alternately, starting with December 2016 update (v8.2), a contact instance can be
//created and its properties returned in one operation by using a
//'Prefer: return=representation' header. Note that a 201 (Created) success status
// is returned, and not a 204 (No content).
string contactAltUri;
JObject contactAlt = new JObject();
contactAlt.Add("firstname", "Peter_Alt");
contactAlt.Add("lastname", "Cambel");
contactAlt.Add("jobtitle", "Junior Developer");
contactAlt.Add("annualincome", 80000);
contactAlt.Add("telephone1", "555-0110");
queryOptions = "?$select=fullname,annualincome,jobtitle,contactid";
HttpRequestMessage createRequestAlt =
new HttpRequestMessage(HttpMethod.Post, getVersionedWebAPIPath() + "contacts" + queryOptions);
createRequestAlt.Content = new StringContent(contactAlt.ToString(),
Encoding.UTF8, "application/json");
createRequestAlt.Headers.Add("Prefer", "return=representation");
HttpResponseMessage createResponseAlt = await httpClient.SendAsync(createRequestAlt);
if (createResponseAlt.StatusCode == HttpStatusCode.Created) //201
{
//Body should contain the requested new-contact information.
JObject createdContactAlt = JsonConvert.DeserializeObject<JObject>(
await createResponseAlt.Content.ReadAsStringAsync());
//Because 'OData-EntityId' header not returned in a 201 response, you must instead
// construct the URI.
contactAltUri = httpClient.BaseAddress + getVersionedWebAPIPath() + "contacts(" + createdContactAlt["contactid"] + ")";
entityUris.Add(contactAltUri);
Console.WriteLine(
"Contact '{0}' created: \n\tAnnual income: {1}" + "\n\tJob title: {2}",
createdContactAlt["fullname"],
createdContactAlt["annualincome"],
createdContactAlt["jobtitle"]);
Console.WriteLine("Contact URI: {0}", contactAltUri);
}
else
{
Console.WriteLine("Failed to create contact for reason: {0}",
createResponseAlt.ReasonPhrase);
throw new CrmHttpResponseException(createResponseAlt.Content);
}
//Similarly, the December 2016 update (v8.2) also enables returning selected properties
//after an update operation (PATCH), with the 'Prefer: return=representation' header.
//Here a success is indicated by 200 (OK) instead of 204 (No content).
//Since we're reusing a local JObject, reinitialize it to remove extraneous properties.
contactAlt.RemoveAll();
contactAlt["annualincome"] = 95000;
contactAlt["jobtitle"] = "Senior Developer";
contactAlt["description"] = "MS Azure and Dynamics 365 Specialist";
queryOptions = "?$select=fullname,annualincome,jobtitle";
HttpRequestMessage updateRequestAlt = new HttpRequestMessage(
new HttpMethod("PATCH"), contactAltUri + queryOptions);
updateRequestAlt.Content = new StringContent(contactAlt.ToString(),
Encoding.UTF8, "application/json");
updateRequestAlt.Headers.Add("Prefer", "return=representation");
HttpResponseMessage updateResponseAlt = await httpClient.SendAsync(updateRequestAlt);
if (updateResponseAlt.StatusCode == HttpStatusCode.OK) //200
{
//Body should contain the requested updated-contact information.
JObject UpdatedContactAlt = JsonConvert.DeserializeObject<JObject>(
await updateResponseAlt.Content.ReadAsStringAsync());
Console.WriteLine(
"Contact '{0}' updated: \n\tAnnual income: {1}" + "\n\tJob title: {2}",
UpdatedContactAlt["fullname"],
UpdatedContactAlt["annualincome"],
UpdatedContactAlt["jobtitle"]);
}
else
{
Console.WriteLine("Failed to update contact for reason: {0}",
updateResponse1.ReasonPhrase);
throw new CrmHttpResponseException(updateResponse1.Content);
}
}
}
/// <summary>
/// Demonstrates creation of entity instance and simultaneous association to another,
/// existing entity.
/// </summary>
public async Task CreateWithAssociationAsync()
{
Console.WriteLine("\n--Section 2 started--");
string queryOptions; //select, expand and filter clauses
//Create a new account and associate with existing contact in one operation.
account1.Add("name", "Contoso Ltd");
account1.Add("telephone1", "555-5555");
account1.Add("primarycontactid@odata.bind", contact1Uri);
HttpRequestMessage createRequest2 =
new HttpRequestMessage(HttpMethod.Post, getVersionedWebAPIPath() + "accounts");
createRequest2.Content = new StringContent(account1.ToString(),
Encoding.UTF8, "application/json");
HttpResponseMessage createResponse2 =
await httpClient.SendAsync(createRequest2);
if (createResponse2.StatusCode == HttpStatusCode.NoContent)
{
Console.WriteLine("Account '{0}' created.", account1.GetValue("name"));
account1Uri = createResponse2.Headers.GetValues("OData-EntityId").
FirstOrDefault();
entityUris.Add(account1Uri);
}
else
{
Console.WriteLine("Failed to create account for reason: {0}.",
createResponse2.ReasonPhrase);
throw new CrmHttpResponseException(createResponse2.Content);
}
//Retrieve account name and primary contact info
queryOptions =
"?$select=name,&$expand=primarycontactid($select=fullname,jobtitle,annualincome)";
HttpResponseMessage retrieveResponse3 =
await httpClient.GetAsync(account1Uri + queryOptions);
if (retrieveResponse3.StatusCode == HttpStatusCode.OK)
{
retrievedAccount1 = JsonConvert.DeserializeObject<JObject>(
await retrieveResponse3.Content.ReadAsStringAsync());
Console.WriteLine("Account '{0}' has primary contact '{1}':",
retrievedAccount1["name"],
retrievedAccount1.GetValue("primarycontactid")["fullname"]
);
Console.WriteLine("\tJob title: {0} \n\tAnnual income: {1}",
retrievedAccount1.GetValue("primarycontactid")["jobtitle"],
retrievedAccount1["primarycontactid"]["annualincome"]
);
}
else
{
Console.WriteLine("Failed to retrieve account for reason: {0}.",
retrieveResponse3.ReasonPhrase);
throw new CrmHttpResponseException(retrieveResponse3.Content);
}
}
/// <summary>
/// Demonstrates creation of entity instance and related entities in a single operation.
/// </summary>
public async Task CreateRelatedAsync()
{
Console.WriteLine("\n--Section 3 started--");
string queryOptions; //select, expand and filter clauses
//Create the following entries in one operation: an account, its
// associated primary contact, and open tasks for that contact. These
// entity types have the following relationships:
// Accounts
// |---[Primary] Contact (N-to-1)
// |---Tasks (1-to-N)
//Build the Account object inside-out, starting with most nested type(s)
JArray tasks = new JArray();
JObject task1 = new JObject();
task1.Add("subject", "Sign invoice");
task1.Add("description", "Invoice #12321");
task1.Add("scheduledend", DateTimeOffset.Parse("4/19/2016"));
tasks.Add(task1);
JObject task2 = new JObject();
task2.Add("subject", "Setup new display");
task2.Add("description", "Theme is - Spring is in the air");
task2.Add("scheduledstart", DateTimeOffset.Parse("4/20/2016"));
tasks.Add(task2);
JObject task3 = new JObject();
task3.Add("subject", "Conduct training");
task3.Add("description", "Train team on making our new blended coffee");
task3.Add("scheduledstart", DateTimeOffset.Parse("6/1/2016"));
tasks.Add(task3);
contact2.Add("firstname", "Susie");
contact2.Add("lastname", "Curtis");
contact2.Add("jobtitle", "Coffee Master");
contact2.Add("annualincome", 48000);
//Add related tasks using corresponding navigation property
contact2.Add("Contact_Tasks", tasks);
account2.Add("name", "Fourth Coffee");
//Add related contacts using corresponding navigation property
account2.Add("primarycontactid", contact2);
HttpRequestMessage createRequest3 =
new HttpRequestMessage(HttpMethod.Post, getVersionedWebAPIPath() + "accounts");
createRequest3.Content = new StringContent(account2.ToString(),
Encoding.UTF8, "application/json");
HttpResponseMessage createResponse3 =
await httpClient.SendAsync(createRequest3);
if (createResponse3.StatusCode == HttpStatusCode.NoContent)
{
Console.WriteLine("Account '{0}' created.",
account2.GetValue("name"));
account2Uri = createResponse3.Headers.GetValues("OData-EntityId").
FirstOrDefault();
entityUris.Add(account2Uri);
}
else
{
Console.WriteLine("Failed to create account for reason: {0}.",
createResponse3.ReasonPhrase);
throw new CrmHttpResponseException(createResponse3.Content);
}
//Retrieve account, primary contact info, and assigned tasks for contact.
//CRM only supports querying-by-expansion one level deep, so first query
// account-primary contact.
queryOptions =
"?$select=name,&$expand=primarycontactid($select=fullname,jobtitle,annualincome)";
HttpResponseMessage retrieveResponse4 =
await httpClient.GetAsync(account2Uri + queryOptions);
if (retrieveResponse4.StatusCode == HttpStatusCode.OK)
{
retrievedAccount2 = JsonConvert.DeserializeObject<JObject>(
await retrieveResponse4.Content.ReadAsStringAsync());
Console.WriteLine("Account '{0}' has primary contact '{1}':",
retrievedAccount2.GetValue("name"),
retrievedAccount2.GetValue("primarycontactid")["fullname"]);
Console.WriteLine("\tJob title: {0} \n\tAnnual income: {1}",
retrievedAccount2["primarycontactid"]["jobtitle"],
retrievedAccount2["primarycontactid"]["annualincome"]);
}
else
{
Console.WriteLine("Failed to retrieve the account/contact info for " +
"reason: {0}.", retrieveResponse4.ReasonPhrase);
throw new CrmHttpResponseException(retrieveResponse4.Content);
}
//Next retrieve same contact and its assigned tasks.
//Don't have a saved URI for contact 'Susie Curtis', so create one
// from base address and entity ID.
string contact2Uri = string.Format("{0}contacts({1})",
httpClient.BaseAddress + getVersionedWebAPIPath(),
retrievedAccount2["primarycontactid"]["contactid"]);
entityUris.Add(contact2Uri);
queryOptions =
"?$select=fullname,&$expand=Contact_Tasks($select=subject,description,scheduledstart,scheduledend)";
HttpResponseMessage retrieveResponse5 =
await httpClient.GetAsync(contact2Uri + queryOptions);
if (retrieveResponse5.StatusCode == HttpStatusCode.OK)
{
retrievedContact2 = JsonConvert.DeserializeObject<JObject>(
await retrieveResponse5.Content.ReadAsStringAsync());
Console.WriteLine("Contact '{0}' has the following assigned tasks:",
retrievedContact2["fullname"]);
foreach (JToken tk in retrievedContact2["Contact_Tasks"])
{
Console.WriteLine(
"Subject: {0}, \n\tDescription: {1}\n\tStart: {2}\n\tEnd: {3}\n",
tk["subject"],
tk["description"],
tk["scheduledstart"].Value<DateTime>().ToString("d"),
tk["scheduledend"].Value<DateTime>().ToString("d")
);
}
}
else
{
Console.WriteLine("Failed to retrieve the contact info for reason: {0}.",
retrieveResponse5.ReasonPhrase);
throw new CrmHttpResponseException(retrieveResponse5.Content);
}
}
/// <summary>
/// Demonstrates associating and disassociating of existing entity instances.
/// </summary>
public async Task AssociateExistingAsync()
{
string queryOptions; //select, expand and filter clauses
Console.WriteLine("\n--Section 4 started--");
//Add 'Peter Cambel' to the contact list of 'Fourth Coffee',
// a 1-to-N relationship.
JObject rel1 = new JObject(); //relationship object for msg content
rel1.Add("@odata.id", contact1Uri);
Uri navUri1 = new Uri(String.Format("{0}/{1}/$ref", account2Uri,
"contact_customer_accounts"));
HttpRequestMessage assocRequest1 =
new HttpRequestMessage(HttpMethod.Post, navUri1);
assocRequest1.Content = new StringContent(rel1.ToString(),
Encoding.UTF8, "application/json");
HttpResponseMessage assocResponse1 =
await httpClient.SendAsync(assocRequest1);
if (assocResponse1.StatusCode == HttpStatusCode.NoContent)
{
Console.WriteLine("Contact '{0}' associated to account '{1}'.",
retrievedContact1["fullname"], account2["name"]);
}
else
{
Console.WriteLine("Failed to associate account/contact entities " +
"for reason: {0}.", assocResponse1.ReasonPhrase);
throw new CrmHttpResponseException(assocResponse1.Content);
}
//Retrieve and output all contacts for account 'Fourth Coffee'.
JObject retrievedContactList1;
queryOptions = "?$select=fullname,jobtitle";
HttpResponseMessage retrieveResponse6 = await httpClient.GetAsync(
account2Uri + "/contact_customer_accounts" + queryOptions);
if (retrieveResponse6.StatusCode == HttpStatusCode.OK)
{
retrievedContactList1 = JsonConvert.DeserializeObject<JObject>(
await retrieveResponse6.Content.ReadAsStringAsync());
Console.WriteLine("Contact list for account '{0}':",
retrievedAccount2["name"]);
foreach (JToken ct in retrievedContactList1["value"])
{
Console.WriteLine("\tName: {0}, Job title: {1}",
ct["fullname"], ct["jobtitle"]);
}
}
else
{
Console.WriteLine("Failed to retrieve the account/contact info" +
" for reason: {0}.", retrieveResponse6.ReasonPhrase);
throw new CrmHttpResponseException(retrieveResponse6.Content);
}
//Dissociate the contact from the account. For a collection-valued
// navigation property, must append URI of referenced entity.
string dis1Uri = navUri1 + "?$id=" + contact1Uri;
//Equivalently, could have dissociated from the other end of the
// relationship, using the single-valued navigation ref, located in
// the contact 'Peter Cambel'. This dissociation URI has a simpler form:
// [Org URI]/api/data/v8.2/contacts([contactid#])/parentcustomerid_account/$ref
HttpResponseMessage disassocResponse1 =
await httpClient.DeleteAsync(dis1Uri);
if (disassocResponse1.StatusCode == HttpStatusCode.NoContent)
{
Console.WriteLine("Contact '{0}' dissociated from account '{1}'.",
retrievedContact1["fullname"], account2["name"]);
}
else
{
Console.WriteLine("Failed to disassociate entities for reason: {0}.",
disassocResponse1.ReasonPhrase);
throw new CrmHttpResponseException(disassocResponse1.Content);
}
//Associate an opportunity to a competitor, an N-to-N relationship.
//First, create the required entity instances.
string comp1Uri, oppor1Uri;
JObject comp1 = new JObject();
comp1.Add("name", "Adventure Works");
comp1.Add("strengths",
"Strong promoter of private tours for multi-day outdoor adventures");
JObject oppor1 = new JObject();
oppor1["name"] = "River rafting adventure";
oppor1["description"] = "Sales team on a river-rafting offsite and team building";
HttpRequestMessage createRequest4 =
new HttpRequestMessage(HttpMethod.Post, getVersionedWebAPIPath() + "competitors");
createRequest4.Content = new StringContent(comp1.ToString(),
Encoding.UTF8, "application/json");
HttpResponseMessage createResponse4 =
await httpClient.SendAsync(createRequest4);
if (createResponse4.StatusCode == HttpStatusCode.NoContent)
{
Console.WriteLine("Competitor '{0}' created.", comp1["name"]);
comp1Uri = createResponse4.Headers.GetValues("OData-EntityId").
FirstOrDefault();
entityUris.Add(comp1Uri);
}
else
{
Console.WriteLine("Failed to create competitor for reason: {0}",
createResponse4.ReasonPhrase);
throw new CrmHttpResponseException(createResponse4.Content);
}
HttpRequestMessage createRequest5 =
new HttpRequestMessage(HttpMethod.Post, getVersionedWebAPIPath() + "opportunities");
createRequest5.Content = new StringContent(oppor1.ToString(),
Encoding.UTF8, "application/json");
HttpResponseMessage createResponse5 =
await httpClient.SendAsync(createRequest5);
if (createResponse5.StatusCode == HttpStatusCode.NoContent)
{
Console.WriteLine("Opportunity '{0}' created.", oppor1["name"]);
oppor1Uri = createResponse5.Headers.GetValues("OData-EntityId").
FirstOrDefault();
entityUris.Add(oppor1Uri);
}
else
{
Console.WriteLine("Failed to create opportunity for reason: {0}",
createResponse5.ReasonPhrase);
throw new CrmHttpResponseException(createResponse5.Content);
}
//Associate opportunity to competitor via opportunitycompetitors_association.
// navigation property.
JObject rel2 = new JObject();
rel2.Add("@odata.id", comp1Uri);
Uri navUri2 = new Uri(String.Format("{0}/{1}/$ref", oppor1Uri,
"opportunitycompetitors_association"));
HttpRequestMessage assocRequest2 =
new HttpRequestMessage(HttpMethod.Post, navUri2);
assocRequest2.Content = new StringContent(rel2.ToString(),
Encoding.UTF8, "application/json");
HttpResponseMessage assocResponse2 =
await httpClient.SendAsync(assocRequest2);
if (assocResponse2.StatusCode == HttpStatusCode.NoContent)
{
Console.WriteLine(
"Opportunity '{0}' associated with competitor '{1}'.",
oppor1["name"], comp1["name"]);
}
else
{
Console.WriteLine("Failed to associate competitor/opportunity" +
"entities for reason: {0}.", assocResponse2.ReasonPhrase);
throw new CrmHttpResponseException(assocResponse2.Content);
}
//Retrieve all opportunities for competitor 'Adventure Works'.
JObject retrievedOpporList1;
//Select only 'name' to limit returned competitor properties.
queryOptions =
"?$select=name,&$expand=opportunitycompetitors_association($select=name,description)";
HttpResponseMessage retrieveResponse7 =
await httpClient.GetAsync(comp1Uri + queryOptions);
if (retrieveResponse7.StatusCode == HttpStatusCode.OK)
{
retrievedOpporList1 = JsonConvert.DeserializeObject<JObject>(
await retrieveResponse7.Content.ReadAsStringAsync());
Console.WriteLine("Competitor '{0}' has the following opportunities:",
retrievedOpporList1["name"]);
foreach (JToken op in
retrievedOpporList1["opportunitycompetitors_association"])
{
Console.WriteLine("\tName: {0}, \n\tDescription: {1}",
op["name"], op["description"]);
}
}
else
{
Console.WriteLine("Failed to retrieve the competitor/opportunity"
+ " info for reason: {0}.",
retrieveResponse7.ReasonPhrase);
throw new CrmHttpResponseException(retrieveResponse7.Content);
}
//Dissociate opportunity from competitor.
string dis2Uri = navUri2 + "?$id=" + comp1Uri;
HttpResponseMessage disassocResponse2 =
await httpClient.DeleteAsync(dis2Uri);
if (disassocResponse2.StatusCode == HttpStatusCode.NoContent)
{
Console.WriteLine(
"Opportunity '{0}' disassociated from competitor '{1}'.",
oppor1["name"], comp1["name"]);
}
else
{
Console.WriteLine("Failed to disassociate entities for reason: {0}.",
disassocResponse1.ReasonPhrase);
throw new CrmHttpResponseException(disassocResponse1.Content);
}
}
/// <summary>
///Provides the high-level logical flow of the program, as well as a section
/// containing cleanup code.
/// </summary>
public async Task RunAsync()
{
try
{
await getWebAPIVersion();
await BasicCreateAndUpdatesAsync();
await CreateWithAssociationAsync();
await CreateRelatedAsync();
await AssociateExistingAsync();
}
catch (Exception ex)
{ DisplayException(ex); }
finally
{
#region Section 5: Delete sample entities
Console.WriteLine("\n--Section 5 started--");
//Delete all the created sample entities. Note that explicit deletion is not required
// for contact tasks because these are automatically cascade-deleted with owner.
Console.Write("\nDo you want these entity records deleted? (y/n) [y]: ");
String answer = Console.ReadLine();
answer = answer.Trim();
if (!(answer.StartsWith("y") || answer.StartsWith("Y") || answer == String.Empty))
{ entityUris.Clear(); }
HttpResponseMessage deleteResponse1;
int successCnt = 0, notFoundCnt = 0, failCnt = 0;
HttpContent lastBadResponseContent = null;
foreach (string ent in entityUris)
{
deleteResponse1 = await httpClient.DeleteAsync(ent);
if (deleteResponse1.IsSuccessStatusCode) //200-299
{
Console.WriteLine("Entity deleted: \n{0}.", ent);
successCnt++;
}
else if (deleteResponse1.StatusCode == HttpStatusCode.NotFound) //404
{
//May have been deleted by another user or via cascade operation
Console.WriteLine("Entity not found: {0}.", ent);
notFoundCnt++;
}
else
{
Console.WriteLine("Failed to delete: {0}.", ent);
failCnt++;
lastBadResponseContent = deleteResponse1.Content;
}
}
Console.WriteLine("Entities deleted: {0}, not found: {1}, delete " +
"failures: {2}. \n", successCnt, notFoundCnt, failCnt);
entityUris.Clear();
if (failCnt > 0)
{
//Throw last failure
throw new CrmHttpResponseException(lastBadResponseContent);
}
#endregion Section 5: Delete sample entities
}
}
static public void Main(string[] args)
{
BasicOperations app = new BasicOperations();
try
{
//Read configuration file and connect to specified CRM server.
app.ConnectToCRM(args);
Task.WaitAll(Task.Run(async () => await app.RunAsync()));
}
catch (System.Exception ex) { DisplayException(ex); }
finally
{
if (app.httpClient != null)
{ app.httpClient.Dispose(); }
Console.WriteLine("Press <Enter> to exit the program.");
Console.ReadLine();
}
}
/// <summary>
/// Obtains the connection information from the application's configuration file, then
/// uses this info to connect to the specified CRM service.
/// </summary>
/// <param name="args"> Command line arguments. The first specifies the name of the
/// connection string setting. </param>
private void ConnectToCRM(String[] cmdargs)
{
//Create a helper object to read app.config for service URL and application
// registration settings.
Configuration config = null;
if (cmdargs.Length > 0)
{ config = new FileConfiguration(cmdargs[0]); }
else
{ config = new FileConfiguration(null); }
//Create a helper object to authenticate the user with this connection info.
Authentication auth = new Authentication(config);
//Next use a HttpClient object to connect to specified CRM Web service.
httpClient = new HttpClient(auth.ClientHandler, true);
//Define the Web API base address, the max period of execute time, the
// default OData version, and the default response payload format.
httpClient.BaseAddress = new Uri(config.ServiceUrl + "api/data/");
httpClient.Timeout = new TimeSpan(0, 2, 0);
httpClient.DefaultRequestHeaders.Add("OData-MaxVersion", "4.0");
httpClient.DefaultRequestHeaders.Add("OData-Version", "4.0");
httpClient.DefaultRequestHeaders.Accept.Add(
new MediaTypeWithQualityHeaderValue("application/json"));
}
/// <summary> Helper method to display caught exceptions </summary>
private static void DisplayException(Exception ex)
{
Console.WriteLine("The application terminated with an error.");
Console.WriteLine(ex.Message);
while (ex.InnerException != null)
{
Console.WriteLine("\t* {0}", ex.InnerException.Message);
ex = ex.InnerException;
}
}
}
}
另請參閱
使用 Microsoft Dynamics 365 Web API
使用 Web API，建立實體
使用 Web API 更新和刪除實體
使用 Web API 擷取實體
使用 Web API 更新和刪除實體
Web API 範例
Web API 基本作業範例
Web API 基本作業範例 (用戶端 JavaScript)
Web API 查詢資料範例 (C#)
Web API 條件式作業範例 (C#)
Web API 函數和動作範例 (C#)
Microsoft Dynamics 365
© 2017 Microsoft. 著作權所有，並保留一切權利。 著作權