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

清洗预处理模块

Browse Source
This commit is contained in:
hongawen
2022-11-25 15:22:25 +08:00
parent 770ca9a61d
commit 0442bd5184
267 changed files with 1611 additions and 39382 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
pqs-device/device-boot/pom.xml
View File

@@ -19,18 +19,18 @@
</properties> </properties>
<dependencies> <dependencies>
<dependency>
<groupId>com.njcn</groupId>
<artifactId>pq-device-boot</artifactId>
<version>${project.version}</version>
</dependency>
<!-- <dependency>--> <!-- <dependency>-->
<!-- <groupId>com.njcn</groupId>--> <!-- <groupId>com.njcn</groupId>-->
<!-- <artifactId>pms-device-boot</artifactId>--> <!-- <artifactId>pq-device-boot</artifactId>-->
<!-- <version>${project.version}</version>--> <!-- <version>${project.version}</version>-->
<!-- </dependency>--> <!-- </dependency>-->
<dependency>
<groupId>com.njcn</groupId>
<artifactId>pms-device-boot</artifactId>
<version>${project.version}</version>
</dependency>
<dependency> <dependency>
<groupId>com.njcn</groupId> <groupId>com.njcn</groupId>
<artifactId>common-swagger</artifactId> <artifactId>common-swagger</artifactId>

820
pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/RMpInharmonicVRateReportD.java
View File

File diff suppressed because it is too large Load Diff

1
pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/RMpPollutionDPO.java
View File

@@ -24,7 +24,6 @@ import java.util.Date;
/** /**
* 单位污区图统计日表 * 单位污区图统计日表
*/ */
@ApiModel(value = "com-njcn-harmonic-pojo-po-RMpPollutionDPO")
@Data @Data
@AllArgsConstructor @AllArgsConstructor
@NoArgsConstructor @NoArgsConstructor

31
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/line/CoustmReportFeignClient.java
View File

@@ -1,31 +0,0 @@
package com.njcn.prepare.harmonic.api.line;
import com.njcn.common.pojo.constant.ServerInfo;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.prepare.harmonic.api.line.fallback.CoustomReportFeignClientFallbackFactory;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
/**
* 自定义报表
* @author qijian
* @date 2022/10/20
*/
@FeignClient(
value = ServerInfo.HARMONIC_PREPARE,//对应模块名
path = "/report",//对应controller请求类
fallbackFactory = CoustomReportFeignClientFallbackFactory.class//服务降级处理类
)
public interface CoustmReportFeignClient {
/**
* 批量处理报表
* @author qijian
* @date 2022/10/19
*/
@PostMapping("/batchReport")
HttpResult<Boolean> batchReport(@RequestBody LineParam reportParam);
}

31
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/line/DayDataFeignClient.java
View File

@@ -1,31 +0,0 @@
package com.njcn.prepare.harmonic.api.line;
import com.njcn.common.pojo.constant.ServerInfo;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.prepare.harmonic.api.line.fallback.DayDataFeignClientFallbackFactory;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
/**
* 自定义报表
* @author qijian
* @date 2022/10/20
*/
@FeignClient(
value = ServerInfo.HARMONIC_PREPARE,//对应模块名
path = "/daydata",//对应controller请求类
fallbackFactory = DayDataFeignClientFallbackFactory.class//服务降级处理类
)
public interface DayDataFeignClient {
/**
* 批量处理报表
* @author qijian
* @date 2022/10/19
*/
@PostMapping("/dayDataHanlder")
HttpResult<Boolean> dayDataHanlder(@RequestBody LineParam jobParam);
}

27
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/line/DistortionRateFeignClient.java
View File

@@ -1,27 +0,0 @@
package com.njcn.prepare.harmonic.api.line;
import com.njcn.common.pojo.constant.ServerInfo;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.prepare.harmonic.api.line.fallback.DistortionRateFeignClientFallbackFactory;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
/**
* 谐波畸变率
* @author xiaoyao
* @version 1.0.0
* @createTime 2022/11/4 15:58
*/
@FeignClient(
value = ServerInfo.HARMONIC_PREPARE,
path = "/distortion",
fallbackFactory = DistortionRateFeignClientFallbackFactory.class
)
public interface DistortionRateFeignClient {
@PostMapping("/distortionRate")
HttpResult<String> distortionRate(@RequestBody @Validated LineParam lineParam);
}

28
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/line/HarmonicGeneralFeignClient.java
View File

@@ -1,28 +0,0 @@
package com.njcn.prepare.harmonic.api.line;
import com.njcn.common.pojo.constant.ServerInfo;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.prepare.harmonic.api.line.fallback.DistortionRateFeignClientFallbackFactory;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
/**
* 稳态综合评估
* @author xiaoyao
* @version 1.0.0
* @createTime 2022/11/7 15:11
*/
@FeignClient(
value = ServerInfo.HARMONIC_PREPARE,
path = "/general",
fallbackFactory = DistortionRateFeignClientFallbackFactory.class
)
public interface HarmonicGeneralFeignClient {
@PostMapping("/generalData")
HttpResult<String> generalData(@RequestBody @Validated LineParam lineParam);
}

27
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/line/HarmonicMetricFeignClient.java
View File

@@ -1,27 +0,0 @@
package com.njcn.prepare.harmonic.api.line;
import com.njcn.common.pojo.constant.ServerInfo;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.prepare.harmonic.api.line.fallback.HarmonicMetricFeignClientFallbackFactory;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
/**
* @author xiaoyao
* @version 1.0.0
* @createTime 2022/11/7 15:12
*/
@FeignClient(
value = ServerInfo.HARMONIC_PREPARE,
path = "/metric",
fallbackFactory = HarmonicMetricFeignClientFallbackFactory.class
)
public interface HarmonicMetricFeignClient {
@PostMapping("/metricData")
HttpResult<String> metricData(@RequestBody @Validated LineParam lineParam);
}

32
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/line/IntegrityFeignClient.java
View File

@@ -1,32 +0,0 @@
package com.njcn.prepare.harmonic.api.line;
import com.njcn.common.pojo.constant.ServerInfo;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.prepare.harmonic.api.line.fallback.IntegrityFeignClientFallbackFactory;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
/**
* 自定义报表
* @author qijian
* @date 2022/10/20
*/
@FeignClient(
value = ServerInfo.HARMONIC_PREPARE,//对应模块名
path = "/integrity",//对应controller请求类
fallbackFactory = IntegrityFeignClientFallbackFactory.class//服务降级处理类
)
public interface IntegrityFeignClient {
/**
* 批量处理报表
* @author qijian
* @date 2022/10/19
*/
@PostMapping("/computeDataIntegrity")
HttpResult<String> computeDataIntegrity(@RequestBody @Validated LineParam lineParam);
}

32
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/line/LimitTargetFeignClient.java
View File

@@ -1,32 +0,0 @@
package com.njcn.prepare.harmonic.api.line;
import com.njcn.common.pojo.constant.ServerInfo;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.prepare.harmonic.api.line.fallback.LimitTargetFeignClientFallbackFactory;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
/**
* 自定义报表
* @author qijian
* @date 2022/10/20
*/
@FeignClient(
value = ServerInfo.HARMONIC_PREPARE,//对应模块名
path = "/limitTarget",//对应controller请求类
fallbackFactory = LimitTargetFeignClientFallbackFactory.class//服务降级处理类
)
public interface LimitTargetFeignClient {
/**
* 批量处理报表
* @author qijian
* @date 2022/10/19
*/
@PostMapping("/getLimitTargetData")
HttpResult<String> getLimitTargetData(@RequestBody @Validated LineParam lineParam);
}

29
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/line/LimitrateFeignClient.java
View File

@@ -1,29 +0,0 @@
package com.njcn.prepare.harmonic.api.line;
import com.njcn.common.pojo.constant.ServerInfo;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.prepare.harmonic.api.line.fallback.LimitrateFeignClientFallbackFactory;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
/**
* 自定义报表
* @author qijian
* @date 2022/10/20
*/
@FeignClient(
value = ServerInfo.HARMONIC_PREPARE,//对应模块名
path = "/limitrate",//对应controller请求类
fallbackFactory = LimitrateFeignClientFallbackFactory.class//服务降级处理类
)
public interface LimitrateFeignClient {
/**
* 越限
*/
@PostMapping("/LimitRateHanlder")
HttpResult<Boolean> limitRateHanlder(@RequestBody LineParam limitRateHanlderParam );
}

32
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/line/NormalLimitFeignClient.java
View File

@@ -1,32 +0,0 @@
package com.njcn.prepare.harmonic.api.line;
import com.njcn.common.pojo.constant.ServerInfo;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.prepare.harmonic.api.line.fallback.NormalFeignClientFallbackFactory;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
/**
*
* @author denghaujun
* @date 2022/10/20
*/
@FeignClient(
value = ServerInfo.HARMONIC_PREPARE,//对应模块名
path = "/normalLimit",//对应controller请求类
fallbackFactory = NormalFeignClientFallbackFactory.class//服务降级处理类
)
public interface NormalLimitFeignClient {
/**
*
* @author denghaujun
* @date 2022/10/19
*/
@PostMapping("/getNormLimitData")
HttpResult<String> getNormLimitData(@RequestBody @Validated LineParam lineParam) ;
}

30
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/line/OnlineRateFeignClient.java
View File

@@ -1,30 +0,0 @@
package com.njcn.prepare.harmonic.api.line;
import com.njcn.common.pojo.constant.ServerInfo;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.prepare.harmonic.api.line.fallback.OnlineRateFeignClientFallbackFactory;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
/**
* 自定义报表
* @author qijian
* @date 2022/10/20
*/
@FeignClient(
value = ServerInfo.HARMONIC_PREPARE,//对应模块名
path = "/onlineRate",//对应controller请求类
fallbackFactory = OnlineRateFeignClientFallbackFactory.class//服务降级处理类
)
public interface OnlineRateFeignClient {
/**
* 在线率
*/
@PostMapping("/getOnlineRateData")
HttpResult<String> getOnlineRateData(@RequestBody @Validated LineParam lineParam);
}

30
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/line/PollutionFeignClient.java
View File

@@ -1,30 +0,0 @@
package com.njcn.prepare.harmonic.api.line;
import com.njcn.common.pojo.constant.ServerInfo;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.prepare.harmonic.api.line.fallback.PollutionFeignClientFallbackFactory;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
/**
* 自定义报表
* @author qijian
* @date 2022/10/20
*/
@FeignClient(
value = ServerInfo.HARMONIC_PREPARE,//对应模块名
path = "/pollution",//对应controller请求类
fallbackFactory = PollutionFeignClientFallbackFactory.class//服务降级处理类
)
public interface PollutionFeignClient {
/**
* 污区
*/
@PostMapping("/processPollutionData")
HttpResult<String> processPollutionData(@RequestBody @Validated LineParam lineParam);
}

44
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/line/fallback/CoustomReportFeignClientFallbackFactory.java
View File

@@ -1,44 +0,0 @@
package com.njcn.prepare.harmonic.api.line.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.device.pq.utils.DeviceEnumUtil;
import com.njcn.prepare.harmonic.api.line.CoustmReportFeignClient;
import com.njcn.prepare.harmonic.api.line.DayDataFeignClient;
import com.njcn.prepare.harmonic.pojo.param.LimitRateHanlderParam;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import feign.hystrix.FallbackFactory;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RequestBody;
/**
* ReportFeignClientFallbackFactory
*
* @author qijian
* @version 1.0.0
* @createTime 2022/10/24 - 9:52
*/
@Slf4j
@Component
public class CoustomReportFeignClientFallbackFactory implements FallbackFactory<CoustmReportFeignClient> {
@Override
public CoustmReportFeignClient create(Throwable throwable) {
Enum<?> exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK;
if (throwable.getCause() instanceof BusinessException) {
BusinessException businessException = (BusinessException)throwable.getCause();
exceptionEnum = DeviceEnumUtil.getExceptionEnum(businessException.getResult());
}
Enum<?> finalExceptionEnum = exceptionEnum;
return new CoustmReportFeignClient() {
@Override
public HttpResult<Boolean> batchReport(@RequestBody LineParam reportParam){
log.error("{}异常，降级处理，异常为：{}", "生成自定义报表: ", throwable.toString());
throw new BusinessException(finalExceptionEnum);
}
};
}
}

