改 EXCEL报文导入

src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Domain/EdiReceive/Services/EdiParseDomainService.cs

@@ -0,0 +1,419 @@
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Logging;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Volo.Abp;
+using Volo.Abp.Domain.Repositories;
+using Volo.Abp.Domain.Services;
+using WY.NewJit.EdiReceive.Entitys;
+using WY.NewJit.IRepositories;
+using WY.NewJit.MsgBaseData;
+using WY.NewJit.MsgCheck;
+using WY.NewJit.Common;
+using WY.NewJit.MsgBaseData.Entitys;
+
+namespace WY.NewJit.EdiReceive.Services
+{
+    /// <summary>
+    /// 红旗报文接收
+    /// </summary>
+    public class EdiParseDomainService : DomainService
+    {
+        #region 成员
+        /// <summary>
+        /// 日志
+        /// </summary>
+        private readonly ILogger<EdiParseDomainService> _logger;
+
+        /// <summary>
+        /// Dapper仓储
+        /// </summary>
+        private readonly INewJitDapperRepository _newJitDapperRepository;
+
+        /// <summary>
+        /// 字典领域服务
+        /// </summary>
+        private readonly DicDomainService _dicDomainService;
+
+        /// <summary>
+        /// 零件仓储
+        /// </summary>
+        private readonly IRepository<ImportRecord, Guid> _importRecordRepository;
+
+        /// <summary>
+        /// M100单据
+        /// </summary>
+        private readonly IRepository<BillM100, Guid> _billM100Repository;
+
+        /// <summary>
+        /// ERP总成分组仓库
+        /// </summary>
+        private readonly IRepository<AssemblyCfgGroup, Guid> _assemblyCfgGroupRepository;
+
+        /// <summary>
+        /// ERP总成仓储
+        /// </summary>
+        private readonly IRepository<AssemblyCfgErp, Guid> _assemblyCfgErpRepository;
+
+        /// <summary>
+        /// 整车总成配置仓库
+        /// </summary>
+        private readonly IRepository<AssemblyCfgVehicle, Guid> _assemblyCfgVehicleRepository;
+
+
+        private readonly LastImportHostSNDomainService _lastImportHostSNDomainService;
+
+        private readonly HQ_CacheManagerDomainService _hqCacheManagerDomainService;
+
+        private readonly HQ_M100DomainService _hqM100DomainServie;
+
+        /// <summary>
+        /// 重复M100
+        /// </summary>
+        private readonly IRepository<RepeatM100, Guid> _repeatM100Repository;
+
+        /// <summary>
+        /// 未知总成维护
+        /// </summary>
+        private readonly IRepository<UnknownAssembly, Guid> _unknownAssemblyRepository;
+
+
+        /// <summary>
+        /// 报文车型对应零件生产工厂车型
+        /// </summary>
+        private static List<DicItem> _msgToPaiGeVehicleModelList = new List<DicItem>();
+
+        /// <summary>
+        /// M100零件生产工厂车型对应生产线
+        /// </summary>
+        private static List<DicItem> _m100VehicleModelProductLineList = new List<DicItem>();
+
+        /// <summary>
+        /// 根据车型代码中的前两位（HS），过滤属于派格的订单；只针对派格的订单进行报文解析
+        /// </summary>
+        private const string _vehicleModelPrefix = "HS";
+
+        /// <summary>
+        /// 错误信息前缀
+        /// </summary>
+        private string _errorMessagePrefix
+        {
+            get
+            {
+                return System.Reflection.MethodBase.GetCurrentMethod().DeclaringType.Name + ".";
+            }
+        }
+
+
+        #endregion
+        public EdiParseDomainService(ILogger<EdiParseDomainService> logger, INewJitDapperRepository newJitDapperRepository, DicDomainService dicDomainService, IRepository<ImportRecord, Guid> importRecordRepository, IRepository<BillM100, Guid> billM100Repository, LastImportHostSNDomainService lastImportHostSNDomainService, IRepository<AssemblyCfgGroup, Guid> assemblyCfgGroupRepository = null, IRepository<AssemblyCfgErp, Guid> assemblyCfgErpRepository = null, IRepository<AssemblyCfgVehicle, Guid> assemblyCfgVehicleRepository = null, HQ_CacheManagerDomainService hqCacheManagerDomainService = null, HQ_M100DomainService hqM100DomainServie = null, IRepository<RepeatM100, Guid> repeatM100Repository = null, IRepository<UnknownAssembly, Guid> unknownAssemblyRepository = null)
+        {
+            _logger = logger;
+            _newJitDapperRepository = newJitDapperRepository;
+            _dicDomainService = dicDomainService;
+            _importRecordRepository = importRecordRepository;
+            _billM100Repository = billM100Repository;
+            _lastImportHostSNDomainService = lastImportHostSNDomainService;
+
+            _msgToPaiGeVehicleModelList = _dicDomainService.GetDicItems(DicTypeName.报文车型对应派格车型);
+            _m100VehicleModelProductLineList = _dicDomainService.GetDicItems(DicTypeName.M100派格车型对应生产线);
+            _assemblyCfgGroupRepository = assemblyCfgGroupRepository;
+            _assemblyCfgErpRepository = assemblyCfgErpRepository;
+            _assemblyCfgVehicleRepository = assemblyCfgVehicleRepository;
+
+            _hqCacheManagerDomainService = hqCacheManagerDomainService;
+            _hqM100DomainServie = hqM100DomainServie;
+            _repeatM100Repository = repeatM100Repository;
+            _unknownAssemblyRepository = unknownAssemblyRepository;
+        }
+
+        /// <summary>
+        /// 解析报文
+        /// </summary>
+        /// <param name="impRecLst"></param>
+        public async Task<ObjectResultDto> ParseEdi(List<ImportRecord> input, bool forceExecute = false)
+        {
+            ObjectResultDto ret = new ObjectResultDto();
+            //取本次导入的最小HostSN
+            int minHostSN = input.Min(itm => itm.HostSN);
+            //上次导入的最大HostSN
+            int lastHostSN = await _lastImportHostSNDomainService.GetLastImportHostSN();
+            string betweenBreakNumMsg = "";
+            if (minHostSN <= lastHostSN + 1)
+            {
+            }
+            else
+            {
+                if (forceExecute == false)
+                {
+                    //两次导入断号提醒
+                    betweenBreakNumMsg = $"两次导入断号提醒：本次导入的最小流水号是：{minHostSN}，上次导入的最大流水号是：{lastHostSN}";
+                }
+            }
+            //扣除重复导入的订单
+            List<ImportRecord> notRepeatOrder = await GetNotRepeatOrder(input);
+
+            #region 断号提醒
+            string breakNumMsg = "";
+            notRepeatOrder = notRepeatOrder.OrderBy(itm => itm.HostSN).ToList();
+            for (int curIdx = 1; curIdx < notRepeatOrder.Count; curIdx++)
+            {
+                int curVal = notRepeatOrder[curIdx].HostSN;
+                int priorIdx = curIdx - 1;
+                int priorVal = notRepeatOrder[priorIdx].HostSN;
+                if (curVal - priorVal != 1)
+                {
+                    breakNumMsg += $"流水号{priorVal}和{curVal}之间存在断号\r\n";
+                }
+            }
+            if (betweenBreakNumMsg.HasValue() || breakNumMsg.HasValue())
+            {
+                if (forceExecute == false)
+                {
+                    //断号提醒
+                    ret.Status = true;
+                    ret.Message = betweenBreakNumMsg + breakNumMsg;
+                    return ret;
+                }
+            }
+            #endregion 
+            //批量插入 导入记录
+            await _importRecordRepository.InsertManyAsync(notRepeatOrder);
+
+            //初始化缓存
+            _hqCacheManagerDomainService.InitLoadCache();
+
+            //过滤掉其它订单，只取派格订单
+            var paigeOrderLst =  notRepeatOrder.Where(itm => itm.VehicleModelCode.Substring(0, 2) == _vehicleModelPrefix).OrderBy(itm => itm.HostSN).ToList();
+            foreach (ImportRecord orderItem in paigeOrderLst)
+            {
+                #region 构建M100实体
+                BillM100 m100Obj = new BillM100(GuidGenerator.Create());
+                m100Obj.MessageFileReceiveID = orderItem.Id;
+                m100Obj.SerialNum = ServerHelper.VinToSN(orderItem.Vin);
+                m100Obj.SerialNumStr = ServerHelper.ToSerialNumStr(orderItem.OnlineTime, orderItem.HostSN);
+                m100Obj.HostSN = orderItem.HostSN;
+                m100Obj.HostSN2 = orderItem.HostSN; //流水号
+                m100Obj.KNR = orderItem.VehicleBodyCode;
+                m100Obj.VIN = orderItem.Vin;
+                m100Obj.AssemblyID = null;
+                m100Obj.OnlineTime = orderItem.OnlineTime;
+                m100Obj.VehicleModelCode = orderItem.VehicleBodyCode;
+                m100Obj.ProductLine = "";
+                m100Obj.Version = "";
+                m100Obj.ReceiveTime = ServerHelper.CurrentDateTime;
+                m100Obj.BillStatus = BillStatusEnum.NotMatch;
+                m100Obj.Description = "";
+                //m100Obj.OperationType = operationType;
+                //m100Obj.Operator = @operator;
+                //m100Obj.OperationTime = operationTime;
+                m100Obj.CanNotPrint = false;
+                m100Obj.NeedReplenishPrint = 0;
+                m100Obj.IsPartSwitch = false;
+                #endregion
+
+                UpdateProductLine(m100Obj);
+                string snStr = ServerHelper.ToSerialNumStr(m100Obj.OnlineTime, m100Obj.HostSN);
+                m100Obj.SetSerialNumStr(snStr);
+
+                //重复报文
+                bool isRepeat = _billM100Repository.Any(itm => itm.HostSN == orderItem.HostSN && itm.VIN == orderItem.Vin);
+                if (isRepeat == true)
+                {
+                    #region 重复报文
+                    var succObj = InsertM100RepeatBill(orderItem, m100Obj);
+                    _logger.LogDebug(_errorMessagePrefix + $"流水号{orderItem.HostSN}是重复报文");
+                    ret.Status = (succObj != null);
+                    return ret;
+                    #endregion
+                }
+
+                //绑定总成分组
+                string colorExplain = orderItem.VehicleModelDesc.Trim().Right(7);
+
+                Group_Assembly groupAssemblyObj = HQ_CacheManagerDomainService._groupAssemblyList.FirstOrDefault(itm => itm.SpecExplain == orderItem.SpecDesc && itm.ColorExplain == colorExplain);
+                if (groupAssemblyObj != null)
+                {
+                    #region 插入整车总成
+                    Guid vehicleAssemblyId = GuidGenerator.Create();
+                    AssemblyCfgVehicle vehicleAssemblyCfgObj = new AssemblyCfgVehicle(vehicleAssemblyId, null, "", null, true);
+                    foreach (OnlyAssemblyInfo assemblyItem in groupAssemblyObj.AssemblyDetails) //插入子表
+                    {
+                        vehicleAssemblyCfgObj.AddChildObj(GuidGenerator.Create(), assemblyItem.Id);
+                    }
+                    var vehicleAssemblyResu = await _assemblyCfgVehicleRepository.InsertAsync(vehicleAssemblyCfgObj, true);
+                    if (vehicleAssemblyResu == null)
+                    {
+                        throw new Exception("插入整车总成返回结果为空InsertAsync！");
+                    }
+                    #endregion
+
+                    //插入M100、未打印表
+                    m100Obj.SetAssemblyID(vehicleAssemblyResu.Id);
+                    var insM100Ret = await _hqM100DomainServie.InsertM100(m100Obj, true);
+                }
+                else
+                {
+                    //未知总成
+                    _logger.LogDebug(_errorMessagePrefix + $"未匹配总成，插入未知总成开始：{orderItem.HostSN}");
+                    //更新单据表
+                    m100Obj.SetAssemblyID(null);
+                    m100Obj.SetBillStatus(BillStatusEnum.NotMatch);
+                    var succObj1 = await _hqM100DomainServie.InsertM100(m100Obj, true);
+
+                    //不匹配时，插入未知总成
+                    var succObj2 = await InsertUnknownAssembly(m100Obj);
+                    _logger.LogDebug(_errorMessagePrefix + $"未匹配总成，插入未知总成完成：{orderItem.HostSN}");
+                    ret.Status = (succObj1 != null && succObj2 != null);
+                }
+
+            }
+
+            /*
+            一、导入记录表
+                1. 从客户网站导出EXCEL格式的订单列表
+                2. 校验  本次导入的最小HostSN必须<= 上次导入的最大HostSN + 1 （上次是10， 本次可以是 9 10 11，不能是12）
+                3. 根据VIN和HostSN，扣除重复导入的记录
+                4. 断号提醒：导入Excel时，如果系统中的流水号不能顺序连接，需要给出提醒，是否继续导入，如果选择继续导入，仍可以导入到系统中
+                5. 最后导入到本系统中 impRecLst
+
+            二、插入M100
+            1. 根据车型代码中的前两位（HS），过滤属于派格的订单；只针对派格的订单进行报文解析
+            2. 根据VIN判断是否重复报文，将重复报文放到“重复报文表”
+            3. 通过车型描述中的颜色（条件一）和规格说明（条件二）两个字段能够定位到该底盘对应哪个总成组（4个总成一组）。如果匹配将订单和总成组进行绑定；如果不匹配将订单放入未知总成
+            4. 插入M100 (更新派格车型、 生产线)
+            5. 插入WaitPrint
+             */
+            ret.Status = true;
+            return ret;
+        }
+
+        /// <summary>
+        /// 根据流水号、VIN  扣除重复导入的订单
+        /// </summary>
+        /// <param name="input"></param>
+        /// <returns></returns>
+        private async Task<List<ImportRecord>> GetNotRepeatOrder(List<ImportRecord> input)
+        {
+            List<ImportRecord> notRepeatLst = new List<ImportRecord>();
+
+            List<ImportRecord> importHistoryLst = await _importRecordRepository.AsQueryable()
+                .OrderBy(itm => itm.HostSN)
+                .TakeLast(10000)
+                .ToListAsync();
+            foreach (ImportRecord item in input)
+            {
+                bool hasData = importHistoryLst.Any(itm => itm.HostSN == item.HostSN && itm.Vin == item.Vin);
+                if (hasData)
+                {
+                }
+                else
+                {
+                    notRepeatLst.Add(item);
+                }
+            }
+            return notRepeatLst;
+        }
+
+        /// <summary>
+        /// 更新车型、生产线
+        /// </summary>
+        /// <param name="billResObj"></param>
+        private void UpdateProductLine(BillM100 bill)
+        {
+            string ediVehicleModel = bill.VehicleModelCode; //报文车型
+            //车型转换：3H 转 CC
+            var obj1 = _msgToPaiGeVehicleModelList.FirstOrDefault(itm => itm.DicItemCode == ediVehicleModel);
+            if (obj1 != null)
+            {
+                string paigeVehicleModel = obj1.DicItemName; // CC
+                if (paigeVehicleModel.Contains('-')) //去掉B8L-PHEV中的-PHEV
+                {
+                    paigeVehicleModel = paigeVehicleModel.Split('-')[0];
+                }
+                bill.SetVehicleModelCode(paigeVehicleModel);
+                //根据车型取对应生产线
+                var obj2 = _m100VehicleModelProductLineList.FirstOrDefault(itm => itm.DicItemCode == paigeVehicleModel);
+                if (obj2 != null)
+                {
+                    string productLine = obj2.DicItemName;
+                    bill.SetProductLine(productLine);
+                }
+                else
+                {
+                    string errorMsg = $"零件生产工厂车型{paigeVehicleModel}没有对应的生产线！";
+                    _logger.LogError(errorMsg);
+                }
+            }
+            else //报文车型 没有对应的 派格车型
+            {
+                string errorMsg = $"报文车型{ediVehicleModel}没有对应的零件生产工厂车型！";
+                _logger.LogError(errorMsg);
+            }
+        }
+
+        private RepeatM100 InsertM100RepeatBill(ImportRecord impordRec, BillM100 m100Bill) //, int? maxSerialNum
+        {
+            RepeatM100 ret = null;
+            int newSN = ServerHelper.VinToSN(m100Bill.VIN);
+            RepeatM100 repeatBill = new RepeatM100(
+                GuidGenerator.Create(),
+                impordRec.Id,
+                newSN,
+                m100Bill.HostSN,
+                m100Bill.KNR,
+                m100Bill.VIN,
+                null,
+                m100Bill.OnlineTime,
+                ServerHelper.CurrentDateTime,
+                m100Bill.VehicleModelCode,
+                m100Bill.ProductLine,
+                ((DateTime)m100Bill.OnlineTime).ToString("yyyyMM"),
+                BillStatusEnum.None
+                );
+
+            //零件子表赋值
+            foreach (BillM100Part m100Part in m100Bill.BillM100Parts)
+            {
+                repeatBill.AddChildObj(GuidGenerator.Create(), m100Part.PartCode, m100Part.PartNum, m100Part.Description);
+            }
+            //插入重复单据
+            ret = _repeatM100Repository.InsertAsync(repeatBill, true).GetAwaiter().GetResult();
+            return ret;
+        }
+
+        /// <summary>
+        /// 不匹配时，插入未知总成，写提醒日志
+        /// </summary>
+        /// <param name="bill"></param>
+        private async Task<UnknownAssembly> InsertUnknownAssembly(BillM100 bill)
+        {
+            UnknownAssembly ret = null;
+            try
+            {
+                //插入未知总成
+                UnknownAssembly unknownAssemblyObj = new UnknownAssembly(GuidGenerator.Create(), bill.Id, "M100");
+                //预批量赋值
+                unknownAssemblyObj.Description = bill.Description; //描述字段保存预批量信息
+
+                //foreach (BillM100Part billPart in bill.BillM100Parts)
+                //{
+                //    unknownAssemblyObj.AddChildObj(GuidGenerator.Create(), billPart.PartCode, billPart.PartNum, billPart.Description);
+                //}
+                //var partNumSum = unknownAssemblyObj.UnknownAssemblyParts.Sum(itm => (int)itm.PartNum);
+                //unknownAssemblyObj.SetPartNum(partNumSum);
+                ret = await _unknownAssemblyRepository.InsertAsync(unknownAssemblyObj);
+                return ret;
+            }
+            catch (Exception ex)
+            {
+                throw new Exception($"InsertUnknownAssembly方法报错：" + ex.Message);
+            }
+        }
+
+
+    }
+}

