|
@@ -1,9 +1,12 @@
|
|
|
package com.sckw.message.service;
|
|
package com.sckw.message.service;
|
|
|
|
|
|
|
|
import com.alibaba.fastjson2.JSONObject;
|
|
import com.alibaba.fastjson2.JSONObject;
|
|
|
|
|
+import com.github.pagehelper.PageHelper;
|
|
|
|
|
+import com.github.pagehelper.PageInfo;
|
|
|
import com.sckw.core.common.enums.enums.DictTypeEnum;
|
|
import com.sckw.core.common.enums.enums.DictTypeEnum;
|
|
|
import com.sckw.core.exception.BusinessException;
|
|
import com.sckw.core.exception.BusinessException;
|
|
|
import com.sckw.core.model.constant.Global;
|
|
import com.sckw.core.model.constant.Global;
|
|
|
|
|
+import com.sckw.core.model.page.PageRes;
|
|
|
import com.sckw.core.model.vo.TableBottom;
|
|
import com.sckw.core.model.vo.TableBottom;
|
|
|
import com.sckw.core.model.vo.TableStatisticRes;
|
|
import com.sckw.core.model.vo.TableStatisticRes;
|
|
|
import com.sckw.core.model.vo.TableTop;
|
|
import com.sckw.core.model.vo.TableTop;
|
|
@@ -20,7 +23,6 @@ import com.sckw.message.model.dto.UserMsgCenterLatestMsgDTO;
|
|
|
import com.sckw.message.model.dto.UserMsgCenterReqDTO;
|
|
import com.sckw.message.model.dto.UserMsgCenterReqDTO;
|
|
|
import com.sckw.message.model.vo.req.DeleteMessagesReqVO;
|
|
import com.sckw.message.model.vo.req.DeleteMessagesReqVO;
|
|
|
import com.sckw.message.model.vo.req.ReadMessagesReqVO;
|
|
import com.sckw.message.model.vo.req.ReadMessagesReqVO;
|
|
|
-import com.sckw.message.model.vo.req.SelectMessagesReqVO;
|
|
|
|
|
import com.sckw.message.model.vo.req.StatisticsMessagesReqVO;
|
|
import com.sckw.message.model.vo.req.StatisticsMessagesReqVO;
|
|
|
import com.sckw.message.model.vo.res.KwmMessageListResVO;
|
|
import com.sckw.message.model.vo.res.KwmMessageListResVO;
|
|
|
import com.sckw.message.model.vo.res.MessagesStatisticsResVO;
|
|
import com.sckw.message.model.vo.res.MessagesStatisticsResVO;
|
|
@@ -105,14 +107,14 @@ public class MessageService {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
|
- * @param reqVO
|
|
|
|
|
|
|
+ * @param dto
|
|
|
* @return java.util.List<com.sckw.message.model.KwmMessage>
|
|
* @return java.util.List<com.sckw.message.model.KwmMessage>
|
|
|
* @desc: 分页查询消息列表
|
|
* @desc: 分页查询消息列表
|
|
|
* @author: yzc
|
|
* @author: yzc
|
|
|
* @date: 2023-06-13 9:05
|
|
* @date: 2023-06-13 9:05
|
|
|
*/
|
|
*/
|
|
|
- public List<KwmMessageListResVO> select(SelectMessagesReqVO reqVO) {
|
|
|
|
|
- SelectMessagesDTO dto = BeanUtils.copyProperties(reqVO, SelectMessagesDTO.class);
|
|
|
|
|
|
|
+ public PageRes select(SelectMessagesDTO dto) {
|
|
|
|
|
+ PageHelper.startPage(dto.getPage(), dto.getPageSize());
|
|
|
//当前登录人是企业管理员则查看全部消息,否则只查看对应用户消息
|
|
//当前登录人是企业管理员则查看全部消息,否则只查看对应用户消息
|
|
|
Integer isMain = LoginUserHolder.getIsMain();
|
|
Integer isMain = LoginUserHolder.getIsMain();
|
|
|
if (Objects.equals(isMain, 1)) {
|
|
if (Objects.equals(isMain, 1)) {
|
|
@@ -121,8 +123,9 @@ public class MessageService {
|
|
|
dto.setUserId(LoginUserHolder.getUserId());
|
|
dto.setUserId(LoginUserHolder.getUserId());
|
|
|
}
|
|
}
|
|
|
List<MessageListDTO> list = kwmMessageService.findPage(dto);
|
|
List<MessageListDTO> list = kwmMessageService.findPage(dto);
|
|
|
|
|
+ PageInfo<MessageListDTO> pageInfo = new PageInfo<>(list);
|
|
|
if (CollectionUtils.isEmpty(list)) {
|
|
if (CollectionUtils.isEmpty(list)) {
|
|
|
- return Collections.emptyList();
|
|
|
|
|
|
|
+ return PageRes.build(pageInfo, list);
|
|
|
}
|
|
}
|
|
|
Map<String, String> categoryMap, statusMap;
|
|
Map<String, String> categoryMap, statusMap;
|
|
|
Map<String, Map<String, String>> dictMap = remoteSystemService.queryDictByType(
|
|
Map<String, Map<String, String>> dictMap = remoteSystemService.queryDictByType(
|
|
@@ -158,7 +161,7 @@ public class MessageService {
|
|
|
}
|
|
}
|
|
|
result.add(res);
|
|
result.add(res);
|
|
|
});
|
|
});
|
|
|
- return result;
|
|
|
|
|
|
|
+ return PageRes.build(pageInfo, result);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|