win代码上传
parent
3145b28624
commit
9f26dbb992
|
|
@ -29,6 +29,7 @@ import java.sql.SQLException;
|
||||||
import java.util.*;
|
import java.util.*;
|
||||||
import java.util.concurrent.CompletableFuture;
|
import java.util.concurrent.CompletableFuture;
|
||||||
import java.util.concurrent.CopyOnWriteArrayList;
|
import java.util.concurrent.CopyOnWriteArrayList;
|
||||||
|
import java.util.concurrent.ExecutorService;
|
||||||
import java.util.stream.Collectors;
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
@ -171,13 +172,23 @@ public class RadarStatusController implements InitializingBean {
|
||||||
@Override
|
@Override
|
||||||
public void run() {
|
public void run() {
|
||||||
while (true) {
|
while (true) {
|
||||||
|
// long start = System.currentTimeMillis();
|
||||||
task(radar, socket);
|
task(radar, socket);
|
||||||
|
|
||||||
|
System.out.println("雷达ip : =====" + radar.getRadarIp());
|
||||||
|
try {
|
||||||
|
Thread.sleep(3000);
|
||||||
|
} catch (InterruptedException e) {
|
||||||
|
throw new RuntimeException(e);
|
||||||
|
}
|
||||||
|
// System.out.println("耗时时间: " + (System.currentTimeMillis() - start) );
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
};
|
};
|
||||||
// timer.schedule(timerTask,0);
|
CompletableFuture.runAsync(() -> {
|
||||||
timerTask.run();
|
timerTask.run();
|
||||||
|
});
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
|
|
||||||
e.printStackTrace();
|
e.printStackTrace();
|
||||||
|
|
@ -186,8 +197,11 @@ public class RadarStatusController implements InitializingBean {
|
||||||
}
|
}
|
||||||
|
|
||||||
private void task(SysRadar radar, Socket socket) {
|
private void task(SysRadar radar, Socket socket) {
|
||||||
|
|
||||||
try {
|
try {
|
||||||
|
long start = System.currentTimeMillis();
|
||||||
List<SysDiscern> discernList = new ArrayList<>();
|
List<SysDiscern> discernList = new ArrayList<>();
|
||||||
|
|
||||||
// socket连接成功返回数据
|
// socket连接成功返回数据
|
||||||
DataResponse data = SocketUtil.getData(socket, radar.getRadarLocation(), radar.getRadarIp());
|
DataResponse data = SocketUtil.getData(socket, radar.getRadarLocation(), radar.getRadarIp());
|
||||||
// 天线号字符串转集合
|
// 天线号字符串转集合
|
||||||
|
|
@ -263,7 +277,7 @@ public class RadarStatusController implements InitializingBean {
|
||||||
} else {
|
} else {
|
||||||
|
|
||||||
}
|
}
|
||||||
|
System.out.println("耗时时间: " + (System.currentTimeMillis() - start) );
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -74,7 +74,7 @@ public class SysRadarController extends BaseController {
|
||||||
radar.setCreateBy(getLoginName());
|
radar.setCreateBy(getLoginName());
|
||||||
int result = radarService.insertRadar(radar);
|
int result = radarService.insertRadar(radar);
|
||||||
List<SysRadar> sysRadars = radarService.selectRadarList(new SysRadar());
|
List<SysRadar> sysRadars = radarService.selectRadarList(new SysRadar());
|
||||||
RadarStatusController.addRadar(sysRadars);
|
|
||||||
return toAjax(result);
|
return toAjax(result);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -6,9 +6,9 @@ spring:
|
||||||
druid:
|
druid:
|
||||||
# 主库数据源
|
# 主库数据源
|
||||||
master:
|
master:
|
||||||
url: jdbc:mysql://localhost:3306/ry?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
|
url: jdbc:mysql://39.104.15.118:3306/ry?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
|
||||||
username: root
|
username: root
|
||||||
password: 12345678
|
password: Orderfood@2022
|
||||||
# 从库数据源
|
# 从库数据源
|
||||||
slave:
|
slave:
|
||||||
# 从数据源开关/默认关闭
|
# 从数据源开关/默认关闭
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue