package cust.report;

import java.util.*;
import java.sql.Timestamp;

import wt.viewmarkup.*;
import wt.content.*;
import wt.ownership.*;
import wt.representation.*;

import wt.queue.*;

import wt.locks.Lock;
import wt.locks.Lockable;
import wt.org.WTPrincipal;
import wt.org.WTPrincipalReference;

import wt.inf.container.*;

import wt.fc.*;
import wt.fc.WTObject;
import wt.fc.QueryResult;
import wt.fc.PersistenceHelper;
import wt.fc.PersistenceManager;

import wt.query.QuerySpec;
import wt.query.ArrayExpression;

import com.ptc.wvs.server.cadagent.*;
import com.ptc.wvs.common.ui.*;

import wt.method.RemoteMethodServer;
import wt.httpgw.GatewayAuthenticator;

import wt.util.WTException;

public class pubQue_01d {

	static String div = "\n\n************************************************************\n";

	public static void main(String[] args) throws Exception {
		RemoteMethodServer rms = RemoteMethodServer.getDefault();
		GatewayAuthenticator auth = new GatewayAuthenticator();
		auth.setRemoteUser("wcadmin");
		rms.setAuthenticator(auth);

		new pubQue_01d();
	}

	public pubQue_01d() throws Exception {

		System.out.println("\n");

		int i2 = 0;
		System.out.println("****** Processing Queues\n");
		i2 = showQueues2(wt.queue.ProcessingQueue.class, i2);
		System.out.println("****** Schedule Queues\n");
		i2 = showQueues2(wt.queue.ScheduleQueue.class, i2);

		// PublishingSummary.class	//wt.viewmarkup.PublishingSummary
		QueryResult resPS=PersistenceHelper.manager.find(new QuerySpec(PublishingSummary.class));
		while(resPS.hasMoreElements()) {

			PublishingSummary wtobj=(PublishingSummary)resPS.nextElement();

			System.out.println("UserName: "+wtobj.getUserName());
			System.out.println("Authoring Application: "+wtobj.getAuthoringApplication());

			System.out.println("Container Name: "+wtobj.getContainerName());
			System.out.println("Container: "+(WTContainer)wtobj.getContainer());
			System.out.println("Container Reference: "+(WTContainerRef)wtobj.getContainerReference());

			System.out.println("Identity: "+wtobj.getIdentity());
			System.out.println("Type: "+wtobj.getType());
			System.out.println("Type Identifier: "+wtobj.getTypeIdentifier());

			System.out.println("PersistInfo: "+(PersistInfo)wtobj.getPersistInfo());

			System.out.println("Job Success: "+(Boolean)wtobj.getJobSuccess());
			System.out.println("Job Submit Time: "+(Timestamp)wtobj.getJobSubmitTime());
			System.out.println("Job End Time: "+(Timestamp)wtobj.getJobEndTime());
			System.out.println("Job Start Time: "+(Timestamp)wtobj.getJobStartTime());
			System.out.println("Job Request Type: "+(Integer)wtobj.getJobRequestType());
			System.out.println("Job Request Source: "+(Integer)wtobj.getJobRequestSource());
			System.out.println("Job Request Queue: "+wtobj.getJobRequestQueue());

			System.out.println("Worker Type: "+wtobj.getWorkerType());
			System.out.println("Worker Name: "+wtobj.getWorkerName());
			System.out.println("Worker Success: "+(Boolean)wtobj.getWorkerSuccess());
			System.out.println("Worker End Exec Time: "+(Timestamp)wtobj.getWorkerEndExecTime());
			System.out.println("Worker End Time: "+(Timestamp)wtobj.getWorkerEndTime());
			System.out.println("Worker Start Exec Time: "+(Timestamp)wtobj.getWorkerStartExecTime());
			System.out.println("Worker Start Time: "+(Timestamp)wtobj.getWorkerStartTime());
			System.out.println("Worker Start Transfer Time: "+(Timestamp)wtobj.getWorkerStartTransferTime());

			//System.out.println("Representable: "+(ObjectReference)wtobj.getRepresentable());

			System.out.println("\n");
		}
		System.out.println("Number of PublishingSummary Objects: "+resPS.size()+div);

		// WtQueue.class
		QueryResult resWtQ=PersistenceHelper.manager.find(new QuerySpec(WtQueue.class));
		while(resWtQ.hasMoreElements()) {

			WtQueue wtobj=(WtQueue)resWtQ.nextElement();

			System.out.println("Name: "+wtobj.getName());
			System.out.println("Execution Host: "+wtobj.getExecutionHost());
			System.out.println("Queue State: "+wtobj.getQueueState());

			System.out.println("Last State Set: "+wtobj.getLastStateSet());
			System.out.println("Suspend Until: "+(Long)wtobj.getSuspendUntil());
			System.out.println("Suspend Duration: "+(Long)wtobj.getSuspendDuration());
			System.out.println("Failure Notification Email: "+wtobj.getFailureNotificationEmail());
			System.out.println("Last Notification Time: "+(Long)wtobj.getLastNotificationTime());
			System.out.println("Total Entries: "+(Integer)wtobj.getTotalEntries());
			System.out.println("Waiting Entries: "+(Integer)wtobj.getWaitingEntries());
			System.out.println("CacheName: "+wtobj.getCacheName());
			System.out.println("QType: "+wtobj.getQType());

			System.out.println("Enabled: "+(boolean)wtobj.isEnabled());
			System.out.println("Running: "+(boolean)wtobj.isRunning());
			System.out.println("Remove Failed Entires: "+(boolean)wtobj.isRemoveFailedEntires());
			System.out.println("queue Suspended: "+(boolean)wtobj.queueSuspended());

			System.out.println("\n");
			int i = 0;

			System.out.println("****** "+wtobj+"\n");
			i = showQueues2(wtobj.getQType(), i);
			System.out.println("****** Schedule Queues\n");
			i = showQueues2(wt.queue.ScheduleQueue.class, i);

			System.out.println("\n");
		}
		System.out.println("Number of WtQueue Objects: "+resWtQ.size()+div);

		// WtQueueEntry.class
		QueryResult resWtQe=PersistenceHelper.manager.find(new QuerySpec(WtQueueEntry.class));
		while(resWtQe.hasMoreElements()) {

			WtQueueEntry wtobj=(WtQueueEntry)resWtQe.nextElement();

			System.out.println("Entry Number: "+wtobj.getEntryNumber());
			System.out.println("Queue Ref: "+wtobj.getQueueRef());
			System.out.println("Entry Owner: "+wtobj.getEntryOwner());
			//System.out.println("User=Principal: "+wtobj.getPrincipal().getName());
			System.out.println("User=Principal: "+(WTPrincipal)wtobj.getPrincipal());

			System.out.println("Target method: "+wtobj.getTargetMethod());
			System.out.println("Target class: "+wtobj.getTargetClass());
			System.out.println("Status: "+wtobj.getStatusInfo().getCode());
			System.out.println("Message: "+wtobj.getStatusInfo().getMessage());
			System.out.println("Reschedule Time: "+wtobj.getStatusInfo().getRescheduleTime());
			System.out.println("Time execution started: "+wtobj.getStartExec());
			System.out.println("Time execution finished: "+wtobj.getEndExec());
			System.out.println("Display String: "+wtobj.getDisplayString());

			System.out.println("\n");
		}
		System.out.println("Number of WtQueueEntry Objects: "+resWtQe.size()+div);

		// ScheduleQueue.class
		QueryResult resSQ=PersistenceHelper.manager.find(new QuerySpec(ScheduleQueue.class));
		while(resSQ.hasMoreElements()) {

			ScheduleQueue wtobj=(ScheduleQueue)resSQ.nextElement();

			System.out.println("Name: "+wtobj.getName());
			//System.out.println("Total Entry Count: "+(Integer)wtobj.getTotalEntryCount());
			//System.out.println("Waiting Entry Count: "+(Integer)wtobj.getWaitingEntryCount());
			System.out.println("Late Entries Count: "+(int)wtobj.getLateEntriesCount());
			System.out.println("Next Process Time: "+(Timestamp)wtobj.getNextProcessTime());

			System.out.println("\n");
		}
		System.out.println("Number of ScheduleQueue Objects: "+resSQ.size()+div);

		// ScheduleQueueEntry.class
		QueryResult resSQE=PersistenceHelper.manager.find(new QuerySpec(ScheduleQueueEntry.class));
		while(resSQE.hasMoreElements()) {

			ScheduleQueueEntry wtobj=(ScheduleQueueEntry)resSQE.nextElement();

			System.out.println("Schedule Time: "+(Timestamp)wtobj.getScheduleTime());
			System.out.println("User=Principal: "+(WTPrincipal)wtobj.getPrincipal());
			System.out.println("Queue: "+(ScheduleQueue)wtobj.getQueue());
			System.out.println("Display String: "+wtobj.getDisplayString());
			System.out.println("Locked: "+(boolean)wtobj.isLocked());

			boolean tstbool = (boolean)wtobj.isLocked();

			if(tstbool) {
				System.out.println("Lock Date: "+(Timestamp)wtobj.getLockDate());
				System.out.println("Lock Note: "+wtobj.getLockNote());
				System.out.println("Locker: "+(WTPrincipalReference)wtobj.getLocker());
				System.out.println("Locker EMail: "+wtobj.getLockerEMail());
				System.out.println("Locker Name: "+wtobj.getLockerName());
				System.out.println("Locker Full Name: "+wtobj.getLockerFullName());
				System.out.println("Lock: "+(Lock)wtobj.getLock());
			}
			System.out.println("\n");
		}
		System.out.println("Number of ScheduleQueueEntry Objects: "+resSQE.size()+div);

		// QueueEntry.class
		QueryResult resQE=PersistenceHelper.manager.find(new QuerySpec(QueueEntry.class));
		while(resQE.hasMoreElements()) {

			QueueEntry wtobj=(QueueEntry)resQE.nextElement();

			System.out.println("Entry Number: "+wtobj.getEntryNumber());
			System.out.println("Queue Ref: "+wtobj.getQueueRef());
			System.out.println("Entry Owner: "+wtobj.getEntryOwner());
			//System.out.println("User=Principal: "+(WTPrincipal)wtobj.getPrincipal());
			System.out.println("User=Principal: "+wtobj.getPrincipal().getName());

			System.out.println("Target method: "+wtobj.getTargetMethod());
			System.out.println("Target class: "+wtobj.getTargetClass());
			System.out.println("Status: "+wtobj.getStatusInfo().getCode());
			System.out.println("Message: "+wtobj.getStatusInfo().getMessage());
			System.out.println("Reschedule Time: "+wtobj.getStatusInfo().getRescheduleTime());
			System.out.println("Time execution started: "+wtobj.getStartExec());
			System.out.println("Time execution finished: "+wtobj.getEndExec());

			//System.out.println("Display String: "+wtobj.getDisplayString());

			System.out.println("Processing Queue: "+(ProcessingQueue)wtobj.getQueue());
			System.out.println("Locked: "+(boolean)wtobj.isLocked());

			boolean tstbool = (boolean)wtobj.isLocked();

			if(tstbool) {
				System.out.println("Lock Date: "+(Timestamp)wtobj.getLockDate());
				System.out.println("Lock Note: "+wtobj.getLockNote());
				System.out.println("Locker: "+(WTPrincipalReference)wtobj.getLocker());
				System.out.println("Locker EMail: "+wtobj.getLockerEMail());
				System.out.println("Locker Name: "+wtobj.getLockerName());
				System.out.println("Locker Full Name: "+wtobj.getLockerFullName());
				System.out.println("Lock: "+(Lock)wtobj.getLock());
			}

			System.out.println("\n");
		}
		System.out.println("Number of QueueEntry Objects: "+resQE.size()+div);
	}

