1、把倾角计数据的处理挪到一个新的服务InclineServer

2、InclineServer处理D350,推送第三方
This commit is contained in:
weidong 2025-10-16 10:37:56 +08:00
parent 353e94cd05
commit 0ba960219b
2 changed files with 5 additions and 2 deletions

View File

@ -78,6 +78,7 @@ public class D350SurfaceInclineMessageExecutor implements Executor<D350SurfaceIn
.select("d.latitude as latitude") .select("d.latitude as latitude")
.select("d.longitude as longitude") .select("d.longitude as longitude")
.leftJoin("gnssstatus d on t.deviceid = d.deviceid") .leftJoin("gnssstatus d on t.deviceid = d.deviceid")
.eq("t.deviceid",deviceId)
.last("limit 1"); .last("limit 1");
device = deviceMapper.selectJoinOne(GnssDeviceJoin.class, jquery); device = deviceMapper.selectJoinOne(GnssDeviceJoin.class, jquery);
if(device != null) deviceInfoMap.put(deviceId,device); if(device != null) deviceInfoMap.put(deviceId,device);

View File

@ -126,8 +126,10 @@ public class InclineDataForwarder{
data.setZy(NumberUtils.scale((double) Zy, 3)); data.setZy(NumberUtils.scale((double) Zy, 3));
data.setZz(NumberUtils.scale((double) Zz, 3)); data.setZz(NumberUtils.scale((double) Zz, 3));
// 经纬度 // 经纬度
if(device.getLongitude()!=null && device.getLatitude()!=null) {
data.setDevLng(device.getLongitude()); data.setDevLng(device.getLongitude());
data.setDevLat(device.getLatitude()); data.setDevLat(device.getLatitude());
}
// 发送 // 发送
TCPClient tcpClient1 = tcpClientMap.get(device.getFwd_group_id()); TCPClient tcpClient1 = tcpClientMap.get(device.getFwd_group_id());