luhaojie/agricultural-monitoring-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

河流，水库站点基本信息管理，bug修复等

Browse Source
This commit is contained in:
mi9688
2024-10-23 18:49:12 +08:00
parent 226370792b
commit 9912eb5671
35 changed files with 1235 additions and 351 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/domain/GGroups.java
View File

@ -72,12 +72,9 @@ private static final long serialVersionUID = 1L;
/** 显示顺序 */
private Integer orderNum;
/** 子组 */
private List<GGroups> children = new ArrayList<>();
/**节点类型：0组，1站点 */
private Integer nodeType= 0;
@ -87,4 +84,5 @@ private static final long serialVersionUID = 1L;
/**站点类型 */
private String siteType;
}

5
fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/domain/GSiteInfo.java → fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/domain/GSiteMonitorInfo.java
View File

@ -4,9 +4,6 @@ import java.math.BigDecimal;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.*;
import lombok.experimental.SuperBuilder;
import org.apache.commons.lang3.builder.ToStringBuilder;
import org.apache.commons.lang3.builder.ToStringStyle;
import com.fastbee.common.annotation.Excel;
import com.fastbee.common.core.domain.BaseEntity;
@ -21,7 +18,7 @@ import com.fastbee.common.core.domain.BaseEntity;
@Data
@NoArgsConstructor
@AllArgsConstructor
public class GSiteInfo extends BaseEntity
public class GSiteMonitorInfo extends BaseEntity
{
private static final long serialVersionUID = 1L;

217
fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/domain/GSiteReservoirInfo.java Normal file
View File

@ -0,0 +1,217 @@
package com.fastbee.ggroup.domain;
import java.math.BigDecimal;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import org.apache.commons.lang3.builder.ToStringBuilder;
import org.apache.commons.lang3.builder.ToStringStyle;
import com.fastbee.common.annotation.Excel;
import com.fastbee.common.core.domain.BaseEntity;
/**
* 水库站点基础信息对象 g_site_reservoir_info
*
* @author kerwincui
* @date 2024-10-23
*/
@ApiModel(value = "GSiteReservoirInfo",description = "水库站点基础信息 g_site_reservoir_info")
@Data
@EqualsAndHashCode(callSuper = true)
public class GSiteReservoirInfo extends BaseEntity
{
private static final long serialVersionUID = 1L;
/** 主键ID */
private Long id;
/** 工程名称 */
@Excel(name = "工程名称")
@ApiModelProperty("工程名称")
private String projectName;
/** 地理坐标 */
@Excel(name = "地理坐标")
@ApiModelProperty("地理坐标")
private String geoCoordinates;
/** 工程位置 */
@Excel(name = "工程位置")
@ApiModelProperty("工程位置")
private String projectLocation;
/** 所在流域 */
@Excel(name = "所在流域")
@ApiModelProperty("所在流域")
private String drainageBasin;
/** 所在水系 */
@Excel(name = "所在水系")
@ApiModelProperty("所在水系")
private String drainageSystem;
/** 所在河流 */
@Excel(name = "所在河流")
@ApiModelProperty("所在河流")
private String river;
/** 所在乡镇/村 */
@Excel(name = "所在乡镇/村")
@ApiModelProperty("所在乡镇/村")
private String townVillage;
/** 水库类型 */
@Excel(name = "水库类型")
@ApiModelProperty("水库类型")
private String reservoirType;
/** 水库功能 */
@Excel(name = "水库功能")
@ApiModelProperty("水库功能")
private String reservoirFunction;
/** 工程建设情况 */
@Excel(name = "工程建设情况")
@ApiModelProperty("工程建设情况")
private String constructionStatus;
/** 水库级别 */
@Excel(name = "水库级别")
@ApiModelProperty("水库级别")
private String reservoirLevel;
/** 主坝级别 */
@Excel(name = "主坝级别")
@ApiModelProperty("主坝级别")
private String mainDamLevel;
/** 主坝尺寸坝高 */
@Excel(name = "主坝尺寸坝高")
@ApiModelProperty("主坝尺寸坝高")
private BigDecimal mainDamHeight;
/** 主坝尺寸坝长 */
@Excel(name = "主坝尺寸坝长")
@ApiModelProperty("主坝尺寸坝长")
private BigDecimal mainDamLength;
/** 坝顶高程 */
@Excel(name = "坝顶高程")
@ApiModelProperty("坝顶高程")
private BigDecimal damCrestElevation;
/** 正常蓄水位 */
@Excel(name = "正常蓄水位")
@ApiModelProperty("正常蓄水位")
private BigDecimal normalStorageLevel;
/** 死水位 */
@Excel(name = "死水位")
@ApiModelProperty("死水位")
private BigDecimal deadWaterLevel;
/** 总库容 */
@Excel(name = "总库容")
@ApiModelProperty("总库容")
private Long totalCapacity;
/** 兴利库容 */
@Excel(name = "兴利库容")
@ApiModelProperty("兴利库容")
private Long beneficialCapacity;
/** 死库容 */
@Excel(name = "死库容")
@ApiModelProperty("死库容")
private Long deadStorage;
/** 正常蓄水位相应水面面积 */
@Excel(name = "正常蓄水位相应水面面积")
@ApiModelProperty("正常蓄水位相应水面面积")
private Integer normalStorageArea;
/** 设计年供水量 */
@Excel(name = "设计年供水量")
@ApiModelProperty("设计年供水量")
private Long annualSupplyCapacity;
/** 行政责任人 */
@Excel(name = "行政责任人")
@ApiModelProperty("行政责任人")
private String administrativeResponsible;
/** 行政责任人单位名称 */
@Excel(name = "行政责任人单位名称")
@ApiModelProperty("行政责任人单位名称")
private String administrativeUnitName;
/** 行政责任人职务 */
@Excel(name = "行政责任人职务")
@ApiModelProperty("行政责任人职务")
private String administrativePosition;
/** 行政责任人电话 */
@Excel(name = "行政责任人电话")
@ApiModelProperty("行政责任人电话")
private String administrativePhone;
/** 技术责任人 */
@Excel(name = "技术责任人")
@ApiModelProperty("技术责任人")
private String technicalResponsible;
/** 技术责任人单位名称 */
@Excel(name = "技术责任人单位名称")
@ApiModelProperty("技术责任人单位名称")
private String technicalUnitName;
/** 技术责任人职务 */
@Excel(name = "技术责任人职务")
@ApiModelProperty("技术责任人职务")
private String technicalPosition;
/** 技术责任人电话 */
@Excel(name = "技术责任人电话")
@ApiModelProperty("技术责任人电话")
private String technicalPhone;
/** 巡查责任人 */
@Excel(name = "巡查责任人")
@ApiModelProperty("巡查责任人")
private String inspectionResponsible;
/** 巡查责任人单位名称 */
@Excel(name = "巡查责任人单位名称")
@ApiModelProperty("巡查责任人单位名称")
private String inspectionUnitName;
/** 巡查责任人职务 */
@Excel(name = "巡查责任人职务")
@ApiModelProperty("巡查责任人职务")
private String inspectionPosition;
/** 巡查责任人电话 */
@Excel(name = "巡查责任人电话")
@ApiModelProperty("巡查责任人电话")
private String inspectionPhone;
/** 创建人 */
@Excel(name = "创建人")
@ApiModelProperty("创建人")
private String createdBy;
/** 更新人 */
@Excel(name = "更新人")
@ApiModelProperty("更新人")
private String updatedBy;
/** 删除标志（0:正常,2:删除） */
private Integer delFlag;
/** 所属站点ID */
@Excel(name = "所属站点ID")
@ApiModelProperty("所属站点ID")
private Long siteId;
}

4
fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/domain/GRiverInfo.java → fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/domain/GSiteRiverInfo.java
View File

@ -4,8 +4,6 @@ import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import org.apache.commons.lang3.builder.ToStringBuilder;
import org.apache.commons.lang3.builder.ToStringStyle;
import com.fastbee.common.annotation.Excel;
import com.fastbee.common.core.domain.BaseEntity;
@ -18,7 +16,7 @@ import com.fastbee.common.core.domain.BaseEntity;
@ApiModel(value = "GRiverInfo",description = "河流基础信息 g_river_info")
@Data
@EqualsAndHashCode(callSuper = true)
public class GRiverInfo extends BaseEntity
public class GSiteRiverInfo extends BaseEntity
{
private static final long serialVersionUID = 1L;

15
fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/enums/SiteTypeCategoryEnum.java
View File

@ -12,7 +12,7 @@ public enum SiteTypeCategoryEnum {
//水利设施与管理
WATER_MANAGEMENT("水利设施与管理"),
//检测站
DETECTION_STATION("检测站"),
DETECTION_STATION("监测站"),
//公共设施
PUBLIC_FACILITIES("公共设施"),
//报警事件
@ -20,7 +20,6 @@ public enum SiteTypeCategoryEnum {
//其他
OTHER("其他");
private final String name;
SiteTypeCategoryEnum(String name){this.name = name;}
@ -32,4 +31,16 @@ public enum SiteTypeCategoryEnum {
}
return null;
}
/**
* 判断变量值是否包含在枚举值里面
*/
public static boolean contains(String value) {
for (SiteTypeCategoryEnum siteTypeCategoryEnum : SiteTypeCategoryEnum.values()) {
if (siteTypeCategoryEnum.getName().equals(value)) {
return true;
}
}
return false;
}
}

18
fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/mapper/GSiteInfoMapper.java → fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/mapper/GSiteMonitorInfoMapper.java
View File

@ -3,7 +3,7 @@ package com.fastbee.ggroup.mapper;
import java.util.List;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.fastbee.ggroup.domain.GSiteInfo;
import com.fastbee.ggroup.domain.GSiteMonitorInfo;
import org.apache.ibatis.annotations.Mapper;
/**
@ -13,7 +13,7 @@ import org.apache.ibatis.annotations.Mapper;
* &#064;date 2024-10-10
*/
@Mapper
public interface GSiteInfoMapper extends BaseMapper<GSiteInfo>
public interface GSiteMonitorInfoMapper extends BaseMapper<GSiteMonitorInfo>
{
/**
* 查询站点基础信息
@ -21,31 +21,31 @@ public interface GSiteInfoMapper extends BaseMapper<GSiteInfo>
* @param id 站点基础信息主键
* @return 站点基础信息
*/
GSiteInfo selectGSiteInfoById(Long id);
GSiteMonitorInfo selectGSiteInfoBySiteId(Long id);
/**
* 查询站点基础信息列表
*
* @param gSiteInfo 站点基础信息
* @param gSiteMonitorInfo 站点基础信息
* @return 站点基础信息集合
*/
List<GSiteInfo> selectGSiteInfoList(GSiteInfo gSiteInfo);
List<GSiteMonitorInfo> selectGSiteInfoList(GSiteMonitorInfo gSiteMonitorInfo);
/**
* 新增站点基础信息
*
* @param gSiteInfo 站点基础信息
* @param gSiteMonitorInfo 站点基础信息
* @return 结果
*/
int insertGSiteInfo(GSiteInfo gSiteInfo);
int insertGSiteInfo(GSiteMonitorInfo gSiteMonitorInfo);
/**
* 修改站点基础信息
*
* @param gSiteInfo 站点基础信息
* @param gSiteMonitorInfo 站点基础信息
* @return 结果
*/
int updateGSiteInfo(GSiteInfo gSiteInfo);
int updateGSiteInfo(GSiteMonitorInfo gSiteMonitorInfo);
/**
* 删除站点基础信息

63
fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/mapper/GSiteReservoirInfoMapper.java Normal file
View File

@ -0,0 +1,63 @@
package com.fastbee.ggroup.mapper;
import java.util.List;
import com.fastbee.ggroup.domain.GSiteReservoirInfo;
import org.apache.ibatis.annotations.Mapper;
/**
* 水库站点基础信息Mapper接口
*
* @author kerwincui
* @date 2024-10-23
*/
@Mapper
public interface GSiteReservoirInfoMapper
{
/**
* 查询水库站点基础信息
*
* @param siteId 水库基础信息所属站点id
* @return 水库站点基础信息
*/
public GSiteReservoirInfo selectGSiteReservoirInfoBySiteId(Long siteId);
/**
* 查询水库站点基础信息列表
*
* @param gSiteReservoirInfo 水库站点基础信息
* @return 水库站点基础信息集合
*/
public List<GSiteReservoirInfo> selectGSiteReservoirInfoList(GSiteReservoirInfo gSiteReservoirInfo);
/**
* 新增水库站点基础信息
*
* @param gSiteReservoirInfo 水库站点基础信息
* @return 结果
*/
public int insertGSiteReservoirInfo(GSiteReservoirInfo gSiteReservoirInfo);
/**
* 修改水库站点基础信息
*
* @param gSiteReservoirInfo 水库站点基础信息
* @return 结果
*/
public int updateGSiteReservoirInfo(GSiteReservoirInfo gSiteReservoirInfo);
/**
* 删除水库站点基础信息
*
* @param id 水库站点基础信息主键
* @return 结果
*/
public int deleteGSiteReservoirInfoById(Long id);
/**
* 批量删除水库站点基础信息
*
* @param ids 需要删除的数据主键集合
* @return 结果
*/
public int deleteGSiteReservoirInfoByIds(Long[] ids);
}

21
fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/mapper/GRiverInfoMapper.java → fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/mapper/GSiteRiverInfoMapper.java
View File

@ -1,7 +1,9 @@
package com.fastbee.ggroup.mapper;
import java.util.List;
import com.fastbee.ggroup.domain.GRiverInfo;
import com.fastbee.ggroup.domain.GSiteRiverInfo;
import com.github.yulichang.base.MPJBaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
* 河流基础信息Mapper接口
@ -9,7 +11,8 @@ import com.fastbee.ggroup.domain.GRiverInfo;
* @author kerwincui
* @date 2024-10-22
*/
public interface GRiverInfoMapper
@Mapper
public interface GSiteRiverInfoMapper extends MPJBaseMapper<GSiteRiverInfo>
{
/**
* 查询河流基础信息
@ -17,31 +20,31 @@ public interface GRiverInfoMapper
* @param id 河流基础信息主键
* @return 河流基础信息
*/
public GRiverInfo selectGRiverInfoById(Long id);
public GSiteRiverInfo selectGRiverInfoBySiteId(Long id);
/**
* 查询河流基础信息列表
*
* @param gRiverInfo 河流基础信息
* @param gSiteRiverInfo 河流基础信息
* @return 河流基础信息集合
*/
public List<GRiverInfo> selectGRiverInfoList(GRiverInfo gRiverInfo);
public List<GSiteRiverInfo> selectGRiverInfoList(GSiteRiverInfo gSiteRiverInfo);
/**
* 新增河流基础信息
*
* @param gRiverInfo 河流基础信息
* @param gSiteRiverInfo 河流基础信息
* @return 结果
*/
public int insertGRiverInfo(GRiverInfo gRiverInfo);
public int insertGRiverInfo(GSiteRiverInfo gSiteRiverInfo);
/**
* 修改河流基础信息
*
* @param gRiverInfo 河流基础信息
* @param gSiteRiverInfo 河流基础信息
* @return 结果
*/
public int updateGRiverInfo(GRiverInfo gRiverInfo);
public int updateGRiverInfo(GSiteRiverInfo gSiteRiverInfo);
/**
* 删除河流基础信息

18
fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/service/IGSiteInfoService.java → fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/service/IGSiteMonitorInfoService.java
View File

@ -1,7 +1,7 @@
package com.fastbee.ggroup.service;
import java.util.List;
import com.fastbee.ggroup.domain.GSiteInfo;
import com.fastbee.ggroup.domain.GSiteMonitorInfo;
/**
* 站点基础信息Service接口
@ -9,7 +9,7 @@ import com.fastbee.ggroup.domain.GSiteInfo;
* @author kerwincui
* &#064;date 2024-10-10
*/
public interface IGSiteInfoService
public interface IGSiteMonitorInfoService
{
/**
* 查询站点基础信息
@ -17,31 +17,31 @@ public interface IGSiteInfoService
* @param id 站点基础信息主键
* @return 站点基础信息
*/
GSiteInfo selectGSiteInfoById(Long id);
GSiteMonitorInfo selectGSiteInfoById(Long id);
/**
* 查询站点基础信息列表
*
* @param gSiteInfo 站点基础信息
* @param gSiteMonitorInfo 站点基础信息
* @return 站点基础信息集合
*/
List<GSiteInfo> selectGSiteInfoList(GSiteInfo gSiteInfo);
List<GSiteMonitorInfo> selectGSiteInfoList(GSiteMonitorInfo gSiteMonitorInfo);
/**
* 新增站点基础信息
*
* @param gSiteInfo 站点基础信息
* @param gSiteMonitorInfo 站点基础信息
* @return 结果
*/
int insertGSiteInfo(GSiteInfo gSiteInfo);
int insertGSiteInfo(GSiteMonitorInfo gSiteMonitorInfo);
/**
* 修改站点基础信息
*
* @param gSiteInfo 站点基础信息
* @param gSiteMonitorInfo 站点基础信息
* @return 结果
*/
int updateGSiteInfo(GSiteInfo gSiteInfo);
int updateGSiteInfo(GSiteMonitorInfo gSiteMonitorInfo);
/**
* 批量删除站点基础信息

61
fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/service/IGSiteReservoirInfoService.java Normal file
View File

@ -0,0 +1,61 @@
package com.fastbee.ggroup.service;
import java.util.List;
import com.fastbee.ggroup.domain.GSiteReservoirInfo;
/**
* 水库站点基础信息Service接口
*
* @author kerwincui
* @date 2024-10-23
*/
public interface IGSiteReservoirInfoService
{
/**
* 查询水库站点基础信息
*
* @param id 水库站点基础信息主键
* @return 水库站点基础信息
*/
public GSiteReservoirInfo selectGSiteReservoirInfoById(Long id);
/**
* 查询水库站点基础信息列表
*
* @param gSiteReservoirInfo 水库站点基础信息
* @return 水库站点基础信息集合
*/
public List<GSiteReservoirInfo> selectGSiteReservoirInfoList(GSiteReservoirInfo gSiteReservoirInfo);
/**
* 新增水库站点基础信息
*
* @param gSiteReservoirInfo 水库站点基础信息
* @return 结果
*/
public int insertGSiteReservoirInfo(GSiteReservoirInfo gSiteReservoirInfo);
/**
* 修改水库站点基础信息
*
* @param gSiteReservoirInfo 水库站点基础信息
* @return 结果
*/
public int updateGSiteReservoirInfo(GSiteReservoirInfo gSiteReservoirInfo);
/**
* 批量删除水库站点基础信息
*
* @param ids 需要删除的水库站点基础信息主键集合
* @return 结果
*/
public int deleteGSiteReservoirInfoByIds(Long[] ids);
/**
* 删除水库站点基础信息信息
*
* @param id 水库站点基础信息主键
* @return 结果
*/
public int deleteGSiteReservoirInfoById(Long id);
}

18
fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/service/IGRiverInfoService.java → fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/service/IGSiteRiverInfoService.java
View File

@ -1,7 +1,7 @@
package com.fastbee.ggroup.service;
import java.util.List;
import com.fastbee.ggroup.domain.GRiverInfo;
import com.fastbee.ggroup.domain.GSiteRiverInfo;
/**
* 河流基础信息Service接口
@ -9,7 +9,7 @@ import com.fastbee.ggroup.domain.GRiverInfo;
* @author kerwincui
* @date 2024-10-22
*/
public interface IGRiverInfoService
public interface IGSiteRiverInfoService
{
/**
* 查询河流基础信息
@ -17,31 +17,31 @@ public interface IGRiverInfoService
* @param id 河流基础信息主键
* @return 河流基础信息
*/
public GRiverInfo selectGRiverInfoById(Long id);
public GSiteRiverInfo selectGRiverInfoById(Long id);
/**
* 查询河流基础信息列表
*
* @param gRiverInfo 河流基础信息
* @param gSiteRiverInfo 河流基础信息
* @return 河流基础信息集合
*/
public List<GRiverInfo> selectGRiverInfoList(GRiverInfo gRiverInfo);
public List<GSiteRiverInfo> selectGRiverInfoList(GSiteRiverInfo gSiteRiverInfo);
/**
* 新增河流基础信息
*
* @param gRiverInfo 河流基础信息
* @param gSiteRiverInfo 河流基础信息
* @return 结果
*/
public int insertGRiverInfo(GRiverInfo gRiverInfo);
public int insertGRiverInfo(GSiteRiverInfo gSiteRiverInfo);
/**
* 修改河流基础信息
*
* @param gRiverInfo 河流基础信息
* @param gSiteRiverInfo 河流基础信息
* @return 结果
*/
public int updateGRiverInfo(GRiverInfo gRiverInfo);
public int updateGRiverInfo(GSiteRiverInfo gSiteRiverInfo);
/**
* 批量删除河流基础信息

3
fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/service/impl/GGroupsServiceImpl.java
View File

@ -131,8 +131,8 @@ public class GGroupsServiceImpl implements IGGroupsService
//根组列表
List<GGroups> roots = new ArrayList<>();
//所有站点列表
List<GGroupSiteVo> gGroupSiteAllList = selectGGroupsAllListSites(new GGroups());
System.err.println("当前项目下所有站点：");
gGroupSiteAllList.forEach(System.err::println);
for (GGroups group : groupsList) {
@ -163,7 +163,6 @@ public class GGroupsServiceImpl implements IGGroupsService
/**
* 查询项目下全部站点
*/
public List<GGroupSiteVo> selectGGroupsAllListSites(GGroups gGroups) {
MPJLambdaWrapper<GSiteGroups> gSiteGroupsMPJLambdaWrapper = new MPJLambdaWrapper<GSiteGroups>()
.select(GSiteGroups::getId, GSiteGroups::getParentId, GSiteGroups::getSiteId)

7
fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/service/impl/GLegendServiceImpl.java
View File

@ -8,6 +8,7 @@ import java.util.stream.Collectors;
import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
import com.fastbee.common.exception.ServiceException;
import com.fastbee.common.utils.DateUtils;
import com.fastbee.ggroup.enums.SiteTypeCategoryEnum;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;
@ -78,6 +79,12 @@ public class GLegendServiceImpl implements IGLegendService
if(!duplicateNameList.isEmpty()){
throw new ServiceException("图例名称重复!");
}
gLegend.setCategory(gLegend.getCategory().trim());
//图例类别校验
if(!SiteTypeCategoryEnum.contains(gLegend.getCategory())){
throw new ServiceException("图例类别不存在!");
}
gLegend.setCreateTime(DateUtils.getNowDate());
return gLegendMapper.insertGLegend(gLegend);
}

96
fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/service/impl/GRiverInfoServiceImpl.java
View File

@ -1,96 +0,0 @@
package com.fastbee.ggroup.service.impl;
import java.util.List;
import com.fastbee.common.utils.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.fastbee.ggroup.mapper.GRiverInfoMapper;
import com.fastbee.ggroup.domain.GRiverInfo;
import com.fastbee.ggroup.service.IGRiverInfoService;
/**
* 河流基础信息Service业务层处理
*
* @author kerwincui
* @date 2024-10-22
*/
@Service
public class GRiverInfoServiceImpl implements IGRiverInfoService
{
@Autowired
private GRiverInfoMapper gRiverInfoMapper;
/**
* 查询河流基础信息
*
* @param id 河流基础信息主键
* @return 河流基础信息
*/
@Override
public GRiverInfo selectGRiverInfoById(Long id)
{
return gRiverInfoMapper.selectGRiverInfoById(id);
}
/**
* 查询河流基础信息列表
*
* @param gRiverInfo 河流基础信息
* @return 河流基础信息
*/
@Override
public List<GRiverInfo> selectGRiverInfoList(GRiverInfo gRiverInfo)
{
return gRiverInfoMapper.selectGRiverInfoList(gRiverInfo);
}
/**
* 新增河流基础信息
*
* @param gRiverInfo 河流基础信息
* @return 结果
*/
@Override
public int insertGRiverInfo(GRiverInfo gRiverInfo)
{
gRiverInfo.setCreateTime(DateUtils.getNowDate());
return gRiverInfoMapper.insertGRiverInfo(gRiverInfo);
}
/**
* 修改河流基础信息
*
* @param gRiverInfo 河流基础信息
* @return 结果
*/
@Override
public int updateGRiverInfo(GRiverInfo gRiverInfo)
{
gRiverInfo.setUpdateTime(DateUtils.getNowDate());
return gRiverInfoMapper.updateGRiverInfo(gRiverInfo);
}
/**
* 批量删除河流基础信息
*
* @param ids 需要删除的河流基础信息主键
* @return 结果
*/
@Override
public int deleteGRiverInfoByIds(Long[] ids)
{
return gRiverInfoMapper.deleteGRiverInfoByIds(ids);
}
/**
* 删除河流基础信息信息
*
* @param id 河流基础信息主键
* @return 结果
*/
@Override
public int deleteGRiverInfoById(Long id)
{
return gRiverInfoMapper.deleteGRiverInfoById(id);
}
}

106
fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/service/impl/GSiteInfoServiceImpl.java
View File

@ -1,106 +0,0 @@
package com.fastbee.ggroup.service.impl;
import java.util.List;
import java.util.Objects;
import com.fastbee.common.exception.ServiceException;
import com.fastbee.common.utils.DateUtils;
import com.fastbee.common.utils.ValidationUtils;
import org.springframework.stereotype.Service;
import com.fastbee.ggroup.mapper.GSiteInfoMapper;
import com.fastbee.ggroup.domain.GSiteInfo;
import com.fastbee.ggroup.service.IGSiteInfoService;
/**
* 站点基础信息Service业务层处理
*
* @author kerwincui
* &#064;date 2024-10-10
*/
@Service
public class GSiteInfoServiceImpl implements IGSiteInfoService
{
private final GSiteInfoMapper gSiteInfoMapper;
public GSiteInfoServiceImpl(GSiteInfoMapper gSiteInfoMapper) {
this.gSiteInfoMapper = gSiteInfoMapper;
}
/**
* 查询站点基础信息
*
* @param id 站点基础信息主键
* @return 站点基础信息
*/
@Override
public GSiteInfo selectGSiteInfoById(Long id)
{
return gSiteInfoMapper.selectGSiteInfoById(id);
}
/**
* 查询站点基础信息列表
*
* @param gSiteInfo 站点基础信息
* @return 站点基础信息
*/
@Override
public List<GSiteInfo> selectGSiteInfoList(GSiteInfo gSiteInfo)
{
return gSiteInfoMapper.selectGSiteInfoList(gSiteInfo);
}
/**
* 新增站点基础信息
*
* @param gSiteInfo 站点基础信息
* @return 结果
*/
@Override
public int insertGSiteInfo(GSiteInfo gSiteInfo)
{
gSiteInfo.setCreateTime(DateUtils.getNowDate());
return gSiteInfoMapper.insertGSiteInfo(gSiteInfo);
}
/**
* 修改站点基础信息
*
* @param gSiteInfo 站点基础信息
* @return 结果
*/
@Override
public int updateGSiteInfo(GSiteInfo gSiteInfo)
{
//参数校验
if(Objects.isNull(gSiteInfo.getSiteId())){
throw new ServiceException("站点ID(siteId)字段不能为空！");
}
if(!ValidationUtils.isMobile(gSiteInfo.getManagerPhone())){
throw new ServiceException("站点管理员手机号(managerPhone)格式不正确！");
}
//检查是否有该条数据
if(Objects.isNull(gSiteInfoMapper.selectGSiteInfoById(gSiteInfo.getSiteId()))){
//没有该条数据，则新增
gSiteInfo.setCreateTime(DateUtils.getNowDate());
return insertGSiteInfo(gSiteInfo);
}
gSiteInfo.setUpdateTime(DateUtils.getNowDate());
return gSiteInfoMapper.updateGSiteInfo(gSiteInfo);
}
/**
* 批量删除站点基础信息
*
* @param ids 需要删除的站点基础信息主键
* @return 结果
*/
@Override
public int deleteGSiteInfoByIds(Long[] ids)
{
return gSiteInfoMapper.deleteGSiteInfoByIds(ids);
}
}

106
fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/service/impl/GSiteMonitorInfoServiceImpl.java Normal file
View File

@ -0,0 +1,106 @@
package com.fastbee.ggroup.service.impl;
import java.util.List;
import java.util.Objects;
import com.fastbee.common.exception.ServiceException;
import com.fastbee.common.utils.DateUtils;
import com.fastbee.common.utils.ValidationUtils;
import org.springframework.stereotype.Service;
import com.fastbee.ggroup.mapper.GSiteMonitorInfoMapper;
import com.fastbee.ggroup.domain.GSiteMonitorInfo;
import com.fastbee.ggroup.service.IGSiteMonitorInfoService;
/**
* 站点基础信息Service业务层处理
*
* @author kerwincui
* &#064;date 2024-10-10
*/
@Service
public class GSiteMonitorInfoServiceImpl implements IGSiteMonitorInfoService
{
private final GSiteMonitorInfoMapper gSiteMonitorInfoMapper;
public GSiteMonitorInfoServiceImpl(GSiteMonitorInfoMapper gSiteMonitorInfoMapper) {
this.gSiteMonitorInfoMapper = gSiteMonitorInfoMapper;
}
/**
* 查询站点基础信息
*
* @param id 站点基础信息主键
* @return 站点基础信息
*/
@Override
public GSiteMonitorInfo selectGSiteInfoById(Long id)
{
return gSiteMonitorInfoMapper.selectGSiteInfoBySiteId(id);
}
/**
* 查询站点基础信息列表
*
* @param gSiteMonitorInfo 站点基础信息
* @return 站点基础信息
*/
@Override
public List<GSiteMonitorInfo> selectGSiteInfoList(GSiteMonitorInfo gSiteMonitorInfo)
{
return gSiteMonitorInfoMapper.selectGSiteInfoList(gSiteMonitorInfo);
}
/**
* 新增站点基础信息
*
* @param gSiteMonitorInfo 站点基础信息
* @return 结果
*/
@Override
public int insertGSiteInfo(GSiteMonitorInfo gSiteMonitorInfo)
{
gSiteMonitorInfo.setCreateTime(DateUtils.getNowDate());
return gSiteMonitorInfoMapper.insertGSiteInfo(gSiteMonitorInfo);
}
/**
* 修改站点基础信息
*
* @param gSiteMonitorInfo 站点基础信息
* @return 结果
*/
@Override
public int updateGSiteInfo(GSiteMonitorInfo gSiteMonitorInfo)
{
//参数校验
if(Objects.isNull(gSiteMonitorInfo.getSiteId())){
throw new ServiceException("站点ID(siteId)字段不能为空！");
}
if(!ValidationUtils.isMobile(gSiteMonitorInfo.getManagerPhone())){
throw new ServiceException("站点管理员手机号(managerPhone)格式不正确！");
}
//检查是否有该条数据
if(Objects.isNull(gSiteMonitorInfoMapper.selectGSiteInfoBySiteId(gSiteMonitorInfo.getSiteId()))){
//没有该条数据，则新增
gSiteMonitorInfo.setCreateTime(DateUtils.getNowDate());
return insertGSiteInfo(gSiteMonitorInfo);
}
gSiteMonitorInfo.setUpdateTime(DateUtils.getNowDate());
return gSiteMonitorInfoMapper.updateGSiteInfo(gSiteMonitorInfo);
}
/**
* 批量删除站点基础信息
*
* @param ids 需要删除的站点基础信息主键
* @return 结果
*/
@Override
public int deleteGSiteInfoByIds(Long[] ids)
{
return gSiteMonitorInfoMapper.deleteGSiteInfoByIds(ids);
}
}

109
fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/service/impl/GSiteReservoirInfoServiceImpl.java Normal file
View File

@ -0,0 +1,109 @@
package com.fastbee.ggroup.service.impl;
import java.util.List;
import java.util.Objects;
import com.fastbee.common.exception.ServiceException;
import com.fastbee.common.utils.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.fastbee.ggroup.mapper.GSiteReservoirInfoMapper;
import com.fastbee.ggroup.domain.GSiteReservoirInfo;
import com.fastbee.ggroup.service.IGSiteReservoirInfoService;
/**
* 水库站点基础信息Service业务层处理
*
* @author kerwincui
* @date 2024-10-23
*/
@Service
public class GSiteReservoirInfoServiceImpl implements IGSiteReservoirInfoService
{
@Autowired
private GSiteReservoirInfoMapper gSiteReservoirInfoMapper;
/**
* 查询水库站点基础信息
*
* @param siteId 水库站点id
* @return 水库站点基础信息
*/
@Override
public GSiteReservoirInfo selectGSiteReservoirInfoById(Long siteId)
{
return gSiteReservoirInfoMapper.selectGSiteReservoirInfoBySiteId(siteId);
}
/**
* 查询水库站点基础信息列表
*
* @param gSiteReservoirInfo 水库站点基础信息
* @return 水库站点基础信息
*/
@Override
public List<GSiteReservoirInfo> selectGSiteReservoirInfoList(GSiteReservoirInfo gSiteReservoirInfo)
{
return gSiteReservoirInfoMapper.selectGSiteReservoirInfoList(gSiteReservoirInfo);
}
/**
* 新增水库站点基础信息
*
* @param gSiteReservoirInfo 水库站点基础信息
* @return 结果
*/
@Override
public int insertGSiteReservoirInfo(GSiteReservoirInfo gSiteReservoirInfo)
{
gSiteReservoirInfo.setCreateTime(DateUtils.getNowDate());
return gSiteReservoirInfoMapper.insertGSiteReservoirInfo(gSiteReservoirInfo);
}
/**
* 修改水库站点基础信息
*
* @param gSiteReservoirInfo 水库站点基础信息
* @return 结果
*/
@Override
public int updateGSiteReservoirInfo(GSiteReservoirInfo gSiteReservoirInfo)
{
//必要参数校验
if(Objects.isNull(gSiteReservoirInfo.getSiteId())){
throw new ServiceException("站点ID(siteId)字段不能为空！");
}
//检查是否有该条数据
if(Objects.isNull(gSiteReservoirInfoMapper.selectGSiteReservoirInfoBySiteId(gSiteReservoirInfo.getSiteId()))){
//没有该条数据则新增
gSiteReservoirInfo.setCreateTime(DateUtils.getNowDate());
return insertGSiteReservoirInfo(gSiteReservoirInfo);
}
gSiteReservoirInfo.setUpdateTime(DateUtils.getNowDate());
return gSiteReservoirInfoMapper.updateGSiteReservoirInfo(gSiteReservoirInfo);
}
/**
* 批量删除水库站点基础信息
*
* @param ids 需要删除的水库站点基础信息主键
* @return 结果
*/
@Override
public int deleteGSiteReservoirInfoByIds(Long[] ids)
{
return gSiteReservoirInfoMapper.deleteGSiteReservoirInfoByIds(ids);
}
/**
* 删除水库站点基础信息信息
*
* @param id 水库站点基础信息主键
* @return 结果
*/
@Override
public int deleteGSiteReservoirInfoById(Long id)
{
return gSiteReservoirInfoMapper.deleteGSiteReservoirInfoById(id);
}
}

111
fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/service/impl/GSiteRiverInfoServiceImpl.java Normal file
View File

@ -0,0 +1,111 @@
package com.fastbee.ggroup.service.impl;
import java.util.List;
import java.util.Objects;
import com.fastbee.common.exception.ServiceException;
import com.fastbee.common.utils.DateUtils;
import org.springframework.stereotype.Service;
import com.fastbee.ggroup.mapper.GSiteRiverInfoMapper;
import com.fastbee.ggroup.domain.GSiteRiverInfo;
import com.fastbee.ggroup.service.IGSiteRiverInfoService;
/**
* 河流基础信息Service业务层处理
*
* @author kerwincui
* &#064;date 2024-10-22
*/
@Service
public class GSiteRiverInfoServiceImpl implements IGSiteRiverInfoService
{
private final GSiteRiverInfoMapper gSiteRiverInfoMapper;
public GSiteRiverInfoServiceImpl(GSiteRiverInfoMapper gSiteRiverInfoMapper) {
this.gSiteRiverInfoMapper = gSiteRiverInfoMapper;
}
/**
* 查询河流基础信息
*
* @param id 河流基础信息主键
* @return 河流基础信息
*/
@Override
public GSiteRiverInfo selectGRiverInfoById(Long id)
{
return gSiteRiverInfoMapper.selectGRiverInfoBySiteId(id);
}
/**
* 查询河流基础信息列表
*
* @param gSiteRiverInfo 河流基础信息
* @return 河流基础信息
*/
@Override
public List<GSiteRiverInfo> selectGRiverInfoList(GSiteRiverInfo gSiteRiverInfo)
{
return gSiteRiverInfoMapper.selectGRiverInfoList(gSiteRiverInfo);
}
/**
* 新增河流基础信息
*
* @param gSiteRiverInfo 河流基础信息
* @return 结果
*/
@Override
public int insertGRiverInfo(GSiteRiverInfo gSiteRiverInfo)
{
gSiteRiverInfo.setCreateTime(DateUtils.getNowDate());
return gSiteRiverInfoMapper.insertGRiverInfo(gSiteRiverInfo);
}
/**
* 修改河流基础信息
*
* @param gSiteRiverInfo 河流基础信息
* @return 结果
*/
@Override
public int updateGRiverInfo(GSiteRiverInfo gSiteRiverInfo)
{
//必要参数校验
if(Objects.isNull(gSiteRiverInfo.getSiteId())){
throw new ServiceException("站点ID(siteId)字段不能为空！");
}
//检查是否有该条数据
if(Objects.isNull(gSiteRiverInfoMapper.selectGRiverInfoBySiteId(gSiteRiverInfo.getSiteId()))){
//没有该条数据则新增
gSiteRiverInfo.setCreateTime(DateUtils.getNowDate());
return insertGRiverInfo(gSiteRiverInfo);
}
gSiteRiverInfo.setUpdateTime(DateUtils.getNowDate());
return gSiteRiverInfoMapper.updateGRiverInfo(gSiteRiverInfo);
}
/**
* 批量删除河流基础信息
*
* @param ids 需要删除的河流基础信息主键
* @return 结果
*/
@Override
public int deleteGRiverInfoByIds(Long[] ids)
{
return gSiteRiverInfoMapper.deleteGRiverInfoByIds(ids);
}
/**
* 删除河流基础信息信息
*
* @param id 河流基础信息主键
* @return 结果
*/
@Override
public int deleteGRiverInfoById(Long id)
{
return gSiteRiverInfoMapper.deleteGRiverInfoById(id);
}
}

37
fastbee-service/fastbee-ggroup-service/src/main/java/com/fastbee/ggroup/service/impl/GSitesServiceImpl.java
View File

@ -7,7 +7,9 @@ import java.util.stream.Collectors;
import cn.hutool.http.HttpUtil;
import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONException;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
@ -117,10 +119,29 @@ public class GSitesServiceImpl extends ServiceImpl<GSiteGroupsMapper,GSiteGroups
if (Objects.isNull(jsonData)) {
throw new ServiceException("上传站点地图json数据为空！");
}
//校验json格式是否正确
//校验文件内容是否是json格式
if (!isValidJson(jsonData)) {
throw new ServiceException("json格式不正确！");
}
//校验json对象是否合法
JSONObject jsonObject = JSONUtil.parseObj(jsonData);
if (!jsonObject.containsKey("coordinates")) {
throw new ServiceException("json缺少coordinates属性！");
}
//判断coordinates的值必须为点线面的一种
Object coordinates = jsonObject.get("coordinates");
//解析为数组
if (!(coordinates instanceof JSONArray)) {
throw new ServiceException("coordinates的值必须为数组类型！");
}
JSONArray jsonArray = JSONUtil.parseArray(coordinates);
//判断数组每个元素必须为经度或纬度
// for (Object o : jsonArray) {
// if (!(o instanceof Double)) {
// throw new ServiceException("coordinates必须只包含经纬度数据！");
// }
// }
int startIndex = space.indexOf("/profile/upload/");
String relativeUrl = space.substring(startIndex);
gSites.setSpace(relativeUrl);
@ -161,6 +182,20 @@ public class GSitesServiceImpl extends ServiceImpl<GSiteGroupsMapper,GSiteGroups
}
return true;
}
/**
* 验证json对象是否是数组
*/
public boolean isValidJsonArray(String jsonStr) {
try {
JSONUtil.parseArray(jsonStr);
} catch (JSONException e) {
return false;
}
return true;
}
/**
* 批量删除站点
*/