工作流中的 JavaScript 代码示例

以下示例显示如何在工作流中使用JavaScript代码：

• 写入数据库
• 查询数据库
• 使用静态SOAP方法触发工作流
• 使用非静态SOAP方法与数据库交互

了解更多 关于静态和非静态SOAP方法。

在这些示例中，使用ECMAScript for XML(E4X)扩展。 使用此扩展，您可以将JavaScript调用和XML基元组合到同一脚本中。

要试用这些示例，请执行以下步骤：

1. 创建工作流并将这些活动添加到工作流：

   1. 开始活动
   2. JavaScript代码活动
   3. 结束活动

   了解更多 关于构建工作流。

2. 将JavaScript代码添加到活动。 了解详情。

3. 保存工作流。

4. 测试示例：

   1. 启动工作流. 了解详情。
   2. 打开日记。 了解详情。

示例1:写入数据库

要写入数据库，可以使用静态 Write 方法 xtk:session 架构：

1. 在XML中撰写写请求。

2. 写记录：

   1. 调用 Write 方法 xtk:session 架构。

      重要

      如果您使用Adobe Campaign v8，我们建议您将暂存机制与 摄取 和 数据更新/删除 的API Write 方法Snowflake。 了解更多。

   2. 将XML代码作为写入请求的参数传递。

步骤1:撰写写请求

您可以添加、更新和删除记录。

插入记录

因为 insert 操作是默认操作，您无需指定它。

将此信息指定为XML属性：

• 要修改的表的架构
• 要填充的表字段

示例:

var myXML = <recipient xtkschema="nms:recipient"
    firstName="Isabel"
    lastName="Garcia"
    email="isabel.garcia@mycompany.com"/>

更新记录

使用 _update 操作。 了解详情。

将此信息指定为XML属性：

• 要修改的表的架构
• 要更新的表字段
• 标识要更新的记录所需的键参数

示例:

var myXML = <recipient xtkschema="nms:recipient"
    status="Client"
    email="isabel.garcia@mycompany.com"
    operation="_update"
    _key="@email"/>

删除记录

使用 DeleteCollection 方法。 了解详情。

指定以下信息：

• 要修改的表的架构
• 的 where 以XML元素形式标识要更新的记录所需的子句

示例:

xtk.session.DeleteCollection(
    "nms:recipient",
    <where>
        <condition expr="[@email] = 'isabel.garcia@mycompany.com'"/>
    </where>,
    false
    )

步骤2:写记录

调用非静态 Write 方法 xtk:session 架构：

xtk.session.Write(myXML)

此方法不返回任何值。

将完整代码添加到工作流中的JavaScript代码活动：

var myXML = <recipient xtkschema="nms:recipient"
    firstName="Isabel"
    lastName="Garcia"
    email="isabel.garcia@mycompany.com"/>

xtk.session.Write(myXML)

以下视频演示如何写入数据库：

示例2:查询数据库

要查询数据库，可以使用非静态 xtk:queryDef 实例方法：

1. 在XML中撰写查询。
2. 创建查询对象。
3. 运行查询。

步骤1:撰写查询

为 queryDef 实体。

语法:

<queryDef schema="nms:recipient" operation="">
    <!-- select, where, and orderBy clauses as XML elements -->
</queryDef>

指定以下信息：

