public without sharing class TestEventPublishAsynchronous {

    // フローから渡されるパラメータ
    public class TestEventPublishAsynchronousInput {

        @InvocableVariable(description='フローのインタビューGUIDを設定する' required=true)
        public String flowGuid;

        @InvocableVariable(description='対象のレコードIDを設定する' required=true)
        public String recordId;

        public TestEventPublishAsynchronousInput(String flowGuid, String recordId) {
            this.flowGuid = flowGuid;
            this.recordId = recordId;
        }        
    }

    @InvocableMethod
    public static void run(List<TestEventPublishAsynchronousInput> inputList) {

        // レコードIDから商談を取得
        Opportunity opp = [Select Id, Name From Opportunity Where Id = :inputList[0].recordId];
        // コールアウト処理を非同期実行
        callout(inputList[0].flowGuid, inputList[0].recordId, opp.Name);
    }

    @future(callout=true)
    private static void callout(String flowGuid, String recordId, String oppName) {
        try {
            // ★ここでコールアウト処理を実装★

            // プラットフォームイベントの公開（成功）
            publishPlatformEvent(flowGuid, recordId, false, null);
        } catch (Exception e) {
            // プラットフォームイベントの公開（失敗）
            publishPlatformEvent(flowGuid, recordId, true, '商談' + oppName +'コールアウト処理に失敗しました');
        }
    }

    //  プラットフォームイベントの公開
    private static void publishPlatformEvent(String flowGuid, String recordId, Boolean hasError, String message) {
        TestEvent__e te = new TestEvent__e(
            FlowId__c  = flowGuid,
            RecordId__c = recordId,
            HasError__c = hasError,
            Message__c = message
        );
        // プラットフォームイベントの公開
        Database.SaveResult sr = EventBus.publish(te);
        if (sr.isSuccess()) {
            // プラットフォームイベント公開正常終了
            System.debug('プラットフォームイベント公開: ' + te);
        } else {
            // プラットフォームイベント公開エラー
            for (Database.Error err å: sr.getErrors()) {
                System.debug('プラットフォームイベント公開に失敗: ' + err.getStatusCode() + ' - ' + err.getMessage());
            }
        }
    }
}