wyh
/
dianci
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: wyh:074326ce6a7119ff5a94847253aca7498cd2fd82
Branches Tags
wyh:main
wyh:detached2
wyh:detached
..
compare: wyh:63b435a23e412404ac115ba79a54554387b41e66
Branches Tags
wyh:main
wyh:detached2
wyh:detached

3 Commits
074326ce6a ... 63b435a23e

Author SHA1 Message Date
王宇航 63b435a23e 111 2024-02-21 17:36:42 +08:00
王宇航 90926b5651 111 2024-02-21 17:31:53 +08:00
王宇航 ad8f487866 判断逻辑更改 2024-02-21 16:49:35 +08:00
4 changed files with 206 additions and 200 deletions
Show Stats Expand all files Collapse all files

4
ruoyi-admin/src/main/resources/application-druid.yml
View File

@ -6,9 +6,9 @@ spring:
druid: druid:
# 主库数据源 # 主库数据源
master: master:
url: jdbc:mysql://39.104.15.118:3306/ry?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8 url: jdbc:mysql://localhost:3306/ry?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
username: root username: root
password: Orderfood@2022 password: 12345678
# 从库数据源 # 从库数据源
slave: slave:
# 从数据源开关/默认关闭 # 从数据源开关/默认关闭

24
ruoyi-admin/src/main/resources/banner.txt
View File

@ -1,24 +0,0 @@
Application Version: ${ruoyi.version}
Spring Boot Version: ${spring-boot.version}
////////////////////////////////////////////////////////////////////
// _ooOoo_ //
// o8888888o //
// 88" . "88 //
// (| ^_^ |) //
// O\ = /O //
// ____/`---'\____ //
// .' \\| |// `. //
// / \\||| : |||// \ //
// / _||||| -:- |||||- \ //
// | | \\\ - /// | | //
// | \_| ''\---/'' | | //
// \ .-\__ `-` ___/-. / //
// ___`. .' /--.--\ `. . ___ //
// ."" '< `.___\_<|>_/___.' >'"". //
// | | : `- \`.;`\ _ /`;.`/ - ` : | | //
// \ \ `-. \_ __\ /__ _/ .-` / / //
// ========`-.____`-.___\_____/___.-`____.-'======== //
// `=---=' //
// ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ //
// 佛祖保佑 永不宕机 永无BUG //
////////////////////////////////////////////////////////////////////

4
ruoyi-common/src/main/java/com/ruoyi/common/utils/SocketUtil.java
View File

@ -30,7 +30,6 @@ public class SocketUtil {
byte[] buffer = new byte[available]; byte[] buffer = new byte[available];
inputStream.read(buffer, 0, available); inputStream.read(buffer, 0, available);
// System.out.println("雷达：" + radarIp + "===" + radarLocation + ": 连接异常：{}" );
String hex = new BigInteger(1, buffer).toString(16); String hex = new BigInteger(1, buffer).toString(16);
@ -48,14 +47,11 @@ public class SocketUtil {
} }
dataResponse.setStatus(1); dataResponse.setStatus(1);
System.out.println("雷达ip " + radarIp+ radarId + radarLocation + "成功");
RadarStatusWebSocket.sendToAll(JSON.toJSONString(dataResponse)); RadarStatusWebSocket.sendToAll(JSON.toJSONString(dataResponse));
return dataResponse; return dataResponse;
} }
} catch (Exception e) { } catch (Exception e) {
// System.out.println("读取数据异常：" + radarIp);
} }
dataResponse.setRadarIp(radarIp); dataResponse.setRadarIp(radarIp);

216
ruoyi-system/src/main/java/com/ruoyi/system/service/impl/RadarRealTimeDataServiceImpl.java
View File

