365 lines
14 KiB
C#
365 lines
14 KiB
C#
/***********************************************************************
|
||
* Project: CoreCms
|
||
* ProjectName: 核心内容管理系统
|
||
* Web: https://www.corecms.net
|
||
* Author: 大灰灰
|
||
* Email: jianweie@163.com
|
||
* CreateTime: 2021/1/31 21:45:10
|
||
* Description: 暂无
|
||
***********************************************************************/
|
||
|
||
using System;
|
||
using System.Threading.Tasks;
|
||
using CoreCms.Net.Configuration;
|
||
using CoreCms.Net.IRepository;
|
||
using CoreCms.Net.IRepository.UnitOfWork;
|
||
using CoreCms.Net.IServices;
|
||
using CoreCms.Net.Loging;
|
||
using CoreCms.Net.Model.Entities;
|
||
using CoreCms.Net.Model.ViewModels.Sms;
|
||
using CoreCms.Net.Model.ViewModels.UI;
|
||
using CoreCms.Net.Utility.Extensions;
|
||
using CoreCms.Net.Utility.Helper;
|
||
using Microsoft.AspNetCore.Http;
|
||
using Microsoft.Extensions.Options;
|
||
using Newtonsoft.Json;
|
||
using Newtonsoft.Json.Linq;
|
||
using SqlSugar;
|
||
|
||
|
||
namespace CoreCms.Net.Services
|
||
{
|
||
/// <summary>
|
||
/// 短信发送日志 接口实现
|
||
/// </summary>
|
||
public class CoreCmsSmsServices : BaseServices<CoreCmsSms>, ICoreCmsSmsServices
|
||
{
|
||
private readonly ICoreCmsSmsRepository _dal;
|
||
private readonly ICoreCmsSettingServices _settingServices;
|
||
private readonly IUnitOfWork _unitOfWork;
|
||
|
||
private readonly IHttpContextAccessor _httpContextAccessor;
|
||
|
||
public CoreCmsSmsServices(IUnitOfWork unitOfWork
|
||
, ICoreCmsSmsRepository dal
|
||
, IHttpContextAccessor httpContextAccessor, ICoreCmsSettingServices settingServices)
|
||
{
|
||
this._dal = dal;
|
||
base.BaseDal = dal;
|
||
_unitOfWork = unitOfWork;
|
||
|
||
_httpContextAccessor = httpContextAccessor;
|
||
_settingServices = settingServices;
|
||
}
|
||
|
||
|
||
|
||
|
||
#region 发送短信（验证码）
|
||
|
||
/// <summary>
|
||
/// 发送短信（验证码）
|
||
/// </summary>
|
||
/// <param name="type"></param>
|
||
/// <param name="mobile"></param>
|
||
/// <returns></returns>
|
||
public async Task<WebApiCallBack> DoSendSms(string type, string mobile)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
var smsOptions = await _settingServices.GetSmsOptions();
|
||
if (smsOptions.Enabled == false)
|
||
{
|
||
jm.msg = "短信功能未开启";
|
||
return jm;
|
||
}
|
||
|
||
Random rd = new Random();
|
||
int codeNumber = rd.Next(100000, 999999);
|
||
|
||
//获取是否存在
|
||
var dt = DateTime.Now;
|
||
var endDt = dt.AddMinutes(10);
|
||
|
||
var oldLog = await _dal.QueryByClauseAsync(p => p.code == type && p.mobile == mobile && p.createTime > dt && p.createTime < endDt, p => p.id, OrderByType.Desc);
|
||
if (oldLog == null)
|
||
{
|
||
oldLog = new CoreCmsSms();
|
||
oldLog.code = type;
|
||
oldLog.createTime = DateTime.Now;
|
||
oldLog.mobile = mobile;
|
||
oldLog.ip = _httpContextAccessor.HttpContext?.Connection.RemoteIpAddress != null ? _httpContextAccessor.HttpContext.Connection.RemoteIpAddress.MapToIPv4().ToString() : "127.0.0.1";
|
||
oldLog.isUsed = false;
|
||
var obj = new
|
||
{
|
||
code = codeNumber
|
||
};
|
||
switch (type)
|
||
{
|
||
case "login":
|
||
oldLog.contentBody = "您本次登陆的验证码是：" + codeNumber + "，请不要将验证码泄露给他人！";
|
||
oldLog.parameters = JsonConvert.SerializeObject(obj);
|
||
break;
|
||
default:
|
||
oldLog.contentBody = "您验证码是：" + codeNumber + "，请不要将验证码泄露给他人！";
|
||
oldLog.parameters = JsonConvert.SerializeObject(obj);
|
||
break;
|
||
}
|
||
await _dal.InsertAsync(oldLog);
|
||
}
|
||
|
||
var str = SendSms(oldLog.mobile, oldLog.contentBody, smsOptions);
|
||
jm.status = true;
|
||
jm.data = str;
|
||
jm.msg = "短信发送成功";
|
||
|
||
return jm;
|
||
}
|
||
#endregion
|
||
|
||
#region 校验短信验证码
|
||
/// <summary>
|
||
/// 校验短信验证码
|
||
/// </summary>
|
||
/// <param name="phone"></param>
|
||
/// <param name="verCode"></param>
|
||
/// <param name="code"></param>
|
||
/// <returns></returns>
|
||
|
||
public async Task<bool> Check(string phone, string verCode, string code)
|
||
{
|
||
var smsInfo = await _dal.QueryByClauseAsync(p =>
|
||
p.mobile == phone && p.code == code && p.createTime < DateTime.Now && p.isUsed == false, p => p.createTime, OrderByType.Desc);
|
||
if (smsInfo != null)
|
||
{
|
||
var parameters = JObject.Parse(smsInfo.parameters);
|
||
if (parameters.ContainsKey("code"))
|
||
{
|
||
var dataCode = parameters["code"]?.ToString();
|
||
if (dataCode != verCode) return false;
|
||
smsInfo.isUsed = true;
|
||
await _dal.UpdateAsync(smsInfo);
|
||
return true;
|
||
}
|
||
return false;
|
||
}
|
||
return false;
|
||
}
|
||
#endregion
|
||
|
||
#region 接口通道发送短信
|
||
|
||
/// <summary>
|
||
/// 接口通道发送短信
|
||
/// </summary>
|
||
/// <param name="mobile"></param>
|
||
/// <param name="contentBody"></param>
|
||
/// <param name="smsOptions">配置文件</param>
|
||
public string SendSms(string mobile, string contentBody, SMSOptions smsOptions)
|
||
{
|
||
if (smsOptions.Enabled)
|
||
{
|
||
string param = $@"action=send&userid={smsOptions.UserId}&account={smsOptions.Account}&password={smsOptions.Password}&content={"【" + smsOptions.Signature + "】" + contentBody}&mobile={mobile}";
|
||
var str = HttpHelper.PostSend(smsOptions.ApiUrl, param);
|
||
return str;
|
||
}
|
||
else
|
||
{
|
||
return "短信接口未开启";
|
||
}
|
||
}
|
||
#endregion
|
||
|
||
#region 发送短信统一方法
|
||
/// <summary>
|
||
/// 发送短信统一方法
|
||
/// </summary>
|
||
/// <param name="mobile">接受者手机号码</param>
|
||
/// <param name="code">模板编码</param>
|
||
/// <param name="parameters">参数</param>
|
||
/// <returns></returns>
|
||
public async Task<WebApiCallBack> Send(string mobile, string code, JObject parameters)
|
||
{
|
||
var jm = new WebApiCallBack();
|
||
var smsOptions = await _settingServices.GetSmsOptions();
|
||
if (smsOptions.Enabled == false)
|
||
{
|
||
jm.msg = "短信功能未开启";
|
||
return jm;
|
||
}
|
||
|
||
if (string.IsNullOrEmpty(mobile))
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code11051;
|
||
return jm;
|
||
}
|
||
var isUsed = false;
|
||
if (code == GlobalEnumVars.SmsMessageTypes.Reg.ToString() || code == GlobalEnumVars.SmsMessageTypes.Login.ToString() || code == GlobalEnumVars.SmsMessageTypes.Veri.ToString())
|
||
{
|
||
var dt = DateTime.Now;
|
||
var newCreateTime = DateTime.Now.AddSeconds(-60);
|
||
var smsInfo = await _dal.QueryByClauseAsync(p =>
|
||
p.mobile == mobile && p.code == code && p.createTime < newCreateTime && p.isUsed == false);
|
||
if (smsInfo != null)
|
||
{
|
||
var ts = dt - smsInfo.createTime;
|
||
if (ts.Seconds < 60)
|
||
{
|
||
jm.msg = "两次发送时间间隔小于60秒";
|
||
return jm;
|
||
}
|
||
parameters = JObject.Parse(smsInfo.parameters); ;
|
||
}
|
||
else
|
||
{
|
||
Random rd = new Random();
|
||
int codeNumber = rd.Next(100000, 999999);
|
||
if (parameters.ContainsKey("code"))
|
||
{
|
||
parameters.Remove("code");
|
||
}
|
||
parameters.Add("code", codeNumber);
|
||
}
|
||
isUsed = false;
|
||
}
|
||
else
|
||
{
|
||
isUsed = true;
|
||
}
|
||
|
||
|
||
var str = string.Empty;
|
||
var allConfigs = await _settingServices.GetConfigDictionaries();
|
||
|
||
if (code == GlobalEnumVars.SmsMessageTypes.Reg.ToString())
|
||
{
|
||
// 账户注册
|
||
var msg = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SmsTplForReg);
|
||
if (!string.IsNullOrEmpty(msg))
|
||
{
|
||
var sendCode = string.Empty;
|
||
if (parameters.ContainsKey("code"))
|
||
{
|
||
sendCode = parameters["code"]?.ToString();
|
||
}
|
||
str = msg.Replace("{code}", sendCode);
|
||
}
|
||
}
|
||
else if (code == GlobalEnumVars.SmsMessageTypes.Login.ToString())
|
||
{
|
||
// 账户登录
|
||
var msg = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SmsTplForLogin);
|
||
if (!string.IsNullOrEmpty(msg))
|
||
{
|
||
var sendCode = string.Empty;
|
||
if (parameters.ContainsKey("code"))
|
||
{
|
||
sendCode = parameters["code"]?.ToString();
|
||
}
|
||
str = msg.Replace("{code}", sendCode);
|
||
}
|
||
}
|
||
else if (code == GlobalEnumVars.SmsMessageTypes.Veri.ToString())
|
||
{
|
||
// 验证验证码
|
||
var msg = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SmsTplForVeri);
|
||
if (!string.IsNullOrEmpty(msg))
|
||
{
|
||
var sendCode = string.Empty;
|
||
if (parameters.ContainsKey("code"))
|
||
{
|
||
sendCode = parameters["code"]?.ToString();
|
||
}
|
||
str = msg.Replace("{code}", sendCode);
|
||
}
|
||
}
|
||
else if (code == GlobalEnumVars.PlatformMessageTypes.CreateOrder.ToString())
|
||
{
|
||
// 订单创建
|
||
var msg = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SmsTplForCreateOrder);
|
||
str = !string.IsNullOrEmpty(msg) ? msg : string.Empty;
|
||
}
|
||
else if (code == GlobalEnumVars.PlatformMessageTypes.OrderPayed.ToString())
|
||
{
|
||
// 订单支付通知买家
|
||
var msg = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SmsTplForOrderPayed);
|
||
str = !string.IsNullOrEmpty(msg) ? msg : string.Empty;
|
||
}
|
||
else if (code == GlobalEnumVars.PlatformMessageTypes.RemindOrderPay.ToString())
|
||
{
|
||
// 未支付催单
|
||
var msg = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SmsTplForRemindOrderPay);
|
||
str = !string.IsNullOrEmpty(msg) ? msg : string.Empty;
|
||
}
|
||
else if (code == GlobalEnumVars.PlatformMessageTypes.DeliveryNotice.ToString())
|
||
{
|
||
// 订单发货
|
||
var msg = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SmsTplForDeliveryNotice);
|
||
str = !string.IsNullOrEmpty(msg) ? msg : string.Empty;
|
||
}
|
||
else if (code == GlobalEnumVars.PlatformMessageTypes.AfterSalesPass.ToString())
|
||
{
|
||
// 售后审核通过
|
||
var msg = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SmsTplForAfterSalesPass);
|
||
str = !string.IsNullOrEmpty(msg) ? msg : string.Empty;
|
||
}
|
||
else if (code == GlobalEnumVars.PlatformMessageTypes.RefundSuccess.ToString())
|
||
{
|
||
// 退款已处理
|
||
var msg = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SmsTplForRefundSuccess);
|
||
str = !string.IsNullOrEmpty(msg) ? msg : string.Empty;
|
||
}
|
||
else if (code == GlobalEnumVars.PlatformMessageTypes.SellerOrderNotice.ToString())
|
||
{
|
||
// 订单支付通知卖家
|
||
var msg = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SmsTplForSellerOrderNotice);
|
||
str = !string.IsNullOrEmpty(msg) ? msg : string.Empty;
|
||
}
|
||
else if (code == GlobalEnumVars.PlatformMessageTypes.Common.ToString())
|
||
{
|
||
//通用类型
|
||
var tpl = string.Empty;
|
||
if (parameters.ContainsKey("tpl"))
|
||
{
|
||
tpl = parameters["tpl"]?.ToString();
|
||
}
|
||
str = tpl;
|
||
if (!string.IsNullOrEmpty(str))
|
||
{
|
||
var msg = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.SmsTplForCommon);
|
||
str = !string.IsNullOrEmpty(msg) ? msg : string.Empty;
|
||
}
|
||
}
|
||
|
||
if (string.IsNullOrEmpty(str))
|
||
{
|
||
jm.msg = GlobalErrorCodeVars.Code10009;
|
||
return jm;
|
||
}
|
||
|
||
var oldLog = new CoreCmsSms();
|
||
oldLog.mobile = mobile;
|
||
oldLog.code = code;
|
||
oldLog.parameters = JsonConvert.SerializeObject(parameters);
|
||
oldLog.contentBody = str;
|
||
oldLog.createTime = DateTime.Now;
|
||
oldLog.ip = _httpContextAccessor.HttpContext?.Connection.RemoteIpAddress != null ?
|
||
_httpContextAccessor.HttpContext.Connection.RemoteIpAddress.MapToIPv4().ToString() : "127.0.0.1";
|
||
oldLog.isUsed = isUsed;
|
||
|
||
await _dal.InsertAsync(oldLog);
|
||
|
||
var result = SendSms(oldLog.mobile, oldLog.contentBody, smsOptions);
|
||
|
||
jm.status = true;
|
||
jm.msg = "发送成功";
|
||
jm.data = result;
|
||
|
||
return jm;
|
||
}
|
||
|
||
#endregion
|
||
|
||
|
||
}
|
||
}
|