DBC22-6929: pull local weather station code to current weather

Author: bcgov-brwang

src/backend/apps/consumer/processor.py

@@ -318,6 +318,7 @@ def process_camera_rows(rows):
             'cam_maintenanceis_on_demand': row.cam_maintenanceis_on_demand if hasattr(row, 'cam_maintenanceis_on_demand') else False,
             'is_new': row.isnew if hasattr(row, 'isnew') else False,
             'seq': row.seq if hasattr(row, 'seq') else 0,
+            'cam_locationsweather_station': row.cam_locationsweather_station if hasattr(row, 'cam_locationsweather_station') else '',
 
         }
         camera_list.append(camera_obj)

src/backend/apps/webcam/models.py

@@ -167,6 +167,7 @@ class CameraSource(models.Model):
     isnew = models.BooleanField(default=False)
     cam_maintenanceis_on_demand = models.BooleanField(default=False)
     seq = models.IntegerField(blank=True, null=True)
+    cam_locationsweather_station = models.CharField(max_length=10, blank=True, null=True)
 
     class Meta:
         db_table = 'Cams_Live'

src/backend/apps/webcam/tasks.py

@@ -99,6 +99,7 @@ def update_cam_from_sql_db(id: int, current_time: datetime.datetime):
                 credit=F('cam_internetcredit'),
                 dbc_mark=F('cam_internetdbc_mark'),
                 isNew=F('isnew'),
+                cam_locations_weather_station=F('cam_locationsweather_station'),
             )
             .values(
                 'id',
@@ -114,12 +115,15 @@ def update_cam_from_sql_db(id: int, current_time: datetime.datetime):
                 'credit',
                 'dbc_mark',
                 'isNew',
+                'cam_locations_weather_station',
             )
             .first()
         )
 
         if cam:
             update_webcam_db(id, cam)
+            print('bruce test here to get code')
+            update_current_weather_code(id, cam)
             return True
         else:
             return False
@@ -142,6 +146,16 @@ def format_region_name(region_name):
     return ''.join(result)
 
 
+def update_current_weather_code(cam_id: int, cam_data: dict):
+    cam = Webcam.objects.get(id=cam_id)
+    local_weather_station_id = cam.local_weather_station_id
+    code = cam_data.get("cam_locations_weather_station")
+    update_data = {
+        "code": code,
+    }
+    CurrentWeather.objects.filter(id=local_weather_station_id).update(**update_data)
+    return True
+
 def update_webcam_db(cam_id: int, cam_data: dict):
     time_now_utc = datetime.datetime.now(datetime.timezone.utc).strftime("%Y%m%d%H%M%S%f")[:-3]
     camera_status = calculate_camera_status(cam_id, time_now_utc)