流程一脚本提交

air_case/b5_spd3_core_business_flow/a_a4_流程四_基础模块设置.air/a_a4_流程四_基础模块设置.py

@@ -110,29 +110,47 @@ def import_goods(hosGoodsId):
     # print(username, password,'aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa')
     # 获取token和projectCode
     token, projectCode, uxid, corpId, info = login_system(username, password).get_token()
-    url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module, "importGoods_url")
+    #查询产品信息===========================================
+    url = commonFuc().get_api_url() + commonFuc().get_business_data(module, "mcmsBranchGoodsInfo_unBindPage_url")
 
     # 获取请求头信息
     headers = commonFuc().get_business_data(module, "json_headers2",
                                             commonFuc().get_business_data(module, "json_contentType"), token,
                                             commonFuc().get_business_data(module, "X-APP-CODE"))
-
     # 获取院区id
     branch_id = FileUtils().r_info(module, '院区新增')["branch_id"]
     while True:
         # #请求体
-        request_body = commonFuc().get_business_data(module, "payload35", hosGoodsId, branch_id)
+        request_body = commonFuc().get_business_data(module, "payload33_1", branch_id,hosGoodsId)
         print(request_body)
         # # # 发送请求
         result = commonFuc().http_post(url, request_body, headers)
-        print('导入新增的产品result', result)
-        code= commonFuc().analysis_json('code',result)
-        if code==1004:
-            time.sleep(10)
+        print('result', result)
+        total=commonFuc().analysis_json('total',result)
+        if total==0:
             continue
-        elif code==0:
+        else:
             break
 
+    # 查询产品信息=========================================
+    #导入院区产品
+    url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module, "importGoods_url")
+
+    # 获取请求头信息
+    headers = commonFuc().get_business_data(module, "json_headers2",
+                                            commonFuc().get_business_data(module, "json_contentType"), token,
+                                            commonFuc().get_business_data(module, "X-APP-CODE"))
+
+    # 获取院区id
+    branch_id = FileUtils().r_info(module, '院区新增')["branch_id"]
+
+    # #请求体
+    request_body = commonFuc().get_business_data(module, "payload35", hosGoodsId, branch_id)
+    print(request_body)
+    # # # 发送请求
+    result = commonFuc().http_post(url, request_body, headers)
+    print('导入新增的产品result', result)
+
 
 def  check_import_goods(hosGoodsId):
     module = "b2_herp3_bs"