From 0f8d9134003b4fa03487080bc2e067933f5889a8 Mon Sep 17 00:00:00 2001 From: hzj <826100833@qq.com> Date: Mon, 31 Mar 2025 08:55:26 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=9F=A5=E8=AF=A2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/DataFlickerController.java | 2 +- .../controller/DataFlucController.java | 2 +- .../controller/DataHarmRateVController.java | 2 +- .../controller/DataHarmphasicIController.java | 2 +- .../controller/DataHarmphasicVController.java | 2 +- .../controller/DataHarmpowerPController.java | 2 +- .../controller/DataHarmpowerQController.java | 2 +- .../controller/DataHarmpowerSController.java | 2 +- .../controller/DataIController.java | 2 +- .../controller/DataInharmIController.java | 2 +- .../controller/DataInharmVController.java | 2 +- .../service/impl/LnDataDealServiceImpl.java | 47 ++++++++++--------- 12 files changed, 35 insertions(+), 34 deletions(-) diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataFlickerController.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataFlickerController.java index a74d3b2..8b0e44d 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataFlickerController.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataFlickerController.java @@ -53,7 +53,7 @@ public class DataFlickerController extends BaseController { public HttpResult batchInsertion(@RequestBody List dataFlickerDTOList) { String methodDescribe = getMethodDescribe("batchInsertion"); - dataFlickerInsert.batchInsertion(dataFlickerDTOList); + dataFlickerQuery.batchInsertion(dataFlickerDTOList); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); } diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataFlucController.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataFlucController.java index 45b49f3..6c81d59 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataFlucController.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataFlucController.java @@ -51,7 +51,7 @@ public class DataFlucController extends BaseController { public HttpResult batchInsertion(@RequestBody List dataFlucDTOList) { String methodDescribe = getMethodDescribe("batchInsertion"); - dataFlucInsert.batchInsertion(dataFlucDTOList); + dataFlucQuery.batchInsertion(dataFlucDTOList); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); } diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmRateVController.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmRateVController.java index fd1a96f..b6da7f6 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmRateVController.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmRateVController.java @@ -70,7 +70,7 @@ public class DataHarmRateVController extends BaseController { public HttpResult batchInsertion(@RequestBody List dataHarmrateVDTOList) { String methodDescribe = getMethodDescribe("batchInsertion"); - dataHarmRateVInsert.batchInsertion(dataHarmrateVDTOList); + dataHarmRateVQuery.batchInsertion(dataHarmrateVDTOList); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); } diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmphasicIController.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmphasicIController.java index a6c1c05..0367c39 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmphasicIController.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmphasicIController.java @@ -52,7 +52,7 @@ public class DataHarmphasicIController extends BaseController { public HttpResult batchInsertion(@RequestBody List dataHarmphasicIDTOList) { String methodDescribe = getMethodDescribe("batchInsertion"); - dataHarmphasicIInsert.batchInsertion(dataHarmphasicIDTOList); + dataHarmphasicIQuery.batchInsertion(dataHarmphasicIDTOList); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); } diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmphasicVController.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmphasicVController.java index fff0d3e..d858cf9 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmphasicVController.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmphasicVController.java @@ -54,7 +54,7 @@ public class DataHarmphasicVController extends BaseController { public HttpResult batchInsertion(@RequestBody List dataHarmphasicVDTOList) { String methodDescribe = getMethodDescribe("batchInsertion"); - dataHarmphasicVInsert.batchInsertion(dataHarmphasicVDTOList); + dataHarmphasicVQuery.batchInsertion(dataHarmphasicVDTOList); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); } diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmpowerPController.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmpowerPController.java index 523b1a3..6d981b0 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmpowerPController.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmpowerPController.java @@ -54,7 +54,7 @@ public class DataHarmpowerPController extends BaseController { public HttpResult batchInsertion(@RequestBody List dataHarmpowerPDTOList) { String methodDescribe = getMethodDescribe("batchInsertion"); - dataHarmpowerPInsert.batchInsertion(dataHarmpowerPDTOList); + dataHarmpowerPQuery.batchInsertion(dataHarmpowerPDTOList); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); } diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmpowerQController.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmpowerQController.java index 60150c5..f486cb2 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmpowerQController.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmpowerQController.java @@ -53,7 +53,7 @@ public class DataHarmpowerQController extends BaseController { public HttpResult batchInsertion(@RequestBody List dataHarmpowerQDTOList) { String methodDescribe = getMethodDescribe("batchInsertion"); - dataHarmpowerQInsert.batchInsertion(dataHarmpowerQDTOList); + dataHarmpowerQQuery.batchInsertion(dataHarmpowerQDTOList); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); } diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmpowerSController.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmpowerSController.java index c1d44de..49aae0d 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmpowerSController.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataHarmpowerSController.java @@ -52,7 +52,7 @@ public class DataHarmpowerSController extends BaseController { public HttpResult batchInsertion(@RequestBody List dataHarmpowerSDTOList) { String methodDescribe = getMethodDescribe("batchInsertion"); - dataHarmpowerSInsert.batchInsertion(dataHarmpowerSDTOList); + dataHarmpowerSQuery.batchInsertion(dataHarmpowerSDTOList); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); } diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataIController.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataIController.java index 2c81264..154c2fe 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataIController.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataIController.java @@ -52,7 +52,7 @@ public class DataIController extends BaseController { public HttpResult batchInsertion(@RequestBody List dataIDTOList) { String methodDescribe = getMethodDescribe("batchInsertion"); - dataIInsert.batchInsertion(dataIDTOList); + dataIQuery.batchInsertion(dataIDTOList); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); } diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataInharmIController.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataInharmIController.java index 4fe44d2..41ba879 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataInharmIController.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataInharmIController.java @@ -52,7 +52,7 @@ public class DataInharmIController extends BaseController { public HttpResult batchInsertion(@RequestBody List dataInharmIDTOList) { String methodDescribe = getMethodDescribe("batchInsertion"); - dataInharmIInsert.batchInsertion(dataInharmIDTOList); + dataInharmIQuery.batchInsertion(dataInharmIDTOList); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); } diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataInharmVController.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataInharmVController.java index e40a3fa..c2d8427 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataInharmVController.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/controller/DataInharmVController.java @@ -53,7 +53,7 @@ public class DataInharmVController extends BaseController { public HttpResult batchInsertion(@RequestBody List dataInharmVDTOList) { String methodDescribe = getMethodDescribe("batchInsertion"); - dataInharmVInsert.batchInsertion(dataInharmVDTOList); + dataInharmVQuery.batchInsertion(dataInharmVDTOList); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); } diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/LnDataDealServiceImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/LnDataDealServiceImpl.java index be038df..797df6a 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/LnDataDealServiceImpl.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/LnDataDealServiceImpl.java @@ -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());