new_mdk/CZKJ.MongoDB/Interface/Initiator.cs

using CZFW.Framework.Model.ViewModel;
using System;
using System.IO;

namespace CZFW.MDB
{
    public class Initiator : IInit
    {
        public Initiator(IMongoRepository _rep, ISchemaRepository schemaRepository)
        {
            repository = _rep;
            _schemaRepository = schemaRepository;
        }

        private IMongoRepository repository;
        public IMongoRepository Repository { get { return repository; } set { repository = value; } }
        ISchemaRepository _schemaRepository;
        string _webRoot;

        public void InitAdmin()
        {
            string adminUser = File.ReadAllText(_webRoot + "/InitData/admin_user.json");
            _schemaRepository.Create(null,adminUser);
            string adminUserObj = File.ReadAllText(_webRoot + "/InitData/sys_admin.json");
            repository.SetCurrentTable("admin_user");
            var res = repository.Insert(adminUserObj);
        }

        public void InitAll(string webRoot)
        {
            _webRoot = webRoot;
            InitSchema();
            InitSysConfig();
            InitNavigation();
            InitAdmin();
            InitSeoShare();
        }

        public void InitDB()
        {
           // repository.AsureTableExist("");
        }

        public void InitNavigation()
        {
            string json = File.ReadAllText(_webRoot + "/InitData/sys_nav.json");
            _schemaRepository.Create(null,json);
        }
        public void InitSysConfig()
        {
            string json = File.ReadAllText(_webRoot + "/InitData/sys_config.json");
            _schemaRepository.Create(null,json);
        }
        public void InitSeoShare()
        {
            string json = File.ReadAllText(_webRoot + "/InitData/seo_share.json");
            _schemaRepository.Create(null,json);
        }

        public void InitSchema()
        {
            repository.AsureTableExist("schema");
        }

      
    }
}