DEMOMySql/MicroServices/Business/Business.Application/SyncDataManagement/SyncMySQLDataAppService.cs

using Microsoft.EntityFrameworkCore;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Dynamic.Core;
using System.Threading.Tasks;
using Volo.Abp.Application.Dtos;
using Volo.Abp.Domain.Repositories;
using Business.Models;
using Microsoft.AspNetCore.Authorization;
using Business.Permissions;
using XCZ;
using Business.ResourceExamineManagement.Dto;
using Bussiness.Model.MES.IC;
using AutoMapper.Internal.Mappers;
using Bussiness.Model.Tech;
using Bussiness.Model.Production;
using Business.Core.MongoDBHelper;
using Business.Core.Utilities;
using Hangfire.Storage.Monitoring;
using Business.BookManagement.Dto;
using Volo.Abp.ObjectMapping;
using Volo.Abp.Application.Services;
using ZstdSharp.Unsafe;
using System.Transactions;
using NUglify.JavaScript.Syntax;
using System.Linq.Expressions;
using XCZ.Extensions;
using System.ComponentModel;
using System.Reflection.Emit;
using NUglify.Helpers;
using Microsoft.AspNetCore.SignalR.Protocol;
using System.ComponentModel.Design;
using Volo.Abp.Validation.StringValues;
using System.Runtime.CompilerServices;
using MongoDB.Driver;
using Volo.Abp.Validation.Localization;
using Hangfire.Annotations;
using System.Globalization;
using MongoDB.Driver.Linq;
using Bussiness.Model.SRM;
using System.ComponentModel.DataAnnotations;
using Bussiness.Model.Sale;
using Amazon.Runtime.Internal.Transform;
using System.IO.Compression;
using System.Collections;
using System.Data.SqlTypes;
using Bussiness.Model.SystemData;
using Bussiness.MongoModel.MES.IC;
using Bussiness.MongoModel.SystemData;
using Bussiness.MongoModel.Tech;
using Bussiness.Model.SIM;

namespace Business.SyncDataManagement
{
    /// <summary>
    /// 同步mysql数据到mongodb
    /// </summary>
    public class SyncMySQLDataAppService : ApplicationService
    {
        #region 服务
        /// <summary>
        /// 物料bom
        /// </summary>
        private readonly IMongoDB<mo_ic_bom> _ic_bom;
        private IRepository<ic_bom, long> _mysql_ic_bom;

        /// <summary>
        /// 物料bom子表
        /// </summary>
        private readonly IMongoDB<mo_ic_bom_child> _ic_bom_child;
        private IRepository<ic_bom_child, long> _mysql_ic_bom_child;

        /// <summary>
        /// 物料
        /// </summary>
        private readonly IMongoDB<mo_ic_item> _ic_item;
        private IRepository<ic_item, long> _mysql_ic_item;

        /// <summary>
        /// 替代群组
        /// </summary>
        private readonly IMongoDB<mo_ic_substitute> _ic_substitute;
        private IRepository<ic_substitute, long> _mysql_ic_substitute;

        /// <summary>
        /// 物料替代多群组
        /// </summary>
        private readonly IMongoDB<mo_ic_substitute_all> _ic_substitute_all;
        private IRepository<ic_substitute_all, long> _mysql_ic_substitute_all;

        /// <summary>
        /// 物料替代多群组明细
        /// </summary>
        private readonly IMongoDB<mo_ic_substitute_all_dtl> _ic_substitute_all_dtl;
        private IRepository<ic_substitute_all_dtl, long> _mysql_ic_substitute_all_dtl;

        /// <summary>
        /// 供应商
        /// </summary>
        private readonly IMongoDB<mo_srm_supplier> _srm_supplier;
        private IRepository<srm_supplier, long> _mysql_srm_supplier;

        /// <summary>
        /// 工艺路径
        /// </summary>
        private readonly IMongoDB<mo_mes_technique> _mes_technique;
        private IRepository<mes_technique, long> _mysql_mes_technique;

