资源检查调整

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

@@ -49,6 +49,7 @@ namespace Business.ResourceExamineManagement
         /// 工艺路径
         /// </summary>
         private readonly IMongoDB<mes_technique> _mes_technique;
+        private IRepository<mes_technique, long> _mysql_mes_technique;
 
         /// <summary>
         /// 工序
@@ -84,18 +85,18 @@ namespace Business.ResourceExamineManagement
         /// 物料详情
         /// </summary>
         private readonly IMongoDB<ic_item> _ic_item;
-        private IBasicRepository<ic_item, long> _mysql_ic_item;
+        private IRepository<ic_item, long> _mysql_ic_item;
 
         /// <summary>
         /// 物料BOM
         /// </summary>
         private readonly IMongoDB<ic_bom> _ic_bom;
-        private IBasicRepository<ic_bom, long> _mysql_ic_bom;
+        private IRepository<ic_bom, long> _mysql_ic_bom;
         /// <summary>
         /// 物料BOM明细
         /// </summary>
         private readonly IMongoDB<ic_bom_child> _ic_bom_child;
-        private IBasicRepository<ic_bom_child, long> _mysql_ic_bom_child;
+        private IRepository<ic_bom_child, long> _mysql_ic_bom_child;
 
         /// <summary>
         /// 物料库存表
@@ -154,9 +155,10 @@ namespace Business.ResourceExamineManagement
             //IMongoDB<ic_substitute_all_dtl> ic_substitute_all_dtl,
             IMongoDB<mes_morder> mes_morder,
             IMongoDB<mes_mooccupy> mes_mooccupy,
-            IBasicRepository<ic_item, long> mysql_ic_item,
-            IBasicRepository<ic_bom, long> mysql_ic_bom,
-            IBasicRepository<ic_bom_child, long> mysql_ic_bom_child
+            IRepository<ic_item, long> mysql_ic_item,
+            IRepository<ic_bom, long> mysql_ic_bom,
+            IRepository<ic_bom_child, long> mysql_ic_bom_child,
+            IRepository<mes_technique, long> mysql_mes_technique
 
             )
         {
@@ -176,6 +178,7 @@ namespace Business.ResourceExamineManagement
             _mysql_ic_item = mysql_ic_item;
             _mysql_ic_bom = mysql_ic_bom;
             _mysql_ic_bom_child = mysql_ic_bom_child;
+            _mysql_mes_technique = mysql_mes_technique;
         }
 
         /// <summary>
@@ -223,10 +226,22 @@ namespace Business.ResourceExamineManagement
         {
             //测试代码
             //await test();
+            //同步数据测试方法
+            //await SyncData();
+
             await ProductiveExamine(1733221167209762816,100);
             return null;
             throw new NotImplementedException();
+        }
 
+        /// <summary>
+        /// 同步数据
+        /// </summary>
+        /// <returns></returns>
+        public async Task SyncData()
+        {
+            var query =  _mysql_mes_technique.GetQueryableAsync().Result.ToListAsync().Result;
+            await _mes_technique.InsertMany(query);
         }
 
         /// <summary>