From 9a8508951ab424848372d3fe5d18be5cf0a16dd1 Mon Sep 17 00:00:00 2001
From: zhn <947514737@qq.com>
Date: Wed, 24 Aug 2022 20:06:06 +0800
Subject: [PATCH] =?UTF-8?q?=E6=90=9C=E7=B4=A2=E4=B8=AD=E5=BF=83=E4=BF=AE?=
 =?UTF-8?q?=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../BussDocumentLibraryEOController.java      |  6 ++
 .../IBussDocumentLibraryEOService.java        |  2 +
 .../BussDocumentLibraryEOServiceImpl.java     | 76 ++++++++++++++++++-
 3 files changed, 82 insertions(+), 2 deletions(-)

diff --git a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/controller/BussDocumentLibraryEOController.java b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/controller/BussDocumentLibraryEOController.java
index 3fc1bd7d9..4227e3341 100644
--- a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/controller/BussDocumentLibraryEOController.java
+++ b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/controller/BussDocumentLibraryEOController.java
@@ -494,4 +494,10 @@ public class BussDocumentLibraryEOController extends JeroController<BussDocument
 		String title = bussDocumentLibraryEOService.getTitle(id, cut);
 		return Result.OK(title);
 	}
+	@ApiOperation(value="编辑ES数据(添加module_type_flag)", notes="编辑ES数据(添加module_type_flag)")
+	@GetMapping(value = "/updateES")
+	public Result<?> getTitle() {
+		int count = bussDocumentLibraryEOService.updateES();
+		return Result.OK(count);
+	}
 }
diff --git a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/IBussDocumentLibraryEOService.java b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/IBussDocumentLibraryEOService.java
index 4b392e7fb..cc0bffe37 100644
--- a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/IBussDocumentLibraryEOService.java
+++ b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/IBussDocumentLibraryEOService.java
@@ -223,4 +223,6 @@ public interface IBussDocumentLibraryEOService extends IService<BussDocumentLibr
     String getTitle(String id,String cut);
 
     String sqlJoint(List<QueryConditionVO> queryConditionVOList);
+
+    int updateES();
 }
diff --git a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/impl/BussDocumentLibraryEOServiceImpl.java b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/impl/BussDocumentLibraryEOServiceImpl.java
index bef304927..6ff4ef6bd 100644
--- a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/impl/BussDocumentLibraryEOServiceImpl.java
+++ b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/impl/BussDocumentLibraryEOServiceImpl.java
@@ -51,6 +51,7 @@ import com.jero.modules.message.websocket.WebSocket;
 import com.jero.modules.ocr.service.IOcrRecordEOService;
 import com.jero.modules.oss.entity.OSSFile;
 import com.jero.modules.oss.service.IOSSFileService;
+import com.jero.modules.searchcenter.enums.ModuleTypeFlagEnum;
 import com.jero.modules.split.common.FileUnZip;
 import com.jero.modules.split.entity.SarFileSplitInfoEO;
 import com.jero.modules.split.service.ISarFileSplitInfoService;
