PingAnYeXianSZCG_API 接口代码

T_Wo_AwardRecord.cs 15KB

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