add lucene

2023-05-09 15:37:26 +08:00
parent 9b8d295fe7
commit f6c8f65177
25 changed files with 1049 additions and 92 deletions
--- a/wcs/nladmin-system/src/main/java/org/nl/acs/device_driver/basedriver/hailiang_one/hailiang_special_device/HailiangSpecialDeviceDriver.java
+++ b/wcs/nladmin-system/src/main/java/org/nl/acs/device_driver/basedriver/hailiang_one/hailiang_special_device/HailiangSpecialDeviceDriver.java
@@ -27,6 +27,8 @@ import org.nl.acs.monitor.DeviceStageMonitor;
 import org.nl.acs.opc.Device;
 import org.nl.acs.order.service.ProduceshiftorderService;
 import org.nl.acs.order.service.dto.ProduceshiftorderDto;
+import org.nl.modules.lucene.service.LuceneExecuteLogService;
+import org.nl.modules.lucene.service.dto.LuceneLogDto;
 import org.nl.modules.wql.util.SpringContextHolder;
 import org.springframework.beans.factory.annotation.Autowired;

@@ -49,7 +51,7 @@ public class HailiangSpecialDeviceDriver extends AbstractOpcDeviceDriver impleme
    ProduceshiftorderService produceshiftorderService = SpringContextHolder.getBean(ProduceshiftorderService.class);
    @Autowired
    DeviceErrorLogService deviceErrorLogService = SpringContextHolder.getBean(DeviceErrorLogServiceImpl.class);
-
+    LuceneExecuteLogService luceneExecuteLogService = SpringContextHolder.getBean("luceneExecuteLogServiceImpl");
    int mode = 0;
    int error = 0;
    int now_one_box_num = 0;
@@ -107,6 +109,7 @@ public class HailiangSpecialDeviceDriver extends AbstractOpcDeviceDriver impleme

            if (mode != last_mode) {
                feedDeviceStatusFlag = false;
+                luceneExecuteLogService.deviceExecuteLog(new LuceneLogDto(this.getDevice().getOpc_server_code(), this.getDevice().getOpc_plc_code(), this.device_code, ItemProtocol.item_mode, String.valueOf(this.last_mode), String.valueOf(this.mode)));
                logServer.deviceExecuteLog(this.device_code, "", "", "信号mode：" + last_mode + "->" + mode);
            }

