使用基于 RosettaNet 的 Web 服务，第四部分: BPEL4WS 和 RosettaNet

<!-- Author: Suhayl Masud. SuhaylA@DifferentThinking.com    http://www.DifferentThinking.com -->
<definitions targetNamespace="http://www.acme.com/services/poRequester"
             xmlns:ACME="http://www.acme.com/services/poRequester"
       xmlns:xsd="http://www.w3.org/2001/XMLSchema"
             xmlns:slt="http://schemas.xmlsoap.org/ws/2002/07/service-link/"
             xmlns:soap="http://schemas.xmlsoap.org/wsdl/soap/"
             xmlns="http://schemas.xmlsoap.org/wsdl/">
   <message name="ReplenishRequestType">
      <part name="PORequest" type="xsd:string"/>
   </message>
   <message name="ReceiptAckType">
      <part name="receiptAck" type="xsd:string"/>
   </message>
   <portType name="replenishRequestPort">
      <operation name="replenishRequest">
         <input message="ACME:ReplenishRequestType"/>
         <output message="ACME:ReceiptAckType"/>
      </operation>
   </portType>
   <slt:serviceLinkType name="replenishRequestSLT">
     <slt:role name="inventoryService">
       <slt:portType name="ACME:replenishRequestPort"/>
     </slt:role>
   </slt:serviceLinkType>
   <!-- Note: This process will be installed on BPEL Engine, it will generate-->
   <!-- The bindings information automatically -->
   <service name="ACMEPORequesterServiceBP">
   </service>
</definitions>

<!-- Author: Suhayl Masud. SuhaylA@DifferentThinking.com http://www.DifferentThinking.com -->
<definitions targetNamespace="http://www.laptops.com/wsdl/POService"
             xmlns:LPTS="http://www.laptops.com/wsdl/POService"
             xmlns:LPTS2="http://www.laptops.com/wsdl/SalesService"
             xmlns:LPTS3="http://www.laptops.com/wsdl/ShippingService"
             xmlns:slt="http://schemas.xmlsoap.org/ws/2002/07/service-link/"
             xmlns:xsd="http://www.w3.org/2001/XMLSchema"
             xmlns="http://schemas.xmlsoap.org/wsdl/">
   <message name="PORequestType">
      <part name="PORequest" type="xsd:string"/>
   </message>
   <message name="ReceiptAckPORequestType">
      <part name="receipt" type="xsd:string"/>
   </message>
   <portType name="placePORequestPort">
      <operation name="placePORequest">
         <input message="LPTS:PORequestType"/>
         <output message="LPTS:ReceiptAckPORequestType"/>
      </operation>
   </portType>
   <slt:serviceLinkType name="PORequestSLT">
     <slt:role name="buyer">
       <slt:portType name="LPTS:placePORequestPort"/>
     </slt:role>
   </slt:serviceLinkType>
   <slt:serviceLinkType name="InternalPORequestSLT">
     <slt:role name="internalSales">
       <slt:portType name="LPTS2:SalesServicePT"/>
     </slt:role>
   </slt:serviceLinkType>
   <slt:serviceLinkType name="InternalPOShippingSLT">
     <slt:role name="internalShipping">
       <slt:portType name="LPTS3:ShippingServicePT"/>
     </slt:role>
   </slt:serviceLinkType>
   <!-- Note: This process will be installed on BPEL Engine, it will generate-->
   <!-- The bindings information automatically -->
   <service name="placePORequestServiceBP">
   </service>
</definitions>

<!-- Author: Suhayl Masud. SuhayAl@DifferentThinking.com http://www.DifferentThinking.com -->
<definitions targetNamespace="http://www.acme.com/services/poAcceptanceReceiver"
             xmlns:ac="http://www.acme.com/services/poAcceptanceReceiver"
             xmlns:acl="http://www.acme.com/services/acmeAccountsService"        
             xmlns:xsd="http://www.w3.org/2001/XMLSchema"
             xmlns:slt="http://schemas.xmlsoap.org/ws/2002/07/service-link/"
             xmlns:soap="http://schemas.xmlsoap.org/wsdl/soap/"
             xmlns="http://schemas.xmlsoap.org/wsdl/">
   <message name="POAcceptanceType">
      <part name="POAcceptance" type="xsd:string"/>
   </message>
   <message name="ReceiptAckType">
      <part name="receiptAck" type="xsd:string"/>
   </message>
   <portType name="sendPOAcceptancePort">
      <operation name="sendPOAcceptance">
         <input message="ac:POAcceptanceType"/>
         <output message="ac:ReceiptAckType"/>
      </operation>
   </portType>
   <slt:serviceLinkType name="POAcceptanceSLT">
      <slt:role name="POService">
        <slt:portType name="ac:sendPOAcceptancePort"/>
      </slt:role>
   </slt:serviceLinkType>
   <slt:serviceLinkType name="AccountsServiceSLT">
      <slt:role name="service">
        <slt:portType name="acl:AccountsServicePT"/>
      </slt:role>
   </slt:serviceLinkType>
   <!-- Note: This process will be installed on BPEL Engine, it will generate-->
   <!-- The bindings information automatically -->
   <service name="ACMEPOReceiverServiceBP">
   </service>