42
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/line/fallback/DayDataFeignClientFallbackFactory.java
View File

@@ -1,42 +0,0 @@
package com.njcn.prepare.harmonic.api.line.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.device.pq.utils.DeviceEnumUtil;
import com.njcn.prepare.harmonic.api.line.DayDataFeignClient;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import feign.hystrix.FallbackFactory;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RequestBody;
/**
* ReportFeignClientFallbackFactory
*
* @author qijian
* @version 1.0.0
* @createTime 2022/10/24 - 9:52
*/
@Slf4j
@Component
public class DayDataFeignClientFallbackFactory implements FallbackFactory<DayDataFeignClient> {
@Override
public DayDataFeignClient create(Throwable throwable) {
Enum<?> exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK;
if (throwable.getCause() instanceof BusinessException) {
BusinessException businessException = (BusinessException)throwable.getCause();
exceptionEnum = DeviceEnumUtil.getExceptionEnum(businessException.getResult());
}
Enum<?> finalExceptionEnum = exceptionEnum;
return new DayDataFeignClient() {
@Override
public HttpResult<Boolean> dayDataHanlder(@RequestBody LineParam jobParam){
log.error("{}异常，降级处理，异常为：{}", "Date数据转Day数据: ", throwable.toString());
throw new BusinessException(finalExceptionEnum);
}
};
}
}

40
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/line/fallback/DistortionRateFeignClientFallbackFactory.java
View File

@@ -1,40 +0,0 @@
package com.njcn.prepare.harmonic.api.line.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.device.pq.utils.DeviceEnumUtil;
import com.njcn.prepare.harmonic.api.line.DistortionRateFeignClient;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import feign.hystrix.FallbackFactory;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.RequestBody;
/**
* @author xiaoyao
* @version 1.0.0
* @createTime 2022/11/7 14:37
*/
@Slf4j
@Component
public class DistortionRateFeignClientFallbackFactory implements FallbackFactory<DistortionRateFeignClient> {
@Override
public DistortionRateFeignClient create(Throwable throwable) {
Enum<?> exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK;
if (throwable.getCause() instanceof BusinessException) {
BusinessException businessException = (BusinessException)throwable.getCause();
exceptionEnum = DeviceEnumUtil.getExceptionEnum(businessException.getResult());
}
Enum<?> finalExceptionEnum = exceptionEnum;
return new DistortionRateFeignClient() {
@Override
public HttpResult<String> distortionRate(@RequestBody @Validated LineParam lineParam){
log.error("{}异常，降级处理，异常为：{}", "谐波畸变率: ", throwable.toString());
throw new BusinessException(finalExceptionEnum);
}
};
}
}

40
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/line/fallback/HarmonicGeneralFeignClientFallbackFactory.java
View File

@@ -1,40 +0,0 @@
package com.njcn.prepare.harmonic.api.line.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.device.pq.utils.DeviceEnumUtil;
import com.njcn.prepare.harmonic.api.line.HarmonicGeneralFeignClient;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import feign.hystrix.FallbackFactory;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.RequestBody;
/**
* @author xiaoyao
* @version 1.0.0
* @createTime 2022/11/7 15:17
*/
@Slf4j
@Component
public class HarmonicGeneralFeignClientFallbackFactory implements FallbackFactory<HarmonicGeneralFeignClient> {
@Override
public HarmonicGeneralFeignClient create(Throwable throwable) {
Enum<?> exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK;
if (throwable.getCause() instanceof BusinessException) {
BusinessException businessException = (BusinessException)throwable.getCause();
exceptionEnum = DeviceEnumUtil.getExceptionEnum(businessException.getResult());
}
Enum<?> finalExceptionEnum = exceptionEnum;
return new HarmonicGeneralFeignClient() {
@Override
public HttpResult<String> generalData(@RequestBody @Validated LineParam lineParam){
log.error("{}异常，降级处理，异常为：{}", "稳态综合评估: ", throwable.toString());
throw new BusinessException(finalExceptionEnum);
}
};
}
}

40
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/line/fallback/HarmonicMetricFeignClientFallbackFactory.java
View File

@@ -1,40 +0,0 @@
package com.njcn.prepare.harmonic.api.line.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.device.pq.utils.DeviceEnumUtil;
import com.njcn.prepare.harmonic.api.line.HarmonicMetricFeignClient;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import feign.hystrix.FallbackFactory;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.RequestBody;
/**
* @author xiaoyao
* @version 1.0.0
* @createTime 2022/11/7 15:14
*/
@Slf4j
@Component
public class HarmonicMetricFeignClientFallbackFactory implements FallbackFactory<HarmonicMetricFeignClient> {
@Override
public HarmonicMetricFeignClient create(Throwable throwable) {
Enum<?> exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK;
if (throwable.getCause() instanceof BusinessException) {
BusinessException businessException = (BusinessException)throwable.getCause();
exceptionEnum = DeviceEnumUtil.getExceptionEnum(businessException.getResult());
}
Enum<?> finalExceptionEnum = exceptionEnum;
return new HarmonicMetricFeignClient() {
@Override
public HttpResult<String> metricData(@RequestBody @Validated LineParam lineParam){
log.error("{}异常，降级处理，异常为：{}", "稳态指标评估: ", throwable.toString());
throw new BusinessException(finalExceptionEnum);
}
};
}
}

39
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/line/fallback/IntegrityFeignClientFallbackFactory.java
View File

@@ -1,39 +0,0 @@
package com.njcn.prepare.harmonic.api.line.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.device.pq.utils.DeviceEnumUtil;
import com.njcn.prepare.harmonic.api.line.IntegrityFeignClient;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import feign.hystrix.FallbackFactory;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.RequestBody;
/**
* IntegrityFeignClientFallbackFactory
*/
@Slf4j
@Component
public class IntegrityFeignClientFallbackFactory implements FallbackFactory<IntegrityFeignClient> {
@Override
public IntegrityFeignClient create(Throwable throwable) {
Enum<?> exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK;
if (throwable.getCause() instanceof BusinessException) {
BusinessException businessException = (BusinessException)throwable.getCause();
exceptionEnum = DeviceEnumUtil.getExceptionEnum(businessException.getResult());
}
Enum<?> finalExceptionEnum = exceptionEnum;
return new IntegrityFeignClient() {
@Override
public HttpResult<String> computeDataIntegrity(@RequestBody @Validated LineParam lineParam) {
log.error("{}异常，降级处理，异常为：{}", "数据完整性处理: ", throwable.toString());
throw new BusinessException(finalExceptionEnum);
}
};
}
}

43
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/line/fallback/LimitTargetFeignClientFallbackFactory.java
View File

@@ -1,43 +0,0 @@
package com.njcn.prepare.harmonic.api.line.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.device.pq.utils.DeviceEnumUtil;
import com.njcn.prepare.harmonic.api.line.LimitTargetFeignClient;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import feign.hystrix.FallbackFactory;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.RequestBody;
/**
* ReportFeignClientFallbackFactory
*
* @author qijian
* @version 1.0.0
* @createTime 2022/10/24 - 9:52
*/
@Slf4j
@Component
public class LimitTargetFeignClientFallbackFactory implements FallbackFactory<LimitTargetFeignClient> {
@Override
public LimitTargetFeignClient create(Throwable throwable) {
Enum<?> exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK;
if (throwable.getCause() instanceof BusinessException) {
BusinessException businessException = (BusinessException)throwable.getCause();
exceptionEnum = DeviceEnumUtil.getExceptionEnum(businessException.getResult());
}
Enum<?> finalExceptionEnum = exceptionEnum;
return new LimitTargetFeignClient() {
@Override
public HttpResult<String> getLimitTargetData(@RequestBody @Validated LineParam lineParam) {
log.error("{}异常，降级处理，异常为：{}", "越限数据: ", throwable.toString());
throw new BusinessException(finalExceptionEnum);
}
};
}
}

42
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/line/fallback/LimitrateFeignClientFallbackFactory.java
View File

@@ -1,42 +0,0 @@
package com.njcn.prepare.harmonic.api.line.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.device.pq.utils.DeviceEnumUtil;
import com.njcn.prepare.harmonic.api.line.LimitrateFeignClient;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import feign.hystrix.FallbackFactory;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RequestBody;
/**
* ReportFeignClientFallbackFactory
*
* @author qijian
* @version 1.0.0
* @createTime 2022/10/24 - 9:52
*/
@Slf4j
@Component
public class LimitrateFeignClientFallbackFactory implements FallbackFactory<LimitrateFeignClient> {
@Override
public LimitrateFeignClient create(Throwable throwable) {
Enum<?> exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK;
if (throwable.getCause() instanceof BusinessException) {
BusinessException businessException = (BusinessException)throwable.getCause();
exceptionEnum = DeviceEnumUtil.getExceptionEnum(businessException.getResult());
}
Enum<?> finalExceptionEnum = exceptionEnum;
return new LimitrateFeignClient() {
@Override
public HttpResult<Boolean> limitRateHanlder(@RequestBody LineParam limitRateHanlderParam ){
log.error("{}异常，降级处理，异常为：{}", "越限数据处理: ", throwable.toString());
throw new BusinessException(finalExceptionEnum);
}
};
}
}

37
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/line/fallback/NormalFeignClientFallbackFactory.java
View File

@@ -1,37 +0,0 @@
package com.njcn.prepare.harmonic.api.line.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.device.pq.utils.DeviceEnumUtil;
import com.njcn.prepare.harmonic.api.line.NormalLimitFeignClient;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import feign.hystrix.FallbackFactory;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
/**
* NormalFeignClientFallbackFactory
*/
@Slf4j
@Component
public class NormalFeignClientFallbackFactory implements FallbackFactory<NormalLimitFeignClient> {
@Override
public NormalLimitFeignClient create(Throwable throwable) {
Enum<?> exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK;
if (throwable.getCause() instanceof BusinessException) {
BusinessException businessException = (BusinessException)throwable.getCause();
exceptionEnum = DeviceEnumUtil.getExceptionEnum(businessException.getResult());
}
Enum<?> finalExceptionEnum = exceptionEnum;
return new NormalLimitFeignClient() {
@Override
public HttpResult<String> getNormLimitData(LineParam lineParam) {
log.error("{}异常，降级处理，异常为：{}", "告警数据: ", throwable.toString());
throw new BusinessException(finalExceptionEnum);
}
};
}
}

39
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/line/fallback/OnlineRateFeignClientFallbackFactory.java
View File

@@ -1,39 +0,0 @@
package com.njcn.prepare.harmonic.api.line.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.device.pq.utils.DeviceEnumUtil;
import com.njcn.prepare.harmonic.api.line.OnlineRateFeignClient;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import feign.hystrix.FallbackFactory;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.RequestBody;
/**
* OnlineRateFeignClientFallbackFactory
*/
@Slf4j
@Component
public class OnlineRateFeignClientFallbackFactory implements FallbackFactory<OnlineRateFeignClient> {
@Override
public OnlineRateFeignClient create(Throwable throwable) {
Enum<?> exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK;
if (throwable.getCause() instanceof BusinessException) {
BusinessException businessException = (BusinessException)throwable.getCause();
exceptionEnum = DeviceEnumUtil.getExceptionEnum(businessException.getResult());
}
Enum<?> finalExceptionEnum = exceptionEnum;
return new OnlineRateFeignClient() {
@Override
public HttpResult<String> getOnlineRateData(@RequestBody @Validated LineParam lineParam){
log.error("{}异常，降级处理，异常为：{}", "在线率: ", throwable.toString());
throw new BusinessException(finalExceptionEnum);
}
};
}
}

40
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/line/fallback/PollutionFeignClientFallbackFactory.java
View File

