package com.ard.work.health.service.impl;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.ard.common.core.utils.StringUtils;
|
import com.ard.system.api.factory.RemoteUserFallbackFactory;
|
import com.ard.work.health.domain.ArdAlarmEqHealth;
|
import com.ard.work.health.domain.ArdAlarmEqHealthExample;
|
import com.ard.work.health.mapper.ArdAlarmEqHealthMapper;
|
import com.ard.work.health.service.ArdAlarmEqHealthService;
|
import com.ard.work.health.task.ArdAlarmpointsExample;
|
import com.ard.work.health.util.OkhttpUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.stereotype.Service;
|
|
import jakarta.annotation.Resource;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.util.Comparator;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.UUID;
|
import java.util.regex.Matcher;
|
import java.util.regex.Pattern;
|
|
import static com.ard.work.health.util.OkhttpUtils.getAllAlarmData;
|
|
@Service
|
public class ArdAlarmEqHealthServiceImpl implements ArdAlarmEqHealthService {
|
|
private static final String eqHealthUrl = "http://112.98.106.22:15028";
|
|
private static final String eqHealthAccount = "rf";
|
|
private static final String eqHealthPassword = "111";
|
|
private static final String refreshTime = "480";
|
|
private static final Logger log = LoggerFactory.getLogger(RemoteUserFallbackFactory.class);
|
|
// @Resource
|
// ArdAlarmpointsMapper ardAlarmpointsMapper;
|
//
|
// @Resource
|
// ArdAlarmpointsHeightMapper ardAlarmpointsHeightMapper;
|
|
@Resource
|
ArdAlarmEqHealthMapper ardAlarmEqHealthMapper;
|
|
/**
|
* @描述 获取登录token
|
* @参数 []
|
* @返回值 java.lang.String
|
* @创建人 刘苏义
|
* @创建时间 2023/5/6 15:27
|
* @修改人和其它信息
|
*/
|
@Override
|
public String getToken() {
|
String token = "";
|
try {
|
String url = eqHealthUrl + "/RoadFlowApi/Home/ValidLogin";
|
Map<String, String> body = new HashMap<>();
|
body.put("account", eqHealthAccount);
|
body.put("password", eqHealthPassword);
|
Map<String, Object> head = new HashMap<>();
|
Map<String, Object> treeJson = OkhttpUtils.postAllAlarmData(url, body, head);
|
if (treeJson != null) {
|
JSONObject jsonObj = (JSONObject) treeJson.get("data");
|
JSONObject data = jsonObj.getJSONObject("data");
|
token = data.getString("token");
|
}
|
} catch (Exception ex) {
|
log.error("获取token异常：" + ex.getMessage());
|
}
|
return token;
|
}
|
|
@Override
|
public void getAlarmDataByApi() {
|
try {
|
String token = getToken();
|
List<ArdAlarmEqHealth> data = new ArrayList<>();
|
if (StringUtils.isNotEmpty(token)) {
|
String url = eqHealthUrl + "/RoadFlowApi/ZX/MeasureData/GetEquipmentFailureModeAlert";
|
Map<String, Object> params = new HashMap<>();
|
Map<String, Object> heads = new HashMap<>();
|
heads.put("roadflow-token", token);
|
Map<String, Object> allAlarmData = getAllAlarmData(url, params, heads);
|
if (allAlarmData.get("data") != null) {
|
JSONArray jsonArrays = (JSONArray) allAlarmData.get("data");
|
for (int i = 0; i < jsonArrays.size(); i++) {
|
JSONObject jsonObj = jsonArrays.getJSONObject(i);
|
String wellNo = jsonObj.getString("EquipNumber");
|
String wellName = jsonObj.getString("EquipNameZH");
|
String MeasureKey = jsonObj.getString("MeasureKey");
|
String PartName = jsonObj.getString("PartName");
|
String type = jsonObj.getString("MeasureType");
|
String problem = jsonObj.getString("ModeDesc");
|
String levelHtml = jsonObj.getString("AlertLevel");
|
String MeasureDate = jsonObj.getString("MeasureDate");
|
String Suggestion = jsonObj.getString("Suggestion");
|
ArdAlarmEqHealth ardAlarmEqHealth = new ArdAlarmEqHealth();
|
ardAlarmEqHealth.setId(UUID.randomUUID().toString().replace("-", ""));
|
ardAlarmEqHealth.setCommand(2001);
|
/*获取井号井名称测点*/
|
ardAlarmEqHealth.setWellNo(wellNo);
|
ardAlarmEqHealth.setWellName(wellName);
|
ardAlarmEqHealth.setMeasureKey(MeasureKey);
|
/*获取报警时间*/
|
|
ardAlarmEqHealth.setAlarmTime(MeasureDate);
|
/*获取经纬度*/
|
ArdAlarmpointsExample ardAlarmpointsExample = new ArdAlarmpointsExample();
|
ardAlarmpointsExample.createCriteria().andNameEqualTo(wellNo);
|
// List<ArdAlarmpoints> ardAlarmpoints = ardAlarmpointsMapper.selectByExample(ardAlarmpointsExample);
|
// if (ardAlarmpoints.size() > 0) {
|
// ardAlarmEqHealth.setLongitude(ardAlarmpoints.get(0).getLongitude());
|
// ardAlarmEqHealth.setLatitude(ardAlarmpoints.get(0).getLatitude());
|
// Integer alarmPointId = ardAlarmpoints.get(0).getId();
|
// /*获取高层*/
|
// ArdAlarmpointsHeightExample ardAlarmpointsHeightExample = new ArdAlarmpointsHeightExample();
|
// ardAlarmpointsHeightExample.createCriteria().andAlarmpointsIdEqualTo(alarmPointId);
|
// List<ArdAlarmpointsHeight> ardAlarmpointsHeights = ardAlarmpointsHeightMapper.selectByExample(ardAlarmpointsHeightExample);
|
// if (ardAlarmpointsHeights.size() > 0) {
|
// ardAlarmEqHealth.setAltitude(ardAlarmpointsHeights.get(0).getHeight());
|
// }
|
// }
|
/*获取传感器类型*/
|
ardAlarmEqHealth.setType(type);
|
/*获取故障信息*/
|
ardAlarmEqHealth.setPosition(PartName);
|
ardAlarmEqHealth.setProblem(problem);
|
ardAlarmEqHealth.setSuggestion(Suggestion);
|
|
Pattern pattern = Pattern.compile("<span.*?>(.*?)</span>");
|
Matcher matcher = pattern.matcher(levelHtml);
|
if (matcher.find()) {
|
String level = matcher.group(1);
|
ardAlarmEqHealth.setLevel(level);
|
}
|
data.add(ardAlarmEqHealth);
|
}
|
}
|
/*插入本地库*/
|
insertAlarmData(data);
|
}
|
}catch (Exception e){
|
log.error("从接口获取报警数据异常" + e.getMessage());
|
}
|
}
|
|
@Override
|
public List<ArdAlarmEqHealth> GetRealAlarm() {
|
try {
|
List<ArdAlarmEqHealth> ardAlarmEqHealths = ardAlarmEqHealthMapper.selectRealByCondition(refreshTime);
|
return ardAlarmEqHealths;
|
} catch (Exception ex) {
|
log.error(ex.getMessage());
|
return null;
|
}
|
}
|
|
/**
|
* @描述 入库方法
|
* @参数 [data]
|
* @返回值 void
|
* @创建人 刘苏义
|
* @创建时间 2023/5/6 15:34
|
* @修改人和其它信息
|
*/
|
private void insertAlarmData(List<ArdAlarmEqHealth> data) {
|
try {
|
data.sort(Comparator.comparing(ArdAlarmEqHealth::getAlarmTime));
|
for (ArdAlarmEqHealth alarm : data) {
|
SimpleDateFormat fmt = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");
|
Date parse = fmt.parse(alarm.getAlarmTime());
|
SimpleDateFormat newfmt = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
String alarmTime = newfmt.format(parse);
|
alarm.setAlarmTime(alarmTime);
|
ArdAlarmEqHealthExample ardAlarmEqHealthExample = new ArdAlarmEqHealthExample();
|
ardAlarmEqHealthExample
|
.createCriteria()
|
.andWellNoEqualTo(alarm.getWellNo())
|
.andTypeEqualTo(alarm.getType())
|
.andAlarmTimeGreaterThanOrEqualTo(alarmTime)
|
.andProblemEqualTo(alarm.getProblem());
|
List<ArdAlarmEqHealth> ardAlarmEqHealths = ardAlarmEqHealthMapper.selectByExample(ardAlarmEqHealthExample);
|
if (ardAlarmEqHealths.size() <= 0) {
|
ardAlarmEqHealthMapper.insert(alarm);
|
}
|
}
|
} catch (Exception ex) {
|
log.error("入库异常：" + ex.getMessage());
|
}
|
}
|
|
}
|