	private static int showQueues2(Class class1, int i) throws WTException {
		int j = i;
		for(Enumeration enumeration = QueueHelper.manager.queues(class1); enumeration.hasMoreElements();) {
			WtQueue wtqueue = (WtQueue)enumeration.nextElement();
			String s = isActive(class1, wtqueue);
			String s1 = wtqueue.getExecutionHost();
			String s2 = "                                   ";
			String s3 = wtqueue.getName();
			//s3 = s3.concat(s2.substring(0, 35 - s3.length()));

			if(class1 == (wt.queue.ProcessingQueue.class)) {
				long l = QueueHelper.manager.getInterval((ProcessingQueue)wtqueue);
				System.out.println(" " + ++j + ". " + s3 + " (" + s + ") execution group (" + (s1 != null ? s1 : "default") + ") interval = " + l);
			} else {
				System.out.println(" " + ++j + ". " + s3 + " (" + s + ") execution group (" + (s1 != null ? s1 : "default") + ")");
			}
		}

		System.out.println("There are no queues to show.");
		return j;
	}

    private static String isActive(Class class1, WtQueue wtqueue) {
        boolean flag;
        try {
            if(class1 == (wt.queue.ProcessingQueue.class))
                flag = QueueHelper.manager.isActive((ProcessingQueue)wtqueue);
            else
                flag = QueueHelper.manager.isActive((ScheduleQueue)wtqueue);
        }
        catch(WTException wtexception) {
            flag = false;
            wtexception.printStackTrace();
        }
        return flag ? "active" : "not active";
    }
}