luhaojie/agricultural-monitoring-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改获取设备实时数据定时任务逻辑

Browse Source
This commit is contained in:
mi9688
2024-11-30 18:25:35 +08:00
parent 172bd4f89d
commit 29f0ac331b
3 changed files with 105 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

105
fastbee-service/fastbee-iot-service/src/main/java/com/fastbee/iot/timer/DeviceDateTask.java
View File

@ -13,6 +13,7 @@ import com.fastbee.deviceData.domain.*;
import com.fastbee.deviceData.mapper.*;
import com.fastbee.deviceData.service.IDeviceRealtimedataWormsService;
import com.fastbee.deviceData.service.impl.DeviceRealtimedataMeteorologyServiceImpl;
import com.fastbee.deviceData.service.impl.DeviceRealtimedataMoistureServiceImpl;
import com.fastbee.deviceData.service.impl.DeviceRealtimedataWormsServiceImpl;
import com.fastbee.deviceInfo.domain.DeviceInformationMeteorology;
import com.fastbee.deviceInfo.domain.DeviceInformationMoisture;
@ -25,7 +26,11 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
* @author mijiupro
@ -45,13 +50,13 @@ public class DeviceDateTask {
private DeviceMapper deviceMapper;
@Autowired
private DeviceRealtimedataWormsServiceImpl wormsDataService;//虫情
private DeviceRealtimedataWormsServiceImpl wormsSaveDataService;//虫情
@Autowired
private DeviceRealtimedataMeteorologyServiceImpl meteorologyDataService;
private DeviceRealtimedataMeteorologyServiceImpl meteorologySaveDataService;
@Autowired
private DeviceRealtimedataMoistureMapper deviceRealtimedataMoistureMapper;
private DeviceRealtimedataMoistureServiceImpl moistureSaveDataService;
@Autowired
private DeviceRealtimedataPhotovoltaicMapper deviceRealtimedataPhotovoltaicMapper;
@ -100,26 +105,31 @@ public class DeviceDateTask {
* 获取虫情设备实时数据并保存
*/
public void getWormsDeviceRealtimeData() {
List<DeviceInformationWorms> list = new LambdaQueryChainWrapper<>(wormsMapper).select(DeviceInformationWorms::getDeviceEncoding).list();
List<String> deviceEncodingList = list.stream().map(DeviceInformationWorms::getDeviceEncoding).collect(Collectors.toList());
StringBuilder deviceAddrsStringBuilder= new StringBuilder("");
//离线设备列表
List<String> offlineDeviceList = new ArrayList<>();
//在线设备列表
List<String> onlineDeviceList = new ArrayList<>();
for (String deviceEncoding : deviceEncodingList) {
deviceAddrsStringBuilder.append(deviceEncoding);
deviceAddrsStringBuilder.append(",");
}
try{
List<DeviceInformationWorms> list = new LambdaQueryChainWrapper<>(wormsMapper).select(DeviceInformationWorms::getDeviceEncoding).list();
StringBuilder deviceAddrsStringBuilder= new StringBuilder("");
for (DeviceInformationWorms worms : list) {
deviceAddrsStringBuilder.append(worms.getDeviceEncoding());
deviceAddrsStringBuilder.append(",");
}
//去除最后，
StringBuilder stringBuilder = deviceAddrsStringBuilder.deleteCharAt(deviceAddrsStringBuilder.length() - 1);
String deviceAddrs = stringBuilder.toString();
List<DeviceRealtimedataWorms> deviceRealtimedataWorms = wormsService.setData(deviceAddrs);
// int i = deviceRealtimedataWormsMapper.in(deviceRealtimedataWorms);
boolean saved = wormsDataService.saveBatch(deviceRealtimedataWorms);
new LambdaUpdateChainWrapper<>(wormsMapper).in(DeviceInformationWorms::getDeviceEncoding,"1017240042").set(DeviceInformationWorms::getStatus, 1).update();
boolean saved = wormsSaveDataService.saveBatch(deviceRealtimedataWorms);
if (!saved){
System.out.println("插入数据失败!");
}
}
catch (Exception e){
log.error("获取虫情设备实时数据失败",e);
new LambdaUpdateChainWrapper<>(wormsMapper).eq(DeviceInformationWorms::getDeviceEncoding,"1017240042").set(DeviceInformationWorms::getStatus, 0).update();
new LambdaUpdateChainWrapper<>(wormsMapper).in(DeviceInformationWorms::getDeviceEncoding,"1017240042").set(DeviceInformationWorms::getStatus, 0).update();
}
}
@ -128,17 +138,39 @@ public class DeviceDateTask {
* 获取气象设备实时数据并保存
*/
public void getDevLinkMetDeviceRealtimeData(){
List<DeviceInformationMeteorology> list = new LambdaQueryChainWrapper<>(meteorologyMapper).select(DeviceInformationMeteorology::getDeviceEncoding).list();
List<String> deviceEncodingList = list.stream().map(DeviceInformationMeteorology::getDeviceEncoding).collect(Collectors.toList());
//离线设备列表
List<String> offlineDeviceList = new ArrayList<>();
//在线设备列表
List<String> onlineDeviceList = new ArrayList<>();
try{
List<DeviceInformationMeteorology> list = new LambdaQueryChainWrapper<>(meteorologyMapper).select(DeviceInformationMeteorology::getDeviceEncoding).list();
DeviceRealtimedataMeteorology deviceRealtimedataMeteorology = metDataService.setData(metDataService.getDeviceRealTimeData("3269"));
boolean save = meteorologyDataService.save(deviceRealtimedataMeteorology);
if (!save){
System.out.println("插入数据失败!");
deviceEncodingList.forEach(deviceEncoding->{
Map<String, String> deviceRealTimeData = new HashMap<>();
try{
deviceRealTimeData = metDataService.getDeviceRealTimeData(deviceEncoding);
onlineDeviceList.add(deviceEncoding);
}
catch (Exception e){
offlineDeviceList.add(deviceEncoding);
}
DeviceRealtimedataMeteorology deviceRealtimedataMeteorology = metDataService.setData(deviceRealTimeData);
boolean save = meteorologySaveDataService.save(deviceRealtimedataMeteorology);
if (!save){
System.out.println("插入数据失败!");
}
});
if(!onlineDeviceList.isEmpty()){
new LambdaUpdateChainWrapper<>(meteorologyMapper).in(DeviceInformationMeteorology::getDeviceEncoding,offlineDeviceList).set(DeviceInformationMeteorology::getStatus, 1).update();
}
}
catch (Exception e){
log.error("获取气象设备实时数据失败",e);
new LambdaUpdateChainWrapper<>(meteorologyMapper).eq(DeviceInformationMeteorology::getDeviceEncoding,"3269").set(DeviceInformationMeteorology::getStatus, 0).update();
if(!offlineDeviceList.isEmpty()){
new LambdaUpdateChainWrapper<>(meteorologyMapper).in(DeviceInformationMeteorology::getDeviceEncoding,offlineDeviceList).set(DeviceInformationMeteorology::getStatus, 0).update();
}
}
@ -147,18 +179,37 @@ public class DeviceDateTask {
* 获取墒情设备实时数据并保存
*/
public void getDevLinkMoistureDeviceRealtimeData() {
List<DeviceInformationMoisture> list = new LambdaQueryChainWrapper<>(moistureMapper).select(DeviceInformationMoisture::getDeviceEncoding).list();
List<String> deviceEncodingList = list.stream().map(DeviceInformationMoisture::getDeviceEncoding).collect(Collectors.toList());
//离线设备列表
List<String> offlineDeviceList = new ArrayList<>();
//在线设备列表
List<String> onlineDeviceList = new ArrayList<>();
try{
DeviceRealtimedataMoisture deviceRealtimedataMoisture = moistureDataService.setData(moistureDataService.getDeviceRealTimeData("3270"));
DeviceRealtimedataMoisture deviceRealtimedataMoisture1 = moistureDataService.setData(moistureDataService.getDeviceRealTimeData("3271"));
int i = deviceRealtimedataMoistureMapper.insert(deviceRealtimedataMoisture);
int i1 = deviceRealtimedataMoistureMapper.insert(deviceRealtimedataMoisture1);
if (i<1||i1<1)
System.out.println("插入数据失败!");
deviceEncodingList.forEach(deviceEncoding->{
Map<String, String> deviceRealTimeData = new HashMap<>();
try {
deviceRealTimeData = moistureDataService.getDeviceRealTimeData(deviceEncoding);
onlineDeviceList.add(deviceEncoding);
}catch (Exception e){
offlineDeviceList.add(deviceEncoding);
}
DeviceRealtimedataMoisture deviceRealtimedataMoisture = moistureDataService.setData(deviceRealTimeData);
boolean save = moistureSaveDataService.save(deviceRealtimedataMoisture);
if (!save){
log.error("墒情设备"+deviceEncoding+"实时数据插入数据失败!");
}
});
if(!onlineDeviceList.isEmpty()){
new LambdaUpdateChainWrapper<>(moistureMapper).in(DeviceInformationMoisture::getDeviceEncoding,onlineDeviceList).set(DeviceInformationMoisture::getStatus, 1).update();
}
}
catch (Exception e){
log.error("获取墒情设备实时数据失败",e);
new LambdaUpdateChainWrapper<>(moistureMapper).in(DeviceInformationMoisture::getDeviceEncoding,"3270","3271").set(DeviceInformationMoisture::getStatus, 0).update();
if(!offlineDeviceList.isEmpty()){
new LambdaUpdateChainWrapper<>(moistureMapper).in(DeviceInformationMoisture::getDeviceEncoding,offlineDeviceList).set(DeviceInformationMoisture::getStatus, 0).update();
}
}
}
/**
@ -205,7 +256,5 @@ public class DeviceDateTask {
System.out.println("插入数据失败!");
}
}