Skip to content
GitLab
Commit 78b3d002 authored by liguangyu06's avatar liguangyu06
Browse files

调整内网和报表的数据库

parent b1e36d8a
Hide whitespace changes
Inline Side-by-side
common/db/sql/sql_del_branch_info.py
View file @ 78b3d002
...@@ -10,7 +10,11 @@ from common.fileUtls import FileUtils ...@@ -10,7 +10,11 @@ from common.fileUtls import FileUtils
class delData(object): class delData(object):
def Delete_branch_by_id(self,type=1,id='id'): 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", # 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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 删除新增的院区数据,减少垃圾数据的产生,保证脚本下次还可以正常运行,接口脚本每次都使用新增数据 # 删除新增的院区数据,减少垃圾数据的产生,保证脚本下次还可以正常运行,接口脚本每次都使用新增数据
...@@ -50,7 +54,11 @@ class delData(object): ...@@ -50,7 +54,11 @@ class delData(object):
cursor.close() cursor.close()
def Delete_goods_change_info(self): 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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 删除产品信息修改数据 # 删除产品信息修改数据
...@@ -62,7 +70,11 @@ class delData(object): ...@@ -62,7 +70,11 @@ class delData(object):
cursor.close() cursor.close()
def Delete_sys_config(self): 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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 删除产品信息修改数据 # 删除产品信息修改数据
...@@ -74,7 +86,11 @@ class delData(object): ...@@ -74,7 +86,11 @@ class delData(object):
cursor.close() cursor.close()
def Delete_sysrAtomDet(self): 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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 删除产品信息修改数据 # 删除产品信息修改数据
...@@ -86,7 +102,11 @@ class delData(object): ...@@ -86,7 +102,11 @@ class delData(object):
cursor.close() cursor.close()
def Delete_sys_message_template(self): 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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 删除产品信息修改数据 # 删除产品信息修改数据
...@@ -98,7 +118,11 @@ class delData(object): ...@@ -98,7 +118,11 @@ class delData(object):
cursor.close() cursor.close()
def Delete_goods_pur_template(self): 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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 删除产品信息修改数据 # 删除产品信息修改数据
...@@ -110,7 +134,11 @@ class delData(object): ...@@ -110,7 +134,11 @@ class delData(object):
cursor.close() cursor.close()
def get_shelf_name_version(self): 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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 获取库区version # 获取库区version
...@@ -127,7 +155,11 @@ class delData(object): ...@@ -127,7 +155,11 @@ class delData(object):
return new_str1 return new_str1
def Delete_probeInfo(self): 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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
...@@ -153,7 +185,11 @@ class delData(object): ...@@ -153,7 +185,11 @@ class delData(object):
cursor.close() cursor.close()
def Delete_probeInfo_other(self,type=1,branch_id='branch_id'): 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", # 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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 删除多余库房信息 # 删除多余库房信息
...@@ -170,7 +206,11 @@ class delData(object): ...@@ -170,7 +206,11 @@ class delData(object):
cursor.close() cursor.close()
def Delete_role(self): 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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 删除角色信息 # 删除角色信息
...@@ -182,7 +222,11 @@ class delData(object): ...@@ -182,7 +222,11 @@ class delData(object):
cursor.close() cursor.close()
def Delete_user(self): 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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 删除用户信息 # 删除用户信息
...@@ -194,7 +238,11 @@ class delData(object): ...@@ -194,7 +238,11 @@ class delData(object):
cursor.close() cursor.close()
def Delete_lcTask(self): 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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 删除用户信息 # 删除用户信息
...@@ -211,7 +259,11 @@ class delData(object): ...@@ -211,7 +259,11 @@ class delData(object):
cursor.close() cursor.close()
def Delete_ld_directory(self): 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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 删除用户信息 # 删除用户信息
...@@ -229,7 +281,11 @@ class delData(object): ...@@ -229,7 +281,11 @@ class delData(object):
def Del_goods_info(self, goodsid): 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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 删除产品信息 # 删除产品信息
...@@ -251,7 +307,11 @@ class delData(object): ...@@ -251,7 +307,11 @@ class delData(object):
cursor.close() cursor.close()
def Del_supply_relation(self): 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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 删除供应关系 # 删除供应关系
...@@ -270,7 +330,11 @@ class delData(object): ...@@ -270,7 +330,11 @@ class delData(object):
print('内网供应关系删除成功 ') print('内网供应关系删除成功 ')
cursor.close() cursor.close()
def Del_supply_relation1(self): 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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 删除供应关系 # 删除供应关系
...@@ -283,7 +347,7 @@ class delData(object): ...@@ -283,7 +347,7 @@ class delData(object):
cursor.close() cursor.close()
def Del_reporter_data(self,type=1,branch_id='branch_id'): def Del_reporter_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.49", port=30017, user="root", password="H-pV2d-1-N0z",
database="spd3_report_hospitaltest2", database="spd3_report_hospitaltest2",
charset="utf8") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
...@@ -315,7 +379,11 @@ class delData(object): ...@@ -315,7 +379,11 @@ class delData(object):
def Delete_business_Data(self,type=1,branch_id='branch_id'): 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", database="spd3_herp_test2",
charset="utf8") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
...@@ -482,7 +550,11 @@ class delData(object): ...@@ -482,7 +550,11 @@ class delData(object):
def Delete_business_Data_current_branch(self,type=1,branch_id='branch_id'): 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", database="spd3_herp_test2",
charset="utf8") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
...@@ -655,7 +727,11 @@ class delData(object): ...@@ -655,7 +727,11 @@ class delData(object):
print('外网边仓删除成功') print('外网边仓删除成功')
cursor.close() 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", database="spd3_herp_test2",
charset="utf8") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
...@@ -669,7 +745,11 @@ class delData(object): ...@@ -669,7 +745,11 @@ class delData(object):
def Delete_business_Data_All(self): 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", database="spd3_herp_test2",
charset="utf8") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
...@@ -864,7 +944,11 @@ class delData(object): ...@@ -864,7 +944,11 @@ class delData(object):
def Del_goods_info_all(self): 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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
hosGoodsId1 = FileUtils().r_info8("b5_spd3_core_business_flow", "产品审核信息", 'message1')['hosGoodsId'] hosGoodsId1 = FileUtils().r_info8("b5_spd3_core_business_flow", "产品审核信息", 'message1')['hosGoodsId']
...@@ -899,7 +983,11 @@ class delData(object): ...@@ -899,7 +983,11 @@ class delData(object):
def check_goods_info(self,hos_goods_id): 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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 查询产品信息 # 查询产品信息
...@@ -964,7 +1052,11 @@ class delData(object): ...@@ -964,7 +1052,11 @@ class delData(object):
return s return s
def get_orgCode(self): 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") charset="utf8")
branch_id = FileUtils().r_info8('b2_herp3_bs', "院区新增", 'message')['branch_id'] branch_id = FileUtils().r_info8('b2_herp3_bs', "院区新增", 'message')['branch_id']
...@@ -978,7 +1070,11 @@ class delData(object): ...@@ -978,7 +1070,11 @@ class delData(object):
return s return s
def get_orgName(self): 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") charset="utf8")
branch_id = FileUtils().r_info8('b2_herp3_bs', "院区新增", 'message')['branch_id'] branch_id = FileUtils().r_info8('b2_herp3_bs', "院区新增", 'message')['branch_id']
...@@ -992,7 +1088,11 @@ class delData(object): ...@@ -992,7 +1088,11 @@ class delData(object):
return s return s
def del_mcms_stock_user(self,user_code,dept_id): 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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 删除库区用户 # 删除库区用户
...@@ -1003,7 +1103,11 @@ class delData(object): ...@@ -1003,7 +1103,11 @@ class delData(object):
cursor.close() cursor.close()
def get_branch_id_bydb(self,no_branch_id): 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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 查询脚本创建的的院区 # 查询脚本创建的的院区
......
common/db/sql/sql_del_kind_goodsinfo.py
View file @ 78b3d002
...@@ -6,7 +6,11 @@ import pymysql ...@@ -6,7 +6,11 @@ import pymysql
class delKindGoodsinfo(object): class delKindGoodsinfo(object):
def delKindGoodsinfo(self): def delKindGoodsinfo(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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 删除耗材分类下的产品，便于脚本下次执行时再次添加产品信息到该耗材分类中 # 删除耗材分类下的产品，便于脚本下次执行时再次添加产品信息到该耗材分类中
...@@ -17,7 +21,11 @@ class delKindGoodsinfo(object): ...@@ -17,7 +21,11 @@ class delKindGoodsinfo(object):
print('耗材分类下的产品删除完毕' ) print('耗材分类下的产品删除完毕' )
cursor.close() cursor.close()
def delkind(self): def delkind(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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 删除耗材分类下的产品，便于脚本下次执行时再次添加产品信息到该耗材分类中 # 删除耗材分类下的产品，便于脚本下次执行时再次添加产品信息到该耗材分类中
......
common/db/sql/sql_del_notices_info.py
View file @ 78b3d002
...@@ -6,7 +6,11 @@ import pymysql ...@@ -6,7 +6,11 @@ import pymysql
class delByNoticeName(object): class delByNoticeName(object):
def delete_ByNoticeName(self): def delete_ByNoticeName(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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 删除新增的院区数据,减少垃圾数据的产生,保证脚本下次还可以正常运行,接口脚本每次都使用新增数据 # 删除新增的院区数据,减少垃圾数据的产生,保证脚本下次还可以正常运行,接口脚本每次都使用新增数据
......
common/db/sql/sql_get_info.py
View file @ 78b3d002
...@@ -6,7 +6,11 @@ import pymysql ...@@ -6,7 +6,11 @@ import pymysql
class sql_get_info(object): class sql_get_info(object):
def get_mcms_stock_info(self,stock_name="东土城院区中心库房"): def get_mcms_stock_info(self,stock_name="东土城院区中心库房"):
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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 删除新增的院区数据,减少垃圾数据的产生,保证脚本下次还可以正常运行,接口脚本每次都使用新增数据 # 删除新增的院区数据,减少垃圾数据的产生,保证脚本下次还可以正常运行,接口脚本每次都使用新增数据
...@@ -25,7 +29,11 @@ class sql_get_info(object): ...@@ -25,7 +29,11 @@ class sql_get_info(object):
def get_mcms_stock_shelf_info(self,stock_id): def get_mcms_stock_shelf_info(self,stock_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") charset="utf8")
cursor = connection.cursor() cursor = connection.cursor()
# 删除产品信息修改数据 # 删除产品信息修改数据
......
common/db/sql/sql_tools.py
View file @ 78b3d002
...@@ -6,7 +6,10 @@ from common.fileUtls import FileUtils ...@@ -6,7 +6,10 @@ from common.fileUtls import FileUtils
def get_db(): def get_db():
# 打开数据库连接 # 打开数据库连接
db = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2", # db = pymysql.connect(host="10.17.65.108", user="root", password="Cmic.2023", database="spd3_herp_test2",
# charset="utf8")
# 调整内网数据库
db = pymysql.connect(host="10.17.65.49", port=30017, user="root", password="H-pV2d-1-N0z", database="spd3_herp_test2",
charset="utf8") charset="utf8")
return db return db
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment