using System; using System.Collections.Generic; using System.Data.Common; using System.Linq; using System.Text; using System.Threading.Tasks; using Sarand.Core.App; using Sarand.Core.Base; using Sarand.Core.Bus; using Sarand.Core.Dbas.Base; using Sarand.Win.Dbas.Base; using Sarand.PatientMgr.Core.App; using Sarand.PatientMgr.Core.Bus; using Sarand.PatientMgr.Core.Mgr; using Sarand.PatientMgr.Win.Dbas.Bus; using Sarand.PatientMgr.Win.Dbas.Internal; //using Sarand.PatientMgr.Win.Dbas.UpdateLog; using Sarand.Win.Dbas.Data; namespace Sarand.PatientMgr.Win.Dbas.Mgr { //======================================================================= internal partial class SpmAdmissionMgr_Dbas : SpmAdmissionMgr { //******************************************************************* // A d m i s s i o n D a t a //******************************************************************* //------------------------------------------------------------------- // Data members. //------------------------------------------------------------------- // Utilities. //------------------------------------------------------------------- // AdmissionData exists. public override bool AdmissionDataExistsById(SysId admissionDataId) { ClearErrorState(); if (!SysId.IsValid(admissionDataId)) return false; SpmAdmissionData.Params prmAdmissionData = new SpmAdmissionData.Params(); prmAdmissionData.IncludedIds.Add(admissionDataId); prmAdmissionData.StatusCat = SpmAdmissionData.StatusCat.Any; return GetAdmissionDataCount(prmAdmissionData) == 1; } //------------------------------------------------------------------- // Get AdmissionData. public override SpmAdmissionData GetAdmissionData(SpmAdmissionData.Params prm) { return GetAdmissionData(GetAdmissionDataQueryFilter(prm).Concat(" AND ", "(", ")")); } private SpmAdmissionData GetAdmissionData(String filter) { ClearErrorState(); long count = GetAdmissionDataCount(filter); if (count == 0) return null; if (count != 1) { SetErrorState("Multiple AdmissionDataes found"); return null; } SpmAdmissionData admissionData = null; // Query data. using (var dbConnection = db.CreateConnection()) using (var dbCommand = dbConnection.CreateCommand()) { try { dbConnection.Open(); SwmAdmissionData_Db dbAdmissionData = new SwmAdmissionData_Db(DbInfo); dbAdmissionData.PopulateFrom(dbCommand, aliasAdmissionData, filter); admissionData = CreateAdmissionData(dbAdmissionData); } catch (Exception exc) { SetErrorState("Database query exception"); Logger.Warn(GetType().Name + ".GetAdmissionData\n\tQuery: " + dbCommand.CommandText + "\n\tException: " + exc.Message); } } return admissionData; } public override SpmAdmissionData GetAdmissionDataById(SysId admissionDataId) { ClearErrorState(); if (!SysId.IsValid(admissionDataId)) return null; SpmAdmissionData.Params prmAdmissionData = new SpmAdmissionData.Params(); prmAdmissionData.IncludedIds.Add(admissionDataId); prmAdmissionData.StatusCat = SpmAdmissionData.StatusCat.Any; return GetAdmissionData(prmAdmissionData); } //------------------------------------------------------------------- // Create AdmissionData. public override SpmAdmissionData CreateAdmissionData(SysId admissionId, Spm.AdmissionDataType admissionDataType) { return new SpmAdmissionData_Dbas(UserContext, admissionId, admissionDataType, 0); } private SpmAdmissionData_Dbas CreateAdmissionData(SwmAdmissionData_Db dbAdmissionData) { ClearErrorState(); SpmAdmissionData_Dbas admissionData = new SpmAdmissionData_Dbas(UserContext, new SysId(dbAdmissionData._AdmissionId), (Spm.AdmissionDataType)dbAdmissionData._Type, (ushort)dbAdmissionData._Flags); PopulateFrom(dbAdmissionData, admissionData); return admissionData; } //------------------------------------------------------------------- // Validate AdmissionData. public override bool IsValidAdmissionDataData(SpmAdmissionData.Data data, SpmAdmissionData.ErrField errField) { ClearErrorState(); if (!base.IsValidAdmissionDataData(data, errField)) return false; return true; } //------------------------------------------------------------------- // Insert AdmissionData. public override bool InsertAdmissionData(SpmAdmissionData admissionData, DbUpdateInfo dbUpdateInfo) { ClearErrorState(); if (!IsValidAdmissionData(admissionData)) return false; if (SysId.IsValid(admissionData.Id)) return SetErrorState(ErrorMessage.ValiditemId); using (var dbConnection = db.CreateConnection()) using (var dbCommand = dbConnection.CreateCommand()) { try { dbConnection.Open(); SwmAdmissionData_Db dbAdmissionData = new SwmAdmissionData_Db(DbInfo); PopulateTo(dbAdmissionData, admissionData, dbUpdateInfo); if (SwmAdmissionData_Db.FieldsNonId.Contains("Id")) { // Generate next Id. //dbAdmissionData._Id = SysId.ToInt(db.GetNextId("AdmissionData", dbUpdateInfo)); } dbAdmissionData.ExecuteInsertCommand(dbCommand); //admissionData.Id = new SysId(dbAdmissionData._Id); } catch (Exception exc) { SetErrorState(exc.Message); } } return !HasErrorState(); } //------------------------------------------------------------------- // Update AdmissionData. public override bool UpdateAdmissionData(SpmAdmissionData admissionData, DbUpdateInfo dbUpdateInfo) { ClearErrorState(); if (!IsValidAdmissionData(admissionData)) return false; if (!SysId.IsValid(admissionData.Id)) return SetErrorState(ErrorMessage.InvalidItemId); using (var dbConnection = db.CreateConnection()) using (var dbCommand = dbConnection.CreateCommand()) { try { // Retrieve AdmissionData. dbConnection.Open(); SwmAdmissionData_Db dbAdmissionData = new SwmAdmissionData_Db(DbInfo); dbAdmissionData.PopulateFrom(dbCommand, aliasAdmissionData, "Id=" + SysId.ToString(admissionData.Id)); //SpmUpdateLogItemMonitor_AdmissionData updateLogMonitor = new SpmUpdateLogItemMonitor_AdmissionData(UserContext, CreateAdmissionData(dbAdmissionData)); // Update properties. PopulateTo(dbAdmissionData, admissionData, dbUpdateInfo); dbAdmissionData.ExecuteUpdateCommand(dbCommand); /* Record updates. updateLogMonitor.RecordUpdatedValues(admissionData); updateLogMonitor.LogUpdates();*/ } catch (Exception exc) { SetErrorState(exc.Message); } } return !HasErrorState(); } //------------------------------------------------------------------- // Delete AdmissionData. public override bool AdmissionDataCanBeDeleted(SpmAdmissionData admissionData) { ClearErrorState(); if (!base.AdmissionDataCanBeDeleted(admissionData)) return false; return true; } public override bool DeleteAdmissionData(SpmAdmissionData admissionData, DbUpdateInfo dbUpdateInfo) { ClearErrorState(); if (!AdmissionDataCanBeDeleted(admissionData)) return false; using (var dbConnection = db.CreateConnection()) using (var dbCommand = dbConnection.CreateCommand()) { try { // Retrieve AdmissionData. dbConnection.Open(); SwmAdmissionData_Db dbAdmissionData = new SwmAdmissionData_Db(DbInfo); dbAdmissionData.PopulateFrom(dbCommand, aliasAdmissionData, "Id=" + admissionData.Id.ToString()); // Delete AdmissionData. dbCommand.CommandType = System.Data.CommandType.Text; dbCommand.CommandText = "DELETE FROM " + SpmDbDfn.GetTableName(SpmDbDfn.TableIdx.SwmAdmissionData) + " WHERE Id=" + SysId.ToString(admissionData.Id) + ";"; dbCommand.ExecuteNonQuery(); } catch (Exception exc) { SetErrorState(exc.Message); } } return !HasErrorState(); } //------------------------------------------------------------------- // Copy data properties to and from database. private void PopulateTo(SwmAdmissionData_Db dbAdmissionData, SpmAdmissionData admissionData, DbUpdateInfo dbUpdateInfo) { dbAdmissionData._AdmissionId = admissionData.AdmissionId.ToInt(); dbAdmissionData._Type = (short)admissionData.AdmissionDataType; dbAdmissionData._Data = admissionData.AdmissionData; dbAdmissionData._Notes = admissionData.Notes; dbAdmissionData._Status = SacsSystem.GetStatusCode(admissionData.Status); dbAdmissionData._Flags = (short)admissionData.Flags; if (!SysId.IsValid(admissionData.Id)) { dbAdmissionData._CreateOn = DateTime.UtcNow; dbAdmissionData._CreateBy = dbUpdateInfo.UserId.ToInt(); dbAdmissionData._CreateHost = dbUpdateInfo.Host; } dbAdmissionData._UpdateOn = DateTime.UtcNow; dbAdmissionData._UpdateBy = dbUpdateInfo.UserId.ToInt(); dbAdmissionData._UpdateHost = dbUpdateInfo.Host; } private void PopulateFrom(SwmAdmissionData_Db dbAdmissionData, SpmAdmissionData admissionData) { admissionData.AdmissionId = new SysId(dbAdmissionData._AdmissionId); admissionData.AdmissionDataType = (Spm.AdmissionDataType)dbAdmissionData._Type; admissionData.AdmissionData = dbAdmissionData._Data; admissionData.Notes = dbAdmissionData._Notes; admissionData.Status = SacsSystem.GetStatusForCode(dbAdmissionData._Status); admissionData.SetCreateStamp(dbAdmissionData._CreateOn, new SysId(dbAdmissionData._CreateBy), dbAdmissionData._CreateHost); admissionData.SetUpdateStamp(dbAdmissionData._UpdateOn, new SysId(dbAdmissionData._UpdateBy), dbAdmissionData._UpdateHost); admissionData.AcceptChanges(); } //------------------------------------------------------------------- // AdmissionData column definitions. private static readonly String aliasAdmissionData = "aAdmData"; private void SetAdmissionDataColDfn (ColumnDfn col, String caption, int width, SpmDbDfn.ColumnIdx dbCol, ColumnAlignment align = ColumnAlignment.Default, DataValue.DataType dataType = DataValue.DataType.String, String alias = "", String prefix = "") { if (String.IsNullOrEmpty(alias) && SpmDbDfn.GetTableForColumn(dbCol) == SpmDbDfn.TableIdx.SwmAdmissionData) alias = aliasAdmissionData; col.Set(caption, width, (int)dbCol, prefix + SpmDbDfn.GetColumnName(dbCol, false), SpmDbDfn.GetColumnNameQual(dbCol, alias), dataType, align); if (dataType == DataValue.DataType.String && dbCol != SpmDbDfn.ColumnIdx.Unknown) col.MaxLength = (int)SpmDbDfn.GetColTextLen(dbCol); } //------------------------------------------------------------------- // Getting prmAdmissionData column definition. public override ColumnDfn GetAdmissionDataColumnDfn(SpmAdmissionData.Column columnId, string caption = "", int width = 0) { ColumnDfn columnDfn = new ColumnDfn((int)columnId, caption, width); switch (columnId) { case SpmAdmissionData.Column.Pos: SetAdmissionDataColDfn(columnDfn, "Pos", 42, SpmDbDfn.ColumnIdx.Unknown, ColumnAlignment.Right); columnDfn.SortMode = ColumnDfn.ColumnSortMode.Off; columnDfn.ReadOnly = true; columnDfn.Resizable = false; break; // AdmissionData Properties. case SpmAdmissionData.Column.AdmissionId: SetAdmissionDataColDfn(columnDfn, "Id", 40, SpmDbDfn.ColumnIdx.SwmAdmissionData_AdmissionId, ColumnAlignment.Right, DataValue.DataType.Long); columnDfn.ReadOnly = true; break; case SpmAdmissionData.Column.Type: SetAdmissionDataColDfn(columnDfn, "Type", 40, SpmDbDfn.ColumnIdx.SwmAdmissionData_Type, ColumnAlignment.Center); break; case SpmAdmissionData.Column.Type_Desc: SetAdmissionDataColDfn(columnDfn, "Type", 100, SpmDbDfn.ColumnIdx.SwmAdmissionData_Type); break; case SpmAdmissionData.Column.AdmissionData: SetAdmissionDataColDfn(columnDfn, "Admission Data", 90, SpmDbDfn.ColumnIdx.SwmAdmissionData_Data); break; // Common properties. case SpmAdmissionData.Column.Notes: SetAdmissionDataColDfn(columnDfn, "Notes", 200, SpmDbDfn.ColumnIdx.SwmAdmissionData_Notes); break; case SpmAdmissionData.Column.Status: SetAdmissionDataColDfn(columnDfn, "Status", 50, SpmDbDfn.ColumnIdx.SwmAdmissionData_Status, ColumnAlignment.Center); break; case SpmAdmissionData.Column.Status_Desc: SetAdmissionDataColDfn(columnDfn, "Status", 50, SpmDbDfn.ColumnIdx.SwmAdmissionData_Status, ColumnAlignment.Center); break; case SpmAdmissionData.Column.Status_Ind: SetAdmissionDataColDfn(columnDfn, "Status", 50, SpmDbDfn.ColumnIdx.SwmAdmissionData_Status, ColumnAlignment.Center, DataValue.DataType.TriState); columnDfn.TriStateFormat = ColumnTriStateFormat.Lights; break; case SpmAdmissionData.Column.CreateOn_Date: SetAdmissionDataColDfn(columnDfn, "Created", 65, SpmDbDfn.ColumnIdx.SwmAdmissionData_CreateOn, ColumnAlignment.Center, DataValue.DataType.Date); columnDfn.ReadOnly = true; break; case SpmAdmissionData.Column.UpdateOn_Date: SetAdmissionDataColDfn(columnDfn, "Updated", 65, SpmDbDfn.ColumnIdx.SwmAdmissionData_UpdateOn, ColumnAlignment.Center, DataValue.DataType.Date); columnDfn.ReadOnly = true; break; } if (!String.IsNullOrEmpty(caption)) columnDfn.Caption = caption; if (width > 0) columnDfn.Width = width; return columnDfn; } //------------------------------------------------------------------- // AdmissionData query filter. public override List GetAdmissionDataQueryFilter(SpmAdmissionData.Params prm) { List filters = new List(); // AdmissionData Id. String includedIds = prm.IncludedIds.Concat(","); if (!includedIds.IsEmpty()) filters.Add(SpmDbDfn.GetColumnNameQual(SpmDbDfn.ColumnIdx.SwmAdmissionData_AdmissionId, aliasAdmissionData) + " IN (" + includedIds + ")"); String excludedIds = prm.ExcludedIds.Concat(","); if (!excludedIds.IsEmpty()) filters.Add(SpmDbDfn.GetColumnNameQual(SpmDbDfn.ColumnIdx.SwmAdmissionData_AdmissionId, aliasAdmissionData) + " NOT IN (" + excludedIds + ")"); // Admission Id. String colAdmisssionData_AdmissionId = SpmDbDfn.GetColumnNameQual(SpmDbDfn.ColumnIdx.SwmAdmissionData_AdmissionId, aliasAdmissionData); if (SysId.IsValid(prm.AdmissionId)) filters.Add(colAdmisssionData_AdmissionId + "=" + prm.AdmissionId.ToString()); String colType = SpmDbDfn.GetColumnNameQual(SpmDbDfn.ColumnIdx.SwmAdmissionData_Type, aliasAdmissionData); if (prm.AdmissionDataType > 0) filters.Add(colType + "=" + ((int)prm.AdmissionDataType).ToString()); // AdmissionData. String colAdmissionData = SpmDbDfn.GetColumnNameQual(SpmDbDfn.ColumnIdx.SwmAdmissionData_Data, aliasAdmissionData); if (StringUtil.IsEmpty(prm.AdmissionData)) filters.Add(colAdmissionData + "=" + DbQuery.FormatForCondition(prm.AdmissionData)); //--------------------------------------------------------------- // Common Properties. if (filters.Count < 1) filters.Add("1=1"); return filters; } //------------------------------------------------------------------- // AdmissionData sort columns. public List GetAdmissionDataSortColumns(SpmAdmissionData.Params prm) { // Sort sequence: List sortColumnNames = new List(); foreach (var columnDfn in prm.SortColumns) { // Need to ensure correct alias used for AdmissionData columns in case of conflict. String sortCol = String.Empty; if (SpmDbDfn.GetTableForColumn((SpmDbDfn.ColumnIdx)columnDfn.DbColumn) == SpmDbDfn.TableIdx.SwmAdmissionData) { sortCol = SpmDbDfn.GetColumnNameQual((SpmDbDfn.ColumnIdx)columnDfn.DbColumn, aliasAdmissionData); } else { sortCol = columnDfn.DataName; if (!StringUtil.IsEmpty(columnDfn.SortDataName)) sortCol = columnDfn.SortDataName; } if (!sortCol.IsEmpty()) { DbOrderByNullMode orderByNullMode = DbOrderByNullMode.Default; // eSaOrderByDemoteNulls, eSaOrderByPromoteNulls sortColumnNames.Add(DbQuery.FormatForOrderBy(sortCol, columnDfn.SortAscending, orderByNullMode).Concat(", ")); } } sortColumnNames.RemoveBlanks(); if (sortColumnNames.IsEmpty()) { // Default sort columns: //sortColumnNames.Add(SpmDbDfn.GetColumnNameQual(SpmDbDfn.ColumnIdx.SwmAdmissionData_Type, aliasAdmissionData) + " ASC"); } return sortColumnNames; } //------------------------------------------------------------------- // AdmissionData count. private long GetAdmissionDataCount(String filter) { ClearErrorState(); return db.GetRowCount(SpmDbDfn.GetTableName(SpmDbDfn.TableIdx.SwmAdmissionData) + " As " + aliasAdmissionData, filter); } public override long GetAdmissionDataCount(SpmAdmissionData.Params prm) { ClearErrorState(); return GetAdmissionDataCount(GetAdmissionDataQueryFilter(prm).Concat(" AND ", "(", ")")); } //------------------------------------------------------------------- // AdmissionData list. public override List GetAdmissionDataList(SpmAdmissionData.Params prm) { List AdmissionDataes = new List(); DbQuery qry = new DbQuery(db.DbmsType); qry.Tables.Add(SpmDbDfn.GetTableName(SpmDbDfn.TableIdx.SwmAdmissionData), aliasAdmissionData); qry.Columns.AddRange(SwmAdmissionData_Db.Fields); qry.Filters.AddRange(GetAdmissionDataQueryFilter(prm)); // Query data. using (var dbConnection = db.CreateConnection()) using (var dbCommand = dbConnection.CreateCommand()) { try { dbConnection.Open(); dbCommand.CommandText = qry.BuildQuery(); using (DbDataReader dbDataReader = dbCommand.ExecuteReader()) { while (dbDataReader.Read()) { SwmAdmissionData_Db dbAdmissionData = new SwmAdmissionData_Db(DbInfo); dbAdmissionData.PopulateFrom(dbDataReader); AdmissionDataes.Add(CreateAdmissionData(dbAdmissionData)); } } } catch (Exception exc) { Logger.Warn(GetType().Name + ".GetAdmissionDataList\n\tQuery: " + dbCommand.CommandText + "\n\tException: " + exc.Message); } } return AdmissionDataes; } //------------------------------------------------------------------- // AdmissionData query execution. public override DbResultSet ExecuteAdmissionDataQuery(List columns, SpmAdmissionData.Params prm) { ClearErrorState(); //--------------------------------------------------------------- // Construct query. DbQuery query = new DbQuery(db.DbmsType); query.Tables.Add(SpmDbDfn.GetTableName(SpmDbDfn.TableIdx.SwmAdmissionData), aliasAdmissionData); // AdmissionData Properties - add columns as defined in query list. /*if (columns.HasId((int)SpmAdmissionData.Column.Id)) query.Columns.Add(SpmDbDfn.GetColumnNameQual(SpmDbDfn.ColumnIdx.SwmAdmissionData_, aliasAdmissionData));*/ if (columns.HasId((int)SpmAdmissionData.Column.AdmissionId)) query.Columns.Add(SpmDbDfn.GetColumnNameQual(SpmDbDfn.ColumnIdx.SwmAdmissionData_AdmissionId, aliasAdmissionData)); if (columns.HasId((int)SpmAdmissionData.Column.Type) || columns.HasId((int)SpmAdmissionData.Column.Type_Desc)) query.Columns.Add(SpmDbDfn.GetColumnNameQual(SpmDbDfn.ColumnIdx.SwmAdmissionData_Type, aliasAdmissionData)); if (columns.HasId((int)SpmAdmissionData.Column.AdmissionData)) query.Columns.Add(SpmDbDfn.GetColumnNameQual(SpmDbDfn.ColumnIdx.SwmAdmissionData_Data, aliasAdmissionData)); // Common Properties if (columns.HasId((int)SpmAdmissionData.Column.Notes)) query.Columns.Add(SpmDbDfn.GetColumnNameQual(SpmDbDfn.ColumnIdx.SwmAdmissionData_Notes, aliasAdmissionData)); if (columns.HasId((int)SpmAdmissionData.Column.Status) || columns.HasId((int)SpmAdmissionData.Column.Status_Desc) || columns.HasId((int)SpmAdmissionData.Column.Status_Ind)) query.Columns.Add(SpmDbDfn.GetColumnNameQual(SpmDbDfn.ColumnIdx.SwmAdmissionData_Status, aliasAdmissionData)); if (columns.HasId((int)SpmAdmissionData.Column.CreateOn_Date)) query.Columns.Add(SpmDbDfn.GetColumnNameQual(SpmDbDfn.ColumnIdx.SwmAdmissionData_CreateOn, aliasAdmissionData)); if (columns.HasId((int)SpmAdmissionData.Column.UpdateOn_Date)) query.Columns.Add(SpmDbDfn.GetColumnNameQual(SpmDbDfn.ColumnIdx.SwmAdmissionData_UpdateOn, aliasAdmissionData)); //--------------------------------------------------------------- // Populate filter. query.Filters.AddRange(GetAdmissionDataQueryFilter(prm)); if (prm.IncludedIds.Count != 1) { // Configure sort sequence. foreach (String sortColumn in GetAdmissionDataSortColumns(prm)) query.OrderBy.Add(sortColumn); } //--------------------------------------------------------------- //return new DbResultSet_DataTableReader(db, query.BuildQuery()); return new Sarand.Win.Dbas.Data.DbResultSet_DataReader(db, query.BuildQuery()); } //------------------------------------------------------------------- public override DataValue GetAdmissionDataDataValue(ColumnDfn column, NamedValue.Map values) { DataValue value = new DataValue(); switch ((SpmAdmissionData.Column)column.Id) { // Notes. case SpmAdmissionData.Column.Notes: value = new DataValue(SacsHierarchyItem.FormatForDisplay(values.GetValue(column.DataName).ToString(), 200)); break; // Status. case SpmAdmissionData.Column.Status_Desc: case SpmAdmissionData.Column.Status_Ind: { String statusCode = values.GetValue(column.DataName).ToString(); SaStatus status = SacsSystem.GetStatusForCode(statusCode); if (column.Id == (int)SpmAdmissionData.Column.Status_Desc) value = new DataValue(SacsSystem.GetStatusDescForCode(statusCode)); else if (column.Id == (int)SpmAdmissionData.Column.Status_Ind) value = new DataValue(SpmAdmissionData.GetStatusTriState(status)); } break; //----------------------------------------------------------- } return value; } //------------------------------------------------------------------- } //======================================================================= }