250425-1代码。

utils/risk/__init__.py

@@ -47,9 +47,9 @@ FROM (
         AVG(a.`rainfall`) AS `rainfall`,
         ROW_NUMBER() OVER (PARTITION BY a.`code` ORDER BY a.`create_time` DESC) AS `rn`
     FROM 
-        `govdata_rain_data_info` a
+        sharedb.`govdata_rain_data_info` a
     LEFT JOIN 
-        `govdata_real_time_address` b ON a.`code` = b.`code`
+        sharedb.`govdata_real_time_address` b ON a.`code` = b.`code`
     WHERE 
         a.`address` LIKE '%茂名%'
     GROUP BY 
@@ -90,7 +90,7 @@ END,'0'))T2 on T1.`name`=T2.`name`;
 
 def get_rain_max_time(db):
     sql = text(f"""
-        SELECT MAX(CREATE_TIME) FROM govdata_rain_data_info;
+        SELECT MAX(CREATE_TIME) FROM sharedb.govdata_rain_data_info;
 """)
 
     sqlresult = db.execute(sql).first()[0]
@@ -123,9 +123,9 @@ FROM (
         AVG(a.`rainfall`) AS `rainfall`,
         ROW_NUMBER() OVER (PARTITION BY a.`code` ORDER BY a.`create_time` DESC) AS `rn`
     FROM 
-        `govdata_rain_data_info` a
+        sharedb.`govdata_rain_data_info` a
     LEFT JOIN 
-        `govdata_real_time_address` b ON a.`code` = b.`code`
+        sharedb.`govdata_real_time_address` b ON a.`code` = b.`code`
     WHERE 
         a.`address` LIKE '%茂名%'
     GROUP BY