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

oralce同步到influxDB

Browse Source
This commit is contained in:
hzj
2024-01-16 09:39:08 +08:00
parent c79a1b8a77
commit a2afabe80c
3 changed files with 82 additions and 40 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
influx-data/influx-target/src/main/java/com/njcn/influx/controller/OracleToInfluxDBController.java
View File

@@ -7,8 +7,6 @@ import com.njcn.influx.service.InfluxDBBaseService;
import com.njcn.oracle.bo.param.DataAsynParam; import com.njcn.oracle.bo.param.DataAsynParam;
import com.njcn.oracle.bo.param.MigrationParam; import com.njcn.oracle.bo.param.MigrationParam;
import com.njcn.oracle.mybatis.service.IReplenishMybatisService; import com.njcn.oracle.mybatis.service.IReplenishMybatisService;
import com.njcn.oracle.service.DataSyncService;
import com.njcn.oracle.util.LocalDateUtil;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
@@ -45,7 +43,6 @@ import java.util.stream.Stream;
public class OracleToInfluxDBController { public class OracleToInfluxDBController {
private final InfluxDBBaseService influxDBBaseService; private final InfluxDBBaseService influxDBBaseService;
private final DataSyncService dataSyncService;
@PostMapping("/dataSync") @PostMapping("/dataSync")
@ApiOperation("数据同步") @ApiOperation("数据同步")
@ApiImplicitParam(name = "dataAsynParam", value = "数据同步参数", required = true) @ApiImplicitParam(name = "dataAsynParam", value = "数据同步参数", required = true)

1
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/JobDetailServiceImpl.java
View File

@@ -32,7 +32,6 @@ import org.springframework.util.CollectionUtils;
* @version V1.0.0 * @version V1.0.0
*/ */
@Service @Service
@DS(("target"))
public class JobDetailServiceImpl extends MppServiceImpl<JobDetailMapper, JobDetail> implements JobDetailService { public class JobDetailServiceImpl extends MppServiceImpl<JobDetailMapper, JobDetail> implements JobDetailService {

118
oracle-data/oracle-target/src/main/resources/static/index.html
View File

@@ -25,45 +25,49 @@
</el-form-item> </el-form-item>
<el-form-item label="数据指标"> <el-form-item label="数据指标">
<el-select <el-select
v-model="formInline.tableNames" v-model="formInline.tableNames"
placeholder="请选择指标" placeholder="请选择指标"
clearable filterable
multiple clearable
collapse-tags multiple
style="width: 240px" collapse-tags
style="width: 360px"
> >
<el-option label="电压闪变数据表" value="DataFlicker"></el-option> <el-option label="电压闪变数据表-DataFlicker" value="DataFlicker"></el-option>
<el-option label="电压波动数据表" value="DataFluc"></el-option> <el-option label="电压波动数据表-DataFluc" value="DataFluc"></el-option>
<el-option label="谐波电流角度数据表" value="DataHarmphasicI"></el-option> <el-option label="谐波电流角度数据表-DataHarmphasicI" value="DataHarmphasicI"></el-option>
<el-option label="谐波电压角度数据表" value="DataHarmphasicV"></el-option> <el-option label="谐波电压角度数据表-DataHarmphasicV" value="DataHarmphasicV"></el-option>
<el-option label="有功功率数据表" value="DataHarmpowerP"></el-option> <el-option label="有功功率数据表-DataHarmpowerP" value="DataHarmpowerP"></el-option>
<el-option label="无功功率数据表" value="DataHarmpowerQ"></el-option> <el-option label="无功功率数据表-DataHarmpowerQ" value="DataHarmpowerQ"></el-option>
<el-option label="视在功率数据表" value="DataHarmpowerS"></el-option> <el-option label="视在功率数据表-DataHarmpowerS" value="DataHarmpowerS"></el-option>
<el-option label="谐波电流含有率数据表" value="DataHarmrateI"></el-option> <el-option label="谐波电流含有率数据表-DataHarmrateI" value="DataHarmrateI"></el-option>
<el-option label="谐波电压含有率数据表" value="DataHarmrateV"></el-option> <el-option label="谐波电压含有率数据表-DataHarmrateV" value="DataHarmrateV"></el-option>
<el-option label="电流简谐波幅值数据表" value="DataInharmI"></el-option> <el-option label="电流简谐波幅值数据表-DataInharmI" value="DataInharmI"></el-option>
<el-option label="电压间谐波幅值数据表" value="DataInharmV"></el-option> <el-option label="电压间谐波幅值数据表-DataInharmV" value="DataInharmV"></el-option>
<el-option label="谐波电流幅值数据表" value="DataI"></el-option> <el-option label="谐波电流幅值数据表-DataI" value="DataI"></el-option>
<el-option label="长时闪变数据表" value="DataPlt"></el-option> <el-option label="长时闪变数据表-DataPlt" value="DataPlt"></el-option>
<el-option label="谐波电压幅值数据表" value="DataV"></el-option> <el-option label="谐波电压幅值数据表-DataV" value="DataV"></el-option>
<el-option label="电压闪变日统计表" value="DayFlicker"></el-option> <el-option label="电压闪变日统计表-DayFlicker" value="DayFlicker"></el-option>
<el-option label="电压波动日统计表" value="DayFluc"></el-option> <el-option label="电压波动日统计表-DayFluc" value="DayFluc"></el-option>
<el-option label="谐波电流角度日统计表" value="DayHarmphasicI"></el-option> <el-option label="谐波电流角度日统计表-DayHarmphasicI" value="DayHarmphasicI"></el-option>
<el-option label="谐波电压角度日统计表" value="DayHarmphasicV"></el-option> <el-option label="谐波电压角度日统计表-DayHarmphasicV" value="DayHarmphasicV"></el-option>
<el-option label="有功功率日统计表" value="DayHarmpowerP"></el-option> <el-option label="有功功率日统计表-DayHarmpowerP" value="DayHarmpowerP"></el-option>
<el-option label="无功功率日统计表" value="DayHarmpowerQ"></el-option> <el-option label="无功功率日统计表-DayHarmpowerQ" value="DayHarmpowerQ"></el-option>
<el-option label="视在功率日统计表" value="DayHarmpowerS"></el-option> <el-option label="视在功率日统计表-DayHarmpowerS" value="DayHarmpowerS"></el-option>
<el-option label="谐波电流含有率日统计表" value="DayHarmrateI"></el-option> <el-option label="谐波电流含有率日统计表-DayHarmrateI" value="DayHarmrateI"></el-option>
<el-option label="谐波电压含有率日统计表" value="DayHarmrateV"></el-option> <el-option label="谐波电压含有率日统计表-DayHarmrateV" value="DayHarmrateV"></el-option>
<el-option label="电流简谐波幅值日统计表" value="DayInharmI"></el-option> <el-option label="电流简谐波幅值日统计表-DayInharmI" value="DayInharmI"></el-option>
<el-option label="电压间谐波幅值日统计表" value="DayInharmV"></el-option> <el-option label="电压间谐波幅值日统计表-DayInharmV" value="DayInharmV"></el-option>
<el-option label="谐波电流幅值日统计表" value="DayI"></el-option> <el-option label="谐波电流幅值日统计表-DayI" value="DayI"></el-option>
<el-option label="长时闪变日统计表" value="DayPlt"></el-option> <el-option label="长时闪变日统计表-DayPlt" value="DayPlt"></el-option>
<el-option label="谐波电压幅值日统计表" value="DayV"></el-option> <el-option label="谐波电压幅值日统计表-DayV" value="DayV"></el-option>
<el-option label="合格率统计表" value="LimitRate"></el-option> <el-option label="合格率统计表-LimitRate" value="LimitRate"></el-option>
<el-option label="合格率指标表" value="LimitTarget"></el-option> <el-option label="合格率指标表-LimitTarget" value="LimitTarget"></el-option>
</el-select> </el-select>
</el-form-item> </el-form-item>
<el-form-item >
<el-checkbox v-model="formInline.checkAll" @change="handleCheckAllChange">{{formInline.checkAll?'取消全选':'全选'}}</el-checkbox>
</el-form-item>
<el-form-item label="数据状态"> <el-form-item label="数据状态">
<el-select v-model="formInline.states" placeholder="请选择状态" clearable multiple collapse-tags> <el-select v-model="formInline.states" placeholder="请选择状态" clearable multiple collapse-tags>
<el-option label="执行中" value="0"></el-option> <el-option label="执行中" value="0"></el-option>
@@ -143,6 +147,7 @@
const formInline = reactive({ const formInline = reactive({
loading: true, loading: true,
states: ['0', '1'], states: ['0', '1'],
checkAll:true,
tableNames: [ tableNames: [
'DataFlicker', 'DataFlicker',
'DataFluc', 'DataFluc',
@@ -175,6 +180,38 @@
'LimitRate', 'LimitRate',
'LimitTarget', 'LimitTarget',
], ],
tableNames2: [
'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',
],
date: [formatTime(new Date()), formatTime(new Date())], date: [formatTime(new Date()), formatTime(new Date())],
total: 0, total: 0,
currentPage: 1, currentPage: 1,
@@ -292,8 +329,17 @@
} }
}) })
} }
const handleCheckAllChange = ()=>{
console.log(formInline.checkAll)
if(formInline.checkAll){
formInline.tableNames = JSON.parse(JSON.stringify(formInline.tableNames2))
}else{
formInline.tableNames = []
}
}
return { return {
handleCheckAllChange,
message, message,
formInline, formInline,
query, query,