Other/data-migration
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

异常数据判断调整

Browse Source
This commit is contained in:
xy
2024-06-02 10:37:54 +08:00
parent a3c70fb545
commit 653a2f4eeb
1 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
mysql-data/mysql-target/src/main/java/com/njcn/mysql/util/PubUtils.java
View File

@@ -64,28 +64,27 @@ public class PubUtils {
try { try {
String methodName1 = "getFreq" + (Objects.isNull(type)?"":type); String methodName1 = "getFreq" + (Objects.isNull(type)?"":type);
Method method1 = data.getClass().getMethod(methodName1); Method method1 = data.getClass().getMethod(methodName1);
//防止数据异常大，超过数据库字段设置的大小 float value1 = (Float) method1.invoke(data);
float value1 = Math.min((Float) method1.invoke(data), 999999.0f);
String methodName2 = "getVuDev" + (Objects.isNull(type)?"":type); String methodName2 = "getVuDev" + (Objects.isNull(type)?"":type);
Method method2 = data.getClass().getMethod(methodName2); Method method2 = data.getClass().getMethod(methodName2);
float value2 = Math.min((Float) method2.invoke(data), 999999.0f); float value2 = (Float) method2.invoke(data);
String methodName3 = "getVlDev" + (Objects.isNull(type)?"":type); String methodName3 = "getVlDev" + (Objects.isNull(type)?"":type);
Method method3 = data.getClass().getMethod(methodName3); Method method3 = data.getClass().getMethod(methodName3);
float value3 = Math.min((Float) method3.invoke(data), 999999.0f); float value3 = (Float) method3.invoke(data);
String methodName4 = "getFreqDev" + (Objects.isNull(type)?"":type); String methodName4 = "getFreqDev" + (Objects.isNull(type)?"":type);
Method method4 = data.getClass().getMethod(methodName4); Method method4 = data.getClass().getMethod(methodName4);
float value4 = Math.min((Float) method4.invoke(data), 999999.0f); float value4 = (Float) method4.invoke(data);
String methodName5 = "getVUnbalance" + (Objects.isNull(type)?"":type); String methodName5 = "getVUnbalance" + (Objects.isNull(type)?"":type);
Method method5 = data.getClass().getMethod(methodName5); Method method5 = data.getClass().getMethod(methodName5);
float value5 = Math.min((Float) method5.invoke(data), 999999.0f); float value5 = (Float) method5.invoke(data);
String methodName6 = "getVThd" + (Objects.isNull(type)?"":type); String methodName6 = "getVThd" + (Objects.isNull(type)?"":type);
Method method6 = data.getClass().getMethod(methodName6); Method method6 = data.getClass().getMethod(methodName6);
float value6 = Math.min((Float) method6.invoke(data), 999999.0f); float value6 = (Float) method6.invoke(data);
List<String> phase = Arrays.asList("A","B","C"); List<String> phase = Arrays.asList("A","B","C");
//频率异常判断 //频率异常判断