任务执行一次bug

[beng003]

点执行一次也会按照cron执行表达式的时间间隔执行，应该怎么解决？

[beng003]

@insistence 有个新问题，修改之后执行一次任务日志中没有了JobSubmissionEvent和JobExecutionEvent事件，导致不能判断任务执行是否完成以及是否出错

[beng003]

@insistence 似乎是任务执行成功后会被删除，get_scheduler_job不再能获得任务信息，导致query_job为None，不能触发记录

[beng003]

@insistence 这里我先应急修复一下scheduler_event_listener

    @classmethod
    def scheduler_event_listener(cls, event):
        # 获取事件类型和任务ID
        event_type = event.__class__.__name__
        # 获取任务执行异常信息
        status = "0"
        exception_info = ""
        # question: 调试信息
        if event_type == "JobExecutionEvent" and event.exception:
            exception_info = str(event.exception)
            status = "1"
        if hasattr(event, "job_id"):
            job_id = int(event.job_id)

            from module_admin.service.job_service import JobService
            from sqlalchemy import delete, select, update
            from module_admin.entity.do.job_do import SysJob

            session = SessionLocal()
            query_job:JobModel = (session.execute(select(SysJob).where(SysJob.job_id == job_id))).scalars().first()
            
            if query_job:
                # 获取任务名称
                job_name = query_job.job_name
                # 获取任务组名
                job_group = query_job.job_group
                # 获取任务执行器
                job_executor = query_job.job_executor
                # 获取调用目标字符串
                invoke_target = query_job.invoke_target
                # 获取调用函数位置参数
                job_args = query_job.job_args
                # 获取调用函数关键字参数
                job_kwargs = query_job.job_kwargs
                # 获取任务触发器
                job_trigger = query_job.cron_expression
                # 构造日志消息
                job_message = f"事件类型: {event_type}, 任务ID: {job_id}, 任务名称: {job_name}, 执行于{datetime.now().strftime('%Y-%m-%d %H:%M:%S')}"
                job_log = JobLogModel(
                    jobName=job_name,
                    jobGroup=job_group,
                    jobExecutor=job_executor,
                    invokeTarget=invoke_target,
                    jobArgs=job_args,
                    jobKwargs=job_kwargs,
                    jobTrigger=job_trigger,
                    jobMessage=job_message,
                    status=status,
                    exceptionInfo=exception_info,
                    createTime=datetime.now(),
                )
                
                JobLogService.add_job_log_services(session, job_log)
                session.close()

[insistence]

@insistence 这里我先应急修复一下scheduler_event_listener

这样写日志中的trigger是不准确的