根据名称装载自定义字段

src/main/java/cn/cslg/pas/controller/PatentController.java

@@ -11,6 +11,8 @@ import cn.cslg.pas.common.model.request.QueryRequest;
 import cn.cslg.pas.common.model.request.StringRequest;
 import cn.cslg.pas.common.utils.Response;
 import cn.cslg.pas.common.vo.PatentPageMessageVO;
+import cn.cslg.pas.common.vo.PatentWithIdVO;
+import cn.cslg.pas.common.vo.StarPatentVO;
 import cn.cslg.pas.common.vo.business.EsAllCountVO;
 import cn.cslg.pas.common.vo.business.EsCountVO;
 import cn.cslg.pas.common.vo.business.PatentKinVO;
@@ -20,12 +22,10 @@ import cn.cslg.pas.factorys.businessFactory.BusinessFactory;
 import cn.cslg.pas.service.business.es.EsCountService;
 import cn.cslg.pas.service.business.es.EsPatentService;
 import cn.cslg.pas.service.business.es.EsService;
+import cn.cslg.pas.service.common.PatentStarApiService;
 import io.swagger.v3.oas.annotations.Operation;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 import java.util.List;
 
@@ -41,7 +41,10 @@ public class PatentController {
 
     @Autowired
     private EsPatentService patentService;
-
+@Autowired
+private EsService esService;
+    @Autowired
+    private PatentStarApiService patentStarApiService;
 
     @Operation(summary = "查询专利")
     @PostMapping("/queryPatent")
@@ -79,4 +82,25 @@ public class PatentController {
         return Response.success(dto);
     }
 
+    @Operation(summary = "根据专利号查询内部专利")
+    @GetMapping("/queryPatentByNo")
+    public Response queryPatentByNo(String patentNo) throws Exception {
+        PatentWithIdVO patentWithIdVO = esService.getIdByPatentNo(patentNo);
+        if(patentWithIdVO==null){
+            return Response.success(null);
+        }
+       return Response.success(patentWithIdVO.getPatent());
+
+    }
+
+    @Operation(summary = "根据专利号查询内部专利")
+    @GetMapping("/queryPatentByNoFromWeb")
+    public Response queryPatentByNoFromWeb(String patentNo) throws Exception {
+        StarPatentVO starPatentVO = patentStarApiService.getPatentByNo(patentNo);
+        if(starPatentVO==null){
+            return Response.success(null);
+        }
+        return Response.success(starPatentVO);
+
+    }
 }

src/main/java/cn/cslg/pas/service/business/ImportTaskService.java

@@ -131,19 +131,21 @@ public class ImportTaskService extends ServiceImpl<ImportTaskMapper, ImportTask>
             throw new UnLoginException("未登录");
         }
 
