标签任务调度对象代码提交

vue-fastapi-backend/module_admin/entity/do/metadata_config_do.py

@@ -43,6 +43,18 @@ class SecuBizConfigRela(Base):
     tab_onum = Column(Integer, nullable=True, comment="表id")
     create_by = Column(String(20), nullable=True, comment="创建者")
     create_time = Column(DateTime, nullable=True, comment="创建时间")    
+class TaskBizConfigRela(Base):
+    """
+    业务域调度配置关联表 ORM 映射类，对应表 t_task_biz_config_rela
+    """
+    __tablename__ = "t_task_biz_config_rela"
+
+    onum = Column(Integer, primary_key=True, autoincrement=True, comment="序号")
+    biz_onum = Column(Integer, nullable=True, comment="业务域id")
+    tab_onum = Column(Integer, nullable=True, comment="表id")
+    create_by = Column(String(20), nullable=True, comment="创建者")
+    create_time = Column(DateTime, nullable=True, comment="创建时间")    
+
 class SecuBizPermiConfig(Base):
     __tablename__ = "t_secu_biz_permi_config"
 
@@ -67,7 +79,22 @@ class SecuBizConfig(Base):
     create_by = Column(String(20), nullable=True, comment="创建者")
     create_time = Column(DateTime, nullable=True, comment="创建时间")
     update_by = Column(String(20), nullable=True, comment="更新者")
-    update_time = Column(DateTime, nullable=True, comment="更新时间")    
+    update_time = Column(DateTime, nullable=True, comment="更新时间")
+class TaskBizConfig(Base):
+    __tablename__ = "t_task_biz_config"
+
+    onum = Column(Integer, primary_key=True, autoincrement=True, comment="序号")
+    biz_name = Column(String(255), nullable=True, comment="业务域名称")  # 这里你给的是int，实际是否应该varchar？
+    risk_lvl = Column(String(50), nullable=True, comment="可关联安全等级序号")
+    isStop = Column(Boolean, nullable=True, comment="是否停用（0：运行 1：停用）")
+    create_by = Column(String(20), nullable=True, comment="创建者")
+    create_time = Column(DateTime, nullable=True, comment="创建时间")
+    update_by = Column(String(20), nullable=True, comment="更新者")
+    update_time = Column(DateTime, nullable=True, comment="更新时间")   
+    status = Column(String(10), nullable=False, default="OFFLINE", comment="状态")
+    ds_time = Column(DateTime, nullable=True, comment="调度时间")
+    ds_ids = Column(String(50), nullable=True, comment="任务ID")
+    schId = Column(String(50), nullable=True, comment="调度id")            
 class BatchBusiLabelConfig(Base):
     """
     批处理业务标签配置表 ORM 映射类，对应表 t_batch_busi_label_config
@@ -127,7 +154,7 @@ class DatasecConfig(Base):
     update_by = Column(String(64), nullable=True, default="", comment="更新者")
     update_time = Column(DateTime, nullable=True, comment="更新时间")
     metatask_param = Column(String(500), nullable=True, comment="参数")
-    status = Column(String(10), nullable=False, default="N", comment="状态")
+    status = Column(String(10), nullable=False, default="OFFLINE", comment="状态")
     ds_time = Column(DateTime, nullable=True, comment="调度时间")
     ds_ids = Column(String(50), nullable=True, comment="任务ID")
     schId = Column(String(50), nullable=True, comment="调度id")

vue-fastapi-backend/module_admin/entity/vo/metadata_config_vo.py

@@ -112,12 +112,21 @@ class SecuBizConfigRelaModel(BaseModel):
     业务域配置关联表对应 Pydantic 模型
     """
     model_config = ConfigDict(alias_generator=to_camel, from_attributes=True)
-
     onum: Optional[int] = Field(default=None, description="序号")
     biz_onum: Optional[int] = Field(default=None, description="业务域ID")
     tab_onum: Optional[int] = Field(default=None, description="表ID")
     create_by: Optional[str] = Field(default=None, description="创建者")
     create_time: Optional[datetime] = Field(default=None, description="创建时间")
