数据库优化

SmsPlatform/BLL/T_Sys_UserAccount.cs

@@ -0,0 +1,203 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using System.Data;
+using System.Collections.Generic;
+
+namespace SmsPlatform.BLL
+{
+    /// <summary>
+	/// T_Sys_UserAccount
+	/// </summary>
+	public partial class T_Sys_UserAccount
+    {
+        private readonly DAL.T_Sys_UserAccount dal = new DAL.T_Sys_UserAccount();
+        public T_Sys_UserAccount()
+        { }
+        #region  BasicMethod
+
+        /// <summary>
+        /// 得到最大ID
+        /// </summary>
+        public int GetMaxId()
+        {
+            return dal.GetMaxId();
+        }
+
+        /// <summary>
+        /// 是否存在该记录
+        /// </summary>
+        public bool Exists(int F_UserId)
+        {
+            return dal.Exists(F_UserId);
+        }
+
+        /// <summary>
+        /// 增加一条数据
+        /// </summary>
+        public int Add(Model.T_Sys_UserAccount model)
+        {
+            return dal.Add(model);
+        }
+
+        /// <summary>
+        /// 更新一条数据
+        /// </summary>
+        public bool Update(Model.T_Sys_UserAccount model)
+        {
+            return dal.Update(model);
+        }
+
+        /// <summary>
+        /// 删除一条数据
+        /// </summary>
+        public bool Delete(int F_UserId)
+        {
+
+            return dal.Delete(F_UserId);
+        }
+        /// <summary>
+        /// 删除一条数据
+        /// </summary>
+        public bool DeleteList(string F_UserIdlist)
+        {
+            return dal.DeleteList(F_UserIdlist);
+        }
+
+        /// <summary>
+        /// 得到一个对象实体
+        /// </summary>
+        public Model.T_Sys_UserAccount GetModel(int F_UserId)
+        {
+
+            return dal.GetModel(F_UserId);
+        }
+
+        ///// <summary>
+        ///// 得到一个对象实体，从缓存中
+        ///// </summary>
+        //public HySoft.XKPCallCenter.Model.T_Sys_UserAccount GetModelByCache(int F_UserId)
+        //{
+
+        //    string CacheKey = "T_Sys_UserAccountModel-" + F_UserId;
+        //    object objModel = Maticsoft.Common.DataCache.GetCache(CacheKey);
+        //    if (objModel == null)
+        //    {
+        //        try
+        //        {
+        //            objModel = dal.GetModel(F_UserId);
+        //            if (objModel != null)
+        //            {
+        //                int ModelCache = Maticsoft.Common.ConfigHelper.GetConfigInt("ModelCache");
+        //                Maticsoft.Common.DataCache.SetCache(CacheKey, objModel, DateTime.Now.AddMinutes(ModelCache), TimeSpan.Zero);
+        //            }
+        //        }
+        //        catch{}
+        //    }
+        //    return (HySoft.XKPCallCenter.Model.T_Sys_UserAccount)objModel;
+        //}
+
+        /// <summary>
+        /// 获得数据列表
+        /// </summary>
+        public DataSet GetList(string strWhere)
+        {
+            return dal.GetList(strWhere);
+        }
+        public DataSet GetListView(string strWhere)
+        {
+            return dal.GetListView(strWhere);
+        }
+        /// <summary>
+        /// 获得前几行数据
+        /// </summary>
+        public DataSet GetList(int Top, string strWhere, string filedOrder)
+        {
+            return dal.GetList(Top, strWhere, filedOrder);
+        }
+        /// <summary>
+        /// 获得数据列表
+        /// </summary>
+        public List<Model.T_Sys_UserAccount> GetModelList(string strWhere)
+        {
+            DataSet ds = dal.GetList(strWhere);
+            return DataTableToList(ds.Tables[0]);
+        }
+        /// <summary>
+        /// 获得数据列表
+        /// </summary>
+        public List<Model.T_Sys_UserAccount> DataTableToList(DataTable dt)
+        {
+            List<Model.T_Sys_UserAccount> modelList = new List<Model.T_Sys_UserAccount>();
+            int rowsCount = dt.Rows.Count;
+            if (rowsCount > 0)
+            {
+                Model.T_Sys_UserAccount model;
+                for (int n = 0; n < rowsCount; n++)
+                {
+                    model = dal.DataRowToModel(dt.Rows[n]);
+                    if (model != null)
+                    {
+                        modelList.Add(model);
+                    }
+                }
+            }
+            return modelList;
+        }
+
+        public List<Model.T_Sys_UserAccount> DataTableToList1(DataTable dt)
+        {
+            List<Model.T_Sys_UserAccount> modelList = new List<Model.T_Sys_UserAccount>();
+            int rowsCount = dt.Rows.Count;
+            if (rowsCount > 0)
+            {
+                Model.T_Sys_UserAccount model;
+                for (int n = 0; n < rowsCount; n++)
+                {
+                    model = dal.DataRowToModel1(dt.Rows[n]);
+                    if (model != null)
+                    {
+                        modelList.Add(model);
+                    }
+                }
+            }
+            return modelList;
+        }
+
+        /// <summary>
+        /// 获得数据列表
+        /// </summary>
+        public DataSet GetAllList()
+        {
+            return GetList("");
+        }
+
+        /// <summary>
+        /// 分页获取数据列表
+        /// </summary>
+        public int GetRecordCount(string strWhere)
+        {
+            return dal.GetRecordCount(strWhere);
+        }
+        /// <summary>
+        /// 分页获取数据列表
+        /// </summary>
+        public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
+        {
+            return dal.GetListByPage(strWhere, orderby, startIndex, endIndex);
+        }
+        /// <summary>
+        /// 分页获取数据列表
+        /// </summary>
+        //public DataSet GetList(int PageSize,int PageIndex,string strWhere)
+        //{
+        //return dal.GetList(PageSize,PageIndex,strWhere);
+        //}
+
+        #endregion  BasicMethod
+        #region  ExtensionMethod
+
+        #endregion  ExtensionMethod
+    }
+}

SmsPlatform/Common/CommandInfo.cs

@@ -0,0 +1,74 @@
+using System;
+using System.Collections.Generic;
+using System.Data.SqlClient;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace SmsPlatform.Common
+{
+    public enum EffentNextType
+    {
+        /// <summary>
+        /// 对其他语句无任何影响 
+        /// </summary>
+        None,
+        /// <summary>
+        /// 当前语句必须为"select count(1) from .."格式，如果存在则继续执行，不存在回滚事务
+        /// </summary>
+        WhenHaveContine,
+        /// <summary>
+        /// 当前语句必须为"select count(1) from .."格式，如果不存在则继续执行，存在回滚事务
+        /// </summary>
+        WhenNoHaveContine,
+        /// <summary>
+        /// 当前语句影响到的行数必须大于0，否则回滚事务
+        /// </summary>
+        ExcuteEffectRows,
+        /// <summary>
+        /// 引发事件-当前语句必须为"select count(1) from .."格式，如果不存在则继续执行，存在回滚事务
+        /// </summary>
+        SolicitationEvent
+    }
+    public class CommandInfo
+    {
+        public object ShareObject = null;
+        public object OriginalData = null;
+        event EventHandler _solicitationEvent;
+        public event EventHandler SolicitationEvent
+        {
+            add
+            {
+                _solicitationEvent += value;
+            }
+            remove
+            {
+                _solicitationEvent -= value;
+            }
+        }
+        public void OnSolicitationEvent()
+        {
+            if (_solicitationEvent != null)
+            {
+                _solicitationEvent(this, new EventArgs());
+            }
+        }
+        public string CommandText;
+        public System.Data.Common.DbParameter[] Parameters;
+        public EffentNextType EffentNextType = EffentNextType.None;
+        public CommandInfo()
+        {
+
+        }
+        public CommandInfo(string sqlText, SqlParameter[] para)
+        {
+            this.CommandText = sqlText;
+            this.Parameters = para;
+        }
+        public CommandInfo(string sqlText, SqlParameter[] para, EffentNextType type)
+        {
+            this.CommandText = sqlText;
+            this.Parameters = para;
+            this.EffentNextType = type;
+        }
+    }
+}

SmsPlatform/Common/RedisHelper.cs

