diff --git a/influx-data/influx-source/src/main/java/com/njcn/influx/service/OracleToInfluxDBService.java b/influx-data/influx-source/src/main/java/com/njcn/influx/service/OracleToInfluxDBService.java index 79a4858..5fe10d2 100644 --- a/influx-data/influx-source/src/main/java/com/njcn/influx/service/OracleToInfluxDBService.java +++ b/influx-data/influx-source/src/main/java/com/njcn/influx/service/OracleToInfluxDBService.java @@ -8,4 +8,7 @@ public interface OracleToInfluxDBService { void hourseDataBacthSysc(DataAsynParam dataAsynParam); void AsyncData(DataAsynParam dataAsynParam); + + + void oneMonitorDataTransport(DataAsynParam dataAsynParam); } diff --git a/influx-data/influx-source/src/main/java/com/njcn/influx/service/impl/OracleEventDetailToMysqlServiceImpl.java b/influx-data/influx-source/src/main/java/com/njcn/influx/service/impl/OracleEventDetailToMysqlServiceImpl.java index 46c89ea..3f81ff9 100644 --- a/influx-data/influx-source/src/main/java/com/njcn/influx/service/impl/OracleEventDetailToMysqlServiceImpl.java +++ b/influx-data/influx-source/src/main/java/com/njcn/influx/service/impl/OracleEventDetailToMysqlServiceImpl.java @@ -13,6 +13,7 @@ import com.njcn.influx.service.PqLineBakService; import lombok.RequiredArgsConstructor; import org.springframework.stereotype.Service; +import java.math.BigDecimal; import java.time.LocalDateTime; import java.time.temporal.ChronoUnit; import java.util.ArrayList; @@ -86,7 +87,7 @@ public class OracleEventDetailToMysqlServiceImpl extends ServiceImpl + + + 查询 迁移 + + +
+ + + + + + 单监测点数据迁移 + + @@ -166,6 +180,7 @@ 'DataV', ], date: [formatTime(new Date()), formatTime(new Date())], + monitorId:'', total: 0, currentPage: 1, pageSize: 20, @@ -221,7 +236,7 @@ let obj = { tableNames: formInline.tableNames, startTime: formInline.date[0], - endTime: formInline.date[1], + endTime: formInline.date[1] } if (row) { obj = { @@ -250,6 +265,41 @@ }) } + + const oneMonitorMove = () => { + + if(!formInline.monitorId){ + ElementPlus.ElMessage.error('请填写监测点id') + return + } + + let obj = { + tableNames: formInline.tableNames, + startTime: formInline.date[0], + endTime: formInline.date[1], + monitorId:formInline.monitorId + } + + fetch('/data/oneMonitorDataTransport', { + method: 'POST', + headers: { + 'Content-Type': 'application/json', + }, + body: JSON.stringify(obj), + }) + .then((res) => { + return res.json() + }) + .then((res) => { + if (res) { + ElementPlus.ElMessage.success('单个监测点数据迁移成功') + query() + } else { + ElementPlus.ElMessage.error('单个监测点数据迁移失败') + } + }) + } + // 处理数据精度 const formatNumber = (row,column) =>{ const duration = row[column]; @@ -291,6 +341,9 @@ } } + + + return { handleCheckAllChange, message, @@ -300,6 +353,7 @@ handleCurrentChange, handleSizeChange, move, + oneMonitorMove, jobRemove, formatNumber, } diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/param/DataAsynParam.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/param/DataAsynParam.java index 7ccba47..b11eef7 100644 --- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/param/DataAsynParam.java +++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/param/DataAsynParam.java @@ -31,4 +31,6 @@ public class DataAsynParam { //执行同步数据类型1:重网页端,2跑批处理 private Integer excuteType=1; + private Integer monitorId; + }