DSXchange

Code: Select all

*Attatch the Datastage API header with the routine
$IFNDEF JOBCONTROL
$INCLUDE DSINCLUDE JOBCONTROL.H
$ENDIF
*Initialize the Err code and Routine name
      ErrorCode = 0
      Equate RoutineName To 'ExtStat'
      ArrVar = ''
      FileHeader = "JobStartTime~JobEndTime~JobElapsedTime~StageType~StageName~LinkName~LnkRowCnt"
      Dir = "E:\TEMP"
      Suffix = ".Txt"
*Find the job & invocations and attach the handle to it
      JobHandle = DSAttachJob("B737_376_DT025_C_MAINT_GRP2_CMT_T06_P4_V1", DSJ.ERRFATAL)
      JobName = DSGetJobInfo(JobHandle,DSJ.JOBNAME)
      JobInvId = DSJobInvocationId
      If JobInvId ne "" Then
         JobName:= ".":JobInvId
      End
*Prepare the log file
      FilePath = Dir:JobName:Suffix
      Command = "TYPE nul >" : FilePath
      Call DSExecute ("NT", Command, Output, SystemReturnCode)
      If SystemReturnCode <> 0 Then
         Call DSLogFatal ("The file path for reconciliation is wrong" , RoutineName)
      End
*Get the Job Start, End and Elapsed timing
      JobStartTime = DSGetJobInfo ( JobHandle, DSJ.JOBSTARTTIMESTAMP )
      JobEndTime = DSGetJobInfo ( JobHandle, DSJ.JOBLASTTIMESTAMP )
      JobElapsedTime = DSGetJobInfo ( JobHandle, DSJ.JOBELAPSED)
*Get the list of Active and Passive stages
*      ActiveStageLst = DSGetJobInfo ( JobHandle , DSJ.STAGELIST)
*      PassiveStageLst = DSGetJobInfo ( JobHandle , DSJ.STAGELIST2 )
*      If ActiveStageLst ne "" And PassiveStageLst ne "" Then
*         StageLst = ActiveStageLst : "," : PassiveStageLst
*      End
*         Else If ActiveStageLst eq "" Then
*         StageLst = PassiveStageLst
*      End
*         Else If PassiveStageLst eq "" Then
*         StageLst = ActiveStageLst
*      End
      StageLst =  DSGetJobInfo ( JobHandle , DSJ.FULLSTAGELIST)
      StageCnt = DCount (StageLst, "," )
*Open the file and append the header
      OpenSeq FilePath to RFileVar Then
         WriteSeqF FileHeader to RFileVar
            Else Call DSLogFatal ("Write opetation failed at reconciliation file" , RoutineName)
*Find the Stage and Link for which we need to take the Count
         For CtrStg = 1 to StageCnt
            StageName = Field (StageLst, ",",CtrStg)
            StageType = DSGetStageInfo(JobHandle, StageName, DSJ.STAGETYPE)
            LinkTypeLst = DSGetStageInfo(JobHandle, StageName,DSJ.LINKTYPES)
            Call DSLogInfo ("The Stage : " : StageName : " has the following links :- " : LinkTypeLst , RoutineName)
            IsAuditStage = "_"
*Right (StageName,1)
            If IsAuditStage eq "_" Then
               LinkLst = DSGetStageInfo(JobHandle, StageName,DSJ.LINKLIST)
               LinkCnt = DCount (LinkLst,",")
               For CtrLnk = 1 to LinkCnt
                  LinkName = Field (LinkLst, ",", CtrLnk)
                  IsAuditLink = "_"
*Right (LinkName,1)
                  If IsAuditLink eq "_" Then
                     LnkRowCnt = DSGetLinkInfo (JobHandle, StageName, LinkName,DSJ.LINKROWCOUNT)
*                     Call DSLogInfo(" The Stage Name was " : StageName : "& The Link Name is " : LinkName : "& The Row count is " : LnkRowCnt, RoutineName)
                     FileLine = JobStartTime:"~":JobEndTime:"~":JobElapsedTime:"~":StageType:"~":StageName:"~":LinkName:"~":LnkRowCnt
                     WriteSeqF FileLine to RFileVar
                        Else Call DSLogFatal ("Write opetation failed at reconciliation file" , RoutineName)
                  End
               Next LinkCnt
            End
         Next CtrStg
         CloseSeq RFileVar
      End
      Else
         Call DSLogFatal ("The reconciliation file was not is a correct stage " , RoutineName)
      End
      Ans = 0