diff --git a/src/main/java/com/gunshi/project/xyt/controller/GateValveCctvRelController.java b/src/main/java/com/gunshi/project/xyt/controller/GateValveCctvRelController.java index f3e4c00..767b15b 100644 --- a/src/main/java/com/gunshi/project/xyt/controller/GateValveCctvRelController.java +++ b/src/main/java/com/gunshi/project/xyt/controller/GateValveCctvRelController.java @@ -9,6 +9,7 @@ import com.gunshi.project.xyt.service.GateValveCctvRelService; import com.gunshi.project.xyt.validate.markers.Insert; import com.gunshi.project.xyt.validate.markers.Update; import io.swagger.v3.oas.annotations.Operation; +import io.swagger.v3.oas.annotations.Parameter; import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.tags.Tag; import org.springframework.beans.factory.annotation.Autowired; @@ -74,8 +75,8 @@ public class GateValveCctvRelController { @Operation(summary = "列表") @PostMapping("/list") - public R> list() { - return R.ok(service.queryList()); + public R> list(@RequestParam(value = "valveCode",required = false) @Parameter(description = "闸阀编码") String valveCode) { + return R.ok(service.queryList(valveCode)); } @Operation(summary = "分页") diff --git a/src/main/java/com/gunshi/project/xyt/controller/GateValveRealController.java b/src/main/java/com/gunshi/project/xyt/controller/GateValveRealController.java index 55cc7fd..9a52e1d 100644 --- a/src/main/java/com/gunshi/project/xyt/controller/GateValveRealController.java +++ b/src/main/java/com/gunshi/project/xyt/controller/GateValveRealController.java @@ -2,6 +2,7 @@ package com.gunshi.project.xyt.controller; import com.gunshi.core.result.R; import com.gunshi.project.xyt.entity.vo.GateStautsVo; +import com.gunshi.project.xyt.model.GateValveKey; import com.gunshi.project.xyt.model.GateValveReal; import com.gunshi.project.xyt.service.GateValveRealService; import com.gunshi.project.xyt.validate.markers.Insert; @@ -63,6 +64,12 @@ public class GateValveRealController { return R.ok(service.realQ(valveCode)); } + @Operation(summary = "调节闸阀") + @PostMapping("/control") + public R control(@RequestBody GateValveKey gateValveKey) { + return R.ok(service.control(gateValveKey)); + } + // @Operation(summary = "分页") // @PostMapping("/page") public R> page() { diff --git a/src/main/java/com/gunshi/project/xyt/entity/vo/AttResBaseVo.java b/src/main/java/com/gunshi/project/xyt/entity/vo/AttResBaseVo.java index 4656596..31a39f6 100644 --- a/src/main/java/com/gunshi/project/xyt/entity/vo/AttResBaseVo.java +++ b/src/main/java/com/gunshi/project/xyt/entity/vo/AttResBaseVo.java @@ -110,6 +110,9 @@ public class AttResBaseVo { @Schema(description="监测水位") private BigDecimal rz; + @Schema(description="坝址控制流域面积") + private BigDecimal watShedArea; + /** * 超讯限 */ @@ -155,6 +158,9 @@ public class AttResBaseVo { @Schema(description = "坝顶高程") private BigDecimal crestElev; + @Schema(description="死库容") + private BigDecimal deadCap; + /** * 兴利库容 */ diff --git a/src/main/java/com/gunshi/project/xyt/mapper/AttResBaseMapper.java b/src/main/java/com/gunshi/project/xyt/mapper/AttResBaseMapper.java index c9a34d8..f84f892 100644 --- a/src/main/java/com/gunshi/project/xyt/mapper/AttResBaseMapper.java +++ b/src/main/java/com/gunshi/project/xyt/mapper/AttResBaseMapper.java @@ -25,7 +25,7 @@ public interface AttResBaseMapper extends BaseMapper { @Select(""" """) - List queryList(); + List queryList(@Param("valveCode") String valveCode); } \ No newline at end of file diff --git a/src/main/java/com/gunshi/project/xyt/model/GateValveKey.java b/src/main/java/com/gunshi/project/xyt/model/GateValveKey.java new file mode 100644 index 0000000..78bb69a --- /dev/null +++ b/src/main/java/com/gunshi/project/xyt/model/GateValveKey.java @@ -0,0 +1,44 @@ +package com.gunshi.project.xyt.model; + + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +import java.io.Serializable; + +/** +* 描述: 闸阀密码表 +* author: xusan +* date: 2024-07-08 17:34:26 +*/ +@Schema(description="闸阀密码表") +@Data +@TableName("public.gate_valve_key") +public class GateValveKey implements Serializable { + + + private static final long serialVersionUID = 1L; + + /** + * 闸阀编号 + */ + @TableId(value="valve_code", type= IdType.AUTO) + @Schema(description="闸阀编号") + private String valveCode; + + /** + * 密码 + */ + @TableField(value="key") + @Schema(description="密码") + private String key; + + @TableField(exist = false) + @Schema(description="开关状态") + private String status; + +} \ No newline at end of file diff --git a/src/main/java/com/gunshi/project/xyt/model/GateValveR.java b/src/main/java/com/gunshi/project/xyt/model/GateValveR.java index e15fb9e..df35dfd 100644 --- a/src/main/java/com/gunshi/project/xyt/model/GateValveR.java +++ b/src/main/java/com/gunshi/project/xyt/model/GateValveR.java @@ -1,15 +1,12 @@ package com.gunshi.project.xyt.model; -import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.TableField; -import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; import com.fasterxml.jackson.annotation.JsonFormat; +import com.github.jeffreyning.mybatisplus.anno.MppMultiId; import com.gunshi.core.dateformat.DateFormatString; import io.swagger.v3.oas.annotations.media.Schema; -import jakarta.validation.constraints.NotBlank; -import jakarta.validation.constraints.NotNull; import jakarta.validation.constraints.Size; import lombok.Data; @@ -29,18 +26,11 @@ public class GateValveR implements Serializable { private static final long serialVersionUID = 1L; - /** - * id - */ - @TableId(value="id", type= IdType.AUTO) - @Schema(description="id") - // @Size(max = 0,message = "id最大长度要小于 0") - @NotNull(message = "id不能为空") - private Long id; /** * 闸阀ID */ + @MppMultiId @TableField(value="valve_code") @Schema(description="闸阀ID") @Size(max = 20,message = "闸阀ID最大长度要小于 20") @@ -56,9 +46,9 @@ public class GateValveR implements Serializable { /** * 操作时间 */ + @MppMultiId @TableField(value="tm") @Schema(description="操作时间") - // @Size(max = 0,message = "操作时间最大长度要小于 0") @JsonFormat(pattern = DateFormatString.YYYY_MM_DD_HH_MM_SS, timezone = "GMT+8") private Date tm; diff --git a/src/main/java/com/gunshi/project/xyt/model/GateValveReal.java b/src/main/java/com/gunshi/project/xyt/model/GateValveReal.java index c00d388..9a0ce56 100644 --- a/src/main/java/com/gunshi/project/xyt/model/GateValveReal.java +++ b/src/main/java/com/gunshi/project/xyt/model/GateValveReal.java @@ -1,14 +1,12 @@ package com.gunshi.project.xyt.model; -import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.TableField; -import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; import com.fasterxml.jackson.annotation.JsonFormat; +import com.github.jeffreyning.mybatisplus.anno.MppMultiId; import com.gunshi.core.dateformat.DateFormatString; import io.swagger.v3.oas.annotations.media.Schema; -import jakarta.validation.constraints.NotNull; import jakarta.validation.constraints.Size; import lombok.Data; @@ -28,17 +26,10 @@ public class GateValveReal implements Serializable { private static final long serialVersionUID = 1L; - /** - * id - */ - @TableId(value="id", type= IdType.AUTO) - @Schema(description="id") - @NotNull(message = "id不能为空") - private Long id; - /** * 闸阀ID */ + @MppMultiId @TableField(value="valve_code") @Schema(description="闸阀ID") @Size(max = 20,message = "闸阀ID最大长度要小于 20") @@ -54,6 +45,7 @@ public class GateValveReal implements Serializable { /** * 操作时间 */ + @MppMultiId @TableField(value="tm") @Schema(description="操作时间") @JsonFormat(pattern = DateFormatString.YYYY_MM_DD_HH_MM_SS, timezone = "GMT+8") diff --git a/src/main/java/com/gunshi/project/xyt/service/GateValveCctvRelService.java b/src/main/java/com/gunshi/project/xyt/service/GateValveCctvRelService.java index 69b65fe..621dc51 100644 --- a/src/main/java/com/gunshi/project/xyt/service/GateValveCctvRelService.java +++ b/src/main/java/com/gunshi/project/xyt/service/GateValveCctvRelService.java @@ -27,8 +27,8 @@ public class GateValveCctvRelService extends ServiceImpl queryList() { - return baseMapper.queryList(); + public List queryList(String valveCode) { + return baseMapper.queryList(valveCode); } } diff --git a/src/main/java/com/gunshi/project/xyt/service/GateValveRealService.java b/src/main/java/com/gunshi/project/xyt/service/GateValveRealService.java index 6ba02f0..e1143a2 100644 --- a/src/main/java/com/gunshi/project/xyt/service/GateValveRealService.java +++ b/src/main/java/com/gunshi/project/xyt/service/GateValveRealService.java @@ -1,11 +1,18 @@ package com.gunshi.project.xyt.service; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.gunshi.project.xyt.entity.vo.GateStautsVo; +import com.gunshi.project.xyt.mapper.GateValveRMapper; import com.gunshi.project.xyt.mapper.GateValveRealMapper; +import com.gunshi.project.xyt.model.GateValveKey; +import com.gunshi.project.xyt.model.GateValveKeyAutoDao; +import com.gunshi.project.xyt.model.GateValveR; import com.gunshi.project.xyt.model.GateValveReal; import com.gunshi.project.xyt.util.DateUtil; +import jakarta.annotation.Resource; import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -23,6 +30,11 @@ import java.util.List; @Transactional(rollbackFor = Exception.class) public class GateValveRealService extends ServiceImpl { + @Resource + private GateValveKeyAutoDao gateValveKeyAutoDao; + + @Resource + private GateValveRMapper gateValveRMapper; public List gateStatusList() { List list = baseMapper.gateStatusList(); @@ -37,6 +49,28 @@ public class GateValveRealService extends ServiceImpl().eq("valve_code",valveCode)); + this.save(real); + return "调节闸阀成功"; + } }