@@ -1,40 +0,0 @@
package com.njcn.prepare.harmonic.api.line.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.device.pq.utils.DeviceEnumUtil;
import com.njcn.prepare.harmonic.api.line.PollutionFeignClient;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import feign.hystrix.FallbackFactory;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.RequestBody;
/**
* PollutionFeignClientFallbackFactory
*
*/
@Slf4j
@Component
public class PollutionFeignClientFallbackFactory implements FallbackFactory<PollutionFeignClient> {
@Override
public PollutionFeignClient create(Throwable throwable) {
Enum<?> exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK;
if (throwable.getCause() instanceof BusinessException) {
BusinessException businessException = (BusinessException)throwable.getCause();
exceptionEnum = DeviceEnumUtil.getExceptionEnum(businessException.getResult());
}
Enum<?> finalExceptionEnum = exceptionEnum;
return new PollutionFeignClient() {
@Override
public HttpResult<String> processPollutionData(@RequestBody @Validated LineParam lineParam){
log.error("{}异常，降级处理，异常为：{}", "污区数据: ", throwable.toString());
throw new BusinessException(finalExceptionEnum);
}
};
}
}

10
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/api/voltage/VoltageFeignClient.java
View File

@@ -1,10 +0,0 @@
package com.njcn.prepare.harmonic.api.voltage;
/**
* @author qijian
* @version 1.0.0
* @date 2022年10月24日 20:13
*/
public interface VoltageFeignClient {
}

62
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/constant/InfluxdbPOConverter.java
View File

