FundSecondUsedDetailDAL.cs 7.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using System.Data;
  6. using CoreFS.CA06;
  7. using DbHelp = Core.StlMes.Client.Sale.DbHelp;
  8. namespace Core.StlMes.Client.Sale.SaleFundMgt.FundDAL.FundSecondLevelAccountDAL
  9. {
  10. /// <summary>
  11. /// 二级账户资金转移情况管理
  12. /// </summary>
  13. public class FundSecondUsedDetailDAL:BaseDAL.BaseDAL
  14. {
  15. public FundSecondUsedDetailDAL(OpeBase ob)
  16. : base(ob)
  17. {
  18. }
  19. private string SQL_QUERY = @" select
  20. trans_seq,
  21. trans_type,
  22. balancesubject,
  23. buyercode,
  24. secondaccount,
  25. money,
  26. leavemoney,
  27. otheraccount,
  28. trans_time,
  29. trans_person,
  30. remark,
  31. updatetime from sel_fund_secondle_usedetail
  32. where 1 = 1 {0} ";
  33. private string SQL_STR_INSERT = @" insert into sel_fund_secondle_usedetail(
  34. trans_seq,
  35. trans_type,
  36. balancesubject,
  37. buyercode,
  38. secondaccount,
  39. money,
  40. leavemoney,
  41. otheraccount,
  42. trans_time,
  43. trans_person,
  44. remark,
  45. updatetime
  46. )
  47. values('{0}','{1}','{2}','{3}','{4}',{5},{6},'{7}',
  48. sysdate,'{8}','{9}',sysdate)";
  49. private string SQL_STR_DELETEBYSEQANDTYPE =
  50. @"delete from sel_fund_secondle_usedetail where 1 = 1 and trans_seq = '{0}' and trans_type = '{1}' ";
  51. /// <summary>
  52. /// 获取二级账户明细数据
  53. /// </summary>
  54. /// <param name="sqlCondition"></param>
  55. /// <returns></returns>
  56. public DataSet GetSelFundSecondleUsedDetail(string sqlCondition)
  57. {
  58. string sqlStr = string.Format(SQL_QUERY,sqlCondition);
  59. DataSet ds = base.ExecuteReaderForSaleFund(sqlStr);
  60. base.SetDataSetCaption(ref ds,base.GetColumnNameAndCaption());
  61. return ds;
  62. }
  63. /// <summary>
  64. /// 通过结算单位,客户单位,二级单位名称返回数据集
  65. /// </summary>
  66. /// <param name="acct"></param>
  67. /// <returns></returns>
  68. public DataSet GetSelFundSecondUsedDetailBybalAndBuyercodeAndsecondName(Model.SEL_FUND_SECONDLE_USEDETAIL acct)
  69. {
  70. return this.GetSelFundSecondleUsedDetail(base.GetSqlConditon(acct.BALANCESUBJECT,acct.BUYERCODE,acct.SECONDACCOUNT));
  71. }
  72. /// <summary>
  73. /// 通过结算单位,客户单位,二级单位名称返回数据集
  74. /// </summary>
  75. /// <param name="balancesubject"></param>
  76. /// <param name="buyercode"></param>
  77. /// <param name="secondacct"></param>
  78. /// <returns></returns>
  79. public DataSet GetSelFundSecondUsedDetailBybalAndBuyercodeAndsecondName(string balancesubject,string buyercode,string secondacct)
  80. {
  81. return this.GetSelFundSecondleUsedDetail(base.GetSqlConditon(balancesubject, buyercode, secondacct));
  82. }
  83. private string GetInsertSqlStr(Model.SEL_FUND_SECONDLE_USEDETAIL acct, out string err)
  84. {
  85. err = "";
  86. try
  87. {
  88. if (!Model.SEL_FUND_SECONDLE_USEDETAIL.IsReasonable(acct, out err))
  89. {
  90. return "";
  91. }
  92. string SQL_INSERT = string.Format(SQL_STR_INSERT,
  93. acct.TRANS_SEQ,
  94. acct.TRANS_TYPE,
  95. acct.BALANCESUBJECT,
  96. acct.BUYERCODE,
  97. acct.SECONDACCOUNT,
  98. acct.MONEY,
  99. acct.LEAVEMONEY,
  100. acct.OTHERACCOUNT,
  101. acct.TRANS_PERSON,
  102. acct.REMARK
  103. );
  104. return SQL_INSERT;
  105. }
  106. catch(Exception ex)
  107. {
  108. err = ex.Message;
  109. return "";
  110. }
  111. }
  112. /// <summary>
  113. /// 新增
  114. /// </summary>
  115. /// <param name="acct"></param>
  116. /// <param name="err"></param>
  117. public void Insert(Model.SEL_FUND_SECONDLE_USEDETAIL acct,out string err)
  118. {
  119. err = "";
  120. string sql = GetInsertSqlStr(acct, out err);
  121. if (sql.Length == 0)
  122. return;
  123. base.ExecuteNoReaderForSaleFund(sql,out err);
  124. }
  125. /// <summary>
  126. /// 新增,带事务
  127. /// </summary>
  128. /// <param name="acct"></param>
  129. /// <param name="transaction"></param>
  130. public void Insert(Model.SEL_FUND_SECONDLE_USEDETAIL acct, DbHelp.DbTransaction transaction)
  131. {
  132. string err = "";
  133. string sql = GetInsertSqlStr(acct, out err);
  134. if (err.Length > 0)
  135. {
  136. transaction.ErrMsg = err;
  137. return;
  138. }
  139. base.ExecuteNoReaderForSaleFund(sql, transaction);
  140. }
  141. public string Sql_Insert(Model.SEL_FUND_SECONDLE_USEDETAIL acct)
  142. {
  143. string err = "";
  144. string sql = GetInsertSqlStr(acct, out err);
  145. return sql;
  146. }
  147. /// <summary>
  148. /// 删除
  149. /// </summary>
  150. /// <param name="busiSeq"></param>
  151. /// <param name="transType"></param>
  152. public void Delete(string busiSeq, string transType)
  153. {
  154. string sqlStr = string.Format(SQL_STR_DELETEBYSEQANDTYPE, busiSeq, transType);
  155. base.ExecuteNoReaderForSaleFund(sqlStr);
  156. }
  157. }
  158. }