Nenhuma Descrição

T_Bus_Supervision.cs 17KB

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