Skip to content

Added the Practitioner provider and getAllPatientsByProvider to PatientProvider #10

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
iamhopeful wants to merge 2 commits into
base: FHIR-DSTU
Choose a base branch
from
Open

Added the Practitioner provider and getAllPatientsByProvider to PatientProvider #10

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
8b61b5c
Add PractitionerResourceProvider and update PatientResourceProvider
iamhopeful Apr 12, 2015
98d1f11
took out println from Practitioner
iamhopeful Apr 29, 2015
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
251 changes: 251 additions & 0 deletions src/edu/gatech/i3l/HealthPort/PractitionerPortInfo.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,251 @@
/**
*
*/
package edu.gatech.i3l.HealthPort;

import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Timestamp;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.sql.Date;
import java.util.List;

import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.sql.DataSource;

import org.apache.commons.lang3.StringEscapeUtils;

import ca.uhn.fhir.model.api.IResource;
import ca.uhn.fhir.model.dstu.composite.CodeableConceptDt;
import ca.uhn.fhir.model.dstu.composite.CodingDt;
import ca.uhn.fhir.model.dstu.composite.ContainedDt;
import ca.uhn.fhir.model.dstu.composite.QuantityDt;
import ca.uhn.fhir.model.dstu.composite.ResourceReferenceDt;
import ca.uhn.fhir.model.dstu.resource.Condition;
import ca.uhn.fhir.model.dstu.resource.Medication;
import ca.uhn.fhir.model.dstu.resource.MedicationPrescription;
import ca.uhn.fhir.model.dstu.resource.Observation;
import ca.uhn.fhir.model.dstu.resource.MedicationPrescription.Dispense;
import ca.uhn.fhir.model.dstu.resource.MedicationPrescription.DosageInstruction;
import ca.uhn.fhir.model.dstu.valueset.ConditionStatusEnum;
import ca.uhn.fhir.model.dstu.valueset.MedicationPrescriptionStatusEnum;
import ca.uhn.fhir.model.dstu.valueset.NarrativeStatusEnum;
import ca.uhn.fhir.model.dstu.valueset.ObservationReliabilityEnum;
import ca.uhn.fhir.model.dstu.valueset.ObservationStatusEnum;
import ca.uhn.fhir.model.primitive.DateDt;
import ca.uhn.fhir.model.primitive.DateTimeDt;
import ca.uhn.fhir.model.primitive.IdDt;
import edu.gatech.i3l.HealthPort.providers.PatientResourceProvider;