@@ -0,0 +1,836 @@
+using Newtonsoft.Json;
+using StackExchange.Redis;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace SmsPlatform.Common
+{
+    public abstract class RedisHelper
+    {
+        public static string connserver = "";
+        public static string connport = "";
+
+        #region 
+        //执行顺序---静态字段---静态构造函数---构造函数
+        private static ConnectionMultiplexer redis;
+        private static IDatabase database;
+        static RedisHelper()
+        {
+            if (connserver != "" && connport != "")
+            {
+                if (redis == null || !redis.IsConnected)
+                {
+                    redis = ConnectionMultiplexer.Connect(connserver + ":" + connport);
+                    //redis = ConnectionMultiplexer.Connect("192.168.4.18, abortConnect=false");
+
+                    database = redis.GetDatabase(10);
+                }
+            }
+        }
+
+        #endregion
+
+        /// <summary>
+        /// 判断是否连接
+        /// </summary>
+        /// <returns></returns>
+        public static bool IsCon()
+        {
+            if (redis == null || !redis.IsConnected)
+            {
+                try
+                {
+                    redis = ConnectionMultiplexer.Connect(connserver + ":" + connport);
+                    //redis = ConnectionMultiplexer.Connect("192.168.4.18, abortConnect=false");
+
+                    database = redis.GetDatabase(15);
+                }
+                catch (Exception e)
+                {
+                    return false;
+                }
+                
+            }
+            return redis.IsConnected;
+            
+
+        }
+
+        #region redis 字符串（string）操作
+
+        /// <summary>
+        /// 设置指定键的值
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="value"></param>
+        /// <returns></returns>
+        public static bool StringSet(string key, string value)
+        {
+            return database.StringSet(key, value);
+        }
+
+        /// <summary>
+        /// 获取指定键的值
+        /// </summary>
+        /// <param name="key"></param>
+        /// <returns></returns>
+        public static object StringGet(string key)
+        {
+            if (redis == null || !redis.IsConnected)
+            {
+                redis = ConnectionMultiplexer.Connect(connserver + ":" + connport);
+                //redis = ConnectionMultiplexer.Connect("192.168.4.18, abortConnect=false");
+
+                database = redis.GetDatabase(15);
+            }
+            if (database.KeyExists(key))
+            {
+                var rt = database.StringGet(key);
+
+                if (rt.IsNull)
+                {
+                    return null;
+                }
+                else
+                {
+                    return rt;
+                }
+            }
+            else
+            { return null; }
+        }
+
+        /// <summary>
+        /// 获取存储在键上的字符串的子字符串
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="start"></param>
+        /// <param name="end"></param>
+        /// <returns></returns>
+        public static object StringGet(string key, int start, int end)
+        {
+            var rt = database.StringGetRange(key, start, end);
+            if (rt.IsNull)
+            {
+                return null;
+            }
+            else
+            {
+                return rt;
+            }
+        }
+
+        /// <summary>
+        /// 设置键的字符串值并返回其旧值
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="value"></param>
+        /// <returns></returns>
+        public static object StringGetAndSet(string key, string value)
+        {
+            var rt = database.StringGetSet(key, value);
+            if (rt.IsNull)
+            {
+                return null;
+            }
+            else
+            {
+                return rt;
+            }
+        }
+
+        /// <summary>
+        /// 返回在键处存储的字符串值中偏移处的位值
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="offset"></param>
+        /// <returns></returns>
+        public static bool StringGetBit(string key, long offset)
+        {
+            return database.StringGetBit(key, offset);
+        }
+
+        /// <summary>
+        /// 获取所有给定键的值
+        /// </summary>
+        /// <param name="keys"></param>
+        /// <returns></returns>
+        public static List<object> StringMultiGet(string[] keys)
+        {
+            List<object> list = new List<object>();
+            for (int i = 0; i < keys.Length; i++)
+            {
+                list.Add(database.StringGet(keys[i]));
+            }
+            return list;
+        }
+
+        /// <summary>
+        /// 存储在键上的字符串值中设置或清除偏移处的位
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="offset"></param>
+        /// <param name="value"></param>
+        /// <returns></returns>
+        public static bool StringSetBit(string key, long offset)
+        {
+            return database.StringSetBit(key, offset, true);
+        }
+
+        /// <summary>
+        /// 使用键和到期时间来设置值
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="value"></param>
+        /// <param name="expiry"></param>
+        /// <returns></returns>
+        public static bool StringSet(string key, string value, TimeSpan expiry)
+        {
+            return database.StringSet(key, value, expiry);
+        }
+
+        /// <summary>
+        /// 设置键的值，仅当键不存在时
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="value"></param>
+        /// <returns></returns>
+        public static void StringSetIfAbsent(string key, string value)
+        {
+            if (database.StringGet(key) == RedisValue.Null)
+            {
+                database.StringSet(key, value);
+            }
+        }
+
+        /// <summary>
+        /// 在指定偏移处开始的键处覆盖字符串的一部分
+        /// </summary>
+        /// <param name="key">键值</param>
+        /// <param name="value">值</param>
+        /// <param name="offset">偏移量</param>
+        /// <returns></returns>
+        public static object StringSet(string key, long offset, string value)
+        {
+            return database.StringSetRange(key, offset, value);
+        }
+
+        /// <summary>
+        /// 获取存储在键中的值的长度
+        /// </summary>
+        /// <param name="key">键值</param>
+        /// <returns></returns>
+        public static long StringSize(string key)
+        {
+            return database.StringLength(key);
+        }
+
+        /// <summary>
+        /// 为多个键分别设置它们的值
+        /// </summary>
+        /// <param name="keys"></param>
+        /// <returns></returns>
+        public static void StringMultiSet(Dictionary<string, string> dic)
+        {
+            foreach (KeyValuePair<string, string> key in dic)
+            {
+                database.StringSet(key.Key, key.Value);
+            }
+        }
+
+        /// <summary>
+        /// 为多个键分别设置它们的值，仅当键不存在时
+        /// </summary>
+        /// <param name="keys">键值集合</param>
+        /// <returns></returns>
+        public static void StringMultiSetIfAbsent(Dictionary<string, string> dic)
+        {
+            foreach (KeyValuePair<string, string> key in dic)
+            {
+                //判断键值是否存在
+                if (database.StringGet(key.Key) == RedisValue.Null)
+                {
+                    database.StringSet(key.Key, key.Value);
+                }
+            }
+        }
+
+        /// <summary>
+        /// 将键的整数值按给定的数值增加
+        /// </summary>
+        /// <param name="key">键值</param>
+        /// <param name="value">给定的数值</param>
+        /// <returns></returns>
+        public static double StringIncrement(string key, double value)
+        {
+            return database.StringIncrement(key, value);
+        }
+
+        /// <summary>
+        /// 在key键对应值的右面追加值value
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="value"></param>
+        /// <returns></returns>
+        public static long StringAppend(string key, string value)
+        {
+            return database.StringAppend(key, value);
+        }
+
+        /// <summary>
+        /// 删除某个键值
+        /// </summary>
+        /// <param name="key"></param>
+        /// <returns></returns>
+        public static bool StringDelete(string key)
+        {
+            return false;
+        }
+
+        #endregion
+
+        #region redis 哈希/散列/字典（Hash）操作
+
+        /// <summary>
+        /// 删除指定的哈希字段
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="field"></param>
+        /// <returns></returns>
+        public static bool HashDelete(string key, string field)
+        {
+            return database.HashDelete(key, field);
+        }
+
+        /// <summary>
+        /// 判断是否存在散列字段
+        /// </summary>
+        /// <param name=""></param>
+        /// <param name=""></param>
+        /// <returns></returns>
+        public static bool HashHasKey(string key, string field)
+        {
+            return database.HashExists(key, field);
+        }
+
+        /// <summary>
+        /// 获取存储在指定键的哈希字段的值
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="field"></param>
+        /// <returns></returns>
+        public static object HashGet(string key, string field)
+        {
+            return database.HashGet(key, field);
+        }
+
+        /// <summary>
+        /// 获取存储在指定键的哈希中的所有字段和值
+        /// </summary>
+        /// <param name="key"></param>
+        /// <returns></returns>
+        public static Dictionary<string, object> HashGetAll(string key)
+        {
+            Dictionary<string, object> dic = new Dictionary<string, object>();
+            var collection = database.HashGetAll(key);
+            foreach (var item in collection)
+            {
+                dic.Add(item.Name, item.Value);
+            }
+            return dic;
+        }
+
+        /// <summary>
+        /// 将哈希字段的浮点值按给定数值增加
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="field"></param>
+        /// <param name="value">给定的数值</param>
+        /// <returns></returns>
+        public static double HashIncrement(string key, string field, double value)
+        {
+            return database.HashIncrement(key, field, value);
+        }
+
+        /// <summary>
+        /// 获取哈希中的所有字段
+        /// </summary>
+        /// <param name="key"></param>
+        /// <returns></returns>
+        public static string[] HashKeys(string key)
+        {
+            return database.HashKeys(key).ToStringArray();
+        }
+
+        /// <summary>
+        /// 获取散列中的字段数量
+        /// </summary>
+        /// <param name="key"></param>
+        /// <returns></returns>
+        public static long HashSize(string key)
+        {
+            return database.HashLength(key);
+        }
+
+        /// <summary>
+        /// 获取所有给定哈希字段的值
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="hashKeys"></param>
+        /// <returns></returns>
+        public static List<object> HashMultiGet(string key, List<string> hashKeys)
+        {
+            List<object> result = new List<object>();
+            foreach (string field in hashKeys)
+            {
+                result.Add(database.HashGet(key, field));
+            }
+            return result;
+        }
+
+        /// <summary>
+        /// 为多个哈希字段分别设置它们的值
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="dic"></param>
+        /// <returns></returns>
+        public static void HashPutAll(string key, Dictionary<string, string> dic)
+        {
+            List<HashEntry> list = new List<HashEntry>();
+            for (int i = 0; i < dic.Count; i++)
+            {
+                KeyValuePair<string, string> param = dic.ElementAt(i);
+                list.Add(new HashEntry(param.Key, param.Value));
+            }
+            database.HashSet(key, list.ToArray());
+        }
+
+        /// <summary>
+        /// 设置散列字段的字符串值
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="field"></param>
+        /// <param name="value"></param>
+        /// <returns></returns>
+        public static void HashPut(string key, string field, string value)
+        {
+            database.HashSet(key, new HashEntry[] { new HashEntry(field, value) });
+        }
+
+        /// <summary>
+        /// 仅当字段不存在时，才设置散列字段的值
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="fiels"></param>
+        /// <param name="value"></param>
+        /// <returns></returns>
+        public static void HashPutIfAbsent(string key, string field, string value)
+        {
+            if (!HashHasKey(key, field))
+            {
+                database.HashSet(key, new HashEntry[] { new HashEntry(field, value) });
+            }
+        }
+
+        /// <summary>
+        /// 获取哈希中的所有值
+        /// </summary>
+        /// <param name="key"></param>
+        /// <returns></returns>
+        public static string[] HashValues(string key)
+        {
+            return database.HashValues(key).ToStringArray();
+        }
+
+        /// <summary>
+        /// redis中获取指定键的值并返回对象
+        /// </summary>
+        /// <typeparam name="T"></typeparam>
+        /// <param name="key"></param>
+        /// <returns></returns>
+        public static T GetHashValue<T>(string key)
+        {
+            HashEntry[] array = database.HashGetAll(key);
+            Dictionary<string, object> dic = new Dictionary<string, object>();
+            for (int i = 0; i < array.Length; i++)
+            {
+                dic.Add(array[i].Name, array[i].Value);
+            }
+            if (dic.Count > 0)
+            {
+                string strJson = JsonConvert.SerializeObject(dic);
+                return JsonConvert.DeserializeObject<T>(strJson);
+            }
+            else
+            {
+                return default(T);
+            }
+        }
+
+        /// <summary>
+        /// 把指定对象存储在键值为key的redis中
+        /// </summary>
+        /// <typeparam name="T"></typeparam>
+        /// <param name="t"></param>
+        /// <param name="key"></param>
+        public static void SetHashValue<T>(T t, string key)
+        {
+            string strJson = JsonConvert.SerializeObject(t);
+            Dictionary<string, string> param = JsonConvert.DeserializeObject<Dictionary<string, string>>(strJson);
+            HashPutAll(key, param);
+        }
+
+        #endregion
+
+        #region redis 列表（List）操作
+
+        /// <summary>
+        /// 从左向右存压栈
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="value"></param>
+        /// <returns></returns>
+        public static long ListLeftPush(string key, string value)
+        {
+            return database.ListLeftPush(key, value);
+        }
+
+        /// <summary>
+        /// 从左出栈
+        /// </summary>
+        /// <param name="key"></param>
+        /// <returns></returns>
+        public static object ListLeftPop(string key)
+        {
+            return database.ListLeftPop(key);
+        }
+
+        /// <summary>
+        /// 队/栈长
+        /// </summary>
+        /// <param name="key"></param>
+        /// <returns></returns>
+        public static long ListSize(string key)
+        {
+            return database.ListLength(key);
+        }
+
+        /// <summary>
+        /// 范围检索,返回List
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="start"></param>
+        /// <param name="end"></param>
+        /// <returns></returns>
+        public static string[] ListRange(string key, int start, int end)
+        {
+            return database.ListRange(key, start, end).ToStringArray();
+        }
+
+        /// <summary>
+        /// 移除key中值为value的i个,返回删除的个数；如果没有这个元素则返回0 
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="i"></param>
+        /// <param name="value"></param>
+        /// <returns></returns>
+        public static long ListRemove(string key, string value)
+        {
+            return database.ListRemove(key, value);
+        }
+
+        /// <summary>
+        /// 检索
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="index"></param>
+        /// <returns></returns>
+        public static object ListIndex(string key, long index)
+        {
+            return database.ListGetByIndex(key, index);
+        }
+
+        /// <summary>
+        /// 赋值
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="index"></param>
+        /// <param name="value"></param>
+        /// <returns></returns>
+        public static void ListSet(string key, int index, string value)
+        {
+            database.ListSetByIndex(key, index, value);
+        }
+
+        /// <summary>
+        /// 裁剪,删除除了[start,end]以外的所有元素 
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="start"></param>
+        /// <param name="end"></param>
+        /// <returns></returns>
+        public static void ListTrim(string key, int start, int end)
+        {
+            database.ListTrim(key, start, end);
+        }
+
+        /// <summary>
+        /// 将源key的队列的右边的一个值删除，然后塞入目标key的队列的左边，返回这个值
+        /// </summary>
+        /// <param name="sourceKey"></param>
+        /// <param name="destinationKey"></param>
+        /// <returns></returns>
+        public static object ListRightPopAndLeftPush(string sourceKey, string destinationKey)
+        {
+            return database.ListRightPopLeftPush(sourceKey, destinationKey);
+        }
+
+        #endregion
+
+        #region redis 集合（Set）操作
+
+        /// <summary>
+        /// 集合添加元素
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="value"></param>
+        public static void SetAdd(string key, string value)
+        {
+            database.SetAdd(key, value);
+        }
+
+        /// <summary>
+        /// 集合组合操作
+        /// </summary>
+        /// <param name="point">操作标示：0--并集；1--交集；2--差集</param>
+        /// <param name="firstKey">第一个集合的键值</param>
+        /// <param name="secondKey">第二个集合的键值</param>
+        public static string[] SetCombine(int point, string firstKey, string secondKey)
+        {
+            RedisValue[] array;
+            switch (point)
+            {
+                case 0:
+                    array = database.SetCombine(SetOperation.Union, firstKey, secondKey);
+                    break;
+                case 1:
+                    array = database.SetCombine(SetOperation.Intersect, firstKey, secondKey);
+                    break;
+                case 2:
+                    array = database.SetCombine(SetOperation.Difference, firstKey, secondKey);
+                    break;
+                default:
+                    array = new RedisValue[0];
+                    break;
+            }
+            return array.ToStringArray();
+        }
+
+        /// <summary>
+        /// 
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="value"></param>
+        /// <returns></returns>
+        public static bool SetContains(string key, string value)
+        {
+            return database.SetContains(key, value);
+        }
+
+        /// <summary>
+        /// 返回对应键值集合的长度
+        /// </summary>
+        /// <param name="key"></param>
+        /// <returns></returns>
+        public static long SetLength(string key)
+        {
+            return database.SetLength(key);
+        }
+
+        /// <summary>
+        /// 根据键值返回集合中所有的value
+        /// </summary>
+        /// <param name="key"></param>
+        /// <returns></returns>
+        public static string[] SetMembers(string key)
+        {
+            return database.SetMembers(key).ToStringArray();
+        }
+
+        /// <summary>
+        /// 将成员从源集移动到目标集
+        /// </summary>
+        /// <param name="sourceKey">源集key</param>
+        /// <param name="destinationKey">目标集key</param>
+        /// <param name="value"></param>
+        public static bool SetMove(string sourceKey, string destinationKey, string value)
+        {
+            return database.SetMove(sourceKey, destinationKey, value);
+        }
+
+        /// <summary>
+        /// 移除集合中指定键值随机元素
+        /// </summary>
+        /// <param name="key"></param>
+        public static string SetPop(string key)
+        {
+            return database.SetPop(key);
+        }
+
+        /// <summary>
+        /// 返回集合中指定键值随机元素
+        /// </summary>
+        /// <param name="key"></param>
+        /// <returns></returns>
+        public static string SetRandomMember(string key)
+        {
+            return database.SetRandomMember(key);
+        }
+
+        /// <summary>
+        /// 
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="count"></param>
+        public static string[] SetRandomMembers(string key, long count)
+        {
+            return database.SetRandomMembers(key, count).ToStringArray();
+        }
+
+        /// <summary>
+        /// 移除集合中指定key值和value
+        /// </summary>
+        /// <param name="key"></param>
+        /// <param name="value"></param>
+        public static void SetRemove(string key, string value)
+        {
+            database.SetRemove(key, value);
+        }
+
+        /// <summary>
+        /// 
+        /// </summary>
+        /// <param name="key"></param>
+        public static void SetScan(string key)
+        {
+            database.SetScan(key);
+        }
+
+        #endregion
+
+        #region redis 有序集合（sorted set）操作
+
+        public static void Method(string key, string value, double score)
+        {
+            database.SortedSetAdd(key, new SortedSetEntry[] { new SortedSetEntry(value, score) });
+        }
+
+        #endregion
+
+        #region redis 键（Key）操作
+
+        /// <summary>
+        /// 获取 Key
+        /// </summary>
+        /// <param name="redisKey"></param>
+        /// <returns></returns>
+        //public static IEnumerable<RedisKey> GetKeyList(string redisKey)
+        //{
+        //    var server = redis.GetServer(Configs.GetValue("Redis_Server"), Configs.GetValue("Redis_Port"));
+        //    return server.Keys(pattern: "*"+ redisKey + "*");
+        //}
+        public static List<string> GetKeyList(string redisKey)
+        {
+            var server = redis.GetServer(connserver, Int32.Parse(connport)); 
+            List<string> keylist = new List<string>();
+            var redisenum = server.Keys(pattern: "*" + redisKey + "*");
+            foreach (var r in redisenum.ToList())
+            {
+                keylist.Add(r.ToString());
+            }
+            return keylist;
+        }
+
+        /// <summary>
+        /// 移除指定 Key
+        /// </summary>
+        /// <param name="redisKey"></param>
+        /// <returns></returns>
+        public static bool KeyDelete(string redisKey)
+        {
+            return database.KeyDelete(redisKey);
+        }
+
+        /// <summary>
+        /// 移除指定 Key
+        /// </summary>
+        /// <param name="redisKey"></param>
+        /// <returns></returns>
+        //public static long KeysDelete(IEnumerable<RedisKey> redisKeys)
+        //{
+        //    return database.KeyDelete(redisKeys.ToArray());
+        //}
+        public static long KeysDelete(List<string> redisKeys)
+        {
+            int n = 0;
+            foreach (var r in redisKeys)
+            {
+                if (database.KeyDelete(r))
+                {
+                    n++;
+                }
+            }
+            return n;
+        }
+
+        /// <summary>
+        /// 校验 Key 是否存在
+        /// </summary>
+        /// <param name="redisKey"></param>
+        /// <returns></returns>
+        public static bool KeyExists(string redisKey)
+        {
+            return database.KeyExists(redisKey);
+        }
+
+        /// <summary>
+        /// 重命名 Key
+        /// </summary>
+        /// <param name="redisKey"></param>
+        /// <param name="redisNewKey"></param>
+        /// <returns></returns>
+        public static bool KeyRename(string redisKey, string redisNewKey)
+        {
+            return database.KeyRename(redisKey, redisNewKey);
+        }
+
+        /// <summary>
+        /// 设置 Key 的时间
+        /// </summary>
+        /// <param name="redisKey"></param>
+        /// <param name="expiry"></param>
+        /// <returns></returns>
+        public static bool KeyExpire(string redisKey, TimeSpan? expiry)
+        {
+            return database.KeyExpire(redisKey, expiry);
+        }
+
+        #endregion
+
+        /// <summary>
+        /// 获取key过期时间
+        /// </summary>
+        /// <param name="redisKey"></param>
+        /// <returns></returns>
+        public static string GetKeyOutTime(string redisKey)
+        {
+            var server = redis.GetServer(connserver , Int32.Parse(connport));
+            var timeNow = server.Time().ToUniversalTime();
+            var time = database.KeyTimeToLive(redisKey);
+            var expire = time == null ? (DateTime?)null : timeNow.Add(time.Value); //返回UTC时间。
+            return expire.Value.AddHours(8).ToString("yyyy-MM-dd HH:mm:ss");
+        }
+    }
+}

