wlyy2.0/patient-co/patient-co-wlyy-job/src/main/java/com/yihu/wlyy/event/ApplicationEvent.java

package com.yihu.wlyy.event;

import com.yihu.wlyy.job.*;
import com.yihu.wlyy.job.consult.EvaluateScoreJob;
import com.yihu.wlyy.redis.RedisThread;
import com.yihu.wlyy.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 lyr-pc on 2017/3/10.
 */
@Service
public class ApplicationEvent implements ApplicationListener<ContextRefreshedEvent> {

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

    @Override
    public void onApplicationEvent(ContextRefreshedEvent ContextRefreshedEvent) {
        try {
            // 启动签约到期处理JOB
            if (!quartzHelper.isExistJob("sign_end_job")) {
                String trigger = SystemConf.getInstance().getSystemProperties().getProperty("sign_end_job_trigger");
                quartzHelper.addJob(SignEndJob.class, trigger, "sign_end_job", new HashMap<String, Object>());
                logger.info("sign end job start success");
            } else {
                logger.info("sign end job exist");
            }
            if (!quartzHelper.isExistJob("evaluate_score_job")) {
                String trigger = SystemConf.getInstance().getSystemProperties().getProperty("evaluate_score_job");
                quartzHelper.addJob(EvaluateScoreJob.class, trigger, "evaluate_score_job", new HashMap<String, Object>());
                logger.info("evaluate_score_job start success");
            } else {
                logger.info("evaluate_score_job exist");
            }
            //启动群发续签图文消息
            if (!quartzHelper.isExistJob("sign_again_job")) {
                String trigger = SystemConf.getInstance().getSystemProperties().getProperty("sign_again_job_trigger");
                quartzHelper.addJob(SignAgainJob.class, trigger, "sign_again_job", new HashMap<String, Object>());
                logger.info("sign_again_job start success");
            } else {
                logger.info("sign_again_job exist");
            }
            //续方支付到期,每天0点触发
            if (!quartzHelper.isExistJob("prescription_pay_overdue_job")) {
                String trigger = SystemConf.getInstance().getSystemProperties().getProperty("prescription_pay_overdue_job");
                quartzHelper.addJob(PrescriptionPayOverdueJob.class, trigger, "prescription_pay_overdue_job", new HashMap<String, Object>());
                logger.info("prescription pay overdue job success");
            } else {
                logger.info("prescription pay overdue job exist");
            }

            //启动发送产检提醒模板消息
//            if (!quartzHelper.isExistJob("prenatal_inspector_job")) {
//                String trigger = SystemConf.getInstance().getSystemProperties().getProperty("prenatal_inspector_job_trigger");
//                quartzHelper.addJob(PrenatalInspectorJob.class, trigger, "prenatal_inspector_job", new HashMap<String, Object>());
//                logger.info("prenatal_inspector_job start success");
//            } else {
//                logger.info("prenatal_inspector_job exist");
//            }


            //遍历支付成功，快递下单失败的记录，重新下单，10分钟跑一次
            if (!quartzHelper.isExistJob("sfexpress_reorder_job")) {
                String trigger = SystemConf.getInstance().getSystemProperties().getProperty("sfexpress_reorder_job");
                quartzHelper.addJob(SFExpressJob.class, trigger, "sfexpress_reorder_job", new HashMap<String, Object>());
                logger.info("sfexpress reorder job job success");
            } else {
                logger.info("sfexpress reorder job job exist");
            }


            //同步智业字典 每晚1点同步
            if (!quartzHelper.isExistJob("zy_dict_job")) {
                String trigger = SystemConf.getInstance().getSystemProperties().getProperty("zy_dict_job");
                quartzHelper.addJob(ZyDictJob.class, trigger, "zy_dict_job", new HashMap<String, Object>());
                logger.info("zy_dict_job job success");
            } else {
                logger.info("zy_dict_job job exist");
            }

            //遍历支付成功，院内结算失败的的记录，重新结算，10分钟跑一次
            if (!quartzHelper.isExistJob("zy_execute_sick_settle_job")) {
                String trigger = SystemConf.getInstance().getSystemProperties().getProperty("zy_execute_sick_settle_job");
                quartzHelper.addJob(PrescriptionExecuteSickSettleJob.class, trigger, "zy_execute_sick_settle_job", new HashMap<String, Object>());
                logger.info("zy_execute_sick_settle_job reorder job job success");
            } else {
                logger.info("zy_execute_sick_settle_job reorder job job exist");
            }

            //居民24小时未回复的咨询自动关闭 每小时59分开始执行一次
            if (!quartzHelper.isExistJob("finish_consult_job")) {
                String trigger = SystemConf.getInstance().getSystemProperties().getProperty("finish_consult_job");
                quartzHelper.addJob(PrescriptionExecuteSickSettleJob.class, trigger, "finish_consult_job", new HashMap<String, Object>());
                logger.info("finish_consult_job success");
            } else {
                logger.info("finish_consult_job exist");
            }

            //提醒有监测方案的居民上传数据，每29分钟执行一次
            if (!quartzHelper.isExistJob("doctor_feldsher_template_job")) {
                String trigger = SystemConf.getInstance().getSystemProperties().getProperty("doctor_feldsher_template_job");
                quartzHelper.addJob(DoctorFeldsherTemplateJob.class, trigger, "doctor_feldsher_template_job", new HashMap<String, Object>());
                logger.info("doctor_feldsher_template_job reorder job job success");
            } else {
                logger.info("doctor_feldsher_template_job reorder job job exist");
            }


            // 启动redis 消息队列线程
            logger.info("redis message start");
            new Thread(redisThread).start();
            logger.info("redis message end");

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