93 lines
3.5 KiB
C#
93 lines
3.5 KiB
C#
using System;
|
|
using AIMSDAL;
|
|
using AIMSModel;
|
|
using AIMSObjectQuery;
|
|
using System.Collections;
|
|
using System.Collections.Generic;
|
|
using System.Data;
|
|
using HelperDB;
|
|
using AIMSExtension;
|
|
using System.Data.SqlClient;
|
|
|
|
namespace AIMSBLL
|
|
{
|
|
public partial class BOperationRecord
|
|
{
|
|
|
|
/// <summary>
|
|
/// 得到手术的最大时间点
|
|
/// </summary>
|
|
/// <param name="doOpeInfo"></param>
|
|
/// <returns></returns>
|
|
public static DateTime lastMaxOperationDate(int PatientId)
|
|
{
|
|
string sqlStr = "select top 1 * from (SELECT s.PatientId , s.EventEndTime etime FROM FactEvents s WHERE s.PatientId = " + PatientId + " union all SELECT s.PatientId , s.DrugEndTime FROM[dbo].[FactDrug] s WHERE s.PatientId = " + PatientId + " ) a order by a.etime desc";
|
|
DataTable dt = DBHelper.GetDataTable(sqlStr);
|
|
return DateTime.Parse(dt.Rows[0][1].ToString());
|
|
}
|
|
|
|
public static DataTable getPhysioDataByTimeName(string IP, string name, DateTime starttime, DateTime endtime)
|
|
{
|
|
DataTable dt = new DataTable();
|
|
string sqlStr = " exec [usp_GetPhysioDataByName] '" + IP + "','" + name + "','" + starttime + "','" + endtime + "'";//
|
|
dt = DATADBHelper.GetDataTable(sqlStr);
|
|
return dt;
|
|
}
|
|
|
|
public static DataTable getPhysioDataByIp(string IP, int operationId, DateTime starttime, DateTime endtime, int collectInterval)
|
|
{
|
|
DataTable dt = new DataTable();
|
|
string sqlStr = " exec [usp_GetPhysioDataByIp] '" + IP + "','" + starttime + "','" + endtime + "'," + collectInterval;
|
|
dt = DATADBHelper.GetDataTable(sqlStr);
|
|
foreach (DataRow item in dt.Rows)
|
|
{
|
|
if (item[0].ToString() == "7")
|
|
{
|
|
foreach (DataRow item1 in dt.Rows)
|
|
{
|
|
if (item1[0].ToString() == "5" && item1[1].ToString() == item[1].ToString())
|
|
{
|
|
item1[2] = "0";
|
|
}
|
|
}
|
|
}
|
|
if (item[0].ToString() == "8")
|
|
{
|
|
foreach (DataRow item1 in dt.Rows)
|
|
{
|
|
if (item1[0].ToString() == "6" && item1[1].ToString() == item[1].ToString())
|
|
{
|
|
item1[2] = "0";
|
|
}
|
|
}
|
|
}
|
|
}
|
|
return dt;
|
|
}
|
|
|
|
public static int Update(string oql, ParameterList parameters)
|
|
{
|
|
using (SqlConnection conn = new SqlConnection(Connection.ConnectionString))
|
|
{
|
|
conn.Open();
|
|
using (SqlCommand cmd = conn.CreateCommand())
|
|
{
|
|
//解析过滤部份Sql语句
|
|
string updateString = oql;// SyntaxAnalyzer.ParseSql(oql, new OperationRecordMap());
|
|
cmd.CommandText = "update OperationRecord set " + updateString;
|
|
cmd.Parameters.Clear();
|
|
//添加参数
|
|
if (parameters != null)
|
|
{
|
|
foreach (string key in parameters.Keys)
|
|
{
|
|
cmd.Parameters.Add(new SqlParameter(key, parameters[key]));
|
|
}
|
|
}
|
|
return cmd.ExecuteNonQuery();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|