您的位置:首页 > 产品设计 > UI/UE

Dynamics 365使用Execute Multiple Request删除系统作业实体记录

2021-03-20 22:07 1226 查看

摘要: 本人微信公众号:微软动态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(8, 0, 0);
                    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 = 1;                int fetchCount = 5000;                string pagingCookie = null;
                orgSvc.Timeout = new TimeSpan(10, 0, 0);                int j = 1;                int i = 1;

                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 <= 500)
                        {
                            multiReqs.Requests.Add(req);
                        }                        else
                        {
                            multiReqs.Requests = new OrganizationRequestCollection();
                            multiReqs.Requests.Add(req);
                            j = 1;
                        }                        if (j == 500 || 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(1024);
            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>

 


内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: