|
@@ -353,11 +353,11 @@ class CMSAnalyst:
|
|
# 2、连接233的数据库'energy_show',从表'wind_engine_group'查找风机编号'engine_code'对应的机型编号'mill_type_code'
|
|
# 2、连接233的数据库'energy_show',从表'wind_engine_group'查找风机编号'engine_code'对应的机型编号'mill_type_code'
|
|
engine = get_engine(dataBase.PLATFORM_DB)
|
|
engine = get_engine(dataBase.PLATFORM_DB)
|
|
engine_code = self.wind_code
|
|
engine_code = self.wind_code
|
|
- 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, engine)
|
|
df2 = pd.read_sql(df_sql2, engine)
|
|
mill_type_code = df2['mill_type_code'].iloc[0]
|
|
mill_type_code = df2['mill_type_code'].iloc[0]
|
|
# 3、从表'unit_bearings'中通过机型编号'mill_type_code'查找部件'brand'、'model'的参数信息
|
|
# 3、从表'unit_bearings'中通过机型编号'mill_type_code'查找部件'brand'、'model'的参数信息
|
|
- df_sql3 = f"SELECT * FROM unit_bearings where mill_type_code = {mill_type_code} "
|
|
|
|
|
|
+ df_sql3 = f"SELECT * FROM unit_bearings where mill_type_code = {'mill_type_code'} "
|
|
df3 = pd.read_sql(df_sql3, engine)
|
|
df3 = pd.read_sql(df_sql3, engine)
|
|
brand = 'front_bearing' + '_brand' # parts代替'front_bearing'
|
|
brand = 'front_bearing' + '_brand' # parts代替'front_bearing'
|
|
model = 'front_bearing' + '_model' # parts代替'front_bearing'
|
|
model = 'front_bearing' + '_model' # parts代替'front_bearing'
|