Package overit.geocallapp.wfm.mobile.core.replicator.bundler.task

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:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected DAMobileBundler	daBundler

Fields inherited from class overit.geocallapp.wfm.replicator.datasource.DATaskReplicatorWfmBase

LOG, RESET_TOMBSTONE_VALUE, utils

Fields inherited from class overit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator

_dataSource, _table

Fields inherited from class overit.geocall.da.DATask

_usedConnections, _usedCouriers

Constructor Summary

Constructors

Constructor	Description
DATRABundle()

Method Summary

Modifier and Type	Method	Description
protected Map<String,String>	acknowledge(HashGetter filter, PooledConnection conn, PooledConnection externalConn)
protected void	addCustomTombStone(TreeMap<Long,Long> tmInsertedKeyTranslations)
protected void	appendCustomTombstone(ArrayList<String> alTombstones, HashGetter filter, Date lastSync, Long idPda, PooledConnection connSystem, PooledConnection connApplication)
protected void	buildRow(DBView data, int row, PooledConnection connApplication)
protected void	doDelete(HashGetter hgToDel, PooledConnection conn, PooledConnection externalConn)
protected Long	doInsert(HashGetter currentRecord, PooledConnection conn, PooledConnection externalConn)
protected void	doUpdate(HashGetter currentRecord, PooledConnection conn, PooledConnection externalConn)
protected DBView	getData(HashGetter filter, PooledConnection connSystem, PooledConnection connApplication)
protected void	init(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 void	setAdditionalData(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, setTransactionParameter

Methods inherited from class overit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator

body

Methods inherited from class overit.geocall.da.DATask

commit, deliverCourier, getConnection, getDA, getIdentity, getServiceConnection, holdFactoryCourier, holdUserCourier, releaseConnection, rollback, run, setIdentity, start, startInBackground, synchronizeOn

Methods inherited from class java.lang.Object

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

Field Details

daBundler

protected DAMobileBundler 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:

init in class overit.geocallapp.wfm.replicator.datasource.DATaskReplicatorWfmBase

getData

protected DBView getData(HashGetter filter,
 PooledConnection connSystem,
 PooledConnection connApplication)
                  throws DAException,
DAValidateException

Specified by:

getData in class overit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator

Throws:

DAException

DAValidateException

setAdditionalData

protected void setAdditionalData(DBView data,
 PooledConnection connApplication)
                          throws DAValidateException,
DAException

Throws:

DAValidateException

DAException

buildRow

protected void buildRow(DBView data,
 int row,
 PooledConnection connApplication)
                 throws DAValidateException,
DAException

Throws:

DAValidateException

DAException

loadCancelledWorkOrderOperations

protected List<BOWorkOrderOperation> loadCancelledWorkOrderOperations(PooledConnection connApplication,
 List<Long> closedBundleOperationsWOOperationIds)
                                                               throws DAValidateException,
DAException

Throws:

DAValidateException

DAException

doInsert

protected Long doInsert(HashGetter currentRecord,
 PooledConnection conn,
 PooledConnection externalConn)
                 throws DAException,
DAValidateException

Specified by:

doInsert in class overit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator

Throws:

DAException

DAValidateException

doUpdate

protected void doUpdate(HashGetter currentRecord,
 PooledConnection conn,
 PooledConnection externalConn)
                 throws DAException,
DAValidateException

Specified by:

doUpdate in class overit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator

Throws:

DAException

DAValidateException

doDelete

protected void doDelete(HashGetter hgToDel,
 PooledConnection conn,
 PooledConnection externalConn)
                 throws DAException,
DAValidateException

Specified by:

doDelete in class overit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator

Throws:

DAException

DAValidateException

addCustomTombStone

protected void addCustomTombStone(TreeMap<Long,Long> tmInsertedKeyTranslations)

Specified by:

addCustomTombStone in class overit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator

acknowledge

protected Map<String,String> acknowledge(HashGetter filter,
 PooledConnection conn,
 PooledConnection externalConn)
                                  throws DAException,
DAValidateException

Specified by:

acknowledge in class overit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator

Throws:

DAException

DAValidateException

appendCustomTombstone

protected void appendCustomTombstone(ArrayList<String> alTombstones,
 HashGetter filter,
 Date lastSync,
 Long idPda,
 PooledConnection connSystem,
 PooledConnection connApplication)
                              throws DAException

Overrides:

appendCustomTombstone in class overit.geocallapp.replicator.basic.base.DataSource.DATaskReplicator

Throws:

DAException