@@ -1,7 +1,9 @@
package com.njcn.prepare.harmonic.constant; package com.njcn.prepare.harmonic.constant;
import com.njcn.prepare.harmonic.pojo.po.*; import com.njcn.harmonic.pojo.po.*;
import com.njcn.prepare.harmonic.pojo.po.line.*; import com.njcn.prepare.harmonic.pojo.influxdb.po.*;
import com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpFlickerReportDPO;
import com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpInharmonicIMagReportDPO;
import org.mapstruct.Mapper; import org.mapstruct.Mapper;
import org.mapstruct.Mapping; import org.mapstruct.Mapping;
import org.mapstruct.factory.Mappers; import org.mapstruct.factory.Mappers;
@@ -73,7 +75,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "v49", target = "harmonicVoltageContent49Max") @Mapping(source = "v49", target = "harmonicVoltageContent49Max")
@Mapping(source = "v50", target = "harmonicVoltageContent50Max") @Mapping(source = "v50", target = "harmonicVoltageContent50Max")
public RMpHarmonicVRateReportDPO dataVPOTORMpHarmonicPReportDPOMax(DataHarmRateVPO dataVPO); public RMpHarmonicVRateReportD dataVPOTORMpHarmonicPReportDPOMax(DataHarmRateVPO dataVPO);
@Mapping(source = "v1", target = "fundamentalVoltageMin") @Mapping(source = "v1", target = "fundamentalVoltageMin")
@Mapping(source = "v2", target = "harmonicVoltageContent2Min") @Mapping(source = "v2", target = "harmonicVoltageContent2Min")
@@ -125,7 +127,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "v48", target = "harmonicVoltageContent48Min") @Mapping(source = "v48", target = "harmonicVoltageContent48Min")
@Mapping(source = "v49", target = "harmonicVoltageContent49Min") @Mapping(source = "v49", target = "harmonicVoltageContent49Min")
@Mapping(source = "v50", target = "harmonicVoltageContent50Min") @Mapping(source = "v50", target = "harmonicVoltageContent50Min")
public RMpHarmonicVRateReportDPO dataVPOTORMpHarmonicPReportDPOMin(DataHarmRateVPO dataVPO); public RMpHarmonicVRateReportD dataVPOTORMpHarmonicPReportDPOMin(DataHarmRateVPO dataVPO);
@Mapping(source = "v1", target = "fundamentalVoltageAvg") @Mapping(source = "v1", target = "fundamentalVoltageAvg")
@@ -178,7 +180,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "v48", target = "harmonicVoltageContent48Avg") @Mapping(source = "v48", target = "harmonicVoltageContent48Avg")
@Mapping(source = "v49", target = "harmonicVoltageContent49Avg") @Mapping(source = "v49", target = "harmonicVoltageContent49Avg")
@Mapping(source = "v50", target = "harmonicVoltageContent50Avg") @Mapping(source = "v50", target = "harmonicVoltageContent50Avg")
public RMpHarmonicVRateReportDPO dataVPOTORMpHarmonicPReportDPOAvg(DataHarmRateVPO dataVPO); public RMpHarmonicVRateReportD dataVPOTORMpHarmonicPReportDPOAvg(DataHarmRateVPO dataVPO);
@Mapping(source = "v1", target = "fundamentalVoltage95") @Mapping(source = "v1", target = "fundamentalVoltage95")
@@ -231,7 +233,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "v48", target = "harmonicVoltageContent4895") @Mapping(source = "v48", target = "harmonicVoltageContent4895")
@Mapping(source = "v49", target = "harmonicVoltageContent4995") @Mapping(source = "v49", target = "harmonicVoltageContent4995")
@Mapping(source = "v50", target = "harmonicVoltageContent5095") @Mapping(source = "v50", target = "harmonicVoltageContent5095")
public RMpHarmonicVRateReportDPO dataVPOTORMpHarmonicPReportDPO95(DataHarmRateVPO dataVPO); public RMpHarmonicVRateReportD dataVPOTORMpHarmonicPReportDPO95(DataHarmRateVPO dataVPO);
/*DataIPO*/ /*DataIPO*/
@@ -286,7 +288,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "i48", target = "harmonicCurrentEffective48Max") @Mapping(source = "i48", target = "harmonicCurrentEffective48Max")
@Mapping(source = "i49", target = "harmonicCurrentEffective49Max") @Mapping(source = "i49", target = "harmonicCurrentEffective49Max")
@Mapping(source = "i50", target = "harmonicCurrentEffective50Max") @Mapping(source = "i50", target = "harmonicCurrentEffective50Max")
public RMpHarmonicIMagReportDPO dataIPOTORMpHarmonicIMagReportDPOMax(DataIPO dataIPO); public RMpHarmonicIMagReportD dataIPOTORMpHarmonicIMagReportDPOMax(DataIPO dataIPO);
@Mapping(source = "IThd", target = "harmonicCurrentThdMin") @Mapping(source = "IThd", target = "harmonicCurrentThdMin")
@Mapping(source = "i1", target = "fundamentalCurrentMin") @Mapping(source = "i1", target = "fundamentalCurrentMin")
@@ -339,7 +341,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "i48", target = "harmonicCurrentEffective48Min") @Mapping(source = "i48", target = "harmonicCurrentEffective48Min")
@Mapping(source = "i49", target = "harmonicCurrentEffective49Min") @Mapping(source = "i49", target = "harmonicCurrentEffective49Min")
@Mapping(source = "i50", target = "harmonicCurrentEffective50Min") @Mapping(source = "i50", target = "harmonicCurrentEffective50Min")
public RMpHarmonicIMagReportDPO dataIPOTORMpHarmonicIMagReportDPOMin(DataIPO dataIPO); public RMpHarmonicIMagReportD dataIPOTORMpHarmonicIMagReportDPOMin(DataIPO dataIPO);
@Mapping(source = "IThd", target = "harmonicCurrentThdAvg") @Mapping(source = "IThd", target = "harmonicCurrentThdAvg")
@@ -393,7 +395,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "i48", target = "harmonicCurrentEffective48Avg") @Mapping(source = "i48", target = "harmonicCurrentEffective48Avg")
@Mapping(source = "i49", target = "harmonicCurrentEffective49Avg") @Mapping(source = "i49", target = "harmonicCurrentEffective49Avg")
@Mapping(source = "i50", target = "harmonicCurrentEffective50Avg") @Mapping(source = "i50", target = "harmonicCurrentEffective50Avg")
public RMpHarmonicIMagReportDPO dataIPOTORMpHarmonicIMagReportDPOAvg(DataIPO dataIPO); public RMpHarmonicIMagReportD dataIPOTORMpHarmonicIMagReportDPOAvg(DataIPO dataIPO);
@Mapping(source = "IThd", target = "harmonicCurrentThd95") @Mapping(source = "IThd", target = "harmonicCurrentThd95")
@@ -447,7 +449,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "i48", target = "harmonicCurrentEffective4895") @Mapping(source = "i48", target = "harmonicCurrentEffective4895")
@Mapping(source = "i49", target = "harmonicCurrentEffective4995") @Mapping(source = "i49", target = "harmonicCurrentEffective4995")
@Mapping(source = "i50", target = "harmonicCurrentEffective5095") @Mapping(source = "i50", target = "harmonicCurrentEffective5095")
public RMpHarmonicIMagReportDPO dataIPOTORMpHarmonicIMagReportDPO95(DataIPO dataIPO); public RMpHarmonicIMagReportD dataIPOTORMpHarmonicIMagReportDPO95(DataIPO dataIPO);
/*RMpFlickerReportDPO*/ /*RMpFlickerReportDPO*/
@@ -517,7 +519,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "i48", target = "i48Min") @Mapping(source = "i48", target = "i48Min")
@Mapping(source = "i49", target = "i49Min") @Mapping(source = "i49", target = "i49Min")
@Mapping(source = "i50", target = "i50Min") @Mapping(source = "i50", target = "i50Min")
public RMpHarmonicIRateReportDPO RMpHarmonicIRateReportDPOConverterMin(DataHarmRateIPO dataHarmRateIPO); public RMpHarmonicIRateReportD RMpHarmonicIRateReportDPOConverterMin(DataHarmRateIPO dataHarmRateIPO);
@Mapping(source = "i2", target = "i2Max") @Mapping(source = "i2", target = "i2Max")
@Mapping(source = "i3", target = "i3Max") @Mapping(source = "i3", target = "i3Max")
@@ -568,7 +570,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "i48", target = "i48Max") @Mapping(source = "i48", target = "i48Max")
@Mapping(source = "i49", target = "i49Max") @Mapping(source = "i49", target = "i49Max")
@Mapping(source = "i50", target = "i50Max") @Mapping(source = "i50", target = "i50Max")
public RMpHarmonicIRateReportDPO RMpHarmonicIRateReportDPOConverterMax(DataHarmRateIPO dataHarmRateIPO); public RMpHarmonicIRateReportD RMpHarmonicIRateReportDPOConverterMax(DataHarmRateIPO dataHarmRateIPO);
@Mapping(source = "i2", target = "i2Avg") @Mapping(source = "i2", target = "i2Avg")
@@ -620,7 +622,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "i48", target = "i48Avg") @Mapping(source = "i48", target = "i48Avg")
@Mapping(source = "i49", target = "i49Avg") @Mapping(source = "i49", target = "i49Avg")
@Mapping(source = "i50", target = "i50Avg") @Mapping(source = "i50", target = "i50Avg")
public RMpHarmonicIRateReportDPO RMpHarmonicIRateReportDPOConverterAvg(DataHarmRateIPO dataHarmRateIPO); public RMpHarmonicIRateReportD RMpHarmonicIRateReportDPOConverterAvg(DataHarmRateIPO dataHarmRateIPO);
@Mapping(source = "i2", target = "i2Cp95") @Mapping(source = "i2", target = "i2Cp95")
@Mapping(source = "i3", target = "i3Cp95") @Mapping(source = "i3", target = "i3Cp95")
@@ -671,7 +673,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "i48", target = "i48Cp95") @Mapping(source = "i48", target = "i48Cp95")
@Mapping(source = "i49", target = "i49Cp95") @Mapping(source = "i49", target = "i49Cp95")
@Mapping(source = "i50", target = "i50Cp95") @Mapping(source = "i50", target = "i50Cp95")
public RMpHarmonicIRateReportDPO RMpHarmonicIRateReportDPOConverter95(DataHarmRateIPO dataHarmRateIPO); public RMpHarmonicIRateReportD RMpHarmonicIRateReportDPOConverter95(DataHarmRateIPO dataHarmRateIPO);
/*RMpInharmonicIRateReportDPO*/ /*RMpInharmonicIRateReportDPO*/
@Mapping(source = "i2", target = "inharmI2Min") @Mapping(source = "i2", target = "inharmI2Min")
@Mapping(source = "i3", target = "inharmI3Min") @Mapping(source = "i3", target = "inharmI3Min")
@@ -722,7 +724,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "i48", target = "inharmI48Min") @Mapping(source = "i48", target = "inharmI48Min")
@Mapping(source = "i49", target = "inharmI49Min") @Mapping(source = "i49", target = "inharmI49Min")
@Mapping(source = "i50", target = "inharmI50Min") @Mapping(source = "i50", target = "inharmI50Min")
public RMpInharmonicIRateReportDPO RMpInharmonicIRateReportDPOConverterMin(DataInHarmRateIPO temp); public RMpInharmonicIRateReportD RMpInharmonicIRateReportDPOConverterMin(DataInHarmRateIPO temp);
@Mapping(source = "i2", target = "inharmI2Max") @Mapping(source = "i2", target = "inharmI2Max")
@Mapping(source = "i3", target = "inharmI3Max") @Mapping(source = "i3", target = "inharmI3Max")
@@ -773,7 +775,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "i48", target = "inharmI48Max") @Mapping(source = "i48", target = "inharmI48Max")
@Mapping(source = "i49", target = "inharmI49Max") @Mapping(source = "i49", target = "inharmI49Max")
@Mapping(source = "i50", target = "inharmI50Max") @Mapping(source = "i50", target = "inharmI50Max")
public RMpInharmonicIRateReportDPO RMpInharmonicIRateReportDPOConverterMax(DataInHarmRateIPO temp); public RMpInharmonicIRateReportD RMpInharmonicIRateReportDPOConverterMax(DataInHarmRateIPO temp);
@Mapping(source = "i2", target = "inharmI2Avg") @Mapping(source = "i2", target = "inharmI2Avg")
@@ -825,7 +827,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "i48", target = "inharmI48Avg") @Mapping(source = "i48", target = "inharmI48Avg")
@Mapping(source = "i49", target = "inharmI49Avg") @Mapping(source = "i49", target = "inharmI49Avg")
@Mapping(source = "i50", target = "inharmI50Avg") @Mapping(source = "i50", target = "inharmI50Avg")
public RMpInharmonicIRateReportDPO RMpInharmonicIRateReportDPOConverterAvg(DataInHarmRateIPO temp); public RMpInharmonicIRateReportD RMpInharmonicIRateReportDPOConverterAvg(DataInHarmRateIPO temp);
@Mapping(source = "i2", target = "inharmI2Cp95") @Mapping(source = "i2", target = "inharmI2Cp95")
@Mapping(source = "i3", target = "inharmI3Cp95") @Mapping(source = "i3", target = "inharmI3Cp95")
@@ -876,7 +878,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "i48", target = "inharmI48Cp95") @Mapping(source = "i48", target = "inharmI48Cp95")
@Mapping(source = "i49", target = "inharmI49Cp95") @Mapping(source = "i49", target = "inharmI49Cp95")
@Mapping(source = "i50", target = "inharmI50Cp95") @Mapping(source = "i50", target = "inharmI50Cp95")
public RMpInharmonicIRateReportDPO RMpInharmonicIRateReportDPOConverter95(DataInHarmRateIPO temp); public RMpInharmonicIRateReportD RMpInharmonicIRateReportDPOConverter95(DataInHarmRateIPO temp);
/*RMpInharmonicIMagReportDPO*/ /*RMpInharmonicIMagReportDPO*/
@Mapping(source = "i1", target = "simpleHarmonicCurrentEffective1Min") @Mapping(source = "i1", target = "simpleHarmonicCurrentEffective1Min")
@@ -1137,7 +1139,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "v48", target = "centreHarmonicVoltageContent48Min") @Mapping(source = "v48", target = "centreHarmonicVoltageContent48Min")
@Mapping(source = "v49", target = "centreHarmonicVoltageContent49Min") @Mapping(source = "v49", target = "centreHarmonicVoltageContent49Min")
@Mapping(source = "v50", target = "centreHarmonicVoltageContent50Min") @Mapping(source = "v50", target = "centreHarmonicVoltageContent50Min")
public RMpInharmonicVRateReportDPO RMpInharmonicVRateReportDPOConverterMin(DataInHarmRateVPO temp); public RMpInharmonicVRateReportD RMpInharmonicVRateReportDPOConverterMin(DataInHarmRateVPO temp);
@Mapping(source = "v1", target = "centreHarmonicVoltageContent1Max") @Mapping(source = "v1", target = "centreHarmonicVoltageContent1Max")
@Mapping(source = "v2", target = "centreHarmonicVoltageContent2Max") @Mapping(source = "v2", target = "centreHarmonicVoltageContent2Max")
@@ -1189,7 +1191,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "v48", target = "centreHarmonicVoltageContent48Max") @Mapping(source = "v48", target = "centreHarmonicVoltageContent48Max")
@Mapping(source = "v49", target = "centreHarmonicVoltageContent49Max") @Mapping(source = "v49", target = "centreHarmonicVoltageContent49Max")
@Mapping(source = "v50", target = "centreHarmonicVoltageContent50Max") @Mapping(source = "v50", target = "centreHarmonicVoltageContent50Max")
public RMpInharmonicVRateReportDPO RMpInharmonicVRateReportDPOConverterMax(DataInHarmRateVPO temp); public RMpInharmonicVRateReportD RMpInharmonicVRateReportDPOConverterMax(DataInHarmRateVPO temp);
@Mapping(source = "v1", target = "centreHarmonicVoltageContent1Avg") @Mapping(source = "v1", target = "centreHarmonicVoltageContent1Avg")
@Mapping(source = "v2", target = "centreHarmonicVoltageContent2Avg") @Mapping(source = "v2", target = "centreHarmonicVoltageContent2Avg")
@@ -1241,7 +1243,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "v48", target = "centreHarmonicVoltageContent48Avg") @Mapping(source = "v48", target = "centreHarmonicVoltageContent48Avg")
@Mapping(source = "v49", target = "centreHarmonicVoltageContent49Avg") @Mapping(source = "v49", target = "centreHarmonicVoltageContent49Avg")
@Mapping(source = "v50", target = "centreHarmonicVoltageContent50Avg") @Mapping(source = "v50", target = "centreHarmonicVoltageContent50Avg")
public RMpInharmonicVRateReportDPO RMpInharmonicVRateReportDPOConverterAvg(DataInHarmRateVPO temp); public RMpInharmonicVRateReportD RMpInharmonicVRateReportDPOConverterAvg(DataInHarmRateVPO temp);
@Mapping(source = "v1", target = "centreHarmonicVoltageContent1Cp95") @Mapping(source = "v1", target = "centreHarmonicVoltageContent1Cp95")
@Mapping(source = "v2", target = "centreHarmonicVoltageContent2Cp95") @Mapping(source = "v2", target = "centreHarmonicVoltageContent2Cp95")
@@ -1293,7 +1295,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "v48", target = "centreHarmonicVoltageContent48Cp95") @Mapping(source = "v48", target = "centreHarmonicVoltageContent48Cp95")
@Mapping(source = "v49", target = "centreHarmonicVoltageContent49Cp95") @Mapping(source = "v49", target = "centreHarmonicVoltageContent49Cp95")
@Mapping(source = "v50", target = "centreHarmonicVoltageContent50Cp95") @Mapping(source = "v50", target = "centreHarmonicVoltageContent50Cp95")
public RMpInharmonicVRateReportDPO RMpInharmonicVRateReportDPOConverter95(DataInHarmRateVPO temp); public RMpInharmonicVRateReportD RMpInharmonicVRateReportDPOConverter95(DataInHarmRateVPO temp);
/*RMpInharmonicVRateReportDPO*/ /*RMpInharmonicVRateReportDPO*/
@Mapping(source = "p1", target = "centreHarmonicVoltageContent1Min") @Mapping(source = "p1", target = "centreHarmonicVoltageContent1Min")
@@ -1346,7 +1348,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "p48", target = "centreHarmonicVoltageContent48Min") @Mapping(source = "p48", target = "centreHarmonicVoltageContent48Min")
@Mapping(source = "p49", target = "centreHarmonicVoltageContent49Min") @Mapping(source = "p49", target = "centreHarmonicVoltageContent49Min")
@Mapping(source = "p50", target = "centreHarmonicVoltageContent50Min") @Mapping(source = "p50", target = "centreHarmonicVoltageContent50Min")
public RMpInharmonicVRateReportDPO RMpHarmonicPReportDPOConverterMin(DataHarmPowerPPO temp); public RMpInharmonicVRateReportD RMpHarmonicPReportDPOConverterMin(DataHarmPowerPPO temp);
@Mapping(source = "p1", target = "centreHarmonicVoltageContent1Max") @Mapping(source = "p1", target = "centreHarmonicVoltageContent1Max")
@Mapping(source = "p2", target = "centreHarmonicVoltageContent2Max") @Mapping(source = "p2", target = "centreHarmonicVoltageContent2Max")
@@ -1398,7 +1400,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "p48", target = "centreHarmonicVoltageContent48Max") @Mapping(source = "p48", target = "centreHarmonicVoltageContent48Max")
@Mapping(source = "p49", target = "centreHarmonicVoltageContent49Max") @Mapping(source = "p49", target = "centreHarmonicVoltageContent49Max")
@Mapping(source = "p50", target = "centreHarmonicVoltageContent50Max") @Mapping(source = "p50", target = "centreHarmonicVoltageContent50Max")
public RMpInharmonicVRateReportDPO RMpHarmonicPReportDPOConverterMax(DataHarmPowerPPO temp); public RMpInharmonicVRateReportD RMpHarmonicPReportDPOConverterMax(DataHarmPowerPPO temp);
@Mapping(source = "p1", target = "centreHarmonicVoltageContent1Avg") @Mapping(source = "p1", target = "centreHarmonicVoltageContent1Avg")
@Mapping(source = "p2", target = "centreHarmonicVoltageContent2Avg") @Mapping(source = "p2", target = "centreHarmonicVoltageContent2Avg")
@@ -1450,7 +1452,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "p48", target = "centreHarmonicVoltageContent48Avg") @Mapping(source = "p48", target = "centreHarmonicVoltageContent48Avg")
@Mapping(source = "p49", target = "centreHarmonicVoltageContent49Avg") @Mapping(source = "p49", target = "centreHarmonicVoltageContent49Avg")
@Mapping(source = "p50", target = "centreHarmonicVoltageContent50Avg") @Mapping(source = "p50", target = "centreHarmonicVoltageContent50Avg")
public RMpInharmonicVRateReportDPO RMpHarmonicPReportDPOConverterAvg(DataHarmPowerPPO temp); public RMpInharmonicVRateReportD RMpHarmonicPReportDPOConverterAvg(DataHarmPowerPPO temp);
@Mapping(source = "p1", target = "centreHarmonicVoltageContent1Cp95") @Mapping(source = "p1", target = "centreHarmonicVoltageContent1Cp95")
@@ -1503,7 +1505,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "p48", target = "centreHarmonicVoltageContent48Cp95") @Mapping(source = "p48", target = "centreHarmonicVoltageContent48Cp95")
@Mapping(source = "p49", target = "centreHarmonicVoltageContent49Cp95") @Mapping(source = "p49", target = "centreHarmonicVoltageContent49Cp95")
@Mapping(source = "p50", target = "centreHarmonicVoltageContent50Cp95") @Mapping(source = "p50", target = "centreHarmonicVoltageContent50Cp95")
public RMpInharmonicVRateReportDPO RMpHarmonicPReportDPOConverter95(DataHarmPowerPPO temp); public RMpInharmonicVRateReportD RMpHarmonicPReportDPOConverter95(DataHarmPowerPPO temp);
/*RMpMeasurePhaseReportDPO*/ /*RMpMeasurePhaseReportDPO*/
@Mapping(source = "max.rms", target = "phaseVoltageEffectiveMax") @Mapping(source = "max.rms", target = "phaseVoltageEffectiveMax")
@@ -1516,7 +1518,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "max3.s", target = "spApparentPowerMax") @Mapping(source = "max3.s", target = "spApparentPowerMax")
@Mapping(source = "max2.pf", target = "spPowerFactorMax") @Mapping(source = "max2.pf", target = "spPowerFactorMax")
@Mapping(source = "max2.df", target = "spFundamentalPowerFactorMax") @Mapping(source = "max2.df", target = "spFundamentalPowerFactorMax")
public RMpMeasurePhaseReportDPO RMpMeasurePhaseReportDPOConverterMax(DataVPO max, DataIPO max1, DataHarmPowerPPO max2, DataHarmPowerSPO max3, DataHarmPowerQPO max4); public RMpMeasurePhaseReportD RMpMeasurePhaseReportDPOConverterMax(DataVPO max, DataIPO max1, DataHarmPowerPPO max2, DataHarmPowerSPO max3, DataHarmPowerQPO max4);
@Mapping(source = "min.rms", target = "phaseVoltageEffectiveMin") @Mapping(source = "min.rms", target = "phaseVoltageEffectiveMin")
@Mapping(source = "min.rmsLvr", target = "lineVoltageEffectiveMin") @Mapping(source = "min.rmsLvr", target = "lineVoltageEffectiveMin")
@@ -1528,7 +1530,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "min3.s", target = "spApparentPowerMin") @Mapping(source = "min3.s", target = "spApparentPowerMin")
@Mapping(source = "min2.pf", target = "spPowerFactorMin") @Mapping(source = "min2.pf", target = "spPowerFactorMin")
@Mapping(source = "min2.df", target = "spFundamentalPowerFactorMin") @Mapping(source = "min2.df", target = "spFundamentalPowerFactorMin")
public RMpMeasurePhaseReportDPO RMpMeasurePhaseReportDPOConverterMin(DataVPO min, DataIPO min1, DataHarmPowerPPO min2, DataHarmPowerSPO min3, DataHarmPowerQPO min4); public RMpMeasurePhaseReportD RMpMeasurePhaseReportDPOConverterMin(DataVPO min, DataIPO min1, DataHarmPowerPPO min2, DataHarmPowerSPO min3, DataHarmPowerQPO min4);
@Mapping(source = "avg.rms", target = "phaseVoltageEffectiveAvg") @Mapping(source = "avg.rms", target = "phaseVoltageEffectiveAvg")
@@ -1541,7 +1543,7 @@ public interface InfluxdbPOConverter {
@Mapping(source = "avg3.s", target = "spApparentPowerAvg") @Mapping(source = "avg3.s", target = "spApparentPowerAvg")
@Mapping(source = "avg2.pf", target = "spPowerFactorAvg") @Mapping(source = "avg2.pf", target = "spPowerFactorAvg")
@Mapping(source = "avg2.df", target = "spFundamentalPowerFactorAvg") @Mapping(source = "avg2.df", target = "spFundamentalPowerFactorAvg")
public RMpMeasurePhaseReportDPO RMpMeasurePhaseReportDPOConverterAVg(DataVPO avg, DataIPO avg1, DataHarmPowerPPO avg2, DataHarmPowerSPO avg3, DataHarmPowerQPO avg4); public RMpMeasurePhaseReportD RMpMeasurePhaseReportDPOConverterAVg(DataVPO avg, DataIPO avg1, DataHarmPowerPPO avg2, DataHarmPowerSPO avg3, DataHarmPowerQPO avg4);
@Mapping(source = "cp95.rms", target = "phaseVoltageEffective95") @Mapping(source = "cp95.rms", target = "phaseVoltageEffective95")
@@ -1554,5 +1556,5 @@ public interface InfluxdbPOConverter {
@Mapping(source = "cp953.s", target = "spApparentPower95") @Mapping(source = "cp953.s", target = "spApparentPower95")
@Mapping(source = "cp952.pf", target = "spPowerFactor95") @Mapping(source = "cp952.pf", target = "spPowerFactor95")
@Mapping(source = "cp952.df", target = "spFundamentalPowerFactor95") @Mapping(source = "cp952.df", target = "spFundamentalPowerFactor95")
public RMpMeasurePhaseReportDPO RMpMeasurePhaseReportDPOConverterCp95(DataVPO cp95, DataIPO cp951, DataHarmPowerPPO cp952, DataHarmPowerSPO cp953, DataHarmPowerQPO cp954); public RMpMeasurePhaseReportD RMpMeasurePhaseReportDPOConverterCp95(DataVPO cp95, DataIPO cp951, DataHarmPowerPPO cp952, DataHarmPowerSPO cp953, DataHarmPowerQPO cp954);
} }

