优化显示逻辑
This commit is contained in:
150
modules/mogo-module-service/src/main/assets/LocParse.java
Normal file
150
modules/mogo-module-service/src/main/assets/LocParse.java
Normal file
@@ -0,0 +1,150 @@
|
||||
import java.io.BufferedReader;
|
||||
import java.io.BufferedWriter;
|
||||
import java.io.File;
|
||||
import java.io.FileInputStream;
|
||||
import java.io.FileOutputStream;
|
||||
import java.io.InputStreamReader;
|
||||
import java.io.OutputStreamWriter;
|
||||
|
||||
public
|
||||
/**
|
||||
* @author congtaowang
|
||||
* @since 2021/3/26
|
||||
*
|
||||
* 描述
|
||||
*/
|
||||
class LocParse {
|
||||
|
||||
public static void main( String[] args ) {
|
||||
new Thread( new Runnable() {
|
||||
@Override
|
||||
public void run() {
|
||||
try {
|
||||
LocParse.run();
|
||||
} catch ( Exception e ) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
} ).run();
|
||||
|
||||
}
|
||||
|
||||
private static void run() throws Exception {
|
||||
InputStreamReader isr = new InputStreamReader( new FileInputStream( "loc.csv" ) );
|
||||
BufferedReader br = new BufferedReader( isr );
|
||||
File loc = new File( "loc.txt" );
|
||||
if ( loc.exists() ) {
|
||||
loc.delete();
|
||||
}
|
||||
loc.createNewFile();
|
||||
OutputStreamWriter locOsw = new OutputStreamWriter( new FileOutputStream( loc ) );
|
||||
BufferedWriter locWr = new BufferedWriter( locOsw );
|
||||
|
||||
final int adasRecAmount = 10;
|
||||
final int intervalLineAmount = 50;
|
||||
|
||||
BufferedWriter writers[] = new BufferedWriter[adasRecAmount];
|
||||
|
||||
for ( int i = 0; i < adasRecAmount; i++ ) {
|
||||
File file = new File( "adas" + i + ".txt" );
|
||||
if ( file.exists() ) {
|
||||
file.delete();
|
||||
}
|
||||
file.createNewFile();
|
||||
OutputStreamWriter osw = new OutputStreamWriter( new FileOutputStream( file ) );
|
||||
writers[i] = new BufferedWriter( osw );
|
||||
}
|
||||
|
||||
String line = null;
|
||||
final int pLon = 1;
|
||||
final int pLat = 2;
|
||||
final int pAlt = 3;
|
||||
final int pHeading = 4;
|
||||
final int pSpeed = 6;
|
||||
final int pDistance = 7;
|
||||
final int pReceiverDataTime = 8;
|
||||
final int pAdasSatelliteTime = 9;
|
||||
final int pSystemTime = 10;
|
||||
final int pSatelliteTime = 11;
|
||||
|
||||
int counter = 0;
|
||||
while ( ( line = br.readLine() ) != null ) {
|
||||
line = line.replace( " ", "" );
|
||||
String seg[] = line.split( "," );
|
||||
|
||||
double lon = Double.parseDouble( seg[pLon] );
|
||||
double lat = Double.parseDouble( seg[pLat] );
|
||||
double alt = Double.parseDouble( seg[pAlt] );
|
||||
double heading = Double.parseDouble( seg[pHeading] );
|
||||
double speed = Double.parseDouble( seg[pSpeed] );
|
||||
double distance = Double.parseDouble( seg[pDistance] );
|
||||
long receiverDataTime = Long.parseLong( seg[pReceiverDataTime] );
|
||||
long adasSatelliteTime = Long.parseLong( seg[pAdasSatelliteTime] );
|
||||
long systemTime = Long.parseLong( seg[pSystemTime] );
|
||||
long satelliteTime = Long.parseLong( seg[pSatelliteTime] );
|
||||
|
||||
// 定位
|
||||
StringBuilder locJson = new StringBuilder( "{" );
|
||||
locJson.append( "\"lon\":" + lon );
|
||||
locJson.append( ",\"lat\":" + lat );
|
||||
locJson.append( ",\"alt\":" + alt );
|
||||
locJson.append( ",\"heading\":" + heading );
|
||||
locJson.append( ",\"speed\":" + speed );
|
||||
locJson.append( ",\"systemTime\":" + systemTime );
|
||||
locJson.append( ",\"receiverDataTime\":" + receiverDataTime );
|
||||
locJson.append( ",\"adasSatelliteTime\":" + adasSatelliteTime );
|
||||
locJson.append( ",\"satelliteTime\":" + satelliteTime );
|
||||
locJson.append( "}\n" );
|
||||
locWr.write( locJson.toString() );
|
||||
|
||||
int writersCount = counter++ / intervalLineAmount;
|
||||
if ( writersCount > adasRecAmount ) {
|
||||
writersCount = adasRecAmount;
|
||||
}
|
||||
for ( int i = 0; i < writersCount; i++ ) {
|
||||
|
||||
int type = 3;
|
||||
switch ( i ) {
|
||||
case 1:
|
||||
case 2:
|
||||
case 3:
|
||||
case 4:
|
||||
case 6:
|
||||
type = i;
|
||||
break;
|
||||
case 0:
|
||||
case 5:
|
||||
case 7:
|
||||
case 8:
|
||||
case 9:
|
||||
type = 3;
|
||||
break;
|
||||
}
|
||||
|
||||
StringBuilder adasJson = new StringBuilder( "{" );
|
||||
adasJson.append( "\"type\":" + type );
|
||||
adasJson.append( ",\"uuid\":" + "\"2_" + i + "\"" );
|
||||
adasJson.append( ",\"lon\":" + lon );
|
||||
adasJson.append( ",\"lat\":" + lat );
|
||||
adasJson.append( ",\"alt\":" + alt );
|
||||
adasJson.append( ",\"heading\":" + heading );
|
||||
adasJson.append( ",\"distance\":" + distance );
|
||||
adasJson.append( ",\"speed\":" + speed );
|
||||
adasJson.append( ",\"systemTime\":" + systemTime );
|
||||
adasJson.append( ",\"satelliteTime\":" + satelliteTime );
|
||||
adasJson.append( ",\"dataAccuracy\":" + 1 );
|
||||
adasJson.append( "}\n" );
|
||||
writers[i].write( adasJson.toString() );
|
||||
}
|
||||
// adas
|
||||
}
|
||||
|
||||
locWr.flush();
|
||||
locWr.close();
|
||||
|
||||
for ( BufferedWriter writer : writers ) {
|
||||
writer.flush();
|
||||
writer.close();
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user