Microservice/pqs
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

Merge remote-tracking branch 'origin/master'

Browse Source
This commit is contained in:
Lee
2023-03-16 14:24:24 +08:00
parent 559e44a32e b13e8b3049
commit 0c72f17af7
292 changed files with 26 additions and 18406 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
pom.xml
View File

@@ -19,7 +19,6 @@
<module>pqs-event</module> <module>pqs-event</module>
<module>pqs-job</module> <module>pqs-job</module>
<module>pqs-job/job-api</module> <module>pqs-job/job-api</module>
<module>pqs-quality</module>
<module>pqs-advance</module> <module>pqs-advance</module>
<module>pqs-prepare</module> <module>pqs-prepare</module>
<module>pqs-process</module> <module>pqs-process</module>
@@ -43,23 +42,17 @@
</distributionManagement> </distributionManagement>
<properties> <properties>
<!--中间件目标地址--> <!--中间件目标地址-->
<!-- <middle.server.url>198.120.100.195</middle.server.url>-->
<middle.server.url>192.168.1.13</middle.server.url> <middle.server.url>192.168.1.13</middle.server.url>
<!--微服务模块发布地址--> <!--微服务模块发布地址-->
<!-- <service.server.url>198.120.100.195</service.server.url>--> <service.server.url>192.168.1.139</service.server.url>
<service.server.url>192.168.1.111</service.server.url>
<!--docker仓库地址--> <!--docker仓库地址-->
<docker.server.url>192.168.1.13</docker.server.url> <docker.server.url>192.168.1.31</docker.server.url>
<!--nacos的ip:port--> <!--nacos的ip:port-->
<nacos.url>${middle.server.url}:18848</nacos.url> <nacos.url>${middle.server.url}:18848</nacos.url>
<!--服务器发布内容为空--> <!--服务器发布内容为空-->
<!-- <nacos.namespace></nacos.namespace>--> <!-- <nacos.namespace></nacos.namespace>-->
<nacos.namespace>fd74182b-1fce-4dba-afa7-2623b0376205</nacos.namespace> <nacos.namespace>415a1c87-33aa-47bd-8e25-13cc456c87ed</nacos.namespace>
<!-- <nacos.namespace>ba3ba5d1-3480-4755-8b87-6b1fce16201c</nacos.namespace>-->
<!-- <nacos.namespace>f6df4a49-39cb-4355-a8fd-8aeb0c537eb1</nacos.namespace>-->
<!-- <nacos.namespace>02bcd264-c473-4bc1-b225-5fc4b937e32e</nacos.namespace>-->
<!--sentinel:port--> <!--sentinel:port-->
<!-- <sentinel.url>192.168.1.14:8080</sentinel.url>-->
<sentinel.url>${middle.server.url}:8080</sentinel.url> <sentinel.url>${middle.server.url}:8080</sentinel.url>
<!--网关地址，主要用于配置swagger中认证token--> <!--网关地址，主要用于配置swagger中认证token-->
<gateway.url>${service.server.url}:10215</gateway.url> <gateway.url>${service.server.url}:10215</gateway.url>
@@ -88,6 +81,7 @@
<mybatis.version>2.1.3</mybatis.version> <mybatis.version>2.1.3</mybatis.version>
<druid.version>1.2.5</druid.version> <druid.version>1.2.5</druid.version>
<mysql.version>8.0.19</mysql.version> <mysql.version>8.0.19</mysql.version>
<mariadb.version>2.4.0</mariadb.version>
<oracle.version>21.6.0.0</oracle.version> <oracle.version>21.6.0.0</oracle.version>
<orai18n.version>21.1.0.0</orai18n.version> <orai18n.version>21.1.0.0</orai18n.version>
<mybatis-plus.version>3.4.2</mybatis-plus.version> <mybatis-plus.version>3.4.2</mybatis-plus.version>
@@ -112,8 +106,10 @@
<xxl-job.version>2.3.0</xxl-job.version> <xxl-job.version>2.3.0</xxl-job.version>
<mqtt.version>1.2.7</mqtt.version> <mqtt.version>1.2.7</mqtt.version>
<easypoi.version>4.4.0</easypoi.version> <easypoi.version>4.4.0</easypoi.version>
<spring-cloud-huawei.version>1.7.0-Hoxton</spring-cloud-huawei.version> <progressbar.version>0.5.3</progressbar.version>
<okhttp.version>4.8.1</okhttp.version> <okhttp.version>4.8.1</okhttp.version>
<minio.version>8.2.1</minio.version>
<spring-cloud-huawei.version>1.7.0-Hoxton</spring-cloud-huawei.version>
</properties> </properties>
<dependencyManagement> <dependencyManagement>
<dependencies> <dependencies>
@@ -340,11 +336,28 @@
<artifactId>easypoi-spring-boot-starter</artifactId> <artifactId>easypoi-spring-boot-starter</artifactId>
<version>${easypoi.version}</version> <version>${easypoi.version}</version>
</dependency> </dependency>
<!--调用minio服务器-->
<dependency>
<groupId>me.tongfei</groupId>
<artifactId>progressbar</artifactId>
<version>${progressbar.version}</version>
</dependency>
<dependency> <dependency>
<groupId>com.squareup.okhttp3</groupId> <groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp</artifactId> <artifactId>okhttp</artifactId>
<version>${okhttp.version}</version> <version>${okhttp.version}</version>
</dependency> </dependency>
<dependency>
<groupId>io.minio</groupId>
<artifactId>minio</artifactId>
<version>${minio.version}</version>
<exclusions>
<exclusion>
<groupId>com.squareup.okhttp3</groupId>
<artifactId>okhttp</artifactId>
</exclusion>
</exclusions>
</dependency>
<!-- 多数据源切换，当数据源为oracle时需要使用 --> <!-- 多数据源切换，当数据源为oracle时需要使用 -->
<dependency> <dependency>
<groupId>com.baomidou</groupId> <groupId>com.baomidou</groupId>

4
pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/TransientServiceImpl.java
View File