8
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/LimitRateServiceTest.java
View File

@@ -1,10 +1,10 @@
package com.njcn.prepare.harmonic.controller; package com.njcn.prepare.harmonic.controller;
import com.njcn.harmonic.pojo.po.ExcelRptTemp;
import com.njcn.influxdb.utils.InfluxDbUtils; import com.njcn.influxdb.utils.InfluxDbUtils;
import com.njcn.prepare.harmonic.mapper.line.ExcelRptTempMapper; import com.njcn.prepare.harmonic.mapper.mysql.line.ExcelRptTempMapper;
import com.njcn.prepare.harmonic.pojo.po.DataVPO; import com.njcn.prepare.harmonic.pojo.influxdb.po.DataVPO;
import com.njcn.prepare.harmonic.pojo.po.ExcelRptTemp; import com.njcn.prepare.harmonic.service.mysql.Impl.line.LimitRateService;
import com.njcn.prepare.harmonic.service.Impl.line.LimitRateService;
import org.influxdb.dto.QueryResult; import org.influxdb.dto.QueryResult;
import org.influxdb.impl.InfluxDBResultMapper; import org.influxdb.impl.InfluxDBResultMapper;
import org.junit.Test; import org.junit.Test;

9
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/area/AreaController.java
View File

@@ -1,9 +0,0 @@
package com.njcn.prepare.harmonic.controller.area;
/**
* @author denghuajun
* @version 1.0.0
* @date 2022年10月17日 20:13
*/
public class AreaController {
}

9
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/device/DeviceController.java
View File

@@ -1,9 +0,0 @@
package com.njcn.prepare.harmonic.controller.device;
/**
* @author denghuajun
* @version 1.0.0
* @date 2022年10月17日 20:13
*/
public class DeviceController {
}

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/DayDataController.java
View File

@@ -7,7 +7,7 @@ import com.njcn.common.pojo.response.HttpResult;
import com.njcn.common.utils.HttpResultUtil; import com.njcn.common.utils.HttpResultUtil;
import com.njcn.device.pq.api.LineFeignClient; import com.njcn.device.pq.api.LineFeignClient;
import com.njcn.prepare.harmonic.pojo.param.LineParam; import com.njcn.prepare.harmonic.pojo.param.LineParam;
import com.njcn.prepare.harmonic.service.line.DayDataService; import com.njcn.prepare.harmonic.service.mysql.line.DayDataService;
import com.njcn.web.controller.BaseController; import com.njcn.web.controller.BaseController;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParam;

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/DistortionRateController.java
View File

@@ -6,7 +6,7 @@ import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.response.HttpResult; import com.njcn.common.pojo.response.HttpResult;
import com.njcn.common.utils.HttpResultUtil; import com.njcn.common.utils.HttpResultUtil;
import com.njcn.prepare.harmonic.pojo.param.LineParam; import com.njcn.prepare.harmonic.pojo.param.LineParam;
import com.njcn.prepare.harmonic.service.line.DistortionRateService; import com.njcn.prepare.harmonic.service.mysql.line.DistortionRateService;
import com.njcn.web.controller.BaseController; import com.njcn.web.controller.BaseController;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParam;

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/HarmonicGeneralController.java
View File

@@ -6,7 +6,7 @@ import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.response.HttpResult; import com.njcn.common.pojo.response.HttpResult;
import com.njcn.common.utils.HttpResultUtil; import com.njcn.common.utils.HttpResultUtil;
import com.njcn.prepare.harmonic.pojo.param.LineParam; import com.njcn.prepare.harmonic.pojo.param.LineParam;
import com.njcn.prepare.harmonic.service.line.HarmonicGeneralService; import com.njcn.prepare.harmonic.service.mysql.line.HarmonicGeneralService;
import com.njcn.web.controller.BaseController; import com.njcn.web.controller.BaseController;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParam;

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/HarmonicMetricController.java
View File

@@ -6,7 +6,7 @@ import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.response.HttpResult; import com.njcn.common.pojo.response.HttpResult;
import com.njcn.common.utils.HttpResultUtil; import com.njcn.common.utils.HttpResultUtil;
import com.njcn.prepare.harmonic.pojo.param.LineParam; import com.njcn.prepare.harmonic.pojo.param.LineParam;
import com.njcn.prepare.harmonic.service.line.HarmonicMetricService; import com.njcn.prepare.harmonic.service.mysql.line.HarmonicMetricService;
import com.njcn.web.controller.BaseController; import com.njcn.web.controller.BaseController;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParam;

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/IntegrityController.java
View File

@@ -6,7 +6,7 @@ import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.response.HttpResult; import com.njcn.common.pojo.response.HttpResult;
import com.njcn.common.utils.HttpResultUtil; import com.njcn.common.utils.HttpResultUtil;
import com.njcn.prepare.harmonic.pojo.param.LineParam; import com.njcn.prepare.harmonic.pojo.param.LineParam;
import com.njcn.prepare.harmonic.service.line.IntegrityService; import com.njcn.prepare.harmonic.service.mysql.line.IntegrityService;
import com.njcn.web.controller.BaseController; import com.njcn.web.controller.BaseController;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParam;

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/LimitTargetController.java
View File

@@ -6,7 +6,7 @@ import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.response.HttpResult; import com.njcn.common.pojo.response.HttpResult;
import com.njcn.common.utils.HttpResultUtil; import com.njcn.common.utils.HttpResultUtil;
import com.njcn.prepare.harmonic.pojo.param.LineParam; import com.njcn.prepare.harmonic.pojo.param.LineParam;
import com.njcn.prepare.harmonic.service.line.LimitTargetService; import com.njcn.prepare.harmonic.service.mysql.line.LimitTargetService;
import com.njcn.web.controller.BaseController; import com.njcn.web.controller.BaseController;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParam;

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/LimitrateController.java
View File

@@ -7,7 +7,7 @@ import com.njcn.common.pojo.response.HttpResult;
import com.njcn.common.utils.HttpResultUtil; import com.njcn.common.utils.HttpResultUtil;
import com.njcn.device.pq.api.LineFeignClient; import com.njcn.device.pq.api.LineFeignClient;
import com.njcn.prepare.harmonic.pojo.param.LineParam; import com.njcn.prepare.harmonic.pojo.param.LineParam;
import com.njcn.prepare.harmonic.service.Impl.line.LimitRateService; import com.njcn.prepare.harmonic.service.mysql.Impl.line.LimitRateService;
import com.njcn.web.controller.BaseController; import com.njcn.web.controller.BaseController;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParam;

5
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/NormalLimitController.java
View File