SmsPlatform/Common/SQLOption.cs

@@ -0,0 +1,17 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace SmsPlatform.Common
+{
+    public class SQLOption
+    {
+        /// <summary>
+        ///SQL数据库连接字符串
+        /// </summary>
+        public static  string ConnectionString { get; set; }
+
+        
+    }
+}

SmsPlatform/Controllers/SmsController.cs

@@ -1,5 +1,6 @@
 using System;
 using System.Collections.Generic;
+using System.Data;
 using System.Linq;
 using System.Threading.Tasks;
 using System.Transactions;
@@ -22,6 +23,8 @@ namespace SmsPlatform.Controllers
         private readonly ILogger<SmsController> _logger;
         private readonly IDistributedCache _cache;
         private readonly IConfiguration _configuration;
+        BLL.T_Sys_UserAccount bll = new BLL.T_Sys_UserAccount();
+
         public SmsController(IDistributedCache cache, IConfiguration configuration, ILogger<SmsController> logger)
         {
             _cache = cache;
@@ -36,29 +39,85 @@ namespace SmsPlatform.Controllers
         [HttpGet("getbalance")]
         public async Task<IActionResult> GetBalance(string usercode, string password, string signcode)
         {
-            var liststr = await _cache.GetStringAsync("T_User_Account");
-            var list = new List<T_User_Account>();
-            if (!string.IsNullOrEmpty(liststr))
+            //var dtCache = RedisHelper.StringGet("T_User_Account");
+            if (RedisHelper .IsCon ()&& _cache != null)
             {
-                list = liststr.ToList<T_User_Account>();
-            }
 
-            var model = list.Where(p => p.UserCode == usercode && p.Password == password).SingleOrDefault();
-            if (model != null)
-            {
-                string outsigncode = SecureHelper.GetMD5(usercode + "+" + password + "+" + model.Sign + "+" + DateTime.Now.ToString("yyyyMMdd"));
-                if (outsigncode.ToUpper() == signcode.ToUpper())
+                //if (_cache != null)
+                //{
+                    var liststr = await _cache.GetStringAsync("T_User_Account");
+                var list = new List<T_User_Account>();
+                if (!string.IsNullOrEmpty(liststr))
                 {
-                    return Success("成功", model.Balance);
+                    list = liststr.ToList<T_User_Account>();
                 }
                 else
                 {
-                    return Error("签名错误");
+                    //将sql中的数据保存到redis中
+                    string strwhere = " F_See='" + usercode + "' and F_Remark='" + password + "'";
+                    DataSet ds = bll.GetList(strwhere);
+                    if (ds != null)
+                    {
+                        DataTable dt = ds.Tables[0];
+                        if (dt.Rows.Count > 0)
+                        {
+                            var models = new T_User_Account();
+                            models.Id = int.Parse (dt.Rows [0]["F_UserId"].ToString ());
+                            models.UserCode = dt.Rows[0]["F_See"].ToString();
+                            models.Password = dt.Rows[0]["F_Remark"].ToString();
+                            models.UserName = "";
+                            models.Sign = dt.Rows[0]["F_Remark"].ToString();
+                            models.Balance = Decimal.Parse (dt.Rows[0]["F_DeptCode"].ToString());
+                            models.CreateTime = DateTime.Now;
+                            list.Add(models);
+                            await _cache.SetStringAsync("T_User_Account", list.ToJson());
+                            liststr = await _cache.GetStringAsync("T_User_Account");
+                            if (!string.IsNullOrEmpty(liststr))
+                            {
+                                list = liststr.ToList<T_User_Account>();
+                            }
+                        }
+                    }
+                }
+                var model = list.Where(p => p.UserCode == usercode && p.Password == password).SingleOrDefault();
+                if (model != null)
+                {
+                    string outsigncode = SecureHelper.GetMD5(usercode + "+" + password + "+" + model.Sign + "+" + DateTime.Now.ToString("yyyyMMdd"));
+                    if (outsigncode.ToUpper() == signcode.ToUpper())
+                    {
+                        return Success("成功", model.Balance);
+                    }
+                    else
+                    {
+                        return Error("签名错误");
+                    }
+                }
+                else
+                {
+                    return Error("账号或者密码错误");
                 }
             }
             else
             {
-                return Error("账号或者密码错误");
+                string strwhere = " F_See='"+usercode + "' and F_Remark='" + password +"'";
+                DataSet ds = bll.GetList(strwhere);
+                if (ds != null)
+                {
+                    DataTable dt = ds.Tables[0];
+                    if (dt.Rows.Count > 0)
+                    {
+                        string outsigncode = SecureHelper.GetMD5(usercode + "+" + password + "+" +dt.Rows [0]["F_Remark"].ToString () + "+" + DateTime.Now.ToString("yyyyMMdd"));
+                        if (outsigncode.ToUpper() == signcode.ToUpper())
+                        {
+                            return Success("成功", dt.Rows[0]["F_DeptCode"].ToString());
+                        }
+                        else
+                        {
+                            return Error("签名错误");
+                        }
+                    }
+                }
+                return Error("获取失败");
             }
         }
 
@@ -69,51 +128,85 @@ namespace SmsPlatform.Controllers
         [HttpPost("updatebalance")]
         public async Task<IActionResult> UpdateBalance(string usercode, string password, decimal amount, string remark, string signcode)
         {
-            var userliststr = await _cache.GetStringAsync("T_User_Account");
-            var userlist = new List<T_User_Account>();
-            if (!string.IsNullOrEmpty(userliststr))
+            if (_cache != null)
             {
-                userlist = userliststr.ToList<T_User_Account>();
-            }
+                var userliststr = await _cache.GetStringAsync("T_User_Account");
+                var userlist = new List<T_User_Account>();
+                if (!string.IsNullOrEmpty(userliststr))
+                {
+                    userlist = userliststr.ToList<T_User_Account>();
+                }
 
-            var model = userlist.Where(p => p.UserCode == usercode && p.Password == password).SingleOrDefault();
-            if (model != null)
-            {
-                string outsigncode = SecureHelper.GetMD5(usercode + "+" + password + "+" + model.Sign + "+" + DateTime.Now.ToString("yyyyMMdd"));
-                if (outsigncode.ToUpper() == signcode.ToUpper())
+                var model = userlist.Where(p => p.UserCode == usercode && p.Password == password).SingleOrDefault();
+                if (model != null)
                 {
-                    model.Balance = model.Balance + amount;
-                    await _cache.SetStringAsync("T_User_Account", userlist.ToJson());
+                    string outsigncode = SecureHelper.GetMD5(usercode + "+" + password + "+" + model.Sign + "+" + DateTime.Now.ToString("yyyyMMdd"));
+                    if (outsigncode.ToUpper() == signcode.ToUpper())
+                    {
+                        model.Balance = model.Balance + amount;
+                        await _cache.SetStringAsync("T_User_Account", userlist.ToJson());
 
+                        #region 更新sql数据库余额
+                        BLL.T_Sys_UserAccount bll = new BLL.T_Sys_UserAccount();
+                        Model.T_Sys_UserAccount mt = bll.GetModel(model.Id);
+                        mt.F_DeptCode = model.Balance.ToString();
+                        bll.Update(mt);
+                        #endregion
 
-                    var amtliststr = await _cache.GetStringAsync("T_User_Amount");
-                    var amtlist = new List<T_User_Amount>();
-                    if (!string.IsNullOrEmpty(amtliststr))
-                    {
-                        amtlist = amtliststr.ToList<T_User_Amount>();
-                    }
+                        var amtliststr = await _cache.GetStringAsync("T_User_Amount");
+                        var amtlist = new List<T_User_Amount>();
+                        if (!string.IsNullOrEmpty(amtliststr))
+                        {
+                            amtlist = amtliststr.ToList<T_User_Amount>();
+                        }
 
-                    var amt = new T_User_Amount();
-                    amt.Id = amtlist.Count > 0 ? amtlist.Max(p => p.Id) + 1 : 1;
-                    amt.UserCode = usercode;
-                    amt.Amount = amount;
-                    amt.Balance = model.Balance;
-                    amt.Remark = remark;
-                    amt.CreateTime = DateTime.Now;
+                        var amt = new T_User_Amount();
+                        amt.Id = amtlist.Count > 0 ? amtlist.Max(p => p.Id) + 1 : 1;
+                        amt.UserCode = usercode;
+                        amt.Amount = amount;
+                        amt.Balance = model.Balance;
+                        amt.Remark = remark;
+                        amt.CreateTime = DateTime.Now;
 
-                    amtlist.Add(amt);
-                    await _cache.SetStringAsync("T_User_Amount", amtlist.ToJson());
+                        amtlist.Add(amt);
+                        await _cache.SetStringAsync("T_User_Amount", amtlist.ToJson());
 
-                    return Success("成功", model.Balance);
+                        return Success("成功", model.Balance);
+                    }
+                    else
+                    {
+                        return Error("签名错误");
+                    }
                 }
                 else
                 {
-                    return Error("签名错误");
+                    return Error("账号或者密码错误");
                 }
             }
             else
             {
-                return Error("账号或者密码错误");
+                string strwhere = " F_See='" + usercode + "' and F_Remark='" + password + "'";
+                DataSet ds = bll.GetList(strwhere);
+                if (ds != null)
+                {
+                    DataTable dt = ds.Tables[0];
+                    if (dt.Rows.Count > 0)
+                    {
+                        string outsigncode = SecureHelper.GetMD5(usercode + "+" + password + "+" + dt.Rows[0]["F_Remark"].ToString() + "+" + DateTime.Now.ToString("yyyyMMdd"));
+                        if (outsigncode.ToUpper() == signcode.ToUpper())
+                        {
+                            var m = bll.GetModel(int.Parse (dt.Rows[0]["F_UserId"].ToString ()));
+                            m.F_DeptCode = (Decimal.Parse (m.F_DeptCode) + amount).ToString ();
+                            bll.Update(m);
+                            return Success("成功", dt.Rows[0]["F_DeptCode"].ToString());
+                        }
+                        else
+                        {
+                            return Error("签名错误");
+                        }
+                    }
+                }
+                return Error("获取失败");
             }
         }
 
@@ -125,52 +218,113 @@ namespace SmsPlatform.Controllers
         [ApiExplorerSettings(IgnoreApi = true)]
         public async Task<IActionResult> DeductAmount(string usercode, string password, string phonenumber, string signcode)
         {
-            var userliststr = await _cache.GetStringAsync("T_User_Account");
-            var userlist = new List<T_User_Account>();
-            if (!string.IsNullOrEmpty(userliststr))
+            if (RedisHelper.IsCon() && _cache != null)
             {
-                userlist = userliststr.ToList<T_User_Account>();
-            }
+                
+                var userliststr = await _cache.GetStringAsync("T_User_Account");
+                var userlist = new List<T_User_Account>();
+                if (!string.IsNullOrEmpty(userliststr))
+                {
+                    userlist = userliststr.ToList<T_User_Account>();
+                }
+                else
+                {
+                    //将sql中的数据保存到redis中
+                    string strwhere = " F_See='" + usercode + "' and F_Remark='" + password + "'";
+                    DataSet ds = bll.GetList(strwhere);
+                    if (ds != null)
+                    {
+                        DataTable dt = ds.Tables[0];
+                        if (dt.Rows.Count > 0)
+                        {
+                            var models = new T_User_Account();
+                            models.Id = int.Parse(dt.Rows[0]["F_UserId"].ToString());
+                            models.UserCode = dt.Rows[0]["F_See"].ToString();
+                            models.Password = dt.Rows[0]["F_Remark"].ToString();
+                            models.UserName = "";
+                            models.Sign = dt.Rows[0]["F_Remark"].ToString();
+                            models.Balance = Decimal.Parse(dt.Rows[0]["F_DeptCode"].ToString());
+                            models.CreateTime = DateTime.Now;
+                            userlist.Add(models);
+                            await _cache.SetStringAsync("T_User_Account", userlist.ToJson());
+                            
+                        }
+                    }
+                }
 
-            var model = userlist.Where(p => p.UserCode == usercode && p.Password == password).SingleOrDefault();
-            if (model != null)
-            {
-                var amount = decimal.Parse(_configuration["amount"]);
-                string outsigncode = SecureHelper.GetMD5(usercode + "+" + password + "+" + model.Sign + "+" + DateTime.Now.ToString("yyyyMMdd"));
-                if (outsigncode.ToUpper() == signcode.ToUpper())
+                var model = userlist.Where(p => p.UserCode == usercode && p.Password == password).SingleOrDefault();
+                if (model != null)
                 {
-                    model.Balance = model.Balance - amount;
-                    await _cache.SetStringAsync("T_User_Account", userlist.ToJson());
+                    var amount = decimal.Parse(_configuration["amount"]);
+                    string outsigncode = SecureHelper.GetMD5(usercode + "+" + password + "+" + model.Sign + "+" + DateTime.Now.ToString("yyyyMMdd"));
+                    if (outsigncode.ToUpper() == signcode.ToUpper())
+                    {
+                        model.Balance = model.Balance - amount;
+                        await _cache.SetStringAsync("T_User_Account", userlist.ToJson());
 
+                        #region 更新sql数据库余额
+                        BLL.T_Sys_UserAccount bll = new BLL.T_Sys_UserAccount();
+                        Model.T_Sys_UserAccount mt = bll.GetModel(model.Id);
+                        mt.F_DeptCode = model.Balance.ToString();
+                        bll.Update(mt);
+                        #endregion
 
-                    var amtliststr = await _cache.GetStringAsync("T_User_Amount");
-                    var amtlist = new List<T_User_Amount>();
-                    if (!string.IsNullOrEmpty(amtliststr))
-                    {
-                        amtlist = amtliststr.ToList<T_User_Amount>();
-                    }
+                        var amtliststr = await _cache.GetStringAsync("T_User_Amount");
+                        var amtlist = new List<T_User_Amount>();
+                        if (!string.IsNullOrEmpty(amtliststr))
+                        {
+                            amtlist = amtliststr.ToList<T_User_Amount>();
+                        }
 
-                    var amt = new T_User_Amount();
-                    amt.Id = amtlist.Count > 0 ? amtlist.Max(p => p.Id) + 1 : 1;
-                    amt.UserCode = usercode;
-                    amt.Amount = amount;
-                    amt.Balance = model.Balance;
-                    amt.Remark = phonenumber + "发送短信";
-                    amt.CreateTime = DateTime.Now;
+                        var amt = new T_User_Amount();
+                        amt.Id = amtlist.Count > 0 ? amtlist.Max(p => p.Id) + 1 : 1;
+                        amt.UserCode = usercode;
+                        amt.Amount = amount;
+                        amt.Balance = model.Balance;
+                        amt.Remark = phonenumber + "发送短信";
+                        amt.CreateTime = DateTime.Now;
 
-                    amtlist.Add(amt);
-                    await _cache.SetStringAsync("T_User_Amount", amtlist.ToJson());
+                        amtlist.Add(amt);
+                        await _cache.SetStringAsync("T_User_Amount", amtlist.ToJson());
 
-                    return Success("成功", model.Balance);
+                        return Success("成功", model.Balance);
+                    }
+                    else
+                    {
+                        return Error("签名错误");
+                    }
                 }
                 else
                 {
-                    return Error("签名错误");
+                    return Error("账号或者密码错误");
                 }
             }
             else
             {
-                return Error("账号或者密码错误");
+                string strwhere = " F_See='" + usercode + "' and F_Remark='" + password + "'";
+                DataSet ds = bll.GetList(strwhere);
+                if (ds != null)
+                {
+                    DataTable dt = ds.Tables[0];
+                    if (dt.Rows.Count > 0)
+                    {
+
+                        string outsigncode = SecureHelper.GetMD5(usercode + "+" + password + "+" + dt.Rows[0]["F_Remark"].ToString() + "+" + DateTime.Now.ToString("yyyyMMdd"));
+                        if (outsigncode.ToUpper() == signcode.ToUpper())
+                        {
+                            var amount = decimal.Parse(_configuration["amount"]);
+                            var m = bll.GetModel(int.Parse(dt.Rows[0]["F_UserId"].ToString()));
+                            m.F_DeptCode = (Decimal.Parse(m.F_DeptCode) - amount).ToString();
+                            bll.Update(m);
+                            return Success("成功", dt.Rows[0]["F_DeptCode"].ToString());
+                        }
+                        else
+                        {
+                            return Error("签名错误");
+                        }
+                    }
+                }
+                return Error("获取失败");
             }
         }
 
@@ -184,97 +338,174 @@ namespace SmsPlatform.Controllers
             string signname, string templatecode, string phonenumber, string paramname, string param)
         {
             //_logger.LogError(signname + "|||" + templatecode + "|||" + phonenumber + "|||" + paramname + "|||" + param );
-
-            var userliststr = await _cache.GetStringAsync("T_User_Account");
-            var userlist = new List<T_User_Account>();
-            if (!string.IsNullOrEmpty(userliststr))
+            if (RedisHelper.IsCon() && _cache != null)
             {
-                userlist = userliststr.ToList<T_User_Account>();
-            }
-
-            var model = userlist.Where(p => p.UserCode == usercode && p.Password == password).SingleOrDefault();
-            if (model != null)
-            {
-                var amount = decimal.Parse(_configuration["amount"]);
-                string outsigncode = SecureHelper.GetMD5(usercode + "+" + password + "+" + model.Sign + "+" + DateTime.Now.ToString("yyyyMMdd"));
-                if (outsigncode.ToUpper() == signcode.ToUpper())
+                var userliststr = await _cache.GetStringAsync("T_User_Account");
+                var userlist = new List<T_User_Account>();
+                if (!string.IsNullOrEmpty(userliststr))
+                {
+                    userlist = userliststr.ToList<T_User_Account>();
+                }
+                else
                 {
-                    var tcount = content.Length + signname.Length + 2;
-                    if (tcount > 70)
+                    //将sql中的数据保存到redis中
+                    string strwhere = " F_See='" + usercode + "' and F_Remark='" + password + "'";
+                    DataSet ds = bll.GetList(strwhere);
+                    if (ds != null)
                     {
-                        amount = (tcount / 67 + 1) * amount;
-                    }
+                        DataTable dt = ds.Tables[0];
+                        if (dt.Rows.Count > 0)
+                        {
+                            var models = new T_User_Account();
+                            models.Id = int.Parse(dt.Rows[0]["F_UserId"].ToString());
+                            models.UserCode = dt.Rows[0]["F_See"].ToString();
+                            models.Password = dt.Rows[0]["F_Remark"].ToString();
+                            models.UserName = "";
+                            models.Sign = dt.Rows[0]["F_Remark"].ToString();
+                            models.Balance = Decimal.Parse(dt.Rows[0]["F_DeptCode"].ToString());
+                            models.CreateTime = DateTime.Now;
+                            userlist.Add(models);
+                            await _cache.SetStringAsync("T_User_Account", userlist.ToJson());
 
-                    SmsHelper sh = new SmsHelper(_configuration);
+                        }
+                    }
+                }
 
-                    string date = DateTime.Now.ToString("yyyyMMdd");
-                    var result = sh.SendSms(signname, templatecode, phonenumber, paramname, param);
-                    if (result.Code == "OK")
+                var model = userlist.Where(p => p.UserCode == usercode && p.Password == password).SingleOrDefault();
+                if (model != null)
+                {
+                    var amount = decimal.Parse(_configuration["amount"]);
+                    string outsigncode = SecureHelper.GetMD5(usercode + "+" + password + "+" + model.Sign + "+" + DateTime.Now.ToString("yyyyMMdd"));
+                    if (outsigncode.ToUpper() == signcode.ToUpper())
                     {
-                        //var sd = sh.Query(result.BizId, phonenumber, date);
-                        //if (sd.SendStatus == 2)
-                        //{
-                        //    var send = GetSend(result.BizId);
-
-                        //    _logger.LogError(phonenumber + " 发送短信失败，原因：" + send.ErrMsg);
-                        //    return Error(send.ErrMsg);
-                        //}
-                        model.Balance = model.Balance - amount;
-                        await _cache.SetStringAsync("T_User_Account", userlist.ToJson());
+                        var tcount = content.Length + signname.Length + 2;
+                        if (tcount > 70)
+                        {
+                            amount = (tcount / 67 + 1) * amount;
+                        }
 
-                        //var amtliststr = await _cache.GetStringAsync("T_User_Amount");
-                        //var amtlist = new List<T_User_Amount>();
-                        //if (!string.IsNullOrEmpty(amtliststr))
-                        //{
-                        //    amtlist = amtliststr.ToList<T_User_Amount>();
-                        //}
-
-                        //var amt = new T_User_Amount();
-                        //amt.Id = amtlist.Count > 0 ? amtlist.Max(p => p.Id) + 1 : 1;
-                        //amt.UserCode = usercode;
-                        //amt.Amount = amount;
-                        //amt.Balance = model.Balance;
-                        //amt.Remark = phonenumber + " 发送短信";
-                        //amt.CreateTime = DateTime.Now;
-
-                        //amtlist.Add(amt);
-                        //await _cache.SetStringAsync("T_User_Amount", amtlist.ToJson());
-
-                        //var sendliststr = await _cache.GetStringAsync("T_Sms_Send");
-                        //var sendlist = new List<T_Sms_Send>();
-                        //if (!string.IsNullOrEmpty(sendliststr))
-                        //{
-                        //    sendlist = sendliststr.ToList<T_Sms_Send>();
-                        //}
-                        //var send = new T_Sms_Send();
-                        //send.Id = sendlist.Count > 0 ? sendlist.Max(p => p.Id) + 1 : 1;
-                        //send.BizId = result.BizId;
-                        //send.PhoneNumber = phonenumber;
-                        //send.SendTime = DateTime.Now;
-                        //send.State = 1;
-                        //sendlist.Add(send);
-                        //await _cache.SetStringAsync("T_Sms_Send", sendlist.ToJson());
-
-                        _logger.LogError(phonenumber + "：" + signname + "|||" + templatecode + "|||" + paramname + "|||" + param);
+                        SmsHelper sh = new SmsHelper(_configuration);
 
-                        return Success("成功", model.Balance);
+                        string date = DateTime.Now.ToString("yyyyMMdd");
+                        var result = sh.SendSms(signname, templatecode, phonenumber, paramname, param);
+                        if (result.Code == "OK")
+                        {
+                            //var sd = sh.Query(result.BizId, phonenumber, date);
+                            //if (sd.SendStatus == 2)
+                            //{
+                            //    var send = GetSend(result.BizId);
+
+                            //    _logger.LogError(phonenumber + " 发送短信失败，原因：" + send.ErrMsg);
+                            //    return Error(send.ErrMsg);
+                            //}
+                            model.Balance = model.Balance - amount;
+                            await _cache.SetStringAsync("T_User_Account", userlist.ToJson());
+
+                            #region 更新sql数据库余额
+                            BLL.T_Sys_UserAccount bll = new BLL.T_Sys_UserAccount();
+                            Model.T_Sys_UserAccount mt = bll.GetModel(model.Id);
+                            mt.F_DeptCode = model.Balance.ToString();
+                            bll.Update(mt);
+                            #endregion
+                            //var amtliststr = await _cache.GetStringAsync("T_User_Amount");
+                            //var amtlist = new List<T_User_Amount>();
+                            //if (!string.IsNullOrEmpty(amtliststr))
+                            //{
+                            //    amtlist = amtliststr.ToList<T_User_Amount>();
+                            //}
+
+                            //var amt = new T_User_Amount();
+                            //amt.Id = amtlist.Count > 0 ? amtlist.Max(p => p.Id) + 1 : 1;
+                            //amt.UserCode = usercode;
+                            //amt.Amount = amount;
+                            //amt.Balance = model.Balance;
+                            //amt.Remark = phonenumber + " 发送短信";
+                            //amt.CreateTime = DateTime.Now;
+
+                            //amtlist.Add(amt);
+                            //await _cache.SetStringAsync("T_User_Amount", amtlist.ToJson());
+
+                            //var sendliststr = await _cache.GetStringAsync("T_Sms_Send");
+                            //var sendlist = new List<T_Sms_Send>();
+                            //if (!string.IsNullOrEmpty(sendliststr))
+                            //{
+                            //    sendlist = sendliststr.ToList<T_Sms_Send>();
+                            //}
+                            //var send = new T_Sms_Send();
+                            //send.Id = sendlist.Count > 0 ? sendlist.Max(p => p.Id) + 1 : 1;
+                            //send.BizId = result.BizId;
+                            //send.PhoneNumber = phonenumber;
+                            //send.SendTime = DateTime.Now;
+                            //send.State = 1;
+                            //sendlist.Add(send);
+                            //await _cache.SetStringAsync("T_Sms_Send", sendlist.ToJson());
+
+                            _logger.LogError(phonenumber + "：" + signname + "|||" + templatecode + "|||" + paramname + "|||" + param);
+
+                            return Success("成功", model.Balance);
+                        }
+                        else
+                        {
+                            _logger.LogError(phonenumber + " 发送短信失败，原因：" + result.Message);
+                            return Error(result.Message);
+                        }
                     }
                     else
                     {
-                        _logger.LogError(phonenumber + " 发送短信失败，原因：" + result.Message);
-                        return Error(result.Message);
+                        return Error("签名错误");
                     }
                 }
                 else
                 {
-                    return Error("签名错误");
+                    return Error("账号或者密码错误");
                 }
             }
             else
             {
-                return Error("账号或者密码错误");
-            }
+                string strwhere = " F_See='" + usercode + "' and F_Remark='" + password + "'";
+                DataSet ds = bll.GetList(strwhere);
+                if (ds != null)
+                {
+                    DataTable dt = ds.Tables[0];
+                    if (dt.Rows.Count > 0)
+                    {
+                        var amount = decimal.Parse(_configuration["amount"]);
+                        string outsigncode = SecureHelper.GetMD5(usercode + "+" + password + "+" + dt.Rows[0]["F_Remark"].ToString() + "+" + DateTime.Now.ToString("yyyyMMdd"));
+                        if (outsigncode.ToUpper() == signcode.ToUpper())
+                        {
+                            var tcount = content.Length + signname.Length + 2;
+                            if (tcount > 70)
+                            {
+                                amount = (tcount / 67 + 1) * amount;
+                            }
+
+                            SmsHelper sh = new SmsHelper(_configuration);
 
+                            string date = DateTime.Now.ToString("yyyyMMdd");
+                            var result = sh.SendSms(signname, templatecode, phonenumber, paramname, param);
+                            if (result.Code == "OK")
+                            {
+                                
+                                var m = bll.GetModel(int.Parse(dt.Rows[0]["F_UserId"].ToString()));
+                                m.F_DeptCode = (Decimal.Parse(m.F_DeptCode) - amount).ToString();
+                                bll.Update(m);
+                                _logger.LogError(phonenumber + "：" + signname + "|||" + templatecode + "|||" + paramname + "|||" + param);
+                                return Success("成功", dt.Rows[0]["F_DeptCode"].ToString());
+                            }
+                            else
+                            {
+                                _logger.LogError(phonenumber + " 发送短信失败，原因：" + result.Message);
+                                return Error(result.Message);
+                            }
+                        }
+                        else
+                        {
+                            return Error("签名错误");
+                        }
+                    }
+                }
+                return Error("获取失败");
+            }
         }
 
         /// <summary>

