DEMOMySql/MicroServices/Business/Buissness.UnitTest/CoreTestDataSeedContributor.cs


using Business.Core.Utilities;
using Bussiness.Model.MES.IC;
using Bussiness.Model.Production;
using Bussiness.Model.Sale;
using Bussiness.Model.SRM;
using Bussiness.Model.Tech;
using Microsoft.Extensions.Hosting;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Volo.Abp.Data;
using Volo.Abp.DependencyInjection;
using Volo.Abp.Domain.Repositories;
using Volo.Abp.MultiTenancy;

namespace Buissness.TestBase
{
    public class CoreTestDataSeedContributor : IDataSeedContributor, ITransientDependency
    {
        private readonly IRepository<ic_item, long> _mysql_ic_item;
        private readonly IRepository<ic_bom, long> _mysql_ic_bom;
        private readonly IRepository<ic_bom_child, long> _mysql_ic_bom_child;
        private readonly IRepository<mes_technique, long> _mysql_mes_technique;
        private readonly IRepository<crm_seorder, long> _mysql_crm_seorder;
        private readonly IRepository<crm_seorderentry, long> _mysql_crm_seorderentry;
        private readonly IRepository<ic_item_stock, long> _mysql_ic_item_stock;
        private readonly IRepository<ic_factory_details, long> _mysql_ic_factory_details;
        private readonly IRepository<mes_oorder, long> _mysql_mes_oorder;
        private readonly IRepository<srm_pr_main, long> _mysql_srm_pr_main;
        private readonly IRepository<mes_mooccupy, long> _mysql_mes_mooccupy;
        private readonly IRepository<mes_morder, long> _mysql_mes_morder;
        private readonly IRepository<mes_moentry, long> _mysql_mes_moentry;
        private readonly IRepository<mes_process, long> _mysql_mes_process;
        private readonly IRepository<mes_tech_process, long> _mysql_mes_tech_process;
        private readonly IRepository<srm_po_main, long> _mysql_srm_po_main;
        private readonly IRepository<srm_po_list, long> _mysql_srm_po_list;
        private readonly IRepository<srm_po_occupy, long> _mysql_srm_po_occupy;
        private readonly IRepository<srm_purchase, long> _mysql_srm_purchase;
        private readonly IRepository<ic_plan, long> _mysql_ic_plan;


        private readonly ICurrentTenant _currentTenant;

        public CoreTestDataSeedContributor(
            IRepository<ic_item, long> mysql_ic_item,
            IRepository<ic_bom, long> mysql_ic_bom,
            IRepository<ic_bom_child, long> mysql_ic_bom_child,
            IRepository<mes_technique, long> mysql_mes_technique,
            IRepository<crm_seorder, long> mysql_crm_seorder,
            IRepository<crm_seorderentry, long> mysql_crm_seorderentry,
            IRepository<ic_item_stock, long> mysql_ic_item_stock,
            IRepository<ic_factory_details, long> mysql_ic_factory_details,
            IRepository<mes_oorder, long> mysql_mes_oorder,
            IRepository<srm_pr_main, long> mysql_srm_pr_main,
            IRepository<mes_mooccupy, long> mysql_mes_mooccupy,
            IRepository<mes_morder, long> mysql_mes_morder,
            IRepository<mes_moentry, long> mysql_mes_moentry,
            IRepository<mes_process, long> mysql_mes_process,
            IRepository<mes_tech_process, long> mysql_mes_tech_process,
            IRepository<srm_po_main, long> mysql_srm_po_main,
            IRepository<srm_po_list, long> mysql_srm_po_list,
            IRepository<srm_po_occupy, long> mysql_srm_po_occupy,
            IRepository<srm_purchase, long> mysql_srm_purchase,
            IRepository<ic_plan, long> mysql_ic_plan,
        ICurrentTenant currentTenant)
        {
            _mysql_ic_item = mysql_ic_item;
            _mysql_ic_bom = mysql_ic_bom;
            _mysql_ic_bom_child = mysql_ic_bom_child;
            _mysql_mes_technique= mysql_mes_technique;
            _mysql_crm_seorder = mysql_crm_seorder;
            _mysql_crm_seorderentry = mysql_crm_seorderentry;
            _mysql_ic_item_stock = mysql_ic_item_stock;
            _mysql_ic_factory_details = mysql_ic_factory_details;
            _mysql_mes_oorder = mysql_mes_oorder;
            _mysql_srm_pr_main = mysql_srm_pr_main;
            _mysql_mes_mooccupy = mysql_mes_mooccupy;
            _mysql_mes_morder = mysql_mes_morder;
            _mysql_mes_moentry = mysql_mes_moentry;
            _mysql_mes_process= mysql_mes_process;
            _mysql_mes_tech_process= mysql_mes_tech_process;
            _mysql_srm_po_main = mysql_srm_po_main;
            _mysql_srm_po_list = mysql_srm_po_list;
            _mysql_srm_po_occupy = mysql_srm_po_occupy;
            _mysql_srm_purchase = mysql_srm_purchase;
            _mysql_ic_plan = mysql_ic_plan;
            _currentTenant = currentTenant;
        }

        public async Task SeedAsync(DataSeedContext context)
        {
            /* Seed additional test data... */
            using (_currentTenant.Change(context?.TenantId))
            {
                await Seedic_itemAsync();
                await Seedic_bomAsync();
                await Seedic_bom_childAsync();
                await Seedmes_techniqueAsync();

            }
        }


        private async Task Seedic_itemAsync()
        {
            await _mysql_ic_item.InsertAsync(new ic_item(new SnowFlake().NextId()) { factory_id=102, allowout=1});
        }

        private async Task Seedic_bomAsync()
        {
            await _mysql_ic_bom.InsertAsync(new ic_bom { factory_id=102,use_status=1});
        }

        public async Task Seedic_bom_childAsync()
        {
            await _mysql_ic_bom_child.InsertAsync(new ic_bom_child { factory_id=102, begin_day=DateTime.Now});
        }

        public async Task Seedmes_techniqueAsync()
        {
            await _mysql_mes_technique.InsertAsync(new mes_technique { factory_id=102, bom="1000"});
        }
    }
}