郑州颐和随访系统

T_Con_Conversation.cs 12KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314
  1. 
  2. using System;
  3. using System.Data;
  4. using System.Text;
  5. using System.Data.SqlClient;
  6. using CallCenterApi.DB;
  7. namespace CallCenterApi.DAL
  8. {
  9. /// <summary>
  10. /// 数据访问类:T_Con_Conversation
  11. /// </summary>
  12. public partial class T_Con_Conversation
  13. {
  14. public T_Con_Conversation()
  15. { }
  16. #region BasicMethod
  17. /// <summary>
  18. /// 增加一条数据
  19. /// </summary>
  20. public int Add(CallCenterApi.Model.T_Con_Conversation model)
  21. {
  22. StringBuilder strSql = new StringBuilder();
  23. strSql.Append("insert into T_Con_Conversation(");
  24. strSql.Append("F_Type,F_Department,F_Section,F_Telephone,F_Physician,F_Title,F_IsDelete,F_FileId)");
  25. strSql.Append(" values (");
  26. strSql.Append("@F_Type,@F_Department,@F_Section,@F_Telephone,@F_Physician,@F_Title,@F_IsDelete,@F_FileId)");
  27. strSql.Append(";select @@IDENTITY");
  28. SqlParameter[] parameters = {
  29. new SqlParameter("@F_Type", SqlDbType.Int,4),
  30. new SqlParameter("@F_Department", SqlDbType.VarChar,200),
  31. new SqlParameter("@F_Section", SqlDbType.VarChar,200),
  32. new SqlParameter("@F_Telephone", SqlDbType.VarChar,200),
  33. new SqlParameter("@F_Physician", SqlDbType.VarChar,200),
  34. new SqlParameter("@F_Title", SqlDbType.VarChar,200),
  35. new SqlParameter("@F_IsDelete", SqlDbType.Int,4),
  36. new SqlParameter("@F_FileId", SqlDbType.Int,4)};
  37. parameters[0].Value = model.F_Type;
  38. parameters[1].Value = model.F_Department;
  39. parameters[2].Value = model.F_Section;
  40. parameters[3].Value = model.F_Telephone;
  41. parameters[4].Value = model.F_Physician;
  42. parameters[5].Value = model.F_Title;
  43. parameters[6].Value = model.F_IsDelete;
  44. parameters[7].Value = model.F_FileId;
  45. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  46. return rows;
  47. }
  48. /// <summary>
  49. /// 更新一条数据
  50. /// </summary>
  51. public bool Update(CallCenterApi.Model.T_Con_Conversation model)
  52. {
  53. StringBuilder strSql = new StringBuilder();
  54. strSql.Append("update T_Con_Conversation set ");
  55. strSql.Append("F_Type=@F_Type,");
  56. strSql.Append("F_Department=@F_Department,");
  57. strSql.Append("F_Section=@F_Section,");
  58. strSql.Append("F_Telephone=@F_Telephone,");
  59. strSql.Append("F_Physician=@F_Physician,");
  60. strSql.Append("F_Title=@F_Title,");
  61. strSql.Append("F_IsDelete=@F_IsDelete,");
  62. strSql.Append("F_FileId=@F_FileId");
  63. strSql.Append(" where ID=@ID ");
  64. SqlParameter[] parameters = {
  65. new SqlParameter("@F_Type", SqlDbType.Int,4),
  66. new SqlParameter("@F_Department", SqlDbType.VarChar,200),
  67. new SqlParameter("@F_Section", SqlDbType.VarChar,200),
  68. new SqlParameter("@F_Telephone", SqlDbType.VarChar,200),
  69. new SqlParameter("@F_Physician", SqlDbType.VarChar,200),
  70. new SqlParameter("@F_Title", SqlDbType.VarChar,200),
  71. new SqlParameter("@F_IsDelete", SqlDbType.Int,4),
  72. new SqlParameter("@F_FileId", SqlDbType.Int,4),
  73. new SqlParameter("@ID", SqlDbType.Int,4)};
  74. parameters[0].Value = model.F_Type;
  75. parameters[1].Value = model.F_Department;
  76. parameters[2].Value = model.F_Section;
  77. parameters[3].Value = model.F_Telephone;
  78. parameters[4].Value = model.F_Physician;
  79. parameters[5].Value = model.F_Title;
  80. parameters[6].Value = model.F_IsDelete;
  81. parameters[7].Value = model.F_FileId;
  82. parameters[8].Value = model.ID;
  83. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  84. if (rows > 0)
  85. {
  86. return true;
  87. }
  88. else
  89. {
  90. return false;
  91. }
  92. }
  93. /// <summary>
  94. /// 删除一条数据
  95. /// </summary>
  96. public bool Delete()
  97. {
  98. //该表无主键信息,请自定义主键/条件字段
  99. StringBuilder strSql = new StringBuilder();
  100. strSql.Append("delete from T_Con_Conversation ");
  101. strSql.Append(" where ");
  102. SqlParameter[] parameters = {
  103. };
  104. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  105. if (rows > 0)
  106. {
  107. return true;
  108. }
  109. else
  110. {
  111. return false;
  112. }
  113. }
  114. /// <summary>
  115. /// 得到一个对象实体
  116. /// </summary>
  117. public CallCenterApi.Model.T_Con_Conversation GetModel(int id)
  118. {
  119. //该表无主键信息,请自定义主键/条件字段
  120. StringBuilder strSql = new StringBuilder();
  121. strSql.Append("select top 1 * from T_Con_Conversation ");
  122. strSql.Append(" where ID=@ID");
  123. SqlParameter[] parameters = {
  124. new SqlParameter("@ID", SqlDbType.Int,4)
  125. };
  126. parameters[0].Value = id;
  127. CallCenterApi.Model.T_Con_Conversation model = new CallCenterApi.Model.T_Con_Conversation();
  128. DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters);
  129. if (ds.Tables[0].Rows.Count > 0)
  130. {
  131. return DataRowToModel(ds.Tables[0].Rows[0]);
  132. }
  133. else
  134. {
  135. return null;
  136. }
  137. }
  138. /// <summary>
  139. /// 得到一个对象实体
  140. /// </summary>
  141. public CallCenterApi.Model.T_Con_Conversation DataRowToModel(DataRow row)
  142. {
  143. CallCenterApi.Model.T_Con_Conversation model = new CallCenterApi.Model.T_Con_Conversation();
  144. if (row != null)
  145. {
  146. if (row["ID"] != null && row["ID"].ToString() != "")
  147. {
  148. model.ID = long.Parse(row["ID"].ToString());
  149. }
  150. if (row["F_Type"] != null && row["F_Type"].ToString() != "")
  151. {
  152. model.F_Type = int.Parse(row["F_Type"].ToString());
  153. }
  154. if (row["F_Department"] != null && row["F_Department"].ToString() != "")
  155. {
  156. model.F_Department = int.Parse(row["F_Department"].ToString());
  157. }
  158. if (row["F_Section"] != null && row["F_Section"].ToString() != "")
  159. {
  160. model.F_Section = int.Parse(row["F_Section"].ToString());
  161. }
  162. if (row["F_Telephone"] != null)
  163. {
  164. model.F_Telephone = row["F_Telephone"].ToString();
  165. }
  166. if (row["F_Physician"] != null)
  167. {
  168. model.F_Physician = row["F_Physician"].ToString();
  169. }
  170. if (row["F_Title"] != null)
  171. {
  172. model.F_Title = row["F_Title"].ToString();
  173. }
  174. if (row["F_IsDelete"] != null && row["F_IsDelete"].ToString() != "")
  175. {
  176. model.F_IsDelete = int.Parse(row["F_IsDelete"].ToString());
  177. }
  178. if (row["F_FileId"] != null && row["F_FileId"].ToString() != "")
  179. {
  180. model.F_FileId = int.Parse(row["F_FileId"].ToString());
  181. }
  182. }
  183. return model;
  184. }
  185. /// <summary>
  186. /// 获得数据列表
  187. /// </summary>
  188. public DataSet GetList(string strWhere)
  189. {
  190. StringBuilder strSql = new StringBuilder();
  191. strSql.Append("select ID,F_Type,F_Department,F_Section,F_Telephone,F_Physician,F_Title,F_IsDelete,F_FileId ");
  192. strSql.Append(" FROM T_Con_Conversation ");
  193. if (strWhere.Trim() != "")
  194. {
  195. strSql.Append(" where " + strWhere);
  196. }
  197. return DbHelperSQL.Query(strSql.ToString());
  198. }
  199. /// <summary>
  200. /// 获得前几行数据
  201. /// </summary>
  202. public DataSet GetList(int Top, string strWhere, string filedOrder)
  203. {
  204. StringBuilder strSql = new StringBuilder();
  205. strSql.Append("select ");
  206. if (Top > 0)
  207. {
  208. strSql.Append(" top " + Top.ToString());
  209. }
  210. strSql.Append(" ID,F_Type,F_Department,F_Section,F_Telephone,F_Physician,F_Title,F_IsDelete,F_FileId ");
  211. strSql.Append(" FROM T_Con_Conversation ");
  212. if (strWhere.Trim() != "")
  213. {
  214. strSql.Append(" where " + strWhere);
  215. }
  216. strSql.Append(" order by " + filedOrder);
  217. return DbHelperSQL.Query(strSql.ToString());
  218. }
  219. /// <summary>
  220. /// 获取记录总数
  221. /// </summary>
  222. public int GetRecordCount(string strWhere)
  223. {
  224. StringBuilder strSql = new StringBuilder();
  225. strSql.Append("select count(1) FROM T_Con_Conversation ");
  226. if (strWhere.Trim() != "")
  227. {
  228. strSql.Append(" where " + strWhere);
  229. }
  230. object obj = DbHelperSQL.GetSingle(strSql.ToString());
  231. if (obj == null)
  232. {
  233. return 0;
  234. }
  235. else
  236. {
  237. return Convert.ToInt32(obj);
  238. }
  239. }
  240. /// <summary>
  241. /// 分页获取数据列表
  242. /// </summary>
  243. public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
  244. {
  245. StringBuilder strSql = new StringBuilder();
  246. strSql.Append("SELECT * FROM ( ");
  247. strSql.Append(" SELECT ROW_NUMBER() OVER (");
  248. if (!string.IsNullOrEmpty(orderby.Trim()))
  249. {
  250. strSql.Append("order by T." + orderby);
  251. }
  252. else
  253. {
  254. strSql.Append("order by T. desc");
  255. }
  256. strSql.Append(")AS Row, T.* from T_Con_Conversation T ");
  257. if (!string.IsNullOrEmpty(strWhere.Trim()))
  258. {
  259. strSql.Append(" WHERE " + strWhere);
  260. }
  261. strSql.Append(" ) TT");
  262. strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex);
  263. return DbHelperSQL.Query(strSql.ToString());
  264. }
  265. /*
  266. /// <summary>
  267. /// 分页获取数据列表
  268. /// </summary>
  269. public DataSet GetList(int PageSize,int PageIndex,string strWhere)
  270. {
  271. SqlParameter[] parameters = {
  272. new SqlParameter("@tblName", SqlDbType.VarChar, 255),
  273. new SqlParameter("@fldName", SqlDbType.VarChar, 255),
  274. new SqlParameter("@PageSize", SqlDbType.Int),
  275. new SqlParameter("@PageIndex", SqlDbType.Int),
  276. new SqlParameter("@IsReCount", SqlDbType.Bit),
  277. new SqlParameter("@OrderType", SqlDbType.Bit),
  278. new SqlParameter("@strWhere", SqlDbType.VarChar,1000),
  279. };
  280. parameters[0].Value = "T_Con_Conversation";
  281. parameters[1].Value = "";
  282. parameters[2].Value = PageSize;
  283. parameters[3].Value = PageIndex;
  284. parameters[4].Value = 0;
  285. parameters[5].Value = 0;
  286. parameters[6].Value = strWhere;
  287. return DbHelperSQL.RunProcedure("UP_GetRecordByPage",parameters,"ds");
  288. }*/
  289. #endregion BasicMethod
  290. #region ExtensionMethod
  291. #endregion ExtensionMethod
  292. }
  293. }