SmsPlatform/Controllers/UserAccountController.cs

@@ -1,5 +1,6 @@
 using System;
 using System.Collections.Generic;
+using System.Data;
 using System.Linq;
 using System.Threading.Tasks;
 using Microsoft.AspNetCore.Mvc;
@@ -19,6 +20,8 @@ namespace SmsPlatform.Controllers
     {
         private readonly ILogger<UserAccountController> _logger;
         private readonly IDistributedCache _cache;
+        BLL.T_Sys_UserAccount bll = new BLL.T_Sys_UserAccount();
+
         public UserAccountController(IDistributedCache cache, ILogger<UserAccountController> logger)
         {
             _cache = cache;
@@ -32,13 +35,23 @@ namespace SmsPlatform.Controllers
         [HttpGet("getlist")]
         public async Task<IActionResult> GetList()
         {
-            var liststr = await _cache.GetStringAsync("T_User_Account");
-            var list = new List<T_User_Account>();
-            if (!string.IsNullOrEmpty(liststr))
+            if (_cache != null)
             {
-                list = liststr.ToList<T_User_Account>();
+                var liststr = await _cache.GetStringAsync("T_User_Account");
+                var list = new List<T_User_Account>();
+                if (!string.IsNullOrEmpty(liststr))
+                {
+                    list = liststr.ToList<T_User_Account>();
+                }
+                return Success("成功", list);
+            }
+            DataSet ds = bll.GetAllList();
+            if (ds != null)
+            {
+                return Success("成功", ds);
             }
-            return Success("成功", list);
+            else
+            { return Error("失败"); }
         }
 
         /// <summary>
@@ -49,24 +62,39 @@ namespace SmsPlatform.Controllers
         [HttpGet("getsingle")]
         public async Task<IActionResult> GetDetailsAsync(int id)
         {
-            var liststr = await _cache.GetStringAsync("T_User_Account");
-            var list = new List<T_User_Account>();
-            if (!string.IsNullOrEmpty(liststr))
+            if (_cache != null)
             {
-                list = liststr.ToList<T_User_Account>();
-            }
+                var liststr = await _cache.GetStringAsync("T_User_Account");
+                var list = new List<T_User_Account>();
+                if (!string.IsNullOrEmpty(liststr))
+                {
+                    list = liststr.ToList<T_User_Account>();
+                }
 
-            var amtliststr = await _cache.GetStringAsync("T_User_Amount");
-            var amtlist = new List<T_User_Amount>();
-            if (!string.IsNullOrEmpty(amtliststr))
+                var amtliststr = await _cache.GetStringAsync("T_User_Amount");
+                var amtlist = new List<T_User_Amount>();
+                if (!string.IsNullOrEmpty(amtliststr))
+                {
+                    amtlist = amtliststr.ToList<T_User_Amount>();
+                }
+
+                var model = list.Where(p => p.Id == id).SingleOrDefault();
+                var amountlist = amtlist.Where(p => p.UserCode == model.UserCode).ToList();
+                var obj = new { model, amountlist };
+                return Success("成功", obj);
+            }
+            //redis获取失败时从数据库读取
+            //BLL.T_Sys_UserAccount bll = new BLL.T_Sys_UserAccount();
+            var m = bll.GetModel(id);
+            if (m != null)
             {
-                amtlist = amtliststr.ToList<T_User_Amount>();
+                await _cache.SetStringAsync("T_User_Account", m.ToJson());
+                return Success("成功", m);
+            }
+            else
+            {
+                return Error("获取用户详情失败");
             }
-
-            var model = list.Where(p => p.Id == id).SingleOrDefault();
-            var amountlist = amtlist.Where(p => p.UserCode == model.UserCode).ToList();
-            var obj = new { model , amountlist };
-            return Success("成功", obj);
         }
 
         /// <summary>
@@ -93,9 +121,33 @@ namespace SmsPlatform.Controllers
             {
                 list = liststr.ToList<T_User_Account>();
             }
-
+            var m = bll.GetModel(input.Id);
+            if (m != null)
+            {
+                T_Sys_UserAccount modelt = new T_Sys_UserAccount();
+                //modelt.F_UserId = input.Id;
+                modelt.F_UserCode = input.UserCode;
+                modelt.F_Password = input.Password;
+                modelt.F_UserName = input.UserName;
+                modelt.F_Remark = input.Sign;
+                modelt.F_DeptCode = input.Balance.ToString();//余额
+                modelt.F_CreateOn = DateTime.Now;
+                bll.Update(modelt);
+            }
+            else
+            {
+                T_Sys_UserAccount modelt = new T_Sys_UserAccount();
+                modelt.F_UserId = input.Id;
+                modelt.F_UserCode = input.UserCode;
+                modelt.F_Password = input.Password;
+                modelt.F_UserName = input.UserName;
+                modelt.F_Remark = input.Sign;
+                modelt.F_DeptCode = input.Balance.ToString();//余额
+                modelt.F_CreateOn = DateTime.Now;
+                bll.Add(modelt);
+            }
             var model = new T_User_Account();
-            if (input.Id != 0)
+            if (input.Id != 0&&_cache !=null )
             {
                 model = list.Where(p => p.Id == input.Id).SingleOrDefault();
                 if (model != null)
@@ -106,8 +158,22 @@ namespace SmsPlatform.Controllers
                     model.Sign = input.Sign;
                     model.Balance = input.Balance;
                     await _cache.SetStringAsync("T_User_Account", list.ToJson());
+                    
                     return Success("修改成功", model);
                 }
+                else
+                {
+                    model.Id = list.Count > 0 ? list.Max(p => p.Id) + 1 : 1;
+                    model.UserCode = input.UserCode;
+                    model.Password = input.Password;
+                    model.UserName = input.UserName;
+                    model.Sign = input.Sign;
+                    model.Balance = input.Balance;
+                    model.CreateTime = DateTime.Now;
+                    list.Add(model);
+                    await _cache.SetStringAsync("T_User_Account", list.ToJson());
+                    return Success("新增成功", model);
+                }
             }
             else
             {
@@ -122,7 +188,7 @@ namespace SmsPlatform.Controllers
                 await _cache.SetStringAsync("T_User_Account", list.ToJson());
                 return Success("新增成功", model);
             }
