fr.gouv.vitam.worker.model

Class LogbookLifeCycleTraceabilityHelper

java.lang.Object

fr.gouv.vitam.worker.model.LogbookLifeCycleTraceabilityHelper

All Implemented Interfaces:

LogbookTraceabilityHelper

Direct Known Subclasses:

LogbookObjectGroupLifeCycleTraceabilityHelper, LogbookUnitLifeCycleTraceabilityHelper

public abstract class LogbookLifeCycleTraceabilityHelper
extends Object
implements LogbookTraceabilityHelper

Field Summary

Fields inherited from interface fr.gouv.vitam.logbook.common.traceability.LogbookTraceabilityHelper

INITIAL_START_DATE

Constructor Summary

Constructors

Constructor and Description
LogbookLifeCycleTraceabilityHelper(HandlerIO handlerIO, LogbookOperationsClient logbookOperationsClient, ItemStatus itemStatus, String operationID, WorkspaceClientFactory workspaceClientFactory)

Method Summary

Modifier and Type	Method and Description
void	createLogbookOperationEvent(Integer tenantId, String eventType, StatusCode status, TraceabilityEvent event) Update or finalize the traceability entry in the logbook collection
void	createLogbookOperationStructure() initialize the traceability entry in the logbook collection
protected void	extractAppendToFinalFile(List<URI> listOfFiles, TraceabilityFile traceabilityFile, MerkleTreeAlgo algo, String rootFolder) Reduce part of the process : lets merge in one only file the disting lifecycles ones
protected abstract Select	generateSelectLogbookOperation(LocalDateTime date)
long	getDataSize() Warning: This method MUST be used after "saveDataInZip" witch initialize traceabilityIterator
boolean	getMaxEntriesReached()
String	getPreviousMonthStartDate() Get the first traceability (in logbook) one month before the given currentDate and return the startDate of the entry
byte[]	getPreviousMonthTimestampToken() Get the first traceability (in logbook) one month before the given currentDate and return the timestampToken of the entry
String	getPreviousStartDate() Get the last traceability (in logbook) event and return the startDate of the entry
byte[]	getPreviousTimestampToken() Get the last traceability (in logbook) event and return the timestampToken of the entry
String	getPreviousYearStartDate() Get the first traceability (in logbook) one year before the given currentDate and return the startDate of the entry
byte[]	getPreviousYearTimestampToken() Get the first traceability (in logbook) one year before the given currentDate and return the timestampToken of the entry
String	getStepName()
String	getTimestampStepName()
String	getTraceabilityEndDate()
String	getTraceabilityStartDate()
String	getUriName()
void	initialize() Initialize traceability.
void	saveEmpty(Integer tenantId) Save the close master event if needed
void	saveEvent(TraceabilityEvent event) Save the finalized event if needed
void	storeAndDeleteZip(Integer tenant, File zipFile, String fileName, String uri, TraceabilityEvent event) Store the temporary zip in the final destination (on a specific offer for example) and delete tmp file.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface fr.gouv.vitam.logbook.common.traceability.LogbookTraceabilityHelper

getTraceabilityType, getZipName, saveDataInZip

Constructor Detail

LogbookLifeCycleTraceabilityHelper

public LogbookLifeCycleTraceabilityHelper(HandlerIO handlerIO,
                                          LogbookOperationsClient logbookOperationsClient,
                                          ItemStatus itemStatus,
                                          String operationID,
                                          WorkspaceClientFactory workspaceClientFactory)

Parameters:

handlerIO - Workflow Input/Output of the traceability event

logbookOperationsClient - used to search the operation to secure

itemStatus - used by workflow, event must be updated here

operationID - of the current traceability process

workspaceClientFactory -

Method Detail

initialize

public void initialize()
                throws TraceabilityException

Description copied from interface: LogbookTraceabilityHelper

Initialize traceability. Sets traceability start date and end date.

Specified by:

initialize in interface LogbookTraceabilityHelper

Throws:

TraceabilityException - for any error

createLogbookOperationStructure

public void createLogbookOperationStructure()
                                     throws TraceabilityException

Description copied from interface: LogbookTraceabilityHelper

initialize the traceability entry in the logbook collection

Specified by:

createLogbookOperationStructure in interface LogbookTraceabilityHelper

Throws:

TraceabilityException - if any error occurs

createLogbookOperationEvent

public void createLogbookOperationEvent(Integer tenantId,
                                        String eventType,
                                        StatusCode status,
                                        TraceabilityEvent event)
                                 throws TraceabilityException

Description copied from interface: LogbookTraceabilityHelper

Update or finalize the traceability entry in the logbook collection

Specified by:

createLogbookOperationEvent in interface LogbookTraceabilityHelper

Parameters:

tenantId - tenant used for the operation

eventType - code of the eventType for the entry

status - status of the entry

event - data of the entry

Throws:

TraceabilityException - if any error occurs

saveEvent

public void saveEvent(TraceabilityEvent event)

Description copied from interface: LogbookTraceabilityHelper

Save the finalized event if needed

Specified by:

saveEvent in interface LogbookTraceabilityHelper

Parameters:

event - The TraceabilityEvent of the operation

saveEmpty

public void saveEmpty(Integer tenantId)

Description copied from interface: LogbookTraceabilityHelper

Save the close master event if needed

Specified by:

saveEmpty in interface LogbookTraceabilityHelper

Parameters:

tenantId - the tenant used for log

getMaxEntriesReached

public boolean getMaxEntriesReached()

Specified by:

getMaxEntriesReached in interface LogbookTraceabilityHelper

Returns:

true if max entries reached (unit & object group lifecycle traceability operation are limited in size)

storeAndDeleteZip