@@ -1759,6 +1760,8 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
                 for (OSSFile ossFile : ossFileList) {
                     Map<String, Object> stringMapCn = new HashMap<>();
                     Map<String, Object> stringMapEn = new HashMap<>();
+                    stringMapCn.put("create_time",new Date());
+                    stringMapEn.put("create_time",new Date());
                     String fileText = "";
                     if (ossFile.getFileName().endsWith(".doc")
                             || ossFile.getFileName().endsWith(".docx")
@@ -1839,11 +1842,19 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
             } else {
                 Map<String, Object> stringMapCn = new HashMap<>();
                 Map<String, Object> stringMapEn = new HashMap<>();
+                Map<String, Object> mapBaseDateCn = new HashMap<>();
+                Map<String, Object> mapBaseDateEn = new HashMap<>();
+                stringMapCn.put("create_time",new Date());
+                stringMapEn.put("create_time",new Date());
+                mapBaseDateCn.put("create_time",new Date());
+                mapBaseDateEn.put("create_time",new Date());
                 for (OnlCgformField onlCgformField : searchFieldList) {
                     String s = StringUtils.valueOf(map.get(onlCgformField.getDbFieldName()));
                     if(StringUtils.isNotBlank(s)){
                         stringMapCn.put(onlCgformField.getDbFieldName(), s);
                         stringMapEn.put(onlCgformField.getDbFieldName(), s);
+                        mapBaseDateCn.put(onlCgformField.getDbFieldName(), s);
+                        mapBaseDateEn.put(onlCgformField.getDbFieldName(), s);
                     }
                 }
                 //封装中文的全文内容(es)
@@ -1856,8 +1867,23 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
                         StringUtils.valueOf(map.get("title")), "", "",
                         cutEn, stringMapEn,SEARCH_FLAG);
                 stringMapEn.put("file_sort",idTemp+"_"+1);
+
+                //用于全文带条件查询-----------------------------
+                //封装中文的全文内容(es)
+                putMapCn(idTemp+"1", StringUtils.valueOf(map.get("serial_number")),  "文档库", sbCn.toString(),
+                        StringUtils.valueOf(map.get("title")), "", "",
+                        cutCn, mapBaseDateCn, null);
+                mapBaseDateCn.put("file_sort",idTemp+"_"+1);
+                //封装英文的全文内容(es)
+                putMapCn(idTemp+"2", StringUtils.valueOf(map.get("serial_number")), "document library", sbEn.toString(),
+                        StringUtils.valueOf(map.get("title")), "", "",
+                        cutEn, mapBaseDateEn,null);
+                stringMapEn.put("file_sort",idTemp+"_"+1);
+                //用于全文带条件查询-----------------------------
                 mapListTempCn.add(stringMapCn);
                 mapListTempEn.add(stringMapEn);
+                mapListTempCn.add(mapBaseDateCn);
+                mapListTempEn.add(mapBaseDateEn);
             }
         } catch (Exception e) {
             e.printStackTrace();
@@ -1879,6 +1905,8 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
         //添加es
         map.put("id", idTemp);
         map.put("module_type", "文档库");
+        map.put("module_type_flag", ModuleTypeFlagEnum.DOCUMENT_LIBRARY.getValue());
+        map.put("create_time", new Date());
         map.put("file_text",fileTextAll);
         JSONObject jsonObject = JSON.parseObject(JSON.toJSONString(map));
         JSONArray arrayCn = JSONArray.parseArray(JSON.toJSONString(mapListTempCn));
@@ -2224,6 +2252,14 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
             if(StringUtils.isNotBlank(issueTime)){
                 issueTimeDate = df.parse(issueTime);
             }
+            if(ObjectUtils.isNotEmpty(map.get("es_update_flag"))){
+                if(ObjectUtils.isNotEmpty(map.get("implement_time"))){
+                    map.put("implement_time",df.format(map.get("implement_time")));
+                }
+                if(ObjectUtils.isNotEmpty(map.get("xin1_che1_xing2_shi2_shi1_ri4_qi1"))){
+                    map.put("xin1_che1_xing2_shi2_shi1_ri4_qi1",df.format(map.get("xin1_che1_xing2_shi2_shi1_ri4_qi1")));
+                }
+            }
             String implementTime = (String) map.get("implement_time");//在产车实施日期
             String newCarimplementTime = (String) map.get("xin1_che1_xing2_shi2_shi1_ri4_qi1");//新车型实施日期
             if (StringUtils.isNotBlank(implementTime) && ObjectUtils.isNotEmpty(issueTimeDate)) {
@@ -2398,7 +2434,7 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
                     String key = entry.getKey();
                     String value = StringUtils.valueOf(entry.getValue());
                     if(fileFieldList.contains(key)){
-                        if(!"null".equals(value)){
+                        if(!"null".equals(value) && StringUtils.isNotBlank(value)){
                             connectIdList.add(value);
                         }
                     }
@@ -2413,6 +2449,12 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
                     //之前没有上传过文件
                     Map<String, Object> stringMapCn = new HashMap<>();
                     Map<String, Object> stringMapEn = new HashMap<>();
+                    Map<String, Object> mapBaseDateCn = new HashMap<>();
+                    Map<String, Object> mapBaseDateEn = new HashMap<>();
+                    stringMapCn.put("create_time",new Date());
+                    stringMapEn.put("create_time",new Date());
+                    mapBaseDateCn.put("create_time",new Date());
+                    mapBaseDateEn.put("create_time",new Date());
                     for (OnlCgformField onlCgformField : searchFieldList) {
                         String s = (String) map.get(onlCgformField.getDbFieldName());
                         if(FieldTypeEnum.DATE_SINGLE.getValue().equals(onlCgformField.getFieldShowType()) && StringUtils.isNotBlank(s)){
@@ -2435,8 +2477,23 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
                             cutEn, stringMapEn,SEARCH_FLAG);
                     stringMapEn.put("file_sort", StringUtils.valueOf(map.get("id")+"_"+1));
 
+                    //用于全文带条件查询-----------------------------
+                    //封装中文的全文内容(es)
+                    putMapCn(StringUtils.valueOf(map.get("id"))+"1", StringUtils.valueOf(map.get("serial_number")),  "文档库", sbCn.toString(),
+                            StringUtils.valueOf(map.get("title")), "", "",
+                            cutCn, mapBaseDateCn, null);
+                    mapBaseDateCn.put("file_sort",StringUtils.valueOf(map.get("id")+"_"+1));
+                    //封装英文的全文内容(es)
+                    putMapCn(StringUtils.valueOf(map.get("id"))+"2", StringUtils.valueOf(map.get("serial_number")), "document library", sbEn.toString(),
+                            StringUtils.valueOf(map.get("title")), "", "",
+                            cutEn, mapBaseDateEn,null);
+                    stringMapEn.put("file_sort",StringUtils.valueOf(map.get("id")+"_"+1));
+                    //用于全文带条件查询-----------------------------
+
                     mapListTempCn.add(stringMapCn);
                     mapListTempEn.add(stringMapEn);
+                    mapListTempCn.add(mapBaseDateCn);
+                    mapListTempEn.add(mapBaseDateEn);
                 }
             }
 
@@ -2473,6 +2530,8 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
         bussDocumentLibraryEOMapper.deleteById((String) map.get("id"));
         bussDocumentLibraryEOMapper.insertInfo(insertField, insertValue);
         map.put("module_type", "文档库");
+        map.put("module_type_flag", ModuleTypeFlagEnum.DOCUMENT_LIBRARY.getValue());
+        map.put("create_time", new Date());
         map.put("file_text", fileTextAll);
         Map<String,Object> objectMapTemp = new HashMap<>();
         for (Map.Entry<String, Object> entry : map.entrySet()) {
@@ -2481,7 +2540,7 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
                 if(dateSingleList.contains(entry.getKey())){
                     value = value.toString().split(" ")[0];
                 }else if("create_time".equals(entry.getKey()) || "update_time".equals(entry.getKey())){
-                    value = value.toString().split(" ")[0];
+//                    value = value.toString().split(" ")[0];
                 }
                 objectMapTemp.put(entry.getKey(),value);
             }
@@ -5650,6 +5709,7 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
         stringMap.put("id", id);
         stringMap.put("serial_number", serialNumber);
         stringMap.put("module_type", moduleType);
+        stringMap.put("module_type_flag", ModuleTypeFlagEnum.DOCUMENT_LIBRARY.getValue());
         stringMap.put("content", content);
         stringMap.put("title", title);
         stringMap.put("file_text", fileText);
@@ -5921,4 +5981,16 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
         return title;
     }
 
+    @Override
+    public int updateES() {
+        List<Map<String, Object>> mapList = this.listMaps();
+        int count = 0;
+        for (Map<String, Object> map : mapList) {
+            map.put("es_update_flag","es_update_flag");
+            updateInfo(map);
+            count ++;
+        }
+        return count;
+    }
+
 }