AppointmentEditor.java

Go to the documentation of this file.

import java.util.Vector;
import java.sql.SQLException;
import java.text.SimpleDateFormat;
import java.sql.PreparedStatement;
import java.util.Set;
import java.util.Iterator;
import java.util.Calendar;

public class AppointmentEditor extends Widget
{ 
        public static final int FIND_DOC = 1;
        public static final int FIND_PATIENT = 2;
        public static final int SAVE = 3;
        public static final int CANCEL = 4;
        
        public int appointment_id;
        public TextBox begintime;
        public TextBox endtime;
        public ActionButton action;
        public boolean done = false;
        public PatientSelect patient;
        public DoctorSelect doctor;
        public DiagnosisList diagnoses;
        public ReferralList referrals;
        public ServicesSelect services;
        
        
        public boolean showErrors = false;
        public Vector errors = new Vector();
        
        public AppointmentEditor(int appointment_id, String prefix, Form form)
        {
          super(prefix, form);
          this.appointment_id = appointment_id;
    action = new ActionButton(n("action"), form);
    begintime = new TextBox(0,20,n("begintime"), form);
    endtime = new TextBox(0,20,n("endtime"), form);
    diagnoses = new DiagnosisList(n("diagnoses"), form);
    referrals = new ReferralList(n("referrals"), form);
    services = new ServicesSelect(n("services"), form);
    doctor = new DoctorSelect(DoctorDb.PRACTICE_ID, 1, n("doctor"), form);
    patient = new PatientSelect(n("patient"), form);
    addChild(action);
    addChild(begintime);
    addChild(endtime);
    addChild(diagnoses);
    addChild(services);
    addChild(doctor);
    addChild(patient);
    addChild(referrals);
        }
        
        public void loadValues()
        {
    super.loadValues();
    
    if (action.action == SAVE)
    {
      showErrors = true;
      if (save()) done = true;
    }
    else if (action.action == CANCEL)
    {
      done = true;
    }
        }
        
        public void loadDefaults()
        {
          super.loadDefaults();
          Query q = new Query(form.connectDb(), form.pw);
          try
          {
            q.query("SELECT begintime, endtime, doctor_id, patient_id FROM appointments WHERE appointment_id = " + appointment_id);
            if (q.r == null || !q.r.next()) return;
      begintime.text = q.r.getString(1);
      endtime.text = q.r.getString(2);
      doctor.id = new Integer(q.r.getInt(3));
      patient.id = new Integer(q.r.getInt(4));

            q.query("SELECT referral_id, type, doctor_id FROM referrals WHERE appointment_id = " + appointment_id);
            if (q != null)
            while(q.r.next())
            {
              Referral r = new Referral();
              r.referral_id = q.r.getInt(1);
              r.incoming = q.r.getInt(2) == 2;
              r.doctor_id = q.r.getInt(3);
              referrals.referrals.add(r);
            }
            
            q.query("SELECT diagnosis_id, name, description FROM diagnoses WHERE appointment_id = " + appointment_id);
            if (q != null)
            while(q.r.next())
            {
              Diagnosis d = new Diagnosis();
              d.diagnosis_id = q.r.getInt(1);
              d.name = q.r.getString(2);
              d.description = q.r.getString(3);
              diagnoses.diagnoses.add(d);
            }
            
            q.query("SELECT service_id FROM appointment_services WHERE appointment_id = " + appointment_id);
            if (q != null)
            while(q.r.next())
              services.ids.put(new Integer(q.r.getInt(1)), null);
          }
          catch (SQLException e)
          {
            p(e);
          }
          finally
          {
            q.close();
          }
        }
        
