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

添加数据同步代码

Browse Source
This commit is contained in:
hzj
2024-01-09 10:27:56 +08:00
parent a8059e4c3f
commit a1a0217e59
3 changed files with 146 additions and 57 deletions
Download Patch File Download Diff File Expand all files Collapse all files

57
oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/param/ServiceType.java
View File

@@ -1,57 +0,0 @@
package com.njcn.oracle.bo.param;
import com.njcn.oracle.bo.po.*;
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;
/**
* Description:
* Date: 2024/1/4 13:54【需求编号】
*
* @author clam
* @version V1.0.0
*/
public enum ServiceType {
DataFlicker,
DataFluc,
DataHarmphasicI,
DataHarmphasicV,
DataHarmpowerP,
DataHarmpowerQ,
DataHarmpowerS,
DataHarmrateI,
DataHarmrateV,
DataInharmI,
DataInharmV,
DataI,
DataPlt,
DataV,
DayFlicker,
DayFluc,
DayHarmphasicI,
DayHarmphasicV,
DayHarmpowerP,
DayHarmpowerQ,
DayHarmpowerS,
DayHarmrateI,
DayHarmrateV,
DayInharmI,
DayInharmV,
DayI,
DayPlt,
DayV,
LimitRate,
LimitTarget;
/**
* 获取所有可执行的组件类型，
* 除了"目录"类型，其他都可以执行
* @return
*/
public static List<ServiceType> getExecutableTypes() {
return Arrays.stream(ServiceType.values()).collect(Collectors.toList());
}
}

77
oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/param/ServiceTypeEnum.java Normal file
View File

@@ -0,0 +1,77 @@
package com.njcn.oracle.bo.param;
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;
/**
* Description:
* Date: 2024/1/4 13:54【需求编号】
*
* @author clam
* @version V1.0.0
*/
public enum ServiceTypeEnum {
DATAFLICKER("DataFlicker","电压闪变数据表"),
DATAFLUC("DataFluc","电压波动数据表"),
DATAHARMPHASICI("DataHarmphasicI","谐波电流角度数据表"),
DATAHARMPHASICV("DataHarmphasicV","谐波电压角度数据表"),
DATAHARMPOWERP("DataHarmpowerP","有功功率数据表"),
DATAHARMPOWERQ("DataHarmpowerQ","无功功率数据表"),
DATAHARMPOWERS("DataHarmpowerS","视在功率数据表"),
DATAHARMRATEI("DataHarmrateI","谐波电流含有率数据表"),
DATAHARMRATEV("DataHarmrateV","谐波电压含有率数据表"),
DATAINHARMI("DataInharmI","电流简谐波幅值数据表"),
DATAINHARMV("DataInharmV","电压间谐波幅值数据表"),
DATAI("DataI","谐波电流幅值数据表"),
DATAPLT("DataPlt","长时闪变数据表"),
DATAV("DataV","谐波电压幅值数据表"),
DAYFLICKER("DayFlicker","电压闪变日统计表"),
DAYFLUC("DayFluc","电压波动日统计表"),
DAYHARMPHASICI("DayHarmphasicI","谐波电流角度日统计表"),
DAYHARMPHASICV("DayHarmphasicV","谐波电压角度日统计表"),
DAYHARMPOWERP("DayHarmpowerP","有功功率日统计表"),
DAYHARMPOWERQ("DayHarmpowerQ","无功功率日统计表"),
DAYHARMPOWERS("DayHarmpowerS","视在功率日统计表"),
DAYHARMRATEI("DayHarmrateI","谐波电流含有率日统计表"),
DAYHARMRATEV("DayHarmrateV","谐波电压含有率日统计表"),
DAYINHARMI("DayInharmI","电流简谐波幅值日统计表"),
DAYINHARMV("DayInharmV","电压间谐波幅值日统计表"),
DAYI("DayI","谐波电流幅值日统计表"),
DAYPLT("DayPlt","长时闪变日统计表"),
DAYV("DayV","谐波电压幅值日统计表"),
LIMITRATE("LimitRate","合格率统计表"),
LIMITTARGET("LimitTarget","合格率指标表");
private final String code;
private final String value;
ServiceTypeEnum( String code,String value) {
this.code = code;
this.value = value;
}
/**
* 获取所有可执行的组件类型，
* 除了"目录"类型，其他都可以执行
* @return
*/
public static List<String> getExecutableTypes() {
return Arrays.stream(ServiceTypeEnum.values()).map(ServiceTypeEnum::name).collect(Collectors.toList());
}
/**
* 通过code获取枚举值
* @param code
* @return
*/
public static String getValueByCode(String code) {
for (ServiceTypeEnum item : ServiceTypeEnum.values()) {
if (item.code.equals(code)) {
return item.value;
}
}
return null;
}
}

69
oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/po/JobDetail.java Normal file
View File

@@ -0,0 +1,69 @@
package com.njcn.oracle.bo.po;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.github.jeffreyning.mybatisplus.anno.MppMultiId;
import lombok.Data;
import java.math.BigDecimal;
import java.time.LocalDateTime;
/**
*
* Description:
* Date: 2024/1/8 12:27【需求编号】
*
* @author clam
* @version V1.0.0
*/
@TableName(value = "JOB_DETAIL")
@Data
public class JobDetail {
/**
* 指标表名
*/
@MppMultiId(value = "TABLE_NAME")
private String tableName;
@TableField(exist = false)
private String tableName_CN;
/**
* 起始时间
*/
@JsonFormat(
pattern = "yyyy-MM-dd HH:mm:ss"
)
@MppMultiId(value = "START_TIME")
private LocalDateTime startTime;
/**
* 截止时间
*/
@JsonFormat(
pattern = "yyyy-MM-dd HH:mm:ss"
)
@MppMultiId(value = "END_TIME")
private LocalDateTime endTime;
/**
* 状态（0-执行中、1-成功、2-失败）
*/
@TableField(value = "STATE")
private Integer state;
/**
* 记录数
*/
@TableField(value = "\"ROW_COUNT\"")
private Integer rowCount;
@JsonFormat(
pattern = "yyyy-MM-dd HH:mm:ss"
)
@TableField(value = "UPDATE_TIME")
private LocalDateTime updateTime;
}