65 lines
1.9 KiB
C#
65 lines
1.9 KiB
C#
using ARW.Admin.WebApi.Filters;
|
|
using Infrastructure.WeChat.TenPay;
|
|
using Infrastructure;
|
|
using Microsoft.AspNetCore.Http;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
using static Infrastructure.WeChat.TenPay.Pay;
|
|
using System.Net.Http;
|
|
using ARW.Admin.WebApi.Controllers;
|
|
using Infrastructure.WeChat.SubScribe;
|
|
using Senparc.Weixin.Entities.TemplateMessage;
|
|
using ARW.Model.Models.Business.SubscribeTasks;
|
|
using ARW.Admin.WebApi.Framework;
|
|
using ARW.Service.Business.IBusinessService.SubscribeTasks;
|
|
using Mapster;
|
|
using ARW.Admin.WebApi.Extensions;
|
|
|
|
namespace ARW.WebApi.Controllers.Api.Wechat.WxSubscribe
|
|
{
|
|
|
|
[Route("api/[controller]")]
|
|
//[Verify]
|
|
public class WxSubscribeController : BaseController
|
|
{
|
|
|
|
private readonly ISubscribeTaskService _SubscribeTaskService;
|
|
|
|
/// <summary>
|
|
/// 依赖注入
|
|
/// </summary>
|
|
/// <param name="SubscribeTaskService">订阅推送任务订阅推送任务服务</param>
|
|
public WxSubscribeController(ISubscribeTaskService SubscribeTaskService)
|
|
{
|
|
_SubscribeTaskService = SubscribeTaskService;
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 添加微信推送任务
|
|
/// </summary>
|
|
/// <param name="parm"></param>
|
|
/// <returns></returns>
|
|
[HttpPost("pushWxSubscribe")]
|
|
public async Task<IActionResult> PushWxSubscribe([FromBody] SubscribeTask parm)
|
|
{
|
|
if (parm == null) { throw new CustomException("请求参数错误"); }
|
|
|
|
//var templateId = parm.TemplateId;
|
|
//var user = JwtUtil.GetLoginUser(App.HttpContext);
|
|
//parm.CustomerGuid = user.UserId;
|
|
parm.CustomerGuid = 1600478763014033408;
|
|
parm.SubscribeTaskStatus = 0;
|
|
|
|
var addModal = parm.Adapt<SubscribeTask>().ToCreate(HttpContext);
|
|
|
|
var response = _SubscribeTaskService.InsertReturnSnowflakeIdAsync(addModal);
|
|
return SUCCESS("添加成功！");
|
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|