地铁二期项目正式开始

kf_quick_msgs.cs 8.9KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281
  1. using System;
  2. using System.Data;
  3. using System.Text;
  4. using MySql.Data.MySqlClient;
  5. using DBUtility;
  6. namespace YTSoft.BaseCallCenter.DAL
  7. {
  8. /// <summary>
  9. /// 数据访问类:kf_quick_msgs
  10. /// </summary>
  11. public partial class kf_quick_msgs
  12. {
  13. public kf_quick_msgs()
  14. { }
  15. #region BasicMethod
  16. /// <summary>
  17. /// 得到最大ID
  18. /// </summary>
  19. public int GetMaxId()
  20. {
  21. return DbHelperMYSQL.GetMaxID("id", "kf_quick_msgs");
  22. }
  23. /// <summary>
  24. /// 是否存在该记录
  25. /// </summary>
  26. public bool Exists(int id)
  27. {
  28. StringBuilder strSql = new StringBuilder();
  29. strSql.Append("select count(1) from kf_quick_msgs");
  30. strSql.Append(" where id=@id ");
  31. MySqlParameter[] parameters = {
  32. new MySqlParameter("@id", MySqlDbType.Int32,11) };
  33. parameters[0].Value = id;
  34. return DbHelperMYSQL.Exists(strSql.ToString(), parameters);
  35. }
  36. /// <summary>
  37. /// 增加一条数据
  38. /// </summary>
  39. public bool Add(YTSoft.BaseCallCenter.Model.kf_quick_msgs model)
  40. {
  41. StringBuilder strSql = new StringBuilder();
  42. strSql.Append("insert into kf_quick_msgs(");
  43. strSql.Append("id,service_id,msg,rate)");
  44. strSql.Append(" values (");
  45. strSql.Append("@id,@service_id,@msg,@rate)");
  46. MySqlParameter[] parameters = {
  47. new MySqlParameter("@id", model.id),
  48. new MySqlParameter("@service_id", model.service_id),
  49. new MySqlParameter("@msg", model.msg),
  50. new MySqlParameter("@rate", model.rate)};
  51. int rows = DbHelperMYSQL.ExecuteSql(strSql.ToString(), parameters);
  52. if (rows > 0)
  53. {
  54. return true;
  55. }
  56. else
  57. {
  58. return false;
  59. }
  60. }
  61. /// <summary>
  62. /// 更新一条数据
  63. /// </summary>
  64. public bool Update(YTSoft.BaseCallCenter.Model.kf_quick_msgs model)
  65. {
  66. StringBuilder strSql = new StringBuilder();
  67. strSql.Append("update kf_quick_msgs set ");
  68. strSql.Append("service_id=@service_id,");
  69. strSql.Append("rate=@rate,");
  70. strSql.Append("msg=@msg");
  71. strSql.Append(" where id=@id ");
  72. MySqlParameter[] parameters = {
  73. new MySqlParameter("@id", model.id),
  74. new MySqlParameter("@service_id", model.service_id),
  75. new MySqlParameter("@msg", model.msg),
  76. new MySqlParameter("@rate", model.rate)};
  77. int rows = DbHelperMYSQL.ExecuteSql(strSql.ToString(), parameters);
  78. if (rows > 0)
  79. {
  80. return true;
  81. }
  82. else
  83. {
  84. return false;
  85. }
  86. }
  87. /// <summary>
  88. /// 删除一条数据
  89. /// </summary>
  90. public bool Delete(int id)
  91. {
  92. StringBuilder strSql = new StringBuilder();
  93. strSql.Append("delete from kf_quick_msgs ");
  94. strSql.Append(" where id=@id ");
  95. MySqlParameter[] parameters = {
  96. new MySqlParameter("@id", MySqlDbType.Int32,11) };
  97. parameters[0].Value = id;
  98. int rows = DbHelperMYSQL.ExecuteSql(strSql.ToString(), parameters);
  99. if (rows > 0)
  100. {
  101. return true;
  102. }
  103. else
  104. {
  105. return false;
  106. }
  107. }
  108. /// <summary>
  109. /// 批量删除数据
  110. /// </summary>
  111. public bool DeleteList(string idlist)
  112. {
  113. StringBuilder strSql = new StringBuilder();
  114. strSql.Append("delete from kf_quick_msgs ");
  115. strSql.Append(" where id in (" + idlist + ") ");
  116. int rows = DbHelperMYSQL.ExecuteSql(strSql.ToString());
  117. if (rows > 0)
  118. {
  119. return true;
  120. }
  121. else
  122. {
  123. return false;
  124. }
  125. }
  126. /// <summary>
  127. /// 得到一个对象实体
  128. /// </summary>
  129. public YTSoft.BaseCallCenter.Model.kf_quick_msgs GetModel(int id)
  130. {
  131. StringBuilder strSql = new StringBuilder();
  132. strSql.Append("select id,service_id,msg,rate from kf_quick_msgs ");
  133. strSql.Append(" where id=@id ");
  134. MySqlParameter[] parameters = {
  135. new MySqlParameter("@id", MySqlDbType.Int32,11) };
  136. parameters[0].Value = id;
  137. YTSoft.BaseCallCenter.Model.kf_quick_msgs model = new YTSoft.BaseCallCenter.Model.kf_quick_msgs();
  138. DataSet ds = DbHelperMYSQL.Query(strSql.ToString(), parameters);
  139. if (ds.Tables[0].Rows.Count > 0)
  140. {
  141. return DataRowToModel(ds.Tables[0].Rows[0]);
  142. }
  143. else
  144. {
  145. return null;
  146. }
  147. }
  148. /// <summary>
  149. /// 得到一个对象实体
  150. /// </summary>
  151. public YTSoft.BaseCallCenter.Model.kf_quick_msgs DataRowToModel(DataRow row)
  152. {
  153. YTSoft.BaseCallCenter.Model.kf_quick_msgs model = new YTSoft.BaseCallCenter.Model.kf_quick_msgs();
  154. if (row != null)
  155. {
  156. if (row["id"] != null && row["id"].ToString() != "")
  157. {
  158. model.id = int.Parse(row["id"].ToString());
  159. }
  160. if (row["rate"] != null && row["rate"].ToString() != "")
  161. {
  162. model.rate = int.Parse(row["rate"].ToString());
  163. }
  164. if (row["service_id"] != null && row["service_id"].ToString() != "")
  165. {
  166. model.service_id = int.Parse(row["service_id"].ToString());
  167. }
  168. if (row["msg"] != null)
  169. {
  170. model.msg = row["msg"].ToString();
  171. }
  172. }
  173. return model;
  174. }
  175. /// <summary>
  176. /// 获得数据列表
  177. /// </summary>
  178. public DataSet GetList(string strWhere)
  179. {
  180. StringBuilder strSql = new StringBuilder();
  181. strSql.Append("select id,service_id,msg,rate ");
  182. strSql.Append(" FROM kf_quick_msgs ");
  183. if (strWhere.Trim() != "")
  184. {
  185. strSql.Append(" where " + strWhere);
  186. }
  187. return DbHelperMYSQL.Query(strSql.ToString());
  188. }
  189. /// <summary>
  190. /// 获取记录总数
  191. /// </summary>
  192. public int GetRecordCount(string strWhere)
  193. {
  194. StringBuilder strSql = new StringBuilder();
  195. strSql.Append("select count(1) FROM kf_quick_msgs ");
  196. if (strWhere.Trim() != "")
  197. {
  198. strSql.Append(" where " + strWhere);
  199. }
  200. object obj = DbHelperMYSQL.GetSingle(strSql.ToString());
  201. if (obj == null)
  202. {
  203. return 0;
  204. }
  205. else
  206. {
  207. return Convert.ToInt32(obj);
  208. }
  209. }
  210. /// <summary>
  211. /// 分页获取数据列表
  212. /// </summary>
  213. public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int pagesize)
  214. {
  215. StringBuilder strSql = new StringBuilder();
  216. strSql.Append("SELECT * FROM kf_quick_msgs ");
  217. if (!string.IsNullOrEmpty(strWhere.Trim()))
  218. {
  219. strSql.Append(" WHERE " + strWhere);
  220. }
  221. if (!string.IsNullOrEmpty(orderby.Trim()))
  222. {
  223. strSql.Append(" Order by " + orderby);
  224. }
  225. strSql.AppendFormat(" limit {0},{1}", startIndex, pagesize);
  226. return DbHelperMYSQL.Query(strSql.ToString());
  227. }
  228. #region
  229. /*
  230. /// <summary>
  231. /// 分页获取数据列表
  232. /// </summary>
  233. public DataSet GetList(int PageSize,int PageIndex,string strWhere)
  234. {
  235. MySqlParameter[] parameters = {
  236. new MySqlParameter("@tblName", MySqlDbType.VarChar, 255),
  237. new MySqlParameter("@fldName", MySqlDbType.VarChar, 255),
  238. new MySqlParameter("@PageSize", MySqlDbType.Int32),
  239. new MySqlParameter("@PageIndex", MySqlDbType.Int32),
  240. new MySqlParameter("@IsReCount", MySqlDbType.Bit),
  241. new MySqlParameter("@OrderType", MySqlDbType.Bit),
  242. new MySqlParameter("@strWhere", MySqlDbType.VarChar,1000),
  243. };
  244. parameters[0].Value = "kf_quick_msgs";
  245. parameters[1].Value = "id";
  246. parameters[2].Value = PageSize;
  247. parameters[3].Value = PageIndex;
  248. parameters[4].Value = 0;
  249. parameters[5].Value = 0;
  250. parameters[6].Value = strWhere;
  251. return DbHelperMYSQL.RunProcedure("UP_GetRecordByPage",parameters,"ds");
  252. }*/
  253. #endregion
  254. #endregion BasicMethod
  255. #region ExtensionMethod
  256. #endregion ExtensionMethod
  257. }
  258. }