kxs_ap_server_v2/Service/Rds/RdsMainService.cs

/*
 * 广告位
 */

using System;
using System.Collections.Generic;
using System.Linq;
using System.Data;
using MySystem.Models.Main;
using Library;
using LitJson;

namespace MySystem.Service.Main
{
    public class RdsMainService
    {
        string _conn = "";
        string _table = "";
        public RdsMainService(string table)
        {
            _conn = ConfigurationManager.AppSettings["RdsMainSqlConnStr"].ToString();
            _table = table;
        }

        /// <summary>
        /// 查询列表
        /// </summary>
        /// <param name="relationData">关联表</param>
        /// <param name="condition">查询条件(sql语句)</param>
        /// <param name="count">总数（输出）</param>
        /// <param name="page">页码</param>
        /// <param name="limit">每页条数</param>
        /// <returns></returns>
        public List<Dictionary<string, object>> List(List<RelationData> relationData, List<string> fields, string orderBy, string condition, out int count, int page = 1, int limit = 30)
        {
            orderBy = _table + "." + orderBy.Replace(",", "," + _table + ".");
            Dictionary<string, object> obj = new DbService(AppConfig.Base.rdsMainTables, _conn).IndexData(_table, relationData, orderBy, page, limit, condition, fields);
            List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
            count = int.Parse(obj["count"].ToString());
            return diclist;
        }
        public List<Dictionary<string, object>> List(List<RelationData> relationData, List<string> fields, string orderBy, string condition, int page = 1, int limit = 30)
        {
            orderBy = _table + "." + orderBy.Replace(",", "," + _table + ".");
            Dictionary<string, object> obj = new DbService(AppConfig.Base.rdsMainTables, _conn).IndexData(_table, relationData, orderBy, page, limit, condition, fields);
            List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
            return diclist;
        }

        /// <summary>
        /// 查询一条记录
        /// </summary>
        /// <param name="Id">主键Id</param>
        /// <returns></returns>
        public Dictionary<string, object> Query(int id)
        {
            return new DbService(AppConfig.Base.rdsMainTables, _conn).Query("*", _table, id);
        }

        public Dictionary<string, object> Query(string condition)
        {
            return new DbService(AppConfig.Base.rdsMainTables, _conn).Query("*", _table, condition);
        }

        /// <summary>
        /// 查询记录数
        /// </summary>
        /// <returns></returns>
        public int Count(string condition, string field = "Id")
        {
            Dictionary<string, object> obj = new DbService(AppConfig.Base.rdsMainTables, _conn).Query("count(" + field + ") num", _table, condition);
            return obj.Count > 0 ? int.Parse(obj["num"].ToString()) : 0;
        }

        /// <summary>
        /// 查询总和
        /// </summary>
        /// <returns></returns>
        public int Sum(string condition, string field = "Id")
        {
            Dictionary<string, object> obj = new DbService(AppConfig.Base.rdsMainTables, _conn).Query("sum(" + field + ") num", _table, condition);
            return obj.Count > 0 ? int.Parse(obj["num"].ToString()) : 0;
        }

        /// <summary>
        /// 查询是否存在
        /// </summary>
        /// <param name="Id">主键Id</param>
        /// <returns></returns>
        public bool Exist(string condition, string field = "1")
        {
            return new DbService(AppConfig.Base.rdsMainTables, _conn).Query(field, _table, condition).Count > 0 ? true : false;
        }
    }
}