source/HF.Core/HF.Finance.Data/SupplierMoneyData.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data;
using System.Threading.Tasks;
using HF.DataAccess.SqlDataContract;
using HF.DataAccess.DBAgent;
using HF.Business.Common;
using HF.Framework;
namespace HF.Finance.Data
{
    public class SupplierMoneyData : BaseData
    {
        public SupplierMoneyData()
        {
            DataBaseName = FinanceModuleHelper.CfgDataBaseName;
        }
        
        public static SupplierMoneyData GetInstance()
        {
            return new SupplierMoneyData();
        }
        public override DataTable GetListTableById(string organizeId, string cateId, string queryJson, int pageindex, int pagesize, string sort)
        {
            if (sort.IsEmpty()) sort = "Caption";
            sort = sort.ToLower().Replace("caption", "a.caption");
            string whereStr = " cateId = @cateId and organizeId=@organizeId ";
            StringBuilder sb = new StringBuilder();
            sb.Append("declare @rowtotal int select @rowtotal = count(distinct custId) from Finance_SupplierMoneyView ");
            sb.Append(" where " + whereStr);
            sb.Append(" select top " + pagesize + "  @rowtotal as rowtotal,* from");
            sb.Append("(");
            sb.Append(" select ROW_NUMBER() over(order by " + sort + ") rownum, a.*,sp.Address,sp.Telephone,sp.LinkMan from");
            sb.Append("(");
            sb.Append(" select cateId, CustId, Caption, SUM(totalmoney) totalMoney, SUM(doMoney) doMoney, SUM(undomoney) undoMoney FROM Finance_SupplierMoneyView");
            sb.Append(" where " + whereStr);
            sb.Append(" group by cateId, custId, Caption");
            sb.Append(") a");
            sb.Append(" left join Supplier_BaseInfo sp on sp.Id=a.CustId");
            sb.Append(")a where rownum > " + (pageindex - 1) * pagesize);
            sb.Append(" order by " + sort);
            SqlDataItem sqlItem = new SqlDataItem();
            sqlItem.CommandText = sb.ToString();
            sqlItem.DatabaseName = DataBaseName;
            sqlItem.AppendParameter("@cateId", cateId);
            sqlItem.AppendParameter("@organizeId", organizeId);
            ClientDBAgent agent = new ClientDBAgent();
            return agent.ExecuteDataTable(sqlItem);
        }
        public override DataTable GetListTable(string organizeId, string cateEnCode, string cateId, string queryJson, int pageindex, int pagesize, string sort)
        {
            SqlDataItem sqlItem = new SqlDataItem();
            if (sort.IsEmpty()) sort = "Caption";
            sort = sort.ToLower().Replace("caption", "a.caption");
            var queryParam = queryJson.ToJObject();
            string whereStr = " organizeId=@organizeId ";
            string grpwhereStr = "  1=1 ";//分组和条件
           //分类编号
            if (!cateEnCode.IsEmpty())