consoleDM.java

package Jvakt;
/*
 * 2025-06-09 V.57 Michael Ekdal		Changed the order of the createStatement to accomodate changes in postgresql-42.7.6.jar
 * 2025-04-01 V.56 Michael Ekdal		Added variable recid
 * 2023-01-09 V.55 Michael Ekdal		Added isCheckStatusActive member.
 * 2022-07-02 V.54 Michael Ekdal		Added variable version.
 */

import javax.swing.table.*;
import java.io.*;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.*;

class consoleDM extends AbstractTableModel {

	static final long serialVersionUID = 50L;
	String afn;
	String columnNames[] = { "Id", "Prio", "Type", "CreDate", "ConDate", "Status", "Body", "Agent","RecId"};
	static Vector<consoleROW> map = new Vector<consoleROW>(100,10);

	consoleROW rad;

	int i = 0;

	static String DBUrl = "jdbc:postgresql://localhost:5433/Jvakt";
	static Connection conn = null;

	String version = "jVakt - consoleDM 2025-APR-01";
	String database = "Jvakt";
	String dbuser   = "console";
	String dbpassword = "";
	String dbhost   = "localhost";
	String dbport   = "5433";

	String jvhost   = "localhost";
	String jvport   = "1956";

	Boolean swDBopen = false; 

	static Long lhou, lmin, Lsec, Lrptdat, Lchktim, Lchktimto;
	static java.sql.Timestamp zD;
	static java.sql.Timestamp zTs;


	public consoleDM() throws IOException {

		getProps();
		if (openDB()) refreshData();

	}

	public int getColumnCount() {
		return columnNames.length;
	}

	public int getRowCount() {
		return map.size()+1;
	}

	public String getColumnName(int col) {
		return columnNames[col];
	}

	public Object getValueAt(int row, int col) {
		// se till att objektet User hämtar värdet med rätt get metod ( if (col == 2) .........

		if ( row >= map.size()) return null;

		consoleROW rad;
		rad = (consoleROW) map.get(row);

		if (col == 0) {
			return rad.getId();
		} else if (col == 1) {
			return rad.getPrio();
		} else if (col == 2) {
			return rad.getType();
		} else if (col == 3) {
			return rad.getCredat();
		} else if (col == 4) {
			return rad.getCondat();
		} else if (col == 5) {
			return rad.getStatus();
		} else if (col == 6) {
			return rad.getBody();
		} else if (col == 7) {
			return rad.getAgent();
		} else if (col == 8) {
			return rad.getRecid();
		} else {
			return null;
		}

	}

	public Class<?> getColumnClass(int c) {
		try {
			//		return getValueAt(0, c).getClass();
			return getValueAt(0, c).getClass();
		} catch (NullPointerException e) {
			return String.class;
		}
	}


	public boolean isCellEditable(int row, int col) {
		return false;
	}

	public void setValueAt(Object value, int row, int col) {
		// save the value in right field depending on the column (if (col == 2) .........
		// 	System.out.println("wD setValueAt " + value + " " + row + " "+ col);

		consoleROW rad;
		if ( row >= map.size()) { 
			rad = new consoleROW(); 
			map.add(rad); 
		}
		else rad = map.get(row);

		if (col == 0) {
			rad.setCount((Integer)value);
		} else if (col == 1) {
			rad.setId((String)value);
		} else if (col == 2) {
			rad.setPrio((Integer)value);
		} else if (col == 3) {
			rad.setType((String)value);            
		} else if (col == 4) {
			rad.setCredat((String)value);
		} else if (col == 5) {
			rad.setCondat((String)value);
		} else if (col == 6) {
			rad.setStatus((String)value);
		} else if (col == 7) {
			rad.setBody((String)value);
		} else if (col == 8) {
			rad.setAgent((String)value);
		} else if (col == 9) {
			rad.setRecid((String)value);
		}
		fireTableCellUpdated(row, col);
	}

	public boolean openDB() {

		try {

			Class.forName("org.postgresql.Driver").newInstance();
			DBUrl = "jdbc:postgresql://"+dbhost+":"+dbport+"/"+database;
			System.out.println(DBUrl);
			System.out.println("dbuser= " + dbuser +"  dbpassword "+ dbpassword);
			conn = DriverManager.getConnection(DBUrl,dbuser,dbpassword);
			conn.setAutoCommit(false);
			conn.setNetworkTimeout(null, 5000);
			swDBopen = true;
		}
		catch (SQLException e) {
			//			System.err.println(e);
			System.err.println("#e1 "+e.getMessage());
			swDBopen = false;
			map.clear();
			createEmptyRow();
		}
		catch (Exception e) {
			//			System.err.println(e);
			System.err.println("#e2 "+e.getMessage());
			swDBopen = false;
			map.clear();
			createEmptyRow();
		}
		return swDBopen;
	}

	public boolean getDBopen() {
		return swDBopen;
	}

