2012-07-26 54 views
1

这MarkLogic XQuery的职位SOAP消息发送到CRM,得到响应回为XML,可以请你帮我实现相同的查询如下:MarkLogic SOAP响应处理

  1. 我希望每次运行此查询五分钟使用MarkLogic Task Server。它运行下一次之前,我要解析的最后一个响应并执行以下操作:

a)如果在响应XML,我们看到的结果/响应/代码[= 200],然后选择结果/响应/头/日期并将其分配给XQuery的$ lastUpdateTime变量。否则$ lastUpdateTime不应得到更新(以确保事务成功)。 b)。我在MarkLogic DataBase中有一个XML,其中包含id,first_name,last_name,phone,email标记。每次SOAP响应都会向我提供来自CRM的更新详细信息,即first_name,last_name,phone,email(其中ID是唯一标识符)。现在我必须遍历每个响应/项目,并且当id与ML DB的XML中的任何记录匹配时,我必须更新各自的first_name,last_name,phone,email。

的XQuery:

let $lastUpdateTime := xdmp:get-request-field("lastUpdateTime", "2012-07-23 09:26:03") 

let $payload := xdmp:quote(
    <SOAP-ENV:Envelope> 
     <SOAP-ENV:Body> 
     .... 
     </SOAP-ENV:Body> 
    </SOAP-ENV:Envelope> 
) 
return 
    let $createLogin := xdmp:http-post("http://localhost/SugarCE-Full-6.5.0/service/v2/soap.php/login") 
    let $payload2 := xdmp:quote(
     <SOAP-ENV:Envelope> 
     <SOAP-ENV:Body> 
      <query>date_modified >= '{$lastUpdateTime} AND deleted = 0'</query> 
     </SOAP-ENV:Body> 
     </SOAP-ENV:Envelope>) 
    return 
    xdmp:http-post("http://localhost/SugarCE-Full-6.5.0/service/v2/soap.php/login") 

响应:

<?xml version="1.0" encoding="UTF-8"?> 
<results warning="more than one root item"> 
    <response xmlns="xdmp:http"> 
    <code>200</code> 
    <message>OK</message> 
    <headers> 
     <date>Thu, 26 Jul 2012 19:33:58 GMT</date>  
    </headers> 
    </response> 
    <SOAP-ENV:Envelope> 
    <SOAP-ENV:Body> 
     <entry_list> 
     <item xsi:type="tns:entry_value"> 
     <item xsi:type="tns:name_value"> 
      <name xsi:type="xsd:string">id</name> 
      <value xsi:type="xsd:string">90cd7230-9fdd-20ae-9ad2-500dabecdb70</value> 
     </item> 
     <item xsi:type="tns:name_value"> 
      <name xsi:type="xsd:string">first_name</name> 
      <value xsi:type="xsd:string">Jhon</value> 
     </item> 
     <item xsi:type="tns:name_value"> 
      <name xsi:type="xsd:string">last_name</name> 
      <value xsi:type="xsd:string">Carter</value> 
     </item> 
     <item xsi:type="tns:name_value"> 
      <name xsi:type="xsd:string">email</name> 
      <value xsi:type="xsd:string">[email protected]</value> 
     </item> 
     <item xsi:type="tns:name_value"> 
      <name xsi:type="xsd:string">phone</name> 
      <value xsi:type="xsd:string">99999999</value> 
     </item>  
      </name_value_list> 
     </item> 
     <item xsi:type="tns:entry_value"> 
     <item xsi:type="tns:name_value"> 
      <name xsi:type="xsd:string">id</name> 
      <value xsi:type="xsd:string">90cd7230-9fdd-20ae-9ad2-500dabecdb71</value> 
     </item> 
     <item xsi:type="tns:name_value"> 
      <name xsi:type="xsd:string">first_name</name> 
      <value xsi:type="xsd:string">Jack</value> 
     </item> 
     <item xsi:type="tns:name_value"> 
      <name xsi:type="xsd:string">last_name</name> 
      <value xsi:type="xsd:string">Sully</value> 
     </item> 
     <item xsi:type="tns:name_value"> 
      <name xsi:type="xsd:string">email</name> 
      <value xsi:type="xsd:string">[email protected]</value> 
     </item> 
     <item xsi:type="tns:name_value"> 
      <name xsi:type="xsd:string">phone</name> 
      <value xsi:type="xsd:string">8888888</value> 
     </item>  
      </name_value_list> 
     </item>  
     </item> 
     </entry_list> 
     </SOAP-ENV:Body> 
    </SOAP-ENV:Envelope> 
</results> 

现有的ML DB XML

<?xml version="1.0" encoding="UTF-8"?> 
<Users> 
    <user> 
     <id>90cd7230-9fdd-20ae-9ad2-500dabecdb70</id> 
     <firstName>Jhon</firstName> 
     <lastName>Carter</lastName> 
     <phone>999999999</phone> 
     <email>[email protected]</email> 
    </user> 
    <user> 
     <id>90cd7230-9fdd-20ae-9ad2-500dabecdb72</id> 
     <firstName>Pankja</firstName> 
     <lastName>Pankaj</lastName> 
     <phone>88888</phone> 
     <email>[email protected]</email> 
    </user> 
    <user> 
     <id>90cd7230-9fdd-20ae-9ad2-500dabecdb78</id> 
     <firstName>xyz</firstName> 
     <lastName>abc</lastName> 
     <phone>1111111</phone> 
     <email>[email protected]</email> 
    </user> 
</Users> 

任何建议将是一个很大的帮助。谢谢。

回答

1

首先,摆脱lastUpdateTime参数。例如,将该值存储在用户xml中作为根元素的属性,并在脚本被调用后立即从那里读取它。每次更新用户XML时,扩展现有代码以更新该时间戳。

接下来,将脚本存储在您选择的数据库中。确保它是一个主要的xquery模块,而不是一个库模块。

最后,进入管理界面,打开您感兴趣的群组,打开计划任务,然后在其中添加一个新任务。模块数据库应指向您存储脚本的位置。任务根引用该模块数据库中的路径前缀。你可以让它保持简单。任务数据库应指向您存储用户XML的位置。

HTH!