package bjepb.promng;

import bjepb.promng.DBConnhelper;
import com.softtech.jdbc.SQLResults;
import com.softtech.jdbc.SQLExecutor;
import java.util.HashMap;
import java.util.Iterator;

public class Management {

private static Management mng = null;

private static final String sqlEmp = "SELECT * FROM EMPLOYEEINFO;";
private static final String sqlExpAdd =
"INSERT INTO EMPLOYEEINFO(LOGINNAME,REALNAME,BIRTHYEAR,BIRTHMONTH,BIRTHDATE," +
"TITLE,SPECIALTY,POSITION,OFFICENUMBER,HOMENUMBER,CELLNUMBER,UNITNAME," +
"ACTIVE,ISADMIN,CANLOGIN,PASSWORD) " +
"VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?);";

private static final String sqlExpModify =
"UPDATE EMPLOYEEINFO SET REALNAME=?,BIRTHYEAR=?,BIRTHMONTH=?,BIRTHDATE=?," +
"TITLE=?,SPECIALTY=?,POSITION=?,OFFICENUMBER=?,HOMENUMBER=?,CELLNUMBER=?,UNITNAME=?," +
"ACTIVE=?,ISADMIN=?,CANLOGIN=?,PASSWORD=? where LOGINNAME=?";

private HashMap<String,Employee> employees = null;

public void PrintEmployees()
{
System.out.println("employee count : " + employees.size());

Iterator it = employees.values().iterator();

while (it.hasNext())
{
Employee employee = (Employee)it.next();
System.out.println("LoginName=[" + employee.getLoginName()
+ "] RealName=[" + employee.getRealName() + "]");
}
}

public int getEmployeesCount()
{
return employees.size();
}

private Management()
{
SQLResults rs = DBConnhelper.excute(sqlEmp);
employees = new HashMap<String,Employee>(rs.getRowCount());
Employee employee = null;
for (int i=0; i <rs.getRowCount(); i++)
{
employee = new Employee(rs.getString(i, "LOGINNAME"));
employee.setRealName(rs.getString(i, "REALNAME"));
employee.setBirthYear(rs.getInt(i, "BIRTHYEAR"));
employee.setBirthMonth(rs.getInt(i, "BIRTHMONTH"));
employee.setBirthDate(rs.getInt(i, "BIRTHDATE"));
employee.setTitle(rs.getString(i, "TITLE"));
employee.setSpecialty(rs.getString(i, "SPECIALTY"));
employee.setPosition(rs.getString(i, "POSITION"));
employee.setOfficeNumber(rs.getString(i, "OFFICENUMBER"));
employee.setHomeNumber(rs.getString(i, "HOMENUMBER"));
employee.setCellNumber(rs.getString(i, "CELLNUMBER"));
employee.setUnitName(rs.getString(i, "UNITNAME"));
employee.setActive(rs.getInt(i, "ACTIVE"));
employee.setIsAdmin(rs.getInt(i, "ISADMIN"));
employee.setCanLogin(rs.getInt(i, "CANLOGIN"));
employee.setPassword(rs.getString(i, "PASSWORD"));

employees.put(employee.getLoginName(), employee);

System.out.println(employee.getLoginName());
}

}

public synchronized static Management getManagement()
{
if (mng == null){
mng = new Management();
}
return mng;
}

public Employee getEmployee(String LoginName) throws Exception
{
Employee employee = employees.get(LoginName);
if (employee != null){
return employee;
}
else{
throw new Exception(LoginName.concat(" doesn't exist!") );
}
}

public Employee addEmployee(Employee employee) throws Exception
{
if (employees.get(employee.getLoginName()) == null){
//append to database
SQLExecutor sqlExec = DBConnhelper.getSqlExec();

sqlExec.addParam(employee.getLoginName());
sqlExec.addParam(employee.getRealName());
sqlExec.addParam(employee.getBirthYear());
sqlExec.addParam(employee.getBirthMonth());
sqlExec.addParam(employee.getBirthDate());
sqlExec.addParam(employee.getTitle());


sqlExec.addParam(employee.getSpecialty());
sqlExec.addParam(employee.getPosition());
sqlExec.addParam(employee.getOfficeNumber());
sqlExec.addParam(employee.getHomeNumber());
sqlExec.addParam(employee.getCellNumber());
sqlExec.addParam(employee.getUnitName());
sqlExec.addParam(employee.getActive());
sqlExec.addParam(employee.getIsAdmin());
sqlExec.addParam(employee.getCanLogin());
sqlExec.addParam(employee.getPassword());


sqlExec.runQuery(sqlExpAdd);

//sqlExec.runQuery(sqlExpAdd);

int numRecordUpdated = sqlExec.getNumRecordsUpdated();

sqlExec.releaseConnection();

if (numRecordUpdated== 1){
synchronized(employees){
employees.put(employee.getLoginName(),employee);
}
return employee;
}
else{
throw new Exception(employee.getLoginName().concat(" add to database error!"));
}

}
else{
throw new Exception(employee.getLoginName().concat(" is already exist!"));
}


}

public Employee modifyEmployee(Employee employee) throws Exception
{
if (employees.get(employee.getLoginName()) == null){
throw new Exception("");
}
else{
//append to database
SQLExecutor sqlExec = DBConnhelper.getSqlExec();

sqlExec.addParam(employee.getRealName());
sqlExec.addParam(employee.getBirthYear());
sqlExec.addParam(employee.getBirthMonth());
sqlExec.addParam(employee.getBirthDate());
sqlExec.addParam(employee.getTitle());
sqlExec.addParam(employee.getSpecialty());
sqlExec.addParam(employee.getPosition());
sqlExec.addParam(employee.getOfficeNumber());
sqlExec.addParam(employee.getHomeNumber());
sqlExec.addParam(employee.getCellNumber());
sqlExec.addParam(employee.getUnitName());
sqlExec.addParam(employee.getActive());
sqlExec.addParam(employee.getIsAdmin());
sqlExec.addParam(employee.getCanLogin());
sqlExec.addParam(employee.getPassword());
sqlExec.addParam(employee.getLoginName());
sqlExec.runQuery(sqlExpModify);

int numRecordUpdated = sqlExec.getNumRecordsUpdated();

sqlExec.releaseConnection();

if (numRecordUpdated== 1){
synchronized(employees){
employees.put(employee.getLoginName(),employee);
}
return employee;
}
else{
throw new Exception("");
}

}
}
}