src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Domain/EdiReceive/Services/HQ_CacheManagerDomainService.cs

@@ -0,0 +1,249 @@
+using Microsoft.Extensions.Logging;
+using System;
+using System.Collections.Concurrent;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.IO;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Volo.Abp.DependencyInjection;
+using Volo.Abp.Domain.Repositories;
+using Volo.Abp.Guids;
+using Volo.Abp.Uow;
+using WY.NewJit.Common;
+using WY.NewJit.MsgBaseData;
+using WY.NewJit.MsgCheck;
+using WY.NewJit.IRepositories;
+using WY.NewJit.MsgBaseData.Entitys;
+
+namespace WY.NewJit.EdiReceive.Services
+{
+    public partial class HQ_CacheManagerDomainService : ITransientDependency
+    {
+        #region 仓储
+
+        /// <summary>
+        /// 日志
+        /// </summary>
+        private ILogger<HQ_CacheManagerDomainService> _logger;
+
+        /// <summary>
+        /// 配置
+        /// </summary>
+        private readonly Microsoft.Extensions.Configuration.IConfiguration _configuration;
+
+        /// <summary>
+        /// Dapper仓储
+        /// </summary>
+        private readonly INewJitDapperRepository _newJitDapperRepository;
+
+        /// <summary>
+        /// 字典领域服务
+        /// </summary>
+        private readonly DicDomainService _dicDomainService;
+
+        /// <summary>
+        /// 跨进程全局配置领域服务
+        /// </summary>
+        private readonly GlobalSettingsDomainService _globalSettingsDomainService;
+        #endregion
+
+        #region 缓存
+        public static List<ErpAssemblyMain> _erpAssemblyMainList = new List<ErpAssemblyMain>();
+
+        /// <summary>
+        /// 分组VS总成关系
+        /// </summary>
+        //public static List<Group2Assembly> _group2assemblyList = new List<Group2Assembly>();
+
+        /// <summary>
+        /// 分组对应多个总成 清单-
+        /// </summary>
+        public static List<Group_Assembly> _groupAssemblyList = new List<Group_Assembly>();
+        
+
+        /// <summary>
+        /// 结算件切换列表
+        /// </summary>
+        public static List<PartSwitch> _partSwitchList = new List<PartSwitch>();
+
+        /// <summary>
+        /// 报文车型VS派格车型
+        /// </summary>
+        public static List<DicItem> _msgToPaiGeVehicleModelList = new List<DicItem>();
+
+        /// <summary>
+        /// R100派格车型VS生产线
+        /// </summary>
+        public static List<DicItem> _r100VehicleModelProductLineList = new List<DicItem>();
+
+        /// <summary>
+        /// M100派格车型VS生产线
+        /// </summary>
+        public static List<DicItem> _m100VehicleModelProductLineList = new List<DicItem>();
+
+        /// <summary>
+        /// 结算件信息列表
+        /// </summary>
+        public static List<PartCfg> _partCfgList = new List<PartCfg>();
+
+        #endregion
+
+        #region 变量
+        /// <summary>
+        /// 错误信息前缀
+        /// </summary>
+        private string _errorMessagePrefix
+        {
+            get
+            {
+                return System.Reflection.MethodBase.GetCurrentMethod().DeclaringType.Name + ".";
+            }
+        }
+
+        /// <summary>
+        /// 上一次缓存刷新时间，和配置文件中RefreshCacheIntervalInMinutes一起使用
+        /// </summary>
+        private DateTime _lastRefreshCacheTime = DateTime.Now;
+
+        #endregion
+
+        #region 构造函数
+        /// <summary>
+        /// 构造函数
+        /// </summary>
+        public HQ_CacheManagerDomainService(
+            ILogger<HQ_CacheManagerDomainService> logger,
+            Microsoft.Extensions.Configuration.IConfiguration configuration,
+            INewJitDapperRepository newJitDapperRepository,
+            DicDomainService dicDomainService,
+            GlobalSettingsDomainService globalSettingsDomainService
+            )
+        {
+            _logger = logger;
+            _configuration = configuration;
+            _newJitDapperRepository = newJitDapperRepository;
+            _dicDomainService = dicDomainService;
+            _globalSettingsDomainService = globalSettingsDomainService;
+        }
+        #endregion
+
+
+        #region 方法
+        public bool InitLoadCache(bool forceRefresh = false)
+        {
+            bool ret = false;
+            try
+            {
+                if (forceRefresh == true)
+                {
+                    DoInitLoadCache();
+                    //结算件信息列表，库存系统同步过来，无法缓存
+                    DoInitPartCfg();
+                    ret = true;
+                }
+                else
+                {
+                    bool isFirstRun = (_partCfgList.Any() == false); //第一次执行
+                    if (isFirstRun)
+                    {
+                        DoInitLoadCache();
+                        ret = true;
+                    }
+                    else //不是第一次执行
+                    {
+                        //判断是否需要刷新
+                        bool isRefresh = _globalSettingsDomainService.GetSetting(GlobalSettingsNameEnum.刷新报文解析缓存);
+                        if (isRefresh)
+                        {
+                            DoInitLoadCache();
+                            _globalSettingsDomainService.SetSetting(GlobalSettingsNameEnum.刷新报文解析缓存, false);
+                        }
+                        else
+                        {
+                            #region 10分钟自动刷新一次缓存
+                            int refCacheInterval = _configuration["ConfigDic:RefreshCacheIntervalInMinutes"]?.TryToInt() ?? 10;
+                            DateTime nowRefreshCacheTime = DateTime.Now;
+                            TimeSpan ts = nowRefreshCacheTime - _lastRefreshCacheTime;
+                            if (ts.TotalMinutes >= refCacheInterval)
+                            {
+                                DoInitLoadCache();
+                                _lastRefreshCacheTime = DateTime.Now;
+                            }
+                            #endregion
+                            ret = true;
+                        }
+                    }
+                    //结算件信息列表，库存系统同步过来，无法缓存
+                    DoInitPartCfg();
+                }
+                return ret;
+            }
+            catch (Exception ex)
+            {
+                string errorMsg = _errorMessagePrefix + "调用InitLoadCache方法时报错：" + ex.Message;
+                throw new Exception(errorMsg);
+            }
+        }
+
+        /// <summary>
+        /// 报文解析前加载缓存
+        /// </summary>
+        public void DoInitLoadCache()
+        {
+            //取ERP总成主表
+            string erpMainSql = "select Id, VehicleModel from FisAssemblyCfgErp where NewVersionId is null order by ErpAssemblyVersion, CreationTime desc";
+            _erpAssemblyMainList = _newJitDapperRepository.GetListBySql<ErpAssemblyMain>(erpMainSql, true);
+
+            //取ERP总成的零件
+            string group2assemblySql = @"
+                    select g.Id as GroupId, g.GroupCode, g.VehicleModel, e.Id as ErpAssemblyId, e.ErpAssemblyCode,
+                      g.SpecExplain, g.ColorExplain
+					  from FisAssemblyCfgGroup g			  
+                      join FisAssemblyCfgErp e on g.Id = e.GroupId
+                      where IsDeleted = 0 and g.IsDisable = 0
+                      order by g.CreationTime desc
+                    ";
+            var group2assemblyList = _newJitDapperRepository.GetListBySql<Group2Assembly>(group2assemblySql, true);
+            //转换成分组、总成 两层结构
+            List<Group_Assembly> _groupAssemblyList = group2assemblyList.GroupBy(itm => itm.GroupId).Select(itm => new Group_Assembly
+            {
+                Id = itm.Key,
+                GroupCode = itm.ElementAt(0).GroupCode,
+                SpecExplain = itm.ElementAt(0).SpecExplain,
+                ColorExplain = itm.ElementAt(0).ColorExplain,
+
+                AssemblyDetails = itm.Select(itm2 => new OnlyAssemblyInfo
+                {
+                    Id = itm2.ErpAssemblyId,
+                    ErpAssemblyCode = itm2.ErpAssemblyCode,
+                    ErpAssemblyName = itm2.ErpAssemblyName
+                }).ToList()
+
+            }).ToList();
+
+
+            //结算件切换列表
+            string partSwitchSql = "select SourcePartCode, TargetPartCode, ActiveBeginTime, ActiveEndTime from FisPartSwitch";
+            _partSwitchList = _newJitDapperRepository.GetListBySql<PartSwitch>(partSwitchSql, true);
+
+            _msgToPaiGeVehicleModelList = _dicDomainService.GetDicItems(DicTypeName.报文车型对应派格车型);
+            _r100VehicleModelProductLineList = _dicDomainService.GetDicItems(DicTypeName.R100派格车型对应生产线);
+            _m100VehicleModelProductLineList = _dicDomainService.GetDicItems(DicTypeName.M100派格车型对应生产线);
+            _logger.LogDebug("重新刷新报文解析缓存！");
+        }
+
+        /// <summary>
+        /// 初始化零件基本信息
+        /// </summary>
+        private void DoInitPartCfg()
+        {
+            //结算件信息列表，库存系统同步过来，无法缓存
+            string partCfgSql = @"select Id, PartCode, PartName, PartType, Description, PartType2, PartType3, RelationKey from FisPartCfg where 1=1"; //,DaXiaoLiangGang,DoorPlankCode,MaterialDescription,SAPMaterialNum
+            _partCfgList = _newJitDapperRepository.GetListBySql<PartCfg>(partCfgSql, true);
+
+        }
+        #endregion
+    }
+}

