Class DATRABundle
java.lang.Object
overit.geocall.da.DATask
overit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator
overit.geocallapp.wfm.replicator.datasource.DATaskReplicatorWfmBase
overit.geocallapp.wfm.mobile.core.replicator.bundler.task.DATRABundle
- All Implemented Interfaces:
Serializable,Runnable,Identified,Tool
public class DATRABundle
extends overit.geocallapp.wfm.replicator.datasource.DATaskReplicatorWfmBase
Bundle replication
- Since:
- 10.1
- See Also:
-
Field Summary
FieldsFields inherited from class overit.geocallapp.wfm.replicator.datasource.DATaskReplicatorWfmBase
LOG, RESET_TOMBSTONE_VALUE, utilsFields inherited from class overit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator
_dataSource, _tableFields inherited from class overit.geocall.da.DATask
_usedConnections, _usedCouriers -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionacknowledge(HashGetter filter, PooledConnection conn, PooledConnection externalConn) protected voidaddCustomTombStone(TreeMap<Long, Long> tmInsertedKeyTranslations) protected voidappendCustomTombstone(ArrayList<String> alTombstones, HashGetter filter, Date lastSync, Long idPda, PooledConnection connSystem, PooledConnection connApplication) protected voidbuildRow(DBView data, int row, PooledConnection connApplication) protected voiddoDelete(HashGetter hgToDel, PooledConnection conn, PooledConnection externalConn) protected LongdoInsert(HashGetter currentRecord, PooledConnection conn, PooledConnection externalConn) protected voiddoUpdate(HashGetter currentRecord, PooledConnection conn, PooledConnection externalConn) protected DBViewgetData(HashGetter filter, PooledConnection connSystem, PooledConnection connApplication) protected voidinit(overit.geocallapp.replicator.basic.base.DataSource.DataSource dataSource, overit.geocallapp.replicator.basic.base.ReplicationTable t, PooledConnection connSystem, PooledConnection connApplication) protected List<BOWorkOrderOperation> loadCancelledWorkOrderOperations(PooledConnection connApplication, List<Long> closedBundleOperationsWOOperationIds) protected voidsetAdditionalData(DBView data, PooledConnection connApplication) Methods inherited from class overit.geocallapp.wfm.replicator.datasource.DATaskReplicatorWfmBase
checkRigaLavorabile, checkRigaLavorabile, getDBViewModificati, getDBViewModificati, getIdAuteUltimaModificaPda, getIncrementalData, getListaFiliali, getPkFieldsPosition, getPkValues, getTransactionParameter, getWOOperationId, getWorkOrderCodeOperationOrdering, isSkippedInterventionUpdate, isUserSafety, removeNotModifiableFields, resetMobileLastModUserToIdentity, setMobileLastModUserToIdentity, setTransactionParameterMethods inherited from class overit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator
bodyMethods inherited from class overit.geocall.da.DATask
commit, deliverCourier, getConnection, getDA, getIdentity, getServiceConnection, holdFactoryCourier, holdUserCourier, releaseConnection, rollback, run, setIdentity, start, startInBackground, synchronizeOn
-
Field Details
-
daBundler
-
-
Constructor Details
-
DATRABundle
public DATRABundle()
-
-
Method Details
-
init
protected void init(overit.geocallapp.replicator.basic.base.DataSource.DataSource dataSource, overit.geocallapp.replicator.basic.base.ReplicationTable t, PooledConnection connSystem, PooledConnection connApplication) - Overrides:
initin classoverit.geocallapp.wfm.replicator.datasource.DATaskReplicatorWfmBase
-
getData
protected DBView getData(HashGetter filter, PooledConnection connSystem, PooledConnection connApplication) throws DAException, DAValidateException - Specified by:
getDatain classoverit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator- Throws:
DAExceptionDAValidateException
-
setAdditionalData
protected void setAdditionalData(DBView data, PooledConnection connApplication) throws DAValidateException, DAException - Throws:
DAValidateExceptionDAException
-
buildRow
protected void buildRow(DBView data, int row, PooledConnection connApplication) throws DAValidateException, DAException - Throws:
DAValidateExceptionDAException
-
loadCancelledWorkOrderOperations
protected List<BOWorkOrderOperation> loadCancelledWorkOrderOperations(PooledConnection connApplication, List<Long> closedBundleOperationsWOOperationIds) throws DAValidateException, DAException - Throws:
DAValidateExceptionDAException
-
doInsert
protected Long doInsert(HashGetter currentRecord, PooledConnection conn, PooledConnection externalConn) throws DAException, DAValidateException - Specified by:
doInsertin classoverit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator- Throws:
DAExceptionDAValidateException
-
doUpdate
protected void doUpdate(HashGetter currentRecord, PooledConnection conn, PooledConnection externalConn) throws DAException, DAValidateException - Specified by:
doUpdatein classoverit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator- Throws:
DAExceptionDAValidateException
-
doDelete
protected void doDelete(HashGetter hgToDel, PooledConnection conn, PooledConnection externalConn) throws DAException, DAValidateException - Specified by:
doDeletein classoverit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator- Throws:
DAExceptionDAValidateException
-
addCustomTombStone
- Specified by:
addCustomTombStonein classoverit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator
-
acknowledge
protected Map<String,String> acknowledge(HashGetter filter, PooledConnection conn, PooledConnection externalConn) throws DAException, DAValidateException - Specified by:
acknowledgein classoverit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator- Throws:
DAExceptionDAValidateException
-
appendCustomTombstone
protected void appendCustomTombstone(ArrayList<String> alTombstones, HashGetter filter, Date lastSync, Long idPda, PooledConnection connSystem, PooledConnection connApplication) throws DAException - Overrides:
appendCustomTombstonein classoverit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator- Throws:
DAException
-