SmsPlatform/SmsPlatform/Common/SmsHelper.cs

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;
        }
    }
}