Utility For Auto Publishing All Project Along With Monitoring Queue

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.Net;
using System.Threading;
using System.Web.Services.Protocols;
using System.Data.SqlClient;
using System.IO;
using PSLibrary = Microsoft.Office.Project.Server.Library; 

namespace AutoPublishUtility
{
    public partial class Form1 : Form
    {
        ///////////////////// DECLARE CONSTANTS//////////////////////////
        private const string PROJECTWEBSERVICE = “_vti_bin/PSI/Project.asmx”;
        private const string QUEUEWEBSERVICE = “_vti_bin/PSI/QueueSystem.asmx”;
        private string baseUrl = “http://ServerName/pwa/“;
        //Int16 PrgBarVal = 0;
        NetworkCredential myCredential = new NetworkCredential(“username”, “password”, “domain”);

        public Form1()
        {
            InitializeComponent();
        } 

        private void Form1_Load(object sender, EventArgs e)
        {
            DataSet ProjectData = new DataSet();

            //////////CREATE LOGFILE FOR LOGENTRY//////////////
            DateTime currentDateTime = DateTime.Now;
            String dateStr = currentDateTime.ToString(“yyyy_MM_dd HH_mm_ss”);
            string FilePathAndName = “C:\\ProjectServerReportingDBSync\\Log\\” + “ProjectServerAutoPublishLogEntry_” + dateStr + “.txt”;
            StreamWriter sw;
            sw = File.CreateText(FilePathAndName);
            sw.Close();                      

            ///////GETTING LIST OF ALL PROJECTS WHICH ARE NOT CALCELED OR CLOSED FROM REPORTING DB//////////
            ProjectData = GetProjectListFromSql();                       

            ///////////////////// PASSING PROJECT UID TO “PUBLISH PROJECT” METHOD FOR PUBLISHING////////

            for (int x = 0; x < ProjectData.Tables[0].Rows.Count; x++)
            {
                Guid PrjId = new Guid(ProjectData.Tables[0].Rows[x][0].ToString());
                ////////////////CHECK IF QUEUE HAS LESS THAN 5 PUBLISHING JOBS ALREADY IN QUEUE, IF YES ADD ANOTHER PROJECT TO IT ELSE SLEEP////////
                while (1==1)
                {
                    int QueueWaitTimeCounter = 0;
                    if (GetQueueStatus() < 5)
                    {
                        PublishProjects(PrjId);
                        this.statusStrip1.TabIndex = 1;
                        this.statusStrip1.Text = ” ‘” + ProjectData.Tables[0].Rows[x][1].ToString() + “‘ ” + “is Getting Processed”;

                        //////////////////// WRITE TO LOG FILE /////////////////////
                        WriteLog(ProjectData.Tables[0].Rows[x][1].ToString(),FilePathAndName);
                        QueueWaitTimeCounter = 0;
                        break;  
                    }
                    else
                    {
                        if(QueueWaitTimeCounter < 600) // CHECK WETHER QUEUE PROCESS IS NOT WAITING FOR MORE THAN 30 MIN
                        {
                            System.Threading.Thread.Sleep(3000); // 3 SECONDS SLEEP TIME
                            QueueWaitTimeCounter += 1;
                        }
                        else
                        {
                            WriteLog(“AutoPublish Utility Terminated Due to Queue Stall at time – “+DateTime.Now, FilePathAndName);
                            CloseApplication();
                        }
                    }
                }           

            }
            CloseApplication();
        }
        private DataSet GetProjectListFromSql()
        {
            /////////////////RETRIEVE ALL PROJECTS LIST WHICH ARE NOT CANCELLED AND COMPLETED
           /////////////////FROM PROJECT SERVER REPORTING DB //////////////////////////////
            this.statusStrip1.Text = “Loading Project Data……….”;
            string ConnStr = “Data Source=ServerName;Initial Catalog=ProjectServer_Reporting;User Id=usrname;Password=password”;
            SqlConnection Conn = new SqlConnection(ConnStr);
            SqlCommand Cmd = new SqlCommand(“SELECT [ProjectUID],[ProjectName],[ProjectCondition] FROM [ProjectServer_Reporting].[dbo].[MSP_EpmProject_UserView] WHERE [ProjectCondition] <> ‘Completed’ AND [ProjectCondition] <> ‘Canceled’ “);
            Cmd.Connection = Conn;
            SqlDataAdapter Da = new SqlDataAdapter(Cmd);
            DataSet Ds = new DataSet();
            Da.Fill(Ds);
            return Ds;
        }
        private void PublishProjects(Guid PrjID)
        {
            try
            {   //////////// PUSHING PROJECT TO QUEUE FOR PUBLISHING///////////////
                ProjectWebSvc.Project PrjWebSvc = new AutoPublishUtility.ProjectWebSvc.Project();
                PrjWebSvc.Url = baseUrl + PROJECTWEBSERVICE;
                //PrjWebSvc.Credentials = CredentialCache.DefaultCredentials
                //CredentialCache myCache = new CredentialCache();
                PrjWebSvc.Credentials = myCredential;
                Guid QueueJobId = Guid.NewGuid();
                PrjWebSvc.QueuePublish(QueueJobId, PrjID, false, “”);
                System.Threading.Thread.Sleep(10000);

            }
            catch (System.Web.Services.Protocols.SoapException ex)
            {
                string errMess = “”;
                PSLibrary.PSClientError error = new PSLibrary.PSClientError(ex);
                PSLibrary.PSErrorInfo[] errors = error.GetAllErrors();
                for (int j = 0; j < errors.Length; j++)
                    errMess = errMess + errors[j].ErrId.ToString() + “\n”;
                errMess = errMess + “\n” + ex.Message.ToString();
               MessageBox.Show(errMess, “Error”, MessageBoxButtons.OK, MessageBoxIcon.Error);
            }
            catch (System.Net.WebException ex)
            {
                MessageBox.Show(ex.Message.ToString(), “Logon Error”,
                    MessageBoxButtons.OK, MessageBoxIcon.Error);
            }
        }
        private void WriteLog(string PrjName, string FilePathAndName)
        { 
            StreamWriter sw;
            sw = File.AppendText(FilePathAndName);
            string ConstructStringforLogFile = PrjName + ” — “+ ” Added to Queue For Publishing at Time – ” + System.DateTime.Now.ToString() ;
            sw.WriteLine(ConstructStringforLogFile);
            sw.Close();
        }
        private int GetQueueStatus()
        {
            QueueSystemWebSvc.QueueSystem QueueSystem = new AutoPublishUtility.QueueSystemWebSvc.QueueSystem();
            QueueSystem.Url = baseUrl + QUEUEWEBSERVICE;
            QueueSystem.Credentials = myCredential;
            QueueSystemWebSvc.QueueStatusDataSet QueueDataSet = new AutoPublishUtility.QueueSystemWebSvc.QueueStatusDataSet();
            QueueDataSet = QueueSystem.ReadAllJobStatusSimple(DateTime.Today.AddDays(-1), System.DateTime.Now, 100, true, QueueSystemWebSvc.SortColumn.QueueProcessingTime, QueueSystemWebSvc.SortOrder.Ascending);
           // this.dataGridView1.DataSource = QueueDataSet.Tables[0];
            int QueueJobsPublishing = 0;
            for (int x = 0; x < QueueDataSet.Tables[0].Rows.Count; x++)
            {
                if (QueueDataSet.Tables[0].Rows[x][2].ToString() == “3”)
                {QueueJobsPublishing += 1;}
            }
            return QueueJobsPublishing;
        }
        private void CloseApplication()
        {
            this.Close();
        }
        private void button1_Click(object sender, EventArgs e)
        {
            GetQueueStatus();
        }
    }
}