思念食品API

T_Sys_Department.cs 16KB

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