package com.moral.monitor.listener.quartz;
|
|
import cn.jiguang.common.ClientConfig;
|
import cn.jpush.api.JPushClient;
|
import cn.jpush.api.push.PushResult;
|
import cn.jpush.api.push.model.Platform;
|
import cn.jpush.api.push.model.PushPayload;
|
import cn.jpush.api.push.model.audience.Audience;
|
import cn.jpush.api.push.model.notification.Notification;
|
import com.moral.monitor.dao.TaskDao;
|
import com.moral.monitor.entity.Equipment;
|
import com.moral.monitor.entity.State;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
import javax.annotation.Resource;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* Created by a on 2017/3/16.
|
*/
|
public class EquipmentCheck {
|
@Resource
|
TaskDao taskDao;
|
private Logger logger = LoggerFactory.getLogger(EquipmentCheck.class);
|
String MASTER_SECRET="980ec9da47076ff94e3b0f1a";
|
String APP_KEY="3f115de9acc4860344a299ea";
|
|
String MASTER_SECRET_IOS="";
|
String APP_KEY_IOS="";
|
|
public void check() {
|
logger.warn("设备检测定时任务开始");
|
long time = new Date().getTime();
|
List<State> states = taskDao.selectFromstateGroupbymac();
|
for (State state : states) {
|
if (time - state.getTime().getTime() > 600000) {//10分钟
|
String mac = state.getMac();
|
taskDao.updateequipmentstate(0,mac);
|
//极光推送致android 和 ios
|
Equipment e = taskDao.selectFromequipment(mac);
|
if (e==null){
|
continue;
|
}
|
|
String alais = e.getRepairman();
|
String title="设备故障";
|
String alert="设备"+e.getName()+"发生故障，请及时维修";
|
HashMap<String, String> extras = new HashMap<String, String>();
|
|
extras.put("id",String.valueOf(e.getId()));
|
extras.put("name",e.getName());
|
extras.put("address",e.getAddress());
|
extras.put("mac",e.getMac());
|
|
try {
|
JPushClient(alais,alert,title,extras,e);
|
}catch (Exception exception){
|
logger.info("Error Message: " + exception.getMessage());
|
}
|
}
|
}
|
}
|
|
|
public void JPushClient(String alias,String alert, String title, Map<String,String> extras,Equipment equipment){
|
JPushClient jpushClient = new JPushClient(MASTER_SECRET, APP_KEY, null, ClientConfig.getInstance());
|
//JPushClient jpushClient_IOS = new JPushClient(MASTER_SECRET_IOS, APP_KEY_IOS, null, ClientConfig.getInstance());
|
|
|
PushPayload payload_android = buildPushObject_android_alias_alertWithTitle(alias,alert,title,extras);
|
PushPayload pushload_ios = buildPushObject_ios_alias_alertWithTitle(alias,alert,extras);
|
|
try {
|
PushResult result1 = jpushClient.sendPush(payload_android);
|
taskDao.insertToofflinelog(equipment.getName(),equipment.getAddress(),equipment.getRepairman());
|
logger.info("极光android推送");
|
PushResult result2 = jpushClient.sendPush(pushload_ios);
|
logger.info(" 极光ios推送");
|
} catch (Exception e) {
|
logger.error("极光推送失败，原因如下：", e);
|
}
|
|
}
|
|
|
//构建推送对象：平台是 Android，目标是 alias 为 "alisename" 的设备，内容是 Android 通知 ALERT，并且标题为 TITLE。扩展数据为null
|
public static PushPayload buildPushObject_android_alias_alertWithTitle(String alias,String alert, String title, Map<String,String> extras) {
|
return PushPayload.newBuilder()
|
.setPlatform(Platform.android())
|
.setAudience(Audience.alias(alias))
|
.setNotification(Notification.android(alert,title, extras))
|
.build();
|
}
|
|
|
public static PushPayload buildPushObject_ios_alias_alertWithTitle(String alias,String alert, Map<String,String> extras) {
|
return PushPayload.newBuilder()
|
.setPlatform(Platform.ios())
|
.setAudience(Audience.alias(alias))
|
.setNotification(Notification.ios(alert,extras))
|
.build();
|
}
|
|
|
|
|
}
|
