摘要: 本人微信公众号：微软动态CRM专家罗勇 ，回复295或者20190112可方便获取本文，同时可以在第一间得到我发布的最新博文信息，follow me！我的网站是 www.luoyong.me 。
系统作业实体(实体逻辑名称为asyncoperation)，若这个实体记录数太多，会对系统造成较大压力，可以利用系统标准的【批量删除】功能(Bulk Delete)来定期删除，批量删除最频繁的密度为每天运行一次。有时候记录数暴增，可能会用到程序来删除，我这里有个例子，上代码，这个是每次获取5000条记录，每次提交500条记录进行删除。
using Microsoft.Crm.Sdk.Messages;
using Microsoft.Xrm.Sdk;
using Microsoft.Xrm.Sdk.Client;
using Microsoft.Xrm.Sdk.Messages;
using Microsoft.Xrm.Sdk.Query;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.IO;
using System.Linq;
using System.Net;
using System.ServiceModel.Description;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Xml; namespace DeleteAsyncOperations
{
class Program
{
static void Main(string[] args)
{
try
{
string inputKey;
ServicePointManager.SecurityProtocol = SecurityProtocolType.Ssl3 | SecurityProtocolType.Tls | SecurityProtocolType.Tls11 | SecurityProtocolType.Tls12;
IServiceManagement<IOrganizationService> orgServiceMgr = ServiceConfigurationFactory.CreateManagement<IOrganizationService>(new Uri(ConfigurationManager.AppSettings["orgUrl"]));
AuthenticationCredentials orgAuCredentials = new AuthenticationCredentials();
orgAuCredentials.ClientCredentials.UserName.UserName = ConfigurationManager.AppSettings["userName"];
orgAuCredentials.ClientCredentials.UserName.Password = ConfigurationManager.AppSettings["passWord"];
string needConfirm = ConfigurationManager.AppSettings["needConfirm"];
using (var orgSvc = GetProxy<IOrganizationService, OrganizationServiceProxy>(orgServiceMgr, orgAuCredentials))
{
orgSvc.Timeout = new TimeSpan(, , );
WhoAmIRequest whoReq = new WhoAmIRequest();
var whoRsp = orgSvc.Execute(whoReq) as WhoAmIResponse;
var userEntity = orgSvc.Retrieve("systemuser", whoRsp.UserId, new Microsoft.Xrm.Sdk.Query.ColumnSet("fullname"));
Console.WriteLine(string.Format("欢迎【{0}】登陆到【{1}】", userEntity.GetAttributeValue<string>("fullname"), ConfigurationManager.AppSettings["orgUrl"]));
Console.WriteLine("本程序用于删除已经成功或者取消的系统作业！");
if (needConfirm == "Y")
{
Console.WriteLine("当前处于需要确认才会继续的模式，若要继续请输入Y然后回车确认！");
inputKey = Console.ReadLine();
if (inputKey.ToUpper() == "Y")
{
UpdateContactCountryCode(orgSvc);
}
else
{
Console.WriteLine("你选择了取消运行!");
}
}
else
{
UpdateContactCountryCode(orgSvc);
}
}
Console.Write("程序运行完成,按任意键退出." + DateTime.Now.ToString());
Console.ReadLine();
}
catch (Exception ex)
{
Console.WriteLine("程序运行出错：" + ex.Message + ex.StackTrace);
Console.ReadLine();
}
} private static void UpdateContactCountryCode(OrganizationServiceProxy orgSvc)
{
const string functionName = "删除已经成功或者取消的系统作业";
Console.WriteLine(string.Format("开始 {0} - {1}", functionName, DateTime.Now.ToString()));
try
{
var updateContactCountryCodeResult = ConfigurationManager.AppSettings["updateContactCountryCodeResult"]; string line = string.Empty;
var contactFetchxml = @"<fetch version='1.0' mapping='logical' distinct='false' no-lock='true'>
<entity name='asyncoperation'>
<attribute name='asyncoperationid' />
<filter type='and'>
<condition attribute='statuscode' operator='in'>
<value>32</value>
<value>30</value>
</condition>
</filter>
</entity>
</fetch>";
int pageNumber = ;
int fetchCount = ;
string pagingCookie = null;
orgSvc.Timeout = new TimeSpan(, , ); int j = ;
int i = ; ExecuteMultipleRequest multiReqs = new ExecuteMultipleRequest()
{
Settings = new ExecuteMultipleSettings()
{
ContinueOnError = true,
ReturnResponses = false
},
Requests = new OrganizationRequestCollection()
};
while (true)
{
string xml = CreateXml(contactFetchxml, pagingCookie, pageNumber, fetchCount);
RetrieveMultipleRequest pageRequest1 = new RetrieveMultipleRequest
{
Query = new FetchExpression(xml)
};
EntityCollection returnCollection = ((RetrieveMultipleResponse)orgSvc.Execute(pageRequest1)).EntityCollection;
int count = returnCollection.Entities.Count();
foreach (var item in returnCollection.Entities)
{
DeleteRequest req = new DeleteRequest();
req.Target = new EntityReference("asyncoperation", item.Id);
if (j <= )
{
multiReqs.Requests.Add(req);
}
else
{
multiReqs.Requests = new OrganizationRequestCollection();
multiReqs.Requests.Add(req);
j = ;
}
if (j == || i == count)
{
orgSvc.Execute(multiReqs);
}
j++;
i++; }
Console.WriteLine(string.Format("共{0}条处理完毕！{1}", pageNumber * fetchCount, DateTime.Now.ToString()));
if (returnCollection.MoreRecords)
{
pageNumber++;
pagingCookie = returnCollection.PagingCookie;
}
else
{
Console.WriteLine("最后一页");
break;
}
}
Console.WriteLine(string.Format("程序处理完成 {0}", updateContactCountryCodeResult));
}
catch (Exception ex)
{
Console.WriteLine(string.Format("运行 {0} 出现异常:{1}", functionName, ex.Message + ex.StackTrace));
}
Console.WriteLine(string.Format("结束 {0} - {1}", functionName, DateTime.Now.ToString()));
Console.WriteLine("================================================");
} private static TProxy GetProxy<TService, TProxy>(
IServiceManagement<TService> serviceManagement,
AuthenticationCredentials authCredentials)
where TService : class
where TProxy : ServiceProxy<TService>
{
Type classType = typeof(TProxy); if (serviceManagement.AuthenticationType !=
AuthenticationProviderType.ActiveDirectory)
{
AuthenticationCredentials tokenCredentials =
serviceManagement.Authenticate(authCredentials);
return (TProxy)classType
.GetConstructor(new Type[] { typeof(IServiceManagement<TService>), typeof(SecurityTokenResponse) })
.Invoke(new object[] { serviceManagement, tokenCredentials.SecurityTokenResponse });
}
return (TProxy)classType
.GetConstructor(new Type[] { typeof(IServiceManagement<TService>), typeof(ClientCredentials) })
.Invoke(new object[] { serviceManagement, authCredentials.ClientCredentials });
} public static string CreateXml(string xml, string cookie, int page, int count)
{
StringReader stringReader = new StringReader(xml);
XmlTextReader reader = new XmlTextReader(stringReader);
XmlDocument doc = new XmlDocument();
doc.Load(reader);
return CreateXml(doc, cookie, page, count);
} public static string CreateXml(XmlDocument doc, string cookie, int page, int count)
{
XmlAttributeCollection attrs = doc.DocumentElement.Attributes;
if (cookie != null)
{
XmlAttribute pagingAttr = doc.CreateAttribute("paging-cookie");
pagingAttr.Value = cookie;
attrs.Append(pagingAttr);
}
XmlAttribute pageAttr = doc.CreateAttribute("page");
pageAttr.Value = System.Convert.ToString(page);
attrs.Append(pageAttr);
XmlAttribute countAttr = doc.CreateAttribute("count");
countAttr.Value = System.Convert.ToString(count);
attrs.Append(countAttr);
StringBuilder sb = new StringBuilder();
StringWriter stringWriter = new StringWriter(sb);
XmlTextWriter writer = new XmlTextWriter(stringWriter);
doc.WriteTo(writer);
writer.Close();
return sb.ToString();
}
}
}
使用的配置文件示例：
<?xml version="1.0" encoding="utf-8" ?>
<configuration>
<startup>
<supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5.2" />
</startup>
<appSettings>
<add key="userName" value="luoyong\crmadmin" />
<add key="passWord" value="*******" />
<add key="orgUrl" value="https://demo.luoyong.me/XRMServices/2011/Organization.svc" />
</appSettings>
</configuration>