@ -8,16 +8,22 @@ import com.ruoyi.common.utils.bean.BeanUtils;
import com.ruoyi.common.utils.bean.ModbusResponse; import com.ruoyi.common.utils.bean.ModbusResponse;
import com.ruoyi.system.service.*; import com.ruoyi.system.service.*;
import org.apache.commons.collections.CollectionUtils; import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.compress.utils.Lists;
import org.apache.commons.lang3.ObjectUtils; import org.apache.commons.lang3.ObjectUtils;
import org.apache.commons.lang3.RandomUtils; import org.apache.commons.lang3.RandomUtils;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.apache.poi.ss.formula.functions.T;
import org.springframework.beans.factory.InitializingBean; import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.io.IOException;
import java.net.Socket; import java.net.Socket;
import java.net.UnknownHostException;
import java.sql.*; import java.sql.*;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.time.LocalDate;
import java.util.*; import java.util.*;
import java.util.Date; import java.util.Date;
import java.util.concurrent.*; import java.util.concurrent.*;
@ -39,61 +45,81 @@ public class RadarRealTimeDataServiceImpl implements RadarRealTimeDataService, I
@Autowired @Autowired
private ISysDiscernService discernService; private ISysDiscernService discernService;
@Autowired
private ThreadPoolTaskExecutor threadPoolTaskExecutor;
private static Map<String, SysIdentifier> identifierHashMap = new HashMap<>();
public static CopyOnWriteArrayList<String> allRadar = new CopyOnWriteArrayList<>(); public static CopyOnWriteArrayList<String> allRadar = new CopyOnWriteArrayList<>();
private Map<Long, String> radarDelMap = new HashMap<>(); private static Map<Long, String> radarDelMap = new HashMap<>();
@Override @Override
public void afterPropertiesSet() { public void afterPropertiesSet() {
List<SysRadar> radarList = service.selectRadarList(new SysRadar()); List<SysRadar> radarList = service.selectRadarList(new SysRadar());
// List<SysIdentifier> sysIdentifiers = identifierService.selectAllIdentifierList(); List<SysIdentifier> sysIdentifiers = identifierService.selectAllIdentifierList();
// Map<String, SysIdentifier> identifierHashMap = new HashMap<>();
// if (CollectionUtils.isNotEmpty(sysIdentifiers)){ if (CollectionUtils.isNotEmpty(sysIdentifiers)) {
// identifierHashMap = sysIdentifiers.stream().collect(Collectors.toMap(SysIdentifier::getIdentifierId, Function.identity()));
// } for (SysIdentifier sysIdentifier : sysIdentifiers) {
CompletableFuture.runAsync(() -> { if (StringUtils.isNotBlank(sysIdentifier.getIdentifierId())) {
radarWebSocket(radarList); identifierHashMap.put(sysIdentifier.getIdentifierId(), sysIdentifier);
}); }
if (StringUtils.isNotBlank(sysIdentifier.getIdentifierTwo())) {
identifierHashMap.put(sysIdentifier.getIdentifierTwo(), sysIdentifier);
}
if (StringUtils.isNotBlank(sysIdentifier.getIdentifierThree())) {
identifierHashMap.put(sysIdentifier.getIdentifierThree(), sysIdentifier);
}
if (StringUtils.isNotBlank(sysIdentifier.getIdentifierFour())) {
identifierHashMap.put(sysIdentifier.getIdentifierFour(), sysIdentifier);
}
}
} }
private void radarWebSocket(List<SysRadar> radarList) { CompletableFuture.runAsync(() -> {
// System.out.println(" 雷达集合：：：" + radarList); radarWebSocket(radarList, identifierHashMap);
}, threadPoolTaskExecutor);
}
private void radarWebSocket(List<SysRadar> radarList, Map<String, SysIdentifier> identifierHashMap) {
ArrayList<Socket> list = Lists.newArrayList();
for (SysRadar radar : radarList) { for (SysRadar radar : radarList) {
try { try {
Socket socket = new Socket(radar.getRadarIp(), 23); Socket socket = new Socket(radar.getRadarIp(), 23);
list.add(socket);
allRadar.add(radar.getRadarIp()); allRadar.add(radar.getRadarIp());
radarDelMap.put(radar.getId(), "0"); radarDelMap.put(radar.getId(), "0");
CompletableFuture.runAsync(() -> { CompletableFuture<Void> voidCompletableFuture = CompletableFuture.runAsync(() -> {
task(radar, socket); task(radar, socket, identifierHashMap);
}); }, threadPoolTaskExecutor);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
} }
} }
private void task(SysRadar radar, Socket socket) { private void task(SysRadar radar, Socket socket, Map<String, SysIdentifier> identifierHashMap) {
long noDataStart = System.currentTimeMillis(); long noDataStart = System.currentTimeMillis();
long noDataEnd = noDataStart;
long start = noDataStart;
int consecutiveZeros = 0; int consecutiveZeros = 0;
int readCount = 1; int readCount = 1;
Map<String, List<PrimaryRadarData>> map = new HashMap<>(); Map<String, List<PrimaryRadarData>> map = new HashMap<>();
Map<String ,Long> timeMap = new HashMap(); Map<String, Long> timeMap = new HashMap<>();
while (StringUtils.equals("0", radarDelMap.get(radar.getId()))) { while (StringUtils.equals("0", radarDelMap.get(radar.getId()))) {
try { try {
// socket连接成功返回数据 // socket连接成功返回数据
DataResponse data = SocketUtil.getData(socket, radar.getRadarLocation(), radar.getRadarIp(), radar.getRadarId()); DataResponse data = SocketUtil.getData(socket, radar.getRadarLocation(), radar.getRadarIp(), radar.getRadarId());
if (Objects.nonNull(data.getData())){ if (readCount == 2) {
timeMap.put("noDataStart",System.currentTimeMillis()); timeMap.put("noDataStart", System.currentTimeMillis());
}
if (consecutiveZeros == 0) {
timeMap.put("zero", System.currentTimeMillis());
} }
// 没数据返回data.data == null // 没数据返回data.data == null
long current = System.currentTimeMillis(); long current = System.currentTimeMillis();
@ -102,42 +128,40 @@ public class RadarRealTimeDataServiceImpl implements RadarRealTimeDataService, I
// 连续2秒没读到数据，结束 // 连续2秒没读到数据，结束
if (current - noDataStart >= 2000) { if (current - noDataStart >= 2000) {
// todo:存数据 // todo:存数据
if (CollectionUtils.isNotEmpty(map.get(getMapKey(radar)))) { if (CollectionUtils.isNotEmpty(map.get(getMapKey(radar,data.getData().get(11))))) {
System.out.println("连续两秒没收到数据：开始存储........" + "开始时间为：" + timeMap.get("noDataStart") + "结束时间为：" + current);
if (readCount > 1) { if (readCount > 1) {
saveData(radar, map, readCount, timeMap.get("noDataStart"), current); saveData(radar, map, readCount, timeMap.get("noDataStart"), current , data.getData().get(11));
timeMap.put("noDataStart",System.currentTimeMillis()); timeMap.put("noDataStart", System.currentTimeMillis());
readCount = 1; readCount = 1;
} }
} }
map.remove(getMapKey(radar)); map.remove(getMapKey(radar,data.getData().get(11)));
noDataStart = current; noDataStart = current;
} }
continue; continue;
} }
SysRadar sysRadar = service.selectRadarByRadarId(radar.getRadarId(), radar.getRadarIp()); // SysRadar sysRadar = service.selectRadarByRadarId(radar.getRadarId(), radar.getRadarIp());
if (sysRadar != null) { // 雷达数据返回封装类赋值 // if (sysRadar != null) { // 雷达数据返回封装类赋值
ModbusResponse modbusResponse = getModbusResponse(data); ModbusResponse modbusResponse = getModbusResponse(data);
String tag = modbusResponse.getTagId(); String tag = modbusResponse.getTagId();
timeMap.put("start", data.getTime());
// 雷达原始数据对象 // 雷达原始数据对象
PrimaryRadarData primaryRadarData = new PrimaryRadarData(); PrimaryRadarData primaryRadarData = new PrimaryRadarData();
// 拷贝封装类属性到雷达原始数据对象 // 拷贝封装类属性到雷达原始数据对象
BeanUtils.copyProperties(modbusResponse, primaryRadarData); BeanUtils.copyProperties(modbusResponse, primaryRadarData);
primaryRadarData.setRadarIp(radar.getRadarIp()); primaryRadarData.setRadarIp(radar.getRadarIp());
// if (primaryRadarData.getNumber()==(Integer.parseInt(radar.getRadarNum()))) {
primaryRadarData.setStationCode(radar.getStationCode()); primaryRadarData.setStationCode(radar.getStationCode());
// }else if (Objects.equals(radar.getRadarId(), data.getData().get(0))){
// primaryRadarData.setStationCode(radar.getStationCode());
// }
primaryRadarData.setRadarId(data.getData().get(0)); primaryRadarData.setRadarId(data.getData().get(0));
primaryRadarData.setRadarLocation(radar.getRadarLocation()); primaryRadarData.setRadarLocation(radar.getRadarLocation());
List<PrimaryRadarData> dataList = map.get(getMapKey(radar)); List<PrimaryRadarData> dataList = map.get(getMapKey(radar, modbusResponse.getNumber()));
//判断读取数据中是否携带标签 //判断读取数据中是否携带标签
if (!"0".equals(modbusResponse.getTagId())) { if (!"0".equals(modbusResponse.getTagId())) {
consecutiveZeros = 0;
// 根据标签去数据库查询标签列表 // 根据标签去数据库查询标签列表
SysIdentifier sysIdentifier = identifierService.selectIdentifierByTag(tag); SysIdentifier sysIdentifier = identifierHashMap.get(tag);
//判断数据库查询结果是否有数据 //判断数据库查询结果是否有数据
if (sysIdentifier != null) { if (sysIdentifier != null) {
// 有数据将查询到的标识器配置属性放进原始数据对象 // 有数据将查询到的标识器配置属性放进原始数据对象
primaryRadarData.setLadleNumber(sysIdentifier.getLadleNumber()); primaryRadarData.setLadleNumber(sysIdentifier.getLadleNumber());
@ -146,7 +170,7 @@ public class RadarRealTimeDataServiceImpl implements RadarRealTimeDataService, I
if (CollectionUtils.isEmpty(dataList)) { if (CollectionUtils.isEmpty(dataList)) {
dataList = new ArrayList<>(); dataList = new ArrayList<>();
dataList.add(primaryRadarData); dataList.add(primaryRadarData);
map.put(getMapKey(radar), dataList); map.put(getMapKey(radar,modbusResponse.getNumber()), dataList);
} }
// if (StringUtils.equals(modbusResponse.getTagId(), dataList.get(dataList.size() - 1).getTagId()) && Objects.equals(primaryRadarData.getRadarId(), dataList.get(dataList.size() - 1).getRadarId()) && Objects.equals(primaryRadarData.getRadarIp(), dataList.get(dataList.size() - 1).getRadarIp())) { // if (StringUtils.equals(modbusResponse.getTagId(), dataList.get(dataList.size() - 1).getTagId()) && Objects.equals(primaryRadarData.getRadarId(), dataList.get(dataList.size() - 1).getRadarId()) && Objects.equals(primaryRadarData.getRadarIp(), dataList.get(dataList.size() - 1).getRadarIp())) {
// if (current - start >= 20000) { // if (current - start >= 20000) {
@ -158,82 +182,96 @@ public class RadarRealTimeDataServiceImpl implements RadarRealTimeDataService, I
// readCount = 1; // readCount = 1;
// } // }
// start = System.currentTimeMillis(); // start = System.currentTimeMillis();
//
// } // }
// dataList.clear(); // dataList.clear();
// dataList.add(primaryRadarData); // dataList.add(primaryRadarData);
// } // }
if (modbusResponse.getNumber() == 1) {
if (!StringUtils.equals(modbusResponse.getTagId(), dataList.get(dataList.size() - 1).getTagId()) if (!StringUtils.equals(modbusResponse.getTagId(), dataList.get(dataList.size() - 1).getTagId())
&& !StringUtils.equals("0", dataList.get(dataList.size() - 1).getTagId()) && !StringUtils.equals("0", dataList.get(dataList.size() - 1).getTagId())
&& Objects.equals(primaryRadarData.getRadarId(), dataList.get(dataList.size() - 1).getRadarId()) && Objects.equals(primaryRadarData.getRadarId(), dataList.get(dataList.size() - 1).getRadarId())
&& Objects.equals(primaryRadarData.getRadarIp(), dataList.get(dataList.size() - 1).getRadarIp())) { && Objects.equals(primaryRadarData.getRadarIp(), dataList.get(dataList.size() - 1).getRadarIp())) {
// todo：存数据 // todo：存数据
long currentTimeMillis = System.currentTimeMillis(); long currentTimeMillis = System.currentTimeMillis();
Long dataStart = timeMap.get("noDataStart");
System.out.println("突然读到另一个标签：开始存储........" System.out.println("突然读到另一个标签：开始存储........"
+ "此次雷达id===="+primaryRadarData.getRadarId() + "上次雷达id===="+primaryRadarData.getRadarId() + "此次雷达id====" + primaryRadarData.getRadarId() + "上次雷达id====" + primaryRadarData.getRadarId()
+ "此次雷达ip为：====" + primaryRadarData.getRadarIp()+ "上次雷达ip为 =====" + dataList.get(dataList.size() - 1).getRadarIp() + dataStart + "结束时间为：" + currentTimeMillis); + "此次雷达ip为：====" + primaryRadarData.getRadarIp() + "上次雷达ip为 =====" + dataList.get(dataList.size() - 1).getRadarIp()
saveData(radar, map, readCount, data.getTime()-1, currentTimeMillis); + "此次雷达标签号为：====" + modbusResponse.getTagId() + "此次雷达标签号为：====" + dataList.get(dataList.size() - 1).getTagId()
+ data.getTime() + "结束时间为：" + currentTimeMillis);
saveData(radar, map, readCount, timeMap.get("noDataStart"), currentTimeMillis, modbusResponse.getNumber());
dataList.clear(); dataList.clear();
timeMap.put("noDataStart",System.currentTimeMillis()); timeMap.put("noDataStart", System.currentTimeMillis());
map.remove(getMapKey(radar)); map.remove(getMapKey(radar,modbusResponse.getNumber()));
dataList.add(primaryRadarData); dataList.add(primaryRadarData);
readCount = 1; readCount = 1;
} }
readCount++;
List<Date> readTime = map.get(getMapKey(radar))
.stream().map(PrimaryRadarData::getCreateTime).collect(Collectors.toList());
if (readTime.get(0) != null) {
readTime.set(0, new Date(System.currentTimeMillis()));
} }
if (modbusResponse.getNumber() == 2){
if (!StringUtils.equals(modbusResponse.getTagId(), dataList.get(dataList.size() - 1).getTagId())
&& !StringUtils.equals("0", dataList.get(dataList.size() - 1).getTagId())
&& Objects.equals(primaryRadarData.getRadarId(), dataList.get(dataList.size() - 1).getRadarId())
&& Objects.equals(primaryRadarData.getRadarIp(), dataList.get(dataList.size() - 1).getRadarIp())) {
// todo：存数据
long currentTimeMillis = System.currentTimeMillis();
System.out.println("突然读到另一个标签：开始存储........"
+ "此次雷达id====" + primaryRadarData.getRadarId() + "上次雷达id====" + primaryRadarData.getRadarId()
+ "此次雷达ip为：====" + primaryRadarData.getRadarIp() + "上次雷达ip为 =====" + dataList.get(dataList.size() - 1).getRadarIp()
+ "此次雷达标签号为：====" + modbusResponse.getTagId() + "此次雷达标签号为：====" + dataList.get(dataList.size() - 1).getTagId()
+ data.getTime() + "结束时间为：" + currentTimeMillis);
saveData(radar, map, readCount, timeMap.get("noDataStart"), currentTimeMillis , modbusResponse.getNumber());
dataList.clear();
timeMap.put("noDataStart", System.currentTimeMillis());
map.remove(getMapKey(radar,modbusResponse.getNumber()));
dataList.add(primaryRadarData);
readCount = 1;
}
}
readCount++;
if (!Objects.equals(data.getData().get(0), dataList.get(dataList.size() - 1).getRadarId())) { if (!Objects.equals(data.getData().get(0), dataList.get(dataList.size() - 1).getRadarId())) {
long end = System.currentTimeMillis(); long end = System.currentTimeMillis();
Long dataStart = timeMap.get("noDataStart"); Long dataStart = timeMap.get("noDataStart");
System.out.println("突然读到另一个雷达id： " + "开始存储........" + "开始时间为：" + dataStart + "结束时间为：" + end); System.out.println("突然读到另一个雷达id： " + "开始存储........" + "开始时间为：" + dataStart + "结束时间为：" + end);
saveData(radar, map, readCount, data.getTime(), end); saveData(radar, map, readCount, data.getTime(), end , modbusResponse.getNumber());
dataList.clear(); dataList.clear();
timeMap.put("noDataStart",System.currentTimeMillis()); timeMap.put("noDataStart", System.currentTimeMillis());
map.remove(getMapKey(radar)); map.remove(getMapKey(radar,modbusResponse.getNumber()));
dataList.add(primaryRadarData); dataList.add(primaryRadarData);
readCount = 1; readCount = 1;
} }
} }
consecutiveZeros = 0;
} else { } else {
Long dataStart = timeMap.get("noDataStart");
//连续10次读取标签号为0 //连续10次读取标签号为0
consecutiveZeros++; consecutiveZeros++;
if (10 == consecutiveZeros) { if (100 == consecutiveZeros) {
// todo：存数据 // todo：存数据
long nullTime = System.currentTimeMillis();
System.out.println("连续10次读取标签号为0：开始存储........" + "开始时间为：" + dataStart + "结束时间为：" + noDataStart); // System.out.println("连续10次读取标签号为0：开始存储........" + radar + map + readCount + "开始时间为：" + timeMap.get("zero") + "结束时间为：" + noDataStart);
saveData(radar, map, readCount, data.getTime(), noDataStart); saveData(radar, map, readCount, timeMap.get("zero"), noDataStart , modbusResponse.getNumber());
readCount = 1; readCount = 1;
map.remove(getMapKey(radar)); map.remove(getMapKey(radar,modbusResponse.getNumber()));
timeMap.remove("noDataStart"); timeMap.put("noDataStart", System.currentTimeMillis());
dataList.clear(); dataList.clear();
consecutiveZeros = 0; consecutiveZeros = 0;
} }
// 没有配置过将铁包号置空 // 没有配置过将铁包号置空
primaryRadarData.setLadleNumber(null); primaryRadarData.setLadleNumber(null);
primaryRadarData.setRadarIp(radar.getRadarIp()); primaryRadarData.setRadarIp(radar.getRadarIp());
} }
CompletableFuture.runAsync(() -> { CompletableFuture.runAsync(() -> {
primaryRadarDataService.insertPrimaryRadarData(primaryRadarData); primaryRadarDataService.insertPrimaryRadarData(primaryRadarData);
}); }, threadPoolTaskExecutor);
noDataStart = current; noDataStart = current;
} } catch (Throwable e) {
} catch (Exception e) { e.printStackTrace();
} }
} }
} }
private void saveData(SysRadar radar, Map<String, List<PrimaryRadarData>> map, int count, long noStartTime, long endTime) { private void saveData(SysRadar radar, Map<String, List<PrimaryRadarData>> map, int count, long noStartTime, long endTime , Integer number) {
Date start = new Date(noStartTime); Date start = new Date(noStartTime);
Date end = new Date(endTime); Date end = new Date(endTime);
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@ -241,7 +279,7 @@ public class RadarRealTimeDataServiceImpl implements RadarRealTimeDataService, I
String sqlEnd = sdf.format(end); String sqlEnd = sdf.format(end);
try { try {
List<PrimaryRadarData> primaryRadarDataList = map.get(getMapKey(radar)); List<PrimaryRadarData> primaryRadarDataList = map.get(getMapKey(radar,number));
if (CollectionUtils.isNotEmpty(primaryRadarDataList)) { if (CollectionUtils.isNotEmpty(primaryRadarDataList)) {
PrimaryRadarData maxData = primaryRadarDataList.stream().max(Comparator.comparingInt(PrimaryRadarData::getValue4)).get(); PrimaryRadarData maxData = primaryRadarDataList.stream().max(Comparator.comparingInt(PrimaryRadarData::getValue4)).get();
@ -266,7 +304,7 @@ public class RadarRealTimeDataServiceImpl implements RadarRealTimeDataService, I
tsanaRadar.setTimeBegin(sqlStart); tsanaRadar.setTimeBegin(sqlStart);
tsanaRadar.setTimeEnd(sqlEnd); tsanaRadar.setTimeEnd(sqlEnd);
tsanaRadar.setTimeCount(count); tsanaRadar.setTimeCount(count);
oracleInsert(tsanaRadar); oracleInsert(tsanaRadar, radar);
} }
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
@ -274,14 +312,14 @@ public class RadarRealTimeDataServiceImpl implements RadarRealTimeDataService, I
} }
private static String getMapKey(SysRadar radar) { private String getMapKey(SysRadar radar,Integer number) {
return radar.getRadarIp() + "-" + radar.getRadarNum() + "-" + radar.getId(); return radar.getRadarIp() + "-" + number + "-" + radar.getId();
} }
@Override @Override
public void addRadar(List<SysRadar> radarList) { public void addRadar(List<SysRadar> radarList) {
List<SysRadar> filterDataList = radarList.stream().filter(item -> !allRadar.contains(item.getRadarIp())).collect(Collectors.toList()); List<SysRadar> filterDataList = radarList.stream().filter(item -> !allRadar.contains(item.getRadarIp())).collect(Collectors.toList());
radarWebSocket(filterDataList); radarWebSocket(filterDataList, identifierHashMap);
} }
@Override @Override
@ -295,7 +333,7 @@ public class RadarRealTimeDataServiceImpl implements RadarRealTimeDataService, I
* @param data * @param data
* @return ModbusResponse * @return ModbusResponse
*/ */
private static SysDiscern copyDataToDiscern(PrimaryRadarData data) { private SysDiscern copyDataToDiscern(PrimaryRadarData data) {
SysDiscern discern = new SysDiscern(); SysDiscern discern = new SysDiscern();
discern.setTagId(data.getTagId()); discern.setTagId(data.getTagId());
discern.setValue4(data.getValue4()); discern.setValue4(data.getValue4());
@ -309,7 +347,7 @@ public class RadarRealTimeDataServiceImpl implements RadarRealTimeDataService, I
* @param data * @param data
* @return ModbusResponse * @return ModbusResponse
*/ */
public static ModbusResponse getModbusResponse(DataResponse data) { public ModbusResponse getModbusResponse(DataResponse data) {
ModbusResponse modbusResponse = new ModbusResponse(); ModbusResponse modbusResponse = new ModbusResponse();
modbusResponse.setRadarNum(data.getData().get(0).toString()); modbusResponse.setRadarNum(data.getData().get(0).toString());
modbusResponse.setTagId(data.getData().get(3).toString()); modbusResponse.setTagId(data.getData().get(3).toString());
@ -325,7 +363,9 @@ public class RadarRealTimeDataServiceImpl implements RadarRealTimeDataService, I
} }
private static void oracleInsert(TsanaRadar tsanaRadar) { private void oracleInsert(TsanaRadar tsanaRadar, SysRadar radar) {
CompletableFuture.runAsync(() -> {
Connection connection = null; Connection connection = null;
PreparedStatement preparedStatement = null; PreparedStatement preparedStatement = null;
try { try {
@ -335,37 +375,21 @@ public class RadarRealTimeDataServiceImpl implements RadarRealTimeDataService, I
String user = "radartest"; String user = "radartest";
String password = "radartest"; String password = "radartest";
connection = DriverManager.getConnection(url, user, password); connection = DriverManager.getConnection(url, user, password);
System.out.println(" ============= 连接数据库成功 ==========");
// ====================================================雷达编号， 标签编号， 工位代号， 标签号， 开始时间， 结束时间， 读取次数 // ====================================================雷达编号， 标签编号， 工位代号， 标签号， 开始时间， 结束时间， 读取次数
String insertStatement = "INSERT INTO xccb.TS_ANARADAR (RADARCODE, LABELCODE, LOCATIONIP , LABELNUM , TIMEBEGIN , TIMEEND , TIMECOUNT) VALUES (?, ?, ?, ?, to_date(?,'yyyy-mm-dd hh24:mi:ss'), to_date(?,'yyyy-mm-dd hh24:mi:ss'), ?)"; String insertStatement = "INSERT INTO xccb.TS_ANARADAR (RADARCODE, LABELCODE, LOCATIONIP , LABELNUM , TIMEBEGIN , TIMEEND , TIMECOUNT) VALUES (?, ?, ?, ?, to_date(?,'yyyy-mm-dd hh24:mi:ss'), to_date(?,'yyyy-mm-dd hh24:mi:ss'), ?)";
System.out.println("insertStatement = " + insertStatement);
preparedStatement = connection.prepareStatement(insertStatement); preparedStatement = connection.prepareStatement(insertStatement);
System.out.println("SQL语句初始化完成");
preparedStatement.setString(1, tsanaRadar.getRadarCode()); preparedStatement.setString(1, tsanaRadar.getRadarCode());
System.out.println("=======RadarCode初始化完成=======" + tsanaRadar.getRadarCode());
preparedStatement.setString(2, tsanaRadar.getLabelCode()); preparedStatement.setString(2, tsanaRadar.getLabelCode());
System.out.println("=======LabelCode初始化完成=======" + tsanaRadar.getLabelCode());
preparedStatement.setString(3, tsanaRadar.getLocationIp()); preparedStatement.setString(3, tsanaRadar.getLocationIp());
System.out.println("=======LocationIp初始化完成=======" + tsanaRadar.getLocationIp());
preparedStatement.setString(4, tsanaRadar.getLabelNum()); preparedStatement.setString(4, tsanaRadar.getLabelNum());
System.out.println("=======LabelNum语句初始化完成=======" + tsanaRadar.getLabelNum());
preparedStatement.setString(5, tsanaRadar.getTimeBegin()); preparedStatement.setString(5, tsanaRadar.getTimeBegin());
System.out.println("=======TimeBegin语句初始化完成=======" + tsanaRadar.getTimeBegin());
preparedStatement.setString(6, tsanaRadar.getTimeEnd()); preparedStatement.setString(6, tsanaRadar.getTimeEnd());
System.out.println("=======TimeEnd语句初始化完成=======" + tsanaRadar.getTimeEnd());
preparedStatement.setInt(7, tsanaRadar.getTimeCount()); preparedStatement.setInt(7, tsanaRadar.getTimeCount());
System.out.println("=======TimeCount初始化完成=======" + tsanaRadar.getTimeCount());
System.out.println("准备执行新增操作.........");
int i = preparedStatement.executeUpdate(); int i = preparedStatement.executeUpdate();
if (i == 0) {
System.out.println("新增数据成功，新增数量： = " + i); } catch (Throwable e) {
} else {
System.out.println("新增数据，新增数量： " + i);
}
} catch (Exception e) {
System.out.println("新增失败。。。。。。");
e.printStackTrace(); e.printStackTrace();
} finally { } finally {
// 关闭连接和statement // 关闭连接和statement
@ -384,5 +408,15 @@ public class RadarRealTimeDataServiceImpl implements RadarRealTimeDataService, I
} }
} }
} }
}, threadPoolTaskExecutor);
} }
public static void main(String[] args) {
LocalDate currentDate = LocalDate.now();
LocalDate twoDaysAgo = currentDate.minusDays(2);
System.out.println(twoDaysAgo);
}
} }