From 00264c10568b4e2bb378eae93b41f96d83b3a174 Mon Sep 17 00:00:00 2001 From: qiaoqinzheng Date: Sat, 28 Oct 2023 15:36:56 +0800 Subject: [PATCH 1/3] =?UTF-8?q?=E4=B8=AD=E6=96=87=E6=8F=90=E7=A4=BA?= =?UTF-8?q?=E4=BF=A1=E6=81=AF=E4=BF=AE=E6=94=B9=E4=B8=BA=E8=8B=B1=E6=96=87?= =?UTF-8?q?=E6=8F=90=E7=A4=BA=20=E5=8F=B0=E7=AB=99=E8=BF=90=E8=A1=8C?= =?UTF-8?q?=E7=AE=A1=E7=90=86=E6=9F=A5=E8=AF=A2=E5=8F=B0=E7=AB=99=E7=9B=91?= =?UTF-8?q?=E6=B5=8B=E6=95=B0=E6=8D=AE=E4=BF=A1=E6=81=AF=E5=A2=9E=E5=8A=A0?= =?UTF-8?q?=E6=96=B0=E7=9A=84=E5=8F=82=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/org/jeecg/common/util/FTPUtil.java | 2 +- .../service/impl/LogManageServiceImpl.java | 4 ++-- .../service/impl/GammaServiceImpl.java | 10 ++++---- .../impl/SpectrumAnalysisServiceImpl.java | 23 +++++++++--------- .../StationOperationController.java | 5 ++-- .../service/IStationOperationService.java | 3 ++- .../impl/StationOperationServiceImpl.java | 24 ++++++++++++------- .../org/jeecg/common/util/ReadLineUtil.java | 2 +- 8 files changed, 41 insertions(+), 32 deletions(-) diff --git a/jeecg-boot-base-core/src/main/java/org/jeecg/common/util/FTPUtil.java b/jeecg-boot-base-core/src/main/java/org/jeecg/common/util/FTPUtil.java index 309d3694..c1a5e077 100644 --- a/jeecg-boot-base-core/src/main/java/org/jeecg/common/util/FTPUtil.java +++ b/jeecg-boot-base-core/src/main/java/org/jeecg/common/util/FTPUtil.java @@ -88,7 +88,7 @@ public class FTPUtil { ServletOutputStream out = null; FTPClient ftpClient = this.LoginFTP(); if (Objects.isNull(ftpClient)){ - throw new RuntimeException("ftp连接失败!"); + throw new RuntimeException("ftp connection failed!"); } //传输模式 try { diff --git a/jeecg-module-log-manage/src/main/java/org/jeecg/modules/service/impl/LogManageServiceImpl.java b/jeecg-module-log-manage/src/main/java/org/jeecg/modules/service/impl/LogManageServiceImpl.java index bd824cd0..5ddeac79 100644 --- a/jeecg-module-log-manage/src/main/java/org/jeecg/modules/service/impl/LogManageServiceImpl.java +++ b/jeecg-module-log-manage/src/main/java/org/jeecg/modules/service/impl/LogManageServiceImpl.java @@ -26,7 +26,7 @@ public class LogManageServiceImpl implements ILogManageService { List result = new ArrayList<>(); FTPClient ftpClient = ftpUtil.LoginFTP(); if(Objects.isNull(ftpClient)){ - throw new RuntimeException("ftp连接失败!"); + throw new RuntimeException("ftp connection failed!"); } try { //切换被动模式 @@ -79,7 +79,7 @@ public class LogManageServiceImpl implements ILogManageService { List result = new ArrayList<>(); FTPClient ftpClient = ftpUtil.LoginFTP(); if (Objects.isNull(ftpClient)){ - throw new RuntimeException("ftp连接失败!"); + throw new RuntimeException("ftp connection failed!"); } try { //切换被动模式 diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/GammaServiceImpl.java b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/GammaServiceImpl.java index 963a99a9..d084cbbc 100644 --- a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/GammaServiceImpl.java +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/GammaServiceImpl.java @@ -3512,14 +3512,14 @@ public class GammaServiceImpl extends AbstractLogOrReport implements IGammaServi // 获取自动处理生成的报告地址 String reportPath = spectrumAnalysisMapper.viewARR(sampleId); if (StringUtils.isBlank(reportPath)) { - throw new RuntimeException("自动处理程序生成报告不存在！"); + throw new RuntimeException("The automatic handler generated report does not exist！"); } String pathName = StringPool.SLASH + spectrumPathProperties.getSaveFilePath() + StringPool.SLASH + reportPath.substring(0, reportPath.lastIndexOf(StringPool.SLASH)); String fileName = reportPath.substring(reportPath.lastIndexOf(StringPool.SLASH) + 1) + ".txt"; // 连接ftp FTPClient ftpClient = ftpUtil.LoginFTP(); if (Objects.isNull(ftpClient)) { - throw new RuntimeException("ftp连接失败"); + throw new RuntimeException("ftp connection failed"); } InputStream inputStream = null; ServletOutputStream outputStream = null; @@ -3569,7 +3569,7 @@ public class GammaServiceImpl extends AbstractLogOrReport implements IGammaServi // 连接ftp FTPClient ftpClient = ftpUtil.LoginFTP(); if (Objects.isNull(ftpClient)) { - throw new RuntimeException("ftp连接失败"); + throw new RuntimeException("ftp connection failed"); } InputStream inputStream = null; ServletOutputStream outputStream = null; @@ -4100,14 +4100,14 @@ public class GammaServiceImpl extends AbstractLogOrReport implements IGammaServi public void viewAutomaticAnalysisLog(Integer sampleId, HttpServletResponse response) { String logPath = spectrumAnalysisMapper.findAutomaticLogPath(sampleId); if (StringUtils.isBlank(logPath)) { - throw new RuntimeException("自动处理程序生成日志不存在！"); + throw new RuntimeException("The log generated by the automatic processor does not exist！"); } String pathName = StringPool.SLASH + spectrumPathProperties.getLogPath() + StringPool.SLASH + logPath.substring(0, logPath.lastIndexOf(StringPool.SLASH)); String fileName = logPath.substring(logPath.lastIndexOf(StringPool.SLASH) + 1); // 连接ftp FTPClient ftpClient = ftpUtil.LoginFTP(); if (Objects.isNull(ftpClient)) { - throw new RuntimeException("ftp连接失败"); + throw new RuntimeException("ftp connection failed"); } InputStream inputStream = null; ServletOutputStream outputStream = null; diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/SpectrumAnalysisServiceImpl.java b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/SpectrumAnalysisServiceImpl.java index 8648bae7..823c2bd0 100644 --- a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/SpectrumAnalysisServiceImpl.java +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/SpectrumAnalysisServiceImpl.java @@ -183,6 +183,7 @@ public class SpectrumAnalysisServiceImpl implements ISpectrumAnalysisService { } System.out.println(sbSql.toString()); List sampleData = Lists.newArrayList(); + long start = System.currentTimeMillis(); try (Connection connection = jdbcTemplate.getDataSource().getConnection(); PreparedStatement statement = connection.prepareStatement(sbSql.toString()); ResultSet resultSet = statement.executeQuery()) { @@ -202,6 +203,7 @@ public class SpectrumAnalysisServiceImpl implements ISpectrumAnalysisService { } catch (SQLException e) { e.printStackTrace(); } + System.out.println(">>>>>>>>>>>>>"+(System.currentTimeMillis() - start)); // List sampleData = spectrumAnalysisMapper.getDBSearchList(dbName, stationTypes, userStations, AllUsers); //获取台站编码 List stationCodes = new LinkedList<>(); @@ -587,7 +589,7 @@ public class SpectrumAnalysisServiceImpl implements ISpectrumAnalysisService { Map map = new HashMap<>(); FTPClient ftpClient = ftpUtil.LoginFTP(); if (Objects.isNull(ftpClient)){ - throw new RuntimeException("ftp连接失败"); + throw new RuntimeException("ftp connection failed"); } InputStream inputStream = null; File file = null; @@ -719,14 +721,14 @@ public class SpectrumAnalysisServiceImpl implements ISpectrumAnalysisService { //获取自动处理生成的报告地址 String reportPath = spectrumAnalysisMapper.viewARR(sampleId); if (StringUtils.isBlank(reportPath)){ - throw new RuntimeException("自动处理程序生成报告不存在！"); + throw new RuntimeException("The automatic handler generated report does not exist！"); } String pathName = StringPool.SLASH + spectrumPathProperties.getSaveFilePath() + StringPool.SLASH + reportPath.substring(0, reportPath.lastIndexOf(StringPool.SLASH)); String fileName = reportPath.substring(reportPath.lastIndexOf(StringPool.SLASH)+1)+".txt"; //连接ftp FTPClient ftpClient = ftpUtil.LoginFTP(); if (Objects.isNull(ftpClient)){ - throw new RuntimeException("ftp连接失败"); + throw new RuntimeException("ftp connection failed"); } InputStream inputStream = null; ServletOutputStream outputStream = null; @@ -3869,14 +3871,14 @@ public class SpectrumAnalysisServiceImpl implements ISpectrumAnalysisService { public void viewAutomaticAnalysisLog(Integer sampleId, HttpServletResponse response) { String logPath = spectrumAnalysisMapper.findAutomaticLogPath(sampleId); if (StringUtils.isBlank(logPath)){ - throw new RuntimeException("自动处理程序生成日志不存在！"); + throw new RuntimeException("The log generated by the automatic processor does not exist！"); } String pathName = StringPool.SLASH + spectrumPathProperties.getLogPath() + StringPool.SLASH + logPath.substring(0, logPath.lastIndexOf(StringPool.SLASH)); String fileName = logPath.substring(logPath.lastIndexOf(StringPool.SLASH) + 1); //连接ftp FTPClient ftpClient = ftpUtil.LoginFTP(); if (Objects.isNull(ftpClient)){ - throw new RuntimeException("ftp连接失败"); + throw new RuntimeException("ftp connection failed"); } InputStream inputStream = null; ServletOutputStream outputStream = null; @@ -4560,12 +4562,11 @@ public class SpectrumAnalysisServiceImpl implements ISpectrumAnalysisService { if (!CollUtil.contains(skip, line)) newLines.add(line); } - - String export = "SaveToTxt.txt"; - writer = ExportUtil.streamWriter(response, export); - for (String newLine : newLines) { - writer.println(newLine); - } + String export = "SaveToTxt.txt"; + writer = ExportUtil.streamWriter(response, export); + for (String newLine : newLines) { + writer.println(newLine); + } } catch (IOException e) { e.printStackTrace(); }finally { diff --git a/jeecg-module-station-operation/src/main/java/org/jeecg/modules/controller/StationOperationController.java b/jeecg-module-station-operation/src/main/java/org/jeecg/modules/controller/StationOperationController.java index a87c8907..09173cd6 100644 --- a/jeecg-module-station-operation/src/main/java/org/jeecg/modules/controller/StationOperationController.java +++ b/jeecg-module-station-operation/src/main/java/org/jeecg/modules/controller/StationOperationController.java @@ -60,10 +60,11 @@ public class StationOperationController { @GetMapping("getDataReceivingStatus") @ApiOperation(value = "查询台站监测数据信息", notes = "查询台站监测数据信息") - public Result getDataReceivingStatus(String userId){ - return stationOperationService.getDataReceivingStatus(userId); + public Result getDataReceivingStatus(String userId, String oneStationId){ + return stationOperationService.getDataReceivingStatus(userId, oneStationId); } + @GetMapping("getDataProvisionEfficiency") @ApiOperation(value = "查询台站数据提供率及有效率", notes = "查询台站数据提供率及有效率") public Result getDataProvisionEfficiency(){ diff --git a/jeecg-module-station-operation/src/main/java/org/jeecg/modules/service/IStationOperationService.java b/jeecg-module-station-operation/src/main/java/org/jeecg/modules/service/IStationOperationService.java index 3f41a80b..9d7c5768 100644 --- a/jeecg-module-station-operation/src/main/java/org/jeecg/modules/service/IStationOperationService.java +++ b/jeecg-module-station-operation/src/main/java/org/jeecg/modules/service/IStationOperationService.java @@ -46,9 +46,10 @@ public interface IStationOperationService extends IService { /** * 查询台站监测数据 * @param userId + * @param stationId * @return */ - Result getDataReceivingStatus(String userId); + Result getDataReceivingStatus(String userId, String oneStationId); /** * 获取台站数据的提供率及有效率 diff --git a/jeecg-module-station-operation/src/main/java/org/jeecg/modules/service/impl/StationOperationServiceImpl.java b/jeecg-module-station-operation/src/main/java/org/jeecg/modules/service/impl/StationOperationServiceImpl.java index 7f76dba1..33faea02 100644 --- a/jeecg-module-station-operation/src/main/java/org/jeecg/modules/service/impl/StationOperationServiceImpl.java +++ b/jeecg-module-station-operation/src/main/java/org/jeecg/modules/service/impl/StationOperationServiceImpl.java @@ -384,7 +384,7 @@ public class StationOperationServiceImpl extends ServiceImpl stationDataMap = (Map) redisUtil.get("stationDataMap"); // //获取四项缓存数据的对应内容 @@ -401,18 +401,24 @@ public class StationOperationServiceImpl extends ServiceImpl userFocusStationQueryWrapper = new LambdaQueryWrapper<>(); - userFocusStationQueryWrapper.eq(SysUserFocusStationStation::getUserId, userId); - List userFocusStations = sysUserFocusStationMapper.selectList(userFocusStationQueryWrapper); - List stationIds = userFocusStations.stream().map(SysUserFocusStation::getStationId).collect(Collectors.toList()); //过滤出当前用户关注的台站信息 List stationDataList = new LinkedList<>(); - for (String stationId:stationIds) { - if (Objects.nonNull(stationDataMap.get(stationId))) { - stationDataList.add(stationDataMap.get(stationId)); + if (StringUtils.isNotBlank(oneStationId)) { + StationData stationData = stationDataMap.get(oneStationId); + stationDataList.add(stationData); + } else { + //根据用户id查询出当前用户关注的台站信息 + LambdaQueryWrapper userFocusStationQueryWrapper = new LambdaQueryWrapper<>(); + userFocusStationQueryWrapper.eq(SysUserFocusStationStation::getUserId, userId); + List userFocusStations = sysUserFocusStationMapper.selectList(userFocusStationQueryWrapper); + List stationIds = userFocusStations.stream().map(SysUserFocusStation::getStationId).collect(Collectors.toList()); + for (String stationId:stationIds) { + if (Objects.nonNull(stationDataMap.get(stationId))) { + stationDataList.add(stationDataMap.get(stationId)); + } } } + // //从redis中获取台站信息 // Map stationInfoMap = (Map)redisUtil.get("stationMap"); // //从redis中获取探测器信息 diff --git a/jeecg-module-web-statistics/src/main/java/org/jeecg/common/util/ReadLineUtil.java b/jeecg-module-web-statistics/src/main/java/org/jeecg/common/util/ReadLineUtil.java index 26a27197..88328c91 100644 --- a/jeecg-module-web-statistics/src/main/java/org/jeecg/common/util/ReadLineUtil.java +++ b/jeecg-module-web-statistics/src/main/java/org/jeecg/common/util/ReadLineUtil.java @@ -41,7 +41,7 @@ public class ReadLineUtil { FTPClient ftpClient = ftpUtil.LoginFTP(); //判断ftp是否连接成功 if (Objects.isNull(ftpClient)){ - throw new RuntimeException("ftp连接失败!"); + throw new RuntimeException("ftp connection failed!"); } InputStream iStream = null; File file = null; From 89a3de3f0bdb211d963f71a531180b0d8a85e06b Mon Sep 17 00:00:00 2001 From: qiaoqinzheng Date: Sat, 28 Oct 2023 17:24:13 +0800 Subject: [PATCH 2/3] =?UTF-8?q?beta=E5=8A=9F=E8=83=BDEnergy=20Calibration?= =?UTF-8?q?=E9=A1=B5=E9=9D=A2fitting=E6=8C=89=E9=92=AE=E5=A2=9E=E5=8A=A0?= =?UTF-8?q?=E4=BC=A0=E9=80=92=E7=9A=84=E7=82=B9=E6=95=B0=E9=87=8F=E9=9C=80?= =?UTF-8?q?=E8=A6=81=E5=A4=A7=E4=BA=8E2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../modules/service/impl/SpectrumAnalysisServiceImpl.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/SpectrumAnalysisServiceImpl.java b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/SpectrumAnalysisServiceImpl.java index 823c2bd0..ee798f3f 100644 --- a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/SpectrumAnalysisServiceImpl.java +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/SpectrumAnalysisServiceImpl.java @@ -2857,8 +2857,11 @@ public class SpectrumAnalysisServiceImpl implements ISpectrumAnalysisService { Cache> cache = betaCache.getBetaCache(); Map cacheMap = new HashMap<>(); Map map = new HashMap<>(); - if ((CollectionUtils.isNotEmpty(tempPoints) && Objects.nonNull(count) && tempPoints.size() != count) || (Objects.isNull(paramA) || StringUtils.isBlank(String.valueOf(paramA))) - || (Objects.isNull(paramB) || StringUtils.isBlank(String.valueOf(paramB))) || (Objects.isNull(paramC) || StringUtils.isBlank(String.valueOf(paramC))) ){ + //tempPoint数组大小需要大于2个值 + if ((CollectionUtils.isNotEmpty(tempPoints) && tempPoints.size() > 2 && Objects.nonNull(count) && tempPoints.size() != count) + || (Objects.isNull(paramA) || StringUtils.isBlank(String.valueOf(paramA))) + || (Objects.isNull(paramB) || StringUtils.isBlank(String.valueOf(paramB))) + || (Objects.isNull(paramC) || StringUtils.isBlank(String.valueOf(paramC))) ){ List xs = new LinkedList<>(); List ys = new LinkedList<>(); for (int i=0; i Date: Mon, 30 Oct 2023 09:01:11 +0800 Subject: [PATCH 3/3] =?UTF-8?q?log-Manage=E5=8A=9F=E8=83=BD=E4=BF=AE?= =?UTF-8?q?=E6=94=B9=20gamma=E5=8A=9F=E8=83=BD=E8=AE=A1=E7=AE=97=E8=A2=AB?= =?UTF-8?q?=E9=99=A4=E6=95=B0=E4=B8=BA0=E9=97=AE=E9=A2=98=E4=BF=AE?= =?UTF-8?q?=E6=94=B9=20=E8=AE=A1=E7=AE=97=E5=8F=B0=E7=AB=99=E5=8D=8A?= =?UTF-8?q?=E5=BE=84=E8=8C=83=E5=9B=B4=E5=86=85=E8=AE=BE=E5=A4=87=E6=8E=A5?= =?UTF-8?q?=E5=8F=A3=E8=BF=94=E5=9B=9E=E7=9A=84=E6=A0=B8=E8=AE=BE=E6=96=BD?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E6=97=A0=E6=B3=95=E6=98=BE=E7=A4=BA=E9=97=AE?= =?UTF-8?q?=E9=A2=98=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/org/jeecg/common/util/FTPUtil.java | 4 ++ .../service/impl/LogManageServiceImpl.java | 1 + .../service/impl/GammaServiceImpl.java | 10 ++++- .../impl/StationOperationServiceImpl.java | 14 +++--- .../mapper/GardsSampleDataWebMapper.java | 2 + .../mapper/xml/GardsSampleDataWebMapper.xml | 44 +++++++++++++++++++ 6 files changed, 67 insertions(+), 8 deletions(-) diff --git a/jeecg-boot-base-core/src/main/java/org/jeecg/common/util/FTPUtil.java b/jeecg-boot-base-core/src/main/java/org/jeecg/common/util/FTPUtil.java index c1a5e077..164ebabf 100644 --- a/jeecg-boot-base-core/src/main/java/org/jeecg/common/util/FTPUtil.java +++ b/jeecg-boot-base-core/src/main/java/org/jeecg/common/util/FTPUtil.java @@ -55,6 +55,10 @@ public class FTPUtil { return this.encoding; } + public String getFtpRootPath() { + return this.ftpRootPath; + } + /** * 登录ftp * @return diff --git a/jeecg-module-log-manage/src/main/java/org/jeecg/modules/service/impl/LogManageServiceImpl.java b/jeecg-module-log-manage/src/main/java/org/jeecg/modules/service/impl/LogManageServiceImpl.java index 5ddeac79..3138b956 100644 --- a/jeecg-module-log-manage/src/main/java/org/jeecg/modules/service/impl/LogManageServiceImpl.java +++ b/jeecg-module-log-manage/src/main/java/org/jeecg/modules/service/impl/LogManageServiceImpl.java @@ -36,6 +36,7 @@ public class LogManageServiceImpl implements ILogManageService { ftpClient.setControlEncoding("UTF-8"); ftpClient.setFileTransferMode(FTPClient.STREAM_TRANSFER_MODE); //切换工作文件路径 + workPath = ftpUtil.getFtpRootPath()+StringPool.SLASH+workPath; ftpClient.changeWorkingDirectory(workPath); List ftpFiles = Arrays.asList(ftpClient.listDirectories()); if (CollectionUtils.isNotEmpty(ftpFiles)){ diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/GammaServiceImpl.java b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/GammaServiceImpl.java index d084cbbc..53ecda17 100644 --- a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/GammaServiceImpl.java +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/GammaServiceImpl.java @@ -4476,7 +4476,10 @@ public class GammaServiceImpl extends AbstractLogOrReport implements IGammaServi } String efficiency = NumberFormatUtil.numberFormat(String.valueOf(nuc.getEfficiency())); String activity = NumberFormatUtil.numberFormat(String.valueOf(nuc.getActivity())); - String actErr = NumberFormatUtil.numberFormat(String.valueOf(nuc.getAct_err() / nuc.getActivity() * 100)); + String actErr = ""; + if (nuc.getActivity() > 0) { + actErr = NumberFormatUtil.numberFormat(String.valueOf(nuc.getAct_err() / nuc.getActivity() * 100)); + } String mda = NumberFormatUtil.numberFormat(String.valueOf(nuc.getMda())); String conc = NumberFormatUtil.numberFormat(String.valueOf(nuc.getConcentration())); String mdc = NumberFormatUtil.numberFormat(String.valueOf(nuc.getMdc())); @@ -4603,7 +4606,10 @@ public class GammaServiceImpl extends AbstractLogOrReport implements IGammaServi double activityValue = nuclideActMda.getActivity(); String activity = NumberFormatUtil.numberFormat(String.valueOf(activityValue)); nuclideActMdaDto.setActivity(activity); - String actErr = NumberFormatUtil.numberFormat(String.valueOf(actErrValue / activityValue * 100)); + String actErr = ""; + if (activityValue > 0) { + actErr = NumberFormatUtil.numberFormat(String.valueOf(actErrValue / activityValue * 100)); + } nuclideActMdaDto.setActErr(actErr); String mda = NumberFormatUtil.numberFormat(String.valueOf(nuclideActMda.getMda())); nuclideActMdaDto.setMda(mda); diff --git a/jeecg-module-station-operation/src/main/java/org/jeecg/modules/service/impl/StationOperationServiceImpl.java b/jeecg-module-station-operation/src/main/java/org/jeecg/modules/service/impl/StationOperationServiceImpl.java index 33faea02..feb2fec6 100644 --- a/jeecg-module-station-operation/src/main/java/org/jeecg/modules/service/impl/StationOperationServiceImpl.java +++ b/jeecg-module-station-operation/src/main/java/org/jeecg/modules/service/impl/StationOperationServiceImpl.java @@ -251,16 +251,18 @@ public class StationOperationServiceImpl extends ServiceImpl Page findReviewedPage(String startDate, String endDate, List stationIdList, Page page); + Page findParticulatePage(String dataType, String spectralQualifie, String startDate, String endDate, List stationIdList, Page page); + } diff --git a/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/mapper/xml/GardsSampleDataWebMapper.xml b/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/mapper/xml/GardsSampleDataWebMapper.xml index 1f3fcb63..ac6fd63e 100644 --- a/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/mapper/xml/GardsSampleDataWebMapper.xml +++ b/jeecg-module-web-statistics/src/main/java/org/jeecg/modules/mapper/xml/GardsSampleDataWebMapper.xml @@ -82,4 +82,48 @@ ORDER BY sam.ACQUISITION_START DESC + + \ No newline at end of file