-
+            
             return Error("保存失败");
         }
 
@@ -144,6 +210,7 @@ namespace SmsPlatform.Controllers
             var model = list.Where(p => p.Id == id).SingleOrDefault();
             list.Remove(model);
             await _cache.SetStringAsync("T_User_Account", list.ToJson());
+            bll.Delete(id);
             return Success("删除成功");
         }
     }

SmsPlatform/DAL/T_Sys_UserAccount.cs

@@ -0,0 +1,605 @@
+using System;
+using System.Collections.Generic;
+using System.Data;
+using System.Linq;
+using System.Threading.Tasks;
+
+using System.Text;
+using System.Data.SqlClient;
+using SmsPlatform.Common;
+
+namespace SmsPlatform.DAL
+{
+    /// <summary>
+	/// 数据访问类:T_Sys_UserAccount
+	/// </summary>
+	public partial class T_Sys_UserAccount
+    {
+        public T_Sys_UserAccount()
+        { }
+        #region  BasicMethod
+
+        /// <summary>
+        /// 得到最大ID
+        /// </summary>
+        public int GetMaxId()
+        {
+            return DbHelperSQL.GetMaxID("F_UserId", "T_Sys_UserAccount");
+        }
+
+        /// <summary>
+        /// 是否存在该记录
+        /// </summary>
+        public bool Exists(int F_UserId)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("select count(1) from T_Sys_UserAccount");
+            strSql.Append(" where F_UserId=@F_UserId");
+            SqlParameter[] parameters = {
+                    new SqlParameter("@F_UserId", SqlDbType.Int,4)
+            };
+            parameters[0].Value = F_UserId;
+
+            return DbHelperSQL.Exists(strSql.ToString(), parameters);
+        }
+
+
+        /// <summary>
+        /// 增加一条数据
+        /// </summary>
+        public int Add(Model.T_Sys_UserAccount model)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("insert into T_Sys_UserAccount(");
+            strSql.Append("F_UserCode,F_Password,F_ExtensionNumber,F_UserName,F_DeptId,F_RoleId,F_GroupId,F_SeatFlag,F_SeatRight,F_SeatLevel,F_SexFlag,F_RemindFlag,F_Remark,F_Telephone,F_Mobile,F_HomePhone,F_Birthday,F_CreateOn,F_CancelOn,F_DeleteFlag,F_APPOnFlag,F_LastActiveTime,F_See,F_HJType,F_PId,F_TmId,F_WorkNumber,F_DeptCode)");
+            strSql.Append(" values (");
+            strSql.Append("@F_UserCode,@F_Password,@F_ExtensionNumber,@F_UserName,@F_DeptId,@F_RoleId,@F_GroupId,@F_SeatFlag,@F_SeatRight,@F_SeatLevel,@F_SexFlag,@F_RemindFlag,@F_Remark,@F_Telephone,@F_Mobile,@F_HomePhone,@F_Birthday,@F_CreateOn,@F_CancelOn,@F_DeleteFlag,@F_APPOnFlag,@F_LastActiveTime,@F_See,@F_HJType,@F_PId,@F_TmId,@F_WorkNumber,@F_DeptCode)");
+            strSql.Append(";select @@IDENTITY");
+            SqlParameter[] parameters = {
+                    new SqlParameter("@F_UserCode", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_Password", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_ExtensionNumber", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_UserName", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_DeptId", SqlDbType.Int,4),
+                    new SqlParameter("@F_RoleId", SqlDbType.Int,4),
+                    new SqlParameter("@F_GroupId", SqlDbType.Int,4),
+                    new SqlParameter("@F_SeatFlag", SqlDbType.Bit,1),
+                    new SqlParameter("@F_SeatRight", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_SeatLevel", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_SexFlag", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_RemindFlag", SqlDbType.Bit,1),
+                    new SqlParameter("@F_Remark", SqlDbType.VarChar,200),
+                    new SqlParameter("@F_Telephone", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_Mobile", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_HomePhone", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_Birthday", SqlDbType.DateTime),
+                    new SqlParameter("@F_CreateOn", SqlDbType.DateTime),
+                    new SqlParameter("@F_CancelOn", SqlDbType.DateTime),
+                    new SqlParameter("@F_DeleteFlag", SqlDbType.SmallInt,2),
+                    new SqlParameter("@F_APPOnFlag", SqlDbType.Bit,1),
+                    new SqlParameter("@F_LastActiveTime", SqlDbType.DateTime),
+                    new SqlParameter("@F_See", SqlDbType.VarChar,100),
+                    new SqlParameter("@F_HJType", SqlDbType.Int,4),
+                    new SqlParameter("@F_PId", SqlDbType.Int,4),
+                    new SqlParameter("@F_TmId", SqlDbType.Int,4),
+                    new SqlParameter("@F_WorkNumber", SqlDbType.VarChar,15),
+                    new SqlParameter("@F_DeptCode", SqlDbType.VarChar,50)};
+            parameters[0].Value = model.F_UserCode;
+            parameters[1].Value = model.F_Password;
+            parameters[2].Value = model.F_ExtensionNumber;
+            parameters[3].Value = model.F_UserName;
+            parameters[4].Value = model.F_DeptId;
+            parameters[5].Value = model.F_RoleId;
+            parameters[6].Value = model.F_GroupId;
+            parameters[7].Value = model.F_SeatFlag;
+            parameters[8].Value = model.F_SeatRight;
+            parameters[9].Value = model.F_SeatLevel;
+            parameters[10].Value = model.F_SexFlag;
+            parameters[11].Value = model.F_RemindFlag;
+            parameters[12].Value = model.F_Remark;
+            parameters[13].Value = model.F_Telephone;
+            parameters[14].Value = model.F_Mobile;
+            parameters[15].Value = model.F_HomePhone;
+            parameters[16].Value = model.F_Birthday;
+            parameters[17].Value = model.F_CreateOn;
+            parameters[18].Value = model.F_CancelOn;
+            parameters[19].Value = model.F_DeleteFlag;
+            parameters[20].Value = model.F_APPOnFlag;
+            parameters[21].Value = model.F_LastActiveTime;
+            parameters[22].Value = model.F_See;
+            parameters[23].Value = model.F_HJType;
+            parameters[24].Value = model.F_PId;
+            parameters[25].Value = model.F_TmId;
+            parameters[26].Value = model.F_WorkNumber;
+            parameters[27].Value = model.F_DeptCode;
+
+            object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
+            if (obj == null)
+            {
+                return 0;
+            }
+            else
+            {
+                return Convert.ToInt32(obj);
+            }
+        }
+        /// <summary>
+        /// 更新一条数据
+        /// </summary>
+        public bool Update(Model.T_Sys_UserAccount model)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("update T_Sys_UserAccount set ");
+            strSql.Append("F_UserCode=@F_UserCode,");
+            strSql.Append("F_Password=@F_Password,");
+            strSql.Append("F_ExtensionNumber=@F_ExtensionNumber,");
+            strSql.Append("F_UserName=@F_UserName,");
+            strSql.Append("F_DeptId=@F_DeptId,");
+            strSql.Append("F_RoleId=@F_RoleId,");
+            strSql.Append("F_GroupId=@F_GroupId,");
+            strSql.Append("F_SeatFlag=@F_SeatFlag,");
+            strSql.Append("F_SeatRight=@F_SeatRight,");
+            strSql.Append("F_SeatLevel=@F_SeatLevel,");
+            strSql.Append("F_SexFlag=@F_SexFlag,");
+            strSql.Append("F_RemindFlag=@F_RemindFlag,");
+            strSql.Append("F_Remark=@F_Remark,");
+            strSql.Append("F_Telephone=@F_Telephone,");
+            strSql.Append("F_Mobile=@F_Mobile,");
+            strSql.Append("F_HomePhone=@F_HomePhone,");
+            strSql.Append("F_Birthday=@F_Birthday,");
+            strSql.Append("F_CreateOn=@F_CreateOn,");
+            strSql.Append("F_CancelOn=@F_CancelOn,");
+            strSql.Append("F_DeleteFlag=@F_DeleteFlag,");
+            strSql.Append("F_APPOnFlag=@F_APPOnFlag,");
+            strSql.Append("F_LastActiveTime=@F_LastActiveTime,");
+            strSql.Append("F_See=@F_See,");
+            strSql.Append("F_HJType=@F_HJType,");
+            strSql.Append("F_PId=@F_PId,");
+            strSql.Append("F_TmId=@F_TmId,");
+            strSql.Append("F_WorkNumber=@F_WorkNumber,");
+            strSql.Append("F_DeptCode=@F_DeptCode");
+            strSql.Append(" where F_UserId=@F_UserId");
+            SqlParameter[] parameters = {
+                    new SqlParameter("@F_UserCode", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_Password", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_ExtensionNumber", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_UserName", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_DeptId", SqlDbType.Int,4),
+                    new SqlParameter("@F_RoleId", SqlDbType.Int,4),
+                    new SqlParameter("@F_GroupId", SqlDbType.Int,4),
+                    new SqlParameter("@F_SeatFlag", SqlDbType.Bit,1),
+                    new SqlParameter("@F_SeatRight", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_SeatLevel", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_SexFlag", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_RemindFlag", SqlDbType.Bit,1),
+                    new SqlParameter("@F_Remark", SqlDbType.VarChar,200),
+                    new SqlParameter("@F_Telephone", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_Mobile", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_HomePhone", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_Birthday", SqlDbType.DateTime),
+                    new SqlParameter("@F_CreateOn", SqlDbType.DateTime),
+                    new SqlParameter("@F_CancelOn", SqlDbType.DateTime),
+                    new SqlParameter("@F_DeleteFlag", SqlDbType.SmallInt,2),
+                    new SqlParameter("@F_APPOnFlag", SqlDbType.Bit,1),
+                    new SqlParameter("@F_LastActiveTime", SqlDbType.DateTime),
+                    new SqlParameter("@F_See", SqlDbType.VarChar,100),
+                    new SqlParameter("@F_HJType", SqlDbType.Int,4),
+                    new SqlParameter("@F_PId", SqlDbType.Int,4),
+                    new SqlParameter("@F_TmId", SqlDbType.Int,4),
+                    new SqlParameter("@F_WorkNumber", SqlDbType.VarChar,15),
+                    new SqlParameter("@F_DeptCode", SqlDbType.VarChar,50),
+                    new SqlParameter("@F_UserId", SqlDbType.Int,4)};
+            parameters[0].Value = model.F_UserCode;
+            parameters[1].Value = model.F_Password;
+            parameters[2].Value = model.F_ExtensionNumber;
+            parameters[3].Value = model.F_UserName;
+            parameters[4].Value = model.F_DeptId;
+            parameters[5].Value = model.F_RoleId;
+            parameters[6].Value = model.F_GroupId;
+            parameters[7].Value = model.F_SeatFlag;
+            parameters[8].Value = model.F_SeatRight;
+            parameters[9].Value = model.F_SeatLevel;
+            parameters[10].Value = model.F_SexFlag;
+            parameters[11].Value = model.F_RemindFlag;
+            parameters[12].Value = model.F_Remark;
+            parameters[13].Value = model.F_Telephone;
+            parameters[14].Value = model.F_Mobile;
+            parameters[15].Value = model.F_HomePhone;
+            parameters[16].Value = model.F_Birthday;
+            parameters[17].Value = model.F_CreateOn;
+            parameters[18].Value = model.F_CancelOn;
+            parameters[19].Value = model.F_DeleteFlag;
+            parameters[20].Value = model.F_APPOnFlag;
+            parameters[21].Value = model.F_LastActiveTime;
+            parameters[22].Value = model.F_See;
+            parameters[23].Value = model.F_HJType;
+            parameters[24].Value = model.F_PId;
+            parameters[25].Value = model.F_TmId;
+            parameters[26].Value = model.F_WorkNumber;
+            parameters[27].Value = model.F_DeptCode;
+            parameters[28].Value = model.F_UserId;
+
+            int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
+            if (rows > 0)
+            {
+                return true;
+            }
+            else
+            {
+                return false;
+            }
+        }
+
+        /// <summary>
+        /// 删除一条数据
+        /// </summary>
+        public bool Delete(int F_UserId)
+        {
+
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("delete from T_Sys_UserAccount ");
+            strSql.Append(" where F_UserId=@F_UserId");
+            SqlParameter[] parameters = {
+                    new SqlParameter("@F_UserId", SqlDbType.Int,4)
+            };
+            parameters[0].Value = F_UserId;
+
+            int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
+            if (rows > 0)
+            {
+                return true;
+            }
+            else
+            {
+                return false;
+            }
+        }
+        /// <summary>
+        /// 批量删除数据
+        /// </summary>
+        public bool DeleteList(string F_UserIdlist)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("delete from T_Sys_UserAccount ");
+            strSql.Append(" where F_UserId in (" + F_UserIdlist + ")  ");
+            int rows = DbHelperSQL.ExecuteSql(strSql.ToString());
+            if (rows > 0)
+            {
+                return true;
+            }
+            else
+            {
+                return false;
+            }
+        }
+
+
+        /// <summary>
+        /// 得到一个对象实体
+        /// </summary>
+        public Model.T_Sys_UserAccount GetModel(int F_UserId)
+        {
+
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("select  top 1 F_UserId,F_UserCode,F_Password,F_ExtensionNumber,F_UserName,F_DeptId,F_RoleId,F_GroupId,F_SeatFlag,F_SeatRight,F_SeatLevel,F_SexFlag,F_RemindFlag,F_Remark,F_Telephone,F_Mobile,F_HomePhone,F_Birthday,F_CreateOn,F_CancelOn,F_DeleteFlag,F_APPOnFlag,F_LastActiveTime,F_See,F_HJType,F_PId,F_TmId,F_WorkNumber,F_DeptCode from T_Sys_UserAccount ");
+            strSql.Append(" where F_UserId=@F_UserId");
+            SqlParameter[] parameters = {
+                    new SqlParameter("@F_UserId", SqlDbType.Int,4)
+            };
+            parameters[0].Value = F_UserId;
+
+            Model.T_Sys_UserAccount model = new Model.T_Sys_UserAccount();
+            
+            DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters);
+            if (ds.Tables[0].Rows.Count > 0)
+            {
+                return DataRowToModel(ds.Tables[0].Rows[0]);
+            }
+            else
+            {
+                return null;
+            }
+        }
+
+
+        /// <summary>
+        /// 得到一个对象实体
+        /// </summary>
+        public Model.T_Sys_UserAccount DataRowToModel(DataRow row)
+        {
+            Model.T_Sys_UserAccount model = new Model.T_Sys_UserAccount();
+            if (row != null)
+            {
+                if (row["F_UserId"] != null && row["F_UserId"].ToString() != "")
+                {
+                    model.F_UserId = int.Parse(row["F_UserId"].ToString());
+                }
+                if (row["F_UserCode"] != null)
+                {
+                    model.F_UserCode = row["F_UserCode"].ToString();
+                }
+                if (row["F_Password"] != null)
+                {
+                    model.F_Password = row["F_Password"].ToString();
+                }
+                if (row["F_ExtensionNumber"] != null)
+                {
+                    model.F_ExtensionNumber = row["F_ExtensionNumber"].ToString();
+                }
+                if (row["F_UserName"] != null)
+                {
+                    model.F_UserName = row["F_UserName"].ToString();
+                }
+                if (row["F_DeptId"] != null && row["F_DeptId"].ToString() != "")
+                {
+                    model.F_DeptId = int.Parse(row["F_DeptId"].ToString());
+                }
+                if (row["F_RoleId"] != null && row["F_RoleId"].ToString() != "")
+                {
+                    model.F_RoleId = int.Parse(row["F_RoleId"].ToString());
+                }
+                if (row["F_GroupId"] != null && row["F_GroupId"].ToString() != "")
+                {
+                    model.F_GroupId = int.Parse(row["F_GroupId"].ToString());
+                }
+                if (row["F_SeatFlag"] != null && row["F_SeatFlag"].ToString() != "")
+                {
+                    if ((row["F_SeatFlag"].ToString() == "1") || (row["F_SeatFlag"].ToString().ToLower() == "true"))
+                    {
+                        model.F_SeatFlag = true;
+                    }
+                    else
+                    {
+                        model.F_SeatFlag = false;
+                    }
+                }
+                if (row["F_SeatRight"] != null)
+                {
+                    model.F_SeatRight = row["F_SeatRight"].ToString();
+                }
+                if (row["F_SeatLevel"] != null)
+                {
+                    model.F_SeatLevel = row["F_SeatLevel"].ToString();
+                }
+                if (row["F_SexFlag"] != null)
+                {
+                    model.F_SexFlag = row["F_SexFlag"].ToString();
+                }
+                if (row["F_RemindFlag"] != null && row["F_RemindFlag"].ToString() != "")
+                {
+                    if ((row["F_RemindFlag"].ToString() == "1") || (row["F_RemindFlag"].ToString().ToLower() == "true"))
+                    {
+                        model.F_RemindFlag = true;
+                    }
+                    else
+                    {
+                        model.F_RemindFlag = false;
+                    }
+                }
+                if (row["F_Remark"] != null)
+                {
+                    model.F_Remark = row["F_Remark"].ToString();
+                }
+                if (row["F_Telephone"] != null)
+                {
+                    model.F_Telephone = row["F_Telephone"].ToString();
+                }
+                if (row["F_Mobile"] != null)
+                {
+                    model.F_Mobile = row["F_Mobile"].ToString();
+                }
+                if (row["F_HomePhone"] != null)
+                {
+                    model.F_HomePhone = row["F_HomePhone"].ToString();
+                }
+                if (row["F_Birthday"] != null && row["F_Birthday"].ToString() != "")
+                {
+                    model.F_Birthday = DateTime.Parse(row["F_Birthday"].ToString());
+                }
+                if (row["F_CreateOn"] != null && row["F_CreateOn"].ToString() != "")
+                {
+                    model.F_CreateOn = DateTime.Parse(row["F_CreateOn"].ToString());
+                }
+                if (row["F_CancelOn"] != null && row["F_CancelOn"].ToString() != "")
+                {
+                    model.F_CancelOn = DateTime.Parse(row["F_CancelOn"].ToString());
+                }
+                if (row["F_DeleteFlag"] != null && row["F_DeleteFlag"].ToString() != "")
+                {
+                    model.F_DeleteFlag = int.Parse(row["F_DeleteFlag"].ToString());
+                }
+                if (row["F_APPOnFlag"] != null && row["F_APPOnFlag"].ToString() != "")
+                {
+                    if ((row["F_APPOnFlag"].ToString() == "1") || (row["F_APPOnFlag"].ToString().ToLower() == "true"))
+                    {
+                        model.F_APPOnFlag = true;
+                    }
+                    else
+                    {
+                        model.F_APPOnFlag = false;
+                    }
+                }
+                if (row["F_LastActiveTime"] != null && row["F_LastActiveTime"].ToString() != "")
+                {
+                    model.F_LastActiveTime = DateTime.Parse(row["F_LastActiveTime"].ToString());
+                }
+                if (row["F_See"] != null)
+                {
+                    model.F_See = row["F_See"].ToString();
+                }
+                if (row["F_HJType"] != null && row["F_HJType"].ToString() != "")
+                {
+                    model.F_HJType = int.Parse(row["F_HJType"].ToString());
+                }
+                if (row["F_PId"] != null && row["F_PId"].ToString() != "")
+                {
+                    model.F_PId = int.Parse(row["F_PId"].ToString());
+                }
+                if (row["F_TmId"] != null && row["F_TmId"].ToString() != "")
+                {
+                    model.F_TmId = int.Parse(row["F_TmId"].ToString());
+                }
+                if (row["F_WorkNumber"] != null)
+                {
+                    model.F_WorkNumber = row["F_WorkNumber"].ToString();
+                }
+                if (row["F_DeptCode"] != null)
+                {
+                    model.F_DeptCode = row["F_DeptCode"].ToString();
+                }
+            }
+            return model;
+        }
+
+        public Model.T_Sys_UserAccount DataRowToModel1(DataRow row)
+        {
+            Model.T_Sys_UserAccount model = new Model.T_Sys_UserAccount();
+            if (row != null)
+            {
+                if (row["F_UserId"] != null && row["F_UserId"].ToString() != "")
+                {
+                    model.F_UserId = int.Parse(row["F_UserId"].ToString());
+                }
+                if (row["F_UserCode"] != null)
+                {
+                    model.F_UserCode = row["F_UserCode"].ToString();
+                }
+                if (row["F_UserName"] != null)
+                {
+                    model.F_UserName = row["F_UserName"].ToString();
+                }
+                if (row["F_GroupId"] != null && row["F_GroupId"].ToString() != "")
+                {
+                    model.F_GroupId = int.Parse(row["F_GroupId"].ToString());
+                }
+
+            }
+            return model;
+        }
+
+        /// <summary>
+        /// 获得数据列表
+        /// </summary>
+        public DataSet GetList(string strWhere)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("select F_UserId,F_UserCode,F_Password,F_ExtensionNumber,F_UserName,F_DeptId,F_RoleId,F_GroupId,F_SeatFlag,F_SeatRight,F_SeatLevel,F_SexFlag,F_RemindFlag,F_Remark,F_Telephone,F_Mobile,F_HomePhone,F_Birthday,F_CreateOn,F_CancelOn,F_DeleteFlag,F_APPOnFlag,F_LastActiveTime,F_See,F_HJType,F_PId,F_TmId,F_WorkNumber,F_DeptCode ");
+            strSql.Append(" FROM T_Sys_UserAccount ");
+            if (strWhere.Trim() != "")
+            {
+                strSql.Append(" where " + strWhere);
+            }
+            return DbHelperSQL.Query(strSql.ToString());
+        }
+
+        public DataSet GetListView(string strWhere)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("select * ");
+            strSql.Append(" FROM V_UserAccount ");
+            if (strWhere.Trim() != "")
+            {
+                strSql.Append(" where " + strWhere);
+            }
+            return DbHelperSQL.Query(strSql.ToString());
+        }
+
+        /// <summary>
+        /// 获得前几行数据
+        /// </summary>
+        public DataSet GetList(int Top, string strWhere, string filedOrder)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("select ");
+            if (Top > 0)
+            {
+                strSql.Append(" top " + Top.ToString());
+            }
+            strSql.Append(" F_UserId,F_UserCode,F_Password,F_ExtensionNumber,F_UserName,F_DeptId,F_RoleId,F_GroupId,F_SeatFlag,F_SeatRight,F_SeatLevel,F_SexFlag,F_RemindFlag,F_Remark,F_Telephone,F_Mobile,F_HomePhone,F_Birthday,F_CreateOn,F_CancelOn,F_DeleteFlag,F_APPOnFlag,F_LastActiveTime,F_See,F_HJType,F_PId,F_TmId,F_WorkNumber,F_DeptCode ");
+            strSql.Append(" FROM T_Sys_UserAccount ");
+            if (strWhere.Trim() != "")
+            {
+                strSql.Append(" where " + strWhere);
+            }
+            strSql.Append(" order by " + filedOrder);
+            return DbHelperSQL.Query(strSql.ToString());
+        }
+
+        /// <summary>
+        /// 获取记录总数
+        /// </summary>
+        public int GetRecordCount(string strWhere)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("select count(1) FROM T_Sys_UserAccount ");
+            if (strWhere.Trim() != "")
+            {
+                strSql.Append(" where " + strWhere);
+            }
+            object obj = DbHelperSQL.GetSingle(strSql.ToString());
+            if (obj == null)
+            {
+                return 0;
+            }
+            else
+            {
+                return Convert.ToInt32(obj);
+            }
+        }
+        /// <summary>
+        /// 分页获取数据列表
+        /// </summary>
+        public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("SELECT * FROM ( ");
+            strSql.Append(" SELECT ROW_NUMBER() OVER (");
+            if (!string.IsNullOrEmpty(orderby.Trim()))
+            {
+                strSql.Append("order by T." + orderby);
+            }
+            else
+            {
+                strSql.Append("order by T.F_UserId desc");
+            }
+            strSql.Append(")AS Row, T.*  from T_Sys_UserAccount T ");
+            if (!string.IsNullOrEmpty(strWhere.Trim()))
+            {
+                strSql.Append(" WHERE " + strWhere);
+            }
+            strSql.Append(" ) TT");
+            strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex);
+            return DbHelperSQL.Query(strSql.ToString());
+        }
+
+        /*
+		/// <summary>
+		/// 分页获取数据列表
+		/// </summary>
+		public DataSet GetList(int PageSize,int PageIndex,string strWhere)
+		{
+			SqlParameter[] parameters = {
+					new SqlParameter("@tblName", SqlDbType.VarChar, 255),
+					new SqlParameter("@fldName", SqlDbType.VarChar, 255),
+					new SqlParameter("@PageSize", SqlDbType.Int),
+					new SqlParameter("@PageIndex", SqlDbType.Int),
+					new SqlParameter("@IsReCount", SqlDbType.Bit),
+					new SqlParameter("@OrderType", SqlDbType.Bit),
+					new SqlParameter("@strWhere", SqlDbType.VarChar,1000),
+					};
+			parameters[0].Value = "T_Sys_UserAccount";
+			parameters[1].Value = "F_UserId";
+			parameters[2].Value = PageSize;
+			parameters[3].Value = PageIndex;
+			parameters[4].Value = 0;
+			parameters[5].Value = 0;
+			parameters[6].Value = strWhere;	
+			return DbHelperSQL.RunProcedure("UP_GetRecordByPage",parameters,"ds");
+		}*/
+
+        #endregion  BasicMethod
+        #region  ExtensionMethod
+
+        #endregion  ExtensionMethod
+    }
+}

