Class DATRWarehouseAgendaMaterial
java.lang.Object
overit.geocall.da.DATask
overit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator
overit.geocallapp.wfm.replicator.datasource.DATaskReplicatorWfmBase
overit.geocallapp.wfm.inventory.replicator.task.DATRWarehouseAgendaMaterial
- All Implemented Interfaces:
Serializable,Runnable,Identified,Tool
public class DATRWarehouseAgendaMaterial
extends overit.geocallapp.wfm.replicator.datasource.DATaskReplicatorWfmBase
Task for replication of RWAREHOUSEAGENDAMATERIAL table.
- See Also:
-
Field Summary
Fields 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 conn, PooledConnection externalConn) 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 conn, PooledConnection externalConn) protected booleanisAgendaPda(HashGetter currentRecord) protected LongloadAgendaPda(String sCodiceAgendaPda, PooledConnection conn) Methods inherited from class overit.geocallapp.wfm.replicator.datasource.DATaskReplicatorWfmBase
checkRigaLavorabile, checkRigaLavorabile, getDBViewModificati, getDBViewModificati, getIdAuteUltimaModificaPda, getIncrementalData, getListaFiliali, getPkFieldsPosition, getPkValues, getTransactionParameter, getWOOperationId, getWorkOrderCodeOperationOrdering, init, 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
-
Constructor Details
-
DATRWarehouseAgendaMaterial
public DATRWarehouseAgendaMaterial()
-
-
Method Details
-
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
-
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
-
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
-
getData
protected DBView getData(HashGetter filter, PooledConnection conn, PooledConnection externalConn) throws DAException, DAValidateException - Specified by:
getDatain classoverit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator- Throws:
DAExceptionDAValidateException
-
isAgendaPda
-
loadAgendaPda
protected Long loadAgendaPda(String sCodiceAgendaPda, PooledConnection conn) throws DAValidateException - Throws:
DAValidateException
-
addCustomTombStone
- Specified by:
addCustomTombStonein classoverit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator
-
appendCustomTombstone
protected void appendCustomTombstone(ArrayList<String> alTombstones, HashGetter filter, Date lastSync, Long idPda, PooledConnection conn, PooledConnection externalConn) throws DAException - Overrides:
appendCustomTombstonein classoverit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator- Throws:
DAException
-
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
-