add level0_id

csst_dfs_api/msc/level2.py

@@ -14,6 +14,7 @@ class Level2DataApi(object):
         ''' retrieve level2 records from database
 
         :param kwargs: Parameter dictionary, key items support:
+            level0_id: [str]
             level1_id: [int]
             data_type: [str]
             create_time : (start, end),

csst_dfs_api/sls/level2spectra.py

@@ -13,6 +13,7 @@ class Level2SpectraApi(object):
         ''' retrieve level2 spectra records from database
 
         :param kwargs: Parameter dictionary, key items support:
+            level0_id: [str]
             level1_id: [int]
             spectra_id: [str]
             create_time : (start, end),
@@ -62,6 +63,7 @@ class Level2SpectraApi(object):
         ''' insert a level1 record into database
  
         :param kwargs: Parameter dictionary, key items support:
+            level0_id: [str]
             level1_id: [int]
             spectra_id : [str]
             region : [str]

tests/common/test_common_catalog.py

@@ -13,15 +13,16 @@ class CommonCatalogTestCase(unittest.TestCase):
     def test_catalog_query(self):
         t= time.time()
         result = self.api.catalog_query(
-            ra=193.2990269, # 15415
-            dec=0.038331050065405756, 
-            radius=2, 
+            ra=193, # 15415
+            dec=26, 
+            radius=0.1, 
             catalog_name='gaia3', 
             min_mag=-1, 
             max_mag=-1, 
             obstime = -1, 
-            limit = -1
+            limit = 1
         )
+        print(result)
         # dt = self.api.to_table(result)
         # df = dt.to_pandas()
         # print(df.head())

tests/msc/test_msc_level2co.py

+import os
+import unittest
+from astropy.io import fits
+
+from csst_dfs_api.msc.level2co import Level2CoApi
+
+class MSCLevel2CoDataTestCase(unittest.TestCase):
+
+    def setUp(self):
+        self.api = Level2CoApi()
+
+    def test_find(self):
+        recs = self.api.find(
+            level1_id=1,
+            create_time = ("2022-06-15 11:12:13","2022-06-16 11:12:13"))
+        print('find:', recs)
+
+    def test_catalog_query(self):
+        result = self.api.catalog_query(
+            obs_id='100000000',
+            obs_time = ("2021-05-24 11:12:13","2021-05-25 13:12:13"),
+            limit = 2)
+        if result.success:
+            dt = self.api.to_table(result)
+            dt.pprint()
+        else:
+            print(result)
+
+    def test_get(self):
+        rec = self.api.get(id = 1)
+        print('get:', rec)
+
+    def test_update_proc_status(self):
+        rec = self.api.update_proc_status(id = 1, status = 4)
+        print('update_proc_status:', rec)
+
+    def test_update_qc2_status(self):
+        rec = self.api.update_qc2_status(id = 1, status = 7)
+        print('update_qc2_status:', rec)
+
+    def test_write(self):
+        rec = self.api.write(
+            level1_id= 1, 
+            data_type = "sci",
+            prc_status = 3,
+            prc_time = '2021-10-22 11:12:13',
+            filename = "MSC_MS_210525120000_100000000_20_cat.fits",
+            file_path = "/opt/temp/csst/msc_data/MSC_MS_210525120000_100000000_20_cat.fits"
+            )
+        print('write:', rec)