SmsPlatform/Model/T_Sys_UserAccount.cs

@@ -0,0 +1,281 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace SmsPlatform.Model
+{
+    /// <summary>
+	/// T_Sys_UserAccount:实体类(属性说明自动提取数据库字段的描述信息)
+	/// </summary>
+	[Serializable]
+    public partial class T_Sys_UserAccount
+    {
+        public T_Sys_UserAccount()
+        { }
+        #region Model
+        private int _f_userid;
+        private string _f_usercode;
+        private string _f_password;
+        private string _f_extensionnumber;
+        private string _f_username;
+        private int _f_deptid = 0;
+        private int _f_roleid = 0;
+        private int? _f_groupid;
+        private bool _f_seatflag;
+        private string _f_seatright;
+        private string _f_seatlevel;
+        private string _f_sexflag;
+        private bool _f_remindflag;
+        private string _f_remark;
+        private string _f_telephone;
+        private string _f_mobile;
+        private string _f_homephone;
+        private DateTime? _f_birthday;
+        private DateTime? _f_createon = DateTime.Now;
+        private DateTime? _f_cancelon;
+        private int? _f_deleteflag = 0;
+        private bool _f_apponflag = false;
+        private DateTime? _f_lastactivetime = DateTime.Now;
+        private string _f_see;
+        private int? _f_hjtype;
+        private int? _f_pid;
+        private int? _f_tmid;
+        private string _f_worknumber;
+        private string _f_deptcode;
+        /// <summary>
+        /// 账户ID
+        /// </summary>
+        public int F_UserId
+        {
+            set { _f_userid = value; }
+            get { return _f_userid; }
+        }
+        /// <summary>
+        /// 员工工号
+        /// </summary>
+        public string F_UserCode
+        {
+            set { _f_usercode = value; }
+            get { return _f_usercode; }
+        }
+        /// <summary>
+        /// 密码
+        /// </summary>
+        public string F_Password
+        {
+            set { _f_password = value; }
+            get { return _f_password; }
+        }
+        /// <summary>
+        /// 分机号
+        /// </summary>
+        public string F_ExtensionNumber
+        {
+            set { _f_extensionnumber = value; }
+            get { return _f_extensionnumber; }
+        }
+        /// <summary>
+        /// 操作员名称
+        /// </summary>
+        public string F_UserName
+        {
+            set { _f_username = value; }
+            get { return _f_username; }
+        }
+        /// <summary>
+        /// 部门ID
+        /// </summary>
+        public int F_DeptId
+        {
+            set { _f_deptid = value; }
+            get { return _f_deptid; }
+        }
+        /// <summary>
+        /// 角色id
+        /// </summary>
+        public int F_RoleId
+        {
+            set { _f_roleid = value; }
+            get { return _f_roleid; }
+        }
+        /// <summary>
+        /// 用户组ID
+        /// </summary>
+        public int? F_GroupId
+        {
+            set { _f_groupid = value; }
+            get { return _f_groupid; }
+        }
+        /// <summary>
+        /// 标志(0：非话务；1话务标志)
+        /// </summary>
+        public bool F_SeatFlag
+        {
+            set { _f_seatflag = value; }
+            get { return _f_seatflag; }
+        }
+        /// <summary>
+        /// 坐席权限组1班长坐席0普通坐席
+        /// </summary>
+        public string F_SeatRight
+        {
+            set { _f_seatright = value; }
+            get { return _f_seatright; }
+        }
+        /// <summary>
+        /// 坐席等级
+        /// </summary>
+        public string F_SeatLevel
+        {
+            set { _f_seatlevel = value; }
+            get { return _f_seatlevel; }
+        }
+        /// <summary>
+        /// 性别（男/女/未知）
+        /// </summary>
+        public string F_SexFlag
+        {
+            set { _f_sexflag = value; }
+            get { return _f_sexflag; }
+        }
+        /// <summary>
+        /// 提醒标志0不提醒1提醒
+        /// </summary>
+        public bool F_RemindFlag
+        {
+            set { _f_remindflag = value; }
+            get { return _f_remindflag; }
+        }
+        /// <summary>
+        /// 备注说明
+        /// </summary>
+        public string F_Remark
+        {
+            set { _f_remark = value; }
+            get { return _f_remark; }
+        }
+        /// <summary>
+        /// 电话
+        /// </summary>
+        public string F_Telephone
+        {
+            set { _f_telephone = value; }
+            get { return _f_telephone; }
+        }
+        /// <summary>
+        /// 手机
+        /// </summary>
+        public string F_Mobile
+        {
+            set { _f_mobile = value; }
+            get { return _f_mobile; }
+        }
+        /// <summary>
+        /// 家庭电话
+        /// </summary>
+        public string F_HomePhone
+        {
+            set { _f_homephone = value; }
+            get { return _f_homephone; }
+        }
+        /// <summary>
+        /// 出生日期
+        /// </summary>
+        public DateTime? F_Birthday
+        {
+            set { _f_birthday = value; }
+            get { return _f_birthday; }
+        }
+        /// <summary>
+        /// 建档日期
+        /// </summary>
+        public DateTime? F_CreateOn
+        {
+            set { _f_createon = value; }
+            get { return _f_createon; }
+        }
+        /// <summary>
+        /// 注销日期
+        /// </summary>
+        public DateTime? F_CancelOn
+        {
+            set { _f_cancelon = value; }
+            get { return _f_cancelon; }
+        }
+        /// <summary>
+        /// 删除标志
+        /// </summary>
+        public int? F_DeleteFlag
+        {
+            set { _f_deleteflag = value; }
+            get { return _f_deleteflag; }
+        }
+        /// <summary>
+        /// app在线标志0不在线1在线
+        /// </summary>
+        public bool F_APPOnFlag
+        {
+            set { _f_apponflag = value; }
+            get { return _f_apponflag; }
+        }
+        /// <summary>
+        /// 最后活跃时间
+        /// </summary>
+        public DateTime? F_LastActiveTime
+        {
+            set { _f_lastactivetime = value; }
+            get { return _f_lastactivetime; }
+        }
+        /// <summary>
+        /// 察看权限（1:个人;2:班组;3:所有）
+        /// </summary>
+        public string F_See
+        {
+            set { _f_see = value; }
+            get { return _f_see; }
+        }
+        /// <summary>
+        /// 此坐席任务是呼入还是呼出（0：呼入；1：呼出）
+        /// </summary>
+        public int? F_HJType
+        {
+            set { _f_hjtype = value; }
+            get { return _f_hjtype; }
+        }
+        /// <summary>
+        /// 任务计划id
+        /// </summary>
+        public int? F_PId
+        {
+            set { _f_pid = value; }
+            get { return _f_pid; }
+        }
+        /// <summary>
+        /// 团队id
+        /// </summary>
+        public int? F_TmId
+        {
+            set { _f_tmid = value; }
+            get { return _f_tmid; }
+        }
+        /// <summary>
+        /// 
+        /// </summary>
+        public string F_WorkNumber
+        {
+            set { _f_worknumber = value; }
+            get { return _f_worknumber; }
+        }
+        /// <summary>
+        /// 用于余额
+        /// </summary>
+        public string F_DeptCode
+        {
+            set { _f_deptcode = value; }
+            get { return _f_deptcode; }
+        }
+        #endregion Model
+
+    }
+}

