bankrollitem.cs

动易SiteFactory&#8482 网上商店系统1.0源代码

namespace PowerEasy.SqlServerDal.Accessories
{
    using Microsoft.Practices.EnterpriseLibrary.Data;
    using PowerEasy.Enumerations;
    using PowerEasy.IDal.Accessories;
    using PowerEasy.Model.Accessories;
    using PowerEasy.SqlServerDal;
    using System;
    using System.Collections;
    using System.Collections.Generic;
    using System.Data;
    using System.Data.Common;

    public class BankrollItem : IBankrollItem
    {
        private int m_TotalOfBankrollItem;
        private int m_TotalOfBill;

        public bool Add(BankrollItemInfo bankrollItemInfo)
        {
            Parameters cmdParams = GetParameters(bankrollItemInfo);
            cmdParams.AddInParameter("@Memo", DbType.String, bankrollItemInfo.Memo);
            return DBHelper.ExecuteProc("PR_Accessories_BankrollItem_Add", cmdParams);
        }

        private static BankrollItemInfo BankrollItemFromrdr(NullableDataReader rdr)
        {
            BankrollItemInfo info = new BankrollItemInfo();
            info.ItemId = rdr.GetInt32("ItemID");
            info.UserName = rdr.GetString("UserName");
            info.ClientId = rdr.GetInt32("ClientID");
            info.DateAndTime = rdr.GetNullableDateTime("DateAndTime");
            info.Money = rdr.GetDecimal("Money");
            info.MoneyType = rdr.GetInt32("MoneyType");
            info.CurrencyType = rdr.GetInt32("CurrencyType");
            info.EBankId = rdr.GetInt32("eBankID");
            info.Bank = rdr.GetString("Bank");
            info.OrderId = rdr.GetInt32("OrderID");
            info.PaymentId = rdr.GetInt32("PaymentID");
            info.Remark = rdr.GetString("Remark");
            info.LogTime = rdr.GetNullableDateTime("LogTime");
            info.Inputer = rdr.GetString("Inputer");
            info.IP = rdr.GetString("IP");
            info.Status = (BankrollItemStatus) rdr.GetInt32("Status");
            info.Memo = rdr.GetString("Memo");
            return info;
        }

        private static void ComplexSearch(string keyword, Database db, DbCommand procdbComm)
        {
            if (!string.IsNullOrEmpty(keyword))
            {
                string str = "";
                string[] strArray = keyword.Split(new char[] { '|' });
                string str2 = strArray[0];
                string str3 = strArray[1];
                string str4 = strArray[2];
                string str5 = strArray[3];
                string str6 = strArray[4];
                string str7 = strArray[5];
                string str8 = strArray[6];
                if ((!string.IsNullOrEmpty(str2) && !string.IsNullOrEmpty(str3)) && ((str2 != "0") && (str3 != "0")))
                {
                    string str9 = str;
                    str = str9 + " ( B.ItemID Between " + str2 + " and " + str3 + ")";
                }
                if (!string.IsNullOrEmpty(str4) && !string.IsNullOrEmpty(str5))
                {
                    string str10 = str + (string.IsNullOrEmpty(str) ? "" : " and ");
                    str = str10 + " ( B.DateAndTime Between '" + str4 + "' and '" + str5 + "') ";
                }
                if (!string.IsNullOrEmpty(str6))
                {
                    str = (str + (string.IsNullOrEmpty(str) ? "" : " and ")) + "( C.ShortedForm like '%" + str6 + "%') ";
                }
                if (!string.IsNullOrEmpty(str7))
                {
                    str = (str + (string.IsNullOrEmpty(str) ? "" : " and ")) + "( B.UserName like '%" + str7 + "%') ";
                }
                if (!string.IsNullOrEmpty(str8))
                {
                    str = (str + (string.IsNullOrEmpty(str) ? "" : " and ")) + " ( B.Bank='" + str8 + "') ";
                }
                db.SetParameterValue(procdbComm, "@Filter", str);
            }
        }

        public bool Confirm(int itemId, BankrollItemStatus status)
        {
            string strSql = "update PE_BankrollItem set Status=@Status where itemId=@itemId";
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@Status", DbType.Int32, (int) status);
            cmdParams.AddInParameter("@itemId", DbType.Int32, itemId);
            return DBHelper.ExecuteSql(strSql, cmdParams);
        }

