Brak opisu

T_Sys_Department.cs 17KB

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