导入前验证APL代码-函数编写模板

//校验逻辑
log.info(context.data)
def data = context.data as Map
// 获取 任务id 和数据所属的行号
def taskId = data._TaskId as String
def rowNo = data._RowNo as String

log.info(taskId)
log.info(rowNo)

// 从缓存中获取预处理函数保存的信息
Cache cache = Fx.cache.defaultCache
def key = taskId + "_" + rowNo

def value = cache.get(key)

log.info(value)

return ValidateResult.builder()
.success(true)
.errorMessage("我是导入前验证函数！！！！")
.build()

导入预处理APL代码-函数编写模板

  // 获取导入的任务id 和 以及是否为最后一批数据
  def taskId = context.task.taskId as String
  log.info(context.task.taskId)
  log.info(context.task.lastBatch)

// 在 cache 中缓存信息，供前验证函数使用
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 将终止本次导入
.success(false)
.errorMessage("我是导入预处理函数！！！！")
.build()