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

1.oracle同步mysql代码

Browse Source 
2.编写最大最小限值，赋值注解
This commit is contained in:
wr
2024-06-02 14:58:25 +08:00
parent 653a2f4eeb
commit ad8fcd8d33
25 changed files with 1188 additions and 312 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
mysql-data/mysql-source/src/main/java/com/njcn/mysql/bo/po/RStatAssesD.java
View File

@@ -3,6 +3,7 @@ package com.njcn.mysql.bo.po;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import com.github.jeffreyning.mybatisplus.anno.MppMultiId;
import com.njcn.mysql.bo.util.CompareValue;
import lombok.Data;
import java.io.Serializable;
@@ -28,17 +29,22 @@ public class RStatAssesD implements Serializable {
private String lineId;
@TableField(value = "vu_dev")
@CompareValue()
private Double vuDev;
@TableField(value = "freq_dev")
@CompareValue()
private Double freqDev;
@TableField(value = "data_plt")
@CompareValue()
private Double dataPlt;
@TableField(value = "v_unbalance_cp95")
@CompareValue()
private Double vUnbalanceCp95;
@TableField(value = "v_thd_cp95")
@CompareValue()
private Double vThdCp95;
}

31
mysql-data/mysql-source/src/main/java/com/njcn/mysql/bo/po/RStatComassesD.java
View File

@@ -3,6 +3,7 @@ package com.njcn.mysql.bo.po;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import com.github.jeffreyning.mybatisplus.anno.MppMultiId;
import com.njcn.mysql.bo.util.CompareValue;
import lombok.Data;
import java.io.Serializable;
@@ -28,93 +29,123 @@ public class RStatComassesD implements Serializable {
private String lineId;
@TableField(value = "freq_dev1")
@CompareValue()
private Double freqDev1;
@TableField(value = "freq_dev2")
@CompareValue()
private Double freqDev2;
@TableField(value = "freq_dev3")
@CompareValue()
private Double freqDev3;
@TableField(value = "freq_dev4")
@CompareValue()
private Double freqDev4;
@TableField(value = "freq_dev5")
@CompareValue()
private Double freqDev5;
@TableField(value = "vu_dev1")
@CompareValue()
private Double vuDev1;
@TableField(value = "vu_dev2")
@CompareValue()
private Double vuDev2;
@TableField(value = "vu_dev3")
@CompareValue()
private Double vuDev3;
@TableField(value = "vu_dev4")
@CompareValue()
private Double vuDev4;
@TableField(value = "vu_dev5")
@CompareValue()
private Double vuDev5;
@TableField(value = "data_plt1")
@CompareValue()
private Double dataPst1;
@TableField(value = "data_plt2")
@CompareValue()
private Double dataPst2;
@TableField(value = "data_plt3")
@CompareValue()
private Double dataPst3;
@TableField(value = "data_plt4")
@CompareValue()
private Double dataPst4;
@TableField(value = "data_plt5")
@CompareValue()
private Double dataPst5;
@TableField(value = "v_unbalance1")
@CompareValue()
private Double vUnbalance1;
@TableField(value = "v_unbalance2")
@CompareValue()
private Double vUnbalance2;
@TableField(value = "v_unbalance3")
@CompareValue()
private Double vUnbalance3;
@TableField(value = "v_unbalance4")
@CompareValue()
private Double vUnbalance4;
@TableField(value = "v_unbalance5")
@CompareValue()
private Double vUnbalance5;
@TableField(value = "v_thd1")
@CompareValue()
private Double vThd1;
@TableField(value = "v_thd2")
@CompareValue()
private Double vThd2;
@TableField(value = "v_thd3")
@CompareValue()
private Double vThd3;
@TableField(value = "v_thd4")
@CompareValue()
private Double vThd4;
@TableField(value = "v_thd5")
@CompareValue()
private Double vThd5;
@TableField(value = "event1")
@CompareValue()
private Double event1;
@TableField(value = "event2")
@CompareValue()
private Double event2;
@TableField(value = "event3")
@CompareValue()
private Double event3;
@TableField(value = "event4")
@CompareValue()
private Double event4;
@TableField(value = "event5")
@CompareValue()
private Double event5;
}

10
mysql-data/mysql-source/src/main/java/com/njcn/mysql/bo/po/RStatDataFlickerD.java
View File

@@ -3,6 +3,7 @@ package com.njcn.mysql.bo.po;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import com.github.jeffreyning.mybatisplus.anno.MppMultiId;
import com.njcn.mysql.bo.util.CompareValue;
import lombok.Data;
import java.io.Serializable;
@@ -39,12 +40,15 @@ public class RStatDataFlickerD implements Serializable {
private Integer qualityFlag;
@TableField(value = "fluc")
private Double fluc;
@CompareValue()
private Float fluc;
@TableField(value = "plt")
private Double plt;
@CompareValue()
private Float plt;
@TableField(value = "pst")
private Double pst;
@CompareValue()
private Float pst;
}

51
mysql-data/mysql-source/src/main/java/com/njcn/mysql/bo/po/RStatDataHarmrateVD.java
View File

@@ -3,6 +3,7 @@ package com.njcn.mysql.bo.po;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import com.github.jeffreyning.mybatisplus.anno.MppMultiId;
import com.njcn.mysql.bo.util.CompareValue;
import lombok.Data;
import java.io.Serializable;
@@ -39,152 +40,202 @@ public class RStatDataHarmrateVD implements Serializable {
private Integer qualityFlag;
@TableField(value = "v_1")
@CompareValue()
private Float v1;
@TableField(value = "v_2")
@CompareValue()
private Float v2;
@TableField(value = "v_3")
@CompareValue()
private Float v3;
@TableField(value = "v_4")
@CompareValue()
private Float v4;
@TableField(value = "v_5")
@CompareValue()
private Float v5;
@TableField(value = "v_6")
@CompareValue()
private Float v6;
@TableField(value = "v_7")
@CompareValue()
private Float v7;
@TableField(value = "v_8")
@CompareValue()
private Float v8;
@TableField(value = "v_9")
@CompareValue()
private Float v9;
@TableField(value = "v_10")
@CompareValue()
private Float v10;
@TableField(value = "v_11")
@CompareValue()
private Float v11;
@TableField(value = "v_12")
@CompareValue()
private Float v12;
@TableField(value = "v_13")
@CompareValue()
private Float v13;
@TableField(value = "v_14")
@CompareValue()
private Float v14;
@TableField(value = "v_15")
@CompareValue()
private Float v15;
@TableField(value = "v_16")
@CompareValue()
private Float v16;
@TableField(value = "v_17")
@CompareValue()
private Float v17;
@TableField(value = "v_18")
@CompareValue()
private Float v18;
@TableField(value = "v_19")
@CompareValue()
private Float v19;
@TableField(value = "v_20")
@CompareValue()
private Float v20;
@TableField(value = "v_21")
@CompareValue()
private Float v21;
@TableField(value = "v_22")
@CompareValue()
private Float v22;
@TableField(value = "v_23")
@CompareValue()
private Float v23;
@TableField(value = "v_24")
@CompareValue()
private Float v24;
@TableField(value = "v_25")
@CompareValue()
private Float v25;
@TableField(value = "v_26")
@CompareValue()
private Float v26;
@TableField(value = "v_27")
@CompareValue()
private Float v27;
@TableField(value = "v_28")
@CompareValue()
private Float v28;
@TableField(value = "v_29")
@CompareValue()
private Float v29;
@TableField(value = "v_30")
@CompareValue()
private Float v30;
@TableField(value = "v_31")
@CompareValue()
private Float v31;
@TableField(value = "v_32")
@CompareValue()
private Float v32;
@TableField(value = "v_33")
@CompareValue()
private Float v33;
@TableField(value = "v_34")
@CompareValue()
private Float v34;
@TableField(value = "v_35")
@CompareValue()
private Float v35;
@TableField(value = "v_36")
@CompareValue()
private Float v36;
@TableField(value = "v_37")
@CompareValue()
private Float v37;
@TableField(value = "v_38")
@CompareValue()
private Float v38;
@TableField(value = "v_39")
@CompareValue()
private Float v39;
@TableField(value = "v_40")
@CompareValue()
private Float v40;
@TableField(value = "v_41")
@CompareValue()
private Float v41;
@TableField(value = "v_42")
@CompareValue()
private Float v42;
@TableField(value = "v_43")
@CompareValue()
private Float v43;
@TableField(value = "v_44")
@CompareValue()
private Float v44;
@TableField(value = "v_45")
@CompareValue()
private Float v45;
@TableField(value = "v_46")
@CompareValue()
private Float v46;
@TableField(value = "v_47")
@CompareValue()
private Float v47;
@TableField(value = "v_48")
@CompareValue()
private Float v48;
@TableField(value = "v_49")
@CompareValue()
private Float v49;
@TableField(value = "v_50")
@CompareValue()
private Float v50;
}

57
mysql-data/mysql-source/src/main/java/com/njcn/mysql/bo/po/RStatDataID.java
View File

@@ -3,6 +3,7 @@ package com.njcn.mysql.bo.po;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import com.github.jeffreyning.mybatisplus.anno.MppMultiId;
import com.njcn.mysql.bo.util.CompareValue;
import lombok.Data;
import java.io.Serializable;
@@ -39,171 +40,227 @@ public class RStatDataID implements Serializable {
private Integer qualityFlag;
@TableField(value = "i_neg")
@CompareValue()
private Float iNeg;
@TableField(value = "i_pos")
@CompareValue()
private Float iPos;
@TableField(value = "i_thd")
@CompareValue()
private Float iThd;
@TableField(value = "i_unbalance")
@CompareValue()
private Float iUnbalance;
@TableField(value = "i_zero")
@CompareValue()
private Float iZero;
@TableField(value = "rms")
@CompareValue()
private Float rms;
@TableField(value = "i_1")
@CompareValue()
private Float i1;
@TableField(value = "i_2")
@CompareValue()
private Float i2;
@TableField(value = "i_3")
@CompareValue()
private Float i3;
@TableField(value = "i_4")
@CompareValue()
private Float i4;
@TableField(value = "i_5")
@CompareValue()
private Float i5;
@TableField(value = "i_6")
@CompareValue()
private Float i6;
@TableField(value = "i_7")
@CompareValue()
private Float i7;
@TableField(value = "i_8")
@CompareValue()
private Float i8;
@TableField(value = "i_9")
@CompareValue()
private Float i9;
@TableField(value = "i_10")
@CompareValue()
private Float i10;
@TableField(value = "i_11")
@CompareValue()
private Float i11;
@TableField(value = "i_12")
@CompareValue()
private Float i12;
@TableField(value = "i_13")
@CompareValue()
private Float i13;
@TableField(value = "i_14")
@CompareValue()
private Float i14;
@TableField(value = "i_15")
@CompareValue()
private Float i15;
@TableField(value = "i_16")
@CompareValue()
private Float i16;
@TableField(value = "i_17")
@CompareValue()
private Float i17;
@TableField(value = "i_18")
@CompareValue()
private Float i18;
@TableField(value = "i_19")
@CompareValue()
private Float i19;
@TableField(value = "i_20")
@CompareValue()
private Float i20;
@TableField(value = "i_21")
@CompareValue()
private Float i21;
@TableField(value = "i_22")
@CompareValue()
private Float i22;
@TableField(value = "i_23")
@CompareValue()
private Float i23;
@TableField(value = "i_24")
@CompareValue()
private Float i24;
@TableField(value = "i_25")
@CompareValue()
private Float i25;
@TableField(value = "i_26")
@CompareValue()
private Float i26;
@TableField(value = "i_27")
@CompareValue()
private Float i27;
@TableField(value = "i_28")
@CompareValue()
private Float i28;
@TableField(value = "i_29")
@CompareValue()
private Float i29;
@TableField(value = "i_30")
@CompareValue()
private Float i30;
@TableField(value = "i_31")
@CompareValue()
private Float i31;
@TableField(value = "i_32")
@CompareValue()
private Float i32;
@TableField(value = "i_33")
@CompareValue()
private Float i33;
@TableField(value = "i_34")
@CompareValue()
private Float i34;
@TableField(value = "i_35")
@CompareValue()
private Float i35;
@TableField(value = "i_36")
@CompareValue()
private Float i36;
@TableField(value = "i_37")
@CompareValue()
private Float i37;
@TableField(value = "i_38")
@CompareValue()
private Float i38;
@TableField(value = "i_39")
@CompareValue()
private Float i39;
@TableField(value = "i_40")
@CompareValue()
private Float i40;
@TableField(value = "i_41")
@CompareValue()
private Float i41;
@TableField(value = "i_42")
@CompareValue()
private Float i42;
@TableField(value = "i_43")
@CompareValue()
private Float i43;
@TableField(value = "i_44")
@CompareValue()
private Float i44;
@TableField(value = "i_45")
@CompareValue()
private Float i45;
@TableField(value = "i_46")
@CompareValue()
private Float i46;
@TableField(value = "i_47")
@CompareValue()
private Float i47;
@TableField(value = "i_48")
@CompareValue()
private Float i48;
@TableField(value = "i_49")
@CompareValue()
private Float i49;
@TableField(value = "i_50")
@CompareValue()
private Float i50;
}

