boor/wanmao-map-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/main'

Browse Source
This commit is contained in:
达富斌
2025-08-17 18:29:42 +08:00
parent 130ff09807 626560d6e2
commit 9c0fe9f7bc
12 changed files with 571 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
yudao-module-farm/src/main/java/cn/iocoder/yudao/module/farm/controller/admin/home/HomeController.java
View File

@@ -21,7 +21,7 @@ import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
* @author: binda
* @date: 2025/8/14 19:43
*/
@Tag(name = "弄成首页")
@Tag(name = "农场首页")
@RestController
@RequestMapping("/farm/home")
@Validated

112
yudao-module-farm/src/main/java/cn/iocoder/yudao/module/farm/dal/dataobject/deviceinfo/DeviceInfoDO.java
View File

@@ -6,9 +6,11 @@ import java.time.LocalDateTime;
import java.time.LocalDateTime;
import java.time.LocalDateTime;
import java.time.LocalDateTime;
import java.util.List;
import com.baomidou.mybatisplus.annotation.*;
import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
import cn.iocoder.yudao.module.farm.framework.util.ImageCollectionUtil;
/**
* 设备信息 DO
@@ -100,17 +102,40 @@ public class DeviceInfoDO extends BaseDO {
*/
private LocalDateTime updatedAt;
/**
* 设备图片
* 设备图片（数据库存储为逗号分隔的字符串）
*/
@TableField(value = "image")
private String image;
/**
* 告警状态图片
* 设备图片集合（业务层使用）
*/
@TableField(exist = false)
private List<String> imageList;
/**
* 告警状态图片（数据库存储为逗号分隔的字符串）
*/
@TableField(value = "alarm_image")
private String alarmImage;
/**
* 离线状态图片
* 告警状态图片集合（业务层使用）
*/
@TableField(exist = false)
private List<String> alarmImageList;
/**
* 离线状态图片（数据库存储为逗号分隔的字符串）
*/
@TableField(value = "offline_image")
private String offlineImage;
/**
* 离线状态图片集合（业务层使用）
*/
@TableField(exist = false)
private List<String> offlineImageList;
/**
* 分类图标
*/
@@ -136,9 +161,16 @@ public class DeviceInfoDO extends BaseDO {
*/
private String edgeInstanceUniqueId;
/**
* 数据快照
* 数据快照（数据库存储为逗号分隔的字符串）
*/
@TableField(value = "data_image")
private String dataImage;
/**
* 数据快照集合（业务层使用）
*/
@TableField(exist = false)
private List<String> dataImageList;
/**
* 基地id
*/
@@ -157,4 +189,76 @@ public class DeviceInfoDO extends BaseDO {
private String plotName;
private String tenantId;
/**
* 获取设备图片集合
*/
public List<String> getImageList() {
if (imageList == null) {
imageList = ImageCollectionUtil.toImageList(this.image);
}
return imageList;
}
/**
* 设置设备图片集合
*/
public void setImageList(List<String> imageList) {
this.imageList = imageList;
this.image = ImageCollectionUtil.toDatabaseString(imageList);
}
/**
* 获取告警状态图片集合
*/
public List<String> getAlarmImageList() {
if (alarmImageList == null) {
alarmImageList = ImageCollectionUtil.toImageList(this.alarmImage);
}
return alarmImageList;
}
/**
* 设置告警状态图片集合
*/
public void setAlarmImageList(List<String> alarmImageList) {
this.alarmImageList = alarmImageList;
this.alarmImage = ImageCollectionUtil.toDatabaseString(alarmImageList);
}
/**
* 获取离线状态图片集合
*/
public List<String> getOfflineImageList() {
if (offlineImageList == null) {
offlineImageList = ImageCollectionUtil.toImageList(this.offlineImage);
}
return offlineImageList;
}
/**
* 设置离线状态图片集合
*/
public void setOfflineImageList(List<String> offlineImageList) {
this.offlineImageList = offlineImageList;
this.offlineImage = ImageCollectionUtil.toDatabaseString(offlineImageList);
}
/**
* 获取数据快照集合
*/
public List<String> getDataImageList() {
if (dataImageList == null) {
dataImageList = ImageCollectionUtil.toImageList(this.dataImage);
}
return dataImageList;
}
/**
* 设置数据快照集合
*/
public void setDataImageList(List<String> dataImageList) {
this.dataImageList = dataImageList;
this.dataImage = ImageCollectionUtil.toDatabaseString(dataImageList);
}
}

29
yudao-module-farm/src/main/java/cn/iocoder/yudao/module/farm/dal/dataobject/pestdiseaseweedlibrary/PestDiseaseWeedLibraryDO.java
View File

@@ -4,8 +4,10 @@ import lombok.*;
import java.time.LocalDateTime;
import java.time.LocalDateTime;
import java.util.List;
import com.baomidou.mybatisplus.annotation.*;
import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
import cn.iocoder.yudao.module.farm.framework.util.ImageCollectionUtil;
/**
* 病虫草害库维护 DO
@@ -44,9 +46,16 @@ public class PestDiseaseWeedLibraryDO extends BaseDO {
*/
private String propose;
/**
* 图片
* 图片（数据库存储为逗号分隔的字符串）
*/
@TableField(value = "images")
private String images;
/**
* 图片集合（业务层使用）
*/
@TableField(exist = false)
private List<String> imageList;
/**
* 0=启用，1=停用
*/
@@ -69,4 +78,22 @@ public class PestDiseaseWeedLibraryDO extends BaseDO {
private String plotName;
private String tenantId;
/**
* 获取图片集合
*/
public List<String> getImageList() {
if (imageList == null) {
imageList = ImageCollectionUtil.toImageList(this.images);
}
return imageList;
}
/**
* 设置图片集合
*/
public void setImageList(List<String> imageList) {
this.imageList = imageList;
this.images = ImageCollectionUtil.toDatabaseString(imageList);
}
}

57
yudao-module-farm/src/main/java/cn/iocoder/yudao/module/farm/dal/dataobject/productmanagement/ProductManagementDO.java
View File

@@ -4,8 +4,10 @@ import lombok.*;
import java.time.LocalDateTime;
import java.time.LocalDateTime;
import java.util.List;
import com.baomidou.mybatisplus.annotation.*;
import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
import cn.iocoder.yudao.module.farm.framework.util.ImageCollectionUtil;
/**
* 商品管理 DO
@@ -44,9 +46,17 @@ public class ProductManagementDO extends BaseDO {
*/
private String packingUnit;
/**
* 商品图片
* 商品图片（数据库存储为逗号分隔的字符串）
*/
@TableField(value = "image")
private String image;
/**
* 商品图片集合（业务层使用）
*/
@TableField(exist = false)
private List<String> imageList;
/**
* 商品介绍
*/
@@ -64,9 +74,16 @@ public class ProductManagementDO extends BaseDO {
*/
private String brandName;
/**
* 商标图片
* 商标图片（数据库存储为逗号分隔的字符串）
*/
@TableField(value = "brand_image")
private String brandImage;
/**
* 商标图片集合（业务层使用）
*/
@TableField(exist = false)
private List<String> brandImageList;
/**
* 商品认证
*/
@@ -89,4 +106,40 @@ public class ProductManagementDO extends BaseDO {
private String plotName;
private String tenantId;
/**
* 获取商品图片集合
*/
public List<String> getImageList() {
if (imageList == null) {
imageList = ImageCollectionUtil.toImageList(this.image);
}
return imageList;
}
/**
* 设置商品图片集合
*/
public void setImageList(List<String> imageList) {
this.imageList = imageList;
this.image = ImageCollectionUtil.toDatabaseString(imageList);
}
/**
* 获取商标图片集合
*/
public List<String> getBrandImageList() {
if (brandImageList == null) {
brandImageList = ImageCollectionUtil.toImageList(this.brandImage);
}
return brandImageList;
}
/**
* 设置商标图片集合
*/
public void setBrandImageList(List<String> brandImageList) {
this.brandImageList = brandImageList;
this.brandImage = ImageCollectionUtil.toDatabaseString(brandImageList);
}
}

29
yudao-module-farm/src/main/java/cn/iocoder/yudao/module/farm/dal/dataobject/specieslibrary/SpeciesLibraryDO.java
View File

@@ -4,8 +4,10 @@ import lombok.*;
import java.time.LocalDateTime;
import java.time.LocalDateTime;
import java.util.List;
import com.baomidou.mybatisplus.annotation.*;
import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
import cn.iocoder.yudao.module.farm.framework.util.ImageCollectionUtil;
/**
* 物种库维护 DO
@@ -48,9 +50,34 @@ public class SpeciesLibraryDO extends BaseDO {
*/
private Integer lifeCycle;
/**
* 图片
* 图片集合（数据库存储为逗号分隔的字符串）
*/
@TableField(value = "image")
private String image;
/**
* 图片集合（业务层使用）
*/
@TableField(exist = false)
private List<String> imageList;
/**
* 获取图片集合
*/
public List<String> getImageList() {
if (imageList == null) {
imageList = ImageCollectionUtil.toImageList(this.image);
}
return imageList;
}
/**
* 设置图片集合
*/
public void setImageList(List<String> imageList) {
this.imageList = imageList;
this.image = ImageCollectionUtil.toDatabaseString(imageList);
}
/**
* 0=启用，1=停用
*/

29
yudao-module-farm/src/main/java/cn/iocoder/yudao/module/farm/dal/dataobject/weatherdisasterlibrary/WeatherDisasterLibraryDO.java
View File

@@ -4,9 +4,11 @@ import lombok.*;
import java.time.LocalDateTime;
import java.time.LocalDateTime;
import java.util.List;
import com.baomidou.mybatisplus.annotation.*;
import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
import cn.iocoder.yudao.module.farm.framework.util.ImageCollectionUtil;
/**
* 气象灾害库维护 DO
@@ -41,9 +43,16 @@ public class WeatherDisasterLibraryDO extends BaseDO {
*/
private String propose;
/**
* 图片
* 图片（数据库存储为逗号分隔的字符串）
*/
@TableField(value = "images")
private String images;
/**
* 图片集合（业务层使用）
*/
@TableField(exist = false)
private List<String> imageList;
/**
* 0=启用，1=停用
*/
@@ -66,4 +75,22 @@ public class WeatherDisasterLibraryDO extends BaseDO {
private String plotName;
private String tenantId;
/**
* 获取图片集合
*/
public List<String> getImageList() {
if (imageList == null) {
imageList = ImageCollectionUtil.toImageList(this.images);
}
return imageList;
}
/**
* 设置图片集合
*/
public void setImageList(List<String> imageList) {
this.imageList = imageList;
this.images = ImageCollectionUtil.toDatabaseString(imageList);
}
}

170
yudao-module-farm/src/main/java/cn/iocoder/yudao/module/farm/framework/util/ImageCollectionUtil.java Normal file
View File

@@ -0,0 +1,170 @@
package cn.iocoder.yudao.module.farm.framework.util;
import cn.hutool.core.util.StrUtil;
import lombok.extern.slf4j.Slf4j;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;
/**
* 图片集合转换工具类
* 用于在数据库字符串（逗号分隔）和Java集合之间转换
*
* @author 芋道源码
*/
@Slf4j
public class ImageCollectionUtil {
/**
* 分隔符
*/
private static final String SEPARATOR = ",";
/**
* 将图片集合转换为数据库存储的字符串
*
* @param imageList 图片集合
* @return 逗号分隔的字符串，如果集合为空则返回null
*/
public static String toDatabaseString(List<String> imageList) {
if (imageList == null || imageList.isEmpty()) {
return null;
}
// 过滤空字符串并去重
List<String> filteredList = imageList.stream()
.filter(StrUtil::isNotBlank)
.distinct()
.collect(Collectors.toList());
if (filteredList.isEmpty()) {
return null;
}
return String.join(SEPARATOR, filteredList);
}
/**
* 将数据库字符串转换为图片集合
*
* @param databaseString 数据库中的字符串
* @return 图片集合，如果字符串为空则返回空集合
*/
public static List<String> toImageList(String databaseString) {
if (StrUtil.isBlank(databaseString)) {
return new ArrayList<>();
}
try {
return Arrays.stream(databaseString.split(SEPARATOR))
.map(String::trim)
.filter(StrUtil::isNotBlank)
.distinct()
.collect(Collectors.toList());
} catch (Exception e) {
log.error("转换图片集合失败，原始字符串: {}", databaseString, e);
return new ArrayList<>();
}
}
/**
* 将单个图片URL转换为集合（兼容旧数据）
*
* @param singleImage 单个图片URL
* @return 图片集合
*/
public static List<String> singleToImageList(String singleImage) {
if (StrUtil.isBlank(singleImage)) {
return new ArrayList<>();
}
// 如果已经是逗号分隔的格式，直接转换
if (singleImage.contains(SEPARATOR)) {
return toImageList(singleImage);
}
// 单个图片，包装成集合
List<String> imageList = new ArrayList<>();
imageList.add(singleImage);
return imageList;
}
/**
* 将图片集合转换为单个图片URL（兼容旧接口）
* 取第一个图片，如果没有则返回null
*
* @param imageList 图片集合
* @return 第一个图片URL或null
*/
public static String imageListToSingle(List<String> imageList) {
if (imageList == null || imageList.isEmpty()) {
return null;
}
return imageList.get(0);
}
/**
* 验证图片集合是否有效
*
* @param imageList 图片集合
* @return 是否有效
*/
public static boolean isValidImageList(List<String> imageList) {
if (imageList == null) {
return false;
}
// 检查是否有空字符串
return imageList.stream().allMatch(StrUtil::isNotBlank);
}
/**
* 获取图片集合的大小
*
* @param imageList 图片集合
* @return 图片数量
*/
public static int getImageCount(List<String> imageList) {
if (imageList == null) {
return 0;
}
return imageList.size();
}
/**
* 添加图片到集合
*
* @param imageList 原图片集合
* @param newImage 新图片URL
* @return 新的图片集合
*/
public static List<String> addImage(List<String> imageList, String newImage) {
if (StrUtil.isBlank(newImage)) {
return imageList != null ? new ArrayList<>(imageList) : new ArrayList<>();
}
List<String> result = imageList != null ? new ArrayList<>(imageList) : new ArrayList<>();
if (!result.contains(newImage)) {
result.add(newImage);
}
return result;
}
/**
* 从集合中移除图片
*
* @param imageList 原图片集合
* @param imageToRemove 要移除的图片URL
* @return 新的图片集合
*/
public static List<String> removeImage(List<String> imageList, String imageToRemove) {
if (imageList == null || StrUtil.isBlank(imageToRemove)) {
return imageList != null ? new ArrayList<>(imageList) : new ArrayList<>();
}
List<String> result = new ArrayList<>(imageList);
result.remove(imageToRemove);
return result;
}
}

8
yudao-module-infra/src/main/java/cn/iocoder/yudao/module/infra/controller/admin/file/FileController.java
View File

@@ -8,6 +8,8 @@ import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.framework.tenant.core.aop.TenantIgnore;
import cn.iocoder.yudao.module.infra.controller.admin.file.vo.file.*;
import cn.iocoder.yudao.module.infra.controller.admin.file.vo.file.FileMultiUploadReqVO;
import cn.iocoder.yudao.module.infra.controller.admin.file.vo.file.FileMultiUploadRespVO;
import cn.iocoder.yudao.module.infra.dal.dataobject.file.FileDO;
import cn.iocoder.yudao.module.infra.service.file.FileService;
import io.swagger.v3.oas.annotations.Operation;
@@ -50,6 +52,12 @@ public class FileController {
uploadReqVO.getDirectory(), file.getContentType()));
}
@PostMapping("/upload-multi")
@Operation(summary = "多文件上传", description = "批量上传多个文件")
public CommonResult<FileMultiUploadRespVO> uploadMultiFiles(@Valid FileMultiUploadReqVO uploadReqVO) throws Exception {
return success(fileService.createFiles(uploadReqVO.getFiles(), uploadReqVO.getDirectory()));
}
@GetMapping("/presigned-url")
@Operation(summary = "获取文件预签名地址", description = "模式二：前端上传文件：用于前端直接上传七牛、阿里云 OSS 等文件存储器")
@Parameters({

32
yudao-module-infra/src/main/java/cn/iocoder/yudao/module/infra/controller/admin/file/vo/file/FileMultiUploadReqVO.java Normal file
View File

@@ -0,0 +1,32 @@
package cn.iocoder.yudao.module.infra.controller.admin.file.vo.file;
import cn.hutool.core.util.StrUtil;
import com.fasterxml.jackson.annotation.JsonIgnore;
import io.swagger.v3.oas.annotations.media.Schema;
import jakarta.validation.constraints.AssertTrue;
import jakarta.validation.constraints.NotEmpty;
import jakarta.validation.constraints.Size;
import lombok.Data;
import org.springframework.web.multipart.MultipartFile;
import java.util.List;
@Schema(description = "管理后台 - 多文件上传 Request VO")
@Data
public class FileMultiUploadReqVO {
@Schema(description = "文件附件列表", requiredMode = Schema.RequiredMode.REQUIRED)
@NotEmpty(message = "文件附件列表不能为空")
@Size(max = 10, message = "最多只能上传10个文件")
private List<MultipartFile> files;
@Schema(description = "文件目录", example = "XXX/YYY")
private String directory;
@AssertTrue(message = "文件目录不正确")
@JsonIgnore
public boolean isDirectoryValid() {
return !StrUtil.containsAny(directory, "..", "/", "\\");
}
}

51
yudao-module-infra/src/main/java/cn/iocoder/yudao/module/infra/controller/admin/file/vo/file/FileMultiUploadRespVO.java Normal file
View File

@@ -0,0 +1,51 @@
package cn.iocoder.yudao.module.infra.controller.admin.file.vo.file;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import java.util.List;
@Schema(description = "管理后台 - 多文件上传 Response VO")
@Data
public class FileMultiUploadRespVO {
@Schema(description = "上传成功的文件列表")
private List<FileUploadResult> successFiles;
@Schema(description = "上传失败的文件列表")
private List<FileUploadResult> failedFiles;
@Schema(description = "总文件数")
private Integer totalCount;
@Schema(description = "成功数量")
private Integer successCount;
@Schema(description = "失败数量")
private Integer failedCount;
@Schema(description = "管理后台 - 文件上传结果")
@Data
public static class FileUploadResult {
@Schema(description = "原始文件名")
private String originalName;
@Schema(description = "文件访问路径")
private String url;
@Schema(description = "文件大小(字节)")
private Long size;
@Schema(description = "文件类型")
private String type;
@Schema(description = "错误信息")
private String errorMessage;
@Schema(description = "是否上传成功")
private Boolean success;
}
}

11
yudao-module-infra/src/main/java/cn/iocoder/yudao/module/infra/service/file/FileService.java
View File

@@ -4,8 +4,10 @@ import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.module.infra.controller.admin.file.vo.file.FileCreateReqVO;
import cn.iocoder.yudao.module.infra.controller.admin.file.vo.file.FilePageReqVO;
import cn.iocoder.yudao.module.infra.controller.admin.file.vo.file.FilePresignedUrlRespVO;
import cn.iocoder.yudao.module.infra.controller.admin.file.vo.file.FileMultiUploadRespVO;
import cn.iocoder.yudao.module.infra.dal.dataobject.file.FileDO;
import jakarta.validation.constraints.NotEmpty;
import org.springframework.web.multipart.MultipartFile;
import java.util.List;
@@ -36,6 +38,15 @@ public interface FileService {
String createFile(@NotEmpty(message = "文件内容不能为空") byte[] content,
String name, String directory, String type);
/**
* 批量上传文件
*
* @param files 文件列表
* @param directory 目录，允许空
* @return 多文件上传结果
*/
FileMultiUploadRespVO createFiles(List<MultipartFile> files, String directory);
/**
* 生成文件预签名地址信息
*

53
yudao-module-infra/src/main/java/cn/iocoder/yudao/module/infra/service/file/FileServiceImpl.java
View File

@@ -2,14 +2,20 @@ package cn.iocoder.yudao.module.infra.service.file;
import cn.hutool.core.date.LocalDateTimeUtil;
import cn.hutool.core.io.FileUtil;
import cn.hutool.core.io.IoUtil;
import cn.hutool.core.lang.Assert;
import cn.hutool.core.util.StrUtil;
import cn.hutool.crypto.digest.DigestUtil;
import org.springframework.web.multipart.MultipartFile;
import java.util.ArrayList;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.module.infra.controller.admin.file.vo.file.FileCreateReqVO;
import cn.iocoder.yudao.module.infra.controller.admin.file.vo.file.FilePageReqVO;
import cn.iocoder.yudao.module.infra.controller.admin.file.vo.file.FilePresignedUrlRespVO;
import cn.iocoder.yudao.module.infra.controller.admin.file.vo.file.FileMultiUploadRespVO;
import cn.iocoder.yudao.module.infra.dal.dataobject.file.FileDO;
import cn.iocoder.yudao.module.infra.dal.mysql.file.FileMapper;
import cn.iocoder.yudao.module.infra.framework.file.core.client.FileClient;
@@ -36,13 +42,13 @@ public class FileServiceImpl implements FileService {
/**
* 上传文件的前缀，是否包含日期（yyyyMMdd）
*
* <p>
* 目的：按照日期，进行分目录
*/
static boolean PATH_PREFIX_DATE_ENABLE = true;
/**
* 上传文件的后缀，是否包含时间戳
*
* <p>
* 目的：保证文件的唯一性，避免覆盖
* 定制：可按需调整成 UUID、或者其他方式
*/
@@ -92,6 +98,49 @@ public class FileServiceImpl implements FileService {
return url;
}
@Override
@SneakyThrows
public FileMultiUploadRespVO createFiles(List<MultipartFile> files, String directory) {
FileMultiUploadRespVO result = new FileMultiUploadRespVO();
List<FileMultiUploadRespVO.FileUploadResult> successFiles = new ArrayList<>();
List<FileMultiUploadRespVO.FileUploadResult> failedFiles = new ArrayList<>();
for (MultipartFile file : files) {
FileMultiUploadRespVO.FileUploadResult fileResult = new FileMultiUploadRespVO.FileUploadResult();
fileResult.setOriginalName(file.getOriginalFilename());
fileResult.setSize(file.getSize());
fileResult.setType(file.getContentType());
try {
// 上传文件
byte[] content = IoUtil.readBytes(file.getInputStream());
String url = createFile(content, file.getOriginalFilename(), directory, file.getContentType());
// 设置成功结果
fileResult.setUrl(url);
fileResult.setSuccess(true);
successFiles.add(fileResult);
FileClient client = fileConfigService.getMasterFileClient();
fileMapper.insert(new FileDO().setConfigId(client.getId())
.setName(fileResult.getOriginalName()).setUrl(url)
.setType(fileResult.getType()).setSize((int) file.getSize()));
} catch (Exception e) {
// 设置失败结果
fileResult.setSuccess(false);
fileResult.setErrorMessage(e.getMessage());
failedFiles.add(fileResult);
}
}
// 设置统计信息
result.setSuccessFiles(successFiles);
result.setFailedFiles(failedFiles);
result.setTotalCount(files.size());
result.setSuccessCount(successFiles.size());
result.setFailedCount(failedFiles.size());
return result;
}
@VisibleForTesting
String generateUploadPath(String name, String directory) {
// 1. 生成前缀、后缀