数据库连接从公网改到内网

cms_class_20241201.py

@@ -119,7 +119,8 @@ class CMSAnalyst:
         
     def _get_by_id(self, windcode, ids):
         df_res = []
-        engine = create_engine('mysql+pymysql://root:admin123456@106.120.102.238:10336/energy_data_prod')
+        engine = create_engine('mysql+pymysql://root:admin123456@192.168.50.235:30306/energy_data_prod')
+     #   engine = create_engine('mysql+pymysql://root:admin123456@106.120.102.238:10336/energy_data_prod')
         for id in ids:
             table_name=windcode+'_wave'
             lastday_df_sql = f"SELECT * FROM {table_name} where id = {id} "
@@ -448,7 +449,8 @@ class CMSAnalyst:
         # 2、连接233的数据库'energy_show'，从表'wind_engine_group'查找风机编号'engine_code'对应的机型编号'mill_type_code'
         engine_code = self.wind_code
         print(engine_code)
-        Engine2 = create_engine('mysql+pymysql://admin:admin123456@106.120.102.238:16306/energy_show')
+        Engine2 = create_engine('mysql+pymysql://admin:admin123456@192.168.50.233:3306/energy_show')
+        #Engine2 = create_engine('mysql+pymysql://admin:admin123456@106.120.102.238:16306/energy_show')        
         # df_sql2 = f"SELECT * FROM {'wind_engine_group'} where engine_code = {'engine_code'} "
         df_sql2 = f"SELECT * FROM wind_engine_group WHERE engine_code = '{engine_code}'"
         df2 = pd.read_sql(df_sql2, Engine2)
@@ -469,7 +471,8 @@ class CMSAnalyst:
         # print(_model)
 
         # 3、从相关的表中通过机型编号'mill_type_code'或者齿轮箱编号gearbox_code查找部件'brand'、'model'的参数信息
-        Engine3 = create_engine('mysql+pymysql://admin:admin123456@106.120.102.238:16306/energy_show')
+        Engine3 = create_engine('mysql+pymysql://admin:admin123456@192.168.50.233:3306/energy_show')
+#      Engine3 = create_engine('mysql+pymysql://admin:admin123456@106.120.102.238:16306/energy_show')
         #unit_bearings主轴承参数表 关键词"main_bearing"
         if 'main_bearing' in str1:
             print("main_bearing")
@@ -547,7 +550,8 @@ class CMSAnalyst:
             df3 = pd.read_sql(df_sql3, Engine3)
             gearbox_code =df3['code'].iloc[0]
             print(gearbox_code)
-            Engine33 = create_engine('mysql+pymysql://admin:admin123456@106.120.102.238:16306/energy_show')
+            Engine33 = create_engine('mysql+pymysql://admin:admin123456@192.168.50.233:3306/energy_show')            
+            #Engine33 = create_engine('mysql+pymysql://admin:admin123456@106.120.102.238:16306/energy_show')
              #如果是行星轮/平行轮 则从unit_gearbox_structure 表中取数据
             if 'planet'in str1 or 'sun' in str1:
                 print("'planet' or 'sun' ")
@@ -656,7 +660,8 @@ class CMSAnalyst:
         # # result = json.dumps(result, ensure_ascii=False)
         #     return result
         # 4、从表'unit_dict_brand_model'中通过'_brand'、'_model'查找部件的参数信息
-        Engine4 = create_engine('mysql+pymysql://admin:admin123456@106.120.102.238:16306/energy_show')
+        Engine4 = create_engine('mysql+pymysql://admin:admin123456@192.168.50.233:3306/energy_show')
+    #    Engine4 = create_engine('mysql+pymysql://admin:admin123456@106.120.102.238:16306/energy_show')  
         df_sql4 = f"SELECT * FROM unit_dict_brand_model where manufacture = %s AND model_number = %s"
         params = [(_brand, _model)]
         df4 = pd.read_sql(df_sql4, Engine4, params=params)