init project

src/main/java/org/springblade/modules/business/data/controller/RtuDataWeatherController.java

@@ -0,0 +1,103 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import lombok.AllArgsConstructor;
+import org.springblade.constant.BusinessConstant;
+import org.springblade.core.boot.ctrl.BladeController;
+import org.springblade.core.mp.support.Condition;
+import org.springblade.core.mp.support.Query;
+import org.springblade.core.secure.BladeUser;
+import org.springblade.core.secure.utils.AuthUtil;
+import org.springblade.core.tool.api.R;
+import org.springblade.core.tool.utils.Func;
+import org.springblade.modules.baseinfo.org.entity.DeptRegionEntity;
+import org.springblade.modules.baseinfo.org.service.IDeptRegionService;
+import org.springblade.modules.business.data.dto.RtuDataRainDTO;
+import org.springblade.modules.business.data.entity.RtuDataRainEntity;
+import org.springblade.modules.business.data.service.IRtuDataRainService;
+import org.springblade.modules.business.data.vo.RtuDataRainVO;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import springfox.documentation.annotations.ApiIgnore;
+
+
+
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@RestController
+@RequestMapping("galaxy-business/rtu/data/rain")
+@AllArgsConstructor
+@Api(value = "降水实时数据管理", tags = "测站实时数据管理")
+public class RtuDataRainController extends BladeController {
+	private final IRtuDataRainService dataRainService;
+	private final IDeptRegionService deptRegionService;
+
+	/**
+	 * 分页
+	 */
+	@GetMapping("/page")
+	@ApiImplicitParams({
+		@ApiImplicitParam(name = "rtuName", value = "测站名称", paramType = "query", dataType = "string"),
+		@ApiImplicitParam(name = "rtuCode", value = "测站编码", paramType = "query", dataType = "string"),
+		@ApiImplicitParam(name = "adCode", value = "行政区划编码", paramType = "query", dataType = "string"),
+	})
+	@ApiOperationSupport(order = 2)
+	@ApiOperation(value = "分页")
+	public R<IPage<RtuDataRainVO>> page(@ApiIgnore RtuDataRainDTO rtuDataRainDTO, Query query) {
+		BladeUser user = AuthUtil.getUser();
+		if (BusinessConstant.ROLE_SYS_ADMIN.equals(user.getRoleName())) {
+			if (rtuDataRainDTO.getAdCode() == null) {
+				rtuDataRainDTO.setAdCode(BusinessConstant.REGION_NM_ADCODE);
+			}
+		} else if (BusinessConstant.ROLE_ORG_ADMIN.equals(user.getRoleName()) || BusinessConstant.ROLE_COMPANY_ADMIN.equals(user.getRoleName()) || BusinessConstant.ROLE_COMPANY_SERVICE_PERSON.equals(user.getRoleName())) {
+			if (rtuDataRainDTO.getAdCode() == null) {
+				LambdaQueryWrapper<DeptRegionEntity> deptRegionEntityLambdaQueryWrapper = Wrappers.<DeptRegionEntity>query().lambda();
+				deptRegionEntityLambdaQueryWrapper.eq(DeptRegionEntity::getIsDeleted, 0);
+				deptRegionEntityLambdaQueryWrapper.eq(DeptRegionEntity::getDeptId, Func.toLong(user.getDeptId()));
+				DeptRegionEntity deptRegionEntity = deptRegionService.getOne(deptRegionEntityLambdaQueryWrapper);
+				rtuDataRainDTO.setAdCode(deptRegionEntity.getAdcd());
+			}
+		}
+		IPage<RtuDataRainVO> pages = dataRainService.selectPage(Condition.getPage(query), rtuDataRainDTO);
+		return R.data(pages);
+	}
+
+
+	/**
+	 * 详情
+	 */
+	@GetMapping("/detail")
+	@ApiImplicitParams({
+		@ApiImplicitParam(name = "rtuCode", value = "测站编码", paramType = "query", dataType = "string"),
+	})
+	@ApiOperationSupport(order = 1)
+	@ApiOperation(value = "详情", notes = "传入 RtuDataRainEntity")
+	public R<RtuDataRainEntity> detail(RtuDataRainEntity entity) {
+		LambdaQueryWrapper<RtuDataRainEntity> wrapper = Wrappers.<RtuDataRainEntity>query().lambda();
+		wrapper.eq(RtuDataRainEntity::getIsDeleted, 0L);
+		wrapper.eq(RtuDataRainEntity::getRtuCode, entity.getRtuCode());
+		RtuDataRainEntity rainEntity = dataRainService.getOne(wrapper);
+		return R.data(rainEntity);
+	}
+}

src/main/java/org/springblade/modules/business/data/dto/RtuDataGroundStoreDTO.java

@@ -0,0 +1,50 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/30
+ */
+package org.springblade.modules.business.data.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springblade.core.mp.base.BaseEntity;
+import org.springblade.modules.business.data.entity.RtuDataGroundEntity;
+
+/***
+ * Date:2022/8/30
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class RtuDataGroundDTO extends RtuDataGroundEntity {
+	/**
+	 * 测站名称
+	 */
+	@ApiModelProperty("测站名称")
+	private String rtuName;
+	/**
+	 * 机构ID
+	 */
+	@ApiModelProperty("机构ID")
+	private Long orgId;
+
+
+	/**
+	 * 项目ID
+	 */
+	@ApiModelProperty("项目ID")
+	private Long projectId;
+
+	/**
+	 * 行政区划编码
+	 */
+	@ApiModelProperty("行政区划编码")
+	private String adCode;
+
+}

src/main/java/org/springblade/modules/business/data/dto/RtuDataRainStoreDTO.java

@@ -0,0 +1,49 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/30
+ */
+package org.springblade.modules.business.data.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springblade.core.mp.base.BaseEntity;
+import org.springblade.modules.business.data.entity.RtuDataRainEntity;
+
+/***
+ * Date:2022/8/30
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class RtuDataRainDTO extends RtuDataRainEntity {
+	/**
+	 * 测站名称
+	 */
+	@ApiModelProperty("测站名称")
+	private String rtuName;
+	/**
+	 * 机构ID
+	 */
+	@ApiModelProperty("机构ID")
+	private Long orgId;
+
+
+	/**
+	 * 项目ID
+	 */
+	@ApiModelProperty("项目ID")
+	private Long projectId;
+
+	/**
+	 * 行政区划编码
+	 */
+	@ApiModelProperty("行政区划编码")
+	private String adCode;
+}

src/main/java/org/springblade/modules/business/data/dto/RtuDataRiverStoreDTO.java

@@ -0,0 +1,49 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/30
+ */
+package org.springblade.modules.business.data.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springblade.core.mp.base.BaseEntity;
+import org.springblade.modules.business.data.entity.RtuDataRiverEntity;
+
+/***
+ * Date:2022/8/30
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class RtuDataRiverDTO extends RtuDataRiverEntity {
+	/**
+	 * 测站名称
+	 */
+	@ApiModelProperty("测站名称")
+	private String rtuName;
+	/**
+	 * 机构ID
+	 */
+	@ApiModelProperty("机构ID")
+	private Long orgId;
+
+
+	/**
+	 * 项目ID
+	 */
+	@ApiModelProperty("项目ID")
+	private Long projectId;
+
+	/**
+	 * 行政区划编码
+	 */
+	@ApiModelProperty("行政区划编码")
+	private String adCode;
+}

src/main/java/org/springblade/modules/business/data/dto/RtuDataRsvrStoreDTO.java

@@ -0,0 +1,49 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/30
+ */
+package org.springblade.modules.business.data.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springblade.core.mp.base.BaseEntity;
+import org.springblade.modules.business.data.entity.RtuDataRsvrEntity;
+
+/***
+ * Date:2022/8/30
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class RtuDataRsvrDTO extends RtuDataRsvrEntity {
+	/**
+	 * 测站名称
+	 */
+	@ApiModelProperty("测站名称")
+	private String rtuName;
+	/**
+	 * 机构ID
+	 */
+	@ApiModelProperty("机构ID")
+	private Long orgId;
+
+
+	/**
+	 * 项目ID
+	 */
+	@ApiModelProperty("项目ID")
+	private Long projectId;
+
+	/**
+	 * 行政区划编码
+	 */
+	@ApiModelProperty("行政区划编码")
+	private String adCode;
+}

src/main/java/org/springblade/modules/business/data/entity/RtuDataGroundStoreEntity.java

@@ -0,0 +1,155 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.ser.std.NullSerializer;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springblade.core.mp.base.BaseEntity;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.util.Date;
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName("data_att_st_somo_cache")
+public class RtuDataGroundEntity extends BaseEntity {
+	private static final long serialVersionUID = 1L;
+
+	/**
+	 * 租户ID
+	 */
+	@ApiModelProperty("租户ID")
+	private String tenantId;
+
+	/**
+	 * 测站编码
+	 */
+	@ApiModelProperty("测站编码")
+	private String rtuCode;
+
+	/**
+	 * 时间
+	 */
+	@ApiModelProperty("时间")
+	@DateTimeFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss"
+	)
+	@JsonFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss",
+		timezone = "GMT+8"
+	)
+	private Date tm;
+
+	/**
+	 * 垂线平均含水量
+	 */
+	@ApiModelProperty("垂线平均含水量")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double vtavslm;
+
+	/**
+	 * 表层含水量
+	 */
+	@ApiModelProperty("表层含水量")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double srlslm;
+
+	/**
+	 * 10CM深度含水量
+	 */
+	@ApiModelProperty("10CM深度含水量")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double slm10;
+
+	/**
+	 * 20CM深度含水量
+	 */
+	@ApiModelProperty("20CM深度含水量")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double slm20;
+
+	/**
+	 * 30CM深度含水量
+	 */
+	@ApiModelProperty("30CM深度含水量")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double slm30;
+
+	/**
+	 * 40CM深度含水量
+	 */
+	@ApiModelProperty("40CM深度含水量")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double slm40;
+
+	/**
+	 * 50CM深度含水量
+	 */
+	@ApiModelProperty("50CM深度含水量")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double slm50;
+
+	/**
+	 * 60CM深度含水量
+	 */
+	@ApiModelProperty("60CM深度含水量")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double slm60;
+
+	/**
+	 * 80CM深度含水量
+	 */
+	@ApiModelProperty("80CM深度含水量")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double slm80;
+
+	/**
+	 * 100CM深度含水量
+	 */
+	@ApiModelProperty("100CM深度含水量")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double slm100;
+
+	/**
+	 * 上报时间
+	 */
+	@ApiModelProperty("上报时间")
+	@DateTimeFormat(
+			pattern = "yyyy-MM-dd HH:mm:ss"
+	)
+	@JsonFormat(
+			pattern = "yyyy-MM-dd HH:mm:ss",
+			timezone = "GMT+8"
+	)
+	private Date upTime;
+
+	/**
+	 * 东华数据库入库时间
+	 */
+	@ApiModelProperty("入库时间")
+	@DateTimeFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss"
+	)
+	@JsonFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss",
+		timezone = "GMT+8"
+	)
+	private Date fromTime;
+}

src/main/java/org/springblade/modules/business/data/entity/RtuDataRainStoreEntity.java

@@ -0,0 +1,127 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.ser.std.NullSerializer;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springblade.core.mp.base.BaseEntity;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.util.Date;
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName("data_att_st_prec_cache")
+public class RtuDataRainEntity extends BaseEntity {
+	private static final long serialVersionUID = 1L;
+
+	/**
+	 * 租户ID
+	 */
+	@ApiModelProperty("租户ID")
+	private String tenantId;
+
+	/**
+	 * 测站编码
+	 */
+	@ApiModelProperty("测站编码")
+	private String rtuCode;
+
+	/**
+	 * 采集时间
+	 */
+	@ApiModelProperty("采集时间")
+	@DateTimeFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss"
+	)
+	@JsonFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss",
+		timezone = "GMT+8"
+	)
+	private Date tm;
+
+	/**
+	 * 降水量
+	 */
+	@ApiModelProperty("降水量")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double drp;
+
+	/**
+	 * 时段长
+	 */
+	@ApiModelProperty("时段长")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double intv;
+
+	/**
+	 * 降水历时,格式 HH.NN
+	 */
+	@ApiModelProperty("降水历时")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double pdr;
+
+	/**
+	 * 日降水量,前一天8时到当前8时，24小时降水量
+	 */
+	@ApiModelProperty("日降水量")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double dyp;
+
+	/**
+	 * 天气状况
+	 */
+	@ApiModelProperty("天气状况")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private String wth;
+
+	/**
+	 * 累计降水量
+	 */
+	@ApiModelProperty("累计降水量")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double pt;
+
+	/**
+	 * 上报时间
+	 */
+	@ApiModelProperty("上报时间")
+	@DateTimeFormat(
+			pattern = "yyyy-MM-dd HH:mm:ss"
+	)
+	@JsonFormat(
+			pattern = "yyyy-MM-dd HH:mm:ss",
+			timezone = "GMT+8"
+	)
+	private Date upTime;
+
+	/**
+	 * 入库时间
+	 */
+	@ApiModelProperty("入库时间")
+	@DateTimeFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss"
+	)
+	@JsonFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss",
+		timezone = "GMT+8"
+	)
+	private Date fromTime;
+}