        /// <summary>
        /// 工序
        /// </summary>
        private readonly IMongoDB<mo_mes_process> _mes_process;
        private IRepository<mes_process, long> _mysql_mes_process;

        /// <summary>
        /// 工艺路径关联工序
        /// </summary>
        private readonly IMongoDB<mo_mes_tech_process> _mes_tech_process;
        private IRepository<mes_tech_process, long> _mysql_mes_tech_process;

        /// <summary>
        /// 物料采购计划表
        /// </summary>
        private readonly IMongoDB<mo_ic_plan> _ic_plan;
        private IRepository<ic_plan, long> _mysql_ic_plan;

        /// <summary>
        /// 物料工厂明细表
        /// </summary>
        private readonly IMongoDB<mo_ic_factory_details> _ic_factory_details;
        private IRepository<ic_factory_details, long> _mysql_ic_factory_details;

        /// <summary>
        /// 物料采购报价单
        /// </summary>
        private readonly IMongoDB<mo_ic_item_pur> _ic_item_pur;
        private IRepository<ic_item_pur, long> _mysql_ic_item_pur;

        /// <summary>
        /// 雪花算法
        /// </summary>
        SnowFlake help = new SnowFlake();
        #endregion

        /// <summary>
        /// 构造函数
        /// </summary>
        public SyncMySQLDataAppService(
            IMongoDB<mo_ic_bom> ic_bom,
            IMongoDB<mo_ic_bom_child> ic_bom_child,
            IMongoDB<mo_ic_item> ic_item,
            IMongoDB<mo_ic_substitute> ic_substitute,
            IMongoDB<mo_ic_substitute_all> ic_substitute_all,
            IMongoDB<mo_ic_substitute_all_dtl> ic_substitute_all_dtl,
            IMongoDB<mo_srm_supplier> srm_supplier,
            IMongoDB<mo_mes_technique> mes_technique,
            IMongoDB<mo_mes_process> mes_process,
            IMongoDB<mo_mes_tech_process> mes_tech_process,
            IMongoDB<mo_ic_factory_details> ic_factory_details,
            IMongoDB<mo_ic_item_pur> ic_item_pur,
            IMongoDB<mo_ic_plan> ic_plan,
            IRepository<ic_bom, long> mysql_ic_bom,
            IRepository<ic_bom_child, long> mysql_ic_bom_child,
            IRepository<ic_item, long> mysql_ic_item,
            IRepository<ic_substitute, long> mysql_ic_substitute,
            IRepository<ic_substitute_all, long> mysql_ic_substitute_all,
            IRepository<ic_substitute_all_dtl, long> mysql_ic_substitute_all_dtl,
            IRepository<srm_supplier, long> mysql_srm_supplier,
            IRepository<mes_technique, long> mysql_mes_technique,
            IRepository<mes_process, long> mysql_mes_process,
            IRepository<mes_tech_process, long> mysql_mes_tech_process,
            IRepository<ic_factory_details, long> mysql_ic_factory_details,
            IRepository<ic_item_pur, long> mysql_ic_item_pur,
            IRepository<ic_plan, long> mysql_ic_plan
            )
        {
            _ic_bom= ic_bom;
            _ic_bom_child= ic_bom_child;
            _ic_item= ic_item;
            _ic_substitute= ic_substitute;
            _ic_substitute_all= ic_substitute_all;
            _ic_substitute_all_dtl= ic_substitute_all_dtl;
            _srm_supplier= srm_supplier;
            _mes_technique = mes_technique;
            _mes_process= mes_process;
            _mes_tech_process = mes_tech_process;
            _ic_factory_details = ic_factory_details;
            _ic_item_pur = ic_item_pur;
            _ic_plan = ic_plan;
            _mysql_ic_bom = mysql_ic_bom;
            _mysql_ic_bom_child= mysql_ic_bom_child;
            _mysql_ic_item= mysql_ic_item;
            _mysql_ic_substitute= mysql_ic_substitute;
            _mysql_ic_substitute_all= mysql_ic_substitute_all;
            _mysql_ic_substitute_all_dtl= mysql_ic_substitute_all_dtl;
            _mysql_srm_supplier= mysql_srm_supplier;
            _mysql_mes_technique= mysql_mes_technique;
            _mysql_mes_process= mysql_mes_process;
            _mysql_mes_tech_process= mysql_mes_tech_process;
            _mysql_ic_factory_details = mysql_ic_factory_details;
            _mysql_ic_item_pur = mysql_ic_item_pur;
            _mysql_ic_plan = mysql_ic_plan;
        }