src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Domain/EdiReceive/Services/HQ_M100DomainService.cs

@@ -0,0 +1,209 @@
+using Microsoft.Extensions.Logging;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Volo.Abp.Domain.Repositories;
+using Volo.Abp.Domain.Services;
+using WY.NewJit.PrintTable;
+using WY.NewJit.Common;
+
+namespace WY.NewJit.MsgCheck
+{
+    public class HQ_M100DomainService : DomainService
+    {
+        /// <summary>
+        /// M100单据
+        /// </summary>
+        private readonly IRepository<BillM100, Guid> _billM100Repository;
+
+        /// <summary>
+        /// 日志
+        /// </summary>
+        private ILogger<M100CheckDomainService> _logger;
+
+        /// <summary>
+        /// 未打印表
+        /// </summary>
+        private readonly IRepository<WaitPrint, Guid> _waitPrintRepository;
+
+        public HQ_M100DomainService(
+            IRepository<BillM100, Guid> billM100Repository,
+            ILogger<M100CheckDomainService> logger,
+            IRepository<WaitPrint, Guid> waitPrintRepository
+            )
+        {
+            _billM100Repository = billM100Repository;
+            _logger = logger;
+            _waitPrintRepository = waitPrintRepository;
+        }
+
+        public async Task<BillM100> InsertM100(BillM100 m100Obj, bool autoSave = false, bool isBatchImportBreakNum = false)
+        {
+            BillM100 m100Ret = null;
+
+            if (isBatchImportBreakNum) //批量导入断号模块调用
+            {
+                //更新M100
+                m100Obj.HostSN2 = 0;
+                //M100转换成WaitPrint：一个底盘、08产线插入3条记录，其它产线插入1条记录
+                WaitPrint[] wpArr2 = M100ConvertToWaitPrint(m100Obj);
+
+                foreach (var wp in wpArr2)
+                {
+                    wp.PrintType = PrintTypeEnum.ReplenishPrint;
+                    //wp.HostSN2 = 0; //WaitPrint的HostSN2从m100的HostSN2取值
+                }
+                m100Ret = await _billM100Repository.InsertAsync(m100Obj, autoSave); //插入M100
+                await _waitPrintRepository.InsertManyAsync(wpArr2, autoSave); //插入未打印表
+                return m100Ret;
+            }
+
+            //M100转换成WaitPrint：一个底盘、08产线插入3条记录，其它产线插入1条记录
+            WaitPrint[] wpArr = M100ConvertToWaitPrint(m100Obj);
+
+            m100Ret = await _billM100Repository.InsertAsync(m100Obj, autoSave); //插入M100
+            await _waitPrintRepository.InsertManyAsync(wpArr, autoSave); //插入未打印表
+            return m100Ret;
+        }
+
+        private WaitPrint[] M100ConvertToWaitPrint(BillM100 m100Obj)
+        {
+            WaitPrint[] wpArr;
+            WaitPrint mbRec = ConvertWaitPrint(m100Obj, BusinessTypeEnum.MenBan);
+            wpArr = new WaitPrint[1] { mbRec };
+            return wpArr;
+        }
+
+        public async Task<BillM100> UpdateM100(BillM100 m100Obj, bool autoSave = false)
+        {
+            var m100Ret = await _billM100Repository.UpdateAsync(m100Obj, autoSave);
+            if (m100Ret != null)
+            {
+
+                //更新已解析状态时，只涉及门板、不涉及柱护板【柱护板一对一解析成功】
+                List<WaitPrint> wpLst = await _waitPrintRepository.GetListAsync(itm => itm.M100Id == m100Ret.Id && itm.BusinessType == BusinessTypeEnum.MenBan);
+                foreach (var wp in wpLst)
+                {
+                    wp.AssemblyID = m100Ret.AssemblyID;
+                    wp.BillStatus = m100Ret.BillStatus;
+                }
+                await _waitPrintRepository.UpdateManyAsync(wpLst, autoSave);
+
+
+                return m100Ret;
+            }
+            return null;
+        }
+
+        private WaitPrint ConvertWaitPrint(BillM100 m100Ret, BusinessTypeEnum businessType)
+        {
+            WaitPrint waitPrint = new WaitPrint(GuidGenerator.Create());
+            ConvertWaitPrint(m100Ret, businessType, waitPrint);
+            return waitPrint;
+        }
+
+        private void ConvertWaitPrint(BillM100 m100Ret, BusinessTypeEnum businessType, WaitPrint waitPrint)
+        {
+            waitPrint.M100Id = m100Ret.Id;
+            waitPrint.BusinessType = businessType;
+            waitPrint.ProductLine = m100Ret.ProductLine;
+            waitPrint.OnlineTime = (DateTime)m100Ret.OnlineTime;
+            waitPrint.HostSN = (int)m100Ret.HostSN;
+            waitPrint.KNR = m100Ret.KNR;
+            waitPrint.VIN = m100Ret.VIN;
+            waitPrint.VehicleModelCode = m100Ret.VehicleModelCode;
+            waitPrint.AssemblyID = m100Ret.AssemblyID;
+            if (businessType == BusinessTypeEnum.MenBan)
+            {
+                waitPrint.BillStatus = m100Ret.BillStatus;
+            }
+            else
+            {
+                waitPrint.BillStatus = BillStatusEnum.Match; //柱护板默认是匹配状态
+            }
+            waitPrint.PrintType = PrintTypeEnum.OrderPrint;
+            waitPrint.HostSN2 = (int)m100Ret.HostSN2;
+            waitPrint.Description = m100Ret.Description;
+            waitPrint.ReceiveTime = m100Ret.ReceiveTime;
+            waitPrint.CreationTime = ServerHelper.CurrentDateTime; //m100Ret.CreationTime;
+            waitPrint.CreatorId = m100Ret.CreatorId;
+            waitPrint.LastModificationTime = m100Ret.LastModificationTime;
+            waitPrint.LastModifierId = m100Ret.LastModifierId;
+        }
+
+        private void Set_WaitPrint(WaitPrint sourceWaitPrint, WaitPrint targetWaitPrint)
+        {
+            targetWaitPrint.M100Id = sourceWaitPrint.M100Id;
+            targetWaitPrint.BusinessType = sourceWaitPrint.BusinessType;
+            targetWaitPrint.ProductLine = sourceWaitPrint.ProductLine;
+            targetWaitPrint.OnlineTime = sourceWaitPrint.OnlineTime;
+            targetWaitPrint.HostSN = sourceWaitPrint.HostSN;
+            targetWaitPrint.KNR = sourceWaitPrint.KNR;
+            targetWaitPrint.VIN = sourceWaitPrint.VIN;
+            targetWaitPrint.VehicleModelCode = sourceWaitPrint.VehicleModelCode;
+            targetWaitPrint.AssemblyID = sourceWaitPrint.AssemblyID;
+            targetWaitPrint.BillStatus = sourceWaitPrint.BillStatus;
+            targetWaitPrint.PrintType = sourceWaitPrint.PrintType;
+            targetWaitPrint.HostSN2 = sourceWaitPrint.HostSN2;
+            targetWaitPrint.Description = sourceWaitPrint.Description;
+            targetWaitPrint.ReceiveTime = sourceWaitPrint.ReceiveTime;
+            targetWaitPrint.CreationTime = sourceWaitPrint.CreationTime;
+            targetWaitPrint.CreatorId = sourceWaitPrint.CreatorId;
+            targetWaitPrint.LastModificationTime = sourceWaitPrint.LastModificationTime;
+            targetWaitPrint.LastModifierId = sourceWaitPrint.LastModifierId;
+        }
+
+        public async Task<Dictionary<Guid, List<BillM100Part>>> GetM100PartDic(List<Guid> m100IdLst)
+        {
+            List<BillM100> m100Lst = await _billM100Repository.GetListAsync(itm => m100IdLst.Contains(itm.Id), true);
+            Dictionary<Guid, List<BillM100Part>> ret = m100Lst.ToDictionary(itm => itm.Id, itm2 => itm2.BillM100Parts);
+            return ret;
+        }
+
+        /// <summary>
+        /// 根据M100插入或更新未打印表，【未知总成重新解析时调用】
+        /// </summary>
+        /// <param name="m100Obj"></param>
+        /// <returns></returns>
+        public async Task<ObjectResultDto> InsertOrUpdateWaitPrintByM100(BillM100 m100Obj, bool autoSave = false)
+        {
+            ObjectResultDto ret = new ObjectResultDto(true, "");
+            List<WaitPrint> wpLst = await _waitPrintRepository.GetListAsync(itm => itm.VIN == m100Obj.VIN && itm.BusinessType == BusinessTypeEnum.MenBan);
+            bool hasData = wpLst.Count > 0;
+            if (hasData) //未打印表有数据
+            {
+                foreach (WaitPrint wp in wpLst)
+                {
+                    wp.AssemblyID = m100Obj.AssemblyID;
+                    wp.BillStatus = m100Obj.BillStatus;
+                }
+                await _waitPrintRepository.UpdateManyAsync(wpLst, autoSave);
+            }
+            else //未打印表没有数据
+            {
+                WaitPrint[] wpArr;
+                if (m100Obj.ProductLine == "08")
+                {
+                    WaitPrint mbRec = ConvertWaitPrint(m100Obj, BusinessTypeEnum.MenBan);
+                    //WaitPrint zhbOtherRec = ConvertWaitPrint(m100Obj, BusinessTypeEnum.OtherZhuHuBan);
+                    //WaitPrint zhbRec = ConvertWaitPrint(m100Obj, BusinessTypeEnum.AC_ZhuHuBan);
+                    //wpArr = new WaitPrint[3] { mbRec, zhbOtherRec, zhbRec };
+                    wpArr = new WaitPrint[1] { mbRec };
+                }
+                else
+                {
+                    WaitPrint mbRec = ConvertWaitPrint(m100Obj, BusinessTypeEnum.MenBan);
+                    wpArr = new WaitPrint[1] { mbRec };
+                }
+                foreach (WaitPrint wp in wpArr)
+                {
+                    wp.PrintType = PrintTypeEnum.ReplenishPrint;
+                }
+                await _waitPrintRepository.InsertManyAsync(wpArr, autoSave); //插入未打印表
+            }
+            return ret;
+        }
+    }
+}