src/main/java/org/springblade/modules/business/data/entity/RtuDataRiverStoreEntity.java

@@ -0,0 +1,92 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.ser.std.NullSerializer;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springblade.core.mp.base.BaseEntity;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.util.Date;
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName("data_att_st_waco_ware_cache")
+public class RtuDataRiverEntity extends BaseEntity {
+	private static final long serialVersionUID = 1L;
+
+	/**
+	 * 租户ID
+	 */
+	@ApiModelProperty("租户ID")
+	private String tenantId;
+
+	/**
+	 * 测站编码
+	 */
+	@ApiModelProperty("测站编码")
+	private String rtuCode;
+
+	/**
+	 * 采集时间
+	 */
+	@ApiModelProperty("采集时间")
+	@DateTimeFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss"
+	)
+	@JsonFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss",
+		timezone = "GMT+8"
+	)
+	private Date tm;
+
+	/**
+	 * 河道水位
+	 */
+	@ApiModelProperty("河道水位")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double z;
+
+	/**
+	 * 上报时间
+	 */
+	@ApiModelProperty("上报时间")
+	@DateTimeFormat(
+			pattern = "yyyy-MM-dd HH:mm:ss"
+	)
+	@JsonFormat(
+			pattern = "yyyy-MM-dd HH:mm:ss",
+			timezone = "GMT+8"
+	)
+	private Date upTime;
+
+	/**
+	 * 数据库入库时间
+	 */
+	@ApiModelProperty("入库时间")
+	@DateTimeFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss"
+	)
+	@JsonFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss",
+		timezone = "GMT+8"
+	)
+	private Date fromTime;
+}

src/main/java/org/springblade/modules/business/data/entity/RtuDataRsvrStoreEntity.java

@@ -0,0 +1,93 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.ser.std.NullSerializer;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springblade.core.mp.base.BaseEntity;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.util.Date;
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName("data_att_st_res_ware_cache")
+public class RtuDataRsvrEntity extends BaseEntity {
+	private static final long serialVersionUID = 1L;
+
+	/**
+	 * 租户ID
+	 */
+	@ApiModelProperty("租户ID")
+	private String tenantId;
+
+	/**
+	 * 测站编码
+	 */
+	@ApiModelProperty("测站编码")
+	private String rtuCode;
+
+	/**
+	 * 采集时间
+	 */
+	@ApiModelProperty("采集时间")
+	@DateTimeFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss"
+	)
+	@JsonFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss",
+		timezone = "GMT+8"
+	)
+	private Date tm;
+
+	/**
+	 * 库上水位
+	 */
+	@ApiModelProperty("库上水位")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double rz;
+
+	/**
+	 * 上报时间
+	 */
+	@ApiModelProperty("上报时间")
+	@DateTimeFormat(
+			pattern = "yyyy-MM-dd HH:mm:ss"
+	)
+	@JsonFormat(
+			pattern = "yyyy-MM-dd HH:mm:ss",
+			timezone = "GMT+8"
+	)
+	private Date upTime;
+
+
+	/**
+	 * 数据库入库时间
+	 */
+	@ApiModelProperty("入库时间")
+	@DateTimeFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss"
+	)
+	@JsonFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss",
+		timezone = "GMT+8"
+	)
+	private Date fromTime;
+}

src/main/java/org/springblade/modules/business/data/entity/RtuDataSzyFlowRateEntity.java

@@ -0,0 +1,18 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2023/6/16
+ */
+package org.springblade.modules.business.data.entity;
+
+/*** 
+ * Date:2023/6/16
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public class RtuDataSzyFlowRateEntity {
+}

src/main/java/org/springblade/modules/business/data/entity/RtuDataSzyFlowRateStoreEntity.java

@@ -0,0 +1,90 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2023/6/16
+ */
+package org.springblade.modules.business.data.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.ser.std.NullSerializer;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springblade.core.mp.base.BaseEntity;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.util.Date;
+
+/***
+ * Date:2023/6/16
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName("data_szy_mp_q_r")
+public class RtuDataSzyFlowRateEntity extends BaseEntity {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 租户ID
+     */
+    @ApiModelProperty("租户ID")
+    private String tenantId;
+
+    /**
+     * 测站编码
+     */
+    @ApiModelProperty("测站编码")
+    private String rtuCode;
+
+    /**
+     * 采集时间
+     */
+    @ApiModelProperty("采集时间")
+    @DateTimeFormat(
+            pattern = "yyyy-MM-dd HH:mm:ss"
+    )
+    @JsonFormat(
+            pattern = "yyyy-MM-dd HH:mm:ss",
+            timezone = "GMT+8"
+    )
+    private Date tm;
+
+    /**
+     * 上报时间
+     */
+    @ApiModelProperty("上报时间")
+    @DateTimeFormat(
+            pattern = "yyyy-MM-dd HH:mm:ss"
+    )
+    @JsonFormat(
+            pattern = "yyyy-MM-dd HH:mm:ss",
+            timezone = "GMT+8"
+    )
+    private Date upTime;
+
+    /**
+     * 数据库入库时间
+     */
+    @ApiModelProperty("入库时间")
+    @DateTimeFormat(
+            pattern = "yyyy-MM-dd HH:mm:ss"
+    )
+    @JsonFormat(
+            pattern = "yyyy-MM-dd HH:mm:ss",
+            timezone = "GMT+8"
+    )
+    private Date fromTime;
+
+    @ApiModelProperty("河道水位")
+    @JsonSerialize(nullsUsing = NullSerializer.class)
+    private Double z;
+
+}

src/main/java/org/springblade/modules/business/data/entity/RtuDataWeatherEntity.java

@@ -0,0 +1,127 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.ser.std.NullSerializer;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springblade.core.mp.base.BaseEntity;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.util.Date;
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName("data_att_st_prec_cache")
+public class RtuDataRainEntity extends BaseEntity {
+	private static final long serialVersionUID = 1L;
+
+	/**
+	 * 租户ID
+	 */
+	@ApiModelProperty("租户ID")
+	private String tenantId;
+
+	/**
+	 * 测站编码
+	 */
+	@ApiModelProperty("测站编码")
+	private String rtuCode;
+
+	/**
+	 * 采集时间
+	 */
+	@ApiModelProperty("采集时间")
+	@DateTimeFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss"
+	)
+	@JsonFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss",
+		timezone = "GMT+8"
+	)
+	private Date tm;
+
+	/**
+	 * 降水量
+	 */
+	@ApiModelProperty("降水量")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double drp;
+
+	/**
+	 * 时段长
+	 */
+	@ApiModelProperty("时段长")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double intv;
+
+	/**
+	 * 降水历时,格式 HH.NN
+	 */
+	@ApiModelProperty("降水历时")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double pdr;
+
+	/**
+	 * 日降水量,前一天8时到当前8时，24小时降水量
+	 */
+	@ApiModelProperty("日降水量")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double dyp;
+
+	/**
+	 * 天气状况
+	 */
+	@ApiModelProperty("天气状况")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private String wth;
+
+	/**
+	 * 累计降水量
+	 */
+	@ApiModelProperty("累计降水量")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double pt;
+
+	/**
+	 * 上报时间
+	 */
+	@ApiModelProperty("上报时间")
+	@DateTimeFormat(
+			pattern = "yyyy-MM-dd HH:mm:ss"
+	)
+	@JsonFormat(
+			pattern = "yyyy-MM-dd HH:mm:ss",
+			timezone = "GMT+8"
+	)
+	private Date upTime;
+
+	/**
+	 * 入库时间
+	 */
+	@ApiModelProperty("入库时间")
+	@DateTimeFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss"
+	)
+	@JsonFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss",
+		timezone = "GMT+8"
+	)
+	private Date fromTime;
+}

src/main/java/org/springblade/modules/business/data/entity/RtuDataWqRiverEntity.java

@@ -0,0 +1,18 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2023/6/16
+ */
+package org.springblade.modules.business.data.entity;
+
+/*** 
+ * Date:2023/6/16
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public class RtuDataWqRiverEntity {
+}

src/main/java/org/springblade/modules/business/data/entity/RtuDataWqRiverStoreEntity.java

@@ -0,0 +1,95 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2023/6/16
+ */
+package org.springblade.modules.business.data.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.ser.std.NullSerializer;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springblade.core.mp.base.BaseEntity;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.util.Date;
+
+/***
+ * Date:2023/6/16
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName("data_szy_river")
+public class RtuDataWqRiverEntity extends BaseEntity {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 租户ID
+     */
+    @ApiModelProperty("租户ID")
+    private String tenantId;
+
+    /**
+     * 测站编码
+     */
+    @ApiModelProperty("测站编码")
+    private String rtuCode;
+
+    /**
+     * 采集时间
+     */
+    @ApiModelProperty("采集时间")
+    @DateTimeFormat(
+            pattern = "yyyy-MM-dd HH:mm:ss"
+    )
+    @JsonFormat(
+            pattern = "yyyy-MM-dd HH:mm:ss",
+            timezone = "GMT+8"
+    )
+    private Date tm;
+
+    /**
+     * 上报时间
+     */
+    @ApiModelProperty("上报时间")
+    @DateTimeFormat(
+            pattern = "yyyy-MM-dd HH:mm:ss"
+    )
+    @JsonFormat(
+            pattern = "yyyy-MM-dd HH:mm:ss",
+            timezone = "GMT+8"
+    )
+    private Date upTime;
+
+    /**
+     * 数据库入库时间
+     */
+    @ApiModelProperty("入库时间")
+    @DateTimeFormat(
+            pattern = "yyyy-MM-dd HH:mm:ss"
+    )
+    @JsonFormat(
+            pattern = "yyyy-MM-dd HH:mm:ss",
+            timezone = "GMT+8"
+    )
+    private Date fromTime;
+
+    @ApiModelProperty("河道水位")
+    @JsonSerialize(nullsUsing = NullSerializer.class)
+    private String waterLevelHigh;
+
+
+    @ApiModelProperty("河道流速")
+    @JsonSerialize(nullsUsing = NullSerializer.class)
+    private String waterFlowSpeed;
+
+}

src/main/java/org/springblade/modules/business/data/entity/RtuRealTimeStatusEntity.java