--- a/wcs/nladmin-system/src/main/java/org/nl/modules/logging/DeviceCodeDir.java
+++ b/wcs/nladmin-system/src/main/java/org/nl/modules/logging/DeviceCodeDir.java
@@ -0,0 +1,23 @@
+package org.nl.modules.logging;
+
+import ch.qos.logback.core.PropertyDefinerBase;
+import org.springframework.stereotype.Component;
+
+// 通过实现logback的PropertyDefinerBase方法,动态定义logback配置中的变量
+@Component
+public class DeviceCodeDir extends PropertyDefinerBase {
+
+    String deviceCodeDir = "";
+    public void setPropertyValue(String deviceCode) {
+        deviceCodeDir = deviceCode ;
+    }
+
+    @Override
+    public String getPropertyValue() {
+        if (deviceCodeDir == ""){
+            deviceCodeDir = "默认";
+        }
+        return "默认";
+    }
+
+}
--- a/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/common/Indexer.java
+++ b/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/common/Indexer.java
@@ -0,0 +1,178 @@
+package org.nl.modules.lucene.common;
+
+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索引器
+ */
+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.numDocs();
+        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();
+//        doc.add(new TextField("content", jsonDoc, Field.Store.YES));
+        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<String> 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", device_id, Field.Store.YES));
+        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 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 Field());
+                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("建立索引成功-----关闭资源");
+    }
+}
--- a/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/common/LuceneIndexWriter.java
+++ b/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/common/LuceneIndexWriter.java
@@ -0,0 +1,66 @@
+package org.nl.modules.lucene.common;
+
+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.nl.modules.lucene.config.UrlConfig;
+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;
+
+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(){
+            @Override
+            public void run() {
+                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;
+    }
+
+
+}
--- a/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/common/Searcher.java
+++ b/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/common/Searcher.java
@@ -0,0 +1,140 @@
+package org.nl.modules.lucene.common;
+
+import cn.hutool.core.date.DateTime;
+import cn.hutool.core.date.DateUtil;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.lucene.document.Document;
+import org.apache.lucene.index.DirectoryReader;
+import org.apache.lucene.index.IndexReader;
+import org.apache.lucene.index.Term;
+import org.apache.lucene.search.*;
+import org.apache.lucene.store.Directory;
+import org.apache.lucene.store.FSDirectory;
+import org.apache.lucene.util.BytesRef;
+
+import java.nio.file.Paths;
+import java.util.ArrayList;
+import java.util.Calendar;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * lucene查询器
+ */
+@Slf4j
+public class Searcher {
+
+    public static Map<String, Object> search(String indexDir, String ext,Map whereJson) throws Exception {
+        //获取要查询的路径，也就是索引所在的位置
+        Directory dir = FSDirectory.open(Paths.get(indexDir));
+        IndexReader reader = DirectoryReader.open(dir);
+        //构建IndexSearcher
+        IndexSearcher searcher = new IndexSearcher(reader);
+        //标准分词器，会自动去掉空格啊，is a the等单词
+//        Analyzer analyzer = new StandardAnalyzer();
+//        Analyzer analyzer = new IKAnalyzer(false);
+        //查询解析器
+//        QueryParser queryParser = new QueryParser("fieldContent", analyzer);
+
+        //记录索引开始时间
+        long startTime = System.currentTimeMillis();
+        // 实际上Lucene本身不支持分页。因此我们需要自己进行逻辑分页。我们要准备分页参数：
+        int pageSize = Integer.parseInt(whereJson.get("size").toString());// 每页条数
+        int pageNum = Integer.parseInt(whereJson.get("page").toString());// 当前页码
+        int start = pageNum * pageSize;// 当前页的起始条数
+        int end = start + pageSize;// 当前页的结束条数（不能包含）
+        // 创建排序对象,需要排序字段SortField，参数：字段的名称、字段的类型、是否反转如果是false，升序。true降序
+        Sort sort = new Sort(new SortField("logTime", SortField.Type.DOC,true));
+
+        TopDocs docs = null;
+        BooleanQuery.Builder booleanQueryBuilder = new BooleanQuery.Builder();
+        //时间范围查询
+        String startDate = (String) whereJson.get("begin_time");
+        String endDate = (String) whereJson.get("end_time");
+        Calendar calendar=Calendar.getInstance();
+        calendar.set(1970, 0, 1);
+        if (startDate == null){
+            startDate = DateUtil.format(calendar.getTime(),"yyyy-MM-dd HH:mm:ss.SSS");
+        }else{
+            startDate = LuceneIndexWriter.getDate(startDate);
+        }
+        if (endDate == null){
+            endDate = DateUtil.format(new DateTime(),"yyyy-MM-dd HH:mm:ss.SSS");
+        } else {
+            endDate = LuceneIndexWriter.getDate(endDate);
+        }
+        TermRangeQuery termRangeQuery = new TermRangeQuery("logTime", new BytesRef(startDate), new BytesRef(endDate), true, true);
+        booleanQueryBuilder.add(termRangeQuery,BooleanClause.Occur.MUST);
+        if (whereJson.get("device_code") != null){
+            Query termQuery = new TermQuery(new Term("device_code", (String) whereJson.get("device_code")));
+            booleanQueryBuilder.add(termQuery,BooleanClause.Occur.MUST);
+        }
+        if (whereJson.get("method") != null){
+            Query termQuery = new TermQuery(new Term("method", (String) whereJson.get("method")));
+            booleanQueryBuilder.add(termQuery,BooleanClause.Occur.MUST);
+        }
+        if (whereJson.get("status_code") != null){
+            Query termQuery = new TermQuery(new Term("status_code", (String) whereJson.get("status_code")));
+            booleanQueryBuilder.add(termQuery,BooleanClause.Occur.MUST);
+        }
+        if (whereJson.get("requestparam") != null){
+            WildcardQuery query = new  WildcardQuery(new Term("requestparam", "*"+(String) whereJson.get("requestparam")+"*"));
+            booleanQueryBuilder.add(query,BooleanClause.Occur.MUST);
+        }
+        if (whereJson.get("responseparam") != null){
+            WildcardQuery query = new  WildcardQuery(new Term("responseparam", "*"+(String) whereJson.get("responseparam")+"*"));
+            booleanQueryBuilder.add(query,BooleanClause.Occur.MUST);
+        }
+        if (whereJson.get("blurry") != null) {
+            WildcardQuery query = new  WildcardQuery(new Term("fieldContent", "*"+(String) whereJson.get("blurry")+"*"));
+            booleanQueryBuilder.add(query, BooleanClause.Occur.MUST);
+        }
+        docs = searcher.search(booleanQueryBuilder.build(), end,sort);
+        //记录索引时间
+        long endTime = System.currentTimeMillis();
+        log.info("匹配{}共耗时{}毫秒",booleanQueryBuilder.build(),(endTime-startTime));
+        log.info("查询到{}条日志文件", docs.totalHits.value);
+        List<String> list = new ArrayList<>();
+        ScoreDoc[] scoreDocs = docs.scoreDocs;
+        if (end > docs.totalHits.value) end = (int) docs.totalHits.value;
+        JSONArray array = new JSONArray();
+
+        for (int i = start; i < end; i++) {
+            ScoreDoc scoreDoc = scoreDocs[i];
+            Document doc = reader.document(scoreDoc.doc);
+            JSONObject object = new JSONObject();
+            object.put("content",doc.get("fieldContent"));
+            object.put("device_code",doc.get("device_code"));
+            object.put("logTime",doc.get("logTime"));
+            object.put("method",doc.get("method"));
+            object.put("status_code",doc.get("status_code"));
+            object.put("requestparam",doc.get("requestparam"));
+            object.put("responseparam",doc.get("responseparam"));
+            if(doc.get("fieldContent") != null) {
+                array.add(object);
+            }
+        }
+        for(Object logDto:array){
+            log.info(logDto.toString());
+        }
+        reader.close();
+        JSONObject jo = new JSONObject();
+        jo.put("content", array);
+        jo.put("totalElements", docs.totalHits.value);
+        return jo;
+    }
+
+    public static void main(String[] args) {
+        String indexDir = "D:\\lucene\\index";
+        //查询这个字符串
+        String q = "07.832";
+        Map whereJson = null;
+        try {
+            search(indexDir, q,whereJson);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+}
--- a/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/config/StaticConfig.java
+++ b/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/config/StaticConfig.java
@@ -0,0 +1,21 @@
+package org.nl.modules.lucene.config;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @deprecated 设置静态参数初始化
+ */
+@Configuration
+public class StaticConfig {
+    //日志索引目录
+    @Value("${lucene.index.path}")
+    private String luceneDir;
+
+    @Bean
+    public int initStatic() {
+        UrlConfig.setLuceneUrl(luceneDir);
+        return 0;
+    }
+}
--- a/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/config/UrlConfig.java
+++ b/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/config/UrlConfig.java
@@ -0,0 +1,13 @@
+package org.nl.modules.lucene.config;
+
+public class UrlConfig {
+    public static String luceneUrl;
+
+    public static String getLuceneUrl() {
+        return luceneUrl;
+    }
+
+    public static void setLuceneUrl(String luceneUrl) {
+        UrlConfig.luceneUrl = luceneUrl;
+    }
+}
--- a/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/enums/LogTypeEnum.java
+++ b/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/enums/LogTypeEnum.java
@@ -0,0 +1,15 @@
+package org.nl.modules.lucene.enums;
+
+public enum LogTypeEnum {
+    DEVICE_LOG("设备日志"),
+    INTERFACE_LOG("接口日志");
+
+    private String desc;
+
+    LogTypeEnum(String desc) {
+        this.desc = desc;
+    }
+    public String getDesc() {
+        return desc;
+    }
+}
--- a/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/rest/LuceneController.java
+++ b/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/rest/LuceneController.java
@@ -0,0 +1,43 @@
+package org.nl.modules.lucene.rest;
+
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.nl.modules.logging.annotation.Log;
+import org.nl.modules.lucene.service.LuceneService;
+import org.springframework.data.domain.Pageable;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.Map;
+
+
+@RestController
+@RequiredArgsConstructor
+@Api(tags = "日志检索")
+@RequestMapping("/api/lucene")
+@Slf4j
+public class LuceneController {
+
+    private final LuceneService luceneService;
+
+    @GetMapping("/labels/values")
+    @ApiOperation("获取标签")
+    public ResponseEntity<Object> labelsValues() {
+        return new ResponseEntity<>(luceneService.getLabelsValues(), HttpStatus.OK);
+    }
+
+
+    @GetMapping("/getAll")
+    @Log("日志检索")
+    @ApiOperation("日志检索")
+    //@PreAuthorize("@el.check('task:list')")
+    public ResponseEntity<Object> get(@RequestParam Map whereJson, Pageable page) {
+        return new ResponseEntity<>(luceneService.getAll(whereJson, page), HttpStatus.OK);
+    }
+}
--- a/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/service/LuceneExecuteLogService.java
+++ b/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/service/LuceneExecuteLogService.java
@@ -0,0 +1,41 @@
+package org.nl.modules.lucene.service;
+
+
+import org.nl.modules.lucene.service.dto.LuceneLogDto;
+
+import java.io.IOException;
+
+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  日志结果对象
+     */
+    void interfaceExecuteLog(LuceneLogDto luceneLogDto) throws IOException;
+
+    /**
+     * 设备执行日志,会保留历史记录
+     *
+     * @param name  日志名称
+     * @param message      日志信息
+     */
+    void extLog(String name, String message);
+
+
+}
--- a/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/service/LuceneService.java
+++ b/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/service/LuceneService.java
@@ -0,0 +1,24 @@
+package org.nl.modules.lucene.service;
+
+import com.alibaba.fastjson.JSONArray;
+import org.springframework.data.domain.Pageable;
+
+import java.util.Map;
+
+
+public interface LuceneService {
+    /**
+     * 获取labels和values树
+     * @return
+     */
+    JSONArray getLabelsValues();
+
+    /**
+     * 获取数据分页
+     *
+     * @param whereJson 条件
+     * @param page      分页参数
+     * @return Map<String, Object>
+     */
+    Map<String, Object> getAll(Map whereJson, Pageable page);
+}
--- a/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/service/dto/LuceneLogDto.java
+++ b/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/service/dto/LuceneLogDto.java
@@ -0,0 +1,85 @@
+package org.nl.modules.lucene.service.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class LuceneLogDto {
+
+    /* 日志标识 */
+    private String log_uuid;
+    /*日志类型*/
+    private String logType;
+    /*设备编号*/
+    private String device_code;
+    /*内容详情*/
+    private String content;
+
+    /* 任务编码 */
+    private String task_code;
+
+    /* 指令编码 */
+    private String instruct_code;
+
+    /* 任务标识 */
+    private String task_id;
+
+    /* 载具号 */
+    private String vehicle_code;
+
+    /* 备注 */
+    private String remark;
+
+    /* 日志类型 */
+    private String log_type;
+
+    /* 方法 */
+    private String method;
+
+    /* 请求参数 */
+    private String requestparam;
+
+    /* 响应参数 */
+    private String responseparam;
+
+    /* 请求地址 */
+    private String requesturl;
+
+    /* 状态码 */
+    private String status_code;
+
+    /* 是否删除 1:是；0：否 */
+    private String is_delete;
+
+    /* 创建者 */
+    private String create_by;
+
+    /* 创建时间  YYYY-MM-DD hh:mm:ss */
+    private String create_time;
+
+    /* 修改者 */
+    private String update_by;
+
+    /* 修改时间 */
+    private String update_time;
+
+
+    public LuceneLogDto(final String opc_server_code, final String opc_plc_code,
+                        final String device_code, final String to_home, final String last_home,
+                        final String home) {
+        super();
+        this.device_code = device_code;
+        this.content = "信号 ["
+                + opc_server_code + "."
+                + opc_plc_code + "."
+                + device_code + "."
+                + to_home + "] 发生变更 "
+                + last_home + " -> "
+                + home;
+    }
+}
--- a/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/service/impl/LuceneExecuteLogServiceImpl.java
+++ b/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/service/impl/LuceneExecuteLogServiceImpl.java
@@ -0,0 +1,101 @@
+package org.nl.modules.lucene.service.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.modules.lucene.common.LuceneIndexWriter;
+import org.nl.modules.lucene.enums.LogTypeEnum;
+import org.nl.modules.lucene.service.LuceneExecuteLogService;
+import org.nl.modules.lucene.service.dto.LuceneLogDto;
+import org.slf4j.MDC;
+import org.springframework.stereotype.Service;
+
+import java.io.IOException;
+
+/**
+ * @author jlm
+ * @description 服务实现
+ * @date 2023-04-11
+ */
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class LuceneExecuteLogServiceImpl implements LuceneExecuteLogService {
+
+    @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));
+//        document.add(new TextField("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();
+            log.info("建立索引共耗时{}毫秒", endTime - startTime);
+            indexWriter.commit();
+            MDC.put("DEVICECODE", luceneLogDto.getDevice_code());
+        } 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);
+        }
+    }
+}
--- a/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/service/impl/LuceneServiceImpl.java
+++ b/wcs/nladmin-system/src/main/java/org/nl/modules/lucene/service/impl/LuceneServiceImpl.java
@@ -0,0 +1,85 @@
+package org.nl.modules.lucene.service.impl;
+
+import cn.hutool.core.util.CharsetUtil;
+import cn.hutool.http.HttpUtil;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.nl.modules.lucene.common.Searcher;
+import org.nl.modules.lucene.service.LuceneService;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.domain.Pageable;
+import org.springframework.stereotype.Service;
+
+import java.util.Map;
+
+
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class LuceneServiceImpl implements LuceneService {
+
+    @Value("${loki.url}")
+    private String lokiUrl;
+
+    @Value("${loki.systemName}")
+    private String systemName;
+
+    //日志索引目录
+    @Value("${lucene.index.path}")
+    private  String luceneUrl;
+
+    /**
+     * 获取labels和values树
+     *
+     * @return
+     */
+    @Override
+    public JSONArray getLabelsValues() {
+        JSONArray result = new JSONArray();
+        // 获取所有标签
+        String labelString = HttpUtil.get(lokiUrl + "/labels", CharsetUtil.CHARSET_UTF_8);
+        JSONObject parse = (JSONObject) JSONObject.parse(labelString);
+        JSONArray labels = parse.getJSONArray("data");
+        for (int i=0; i<labels.size(); i++) {
+            // 获取标签下的所有值
+            String valueString = HttpUtil.get(lokiUrl + "/label/" + labels.getString(i) + "/values", CharsetUtil.CHARSET_UTF_8);
+            JSONObject parse2 = (JSONObject) JSONObject.parse(valueString);
+            JSONArray values = parse2.getJSONArray("data");
+            JSONArray children = new JSONArray();
+            // 组成树形状态 两级
+            for (int j=0; j<values.size(); j++) {
+                JSONObject leaf = new JSONObject();
+                leaf.put("label", values.getString(j));
+                leaf.put("value", values.getString(j));
+                children.add(leaf);
+            }
+
+            JSONObject node = new JSONObject();
+            node.put("label", labels.getString(i));
+            node.put("value", labels.getString(i));
+            node.put("children", children);
+            result.add(node);
+        }
+        return result;
+    }
+
+    @Override
+    public Map<String, Object> getAll(Map whereJson, Pageable page) {
+        JSONObject jo = new JSONObject();
+        try {
+            JSONObject jsonObject = (JSONObject) Searcher.search(luceneUrl, "", whereJson);
+            JSONArray array = jsonObject.getJSONArray("content");
+            int totalElements = Integer.parseInt(jsonObject.get("totalElements").toString());
+            jo.put("content", array);
+            jo.put("totalElements", totalElements);
+        } catch (Exception e) {
+            log.error("索引查询为空", e);
+            throw new NullPointerException("索引查询为空");
+        }
+
+        return jo;
+    }
+
+}