src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Domain/EdiReceive/Services/LastImportHostSNDomainService.cs

@@ -0,0 +1,73 @@
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Logging;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Volo.Abp.Domain.Repositories;
+using Volo.Abp.Domain.Services;
+using WY.NewJit.EdiReceive.Entitys;
+using WY.NewJit.IRepositories;
+using WY.NewJit.MsgBaseData;
+using WY.NewJit.MsgCheck;
+
+namespace WY.NewJit.EdiReceive.Services
+{
+    public class LastImportHostSNDomainService : DomainService
+    {
+        #region 成员
+        /// <summary>
+        /// 日志
+        /// </summary>
+        private readonly ILogger<LastImportHostSNDomainService> _logger;
+
+        /// <summary>
+        /// Dapper仓储
+        /// </summary>
+        private readonly INewJitDapperRepository _newJitDapperRepository;
+
+        /// <summary>
+        /// 字典领域服务
+        /// </summary>
+        private readonly DicDomainService _dicDomainService;
+
+        /// <summary>
+        /// 零件仓储
+        /// </summary>
+        private readonly IRepository<ImportRecord, Guid> _importRecordRepository;
+
+        /// <summary>
+        /// M100单据
+        /// </summary>
+        private readonly IRepository<BillM100, Guid> _billM100Repository;
+
+        private readonly IRepository<LastImportHostSN, Guid> _lastImportHostSNRepository;
+
+        #endregion
+        public LastImportHostSNDomainService(ILogger<LastImportHostSNDomainService> logger, INewJitDapperRepository newJitDapperRepository, DicDomainService dicDomainService, IRepository<ImportRecord, Guid> importRecordRepository, IRepository<BillM100, Guid> billM100Repository, IRepository<LastImportHostSN, Guid> lastImportHostSNRepository)
+        {
+            _logger = logger;
+            _newJitDapperRepository = newJitDapperRepository;
+            _dicDomainService = dicDomainService;
+            _importRecordRepository = importRecordRepository;
+            _billM100Repository = billM100Repository;
+            _lastImportHostSNRepository = lastImportHostSNRepository;
+        }
+
+        public async Task<int> GetLastImportHostSN()
+        {
+            var lst = await _lastImportHostSNRepository.GetListAsync();
+            if (lst.Count > 0)
+            {
+                return lst[0].HostSN;
+            }
+            else
+            {
+                int maxSN = await _lastImportHostSNRepository.MaxAsync(itm => itm.HostSN);
+                return maxSN;
+            }
+        }
+
+    }
+}