151
mysql-data/mysql-source/src/main/java/com/njcn/mysql/bo/po/RStatDataInharmVD.java
View File

@@ -3,6 +3,7 @@ package com.njcn.mysql.bo.po;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import com.github.jeffreyning.mybatisplus.anno.MppMultiId;
import com.njcn.mysql.bo.util.CompareValue;
import lombok.Data;
import java.io.Serializable;
@@ -39,153 +40,203 @@ public class RStatDataInharmVD implements Serializable {
private Integer qualityFlag;
@TableField(value = "v_1")
private Double v1;
@CompareValue()
private Float v1;
@TableField(value = "v_2")
private Double v2;
@CompareValue()
private Float v2;
@TableField(value = "v_3")
private Double v3;
@CompareValue()
private Float v3;
@TableField(value = "v_4")
private Double v4;
@CompareValue()
private Float v4;
@TableField(value = "v_5")
private Double v5;
@CompareValue()
private Float v5;
@TableField(value = "v_6")
private Double v6;
@CompareValue()
private Float v6;
@TableField(value = "v_7")
private Double v7;
@CompareValue()
private Float v7;
@TableField(value = "v_8")
private Double v8;
@CompareValue()
private Float v8;
@TableField(value = "v_9")
private Double v9;
@CompareValue()
private Float v9;
@TableField(value = "v_10")
private Double v10;
@CompareValue()
private Float v10;
@TableField(value = "v_11")
private Double v11;
@CompareValue()
private Float v11;
@TableField(value = "v_12")
private Double v12;
@CompareValue()
private Float v12;
@TableField(value = "v_13")
private Double v13;
@CompareValue()
private Float v13;
@TableField(value = "v_14")
private Double v14;
@CompareValue()
private Float v14;
@TableField(value = "v_15")
private Double v15;
@CompareValue()
private Float v15;
@TableField(value = "v_16")
private Double v16;
@CompareValue()
private Float v16;
@TableField(value = "v_17")
private Double v17;
@CompareValue()
private Float v17;
@TableField(value = "v_18")
private Double v18;
@CompareValue()
private Float v18;
@TableField(value = "v_19")
private Double v19;
@CompareValue()
private Float v19;
@TableField(value = "v_20")
private Double v20;
@CompareValue()
private Float v20;
@TableField(value = "v_21")
private Double v21;
@CompareValue()
private Float v21;
@TableField(value = "v_22")
private Double v22;
@CompareValue()
private Float v22;
@TableField(value = "v_23")
private Double v23;
@CompareValue()
private Float v23;
@TableField(value = "v_24")
private Double v24;
@CompareValue()
private Float v24;
@TableField(value = "v_25")
private Double v25;
@CompareValue()
private Float v25;
@TableField(value = "v_26")
private Double v26;
@CompareValue()
private Float v26;
@TableField(value = "v_27")
private Double v27;
@CompareValue()
private Float v27;
@TableField(value = "v_28")
private Double v28;
@CompareValue()
private Float v28;
@TableField(value = "v_29")
private Double v29;
@CompareValue()
private Float v29;
@TableField(value = "v_30")
private Double v30;
@CompareValue()
private Float v30;
@TableField(value = "v_31")
private Double v31;
@CompareValue()
private Float v31;
@TableField(value = "v_32")
private Double v32;
@CompareValue()
private Float v32;
@TableField(value = "v_33")
private Double v33;
@CompareValue()
private Float v33;
@TableField(value = "v_34")
private Double v34;
@CompareValue()
private Float v34;
@TableField(value = "v_35")
private Double v35;
@CompareValue()
private Float v35;
@TableField(value = "v_36")
private Double v36;
@CompareValue()
private Float v36;
@TableField(value = "v_37")
private Double v37;
@CompareValue()
private Float v37;
@TableField(value = "v_38")
private Double v38;
@CompareValue()
private Float v38;
@TableField(value = "v_39")
private Double v39;
@CompareValue()
private Float v39;
@TableField(value = "v_40")
private Double v40;
@CompareValue()
private Float v40;
@TableField(value = "v_41")
private Double v41;
@CompareValue()
private Float v41;
@TableField(value = "v_42")
private Double v42;
@CompareValue()
private Float v42;
@TableField(value = "v_43")
private Double v43;
@CompareValue()
private Float v43;
@TableField(value = "v_44")
private Double v44;
@CompareValue()
private Float v44;
@TableField(value = "v_45")
private Double v45;
@CompareValue()
private Float v45;
@TableField(value = "v_46")
private Double v46;
@CompareValue()
private Float v46;
@TableField(value = "v_47")
private Double v47;
@CompareValue()
private Float v47;
@TableField(value = "v_48")
private Double v48;
@CompareValue()
private Float v48;
@TableField(value = "v_49")
private Double v49;
@CompareValue()
private Float v49;
@TableField(value = "v_50")
private Double v50;
@CompareValue()
private Float v50;
}

5
mysql-data/mysql-source/src/main/java/com/njcn/mysql/bo/po/RStatDataPltD.java
View File

@@ -3,8 +3,10 @@ package com.njcn.mysql.bo.po;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import com.github.jeffreyning.mybatisplus.anno.MppMultiId;
import com.njcn.mysql.bo.util.CompareValue;
import lombok.Data;
import javax.validation.constraints.Max;
import java.io.Serializable;
import java.time.LocalDate;
@@ -39,6 +41,7 @@ public class RStatDataPltD implements Serializable {
private Integer qualityFlag;
@TableField(value = "plt")
private Double plt;
@CompareValue()
private Float plt;
}

62
mysql-data/mysql-source/src/main/java/com/njcn/mysql/bo/po/RStatDataVD.java
View File

@@ -3,6 +3,7 @@ package com.njcn.mysql.bo.po;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import com.github.jeffreyning.mybatisplus.anno.MppMultiId;
import com.njcn.mysql.bo.util.CompareValue;
import lombok.Data;
import java.io.Serializable;
@@ -39,186 +40,247 @@ public class RStatDataVD implements Serializable {
private Integer qualityFlag;
@TableField(value = "freq")
@CompareValue()
private Float freq;
@TableField(value = "freq_dev")
@CompareValue()
private Float freqDev;
@TableField(value = "rms")
@CompareValue()
private Float rms;
@TableField(value = "rms_lvr")
@CompareValue()
private Float rmsLvr;
@TableField(value = "v_neg")
@CompareValue()
private Float vNeg;
@TableField(value = "v_pos")
@CompareValue()
private Float vPos;
@TableField(value = "v_thd")
@CompareValue()
private Float vThd;
@TableField(value = "v_unbalance")
@CompareValue()
private Float vUnbalance;
@TableField(value = "v_zero")
@CompareValue()
private Float vZero;
@TableField(value = "vl_dev")
@CompareValue()
private Float vlDev;
@TableField(value = "vu_dev")
@CompareValue()
private Float vuDev;
@TableField(value = "v_1")
@CompareValue()
private Float v1;
@TableField(value = "v_2")
@CompareValue()
private Float v2;
@TableField(value = "v_3")
@CompareValue()
private Float v3;
@TableField(value = "v_4")
@CompareValue()
private Float v4;
@TableField(value = "v_5")
@CompareValue()
private Float v5;
@TableField(value = "v_6")
@CompareValue()
private Float v6;
@TableField(value = "v_7")
@CompareValue()
private Float v7;
@TableField(value = "v_8")
@CompareValue()
private Float v8;
@TableField(value = "v_9")
@CompareValue()
private Float v9;
@TableField(value = "v_10")
@CompareValue()
private Float v10;
@TableField(value = "v_11")
@CompareValue()
private Float v11;
@TableField(value = "v_12")
@CompareValue()
private Float v12;
@TableField(value = "v_13")
@CompareValue()
private Float v13;
@TableField(value = "v_14")
@CompareValue()
private Float v14;
@TableField(value = "v_15")
@CompareValue()
private Float v15;
@TableField(value = "v_16")
@CompareValue()
private Float v16;
@TableField(value = "v_17")
@CompareValue()
private Float v17;
@TableField(value = "v_18")
@CompareValue()
private Float v18;
@TableField(value = "v_19")
@CompareValue()
private Float v19;
@TableField(value = "v_20")
@CompareValue()
private Float v20;
@TableField(value = "v_21")
@CompareValue()
private Float v21;
@TableField(value = "v_22")
@CompareValue()
private Float v22;
@TableField(value = "v_23")
@CompareValue()
private Float v23;
@TableField(value = "v_24")
@CompareValue()
private Float v24;
@TableField(value = "v_25")
@CompareValue()
private Float v25;
@TableField(value = "v_26")
@CompareValue()
private Float v26;
@TableField(value = "v_27")
@CompareValue()
private Float v27;
@TableField(value = "v_28")
@CompareValue()
private Float v28;
@TableField(value = "v_29")
@CompareValue()
private Float v29;
@TableField(value = "v_30")
@CompareValue()
private Float v30;
@TableField(value = "v_31")
@CompareValue()
private Float v31;
@TableField(value = "v_32")
@CompareValue()
private Float v32;
@TableField(value = "v_33")
@CompareValue()
private Float v33;
@TableField(value = "v_34")
@CompareValue()
private Float v34;
@TableField(value = "v_35")
@CompareValue()
private Float v35;
@TableField(value = "v_36")
@CompareValue()
private Float v36;
@TableField(value = "v_37")
@CompareValue()
private Float v37;
@TableField(value = "v_38")
@CompareValue()
private Float v38;
@TableField(value = "v_39")
@CompareValue()
private Float v39;
@TableField(value = "v_40")
@CompareValue()
private Float v40;
@TableField(value = "v_41")
@CompareValue()
private Float v41;
@TableField(value = "v_42")
@CompareValue()
private Float v42;
@TableField(value = "v_43")
@CompareValue()
private Float v43;
@TableField(value = "v_44")
@CompareValue()
private Float v44;
@TableField(value = "v_45")
@CompareValue()
private Float v45;
@TableField(value = "v_46")
@CompareValue()
private Float v46;
@TableField(value = "v_47")
@CompareValue()
private Float v47;
@TableField(value = "v_48")
@CompareValue()
private Float v48;
@TableField(value = "v_49")
@CompareValue()
private Float v49;
@TableField(value = "v_50")
@CompareValue()
private Float v50;
}

