Merge remote-tracking branch 'origin/mdc' into mdc

This commit is contained in:
nieziyan 2024-03-01 18:27:58 +08:00
commit 0b15a28641
6 changed files with 31 additions and 31 deletions

View File

@ -233,11 +233,11 @@ public abstract class AbstractS_D_Q_G_SpectrumHandler extends AbstractSpectrumHa
this.startIntoDatabaseTime = new Date(); this.startIntoDatabaseTime = new Date();
//如果数据已经存储不在重复存储 //如果数据已经存储不在重复存储
final GardsSampleData query = spectrumServiceQuotes.getSampleDataService().findByInputFileName(super.spectrumFileRelativePath); final GardsSampleData query = spectrumServiceQuotes.getSampleDataService().findByInputFileName(super.spectrumFileRelativePath);
//如果数据已经存储 并且状态是 P 则判断文件重复 如果数据已经存储并且状态是 F 不进行处理 //如果数据已经存储 并且状态是 P R 则判断文件重复 如果数据已经存储并且状态是 F 不进行处理
if(Objects.nonNull(query)){ if(Objects.nonNull(query)){
this.sampleData = query; this.sampleData = query;
this.endIntoDatabaseTime = new Date(); this.endIntoDatabaseTime = new Date();
if (query.getStatus().equalsIgnoreCase(SampleStatus.COMPLETE.value)) { if (query.getStatus().equalsIgnoreCase(SampleStatus.COMPLETE.value) || query.getStatus().equalsIgnoreCase(SampleStatus.INTERACTIVE.value)) {
//设置文件重复标记为true //设置文件重复标记为true
this.parsingProcessLog.setFileRepeat(true); this.parsingProcessLog.setFileRepeat(true);
//发送文件重复错误事件后续统计报告使用 //发送文件重复错误事件后续统计报告使用

View File

@ -138,19 +138,9 @@ public class SpectrumParsingActuator implements Runnable{
} }
} }
} catch (Exception e) { } catch (Exception e) {
try {
if (StrUtil.isBlank(subject)) {
subject = message.getSubject();
}
if (StrUtil.isBlank(receiveDate)) {
receiveDate = DateUtils.formatDate(message.getReceivedDate(),"yyyy-MM-dd HH:mm:ss");
}
} catch (MessagingException ex) {
log.error("SpectrumParsingActuator中获取Message信息出现异常", ex);
}
// 如果不是下载导致的失败 并且 下载成功则删除下载的邮件对象 // 如果不是下载导致的失败 并且 下载成功则删除下载的邮件对象
if(!(e instanceof DownloadEmailException) && downloadFlag){ if(!(e instanceof DownloadEmailException) && downloadFlag){
log.error("Remove Email"+ subject + StringPool.UNDERSCORE + receiveDate + StringPool.UNDERSCORE); log.error("Catch Remove Email"+ subject + StringPool.UNDERSCORE + receiveDate + StringPool.UNDERSCORE);
emailServiceManager.removeMail(message,batchesCounter); emailServiceManager.removeMail(message,batchesCounter);
} }
//输出异常信息 //输出异常信息

View File

@ -1785,7 +1785,6 @@ public class GammaServiceImpl extends AbstractLogOrReport implements IGammaServi
phd.getVPeak().remove(curRow); phd.getVPeak().remove(curRow);
//重新计算核素活度浓度 //重新计算核素活度浓度
gammaFileUtil.NuclidesIdent(phd, nuclideMap); gammaFileUtil.NuclidesIdent(phd, nuclideMap);
redisUtil.set(userName+StringPool.DASH+phd.getHeader().getSystem_type(), nuclideMap);
//重新分析数据 //重新分析数据
gammaFileUtil.PeaksChanged(phd); gammaFileUtil.PeaksChanged(phd);
for (int i = 0; i < phd.getVPeak().size(); i++) { for (int i = 0; i < phd.getVPeak().size(); i++) {
@ -2075,7 +2074,6 @@ public class GammaServiceImpl extends AbstractLogOrReport implements IGammaServi
nuclideMap.remove(nuclideName); nuclideMap.remove(nuclideName);
//重新计算核素活度浓度 //重新计算核素活度浓度
gammaFileUtil.NuclidesIdent(phd, nuclideMap); gammaFileUtil.NuclidesIdent(phd, nuclideMap);
redisUtil.set(userName+StringPool.DASH+phd.getHeader().getSystem_type(), nuclideMap);
//从核素的选中列表中移除对应下标的核素信息 //从核素的选中列表中移除对应下标的核素信息
list_identify.remove(index); list_identify.remove(index);
//重新初始化峰列表信息 //重新初始化峰列表信息

View File

@ -68,13 +68,16 @@ public class JeecgAutoProcessApplication extends SpringBootServletInitializer im
@Override @Override
public void run(String... args) throws Exception { public void run(String... args) throws Exception {
//调用dll String os = System.getProperty("os.name").toLowerCase();
if (os.contains("win")) {
//Windows加载dll工具库 //Windows加载dll工具库
System.loadLibrary("ReadPHDFile"); System.loadLibrary("ReadPHDFile");
System.loadLibrary("GammaAnaly"); System.loadLibrary("GammaAnaly");
} else {
//Linux版本加载dll工具库 //Linux版本加载dll工具库
// System.load("/usr/local/jdk/lib/libReadPHDFile.so"); System.load("/usr/local/jdk/lib/libReadPHDFile.so");
// System.load("/usr/local/jdk/lib/libGammaAnalyALG.so"); System.load("/usr/local/jdk/lib/libGammaAnalyALG.so");
}
nuclLibService.getNuclideMap(); nuclLibService.getNuclideMap();
//根据配置文件配置邮件获取策略定义时间条件默认EmailReceivePolicy.HISTORY_ORDER_RECEIVE.getPolicy() //根据配置文件配置邮件获取策略定义时间条件默认EmailReceivePolicy.HISTORY_ORDER_RECEIVE.getPolicy()
Date systemStartupTime = null; Date systemStartupTime = null;

View File

@ -62,12 +62,16 @@ public class JeecgSpectrumAnalysisApplication extends SpringBootServletInitializ
@Override @Override
public void run(String... args) throws Exception { public void run(String... args) throws Exception {
String os = System.getProperty("os.name").toLowerCase();
if (os.contains("win")) {
//Windows加载dll工具库 //Windows加载dll工具库
System.loadLibrary("ReadPHDFile"); System.loadLibrary("ReadPHDFile");
System.loadLibrary("GammaAnaly"); System.loadLibrary("GammaAnaly");
} else {
//Linux版本加载dll工具库 //Linux版本加载dll工具库
// System.load("/usr/local/jdk/lib/libReadPHDFile.so"); System.load("/usr/local/jdk/lib/libReadPHDFile.so");
// System.load("/usr/local/jdk/lib/libGammaAnalyALG.so"); System.load("/usr/local/jdk/lib/libGammaAnalyALG.so");
}
//创建缓存 //创建缓存
betaCache.initCache(); betaCache.initCache();
localCache.initCache(); localCache.initCache();

View File

@ -41,8 +41,13 @@ public class JeecgWebStatisticsApplication extends SpringBootServletInitializer
@Override @Override
public void run(String... args) throws Exception { public void run(String... args) throws Exception {
//windows环境调用dll String os = System.getProperty("os.name").toLowerCase();
if (os.contains("win")) {
//Windows加载dll工具库
System.loadLibrary("ReadPHDFile"); System.loadLibrary("ReadPHDFile");
//System.load("/usr/local/jdk/lib/libReadPHDFile.so"); } else {
//Linux版本加载dll工具库
System.load("/usr/local/jdk/lib/libReadPHDFile.so");
}
} }
} }