src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Domain/MsgBaseData/Entitys/AssemblyCfgErp.cs

@@ -52,6 +52,16 @@ namespace WY.NewJit.MsgBaseData
         /// </summary>
         public virtual Guid GroupId { get; set; }
 
+        /// <summary>
+        /// 规格说明
+        /// </summary>
+        public virtual string SpecExplain { get; set; }
+
+        /// <summary>
+        /// 颜色说明
+        /// </summary>
+        public virtual string ColorExplain { get; set; }
+
         /// <summary>
         /// 结算件列表
         /// </summary>

src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Domain/MsgBaseData/Entitys/AssemblyCfgGroup.cs

@@ -27,6 +27,17 @@ namespace WY.NewJit.MsgBaseData
         /// </summary>
         public virtual bool IsDisable { get; set; }
 
+        /// <summary>
+        /// 规格说明
+        /// </summary>
+        public virtual string SpecExplain { get; set; }
+
+        /// <summary>
+        /// 颜色说明
+        /// </summary>
+        public virtual string ColorExplain { get; set; }
+
+
         private AssemblyCfgGroup()
         {
         }

src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Domain/MsgBaseData/Entitys/Group_Assembly_Part.cs

@@ -28,6 +28,34 @@ namespace WY.NewJit.MsgBaseData.Entitys
 
     }
 
+    public class Group_Assembly
+    {
+        public virtual Guid Id { get; set; }
+        /// <summary>
+        /// SAP分组编码（对应SAP的长描述或补充备注）
+        /// </summary>
+        public virtual string GroupCode { get; set; }
+
+        /// <summary>
+        /// 规格说明
+        /// </summary>
+        public virtual string SpecExplain { get; set; }
+
+        /// <summary>
+        /// 颜色说明
+        /// </summary>
+        public virtual string ColorExplain { get; set; }
+
+        public List<OnlyAssemblyInfo> AssemblyDetails;
+
+        public Group_Assembly()
+        {
+            AssemblyDetails = new List<OnlyAssemblyInfo>();
+        }
+
+    }
+
+
     public class AssemblyInfo
     {
         /// <summary>
@@ -49,6 +77,30 @@ namespace WY.NewJit.MsgBaseData.Entitys
 
     }
 
+    public class OnlyAssemblyInfo
+    {
+        /// <summary>
+        /// Erp总成ID
+        /// </summary>
+        public Guid Id { get; set; }
+
+        /// <summary>
+        /// Erp总成编码
+        /// </summary>
+        public string ErpAssemblyCode { get; set; }
+
+        /// <summary>
+        /// Erp总成编码
+        /// </summary>
+        public string ErpAssemblyName { get; set; }
+
+        public OnlyAssemblyInfo()
+        {
+        }
+
+    }
+
+
     public class PartInfo
     {
         /// <summary>

src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Domain/MsgCheck/Entitys/BillM100.cs

@@ -17,7 +17,7 @@ namespace WY.NewJit.MsgCheck
         /// <summary>
         /// 报文接收ID，对应报文接收表主键
         /// </summary>
-        public virtual Guid? MessageFileReceiveID { get; protected set; }
+        public virtual Guid? MessageFileReceiveID { get; set; }
 
         /// <summary>
         /// 流水号#
@@ -49,7 +49,7 @@ namespace WY.NewJit.MsgCheck
         /// <summary>
         /// 车型代码（取通用字典）
         /// </summary>
-        public virtual string VehicleModelCode { get; protected set; }
+        public virtual string VehicleModelCode { get; set; }
 
         /// <summary>
         /// 生产线（派格按生产线分类）
@@ -59,17 +59,17 @@ namespace WY.NewJit.MsgCheck
         /// <summary>
         /// 版本
         /// </summary>
-        public virtual string Version { get; protected set; }
+        public virtual string Version { get; set; }
 
         /// <summary>
         /// 接收时间
         /// </summary>
-        public virtual DateTime? ReceiveTime { get; protected set; }
+        public virtual DateTime? ReceiveTime { get; set; }
 
         /// <summary>
         /// 单据状态（0 空；1 未匹配；2 已匹配未打印；3 已打印）
         /// </summary>
-        public virtual BillStatusEnum BillStatus { get; protected set; }
+        public virtual BillStatusEnum BillStatus { get; set; }
 
         /// <summary>
         /// 描述
@@ -142,9 +142,9 @@ namespace WY.NewJit.MsgCheck
             //因为它会被来自数据库的值覆盖.可能不适用于私有构造函数.
         }
 
-        //protected BillM100(Guid id)
+        public BillM100(Guid id)
-        //    :base(id)
+            : base(id)
-        //{ }
+        { }
 
         //public BillM100(Guid id, Guid? messageFileReceiveID, int? serialNum, int? hostSN, string kNR, string vIN, Guid? assemblyID, DateTime? onlineTime, string vehicleModelCode, string version, DateTime? receiveTime, BillStatusEnum billStatus)
         //    : base(id)

src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Domain/MsgCheck/Services/BillNumberRecordDomainService.cs

