SlmBaseLoadInfoBll.cs 6.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175
  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 System.ComponentModel;
  8. using System.Drawing;
  9. using System.Windows.Forms;
  10. using Infragistics.Win.UltraWinGrid;
  11. using System.Collections;
  12. using ColumnDefine = Core.StlMes.Client.Sale.Common.TbColumnDefine.TbColumnDefine;
  13. namespace Core.StlMes.Client.Sale.BLL.SaleBusinessMgt.BaseData
  14. {
  15. public class SlmBaseLoadInfoBll : SaleBusinessMgt.BllBase.BaseBll
  16. {
  17. public SlmBaseLoadInfoBll(OpeBase ob)
  18. : base(ob)
  19. {
  20. }
  21. /// <summary>
  22. /// 查询入口
  23. /// </summary>
  24. /// <param name="sqlCondition"></param>
  25. /// <returns></returns>
  26. private DataSet GetSlmBaseLoadInfo(string sqlCondition)
  27. {
  28. string sqlStr = string.Format(SqlCollection.BaseData._QUERYSLMBASESTATION, sqlCondition, base.DateTimeTocharFormat);
  29. return base.ExecuteQuery(sqlStr);
  30. }
  31. /// <summary>
  32. /// 查询有效汽运数据
  33. /// </summary>
  34. /// <param name="carType"></param>
  35. /// <returns></returns>
  36. public DataSet GetValidCarSlmBaseLoadInfo()
  37. {
  38. string sqlCondition = string.Format(" and cartype = '{0}' and validflag = '{1}'", "汽运", "1");
  39. return GetSlmBaseLoadInfo(sqlCondition);
  40. }
  41. /// <summary>
  42. /// 查询无效汽运数据
  43. /// </summary>
  44. /// <param name="carType"></param>
  45. /// <returns></returns>
  46. public DataSet GetNotValidCarSlmBaseLoadInfo()
  47. {
  48. string sqlCondition = string.Format(" and cartype = '{0}' and validflag = '{1}'", "汽运", "0");
  49. return GetSlmBaseLoadInfo(sqlCondition);
  50. }
  51. /// <summary>
  52. /// 查询有效的所有数据
  53. /// </summary>
  54. /// <returns></returns>
  55. public DataSet GetValidSlmBaseLoadInfoAll()
  56. {
  57. string sqlCondition = string.Format(" and validflag = '{0}'", "1");
  58. return GetSlmBaseLoadInfo(sqlCondition);
  59. }
  60. /// <summary>
  61. /// 查询无效的所有数据
  62. /// </summary>
  63. /// <returns></returns>
  64. public DataSet GetNotValidSlmBaseLoadInfoAll()
  65. {
  66. string sqlCondition = string.Format(" and validflag = '{0}'", "0");
  67. return GetSlmBaseLoadInfo(sqlCondition);
  68. }
  69. /// <summary>
  70. /// 查询所有数据(无效、有效)
  71. /// </summary>
  72. /// <returns></returns>
  73. public DataSet GetSlmBaseLoadInfoAll()
  74. {
  75. return GetSlmBaseLoadInfo("");
  76. }
  77. /// <summary>
  78. /// 到站信息维护 新增
  79. /// </summary>
  80. /// <param name="hs"></param>
  81. /// <param name="errMsg"></param>
  82. public void Insert(Hashtable hs, out string errMsg)
  83. {
  84. errMsg = "";
  85. hs.Add(ColumnDefine.SLM_BASE_STATION.STATION_NO, GetSlmBaseStationCode());
  86. CoreClientParam param = base.GetCoreClientParam(_ServerName, "insert", new object[] { hs });
  87. CoreClientParam result = base.fr.ExecuteNonQuery(param, CoreInvokeType.Internal);
  88. errMsg = base.GetReturnErrorInfo(result);
  89. }
  90. /// <summary>
  91. /// 到站信息维护 删除
  92. /// </summary>
  93. /// <param name="stationNo"></param>
  94. public void Delete(string stationNo,string deleteName,out string errMsg)
  95. {
  96. errMsg = "";
  97. CoreClientParam param = base.GetCoreClientParam(_ServerName, "delete", new object[] { stationNo,deleteName });
  98. CoreClientParam result = base.fr.ExecuteNonQuery(param, CoreInvokeType.Internal);
  99. errMsg = base.GetReturnErrorInfo(result);
  100. }
  101. /// <summary>
  102. /// 到站信息维护 修改
  103. /// </summary>
  104. /// <param name="hs"></param>
  105. /// <param name="errMsg"></param>
  106. public void Update(Hashtable hs, out string errMsg)
  107. {
  108. errMsg = "";
  109. CoreClientParam param = base.GetCoreClientParam(_ServerName, "update", new object[] { hs });
  110. CoreClientParam result = base.fr.ExecuteNonQuery(param, CoreInvokeType.Internal);
  111. errMsg = base.GetReturnErrorInfo(result);
  112. }
  113. /// <summary>
  114. /// 获取数据行数
  115. /// </summary>
  116. /// <returns></returns>
  117. private double GetCoutOfSlmBaseStation()
  118. {
  119. string sqlStr = "select count(1) from slm_base_station ";
  120. DataSet ds = base.ExecuteQuery(sqlStr);
  121. if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
  122. return 0;
  123. return Util.ConverObject.ConvertToDouble(ds.Tables[0].Rows[0][0]);
  124. }
  125. /// <summary>
  126. /// 自动生成客户编码
  127. /// </summary>
  128. /// <returns></returns>
  129. private string GetSlmBaseStationCode()
  130. {
  131. string customberno = "";
  132. string sqlStr = @"select *
  133. from (select lpad(l || '', 6, 0) customberno, a.station_no, rownum rn
  134. from (select level - 1 l from dual connect by level < {0}) b
  135. left join slm_base_station a on a.station_no =
  136. lpad(b.l || '', 6, 0)
  137. where a.station_no is null
  138. order by b.l)
  139. where rn = 1";
  140. sqlStr = string.Format(sqlStr, GetCoutOfSlmBaseStation() + 100);
  141. DataSet ds = base.ExecuteQuery(sqlStr);
  142. try
  143. {
  144. if (ds.Tables[0].Rows.Count == 0)
  145. customberno = "000001";
  146. else
  147. customberno = ds.Tables[0].Rows[0]["CUSTOMBERNO"].ToString();
  148. }
  149. catch
  150. {
  151. }
  152. return customberno;
  153. }
  154. /// <summary>
  155. /// 服务器方法名路径
  156. /// </summary>
  157. private string _ServerName = "core.stlmes.server.sale.service.basedata.SlmBaseStation";
  158. }
  159. }