|
@@ -72,6 +72,7 @@ public class TimeMessageController {
|
|
|
.count(Wrappers.<TimeMessage>query()
|
|
|
.eq(userId != null, "user_id", userId)
|
|
|
.eq("type", 0)
|
|
|
+ .eq("view_flag",0)
|
|
|
.eq("statuz",1)
|
|
|
.notIn("device_model", ApiConstants.DeviceModel.PC));
|
|
|
TimeMessage one = timeMessageService.getOne(
|
|
@@ -91,6 +92,7 @@ public class TimeMessageController {
|
|
|
.count(Wrappers.<TimeMessage>query()
|
|
|
.eq(userId != null, "user_id", userId)
|
|
|
.notIn("type", 0)
|
|
|
+ .eq("view_flag",0)
|
|
|
.eq("statuz",1)
|
|
|
.notIn("device_model", ApiConstants.DeviceModel.PC));
|
|
|
TimeMessage notice = timeMessageService.getOne(
|
|
@@ -200,6 +202,28 @@ public class TimeMessageController {
|
|
|
return RestResponse.success();
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 一键已读
|
|
|
+ * @param messageVo
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ @PostMapping("cacelUnread")
|
|
|
+ public RestResponse<Boolean> cacelUnread(@RequestBody MessageVo messageVo) {
|
|
|
+ if (messageVo.getUserId() == null || messageVo.getType() == null){
|
|
|
+ return RestResponse.fail("请核对参数.");
|
|
|
+ }
|
|
|
+
|
|
|
+ TimeMessage updateEntity = new TimeMessage();
|
|
|
+ updateEntity.setViewFlag(1);
|
|
|
+ timeMessageService.update(updateEntity, new QueryWrapper<TimeMessage>()
|
|
|
+ .eq("user_id",messageVo.getUserId())
|
|
|
+ .eq("type",messageVo.getType())
|
|
|
+ );
|
|
|
+
|
|
|
+ return RestResponse.success();
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
/**
|
|
|
* @param messageVo
|
|
|
* 分页功能的请求对象
|