diff --git a/backend/src/main/java/com/yfd/platform/config/SecurityConfig.java b/backend/src/main/java/com/yfd/platform/config/SecurityConfig.java index c4d0b605..165beccc 100644 --- a/backend/src/main/java/com/yfd/platform/config/SecurityConfig.java +++ b/backend/src/main/java/com/yfd/platform/config/SecurityConfig.java @@ -65,6 +65,7 @@ public class SecurityConfig { .requestMatchers("/eq/**").permitAll() .requestMatchers("/env/**").permitAll() .requestMatchers("/warn/**").permitAll() + .requestMatchers("/threedroamb/**").permitAll() .requestMatchers("/overview/**").permitAll() .requestMatchers("/wt/**").permitAll() .requestMatchers("/fb/**").permitAll() diff --git a/backend/src/main/java/com/yfd/platform/config/SwaggerConfig.java b/backend/src/main/java/com/yfd/platform/config/SwaggerConfig.java index fc91476f..2e43cdb8 100644 --- a/backend/src/main/java/com/yfd/platform/config/SwaggerConfig.java +++ b/backend/src/main/java/com/yfd/platform/config/SwaggerConfig.java @@ -249,6 +249,15 @@ public class SwaggerConfig { .build(); } + @Bean + public GroupedOpenApi groupThreedRoamApi() { + return GroupedOpenApi.builder() + .group("5.3 三维漫游") + .packagesToScan("com.yfd.platform.qgc_sys.threedRoam.controller") + .build(); + } + + @Bean public GroupedOpenApi groupLygkApi() { return GroupedOpenApi.builder() diff --git a/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/controller/MsThreedRoamMController.java b/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/controller/MsThreedRoamMController.java new file mode 100644 index 00000000..6583e97e --- /dev/null +++ b/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/controller/MsThreedRoamMController.java @@ -0,0 +1,119 @@ +package com.yfd.platform.qgc_sys.threedRoam.controller; + +import cn.hutool.core.util.StrUtil; +import com.yfd.platform.common.DataSourceRequest; +import com.yfd.platform.common.DataSourceResult; +import com.yfd.platform.common.exception.BizException; +import com.yfd.platform.config.ResponseResult; +import com.yfd.platform.qgc_sys.threedRoam.domain.MsThreedRoamMEntity; +import com.yfd.platform.qgc_sys.threedRoam.dto.MsThreedRoamBVO; +import com.yfd.platform.qgc_sys.threedRoam.dto.MsThreedRoamMVO; +import com.yfd.platform.qgc_sys.threedRoam.service.IMsThreedRoamMService; +import io.swagger.v3.oas.annotations.Operation; +import io.swagger.v3.oas.annotations.tags.Tag; +import jakarta.annotation.Resource; +import jakarta.servlet.http.HttpServletResponse; +import org.apache.poi.xssf.usermodel.XSSFRow; +import org.apache.poi.xssf.usermodel.XSSFSheet; +import org.apache.poi.xssf.usermodel.XSSFWorkbook; +import org.springframework.web.bind.annotation.*; +import org.springframework.web.multipart.MultipartFile; + +import java.io.OutputStream; +import java.net.URLEncoder; + +/** + * 三维漫游数据主表控制器 + * + * @author migration + */ +@RestController +@RequestMapping("/threedroamb") +@Tag(name = "三维漫游数据主表控制器") +public class MsThreedRoamMController { + + @Resource + private IMsThreedRoamMService msThreedRoamMService; + + @PostMapping("/GetKendoListCust") + @Operation(summary = "条件过滤数据列表") + public ResponseResult getKendoListCust(@RequestBody DataSourceRequest dataSourceRequest) { + DataSourceResult result = msThreedRoamMService.getKendoListCustReturn(dataSourceRequest); + return ResponseResult.successData(result); + } + + @PostMapping("/save") + @Operation(summary = "保存三维漫游数据") + public ResponseResult save(@RequestBody MsThreedRoamMVO vo) { + if (msThreedRoamMService.save(vo)) { + return ResponseResult.success(); + } else { + return ResponseResult.error("三维漫游数据保存失败"); + } + } + + @GetMapping("/getThreedRoamDetails") + @Operation(summary = "获取三维漫游数据详情") + public ResponseResult getThreedRoamDetails(@RequestParam("id") String id) { + return ResponseResult.successData(msThreedRoamMService.getThreedRoamDetails(id)); + } + + @GetMapping("/delete") + @Operation(summary = "删除三维漫游数据") + public ResponseResult delete(@RequestParam("id") String id) { + if (msThreedRoamMService.delete(id)) { + return ResponseResult.success(); + } else { + return ResponseResult.error("三维漫游数据删除失败"); + } + } + + @PostMapping("/getThreedRoamData") + @Operation(summary = "三维漫游数据") + public MsThreedRoamBVO getThreedRoamData(@RequestBody DataSourceRequest dataSourceRequest) { + return msThreedRoamMService.getThreedRoamData(dataSourceRequest); + } + + @PostMapping("/export") + @Operation(summary = "导出三维漫游数据模板") + public void export(HttpServletResponse response) { + try { + String fileName = "三维漫游数据模板"; + + XSSFWorkbook workBook = new XSSFWorkbook(); + XSSFSheet sheet = workBook.createSheet(); + workBook.setSheetName(0, "三维漫游数据模板"); + + XSSFRow row = sheet.createRow(0); + row.createCell(0).setCellValue("飞行路径Code"); + row.createCell(1).setCellValue("飞行路径名称"); + row.createCell(2).setCellValue("经度\u00B0(0-180\u00B0)"); + row.createCell(3).setCellValue("纬度\u00B0(0-90\u00B0)"); + row.createCell(4).setCellValue("高程(m)(小于10000m)"); + row.createCell(5).setCellValue("时间(s)(小于100s)"); + row.createCell(6).setCellValue("序号"); + row.createCell(7).setCellValue("里程碑节点编码(电站编码)"); + row.createCell(8).setCellValue("里程碑节点名称(电站名称)"); + + response.setContentType("application/vnd.ms-excel;charset=utf-8"); + response.setHeader("Content-Disposition", "attachment;filename=" + + URLEncoder.encode(fileName, "utf-8") + ".xlsx"); + OutputStream outputStream = response.getOutputStream(); + workBook.write(outputStream); + outputStream.flush(); + outputStream.close(); + } catch (Exception e) { + // ignore + } + } + + @PostMapping("/import") + @Operation(summary = "导入三维漫游数据") + public ResponseResult importExcel(MultipartFile file) { + if (msThreedRoamMService.importData(file)) { + return ResponseResult.success(); + } else { + return ResponseResult.error("导入三维漫游数据失败"); + } + } +} diff --git a/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/domain/MsThreedRoamEntity.java b/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/domain/MsThreedRoamEntity.java new file mode 100644 index 00000000..c7d4a575 --- /dev/null +++ b/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/domain/MsThreedRoamEntity.java @@ -0,0 +1,78 @@ +package com.yfd.platform.qgc_sys.threedRoam.domain; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; + +import java.io.Serializable; +import java.math.BigDecimal; +import java.util.Date; + +/** + * 三维漫游数据表实体（子表） + * + * @author migration + */ +@Data +@TableName("MS_THREEDROAM_B") +public class MsThreedRoamEntity implements Serializable { + + private static final long serialVersionUID = 1L; + + @TableId(type = IdType.ASSIGN_UUID) + @TableField("ID") + private String id; + + @TableField("ROAM_ID") + private String roamId; + + @TableField("CODE") + private String code; + + @TableField("NAME") + private String name; + + @TableField("LGTD") + private BigDecimal lgtd; + + @TableField("LTTD") + private BigDecimal lttd; + + @TableField("DTMEL") + private BigDecimal dtmel; + + @TableField("TIME") + private BigDecimal time; + + @TableField("ORDER_INDEX") + private Integer orderIndex; + + @TableField("STCD") + private String stcd; + + @TableField("STNM") + private String stnm; + + @TableField("RECORD_USER") + private String recordUser; + + @TableField("RECORD_TIME") + private Date recordTime; + + @TableField("MODIFY_USER") + private String modifyUser; + + @TableField("MODIFY_TIME") + private Date modifyTime; + + @TableField("IS_DELETED") + private Integer isDeleted; + + @TableField("DELETE_USER") + private String deleteUser; + + @TableField("DELETE_TIME") + private Date deleteTime; +} diff --git a/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/domain/MsThreedRoamMEntity.java b/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/domain/MsThreedRoamMEntity.java new file mode 100644 index 00000000..2d9d82dc --- /dev/null +++ b/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/domain/MsThreedRoamMEntity.java @@ -0,0 +1,74 @@ +package com.yfd.platform.qgc_sys.threedRoam.domain; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; + +import java.io.Serializable; +import java.util.Date; + +/** + * 三维漫游数据主表实体 + * + * @author migration + */ +@Data +@TableName("MS_THREEDROAMM_B") +public class MsThreedRoamMEntity implements Serializable { + + private static final long serialVersionUID = 1L; + + @TableId(type = IdType.ASSIGN_UUID) + @TableField("ID") + private String id; + + @TableField("CODE") + private String code; + + @TableField("NAME") + private String name; + + @TableField("RVCD") + private String rvcd; + + @TableField("REMARK") + private String remark; + + @TableField("RECORD_USER") + private String recordUser; + + @TableField("RECORD_TIME") + private Date recordTime; + + @TableField("MODIFY_USER") + private String modifyUser; + + @TableField("MODIFY_TIME") + private Date modifyTime; + + @TableField("IS_DELETED") + private Integer isDeleted; + + @TableField("DELETE_USER") + private String deleteUser; + + @TableField("DELETE_TIME") + private Date deleteTime; + + @TableField("BASE_ID") + private String baseId; + + /** 河段名称（非表字段，查询时填充） */ + @TableField(exist = false) + private String rvcdName; + + /** 基地编码（非表字段，查询时填充） */ + @TableField(exist = false) + private String bscd; + + /** 基地名称（非表字段，查询时填充） */ + @TableField(exist = false) + private String bsnm; +} diff --git a/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/dto/MsThreedRoamBVO.java b/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/dto/MsThreedRoamBVO.java new file mode 100644 index 00000000..8c054783 --- /dev/null +++ b/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/dto/MsThreedRoamBVO.java @@ -0,0 +1,27 @@ +package com.yfd.platform.qgc_sys.threedRoam.dto; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +import java.math.BigDecimal; +import java.util.List; + +/** + * 三维漫游飞行路径数据查询结果 VO + */ +@Data +@Schema(description = "三维漫游飞行路径数据") +public class MsThreedRoamBVO { + + @Schema(description = "数据集合 (坐标序列: totalTime, lgtd, lttd, dtmel, ...)") + private List list; + + @Schema(description = "里程碑集合") + private List milestoneList; + + @Schema(description = "流域/编码") + private String code; + + @Schema(description = "总时间") + private BigDecimal totalTime; +} diff --git a/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/dto/MsThreedRoamMVO.java b/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/dto/MsThreedRoamMVO.java new file mode 100644 index 00000000..7fb0a15b --- /dev/null +++ b/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/dto/MsThreedRoamMVO.java @@ -0,0 +1,33 @@ +package com.yfd.platform.qgc_sys.threedRoam.dto; + +import com.yfd.platform.qgc_sys.threedRoam.domain.MsThreedRoamEntity; +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +import java.util.List; + +/** + * 三维漫游数据保存/查询 VO + */ +@Data +@Schema(description = "三维漫游数据") +public class MsThreedRoamMVO { + + @Schema(description = "主键") + private String id; + + @Schema(description = "编码") + private String code; + + @Schema(description = "名称") + private String name; + + @Schema(description = "河段") + private String rvcd; + + @Schema(description = "备注") + private String remark; + + @Schema(description = "漫游数据集合") + private List list; +} diff --git a/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/dto/MsThreedRoamVO.java b/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/dto/MsThreedRoamVO.java new file mode 100644 index 00000000..68972f0a --- /dev/null +++ b/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/dto/MsThreedRoamVO.java @@ -0,0 +1,50 @@ +package com.yfd.platform.qgc_sys.threedRoam.dto; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +import java.util.Date; + +/** + * 三维漫游列表 VO + */ +@Data +@Schema(description = "三维漫游列表") +public class MsThreedRoamVO { + + @Schema(description = "主键") + private String id; + + @Schema(description = "编码") + private String code; + + @Schema(description = "名称") + private String name; + + @Schema(description = "备注") + private String remark; + + @Schema(description = "创建人") + private String recordUser; + + @Schema(description = "更新人") + private String modifyUser; + + @Schema(description = "创建时间") + private Date recordTime; + + @Schema(description = "更新时间") + private Date modifyTime; + + @Schema(description = "河段编码") + private String rvcd; + + @Schema(description = "河段名称") + private String rvcdName; + + @Schema(description = "基地编码") + private String bscd; + + @Schema(description = "基地名称") + private String bsnm; +} diff --git a/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/mapper/MsThreedRoamMMapper.java b/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/mapper/MsThreedRoamMMapper.java new file mode 100644 index 00000000..4ba171ad --- /dev/null +++ b/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/mapper/MsThreedRoamMMapper.java @@ -0,0 +1,12 @@ +package com.yfd.platform.qgc_sys.threedRoam.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.yfd.platform.qgc_sys.threedRoam.domain.MsThreedRoamMEntity; +import org.apache.ibatis.annotations.Mapper; + +/** + * 三维漫游数据主表 Mapper + */ +@Mapper +public interface MsThreedRoamMMapper extends BaseMapper { +} diff --git a/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/mapper/MsThreedRoamMapper.java b/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/mapper/MsThreedRoamMapper.java new file mode 100644 index 00000000..647039d0 --- /dev/null +++ b/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/mapper/MsThreedRoamMapper.java @@ -0,0 +1,30 @@ +package com.yfd.platform.qgc_sys.threedRoam.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.yfd.platform.qgc_sys.threedRoam.domain.MsThreedRoamEntity; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +import java.util.List; + +/** + * 三维漫游数据子表 Mapper + */ +@Mapper +public interface MsThreedRoamMapper extends BaseMapper { + + /** + * 批量插入漫游详细数据 + */ + int batchInsertList(@Param("list") List list); + + /** + * 根据漫游ID删除详细数据 + */ + void deleteTheedRoam(@Param("roamId") String roamId); + + /** + * 查询电站编码和名称（校验里程碑节点是否存在） + */ + MsThreedRoamEntity selectStcd(@Param("stcd") String stcd); +} diff --git a/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/service/IMsThreedRoamMService.java b/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/service/IMsThreedRoamMService.java new file mode 100644 index 00000000..e709d845 --- /dev/null +++ b/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/service/IMsThreedRoamMService.java @@ -0,0 +1,44 @@ +package com.yfd.platform.qgc_sys.threedRoam.service; + +import com.yfd.platform.common.DataSourceRequest; +import com.yfd.platform.common.DataSourceResult; +import com.yfd.platform.qgc_sys.threedRoam.domain.MsThreedRoamMEntity; +import com.yfd.platform.qgc_sys.threedRoam.dto.MsThreedRoamBVO; +import com.yfd.platform.qgc_sys.threedRoam.dto.MsThreedRoamMVO; +import org.springframework.web.multipart.MultipartFile; + +/** + * 三维漫游数据主表 Service 接口 + */ +public interface IMsThreedRoamMService { + + /** + * 条件过滤数据列表（GetKendoListCust） + */ + DataSourceResult getKendoListCustReturn(DataSourceRequest dataSourceRequest); + + /** + * 保存三维漫游数据 + */ + Boolean save(MsThreedRoamMVO vo); + + /** + * 获取三维漫游数据详情 + */ + MsThreedRoamMVO getThreedRoamDetails(String id); + + /** + * 删除三维漫游数据 + */ + Boolean delete(String id); + + /** + * 获取三维漫游飞行路径数据 + */ + MsThreedRoamBVO getThreedRoamData(DataSourceRequest dataSourceRequest); + + /** + * 导入三维漫游数据 + */ + Boolean importData(MultipartFile file); +} diff --git a/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/service/impl/MsThreedRoamMServiceImpl.java b/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/service/impl/MsThreedRoamMServiceImpl.java new file mode 100644 index 00000000..e7602266 --- /dev/null +++ b/backend/src/main/java/com/yfd/platform/qgc_sys/threedRoam/service/impl/MsThreedRoamMServiceImpl.java @@ -0,0 +1,418 @@ +package com.yfd.platform.qgc_sys.threedRoam.service.impl; + +import cn.hutool.core.collection.CollUtil; +import cn.hutool.core.util.StrUtil; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.yfd.platform.common.DataSourceLoadOptionsBase; +import com.yfd.platform.common.DataSourceRequest; +import com.yfd.platform.common.DataSourceResult; +import com.yfd.platform.common.MicroservicDynamicSQLMapper; +import com.yfd.platform.common.exception.BizException; +import com.yfd.platform.qgc_sys.threedRoam.domain.MsThreedRoamEntity; +import com.yfd.platform.qgc_sys.threedRoam.domain.MsThreedRoamMEntity; +import com.yfd.platform.qgc_sys.threedRoam.dto.MsThreedRoamBVO; +import com.yfd.platform.qgc_sys.threedRoam.dto.MsThreedRoamMVO; +import com.yfd.platform.qgc_sys.threedRoam.mapper.MsThreedRoamMMapper; +import com.yfd.platform.qgc_sys.threedRoam.mapper.MsThreedRoamMapper; +import com.yfd.platform.qgc_sys.threedRoam.service.IMsThreedRoamMService; +import com.yfd.platform.utils.QgcQueryWrapperUtil; +import jakarta.annotation.Resource; +import org.apache.poi.xssf.usermodel.XSSFRow; +import org.apache.poi.xssf.usermodel.XSSFSheet; +import org.apache.poi.xssf.usermodel.XSSFWorkbook; +import org.springframework.beans.BeanUtils; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; +import org.springframework.web.multipart.MultipartFile; + +import java.io.IOException; +import java.math.BigDecimal; +import java.util.*; +import java.util.stream.Collectors; + +/** + * 三维漫游数据主表 Service 实现类 + */ +@Service +public class MsThreedRoamMServiceImpl extends ServiceImpl implements IMsThreedRoamMService { + + @Resource + private MicroservicDynamicSQLMapper microservicDynamicSQLMapper; + + @Resource + private MsThreedRoamMapper msThreedRoamMapper; + + @Resource + private MsThreedRoamMMapper msThreedRoamMMapper; + + @Override + public DataSourceResult getKendoListCustReturn(DataSourceRequest dataSourceRequest) { + DataSourceLoadOptionsBase loadOptions = dataSourceRequest == null ? null : dataSourceRequest.toDevRequest(); + + StringBuilder sql = new StringBuilder(); + sql.append("SELECT a.ID, a.CODE, a.NAME, a.RVCD, b.HBRVNM AS rvcdName, a.REMARK, ") + .append("a.RECORD_USER, a.RECORD_TIME, a.MODIFY_USER, a.MODIFY_TIME, ") + .append("c.BASEID AS bscd, c.BASENAME AS bsnm ") + .append("FROM MS_THREEDROAMM_B a ") + .append("LEFT JOIN SD_HBRV_DIC b ON a.RVCD = b.HBRVCD AND b.IS_DELETED = 0 ") + .append("LEFT JOIN SD_HYDROBASE c ON b.BASEID = c.BASEID AND c.IS_DELETED = 0 ") + .append("WHERE a.IS_DELETED = 0"); + + Map paramMap = new HashMap<>(); + String filterSql = buildFilterSql(dataSourceRequest == null ? null : dataSourceRequest.getFilter(), paramMap, new int[]{0}); + if (StrUtil.isNotBlank(filterSql)) { + sql.append(" AND ").append(filterSql); + } + + // 排序 + sql.append(" ORDER BY a.CODE ASC"); + + Page page = loadOptions == null ? null + : QgcQueryWrapperUtil.buildPage(loadOptions, loadOptions.getSkip(), loadOptions.getTake()); + List list = microservicDynamicSQLMapper.pageAllListWithResultType( + page, sql.toString(), paramMap, MsThreedRoamMEntity.class + ); + + DataSourceResult result = new DataSourceResult<>(); + result.setData(list); + result.setTotal(page == null ? list.size() : page.getTotal()); + result.setAggregates(new HashMap<>()); + return result; + } + + /** + * 递归构建过滤 SQL + */ + private String buildFilterSql(com.yfd.platform.common.DataSourceRequest.FilterDescriptor filter, + Map paramMap, int[] indexHolder) { + if (filter == null) return ""; + + List childFilters = filter.getFilters(); + if (CollUtil.isNotEmpty(childFilters)) { + List childConditions = new ArrayList<>(); + for (com.yfd.platform.common.DataSourceRequest.FilterDescriptor child : childFilters) { + String childSql = buildFilterSql(child, paramMap, indexHolder); + if (StrUtil.isNotBlank(childSql)) { + childConditions.add(childSql); + } + } + if (childConditions.isEmpty()) return ""; + String logic = StrUtil.isNotBlank(filter.getLogic()) ? filter.getLogic() : "and"; + String connector = "and".equalsIgnoreCase(logic) ? " AND " : " OR "; + return "(" + String.join(connector, childConditions) + ")"; + } + + String field = filter.getField(); + Object value = filter.getValue(); + String operator = filter.getOperator(); + + if (StrUtil.isBlank(field)) return ""; + + String column = mapToListColumn(field); + if (StrUtil.isBlank(column)) return ""; + + if ("isnull".equalsIgnoreCase(operator)) return column + " IS NULL"; + if ("isnotnull".equalsIgnoreCase(operator)) return column + " IS NOT NULL"; + if (value == null) return ""; + + String paramKey = "t" + indexHolder[0]++; + paramMap.put(paramKey, value); + + if ("eq".equalsIgnoreCase(operator)) { + return column + " = #{map." + paramKey + "}"; + } else if ("neq".equalsIgnoreCase(operator)) { + return column + " != #{map." + paramKey + "}"; + } else if ("contains".equalsIgnoreCase(operator)) { + return column + " LIKE '%' || #{map." + paramKey + "} || '%'"; + } else if ("startswith".equalsIgnoreCase(operator)) { + return column + " LIKE #{map." + paramKey + "} || '%'"; + } else if ("endswith".equalsIgnoreCase(operator)) { + return column + " LIKE '%' || #{map." + paramKey + "}"; + } + return ""; + } + + private String mapToListColumn(String field) { + if (StrUtil.isBlank(field)) return null; + return switch (field) { + case "code" -> "a.CODE"; + case "name" -> "a.NAME"; + case "rvcd" -> "a.RVCD"; + case "remark" -> "a.REMARK"; + default -> null; + }; + } + + @Override + @Transactional(rollbackFor = Exception.class) + public Boolean save(MsThreedRoamMVO vo) { + MsThreedRoamMEntity entity = new MsThreedRoamMEntity(); + BeanUtils.copyProperties(vo, entity); + + // 校验编码是否存在 + if (!checkCodeExist(entity)) { + throw new BizException("该编码已存在"); + } + + boolean result; + if (StrUtil.isNotBlank(entity.getId())) { + result = this.updateById(entity); + } else { + result = this.save(entity); + } + + if (result && CollUtil.isNotEmpty(vo.getList())) { + // 删除旧数据 + msThreedRoamMapper.deleteTheedRoam(entity.getId()); + + // 批量插入新数据 + List batchList = new ArrayList<>(); + List detailList = vo.getList(); + for (int i = 0; i < detailList.size(); i++) { + MsThreedRoamEntity detail = detailList.get(i); + if (StrUtil.isBlank(detail.getStcd())) { + detail.setStcd(""); + } + if (StrUtil.isBlank(detail.getStnm())) { + detail.setStnm(""); + } + detail.setRoamId(entity.getId()); + detail.setCode(vo.getCode()); + detail.setName(vo.getName()); + batchList.add(detail); + + if (batchList.size() == 2000 || i == detailList.size() - 1) { + int fruit = msThreedRoamMapper.batchInsertList(batchList); + if (fruit < 1) { + throw new BizException("保存三维漫游数据失败"); + } + batchList = new ArrayList<>(); + } + } + } + return result; + } + + /** + * 校验编码是否存在（修改时排除自身） + */ + private boolean checkCodeExist(MsThreedRoamMEntity entity) { + QueryWrapper wrapper = new QueryWrapper<>(); + wrapper.eq("CODE", entity.getCode()); + MsThreedRoamMEntity exist = msThreedRoamMMapper.selectOne(wrapper); + if (exist != null && !exist.getId().equals(entity.getId())) { + return false; + } + return true; + } + + @Override + public MsThreedRoamMVO getThreedRoamDetails(String id) { + MsThreedRoamMVO vo = new MsThreedRoamMVO(); + MsThreedRoamMEntity entity = msThreedRoamMMapper.selectById(id); + if (entity != null) { + BeanUtils.copyProperties(entity, vo); + + QueryWrapper wrapper = new QueryWrapper<>(); + wrapper.eq("ROAM_ID", id); + wrapper.orderByAsc("ORDER_INDEX"); + List list = msThreedRoamMapper.selectList(wrapper); + vo.setList(list); + } + return vo; + } + + @Override + @Transactional(rollbackFor = Exception.class) + public Boolean delete(String id) { + // 删除子表数据 + QueryWrapper wrapper = new QueryWrapper<>(); + wrapper.eq("ROAM_ID", id); + List list = msThreedRoamMapper.selectList(wrapper); + if (CollUtil.isNotEmpty(list)) { + msThreedRoamMapper.delete(wrapper); + } + // 删除主表数据 + int result = msThreedRoamMMapper.deleteById(id); + return result > 0; + } + + @Override + public MsThreedRoamBVO getThreedRoamData(DataSourceRequest dataSourceRequest) { + DataSourceLoadOptionsBase loadOptions = dataSourceRequest.toDevRequest(); + String code = QgcQueryWrapperUtil.getFilterFieldValue(loadOptions, "code"); + + MsThreedRoamMEntity entity = msThreedRoamMMapper.selectOne( + new QueryWrapper().eq("CODE", code)); + if (entity == null) { + throw new BizException("该流域没有三维漫游数据"); + } + + QueryWrapper wrapper = new QueryWrapper<>(); + wrapper.eq("ROAM_ID", entity.getId()); + wrapper.orderByAsc("ORDER_INDEX"); + List threedRoamList = msThreedRoamMapper.selectList(wrapper); + + BigDecimal totalTime = BigDecimal.ZERO; + List lists = new ArrayList<>(); + String baseCode = ""; + List milestoneList = new ArrayList<>(); + List stcdList = new ArrayList<>(); + + for (MsThreedRoamEntity detail : threedRoamList) { + totalTime = totalTime.add(detail.getTime().multiply(new BigDecimal("0.2"))); + lists.add(totalTime); + lists.add(detail.getLgtd()); + lists.add(detail.getLttd()); + lists.add(detail.getDtmel()); + baseCode = detail.getCode(); + + if (StrUtil.isNotBlank(detail.getStcd()) && !stcdList.contains(detail.getStnm())) { + stcdList.add(detail.getStnm()); + milestoneList.add(new String[]{detail.getStnm(), totalTime.toString()}); + } + } + + MsThreedRoamBVO vo = new MsThreedRoamBVO(); + vo.setList(lists); + vo.setTotalTime(totalTime); + vo.setCode(baseCode); + vo.setMilestoneList(milestoneList); + return vo; + } + + @Override + public Boolean importData(MultipartFile file) { + if (file == null) { + throw new BizException("请上传文件"); + } + + List list = new ArrayList<>(); + try { + XSSFWorkbook workbook = new XSSFWorkbook(file.getInputStream()); + int sheets = workbook.getNumberOfSheets(); + for (int i = 0; i < sheets; i++) { + XSSFSheet sheet = workbook.getSheetAt(i); + int rows = sheet.getPhysicalNumberOfRows(); + for (int j = 1; j < rows; j++) { + MsThreedRoamEntity detail = new MsThreedRoamEntity(); + XSSFRow row = sheet.getRow(j); + + detail.setCode(row.getCell(0).toString()); + detail.setName(row.getCell(1).toString()); + + double lgtd = Double.parseDouble(row.getCell(2).toString()); + if (lgtd > 180 || lgtd < 0) { + throw new BizException("经度必须在0-180\u00B0之间"); + } + detail.setLgtd(new BigDecimal(row.getCell(2).toString())); + + double lttd = Double.parseDouble(row.getCell(3).toString()); + if (lttd > 90 || lttd < 0) { + throw new BizException("纬度必须在0-90\u00B0之间"); + } + detail.setLttd(new BigDecimal(row.getCell(3).toString())); + + double dtmel = Double.parseDouble(row.getCell(4).toString()); + if (dtmel >= 10000 || dtmel < 0) { + throw new BizException("高程小于10000米"); + } + detail.setDtmel(new BigDecimal(row.getCell(4).toString()).setScale(3, BigDecimal.ROUND_HALF_UP)); + + double time = Double.parseDouble(row.getCell(5).toString()); + if (time >= 100 || time < 0) { + throw new BizException("时间小于100秒"); + } + detail.setTime(new BigDecimal(row.getCell(5).toString()).setScale(1, BigDecimal.ROUND_HALF_UP)); + + int px = (int) Double.parseDouble(row.getCell(6).toString()); + detail.setOrderIndex(px); + + if (row.getCell(7) != null && StrUtil.isNotBlank(row.getCell(7).toString())) { + detail.setStcd(row.getCell(7).toString()); + } else { + detail.setStcd(""); + } + if (row.getCell(8) != null && StrUtil.isNotBlank(row.getCell(8).toString())) { + detail.setStnm(row.getCell(8).toString()); + } else { + detail.setStnm(""); + } + + list.add(detail); + } + } + } catch (IOException e) { + throw new BizException("导入文档解析错误"); + } + + return saveImportData(list); + } + + /** + * 保存导入数据 + */ + @Transactional(rollbackFor = Exception.class) + public Boolean saveImportData(List list) { + Map> collect = list.stream() + .collect(Collectors.groupingBy(MsThreedRoamEntity::getCode)); + + collect.forEach((code, roamList) -> { + MsThreedRoamMEntity entity = msThreedRoamMMapper.selectOne( + new QueryWrapper().eq("CODE", code)); + if (entity == null) { + entity = new MsThreedRoamMEntity(); + entity.setCode(code); + } + entity.setName(roamList.get(0).getName()); + + boolean result; + if (StrUtil.isNotBlank(entity.getId())) { + result = this.updateById(entity); + } else { + result = this.save(entity); + } + + if (result) { + msThreedRoamMapper.deleteTheedRoam(entity.getId()); + + List batchList = new ArrayList<>(); + List stcdExistList = new ArrayList<>(); + List newStcdList = new ArrayList<>(); + + for (int i = 0; i < roamList.size(); i++) { + MsThreedRoamEntity detail = roamList.get(i); + detail.setRoamId(entity.getId()); + + if (StrUtil.isNotBlank(detail.getStcd())) { + if (!stcdExistList.contains(detail.getStcd()) && !newStcdList.contains(detail.getStcd())) { + MsThreedRoamEntity stcdEntity = msThreedRoamMapper.selectStcd(detail.getStcd()); + if (stcdEntity != null) { + stcdExistList.add(detail.getStcd()); + } else { + newStcdList.add(detail.getStcd()); + detail.setStcd(""); + detail.setStnm(""); + } + } else if (newStcdList.contains(detail.getStcd())) { + detail.setStcd(""); + detail.setStnm(""); + } + } + + batchList.add(detail); + if (batchList.size() == 2000 || i == roamList.size() - 1) { + int fruit = msThreedRoamMapper.batchInsertList(batchList); + if (fruit < 1) { + throw new BizException("导入三维漫游数据失败"); + } + batchList = new ArrayList<>(); + } + } + } + }); + return true; + } +} diff --git a/backend/src/main/resources/mapper/qgc_sys/threedRoam/MsThreedRoamMapper.xml b/backend/src/main/resources/mapper/qgc_sys/threedRoam/MsThreedRoamMapper.xml new file mode 100644 index 00000000..2f679b71 --- /dev/null +++ b/backend/src/main/resources/mapper/qgc_sys/threedRoam/MsThreedRoamMapper.xml @@ -0,0 +1,43 @@ + + + + + + INSERT INTO MS_THREEDROAM_B(ROAM_ID, CODE, NAME, LGTD, LTTD, DTMEL, TIME, ORDER_INDEX, STCD, STNM) + SELECT * + FROM ( + + SELECT + #{item.roamId} AS roamId, + #{item.code} AS code, + #{item.name} AS name, + #{item.lgtd} AS lgtd, + #{item.lttd} AS lttd, + #{item.dtmel} AS dtmel, + #{item.time} AS time, + #{item.orderIndex} AS orderIndex, + #{item.stcd} AS stcd, + #{item.stnm} AS stnm + FROM DUAL + + ) + + + + DELETE FROM MS_THREEDROAM_B + + + AND ROAM_ID = #{roamId} + + + + + + +