|
@@ -1,5 +1,6 @@
|
|
|
package cn.com.ty.lift.push.message.controller;
|
|
|
|
|
|
+import cn.com.ty.lift.common.constants.ApiConstants;
|
|
|
import cn.com.ty.lift.push.message.dao.entity.TimeMessage;
|
|
|
import cn.com.ty.lift.push.message.object.MessageBO;
|
|
|
import cn.com.ty.lift.push.message.object.MessageVo;
|
|
@@ -34,12 +35,14 @@ public class TimeMessageController {
|
|
|
IPage<TimeMessage> result = timeMessageService.page(page, Wrappers.<TimeMessage>query()
|
|
|
.eq(messageVo.getUserId() != null, "user_id", messageVo.getUserId())
|
|
|
.eq(messageVo.getType() != null, "type", messageVo.getType())
|
|
|
+ .notIn("device_model", ApiConstants.DeviceModel.PC)
|
|
|
.orderByAsc("view_flag", "create_time"));
|
|
|
MessageBO messageBO = MessageBO.pageCastMessageBo(result);
|
|
|
messageBO.setReadCount((long) timeMessageService.count(Wrappers.<TimeMessage>query()
|
|
|
.eq(messageVo.getUserId() != null, "user_id", messageVo.getUserId())
|
|
|
.eq("view_flag", 1)
|
|
|
- .eq("type", messageVo.getType())));
|
|
|
+ .eq("type", messageVo.getType())
|
|
|
+ .notIn("device_model", ApiConstants.DeviceModel.PC)));
|
|
|
messageBO.setUnreadCount(messageBO.getTotal() - messageBO.getReadCount());
|
|
|
return RestResponse.success(messageBO);
|
|
|
}
|
|
@@ -58,6 +61,7 @@ public class TimeMessageController {
|
|
|
|
|
|
/**
|
|
|
* 设置多条消息已读
|
|
|
+ *
|
|
|
* @param messageVo id列表
|
|
|
* @return 操作结果
|
|
|
*/
|