Kaynağa Gözat

合并本地分支

weiximei 6 yıl önce
ebeveyn
işleme
1e58ed32c4

+ 5
- 11
CODE/smart-community/app-api/src/main/java/com/community/huiju/controller/MessageController.java Dosyayı Görüntüle

@@ -3,8 +3,6 @@ package com.community.huiju.controller;
3 3
 import com.community.commom.constant.Constant;
4 4
 import com.community.commom.mode.ResponseBean;
5 5
 import com.community.commom.session.UserElement;
6
-import com.community.huiju.model.ToCommunities;
7
-import com.community.huiju.model.TpMessage;
8 6
 import com.community.huiju.service.MessageServiceI;
9 7
 import io.swagger.annotations.Api;
10 8
 import io.swagger.annotations.ApiImplicitParam;
@@ -19,7 +17,6 @@ import org.springframework.web.bind.annotation.RequestParam;
19 17
 import org.springframework.web.bind.annotation.RestController;
20 18
 
21 19
 import javax.servlet.http.HttpSession;
22
-import java.util.List;
23 20
 import java.util.Map;
24 21
 
25 22
 /**
@@ -66,14 +63,12 @@ public class MessageController extends BaseController {
66 63
 		UserElement userElement = (UserElement) session.getAttribute(Constant.APP_USER_SESSION);
67 64
 		Integer userId = userElement.getId();
68 65
 		ResponseBean responseBean = new ResponseBean();
69
-
70 66
 		if (!check(communityId)) {
71 67
 			responseBean.addError("小区不存在");
72 68
 			return responseBean;
73 69
 		}
74
-
75
-		List<TpMessage> newsList = messageService.getMessages(communityId,pageNum,pageSize, Constant.MODEL_TYPE_NEWS, userId);
76
-		responseBean.addSuccess(newsList);
70
+		Map<String,Object> map = messageService.getMessages(communityId,pageNum,pageSize, Constant.MODEL_TYPE_NEWS, userId);
71
+		responseBean.addSuccess(map);
77 72
 		return responseBean;
78 73
 	}
79 74
 	
@@ -89,14 +84,13 @@ public class MessageController extends BaseController {
89 84
 		UserElement userElement = (UserElement) session.getAttribute(Constant.APP_USER_SESSION);
90 85
 		Integer userId = userElement.getId();
91 86
 		ResponseBean responseBean = new ResponseBean();
92
-
87
+		
93 88
 		if (!check(communityId)) {
94 89
 			responseBean.addError("小区不存在");
95 90
 			return responseBean;
96 91
 		}
97
-
98
-		List<TpMessage> upcomingList = messageService.getMessages(communityId,pageNum,pageSize,Constant.MODEL_TYPE_UPCOMING, userId);
99
-		responseBean.addSuccess(upcomingList);
92
+		Map<String,Object> map = messageService.getMessages(communityId,pageNum,pageSize,Constant.MODEL_TYPE_UPCOMING, userId);
93
+		responseBean.addSuccess(map);
100 94
 		return responseBean;
101 95
 	}
102 96
 

+ 1
- 4
CODE/smart-community/app-api/src/main/java/com/community/huiju/service/MessageServiceI.java Dosyayı Görüntüle

@@ -1,8 +1,5 @@
1 1
 package com.community.huiju.service;
2 2
 
3
-import com.community.huiju.model.TpMessage;
4
-
5
-import java.util.List;
6 3
 import java.util.Map;
7 4
 
8 5
 public interface MessageServiceI {
@@ -21,7 +18,7 @@ public interface MessageServiceI {
21 18
 	 * @param modelType
22 19
 	 * @return
23 20
 	 */
24
-	List<TpMessage> getMessages(Integer communityId, Integer pageNum, Integer pageSize,Integer modelType, Integer userId);
21
+	Map<String,Object> getMessages(Integer communityId, Integer pageNum, Integer pageSize,Integer modelType, Integer userId);
25 22
 
26 23
 	/**
27 24
 	 * 全部已读

+ 8
- 4
CODE/smart-community/app-api/src/main/java/com/community/huiju/service/impl/MessageServiceImpl.java Dosyayı Görüntüle

@@ -3,11 +3,12 @@ package com.community.huiju.service.impl;
3 3
 import com.community.huiju.dao.TpMessageMapper;
4 4
 import com.community.huiju.model.TpMessage;
5 5
 import com.community.huiju.service.MessageServiceI;
6
+import com.github.pagehelper.Page;
6 7
 import com.github.pagehelper.PageHelper;
7
-import io.swagger.models.auth.In;
8 8
 import org.springframework.beans.factory.annotation.Autowired;
9 9
 import org.springframework.stereotype.Service;
10 10
 
11
+import java.util.HashMap;
11 12
 import java.util.List;
12 13
 import java.util.Map;
13 14
 
@@ -40,12 +41,15 @@ public class MessageServiceImpl implements MessageServiceI {
40 41
 	 * @return
41 42
 	 */
42 43
 	@Override
43
-	public List<TpMessage> getMessages(Integer communityId, Integer pageNum, Integer pageSize,Integer modelType, Integer userId) {
44
+	public Map<String,Object> getMessages(Integer communityId, Integer pageNum, Integer pageSize,Integer modelType, Integer userId) {
44 45
 		//使用分页插件
45
-		PageHelper.startPage(pageNum, pageSize);
46
+		Page page = PageHelper.startPage(pageNum, pageSize);
46 47
 		// 获取数据
47 48
 		List<TpMessage> messageList = tpMessageMapper.getMessages(userId,communityId, modelType);
48
-		return messageList;
49
+		Map<String,Object> map = new HashMap<>();
50
+		map.put("list",messageList);
51
+		map.put("total",page.getTotal());
52
+		return map;
49 53
 	}
50 54
 
51 55
 	/**