Package fr.gouv.vitam.collect.internal.core.service

Class TransactionService

java.lang.Object

fr.gouv.vitam.collect.internal.core.service.TransactionService

public class TransactionService
extends Object

Constructor Summary

Constructors

Constructor	Description
TransactionService(TransactionRepository transactionRepository, ProjectService projectService, MetadataRepository metadataRepository, FluxService fluxService, WorkspaceClientFactory workspaceCollectClientFactory, AccessInternalClientFactory accessInternalClientFactory, IngestInternalClientFactory ingestInternalClientFactory)

Method Summary

Modifier and Type	Method	Description
void	attachVitamOperationId(String transactionId, String operationId)
void	changeTransactionStatus(TransactionStatus transactionStatus, String transactionId)
boolean	changeTransactionToSendingIfBatchesNotKo(TransactionModel transaction)
void	checkAbortTransaction(TransactionModel transactionModel)
void	checkReadyTransaction(TransactionModel transactionModel)
void	checkReopenTransaction(TransactionModel transactionModel)
void	checkSendingTransaction(TransactionModel transactionModel)
void	checkSendTransaction(TransactionModel transactionModel)
boolean	checkStatus(TransactionModel transactionModel, TransactionStatus... transactionStatus)
void	createTransaction(TransactionDto transactionDto, ProjectDto projectDto)	create a transaction model
void	deleteTransaction(String id)	delete transaction according to id
void	deleteTransactionContent(String transactionId)
Optional<TransactionModel>	findLastTransactionByProjectId(String id)	Deprecated.
boolean	findOneAndReplace(TransactionStatus transactionStatus, TransactionModel transactionModel)
List<TransactionModel>	findReadyAutoIngestTransactions()
Optional<TransactionModel>	findTransaction(String id)	return transaction according to id
List<TransactionDto>	findTransactionsByProjectId(String id)	return transaction according to id
List<TransactionModel>	getListTransactionToDeleteByTenant(Integer tenantId)
void	isTransactionContentEmpty(String id)	check if the transaction content is empty
void	manageTransactionsStatus()
void	purgeByBatchId(String batchId, TransactionModel transactionModel)
TransactionModel	replaceTransaction(TransactionDto transactionDto)	update a transaction model
void	replaceTransaction(TransactionModel transactionModel)
javax.ws.rs.core.Response	uploadTransactionZip(InputStream inputStreamObject, TransactionModel transactionModel, String encoding)

Methods inherited from class java.lang.Object

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

Constructor Details

TransactionService

public TransactionService(TransactionRepository transactionRepository,
 ProjectService projectService,
 MetadataRepository metadataRepository,
 FluxService fluxService,
 WorkspaceClientFactory workspaceCollectClientFactory,
 AccessInternalClientFactory accessInternalClientFactory,
 IngestInternalClientFactory ingestInternalClientFactory)

Method Details

createTransaction

public void createTransaction(TransactionDto transactionDto,
 ProjectDto projectDto)
                       throws CollectInternalException

create a transaction model

Throws:

CollectInternalException - exception thrown in case of error

deleteTransaction

public void deleteTransaction(String id)
                       throws CollectInternalException

delete transaction according to id

Parameters:

id - transaction to delete

Throws:

CollectInternalException - exception thrown in case of error

findTransaction

public Optional<TransactionModel> findTransaction(String id)
                                           throws CollectInternalException

return transaction according to id

Parameters:

id - model id to find

Returns:

Optional

Throws:

CollectInternalException - exception thrown in case of error

findLastTransactionByProjectId

@Deprecated
public Optional<TransactionModel> findLastTransactionByProjectId(String id)
                                                          throws CollectInternalException

Deprecated.

return transaction according to project id

Parameters:

id - model id to find

Returns:

Optional

Throws:

CollectInternalException - exception thrown in case of error FIXME : Delete usages since no there is no more 1 transaction limit for project

findTransactionsByProjectId

public List<TransactionDto> findTransactionsByProjectId(String id)
                                                 throws CollectInternalException

return transaction according to id

Parameters:

id - model id to find

Returns:

Optional

Throws:

CollectInternalException - exception thrown in case of error

checkReadyTransaction

public void checkReadyTransaction(TransactionModel transactionModel)
                           throws CollectInternalException

Throws:

CollectInternalException

checkSendingTransaction

public void checkSendingTransaction(TransactionModel transactionModel)
                             throws CollectInternalException

Throws:

CollectInternalException

checkSendTransaction

public void checkSendTransaction(TransactionModel transactionModel)
                          throws CollectInternalException

Throws:

CollectInternalException

replaceTransaction

public void replaceTransaction(TransactionModel transactionModel)
                        throws CollectInternalException

Throws:

CollectInternalException

findOneAndReplace

public boolean findOneAndReplace(TransactionStatus transactionStatus,
 TransactionModel transactionModel)
                          throws InvalidParseOperationException

Throws:

InvalidParseOperationException

checkAbortTransaction

public void checkAbortTransaction(TransactionModel transactionModel)
                           throws CollectInternalException

Throws:

CollectInternalException

checkReopenTransaction

public void checkReopenTransaction(TransactionModel transactionModel)
                            throws CollectInternalException

Throws:

CollectInternalException

checkStatus

public boolean checkStatus(TransactionModel transactionModel,
 TransactionStatus... transactionStatus)

changeTransactionStatus

public void changeTransactionStatus(TransactionStatus transactionStatus,
 String transactionId)
                             throws CollectInternalException

Throws:

CollectInternalException

attachVitamOperationId

public void attachVitamOperationId(String transactionId,
 String operationId)
                            throws CollectInternalException

Throws:

CollectInternalException

getListTransactionToDeleteByTenant

public List<TransactionModel> getListTransactionToDeleteByTenant(Integer tenantId)
                                                          throws CollectInternalException

Throws:

CollectInternalException

findReadyAutoIngestTransactions

public List<TransactionModel> findReadyAutoIngestTransactions()
                                                       throws CollectInternalException

Throws:

CollectInternalException

manageTransactionsStatus

public void manageTransactionsStatus()
                              throws CollectInternalException

Throws:

CollectInternalException

replaceTransaction

public TransactionModel replaceTransaction(TransactionDto transactionDto)
                                    throws CollectInternalException

update a transaction model

Throws:

CollectInternalException - exception thrown in case of error

isTransactionContentEmpty

public void isTransactionContentEmpty(String id)
                               throws CollectInternalException

check if the transaction content is empty

Throws:

CollectInternalException - exception thrown in case of error

deleteTransactionContent

public void deleteTransactionContent(String transactionId)
                              throws CollectInternalException

Throws:

CollectInternalException

purgeByBatchId

public void purgeByBatchId(String batchId,
 TransactionModel transactionModel)
                    throws CollectInternalException

Throws:

CollectInternalException

uploadTransactionZip

public javax.ws.rs.core.Response uploadTransactionZip(InputStream inputStreamObject,
 TransactionModel transactionModel,
 @Nullable
 String encoding)
                                               throws CollectInternalException

Throws:

CollectInternalException

changeTransactionToSendingIfBatchesNotKo

public boolean changeTransactionToSendingIfBatchesNotKo(TransactionModel transaction)
                                                 throws InvalidParseOperationException,
CollectInternalException

Throws:

InvalidParseOperationException

CollectInternalException