@@ -0,0 +1,18 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2023/6/15
+ */
+package org.springblade.modules.business.data.entity;
+
+/*** 
+ * Date:2023/6/15
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public class RtuRealTimeStatusEntity {
+}

src/main/java/org/springblade/modules/business/data/entity/RtuRealTimeStatusStoreEntity.java

@@ -0,0 +1,160 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2023/6/15
+ */
+package org.springblade.modules.business.data.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.ser.std.NullSerializer;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springblade.core.mp.base.BaseEntity;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.util.Date;
+
+/***
+ * Date:2023/6/15
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName("data_rtu_realtime_status")
+public class RtuRealTimeStatusEntity extends BaseEntity {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 租户ID
+     */
+    @ApiModelProperty("租户ID")
+    private String tenantId;
+
+    /**
+     * 测站编码
+     */
+    @ApiModelProperty("测站编码")
+    private String rtuCode;
+
+    /**
+     * 采集时间
+     */
+    @ApiModelProperty("采集时间")
+    @DateTimeFormat(
+            pattern = "yyyy-MM-dd HH:mm:ss"
+    )
+    @JsonFormat(
+            pattern = "yyyy-MM-dd HH:mm:ss",
+            timezone = "GMT+8"
+    )
+    private Date collectTime;
+
+    /**
+     * 上报时间
+     */
+    @ApiModelProperty("上报时间")
+    @DateTimeFormat(
+            pattern = "yyyy-MM-dd HH:mm:ss"
+    )
+    @JsonFormat(
+            pattern = "yyyy-MM-dd HH:mm:ss",
+            timezone = "GMT+8"
+    )
+    private Date upTime;
+
+
+    /**
+     * 数据库入库时间
+     */
+    @ApiModelProperty("入库时间")
+    @DateTimeFormat(
+            pattern = "yyyy-MM-dd HH:mm:ss"
+    )
+    @JsonFormat(
+            pattern = "yyyy-MM-dd HH:mm:ss",
+            timezone = "GMT+8"
+    )
+    private Date pickTime;
+
+    @ApiModelProperty("经度")
+    @JsonSerialize(nullsUsing = NullSerializer.class)
+    private Double lng;
+
+    @ApiModelProperty("纬度")
+    @JsonSerialize(nullsUsing = NullSerializer.class)
+    private Double lat;
+
+    @ApiModelProperty("信号强度")
+    @JsonSerialize(nullsUsing = NullSerializer.class)
+    private Double dtuSignal;
+
+    @ApiModelProperty("电源电压")
+    @JsonSerialize(nullsUsing = NullSerializer.class)
+    private Double voltage;
+
+    @ApiModelProperty("RTU温度")
+    @JsonSerialize(nullsUsing = NullSerializer.class)
+    private Double temperature;
+
+    @ApiModelProperty("设备状态")
+    @JsonSerialize(nullsUsing = NullSerializer.class)
+    private Integer rtuStatus;
+
+    @ApiModelProperty("异常值")
+    @JsonSerialize(nullsUsing = NullSerializer.class)
+    private Integer rtuError;
+
+    @ApiModelProperty("电池状态")
+    @JsonSerialize(nullsUsing = NullSerializer.class)
+    private String batteryStatus;
+
+    @ApiModelProperty("充电状态")
+    @JsonSerialize(nullsUsing = NullSerializer.class)
+    private String batteryBatteryIn;
+
+    @ApiModelProperty("放电状态")
+    @JsonSerialize(nullsUsing = NullSerializer.class)
+    private String batteryBatteryOut;
+
+    @ApiModelProperty("电池电量 ,百分比")
+    @JsonSerialize(nullsUsing = NullSerializer.class)
+    private Double batteryPower;
+
+    @ApiModelProperty("电池温度")
+    @JsonSerialize(nullsUsing = NullSerializer.class)
+    private Double batteryTemperature;
+
+    @ApiModelProperty("太阳能板电压")
+    @JsonSerialize(nullsUsing = NullSerializer.class)
+    private Double sunPowerVoltage;
+
+    @ApiModelProperty("太阳能板电流")
+    @JsonSerialize(nullsUsing = NullSerializer.class)
+    private Double sunPowerElectric;
+
+    @ApiModelProperty("水位计状态")
+    @JsonSerialize(nullsUsing = NullSerializer.class)
+    private String waterSensorStatus;
+
+    /**
+     * 交流电充电报警 0 正常 ，1停电
+     */
+    @ApiModelProperty("交流电充电报警")
+    @JsonSerialize(nullsUsing = NullSerializer.class)
+    private String acChargeWarning;
+
+    /**
+     * 电池电压报警 0 正常 ，1报警
+     */
+    @ApiModelProperty("电池电压报警")
+    @JsonSerialize(nullsUsing = NullSerializer.class)
+    private String batteryVoltageWarning;
+}

src/main/java/org/springblade/modules/business/data/mapper/RtuDataGroundHistoreMapper.java

@@ -0,0 +1,37 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.apache.ibatis.annotations.Param;
+import org.springblade.modules.business.data.dto.RtuDataGroundDTO;
+import org.springblade.modules.business.data.dto.RtuDataGroundStoreDTO;
+import org.springblade.modules.business.data.entity.RtuDataGroundEntity;
+import org.springblade.modules.business.data.entity.RtuDataGroundStoreEntity;
+import org.springblade.modules.business.data.vo.RtuDataGroundStoreVO;
+import org.springblade.modules.business.data.vo.RtuDataGroundVO;
+
+import java.util.List;
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public interface RtuDataGroundStoreMapper extends BaseMapper<RtuDataGroundStoreEntity> {
+	/**
+	 * 自定义分页
+	 *
+	 * @param page 分页
+	 * @return List<RtuInfoVO>
+	 */
+	List<RtuDataGroundStoreVO> selectPage(IPage page, @Param("groundDTO") RtuDataGroundStoreDTO groundDTO);
+}

src/main/java/org/springblade/modules/business/data/mapper/RtuDataGroundHistoreMapper.xml

