新乡民调(来自息县民调) - 主标

T_Call_OutAnswersWX.cs 14KB

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