diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/pom.xml b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/pom.xml
new file mode 100644
index 0000000..71b49d0
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/pom.xml
@@ -0,0 +1,16 @@
+
+
+
+ hzinfo-ris-pxhd-service-api
+ org.springblade
+ 4.5.0.RELEASE
+
+ 4.0.0
+
+ pxhd-dam-safety-monitor-api
+ ${project.artifactId}
+ jar
+
+
\ No newline at end of file
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/TBuilding.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/TBuilding.java
new file mode 100644
index 0000000..ac34d74
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/TBuilding.java
@@ -0,0 +1,24 @@
+package org.springblade.damsafety.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import org.springblade.core.mp.base.BaseEntity;
+
+/**
+ * 建筑物信息表
+ */
+@Data
+@TableName("t_building")
+public class TBuilding extends BaseEntity {
+ @ApiModelProperty("水库编号")
+ private String rscd;
+ @ApiModelProperty("建筑物名称")
+ private String name;
+ @ApiModelProperty("建筑物分级路径")
+ private String ipath;
+ @ApiModelProperty("简介")
+ private String brief;
+ @ApiModelProperty("图片地址")
+ private String attach;
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/TProjInfo.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/TProjInfo.java
new file mode 100644
index 0000000..6e66a05
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/TProjInfo.java
@@ -0,0 +1,38 @@
+package org.springblade.damsafety.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 java.util.Date;
+
+/**
+ * 工程物信息表
+ */
+@Data
+@TableName("t_projinfo")
+@EqualsAndHashCode(callSuper = true)
+public class TProjInfo extends BaseEntity {
+ @ApiModelProperty("水库编码")
+ private String rscd;
+ @ApiModelProperty("工程名称")
+ private String projName;
+ @ApiModelProperty("工程编号")
+ private String projCode;
+ @ApiModelProperty("开工日期")
+ @JsonFormat(pattern = "yyyy-MM-dd")
+ private Date startDate;
+ @ApiModelProperty("竣工日期")
+ @JsonFormat(pattern = "yyyy-MM-dd")
+ private Date completeDate;
+ @ApiModelProperty("蓄水日期")
+ @JsonFormat(pattern = "yyyy-MM-dd")
+ private Date storeWaterDate;
+ @ApiModelProperty("工程所在位置")
+ private String location;
+ @ApiModelProperty("备注")
+ private String rm;
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/TSectionConfig.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/TSectionConfig.java
new file mode 100644
index 0000000..8df2e9f
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/TSectionConfig.java
@@ -0,0 +1,34 @@
+package org.springblade.damsafety.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+/**
+ * 大坝断面数据配置表
+ */
+@Data
+@TableName("t_section_config")
+public class TSectionConfig implements Serializable {
+ @ApiModelProperty("渗流量测点编号")
+ @TableId(type = IdType.INPUT)
+ private String stcd;
+ @ApiModelProperty("断面编号")
+ private String sectionNo;
+ @ApiModelProperty("是否显示浸润线")
+ private String opinion;
+ @ApiModelProperty("x轴")
+ private BigDecimal xzhou;
+ @ApiModelProperty("y轴最大值")
+ private BigDecimal ymax;
+ @ApiModelProperty("y轴最小值")
+ private BigDecimal ymin;
+ @ApiModelProperty("警戒值")
+ private BigDecimal warm;
+
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpDamsB.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpDamsB.java
new file mode 100644
index 0000000..7e6f43a
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpDamsB.java
@@ -0,0 +1,32 @@
+package org.springblade.damsafety.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * 断面特征点信息表
+ */
+@Data
+@TableName("wrp_dams_b")
+public class WrpDamsB implements Serializable {
+ @ApiModelProperty("断面编号")
+ private String damcd;
+ @ApiModelProperty("特征点编号")
+ @TableId(type= IdType.INPUT)
+ private String damscd;
+ @ApiModelProperty("特征点名称")
+ private String damsnm;
+ @ApiModelProperty("起点距(m)")
+ private BigDecimal redi;
+ @ApiModelProperty("高程(m)")
+ private BigDecimal poel;
+ @ApiModelProperty("更新时间")
+ private Date dtuptm;
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpDfrSrhrdsmp.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpDfrSrhrdsmp.java
new file mode 100644
index 0000000..80b892e
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpDfrSrhrdsmp.java
@@ -0,0 +1,56 @@
+package org.springblade.damsafety.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 java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ *水平位移监测测点
+ */
+@Data
+@TableName("wrp_dfr_srhrdsmp")
+@EqualsAndHashCode(callSuper = true)
+public class WrpDfrSrhrdsmp extends BaseEntity {
+ @ApiModelProperty("测站编码")
+ private String stcd;
+ @ApiModelProperty("断面编号")
+ private String damcd;
+ @ApiModelProperty("测点编号")
+ private String mpcd;
+ @ApiModelProperty("桩号")
+ private String ch;
+ @ApiModelProperty("轴距")
+ private BigDecimal ofax;
+ @ApiModelProperty("高程")
+ private BigDecimal el;
+ @ApiModelProperty("基准值 X")
+ private BigDecimal stvlx;
+ @ApiModelProperty("基准值 Y")
+ private BigDecimal stvly;
+ @ApiModelProperty("位移阈值")
+ private BigDecimal xyhrds;
+ @ApiModelProperty("型式")
+ private String tp;
+ @ApiModelProperty("基础情况")
+ private String bsin;
+ @ApiModelProperty("安装日期")
+ @JsonFormat(pattern = "yyyy-MM-dd")
+ private Date indt;
+ @ApiModelProperty("测定日期")
+ @JsonFormat(pattern = "yyyy-MM-dd")
+ private Date dtdt;
+ @ApiModelProperty("仪器编号")
+ private String dvcd;
+ @ApiModelProperty("经度")
+ private BigDecimal eslg;
+ @ApiModelProperty("纬度")
+ private BigDecimal nrlt;
+ @ApiModelProperty("备注")
+ private String rm;
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpDfrSrvrdsbp.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpDfrSrvrdsbp.java
new file mode 100644
index 0000000..786ca2d
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpDfrSrvrdsbp.java
@@ -0,0 +1,55 @@
+package org.springblade.damsafety.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 java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * 监测基点表
+ */
+@Data
+@TableName("wrp_dfr_srvrdsbp")
+@EqualsAndHashCode(callSuper = true)
+public class WrpDfrSrvrdsbp extends BaseEntity {
+ @ApiModelProperty("水库代码")
+ private String rscd;
+ @ApiModelProperty("水工建筑物id")
+ private Long hycncd;
+ @ApiModelProperty("基点编号")
+ private String bpcd;
+ @ApiModelProperty("考证信息日期")
+ @JsonFormat(pattern = "yyyy-MM-dd")
+ private Date txindt;
+ @ApiModelProperty("基点类型")
+ private String bptp;
+ @ApiModelProperty("桩号")
+ private String ch;
+ @ApiModelProperty("轴距")
+ private BigDecimal ofax;
+ @ApiModelProperty("高程")
+ private BigDecimal el;
+ @ApiModelProperty("型式")
+ private String tp;
+ @ApiModelProperty("基础情况")
+ private String bsin;
+ @ApiModelProperty("安装日期")
+ @JsonFormat(pattern = "yyyy-MM-dd")
+ private Date indt;
+ @ApiModelProperty("测定日期")
+ @JsonFormat(pattern = "yyyy-MM-dd")
+ private Date dtdt;
+ @ApiModelProperty("经度")
+ private BigDecimal lgtd;
+ @ApiModelProperty("纬度")
+ private BigDecimal lttd;
+ @ApiModelProperty("工作状态")
+ private String wkcn;
+ @ApiModelProperty("备注")
+ private String rm;
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpDfrSrvrdsmp.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpDfrSrvrdsmp.java
new file mode 100644
index 0000000..fb47eeb
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpDfrSrvrdsmp.java
@@ -0,0 +1,53 @@
+package org.springblade.damsafety.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 java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * 垂直位移监测测点
+ */
+@Data
+@TableName("wrp_dfr_srvrdsmp")
+@EqualsAndHashCode(callSuper = true)
+public class WrpDfrSrvrdsmp extends BaseEntity {
+ @ApiModelProperty("测站编码")
+ private String stcd;
+ @ApiModelProperty("断面编号")
+ private String damcd;
+ @ApiModelProperty("测点编号")
+ private String mpcd;
+ @ApiModelProperty("桩号")
+ private String ch;
+ @ApiModelProperty("轴距")
+ private BigDecimal ofax;
+ @ApiModelProperty("初始高程")
+ private BigDecimal inel;
+ @ApiModelProperty("位移阈值")
+ private BigDecimal vrds;
+ @ApiModelProperty("型式")
+ private String tp;
+ @ApiModelProperty("基础情况")
+ private String bsin;
+ @ApiModelProperty("安装日期")
+ @JsonFormat(pattern = "yyyy-MM-dd")
+ private Date indt;
+ @ApiModelProperty("测定日期")
+ @JsonFormat(pattern = "yyyy-MM-dd")
+ private Date dtdt;
+ @ApiModelProperty("仪器编号")
+ private String dvcd;
+ @ApiModelProperty("经度")
+ private BigDecimal eslg;
+ @ApiModelProperty("纬度")
+ private BigDecimal nrlt;
+ @ApiModelProperty("备注")
+ private String rm;
+
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpSectionB.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpSectionB.java
new file mode 100644
index 0000000..4159e39
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpSectionB.java
@@ -0,0 +1,38 @@
+package org.springblade.damsafety.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springblade.core.mp.base.BaseEntity;
+
+import java.math.BigDecimal;
+
+/**
+ * 大坝断面信息表
+ */
+@Data
+@TableName("wrp_section_b")
+@EqualsAndHashCode(callSuper = true)
+public class WrpSectionB extends BaseEntity {
+ @ApiModelProperty("水库编号")
+ private String rscd;
+ @ApiModelProperty("建筑物id")
+ private Long buildingId;
+ @ApiModelProperty("断面编码")
+ private String damcd;
+ @ApiModelProperty("断面名称")
+ private String damnm;
+ @ApiModelProperty("防渗墙类型")
+ private String wallType;
+ @ApiModelProperty("断面长度")
+ private BigDecimal damlen;
+ @ApiModelProperty("断面宽度")
+ private BigDecimal damwd;
+ @ApiModelProperty("备注")
+ private String rm;
+ @ApiModelProperty("预留字段")
+ private String text;
+ @ApiModelProperty("图片地址")
+ private String attach;
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpSpgPztb.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpSpgPztb.java
new file mode 100644
index 0000000..7e3884c
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpSpgPztb.java
@@ -0,0 +1,58 @@
+package org.springblade.damsafety.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springblade.core.mp.base.BaseEntity;
+
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * 测压管测点
+ */
+@Data
+@TableName("wrp_spg_pztb")
+@EqualsAndHashCode(callSuper = true)
+public class WrpSpgPztb extends BaseEntity {
+ @ApiModelProperty("测站编码")
+ private String stcd;
+ @ApiModelProperty("测点编号")
+ private String mpcd;
+ @ApiModelProperty("断面编号")
+ private String damcd;
+ @ApiModelProperty("桩号")
+ private String ch;
+ @ApiModelProperty("坝轴距")
+ private BigDecimal ofax;
+ @ApiModelProperty("监测部位")
+ private String msps;
+
+ @ApiModelProperty("监测类型")
+ private String mstp;
+ @ApiModelProperty("安装高程")
+ private BigDecimal el;
+ @ApiModelProperty("进水段底高程")
+ private BigDecimal ipbtel;
+ @ApiModelProperty("进水段顶高程")
+ private BigDecimal iptpel;
+ @ApiModelProperty("管口高程")
+ private BigDecimal tbtpel;
+ @ApiModelProperty("管底高程")
+ private BigDecimal tbbtel;
+ @ApiModelProperty("水位阈值高程")
+ private BigDecimal pztbtel;
+
+ @ApiModelProperty("仪器编号")
+ private String dvcd;
+ @ApiModelProperty("经度")
+ private BigDecimal eslg;
+ @ApiModelProperty("纬度")
+ private BigDecimal nrlt;
+ @ApiModelProperty("备注")
+ private String rm;
+
+
+
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpSpgSpprmp.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpSpgSpprmp.java
new file mode 100644
index 0000000..019f351
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpSpgSpprmp.java
@@ -0,0 +1,52 @@
+package org.springblade.damsafety.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 java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * 渗流压力测点信息表
+ */
+@Data
+@TableName("wrp_spg_spprmp")
+@EqualsAndHashCode(callSuper = true)
+public class WrpSpgSpprmp extends BaseEntity {
+ @ApiModelProperty("测站编码")
+ private String stcd;
+ @ApiModelProperty("断面编码")
+ private String damcd;
+ @ApiModelProperty("测点编号")
+ private String mpcd;
+ @ApiModelProperty("考证信息日期")
+ @JsonFormat(pattern = "yyyy-MM-dd")
+ private Date txindt;
+ @ApiModelProperty("桩号")
+ private String ch;
+ @ApiModelProperty("轴距")
+ private BigDecimal ofax;
+ @ApiModelProperty("高程")
+ private BigDecimal el;
+ @ApiModelProperty("监测类型")
+ private String mstp;
+ @ApiModelProperty("透水段底高程")
+ private BigDecimal pmbtel;
+ @ApiModelProperty("透水段顶高程")
+ private BigDecimal pmtpel;
+ @ApiModelProperty("安装日期")
+ @JsonFormat(pattern = "yyyy-MM-dd")
+ private Date indt;
+ @ApiModelProperty("仪器出厂编号")
+ private String dvfccd;
+ @ApiModelProperty("工作状态")
+ private String wkcn;
+ @ApiModelProperty("备注")
+ private String rm;
+
+
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpSpgSpqnmp.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpSpgSpqnmp.java
new file mode 100644
index 0000000..4f26d7b
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/entity/WrpSpgSpqnmp.java
@@ -0,0 +1,45 @@
+package org.springblade.damsafety.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 java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * 渗流量测点
+ */
+@Data
+@TableName("wrp_spg_spqnmp")
+@EqualsAndHashCode(callSuper = true)
+public class WrpSpgSpqnmp extends BaseEntity {
+ @ApiModelProperty("测站编码")
+ private String stcd;
+ @ApiModelProperty("测点编号")
+ private String mpcd;
+ @ApiModelProperty("断面编号")
+ private String damcd;
+ @ApiModelProperty("桩号")
+ private String ch;
+ @ApiModelProperty("轴距")
+ private BigDecimal ofax;
+ @ApiModelProperty("高程")
+ private BigDecimal el;
+ @ApiModelProperty("渗流阈值")
+ private BigDecimal spprwl;
+ @ApiModelProperty("安装日期")
+ @JsonFormat(pattern = "yyyy-MM-dd")
+ private Date indt;
+ @ApiModelProperty("仪器编号")
+ private String dvcd;
+ @ApiModelProperty("经度")
+ private BigDecimal eslg;
+ @ApiModelProperty("纬度")
+ private BigDecimal nrlt;
+ @ApiModelProperty("备注")
+ private String rm;
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/feign/IWrpSectionBClient.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/feign/IWrpSectionBClient.java
new file mode 100644
index 0000000..c12f15b
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/feign/IWrpSectionBClient.java
@@ -0,0 +1,26 @@
+package org.springblade.damsafety.feign;
+
+import org.springblade.core.tool.api.R;
+import org.springblade.damsafety.vo.WrpSectionBVO;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.GetMapping;
+
+import java.util.List;
+import java.util.Map;
+
+@FeignClient(
+ value = "dam-safety",
+ url = "${feign.dam-safety:}"
+)
+public interface IWrpSectionBClient {
+ String API_PREFIX = "/wrpSectionBClient";
+ String LIST = API_PREFIX + "/list";
+
+ /**
+ * 获取断面列表
+ *
+ * @return
+ */
+ @GetMapping(LIST)
+ R> list(Map param);
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/TBuildingVo.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/TBuildingVo.java
new file mode 100644
index 0000000..d786042
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/TBuildingVo.java
@@ -0,0 +1,8 @@
+package org.springblade.damsafety.vo;
+
+import lombok.Data;
+import org.springblade.damsafety.entity.TBuilding;
+
+public class TBuildingVo extends TBuilding {
+
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/TProjInfoVo.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/TProjInfoVo.java
new file mode 100644
index 0000000..edc283b
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/TProjInfoVo.java
@@ -0,0 +1,7 @@
+package org.springblade.damsafety.vo;
+
+import org.springblade.damsafety.entity.TProjInfo;
+
+public class TProjInfoVo extends TProjInfo {
+
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/WrpDfrSrhrdsmpVo.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/WrpDfrSrhrdsmpVo.java
new file mode 100644
index 0000000..6fd1d6c
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/WrpDfrSrhrdsmpVo.java
@@ -0,0 +1,7 @@
+package org.springblade.damsafety.vo;
+
+import org.springblade.damsafety.entity.WrpDfrSrhrdsmp;
+
+public class WrpDfrSrhrdsmpVo extends WrpDfrSrhrdsmp {
+
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/WrpDfrSrvrdsbpVo.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/WrpDfrSrvrdsbpVo.java
new file mode 100644
index 0000000..ed41462
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/WrpDfrSrvrdsbpVo.java
@@ -0,0 +1,6 @@
+package org.springblade.damsafety.vo;
+
+import org.springblade.damsafety.entity.WrpDfrSrvrdsbp;
+
+public class WrpDfrSrvrdsbpVo extends WrpDfrSrvrdsbp {
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/WrpDfrSrvrdsmpVo.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/WrpDfrSrvrdsmpVo.java
new file mode 100644
index 0000000..e50f2f9
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/WrpDfrSrvrdsmpVo.java
@@ -0,0 +1,6 @@
+package org.springblade.damsafety.vo;
+
+import org.springblade.damsafety.entity.WrpDfrSrvrdsmp;
+
+public class WrpDfrSrvrdsmpVo extends WrpDfrSrvrdsmp {
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/WrpSectionBVO.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/WrpSectionBVO.java
new file mode 100644
index 0000000..544cc6f
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/WrpSectionBVO.java
@@ -0,0 +1,15 @@
+package org.springblade.damsafety.vo;
+
+import org.springblade.damsafety.entity.WrpDfrSrvrdsbp;
+import org.springblade.damsafety.entity.WrpSectionB;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.util.List;
+
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class WrpSectionBVO extends WrpSectionB {
+ //测点集合
+ private List points;
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/WrpSpgPztbVo.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/WrpSpgPztbVo.java
new file mode 100644
index 0000000..41501b5
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/WrpSpgPztbVo.java
@@ -0,0 +1,6 @@
+package org.springblade.damsafety.vo;
+
+import org.springblade.damsafety.entity.WrpSpgPztb;
+
+public class WrpSpgPztbVo extends WrpSpgPztb {
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/WrpSpgSpprmpVo.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/WrpSpgSpprmpVo.java
new file mode 100644
index 0000000..a9b4a85
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/WrpSpgSpprmpVo.java
@@ -0,0 +1,6 @@
+package org.springblade.damsafety.vo;
+
+import org.springblade.damsafety.entity.WrpSpgSpprmp;
+
+public class WrpSpgSpprmpVo extends WrpSpgSpprmp {
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/WrpSpgSpqnmpVo.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/WrpSpgSpqnmpVo.java
new file mode 100644
index 0000000..07e7aa8
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/dam-safety-monitor-service-api/src/main/java/org/springblade/damsafety/vo/WrpSpgSpqnmpVo.java
@@ -0,0 +1,6 @@
+package org.springblade.damsafety.vo;
+
+import org.springblade.damsafety.entity.WrpSpgSpqnmp;
+
+public class WrpSpgSpqnmpVo extends WrpSpgSpqnmp {
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/engineering-management-service-api/pom.xml b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/engineering-management-service-api/pom.xml
new file mode 100644
index 0000000..e40490c
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/engineering-management-service-api/pom.xml
@@ -0,0 +1,17 @@
+
+
+
+ hzinfo-ris-pxhd-service-api
+ org.springblade
+ 4.5.0.RELEASE
+
+ 4.0.0
+
+ pxhd-engineering-management-api
+ ${project.artifactId}
+ jar
+
+
+
\ No newline at end of file
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/engineering-management-service-api/src/main/java/org/springblade/engineer_management/util/DownLoadUtil.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/engineering-management-service-api/src/main/java/org/springblade/engineer_management/util/DownLoadUtil.java
new file mode 100644
index 0000000..9f0ac95
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/engineering-management-service-api/src/main/java/org/springblade/engineer_management/util/DownLoadUtil.java
@@ -0,0 +1,33 @@
+package org.springblade.engineer_management.util;
+
+import org.apache.commons.io.FileUtils;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
+
+import java.io.File;
+import java.io.IOException;
+import java.net.URLEncoder;
+
+public class DownLoadUtil {
+ public DownLoadUtil() {
+ }
+
+ public static ResponseEntity downLoad(File downFile) throws IOException {
+ if (!downFile.exists()) {
+// throw new HZException("500", "该文件不存在,请查证");
+ return null;
+ } else {
+ byte[] data = FileUtils.readFileToByteArray(downFile);
+ return downLoad(data, downFile.getName());
+ }
+ }
+
+ public static ResponseEntity downLoad(byte[] data, String downName) throws IOException {
+ HttpHeaders headers = new HttpHeaders();
+ headers.setContentDispositionFormData("attachment", URLEncoder.encode(downName, "UTF-8"));
+ headers.setContentType(MediaType.APPLICATION_OCTET_STREAM);
+ return new ResponseEntity(data, headers, HttpStatus.OK);
+ }
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/general-dispatching-service-api/pom.xml b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/general-dispatching-service-api/pom.xml
new file mode 100644
index 0000000..87b6407
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/general-dispatching-service-api/pom.xml
@@ -0,0 +1,16 @@
+
+
+
+ hzinfo-ris-pxhd-service-api
+ org.springblade
+ 4.5.0.RELEASE
+
+ 4.0.0
+
+ pxhd-general-dispatching-api
+ ${project.artifactId}
+ jar
+
+
\ No newline at end of file
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/pom.xml b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/pom.xml
new file mode 100644
index 0000000..66e3b54
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/pom.xml
@@ -0,0 +1,16 @@
+
+
+
+ hzinfo-ris-pxhd-service-api
+ org.springblade
+ 4.5.0.RELEASE
+
+ 4.0.0
+
+ pxhd-hz3000-real-data-api
+ ${project.artifactId}
+ jar
+
+
\ No newline at end of file
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/entity/DataGridModel.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/entity/DataGridModel.java
new file mode 100644
index 0000000..a252fc3
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/entity/DataGridModel.java
@@ -0,0 +1,39 @@
+package org.springblade.hz3000_real_data.entity;
+
+
+import java.io.Serializable;
+import java.util.List;
+
+public class DataGridModel implements Serializable {
+ private static final long serialVersionUID = 8591890308861767849L;
+ private long total = 0L;
+ private List rows;
+ private List footer;
+
+ public DataGridModel() {
+ }
+
+ public List getFooter() {
+ return this.footer;
+ }
+
+ public void setFooter(List footer) {
+ this.footer = footer;
+ }
+
+ public long getTotal() {
+ return this.total;
+ }
+
+ public void setTotal(long total) {
+ this.total = total;
+ }
+
+ public List getRows() {
+ return this.rows;
+ }
+
+ public void setRows(List rows) {
+ this.rows = rows;
+ }
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/entity/ListPageUtil.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/entity/ListPageUtil.java
new file mode 100644
index 0000000..b46b4b0
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/entity/ListPageUtil.java
@@ -0,0 +1,28 @@
+package org.springblade.hz3000_real_data.entity;
+
+import java.util.Collections;
+import java.util.List;
+
+public class ListPageUtil {
+ public ListPageUtil() {
+ }
+
+ public List getPagedList(int pageNum, int pageSize, List data) {
+ if (pageNum > 0 && pageSize > 0) {
+ int fromIndex = (pageNum - 1) * pageSize;
+ if (fromIndex >= data.size()) {
+ return Collections.emptyList();
+ } else {
+ int toIndex = pageNum * pageSize;
+ if (toIndex >= data.size()) {
+ toIndex = data.size();
+ }
+
+ return data.subList(fromIndex, toIndex);
+ }
+ } else {
+ return data;
+ }
+ }
+
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/entity/SystemPath.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/entity/SystemPath.java
new file mode 100644
index 0000000..1211855
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/entity/SystemPath.java
@@ -0,0 +1,47 @@
+package org.springblade.hz3000_real_data.entity;
+
+public class SystemPath {
+ private static String SYSTEM_NAME = System.getProperty("os.name").toLowerCase();
+
+ public SystemPath() {
+ }
+
+ public static String getSysPath() {
+ String path = Thread.currentThread().getContextClassLoader().getResource("").toString();
+ String temp = path.replaceFirst("file:/", "").replaceFirst("WEB-INF/classes/", "");
+ String separator = System.getProperty("file.separator");
+ String resultPath = temp.replaceAll("/", separator + separator);
+ return resultPath;
+ }
+
+ public static String getClassPath() {
+ String path = Thread.currentThread().getContextClassLoader().getResource("").toString();
+ String temp = path.replaceFirst("file:/", "");
+ String separator = System.getProperty("file.separator");
+ String resultPath = temp.replaceAll("/", separator + separator);
+ return resultPath;
+ }
+
+ public static String getSystempPath() {
+ return System.getProperty("java.io.tmpdir");
+ }
+
+ public static String getSeparator() {
+ return System.getProperty("file.separator");
+ }
+
+ public static boolean isWindows() {
+ return SYSTEM_NAME.indexOf("win") >= 0;
+ }
+
+ public static boolean isLinux() {
+ return SYSTEM_NAME.indexOf("linux") >= 0;
+ }
+
+// public static void main(String[] args) {
+// System.out.println(getSysPath());
+// System.out.println(System.getProperty("java.io.tmpdir"));
+// System.out.println(getSeparator());
+// System.out.println(getClassPath());
+// }
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/BasePoint.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/BasePoint.java
new file mode 100644
index 0000000..7631cbd
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/BasePoint.java
@@ -0,0 +1,112 @@
+package org.springblade.hz3000_real_data.fac.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+
+/**
+ * 数据点基础类
+ *
+ * @author ypj
+ */
+@ApiModel("原始点")
+public class BasePoint extends Point {
+ private static final long serialVersionUID = 6878843178471415799L;
+ @ApiModelProperty(value = "组id")
+ private String groupId;
+ @ApiModelProperty(value = "组名称")
+ private String groupName;
+ @ApiModelProperty(value = "站点id")
+ private String factoryId;
+ @ApiModelProperty(value = "站点名称")
+ private String factoryName;
+ @ApiModelProperty(value = "通道号")
+ private String channelIndex;
+ @ApiModelProperty(value = "模块号")
+ private String moduleIndex;
+ @ApiModelProperty(value = "地址号")
+ private String addressIndex;
+ @ApiModelProperty(value = "数据类型")
+ private Integer dataType;
+ @ApiModelProperty(value = "站点id")
+ private String stationId;
+
+ public String getGroupId() {
+ return groupId;
+ }
+
+ public void setGroupId(String groupId) {
+ this.groupId = groupId;
+ }
+
+ public String getGroupName() {
+ return groupName;
+ }
+
+ public void setGroupName(String groupName) {
+ this.groupName = groupName;
+ }
+
+ public String getFactoryId() {
+ return factoryId;
+ }
+
+ public void setFactoryId(String factoryId) {
+ this.factoryId = factoryId;
+ }
+
+ public String getFactoryName() {
+ return factoryName;
+ }
+
+ public void setFactoryName(String factoryName) {
+ this.factoryName = factoryName;
+ }
+
+ public String getChannelIndex() {
+ return channelIndex;
+ }
+
+ public void setChannelIndex(String channelIndex) {
+ this.channelIndex = channelIndex;
+ }
+
+ public String getModuleIndex() {
+ return moduleIndex;
+ }
+
+ public void setModuleIndex(String moduleIndex) {
+ this.moduleIndex = moduleIndex;
+ }
+
+ public String getAddressIndex() {
+ return addressIndex;
+ }
+
+ public void setAddressIndex(String addressIndex) {
+ this.addressIndex = addressIndex;
+ }
+
+ public Integer getDataType() {
+ return dataType;
+ }
+
+ public void setDataType(Integer dataType) {
+ this.dataType = dataType;
+ }
+
+ public String getStationId() {
+ return stationId;
+ }
+
+ public void setStationId(String stationId) {
+ this.stationId = stationId;
+ }
+
+ public void setBaseInfo(String stationId, String factoryId, String factoryName, String groupId, String groupName) {
+ this.stationId = stationId;
+ this.factoryId = factoryId;
+ this.factoryName = factoryName;
+ this.groupId = groupId;
+ this.groupName = groupName;
+ }
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/DataGroup.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/DataGroup.java
new file mode 100644
index 0000000..20f4cb0
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/DataGroup.java
@@ -0,0 +1,192 @@
+package org.springblade.hz3000_real_data.fac.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+
+import java.util.List;
+
+@ApiModel
+public class DataGroup extends Point {
+ private static final long serialVersionUID = -5427155903332937386L;
+ @ApiModelProperty(value = "厂id")
+ private String factoryId;
+ @ApiModelProperty(value = "厂名称")
+ private String factoryName;
+ @ApiModelProperty(value = "是否加锁")
+ private Boolean unlock;
+ @ApiModelProperty(value = "遥测列表")
+ private List telemetryPointList;
+ @ApiModelProperty(value = "遥控列表")
+ private List telecontrolPointList;
+ @ApiModelProperty(value = "遥信列表")
+ private List telesignalPointList;
+ @ApiModelProperty(value = "事件列表")
+ private List eventPointList;
+ @ApiModelProperty(value = "字符串列表")
+ private List strPointList;
+ @ApiModelProperty(value = "告警总数")
+ private Integer soeSize = 0;
+ @ApiModelProperty(value = "遥测总数")
+ private Integer ycSize = 0;
+ @ApiModelProperty(value = "遥控总数")
+ private Integer ykSize = 0;
+ @ApiModelProperty(value = "遥信总数")
+ private Integer yxSize = 0;
+ @ApiModelProperty(value = "字符串总数")
+ private Integer strSize = 0;
+
+ @ApiModelProperty(value = "事件组")
+ private GroupType soeGroup;
+ @ApiModelProperty(value = "遥测组")
+ private GroupType ycGroup;
+ @ApiModelProperty(value = "遥信组")
+ private GroupType yxGroup;
+ @ApiModelProperty(value = "遥控组")
+ private GroupType ykGroup;
+ @ApiModelProperty(value = "字符串组")
+ private GroupType strGroup;
+
+ public GroupType getSoeGroup() {
+ return soeGroup;
+ }
+
+ public void setSoeGroup(GroupType soeGroup) {
+ this.soeGroup = soeGroup;
+ }
+
+ public GroupType getYcGroup() {
+ return ycGroup;
+ }
+
+ public void setYcGroup(GroupType ycGroup) {
+ this.ycGroup = ycGroup;
+ }
+
+ public GroupType getYxGroup() {
+ return yxGroup;
+ }
+
+ public void setYxGroup(GroupType yxGroup) {
+ this.yxGroup = yxGroup;
+ }
+
+ public GroupType getYkGroup() {
+ return ykGroup;
+ }
+
+ public void setYkGroup(GroupType ykGroup) {
+ this.ykGroup = ykGroup;
+ }
+
+ public String getFactoryId() {
+ return factoryId;
+ }
+
+ public void setFactoryId(String factoryId) {
+ this.factoryId = factoryId;
+ }
+
+ public String getFactoryName() {
+ return factoryName;
+ }
+
+ public void setFactoryName(String factoryName) {
+ this.factoryName = factoryName;
+ }
+
+ public Boolean isUnlock() {
+ return unlock;
+ }
+
+ public void setUnlock(Boolean unlock) {
+ this.unlock = unlock;
+ }
+
+ public List getTelemetryPointList() {
+ return telemetryPointList;
+ }
+
+ public void setTelemetryPointList(List telemetryPointList) {
+ this.telemetryPointList = telemetryPointList;
+ }
+
+ public List getTelecontrolPointList() {
+ return telecontrolPointList;
+ }
+
+ public void setTelecontrolPointList(List telecontrolPointList) {
+ this.telecontrolPointList = telecontrolPointList;
+ }
+
+ public List getTelesignalPointList() {
+ return telesignalPointList;
+ }
+
+ public void setTelesignalPointList(List telesignalPointList) {
+ this.telesignalPointList = telesignalPointList;
+ }
+
+ public List getEventPointList() {
+ return eventPointList;
+ }
+
+ public void setEventPointList(List eventPointList) {
+ this.eventPointList = eventPointList;
+ }
+
+ public List getStrPointList() {
+ return strPointList;
+ }
+
+ public void setStrPointList(List strPointList) {
+ this.strPointList = strPointList;
+ }
+
+ public int getSoeSize() {
+ return soeSize;
+ }
+
+ public void setSoeSize(Integer soeSize) {
+ this.soeSize = soeSize;
+ }
+
+ public int getYcSize() {
+ return ycSize;
+ }
+
+ public void setYcSize(Integer ycSize) {
+ this.ycSize = ycSize;
+ }
+
+ public int getYkSize() {
+ return ykSize;
+ }
+
+ public void setYkSize(Integer ykSize) {
+ this.ykSize = ykSize;
+ }
+
+ public int getYxSize() {
+ return yxSize;
+ }
+
+ public void setYxSize(Integer yxSize) {
+ this.yxSize = yxSize;
+ }
+
+ public GroupType getStrGroup() {
+ return strGroup;
+ }
+
+ public void setStrGroup(GroupType strGroup) {
+ this.strGroup = strGroup;
+ }
+
+ public Integer getStrSize() {
+ return strSize;
+ }
+
+ public void setStrSize(Integer strSize) {
+ this.strSize = strSize;
+ }
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/Factory.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/Factory.java
new file mode 100644
index 0000000..fec3cfd
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/Factory.java
@@ -0,0 +1,71 @@
+package org.springblade.hz3000_real_data.fac.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import org.springblade.hz3000_real_data.fac.utils.LanguageUtils;
+
+import java.util.List;
+
+@ApiModel("厂信息")
+public class Factory extends Point {
+ private static final long serialVersionUID = -4443313438904921892L;
+ @ApiModelProperty(value = "站点编号")
+ private String stationNum;
+ @ApiModelProperty(value = "组编号")
+ private String theGroupNum;
+ @ApiModelProperty(value = "组集合")
+ private List groups;
+ @ApiModelProperty(value = "组id")
+ private String theGroupId;
+ @ApiModelProperty(value = "组总数")
+ private Integer groupSize = 0;
+
+ public String getStationNum() {
+ return stationNum;
+ }
+
+ public void setStationNum(String stationNum) {
+ this.stationNum = stationNum;
+ }
+
+ public String getTheGroupNum() {
+ return theGroupNum;
+ }
+
+ public void setTheGroupNum(String theGroupNum) {
+ this.theGroupNum = theGroupNum;
+ }
+
+ public List getGroups() {
+ return groups;
+ }
+
+ public void setGroups(List groups) {
+ this.groups = groups;
+ }
+
+ public String getTheGroupId() {
+ return theGroupId;
+ }
+
+ public void setTheGroupId(String theGroupId) {
+ this.theGroupId = theGroupId;
+ }
+
+ public void toEnglishName() {
+ LanguageUtils.toEnglishName(this);
+ }
+
+ public void toChineseName() {
+ LanguageUtils.toChinessName(this);
+ }
+
+ public int getGroupSize() {
+ return groupSize;
+ }
+
+ public void setGroupSize(Integer groupSize) {
+ this.groupSize = groupSize;
+ }
+
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/GroupType.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/GroupType.java
new file mode 100644
index 0000000..aec8304
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/GroupType.java
@@ -0,0 +1,32 @@
+package org.springblade.hz3000_real_data.fac.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+
+import java.util.List;
+
+@ApiModel("组类型")
+public class GroupType extends BasePoint {
+ private static final long serialVersionUID = -5013035391910210737L;
+
+ @ApiModelProperty(value = "点列表")
+ List extends BasePoint> pointList;
+
+ Integer childrenCount = 0;
+
+ public Integer getChildrenCount() {
+ return childrenCount;
+ }
+
+ public void setChildrenCount(Integer childrenCount) {
+ this.childrenCount = childrenCount;
+ }
+
+ public List extends BasePoint> getPointList() {
+ return pointList;
+ }
+
+ public void setPointList(List extends BasePoint> pointList) {
+ this.pointList = pointList;
+ }
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/LanguageInterface.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/LanguageInterface.java
new file mode 100644
index 0000000..e13b26d
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/LanguageInterface.java
@@ -0,0 +1,15 @@
+package org.springblade.hz3000_real_data.fac.entity;
+
+public interface LanguageInterface {
+ String getName();
+
+ void setName(String name);
+
+ String getEng();
+
+ void setEng(String eng);
+
+ String getChn();
+
+ void setChn(String chn);
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/Point.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/Point.java
new file mode 100644
index 0000000..2e5fddc
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/Point.java
@@ -0,0 +1,81 @@
+package org.springblade.hz3000_real_data.fac.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+
+import java.io.Serializable;
+
+@ApiModel("点信息")
+public class Point implements Serializable ,LanguageInterface{
+ private static final long serialVersionUID = 4657709877092481867L;
+ /**
+ * id
+ */
+ @ApiModelProperty(value = "id")
+ private String id;
+ /**
+ * 名称
+ */
+ @ApiModelProperty(value = "名称")
+ private String name;
+ /**
+ * 中文
+ */
+ @ApiModelProperty(value = "中文")
+ private String chn;
+ /**
+ * 英文
+ */
+ @ApiModelProperty(value = "英文")
+ private String eng;
+ /**
+ * 节点类型
+ */
+ @ApiModelProperty(value = "节点类型")
+ private Integer pointType = 0;
+
+ public Integer getPointType() {
+ return pointType;
+ }
+
+ public void setPointType(Integer pointType) {
+ this.pointType = pointType;
+ }
+ public String getId() {
+ return id;
+ }
+
+ public void setId(String id) {
+ this.id = id;
+ }
+
+ @Override
+ public String getName() {
+ return name;
+ }
+
+ @Override
+ public void setName(String name) {
+ this.name = name;
+ }
+
+ @Override
+ public String getChn() {
+ return chn;
+ }
+
+ @Override
+ public void setChn(String chn) {
+ this.chn = chn;
+ }
+
+ @Override
+ public String getEng() {
+ return eng;
+ }
+
+ @Override
+ public void setEng(String eng) {
+ this.eng = eng;
+ }
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/SoePoint.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/SoePoint.java
new file mode 100644
index 0000000..8c0b965
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/SoePoint.java
@@ -0,0 +1,95 @@
+package org.springblade.hz3000_real_data.fac.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+
+import java.util.List;
+
+
+@ApiModel("点信息")
+public class SoePoint extends BasePoint {
+
+ private static final long serialVersionUID = 4592781482217840848L;
+
+ @ApiModelProperty(value = "类型")
+ private String type;
+ @ApiModelProperty(value = "告警类型")
+ private String alarmType;
+ @ApiModelProperty(value = "告警声音")
+ private String alarmSound;
+ @ApiModelProperty(value = "动作列表")
+ private String actionNameList;
+ @ApiModelProperty(value = "动作单位列表")
+ private String actionUnitList;
+ @ApiModelProperty(value = "组id")
+ private String groupId;
+ @ApiModelProperty(value = "动作名称数组")
+ private List actionNameListArray;
+ @ApiModelProperty(value = "动作单位数组")
+ private List actionUnitListArray;
+
+ public String getType() {
+ return type;
+ }
+
+ public void setType(String type) {
+ this.type = type;
+ }
+
+ public String getAlarmType() {
+ return alarmType;
+ }
+
+ public void setAlarmType(String alarmType) {
+ this.alarmType = alarmType;
+ }
+
+ public String getAlarmSound() {
+ return alarmSound;
+ }
+
+ public void setAlarmSound(String alarmSound) {
+ this.alarmSound = alarmSound;
+ }
+
+ public String getActionNameList() {
+ return actionNameList;
+ }
+
+ public void setActionNameList(String actionNameList) {
+ this.actionNameList = actionNameList;
+ }
+
+ public String getActionUnitList() {
+ return actionUnitList;
+ }
+
+ public void setActionUnitList(String actionUnitList) {
+ this.actionUnitList = actionUnitList;
+ }
+
+ public String getGroupId() {
+ return groupId;
+ }
+
+ public void setGroupId(String groupId) {
+ this.groupId = groupId;
+ }
+
+ public List getActionNameListArray() {
+ return actionNameListArray;
+ }
+
+ public void setActionNameListArray(List actionNameListArray) {
+ this.actionNameListArray = actionNameListArray;
+ }
+
+ public List getActionUnitListArray() {
+ return actionUnitListArray;
+ }
+
+ public void setActionUnitListArray(List actionUnitListArray) {
+ this.actionUnitListArray = actionUnitListArray;
+ }
+
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/YcPoint.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/YcPoint.java
new file mode 100644
index 0000000..34b242f
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/YcPoint.java
@@ -0,0 +1,10 @@
+package org.springblade.hz3000_real_data.fac.entity;
+
+import io.swagger.annotations.ApiModel;
+
+@ApiModel("遥测点信息")
+public class YcPoint extends BasePoint {
+
+ private static final long serialVersionUID = -4522390387219103139L;
+
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/YkPoint.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/YkPoint.java
new file mode 100644
index 0000000..faa0b64
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/YkPoint.java
@@ -0,0 +1,26 @@
+package org.springblade.hz3000_real_data.fac.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+
+/**
+ *
+ * @author ypj
+ *
+ */
+@ApiModel("遥控点信息")
+public class YkPoint extends BasePoint {
+
+ private static final long serialVersionUID = 7000254579441509126L;
+ @ApiModelProperty(value = "说明")
+ private String explain;
+
+ public String getExplain() {
+ return explain;
+ }
+
+ public void setExplain(String explain) {
+ this.explain = explain;
+ }
+
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/YxPoint.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/YxPoint.java
new file mode 100644
index 0000000..c461a99
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/entity/YxPoint.java
@@ -0,0 +1,26 @@
+package org.springblade.hz3000_real_data.fac.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+
+/**
+ *
+ * @author ypj
+ *
+ */
+@ApiModel("遥信点信息")
+public class YxPoint extends BasePoint {
+
+ private static final long serialVersionUID = -8093857719124678389L;
+ @ApiModelProperty(value = "告警类型")
+ private String alarmType;
+
+ public String getAlarmType() {
+ return alarmType;
+ }
+
+ public void setAlarmType(String alarmType) {
+ this.alarmType = alarmType;
+ }
+
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/enums/LanguageEnum.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/enums/LanguageEnum.java
new file mode 100644
index 0000000..4359169
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/enums/LanguageEnum.java
@@ -0,0 +1,20 @@
+package org.springblade.hz3000_real_data.fac.enums;
+
+public enum LanguageEnum {
+ Chinese("cn", "汉语"), English("en", "英语");
+ private final String code;
+ private final String desc;
+
+ LanguageEnum(String code, String desc) {
+ this.code = code;
+ this.desc = desc;
+ }
+
+ public String getCode() {
+ return code;
+ }
+
+ public String getDesc() {
+ return desc;
+ }
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/utils/LanguageUtils.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/utils/LanguageUtils.java
new file mode 100644
index 0000000..397a7aa
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/fac/utils/LanguageUtils.java
@@ -0,0 +1,101 @@
+package org.springblade.hz3000_real_data.fac.utils;
+
+import org.springblade.hz3000_real_data.fac.entity.*;
+import org.springblade.hz3000_real_data.fac.enums.LanguageEnum;
+
+import java.util.List;
+
+public class LanguageUtils {
+ public static final String CURRENT_LANGUAGE = "currentLanguage";
+
+ public static void toEnglishName(LanguageInterface entity) {
+ String eng = entity.getEng();
+ if (eng != null && eng.length() > 0) {
+ entity.setName(eng);
+ }
+ }
+
+ public static void toChinessName(LanguageInterface entity) {
+ String chn = entity.getChn();
+ if (chn != null && chn.length() > 0) {
+ entity.setName(chn);
+ }
+ }
+
+ public static void toEnglishName(List list) {
+ for (LanguageInterface entity : list) {
+ toEnglishName(entity);
+ }
+ }
+
+ public static void toChinessName(List list) {
+ for (LanguageInterface entity : list) {
+ toChinessName(entity);
+ }
+ }
+
+ public void changeNameByLanguage(LanguageInterface entity, String language) {
+ if (null != language) {
+ if (LanguageEnum.English.equals(language)) {
+ toEnglishName(entity);
+ } else {
+ toChinessName(entity);
+ }
+ }
+ }
+
+ public static void changeNameByLanguage(List list, String language) {
+ if (null != language) {
+ if (LanguageEnum.English.equals(language)) {
+ toEnglishName(list);
+ } else {
+ toChinessName(list);
+ }
+ }
+ }
+
+ public static void changeAllToEnglish(List factoryList) {
+ for (Factory factory : factoryList) {
+ toEnglishName(factory);
+ List groupList = factory.getGroups();
+ if (null != groupList) {
+ for (DataGroup group : groupList) {
+ toEnglishName(group);
+ List ycPointList = group.getTelemetryPointList();
+ if (null != ycPointList) {
+ for (YcPoint ycPoint : ycPointList) {
+ toEnglishName(ycPoint);
+ }
+ }
+ List yxPointList = group.getTelesignalPointList();
+ if(null != yxPointList){
+ for(YxPoint yxPoint: yxPointList ){
+ toEnglishName(yxPoint);
+ }
+ }
+ List ykPointList = group.getTelecontrolPointList();
+ if(null != ykPointList){
+ for (YkPoint ykPoint : ykPointList){
+ toEnglishName(ykPoint);
+ }
+ }
+ List soePointList = group.getEventPointList();
+ if(null != soePointList){
+ for(SoePoint soePoint : soePointList){
+ toEnglishName(soePoint);
+ }
+ }
+ }
+ }
+ }
+ }
+
+// public static void main(String[] arg) {
+// LanguageInterface entity = new YcPoint();
+// entity.setName("中文");
+// entity.setChn("粤语");
+// entity.setEng("English");
+// toEnglishName(entity);
+// System.out.println(entity.getName());
+// }
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/feign/IHz3000HistoryDataClient.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/feign/IHz3000HistoryDataClient.java
new file mode 100644
index 0000000..5bdc61f
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/feign/IHz3000HistoryDataClient.java
@@ -0,0 +1,24 @@
+package org.springblade.hz3000_real_data.feign;
+
+import org.springblade.hz3000_real_data.history.entity.HistoryRequestResult;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.GetMapping;
+
+import java.util.List;
+import java.util.Map;
+
+@FeignClient(
+ value = "hz3000-real-data",
+ url = "${feign.hz3000-real-data:}"
+)
+public interface IHz3000HistoryDataClient {
+ String API_PREFIX = "/hz3000HistoryDataClient";
+ String GET_HISTORY_DATA = API_PREFIX + "/queryHisDateOfTimeRange";
+
+ /**
+ * 获取测站详情
+ * @return
+ */
+ @GetMapping(GET_HISTORY_DATA)
+ Map> queryHisDateOfTimeRange(List realIds, String start, String end);
+}
\ No newline at end of file
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/feign/IHz3000RealDataClient.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/feign/IHz3000RealDataClient.java
new file mode 100644
index 0000000..61718ae
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/feign/IHz3000RealDataClient.java
@@ -0,0 +1,29 @@
+package org.springblade.hz3000_real_data.feign;
+
+import org.springblade.hz3000_real_data.real.entity.Data;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.GetMapping;
+
+import java.util.List;
+import java.util.Map;
+
+@FeignClient(
+ value = "hz3000-real-data",
+ url = "${feign.hz3000-real-data:}"
+)
+public interface IHz3000RealDataClient {
+ String API_PREFIX = "/hz3000RealDataClient";
+ String GET_REAL_DATA_BY_ID = API_PREFIX + "/getRealDataById";
+ String GET_REAL_DATA = API_PREFIX + "/getRealData";
+
+ /**
+ * 获取测站详情
+ * @return
+ */
+ @GetMapping(GET_REAL_DATA_BY_ID)
+ Map getRealDataById(String[] realIds, String stationId);
+
+ @GetMapping(GET_REAL_DATA)
+ List getRealData(List ids,int type,String stationId);
+
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/history/entity/HisDataYc.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/history/entity/HisDataYc.java
new file mode 100644
index 0000000..9ce9d22
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/history/entity/HisDataYc.java
@@ -0,0 +1,72 @@
+package org.springblade.hz3000_real_data.history.entity;
+
+import java.util.Date;
+
+public class HisDataYc {
+ private double val;
+ private Date datatime;
+ private int q;
+ private int _msec;
+
+ public double getVal() {
+ return val;
+ }
+
+ public void setVal(double val) {
+ this.val = val;
+ }
+
+ public Date getDatatime() {
+ return datatime;
+ }
+
+ public void setDatatime(Date datatime) {
+ this.datatime = datatime;
+ }
+
+ public int getQ() {
+ return q;
+ }
+
+ public void setQ(int q) {
+ this.q = q;
+ }
+
+ public int get_Msec() {
+ return _msec;
+ }
+
+ public void set_Msec(int _msec) {
+ this._msec = _msec;
+ }
+
+ @Override
+ public int hashCode() {
+ final int prime = 31;
+ int result = 1;
+ result = prime * result + ((datatime == null) ? 0 : datatime.hashCode());
+ return result;
+ }
+
+ @Override
+ public boolean equals(Object obj) {
+ if (this == obj)
+ return true;
+ if (obj == null)
+ return false;
+ if (getClass() != obj.getClass())
+ return false;
+ HisDataYc other = (HisDataYc) obj;
+ if (datatime == null) {
+ if (other.datatime != null)
+ return false;
+ } else if (!datatime.equals(other.datatime))
+ return false;
+ return true;
+ }
+
+ @Override
+ public String toString() {
+ return "HisDataYc [val=" + val + ", datatime=" + datatime + ", q=" + q + ", _msec=" + _msec + "]";
+ }
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/history/entity/HistoryRequestResult.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/history/entity/HistoryRequestResult.java
new file mode 100644
index 0000000..154f748
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/history/entity/HistoryRequestResult.java
@@ -0,0 +1,95 @@
+package org.springblade.hz3000_real_data.history.entity;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+public class HistoryRequestResult {
+
+ private String realId;
+
+ private Double val;
+
+ private String datatime;
+
+ private int q;
+
+ public HistoryRequestResult(String realId, String datatime) {
+ this.realId = realId;
+ this.datatime = datatime;
+ }
+
+ public HistoryRequestResult() {
+ }
+
+ @JsonProperty("hzrealid")
+ public String getRealId() {
+ return realId;
+ }
+
+ public void setRealId(String realId) {
+ this.realId = realId;
+ }
+
+ public Double getVal() {
+ return val;
+ }
+
+ public void setVal(Double val) {
+ this.val = val;
+ }
+
+ public String getDatatime() {
+ return datatime;
+ }
+
+ public void setDatatime(String datatime) {
+ this.datatime = datatime;
+ }
+
+ public int getQ() {
+ return q;
+ }
+
+ public void setQ(int q) {
+ this.q = q;
+ }
+
+ @Override
+ public int hashCode() {
+ final int prime = 31;
+ int result = 1;
+ result = prime * result + ((datatime == null) ? 0 : datatime.hashCode());
+ result = prime * result + q;
+ result = prime * result + ((realId == null) ? 0 : realId.hashCode());
+ return result;
+ }
+
+ @Override
+ public boolean equals(Object obj) {
+ if (this == obj)
+ return true;
+ if (obj == null)
+ return false;
+ if (getClass() != obj.getClass())
+ return false;
+ HistoryRequestResult other = (HistoryRequestResult) obj;
+ if (datatime == null) {
+ if (other.datatime != null)
+ return false;
+ } else if (!datatime.equals(other.datatime))
+ return false;
+ if (q != other.q)
+ return false;
+ if (realId == null) {
+ if (other.realId != null)
+ return false;
+ } else if (!realId.equals(other.realId))
+ return false;
+ return true;
+ }
+
+ @Override
+ public String toString() {
+ return "HistoryRequestResult [realId=" + realId + ", val=" + val + ", datatime=" + datatime + ", q=" + q + "]";
+ }
+
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/real/entity/Data.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/real/entity/Data.java
new file mode 100644
index 0000000..cc514cf
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/real/entity/Data.java
@@ -0,0 +1,55 @@
+//
+// Source code recreated from a .class file by IntelliJ IDEA
+// (powered by Fernflower decompiler)
+//
+
+package org.springblade.hz3000_real_data.real.entity;
+
+
+import org.springblade.hz3000_real_data.fac.entity.BasePoint;
+
+import java.io.Serializable;
+import java.util.Date;
+
+public class Data implements Serializable {
+ private static final long serialVersionUID = -3968193306625634915L;
+ private double value;
+ private Date time;
+ private BasePoint point;
+ private int q;
+
+ public Data() {
+ }
+
+ public double getValue() {
+ return this.value;
+ }
+
+ public void setValue(double value) {
+ this.value = value;
+ }
+
+ public Date getTime() {
+ return this.time;
+ }
+
+ public void setTime(Date time) {
+ this.time = time;
+ }
+
+ public BasePoint getPoint() {
+ return this.point;
+ }
+
+ public void setPoint(BasePoint point) {
+ this.point = point;
+ }
+
+ public int getQ() {
+ return this.q;
+ }
+
+ public void setQ(int q) {
+ this.q = q;
+ }
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/util/RSAUtils.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/util/RSAUtils.java
new file mode 100644
index 0000000..0ddc3bc
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hz3000-real-data-service-api/src/main/java/org/springblade/hz3000_real_data/util/RSAUtils.java
@@ -0,0 +1,183 @@
+package org.springblade.hz3000_real_data.util;
+
+import javax.crypto.Cipher;
+import java.math.BigInteger;
+import java.security.KeyFactory;
+import java.security.KeyPair;
+import java.security.KeyPairGenerator;
+import java.security.NoSuchAlgorithmException;
+import java.security.interfaces.RSAPrivateKey;
+import java.security.interfaces.RSAPublicKey;
+import java.security.spec.RSAPrivateKeySpec;
+import java.security.spec.RSAPublicKeySpec;
+import java.util.HashMap;
+
+public class RSAUtils {
+ public static final String PUBLIC_KEY = "public";
+ public static final String PRIVATE_KEY = "private";
+
+ public RSAUtils() {
+ }
+
+ public static HashMap getKeys() throws NoSuchAlgorithmException {
+ HashMap map = new HashMap();
+ KeyPairGenerator keyPairGen = KeyPairGenerator.getInstance("RSA");
+ keyPairGen.initialize(1024);
+ KeyPair keyPair = keyPairGen.generateKeyPair();
+ RSAPublicKey publicKey = (RSAPublicKey)keyPair.getPublic();
+ RSAPrivateKey privateKey = (RSAPrivateKey)keyPair.getPrivate();
+ map.put("public", publicKey);
+ map.put("private", privateKey);
+ return map;
+ }
+
+ public static RSAPublicKey getPublicKey(String modulus, String exponent) {
+ try {
+ BigInteger b1 = new BigInteger(modulus);
+ BigInteger b2 = new BigInteger(exponent);
+ KeyFactory keyFactory = KeyFactory.getInstance("RSA");
+ RSAPublicKeySpec keySpec = new RSAPublicKeySpec(b1, b2);
+ return (RSAPublicKey)keyFactory.generatePublic(keySpec);
+ } catch (Exception var6) {
+ var6.printStackTrace();
+ return null;
+ }
+ }
+
+ public static RSAPrivateKey getPrivateKey(String modulus, String exponent) {
+ try {
+ BigInteger b1 = new BigInteger(modulus);
+ BigInteger b2 = new BigInteger(exponent);
+ KeyFactory keyFactory = KeyFactory.getInstance("RSA");
+ RSAPrivateKeySpec keySpec = new RSAPrivateKeySpec(b1, b2);
+ return (RSAPrivateKey)keyFactory.generatePrivate(keySpec);
+ } catch (Exception var6) {
+ var6.printStackTrace();
+ return null;
+ }
+ }
+
+ public static String encryptByPublicKey(String data, RSAPublicKey publicKey) throws Exception {
+ Cipher cipher = Cipher.getInstance("RSA");
+ cipher.init(1, publicKey);
+ int key_len = publicKey.getModulus().bitLength() / 8;
+ String[] datas = splitString(data, key_len - 11);
+ String mi = "";
+ String[] var6 = datas;
+ int var7 = datas.length;
+
+ for(int var8 = 0; var8 < var7; ++var8) {
+ String s = var6[var8];
+ mi = mi + bcd2Str(cipher.doFinal(s.getBytes()));
+ }
+
+ return mi;
+ }
+
+ public static String decryptByPrivateKey(String data, RSAPrivateKey privateKey) throws Exception {
+ Cipher cipher = Cipher.getInstance("RSA");
+ cipher.init(2, privateKey);
+ int key_len = privateKey.getModulus().bitLength() / 8;
+ byte[] bytes = data.getBytes();
+ byte[] bcd = ASCII_To_BCD(bytes, bytes.length);
+ String ming = "";
+ byte[][] arrays = splitArray(bcd, key_len);
+ byte[][] var8 = arrays;
+ int var9 = arrays.length;
+
+ for(int var10 = 0; var10 < var9; ++var10) {
+ byte[] arr = var8[var10];
+ ming = ming + new String(cipher.doFinal(arr));
+ }
+
+ return ming;
+ }
+
+ public static byte[] ASCII_To_BCD(byte[] ascii, int asc_len) {
+ byte[] bcd = new byte[asc_len / 2];
+ int j = 0;
+
+ for(int i = 0; i < (asc_len + 1) / 2; ++i) {
+ bcd[i] = asc_to_bcd(ascii[j++]);
+ bcd[i] = (byte)((j >= asc_len ? 0 : asc_to_bcd(ascii[j++])) + (bcd[i] << 4));
+ }
+
+ return bcd;
+ }
+
+ public static byte asc_to_bcd(byte asc) {
+ byte bcd;
+ if (asc >= 48 && asc <= 57) {
+ bcd = (byte)(asc - 48);
+ } else if (asc >= 65 && asc <= 70) {
+ bcd = (byte)(asc - 65 + 10);
+ } else if (asc >= 97 && asc <= 102) {
+ bcd = (byte)(asc - 97 + 10);
+ } else {
+ bcd = (byte)(asc - 48);
+ }
+
+ return bcd;
+ }
+
+ public static String bcd2Str(byte[] bytes) {
+ char[] temp = new char[bytes.length * 2];
+
+ for(int i = 0; i < bytes.length; ++i) {
+ char val = (char)((bytes[i] & 240) >> 4 & 15);
+ temp[i * 2] = (char)(val > '\t' ? val + 65 - 10 : val + 48);
+ val = (char)(bytes[i] & 15);
+ temp[i * 2 + 1] = (char)(val > '\t' ? val + 65 - 10 : val + 48);
+ }
+
+ return new String(temp);
+ }
+
+ public static String[] splitString(String string, int len) {
+ int x = string.length() / len;
+ int y = string.length() % len;
+ int z = 0;
+ if (y != 0) {
+ z = 1;
+ }
+
+ String[] strings = new String[x + z];
+ String str = "";
+
+ for(int i = 0; i < x + z; ++i) {
+ if (i == x + z - 1 && y != 0) {
+ str = string.substring(i * len, i * len + y);
+ } else {
+ str = string.substring(i * len, i * len + len);
+ }
+
+ strings[i] = str;
+ }
+
+ return strings;
+ }
+
+ public static byte[][] splitArray(byte[] data, int len) {
+ int x = data.length / len;
+ int y = data.length % len;
+ int z = 0;
+ if (y != 0) {
+ z = 1;
+ }
+
+ byte[][] arrays = new byte[x + z][];
+
+ for(int i = 0; i < x + z; ++i) {
+ byte[] arr = new byte[len];
+ if (i == x + z - 1 && y != 0) {
+ System.arraycopy(data, i * len, arr, 0, y);
+ } else {
+ System.arraycopy(data, i * len, arr, 0, len);
+ }
+
+ arrays[i] = arr;
+ }
+
+ return arrays;
+ }
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hzinfo-inspect-service-api/pom.xml b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hzinfo-inspect-service-api/pom.xml
new file mode 100644
index 0000000..18d9d62
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hzinfo-inspect-service-api/pom.xml
@@ -0,0 +1,16 @@
+
+
+
+ hzinfo-ris-pxhd-service-api
+ org.springblade
+ 4.5.0.RELEASE
+
+ 4.0.0
+
+ pxhd-hzinfo-inspect-api
+ ${project.artifactId}
+ jar
+
+
\ No newline at end of file
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hzinfo-inspect-service-api/src/main/java/org/springblade/hzinfo_inspect/Constants.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hzinfo-inspect-service-api/src/main/java/org/springblade/hzinfo_inspect/Constants.java
new file mode 100644
index 0000000..eb9b690
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hzinfo-inspect-service-api/src/main/java/org/springblade/hzinfo_inspect/Constants.java
@@ -0,0 +1,8 @@
+package org.springblade.hzinfo_inspect;
+
+/**
+ * @Author: py
+ */
+public class Constants {
+ public final static String APP_NAME = "hzinfo-inspect";
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hzinfo-inspect-service-api/src/main/java/org/springblade/hzinfo_inspect/gather/entity/InspectReportEntity.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hzinfo-inspect-service-api/src/main/java/org/springblade/hzinfo_inspect/gather/entity/InspectReportEntity.java
new file mode 100644
index 0000000..62d8872
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hzinfo-inspect-service-api/src/main/java/org/springblade/hzinfo_inspect/gather/entity/InspectReportEntity.java
@@ -0,0 +1,29 @@
+package org.springblade.hzinfo_inspect.gather.entity;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class InspectReportEntity implements Serializable {
+ private static final long serialVersionUID = -3296006758328565445L;
+
+ @ApiModelProperty("人员ID")
+ private Long userId;
+
+ @ApiModelProperty("姓名")
+ private String userName;
+
+ @ApiModelProperty("完成任务情况")
+ private String completeSituation;
+
+ @ApiModelProperty("未完成任务情况")
+ private String incompleteSituation;
+
+ @ApiModelProperty("工时")
+ private Integer hours;
+
+ @ApiModelProperty("发现问题数量")
+ private Integer findProblemCount;
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hzinfo-inspect-service-api/src/main/java/org/springblade/hzinfo_inspect/gather/entity/TaskGatherEntity.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hzinfo-inspect-service-api/src/main/java/org/springblade/hzinfo_inspect/gather/entity/TaskGatherEntity.java
new file mode 100644
index 0000000..2d5a9bd
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hzinfo-inspect-service-api/src/main/java/org/springblade/hzinfo_inspect/gather/entity/TaskGatherEntity.java
@@ -0,0 +1,164 @@
+package org.springblade.hzinfo_inspect.gather.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springblade.core.mp.base.BaseEntity;
+import org.springblade.core.mp.support.QueryField;
+import org.springblade.core.mp.support.SqlCondition;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+
+
+/**
+ * 实体类
+ *
+ * @author Chill
+ */
+@Data
+@TableName("hz_st_hi_task_gather")
+@EqualsAndHashCode(callSuper = true)
+@ApiModel(value = "TaskGather对象", description = "巡检任务统计数据集合对象,集控站使用")
+public class TaskGatherEntity extends BaseEntity {
+
+ private static final long serialVersionUID = 1L;
+
+
+ @QueryField(condition = SqlCondition.EQUAL)
+ @ApiModelProperty("租户ID")
+ private String tenantId;
+
+ /**
+ * 用户id
+ */
+ @QueryField(condition = SqlCondition.EQUAL)
+ @ApiModelProperty(value = "用户id")
+ private Long userId;
+ /**
+ * 用户名称
+ */
+ @ApiModelProperty(value = "用户名称")
+ private String userName;
+ /**
+ * 路径id
+ */
+ @QueryField(condition = SqlCondition.EQUAL)
+ @ApiModelProperty(value = "路径id")
+ private Long routeId;
+ /**
+ *
+ */
+ @ApiModelProperty(value = "路径名称")
+ private String routeName;
+ /**
+ * 问题数
+ */
+ @ApiModelProperty(value = "问题数")
+ private Long problemNum;
+ /**
+ * 计划ID
+ */
+ @ApiModelProperty(value = "计划ID")
+ private Long planId;
+ /**
+ * 计划模式 0 人员 1岗位 2机构 3自由模式 4 自由人模式
+ */
+ @ApiModelProperty(value = "计划模式 0 人员 1岗位 2机构 3自由模式 4 自由人模式")
+ private String type;
+ /**
+ * 计划名称
+ */
+ @ApiModelProperty(value = "计划名称")
+ private String planName;
+ /**
+ * 任务批次号
+ */
+ @ApiModelProperty(value = "任务批次号")
+ private String batchNumber;
+ /**
+ * 计划周期 0: 从不 1:每天 2:每月 3:每季度 5:每年 4:每周
+ */
+ @ApiModelProperty(value = "计划周期 0: 从不 1:每天 2:每月 3:每季度 5:每年 4:每周")
+ private String cycle;
+ /**
+ * 派发方式:0 抢占模式 1 并发模式
+ */
+ @ApiModelProperty(value = "派发方式:0 抢占模式 1 并发模式")
+ private String method;
+ /**
+ * 任务计划开始时间
+ */
+ @ApiModelProperty(value = "任务计划开始时间")
+ private LocalDateTime planStartTime;
+ /**
+ * 任务计划结束时间
+ */
+ @ApiModelProperty(value = "任务计划结束时间")
+ private LocalDateTime planEndTime;
+ /**
+ * 任务实际开始时间
+ */
+ @ApiModelProperty(value = "任务实际开始时间")
+ private LocalDateTime startTime;
+ /**
+ * 任务实际结束时间
+ */
+ @ApiModelProperty(value = "任务实际结束时间")
+ private LocalDateTime endTime;
+ /**
+ * 巡检报备 0 未报备 1已报备
+ */
+ @ApiModelProperty(value = "巡检报备 0 未报备 1已报备")
+ private String keepOnRecord;
+ /**
+ * 巡检类型标识: 0普通巡检,1,视频自动巡检,2机器人巡检
+ */
+ @ApiModelProperty(value = "巡检类型标识: 0普通巡检,1,视频自动巡检,2机器人巡检")
+ private String autoVideo;
+ /**
+ * 临时任务的巡检任务内容
+ */
+ @ApiModelProperty(value = "临时任务的巡检任务内容")
+ private String taskContent;
+ /**
+ * 计划类型,common常规任务,temporary临时任务
+ */
+ @ApiModelProperty(value = "计划类型,common常规任务,temporary临时任务")
+ private String planType;
+ /**
+ * 任务开始前 是否发送提醒短信 标识
+ */
+ @ApiModelProperty(value = "任务开始前 是否发送提醒短信 标识")
+ private Boolean startRemindFlag;
+ /**
+ * 任务结束前 是否发送提醒短信 标识
+ */
+ @ApiModelProperty(value = "任务结束前 是否发送提醒短信 标识")
+ private Boolean endRemindFlag;
+ /**
+ * 开始前提醒时间
+ */
+ @ApiModelProperty(value = "开始前提醒时间")
+ private LocalDateTime startRemindTime;
+ /**
+ * 结束前提醒时间
+ */
+ @ApiModelProperty(value = "结束前提醒时间")
+ private LocalDateTime endRemindTime;
+
+ public String getStrPlanStartTime(){
+ DateTimeFormatter dfShort = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+ return dfShort.format(getPlanStartTime());
+ }
+
+ public Long getProblemNum() {
+ if(problemNum == null){
+ return 0L;
+ }
+ return problemNum;
+ }
+
+}
diff --git a/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hzinfo-inspect-service-api/src/main/java/org/springblade/hzinfo_inspect/gather/feign/IInspectGatherClient.java b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hzinfo-inspect-service-api/src/main/java/org/springblade/hzinfo_inspect/gather/feign/IInspectGatherClient.java
new file mode 100644
index 0000000..3ec4e29
--- /dev/null
+++ b/HZInfo-RIS-PXHD/hzinfo-ris-pxhd-service-api/hzinfo-inspect-service-api/src/main/java/org/springblade/hzinfo_inspect/gather/feign/IInspectGatherClient.java
@@ -0,0 +1,38 @@
+package org.springblade.hzinfo_inspect.gather.feign;
+
+import org.springblade.core.tool.api.R;
+import org.springblade.hzinfo_inspect.Constants;
+import org.springblade.hzinfo_inspect.gather.entity.TaskGatherEntity;
+import org.springblade.hzinfo_inspect.gather.vo.TaskGatherReportVO;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestParam;
+
+import java.util.List;
+import java.util.Map;
+
+@FeignClient(
+ value = Constants.APP_NAME
+)
+public interface IInspectGatherClient {
+
+ String API_PREFIX = "/feign/gather";
+ String LIST_GATHER_TASK_BY_DISPOSER = API_PREFIX + "/listGatherTaskByDisposer";
+ String LIST_TASK_GATHER_REPORT = API_PREFIX + "/listTaskGatherReport";
+ String LIST_BY_TIME_AND_PERSON = API_PREFIX + "/listByTimeAndPerson";
+ String INSPECT_CONCLUSION = API_PREFIX + "/getInspectConclusion";
+
+ @GetMapping(LIST_GATHER_TASK_BY_DISPOSER)
+ R> listGatherTaskByDisposer(@RequestParam("disposer") String disposer);
+
+ @PostMapping(LIST_TASK_GATHER_REPORT)
+ List listTaskGatherReport(@RequestBody Map params);
+
+ @PostMapping(LIST_BY_TIME_AND_PERSON)
+ List listByTimeAndPerson(@RequestBody Map params);
+
+ @PostMapping(INSPECT_CONCLUSION)
+ List