From cb06b77aeff8bd50f165c354f39d6e159dbc2555 Mon Sep 17 00:00:00 2001 From: wr <1754607820@qq.com> Date: Fri, 21 Feb 2025 10:41:57 +0800 Subject: [PATCH] =?UTF-8?q?1.=E8=A7=A3=E5=86=B3mysql=20index=E5=85=B3?= =?UTF-8?q?=E9=94=AE=E5=AD=97=202.=E5=A2=9E=E5=8A=A0=E9=80=9A=E8=AE=AF?= =?UTF-8?q?=E8=84=9A=E6=9C=AC=E7=9B=B8=E5=85=B3=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/DetectionServiceImpl.java | 4 +- .../plan/service/impl/AdPlanServiceImpl.java | 2 +- .../service/impl/ReportServiceImpl.java | 4 +- .../service/impl/ResultServiceImpl.java | 36 +-- .../script/controller/PqScriptController.java | 57 +++- .../mapper/mapping/PqScriptDtlsMapper.xml | 2 +- .../gather/script/pojo/param/ScriptParam.java | 29 ++ .../script/pojo/po/PqScriptCheckData.java | 3 +- .../gather/script/pojo/po/PqScriptDtls.java | 4 +- .../gather/script/pojo/po/SourceIssue.java | 6 + .../script/service/IPqScriptDtlsService.java | 28 +- .../impl/PqScriptCheckDataServiceImpl.java | 4 +- .../service/impl/PqScriptDtlsServiceImpl.java | 252 ++++++++++++------ .../gather/script/util/ScriptDtlsDesc.java | 2 +- 14 files changed, 311 insertions(+), 122 deletions(-) create mode 100644 detection/src/main/java/com/njcn/gather/script/pojo/param/ScriptParam.java diff --git a/detection/src/main/java/com/njcn/gather/detection/service/impl/DetectionServiceImpl.java b/detection/src/main/java/com/njcn/gather/detection/service/impl/DetectionServiceImpl.java index d498e9c6..221c1ab2 100644 --- a/detection/src/main/java/com/njcn/gather/detection/service/impl/DetectionServiceImpl.java +++ b/detection/src/main/java/com/njcn/gather/detection/service/impl/DetectionServiceImpl.java @@ -514,7 +514,7 @@ public class DetectionServiceImpl { DictDataEnum dataRule, String code) { List checkData = pqScriptCheckDataService.list(new MPJLambdaWrapper() - .eq(PqScriptCheckData::getIndex, sourceIssue.getIndex()) + .eq(PqScriptCheckData::getScriptIndex, sourceIssue.getIndex()) .eq(PqScriptCheckData::getScriptId, sourceIssue.getScriptId()) ); Map> map = devListMap(dev, dataRule, code); @@ -802,7 +802,7 @@ public class DetectionServiceImpl { Map issueHarmMap; if (P.equals(type)) { List checkData = pqScriptCheckDataService.list(new MPJLambdaWrapper() - .eq(PqScriptCheckData::getIndex, sourceIssue.getIndex()) + .eq(PqScriptCheckData::getScriptIndex, sourceIssue.getIndex()) .eq(PqScriptCheckData::getPhase, phase) .eq(PqScriptCheckData::getScriptId, sourceIssue.getScriptId()) ); diff --git a/detection/src/main/java/com/njcn/gather/plan/service/impl/AdPlanServiceImpl.java b/detection/src/main/java/com/njcn/gather/plan/service/impl/AdPlanServiceImpl.java index 1c779ca4..b69ddb01 100644 --- a/detection/src/main/java/com/njcn/gather/plan/service/impl/AdPlanServiceImpl.java +++ b/detection/src/main/java/com/njcn/gather/plan/service/impl/AdPlanServiceImpl.java @@ -354,7 +354,7 @@ public class AdPlanServiceImpl extends ServiceImpl impleme List scriptDtlsList = pqScriptDtlsService.listPqScriptDtlByScriptId(scriptId); Map> collect = scriptDtlsList.stream() - .sorted(Comparator.comparing(PqScriptDtls::getIndex)) + .sorted(Comparator.comparing(PqScriptDtls::getScriptIndex)) .collect(Collectors.groupingBy(PqScriptDtls::getScriptType, LinkedHashMap::new, Collectors.toList())); collect.forEach((key, value) -> { diff --git a/detection/src/main/java/com/njcn/gather/report/service/impl/ReportServiceImpl.java b/detection/src/main/java/com/njcn/gather/report/service/impl/ReportServiceImpl.java index 7bc158b3..7b74ca87 100644 --- a/detection/src/main/java/com/njcn/gather/report/service/impl/ReportServiceImpl.java +++ b/detection/src/main/java/com/njcn/gather/report/service/impl/ReportServiceImpl.java @@ -488,7 +488,7 @@ public class ReportServiceImpl implements IReportService { queryWrapper.eq(PqScriptCheckData::getScriptId, scriptId) .eq(PqScriptCheckData::getEnable, DataStateEnum.ENABLE.getCode()) .in(PqScriptCheckData::getPhase, phase) - .eq(PqScriptCheckData::getIndex, index); + .eq(PqScriptCheckData::getScriptIndex, index); List list = pqScriptCheckDataService.list(queryWrapper); if (CollectionUtil.isNotEmpty(list)) { return list.get(0).getValueType(); @@ -537,7 +537,7 @@ public class ReportServiceImpl implements IReportService { .eq(PqScriptDtls::getValue, value); List pqScriptDtls = pqScriptDtlsService.list(queryWrapper); if (CollectionUtil.isNotEmpty(pqScriptDtls)) { - return pqScriptDtls.get(0).getIndex(); + return pqScriptDtls.get(0).getScriptIndex(); } return null; } diff --git a/detection/src/main/java/com/njcn/gather/result/service/impl/ResultServiceImpl.java b/detection/src/main/java/com/njcn/gather/result/service/impl/ResultServiceImpl.java index 7c8620cf..1b44e97a 100644 --- a/detection/src/main/java/com/njcn/gather/result/service/impl/ResultServiceImpl.java +++ b/detection/src/main/java/com/njcn/gather/result/service/impl/ResultServiceImpl.java @@ -126,8 +126,8 @@ public class ResultServiceImpl implements IResultService { .selectAll(PqScriptDtls.class) .eq(StrUtil.isNotBlank(param.getScriptId()), PqScriptDtls::getScriptId, param.getScriptId()) .eq(StrUtil.isNotBlank(param.getScriptType()), PqScriptDtls::getScriptType, param.getScriptType()) - .ne(PqScriptDtls::getIndex, -1) - .eq(PqScriptDtls::getEnable, DataStateEnum.ENABLE.getCode()) + .ne(PqScriptDtls::getScriptIndex, -1) + .eq(StrUtil.isNotBlank(param.getDevId()),PqScriptDtls::getEnable, DataStateEnum.ENABLE.getCode()) ); Map> resultMap = new HashMap<>(5); if(StrUtil.isNotBlank(param.getDevId())){ @@ -144,7 +144,7 @@ public class ResultServiceImpl implements IResultService { } Map> dtlsSortMap = dtlsList.stream() - .sorted(Comparator.comparing(PqScriptDtls::getIndex)) + .sorted(Comparator.comparing(PqScriptDtls::getScriptIndex)) .collect(Collectors.groupingBy(PqScriptDtls::getScriptType, LinkedHashMap::new, Collectors.toList())); List dictTreeById = dictTreeService.getDictTreeById(new ArrayList<>(dtlsSortMap.keySet())); @@ -170,7 +170,7 @@ public class ResultServiceImpl implements IResultService { infoVO.setScriptTypeCode(dictTree.getId()); //额定条件下频率准确度测试 LinkedHashMap> subTypeMap = value.stream() - .sorted(Comparator.comparing(PqScriptDtls::getIndex)) + .sorted(Comparator.comparing(PqScriptDtls::getScriptIndex)) .filter(x -> "Base".equals(x.getScriptSubType())) .collect(Collectors.groupingBy(PqScriptDtls::getScriptSubType, LinkedHashMap::new, Collectors.toList())); subTypeMap.forEach((subKey, subValue) -> { @@ -179,8 +179,8 @@ public class ResultServiceImpl implements IResultService { subType.setScriptTypeName(subName.get(subKey).replace("XX", dictTree.getName())); subType.setScriptTypeCode(subKey); LinkedHashMap> indexMap = subValue.stream() - .sorted(Comparator.comparing(PqScriptDtls::getIndex)) - .collect(Collectors.groupingBy(PqScriptDtls::getIndex, LinkedHashMap::new, Collectors.toList())); + .sorted(Comparator.comparing(PqScriptDtls::getScriptIndex)) + .collect(Collectors.groupingBy(PqScriptDtls::getScriptIndex, LinkedHashMap::new, Collectors.toList())); List subTypeList = new ArrayList<>(); indexMap.forEach((index, scriptDtlIndexList) -> { TreeDataVO dtlType = new TreeDataVO(); @@ -208,7 +208,7 @@ public class ResultServiceImpl implements IResultService { //单影响量下频率准确度测试 LinkedHashMap> subSingleTypeMap = value.stream() - .sorted(Comparator.comparing(PqScriptDtls::getIndex)) + .sorted(Comparator.comparing(PqScriptDtls::getScriptIndex)) .filter(x -> !"Base".equals(x.getScriptSubType())) .collect(Collectors.groupingBy(PqScriptDtls::getScriptSubType, LinkedHashMap::new, Collectors.toList())); if (CollUtil.isNotEmpty(subSingleTypeMap)) { @@ -224,8 +224,8 @@ public class ResultServiceImpl implements IResultService { List subTypeList = new ArrayList<>(); LinkedHashMap> indexMap = subValue.stream() - .sorted(Comparator.comparing(PqScriptDtls::getIndex)) - .collect(Collectors.groupingBy(PqScriptDtls::getIndex, LinkedHashMap::new, Collectors.toList())); + .sorted(Comparator.comparing(PqScriptDtls::getScriptIndex)) + .collect(Collectors.groupingBy(PqScriptDtls::getScriptIndex, LinkedHashMap::new, Collectors.toList())); indexMap.forEach((index, scriptDtlIndexList) -> { TreeDataVO dtlType = new TreeDataVO(); dtlType.setIndex(index); @@ -268,21 +268,21 @@ public class ResultServiceImpl implements IResultService { List dip = subValue.stream() .filter(x -> "Dip".equals(x.getValueType()) && "A".equals(x.getPhase())) .filter(x -> x.getTransValue() >= start && x.getTransValue() <= end) - .sorted(Comparator.comparing(PqScriptDtls::getIndex)) + .sorted(Comparator.comparing(PqScriptDtls::getScriptIndex)) .collect(Collectors.toList()); TreeDataVO vo = new TreeDataVO(); vo.setScriptTypeName(name); TreeDataVO dlt; for (PqScriptDtls dtls : dip) { dlt = new TreeDataVO(); - List scriptDtlIndexList = subValue.stream().filter(x -> dtls.getIndex().equals(x.getIndex())).collect(Collectors.toList()); + List scriptDtlIndexList = subValue.stream().filter(x -> dtls.getScriptIndex().equals(x.getScriptIndex())).collect(Collectors.toList()); //特征幅值=20%Un,持续时间=1周波 dlt.setScriptTypeName("特征幅值=" + dtls.getTransValue() + "%Un,持续时间=" + dtls.getRetainTime().intValue() + "周波"); - dlt.setIndex(dtls.getIndex()); + dlt.setIndex(dtls.getScriptIndex()); dlt.setScriptType(scriptDtlIndexList.get(0).getScriptType()); dlt.setSourceDesc(ScriptDtlsDesc.getStringBuffer(scriptDtlIndexList, isValueType).toString()); - if (finalResultMap.containsKey(dtls.getIndex())) { - dlt.setFly(conform(finalResultMap.get(dtls.getIndex()))); + if (finalResultMap.containsKey(dtls.getScriptIndex())) { + dlt.setFly(conform(finalResultMap.get(dtls.getScriptIndex()))); } info.add(dlt); @@ -398,7 +398,7 @@ public class ResultServiceImpl implements IResultService { case IMBV: List list = pqScriptCheckDataService.list(new MPJLambdaWrapper() .eq(PqScriptCheckData::getScriptId, scriptDtlIndexList.get(0).getScriptId()) - .eq(PqScriptCheckData::getIndex, scriptDtlIndexList.get(0).getIndex()) + .eq(PqScriptCheckData::getScriptIndex, scriptDtlIndexList.get(0).getScriptIndex()) ); //三相负序电压不平衡度=0% dtlType.setScriptTypeName(dictTree.getName() + "=" + list.get(0).getValue() + ResultUnitEnum.IMBV.getUnit()); @@ -409,7 +409,7 @@ public class ResultServiceImpl implements IResultService { case IMBA: List imba = pqScriptCheckDataService.list(new MPJLambdaWrapper() .eq(PqScriptCheckData::getScriptId, scriptDtlIndexList.get(0).getScriptId()) - .eq(PqScriptCheckData::getIndex, scriptDtlIndexList.get(0).getIndex()) + .eq(PqScriptCheckData::getScriptIndex, scriptDtlIndexList.get(0).getScriptIndex()) ); //三相负序电流不平衡度=0% dtlType.setScriptTypeName(dictTree.getName() + "=" + imba.get(0).getValue() + ResultUnitEnum.IMBV.getUnit()); @@ -767,7 +767,7 @@ public class ResultServiceImpl implements IResultService { .select(PqScriptCheckData::getHarmNum) .eq(PqScriptCheckData::getScriptId, param.getScriptId()) .isNotNull(PqScriptCheckData::getHarmNum) - .eq(PqScriptCheckData::getIndex, param.getIndex()) + .eq(PqScriptCheckData::getScriptIndex, param.getIndex()) ); harmNum = list.stream().sorted(Comparator.comparing(PqScriptCheckData::getHarmNum)) .map(PqScriptCheckData::getHarmNum).distinct().collect(Collectors.toList()); @@ -800,7 +800,7 @@ public class ResultServiceImpl implements IResultService { .select(PqScriptCheckData::getHarmNum) .eq(PqScriptCheckData::getScriptId, param.getScriptId()) .isNotNull(PqScriptCheckData::getHarmNum) - .eq(PqScriptCheckData::getIndex, param.getIndex()) + .eq(PqScriptCheckData::getScriptIndex, param.getIndex()) ); harmNum = list.stream().sorted(Comparator.comparing(PqScriptCheckData::getHarmNum)) .map(PqScriptCheckData::getHarmNum).distinct().collect(Collectors.toList()); diff --git a/detection/src/main/java/com/njcn/gather/script/controller/PqScriptController.java b/detection/src/main/java/com/njcn/gather/script/controller/PqScriptController.java index 7164d97c..ad3fa2a5 100644 --- a/detection/src/main/java/com/njcn/gather/script/controller/PqScriptController.java +++ b/detection/src/main/java/com/njcn/gather/script/controller/PqScriptController.java @@ -10,7 +10,9 @@ import com.njcn.common.utils.LogUtil; import com.njcn.gather.script.pojo.param.PqScriptDtlsParam; import com.njcn.gather.script.pojo.param.PqScriptIssueParam; import com.njcn.gather.script.pojo.param.PqScriptParam; +import com.njcn.gather.script.pojo.param.ScriptParam; import com.njcn.gather.script.pojo.po.PqScript; +import com.njcn.gather.script.pojo.po.PqScriptCheckData; import com.njcn.gather.script.pojo.po.PqScriptDtls; import com.njcn.gather.script.pojo.po.SourceIssue; import com.njcn.gather.script.service.IPqScriptDtlsService; @@ -130,7 +132,7 @@ public class PqScriptController extends BaseController { @ApiOperation("获取指定模式下的所有检测脚本") @ApiImplicitParam(name = "patternId", value = "模式Id", required = true) public HttpResult>> getAllPqScript(@RequestParam("patternId") String patternId) { - String methodDescribe = getMethodDescribe("getAll"); + String methodDescribe = getMethodDescribe("getAllPqScript"); LogUtil.njcnDebug(log, "{},查询数据为:{}", methodDescribe, patternId); List> result = pqScriptService.listAllPqScript(patternId); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, result, methodDescribe); @@ -140,8 +142,8 @@ public class PqScriptController extends BaseController { @OperateInfo @PostMapping("/dlsDetails") @ApiOperation("根据脚本id查询检测脚本详情") - @ApiImplicitParam(name = "id", value = "检测脚本id", required = true) - public HttpResult> dls(@RequestBody PqScriptIssueParam param) { + @ApiImplicitParam(name = "param", value = "检测脚本", required = true) + public HttpResult> dlsDetails(@RequestBody PqScriptIssueParam param) { String methodDescribe = getMethodDescribe("dlsDetails"); LogUtil.njcnDebug(log, "{},查询数据为:{}", methodDescribe, param); List sourceIssues = pqScriptDtlsService.listSourceIssue(param); @@ -152,12 +154,59 @@ public class PqScriptController extends BaseController { @OperateInfo @PostMapping("/addScriptDtls") @ApiOperation("添加检测脚本") - @ApiImplicitParam(name = "id", value = "检测脚本id", required = true) + @ApiImplicitParam(name = "sourceIssue", value = "检测脚本", required = true) public HttpResult addScriptDtls(@RequestBody PqScriptDtlsParam sourceIssue) { String methodDescribe = getMethodDescribe("addScriptDtls"); LogUtil.njcnDebug(log, "{},查询数据为:{}", methodDescribe, sourceIssue); Boolean b = pqScriptDtlsService.saveScriptDtls(sourceIssue); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, b , methodDescribe); } + + @OperateInfo + @PostMapping("/scriptDtlsCheckDataList") + @ApiOperation("根据通讯参数生成装置下发原始数据公式") + @ApiImplicitParam(name = "sourceIssue", value = "检测脚本", required = true) + public HttpResult> scriptDtlsCheckDataList(@RequestBody PqScriptDtlsParam sourceIssue) { + String methodDescribe = getMethodDescribe("scriptDtlsCheckDataList"); + LogUtil.njcnDebug(log, "{},查询数据为:{}", methodDescribe, sourceIssue); + List checkData = pqScriptDtlsService.scriptDtlsCheckDataList(sourceIssue); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, checkData , methodDescribe); + } + + + @OperateInfo + @PostMapping("/deleteDtls") + @ApiOperation("删除脚本") + @ApiImplicitParam(name = "sourceIssue", value = "检测脚本", required = true) + public HttpResult deleteDtls(@RequestBody @Validated ScriptParam sourceIssue) { + String methodDescribe = getMethodDescribe("deleteDtls"); + LogUtil.njcnDebug(log, "{},查询数据为:{}", methodDescribe, sourceIssue); + Boolean b = pqScriptDtlsService.deleteDtls(sourceIssue); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, b , methodDescribe); + } + + + @OperateInfo + @PostMapping("/updateDtls") + @ApiOperation("启用关闭脚本") + @ApiImplicitParam(name = "sourceIssue", value = "检测脚本", required = true) + public HttpResult updateDtls(@RequestBody @Validated ScriptParam sourceIssue) { + String methodDescribe = getMethodDescribe("updateDtls"); + LogUtil.njcnDebug(log, "{},查询数据为:{}", methodDescribe, sourceIssue); + Boolean b = pqScriptDtlsService.updateDtls(sourceIssue); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, b , methodDescribe); + } + + @OperateInfo + @PostMapping("/checkDataList") + @ApiOperation("通讯脚本回显") + @ApiImplicitParam(name = "sourceIssue", value = "检测脚本", required = true) + public HttpResult> checkDataList(@RequestBody @Validated ScriptParam sourceIssue) { + String methodDescribe = getMethodDescribe("checkDataList"); + LogUtil.njcnDebug(log, "{},查询数据为:{}", methodDescribe, sourceIssue); + List checkData = pqScriptDtlsService.checkDataList(sourceIssue); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, checkData, methodDescribe); + } + } diff --git a/detection/src/main/java/com/njcn/gather/script/mapper/mapping/PqScriptDtlsMapper.xml b/detection/src/main/java/com/njcn/gather/script/mapper/mapping/PqScriptDtlsMapper.xml index f45dfe15..35e6e867 100644 --- a/detection/src/main/java/com/njcn/gather/script/mapper/mapping/PqScriptDtlsMapper.xml +++ b/detection/src/main/java/com/njcn/gather/script/mapper/mapping/PqScriptDtlsMapper.xml @@ -6,7 +6,7 @@