73
mysql-data/mysql-source/src/main/java/com/njcn/mysql/bo/po/RStatLimitRateD.java
View File

@@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.github.jeffreyning.mybatisplus.anno.MppMultiId;
import com.njcn.mysql.bo.util.CompareValue;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@@ -41,48 +42,56 @@ public class RStatLimitRateD {
* 总计算次数
*/
@TableField(value = "all_time")
@CompareValue()
private Integer allTime;
/**
* 闪变越限次数
*/
@TableField(value = "flicker_overtime")
@CompareValue()
private Integer flickerOvertime;
/**
* 闪变总计算次数
*/
@TableField(value = "flicker_all_time")
@CompareValue()
private Integer flickerAllTime;
/**
* 频率偏差越限次数
*/
@TableField(value = "freq_dev_overtime")
@CompareValue()
private Integer freqDevOvertime;
/**
* 电压偏差越限次数
*/
@TableField(value = "voltage_dev_overtime")
@CompareValue()
private Integer voltageDevOvertime;
/**
* 三相电压不平衡度越限次数
*/
@TableField(value = "ubalance_overtime")
@CompareValue()
private Integer ubalanceOvertime;
/**
* 电压谐波畸变率越限次数
*/
@TableField(value = "uaberrance_overtime")
@CompareValue()
private Integer uaberranceOvertime;
/**
* 负序电流限值次数
*/
@TableField(value = "i_neg_overtime")
@CompareValue()
private Integer iNegOvertime;
/**
@@ -90,6 +99,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_2_overtime")
@CompareValue()
private Integer uharm2Overtime;
/**
@@ -97,6 +107,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_3_overtime")
@CompareValue()
private Integer uharm3Overtime;
/**
@@ -104,6 +115,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_4_overtime")
@CompareValue()
private Integer uharm4Overtime;
/**
@@ -111,6 +123,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_5_overtime")
@CompareValue()
private Integer uharm5Overtime;
/**
@@ -118,6 +131,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_6_overtime")
@CompareValue()
private Integer uharm6Overtime;
/**
@@ -125,6 +139,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_7_overtime")
@CompareValue()
private Integer uharm7Overtime;
/**
@@ -132,6 +147,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_8_overtime")
@CompareValue()
private Integer uharm8Overtime;
/**
@@ -139,6 +155,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_9_overtime")
@CompareValue()
private Integer uharm9Overtime;
/**
@@ -146,6 +163,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_10_overtime")
@CompareValue()
private Integer uharm10Overtime;
/**
@@ -153,6 +171,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_11_overtime")
@CompareValue()
private Integer uharm11Overtime;
/**
@@ -160,6 +179,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_12_overtime")
@CompareValue()
private Integer uharm12Overtime;
/**
@@ -167,6 +187,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_13_overtime")
@CompareValue()
private Integer uharm13Overtime;
/**
@@ -174,6 +195,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_14_overtime")
@CompareValue()
private Integer uharm14Overtime;
/**
@@ -181,6 +203,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_15_overtime")
@CompareValue()
private Integer uharm15Overtime;
/**
@@ -188,6 +211,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_16_overtime")
@CompareValue()
private Integer uharm16Overtime;
/**
@@ -195,6 +219,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_17_overtime")
@CompareValue()
private Integer uharm17Overtime;
/**
@@ -202,6 +227,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_18_overtime")
@CompareValue()
private Integer uharm18Overtime;
/**
@@ -209,6 +235,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_19_overtime")
@CompareValue()
private Integer uharm19Overtime;
/**
@@ -216,6 +243,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_20_overtime")
@CompareValue()
private Integer uharm20Overtime;
/**
@@ -223,6 +251,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_21_overtime")
@CompareValue()
private Integer uharm21Overtime;
/**
@@ -230,6 +259,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_22_overtime")
@CompareValue()
private Integer uharm22Overtime;
/**
@@ -237,6 +267,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_23_overtime")
@CompareValue()
private Integer uharm23Overtime;
/**
@@ -244,6 +275,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_24_overtime")
@CompareValue()
private Integer uharm24Overtime;
/**
@@ -251,6 +283,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "uharm_25_overtime")
@CompareValue()
private Integer uharm25Overtime;
/**
@@ -258,6 +291,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_2_overtime")
@CompareValue()
private Integer iharm2Overtime;
/**
@@ -265,6 +299,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_3_overtime")
@CompareValue()
private Integer iharm3Overtime;
/**
@@ -272,6 +307,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_4_overtime")
@CompareValue()
private Integer iharm4Overtime;
/**
@@ -279,6 +315,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_5_overtime")
@CompareValue()
private Integer iharm5Overtime;
/**
@@ -286,6 +323,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_6_overtime")
@CompareValue()
private Integer iharm6Overtime;
/**
@@ -293,6 +331,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_7_overtime")
@CompareValue()
private Integer iharm7Overtime;
/**
@@ -300,6 +339,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_8_overtime")
@CompareValue()
private Integer iharm8Overtime;
/**
@@ -307,6 +347,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_9_overtime")
@CompareValue()
private Integer iharm9Overtime;
/**
@@ -314,6 +355,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_10_overtime")
@CompareValue()
private Integer iharm10Overtime;
/**
@@ -321,6 +363,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_11_overtime")
@CompareValue()
private Integer iharm11Overtime;
/**
@@ -328,6 +371,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_12_overtime")
@CompareValue()
private Integer iharm12Overtime;
/**
@@ -335,6 +379,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_13_overtime")
@CompareValue()
private Integer iharm13Overtime;
/**
@@ -342,6 +387,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_14_overtime")
@CompareValue()
private Integer iharm14Overtime;
/**
@@ -349,6 +395,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_15_overtime")
@CompareValue()
private Integer iharm15Overtime;
/**
@@ -356,6 +403,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_16_overtime")
@CompareValue()
private Integer iharm16Overtime;
/**
@@ -363,6 +411,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_17_overtime")
@CompareValue()
private Integer iharm17Overtime;
/**
@@ -370,6 +419,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_18_overtime")
@CompareValue()
private Integer iharm18Overtime;
/**
@@ -377,6 +427,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_19_overtime")
@CompareValue()
private Integer iharm19Overtime;
/**
@@ -384,6 +435,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_20_overtime")
@CompareValue()
private Integer iharm20Overtime;
/**
@@ -391,6 +443,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_21_overtime")
@CompareValue()
private Integer iharm21Overtime;
/**
@@ -398,6 +451,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_22_overtime")
@CompareValue()
private Integer iharm22Overtime;
/**
@@ -405,6 +459,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_23_overtime")
@CompareValue()
private Integer iharm23Overtime;
/**
@@ -412,6 +467,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_24_overtime")
@CompareValue()
private Integer iharm24Overtime;
/**
@@ -419,6 +475,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "iharm_25_overtime")
@CompareValue()
private Integer iharm25Overtime;
/**
@@ -426,6 +483,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "inuharm_1_overtime")
@CompareValue()
private Integer inuharm1Overtime;
/**
@@ -433,6 +491,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "inuharm_2_overtime")
@CompareValue()
private Integer inuharm2Overtime;
/**
@@ -440,6 +499,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "inuharm_3_overtime")
@CompareValue()
private Integer inuharm3Overtime;
/**
@@ -447,6 +507,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "inuharm_4_overtime")
@CompareValue()
private Integer inuharm4Overtime;
/**
@@ -454,6 +515,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "inuharm_5_overtime")
@CompareValue()
private Integer inuharm5Overtime;
/**
@@ -461,6 +523,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "inuharm_6_overtime")
@CompareValue()
private Integer inuharm6Overtime;
/**
@@ -468,6 +531,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "inuharm_7_overtime")
@CompareValue()
private Integer inuharm7Overtime;
/**
@@ -475,6 +539,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "inuharm_8_overtime")
@CompareValue()
private Integer inuharm8Overtime;
/**
@@ -482,6 +547,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "inuharm_9_overtime")
@CompareValue()
private Integer inuharm9Overtime;
/**
@@ -489,6 +555,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "inuharm_10_overtime")
@CompareValue()
private Integer inuharm10Overtime;
/**
@@ -496,6 +563,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "inuharm_11_overtime")
@CompareValue()
private Integer inuharm11Overtime;
/**
@@ -503,6 +571,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "inuharm_12_overtime")
@CompareValue()
private Integer inuharm12Overtime;
/**
@@ -510,6 +579,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "inuharm_13_overtime")
@CompareValue()
private Integer inuharm13Overtime;
/**
@@ -517,6 +587,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "inuharm_14_overtime")
@CompareValue()
private Integer inuharm14Overtime;
/**
@@ -524,6 +595,7 @@ public class RStatLimitRateD {
*/
@TableField(value = "inuharm_15_overtime")
@CompareValue()
private Integer inuharm15Overtime;
/**
@@ -531,5 +603,6 @@ public class RStatLimitRateD {
*/
@TableField(value = "inuharm_16_overtime")
@CompareValue()
private Integer inuharm16Overtime;
}

73
mysql-data/mysql-source/src/main/java/com/njcn/mysql/bo/po/RStatLimitTargetD.java
View File

