资源检查数据同步调整

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

@@ -108,6 +108,8 @@ namespace Business.ResourceExamineManagement
         /// 物料库存表
         /// </summary>
         private readonly IMongoDB<ic_item_stock> _ic_item_stock;
+        private IRepository<ic_item_stock, long> _mysql_ic_item_stock;
+
         /// <summary>
         /// 物料质检表
         /// </summary>
@@ -170,7 +172,8 @@ namespace Business.ResourceExamineManagement
             IRepository<ic_bom_child, long> mysql_ic_bom_child,
             IRepository<mes_technique, long> mysql_mes_technique,
             IRepository<crm_seorder, long> mysql_crm_seorder,
-            IRepository<crm_seorderentry, long> mysql_crm_seorderentry
+            IRepository<crm_seorderentry, long> mysql_crm_seorderentry,
+            IRepository<ic_item_stock, long> mysql_ic_item_stock
             )
         {
             _mes_technique = mes_technique;
@@ -192,6 +195,7 @@ namespace Business.ResourceExamineManagement
             _mysql_ic_bom = mysql_ic_bom;
             _mysql_ic_bom_child = mysql_ic_bom_child;
             _mysql_mes_technique = mysql_mes_technique;
+            _mysql_ic_item_stock = mysql_ic_item_stock;
         }
 
         /// <summary>
@@ -255,14 +259,12 @@ namespace Business.ResourceExamineManagement
         /// <returns></returns>
         public async Task SyncData()
         {
-            var query = _mysql_mes_technique.GetQueryableAsync().Result.ToListAsync().Result;
-            await _mes_technique.InsertMany(query);
-            //var dt1 = DateTime.Now;
-            //var a = await _mysql_ic_bom.GetQueryableAsync();
-            //var query1 =await a.ToListAsync();
-            //await _ic_bom.InsertMany(query1);
-            //var dt2 = DateTime.Now;
-            //var c = 3;
+            //同步物料库存数据
+            var icitemStokc = _mysql_ic_item_stock.GetQueryableAsync().Result.ToListAsync().Result;
+            if (icitemStokc.Count > 0)
+            {
+                await _ic_item_stock.InsertMany(icitemStokc);
+            }
         }
 
         /// <summary>