Compare commits
No commits in common. "164e44d08644dbbef6536f45808bfabfd47b3c61" and "19c9bae34890674449f11d5fb09f7e253cb87065" have entirely different histories.
164e44d086
...
19c9bae348
|
@ -1,12 +0,0 @@
|
||||||
package org.jeecg.modules.base.dto;
|
|
||||||
|
|
||||||
import lombok.Data;
|
|
||||||
|
|
||||||
@Data
|
|
||||||
public class RoiDto {
|
|
||||||
|
|
||||||
private Integer roiNum;
|
|
||||||
|
|
||||||
private String phdPath;
|
|
||||||
|
|
||||||
}
|
|
|
@ -47,7 +47,7 @@ public interface AnalysisManService {
|
||||||
|
|
||||||
void saveQcCheckROI(Integer sampleId, Map<String, QcCheckItem> qcItems, Integer idAnalysis);
|
void saveQcCheckROI(Integer sampleId, Map<String, QcCheckItem> qcItems, Integer idAnalysis);
|
||||||
|
|
||||||
void saveMDCROI(Integer sampleId, List<Map<String, CalMDCInfo>> mdcInfoMaps, Integer idAnalysis);
|
void saveMDCROI(Integer sampleId, Map<String, CalMDCInfo> mdcInfoMap, Integer idAnalysis);
|
||||||
|
|
||||||
void saveAnalySettingROI(Integer sampleId, Integer idAnalysis, List<PHDFile> phdFiles);
|
void saveAnalySettingROI(Integer sampleId, Integer idAnalysis, List<PHDFile> phdFiles);
|
||||||
}
|
}
|
||||||
|
|
|
@ -489,12 +489,10 @@ public class AnalysisManServiceImpl implements AnalysisManService {
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void saveMDCROI(Integer sampleId, List<Map<String, CalMDCInfo>> mdcInfoMaps, Integer idAnalysis){
|
public void saveMDCROI(Integer sampleId, Map<String, CalMDCInfo> mdcInfoMap, Integer idAnalysis){
|
||||||
List<GardsMDCRoi> mdcRois = new ArrayList<>();
|
List<GardsMDCRoi> mdcRois = new ArrayList<>();
|
||||||
List<Integer> roiIds = ListUtil.toList(this.middleDataMap.keySet());
|
Set<Integer> roiIds = this.middleDataMap.keySet();
|
||||||
for (int i = 0; i < roiIds.size(); i++) {
|
for (Integer roiId : roiIds) {
|
||||||
Integer roiId = roiIds.get(i);
|
|
||||||
Map<String, CalMDCInfo> mdcInfoMap = mdcInfoMaps.get(i);
|
|
||||||
mdcRois.addAll(saveMDCROI(sampleId, idAnalysis, roiId, mdcInfoMap));
|
mdcRois.addAll(saveMDCROI(sampleId, idAnalysis, roiId, mdcInfoMap));
|
||||||
}
|
}
|
||||||
mdcRoiManService.saveBatch(mdcRois);
|
mdcRoiManService.saveBatch(mdcRois);
|
||||||
|
|
|
@ -5,7 +5,6 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
|
||||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
||||||
import org.apache.ibatis.annotations.Mapper;
|
import org.apache.ibatis.annotations.Mapper;
|
||||||
import org.apache.ibatis.annotations.Param;
|
import org.apache.ibatis.annotations.Param;
|
||||||
import org.jeecg.modules.base.dto.RoiDto;
|
|
||||||
import org.jeecg.modules.base.entity.configuration.GardsDetectors;
|
import org.jeecg.modules.base.entity.configuration.GardsDetectors;
|
||||||
import org.jeecg.modules.base.entity.configuration.GardsNuclLib;
|
import org.jeecg.modules.base.entity.configuration.GardsNuclLib;
|
||||||
import org.jeecg.modules.base.entity.configuration.GardsNuclLinesLib;
|
import org.jeecg.modules.base.entity.configuration.GardsNuclLinesLib;
|
||||||
|
@ -87,8 +86,6 @@ public interface SpectrumAnalysisMapper {
|
||||||
|
|
||||||
Integer getAnalysisID(@Param(value = "dbName") String dbName, @Param(value = "sampleId") Integer sampleId, @Param(value = "userName") String userName);
|
Integer getAnalysisID(@Param(value = "dbName") String dbName, @Param(value = "sampleId") Integer sampleId, @Param(value = "userName") String userName);
|
||||||
|
|
||||||
List<RoiDto> roiPaths(@Param("dbName") String dbName, @Param("analysisId") Integer analysisId);
|
|
||||||
|
|
||||||
List<GardsCalibrationPairsSpectrum> ReadGammaFitChannelEnergy(@Param(value = "idAnalysis") Integer idAnalysis);
|
List<GardsCalibrationPairsSpectrum> ReadGammaFitChannelEnergy(@Param(value = "idAnalysis") Integer idAnalysis);
|
||||||
|
|
||||||
List<GardsCalibrationSpectrum> ReadGammaCalibrationParam(@Param(value = "dbName") String dbName, @Param(value = "idAnalysis") Integer idAnalysis);
|
List<GardsCalibrationSpectrum> ReadGammaCalibrationParam(@Param(value = "dbName") String dbName, @Param(value = "idAnalysis") Integer idAnalysis);
|
||||||
|
|
|
@ -1104,8 +1104,5 @@
|
||||||
<select id="findNuclidesAnalysis" resultType="java.lang.String">
|
<select id="findNuclidesAnalysis" resultType="java.lang.String">
|
||||||
select NAME from CONFIGURATION.GARDS_NUCL_LIB
|
select NAME from CONFIGURATION.GARDS_NUCL_LIB
|
||||||
</select>
|
</select>
|
||||||
<select id="roiPaths" resultType="org.jeecg.modules.base.dto.RoiDto">
|
|
||||||
SELECT ROI_NUM, PHD_PATH FROM ${dbName}.GARDS_ANALYSIS_ROI WHERE IDANALYSIS = #{analysisId} ORDER BY ROI_NUM ASC
|
|
||||||
</select>
|
|
||||||
|
|
||||||
</mapper>
|
</mapper>
|
|
@ -21,7 +21,6 @@ import org.jeecg.common.properties.ParameterProperties;
|
||||||
import org.jeecg.common.properties.SpectrumPathProperties;
|
import org.jeecg.common.properties.SpectrumPathProperties;
|
||||||
import org.jeecg.common.system.util.JwtUtil;
|
import org.jeecg.common.system.util.JwtUtil;
|
||||||
import org.jeecg.common.util.*;
|
import org.jeecg.common.util.*;
|
||||||
import org.jeecg.modules.base.dto.RoiDto;
|
|
||||||
import org.jeecg.modules.base.entity.configuration.GardsNuclLib;
|
import org.jeecg.modules.base.entity.configuration.GardsNuclLib;
|
||||||
import org.jeecg.modules.base.entity.configuration.GardsNuclLinesLib;
|
import org.jeecg.modules.base.entity.configuration.GardsNuclLinesLib;
|
||||||
import org.jeecg.modules.base.entity.original.GardsSampleData;
|
import org.jeecg.modules.base.entity.original.GardsSampleData;
|
||||||
|
@ -52,8 +51,6 @@ import java.text.ParseException;
|
||||||
import java.util.*;
|
import java.util.*;
|
||||||
import java.util.stream.Collectors;
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
import static org.aspectj.weaver.tools.cache.SimpleCacheFactory.path;
|
|
||||||
|
|
||||||
@Service
|
@Service
|
||||||
public class SelfStationServiceImpl implements ISelfStationService {
|
public class SelfStationServiceImpl implements ISelfStationService {
|
||||||
|
|
||||||
|
@ -122,7 +119,6 @@ public class SelfStationServiceImpl implements ISelfStationService {
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
@DS("ora")
|
|
||||||
public Result loadFromDB(String dbName, Integer sampleId, String analyst, HttpServletRequest request) {
|
public Result loadFromDB(String dbName, Integer sampleId, String analyst, HttpServletRequest request) {
|
||||||
Result result = new Result();
|
Result result = new Result();
|
||||||
Map<String, Map<String, Object>> resultMap = new HashMap<>();
|
Map<String, Map<String, Object>> resultMap = new HashMap<>();
|
||||||
|
@ -135,18 +131,14 @@ public class SelfStationServiceImpl implements ISelfStationService {
|
||||||
result.error500("Please select a piece of data");
|
result.error500("Please select a piece of data");
|
||||||
return result;
|
return result;
|
||||||
}
|
}
|
||||||
String prefix = spectrumPathProperties.getRootPath() + spectrumPathProperties.getSaveFilePath() + StringPool.SLASH;
|
|
||||||
//查询分析id,相关的分析结果
|
//查询分析id,相关的分析结果
|
||||||
Integer analysisID = null;
|
Integer analysisID = null;
|
||||||
List<RoiDto> roiPaths = new ArrayList<>();
|
|
||||||
if (dbName.equalsIgnoreCase("auto")){
|
if (dbName.equalsIgnoreCase("auto")){
|
||||||
dbName = "RNAUTO";
|
dbName = "RNAUTO";
|
||||||
analysisID = spectrumAnalysisMapper.getAnalysisID(dbName, sampleId, "RNAUTO");
|
analysisID = spectrumAnalysisMapper.getAnalysisID(dbName, sampleId, "RNAUTO");
|
||||||
roiPaths = spectrumAnalysisMapper.roiPaths(dbName, analysisID);
|
|
||||||
} else if (dbName.equalsIgnoreCase("man")){
|
} else if (dbName.equalsIgnoreCase("man")){
|
||||||
dbName = "RNMAN";
|
dbName = "RNMAN";
|
||||||
analysisID = spectrumAnalysisMapper.getAnalysisID(dbName, sampleId, analyst);
|
analysisID = spectrumAnalysisMapper.getAnalysisID(dbName, sampleId, analyst);
|
||||||
roiPaths = spectrumAnalysisMapper.roiPaths(dbName, analysisID);
|
|
||||||
}
|
}
|
||||||
try {
|
try {
|
||||||
if (Objects.nonNull(analysisID)) {
|
if (Objects.nonNull(analysisID)) {
|
||||||
|
@ -169,14 +161,14 @@ public class SelfStationServiceImpl implements ISelfStationService {
|
||||||
detFileName = dbSpectrumFilePath.getDetBgFilePath().substring(dbSpectrumFilePath.getDetBgFilePath().lastIndexOf(StringPool.SLASH)+1);
|
detFileName = dbSpectrumFilePath.getDetBgFilePath().substring(dbSpectrumFilePath.getDetBgFilePath().lastIndexOf(StringPool.SLASH)+1);
|
||||||
}
|
}
|
||||||
//从缓存中获取公用变量的数据
|
//从缓存中获取公用变量的数据
|
||||||
SelfStationData selfStationData = selfCache.getIfPresent(sampleFileName + StringPool.DASH + userName);
|
SelfStationData selfStationData = selfCache.getIfPresent(sampleFileName + "-" + userName);
|
||||||
if (Objects.isNull(selfStationData)) {
|
if (Objects.isNull(selfStationData)) {
|
||||||
//初始化自建台站数据对象
|
//初始化自建台站数据对象
|
||||||
selfStationData = new SelfStationData();
|
selfStationData = new SelfStationData();
|
||||||
//判断sample文件名是否为空
|
//判断sample文件名是否为空
|
||||||
if (Objects.nonNull(sample)) {
|
if (Objects.nonNull(sample)) {
|
||||||
//拼接sample文件路径
|
//拼接sample文件路径
|
||||||
String sampleFilePath = prefix + dbSpectrumFilePath.getSampleFilePath();
|
String sampleFilePath = ftpUtil.getFtpRootPath() + spectrumPathProperties.getSaveFilePath() + StringPool.SLASH + dbSpectrumFilePath.getSampleFilePath();
|
||||||
//返回结果map
|
//返回结果map
|
||||||
Map<String, Object> map = new HashMap<>();
|
Map<String, Object> map = new HashMap<>();
|
||||||
//获取sample分析后的对象
|
//获取sample分析后的对象
|
||||||
|
@ -186,15 +178,12 @@ public class SelfStationServiceImpl implements ISelfStationService {
|
||||||
selfStationData.setSampleTmpPath(sampleFilePath);
|
selfStationData.setSampleTmpPath(sampleFilePath);
|
||||||
selfStationUtil.loadFile(selfStationData, sample.getSampleId(), sample.getStatus(), "sample", map);
|
selfStationUtil.loadFile(selfStationData, sample.getSampleId(), sample.getStatus(), "sample", map);
|
||||||
resultMap.put("sample", map);
|
resultMap.put("sample", map);
|
||||||
|
|
||||||
// 返回Beta和Gamma的数据
|
|
||||||
bGSpectrum(struct, map);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
//判断det文件名是否为空
|
//判断det文件名是否为空
|
||||||
if (Objects.nonNull(detBg)) {
|
if (Objects.nonNull(detBg)) {
|
||||||
//拼接det文件路径
|
//拼接det文件路径
|
||||||
String detFilePath = prefix + dbSpectrumFilePath.getDetBgFilePath();
|
String detFilePath = ftpUtil.getFtpRootPath() + spectrumPathProperties.getSaveFilePath() + StringPool.SLASH + dbSpectrumFilePath.getDetBgFilePath();
|
||||||
//返回结果map
|
//返回结果map
|
||||||
Map<String, Object> map = new HashMap<>();
|
Map<String, Object> map = new HashMap<>();
|
||||||
//获取sample分析后的对象
|
//获取sample分析后的对象
|
||||||
|
@ -232,45 +221,13 @@ public class SelfStationServiceImpl implements ISelfStationService {
|
||||||
redisUtil.set(userName+StringPool.DASH+systemType+"-list-self", userLib);
|
redisUtil.set(userName+StringPool.DASH+systemType+"-list-self", userLib);
|
||||||
redisUtil.set(userName+StringPool.DASH+systemType+"-self", nuclideMap);
|
redisUtil.set(userName+StringPool.DASH+systemType+"-self", nuclideMap);
|
||||||
}
|
}
|
||||||
// 将四个Gamma ROI文件对象放到缓存中
|
|
||||||
SelfStationVueData sampleVueData = selfStationData.getSampleVueData();
|
|
||||||
|
|
||||||
Map<Integer, String> roiPathMap = roiPaths.stream()
|
|
||||||
.collect(Collectors.toMap(RoiDto::getRoiNum, RoiDto::getPhdPath));
|
|
||||||
|
|
||||||
String fullPath1 = prefix + roiPathMap.get(1);
|
|
||||||
String fullPath2 = prefix + roiPathMap.get(2);
|
|
||||||
String fullPath3 = prefix + roiPathMap.get(3);
|
|
||||||
String fullPath4 = prefix + roiPathMap.get(4);
|
|
||||||
|
|
||||||
String name1 = FileUtil.getName(fullPath1);
|
|
||||||
String name2 = FileUtil.getName(fullPath2);
|
|
||||||
String name3 = FileUtil.getName(fullPath3);
|
|
||||||
String name4 = FileUtil.getName(fullPath4);
|
|
||||||
|
|
||||||
String path = fullPath1.substring(0, fullPath1.lastIndexOf(StrUtil.SLASH));
|
|
||||||
|
|
||||||
sampleVueData.setROIOneFileName(name1);
|
|
||||||
sampleVueData.setROIOnePHDFile(selfStationUtil.getGammaPHD(name1, path));
|
|
||||||
sampleVueData.setROITwoFileName(name2);
|
|
||||||
sampleVueData.setROITwoPHDFile(selfStationUtil.getGammaPHD(name2, path));
|
|
||||||
sampleVueData.setROIThreeFileName(name3);
|
|
||||||
sampleVueData.setROIThreePHDFile(selfStationUtil.getGammaPHD(name3, path));
|
|
||||||
sampleVueData.setROIFourFileName(name4);
|
|
||||||
sampleVueData.setROIFourPHDFile(selfStationUtil.getGammaPHD(name4, path));
|
|
||||||
}
|
}
|
||||||
//将自建台站的数据封装到缓存对象中
|
|
||||||
selfCache.put(sampleFileName + StringPool.DASH + userName, selfStationData);
|
|
||||||
//将缓存对象存入到缓存中
|
|
||||||
selfStationCache.setSelfCache(selfCache);
|
|
||||||
} else {
|
} else {
|
||||||
if (Objects.nonNull(sample)) {
|
if (Objects.nonNull(sample)) {
|
||||||
//返回结果map
|
//返回结果map
|
||||||
Map<String, Object> map = new HashMap<>();
|
Map<String, Object> map = new HashMap<>();
|
||||||
selfStationUtil.loadFile(selfStationData, sample.getSampleId(), sample.getStatus(), "sample", map);
|
selfStationUtil.loadFile(selfStationData, sample.getSampleId(), sample.getStatus(), "sample", map);
|
||||||
resultMap.put("sample", map);
|
resultMap.put("sample", map);
|
||||||
// 返回Beta和Gamma的数据
|
|
||||||
bGSpectrum(selfStationData.getSampleStruct(), map);
|
|
||||||
}
|
}
|
||||||
if (Objects.nonNull(detBg)) {
|
if (Objects.nonNull(detBg)) {
|
||||||
//返回结果map
|
//返回结果map
|
||||||
|
@ -282,10 +239,9 @@ public class SelfStationServiceImpl implements ISelfStationService {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
e.printStackTrace();
|
|
||||||
}
|
}
|
||||||
result.setSuccess(true);
|
|
||||||
result.setResult(resultMap);
|
|
||||||
return result;
|
return result;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -545,6 +501,7 @@ public class SelfStationServiceImpl implements ISelfStationService {
|
||||||
seriseData.setY(gCounts.get(i));
|
seriseData.setY(gCounts.get(i));
|
||||||
seriseDataG.add(seriseData);
|
seriseDataG.add(seriseData);
|
||||||
}
|
}
|
||||||
|
Map<String, Object> result = new HashMap<>();
|
||||||
map.put("bSpectrum", seriseDataB);
|
map.put("bSpectrum", seriseDataB);
|
||||||
map.put("gSpectrum", seriseDataG);
|
map.put("gSpectrum", seriseDataG);
|
||||||
}
|
}
|
||||||
|
@ -4890,12 +4847,7 @@ public class SelfStationServiceImpl implements ISelfStationService {
|
||||||
String path4 = savePathName + StrUtil.SLASH + phdFile4.getFilename();
|
String path4 = savePathName + StrUtil.SLASH + phdFile4.getFilename();
|
||||||
List<String> phdFilePaths = ListUtil.toList(path1, path2, path3, path4);
|
List<String> phdFilePaths = ListUtil.toList(path1, path2, path3, path4);
|
||||||
//读取参数内容
|
//读取参数内容
|
||||||
Map<String, CalMDCInfo> mdcInfoMap1 = phdFile1.getMdcInfoMap();
|
Map<String, CalMDCInfo> mdcInfoMap = phdFile1.getMdcInfoMap();
|
||||||
Map<String, CalMDCInfo> mdcInfoMap2 = phdFile1.getMdcInfoMap();
|
|
||||||
Map<String, CalMDCInfo> mdcInfoMap3 = phdFile1.getMdcInfoMap();
|
|
||||||
Map<String, CalMDCInfo> mdcInfoMap4 = phdFile1.getMdcInfoMap();
|
|
||||||
List<Map<String, CalMDCInfo>> mdcInfoMaps = ListUtil.toList(mdcInfoMap1, mdcInfoMap2,
|
|
||||||
mdcInfoMap3, mdcInfoMap4);
|
|
||||||
|
|
||||||
bRet = gammaFileUtil.GetInterMiddlData(phdFiles, userName, middleDatas, "save");
|
bRet = gammaFileUtil.GetInterMiddlData(phdFiles, userName, middleDatas, "save");
|
||||||
if (!bRet) {
|
if (!bRet) {
|
||||||
|
@ -4969,7 +4921,7 @@ public class SelfStationServiceImpl implements ISelfStationService {
|
||||||
// 向 RNMAN.GARDS_ANALY_SETTING 表写入 SpecSetup 分析参数设置
|
// 向 RNMAN.GARDS_ANALY_SETTING 表写入 SpecSetup 分析参数设置
|
||||||
analysisManService.saveAnalySettingROI(sampleId, idAnalysis, phdFiles);
|
analysisManService.saveAnalySettingROI(sampleId, idAnalysis, phdFiles);
|
||||||
// 向 RNMAN.GARDS_MDC 表写入 MDC计算结果
|
// 向 RNMAN.GARDS_MDC 表写入 MDC计算结果
|
||||||
analysisManService.saveMDCROI(sampleId, mdcInfoMaps, idAnalysis);
|
analysisManService.saveMDCROI(sampleId, mdcInfoMap, idAnalysis);
|
||||||
if (bRet) {
|
if (bRet) {
|
||||||
phd.setStatus("R");
|
phd.setStatus("R");
|
||||||
//分析成功后存储日志文件和报告文件
|
//分析成功后存储日志文件和报告文件
|
||||||
|
|
Loading…
Reference in New Issue
Block a user