Middleware/cn-data-platform
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改查询

Browse Source
This commit is contained in:
hzj
2025-03-31 08:55:26 +08:00
parent 2203238f31
commit 0f8d913400
12 changed files with 35 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataFlickerController.java
View File

@@ -53,7 +53,7 @@ public class DataFlickerController extends BaseController {
public HttpResult<String> batchInsertion(@RequestBody List<DataFlickerDTO> dataFlickerDTOList) {
String methodDescribe = getMethodDescribe("batchInsertion");
dataFlickerInsert.batchInsertion(dataFlickerDTOList);
dataFlickerQuery.batchInsertion(dataFlickerDTOList);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
}

2
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataFlucController.java
View File

@@ -51,7 +51,7 @@ public class DataFlucController extends BaseController {
public HttpResult<String> batchInsertion(@RequestBody List<DataFlucDTO> dataFlucDTOList) {
String methodDescribe = getMethodDescribe("batchInsertion");
dataFlucInsert.batchInsertion(dataFlucDTOList);
dataFlucQuery.batchInsertion(dataFlucDTOList);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
}

2
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmRateVController.java
View File

@@ -70,7 +70,7 @@ public class DataHarmRateVController extends BaseController {
public HttpResult<String> batchInsertion(@RequestBody List<DataHarmrateVDTO> dataHarmrateVDTOList) {
String methodDescribe = getMethodDescribe("batchInsertion");
dataHarmRateVInsert.batchInsertion(dataHarmrateVDTOList);
dataHarmRateVQuery.batchInsertion(dataHarmrateVDTOList);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
}

2
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmphasicIController.java
View File

@@ -52,7 +52,7 @@ public class DataHarmphasicIController extends BaseController {
public HttpResult<String> batchInsertion(@RequestBody List<DataHarmphasicIDTO> dataHarmphasicIDTOList) {
String methodDescribe = getMethodDescribe("batchInsertion");
dataHarmphasicIInsert.batchInsertion(dataHarmphasicIDTOList);
dataHarmphasicIQuery.batchInsertion(dataHarmphasicIDTOList);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
}

2
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmphasicVController.java
View File

@@ -54,7 +54,7 @@ public class DataHarmphasicVController extends BaseController {
public HttpResult<String> batchInsertion(@RequestBody List<DataHarmphasicVDTO> dataHarmphasicVDTOList) {
String methodDescribe = getMethodDescribe("batchInsertion");
dataHarmphasicVInsert.batchInsertion(dataHarmphasicVDTOList);
dataHarmphasicVQuery.batchInsertion(dataHarmphasicVDTOList);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
}

2
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmpowerPController.java
View File

@@ -54,7 +54,7 @@ public class DataHarmpowerPController extends BaseController {
public HttpResult<String> batchInsertion(@RequestBody List<DataHarmpowerPDTO> dataHarmpowerPDTOList) {
String methodDescribe = getMethodDescribe("batchInsertion");
dataHarmpowerPInsert.batchInsertion(dataHarmpowerPDTOList);
dataHarmpowerPQuery.batchInsertion(dataHarmpowerPDTOList);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
}

2
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmpowerQController.java
View File

@@ -53,7 +53,7 @@ public class DataHarmpowerQController extends BaseController {
public HttpResult<String> batchInsertion(@RequestBody List<DataHarmpowerQDTO> dataHarmpowerQDTOList) {
String methodDescribe = getMethodDescribe("batchInsertion");
dataHarmpowerQInsert.batchInsertion(dataHarmpowerQDTOList);
dataHarmpowerQQuery.batchInsertion(dataHarmpowerQDTOList);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
}

2
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmpowerSController.java
View File

@@ -52,7 +52,7 @@ public class DataHarmpowerSController extends BaseController {
public HttpResult<String> batchInsertion(@RequestBody List<DataHarmpowerSDTO> dataHarmpowerSDTOList) {
String methodDescribe = getMethodDescribe("batchInsertion");
dataHarmpowerSInsert.batchInsertion(dataHarmpowerSDTOList);
dataHarmpowerSQuery.batchInsertion(dataHarmpowerSDTOList);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
}

2
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataIController.java
View File

@@ -52,7 +52,7 @@ public class DataIController extends BaseController {
public HttpResult<String> batchInsertion(@RequestBody List<DataIDTO> dataIDTOList) {
String methodDescribe = getMethodDescribe("batchInsertion");
dataIInsert.batchInsertion(dataIDTOList);
dataIQuery.batchInsertion(dataIDTOList);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
}

2
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataInharmIController.java
View File

@@ -52,7 +52,7 @@ public class DataInharmIController extends BaseController {
public HttpResult<String> batchInsertion(@RequestBody List<DataInharmIDTO> dataInharmIDTOList) {
String methodDescribe = getMethodDescribe("batchInsertion");
dataInharmIInsert.batchInsertion(dataInharmIDTOList);
dataInharmIQuery.batchInsertion(dataInharmIDTOList);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
}

2
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataInharmVController.java
View File

@@ -53,7 +53,7 @@ public class DataInharmVController extends BaseController {
public HttpResult<String> batchInsertion(@RequestBody List<DataInharmVDTO> dataInharmVDTOList) {
String methodDescribe = getMethodDescribe("batchInsertion");
dataInharmVInsert.batchInsertion(dataInharmVDTOList);
dataInharmVQuery.batchInsertion(dataInharmVDTOList);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
}

47
data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/LnDataDealServiceImpl.java
View File

@@ -1,5 +1,6 @@
package com.njcn.dataProcess.service.impl;
import com.njcn.dataProcess.annotation.QueryBean;
import com.njcn.dataProcess.dto.LnDataDTO;
import com.njcn.dataProcess.annotation.InsertBean;
import com.njcn.dataProcess.service.*;
@@ -14,42 +15,42 @@ import org.springframework.stereotype.Service;
*/
@Service("RelationLnDataDealServiceImpl")
public class LnDataDealServiceImpl implements LnDataDealService {
@InsertBean
private IDataFlicker dataFlickerInsert;
@InsertBean
private IDataFluc dataFlucInsert;
@InsertBean
private IDataHarmphasicI dataHarmphasicIInsert;
@InsertBean
private IDataHarmphasicV dataHarmphasicVInsert;
@QueryBean
private IDataFlicker dataFlickerQuery;
@QueryBean
private IDataFluc dataFlucQuery;
@QueryBean
private IDataHarmphasicI dataHarmphasicIQuery;
@QueryBean
private IDataHarmphasicV dataHarmphasicVQuery;
@InsertBean
private IDataHarmRateV dataHarmrateVInsert;
@InsertBean
@QueryBean
private IDataHarmRateV dataHarmrateVQuery;
@QueryBean
private IDataHarmpowerP dataHarmpowerPService;
@InsertBean
@QueryBean
private IDataHarmpowerQ dataHarmpowerQService;
@InsertBean
@QueryBean
private IDataHarmpowerS dataHarmpowerSService;
@InsertBean
@QueryBean
private IDataI dataIService;
@InsertBean
@QueryBean
private IDataInharmI dataInharmIService;
@InsertBean
@QueryBean
private IDataInharmV dataInharmVService;
@InsertBean
@QueryBean
private IDataPlt dataPltService;
@InsertBean
@QueryBean
private IDataV dataVService;
@Override
public void batchInsertion(LnDataDTO lnDataDTO) {
dataVService.batchInsertion(lnDataDTO.getDataVList());
dataHarmrateVInsert.batchInsertion(lnDataDTO.getDataHarmrateVDTOList());
dataFlickerInsert.batchInsertion(lnDataDTO.getDataFlickerDTOList());
dataFlucInsert.batchInsertion(lnDataDTO.getDataFlucDTOList());
dataHarmphasicIInsert.batchInsertion(lnDataDTO.getDataHarmphasicIDTOList());
dataHarmphasicVInsert.batchInsertion(lnDataDTO.getDataHarmphasicVDTOList());
dataHarmrateVQuery.batchInsertion(lnDataDTO.getDataHarmrateVDTOList());
dataFlickerQuery.batchInsertion(lnDataDTO.getDataFlickerDTOList());
dataFlucQuery.batchInsertion(lnDataDTO.getDataFlucDTOList());
dataHarmphasicIQuery.batchInsertion(lnDataDTO.getDataHarmphasicIDTOList());
dataHarmphasicVQuery.batchInsertion(lnDataDTO.getDataHarmphasicVDTOList());
dataHarmpowerPService.batchInsertion(lnDataDTO.getDataHarmpowerPDTOList());
dataHarmpowerQService.batchInsertion(lnDataDTO.getDataHarmpowerQDTOList());
dataHarmpowerSService.batchInsertion(lnDataDTO.getDataHarmpowerSDTOList());