# CompRoomJobChecker.java

    package cloud.wconnect.frontoffice.scheduler.comproom;

    import cloud.wconnect.commonlib.cons.FunctionIdConstant;
    import cloud.wconnect.commonlib.cons.MoudleIdConstant;
    import cloud.wconnect.commonlib.cons.SchedulerCons;
    import cloud.wconnect.commonlib.pojo.dto.PropertyDTO;
    import cloud.wconnect.commonlib.pojo.dto.scheduler.JobBodyDTO;
    import cloud.wconnect.commonlib.service.PropertyInternalService;
    import cloud.wconnect.commonlib.service.SchedulerInternalService;
    import cloud.wconnect.commonlib.util.CronRuleUtil;
    import cloud.wconnect.frontoffice.entity.comproom.CompRoomScheduler;
    import cloud.wconnect.frontoffice.service.comproom.ICompRoomSchedulerService;
    import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
    import com.fasterxml.jackson.databind.ObjectMapper;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.scheduling.annotation.Scheduled;
    import org.springframework.stereotype.Component;

    import java.util.ArrayList;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.stream.Collectors;

    /**
     * 免费房功能的job检查器
     *
     * @author lichen
     * @date 2024/3/13
     */
    @Slf4j
    @Component
    public class CompRoomJobChecker {

        @Autowired
        private ICompRoomSchedulerService schedulerService;
        @Autowired
        private SchedulerInternalService schedulerInternalService;
        @Autowired
        private PropertyInternalService propertyInternalService;
        @Autowired
        private ObjectMapper objectMapper;
        @Value("${default.timezone}")
        private String defaultTimezone;
        private final static Integer MODULE_ID = MoudleIdConstant.FRONT_OFFICE; // front office module id
        private final static Integer FUNCTION_ID = FunctionIdConstant.COMP_ROOM; // comp room feature id

        /**
         * 每小时检查一下 处于未同步状态的调度任务， 并将其同步到调度中心
         *
         * @return void
         * @author lichen
         * @date 2024/3/11
         */
        @Scheduled(cron = "${schedule.cron.sync-scheduler-job}", zone = "${default.timezone}")
        public void checkSchedulerJob() {
            //查询未同步的定时任务
            List<CompRoomScheduler> unSyncJobs = schedulerService.list(new LambdaQueryWrapper<CompRoomScheduler>()
                    .eq(CompRoomScheduler::getSyncState, false));
            if (unSyncJobs.isEmpty()) {
                return;
            }

            List<Integer> propertyIds = unSyncJobs.stream().map(CompRoomScheduler::getPropertyId).distinct().toList();
            Map<Integer, String> propertyIdToTimezoneMapping = propertyInternalService.getProperty(propertyIds)
                    .stream().collect(Collectors.toMap(PropertyDTO::getId, PropertyDTO::getTimezone));

            List<String> updateJobIds = new ArrayList<>();
            List<String> deleteJobIds = new ArrayList<>();
            unSyncJobs.forEach(job -> {
                if (job.getStatus() == SchedulerCons.STATUS_START) {//开启
                    try {
                        JobBodyDTO task = new JobBodyDTO()
                                .setJobId(job.getId()).setModuleId(MODULE_ID).setFunctionId(FUNCTION_ID)
                                .setStartDate(job.getStartDate())
                                .setCronRule(CronRuleUtil.generateCronRuleForScheduler(objectMapper.readValue(job.getScheduler(), HashMap.class), job.getStartDate(), propertyIdToTimezoneMapping.get(job.getPropertyId()), defaultTimezone));
                        schedulerInternalService.launchJob(task);
                        updateJobIds.add(job.getId());
                    } catch (Exception e) {
                        log.error("Launch comp room scheduler job["+ job.getId() +"] failed", e);
                    }
                } else {//关闭 or 删除中
                    try {
                        schedulerInternalService.deleteJob(new JobBodyDTO().setJobId(job.getId()).setModuleId(MODULE_ID).setFunctionId(FUNCTION_ID));
                        if (job.getStatus() == SchedulerCons.STATUS_STOP) {
                            updateJobIds.add(job.getId());
                        } else {
                            deleteJobIds.add(job.getId());
                        }
                    } catch (Exception e) {
                        log.error("Delete comp room scheduler job["+ job.getId() +"] failed", e);
                    }
                }
            });

            if (!updateJobIds.isEmpty()) {
                schedulerService.refreshSyncStateByIds(updateJobIds);
            }

            if (!deleteJobIds.isEmpty()) {
                schedulerService.removeByIds(deleteJobIds);
            }
        }

    }