新增项目

SmsPlatform.sln

@@ -0,0 +1,31 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio 15
+VisualStudioVersion = 15.0.27703.1
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "SmsPlatform", "SmsPlatform\SmsPlatform.csproj", "{80EDAD10-4D5F-484A-B574-EA07558713AC}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "SmsReceive", "SmsReceive\SmsReceive.csproj", "{3F808FDF-9D2F-4F4C-91C5-55441C13E21E}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{80EDAD10-4D5F-484A-B574-EA07558713AC}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{80EDAD10-4D5F-484A-B574-EA07558713AC}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{80EDAD10-4D5F-484A-B574-EA07558713AC}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{80EDAD10-4D5F-484A-B574-EA07558713AC}.Release|Any CPU.Build.0 = Release|Any CPU
+		{3F808FDF-9D2F-4F4C-91C5-55441C13E21E}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{3F808FDF-9D2F-4F4C-91C5-55441C13E21E}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{3F808FDF-9D2F-4F4C-91C5-55441C13E21E}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{3F808FDF-9D2F-4F4C-91C5-55441C13E21E}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {5C1F0480-6673-48F7-9C4C-DE041583C23F}
+	EndGlobalSection
+EndGlobal

SmsPlatform/Common/AjaxResult.cs

@@ -0,0 +1,87 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace SmsPlatform.Common
+{
+    public class AjaxResult
+    {
+        /// <summary>
+        /// 操作结果类型
+        /// </summary>
+        public object state { get; set; }
+        /// <summary>
+        /// 获取 消息内容
+        /// </summary>
+        public string message { get; set; }
+        /// <summary>
+        /// 获取 返回数据
+        /// </summary>
+        public object data { get; set; }
+    }
+    /// <summary>
+    /// 表示 ajax 操作结果类型的枚举
+    /// </summary>
+    public enum ResultTypes
+    {
+        /// <summary>
+        /// 成功结果类型
+        /// </summary>
+        success = 200, //请求(或处理)成功,
+
+        /// <summary>
+        /// 成功结果类型
+        /// </summary>
+        redirect = 302, //跳转,
+
+        /// <summary>
+        /// 警告结果类型
+        /// </summary>
+        warning = 402,//警告
+
+        /// <summary>
+        /// 未授权
+        /// </summary>
+        unauthorized = 401,
+
+
+        /// <summary>
+        /// 请求参数不完整或不正确
+        /// </summary>
+        parameterError = 400,
+
+        /// <summary>
+        /// 请求TOKEN失效
+        /// </summary>
+        tokenInvalid = 403,
+
+        /// <summary>
+        /// HTTP请求类型不合法
+        /// </summary>
+        httpMehtodError = 405,
+
+
+        /// <summary>
+        /// HTTP请求类型不合法
+        /// </summary>
+        httpRequestError = 406,
+
+
+        /// <summary>
+        /// 该URL已经失效
+        /// </summary>
+        yrlExpireError = 407,
+
+        /// <summary>
+        /// 未登录或登录已过期
+        /// </summary>
+        notoken = 499,
+
+        /// <summary>
+        /// 异常结果类型
+        /// </summary>
+        error = 500
+
+    }
+}

SmsPlatform/Common/BaseController.cs

@@ -0,0 +1,78 @@
+using Microsoft.AspNetCore.Mvc;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace SmsPlatform.Common
+{
+    public class BaseController : Controller
+    {
+        /// <summary>
+        /// 成功的消息格式化
+        /// </summary>
+        /// <param name="message"></param>
+        /// <returns></returns>
+        protected virtual IActionResult Success(string message)
+        {
+            var jsonMsg = new AjaxResult { state = ResultTypes.success.ToString(), message = message }.ToJson();
+            return Content(jsonMsg);
+        }
+
+        /// <summary>
+        /// 成功的消息格式化
+        /// </summary>
+        /// <param name="message"></param>
+        /// <param name="data"></param>
+        /// <returns></returns>
+        protected virtual IActionResult Success(string message, object data)
+        {
+            var jsonMsg = new AjaxResult { state = ResultTypes.success.ToString(), message = message, data = data }.ToJson();
+            return Content(jsonMsg);
+        }
+
+        /// <summary>
+        /// 跳转的消息格式化
+        /// </summary>
+        /// <param name="message"></param>
+        /// <param name="data"></param>
+        /// <returns></returns>
+        protected virtual IActionResult Redirect(string message, object data)
+        {
+            return Content(new AjaxResult { state = ResultTypes.redirect.ToString(), message = message, data = data }.ToJson());
+        }
+
+        /// <summary>
+        /// 错误的消息格式化
+        /// </summary>
+        /// <param name="message"></param>
+        /// <returns></returns>
+        protected virtual IActionResult Error(string message)
+        {
+            var jsonMsg = new AjaxResult { state = ResultTypes.error.ToString(), message = message }.ToJson();
+            return Content(jsonMsg);
+        }
+
+        /// <summary>
+        /// 未登录或者登录已过期
+        /// </summary>
+        /// <param name="message"></param>
+        /// <returns></returns>
+        protected virtual IActionResult NoToken(string message)
+        {
+            var jsonMsg = new AjaxResult { state = ResultTypes.notoken.ToString(), message = message }.ToJson();
+            return Content(jsonMsg);
+        }
+
+        /// <summary>
+        /// 未授权
+        /// </summary>
+        /// <param name="message"></param>
+        /// <returns></returns>
+        protected virtual IActionResult UnAuthorized(string message)
+        {
+            var jsonMsg = new AjaxResult { state = ResultTypes.unauthorized.ToString(), message = message }.ToJson();
+            return Content(jsonMsg);
+        }
+    }
+}

SmsPlatform/Common/JsonHelper.cs

@@ -0,0 +1,45 @@
+using Newtonsoft.Json;
+using Newtonsoft.Json.Converters;
+using Newtonsoft.Json.Linq;
+using System;
+using System.Collections.Generic;
+using System.Data;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace SmsPlatform.Common
+{
+    public static class JsonHelper
+    {
+        public static object ToJson(this string Json)
+        {
+            return Json == null ? null : JsonConvert.DeserializeObject(Json);
+        }
+        public static string ToJson(this object obj)
+        {
+            var timeConverter = new IsoDateTimeConverter { DateTimeFormat = "yyyy-MM-dd HH:mm:ss" };
+            return JsonConvert.SerializeObject(obj, timeConverter);
+        }
+        public static string ToJson(this object obj, string datetimeformats)
+        {
+            var timeConverter = new IsoDateTimeConverter { DateTimeFormat = datetimeformats };
+            return JsonConvert.SerializeObject(obj, timeConverter);
+        }
+        public static T ToObject<T>(this string Json)
+        {
+            return Json == null ? default(T) : JsonConvert.DeserializeObject<T>(Json);
+        }
+        public static List<T> ToList<T>(this string Json)
+        {
+            return Json == null ? null : JsonConvert.DeserializeObject<List<T>>(Json);
+        }
+        public static DataTable ToTable(this string Json)
+        {
+            return Json == null ? null : JsonConvert.DeserializeObject<DataTable>(Json);
+        }
+        public static JObject ToJObject(this string Json)
+        {
+            return Json == null ? JObject.Parse("{}") : JObject.Parse(Json.Replace("&nbsp;", ""));
+        }
+    }
+}