        /// <summary>
        /// 同步基础数据到mongodb
        /// </summary>
        /// <returns></returns>
        /// <exception cref="NotImplementedException"></exception>
        public void SyncBaseDataToMongoDB()
        {
            //同步物料Bom数据
            var icBoms =  _mysql_ic_bom.GetListAsync().Result;
            if (icBoms.Count > 0)
            {
                //先清空表数据
                 _ic_bom.Delete(p=>p.mysql_id != -1);
                var moIcBoms = ObjectMapper.Map<List<ic_bom>, List<mo_ic_bom>>(icBoms);
                moIcBoms.ForEach(s => s.id = help.NextId());
                //插入数据
                 _ic_bom.InsertMany(moIcBoms);
            }

            //同步物料BOM明细数据
            var icbom_childs =  _mysql_ic_bom_child.GetListAsync().Result;
            if (icbom_childs.Count > 0)
            {
                //先清空表数据
                 _ic_bom_child.Delete(p => p.mysql_id != -1);
                var moIcbom_childs = ObjectMapper.Map<List<ic_bom_child>, List<mo_ic_bom_child>>(icbom_childs);
                moIcbom_childs.ForEach(s => s.id = help.NextId());
                //插入数据
                _ic_bom_child.InsertMany(moIcbom_childs);
            }

            //同步物料数据
            var icItems =  _mysql_ic_item.GetListAsync().Result;
            if (icItems.Count > 0)
            {
                //先清空表数据
                 _ic_item.Delete(p => p.mysql_id != -1);
                var moIcItems = ObjectMapper.Map<List<ic_item>, List<mo_ic_item>>(icItems);
                moIcItems.ForEach(s => s.id = help.NextId());
                //插入数据
                _ic_item.InsertMany(moIcItems);
            }

            //同步替代群组数据
            var subtitutes =  _mysql_ic_substitute.GetListAsync().Result;
            if (subtitutes.Count > 0)
            {
                //先清空表数据
                 _ic_substitute.Delete(p => p.mysql_id != -1);
                var moSubtitutes = ObjectMapper.Map<List<ic_substitute>, List<mo_ic_substitute>>(subtitutes);
                moSubtitutes.ForEach(s => s.id = help.NextId());
                //插入数据
                _ic_substitute.InsertMany(moSubtitutes);
            }

            //同步物料替代多群组数据
            var subAlls =  _mysql_ic_substitute_all.GetListAsync().Result;
            if (subAlls.Count > 0)
            {
                //先清空表数据
                 _ic_substitute_all.Delete(p => p.mysql_id != -1);
                var moSubAlls = ObjectMapper.Map<List<ic_substitute_all>, List<mo_ic_substitute_all>>(subAlls);
                moSubAlls.ForEach(s => s.id = help.NextId());
                //插入数据
                _ic_substitute_all.InsertMany(moSubAlls);
            }

            //同步物料替代多群组明细数据
            var subAllDtls =  _mysql_ic_substitute_all_dtl.GetListAsync().Result;
            if (subAllDtls.Count > 0)
            {
                //先清空表数据
                 _ic_substitute_all_dtl.Delete(p => p.mysql_id != -1);
                var moSubAllDtls = ObjectMapper.Map<List<ic_substitute_all_dtl>, List<mo_ic_substitute_all_dtl>>(subAllDtls);
                moSubAllDtls.ForEach(s => s.id = help.NextId());
                //插入数据
                _ic_substitute_all_dtl.InsertMany(moSubAllDtls);
            }

            //同步供应商数据
            var suppliers =  _mysql_srm_supplier.GetListAsync().Result;
            if (suppliers.Count > 0)
            {
                //先清空表数据
                 _srm_supplier.Delete(p => p.mysql_id != -1);
                var moSuppliers = ObjectMapper.Map<List<srm_supplier>, List<mo_srm_supplier>>(suppliers);
                moSuppliers.ForEach(s => s.id = help.NextId());
                //插入数据
                _srm_supplier.InsertMany(moSuppliers);
            }

            //同步工艺路径数据
            var techs =  _mysql_mes_technique.GetListAsync().Result;
            if (techs.Count > 0)
            {
                //先清空表数据
                 _mes_technique.Delete(p => p.mysql_id != -1);
                var moTechs = ObjectMapper.Map<List<mes_technique>, List<mo_mes_technique>>(techs);
                moTechs.ForEach(s => s.id = help.NextId());
                //插入数据
                _mes_technique.InsertMany(moTechs);
            }

            //同步工序数据
            var processes =  _mysql_mes_process.GetListAsync().Result;
            if (suppliers.Count > 0)
            {
                //先清空表数据
                 _mes_process.Delete(p => p.mysql_id != -1);
                var moProcesses = ObjectMapper.Map<List<mes_process>, List<mo_mes_process>>(processes);
                moProcesses.ForEach(s => s.id = help.NextId());
                //插入数据
                _mes_process.InsertMany(moProcesses);
            }

            //同步工艺关联工序数据
            var tech_procs =  _mysql_mes_tech_process.GetListAsync().Result;
            if (tech_procs.Count > 0)
            {
                //先清空表数据
                 _mes_tech_process.Delete(p => p.mysql_id != -1);
                var moTech_procs = ObjectMapper.Map<List<mes_tech_process>, List<mo_mes_tech_process>>(tech_procs);
                moTech_procs.ForEach(s => s.id = help.NextId());
                //插入数据
                _mes_tech_process.InsertMany(moTech_procs);
            }

            //工厂物料明细表
            var ic_factory_details = _mysql_ic_factory_details.GetListAsync().Result;
            if (ic_factory_details.Count > 0)
            {
                //先清空表数据
                _ic_factory_details.Delete(p => p.mysql_id != -1);
                var moIc_factory_details = ObjectMapper.Map<List<ic_factory_details>, List<mo_ic_factory_details>>(ic_factory_details);
                moIc_factory_details.ForEach(s => s.id = help.NextId());
                _ic_factory_details.InsertMany(moIc_factory_details);
            }

            //物料采购计划表
            var ic_plan = _mysql_ic_plan.GetListAsync().Result;
            if (ic_plan.Count > 0)
            {
                //先清空表数据
                _ic_plan.Delete(p => p.mysql_id != -1);
                var moIc_plan = ObjectMapper.Map<List<ic_plan>, List<mo_ic_plan>>(ic_plan);
                moIc_plan.ForEach(s => s.id = help.NextId());
                _ic_plan.InsertMany(moIc_plan);
            }

            //物料采购报价单
            var ic_item_pur = _mysql_ic_item_pur.GetListAsync().Result;
            if (ic_item_pur.Count > 0)
            {
                //先清空表数据
                _ic_item_pur.Delete(p => p.mysql_id != -1);
                var moIc_item_pur = ObjectMapper.Map<List<ic_item_pur>, List<mo_ic_item_pur>>(ic_item_pur);
                moIc_item_pur.ForEach(s => s.id = help.NextId());
                _ic_item_pur.InsertMany(moIc_item_pur);
            }
        }
    }
}