优化脚本

air_case/b5_spd3_core_business_flow/a_a7流程五_中心库入库结算_正结算3_内网验收入库结算.air/a_a7流程五_中心库入库结算_正结算3_内网验收入库结算.py

@@ -118,13 +118,19 @@ def check_accept_order(type=1):
 
     sourceId = sourceOrderNo
     url = commonFuc().get_api_add_port_url() + commonFuc().get_business_data(module, "check_wait_detail_url")
-
+    print('url',url)
     request_body = commonFuc().get_business_data(module, "payload1", sourceId, sourceType, billMode, branch_id)
 
     # print('request_body',request_body)
     # 发送请求
-    time.sleep(6)
-    result = commonFuc().http_post(url, request_body, headers)
+    while True:
+        time.sleep(6)
+        result = commonFuc().http_post(url, request_body, headers)
+        code=commonFuc().analysis_json('code',result)
+        if code==0:
+            break
+        else:
+            print('数据未同步完成，等待6秒')
     print('result', result)
     # 断言
     data = commonFuc().analysis_json('data', result)

common/db/sql/sql_del_branch_info.py

@@ -217,6 +217,17 @@ class delData(object):
         cursor.execute("commit;")
         print('外网产品信息删除成功 ')
         cursor.close()
+    def Del_supply_relation(self):
+        connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2",
+                                     charset="utf8")
+        cursor = connection.cursor()
+        # 删除产品信息
+        sql = "delete from supply_relation where contact_way like '_____' and contact_user like '_____';"
+        print(sql)
+        cursor.execute(sql)
+        cursor.execute("commit;")
+        print('内网供应关系删除成功 ')
+        cursor.close()
 # delData().Delete_branch_by_id()
 # delData().Delete_goods_change_info()
 # delData().Delete_sys_config()