SmsPlatform/Common/SecureHelper.cs

@@ -0,0 +1,61 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Security.Cryptography;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace SmsPlatform.Common
+{
+    public static class SecureHelper
+    {
+        private static Encoding _encoding { get => Encoding.UTF8; }
+
+        private static string BsToStr(byte[] bs) => string.Join(string.Empty, bs.Select(x => x.ToString("x2"))).Replace("-", string.Empty);
+
+        /// <summary>
+        /// 获取MD5
+        /// </summary>
+        /// <param name="str"></param>
+        /// <returns></returns>
+        public static string GetMD5(string str)
+        {
+            using (var md5 = new MD5CryptoServiceProvider())
+            {
+                var bs = _encoding.GetBytes(str);
+                bs = md5.ComputeHash(bs);
+                return BsToStr(bs);
+            }
+        }
+
+        /// <summary>
+        /// 获取sha1
+        /// </summary>
+        /// <param name="str"></param>
+        /// <returns></returns>
+        public static string GetSHA1(string str)
+        {
+            using (var sha1 = new SHA1CryptoServiceProvider())
+            {
+                var bs = _encoding.GetBytes(str);
+                bs = sha1.ComputeHash(bs);
+                return BsToStr(bs);
+            }
+        }
+
+        /// <summary>
+        /// SHA256函数
+        /// </summary>
+        /// /// <param name="str">原始字符串</param>
+        /// <returns>SHA256结果</returns>
+        public static string GetSHA256(string str)
+        {
+            using (var Sha256 = new SHA256CryptoServiceProvider())
+            {
+                var bs = _encoding.GetBytes(str);
+                bs = Sha256.ComputeHash(bs);
+                return BsToStr(bs);
+            }
+        }
+    }
+}

SmsPlatform/Common/SmsHelper.cs

@@ -0,0 +1,176 @@
+using Aliyun.Acs.Core;
+using Aliyun.Acs.Core.Exceptions;
+using Aliyun.Acs.Core.Profile;
+using Aliyun.Acs.Dysmsapi.Model.V20170525;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Logging;
+using NLog;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace SmsPlatform.Common
+{
+    public class SmsHelper
+    {
+        //产品名称:云通信短信API产品,开发者无需替换
+        private string product = "";
+        //产品域名,开发者无需替换
+        private string domain = "";
+
+        // TODO 此处需要替换成开发者自己的AK(在阿里云访问控制台寻找)
+        private string accesskeyid = "";
+        private string accesskeysecret = "";
+
+        private Logger _logger;
+
+        public SmsHelper(IConfiguration configuration)
+        {
+            product = configuration["Dysms:product"];
+            domain = configuration["Dysms:domain"];
+            accesskeyid = configuration["Dysms:accesskeyid"];
+            accesskeysecret = configuration["Dysms:accesskeysecret"];
+
+            _logger = LogManager.GetCurrentClassLogger();
+        }
+
+        public SendSmsResponse SendSms(string signname, string templatecode, string phonenumber, string keys, string values)
+        {
+            //string json = "{\"name\":\"张三\",\"code\":\"ZS-123456\"}";
+            string result = string.Empty;
+            string json = string.Empty;
+            
+            if (!string.IsNullOrEmpty(keys))
+            {
+                json = "{";
+
+                string[] keyary = keys.Split(',');
+                string[] valueary = values.Split(',');
+
+                for (int i = 0; i < keyary.Count(); i++)
+                {
+                    json += "\"" + keyary[i] + "\":\"" + valueary[i] + "\",";
+                }
+                json = json.Substring(0, json.Length - 1);
+                json += "}";
+            }
+            //string date = DateTime.Now.ToString("yyyyMMdd");
+            SendSmsResponse reponse = SendSms(signname, templatecode, phonenumber, json);
+            //if (reponse.Code != "OK")
+            //{
+            //    result = reponse.Message;
+            //}
+
+            return reponse;
+        }
+
+        /// <summary>
+        /// 单号码发送短信
+        /// </summary>
+        /// <returns></returns>
+        public SendSmsResponse SendSms(string signname, string templatecode, string phonenumber, string json)
+        {
+            IClientProfile profile = DefaultProfile.GetProfile("cn-hangzhou", accesskeyid, accesskeysecret);
+            DefaultProfile.AddEndpoint("cn-hangzhou", "cn-hangzhou", product, domain);
+            IAcsClient acsClient = new DefaultAcsClient(profile);
+            SendSmsRequest request = new SendSmsRequest();
+            SendSmsResponse response = null;
+            try
+            {
+
+                //必填:待发送手机号。支持以逗号分隔的形式进行批量调用，批量上限为1000个手机号码,批量调用相对于单条调用及时性稍有延迟,验证码类型的短信推荐使用单条调用的方式
+                request.PhoneNumbers = phonenumber;
+                //必填:短信签名-可在短信控制台中找到
+                request.SignName = signname;
+                //必填:短信模板-可在短信控制台中找到
+                request.TemplateCode = templatecode;
+                //可选:模板中的变量替换JSON串,如模板内容为"亲爱的${name},您的验证码为${code}"时,此处的值为
+                request.TemplateParam = json;
+                //可选:outId为提供给业务方扩展字段,最终在短信回执消息中将此值带回给调用者
+                //request.OutId = "yourOutId";
+                //请求失败这里会抛ClientException异常
+                response = acsClient.GetAcsResponse(request);
+
+            }
+            catch (ServerException e)
+            {
+                _logger.Error(signname+"|||"+ templatecode + "|||" + phonenumber + "|||" + json + "|||" + e.ToString());
+            }
+            catch (ClientException e)
+            {
+                _logger.Error(signname + "|||" + templatecode + "|||" + phonenumber + "|||" + json + "|||" + e.ToString());
+            }
+            return response;
+
+        }
+
+        /// <summary>
+        /// 查询发送详情
+        /// </summary>
+        /// <param name="bizId"></param>
+        /// <returns></returns>
+        public QuerySendDetailsResponse QuerySendDetails(string bizId, string phonenumber, string senddate, long? pagesize = 10, long? currentpage = 1)
+        {
+            //初始化acsClient,暂不支持region化
+            IClientProfile profile = DefaultProfile.GetProfile("cn-hangzhou", accesskeyid, accesskeysecret);
+            DefaultProfile.AddEndpoint("cn-hangzhou", "cn-hangzhou", product, domain);
+            IAcsClient acsClient = new DefaultAcsClient(profile);
+            //组装请求对象
+            QuerySendDetailsRequest request = new QuerySendDetailsRequest();
+            //必填-号码
+            request.PhoneNumber = phonenumber;
+            //可选-流水号
+            request.BizId = bizId;
+            if (string.IsNullOrEmpty(senddate))
+            {
+                senddate = DateTime.Now.ToString("yyyyMMdd");
+            }
+            //必填-发送日期 支持30天内记录查询，格式yyyyMMdd       
+            request.SendDate = senddate;
+            //必填-页大小
+            request.PageSize = pagesize;
+            //必填-当前页码从1开始计数
+            request.CurrentPage = currentpage;
+
+            QuerySendDetailsResponse querySendDetailsResponse = null;
+            try
+            {
+                querySendDetailsResponse = acsClient.GetAcsResponse(request);
+            }
+            catch (ServerException e)
+            {
+                _logger.Error(e.ToString());
+            }
+            catch (ClientException e)
+            {
+                _logger.Error(e.ToString());
+            }
+            return querySendDetailsResponse;
+        }
+
+        /// <summary>
+        /// 查询发送详情
+        /// </summary>
+        /// <param name="bizId"></param>
+        /// <returns></returns>
+        public QuerySendDetailsResponse.QuerySendDetails_SmsSendDetailDTO Query(string bizId, string phonenumber, string senddate)
+        {
+            QuerySendDetailsResponse.QuerySendDetails_SmsSendDetailDTO result = new QuerySendDetailsResponse.QuerySendDetails_SmsSendDetailDTO();
+            var qr = QuerySendDetails(bizId, phonenumber, senddate);
+            if (qr.Code == "OK")
+            {
+                if (qr.SmsSendDetailDTOs.Count > 0)
+                {
+                    var ssdd = qr.SmsSendDetailDTOs[0];
+                    if (ssdd.SendStatus == 1)
+                    {
+                        System.Threading.Thread.Sleep(1000);
+                        result = Query(bizId, phonenumber, senddate);
+                    }
+                }
+            }
+            return result;
+        }
+    }
+}

