導(dǎo)入前驗(yàn)證APL代碼-函數(shù)編寫模板
//校驗(yàn)邏輯
log.info(context.data)
def data = context.data as Map
// 獲取 任務(wù)id 和數(shù)據(jù)所屬的行號(hào)
def taskId = data._TaskId as String
def rowNo = data._RowNo as String
log.info(taskId)
log.info(rowNo)
// 從緩存中獲取預(yù)處理函數(shù)保存的信息
Cache cache = Fx.cache.defaultCache
def key = taskId + "_" + rowNo
def value = cache.get(key)
log.info(value)
return ValidateResult.builder()
.success(true)
.errorMessage("我是導(dǎo)入前驗(yàn)證函數(shù)!?。?!")
.build()
導(dǎo)入預(yù)處理APL代碼-函數(shù)編寫模板
// 獲取導(dǎo)入的任務(wù)id 和 以及是否為最后一批數(shù)據(jù) def taskId = context.task.taskId as String log.info(context.task.taskId) log.info(context.task.lastBatch) // 在 cache 中緩存信息,供前驗(yàn)證函數(shù)使用 Cache cache = Fx.cache.defaultCache List<Map> dataList = context.dataList as List dataList.each{data -> def rowNo = data._RowNo as String def name = data.field_MG1ch__c as String def key = taskId + "_" + rowNo log.info(key) def value = "" + name cache.put(key, value, 30) } return ValidateResult.builder() // 返回 false 將終止本次導(dǎo)入 .success(false) .errorMessage("我是導(dǎo)入預(yù)處理函數(shù)?。。?!") .build()