封丘民调

T_Call_OutTelNumWX.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_Call_OutTelNumWX
  13. /// </summary>
  14. public partial class T_Call_OutTelNumWX
  15. {
  16. public T_Call_OutTelNumWX()
  17. { }
  18. #region BasicMethod
  19. /// <summary>
  20. /// 是否存在该记录
  21. /// </summary>
  22. public bool Exists(int F_Id)
  23. {
  24. StringBuilder strSql = new StringBuilder();
  25. strSql.Append("select count(1) from T_Call_OutTelNumWX");
  26. strSql.Append(" where F_Id=@F_Id");
  27. SqlParameter[] parameters = {
  28. new SqlParameter("@F_Id", SqlDbType.Int,4)
  29. };
  30. parameters[0].Value = F_Id;
  31. return DbHelperSQL.Exists(strSql.ToString(), parameters);
  32. }
  33. /// <summary>
  34. /// 增加一条数据
  35. /// </summary>
  36. public int Add(CallCenterApi.Model.T_Call_OutTelNumWX model)
  37. {
  38. StringBuilder strSql = new StringBuilder();
  39. strSql.Append("insert into T_Call_OutTelNumWX(");
  40. strSql.Append("F_PagerId,F_CusID,F_CusName,F_TelPhone,F_Phone,F_CountryId,F_Country,F_Address,F_Openid,F_UserId,F_UserName,F_CreateTime,F_Count,F_AskInfo,F_AskRes,F_DeleteFlag)");
  41. strSql.Append(" values (");
  42. strSql.Append("@F_PagerId,@F_CusID,@F_CusName,@F_TelPhone,@F_Phone,@F_CountryId,@F_Country,@F_Address,@F_Openid,@F_UserId,@F_UserName,@F_CreateTime,@F_Count,@F_AskInfo,@F_AskRes,@F_DeleteFlag)");
  43. strSql.Append(";select @@IDENTITY");
  44. SqlParameter[] parameters = {
  45. new SqlParameter("@F_PagerId", SqlDbType.Int,4),
  46. new SqlParameter("@F_CusID", SqlDbType.Int,4),
  47. new SqlParameter("@F_CusName", SqlDbType.NVarChar,200),
  48. new SqlParameter("@F_TelPhone", SqlDbType.NVarChar,200),
  49. new SqlParameter("@F_Phone", SqlDbType.NVarChar,200),
  50. new SqlParameter("@F_CountryId", SqlDbType.Int,4),
  51. new SqlParameter("@F_Country", SqlDbType.NVarChar,200),
  52. new SqlParameter("@F_Address", SqlDbType.NVarChar,2000),
  53. new SqlParameter("@F_Openid", SqlDbType.NVarChar,200),
  54. new SqlParameter("@F_UserId", SqlDbType.Int,4),
  55. new SqlParameter("@F_UserName", SqlDbType.NVarChar,50),
  56. new SqlParameter("@F_CreateTime", SqlDbType.DateTime),
  57. new SqlParameter("@F_Count", SqlDbType.Int,4),
  58. new SqlParameter("@F_AskInfo", SqlDbType.Text),
  59. new SqlParameter("@F_AskRes", SqlDbType.Text),
  60. new SqlParameter("@F_DeleteFlag", SqlDbType.Int,4)};
  61. parameters[0].Value = model.F_PagerId;
  62. parameters[1].Value = model.F_CusID;
  63. parameters[2].Value = model.F_CusName;
  64. parameters[3].Value = model.F_TelPhone;
  65. parameters[4].Value = model.F_Phone;
  66. parameters[5].Value = model.F_CountryId;
  67. parameters[6].Value = model.F_Country;
  68. parameters[7].Value = model.F_Address;
  69. parameters[8].Value = model.F_Openid;
  70. parameters[9].Value = model.F_UserId;
  71. parameters[10].Value = model.F_UserName;
  72. parameters[11].Value = model.F_CreateTime;
  73. parameters[12].Value = model.F_Count;
  74. parameters[13].Value = model.F_AskInfo;
  75. parameters[14].Value = model.F_AskRes;
  76. parameters[15].Value = model.F_DeleteFlag;
  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_Call_OutTelNumWX model)
  91. {
  92. StringBuilder strSql = new StringBuilder();
  93. strSql.Append("update T_Call_OutTelNumWX set ");
  94. strSql.Append("F_PagerId=@F_PagerId,");
  95. strSql.Append("F_CusID=@F_CusID,");
  96. strSql.Append("F_CusName=@F_CusName,");
  97. strSql.Append("F_TelPhone=@F_TelPhone,");
  98. strSql.Append("F_Phone=@F_Phone,");
  99. strSql.Append("F_CountryId=@F_CountryId,");
  100. strSql.Append("F_Country=@F_Country,");
  101. strSql.Append("F_Address=@F_Address,");
  102. strSql.Append("F_Openid=@F_Openid,");
  103. strSql.Append("F_UserId=@F_UserId,");
  104. strSql.Append("F_UserName=@F_UserName,");
  105. strSql.Append("F_CreateTime=@F_CreateTime,");
  106. strSql.Append("F_Count=@F_Count,");
  107. strSql.Append("F_AskInfo=@F_AskInfo,");
  108. strSql.Append("F_AskRes=@F_AskRes,");
  109. strSql.Append("F_DeleteFlag=@F_DeleteFlag");
  110. strSql.Append(" where F_Id=@F_Id");
  111. SqlParameter[] parameters = {
  112. new SqlParameter("@F_PagerId", SqlDbType.Int,4),
  113. new SqlParameter("@F_CusID", SqlDbType.Int,4),
  114. new SqlParameter("@F_CusName", SqlDbType.NVarChar,200),
  115. new SqlParameter("@F_TelPhone", SqlDbType.NVarChar,200),
  116. new SqlParameter("@F_Phone", SqlDbType.NVarChar,200),
  117. new SqlParameter("@F_CountryId", SqlDbType.Int,4),
  118. new SqlParameter("@F_Country", SqlDbType.NVarChar,200),
  119. new SqlParameter("@F_Address", SqlDbType.NVarChar,2000),
  120. new SqlParameter("@F_Openid", SqlDbType.NVarChar,200),
  121. new SqlParameter("@F_UserId", SqlDbType.Int,4),
  122. new SqlParameter("@F_UserName", SqlDbType.NVarChar,50),
  123. new SqlParameter("@F_CreateTime", SqlDbType.DateTime),
  124. new SqlParameter("@F_Count", SqlDbType.Int,4),
  125. new SqlParameter("@F_AskInfo", SqlDbType.Text),
  126. new SqlParameter("@F_AskRes", SqlDbType.Text),
  127. new SqlParameter("@F_DeleteFlag", SqlDbType.Int,4),
  128. new SqlParameter("@F_Id", SqlDbType.Int,4)};
  129. parameters[0].Value = model.F_PagerId;
  130. parameters[1].Value = model.F_CusID;
  131. parameters[2].Value = model.F_CusName;
  132. parameters[3].Value = model.F_TelPhone;
  133. parameters[4].Value = model.F_Phone;
  134. parameters[5].Value = model.F_CountryId;
  135. parameters[6].Value = model.F_Country;
  136. parameters[7].Value = model.F_Address;
  137. parameters[8].Value = model.F_Openid;
  138. parameters[9].Value = model.F_UserId;
  139. parameters[10].Value = model.F_UserName;
  140. parameters[11].Value = model.F_CreateTime;
  141. parameters[12].Value = model.F_Count;
  142. parameters[13].Value = model.F_AskInfo;
  143. parameters[14].Value = model.F_AskRes;
  144. parameters[15].Value = model.F_DeleteFlag;
  145. parameters[16].Value = model.F_Id;
  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_Id)
  160. {
  161. StringBuilder strSql = new StringBuilder();
  162. strSql.Append("delete from T_Call_OutTelNumWX ");
  163. strSql.Append(" where F_Id=@F_Id");
  164. SqlParameter[] parameters = {
  165. new SqlParameter("@F_Id", SqlDbType.Int,4)
  166. };
  167. parameters[0].Value = F_Id;
  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_Idlist)
  182. {
  183. StringBuilder strSql = new StringBuilder();
  184. strSql.Append("delete from T_Call_OutTelNumWX ");
  185. strSql.Append(" where F_Id in (" + F_Idlist + ") ");
  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 CallCenterApi.Model.T_Call_OutTelNumWX GetModel(int F_Id)
  200. {
  201. StringBuilder strSql = new StringBuilder();
  202. strSql.Append("select top 1 * from T_Call_OutTelNumWX ");
  203. strSql.Append(" where F_Id=@F_Id");
  204. SqlParameter[] parameters = {
  205. new SqlParameter("@F_Id", SqlDbType.Int,4)
  206. };
  207. parameters[0].Value = F_Id;
  208. CallCenterApi.Model.T_Call_OutTelNumWX model = new CallCenterApi.Model.T_Call_OutTelNumWX();
  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 CallCenterApi.Model.T_Call_OutTelNumWX DataRowToModel(DataRow row)
  223. {
  224. CallCenterApi.Model.T_Call_OutTelNumWX model = new CallCenterApi.Model.T_Call_OutTelNumWX();
  225. if (row != null)
  226. {
  227. if (row["F_Id"] != null && row["F_Id"].ToString() != "")
  228. {
  229. model.F_Id = int.Parse(row["F_Id"].ToString());
  230. }
  231. if (row["F_PagerId"] != null && row["F_PagerId"].ToString() != "")
  232. {
  233. model.F_PagerId = int.Parse(row["F_PagerId"].ToString());
  234. }
  235. if (row["F_CusID"] != null && row["F_CusID"].ToString() != "")
  236. {
  237. model.F_CusID = int.Parse(row["F_CusID"].ToString());
  238. }
  239. if (row["F_CusName"] != null)
  240. {
  241. model.F_CusName = row["F_CusName"].ToString();
  242. }
  243. if (row["F_TelPhone"] != null)
  244. {
  245. model.F_TelPhone = row["F_TelPhone"].ToString();
  246. }
  247. if (row["F_Phone"] != null)
  248. {
  249. model.F_Phone = row["F_Phone"].ToString();
  250. }
  251. if (row["F_CountryId"] != null && row["F_CountryId"].ToString() != "")
  252. {
  253. model.F_CountryId = int.Parse(row["F_CountryId"].ToString());
  254. }
  255. if (row["F_Country"] != null)
  256. {
  257. model.F_Country = row["F_Country"].ToString();
  258. }
  259. if (row["F_Address"] != null)
  260. {
  261. model.F_Address = row["F_Address"].ToString();
  262. }
  263. if (row["F_Openid"] != null)
  264. {
  265. model.F_Openid = row["F_Openid"].ToString();
  266. }
  267. if (row["F_UserId"] != null && row["F_UserId"].ToString() != "")
  268. {
  269. model.F_UserId = int.Parse(row["F_UserId"].ToString());
  270. }
  271. if (row["F_UserName"] != null)
  272. {
  273. model.F_UserName = row["F_UserName"].ToString();
  274. }
  275. if (row["F_CreateTime"] != null && row["F_CreateTime"].ToString() != "")
  276. {
  277. model.F_CreateTime = DateTime.Parse(row["F_CreateTime"].ToString());
  278. }
  279. if (row["F_Count"] != null && row["F_Count"].ToString() != "")
  280. {
  281. model.F_Count = int.Parse(row["F_Count"].ToString());
  282. }
  283. if (row["F_AskInfo"] != null)
  284. {
  285. model.F_AskInfo = row["F_AskInfo"].ToString();
  286. }
  287. if (row["F_AskRes"] != null)
  288. {
  289. model.F_AskRes = row["F_AskRes"].ToString();
  290. }
  291. if (row["F_DeleteFlag"] != null && row["F_DeleteFlag"].ToString() != "")
  292. {
  293. model.F_DeleteFlag = int.Parse(row["F_DeleteFlag"].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 * ");
  305. strSql.Append(" FROM T_Call_OutTelNumWX ");
  306. if (strWhere.Trim() != "")
  307. {
  308. strSql.Append(" where " + strWhere);
  309. }
  310. return DbHelperSQL.Query(strSql.ToString());
  311. }
  312. /// <summary>
  313. /// 获得前几行数据
  314. /// </summary>
  315. public DataSet GetList(int Top, string strWhere, string filedOrder)
  316. {
  317. StringBuilder strSql = new StringBuilder();
  318. strSql.Append("select ");
  319. if (Top > 0)
  320. {
  321. strSql.Append(" top " + Top.ToString());
  322. }
  323. strSql.Append(" * ");
  324. strSql.Append(" FROM T_Call_OutTelNumWX ");
  325. if (strWhere.Trim() != "")
  326. {
  327. strSql.Append(" where " + strWhere);
  328. }
  329. strSql.Append(" order by " + filedOrder);
  330. return DbHelperSQL.Query(strSql.ToString());
  331. }
  332. /// <summary>
  333. /// 获取记录总数
  334. /// </summary>
  335. public int GetRecordCount(string strWhere)
  336. {
  337. StringBuilder strSql = new StringBuilder();
  338. strSql.Append("select count(1) FROM T_Call_OutTelNumWX ");
  339. if (strWhere.Trim() != "")
  340. {
  341. strSql.Append(" where " + strWhere);
  342. }
  343. object obj = DbHelperSQL.GetSingle(strSql.ToString());
  344. if (obj == null)
  345. {
  346. return 0;
  347. }
  348. else
  349. {
  350. return Convert.ToInt32(obj);
  351. }
  352. }
  353. /// <summary>
  354. /// 分页获取数据列表
  355. /// </summary>
  356. public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
  357. {
  358. StringBuilder strSql = new StringBuilder();
  359. strSql.Append("SELECT * FROM ( ");
  360. strSql.Append(" SELECT ROW_NUMBER() OVER (");
  361. if (!string.IsNullOrEmpty(orderby.Trim()))
  362. {
  363. strSql.Append("order by T." + orderby);
  364. }
  365. else
  366. {
  367. strSql.Append("order by T.F_Id desc");
  368. }
  369. strSql.Append(")AS Row, T.* from T_Call_OutTelNumWX T ");
  370. if (!string.IsNullOrEmpty(strWhere.Trim()))
  371. {
  372. strSql.Append(" WHERE " + strWhere);
  373. }
  374. strSql.Append(" ) TT");
  375. strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex);
  376. return DbHelperSQL.Query(strSql.ToString());
  377. }
  378. #endregion BasicMethod
  379. #region ExtensionMethod
  380. /// <summary>
  381. /// 根据号码得到一个对象实体
  382. /// </summary>
  383. public CallCenterApi.Model.T_Call_OutTelNumWX GetModelByTel(string tel)
  384. {
  385. StringBuilder strSql = new StringBuilder();
  386. strSql.Append("select top 1 * from T_Call_OutTelNumWX ");
  387. strSql.Append(" where F_TelPhone=@F_TelPhone order by F_CreateTime desc");
  388. SqlParameter[] parameters = {
  389. new SqlParameter("@F_TelPhone", SqlDbType.NVarChar,200)
  390. };
  391. parameters[0].Value = tel;
  392. CallCenterApi.Model.T_Call_OutTelNumWX model = new CallCenterApi.Model.T_Call_OutTelNumWX();
  393. DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters);
  394. if (ds.Tables[0].Rows.Count > 0)
  395. {
  396. return DataRowToModel(ds.Tables[0].Rows[0]);
  397. }
  398. else
  399. {
  400. return null;
  401. }
  402. }
  403. #endregion ExtensionMethod
  404. }
  405. }