SmsPlatform/Controllers/SmsController.cs

@@ -0,0 +1,305 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using System.Transactions;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.Extensions.Caching.Distributed;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Logging;
+using SmsPlatform.Common;
+using SmsPlatform.Model;
+
+namespace SmsPlatform.Controllers
+{
+    /// <summary>
+    /// 短信模块
+    /// </summary>
+    [Produces("application/json")]
+    [Route("api/[controller]")]
+    public class SmsController : BaseController
+    {
+        private readonly ILogger<SmsController> _logger;
+        private readonly IDistributedCache _cache;
+        private readonly IConfiguration _configuration;
+        public SmsController(IDistributedCache cache, IConfiguration configuration, ILogger<SmsController> logger)
+        {
+            _cache = cache;
+            _logger = logger;
+            _configuration = configuration;
+        }
+
+        /// <summary>
+        /// 获取用户余额
+        /// </summary>
+        /// <returns></returns>
+        [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))
+            {
+                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("账号或者密码错误");
+            }
+        }
+
+        /// <summary>
+        /// 更新余额
+        /// </summary>
+        /// <returns></returns>
+        [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))
+            {
+                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())
+                {
+                    model.Balance = model.Balance + amount;
+                    await _cache.SetStringAsync("T_User_Account", userlist.ToJson());
+
+
+                    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;
+
+                    amtlist.Add(amt);
+                    await _cache.SetStringAsync("T_User_Amount", amtlist.ToJson());
+
+                    return Success("成功", model.Balance);
+                }
+                else
+                {
+                    return Error("签名错误");
+                }
+            }
+            else
+            {
+                return Error("账号或者密码错误");
+            }
+        }
+
+        /// <summary>
+        /// 扣款
+        /// </summary>
+        /// <returns></returns>
+        [HttpPost("deductamount")]
+        [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))
+            {
+                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())
+                {
+                    model.Balance = model.Balance - amount;
+                    await _cache.SetStringAsync("T_User_Account", userlist.ToJson());
+
+
+                    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());
+
+                    return Success("成功", model.Balance);
+                }
+                else
+                {
+                    return Error("签名错误");
+                }
+            }
+            else
+            {
+                return Error("账号或者密码错误");
+            }
+        }
+
+        /// <summary>
+        /// 发送短信
+        /// </summary>
+        /// <returns></returns>
+        [HttpPost("sendsms")]
+        [ApiExplorerSettings(IgnoreApi = true)]
+        public async Task<IActionResult> SendSms(string usercode, string password, string signcode, string content,
+            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))
+            {
+                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 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 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 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
+                {
+                    return Error("签名错误");
+                }
+            }
+            else
+            {
+                return Error("账号或者密码错误");
+            }
+
+        }
+
+        /// <summary>
+        /// 获取错误信息
+        /// </summary>
+        /// <param name="BizId"></param>
+        /// <returns></returns>
+        [ApiExplorerSettings(IgnoreApi = true)]
+        public T_Sms_Send GetSend(string BizId)
+        {
+            var sendliststr = _cache.GetString("T_Sms_Send");
+            var sendlist = new List<T_Sms_Send>();
+            if (!string.IsNullOrEmpty(sendliststr))
+            {
+                sendlist = sendliststr.ToList<T_Sms_Send>();
+            }
+            var send = sendlist.Where(p => p.BizId == BizId).FirstOrDefault();
+            if (send == null)
+            {
+                System.Threading.Thread.Sleep(1000);
+                send = GetSend(BizId);
+            }
+            string str = send.ToJson();
+            sendlist.Remove(send);
+            return str.ToObject<T_Sms_Send>();
+        }
+    }
+}

SmsPlatform/Controllers/UserAccountController.cs

@@ -0,0 +1,150 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.Extensions.Caching.Distributed;
+using Microsoft.Extensions.Logging;
+using SmsPlatform.Common;
+using SmsPlatform.Model;
+
+namespace SmsPlatform.Controllers
+{
+    /// <summary>
+    /// 用户模块
+    /// </summary>
+    [Produces("application/json")]
+    [Route("api/[controller]")]
+    public class UserAccountController : BaseController
+    {
+        private readonly ILogger<UserAccountController> _logger;
+        private readonly IDistributedCache _cache;
+        public UserAccountController(IDistributedCache cache, ILogger<UserAccountController> logger)
+        {
+            _cache = cache;
+            _logger = logger;
+        }
+
+        /// <summary>
+        /// 获取用户列表
+        /// </summary>
+        /// <returns></returns>
+        [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))
+            {
+                list = liststr.ToList<T_User_Account>();
+            }
+            return Success("成功", list);
+        }
+
+        /// <summary>
+        /// 获取用户详情 by id
+        /// </summary>
+        /// <param name="id">id</param>
+        /// <returns></returns>
+        [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))
+            {
+                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))
+            {
+                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);
+        }
+
+        /// <summary>
+        /// 添加修改用户信息
+        /// </summary>
+        /// <param name="input">用户信息参数</param>
+        /// <returns></returns>
+        [HttpPost("addupdate")]
+        [ApiExplorerSettings(IgnoreApi = true)]
+        public async Task<IActionResult> AddUpdate(T_User_Account input)
+        {
+            #region 验证判断
+            if (string.IsNullOrEmpty(input.UserCode))
+                return Error("账号不能为空");
+            if (string.IsNullOrEmpty(input.Password))
+                return Error("密码不能为空");
+            if (string.IsNullOrEmpty(input.Sign))
+                return Error("签名不能为空");
+            #endregion
+
+            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 model = new T_User_Account();
+            if (input.Id != 0)
+            {
+                model = list.Where(p => p.Id == input.Id).SingleOrDefault();
+                if (model != null)
+                {
+                    model.UserCode = input.UserCode;
+                    model.Password = input.Password;
+                    model.UserName = input.UserName;
+                    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);
+            }
+
+            return Error("保存失败");
+        }
+
+        /// <summary>
+        /// 删除用户
+        /// </summary>
+        /// <param name="id"></param>
+        /// <returns></returns>
+        [HttpPost("delete")]
+        [ApiExplorerSettings(IgnoreApi = true)]
+        public async Task<IActionResult> Delete(int id)
+        {
+            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 model = list.Where(p => p.Id == id).SingleOrDefault();
+            list.Remove(model);
+            await _cache.SetStringAsync("T_User_Account", list.ToJson());
+            return Success("删除成功");
+        }
+    }
+}