</definitions>

<!-- Author: Suhayl Masud. Suhayl@DifferentThinking.com http://www.DifferentThinking.com -->
<process name="acmePORequesterProcess"
          targetNamespace="http://www.acme.com/services/acmePORequesterProcess"
          xmlns="http://schemas.xmlsoap.org/ws/2002/07/business-process/"
          xmlns:acmePOR="http://www.acme.com/services/poRequester"
          xmlns:laptopsPO="http://www.laptops.com/wsdl/POService">
<!-- This process has two partners, the internal ACME inventory service that triggers the -->
<!-- process and the POFulfiller (Laptops Inc), to whom the PORequest is sent             -->
  <partners>
    <partner name="inventoryService" serviceLinkType="acmePOR:replenishRequestSLT"/>
    <partner name="POFulfiller" serviceLinkType="laptopsPO:PORequestSLT"/>
  </partners>
  <containers>
    <container name="replenishRequestCTR" messageType="acmePOR:ReplenishRequestType"/>
    <container name="replenishResponseCTR" messageType="acmePOR:ReceiptAckType"/>
    <container name="outputPORequestAckContainer" 
    messageType="laptopsPO:ReceiptAckPORequestType"/>
  </containers>
<sequence name="placePOSequence">
<!-- Receive the inventory manager PO Request and store it in replenishRequest container-->
   <receive name="ReplenishRecieve"
             partner="inventoryService" portType="acmePOR:replenishRequestPort" 
             operation="replenishRequest"
             container="replenishRequestCTR" createInstance="yes">
   </receive>   
<!-- Initialize container -->
<assign>
      <copy>
        <from expression="'initializing'"/>
        <to container="replenishResponseCTR" part="receiptAck"/>
      </copy>
</assign>
 
<!-- Invoke placePORequest service at Laptops Inc -->
<invoke name="PlacePOwithSeller"
            partner="POFulfiller" portType="laptopsPO:placePORequest" operation="placePORequest"
            inputContainer="replenishRequestCTR" 
            outputContainer="outputPORequestAckContainer"/>
<!-- Copy Receipt Ack from Laptops Inc to be sent to Inventory Manager -->
<assign>
      <copy>
         <from container="outputPORequestAckContainer" part="receipt"/>
         <to container="replenishResponseCTR" part="receiptAck"/>
      </copy>
</assign>
<!-- Reply to inventory manager with the receipt ack of the PO Order sent by laptops Inc -->
<reply name="ReplenishResponse"
           partner="inventoryService" portType="acmePOR:replenishRequestPort" 
           operation="replenishRequest"
           container="replenishResponseCTR">
</reply>
</sequence>
</process>

 
  <partners>
    <partner name="inventoryService" serviceLinkType="acmePOR:replenishRequestSLT"/>
    <partner name="POFulfiller" serviceLinkType="laptopsPO:PORequestSLT"/>
  </partners>

 
  <containers>
    <container name="replenishRequest" messageType="acmePOR:ReplenishRequestType"/>
    <container name="replenishResponse" messageType="acmePOR:ReceiptAckType"/>
    <container name="inputPORequestContainer" messageType="laptopsPO:PORequestType"/>
    <container name="outputPORequestAckContainer" 
    messageType="laptopsPO:ReceiptAckPORequestType"/>
  </containers>

<sequence name="placePOSequence">
  <receive name="ReplenishRecieve"
            partner="inventoryService" portType="acmePOR:replenishRequestPort" 
            operation="replenishRequest"
            container="replenishRequest" createInstance="yes">
  </receive>

  <invoke name="PlacePOwithSeller"
         partner="POFulfiller" portType="laptopsPO:placePORequest" operation="placePORequest"
         inputContainer="inputPORequestContainer" outputContainer="outputPORequestAckContainer">
  </invoke>