/**
* @author Myung Choi Constructor requires UserID. - Connects to SQL database to
* obtain patient related parameters.
*/
public class PractitionerPortInfo {


public String providerOrg = null;
public String providerId = null;
public String providerNpi = null;
public String facilityName = null;
public String specialty = null;
public String name = null;
public String pClass = null;
public String location = null;
public Date dateOfBirth = null;
public String sex = null;
public String supervisionRequired = null;
public String personId = null;
public String primaryClinicLocation = null;

// Database Paging Resource Names
public static String OBSERVATION = "OBSERVATION";
public static String CONDITION = "CONDITIONS";
public static String MEDICATIONPRESCRIPTION = "MEDICATIONPRESCRIPTION";

private DataSource dataSource;

/**
*
*/
public PractitionerPortInfo() {
databaseSetup("jdbc/HealthPort");
}

public PractitionerPortInfo(String jndiName) {
databaseSetup(jndiName);
}

public PractitionerPortInfo(String jndiName, String userId) {
databaseSetup(jndiName);
setInformation(userId);
}

public List<String> getResourceIdsByProviderName(String tableName,
String practitionerName) {
List<String> retVal = new ArrayList<String>();

Connection connection = null;
Statement statement = null;

String SQL_STATEMENT = "SELECT Provider_ID FROM " + tableName
+ " WHERE name = '" + practitionerName + "'";

connection = getConnection();
try {
statement = connection.createStatement();
ResultSet rs = statement.executeQuery(SQL_STATEMENT);

while (rs.next()) {
retVal.add(rs.getString("Provider_ID"));
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
connection.close();
} catch (SQLException e) { // TODO Auto-generated catch block
e.printStackTrace();
}
}


return retVal;
}

private void databaseSetup(String jndiName) {
try {
dataSource = (DataSource) new InitialContext()
.lookup("java:/comp/env/" + jndiName);
} catch (NamingException e) {
e.printStackTrace();
}
}

public Connection getConnection() {
try {
return dataSource.getConnection();
} catch (SQLException e) {
e.printStackTrace();
return null;
}
}

public void resetInformation() {

providerOrg = null;
providerId = null;
providerNpi = null;
facilityName = null;
specialty = null;
name = null;
pClass = null;
location = null;
dateOfBirth = null;
sex = null;
supervisionRequired = null;
personId = null;
primaryClinicLocation = null;

}

public void setRSInformation(ResultSet rs) throws SQLException {


providerOrg = rs.getString("Provider_Org");
providerId = rs.getString("Provider_ID");
providerNpi = rs.getString("Provider_NPI");
facilityName = rs.getString("Facility_Name");
specialty = rs.getString("Specialty");
name = rs.getString("Name");
pClass = rs.getString("Class");
location = rs.getString("Location");
sex = rs.getString("Sex");
supervisionRequired = rs.getString("Supervision_Required");
personId = rs.getString("Person_ID");
primaryClinicLocation = rs.getString("Primary_Clinic_Location");

}

public void setInformation(String providerId) {

Connection connection = null;
Statement statement = null;

this.providerId = providerId;

try {
connection = getConnection();
statement = connection.createStatement();
String SQL_STATEMENT = "SELECT Provider_ID, Provider_Org, Provider_NPI, Facility_Name, Specialty, Name, Class, Location, Sex, Supervision_Required, Person_ID, Primary_Clinic_Location FROM provider where Provider_ID='" + providerId + "'";

ResultSet resultSet = statement.executeQuery(SQL_STATEMENT);

if(resultSet!= null) {
if (resultSet.next()) {
setRSInformation(resultSet);
}
}

} catch (Exception e) {
e.printStackTrace();
resetInformation();
} finally {
try {
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}

public String getOrgID(String Tag) {
String orgID = null;
Connection connection = getConnection();
try {
Statement statement = connection.createStatement();
String SQL_STATEMENT = "SELECT * FROM ORGANIZATION WHERE TAG='"
+ Tag + "'";
ResultSet resultSet = statement.executeQuery(SQL_STATEMENT);

if (resultSet.next()) {
orgID = resultSet.getString("ID");

}


} catch (Exception e) {
e.printStackTrace();
resetInformation();
} finally {
try {
connection.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

return orgID;
}

/**
* @param string
* @param string2
*/
public void setInformationProviderID(String string, String string2) {
// TODO Auto-generated method stub

}


}
3 changes: 3 additions & 0 deletions src/edu/gatech/i3l/HealthPort/RestfulServlet.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@
import edu.gatech.i3l.HealthPort.providers.MedicationPrescrResource;
import edu.gatech.i3l.HealthPort.providers.ObservationResourceProvider;
import edu.gatech.i3l.HealthPort.providers.PatientResourceProvider;
import edu.gatech.i3l.HealthPort.providers.PractitionerResourceProvider;

import org.slf4j.LoggerFactory;

Expand Down Expand Up @@ -63,6 +64,8 @@ protected void initialize() throws ServletException {
resourceProviders.add(new ObservationResourceProvider());
resourceProviders.add(new ConditionResourceProvider());
resourceProviders.add(new MedicationPrescrResource());
resourceProviders.add(new PractitionerResourceProvider());

setResourceProviders(resourceProviders);

// /*
Expand Down
Loading