package com.ard.work.health.task;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.serializer.SerializerFeature;
|
import com.ard.common.core.utils.StringUtils;
|
import com.ard.work.health.domain.ArdAlarmEqHealth;
|
import com.ard.work.health.service.ArdAlarmEqHealthService;
|
import com.ard.work.health.util.Global;
|
import com.ard.work.health.util.LonlatConver;
|
import com.ard.work.websocket.utils.JKWebSocketUtils;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.cloud.context.config.annotation.RefreshScope;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
import org.springframework.web.socket.TextMessage;
|
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Calendar;
|
import java.util.Collections;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Component
|
@Slf4j(topic = "task")
|
@RefreshScope
|
public class HealthTask {
|
|
@Value("${health.getAlarmAPITask}")
|
Boolean EqHealthGetAlarmAPITaskEnable;
|
|
@Value("${health.realTask}")
|
Boolean EqHealthRealTaskEnable;
|
|
@Autowired
|
private ArdAlarmEqHealthService ardAlarmEqHealthService;
|
|
/**
|
* @描述 设备健康报警api接口查询定时任务
|
* @参数 []
|
* @返回值 void
|
* @创建人 刘苏义
|
* @创建时间 2023/5/5 11:51
|
* @修改人和其它信息
|
*/
|
@Scheduled(cron = "0/20 * * * * ?")
|
public void GetAlarmEqHealthApiTask() {
|
if (!EqHealthGetAlarmAPITaskEnable) {
|
return;
|
}
|
log.debug("设备健康报警定时获取数据");
|
ardAlarmEqHealthService.getAlarmDataByApi();
|
}
|
|
/**
|
* @描述 设备健康报警上传前端定时任务
|
* @参数 []
|
* @返回值 void
|
* @创建人 刘苏义
|
* @创建时间 2023/5/5 11:51
|
* @修改人和其它信息
|
*/
|
@Scheduled(cron = "0/20 * * * * ?")
|
public void EqHealthAlarmRealTask() {
|
if (!EqHealthRealTaskEnable) {
|
return;
|
}
|
log.debug("设备健康报警定时任务开始");
|
// 开始时间
|
long stime = System.currentTimeMillis();
|
try {
|
/*获取数据库最新50条数据*/
|
List<ArdAlarmEqHealth> ardAlarmEqHealths = ardAlarmEqHealthService.GetRealAlarm();
|
Map<String, Object> map = new HashMap<>();
|
map.put("Command", 2001);
|
int count = 0;
|
List<ArdAlarmEqHealth> objs = new ArrayList<>();
|
for (ArdAlarmEqHealth data : ardAlarmEqHealths) {
|
|
//判断DirectLE为空 赋值空字符串
|
if (data.getDirectle() == null) {
|
data.setDirectle("");
|
}
|
//经纬度火星转84
|
if (data.getLongitude() != 0 && data.getLatitude() != 0) {
|
double[] wgs84 = LonlatConver.gcj02_To_Wgs84(data.getLongitude(), data.getLatitude());//火星转84
|
data.setLongitude(wgs84[0]);
|
data.setLatitude(wgs84[1]);
|
}
|
|
String alarmTime = data.getAlarmTime();
|
//将最新数据放入obj
|
if (StringUtils.isEmpty(Global.EqHealthNewTime)) {
|
/*如果临时最新时间为空，则取最近10秒内的最新数据*/
|
SimpleDateFormat fmt = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
Calendar calendar = Calendar.getInstance();
|
calendar.add(Calendar.MINUTE, -10);
|
Date time = calendar.getTime();
|
int dateFlag = alarmTime.compareTo(fmt.format(time));
|
if (dateFlag > 0) {
|
objs.add(data);
|
Global.EqHealthNewTime = alarmTime;
|
}
|
} else {
|
/*否则判断当前数据的时间是否大于最新时间*/
|
int dateFlag = alarmTime.compareTo(Global.EqHealthNewTime);
|
if (dateFlag > 0) {
|
objs.add(data);
|
Global.EqHealthNewTime = alarmTime;
|
}
|
}
|
|
//统计所有countLE的总数
|
if (StringUtils.isEmpty(data.getDirectle())) {
|
count++;
|
}
|
data.setId(data.getMeasureKey() + "&" + data.getCommand());
|
}
|
if (objs.size() > 0) {
|
map.put("obj", objs);
|
} else {
|
map.put("obj", -1);
|
}
|
map.put("count", count);
|
map.put("data", ardAlarmEqHealths);
|
if (ardAlarmEqHealths.size() > 0) {
|
|
//推送
|
JKWebSocketUtils.sendMessageAll(Collections.singletonList(new TextMessage(JSON.toJSONString(map, SerializerFeature.DisableCircularReferenceDetect))));
|
|
// for (Integer userId : SessionCollection.getClientsessionmap().keySet()) {
|
//
|
// List<WebSocketSession> webSocketSessions = SessionCollection.getClientsessionmap().get(userId);
|
// for (WebSocketSession webSocketSession : webSocketSessions) {
|
// if (webSocketSession != null && webSocketSession.isOpen()) {
|
// synchronized (webSocketSession) {
|
// try {
|
// webSocketSession.sendMessage(new TextMessage(JSON.toJSONString(map, SerializerFeature.DisableCircularReferenceDetect)));
|
// } catch (IOException e) {
|
// continue;
|
// }
|
//
|
// }
|
// }
|
// }
|
// }
|
}
|
|
} catch (Exception ex) {
|
log.error("设备健康实时数据定时任务异常：" + ex.getMessage());
|
}
|
// 结束时间
|
long etime = System.currentTimeMillis();
|
// 计算执行时间
|
log.debug("设备健康报警定时任务结束：" + (etime - stime) + " 毫秒");
|
}
|
}
|
