1 @Service
 2 public class PostServiceImpl implements PostService {
 3
 4     @Autowired
 5     private IPostRepository postRepository;
 6
 7     @Autowired
 8     private PostAssembler postAssembler;
 9
10
11
12     public PostingRespBody posting(RequestDto<PostingReqBody> requestDto) throws BusinessException {
13         PostingReqBody postingReqBody = requestDto.getBody();
14         /**
15          *NOTE： 请求参数校验交给了validation，这里无需校验userId和postId是否为空
16          */
17         String userId = postingReqBody.getUserId();
18         String title = postingReqBody.getTitle();
19         String sourceContent = postingReqBody.getSourceContent();
20
21         long userIdInLong = Long.valueOf(userId);
22
23         /**
24          * 组装domain model entity
25          * NOTE：这里的PostAuthor不需要从repository重载，原因在于：deletePost场景需要用户登录后才能操作，
26          *         在进入service之前，已经在controller层完成了用户身份鉴权，故到达这里的userId肯定是合法的用户
27          */
28         PostAuthor postAuthor = new PostAuthor(userIdInLong);
29         Post post = postAuthor.posting(title, sourceContent);
30
31         /**
32          * NOTE：使用repository将model entity 写入存储
33          */
34         postRepository.save(post);
35
36         /**
37          * NOTE：使用postAssembler将Post model组装成dto返回。
38          */
39         return postAssembler.assemblePostingRespBody(post);
40     }
41
42
43     public DeletePostRespBody delete(RequestDto<DeletePostReqBody> requestDto) throws BusinessException {
44         DeletePostReqBody deletePostReqBody = requestDto.getBody();
45
46         /**
47          *NOTE： 请求参数校验交给了validation，这里无需校验userId和postId是否为空
48          */
49         String userId = deletePostReqBody.getUserId();
50         String postId = deletePostReqBody.getPostId();
51
52         long userIdInLong = Long.valueOf(userId);
53         long postIdInLong = Long.valueOf(postId);
54
55         /**
56          * 组装domain model entity
57          * NOTE：这里的PostAuthor不需要从repository重载，原因在于：deletePost场景需要用户登录后才能操作，
58          *         在进入service之前，已经在controller层完成了用户身份鉴权，故到达这里的userId肯定是合法的用户
59          */
60         PostAuthor postAuthor = new PostAuthor(userIdInLong);
61         /**
62          * 从repository中重载domain model entity
63          * 借此判断该postId是否真的存在帖子
64          */
65         Post post = postRepository.query(postIdInLong);
66
67         postAuthor.deletePost(post);
68
69         postRepository.delete(post);
70
71         return null;
72     }
73
74
75     @Override
76     public QueryPostDetailRespBody queryPostDetail(RequestDto<QueryPostDetailReqBody> requestDto)
77             throws BusinessException {
78         QueryPostDetailReqBody queryPostDetailReqBody = requestDto.getBody();
79
80         String readerId = queryPostDetailReqBody.getReaderId();
81         String postId = queryPostDetailReqBody.getPostId();
82
83         long readerIdInLong = Long.valueOf(readerId);
84         long postIdInLong = Long.valueOf(postId);
85
86         //TODO 可能有一些权限校验，比如：判定该读者是否有查看作者帖子的权限等。这里暂且不展开讨论。
87         PostReader postReader = new PostReader(readerIdInLong);
88
89         Post post = postRepository.query(postIdInLong);
90
91         /**
92          * NOTE: 使用postAssembler将domain层的model组装成dto，组装过程：
93          *         1、完成类型转换、数据格式化；
94          *         2、将多个model组合成一个dto，一并返回。
95          */
96         return postAssembler.assembleQueryPostDetailRespBody(post);
97     }
98
99 }

 1 /**
 2  * Post模块的组装器，完成domain model对象到dto的转换，组装职责包括：
 3  *         1、完成类型转换、数据格式化；如日志格式化，状态enum装换为前端认识的string；
 4  *         2、将多个model组合成一个dto，一并返回。
 5  * TODO: 不太好的地方每个assemble方法都需要先判断入参对象是否为空。
 6  * @author daoqidelv
 7  * @createdate 2017年9月24日
 8  */
 9 @Component
10 public class PostAssembler {
11
12     private final static String POSTING_TIME_STRING_DATE_FORMAT = "yyyy-MM-dd hh:mm:ss";
13
14     @Autowired
15     private ApplicationUtil applicationUtil;
16
17     public PostingRespBody assemblePostingRespBody(Post post) {
18         if(post == null) {
19             return null;
20         }
21         PostingRespBody postingRespBody = new PostingRespBody();
22         postingRespBody.setPostId(String.valueOf(post.getId()));
23         return postingRespBody;
24     }
25
26     public QueryPostDetailRespBody assembleQueryPostDetailRespBody(Post post) {
27         /**
28          * NOTE: 判定入参post是否为null
29          */
30         if(post == null) {
31             return null;
32         }
33         QueryPostDetailRespBody queryPostDetailRespBody = new QueryPostDetailRespBody();
34         queryPostDetailRespBody.setAuthorId(String.valueOf(post.getAuthorId())); //完成类型转换
35         queryPostDetailRespBody.setPostId(String.valueOf(post.getId()));//完成类型转换
36         queryPostDetailRespBody.setPostingTime(
37                 applicationUtil.convertTimestampToString(post.getPostingTime(), POSTING_TIME_STRING_DATE_FORMAT));//完成日期格式化
38         queryPostDetailRespBody.setSourceContent(post.getSourceContent());
39         queryPostDetailRespBody.setTitle(post.getTitle());
40         return queryPostDetailRespBody;
41     }
42
43 }