WS-BPEL と IoC で作成する構成可能なワークフロー: 第 2 回 BPEL ワークフローを開発してホストする

<?xml version="1.0" encoding="UTF-8"?>
<process name="MergedProductionWorkflow">
    <import />
    <!-- other import tags -->
    <partnerLinks />
    <variables>
        <variable name="productionOrder" 
            messageType="prod:ProductionOrderMessage"/>
        <variable name="response" 
            messageType="prod:ProductionResponseMessage"/>
        <variable name="productionItems" 
            messageType="prod:ProductionItemsMessage"/>
        <variable name="itemType" type="xsd:string"/>
        <variable name="processDetails" 
            messageType="prod:ProcessDetailsMessage"/>
        <variable name="workOrder" 
            messageType="prod:WorkOrderMessage"/>
        <variable name="manufacturingSchedule" 
            messageType="prod:ManufacturingScheduleMessage"/>
        <variable name="productionItem" 
            messageType="prod:ProductionItemMessage"/>
        <!--  A few other variables to hold temporary data -->
   </variables>
   <sequence />
</process>

<?xml version="1.0" encoding="UTF-8"?>
<wsdl:definitions ...>

  <wsdl:import namespace="http://fictitiousManufacturingEnterprise.com/pms" 
      location="ProductionOrderRecivingService.wsdl" />

  <wsdl:types>
      <xsd:element name="productionItem">
          <xsd:complexType>
              <xsd:sequence>
                 <xsd:element name="itemID" type="xsd:string" />
                 <xsd:element name="itemName" type="xsd:string" />
                 <xsd:element name="itemType" type="xsd:string" />
                 <xsd:element name="itemQuantity" type="xsd:string"/>
                 <xsd:element ref="processDetails" minOccurs="0"/>
             </xsd:sequence>
          </xsd:complexType>
      </xsd:element>

      <xsd:element name="productionItems">
          <xsd:complexType>
              <xsd:sequence>
                 <xsd:element ref="productionItem" 
                      minOccurs="0" maxOccurs="unbounded"/>
              </xsd:sequence>
          </xsd:complexType>
      </xsd:element>
   </wsdl:types>
   
    <wsdl:message name="ProductionOrderMessage">
         <wsdl:part name="productionOrder" element="prod:productionOrder" />
    </wsdl:message>

     <wsdl:message name="ProductionItemsMessage">
         <wsdl:part name="productionItems" element="prod:productionItems" />
     </wsdl:message>

     <wsdl:portType />

     <wsdl:binding />

     <wsdl:service />

     <plnk:partnerLinkType name="Items2BProducedPartnerLinkType">
         <plnk:role name="items2BProducedService"
             portType="prod:Items2BProducedPortType"/>
     </plnk:partnerLinkType>

</wsdl:definitions>

    <xsd:element name="productionOrder">
        <xsd:complexType>
           <xsd:sequence>
                <xsd:element name="orderID" type="xsd:string" />
                <xsd:element name="orderDate" type="xsd:date" />
                <xsd:element name="departmentID" type="xsd:string" />
                <xsd:element name="orderItems" type="xsd:string"/>
            </xsd:sequence>
        </xsd:complexType>
    </xsd:element>

    <xsd:element name="productionItem">
        <xsd:complexType>
           <xsd:sequence>
               <xsd:element name="itemID" type="xsd:string" />
               <xsd:element name="itemName" type="xsd:string" />
               <xsd:element ref="itemType" />
               <xsd:element name="itemQuantity" type="xsd:string"/>
               <xsd:element name="processDetails" type="xsd:string"/>
           </xsd:sequence>
        </xsd:complexType>
    </xsd:element>

    <xsd:element name="itemType" type="xsd:string"/>

    <xsd:element name="processDetails">
        <xsd:complexType>
           <xsd:sequence>
               <xsd:element name="processID" type="xsd:string" />
               <xsd:element name="processType" type="xsd:string" />
               <xsd:element name="processDescription" type="xsd:string" />
           </xsd:sequence>
        </xsd:complexType>
    </xsd:element>

    <xsd:element name="workOrder">
        <xsd:complexType>
           <xsd:sequence>
               <xsd:element name="workOrderID" type="xsd:string" />
               <xsd:element name="orderData" type="xsd:string" />
               <xsd:element ref="productionOrder" />
           </xsd:sequence>
        </xsd:complexType>
    </xsd:element>

    <xsd:element name="manufacturingSchedule">
        <xsd:complexType>
           <xsd:sequence>
               <xsd:element name="itemID" type="xsd:string" />
               <xsd:element name="scheduleDate" type="xsd:string" />
               <xsd:element name="itemQuantity" type="xsd:string" />
           </xsd:sequence>
        </xsd:complexType>
    </xsd:element>

<?xml version='1.0' encoding='utf-8'?>
<soap:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" >
<soap:Body>
<sns:productionOrder xmlns:sns="http://fictitiousManufacturingEnterprise.com/pms">
     <!-- production order data -->
   </sns:productionOrder >
