From 7feca0fdef5b10b8f899464b6473e9240d86cddd Mon Sep 17 00:00:00 2001 From: qiaoqinzheng Date: Thu, 21 Sep 2023 17:20:10 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9beta=E6=A8=A1=E5=9D=97saveToD?= =?UTF-8?q?B=E6=8E=A5=E5=8F=A3=E9=97=AE=E9=A2=98=20=E4=BF=AE=E6=94=B9gamma?= =?UTF-8?q?=E6=A8=A1=E5=9D=97saveToDB=E6=8E=A5=E5=8F=A3=E9=97=AE=E9=A2=98?= =?UTF-8?q?=20=E4=BF=AE=E6=94=B9beta=E6=A8=A1=E5=9D=97saveToTXT,saveToExce?= =?UTF-8?q?l,saveToHtml=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../resources/excelTemplate/SaveExcel.xls | Bin 27136 -> 29696 bytes .../resources/excelTemplate/SaveHtml.html | 24 +- .../main/resources/excelTemplate/SaveTxt.txt | 9 +- .../java/org/jeecg/common/GammaFileUtil.java | 5 +- .../org/jeecg/common/util/GammaFileUtil.java | 221 +++++++++--------- .../org/jeecg/common/util/PHDFileUtil.java | 171 ++++++-------- .../modules/controller/GammaController.java | 4 +- .../entity/vo/BgDataAnlyseResultIn.java | 24 ++ .../mapper/GardsAnalysesManMapper.java | 3 +- .../GardsCalibrationSpectrumMapper.java | 6 + .../mapper/xml/GardsAnalysesManMapper.xml | 4 +- .../xml/GardsCalibrationSpectrumMapper.xml | 29 +++ .../jeecg/modules/service/IGammaService.java | 2 +- .../IGardsAnalySettingSpectrumService.java | 2 +- ...IGardsCalibrationPairsSpectrumService.java | 2 +- .../IGardsCalibrationSpectrumService.java | 2 +- .../IGardsNuclIdedSpectrumService.java | 2 +- .../IGardsNuclLinesIdedSpectrumService.java | 2 +- .../service/IGardsPeaksSpectrumService.java | 2 +- .../service/IGardsQcCheckSpectrumService.java | 2 +- .../service/ISpectrumAnalysisService.java | 4 +- .../service/impl/GammaServiceImpl.java | 93 ++------ .../GardsAnalySettingSpectrumServiceImpl.java | 8 +- ...dsCalibrationPairsSpectrumServiceImpl.java | 7 +- .../GardsCalibrationSpectrumServiceImpl.java | 9 +- .../GardsNuclIdedSpectrumServiceImpl.java | 7 +- ...GardsNuclLinesIdedSpectrumServiceImpl.java | 5 +- .../impl/GardsPeaksSpectrumServiceImpl.java | 10 +- .../impl/GardsQcCheckSpectrumServiceImpl.java | 19 +- .../GardsSampleAuxSpectrumServiceImpl.java | 2 +- .../GardsSampleCertSpectrumServiceImpl.java | 3 +- 31 files changed, 321 insertions(+), 362 deletions(-) create mode 100644 jeecg-module-spectrum-analysis/src/main/java/org/jeecg/modules/mapper/xml/GardsCalibrationSpectrumMapper.xml 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 17c625eebe4aa50c249d17c1627769f8811a99c5..22c3e55673c9db9e4c0cbcc2ddd5535c31977ab9 100644 GIT binary patch delta 4447 zcmbtYUu;uV82`@Q?Vua%wqw#xSXva~aJsDY~57rHO72sk+ii90MJO}A!;IOCVDhCH^-@k#(smJ>U6P5 z`C!FN@_zHkz1z%7il7CL%EzVUL-TDshzhbEX<0(SDa?$ z_@UxpOVDm};AO?hmhus+z&j)@#~USH?&_;_%s`2uh2Si!0xE7 zHncZkAn0y%8pzM%r}ikVe%t;o-8(C}CkHCIWU8`(?stUbff!SK7+iKiF8#@IO#5-! zM{A@%+HfooUR38eLGVM`w}BrPr49jeg9hI5ZfGT{h4<+iq;wyl0;og>sRV=Y z4vmh`XpG7bhX`rvVTiaSjL_wQV|1;Bx@VZ5$_8lC0bV9oo&_Wuqglro2aYlZEPrhK zDUw5Ur3w$vfOvX@Jn^MyJEuK)dYIf0MFAr@<$Kx!st`#PRY3yCnV%=X1$I#?PMatf zBsV;&VE*71&fDX_kMB>8K>Pm?J)X41ABV^n;IliD6`>XhRk6aGFkEC4rso&ggk~qQ z0xYTt&B*y`IA00P2zg4la1)wgaziY*3B!E*7t@3Spx7ofgXD%+a1)w=^A&L3CNx9j zso;YDqGpt=2=OcRo5FiAT4WEV=NH+7W+$@ZE2;<0$oWb*Uk{oQ@>Fo)9yG(`hFEY9 zMvLu10Z?oYnn7~IE4T;E!1)R|Zx5Ow@>Foa9yFt5MJU0z_Gb8n5;laNM7?F_;s71J z0QdT}@1td`a<)YQ31oV?TS89>E>vj0#3sv>SLsdmUnqkYfk6oB@#A=n!jB?cwpz#< z@#}bidGNQmtA-y;xaK9H;YXA-C(+z>_)20$4L^-=S*@_(2bVO*Eqpkf@G(E0PfW7_ z_I0&ySg-3n!g>R7SI9pP`KO9Y7PI-PA=s$fHVNBSyxSFEn{Z{ftIP1po8y(2P{=ER zSq5Gx$wK6QMPRdz*plOGigfm6Wh93<_Zc zAMOdXZY9|jsG!A}9)?PZ=V?$$6B4JpG{;kJBvDPfi*NU=sEO*R;T*@px?`XB_*e{Q zdt50a@Tjocrq7BByS5BhLaVeB$D~q-k|(P0B}S4Ebm&$wf$&;}!}0&m%?>dq zp?k1HMAVhxxIf)^yw6c*tg%zr@767LlD!JAXEWO6O`5v4C3V8 z4Qvfw-&u^I2mpti%0N|=*m1X=ieNe#l$$Fef{wdwW}01OQ@e60c@sxTMayv`e?1fA6PF40GaR zm0nO^Qr1t<-|7~AMYr=q`3N`;lr6~6SV0Y4EjXau2^-f7%8)9H{G_s7boi;5?dL*2 zH5Xl{cAn3&)vygY{Km3lC?8AcH`i zlO+dK0Ma+-`efw|F1W_a_A$f?A>F0exxD~Ptx}Tac5^Q z-*gt>jpIg5)`_KKni~{Q;YBFsZv|G$jpX2x)BPYH>|Joe1Avf%TDozn%H3$jYGka5 zN=9@HQD!7KEFN*eu9X?_Hsp}PwNXZEGM5KkJXD#h<7hWuM~+!1>zZvO>f-d_NCI2v z_mOo>ka4=t))X-{m5f%oTg{rNsYxHzJ9Lh%fs3yW<%&D2#yOMXi_NVXmo=8!IPad- z(zVh1svb5OEs|mBYLSdM{V^8_wxjEyWY-${xI?iID=C9bl%3GAgBB-t z4y$X|@?E**rF19DzW1=w9PNe!rl|BTQE5}u_Cx{?QeraLU~MlWc}cS>BYB-R%Hz$Z z=)$D0q05Z*NWNH0TwaglciTwtAE8esW0;{oCxdO)Dt)r5hk0xK2=#H5IBx5j4|6=l zDA)6_{dCX>tE+^>bbQ?x!|Cu_MxB*rQX&wN^<7e*R(i1(nwVJ(#m&b~h zX8kHHzkS-MoV}vpJG6SX!TSsoOV}3JO4(keU(SZ^S9mtgmSlq`U)Ef=Hc`&iMgC)= z!MP?{QT?#s6f6(#%;uPL&f5`gL W(ZsJ>gkP;F51qVE|4QMRbN>Jp=4LDa 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