持久化——DDD务实篇（一） | Michael-J

1
2
3
4
5
6
7
8

@Override
@Transactional
public void changeRoleRemark(long primaryAccountId, String roleName, Stringremark) throws RoleNotFoundException {
    Optional<Role> result = getUserRoleByName(primaryAccountId, roleName);
    Role role = result.orElseThrow(RoleNotFoundException::new);
    role.changeRemark(remark);
    roleRepository.update(role);
}

1
2
3
4
5
6
7
8
9
10
11
12

@Override
@Transactional
public void deleteUserRole(long primaryAccountId, String roleName)
        throws RoleNotFoundException {
    Optional<Role> result = getUserRoleByName(primaryAccountId, roleName);
    Role role = result.orElseThrow(RoleNotFoundException::new);
    RoleRelationParam roleRelationParam = new RoleRelationParam();
    roleRelationParam.setPrimaryAccountId(primaryAccountId);
    roleRelationParam.setRoleId(role.getId());
    roleRelationRepository.revokeRolePolicy(roleRelationParam);
    roleRepository.delete(primaryAccountId, roleName);
}

1
2
3
4
5
6
7
8

@Override
public void execute() {
    StepRepository stepRepository = BeanUtil.getBean(StepRepository.class);
    for(Step step: steps) {
        step.execute();
        stepRepository.save(step);
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86

/**
 * 子账号用户组
 *
 * Created by Michael Jiang on 16-12-5.
 */
public class UserGroup extends Entity {
    private static final long serialVersionUID = -3431132267526140851L;
    private static final int MAX_GROUP_NUMBER = 50;

@Min(1)
    private long primaryAccountId;

@Pattern(regexp = "^[a-z]([a-z0-9-]{0,62}[a-z0-9]$|[a-z0-9]?)", message = "组名称只能是英文字母，数字和中划线")
    private String name;

@Size(max = 255)
    private String remark;

@Size(max = 50)
    private List<String> subAccountList;

public UserGroup(Long primaryAccountId, String name) {
        this(primaryAccountId, name, "");
    }

public UserGroup(Long primaryAccountId, String name, String remark) {
        this.primaryAccountId = primaryAccountId;
        this.name = name;
        this.remark = remark;
        this.subAccountList = Lists.newArrayList();
    }

public long getPrimaryAccountId() {
        return primaryAccountId;
    }

public String getName() {
        return name;
    }

public String getRemark() {
        return remark;
    }

public void changeName(String newGroupName) {
        this.name = newGroupName;
    }

public void changeRemark(String newRemark) {
        this.remark = newRemark;
    }

public void addSubAccount(String subAccount) throws MaxGroupMemberException, AlreadyJoinGroupException {
        if (subAccountList.size() < MAX_GROUP_NUMBER) {
            if (subAccountList.contains(subAccount)) {
                throw new AlreadyJoinGroupException();
            }
            this.subAccountList.add(subAccount);
        } else {
            throw new MaxGroupMemberException();
        }
    }

public void removeSubAccount(String subAccount) {
        this.subAccountList.remove(subAccount);
    }

public List<String> getSubAccountList() {
        return subAccountList;
    }

protected void setSubAccountList(List<String> subAccountList) {
        this.subAccountList = subAccountList;
    }

@Override
    public Set<String> validate() {
        return Entity.validate(this);
    }

@Override
    public String toString() {
        return "UserGroup{" + "primaryAccountId='" + primaryAccountId + '\'' + ", name='" + name + '\'' + ", remark='"
                + remark + '\'' + ", subAccountList=" + subAccountList + '}';
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

<resultMap id="groupResult" type="userGroup">
       <constructor>
           <arg column="primary_account_id" javaType="long"/>
           <arg column="name" javaType="String"/>
           <arg column="remark" javaType="String"/>
       </constructor>
       <id column="id" property="id"/>
       <result column="gmt_create" property="gmtCreate"/>
       <result column="gmt_modify" property="gmtModify"/>
       <result column="is_deleted" property="isDeleted"/>
       <collection property="subAccountList" javaType="list" column="id" ofType="String"
                   select="selectSubAccountUser" fetchType="eager">
           <result column="sub_account_user"/>
       </collection>
   </resultMap>

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

/**
 * EMailAddress值对象 Type Handler
 *
 * Created by Michael Jiang on 16-12-6.
 */
@MappedTypes(EMailAddress.class)
@MappedJdbcTypes(JdbcType.VARCHAR)
public class EMailAddressTypeHandler extends BaseTypeHandler<EMailAddress> {
    @Override
    public void setNonNullParameter(PreparedStatement preparedStatement, int i, EMailAddress eMailAddress,
            JdbcType jdbcType) throws SQLException {
        preparedStatement.setString(i, eMailAddress.email());
    }

@Override
    public EMailAddress getNullableResult(ResultSet resultSet, String s) throws SQLException {
        return new EMailAddress(resultSet.getString(s));
    }

@Override
    public EMailAddress getNullableResult(ResultSet resultSet, int i) throws SQLException {
        return new EMailAddress(resultSet.getString(i));
    }

@Override
    public EMailAddress getNullableResult(CallableStatement callableStatement, int i) throws SQLException {
        return new EMailAddress(callableStatement.getString(i));
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

/**
 * 带id的值对象 Created by jiangwenkang on 16-11-7.
 */
public abstract class IdentifiedValueObject<V extends IdentifiedValueObject> implements ValueObject<V> {
    private static final long serialVersionUID = -7815856088988915247L;

protected Long id;
    protected Date gmtCreate;

protected Long getId() {
        return id;
    }

protected void setId(Long id) {
        this.id = id;
    }

public Date getGmtCreate() {
        return gmtCreate;
    }

protected void setGmtCreate(Date gmtCreate) {
        this.gmtCreate = gmtCreate;
    }

@Override
    public String toString() {
        return "IdentifiedValueObject{" + "id=" + id + ", gmtCreate=" + gmtCreate + '}';
    }
}