SmsPlatform/Model/T_Sms_Send.cs

@@ -0,0 +1,98 @@
+using System;
+namespace SmsPlatform.Model
+{
+    /// <summary>
+    /// T_Sms_Template:实体类(属性说明自动提取数据库字段的描述信息)
+    /// </summary>
+    [Serializable]
+    public partial class T_Sms_Send
+    {
+        public T_Sms_Send()
+        { }
+        #region Model
+        private int _id;
+        private string _phonenumber;
+        private string _bizid;
+        private DateTime? _sendtime;
+        private DateTime? _reporttime;
+        private int _state;
+        private string _errcode;
+        private string _errmsg;
+        private int _smssize;
+        /// <summary>
+        /// 自增id
+        /// </summary>
+        public int Id
+        {
+            set { _id = value; }
+            get { return _id; }
+        }
+        /// <summary>
+        /// 手机号码
+        /// </summary>
+        public string PhoneNumber
+        {
+            set { _phonenumber = value; }
+            get { return _phonenumber; }
+        }
+        /// <summary>
+        /// 发送回执ID
+        /// </summary>
+        public string BizId
+        {
+            set { _bizid = value; }
+            get { return _bizid; }
+        }
+        /// <summary>
+        /// 发送时间
+        /// </summary>
+        public DateTime? SendTime
+        {
+            set { _sendtime = value; }
+            get { return _sendtime; }
+        }
+        /// <summary>
+        /// 回执时间
+        /// </summary>
+        public DateTime? ReportTime
+        {
+            set { _reporttime = value; }
+            get { return _reporttime; }
+        }
+        /// <summary>
+        /// 发送状态 1：等待回执，2：发送失败，3：发送成功
+        /// </summary>
+        public int State
+        {
+            set { _state = value; }
+            get { return _state; }
+        }
+        /// <summary>
+        /// 错误码
+        /// </summary>
+        public string ErrCode
+        {
+            set { _errcode = value; }
+            get { return _errcode; }
+        }
+        /// <summary>
+        /// 错误信息
+        /// </summary>
+        public string ErrMsg
+        {
+            set { _errmsg = value; }
+            get { return _errmsg; }
+        }
+        /// <summary>
+        /// 	短信大小--140字节算一条短信，短信长度超过140字节时会拆分成多条短信发送
+        /// </summary>
+        public int SmsSize
+        {
+            set { _smssize = value; }
+            get { return _smssize; }
+        }
+        #endregion Model
+
+    }
+}
+

SmsPlatform/Model/T_Sms_Template.cs

@@ -0,0 +1,71 @@
+using System;
+namespace SmsPlatform.Model
+{
+    /// <summary>
+    /// T_Sms_Template:实体类(属性说明自动提取数据库字段的描述信息)
+    /// </summary>
+    [Serializable]
+    public partial class T_Sms_Template
+    {
+        public T_Sms_Template()
+        { }
+        #region Model
+        private int _id;
+        private string _name;
+        private string _script;
+        private string _code;
+        private string _paramname;
+        private DateTime? _createtime;
+        /// <summary>
+        /// 自增id
+        /// </summary>
+        public int Id
+        {
+            set { _id = value; }
+            get { return _id; }
+        }
+        /// <summary>
+        /// 模板名称
+        /// </summary>
+        public string Name
+        {
+            set { _name = value; }
+            get { return _name; }
+        }
+        /// <summary>
+        /// 模板脚本
+        /// </summary>
+        public string Script
+        {
+            set { _script = value; }
+            get { return _script; }
+        }
+        /// <summary>
+        /// 模板Code
+        /// </summary>
+        public string Code
+        {
+            set { _code = value; }
+            get { return _code; }
+        }
+        /// <summary>
+        /// 模板参数名
+        /// </summary>
+        public string ParamName
+        {
+            set { _paramname = value; }
+            get { return _paramname; }
+        }
+        /// <summary>
+        /// 创建时间
+        /// </summary>
+        public DateTime? CreateTime
+        {
+            set { _createtime = value; }
+            get { return _createtime; }
+        }
+        #endregion Model
+
+    }
+}
+

SmsPlatform/Model/T_User_Account.cs

@@ -0,0 +1,80 @@
+using System;
+namespace SmsPlatform.Model
+{
+    /// <summary>
+    /// T_User_Account:实体类(属性说明自动提取数据库字段的描述信息)
+    /// </summary>
+    [Serializable]
+    public partial class T_User_Account
+    {
+        public T_User_Account()
+        { }
+        #region Model
+        private int _id;
+        private string _usercode;
+        private string _password;
+        private string _username;
+        private decimal? _balance;
+        private string _sign;
+        private DateTime? _createtime;
+        /// <summary>
+        /// 自增id
+        /// </summary>
+        public int Id
+        {
+            set { _id = value; }
+            get { return _id; }
+        }
+        /// <summary>
+        /// 用户账号
+        /// </summary>
+        public string UserCode
+        {
+            set { _usercode = value; }
+            get { return _usercode; }
+        }
+        /// <summary>
+        /// 密码
+        /// </summary>
+        public string Password
+        {
+            set { _password = value; }
+            get { return _password; }
+        }
+        /// <summary>
+        /// 昵称
+        /// </summary>
+        public string UserName
+        {
+            set { _username = value; }
+            get { return _username; }
+        }
+        /// <summary>
+        /// 余额
+        /// </summary>
+        public decimal? Balance
+        {
+            set { _balance = value; }
+            get { return _balance; }
+        }
+        /// <summary>
+        /// 签名
+        /// </summary>
+        public string Sign
+        {
+            set { _sign = value; }
+            get { return _sign; }
+        }
+        /// <summary>
+        /// 创建时间
+        /// </summary>
+        public DateTime? CreateTime
+        {
+            set { _createtime = value; }
+            get { return _createtime; }
+        }
+        #endregion Model
+
+    }
+}
+

SmsPlatform/Model/T_User_Amount.cs

@@ -0,0 +1,71 @@
+using System;
+namespace SmsPlatform.Model
+{
+    /// <summary>
+    /// T_User_Amount:实体类(属性说明自动提取数据库字段的描述信息)
+    /// </summary>
+    [Serializable]
+    public partial class T_User_Amount
+    {
+        public T_User_Amount()
+        { }
+        #region Model
+        private int _id;
+        private string _usercode;
+        private decimal? _amount;
+        private decimal? _balance;
+        private string _remark;
+        private DateTime? _createtime;
+        /// <summary>
+        /// 自增id
+        /// </summary>
+        public int Id
+        {
+            set { _id = value; }
+            get { return _id; }
+        }
+        /// <summary>
+        /// 用户账号
+        /// </summary>
+        public string UserCode
+        {
+            set { _usercode = value; }
+            get { return _usercode; }
+        }
+        /// <summary>
+        /// 金额变动
+        /// </summary>
+        public decimal? Amount
+        {
+            set { _amount = value; }
+            get { return _amount; }
+        }
+        /// <summary>
+        /// 余额
+        /// </summary>
+        public decimal? Balance
+        {
+            set { _balance = value; }
+            get { return _balance; }
+        }
+        /// <summary>
+        /// 备注
+        /// </summary>
+        public string Remark
+        {
+            set { _remark = value; }
+            get { return _remark; }
+        }
+        /// <summary>
+        /// 创建时间
+        /// </summary>
+        public DateTime? CreateTime
+        {
+            set { _createtime = value; }
+            get { return _createtime; }
+        }
+        #endregion Model
+
+    }
+}
+

