初始化项目

云

2026-06-26 20b96473f2520590a0dca6b775b81e3ea06a77a0

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
package cn.iocoder.yudao.module.iot.job.rule;
 
import cn.hutool.core.map.MapUtil;
import cn.iocoder.yudao.module.iot.enums.rule.IotSceneRuleTriggerTypeEnum;
import cn.iocoder.yudao.module.iot.service.rule.scene.IotSceneRuleService;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.quartz.JobExecutionContext;
import org.springframework.scheduling.quartz.QuartzJobBean;
 
import java.util.Map;
 
/**
 * IoT 规则场景 Job，用于执行 {@link IotSceneRuleTriggerTypeEnum#TIMER} 类型的规则场景
 *
 * @author 芋道源码
 */
@Slf4j
public class IotSceneRuleJob extends QuartzJobBean {
 
    /**
     * JobData Key - 规则场景编号
     */
    public static final String JOB_DATA_KEY_RULE_SCENE_ID = "sceneRuleId";
 
    @Resource
    private IotSceneRuleService sceneRuleService;
 
    @Override
    protected void executeInternal(JobExecutionContext context) {
        // 获得规则场景编号
        Long sceneRuleId = context.getMergedJobDataMap().getLong(JOB_DATA_KEY_RULE_SCENE_ID);
 
        // 执行规则场景
        sceneRuleService.executeSceneRuleByTimer(sceneRuleId);
    }
 
    /**
     * 创建 JobData Map
     *
     * @param sceneRuleId 规则场景编号
     * @return JobData Map
     */
    public static Map<String, Object> buildJobDataMap(Long sceneRuleId) {
        return MapUtil.of(JOB_DATA_KEY_RULE_SCENE_ID, sceneRuleId);
    }
 
    /**
     * 创建 Job 名字
     *
     * @param sceneRuleId 规则场景编号
     * @return Job 名字
     */
    public static String buildJobName(Long sceneRuleId) {
        return String.format("%s_%d", IotSceneRuleJob.class.getSimpleName(), sceneRuleId);
    }
 
}