
	<!--
		ProcessCollecte BPEL Process [Generated by the Eclipse BPEL Designer]
	-->
	<!-- Date: Wed Jun 03 15:56:55 CEST 2009 -->

<bpel:process name="I_ProcessCollecte" targetNamespace="http://process.collecte.architecture.cnav.fr/"
	suppressJoinFailure="yes" xmlns:tns="http://process.collecte.architecture.cnav.fr/"
	xmlns:bpel="http://docs.oasis-open.org/wsbpel/2.0/process/executable"
	xmlns:wsdl1="http://collecte.architecture.cnav.fr/" 
	xmlns:wsdl2="http://suivi.architecture.cnav.fr/" 
	xmlns:wsdl3="http://generation.architecture.cnav.fr/" 
	xmlns:wsdl4="http://notif.architecture.cnav.fr/" >
	<!-- Import the client WSDL -->
    <bpel:import location="ProcessCollecteArtifacts.wsdl"
		namespace="http://process.collecte.architecture.cnav.fr/" 
		importType="http://schemas.xmlsoap.org/wsdl/" />

	<!--
		=================================================================
	-->
	<!--
		PARTNERLINKS
	-->
	<!--
		List of services participating in this BPEL process
	-->
	<!--
		=================================================================
	-->
	<bpel:partnerLinks>
		<!--
			The 'client' role represents the requester of this service. It is
			used for callback. The location and correlation information
			associated with the client role are automatically set using
			WS-Addressing.
		-->
		<bpel:partnerLink name="client" partnerLinkType="tns:ProcessCollecte"
			myRole="ProcessCollecteProvider" partnerRole="ProcessCollecteRequester" />
		<bpel:partnerLink name="cnav" partnerLinkType="tns:cnav"
			partnerRole="cnav"></bpel:partnerLink>
		<bpel:partnerLink name="msa" partnerLinkType="tns:msa"
			partnerRole="msa"></bpel:partnerLink>
		<bpel:partnerLink name="probtp" partnerLinkType="tns:probtp"
			partnerRole="probtp"></bpel:partnerLink>
		<bpel:partnerLink name="majSuivi" partnerLinkType="tns:majSuivi"
			partnerRole="majSuivi"></bpel:partnerLink>
        <bpel:partnerLink name="docNS4" partnerLinkType="tns:docNS4"
			partnerRole="docNS4"></bpel:partnerLink>
        <bpel:partnerLink name="notifRetard" partnerLinkType="tns:notifRetard"
			partnerRole="notifRetard"></bpel:partnerLink>
        
    </bpel:partnerLinks>

	<!--
		=================================================================
	-->
	<!--
		VARIABLES
	-->
	<!--
		List of messages and XML documents used within this BPEL process
	-->
	<!--
		=================================================================
	-->
	<bpel:variables>
		<!-- Reference to the message passed as input during initiation -->
		<bpel:variable name="input" messageType="tns:ProcessCollecteRequestMessage" />

		<!--
			Reference to the message that will be sent back to the requester
			during callback
		-->

		<bpel:variable name="cnavResponse" messageType="wsdl1:collecteRegimeResponse"></bpel:variable>
		<bpel:variable name="cnavRequest" messageType="wsdl1:collecteRegime"></bpel:variable>
		<bpel:variable name="msaResponse" messageType="wsdl1:collecteRegimeResponse"></bpel:variable>
		<bpel:variable name="msaRequest" messageType="wsdl1:collecteRegime"></bpel:variable>
		<bpel:variable name="probtpResponse" messageType="wsdl1:collecteRegimeResponse"></bpel:variable>
		<bpel:variable name="probtpRequest" messageType="wsdl1:collecteRegime"></bpel:variable>
		
		
        <bpel:variable name="majSuiviResponse" messageType="wsdl2:miseAJourSuiviCollecteResponse"></bpel:variable>
        <bpel:variable name="majSuiviRequest" messageType="wsdl2:miseAJourSuiviCollecte"></bpel:variable>
        <bpel:variable name="docNS4Response" messageType="wsdl3:constitutionNS4Response"></bpel:variable>
        <bpel:variable name="docNS4Request" messageType="wsdl3:constitutionNS4"></bpel:variable>
        <bpel:variable name="notifRetardResponse" messageType="wsdl4:notificationRetardResponse"></bpel:variable>
        <bpel:variable name="notifRetardRequest" messageType="wsdl4:notificationRetard"></bpel:variable>
    </bpel:variables>

	<!--
		=================================================================
	-->
	<!--
		ORCHESTRATION LOGIC
	-->
	<!--
		Set of activities coordinating the flow of messages across the
	-->
	<!--
		services integrated within this business process
	-->
	<!--
		=================================================================
	-->

    <bpel:sequence name="main">
    	<!--
			Receive input from requestor. Note: This maps to operation defined in
			ProcessCollecte.wsdl
		-->
		<bpel:receive name="receiveInput" partnerLink="client" createInstance="yes" operation="process" portType="tns:I_ProcessCollecte" variable="input" />

		<!--
			Asynchronous callback to the requester. Note: the callback location
			and correlation id is transparently handled using WS-addressing.
		-->
		<bpel:assign validate="no" name="AssignEPR">
			<bpel:copy>
				<bpel:from>
					<bpel:literal>
						<sref:service-ref xmlns:sref="http://docs.oasis-open.org/wsbpel/2.0/serviceref">
							<wsa:EndpointReference xmlns:wsa="http://www.w3.org/2005/08/addressing">
								<wsa:Address>ServiceActiviteCollectePartenaire1EJBEndpoint
								</wsa:Address>
							</wsa:EndpointReference>
						</sref:service-ref>
					</bpel:literal>
				</bpel:from>
				<bpel:to partnerLink="cnav"></bpel:to>
			</bpel:copy>
			<bpel:copy>
				<bpel:from>
					<bpel:literal>
						<sref:service-ref xmlns:sref="http://docs.oasis-open.org/wsbpel/2.0/serviceref">
							<wsa:EndpointReference xmlns:wsa="http://www.w3.org/2005/08/addressing">
								<wsa:Address>ServiceActiviteCollectePartenaire2EJBEndpoint
								</wsa:Address>
							</wsa:EndpointReference>
						</sref:service-ref>
					</bpel:literal>
				</bpel:from>
				<bpel:to partnerLink="msa"></bpel:to>
			</bpel:copy>
			<bpel:copy>
				<bpel:from>
					<bpel:literal>
						<sref:service-ref xmlns:sref="http://docs.oasis-open.org/wsbpel/2.0/serviceref">
							<wsa:EndpointReference xmlns:wsa="http://www.w3.org/2005/08/addressing">
								<wsa:Address>ServiceActiviteCollectePartenaire3EJBEndpoint
								</wsa:Address>
							</wsa:EndpointReference>
						</sref:service-ref>
					</bpel:literal>
				</bpel:from>
				<bpel:to partnerLink="probtp"></bpel:to>
			</bpel:copy>
		</bpel:assign>

  		<bpel:assign validate="no" name="InitRequests">
            <bpel:copy>
                <bpel:from>
                    <bpel:literal xml:space="preserve">
		      <tns:miseAJourSuiviCollecte xmlns:tns="http://suivi.architecture.cnav.fr/" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
			<arg0 />
			<arg1 />
			<arg1 />
			<arg1 />
		      </tns:miseAJourSuiviCollecte>
		    </bpel:literal>
                </bpel:from>
                <bpel:to variable="majSuiviRequest" part="parameters"></bpel:to>
            </bpel:copy>
            <bpel:copy>
                <bpel:from>
                    <bpel:literal xml:space="preserve">
		      <tns:constitutionNS4 xmlns:tns="http://generation.architecture.cnav.fr/" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:type="tns:constitutionNS4">
			<arg0 />
			<arg1 />
			<arg1 />
			<arg1 />
		      </tns:constitutionNS4>
		    </bpel:literal>
                </bpel:from>
                <bpel:to variable="docNS4Request" part="parameters"></bpel:to>
            </bpel:copy>
            <bpel:copy>
                <bpel:from>
                    <bpel:literal xml:space="preserve">
		      <tns:notificationRetard xmlns:tns="http://notif.architecture.cnav.fr/" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:type="tns:notificationRetard">
			<arg0 />
			<arg1 />
			<arg1 />
			<arg1 />
		      </tns:notificationRetard>
		    </bpel:literal>
                </bpel:from>
                <bpel:to variable="notifRetardRequest" part="parameters"></bpel:to>
            </bpel:copy>
        </bpel:assign>
       

		<!-- Flow appelle Collectes ====================================================================== -->
       <bpel:flow name="Flow">

			<!-- CNAV Sequence=============================================================================-->

			<bpel:sequence name="SequenceCNAV">
				<bpel:forEach parallel="no" counterName="Counter" name="PourChaqueRegimeDeLaListe">
					<bpel:startCounterValue><![CDATA[1]]></bpel:startCounterValue>
					<bpel:finalCounterValue><![CDATA[count($input.payload/msgDepotCollecte/listeRegimes)]]></bpel:finalCounterValue>
					<bpel:scope>
						<bpel:if name="If collecte CNAV">
							<bpel:condition><![CDATA[$input.payload/msgDepotCollecte/listeRegimes[$Counter]="CNAV"]]></bpel:condition>
							<bpel:sequence>

								<bpel:assign validate="no" name="AssignCNAV">
									
                                  
                                    <bpel:copy>
                                        <bpel:from part="payload" variable="input">
                                            <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[msgDepotCollecte]]></bpel:query>
                                        </bpel:from>
                                        <bpel:to part="parameters" variable="cnavRequest">
                                            <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[arg0]]></bpel:query>
                                        </bpel:to>
                                    </bpel:copy>
                                </bpel:assign>
				<bpel:invoke name="InvokeCollecteCNAV" partnerLink="cnav" operation="collecteRegime" inputVariable="cnavRequest" outputVariable="cnavResponse"></bpel:invoke>
				
				<!--
				<bpel:if name="If returnCode">
					<bpel:condition><![CDATA[count($cnavResponse.parameters/return/codeRetour) = 0]]></bpel:condition>
					<bpel:sequence name="failed -&gt; retry after 5sec">
						<bpel:wait name="Wait">
							<bpel:for><![CDATA['PT5S']]></bpel:for>
						</bpel:wait>
						<bpel:invoke name="RetryCollecteCNAV" partnerLink="cnav" operation="collecteRegime" inputVariable="cnavRequest" outputVariable="cnavResponse"></bpel:invoke>
					</bpel:sequence>
			      </bpel:if>
			      -->
			      <bpel:assign validate="no" name="AssignCollecteCNAVResult"><bpel:copy>
                                        <bpel:from part="parameters" variable="cnavResponse">
                                            <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[return]]></bpel:query>
                                        </bpel:from>
                                        <bpel:to part="parameters" variable="majSuiviRequest">
                                            <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0">
                                                <![CDATA[arg1[1]]]>
                                            </bpel:query>
                                        </bpel:to>
                                    </bpel:copy>
                                
                                    <bpel:copy>
                                        <bpel:from part="parameters" variable="cnavResponse">
                                            <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[return]]></bpel:query>
                                        </bpel:from>
                                        <bpel:to part="parameters" variable="docNS4Request">
						<bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0">
                                                <![CDATA[arg1[1]]]>
                                            </bpel:query>
					</bpel:to>
                                    </bpel:copy>
                                    <bpel:copy>
                                        <bpel:from part="parameters" variable="cnavResponse">
                                            <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[return]]></bpel:query>
                                        </bpel:from>
                                        <bpel:to part="parameters" variable="notifRetardRequest">
						<bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0">
                                                <![CDATA[arg1[1]]]>
                                            </bpel:query>
					</bpel:to>
                                    </bpel:copy>

                                </bpel:assign>
                                
                                
                            </bpel:sequence>
						</bpel:if>
					</bpel:scope>
				</bpel:forEach>
			</bpel:sequence>

			<!-- fin CNAV Sequence=========================================================================-->


			<!-- MSA  Sequence=============================================================================-->
			
			<bpel:sequence name="SequenceMSA">
				<bpel:forEach parallel="no" counterName="Counter" name="PourChaqueRegimeDeLaListeMSA">
					<bpel:startCounterValue><![CDATA[1]]></bpel:startCounterValue>
					<bpel:finalCounterValue><![CDATA[count($input.payload/msgDepotCollecte/listeRegimes)]]></bpel:finalCounterValue>
					<bpel:scope>
						<bpel:if name="If collecte MSA">
							<bpel:condition><![CDATA[$input.payload/msgDepotCollecte/listeRegimes[$Counter]="MSA"]]></bpel:condition>
							<bpel:sequence>

								<bpel:assign validate="no" name="AssignMSA">
									<bpel:copy>
                                        <bpel:from part="payload" variable="input">
                                            <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[msgDepotCollecte]]></bpel:query>
					</bpel:from>
                                        <bpel:to part="parameters" variable="msaRequest">
                                            <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[arg0]]></bpel:query>
                                        </bpel:to>
                                    </bpel:copy>
                                </bpel:assign>
								<bpel:invoke name="InvokeCollecteMSA" partnerLink="msa" operation="collecteRegime" inputVariable="msaRequest" outputVariable="msaResponse"></bpel:invoke>
								<!--  
								<bpel:if name="If returnCode">
									<bpel:condition><![CDATA[$msaResponse.parameters/return/codeRetour="2"]]></bpel:condition>

									<bpel:sequence name="failed -&gt; retry after 5sec">
										<bpel:wait name="Wait">
											<bpel:for><![CDATA['PT5S']]></bpel:for>
										</bpel:wait>
										<bpel:invoke name="RetryCollecteMSA" partnerLink="msa" operation="collecteRegime" inputVariable="msaRequest" outputVariable="msaResponse"></bpel:invoke>
									</bpel:sequence>
						       </bpel:if>
						       -->
			      <bpel:assign validate="no" name="AssignCollecteMSAResult"><bpel:copy>
                                        <bpel:from part="parameters" variable="msaResponse">
                                            <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[return]]></bpel:query>
                                        </bpel:from>
                                        <bpel:to part="parameters" variable="majSuiviRequest">
                                            <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0">
                                                <![CDATA[arg1[2]]]>
                                            </bpel:query>
                                        </bpel:to>
                                    </bpel:copy>
                                      <bpel:copy>
                                        <bpel:from part="parameters" variable="msaResponse">
                                            <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[return]]></bpel:query>
                                        </bpel:from>
                                        <bpel:to part="parameters" variable="docNS4Request">
						<bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0">
                                                <![CDATA[arg1[2]]]>
                                            </bpel:query>
					</bpel:to>
                                    </bpel:copy>
                                    <bpel:copy>
                                        <bpel:from part="parameters" variable="msaResponse">
                                            <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[return]]></bpel:query>
                                        </bpel:from>
                                        <bpel:to part="parameters" variable="notifRetardRequest">
						<bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0">
                                                <![CDATA[arg1[2]]]>
                                            </bpel:query>
					</bpel:to>
                                    </bpel:copy>

        </bpel:assign>
                        
                                
                            </bpel:sequence>
						</bpel:if>
					</bpel:scope>
				</bpel:forEach>
			</bpel:sequence>

			<!-- fin MSA SequenceSequence====================================================================-->


			<!-- PROBTP SequenceSequence======================================================================-->

			<bpel:sequence name="SequencePROBTP">
				<bpel:forEach parallel="no" counterName="Counter" name="PourChaqueRegimeDeLaListe">
					<bpel:startCounterValue><![CDATA[1]]></bpel:startCounterValue>
					<bpel:finalCounterValue><![CDATA[count($input.payload/msgDepotCollecte/listeRegimes)]]></bpel:finalCounterValue>
					<bpel:scope>
						<bpel:if name="If collecte PROBTP">
							<bpel:condition><![CDATA[$input.payload/msgDepotCollecte/listeRegimes[$Counter]="PROBTP"]]></bpel:condition>
							<bpel:sequence>

								<bpel:assign validate="no" name="AssignPROBTP">
									
                                  
                                    <bpel:copy>
                                        <bpel:from part="payload" variable="input">
                                            <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[msgDepotCollecte]]></bpel:query>
					</bpel:from>
                                        <bpel:to part="parameters" variable="probtpRequest">
                                            <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[arg0]]></bpel:query>
                                        </bpel:to>
                                    </bpel:copy>
                                </bpel:assign>
				<bpel:invoke name="InvokeCollectePROBTP" partnerLink="probtp" operation="collecteRegime" inputVariable="probtpRequest" outputVariable="probtpResponse"></bpel:invoke>
				<!--  
				<bpel:if name="If returnCode">
					<bpel:condition><![CDATA[$probtpResponse.parameters/return/codeRetour="2"]]></bpel:condition>

					<bpel:sequence name="failed -&gt; retry after 5sec">
						<bpel:wait name="Wait">
							<bpel:for><![CDATA['PT5S']]></bpel:for>
						</bpel:wait>
						<bpel:invoke name="RetryCollectePROBTP" partnerLink="probtp" operation="collecteRegime" inputVariable="probtpRequest" outputVariable="probtpResponse"></bpel:invoke>
					</bpel:sequence>


                                </bpel:if>
                                -->
			      <bpel:assign validate="no" name="AssignCollectePROBTPResult"><bpel:copy>
                                        <bpel:from part="parameters" variable="probtpResponse">
                                            <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[return]]></bpel:query>
                                        </bpel:from>
                                        <bpel:to part="parameters" variable="majSuiviRequest">
                                            <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0">
                                                <![CDATA[arg1[3]]]>
                                            </bpel:query>
                                        </bpel:to>
                                    </bpel:copy>
                                     <bpel:copy>
                                        <bpel:from part="parameters" variable="probtpResponse">
                                            <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[return]]></bpel:query>
                                        </bpel:from>
                                        <bpel:to part="parameters" variable="docNS4Request">
						<bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0">
                                                <![CDATA[arg1[3]]]>
                                            </bpel:query>
					</bpel:to>
                                    </bpel:copy>
                                    <bpel:copy>
                                        <bpel:from part="parameters" variable="probtpResponse">
                                            <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[return]]></bpel:query>
                                        </bpel:from>
                                        <bpel:to part="parameters" variable="notifRetardRequest">
						<bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0">
                                                <![CDATA[arg1[3]]]>
                                            </bpel:query>
					</bpel:to>
                                    </bpel:copy>

			    </bpel:assign>
                                
                                
                            </bpel:sequence>
						</bpel:if>
					</bpel:scope>
				</bpel:forEach>
			</bpel:sequence>
			<!-- fin MSA SequenceSequence=======================================================================-->


		</bpel:flow>
		<!-- fin Flow appelle Collectes Sequence==================================================================-->
	
		
	<!-- Appel de MajSuiviSequence================================================================================-->
        
	<bpel:assign validate="no" name="AssignMessageDepotCollectionSurMajSuivi">
            <bpel:copy>
                <bpel:from part="payload" variable="input">
                                            <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[msgDepotCollecte]]></bpel:query>
		</bpel:from>
                <bpel:to part="parameters" variable="majSuiviRequest">
                    <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[arg0]]></bpel:query>
                </bpel:to>
            </bpel:copy>
        </bpel:assign>
        <bpel:invoke name="InvokeMajSuivi" partnerLink="majSuivi" operation="miseAJourSuiviCollecte" portType="ns:I_ServiceMAJSuiviPortType" inputVariable="majSuiviRequest" outputVariable="majSuiviResponse"></bpel:invoke>


	<!-- Fin process : construction du Doc ou notif retardSequence===================================================================-->
        
        <bpel:if name="If Toutes Les Collectes sont OK">
            <bpel:condition><![CDATA[$cnavResponse.parameters/return/codeRetour="1" and $msaResponse.parameters/return/codeRetour="1" and $probtpResponse.parameters/return/codeRetour="1"]]></bpel:condition>
            <bpel:sequence name="ConstitionDocNSV4">
                <bpel:assign validate="no" name="AssignDocNS4">
                    <bpel:copy>
                        <bpel:from part="payload" variable="input">
                                            <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[msgDepotCollecte]]></bpel:query>
			</bpel:from>
                        <bpel:to part="parameters" variable="docNS4Request">
                            <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[arg0]]></bpel:query>
                        </bpel:to>
                    </bpel:copy>
                </bpel:assign>
                <bpel:invoke name="InvokeDocNS4" partnerLink="docNS4" operation="constitutionNS4" inputVariable="docNS4Request" outputVariable="docNS4Response"></bpel:invoke>
            </bpel:sequence>
            <bpel:else>
                <bpel:sequence name="NotificationRetard">
                    <bpel:assign validate="no" name="AssignNotifRetard">
                        <bpel:copy>
                            <bpel:from part="payload" variable="input">
                                            <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[msgDepotCollecte]]></bpel:query>
			    </bpel:from>
                            <bpel:to part="parameters" variable="notifRetardRequest">
                                <bpel:query queryLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath1.0"><![CDATA[arg0]]></bpel:query>
                            </bpel:to>
                        </bpel:copy>
                    </bpel:assign>
                    <bpel:invoke name="InvokeNotifRetard" partnerLink="notifRetard" operation="notificationRetard" inputVariable="notifRetardRequest" outputVariable="notifRetardResponse"></bpel:invoke>
                </bpel:sequence>
            </bpel:else>
        </bpel:if>
    
    </bpel:sequence>
    
    
</bpel:process>