committed by
GitHub
19 changed files with 103 additions and 39 deletions
@ -1,10 +1,12 @@ |
|||||
using LINGYUN.Abp.WeChat.Official.Models; |
using LINGYUN.Abp.WeChat.Official.Models; |
||||
using System; |
using System; |
||||
|
using Volo.Abp.Auditing; |
||||
|
|
||||
namespace LINGYUN.Abp.WeChat.Official.Message; |
namespace LINGYUN.Abp.WeChat.Official.Message; |
||||
|
|
||||
[Serializable] |
[Serializable] |
||||
public class MessageHandleInput : WeChatMessage |
public class MessageHandleInput : WeChatMessage |
||||
{ |
{ |
||||
|
[DisableAuditing] |
||||
public string Data { get; set; } |
public string Data { get; set; } |
||||
} |
} |
||||
|
|||||
@ -0,0 +1,18 @@ |
|||||
|
using LINGYUN.Abp.WeChat.Common.Messages; |
||||
|
using System.Threading.Tasks; |
||||
|
|
||||
|
namespace LINGYUN.Abp.WeChat.Official.Messages; |
||||
|
public abstract class WeChatOfficialMessageResolveContributorBase : MessageResolveContributorBase |
||||
|
{ |
||||
|
public override Task ResolveAsync(IMessageResolveContext context) |
||||
|
{ |
||||
|
if (!context.HasMessageKey("AgentID")) |
||||
|
{ |
||||
|
return ResolveWeChatMessageAsync(context); |
||||
|
} |
||||
|
|
||||
|
return Task.CompletedTask; |
||||
|
} |
||||
|
|
||||
|
protected abstract Task ResolveWeChatMessageAsync(IMessageResolveContext context); |
||||
|
} |
||||
@ -1,10 +1,12 @@ |
|||||
using LINGYUN.Abp.WeChat.Work.Models; |
using LINGYUN.Abp.WeChat.Work.Models; |
||||
using System; |
using System; |
||||
|
using Volo.Abp.Auditing; |
||||
|
|
||||
namespace LINGYUN.Abp.WeChat.Work.Message; |
namespace LINGYUN.Abp.WeChat.Work.Message; |
||||
|
|
||||
[Serializable] |
[Serializable] |
||||
public class MessageHandleInput : WeChatWorkMessage |
public class MessageHandleInput : WeChatWorkMessage |
||||
{ |
{ |
||||
|
[DisableAuditing] |
||||
public string Data { get; set; } |
public string Data { get; set; } |
||||
} |
} |
||||
|
|||||
@ -0,0 +1,24 @@ |
|||||
|
using LINGYUN.Abp.WeChat.Common.Messages.Handlers; |
||||
|
using LINGYUN.Abp.WeChat.Work.Common.Messages.Models; |
||||
|
using LINGYUN.Abp.WeChat.Work.Messages; |
||||
|
|
||||
|
namespace LY.MicroService.Applications.Single.WeChat.Work.Messages; |
||||
|
/// <summary>
|
||||
|
/// 文本消息客服回复
|
||||
|
/// </summary>
|
||||
|
public class TextMessageReplyContributor : IMessageHandleContributor<TextMessage> |
||||
|
{ |
||||
|
public async virtual Task HandleAsync(MessageHandleContext<TextMessage> context) |
||||
|
{ |
||||
|
var messageSender = context.ServiceProvider.GetRequiredService<IWeChatWorkMessageSender>(); |
||||
|
|
||||
|
await messageSender.SendAsync( |
||||
|
new LINGYUN.Abp.WeChat.Work.Messages.Models.WeChatWorkTextMessage( |
||||
|
context.Message.AgentId.ToString(), |
||||
|
new LINGYUN.Abp.WeChat.Work.Messages.Models.TextMessage( |
||||
|
context.Message.Content)) |
||||
|
{ |
||||
|
ToUser = context.Message.FromUserName, |
||||
|
}); |
||||
|
} |
||||
|
} |
||||
Loading…
Reference in new issue