Version: 19.05 (EOL)
Transaction History Publisher
The Transaction History Publisher is used to publish transaction history data to the customer's data warehouse. The list of ids returned in the result contains published record's primary keys.
This service is configured via the Form Details tab under the Tracking Code section.
Service Invoke Parameters
Parameters are optional except where otherwise indicated.
Parameter | Description |
---|---|
svcDef | SvcDef Required. A service definition value object. |
rows | List <map> Required. The rows data as a List. |
Script Result
The script returns a list of numbers which are published.
Error Handling
If an error occurs invoking your Transaction History Publisher script, the error is logged in the Journey Manager database error log, and the user is redirected to the error page on the form space. The transaction is rolled back, and no transaction record is created.
Service Template
This section shows service template Groovy script.
import com.avoka.core.groovy.GroovyLogger as logger
import com.avoka.tm.svc.*
import com.avoka.tm.vo.*
import com.jcraft.jsch.*
class FluentTransactionHistoryPublisher {
/*
* Perform a transaction history publishing
*
* return: list of the published transactions' primary keys.
*/
List<number> invoke(SvcDef svcDef, List<map> rows) {
/* // JCraft SFTP Upload Example
ChannelSftp channelSftp
Session session
try {
String username = svcDef.svcConn.username
String password = svcDef.svcConn.password
String endpoint = svcDef.svcConn.endpoint
JSch jsch = new JSch()
session = jsch.getSession(username, endpoint, 22)
session.setPassword(password)
Properties config = new Properties()
config.put("StrictHostKeyChecking", "no")
session.setConfig(config)
session.connect()
Channel channel = session.openChannel("sftp")
channel.connect()
channelSftp = (ChannelSftp) channel
// TODO: write the rows in local 'myfile.data' file and then upload
channelSftp.put('/local/storage/myfile.data', '/remote/myfile.data')
} finally {
channelSftp?.disconnect()
session?.disconnect()
}
*/
//Fill and return rows' ids
final List<number> result = new ArrayList<>()
for (Map<string object> row: rows) {
result.add(Long.parseLong(row.get('transaction_history_oid').toString()))
}
return result
}
}
Templates
Unit Test
import com.avoka.core.groovy.GroovyLogger as logger
import com.avoka.tm.svc.*
import com.avoka.tm.vo.*
import org.junit.Test
class UnitTest extends AbstractJUnitTest {
/*
* Perform service unit test
*
* throws exception if unit test fails
*/
@Test
void testTxnHistoryPublisher() throws Exception {
//TODO fill some rows data
List<map>> rows = new ArrayList<>()
Map params = [
"svcDef": svcDef,
"rows": rows
]
List<number> ids = (List<number>) new ServiceInvoker(svcDef).invoke(params)
logger.info "Published ids.size: " + ids.size()
// Test any business logic performed
assert ids != null
}
}