using System;
|
using System.Collections.Concurrent;
|
using System.Collections.Generic;
|
using System.Threading.Tasks;
|
using CoreCms.Net.Caching.AccressToken;
|
using CoreCms.Net.Model;
|
using CoreCms.Net.Model.FromBody;
|
using CoreCms.Net.WeChat.Service.Enums;
|
using CoreCms.Net.WeChat.Service.HttpClients;
|
using CoreCms.Net.WeChat.Service.Options;
|
using Microsoft.AspNetCore.Authorization;
|
using Microsoft.AspNetCore.Http;
|
using Microsoft.AspNetCore.Mvc;
|
using Microsoft.Extensions.Options;
|
using SKIT.FlurlHttpClient.Wechat.Api;
|
using SKIT.FlurlHttpClient.Wechat.Api.Models;
|
|
namespace CoreCms.Net.Web.WebApi.Controllers
|
{
|
/// <summary>
|
/// 微信公众号通用接口
|
/// </summary>
|
[Route("api/[controller]/[action]")]
|
[ApiController]
|
public class WeChatOffiaccountController : ControllerBase
|
{
|
private readonly IWeChatApiHttpClientFactory _weChatApiHttpClientFactory;
|
private readonly WeChatOptions _weChatOptions;
|
|
/// <summary>
|
/// 构造函数
|
/// </summary>
|
/// <param name="weChatOptions"></param>
|
/// <param name="weChatApiHttpClientFactory"></param>
|
public WeChatOffiaccountController(IOptions<WeChatOptions> weChatOptions, IWeChatApiHttpClientFactory weChatApiHttpClientFactory)
|
{
|
_weChatApiHttpClientFactory = weChatApiHttpClientFactory;
|
_weChatOptions = weChatOptions.Value;
|
}
|
|
|
/// <summary>
|
/// JS-SDK使用权限签名算法
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost]
|
//[Authorize]
|
public IActionResult GetWeChatConfig(FMGetWeChatConfig entity)
|
{
|
//获取全局缓存的jsapi_ticket
|
var jsApiTicket = WeChatCacheAccessTokenHelper.GetWeChatJsApiTicket();
|
var nonceStr = CoreCms.Net.Utility.Helper.CommonHelper.GetSerialNumber();
|
var timestamp = CoreCms.Net.Utility.Helper.CommonHelper.GetTimeStampByTotalSeconds().ToString();
|
//var url = Request.GetTypedHeaders().Referer;
|
//获取前面
|
var signatureStr = "jsapi_ticket=" + jsApiTicket + "&noncestr=" + nonceStr + "×tamp=" + timestamp + "&url=" + entity.url;
|
var signature = CoreCms.Net.Utility.Helper.CommonHelper.Sha1Signature(signatureStr);
|
|
return new JsonResult(new
|
{
|
jsApiTicket,
|
appId = _weChatOptions.WeiXinAppId,
|
timestamp,
|
nonceStr,
|
signature,
|
entity.url,
|
entity
|
});
|
}
|
|
/// <summary>
|
/// 通用发送模板消息方法
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
[HttpPost]
|
public async Task<ActionResult> Send(TmpMsgModel model)
|
{
|
try
|
{
|
var client = _weChatApiHttpClientFactory.CreateWeXinClient();
|
var accessToken = WeChatCacheAccessTokenHelper.GetWeChatAccessToken();
|
var request = new CgibinMessageTemplateSendRequest
|
{
|
AccessToken = accessToken,
|
ToUserOpenId = model.OpenId,
|
TemplateId = model.TemplateId,
|
MiniProgram = null,
|
Data = new ConcurrentDictionary<string, CgibinMessageTemplateSendRequest.Types.DataItem>()
|
};
|
|
if (!string.IsNullOrEmpty(model.Url))
|
{
|
request.Url = model.Url;
|
}
|
|
const string color = "#CCC";
|
|
if (!string.IsNullOrEmpty(model.First))
|
{
|
request.Data.Add(new KeyValuePair<string, CgibinMessageTemplateSendRequest.Types.DataItem>("first", new CgibinMessageTemplateSendRequest.Types.DataItem() { Color = color, Value = model.First }));
|
}
|
if (!string.IsNullOrEmpty(model.Keyword1))
|
{
|
request.Data.Add(new KeyValuePair<string, CgibinMessageTemplateSendRequest.Types.DataItem>("keyword1", new CgibinMessageTemplateSendRequest.Types.DataItem() { Color = color, Value = model.Keyword1 }));
|
}
|
if (!string.IsNullOrEmpty(model.Keyword2))
|
{
|
request.Data.Add(new KeyValuePair<string, CgibinMessageTemplateSendRequest.Types.DataItem>("keyword2", new CgibinMessageTemplateSendRequest.Types.DataItem() { Color = color, Value = model.Keyword2 }));
|
}
|
if (!string.IsNullOrEmpty(model.Keyword3))
|
{
|
request.Data.Add(new KeyValuePair<string, CgibinMessageTemplateSendRequest.Types.DataItem>("keyword3", new CgibinMessageTemplateSendRequest.Types.DataItem() { Color = color, Value = model.Keyword3 }));
|
}
|
if (!string.IsNullOrEmpty(model.Keyword4))
|
{
|
request.Data.Add(new KeyValuePair<string, CgibinMessageTemplateSendRequest.Types.DataItem>("keyword4", new CgibinMessageTemplateSendRequest.Types.DataItem() { Color = color, Value = model.Keyword4 }));
|
}
|
if (!string.IsNullOrEmpty(model.Keyword5))
|
{
|
request.Data.Add(new KeyValuePair<string, CgibinMessageTemplateSendRequest.Types.DataItem>("keyword5", new CgibinMessageTemplateSendRequest.Types.DataItem() { Color = color, Value = model.Keyword5 }));
|
}
|
if (!string.IsNullOrEmpty(model.Keyword6))
|
{
|
request.Data.Add(new KeyValuePair<string, CgibinMessageTemplateSendRequest.Types.DataItem>("keyword6", new CgibinMessageTemplateSendRequest.Types.DataItem() { Color = color, Value = model.Keyword6 }));
|
}
|
if (!string.IsNullOrEmpty(model.Keyword7))
|
{
|
request.Data.Add(new KeyValuePair<string, CgibinMessageTemplateSendRequest.Types.DataItem>("keyword7", new CgibinMessageTemplateSendRequest.Types.DataItem() { Color = color, Value = model.Keyword7 }));
|
}
|
if (!string.IsNullOrEmpty(model.Keyword8))
|
{
|
request.Data.Add(new KeyValuePair<string, CgibinMessageTemplateSendRequest.Types.DataItem>("keyword8", new CgibinMessageTemplateSendRequest.Types.DataItem() { Color = color, Value = model.Keyword8 }));
|
}
|
if (!string.IsNullOrEmpty(model.Keyword9))
|
{
|
request.Data.Add(new KeyValuePair<string, CgibinMessageTemplateSendRequest.Types.DataItem>("keyword9", new CgibinMessageTemplateSendRequest.Types.DataItem() { Color = color, Value = model.Keyword9 }));
|
}
|
if (!string.IsNullOrEmpty(model.Keyword10))
|
{
|
request.Data.Add(new KeyValuePair<string, CgibinMessageTemplateSendRequest.Types.DataItem>("keyword10", new CgibinMessageTemplateSendRequest.Types.DataItem() { Color = color, Value = model.Keyword10 }));
|
}
|
if (!string.IsNullOrEmpty(model.Remark))
|
{
|
request.Data.Add(new KeyValuePair<string, CgibinMessageTemplateSendRequest.Types.DataItem>("remark", new CgibinMessageTemplateSendRequest.Types.DataItem() { Color = color, Value = model.Remark }));
|
}
|
|
var response = await client.ExecuteCgibinMessageTemplateSendAsync(request, HttpContext.RequestAborted);
|
return response.ErrorCode != (int)WeChatReturnCode.ReturnCode.请求成功
|
? new JsonResult(new { ResultCode = "1", Msg = "错误：" + response.ErrorMessage })
|
: new JsonResult(new { ResultCode = "0", Msg = "已发送成功", Data = response.MessageId });
|
}
|
catch (Exception ex)
|
{
|
return new JsonResult(new { ResultCode = "1", Msg = ex.ToString() });
|
}
|
}
|
|
|
}
|
}
|