SmsPlatform/SmsPlatform.csproj

@@ -9,6 +9,14 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <Compile Remove="Common\SQLOption.cs" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <Content Remove="Web.config" />
+  </ItemGroup>
+
+  <ItemGroup>
     <PackageReference Include="Microsoft.AspNetCore.All" Version="2.0.8" />
     <PackageReference Include="Microsoft.VisualStudio.Web.CodeGeneration.Design" Version="2.0.3" />
     <PackageReference Include="NLog.Web.AspNetCore" Version="4.4.1" />
@@ -20,10 +28,6 @@
   </ItemGroup>
 
   <ItemGroup>
-    <Folder Include="Model\" />
-  </ItemGroup>
-
-  <ItemGroup>
     <Reference Include="aliyun-net-sdk-core">
       <HintPath>dll\aliyun-net-sdk-core.dll</HintPath>
     </Reference>

SmsPlatform/Startup.cs

@@ -13,6 +13,7 @@ using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
 using NLog.Extensions.Logging;
 using NLog.Web;
+using SmsPlatform.Common;
 using Swashbuckle.AspNetCore.Swagger;
 
 namespace SmsPlatform
@@ -29,7 +30,7 @@ namespace SmsPlatform
                             .Build();
         }
 
-        public IConfiguration Configuration { get; }
+        public  IConfiguration Configuration { get; }
 
         // This method gets called by the runtime. Use this method to add services to the container.
         public void ConfigureServices(IServiceCollection services)
