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;
        #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,
            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
            )
        {
            _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;
            _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;
        }

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

            //同步物料BOM明细数据
            var icbom_childs = await _mysql_ic_bom_child.GetListAsync();
            if (icbom_childs.Count > 0)
            {
                //先清空表数据
                await _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);
                //插入数据
                await _ic_bom_child.InsertMany(moIcbom_childs);
            }

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

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

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

            //同步物料替代多群组明细数据
            var subAllDtls = await _mysql_ic_substitute_all_dtl.GetListAsync();
            if (subAllDtls.Count > 0)
            {
                //先清空表数据
                await _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);
                //插入数据
                await _ic_substitute_all_dtl.InsertMany(moSubAllDtls);
            }

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

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

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

            //同步工艺关联工序数据
            var tech_procs = await _mysql_mes_tech_process.GetListAsync();
            if (tech_procs.Count > 0)
            {
                //先清空表数据
                await _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);
                //插入数据
                await _mes_tech_process.InsertMany(moTech_procs);
            }
        }
    }
}