|
|
|
@ -7,6 +7,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; |
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|
|
|
import com.youlai.boot.common.constant.CommonConstants; |
|
|
|
import com.youlai.boot.common.exception.BusinessException; |
|
|
|
import com.youlai.boot.common.util.CoordinateTransformUtils; |
|
|
|
import com.youlai.boot.common.util.FileUtils; |
|
|
|
import com.youlai.boot.common.util.JavaVCUtils; |
|
|
|
@ -18,6 +19,7 @@ import com.youlai.boot.mini.converter.MiniStrayAnimalConverter; |
|
|
|
import com.youlai.boot.mini.mapper.MiniStrayAnimalMapper; |
|
|
|
import com.youlai.boot.mini.mapper.MiniStrayAnimalNoteMapper; |
|
|
|
import com.youlai.boot.mini.mapper.MiniStrayAnimalNoteMediaMapper; |
|
|
|
import com.youlai.boot.mini.model.dto.DeleteStrayAnimalNoteMediaDTO; |
|
|
|
import com.youlai.boot.mini.model.enums.AnimalNoteMediaTypeEnum; |
|
|
|
import com.youlai.boot.mini.model.entity.MiniStrayAnimal; |
|
|
|
import com.youlai.boot.mini.model.entity.MiniStrayAnimalNote; |
|
|
|
@ -26,6 +28,7 @@ import com.youlai.boot.mini.model.form.StrayAnimalForm; |
|
|
|
import com.youlai.boot.mini.service.StrayAnimalService; |
|
|
|
import lombok.RequiredArgsConstructor; |
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
import org.apache.commons.collections4.CollectionUtils; |
|
|
|
import org.apache.commons.io.FilenameUtils; |
|
|
|
import org.locationtech.jts.geom.Coordinate; |
|
|
|
import org.locationtech.jts.geom.GeometryFactory; |
|
|
|
@ -37,9 +40,8 @@ import org.springframework.web.multipart.MultipartFile; |
|
|
|
import javax.imageio.ImageIO; |
|
|
|
import java.awt.image.BufferedImage; |
|
|
|
import java.io.File; |
|
|
|
import java.util.Date; |
|
|
|
import java.util.List; |
|
|
|
import java.util.UUID; |
|
|
|
import java.text.MessageFormat; |
|
|
|
import java.util.*; |
|
|
|
|
|
|
|
/** |
|
|
|
* 流浪动物业务实现类 |
|
|
|
@ -71,20 +73,22 @@ public class StrayAnimalServiceImpl extends ServiceImpl<MiniStrayAnimalMapper, M |
|
|
|
MiniStrayAnimalNote note = saveNoteInfo(formData, miniStrayAnimal); |
|
|
|
|
|
|
|
// 4. 处理并保存媒体文件
|
|
|
|
saveMediaFiles(note, images, videos); |
|
|
|
saveMediaFiles(note, images, videos, miniStrayAnimal.getCreateTimestamp()); |
|
|
|
|
|
|
|
// 5. 提交审核
|
|
|
|
|
|
|
|
return miniStrayAnimal.getUuid(); |
|
|
|
} |
|
|
|
|
|
|
|
private void saveMediaFiles(MiniStrayAnimalNote note, List<MultipartFile> images, List<MultipartFile> videos) { |
|
|
|
int sortOrder = 0; |
|
|
|
private void saveMediaFiles(MiniStrayAnimalNote note, List<MultipartFile> images, List<MultipartFile> videos, long currentTimestamp) { |
|
|
|
long sortOrder = currentTimestamp; |
|
|
|
// 处理图片
|
|
|
|
if (images != null) { |
|
|
|
for (MultipartFile image : images) { |
|
|
|
try { |
|
|
|
String objectName = "animal_note/" |
|
|
|
+ note.getId() + "/" |
|
|
|
+ note.getCreateTimestamp() + RandomNumberUtils.createRandomLowerLetterAndNumber(8) |
|
|
|
+ currentTimestamp + RandomNumberUtils.createRandomLowerLetterAndNumber(8) |
|
|
|
+ "." |
|
|
|
+ FilenameUtils.getExtension(image.getOriginalFilename()); |
|
|
|
String url = aliyunFileService.uploadFile(objectName, image.getInputStream()); |
|
|
|
@ -98,8 +102,8 @@ public class StrayAnimalServiceImpl extends ServiceImpl<MiniStrayAnimalMapper, M |
|
|
|
miniStrayAnimalNoteMedia.setWidth(imageInfo.getWidth()); |
|
|
|
miniStrayAnimalNoteMedia.setHeight(imageInfo.getHeight()); |
|
|
|
miniStrayAnimalNoteMedia.setSortOrder(sortOrder++); |
|
|
|
miniStrayAnimalNoteMedia.setCreateTimestamp(note.getCreateTimestamp()); |
|
|
|
miniStrayAnimalNoteMedia.setCreateTime(new Date(miniStrayAnimalNoteMedia.getCreateTimestamp())); |
|
|
|
miniStrayAnimalNoteMedia.setCreateTimestamp(currentTimestamp); |
|
|
|
miniStrayAnimalNoteMedia.setCreateTime(new Date(currentTimestamp)); |
|
|
|
miniStrayAnimalNoteMedia.setCreateBy(note.getMiniUserId()); |
|
|
|
|
|
|
|
int result = miniStrayAnimalNoteMediaMapper.insert(miniStrayAnimalNoteMedia); |
|
|
|
@ -114,7 +118,7 @@ public class StrayAnimalServiceImpl extends ServiceImpl<MiniStrayAnimalMapper, M |
|
|
|
String tmpPath = System.getProperty("user.dir") + "/tmp"; |
|
|
|
for (MultipartFile video : videos) { |
|
|
|
try { |
|
|
|
String fileName = note.getCreateTimestamp() + RandomNumberUtils.createRandomLowerLetterAndNumber(8); |
|
|
|
String fileName = currentTimestamp + RandomNumberUtils.createRandomLowerLetterAndNumber(8); |
|
|
|
String objectName = "animal_note/" |
|
|
|
+ note.getId() + "/" |
|
|
|
+ fileName |
|
|
|
@ -128,8 +132,8 @@ public class StrayAnimalServiceImpl extends ServiceImpl<MiniStrayAnimalMapper, M |
|
|
|
miniStrayAnimalNoteMedia.setSourceUrl(url); |
|
|
|
miniStrayAnimalNoteMedia.setStorageKey(objectName); |
|
|
|
miniStrayAnimalNoteMedia.setSortOrder(sortOrder++); |
|
|
|
miniStrayAnimalNoteMedia.setCreateTimestamp(note.getCreateTimestamp()); |
|
|
|
miniStrayAnimalNoteMedia.setCreateTime(new Date(miniStrayAnimalNoteMedia.getCreateTimestamp())); |
|
|
|
miniStrayAnimalNoteMedia.setCreateTimestamp(currentTimestamp); |
|
|
|
miniStrayAnimalNoteMedia.setCreateTime(new Date(currentTimestamp)); |
|
|
|
miniStrayAnimalNoteMedia.setCreateBy(note.getMiniUserId()); |
|
|
|
//时长
|
|
|
|
FileUtils.saveFile(video, tmpPath, fileName); |
|
|
|
@ -138,7 +142,7 @@ public class StrayAnimalServiceImpl extends ServiceImpl<MiniStrayAnimalMapper, M |
|
|
|
miniStrayAnimalNoteMedia.setDuration((int) Math.ceil(duration)); |
|
|
|
//缩略图
|
|
|
|
BufferedImage thumbnail = JavaVCUtils.getVideoThumbnail(videoPath, 1); |
|
|
|
String thumbnailFileName = note.getCreateTimestamp() + RandomNumberUtils.createRandomLowerLetterAndNumber(8); |
|
|
|
String thumbnailFileName = currentTimestamp + RandomNumberUtils.createRandomLowerLetterAndNumber(8); |
|
|
|
String thumbnailObjectName = "animal_note/" |
|
|
|
+ note.getId() + "/" |
|
|
|
+ thumbnailFileName |
|
|
|
@ -207,27 +211,40 @@ public class StrayAnimalServiceImpl extends ServiceImpl<MiniStrayAnimalMapper, M |
|
|
|
|
|
|
|
private void validateInput(List<MultipartFile> images, List<MultipartFile> videos) { |
|
|
|
// 验证必填图片
|
|
|
|
Assert.notEmpty(images, "需要上传图片"); |
|
|
|
if (images == null || images.isEmpty()) { |
|
|
|
throw new BusinessException("需要上传图片"); |
|
|
|
} |
|
|
|
// 验证图片数量
|
|
|
|
Assert.isTrue( |
|
|
|
images.size() <= CommonConstants.STRAY_ANIMAL_IMAGE_NUM_LIMIT, |
|
|
|
"最多只能上传" + CommonConstants.STRAY_ANIMAL_IMAGE_NUM_LIMIT + "张图片"); |
|
|
|
if (images.size() > CommonConstants.STRAY_ANIMAL_IMAGE_NUM_LIMIT) { |
|
|
|
throw new BusinessException( |
|
|
|
"最多只能上传" + CommonConstants.STRAY_ANIMAL_IMAGE_NUM_LIMIT + "张图片" |
|
|
|
); |
|
|
|
} |
|
|
|
|
|
|
|
// 验证视频数量
|
|
|
|
Assert.isTrue( |
|
|
|
CollUtil.isEmpty(videos) || videos.size() <= CommonConstants.STRAY_ANIMAL_VIDEO_NUM_LIMIT, |
|
|
|
"最多只能上传" + CommonConstants.STRAY_ANIMAL_VIDEO_NUM_LIMIT + "个视频"); |
|
|
|
if (!CollUtil.isEmpty(videos) && videos.size() > CommonConstants.STRAY_ANIMAL_VIDEO_NUM_LIMIT) { |
|
|
|
throw new BusinessException( |
|
|
|
"最多只能上传" + CommonConstants.STRAY_ANIMAL_VIDEO_NUM_LIMIT + "个视频" |
|
|
|
); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
public void updateStrayAnimal(String uuid, StrayAnimalForm formData) { |
|
|
|
public void updateStrayAnimal(String animalUuid, StrayAnimalForm formData) { |
|
|
|
// 校验动物是否存在
|
|
|
|
MiniStrayAnimal animal = miniStrayAnimalMapper.selectOne( |
|
|
|
new LambdaQueryWrapper<MiniStrayAnimal>() |
|
|
|
.eq(MiniStrayAnimal::getUuid, uuid) |
|
|
|
.eq(MiniStrayAnimal::getUuid, animalUuid) |
|
|
|
.eq(MiniStrayAnimal::getDeleted, 0) |
|
|
|
); |
|
|
|
Assert.notNull(animal, "动物不存在"); |
|
|
|
if (animal == null) { |
|
|
|
throw new BusinessException("动物不存在"); |
|
|
|
} |
|
|
|
|
|
|
|
if (1 == animal.getAuditStatus()) { |
|
|
|
throw new BusinessException("审核中无法更改"); |
|
|
|
} |
|
|
|
|
|
|
|
long currentTimestamp = System.currentTimeMillis(); |
|
|
|
|
|
|
|
@ -235,6 +252,7 @@ public class StrayAnimalServiceImpl extends ServiceImpl<MiniStrayAnimalMapper, M |
|
|
|
updateAnimalInfo(animal.getId(), formData, currentTimestamp); |
|
|
|
// 3. 更新笔记信息`
|
|
|
|
updateNoteInfo(animal.getId(), formData, currentTimestamp); |
|
|
|
// 4. 提交审核
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
@ -269,4 +287,93 @@ public class StrayAnimalServiceImpl extends ServiceImpl<MiniStrayAnimalMapper, M |
|
|
|
miniStrayAnimalMapper.updateStrayAnimal(miniStrayAnimal); |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public void deleteMediaSource(DeleteStrayAnimalNoteMediaDTO deleteStrayAnimalNoteMediaDTO) { |
|
|
|
List<String> noteMediaUuidList = deleteStrayAnimalNoteMediaDTO.getNoteMediaUuidList(); |
|
|
|
|
|
|
|
MiniStrayAnimalNote note = miniStrayAnimalNoteMapper.selectOne(new LambdaQueryWrapper<MiniStrayAnimalNote>() |
|
|
|
.eq(MiniStrayAnimalNote::getUuid, deleteStrayAnimalNoteMediaDTO.getNoteUuid())); |
|
|
|
if (note == null) { |
|
|
|
throw new BusinessException("笔记不存在"); |
|
|
|
} |
|
|
|
|
|
|
|
LambdaQueryWrapper<MiniStrayAnimalNoteMedia> queryWrapper = |
|
|
|
new LambdaQueryWrapper<MiniStrayAnimalNoteMedia>() |
|
|
|
.in(MiniStrayAnimalNoteMedia::getUuid, noteMediaUuidList) |
|
|
|
.eq(MiniStrayAnimalNoteMedia::getNoteId, note.getId()) |
|
|
|
.eq(MiniStrayAnimalNoteMedia::getDeleted, 0); |
|
|
|
|
|
|
|
List<MiniStrayAnimalNoteMedia> mediaList = |
|
|
|
miniStrayAnimalNoteMediaMapper.selectList(queryWrapper); |
|
|
|
|
|
|
|
if (CollectionUtils.isNotEmpty(mediaList)) { |
|
|
|
|
|
|
|
// 删除源文件
|
|
|
|
List<String> storageKeyList = mediaList.stream() |
|
|
|
.map(MiniStrayAnimalNoteMedia::getStorageKey) |
|
|
|
.toList(); |
|
|
|
aliyunFileService.deleteMultiFile(storageKeyList); |
|
|
|
|
|
|
|
long currentTimestamp = System.currentTimeMillis(); |
|
|
|
|
|
|
|
// 逻辑删除
|
|
|
|
miniStrayAnimalNoteMediaMapper.update( |
|
|
|
null, |
|
|
|
new LambdaUpdateWrapper<MiniStrayAnimalNoteMedia>() |
|
|
|
.in(MiniStrayAnimalNoteMedia::getUuid, noteMediaUuidList) |
|
|
|
.eq(MiniStrayAnimalNoteMedia::getNoteId, note.getId()) |
|
|
|
.set(MiniStrayAnimalNoteMedia::getDeleted, 1) |
|
|
|
.set(MiniStrayAnimalNoteMedia::getUpdateTimestamp, currentTimestamp) |
|
|
|
.set(MiniStrayAnimalNoteMedia::getUpdateTime, new Date(currentTimestamp)) |
|
|
|
.set(MiniStrayAnimalNoteMedia::getUpdateBy, SecurityUtils.getUserId()) |
|
|
|
); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public void saveMediaSource(String noteMediaUuid, List<MultipartFile> images, List<MultipartFile> videos) { |
|
|
|
if ((images == null || images.isEmpty()) && (videos == null || videos.isEmpty())) { |
|
|
|
throw new BusinessException("需要上传媒体资源"); |
|
|
|
} |
|
|
|
MiniStrayAnimalNote note = miniStrayAnimalNoteMapper.selectOne( |
|
|
|
new LambdaQueryWrapper<MiniStrayAnimalNote>() |
|
|
|
.eq(MiniStrayAnimalNote::getUuid, noteMediaUuid) |
|
|
|
.eq(MiniStrayAnimalNote::getDeleted, 0) |
|
|
|
); |
|
|
|
if (note == null) { |
|
|
|
throw new BusinessException("笔记不存在"); |
|
|
|
} |
|
|
|
|
|
|
|
Long animalId = note.getStrayAnimalId(); |
|
|
|
MiniStrayAnimal miniStrayAnimal = miniStrayAnimalMapper.selectById(animalId); |
|
|
|
if (miniStrayAnimal == null) { |
|
|
|
throw new BusinessException("动物信息不存在"); |
|
|
|
} |
|
|
|
if (1 == miniStrayAnimal.getAuditStatus()){ |
|
|
|
throw new BusinessException("审核中"); |
|
|
|
} |
|
|
|
|
|
|
|
//校验数量有没有超出
|
|
|
|
Map<String, Object> param = new HashMap<>(); |
|
|
|
param.put("noteId", note.getId()); |
|
|
|
|
|
|
|
if (CollectionUtils.isNotEmpty(images)){ |
|
|
|
param.put("mediaType", AnimalNoteMediaTypeEnum.IMAGE.name().toLowerCase()); |
|
|
|
int imagesExist = miniStrayAnimalNoteMediaMapper.getMediaCountByNoteIdAndType(param); |
|
|
|
if (imagesExist+images.size() > CommonConstants.STRAY_ANIMAL_IMAGE_NUM_LIMIT) { |
|
|
|
throw new BusinessException("图片总数不能超过" + CommonConstants.STRAY_ANIMAL_IMAGE_NUM_LIMIT + "张"); |
|
|
|
} |
|
|
|
} |
|
|
|
if (CollectionUtils.isNotEmpty(videos)){ |
|
|
|
param.put("mediaType", AnimalNoteMediaTypeEnum.VIDEO.name().toLowerCase()); |
|
|
|
int videosExist = miniStrayAnimalNoteMediaMapper.getMediaCountByNoteIdAndType(param); |
|
|
|
if(videosExist+videos.size() > CommonConstants.STRAY_ANIMAL_VIDEO_NUM_LIMIT){ |
|
|
|
throw new BusinessException("视频总数不能超过" + CommonConstants.STRAY_ANIMAL_VIDEO_NUM_LIMIT + "个"); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
saveMediaFiles(note, images, videos, System.currentTimeMillis()); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
review512jwy@163.com
1 month ago