</soap:Body>
</soap:Envelope>

<process name="MergedProductionWorkflow">
    <import />
    <partnerLinks />
    <variables />
    <sequence>

       <!-- Step 1: The process-execution layer receives a production order from 
           a client application. -->
<receive 
           name="receiveProductionOrder"
           partnerLink="productionManagementPartnerLink"
           portType="prod:ProductionManagementPortType" 
           operation="receiveProductionOrder" 
           createInstance="yes" 
           variable="productionOrder"/>

       <!-- Other steps to process the production order -->

       <!-- Response back to requesting client application-->
<reply 
           name="replyPurchaseOrder" 
           partnerLink="productionManagementPartnerLink"
           portType="prod:ProductionManagementPortType" 
           operation="receiveProductionOrder"
           variable="responseMessage" />

     </sequence>
</process>

<process name="MergedProductionWorkflow">
    <import />
    <partnerLinks />
    <variables />
    <sequence>
       <!-- Step 1: The process-execution layer receives a production order from 
           a client application. -->
       <receive />

       <!-- Step 2: The process-execution layer uses the items2BProduced Java bean
           to extract the list of items that need to be produced from the 
           production order. -->
<invoke name="getListOfProductionItems" 
          partnerLink="productionItemsListPartnerLink"
          portType="list:ProductionItemsListPortType"
          operation="getListOfProductionItems" 
          inputVariable="productionOrder"
          outputVariable="productionItems">
       </invoke>

       <!-- Other steps to process the production order -->

       <!-- Response back to requesting client application-->
       <reply />
    </sequence>
</process>

<process name="MergedProductionWorkflow">
    <import />
    <partnerLinks />
    <variables />
    <sequence>

       <!-- Step 1: The process-execution layer receives a production order from 
           a client application. -->
       <receive />

       <!-- Step 2: The process-execution layer uses the items2BProduced Java bean
           to extract the list of items that need to be produced from the 
           production order. -->
       <invoke />
       <!-- Step 3: For each item in the production order, the process-execution 
           layer uses the typeOfItem Java bean to check whether the item belongs
           to the large-variety category or the bulk-production category. -->

       <!-- Sub-step 3-1: Check how many items are in the list of items to be 
           produced -->
       <assign>
         <copy>
            <!-- Copy items size in a local variable named numberOfItems-->
            <from>
               count($productionItems.productionItems/prod:productionItem)
            </from>
            <to variable="numberOfItems"/>
         </copy>
      </assign>

      <!-- Sub-step 3-2: Run a loop to check each item in the list-->
      <while> 
        <condition>$numberOfItems > 0</condition> 
          <scope>
           <sequence> 

                <!-- Sub-step 3-3: Copy an item from the list to a local variable-->
                <assign>
                   <copy>
                       <from>$productionItems.productionItems[$numberOfItems]</from>
                       <to variable="productionItem" part="productionItem"/>
                   </copy>
                </assign>

                <!-- Sub-step 3-4: Invoke typeOfItemPartner service-->
                <invoke name="getItemType"
                    partnerLink="typeOfItemPartnerLink"
                    portType="type:ProductionItemTypePortType"
                    operation="getTypeOfProductionItem"
                    inputVariable="productionItem"
                    outputVariable="itemType">
                </invoke>

             </sequence>
             </scope>
          </condition>
       </while>

       <!-- Response back to requesting client application-->
       <reply />

    </sequence>

</process>

