流程五脚本提交

air_case/b6_spd3_core_business_flow_database_check/a_a3_流程三_产品导入和审批_数据库验证.air/a_a3_流程三_产品导入和审批_数据库验证.py

@@ -19,20 +19,25 @@ import sys
 
 def check_mcms_goods_info(type=1):
     print('检查审批前的产品信息')
-    if type == 1:
-        hos_goods_id = FileUtils().r_info8('b5_spd3_core_business_flow', '产品审核信息', 'message1')["hosGoodsId"]
-    elif type == 2:
-        hos_goods_id = FileUtils().r_info8('b5_spd3_core_business_flow', '产品审核信息', 'message2')["hosGoodsId"]
-    elif type == 3:
-        hos_goods_id = FileUtils().r_info8('b5_spd3_core_business_flow', '产品审核信息', 'message3')["hosGoodsId"]
-    elif type == 4:
-        hos_goods_id = FileUtils().r_info8('b5_spd3_core_business_flow', '产品审核信息', 'message4')["hosGoodsId"]
-    elif type == 5:
-        hos_goods_id = FileUtils().r_info8('b5_spd3_core_business_flow', '产品审核信息', 'message5')["hosGoodsId"]
-    else:
+    try:
+        if type == 1:
+            hos_goods_id = FileUtils().r_info8('b5_spd3_core_business_flow', '产品审核信息', 'message1')["hosGoodsId"]
+        elif type == 2:
+            hos_goods_id = FileUtils().r_info8('b5_spd3_core_business_flow', '产品审核信息', 'message2')["hosGoodsId"]
+        elif type == 3:
+            hos_goods_id = FileUtils().r_info8('b5_spd3_core_business_flow', '产品审核信息', 'message3')["hosGoodsId"]
+        elif type == 4:
+            hos_goods_id = FileUtils().r_info8('b5_spd3_core_business_flow', '产品审核信息', 'message4')["hosGoodsId"]
+        elif type == 5:
+            hos_goods_id = FileUtils().r_info8('b5_spd3_core_business_flow', '产品审核信息', 'message5')["hosGoodsId"]
+        else:
+            hos_goods_id = 'hos_goods_id'
+        # if hos_goods_id==None:
+        #     print('产品信息还未写入文件，请检查脚本')
+        #     sys.exit(0)
+    except Exception as e:
+        print("发生异常：", str(e))
         hos_goods_id = 'hos_goods_id'
-    if hos_goods_id==None:
-        print('产品信息还未写入文件，请检查脚本')
         sys.exit(0)
     branch_id = get_branch_id()
     sql1 = "select * from spd_ybtest_hdi.mcms_goods_info where id='%s';" % hos_goods_id