@@ -3,6 +3,7 @@ package com.njcn.mysql.bo.po;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import com.github.jeffreyning.mybatisplus.anno.MppMultiId;
import com.njcn.mysql.bo.util.CompareValue;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@@ -39,431 +40,503 @@ public class RStatLimitTargetD {
* 总计算次数
*/
@TableField(value = "all_time")
@CompareValue()
private Integer allTime;
/**
* 闪变总计算次数
*/
@TableField(value = "flicker_all_time")
@CompareValue()
private Integer flickerAllTime;
/**
* 闪变越限次数
*/
@TableField(value = "flicker_overtime")
@CompareValue()
private Integer flickerOvertime;
/**
* 频率偏差越限次数
*/
@TableField(value = "freq_dev_overtime")
@CompareValue()
private Integer freqDevOvertime;
/**
* 电压偏差越限次数
*/
@TableField(value = "voltage_dev_overtime")
@CompareValue()
private Integer voltageDevOvertime;
/**
* 电压不平衡度越限次数
*/
@TableField(value = "ubalance_overtime")
@CompareValue()
private Integer ubalanceOvertime;
/**
* 电压谐波畸变率越限次数
*/
@TableField(value = "uaberrance_overtime")
@CompareValue()
private Integer uaberranceOvertime;
/**
* 负序电流限值次数
*/
@TableField(value = "i_neg_overtime")
@CompareValue()
private Integer iNegOvertime;
/**
* 2次电压谐波含有率越限次数
*/
@TableField(value = "uharm_2_overtime")
@CompareValue()
private Integer uharm2Overtime;
/**
* 3次电压谐波含有率越限次数
*/
@TableField(value = "uharm_3_overtime")
@CompareValue()
private Integer uharm3Overtime;
/**
* 4次电压谐波含有率越限次数
*/
@TableField(value = "uharm_4_overtime")
@CompareValue()
private Integer uharm4Overtime;
/**
* 5次电压谐波含有率越限次数
*/
@TableField(value = "uharm_5_overtime")
@CompareValue()
private Integer uharm5Overtime;
/**
* 6次电压谐波含有率越限次数
*/
@TableField(value = "uharm_6_overtime")
@CompareValue()
private Integer uharm6Overtime;
/**
* 7次电压谐波含有率越限次数
*/
@TableField(value = "uharm_7_overtime")
@CompareValue()
private Integer uharm7Overtime;
/**
* 8次电压谐波含有率越限次数
*/
@TableField(value = "uharm_8_overtime")
@CompareValue()
private Integer uharm8Overtime;
/**
* 9次电压谐波含有率越限次数
*/
@TableField(value = "uharm_9_overtime")
@CompareValue()
private Integer uharm9Overtime;
/**
* 10次电压谐波含有率越限次数
*/
@TableField(value = "uharm_10_overtime")
@CompareValue()
private Integer uharm10Overtime;
/**
* 11次电压谐波含有率越限次数
*/
@TableField(value = "uharm_11_overtime")
@CompareValue()
private Integer uharm11Overtime;
/**
* 12次电压谐波含有率越限次数
*/
@TableField(value = "uharm_12_overtime")
@CompareValue()
private Integer uharm12Overtime;
/**
* 13次电压谐波含有率越限次数
*/
@TableField(value = "uharm_13_overtime")
@CompareValue()
private Integer uharm13Overtime;
/**
* 14次电压谐波含有率越限次数
*/
@TableField(value = "uharm_14_overtime")
@CompareValue()
private Integer uharm14Overtime;
/**
* 15次电压谐波含有率越限次数
*/
@TableField(value = "uharm_15_overtime")
@CompareValue()
private Integer uharm15Overtime;
/**
* 16次电压谐波含有率越限次数
*/
@TableField(value = "uharm_16_overtime")
@CompareValue()
private Integer uharm16Overtime;
/**
* 17次电压谐波含有率越限次数
*/
@TableField(value = "uharm_17_overtime")
@CompareValue()
private Integer uharm17Overtime;
/**
* 18次电压谐波含有率越限次数
*/
@TableField(value = "uharm_18_overtime")
@CompareValue()
private Integer uharm18Overtime;
/**
* 19次电压谐波含有率越限次数
*/
@TableField(value = "uharm_19_overtime")
@CompareValue()
private Integer uharm19Overtime;
/**
* 20次电压谐波含有率越限次数
*/
@TableField(value = "uharm_20_overtime")
@CompareValue()
private Integer uharm20Overtime;
/**
* 21次电压谐波含有率越限次数
*/
@TableField(value = "uharm_21_overtime")
@CompareValue()
private Integer uharm21Overtime;
/**
* 22次电压谐波含有率越限次数
*/
@TableField(value = "uharm_22_overtime")
@CompareValue()
private Integer uharm22Overtime;
/**
* 23次电压谐波含有率越限次数
*/
@TableField(value = "uharm_23_overtime")
@CompareValue()
private Integer uharm23Overtime;
/**
* 24次电压谐波含有率越限次数
*/
@TableField(value = "uharm_24_overtime")
@CompareValue()
private Integer uharm24Overtime;
/**
* 25次电压谐波含有率越限次数
*/
@TableField(value = "uharm_25_overtime")
@CompareValue()
private Integer uharm25Overtime;
/**
* 2次电流谐波幅值越限次数
*/
@TableField(value = "iharm_2_overtime")
@CompareValue()
private Integer iharm2Overtime;
/**
* 3次电流谐波幅值越限次数
*/
@TableField(value = "iharm_3_overtime")
@CompareValue()
private Integer iharm3Overtime;
/**
* 4次电流谐波幅值越限次数
*/
@TableField(value = "iharm_4_overtime")
@CompareValue()
private Integer iharm4Overtime;
/**
* 5次电流谐波幅值越限次数
*/
@TableField(value = "iharm_5_overtime")
@CompareValue()
private Integer iharm5Overtime;
/**
* 6次电流谐波幅值越限次数
*/
@TableField(value = "iharm_6_overtime")
@CompareValue()
private Integer iharm6Overtime;
/**
* 7次电流谐波幅值越限次数
*/
@TableField(value = "iharm_7_overtime")
@CompareValue()
private Integer iharm7Overtime;
/**
* 8次电流谐波幅值越限次数
*/
@TableField(value = "iharm_8_overtime")
@CompareValue()
private Integer iharm8Overtime;
/**
* 9次电流谐波幅值越限次数
*/
@TableField(value = "iharm_9_overtime")
@CompareValue()
private Integer iharm9Overtime;
/**
* 10次电流谐波幅值越限次数
*/
@TableField(value = "iharm_10_overtime")
@CompareValue()
private Integer iharm10Overtime;
/**
* 11次电流谐波幅值越限次数
*/
@TableField(value = "iharm_11_overtime")
@CompareValue()
private Integer iharm11Overtime;
/**
* 12次电流谐波幅值越限次数
*/
@TableField(value = "iharm_12_overtime")
@CompareValue()
private Integer iharm12Overtime;
/**
* 13次电流谐波幅值越限次数
*/
@TableField(value = "iharm_13_overtime")
@CompareValue()
private Integer iharm13Overtime;
/**
* 14次电流谐波幅值越限次数
*/
@TableField(value = "iharm_14_overtime")
@CompareValue()
private Integer iharm14Overtime;
/**
* 15次电流谐波幅值越限次数
*/
@TableField(value = "iharm_15_overtime")
@CompareValue()
private Integer iharm15Overtime;
/**
* 16次电流谐波幅值越限次数
*/
@TableField(value = "iharm_16_overtime")
@CompareValue()
private Integer iharm16Overtime;
/**
* 17次电流谐波幅值越限次数
*/
@TableField(value = "iharm_17_overtime")
@CompareValue()
private Integer iharm17Overtime;
/**
* 18次电流谐波幅值越限次数
*/
@TableField(value = "iharm_18_overtime")
@CompareValue()
private Integer iharm18Overtime;
/**
* 19次电流谐波幅值越限次数
*/
@TableField(value = "iharm_19_overtime")
@CompareValue()
private Integer iharm19Overtime;
/**
* 20次电流谐波幅值越限次数
*/
@TableField(value = "iharm_20_overtime")
@CompareValue()
private Integer iharm20Overtime;
/**
* 21次电流谐波幅值越限次数
*/
@TableField(value = "iharm_21_overtime")
@CompareValue()
private Integer iharm21Overtime;
/**
* 22次电流谐波幅值越限次数
*/
@TableField(value = "iharm_22_overtime")
@CompareValue()
private Integer iharm22Overtime;
/**
* 23次电流谐波幅值越限次数
*/
@TableField(value = "iharm_23_overtime")
@CompareValue()
private Integer iharm23Overtime;
/**
* 24次电流谐波幅值越限次数
*/
@TableField(value = "iharm_24_overtime")
@CompareValue()
private Integer iharm24Overtime;
/**
* 25次电流谐波幅值越限次数
*/
@TableField(value = "iharm_25_overtime")
@CompareValue()
private Integer iharm25Overtime;
/**
* 0.5次间谐波电压限值次数
*/
@TableField(value = "inuharm_1_overtime")
@CompareValue()
private Integer inuharm1Overtime;
/**
* 1.5次间谐波电压限值次数
*/
@TableField(value = "inuharm_2_overtime")
@CompareValue()
private Integer inuharm2Overtime;
/**
* 2.5次间谐波电压限值次数
*/
@TableField(value = "inuharm_3_overtime")
@CompareValue()
private Integer inuharm3Overtime;
/**
* 3.5次间谐波电压限值次数
*/
@TableField(value = "inuharm_4_overtime")
@CompareValue()
private Integer inuharm4Overtime;
/**
* 4.5次间谐波电压限值次数
*/
@TableField(value = "inuharm_5_overtime")
@CompareValue()
private Integer inuharm5Overtime;
/**
* 5.5次间谐波电压限值次数
*/
@TableField(value = "inuharm_6_overtime")
@CompareValue()
private Integer inuharm6Overtime;
/**
* 6.5次间谐波电压限值次数
*/
@TableField(value = "inuharm_7_overtime")
@CompareValue()
private Integer inuharm7Overtime;
/**
* 7.5次间谐波电压限值次数
*/
@TableField(value = "inuharm_8_overtime")
@CompareValue()
private Integer inuharm8Overtime;
/**
* 8.5次间谐波电压限值次数
*/
@TableField(value = "inuharm_9_overtime")
@CompareValue()
private Integer inuharm9Overtime;
/**
* 9.5次间谐波电压限值次数
*/
@TableField(value = "inuharm_10_overtime")
@CompareValue()
private Integer inuharm10Overtime;
/**
* 10.5次间谐波电压限值次数
*/
@TableField(value = "inuharm_11_overtime")
@CompareValue()
private Integer inuharm11Overtime;
/**
* 11.5次间谐波电压限值次数
*/
@TableField(value = "inuharm_12_overtime")
@CompareValue()
private Integer inuharm12Overtime;
/**
* 12.5次间谐波电压限值次数
*/
@TableField(value = "inuharm_13_overtime")
@CompareValue()
private Integer inuharm13Overtime;
/**
* 13.5次间谐波电压限值次数
*/
@TableField(value = "inuharm_14_overtime")
@CompareValue()
private Integer inuharm14Overtime;
/**
* 14.5次间谐波电压限值次数
*/
@TableField(value = "inuharm_15_overtime")
@CompareValue()
private Integer inuharm15Overtime;
/**
* 15.5次间谐波电压限值次数
*/
@TableField(value = "inuharm_16_overtime")
@CompareValue()
private Integer inuharm16Overtime;
}

13
mysql-data/mysql-source/src/main/java/com/njcn/mysql/bo/util/CompareValue.java Normal file
View File

@@ -0,0 +1,13 @@
package com.njcn.mysql.bo.util;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
@Target(ElementType.FIELD)
@Retention(RetentionPolicy.RUNTIME)
public @interface CompareValue {
float maxValue() default 999999.0f;
float minValue() default -999999.0f;
}

22
mysql-data/mysql-source/src/main/java/com/njcn/mysql/service/OracleDataService.java
View File

@@ -1,6 +1,7 @@
package com.njcn.mysql.service;
import com.njcn.oracle.bo.po.*;
import com.njcn.oracle.mapper.DayInharmVMapper;
import java.util.List;
@@ -59,4 +60,25 @@ public interface OracleDataService {
* @return
*/
List<DayI> getDayI(String time);
/**
* 查询oracle中DAY_PLT数据
* @param time
* @return
*/
List<DayPlt> getDayPlt(String time);
/**
* 查询oracle中DAY_FLICKER数据
* @param time
* @return
*/
List<DayFlicker> getDayFlicker(String time);
/**
* 查询oracle中DAY_INHARM_V数据
* @param time
* @return
*/
List<DayInharmV> getDayInHarmV(String time);
}

