diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/config/lucene/Indexer.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/config/lucene/Indexer.java
deleted file mode 100644
index 64895ee14..000000000
--- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/config/lucene/Indexer.java
+++ /dev/null
@@ -1,187 +0,0 @@
-package org.nl.config.lucene;
-
-import com.alibaba.fastjson.JSONObject;
-import org.apache.commons.io.FileUtils;
-import org.apache.lucene.analysis.Analyzer;
-import org.apache.lucene.document.Document;
-import org.apache.lucene.document.Field;
-import org.apache.lucene.document.TextField;
-import org.apache.lucene.index.IndexWriter;
-import org.apache.lucene.index.IndexWriterConfig;
-import org.apache.lucene.store.Directory;
-import org.apache.lucene.store.FSDirectory;
-import org.springframework.beans.factory.annotation.Value;
-import org.wltea.analyzer.lucene.IKAnalyzer;
-
-import java.io.BufferedReader;
-import java.io.File;
-import java.io.FileReader;
-import java.io.IOException;
-import java.nio.file.Paths;
-import java.util.Set;
-
-/**
- *
- * lucene索引器
- *
- *
- * @author generator
- * @since 2023-11-16
- */
-public class Indexer {
- /**
- * 写索引实例
- */
- private IndexWriter writer;
-
- public IndexWriter getWriter() {
- return writer;
- }
-
- /**
- * 构造方法,实例化IndexWriter
- *
- * @param indexDir
- * @throws Exception
- */
- public Indexer(String indexDir) throws Exception {
- Directory dir = FSDirectory.open(Paths.get(indexDir));
- //标准分词器,会自动去掉空格啊,is a the等单词
-// Analyzer analyzer = new StandardAnalyzer();
- Analyzer analyzer = new IKAnalyzer();
- //将标准分词器配到写索引的配置中
- IndexWriterConfig config = new IndexWriterConfig(analyzer);
- //实例化写索引对象
- writer = new IndexWriter(dir, config);
- }
-
- /**
- * 索引指定目录下的所有文件
- *
- * @param dataDir
- * @return
- * @throws Exception
- */
- public int indexAll(String dataDir) throws Exception {
- // 获取该路径下的所有文件
- File[] files = new File(dataDir).listFiles();
- if (null != files) {
- for (File file : files) {
- //调用下面的indexFile方法,对每个文件进行索引
- indexFile(file);
- }
- }
- //返回索引的文件数
- return writer.numRamDocs();
- }
-
- /**
- * 索引指定的文件
- *
- * @param file
- * @throws Exception
- */
- private void indexFile(File file) throws Exception {
- System.out.println("索引文件的路径:" + file.getCanonicalPath());
- //调用下面的getDocument方法,获取该文件的document
- Document doc = getDocument(file);
- //添加索引文档
- //Document doc = json2Doc(jsonDoc);
-// Document doc = new Document();
- Field fieldContent = new TextField("fieldContent", FileUtils.readFileToString(null, "UTF-8"), Field.Store.YES);
-
- //将doc添加到索引中
- writer.addDocument(doc);
- }
-
- /**
- * 获取文档,文档里再设置每个字段,就类似于数据库中的一行记录
- *
- * @param file
- * @return
- * @throws Exception
- */
- private Document getDocument(File file) throws Exception {
- Document doc = new Document();
- //开始添加字段
- //添加内容
- doc.add(new TextField("contents", new FileReader(file)));
- //添加文件名,并把这个字段存到索引文件里
- doc.add(new TextField("fileName", file.getName(), Field.Store.YES));
- //添加文件路径
- doc.add(new TextField("fullPath", file.getCanonicalPath(), Field.Store.YES));
- return doc;
- }
-
- public Document json2Doc(String strDoc) {
- Document doc = new Document();
- JSONObject jsonDoc = JSONObject.parseObject(strDoc);
- Set keys = jsonDoc.keySet();
- for (String key : keys) {
- doc.add(new TextField(key, jsonDoc.getString(key), Field.Store.YES));
- }
- return doc;
- }
-
- public void addLogIndex(String msg) throws IOException {
- //步骤一:创建Directory对象,用于指定索引库的位置 RAMDirectory内存
- Directory directory = FSDirectory.open(new File("D:\\lucene\\index").toPath());
- //步骤二:创建一个IndexWriter对象,用于写索引
-// Analyzer analyzer = new StandardAnalyzer();
- IndexWriter indexWriter = new IndexWriter(directory, new IndexWriterConfig(new IKAnalyzer(false)));
-// indexWriter.deleteAll();//清理所有索引库
-// IndexWriter indexWriter=new IndexWriter(directory,new IndexWriterConfig(new StandardAnalyzer()));
- //记录索引开始时间
- long startTime = System.currentTimeMillis();
- //步骤三:读取磁盘中文件,对应每一个文件创建一个文档对象
- Document document = new Document();
- document.add(new TextField("fieldContent", msg, Field.Store.YES));
- indexWriter.addDocument(document);
- //记录索引结束时间
- long endTime = System.currentTimeMillis();
- System.out.println("建立索引" + "共耗时" + (endTime - startTime) + "毫秒");
- indexWriter.commit();
- //步骤八:关闭资源
- indexWriter.close();
- System.out.println("建立索引成功-----关闭资源");
- }
-
- /**
- * 系统的日志文件路径
- */
- @Value("${logging.file.path}")
- private String logUrl;
-
- public static void main(String[] args) throws IOException {
- //步骤一:创建Directory对象,用于指定索引库的位置 RAMDirectory内存
- Directory directory = FSDirectory.open(new File("D:\\lucene\\index").toPath());
- //步骤二:创建一个IndexWriter对象,用于写索引
-// Analyzer analyzer = new StandardAnalyzer();
- IndexWriter indexWriter = new IndexWriter(directory, new IndexWriterConfig(new IKAnalyzer(false)));
-
- indexWriter.deleteAll();//清理所有索引库
-// indexWriter=new IndexWriter(directory,new IndexWriterConfig(new StandardAnalyzer()));
- //记录索引开始时间
- long startTime = System.currentTimeMillis();
- //步骤三:读取磁盘中文件,对应每一个文件创建一个文档对象
- File file = new File("D:\\testlog");
- //步骤四:获取文件列表
- File[] files = file.listFiles();
- for (File item : files) {
- BufferedReader bufferedReader = new BufferedReader(new FileReader(item));
- String strLine = null;
- while (null != (strLine = bufferedReader.readLine())) {
- Document document = new Document();
- document.add(new TextField("fieldContent", strLine, Field.Store.YES));
- indexWriter.addDocument(document);
- }
- }
- //记录索引结束时间
- long endTime = System.currentTimeMillis();
- System.out.println("建立索引" + "共耗时" + (endTime - startTime) + "毫秒");
- indexWriter.commit();
- //步骤八:关闭资源
- indexWriter.close();
- System.out.println("建立索引成功-----关闭资源");
- }
-}
diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/config/lucene/LuceneAppender.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/config/lucene/LuceneAppender.java
index d342c3a0a..e9e48cb00 100644
--- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/config/lucene/LuceneAppender.java
+++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/config/lucene/LuceneAppender.java
@@ -16,7 +16,9 @@ import org.apache.lucene.index.IndexWriter;
import org.apache.lucene.index.IndexWriterConfig;
import org.apache.lucene.store.Directory;
import org.apache.lucene.store.FSDirectory;
-import org.nl.common.utils.YmlConfigFileUtil;
+import org.springframework.beans.factory.config.YamlPropertiesFactoryBean;
+import org.springframework.core.io.ClassPathResource;
+import org.springframework.core.io.Resource;
import org.wltea.analyzer.lucene.IKAnalyzer;
import java.io.IOException;
@@ -30,7 +32,7 @@ import java.util.regex.Pattern;
public class LuceneAppender extends AppenderBase {
- private Directory index;
+ private static Directory index;
public static IndexWriter indexWriter;
@@ -38,24 +40,25 @@ public class LuceneAppender extends AppenderBase {
public void start() {
super.start();
try {
- // 读取配置文件
- Properties properties = YmlConfigFileUtil.readConfig("config/application.yml");
-
- // 获取配置值
- String luceneDir = properties.getProperty("lucene.index.path");
- index = FSDirectory.open(Paths.get(luceneDir));
- } catch (IOException e) {
+ init();
+ } catch (Exception e) {
e.printStackTrace();
}
+ }
+ public static void init() throws IOException {
+ Resource resource = new ClassPathResource("config/application.yml");
+ YamlPropertiesFactoryBean yamlPropertiesFactoryBean = new YamlPropertiesFactoryBean();
+ yamlPropertiesFactoryBean.setResources(resource);
+ Properties properties = yamlPropertiesFactoryBean.getObject();
+ // 获取配置值
+ String luceneDir = properties.getProperty("lucene.index.path");
+ System.out.println("---index地址----" + luceneDir);
+ index = FSDirectory.open(Paths.get(luceneDir));
// 初始化 Lucene 索引
Analyzer analyzer = new IKAnalyzer();
IndexWriterConfig config = new IndexWriterConfig(analyzer);
- try {
- indexWriter = new IndexWriter(index, config);
- } catch (IOException e) {
- e.printStackTrace();
- }
+ indexWriter = new IndexWriter(index, config);
}
diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/config/lucene/LuceneIndexWriter.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/config/lucene/LuceneIndexWriter.java
deleted file mode 100644
index 0e9fdb613..000000000
--- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/config/lucene/LuceneIndexWriter.java
+++ /dev/null
@@ -1,70 +0,0 @@
-package org.nl.config.lucene;
-
-import cn.hutool.core.date.DateUtil;
-import org.apache.lucene.index.CorruptIndexException;
-import org.apache.lucene.index.IndexWriter;
-import org.apache.lucene.index.IndexWriterConfig;
-import org.apache.lucene.store.Directory;
-import org.apache.lucene.store.FSDirectory;
-import org.wltea.analyzer.lucene.IKAnalyzer;
-
-import java.io.File;
-import java.io.IOException;
-import java.text.ParseException;
-import java.text.SimpleDateFormat;
-import java.util.Date;
-
-/**
- *
- * 、
- *
- *
- * @author generator
- * @since 2023-11-16
- */
-public class LuceneIndexWriter {
- private static IndexWriter indexWriter;
-
- static {
- try {
- Directory directory = FSDirectory.open(new File(UrlConfig.luceneUrl).toPath());
- IndexWriterConfig config = new IndexWriterConfig(new IKAnalyzer());
- indexWriter = new IndexWriter(directory, config);
- } catch (Exception e) {
- e.printStackTrace();
- }
- /**当当前线程结束时,自动关闭IndexWriter,使用Runtime对象*/
- Runtime.getRuntime().addShutdownHook(new Thread(() -> {
- try {
- closeIndexWriter();
- } catch (Exception e) {
- e.printStackTrace();
- }
- }));
- }
- /**在线程结束时,自动关闭IndexWriter*/
- public static IndexWriter getIndexWriter() {
- return indexWriter;
- }
- /**关闭IndexWriter
- * @throws IOException
- * @throws CorruptIndexException */
- public static void closeIndexWriter() throws Exception {
- if(indexWriter != null) {
- indexWriter.close();
- }
- }
-
- public static void main(String[] args) throws IOException {
- indexWriter.deleteAll();
- }
-
- public static String getDate(String timeString) throws ParseException {
- //时间格式
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSSX");
- Date date = sdf.parse(timeString);
- //格式化后的时间
- timeString = DateUtil.format(date, "yyyy-MM-dd HH:mm:ss.SSS");
- return timeString;
- }
-}
diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/config/lucene/Searcher.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/config/lucene/Searcher.java
index 45b867ef3..f9f035258 100644
--- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/config/lucene/Searcher.java
+++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/config/lucene/Searcher.java
@@ -95,6 +95,7 @@ public class Searcher {
whereJson.get(LogMessageConstant.FIELD_LEVEL).toString()));
booleanQueryBuilder.add(termQuery, BooleanClause.Occur.MUST);
}
+ // 使用实体接收
List list = new ArrayList<>();
TopFieldCollector collector = TopFieldCollector.create(sort, 20000, 0);
searcher.search(booleanQueryBuilder.build(), collector);
diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/lucene/LuceneExecuteLogService.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/lucene/LuceneExecuteLogService.java
deleted file mode 100644
index e5c683702..000000000
--- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/lucene/LuceneExecuteLogService.java
+++ /dev/null
@@ -1,48 +0,0 @@
-package org.nl.system.service.lucene;
-
-import org.nl.system.service.lucene.dto.LuceneLogDto;
-
-import java.io.IOException;
-
-/**
- *
- * 日志检索服务
- *
- *
- * @author generator
- * @since 2023-11-16
- */
-public interface LuceneExecuteLogService {
- /**
- * 设备光电变化实时光电信号
- *
- * @param device_code 设备编号
- * @param key plc信号
- * @param value plc信号值
- */
- void deviceItemValue(String device_code, String key, String value);
-
- /**
- * 设备执行日志,会保留历史记录
- *
- * @param luceneLogDto 日志结果对象
- */
- void deviceExecuteLog(LuceneLogDto luceneLogDto);
-
- /**
- * 接口日志,会保留历史记录
- * @param luceneLogDto 日志结果对象
- * @throws IOException
- */
- void interfaceExecuteLog(LuceneLogDto luceneLogDto) throws IOException;
-
- /**
- * 设备执行日志,会保留历史记录
- *
- * @param name 日志名称
- * @param message 日志信息
- */
- void extLog(String name, String message);
-
-
-}
diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/lucene/impl/LuceneExecuteLogServiceImpl.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/lucene/impl/LuceneExecuteLogServiceImpl.java
index 2c049465c..4f039890c 100644
--- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/lucene/impl/LuceneExecuteLogServiceImpl.java
+++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/lucene/impl/LuceneExecuteLogServiceImpl.java
@@ -1,111 +1,111 @@
-package org.nl.system.service.lucene.impl;
-
-import cn.hutool.core.date.DateTime;
-import cn.hutool.core.date.DateUtil;
-import cn.hutool.core.util.ObjectUtil;
-import lombok.RequiredArgsConstructor;
-import lombok.SneakyThrows;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.lucene.document.Document;
-import org.apache.lucene.document.Field;
-import org.apache.lucene.document.StringField;
-import org.apache.lucene.index.IndexWriter;
-import org.nl.common.enums.LogTypeEnum;
-import org.nl.config.lucene.DynamicLogger;
-import org.nl.config.lucene.LuceneIndexWriter;
-import org.nl.system.service.lucene.LuceneExecuteLogService;
-import org.nl.system.service.lucene.dto.LuceneLogDto;
-import org.slf4j.Logger;
-import org.slf4j.MDC;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.stereotype.Service;
-
-import java.io.IOException;
-
-/**
- * @author jlm
- * @description 服务实现
- * @date 2023-04-11
- */
-@Service
-@RequiredArgsConstructor
-@Slf4j
-public class LuceneExecuteLogServiceImpl implements LuceneExecuteLogService {
-
- /**
- * 日志目录
- */
- @Value("${logging.file.path}")
- private String logPath;
-
- @Override
- public void deviceItemValue(String device_code, String key, String value) {
- String now = DateUtil.now();
- }
-
- @SneakyThrows
- @Override
- public void deviceExecuteLog(LuceneLogDto luceneLogDto) {
- luceneLogDto.setLogType(LogTypeEnum.DEVICE_LOG.getDesc());
- addIndex(luceneLogDto);
- }
-
- @Override
- public void interfaceExecuteLog(LuceneLogDto luceneLogDto) throws IOException {
- luceneLogDto.setLogType(LogTypeEnum.INTERFACE_LOG.getDesc());
- addIndex(luceneLogDto);
- }
-
- private void addIndex(LuceneLogDto luceneLogDto) throws IOException {
- IndexWriter indexWriter = LuceneIndexWriter.getIndexWriter();
- //创建一个Document对象
- Document document = new Document();
- try {
- //记录索引开始时间
- long startTime = System.currentTimeMillis();
- //向document对象中添加域。
- if (ObjectUtil.isNotEmpty(luceneLogDto.getDevice_code())) {
- document.add(new StringField("device_code", luceneLogDto.getDevice_code(), Field.Store.YES));
- }
- if (ObjectUtil.isNotEmpty(luceneLogDto.getContent())) {
- document.add(new StringField("fieldContent", luceneLogDto.getContent(), Field.Store.YES));
- }
- if (ObjectUtil.isNotEmpty(luceneLogDto.getMethod())) {
- document.add(new StringField("method", luceneLogDto.getMethod(), Field.Store.YES));
- }
- if (ObjectUtil.isNotEmpty(luceneLogDto.getStatus_code())) {
- document.add(new StringField("status_code", luceneLogDto.getStatus_code(), Field.Store.YES));
- }
- if (ObjectUtil.isNotEmpty(luceneLogDto.getRequestparam())) {
- document.add(new StringField("requestparam", luceneLogDto.getRequestparam(), Field.Store.YES));
- }
- if (ObjectUtil.isNotEmpty(luceneLogDto.getResponseparam())) {
- document.add(new StringField("responseparam", luceneLogDto.getResponseparam(), Field.Store.YES));
- }
- document.add(new StringField("logType", luceneLogDto.getLogType(), Field.Store.YES));
- document.add(new StringField("logTime", DateUtil.format(new DateTime(), "yyyy-MM-dd HH:mm:ss.SSS"), Field.Store.YES));
- indexWriter.addDocument(document);
- //记录索引结束时间
- long endTime = System.currentTimeMillis();
- indexWriter.commit();
- //实现日志文件按业务独立生成日志文件到指定路径
- DynamicLogger loggerBuilder =new DynamicLogger(logPath+"\\"+luceneLogDto.getLogType()+"\\");
- Logger logger = loggerBuilder.getLogger(luceneLogDto.getDevice_code());
- logger.info("{}",luceneLogDto.toString());
- } catch (Exception e) {
- log.error(e.getMessage(), e);
- }
- }
-
- @Override
- public void extLog(String name, String message) {
- try {
- MDC.put(name, name);
- log.info("{}", message);
- } catch (Exception e) {
- e.printStackTrace();
- } finally {
- MDC.remove(name);
- }
- }
-}
+//package org.nl.system.service.lucene.impl;
+//
+//import cn.hutool.core.date.DateTime;
+//import cn.hutool.core.date.DateUtil;
+//import cn.hutool.core.util.ObjectUtil;
+//import lombok.RequiredArgsConstructor;
+//import lombok.SneakyThrows;
+//import lombok.extern.slf4j.Slf4j;
+//import org.apache.lucene.document.Document;
+//import org.apache.lucene.document.Field;
+//import org.apache.lucene.document.StringField;
+//import org.apache.lucene.index.IndexWriter;
+//import org.nl.common.enums.LogTypeEnum;
+//import org.nl.config.lucene.DynamicLogger;
+//import org.nl.config.lucene.LuceneIndexWriter;
+//import org.nl.system.service.lucene.LuceneExecuteLogService;
+//import org.nl.system.service.lucene.dto.LuceneLogDto;
+//import org.slf4j.Logger;
+//import org.slf4j.MDC;
+//import org.springframework.beans.factory.annotation.Value;
+//import org.springframework.stereotype.Service;
+//
+//import java.io.IOException;
+//
+///**
+// * @author jlm
+// * @description 服务实现
+// * @date 2023-04-11
+// */
+//@Service
+//@RequiredArgsConstructor
+//@Slf4j
+//public class LuceneExecuteLogServiceImpl implements LuceneExecuteLogService {
+//
+// /**
+// * 日志目录
+// */
+// @Value("${logging.file.path}")
+// private String logPath;
+//
+// @Override
+// public void deviceItemValue(String device_code, String key, String value) {
+// String now = DateUtil.now();
+// }
+//
+// @SneakyThrows
+// @Override
+// public void deviceExecuteLog(LuceneLogDto luceneLogDto) {
+// luceneLogDto.setLogType(LogTypeEnum.DEVICE_LOG.getDesc());
+// addIndex(luceneLogDto);
+// }
+//
+// @Override
+// public void interfaceExecuteLog(LuceneLogDto luceneLogDto) throws IOException {
+// luceneLogDto.setLogType(LogTypeEnum.INTERFACE_LOG.getDesc());
+// addIndex(luceneLogDto);
+// }
+//
+// private void addIndex(LuceneLogDto luceneLogDto) throws IOException {
+// IndexWriter indexWriter = LuceneIndexWriter.getIndexWriter();
+// //创建一个Document对象
+// Document document = new Document();
+// try {
+// //记录索引开始时间
+// long startTime = System.currentTimeMillis();
+// //向document对象中添加域。
+// if (ObjectUtil.isNotEmpty(luceneLogDto.getDevice_code())) {
+// document.add(new StringField("device_code", luceneLogDto.getDevice_code(), Field.Store.YES));
+// }
+// if (ObjectUtil.isNotEmpty(luceneLogDto.getContent())) {
+// document.add(new StringField("fieldContent", luceneLogDto.getContent(), Field.Store.YES));
+// }
+// if (ObjectUtil.isNotEmpty(luceneLogDto.getMethod())) {
+// document.add(new StringField("method", luceneLogDto.getMethod(), Field.Store.YES));
+// }
+// if (ObjectUtil.isNotEmpty(luceneLogDto.getStatus_code())) {
+// document.add(new StringField("status_code", luceneLogDto.getStatus_code(), Field.Store.YES));
+// }
+// if (ObjectUtil.isNotEmpty(luceneLogDto.getRequestparam())) {
+// document.add(new StringField("requestparam", luceneLogDto.getRequestparam(), Field.Store.YES));
+// }
+// if (ObjectUtil.isNotEmpty(luceneLogDto.getResponseparam())) {
+// document.add(new StringField("responseparam", luceneLogDto.getResponseparam(), Field.Store.YES));
+// }
+// document.add(new StringField("logType", luceneLogDto.getLogType(), Field.Store.YES));
+// document.add(new StringField("logTime", DateUtil.format(new DateTime(), "yyyy-MM-dd HH:mm:ss.SSS"), Field.Store.YES));
+// indexWriter.addDocument(document);
+// //记录索引结束时间
+// long endTime = System.currentTimeMillis();
+// indexWriter.commit();
+// //实现日志文件按业务独立生成日志文件到指定路径
+// DynamicLogger loggerBuilder =new DynamicLogger(logPath+"\\"+luceneLogDto.getLogType()+"\\");
+// Logger logger = loggerBuilder.getLogger(luceneLogDto.getDevice_code());
+// logger.info("{}",luceneLogDto.toString());
+// } catch (Exception e) {
+// log.error(e.getMessage(), e);
+// }
+// }
+//
+// @Override
+// public void extLog(String name, String message) {
+// try {
+// MDC.put(name, name);
+// log.info("{}", message);
+// } catch (Exception e) {
+// e.printStackTrace();
+// } finally {
+// MDC.remove(name);
+// }
+// }
+//}
diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/menu/impl/SysMenuServiceImpl.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/menu/impl/SysMenuServiceImpl.java
index 2fa76ef4a..d6e393f11 100644
--- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/menu/impl/SysMenuServiceImpl.java
+++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/system/service/menu/impl/SysMenuServiceImpl.java
@@ -21,7 +21,6 @@ import org.nl.config.IdUtil;
import org.nl.config.language.LangProcess;
import org.nl.system.service.dict.dao.Dict;
import org.nl.system.service.dict.dao.mapper.SysDictMapper;
-import org.nl.system.service.lucene.LuceneExecuteLogService;
import org.nl.system.service.menu.dto.MenuDto;
import org.nl.system.service.menu.ISysMenuService;
import org.nl.system.service.menu.dao.SysMenu;
@@ -54,9 +53,6 @@ public class SysMenuServiceImpl extends ServiceImpl impl
@Autowired
private SysDictMapper sysDictMapper;
- @Autowired
- private LuceneExecuteLogService luceneExecuteLogService;
-
@Override
public List queryAll(Map param) {
// 父节点标识
diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/WmsToAcsService.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/WmsToAcsService.java
index e7448e353..47334d7d5 100644
--- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/WmsToAcsService.java
+++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/WmsToAcsService.java
@@ -1,5 +1,7 @@
package org.nl.wms.ext.acs.service;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
import org.nl.wms.ext.acs.service.dto.to.wms.AcsResponse;
import org.nl.wms.sch.task_manage.AcsTaskDto;
@@ -21,4 +23,13 @@ public interface WmsToAcsService {
*/
Map issueTaskToAcs(List list);
+ /**
+ * 更新任务状态
+ *
+ * @param arr /
+ * @return JSONObject
+ */
+ JSONObject updateTask(JSONArray arr);
+
+ JSONObject getHotPointStatus(JSONArray deviceRows);
}
diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/impl/WmsToAcsServiceImpl.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/impl/WmsToAcsServiceImpl.java
index dc6918f59..ecc1595b9 100644
--- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/impl/WmsToAcsServiceImpl.java
+++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/impl/WmsToAcsServiceImpl.java
@@ -34,4 +34,16 @@ public class WmsToAcsServiceImpl implements WmsToAcsService {
return AcsUtil.notifyAcs(api, jsonArray);
}
+ @Override
+ public JSONObject updateTask(JSONArray arr) {
+ String api = "api/wms/updateTask";
+ return AcsUtil.notifyAcs(api, arr);
+ }
+
+ @Override
+ public JSONObject getHotPointStatus(JSONArray deviceRows) {
+ String api = "api/wms/querydevice";
+ return AcsUtil.notifyAcs(api, deviceRows);
+ }
+
}
diff --git a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/pda/mps/controller/RawFoilPdaController.java b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/pda/mps/controller/RawFoilPdaController.java
index f12901399..2ca26d52e 100644
--- a/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/pda/mps/controller/RawFoilPdaController.java
+++ b/lms2/nladmin-system/nlsso-server/src/main/java/org/nl/wms/pda/mps/controller/RawFoilPdaController.java
@@ -5,7 +5,6 @@ import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.nl.common.logging.annotation.Log;
import org.nl.wms.pda.mps.service.RawFoilPdaService;
-import org.nl.wms.pdm.bi.service.IpdmBiRawfoilworkorderService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
@@ -45,5 +44,10 @@ public class RawFoilPdaController {
public ResponseEntity