#include vhLib.Macro

vhROLLBACK 	;ROLLBACK ULITIY
        
Begin    
        ; -- Init Vars--------
        do INIT^vhTERMINA
        
        N JrnFile,ProcessId                     
        N AdrFirst,AdrLast
        N Result
        N Namespace set Namespace = $$$NSpace
        
         
        ; -- Declar Vars-----------
        S JrnFile=$$GetJrnFile                                   ; Get Journal File
        G:'##class(TECH.File).Exists(JrnFile) End 
         
        R "ProcessId ? ",ProcessId,!
        
        R "First Address : ",AdrFirst,!
        G:'$L(AdrFirst) End                                      ; Quit if not given
         
        R "Last Address  : ",AdrLast,! 				             ; Get Last Address
        G:'$L(AdrLast) End                                       ; Quit if not given
       
       	ZN "%SYS"                                                ; Default %SYS Namespace
         
        Set oRefJournalFile = ##class(%SYS.Journal.File).%OpenId(JrnFile)
        
        if AdrFirst<AdrLast {
	        do PcsRollForward(oRefJournalFile,ProcessId,AdrFirst,AdrLast)
        }
        else { 
        	do PcsRollBack(oRefJournalFile,ProcessId,AdrFirst,AdrLast)  
        }              ; Start Rollback Processing
        
        zn Namespace
         
End     Q
         
        ; ** FUNCTIONS & PROCEDURES *******************************************************************************
        ;-- Get Journal File ----
GetJrnFile()
        N JrnFile,JrnFiles,IdxFile
        N Path
                
        S JrnFile="",Path=##class(%SYS.Journal.System).GetPrimaryDirectory()
        S JrnFile = $$DISPDIR^vhDEV(Path,"*.0*")
         
        Q ##class(TECH.Files).AppendFile(Path,JrnFile)                                              ;  Quit FileName)
         
         
        ; -- Rollback Processing ----  
PcsRollBack(JrnFile,ProcessId,AdrLast,AdrFirst)
        N AdrCurr,JrnInfo,Result
        N Global,Value
        S AdrCurr=AdrLast
        S Result=1        
         
        S $ZT="ErrPcsRollback"
         
        TSTART                                                   ; Start Transaction
       
        for  {   
        	Set Record = JrnFile.GetRecordAt(AdrCurr)
        	If (Record.ProcessID=ProcessId) || ('$L(ProcessId)) {
        		if Record.%IsA("%SYS.Journal.SetKillRecord") {
        			#dim Record As %SYS.Journal.SetKillRecord
        			set Global = Record.GlobalReference
        			if Global["KlantDocument"{
        				set OldValue = Record.OldValue
        				if ##class(%Library.JournalRecordType).LogicalToDisplay(Record.Type)="SET" set @Global=OldValue W !,"undo Set"
        				if ##class(%Library.JournalRecordType).LogicalToDisplay(Record.Type)="KILL" set @Global=OldValue W !,"undo Kill"
        			}
        		}
        	}
        	
        	S AdrCurr=Record.PrevAddress
        	quit:AdrCurr<AdrFirst
        }
        I $TL TCOMMIT                                            ; Commit Transaction if one is started
        Q

        ; -- RollForward Processing ----  
PcsRollForward(JrnFile,ProcessId,AdrFirst,AdrLast)
        N AdrCurr,JrnInfo,Result
        N Global,Value
        S Result=1        
         
        set AdrCurr = AdrFirst
        S $ZT="ErrPcsRollback"
         
        TSTART                                                   ; Start Transaction
        
        s fn="e:\code.txt"
        o fn:"wns"
        u fn
        for  {   
        	Set Record = JrnFile.GetRecordAt(AdrCurr)
        	If (Record.ProcessID[ProcessId) || ('$L(ProcessId)) {
        		if Record.%IsA("%SYS.Journal.SetKillRecord") {
        			#dim Record As %SYS.Journal.SetKillRecord
        			set Global = Record.GlobalReference
        			if Global["KlantDocumentService" {
        				set Value = Record.NewValue
        				if ##class(%Library.JournalRecordType).LogicalToDisplay(Record.Type)="SET" {
	        				W !,Value
	        				;set @Global=Value 
        				}
        				if ##class(%Library.JournalRecordType).LogicalToDisplay(Record.Type)="KILL" {
	        				;W !,"Kill"_Global
	        				;Kill @Global 
        				}
        			}
        		}
        	}
        	
        	S AdrCurr=Record.NextAddress
        	quit:AdrCurr>AdrLast 
        }
        
        c fn
        
        I $TL TCOMMIT                                            ; Commit Transaction if one is started
        Q


                       
ErrPcsRollback
        S $ZT="" 
        zn Namespace
        D ShowMessage($ZE) TROLLBACK
        Q                        


ShowMessage(Warning)
		zn Namespace
		D Boodschap^vhTXTPOP(Warning)
		zn "%SYS"
		Quit