nordic-dev.net/PAMGuard
nordic-dev.net/PAMGuard
2
0
Fork 0
mirror of https://github.com/PAMGuard/PAMGuard.git synced 2024-11-21 22:52:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

DWV Import

Browse Source 
Fixed DWV importer so that a binary file is still created if a DWV file
doesn't exist. this is totally normal in quiet conditions, so the
correct thing to do is to generate a binary file with no data so that
effort is correctly recorded.
This commit is contained in:
Douglas Gillespie 2022-10-18 17:02:49 +01:00
parent 15d4468a0e
commit 0029fbb1c1
3 changed files with 93 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
src/soundtrap/DWVConvertInformation.java
View File

@ -9,13 +9,17 @@ public class DWVConvertInformation {
private STGroupInfo fileGroup;
private int nDWV;
private int nDone;
private int nDWVDone;
private int nFileDone;
private int nFile;
public DWVConvertInformation(STGroupInfo fileGroup, int nDWV, int nDone) {
public DWVConvertInformation(STGroupInfo fileGroup, int nFile, int nFileDone, int nDWV, int nDWVDone) {
this.fileGroup = fileGroup;
this.nFile = nFile;
this.nFileDone = nFileDone;
this.nDWV = nDWV;
this.nDone = nDone;
this.nDWVDone = nDWVDone;
}
@ -36,10 +40,26 @@ public class DWVConvertInformation {
/**
* @return the nDone
* @return the nDWVDone
*/
public int getnDone() {
return nDone;
public int getnDWVDone() {
return nDWVDone;
}
/**
* @return the nFileDone
*/
public int getnFileDone() {
return nFileDone;
}
/**
* @return the nFile
*/
public int getnFile() {
return nFile;
}
}

72
src/soundtrap/DWVConverter.java
View File

@ -81,8 +81,10 @@ public class DWVConverter {
binarySource.setBinaryStorageStream(outputStream);
binaryStream = clickBinaryDataSource.getBinaryStorageStream();
int iFile = 0;
int nFile = fileGroups.size();
for (STGroupInfo fileGroup:fileGroups) {
processFiles(fileGroup);
processFiles(fileGroup, nFile, ++iFile);
if (keepRunning == false) {
break;
}
@ -94,16 +96,30 @@ public class DWVConverter {
return null;
}
private void processFiles(STGroupInfo fileGroup) {
this.publish(new DWVConvertInformation(fileGroup, 0, 0));
if (fileGroup.hasDWV() == false) return;
private void processFiles(STGroupInfo fileGroup, int nFile, int iFile) {
this.publish(new DWVConvertInformation(fileGroup, nFile, iFile, 0, 0));
if (fileGroup.hasDWV() == false) {
/*
* Don't do this. In quiet conditions there will be a BCL file with a start and stop time
* but if there were no detections there will be no dwv file. We should make the pgdf file
* in any case so that there is a full PAMGuard record of effort.
* In other circumstances dwv files don't actually have data, in which case there may still be
* a null file, which is not so good. Will have to think about how to report this - perhaps in
* this case it's better not to make a pgdf file to show a genuine gap in the data.
*/
// return;
}
BCLReader bclReader = new BCLReader(fileGroup.getBclFile());
boolean ok = bclReader.open();
if (ok == false) return;
DWVReader dwvReader = new DWVReader(fileGroup.getDwvFile(), fileGroup.getDwvInfo());
dwvReader.openDWV();
int nDWV = dwvReader.getNumDWV();
int repStep = Math.max(1, nDWV/100);
int nDWV = 0;
DWVReader dwvReader = null;
if (fileGroup.hasDWV()) {
dwvReader = new DWVReader(fileGroup.getDwvFile(), fileGroup.getDwvInfo());
dwvReader.openDWV();
nDWV = dwvReader.getNumDWV();
}
int repStep = Math.max(10, nDWV/100);
int nRead = 0;
while (true) {
BCLLine bclLine = bclReader.nextBCLLine();
@ -127,7 +143,7 @@ public class DWVConverter {
dataLine(fileGroup, bclLine, dwvReader);
nRead++;
if (nRead%repStep == 0) {
this.publish(new DWVConvertInformation(fileGroup, nDWV, nRead));
this.publish(new DWVConvertInformation(fileGroup, nFile, iFile, nDWV, nRead));
}
break;
@ -140,10 +156,14 @@ public class DWVConverter {
// e.printStackTrace();
// }
}
this.publish(new DWVConvertInformation(fileGroup, nFile, iFile, nDWV, nDWV));
}
private void dataLine(STGroupInfo fileGroup, BCLLine bclLine, DWVReader dwvReader) {
double[] dwvData = dwvReader.readNextClick(null);
double[] dwvData = null;
if (dwvReader != null) {
dwvData = dwvReader.readNextClick(null);
}
if (dwvData == null) {
return; // can happen if file didn't flush correclty and some dwv is missing.
}
@ -185,21 +205,37 @@ public class DWVConverter {
}
if (bclLine.getState() == 1) {
long dwvFileStart = fileGroup.getDwvInfo().getTimeInfo().samplingStartTimeUTC;
long wavFileStart = fileGroup.getWavInfo().getTimeInfo().samplingStartTimeUTC;
fileStartMicroseconds = bclLine.getMicroSeconds();
Debug.out.printf("DWV start %s wav start %s bcl start %s\n", PamCalendar.formatDBDateTime(dwvFileStart),
PamCalendar.formatDBDateTime(wavFileStart), PamCalendar.formatDBDateTime(bclLine.getMilliseconds()));
long wavFileStart = fileGroup.getWavInfo().getTimeInfo().samplingStartTimeUTC;
try {
if (fileGroup.getDwvInfo() != null) {
long dwvFileStart = fileGroup.getDwvInfo().getTimeInfo().samplingStartTimeUTC;
Debug.out.printf("DWV start %s wav start %s bcl start %s\n", PamCalendar.formatDBDateTime(dwvFileStart),
PamCalendar.formatDBDateTime(wavFileStart), PamCalendar.formatDBDateTime(bclLine.getMilliseconds()));
}
else {
Debug.out.printf("No DWV File !!! wav start %s bcl start %s\n",
PamCalendar.formatDBDateTime(wavFileStart), PamCalendar.formatDBDateTime(bclLine.getMilliseconds()));
}
}
catch (Exception e) {
System.out.println(e.getMessage());
}
binaryStream.openOutputFiles(bclLine.getMilliseconds());
binaryStream.writeHeader(bclLine.getMilliseconds(), System.currentTimeMillis());
binaryStream.writeModuleHeader();
onEffort = true;
}
if (bclLine.getState() == 0) {
long dwvFileStop = fileGroup.getDwvInfo().getTimeInfo().samplingStopTimeUTC;
long wavFileStop = fileGroup.getWavInfo().getTimeInfo().samplingStopTimeUTC;
Debug.out.printf("DWV stop %s wav stop %s E stop %s\n", PamCalendar.formatDBDateTime(dwvFileStop),
PamCalendar.formatDBDateTime(wavFileStop), PamCalendar.formatDBDateTime(bclLine.getMilliseconds()));
try {
long dwvFileStop = fileGroup.getDwvInfo().getTimeInfo().samplingStopTimeUTC;
long wavFileStop = fileGroup.getWavInfo().getTimeInfo().samplingStopTimeUTC;
Debug.out.printf("DWV stop %s wav stop %s E stop %s\n", PamCalendar.formatDBDateTime(dwvFileStop),
PamCalendar.formatDBDateTime(wavFileStop), PamCalendar.formatDBDateTime(bclLine.getMilliseconds()));
}
catch (Exception e) {
System.out.println(e.getMessage());
}
binaryStream.writeModuleFooter();
binaryStream.writeFooter(bclLine.getMilliseconds(), System.currentTimeMillis(), BinaryFooter.END_UNKNOWN);
binaryStream.closeFile();

20
src/soundtrap/ImportBCLDialog.java
View File

@ -56,7 +56,7 @@ public class ImportBCLDialog extends PamDialog {
private JTextField customDateTimeFormat;
private JLabel fileCountInfo;
private JLabel thisFileInfo;
private JProgressBar allProgress;
private JProgressBar oneFileProgress, totalProgress;
private JComboBox<String> detectorName;
private int nSoundTraps;
private Hashtable<String, String> uniqueDevices = new Hashtable<>();
@ -162,8 +162,10 @@ public class ImportBCLDialog extends PamDialog {
thisFileInfo = new JLabel(" - ");
progressPanel.add(thisFileInfo);
allProgress = new JProgressBar();
progressPanel.add(allProgress);
totalProgress = new JProgressBar();
progressPanel.add(totalProgress);
oneFileProgress = new JProgressBar();
progressPanel.add(oneFileProgress);
startButton = new JButton("Start");
getButtonPanel().add(startButton, 0);
@ -388,10 +390,14 @@ public class ImportBCLDialog extends PamDialog {
thisFileInfo.setText("NO DWV records");
return;
}
int prog = dwvConvertInformation.getnDone() * 100 / dwvConvertInformation.getnDWV();
allProgress.setValue(prog);
thisFileInfo.setText(String.format("Repacked %d of %d clicks", dwvConvertInformation.getnDone(),
dwvConvertInformation.getnDWV()));
int prog = dwvConvertInformation.getnDWVDone() * 100 / dwvConvertInformation.getnDWV();
oneFileProgress.setValue(prog);
thisFileInfo.setText(String.format("Repacked %d of %d clicks in file %d of %d",
dwvConvertInformation.getnDWVDone(), dwvConvertInformation.getnDWV(),
dwvConvertInformation.getnFileDone(), dwvConvertInformation.getnFile()));
prog = dwvConvertInformation.getnFileDone() * 100 / dwvConvertInformation.getnFile();
totalProgress.setValue(prog);
}
@Override