@@ -57,13 +58,21 @@ namespace SmsPlatform
             #endregion
 
             #region redis配置
+            RedisHelper .connserver = Configuration.GetSection("Redis:HostName").Value; //Configuration["Redis:HostName"].ToString();
+            RedisHelper .connport = Configuration["Redis:Port"].ToString();
             services.AddDistributedRedisCache(options =>
             {
                 options.InstanceName = Configuration["Redis:InstanceName"].ToString();
                 options.Configuration = $"{Configuration["Redis:HostName"].ToString()}:{Configuration["Redis:Port"].ToString()},allowAdmin=true,password={Configuration["Redis:Password"].ToString()},defaultdatabase={Configuration["Redis:Defaultdatabase"].ToString()}";
+                //options.Configuration = $"{Configuration["Redis:HostName"].ToString()}:{Configuration["Redis:Port"].ToString()},defaultdatabase={Configuration["Redis:Defaultdatabase"].ToString()}";
             });
             #endregion
 
+            #region SQL配置
+            DbHelperSQL .connectionString = Configuration.GetSection("connectionStrings:conn").Value;
+            
+            #endregion
+
             //注册Swagger生成器，定义一个和多个Swagger 文档
             services.AddSwaggerGen(c =>
             {

SmsPlatform/appsettings.Development.json

@@ -8,8 +8,8 @@
     }
   },
   "Redis": {
-    "HostName": "139.224.236.21",
-    "Port": "4000",
+    "HostName": "139.224.236.21", //139.224.236.21
+    "Port": "6379", //4000
     "Password": "sms+800100",
     "Defaultdatabase": "15",
     "InstanceName": "sms"
@@ -20,5 +20,8 @@
     "domain": "dysmsapi.aliyuncs.com",
     "accesskeyid": "LTAID8jj0g51ZsYv",
     "accesskeysecret": "EH0S0XbUQihHSGA7FMutP0J8kzXqPk"
+  },
+  "connectionStrings": {
+    "conn": "Server=192.168.4.18;Database=GSZLS;Persist Security Info=True;User ID=sa;password=800100;"
   }
 }

SmsPlatform/appsettings.Production.json

@@ -20,5 +20,8 @@
     "domain": "dysmsapi.aliyuncs.com",
     "accesskeyid": "LTAIICc6dV9MdBHK",
     "accesskeysecret": "Ed5qMOJIp4QMMERpmMr48Zpu0BTcTN"
+  },
+  "connectionStrings": {
+    "conn": "Server=192.168.4.18;Database=GSZLS;Persist Security Info=True;User ID=sa;password=800100;"
   }
 }