@@ -6,20 +6,17 @@ import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.response.HttpResult; import com.njcn.common.pojo.response.HttpResult;
import com.njcn.common.utils.HttpResultUtil; import com.njcn.common.utils.HttpResultUtil;
import com.njcn.prepare.harmonic.pojo.param.LineParam; import com.njcn.prepare.harmonic.pojo.param.LineParam;
import com.njcn.prepare.harmonic.service.line.NormalLimitService; import com.njcn.prepare.harmonic.service.mysql.line.NormalLimitService;
import com.njcn.web.controller.BaseController; import com.njcn.web.controller.BaseController;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import java.time.LocalDateTime;
/** /**
* @author denghuajun * @author denghuajun
* @version 1.0.0 * @version 1.0.0

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/OnlineRateController.java
View File

@@ -6,7 +6,7 @@ import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.response.HttpResult; import com.njcn.common.pojo.response.HttpResult;
import com.njcn.common.utils.HttpResultUtil; import com.njcn.common.utils.HttpResultUtil;
import com.njcn.prepare.harmonic.pojo.param.LineParam; import com.njcn.prepare.harmonic.pojo.param.LineParam;
import com.njcn.prepare.harmonic.service.line.OnlineRateService; import com.njcn.prepare.harmonic.service.mysql.line.OnlineRateService;
import com.njcn.web.controller.BaseController; import com.njcn.web.controller.BaseController;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParam;

6
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/PollutionController.java
View File

@@ -3,16 +3,14 @@ package com.njcn.prepare.harmonic.controller.line;
import com.njcn.common.pojo.annotation.OperateInfo; import com.njcn.common.pojo.annotation.OperateInfo;
import com.njcn.common.pojo.enums.common.LogEnum; import com.njcn.common.pojo.enums.common.LogEnum;
import com.njcn.common.pojo.enums.response.CommonResponseEnum; import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.param.StatisticsBizBaseParam;
import com.njcn.common.pojo.response.HttpResult; import com.njcn.common.pojo.response.HttpResult;
import com.njcn.common.utils.HttpResultUtil; import com.njcn.common.utils.HttpResultUtil;
import com.njcn.prepare.harmonic.pojo.param.LineParam; import com.njcn.prepare.harmonic.pojo.param.LineParam;
import com.njcn.prepare.harmonic.service.line.PollutionService; import com.njcn.prepare.harmonic.service.mysql.line.PollutionService;
import com.njcn.web.controller.BaseController; import com.njcn.web.controller.BaseController;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import lombok.AllArgsConstructor;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.validation.annotation.Validated; import org.springframework.validation.annotation.Validated;
@@ -21,8 +19,6 @@ import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import javax.servlet.http.HttpServletResponse;
/** /**
* 监测点污染指标 * 监测点污染指标

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/line/ReportController.java
View File

@@ -6,7 +6,7 @@ import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.response.HttpResult; import com.njcn.common.pojo.response.HttpResult;
import com.njcn.common.utils.HttpResultUtil; import com.njcn.common.utils.HttpResultUtil;
import com.njcn.prepare.harmonic.pojo.param.LineParam; import com.njcn.prepare.harmonic.pojo.param.LineParam;
import com.njcn.prepare.harmonic.service.line.ReportService; import com.njcn.prepare.harmonic.service.mysql.line.ReportService;
import com.njcn.web.controller.BaseController; import com.njcn.web.controller.BaseController;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParam;

9
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/substion/SubstionController.java
View File

@@ -1,9 +0,0 @@
package com.njcn.prepare.harmonic.controller.substion;
/**
* @author denghuajun
* @version 1.0.0
* @date 2022年10月17日 20:13
*/
public class SubstionController {
}

9
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/controller/voltage/VoltageController.java
View File

@@ -1,9 +0,0 @@
package com.njcn.prepare.harmonic.controller.voltage;
/**
* @author denghuajun
* @version 1.0.0
* @date 2022年10月17日 20:13
*/
public class VoltageController {
}

9
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/area/AreaMapper.java
View File

@@ -1,9 +0,0 @@
package com.njcn.prepare.harmonic.mapper.area;
/**
* @author denghuajun
* @version 1.0.0
* @date 2022年10月17日 20:15
*/
public interface AreaMapper {
}

5
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/device/DeviceMapper.java
View File

@@ -1,5 +0,0 @@
package com.njcn.prepare.harmonic.mapper.device;
public interface DeviceMapper {
}

16
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/RMpFlickerReportDPOMapper.java
View File

@@ -1,16 +0,0 @@
package com.njcn.prepare.harmonic.mapper.line;
import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
import com.njcn.prepare.harmonic.pojo.po.line.RMpFlickerReportDPO;
/**
*
* Description:
* 接口文档访问地址：http://serverIP:port/swagger-ui.html
* Date: 2022/10/26 14:15【需求编号】
*
* @author clam
* @version V1.0.0
*/
public interface RMpFlickerReportDPOMapper extends MppBaseMapper<RMpFlickerReportDPO> {
}

5
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/AbnormalMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/AbnormalMapper.java
View File

@@ -1,8 +1,7 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.njcn.prepare.harmonic.pojo.po.AbnormalPO; import com.njcn.prepare.harmonic.pojo.mysql.po.line.MpSurplusAbnormalD;
import com.njcn.prepare.harmonic.pojo.po.MpSurplusAbnormalD;
/** /**
* @author denghuajun * @author denghuajun

4
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/ExcelRptMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/ExcelRptMapper.java
View File

@@ -1,7 +1,7 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.njcn.prepare.harmonic.pojo.po.ExcelRpt; import com.njcn.harmonic.pojo.po.ExcelRpt;
/** /**
* ExcelRptMapper * ExcelRptMapper

4
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/ExcelRptTempMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/ExcelRptTempMapper.java
View File

@@ -1,7 +1,7 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.njcn.prepare.harmonic.pojo.po.ExcelRptTemp; import com.njcn.harmonic.pojo.po.ExcelRptTemp;
import java.util.List; import java.util.List;

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/LimitRatePOMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/LimitRatePOMapper.java
View File

@@ -1,4 +1,4 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
import com.njcn.harmonic.pojo.po.LimitRatePO; import com.njcn.harmonic.pojo.po.LimitRatePO;

4
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/LimitTargetPOMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/LimitTargetPOMapper.java
View File

@@ -1,7 +1,7 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.njcn.prepare.harmonic.pojo.po.line.LimitTargetPO; import com.njcn.prepare.harmonic.pojo.mysql.po.line.LimitTargetPO;
/** /**
* Description: * Description:

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/NormLimitMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/NormLimitMapper.java
View File

@@ -1,4 +1,4 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
/** /**
* @author denghuajun * @author denghuajun

24
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpFlickerReportDPOMapper.java Normal file
View File

@@ -0,0 +1,24 @@
package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
import com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpFlickerReportDPO;
import org.apache.ibatis.annotations.Select;
import java.util.List;
/**
* Description:
* 接口文档访问地址：http://serverIP:port/swagger-ui.html
* Date: 2022/10/26 14:15【需求编号】
*
* @author clam
* @version V1.0.0
*/
public interface RMpFlickerReportDPOMapper extends MppBaseMapper<RMpFlickerReportDPO> {
@Select("select name from sys_user")
List<String> testMysql();
@Select("select name from pqs_user")
List<String> testOracle();
}

6
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/RMpHarmonicIMagReportDPOMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpHarmonicIMagReportDPOMapper.java
View File

@@ -1,7 +1,7 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
import com.njcn.prepare.harmonic.pojo.po.line.RMpHarmonicIMagReportDPO; import com.njcn.harmonic.pojo.po.RMpHarmonicIMagReportD;
/** /**
* *
@@ -12,5 +12,5 @@ import com.njcn.prepare.harmonic.pojo.po.line.RMpHarmonicIMagReportDPO;
* @author clam * @author clam
* @version V1.0.0 * @version V1.0.0
*/ */
public interface RMpHarmonicIMagReportDPOMapper extends MppBaseMapper<RMpHarmonicIMagReportDPO> { public interface RMpHarmonicIMagReportDPOMapper extends MppBaseMapper<RMpHarmonicIMagReportD> {
} }

6
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/RMpHarmonicIRateReportDPOMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpHarmonicIRateReportDPOMapper.java
View File

@@ -1,7 +1,7 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
import com.njcn.prepare.harmonic.pojo.po.line.RMpHarmonicIRateReportDPO; import com.njcn.harmonic.pojo.po.RMpHarmonicIRateReportD;
/** /**
* *
@@ -12,5 +12,5 @@ import com.njcn.prepare.harmonic.pojo.po.line.RMpHarmonicIRateReportDPO;
* @author clam * @author clam
* @version V1.0.0 * @version V1.0.0
*/ */
public interface RMpHarmonicIRateReportDPOMapper extends MppBaseMapper<RMpHarmonicIRateReportDPO> { public interface RMpHarmonicIRateReportDPOMapper extends MppBaseMapper<RMpHarmonicIRateReportD> {
} }

4
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/RMpHarmonicPReportDPOMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpHarmonicPReportDPOMapper.java
View File

@@ -1,7 +1,7 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
import com.njcn.prepare.harmonic.pojo.po.line.RMpHarmonicPReportDPO; import com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpHarmonicPReportDPO;
/** /**
* Description: * Description:

6
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/RMpHarmonicVRateReportDPOMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpHarmonicVRateReportDPOMapper.java
View File

@@ -1,7 +1,7 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
import com.njcn.prepare.harmonic.pojo.po.line.RMpHarmonicVRateReportDPO; import com.njcn.harmonic.pojo.po.RMpHarmonicVRateReportD;
/** /**
* *
@@ -12,5 +12,5 @@ import com.njcn.prepare.harmonic.pojo.po.line.RMpHarmonicVRateReportDPO;
* @author clam * @author clam
* @version V1.0.0 * @version V1.0.0
*/ */
public interface RMpHarmonicVRateReportDPOMapper extends MppBaseMapper<RMpHarmonicVRateReportDPO> { public interface RMpHarmonicVRateReportDPOMapper extends MppBaseMapper<RMpHarmonicVRateReportD> {
} }

4
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/RMpInharmonicIMagReportDPOMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpInharmonicIMagReportDPOMapper.java
View File

@@ -1,7 +1,7 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
import com.njcn.prepare.harmonic.pojo.po.line.RMpInharmonicIMagReportDPO; import com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpInharmonicIMagReportDPO;
/** /**
* Description: * Description:

6
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/RMpInharmonicIRateReportDPOMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpInharmonicIRateReportDPOMapper.java
View File

@@ -1,7 +1,7 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
import com.njcn.prepare.harmonic.pojo.po.line.RMpInharmonicIRateReportDPO; import com.njcn.harmonic.pojo.po.RMpInharmonicIRateReportD;
/** /**
* *
@@ -12,5 +12,5 @@ import com.njcn.prepare.harmonic.pojo.po.line.RMpInharmonicIRateReportDPO;
* @author clam * @author clam
* @version V1.0.0 * @version V1.0.0
*/ */
public interface RMpInharmonicIRateReportDPOMapper extends MppBaseMapper<RMpInharmonicIRateReportDPO> { public interface RMpInharmonicIRateReportDPOMapper extends MppBaseMapper<RMpInharmonicIRateReportD> {
} }

6
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/RMpInharmonicVRateReportDPOMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpInharmonicVRateReportDPOMapper.java
View File

@@ -1,7 +1,7 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
import com.njcn.prepare.harmonic.pojo.po.line.RMpInharmonicVRateReportDPO; import com.njcn.harmonic.pojo.po.RMpInharmonicVRateReportD;
/** /**
* Description: * Description:
@@ -11,5 +11,5 @@ import com.njcn.prepare.harmonic.pojo.po.line.RMpInharmonicVRateReportDPO;
* @author clam * @author clam
* @version V1.0.0 * @version V1.0.0
*/ */
public interface RMpInharmonicVRateReportDPOMapper extends MppBaseMapper<RMpInharmonicVRateReportDPO> { public interface RMpInharmonicVRateReportDPOMapper extends MppBaseMapper<RMpInharmonicVRateReportD> {
} }

6
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/RMpMeasurePhaseReportDPOMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpMeasurePhaseReportDPOMapper.java
View File

@@ -1,7 +1,7 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
import com.njcn.prepare.harmonic.pojo.po.line.RMpMeasurePhaseReportDPO; import com.njcn.harmonic.pojo.po.RMpMeasurePhaseReportD;
/** /**
* *
@@ -12,5 +12,5 @@ import com.njcn.prepare.harmonic.pojo.po.line.RMpMeasurePhaseReportDPO;
* @author clam * @author clam
* @version V1.0.0 * @version V1.0.0
*/ */
public interface RMpMeasurePhaseReportDPOMapper extends MppBaseMapper<RMpMeasurePhaseReportDPO> { public interface RMpMeasurePhaseReportDPOMapper extends MppBaseMapper<RMpMeasurePhaseReportD> {
} }

6
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/RMpMeasureReportDPOMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpMeasureReportDPOMapper.java
View File

@@ -1,7 +1,7 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
import com.njcn.prepare.harmonic.pojo.po.line.RMpMeasureReportDPO; import com.njcn.harmonic.pojo.po.RMpMeasureReportD;
/** /**
* *
@@ -12,5 +12,5 @@ import com.njcn.prepare.harmonic.pojo.po.line.RMpMeasureReportDPO;
* @author clam * @author clam
* @version V1.0.0 * @version V1.0.0
*/ */
public interface RMpMeasureReportDPOMapper extends MppBaseMapper<RMpMeasureReportDPO> { public interface RMpMeasureReportDPOMapper extends MppBaseMapper<RMpMeasureReportD> {
} }