SmsPlatform/Program.cs

@@ -0,0 +1,25 @@
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore;
+using Microsoft.AspNetCore.Hosting;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Logging;
+
+namespace SmsPlatform
+{
+    public class Program
+    {
+        public static void Main(string[] args)
+        {
+            BuildWebHost(args).Run();
+        }
+
+        public static IWebHost BuildWebHost(string[] args) =>
+            WebHost.CreateDefaultBuilder(args)
+                .UseStartup<Startup>()
+                .Build();
+    }
+}

SmsPlatform/Properties/launchSettings.json

@@ -0,0 +1,29 @@
+{
+  "iisSettings": {
+    "windowsAuthentication": false,
+    "anonymousAuthentication": true,
+    "iisExpress": {
+      "applicationUrl": "http://localhost:64157/",
+      "sslPort": 0
+    }
+  },
+  "profiles": {
+    "IIS Express": {
+      "commandName": "IISExpress",
+      "launchBrowser": true,
+      "launchUrl": "swagger",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "SmsPlatform": {
+      "commandName": "Project",
+      "launchBrowser": true,
+      "launchUrl": "api/values",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      },
+      "applicationUrl": "http://localhost:64158/"
+    }
+  }
+}

SmsPlatform/SmsPlatform.csproj

@@ -0,0 +1,35 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <TargetFramework>netcoreapp2.0</TargetFramework>
+  </PropertyGroup>
+
+  <PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'">
+    <DocumentationFile>bin\Debug\netcoreapp2.0\SmsPlatform.xml</DocumentationFile>
+  </PropertyGroup>
+
+  <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" />
+    <PackageReference Include="Swashbuckle.AspNetCore" Version="4.0.1" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <DotNetCliToolReference Include="Microsoft.VisualStudio.Web.CodeGeneration.Tools" Version="2.0.4" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <Folder Include="Model\" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <Reference Include="aliyun-net-sdk-core">
+      <HintPath>dll\aliyun-net-sdk-core.dll</HintPath>
+    </Reference>
+    <Reference Include="aliyun-net-sdk-dysmsapi">
+      <HintPath>dll\aliyun-net-sdk-dysmsapi.dll</HintPath>
+    </Reference>
+  </ItemGroup>
+
+</Project>

SmsPlatform/Startup.cs

@@ -0,0 +1,112 @@
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+using System.Reflection;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.Builder;
+using Microsoft.AspNetCore.Hosting;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Logging;
+using Microsoft.Extensions.Options;
+using NLog.Extensions.Logging;
+using NLog.Web;
+using Swashbuckle.AspNetCore.Swagger;
+
+namespace SmsPlatform
+{
+    public class Startup
+    {
+        public Startup(IHostingEnvironment env)
+        {
+            Configuration = new ConfigurationBuilder()
+                            .SetBasePath(env.ContentRootPath)
+                            .AddJsonFile("appsettings.json", optional: true, reloadOnChange: true)
+                            .AddJsonFile($"appsettings.{env.EnvironmentName}.json", optional: true, reloadOnChange: true)
+                            .AddEnvironmentVariables()
+                            .Build();
+        }
+
+        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)
+        {
+            #region Cors 配置
+            //生产环境 的cors
+            services.AddCors(options =>
+            {
+                options.AddPolicy("CorsProd",
+                 builder => builder.AllowAnyOrigin()
+                //builder => builder.WithOrigins(Configuration["Cors"].Split(','))
+                .AllowAnyMethod()
+                .AllowAnyHeader()
+                .AllowCredentials().SetPreflightMaxAge(TimeSpan.FromMinutes(30)));
+            });
+            //开发环境的cors
+            services.AddCors(options =>
+            {
+                options.AddPolicy("CorsDev",
+                builder => builder.AllowAnyOrigin()
+                .AllowAnyMethod()
+                .AllowAnyHeader()
+                .AllowCredentials().SetPreflightMaxAge(TimeSpan.FromMinutes(30)));
+            });
+            #endregion
+
+            #region redis配置
+            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()}";
+            });
+            #endregion
+
+            //注册Swagger生成器，定义一个和多个Swagger 文档
+            services.AddSwaggerGen(c =>
+            {
+                c.SwaggerDoc("v1", new Info { Title = "SmsPlatform", Version = "v1" });
+                // 设置SWAGER JSON和UI的注释路径。
+                var xmlFile = $"{Assembly.GetExecutingAssembly().GetName().Name}.xml";
+                var xmlPath = Path.Combine(AppContext.BaseDirectory, xmlFile);
+                c.IncludeXmlComments(xmlPath);
+            });
+
+            services.AddMvc();
+        }
+
+        // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
+        public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory loggerFactory)
+        {
+            if (env.IsProduction())
+            {
+                app.UseCors("CorsProd");
+            }
+            else
+            {
+                app.UseCors("CorsDev");
+                app.UseDeveloperExceptionPage();
+                app.UseDatabaseErrorPage();
+                app.UseBrowserLink();
+            }
+
+            app.UseMvc();
+
+            loggerFactory.AddNLog();//添加NLog
+            env.ConfigureNLog("nlog.config");//读取Nlog配置文件
+            app.AddNLogWeb();
+
+            //启用中间件服务生成Swagger作为JSON终结点
+            app.UseSwagger();
+            //启用中间件服务对swagger-ui，指定Swagger JSON终结点
+            app.UseSwaggerUI(c =>
+            {
+                c.SwaggerEndpoint("/swagger/v1/swagger.json", "SmsPlatform V1");
+                // 要在应用程序的根处提供Swagger UI ，请将该RoutePrefix属性设置为空字符串
+                c.RoutePrefix = string.Empty;
+            });
+        }
+    }
+}

SmsPlatform/appsettings.Development.json

@@ -0,0 +1,24 @@
+{
+  "Logging": {
+    "IncludeScopes": false,
+    "LogLevel": {
+      "Default": "Debug",
+      "System": "Information",
+      "Microsoft": "Information"
+    }
+  },
+  "Redis": {
+    "HostName": "139.224.236.21",
+    "Port": "4000",
+    "Password": "sms+800100",
+    "Defaultdatabase": "15",
+    "InstanceName": "sms"
+  },
+  "amount": 0.08,
+  "Dysms": {
+    "product": "Dysmsapi",
+    "domain": "dysmsapi.aliyuncs.com",
+    "accesskeyid": "LTAID8jj0g51ZsYv",
+    "accesskeysecret": "EH0S0XbUQihHSGA7FMutP0J8kzXqPk"
+  }
+}

SmsPlatform/appsettings.Production.json