<process name="MergedProductionWorkflow">
    <import />
    <partnerLinks />
    <variables />
    <sequence>
       <!-- Steps 1, 2 and 3-1 go here. -->
       <!-- Sub-step 3-2: Run a loop to check each item in the list-->
       <while> <condition /> <scope /> <sequence /> 
               <!-- Sub-steps 3-3 and 3-4 go here-->
               
               <!-- Steps 4 to 9: Rest of the workflow steps. -->
                <if>
                   <condition>'LARGE_VARIETY' = $typeOfItem </condition>
                   <flow>
                      <invoke name="fetchProcessDetails"
                          partnerLink="processDetailsPartnerLink"
                          portType="prod:ProcessDetailsPortType"
                          operation="getProcessDetailsOfLargeVarietyItem" 
                          inputVariable="productionItem" 
                          outputVariable="processDetails">
                     </invoke>
                     <invoke name="issueLargeVarietyWO"
                          partnerLink="largeVarietyWOPartnerLink"
                          portType="prod:LargeVarietyWOPortType"
                          operation="issueLargeVarietyWO" 
                          inputVariable="largeVarietyWO"
                          outputVariable="workOrder">
                     </invoke>
                  </flow> 
                </if>

                <if>
                  <condition>'BULK_PRODUCTION' = $typeOfItem </condition>
                     <flow>
                       <invoke name="checkManufacturingSchedule"
                           partnerLink="manufacturingSchedulePartnerLink"
                           portType="prod:ManufacturingSchedulePortType"
                           operation="getManufacturingSchedule" 
                           inputVariable="itemID" 
                           outputVariable="manufacturingSchedule">
                       </invoke>
                       <assign> 
                           <copy> 
                              <from>
                                $productionItem.productionItem
                                /prod:productionItem/prod:itemQuantity
                              </from>
                              <to variable="itemQuantity" /> 
                            </copy> 
                       </assign> 
                       <invoke name="checkAdditionalProductionRequirement"
                            partnerLink="additionalProductionRequirementPartnerLink"
                            portType="prod:AdditionalProductionRequirementPortType"
                            operation="checkAdditionalProductionRequirement" 
                            inputVariable="bulkProdRequirement" 
                            outputVariable="itemQuantity2Produce">
                       </invoke>
                       <assign>
                          <copy>
                              <from variable="itemQuantity2Produce"
                                 part="quantity2Produce"/>
                              <to variable="qty2Produce"/>
                            </copy>
                       </assign>
                       <if>
                            <condition> $qty2Produce > 0 </condition>
                            <invoke name="reserveProduction"
                                 partnerLink="productionReservationPartnerLink"
                                 portType="prod:ProductionReservationPortType"
                                 operation="reserveProductionInCurrentMS" 
                                 inputVariable="qty2Reserve" 
                                 outputVariable="reservationResponse">
                             </invoke>
                        </if>
                        <invoke name="issueBulkProductionWO"
                             partnerLink="bulkProductionWOPartnerLink"
                             portType="prod:BulkProductionWOPortType"
                             operation="issueWorkOrderForBulkProductionItem" 
                             inputVariable="itemID" 
                             outputVariable="reservationAck">
                        </invoke>
                    </flow> 
                </if>
            </sequence> </scope> </condition> </while>
       <!-- Response back to requesting client application-->
       <reply />
    </sequence>
</process>

<deploy xmlns="http://www.apache.org/ode/schemas/dd/2007/03"
    xmlns:prod="http:// http://fictitiousManufacturingEnterprise.com/bpel"
    xmlns:sns="http://fictitiousManufacturingEnterprise.com/pms">

    <process name="prod:MergedProductionOrder">
        <provide partnerLink="productionOrderReceivingPartnerLink">
         <service name="sns:productionOrderReceivingService"
               port="productionOrderReceivingPort"/>
        </provide>

        <invoke partnerLink="items2BProducedPartnerLink">
        <service name="sns:items2BProducedService" port="items2BProducedPort"/>
        </invoke>

        <invoke partnerLink="typeOfItemPartnerLink">
        <service name="sns:typeOfItemService" port="typeOfItemPort"/>
        </invoke>

        <invoke partnerLink="processDetailsPartnerLink">
        <service name="sns:processDetailsService" port="processDetailsPort"/>
        </invoke>

        <!-- other services invoked by merged production workflow -->

    </process>
</deploy>

 
package sample.wf.;

import org.apache.axiom.om.OMAbstractFactory;
import org.apache.axiom.om.OMElement;
import org.apache.axiom.om.OMFactory;
import org.apache.axiom.om.OMNamespace;
import org.apache.axiom.om.OMText;

public class AxisAwareItems2BProduced {

    private Items2BProduced items2BProduced= null;

    public void setItems2BProduced(Items2BProduced items2BProduced) {
            this.items2BProduced = items2BProduced;
    }

    //The getListOfItems operation of Items2BProduced web service
    public OMElement getListOfItems(OMElement productionOrderOMElement) {
        //Step 1: Getting production order request data from OMElement object
        OMElement productionOrderRequest = 
            productionOrderOM.getFirstElement();

        //Step 2: Invoking the IoC bean
        OMElement itemsList = 
           factory.createOMElement(
               this.items2BProduced.getListOfItems(productionOrderRequest));

        //Step 3: Create an empty OMElement response object using a factory class 
        OMFactory Factory=
            OMAbstractFactory.getOMFactory();

        OMNamespace items2ProduceNs= factory.createOMNamespace(
           "http:// http://fictitiousManufacturingEnterprise.com/items2BProduced", 
           "productionOrder");
        OMElement responseWrapper =
           factory.createOMElement("itemsList", items2ProduceNs);

        //Step 4: Populate response object with response data
        responseWrapper.addChild(itemsList);

        //Step 5: Return response object
        return responseWrapper;
    }
}

 
<?xml version="1.0" encoding="UTF-8"?>
  <beans xmlns="http://www.springframework.org/schema/beans" ....>

  <!-- Axis-aware wrapper for items2BProduced bean -->
  <bean id="axisAwareItems2BProduced" 
      class="sample.wf.Axis.AxisAwareItems2BProduced" >
       <property name="items2BProduced" ref="items2BProduced"/>
  </bean>

  <bean id="items2BProduced" class="sample.wf.Items2BProduced" />

  <bean id="typeOfItem" class="sample.wf.TypeOfItem" />

  <!-- Other beans of task layer -->

</beans>