Elgato_dark/sol-cloud
1
0
Fork 0
mirror of https://github.com/BgaSol/sol-cloud synced 2026-04-21 17:17:16 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

refactor(message): update message envelope controller and service methods

Browse source
This commit is contained in:
sol 2026-03-18 13:20:54 +08:00
parent 835f68d88c
commit c0e125d71c
2 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
cloud/common/common-base-web/src/main/java/com/bgasol/common/message/service/MessageEnvelopeService.java
View file

@ -10,7 +10,6 @@ import com.bgasol.model.system.message.entity.MessageEnvelopeEntity;
import com.bgasol.model.system.message.entity.MessageEnvelopeStatusEnum;
import com.bgasol.model.system.user.api.UserApi;
import com.bgasol.model.system.user.entity.UserEntity;
import jakarta.validation.Valid;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.ObjectUtils;
@ -41,6 +40,7 @@ public class MessageEnvelopeService extends BaseService<MessageEnvelopeEntity<?>
}
@Override
@Transactional(readOnly = true)
public void findOtherTable(List<MessageEnvelopeEntity<?>> list) {
Set<String> userIds = list.stream()
.map(MessageEnvelopeEntity::getUserId)
@ -82,7 +82,8 @@ public class MessageEnvelopeService extends BaseService<MessageEnvelopeEntity<?>
}
}
public void read(@Valid List<String> ids) {
@Transactional
public void toReadById(List<String> ids) {
Set<String> idSet = new HashSet<>(ids);
MessageEnvelopeEntity<?> messageEnvelopeEntity = new MessageEnvelopeEntity<>();
messageEnvelopeEntity.setStatus(MessageEnvelopeStatusEnum.READ);

5
cloud/web/web-system-8081/src/main/java/com/bgasol/web/system/message/controller/MessageEnvelopeController.java
View file

@ -13,6 +13,7 @@ import com.bgasol.model.system.message.entity.MessageEnvelopeEntity;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.validation.Valid;
import jakarta.validation.constraints.NotEmpty;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.*;
@ -62,8 +63,8 @@ public class MessageEnvelopeController extends BaseController<
@PostMapping("/read")
@Operation(summary = "批量已读消息", operationId = "readMessageEnvelope")
@SaCheckPermission(value = "messageEnvelope:read", orRole = "admin")
public BaseVo<Void> read(@RequestBody @Valid List<String> ids) {
messageEnvelopeService.read(ids);
public BaseVo<Void> read(@RequestBody @Valid @NotEmpty(message = "ids列表不能为空") List<String> ids) {
messageEnvelopeService.toReadById(ids);
return BaseVo.success();
}