You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
279 lines
11 KiB
279 lines
11 KiB
9 months ago
|
using System;
|
||
|
|
using System.Collections.Generic;
|
||
|
|
using System.Linq;
|
||
|
|
using System.Text;
|
||
|
|
|
||
|
|
using System.Data;
|
||
|
|
using MySql.Data.MySqlClient;
|
||
|
|
|
||
|
|
namespace FangYar.OracleDAL.ZHSQ
|
||
|
|
{
|
||
|
|
public class WarnHandleDAL : FangYar.IDAL.ZHSQ.WarnHandleIDAL
|
||
|
|
{
|
||
|
|
|
||
|
|
#region 私有方法
|
||
|
|
/// <summary>
|
||
|
|
/// DataRow转model实体类对象
|
||
|
|
/// </summary>
|
||
|
|
private void DataRowToModel(Model.ZHSQ.ZHSQ_WARN_HANDLE_Model model, DataRow dr)
|
||
|
|
{
|
||
|
|
if (!DBNull.Value.Equals(dr["ID"]))
|
||
|
|
model.ID = dr["ID"].ToString();
|
||
|
|
|
||
|
|
if (!DBNull.Value.Equals(dr["RECORD_ID"]))
|
||
|
|
model.RECORD_ID = dr["RECORD_ID"].ToString();
|
||
|
|
if (!DBNull.Value.Equals(dr["HANDLE_STATE"]))
|
||
|
|
model.HANDLE_STATE = dr["HANDLE_STATE"].ToString();
|
||
|
|
if (!DBNull.Value.Equals(dr["HANDLE_TIME"]))
|
||
|
|
model.HANDLE_TIME = Convert.ToDateTime(dr["HANDLE_TIME"].ToString());
|
||
|
|
if (!DBNull.Value.Equals(dr["HANDLE_DES"]))
|
||
|
|
model.HANDLE_DES = dr["HANDLE_DES"].ToString();
|
||
|
|
if (!DBNull.Value.Equals(dr["HANDLE_USERS"]))
|
||
|
|
model.HANDLE_USERS = dr["HANDLE_USERS"].ToString();
|
||
|
|
if (!DBNull.Value.Equals(dr["HANDLE_PICS"]))
|
||
|
|
model.HANDLE_PICS = dr["HANDLE_PICS"].ToString();
|
||
|
|
if (!DBNull.Value.Equals(dr["HANDLE_TIMES"]))
|
||
|
|
model.HANDLE_TIMES = dr["HANDLE_TIMES"].ToString();
|
||
|
|
}
|
||
|
|
/// <summary>
|
||
|
|
/// DataRow转model实体类对象
|
||
|
|
/// </summary>
|
||
|
|
private Model.ZHSQ.ZHSQ_WARN_HANDLE_Model DataRowToModel(DataRow dr)
|
||
|
|
{
|
||
|
|
Model.ZHSQ.ZHSQ_WARN_HANDLE_Model model = new Model.ZHSQ.ZHSQ_WARN_HANDLE_Model();
|
||
|
|
if (!DBNull.Value.Equals(dr["ID"]))
|
||
|
|
model.ID = dr["ID"].ToString();
|
||
|
|
|
||
|
|
if (!DBNull.Value.Equals(dr["RECORD_ID"]))
|
||
|
|
model.RECORD_ID = dr["RECORD_ID"].ToString();
|
||
|
|
if (!DBNull.Value.Equals(dr["HANDLE_STATE"]))
|
||
|
|
model.HANDLE_STATE = dr["HANDLE_STATE"].ToString();
|
||
|
|
if (!DBNull.Value.Equals(dr["HANDLE_TIME"]))
|
||
|
|
model.HANDLE_TIME = Convert.ToDateTime(dr["HANDLE_TIME"].ToString());
|
||
|
|
if (!DBNull.Value.Equals(dr["HANDLE_DES"]))
|
||
|
|
model.HANDLE_DES = dr["HANDLE_DES"].ToString();
|
||
|
|
if (!DBNull.Value.Equals(dr["HANDLE_USERS"]))
|
||
|
|
model.HANDLE_USERS = dr["HANDLE_USERS"].ToString();
|
||
|
|
if (!DBNull.Value.Equals(dr["HANDLE_PICS"]))
|
||
|
|
model.HANDLE_PICS = dr["HANDLE_PICS"].ToString();
|
||
|
|
if (!DBNull.Value.Equals(dr["HANDLE_TIMES"]))
|
||
|
|
model.HANDLE_TIMES = dr["HANDLE_TIMES"].ToString();
|
||
|
|
return model;
|
||
|
|
}
|
||
|
|
/// <summary>
|
||
|
|
/// 把DataTable行转成实体类List集合
|
||
|
|
/// </summary>
|
||
|
|
private List<FangYar.Model.ZHSQ.ZHSQ_WARN_HANDLE_Model> DataTableToList(DataTable dt)
|
||
|
|
{
|
||
|
|
List<FangYar.Model.ZHSQ.ZHSQ_WARN_HANDLE_Model> modellist = new List<Model.ZHSQ.ZHSQ_WARN_HANDLE_Model>();
|
||
|
|
if (dt.Rows.Count > 0)
|
||
|
|
{
|
||
|
|
foreach (DataRow myRow in dt.Rows)
|
||
|
|
{
|
||
|
|
modellist.Add(DataRowToModel(myRow));
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return modellist;
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
#endregion
|
||
|
|
|
||
|
|
#region 基本方法
|
||
|
|
/// <summary>
|
||
|
|
/// 根据ID获取model
|
||
|
|
/// </summary>
|
||
|
|
public FangYar.Model.ZHSQ.ZHSQ_WARN_HANDLE_Model GetModelByID(string ID)
|
||
|
|
{
|
||
|
|
Model.ZHSQ.ZHSQ_WARN_HANDLE_Model model = null;
|
||
|
|
string sql = "select * from ZHSQ_WARN_HANDLE where ID=@ID";
|
||
|
|
MySqlParameter[] paras = { new MySqlParameter("@ID", ID) };
|
||
|
|
DataTable dt = FangYar.Common.MySqlHelper.QueryTable(sql, paras);
|
||
|
|
if (dt.Rows.Count > 0)
|
||
|
|
{
|
||
|
|
model = new Model.ZHSQ.ZHSQ_WARN_HANDLE_Model();
|
||
|
|
DataRowToModel(model, dt.Rows[0]);
|
||
|
|
return model;
|
||
|
|
|
||
|
|
}
|
||
|
|
else
|
||
|
|
{
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
}
|
||
|
|
/// <summary>
|
||
|
|
/// 添加
|
||
|
|
/// </summary>
|
||
|
|
public bool Add(FangYar.Model.ZHSQ.ZHSQ_WARN_HANDLE_Model model)
|
||
|
|
{
|
||
|
|
StringBuilder strsql = new StringBuilder();
|
||
|
|
strsql.Append("insert into ZHSQ_WARN_HANDLE (RECORD_ID,HANDLE_STATE,HANDLE_TIME,HANDLE_DES,HANDLE_USERS,HANDLE_PICS,HANDLE_TIMES)");
|
||
|
|
strsql.Append("values");
|
||
|
|
strsql.Append("(@RECORD_ID,@HANDLE_STATE,@HANDLE_TIME,@HANDLE_DES,@HANDLE_USERS,@HANDLE_PICS,@HANDLE_TIMES)");
|
||
|
|
MySqlParameter[] paras ={
|
||
|
|
new MySqlParameter("@RECORD_ID",model.RECORD_ID),
|
||
|
|
new MySqlParameter("@HANDLE_STATE",model.HANDLE_STATE),
|
||
|
|
new MySqlParameter("@HANDLE_TIME",model.HANDLE_TIME),
|
||
|
|
new MySqlParameter("@HANDLE_DES",model.HANDLE_DES),
|
||
|
|
new MySqlParameter("@HANDLE_USERS",model.HANDLE_USERS),
|
||
|
|
new MySqlParameter("@HANDLE_PICS",model.HANDLE_PICS),
|
||
|
|
new MySqlParameter("@HANDLE_TIMES",model.HANDLE_TIMES)
|
||
|
|
};
|
||
|
|
int i = FangYar.Common.MySqlHelper.ExecuteSql(strsql.ToString(), paras);
|
||
|
|
if (i > 0)
|
||
|
|
{
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
else
|
||
|
|
{
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|
||
|
|
/// <summary>
|
||
|
|
/// 删除
|
||
|
|
/// </summary>
|
||
|
|
public bool Delete(string IDList)
|
||
|
|
{
|
||
|
|
string sql = "delete from ZHSQ_WARN_HANDLE where ID in('" + IDList + "')";
|
||
|
|
try
|
||
|
|
{
|
||
|
|
FangYar.Common.MySqlHelper.ExecuteSql(sql);
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
catch
|
||
|
|
{
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|
||
|
|
/// <summary>
|
||
|
|
/// 编辑
|
||
|
|
/// </summary>
|
||
|
|
public bool Edit(FangYar.Model.ZHSQ.ZHSQ_WARN_HANDLE_Model model)
|
||
|
|
{
|
||
|
|
StringBuilder strsql = new StringBuilder();
|
||
|
|
strsql.Append("update ZHSQ_WARN_HANDLE set ");
|
||
|
|
strsql.Append("RECORD_ID=@RECORD_ID,");
|
||
|
|
strsql.Append("HANDLE_STATE=@HANDLE_STATE,");
|
||
|
|
strsql.Append("HANDLE_TIME=@HANDLE_TIME,");
|
||
|
|
strsql.Append("HANDLE_DES=@HANDLE_DES,");
|
||
|
|
strsql.Append("HANDLE_USERS=@HANDLE_USERS,");
|
||
|
|
strsql.Append("HANDLE_PICS=@HANDLE_PICS,");
|
||
|
|
strsql.Append("HANDLE_TIMES=@HANDLE_TIMES ");
|
||
|
|
strsql.Append(" where ID=@ID");
|
||
|
|
MySqlParameter[] paras ={
|
||
|
|
new MySqlParameter("@RECORD_ID",model.RECORD_ID),
|
||
|
|
new MySqlParameter("@HANDLE_STATE",model.HANDLE_STATE),
|
||
|
|
new MySqlParameter("@HANDLE_TIME",model.HANDLE_TIME),
|
||
|
|
new MySqlParameter("@HANDLE_DES",model.HANDLE_DES),
|
||
|
|
new MySqlParameter("@HANDLE_USERS",model.HANDLE_USERS),
|
||
|
|
new MySqlParameter("@HANDLE_PICS",model.HANDLE_PICS),
|
||
|
|
new MySqlParameter("@HANDLE_TIMES",model.HANDLE_TIMES),
|
||
|
|
new MySqlParameter("@ID",model.ID)
|
||
|
|
};
|
||
|
|
int i = FangYar.Common.MySqlHelper.ExecuteSql(strsql.ToString(), paras);
|
||
|
|
if (i > 0) { return true; }
|
||
|
|
else { return false; }
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
#endregion
|
||
|
|
|
||
|
|
#region 分页
|
||
|
|
|
||
|
|
/// <summary>
|
||
|
|
/// 分页无排序
|
||
|
|
/// </summary>
|
||
|
|
/// <param name="PageIndex">页面索引</param>
|
||
|
|
/// <param name="PageSize">页面大小</param>
|
||
|
|
/// <param name="strwhere">查询条件</param>
|
||
|
|
/// <returns></returns>
|
||
|
|
public string QueryJsonList(int PageIndex, int PageSize, string strwhere)
|
||
|
|
{
|
||
|
|
|
||
|
|
return FangYar.Common.JsonHelper.ToJson(QueryPage(PageIndex, PageSize, strwhere));
|
||
|
|
}
|
||
|
|
/// <summary>
|
||
|
|
/// 分页无排序
|
||
|
|
/// </summary>
|
||
|
|
/// <param name="PageIndex">页面索引</param>
|
||
|
|
/// <param name="PageSize">页面大小</param>
|
||
|
|
/// <param name="strwhere">查询条件</param>
|
||
|
|
/// <returns></returns>
|
||
|
|
public string QueryJsonList(int PageIndex, int PageSize, string strwhere, string order)
|
||
|
|
{
|
||
|
|
|
||
|
|
return FangYar.Common.JsonHelper.ToJson(QueryPage(PageIndex, PageSize, strwhere, order));
|
||
|
|
}
|
||
|
|
/// <summary>
|
||
|
|
/// 分页无排序
|
||
|
|
/// </summary>
|
||
|
|
/// <param name="PageIndex">页面索引</param>
|
||
|
|
/// <param name="PageSize">页面大小</param>
|
||
|
|
/// <param name="strwhere">查询条件</param>
|
||
|
|
/// <returns></returns>
|
||
|
|
public List<FangYar.Model.ZHSQ.ZHSQ_WARN_HANDLE_Model> QueryList(int PageIndex, int PageSize, string strwhere)
|
||
|
|
{
|
||
|
|
|
||
|
|
return DataTableToList(QueryPage(PageIndex, PageSize, strwhere));
|
||
|
|
}
|
||
|
|
/// <summary>
|
||
|
|
/// 分页无排序
|
||
|
|
/// </summary>
|
||
|
|
/// <param name="PageIndex">页面索引</param>
|
||
|
|
/// <param name="PageSize">页面大小</param>
|
||
|
|
/// <param name="strwhere">查询条件</param>
|
||
|
|
/// <returns></returns>
|
||
|
|
public List<FangYar.Model.ZHSQ.ZHSQ_WARN_HANDLE_Model> QueryList(int PageIndex, int PageSize, string strwhere, string order)
|
||
|
|
{
|
||
|
|
|
||
|
|
return DataTableToList(QueryPage(PageIndex, PageSize, strwhere, order));
|
||
|
|
}
|
||
|
|
/// <summary>
|
||
|
|
/// 分页无排序
|
||
|
|
/// </summary>
|
||
|
|
/// <param name="PageIndex">页面索引</param>
|
||
|
|
/// <param name="PageSize">页面大小</param>
|
||
|
|
/// <param name="strwhere">查询条件</param>
|
||
|
|
/// <returns></returns>
|
||
|
|
public DataTable QueryPage(int PageIndex, int PageSize, string strwhere)
|
||
|
|
{
|
||
|
|
|
||
|
|
return FangYar.Common.MySqlHelper.QueryPage(PageIndex, PageSize, "ZHSQ_WARN_HANDLE", strwhere);
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary>
|
||
|
|
/// 分页无排序
|
||
|
|
/// </summary>
|
||
|
|
/// <param name="PageIndex">页面索引</param>
|
||
|
|
/// <param name="PageSize">页面大小</param>
|
||
|
|
/// <param name="strwhere">查询条件</param>
|
||
|
|
/// <param name="strwhere">排序</param>
|
||
|
|
/// <returns></returns>
|
||
|
|
public DataTable QueryPage(int PageIndex, int PageSize, string strwhere, string order)
|
||
|
|
{
|
||
|
|
|
||
|
|
return FangYar.Common.MySqlHelper.QueryPage(PageIndex, PageSize, "ZHSQ_WARN_HANDLE", strwhere, order);
|
||
|
|
}
|
||
|
|
/// <summary>
|
||
|
|
/// 存储过程分页
|
||
|
|
/// </summary>
|
||
|
|
/// <param name="PageIndex">页面索引</param>
|
||
|
|
/// <param name="PageSize">页面大小</param>
|
||
|
|
/// <param name="strwhere">查询条件</param>
|
||
|
|
/// <param name="strwhere">排序</param>
|
||
|
|
/// <returns></returns>
|
||
|
|
public void QueryProc(int PageIndex, int PageSize, string strwhere, string order)
|
||
|
|
{
|
||
|
|
int totalcount = 0;
|
||
|
|
FangYar.Common.SqlPagerHelperOra.Select(PageSize, PageIndex, out totalcount, "ZHSQ_WARN_HANDLE", "*", null, null, null);
|
||
|
|
|
||
|
|
|
||
|
|
}
|
||
|
|
#endregion
|
||
|
|
}
|
||
|
|
}
|