数据同步到mongodb调整

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

@@ -173,17 +173,17 @@ namespace Business.SyncDataManagement
                 //插入数据
                 await _ic_bom_child.InsertMany(moIcbom_childs);
             }
-/*
-            //工厂物料明细表
-            var ic_factory_details = _mysql_ic_factory_details.GetListAsync().Result;
-            if (ic_factory_details.Count > 0)
-            {
-                //先清空表数据
-                await _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());
-                await _ic_factory_details.InsertMany(moIc_factory_details);
-            }
+
+            ////工厂物料明细表
+            //var ic_factory_details = _mysql_ic_factory_details.GetListAsync().Result;
+            //if (ic_factory_details.Count > 0)
+            //{
+            //    //先清空表数据
+            //    await _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());
+            //    await _ic_factory_details.InsertMany(moIc_factory_details);
+            //}
 
             //同步物料数据
             var icItems = _mysql_ic_item.GetListAsync().Result;
@@ -282,16 +282,16 @@ namespace Business.SyncDataManagement
             }
 
 
-            //物料采购计划表
-            var ic_plan = _mysql_ic_plan.GetListAsync().Result;
-            if (ic_plan.Count > 0)
-            {
-                //先清空表数据
-                await _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());
-                await _ic_plan.InsertMany(moIc_plan);
-            }
+            ////物料采购计划表
+            //var ic_plan = _mysql_ic_plan.GetListAsync().Result;
+            //if (ic_plan.Count > 0)
+            //{
+            //    //先清空表数据
+            //    await _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());
+            //    await _ic_plan.InsertMany(moIc_plan);
+            //}
 
             //物料采购报价单
             var srm_purchase = _mysql_srm_purchase.GetListAsync().Result;
@@ -302,7 +302,7 @@ namespace Business.SyncDataManagement
                 var mosrm_purchase = ObjectMapper.Map<List<srm_purchase>, List<mo_srm_purchase>>(srm_purchase);
                 mosrm_purchase.ForEach(s => s.id = help.NextId());
                 await _srm_purchase.InsertMany(mosrm_purchase);
-            }*/
+            }
         }
     }
 }