	public boolean refreshData() {

		if (!swDBopen) {
			if (!openDB()) return false;
		}

		try {
			String s = new String("select * from console order by credat desc;"); 
//						System.out.println(s);
//			System.out.println(ResultSet.CONCUR_READ_ONLY+" "+ResultSet.TYPE_FORWARD_ONLY+" "+ResultSet.CLOSE_CURSORS_AT_COMMIT);
			//			Statement stmt = conn.createStatement(ResultSet.CONCUR_READ_ONLY,ResultSet.TYPE_SCROLL_INSENSITIVE); 
			//			Statement stmt = conn.createStatement(ResultSet.CONCUR_UPDATABLE,ResultSet.TYPE_FORWARD_ONLY,ResultSet.CLOSE_CURSORS_AT_COMMIT ); 
			Statement stmt = conn.createStatement(ResultSet.TYPE_FORWARD_ONLY,ResultSet.CONCUR_READ_ONLY,ResultSet.CLOSE_CURSORS_AT_COMMIT ); 
			stmt.setFetchSize(25);
			stmt.setQueryTimeout(5);
			
			ResultSet rs = stmt.executeQuery(s);

			map.clear();

			while (rs.next()) {
//								System.out.println("rs.next");
				rad = new consoleROW();

				rad.setCount(rs.getInt("count"));
				rad.setId(rs.getString("id"));
				rad.setPrio(rs.getInt("prio"));
				rad.setType(rs.getString("type"));
				rad.setCredat(rs.getString("credat"));
				rad.setCondat(rs.getString("condat"));
				rad.setStatus(rs.getString("status"));
				rad.setBody(rs.getString("body"));
				rad.setAgent(rs.getString("agent"));
				rad.setRecid(rs.getString("recid"));

				map.add(rad);
			}

			rs.close(); 
			stmt.close();
			//		fireTableDataChanged();
		}
		catch (SQLException e) {
			System.err.println(e);
			System.err.println("#C1 "+e.getMessage());
			swDBopen = false;
			createEmptyRow();
			return false;
		}
		catch (Exception e) {
			System.err.println(e);
			System.err.println("#C2 "+e.getMessage());
			swDBopen = false;
			createEmptyRow();
			return false;
		}
		return true;
	}

	private boolean createEmptyRow() {

		rad = new consoleROW();

		rad.setCount(0);
		rad.setId("**<>**");
		rad.setPrio(0);
		rad.setType(" ");
		rad.setCredat(" ");
		rad.setCondat(" ");
		rad.setStatus(" ");
		rad.setBody(" ");
		rad.setAgent(" ");
		rad.setRecid(null);

		return true;	
	}

	public boolean closeDB() {

		try {
			if (swDBopen) 	conn.close();
		}
		catch (SQLException e) {
			System.err.println(e);
			System.err.println(e.getMessage());
			return true;
		}
		return true;
	}

	void getProps() {

		Properties prop = new Properties();
		InputStream input = null;
		try {
			input = new FileInputStream("console.properties");
			prop.load(input);
			// get the property value and print it out
			database = prop.getProperty("database");
			dbuser   = prop.getProperty("dbuser");
			dbpassword = prop.getProperty("dbpassword");
			if (dbpassword.startsWith("==y")) {
				byte[] decodedBytes = Base64.getDecoder().decode(dbpassword.substring(3));
				String decodedString = new String(decodedBytes);
				dbpassword=decodedString;
			}
			dbhost   = prop.getProperty("dbhost");
			dbport   = prop.getProperty("dbport");
			jvport   = prop.getProperty("jvport");
			jvhost   = prop.getProperty("jvhost");
			input.close();
		} catch (IOException ex) {
			// ex.printStackTrace();
		}

	}

	public boolean isCheckStatusActive() {

		boolean statusRC = false; 

		if (!swDBopen) {
			if (!openDB()) return false;
		}

		try {
			String s = new String("select * from status WHERE (state='A' or state = 'D') and id='Jvakt-CheckStatus';"); 

			Statement stmt = conn.createStatement(ResultSet.TYPE_FORWARD_ONLY,ResultSet.CONCUR_READ_ONLY,ResultSet.CLOSE_CURSORS_AT_COMMIT ); 
			stmt.setFetchSize(10);
			stmt.setQueryTimeout(5); 
			ResultSet rs = stmt.executeQuery(s);

			zTs = new java.sql.Timestamp((new Date(System.currentTimeMillis())).getTime());  // YYYY-MM-DD hh:mm.ss.nnn.  now

			//				System.out.println("Last RS: "+statusRC) ; 
			//				System.out.println("Getrow RS: "+rs.getRow()) ; 
			//				System.out.println("zTs: "+zTs) ;
			statusRC=false;
			Lsec = new Long(0);
			while (rs.next()) {
				statusRC=true;
				zD = rs.getTimestamp("rptdat");
				Lsec = (zTs.getTime() / 1000 - zD.getTime() / 1000);  // Actual time minus the time rptdat in seconds  
				//					System.out.println("Lsec: "+Lsec) ;
			}
			if ( Lsec > 1200 ) statusRC = false;    // false when mire than 20 minutes has passed since the Jvakt-CheckStatus was updated

			rs.close(); 
			stmt.close();
		}
		catch (SQLException e) {
			System.err.println(e);
			System.err.println(e.getMessage());
			swDBopen = false;
		}
		catch (Exception e) {
			System.err.println(e);
			System.err.println(e.getMessage());
		}
		return statusRC;
	}

}