added DFS APIs

csst_common/data_manager.py

@@ -11,6 +11,7 @@ Modified-History:
     2022-10-26, Bo Zhang, reconstruct CsstMsDataManager, deprecate CsstMbiDataManager
     2022-10-28, Bo Zhang, added CsstMsDataManager.query_rc(), dm.dfs_mode, dm.node
     2022-11-06, Bo Zhang, deleted CsstMbiDataManager
+    2022-11-20, Bo Zhang, added DFS APIs
 """
 import glob
 import os
@@ -19,6 +20,10 @@ from typing import Union
 
 from astropy.io import fits
 from astropy.table import Table
+from csst_dfs_api.msc.calmerge import CalMergeApi
+from csst_dfs_api.msc.level0 import Level0DataApi
+from csst_dfs_api.msc.level0prc import Level0PrcApi
+from csst_dfs_api.msc.level1 import Level1DataApi
 
 from .dfs import gaia_query_from_dfs
 from .logger import get_logger
@@ -214,6 +219,11 @@ class CsstMsDataManager:
         self.logger_mod = get_logger(name="CSST L1 Module Logger", filename=os.path.join(dir_l1, log_mod))
         self.logger_mod.info("logger_mod initialized")
 
+        self.dfs_L1DataApi = Level0DataApi()
+        self.dfs_L1DataApi = Level1DataApi()
+        self.dfs_L0PrcApi = Level0PrcApi()  # level0到level1的处理过程记录
+        self.dfs_CalApi = CalMergeApi()  # 参考文件合并文件操作API
+
     def set_env(self):
         """ set environment variables """
         if os.uname()[1] == "dandelion":
@@ -262,8 +272,8 @@ class CsstMsDataManager:
 
         # parse info
         _telescope, _instrument, _survey, _imagetype, \
-            _exp_start, _exp_stop, _exp_id, \
-            _detector, *_l0_post, _ext = re.split(r"[_.]", fps_img[0])
+        _exp_start, _exp_stop, _exp_id, \
+        _detector, *_l0_post, _ext = re.split(r"[_.]", fps_img[0])
 
         _exp_start = int(_exp_start)
         _exp_stop = int(_exp_stop)