public void storeAndDeleteZip(Integer tenant,
                              File zipFile,
                              String fileName,
                              String uri,
                              TraceabilityEvent event)
                       throws TraceabilityException

Description copied from interface: LogbookTraceabilityHelper

Store the temporary zip in the final destination (on a specific offer for example) and delete tmp file.

Specified by:

storeAndDeleteZip in interface LogbookTraceabilityHelper

Parameters:

tenant - tenant used for the operation

zipFile - file containing multiple information about the traceability operation (data, merkle, computingData, ...)

fileName - name of the file on the destination

uri - uri of the tmp file

event - traceability event that should be updated by this operation

Throws:

TraceabilityException - if any error occurs

getStepName

public String getStepName()

Specified by:

getStepName in interface LogbookTraceabilityHelper

Returns:

the main eventType code for the specific implementation class

getTimestampStepName

public String getTimestampStepName()

Specified by:

getTimestampStepName in interface LogbookTraceabilityHelper

Returns:

the timestamp eventType code for the specific implementation class

getUriName

public String getUriName()

Specified by:

getUriName in interface LogbookTraceabilityHelper

Returns:

the uri of the tmp file

getTraceabilityStartDate

public String getTraceabilityStartDate()

Specified by:

getTraceabilityStartDate in interface LogbookTraceabilityHelper

Returns:

the start date of the traceability (computed from the end date of the last traceability)

getTraceabilityEndDate

public String getTraceabilityEndDate()

Specified by:

getTraceabilityEndDate in interface LogbookTraceabilityHelper

Returns:

the end date of the traceability (now)

getDataSize

public long getDataSize()

Description copied from interface: LogbookTraceabilityHelper

Warning: This method MUST be used after "saveDataInZip" witch initialize traceabilityIterator

Specified by:

getDataSize in interface LogbookTraceabilityHelper

Returns:

the number of items secured in traceabilityIterator

getPreviousTimestampToken

public byte[] getPreviousTimestampToken()
                                 throws InvalidParseOperationException

Description copied from interface: LogbookTraceabilityHelper

Get the last traceability (in logbook) event and return the timestampToken of the entry

Specified by:

getPreviousTimestampToken in interface LogbookTraceabilityHelper

Returns:

the timestamp token of the last traceability entry or null if no previous traceability OK for that type

Throws:

InvalidParseOperationException - if any errors occurs while deserializing entry's data.

getPreviousMonthTimestampToken

public byte[] getPreviousMonthTimestampToken()
                                      throws InvalidParseOperationException,
                                             TraceabilityException

Description copied from interface: LogbookTraceabilityHelper

Get the first traceability (in logbook) one month before the given currentDate and return the timestampToken of the entry

Specified by:

getPreviousMonthTimestampToken in interface LogbookTraceabilityHelper

Returns:

the timestamp token of the matching entry or null if no matching entry

Throws:

InvalidParseOperationException - if any errors occurs while deserializing entry's data.

TraceabilityException - if any other error occurs

getPreviousYearTimestampToken

public byte[] getPreviousYearTimestampToken()
                                     throws InvalidParseOperationException,
                                            TraceabilityException

Description copied from interface: LogbookTraceabilityHelper

Get the first traceability (in logbook) one year before the given currentDate and return the timestampToken of the entry

Specified by:

getPreviousYearTimestampToken in interface LogbookTraceabilityHelper

Returns:

the timestamp token of the matching entry or null if no matching entry

Throws:

InvalidParseOperationException - if any errors occurs while deserializing entry's data.

TraceabilityException - if any other error occurs

getPreviousStartDate

public String getPreviousStartDate()
                            throws InvalidParseOperationException

Description copied from interface: LogbookTraceabilityHelper

Get the last traceability (in logbook) event and return the startDate of the entry

Specified by:

getPreviousStartDate in interface LogbookTraceabilityHelper

Returns:

the start date of the last traceability entry

Throws:

InvalidParseOperationException - if any errors occurs while deserializing entry's data.

getPreviousMonthStartDate

public String getPreviousMonthStartDate()
                                 throws InvalidParseOperationException,
                                        TraceabilityException

Description copied from interface: LogbookTraceabilityHelper

Get the first traceability (in logbook) one month before the given currentDate and return the startDate of the entry

Specified by:

getPreviousMonthStartDate in interface LogbookTraceabilityHelper

Returns:

the start date of the matching entry or null if no matching entry

Throws:

InvalidParseOperationException - if any errors occurs while deserializing entry's data.

TraceabilityException - if any other error occurs

getPreviousYearStartDate

public String getPreviousYearStartDate()
                                throws InvalidParseOperationException,
                                       TraceabilityException

Description copied from interface: LogbookTraceabilityHelper

Get the first traceability (in logbook) one year before the given currentDate and return the startDate of the entry

Specified by:

getPreviousYearStartDate in interface LogbookTraceabilityHelper

Returns:

the start date of the matching entry or null if no matching entry

Throws:

InvalidParseOperationException - if any errors occurs while deserializing entry's data.

TraceabilityException - if any other error occurs

extractAppendToFinalFile

protected void extractAppendToFinalFile(List<URI> listOfFiles,
                                        TraceabilityFile traceabilityFile,
                                        MerkleTreeAlgo algo,
                                        String rootFolder)
                                 throws TraceabilityException

Reduce part of the process : lets merge in one only file the disting lifecycles ones

Parameters:

listOfFiles -

traceabilityFile -

algo -

rootFolder -

Throws:

TraceabilityException

generateSelectLogbookOperation

protected abstract Select generateSelectLogbookOperation(LocalDateTime date)
                                                  throws InvalidCreateOperationException

Throws:

InvalidCreateOperationException