From 758964d9a8c97768318d6e3526db8446b620aafe Mon Sep 17 00:00:00 2001 From: guofeihu <3347277866@qq.com> Date: Wed, 14 Aug 2024 17:33:47 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E8=83=BD=E6=BA=90=E5=9C=BA=E7=AB=99?= =?UTF-8?q?=E5=A2=9E=E5=88=A0=E6=94=B9=E6=9F=A5=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../pq/pojo/param/NewStationQueryParam.java | 70 +++++++++++++++++++ .../njcn/device/pq/pojo/po/NewStation.java | 62 ++++++++++++++++ .../pq/controller/NewStationController.java | 69 ++++++++++++++++++ .../device/pq/mapper/NewStationMapper.java | 22 ++++++ .../pq/mapper/mapping/NewStationMapper.xml | 30 ++++++++ .../device/pq/service/INewStationService.java | 40 +++++++++++ .../service/impl/NewStationServiceImpl.java | 58 +++++++++++++++ 7 files changed, 351 insertions(+) create mode 100644 pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/param/NewStationQueryParam.java create mode 100644 pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/po/NewStation.java create mode 100644 pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/controller/NewStationController.java create mode 100644 pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/NewStationMapper.java create mode 100644 pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/NewStationMapper.xml create mode 100644 pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/INewStationService.java create mode 100644 pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/NewStationServiceImpl.java diff --git a/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/param/NewStationQueryParam.java b/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/param/NewStationQueryParam.java new file mode 100644 index 000000000..a617a9973 --- /dev/null +++ b/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/param/NewStationQueryParam.java @@ -0,0 +1,70 @@ +package com.njcn.device.pq.pojo.param; + +import com.njcn.web.pojo.param.BaseParam; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import javax.validation.constraints.NotBlank; + +/** + *

+ * 新能源场站高低电压穿越表查询类 + *

+ * + * @author guofeihu + * @since 2024-08-14 + */ +@Data +@ApiModel +public class NewStationQueryParam extends BaseParam { + + @ApiModelProperty(name = "id") + private String id; + + @ApiModelProperty(name = "新能源场站名称") + private String name; + + @ApiModelProperty(name = "新能源场站类型") + private String stationType; + + @ApiModelProperty(name = "电压等级Guid") + private String scale; + + @ApiModelProperty(name = "额定有功功率") + private String ratedPower; + + @ApiModelProperty(name = "经度") + private String longitude; + + @ApiModelProperty(name = "维度") + private String latitude; + + @Data + public static class NewStationEdit{ + @ApiModelProperty(name = "id") + private String id; + + @NotBlank(message = "新能源场站名称不能为空") + @ApiModelProperty(name = "新能源场站名称") + private String name; + + @NotBlank(message = "新能源场站类型不能为空") + @ApiModelProperty(name = "新能源场站类型") + private String stationType; + + @ApiModelProperty(name = "电压等级Guid") + private String scale; + + @NotBlank(message = "额定有功功率不能为空") + @ApiModelProperty(name = "额定有功功率") + private String ratedPower; + + @NotBlank(message = "经度不能为空") + @ApiModelProperty(name = "经度") + private String longitude; + + @NotBlank(message = "维度不能为空") + @ApiModelProperty(name = "维度") + private String latitude; + } +} diff --git a/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/po/NewStation.java b/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/po/NewStation.java new file mode 100644 index 000000000..f4e3de098 --- /dev/null +++ b/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/po/NewStation.java @@ -0,0 +1,62 @@ +package com.njcn.device.pq.pojo.po; + +import com.baomidou.mybatisplus.annotation.TableName; +import com.njcn.db.bo.BaseEntity; +import lombok.Getter; +import lombok.Setter; + +/** + *

+ * 新能源场站高低电压穿越表实体类 + *

+ * + * @author guofeihu + * @since 2024-08-14 + */ +@Getter +@Setter +@TableName("pq_new_station") +public class NewStation extends BaseEntity { + + private static final long serialVersionUID = 1L; + + /** + * id + */ + private String id; + + /** + * 新能源场站名称 + */ + private String name; + + /** + * （关联sys_dict_type字典表）新能源场站类型（风电场、光伏电站） + */ + private String stationType; + + /** + * （关联sys_dict_type字典表）电压等级Guid + */ + private String scale; + + /** + * 额定有功功率 + */ + private String ratedPower; + + /** + * 经度 + */ + private String longitude; + + /** + * 维度 + */ + private String latitude; + + /** + * 状态：0-删除 1-正常 + */ + private Integer state; +} diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/controller/NewStationController.java b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/controller/NewStationController.java new file mode 100644 index 000000000..fd26fed9d --- /dev/null +++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/controller/NewStationController.java @@ -0,0 +1,69 @@ +package com.njcn.device.pq.controller; + +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.njcn.common.pojo.annotation.OperateInfo; +import com.njcn.common.pojo.constant.OperateType; +import com.njcn.common.pojo.enums.common.LogEnum; +import com.njcn.common.pojo.enums.response.CommonResponseEnum; +import com.njcn.common.pojo.response.HttpResult; +import com.njcn.common.utils.HttpResultUtil; +import com.njcn.common.utils.LogUtil; +import com.njcn.device.pq.pojo.param.NewStationQueryParam; +import com.njcn.device.pq.pojo.po.NewStation; +import com.njcn.device.pq.service.INewStationService; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.validation.annotation.Validated; +import org.springframework.web.bind.annotation.*; +import com.njcn.web.controller.BaseController; + +/** + *

+ * 新能源场站高低电压穿越表 前端控制器 + *

+ * + * @author guofeihu + * @since 2024-08-14 + */ +@Api(tags = "新能源场站高低电压穿越表管理") +@Slf4j +@RestController +@RequestMapping("/newStation") +@RequiredArgsConstructor +public class NewStationController extends BaseController { + + private final INewStationService iNewStationService; + + @OperateInfo(info = LogEnum.BUSINESS_COMMON, operateType = OperateType.QUERY) + @PostMapping("/queryPage") + @ApiOperation("新能源场站高低电压穿越表分页查询") + public HttpResult> queryPage(@RequestBody @Validated NewStationQueryParam newStationQueryParam){ + String methodDescribe = getMethodDescribe("queryPage"); + Page page = iNewStationService.queryPage(newStationQueryParam); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, page, methodDescribe); + } + + @OperateInfo(info = LogEnum.SYSTEM_COMMON, operateType = OperateType.ADD) + @PostMapping("/editNewStation") + @ApiOperation("新能源场站高低电压穿越信息更新") + public HttpResult editNewStation(@RequestBody @Validated NewStationQueryParam.NewStationEdit newStationEdit) { + String methodDescribe = getMethodDescribe("editNewStation"); + LogUtil.njcnDebug(log, "{}，更新对象为：{}", methodDescribe, newStationEdit); + iNewStationService.editNewStation(newStationEdit); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); + } + + @OperateInfo(info = LogEnum.SYSTEM_COMMON, operateType = OperateType.DELETE) + @DeleteMapping("/delNewStation") + @ApiOperation("新能源场站高低电压穿越信息删除") + public HttpResult delNewStation(@RequestParam(name = "ids") String ids) { + String methodDescribe = getMethodDescribe("delNewStation"); + LogUtil.njcnDebug(log, "{}，删除的Id的集合为：{}", methodDescribe, ids); + iNewStationService.delNewStation(ids); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); + } + +} + diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/NewStationMapper.java b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/NewStationMapper.java new file mode 100644 index 000000000..c93ef8777 --- /dev/null +++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/NewStationMapper.java @@ -0,0 +1,22 @@ +package com.njcn.device.pq.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.njcn.device.pq.pojo.param.NewStationQueryParam; +import com.njcn.device.pq.pojo.po.NewStation; +import org.apache.ibatis.annotations.Param; + +/** + *

+ * 新能源场站高低电压穿越表 Mapper 接口 + *

+ * + * @author guofeihu + * @since 2024-08-14 + */ +public interface NewStationMapper extends BaseMapper { + + Page queryPage(IPage page, @Param("newStationQueryParam") NewStationQueryParam newStationQueryParam); + +} diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/NewStationMapper.xml b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/NewStationMapper.xml new file mode 100644 index 000000000..5d03c68f3 --- /dev/null +++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/NewStationMapper.xml @@ -0,0 +1,30 @@ + + + + + + + + + + + + + + + + + + diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/INewStationService.java b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/INewStationService.java new file mode 100644 index 000000000..bee410584 --- /dev/null +++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/INewStationService.java @@ -0,0 +1,40 @@ +package com.njcn.device.pq.service; + +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.baomidou.mybatisplus.extension.service.IService; +import com.njcn.device.pq.pojo.param.NewStationQueryParam; +import com.njcn.device.pq.pojo.po.NewStation; + +/** + *

+ * 新能源场站高低电压穿越表 服务类 + *

+ * + * @author guofeihu + * @since 2024-08-14 + */ +public interface INewStationService extends IService { + + /** + * 新能源场站高低电压穿越表分页查询 + * @param newStationQueryParam + * @return + */ + Page queryPage(NewStationQueryParam newStationQueryParam); + + /*** + * 新能源场站高低电压穿越表更新 + * @param newStationEdit + * @return Boolean + */ + Boolean editNewStation(NewStationQueryParam.NewStationEdit newStationEdit) ; + + /*** + * 新能源场站高低电压穿越表删除 + * @author wr + * @param ids + * @return Boolean + */ + Boolean delNewStation(String ids); + +} diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/NewStationServiceImpl.java b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/NewStationServiceImpl.java new file mode 100644 index 000000000..52a540326 --- /dev/null +++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/NewStationServiceImpl.java @@ -0,0 +1,58 @@ +package com.njcn.device.pq.service.impl; + +import cn.hutool.core.bean.BeanUtil; +import cn.hutool.core.util.IdUtil; +import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.njcn.device.pq.mapper.NewStationMapper; +import com.njcn.device.pq.pojo.param.NewStationQueryParam; +import com.njcn.device.pq.pojo.po.NewStation; +import com.njcn.device.pq.service.INewStationService; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Service; +import java.util.Arrays; + +/** + *

+ * 新能源场站高低电压穿越表 服务实现类 + *

+ * + * @author guofeihu + * @since 2024-08-14 + */ +@Service +@RequiredArgsConstructor +public class NewStationServiceImpl extends ServiceImpl implements INewStationService { + + @Override + public Page queryPage(NewStationQueryParam newStationQueryParam) { + Page returnpage = new Page<> (newStationQueryParam.getPageNum(),newStationQueryParam.getPageSize()); + returnpage = this.getBaseMapper().queryPage(returnpage,newStationQueryParam); + return returnpage; + } + + @Override + public Boolean editNewStation(NewStationQueryParam.NewStationEdit newStationEdit) { + NewStation newStation = new NewStation(); + BeanUtil.copyProperties(newStationEdit, newStation); + newStation.setState(1); + boolean result ; + if(newStation.getId() != null){ + result = this.updateById(newStation); + }else{ + newStation.setId(IdUtil.simpleUUID()); + result = this.save(newStation); + } + return result; + } + + @Override + public Boolean delNewStation(String ids) { + LambdaUpdateWrapper lambdaUpdateWrapper = new LambdaUpdateWrapper<>(); + lambdaUpdateWrapper.set(NewStation::getState,0) + .in(NewStation::getId, Arrays.asList(ids.split(","))); + boolean update = this.update(lambdaUpdateWrapper); + return update; + } +}