@@ -15,6 +15,9 @@ using WY.NewJit.PrintTable;
 
 namespace WY.NewJit.MsgCheck
 {
+    /// <summary>
+    /// 吕志斌开发的生成断号数据
+    /// </summary>
     [Dependency(Microsoft.Extensions.DependencyInjection.ServiceLifetime.Singleton, ReplaceServices = true)]
     public class BillNumberRecordDomainService : DomainService
     {

src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Domain/MsgCheck/Services/CacheManagerDomainService.cs

@@ -1,4 +1,5 @@
-using Microsoft.Extensions.Logging;
+/*
+using Microsoft.Extensions.Logging;
 using System;
 using System.Collections.Concurrent;
 using System.Collections.Generic;
@@ -301,6 +302,8 @@ namespace WY.NewJit.MsgCheck
 
     }
 }
+*/
+
 /* 调用缓存管理领域服务的代码
 private readonly CacheManagerDomainService _cacheManagerDomainService;
 CacheManagerDomainService cacheManagerDomainService

src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Domain/MsgCheck/Services/M100DomainService.cs

@@ -43,102 +43,7 @@ namespace WY.NewJit.MsgCheck
             _billNumRecDomainSrv = billNumRecDomainSrv;
         }
 
-        public async Task<BillM100> InsertM100(BillM100 m100Obj, bool autoSave = false, bool isBatchImportBreakNum = false)
+        /*
-        {
-            BillM100 m100Ret = null;
-
-            if (isBatchImportBreakNum) //批量导入断号模块调用
-            {
-                //更新M100
-                m100Obj.HostSN2 = 0;
-                //M100转换成WaitPrint：一个底盘、08产线插入3条记录，其它产线插入1条记录
-                WaitPrint[] wpArr2 = M100ConvertToWaitPrint(m100Obj);
-
-                foreach (var wp in wpArr2)
-                {
-                    wp.PrintType = PrintTypeEnum.ReplenishPrint;
-                    //wp.HostSN2 = 0; //WaitPrint的HostSN2从m100的HostSN2取值
-                }
-                m100Ret = await _billM100Repository.InsertAsync(m100Obj, autoSave); //插入M100
-                await _waitPrintRepository.InsertManyAsync(wpArr2, autoSave); //插入未打印表
-                return m100Ret;
-            }
-
-            //调用HostSN2方法
-            BillNumberRecord billNumRec = await _billNumRecDomainSrv.GetBillNumber(m100Obj.HostSN.TryToIntNotNull(), m100Obj.ProductLine);
-            var normalObj = billNumRec.Datas.FirstOrDefault(itm => itm.BillNumberType == BillNumberTypeEnum.正常);
-            var lateObj = billNumRec.Datas.FirstOrDefault(itm => itm.BillNumberType == BillNumberTypeEnum.迟到);
-            var breakNumLst = billNumRec.Datas.Where(itm => itm.BillNumberType == BillNumberTypeEnum.断号).ToList();
-            //更新M100
-            m100Obj.HostSN2 = normalObj != null ? normalObj.HostSN2 : lateObj.HostSN2;
-            //M100转换成WaitPrint：一个底盘、08产线插入3条记录，其它产线插入1条记录
-            WaitPrint[] wpArr = M100ConvertToWaitPrint(m100Obj);
-
-            //处理断号
-            if (breakNumLst.Count > 0)
-            {
-                List<WaitPrint> waitPrintBreakNumLst = new List<WaitPrint>();
-                foreach (var sourceWaitPrint in wpArr) //遍历门板、柱护板、其它柱护板
-                {
-                    foreach (var breaknum in breakNumLst) //遍历断号
-                    {
-                        WaitPrint targetWaitPrint = new WaitPrint(GuidGenerator.Create());
-                        targetWaitPrint.M100Id = Guid.Parse("00000000-0000-0000-0000-000000000000");
-                        targetWaitPrint.BusinessType = sourceWaitPrint.BusinessType;
-                        targetWaitPrint.ProductLine = sourceWaitPrint.ProductLine;
-                        targetWaitPrint.OnlineTime = sourceWaitPrint.OnlineTime;
-                        targetWaitPrint.HostSN = breaknum.HostSN;
-                        targetWaitPrint.KNR = null;
-                        targetWaitPrint.VIN = null;
-                        targetWaitPrint.VehicleModelCode = null;
-                        targetWaitPrint.AssemblyID = null;
-                        targetWaitPrint.BillStatus = BillStatusEnum.BreakNum;
-                        targetWaitPrint.PrintType = PrintTypeEnum.OrderPrint;
-                        targetWaitPrint.HostSN2 = breaknum.HostSN2;
-                        targetWaitPrint.Description = null;
-                        targetWaitPrint.ReceiveTime = null;
-                        targetWaitPrint.CreationTime = ServerHelper.CurrentDateTime;
-                        //targetWaitPrint.CreatorId = null;
-                        //targetWaitPrint.LastModificationTime = null;
-                        //targetWaitPrint.LastModifierId = null;
-                        waitPrintBreakNumLst.Add(targetWaitPrint);
-                    }
-                }
-                await _waitPrintRepository.InsertManyAsync(waitPrintBreakNumLst, autoSave); //插入断号
-            }
-            //处理正常、迟到
-            if (normalObj != null) //正常
-            {
-                m100Ret = await _billM100Repository.InsertAsync(m100Obj, autoSave); //插入M100
-                await _waitPrintRepository.InsertManyAsync(wpArr, autoSave); //插入未打印表
-            }
-            else if (lateObj != null) //迟到
-            {
-                m100Ret = await _billM100Repository.InsertAsync(m100Obj, autoSave); //插入M100
-
-                foreach (var item in wpArr) //遍历门板、柱护板、其它柱护板
-                {
-                    var insObj = await _waitPrintRepository.FirstOrDefaultAsync(itm =>
-                        itm.HostSN2 == m100Obj.HostSN2
-                        && itm.BillStatus == BillStatusEnum.BreakNum
-                        && itm.BusinessType == item.BusinessType);
-                    if (insObj != null)
-                    {
-                        //如果未打印表有对应断号记录，将迟到记录与之合并
-                        Set_WaitPrint(item, insObj);
-                        var updateRet = await _waitPrintRepository.UpdateAsync(insObj);
-                    }
-                    else
-                    {
-                        //如果未打印表没有----对应断号记录，则插入
-                        item.PrintType = PrintTypeEnum.ReplenishPrint;
-                        var insertRet = await _waitPrintRepository.InsertAsync(item, autoSave);
-                    }
-                }
-            }
-            return m100Ret;
-        }
-
         private WaitPrint[] M100ConvertToWaitPrint(BillM100 m100Obj)
         {
             WaitPrint[] wpArr;
@@ -158,40 +63,6 @@ namespace WY.NewJit.MsgCheck
             return wpArr;
         }
 
-        public async Task<BillM100> UpdateM100(BillM100 m100Obj, bool autoSave = false)
-        {
-            var m100Ret = await _billM100Repository.UpdateAsync(m100Obj, autoSave);
-            if (m100Ret != null)
-            {
-                //if (m100Obj.ProductLine == "08")
-                //{
-                //    //更新已解析状态时，只涉及门板、2条柱护板
-                //    WaitPrint mbRec = await _waitPrintRepository.GetAsync(itm => itm.M100Id == m100Ret.Id && itm.BusinessType == BusinessTypeEnum.MenBan);
-                //    ConvertWaitPrint(m100Ret, BusinessTypeEnum.MenBan, mbRec);
-                //    await _waitPrintRepository.UpdateAsync(mbRec);
-                //}
-                //else
-                //{
-                //    WaitPrint mbRec = await _waitPrintRepository.GetAsync(itm => itm.M100Id == m100Ret.Id && itm.BusinessType == BusinessTypeEnum.MenBan);
-                //    ConvertWaitPrint(m100Ret, BusinessTypeEnum.MenBan, mbRec);
-                //    await _waitPrintRepository.UpdateAsync(mbRec);
-                //}
-
-                //更新已解析状态时，只涉及门板、不涉及柱护板【柱护板一对一解析成功】
-                List<WaitPrint> wpLst = await _waitPrintRepository.GetListAsync(itm => itm.M100Id == m100Ret.Id && itm.BusinessType == BusinessTypeEnum.MenBan);
-                foreach (var wp in wpLst)
-                {
-                    wp.AssemblyID = m100Ret.AssemblyID;
-                    wp.BillStatus = m100Ret.BillStatus;
-                }
-                await _waitPrintRepository.UpdateManyAsync(wpLst, autoSave);
-
-
-                return m100Ret;
-            }
-            return null;
-        }
-
         private WaitPrint ConvertWaitPrint(BillM100 m100Ret, BusinessTypeEnum businessType)
         {
             WaitPrint waitPrint = new WaitPrint(GuidGenerator.Create());
@@ -249,12 +120,148 @@ namespace WY.NewJit.MsgCheck
             targetWaitPrint.LastModificationTime = sourceWaitPrint.LastModificationTime;
             targetWaitPrint.LastModifierId = sourceWaitPrint.LastModifierId;
         }
+        */
+
+        public async Task<BillM100> InsertM100(BillM100 m100Obj, bool autoSave = false, bool isBatchImportBreakNum = false)
+        {
+            throw new NotImplementedException();
+            //BillM100 m100Ret = null;
+
+            //if (isBatchImportBreakNum) //批量导入断号模块调用
+            //{
+            //    //更新M100
+            //    m100Obj.HostSN2 = 0;
+            //    //M100转换成WaitPrint：一个底盘、08产线插入3条记录，其它产线插入1条记录
+            //    WaitPrint[] wpArr2 = M100ConvertToWaitPrint(m100Obj);
+
+            //    foreach (var wp in wpArr2)
+            //    {
+            //        wp.PrintType = PrintTypeEnum.ReplenishPrint;
+            //        //wp.HostSN2 = 0; //WaitPrint的HostSN2从m100的HostSN2取值
+            //    }
+            //    m100Ret = await _billM100Repository.InsertAsync(m100Obj, autoSave); //插入M100
+            //    await _waitPrintRepository.InsertManyAsync(wpArr2, autoSave); //插入未打印表
+            //    return m100Ret;
+            //}
+
+            ////调用HostSN2方法
+            //BillNumberRecord billNumRec = await _billNumRecDomainSrv.GetBillNumber(m100Obj.HostSN.TryToIntNotNull(), m100Obj.ProductLine);
+            //var normalObj = billNumRec.Datas.FirstOrDefault(itm => itm.BillNumberType == BillNumberTypeEnum.正常);
+            //var lateObj = billNumRec.Datas.FirstOrDefault(itm => itm.BillNumberType == BillNumberTypeEnum.迟到);
+            //var breakNumLst = billNumRec.Datas.Where(itm => itm.BillNumberType == BillNumberTypeEnum.断号).ToList();
+            ////更新M100
+            //m100Obj.HostSN2 = normalObj != null ? normalObj.HostSN2 : lateObj.HostSN2;
+            ////M100转换成WaitPrint：一个底盘、08产线插入3条记录，其它产线插入1条记录
+            //WaitPrint[] wpArr = M100ConvertToWaitPrint(m100Obj);
+
+            ////处理断号
+            //if (breakNumLst.Count > 0)
+            //{
+            //    List<WaitPrint> waitPrintBreakNumLst = new List<WaitPrint>();
+            //    foreach (var sourceWaitPrint in wpArr) //遍历门板、柱护板、其它柱护板
+            //    {
+            //        foreach (var breaknum in breakNumLst) //遍历断号
+            //        {
+            //            WaitPrint targetWaitPrint = new WaitPrint(GuidGenerator.Create());
+            //            targetWaitPrint.M100Id = Guid.Parse("00000000-0000-0000-0000-000000000000");
+            //            targetWaitPrint.BusinessType = sourceWaitPrint.BusinessType;
+            //            targetWaitPrint.ProductLine = sourceWaitPrint.ProductLine;
+            //            targetWaitPrint.OnlineTime = sourceWaitPrint.OnlineTime;
+            //            targetWaitPrint.HostSN = breaknum.HostSN;
+            //            targetWaitPrint.KNR = null;
+            //            targetWaitPrint.VIN = null;
+            //            targetWaitPrint.VehicleModelCode = null;
+            //            targetWaitPrint.AssemblyID = null;
+            //            targetWaitPrint.BillStatus = BillStatusEnum.BreakNum;
+            //            targetWaitPrint.PrintType = PrintTypeEnum.OrderPrint;
+            //            targetWaitPrint.HostSN2 = breaknum.HostSN2;
+            //            targetWaitPrint.Description = null;
+            //            targetWaitPrint.ReceiveTime = null;
+            //            targetWaitPrint.CreationTime = ServerHelper.CurrentDateTime;
+            //            //targetWaitPrint.CreatorId = null;
+            //            //targetWaitPrint.LastModificationTime = null;
+            //            //targetWaitPrint.LastModifierId = null;
+            //            waitPrintBreakNumLst.Add(targetWaitPrint);
+            //        }
+            //    }
+            //    await _waitPrintRepository.InsertManyAsync(waitPrintBreakNumLst, autoSave); //插入断号
+            //}
+            ////处理正常、迟到
+            //if (normalObj != null) //正常
+            //{
+            //    m100Ret = await _billM100Repository.InsertAsync(m100Obj, autoSave); //插入M100
+            //    await _waitPrintRepository.InsertManyAsync(wpArr, autoSave); //插入未打印表
+            //}
+            //else if (lateObj != null) //迟到
+            //{
+            //    m100Ret = await _billM100Repository.InsertAsync(m100Obj, autoSave); //插入M100
+
+            //    foreach (var item in wpArr) //遍历门板、柱护板、其它柱护板
+            //    {
+            //        var insObj = await _waitPrintRepository.FirstOrDefaultAsync(itm =>
+            //            itm.HostSN2 == m100Obj.HostSN2
+            //            && itm.BillStatus == BillStatusEnum.BreakNum
+            //            && itm.BusinessType == item.BusinessType);
+            //        if (insObj != null)
+            //        {
+            //            //如果未打印表有对应断号记录，将迟到记录与之合并
+            //            Set_WaitPrint(item, insObj);
+            //            var updateRet = await _waitPrintRepository.UpdateAsync(insObj);
+            //        }
+            //        else
+            //        {
+            //            //如果未打印表没有----对应断号记录，则插入
+            //            item.PrintType = PrintTypeEnum.ReplenishPrint;
+            //            var insertRet = await _waitPrintRepository.InsertAsync(item, autoSave);
+            //        }
+            //    }
+            //}
+            //return m100Ret;
+        }
+
+        public async Task<BillM100> UpdateM100(BillM100 m100Obj, bool autoSave = false)
+        {
+            throw new NotImplementedException();
+            //var m100Ret = await _billM100Repository.UpdateAsync(m100Obj, autoSave);
+            //if (m100Ret != null)
+            //{
+            //    //if (m100Obj.ProductLine == "08")
+            //    //{
+            //    //    //更新已解析状态时，只涉及门板、2条柱护板
+            //    //    WaitPrint mbRec = await _waitPrintRepository.GetAsync(itm => itm.M100Id == m100Ret.Id && itm.BusinessType == BusinessTypeEnum.MenBan);
+            //    //    ConvertWaitPrint(m100Ret, BusinessTypeEnum.MenBan, mbRec);
+            //    //    await _waitPrintRepository.UpdateAsync(mbRec);
+            //    //}
+            //    //else
+            //    //{
+            //    //    WaitPrint mbRec = await _waitPrintRepository.GetAsync(itm => itm.M100Id == m100Ret.Id && itm.BusinessType == BusinessTypeEnum.MenBan);
+            //    //    ConvertWaitPrint(m100Ret, BusinessTypeEnum.MenBan, mbRec);
+            //    //    await _waitPrintRepository.UpdateAsync(mbRec);
+            //    //}
+
+            //    //更新已解析状态时，只涉及门板、不涉及柱护板【柱护板一对一解析成功】
+            //    List<WaitPrint> wpLst = await _waitPrintRepository.GetListAsync(itm => itm.M100Id == m100Ret.Id && itm.BusinessType == BusinessTypeEnum.MenBan);
+            //    foreach (var wp in wpLst)
+            //    {
+            //        wp.AssemblyID = m100Ret.AssemblyID;
+            //        wp.BillStatus = m100Ret.BillStatus;
+            //    }
+            //    await _waitPrintRepository.UpdateManyAsync(wpLst, autoSave);
+
+
+            //    return m100Ret;
+            //}
+            //return null;
+        }
+
 
         public async Task<Dictionary<Guid, List<BillM100Part>>> GetM100PartDic(List<Guid> m100IdLst)
         {
-            List<BillM100> m100Lst = await _billM100Repository.GetListAsync(itm => m100IdLst.Contains(itm.Id), true);
+            throw new NotImplementedException();
-            Dictionary<Guid, List<BillM100Part>> ret = m100Lst.ToDictionary(itm => itm.Id, itm2 => itm2.BillM100Parts);
+
-            return ret;
+            //List<BillM100> m100Lst = await _billM100Repository.GetListAsync(itm => m100IdLst.Contains(itm.Id), true);
+            //Dictionary<Guid, List<BillM100Part>> ret = m100Lst.ToDictionary(itm => itm.Id, itm2 => itm2.BillM100Parts);
+            //return ret;
         }
 
         /// <summary>
@@ -264,41 +271,43 @@ namespace WY.NewJit.MsgCheck
         /// <returns></returns>
         public async Task<ObjectResultDto> InsertOrUpdateWaitPrintByM100(BillM100 m100Obj, bool autoSave = false)
         {
-            ObjectResultDto ret = new ObjectResultDto(true, "");
+            throw new NotImplementedException();
-            List<WaitPrint> wpLst = await _waitPrintRepository.GetListAsync(itm => itm.VIN == m100Obj.VIN && itm.BusinessType == BusinessTypeEnum.MenBan);
+
-            bool hasData = wpLst.Count > 0;
+            //ObjectResultDto ret = new ObjectResultDto(true, "");
-            if (hasData) //未打印表有数据
+            //List<WaitPrint> wpLst = await _waitPrintRepository.GetListAsync(itm => itm.VIN == m100Obj.VIN && itm.BusinessType == BusinessTypeEnum.MenBan);
-            {
+            //bool hasData = wpLst.Count > 0;
-                foreach (WaitPrint wp in wpLst)
+            //if (hasData) //未打印表有数据
-                {
+            //{
-                    wp.AssemblyID = m100Obj.AssemblyID;
+            //    foreach (WaitPrint wp in wpLst)
-                    wp.BillStatus = m100Obj.BillStatus;
+            //    {
-                }
+            //        wp.AssemblyID = m100Obj.AssemblyID;
-                await _waitPrintRepository.UpdateManyAsync(wpLst, autoSave);
+            //        wp.BillStatus = m100Obj.BillStatus;
-            }
+            //    }
-            else //未打印表没有数据
+            //    await _waitPrintRepository.UpdateManyAsync(wpLst, autoSave);
-            {
+            //}
-                WaitPrint[] wpArr;
+            //else //未打印表没有数据
-                if (m100Obj.ProductLine == "08")
+            //{
-                {
+            //    WaitPrint[] wpArr;
-                    WaitPrint mbRec = ConvertWaitPrint(m100Obj, BusinessTypeEnum.MenBan);
+            //    if (m100Obj.ProductLine == "08")
-                    //WaitPrint zhbOtherRec = ConvertWaitPrint(m100Obj, BusinessTypeEnum.OtherZhuHuBan);
+            //    {
-                    //WaitPrint zhbRec = ConvertWaitPrint(m100Obj, BusinessTypeEnum.AC_ZhuHuBan);
+            //        WaitPrint mbRec = ConvertWaitPrint(m100Obj, BusinessTypeEnum.MenBan);
-                    //wpArr = new WaitPrint[3] { mbRec, zhbOtherRec, zhbRec };
+            //        //WaitPrint zhbOtherRec = ConvertWaitPrint(m100Obj, BusinessTypeEnum.OtherZhuHuBan);
-                    wpArr = new WaitPrint[1] { mbRec };
+            //        //WaitPrint zhbRec = ConvertWaitPrint(m100Obj, BusinessTypeEnum.AC_ZhuHuBan);
-                }
+            //        //wpArr = new WaitPrint[3] { mbRec, zhbOtherRec, zhbRec };
-                else
+            //        wpArr = new WaitPrint[1] { mbRec };
-                {
+            //    }
-                    WaitPrint mbRec = ConvertWaitPrint(m100Obj, BusinessTypeEnum.MenBan);
+            //    else
-                    wpArr = new WaitPrint[1] { mbRec };
+            //    {
-                }
+            //        WaitPrint mbRec = ConvertWaitPrint(m100Obj, BusinessTypeEnum.MenBan);
-                foreach (WaitPrint wp in wpArr)
+            //        wpArr = new WaitPrint[1] { mbRec };
-                {
+            //    }
-                    wp.PrintType = PrintTypeEnum.ReplenishPrint;
+            //    foreach (WaitPrint wp in wpArr)
-                }
+            //    {
-                await _waitPrintRepository.InsertManyAsync(wpArr, autoSave); //插入未打印表
+            //        wp.PrintType = PrintTypeEnum.ReplenishPrint;
-            }
+            //    }
-            return ret;
+            //    await _waitPrintRepository.InsertManyAsync(wpArr, autoSave); //插入未打印表
+            //}
+            //return ret;
         }
     }
 }

