CSLA框架的codesmith模板改造

[Serializable]
    public class MultyDeleteCommand<T, C> : CommandBase<MultyDeleteCommand<T, C>>
        where T : BusinessBase<T>
        where C : IGeneratedCriteria, new()
    {
        #region Authorization Methods

        public static bool CanExecuteCommand()
        {
            return Csla.Rules.BusinessRules.HasPermission(Csla.Rules.AuthorizationActions.DeleteObject,
                 typeof(T));
        }

        #endregion

        #region Factory Methods

        public static bool Execute(IEnumerable<object> pkList)
        {
            if (!CanExecuteCommand())
                throw new System.Security.SecurityException("没有权限执行删除操作");

            MultyDeleteCommand<T, C> cmd = new MultyDeleteCommand<T, C>();
            cmd.PKList = pkList;
            cmd.BeforeServer();
            cmd = DataPortal.Execute<MultyDeleteCommand<T, C>>(cmd);
            cmd.AfterServer();
            return cmd.Result;
        }

        private MultyDeleteCommand()
        { /* require use of factory methods */ }

        #endregion

        #region Client-side Code


        public static readonly PropertyInfo<bool> ResultProperty = RegisterProperty<bool>(p => p.Result);
        public bool Result
        {
            get { return ReadProperty(ResultProperty); }
            set { LoadProperty(ResultProperty, value); }
        }

        public IEnumerable<object> PKList { get; set; }

        private void BeforeServer()
        {
            // TODO: implement code to run on client
            // before server is called
        }

        private void AfterServer()
        {
            // TODO: implement code to run on client
            // after server is called
        }

        #endregion

        #region Server-side Code

        protected override void DataPortal_Execute()
        {
            string temp = ""; string key = "";
            var criteria = new C();
            if (string.IsNullOrWhiteSpace(criteria.TableFullName) || string.IsNullOrWhiteSpace(criteria.PKName))
                throw new Exception("表名和主键名不能为空");

            SqlParameter[] parm = new SqlParameter[PKList.Count()]; //初始化参数个数
            for (int i = 0; i < PKList.Count(); i++)
            {
                key = "@StringId" + i.ToString();
                temp += key + ","; //将每个参数连接起来
                parm[i] = new SqlParameter(key, PKList.ElementAt(i));
            }
            temp = (temp + ")").Replace(",)", ""); //去掉最后一个逗号          

            string commandText = string.Format("DELETE {0} WHERE [{1}] IN ({2})",criteria.TableFullName, criteria.PKName, temp);
            if (!string.IsNullOrEmpty(criteria.SoftDeletedName))
                commandText = string.Format("UPDATE {0} SET [{1}]=1 WHERE [{2}] IN ({3})", criteria.TableFullName, criteria.SoftDeletedName, criteria.PKName, temp);

            using (var connection = new SqlConnection(ADOHelper.ConnectionString))
            {
                connection.Open();
                using (var command = new SqlCommand(commandText, connection))
                {
                    command.Parameters.AddRange(parm);

                    //result: The number of rows changed, inserted, or deleted. -1 for select statements; 0 if no rows were affected, or the statement failed. 
                    int result = command.ExecuteNonQuery();
                    if (result == 0)
                        throw new DBConcurrencyException("您提交的数据已过期，请刷新您的界面后重试.");
                    else
                        Result = true;
                }
            }

        }

        #endregion
    }