-        if(importTaskDTO.getType()==null){
+        if (importTaskDTO.getType() == null) {
             importTaskDTO.setType(4);
         }
 
         ImportTaskCondition importTaskCondition = new ImportTaskCondition();
-        if (importTaskDTO.getImportToType().equals(0)) {
-            importTaskCondition.setProjectType(0);
-            importTaskCondition.setProjectId(importTaskDTO.getImportToId());
-        } else if (importTaskDTO.getImportToType().equals(1)) {
-            importTaskCondition.setProjectType(1);
-            importTaskCondition.setProjectId(importTaskDTO.getImportToId());
-        } else if (importTaskDTO.getImportToType().equals(2)) {
-            importTaskCondition.setProductId(importTaskDTO.getImportToId());
+        if (importTaskDTO.getImportToId() != null) {
+            if (importTaskDTO.getImportToType().equals(0)) {
+                importTaskCondition.setProjectType(0);
+                importTaskCondition.setProjectId(importTaskDTO.getImportToId());
+            } else if (importTaskDTO.getImportToType().equals(1)) {
+                importTaskCondition.setProjectType(1);
+                importTaskCondition.setProjectId(importTaskDTO.getImportToId());
+            } else if (importTaskDTO.getImportToType().equals(2)) {
+                importTaskCondition.setProductId(importTaskDTO.getImportToId());
+            }
         }
         if (!importTaskDTO.getType().equals(1)) {
             importTaskDTO.setImportContent(MathUtils.BinaryToDecimal(importTaskDTO.getImportContent()));
@@ -160,7 +162,7 @@ public class ImportTaskService extends ServiceImpl<ImportTaskMapper, ImportTask>
         importTaskCondition.setOrderByType(importTaskDTO.getOrderByType());
         importTaskCondition.setCreateId(personnelVO.getId());
 
-       String fieldJson= JsonUtils.objectToJson(importTaskCondition);
+        String fieldJson = JsonUtils.objectToJson(importTaskCondition);
         importTaskCondition.setCustomFields(fieldJson);
         importTaskCondition.insert();
 
@@ -258,9 +260,9 @@ public class ImportTaskService extends ServiceImpl<ImportTaskMapper, ImportTask>
     }
 
     private void loadImportTask(List<ImportTaskVO> importTaskVOS) throws IOException {
-        List<ImportTaskAMVO> importTaskAMVOS =schedulingTaskService.getImportTaskAMVOs();
-        if(importTaskAMVOS==null){
-            importTaskAMVOS=new ArrayList<>();
+        List<ImportTaskAMVO> importTaskAMVOS = schedulingTaskService.getImportTaskAMVOs();
+        if (importTaskAMVOS == null) {
+            importTaskAMVOS = new ArrayList<>();
         }
         List<String> createIds = new ArrayList<>();
         importTaskVOS.forEach(item -> {
@@ -310,10 +312,10 @@ public class ImportTaskService extends ServiceImpl<ImportTaskMapper, ImportTask>
 
 
             //装载正在进行中任务的完成条数
-          ImportTaskAMVO importTaskAMVO =  importTaskAMVOS.stream().filter(item->item.getId().equals(importTaskVO.getId())).findFirst().orElse(null);
-        if(importTaskAMVO!=null){
-            importTaskVO.setDoneNum(importTaskAMVO.getDoneNum());
-        }
+            ImportTaskAMVO importTaskAMVO = importTaskAMVOS.stream().filter(item -> item.getId().equals(importTaskVO.getId())).findFirst().orElse(null);
+            if (importTaskAMVO != null) {
+                importTaskVO.setDoneNum(importTaskAMVO.getDoneNum());
+            }
         }
 
     }

src/main/java/cn/cslg/pas/service/business/ReportProjectService.java

@@ -322,7 +322,7 @@ public class ReportProjectService extends ServiceImpl<ReportProjectMapper, Repor
             try {
                 PatentWithIdVO patentWithIdVO = esService.getIdByPatentNo(reportProject.getSignPatentNo());
                 if (patentWithIdVO != null && patentWithIdVO.getPatent() != null) {
-                    reportProject.setPatentType(reportProject.getPatentType());
+                    reportProject.setPatentType(Integer.parseInt(patentWithIdVO.getPatent().getPatentType()));
                 }
             } catch (Exception e) {
                 throw new XiaoShiException("未查询到标的专利");

src/main/java/cn/cslg/pas/service/common/PatentStarApiService.java

@@ -822,4 +822,5 @@ public class PatentStarApiService {
         return patentColumnDTOS;
 
     }
+
 }

src/main/java/cn/cslg/pas/service/importPatent/GetCataloguingFromWebThread.java

@@ -114,14 +114,14 @@ public class GetCataloguingFromWebThread extends Thread {
                 }
 //
 //                //添加法律事务
-                esService.addEsLegalEvent(uploadPatentWebDTO.getStarPatentVO().getPublicNo());
-//
+//                esService.addEsLegalEvent(uploadPatentWebDTO.getStarPatentVO().getPublicNo());
+
 //                //添加引用专利
-                String nos = starPatentVO.getQuoteNos();
-                if (nos != null) {
-                    List<String> quotedNos = this.reQuotedNos(nos);
-                    esService.addEsQuotePatent(uploadPatentWebDTO.getPatent().getPublicNo(), quotedNos);
-                }
+//                String nos = starPatentVO.getQuoteNos();
+//                if (nos != null) {
+//                    List<String> quotedNos = this.reQuotedNos(nos);
+//                    esService.addEsQuotePatent(uploadPatentWebDTO.getPatent().getPublicNo(), quotedNos);
+//                }
                 //加入es保存队列
                 importFromWebToEsService.loadPatentMessageDone(uploadPatentWebDTO);
             } catch (Exception e) {

src/main/java/cn/cslg/pas/service/importPatent/SavePatentToEsThread.java

@@ -140,7 +140,10 @@ public class SavePatentToEsThread extends Thread {
     public void setIfProductAll(Boolean ifProductAll) {
 
         this.ifProductAll = ifProductAll;
-
+        if (taskLock.tryLock()) {
+            taskCondition.signalAll();
+            taskLock.unlock();
+        }
     }