src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Domain/MsgCheck/Services/R100CheckDomainService.cs

@@ -991,6 +991,48 @@ namespace WY.NewJit.MsgCheck
 
     }
 
+
+    [Serializable]
+    public class Group2Assembly
+    {
+        /// <summary>
+        /// 分组Id， 对应总成分组表Id
+        /// </summary>
+        public Guid GroupId { get; set; }
+
+        /// <summary>
+        /// 分组代码
+        /// </summary>
+        public string GroupCode { get; set; }
+
+        /// <summary>
+        /// Erp总成ID
+        /// </summary>
+        public Guid ErpAssemblyId { get; set; }
+
+        /// <summary>
+        /// Erp总成编码
+        /// </summary>
+        public string ErpAssemblyCode { get; set; }
+
+        /// <summary>
+        /// Erp总成名称
+        /// </summary>
+        public string ErpAssemblyName { get; set; }
+
+        /// <summary>
+        /// 规格说明
+        /// </summary>
+        public virtual string SpecExplain { get; set; }
+
+        /// <summary>
+        /// 颜色说明
+        /// </summary>
+        public virtual string ColorExplain { get; set; }
+
+    }
+
+
     public class ErpAssemblyMain
     {
         public Guid Id { get; set; }

src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Domain/WY.NewJit.Domain.csproj

@@ -30,7 +30,6 @@
   </ItemGroup>
 
   <ItemGroup>
-    <Folder Include="EdiReceive\Services\" />
     <Folder Include="MsgConversion\Services\" />
     <Folder Include="MsgTransmission\Services\" />
   </ItemGroup>

src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.EntityFrameworkCore.DbMigrations/Migrations/20240110033428_NewJitPG_HQ_0110.cs

@@ -0,0 +1,41 @@
+using System;
+using Microsoft.EntityFrameworkCore.Migrations;
+
+namespace WY.NewJit.Migrations
+{
+    public partial class NewJitPG_HQ_0110 : Migration
+    {
+        protected override void Up(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.CreateTable(
+                name: "FisBaseConfig",
+                columns: table => new
+                {
+                    Id = table.Column<Guid>(type: "uniqueidentifier", nullable: false),
+                    ParamName = table.Column<string>(type: "nvarchar(50)", maxLength: 50, nullable: true),
+                    ParamValue = table.Column<string>(type: "nvarchar(50)", maxLength: 50, nullable: true),
+                    State = table.Column<int>(type: "int", precision: 1, nullable: false),
+                    Remark = table.Column<string>(type: "nvarchar(500)", maxLength: 500, nullable: true),
+                    ExtraProperties = table.Column<string>(type: "nvarchar(max)", nullable: true),
+                    ConcurrencyStamp = table.Column<string>(type: "nvarchar(40)", maxLength: 40, nullable: true)
+                },
+                constraints: table =>
+                {
+                    table.PrimaryKey("PK_FisBaseConfig", x => x.Id);
+                });
+
+            migrationBuilder.CreateIndex(
+                name: "IX_FisBaseConfig_ParamName",
+                table: "FisBaseConfig",
+                column: "ParamName",
+                unique: true,
+                filter: "[ParamName] IS NOT NULL");
+        }
+
+        protected override void Down(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.DropTable(
+                name: "FisBaseConfig");
+        }
+    }
+}

src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.EntityFrameworkCore.DbMigrations/Migrations/20240115023640_NewJitPG_HQ_Init.cs

@@ -0,0 +1,33 @@
+using Microsoft.EntityFrameworkCore.Migrations;
+
+namespace WY.NewJit.Migrations
+{
+    public partial class NewJitPG_HQ_Init : Migration
+    {
+        protected override void Up(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.AddColumn<string>(
+                name: "ColorExplain",
+                table: "FisAssemblyCfgErp",
+                type: "nvarchar(max)",
+                nullable: true);
+
+            migrationBuilder.AddColumn<string>(
+                name: "SpecExplain",
+                table: "FisAssemblyCfgErp",
+                type: "nvarchar(max)",
+                nullable: true);
+        }
+
+        protected override void Down(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.DropColumn(
+                name: "ColorExplain",
+                table: "FisAssemblyCfgErp");
+
+            migrationBuilder.DropColumn(
+                name: "SpecExplain",
+                table: "FisAssemblyCfgErp");
+        }
+    }
+}

src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.EntityFrameworkCore.DbMigrations/Migrations/20240115024450_NewJitPG_HQ_Init2.cs

@@ -0,0 +1,53 @@
+using Microsoft.EntityFrameworkCore.Migrations;
+
+namespace WY.NewJit.Migrations
+{
+    public partial class NewJitPG_HQ_Init2 : Migration
+    {
+        protected override void Up(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.AlterColumn<string>(
+                name: "SpecExplain",
+                table: "FisAssemblyCfgErp",
+                type: "varchar(50)",
+                maxLength: 50,
+                nullable: true,
+                oldClrType: typeof(string),
+                oldType: "nvarchar(max)",
+                oldNullable: true);
+
+            migrationBuilder.AlterColumn<string>(
+                name: "ColorExplain",
+                table: "FisAssemblyCfgErp",
+                type: "varchar(50)",
+                maxLength: 50,
+                nullable: true,
+                oldClrType: typeof(string),
+                oldType: "nvarchar(max)",
+                oldNullable: true);
+        }
+
+        protected override void Down(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.AlterColumn<string>(
+                name: "SpecExplain",
+                table: "FisAssemblyCfgErp",
+                type: "nvarchar(max)",
+                nullable: true,
+                oldClrType: typeof(string),
+                oldType: "varchar(50)",
+                oldMaxLength: 50,
+                oldNullable: true);
+
+            migrationBuilder.AlterColumn<string>(
+                name: "ColorExplain",
+                table: "FisAssemblyCfgErp",
+                type: "nvarchar(max)",
+                nullable: true,
+                oldClrType: typeof(string),
+                oldType: "varchar(50)",
+                oldMaxLength: 50,
+                oldNullable: true);
+        }
+    }
+}

src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.EntityFrameworkCore.DbMigrations/Migrations/20240115055730_NewJitPG_HQ_Init3.cs

@@ -0,0 +1,35 @@
+using Microsoft.EntityFrameworkCore.Migrations;
+
+namespace WY.NewJit.Migrations
+{
+    public partial class NewJitPG_HQ_Init3 : Migration
+    {
+        protected override void Up(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.AddColumn<string>(
+                name: "ColorExplain",
+                table: "FisAssemblyCfgGroup",
+                type: "varchar(50)",
+                maxLength: 50,
+                nullable: true);
+
+            migrationBuilder.AddColumn<string>(
+                name: "SpecExplain",
+                table: "FisAssemblyCfgGroup",
+                type: "varchar(50)",
+                maxLength: 50,
+                nullable: true);
+        }
+
+        protected override void Down(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.DropColumn(
+                name: "ColorExplain",
+                table: "FisAssemblyCfgGroup");
+
+            migrationBuilder.DropColumn(
+                name: "SpecExplain",
+                table: "FisAssemblyCfgGroup");
+        }
+    }
+}

src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.EntityFrameworkCore.DbMigrations/Migrations/NewJitMigrationsDbContextModelSnapshot.cs

@@ -3287,6 +3287,10 @@ namespace WY.NewJit.Migrations
                         .ValueGeneratedOnAdd()
                         .HasColumnType("uniqueidentifier");
 
+                    b.Property<string>("ColorExplain")
+                        .HasMaxLength(50)
+                        .HasColumnType("varchar(50)");
+
                     b.Property<string>("ConcurrencyStamp")
                         .IsConcurrencyToken()
                         .HasMaxLength(40)
@@ -3351,6 +3355,10 @@ namespace WY.NewJit.Migrations
                         .HasMaxLength(50)
                         .HasColumnType("varchar(50)");
 
+                    b.Property<string>("SpecExplain")
+                        .HasMaxLength(50)
+                        .HasColumnType("varchar(50)");
+
                     b.Property<string>("VehicleModel")
                         .HasMaxLength(50)
                         .HasColumnType("varchar(50)");
@@ -3366,6 +3374,10 @@ namespace WY.NewJit.Migrations
                         .ValueGeneratedOnAdd()
                         .HasColumnType("uniqueidentifier");
 
+                    b.Property<string>("ColorExplain")
+                        .HasMaxLength(50)
+                        .HasColumnType("varchar(50)");
+
                     b.Property<string>("ConcurrencyStamp")
                         .IsConcurrencyToken()
                         .HasMaxLength(40)
@@ -3413,6 +3425,10 @@ namespace WY.NewJit.Migrations
                         .HasColumnType("uniqueidentifier")
                         .HasColumnName("LastModifierId");
 
+                    b.Property<string>("SpecExplain")
+                        .HasMaxLength(50)
+                        .HasColumnType("varchar(50)");
+
                     b.Property<string>("VehicleModel")
                         .HasColumnType("nvarchar(max)");
 
@@ -3619,6 +3635,47 @@ namespace WY.NewJit.Migrations
                     b.ToTable("FisAssemblyCfgVehicleChild");
                 });
 