<assign name="copyreceivedreceipt">
      <copy>
      <from container="outputPORequestAckContainer" part="receipt"/>
       <to container="replenishResponse" part="receiptAck"/>
      </copy>
</assign>   

<reply name="ReplenishResponse"
           partner="inventoryService" portType="acmePOR:replenishRequestPort" 
           operation="replenishRequest"
           container="replenishResponse">
</reply>
</sequence>
</process> 

<!-- Author: Suhayl Masud. SuhaylA@DifferentThinking.com http://www.DifferentThinking.com -->
<process name="acmePOReceiverProcess"
    targetNamespace="http://www.acme.com/services/acmePOReceiverProcess"
    xmlns="http://schemas.xmlsoap.org/ws/2002/07/business-process/"
         xmlns:acmePOA="http://www.acme.com/services/poAcceptanceReceiver"
    xmlns:acmeAcct="http://www.acme.com/service/accountsService"
      xmlns:laptopsPO="http://www.laptops.com/services/LaptopsIncPlacePO">
<!-- The process has two partners. JoeLaptops, which is the acceptance notifier -->
<!-- and sends the process the PO confirmation, and the second partner is an internal -->
<!-- Accounts service that is informed of the latest purchase that needs to be paid -->
  <partners>
     <partner name="POAcceptanceNotifier" serviceLinkType="acmePOA:POAcceptanceSLT"/>
     <partner name="Accounting" serviceLinkType="acmeAcct:AccountsServiceSLT"/>
  </partners>
<containers>
    <container name="POAcceptanceContainer" messageType="acmePOA:POAcceptanceType"/>
    <container name="POAcceptanceReceipt" messageType="acmePOA:ReceiptAckType"/>
    <container name="PurchaseReport" messageType="acmeAcct:reportPurchaseMsg"/>
</containers>
<sequence name="receivePOSequence">
<!-- The process receives the PO confirmation from JoeLaptops -->
<receive name="ReceivePOAcceptance"
             partner="POAcceptanceNotifier" portType="acmePOA:sendPOAcceptancePort" 
             operation="sendPOAcceptance"
             container="POAcceptanceContainer" createInstance="yes">
</receive>   
<!-- Copy acknowledgement of the PO Confirmation to be sent to JoeLaptops -->
<assign>
      <copy>
        <from expression="'Acme corp has received your PO Acceptance. Thank you'"/>
        <to container="POAcceptanceReceipt" part="receiptAck"/>
      </copy>
</assign>
<!-- Send JoeLaptops Receipt Acknowledging the PO Confirmation -->
<reply name="POAcceptanceReceiptAck"
           partner="POAcceptanceNotifier" portType="acmePOA:sendPOAcceptancePort" 
           operation="sendPOAcceptance"
           container="POAcceptanceReceipt">
</reply>
<!-- Copy the POConfirmation to a purchase report container -->
<assign>
      <copy>
        <from container="POAcceptanceContainer" part="POAcceptance"/>
        <to container="PurchaseReport" part="purchaseReport"/>
      </copy>
</assign>
<!-- Send the accounting service the purchase report -->
<invoke name="invoke" partner="Accounting" portType="acmeAcct:AccountsServicePT"
            operation="reportPurchase" inputContainer="PurchaseReport" 
            outputContainer="POAcceptanceReceipt"/>
</sequence>
</process>

<!-- Author: Suhayl Masud. SuhaylA@DifferentThinking.com  http://www.DifferentThinking.com -->
<process xmlns="http://schemas.xmlsoap.org/ws/2002/07/business-process/"
         name="laptopsPlacePOProcess"
         targetNamespace="http://www.laptops.com/services/POService"
         xmlns:tns="http://www.laptops.com/wsdl/POService"
    xmlns:tns2="http://localhost:8080/laptops/laptopsSalesService.wsdl"
     xmlns:tns3="http://localhost:8080/laptops/laptopsShippingService.wsdl"
    xmlns:acme="http://localhost:8080/acme/ACMEPOAcceptance.wsdl">
<!-- Define Partners -->
  <partners>
    <partner name="buyer" serviceLinkType="tns:PORequestSLT"/>
    <partner name="internalSales" serviceLinkType="tns:InternalPORequestSLT"/>
    <partner name="internalShipping" serviceLinkType="tns:InternalPOShippingSLT"/>
    <partner name="acceptanceReceiver" serviceLinkType="acme:PORequestSLT"/>
  </partners>
