/***********************************************************************
|
* Project: baifenBinfa
|
* ProjectName: 百分兵法管理系统
|
* Web: http://chuanyin.com
|
* Author:
|
* Email:
|
* CreateTime: 202403/02
|
* Description: 暂无
|
***********************************************************************/
|
|
using System;
|
using System.Threading.Tasks;
|
using CoreCms.Net.Caching.AutoMate.RedisCache;
|
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.UI;
|
using CoreCms.Net.Utility.Extensions;
|
using CoreCms.Net.Utility.Helper;
|
using Microsoft.Extensions.DependencyInjection;
|
using Newtonsoft.Json;
|
using Newtonsoft.Json.Linq;
|
using NLog;
|
|
|
namespace CoreCms.Net.Services
|
{
|
/// <summary>
|
/// 消息配置表 接口实现
|
/// </summary>
|
public class CoreCmsMessageCenterServices : BaseServices<CoreCmsMessageCenter>, ICoreCmsMessageCenterServices
|
{
|
private readonly ICoreCmsMessageCenterRepository _dal;
|
|
private readonly IServiceProvider _serviceProvider;
|
private readonly IRedisOperationRepository _redisOperationRepository;
|
|
|
private readonly IUnitOfWork _unitOfWork;
|
public CoreCmsMessageCenterServices(IUnitOfWork unitOfWork, ICoreCmsMessageCenterRepository dal, IServiceProvider serviceProvider, ISysTaskLogServices taskLogServices, IRedisOperationRepository redisOperationRepository)
|
{
|
this._dal = dal;
|
_serviceProvider = serviceProvider;
|
_redisOperationRepository = redisOperationRepository;
|
base.BaseDal = dal;
|
_unitOfWork = unitOfWork;
|
}
|
|
|
/// <summary>
|
/// 商家发送信息助手
|
/// </summary>
|
/// <param name="userId">接受者id</param>
|
/// <param name="code">模板编码</param>
|
/// <param name="parameters">参数</param>
|
/// <returns></returns>
|
public async Task<WebApiCallBack> SendMessage(int userId, string code, JObject parameters)
|
{
|
try
|
{
|
var jm = new WebApiCallBack();
|
|
using var container = _serviceProvider.CreateScope();
|
|
var userServices = container.ServiceProvider.GetService<ICoreCmsUserServices>();
|
var settingServices = container.ServiceProvider.GetService<ICoreCmsSettingServices>();
|
var smsServices = container.ServiceProvider.GetService<ICoreCmsSmsServices>();
|
var messageServices = container.ServiceProvider.GetService<ICoreCmsMessageServices>();
|
var allConfigs = await settingServices.GetConfigDictionaries();
|
|
var config = await _dal.QueryByClauseAsync(p => p.code == code);
|
if (config == null)
|
{
|
jm.msg = GlobalErrorCodeVars.Code10100;
|
return jm;
|
}
|
if (config.isSms)
|
{
|
//判断短信是否够,如果够，就去发
|
var user = await userServices.QueryByClauseAsync(p => p.id == userId);
|
if (user != null && !string.IsNullOrEmpty(user.mobile))
|
{
|
var mobile = user.mobile;
|
//判断是否平台通知
|
if (code == GlobalEnumVars.PlatformMessageTypes.SellerOrderNotice.ToString())
|
{
|
mobile = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.ShopMobile);
|
}
|
//发货时，短信通知用发货人的
|
if (code == GlobalEnumVars.PlatformMessageTypes.DeliveryNotice.ToString())
|
{
|
if (parameters.ContainsKey("shipMobile"))
|
{
|
mobile = parameters["shipMobile"].ObjectToString();
|
}
|
}
|
if (!string.IsNullOrEmpty(mobile))
|
{
|
await smsServices.Send(mobile, code, parameters);
|
}
|
}
|
}
|
//站内消息
|
if (config.isMessage && code != GlobalEnumVars.PlatformMessageTypes.SellerOrderNotice.ToString())
|
{
|
await messageServices.Send(userId, code, parameters);
|
}
|
//微信模板消息【小程序，公众号都走这里】
|
if (config.isWxTempletMessage &&
|
(code == GlobalEnumVars.PlatformMessageTypes.OrderPayed.ToString() || code == GlobalEnumVars.PlatformMessageTypes.DeliveryNotice.ToString() || code == GlobalEnumVars.PlatformMessageTypes.RemindOrderPay.ToString()))
|
{
|
var @params = new JObject();
|
@params.Add("parameters", parameters);
|
|
var data = new
|
{
|
userId,
|
code,
|
parameters = @params
|
};
|
|
//队列推送消息
|
await _redisOperationRepository.ListLeftPushAsync(RedisMessageQueueKey.SendWxTemplateMessage, JsonConvert.SerializeObject(data));
|
|
}
|
jm.status = true;
|
return jm;
|
}
|
catch (Exception ex)
|
{
|
NLogUtil.WriteAll(LogLevel.Trace, LogType.RefundResultNotification, "商家发送信息助手", JsonConvert.SerializeObject(ex));
|
throw;
|
}
|
}
|
|
}
|
}
|