• 要读取的表的架构
• 操作
• 要返回的列(在 select 子句
• 条件，在 where 子句
• 筛选条件(在 orderBy 子句

您可以使用以下操作：

编写 select, where和 orderBy 子句作为XML元素：

• select 子句

  指定要返回的列。 例如，要选择人员的名字和姓氏，请编写以下代码：

  <select>
      <node expr="@firstName"/>
      <node expr="@lastName"/>
  </select>
  

  使用 nms:recipient 架构中，以下形式返回了元素：

  <recipient firstName="Bo" lastName="Didley"/>
  

• where 子句

  要指定条件，请使用 where 子句。 例如，要选择位于 培训 文件夹，可以编写此代码：

  <where>
      <condition expr="[folder/@label]='Training'"/>
  </where>
  

  组合多个表达式时，在第一个表达式中使用布尔运算符。 例如，要选择所有名为Isabel Garcia的人员，您可以编写以下代码：

  <condition boolOperator="AND" expr="@firstName='Isabel'"/>
  <condition expr="@lastName='Garcia'"/>
  

• orderBy 子句

  要对结果集进行排序，请指定 orderBy 子句作为XML元素，且 sortDesc 属性。 例如，要对姓氏进行升序排序，您可以编写以下代码：

  <orderBy>
      <node expr="@lastName> sortDesc="false"/>
  </orderBy>
  

步骤2:创建查询对象

要从XML代码创建实体，请使用 create(content) 方法：

var query = xtk.queryDef.create(
    <queryDef schema="nms:recipient" operation="select">
    …
    </queryDef>)

为 create(content) 方法。

的 content 参数是一个字符串参数，且是可选参数。 此参数包含描述实体的XML代码。

步骤3:运行查询

请执行以下步骤：

1. 调用 ExecuteQuery 方法 queryDef 实体：

   var res = query.ExecuteQuery()
   

2. 处理结果：

   1. 迭代到 select 操作，使用循环结构。
   2. 使用 getIfExists 操作。
   3. 使用 count 操作。

结果a select 操作

所有匹配项都将作为收藏集返回：

<recipient-collection>
    <recipient email="jane.smith@mycompany.com">
    <recipient email="john.harris@mycompany.com">
</recipient-collection>

要迭代结果，请使用 for each 循环：

for each (var rcp in res:recipient)
    logInfo(rcp.@email)

循环包括本地收件人变量。 对于收件人集合中返回的每个收件人，都会打印收件人的电子邮件。 了解更多 关于 logInfo 函数。

结果a getIfExists 操作

每个匹配项都作为元素返回：

<recipient id="52,378,079">

如果没有匹配项，则返回空元素：

<recipient/>

您可以引用主键节点，例如 @id 属性：

if (res.@id !=undefined)
    { // match was found
    …
    }

结果 get 操作

将作为元素返回一个匹配项：

<recipient id="52,378,079">

如果没有匹配项，则返回错误。

结果 count 操作

元素 count 属性：

<recipient count="200">

要使用结果，请参阅 @count 属性：

if (res.@count > 0)
    { // matches were found
    …
    }

对于 select 操作时，将此代码添加到工作流中的JavaScript代码活动：

var myXML =
<queryDef schema="nms:recipient" operation="select">
    <select>
        <node expr="@firstName"/>
        <node expr="@lastName"/>
    </select>
</queryDef>

var query = xtk.queryDef.create(myXML)

var res = query.ExecuteQuery()

for each (var rcp in res.recipient)
    logInfo(rcp.@firstName + " " + rcp.@lastName)

因为 select 操作是默认操作，您无需指定它。

以下视频演示了如何从数据库读取：

触发工作流

您可以以编程方式触发工作流，例如在技术工作流中触发工作流，或处理用户在Web应用程序页面上输入的信息。

工作流触发可通过事件的使用进行。 您可以将以下功能用于事件：

• 要发布事件，您可以使用静态 PostEvent 方法。 了解详情。
• 要接收事件，您可以使用 External signal 活动。 了解详情。

您可以通过不同方式触发工作流：

• 您可以在内联触发工作流，即从 JavaScript code 活动。
• 您可以在完成另一个工作流时触发工作流：

  • 将初始化脚本添加到 End 活动。

  • 添加 External signal 活动时，您可以在页面上找到该活动。

    完成初始工作流后，会发布一个事件。 将激活传出过渡并填充事件变量。 然后，目标工作流会接收该事件。

    小贴士

    最佳做法是，在向活动添加脚本时，请用双连字符括住活动名称，例如， -- end --. 了解更多 关于工作流最佳实践。

的语法 PostEvent 方法：

PostEvent(
    String     //ID of the target workflow
    String     //Name of the target activity
    String     //Name of the transition to be activated in case of multiple transitions
    XML        //Event parameters, in the <variables/> element
    Boolean    //To trigger the target workflow only once, set this parameter to true.
)

在本例中，完成工作流后，会向 信号 活动 wkfExampleReceiver 工作流：

var strLabel = "Adobe Campaign, Marketing that delivers"
xtk.workflow.PostEvent(
    "wkfExampleReceiver",
    "signal",
    "",
    <variables strLine={strLabel}/>,
    false)

因为最后一个参数被设置为 false, wkfExampleReceiver 每次完成初始工作流时，都会触发工作流。

在触发工作流时，请牢记以下原则：

• 的 PostEvent 命令以异步方式运行。 命令被置于服务器队列中。 该方法在事件发布后返回。
• 必须启动目标工作流。 否则，错误将写入日志文件。
• 如果目标工作流已暂停，则 PostEvent 命令排入队列，直到工作流继续。
• 触发的活动不要求任务正在进行中。

以下视频演示了如何使用静态API方法：

以下视频演示了如何触发工作流：

与数据库交互

以下示例显示如何执行这些操作：

• 使用 get 和 create 架构上使用非静态SOAP方法的方法
• 创建执行SQL查询的方法
• 使用 write 插入、更新和删除记录的方法

请执行以下步骤：

1. 定义查询：

   • 使用 create 方法(例如， xtk:workflow 架构。 了解详情。
   • 使用 queryDef 方法来发出SQL查询。

2. 使用 ExecuteQuery 方法。 了解详情。

   使用 for each 循环来检索结果。

的语法 queryDef 方法 select 子句

<queryDef schema="schema_key" operation="operation_type">
    <select>
        <node expr="expression1">
        <node sql="expression2">
    </select>
    <where>
        <condition expr="expression1"/>
        <condition sql="expression2"/>
    </where>
    <orderBy>
        <node expr="expression1">
        <node sql="expression2">
    </orderBy>
    <groupBy>
        <node expr="expression1">
        <node sql="expression2">
    </groupBy>
    <having>
        <condition expr="expression1"/>
        <condition sql="expression2"/>
    </having>
</queryDef>

Create 方法

示例1:选择记录并写入日记帐

位于 wfExamples 文件夹。 结果按内部名称（升序）排序，并写入日记帐。

var query = xtk.queryDef.create(
    <queryDef schema="xtk:workflow" operation="select">
        <select>
            <node expr="@internalName"/>
        </select>
        <where>
            <condition expr="[folder/@name]='wfExamples'"/>
        </where>
        <orderBy>
            <node expr="@internalName" sortDesc="false"/>
        </orderBy>
    </queryDef>
    )

var res = query.ExecuteQuery()
for each (var w in res.workflow)
    logInfo(w.@internalName)

示例2:删除记录

将选择名为Chris Smith的所有收件人的名字、姓氏、电子邮件和ID。 结果按电子邮件升序排序，并写入日志。 A delete 操作用于删除所选记录。

// Build the query, create a query object and hold the object in a variable
var query = xtk.queryDef.create(
        <queryDef schema="nms:recipient" operation="select">
            <select>
                <node expr="@firstName"/>
                <node expr="@lastName"/>
                <node expr="@email"/>
                <node expr="@id"/>
            </select>
            <where>
                <condition expr="[folder/@label]='Recipients'"/>
                <condition expr="[@lastName]='Smith'"/>
                <condition expr="[@firstName]='Chris'"/>
            </where>
            <orderBy>
                <node expr="@email" sortDesc="false"/>
            </orderBy>
        </queryDef>
)

//Run the query using the ExecuteQuery method against the created object
var res = query.ExecuteQuery()

//Loop through the results, print out the person's name and email, then delete the records
for each (var rec in res.recipient)
    {
     logInfo("Delete record = Email: " + rec.@email + ', ' + rec.@firstName + ' ' + rec.@lastName)
     xtk.session.Write(<recipient xtkschema="nms:recipient" _operation="delete" id={rec.@id}/>)
    }

示例3:选择记录并写入日记帐

在此示例中，使用非静态方法。 其信息存储在 1234 文件夹和其电子邮件域名以“adobe”开头的文件夹。 结果按出生日期以降序排序。 收件人的电子邮件将写入日记。

var query = xtk.queryDef.create(
<queryDef schema="nms:recipient" operation="select">
    <select>
        <node expr="@email"/>
        <node sql="sEmail"/>
        <node expr="Year(@birthDate)"/>
    </select>
    <where>
        <condition expr="[@folder-id] = 1234 and @domain like 'adobe%'"/>
        <condition sql="iFolderId = 1234 and sDomain like 'adobe%'"/>
    </where>
    <orderBy>
        <node expr="@birthDate" sortDesc="true"/>
    </orderBy>
</queryDef>
)

var res = query.ExecuteQuery()
for each (var w in res.recipient)
    logInfo(w.@email)

Write 方法

您可以插入、更新和删除记录。 您可以使用 Write 方法。Adobe Campaign中的任何架构。 由于此方法是静态的，因此您无需创建对象。 您可以使用以下操作：

• 的 update 操作

• 的 insertOrUpdate 操作，使用 _key 用于标识要更新的记录的参数

  如果您没有指定 收件人 ，则如果存在匹配项，则记录将在任何子文件夹中更新。 否则，将在根中创建记录 收件人 文件夹。

• 的 delete 操作

示例1:插入或更新记录

xtk.session.Write(
<recipient
    xtkschema="nms:recipient"
    _operation="insertOrUpdate" _key="@email"
    lastName="Lennon"
    firstName="John"
    email="johnlennon@thebeatles.com"
/>
)

示例2:删除记录

此示例将静态方法与非静态方法结合在一起。

var query=xtk.queryDef.create(
<queryDef schema="nms:recipient" operation="select">
    <select>
        <node expr="@Id"/>
    </select>
    <where>
        <condition expr="[@email]='johnlennon@thebeatles.com'"/>
    </where>
</queryDef>
);

var res = query.ExecuteQuery()
for each (var w in res.recipient) {
xtk.session.Write(
    <recipient xtkschema="nms:recipient" _operation="delete" id={w.@id}/>
);
}

以下视频演示了如何使用非静态API方法：

以下视频演示了在工作流中使用非静态API方法的示例：

相关主题

• 面向数据的API
• JavaScript 脚本和模板
• JavaScript 中的 SOAP 方法

API文档

• SOAP调用示例
• 方法:
  • 创建
  • DeleteCollection
  • ExecuteQuery
  • PostEvent
  • 写入
• logInfo函数

Business.Adobe.com资源