wlyy2.0/svr/svr-iot-job/src/main/java/com/yihu/jw/event/ApplicationEvent.java

package com.yihu.jw.event;

import com.yihu.jw.job.QuartzHelper;
import com.yihu.jw.job.wlw.InventoryWarningJob;
import com.yihu.jw.util.SystemConf;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationListener;
import org.springframework.context.event.ContextRefreshedEvent;
import org.springframework.stereotype.Service;

import java.util.HashMap;

/**
 * Created by zdm on 2017/3/10.
 */
@Service
public class ApplicationEvent implements ApplicationListener<ContextRefreshedEvent> {

    private Logger logger = LoggerFactory.getLogger(ApplicationEvent.class);
    @Autowired
    QuartzHelper quartzHelper;

    @Override
    public void onApplicationEvent(ContextRefreshedEvent ContextRefreshedEvent) {
        try {
            //设备库存预警提醒
            if (!quartzHelper.isExistJob("device_inventory_warning_job")) {
                String trigger = SystemConf.getInstance().getSystemProperties().getProperty("device_inventory_warning_job");
                quartzHelper.addJob(InventoryWarningJob.class, trigger, "device_inventory_warning_job", new HashMap<String, Object>());
                logger.info("device_inventory_warning_job  job success");
            } else {
                logger.info("device_inventory_warning_job  job exist");
            }


        } catch (Exception e) {
            logger.info(" job start failed");
        }
    }
}