diff --git a/hzims-service-api/pom.xml b/hzims-service-api/pom.xml
index 62171b4..6fc1e55 100644
--- a/hzims-service-api/pom.xml
+++ b/hzims-service-api/pom.xml
@@ -31,6 +31,8 @@
digital-twin-display-api
dam-safety-api
video-image-api
+ water-quality-api
+ water-rain-api
diff --git a/hzims-service-api/water-quality-api/pom.xml b/hzims-service-api/water-quality-api/pom.xml
new file mode 100644
index 0000000..c203bd2
--- /dev/null
+++ b/hzims-service-api/water-quality-api/pom.xml
@@ -0,0 +1,20 @@
+
+
+ 4.0.0
+
+ com.hnac.hzims
+ hzims-service-api
+ 4.0.0-SNAPSHOT
+
+
+ water-quality-api
+
+
+ 8
+ 8
+ UTF-8
+
+
+
\ No newline at end of file
diff --git a/hzims-service-api/water-quality-api/src/main/java/com/hnac/hzims/waterquality/entity/WqConfigD.java b/hzims-service-api/water-quality-api/src/main/java/com/hnac/hzims/waterquality/entity/WqConfigD.java
new file mode 100644
index 0000000..c69e21a
--- /dev/null
+++ b/hzims-service-api/water-quality-api/src/main/java/com/hnac/hzims/waterquality/entity/WqConfigD.java
@@ -0,0 +1,24 @@
+package com.hnac.hzims.waterquality.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;
+
+/**
+ *水质监测指标配置
+ */
+@Data
+@TableName("wq_config_d")
+public class WqConfigD implements Serializable {
+ @ApiModelProperty("测站编码")
+ @TableId(type=IdType.INPUT)
+ private String stcd;
+ @ApiModelProperty("指标类型")
+ private String type;
+ @ApiModelProperty("指标值")
+ private String value;
+}
diff --git a/hzims-service-api/water-quality-api/src/main/java/com/hnac/hzims/waterquality/entity/WqWfrinfB.java b/hzims-service-api/water-quality-api/src/main/java/com/hnac/hzims/waterquality/entity/WqWfrinfB.java
new file mode 100644
index 0000000..6cd688b
--- /dev/null
+++ b/hzims-service-api/water-quality-api/src/main/java/com/hnac/hzims/waterquality/entity/WqWfrinfB.java
@@ -0,0 +1,54 @@
+package com.hnac.hzims.waterquality.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;
+
+
+/**
+ *水功能区基本信息
+ */
+@Data
+@TableName("wq_wfrinf_b")
+@EqualsAndHashCode(callSuper = true)
+public class WqWfrinfB extends BaseEntity {
+ @ApiModelProperty("水功能区代码")
+ private String wfrcd;
+ @ApiModelProperty("水功能区名称")
+ private String wfrnm;
+ @ApiModelProperty("流域名称")
+ private String bsnm;
+ @ApiModelProperty("水系名称")
+ private String hnnm;
+ @ApiModelProperty("河流名称")
+ private String rvnm;
+ @ApiModelProperty("水功能区起始断面名称")
+ private String wfrscsnm;
+ @ApiModelProperty("水功能区起始断面经度")
+ private Double wfrscslgtd;
+ @ApiModelProperty("水功能区起始断面纬度")
+ private Double wfrscslttd;
+ @ApiModelProperty("水功能区终止断面名称")
+ private String wfrecsnm;
+ @ApiModelProperty("水功能区终止断面经度")
+ private Double wfrecslgtd;
+ @ApiModelProperty("水功能区终止断面纬度")
+ private Double wfrecslttd;
+
+ @ApiModelProperty("行政区划码")
+ private String addvcd;
+ @ApiModelProperty("水功能区长度")
+ private Double wfrln;
+ @ApiModelProperty("水功能区库容")
+ private Double wfrrc;
+ @ApiModelProperty("水功能区面积")
+ private Double wfrar;
+ @ApiModelProperty("水功能区水质目标")
+ private String wfrwqt;
+ @ApiModelProperty("水功能区功能排序")
+ private String wfrwfo;
+ @ApiModelProperty("备注")
+ private String nt;
+}
diff --git a/hzims-service-api/water-quality-api/src/main/java/com/hnac/hzims/waterquality/entity/WqWqsinfB.java b/hzims-service-api/water-quality-api/src/main/java/com/hnac/hzims/waterquality/entity/WqWqsinfB.java
new file mode 100644
index 0000000..96c7c70
--- /dev/null
+++ b/hzims-service-api/water-quality-api/src/main/java/com/hnac/hzims/waterquality/entity/WqWqsinfB.java
@@ -0,0 +1,59 @@
+package com.hnac.hzims.waterquality.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("wq_wqsinf_b")
+@EqualsAndHashCode(callSuper = true)
+public class WqWqsinfB extends BaseEntity {
+ @ApiModelProperty("测站编码")
+ private String stcd;
+ @ApiModelProperty("测站名称")
+ private String stnm;
+ @ApiModelProperty("测站等级")
+ private String stgrd;
+ @ApiModelProperty("流域名称")
+ private String bsnm;
+ @ApiModelProperty("水系名称")
+ private String hnnm;
+ @ApiModelProperty("河流名称")
+ private String rvnm;
+ @ApiModelProperty("经度")
+ private Double lgtd;
+ @ApiModelProperty("纬度")
+ private Double lttd;
+ @ApiModelProperty("站址")
+ private String stlc;
+ @ApiModelProperty("行政区划码")
+ private String addvcd;
+ @ApiModelProperty("水资源分区码")
+ private String wrrcd;
+ @ApiModelProperty("水功能区划码")
+ private String wfrcd;
+ @ApiModelProperty("管理单位")
+ private String adag;
+ @ApiModelProperty("监测单位")
+ private String mnag;
+ @ApiModelProperty("监测频次")
+ private Integer mnfrq;
+ @ApiModelProperty("自动监测")
+ private Integer atmn;
+ @ApiModelProperty("建站年月")
+ @JsonFormat(pattern = "yyyy-MM-dd")
+ private Date esstym;
+ @ApiModelProperty("撤站年月")
+ @JsonFormat(pattern = "yyyy-MM-dd")
+ private Date wdstym;
+ @ApiModelProperty("备注")
+ private String nt;
+}
diff --git a/hzims-service-api/water-quality-api/src/main/java/com/hnac/hzims/waterquality/entity/WqWrrinfB.java b/hzims-service-api/water-quality-api/src/main/java/com/hnac/hzims/waterquality/entity/WqWrrinfB.java
new file mode 100644
index 0000000..b09563b
--- /dev/null
+++ b/hzims-service-api/water-quality-api/src/main/java/com/hnac/hzims/waterquality/entity/WqWrrinfB.java
@@ -0,0 +1,22 @@
+package com.hnac.hzims.waterquality.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import org.springblade.core.mp.base.BaseEntity;
+
+
+/**
+ * 水资源分区基本信息
+ */
+@Data
+@TableName("wq_wrrinf_b")
+public class WqWrrinfB extends BaseEntity {
+ @ApiModelProperty("水资源分区码")
+ private String wrrcd;
+ @ApiModelProperty("水资源分区名称")
+ private String wrrnm;
+ @ApiModelProperty("水资源分区面积")
+ private Double wrr5r;
+
+}
diff --git a/hzims-service-api/water-quality-api/src/main/java/com/hnac/hzims/waterquality/feign/IWqWqsinfBClient.java b/hzims-service-api/water-quality-api/src/main/java/com/hnac/hzims/waterquality/feign/IWqWqsinfBClient.java
new file mode 100644
index 0000000..a80f5c4
--- /dev/null
+++ b/hzims-service-api/water-quality-api/src/main/java/com/hnac/hzims/waterquality/feign/IWqWqsinfBClient.java
@@ -0,0 +1,50 @@
+/*
+ * Copyright (c) 2018-2028, Chill Zhuang All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright Example,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * Example, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the dreamlu.net developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: Chill 庄骞 (smallchill@163.com)
+ */
+package com.hnac.hzims.waterquality.feign;
+
+import com.hnac.hzims.waterquality.vo.WqWqsinfBVo;
+import org.springblade.core.launch.constant.AppConstant;
+import org.springblade.core.tool.api.R;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+
+import java.util.List;
+
+/**
+ * Example Feign接口类
+ *
+ * @author Chill
+ */
+@FeignClient(
+ value = AppConstant.APPLICATION_DESK_NAME
+)
+public interface IWqWqsinfBClient {
+
+ String API_PREFIX = "/wqWqsinfBClient";
+ String LIST = API_PREFIX + "/list";
+
+ /**
+ * 获取Example列表
+ *
+ * @param number
+ * @return
+ */
+ @GetMapping(LIST)
+ R> list(@RequestParam("number") Integer number);
+
+}
diff --git a/hzims-service-api/water-quality-api/src/main/java/com/hnac/hzims/waterquality/vo/WqWqsinfBVo.java b/hzims-service-api/water-quality-api/src/main/java/com/hnac/hzims/waterquality/vo/WqWqsinfBVo.java
new file mode 100644
index 0000000..9d05b72
--- /dev/null
+++ b/hzims-service-api/water-quality-api/src/main/java/com/hnac/hzims/waterquality/vo/WqWqsinfBVo.java
@@ -0,0 +1,7 @@
+package com.hnac.hzims.waterquality.vo;
+
+
+import com.hnac.hzims.waterquality.entity.WqWqsinfB;
+
+public class WqWqsinfBVo extends WqWqsinfB {
+}
diff --git a/hzims-service-api/water-rain-api/pom.xml b/hzims-service-api/water-rain-api/pom.xml
new file mode 100644
index 0000000..a919a96
--- /dev/null
+++ b/hzims-service-api/water-rain-api/pom.xml
@@ -0,0 +1,20 @@
+
+
+ 4.0.0
+
+ com.hnac.hzims
+ hzims-service-api
+ 4.0.0-SNAPSHOT
+
+
+ water-rain-api
+
+
+ 8
+ 8
+ UTF-8
+
+
+
\ No newline at end of file
diff --git a/hzims-service-api/water-rain-api/src/main/java/com/hnac/hzims/waterrain/bo/StationResp.java b/hzims-service-api/water-rain-api/src/main/java/com/hnac/hzims/waterrain/bo/StationResp.java
new file mode 100644
index 0000000..2691c22
--- /dev/null
+++ b/hzims-service-api/water-rain-api/src/main/java/com/hnac/hzims/waterrain/bo/StationResp.java
@@ -0,0 +1,26 @@
+package com.hnac.hzims.waterrain.bo;
+
+
+import com.hnac.hzims.waterrain.entity.StStbprpB;
+
+public class StationResp {
+ private StStbprpB stStbprpB;
+
+ private Object obj;
+
+ public StStbprpB getStStbprpB() {
+ return stStbprpB;
+ }
+
+ public void setStStbprpB(StStbprpB stStbprpB) {
+ this.stStbprpB = stStbprpB;
+ }
+
+ public Object getObj() {
+ return obj;
+ }
+
+ public void setObj(Object obj) {
+ this.obj = obj;
+ }
+}
diff --git a/hzims-service-api/water-rain-api/src/main/java/com/hnac/hzims/waterrain/entity/HzStPptnR.java b/hzims-service-api/water-rain-api/src/main/java/com/hnac/hzims/waterrain/entity/HzStPptnR.java
new file mode 100644
index 0000000..dda2d53
--- /dev/null
+++ b/hzims-service-api/water-rain-api/src/main/java/com/hnac/hzims/waterrain/entity/HzStPptnR.java
@@ -0,0 +1,13 @@
+package com.hnac.hzims.waterrain.entity;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+@Data
+public class HzStPptnR implements Serializable {
+ private String stcd;
+ private Date tm;
+ private Double drp;
+}
diff --git a/hzims-service-api/water-rain-api/src/main/java/com/hnac/hzims/waterrain/entity/HzStRiverR.java b/hzims-service-api/water-rain-api/src/main/java/com/hnac/hzims/waterrain/entity/HzStRiverR.java
new file mode 100644
index 0000000..d69750a
--- /dev/null
+++ b/hzims-service-api/water-rain-api/src/main/java/com/hnac/hzims/waterrain/entity/HzStRiverR.java
@@ -0,0 +1,14 @@
+package com.hnac.hzims.waterrain.entity;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+@Data
+public class HzStRiverR implements Serializable {
+ private String stcd;
+ private Date tm;
+ private Double z;
+ private Double q;
+}
diff --git a/hzims-service-api/water-rain-api/src/main/java/com/hnac/hzims/waterrain/entity/HzStRsvrR.java b/hzims-service-api/water-rain-api/src/main/java/com/hnac/hzims/waterrain/entity/HzStRsvrR.java
new file mode 100644
index 0000000..feb5928
--- /dev/null
+++ b/hzims-service-api/water-rain-api/src/main/java/com/hnac/hzims/waterrain/entity/HzStRsvrR.java
@@ -0,0 +1,15 @@
+package com.hnac.hzims.waterrain.entity;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+@Data
+public class HzStRsvrR implements Serializable {
+ private String stcd;//测站编码
+ private Date tm;//时间
+ private Double rz; //水位
+ private Double inq;//流量
+}
+
diff --git a/hzims-service-api/water-rain-api/src/main/java/com/hnac/hzims/waterrain/entity/ReorganizeData.java b/hzims-service-api/water-rain-api/src/main/java/com/hnac/hzims/waterrain/entity/ReorganizeData.java
new file mode 100644
index 0000000..fee68a4
--- /dev/null
+++ b/hzims-service-api/water-rain-api/src/main/java/com/hnac/hzims/waterrain/entity/ReorganizeData.java
@@ -0,0 +1,14 @@
+package com.hnac.hzims.waterrain.entity;
+
+import lombok.Data;
+
+import java.util.List;
+import java.util.Map;
+
+@Data
+public class ReorganizeData {
+ private String yearMonth;
+ private String stcd;
+ private String sttp;
+ private List