|
@@ -97,7 +97,24 @@ public class CompareMessageService extends ServiceImpl<CompareMessageMapper, Com
|
|
|
}
|
|
|
|
|
|
public Boolean updateCompareMessage(List<CompareMessage> compareMessageList) {
|
|
|
- return this.saveOrUpdateBatch(compareMessageList);
|
|
|
+ List<Integer> ids =compareMessageList.stream().map(CompareMessage::getId).collect(Collectors.toList());
|
|
|
+ if(ids.size()!=0){
|
|
|
+ LambdaQueryWrapper<CompareMessage> queryWrapper =new LambdaQueryWrapper<CompareMessage>();
|
|
|
+ queryWrapper.in(CompareMessage::getId,ids);
|
|
|
+ List<CompareMessage> compareMessages =this.list(queryWrapper);
|
|
|
+ compareMessages.forEach(item->{
|
|
|
+ compareMessageList.forEach(tem->{
|
|
|
+ if(item.getId().equals(tem.getId())){
|
|
|
+ item.setCompareResult(tem.getCompareResult());
|
|
|
+ item.setCompareDescription(tem.getCompareDescription());
|
|
|
+ item.setTargetDescription(tem.getTargetDescription());
|
|
|
+ }
|
|
|
+ });
|
|
|
+ });
|
|
|
+
|
|
|
+ return this.saveOrUpdateBatch(compareMessages);
|
|
|
+ }
|
|
|
+ return true;
|
|
|
}
|
|
|
|
|
|
public Boolean removeCompareMessage(List<Integer> ids) {
|
|
@@ -105,6 +122,10 @@ public class CompareMessageService extends ServiceImpl<CompareMessageMapper, Com
|
|
|
}
|
|
|
|
|
|
public Map<String, Object> queryCompareMessage(Integer taskId, String patentNo, Integer reportId) throws IOException {
|
|
|
+ if(taskId!=null){
|
|
|
+ Task task =taskService.getById(taskId);
|
|
|
+ reportId =task.getReportId();
|
|
|
+ }
|
|
|
List<PatentRightVo> patentRightVos = new ArrayList<>();
|
|
|
String resBody = outInterfaceService.getPatentRightFromPAS(patentNo);
|
|
|
JSONObject jsonObject = JSONObject.parseObject(resBody);
|
|
@@ -117,9 +138,6 @@ public class CompareMessageService extends ServiceImpl<CompareMessageMapper, Com
|
|
|
if (reportId != null && reportId != 0) {
|
|
|
queryWrapper.eq(Features::getReportId, reportId);
|
|
|
}
|
|
|
- if (taskId != null) {
|
|
|
- queryWrapper.eq(Features::getTaskId, taskId);
|
|
|
- }
|
|
|
queryWrapper.eq(Features::getSignPatentNo, patentNo);
|
|
|
List<Features> features = featureService.list(queryWrapper);
|
|
|
List<Integer> featureIds = features.stream().map(Features::getId).collect(Collectors.toList());
|
|
@@ -220,8 +238,15 @@ public class CompareMessageService extends ServiceImpl<CompareMessageMapper, Com
|
|
|
*/
|
|
|
public Map<String, Object> querySynery(Integer taskId, String patentNo) throws IOException {
|
|
|
Task task =taskService.getById(taskId);
|
|
|
+ //根据 reportId 和 专利号查询特征Id
|
|
|
+ LambdaQueryWrapper<Features> wrapper =new LambdaQueryWrapper<>();
|
|
|
+ wrapper.eq(Features::getReportId,task.getReportId())
|
|
|
+ .eq(Features::getSignPatentNo,patentNo);
|
|
|
+ List<Features> features =featureService.list(wrapper);
|
|
|
+ List<Integer> featureIds =features.stream().map(Features::getId).collect(Collectors.toList());
|
|
|
LambdaQueryWrapper<CompareMessage> queryWrapper =new LambdaQueryWrapper<>();
|
|
|
- queryWrapper.eq(CompareMessage::getTaskId,taskId);
|
|
|
+ queryWrapper.eq(CompareMessage::getTaskId,taskId)
|
|
|
+ .in(CompareMessage::getFeatureId,featureIds);
|
|
|
List<CompareMessage> compareMessages =this.list(queryWrapper);
|
|
|
if(compareMessages.size()==0){
|
|
|
Map<String, Object> map = this.queryCompareMessage(null, patentNo, task.getReportId());
|
|
@@ -259,10 +284,11 @@ public class CompareMessageService extends ServiceImpl<CompareMessageMapper, Com
|
|
|
List<CompareMessage> compareMessageList = compareMessages.stream().filter(tem -> tem.getFeatureId().equals(item.getId())).collect(Collectors.toList());
|
|
|
compareMessageList.forEach(
|
|
|
tem->{
|
|
|
- if(tem.getTaskType().equals(null)){
|
|
|
+ if(tem.getTaskType()==null){
|
|
|
compareMessageVO.setCompareResult(tem.getCompareResult());
|
|
|
compareMessageVO.setCompareDescription(tem.getCompareDescription());
|
|
|
compareMessageVO.setTargetDescription(tem.getTargetDescription());
|
|
|
+ compareMessageVO.setCMid(tem.getId());
|
|
|
}
|
|
|
else if(tem.getTaskType().equals(1)){
|
|
|
compareMessageVO.setCompareResult2(tem.getCompareResult());
|