/* Licensed under LGPL */
using System;
using System.Collections.Generic;
using System.Linq;
using System.Data;
using System.Text;
using System.Diagnostics;
using IndianHealthService.BMXNet;
namespace IndianHealthService.ClinicalScheduling
{
///
/// Data Access Layer
///
public class DAL
{
private RemoteSession _thisConnection; // set in constructor
delegate DataTable RPMSDataTableDelegate(string CommandString, string TableName); // for use in calling (Sync and Async)
delegate string TransmitRPCAsync(string RPCName, string Params); //same idea
///
/// Constructor
///
/// The current connection to use
public DAL(RemoteSession conn)
{
this._thisConnection = conn;
}
///
/// Get Current version from ^ nmsp + APPL(1,0)
///
/// Namespace to ask for. Only "BMX" and "BSDX" are supported.
/// Datatable with the following fields:
/// "T00030ERROR^T00030MAJOR_VERSION^T00030MINOR_VERSION^T00030BUILD
public DataTable GetVersion(string nmsp)
{
string cmd = String.Format("BMX VERSION INFO^{0}", nmsp);
return _thisConnection.TableFromCommand(cmd);
}
///
/// Get Scheduling User Info
///
/// You should know what this is
/// Datatable with one column: "MANAGER": One Row that's "YES" or "NO"
public DataTable GetUserInfo(string DUZ)
{
string cmd = String.Format("BSDX SCHEDULING USER INFO^{0}^{1}", DUZ, "BSDXZMGR");
return _thisConnection.TableFromCommand(cmd);
}
///
/// Get all Access Types from the BSDX ACCESS TYPE file
///
/// DataTable with the following fields (add _ for spaces)
/// ACCESS TYPE NAME (RF), [0;1]
/// INACTIVE (S), [0;2]
/// DEPARTMENT NAME (P9002018.2'), [0;3]
/// DISPLAY COLOR (F), [0;4]
/// RED (NJ3,0), [0;5]
/// GREEN (NJ3,0), [0;6]
/// BLUE (NJ3,0), [0;7]
///
public DataTable GetAccessTypes(DataSet dataSetToTakeTable, string tablename)
{
string sCommandText = "SELECT * FROM BSDX_ACCESS_TYPE";
DataTable table = _thisConnection.TableFromSQL(sCommandText, dataSetToTakeTable, tablename);
DataColumn dcKey = table.Columns["BMXIEN"];
DataColumn[] dcKeys = new DataColumn[1];
dcKeys[0] = dcKey;
table.PrimaryKey = dcKeys;
return table;
}
///
/// Get the Patients who have appointments in between dates for the clinics requested
///
/// | delimited resource list (resource IENS, not names)
/// Self Explanatory
/// Self Explanatory
/// DataTable with the following columns:
/// T00030Name^D00020DOB^T00030Sex^T00030HRN^D00030ApptDate^T00030Clinic^T00030TypeStatus
/// I00010RESOURCEID^T00030APPT_MADE_BY^D00020DATE_APPT_MADE^T00250NOTE^T00030STREET^
/// T00030CITY^T00030STATE^T00030ZIP^T00030HOMEPHONE
///
///Mirrors dsPatientApptDisplay2.PatientAppts Schema in this project. Can merge table into schema.
public DataTable GetClinicSchedules(string sClinicList, DateTime BeginDate, DateTime EndDate)
{
string sBegin = FMDateTime.Create(BeginDate).DateOnly.FMDateString;
string sEnd = FMDateTime.Create(EndDate).DateOnly.FMDateString;
string cmd = String.Format("BSDX CLINIC LETTERS^{0}^{1}^{2}", sClinicList, sBegin, sEnd);
return _thisConnection.TableFromCommand(cmd);
}
///
/// Get the letter templates associated with the requested clinics (reminder letter, cancellation letter etc)
///
/// | delimited resource list (resource IENS, not names)
/// DataTable with the following columns:
/// I00010RESOURCEID^T00030RESOURCE_NAME^T00030LETTER_TEXT^T00030NO_SHOW_LETTER^T00030CLINIC_CANCELLATION_LETTER
///
/// Mirrors dsPatientApptDisplay2.BSDXResource Schema. Can merge table into schema.
public DataTable GetResourceLetters(string sClinicList)
{
string cmd = String.Format("BSDX RESOURCE LETTERS^{0}", sClinicList);
return _thisConnection.TableFromCommand(cmd);
}
///
/// Get the list of Patients who have Rebooked Appointments
///
/// | delimited resource list (resource IENS, not names)
/// Self Explanatory
/// Self Explanatory
/// T00030Name^D00020DOB^T00030Sex^T00030HRN^D00030NewApptDate^T00030Clinic^T00030TypeStatus
/// ^I00010RESOURCEID^T00030APPT_MADE_BY^D00020DATE_APPT_MADE^T00250NOTE^T00030STREET^T00030CITY
/// ^T00030STATE^T00030ZIP^T00030HOMEPHONE^D00030OldApptDate
///
/// Mirrors dsRebookAppts.PatientAppt Schema. Can merge table into schema.
public DataTable GetRebookedAppointments(string sClinicList, DateTime BeginDate, DateTime EndDate)
{
string sBegin = FMDateTime.Create(BeginDate).DateOnly.FMDateString;
string sEnd = FMDateTime.Create(EndDate).DateOnly.FMDateString;
string cmd = String.Format("BSDX REBOOK CLINIC LIST^{0}^{1}^{2}", sClinicList, sBegin, sEnd);
return _thisConnection.TableFromCommand(cmd);
}
///
/// Should have documented this better when I remembered what this did!
///
/// | delimited list of appointment IENs in ^BSDXAPPT
/// "T00030Name^D00020DOB^T00030Sex^T00030HRN^D00030NewApptDate^T00030Clinic^T00030TypeStatus
/// ^I00010RESOURCEID^T00030APPT_MADE_BY^D00020DATE_APPT_MADE^T00250NOTE^T00030STREET^T00030CITY
/// ^T00030STATE^T00030ZIP^T00030HOMEPHONE^D00030OldApptDate
public DataTable GetRebookedAppointments(string sApptList)
{
string cmd = String.Format("BSDX REBOOK LIST^{0}", sApptList);
return _thisConnection.TableFromCommand(cmd);
}
///
/// Really does what it says! Gets them by going through the BSDX APPOITMENT file index
/// between the specified dates for the Resource.
///
/// | delmited list of Resource IENs in ^BSDXRES
///
///
/// "T00030Name^D00020DOB^T00030Sex^T00030HRN^D00030NewApptDate^T00030Clinic^T00030TypeStatus
/// ^I00010RESOURCEID^T00030APPT_MADE_BY^D00020DATE_APPT_MADE^T00250NOTE^T00030STREET^T00030CITY
/// ^T00030STATE^T00030ZIP^T00030HOMEPHONE^D00030OldApptDate
public DataTable GetCancelledAppointments(string sClinicList, DateTime BeginDate, DateTime EndDate)
{
string sBegin = FMDateTime.Create(BeginDate).DateOnly.FMDateString;
string sEnd = FMDateTime.Create(EndDate).DateOnly.FMDateString;
string cmd = String.Format("BSDX CANCEL CLINIC LIST^{0}^{1}^{2}", sClinicList, sBegin, sEnd);
return _thisConnection.TableFromCommand(cmd);
}
///
/// Delete All Slots for a Resource
///
/// Integer Resource IEN in BSDX RESOURCE
/// Self-Explanatory
/// Self-Explanatory
/// Table with 2 columns: ERRORID & ERRORTEXT
/// ErrorID of -1 is A OK (successful operation); anything else is bad.
public DataTable MassSlotDelete(string sResourceID, DateTime BeginDate, DateTime EndDate)
{
string sBegin = FMDateTime.Create(BeginDate).DateOnly.FMDateString;
string sEnd = FMDateTime.Create(EndDate).DateOnly.FMDateString;
string cmd = String.Format("BSDX CANCEL AV BY DATE^{0}^{1}^{2}", sResourceID, sBegin, sEnd);
return _thisConnection.TableFromCommand(cmd);
}
///
/// Remove the check-in for the appointment
///
/// Appointment IEN/Key
/// Table with 1 columns: ERRORID. ErrorID of "0" is okay;
/// any other (negative numbers plus text) is bad
public DataTable RemoveCheckIn(int ApptID)
{
string cmd = string.Format("BSDX REMOVE CHECK-IN^{0}", ApptID);
return _thisConnection.TableFromCommand(cmd);
}
///
/// Gets All radiology exams for a Patient in a specific hospital location
///
///
/// Hospital Location IEN
/// Generic List of type RadiologyExam
public List GetRadiologyExamsForPatientinHL(int DFN, int SCIEN)
{
string cmd = string.Format("BSDX GET RAD EXAM FOR PT^{0}^{1}", DFN, SCIEN);
DataTable tbl = _thisConnection.TableFromCommand(cmd);
return (from row in tbl.AsEnumerable()
select new RadiologyExam
{
IEN = row.Field("BMXIEN"),
Status = row.Field("STATUS"),
Procedure = row.Field("PROCEDURE"),
RequestDate = row.Field("REQUEST_DATE")
}).ToList();
}
///
/// Schedules a Single Radiology Exam for a patient
///
///
/// IEN of exam in 75.1 (RAD/NUC MED ORDERS) file
/// Start DateTime of appointment
/// should always return true
public bool ScheduleRadiologyExam(int DFN, int examIEN, DateTime dStart)
{
string fmStartDate = FMDateTime.Create(dStart).FMDateString;
string result = _thisConnection.TransmitRPC("BSDX SCHEDULE RAD EXAM", string.Format("{0}^{1}^{2}", DFN, examIEN, fmStartDate));
return result == "1" ? true : false;
}
///
/// Put the radiology exam on Hold because the appointment has been cancelled for it
///
///
/// IEN of exam in 75.1 (RAD/NUC MED ORDERS) file
/// should always return true
public bool CancelRadiologyExam(int DFN, int examIEN)
{
string result = _thisConnection.TransmitRPC("BSDX HOLD RAD EXAM", string.Format("{0}^{1}", DFN, examIEN));
return result == "1" ? true : false;
}
///
/// Can we Cancel an Exam appointment? Exams that are discontinued, Active or Complete cannot be discontinued
///
/// IEN of exam in 75.1 (RAD/NUC MED ORDERS) file
/// true or false
public bool CanCancelRadExam(int examIEN)
{
string result = _thisConnection.TransmitRPC("BSDX CAN HOLD RAD EXAM", examIEN.ToString());
return result == "1" ? true : false;
}
///
/// Save User Preference in DB For Printing Routing Slip
/// Uses Parameter BSDX AUTO PRINT RS
///
///
/// Notice Code-Fu for Async Save...
///
public bool AutoPrintRoutingSlip
{
get
{
string val = _thisConnection.TransmitRPC("BSDX GET PARAM", "BSDX AUTO PRINT RS"); //1 = true; 0 = false; "" = not set
return val == "1" ? true : false;
}
set
{
TransmitRPCAsync _asyncTransmitter = new TransmitRPCAsync(_thisConnection.TransmitRPC);
// 0 = success; anything else is wrong. Not being tested here as its success is not critical to application use.
_asyncTransmitter.BeginInvoke("BSDX SET PARAM", String.Format("{0}^{1}", "BSDX AUTO PRINT RS", value ? "1" : "0"), null, null);
}
}
///
/// Save User Preference in DB For Printing Routing Slip
/// Uses Parameter BSDX AUTO PRINT AS
///
///
/// Notice Code-Fu for Async Save...
///
public bool AutoPrintAppointmentSlip
{
get
{
string val = _thisConnection.TransmitRPC("BSDX GET PARAM", "BSDX AUTO PRINT AS"); //1 = true; 0 = false; "" = not set
return val == "1" ? true : false;
}
set
{
TransmitRPCAsync _asyncTransmitter = new TransmitRPCAsync(_thisConnection.TransmitRPC);
// 0 = success; anything else is wrong. Not being tested here as its success is not critical to application use.
_asyncTransmitter.BeginInvoke("BSDX SET PARAM", String.Format("{0}^{1}", "BSDX AUTO PRINT AS", value ? "1" : "0"), null, null);
}
}
///
/// Workhorse
///
///
///
///
private DataTable RPMSDataTable(string sSQL, string sTableName)
{
//Retrieves a recordset from RPMS
string sErrorMessage = "";
DataTable dtOut;
try
{
RPMSDataTableDelegate rdtd = new RPMSDataTableDelegate(_thisConnection.TableFromSQL);
dtOut = (DataTable)rdtd.Invoke(sSQL, sTableName);
}
catch (Exception ex)
{
sErrorMessage = "DAL.RPMSDataTable error: " + ex.Message;
throw ex;
}
return dtOut;
}
}
}