新野县12345_后端

T_SMS_SendSMSTask.cs 15KB

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