实时数据同步调整

MicroServices/Business/Business.Application/ResourceExamineManagement/ResourceExamineAppService.cs

@@ -35,6 +35,7 @@ using System.ComponentModel.Design;
 using Volo.Abp.Validation.StringValues;
 using System.Runtime.CompilerServices;
 using MongoDB.Driver;
+using Volo.Abp.Validation.Localization;
 
 namespace Business.ResourceExamineManagement
 {
@@ -237,13 +238,13 @@ namespace Business.ResourceExamineManagement
         public async Task<PschedDto> ReceiveResult(SeorderentryDto input)
         {
             //数据库快照-同步mysql库数据到mongoDB中
-            //await SyncData();
+            await SyncData();
             //生成当前计算bangid
-            SnowFlake snow = new SnowFlake();
-            long bangid = snow.NextId();
+            //SnowFlake snow = new SnowFlake();
+            //long bangid = snow.NextId();
 
-            //产能检查
-            await ProductiveExamine(1733221167209762816, 100);
+            ////产能检查
+            //await ProductiveExamine(1733221167209762816, 100);
             return null;
             throw new NotImplementedException();
         }
@@ -254,8 +255,13 @@ namespace Business.ResourceExamineManagement
         /// <returns></returns>
         public async Task SyncData()
         {
-            var query = _mysql_mes_technique.GetQueryableAsync().Result.ToListAsync().Result;
-            await _mes_technique.InsertMany(query);
+            //var query = _mysql_mes_technique.GetQueryableAsync().Result.ToListAsync().Result;
+            //await _mes_technique.InsertMany(query);
+            var dt1 = DateTime.Now;
+            var query = _mysql_ic_bom_child.GetQueryableAsync().Result.ToListAsync().Result;
+            await _ic_bom_child.InsertMany(query);
+            var dt2 = DateTime.Now;
+            var c = 3;
         }
 
         /// <summary>
@@ -697,7 +703,7 @@ namespace Business.ResourceExamineManagement
         }
 
         /// <summary>
-        /// 计算库存量
+        /// 计算物料库存量
         /// </summary>
         /// <param name="returnlist"></param>
         public void BomStock(List<BomChildExamineDto> returnlist,long bangid,long orderid,long orderentryid, long factoryid)

MicroServices/Business/Bussiness.Model/MES/IC/ic_bom_child.cs

@@ -1,6 +1,7 @@
 using Business.Core.Attributes;
 using Business.Model;
 using Microsoft.EntityFrameworkCore;
+using MongoDB.Bson.Serialization.Attributes;
 using System.ComponentModel;
 using System.ComponentModel.DataAnnotations;
 
@@ -138,11 +139,13 @@ namespace Bussiness.Model.MES.IC
         /// 操作时间
         /// </summary>
         [Description("操作时间")]
+        [BsonIgnore]
         public DateTime? op_time { get; set; }
         /// <summary>
         /// 序号
         /// </summary>
         [Description("序号")]
+        [BsonIgnore]
         public int child_num { get; set; }
     }
 }