Ei kuvausta

T_Bus_Operation.cs 16KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401
  1. using System;
  2. using System.Data;
  3. using System.Text;
  4. using System.Data.SqlClient;
  5. using CallCenterApi.DB;
  6. namespace CallCenterApi.DAL
  7. {
  8. /// <summary>
  9. /// 数据访问类:T_Bus_Operation
  10. /// </summary>
  11. public partial class T_Bus_Operation
  12. {
  13. public T_Bus_Operation()
  14. { }
  15. #region BasicMethod
  16. /// <summary>
  17. /// 是否存在该记录
  18. /// </summary>
  19. public bool Exists(int F_Id)
  20. {
  21. StringBuilder strSql = new StringBuilder();
  22. strSql.Append("select count(1) from T_Bus_Operation");
  23. strSql.Append(" where F_Id=@F_Id");
  24. SqlParameter[] parameters = {
  25. new SqlParameter("@F_Id", SqlDbType.Int,4)
  26. };
  27. parameters[0].Value = F_Id;
  28. return DbHelperSQL.Exists(strSql.ToString(), parameters);
  29. }
  30. /// <summary>
  31. /// 增加一条数据
  32. /// </summary>
  33. public int Add(CallCenterApi.Model.T_Bus_Operation model)
  34. {
  35. StringBuilder strSql = new StringBuilder();
  36. strSql.Append("insert into T_Bus_Operation(");
  37. strSql.Append("F_WorkOrderId,F_AssignedId,F_Message,F_CallRecordId,F_LeaveRecordId,F_State,F_File,F_CreateUser,F_CreateTime,F_IsDelete,F_DeleteUser,F_DeleteTime,F_Type)");
  38. strSql.Append(" values (");
  39. strSql.Append("@F_WorkOrderId,@F_AssignedId,@F_Message,@F_CallRecordId,@F_LeaveRecordId,@F_State,@F_File,@F_CreateUser,@F_CreateTime,@F_IsDelete,@F_DeleteUser,@F_DeleteTime,@F_Type)");
  40. strSql.Append(";select @@IDENTITY");
  41. SqlParameter[] parameters = {
  42. new SqlParameter("@F_WorkOrderId", SqlDbType.NVarChar,20),
  43. new SqlParameter("@F_AssignedId", SqlDbType.Int,4),
  44. new SqlParameter("@F_Message", SqlDbType.NVarChar,-1),
  45. new SqlParameter("@F_CallRecordId", SqlDbType.Int,4),
  46. new SqlParameter("@F_LeaveRecordId", SqlDbType.Int,4),
  47. new SqlParameter("@F_State", SqlDbType.Int,4),
  48. new SqlParameter("@F_File", SqlDbType.VarChar,500),
  49. new SqlParameter("@F_CreateUser", SqlDbType.VarChar,50),
  50. new SqlParameter("@F_CreateTime", SqlDbType.DateTime),
  51. new SqlParameter("@F_IsDelete", SqlDbType.Int,4),
  52. new SqlParameter("@F_DeleteUser", SqlDbType.VarChar,50),
  53. new SqlParameter("@F_DeleteTime", SqlDbType.DateTime),
  54. new SqlParameter("@F_Type", SqlDbType.Int,4)
  55. };
  56. parameters[0].Value = model.F_WorkOrderId;
  57. parameters[1].Value = model.F_AssignedId;
  58. parameters[2].Value = model.F_Message;
  59. parameters[3].Value = model.F_CallRecordId;
  60. parameters[4].Value = model.F_LeaveRecordId;
  61. parameters[5].Value = model.F_State;
  62. parameters[6].Value = model.F_File;
  63. parameters[7].Value = model.F_CreateUser;
  64. parameters[8].Value = model.F_CreateTime;
  65. parameters[9].Value = model.F_IsDelete;
  66. parameters[10].Value = model.F_DeleteUser;
  67. parameters[11].Value = model.F_DeleteTime;
  68. parameters[12].Value = model.F_Type;
  69. object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
  70. if (obj == null)
  71. {
  72. return 0;
  73. }
  74. else
  75. {
  76. return Convert.ToInt32(obj);
  77. }
  78. }
  79. /// <summary>
  80. /// 更新一条数据
  81. /// </summary>
  82. public bool Update(CallCenterApi.Model.T_Bus_Operation model)
  83. {
  84. StringBuilder strSql = new StringBuilder();
  85. strSql.Append("update T_Bus_Operation set ");
  86. strSql.Append("F_WorkOrderId=@F_WorkOrderId,");
  87. strSql.Append("F_AssignedId=@F_AssignedId,");
  88. strSql.Append("F_Message=@F_Message,");
  89. strSql.Append("F_CallRecordId=@F_CallRecordId,");
  90. strSql.Append("F_LeaveRecordId=@F_LeaveRecordId,");
  91. strSql.Append("F_State=@F_State,");
  92. strSql.Append("F_File=@F_File,");
  93. strSql.Append("F_CreateUser=@F_CreateUser,");
  94. strSql.Append("F_CreateTime=@F_CreateTime,");
  95. strSql.Append("F_IsDelete=@F_IsDelete,");
  96. strSql.Append("F_DeleteUser=@F_DeleteUser,");
  97. strSql.Append("F_DeleteTime=@F_DeleteTime,");
  98. strSql.Append("F_Type=@F_Type");
  99. strSql.Append(" where F_Id=@F_Id");
  100. SqlParameter[] parameters = {
  101. new SqlParameter("@F_WorkOrderId", SqlDbType.NVarChar,20),
  102. new SqlParameter("@F_AssignedId", SqlDbType.Int,4),
  103. new SqlParameter("@F_Message", SqlDbType.NVarChar,-1),
  104. new SqlParameter("@F_CallRecordId", SqlDbType.Int,4),
  105. new SqlParameter("@F_LeaveRecordId", SqlDbType.Int,4),
  106. new SqlParameter("@F_State", SqlDbType.Int,4),
  107. new SqlParameter("@F_File", SqlDbType.VarChar,500),
  108. new SqlParameter("@F_CreateUser", SqlDbType.VarChar,50),
  109. new SqlParameter("@F_CreateTime", SqlDbType.DateTime),
  110. new SqlParameter("@F_IsDelete", SqlDbType.Int,4),
  111. new SqlParameter("@F_DeleteUser", SqlDbType.VarChar,50),
  112. new SqlParameter("@F_DeleteTime", SqlDbType.DateTime),
  113. new SqlParameter("@F_Type", SqlDbType.Int,4),
  114. new SqlParameter("@F_Id", SqlDbType.Int,4)};
  115. parameters[0].Value = model.F_WorkOrderId;
  116. parameters[1].Value = model.F_AssignedId;
  117. parameters[2].Value = model.F_Message;
  118. parameters[3].Value = model.F_CallRecordId;
  119. parameters[4].Value = model.F_LeaveRecordId;
  120. parameters[5].Value = model.F_State;
  121. parameters[6].Value = model.F_File;
  122. parameters[7].Value = model.F_CreateUser;
  123. parameters[8].Value = model.F_CreateTime;
  124. parameters[9].Value = model.F_IsDelete;
  125. parameters[10].Value = model.F_DeleteUser;
  126. parameters[11].Value = model.F_DeleteTime;
  127. parameters[12].Value = model.F_Type;
  128. parameters[13].Value = model.F_Id;
  129. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  130. if (rows > 0)
  131. {
  132. return true;
  133. }
  134. else
  135. {
  136. return false;
  137. }
  138. }
  139. /// <summary>
  140. /// 删除一条数据
  141. /// </summary>
  142. public bool Delete(int F_Id)
  143. {
  144. StringBuilder strSql = new StringBuilder();
  145. strSql.Append("delete from T_Bus_Operation ");
  146. strSql.Append(" where F_Id=@F_Id");
  147. SqlParameter[] parameters = {
  148. new SqlParameter("@F_Id", SqlDbType.Int,4)
  149. };
  150. parameters[0].Value = F_Id;
  151. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  152. if (rows > 0)
  153. {
  154. return true;
  155. }
  156. else
  157. {
  158. return false;
  159. }
  160. }
  161. /// <summary>
  162. /// 批量删除数据
  163. /// </summary>
  164. public bool DeleteList(string F_Idlist)
  165. {
  166. StringBuilder strSql = new StringBuilder();
  167. strSql.Append("delete from T_Bus_Operation ");
  168. strSql.Append(" where F_Id in (" + F_Idlist + ") ");
  169. int rows = DbHelperSQL.ExecuteSql(strSql.ToString());
  170. if (rows > 0)
  171. {
  172. return true;
  173. }
  174. else
  175. {
  176. return false;
  177. }
  178. }
  179. /// <summary>
  180. /// 得到一个对象实体
  181. /// </summary>
  182. public CallCenterApi.Model.T_Bus_Operation GetModel(int F_Id)
  183. {
  184. StringBuilder strSql = new StringBuilder();
  185. strSql.Append("select top 1 F_Id,F_WorkOrderId,F_AssignedId,F_Message,F_CallRecordId,F_LeaveRecordId,F_State,F_File,F_CreateUser,F_CreateTime,F_IsDelete,F_DeleteUser,F_DeleteTime,F_Type from T_Bus_Operation ");
  186. strSql.Append(" where F_Id=@F_Id");
  187. SqlParameter[] parameters = {
  188. new SqlParameter("@F_Id", SqlDbType.Int,4)
  189. };
  190. parameters[0].Value = F_Id;
  191. CallCenterApi.Model.T_Bus_Operation model = new CallCenterApi.Model.T_Bus_Operation();
  192. DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters);
  193. if (ds.Tables[0].Rows.Count > 0)
  194. {
  195. return DataRowToModel(ds.Tables[0].Rows[0]);
  196. }
  197. else
  198. {
  199. return null;
  200. }
  201. }
  202. /// <summary>
  203. /// 得到一个对象实体
  204. /// </summary>
  205. public CallCenterApi.Model.T_Bus_Operation DataRowToModel(DataRow row)
  206. {
  207. CallCenterApi.Model.T_Bus_Operation model = new CallCenterApi.Model.T_Bus_Operation();
  208. if (row != null)
  209. {
  210. if (row["F_Id"] != null && row["F_Id"].ToString() != "")
  211. {
  212. model.F_Id = int.Parse(row["F_Id"].ToString());
  213. }
  214. if (row["F_WorkOrderId"] != null)
  215. {
  216. model.F_WorkOrderId = row["F_WorkOrderId"].ToString();
  217. }
  218. if (row["F_AssignedId"] != null && row["F_AssignedId"].ToString() != "")
  219. {
  220. model.F_AssignedId = int.Parse(row["F_AssignedId"].ToString());
  221. }
  222. if (row["F_Message"] != null)
  223. {
  224. model.F_Message = row["F_Message"].ToString();
  225. }
  226. if (row["F_CallRecordId"] != null && row["F_CallRecordId"].ToString() != "")
  227. {
  228. model.F_CallRecordId = int.Parse(row["F_CallRecordId"].ToString());
  229. }
  230. if (row["F_LeaveRecordId"] != null && row["F_LeaveRecordId"].ToString() != "")
  231. {
  232. model.F_LeaveRecordId = int.Parse(row["F_LeaveRecordId"].ToString());
  233. }
  234. if (row["F_State"] != null && row["F_State"].ToString() != "")
  235. {
  236. model.F_State = int.Parse(row["F_State"].ToString());
  237. }
  238. if (row["F_File"] != null)
  239. {
  240. model.F_File = row["F_File"].ToString();
  241. }
  242. if (row["F_CreateUser"] != null)
  243. {
  244. model.F_CreateUser = row["F_CreateUser"].ToString();
  245. }
  246. if (row["F_CreateTime"] != null && row["F_CreateTime"].ToString() != "")
  247. {
  248. model.F_CreateTime = DateTime.Parse(row["F_CreateTime"].ToString());
  249. }
  250. if (row["F_IsDelete"] != null && row["F_IsDelete"].ToString() != "")
  251. {
  252. model.F_IsDelete = int.Parse(row["F_IsDelete"].ToString());
  253. }
  254. if (row["F_DeleteUser"] != null)
  255. {
  256. model.F_DeleteUser = row["F_DeleteUser"].ToString();
  257. }
  258. if (row["F_DeleteTime"] != null && row["F_DeleteTime"].ToString() != "")
  259. {
  260. model.F_DeleteTime = DateTime.Parse(row["F_DeleteTime"].ToString());
  261. }
  262. if (row["F_Type"] != null && row["F_Type"].ToString() != "")
  263. {
  264. model.F_Type = int.Parse(row["F_Type"].ToString());
  265. }
  266. }
  267. return model;
  268. }
  269. /// <summary>
  270. /// 获得数据列表
  271. /// </summary>
  272. public DataSet GetList(string strWhere)
  273. {
  274. StringBuilder strSql = new StringBuilder();
  275. strSql.Append("select F_Id,F_WorkOrderId,F_AssignedId,F_Message,F_CallRecordId,F_LeaveRecordId,F_State,F_File,F_CreateUser,F_CreateTime,F_IsDelete,F_DeleteUser,F_DeleteTime,F_Type ");
  276. strSql.Append(" FROM T_Bus_Operation ");
  277. if (strWhere.Trim() != "")
  278. {
  279. strSql.Append(" where " + strWhere);
  280. }
  281. return DbHelperSQL.Query(strSql.ToString());
  282. }
  283. /// <summary>
  284. /// 获得前几行数据
  285. /// </summary>
  286. public DataSet GetList(int Top, string strWhere, string filedOrder)
  287. {
  288. StringBuilder strSql = new StringBuilder();
  289. strSql.Append("select ");
  290. if (Top > 0)
  291. {
  292. strSql.Append(" top " + Top.ToString());
  293. }
  294. strSql.Append(" F_Id,F_WorkOrderId,F_AssignedId,F_Message,F_CallRecordId,F_LeaveRecordId,F_State,F_File,F_CreateUser,F_CreateTime,F_IsDelete,F_DeleteUser,F_DeleteTime,F_Type ");
  295. strSql.Append(" FROM T_Bus_Operation ");
  296. if (strWhere.Trim() != "")
  297. {
  298. strSql.Append(" where " + strWhere);
  299. }
  300. strSql.Append(" order by " + filedOrder);
  301. return DbHelperSQL.Query(strSql.ToString());
  302. }
  303. /// <summary>
  304. /// 获取记录总数
  305. /// </summary>
  306. public int GetRecordCount(string strWhere)
  307. {
  308. StringBuilder strSql = new StringBuilder();
  309. strSql.Append("select count(1) FROM T_Bus_Operation ");
  310. if (strWhere.Trim() != "")
  311. {
  312. strSql.Append(" where " + strWhere);
  313. }
  314. object obj = DbHelperSQL.GetSingle(strSql.ToString());
  315. if (obj == null)
  316. {
  317. return 0;
  318. }
  319. else
  320. {
  321. return Convert.ToInt32(obj);
  322. }
  323. }
  324. /// <summary>
  325. /// 分页获取数据列表
  326. /// </summary>
  327. public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
  328. {
  329. StringBuilder strSql = new StringBuilder();
  330. strSql.Append("SELECT * FROM ( ");
  331. strSql.Append(" SELECT ROW_NUMBER() OVER (");
  332. if (!string.IsNullOrEmpty(orderby.Trim()))
  333. {
  334. strSql.Append("order by T." + orderby);
  335. }
  336. else
  337. {
  338. strSql.Append("order by T.F_Id desc");
  339. }
  340. strSql.Append(")AS Row, T.* from T_Bus_Operation T ");
  341. if (!string.IsNullOrEmpty(strWhere.Trim()))
  342. {
  343. strSql.Append(" WHERE " + strWhere);
  344. }
  345. strSql.Append(" ) TT");
  346. strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex);
  347. return DbHelperSQL.Query(strSql.ToString());
  348. }
  349. /*
  350. /// <summary>
  351. /// 分页获取数据列表
  352. /// </summary>
  353. public DataSet GetList(int PageSize,int PageIndex,string strWhere)
  354. {
  355. SqlParameter[] parameters = {
  356. new SqlParameter("@tblName", SqlDbType.VarChar, 255),
  357. new SqlParameter("@fldName", SqlDbType.VarChar, 255),
  358. new SqlParameter("@PageSize", SqlDbType.Int),
  359. new SqlParameter("@PageIndex", SqlDbType.Int),
  360. new SqlParameter("@IsReCount", SqlDbType.Bit),
  361. new SqlParameter("@OrderType", SqlDbType.Bit),
  362. new SqlParameter("@strWhere", SqlDbType.VarChar,1000),
  363. };
  364. parameters[0].Value = "T_Bus_Operation";
  365. parameters[1].Value = "F_Id";
  366. parameters[2].Value = PageSize;
  367. parameters[3].Value = PageIndex;
  368. parameters[4].Value = 0;
  369. parameters[5].Value = 0;
  370. parameters[6].Value = strWhere;
  371. return DbHelperSQL.RunProcedure("UP_GetRecordByPage",parameters,"ds");
  372. }*/
  373. #endregion BasicMethod
  374. #region ExtensionMethod
  375. #endregion ExtensionMethod
  376. }
  377. }