@@ -0,0 +1,24 @@
+{
+  "Logging": {
+    "IncludeScopes": false,
+    "LogLevel": {
+      "Default": "Info",
+      "System": "Info",
+      "Microsoft": "Info"
+    }
+  },
+  "Redis": {
+    "HostName": "139.224.236.21",
+    "Port": "4000",
+    "Password": "sms+800100",
+    "Defaultdatabase": "15",
+    "InstanceName": "sms"
+  },
+  "amount": 0.08,
+  "Dysms": {
+    "product": "Dysmsapi",
+    "domain": "dysmsapi.aliyuncs.com",
+    "accesskeyid": "LTAIICc6dV9MdBHK",
+    "accesskeysecret": "Ed5qMOJIp4QMMERpmMr48Zpu0BTcTN"
+  }
+}

SmsPlatform/appsettings.json

@@ -0,0 +1,15 @@
+{
+  "Logging": {
+    "IncludeScopes": false,
+    "Debug": {
+      "LogLevel": {
+        "Default": "Warning"
+      }
+    },
+    "Console": {
+      "LogLevel": {
+        "Default": "Warning"
+      }
+    }
+  }
+}

SmsPlatform/nlog.config

@@ -0,0 +1,71 @@
+<?xml version="1.0" encoding="utf-8" ?>
+<nlog xmlns="http://www.nlog-project.org/schemas/NLog.xsd"
+      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+      autoReload="true"
+      internalLogLevel="Error"
+      internalLogFile="nlogtemp\internal-nlog.txt">
+
+ <!-- 加载ASP.NET Core插件 -->
+  <extensions>
+    <add assembly="NLog.Web.AspNetCore"/>
+  </extensions>
+
+  <!-- 输出目的地 -->
+  <targets>
+    <!-- 输出到文件,这个文件记录所有日志 -->
+    <!--<target xsi:type="File" name="allfile" fileName="\nlogtemp\${shortdate}\nlog-all-${shortdate}.log"
+                layout="记录时间：${longdate}|控制器：${logger}|消息：${message} 异常：${exception}" />-->
+
+    <!-- 另外一个日志记录文件,户口也跳过Microsoft开头相关日志信息 -->
+    <!--archiveFileName表示滚动日志存放路径，log.{#####}.txt是滚动日志文件名-->
+    <!--archiveAboveSize每个日志文件大小的最大值（单位：字节）20(mb)=20971520(b)，主日志文件超过大小超过该值时会将文件内容写入滚动日志并清空主日志文件内容-->
+    <!--maxArchiveFiles滚动日志文件上限数，滚动日志文件数达到上限新的文件内容会覆盖旧文件内容 -->
+
+    <target xsi:type="File" name="own_file" fileName="log/${shortdate}/own_${shortdate}.log"
+            archiveFileName="log/${shortdate}/own_${shortdate}.{#####}.log"
+            archiveAboveSize="20971520" archiveNumbering="Rolling" concurrentWrites="true" maxArchiveFiles="-1" keepFileOpen="false" 
+            layout="${level}|记录时间：${longdate}|${event-properties:item=EventId.Id}|控制器：${logger}|action: ${aspnet-mvc-action}|${newline}消息：${message}|${newline}异常：${exception}|${newline}url: ${aspnet-request-url}|${newline}" />
+    <!--layout="记录时间：${longdate}|控制器：${logger}|  action: ${aspnet-mvc-action}|  消息：${message} 异常：${exception}" />-->
+    <!--错误提示-->
+    
+
+    <target name="error_file" xsi:type="File" fileName="log/${shortdate}/error-${shortdate}.log"
+            archiveFileName="log/${shortdate}/own-${shortdate}.{#####}.log"
+            archiveAboveSize="20971520" archiveNumbering="Rolling" concurrentWrites="true" maxArchiveFiles="-1" keepFileOpen="false" 
+            layout="${level}|记录时间：${longdate}|控制器：${logger}|action: ${aspnet-mvc-action}|${newline}消息：${message}|${newline}异常：${onexception:${exception:format=tostring} ${newline} ${stacktrace}|${newline}" />
+    <target name="debugger_file" xsi:type="File" fileName="log/${shortdate}/debugger-${shortdate}.log"
+            archiveFileName="log/${shortdate}/debugger-${shortdate}.{#####}.log"
+            archiveAboveSize="20971520" archiveNumbering="Rolling" concurrentWrites="true" maxArchiveFiles="-1" keepFileOpen="false"
+            layout="${level}|记录时间：${date:format=HH/:mm/:ss}|控制器：${logger}|action: ${aspnet-mvc-action}|消息：${message}|${newline}" />
+     <target name="warn_file" xsi:type="File" fileName="log/${shortdate}/warn-${shortdate}.log"
+            archiveFileName="log/${shortdate}/warn-${shortdate}.{#####}.log"
+            archiveAboveSize="20971520" archiveNumbering="Rolling" concurrentWrites="true" maxArchiveFiles="-1" keepFileOpen="false" 
+            layout="${level}|记录时间：${date:format=HH/:mm/:ss}|控制器：${logger}|action: ${aspnet-mvc-action}|消息：${message}|${newline}" />
+    <!-- write to the void aka just remove -->
+    <target xsi:type="Null" name="blackhole" />
+  </targets>
+
+  <!-- 写入目的地的规则 -->
+  <rules>
+    <!--全部记录,包括Microsoft开头的相关日志信息-->
+    <!--<logger name="*" minlevel="Trace" writeTo="allfile" />-->
+
+    <!--name - 记录者的名字 (允许使用通配符*)
+        minlevel - 匹配日志范围的最低级别
+        maxlevel - 匹配日志范围的最高级别
+        level - 匹配的单一日志级别 :::::NLog 用于输出日志的级别包括：Trace,Debug,Info,Warn,Error,Fatal
+        levels - 匹配的一系列日志级别，由逗号分隔。
+        writeTo - 规则匹配时日志应该被写入的一系列目标，由逗号分隔。-->
+
+    <!--跳过Microsoft开头的相关日志信息-->
+    <!--<logger name="Microsoft.*" minlevel="Trace" writeTo="blackhole" final="true" />-->
+
+    <!--错误提示-->
+    <logger name="*" minlevel="Trace" writeTo="own_file" />
+    <logger name="*" level="Debug" writeTo="debugger_file" />
+    <logger name="*" minlevel="Error" writeTo="error_file" />
+    <logger name="*" level="Warn" writeTo="warn_file" />
+ 
+
+  </rules>
+</nlog>

SmsReceive/Program.cs

@@ -0,0 +1,122 @@
+using Aliyun.Acs.Core;
+using Aliyun.Acs.Core.Profile;
+using Microsoft.Extensions.Caching.Redis;
+using Microsoft.Extensions.Caching.Distributed;
+using Microsoft.Extensions.Configuration;
+using System;
+using System.Threading;
+
+namespace SmsReceive
+{
+    class Program
+    {
+        private static int maxThread = 2;
+        static IAcsClient acsClient = null;
+        private static RedisCache redisCache = null;
+        static void Main(string[] args)
+        {
+            var config = new ConfigurationBuilder().AddJsonFile("config.json", optional: true, reloadOnChange: true).Build();
+
+            redisCache = new RedisCache(new RedisCacheOptions()
+            {
+                InstanceName = config["Redis:InstanceName"].ToString(),
+                Configuration = $"{config["Redis:HostName"].ToString()}:{config["Redis:Port"].ToString()},allowAdmin=true,password={config["Redis:Password"].ToString()},defaultdatabase={config["Redis:Defaultdatabase"].ToString()}"
+            });
+
+            ////redisCache.Remove("T_Sms_Send");
+            //var userliststr = redisCache.GetStringAsync("T_Sms_Send").Result.ToString();
+            //Console.WriteLine(userliststr);
+
+            string product = config["Dysms:product"].ToString();
+            string domain = config["Dysms:domain"].ToString();
+            string accesskeyid = config["Dysms:accesskeyid"].ToString();
+            string accesskeysecret = config["Dysms:accesskeysecret"].ToString();
+            string messagetype = config["Dysms:messagetype"].ToString();
+            string queuename = config["Dysms:queuename"].ToString();
+            string regionid = config["Dysms:regionid"].ToString();
+            string mnsaccountendpoint = config["Dysms:mnsaccountendpoint"].ToString();
+
+            IClientProfile profile = DefaultProfile.GetProfile(regionid, accesskeyid, accesskeysecret);
+            DefaultProfile.AddEndpoint(regionid, regionid, product, domain);
+            acsClient = new DefaultAcsClient(profile);
+
+            //for (int i = 0; i < maxThread; i++)
+            //{
+            //    ReceiveTask testTask = new ReceiveTask("PullMessageTask-thread-" + i, messagetype, queuename, mnsaccountendpoint, acsClient, redisCache);
+            //    Thread t = new Thread(new ThreadStart(testTask.Handle));
+            //    //启动线程
+            //    t.Start();
+            //}
+
+            ReceiveTask testTask = new ReceiveTask("PullMessageTask-thread", messagetype, queuename, mnsaccountendpoint, acsClient, redisCache);
+            Thread t = new Thread(new ThreadStart(testTask.Handle));
+            //启动线程
+            t.Start();
+
+            Console.ReadKey();
+        }
+
+        public partial class T_User_Amount
+        {
+            public T_User_Amount()
+            { }
+            #region Model
+            private int _id;
+            private string _usercode;
+            private decimal? _amount;
+            private decimal? _balance;
+            private string _remark;
+            private DateTime? _createtime;
+            /// <summary>
+            /// 自增id
+            /// </summary>
+            public int Id
+            {
+                set { _id = value; }
+                get { return _id; }
+            }
+            /// <summary>
+            /// 用户账号
+            /// </summary>
+            public string UserCode
+            {
+                set { _usercode = value; }
+                get { return _usercode; }
+            }
+            /// <summary>
+            /// 金额变动
+            /// </summary>
+            public decimal? Amount
+            {
+                set { _amount = value; }
+                get { return _amount; }
+            }
+            /// <summary>
+            /// 余额
+            /// </summary>
+            public decimal? Balance
+            {
+                set { _balance = value; }
+                get { return _balance; }
+            }
+            /// <summary>
+            /// 备注
+            /// </summary>
+            public string Remark
+            {
+                set { _remark = value; }
+                get { return _remark; }
+            }
+            /// <summary>
+            /// 创建时间
+            /// </summary>
+            public DateTime? CreateTime
+            {
+                set { _createtime = value; }
+                get { return _createtime; }
+            }
+            #endregion Model
+
+        }
+    }
+}

SmsReceive/ReceiveTask.cs

@@ -0,0 +1,247 @@
+using Aliyun.Acs.Core;
+using Aliyun.Acs.Dybaseapi.Model.V20170525;
+using Aliyun.MNS;
+using Aliyun.MNS.Model;
+using Microsoft.Extensions.Caching.Redis;
+using Microsoft.Extensions.Caching.Distributed;
+using System;
+using System.Collections.Generic;
+using System.Text;
+using System.Threading;
+using Newtonsoft.Json.Linq;
+using Newtonsoft.Json;
+using System.Linq;
+using Newtonsoft.Json.Converters;
+
+namespace SmsReceive
+{
+    public class ReceiveTask
+    {
+        private object o = new object();
+        private int sleepTime = 50;
+        public String name { get; private set; }
+        public String messageType { get; private set; }
+        public String queueName { get; private set; }
+        public String mnsAccountEndpoint { get; private set; }
+        public int TaskID { get; private set; }
+        public IAcsClient acsClient { get; private set; }
+        public RedisCache redisCache = null;
+
+        public ReceiveTask(String name, String messageType, String queueName, String mnsAccountEndpoint, IAcsClient acsClient, RedisCache redisCache)
+        {
+            this.name = name;
+            this.messageType = messageType;
+            this.queueName = queueName;
+            this.mnsAccountEndpoint = mnsAccountEndpoint;
+            this.acsClient = acsClient;
+            this.redisCache = redisCache;
+        }
+        long bufferTime = 60 * 2;//过期时间小于2分钟则重新获取，防止服务器时间误差
+
+        Dictionary<string, QueryTokenForMnsQueueResponse.QueryTokenForMnsQueue_MessageTokenDTO> tokenMap = new Dictionary<string, QueryTokenForMnsQueueResponse.QueryTokenForMnsQueue_MessageTokenDTO>();
+        Dictionary<string, Queue> queueMap = new Dictionary<string, Queue>();
+
+        /// 处理消息
+        public void Handle()
+        {
+            while (true)
+            {
+                try
+                {
+                    QueryTokenForMnsQueueResponse.QueryTokenForMnsQueue_MessageTokenDTO token = null;
+                    Queue queue = null;
+                    lock (o)
+                    {
+                        if (tokenMap.ContainsKey(messageType))
+                        {
+                            token = tokenMap[messageType];
+                        }
+                        if (queueMap.ContainsKey(queueName))
+                        {
+                            queue = queueMap[queueName];
+                        }
+                        TimeSpan ts = new TimeSpan(0);
+                        if (token != null)
+                        {
+                            DateTime b = Convert.ToDateTime(token.ExpireTime);
+                            DateTime c = Convert.ToDateTime(DateTime.Now);
+                            ts = b - c;
+                        }
+                        if (token == null || ts.TotalSeconds < bufferTime || queue == null)
+                        {
+                            token = GetTokenByMessageType(acsClient, messageType);
+                            IMNS client = new Aliyun.MNS.MNSClient(token.AccessKeyId, token.AccessKeySecret, mnsAccountEndpoint, token.SecurityToken);
+                            queue = client.GetNativeQueue(queueName);
+                            if (tokenMap.ContainsKey(messageType))
+                            {
+                                tokenMap.Remove(messageType);
+                            }
+                            if (queueMap.ContainsKey(queueName))
+                            {
+                                queueMap.Remove(queueName);
+                            }
+                            tokenMap.Add(messageType, token);
+                            queueMap.Add(queueName, queue);
+                        }
+                    }
+                    BatchReceiveMessageResponse batchReceiveMessageResponse = queue.BatchReceiveMessage(16);
+                    if (batchReceiveMessageResponse != null)
+                    {
+                        List<Message> messages = batchReceiveMessageResponse.Messages;
+                        foreach (var msg in messages)
+                        {
+                            try
+                            {
+                                byte[] outputb = Convert.FromBase64String(msg.Body);
+                                string orgStr = Encoding.UTF8.GetString(outputb);
+                                System.Console.WriteLine(orgStr);
+                                ////TODO 具体消费逻辑,待客户自己实现.
+
+                                //var orgmodel = JObject.Parse(orgStr.Replace("&nbsp;", ""));
+                                //if (orgmodel["success"].ToString().ToLower() != "true")
+                                //{
+                                //    var sendliststr = redisCache.GetString("T_Sms_Send");
+                                //    var sendlist = new List<T_Sms_Send>();
+                                //    if (!string.IsNullOrEmpty(sendliststr))
+                                //    {
+                                //        sendlist = JsonConvert.DeserializeObject<List<T_Sms_Send>>(sendliststr);
+                                //    }
+                                //    var send = new T_Sms_Send();
+                                //    send.Id = sendlist.Count > 0 ? sendlist.Max(p => p.Id) + 1 : 1;
+                                //    send.BizId = orgmodel["biz_id"].ToString();
+                                //    send.PhoneNumber = orgmodel["phone_number"].ToString();
+                                //    send.SendTime = DateTime.Now;
+                                //    send.ReportTime = DateTime.Parse(orgmodel["report_time"].ToString());
+                                //    send.SendTime= DateTime.Parse(orgmodel["send_time"].ToString());
+                                //    send.SmsSize = Int32.Parse(orgmodel["sms_size"].ToString());
+                                //    send.State = 2;
+                                //    send.ErrCode= orgmodel["err_code"].ToString();
+                                //    send.ErrMsg = orgmodel["err_msg"].ToString();
+                                //    sendlist.Add(send);
+
+                                //    var timeConverter = new IsoDateTimeConverter { DateTimeFormat = "yyyy-MM-dd HH:mm:ss" };
+                                //    redisCache.SetString("T_Sms_Send", JsonConvert.SerializeObject(sendlist, timeConverter));
+                                //}
+
+                                //消费成功的前提下删除消息
+                                queue.DeleteMessage(msg.ReceiptHandle);
+                            }
+                            catch (Exception e)
+                            {
+                                System.Console.WriteLine("exception:" + e.Message.ToString());
+                            }
+                        }
+                    }
+                }
+                catch (Exception e)
+                {
+                    System.Console.WriteLine("Handle exception:" + e.Message.ToString());
+                }
+                Thread.Sleep(sleepTime);
+            }
+        }
+
+        public QueryTokenForMnsQueueResponse.QueryTokenForMnsQueue_MessageTokenDTO GetTokenByMessageType(IAcsClient acsClient, String messageType)
+        {
+            QueryTokenForMnsQueueRequest request = new QueryTokenForMnsQueueRequest();
+            request.MessageType = messageType;
+            QueryTokenForMnsQueueResponse queryTokenForMnsQueueResponse = acsClient.GetAcsResponse(request);
+            QueryTokenForMnsQueueResponse.QueryTokenForMnsQueue_MessageTokenDTO token = queryTokenForMnsQueueResponse.MessageTokenDTO;
+            return token;
+        }
+
+
+        /// <summary>
+        /// 消息类
+        /// </summary>
+        public partial class T_Sms_Send
+        {
+            public T_Sms_Send()
+            { }
+            #region Model
+            private int _id;
+            private string _phonenumber;
+            private string _bizid;
+            private DateTime? _sendtime;
+            private DateTime? _reporttime;
+            private int _state;
+            private string _errcode;
+            private string _errmsg;
+            private int _smssize;
+            /// <summary>
+            /// 自增id
+            /// </summary>
+            public int Id
+            {
+                set { _id = value; }
+                get { return _id; }
+            }
+            /// <summary>
+            /// 手机号码
+            /// </summary>
+            public string PhoneNumber
+            {
+                set { _phonenumber = value; }
+                get { return _phonenumber; }
+            }
+            /// <summary>
+            /// 发送回执ID
+            /// </summary>
+            public string BizId
+            {
+                set { _bizid = value; }
+                get { return _bizid; }
+            }
+            /// <summary>
+            /// 发送时间
+            /// </summary>
+            public DateTime? SendTime
+            {
+                set { _sendtime = value; }
+                get { return _sendtime; }
+            }
+            /// <summary>
+            /// 回执时间
+            /// </summary>
+            public DateTime? ReportTime
+            {
+                set { _reporttime = value; }
+                get { return _reporttime; }
+            }
+            /// <summary>
+            /// 发送状态 1：等待回执，2：发送失败，3：发送成功
+            /// </summary>
+            public int State
+            {
+                set { _state = value; }
+                get { return _state; }
+            }
+            /// <summary>
+            /// 错误码
+            /// </summary>
+            public string ErrCode
+            {
+                set { _errcode = value; }
+                get { return _errcode; }
+            }
+            /// <summary>
+            /// 错误信息
+            /// </summary>
+            public string ErrMsg
+            {
+                set { _errmsg = value; }
+                get { return _errmsg; }
+            }
+            /// <summary>
+            /// 	短信大小--140字节算一条短信，短信长度超过140字节时会拆分成多条短信发送
+            /// </summary>
+            public int SmsSize
+            {
+                set { _smssize = value; }
+                get { return _smssize; }
+            }
+            #endregion Model
+
+        }
+    }
+}

SmsReceive/SmsReceive.csproj

@@ -0,0 +1,35 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>netcoreapp2.1</TargetFramework>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.Extensions.Caching.Redis" Version="2.2.0" />
+    <PackageReference Include="Microsoft.Extensions.Configuration" Version="2.2.0" />
+    <PackageReference Include="Microsoft.Extensions.Configuration.Json" Version="2.2.0" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <Reference Include="aliyun-net-sdk-core">
+      <HintPath>dll\aliyun-net-sdk-core.dll</HintPath>
+    </Reference>
+    <Reference Include="aliyun-net-sdk-dybaseapi">
+      <HintPath>dll\aliyun-net-sdk-dybaseapi.dll</HintPath>
+    </Reference>
+    <Reference Include="aliyun-net-sdk-dysmsapi">
+      <HintPath>dll\aliyun-net-sdk-dysmsapi.dll</HintPath>
+    </Reference>
+    <Reference Include="Aliyun.MNS">
+      <HintPath>dll\Aliyun.MNS.dll</HintPath>
+    </Reference>
+  </ItemGroup>
+
+  <ItemGroup>
+    <None Update="config.json">
+      <CopyToOutputDirectory>Always</CopyToOutputDirectory>
+    </None>
+  </ItemGroup>
+
+</Project>

SmsReceive/config.json

@@ -0,0 +1,30 @@
+{
+  "Logging": {
+    "IncludeScopes": false,
+    "LogLevel": {
+      "Default": "Debug",
+      "System": "Error",
+      "Microsoft": "Error",
+      "Steeltoe": "Error"
+    }
+  },
+  "Redis": {
+    "HostName": "139.224.236.21",
+    "Port": "4000",
+    "Password": "sms+800100",
+    "Defaultdatabase": "15",
+    "InstanceName": "sms"
+  },
+  "amount": 0.08,
+  "Dysms": {
+    "product": "Dybaseapi",
+    "domain": "dybaseapi.aliyuncs.com",
+    "accesskeyid": "LTAIICc6dV9MdBHK",
+    "accesskeysecret": "Ed5qMOJIp4QMMERpmMr48Zpu0BTcTN",
+    "messagetype": "SmsReport", //消息类型目前有4种. 短信回执:SmsReport; 短信上行:SmsUp; 语音回执:VoiceReport; 流量回执:FlowReport;
+    "queuename": "Alicom-Queue-1751140347246528-SmsReport",
+    "regionid": "cn-hangzhou",
+    "maxthread": 2,
+    "mnsaccountendpoint": "https://1943695596114318.mns.cn-hangzhou.aliyuncs.com/"
+  }
+}