From fa89f5c4b746a41efee0362bd3a42ea2c97e2cff Mon Sep 17 00:00:00 2001
From: rain <167982779@qq.com>
Date: Mon, 22 Apr 2024 18:13:46 +0800
Subject: [PATCH] 在加水印前对文件进行音视频处理，分别执行不同方法。增加图片压缩、视频压缩方法。
---
src/main/java/com/dji/sample/manage/service/impl/WorkspaceServiceImpl.java | 56 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 56 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/dji/sample/manage/service/impl/WorkspaceServiceImpl.java b/src/main/java/com/dji/sample/manage/service/impl/WorkspaceServiceImpl.java
index b90d262..3b19e78 100644
--- a/src/main/java/com/dji/sample/manage/service/impl/WorkspaceServiceImpl.java
+++ b/src/main/java/com/dji/sample/manage/service/impl/WorkspaceServiceImpl.java
@@ -1,7 +1,11 @@
package com.dji.sample.manage.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.dji.sample.common.error.CommonErrorEnum;
+import com.dji.sample.common.model.Pagination;
+import com.dji.sample.common.model.PaginationData;
import com.dji.sample.component.mqtt.model.*;
import com.dji.sample.component.mqtt.service.IMessageSenderService;
import com.dji.sample.manage.dao.IWorkspaceMapper;
@@ -18,8 +22,11 @@
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.StringUtils;
+import java.util.List;
import java.util.Map;
import java.util.Optional;
+import java.util.UUID;
+import java.util.stream.Collectors;
@Service
@Transactional
@@ -33,6 +40,35 @@
@Autowired
private IMessageSenderService messageSenderService;
+
+ @Override
+ public PaginationData<WorkspaceDTO> selectWorkspace(long page, long pageSize) {
+ Page<WorkspaceEntity> entityPage = mapper.selectPage(
+ new Page<>(page, pageSize),
+ new QueryWrapper<>());
+
+ List<WorkspaceDTO> list = entityPage.getRecords()
+ .stream()
+ .map(this::entityConvertToDto)
+ .collect(Collectors.toList());
+ return new PaginationData<>(list, new Pagination(entityPage));
+ }
+
+ @Override
+ public Boolean createWorkspace(WorkspaceDTO dto) {
+ dto.setWorkspaceId(UUID.randomUUID().toString());
+ return mapper.insert(dtoConvertToEntity(dto)) > 0;
+ }
+
+ @Override
+ public Boolean deleteWorkspaceById(Integer id) {
+ return mapper.deleteById(id) > 0;
+ }
+
+ @Override
+ public Boolean updateWorkspaceById(WorkspaceDTO dto) {
+ return mapper.updateById(dtoConvertToEntity(dto)) > 0;
+ }
@Override
public Optional<WorkspaceDTO> getWorkspaceByWorkspaceId(String workspaceId) {
@@ -77,6 +113,12 @@
messageSenderService.publish(topic, builder.build());
}
+ @Override
+ public WorkspaceEntity getWorkspaceById(int id) {
+ WorkspaceEntity entity=mapper.selectById(id);
+ return entity;
+ }
+
/**
* Convert database entity objects into workspace data transfer object.
* @param entity
@@ -95,4 +137,18 @@
.bindCode(entity.getBindCode())
.build();
}
+
+ private WorkspaceEntity dtoConvertToEntity(WorkspaceDTO dto) {
+ if (dto == null) {
+ return null;
+ }
+ return WorkspaceEntity.builder()
+ .id(dto.getId())
+ .workspaceId(dto.getWorkspaceId())
+ .platformName(dto.getPlatformName())
+ .workspaceDesc(dto.getWorkspaceDesc())
+ .workspaceName(dto.getWorkspaceName())
+ .bindCode(dto.getBindCode())
+ .build();
+ }
}
--
Gitblit v1.9.3