        public bool Delete(int itemId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@ItemId", DbType.Int32, itemId);
            return DBHelper.ExecuteSql("Delete PE_BankrollItem Where [ItemId] = @ItemId", cmdParams);
        }

        public bool ExistsConfirmRemittance(int orderId)
        {
            string strSql = "Select ItemID from PE_BankrollItem where OrderID=@OrderID and Status=0";
            return DBHelper.ExistsSql(strSql, new Parameters("@OrderID", DbType.Int32, orderId));
        }

        public bool ExistsPaymentLog(int paymentId)
        {
            return DBHelper.Exists(CommandType.Text, "select * from PE_BankrollItem where PaymentID=@PaymentID", new Parameters("@PaymentID", DbType.Int32, paymentId));
        }

        public BankrollItemInfo GetBankrollItemById(int itemId)
        {
            Database database = DatabaseFactory.CreateDatabase();
            DbCommand sqlStringCommand = database.GetSqlStringCommand("Select * From PE_BankrollItem Where [ItemId] = @ItemId");
            database.AddInParameter(sqlStringCommand, "@ItemId", DbType.Int32, itemId);
            using (NullableDataReader reader = new NullableDataReader(database.ExecuteReader(sqlStringCommand)))
            {
                if (reader.Read())
                {
                    return BankrollItemFromrdr(reader);
                }
                return new BankrollItemInfo(true);
            }
        }

        public DataTable GetBillOfAgent(int startRowIndexId, int maxNumberRows, string userName)
        {
            Database database = DatabaseFactory.CreateDatabase();
            DbCommand storedProcCommand = database.GetStoredProcCommand("PR_Accessories_BankroolItem_GetBill");
            database.AddInParameter(storedProcCommand, "@StartRows", DbType.Int32, startRowIndexId);
            database.AddInParameter(storedProcCommand, "@PageSize", DbType.Int32, maxNumberRows);
            database.AddInParameter(storedProcCommand, "@SortColumn", DbType.String, "B.OrderID");
            database.AddInParameter(storedProcCommand, "@StrColumn", DbType.String, "Max(O.OrderNum) as tOrderNum,sum(B.Money) as tMoney,Max(B.DateAndTime) as tDateAndTime,Max(B.Remark) as tRemark");
            database.AddInParameter(storedProcCommand, "@Sorts", DbType.String, "desc");
            database.AddInParameter(storedProcCommand, "@Filter", DbType.String, "B.UserName='" + userName + "' ");
            database.AddInParameter(storedProcCommand, "@TableName", DbType.String, "PE_BankrollItem B Left join PE_Orders O On B.OrderID=O.OrderID");
            database.AddOutParameter(storedProcCommand, "@Total", DbType.Int32, maxNumberRows);
            DataTable table = new DataTable();
            table.Columns.Add("DateAndTime", typeof(DateTime));
            table.Columns.Add("OrderNum", typeof(string));
            table.Columns.Add("Money", typeof(decimal));
            table.Columns.Add("Remark", typeof(string));
            using (NullableDataReader reader = new NullableDataReader(database.ExecuteReader(storedProcCommand)))
            {
                while (reader.Read())
                {
                    DataRow row = table.NewRow();
                    row["DateAndTime"] = reader.GetDateTime("tDateAndTime");
                    row["OrderNum"] = reader.GetString("tOrderNum");
                    row["Money"] = reader.GetDecimal("tMoney");
                    row["Remark"] = reader.GetString("tRemark");
                    table.Rows.Add(row);
                }
            }
            this.m_TotalOfBill = (int) database.GetParameterValue(storedProcCommand, "@Total");
            return table;
        }

        private static ArrayList GetIncomeAndPayout(string sql)
        {
            ArrayList list = new ArrayList();
            using (NullableDataReader reader = DBHelper.ExecuteReaderSql(sql))
            {
                if (reader.Read())
                {
                    list.Add(reader[0]);
                }
                if (reader.NextResult() && reader.Read())
                {
                    list.Add(reader[0]);