Galosys.Foundation.Integration.Im.Abstractions 26.7.31.1

Galosys.Foundation.Integration.Im.Abstractions

IM 集成抽象层 — 为钉钉、飞书、企微等 IM 平台提供统一接口抽象。平台无关的业务代码只依赖此模块。

DI 注册

通过 AddIntegrationIm<T>() 注册具体平台实现到 DI 容器：

// 注册钉钉适配器
services.AddIntegrationIm<DingTalkPlatform>();

// 或注册飞书适配器
services.AddIntegrationIm<FeishuPlatform>();

具体平台的注册扩展方法在对应适配器模块中：

// DingTalk
services.AddAlibabaCloudDingTalk();

// Feishu
services.AddMudFeishu();

接口概览

// 门面接口 — 聚合四个子服务
public interface IImPlatform
{
    IMessageSender Notification { get; }
    IApprovalHandler Approval { get; }
    IWebhookHandler Webhook { get; }
    IUserMappingStore UserMapping { get; }
    string Platform { get; }
}

// 消息通知
public interface IMessageSender
{
    Task<string> SendAsync(ImMessage message, CancellationToken ct = default);
    Task<string> SendCardAsync(string targetId, ApprovalCardData data, CancellationToken ct = default);
    Task<bool> RevokeAsync(string messageId, CancellationToken ct = default);
}

// 审批管理
public interface IApprovalHandler
{
    Task<string> StartAsync(ApprovalRequest request, CancellationToken ct = default);
    Task<ApprovalStatus> QueryStatusAsync(string instanceId, CancellationToken ct = default);
    Task HandleCallbackAsync(ApprovalCallback callback, CancellationToken ct = default);
}

// Webhook 回调处理
public interface IWebhookHandler
{
    Task<TResult> HandleAsync<TResult>(string platform, string rawBody,
        IReadOnlyDictionary<string, string> headers, CancellationToken ct = default);
}

// 用户 ID 映射
public interface IUserMappingStore
{
    Task<string> ToPlatformIdAsync(string erpUserId, string platform, CancellationToken ct = default);
    Task<string> ToErpIdAsync(string platformUserId, string platform, CancellationToken ct = default);
    Task SyncAsync(CancellationToken ct = default);
}

DTO 模型

// 消息
public record ImMessage(
    ImTargetType TargetType,    // User / Group
    string TargetId,
    ImMessageType Type,         // Text / Markdown / Card
    string Title,
    string Content,
    IReadOnlyList<ImAction>? Actions
);

// 审批请求
public record ApprovalRequest(
    string BizKey,              // ERP 业务单据号
    string Title,
    string Description,
    decimal? Amount,
    string InitiatorId,
    IReadOnlyList<string> ApproverIds,
    IReadOnlyList<ApprovalFormField>? FormFields
);

// 审批回调
public abstract record ApprovalCallback(
    string Platform,
    string InstanceId,
    string BizKey,
    ApprovalStatus Status,      // Pending / Approved / Rejected / Canceled
    string? Comment,
    string OperatorId
);

配置

[Options("Integration:Im")]
public class ImPlatformOptions
{
    public string AppId { get; set; }
    public string AppSecret { get; set; }
    public string? WebhookUrl { get; set; }
}

文档

• 架构设计: docs/im-abstraction-layer-design.md