userpointlog.cs

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

                    info.Memo = reader.GetString("Memo");
                    return info;
                }
                return new PowerEasy.Model.UserManage.UserPointLogInfo(true);
            }
        }

        public PowerEasy.Model.UserManage.UserPointLogInfo GetPointLogByIdAndUserName(int logId, string userName)
        {
            string strSql = "select * from PE_PointLog where LogID = @LogID AND UserName=@UserName";
            Parameters cmdParams = new Parameters("@LogID", DbType.Int32, logId);
            cmdParams.AddInParameter("@UserName", DbType.String, userName);
            using (NullableDataReader reader = DBHelper.ExecuteReaderSql(strSql, cmdParams))
            {
                if (reader.Read())
                {
                    PowerEasy.Model.UserManage.UserPointLogInfo info = UserPointLogInfo(reader);
                    info.Memo = reader.GetString("Memo");
                    return info;
                }
                return new PowerEasy.Model.UserManage.UserPointLogInfo(true);
            }
        }

        private static Parameters GetProcdbComm(PowerEasy.Model.UserManage.UserPointLogInfo userPointLogInfo)
        {
            Parameters parameters = new Parameters();
            parameters.AddInParameter("@LogID", DbType.Int32, userPointLogInfo.LogId);
            parameters.AddInParameter("@UserName", DbType.String, userPointLogInfo.UserName);
            parameters.AddInParameter("@ModuleType", DbType.Int32, userPointLogInfo.ModuleType);
            parameters.AddInParameter("@InfoID", DbType.Int32, userPointLogInfo.InfoId);
            parameters.AddInParameter("@Point", DbType.Int32, userPointLogInfo.Point);
            parameters.AddInParameter("@LogTime", DbType.DateTime, userPointLogInfo.LogTime);
            parameters.AddInParameter("@Times", DbType.Int32, userPointLogInfo.Times);
            parameters.AddInParameter("@IncomePayOut", DbType.Int32, userPointLogInfo.IncomePayOut);
            parameters.AddInParameter("@Remark", DbType.String, userPointLogInfo.Remark);
            parameters.AddInParameter("@IP", DbType.String, userPointLogInfo.IP);
            parameters.AddInParameter("@Inputer", DbType.String, userPointLogInfo.Inputer);
            parameters.AddInParameter("@Memo", DbType.String, userPointLogInfo.Memo);
            return parameters;
        }

        public ArrayList GetTotalInComeAndPayOutAll()
        {
            return GetIncomeAndPayout("select Isnull(sum(Point),0) from PE_PointLog Where [Point]>0 and IncomePayout=1 ; select Isnull(sum(Point),0) from PE_PointLog Where Point>0 and IncomePayout=2");
        }

        public ArrayList GetTotalInComeAndPayOutAll(string userName)
        {
            return GetIncomeAndPayout("select Isnull(sum(Point),0) from PE_PointLog Where [Point]>0 and IncomePayout=1 and UserName = '" + userName + "'; select Isnull(sum(Point),0) from PE_PointLog Where Point>0 and IncomePayout=2 and UserName = '" + userName + "'");
        }

        public int GetValidPointLogId(string userName, int moduleType, int infoId, int chargeType, int pitchTime, int readTimes)
        {
            Parameters cmdParams = new Parameters();
            string strSql = "select top 1 LogID from PE_PointLog";
            string str2 = string.Concat(new object[] { " where UserName='", userName, "' and ModuleType=", moduleType, " and InfoID=", infoId, " and IncomePayout=2 " });
            switch (chargeType)
            {
                case 0:
                    strSql = strSql + str2;
                    break;

                case 1:
                    strSql = strSql + str2 + " and DateDiff(hh,LogTime,GetDate())<" + pitchTime.ToString();
                    break;

                case 2:
                    strSql = strSql + str2 + " and Times< " + readTimes.ToString();
                    break;

                case 3:
                {
                    string str3 = strSql;
                    strSql = str3 + str2 + " and DateDiff(hh,LogTime,GetDate())<" + pitchTime.ToString() + " or Times<" + readTimes.ToString();
                    break;
                }
                case 4:
                {
                    string str4 = strSql;
                    strSql = str4 + str2 + " and DateDiff(hh,LogTime,GetDate())<" + pitchTime.ToString() + " and Times<" + readTimes.ToString();
                    break;
                }
                case 5:
                    strSql = strSql + " where 1=0 ";
                    break;
            }
            return DataConverter.CLng(DBHelper.ExecuteScalarSql(strSql, cmdParams));
        }

        public int PointSum(int sumType)
        {
            Database database = DatabaseFactory.CreateDatabase();
            DbCommand storedProcCommand = database.GetStoredProcCommand("PR_UserManage_UserPointLog_PointSum");
            database.AddInParameter(storedProcCommand, "@SumType", DbType.String, sumType);
            try
            {
                return (Convert.IsDBNull(database.ExecuteScalar(storedProcCommand)) ? 0 : Convert.ToInt32(storedProcCommand));
            }
            catch
            {
                return 0;
            }
        }

        public int PointSum(int sumType, string userName)
        {
            Database database = DatabaseFactory.CreateDatabase();
            DbCommand storedProcCommand = database.GetStoredProcCommand("PR_UserManage_UserPointLog_UserPointSum");
            database.AddInParameter(storedProcCommand, "@SumType", DbType.String, sumType);
            database.AddInParameter(storedProcCommand, "@UserName", DbType.String, userName);
            try
            {
                return (Convert.IsDBNull(database.ExecuteScalar(storedProcCommand)) ? 0 : Convert.ToInt32(storedProcCommand));
            }
            catch
            {
                return 0;
            }
        }

        public bool UpdateTimes(int id, string ip)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@Id", DbType.String, id);
            cmdParams.AddInParameter("@Ip", DbType.String, ip);
            return DBHelper.ExecuteProc("PR_UserManage_UserPointLog_UpdateTimes", cmdParams);
        }

        public void UpdateTimes(string userTrueIP, int logId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@userTrueIP", DbType.String, userTrueIP);
            cmdParams.AddInParameter("@LogId", DbType.Int32, logId);
            string strSql = "update PE_PointLog set Times=Times+1,IP=@userTrueIP where LogID=@LogId";
            DBHelper.ExecuteSql(strSql, cmdParams);
        }

        private static PowerEasy.Model.UserManage.UserPointLogInfo UserPointLogInfo(NullableDataReader rdr)
        {
            PowerEasy.Model.UserManage.UserPointLogInfo info = new PowerEasy.Model.UserManage.UserPointLogInfo();
            info.LogId = rdr.GetInt32("LogID");
            info.UserName = rdr.GetString("UserName");
            info.ModuleType = rdr.GetInt32("ModuleType");
            info.InfoId = rdr.GetInt32("InfoID");
            info.Point = rdr.GetInt32("Point");
            info.LogTime = rdr.GetDateTime("LogTime");
            info.Times = rdr.GetInt32("Times");
            info.IncomePayOut = rdr.GetInt32("IncomePayOut");
            info.Remark = rdr.GetString("Remark");
            info.IP = rdr.GetString("IP");
            info.Inputer = rdr.GetString("Inputer");
            return info;
        }

        public int ViewInfosOneDay(string userName)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@UserName", DbType.String, userName);
            string strSql = "select count(0) from PE_PointLog where UserName=@UserName and IncomePayout=2 and InfoID>0 and DateDiff(d,LogTime,GetDate())<1";
            return DataConverter.CLng(DBHelper.ExecuteScalarSql(strSql, cmdParams));
        }

        public int ViewTotalInfos(string userName)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@UserName", DbType.String, userName);
            string strSql = "select count(0) from PE_PointLog where UserName=@UserName and IncomePayout=2 and InfoID>0";
            return DataConverter.CLng(DBHelper.ExecuteScalarSql(strSql, cmdParams));
        }
    }
}