|
|
@@ -25,6 +25,7 @@ import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
|
|
|
import lombok.AllArgsConstructor;
|
|
|
import javax.validation.Valid;
|
|
|
|
|
|
+import org.springblade.client.dto.UnReadDTO;
|
|
|
import org.springblade.client.entity.Message;
|
|
|
import org.springblade.client.message.service.IMessageService;
|
|
|
import org.springblade.client.vo.MessageVO;
|
|
|
@@ -59,9 +60,21 @@ public class MessageController extends BladeController {
|
|
|
@ApiOperation(value = "详情", notes = "传入message")
|
|
|
public R<Message> detail(Message message) {
|
|
|
Message detail = messageService.getOne(Condition.getQueryWrapper(message));
|
|
|
+ detail.setIsRead(1);
|
|
|
+ messageService.updateById(detail);
|
|
|
return R.data(detail);
|
|
|
}
|
|
|
|
|
|
+ //备用接口: socket辅助接口, 防止socket掉线
|
|
|
+ @GetMapping("/getUserMessage")
|
|
|
+ @ApiOperationSupport(order = 1)
|
|
|
+ @ApiOperation(value = "详情", notes = "传入message")
|
|
|
+ public String getUserMessage()
|
|
|
+ {
|
|
|
+ UnReadDTO readDTO = messageService.getUserMessage(AuthUtil.getUserId());
|
|
|
+ return readDTO.toString();
|
|
|
+ }
|
|
|
+
|
|
|
/**
|
|
|
* 分页
|
|
|
*/
|
|
|
@@ -72,7 +85,10 @@ public class MessageController extends BladeController {
|
|
|
LambdaQueryWrapper<Message> messageLambdaQueryWrapper=new LambdaQueryWrapper<>();
|
|
|
messageLambdaQueryWrapper
|
|
|
.like(Message::getToUserId, AuthUtil.getUserId())
|
|
|
- .eq(Message::getTenantId,AuthUtil.getTenantId());
|
|
|
+ .eq(Message::getTenantId,AuthUtil.getTenantId())
|
|
|
+ .orderByDesc(Message::getCreateTime)
|
|
|
+ .orderByAsc(Message::getIsRead)
|
|
|
+ ;
|
|
|
IPage<Message> pages = messageService.page(Condition.getPage(query), messageLambdaQueryWrapper);
|
|
|
return R.data(pages);
|
|
|
}
|