CQRS学习——一个例子（其六）

public class BookController : DpfbMvcController
    {
        public ActionResult List(int size = 10, int index = 1)
        {
            throw new NotImplementedException();
        }

        [Authorize]
        public ActionResult Add()
        {
            return View();
        }

        [Authorize]
        [HttpPost]
        public ActionResult Add(BookAddViewModel model)
        {
            throw new NotImplementedException();
        }
    }

namespace SI.Cqrs.Models.AggreateRoots
{
    public class Book : AggregateRoot
    {
        public string Name { get; set; }
        public decimal Price { get; set; }
    }
}

 public class BookHandler:ICommandHandler<DpfbItemInsertCommand<Book>>
    {
        [Dependency]
        internal IBookReponsitory BookReponsitory { get; set; }

        void ICommandHandler<DpfbItemInsertCommand<Book>>.Execute(DpfbItemInsertCommand<Book> command)
        {
            BookReponsitory.Insert(command.AggregateRoot);
        }
    }

public class BookController : DpfbMvcController
    {
        [Dependency]
        internal IBookQueryEntry BookQueryEntry { get; set; }

        public ActionResult List(int size = 10, int index = 1)
        {
            var pageInfo = new PageInfo(size, index);
            var result = BookQueryEntry.Page(i => i.Name, pageInfo);
            return View(result);
        }

        [Authorize]
        public ActionResult Add()
        {
            return View();
        }

        [Authorize]
        [HttpPost]
        public ActionResult Add(BookAddViewModel model)
        {
            var book = new Book {Name = model.Name, Price = model.Price};
            var command = new DpfbItemInsertCommand<Book> {AggregateRoot = book};
            CommandBus.Send(command);
            return Redirect("List");
        }
    }

public class BookReponsitory : SoftDeleteEntityFrameworkReponsitory<Book>, IBookReponsitory
    {

    }

public class BookQueryEntry : ReponsitoryBasedQueryEntry<Book>, IBookQueryEntry
    {
        public override IBasicReponsitory<Book> BasicReponsitory
        {
            get { return BookReponsitory; }
        }

        [Dependency]
        internal IBookReponsitory BookReponsitory { get; set; }
    }

public class BookMap:TableMap<Book>
    {
        public BookMap()
        {
            /*为Name创建唯一索引*/
            Property(i => i.Name).IsRequired()
                .HasColumnAnnotation(IndexAnnotation.AnnotationName,
                    new IndexAttribute("IU_UserName", 1) {IsUnique = true})
                .HasMaxLength(100);
        }
    }

public class SocialInsuranceContext : DbContext
    {
        public SocialInsuranceContext()
            : base("name=SocialInsuranceContext")
        {

        }

        public DbSet<User> Users { get; set; }

        protected override void OnModelCreating(DbModelBuilder modelBuilder)
        {
            base.OnModelCreating(modelBuilder);
            modelBuilder.Configurations.Add(new UserMap());
            modelBuilder.Configurations.Add(new BookMap());
        }
    }

PM> Add-Migration Initial_Database
Scaffolding migration ‘Initial_Database‘.
The Designer Code for this migration file includes a snapshot of your current Code First model. This snapshot is used to calculate the changes to your model when you scaffold the next migration. If you make additional changes to your model that you want to include in this migration, then you can re-scaffold it by running ‘Add-Migration Initial_Database‘ again.
PM> Update-Database
Specify the ‘-Verbose‘ flag to view the SQL statements being applied to the target database.
Applying explicit migrations: [201510300844286_Initial_Database].
Applying explicit migration: 201510300844286_Initial_Database.
Running Seed method.
PM>