+            modelBuilder.Entity("WY.NewJit.MsgBaseData.BaseConfig", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("uniqueidentifier");
+
+                    b.Property<string>("ConcurrencyStamp")
+                        .IsConcurrencyToken()
+                        .HasMaxLength(40)
+                        .HasColumnType("nvarchar(40)")
+                        .HasColumnName("ConcurrencyStamp");
+
+                    b.Property<string>("ExtraProperties")
+                        .HasColumnType("nvarchar(max)")
+                        .HasColumnName("ExtraProperties");
+
+                    b.Property<string>("ParamName")
+                        .HasMaxLength(50)
+                        .HasColumnType("nvarchar(50)");
+
+                    b.Property<string>("ParamValue")
+                        .HasMaxLength(50)
+                        .HasColumnType("nvarchar(50)");
+
+                    b.Property<string>("Remark")
+                        .HasMaxLength(500)
+                        .HasColumnType("nvarchar(500)");
+
+                    b.Property<int>("State")
+                        .HasPrecision(1)
+                        .HasColumnType("int");
+
+                    b.HasKey("Id");
+
+                    b.HasIndex("ParamName")
+                        .IsUnique()
+                        .HasFilter("[ParamName] IS NOT NULL");
+
+                    b.ToTable("FisBaseConfig");
+                });
+
             modelBuilder.Entity("WY.NewJit.MsgBaseData.DicItem", b =>
                 {
                     b.Property<Guid>("Id")

src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.EntityFrameworkCore/EntityFrameworkCore/NewJitDbContextModelCreatingExtensions.cs

@@ -73,8 +73,8 @@ namespace WY.NewJit.EntityFrameworkCore
                 b.Property(itm => itm.VehicleModel).HasColumnType("varchar").HasMaxLength(50);
                 b.Property(itm => itm.RelationKey).HasColumnType("varchar").HasMaxLength(50);
                 b.Property(itm => itm.GroupCode).HasColumnType("varchar").HasMaxLength(100);
-
+                b.Property(itm => itm.SpecExplain).HasColumnType("varchar").HasMaxLength(50);
-
+                b.Property(itm => itm.ColorExplain).HasColumnType("varchar").HasMaxLength(50);
             });
 
             builder.Entity<AssemblyCfgGroup>(b =>
@@ -83,6 +83,9 @@ namespace WY.NewJit.EntityFrameworkCore
                 b.ConfigureByConvention();//配置/映射继承的属性,应始终对你所有的实体使用它
 
                 b.Property(itm => itm.GroupCode).HasColumnType("varchar").HasMaxLength(100);
+                b.Property(itm => itm.SpecExplain).HasColumnType("varchar").HasMaxLength(50);
+                b.Property(itm => itm.ColorExplain).HasColumnType("varchar").HasMaxLength(50);
+
             });