Domaでのシステム制御項目を含むInsert文生成時における指定

Question

やりたいこと

ユーザ登録機能の作成。
###現状
ユーザ登録時に作成者(created_by)などのシステム制御項目を挿入するようにしたいが、Insert文のcreated_byのvalueにnullが入ってしまうためエラーで落ちる。
（ユーザ情報を格納するテーブルで「created_by(作成者)」をnot nullに指定しているため）
created_byへ値を設定している（ハズ）の箇所はDefaultEntityListenerというクラスです。ここで値が設定できていません。
以下にコードを示していますが、DefaultEntityListenerのval createdBy = AuditInfoHolder.getAuditUser();の部分で値が取得できていないことがわかりました。
以下エラー画像（created_byは作成者)

###テーブル定義

CREATE TABLE IF NOT EXISTS users(
  user_id INT(11) unsigned NOT NULL AUTO_INCREMENT COMMENT 'ユーザID'
  , name VARCHAR(100) DEFAULT NULL COMMENT '名前'
  , email VARCHAR(100) DEFAULT NULL COMMENT 'メールアドレス'
  , password VARCHAR(100) DEFAULT NULL COMMENT 'パスワード'
  , created_by VARCHAR(50) NOT NULL COMMENT '登録者'
  , created_at DATETIME NOT NULL COMMENT '登録日時'
  , updated_by VARCHAR(50) DEFAULT NULL COMMENT '更新者'
  , updated_at DATETIME DEFAULT NULL COMMENT '更新日時'
  , deleted_by VARCHAR(50) DEFAULT NULL COMMENT '削除者'
  , deleted_at DATETIME DEFAULT NULL COMMENT '削除日時'
  , version INT(11) unsigned NOT NULL DEFAULT 1 COMMENT '改訂番号'
  , PRIMARY KEY (user_id)
  , KEY idx_users (email, deleted_at)
) COMMENT='ユーザー';

###ソース
作成者や作成日時などのシステム制御項目は共通化のためにUser.java(DTO)とは別でDomaDto.javaとして定義している。

package com.example.demo.domain.dto;

import com.example.demo.domain.dto.common.DomaDtoImpl;
import lombok.Data;
import org.seasar.doma.*;

@Entity
@Data
@Table(name = "users")
public class User extends DomaDtoImpl {
    //自動採番設定
    @Id
    @Column(name = "user_id")
    @GeneratedValue(strategy= GenerationType.IDENTITY)
    Long id;

    @Column
    String name;

    @Column
    String email;

    @Column
    String password;

}

DomaDto.javaではシステム制御項目を定義している。また、自動的に更新するようにDefaultEntityListener.javaを作成し指定している。

package com.example.demo.domain.dto.common;

import com.fasterxml.jackson.annotation.JsonIgnore;
import lombok.Data;
import org.seasar.doma.Column;
import org.seasar.doma.Entity;
import org.seasar.doma.Version;

import java.io.Serializable;
import java.time.LocalDateTime;

@Entity(listener = DefaultEntityListener.class)// 自動的にシステム制御項目を更新するためにリスナーを指定する
@Data
public abstract class DomaDtoImpl implements DomaDto,Serializable {

    // 作成者
    @JsonIgnore
    @Column
    private String created_by;

    //作成日時
    @JsonIgnore
    @Column
    private LocalDateTime Created_at;

    //更新者
    @JsonIgnore
    @Column
    private String updated_by;

    //更新日時
    @JsonIgnore
    @Column
    private  LocalDateTime updated_at;

    //削除者
    @JsonIgnore
    @Column
    private String deleted_by;

    //削除日
    @JsonIgnore
    @Column
    private LocalDateTime deleted_at;

    // 楽観的排他制御で使用する改定番号
    @Version
    @Column(name = "version")
    @JsonIgnore
    Integer version;

}

package com.example.demo.domain.dto.common;

import com.example.demo.common.utils.ReflectionUtils;
import com.example.demo.domain.exception.DoubleSubmitErrorException;
import lombok.NoArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import lombok.val;
import org.apache.commons.lang3.StringUtils;
import org.seasar.doma.Id;
import org.seasar.doma.jdbc.entity.EntityListener;
import org.seasar.doma.jdbc.entity.PreDeleteContext;
import org.seasar.doma.jdbc.entity.PreInsertContext;
import org.seasar.doma.jdbc.entity.PreUpdateContext;


import java.util.List;
import java.util.Objects;

import static java.util.stream.Collectors.toList;

@NoArgsConstructor
@Slf4j
public class DefaultEntityListener<ENTITY> implements EntityListener<ENTITY> {

    @Override
    public void preInsert(ENTITY entity, PreInsertContext<ENTITY> context) {
        // 二重送信防止チェック
        val expected = DoubleSubmitCheckTokenHolder.getExpectedToken();
        val actual = DoubleSubmitCheckTokenHolder.getActualToken();

        if (expected != null && actual != null && !Objects.equals(expected, actual)) {
            throw new DoubleSubmitErrorException();
        }

        if (entity instanceof DomaDto) {
            val domaDto = (DomaDto) entity;
            val createdAt = AuditInfoHolder.getAuditDateTime();
            val createdBy = AuditInfoHolder.getAuditUser();

            domaDto.setCreated_at(createdAt); // 作成日
            domaDto.setCreated_by(createdBy); // 作成者
        }
    }

    @Override
    public void preUpdate(ENTITY entity, PreUpdateContext<ENTITY> context) {

        if (entity instanceof DomaDto) {
            val domaDto = (DomaDto) entity;
            val updatedAt = AuditInfoHolder.getAuditDateTime();
            val updatedBy = AuditInfoHolder.getAuditUser();

            val methodName = context.getMethod().getName();
            if (StringUtils.startsWith("delete", methodName)) {
                domaDto.setDeleted_at(updatedAt); // 削除日
                domaDto.setDeleted_by(updatedBy); // 削除者
            } else {
                domaDto.setUpdated_at(updatedAt); // 更新日
                domaDto.setUpdated_by(updatedBy); // 更新者
            }
        }
    }

    @Override
    public void preDelete(ENTITY entity, PreDeleteContext<ENTITY> context) {

        if (entity instanceof DomaDto) {
            val domaDto = (DomaDto) entity;
            val deletedAt = AuditInfoHolder.getAuditDateTime();
            val deletedBy = AuditInfoHolder.getAuditUser();
            val name = domaDto.getClass().getName();
            val ids = getIds(domaDto);

            // 物理削除した場合はログ出力する
            log.info("データを物理削除しました。entity={}, id={}, deletedBy={}, deletedAt={}", name, ids, deletedBy, deletedAt);
        }
    }

    /**
     * Idアノテーションが付与されたフィールドの値のリストを返します。
     *
     * @param dto
     * @return
     */
    protected List<Object> getIds(DomaDto dto) {
        return ReflectionUtils.findWithAnnotation(dto.getClass(), Id.class)
                .map(f -> ReflectionUtils.getFieldValue(f, dto)).collect(toList());
    }

}

created_byを自動更新させるためには他に何か指定が必要でしょうか。
またプロジェクト全体のソースコードはgithubへあげてあります。
ご指摘いただけると幸いです。

Answer 1

システム制御項目をセットするaopの考慮が不足していました。
作成してgithubにアップしました。