diff --git a/jeecg-boot-base-core/src/main/resources/excelTemplate/SaveExcel.xls b/jeecg-boot-base-core/src/main/resources/excelTemplate/SaveExcel.xls index 17c625ee..22c3e556 100644 Binary files a/jeecg-boot-base-core/src/main/resources/excelTemplate/SaveExcel.xls and b/jeecg-boot-base-core/src/main/resources/excelTemplate/SaveExcel.xls differ diff --git a/jeecg-boot-base-core/src/main/resources/excelTemplate/SaveHtml.html b/jeecg-boot-base-core/src/main/resources/excelTemplate/SaveHtml.html index 42d06c65..f0047357 100644 --- a/jeecg-boot-base-core/src/main/resources/excelTemplate/SaveHtml.html +++ b/jeecg-boot-base-core/src/main/resources/excelTemplate/SaveHtml.html @@ -117,12 +117,12 @@ New Gamma - CH(x) = (?1)+(?2)*x+(?3)x*x - CH(x) = (?1)+(?2)*x+(?3)x*x + CH(x) = ([[${betaCalibrationSEC.coeff1}]])+([[${betaCalibrationSEC.coeff2}]])*x+([[${betaCalibrationSEC.coeff3}]])x*x + CH(x) = ([[${gammaCalibrationSEC.coeff1}]])+([[${gammaCalibrationSEC.coeff2}]])*x+([[${gammaCalibrationSEC.coeff3}]])x*x - E(x) = (-3.33443)+(0.398048)*x+(-0.000124)x*x - E(x) = (0.879727)+(0.365551)*x+(-2.8e-05)x*x + E(x) = ([[${betaCalibrationSCE.coeff1}]])+([[${betaCalibrationSCE.coeff2}]])*x+([[${betaCalibrationSCE.coeff3}]])x*x + E(x) = ([[${gammaCalibrationSCE.coeff1}]])+([[${gammaCalibrationSCE.coeff2}]])*x+([[${gammaCalibrationSCE.coeff3}]])x*x   @@ -169,12 +169,12 @@ New Gamma - CH(x) = (?1)+(?2)*x+(?3)x*x - CH(x) = (?1)+(?2)*x+(?3)x*x + CH(x) = ([[${betaCalibrationDEC.coeff1}]])+([[${betaCalibrationDEC.coeff2}]])*x+([[${betaCalibrationDEC.coeff3}]])x*x + CH(x) = ([[${gammaCalibrationDEC.coeff1}]])+([[${gammaCalibrationDEC.coeff2}]])*x+([[${gammaCalibrationDEC.coeff3}]])x*x - E(x) = (0.879727)+(0.365551)*x+(-2.8e-05)x*x - E(x) = (0.879727)+(0.365551)*x+(-2.8e-05)x*x + E(x) = ([[${betaCalibrationDCE.coeff1}]])+([[${betaCalibrationDCE.coeff2}]])*x+([[${betaCalibrationDCE.coeff3}]])x*x + E(x) = ([[${gammaCalibrationDCE.coeff1}]])+([[${gammaCalibrationDCE.coeff2}]])*x+([[${gammaCalibrationDCE.coeff3}]])x*x   @@ -222,12 +222,12 @@ New Gamma - CH(x) = (?1)+(?2)*x+(?3)x*x - CH(x) = (?1)+(?2)*x+(?3)x*x + CH(x) = ([[${betaCalibrationGEC.coeff1}]])+([[${betaCalibrationGEC.coeff2}]])*x+([[${betaCalibrationGEC.coeff3}]])x*x + CH(x) = ([[${gammaCalibrationGEC.coeff1}]])+([[${gammaCalibrationGEC.coeff2}]])*x+([[${gammaCalibrationGEC.coeff3}]])x*x - E(x) = (-3.33443)+(0.398048)*x+(-0.000124)x*x - E(x) = (0.879727)+(0.365551)*x+(-2.8e-05)x*x + E(x) = ([[${betaCalibrationGCE.coeff1}]])+([[${betaCalibrationGCE.coeff2}]])*x+([[${betaCalibrationGCE.coeff3}]])x*x + E(x) = ([[${gammaCalibrationGCE.coeff1}]])+([[${gammaCalibrationGCE.coeff2}]])*x+([[${gammaCalibrationGCE.coeff3}]])x*x   diff --git a/jeecg-boot-base-core/src/main/resources/excelTemplate/SaveTxt.txt b/jeecg-boot-base-core/src/main/resources/excelTemplate/SaveTxt.txt index 160cbc39..775aa787 100644 --- a/jeecg-boot-base-core/src/main/resources/excelTemplate/SaveTxt.txt +++ b/jeecg-boot-base-core/src/main/resources/excelTemplate/SaveTxt.txt @@ -33,8 +33,7 @@ #SAMPLE New CALIBRATION New Beta New Gamma - CH(x) = (?1)+(?2)*x+(?3)x*x CH(x) = (?1)+(?2)*x+(?3)x*x - E(x) = (-3.33443)+(0.398048)*x+(-0.000124)x*x E(x) = (0.879727)+(0.365551)*x+(-2.8e-05)x*x +${sampleNewCalibration} #SAMPLE: LIMITS PER ROI Roi Beta Gamma @@ -47,8 +46,7 @@ ${sampleRoi} #DET New CALIBRATION New Beta New Gamma - CH(x) = (?1)+(?2)*x+(?3)x*x CH(x) = (?1)+(?2)*x+(?3)x*x - E(x) = (0.879727)+(0.365551)*x+(-2.8e-05)x*x E(x) = (0.879727)+(0.365551)*x+(-2.8e-05)x*x +${detNewCalibration} #DET: LIMITS PER ROI Roi Beta Gamma @@ -61,8 +59,7 @@ ${detRoi} #GAS New CALIBRATION New Beta New Gamma - CH(x) = (?1)+(?2)*x+(?3)x*x CH(x) = (?1)+(?2)*x+(?3)x*x - E(x) = (-3.33443)+(0.398048)*x+(-0.000124)x*x E(x) = (0.879727)+(0.365551)*x+(-2.8e-05)x*x +${gasNewCalibration} #GAS: LIMITS PER ROI Roi Beta Gamma diff --git a/jeecg-module-auto-process/src/main/java/org/jeecg/common/GammaFileUtil.java b/jeecg-module-auto-process/src/main/java/org/jeecg/common/GammaFileUtil.java index d822691d..ee83e1ee 100644 --- a/jeecg-module-auto-process/src/main/java/org/jeecg/common/GammaFileUtil.java +++ b/jeecg-module-auto-process/src/main/java/org/jeecg/common/GammaFileUtil.java @@ -2710,10 +2710,11 @@ public class GammaFileUtil { } public List DoubleLimit(List data){ + List rData = new LinkedList<>(); for(int pos=0;pos DoubleLimit_G(List _data) { diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/common/util/GammaFileUtil.java b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/common/util/GammaFileUtil.java index ffd95e03..5caf617a 100644 --- a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/common/util/GammaFileUtil.java +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/common/util/GammaFileUtil.java @@ -76,15 +76,8 @@ public class GammaFileUtil { ftpClient.setControlEncoding("UTF-8"); ftpClient.setFileTransferMode(FTPClient.STREAM_TRANSFER_MODE); ftpClient.changeWorkingDirectory(pathName); - List ftpFiles = Arrays.asList(ftpClient.listFiles()); - ftpFiles = ftpFiles.stream().filter(item -> item.getName().equals(fileName)).collect(Collectors.toList()); - if (ftpFiles.size() == 0) { - result.error500("ftp获取文件数据失败"); - return false; - } - FTPFile ftpFile = ftpFiles.get(0); - if (Objects.nonNull(ftpFile)) { - inputStream = ftpClient.retrieveFileStream(ftpFile.getName()); + inputStream = ftpClient.retrieveFileStream(fileName); + if (Objects.nonNull(inputStream)) { //声明一个临时文件 File file = File.createTempFile("tmp", null); //将ftp文件的输入流复制给临时文件 @@ -270,7 +263,7 @@ public class GammaFileUtil { return true; } - public void SetBaseInfo(PHDFile phd){ + public void SetBaseInfo(PHDFile phd) { String pathName = phd.getFilepath(); String fileName = phd.getFilename(); //文件名称需要加上自动处理的前缀以及修改不同的文件后缀名 @@ -281,6 +274,7 @@ public class GammaFileUtil { if (Objects.isNull(ftpClient)){ String warning = "ftp连接失败"; } + InputStream inputStream = null; try { //切换被动模式 ftpClient.enterLocalPassiveMode(); @@ -289,27 +283,27 @@ public class GammaFileUtil { ftpClient.setControlEncoding("UTF-8"); ftpClient.setFileTransferMode(FTPClient.STREAM_TRANSFER_MODE); ftpClient.changeWorkingDirectory(pathName); - List ftpFiles = Arrays.asList(ftpClient.listFiles()); String lcFileName = "RNAUTO_"+subFileName + ".lc"; - List lcFiles = ftpFiles.stream().filter(item -> item.getName().equals(lcFileName)).collect(Collectors.toList()); - if (CollectionUtils.isNotEmpty(lcFiles)){ - FTPFile lcFile = lcFiles.get(0); - if (Objects.nonNull(lcFile)){ - InputStream inputStream = ftpClient.retrieveFileStream(lcFile.getName()); - //声明一个临时文件 - File file = File.createTempFile("tmp", null); - //将ftp文件的输入流复制给临时文件 - FileUtils.copyInputStreamToFile(inputStream, file); - List readLines = FileUtils.readLines(file, "UTF-8"); - List vData = ReadLcScacInfo(readLines); - phd.setVLc(vData); - } + inputStream = ftpClient.retrieveFileStream(lcFileName); + if (Objects.nonNull(inputStream)){ + //声明一个临时文件 + File file = File.createTempFile("tmp", null); + //将ftp文件的输入流复制给临时文件 + FileUtils.copyInputStreamToFile(inputStream, file); + List readLines = FileUtils.readLines(file, "UTF-8"); + List vData = ReadLcScacInfo(readLines); + phd.setVLc(vData); } } catch (IOException e) { throw new RuntimeException(e); } finally { try { - ftpClient.disconnect(); + if (Objects.nonNull(ftpClient)) { + ftpClient.disconnect(); + } + if (Objects.nonNull(inputStream)) { + inputStream.close(); + } } catch (IOException e) { throw new RuntimeException(e); } @@ -321,6 +315,7 @@ public class GammaFileUtil { if (Objects.isNull(ftpClient)){ String warning = "ftp连接失败"; } + InputStream inputStream = null; try { //切换被动模式 ftpClient.enterLocalPassiveMode(); @@ -329,27 +324,27 @@ public class GammaFileUtil { ftpClient.setControlEncoding("UTF-8"); ftpClient.setFileTransferMode(FTPClient.STREAM_TRANSFER_MODE); ftpClient.changeWorkingDirectory(pathName); - List ftpFiles = Arrays.asList(ftpClient.listFiles()); String scacFileName = "RNAUTO_"+subFileName + ".scac"; - List scacFiles = ftpFiles.stream().filter(item -> item.getName().equals(scacFileName)).collect(Collectors.toList()); - if (CollectionUtils.isNotEmpty(scacFiles)){ - FTPFile scacFile = scacFiles.get(0); - if (Objects.nonNull(scacFile)){ - InputStream inputStream = ftpClient.retrieveFileStream(scacFile.getName()); - //声明一个临时文件 - File file = File.createTempFile("tmp", null); - //将ftp文件的输入流复制给临时文件 - FileUtils.copyInputStreamToFile(inputStream, file); - List readLines = FileUtils.readLines(file, "UTF-8"); - List vData = ReadLcScacInfo(readLines); - phd.setVScac(vData); - } + inputStream = ftpClient.retrieveFileStream(scacFileName); + if (Objects.nonNull(inputStream)){ + //声明一个临时文件 + File file = File.createTempFile("tmp", null); + //将ftp文件的输入流复制给临时文件 + FileUtils.copyInputStreamToFile(inputStream, file); + List readLines = FileUtils.readLines(file, "UTF-8"); + List vData = ReadLcScacInfo(readLines); + phd.setVScac(vData); } } catch (IOException e) { throw new RuntimeException(e); } finally { try { - ftpClient.disconnect(); + if (Objects.nonNull(ftpClient)) { + ftpClient.disconnect(); + } + if (Objects.nonNull(inputStream)) { + inputStream.close(); + } } catch (IOException e) { throw new RuntimeException(e); } @@ -361,6 +356,7 @@ public class GammaFileUtil { if (Objects.isNull(ftpClient)){ String warning = "ftp连接失败"; } + InputStream inputStream = null; try { //切换被动模式 ftpClient.enterLocalPassiveMode(); @@ -369,27 +365,27 @@ public class GammaFileUtil { ftpClient.setControlEncoding("UTF-8"); ftpClient.setFileTransferMode(FTPClient.STREAM_TRANSFER_MODE); ftpClient.changeWorkingDirectory(pathName); - List ftpFiles = Arrays.asList(ftpClient.listFiles()); String baselineFileName = "RNAUTO_"+subFileName + ".baseline"; - List baselineFiles = ftpFiles.stream().filter(item -> item.getName().equals(baselineFileName)).collect(Collectors.toList()); - if (CollectionUtils.isNotEmpty(baselineFiles)){ - FTPFile baselineFile = baselineFiles.get(0); - if (Objects.nonNull(baselineFile)){ - InputStream inputStream = ftpClient.retrieveFileStream(baselineFile.getName()); - //声明一个临时文件 - File file = File.createTempFile("tmp", null); - //将ftp文件的输入流复制给临时文件 - FileUtils.copyInputStreamToFile(inputStream, file); - List readLines = FileUtils.readLines(file, "UTF-8"); - ReadBaseCtrlInfo(phd,readLines); - phd.setVBase(phd.getBaseCtrls().getBaseline()); - } + inputStream = ftpClient.retrieveFileStream(baselineFileName); + if (Objects.nonNull(inputStream)){ + //声明一个临时文件 + File file = File.createTempFile("tmp", null); + //将ftp文件的输入流复制给临时文件 + FileUtils.copyInputStreamToFile(inputStream, file); + List readLines = FileUtils.readLines(file, "UTF-8"); + ReadBaseCtrlInfo(phd,readLines); + phd.setVBase(phd.getBaseCtrls().getBaseline()); } } catch (IOException e) { throw new RuntimeException(e); } finally { try { - ftpClient.disconnect(); + if (Objects.nonNull(ftpClient)) { + ftpClient.disconnect(); + } + if (Objects.nonNull(inputStream)) { + inputStream.close(); + } } catch (IOException e) { throw new RuntimeException(e); } @@ -397,7 +393,7 @@ public class GammaFileUtil { } } - public List ReadLcScacInfo(List readLines){ + public List ReadLcScacInfo(List readLines) { List vData = new LinkedList<>(); for (int i=0; i< readLines.size(); i++){ String line = readLines.get(i); @@ -432,7 +428,7 @@ public class GammaFileUtil { return vData; } - public void ReadBaseCtrlInfo(PHDFile phd, List readLines){ + public void ReadBaseCtrlInfo(PHDFile phd, List readLines) { for (int i=0; i< readLines.size(); i++){ String line = readLines.get(i); if (line.contains("#")){ @@ -486,7 +482,7 @@ public class GammaFileUtil { } } - public boolean getResultFromDB(String dbName, Integer sampleId, PHDFile phd, Result result){ + public boolean getResultFromDB(String dbName, String userName, Integer sampleId, PHDFile phd, Result result) { //判断连接的数据库 String T_analy, T_calib, T_peaks, T_param, T_nuc_line, T_nuc_act, T_qc, T_setting; if (dbName.equals("auto")){ @@ -497,6 +493,7 @@ public class GammaFileUtil { T_nuc_line = "RNAUTO.GARDS_NUCL_LINES_IDED"; T_nuc_act = "RNAUTO.GARDS_NUCL_IDED"; T_qc = "RNAUTO.GARDS_QC_CHECK"; + userName = "RNAUTO"; }else { T_analy = "RNMAN.GARDS_ANALYSES"; T_calib = "RNMAN.GARDS_CALIBRATION_PAIRS"; @@ -519,7 +516,7 @@ public class GammaFileUtil { } // 获取 ananlysis_id、BaseLine、Lc、Scac、峰数量、Category、谱注释等信息 - GardsAnalysesSpectrum analysis = spectrumAnalysisMapper.getAnalysis(T_analy, sampleId); + GardsAnalysesSpectrum analysis = spectrumAnalysisMapper.getAnalysis(T_analy, sampleId, userName); int peakNum = 0; if (Objects.nonNull(analysis)){ phd.setId_analysis(analysis.getIdAnalysis().toString()); @@ -780,7 +777,7 @@ public class GammaFileUtil { return true; } - public List Qcstate(PHDFile phd){ + public List Qcstate(PHDFile phd) { // Collection Time、 Acq Time、 Decay Time、 SampVol、 Be7-FWHM、 Ba140-MDC、 Xe133-MDC List qcState = new LinkedList<>(); for (int i=0;i<7; i++){ @@ -809,7 +806,7 @@ public class GammaFileUtil { return qcState; } - public void RunQC(PHDFile phd){ + public void RunQC(PHDFile phd) { System.loadLibrary("GammaAnaly"); try { Date start = DateUtils.parseDate(phd.getCollect().getCollection_start_date() + StringPool.SPACE + phd.getCollect().getCollection_start_time()); @@ -911,7 +908,7 @@ public class GammaFileUtil { } } - public Double CalculateMDC(PHDFile phd, List vMdcInfo, Double CCF){ + public Double CalculateMDC(PHDFile phd, List vMdcInfo, Double CCF) { try { System.loadLibrary("GammaAnaly"); if(vMdcInfo.size() < 3 || vMdcInfo.get(2) == 0) { @@ -988,7 +985,7 @@ public class GammaFileUtil { } } - public boolean ReadQCLimit(Map qcItems, Map vMdcInfoMap, Double ener_Be7, String systemType){ + public boolean ReadQCLimit(Map qcItems, Map vMdcInfoMap, Double ener_Be7, String systemType) { try { String filePath = parameterFilePath+ File.separator +"SystemManager.xml"; //创建一个文档解析器工厂 @@ -1175,7 +1172,7 @@ public class GammaFileUtil { } } - public void UpdateChart(PHDFile phd, Map map, Map colorMap){ + public void UpdateChart(PHDFile phd, Map map, Map colorMap) { List m_vCount = new LinkedList<>(); long m_nCount = phd.getSpec().getNum_g_channel(); long m_nSChan = phd.getSpec().getBegin_channel(); @@ -1203,7 +1200,7 @@ public class GammaFileUtil { map.put("shapeChannelData", shapeChannelData); } - public ChartData Energy_Count(PHDFile phd, List m_vCount, long m_nCount, String color){ + public ChartData Energy_Count(PHDFile phd, List m_vCount, long m_nCount, String color) { int start = 0; long end = -1; //Energy @@ -1228,7 +1225,7 @@ public class GammaFileUtil { return data1; } - public ChartData Channel_Count(List m_vCount, long m_nCount, String color){ + public ChartData Channel_Count(List m_vCount, long m_nCount, String color) { int start = 1; long end = -1; ChartData data1 = new ChartData(); @@ -1252,7 +1249,7 @@ public class GammaFileUtil { return data1; } - public List Lc_Scac_base(boolean showLc, PHDFile phd, long m_nCount, Map colorMap){ + public List Lc_Scac_base(boolean showLc, PHDFile phd, long m_nCount, Map colorMap) { List datalist = new LinkedList<>(); int start = 0; long end = -1; @@ -1342,15 +1339,15 @@ public class GammaFileUtil { return datalist; } - public List Channel_Peak(PHDFile phd, long m_nCount, String color){ + public List Channel_Peak(PHDFile phd, long m_nCount, String color) { return PeakSet(phd.getVPeak(), phd.getVBase(), color, m_nCount, null, false); } - public List Energy_Peak(PHDFile phd, long m_nCount, String color){ + public List Energy_Peak(PHDFile phd, long m_nCount, String color) { return PeakSet(phd.getVPeak(), phd.getVBase(), color, m_nCount, phd.getUsedEnerPara().getP(), true); } - public List PeakSet(List vPeak, List vBase, String color, long m_nCount, List p, boolean bEnergy){ + public List PeakSet(List vPeak, List vBase, String color, long m_nCount, List p, boolean bEnergy) { System.loadLibrary("GammaAnaly"); List datalist = new LinkedList<>(); int peakNum = vPeak.size(); @@ -1428,7 +1425,7 @@ public class GammaFileUtil { return datalist; } - public List Energy_BaseCP(PHDFile phd){ + public List Energy_BaseCP(PHDFile phd) { System.loadLibrary("GammaAnaly"); List shapes = new LinkedList<>(); CalValuesOut calValuesOut = CalValuesHandler.calFcnEval(phd.getBaseCtrls().getXCtrl(), phd.getUsedEnerPara().getP()); @@ -1447,7 +1444,7 @@ public class GammaFileUtil { return shapes; } - public List Channel_BaseCP(PHDFile phd){ + public List Channel_BaseCP(PHDFile phd) { List shapes = new LinkedList<>(); int num = phd.getBaseCtrls().getXCtrl().size(); if(num == phd.getBaseCtrls().getYCtrl().size()) { @@ -1464,7 +1461,7 @@ public class GammaFileUtil { return shapes; } - public List AllData(boolean showLc, PHDFile phd, List m_vCount, long m_nCount, Map colorMap){ + public List AllData(boolean showLc, PHDFile phd, List m_vCount, long m_nCount, Map colorMap) { List datalist = new LinkedList<>(); datalist.add(Channel_Count(m_vCount, m_nCount, colorMap.get("Color_Spec"))); datalist.add(Energy_Count(phd, m_vCount, m_nCount, colorMap.get("Color_Spec"))); @@ -1474,7 +1471,7 @@ public class GammaFileUtil { return datalist; } - public boolean AnalyseData(PHDFile phd, ConfigureData configureData, List nuclides, boolean bSingle){ + public boolean AnalyseData(PHDFile phd, ConfigureData configureData, List nuclides, boolean bSingle) { //调用方法判断是否修改了参数 if (Objects.nonNull(configureData)){ SpecSetup phdSetting = phd.getSetting(); @@ -1583,7 +1580,7 @@ public class GammaFileUtil { } } - public void NuclidesIdent(PHDFile phd, Map map){ + public void NuclidesIdent(PHDFile phd, Map map) { // 当重新分析时先清除上一次的分析结果 phd.getMapNucActMda().clear(); for(int i=0; i Differance(PHDFile phd, List vecPeak, List m_vCount, long m_nCount){ + public List Differance(PHDFile phd, List vecPeak, List m_vCount, long m_nCount) { System.loadLibrary("GammaAnaly"); List pointlist = new LinkedList<>(); int start =0; @@ -1981,7 +1978,7 @@ public class GammaFileUtil { return pointlist; } - public void ReadData(List m_vEnergy, List m_vNuclide){ + public void ReadData(List m_vEnergy, List m_vNuclide) { try { String filePath = parameterFilePath+File.separator+"Energy_Nuclide.txt"; File file = new File(filePath); @@ -2389,7 +2386,7 @@ public class GammaFileUtil { } } - public boolean GetInterMiddlData(PHDFile phd, String userName, GStoreMiddleProcessData middleData){ + public boolean GetInterMiddlData(PHDFile phd, String userName, GStoreMiddleProcessData middleData) { boolean bRet = true; Map temp = new HashMap<>(); try { @@ -2401,7 +2398,7 @@ public class GammaFileUtil { return bRet; } - public String GetLogContent(GStoreMiddleProcessData middleData){ + public String GetLogContent(GStoreMiddleProcessData middleData) { StringBuffer strBuffer = new StringBuffer(); strBuffer.append("-------------------------- Sample Analyse Beginning at "+DateUtils.formatDate(new Date(), "yyyy-MM-dd HH:mm:ss")+" ---------------------------\n"); strBuffer.append("\n"); @@ -2572,7 +2569,7 @@ public class GammaFileUtil { return strBuffer.toString(); } - public String GetReportContent(GStoreMiddleProcessData middleData){ + public String GetReportContent(GStoreMiddleProcessData middleData) { StringBuffer strBuffer = new StringBuffer(); strBuffer.append("CNL06 GENERATED REPORT\n"); strBuffer.append(middleData.analyses_type+" RADIONUCLIDE REPORT\n"); @@ -2714,11 +2711,12 @@ public class GammaFileUtil { return strBuffer.toString(); } - public List DoubleLimit(List data){ + public List DoubleLimit(List data) { + List rData = new LinkedList<>(); for(int pos=0;pos DoubleLimit_I(List _data) { @@ -2887,13 +2885,13 @@ public class GammaFileUtil { for(int pos=0;pos dvctIDPEAK = new LinkedList<>(); + List dvctIDPEAK = new LinkedList<>(); List dvctCENTROIDCHANNEL = new LinkedList<>(); List dvctUNCCENTROIDCHANNEL = new LinkedList<>(); List dvctENERGY = new LinkedList<>(); @@ -3144,7 +3142,7 @@ public class GammaFileUtil { List dvctNuclide_name = new LinkedList<>(); List dvctComments = new LinkedList<>(); for(int m=0; m itor:fileAnlyse.getMapNucActMda().entrySet()) { List svctNUCLIDEFULLNAME = new LinkedList<>(); - List dvctIDPEAK = new LinkedList<>(); + List dvctIDPEAK = new LinkedList<>(); List dvctENERGY = new LinkedList<>(); List dvctUNCENERGY = new LinkedList<>(); List dvctABUNDANCE = new LinkedList<>(); @@ -3242,7 +3240,7 @@ public class GammaFileUtil { first = first InitList(double energy, double tolerance, List nuclides){ + public List InitList(double energy, double tolerance, List nuclides) { if(nuclides.size() < 1){ return new LinkedList<>(); } @@ -3644,7 +3642,7 @@ public class GammaFileUtil { return nuclideList; } - public void InitTable(String name, Map map, PHDFile phd, Map colorMap){ + public void InitTable(String name, Map map, PHDFile phd, Map colorMap) { InitNuclideInfo(name, map); long span = phd.getSpec().getG_energy_span(); List nuclideTableList = spectrumAnalysisMapper.getNuclideTable(name, span); @@ -3654,7 +3652,7 @@ public class GammaFileUtil { } } - public void InitNuclideInfo(String name, Map map){ + public void InitNuclideInfo(String name, Map map) { map.put("name", name); GardsNuclLib nuclideInfo = spectrumAnalysisMapper.getNuclideInfo(name); @@ -3686,7 +3684,7 @@ public class GammaFileUtil { } } - public void InitChart(List nuclideTableList, PHDFile phd, Map map, Map colorMap){ + public void InitChart(List nuclideTableList, PHDFile phd, Map map, Map colorMap) { List> chartList = new LinkedList<>(); for (int i=0; i < nuclideTableList.size(); i++){ Map chartMap = new HashMap<>(); @@ -3788,7 +3786,7 @@ public class GammaFileUtil { return channel; } - public void InitPara(PHDFile phd){ + public void InitPara(PHDFile phd) { List Acal_tail_para = new LinkedList<>(); Acal_tail_para.add(99.0); Acal_tail_para.add(0.0); @@ -3863,7 +3861,7 @@ public class GammaFileUtil { return i; } - public List FitPeakBaseLine(PHDFile phd, List vIdx){ + public List FitPeakBaseLine(PHDFile phd, List vIdx) { List tablePeaksList = new LinkedList<>(); int peakNum = vIdx.size(); for (int i=0; i ftpFiles = Arrays.asList(ftpClient.listFiles()); - ftpFiles = ftpFiles.stream().filter(item -> item.getName().equals(compareFileName)).collect(Collectors.toList()); - if (ftpFiles.size() == 0) { - result.error500("ftp获取文件数据失败"); - return m_vecCompare; - } - FTPFile ftpFile = ftpFiles.get(0); - if (Objects.nonNull(ftpFile)) { - inputStream = ftpClient.retrieveFileStream(ftpFile.getName()); + inputStream = ftpClient.retrieveFileStream(compareFileName); + if (Objects.nonNull(inputStream)) { //声明一个临时文件 File file = File.createTempFile("tmp", null); //将ftp文件的输入流复制给临时文件 @@ -4095,7 +4086,7 @@ public class GammaFileUtil { return m_vecCompare; } - public List CompareData(List m_vecCompare, long m_nCount, Map colorMap, List vEnergy){ + public List CompareData(List m_vecCompare, long m_nCount, Map colorMap, List vEnergy) { List datalist = new LinkedList<>(); int size = m_vecCompare.size(); if(size == m_nCount) { diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/common/util/PHDFileUtil.java b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/common/util/PHDFileUtil.java index 83d76c1d..855bfbf3 100644 --- a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/common/util/PHDFileUtil.java +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/common/util/PHDFileUtil.java @@ -278,6 +278,8 @@ public class PHDFileUtil { } public List readLine(String filePath){ + String parameterFilePath = filePath.substring(0, filePath.lastIndexOf(StringPool.SLASH)); + String fileName = filePath.substring(filePath.lastIndexOf(StringPool.SLASH) + 1); //连接ftp FTPClient ftpClient = ftpUtil.LoginFTP(); //判断ftp是否连接成功 @@ -286,32 +288,24 @@ public class PHDFileUtil { } InputStream iStream= null; try { + //被动模式 ftpClient.enterLocalPassiveMode(); - String fileName = filePath.substring(filePath.lastIndexOf(StringPool.SLASH) + 1); - String parameterFilePath = filePath.substring(0, filePath.lastIndexOf(StringPool.SLASH)); - //判断文件路径是否为空 - if (StringUtils.isNotBlank(parameterFilePath)){ - //在当前工作路径下读取文件 - ftpClient.changeWorkingDirectory(parameterFilePath); - ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE); - // 设置编码，当文件中存在中文且上传后文件乱码时可使用此配置项 - ftpClient.setControlEncoding(ftpUtil.getEncoding()); - ftpClient.setFileTransferMode(FTPClient.STREAM_TRANSFER_MODE); - List ftpFiles = Arrays.asList(ftpClient.listFiles()); - if (CollectionUtils.isNotEmpty(ftpFiles)){ - for (FTPFile ftpFile:ftpFiles) { - if (ftpFile.getName().equals(fileName)){ - //读取ftp文件的输入流 - iStream=ftpClient.retrieveFileStream(ftpFile.getName()); - //声明一个临时文件 - File file = File.createTempFile("tmp", null); - //将ftp文件的输入流复制给临时文件 - FileUtils.copyInputStreamToFile(iStream, file); - List allLines = FileUtils.readLines(file, ftpUtil.getEncoding()); - return allLines; - } - } - } + //设置文件类型--二进制文件 + ftpClient.setFileType(FTP.BINARY_FILE_TYPE); + // + ftpClient.setControlEncoding("UTF-8"); + ftpClient.setFileTransferMode(FTPClient.STREAM_TRANSFER_MODE); + //在当前工作路径下读取文件 + ftpClient.changeWorkingDirectory(parameterFilePath); + //读取ftp文件的输入流 + iStream=ftpClient.retrieveFileStream(fileName); + if (Objects.nonNull(iStream)) { + //声明一个临时文件 + File file = File.createTempFile("tmp", null); + //将ftp文件的输入流复制给临时文件 + FileUtils.copyInputStreamToFile(iStream, file); + List allLines = FileUtils.readLines(file, ftpUtil.getEncoding()); + return allLines; } } catch (IOException e) { throw new RuntimeException(e); @@ -488,38 +482,31 @@ public class PHDFileUtil { ftpClient.setFileTransferMode(FTPClient.STREAM_TRANSFER_MODE); //切换工作路径 ftpClient.changeWorkingDirectory(filePath); - //获取路径下所有的ftp文件信息 - List ftpFiles = Arrays.asList(ftpClient.listFiles()); - if (CollectionUtils.isNotEmpty(ftpFiles)) { - //获取sampleFileName - ftpFiles = ftpFiles.stream().filter(item -> item.getName().equals(sampleFileName)).collect(Collectors.toList()); - if (CollectionUtils.isNotEmpty(ftpFiles)) { - FTPFile sampleFile = ftpFiles.get(0); - //解析sampleFile - inputStream = ftpClient.retrieveFileStream(sampleFile.getName()); - //声明一个临时文件 - File file = File.createTempFile("tmp", null); - //将ftp文件的输入流复制给临时文件 - FileUtils.copyInputStreamToFile(inputStream, file); - //加载sampleFile内容 - EnergySpectrumStruct struct = EnergySpectrumHandler.getSourceData(file.getAbsolutePath()); - //获取所需要的数据 - String dataType = struct.data_type; - String systemType = struct.system_type; - String spectrumQuantity = struct.spectrum_quantity; - double acquisitionLiveTime = struct.acquisition_live_time; - String measurementId = struct.measurement_id; - String gasBkMeasurementId = struct.gas_bk_measurement_id; - String detectorBkMeasurementId = struct.detector_bk_measurement_id; - //格式化文件名称 - String fileSuffix = nameStandUtil.GetSuffix(dataType, systemType, spectrumQuantity, String.valueOf(acquisitionLiveTime)); - String measurementName = nameStandUtil.GetFileNameFromDateTime(measurementId, fileSuffix); - String gasFileName = nameStandUtil.GetFileNameFromDateTime(gasBkMeasurementId, "_G.PHD"); - String detaFileName = nameStandUtil.GetFileNameFromDateTime(detectorBkMeasurementId, "_D.PHD"); - map.put("gasFileName", gasFileName); - map.put("detaFileName", detaFileName); - map.put("sampleSystemType", systemType); - } + //解析sampleFile + inputStream = ftpClient.retrieveFileStream(sampleFileName); + if (Objects.nonNull(inputStream)) { + //声明一个临时文件 + File file = File.createTempFile("tmp", null); + //将ftp文件的输入流复制给临时文件 + FileUtils.copyInputStreamToFile(inputStream, file); + //加载sampleFile内容 + EnergySpectrumStruct struct = EnergySpectrumHandler.getSourceData(file.getAbsolutePath()); + //获取所需要的数据 + String dataType = struct.data_type; + String systemType = struct.system_type; + String spectrumQuantity = struct.spectrum_quantity; + double acquisitionLiveTime = struct.acquisition_live_time; + String measurementId = struct.measurement_id; + String gasBkMeasurementId = struct.gas_bk_measurement_id; + String detectorBkMeasurementId = struct.detector_bk_measurement_id; + //格式化文件名称 + String fileSuffix = nameStandUtil.GetSuffix(dataType, systemType, spectrumQuantity, String.valueOf(acquisitionLiveTime)); + String measurementName = nameStandUtil.GetFileNameFromDateTime(measurementId, fileSuffix); + String gasFileName = nameStandUtil.GetFileNameFromDateTime(gasBkMeasurementId, "_G.PHD"); + String detaFileName = nameStandUtil.GetFileNameFromDateTime(detectorBkMeasurementId, "_D.PHD"); + map.put("gasFileName", gasFileName); + map.put("detaFileName", detaFileName); + map.put("sampleSystemType", systemType); } } catch (IOException e) { throw new RuntimeException(e); @@ -554,18 +541,11 @@ public class PHDFileUtil { ftpClient.setFileTransferMode(FTPClient.STREAM_TRANSFER_MODE); //切换文件路径 ftpClient.changeWorkingDirectory(filePath); - //获取路径下所有文件信息 - List ftpFiles = Arrays.asList(ftpClient.listFiles()); - if (CollectionUtils.isNotEmpty(ftpFiles)){ - //根据文件名称 分别获取 sample gas det文件 - List files = ftpFiles.stream().filter(item -> item.getName().equals(fileName)).collect(Collectors.toList()); - if (CollectionUtils.isNotEmpty(files)){ - FTPFile ftpFile = files.get(0); - inputStream = ftpClient.retrieveFileStream(ftpFile.getName()); - file = File.createTempFile("tmp", null); - //将ftp文件的输入流复制给临时文件 - FileUtils.copyInputStreamToFile(inputStream, file); - } + inputStream = ftpClient.retrieveFileStream(fileName); + if (Objects.nonNull(inputStream)){ + file = File.createTempFile("tmp", null); + //将ftp文件的输入流复制给临时文件 + FileUtils.copyInputStreamToFile(inputStream, file); } } catch (IOException e) { throw new RuntimeException(e); @@ -631,18 +611,11 @@ public class PHDFileUtil { ftpClient.setFileTransferMode(FTPClient.STREAM_TRANSFER_MODE); //切换文件路径 ftpClient.changeWorkingDirectory(filePath); - //获取路径下所有文件信息 - List ftpFiles = Arrays.asList(ftpClient.listFiles()); - if (CollectionUtils.isNotEmpty(ftpFiles)){ - //根据文件名称 分别获取 sample gas det文件 - List files = ftpFiles.stream().filter(item -> item.getName().equals(fileName)).collect(Collectors.toList()); - if (CollectionUtils.isNotEmpty(files)){ - FTPFile ftpFile = files.get(0); - inputStream = ftpClient.retrieveFileStream(ftpFile.getName()); - file = File.createTempFile("tmp", null); - //将ftp文件的输入流复制给临时文件 - FileUtils.copyInputStreamToFile(inputStream, file); - } + inputStream = ftpClient.retrieveFileStream(fileName); + if (Objects.nonNull(inputStream)){ + file = File.createTempFile("tmp", null); + //将ftp文件的输入流复制给临时文件 + FileUtils.copyInputStreamToFile(inputStream, file); } } catch (IOException e) { throw new RuntimeException(e); @@ -763,18 +736,11 @@ public class PHDFileUtil { ftpClient.setFileTransferMode(FTPClient.STREAM_TRANSFER_MODE); //切换文件路径 ftpClient.changeWorkingDirectory(path); - //获取路径下所有文件信息 - List ftpFiles = Arrays.asList(ftpClient.listFiles()); - if (CollectionUtils.isNotEmpty(ftpFiles)){ - //根据文件名称 分别获取 sample gas det文件 - List files = ftpFiles.stream().filter(item -> item.getName().equals(fileName)).collect(Collectors.toList()); - if (CollectionUtils.isNotEmpty(files)){ - FTPFile ftpFile = files.get(0); - inputStream = ftpClient.retrieveFileStream(ftpFile.getName()); - file = File.createTempFile("tmp", null); - //将ftp文件的输入流复制给临时文件 - FileUtils.copyInputStreamToFile(inputStream, file); - } + inputStream = ftpClient.retrieveFileStream(fileName); + if (Objects.nonNull(inputStream)){ + file = File.createTempFile("tmp", null); + //将ftp文件的输入流复制给临时文件 + FileUtils.copyInputStreamToFile(inputStream, file); } } catch (IOException e) { throw new RuntimeException(e); @@ -837,18 +803,13 @@ public class PHDFileUtil { ftpClient.setControlEncoding("UTF-8"); ftpClient.setFileTransferMode(FTPClient.STREAM_TRANSFER_MODE); ftpClient.changeWorkingDirectory(filePath); - List ftpFiles = Arrays.asList(ftpClient.listFiles()); - ftpFiles = ftpFiles.stream().filter(item -> item.getName().equals(fileName)).collect(Collectors.toList()); - if (CollectionUtils.isNotEmpty(ftpFiles)){ - FTPFile ftpFile = ftpFiles.get(0); - if (Objects.nonNull(ftpFile)){ - inputStream = ftpClient.retrieveFileStream(ftpFile.getName()); - //声明一个临时文件 - File file = File.createTempFile("tmp", null); - //将ftp文件的输入流复制给临时文件 - FileUtils.copyInputStreamToFile(inputStream, file); - struct = EnergySpectrumHandler.getSourceData(file.getAbsolutePath()); - } + inputStream = ftpClient.retrieveFileStream(fileName); + if (Objects.nonNull(inputStream)){ + //声明一个临时文件 + File file = File.createTempFile("tmp", null); + //将ftp文件的输入流复制给临时文件 + FileUtils.copyInputStreamToFile(inputStream, file); + struct = EnergySpectrumHandler.getSourceData(file.getAbsolutePath()); } } catch (IOException e) { throw new RuntimeException(e); diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/controller/GammaController.java b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/controller/GammaController.java index 3e597dba..62039957 100644 --- a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/controller/GammaController.java +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/controller/GammaController.java @@ -24,8 +24,8 @@ public class GammaController { @GetMapping("initValue") @ApiOperation(value = "初始化gamma数据", notes = "初始化gamma数据") - public Result initValue(Integer sampleId, String dbName) { - return gammaService.initValue(sampleId, dbName); + public Result initValue(Integer sampleId, String dbName, HttpServletRequest request) { + return gammaService.initValue(sampleId, dbName, request); } @GetMapping("gammaByDB") diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/entity/vo/BgDataAnlyseResultIn.java b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/entity/vo/BgDataAnlyseResultIn.java index c6dc88c1..df0bfa60 100644 --- a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/entity/vo/BgDataAnlyseResultIn.java +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/entity/vo/BgDataAnlyseResultIn.java @@ -231,8 +231,32 @@ public class BgDataAnlyseResultIn implements Serializable { List gammaCalibrationSpectrumList; + GardsCalibrationSpectrum gammaCalibrationSCE; + + GardsCalibrationSpectrum gammaCalibrationSEC; + + GardsCalibrationSpectrum gammaCalibrationGCE; + + GardsCalibrationSpectrum gammaCalibrationGEC; + + GardsCalibrationSpectrum gammaCalibrationDCE; + + GardsCalibrationSpectrum gammaCalibrationDEC; + List betaCalibrationSpectrumList; + GardsCalibrationSpectrum betaCalibrationSCE; + + GardsCalibrationSpectrum betaCalibrationSEC; + + GardsCalibrationSpectrum betaCalibrationGCE; + + GardsCalibrationSpectrum betaCalibrationGEC; + + GardsCalibrationSpectrum betaCalibrationDCE; + + GardsCalibrationSpectrum betaCalibrationDEC; + List roiChannelsSpectrumList; List roiResultsSpectrumList; diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/mapper/GardsAnalysesManMapper.java b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/mapper/GardsAnalysesManMapper.java index d8d6de03..d85ce577 100644 --- a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/mapper/GardsAnalysesManMapper.java +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/mapper/GardsAnalysesManMapper.java @@ -1,11 +1,12 @@ package org.jeecg.modules.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.apache.ibatis.annotations.Param; import org.jeecg.modules.base.entity.rnman.GardsAnalyses; import org.jeecg.modules.entity.GardsAnalysesSpectrum; public interface GardsAnalysesManMapper extends BaseMapper { - void updateEntity(GardsAnalysesSpectrum analyses); + void updateEntity(@Param(value = "analyses") GardsAnalysesSpectrum analyses); } diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/mapper/GardsCalibrationSpectrumMapper.java b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/mapper/GardsCalibrationSpectrumMapper.java index 3fbdc68b..3f24e6f8 100644 --- a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/mapper/GardsCalibrationSpectrumMapper.java +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/mapper/GardsCalibrationSpectrumMapper.java @@ -1,7 +1,13 @@ package org.jeecg.modules.mapper; +import com.baomidou.mybatisplus.annotation.InterceptorIgnore; import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.apache.ibatis.annotations.Param; import org.jeecg.modules.base.entity.rnman.GardsCalibration; public interface GardsCalibrationSpectrumMapper extends BaseMapper { + + @InterceptorIgnore(tenantLine = "true") + void insertCalibrationGamma(@Param(value = "calibration") GardsCalibration calibration); + } diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/mapper/xml/GardsAnalysesManMapper.xml b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/mapper/xml/GardsAnalysesManMapper.xml index 836abe6a..823aff17 100644 --- a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/mapper/xml/GardsAnalysesManMapper.xml +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/mapper/xml/GardsAnalysesManMapper.xml @@ -5,8 +5,8 @@ UPDATE RNMAN.GARDS_ANALYSES - SET ANALYSISBEGIN = to_date(#{analyses.analysisBeginStr},'yyyy/MM/dd HH:mm:ss'), - ANALYSISEND = to_date(#{analyses.analysisEndStr},'yyyy/MM/dd HH:mm:ss'), + SET ANALYSISBEGIN = to_date(#{analyses.analysisBeginStr},'yyyy/MM/dd HH:mi:ss'), + ANALYSISEND = to_date(#{analyses.analysisEndStr},'yyyy/MM/dd HH:mi:ss'), SOFTWARE = #{analyses.software}, SWVERSION = #{analyses.swVersion}, COMMENTS = #{analyses.comments}, diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/mapper/xml/GardsCalibrationSpectrumMapper.xml b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/mapper/xml/GardsCalibrationSpectrumMapper.xml new file mode 100644 index 00000000..5f18eb40 --- /dev/null +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/mapper/xml/GardsCalibrationSpectrumMapper.xml @@ -0,0 +1,29 @@ + + + + + + INSERT INTO + RNMAN.GARDS_CALIBRATION( + SAMPLE_ID, + IDANALYSIS, + SAMPLE_TYPE, + CALTYPE, + FUNCTION, + FUNCTIONDEF, + STARTOFRANGE, + ENDOFRANGE, + COEFF_STRING) + VALUES(#{calibration.sampleId}, + #{calibration.idAnalysis}, + #{calibration.sampleType}, + #{calibration.calType}, + #{calibration.function}, + #{calibration.functionDef}, + #{calibration.startOfRange}, + #{calibration.endOfRange}, + #{calibration.coeffString}) + + + + \ No newline at end of file diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGammaService.java b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGammaService.java index 75dbd89a..5423acf1 100644 --- a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGammaService.java +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGammaService.java @@ -11,7 +11,7 @@ import java.util.List; public interface IGammaService{ - Result initValue(Integer sampleId, String dbName); + Result initValue(Integer sampleId, String dbName, HttpServletRequest request); Result gammaByDB(String dbName, Integer sampleId, HttpServletRequest request); diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsAnalySettingSpectrumService.java b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsAnalySettingSpectrumService.java index 4a2c1212..1baeceb4 100644 --- a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsAnalySettingSpectrumService.java +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsAnalySettingSpectrumService.java @@ -6,6 +6,6 @@ import org.jeecg.modules.entity.vo.PHDFile; public interface IGardsAnalySettingSpectrumService extends IService { - boolean saveAnalySettingGamma(PHDFile phd, String idAnalysis); + int saveAnalySettingGamma(PHDFile phd, String idAnalysis); } diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsCalibrationPairsSpectrumService.java b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsCalibrationPairsSpectrumService.java index c6aad278..508e5d9b 100644 --- a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsCalibrationPairsSpectrumService.java +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsCalibrationPairsSpectrumService.java @@ -11,6 +11,6 @@ public interface IGardsCalibrationPairsSpectrumService extends IService calibrationPairsList); - boolean saveGardsCalibrationPairsGamma(GStoreMiddleProcessData middleData, Integer sampleId, String idAnalysis); + int saveGardsCalibrationPairsGamma(GStoreMiddleProcessData middleData, Integer sampleId, String idAnalysis); } diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsCalibrationSpectrumService.java b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsCalibrationSpectrumService.java index 5ee16735..c76067b0 100644 --- a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsCalibrationSpectrumService.java +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsCalibrationSpectrumService.java @@ -10,6 +10,6 @@ public interface IGardsCalibrationSpectrumService extends IService calibrationPairsList); - boolean saveCalibrationGamma(GStoreMiddleProcessData middleData, Integer sampleId, String idAnalysis); + int saveCalibrationGamma(GStoreMiddleProcessData middleData, Integer sampleId, String idAnalysis); } diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsNuclIdedSpectrumService.java b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsNuclIdedSpectrumService.java index be379230..fe63c6ef 100644 --- a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsNuclIdedSpectrumService.java +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsNuclIdedSpectrumService.java @@ -7,6 +7,6 @@ import org.jeecg.modules.entity.vo.GStoreMiddleProcessData; public interface IGardsNuclIdedSpectrumService extends IService { - boolean saveNuclIdedGamma(GStoreMiddleProcessData middleData, Integer sampleId, String idAnalysis); + int saveNuclIdedGamma(GStoreMiddleProcessData middleData, Integer sampleId, String idAnalysis); } diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsNuclLinesIdedSpectrumService.java b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsNuclLinesIdedSpectrumService.java index d932c5b9..e725e91b 100644 --- a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsNuclLinesIdedSpectrumService.java +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsNuclLinesIdedSpectrumService.java @@ -6,6 +6,6 @@ import org.jeecg.modules.entity.vo.GStoreMiddleProcessData; public interface IGardsNuclLinesIdedSpectrumService extends IService { - boolean saveNuclLinesIdedGamma(GStoreMiddleProcessData middleData, Integer sampleId, String idAnalysis); + int saveNuclLinesIdedGamma(GStoreMiddleProcessData middleData, Integer sampleId, String idAnalysis); } diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsPeaksSpectrumService.java b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsPeaksSpectrumService.java index 340297b8..682236a6 100644 --- a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsPeaksSpectrumService.java +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsPeaksSpectrumService.java @@ -6,6 +6,6 @@ import org.jeecg.modules.entity.vo.GStoreMiddleProcessData; public interface IGardsPeaksSpectrumService extends IService { - boolean savePeaksGamma(GStoreMiddleProcessData middleData, Integer sampleId, String idAnalysis); + int savePeaksGamma(GStoreMiddleProcessData middleData, Integer sampleId, String idAnalysis); } diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsQcCheckSpectrumService.java b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsQcCheckSpectrumService.java index 133539d9..04ef9e08 100644 --- a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsQcCheckSpectrumService.java +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/IGardsQcCheckSpectrumService.java @@ -7,6 +7,6 @@ import org.jeecg.modules.entity.vo.PHDFile; public interface IGardsQcCheckSpectrumService extends IService { - boolean saveQcCheckGamma(GStoreMiddleProcessData middleData, PHDFile phd, String idAnalysis); + int saveQcCheckGamma(GStoreMiddleProcessData middleData, PHDFile phd, String idAnalysis); } diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/ISpectrumAnalysisService.java b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/ISpectrumAnalysisService.java index 6789b42e..b6391040 100644 --- a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/ISpectrumAnalysisService.java +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/ISpectrumAnalysisService.java @@ -18,11 +18,9 @@ public interface ISpectrumAnalysisService { Result getDBSpectrumList(QueryRequest queryRequest, GardsSampleDataSpectrum gardsSampleData, String dbName, String[] menuTypes, boolean AllUsers, boolean CollectStopB, boolean AcqStartB, Date startDate, Date endDate, HttpServletRequest request); - Result getSpectrumFiles(HttpServletRequest request); - Result getFilesBySampleFile(String fileName, HttpServletRequest request); - Result getDBSpectrumChart(String dbName, Integer sampleId); + Result getDBSpectrumChart(String dbName, Integer sampleId, HttpServletRequest request); Result getFileSpectrumChart(String sampleFileName, String gasFileName, String detFileName, String qcFileName, HttpServletRequest request); 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 6ce6916d..70d242f7 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 @@ -15,7 +15,6 @@ import org.apache.commons.io.FileUtils; import org.apache.commons.lang3.StringUtils; import com.google.common.cache.Cache; import org.apache.commons.net.ftp.FTPClient; -import org.apache.commons.net.ftp.FTPFile; import org.jeecg.common.api.vo.Result; import org.jeecg.common.cache.LocalCache; import org.jeecg.common.constant.DateConstant; @@ -30,7 +29,6 @@ import org.jeecg.modules.entity.vo.*; import org.jeecg.modules.entity.*; import org.jeecg.modules.mapper.SpectrumAnalysisMapper; import org.jeecg.modules.native_jni.CalValuesHandler; -import org.jeecg.modules.native_jni.struct.CalValuesOut; import org.jeecg.modules.service.*; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; @@ -77,8 +75,6 @@ public class GammaServiceImpl implements IGammaService { private SpectrumPathProperties spectrumPathProperties; @Autowired private FTPUtil ftpUtil; - @Autowired - private SSEUtil sseUtil; @Value("${ZeroTime}") private String ZeroTimeStr; @Autowired @@ -115,8 +111,9 @@ public class GammaServiceImpl implements IGammaService { private IGardsAnalySettingSpectrumService analySettingSpectrumService; @Override - public Result initValue(Integer sampleId, String dbName) { + public Result initValue(Integer sampleId, String dbName, HttpServletRequest request) { Result result = new Result(); + String userName = JwtUtil.getUserNameByToken(request); Cache phdCache = localCache.getPHDCache(); PHDFile phd = new PHDFile(); //读取文件内容 @@ -135,7 +132,7 @@ public class GammaServiceImpl implements IGammaService { //声明基础数组信息 gammaFileUtil.SetBaseInfo(phd); //从数据库中读取相关信息 - boolean bRet = gammaFileUtil.getResultFromDB(dbName, sampleId, phd, result); + boolean bRet = gammaFileUtil.getResultFromDB(dbName, userName, sampleId, phd, result); if (!bRet){ return result; } @@ -169,7 +166,7 @@ public class GammaServiceImpl implements IGammaService { //声明基础数组信息 gammaFileUtil.SetBaseInfo(phd); //从数据库中读取相关信息 - boolean bRet = gammaFileUtil.getResultFromDB(dbName, sampleId, phd, result); + boolean bRet = gammaFileUtil.getResultFromDB(dbName, userName, sampleId, phd, result); if (!bRet){ return result; } @@ -205,7 +202,10 @@ public class GammaServiceImpl implements IGammaService { String path = StringPool.SLASH + spectrumPathProperties.getUploadPath() + StringPool.SLASH + userName; PHDFile phd = new PHDFile(); //加载文件内容 - gammaFileUtil.loadFile(path, fileName, phd, result); + boolean bRet = gammaFileUtil.loadFile(path, fileName, phd, result); + if (!bRet) { + return result; + } //获取当前角色的颜色配置 Map colorMap = sysUserColorService.initColor(userName); // 更新 ‘QC Flags’ 状态 @@ -2113,7 +2113,7 @@ public class GammaServiceImpl implements IGammaService { if(StringUtils.isBlank(reportPath.trim())) { String waring = "The file isn't existed."; } - String pathName = reportPath.substring(0, reportPath.lastIndexOf(StringPool.SLASH)); + String pathName = StringPool.SLASH + spectrumPathProperties.getRootPath() + StringPool.SLASH + reportPath.substring(0, reportPath.lastIndexOf(StringPool.SLASH)); String fileName = reportPath.substring(reportPath.lastIndexOf(StringPool.SLASH)+1)+".txt"; //连接ftp FTPClient ftpClient = ftpUtil.LoginFTP(); @@ -2129,16 +2129,9 @@ public class GammaServiceImpl implements IGammaService { // 设置编码，当文件中存在中文且上传后文件乱码时可使用此配置项 ftpClient.setControlEncoding("UTF-8"); ftpClient.setFileTransferMode(FTPClient.STREAM_TRANSFER_MODE); - pathName=StringPool.SLASH + spectrumPathProperties.getRootPath() + StringPool.SLASH + pathName; ftpClient.changeWorkingDirectory(pathName); - List ftpFiles = Arrays.asList(ftpClient.listFiles()); - ftpFiles=ftpFiles.stream().filter(item -> item.getName().equals(fileName)).collect(Collectors.toList()); - if (CollectionUtils.isEmpty(ftpFiles)){ - throw new RuntimeException("ftp下对应的报告文件不存在"); - } - FTPFile ftpFile = ftpFiles.get(0); - if (Objects.nonNull(ftpFile)){ - inputStream = ftpClient.retrieveFileStream(ftpFile.getName()); + inputStream = ftpClient.retrieveFileStream(fileName); + if (Objects.nonNull(inputStream)){ outputStream = response.getOutputStream(); byte[] buffer = new byte[1024]; int bytesRead; @@ -2176,7 +2169,7 @@ public class GammaServiceImpl implements IGammaService { if(StringUtils.isBlank(reportPath.trim())) { String waring = "The file isn't existed."; } - String pathName = reportPath.substring(0, reportPath.lastIndexOf(StringPool.SLASH)); + String pathName = StringPool.SLASH + spectrumPathProperties.getRootPath() + StringPool.SLASH + reportPath.substring(0, reportPath.lastIndexOf(StringPool.SLASH)); String fileName = reportPath.substring(reportPath.lastIndexOf(StringPool.SLASH)+1)+".txt"; //连接ftp FTPClient ftpClient = ftpUtil.LoginFTP(); @@ -2192,16 +2185,9 @@ public class GammaServiceImpl implements IGammaService { // 设置编码，当文件中存在中文且上传后文件乱码时可使用此配置项 ftpClient.setControlEncoding("UTF-8"); ftpClient.setFileTransferMode(FTPClient.STREAM_TRANSFER_MODE); - pathName=StringPool.SLASH + spectrumPathProperties.getRootPath() + StringPool.SLASH + pathName; ftpClient.changeWorkingDirectory(pathName); - List ftpFiles = Arrays.asList(ftpClient.listFiles()); - ftpFiles=ftpFiles.stream().filter(item -> item.getName().equals(fileName)).collect(Collectors.toList()); - if (CollectionUtils.isEmpty(ftpFiles)){ - throw new RuntimeException("ftp下对应的报告文件不存在"); - } - FTPFile ftpFile = ftpFiles.get(0); - if (Objects.nonNull(ftpFile)){ - inputStream = ftpClient.retrieveFileStream(ftpFile.getName()); + inputStream = ftpClient.retrieveFileStream(fileName); + if (Objects.nonNull(inputStream)){ //设置响应类型 response.setContentType("application/octet-stream"); //解决中文不能生成文件 @@ -2721,7 +2707,7 @@ public class GammaServiceImpl implements IGammaService { if (StringUtils.isBlank(logPath)){ String waring = "The file isn't existed."; } - String pathName = logPath.substring(0, logPath.lastIndexOf(StringPool.SLASH)); + 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(); @@ -2737,16 +2723,9 @@ public class GammaServiceImpl implements IGammaService { // 设置编码，当文件中存在中文且上传后文件乱码时可使用此配置项 ftpClient.setControlEncoding("UTF-8"); ftpClient.setFileTransferMode(FTPClient.STREAM_TRANSFER_MODE); - pathName=StringPool.SLASH + spectrumPathProperties.getLogPath() + StringPool.SLASH + pathName; ftpClient.changeWorkingDirectory(pathName); - List ftpFiles = Arrays.asList(ftpClient.listFiles()); - ftpFiles=ftpFiles.stream().filter(item -> item.getName().equals(fileName)).collect(Collectors.toList()); - if (CollectionUtils.isEmpty(ftpFiles)){ - throw new RuntimeException("ftp下对应的报告文件不存在"); - } - FTPFile ftpFile = ftpFiles.get(0); - if (Objects.nonNull(ftpFile)){ - inputStream = ftpClient.retrieveFileStream(ftpFile.getName()); + inputStream = ftpClient.retrieveFileStream(fileName); + if (Objects.nonNull(inputStream)){ outputStream = response.getOutputStream(); byte[] buffer = new byte[1024]; int bytesRead; @@ -2919,42 +2898,18 @@ public class GammaServiceImpl implements IGammaService { spectrumAnalysisMapper.deleteAnalySetting(Integer.valueOf(idAnalysis)); } // 向 RNMAN.GARDS_CALIBRATION_PAIRS 表写入 Energy 刻度数据对 - bRet = calibrationPairsSpectrumService.saveGardsCalibrationPairsGamma(middleData, Integer.valueOf(phd.getId_sample()), idAnalysis); - if (!bRet) { - result.error500("Save analysis results to DB failed."); - return result; - } - bRet = calibrationSpectrumService.saveCalibrationGamma(middleData, Integer.valueOf(phd.getId_sample()), idAnalysis); - if (!bRet) { - result.error500("Save analysis results to DB failed."); - return result; - } + calibrationPairsSpectrumService.saveGardsCalibrationPairsGamma(middleData, Integer.valueOf(phd.getId_sample()), idAnalysis); + calibrationSpectrumService.saveCalibrationGamma(middleData, Integer.valueOf(phd.getId_sample()), idAnalysis); // 向 RNMAN.GARDS_PEAKS 表写入峰信息 - bRet = peaksSpectrumService.savePeaksGamma(middleData, Integer.valueOf(phd.getId_sample()), idAnalysis); - if (!bRet) { - result.error500("Save analysis results to DB failed."); - return result; - } + peaksSpectrumService.savePeaksGamma(middleData, Integer.valueOf(phd.getId_sample()), idAnalysis); // 向 RNMAN.GARDS_NUCL_LINES_IDED 表写入被识别核素的射线信息 - bRet = nuclLinesIdedSpectrumService.saveNuclLinesIdedGamma(middleData, Integer.valueOf(phd.getId_sample()), idAnalysis); - if (!bRet) { - result.error500("Save analysis results to DB failed."); - return result; - } + nuclLinesIdedSpectrumService.saveNuclLinesIdedGamma(middleData, Integer.valueOf(phd.getId_sample()), idAnalysis); // 向 RNMAN.GARDS_NUCL_IDED 表写入被识别核素的活度浓度信息 - bRet = nuclIdedSpectrumService.saveNuclIdedGamma(middleData, Integer.valueOf(phd.getId_sample()), idAnalysis); - if (!bRet) { - result.error500("Save analysis results to DB failed."); - return result; - } + nuclIdedSpectrumService.saveNuclIdedGamma(middleData, Integer.valueOf(phd.getId_sample()), idAnalysis); // 向 RNMAN.GARDS_QC_CHECK 表写入 QC 检查结果 - bRet = qcCheckSpectrumService.saveQcCheckGamma(middleData, phd, idAnalysis); - if (!bRet) { - result.error500("Save analysis results to DB failed."); - return result; - } + qcCheckSpectrumService.saveQcCheckGamma(middleData, phd, idAnalysis); // 向 RNMAN.GARDS_ANALY_SETTING 表写入 SpecSetup 分析参数设置 - bRet = analySettingSpectrumService.saveAnalySettingGamma(phd, idAnalysis); + analySettingSpectrumService.saveAnalySettingGamma(phd, idAnalysis); if(bRet) { phd.setStatus("R"); List paths=new LinkedList<>(); diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/GardsAnalySettingSpectrumServiceImpl.java b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/GardsAnalySettingSpectrumServiceImpl.java index ed6165ab..97806509 100644 --- a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/GardsAnalySettingSpectrumServiceImpl.java +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/GardsAnalySettingSpectrumServiceImpl.java @@ -15,8 +15,7 @@ public class GardsAnalySettingSpectrumServiceImpl extends ServiceImpl0){ - bRet = true; - } - return bRet; + return insert; } } diff --git a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/GardsCalibrationPairsSpectrumServiceImpl.java b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/GardsCalibrationPairsSpectrumServiceImpl.java index 723d86cd..0f70be56 100644 --- a/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/GardsCalibrationPairsSpectrumServiceImpl.java +++ b/jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/service/impl/GardsCalibrationPairsSpectrumServiceImpl.java @@ -31,8 +31,7 @@ public class GardsCalibrationPairsSpectrumServiceImpl extends ServiceImpl calibrationPairsList = new LinkedList<>(); // 向 RNMAN.GARDS_CALIBRATION_PAIRS 表写入 Energy 刻度数据对 int t_size = middleData.calibration_pairs_E_idCalPoint.size(); @@ -108,8 +107,8 @@ public class GardsCalibrationPairsSpectrumServiceImpl extends ServiceImpl calibrationList = new LinkedList<>(); int t_size = middleData.calibration_pairs_E_idCalPoint.size(); if (t_size>0){ @@ -96,8 +95,10 @@ public class GardsCalibrationSpectrumServiceImpl extends ServiceImpl nuclIdedList = new LinkedList<>(); int t_size = middleData.nucl_ided_Nuclidename.size(); if(t_size > 0){ @@ -51,9 +50,9 @@ public class GardsNuclIdedSpectrumServiceImpl extends ServiceImpl map = middleData.nucl_lines_ided_data; List nuclLinesIdedList = new LinkedList<>(); for(String key: map.keySet()){ @@ -55,7 +54,7 @@ public class GardsNuclLinesIdedSpectrumServiceImpl extends ServiceImpl peaksList = new LinkedList<>(); int t_size = middleData.peaks_idPeak.size(); if(t_size > 0){ @@ -30,13 +30,13 @@ public class GardsPeaksSpectrumServiceImpl extends ServiceImpl 0){ - List qcCheckList = new LinkedList<>(); + List qcCheckList = new LinkedList<>(); + if(t_size > 0) { for (int i=0; i