package com.ruoyi.alarm.steal.service.impl;
|
|
|
import com.alibaba.fastjson2.JSON;
|
import com.alibaba.fastjson2.JSONObject;
|
import com.ruoyi.alarm.steal.domain.ArdAlarmStealelec;
|
import com.ruoyi.alarm.steal.service.IStealElecAlarmService;
|
import com.ruoyi.alarmpoints.well.domain.ArdAlarmpointsWell;
|
import com.ruoyi.alarmpoints.well.mapper.ArdAlarmpointsWellMapper;
|
import com.ruoyi.alarm.steal.mapper.ArdAlarmStealelecMapper;
|
import com.ruoyi.system.service.ISysConfigService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
import org.springframework.web.client.RestTemplate;
|
|
import javax.annotation.Resource;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* @ClassName StealElecAlarmServiceImpl
|
* @Description:盗电警报服务实现类
|
* @Author 刘苏义
|
* @Date 2022/12/26 16:34
|
* @Version 1.0
|
*/
|
@Slf4j(topic = "alarm")
|
@Service
|
public class IStealElecAlarmServiceImpl implements IStealElecAlarmService {
|
@Resource
|
ArdAlarmStealelecMapper ardAlarmStealelecMapper;
|
@Resource
|
ArdAlarmpointsWellMapper ardAlarmpointsWellMapper;
|
@Resource
|
RestTemplate restTemplate;
|
@Resource
|
private ISysConfigService configService;
|
|
/**
|
* @描述 获取api数据写入数据库
|
* @参数 [url]
|
* @返回值 void
|
* @创建人 刘苏义
|
* @创建时间 2023/1/6 8:55
|
* @修改人和其它信息
|
*/
|
@Override
|
@SuppressWarnings("unchecked")
|
public void getAlarmByApi() {
|
try {
|
String stealElecUrl = configService.selectConfigByKey("stealElecUrl");
|
String allAlarmData = restTemplate.getForObject(stealElecUrl, String.class);
|
//剔除所有\符号
|
String message = allAlarmData.replaceAll("\\\\", "");
|
//剔除整个字符串首尾双引号
|
if (message.startsWith("\"")) {
|
message = message.substring(1);
|
}
|
if (message.endsWith("\"")) {
|
message = message.substring(0, message.length() - 1);
|
}
|
Map<String, Object> result = (Map<String, Object>) JSON.parse(message);
|
//获取到json对象list集合
|
List<JSONObject> list = (List<JSONObject>) result.get("data");
|
if (list.size() > 0) {
|
for (JSONObject object : list) {
|
String JSONStr = JSON.toJSONString(object);
|
//转成实体对象
|
ArdAlarmStealelec wd = JSON.parseObject(JSONStr, ArdAlarmStealelec.class);
|
ArdAlarmStealelec ardAlarmStealelec = ardAlarmStealelecMapper.selectByPrimaryKey(wd.getId());
|
if (ardAlarmStealelec == null) {
|
//同时插入到数据库中
|
wd.setCommand(1001);
|
wd.setCreateTime(new Date());
|
ArdAlarmpointsWell well = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(wd.getDescribe());
|
if(well!=null)
|
{
|
wd.setLongitude(well.getLongitude());
|
wd.setLatitude(well.getLatitude());
|
wd.setDeptId(well.getDeptId());
|
}
|
int insert = ardAlarmStealelecMapper.insertArdAlarmStealelec(wd);
|
if (insert > 0) {
|
log.info("数据插入成功：" + wd.getId());
|
} else {
|
log.info("数据插入失败：" + wd.getId());
|
}
|
}
|
}
|
}
|
} catch (Exception ex) {
|
log.error("拉取盗电报警数据异常：" + ex.getMessage());
|
}
|
}
|
|
/**
|
* @描述 获取实时数据
|
* @参数 []
|
* @返回值 java.util.List<cn.easyuse.ssm.po.ArdAlarmStealelec>
|
* @创建人 刘苏义
|
* @创建时间 2023/1/6 8:59
|
* @修改人和其它信息
|
*/
|
@Override
|
public List<ArdAlarmStealelec> getRealAlarm(Long deptId) {
|
try {
|
String refreshTime = configService.selectConfigByKey("refreshTime");
|
return ardAlarmStealelecMapper.selectRealByCondition(refreshTime,deptId);
|
} catch (Exception ex) {
|
log.error(ex.getMessage());
|
return null;
|
}
|
}
|
/**
|
* @描述 更新井号已读时间
|
* @参数 [describe, DirectLE]
|
* @返回值 int
|
* @创建人 刘苏义
|
* @创建时间 2023/1/6 9:00
|
* @修改人和其它信息
|
*/
|
@Override
|
public int updateViewTimeByDescribe(String describe, String alarmTime,String viewTime) {
|
return ardAlarmStealelecMapper.updateViewTimeByDescribe(describe,alarmTime, viewTime);
|
}
|
}
|
