|
|
@ -5,6 +5,7 @@ import com.yihu.jw.care.job.QuartzHelper;
|
|
|
import com.yihu.jw.care.job.birthday.BirthdayWishesNotPushJob;
|
|
|
import com.yihu.jw.care.job.consult.FinishConsultJob;
|
|
|
import com.yihu.jw.care.job.data.SaveDataPushJob;
|
|
|
import com.yihu.jw.care.job.data.TimeApiJob;
|
|
|
import com.yihu.jw.care.job.device.*;
|
|
|
import com.yihu.jw.care.job.message.PatientSendUnreadJob;
|
|
|
import com.yihu.jw.care.job.order.*;
|
|
|
@ -39,16 +40,25 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
|
|
|
//居民24小时未回复的咨询自动关闭 每小时59分开始执行一次
|
|
|
if (!quartzHelper.isExistJob("finish_consult_job")) {
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("finish_consult_job");
|
|
|
quartzHelper.addJob(FinishConsultJob.class, trigger, "finish_consult_job", new HashMap<String, Object>());
|
|
|
quartzHelper.addJob(FinishConsultJob.class, trigger, "finish_consult_job", new HashMap<>());
|
|
|
logger.info("finish_consult_job success");
|
|
|
} else {
|
|
|
logger.info("finish_consult_job exist");
|
|
|
}
|
|
|
|
|
|
//每天晚上1点执行
|
|
|
if (!quartzHelper.isExistJob("time_api_job")) {
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("time_api_job");
|
|
|
quartzHelper.addJob(TimeApiJob.class, trigger, "time_api_job", new HashMap<>());
|
|
|
logger.info("time_api_job success");
|
|
|
} else {
|
|
|
logger.info("time_api_job exist");
|
|
|
}
|
|
|
|
|
|
//#每天的早上9:00，给所有医生/社工/教师发送一条短信
|
|
|
/*if (!quartzHelper.isExistJob("DOCTOR_SEND_UNREAD_MES_JOB")) {
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("DOCTOR_SEND_UNREAD_MES_JOB");
|
|
|
quartzHelper.addJob(DoctorSendUnreadJob.class, trigger, "DOCTOR_SEND_UNREAD_MES_JOB", new HashMap<String, Object>());
|
|
|
quartzHelper.addJob(DoctorSendUnreadJob.class, trigger, "DOCTOR_SEND_UNREAD_MES_JOB", new HashMap<>());
|
|
|
logger.info("DOCTOR_SEND_UNREAD_MES_JOB success");
|
|
|
} else {
|
|
|
logger.info("DOCTOR_SEND_UNREAD_MES_JOB exist");
|
|
|
@ -57,7 +67,7 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
|
|
|
//#每天的早上9:00，给所有居民发送未读消息微信模板
|
|
|
if (!quartzHelper.isExistJob("PATIENT_SEND_UNREAD_MES_JOB")) {
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("PATIENT_SEND_UNREAD_MES_JOB");
|
|
|
quartzHelper.addJob(PatientSendUnreadJob.class, trigger, "PATIENT_SEND_UNREAD_MES_JOB", new HashMap<String, Object>());
|
|
|
quartzHelper.addJob(PatientSendUnreadJob.class, trigger, "PATIENT_SEND_UNREAD_MES_JOB", new HashMap<>());
|
|
|
logger.info("PATIENT_SEND_UNREAD_MES_JOB success");
|
|
|
} else {
|
|
|
logger.info("PATIENT_SEND_UNREAD_MES_JOB exist");
|
|
|
@ -66,7 +76,7 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
|
|
|
//#每天的早上9:00，生日祝福提醒短信
|
|
|
if (!quartzHelper.isExistJob("BIRTHDAY_REMINDER_JOB")) {
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("BIRTHDAY_REMINDER_JOB");
|
|
|
quartzHelper.addJob(BirthdayReminderJob.class, trigger, "BIRTHDAY_REMINDER_JOB", new HashMap<String, Object>());
|
|
|
quartzHelper.addJob(BirthdayReminderJob.class, trigger, "BIRTHDAY_REMINDER_JOB", new HashMap<>());
|
|
|
logger.info("BIRTHDAY_REMINDER_JOB success");
|
|
|
} else {
|
|
|
logger.info("BIRTHDAY_REMINDER_JOB exist");
|
|
|
@ -75,7 +85,7 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
|
|
|
//#取消订单支付超时的订单，每3分钟执行一次
|
|
|
if (!quartzHelper.isExistJob("CANCEL_PAY_ORDER_OVERTIME_JOB")) {
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("CANCEL_PAY_ORDER_OVERTIME_JOB");
|
|
|
quartzHelper.addJob(CancelPayOrderJob.class, trigger, "CANCEL_PAY_ORDER_OVERTIME_JOB", new HashMap<String, Object>());
|
|
|
quartzHelper.addJob(CancelPayOrderJob.class, trigger, "CANCEL_PAY_ORDER_OVERTIME_JOB", new HashMap<>());
|
|
|
logger.info("CANCEL_PAY_ORDER_OVERTIME_JOB success");
|
|
|
} else {
|
|
|
logger.info("CANCEL_PAY_ORDER_OVERTIME_JOB exist");
|
|
|
@ -84,7 +94,7 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
|
|
|
//#居民紧急联系人数据同步更新每2分钟执行一次
|
|
|
if (!quartzHelper.isExistJob("PATIENT_SOS_CONTACTS_JOB")) {
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("PATIENT_SOS_CONTACTS_JOB");
|
|
|
quartzHelper.addJob(PatientSosContactsJob.class, trigger, "PATIENT_SOS_CONTACTS_JOB", new HashMap<String, Object>());
|
|
|
quartzHelper.addJob(PatientSosContactsJob.class, trigger, "PATIENT_SOS_CONTACTS_JOB", new HashMap<>());
|
|
|
logger.info("PATIENT_SOS_CONTACTS_JOB success");
|
|
|
} else {
|
|
|
logger.info("PATIENT_SOS_CONTACTS_JOB exist");
|
|
|
@ -92,7 +102,7 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
|
|
|
|
|
|
if (!quartzHelper.isExistJob("DEVICE_LOST_ASSOCIATION_JOB")) {
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("DEVICE_LOST_ASSOCIATION_JOB");
|
|
|
quartzHelper.addJob(DeviceLostAssociationJob.class, trigger, "DEVICE_LOST_ASSOCIATION_JOB", new HashMap<String, Object>());
|
|
|
quartzHelper.addJob(DeviceLostAssociationJob.class, trigger, "DEVICE_LOST_ASSOCIATION_JOB", new HashMap<>());
|
|
|
logger.info("DEVICE_LOST_ASSOCIATION_JOB success");
|
|
|
} else {
|
|
|
logger.info("DEVICE_LOST_ASSOCIATION_JOB exist");
|
|
|
@ -101,7 +111,7 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
|
|
|
//#居民紧急预警工单超时未处理弹框推送
|
|
|
if (!quartzHelper.isExistJob("EME_WARNING_OVERTIME_NOT_RESPONSE")) {
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("EME_WARNING_OVERTIME_NOT_RESPONSE");
|
|
|
quartzHelper.addJob(EmeWarnOrderJob.class, trigger, "EME_WARNING_OVERTIME_NOT_RESPONSE", new HashMap<String, Object>());
|
|
|
quartzHelper.addJob(EmeWarnOrderJob.class, trigger, "EME_WARNING_OVERTIME_NOT_RESPONSE", new HashMap<>());
|
|
|
logger.info("EME_WARNING_OVERTIME_NOT_RESPONSE success");
|
|
|
} else {
|
|
|
logger.info("EME_WARNING_OVERTIME_NOT_RESPONSE exist");
|
|
|
@ -110,7 +120,7 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
|
|
|
//#居民紧急预警工单超时未处理弹框推送
|
|
|
if (!quartzHelper.isExistJob("EME_WARNING_OVERTIME_NOT_RESPONSE_DAY")) {
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("EME_WARNING_OVERTIME_NOT_RESPONSE_DAY");
|
|
|
quartzHelper.addJob(EmeWarnOrderDayJob.class, trigger, "EME_WARNING_OVERTIME_NOT_RESPONSE_DAY", new HashMap<String, Object>());
|
|
|
quartzHelper.addJob(EmeWarnOrderDayJob.class, trigger, "EME_WARNING_OVERTIME_NOT_RESPONSE_DAY", new HashMap<>());
|
|
|
logger.info("EME_WARNING_OVERTIME_NOT_RESPONSE_DAY success");
|
|
|
} else {
|
|
|
logger.info("EME_WARNING_OVERTIME_NOT_RESPONSE_DAY exist");
|
|
|
@ -119,7 +129,7 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
|
|
|
//#取消订单支付超时的订单，每5分钟执行一次
|
|
|
if (!quartzHelper.isExistJob("OVERTIME_VISIT_JOB")) {
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("OVERTIME_VISIT_JOB");
|
|
|
quartzHelper.addJob(OverTimeVistJob.class, trigger, "OVERTIME_VISIT_JOB", new HashMap<String, Object>());
|
|
|
quartzHelper.addJob(OverTimeVistJob.class, trigger, "OVERTIME_VISIT_JOB", new HashMap<>());
|
|
|
logger.info("OVERTIME_VISIT_JOB success");
|
|
|
} else {
|
|
|
logger.info("OVERTIME_VISIT_JOB exist");
|
|
|
@ -128,7 +138,7 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
|
|
|
//归集数据定时推送 每天凌晨两点
|
|
|
if (!quartzHelper.isExistJob("SAVE_DATA_PUSH_JOB")){
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("SAVE_DATA_PUSH_JOB");
|
|
|
quartzHelper.addJob(SaveDataPushJob.class, trigger, "SAVE_DATA_PUSH_JOB", new HashMap<String, Object>());
|
|
|
quartzHelper.addJob(SaveDataPushJob.class, trigger, "SAVE_DATA_PUSH_JOB", new HashMap<>());
|
|
|
logger.info("SAVE_DATA_PUSH_JOB success");
|
|
|
}else {
|
|
|
logger.info("SAVE_DATA_PUSH_JOB exist");
|
|
|
@ -137,7 +147,7 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
|
|
|
//定时查询移动平台物联卡信息
|
|
|
if (!quartzHelper.isExistJob("UPDATE_SIMS_JOB")){
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("UPDATE_SIMS_JOB");
|
|
|
quartzHelper.addJob(UpdateSimsJob.class, trigger, "UPDATE_SIMS_JOB", new HashMap<String, Object>());
|
|
|
quartzHelper.addJob(UpdateSimsJob.class, trigger, "UPDATE_SIMS_JOB", new HashMap<>());
|
|
|
logger.info("UPDATE_SIMS_JOB success");
|
|
|
}else {
|
|
|
logger.info("UPDATE_SIMS_JOB exist");
|
|
|
@ -146,7 +156,7 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
|
|
|
//定时查询移动平台物联卡信息--日
|
|
|
if (!quartzHelper.isExistJob("GET_SIMS_VOICE_FLOW_DAY_JOB")){
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("GET_SIMS_VOICE_FLOW_DAY_JOB");
|
|
|
quartzHelper.addJob(GetSimsVoiceFlowDayJob.class, trigger, "GET_SIMS_VOICE_FLOW_DAY_JOB", new HashMap<String, Object>());
|
|
|
quartzHelper.addJob(GetSimsVoiceFlowDayJob.class, trigger, "GET_SIMS_VOICE_FLOW_DAY_JOB", new HashMap<>());
|
|
|
logger.info("GET_SIMS_VOICE_FLOW_DAY_JOB success");
|
|
|
}else {
|
|
|
logger.info("GET_SIMS_VOICE_FLOW_DAY_JOB exist");
|
|
|
@ -155,7 +165,7 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
|
|
|
//定时查询移动平台物联卡信息--月
|
|
|
if (!quartzHelper.isExistJob("GET_SIMS_VOICE_FLOW_MONTH_JOB")){
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("GET_SIMS_VOICE_FLOW_MONTH_JOB");
|
|
|
quartzHelper.addJob(GetSimsVoiceFlowMonthJob.class, trigger, "GET_SIMS_VOICE_FLOW_MONTH_JOB", new HashMap<String, Object>());
|
|
|
quartzHelper.addJob(GetSimsVoiceFlowMonthJob.class, trigger, "GET_SIMS_VOICE_FLOW_MONTH_JOB", new HashMap<>());
|
|
|
logger.info("GET_SIMS_VOICE_FLOW_MONTH_JOB success");
|
|
|
}else {
|
|
|
logger.info("GET_SIMS_VOICE_FLOW_MONTH_JOB exist");
|
|
|
@ -164,7 +174,7 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
|
|
|
//#每天早上10点发送血压(1天)血糖(7天)未测量通知
|
|
|
if (!quartzHelper.isExistJob("BLOOD_PRESSURE_GLUCOSE_NOT_MEASURED")){
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("BLOOD_PRESSURE_GLUCOSE_NOT_MEASURED");
|
|
|
quartzHelper.addJob(PressureGlucoseNotJob.class, trigger, "BLOOD_PRESSURE_GLUCOSE_NOT_MEASURED", new HashMap<String, Object>());
|
|
|
quartzHelper.addJob(PressureGlucoseNotJob.class, trigger, "BLOOD_PRESSURE_GLUCOSE_NOT_MEASURED", new HashMap<>());
|
|
|
logger.info("BLOOD_PRESSURE_GLUCOSE_NOT_MEASURED success");
|
|
|
}else {
|
|
|
logger.info("BLOOD_PRESSURE_GLUCOSE_NOT_MEASURED exist");
|
|
|
@ -182,7 +192,7 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
|
|
|
//#智慧水表工单触发
|
|
|
if (!quartzHelper.isExistJob("DAILY_WATER_JOB")){
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("DAILY_WATER_JOB");
|
|
|
quartzHelper.addJob(DailyWaterJob.class, trigger, "DAILY_WATER_JOB", new HashMap<String, Object>());
|
|
|
quartzHelper.addJob(DailyWaterJob.class, trigger, "DAILY_WATER_JOB", new HashMap<>());
|
|
|
logger.info("DAILY_WATER_JOB success");
|
|
|
}else {
|
|
|
logger.info("DAILY_WATER_JOB exist");
|
|
|
@ -191,7 +201,7 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
|
|
|
//#人脸库每天晚上3点跑一次
|
|
|
if (!quartzHelper.isExistJob("DEVICE_DATA_FACE_JOB")){
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("DEVICE_DATA_FACE_JOB");
|
|
|
quartzHelper.addJob(UpdPatientFaceJob.class, trigger, "DEVICE_DATA_FACE_JOB", new HashMap<String, Object>());
|
|
|
quartzHelper.addJob(UpdPatientFaceJob.class, trigger, "DEVICE_DATA_FACE_JOB", new HashMap<>());
|
|
|
logger.info("DEVICE_DATA_FACE_JOB success");
|
|
|
}else {
|
|
|
logger.info("DEVICE_DATA_FACE_JOB exist");
|
|
|
@ -200,7 +210,7 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
|
|
|
//#人脸记录每30分钟跑一次
|
|
|
if (!quartzHelper.isExistJob("SYN_FACE_RECORD_JOB")){
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("SYN_FACE_RECORD_JOB");
|
|
|
quartzHelper.addJob(SynPatientFaceRecordsJob.class, trigger, "SYN_FACE_RECORD_JOB", new HashMap<String, Object>());
|
|
|
quartzHelper.addJob(SynPatientFaceRecordsJob.class, trigger, "SYN_FACE_RECORD_JOB", new HashMap<>());
|
|
|
logger.info("SYN_FACE_RECORD_JOB success");
|
|
|
}else {
|
|
|
logger.info("SYN_FACE_RECORD_JOB exist");
|
|
|
@ -262,7 +272,7 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
|
|
|
//天气预报：每天早上11点播报
|
|
|
if (!quartzHelper.isExistJob("PUSH_MESSAGE_WEATHER_FORECAST_JOB")){
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("PUSH_MESSAGE_WEATHER_FORECAST_JOB");
|
|
|
quartzHelper.addJob(PushWeatherForecastJob.class,trigger,"PUSH_MESSAGE_WEATHER_FORECAST_JOB",new HashMap<String,Object>());
|
|
|
quartzHelper.addJob(PushWeatherForecastJob.class,trigger,"PUSH_MESSAGE_WEATHER_FORECAST_JOB", new HashMap<>());
|
|
|
logger.info("PUSH_MESSAGE_WEATHER_FORECAST_JOB success");
|
|
|
}else {
|
|
|
logger.info("PUSH_MESSAGE_WEATHER_FORECAST_JOB exist");
|
|
|
@ -278,7 +288,7 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
|
|
|
//朝晖日报：每天晚上8点发送
|
|
|
if (!quartzHelper.isExistJob("PUSH_ZHAO_HUI_RI_BAO_JOB")){
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("PUSH_ZHAO_HUI_RI_BAO_JOB");
|
|
|
quartzHelper.addJob(PushZhaohuiRoundJob.class,trigger,"PUSH_ZHAO_HUI_RI_BAO_JOB",new HashMap<String,Object>());
|
|
|
quartzHelper.addJob(PushZhaohuiRoundJob.class,trigger,"PUSH_ZHAO_HUI_RI_BAO_JOB", new HashMap<>());
|
|
|
logger.info("PUSH_ZHAO_HUI_RI_BAO_JOB success");
|
|
|
}else {
|
|
|
logger.info("PUSH_ZHAO_HUI_RI_BAO_JOB exist");
|
|
|
@ -286,7 +296,7 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
|
|
|
//家属设备微信推送
|
|
|
if (!quartzHelper.isExistJob("FAMILY_WECHAT_PUSH_DEVICE_JOB")){
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("FAMILY_WECHAT_PUSH_DEVICE_JOB");
|
|
|
quartzHelper.addJob(FamilySystemWechatPushJob.class,trigger,"FAMILY_WECHAT_PUSH_DEVICE_JOB",new HashMap<String,Object>());
|
|
|
quartzHelper.addJob(FamilySystemWechatPushJob.class,trigger,"FAMILY_WECHAT_PUSH_DEVICE_JOB", new HashMap<>());
|
|
|
logger.info("FAMILY_WECHAT_PUSH_DEVICE_JOB success");
|
|
|
}else {
|
|
|
logger.info("FAMILY_WECHAT_PUSH_DEVICE_JOB exist");
|
|
|
@ -294,7 +304,7 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
|
|
|
//物联设备
|
|
|
if (!quartzHelper.isExistJob("DEVICE_SYNC_JOB")){
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("DEVICE_SYNC_JOB");
|
|
|
quartzHelper.addJob(DeviceSyncJob.class,trigger,"DEVICE_SYNC_JOB",new HashMap<String,Object>());
|
|
|
quartzHelper.addJob(DeviceSyncJob.class,trigger,"DEVICE_SYNC_JOB",new HashMap<>());
|
|
|
logger.info("DEVICE_SYNC_JOB success");
|
|
|
}else {
|
|
|
logger.info("DEVICE_SYNC_JOB exist");
|
|
|
@ -303,7 +313,7 @@ public class ApplicationEvent implements ApplicationListener<ContextRefreshedEve
|
|
|
//预警中的工单，2小时无人处理时，由系统自动发送一条工作提醒给对应的社工
|
|
|
if (!quartzHelper.isExistJob("ORDER_URGE_REMINDER_JOB")){
|
|
|
String trigger = SystemConf.getInstance().getSystemProperties().getProperty("ORDER_URGE_REMINDER_JOB");
|
|
|
quartzHelper.addJob(OrderUrgeReminderJob.class,trigger,"ORDER_URGE_REMINDER_JOB",new HashMap<String,Object>());
|
|
|
quartzHelper.addJob(OrderUrgeReminderJob.class,trigger,"ORDER_URGE_REMINDER_JOB", new HashMap<>());
|
|
|
logger.info("ORDER_URGE_REMINDER_JOB success");
|
|
|
}else {
|
|
|
logger.info("ORDER_URGE_REMINDER_JOB exist");
|
wangzhinan