diff --git a/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/param/PmsTerminalLogParam.java b/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/param/PmsTerminalLogParam.java new file mode 100644 index 000000000..88a3c15a8 --- /dev/null +++ b/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/param/PmsTerminalLogParam.java @@ -0,0 +1,25 @@ +package com.njcn.device.pms.pojo.param; + +import com.njcn.web.pojo.param.BaseParam; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; + +/** + * pqs + * + * @author cdf + * @date 2023/2/27 + */ +@Data +@EqualsAndHashCode(callSuper = true) +public class PmsTerminalLogParam extends BaseParam { + + @ApiModelProperty(name = "type",value = "0.电站 1.装置 2.线路 3.台区 4.发电用户 5.用电用户 6.主网监测点 7.配网监测点") + private Integer type; + + @ApiModelProperty(name = "createBy",value = "操作用户") + private String createBy; + + +} diff --git a/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/po/Monitor.java b/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/po/Monitor.java index 9a297b5be..87731dee6 100644 --- a/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/po/Monitor.java +++ b/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/po/Monitor.java @@ -60,15 +60,6 @@ public class Monitor extends BaseEntity { */ private String powerrId; - /** - * 母线名称 - */ - private String generatrixWireName; - - /** - * 母线ID(外键) - */ - private String generatrixId; /** * 监测线路名称 diff --git a/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/po/TerminalLog.java b/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/po/TerminalLog.java index a4fa41e03..21deeda7f 100644 --- a/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/po/TerminalLog.java +++ b/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/po/TerminalLog.java @@ -6,6 +6,7 @@ import com.njcn.db.bo.BaseEntity; import java.io.Serializable; import java.time.LocalDateTime; +import io.swagger.annotations.ApiModelProperty; import lombok.Data; import lombok.Getter; import lombok.Setter; @@ -30,6 +31,7 @@ public class TerminalLog extends BaseEntity implements Serializable,Cloneable { /** * 0.电站 1.装置 2.台区 3.线路 4.监测点 */ + @ApiModelProperty(name = "type",value = "0.电站 1.装置 2.线路 3.台区 4.发电用户 5.用电用户 6.主网监测点 7.配网监测点") private Integer type; /** @@ -45,11 +47,13 @@ public class TerminalLog extends BaseEntity implements Serializable,Cloneable { /** * 操作描述 */ + @ApiModelProperty(name = "operatorDescribe",value = "操作描述") private String operatorDescribe; /** * 操作结果 0.失败 1.成功 */ + @ApiModelProperty(name = "results",value = "0.失败 1.成功") private Integer results; /** diff --git a/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/vo/PowerGenerationUserVO.java b/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/vo/PowerGenerationUserVO.java new file mode 100644 index 000000000..5e812e6b0 --- /dev/null +++ b/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/vo/PowerGenerationUserVO.java @@ -0,0 +1,126 @@ +package com.njcn.device.pms.pojo.vo; + +import com.njcn.db.bo.BaseEntity; +import lombok.Data; +import lombok.EqualsAndHashCode; + +import java.time.LocalDate; + +/** + * pqs + * + * @author cdf + * @date 2023/2/27 + */ +@Data +@EqualsAndHashCode(callSuper = true) +public class PowerGenerationUserVO extends BaseEntity { + + private static final long serialVersionUID = 1L; + + /** + * 用户编号 + */ + private String id; + + /** + * 用户名称 + */ + private String name; + + /** + * 组织机构名称 + */ + private String orgName; + + /** + * 组织机构ID(外键) + */ + private String orgId; + + /** + * 运维单位名称 + */ + private String operationName; + + /** + * 运维单位ID(外键) + */ + private String operationId; + + /** + * 电源类别(字典) + */ + private String powerCategory; + + /** + * 电站类型(字典) + */ + private String powerStationType; + + /** + * 发电方式(字典) + */ + private String powerGenerationMode; + + /** + * 并网电压等级(字典) + */ + private String voltageLevel; + + /** + * 总装机容量 + */ + private Float sourceCapacity; + + /** + * 并网日期 + */ + private LocalDate connectionDate; + + /** + * 能源消纳方式(字典) + */ + private String connectionMode; + + /** + * 客户状态(字典) + */ + private String gcStat; + + /** + * 供电变电站(外键) + */ + private String powerStationId; + + /** + * 供电线路(外键) + */ + private String lineId; + + /** + * 供电台区(外键) + */ + private String platformId; + + /** + * 供电台区名称 + */ + private String platformName; + + /** + * 用户标签 + */ + private String userTag; + + /** + * 是否是上送国网监测点,0-否 1-是 + */ + private Integer isUpToGrid; + + /** + * 数据状态:0-删除;1-正常; + */ + private Integer status; + +} diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/controller/ledgerManger/PmsPowerGenerationUserController.java b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/controller/ledgerManger/PmsPowerGenerationUserController.java index d9f90049f..ab9b567e9 100644 --- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/controller/ledgerManger/PmsPowerGenerationUserController.java +++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/controller/ledgerManger/PmsPowerGenerationUserController.java @@ -13,6 +13,7 @@ import com.njcn.device.pms.pojo.param.PowerDistributionareaParam; import com.njcn.device.pms.pojo.param.PowerGenerationUserParam; import com.njcn.device.pms.pojo.param.PowerUserParam; import com.njcn.device.pms.pojo.po.PowerGenerationUser; +import com.njcn.device.pms.pojo.vo.PowerGenerationUserVO; import com.njcn.device.pms.service.majornetwork.IPowerGenerationUserService; import com.njcn.web.pojo.param.BaseParam; import io.swagger.annotations.Api; @@ -106,9 +107,9 @@ public class PmsPowerGenerationUserController extends BaseController { @OperateInfo(info = LogEnum.BUSINESS_COMMON) @PostMapping("/getPowerGenerationUserList") @ApiOperation("获取发电用户列表") - public HttpResult> getPowerGenerationUserList(@RequestBody PowerDistributionareaParam powerDistributionareaParam) { + public HttpResult> getPowerGenerationUserList(@RequestBody PowerDistributionareaParam powerDistributionareaParam) { String methodDescribe = getMethodDescribe("getPowerGenerationUserList"); - List result = iPowerGenerationUserService.getPowerGenerationUserList(powerDistributionareaParam); + List result = iPowerGenerationUserService.getPowerGenerationUserList(powerDistributionareaParam); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, result, methodDescribe); } diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/controller/ledgerManger/TerminalLogController.java b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/controller/ledgerManger/TerminalLogController.java index d4df50f27..091612cad 100644 --- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/controller/ledgerManger/TerminalLogController.java +++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/controller/ledgerManger/TerminalLogController.java @@ -1,9 +1,24 @@ package com.njcn.device.pms.controller.ledgerManger; -import org.springframework.web.bind.annotation.RequestMapping; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.njcn.common.pojo.annotation.OperateInfo; +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.device.pms.pojo.param.PmsTerminalLogParam; +import com.njcn.device.pms.pojo.param.PmsTerminalParam; +import com.njcn.device.pms.pojo.po.GeneratrixWire; +import com.njcn.device.pms.pojo.po.TerminalLog; +import com.njcn.device.pms.service.majornetwork.ITerminalLogService; +import com.njcn.web.pojo.param.BaseParam; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiImplicitParam; +import io.swagger.annotations.ApiOperation; +import lombok.RequiredArgsConstructor; +import org.springframework.web.bind.annotation.*; -import org.springframework.web.bind.annotation.RestController; import com.njcn.web.controller.BaseController; /** @@ -16,7 +31,27 @@ import com.njcn.web.controller.BaseController; */ @RestController @RequestMapping("/pms/terminalLog") +@RequiredArgsConstructor +@Api(tags = "台账-终端操作日志") public class TerminalLogController extends BaseController { + private final ITerminalLogService iTerminalLogService; + + + /** + * 查询所有日志 + * @author cdf + * @date 2023/2/27 + */ + @OperateInfo(info = LogEnum.BUSINESS_COMMON) + @PostMapping("/page") + @ApiOperation("分页查询所有日志") + @ApiImplicitParam(name = "pmsTerminalLogParam", value = "基本查询体", required = true) + public HttpResult> page(@RequestBody PmsTerminalLogParam pmsTerminalLogParam) { + String methodDescribe = getMethodDescribe("page"); + Page result = iTerminalLogService.page(pmsTerminalLogParam); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, result, methodDescribe); + } + } diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/PowerGenerationUserMapper.java b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/PowerGenerationUserMapper.java index 4eff14a14..10ac8fca0 100644 --- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/PowerGenerationUserMapper.java +++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/PowerGenerationUserMapper.java @@ -2,6 +2,11 @@ package com.njcn.device.pms.mapper.majornetwork; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.njcn.device.pms.pojo.po.PowerGenerationUser; +import com.njcn.device.pms.pojo.vo.PowerClientVO; +import com.njcn.device.pms.pojo.vo.PowerGenerationUserVO; +import org.apache.ibatis.annotations.Param; + +import java.util.List; /** *

@@ -13,4 +18,7 @@ import com.njcn.device.pms.pojo.po.PowerGenerationUser; */ public interface PowerGenerationUserMapper extends BaseMapper { + + List getPowerGenerationUserSelect(@Param("orgIds") List orgIds); + } diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/TerminalLogMapper.java b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/TerminalLogMapper.java index 7f7ca9c65..67ec74981 100644 --- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/TerminalLogMapper.java +++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/TerminalLogMapper.java @@ -2,7 +2,10 @@ package com.njcn.device.pms.mapper.majornetwork; import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.njcn.device.pms.pojo.param.PmsTerminalLogParam; import com.njcn.device.pms.pojo.po.TerminalLog; +import org.apache.ibatis.annotations.Param; /** *

@@ -14,4 +17,6 @@ import com.njcn.device.pms.pojo.po.TerminalLog; */ public interface TerminalLogMapper extends BaseMapper { + Page pageList(Page page,@Param("pmsTerminalLogParam") PmsTerminalLogParam pmsTerminalLogParam); + } diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/mapping/PmsTerminalLogMapper.xml b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/mapping/PmsTerminalLogMapper.xml new file mode 100644 index 000000000..71c3974c0 --- /dev/null +++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/mapping/PmsTerminalLogMapper.xml @@ -0,0 +1,28 @@ + + + + + + + + diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/mapping/PowerGenerationUserMapper.xml b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/mapping/PowerGenerationUserMapper.xml index 53e838720..7e25558a2 100644 --- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/mapping/PowerGenerationUserMapper.xml +++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/mapping/PowerGenerationUserMapper.xml @@ -2,4 +2,27 @@ + + + diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/IPowerGenerationUserService.java b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/IPowerGenerationUserService.java index 26d3b1447..6dc6f5cfc 100644 --- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/IPowerGenerationUserService.java +++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/IPowerGenerationUserService.java @@ -6,6 +6,7 @@ import com.njcn.device.pms.pojo.param.PowerDistributionareaParam; import com.njcn.device.pms.pojo.param.PowerGenerationUserParam; import com.njcn.device.pms.pojo.param.PowerUserParam; import com.njcn.device.pms.pojo.po.PowerGenerationUser; +import com.njcn.device.pms.pojo.vo.PowerGenerationUserVO; import com.njcn.web.pojo.param.BaseParam; import java.util.List; @@ -62,7 +63,7 @@ public interface IPowerGenerationUserService extends IService getPowerGenerationUserList(PowerDistributionareaParam powerDistributionareaParam); + List getPowerGenerationUserList(PowerDistributionareaParam powerDistributionareaParam); /** * 分页查询发电用户列表 diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/ITerminalLogService.java b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/ITerminalLogService.java index 7487bec46..649f06386 100644 --- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/ITerminalLogService.java +++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/ITerminalLogService.java @@ -1,7 +1,9 @@ package com.njcn.device.pms.service.majornetwork; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.IService; +import com.njcn.device.pms.pojo.param.PmsTerminalLogParam; import com.njcn.device.pms.pojo.po.TerminalLog; /** @@ -14,4 +16,11 @@ import com.njcn.device.pms.pojo.po.TerminalLog; */ public interface ITerminalLogService extends IService { + /** + * 分页查询日志 + * @author cdf + * @date 2023/2/27 + */ + Page page(PmsTerminalLogParam pmsTerminalLogParam); + } diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/MonitorServiceImpl.java b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/MonitorServiceImpl.java index 18e8d1b2d..fe1640194 100644 --- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/MonitorServiceImpl.java +++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/MonitorServiceImpl.java @@ -356,11 +356,6 @@ public class MonitorServiceImpl extends ServiceImpl impl throw new BusinessException(PmsDeviceResponseEnum.VOLTAGE_EMPTY); } - - monitor.setOperationName(dept.getName()); - monitor.setOperationName(deptOp.getName()); - monitor.setGeneratrixWireName(generatrix.getName()); - } diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/PowerGenerationUserServiceImpl.java b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/PowerGenerationUserServiceImpl.java index 289f41504..76e81697d 100644 --- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/PowerGenerationUserServiceImpl.java +++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/PowerGenerationUserServiceImpl.java @@ -13,6 +13,7 @@ import com.njcn.device.pms.pojo.param.PowerGenerationUserParam; import com.njcn.device.pms.pojo.param.PowerUserParam; import com.njcn.device.pms.pojo.po.PowerClient; import com.njcn.device.pms.pojo.po.PowerGenerationUser; +import com.njcn.device.pms.pojo.vo.PowerGenerationUserVO; import com.njcn.device.pms.service.majornetwork.IPowerGenerationUserService; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.njcn.user.api.DeptFeignClient; @@ -23,6 +24,7 @@ import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; import java.time.LocalDate; +import java.util.ArrayList; import java.util.List; import java.util.Objects; @@ -79,15 +81,13 @@ public class PowerGenerationUserServiceImpl extends ServiceImpl getPowerGenerationUserList(PowerDistributionareaParam powerDistributionareaParam) { + public List getPowerGenerationUserList(PowerDistributionareaParam powerDistributionareaParam) { LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); + List deptIds =new ArrayList<>(); if(StrUtil.isNotBlank(powerDistributionareaParam.getOrgId())){ - List deptIds = deptFeignClient.getDepSonSelfCodetByDeptId(powerDistributionareaParam.getOrgId()).getData(); - lambdaQueryWrapper.in(PowerGenerationUser::getOrgId,deptIds).eq(PowerGenerationUser::getStatus,DataStateEnum.ENABLE.getCode()); + deptIds = deptFeignClient.getDepSonSelfCodetByDeptId(powerDistributionareaParam.getOrgId()).getData(); } - lambdaQueryWrapper.select(PowerGenerationUser::getName,PowerGenerationUser::getId,PowerGenerationUser::getOrgId,PowerGenerationUser::getOrgName); - lambdaQueryWrapper.orderByDesc(PowerGenerationUser::getCreateTime).eq(PowerGenerationUser::getStatus, DataStateEnum.ENABLE.getCode()); - return this.list(lambdaQueryWrapper); + return this.baseMapper.getPowerGenerationUserSelect(deptIds); } @Override diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/TerminalLogServiceImpl.java b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/TerminalLogServiceImpl.java index 698f556c8..913ec473a 100644 --- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/TerminalLogServiceImpl.java +++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/TerminalLogServiceImpl.java @@ -1,11 +1,19 @@ package com.njcn.device.pms.service.majornetwork.impl; +import cn.hutool.core.util.StrUtil; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.njcn.common.pojo.enums.common.DataStateEnum; import com.njcn.device.pms.mapper.majornetwork.TerminalLogMapper; +import com.njcn.device.pms.pojo.param.PmsTerminalLogParam; import com.njcn.device.pms.pojo.po.TerminalLog; import com.njcn.device.pms.service.majornetwork.ITerminalLogService; +import com.njcn.web.factory.PageFactory; import org.springframework.stereotype.Service; +import java.util.Objects; + /** *

* 服务实现类 @@ -17,4 +25,8 @@ import org.springframework.stereotype.Service; @Service public class TerminalLogServiceImpl extends ServiceImpl implements ITerminalLogService { + @Override + public Page page(PmsTerminalLogParam pmsTerminalLogParam) { + return this.baseMapper.pageList(new Page<>(PageFactory.getPageNum(pmsTerminalLogParam),PageFactory.getPageSize(pmsTerminalLogParam)),pmsTerminalLogParam); + } }