4
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/RMpPltReportDPOMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpPltReportDPOMapper.java
View File

@@ -1,7 +1,7 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
import com.njcn.prepare.harmonic.pojo.po.line.RMpPltReportDPO; import com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpPltReportDPO;
/** /**
* *

7
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/RMpPollutionDMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpPollutionDMapper.java
View File

@@ -1,10 +1,9 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.njcn.prepare.harmonic.pojo.po.RMpPollutionD; import com.njcn.harmonic.pojo.po.RMpPollutionDPO;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import java.util.List;
import java.util.Map; import java.util.Map;
/** /**
@@ -15,7 +14,7 @@ import java.util.Map;
* @author xiaoyao * @author xiaoyao
* @since 2022-10-20 * @since 2022-10-20
*/ */
public interface RMpPollutionDMapper extends BaseMapper<RMpPollutionD> { public interface RMpPollutionDMapper extends BaseMapper<RMpPollutionDPO> {
int insertPollution(@Param("item") Map<String, Object> item); int insertPollution(@Param("item") Map<String, Object> item);

4
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/RMpVThdMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpVThdMapper.java
View File

@@ -1,7 +1,7 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.njcn.prepare.harmonic.pojo.po.RMpVThd; import com.njcn.harmonic.pojo.po.RMpVThd;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import java.util.Map; import java.util.Map;

7
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/RStatPollutionOrgDMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RStatPollutionOrgDMapper.java
View File

@@ -1,8 +1,7 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.njcn.prepare.harmonic.pojo.po.RMpPollutionD; import com.njcn.harmonic.pojo.po.RStatPollutionOrgDPO;
import com.njcn.prepare.harmonic.pojo.po.RStatPollutionOrgD;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import java.util.Map; import java.util.Map;
@@ -15,7 +14,7 @@ import java.util.Map;
* @author xiaoyao * @author xiaoyao
* @since 2022-10-20 * @since 2022-10-20
*/ */
public interface RStatPollutionOrgDMapper extends BaseMapper<RStatPollutionOrgD> { public interface RStatPollutionOrgDMapper extends BaseMapper<RStatPollutionOrgDPO> {
int insertPollution(@Param("item") Map<String, Object> item); int insertPollution(@Param("item") Map<String, Object> item);

6
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/RStatPollutionOrgMMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RStatPollutionOrgMMapper.java
View File

@@ -1,7 +1,7 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.njcn.prepare.harmonic.pojo.po.RStatPollutionOrgM; import com.njcn.harmonic.pojo.po.RStatPollutionOrgMPO;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import java.util.Map; import java.util.Map;
@@ -14,7 +14,7 @@ import java.util.Map;
* @author xiaoyao * @author xiaoyao
* @since 2022-10-20 * @since 2022-10-20
*/ */
public interface RStatPollutionOrgMMapper extends BaseMapper<RStatPollutionOrgM> { public interface RStatPollutionOrgMMapper extends BaseMapper<RStatPollutionOrgMPO> {
int insertPollution(@Param("item") Map<String, Object> item); int insertPollution(@Param("item") Map<String, Object> item);
} }

6
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/RStatPollutionOrgQMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RStatPollutionOrgQMapper.java
View File

@@ -1,7 +1,7 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.njcn.prepare.harmonic.pojo.po.RStatPollutionOrgQ; import com.njcn.harmonic.pojo.po.RStatPollutionOrgQPO;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import java.util.Map; import java.util.Map;
@@ -14,7 +14,7 @@ import java.util.Map;
* @author xiaoyao * @author xiaoyao
* @since 2022-10-20 * @since 2022-10-20
*/ */
public interface RStatPollutionOrgQMapper extends BaseMapper<RStatPollutionOrgQ> { public interface RStatPollutionOrgQMapper extends BaseMapper<RStatPollutionOrgQPO> {
int insertPollution(@Param("item") Map<String, Object> item); int insertPollution(@Param("item") Map<String, Object> item);
} }

6
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/RStatPollutionOrgYMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RStatPollutionOrgYMapper.java
View File

@@ -1,7 +1,7 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.njcn.prepare.harmonic.pojo.po.RStatPollutionOrgY; import com.njcn.harmonic.pojo.po.RStatPollutionOrgYPO;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import java.util.Map; import java.util.Map;
@@ -14,7 +14,7 @@ import java.util.Map;
* @author xiaoyao * @author xiaoyao
* @since 2022-10-20 * @since 2022-10-20
*/ */
public interface RStatPollutionOrgYMapper extends BaseMapper<RStatPollutionOrgY> { public interface RStatPollutionOrgYMapper extends BaseMapper<RStatPollutionOrgYPO> {
int insertPollution(@Param("item") Map<String, Object> item); int insertPollution(@Param("item") Map<String, Object> item);
} }

7
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/RStatPollutionSubstationDMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RStatPollutionSubstationDMapper.java
View File

@@ -1,8 +1,7 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.njcn.prepare.harmonic.pojo.po.RStatPollutionOrgD; import com.njcn.harmonic.pojo.po.RStatPollutionSubstationDPO;
import com.njcn.prepare.harmonic.pojo.po.RStatPollutionSubstationD;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import java.util.Map; import java.util.Map;
@@ -15,7 +14,7 @@ import java.util.Map;
* @author xiaoyao * @author xiaoyao
* @since 2022-10-20 * @since 2022-10-20
*/ */
public interface RStatPollutionSubstationDMapper extends BaseMapper<RStatPollutionSubstationD> { public interface RStatPollutionSubstationDMapper extends BaseMapper<RStatPollutionSubstationDPO> {
int insertPollution(@Param("item") Map<String, Object> item); int insertPollution(@Param("item") Map<String, Object> item);

5
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/RStatPollutionSubstationMMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RStatPollutionSubstationMMapper.java
View File

@@ -1,7 +1,8 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.njcn.prepare.harmonic.pojo.po.RStatPollutionSubstationM; import com.njcn.harmonic.pojo.po.RStatPollutionSubstationDPO;
import com.njcn.harmonic.pojo.po.RStatPollutionSubstationM;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import java.util.Map; import java.util.Map;

6
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/RStatPollutionSubstationQMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RStatPollutionSubstationQMapper.java
View File

@@ -1,7 +1,7 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.njcn.prepare.harmonic.pojo.po.RStatPollutionSubstationQ; import com.njcn.harmonic.pojo.po.RStatPollutionSubstationQPO;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import java.util.Map; import java.util.Map;
@@ -14,7 +14,7 @@ import java.util.Map;
* @author xiaoyao * @author xiaoyao
* @since 2022-10-20 * @since 2022-10-20
*/ */
public interface RStatPollutionSubstationQMapper extends BaseMapper<RStatPollutionSubstationQ> { public interface RStatPollutionSubstationQMapper extends BaseMapper<RStatPollutionSubstationQPO> {
int insertPollution(@Param("item") Map<String, Object> item); int insertPollution(@Param("item") Map<String, Object> item);
} }

6
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/RStatPollutionSubstationYMapper.java → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RStatPollutionSubstationYMapper.java
View File

@@ -1,7 +1,7 @@
package com.njcn.prepare.harmonic.mapper.line; package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.njcn.prepare.harmonic.pojo.po.RStatPollutionSubstationY; import com.njcn.harmonic.pojo.po.RStatPollutionSubstationYPO;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import java.util.Map; import java.util.Map;
@@ -14,7 +14,7 @@ import java.util.Map;
* @author xiaoyao * @author xiaoyao
* @since 2022-10-20 * @since 2022-10-20
*/ */
public interface RStatPollutionSubstationYMapper extends BaseMapper<RStatPollutionSubstationY> { public interface RStatPollutionSubstationYMapper extends BaseMapper<RStatPollutionSubstationYPO> {
int insertPollution(@Param("item") Map<String, Object> item); int insertPollution(@Param("item") Map<String, Object> item);
} }

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/ExcelRptTempMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/ExcelRptTempMapper.xml
View File

@@ -1,6 +1,6 @@
<?xml version="1.0" encoding="UTF-8" ?> <?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.ExcelRptTempMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.ExcelRptTempMapper">
<select id="getActiveTempList" resultType="com.njcn.prepare.harmonic.pojo.po.ExcelRptTemp"> <select id="getActiveTempList" resultType="com.njcn.prepare.harmonic.pojo.po.ExcelRptTemp">
SELECT SELECT

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/LimitRatePOMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/LimitRatePOMapper.xml
View File

@@ -1,6 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.LimitRatePOMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.LimitRatePOMapper">
<resultMap id="BaseResultMap" type="com.njcn.harmonic.pojo.po.LimitRatePO"> <resultMap id="BaseResultMap" type="com.njcn.harmonic.pojo.po.LimitRatePO">
<!--@mbg.generated--> <!--@mbg.generated-->
<!--@Table limit_rate--> <!--@Table limit_rate-->

4
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/LimitTargetPOMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/LimitTargetPOMapper.xml
View File

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.LimitTargetPOMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.LimitTargetPOMapper">
<resultMap id="BaseResultMap" type="com.njcn.prepare.harmonic.pojo.po.line.LimitTargetPO"> <resultMap id="BaseResultMap" type="com.njcn.prepare.harmonic.pojo.mysql.po.line.LimitTargetPO">
<!--@mbg.generated--> <!--@mbg.generated-->
<!--@Table limit_target--> <!--@Table limit_target-->
<id column="line_id" property="lineId" /> <id column="line_id" property="lineId" />

4
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/RMpFlickerReportDPOMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RMpFlickerReportDPOMapper.xml
View File

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.RMpFlickerReportDPOMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.RMpFlickerReportDPOMapper">
<resultMap id="BaseResultMap" type="com.njcn.prepare.harmonic.pojo.po.line.RMpFlickerReportDPO"> <resultMap id="BaseResultMap" type="com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpFlickerReportDPO">
<!--@mbg.generated--> <!--@mbg.generated-->
<!--@Table r_mp_flicker_report_d--> <!--@Table r_mp_flicker_report_d-->
<id column="measurement_point_id" jdbcType="VARCHAR" property="measurementPointId" /> <id column="measurement_point_id" jdbcType="VARCHAR" property="measurementPointId" />

4
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/RMpHarmonicIMagReportDPOMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RMpHarmonicIMagReportDPOMapper.xml
View File

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.RMpHarmonicIMagReportDPOMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.RMpHarmonicIMagReportDPOMapper">
<resultMap id="BaseResultMap" type="com.njcn.prepare.harmonic.pojo.po.line.RMpHarmonicIMagReportDPO"> <resultMap id="BaseResultMap" type="com.njcn.harmonic.pojo.po.RMpHarmonicIMagReportD">
<!--@mbg.generated--> <!--@mbg.generated-->
<!--@Table r_mp_harmonic_i_mag_report_d--> <!--@Table r_mp_harmonic_i_mag_report_d-->
<id column="measurement_point_id" jdbcType="VARCHAR" property="measurementPointId" /> <id column="measurement_point_id" jdbcType="VARCHAR" property="measurementPointId" />

4
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/RMpHarmonicIRateReportDPOMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RMpHarmonicIRateReportDPOMapper.xml
View File

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.RMpHarmonicIRateReportDPOMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.RMpHarmonicIRateReportDPOMapper">
<resultMap id="BaseResultMap" type="com.njcn.prepare.harmonic.pojo.po.line.RMpHarmonicIRateReportDPO"> <resultMap id="BaseResultMap" type="com.njcn.harmonic.pojo.po.RMpHarmonicIRateReportD">
<!--@mbg.generated--> <!--@mbg.generated-->
<!--@Table r_mp_harmonic_i_rate_report_d--> <!--@Table r_mp_harmonic_i_rate_report_d-->
<id column="measurement_point_id" jdbcType="VARCHAR" property="measurementPointId" /> <id column="measurement_point_id" jdbcType="VARCHAR" property="measurementPointId" />

4
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/RMpHarmonicPReportDPOMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RMpHarmonicPReportDPOMapper.xml
View File

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.RMpHarmonicPReportDPOMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.RMpHarmonicPReportDPOMapper">
<resultMap id="BaseResultMap" type="com.njcn.prepare.harmonic.pojo.po.line.RMpHarmonicPReportDPO"> <resultMap id="BaseResultMap" type="com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpHarmonicPReportDPO">
<!--@mbg.generated--> <!--@mbg.generated-->
<!--@Table r_mp_harmonic_p_report_d--> <!--@Table r_mp_harmonic_p_report_d-->
<id column="measurement_point_id" jdbcType="VARCHAR" property="measurementPointId" /> <id column="measurement_point_id" jdbcType="VARCHAR" property="measurementPointId" />

4
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/RMpHarmonicVRateReportDPOMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RMpHarmonicVRateReportDPOMapper.xml
View File

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.RMpHarmonicVRateReportDPOMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.RMpHarmonicVRateReportDPOMapper">
<resultMap id="BaseResultMap" type="com.njcn.prepare.harmonic.pojo.po.line.RMpHarmonicVRateReportDPO"> <resultMap id="BaseResultMap" type="com.njcn.harmonic.pojo.po.RMpHarmonicVRateReportD">
<!--@mbg.generated--> <!--@mbg.generated-->
<!--@Table r_mp_harmonic_v_rate_report_d--> <!--@Table r_mp_harmonic_v_rate_report_d-->
<id column="measurement_point_id" jdbcType="VARCHAR" property="measurementPointId" /> <id column="measurement_point_id" jdbcType="VARCHAR" property="measurementPointId" />

4
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/RMpInharmonicIMagReportDPOMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RMpInharmonicIMagReportDPOMapper.xml
View File

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.RMpInharmonicIMagReportDPOMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.RMpInharmonicIMagReportDPOMapper">
<resultMap id="BaseResultMap" type="com.njcn.prepare.harmonic.pojo.po.line.RMpInharmonicIMagReportDPO"> <resultMap id="BaseResultMap" type="com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpInharmonicIMagReportDPO">
<!--@mbg.generated--> <!--@mbg.generated-->
<!--@Table r_mp_inharmonic_i_mag_report_d--> <!--@Table r_mp_inharmonic_i_mag_report_d-->
<id column="measurement_point_id" jdbcType="VARCHAR" property="measurementPointId" /> <id column="measurement_point_id" jdbcType="VARCHAR" property="measurementPointId" />

4
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/RMpInharmonicIRateReportDPOMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RMpInharmonicIRateReportDPOMapper.xml
View File

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.RMpInharmonicIRateReportDPOMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.RMpInharmonicIRateReportDPOMapper">
<resultMap id="BaseResultMap" type="com.njcn.prepare.harmonic.pojo.po.line.RMpInharmonicIRateReportDPO"> <resultMap id="BaseResultMap" type="com.njcn.harmonic.pojo.po.RMpInharmonicIRateReportD">
<!--@mbg.generated--> <!--@mbg.generated-->
<!--@Table r_mp_inharmonic_i_rate_report_d--> <!--@Table r_mp_inharmonic_i_rate_report_d-->
<id column="measurement_point_id" jdbcType="VARCHAR" property="measurementPointId" /> <id column="measurement_point_id" jdbcType="VARCHAR" property="measurementPointId" />

4
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/RMpInharmonicVRateReportDPOMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RMpInharmonicVRateReportDPOMapper.xml
View File

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.RMpInharmonicVRateReportDPOMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.RMpInharmonicVRateReportDPOMapper">
<resultMap id="BaseResultMap" type="com.njcn.prepare.harmonic.pojo.po.line.RMpInharmonicVRateReportDPO"> <resultMap id="BaseResultMap" type="com.njcn.harmonic.pojo.po.RMpInharmonicVRateReportD">
<!--@mbg.generated--> <!--@mbg.generated-->
<!--@Table r_mp_inharmonic_v_rate_report_d--> <!--@Table r_mp_inharmonic_v_rate_report_d-->
<id column="measurement_point_id" jdbcType="VARCHAR" property="measurementPointId" /> <id column="measurement_point_id" jdbcType="VARCHAR" property="measurementPointId" />

4
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/RMpMeasurePhaseReportDPOMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RMpMeasurePhaseReportDPOMapper.xml
View File

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.RMpMeasurePhaseReportDPOMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.RMpMeasurePhaseReportDPOMapper">
<resultMap id="BaseResultMap" type="com.njcn.prepare.harmonic.pojo.po.line.RMpMeasurePhaseReportDPO"> <resultMap id="BaseResultMap" type="com.njcn.harmonic.pojo.po.RMpMeasurePhaseReportD">
<!--@mbg.generated--> <!--@mbg.generated-->
<!--@Table r_mp_measure_phase_report_d--> <!--@Table r_mp_measure_phase_report_d-->
<id column="measurement_point_id" jdbcType="VARCHAR" property="measurementPointId" /> <id column="measurement_point_id" jdbcType="VARCHAR" property="measurementPointId" />

4
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/RMpMeasureReportDPOMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RMpMeasureReportDPOMapper.xml
View File

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.RMpMeasureReportDPOMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.RMpMeasureReportDPOMapper">
<resultMap id="BaseResultMap" type="com.njcn.prepare.harmonic.pojo.po.line.RMpMeasureReportDPO"> <resultMap id="BaseResultMap" type="com.njcn.harmonic.pojo.po.RMpMeasureReportD">
<!--@mbg.generated--> <!--@mbg.generated-->
<!--@Table r_mp_measure_report_d--> <!--@Table r_mp_measure_report_d-->
<id column="measurement_point_id" jdbcType="VARCHAR" property="measurementPointId" /> <id column="measurement_point_id" jdbcType="VARCHAR" property="measurementPointId" />

4
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/RMpPltReportDPOMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RMpPltReportDPOMapper.xml
View File

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.RMpPltReportDPOMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.RMpPltReportDPOMapper">
<resultMap id="BaseResultMap" type="com.njcn.prepare.harmonic.pojo.po.line.RMpPltReportDPO"> <resultMap id="BaseResultMap" type="com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpPltReportDPO">
<!--@mbg.generated--> <!--@mbg.generated-->
<!--@Table r_mp_plt_report_d--> <!--@Table r_mp_plt_report_d-->
<id column="measurement_point_id" jdbcType="VARCHAR" property="measurementPointId" /> <id column="measurement_point_id" jdbcType="VARCHAR" property="measurementPointId" />

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/RMpPollutionDMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RMpPollutionDMapper.xml
View File

@@ -1,6 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.RMpPollutionDMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.RMpPollutionDMapper">
<insert id="insertPollution"> <insert id="insertPollution">
INSERT INTO r_mp_pollution_d ( line_id, data_date, pollution_type, `value`) VALUES INSERT INTO r_mp_pollution_d ( line_id, data_date, pollution_type, `value`) VALUES

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/RMpVThdMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RMpVThdMapper.xml
View File

@@ -1,6 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.RMpVThdMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.RMpVThdMapper">
<insert id="insertRate"> <insert id="insertRate">
INSERT INTO r_mp_v_thd ( measurement_point_id, data_type, data_date, v_thd) VALUES INSERT INTO r_mp_v_thd ( measurement_point_id, data_type, data_date, v_thd) VALUES

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/RStatPollutionOrgDMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RStatPollutionOrgDMapper.xml
View File

@@ -1,6 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.RStatPollutionOrgDMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.RStatPollutionOrgDMapper">
<insert id="insertPollution"> <insert id="insertPollution">
INSERT INTO r_stat_pollution_org_d ( org_id, data_date, pollution_type, `value`) VALUES INSERT INTO r_stat_pollution_org_d ( org_id, data_date, pollution_type, `value`) VALUES

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/RStatPollutionOrgMMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RStatPollutionOrgMMapper.xml
View File

@@ -1,6 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.RStatPollutionOrgMMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.RStatPollutionOrgMMapper">
<insert id="insertPollution"> <insert id="insertPollution">
INSERT INTO r_stat_pollution_org_m ( org_id, data_date, pollution_type, `value`) VALUES INSERT INTO r_stat_pollution_org_m ( org_id, data_date, pollution_type, `value`) VALUES

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/RStatPollutionOrgQMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RStatPollutionOrgQMapper.xml
View File

@@ -1,6 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.RStatPollutionOrgQMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.RStatPollutionOrgQMapper">
<insert id="insertPollution"> <insert id="insertPollution">
INSERT INTO r_stat_pollution_org_q ( org_id, data_date, pollution_type, `value`) VALUES INSERT INTO r_stat_pollution_org_q ( org_id, data_date, pollution_type, `value`) VALUES

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/RStatPollutionOrgYMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RStatPollutionOrgYMapper.xml
View File

@@ -1,6 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.RStatPollutionOrgYMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.RStatPollutionOrgYMapper">
<insert id="insertPollution"> <insert id="insertPollution">
INSERT INTO r_stat_pollution_org_y ( org_id, data_date, pollution_type, `value`) VALUES INSERT INTO r_stat_pollution_org_y ( org_id, data_date, pollution_type, `value`) VALUES

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/RStatPollutionSubstationDMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RStatPollutionSubstationDMapper.xml
View File

@@ -1,6 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.RStatPollutionSubstationDMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.RStatPollutionSubstationDMapper">
<insert id="insertPollution"> <insert id="insertPollution">
INSERT INTO r_stat_pollution_substation_d ( substation_id, data_date, pollution_type, `value`) VALUES INSERT INTO r_stat_pollution_substation_d ( substation_id, data_date, pollution_type, `value`) VALUES

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/RStatPollutionSubstationMMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RStatPollutionSubstationMMapper.xml
View File

@@ -1,6 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.RStatPollutionSubstationMMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.RStatPollutionSubstationMMapper">
<insert id="insertPollution"> <insert id="insertPollution">
INSERT INTO r_stat_pollution_substation_m ( substation_id, data_date, pollution_type, `value`) VALUES INSERT INTO r_stat_pollution_substation_m ( substation_id, data_date, pollution_type, `value`) VALUES

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/RStatPollutionSubstationQMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RStatPollutionSubstationQMapper.xml
View File

@@ -1,6 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.RStatPollutionSubstationQMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.RStatPollutionSubstationQMapper">
<insert id="insertPollution"> <insert id="insertPollution">
INSERT INTO r_stat_pollution_substation_q ( substation_id, data_date, pollution_type, `value`) VALUES INSERT INTO r_stat_pollution_substation_q ( substation_id, data_date, pollution_type, `value`) VALUES

2
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/line/mapping/RStatPollutionSubstationYMapper.xml → pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RStatPollutionSubstationYMapper.xml
View File

@@ -1,6 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.njcn.prepare.harmonic.mapper.line.RStatPollutionSubstationYMapper"> <mapper namespace="com.njcn.prepare.harmonic.mapper.mysql.line.RStatPollutionSubstationYMapper">
<insert id="insertPollution"> <insert id="insertPollution">
INSERT INTO r_stat_pollution_substation_y ( substation_id, data_date, pollution_type, `value`) VALUES INSERT INTO r_stat_pollution_substation_y ( substation_id, data_date, pollution_type, `value`) VALUES

9
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/substion/subMapper.java
View File

@@ -1,9 +0,0 @@
package com.njcn.prepare.harmonic.mapper.substion;
/**
* @author denghuajun
* @version 1.0.0
* @date 2022年10月17日 20:16
*/
public interface subMapper {
}

9
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/mapper/voltage/VoltageMapper.java
View File

@@ -1,9 +0,0 @@
package com.njcn.prepare.harmonic.mapper.voltage;
/**
* @author denghuajun
* @version 1.0.0
* @date 2022年10月17日 20:16
*/
public interface VoltageMapper {
}

9
pqs-prepare/harmonic-prepare/src/main/java/com/njcn/prepare/harmonic/pojo/dto/LineDTO.java
View File

@@ -1,9 +0,0 @@
package com.njcn.prepare.harmonic.pojo.dto;
/**
* @author denghuajun
* @version 1.0.0
* @date 2022年10月17日 20:17
*/
public class LineDTO {
}

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