Commit ce424fdd authored by Zhang Xin's avatar Zhang Xin
Browse files

crs ref file miss bug; modify obs type

parent eba9a6c2
...@@ -29,6 +29,7 @@ class ChipOutput(object): ...@@ -29,6 +29,7 @@ class ChipOutput(object):
project_cycle=self.config["project_cycle"], project_cycle=self.config["project_cycle"],
run_counter=self.config["run_counter"], run_counter=self.config["run_counter"],
chip_name=self.chip_label, chip_name=self.chip_label,
obstype=pointing.pointing_type,
dataset=pointing.dataset) dataset=pointing.dataset)
obs_id = _util.get_obs_id(img_type=self.pointing_type, project_cycle=config["project_cycle"], run_counter=config[ obs_id = _util.get_obs_id(img_type=self.pointing_type, project_cycle=config["project_cycle"], run_counter=config[
...@@ -71,7 +72,7 @@ class ChipOutput(object): ...@@ -71,7 +72,7 @@ class ChipOutput(object):
self.hdr += additional_column_names self.hdr += additional_column_names
def create_output_file(self): def create_output_file(self):
if self.pointing_type == 'SCI': if self.pointing_type == 'WIDE' or self.pointing_type == 'DEEP':
self.cat = open(os.path.join(self.subdir, self.cat_name), "w") self.cat = open(os.path.join(self.subdir, self.cat_name), "w")
self.logger.info("Creating catalog file %s ...\n" % self.logger.info("Creating catalog file %s ...\n" %
(os.path.join(self.subdir, self.cat_name))) (os.path.join(self.subdir, self.cat_name)))
......
...@@ -10,7 +10,7 @@ import observation_sim.instruments._util as _util ...@@ -10,7 +10,7 @@ import observation_sim.instruments._util as _util
class Pointing(object): class Pointing(object):
def __init__(self, id=0, ra=0., dec=0., img_pa=0., timestamp=1621915200, sat_x=0., sat_y=0., sat_z=0., sun_x=0., sun_y=0., sun_z=0., sat_vx=0., sat_vy=0., sat_vz=0., exp_time=150., pointing_type='SCI', pointing_type_code='101', pointing_id='00000001', obs_config_file=None, t_shutter_open=1.3, t_shutter_close=1.3, dataset='csst-msc-c9-25sqdeg-v3'): def __init__(self, id=0, ra=0., dec=0., img_pa=0., timestamp=1621915200, sat_x=0., sat_y=0., sat_z=0., sun_x=0., sun_y=0., sun_z=0., sat_vx=0., sat_vy=0., sat_vz=0., exp_time=150., pointing_type='WIDE', pointing_type_code='101', pointing_id='00000001', obs_config_file=None, t_shutter_open=1.3, t_shutter_close=1.3, dataset='csst-msc-c9-25sqdeg-v3'):
self.id = id self.id = id
self.ra = ra self.ra = ra
self.dec = dec self.dec = dec
...@@ -91,6 +91,9 @@ class Pointing(object): ...@@ -91,6 +91,9 @@ class Pointing(object):
# [TODO] Can also define other survey types # [TODO] Can also define other survey types
if is_deep == 2: if is_deep == 2:
self.survey_field_type = "DEEP" self.survey_field_type = "DEEP"
self.pointing_type = "DEEP"
else:
self.pointing_type = "WIDE"
if not self.obs_config_file: if not self.obs_config_file:
self.obs_config_file = str(columns[20]) self.obs_config_file = str(columns[20])
...@@ -102,7 +105,7 @@ class Pointing(object): ...@@ -102,7 +105,7 @@ class Pointing(object):
self.pointing_type_code = columns[21][0:3] self.pointing_type_code = columns[21][0:3]
self.obs_id = columns[21][3:] self.obs_id = columns[21][3:]
if self.obs_param["obs_type"]:
self.pointing_type = self.obs_param["obs_type"] self.pointing_type = self.obs_param["obs_type"]
else: else:
self.timestamp = t self.timestamp = t
......
...@@ -82,7 +82,7 @@ def getChipSLSConf(chipID): ...@@ -82,7 +82,7 @@ def getChipSLSConf(chipID):
def generateHeader(chip, pointing, img_type=None, img_type_code=None, project_cycle='9', run_counter='1'): def generateHeader(chip, pointing, img_type=None, img_type_code=None, project_cycle='9', run_counter='1'):
if (img_type is None) or (img_type_code is None): if (img_type is None) or (img_type_code is None):
img_type = pointing.pointing_type img_type = pointing.survey_field_type
img_type_code = pointing.pointing_type_code img_type_code = pointing.pointing_type_code
h_prim = generatePrimaryHeader( h_prim = generatePrimaryHeader(
...@@ -95,12 +95,13 @@ def generateHeader(chip, pointing, img_type=None, img_type_code=None, project_cy ...@@ -95,12 +95,13 @@ def generateHeader(chip, pointing, img_type=None, img_type_code=None, project_cy
pixel_scale=chip.pix_scale, pixel_scale=chip.pix_scale,
time_pt=pointing.timestamp, time_pt=pointing.timestamp,
exptime=pointing.exp_time, exptime=pointing.exp_time,
im_type=img_type, obstype=img_type,
sat_pos=[pointing.sat_x, pointing.sat_y, pointing.sat_z], sat_pos=[pointing.sat_x, pointing.sat_y, pointing.sat_z],
sat_vel=[pointing.sat_vx, pointing.sat_vy, pointing.sat_vz], sat_vel=[pointing.sat_vx, pointing.sat_vy, pointing.sat_vz],
project_cycle=project_cycle, project_cycle=project_cycle,
run_counter=run_counter, run_counter=run_counter,
chip_name=str(chip.chipID).rjust(2, '0')) chip_name=str(chip.chipID).rjust(2, '0'),
dataset=pointing.dataset)
h_ext = generateExtensionHeader( h_ext = generateExtensionHeader(
chip=chip, chip=chip,
xlen=chip.npix_x, xlen=chip.npix_x,
......
...@@ -18,7 +18,7 @@ def prepare_headers(self, chip, pointing): ...@@ -18,7 +18,7 @@ def prepare_headers(self, chip, pointing):
project_cycle=self.overall_config["project_cycle"], project_cycle=self.overall_config["project_cycle"],
run_counter=self.overall_config["run_counter"], run_counter=self.overall_config["run_counter"],
chip_name=str(chip.chipID).rjust(2, '0'), chip_name=str(chip.chipID).rjust(2, '0'),
obstype=pointing.survey_field_type, obstype=pointing.pointing_type,
dataset=pointing.dataset) dataset=pointing.dataset)
self.h_ext = generateExtensionHeader( self.h_ext = generateExtensionHeader(
chip=chip, chip=chip,
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment