using DataRWDAL.Base;
|
using SqlSugar;
|
using System.Collections.Generic;
|
using System.Collections.ObjectModel;
|
using System.ComponentModel;
|
using System.Dynamic;
|
using System.Reflection;
|
using System.Runtime.InteropServices.Expando;
|
using XImagingXhandler.XDAL;
|
|
namespace DataRWDAL
|
{
|
/// <summary>
|
/// 液体类型与液体范围关系库表操作类
|
/// </summary>
|
public class LiquidTypeRSRangeDB:BaseDB
|
{
|
#region 查询返回液体类型数据集 by 查询请求参数
|
/// <summary>
|
/// 查询返回液体类型数据集 by 查询请求参数
|
/// </summary>
|
/// <param name="lType">1:默认类型；0：非默认；2：全部类型</param>
|
/// <returns>液体类型数据集</returns>
|
public static List<LiquidType> GetLiquidTypeFromdb(int lType)
|
{
|
List<LiquidType> liquidTypes = new List<LiquidType>();
|
using (var db = GetInstance())
|
{
|
if (lType == 1 || lType == 0)
|
{
|
liquidTypes = db.Queryable<LiquidType>().Where(it => it.is_default_type.Equals(lType)).OrderBy(it => it.timestamp, SqlSugar.OrderByType.Asc).ToList();
|
LiquidType lbt = new LiquidType();
|
lbt.liquid_type_id = "0";
|
lbt.liquid_type_name = "所有类型";
|
lbt.liquid_type_name_en = "All";
|
liquidTypes.Insert(0,lbt);
|
}
|
else if (lType == 2)
|
{
|
liquidTypes = db.Queryable<LiquidType>().OrderBy(it => it.timestamp, SqlSugar.OrderByType.Asc).ToList();
|
LiquidType lbt = new LiquidType();
|
lbt.liquid_type_id = "0";
|
lbt.liquid_type_name = "所有类型";
|
lbt.liquid_type_name_en = "All";
|
liquidTypes.Insert(0,lbt);
|
}
|
else
|
{
|
LiquidType lbt = new LiquidType();
|
lbt.liquid_type_id = "0";
|
lbt.liquid_type_name = "所有类型";
|
lbt.liquid_type_name_en = "All";
|
liquidTypes.Insert(0, lbt);
|
}
|
}
|
return liquidTypes;
|
}
|
#endregion
|
|
#region 查询返回液体参数数据集 by 液体类型Id、液体范围Id、设备臂Id
|
/// <summary>
|
/// 查询返回液体参数数据集 by 液体类型Id、液体范围Id、设备臂Id
|
/// </summary>
|
/// <param name="liquidTypeId">液体类型Id</param>
|
/// <param name="liquidRangeId">液体范围Id</param>
|
/// <param name="armId">设备臂Id</param>
|
/// <returns>液体参数数据集</returns>
|
public static ObservableCollection<Liquid> GetLiquidFromdbByTypeAndRange(string liquidTypeId, string liquidRangeId, string armId)
|
{
|
using (var db = GetInstance())
|
{
|
//string sqlstr = "select t.liquid_type_id,lt.liquid_type_name,lt.liquid_type_name_en,lr.liquid_range_name,lr.liquid_range_name_en,t.liquid_range_id,t.device_arm_id,l.* from liquidtypersrange t, liquid l,liquidtype lt,liquidrange lr where t.liquid_id=l.liquid_id and t.liquid_type_id=lt.liquid_type_id and t.liquid_range_id=lr.liquid_range_id and t.liquid_type_id='" + liquidTypeId + "' and t.liquid_range_id='" + liquidRangeId + "' and t.device_arm_id=" + armId + " and t.liquid_rs_status=1";
|
|
// 多表查询
|
var query = db.Queryable("LiquidTypeRSRange", "t").AddJoinInfo("Liquid", "l", "t.liquid_id=l.liquid_id and t.liquid_type_id='"+liquidTypeId+"' and t.liquid_range_id='"+ liquidRangeId+ "' and t.device_arm_id="+armId.ToString()+" and t.liquid_rs_status=1 and l.liquid_status=1", JoinType.Inner)
|
.AddJoinInfo("LiquidType", "lt", "lt.liquid_type_id=t.liquid_type_id", JoinType.Inner)
|
.AddJoinInfo("LiquidRange", "lr", "lr.liquid_range_id=t.liquid_range_id", JoinType.Inner)
|
.Select("t.liquid_type_id,lt.liquid_type_name,lt.liquid_type_name_en,lr.liquid_range_name,lr.liquid_range_name_en,t.liquid_range_id,t.device_arm_id,l.*");
|
var a = query.ToList();
|
ObservableCollection<Liquid> liquids = new ObservableCollection<Liquid>();
|
foreach(ExpandoObject epo in a)
|
{
|
Liquid lq= epo.ToEntity<Liquid>();
|
lq.device_arm_id = armId;
|
liquids.Add(lq);
|
}
|
var result = liquids;
|
return result;
|
}
|
}
|
#endregion
|
|
#region 添加一条新的液体类型与液体范围关系数据 by 液体类型与液体范围关系对象
|
/// <summary>
|
/// 添加一条新的液体类型与液体范围关系数据 by 液体类型与液体范围关系对象
|
/// </summary>
|
/// <param name="liquidTypeRSRange">液体类型与液体范围关系对象</param>
|
/// <returns>1:成功；0：失败</returns>
|
public static int AddLiquidTypeRSRangeIntodb(LiquidTypeRSRange liquidTypeRSRange)
|
{
|
using (var db = GetInstance())
|
{
|
return db.Insertable<LiquidTypeRSRange>(liquidTypeRSRange).ExecuteCommand();
|
}
|
}
|
#endregion
|
|
#region 修改一条液体类型与液体范围关系数据 by 液体类型与液体范围关系对象的Id、液体类型Id、设备臂Id、数据状态
|
/// <summary>
|
/// 修改一条液体类型与液体范围关系数据 by 液体类型与液体范围关系对象的Id、液体类型Id、设备臂Id、数据状态
|
/// </summary>
|
/// <param name="liquidTypeRSRange">液体类型与液体范围关系对象</param>
|
/// <returns>1:成功；0：失败</returns>
|
public static int UpdateLiquidTypeRSRangeIntodb(LiquidTypeRSRange liquidTypeRSRange)
|
{
|
using (var db = GetInstance())
|
{
|
return db.Updateable<LiquidTypeRSRange>(liquidTypeRSRange).Where(it=>it.liquid_range_id.Equals(liquidTypeRSRange.liquid_range_id)
|
&&it.liquid_type_id.Equals(liquidTypeRSRange.liquid_type_id)
|
&&it.device_arm_id.Equals(liquidTypeRSRange.device_arm_id)
|
&&it.liquid_rs_status.Equals(1)).ExecuteCommand();
|
}
|
}
|
#endregion
|
|
#region 删除一条新的液体类型与液体范围关系数据 by 液体类型与液体范围关系对象
|
/// <summary>
|
/// 删除一条新的液体类型与液体范围关系数据 by 液体类型与液体范围关系对象
|
/// </summary>
|
/// <param name="liquidTypeRSRange">液体类型与液体范围关系对象</param>
|
/// <returns>1：成功；0：失败</returns>
|
public static int DeleteLiquidTypeRSRangeIntodb(LiquidTypeRSRange liquidTypeRSRange)
|
{
|
using (var db = GetInstance())
|
{
|
return db.Updateable<LiquidTypeRSRange>(liquidTypeRSRange).Where(it => it.liquid_range_id.Equals(liquidTypeRSRange.liquid_range_id)
|
&& it.liquid_type_id.Equals(liquidTypeRSRange.liquid_type_id)
|
&& it.liquid_rs_status.Equals(1)).ExecuteCommand();
|
}
|
}
|
#endregion
|
}
|
|
/// <summary>
|
/// ExpandoObject 转化为实体类
|
/// </summary>
|
public static class ExpandoObjectExtensions
|
{
|
public static T ToEntity<T>(this ExpandoObject expando) where T : class, new()
|
{
|
var entity = new T();
|
var type = entity.GetType();
|
|
foreach (var property in expando)
|
{
|
var propName = property.Key;
|
var propValue = property.Value;
|
var prop = type.GetProperty(propName);
|
|
if (prop == null) continue;
|
|
if (propValue != null && prop.PropertyType.IsAssignableFrom(propValue.GetType()))
|
{
|
prop.SetValue(entity, propValue, null);
|
}
|
else if (propValue != null)
|
{
|
var converter = TypeDescriptor.GetConverter(prop.PropertyType);
|
if (converter.CanConvertFrom(propValue.GetType()))
|
{
|
prop.SetValue(entity, converter.ConvertFrom(propValue), null);
|
}
|
}
|
}
|
|
return entity;
|
}
|
}
|
}
|