        protected boolean save()
        {
          if (doctor.id == null)
            errors.add("Doctor not specified");
    if (patient.id == null)
      errors.add("Patient not specified");
    if (begintime.text == null || begintime.text.trim().length() == 0)
      errors.add("Begin time not specified");
    if (endtime.text == null || endtime.text.trim().length() == 0)
      errors.add("End time not specified");

    java.sql.Timestamp bt, et;
    bt = toTimestamp(begintime.text);
    if (bt == null)
      errors.add("Unable to parse begin time. (Example of valid format is 2000-01-01 13:30)");
    et = toTimestamp(endtime.text);
    if (et == null)
      errors.add("Unable to parse end time. (Example of valid format is 2000-01-01 13:30)");
    
    if (et != null && bt != null && bt.getTime() >= et.getTime())
    {
      errors.add("Appointment end time must be later than begin time");
    }
    
    if (errors.size() > 0) return false;

          form.connectDb();
          Query q = new Query(form.conn, form.pw);
          try
          {
            boolean transactionComplete = false;
            q.execute("BEGIN");
      try
            {
              PreparedStatement s;
              if (appointment_id > 0)
              {
                s = form.conn.prepareStatement("\n"+
"                 UPDATE appointments SET begintime = ?, endtime = ?, \n"+
"                   doctor_id = ?, patient_id = ?\n"+
"                 WHERE appointment_id = " + appointment_id);
              }
              else
              {
                s = form.conn.prepareStatement("\n"+
"                 INSERT INTO appointments (begintime, endtime, doctor_id, patient_id)\n"+
"                 VALUES (?,?,?,?)");
              }
              try
              {
                s.setTimestamp(1, bt);
                s.setTimestamp(2, et);
                s.setInt(3, doctor.id.intValue());
                s.setInt(4, patient.id.intValue());
                s.executeUpdate();
              }
              finally
              {
                s.close();
              }
              
              if (appointment_id > 0)
              {
                q.execute
                (
                  "DELETE FROM diagnoses WHERE appointment_id = " + appointment_id + ";\n" + 
                  "DELETE FROM referrals WHERE appointment_id = " + appointment_id + ";\n" + 
                  "DELETE FROM appointment_services WHERE appointment_id = " + appointment_id + ";\n"
                );
              }
              else
              {
                q.query("SELECT currval('appointments_appointment_id_seq')");
                if (q == null || !q.r.next()) 
                {
                  errors.add("Internal Error: Failed to retrieve appointment_id");
                  return false;
                }
                appointment_id = q.r.getInt(1);
              }
              
              // TODO: it would be better to use the original referral and diagnosis ids
              // rather than creating new ones

              for(int i = 0; i < referrals.referrals.size(); ++i)
              {
                Referral r = (Referral) referrals.referrals.get(i);
                q.execute(
                  "INSERT INTO referrals (appointment_id, doctor_id, type)\n" +
                  "VALUES (" + appointment_id + ", " + r.doctor_id + ", " + 
                  (r.incoming ? "2" : "1") + ")"
                );
              }
              
              s = form.conn.prepareStatement("INSERT INTO diagnoses (appointment_id, name, description) " 
                + "VALUES (?,?,?)");
              try
              {
                s.setInt(1, appointment_id);
                for(int i = 0; i < diagnoses.diagnoses.size(); ++i)
                {
                  Diagnosis d = (Diagnosis) diagnoses.diagnoses.get(i);
            s.setString(2, d.name == null ? "" : d.name);
            s.setString(3, d.description == null ? "" : d.description);
                  s.executeUpdate();
                }
              }
              finally
              {
                s.close();
              }
              
              Set keys = services.ids.keySet();
              for(Iterator i = keys.iterator(); i.hasNext();)
              {
                Integer n = (Integer) i.next();
                q.execute(
                  "INSERT INTO appointment_services (appointment_id, service_id)\n" +
                  "VALUES (" + appointment_id + ", " + n.intValue() + ")"
                );
              }       
                
              transactionComplete = true;
            }
                catch (Throwable e)
                {
                  transactionComplete = false;
                  throw e;
                }
                finally
                {
                  q.execute(transactionComplete ? "COMMIT" : "ROLLBACK");
                }
          }
          catch (SQLException e)
          {
            p(e);
          }
          catch (Throwable e)
          {
            Query.rethrow(e);
          }
          finally
          {
            q.close();
          }
          return true;
        }
        
        public void display(boolean hidden)
        {
    super.display(hidden);
    
    if (hidden || modalChild != null) return;
    
    if (showErrors)
    {
      p("<h3>Save Failed</h3>");
      if (errors.size() > 0)
      {
        p("<p><strong>Please correct the following errors:</strong></p>");
        p("<ul>\n");
        for (int i = 0; i < errors.size(); ++i)
        {
          String s = (String) errors.get(i);
          p("  <li><font color=red>" + s + "</font></li>\n");
        }
        p("</ul>\n");
      }
    }
    
    p(
"<table>\n"+
"<tr>\n"+
"  <td valign=top>Patient:</td>\n"+
"  <td>"); patient.display(); p("</td>\n"+
"</tr>\n"+
"<tr>\n"+
"  <td valign=top>Doctor:</td>\n"+
"  <td>"); doctor.display(); p("</td>\n"+
"</tr>\n"+
"<tr>\n"+
"  <td valign=top>Begin Time:</td>\n"+
"  <td>"); begintime.display(); p("</td>\n"+
"</tr>\n"+
"<tr>\n"+
"  <td valign=top>End Time:</td>\n"+
"  <td>"); endtime.display(); p("</td>\n"+
"</tr>\n"+
"<tr>\n"+
"  <td valign=top>Services <i>(select many)</i>:</td>\n"+
"  <td>\n"+
"  "); services.display(); p("\n"+
"  </td>\n"+
"</tr>\n"+
"<tr>\n"+
"  <td valign=top>Diagnoses:</td>\n"+
"  <td>\n"+
"  "); diagnoses.display(); p("\n"+
"  </td>\n"+
"</tr>\n"+
"<tr>\n"+
"  <td valign=top>Referrals:</td>\n"+
"  <td>\n"+
"  "); referrals.display(); p("\n"+
"  </td>\n"+
"</tr>\n"+
"<tr>\n"+
"  <td>&nbsp;</td>\n"+
"  <td>\n"+
"  "); action.display("Save Changes", SAVE); action.display("Cancel", CANCEL); 
p("\n"+
"  </td>\n"+
"</td>\n"+
"</table>\n"+
"");
        }
        
        java.sql.Timestamp toTimestamp(String s)
        {
    SimpleDateFormat f = new SimpleDateFormat("yyyy-MM-dd HH:mm");
    
    java.sql.Timestamp t = null;
    java.util.Date d = null;
    
    try
    {
      d = f.parse(s);
    }
    catch (java.text.ParseException e) {}
    
    if (d != null)
    {
      Calendar c = Calendar.getInstance(); 
      c.setTime(d);
      c.set(Calendar.SECOND, 0);
      t = new java.sql.Timestamp(c.getTimeInMillis());
    }  
    return t;
        }
};

---