fix:1.去除无用excel注解
This commit is contained in:
parent
4134a749fb
commit
bac24c87fe
|
|
@ -10,22 +10,6 @@ public class DBUtil {
|
||||||
public static final String ORACLE_URL_PREFIX = "jdbc:oracle:thin:@";
|
public static final String ORACLE_URL_PREFIX = "jdbc:oracle:thin:@";
|
||||||
public static final String POSTGRES_URL_PREFIX = "jdbc:postgresql://";
|
public static final String POSTGRES_URL_PREFIX = "jdbc:postgresql://";
|
||||||
|
|
||||||
/*public static Connection getConnection(String url, String username, String password, String Driver) throws SQLException{
|
|
||||||
try {
|
|
||||||
Class.forName(Driver);
|
|
||||||
Properties props = new Properties();
|
|
||||||
props.put("user", username);
|
|
||||||
props.put("password", password);
|
|
||||||
props.put("oracle.net.CONNECT_TIMEOUT", "300000");
|
|
||||||
props.put("oracle.jdbc.ReadTimeout", "600000");
|
|
||||||
return DriverManager.getConnection(url, props);
|
|
||||||
} catch(ClassNotFoundException e){
|
|
||||||
System.out.println("找不到驱动程序类 ,加载驱动失败!");
|
|
||||||
e.printStackTrace() ;
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
}*/
|
|
||||||
|
|
||||||
public static String getUrl(String ip, Integer port, String serveId){
|
public static String getUrl(String ip, Integer port, String serveId){
|
||||||
return String.format("%s%s:%s%s", DBUtil.ORACLE_URL_PREFIX, ip, port, serveId);
|
return String.format("%s%s:%s%s", DBUtil.ORACLE_URL_PREFIX, ip, port, serveId);
|
||||||
}
|
}
|
||||||
|
|
@ -55,35 +39,6 @@ public class DBUtil {
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/*public static List<Map<String, Object>> queryToMapList(String sql) throws SQLException {
|
|
||||||
List<Map<String, Object>> resultMapList = new ArrayList<>();
|
|
||||||
try {
|
|
||||||
stmt = connection.createStatement();
|
|
||||||
rs = stmt.executeQuery(sql);
|
|
||||||
ResultSetMetaData metaData = rs.getMetaData();
|
|
||||||
int columnCount = metaData.getColumnCount();
|
|
||||||
while (rs.next()) {
|
|
||||||
Map<String, Object> rsRow = new HashMap<>();
|
|
||||||
for (int i = 1; i <= columnCount; i++) {
|
|
||||||
String columnName = metaData.getColumnName(i);
|
|
||||||
if (metaData.getColumnClassName(i).equals("java.sql.Timestamp")) {
|
|
||||||
if (rs.getObject(i) != null)
|
|
||||||
rsRow.put(columnName, new Date(rs.getDate(i).getTime()));
|
|
||||||
} else {
|
|
||||||
rsRow.put(columnName, rs.getObject(i));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
resultMapList.add(rsRow);
|
|
||||||
}
|
|
||||||
} catch (Exception e) {
|
|
||||||
throw e;
|
|
||||||
} finally {
|
|
||||||
close();
|
|
||||||
}
|
|
||||||
return resultMapList;
|
|
||||||
}*/
|
|
||||||
|
|
||||||
//释放资源
|
//释放资源
|
||||||
public static void close(Connection conn, Statement stmt, ResultSet rs){
|
public static void close(Connection conn, Statement stmt, ResultSet rs){
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -30,14 +30,11 @@ public class StasSyncLog implements Serializable {
|
||||||
@TableId(type = IdType.ASSIGN_ID)
|
@TableId(type = IdType.ASSIGN_ID)
|
||||||
private String id;
|
private String id;
|
||||||
/**记录id*/
|
/**记录id*/
|
||||||
@Excel(name = "记录id", width = 15)
|
|
||||||
private String recordId;
|
private String recordId;
|
||||||
/**开始时间*/
|
/**开始时间*/
|
||||||
@Excel(name = "开始时间", width = 20, format = "yyyy-MM-dd HH:mm:ss")
|
|
||||||
@JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
|
@JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
|
||||||
@DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
|
@DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
|
||||||
private Date startTime;
|
private Date startTime;
|
||||||
/**描述*/
|
/**描述*/
|
||||||
@Excel(name = "描述", width = 15)
|
|
||||||
private String description;
|
private String description;
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -26,12 +26,9 @@ public class StasSyncNum implements Serializable {
|
||||||
@TableId(type = IdType.ASSIGN_ID)
|
@TableId(type = IdType.ASSIGN_ID)
|
||||||
private String id;
|
private String id;
|
||||||
/**记录id*/
|
/**记录id*/
|
||||||
@Excel(name = "记录id", width = 15)
|
|
||||||
private String recordId;
|
private String recordId;
|
||||||
/**同步表名*/
|
/**同步表名*/
|
||||||
@Excel(name = "同步表名", width = 15)
|
|
||||||
private String tableName;
|
private String tableName;
|
||||||
/**同步数据条数*/
|
/**同步数据条数*/
|
||||||
@Excel(name = "同步数据条数", width = 15)
|
|
||||||
private Integer syncNum;
|
private Integer syncNum;
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -30,21 +30,16 @@ public class StasSyncRecord implements Serializable {
|
||||||
@TableId(type = IdType.ASSIGN_ID)
|
@TableId(type = IdType.ASSIGN_ID)
|
||||||
private String id;
|
private String id;
|
||||||
/**任务id*/
|
/**任务id*/
|
||||||
@Excel(name = "任务id", width = 15)
|
|
||||||
private String taskId;
|
private String taskId;
|
||||||
/**源库id*/
|
/**源库id*/
|
||||||
@Excel(name = "源库id", width = 15)
|
|
||||||
private String sourceId;
|
private String sourceId;
|
||||||
/**目标库id*/
|
/**目标库id*/
|
||||||
@Excel(name = "目标库id", width = 15)
|
|
||||||
private String targetId;
|
private String targetId;
|
||||||
/**开始时间*/
|
/**开始时间*/
|
||||||
@Excel(name = "开始时间", width = 20, format = "yyyy-MM-dd HH:mm:ss")
|
|
||||||
@JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
|
@JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
|
||||||
@DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
|
@DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
|
||||||
private Date startTime;
|
private Date startTime;
|
||||||
/**结束时间*/
|
/**结束时间*/
|
||||||
@Excel(name = "结束时间", width = 20, format = "yyyy-MM-dd HH:mm:ss")
|
|
||||||
@JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
|
@JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
|
||||||
@DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
|
@DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
|
||||||
private Date endTime;
|
private Date endTime;
|
||||||
|
|
|
||||||
|
|
@ -38,29 +38,21 @@ public class StasSyncStrategy implements Serializable {
|
||||||
@DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
|
@DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
|
||||||
private Date createTime;
|
private Date createTime;
|
||||||
/**修改人*/
|
/**修改人*/
|
||||||
@Excel(name = "修改人", width = 15)
|
|
||||||
private String updateBy;
|
private String updateBy;
|
||||||
/**修改时间*/
|
/**修改时间*/
|
||||||
@JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
|
@JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
|
||||||
@DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
|
@DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
|
||||||
@Excel(name = "修改时间", width = 15)
|
|
||||||
private Date updateTime;
|
private Date updateTime;
|
||||||
/**任务id*/
|
/**任务id*/
|
||||||
@Excel(name = "任务id", width = 15)
|
|
||||||
private String taskId;
|
private String taskId;
|
||||||
/**源用户*/
|
/**源用户*/
|
||||||
@Excel(name = "源用户", width = 15)
|
|
||||||
private String sourceOwner;
|
private String sourceOwner;
|
||||||
/**目标用户*/
|
/**目标用户*/
|
||||||
@Excel(name = "目标用户", width = 15)
|
|
||||||
private String targetOwner;
|
private String targetOwner;
|
||||||
/**同步表名*/
|
/**同步表名*/
|
||||||
@Excel(name = "同步表名称", width = 15)
|
|
||||||
private String tableName;
|
private String tableName;
|
||||||
/**依据字段*/
|
/**依据字段*/
|
||||||
@Excel(name = "依据字段", width = 15)
|
|
||||||
private String columnName;
|
private String columnName;
|
||||||
/**同步位置*/
|
/**同步位置*/
|
||||||
@Excel(name = "同步位置", width = 15)
|
|
||||||
private String syncOrigin;
|
private String syncOrigin;
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -50,39 +50,30 @@ public class StasTaskConfig implements Serializable {
|
||||||
@Schema(description = "更新日期")
|
@Schema(description = "更新日期")
|
||||||
private Date updateTime;
|
private Date updateTime;
|
||||||
/**任务名称*/
|
/**任务名称*/
|
||||||
@Excel(name = "任务名称", width = 15)
|
|
||||||
@Schema(description = "任务名称")
|
@Schema(description = "任务名称")
|
||||||
private String taskName;
|
private String taskName;
|
||||||
/**定时任务ID*/
|
/**定时任务ID*/
|
||||||
@Excel(name = "定时任务ID", width = 15)
|
|
||||||
@Schema(description = "定时任务ID")
|
@Schema(description = "定时任务ID")
|
||||||
private String quartzId;
|
private String quartzId;
|
||||||
/**cron表达式*/
|
/**cron表达式*/
|
||||||
@Excel(name = "cron表达式", width = 15)
|
|
||||||
@Schema(description = "cron表达式")
|
@Schema(description = "cron表达式")
|
||||||
private String cron;
|
private String cron;
|
||||||
/**源库id*/
|
/**源库id*/
|
||||||
@Excel(name = "源库id", width = 15)
|
|
||||||
@Schema(description = "源库id")
|
@Schema(description = "源库id")
|
||||||
private String sourceId;
|
private String sourceId;
|
||||||
/**目标库id*/
|
/**目标库id*/
|
||||||
@Excel(name = "目标库id", width = 15)
|
|
||||||
@Schema(description = "目标库id")
|
@Schema(description = "目标库id")
|
||||||
private String targetId;
|
private String targetId;
|
||||||
/**单表批次获取数量*/
|
/**单表批次获取数量*/
|
||||||
@Excel(name = "单表批次获取数量", width = 15)
|
|
||||||
@Schema(description = "单表批次获取数量")
|
@Schema(description = "单表批次获取数量")
|
||||||
private Integer syncCount;
|
private Integer syncCount;
|
||||||
/**单表批次获取天数*/
|
/**单表批次获取天数*/
|
||||||
@Excel(name = "单表批次获取天数", width = 15)
|
|
||||||
@Schema(description = "单表批次获取天数")
|
@Schema(description = "单表批次获取天数")
|
||||||
private Integer syncDay;
|
private Integer syncDay;
|
||||||
/**任务状态*/
|
/**任务状态*/
|
||||||
@Excel(name = "任务状态", width = 15)
|
|
||||||
@Schema(description = "任务状态")
|
@Schema(description = "任务状态")
|
||||||
private Integer taskStatus;
|
private Integer taskStatus;
|
||||||
/**描述*/
|
/**描述*/
|
||||||
@Excel(name = "描述", width = 15)
|
|
||||||
@Schema(description = "描述")
|
@Schema(description = "描述")
|
||||||
private String description;
|
private String description;
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -42,10 +42,6 @@ public class SyncDataJob implements Job {
|
||||||
|
|
||||||
private String parameter;
|
private String parameter;
|
||||||
|
|
||||||
public void setParameter(String parameter) {
|
|
||||||
this.parameter = parameter;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
|
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
|
||||||
try {
|
try {
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue
Block a user