@@ -101,6 +101,13 @@ public class ThWestreamMessageServiceImpl extends ServiceImpl<ThWestreamMessageM | |||
*/ | |||
@Override | |||
public JsonResult sum(WestreamMessageQuery query) { | |||
if (StringUtils.isEmpty(query.getOpenId())) { | |||
return JsonResult.error("openid为空"); | |||
} | |||
if (StringUtils.isNull(query.getTenantId())) { | |||
return JsonResult.error("TenantId为空"); | |||
} | |||
//查询出所有未读的 | |||
List<ThWestreamMessage> list = this.list(Wrappers.<ThWestreamMessage>lambdaQuery() | |||
.eq(ThWestreamMessage::getTenantId, query.getTenantId()) |