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.
311 lines
13 KiB
311 lines
13 KiB
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 CpyInfoDAL:FangYar.IDAL.ZHSQ.CpyInfoIDAL
|
|
{
|
|
|
|
#region 私有方法
|
|
/// <summary>
|
|
/// DataRow转model实体类对象
|
|
/// </summary>
|
|
private void DataRowToModel(Model.ZHSQ.ZHSQ_CPY_INFO_Model model, DataRow dr)
|
|
{
|
|
if (!DBNull.Value.Equals(dr["ID"]))
|
|
model.ID = dr["ID"].ToString();
|
|
if (!DBNull.Value.Equals(dr["CPY_CODE"]))
|
|
model.CPY_CODE = dr["CPY_CODE"].ToString();
|
|
if (!DBNull.Value.Equals(dr["CPY_NAME"]))
|
|
model.CPY_NAME = dr["CPY_NAME"].ToString();
|
|
if (!DBNull.Value.Equals(dr["GROUP_ID"]))
|
|
model.GROUP_ID = dr["GROUP_ID"].ToString();
|
|
if (!DBNull.Value.Equals(dr["CPY_CLASS"]))
|
|
model.CPY_CLASS = dr["CPY_CLASS"].ToString();
|
|
if (!DBNull.Value.Equals(dr["CPY_INDUSTRY"]))
|
|
model.CPY_INDUSTRY = dr["CPY_INDUSTRY"].ToString();
|
|
if (!DBNull.Value.Equals(dr["CPY_LOC"]))
|
|
model.CPY_LOC = dr["CPY_LOC"].ToString();
|
|
if (!DBNull.Value.Equals(dr["CPY_CONCACTS"]))
|
|
model.CPY_CONCACTS = dr["CPY_CONCACTS"].ToString();
|
|
if (!DBNull.Value.Equals(dr["CPY_TELNUM"]))
|
|
model.CPY_TELNUM = dr["CPY_TELNUM"].ToString();
|
|
if (!DBNull.Value.Equals(dr["CPY_DEVPOPNAME"]))
|
|
model.CPY_DEVPOPNAME = dr["CPY_DEVPOPNAME"].ToString();
|
|
if (!DBNull.Value.Equals(dr["CPY_DEVPOPTELNUM"]))
|
|
model.CPY_DEVPOPTELNUM = dr["CPY_DEVPOPTELNUM"].ToString();
|
|
}
|
|
/// <summary>
|
|
/// DataRow转model实体类对象
|
|
/// </summary>
|
|
private Model.ZHSQ.ZHSQ_CPY_INFO_Model DataRowToModel( DataRow dr)
|
|
{
|
|
Model.ZHSQ.ZHSQ_CPY_INFO_Model model = new Model.ZHSQ.ZHSQ_CPY_INFO_Model();
|
|
if (!DBNull.Value.Equals(dr["ID"]))
|
|
model.ID = dr["ID"].ToString();
|
|
if (!DBNull.Value.Equals(dr["CPY_CODE"]))
|
|
model.CPY_CODE = dr["CPY_CODE"].ToString();
|
|
if (!DBNull.Value.Equals(dr["CPY_NAME"]))
|
|
model.CPY_NAME = dr["CPY_NAME"].ToString();
|
|
if (!DBNull.Value.Equals(dr["GROUP_ID"]))
|
|
model.GROUP_ID = dr["GROUP_ID"].ToString();
|
|
if (!DBNull.Value.Equals(dr["CPY_CLASS"]))
|
|
model.CPY_CLASS = dr["CPY_CLASS"].ToString();
|
|
if (!DBNull.Value.Equals(dr["CPY_INDUSTRY"]))
|
|
model.CPY_INDUSTRY = dr["CPY_INDUSTRY"].ToString();
|
|
if (!DBNull.Value.Equals(dr["CPY_LOC"]))
|
|
model.CPY_LOC = dr["CPY_LOC"].ToString();
|
|
if (!DBNull.Value.Equals(dr["CPY_CONCACTS"]))
|
|
model.CPY_CONCACTS = dr["CPY_CONCACTS"].ToString();
|
|
if (!DBNull.Value.Equals(dr["CPY_TELNUM"]))
|
|
model.CPY_TELNUM = dr["CPY_TELNUM"].ToString();
|
|
if (!DBNull.Value.Equals(dr["CPY_DEVPOPNAME"]))
|
|
model.CPY_DEVPOPNAME = dr["CPY_DEVPOPNAME"].ToString();
|
|
if (!DBNull.Value.Equals(dr["CPY_DEVPOPTELNUM"]))
|
|
model.CPY_DEVPOPTELNUM = dr["CPY_DEVPOPTELNUM"].ToString();
|
|
return model;
|
|
}
|
|
/// <summary>
|
|
/// 把DataTable行转成实体类List集合
|
|
/// </summary>
|
|
private List<FangYar.Model.ZHSQ.ZHSQ_CPY_INFO_Model> DataTableToList(DataTable dt)
|
|
{
|
|
List<FangYar.Model.ZHSQ.ZHSQ_CPY_INFO_Model> modellist = new List<Model.ZHSQ.ZHSQ_CPY_INFO_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_CPY_INFO_Model GetModelByID(string ID)
|
|
{
|
|
Model.ZHSQ.ZHSQ_CPY_INFO_Model model = null;
|
|
string sql = "select * from ZHSQ_CPY_INFO where ID=@ID";
|
|
MySqlParameter[] paras ={
|
|
new MySqlParameter("@ID",MySqlDbType.VarChar,36)
|
|
};
|
|
paras[0].Value = ID;
|
|
DataTable dt = FangYar.Common.MySqlHelper.QueryTable(sql, paras);
|
|
if (dt.Rows.Count > 0)
|
|
{
|
|
model = new Model.ZHSQ.ZHSQ_CPY_INFO_Model();
|
|
DataRowToModel(model, dt.Rows[0]);
|
|
return model;
|
|
|
|
}
|
|
else
|
|
{
|
|
|
|
return null;
|
|
}
|
|
|
|
|
|
|
|
}
|
|
/// <summary>
|
|
/// 添加
|
|
/// </summary>
|
|
public bool Add(FangYar.Model.ZHSQ.ZHSQ_CPY_INFO_Model model)
|
|
{
|
|
StringBuilder strsql = new StringBuilder();
|
|
strsql.Append("insert into ZHSQ_CPY_INFO (CPY_CODE,CPY_NAME,GROUP_ID,CPY_CLASS,CPY_INDUSTRY,CPY_LOC,CPY_CONCACTS,CPY_TELNUM,CPY_DEVPOPNAME,CPY_DEVPOPTELNUM)");
|
|
strsql.Append("values");
|
|
strsql.Append("(@CPY_CODE,@CPY_NAME,@GROUP_ID,@CPY_CLASS,@CPY_INDUSTRY,@CPY_LOC,@CPY_CONCACTS,@CPY_TELNUM,@CPY_DEVPOPNAME,@CPY_DEVPOPTELNUM)");
|
|
MySqlParameter[] paras ={
|
|
new MySqlParameter("@CPY_CODE",MySqlDbType.VarChar,50),
|
|
new MySqlParameter("@CPY_NAME",MySqlDbType.VarChar,50),
|
|
new MySqlParameter("@GROUP_ID",MySqlDbType.VarChar,36),
|
|
new MySqlParameter("@CPY_CLASS",MySqlDbType.VarChar,36),
|
|
new MySqlParameter("@CPY_INDUSTRY",MySqlDbType.VarChar,36),
|
|
new MySqlParameter("@CPY_LOC",MySqlDbType.VarChar,50),
|
|
new MySqlParameter("@CPY_CONCACTS",MySqlDbType.VarChar,50),
|
|
new MySqlParameter("@CPY_TELNUM",MySqlDbType.VarChar,50),
|
|
new MySqlParameter("@CPY_DEVPOPNAME",MySqlDbType.VarChar,50),
|
|
new MySqlParameter("@CPY_DEVPOPTELNUM",MySqlDbType.VarChar,50)
|
|
|
|
};
|
|
paras[0].Value = model.CPY_CODE;
|
|
paras[1].Value = model.CPY_NAME;
|
|
paras[2].Value = model.GROUP_ID;
|
|
paras[3].Value = model.CPY_CLASS;
|
|
paras[4].Value = model.CPY_INDUSTRY;
|
|
paras[5].Value = model.CPY_LOC;
|
|
paras[6].Value = model.CPY_CONCACTS;
|
|
paras[7].Value = model.CPY_TELNUM;
|
|
paras[8].Value = model.CPY_DEVPOPNAME;
|
|
paras[9].Value = model.CPY_DEVPOPTELNUM;
|
|
|
|
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_CPY_INFO where ID in('" + IDList + "')";
|
|
try
|
|
{
|
|
FangYar.Common.MySqlHelper.ExecuteSql(sql);
|
|
return true;
|
|
}
|
|
catch
|
|
{
|
|
return false;
|
|
}
|
|
|
|
}
|
|
/// <summary>
|
|
/// 编辑
|
|
/// </summary>
|
|
public bool Edit(FangYar.Model.ZHSQ.ZHSQ_CPY_INFO_Model model)
|
|
{
|
|
StringBuilder strsql = new StringBuilder();
|
|
strsql.Append("update ZHSQ_CPY_INFO set ");
|
|
strsql.Append("CPY_CODE=@CPY_CODE,");
|
|
strsql.Append("CPY_NAME=@CPY_NAME,");
|
|
strsql.Append("GROUP_ID=@GROUP_ID,");
|
|
strsql.Append("CPY_CLASS=@CPY_CLASS,");
|
|
strsql.Append("CPY_INDUSTRY=@CPY_INDUSTRY,");
|
|
strsql.Append("CPY_LOC=@CPY_LOC,");
|
|
strsql.Append("CPY_CONCACTS=@CPY_CONCACTS,");
|
|
strsql.Append("CPY_TELNUM=@CPY_TELNUM,");
|
|
strsql.Append("CPY_DEVPOPNAME=@CPY_DEVPOPNAME,");
|
|
strsql.Append("CPY_DEVPOPTELNUM=@CPY_DEVPOPTELNUM ");
|
|
strsql.Append(" where ID=@ID");
|
|
MySqlParameter[] paras ={
|
|
new MySqlParameter("@CPY_CODE",model.CPY_CODE),
|
|
new MySqlParameter("@CPY_NAME",model.CPY_NAME),
|
|
new MySqlParameter("@GROUP_ID",model.GROUP_ID),
|
|
new MySqlParameter("@CPY_CLASS",model.CPY_CLASS),
|
|
new MySqlParameter("@CPY_INDUSTRY",model.CPY_INDUSTRY),
|
|
new MySqlParameter("@CPY_LOC",model.CPY_LOC),
|
|
new MySqlParameter("@CPY_CONCACTS",model.CPY_CONCACTS),
|
|
new MySqlParameter("@CPY_TELNUM",model.CPY_TELNUM),
|
|
new MySqlParameter("@CPY_DEVPOPNAME",model.CPY_DEVPOPNAME),
|
|
new MySqlParameter("@CPY_DEVPOPTELNUM",model.CPY_DEVPOPTELNUM),
|
|
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_CPY_INFO_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_CPY_INFO_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_CPY_INFO", 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_CPY_INFO", 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_CPY_INFO", "*", null, null, null);
|
|
|
|
|
|
}
|
|
#endregion
|
|
}
|
|
}
|
|
|