+class TaskBizConfigRelaModel(BaseModel):
+    """
+    业务域配置关联表对应 Pydantic 模型
+    """
+    model_config = ConfigDict(alias_generator=to_camel, from_attributes=True)
+    onum: Optional[int] = Field(default=None, description="序号")
+    biz_onum: Optional[int] = Field(default=None, description="业务域ID")
+    tab_onum: Optional[int] = Field(default=None, description="表ID")
+    create_by: Optional[str] = Field(default=None, description="创建者")
+    create_time: Optional[datetime] = Field(default=None, description="创建时间")    
 
 class SecuBizConfigAddModel(BaseModel):
     """
@@ -337,4 +346,67 @@ class DatasecConfigPageQueryModel(DatasecConfigModel):
     page_num: int = Field(default=1, description='当前页码')
     page_size: int = Field(default=10, description='每页记录数')       
     begin_time: Optional[str]= Field(default=None, description='开始时间')
-    end_time: Optional[str]= Field(default=None, description='结束时间')    
+    end_time: Optional[str]= Field(default=None, description='结束时间')    
+
+class TaskBizConfigAddModel(BaseModel):
+    """
+    标签任务域配置对应 Pydantic 模型
+    """
+    model_config = ConfigDict(alias_generator=to_camel, from_attributes=True)
+
+    onum: Optional[int] = Field(default=None, description='序号')
+    biz_name: Optional[str] = Field(default=None, description='业务域名称')
+    risk_lvl: Optional[str] = Field(default=None, description='可关联安全等级序号')
+    isStop: Optional[Literal[0, 1]] = Field(default=None, description='是否停用（0：运行 1：停用）')
+    create_by: Optional[str] = Field(default=None, description='创建者')
+    create_time: Optional[datetime] = Field(default=None, description='创建时间')
+    update_by: Optional[str] = Field(default=None, description='更新者')
+    update_time: Optional[datetime] = Field(default=None, description='更新时间')
+    tab_onum_list: List[int] = Field(default=None, description='表id列表')    
+class TaskBizConfigModel(BaseModel):
+    """
+    标签任务配置对应 Pydantic 模型
+    """
+    model_config = ConfigDict(alias_generator=to_camel, from_attributes=True)
+
+    onum: Optional[int] = Field(default=None, description='序号')
+    biz_name: Optional[str] = Field(default=None, description='业务域名称')
+    risk_lvl: Optional[str] = Field(default=None, description='可关联安全等级序号')
+    isStop: Optional[Literal[0, 1]] = Field(default=None, description='是否停用（0：运行 1：停用）')
+    create_by: Optional[str] = Field(default=None, description='创建者')
+    create_time: Optional[datetime] = Field(default=None, description='创建时间')
+    update_by: Optional[str] = Field(default=None, description='更新者')
+    update_time: Optional[datetime] = Field(default=None, description='更新时间')
+    status: Optional[str] = Field(default="N", description="状态")
+    ds_time: Optional[datetime] = Field(default=None, description="调度时间")
+    ds_ids: Optional[str] = Field(default=None, description="任务ID")
+    schId: Optional[str] = Field(default=None, description="调度id")    
+    @NotBlank(field_name='risk_lvl', message='安全等级不能为空')
+    @Size(field_name='risk_lvl', max_length=50, message='安全等级长度不能超过50')
+    def get_risk_lvl(self):
+        return self.risk_lvl
+
+    def validate_fields(self):
+        self.get_risk_lvl()
+
+class DeleteTaskBizConfigModel(BaseModel):
+    """
+    删除业务域配置模型
+    """
+    model_config = ConfigDict(alias_generator=to_camel)
+    onums: str = Field(..., description='需要删除的唯一编号（多个用逗号分隔）')
+
+class TaskBizConfigQueryModel(TaskBizConfigModel):
+    """
+    业务域配置不分页查询模型
+    """
+    begin_time: Optional[str] = Field(default=None, description='开始时间')
+    end_time: Optional[str] = Field(default=None, description='结束时间')
+
+@as_query
+class TaskBizConfigPageQueryModel(TaskBizConfigQueryModel):
+    """
+    业务域配置分页查询模型
+    """
+    page_num: int = Field(default=1, description='当前页码')
+    page_size: int = Field(default=10, description='每页记录数')