Kaynağa Gözat

计算结果存储DOPbang

tangdi 3 yıl önce
ebeveyn
işleme
ab083cc5fa

+ 50 - 1
MicroServices/Business/Business.Application/ResourceExamineManagement/ResourceExamineAppService.cs

@@ -136,6 +136,14 @@ namespace Business.ResourceExamineManagement
         private readonly IMongoDB<mo_mes_oorder> _mes_oorder;
         private readonly IMongoDB<mo_mes_oorder> _mes_oorder;
         private IRepository<mes_oorder, long> _mysql_mes_oorder;
         private IRepository<mes_oorder, long> _mysql_mes_oorder;
 
 
+        private IRepository<b_examine_result, long> _mysql_examine_result;
+        private IRepository<b_bom_child_examine, long> _mysql_bom_child_examine;
+        private IRepository<b_mo_occupy, long> _mysql_mo_occupy;
+        private IRepository<b_mo_order, long> _mysql_mo_order;
+        private IRepository<b_ooder, long> _mysql_ooder;
+        private IRepository<b_purchase, long> _mysql_purchase;
+        private IRepository<b_purchase_occupy, long> _mysql_purchase_occupy;
+
         /// <summary>
         /// <summary>
         /// 物料质检表
         /// 物料质检表
         /// </summary>
         /// </summary>
@@ -271,6 +279,13 @@ namespace Business.ResourceExamineManagement
             IRepository<srm_po_occupy, long> mysql_srm_po_occupy,
             IRepository<srm_po_occupy, long> mysql_srm_po_occupy,
             IRepository<ic_item_pur, long> mysql_ic_item_pur,
             IRepository<ic_item_pur, long> mysql_ic_item_pur,
             IRepository<ic_plan, long> mysql_ic_plan,
             IRepository<ic_plan, long> mysql_ic_plan,
+            IRepository<b_examine_result, long> mysql_examine_result,
+            IRepository<b_bom_child_examine, long> mysql_bom_child_examine,
+            IRepository<b_mo_occupy, long> mysql_mo_occupy,
+            IRepository<b_mo_order, long> mysql_mo_order,
+            IRepository<b_ooder, long> mysql_ooder,
+            IRepository<b_purchase, long> mysql_purchase,
+            IRepository<b_purchase_occupy, long> mysql_purchase_occupy,
             PretreatmentAppService pretreatmentAppService,
             PretreatmentAppService pretreatmentAppService,
             CalcBomViewAppService calcbomviewAppService,
             CalcBomViewAppService calcbomviewAppService,
             PurchaseOrderAppService purchaseOrderAppService,
             PurchaseOrderAppService purchaseOrderAppService,
@@ -319,6 +334,13 @@ namespace Business.ResourceExamineManagement
             _mysql_srm_po_occupy = mysql_srm_po_occupy;
             _mysql_srm_po_occupy = mysql_srm_po_occupy;
             _mysql_ic_item_pur = mysql_ic_item_pur;
             _mysql_ic_item_pur = mysql_ic_item_pur;
             _mysql_ic_plan = mysql_ic_plan;
             _mysql_ic_plan = mysql_ic_plan;
+            _mysql_examine_result = mysql_examine_result;
+            _mysql_bom_child_examine = mysql_bom_child_examine;
+            _mysql_mo_occupy = mysql_mo_occupy;
+            _mysql_mo_order= mysql_mo_order;
+            _mysql_ooder=mysql_ooder;
+            _mysql_purchase = mysql_purchase;
+            _mysql_purchase_occupy = mysql_purchase_occupy;
             _pretreatmentAppService = pretreatmentAppService;
             _pretreatmentAppService = pretreatmentAppService;
             _CalcBomViewAppService = calcbomviewAppService;
             _CalcBomViewAppService = calcbomviewAppService;
             _purchaseOrderAppService = purchaseOrderAppService;
             _purchaseOrderAppService = purchaseOrderAppService;
@@ -622,7 +644,34 @@ namespace Business.ResourceExamineManagement
                     });*/
                     });*/
                 });
                 });
             }
             }
-
+            if (examineList.Any())
+            {
+                await _mysql_examine_result.InsertManyAsync(examineList);
+            }
+            if (bomExamineList.Any())
+            {
+                await _mysql_bom_child_examine.InsertManyAsync(bomExamineList);
+            }
+            if (mooccupyList.Any())
+            {
+                await _mysql_mo_occupy.InsertManyAsync(mooccupyList);
+            }
+            if (moorderList.Any())
+            {
+                await _mysql_mo_order.InsertManyAsync(moorderList);
+            }
+            if (ooderList.Any())
+            {
+                await _mysql_ooder.InsertManyAsync(ooderList);
+            }
+            if (purchaseList.Any())
+            {
+                await _mysql_purchase.InsertManyAsync(purchaseList);
+            }
+            if (purchaseoccupyList.Any())
+            {
+                await _mysql_purchase_occupy.InsertManyAsync(purchaseoccupyList);
+            }
             //清空快照数据
             //清空快照数据
             await ClearSnapShot(bangid);
             await ClearSnapShot(bangid);
             return JsonConvert.SerializeObject(rtn);
             return JsonConvert.SerializeObject(rtn);