@@ -0,0 +1,67 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="org.springblade.modules.business.data.mapper.RtuDataGroundStoreMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="rtuGroundDataResultMap" type="org.springblade.modules.business.data.entity.RtuDataGroundStoreEntity">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="tm" property="tm"/>
+        <result column="vtavslm" property="vtavslm"/>
+        <result column="srlslm" property="srlslm"/>
+        <result column="slm10" property="slm10"/>
+        <result column="slm20" property="slm20"/>
+        <result column="slm30" property="slm30"/>
+        <result column="slm40" property="slm40"/>
+        <result column="slm50" property="slm50"/>
+        <result column="slm40" property="slm40"/>
+        <result column="slm60" property="slm60"/>
+        <result column="slm80" property="slm80"/>
+        <result column="slm100" property="slm100"/>
+        <result column="up_time" property="upTime"/>
+        <result column="from_time" property="fromTime"/>
+    </resultMap>
+
+
+    <resultMap id="rtuGroundDataVOResultMap" type="org.springblade.modules.business.data.vo.RtuDataGroundStoreVO">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="tm" property="tm"/>
+        <result column="vtavslm" property="vtavslm"/>
+        <result column="srlslm" property="srlslm"/>
+        <result column="rtu_name" property="rtuName"/>
+        <result column="slm10" property="slm10"/>
+        <result column="slm20" property="slm20"/>
+        <result column="slm30" property="slm30"/>
+        <result column="slm40" property="slm40"/>
+        <result column="slm50" property="slm50"/>
+        <result column="slm60" property="slm60"/>
+        <result column="slm80" property="slm80"/>
+        <result column="slm100" property="slm100"/>
+        <result column="ad_city" property="adCity"/>
+        <result column="ad_dist" property="adDist"/>
+        <result column="up_time" property="upTime"/>
+        <result column="from_time" property="fromTime"/>
+    </resultMap>
+
+
+    <select id="selectPage" resultMap="rtuGroundDataVOResultMap">
+        SELECT
+        n.*,
+        r.rtu_name,r.ad_city,r.ad_dist
+        FROM
+        data_att_st_somo_cache n
+        LEFT JOIN  rtu_info r ON n.rtu_code = r.rtu_code and r.is_deleted=0
+        LEFT JOIN  data_ad_cd_b a ON a.adcd = r.ad_code and a.is_deleted=0
+        WHERE
+        n.is_deleted = 0
+        <if test="groundDTO.rtuName!=null">
+            and r.rtu_name LIKE concat(concat('%', #{groundDTO.rtuName}), '%')
+        </if>
+        <if test="groundDTO.rtuCode!=null">
+            and n.rtu_code like concat(concat('%', #{groundDTO.rtuCode}), '%')
+        </if>
+        <if test="groundDTO.adCode!=null">
+            and (a.adcd =#{groundDTO.adCode} or a.ancestors in (SELECT ancestors FROM data_ad_cd_b WHERE ancestors  like concat(concat('%', #{groundDTO.adCode}), '%')))
+        </if>
+
+    </select>
+</mapper>

src/main/java/org/springblade/modules/business/data/mapper/RtuDataRainHistoreMapper.java

@@ -0,0 +1,37 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.apache.ibatis.annotations.Param;
+import org.springblade.modules.business.data.dto.RtuDataRainDTO;
+import org.springblade.modules.business.data.dto.RtuDataRainStoreDTO;
+import org.springblade.modules.business.data.entity.RtuDataRainEntity;
+import org.springblade.modules.business.data.entity.RtuDataRainStoreEntity;
+import org.springblade.modules.business.data.vo.RtuDataRainStoreVO;
+import org.springblade.modules.business.data.vo.RtuDataRainVO;
+
+import java.util.List;
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public interface RtuDataRainStoreMapper extends BaseMapper<RtuDataRainStoreEntity> {
+	/**
+	 * 自定义分页
+	 *
+	 * @param page 分页
+	 * @return List<RtuInfoVO>
+	 */
+	List<RtuDataRainStoreVO> selectPage(IPage page, @Param("rtuDataRainDTO") RtuDataRainStoreDTO rtuDataRainDTO);
+}

src/main/java/org/springblade/modules/business/data/mapper/RtuDataRainHistoreMapper.xml

@@ -0,0 +1,50 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="org.springblade.modules.business.data.mapper.RtuDataRainStoreMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="rtuRainDataResultMap" type="org.springblade.modules.business.data.entity.RtuDataRainStoreEntity">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="tm" property="tm"/>
+        <result column="drp" property="drp"/>
+        <result column="intv" property="intv"/>
+        <result column="up_time" property="upTime"/>
+        <result column="from_time" property="fromTime"/>
+    </resultMap>
+
+
+    <resultMap id="rtuRainDataVOResultMap" type="org.springblade.modules.business.data.vo.RtuDataRainStoreVO">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="tm" property="tm"/>
+        <result column="drp" property="drp"/>
+        <result column="intv" property="intv"/>
+        <result column="rtu_name" property="rtuName"/>
+        <result column="ad_city" property="adCity"/>
+        <result column="ad_dist" property="adDist"/>
+        <result column="up_time" property="upTime"/>
+        <result column="from_time" property="fromTime"/>
+    </resultMap>
+
+
+    <select id="selectPage" resultMap="rtuRainDataVOResultMap">
+        SELECT
+        n.*,
+        r.rtu_name,r.ad_city,r.ad_dist
+        FROM
+        data_att_st_prec_cache n
+        LEFT JOIN  rtu_info r ON n.rtu_code = r.rtu_code and r.is_deleted=0
+        LEFT JOIN  data_ad_cd_b a ON a.adcd = r.ad_code and a.is_deleted=0
+        WHERE
+        n.is_deleted = 0
+        <if test="rtuDataRainDTO.rtuName!=null ">
+            and r.rtu_name LIKE concat(concat('%', #{rtuDataRainDTO.rtuName}), '%')
+        </if>
+        <if test="rtuDataRainDTO.rtuCode!=null">
+            and n.rtu_code like concat(concat('%', #{rtuDataRainDTO.rtuCode}), '%')
+        </if>
+        <if test="rtuDataRainDTO.adCode!=null">
+            and (a.adcd =#{rtuDataRainDTO.adCode} or a.ancestors in (SELECT ancestors FROM data_ad_cd_b WHERE ancestors  like concat(concat('%', #{rtuDataRainDTO.adCode}), '%')))
+        </if>
+
+    </select>
+</mapper>

src/main/java/org/springblade/modules/business/data/mapper/RtuDataRiverHistoreMapper.java

@@ -0,0 +1,40 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.apache.ibatis.annotations.Param;
+import org.springblade.modules.business.data.dto.RtuDataRiverDTO;
+import org.springblade.modules.business.data.dto.RtuDataRiverStoreDTO;
+import org.springblade.modules.business.data.entity.RtuDataRiverEntity;
+import org.springblade.modules.business.data.entity.RtuDataRiverStoreEntity;
+import org.springblade.modules.business.data.vo.RtuDataRiverStoreVO;
+import org.springblade.modules.business.data.vo.RtuDataRiverVO;
+
+import java.util.List;
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public interface RtuDataRiverStoreMapper extends BaseMapper<RtuDataRiverStoreEntity> {
+	/**
+	 * 自定义分页
+	 *
+	 * @param page 分页
+	 * @return List<RtuInfoVO>
+	 */
+	List<RtuDataRiverStoreVO> selectPage(IPage page, @Param("riverDTO") RtuDataRiverStoreDTO riverDTO);
+
+	List<RtuDataRiverStoreVO> selectWaterPage(IPage page, @Param("riverDTO") RtuDataRiverStoreDTO riverDTO);
+
+}

src/main/java/org/springblade/modules/business/data/mapper/RtuDataRiverHistoreMapper.xml

@@ -0,0 +1,75 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="org.springblade.modules.business.data.mapper.RtuDataRiverStoreMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="rtuRiverDataEntityResultMap" type="org.springblade.modules.business.data.entity.RtuDataRiverStoreEntity">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="tm" property="tm"/>
+        <result column="z" property="z"/>
+        <result column="up_time" property="upTime"/>
+        <result column="from_time" property="fromTime"/>
+    </resultMap>
+
+
+    <resultMap id="rtuRiverDataVOResultMap" type="org.springblade.modules.business.data.vo.RtuDataRiverStoreVO">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="tm" property="tm"/>
+        <result column="z" property="z"/>
+        <result column="ad_city" property="adCity"/>
+        <result column="ad_dist" property="adDist"/>
+        <result column="up_time" property="upTime"/>
+        <result column="from_time" property="fromTime"/>
+    </resultMap>
+
+    <resultMap id="rtuWaterDataVOResultMap" type="org.springblade.modules.business.data.vo.RtuDataRiverStoreVO">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="tm" property="tm"/>
+        <result column="z" property="z"/>
+        <result column="rz" property="rz"/>
+        <result column="ad_city" property="adCity"/>
+        <result column="ad_dist" property="adDist"/>
+        <result column="up_time" property="upTime"/>
+        <result column="from_time" property="fromTime"/>
+    </resultMap>
+
+    <select id="selectPage" resultMap="rtuRiverDataVOResultMap">
+        SELECT
+        n.*,
+        r.rtu_name,r.ad_city,r.ad_dist
+        FROM
+        data_att_st_waco_ware_cache n
+        LEFT JOIN  rtu_info r ON n.rtu_code = r.rtu_code and r.is_deleted=0
+        LEFT JOIN  data_ad_cd_b a ON a.adcd = r.ad_code and a.is_deleted=0
+        WHERE
+        n.is_deleted = 0
+        <if test="riverDTO.rtuName!=null ">
+            and r.rtu_name LIKE concat(concat('%', #{riverDTO.rtuName}), '%')
+        </if>
+        <if test="riverDTO.rtuCode!=null">
+            and n.rtu_code like concat(concat('%', #{riverDTO.rtuCode}), '%')
+        </if>
+        <if test="riverDTO.adCode!=null">
+            and (a.adcd =#{riverDTO.adCode} or a.ancestors in (SELECT ancestors FROM data_ad_cd_b WHERE ancestors  like concat(concat('%', #{riverDTO.adCode}), '%')))
+        </if>
+    </select>
+
+    <select id="selectWaterPage" resultMap="rtuWaterDataVOResultMap">
+        SELECT r.rtu_code,r.rtu_name,res.rz,w.z,res.tm rsvrTm,w.tm,r.ad_city,r.ad_dist
+        FROM rtu_info  r
+        LEFT JOIN data_att_st_res_ware_cache res  on res.rtu_code = r.rtu_code and res.is_deleted=0
+        LEFT JOIN data_att_st_waco_ware_cache w on w.rtu_code = r.rtu_code and w.is_deleted=0
+        LEFT JOIN data_ad_cd_b a ON a.adcd = r.ad_code and a.is_deleted=0
+        WHERE r.is_deleted=0 and  (r.is_res=1 or r.is_river=1)
+        <if test="riverDTO.rtuName!=null ">
+            and r.rtu_name LIKE concat(concat('%', #{riverDTO.rtuName}), '%')
+        </if>
+        <if test="riverDTO.rtuCode!=null">
+            and r.rtu_code like concat(concat('%', #{riverDTO.rtuCode}), '%')
+        </if>
+        <if test="riverDTO.adCode!=null">
+            and (r.ad_code =#{riverDTO.adCode} or a.ancestors in (SELECT ancestors FROM data_ad_cd_b WHERE ancestors  like concat(concat('%', #{riverDTO.adCode}), '%')))
+        </if>
+        order by res.tm desc,w.tm desc,r.ad_code,r.rtu_code
+    </select>
+</mapper>

src/main/java/org/springblade/modules/business/data/mapper/RtuDataRsvrHistoreMapper.java

@@ -0,0 +1,38 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.apache.ibatis.annotations.Param;
+import org.springblade.modules.business.data.dto.RtuDataRsvrDTO;
+import org.springblade.modules.business.data.dto.RtuDataRsvrStoreDTO;
+import org.springblade.modules.business.data.entity.RtuDataRsvrEntity;
+import org.springblade.modules.business.data.entity.RtuDataRsvrStoreEntity;
+import org.springblade.modules.business.data.vo.RtuDataRsvrStoreVO;
+import org.springblade.modules.business.data.vo.RtuDataRsvrVO;
+
+import java.util.List;
+
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public interface RtuDataRsvrStoreMapper extends BaseMapper<RtuDataRsvrStoreEntity> {
+	/**
+	 * 自定义分页
+	 *
+	 * @param page 分页
+	 * @return List<RtuInfoVO>
+	 */
+	List<RtuDataRsvrStoreVO> selectPage(IPage page, @Param("rsvrDTO") RtuDataRsvrStoreDTO rsvrDTO);
+}

src/main/java/org/springblade/modules/business/data/mapper/RtuDataRsvrHistoreMapper.xml

@@ -0,0 +1,46 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="org.springblade.modules.business.data.mapper.RtuDataRsvrStoreMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="rtuRsvrDataEntityResultMap" type="org.springblade.modules.business.data.entity.RtuDataRsvrStoreEntity">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="tm" property="tm"/>
+        <result column="rz" property="rz"/>
+        <result column="up_time" property="upTime"/>
+        <result column="from_time" property="fromTime"/>
+    </resultMap>
+
+    <resultMap id="rtuRsvrDataVOResultMap" type="org.springblade.modules.business.data.vo.RtuDataRsvrStoreVO">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="tm" property="tm"/>
+        <result column="rz" property="rz"/>
+        <result column="rtu_name" property="rtuName"/>
+        <result column="ad_city" property="adCity"/>
+        <result column="ad_dist" property="adDist"/>
+        <result column="up_time" property="upTime"/>
+        <result column="from_time" property="fromTime"/>
+    </resultMap>
+
+
+    <select id="selectPage" resultMap="rtuRsvrDataVOResultMap">
+        SELECT
+        n.*,
+        r.rtu_name,r.ad_city,r.ad_dist
+        FROM
+        data_att_st_res_ware_cache n
+        LEFT JOIN  rtu_info r ON n.rtu_code = r.rtu_code and r.is_deleted=0
+        LEFT JOIN  data_ad_cd_b a ON a.adcd = r.ad_code and a.is_deleted=0
+        WHERE
+        n.is_deleted = 0
+        <if test="rsvrDTO.rtuName!=null ">
+            and r.rtu_name LIKE concat(concat('%', #{rsvrDTO.rtuName}), '%')
+        </if>
+        <if test="rsvrDTO.rtuCode!=null">
+            and n.rtu_code like concat(concat('%', #{rsvrDTO.rtuCode}), '%')
+        </if>
+        <if test="rsvrDTO.adCode!=null">
+            and (a.adcd =#{rsvrDTO.adCode} or a.ancestors in (SELECT ancestors FROM data_ad_cd_b WHERE ancestors  like concat(concat('%', #{rsvrDTO.adCode}), '%')))
+        </if>
+    </select>
+</mapper>

src/main/java/org/springblade/modules/business/data/mapper/RtuDataSzyMpHistoreMapper.java

@@ -0,0 +1,29 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.apache.ibatis.annotations.Param;
+import org.springblade.modules.business.data.dto.RtuDataRsvrDTO;
+import org.springblade.modules.business.data.entity.RtuDataRsvrEntity;
+import org.springblade.modules.business.data.vo.RtuDataRsvrVO;
+
+import java.util.List;
+
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public interface RtuDataSzyMpMapper extends BaseMapper<RtuDataRsvrEntity> {
+
+}

src/main/java/org/springblade/modules/business/data/mapper/RtuDataSzyMpHistoreMapper.xml

@@ -0,0 +1,46 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="org.springblade.modules.business.data.mapper.RtuDataRsvrMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="rtuRsvrDataEntityResultMap" type="org.springblade.modules.business.data.entity.RtuDataRsvrEntity">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="tm" property="tm"/>
+        <result column="rz" property="rz"/>
+        <result column="up_time" property="upTime"/>
+        <result column="from_time" property="fromTime"/>
+    </resultMap>
+
+    <resultMap id="rtuRsvrDataVOResultMap" type="org.springblade.modules.business.data.vo.RtuDataRsvrVO">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="tm" property="tm"/>
+        <result column="rz" property="rz"/>
+        <result column="rtu_name" property="rtuName"/>
+        <result column="ad_city" property="adCity"/>
+        <result column="ad_dist" property="adDist"/>
+        <result column="up_time" property="upTime"/>
+        <result column="from_time" property="fromTime"/>
+    </resultMap>
+
+
+    <select id="selectPage" resultMap="rtuRsvrDataVOResultMap">
+        SELECT
+        n.*,
+        r.rtu_name,r.ad_city,r.ad_dist
+        FROM
+        data_att_st_res_ware_cache n
+        LEFT JOIN  rtu_info r ON n.rtu_code = r.rtu_code and r.is_deleted=0
+        LEFT JOIN  data_ad_cd_b a ON a.adcd = r.ad_code and a.is_deleted=0
+        WHERE
+        n.is_deleted = 0
+        <if test="rsvrDTO.rtuName!=null ">
+            and r.rtu_name LIKE concat(concat('%', #{rsvrDTO.rtuName}), '%')
+        </if>
+        <if test="rsvrDTO.rtuCode!=null">
+            and n.rtu_code like concat(concat('%', #{rsvrDTO.rtuCode}), '%')
+        </if>
+        <if test="rsvrDTO.adCode!=null">
+            and (a.adcd =#{rsvrDTO.adCode} or a.ancestors in (SELECT ancestors FROM data_ad_cd_b WHERE ancestors  like concat(concat('%', #{rsvrDTO.adCode}), '%')))
+        </if>
+    </select>
+</mapper>

src/main/java/org/springblade/modules/business/data/mapper/RtuDataSzyMpMapper.java

@@ -0,0 +1,35 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.apache.ibatis.annotations.Param;
+import org.springblade.modules.business.data.dto.RtuDataRsvrDTO;
+import org.springblade.modules.business.data.entity.RtuDataRsvrEntity;
+import org.springblade.modules.business.data.vo.RtuDataRsvrVO;
+
+import java.util.List;
+
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public interface RtuDataSzyRiverMapper extends BaseMapper<RtuDataRsvrEntity> {
+	/**
+	 * 自定义分页
+	 *
+	 * @param page 分页
+	 * @return List<RtuInfoVO>
+	 */
+	List<RtuDataRsvrVO> selectPage(IPage page, @Param("rsvrDTO") RtuDataRsvrDTO rsvrDTO);
+}

src/main/java/org/springblade/modules/business/data/mapper/RtuDataSzyMpMapper.xml

@@ -0,0 +1,46 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="org.springblade.modules.business.data.mapper.RtuDataRsvrMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="rtuRsvrDataEntityResultMap" type="org.springblade.modules.business.data.entity.RtuDataRsvrEntity">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="tm" property="tm"/>
+        <result column="rz" property="rz"/>
+        <result column="up_time" property="upTime"/>
+        <result column="from_time" property="fromTime"/>
+    </resultMap>
+
+    <resultMap id="rtuRsvrDataVOResultMap" type="org.springblade.modules.business.data.vo.RtuDataRsvrVO">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="tm" property="tm"/>
+        <result column="rz" property="rz"/>
+        <result column="rtu_name" property="rtuName"/>
+        <result column="ad_city" property="adCity"/>
+        <result column="ad_dist" property="adDist"/>
+        <result column="up_time" property="upTime"/>
+        <result column="from_time" property="fromTime"/>
+    </resultMap>
+
+
+    <select id="selectPage" resultMap="rtuRsvrDataVOResultMap">
+        SELECT
+        n.*,
+        r.rtu_name,r.ad_city,r.ad_dist
+        FROM
+        data_att_st_res_ware_cache n
+        LEFT JOIN  rtu_info r ON n.rtu_code = r.rtu_code and r.is_deleted=0
+        LEFT JOIN  data_ad_cd_b a ON a.adcd = r.ad_code and a.is_deleted=0
+        WHERE
+        n.is_deleted = 0
+        <if test="rsvrDTO.rtuName!=null ">
+            and r.rtu_name LIKE concat(concat('%', #{rsvrDTO.rtuName}), '%')
+        </if>
+        <if test="rsvrDTO.rtuCode!=null">
+            and n.rtu_code like concat(concat('%', #{rsvrDTO.rtuCode}), '%')
+        </if>
+        <if test="rsvrDTO.adCode!=null">
+            and (a.adcd =#{rsvrDTO.adCode} or a.ancestors in (SELECT ancestors FROM data_ad_cd_b WHERE ancestors  like concat(concat('%', #{rsvrDTO.adCode}), '%')))
+        </if>
+    </select>
+</mapper>

src/main/java/org/springblade/modules/business/data/mapper/RtuDataSzyRiverHistoreMapper.java

@@ -0,0 +1,35 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.apache.ibatis.annotations.Param;
+import org.springblade.modules.business.data.dto.RtuDataRsvrDTO;
+import org.springblade.modules.business.data.entity.RtuDataRsvrEntity;
+import org.springblade.modules.business.data.vo.RtuDataRsvrVO;
+
+import java.util.List;
+
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public interface RtuDataSzyRiverMapper extends BaseMapper<RtuDataRsvrEntity> {
+	/**
+	 * 自定义分页
+	 *
+	 * @param page 分页
+	 * @return List<RtuInfoVO>
+	 */
+	List<RtuDataRsvrVO> selectPage(IPage page, @Param("rsvrDTO") RtuDataRsvrDTO rsvrDTO);
+}

src/main/java/org/springblade/modules/business/data/mapper/RtuDataSzyRiverHistoreMapper.xml

@@ -0,0 +1,46 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="org.springblade.modules.business.data.mapper.RtuDataRsvrMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="rtuRsvrDataEntityResultMap" type="org.springblade.modules.business.data.entity.RtuDataRsvrEntity">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="tm" property="tm"/>
+        <result column="rz" property="rz"/>
+        <result column="up_time" property="upTime"/>
+        <result column="from_time" property="fromTime"/>
+    </resultMap>
+
+    <resultMap id="rtuRsvrDataVOResultMap" type="org.springblade.modules.business.data.vo.RtuDataRsvrVO">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="tm" property="tm"/>
+        <result column="rz" property="rz"/>
+        <result column="rtu_name" property="rtuName"/>
+        <result column="ad_city" property="adCity"/>
+        <result column="ad_dist" property="adDist"/>
+        <result column="up_time" property="upTime"/>
+        <result column="from_time" property="fromTime"/>
+    </resultMap>
+
+
+    <select id="selectPage" resultMap="rtuRsvrDataVOResultMap">
+        SELECT
+        n.*,
+        r.rtu_name,r.ad_city,r.ad_dist
+        FROM
+        data_att_st_res_ware_cache n
+        LEFT JOIN  rtu_info r ON n.rtu_code = r.rtu_code and r.is_deleted=0
+        LEFT JOIN  data_ad_cd_b a ON a.adcd = r.ad_code and a.is_deleted=0
+        WHERE
+        n.is_deleted = 0
+        <if test="rsvrDTO.rtuName!=null ">
+            and r.rtu_name LIKE concat(concat('%', #{rsvrDTO.rtuName}), '%')
+        </if>
+        <if test="rsvrDTO.rtuCode!=null">
+            and n.rtu_code like concat(concat('%', #{rsvrDTO.rtuCode}), '%')
+        </if>
+        <if test="rsvrDTO.adCode!=null">
+            and (a.adcd =#{rsvrDTO.adCode} or a.ancestors in (SELECT ancestors FROM data_ad_cd_b WHERE ancestors  like concat(concat('%', #{rsvrDTO.adCode}), '%')))
+        </if>
+    </select>
+</mapper>

src/main/java/org/springblade/modules/business/data/mapper/RtuDataSzyRiverMapper.java

@@ -0,0 +1,35 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.apache.ibatis.annotations.Param;
+import org.springblade.modules.business.data.dto.RtuDataRsvrDTO;
+import org.springblade.modules.business.data.entity.RtuDataRsvrEntity;
+import org.springblade.modules.business.data.vo.RtuDataRsvrVO;
+
+import java.util.List;
+
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public interface RtuDataRsvrMapper extends BaseMapper<RtuDataRsvrEntity> {
+	/**
+	 * 自定义分页
+	 *
+	 * @param page 分页
+	 * @return List<RtuInfoVO>
+	 */
+	List<RtuDataRsvrVO> selectPage(IPage page, @Param("rsvrDTO") RtuDataRsvrDTO rsvrDTO);
+}

src/main/java/org/springblade/modules/business/data/mapper/RtuDataSzyRiverMapper.xml

@@ -0,0 +1,46 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="org.springblade.modules.business.data.mapper.RtuDataRsvrMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="rtuRsvrDataEntityResultMap" type="org.springblade.modules.business.data.entity.RtuDataRsvrEntity">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="tm" property="tm"/>
+        <result column="rz" property="rz"/>
+        <result column="up_time" property="upTime"/>
+        <result column="from_time" property="fromTime"/>
+    </resultMap>
+
+    <resultMap id="rtuRsvrDataVOResultMap" type="org.springblade.modules.business.data.vo.RtuDataRsvrVO">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="tm" property="tm"/>
+        <result column="rz" property="rz"/>
+        <result column="rtu_name" property="rtuName"/>
+        <result column="ad_city" property="adCity"/>
+        <result column="ad_dist" property="adDist"/>
+        <result column="up_time" property="upTime"/>
+        <result column="from_time" property="fromTime"/>
+    </resultMap>
+
+
+    <select id="selectPage" resultMap="rtuRsvrDataVOResultMap">
+        SELECT
+        n.*,
+        r.rtu_name,r.ad_city,r.ad_dist
+        FROM
+        data_att_st_res_ware_cache n
+        LEFT JOIN  rtu_info r ON n.rtu_code = r.rtu_code and r.is_deleted=0
+        LEFT JOIN  data_ad_cd_b a ON a.adcd = r.ad_code and a.is_deleted=0
+        WHERE
+        n.is_deleted = 0
+        <if test="rsvrDTO.rtuName!=null ">
+            and r.rtu_name LIKE concat(concat('%', #{rsvrDTO.rtuName}), '%')
+        </if>
+        <if test="rsvrDTO.rtuCode!=null">
+            and n.rtu_code like concat(concat('%', #{rsvrDTO.rtuCode}), '%')
+        </if>
+        <if test="rsvrDTO.adCode!=null">
+            and (a.adcd =#{rsvrDTO.adCode} or a.ancestors in (SELECT ancestors FROM data_ad_cd_b WHERE ancestors  like concat(concat('%', #{rsvrDTO.adCode}), '%')))
+        </if>
+    </select>
+</mapper>

src/main/java/org/springblade/modules/business/data/mapper/RtuDataWeatherMapper.java

@@ -0,0 +1,34 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.apache.ibatis.annotations.Param;
+import org.springblade.modules.business.data.dto.RtuDataRainDTO;
+import org.springblade.modules.business.data.entity.RtuDataRainEntity;
+import org.springblade.modules.business.data.vo.RtuDataRainVO;
+
+import java.util.List;
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public interface RtuDataRainMapper extends BaseMapper<RtuDataRainEntity> {
+	/**
+	 * 自定义分页
+	 *
+	 * @param page 分页
+	 * @return List<RtuInfoVO>
+	 */
+	List<RtuDataRainVO> selectPage(IPage page, @Param("rtuDataRainDTO") RtuDataRainDTO rtuDataRainDTO);
+}

src/main/java/org/springblade/modules/business/data/mapper/RtuDataWeatherMapper.xml

@@ -0,0 +1,50 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="org.springblade.modules.business.data.mapper.RtuDataRainMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="rtuRainDataResultMap" type="org.springblade.modules.business.data.entity.RtuDataRainEntity">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="tm" property="tm"/>
+        <result column="drp" property="drp"/>
+        <result column="intv" property="intv"/>
+        <result column="up_time" property="upTime"/>
+        <result column="from_time" property="fromTime"/>
+    </resultMap>
+
+
+    <resultMap id="rtuRainDataVOResultMap" type="org.springblade.modules.business.data.vo.RtuDataRainVO">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="tm" property="tm"/>
+        <result column="drp" property="drp"/>
+        <result column="intv" property="intv"/>
+        <result column="rtu_name" property="rtuName"/>
+        <result column="ad_city" property="adCity"/>
+        <result column="ad_dist" property="adDist"/>
+        <result column="up_time" property="upTime"/>
+        <result column="from_time" property="fromTime"/>
+    </resultMap>
+
+
+    <select id="selectPage" resultMap="rtuRainDataVOResultMap">
+        SELECT
+        n.*,
+        r.rtu_name,r.ad_city,r.ad_dist
+        FROM
+        data_att_st_prec_cache n
+        LEFT JOIN  rtu_info r ON n.rtu_code = r.rtu_code and r.is_deleted=0
+        LEFT JOIN  data_ad_cd_b a ON a.adcd = r.ad_code and a.is_deleted=0
+        WHERE
+        n.is_deleted = 0
+        <if test="rtuDataRainDTO.rtuName!=null ">
+            and r.rtu_name LIKE concat(concat('%', #{rtuDataRainDTO.rtuName}), '%')
+        </if>
+        <if test="rtuDataRainDTO.rtuCode!=null">
+            and n.rtu_code like concat(concat('%', #{rtuDataRainDTO.rtuCode}), '%')
+        </if>
+        <if test="rtuDataRainDTO.adCode!=null">
+            and (a.adcd =#{rtuDataRainDTO.adCode} or a.ancestors in (SELECT ancestors FROM data_ad_cd_b WHERE ancestors  like concat(concat('%', #{rtuDataRainDTO.adCode}), '%')))
+        </if>
+
+    </select>
+</mapper>

src/main/java/org/springblade/modules/business/data/mapper/RtuRealTimeStatusHistoreMapper.java

@@ -0,0 +1,24 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.springblade.modules.business.data.entity.RtuRealTimeStatusEntity;
+
+
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public interface RtuRealTimeStatusMapper extends BaseMapper<RtuRealTimeStatusEntity> {
+
+}

src/main/java/org/springblade/modules/business/data/mapper/RtuRealTimeStatusHistoreMapper.xml

@@ -0,0 +1,32 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="org.springblade.modules.business.data.mapper.RtuRealTimeStatusMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="rtuRsvrDataEntityResultMap" type="org.springblade.modules.business.data.entity.RtuRealTimeStatusEntity">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="collect_time" property="collectTime"/>
+        <result column="up_time" property="upTime"/>
+        <result column="pick_time" property="pickTime"/>
+        <result column="lng" property="lng"/>
+        <result column="lat" property="lat"/>
+        <result column="dtu_signal" property="dtuSignal"/>
+        <result column="voltage" property="voltage"/>
+        <result column="temperature" property="temperature"/>
+        <result column="rtu_status" property="rtuStatus"/>
+        <result column="rtu_error" property="rtuError"/>
+        <result column="battery_status" property="batteryStatus"/>
+        <result column="battery_battery_in" property="batteryBatteryIn"/>
+        <result column="battery_battery_out" property="batteryBatteryOut"/>
+        <result column="battery_power" property="batteryPower"/>
+        <result column="battery_temperature" property="batteryTemperature"/>
+        <result column="sun_power_voltage" property="sunPowerVoltage"/>
+        <result column="sun_power_electric" property="sunPowerElectric"/>
+        <result column="water_sensor_status" property="waterSensorStatus"/>
+        <result column="ac_charge_warning" property="acChargeWarning"/>
+        <result column="battery_voltage_warning" property="batteryVoltageWarning"/>
+        <result column="datagram_channel_index" property="datagramChannelIndex"/>
+
+    </resultMap>
+
+</mapper>

src/main/java/org/springblade/modules/business/data/mapper/RtuRealTimeStatusMapper.java

@@ -0,0 +1,35 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.apache.ibatis.annotations.Param;
+import org.springblade.modules.business.data.dto.RtuDataRsvrDTO;
+import org.springblade.modules.business.data.entity.RtuDataRsvrEntity;
+import org.springblade.modules.business.data.vo.RtuDataRsvrVO;
+
+import java.util.List;
+
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public interface RtuDataRsvrMapper extends BaseMapper<RtuDataRsvrEntity> {
+	/**
+	 * 自定义分页
+	 *
+	 * @param page 分页
+	 * @return List<RtuInfoVO>
+	 */
+	List<RtuDataRsvrVO> selectPage(IPage page, @Param("rsvrDTO") RtuDataRsvrDTO rsvrDTO);
+}

src/main/java/org/springblade/modules/business/data/mapper/RtuRealTimeStatusMapper.xml

@@ -0,0 +1,46 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="org.springblade.modules.business.data.mapper.RtuDataRsvrMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="rtuRsvrDataEntityResultMap" type="org.springblade.modules.business.data.entity.RtuDataRsvrEntity">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="tm" property="tm"/>
+        <result column="rz" property="rz"/>
+        <result column="up_time" property="upTime"/>
+        <result column="from_time" property="fromTime"/>
+    </resultMap>
+
+    <resultMap id="rtuRsvrDataVOResultMap" type="org.springblade.modules.business.data.vo.RtuDataRsvrVO">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="tm" property="tm"/>
+        <result column="rz" property="rz"/>
+        <result column="rtu_name" property="rtuName"/>
+        <result column="ad_city" property="adCity"/>
+        <result column="ad_dist" property="adDist"/>
+        <result column="up_time" property="upTime"/>
+        <result column="from_time" property="fromTime"/>
+    </resultMap>
+
+
+    <select id="selectPage" resultMap="rtuRsvrDataVOResultMap">
+        SELECT
+        n.*,
+        r.rtu_name,r.ad_city,r.ad_dist
+        FROM
+        data_att_st_res_ware_cache n
+        LEFT JOIN  rtu_info r ON n.rtu_code = r.rtu_code and r.is_deleted=0
+        LEFT JOIN  data_ad_cd_b a ON a.adcd = r.ad_code and a.is_deleted=0
+        WHERE
+        n.is_deleted = 0
+        <if test="rsvrDTO.rtuName!=null ">
+            and r.rtu_name LIKE concat(concat('%', #{rsvrDTO.rtuName}), '%')
+        </if>
+        <if test="rsvrDTO.rtuCode!=null">
+            and n.rtu_code like concat(concat('%', #{rsvrDTO.rtuCode}), '%')
+        </if>
+        <if test="rsvrDTO.adCode!=null">
+            and (a.adcd =#{rsvrDTO.adCode} or a.ancestors in (SELECT ancestors FROM data_ad_cd_b WHERE ancestors  like concat(concat('%', #{rsvrDTO.adCode}), '%')))
+        </if>
+    </select>
+</mapper>

src/main/java/org/springblade/modules/business/data/service/IRtuDataGroundHistoreService.java

@@ -0,0 +1,39 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.service;
+
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.springblade.core.mp.base.BaseService;
+import org.springblade.etl.entity.EtlGroundDataEntity;
+import org.springblade.modules.business.data.dto.RtuDataGroundDTO;
+import org.springblade.modules.business.data.entity.RtuDataGroundEntity;
+import org.springblade.modules.business.data.vo.RtuDataGroundVO;
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public interface IRtuDataGroundService extends BaseService<RtuDataGroundEntity> {
+	/**
+	 * 自定义分页
+	 * @param page
+	 * @return
+	 */
+	IPage<RtuDataGroundVO> selectPage(IPage<RtuDataGroundVO> page, RtuDataGroundDTO rtuDataGroundDTO);
+
+	/**
+	 * 更新或插入墒情数据
+	 * @param etlGroundDataEntity
+	 * @return
+	 */
+	boolean updateGroundInfo(EtlGroundDataEntity etlGroundDataEntity);
+}

src/main/java/org/springblade/modules/business/data/service/IRtuDataRainHistoreService.java

@@ -0,0 +1,39 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.service;
+
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.springblade.core.mp.base.BaseService;
+import org.springblade.etl.entity.EtlRainDataEntity;
+import org.springblade.modules.business.data.dto.RtuDataRainDTO;
+import org.springblade.modules.business.data.entity.RtuDataRainEntity;
+import org.springblade.modules.business.data.vo.RtuDataRainVO;
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public interface IRtuDataRainService extends BaseService<RtuDataRainEntity> {
+	/**
+	 * 自定义分页
+	 * @param page
+	 * @return
+	 */
+	IPage<RtuDataRainVO> selectPage(IPage<RtuDataRainVO> page, RtuDataRainDTO rtuDataRainDTO);
+
+	/**
+	 * 更新或插入雨情数据
+	 * @param entity
+	 * @return
+	 */
+	boolean updateRainInfo(RtuDataRainEntity entity);
+}

src/main/java/org/springblade/modules/business/data/service/IRtuDataRiverHistoreService.java

@@ -0,0 +1,44 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.service;
+
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.apache.ibatis.annotations.Param;
+import org.springblade.core.mp.base.BaseService;
+import org.springblade.etl.entity.EtlRiverDataEntity;
+import org.springblade.modules.business.data.dto.RtuDataRiverDTO;
+import org.springblade.modules.business.data.entity.RtuDataRiverEntity;
+import org.springblade.modules.business.data.vo.RtuDataRiverVO;
+
+import java.util.List;
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public interface IRtuDataRiverService extends BaseService<RtuDataRiverEntity> {
+	/**
+	 * 自定义分页
+	 * @param page
+	 * @return
+	 */
+	IPage<RtuDataRiverVO> selectPage(IPage<RtuDataRiverVO> page, RtuDataRiverDTO rtuDataRiverDTO);
+
+	/**
+	 * 更新或插入河道水情数据
+	 * @param entity
+	 * @return
+	 */
+	boolean updateRiverInfo(RtuDataRiverEntity entity);
+
+	IPage<RtuDataRiverVO> selectWaterPage(IPage<RtuDataRiverVO> page, RtuDataRiverDTO rtuDataRiverDTO);
+}

src/main/java/org/springblade/modules/business/data/service/IRtuDataRsvrHistoreService.java

@@ -0,0 +1,39 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.service;
+
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.springblade.core.mp.base.BaseService;
+import org.springblade.etl.entity.EtlRsvrDataEntity;
+import org.springblade.modules.business.data.dto.RtuDataRsvrDTO;
+import org.springblade.modules.business.data.entity.RtuDataRsvrEntity;
+import org.springblade.modules.business.data.vo.RtuDataRsvrVO;
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public interface IRtuDataRsvrService extends BaseService<RtuDataRsvrEntity> {
+	/**
+	 * 自定义分页
+	 * @param page
+	 * @return
+	 */
+	IPage<RtuDataRsvrVO> selectPage(IPage<RtuDataRsvrVO> page, RtuDataRsvrDTO rtuDataRsvrDTO);
+
+	/**
+	 * 更新或插入水库水情数据
+	 * @param entity
+	 * @return
+	 */
+	boolean updateRsvrInfo(RtuDataRsvrEntity entity);
+}

src/main/java/org/springblade/modules/business/data/service/IRtuDataSzyMpHistoreService.java

@@ -0,0 +1,21 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2023/6/16
+ */
+package org.springblade.modules.business.data.service;
+
+import org.springblade.core.mp.base.BaseService;
+import org.springblade.modules.business.data.entity.RtuDataSzyFlowRateEntity;
+
+/***
+ * Date:2023/6/16
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public interface IRtuDataSzyMpService extends BaseService<RtuDataSzyFlowRateEntity> {
+}

src/main/java/org/springblade/modules/business/data/service/IRtuDataSzyMpService.java

@@ -0,0 +1,18 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2023/6/16
+ */
+package org.springblade.modules.business.data.service;
+
+/*** 
+ * Date:2023/6/16
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public class IRtuDataSzyMpService {
+}

src/main/java/org/springblade/modules/business/data/service/IRtuDataSzyRiverHistoreService.java

@@ -0,0 +1,21 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2023/6/16
+ */
+package org.springblade.modules.business.data.service;
+
+import org.springblade.core.mp.base.BaseService;
+import org.springblade.modules.business.data.entity.RtuDataWqRiverEntity;
+
+/***
+ * Date:2023/6/16
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public interface IRtuDataSzyRiverService extends BaseService<RtuDataWqRiverEntity> {
+}

src/main/java/org/springblade/modules/business/data/service/IRtuDataSzyRiverService.java

@@ -0,0 +1,18 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2023/6/16
+ */
+package org.springblade.modules.business.data.service;
+
+/*** 
+ * Date:2023/6/16
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public class IRtuDataSzyRiverService {
+}

src/main/java/org/springblade/modules/business/data/service/IRtuDataWeatherService.java

@@ -0,0 +1,39 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.service;
+
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.springblade.core.mp.base.BaseService;
+import org.springblade.etl.entity.EtlRainDataEntity;
+import org.springblade.modules.business.data.dto.RtuDataRainDTO;
+import org.springblade.modules.business.data.entity.RtuDataRainEntity;
+import org.springblade.modules.business.data.vo.RtuDataRainVO;
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public interface IRtuDataRainService extends BaseService<RtuDataRainEntity> {
+	/**
+	 * 自定义分页
+	 * @param page
+	 * @return
+	 */
+	IPage<RtuDataRainVO> selectPage(IPage<RtuDataRainVO> page, RtuDataRainDTO rtuDataRainDTO);
+
+	/**
+	 * 更新或插入雨情数据
+	 * @param entity
+	 * @return
+	 */
+	boolean updateRainInfo(RtuDataRainEntity entity);
+}

src/main/java/org/springblade/modules/business/data/service/IRtuRealTimeStatusHistoreService.java

@@ -0,0 +1,7 @@
+package org.springblade.modules.business.data.service;
+
+import org.springblade.core.mp.base.BaseService;
+import org.springblade.modules.business.data.entity.RtuRealTimeStatusEntity;
+
+public interface IRtuRealTimeStatusService extends BaseService<RtuRealTimeStatusEntity> {
+}

src/main/java/org/springblade/modules/business/data/service/IRtuRealTimeStatusService.java

@@ -0,0 +1,4 @@
+package org.springblade.modules.business.data.service;
+
+public interface IRtuRealTimeStatusService {
+}

src/main/java/org/springblade/modules/business/data/service/impl/RtuDataGroundHistoreServiceImpl.java

@@ -0,0 +1,65 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import org.springblade.core.mp.base.BaseServiceImpl;
+import org.springblade.etl.entity.EtlGroundDataEntity;
+import org.springblade.modules.business.data.dto.RtuDataGroundDTO;
+import org.springblade.modules.business.data.entity.RtuDataGroundEntity;
+import org.springblade.modules.business.data.mapper.RtuDataGroundMapper;
+import org.springblade.modules.business.data.service.IRtuDataGroundService;
+import org.springblade.modules.business.data.vo.RtuDataGroundVO;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Service
+public class RtuDataGroundServiceImpl extends BaseServiceImpl<RtuDataGroundMapper, RtuDataGroundEntity> implements IRtuDataGroundService {
+	@Override
+	public IPage<RtuDataGroundVO> selectPage(IPage<RtuDataGroundVO> page, RtuDataGroundDTO rtuDataGroundDTO) {
+		return page.setRecords(baseMapper.selectPage(page, rtuDataGroundDTO));
+	}
+
+	@Override
+	public boolean updateGroundInfo(EtlGroundDataEntity etlGroundDataEntity) {
+		LambdaQueryWrapper<RtuDataGroundEntity> dataWrapper = Wrappers.<RtuDataGroundEntity>query().lambda();
+		dataWrapper.eq(RtuDataGroundEntity::getRtuCode, etlGroundDataEntity.getRtuCode());
+		dataWrapper.eq(RtuDataGroundEntity::getIsDeleted, 0);
+		RtuDataGroundEntity groundDataEntity = this.getOne(dataWrapper);
+		if (null == groundDataEntity) {
+			groundDataEntity = new RtuDataGroundEntity();
+			groundDataEntity.setRtuCode(etlGroundDataEntity.getRtuCode());
+			groundDataEntity.setCreateTime(new Date());
+			groundDataEntity.setStatus(1);
+			groundDataEntity.setIsDeleted(0);
+		}
+		groundDataEntity.setSlm10(etlGroundDataEntity.getMoco10cm());
+		groundDataEntity.setSlm20(etlGroundDataEntity.getMoco20cm());
+		groundDataEntity.setSlm30(etlGroundDataEntity.getMoco30cm());
+		groundDataEntity.setSlm40(etlGroundDataEntity.getMoco40cm());
+		groundDataEntity.setSlm50(etlGroundDataEntity.getMoco50cm());
+		groundDataEntity.setSlm60(etlGroundDataEntity.getMoco60cm());
+		groundDataEntity.setSlm80(etlGroundDataEntity.getMoco80cm());
+		groundDataEntity.setSlm100(etlGroundDataEntity.getMoco100cm());
+		groundDataEntity.setSrlslm(etlGroundDataEntity.getSurfMoco());
+		groundDataEntity.setVtavslm(etlGroundDataEntity.getVertAverMoco());
+		groundDataEntity.setTm(etlGroundDataEntity.getTm());
+		groundDataEntity.setFromTime(etlGroundDataEntity.getFromDate());
+		return this.saveOrUpdate(groundDataEntity);
+	}
+}

src/main/java/org/springblade/modules/business/data/service/impl/RtuDataRainHistoreServiceImpl.java

@@ -0,0 +1,52 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import org.springblade.core.mp.base.BaseServiceImpl;
+import org.springblade.etl.entity.EtlRainDataEntity;
+import org.springblade.modules.business.data.dto.RtuDataRainDTO;
+import org.springblade.modules.business.data.entity.RtuDataRainEntity;
+import org.springblade.modules.business.data.mapper.RtuDataRainMapper;
+import org.springblade.modules.business.data.service.IRtuDataRainService;
+import org.springblade.modules.business.data.vo.RtuDataRainVO;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.Date;
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Service
+public class RtuDataRainServiceImpl extends BaseServiceImpl<RtuDataRainMapper, RtuDataRainEntity> implements IRtuDataRainService {
+
+	@Override
+	public IPage<RtuDataRainVO> selectPage(IPage<RtuDataRainVO> page, RtuDataRainDTO rtuDataRainDTO) {
+		return page.setRecords(baseMapper.selectPage(page, rtuDataRainDTO));
+	}
+
+	@Override
+	public boolean updateRainInfo(RtuDataRainEntity entity) {
+		LambdaQueryWrapper<RtuDataRainEntity> dataWrapper = Wrappers.<RtuDataRainEntity>query().lambda();
+		dataWrapper.eq(RtuDataRainEntity::getRtuCode, entity.getRtuCode());
+		dataWrapper.eq(RtuDataRainEntity::getIsDeleted, 0);
+		RtuDataRainEntity rainEntity = this.getOne(dataWrapper);
+		if (null != rainEntity) {
+			entity.setId(rainEntity.getId());
+		}
+		entity.setUpdateTime(new Date());
+		return this.saveOrUpdate(entity);
+	}
+}

src/main/java/org/springblade/modules/business/data/service/impl/RtuDataRiverHistoreServiceImpl.java

@@ -0,0 +1,57 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.service.impl;
+
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import org.springblade.core.mp.base.BaseServiceImpl;
+import org.springblade.etl.entity.EtlRiverDataEntity;
+import org.springblade.modules.business.data.dto.RtuDataRiverDTO;
+import org.springblade.modules.business.data.entity.RtuDataRiverEntity;
+import org.springblade.modules.business.data.mapper.RtuDataRiverMapper;
+import org.springblade.modules.business.data.service.IRtuDataRiverService;
+import org.springblade.modules.business.data.vo.RtuDataRiverVO;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+import java.util.List;
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Service
+public class RtuDataRiverServiceImpl extends BaseServiceImpl<RtuDataRiverMapper, RtuDataRiverEntity> implements IRtuDataRiverService {
+    @Override
+    public IPage<RtuDataRiverVO> selectPage(IPage<RtuDataRiverVO> page, RtuDataRiverDTO rtuDataRiverDTO) {
+        return page.setRecords(baseMapper.selectPage(page, rtuDataRiverDTO));
+    }
+
+    @Override
+    public boolean updateRiverInfo(RtuDataRiverEntity entity) {
+        LambdaQueryWrapper<RtuDataRiverEntity> dataWrapper = Wrappers.<RtuDataRiverEntity>query().lambda();
+        dataWrapper.eq(RtuDataRiverEntity::getRtuCode, entity.getRtuCode());
+        dataWrapper.eq(RtuDataRiverEntity::getIsDeleted, 0);
+        RtuDataRiverEntity riverEntity = this.getOne(dataWrapper);
+        if (null != riverEntity) {
+            entity.setId(riverEntity.getId());
+        }
+        entity.setUpdateTime(new Date());
+        return this.saveOrUpdate(entity);
+    }
+
+    @Override
+    public IPage<RtuDataRiverVO> selectWaterPage(IPage<RtuDataRiverVO> page, RtuDataRiverDTO rtuDataRiverDTO) {
+        return page.setRecords(baseMapper.selectWaterPage(page, rtuDataRiverDTO));
+    }
+}

src/main/java/org/springblade/modules/business/data/service/impl/RtuDataRsvrHistoreServiceImpl.java

@@ -0,0 +1,51 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.service.impl;
+
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import org.springblade.core.mp.base.BaseServiceImpl;
+import org.springblade.etl.entity.EtlRsvrDataEntity;
+import org.springblade.modules.business.data.dto.RtuDataRsvrDTO;
+import org.springblade.modules.business.data.entity.RtuDataRsvrEntity;
+import org.springblade.modules.business.data.mapper.RtuDataRsvrMapper;
+import org.springblade.modules.business.data.service.IRtuDataRsvrService;
+import org.springblade.modules.business.data.vo.RtuDataRsvrVO;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Service
+public class RtuDataRsvrServiceImpl extends BaseServiceImpl<RtuDataRsvrMapper, RtuDataRsvrEntity> implements IRtuDataRsvrService {
+	@Override
+	public IPage<RtuDataRsvrVO> selectPage(IPage<RtuDataRsvrVO> page, RtuDataRsvrDTO rtuDataRsvrDTO) {
+		return page.setRecords(baseMapper.selectPage(page, rtuDataRsvrDTO));
+	}
+
+	@Override
+	public boolean updateRsvrInfo(RtuDataRsvrEntity entity) {
+		LambdaQueryWrapper<RtuDataRsvrEntity> dataWrapper = Wrappers.<RtuDataRsvrEntity>query().lambda();
+		dataWrapper.eq(RtuDataRsvrEntity::getRtuCode, entity.getRtuCode());
+		dataWrapper.eq(RtuDataRsvrEntity::getIsDeleted, 0);
+		RtuDataRsvrEntity rsvrDataEntity = this.getOne(dataWrapper);
+		if (null != rsvrDataEntity) {
+			entity.setId(rsvrDataEntity.getId());
+		}
+		entity.setUpdateTime(new Date());
+		return this.saveOrUpdate(entity);
+	}
+}

src/main/java/org/springblade/modules/business/data/service/impl/RtuDataSzyMpHistoreServiceImpl.java

@@ -0,0 +1,25 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2023/6/16
+ */
+package org.springblade.modules.business.data.service.impl;
+
+import org.springblade.core.mp.base.BaseServiceImpl;
+import org.springblade.modules.business.data.entity.RtuDataSzyFlowRateEntity;
+import org.springblade.modules.business.data.mapper.RtuDataSzyMpMapper;
+import org.springblade.modules.business.data.service.IRtuDataSzyMpService;
+import org.springframework.stereotype.Service;
+
+/***
+ * Date:2023/6/16
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Service
+public class RtuDataSzyMpServiceImpl extends BaseServiceImpl<RtuDataSzyMpMapper, RtuDataSzyFlowRateEntity> implements IRtuDataSzyMpService {
+}

src/main/java/org/springblade/modules/business/data/service/impl/RtuDataSzyMpServiceImpl.java

@@ -0,0 +1,18 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2023/6/16
+ */
+package org.springblade.modules.business.data.service.impl;
+
+/*** 
+ * Date:2023/6/16
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public class RtuDataSzyMpServiceImpl {
+}

src/main/java/org/springblade/modules/business/data/service/impl/RtuDataSzyRiverHistoreServiceImpl.java

@@ -0,0 +1,25 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2023/6/16
+ */
+package org.springblade.modules.business.data.service.impl;
+
+import org.springblade.core.mp.base.BaseServiceImpl;
+import org.springblade.modules.business.data.entity.RtuDataWqRiverEntity;
+import org.springblade.modules.business.data.mapper.RtuDataSzyRiverMapper;
+import org.springblade.modules.business.data.service.IRtuDataSzyRiverService;
+import org.springframework.stereotype.Service;
+
+/***
+ * Date:2023/6/16
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Service
+public class RtuDataSzyRiverServiceImpl extends BaseServiceImpl<RtuDataSzyRiverMapper, RtuDataWqRiverEntity> implements IRtuDataSzyRiverService {
+}

src/main/java/org/springblade/modules/business/data/service/impl/RtuDataSzyRiverServiceImpl.java

@@ -0,0 +1,18 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2023/6/16
+ */
+package org.springblade.modules.business.data.service.impl;
+
+/*** 
+ * Date:2023/6/16
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public class RtuDataSzyRiverServiceImpl {
+}

src/main/java/org/springblade/modules/business/data/service/impl/RtuDataWeatherServiceImpl.java

@@ -0,0 +1,52 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import org.springblade.core.mp.base.BaseServiceImpl;
+import org.springblade.etl.entity.EtlRainDataEntity;
+import org.springblade.modules.business.data.dto.RtuDataRainDTO;
+import org.springblade.modules.business.data.entity.RtuDataRainEntity;
+import org.springblade.modules.business.data.mapper.RtuDataRainMapper;
+import org.springblade.modules.business.data.service.IRtuDataRainService;
+import org.springblade.modules.business.data.vo.RtuDataRainVO;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.Date;
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Service
+public class RtuDataRainServiceImpl extends BaseServiceImpl<RtuDataRainMapper, RtuDataRainEntity> implements IRtuDataRainService {
+
+	@Override
+	public IPage<RtuDataRainVO> selectPage(IPage<RtuDataRainVO> page, RtuDataRainDTO rtuDataRainDTO) {
+		return page.setRecords(baseMapper.selectPage(page, rtuDataRainDTO));
+	}
+
+	@Override
+	public boolean updateRainInfo(RtuDataRainEntity entity) {
+		LambdaQueryWrapper<RtuDataRainEntity> dataWrapper = Wrappers.<RtuDataRainEntity>query().lambda();
+		dataWrapper.eq(RtuDataRainEntity::getRtuCode, entity.getRtuCode());
+		dataWrapper.eq(RtuDataRainEntity::getIsDeleted, 0);
+		RtuDataRainEntity rainEntity = this.getOne(dataWrapper);
+		if (null != rainEntity) {
+			entity.setId(rainEntity.getId());
+		}
+		entity.setUpdateTime(new Date());
+		return this.saveOrUpdate(entity);
+	}
+}

src/main/java/org/springblade/modules/business/data/service/impl/RtuRealTimeStatusServiceHistoreImpl.java

@@ -0,0 +1,23 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2023/6/15
+ */
+package org.springblade.modules.business.data.service.impl;
+
+import org.springblade.core.mp.base.BaseServiceImpl;
+import org.springblade.modules.business.data.entity.RtuRealTimeStatusEntity;
+import org.springblade.modules.business.data.mapper.RtuRealTimeStatusMapper;
+import org.springblade.modules.business.data.service.IRtuRealTimeStatusService;
+
+/***
+ * Date:2023/6/15
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public class RtuRealTimeStatusServiceImpl extends BaseServiceImpl<RtuRealTimeStatusMapper, RtuRealTimeStatusEntity> implements IRtuRealTimeStatusService {
+}

src/main/java/org/springblade/modules/business/data/service/impl/RtuRealTimeStatusServiceImpl.java

@@ -0,0 +1,18 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2023/6/15
+ */
+package org.springblade.modules.business.data.service.impl;
+
+/*** 
+ * Date:2023/6/15
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public class RtuRealTimeStatusServiceImpl {
+}

src/main/java/org/springblade/modules/business/data/vo/RtuDataGroundStoreVO.java

@@ -0,0 +1,50 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.vo;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springblade.modules.business.data.entity.RtuDataGroundEntity;
+
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class RtuDataGroundVO extends RtuDataGroundEntity {
+
+	/**
+	 * 测站名称
+	 */
+	@ApiModelProperty("测站名称")
+	private String rtuName;
+
+	/**
+	 * 所属盟市
+	 */
+	@ApiModelProperty(value = "所属盟市")
+	private String adCity;
+
+	/**
+	 * 所属盟县旗区
+	 */
+	@ApiModelProperty(value = "所属盟县旗区")
+	private String adDist;
+
+	/**
+	 * 行政区
+	 */
+	@ApiModelProperty(value = "行政区")
+	private String areaName;
+}

src/main/java/org/springblade/modules/business/data/vo/RtuDataRainStoreVO.java

@@ -0,0 +1,57 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.vo;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springblade.modules.business.data.entity.RtuDataRainEntity;
+
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class RtuDataRainVO extends RtuDataRainEntity {
+
+	/**
+	 * 测站名称
+	 */
+	@ApiModelProperty("测站名称")
+	private String rtuName;
+
+	/**
+	 * 测站类型概要
+	 */
+	@ApiModelProperty(value = "测站类型概要")
+	private String rtuKindDesc;
+
+	/**
+	 * 所属盟市
+	 */
+	@ApiModelProperty(value = "所属盟市")
+	private String adCity;
+
+	/**
+	 * 所属盟县旗区
+	 */
+	@ApiModelProperty(value = "所属盟县旗区")
+	private String adDist;
+
+	/**
+	 * 行政区
+	 */
+	@ApiModelProperty(value = "行政区")
+	private String areaName;
+
+}

src/main/java/org/springblade/modules/business/data/vo/RtuDataRiverStoreVO.java

@@ -0,0 +1,95 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.vo;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.ser.std.NullSerializer;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springblade.modules.business.data.entity.RtuDataRiverEntity;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.util.Date;
+
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class RtuDataRiverVO extends RtuDataRiverEntity {
+	/**
+	 * 测站名称
+	 */
+	@ApiModelProperty("测站名称")
+	private String rtuName;
+
+	/**
+	 * 所属盟市
+	 */
+	@ApiModelProperty(value = "所属盟市")
+	private String adCity;
+
+	/**
+	 * 所属盟县旗区
+	 */
+	@ApiModelProperty(value = "所属盟县旗区")
+	private String adDist;
+
+	/**
+	 * 行政区
+	 */
+	@ApiModelProperty(value = "行政区")
+	private String areaName;
+
+
+	/**
+	 * 库上水位
+	 */
+	@ApiModelProperty("库上水位")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double rz;
+
+
+	/**
+	 * 水库水位时间
+	 */
+	@ApiModelProperty("时间")
+	@DateTimeFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss"
+	)
+	@JsonFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss",
+		timezone = "GMT+8"
+	)
+	private Date rsvrTm;
+
+
+	@ApiModelProperty("水位")
+	@JsonSerialize(nullsUsing = NullSerializer.class)
+	private Double wl;
+
+	/**
+	 * 水库水位时间
+	 */
+	@ApiModelProperty("时间")
+	@DateTimeFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss"
+	)
+	@JsonFormat(
+		pattern = "yyyy-MM-dd HH:mm:ss",
+		timezone = "GMT+8"
+	)
+	private Date wlTm;
+}

src/main/java/org/springblade/modules/business/data/vo/RtuDataRsvrStoreVO.java

@@ -0,0 +1,49 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/28
+ */
+package org.springblade.modules.business.data.vo;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springblade.modules.business.data.entity.RtuDataRsvrEntity;
+
+
+/***
+ * Date:2022/8/28
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class RtuDataRsvrVO extends RtuDataRsvrEntity {
+	/**
+	 * 测站名称
+	 */
+	@ApiModelProperty("测站名称")
+	private String rtuName;
+
+	/**
+	 * 所属盟市
+	 */
+	@ApiModelProperty(value = "所属盟市")
+	private String adCity;
+
+	/**
+	 * 所属盟县旗区
+	 */
+	@ApiModelProperty(value = "所属盟县旗区")
+	private String adDist;
+
+	/**
+	 * 行政区
+	 */
+	@ApiModelProperty(value = "行政区")
+	private String areaName;
+}

src/main/java/org/springblade/modules/business/data/wrapper/RtuDataGroundHistoreWrapper.java

@@ -0,0 +1,36 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/22
+ */
+package org.springblade.modules.business.data.wrapper;
+
+import org.springblade.core.mp.support.BaseEntityWrapper;
+import org.springblade.core.tool.utils.BeanUtil;
+import org.springblade.modules.business.data.entity.RtuDataGroundEntity;
+import org.springblade.modules.business.data.vo.RtuDataGroundVO;
+
+
+import java.util.Objects;
+
+/***
+ * Date:2022/8/22
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public class RtuDataGroundWrapper extends BaseEntityWrapper<RtuDataGroundEntity, RtuDataGroundVO> {
+	public static RtuDataGroundWrapper build() {
+		return new RtuDataGroundWrapper();
+	}
+
+	@Override
+	public RtuDataGroundVO entityVO(RtuDataGroundEntity entity) {
+		RtuDataGroundVO rtuDataGroundVO = Objects.requireNonNull(BeanUtil.copy(entity, RtuDataGroundVO.class));
+
+		return rtuDataGroundVO;
+	}
+}

src/main/java/org/springblade/modules/business/data/wrapper/RtuDataRainHistoreWrapper.java

@@ -0,0 +1,35 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/22
+ */
+package org.springblade.modules.business.data.wrapper;
+
+import org.springblade.core.mp.support.BaseEntityWrapper;
+import org.springblade.core.tool.utils.BeanUtil;
+import org.springblade.modules.business.data.entity.RtuDataRainEntity;
+import org.springblade.modules.business.data.vo.RtuDataRainVO;
+
+
+import java.util.Objects;
+
+/***
+ * Date:2022/8/22
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public class RtuDataRainWrapper extends BaseEntityWrapper<RtuDataRainEntity, RtuDataRainVO> {
+	public static RtuDataRainWrapper build() {
+		return new RtuDataRainWrapper();
+	}
+
+	@Override
+	public RtuDataRainVO entityVO(RtuDataRainEntity entity) {
+		RtuDataRainVO rtuDataRainVO = Objects.requireNonNull(BeanUtil.copy(entity, RtuDataRainVO.class));
+		return rtuDataRainVO;
+	}
+}

src/main/java/org/springblade/modules/business/data/wrapper/RtuDataRiverHistoreWrapper.java

@@ -0,0 +1,47 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/22
+ */
+package org.springblade.modules.business.data.wrapper;
+
+
+import org.springblade.core.mp.support.BaseEntityWrapper;
+import org.springblade.core.tool.utils.BeanUtil;
+import org.springblade.modules.business.data.entity.RtuDataRiverEntity;
+import org.springblade.modules.business.data.vo.RtuDataRiverVO;
+
+
+import java.util.Objects;
+
+/***
+ * Date:2022/8/22
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public class RtuDataRiverWrapper extends BaseEntityWrapper<RtuDataRiverEntity, RtuDataRiverVO> {
+	public static RtuDataRiverWrapper build() {
+		return new RtuDataRiverWrapper();
+	}
+
+	@Override
+	public RtuDataRiverVO entityVO(RtuDataRiverEntity entity) {
+		RtuDataRiverVO rtuInfoVO = Objects.requireNonNull(BeanUtil.copy(entity, RtuDataRiverVO.class));
+		return entityVO(rtuInfoVO);
+	}
+
+	public RtuDataRiverVO entityVO(RtuDataRiverVO vo) {
+		if (vo.getTm() != null) {
+			vo.setWl(vo.getZ());
+			vo.setWlTm(vo.getTm());
+		} else if (vo.getRsvrTm() != null) {
+			vo.setWl(vo.getRz());
+			vo.setWlTm(vo.getRsvrTm());
+		}
+		return vo;
+	}
+}

src/main/java/org/springblade/modules/business/data/wrapper/RtuDataRsvrHistoreWrapper.java

@@ -0,0 +1,37 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/22
+ */
+package org.springblade.modules.business.data.wrapper;
+
+
+import org.springblade.core.mp.support.BaseEntityWrapper;
+import org.springblade.core.tool.utils.BeanUtil;
+import org.springblade.modules.business.data.entity.RtuDataRsvrEntity;
+import org.springblade.modules.business.data.vo.RtuDataRsvrVO;
+
+
+import java.util.Objects;
+
+/***
+ * Date:2022/8/22
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public class RtuDataRsvrWrapper extends BaseEntityWrapper<RtuDataRsvrEntity, RtuDataRsvrVO> {
+	public static RtuDataRsvrWrapper build() {
+		return new RtuDataRsvrWrapper();
+	}
+
+	@Override
+	public RtuDataRsvrVO entityVO(RtuDataRsvrEntity entity) {
+		RtuDataRsvrVO rtuInfoVO = Objects.requireNonNull(BeanUtil.copy(entity, RtuDataRsvrVO.class));
+
+		return rtuInfoVO;
+	}
+}

src/main/java/org/springblade/modules/business/datagram/entity/RtuDatagramInfoEntity.java

@@ -0,0 +1,71 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2023/6/16
+ */
+package org.springblade.modules.business.datagram.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springblade.core.mp.base.BaseEntity;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.util.Date;
+
+/***
+ * Date:2023/6/16
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName("data_rtu_datagram_info")
+public class RtuDatagramInfo extends BaseEntity {
+    private static final long serialVersionUID = 1L;
+    /**
+     * 租户ID
+     */
+    @ApiModelProperty("租户ID")
+    private String tenantId;
+
+    /**
+     * 测站编码
+     */
+    @ApiModelProperty("测站编码")
+    private String rtuCode;
+
+    /**
+     * 原始报文
+     */
+    @ApiModelProperty("原始报文")
+    private String datagram;
+
+    /**
+     * 水文 sw2014
+     * 水资源 szy2012
+     * DTU直传 dtu2021
+     * 内蒙水文扩展 sw2014_nm_ext
+     * 交通jt808
+     */
+    @ApiModelProperty("规约")
+    private String agreement;
+
+    /**
+     * 接收时间
+     */
+    @ApiModelProperty("接收时间")
+    @DateTimeFormat(
+            pattern = "yyyy-MM-dd HH:mm:ss"
+    )
+    @JsonFormat(
+            pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8"
+    )
+    private Date pickTime;
+}

src/main/java/org/springblade/modules/business/datagram/mapper/RtuDatagramMapper.java

@@ -0,0 +1,41 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2022/8/24
+ */
+package org.springblade.modules.business.warning.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.apache.ibatis.annotations.Param;
+import org.springblade.modules.business.warning.dto.RtuWarningInfoDTO;
+import org.springblade.modules.business.warning.entity.RtuWarningInfoEntity;
+import org.springblade.modules.business.warning.vo.RtuWarningInfoVO;
+
+import java.util.List;
+
+/***
+ * Date:2022/8/24
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public interface RtuWarningMapper extends BaseMapper<RtuWarningInfoEntity> {
+	/**
+	 * 查询分页
+	 * @param page
+	 * @param rtuWarningInfoDTO
+	 * @return
+	 */
+	List<RtuWarningInfoVO> selectPage(IPage page, @Param("rtuWarningInfoDTO") RtuWarningInfoDTO rtuWarningInfoDTO);
+
+	/**
+	 * 设备异常测站数量
+	 * @param rtuWarningInfoDTO
+	 * @return
+	 */
+	Long warningRtuCount(@Param("rtuWarningInfoDTO") RtuWarningInfoDTO rtuWarningInfoDTO);
+}

src/main/java/org/springblade/modules/business/datagram/mapper/RtuDatagramMapper.xml

@@ -0,0 +1,74 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="org.springblade.modules.business.warning.mapper.RtuWarningMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="rtuWarningInfoEntityResultMap"
+               type="org.springblade.modules.business.warning.entity.RtuWarningInfoEntity">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="warning_kind" property="warningKind"/>
+        <result column="warning_desc" property="warningDesc"/>
+        <result column="warning_happen_time" property="warningHappenTime"/>
+        <result column="warning_recovery_time" property="warningRecoveryTime"/>
+        <result column="warning_status" property="warningStatus"/>
+        <result column="data_from_id" property="dataFromId"/>
+    </resultMap>
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="rtuWarningInfoVOResultMap" type="org.springblade.modules.business.warning.vo.RtuWarningInfoVO">
+        <result column="rtu_code" property="rtuCode"/>
+        <result column="warning_kind" property="warningKind"/>
+        <result column="warning_desc" property="warningDesc"/>
+        <result column="warning_happen_time" property="warningHappenTime"/>
+        <result column="warning_recovery_time" property="warningRecoveryTime"/>
+        <result column="warning_status" property="warningStatus"/>
+        <result column="data_from_id" property="dataFromId"/>
+        <result column="rtu_name" property="rtuName"/>
+        <result column="ad_city" property="adCity"/>
+        <result column="ad_dist" property="adDist"/>
+        <result column="ancestors" property="ancestors"/>
+        <result column="adcd" property="adCode"/>
+    </resultMap>
+
+
+    <select id="selectPage" resultMap="rtuWarningInfoVOResultMap">
+        SELECT
+        w.*, r.rtu_name,r.ad_city,r.ad_dist,a.ancestors,a.adcd
+        FROM
+        rtu_warning w
+        LEFT JOIN rtu_info r ON r.rtu_code = w.rtu_code
+        LEFT JOIN data_ad_cd_b a ON a.adcd = r.ad_code and a.is_deleted=0
+        WHERE
+        w.is_deleted = 0
+        <if test="rtuWarningInfoDTO.rtuCode!=null">
+            and r.rtu_code like concat(concat('%', #{rtuWarningInfoDTO.rtuCode}), '%')
+        </if>
+        <if test="rtuWarningInfoDTO.rtuName!=null">
+            and r.rtu_name like concat(concat('%', #{rtuWarningInfoDTO.rtuName}), '%')
+        </if>
+        <if test="rtuWarningInfoDTO.warningStatus!=null">
+            and w.warning_status = #{rtuWarningInfoDTO.warningStatus}
+        </if>
+        <if test="rtuWarningInfoDTO.adCode!=null">
+            and (a.adcd =#{rtuWarningInfoDTO.adCode} or a.ancestors in (SELECT ancestors FROM data_ad_cd_b WHERE ancestors  like concat(concat('%', #{rtuWarningInfoDTO.adCode}), '%')))
+        </if>
+        order by w.warning_happen_time desc
+    </select>
+
+    <select id="warningRtuCount" resultType="java.lang.Long">
+        SELECT count(*) FROM
+        ( SELECT
+        w.rtu_code
+        FROM
+        rtu_warning w
+        LEFT JOIN rtu_info r ON w.rtu_code = r.rtu_code and r.is_deleted=0
+        LEFT JOIN data_ad_cd_b a ON a.adcd = r.ad_code and a.is_deleted=0
+        WHERE
+        w.is_deleted = 0
+        <if test="rtuWarningInfoDTO.adCode!=null">
+            and (a.adcd =#{rtuWarningInfoDTO.adCode} or a.ancestors in (SELECT ancestors FROM data_ad_cd_b WHERE ancestors  like concat(concat('%', #{rtuWarningInfoDTO.adCode}), '%')))
+        </if>
+        and w.warning_status = 0
+        group by w.rtu_code ) a
+    </select>
+</mapper>

src/main/java/org/springblade/modules/business/datagram/service/IRtuDatagramService.java

@@ -0,0 +1,18 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2023/6/16
+ */
+package org.springblade.modules.business.datagram.service;
+
+/*** 
+ * Date:2023/6/16
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public class IRtuDatagramService {
+}

src/main/java/org/springblade/modules/business/datagram/service/impl/RtuDatagramServiceImpl.java

@@ -0,0 +1,18 @@
+/**
+ * Copyright 2019 DH
+ * All right reserved.
+ * 项目名称: 大恒泰山系统
+ * 创建日期:2023/6/16
+ */
+package org.springblade.modules.business.datagram.service.impl;
+
+/*** 
+ * Date:2023/6/16
+ * Title:文件所属模块（必须填写）
+ * Description：对本文件的详细描述，原则上不能少于30字
+ * @author dylan
+ * @version 1.0
+ * Remark：认为有必要的其他信息
+ */
+public class RtuDatagramServiceImpl {
+}