29
mysql-data/mysql-source/src/main/java/com/njcn/mysql/service/impl/OracleDataServiceImpl.java
View File

@@ -23,10 +23,14 @@ public class OracleDataServiceImpl implements OracleDataService {
private final PqsComAssesMapper pqsComAssesMapper;
private final PqsAssesMapper pqsAssesMapper;
private final DayIMapper dayIMapper;
private final LimitRateMapper limitRateMapper;
private final LimitTargetMapper limitTargetMapper;
private final DayPltMapper dayPltMapper;
private final DayFlickerMapper dayFlickerMapper;
private final DayInharmVMapper dayInharmVMapper;
@Override
public List<DayHarmrateV> getDayHarmRate(String time) {
@@ -83,4 +87,25 @@ public class OracleDataServiceImpl implements OracleDataService {
lambdaQueryWrapper.apply("TIMEID = to_date({0},'yyyy-mm-dd')",time);
return dayIMapper.selectList(lambdaQueryWrapper);
}
@Override
public List<DayPlt> getDayPlt(String time) {
LambdaQueryWrapper<DayPlt> lambdaQueryWrapper = new LambdaQueryWrapper<>();
lambdaQueryWrapper.apply("TIMEID = to_date({0},'yyyy-mm-dd')",time);
return dayPltMapper.selectList(lambdaQueryWrapper);
}
@Override
public List<DayFlicker> getDayFlicker(String time) {
LambdaQueryWrapper<DayFlicker> lambdaQueryWrapper = new LambdaQueryWrapper<>();
lambdaQueryWrapper.apply("TIMEID = to_date({0},'yyyy-mm-dd')",time);
return dayFlickerMapper.selectList(lambdaQueryWrapper);
}
@Override
public List<DayInharmV> getDayInHarmV(String time) {
LambdaQueryWrapper<DayInharmV> lambdaQueryWrapper = new LambdaQueryWrapper<>();
lambdaQueryWrapper.apply("TIMEID = to_date({0},'yyyy-mm-dd')",time);
return dayInharmVMapper.selectList(lambdaQueryWrapper);
}
}

50
mysql-data/mysql-target/src/main/java/com/njcn/mysql/controller/OracleToMysqlController.java
View File

@@ -2,11 +2,14 @@ package com.njcn.mysql.controller;
import cn.hutool.core.date.DatePattern;
import cn.hutool.core.date.LocalDateTimeUtil;
import com.njcn.mysql.bo.po.RStatDataPltD;
import com.njcn.mysql.service.OracleToMysqlService;
import com.njcn.mysql.util.MaxValueProcessor;
import com.njcn.oracle.bo.param.DataAsynParam;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.GetMapping;
@@ -95,7 +98,7 @@ public class OracleToMysqlController {
}
@GetMapping("/dayISync")
@ApiOperation("day_v转成r_stat_data_i_d")
@ApiOperation("day_i转成r_stat_data_i_d")
public Boolean dayISync(@RequestParam("startDateTime")String startDateTime, @RequestParam("endDateTime")String endDateTime) {
DataAsynParam dataAsynParam = new DataAsynParam();
dataAsynParam.setStartDateTime(LocalDateTimeUtil.parse(startDateTime, DatePattern.NORM_DATE_PATTERN));
@@ -103,4 +106,49 @@ public class OracleToMysqlController {
oracleToMysqlService.insertDataI(startDateTime,endDateTime);
return true;// HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, true, "数据同步");
}
@GetMapping("/dayPltSync")
@ApiOperation("day_plt转成r_stat_data_plt_d")
public Boolean dayPltSync(@RequestParam("startDateTime")String startDateTime, @RequestParam("endDateTime")String endDateTime) {
DataAsynParam dataAsynParam = new DataAsynParam();
dataAsynParam.setStartDateTime(LocalDateTimeUtil.parse(startDateTime, DatePattern.NORM_DATE_PATTERN));
dataAsynParam.setEndDateTime(LocalDateTimeUtil.parse(endDateTime, DatePattern.NORM_DATE_PATTERN));
oracleToMysqlService.insertPlt(startDateTime,endDateTime);
return true;// HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, true, "数据同步");
}
@GetMapping("/dayFlickerSync")
@ApiOperation("day_flicker转成r_stat_data_flicker_d")
public Boolean dayFlickerSync(@RequestParam("startDateTime")String startDateTime, @RequestParam("endDateTime")String endDateTime) {
DataAsynParam dataAsynParam = new DataAsynParam();
dataAsynParam.setStartDateTime(LocalDateTimeUtil.parse(startDateTime, DatePattern.NORM_DATE_PATTERN));
dataAsynParam.setEndDateTime(LocalDateTimeUtil.parse(endDateTime, DatePattern.NORM_DATE_PATTERN));
oracleToMysqlService.insertFlicker(startDateTime,endDateTime);
return true;// HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, true, "数据同步");
}
@GetMapping("/dayInHarmVSync")
@ApiOperation("day_inharm_v转成r_stat_data_inharm_v_d")
public Boolean dayInHarmVSync(@RequestParam("startDateTime")String startDateTime, @RequestParam("endDateTime")String endDateTime) {
DataAsynParam dataAsynParam = new DataAsynParam();
dataAsynParam.setStartDateTime(LocalDateTimeUtil.parse(startDateTime, DatePattern.NORM_DATE_PATTERN));
dataAsynParam.setEndDateTime(LocalDateTimeUtil.parse(endDateTime, DatePattern.NORM_DATE_PATTERN));
oracleToMysqlService.insertInHarmV(startDateTime,endDateTime);
return true;// HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, true, "数据同步");
}
public static void main(String[] args) {
RStatDataPltD user = new RStatDataPltD();
user.setPlt(1101111.0f);
try {
MaxValueProcessor.process(user);
System.out.println(user.getPlt());
} catch (Exception e) {
System.out.println("Validation failed: " + e.getMessage());
}
}
}

52
mysql-data/mysql-target/src/main/java/com/njcn/mysql/job/OracleToMysqlDBJob.java Normal file
View File

@@ -0,0 +1,52 @@
package com.njcn.mysql.job;
import cn.hutool.core.date.DatePattern;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.date.LocalDateTimeUtil;
import com.njcn.mysql.service.OracleToMysqlService;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
import java.time.temporal.ChronoUnit;
/**
* Description:
* Date: 2024/1/18 10:15【需求编号】
*
* @author clam
* @version V1.0.0
*/
@Component
@EnableScheduling
@RequiredArgsConstructor
@Slf4j
public class OracleToMysqlDBJob {
private final OracleToMysqlService oracleToMysqlService;
@Scheduled(cron="0 0 7 * * ?")
public void executeEvent() {
// 获取当前时间
String date = DateUtil.format(LocalDateTime.now(), DatePattern.NORM_DATE_PATTERN);
System.out.println("-----------------------------------------------------------------------");
oracleToMysqlService.insertDayHarmRateV(date,date);
oracleToMysqlService.insertPqsIntegrity(date,date);
oracleToMysqlService.insertDayV(date,date);
oracleToMysqlService.insertLimitRate(date,date);
oracleToMysqlService.insertLimitTarget(date,date);
oracleToMysqlService.insertComAsses(date,date);
oracleToMysqlService.insertAsses(date,date);
oracleToMysqlService.insertDataI(date,date);
oracleToMysqlService.insertPlt(date,date);
oracleToMysqlService.insertFlicker(date,date);
oracleToMysqlService.insertInHarmV(date,date);
System.out.println("-----------------------------------------------------------------------\n");
}
}

257
mysql-data/mysql-target/src/main/java/com/njcn/mysql/service/impl/OracleToMysqlServiceImpl.java
View File

@@ -5,6 +5,7 @@ import cn.hutool.core.util.ObjUtil;
import com.njcn.mysql.bo.enums.TargetEnum;
import com.njcn.mysql.bo.po.*;
import com.njcn.mysql.service.*;
import com.njcn.mysql.util.MaxValueProcessor;
import com.njcn.mysql.util.PubUtils;
import com.njcn.oracle.bo.po.*;
import lombok.AllArgsConstructor;
@@ -32,8 +33,10 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
private final IRStatAssesDService statAssesDService;
private final IRStatDataIDService statDataIDService;
private final IRStatLimitRateDService rLimitRateDService;
private final IRStatLimitTargetDService rStatLimitTargetDService;
private final IRStatDataPltDService statDataPltDService;
private final IRStatDataFlickerDService statDataFlickerDService;
private final IRStatDataInharmVDService statDataInharmVDService;
@Override
@@ -43,7 +46,7 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
//lineId:Oracle监测点ID id:Mysql监测点ID
Map<String, String> oracleRelationMysql = bakList.stream().collect(Collectors.toMap(PqLineBak::getLineId, PqLineBak::getId));
timeList.forEach(item->{
System.out.println("当前执行日期:"+ item);
System.out.println("insertDayHarmRateV->当前执行日期:"+ item);
List<RStatDataHarmrateVD> result = new ArrayList<>();
long system1 = System.currentTimeMillis();
List<DayHarmrateV> list = oracleDataService.getDayHarmRate(item);
@@ -61,17 +64,21 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
RStatDataHarmrateVD po4 = getData1(data,oracleRelationMysql,"CP95");
PubUtils.setValuesUsingReflection(po4,data,true,"getV","setV","Cp95");
MaxValueProcessor.process(po1);
MaxValueProcessor.process(po2);
MaxValueProcessor.process(po3);
MaxValueProcessor.process(po4);
result.addAll(Arrays.asList(po1,po2,po3,po4));
}
});
} else {
long system2 = System.currentTimeMillis();
System.out.println("查询oracle数据:0,执行时间:" + (system2-system1)/1000.0 + "s");
System.out.println("insertDayHarmRateV->查询oracle数据:0,执行时间:" + (system2-system1)/1000.0 + "s");
}
if(CollUtil.isNotEmpty(result)){
rStatDataHarmRateVDService.insert(result);
long system2 = System.currentTimeMillis();
System.out.println("查询oracle数据:"+(CollUtil.isNotEmpty(list)?list.size():0)+",插入mysql数据:"+ result.size() + ",执行时间:" + (system2-system1)/1000.0 + "s");
System.out.println("insertDayHarmRateV->查询oracle数据:"+(CollUtil.isNotEmpty(list)?list.size():0)+",插入mysql数据:"+ result.size() + ",执行时间:" + (system2-system1)/1000.0 + "s");
}
});
}
@@ -84,7 +91,7 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
Map<String, String> oracleRelationMysql = bakList.stream().collect(Collectors.toMap(PqLineBak::getLineId, PqLineBak::getId));
ZoneId zoneId = ZoneId.systemDefault();
timeList.forEach(item->{
System.out.println("当前执行日期:"+ item);
System.out.println("insertPqsIntegrity->当前执行日期:"+ item);
List<RStatIntegrityD> result = new ArrayList<>();
long system1 = System.currentTimeMillis();
List<PqsIntegrity> list = oracleDataService.getPqsIntegrity(item);
@@ -96,17 +103,18 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
po.setLineIndex(oracleRelationMysql.get(data.getLineIndex()));
po.setDueTime(data.getDue());
po.setRealTime(data.getReal());
MaxValueProcessor.process(po);
result.add(po);
}
});
} else {
long system2 = System.currentTimeMillis();
System.out.println("查询oracle数据:0,执行时间:" + (system2-system1)/1000.0 + "s");
System.out.println("insertPqsIntegrity->查询oracle数据:0,执行时间:" + (system2-system1)/1000.0 + "s");
}
if(CollUtil.isNotEmpty(result)){
integrityService.insert(result);
long system2 = System.currentTimeMillis();
System.out.println("查询oracle数据:"+(CollUtil.isNotEmpty(list)?list.size():0)+",插入mysql数据:"+ result.size() + ",执行时间:" + (system2-system1)/1000.0 + "s");
System.out.println("insertPqsIntegrity->查询oracle数据:"+(CollUtil.isNotEmpty(list)?list.size():0)+",插入mysql数据:"+ result.size() + ",执行时间:" + (system2-system1)/1000.0 + "s");
}
});
}
@@ -118,7 +126,7 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
//lineId:Oracle监测点ID id:Mysql监测点ID
Map<String, String> oracleRelationMysql = bakList.stream().collect(Collectors.toMap(PqLineBak::getLineId, PqLineBak::getId));
timeList.forEach(item->{
System.out.println("当前执行日期:"+ item);
System.out.println("insertDayV->当前执行日期:"+ item);
List<RStatDataVD> result = new ArrayList<>();
long system1 = System.currentTimeMillis();
List<DayV> list = oracleDataService.getDayV(item);
@@ -175,17 +183,21 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
po4.setRmsLvr(0.0f);
}
PubUtils.setValuesUsingReflection(po4,data,true,"getV","setV","Cp95");
MaxValueProcessor.process(po1);
MaxValueProcessor.process(po2);
MaxValueProcessor.process(po3);
MaxValueProcessor.process(po4);
result.addAll(Arrays.asList(po1,po2,po3,po4));
}
});
} else {
long system2 = System.currentTimeMillis();
System.out.println("查询oracle数据:0,执行时间:" + (system2-system1)/1000.0 + "s");
System.out.println("insertDayV->查询oracle数据:0,执行时间:" + (system2-system1)/1000.0 + "s");
}
if(CollUtil.isNotEmpty(result)){
rStatDataVDService.insert(result);
long system2 = System.currentTimeMillis();
System.out.println("查询oracle数据:"+(CollUtil.isNotEmpty(list)?list.size():0)+",插入mysql数据:"+ result.size() + ",执行时间:" + (system2-system1)/1000.0 + "s");
System.out.println("insertDayV->查询oracle数据:"+(CollUtil.isNotEmpty(list)?list.size():0)+",插入mysql数据:"+ result.size() + ",执行时间:" + (system2-system1)/1000.0 + "s");
}
});
}
@@ -198,7 +210,7 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
//lineId:Oracle监测点ID id:Mysql监测点ID
Map<String, String> oracleRelationMysql = bakList.stream().collect(Collectors.toMap(PqLineBak::getLineId, PqLineBak::getId));
timeList.forEach(item->{
System.out.println("当前执行日期:"+ item);
System.out.println("insertLimitRate->当前执行日期:"+ item);
List<RStatLimitRateD> result = new ArrayList<>();
long system1 = System.currentTimeMillis();
List<LimitRate> list = oracleDataService.getLimitRate(item);
@@ -211,17 +223,18 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
po.setAllTime(data.getAlltime());
po.setFlickerAllTime(data.getFlicketAlltime());
BeanUtils.copyProperties(data,po);
MaxValueProcessor.process(po);
result.add(po);
}
});
} else {
long system2 = System.currentTimeMillis();
System.out.println("查询oracle数据:0,执行时间:" + (system2-system1)/1000.0 + "s");
System.out.println("insertLimitRate->查询oracle数据:0,执行时间:" + (system2-system1)/1000.0 + "s");
}
if(CollUtil.isNotEmpty(result)){
rLimitRateDService.insert(result);
long system2 = System.currentTimeMillis();
System.out.println("查询oracle数据:"+(CollUtil.isNotEmpty(list)?list.size():0)+",插入mysql数据:"+ result.size() + ",执行时间:" + (system2-system1)/1000.0 + "s");
System.out.println("insertLimitRate->查询oracle数据:"+(CollUtil.isNotEmpty(list)?list.size():0)+",插入mysql数据:"+ result.size() + ",执行时间:" + (system2-system1)/1000.0 + "s");
}
});
}
@@ -234,7 +247,7 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
//lineId:Oracle监测点ID id:Mysql监测点ID
Map<String, String> oracleRelationMysql = bakList.stream().collect(Collectors.toMap(PqLineBak::getLineId, PqLineBak::getId));
timeList.forEach(item->{
System.out.println("当前执行日期:"+ item);
System.out.println("insertLimitTarget->当前执行日期:"+ item);
List<RStatLimitTargetD> result = new ArrayList<>();
long system1 = System.currentTimeMillis();
List<LimitTarget> list = oracleDataService.getLimitTarget(item);
@@ -247,17 +260,18 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
po.setAllTime(data.getAlltime());
po.setFlickerAllTime(data.getFlicketAlltime());
BeanUtils.copyProperties(data,po);
MaxValueProcessor.process(po);
result.add(po);
}
});
} else {
long system2 = System.currentTimeMillis();
System.out.println("查询oracle数据:0,执行时间:" + (system2-system1)/1000.0 + "s");
System.out.println("insertLimitTarget->查询oracle数据:0,执行时间:" + (system2-system1)/1000.0 + "s");
}
if(CollUtil.isNotEmpty(result)){
rStatLimitTargetDService.insert(result);
long system2 = System.currentTimeMillis();
System.out.println("查询oracle数据:"+(CollUtil.isNotEmpty(list)?list.size():0)+",插入mysql数据:"+ result.size() + ",执行时间:" + (system2-system1)/1000.0 + "s");
System.out.println("insertLimitTarget->查询oracle数据:"+(CollUtil.isNotEmpty(list)?list.size():0)+",插入mysql数据:"+ result.size() + ",执行时间:" + (system2-system1)/1000.0 + "s");
}
});
}
@@ -269,7 +283,7 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
//lineId:Oracle监测点ID id:Mysql监测点ID
Map<String, String> oracleRelationMysql = bakList.stream().collect(Collectors.toMap(PqLineBak::getLineId, PqLineBak::getId));
timeList.forEach(item-> {
System.out.println("当前执行日期:"+ item);
System.out.println("insertComAsses->当前执行日期:"+ item);
List<RStatComassesD> result = new ArrayList<>();
long system1 = System.currentTimeMillis();
List<PqsComAsses> pqsComAsses = oracleDataService.getPqsComAsses(item);
@@ -309,17 +323,18 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
comAsses.setEvent3(data.getEvent3());
comAsses.setEvent4(data.getEvent4());
comAsses.setEvent5(data.getEvent5());
MaxValueProcessor.process(comAsses);
result.add(comAsses);
}
});
} else {
long system2 = System.currentTimeMillis();
System.out.println("查询oracle数据:0,执行时间:" + (system2-system1)/1000.0 + "s");
System.out.println("insertComAsses->查询oracle数据:0,执行时间:" + (system2-system1)/1000.0 + "s");
}
if(CollUtil.isNotEmpty(result)){
statComassesDService.insert(result);
long system2 = System.currentTimeMillis();
System.out.println("查询oracle数据:"+(CollUtil.isNotEmpty(pqsComAsses)?pqsComAsses.size():0)+",插入mysql数据:"+ result.size() + ",执行时间:" + (system2-system1)/1000.0 + "s");
System.out.println("insertComAsses->查询oracle数据:"+(CollUtil.isNotEmpty(pqsComAsses)?pqsComAsses.size():0)+",插入mysql数据:"+ result.size() + ",执行时间:" + (system2-system1)/1000.0 + "s");
}
});
}
@@ -331,7 +346,7 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
//lineId:Oracle监测点ID id:Mysql监测点ID
Map<String, String> oracleRelationMysql = bakList.stream().collect(Collectors.toMap(PqLineBak::getLineId, PqLineBak::getId));
timeList.forEach(item-> {
System.out.println("当前执行日期:"+ item);
System.out.println("insertAsses->当前执行日期:"+ item);
List<RStatAssesD> result = new ArrayList<>();
long system1 = System.currentTimeMillis();
List<PqsAsses> pqsComAsses = oracleDataService.getPqsAsses(item);
@@ -346,17 +361,18 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
assesD.setDataPlt(data.getDataPlt());
assesD.setVUnbalanceCp95(data.getVUnbalanceCP95());
assesD.setVThdCp95(data.getVThdCP95());
MaxValueProcessor.process(assesD);
result.add(assesD);
}
});
} else {
long system2 = System.currentTimeMillis();
System.out.println("查询oracle数据:0,执行时间:" + (system2-system1)/1000.0 + "s");
System.out.println("insertAsses->查询oracle数据:0,执行时间:" + (system2-system1)/1000.0 + "s");
}
if(CollUtil.isNotEmpty(result)){
statAssesDService.insert(result);
long system2 = System.currentTimeMillis();
System.out.println("查询oracle数据:"+(CollUtil.isNotEmpty(pqsComAsses)?pqsComAsses.size():0)+",插入mysql数据:"+ result.size() + ",执行时间:" + (system2-system1)/1000.0 + "s");
System.out.println("insertAsses->查询oracle数据:"+(CollUtil.isNotEmpty(pqsComAsses)?pqsComAsses.size():0)+",插入mysql数据:"+ result.size() + ",执行时间:" + (system2-system1)/1000.0 + "s");
}
});
}
@@ -368,7 +384,7 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
//lineId:Oracle监测点ID id:Mysql监测点ID
Map<String, String> oracleRelationMysql = bakList.stream().collect(Collectors.toMap(PqLineBak::getLineId, PqLineBak::getId));
timeList.forEach(item-> {
System.out.println("当前执行日期:"+ item);
System.out.println("insertDataI->当前执行日期:"+ item);
List<RStatDataID> result = new ArrayList<>();
long system1 = System.currentTimeMillis();
List<DayI> list = oracleDataService.getDayI(item);
@@ -386,17 +402,21 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
RStatDataID po4 = getDataI(data,oracleRelationMysql,"CP95");
PubUtils.setValuesUsingReflection(po4,data,true,"getI","setI","Cp95");
MaxValueProcessor.process(po1);
MaxValueProcessor.process(po2);
MaxValueProcessor.process(po3);
MaxValueProcessor.process(po4);
result.addAll(Arrays.asList(po1,po2,po3,po4));
}
});
} else {
long system2 = System.currentTimeMillis();
System.out.println("查询oracle数据:0,执行时间:" + (system2-system1)/1000.0 + "s");
System.out.println("insertDataI->查询oracle数据:0,执行时间:" + (system2-system1)/1000.0 + "s");
}
if(CollUtil.isNotEmpty(result)){
statDataIDService.insert(result);
long system2 = System.currentTimeMillis();
System.out.println("查询oracle数据:"+(CollUtil.isNotEmpty(list)?list.size():0)+",插入mysql数据:"+ result.size() + ",执行时间:" + (system2-system1)/1000.0 + "s");
System.out.println("insertDataI->查询oracle数据:"+(CollUtil.isNotEmpty(list)?list.size():0)+",插入mysql数据:"+ result.size() + ",执行时间:" + (system2-system1)/1000.0 + "s");
}
});
}
@@ -408,7 +428,29 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
//lineId:Oracle监测点ID id:Mysql监测点ID
Map<String, String> oracleRelationMysql = bakList.stream().collect(Collectors.toMap(PqLineBak::getLineId, PqLineBak::getId));
timeList.forEach(item-> {
System.out.println("insertPlt->当前执行日期:"+ item);
List<RStatDataPltD> result = new ArrayList<>();
long system1 = System.currentTimeMillis();
List<DayPlt> list = oracleDataService.getDayPlt(item);
if(CollUtil.isNotEmpty(list)){
list.forEach(data->{
if (ObjUtil.isNotNull(oracleRelationMysql.get(data.getLineid()))) {
RStatDataPltD po1 = getDataPlt(data,oracleRelationMysql,"AVG");
RStatDataPltD po2 = getDataPlt(data,oracleRelationMysql,"MAX");
RStatDataPltD po3 = getDataPlt(data,oracleRelationMysql,"MIN");
RStatDataPltD po4 = getDataPlt(data,oracleRelationMysql,"CP95");
result.addAll(Arrays.asList(po1,po2,po3,po4));
}
});
} else {
long system2 = System.currentTimeMillis();
System.out.println("insertPlt->查询oracle数据:0,执行时间:" + (system2-system1)/1000.0 + "s");
}
if(CollUtil.isNotEmpty(result)){
statDataPltDService.insert(result);
long system2 = System.currentTimeMillis();
System.out.println("insertPlt->查询oracle数据:"+(CollUtil.isNotEmpty(list)?list.size():0)+",插入mysql数据:"+ result.size() + ",执行时间:" + (system2-system1)/1000.0 + "s");
}
});
}
@@ -419,7 +461,29 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
//lineId:Oracle监测点ID id:Mysql监测点ID
Map<String, String> oracleRelationMysql = bakList.stream().collect(Collectors.toMap(PqLineBak::getLineId, PqLineBak::getId));
timeList.forEach(item-> {
System.out.println("insertFlicker->当前执行日期:"+ item);
List<RStatDataFlickerD> result = new ArrayList<>();
long system1 = System.currentTimeMillis();
List<DayFlicker> list = oracleDataService.getDayFlicker(item);
if(CollUtil.isNotEmpty(list)){
list.forEach(data->{
if (ObjUtil.isNotNull(oracleRelationMysql.get(data.getLineid()))) {
RStatDataFlickerD po1 = getDataFlicker(data,oracleRelationMysql,"AVG");
RStatDataFlickerD po2 = getDataFlicker(data,oracleRelationMysql,"MAX");
RStatDataFlickerD po3 = getDataFlicker(data,oracleRelationMysql,"MIN");
RStatDataFlickerD po4 = getDataFlicker(data,oracleRelationMysql,"CP95");
result.addAll(Arrays.asList(po1,po2,po3,po4));
}
});
} else {
long system2 = System.currentTimeMillis();
System.out.println("insertFlicker->查询oracle数据:0,执行时间:" + (system2-system1)/1000.0 + "s");
}
if(CollUtil.isNotEmpty(result)){
statDataFlickerDService.insert(result);
long system2 = System.currentTimeMillis();
System.out.println("insertFlicker->查询oracle数据:"+(CollUtil.isNotEmpty(list)?list.size():0)+",插入mysql数据:"+ result.size() + ",执行时间:" + (system2-system1)/1000.0 + "s");
}
});
}
@@ -430,6 +494,29 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
//lineId:Oracle监测点ID id:Mysql监测点ID
Map<String, String> oracleRelationMysql = bakList.stream().collect(Collectors.toMap(PqLineBak::getLineId, PqLineBak::getId));
timeList.forEach(item-> {
System.out.println("insertInHarmV->当前执行日期:"+ item);
List<RStatDataInharmVD> result = new ArrayList<>();
long system1 = System.currentTimeMillis();
List<DayInharmV> list = oracleDataService.getDayInHarmV(item);
if(CollUtil.isNotEmpty(list)){
list.forEach(data->{
if (ObjUtil.isNotNull(oracleRelationMysql.get(data.getLineid()))) {
RStatDataInharmVD po1 = getDataInHarmV(data,oracleRelationMysql,"AVG");
RStatDataInharmVD po2 = getDataInHarmV(data,oracleRelationMysql,"MAX");
RStatDataInharmVD po3 = getDataInHarmV(data,oracleRelationMysql,"MIN");
RStatDataInharmVD po4 = getDataInHarmV(data,oracleRelationMysql,"CP95");
result.addAll(Arrays.asList(po1,po2,po3,po4));
}
});
} else {
long system2 = System.currentTimeMillis();
System.out.println("insertInHarmV->查询oracle数据:0,执行时间:" + (system2-system1)/1000.0 + "s");
}
if(CollUtil.isNotEmpty(result)){
statDataInharmVDService.insert(result);
long system2 = System.currentTimeMillis();
System.out.println("insertInHarmV->查询oracle数据:"+(CollUtil.isNotEmpty(list)?list.size():0)+",插入mysql数据:"+ result.size() + ",执行时间:" + (system2-system1)/1000.0 + "s");
}
});
}
@@ -443,6 +530,7 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
po1.setValueType(valueType);
//异常数据判断
po1.setQualityFlag(PubUtils.judgeData(TargetEnum.DAY_HARM_RATE_V.getCode(),data,null));
MaxValueProcessor.process(po1);
return po1;
}
@@ -506,13 +594,14 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
//异常数据判断
po1.setQualityFlag(PubUtils.judgeData(TargetEnum.DAY_V.getCode(),data,"Cp95"));
}
MaxValueProcessor.process(po1);
return po1;
}
public RStatDataID getDataI(DayI data, Map<String, String> oracleRelationMysql, String valueType) {
ZoneId zoneId = ZoneId.systemDefault();
RStatDataID po1 = new RStatDataID();
po1.setTime(data.getTimeid().atZone(zoneId).toLocalDate());
po1.setTime(data.getTimeid().toInstant().atZone(zoneId).toLocalDate());
po1.setLineId(oracleRelationMysql.get(data.getLineid()));
po1.setPhaseType(data.getPhasicType());
po1.setValueType(valueType);
@@ -523,6 +612,8 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
po1.setIThd(data.getIThd());
po1.setIUnbalance(data.getIUnbalance());
po1.setIZero(data.getIZero());
//异常数据判断
po1.setQualityFlag(PubUtils.judgeData(TargetEnum.DAY_I.getCode(),data,null));
} else if (Objects.equals(valueType,"MAX")) {
po1.setRms(data.getRmsMax());
po1.setINeg(data.getINegMax());
@@ -531,6 +622,7 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
po1.setIUnbalance(data.getIUnbalanceMax());
po1.setIZero(data.getIZeroMax());
//异常数据判断
po1.setQualityFlag(PubUtils.judgeData(TargetEnum.DAY_I.getCode(),data,"Max"));
} else if (Objects.equals(valueType,"MIN")) {
po1.setRms(data.getRmsMin());
po1.setINeg(data.getINegMin());
@@ -538,6 +630,8 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
po1.setIThd(data.getIThdMin());
po1.setIUnbalance(data.getIUnbalanceMin());
po1.setIZero(data.getIZeroMin());
//异常数据判断
po1.setQualityFlag(PubUtils.judgeData(TargetEnum.DAY_I.getCode(),data,"Min"));
} else if (Objects.equals(valueType,"CP95")) {
po1.setRms(data.getRmsCp95());
po1.setINeg(data.getINegCp95());
@@ -545,27 +639,102 @@ public class OracleToMysqlServiceImpl implements OracleToMysqlService {
po1.setIThd(data.getIThdCp95());
po1.setIUnbalance(data.getIUnbalanceCp95());
po1.setIZero(data.getIZeroCp95());
//异常数据判断
po1.setQualityFlag(PubUtils.judgeData(TargetEnum.DAY_I.getCode(),data,"Cp95"));
}
MaxValueProcessor.process(po1);
return po1;
}
public void getRmsLvrData(List<DayV> list) {
Map<String,List<Float>> map = new HashMap<>();
Map<String, List<DayV>> dayMap = list.stream().collect(Collectors.groupingBy(DayV::getLineid));
List<DayV> tList = list.stream().filter(type ->Objects.equals(type.getPhasicType(),"T")).collect(Collectors.toList());
tList.forEach(item->{
if (CollUtil.isNotEmpty(dayMap.get(item.getLineid()))){
DayV dayV = dayMap.get(item.getLineid()).stream().filter(type ->Objects.equals(type.getPhasicType(),"T")).collect(Collectors.toList()).get(0);
dayMap.get(item.getLineid()).forEach(day->{
if (Objects.equals(day.getPhasicType(),"A")) {
} else if (Objects.equals(day.getPhasicType(),"B")) {
} else if (Objects.equals(day.getPhasicType(),"C")) {
public RStatDataPltD getDataPlt(DayPlt data, Map<String, String> oracleRelationMysql, String valueType) {
ZoneId zoneId = ZoneId.systemDefault();
RStatDataPltD po1 = new RStatDataPltD();
po1.setTime(data.getTimeid().toInstant().atZone(zoneId).toLocalDate());
po1.setLineId(oracleRelationMysql.get(data.getLineid()));
po1.setPhaseType(data.getPhasicType());
po1.setValueType(valueType);
if (Objects.equals(valueType,"AVG")) {
po1.setPlt(data.getPlt());
//异常数据判断
po1.setQualityFlag(PubUtils.judgeData(TargetEnum.DAY_PLT.getCode(),data,null));
} else if (Objects.equals(valueType,"MAX")) {
po1.setPlt(data.getPltMax());
//异常数据判断
po1.setQualityFlag(PubUtils.judgeData(TargetEnum.DAY_PLT.getCode(),data,"Max"));
} else if (Objects.equals(valueType,"MIN")) {
po1.setPlt(data.getPltMin());
//异常数据判断
po1.setQualityFlag(PubUtils.judgeData(TargetEnum.DAY_PLT.getCode(),data,"Min"));
} else if (Objects.equals(valueType,"CP95")) {
po1.setPlt(data.getPltCp95());
//异常数据判断
po1.setQualityFlag(PubUtils.judgeData(TargetEnum.DAY_PLT.getCode(),data,"Cp95"));
}
});
}
});
MaxValueProcessor.process(po1);
return po1;
}
public RStatDataFlickerD getDataFlicker(DayFlicker data, Map<String, String> oracleRelationMysql, String valueType) {
ZoneId zoneId = ZoneId.systemDefault();
RStatDataFlickerD po1 = new RStatDataFlickerD();
po1.setTime(data.getTimeid().toInstant().atZone(zoneId).toLocalDate());
po1.setLineId(oracleRelationMysql.get(data.getLineid()));
po1.setPhaseType(data.getPhasicType());
po1.setValueType(valueType);
if (Objects.equals(valueType,"AVG")) {
po1.setFluc(data.getFluc());
po1.setPlt(data.getPlt());
po1.setPst(data.getPst());
//异常数据判断
po1.setQualityFlag(PubUtils.judgeData(TargetEnum.DAY_FLICKER.getCode(),data,null));
} else if (Objects.equals(valueType,"MAX")) {
po1.setFluc(data.getFlucMax());
po1.setPlt(data.getPltMax());
po1.setPst(data.getPstMax());
//异常数据判断
po1.setQualityFlag(PubUtils.judgeData(TargetEnum.DAY_FLICKER.getCode(),data,"Max"));
} else if (Objects.equals(valueType,"MIN")) {
po1.setFluc(data.getFlucMin());
po1.setPlt(data.getPltMin());
po1.setPst(data.getPstMin());
//异常数据判断
po1.setQualityFlag(PubUtils.judgeData(TargetEnum.DAY_FLICKER.getCode(),data,"Min"));
} else if (Objects.equals(valueType,"CP95")) {
po1.setFluc(data.getFlucCp95());
po1.setPlt(data.getPltCp95());
po1.setPst(data.getPstCp95());
//异常数据判断
po1.setQualityFlag(PubUtils.judgeData(TargetEnum.DAY_FLICKER.getCode(),data,"Cp95"));
}
MaxValueProcessor.process(po1);
return po1;
}
public RStatDataInharmVD getDataInHarmV(DayInharmV data, Map<String, String> oracleRelationMysql, String valueType) {
ZoneId zoneId = ZoneId.systemDefault();
RStatDataInharmVD po1 = new RStatDataInharmVD();
po1.setTime(data.getTimeid().toInstant().atZone(zoneId).toLocalDate());
po1.setLineId(oracleRelationMysql.get(data.getLineid()));
po1.setPhaseType(data.getPhasicType());
po1.setValueType(valueType);
if (Objects.equals(valueType,"AVG")) {
PubUtils.setValuesUsingReflection(po1,data,false,"getV","setV",null);
//异常数据判断
po1.setQualityFlag(PubUtils.judgeData(TargetEnum.DAY_IN_HARM_V.getCode(),data,null));
} else if (Objects.equals(valueType,"MAX")) {
PubUtils.setValuesUsingReflection(po1,data,true,"getV","setV","Max");
//异常数据判断
po1.setQualityFlag(PubUtils.judgeData(TargetEnum.DAY_IN_HARM_V.getCode(),data,"Max"));
} else if (Objects.equals(valueType,"MIN")) {
PubUtils.setValuesUsingReflection(po1,data,true,"getV","setV","Min");
//异常数据判断
po1.setQualityFlag(PubUtils.judgeData(TargetEnum.DAY_IN_HARM_V.getCode(),data,"Min"));
} else if (Objects.equals(valueType,"CP95")) {
PubUtils.setValuesUsingReflection(po1,data,true,"getV","setV","Cp95");
//异常数据判断
po1.setQualityFlag(PubUtils.judgeData(TargetEnum.DAY_IN_HARM_V.getCode(),data,"Cp95"));
}
MaxValueProcessor.process(po1);
return po1;
}
}

2
mysql-data/mysql-target/src/main/java/com/njcn/mysql/service/impl/RStatDataFlickerDServiceImpl.java
View File

@@ -1,5 +1,6 @@
package com.njcn.mysql.service.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
import com.njcn.mysql.bo.po.RStatDataFlickerD;
import com.njcn.mysql.mapper.RStatDataFlickerDMapper;
@@ -16,6 +17,7 @@ import java.util.List;
* @createTime 2023/3/24 9:53
*/
@Service
@DS("target")
public class RStatDataFlickerDServiceImpl extends MppServiceImpl<RStatDataFlickerDMapper, RStatDataFlickerD> implements IRStatDataFlickerDService {
@Override
public void insert(List<RStatDataFlickerD> list) {

2
mysql-data/mysql-target/src/main/java/com/njcn/mysql/service/impl/RStatDataInharmVDServiceImpl.java
View File

@@ -1,5 +1,6 @@
package com.njcn.mysql.service.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
import com.njcn.mysql.bo.po.RStatDataInharmVD;
import com.njcn.mysql.mapper.RStatDataInHarmVDMapper;
@@ -16,6 +17,7 @@ import java.util.List;
* @createTime 2023/3/24 9:53
*/
@Service
@DS("target")
public class RStatDataInharmVDServiceImpl extends MppServiceImpl<RStatDataInHarmVDMapper, RStatDataInharmVD> implements IRStatDataInharmVDService {
@Override

2
mysql-data/mysql-target/src/main/java/com/njcn/mysql/service/impl/RStatDataPltDServiceImpl.java
View File

@@ -1,5 +1,6 @@
package com.njcn.mysql.service.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
import com.njcn.mysql.bo.po.RStatDataPltD;
import com.njcn.mysql.mapper.RStatDataPltDMapper;
@@ -16,6 +17,7 @@ import java.util.List;
* @createTime 2023/3/24 9:53
*/
@Service
@DS("target")
public class RStatDataPltDServiceImpl extends MppServiceImpl<RStatDataPltDMapper, RStatDataPltD> implements IRStatDataPltDService {
@Override

64
mysql-data/mysql-target/src/main/java/com/njcn/mysql/util/MaxValueProcessor.java Normal file
View File

@@ -0,0 +1,64 @@
package com.njcn.mysql.util;
import cn.hutool.core.util.ObjectUtil;
import com.njcn.mysql.bo.util.CompareValue;
import java.lang.reflect.Field;
//防止数据过大
public class MaxValueProcessor {
public static void process(Object obj) {
Field[] fields = obj.getClass().getDeclaredFields();
for (Field field : fields) {
if (field.isAnnotationPresent(CompareValue.class)) {
CompareValue compareValue = field.getAnnotation(CompareValue.class);
field.setAccessible(true);
Class<?> type = field.getType();
try {
if (type == Float.class) {
Float fieldValue = (Float) field.get(obj);
float minValue = compareValue.minValue();
float maxValue = compareValue.maxValue();
if(ObjectUtil.isNotNull(fieldValue)){
if (fieldValue > maxValue) {
field.set(obj, maxValue);
}
if (fieldValue < minValue) {
field.set(obj, minValue);
}
}
}
if (type == Double.class) {
Double fieldValue = (Double) field.get(obj);
double minValue = compareValue.minValue();
double maxValue = compareValue.maxValue();
if(ObjectUtil.isNotNull(fieldValue)){
if (fieldValue > maxValue) {
field.set(obj, maxValue);
}
if (fieldValue < minValue) {
field.set(obj, minValue);
}
}
}
if (type == Integer.class) {
Integer fieldValue = (Integer) field.get(obj);
int minValue = (int) compareValue.minValue();
int maxValue = (int) compareValue.maxValue();
if(ObjectUtil.isNotNull(fieldValue)){
if (fieldValue > maxValue) {
field.set(obj, maxValue);
}
if (fieldValue < minValue) {
field.set(obj, minValue);
}
}
}
} catch (IllegalAccessException e) {
e.printStackTrace();
}
}
}
}
}

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

@@ -2,9 +2,9 @@ package com.njcn.mysql.util;
import cn.hutool.core.date.DatePattern;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.njcn.oracle.bo.po.DayHarmrateV;
import com.njcn.oracle.bo.po.DayV;
import com.njcn.oracle.bo.po.*;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.math.BigDecimal;
import java.text.SimpleDateFormat;
@@ -111,6 +111,53 @@ public class PubUtils {
e.getMessage();
}
return result;
case 2:
try {
DayFlicker data2 = new ObjectMapper().convertValue(object, DayFlicker.class);
String methodName1 = "getFluc" + (Objects.isNull(type)?"":type);
Method method1=data2.getClass().getMethod(methodName1);
float value = (Float) method1.invoke(data2);
String methodName2 = "getPlt" + (Objects.isNull(type)?"":type);
Method method2=data2.getClass().getMethod(methodName2);
float value2 = (Float) method2.invoke(data2);
String methodName3 = "getPst" + (Objects.isNull(type)?"":type);
Method method3=data2.getClass().getMethod(methodName3);
float value3 = (Float) method3.invoke(data2);
//电压波动值判断
if ( (value > 40.0|| value < 0)){
result = 1;
}
//短时闪变值判断
if ( (value2 > 20.0|| value2 < 0)){
result = 1;
}
//长时闪变值判断
if ( (value3 > 20.0|| value3 < 0)){
result = 1;
}
} catch (NoSuchMethodException | IllegalAccessException | InvocationTargetException e) {
e.getMessage();
}
return result;
case 3:
//长时闪变
DayPlt data3 = new ObjectMapper().convertValue(object, DayPlt.class);
String methodName1 = "getPlt" + (Objects.isNull(type)?"":type);
Method method1 = null;
try {
method1 = data3.getClass().getMethod(methodName1);
float value = (Float) method1.invoke(data3);
//长时闪变值判断
if ( (value > 20.0|| value < 0)){
result = 1;
}
} catch (NoSuchMethodException | IllegalAccessException | InvocationTargetException e) {
e.getMessage();
}
return result;
case 4:
DayHarmrateV data4 = new ObjectMapper().convertValue(object, DayHarmrateV.class);
List<Float> avgData4 = getData(data4);

4
oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/po/DayFlicker.java
View File

@@ -5,6 +5,8 @@ import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.time.LocalDateTime;
import java.util.Date;
import lombok.Getter;
import lombok.Setter;
@@ -23,7 +25,7 @@ public class DayFlicker implements Serializable{
private static final long serialVersionUID = 1L;
@TableField("TIMEID")
private LocalDateTime timeid;
private Date timeid;
@TableField("LINEID")
private String lineid;
@TableField("PHASIC_TYPE")

4
oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/po/DayI.java
View File

@@ -5,6 +5,8 @@ import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.time.LocalDateTime;
import java.util.Date;
import lombok.Getter;
import lombok.Setter;
@@ -23,7 +25,7 @@ public class DayI implements Serializable {
private static final long serialVersionUID = 1L;
@TableField("TIMEID")
private LocalDateTime timeid;
private Date timeid;
@TableField("LINEID")
private String lineid;
@TableField("PHASIC_TYPE")

7
oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/po/DayInharmV.java
View File

@@ -5,6 +5,8 @@ import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.time.LocalDateTime;
import java.util.Date;
import lombok.Getter;
import lombok.Setter;
@@ -23,11 +25,14 @@ public class DayInharmV implements Serializable {
private static final long serialVersionUID = 1L;
@TableField("TIMEID")
private LocalDateTime timeid;
private Date timeid;
@TableField("LINEID")
private String lineid;
@TableField("PHASIC_TYPE")
private String phasicType;
@TableField("V_1")
private Float v1;
@TableField("V_2")

12
oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/po/DayPlt.java
View File

@@ -5,8 +5,11 @@ import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.time.LocalDateTime;
import java.util.Date;
import lombok.Getter;
import lombok.Setter;
import org.springframework.format.annotation.DateTimeFormat;
/**
* <p>
@@ -22,18 +25,25 @@ import lombok.Setter;
public class DayPlt implements Serializable {
private static final long serialVersionUID = 1L;
@TableField("TIMEID")
private LocalDateTime timeid;
private Date timeid;
@TableField("LINEID")
private String lineid;
@TableField("PHASIC_TYPE")
private String phasicType;
@TableField("PLT")
private Float plt;
@TableField("PLT_MAX")
private Float pltMax;
@TableField("PLT_MIN")
private Float pltMin;
@TableField("PLT_CP95")
private Float pltCp95;