mirror of
https://github.com/PAMGuard/PAMGuard.git
synced 2024-11-21 22:52:22 +00:00
Work on localisation export
Not ready to rock yet.
This commit is contained in:
parent
f24dd9bb91
commit
0165982a22
@ -4,7 +4,7 @@
|
||||
<groupId>org.pamguard</groupId>
|
||||
<artifactId>Pamguard</artifactId>
|
||||
<name>Pamguard</name>
|
||||
<version>2.02.11f</version>
|
||||
<version>2.02.12</version>
|
||||
<description>Pamguard using Maven to control dependencies</description>
|
||||
<url>www.pamguard.org</url>
|
||||
<organization>
|
||||
|
@ -173,8 +173,19 @@ public class AcquisitionControl extends RawInputControlledUnit implements PamSet
|
||||
|
||||
registerDaqSystem(new SoundCardSystem(this));
|
||||
if (PlatformInfo.calculateOS() == OSType.WINDOWS) {
|
||||
long tic = System.currentTimeMillis();
|
||||
long toc = tic;
|
||||
registerDaqSystem(new ASIOSoundSystem(this));
|
||||
toc = System.currentTimeMillis();
|
||||
if (toc-tic>1000) {
|
||||
System.out.printf("Registering ASIOSoundSystem took %3.1fs\n", (double)(toc-tic)/1000.);
|
||||
}
|
||||
tic = System.currentTimeMillis();
|
||||
registerDaqSystem(new NewAsioSoundSystem(this));
|
||||
toc = System.currentTimeMillis();
|
||||
if (toc-tic>1000) {
|
||||
System.out.printf("Registering NewAsioSoundSystem took %3.1fs\n", (double)(toc-tic)/1000.);
|
||||
}
|
||||
}
|
||||
registerDaqSystem(new FileInputSystem(this));
|
||||
registerDaqSystem(folderSystem = new FolderInputSystem(this));
|
||||
|
21
src/Localiser/LocalisationAlgorithm.java
Normal file
21
src/Localiser/LocalisationAlgorithm.java
Normal file
@ -0,0 +1,21 @@
|
||||
package Localiser;
|
||||
|
||||
import PamDetection.LocContents;
|
||||
import PamDetection.LocalisationInfo;
|
||||
|
||||
/**
|
||||
* Interface to attach to localisation algorithms which can provide basic information
|
||||
* (primarily for better book keeping and Tethys output)
|
||||
* @author dg50
|
||||
*
|
||||
*/
|
||||
public interface LocalisationAlgorithm {
|
||||
|
||||
/**
|
||||
* Get the likely content flags for this localiser.
|
||||
* @see LocalisationInfo
|
||||
* @see LocContents
|
||||
* @return localisation flags.
|
||||
*/
|
||||
public int getLocalisationContents();
|
||||
}
|
@ -1,5 +1,6 @@
|
||||
package Localiser.algorithms.timeDelayLocalisers.bearingLoc;
|
||||
|
||||
import Localiser.LocalisationAlgorithm;
|
||||
import pamMaths.PamVector;
|
||||
|
||||
/**
|
||||
@ -8,7 +9,7 @@ import pamMaths.PamVector;
|
||||
* @author Doug Gillespie
|
||||
*
|
||||
*/
|
||||
public interface BearingLocaliser {
|
||||
public interface BearingLocaliser extends LocalisationAlgorithm {
|
||||
|
||||
/**
|
||||
* Do any preparation necessary (e.g. creation of look up tables)
|
||||
|
@ -1,5 +1,6 @@
|
||||
package Localiser.algorithms.timeDelayLocalisers.bearingLoc;
|
||||
|
||||
import PamDetection.LocContents;
|
||||
import pamMaths.PamVector;
|
||||
|
||||
public class CombinedBearingLocaliser implements BearingLocaliser {
|
||||
@ -23,6 +24,11 @@ public class CombinedBearingLocaliser implements BearingLocaliser {
|
||||
firstSimplexStep[0] = firstSimplexStep[1] = Math.PI/180.;
|
||||
}
|
||||
|
||||
@Override
|
||||
public int getLocalisationContents() {
|
||||
return LocContents.HAS_BEARING | LocContents.HAS_AMBIGUITY;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void prepare(int[] arrayElements, long timeMillis, double timingError) {
|
||||
firstLocaliser.prepare(arrayElements, timeMillis, timingError);
|
||||
|
@ -5,6 +5,7 @@ import Array.PamArray;
|
||||
import Jama.LUDecomposition;
|
||||
import Jama.Matrix;
|
||||
import Jama.QRDecomposition;
|
||||
import PamDetection.LocContents;
|
||||
import PamUtils.PamUtils;
|
||||
import pamMaths.PamVector;
|
||||
|
||||
@ -30,6 +31,11 @@ public class LSQBearingLocaliser implements BearingLocaliser {
|
||||
this.timingError = timingError;
|
||||
}
|
||||
|
||||
@Override
|
||||
public int getLocalisationContents() {
|
||||
return LocContents.HAS_BEARING | LocContents.HAS_AMBIGUITY;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void prepare(int[] arrayElements, long timeMillis, double timingError) {
|
||||
/*
|
||||
|
@ -6,6 +6,7 @@ import Array.ArrayManager;
|
||||
import Array.PamArray;
|
||||
import Jama.Matrix;
|
||||
import Localiser.algorithms.Correlations;
|
||||
import PamDetection.LocContents;
|
||||
import PamUtils.ArrayDump;
|
||||
import PamUtils.PamUtils;
|
||||
import PamUtils.SystemTiming;
|
||||
@ -61,6 +62,11 @@ public class MLGridBearingLocaliser implements BearingLocaliser {
|
||||
prepare(arrayElements, timMillis, timingError, Math.toRadians(1), Math.toRadians(1));
|
||||
}
|
||||
|
||||
@Override
|
||||
public int getLocalisationContents() {
|
||||
return LocContents.HAS_BEARING | LocContents.HAS_AMBIGUITY;
|
||||
}
|
||||
|
||||
synchronized private void prepare(int[] arrayElements, long timeMillis, double timingError, double thetaStep, double phiStep) {
|
||||
this.timingError = timingError;
|
||||
this.thetaStep = thetaStep;
|
||||
|
@ -8,6 +8,7 @@ import Jama.Matrix;
|
||||
import Localiser.algorithms.Correlations;
|
||||
import Localiser.algorithms.PeakPosition2D;
|
||||
import Localiser.algorithms.PeakSearch;
|
||||
import PamDetection.LocContents;
|
||||
import PamUtils.ArrayDump;
|
||||
import PamUtils.PamUtils;
|
||||
import PamUtils.SystemTiming;
|
||||
@ -73,6 +74,11 @@ public class MLGridBearingLocaliser2 implements BearingLocaliser {
|
||||
prepare(arrayElements, timMillis, timingError, Math.toRadians(3), Math.toRadians(3));
|
||||
}
|
||||
|
||||
@Override
|
||||
public int getLocalisationContents() {
|
||||
return LocContents.HAS_BEARING | LocContents.HAS_AMBIGUITY;
|
||||
}
|
||||
|
||||
synchronized private void prepare(int[] arrayElements, long timeMillis, double timingError, double thetaStep, double phiStep) {
|
||||
this.timingError = timingError;
|
||||
this.thetaStep = thetaStep;
|
||||
|
@ -3,6 +3,8 @@
|
||||
*/
|
||||
package Localiser.algorithms.timeDelayLocalisers.bearingLoc;
|
||||
|
||||
import PamDetection.LocContents;
|
||||
|
||||
/**
|
||||
* @author dg50
|
||||
*
|
||||
@ -19,6 +21,11 @@ public class MLLineBearingLocaliser2 extends MLGridBearingLocaliser2 {
|
||||
// TODO Auto-generated constructor stub
|
||||
}
|
||||
|
||||
@Override
|
||||
public int getLocalisationContents() {
|
||||
return LocContents.HAS_BEARING | LocContents.HAS_AMBIGUITY | LocContents.HAS_AMBIGUITY;
|
||||
}
|
||||
|
||||
/**
|
||||
* Convert a bin into an angle.
|
||||
* @param bin bin index
|
||||
|
@ -6,6 +6,7 @@ import Array.ArrayManager;
|
||||
import Array.PamArray;
|
||||
import Jama.Matrix;
|
||||
import Jama.QRDecomposition;
|
||||
import PamDetection.LocContents;
|
||||
import PamUtils.PamUtils;
|
||||
import pamMaths.PamVector;
|
||||
|
||||
@ -17,111 +18,111 @@ import pamMaths.PamVector;
|
||||
*/
|
||||
public class PairBearingLocaliser implements BearingLocaliser {
|
||||
|
||||
public class LSQBearingLocaliser implements BearingLocaliser {
|
||||
|
||||
private int hydrophoneBitMap;
|
||||
private long timeMillis;
|
||||
private double timingError;
|
||||
|
||||
private Matrix hydrophoneVectors, hydrophoneUnitVectors;
|
||||
private double[] hydrophoneSpacing;
|
||||
private PamArray currentArray;
|
||||
private int arrayType;
|
||||
private PamVector[] arrayAxis;
|
||||
// private LUDecomposition luHydrophoneUnitMatrix;
|
||||
private QRDecomposition qrHydrophones;
|
||||
|
||||
public LSQBearingLocaliser(int hydrophoneBitMap, long timeMillis, double timingError) {
|
||||
this.hydrophoneBitMap = hydrophoneBitMap;
|
||||
this.timeMillis = timeMillis;
|
||||
this.timingError = timingError;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void prepare(int[] arrayElements, long timeMillis, double timingError) {
|
||||
/*
|
||||
* Set up the matrixes of inter hydrophone vectors.
|
||||
*/
|
||||
|
||||
hydrophoneBitMap = PamUtils.makeChannelMap(arrayElements);
|
||||
ArrayManager arrayManager = ArrayManager.getArrayManager();
|
||||
currentArray = arrayManager.getCurrentArray();
|
||||
arrayType = arrayManager.getArrayShape(currentArray, hydrophoneBitMap);
|
||||
|
||||
arrayAxis = arrayManager.getArrayDirections(currentArray, hydrophoneBitMap);
|
||||
|
||||
int nHyd = arrayElements.length;
|
||||
int nDelay = (nHyd*(nHyd-1))/2;
|
||||
hydrophoneVectors = new Matrix(nDelay, 3);
|
||||
hydrophoneUnitVectors = new Matrix(nDelay, 3);
|
||||
hydrophoneSpacing = new double[nDelay];
|
||||
int iRow = 0;
|
||||
for (int i = 0; i < nHyd; i++) {
|
||||
PamVector vi = currentArray.getAbsHydrophoneVector(i, timeMillis);
|
||||
for (int j = i+1; j <nHyd; j++) {
|
||||
PamVector vj = currentArray.getAbsHydrophoneVector(j, timeMillis);
|
||||
PamVector v = vj.sub(vi);
|
||||
hydrophoneSpacing[iRow] = v.norm();
|
||||
PamVector uv = v.getUnitVector();
|
||||
for (int e = 0; e < 3; e++) {
|
||||
hydrophoneVectors.set(iRow, e, v.getElement(e));
|
||||
hydrophoneUnitVectors.set(iRow, e, uv.getElement(e));
|
||||
}
|
||||
iRow++;
|
||||
}
|
||||
}
|
||||
// luHydrophoneUnitMatrix = new LUDecomposition(hydrophoneUnitVectors);
|
||||
qrHydrophones = new QRDecomposition(hydrophoneUnitVectors);
|
||||
}
|
||||
|
||||
@Override
|
||||
public int getArrayType() {
|
||||
return arrayType;
|
||||
}
|
||||
|
||||
@Override
|
||||
public int getHydrophoneMap() {
|
||||
return hydrophoneBitMap;
|
||||
}
|
||||
|
||||
@Override
|
||||
public PamVector[] getArrayAxis() {
|
||||
return arrayAxis;
|
||||
}
|
||||
|
||||
/*
|
||||
* @return true if a new grid needs to be created
|
||||
*/
|
||||
private boolean resetArray(long timeMillis){
|
||||
|
||||
if (currentArray == null || (this.timeMillis!=timeMillis && currentArray.getHydrophoneLocator().isChangeable())){
|
||||
prepare(PamUtils.getChannelArray(hydrophoneBitMap), timeMillis, 1e-6);
|
||||
this.timeMillis = timeMillis;
|
||||
return true;
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
@Override
|
||||
public double[][] localise(double[] delays, long timeMillis) {
|
||||
resetArray(timeMillis);
|
||||
Matrix normDelays = new Matrix(delays.length, 1);
|
||||
double c = currentArray.getSpeedOfSound();
|
||||
for (int i = 0; i < delays.length; i++) {
|
||||
normDelays.set(i, 0, -delays[i]*c/hydrophoneSpacing[i]);
|
||||
}
|
||||
// Matrix soln = luHydrophoneUnitMatrix.solve(normDelays);
|
||||
Matrix soln2 = qrHydrophones.solve(normDelays);
|
||||
double[][] angs = new double[2][2];
|
||||
PamVector v = new PamVector(soln2.get(0, 0), soln2.get(1,0), soln2.get(2, 0));
|
||||
double m = v.normalise();
|
||||
angs[0][0] = Math.PI/2. - Math.atan2(v.getElement(0),v.getElement(1));
|
||||
angs[0][1] = Math.asin(v.getElement(2));
|
||||
return angs;
|
||||
}
|
||||
|
||||
}
|
||||
// public class LSQBearingLocaliser implements BearingLocaliser {
|
||||
//
|
||||
// private int hydrophoneBitMap;
|
||||
// private long timeMillis;
|
||||
// private double timingError;
|
||||
//
|
||||
// private Matrix hydrophoneVectors, hydrophoneUnitVectors;
|
||||
// private double[] hydrophoneSpacing;
|
||||
// private PamArray currentArray;
|
||||
// private int arrayType;
|
||||
// private PamVector[] arrayAxis;
|
||||
// // private LUDecomposition luHydrophoneUnitMatrix;
|
||||
// private QRDecomposition qrHydrophones;
|
||||
//
|
||||
// public LSQBearingLocaliser(int hydrophoneBitMap, long timeMillis, double timingError) {
|
||||
// this.hydrophoneBitMap = hydrophoneBitMap;
|
||||
// this.timeMillis = timeMillis;
|
||||
// this.timingError = timingError;
|
||||
// }
|
||||
//
|
||||
// @Override
|
||||
// public void prepare(int[] arrayElements, long timeMillis, double timingError) {
|
||||
// /*
|
||||
// * Set up the matrixes of inter hydrophone vectors.
|
||||
// */
|
||||
//
|
||||
// hydrophoneBitMap = PamUtils.makeChannelMap(arrayElements);
|
||||
// ArrayManager arrayManager = ArrayManager.getArrayManager();
|
||||
// currentArray = arrayManager.getCurrentArray();
|
||||
// arrayType = arrayManager.getArrayShape(currentArray, hydrophoneBitMap);
|
||||
//
|
||||
// arrayAxis = arrayManager.getArrayDirections(currentArray, hydrophoneBitMap);
|
||||
//
|
||||
// int nHyd = arrayElements.length;
|
||||
// int nDelay = (nHyd*(nHyd-1))/2;
|
||||
// hydrophoneVectors = new Matrix(nDelay, 3);
|
||||
// hydrophoneUnitVectors = new Matrix(nDelay, 3);
|
||||
// hydrophoneSpacing = new double[nDelay];
|
||||
// int iRow = 0;
|
||||
// for (int i = 0; i < nHyd; i++) {
|
||||
// PamVector vi = currentArray.getAbsHydrophoneVector(i, timeMillis);
|
||||
// for (int j = i+1; j <nHyd; j++) {
|
||||
// PamVector vj = currentArray.getAbsHydrophoneVector(j, timeMillis);
|
||||
// PamVector v = vj.sub(vi);
|
||||
// hydrophoneSpacing[iRow] = v.norm();
|
||||
// PamVector uv = v.getUnitVector();
|
||||
// for (int e = 0; e < 3; e++) {
|
||||
// hydrophoneVectors.set(iRow, e, v.getElement(e));
|
||||
// hydrophoneUnitVectors.set(iRow, e, uv.getElement(e));
|
||||
// }
|
||||
// iRow++;
|
||||
// }
|
||||
// }
|
||||
// // luHydrophoneUnitMatrix = new LUDecomposition(hydrophoneUnitVectors);
|
||||
// qrHydrophones = new QRDecomposition(hydrophoneUnitVectors);
|
||||
// }
|
||||
//
|
||||
// @Override
|
||||
// public int getArrayType() {
|
||||
// return arrayType;
|
||||
// }
|
||||
//
|
||||
// @Override
|
||||
// public int getHydrophoneMap() {
|
||||
// return hydrophoneBitMap;
|
||||
// }
|
||||
//
|
||||
// @Override
|
||||
// public PamVector[] getArrayAxis() {
|
||||
// return arrayAxis;
|
||||
// }
|
||||
//
|
||||
// /*
|
||||
// * @return true if a new grid needs to be created
|
||||
// */
|
||||
// private boolean resetArray(long timeMillis){
|
||||
//
|
||||
// if (currentArray == null || (this.timeMillis!=timeMillis && currentArray.getHydrophoneLocator().isChangeable())){
|
||||
// prepare(PamUtils.getChannelArray(hydrophoneBitMap), timeMillis, 1e-6);
|
||||
// this.timeMillis = timeMillis;
|
||||
// return true;
|
||||
// }
|
||||
//
|
||||
// return false;
|
||||
// }
|
||||
//
|
||||
// @Override
|
||||
// public double[][] localise(double[] delays, long timeMillis) {
|
||||
// resetArray(timeMillis);
|
||||
// Matrix normDelays = new Matrix(delays.length, 1);
|
||||
// double c = currentArray.getSpeedOfSound();
|
||||
// for (int i = 0; i < delays.length; i++) {
|
||||
// normDelays.set(i, 0, -delays[i]*c/hydrophoneSpacing[i]);
|
||||
// }
|
||||
// // Matrix soln = luHydrophoneUnitMatrix.solve(normDelays);
|
||||
// Matrix soln2 = qrHydrophones.solve(normDelays);
|
||||
// double[][] angs = new double[2][2];
|
||||
// PamVector v = new PamVector(soln2.get(0, 0), soln2.get(1,0), soln2.get(2, 0));
|
||||
// double m = v.normalise();
|
||||
// angs[0][0] = Math.PI/2. - Math.atan2(v.getElement(0),v.getElement(1));
|
||||
// angs[0][1] = Math.asin(v.getElement(2));
|
||||
// return angs;
|
||||
// }
|
||||
//
|
||||
// }
|
||||
|
||||
private int[] phoneNumbers;
|
||||
|
||||
@ -206,6 +207,11 @@ public class PairBearingLocaliser implements BearingLocaliser {
|
||||
}
|
||||
|
||||
|
||||
@Override
|
||||
public int getLocalisationContents() {
|
||||
return LocContents.HAS_BEARING | LocContents.HAS_AMBIGUITY | LocContents.HAS_AMBIGUITY;
|
||||
}
|
||||
|
||||
/**
|
||||
* Some hydrophone locators have arrays which change with time. In this case the ML grid localiser will need to recalculate the look up table for localised ppositions
|
||||
*
|
||||
|
@ -14,6 +14,7 @@ import Array.ArrayManager;
|
||||
import Array.PamArray;
|
||||
import Jama.Matrix;
|
||||
import Jama.QRDecomposition;
|
||||
import PamDetection.LocContents;
|
||||
import PamUtils.PamUtils;
|
||||
import pamMaths.PamVector;
|
||||
|
||||
@ -39,6 +40,11 @@ public class SimplexBearingLocaliser implements BearingLocaliser {
|
||||
this.timingError = timingError;
|
||||
}
|
||||
|
||||
@Override
|
||||
public int getLocalisationContents() {
|
||||
return LocContents.HAS_BEARING | LocContents.HAS_AMBIGUITY;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void prepare(int[] arrayElements, long timeMillis, double timingError) {
|
||||
/*
|
||||
|
@ -11,6 +11,7 @@ public class LocContents implements LocalisationInfo {
|
||||
|
||||
/**Flags for what type of 'Raw' localisation information from a detection**/
|
||||
|
||||
|
||||
/**
|
||||
* Time delays are present
|
||||
*/
|
||||
@ -78,8 +79,47 @@ public class LocContents implements LocalisationInfo {
|
||||
/**
|
||||
* Errors parallel and perpendicular to the ships track.
|
||||
*/
|
||||
static public final int HAS_PERPENDICULARERRORS = 0x100;
|
||||
static public final int HAS_PERPENDICULARERRORS = 0x1000;
|
||||
|
||||
static public final int[] allTypes = {HAS_TIMEDELAYS, HAS_ECHO, HAS_BEARING, HAS_BEARINGERROR, HAS_RANGE, HAS_RANGEERROR, HAS_DEPTH, HAS_DEPTHERROR,
|
||||
HAS_LATLONG, HAS_XY, HAS_XYZ, HAS_AMBIGUITY, HAS_PERPENDICULARERRORS};
|
||||
|
||||
/**
|
||||
* Main types of interest.
|
||||
*/
|
||||
static public final int[] mainTypes = {HAS_BEARING, HAS_RANGE, HAS_DEPTH, HAS_LATLONG, HAS_XY, HAS_XYZ};
|
||||
|
||||
public static String getTypeString(int type) {
|
||||
switch (type) {
|
||||
case HAS_TIMEDELAYS:
|
||||
return "Time delays";
|
||||
case HAS_ECHO:
|
||||
return "Echoes";
|
||||
case HAS_BEARING:
|
||||
return "Bearing";
|
||||
case HAS_BEARINGERROR:
|
||||
return "Bearing Error";
|
||||
case HAS_RANGE:
|
||||
return "Range";
|
||||
case HAS_DEPTH:
|
||||
return "Depth";
|
||||
case HAS_RANGEERROR:
|
||||
return "Range Error";
|
||||
case HAS_DEPTHERROR:
|
||||
return "Depth Error";
|
||||
case HAS_LATLONG:
|
||||
return "Lat Long";
|
||||
case HAS_XY:
|
||||
return "XY";
|
||||
case HAS_XYZ:
|
||||
return "XYZ";
|
||||
case HAS_AMBIGUITY:
|
||||
return "Ambiguity";
|
||||
case HAS_PERPENDICULARERRORS:
|
||||
return "Perpendicular Errors";
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
/**
|
||||
* bitmap of flags saying what's in the localisation information
|
||||
|
@ -234,6 +234,8 @@ public class PamModuleInfo implements PamDependent{
|
||||
// Class[] paramList = new Class[1];
|
||||
// paramList[0] = unitName.getClass();
|
||||
boolean error = false;
|
||||
long tic = System.currentTimeMillis();
|
||||
long toc = tic;
|
||||
try {
|
||||
Constructor constructor = moduleClass.getConstructor(constrParams1);
|
||||
newUnit = (PamControlledUnit) constructor.newInstance(pamConfiguration, unitName);
|
||||
@ -262,6 +264,11 @@ public class PamModuleInfo implements PamDependent{
|
||||
return null;
|
||||
}
|
||||
}
|
||||
toc = System.currentTimeMillis();
|
||||
if (toc-tic > 1000) {
|
||||
System.out.printf("Module %s-%s was slow to load, taking %3.1f seconds\n", newUnit.getUnitType(),
|
||||
newUnit.getUnitName(), (double)(toc-tic)/1000.);
|
||||
}
|
||||
|
||||
setNInstances(nInstances + 1);
|
||||
|
||||
|
@ -62,7 +62,7 @@ public class RWEProcess extends PamProcess {
|
||||
this.rweControl = rweControl;
|
||||
rweDataBlock = new RWEDataBlock(rweControl, rweControl.getUnitName(), this, 0);
|
||||
addOutputDataBlock(rweDataBlock);
|
||||
rweDataBlock.setLocalisationContents(LocContents.HAS_BEARING);
|
||||
// rweDataBlock.setLocalisationContents(LocContents.HAS_BEARING);
|
||||
rweDataBlock.setDatagramProvider(new RWEDatagramProvider());
|
||||
rweDataBlock.setOverlayDraw(new RWEOverlayGraphics(this, rweDataBlock));
|
||||
StandardSymbolManager symbolManager = symbolManager = new RWESymbolManager(rweDataBlock, RWEOverlayGraphics.defaultSymbol, true);
|
||||
@ -138,6 +138,11 @@ public class RWEProcess extends PamProcess {
|
||||
rweChannelProcesses[i] = new RWEChannelProcess(this, i);
|
||||
}
|
||||
}
|
||||
int nChan = PamUtils.getNumChannels(channelMap);
|
||||
if (nChan > 1) {
|
||||
// really needs properly setting up with channel groups
|
||||
rweDataBlock.setLocalisationContents(LocContents.HAS_BEARING);
|
||||
}
|
||||
// checkBearingLocaliser(sourceDataBlock.getChannelMap());
|
||||
}
|
||||
|
||||
@ -433,6 +438,7 @@ public class RWEProcess extends PamProcess {
|
||||
int hydrophoneMap = sourceDataBlock.getChannelListManager().channelIndexesToPhones(chanMap);
|
||||
return findBearingLocaliser(hydrophoneMap);
|
||||
}
|
||||
|
||||
private synchronized BearingLocaliser findBearingLocaliser(int hydrophoneMap) {
|
||||
int nPhones = PamUtils.getNumChannels(hydrophoneMap);
|
||||
if (nPhones < 2) {
|
||||
|
@ -132,6 +132,7 @@ import PamguardMVC.PamProcess;
|
||||
import PamguardMVC.PamRawDataBlock;
|
||||
import PamguardMVC.SimpleDataObserver;
|
||||
import PamguardMVC.dataOffline.OfflineDataLoading;
|
||||
import PamguardMVC.dataSelector.DataSelectParams;
|
||||
import PamguardMVC.dataSelector.DataSelector;
|
||||
import dataPlotsFX.data.DataTypeInfo;
|
||||
import fftManager.FFTDataBlock;
|
||||
@ -2927,6 +2928,10 @@ InternalFrameListener, DisplayPanelContainer, SpectrogramParametersUser, PamSett
|
||||
// PamCalendar.formatTime(currentTimeMilliseconds)));
|
||||
String name = spectrogramDisplay.getDataSelectorName(panelId);
|
||||
DataSelector dataSelector = usedDataBlock.getDataSelector(name, false);
|
||||
|
||||
if (dataSelector.getParams().getCombinationFlag() == DataSelectParams.DATA_SELECT_DISABLE) {
|
||||
dataSelector = null;
|
||||
}
|
||||
directDrawProjector.setDataSelector(dataSelector);
|
||||
if (usedDataBlock.getPamSymbolManager() != null) {
|
||||
directDrawProjector.setPamSymbolChooser(usedDataBlock.getPamSymbolManager().getSymbolChooser(name, directDrawProjector));
|
||||
|
@ -25,7 +25,15 @@ public class AsioDriverInfos {
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* Gets called back from the jni call to callJniGetAsioDrivers
|
||||
* @param driverName
|
||||
* @param maxChannels
|
||||
* @param sampleRateInfo
|
||||
*/
|
||||
public void addDriverToList(String driverName, int[] maxChannels, int[]sampleRateInfo){
|
||||
lastDriverEnumeration = System.currentTimeMillis();
|
||||
System.out.printf("Getting driver detail for ASIO %s took %3.1fs\n", driverName, (double) (lastDriverEnumeration-driverEnumerationStart)/1000.);
|
||||
ArrayList<Integer>sampleRates = new ArrayList<Integer>();
|
||||
ArrayList<Integer>maxAvailableChannels = new ArrayList<Integer>();
|
||||
for(int i = 0;i<sampleRateInfo.length;i++){
|
||||
@ -34,13 +42,22 @@ public class AsioDriverInfos {
|
||||
}
|
||||
AsioDriverInfo asioDriverInfo = new AsioDriverInfo(driverName, maxAvailableChannels,sampleRates);
|
||||
asioDriverList.add(asioDriverInfo);
|
||||
driverEnumerationStart = System.currentTimeMillis();
|
||||
}
|
||||
|
||||
long driverEnumerationStart;
|
||||
long lastDriverEnumeration;
|
||||
private ArrayList<AsioDriverInfo> getAsioDriverList() {
|
||||
clearDriverList();
|
||||
long t1 = System.currentTimeMillis();
|
||||
driverEnumerationStart = t1;
|
||||
asioJniInterface.callJniGetAsioDrivers(this);
|
||||
long t2 = System.currentTimeMillis();
|
||||
System.out.printf("Call to asioJniInterface.callJniGetAsioDrivers took %3.1fs\n", (double) (t2-t1)/1000.);
|
||||
|
||||
for(int i = 0; i<asioDriverList.size();i++){
|
||||
System.out.printf("ASIO drivers: " + asioDriverList.get(i).driverName + " maxChannels: " + asioDriverList.get(i).maxChannels + " Can sample at ");
|
||||
long tic = System.currentTimeMillis();
|
||||
boolean firstHz = true;
|
||||
for(int j = 0;j<asioDriverList.get(i).sampleRateInfo.size();j++){
|
||||
if (firstHz == false) {
|
||||
@ -53,6 +70,11 @@ public class AsioDriverInfos {
|
||||
firstHz = false;
|
||||
}
|
||||
System.out.printf(" Hz\n");
|
||||
long toc = System.currentTimeMillis();
|
||||
if (toc-tic > 1000) {
|
||||
System.out.printf("Checking cababilities for ASIO %s took %3.1fs\n", asioDriverList.get(i).driverName,
|
||||
(double) (toc-tic)/1000.);
|
||||
}
|
||||
}
|
||||
// System.out.println();
|
||||
// System.out.println("Java:: just called asioJniInterface.callJniGetAsioDrivers(this);");
|
||||
@ -65,11 +87,14 @@ public class AsioDriverInfos {
|
||||
// System.out.println("getCurrentAsioDriverList():: asioDriverList.size()=" + asioDriverList.size());
|
||||
// System.out.flush();
|
||||
if(asioDriverList.size()==0){
|
||||
return asioDriverList = getAsioDriverList();
|
||||
long tic = System.currentTimeMillis();
|
||||
asioDriverList = getAsioDriverList();
|
||||
long toc = System.currentTimeMillis();
|
||||
if (toc-tic>1000) {
|
||||
System.out.printf("Enumerating ASIO driver list took %3.1fs\n", (double)(toc-tic)/1000.);
|
||||
}
|
||||
}
|
||||
else{
|
||||
return asioDriverList;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
|
@ -312,19 +312,19 @@ public class ClickDetector extends PamProcess {
|
||||
offlineEventDataBlock.SetLogging(offlineEventLogging);
|
||||
targetMotionSQLLogging = new TargetMotionSQLLogging(2);
|
||||
offlineEventLogging.addAddOn(targetMotionSQLLogging);
|
||||
if (isViewer) {
|
||||
// offlineEventDataBlock = new
|
||||
// OfflineEventDataBlock(clickControl.getUnitName()+"_OfflineEvents",
|
||||
// this, 0);
|
||||
// offlineEventLogging = new OfflineEventLogging(clickControl,
|
||||
// offlineEventDataBlock);
|
||||
// targetMotionSQLLogging = new TargetMotionSQLLogging(2);
|
||||
// offlineEventLogging.addAddOn(targetMotionSQLLogging);
|
||||
// offlineEventDataBlock.SetLogging(offlineEventLogging);
|
||||
} else { // for normal and mixed mode.
|
||||
// if (isViewer) {
|
||||
// // offlineEventDataBlock = new
|
||||
// // OfflineEventDataBlock(clickControl.getUnitName()+"_OfflineEvents",
|
||||
// // this, 0);
|
||||
// // offlineEventLogging = new OfflineEventLogging(clickControl,
|
||||
// // offlineEventDataBlock);
|
||||
// // targetMotionSQLLogging = new TargetMotionSQLLogging(2);
|
||||
// // offlineEventLogging.addAddOn(targetMotionSQLLogging);
|
||||
// // offlineEventDataBlock.SetLogging(offlineEventLogging);
|
||||
// } else { // for normal and mixed mode.
|
||||
offlineEventDataBlock.setLocalisationContents(LocContents.HAS_BEARING | LocContents.HAS_RANGE
|
||||
| LocContents.HAS_LATLONG | LocContents.HAS_AMBIGUITY | LocContents.HAS_PERPENDICULARERRORS);
|
||||
}
|
||||
// }
|
||||
// set up the subtable for the Event Logger, and force creation
|
||||
offlineEventLogging.setSubLogging(getClickDataBlock().getOfflineClickLogging());
|
||||
|
||||
@ -458,6 +458,8 @@ public class ClickDetector extends PamProcess {
|
||||
nChannelGroups = GroupedSourcePanel.countChannelGroups(cp.getChannelBitmap(), cp.getChannelGroups());
|
||||
int groupChannels;
|
||||
channelGroupDetectors = new ChannelGroupDetector[nChannelGroups];
|
||||
|
||||
int locContents = 0;
|
||||
for (int i = 0; i < nChannelGroups; i++) {
|
||||
groupChannels = GroupedSourcePanel.getGroupChannels(i, cp.getChannelBitmap(), cp.getChannelGroups());
|
||||
channelGroupDetectors[i] = new ChannelGroupDetector(i, groupChannels);
|
||||
@ -467,9 +469,21 @@ public class ClickDetector extends PamProcess {
|
||||
if (multiThread) {
|
||||
channelGroupDetectors[i].halfBuiltClicks.addObserver(newClickMonitor, true);
|
||||
}
|
||||
if (channelGroupDetectors[i].bearingLocaliser != null) {
|
||||
locContents |= channelGroupDetectors[i].bearingLocaliser.getLocalisationContents();
|
||||
}
|
||||
// System.out.println("Group " + i + " contains channels list " +
|
||||
// groupChannels);
|
||||
}
|
||||
outputClickData.setLocalisationContents(locContents);
|
||||
if (locContents == 0) {
|
||||
offlineEventDataBlock.setLocalisationContents(0);
|
||||
}
|
||||
else {
|
||||
int eventLocCont = LocContents.HAS_LATLONG | LocContents.HAS_XYZ | LocContents.HAS_RANGE;
|
||||
eventLocCont |= (locContents & LocContents.HAS_AMBIGUITY);
|
||||
offlineEventDataBlock.setLocalisationContents(eventLocCont);
|
||||
}
|
||||
|
||||
globalChannelList = new int[nChan = PamUtils
|
||||
.getNumChannels(clickControl.clickParameters.getChannelBitmap())];
|
||||
|
@ -27,6 +27,7 @@ public class ClickEventTethysDataProvider extends AutoTethysProvider {
|
||||
|
||||
@Override
|
||||
public GranularityEnumType[] getAllowedGranularities() {
|
||||
// these are by definition grouped.
|
||||
GranularityEnumType[] allowed = {GranularityEnumType.GROUPED};
|
||||
return allowed;
|
||||
}
|
||||
@ -59,14 +60,19 @@ public class ClickEventTethysDataProvider extends AutoTethysProvider {
|
||||
addUserDefined(params, numName, number.toString());
|
||||
}
|
||||
|
||||
// @Override
|
||||
// public boolean wantExportDialogCard(ExportWizardCard wizPanel) {
|
||||
//// if (wizPanel.getClass() == GranularityCard.class) {
|
||||
//// return false;
|
||||
//// }
|
||||
//// else {
|
||||
// return true;
|
||||
//// }
|
||||
// }
|
||||
|
||||
@Override
|
||||
public boolean wantExportDialogCard(ExportWizardCard wizPanel) {
|
||||
if (wizPanel.getClass() == GranularityCard.class) {
|
||||
return false;
|
||||
}
|
||||
else {
|
||||
public boolean granularityOK(GranularityEnumType granularityType) {
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
@ -26,6 +26,7 @@ import dataMap.OfflineDataMap;
|
||||
import dataMap.OfflineDataMapPoint;
|
||||
import nilus.AlgorithmType;
|
||||
import nilus.AlgorithmType.SupportSoftware;
|
||||
import nilus.Localize.Localizations;
|
||||
import nilus.DataSourceType;
|
||||
import nilus.Deployment;
|
||||
import nilus.Detection;
|
||||
@ -380,8 +381,10 @@ public class DetectionsHandler extends CollectionHandler {
|
||||
}
|
||||
|
||||
return exportCount;
|
||||
}/**
|
||||
* Export detections in all deployments for this PAMGuard dataset.
|
||||
}
|
||||
|
||||
/**
|
||||
* Export detections and localisations in all deployments for this PAMGuard dataset.
|
||||
* @param dataBlock
|
||||
* @param streamExportParams
|
||||
* @param exportObserver
|
||||
@ -396,7 +399,14 @@ public class DetectionsHandler extends CollectionHandler {
|
||||
DBXMLConnect dbxmlConnect = tethysControl.getDbxmlConnect();
|
||||
DeploymentHandler depHandler = tethysControl.getDeploymentHandler();
|
||||
ArrayList<PDeployment> deployments = depHandler.getMatchedDeployments();
|
||||
Detections currentDetections = null;
|
||||
|
||||
/*
|
||||
* The main documents for both dets and locs.
|
||||
*/
|
||||
Detections detectionsDocument = null;
|
||||
Localizations localisationsDocument = null;
|
||||
DetectionGroup onEffortDetections = null;
|
||||
|
||||
OfflineDataMap dataMap = dataBlock.getPrimaryDataMap();
|
||||
DataSelector dataSelector = dataBlock.getDataSelector(tethysControl.getDataSelectName(), false);
|
||||
int totalCount = dataMap.getDataCount();
|
||||
@ -427,16 +437,23 @@ public class DetectionsHandler extends CollectionHandler {
|
||||
List<OfflineDataMapPoint> mapPoints = dataMap.getMapPoints();
|
||||
for (OfflineDataMapPoint mapPoint : mapPoints) {
|
||||
if (!activeExport) {
|
||||
prog = new DetectionExportProgress(deployment, currentDetections,totalMapPoints, doneMapPoints,
|
||||
prog = new DetectionExportProgress(deployment, detectionsDocument,totalMapPoints, doneMapPoints,
|
||||
lastUnitTime, totalCount, exportCount, skipCount, DetectionExportProgress.STATE_CANCELED);
|
||||
exportObserver.update(prog);
|
||||
break;
|
||||
}
|
||||
|
||||
if (currentDetections == null) {
|
||||
if (detectionsDocument == null && streamExportParams.exportDetections) {
|
||||
// needed in inner loop in case doc gets written at 500000.
|
||||
currentDetections = startDetectionsDocument(deployment, dataBlock, streamExportParams);
|
||||
currentDetections.getEffort().setStart(TethysTimeFuncs.xmlGregCalFromMillis(deployment.getAudioStart()));
|
||||
detectionsDocument = startDetectionsDocument(deployment, dataBlock, streamExportParams);
|
||||
detectionsDocument.getEffort().setStart(TethysTimeFuncs.xmlGregCalFromMillis(deployment.getAudioStart()));
|
||||
onEffortDetections = detectionsDocument.getOnEffort();
|
||||
}
|
||||
else {
|
||||
onEffortDetections = null;
|
||||
}
|
||||
if (localisationsDocument == null && streamExportParams.exportLocalisations) {
|
||||
localisationsDocument = startLocalisationDocument(deployment, dataBlock, streamExportParams);
|
||||
}
|
||||
|
||||
if (mapPoint.getEndTime() < deployment.getAudioStart()) {
|
||||
@ -449,7 +466,6 @@ public class DetectionsHandler extends CollectionHandler {
|
||||
ArrayList<PamDataUnit> dataCopy = dataBlock.getDataCopy(deployment.getAudioStart(), deployment.getAudioEnd(), true, dataSelector);
|
||||
Collections.sort(dataCopy);
|
||||
skipCount += dataBlock.getUnitsCount() - dataCopy.size();
|
||||
DetectionGroup onEffort = currentDetections.getOnEffort();
|
||||
for (PamDataUnit dataUnit : dataCopy) {
|
||||
/*
|
||||
* Here is where we need to handle the different granularities.
|
||||
@ -459,11 +475,13 @@ public class DetectionsHandler extends CollectionHandler {
|
||||
for (int dd = 0; dd < dets.length; dd++) {
|
||||
exportCount++;
|
||||
documentCount++;
|
||||
onEffort.getDetection().add(dets[dd]);
|
||||
if (streamExportParams.exportDetections) {
|
||||
onEffortDetections.getDetection().add(dets[dd]);
|
||||
}
|
||||
}
|
||||
}
|
||||
if (exportCount % 100 == 0) {
|
||||
prog = new DetectionExportProgress(deployment, currentDetections, totalMapPoints, doneMapPoints,
|
||||
prog = new DetectionExportProgress(deployment, detectionsDocument, totalMapPoints, doneMapPoints,
|
||||
lastUnitTime, totalCount, exportCount, skipCount, DetectionExportProgress.STATE_GATHERING);
|
||||
exportObserver.update(prog);
|
||||
}
|
||||
@ -471,23 +489,25 @@ public class DetectionsHandler extends CollectionHandler {
|
||||
}
|
||||
|
||||
doneMapPoints ++;
|
||||
prog = new DetectionExportProgress(deployment, currentDetections,totalMapPoints, doneMapPoints,
|
||||
prog = new DetectionExportProgress(deployment, detectionsDocument,totalMapPoints, doneMapPoints,
|
||||
lastUnitTime, totalCount, exportCount, skipCount, DetectionExportProgress.STATE_GATHERING);
|
||||
exportObserver.update(prog);
|
||||
|
||||
if (documentCount > 50000000 && mapPoint != dataMap.getLastMapPoint()) {
|
||||
prog = new DetectionExportProgress(deployment, currentDetections,totalMapPoints, doneMapPoints,
|
||||
prog = new DetectionExportProgress(deployment, detectionsDocument,totalMapPoints, doneMapPoints,
|
||||
lastUnitTime, totalCount, exportCount, skipCount, DetectionExportProgress.STATE_WRITING);
|
||||
exportObserver.update(prog);
|
||||
closeDetectionsDocument(currentDetections, mapPoint.getEndTime());
|
||||
if (detectionsDocument != null) {
|
||||
closeDetectionsDocument(detectionsDocument, mapPoint.getEndTime());
|
||||
try {
|
||||
if (checkDetectionsDocument(currentDetections, granularityHandler)) {
|
||||
dbxmlConnect.postAndLog(currentDetections);
|
||||
if (checkDetectionsDocument(detectionsDocument, granularityHandler)) {
|
||||
dbxmlConnect.postAndLog(detectionsDocument);
|
||||
}
|
||||
} catch (TethysException e) {
|
||||
tethysControl.showException(e);
|
||||
}
|
||||
currentDetections = null;
|
||||
detectionsDocument = null;
|
||||
}
|
||||
}
|
||||
|
||||
if (viewerLoadPolicy == ViewerLoadPolicy.LOAD_ALWAYS_EVERYTHING) {
|
||||
@ -502,26 +522,26 @@ public class DetectionsHandler extends CollectionHandler {
|
||||
return DetectionExportProgress.STATE_CANCELED;
|
||||
}
|
||||
|
||||
if (currentDetections != null) {
|
||||
if (detectionsDocument != null) {
|
||||
Detection dets[] = granularityHandler.cleanup(deployment.getAudioEnd());
|
||||
if (dets != null) {
|
||||
for (int dd = 0; dd < dets.length; dd++) {
|
||||
exportCount++;
|
||||
documentCount++;
|
||||
currentDetections.getOnEffort().getDetection().add(dets[dd]);
|
||||
detectionsDocument.getOnEffort().getDetection().add(dets[dd]);
|
||||
}
|
||||
}
|
||||
prog = new DetectionExportProgress(deployment, currentDetections,totalMapPoints, doneMapPoints,
|
||||
prog = new DetectionExportProgress(deployment, detectionsDocument,totalMapPoints, doneMapPoints,
|
||||
lastUnitTime, totalCount, exportCount, skipCount, DetectionExportProgress.STATE_WRITING);
|
||||
closeDetectionsDocument(currentDetections, deployment.getAudioEnd());
|
||||
closeDetectionsDocument(detectionsDocument, deployment.getAudioEnd());
|
||||
try {
|
||||
if (checkDetectionsDocument(currentDetections, granularityHandler)) {
|
||||
dbxmlConnect.postAndLog(currentDetections);
|
||||
if (checkDetectionsDocument(detectionsDocument, granularityHandler)) {
|
||||
dbxmlConnect.postAndLog(detectionsDocument);
|
||||
}
|
||||
} catch (TethysException e) {
|
||||
tethysControl.showException(e);
|
||||
}
|
||||
currentDetections = null;
|
||||
detectionsDocument = null;
|
||||
}
|
||||
}
|
||||
|
||||
@ -531,6 +551,20 @@ public class DetectionsHandler extends CollectionHandler {
|
||||
return DetectionExportProgress.STATE_COMPLETE;
|
||||
}
|
||||
|
||||
private Localizations startLocalisationDocument(PDeployment deployment, PamDataBlock dataBlock,
|
||||
StreamExportParams streamExportParams) {
|
||||
Localizations localisations = new Localizations();
|
||||
try {
|
||||
Helper.createRequiredElements(localisations);
|
||||
} catch (IllegalArgumentException | IllegalAccessException | InstantiationException e) {
|
||||
e.printStackTrace();
|
||||
return null;
|
||||
}
|
||||
|
||||
return localisations;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Start a new detections document for the deployment and datablock. <br>
|
||||
* Add all the standard information to the top of the Document
|
||||
|
@ -1,17 +1,17 @@
|
||||
package tethys.localization;
|
||||
|
||||
//import nilus.CylindricalCoordinateType;
|
||||
//import nilus.LocalizationType;
|
||||
//import nilus.Localize.Effort.CoordinateReferenceSystem;
|
||||
import nilus.CylindricalCoordinateType;
|
||||
import nilus.LocalizationType;
|
||||
import nilus.Localize.Effort.CoordinateReferenceSystem;
|
||||
|
||||
public class LocalizationHandler {
|
||||
|
||||
|
||||
// public LocalizationType getLoc() {
|
||||
// LocalizationType lt = new LocalizationType();
|
||||
// CylindricalCoordinateType cct = new CylindricalCoordinateType();
|
||||
//// cct.set
|
||||
// CoordinateReferenceSystem cr;
|
||||
// return null;
|
||||
// }
|
||||
public LocalizationType getLoc() {
|
||||
LocalizationType lt = new LocalizationType();
|
||||
CylindricalCoordinateType cct = new CylindricalCoordinateType();
|
||||
// cct.set
|
||||
CoordinateReferenceSystem cr;
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
40
src/tethys/localization/TethysLocalisationInfo.java
Normal file
40
src/tethys/localization/TethysLocalisationInfo.java
Normal file
@ -0,0 +1,40 @@
|
||||
package tethys.localization;
|
||||
|
||||
import PamDetection.LocContents;
|
||||
import PamDetection.LocalisationInfo;
|
||||
import PamguardMVC.PamDataBlock;
|
||||
|
||||
/**
|
||||
* Summary of localisation info in a datablock, specific to Tethys needs.
|
||||
* @author dg50
|
||||
*
|
||||
*/
|
||||
public class TethysLocalisationInfo {
|
||||
|
||||
private PamDataBlock pamDataBlock;
|
||||
|
||||
public TethysLocalisationInfo(PamDataBlock pamDataBlock) {
|
||||
this.pamDataBlock = pamDataBlock;
|
||||
}
|
||||
|
||||
public String getLoclisationTypes() {
|
||||
LocalisationInfo locCont = pamDataBlock.getLocalisationContents();
|
||||
if (locCont == null || locCont.getLocContent() == 0) {
|
||||
return null;
|
||||
}
|
||||
String str = null;
|
||||
int[] mainTypes = LocContents.mainTypes;
|
||||
for (int i = 0; i < mainTypes.length; i++) {
|
||||
if (locCont.hasLocContent(mainTypes[i])) {
|
||||
if (str == null) {
|
||||
str = LocContents.getTypeString(mainTypes[i]);
|
||||
}
|
||||
else {
|
||||
str += ", " + LocContents.getTypeString(mainTypes[i]);
|
||||
}
|
||||
}
|
||||
}
|
||||
return str;
|
||||
}
|
||||
|
||||
}
|
@ -20,7 +20,7 @@ public class PGranularityType {
|
||||
case BINNED:
|
||||
return "Binned";
|
||||
case CALL:
|
||||
return "Call";
|
||||
return "Call / detection";
|
||||
case ENCOUNTER:
|
||||
return "Encounter";
|
||||
case GROUPED:
|
||||
|
@ -26,11 +26,19 @@ public class StreamExportParams implements Serializable {
|
||||
|
||||
/**
|
||||
* Datablock long data name (used instead of datablock
|
||||
* reference so this object and serialise.
|
||||
* reference so this object is serialise.
|
||||
*/
|
||||
public String longDataName;
|
||||
|
||||
public boolean selected;
|
||||
/**
|
||||
* Have selected export of detections.
|
||||
*/
|
||||
public boolean exportDetections;
|
||||
|
||||
/**
|
||||
* Have selected export of localisations.
|
||||
*/
|
||||
public boolean exportLocalisations;
|
||||
|
||||
/**
|
||||
* Granularity type, binned, call, encounter, grouped.
|
||||
@ -74,10 +82,9 @@ public class StreamExportParams implements Serializable {
|
||||
return detectionDescription;
|
||||
}
|
||||
|
||||
public StreamExportParams(TethysControl tethysControl, PamDataBlock dataBlock, boolean selected) {
|
||||
public StreamExportParams(TethysControl tethysControl, PamDataBlock dataBlock) {
|
||||
super();
|
||||
this.longDataName = dataBlock.getLongDataName();
|
||||
this.selected = selected;
|
||||
autoFill(tethysControl, dataBlock);
|
||||
}
|
||||
|
||||
|
@ -13,6 +13,7 @@ import PamController.PamControlledUnit;
|
||||
import PamController.PamSettings;
|
||||
import PamController.PamguardVersionInfo;
|
||||
import PamController.settings.output.xml.PamguardXMLWriter;
|
||||
import PamDetection.LocalisationInfo;
|
||||
import PamUtils.XMLUtils;
|
||||
import PamguardMVC.DataAutomationInfo;
|
||||
import PamguardMVC.DataUnitBaseData;
|
||||
@ -37,6 +38,7 @@ import nilus.SpeciesIDType;
|
||||
import tethys.TethysControl;
|
||||
import tethys.TethysTimeFuncs;
|
||||
import tethys.detection.DetectionsHandler;
|
||||
import tethys.localization.TethysLocalisationInfo;
|
||||
import tethys.niluswraps.PDeployment;
|
||||
import tethys.output.StreamExportParams;
|
||||
import tethys.output.TethysExportParams;
|
||||
@ -505,5 +507,41 @@ abstract public class AutoTethysProvider implements TethysDataProvider {
|
||||
return tethysControl;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean hasDetections() {
|
||||
return true;
|
||||
}
|
||||
|
||||
|
||||
@Override
|
||||
public boolean canExportLocalisations(GranularityEnumType granularityType) {
|
||||
LocalisationInfo locCont = pamDataBlock.getLocalisationContents();
|
||||
if (locCont == null) {
|
||||
return false;
|
||||
}
|
||||
return (locCont.getLocContent() > 0 & granularityOK(granularityType));
|
||||
}
|
||||
|
||||
/**
|
||||
* Granularity is OK for export.
|
||||
* @param granularityType
|
||||
* @return
|
||||
*/
|
||||
public boolean granularityOK(GranularityEnumType granularityType) {
|
||||
return (granularityType == null || granularityType == GranularityEnumType.CALL);
|
||||
}
|
||||
|
||||
@Override
|
||||
public TethysLocalisationInfo getLocalisationInfo() {
|
||||
LocalisationInfo locCont = pamDataBlock.getLocalisationContents();
|
||||
if (locCont == null || locCont.getLocContent() == 0) {
|
||||
return null;
|
||||
}
|
||||
else {
|
||||
return new TethysLocalisationInfo(pamDataBlock);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
}
|
||||
|
@ -2,6 +2,7 @@ package tethys.pamdata;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
import PamDetection.LocalisationInfo;
|
||||
import PamguardMVC.PamDataUnit;
|
||||
import nilus.AlgorithmType;
|
||||
import nilus.AlgorithmType.Parameters;
|
||||
@ -10,6 +11,7 @@ import nilus.DescriptionType;
|
||||
import nilus.Detection;
|
||||
import nilus.DetectionEffortKind;
|
||||
import nilus.GranularityEnumType;
|
||||
import tethys.localization.TethysLocalisationInfo;
|
||||
import tethys.niluswraps.PDeployment;
|
||||
import tethys.output.StreamExportParams;
|
||||
import tethys.output.TethysExportParams;
|
||||
@ -82,6 +84,22 @@ public interface TethysDataProvider {
|
||||
*/
|
||||
public String getDetectionsName();
|
||||
|
||||
/**
|
||||
* True if the datablock is detections. This will (nearly) always
|
||||
* be true or the block wouldn't have a TethysDataProvider, however
|
||||
* there may be one or two localisers that should really only output
|
||||
* localisation information.
|
||||
* @return
|
||||
*/
|
||||
public boolean hasDetections();
|
||||
|
||||
/**
|
||||
* See if it's possible for this block to export localisations. This may
|
||||
* depend on the selected granularity.
|
||||
* @param granularityType
|
||||
* @return
|
||||
*/
|
||||
public boolean canExportLocalisations(GranularityEnumType granularityType);
|
||||
|
||||
/**
|
||||
* Create a Tethys Detection object from a PamDataUnit.<br>
|
||||
@ -120,5 +138,12 @@ public interface TethysDataProvider {
|
||||
*/
|
||||
public boolean wantExportDialogCard(ExportWizardCard wizPanel);
|
||||
|
||||
/**
|
||||
* Get localisation info for the datablock. Can be null, but probably never is. More likely to have a zero of available types;
|
||||
* @return
|
||||
*/
|
||||
public TethysLocalisationInfo getLocalisationInfo();
|
||||
|
||||
|
||||
|
||||
}
|
||||
|
@ -42,7 +42,7 @@ public class DetectionsExportWizard extends PamWizard {
|
||||
|
||||
streamExportParams = tethysControl.getTethysExportParams().getStreamParams(dataBlock);
|
||||
if (streamExportParams == null) {
|
||||
streamExportParams = new StreamExportParams(tethysControl, dataBlock, false);
|
||||
streamExportParams = new StreamExportParams(tethysControl, dataBlock);
|
||||
}
|
||||
tethysDataProvider = dataBlock.getTethysDataProvider(tethysControl);
|
||||
getMainPanel().add(BorderLayout.NORTH, new ExportStreamInfoPanel(dataBlock));
|
||||
|
@ -9,6 +9,7 @@ import java.awt.event.ActionListener;
|
||||
import javax.swing.BoxLayout;
|
||||
import javax.swing.ButtonGroup;
|
||||
import javax.swing.JButton;
|
||||
import javax.swing.JCheckBox;
|
||||
import javax.swing.JLabel;
|
||||
import javax.swing.JPanel;
|
||||
import javax.swing.JRadioButton;
|
||||
@ -17,9 +18,6 @@ import javax.swing.JTextArea;
|
||||
import javax.swing.JTextField;
|
||||
import javax.swing.border.TitledBorder;
|
||||
|
||||
import org.w3c.dom.Document;
|
||||
|
||||
import PamController.settings.output.xml.PamguardXMLWriter;
|
||||
import PamView.dialog.PamGridBagContraints;
|
||||
import PamView.panel.WestAlignedPanel;
|
||||
import PamguardMVC.PamDataBlock;
|
||||
@ -28,6 +26,7 @@ import PamguardMVC.dataSelector.DataSelector;
|
||||
import PamguardMVC.dataSelector.DataSelectorChangeListener;
|
||||
import nilus.GranularityEnumType;
|
||||
import tethys.TethysControl;
|
||||
import tethys.localization.TethysLocalisationInfo;
|
||||
import tethys.niluswraps.PGranularityType;
|
||||
import tethys.output.StreamExportParams;
|
||||
import tethys.pamdata.TethysDataProvider;
|
||||
@ -40,22 +39,51 @@ public class GranularityCard extends ExportWizardCard {
|
||||
|
||||
private JTextField binLength, minBinnedCalls, encounterGap, minEncounterCalls;
|
||||
|
||||
private JCheckBox exportDetections, exportLocalisations;
|
||||
|
||||
private JLabel localisationTypes;
|
||||
|
||||
private JRadioButton groupChannels, separateChannels;
|
||||
|
||||
private DataSelector dataSelector;
|
||||
|
||||
private DetectionsExportWizard detectionsExportWizard;
|
||||
|
||||
private int encounterIndex, binnedIndex;
|
||||
private int callIndex, encounterIndex, binnedIndex;
|
||||
|
||||
private GranularityEnumType[] allowedGranularities;
|
||||
|
||||
private TethysDataProvider tethysDataProvider;
|
||||
|
||||
public GranularityCard(DetectionsExportWizard detectionsExportWizard, TethysControl tethysControl, PamDataBlock dataBlock) {
|
||||
super(tethysControl, detectionsExportWizard, "Granularity", dataBlock);
|
||||
this.detectionsExportWizard = detectionsExportWizard;
|
||||
setLayout(new BoxLayout(this, BoxLayout.Y_AXIS));
|
||||
|
||||
TethysDataProvider tethysDataProvider = dataBlock.getTethysDataProvider(tethysControl);
|
||||
tethysDataProvider = dataBlock.getTethysDataProvider(tethysControl);
|
||||
|
||||
GranularityChange gc = new GranularityChange();
|
||||
|
||||
exportDetections = new JCheckBox("Export Detections");
|
||||
exportLocalisations = new JCheckBox("Export Localisations");
|
||||
exportDetections.addActionListener(gc);
|
||||
exportLocalisations.addActionListener(gc);
|
||||
JPanel whatPanel = new JPanel(new GridBagLayout());
|
||||
GridBagConstraints cw = new PamGridBagContraints();
|
||||
cw.gridwidth = 2;
|
||||
whatPanel.add(exportDetections, cw);
|
||||
cw.gridy++;
|
||||
whatPanel.add(exportLocalisations, cw);
|
||||
cw.gridwidth = 1;
|
||||
cw.gridy++;
|
||||
whatPanel.add(new JLabel("Loclisation types: ", JLabel.RIGHT), cw);
|
||||
cw.gridx++;
|
||||
whatPanel.add(localisationTypes = new JLabel("none"), cw);
|
||||
JPanel walPanel = new WestAlignedPanel(whatPanel);
|
||||
walPanel.setBorder(new TitledBorder("What to export"));
|
||||
this.add(walPanel);
|
||||
localisationTypes.setToolTipText("Not all listed localisation types may be present in actual data");
|
||||
|
||||
// granularity
|
||||
allowedGranularities = tethysDataProvider.getAllowedGranularities();
|
||||
granularities = new JRadioButton[allowedGranularities.length];
|
||||
@ -63,7 +91,6 @@ public class GranularityCard extends ExportWizardCard {
|
||||
GridBagConstraints c = new PamGridBagContraints();
|
||||
granPanel.setBorder(new TitledBorder("Granularity"));
|
||||
ButtonGroup granGroup = new ButtonGroup();
|
||||
GranularityChange gc = new GranularityChange();
|
||||
binLength = new JTextField(5);
|
||||
minBinnedCalls = new JTextField(5);
|
||||
encounterGap = new JTextField(5);
|
||||
@ -75,6 +102,9 @@ public class GranularityCard extends ExportWizardCard {
|
||||
granularities[i].addActionListener(gc);
|
||||
granPanel.add(granularities[i], c);
|
||||
granGroup.add(granularities[i]);
|
||||
if (allowedGranularities[i] == GranularityEnumType.CALL) {
|
||||
callIndex = i;
|
||||
}
|
||||
if (allowedGranularities[i] == GranularityEnumType.BINNED) {
|
||||
binnedIndex = i;
|
||||
c.gridx++;
|
||||
@ -149,16 +179,6 @@ public class GranularityCard extends ExportWizardCard {
|
||||
|
||||
}
|
||||
|
||||
private void enableControls() {
|
||||
binLength.setEnabled(granularities[binnedIndex].isSelected());
|
||||
minBinnedCalls.setEnabled(granularities[binnedIndex].isSelected());
|
||||
encounterGap.setEnabled(granularities[encounterIndex].isSelected());
|
||||
minEncounterCalls.setEnabled(granularities[encounterIndex].isSelected());
|
||||
boolean binOrencount = granularities[binnedIndex].isSelected() | granularities[encounterIndex].isSelected();
|
||||
separateChannels.setEnabled(binOrencount);
|
||||
groupChannels.setEnabled(binOrencount);
|
||||
}
|
||||
|
||||
protected void newDataSelection() {
|
||||
if (dataSelector == null) {
|
||||
return;
|
||||
@ -177,12 +197,9 @@ public class GranularityCard extends ExportWizardCard {
|
||||
|
||||
@Override
|
||||
public boolean getParams(StreamExportParams streamExportParams) {
|
||||
for (int i = 0; i < allowedGranularities.length; i++) {
|
||||
if (granularities[i].isSelected()) {
|
||||
streamExportParams.granularity = allowedGranularities[i];
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
streamExportParams.granularity = getCurrentGranularity();
|
||||
|
||||
if (streamExportParams.granularity == GranularityEnumType.BINNED) {
|
||||
try {
|
||||
streamExportParams.binDurationS = Double.valueOf(binLength.getText());
|
||||
@ -214,9 +231,26 @@ public class GranularityCard extends ExportWizardCard {
|
||||
|
||||
streamExportParams.separateChannels = separateChannels.isSelected();
|
||||
|
||||
streamExportParams.exportDetections = exportDetections.isSelected();
|
||||
|
||||
streamExportParams.exportLocalisations = exportLocalisations.isSelected();
|
||||
|
||||
if (streamExportParams.exportDetections == false && streamExportParams.exportLocalisations == false) {
|
||||
return detectionsExportWizard.showWarning("You must select Detections or Localisations for export");
|
||||
}
|
||||
|
||||
return streamExportParams.granularity != null;
|
||||
}
|
||||
|
||||
private GranularityEnumType getCurrentGranularity() {
|
||||
for (int i = 0; i < allowedGranularities.length; i++) {
|
||||
if (granularities[i].isSelected()) {
|
||||
return allowedGranularities[i];
|
||||
}
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void setParams(StreamExportParams streamExportParams) {
|
||||
for (int i = 0; i < granularities.length; i++) {
|
||||
@ -228,8 +262,56 @@ public class GranularityCard extends ExportWizardCard {
|
||||
minEncounterCalls.setText(String.format("%d", streamExportParams.minEncounterCount));
|
||||
separateChannels.setSelected(streamExportParams.separateChannels);
|
||||
groupChannels.setSelected(streamExportParams.separateChannels == false);
|
||||
String locStr = getLocInfString();
|
||||
if (locStr == null) {
|
||||
localisationTypes.setText("none");
|
||||
// exportDetections.setSelected(true);
|
||||
exportLocalisations.setSelected(false);
|
||||
}
|
||||
else {
|
||||
localisationTypes.setText(locStr);
|
||||
}
|
||||
|
||||
exportDetections.setSelected(streamExportParams.exportDetections);
|
||||
exportLocalisations.setSelected(streamExportParams.exportLocalisations);
|
||||
|
||||
newDataSelection();
|
||||
enableControls();
|
||||
}
|
||||
|
||||
private void enableControls() {
|
||||
String locStr = getLocInfString();
|
||||
boolean dets = exportDetections.isSelected();
|
||||
boolean locs = exportLocalisations.isSelected();
|
||||
granularities[binnedIndex].setEnabled(!locs);
|
||||
granularities[encounterIndex].setEnabled(!locs);
|
||||
GranularityEnumType granularity = getCurrentGranularity();
|
||||
boolean canLoc = tethysDataProvider.canExportLocalisations(granularity);
|
||||
exportLocalisations.setEnabled(canLoc);
|
||||
if (canLoc == false) {
|
||||
exportLocalisations.setSelected(false);
|
||||
exportDetections.setSelected(true);
|
||||
}
|
||||
|
||||
if (granularities.length == 1) {
|
||||
granularities[0].setSelected(true);
|
||||
}
|
||||
|
||||
binLength.setEnabled(granularities[binnedIndex].isSelected());
|
||||
minBinnedCalls.setEnabled(granularities[binnedIndex].isSelected());
|
||||
encounterGap.setEnabled(granularities[encounterIndex].isSelected());
|
||||
minEncounterCalls.setEnabled(granularities[encounterIndex].isSelected());
|
||||
boolean binOrencount = granularities[binnedIndex].isSelected() | granularities[encounterIndex].isSelected();
|
||||
separateChannels.setEnabled(binOrencount);
|
||||
groupChannels.setEnabled(binOrencount);
|
||||
}
|
||||
|
||||
private String getLocInfString() {
|
||||
TethysLocalisationInfo locInf = getDataBlock().getTethysDataProvider(getTethysControl()).getLocalisationInfo();
|
||||
if (locInf == null) {
|
||||
return null;
|
||||
}
|
||||
return locInf.getLoclisationTypes();
|
||||
}
|
||||
|
||||
}
|
||||
|
@ -39,6 +39,10 @@ public class WMDDataSelector extends DataSelector {
|
||||
|
||||
@Override
|
||||
public double scoreData(PamDataUnit pamDataUnit) {
|
||||
int combFlag = wmAlarmParameters.getCombinationFlag();
|
||||
if (combFlag == DataSelectParams.DATA_SELECT_DISABLE) {
|
||||
return 1;
|
||||
}
|
||||
ConnectedRegionDataUnit crDataUnit = (ConnectedRegionDataUnit) pamDataUnit;
|
||||
return (wantWhistle(crDataUnit) ? 1: 0);
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user