199 lines
16 KiB
C#
199 lines
16 KiB
C#
using AIMSModel;
|
|
using HelperDB;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Data;
|
|
using System.Data.SqlClient;
|
|
using System.Drawing;
|
|
using System.IO;
|
|
|
|
namespace AIMSDAL
|
|
{
|
|
|
|
public static partial class DUseDrugsReportService
|
|
{
|
|
//Add Mothed Start
|
|
public static readonly string InsertSql = "INSERT UseDrugsReport (用药Id, 加药时间, 使用日期, 患者姓名, 性别, 年龄, 住院号, 病历号, 身份证号码, 疾病名称, 药品名称, 剩余药品弃取记录, 批号, 处方剂量, 用量, 残留剂量, 残液处理方式, 残液处理地点, 处方医师, 执行护士, 复核人, 核对护士, 术间, 医生签名, 医生签名2, 护士签名, PatientRecordId, State, Num, SpecUnit, Enter, 镇痛泵使用量, 镇痛泵余量)VALUES (@用药Id, @加药时间, @使用日期, @患者姓名, @性别, @年龄, @住院号, @病历号, @身份证号码, @疾病名称, @药品名称, @剩余药品弃取记录, @批号, @处方剂量, @用量, @残留剂量, @残液处理方式, @残液处理地点, @处方医师, @执行护士, @复核人, @核对护士, @术间, @医生签名, @医生签名2, @护士签名, @PatientRecordId, @State, @Num, @SpecUnit, @Enter, @镇痛泵使用量, @镇痛泵余量)";
|
|
public static readonly string UpdateSql = "Update UseDrugsReport set 用药Id=@用药Id, 加药时间=@加药时间, 使用日期=@使用日期, 患者姓名=@患者姓名, 性别=@性别, 年龄=@年龄, 住院号=@住院号, 病历号=@病历号, 身份证号码=@身份证号码, 疾病名称=@疾病名称, 药品名称=@药品名称, 剩余药品弃取记录=@剩余药品弃取记录, 批号=@批号, 处方剂量=@处方剂量, 用量=@用量, 残留剂量=@残留剂量, 残液处理方式=@残液处理方式, 残液处理地点=@残液处理地点, 处方医师=@处方医师, 执行护士=@执行护士, 复核人=@复核人, 核对护士=@核对护士, 术间=@术间, 医生签名=@医生签名, 医生签名2=@医生签名2, 护士签名=@护士签名, PatientRecordId=@PatientRecordId, State=@State, Num=@Num, SpecUnit=@SpecUnit, Enter=@Enter, 镇痛泵使用量=@镇痛泵使用量, 镇痛泵余量=@镇痛泵余量 where Id=@Id";
|
|
public static readonly string DeleteSql = "Delete FROM UseDrugsReport where Id=@Id";
|
|
public static readonly string SelectSql = "Select * FROM UseDrugsReport";
|
|
public static readonly string SelectSqlById = "Select * FROM UseDrugsReport where Id =@Id";
|
|
public static int AddUseDrugsReport(UseDrugsReport useDrugsReport)
|
|
{
|
|
string sql = InsertSql;
|
|
SqlParameter[] para = new SqlParameter[]
|
|
{
|
|
new SqlParameter("@用药Id",useDrugsReport.用药Id), new SqlParameter("@加药时间",useDrugsReport.加药时间), new SqlParameter("@使用日期",useDrugsReport.使用日期), new SqlParameter("@患者姓名",useDrugsReport.患者姓名), new SqlParameter("@性别",useDrugsReport.性别), new SqlParameter("@年龄",useDrugsReport.年龄), new SqlParameter("@住院号",useDrugsReport.住院号), new SqlParameter("@病历号",useDrugsReport.病历号), new SqlParameter("@身份证号码",useDrugsReport.身份证号码), new SqlParameter("@疾病名称",useDrugsReport.疾病名称), new SqlParameter("@药品名称",useDrugsReport.药品名称), new SqlParameter("@剩余药品弃取记录",useDrugsReport.剩余药品弃取记录), new SqlParameter("@批号",useDrugsReport.批号), new SqlParameter("@处方剂量",useDrugsReport.处方剂量), new SqlParameter("@用量",useDrugsReport.用量), new SqlParameter("@残留剂量",useDrugsReport.残留剂量), new SqlParameter("@残液处理方式",useDrugsReport.残液处理方式), new SqlParameter("@残液处理地点",useDrugsReport.残液处理地点), new SqlParameter("@处方医师",useDrugsReport.处方医师), new SqlParameter("@执行护士",useDrugsReport.执行护士), new SqlParameter("@复核人",useDrugsReport.复核人), new SqlParameter("@核对护士",useDrugsReport.核对护士), new SqlParameter("@术间",useDrugsReport.术间), new SqlParameter("@医生签名",useDrugsReport.医生签名), new SqlParameter("@医生签名2",useDrugsReport.医生签名2), new SqlParameter("@护士签名",useDrugsReport.护士签名), new SqlParameter("@PatientRecordId",useDrugsReport.PatientRecordId), new SqlParameter("@State",useDrugsReport.State), new SqlParameter("@Num",useDrugsReport.Num), new SqlParameter("@SpecUnit",useDrugsReport.SpecUnit), new SqlParameter("@Enter",useDrugsReport.Enter), new SqlParameter("@镇痛泵使用量",useDrugsReport.镇痛泵使用量), new SqlParameter("@镇痛泵余量",useDrugsReport.镇痛泵余量)
|
|
};
|
|
return DBHelper.ExecNonQuery(sql, para);
|
|
}
|
|
public static int UpdateUseDrugsReport(UseDrugsReport useDrugsReport)
|
|
{
|
|
string sql = UpdateSql;
|
|
SqlParameter[] para = new SqlParameter[]
|
|
{
|
|
new SqlParameter("@Id",useDrugsReport.Id), new SqlParameter("@用药Id",useDrugsReport.用药Id), new SqlParameter("@加药时间",useDrugsReport.加药时间), new SqlParameter("@使用日期",useDrugsReport.使用日期), new SqlParameter("@患者姓名",useDrugsReport.患者姓名), new SqlParameter("@性别",useDrugsReport.性别), new SqlParameter("@年龄",useDrugsReport.年龄), new SqlParameter("@住院号",useDrugsReport.住院号), new SqlParameter("@病历号",useDrugsReport.病历号), new SqlParameter("@身份证号码",useDrugsReport.身份证号码), new SqlParameter("@疾病名称",useDrugsReport.疾病名称), new SqlParameter("@药品名称",useDrugsReport.药品名称), new SqlParameter("@剩余药品弃取记录",useDrugsReport.剩余药品弃取记录), new SqlParameter("@批号",useDrugsReport.批号), new SqlParameter("@处方剂量",useDrugsReport.处方剂量), new SqlParameter("@用量",useDrugsReport.用量), new SqlParameter("@残留剂量",useDrugsReport.残留剂量), new SqlParameter("@残液处理方式",useDrugsReport.残液处理方式), new SqlParameter("@残液处理地点",useDrugsReport.残液处理地点), new SqlParameter("@处方医师",useDrugsReport.处方医师), new SqlParameter("@执行护士",useDrugsReport.执行护士), new SqlParameter("@复核人",useDrugsReport.复核人), new SqlParameter("@核对护士",useDrugsReport.核对护士), new SqlParameter("@术间",useDrugsReport.术间), new SqlParameter("@医生签名",useDrugsReport.医生签名), new SqlParameter("@医生签名2",useDrugsReport.医生签名2), new SqlParameter("@护士签名",useDrugsReport.护士签名), new SqlParameter("@PatientRecordId",useDrugsReport.PatientRecordId), new SqlParameter("@State",useDrugsReport.State), new SqlParameter("@Num",useDrugsReport.Num), new SqlParameter("@SpecUnit",useDrugsReport.SpecUnit), new SqlParameter("@Enter",useDrugsReport.Enter), new SqlParameter("@镇痛泵使用量",useDrugsReport.镇痛泵使用量), new SqlParameter("@镇痛泵余量",useDrugsReport.镇痛泵余量)
|
|
};
|
|
return DBHelper.ExecNonQuery(sql, para);
|
|
}
|
|
public static int DelUseDrugsReport(UseDrugsReport useDrugsReport)
|
|
{
|
|
string sql = DeleteSql;
|
|
SqlParameter[] para = new SqlParameter[]
|
|
{
|
|
new SqlParameter("@Id",useDrugsReport.Id)
|
|
};
|
|
return DBHelper.ExecNonQuery(sql, para);
|
|
}
|
|
public static int DelUseDrugsReport(int id)
|
|
{
|
|
string sql = DeleteSql;
|
|
SqlParameter[] para = new SqlParameter[]
|
|
{
|
|
new SqlParameter("@Id",id)
|
|
};
|
|
return DBHelper.ExecNonQuery(sql, para);
|
|
}
|
|
public static IList<UseDrugsReport> GetAllList()
|
|
{
|
|
string sql = SelectSql;
|
|
return GetListBySql(sql);
|
|
}
|
|
|
|
|
|
public static UseDrugsReport GetUseDrugsReportById(int Id)
|
|
{
|
|
string sql = SelectSqlById;
|
|
SqlParameter para = new SqlParameter("@Id", Id);
|
|
IList<UseDrugsReport> list = GetListBySql(sql, para);
|
|
if (list.Count > 0)
|
|
return list[0];
|
|
else
|
|
return null;
|
|
}
|
|
|
|
public static IList<UseDrugsReport> GetListByDateTime(string BeginDate, string EndDate)
|
|
{
|
|
//string sql = "Select *,(select top 1 orderby from [dbo].[OperationRoom] where Name=术间 and IsValid=1) roomorder FROM UseDrugsReport where 使用日期>=CONVERT(VARCHAR(10),'" + BeginDate + "',120) AND 使用日期<=CONVERT(VARCHAR(10),'" + EndDate + "',120) ORDER BY 使用日期 DESC,roomorder";
|
|
string sql = "Select *,(select top 1 orderby from [dbo].[OperationRoom] where Name=术间 and IsValid=1) roomorder FROM UseDrugsReport where 使用日期>=CONVERT(VARCHAR(10),'" + BeginDate + "',120) AND 使用日期<=CONVERT(VARCHAR(10),'" + EndDate + "',120) ORDER BY 处方医师";
|
|
return GetListBySql(sql);
|
|
}
|
|
|
|
public static IList<UseDrugsReport> GetListByDateTimeWork(string BeginDate, string EndDate, int RecordId)
|
|
{
|
|
//string sql = "Select * FROM UseDrugsReport where 使用日期>=CONVERT(VARCHAR(10),'" + BeginDate + "',120) AND 使用日期<=CONVERT(VARCHAR(10),'" + EndDate + "',120) and PatientRecordId= '" + RecordId + "' ORDER BY 使用日期 DESC";
|
|
string sql = "Select * FROM UseDrugsReport where 使用日期>=CONVERT(VARCHAR(10),'" + BeginDate + "',120) AND 使用日期<=CONVERT(VARCHAR(10),'" + EndDate + "',120) and PatientRecordId= '" + RecordId + "' ORDER BY 处方医师";
|
|
return GetListBySql(sql);
|
|
}
|
|
|
|
private static IList<UseDrugsReport> GetListBySql(string sql, params SqlParameter[] para)
|
|
{
|
|
IList<UseDrugsReport> list = new List<UseDrugsReport>();
|
|
using (SqlConnection conn = new SqlConnection(Connection.ConnectionString))
|
|
{
|
|
if (conn.State != ConnectionState.Open)
|
|
conn.Open();
|
|
SqlCommand cmd = new SqlCommand(sql, conn);
|
|
cmd.Parameters.AddRange(para);
|
|
using (SqlDataReader reader = cmd.ExecuteReader(CommandBehavior.CloseConnection))
|
|
{
|
|
while (reader.Read())
|
|
{
|
|
UseDrugsReport temp = new UseDrugsReport();
|
|
|
|
temp.Id = DBHelper.GetInt(reader["Id"]);
|
|
temp.用药Id = DBHelper.GetInt(reader["用药Id"]);
|
|
if (reader["PatientRecordId"].ToString().Length > 1)
|
|
{
|
|
temp.PatientRecordId = DBHelper.GetInt(reader["PatientRecordId"]);
|
|
}
|
|
if (reader["State"].ToString().Length > 0)
|
|
{
|
|
temp.State = DBHelper.GetInt(reader["State"]);
|
|
}
|
|
temp.加药时间 = DBHelper.GetDateTime(reader["加药时间"]);
|
|
temp.使用日期 = DBHelper.GetString(reader["使用日期"]);
|
|
temp.患者姓名 = DBHelper.GetString(reader["患者姓名"]);
|
|
temp.性别 = DBHelper.GetString(reader["性别"]);
|
|
temp.年龄 = DBHelper.GetString(reader["年龄"]);
|
|
temp.住院号 = DBHelper.GetString(reader["住院号"]);
|
|
temp.病历号 = DBHelper.GetString(reader["病历号"]);
|
|
temp.身份证号码 = DBHelper.GetString(reader["身份证号码"]);
|
|
temp.疾病名称 = DBHelper.GetString(reader["疾病名称"]);
|
|
temp.药品名称 = DBHelper.GetString(reader["药品名称"]);
|
|
temp.剩余药品弃取记录 = DBHelper.GetString(reader["剩余药品弃取记录"]);
|
|
temp.批号 = DBHelper.GetString(reader["批号"]);
|
|
temp.处方剂量 = DBHelper.GetString(reader["处方剂量"]);
|
|
temp.用量 = DBHelper.GetString(reader["用量"]);
|
|
temp.残留剂量 = DBHelper.GetString(reader["残留剂量"]);
|
|
temp.残液处理方式 = DBHelper.GetString(reader["残液处理方式"]);
|
|
temp.残液处理地点 = DBHelper.GetString(reader["残液处理地点"]);
|
|
temp.处方医师 = DBHelper.GetString(reader["处方医师"]);
|
|
temp.执行护士 = DBHelper.GetString(reader["执行护士"]);
|
|
temp.复核人 = DBHelper.GetString(reader["复核人"]);
|
|
temp.核对护士 = DBHelper.GetString(reader["核对护士"]);
|
|
temp.术间 = DBHelper.GetString(reader["术间"]);
|
|
temp.医生签名 = DBHelper.GetString(reader["医生签名"]);
|
|
temp.医生签名2 = DBHelper.GetString(reader["医生签名2"]);
|
|
temp.护士签名 = DBHelper.GetString(reader["护士签名"]);
|
|
if (reader["PatientRecordId"] != null)
|
|
{
|
|
temp.PatientRecordId = DBHelper.GetInt(reader["PatientRecordId"]);
|
|
}
|
|
temp.State = DBHelper.GetInt(reader["State"]);
|
|
temp.Enter = DBHelper.GetInt(reader["Enter"]);
|
|
if (reader["Num"].ToString() != "")
|
|
{
|
|
temp.Num = DBHelper.GetInt(reader["Num"]);
|
|
}
|
|
temp.SpecUnit = DBHelper.GetString(reader["SpecUnit"]);
|
|
temp.镇痛泵使用量 = DBHelper.GetString(reader["镇痛泵使用量"]);
|
|
temp.镇痛泵余量 = DBHelper.GetString(reader["镇痛泵余量"]);
|
|
|
|
if (temp.医生签名 != null && temp.医生签名 != "")
|
|
{
|
|
temp.医生签名Img = BytesToImage(Convert.FromBase64String(temp.医生签名));
|
|
}
|
|
|
|
if (temp.护士签名 != null && temp.护士签名 != "")
|
|
{
|
|
temp.护士签名Img = BytesToImage(Convert.FromBase64String(temp.护士签名));
|
|
}
|
|
list.Add(temp);
|
|
}
|
|
reader.Close();
|
|
return list;
|
|
}
|
|
}
|
|
}
|
|
public static DataTable GetUseDrugsReport(string BeginDate, string EndDate)
|
|
{
|
|
string strSql = "EXEC [SP_UseDrugsReport] '" + BeginDate + "','" + EndDate + "' ";
|
|
return DBHelper.GetDataTable(strSql); ;
|
|
}
|
|
public static DataTable GetUseDrugsReportById(string OperationRecordId)
|
|
{
|
|
string strSql = "EXEC [SP_UseDrugsReportById] '" + OperationRecordId + "' ";
|
|
return DBHelper.GetDataTable(strSql);
|
|
}
|
|
/// <summary>
|
|
/// Byte[]转Image
|
|
/// </summary>
|
|
/// <param name="buffer"></param>
|
|
/// <returns></returns>
|
|
public static Image BytesToImage(byte[] buffer)
|
|
{
|
|
MemoryStream ms = new MemoryStream(buffer);
|
|
Image image = Image.FromStream(ms);
|
|
return image;
|
|
}
|
|
public static DataTable GetUseDrugsNotRegister(string begin,string end)
|
|
{
|
|
string sql = "exec SP_UseDrugsNotRegister '" + begin + "','" + end + "'";
|
|
return DBHelper.GetDataTable(sql);
|
|
}
|
|
}
|
|
}
|
|
|
|
|