<!-- Define Containers used when interacting with partners -->
  <containers>
    <container name="PORequestCtr" messageType="tns:PORequestType"/>
    <container name="internalPORequest" messageType="tns2:fillPORequest"/>
    <container name="internalPOAcceptance" messageType="tns2:poConfirmation"/>
    <container name="internalShippingOrder" messageType="tns3:shipPurchaseOrder"/>    
    <container name="internalSOResp" messageType="tns3:shipPOResp"/>        
    <container name="POAcceptance" messageType="acme:POAcceptanceType"/>
    <container name="buyerReceipt" messageType="acme:ReceiptAckType"/>
    <container name="LaptopsReceiptAck" messageType="tns:ReceiptAckPORequestType"/>
  </containers>
  <sequence name="placePOSequence">
  
<!-- Receive PORequest from ACME -->
  
    <receive name="RecievePORequest"
              partner="buyer" portType="tns:placePORequestPort" operation="placePORequest"
             container="PORequestCtr" createInstance="yes">
    </receive>
<!-- initialize Containers -->
    <assign>
      <copy>
        <from expression="'initializing'"/>
        <to container="internalPORequest" part="poRequest"/>
      </copy>
    </assign>
    <assign>
      <copy>
        <from expression="'Receipt Acknowledgement This message is to acknowledge 
        that Laptops Inc have received your PO Request. We are working on the 
        response which you will receive shortly'"/>
        <to container="LaptopsReceiptAck" part="receipt"/>
      </copy>
    </assign>
<!-- initialize internalShippingOrder --> 
    <assign>
      <copy>
        <from expression="'initializing'"/>
        <to container="internalShippingOrder" part="shipPOAcceptance"/>
      </copy> 
    </assign>
    <assign>
      <copy>
        <from expression="'initializing'"/>
        <to container="internalShippingOrder" part="poShippingOrder"/>
      </copy> 
    </assign>
<!-- initialize internalSOResponse --> 
    <assign>
      <copy>
        <from expression="'initializing'"/>
        <to container="internalSOResp" part="shipResponse"/>
      </copy> 
    </assign>
<!-- Send ACME Receipt Acknowledgment of PORequest -->
    <reply name="ReceiptAckActivity"
           partner="buyer" portType="tns:placePORequestPort" operation="placePORequest"
           container="LaptopsReceiptAck">
    </reply>
<!-- copy PORequest to container used for internal PORequest -->
    <assign>
      <copy>
        <from container="PORequestCtr" part="PORequest"/>
        <to container="internalPORequest" part="poRequest"/>
      </copy>
 </assign>
<!-- Ask Internal Sales department to process PORequest -->
<invoke name="invoke" partner="internalSales" portType="tns2:SalesServicePT"
            operation="fillPO" inputContainer="internalPORequest" 
            outputContainer="internalPOAcceptance"/>
<!-- Copy the response from Internal Sales to send to ACME -->
  <assign>
      <copy>
        <from container="internalPOAcceptance" part="poConfirmation"/>
        <to container="POAcceptance" part="POAcceptance"/>
      </copy>
  </assign>
<!-- Send ACME substantive message, letting ACME know if the PO was accepted -->
    <invoke name="SendBuyerPOAcceptance"
       partner="acceptanceReceiver" portType="acme:sendPOAcceptancePort" 
       operation="sendPOAcceptance"
       inputContainer="POAcceptance" outputContainer="buyerReceipt">
    </invoke>
<!-- Copy ACME's receipt message of the POConfirmation to container for 
internal shipping service -->
  <assign>
      <copy>
        <from container="buyerReceipt" part="receiptAck"/>
        <to container="internalShippingOrder" part="shipPOAcceptance"/>
      </copy>
  </assign>
<!-- Copy POConfirmation to container for internal shipping service -->
  <assign>
 <copy>
       <from container="internalPOAcceptance" part="poConfirmation"/>
       <to container="internalShippingOrder" part="poShippingOrder"/>
      </copy>
  </assign>
<!-- Send POConfirmation and ACME's receipt acknowledging the POConfirmation to 
the shipping service -->
  <invoke name="invokeShipping" partner="internalShipping" portType="tns3:ShippingServicePT"
   operation="shipPO" inputContainer="internalShippingOrder" outputContainer="internalSOResp"/>
</sequence>
</process>