From b785d61589c3ff02e418cb80666bcbb7c9bb9a81 Mon Sep 17 00:00:00 2001 From: liguangyu06 <1666071293@qq.com> Date: Thu, 6 Feb 2025 09:03:35 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4=E5=86=85=E7=BD=91=E5=92=8C?= =?UTF-8?q?=E6=8A=A5=E8=A1=A8=E7=9A=84=E6=95=B0=E6=8D=AE=E5=BA=93?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- common/db/sql/sql_del_branch_info.py | 168 ++++++++++++++++++++++----- 1 file changed, 138 insertions(+), 30 deletions(-) diff --git a/common/db/sql/sql_del_branch_info.py b/common/db/sql/sql_del_branch_info.py index fec8086a..659917f6 100644 --- a/common/db/sql/sql_del_branch_info.py +++ b/common/db/sql/sql_del_branch_info.py @@ -9,8 +9,12 @@ from common.fileUtls import FileUtils class delData(object): - def Delete_branch_by_id(self,type=1,id='id'): - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + def Delete_branch_by_id(self, type=1, id='id'): + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", + database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() # 删除新增的院区数据,减少垃圾数据的产生,保证脚本下次还可以正常运行,接口脚本每次都使用新增数据 @@ -50,7 +54,11 @@ class delData(object): cursor.close() def Delete_goods_change_info(self): - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", + database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() # 删除产品信息修改数据 @@ -62,7 +70,11 @@ class delData(object): cursor.close() def Delete_sys_config(self): - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", + database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() # 删除产品信息修改数据 @@ -74,7 +86,11 @@ class delData(object): cursor.close() def Delete_sysrAtomDet(self): - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", + database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() # 删除产品信息修改数据 @@ -86,7 +102,11 @@ class delData(object): cursor.close() def Delete_sys_message_template(self): - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", + database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() # 删除产品信息修改数据 @@ -98,7 +118,11 @@ class delData(object): cursor.close() def Delete_goods_pur_template(self): - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", + database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() # 删除产品信息修改数据 @@ -110,7 +134,11 @@ class delData(object): cursor.close() def get_shelf_name_version(self): - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", + database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() # 获取库区version @@ -127,7 +155,11 @@ class delData(object): return new_str1 def Delete_probeInfo(self): - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", + database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() @@ -152,8 +184,12 @@ class delData(object): # print('多余库房信息删除成功 ') cursor.close() - def Delete_probeInfo_other(self,type=1,branch_id='branch_id'): - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + def Delete_probeInfo_other(self, type=1, branch_id='branch_id'): + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", + database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() # 删除多余库房信息 @@ -170,7 +206,11 @@ class delData(object): cursor.close() def Delete_role(self): - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", + database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() # 删除角色信息 @@ -182,7 +222,11 @@ class delData(object): cursor.close() def Delete_user(self): - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", + database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() # 删除用户信息 @@ -194,7 +238,11 @@ class delData(object): cursor.close() def Delete_lcTask(self): - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", + database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() # 删除用户信息 @@ -211,7 +259,11 @@ class delData(object): cursor.close() def Delete_ld_directory(self): - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", + database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() # 删除用户信息 @@ -229,7 +281,11 @@ class delData(object): def Del_goods_info(self, goodsid): # 内网的 - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", + database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() # 删除产品信息 @@ -251,7 +307,11 @@ class delData(object): cursor.close() def Del_supply_relation(self): - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", + database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() # 删除供应关系 @@ -269,8 +329,13 @@ class delData(object): cursor.execute("commit;") print('内网供应关系删除成功 ') cursor.close() + def Del_supply_relation1(self): - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", + database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() # 删除供应关系 @@ -282,8 +347,11 @@ class delData(object): print('内网供应关系删除成功 ') cursor.close() - def Del_reporter_data(self,type=1,branch_id='branch_id'): - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", + def Del_reporter_data(self, type=1, branch_id='branch_id'): + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", + # database="spd3_report_hospitaltest2", + # charset="utf8") + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", database="spd3_report_hospitaltest2", charset="utf8") cursor = connection.cursor() @@ -315,7 +383,11 @@ class delData(object): def Delete_business_Data(self,type=1,branch_id='branch_id'): # 删除业务数据，包括采购，出入库，结算等 - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", + # database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() @@ -482,7 +554,11 @@ class delData(object): def Delete_business_Data_current_branch(self,type=1,branch_id='branch_id'): # 删除业务数据，包括采购，出入库，结算等 - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", + # database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() @@ -655,7 +731,11 @@ class delData(object): print('外网边仓删除成功') cursor.close() - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", + # database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() @@ -669,7 +749,11 @@ class delData(object): def Delete_business_Data_All(self): # 获取院区数据 - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", + # database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() @@ -864,7 +948,11 @@ class delData(object): def Del_goods_info_all(self): # 内网的 - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", + database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() hosGoodsId1 = FileUtils().r_info8("b5_spd3_core_business_flow", "产品审核信息", 'message1')['hosGoodsId'] @@ -899,7 +987,11 @@ class delData(object): def check_goods_info(self,hos_goods_id): # 内网的 - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", + database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() # 查询产品信息 @@ -964,7 +1056,11 @@ class delData(object): return s def get_orgCode(self): - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", + database="spd3_herp_test2", charset="utf8") branch_id = FileUtils().r_info8('b2_herp3_bs', "院区新增", 'message')['branch_id'] @@ -978,7 +1074,11 @@ class delData(object): return s def get_orgName(self): - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", + database="spd3_herp_test2", charset="utf8") branch_id = FileUtils().r_info8('b2_herp3_bs', "院区新增", 'message')['branch_id'] @@ -992,7 +1092,11 @@ class delData(object): return s def del_mcms_stock_user(self,user_code,dept_id): # 内网的 - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", + database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() # 删除库区用户 @@ -1003,7 +1107,11 @@ class delData(object): cursor.close() def get_branch_id_bydb(self,no_branch_id): # 内网的 - connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # connection = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", + # charset="utf8") + # 内网切换数据库 + connection = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", + database="spd3_herp_test2", charset="utf8") cursor = connection.cursor() # 查询脚本创建的的院区 -- GitLab