@@ -197,8 +197,8 @@ public class TransientServiceImpl implements TransientService {
cfgPath = OssPath.WAVE_DIR + ip + StrUtil.SLASH + waveName + GeneralConstant.CFG; cfgPath = OssPath.WAVE_DIR + ip + StrUtil.SLASH + waveName + GeneralConstant.CFG;
datPath = OssPath.WAVE_DIR + ip + StrUtil.SLASH + waveName + GeneralConstant.DAT; datPath = OssPath.WAVE_DIR + ip + StrUtil.SLASH + waveName + GeneralConstant.DAT;
try ( try (
InputStream cfgStream = obsUtil.fileDownload(cfgPath); InputStream cfgStream = obsUtil.downloadStream(cfgPath);
InputStream datStream = obsUtil.fileDownload(datPath) InputStream datStream = obsUtil.downloadStream(datPath)
) { ) {
if (Objects.isNull(cfgStream) || Objects.isNull(datStream)) { if (Objects.isNull(cfgStream) || Objects.isNull(datStream)) {
throw new BusinessException(EventResponseEnum.ANALYSEWAVE_NOT_FOUND); throw new BusinessException(EventResponseEnum.ANALYSEWAVE_NOT_FOUND);

26
pqs-quality/pom.xml
View File

@@ -1,26 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>pqs</artifactId>
<groupId>com.njcn</groupId>
<version>1.0.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>pqs-quality</artifactId>
<packaging>pom</packaging>
<name>电能质量模块</name>
<modules>
<module>quality-api</module>
<module>quality-boot</module>
</modules>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
</properties>
</project>

49
pqs-quality/quality-api/pom.xml
View File

@@ -1,49 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>pqs-quality</artifactId>
<groupId>com.njcn</groupId>
<version>1.0.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>quality-api</artifactId>
<name>电能质量模块对外接口</name>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
</properties>
<dependencies>
<dependency>
<groupId>com.njcn</groupId>
<artifactId>common-core</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>com.njcn</groupId>
<artifactId>common-db</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>com.njcn</groupId>
<artifactId>${micro.sdk}</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>com.njcn</groupId>
<artifactId>common-poi</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.influxdb</groupId>
<artifactId>influxdb-java</artifactId>
</dependency>
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
</dependency>
</dependencies>
</project>

27
pqs-quality/quality-api/src/main/java/com/njcn/quality/api/EleAirStrategyFeignClient.java
View File

@@ -1,27 +0,0 @@
package com.njcn.quality.api;
import com.njcn.common.pojo.constant.ServerInfo;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.quality.api.fallback.EleOnlineRateFallbackFactory;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
/**
* pqs
*
* @author cdf
* @date 2022/4/22
*/
@FeignClient(value = ServerInfo.ENERGY,path = "/air",fallbackFactory = EleOnlineRateFallbackFactory.class)
public interface EleAirStrategyFeignClient {
/**
* 获取策略下的监测点
* @author cdf
* @date 2022/4/22
*/
@GetMapping("dealAirStrategyId")
HttpResult<Boolean> dealAirStrategyId(@RequestParam("id") String id,@RequestParam("operation") String operation);
}

27
pqs-quality/quality-api/src/main/java/com/njcn/quality/api/EleIntegrityFeignClient.java
View File

@@ -1,27 +0,0 @@
package com.njcn.quality.api;
import com.njcn.common.pojo.constant.ServerInfo;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.quality.api.fallback.EleIntegrityFallbackFactory;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PostMapping;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/4/20 15:08
*/
@FeignClient(value = ServerInfo.ENERGY,path = "/integrity",fallbackFactory = EleIntegrityFallbackFactory.class)
public interface EleIntegrityFeignClient {
@PostMapping("/getPowerLineId")
HttpResult<List<String>> getPowerLineId();
@PostMapping("/getAirLineId")
HttpResult<List<String>> getAirLineId();
}

26
pqs-quality/quality-api/src/main/java/com/njcn/quality/api/EleOnlineRateFeignClient.java
View File

@@ -1,26 +0,0 @@
package com.njcn.quality.api;
import com.njcn.common.pojo.constant.ServerInfo;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.quality.api.fallback.EleOnlineRateFallbackFactory;
import com.njcn.quality.pojo.dto.OnlineRateDTO;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/4/20 15:08
*/
@FeignClient(value = ServerInfo.ENERGY,path = "/onlineRate",fallbackFactory = EleOnlineRateFallbackFactory.class)
public interface EleOnlineRateFeignClient {
@PostMapping("/getDeviceTime")
HttpResult<List<OnlineRateDTO>> getDeviceTime(@RequestParam("startTime") String startTime, @RequestParam("endTime") String endTime);
}

41
pqs-quality/quality-api/src/main/java/com/njcn/quality/api/fallback/EleAirStrategyFallbackFactory.java
View File

@@ -1,41 +0,0 @@
package com.njcn.quality.api.fallback;
import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.exception.BusinessException;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.quality.api.EleAirStrategyFeignClient;
import com.njcn.quality.utils.EnergyEnumUtil;
import feign.hystrix.FallbackFactory;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/4/20 15:09
*/
@Slf4j
@Component
public class EleAirStrategyFallbackFactory implements FallbackFactory<EleAirStrategyFeignClient> {
@Override
public EleAirStrategyFeignClient create(Throwable cause) {
//判断抛出异常是否为解码器抛出的业务异常
Enum<?> exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK;
if(cause.getCause() instanceof BusinessException){
BusinessException businessException = (BusinessException) cause.getCause();
exceptionEnum = EnergyEnumUtil.getExceptionEnum(businessException.getResult());
}
Enum<?> finalExceptionEnum = exceptionEnum;
return new EleAirStrategyFeignClient() {
@Override
public HttpResult<Boolean> dealAirStrategyId(String id,String operation) {
log.error("{}异常，降级处理，异常为：{}","空调控制策略数据",cause.toString());
throw new BusinessException(finalExceptionEnum);
}
};
}
}

48
pqs-quality/quality-api/src/main/java/com/njcn/quality/api/fallback/EleIntegrityFallbackFactory.java
View File

@@ -1,48 +0,0 @@
package com.njcn.quality.api.fallback;
import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.exception.BusinessException;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.quality.api.EleIntegrityFeignClient;
import com.njcn.quality.utils.EnergyEnumUtil;
import feign.hystrix.FallbackFactory;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/4/20 15:09
*/
@Slf4j
@Component
public class EleIntegrityFallbackFactory implements FallbackFactory<EleIntegrityFeignClient> {
@Override
public EleIntegrityFeignClient create(Throwable cause) {
//判断抛出异常是否为解码器抛出的业务异常
Enum<?> exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK;
if(cause.getCause() instanceof BusinessException){
BusinessException businessException = (BusinessException) cause.getCause();
exceptionEnum = EnergyEnumUtil.getExceptionEnum(businessException.getResult());
}
Enum<?> finalExceptionEnum = exceptionEnum;
return new EleIntegrityFeignClient() {
@Override
public HttpResult<List<String>> getPowerLineId() {
log.error("{}异常，降级处理，异常为：{}","获取在线用采监测点",cause.toString());
throw new BusinessException(finalExceptionEnum);
}
@Override
public HttpResult<List<String>> getAirLineId() {
log.error("{}异常，降级处理，异常为：{}","获取在线空调监测点",cause.toString());
throw new BusinessException(finalExceptionEnum);
}
};
}
}

44
pqs-quality/quality-api/src/main/java/com/njcn/quality/api/fallback/EleOnlineRateFallbackFactory.java
View File

@@ -1,44 +0,0 @@
package com.njcn.quality.api.fallback;
import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.exception.BusinessException;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.quality.api.EleOnlineRateFeignClient;
import com.njcn.quality.pojo.dto.OnlineRateDTO;
import com.njcn.quality.utils.EnergyEnumUtil;
import feign.hystrix.FallbackFactory;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/4/20 15:09
*/
@Slf4j
@Component
public class EleOnlineRateFallbackFactory implements FallbackFactory<EleOnlineRateFeignClient> {
@Override
public EleOnlineRateFeignClient create(Throwable cause) {
//判断抛出异常是否为解码器抛出的业务异常
Enum<?> exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK;
if(cause.getCause() instanceof BusinessException){
BusinessException businessException = (BusinessException) cause.getCause();
exceptionEnum = EnergyEnumUtil.getExceptionEnum(businessException.getResult());
}
Enum<?> finalExceptionEnum = exceptionEnum;
return new EleOnlineRateFeignClient() {
@Override
public HttpResult<List<OnlineRateDTO>> getDeviceTime(String startTime, String endTime) {
log.error("{}异常，降级处理，异常为：{}","装置在线率数据",cause.toString());
throw new BusinessException(finalExceptionEnum);
}
};
}
}

26
pqs-quality/quality-api/src/main/java/com/njcn/quality/enums/EleStatisticalSetEnum.java
View File

@@ -1,26 +0,0 @@
package com.njcn.quality.enums;
import lombok.Getter;
/**
* 用能费率配置
* @author denghuajun
* @version 1.0.0
* @date 2022年04月14日 15:04
*/
@Getter
public enum EleStatisticalSetEnum {
/**
* 枚举配置
*/
LOAD_STATISTICS("负荷统计"),
ELETRIC_DEGREE("电度统计");
private final String name;
EleStatisticalSetEnum(String name) {
this.name = name;
}
}

82
pqs-quality/quality-api/src/main/java/com/njcn/quality/enums/EnergyResponseEnum.java
View File

@@ -1,82 +0,0 @@
package com.njcn.quality.enums;
import lombok.Getter;
/**
* @author cdf
* @version 1.0.0
* @date 2022年02月23日 09:56
*/
@Getter
public enum EnergyResponseEnum {
/**
* 用能模块异常响应码的范围：
* A00450 ~ A00549
*/
ENERGY_COMMON_ERROR("A00450","用能模块异常"),
NET_DEV_NAME_REPEAT("A00451", "网关设备名称重复"),
DEV_VERSION_REPEAT("A00451", "设备版本信息重复"),
/**
* 用能模板交互应答code
*/
SUCCESS("200","success"),
PROCESSING("202","请求处理中"),
AUTO_OFFLINE("300","设备有异常，主动下线"),
FAIL("400","请求失败"),
PARAM_FAIL_TIMESTAMP("400","请求失败,时间戳不能为空,请检查timestamp字段"),
PARAM_ERROR_TIMESTAMP("400","请求失败,时间戳格式错误,请检查timestamp字段"),
PARAM_FAIL_TYPE("400","请求失败,消息类型不能为空,请检查type字段"),
TYPE_ERROR("400","请求失败,接口名称不匹配,请检查type字段"),
REGISTER_ERROR("400","注册失败,注册的联网设备不存在,请先平台录入"),
REPEAT_ERROR("400","注册失败,有重复装置注册"),
EXIST_ERROR("400","注册失败,存在已注册的装置"),
CANCEL_ERROR("400","取消注册失败,存在未注册或者接入的装置，无法取消注册"),
NO_MODEL_FIND("402","接入失败,模板未找到"),
MODEL_UPGRADE("402","接入失败,模板版本需升级"),
MISSING_MODEL("402","接入失败,模板数据缺失"),
MISSING_TOPIC("402","接入失败,缺少网关主题相关信息"),
NO_DID_FIND("400","接入失败,需要接入的装置未找到"),
MODULE_MATCH_ERROR("400","接入失败,接入的装置和模板数量不匹配"),
SAME_DEV_ERROR("400","模板数据错误,存在重复的装置信息"),
MODEL_ERROR("400","模板数据错误,模板未找到"),
NET_DEV_MODEL_ERROR("400","网关模板解析错误，平台未找到此网关"),
LINE_REPEAT_ERROR("400","网关模板解析错误，库中存在相同的监测点id"),
CERTIFICATION_ERROR("401","请求未认证/认证错误"),
REQUEST_REFUSE("403","请求被拒绝"),
FUNCTION_MISSING("404","请求的资源不存在"),
OVER_WAITING_TIME("408","请求超时"),
OTHER_ERROR("500","其他错误"),
NO_DICT("501","字典表无此数据"),
NO_TABLE("501","字典表无influxDB表名数据"),
DEV_LINE_EMPTY("501","设备监测点不可为空"),
DIC_NAME_REPEAT("502","字典名称不可重复"),
CHILDREN_EXIT("503","存在子节点，不可删除"),
CAI_BIND("504","用能负荷未绑定监测点"),
LOAD_VAL_CONFLICT("505","负荷类型与值类型冲突"),
ENERGY_EMPTY("506","用能查询数据为空"),
TASK_CREATE_ERROR("507","定时任务创建失败"),
TASK_HAS_START("508","任务已经执行完毕"),
TASK_DEL_ERROR("509","定时任务删除失败,请联系管理员"),
TASK_RUNING("510","任务正在执行无法操作,请先停止任务"),
FILE_EMPTY("511","上传的文件为空，请检查文件")
;
private final String code;
private final String message;
EnergyResponseEnum(String code, String message) {
this.code = code;
this.message = message;
}
}

33
pqs-quality/quality-api/src/main/java/com/njcn/quality/enums/LoadEnum.java
View File

@@ -1,33 +0,0 @@
package com.njcn.quality.enums;
import lombok.Getter;
/**
* pqs
*
* @author cdf
* @date 2022/4/18
*/
@Getter
public enum LoadEnum {
AIR_LOAD("空调负荷"),
WORK_LOAD("办公负荷"),
EAT_LOAD("厨房负荷"),
SLEEP_LOAD("宿舍负荷"),
SUN_LOAD("光伏发电"),
HIGH_LINE("高压进线")
;
private final String name;
LoadEnum(String name){
this.name=name;
}
}

90
pqs-quality/quality-api/src/main/java/com/njcn/quality/param/AirStrategyParam.java
View File

@@ -1,90 +0,0 @@
package com.njcn.quality.param;
import com.njcn.common.pojo.constant.PatternRegex;
import com.njcn.web.constant.ValidMessage;
import com.njcn.web.pojo.annotation.DateTimeStrValid;
import com.njcn.web.pojo.param.BaseParam;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull;
import javax.validation.constraints.Pattern;
import java.util.List;
/**
* pqs
* 空调策略
* @author cdf
* @date 2022/4/21
*/
@Data
@ApiModel
public class AirStrategyParam{
@ApiModelProperty(name = "策略名称",required = true)
@NotBlank(message = "名称不可为空")
private String name;
@ApiModelProperty(name = "开始时间",required = true)
@NotBlank(message = "开始时间不可为空")
@DateTimeStrValid(format = "yyyy-MM-dd HH:mm:ss",message = "开始时间格式有误")
private String startTime;
@ApiModelProperty(name = "开始时间",required = true)
@NotBlank(message = "开始时间不可为空")
@DateTimeStrValid(format = "yyyy-MM-dd HH:mm:ss",message = "结束时间格式有误")
private String endTime;
@ApiModelProperty(name = "空调模式",required = true)
@NotBlank(message = "模式不可为空")
private String mode;
@ApiModelProperty(name = "空调温度",required = true)
@NotNull(message = "空调温度不可为空")
private Integer temperature;
@ApiModelProperty(name = "空调风速",required = true)
@NotBlank(message = "空调风速不可为空")
private String wind;
@ApiModelProperty(name = "排序",required = true)
@NotNull(message = "排序不可为空")
private Integer sort;
@ApiModelProperty(name = "监测点集",required = true)
@NotEmpty(message = "监测点集不可为空")
private List<String> lineIds;
/**
* 更新操作实体
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class AirUpdateParam extends AirStrategyParam {
@ApiModelProperty("id")
@NotBlank(message = ValidMessage.ID_NOT_BLANK)
@Pattern(regexp = PatternRegex.SYSTEM_ID, message = ValidMessage.ID_FORMAT_ERROR)
private String id;
}
/**
* 分页查询实体
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class AirStrategyQueryParam extends BaseParam {
}
}

57
pqs-quality/quality-api/src/main/java/com/njcn/quality/param/DataArrayParam.java
View File

@@ -1,57 +0,0 @@
package com.njcn.quality.param;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull;
/**
* 类的介绍：详细数据
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/9 13:36
*/
@Data
public class DataArrayParam {
@ApiModelProperty(value = "数据集表Id")
@NotEmpty(message = "数据集表Id不可为空")
private String pid;
@ApiModelProperty(value = "数据类型表id")
@NotEmpty(message = "数据类型表id不可为空")
private String dataId;
@ApiModelProperty(value = "数据分类")
private String className;
@ApiModelProperty(value = "排序")
private Integer sort;
@ApiModelProperty(value = "数据名称")
@NotEmpty(message = "数据名称不可为空")
private String name;
@ApiModelProperty(value = "数据名称别名")
@NotEmpty(message = "数据名称别名不可为空")
private String anotherName;
@ApiModelProperty(value = "数据编号")
@NotNull(message = "数据编号不可为空")
private Integer idx;
@ApiModelProperty(value = "数据类型")
private String type;
@ApiModelProperty(value = "相别")
private String phase;
@ApiModelProperty(value = "统计类型")
private String statMethod;
@ApiModelProperty(value = "influxDB表名")
private String classId;
}

34
pqs-quality/quality-api/src/main/java/com/njcn/quality/param/DataGroupParam.java
View File

@@ -1,34 +0,0 @@
package com.njcn.quality.param;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import javax.validation.constraints.NotEmpty;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/16 9:14
*/
@Data
public class DataGroupParam {
@ApiModelProperty(value = "数据集表Id")
@NotEmpty(message = "数据集表Id不可为空")
private String pid;
@ApiModelProperty(value = "分组名称")
private String name;
@ApiModelProperty(value = "统计方式")
private String statMethod;
@ApiModelProperty(value = "相别")
private String phase;
@ApiModelProperty(value = "排序")
private Integer sort;
}

33
pqs-quality/quality-api/src/main/java/com/njcn/quality/param/DataHisParam.java
View File

@@ -1,33 +0,0 @@
package com.njcn.quality.param;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.List;
/**
* pqs
* 通过字段表名获取统计趋势和历史趋势实体
* @author cdf
* @date 2022/3/28
*/
@Data
@ApiModel
public class DataHisParam {
@ApiModelProperty(name = "监测点id",required = true)
private String lineId;
@ApiModelProperty(name = "指标id集",required = true)
private List<String> arrName;
private String classId;
@ApiModelProperty(name = "起始时间",required = true)
private String startTime;
@ApiModelProperty(name = "结束时间",required = true)
private String endTime;
}

71
pqs-quality/quality-api/src/main/java/com/njcn/quality/param/DataModelParam.java
View File

@@ -1,71 +0,0 @@
package com.njcn.quality.param;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.njcn.common.pojo.constant.PatternRegex;
import com.njcn.web.constant.ValidMessage;
import com.njcn.web.pojo.param.BaseParam;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull;
import javax.validation.constraints.Pattern;
import java.time.LocalDateTime;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/8 20:19
*/
@Data
public class DataModelParam {
@ApiModelProperty(value = "数据模板名称")
@NotEmpty(message = "数据模板名称不可为空")
private String name;
@ApiModelProperty(value = "设备模板编号")
@NotNull(message = "设备模板编号不可为空")
private Integer idx;
@ApiModelProperty(value = "版本号")
private String version;
/**
* 创建或最后修改时间
*/
@ApiModelProperty(value = "创建或最后修改时间",required = true)
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private LocalDateTime time;
@ApiModelProperty(value = "创建时间",required = true)
private LocalDateTime createTime;
/**
* 更新操作实体
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class DataModelUpdateParam extends DataModelParam {
@ApiModelProperty("id")
@NotBlank(message = ValidMessage.ID_NOT_BLANK)
@Pattern(regexp = PatternRegex.SYSTEM_ID, message = ValidMessage.ID_FORMAT_ERROR)
private String id;
}
/**
* 分页查询实体
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class DataModelQueryParam extends BaseParam {
}
}

72
pqs-quality/quality-api/src/main/java/com/njcn/quality/param/DataSetParam.java
View File

@@ -1,72 +0,0 @@
package com.njcn.quality.param;
import com.njcn.common.pojo.constant.PatternRegex;
import com.njcn.web.constant.ValidMessage;
import com.njcn.web.pojo.param.BaseParam;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull;
import javax.validation.constraints.Pattern;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/9 10:08
*/
@Data
public class DataSetParam {
@ApiModelProperty(value = "数据模板表Id")
@NotEmpty(message = "数据模板表Id不可为空")
private String pid;
@ApiModelProperty(value = "数据集名称")
@NotEmpty(message = "数据集名称不可为空")
private String name;
@ApiModelProperty(value = "数据集序号")
@NotNull(message = "数据集序号不可为空")
private Integer idx;
@ApiModelProperty(value = "数据集别名")
private String anotherName;
/**
* 0 不存储
* 1 存储
*/
@ApiModelProperty(value = "是否存储")
@NotNull(message = "数据集序号不可为空")
private Integer storeFlag;
/**
* 更新操作实体
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class DataSetUpdateParam extends DataSetParam {
@ApiModelProperty("id")
@NotBlank(message = ValidMessage.ID_NOT_BLANK)
@Pattern(regexp = PatternRegex.SYSTEM_ID, message = ValidMessage.ID_FORMAT_ERROR)
private String id;
}
/**
* 分页查询实体
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class DataSetQueryParam extends BaseParam {
}
}

117
pqs-quality/quality-api/src/main/java/com/njcn/quality/param/DevCfgParam.java
View File

@@ -1,117 +0,0 @@
package com.njcn.quality.param;
import com.njcn.common.pojo.constant.PatternRegex;
import com.njcn.web.constant.ValidMessage;
import com.njcn.web.pojo.param.BaseParam;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.Pattern;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/8 13:30
*/
@Data
public class DevCfgParam {
@ApiModelProperty(value = "联网设备表Id")
@NotEmpty(message = "联网设备表Id不可为空")
private String pid;
@ApiModelProperty(value = "设备Id")
@NotEmpty(message = "设备Id不可为空")
private String did;
@ApiModelProperty(value = "版本信息表Id")
private String versionId;
@ApiModelProperty(value = "设备数据模板Id")
private String idx;
@ApiModelProperty(value = "设备名称")
private String name;
@ApiModelProperty(value = "设备型号")
private String type;
@ApiModelProperty(value = "设备类别")
private String devApp;
@ApiModelProperty(value = "设备和联网装置通讯协议")
private String protocol;
/**
* 设备和联网装置通讯接口 Lora、RS485、Eth、Bus内部总线方式
*/
@ApiModelProperty(value = "设备和联网装置通讯接口")
private String ci;
/**
* 内部时钟源 Rtc、None
*/
@ApiModelProperty(value = "内部时钟源")
private String iclk;
/**
* 外部时钟源 BCode、Sntp、MasterStation
*/
@ApiModelProperty(value = "内部时钟源")
private String eclk;
/**
* 数据上送周期（单位秒）
*/
@ApiModelProperty(value = "数据上送周期")
private Integer period;
@ApiModelProperty(value = "安装区域省")
private String province;
@ApiModelProperty(value = "安装区域市")
private String city;
@ApiModelProperty(value = "安装区域县或区")
private String county;
@ApiModelProperty(value = "安装地址（厂区或变电站）")
private String address;
@ApiModelProperty(value = "安装位置")
private String position;
@ApiModelProperty(value = "设备总线路")
private Integer allNum;
@ApiModelProperty(value = "监测点数目")
private Integer lineNum;
/**
* 更新操作实体
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class DevCfgUpdateParam extends DevCfgParam {
@ApiModelProperty("id")
@NotBlank(message = ValidMessage.ID_NOT_BLANK)
@Pattern(regexp = PatternRegex.SYSTEM_ID, message = ValidMessage.ID_FORMAT_ERROR)
private String id;
}
/**
* 分页查询实体
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class DevCfgQueryParam extends BaseParam {
}
}

33
pqs-quality/quality-api/src/main/java/com/njcn/quality/param/DevLineQueryParam.java
View File

@@ -1,33 +0,0 @@
package com.njcn.quality.param;
import com.njcn.web.pojo.annotation.DateTimeStrValid;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.springframework.validation.annotation.Validated;
import javax.validation.constraints.NotBlank;
/**
* pqs
*
* @author cdf
* @date 2022/3/14
*/
@Data
@Validated
public class DevLineQueryParam {
@NotBlank(message = "id不可为空")
@ApiModelProperty("id")
private String id;
@DateTimeStrValid
private String beginTime;
@DateTimeStrValid
private String endTime;
@ApiModelProperty("页码")
private Integer page;
@ApiModelProperty("页面尺寸")
private Integer pageSize;
}

94
pqs-quality/quality-api/src/main/java/com/njcn/quality/param/DevVersionParam.java
View File

@@ -1,94 +0,0 @@
package com.njcn.quality.param;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.njcn.common.pojo.constant.PatternRegex;
import com.njcn.web.constant.ValidMessage;
import com.njcn.web.pojo.param.BaseParam;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.Pattern;
import java.time.LocalDateTime;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/7 19:02
*/
@Data
public class DevVersionParam{
/**
* 网关id
*/
@ApiModelProperty(value = "网关id",required = true)
@NotBlank(message = "网关id不可为空")
private String ndid;
/**
* 模板名称
*/
@ApiModelProperty(value = "模板名称",required = true)
@NotBlank(message = "模板名称不可为空")
private String name;
/**
* 设备类型（0：联网设备；1：逻辑设备）
*/
@ApiModelProperty(value = "设备类型",required = true)
@NotEmpty(message = "设备类型不可为空")
private Integer type;
/**
* 版本号
*/
@ApiModelProperty(value = "版本号",required = true)
@NotBlank(message = "版本号不可为空")
private String version;
/**
* 创建或最后修改时间
*/
@ApiModelProperty(value = "创建或最后修改时间",required = true)
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private LocalDateTime time;
/**
* 创建或最后修改时间
*/
@ApiModelProperty(value = "创建时间",required = true)
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private LocalDateTime createTime;
/**
* 更新操作实体
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class DevVersionUpdateParam extends DevVersionParam {
@ApiModelProperty("id")
@NotBlank(message = ValidMessage.ID_NOT_BLANK)
@Pattern(regexp = PatternRegex.SYSTEM_ID, message = ValidMessage.ID_FORMAT_ERROR)
private String id;
}
/**
* 分页查询实体
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class DevVersionQueryParam extends BaseParam {
}
}

67
pqs-quality/quality-api/src/main/java/com/njcn/quality/param/DictParam.java
View File

@@ -1,67 +0,0 @@
package com.njcn.quality.param;
import com.njcn.common.pojo.constant.PatternRegex;
import com.njcn.web.constant.ValidMessage;
import com.njcn.web.pojo.param.BaseParam;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.Pattern;
/**
* pqs
*
* @author cdf
* @date 2022/3/22
*/
@Data
public class DictParam {
/**
* 父级id
*/
@ApiModelProperty(value = "父级id")
private String pid;
/**
* 字典表字段名
*/
@ApiModelProperty(value = "字典表字段名")
private String name;
/**
* 字典表别名
*/
@ApiModelProperty(value = "字典表别名")
private String anotherName;
/**
* 更新操作实体
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class DictUpdateParam extends DictParam {
@ApiModelProperty("id")
@NotBlank(message = ValidMessage.ID_NOT_BLANK)
@Pattern(regexp = PatternRegex.SYSTEM_ID, message = ValidMessage.ID_FORMAT_ERROR)
private String id;
}
/**
* 分页查询实体
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class DictQueryParam extends BaseParam {
@ApiModelProperty("pid")
@NotBlank(message = ValidMessage.ID_NOT_BLANK)
@Pattern(regexp = PatternRegex.SYSTEM_ID, message = ValidMessage.ID_FORMAT_ERROR)
private String pid;
}
}

18
pqs-quality/quality-api/src/main/java/com/njcn/quality/param/ElDataBindParam.java
View File

@@ -1,18 +0,0 @@
package com.njcn.quality.param;
import com.njcn.quality.pojo.po.EleBind;
import lombok.Data;
import java.util.List;
/**
* pqs
*
* @author cdf
* @date 2022/3/30
*/
@Data
public class ElDataBindParam {
private List<EleBind> list;
}

25
pqs-quality/quality-api/src/main/java/com/njcn/quality/param/EleParam.java
View File

@@ -1,25 +0,0 @@
package com.njcn.quality.param;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotEmpty;
import java.util.List;
/**
* @author denghuajun
* @version 1.0.0
* @date 2022年04月15日 13:38
*/
@Data
public class EleParam {
@ApiModelProperty("统计类型配置id")
@NotBlank(message = "id不可为空")
private String id;
@ApiModelProperty("指标类型集合ids")
@NotEmpty(message = "id数组")
private List<String> ids;
}

58
pqs-quality/quality-api/src/main/java/com/njcn/quality/param/ElectComparaParam.java
View File

@@ -1,58 +0,0 @@
package com.njcn.quality.param;
import com.njcn.web.pojo.annotation.DateTimeStrValid;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull;
import java.util.List;
/**
* pqs
*
* @author cdf
* @date 2022/4/18
*/
@Data
@ApiModel
public class ElectComparaParam {
@ApiModelProperty(value = "统计指标")
@NotBlank(message = "统计指标不可为空")
private String tagType;
@ApiModelProperty(value = "负荷类型")
@NotEmpty(message = "负荷类型不可为空")
private List<String> loadType;
@ApiModelProperty(value = "值类型")
private String valType;
@ApiModelProperty(value = "开始时间")
@NotBlank(message = "开始时间不可为空")
@DateTimeStrValid
private String startTime;
@ApiModelProperty(value = "结束时间")
@NotBlank(message = "结束时间不可为空")
@DateTimeStrValid
private String endTime;
@ApiModelProperty(value = "同比环比起始时间")
@NotBlank(message = "同比环比起始时间不可为空")
private String startTimeBi;
@ApiModelProperty(value = "同比环比结束时间")
@NotBlank(message = "同比环比结束时间不可为空")
@DateTimeStrValid
private String endTimeBi;
@ApiModelProperty(value = "统计类型")
@NotNull(message = "0.电度 1.电费")
private Integer statisticType;
}

45
pqs-quality/quality-api/src/main/java/com/njcn/quality/param/EnergyBaseParam.java
View File

@@ -1,45 +0,0 @@
package com.njcn.quality.param;
import com.njcn.web.constant.ValidMessage;
import com.njcn.web.pojo.annotation.DateTimeStrValid;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import javax.validation.constraints.NotBlank;
import java.io.Serializable;
/**
* pqs
*
* @author cdf
* @date 2022/4/1
*/
@Data
public class EnergyBaseParam implements Serializable {
private static final long serialVersionUID = 1L;
@ApiModelProperty("id")
@NotBlank(message = ValidMessage.ID_NOT_BLANK)
private String id;
@ApiModelProperty("lineId")
@NotBlank(message = ValidMessage.ID_NOT_BLANK)
private String lineId;
@ApiModelProperty("pageNum")
private Integer pageNum;
@ApiModelProperty("pageSize")
private Integer pageSize;
@ApiModelProperty("startTime")
@DateTimeStrValid
private String startTime;
@ApiModelProperty("endTime")
@DateTimeStrValid
private String endTime;
}

36
pqs-quality/quality-api/src/main/java/com/njcn/quality/param/GroupArrParam.java
View File

@@ -1,36 +0,0 @@
package com.njcn.quality.param;
import com.njcn.web.constant.ValidMessage;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotEmpty;
import java.util.List;
/**
* pqs
* 重新分组
*
* @author cdf
* @date 2022/3/16
*/
@Data
public class GroupArrParam {
@ApiModelProperty("setId")
@NotBlank(message = ValidMessage.ID_NOT_BLANK)
private String setId;
@ApiModelProperty("data")
@NotEmpty(message = "数据不能为空")
private List<ArrItem> data;
@Data
public static class ArrItem {
private String id;
private String name;
private List<String> children;
}
}

107
pqs-quality/quality-api/src/main/java/com/njcn/quality/param/HardwareParam.java
View File

@@ -1,107 +0,0 @@
package com.njcn.quality.param;
import com.njcn.common.pojo.constant.PatternRegex;
import com.njcn.web.constant.ValidMessage;
import com.njcn.web.pojo.param.BaseParam;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import org.hibernate.validator.constraints.Range;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull;
import javax.validation.constraints.Pattern;
/**
* @author 徐扬
*/
@Data
public class HardwareParam {
@ApiModelProperty("id")
@NotBlank(message = ValidMessage.ID_NOT_BLANK)
@Pattern(regexp = PatternRegex.SYSTEM_ID, message = ValidMessage.ID_FORMAT_ERROR)
private String id;
@ApiModelProperty(value = "设备类型区分")
@NotNull()
@Range(min = 0, max = 1)
private Integer type;
@ApiModelProperty(value = "设备类型")
private String devType;
@ApiModelProperty(value = "设备名称")
private String devName;
@ApiModelProperty(value = "设备厂商信息")
private String msgInfo;
@ApiModelProperty(value = "设备状态")
private String devStatus;
@ApiModelProperty(value = "设备硬件版本号")
private String hardVer;
@ApiModelProperty(value = "CPU核心数")
private Integer cpuCore;
@ApiModelProperty(value = "CPU主频（单位GHz）")
private Float cpuFreq;
@ApiModelProperty(value = "CPU架构")
private String arch;
@ApiModelProperty(value = "CPU监控阈值（单位%）")
private Float cpuLmt;
@ApiModelProperty(value = "物理内存（单位MB）")
private Float memPhy;
@ApiModelProperty(value = "虚拟内存（单位MB）")
private Float memVirt;
@ApiModelProperty(value = "内存监控阈值（单位%）")
private Float memLmt;
@ApiModelProperty(value = "磁盘空间（单位MB）")
private Float diskPhy;
@ApiModelProperty(value = "存储监控阈值（单位%）")
private Float diskLmt;
@ApiModelProperty(value = "已使用磁盘空间（单位MB）")
private Float diskUsePhy;
@ApiModelProperty(value = "操作系统名称，裸机系统填None")
private String osName;
@ApiModelProperty(value = "操作系统版本，裸机系统填None")
private String osVersion;
@ApiModelProperty(value = "应用程序版本号")
private String appVersion;
@ApiModelProperty(value = "应用程序发布日期")
private String appDate;
@ApiModelProperty(value = "应用程序校验码")
private String appCheck;
@ApiModelProperty(value = "是否支持远程升级程序")
private String softUpdate;
/**
* 分页查询实体
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class HardwareQueryParam extends BaseParam {
}
}

21
pqs-quality/quality-api/src/main/java/com/njcn/quality/param/JobInfoParam.java
View File

@@ -1,21 +0,0 @@
package com.njcn.quality.param;
import lombok.Data;
import java.io.Serializable;
/**
* @author hongawen
* @version 1.0.0
* @date 2022年04月18日 15:37
*/
@Data
public class JobInfoParam implements Serializable {
private String strategyId;
private String startTime;
private String endTime;
}

87
pqs-quality/quality-api/src/main/java/com/njcn/quality/param/LineParam.java
View File

@@ -1,87 +0,0 @@
package com.njcn.quality.param;
import com.njcn.common.pojo.constant.PatternRegex;
import com.njcn.web.constant.ValidMessage;
import com.njcn.web.pojo.param.BaseParam;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull;
import javax.validation.constraints.Pattern;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/8 13:52
*/
@Data
public class LineParam {
@ApiModelProperty(value = "监测点id")
@NotEmpty(message = "监测点id不可为空")
private String lineId;
@ApiModelProperty(value = "逻辑设备表Id")
@NotEmpty(message = "逻辑设备表Id不可为空")
private String pid;
@ApiModelProperty(value = "监测点名称")
@NotEmpty(message = "监测点名称不可为空")
private String name;
@ApiModelProperty(value = "监测点编号")
@NotNull(message = "监测点编号不可为空")
private Integer idx;
@ApiModelProperty(value = "安装区域省")
private String province;
@ApiModelProperty(value = "安装区域市")
private String city;
@ApiModelProperty(value = "安装区域县或区")
private String county;
@ApiModelProperty(value = "安装地址（厂区或变电站）")
private String address;
@ApiModelProperty(value = "安装位置")
private String position;
@ApiModelProperty(value = "电压等级")
private String volGrade;
@ApiModelProperty(value = "PT变比")
private String ptRatio;
@ApiModelProperty(value = "CT变比")
private String ctRatio;
/**
* 更新操作实体
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class LineUpdateParam extends LineParam {
@ApiModelProperty("id")
@NotBlank(message = ValidMessage.ID_NOT_BLANK)
@Pattern(regexp = PatternRegex.SYSTEM_ID, message = ValidMessage.ID_FORMAT_ERROR)
private String id;
}
/**
* 分页查询实体
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class LineQueryParam extends BaseParam {
}
}

54
pqs-quality/quality-api/src/main/java/com/njcn/quality/param/LoadStatisticParam.java
View File

@@ -1,54 +0,0 @@
package com.njcn.quality.param;
import com.njcn.web.pojo.annotation.DateTimeStrValid;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotEmpty;
import java.util.List;
/**
* pqs
*
* @author cdf
* @date 2022/4/18
*/
@Data
@ApiModel
public class LoadStatisticParam {
@ApiModelProperty(value = "统计指标",required = true)
@NotBlank(message = "统计指标不可为空")
private String tagType;
@ApiModelProperty(value = "负荷类型",required = true)
@NotEmpty(message = "负荷类型不可为空")
private List<String> loadType;
@ApiModelProperty(value = "值类型 0.最大值 1.最小值",required = true)
@NotEmpty(message = "值类型不可为空")
private List<Integer> valType;
@ApiModelProperty(value = "开始时间",required = true)
@NotBlank(message = "开始时间不可为空")
@DateTimeStrValid
private String startTime;
@ApiModelProperty(value = "结束时间",required = true)
@NotBlank(message = "结束时间不可为空")
@DateTimeStrValid
private String endTime;
@ApiModelProperty(value = "同比环比开始时间",required = true)
@NotBlank(message = "同比环比开始时间不可为空")
private String startTimeBi;
@ApiModelProperty(value = "同比环比结束时间",required = true)
@NotBlank(message = "同比环比结束时间不可为空")
@DateTimeStrValid
private String endTimeBi;
}

108
pqs-quality/quality-api/src/main/java/com/njcn/quality/param/NetDevParam.java
View File

@@ -1,108 +0,0 @@
package com.njcn.quality.param;
import com.njcn.common.pojo.constant.PatternRegex;
import com.njcn.web.constant.ValidMessage;
import com.njcn.web.pojo.param.BaseParam;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.Pattern;
/**
* <p>
*
* </p>
*
* @author cdf
* @since 2022-02-22
*/
@Data
public class NetDevParam {
/**
* 联网设备名称
*/
@ApiModelProperty(value = "名称",required = true)
@NotBlank(message = "网关设备名称不可为空")
private String name;
/**
* 联网设备ID
*/
@ApiModelProperty(value = "联网设备ID",required = true)
@NotBlank(message = "网关设备ID不可为空")
private String ndid;
/**
* 关联版本信息表Id
*/
private String versionId;
/**
* 联网设备型号（字典表）
*/
private String type;
/**
* 联网设备接入网络方式 “4G” “WIFI” （字典表）
*/
private String netType;
/**
* 用户ID
*/
private String uid;
/**
* 子用户信息
*/
private String cUid;
/**
* 硬件信息表Id
*/
private String info;
/**
* 状态
*/
private Integer state;
/**
* 排序字段
* @author cdf
* @date 2022/4/20
*/
@ApiModelProperty(value = "排序字段",required = true)
@NotBlank(message = "排序字段不可为空")
private Integer sort;
/**
* 更新操作实体
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class NetDevUpdateParam extends NetDevParam {
@ApiModelProperty("id")
@NotBlank(message = ValidMessage.ID_NOT_BLANK)
@Pattern(regexp = PatternRegex.SYSTEM_ID, message = ValidMessage.ID_FORMAT_ERROR)
private String id;
}
/**
* 分页查询实体
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class NetDevQueryParam extends BaseParam {
}
}

32
pqs-quality/quality-api/src/main/java/com/njcn/quality/param/UpdateDeviceVersion.java
View File

@@ -1,32 +0,0 @@
package com.njcn.quality.param;
import com.njcn.common.pojo.constant.PatternRegex;
import com.njcn.web.constant.ValidMessage;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import org.springframework.web.multipart.MultipartFile;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull;
import javax.validation.constraints.Pattern;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/7/6 9:24
*/
@Data
public class UpdateDeviceVersion {
@ApiModelProperty("装置id")
@NotBlank(message = ValidMessage.ID_NOT_BLANK)
@Pattern(regexp = PatternRegex.NORMAL, message = ValidMessage.ID_FORMAT_ERROR)
private String name;
@ApiModelProperty("装置版本文件")
@NotNull(message = ValidMessage.DEVICE_VERSION_NOT_BLANK)
private MultipartFile deviceVersionFile;
}

59
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/constant/ApiParam.java
View File

@@ -1,59 +0,0 @@
package com.njcn.quality.pojo.constant;
/**
* @author 徐扬
*/
public interface ApiParam {
/**
* 设备接入网络设备注册申请
*/
String CMD_DEV_REGISTER = "CMD_DEV_REGISTER";
/**
* 平台对接入网络设备注册应答
*/
String REP_DEV_REGISTER = "REP_DEV_REGISTER";
/**
* 设备接入请求
*/
String CMD_LINKUP = "CMD_LINKUP";
/**
* 设备接入应答
*/
String REP_LINKUP = "REP_LINKUP";
/**
* 设备主动断开上报
*/
String ACT_LINK_DOWN = "ACT_LINK_DOWN";
/**
* 设备心跳请求
*/
String CMD_HEARTBEAT = "CMD_HEARTBEAT";
/**
* 设备心跳应答
*/
String REP_HEARTBEAT = "REP_HEARTBEAT";
/**
* 联网装置主题信息上送
*/
String ACT_DEV_TOPIC = "ACT_DEV_TOPIC";
/**
* 设备数据询问
*/
String CMD_DEV_DATA = "CMD_DEV_DATA";
/**
* 联网装置主题信息上送
*/
String REP_DEV_DATA = "REP_DEV_DATA";
}

68
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/constant/DataType.java
View File

@@ -1,68 +0,0 @@
package com.njcn.quality.pojo.constant;
/**
* @author 徐扬
*/
public interface DataType {
/**
* 电度数据
*/
String EPD = "EPD";
/**
* 电能质量数据
*/
String PQD = "PQD";
/**
* 事件
*/
String EVT = "EVT";
/**
* 告警
*/
String ALM = "ALM";
/**
* 通用测量
*/
String MD = "MD";
/**
* 通用测量
*/
String STS = "STS";
/**
* 开入信号量
*/
String DI = "DI";
/**
* 开入信号量
*/
String DO = "DO";
/**
* 参数
*/
String PARM = "PARM";
/**
* 控制
*/
String CTRL = "CTRL";
/**
* 自动控制
*/
String ACTRL = "ACTRL";
/**
* 模板
*/
String TEMPLATE = "TEMPLATE";
}

61
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/constant/ModelState.java
View File

@@ -1,61 +0,0 @@
package com.njcn.quality.pojo.constant;
/**
* @author 徐扬
*/
public interface ModelState {
/**
* 注册成功状态
*/
Integer SUCCESS = 1;
Integer FAIL = 0;
/**
* DID操作
*/
Integer REGISTER = 1;
Integer UNREGISTER = 0;
Integer ACCESS = 2;
/**
* 报文处理优先级
*/
Integer PRIORITY_FIRST = 1;
Integer PRIORITY_SECOND = 2;
Integer PRIORITY_THIRD = 3;
Integer PRIORITY_FORTH = 4;
Integer PRIORITY_FIFTH = 5;
/**
* 报文过期的相对时间 -1表示永不过期
*/
Integer EXPIRE = -1;
/**
* 设备类型（0：联网设备；1：逻辑设备）
* 模板类型（0：联网设备模板；1：逻辑设备模板；2：用户模板；3：典表数据模板）
*/
Integer NET_DEV = 0;
Integer LOGIC_DEV = 1;
Integer USER = 2;
Integer DICTIONARY = 3;
/**
* 操作类型
*/
String WRITE = "write";
String READ = "read";
Integer online = 1;
Integer offline = 0;
}

21
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/constant/TableName.java
View File

@@ -1,21 +0,0 @@
package com.njcn.quality.pojo.constant;
/**
* pqs
*
* @author cdf
* @date 2022/3/25
*/
public interface TableName {
String eleEpdPqd = "ele_epd_pqd";
String eleMd = "ele_md";
String eleCtrl = "ele_ctrl";
String eleSts = "ele_sts";
String powerData = "power_data";
String powerDataReal = "power_data_Real";
String powerQuality = "power_quality_data";
String powerQualityReal = "power_quality_data_Real";
}

42
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/ACtrlDTO.java
View File

@@ -1,42 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 15:10
*/
@Data
public class ACtrlDTO implements Serializable {
@SerializedName("Name")
private String name;
@SerializedName("IDX")
private Integer idx;
@SerializedName("Enable")
private Integer enable;
@SerializedName("Number")
private Integer number;
@SerializedName("StartTime")
private String startTime;
@SerializedName("EndTime")
private String endTime;
@SerializedName("Condition")
private List<String> condition;
@SerializedName("OutRes")
private List<String> outRes;
}

53
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/AccessDTO.java
View File

@@ -1,53 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.io.Serializable;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/12 17:04
*/
@Data
@EqualsAndHashCode(callSuper = true)
public class AccessDTO extends PublicParamDTO implements Serializable {
/**
* 请求参数
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class AccessRequest extends AccessDTO implements Serializable{
@SerializedName("expire")
private Integer expire;
@SerializedName("param")
private AccessParamDTO param;
}
/**
* 应答参数
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class AccessResponse extends AccessDTO implements Serializable{
@SerializedName("code")
private Integer code;
@SerializedName("msg")
private String msg;
@SerializedName("param")
private AccessParamDTO param;
}
}

25
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/AccessParamDTO.java
View File

@@ -1,25 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/12 17:08
*/
@Data
public class AccessParamDTO implements Serializable {
@SerializedName("DID")
List<String> did;
@SerializedName("TpList")
List<TpListDTO> tpList;
}

29
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/AirStrategyDTO.java
View File

@@ -1,29 +0,0 @@
package com.njcn.quality.pojo.dto;
import lombok.Data;
/**
* pqs
*
* @author cdf
* @date 2022/4/22
*/
@Data
public class AirStrategyDTO {
private Integer mid;
private String deviceId;
private Long timestamp;
private Integer expire;
private String type;
private Param param;
@Data
public static class Param{
private String lineId;
private String action;
private String parm;
}
}

28
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/AlmDTO.java
View File

@@ -1,28 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 14:45
*/
@Data
public class AlmDTO implements Serializable {
@SerializedName("Name")
private String name;
@SerializedName("IDX")
private Integer idx;
@SerializedName("Type")
private String type;
}

47
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/AskDataDTO.java
View File

@@ -1,47 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.io.Serializable;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/12 21:28
*/
@Data
@EqualsAndHashCode(callSuper = true)
public class AskDataDTO extends PublicParamDTO implements Serializable {
/**
* 请求参数
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class AskDataRequest extends AskDataDTO implements Serializable{
@SerializedName("param")
private AskDataParamDTO param;
}
/**
* 响应参数
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class AskDataResponse extends AskDataDTO implements Serializable{
@SerializedName("code")
private Integer code;
@SerializedName("msg")
private String msg;
@SerializedName("param")
private TemplateDataArrayDTO param;
}
}

27
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/AskDataParamDTO.java
View File

@@ -1,27 +0,0 @@
package com.njcn.quality.pojo.dto;
import lombok.Data;
import java.io.Serializable;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/12 21:30
*/
@Data
public class AskDataParamDTO implements Serializable {
private String dataType;
private String operate;
private String startTime;
private String endTime;
private Object dataArray;
}

29
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/CpuInfoDTO.java
View File

@@ -1,29 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 12:09
*/
@Data
public class CpuInfoDTO implements Serializable {
@SerializedName("CpuCore")
private Integer cpuCore;
@SerializedName("CpuFreq")
private Float cpuFreq;
@SerializedName("Arch")
private String arch;
@SerializedName("CpuLmt")
private Float cpuLmt;
}

48
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/CtrlDTO.java
View File

@@ -1,48 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 15:06
*/
@Data
public class CtrlDTO implements Serializable {
@SerializedName("Name")
private String name;
@SerializedName("IDX")
private Integer idx;
@SerializedName("Type")
private String type;
@SerializedName("Check")
private Integer remoteCheck;
@SerializedName("Auto")
private Integer auto;
@SerializedName("MaxNum")
private Integer maxNum;
@SerializedName("MinNum")
private Integer minNum;
@SerializedName("Ctlvalue")
private List<String> ctlValue;
@SerializedName("Strlen")
private Integer strLen;
@SerializedName("Encode")
private Integer encode;
}

25
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/CuDevDTO.java
View File

@@ -1,25 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/6/20 13:53
*/
@Data
public class CuDevDTO implements Serializable {
@SerializedName("IDX")
private String idx;
@SerializedName("DevIDList")
private List<String> devIdList;
}

27
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/CuIdDTO.java
View File

@@ -1,27 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/6/20 13:56
*/
@Data
public class CuIdDTO implements Serializable {
@SerializedName("ID")
private String id;
@SerializedName("IDX")
private String idx;
@SerializedName("Permissions")
private List<String> permissions;
}

24
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/DataArrayDTO.java
View File

@@ -1,24 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 15:18
*/
@Data
public class DataArrayDTO implements Serializable {
@SerializedName("Type")
private String type;
@SerializedName("IDX")
private Integer idx;
}

21
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/DataArrayListDTO.java
View File

@@ -1,21 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/21 18:57
*/
@Data
public class DataArrayListDTO {
@SerializedName("TEMPLATE")
private TemplateDTO template;
}

40
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/DataSetDTO.java
View File

@@ -1,40 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 14:21
*/
@Data
public class DataSetDTO implements Serializable {
@SerializedName("Name")
private String name;
@SerializedName("IDX")
private Integer idx;
@SerializedName("DataType")
private String dataType;
@SerializedName("StartTime")
private String startTime;
@SerializedName("Period")
private Integer period;
@SerializedName("StoreFlag")
private Integer storeFlag;
@SerializedName("DataArray")
private List<DataArrayDTO> dataArray;
}

30
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/DevCfgDTO.java
View File

@@ -1,30 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 13:03
*/
@Data
public class DevCfgDTO implements Serializable {
@SerializedName("Name")
private String name;
@SerializedName("Version")
private String version;
@SerializedName("Time")
private String time;
@SerializedName("Cfg")
private List<DeviceDTO> cfg;
}

79
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/DevDTO.java
View File

@@ -1,79 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 13:04
*/
@Data
public class DevDTO implements Serializable {
@SerializedName("Name")
private String name;
@SerializedName("Version")
private String version;
@SerializedName("Time")
private String time;
@SerializedName("IDX")
private Integer idx;
@SerializedName("DevType")
private String devType;
@SerializedName("DataList")
private List<String> dataList;
@SerializedName("DataSet")
private List<DataSetDTO> dataSet;
@SerializedName("IClk")
private String iclk;
@SerializedName("EClk")
private String eclk;
@SerializedName("LineNum")
private Integer lineNum;
@SerializedName("EPD")
private List<EpdPqdDTO> epd;
@SerializedName("PQD")
private List<EpdPqdDTO> pqd;
@SerializedName("EVT")
private List<EvtDTO> evt;
@SerializedName("ALM")
private List<AlmDTO> alm;
@SerializedName("MD")
private List<MdDTO> md;
@SerializedName("STS")
private List<StsDTO> sts;
@SerializedName("DI")
private List<DiDTO> di;
@SerializedName("DO")
private List<DoDTO> doDTO;
@SerializedName("Param")
private List<ParamDTO> param;
@SerializedName("CTRL")
private List<CtrlDTO> ctrl;
}

32
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/DevInfoDTO.java
View File

@@ -1,32 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 12:08
*/
@Data
public class DevInfoDTO implements Serializable {
@SerializedName("DevType")
private String devType;
@SerializedName("DevName")
private String devName;
@SerializedName("MsgInfo")
private String msgInfo;
@SerializedName("DevStatus")
private String devStatus;
@SerializedName("HardVer")
private String hardVer;
}

67
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/DeviceDTO.java
View File

@@ -1,67 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 13:38
*/
@Data
public class DeviceDTO implements Serializable {
@SerializedName("DevModName")
private String name;
@SerializedName("DevModVersion")
private String version;
@SerializedName("DevModTime")
private String time;
@SerializedName("ID")
private String id;
@SerializedName("DevType")
private String type;
@SerializedName("DevApp")
private String devApp;
@SerializedName("DevInfo")
private DevInfoDTO devInfo;
@SerializedName("Province")
private String province;
@SerializedName("City")
private String city;
@SerializedName("County")
private String county;
@SerializedName("Address")
private String address;
@SerializedName("Position")
private String position;
@SerializedName("LineNum")
private Integer lineNum;
@SerializedName("LineInfo")
private List<LineDTO> lineInfo;
@SerializedName("FileFrameLength")
private Integer fileFrameLength;
@SerializedName("FileFrameTimeout")
private Integer fileFrameTimeout;
}

28
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/DeviceOperateDTO.java
View File

@@ -1,28 +0,0 @@
package com.njcn.quality.pojo.dto;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/24 18:40
*/
@Data
public class DeviceOperateDTO implements Serializable {
private String ndid;
private List<String> did;
private String type;
private String message;
private String time;
}

21
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/DiDTO.java
View File

@@ -1,21 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 14:57
*/
@Data
public class DiDTO extends StsDTO implements Serializable {
@SerializedName("TranFlag")
private Integer tranFlag;
}

27
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/DiskInfoDTO.java
View File

@@ -1,27 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 12:09
*/
@Data
public class DiskInfoDTO implements Serializable {
@SerializedName("DiskPhy")
private Float diskPhy;
@SerializedName("DiskUsePhy")
private Float diskUsePhy;
@SerializedName("DiskLmt")
private Float diskLmt;
}

29
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/DoDTO.java
View File

@@ -1,29 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 14:59
*/
@Data
public class DoDTO implements Serializable {
@SerializedName("Name")
private String name;
@SerializedName("IDX")
private Integer idx;
@SerializedName("CurSts")
private Integer curSts;
@SerializedName("CtlSts")
private Integer ctlSts;
}

20
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/ElePublicDTO.java
View File

@@ -1,20 +0,0 @@
package com.njcn.quality.pojo.dto;
import lombok.Data;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/4/15 8:58
*/
@Data
public class ElePublicDTO {
private String lineId;
private Double data;
}

46
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/EpdPqdDTO.java
View File

@@ -1,46 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 14:27
*/
@Data
public class EpdPqdDTO implements Serializable {
@SerializedName("Name")
private String name;
@SerializedName("IDX")
private Integer idx;
@SerializedName("Type")
private String type;
@SerializedName("Phase")
private String phase;
@SerializedName("Unit")
private String unit;
@SerializedName("HarmStart")
private String harmStart;
@SerializedName("HarmEnd")
private String harmEnd;
@SerializedName("ClassID")
private String classId;
@SerializedName("StatMethod")
private List<String> statMethod;
}

30
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/EvtDTO.java
View File

@@ -1,30 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 14:40
*/
@Data
public class EvtDTO implements Serializable {
@SerializedName("Name")
private String name;
@SerializedName("IDX")
private Integer idx;
@SerializedName("Type")
private String type;
@SerializedName("Parm")
private List<EvtParam> param;
}

31
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/EvtParam.java
View File

@@ -1,31 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 14:41
*/
@Data
public class EvtParam implements Serializable {
@SerializedName("Name")
private String name;
@SerializedName("Type")
private String type;
@SerializedName("Unit")
private String unit;
@SerializedName("Data")
private String data;
}

50
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/LineDTO.java
View File

@@ -1,50 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 13:38
*/
@Data
public class LineDTO implements Serializable {
@SerializedName("Name")
private String name;
@SerializedName("lineId")
private String lineId;
@SerializedName("IDX")
private Integer idx;
@SerializedName("Province")
private String province;
@SerializedName("City")
private String city;
@SerializedName("County")
private String county;
@SerializedName("Address")
private String address;
@SerializedName("Position")
private String position;
@SerializedName("VolGrade")
private String volGrade;
@SerializedName("PtRatio")
private String ptRatio;
@SerializedName("CtRatio")
private String ctRatio;
}

43
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/MdDTO.java
View File

@@ -1,43 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 14:48
*/
@Data
public class MdDTO implements Serializable {
@SerializedName("Name")
private String name;
@SerializedName("IDX")
private Integer idx;
@SerializedName("Type")
private String type;
@SerializedName("Unit")
private String unit;
@SerializedName("Phase")
private String phase;
@SerializedName("ClassID")
private String classId;
@SerializedName("StatMethod")
private List<String> statMethod;
@SerializedName("TranRule")
private String tranRule;
}

26
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/MemInfoDTO.java
View File

@@ -1,26 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 12:09
*/
@Data
public class MemInfoDTO implements Serializable {
@SerializedName("MemPhy")
private Float memPhy;
@SerializedName("MemVirt")
private Float memVirt;
@SerializedName("MemLmt")
private Float memLmt;
}

18
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/NetAndDevByLineDTO.java
View File

@@ -1,18 +0,0 @@
package com.njcn.quality.pojo.dto;
import lombok.Data;
/**
* pqs
*
* @author cdf
* @date 2022/4/22
*/
@Data
public class NetAndDevByLineDTO {
private String ndid;
private String devId;
private String lineId;
private String lineName;
}

63
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/NetDevDTO.java
View File

@@ -1,63 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 12:03
*/
@Data
public class NetDevDTO implements Serializable {
@SerializedName("Name")
private String name;
@SerializedName("Version")
private String version;
@SerializedName("Time")
private String time;
@SerializedName("DevName")
private String devName;
@SerializedName("DevType")
private String devType;
@SerializedName("NetType")
private String netType;
@SerializedName("NDID")
private String nDid;
@SerializedName("DevTopicVer")
private String devTopicVer;
@SerializedName("Uid")
private String uid;
@SerializedName("CUid")
private List<String> cUid;
@SerializedName("DevInfo")
private DevInfoDTO devInfoDTO;
@SerializedName("CpuInfo")
private CpuInfoDTO cpuInfoDTO;
@SerializedName("MemInfo")
private MemInfoDTO memInfoDTO;
@SerializedName("DiskInfo")
private DiskInfoDTO diskInfoDTO;
@SerializedName("SoftInfo")
private SoftInfoDTO softInfoDTO;
}

27
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/OnlineRateDTO.java
View File

@@ -1,27 +0,0 @@
package com.njcn.quality.pojo.dto;
import lombok.Data;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/4/18 20:36
*/
@Data
public class OnlineRateDTO {
private Long time;
private String deviceId;
private Double onlineRate;
private Integer onlineTime;
private Integer offlineTime;
}

49
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/ParamDTO.java
View File

@@ -1,49 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 15:02
*/
@Data
public class ParamDTO implements Serializable {
@SerializedName("Name")
private String name;
@SerializedName("IDX")
private Integer idx;
@SerializedName("Type")
private String type;
@SerializedName("DataType")
private String dataType;
@SerializedName("ModifyFlag")
private Integer modifyFlag;
@SerializedName("MaxNum")
private Integer maxNum;
@SerializedName("MinNum")
private Integer minNum;
@SerializedName("SetValue")
private List<String> setValue;
@SerializedName("Strlen")
private Integer strLen;
@SerializedName("DefaultValue")
private String defaultValue;
}

42
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/PublicParamDTO.java
View File

@@ -1,42 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/12 19:18
*/
@Data
public class PublicParamDTO implements Serializable {
/**
* 在请求报文中该值为请求 ID，在设备主动上报数据的报文中该字段可不填写
*/
@SerializedName("mid")
private Integer mid;
@SerializedName("userId")
private String userId;
@SerializedName("deviceId")
private String deviceId;
@SerializedName("timestamp")
private String timestamp;
/**
* 报文处理的优先级
*/
@SerializedName("level")
private Integer level;
@SerializedName("type")
private String type;
}

51
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/RegisterDTO.java
View File

@@ -1,51 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.io.Serializable;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/11 14:36
*/
@Data
@EqualsAndHashCode(callSuper = true)
public class RegisterDTO extends PublicParamDTO implements Serializable {
/**
* 请求参数
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class RegisterRequest extends RegisterDTO implements Serializable{
@SerializedName("expire")
private Integer expire;
@SerializedName("param")
private RegisterParamDTO.RegisterParamRequest param;
}
/**
* 应答参数
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class RegisterResponse extends RegisterDTO implements Serializable{
@SerializedName("code")
private Integer code;
@SerializedName("msg")
private String msg;
@SerializedName("param")
private RegisterParamDTO.RegisterParamResponse param;
}
}

50
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/RegisterParamDTO.java
View File

@@ -1,50 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.io.Serializable;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/11 14:58
*/
@Data
public class RegisterParamDTO implements Serializable {
@SerializedName("NDID")
private String nDid;
@SerializedName("DID")
private List<String> did;
/**
* 请求参数
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class RegisterParamRequest extends RegisterParamDTO implements Serializable{
@SerializedName("type")
private Integer type;
}
/**
* 应答参数
*/
@Data
@EqualsAndHashCode(callSuper = true)
public static class RegisterParamResponse extends RegisterParamDTO implements Serializable{
@SerializedName("res")
private Integer res;
@SerializedName("type")
private Integer resType;
}
}

36
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/SoftInfoDTO.java
View File

@@ -1,36 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 12:09
*/
@Data
public class SoftInfoDTO implements Serializable {
@SerializedName("OsName")
private String osName;
@SerializedName("OsVersion")
private String osVersion;
@SerializedName("AppVersion")
private String appVersion;
@SerializedName("AppDate")
private String appDate;
@SerializedName("AppCheck")
private String appCheck;
@SerializedName("Softupdate")
private String softUpdate;
}

36
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/StsDTO.java
View File

@@ -1,36 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 14:52
*/
@Data
public class StsDTO implements Serializable {
@SerializedName("Name")
private String name;
@SerializedName("IDX")
private Integer idx;
@SerializedName("StoreFlag")
private Integer storeFlag;
@SerializedName("CurSts")
private Integer curSts;
@SerializedName("ClassID")
private String classId;
@SerializedName("TranRule")
private String tranRule;
}

30
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/TemplateDTO.java
View File

@@ -1,30 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 11:36
*/
@Data
public class TemplateDTO implements Serializable {
@SerializedName("NetDevMod")
private NetDevDTO netDev;
@SerializedName("DevCfg")
private DevCfgDTO devCfg;
@SerializedName("DevMod")
private List<DevDTO> dev;
@SerializedName("UserCfg")
private UserCfgDTO userCfg;
}

32
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/TemplateDataArrayDTO.java
View File

@@ -1,32 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 13:01
*/
@Data
public class TemplateDataArrayDTO implements Serializable {
@SerializedName("Data_Type")
private String dataType;
@SerializedName("DsName")
private String dsName;
@SerializedName("Data_Array")
private List<DataArrayListDTO> dataArray;
@SerializedName("Res")
private String res;
}

21
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/ThreadDTO.java
View File

@@ -1,21 +0,0 @@
package com.njcn.quality.pojo.dto;
import lombok.Data;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.CompletableFuture;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/4/1 10:17
*/
@Data
public class ThreadDTO {
public static Map<String,CompletableFuture<String>> list = new HashMap<>();
}

22
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/TopicDTO.java
View File

@@ -1,22 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/24 14:28
*/
@Data
public class TopicDTO implements Serializable {
@SerializedName("topic")
private List<String> topic;
}

21
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/TopicParamDTO.java
View File

@@ -1,21 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/24 14:38
*/
@Data
public class TopicParamDTO extends PublicParamDTO implements Serializable {
@SerializedName("param")
private TopicDTO param;
}

31
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/TpListDTO.java
View File

@@ -1,31 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/12 17:03
*/
@Data
public class TpListDTO implements Serializable {
@SerializedName("name")
private String name;
@SerializedName("IDX")
private String idx;
@SerializedName("version")
private String version;
@SerializedName("time")
private String time;
}

36
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/dto/UserCfgDTO.java
View File

@@ -1,36 +0,0 @@
package com.njcn.quality.pojo.dto;
import com.google.gson.annotations.SerializedName;;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/13 13:05
*/
@Data
public class UserCfgDTO implements Serializable {
@SerializedName("Name")
private String name;
@SerializedName("Version")
private String version;
@SerializedName("Time")
private String time;
@SerializedName("Uid")
private String uid;
@SerializedName("CUid")
private List<CuIdDTO> cuId;
@SerializedName("CuDev")
private List<CuDevDTO> cuDev;
}

19
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/AirSet.java
View File

@@ -1,19 +0,0 @@
package com.njcn.quality.pojo.po;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Data;
/**
* pqs
*
* @author cdf
* @date 2022/4/21
*/
@TableName(value = "ele_air_set")
@Data
@AllArgsConstructor
public class AirSet {
private String id;
private String lineId;
}

28
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/AirStrategy.java
View File

@@ -1,28 +0,0 @@
package com.njcn.quality.pojo.po;
import com.baomidou.mybatisplus.annotation.TableName;
import com.njcn.db.bo.BaseEntity;
import lombok.Data;
/**
* pqs
* 空调策略
* @author cdf
* @date 2022/4/21
*/
@TableName(value = "ele_air_strategy")
@Data
public class AirStrategy extends BaseEntity {
private String id;
private String name;
private String startTime;
private String endTime;
private String mode;
private Integer temperature;
private String wind;
private Integer state;
private Integer sort;
private Integer status;
private String xxlId;
}

83
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/DataArray.java
View File

@@ -1,83 +0,0 @@
package com.njcn.quality.pojo.po;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Getter;
import lombok.Setter;
/**
* <p>
*
* </p>
*
* @author cdf
* @since 2022-03-03
*/
@Getter
@Setter
@TableName("ele_data_array")
public class DataArray {
private static final long serialVersionUID = 1L;
/**
* 详细数据表Id
*/
private String id;
/**
* 数据集表Id
*/
private String pid;
/**
* 数据类型表Id
*/
private String dataId;
/**
* 数据分类,同一个类型的数据存储到同一个表上（数据表名）
*/
private String className;
/**
* 排序
*/
private Integer sort;
/**
* 数据名称
*/
private String name;
/**
* 数据名称别名
*/
private String anotherName;
/**
* 数据编号
*/
private Integer idx;
/**
* 数据类型
*/
private String type;
/**
* 相别
*/
private String phase;
/**
* 统计类型
*/
private String statMethod;
/**
* influxDB表名
*/
private String classId;
}

40
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/DataGroup.java
View File

@@ -1,40 +0,0 @@
package com.njcn.quality.pojo.po;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Getter;
import lombok.Setter;
/**
* <p>
*
* </p>
*
* @author cdf
* @since 2022-03-03
*/
@Getter
@Setter
@TableName("ele_data_group")
public class DataGroup {
private static final long serialVersionUID = 1L;
private String id;
/**
* 关联数据集表id
*/
private String pid;
/**
* 分组名称
*/
private String name;
private String statMethod;
private String phase;
private Integer sort;
}

52
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/DataMould.java
View File

@@ -1,52 +0,0 @@
package com.njcn.quality.pojo.po;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Getter;
import lombok.Setter;
import java.time.LocalDateTime;
/**
* <p>
*
* </p>
*
* @author cdf
* @since 2022-03-03
*/
@Getter
@Setter
@TableName("ele_data_mould")
public class DataMould {
private static final long serialVersionUID = 1L;
private String id;
/**
* 数据模板名称
*/
private String name;
/**
* 设备模板编号
*/
private Integer idx;
/**
* 版本号（从V1.00开始）
*/
private String version;
/**
* 创建或最后修改时间
*/
private LocalDateTime time;
private Integer state;
private LocalDateTime createTime;
}

46
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/DataSet.java
View File

@@ -1,46 +0,0 @@
package com.njcn.quality.pojo.po;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Getter;
import lombok.Setter;
/**
* <p>
*
* </p>
*
* @author cdf
* @since 2022-03-03
*/
@Getter
@Setter
@TableName("ele_data_set")
public class DataSet {
private static final long serialVersionUID = 1L;
private String id;
/**
* 数据模板表Id
*/
private String pid;
/**
* 数据集名称
*/
private String name;
/**
* 数据集序号
*/
private Integer idx;
/**
* 是否存储“1”“0”
*/
private Integer storeFlag;
private String anotherName;
}

58
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/DevVersion.java
View File

@@ -1,58 +0,0 @@
package com.njcn.quality.pojo.po;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import java.time.LocalDateTime;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/7 9:20
*/
@Data
@TableName("ele_dev_version")
public class DevVersion {
private static final long serialVersionUID = 1L;
/**
* 设备配置模板表Id
*/
private String id;
/**
* 网关id
*/
private String ndid;
/**
* 模板名称
*/
private String name;
/**
* 模板类型（0：联网设备模板；1：逻辑设备模板；2：用户模板；3：典表数据模板）
*/
private Integer type;
/**
* 版本号（从V1.00开始）
*/
private String version;
/**
* 创建或最后修改时间
*/
private LocalDateTime time;
/**
* 状态 0-删除；1-正常
*/
private Integer state;
private LocalDateTime createTime;
}

29
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleALM.java
View File

@@ -1,29 +0,0 @@
package com.njcn.quality.pojo.po;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/14 20:29
*/
@Data
@TableName("ele_alm")
public class EleALM {
private static final long serialVersionUID = 1L;
private String id;
private String name;
private String anotherName;
private Integer idx;
private String type;
}

41
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleActrl.java
View File

@@ -1,41 +0,0 @@
package com.njcn.quality.pojo.po;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import java.time.LocalDateTime;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/14 21:32
*/
@Data
@TableName("ele_actrl")
public class EleActrl {
private static final long serialVersionUID = 1L;
private String id;
private String name;
private String anotherName;
private Integer idx;
private Integer enable;
private Integer autoIdx;
private LocalDateTime startTime;
private LocalDateTime endTime;
private String condition;
private String outRes;
}

22
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleBind.java
View File

@@ -1,22 +0,0 @@
package com.njcn.quality.pojo.po;
import lombok.Data;
/**
* pqs
*
* @author cdf
* @date 2022/3/29
*/
@Data
public class EleBind {
private static final long serialVersionUID = 1L;
private String lineId;
private String tagId;
private String ndid;
}

45
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleCtrl.java
View File

@@ -1,45 +0,0 @@
package com.njcn.quality.pojo.po;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/14 21:26
*/
@Data
@TableName("ele_ctrl")
public class EleCtrl {
private static final long serialVersionUID = 1L;
private String id;
private String name;
private String anotherName;
private Integer idx;
private String type;
private Integer remoteCheck;
private Integer auto;
private Integer maxNum;
private Integer minNum;
private String ctlValue;
private Integer strLen;
private String encode;
private String classId;
}

37
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleDi.java
View File

@@ -1,37 +0,0 @@
package com.njcn.quality.pojo.po;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/14 20:57
*/
@Data
@TableName("ele_di")
public class EleDi {
private static final long serialVersionUID = 1L;
private String id;
private String name;
private String anotherName;
private Integer idx;
private Integer storeFlag;
private Integer curSts;
private String classId;
private String tranRule;
private Integer tranFlag;
}

32
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleDict.java
View File

@@ -1,32 +0,0 @@
package com.njcn.quality.pojo.po;
import com.baomidou.mybatisplus.annotation.TableName;
import com.njcn.db.bo.BaseEntity;
import lombok.Data;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/24 11:00
*/
@Data
@TableName("ele_dict")
public class EleDict extends BaseEntity {
private static final long serialVersionUID = 1L;
private String id;
private String pid;
private String name;
private String anotherName;
private Integer state;
private Integer sort;
}

33
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleDo.java
View File

@@ -1,33 +0,0 @@
package com.njcn.quality.pojo.po;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/14 20:59
*/
@Data
@TableName("ele_do")
public class EleDo {
private static final long serialVersionUID = 1L;
private String id;
private String name;
private String anotherName;
private Integer idx;
private Integer curSts;
private Integer ctlSts;
private String classId;
}

40
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleEpdPqd.java
View File

@@ -1,40 +0,0 @@
package com.njcn.quality.pojo.po;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/14 19:57
*/
@Data
@TableName("ele_epd_pqd")
public class EleEpdPqd {
private static final long serialVersionUID = 1L;
private String id;
private String name;
private String anotherName;
private Integer idx;
private String type;
private String phase;
private String unit;
private Integer harmStart;
private Integer harmEnd;
private String classId;
private String statMethod;
}

28
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleEvt.java
View File

@@ -1,28 +0,0 @@
package com.njcn.quality.pojo.po;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/14 20:06
*/
@Data
@TableName("ele_evt")
public class EleEvt {
private static final long serialVersionUID = 1L;
private String id;
private String name;
private String anotherName;
private Integer idx;
private String type;
}

29
pqs-quality/quality-api/src/main/java/com/njcn/quality/pojo/po/EleEvtParm.java
View File

@@ -1,29 +0,0 @@
package com.njcn.quality.pojo.po;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2022/3/14 20:26
*/
@Data
@TableName("ele_evt_parm")
public class EleEvtParm {
private static final long serialVersionUID = 1L;
private String id;
private String pid;
private String name;
private String type;
private String data;
}

Some files were not shown because too many files have changed in this diff Show More