PatentService.java 102 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547
  1. package cn.cslg.pas.service;
  2. import cn.cslg.pas.common.core.base.Constants;
  3. import cn.cslg.pas.common.model.BaseEntity;
  4. import cn.cslg.pas.common.model.QueryPatentVO;
  5. import cn.cslg.pas.common.model.dto.PatentDTO;
  6. import cn.cslg.pas.common.model.dto.PatentQueryFieldSourceDTO;
  7. import cn.cslg.pas.common.model.dto.TaskWebSocketDTO;
  8. import cn.cslg.pas.domain.*;
  9. import cn.cslg.pas.common.model.vo.PatentExportVO;
  10. import cn.cslg.pas.common.model.vo.PatentQueryFieldSourceVO;
  11. import cn.cslg.pas.common.model.vo.PatentVO;
  12. import cn.cslg.pas.common.model.vo.TaskParams;
  13. import cn.cslg.pas.common.utils.*;
  14. import cn.cslg.pas.common.model.dto.CustomFieldDTO;
  15. import cn.cslg.pas.common.model.params.PatentCustomFieldParams;
  16. import cn.cslg.pas.common.utils.WebSocketServer;
  17. import cn.cslg.pas.mapper.PatentMapper;
  18. import cn.cslg.pas.common.utils.CacheUtils;
  19. import cn.cslg.pas.common.utils.PatentUtils;
  20. import cn.hutool.core.io.FileUtil;
  21. import cn.hutool.core.util.IdUtil;
  22. import com.alibaba.fastjson.JSON;
  23. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  24. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  25. import com.baomidou.mybatisplus.core.metadata.IPage;
  26. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  27. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  28. import lombok.RequiredArgsConstructor;
  29. import org.apache.ibatis.annotations.Param;
  30. import org.apache.poi.hssf.usermodel.*;
  31. import org.apache.poi.hssf.util.HSSFColor;
  32. import org.apache.poi.ss.usermodel.*;
  33. import org.springframework.beans.BeanUtils;
  34. import org.springframework.context.annotation.Lazy;
  35. import org.springframework.scheduling.annotation.Async;
  36. import org.springframework.stereotype.Service;
  37. import java.io.FileOutputStream;
  38. import java.util.*;
  39. import java.util.stream.Collectors;
  40. /**
  41. * <p>
  42. * 专利信息表 服务实现类
  43. * </p>
  44. *
  45. * @author 王岩
  46. * @since 2021-12-26
  47. */
  48. @Service
  49. @RequiredArgsConstructor(onConstructor_ = {@Lazy})
  50. public class PatentService extends ServiceImpl<PatentMapper, Patent> {
  51. private final PatentMapper patentMapper;
  52. private final PatentApplicantService patentApplicantService;
  53. private final PatentApplicantLinkService applicantAttributeService;
  54. private final ProjectPatentLinkService projectPatentLinkService;
  55. private final CustomAnalysisItemSourceService customAnalysisItemSourceService;
  56. private final CacheUtils cacheUtils;
  57. private final DataAnalysisService dataAnalysisService;
  58. private final PatentAffairService patentAffairService;
  59. private final ProjectFieldTreeService projectFieldTreeService;
  60. private final ProjectFieldOptionService projectFieldOptionService;
  61. private final PatentLabelService patentLabelService;
  62. private final ProjectFieldTextService projectFieldTextService;
  63. private final PatentFieldService patentFieldService;
  64. private final ProjectFieldService projectFieldService;
  65. private final TaskService taskService;
  66. private final FileUtils fileUtils;
  67. private final PatentImageService patentImageService;
  68. private final PatentInventorService patentInventorService;
  69. private final PatentAgencyService patentAgencyService;
  70. private final PatentAgentService patentAgentService;
  71. private final ProjectFolderPatentLinkService projectFolderPatentLinkService;
  72. private final PatentApplicantMergeLinkService patentApplicantMergeLinkService;
  73. private final AreaService areaService;
  74. private final PatentClassNumberService patentClassNumberService;
  75. private final PatentClassNumberLinkService patentClassNumberLinkService;
  76. private final ProjectFieldPatentLinkService projectFieldPatentLinkService;
  77. private final PatentInstructionService patentInstructionService;
  78. private final PatentSimpleFamilyService patentSimpleFamilyService;
  79. private final SystemDictService systemDictService;
  80. private final PatentSimpleFamilyLinkService patentSimpleFamilyLinkService;
  81. private final PatentRightService patentRightService;
  82. private final PatentInstructionTextService patentInstructionTextService;
  83. private final PatentLicensorService patentLicensorService;
  84. private final PatentPledgeService patentPledgeService;
  85. private final PatentInventorMergeService patentInventorMergeService;
  86. public List<Patent> getPatentListByIds(List<Integer> ids) {
  87. if (ids == null || ids.size() == 0) {
  88. return new ArrayList<>();
  89. }
  90. LambdaQueryWrapper<Patent> queryWrapper = new LambdaQueryWrapper<>();
  91. queryWrapper.in(Patent::getId, ids);
  92. return this.list(queryWrapper);
  93. }
  94. public List<Patent> getPatentListByPatentNo(List<String> patentNo) {
  95. if (patentNo == null || patentNo.size() == 0) {
  96. return new ArrayList<>();
  97. }
  98. LambdaQueryWrapper<Patent> queryWrapper = new LambdaQueryWrapper<>();
  99. queryWrapper.in(Patent::getPatentNo, patentNo);
  100. return this.list(queryWrapper);
  101. }
  102. public Patent getByPatentNo(String patentNo) {
  103. LambdaQueryWrapper<Patent> queryWrapper = new LambdaQueryWrapper<>();
  104. queryWrapper.eq(Patent::getPatentNo, patentNo);
  105. return this.getOne(queryWrapper);
  106. }
  107. public List<Patent> getPublicDateAndPatentNoByPatentNo(List<String> patentNo) {
  108. LambdaQueryWrapper<Patent> queryWrapper = new LambdaQueryWrapper<>();
  109. queryWrapper.select(Patent::getPublicDate, Patent::getPatentNo, Patent::getId, Patent::getPublicNo
  110. , Patent::getSimpleFamily, Patent::getInpadocFamily, Patent::getPatSnapFamily);
  111. queryWrapper.in(Patent::getPatentNo, patentNo);
  112. queryWrapper.last(" order by appdate, patentno");
  113. return this.list(queryWrapper);
  114. }
  115. public List<Patent> getPatentIdAndPatentNoByIds(List<Integer> ids) {
  116. if (ids == null || ids.size() == 0) {
  117. return new ArrayList<>();
  118. }
  119. LambdaQueryWrapper<Patent> queryWrapper = new LambdaQueryWrapper<>();
  120. queryWrapper.select(Patent::getPatentNo, Patent::getId);
  121. queryWrapper.in(Patent::getId, ids);
  122. return this.list(queryWrapper);
  123. }
  124. public Date getDateTime(String ids, Integer fieldId, String type) {
  125. String column = "";
  126. switch (fieldId) {
  127. case 25:
  128. column = "appdate";
  129. break;
  130. case 26:
  131. column = "publicdate";
  132. break;
  133. case 27:
  134. column = "publictodate";
  135. break;
  136. default:
  137. return new Date(baseMapper.getDateTime2(ids, fieldId, type) * 1000L);
  138. }
  139. return new Date(baseMapper.getDateTime(ids, column, type) * 1000L);
  140. }
  141. public String getPatentNumberTypeCount(Integer projectId, String id, Integer field, CustomAnalysisItemSource source) {
  142. QueryWrapper<Patent> queryWrapper = new QueryWrapper<>();
  143. List<Integer> ids = StringUtils.changeStringToInteger(id, ",");
  144. String column = "";
  145. List<String> options = Arrays.asList(">", ">=", "<", "<=");
  146. if (ids.size() == 0) {
  147. return null;
  148. }
  149. Integer mino = source.getMin().getOperator();
  150. Integer maxo = source.getMax().getOperator();
  151. Integer minv = source.getMin().getValue();
  152. Integer maxv = source.getMax().getValue();
  153. queryWrapper.lambda().in(Patent::getId, ids);
  154. switch (field) {
  155. case 32:
  156. column = "quoteno";
  157. break;
  158. case 33:
  159. column = "quotedno";
  160. break;
  161. case 34:
  162. column = "inpadocfamilynum";
  163. break;
  164. case 35:
  165. column = "simplefamilynum";
  166. break;
  167. case 55:
  168. column = "patsnapfamilynum";
  169. break;
  170. case 38:
  171. column = "num2";
  172. break;
  173. case 39:
  174. column = "num3";
  175. break;
  176. default:
  177. List<Integer> patentIds = baseMapper.getCustomFieldCount(ids, field, options.get(mino), options.get(maxo), minv, maxv);
  178. return StringUtils.join(patentIds.stream().distinct().collect(Collectors.toList()), ",");
  179. }
  180. if (mino.equals(0)) {
  181. queryWrapper.gt(column, minv);
  182. } else {
  183. queryWrapper.ge(column, minv);
  184. }
  185. if (maxo.equals(2)) {
  186. queryWrapper.lt(column, maxv);
  187. } else {
  188. queryWrapper.le(column, maxv);
  189. }
  190. List<Patent> patentList = this.list(queryWrapper);
  191. return StringUtils.join(patentList.stream().map(Patent::getId).distinct().collect(Collectors.toList()), ",");
  192. }
  193. public String getPatentDateTime2(Integer projectId, Integer field, Long startDate, Long endDate, String id) {
  194. LambdaQueryWrapper<Patent> queryWrapper = new LambdaQueryWrapper<>();
  195. List<Integer> ids = StringUtils.changeStringToInteger(id, ",");
  196. if (ids.size() == 0) {
  197. return null;
  198. }
  199. queryWrapper.in(Patent::getId, ids);
  200. switch (field) {
  201. case 25:
  202. queryWrapper.between(Patent::getApplicationDate, startDate, endDate);
  203. break;
  204. case 26:
  205. queryWrapper.between(Patent::getPublicDate, startDate, endDate);
  206. break;
  207. case 27:
  208. queryWrapper.between(Patent::getPublicAccreditDate, startDate, endDate);
  209. break;
  210. default:
  211. List<Integer> patentIds = baseMapper.getCustomFieldTime(ids, field, startDate, endDate);
  212. return StringUtils.join(patentIds.stream().distinct().collect(Collectors.toList()), ",");
  213. }
  214. List<Patent> patentList = this.list(queryWrapper);
  215. return StringUtils.join(patentList.stream().map(BaseEntity::getId).distinct().collect(Collectors.toList()), ",");
  216. }
  217. private void setQueryPatentParams(PatentVO params) {
  218. params.setSelfField(new ArrayList<>());
  219. List<String> customIds = new ArrayList<>();
  220. List<String> notInIds =new ArrayList<>();
  221. params.setCids(new ArrayList<>());
  222. if (StringUtils.isNotEmpty(params.getName())) {
  223. params.setNameSql(PatentUtils.formatTextQuerySql(params.getName(), "a.name"));
  224. }
  225. if (StringUtils.isNotEmpty(params.getAbstractStr())) {
  226. params.setAbstractStrSql(PatentUtils.formatTextQuerySql(params.getAbstractStr(), "a.abstract"));
  227. }
  228. if (StringUtils.isNotEmpty(params.getPublicNo())) {
  229. params.setPublicNoSql(PatentUtils.formatTextQuerySql(params.getPublicNo(), "a.publicno"));
  230. }
  231. if (StringUtils.isNotEmpty(params.getApplicationNo())) {
  232. params.setApplicationNoSql(PatentUtils.formatTextQuerySql(params.getApplicationNo(), "a.applicationno"));
  233. }
  234. if (StringUtils.isNotEmpty(params.getRightContent())) {
  235. params.setRightContentSql(PatentUtils.formatTextQuerySql(params.getRightContent(), "content"));
  236. }
  237. for (int i = 0; i < params.getField().size(); i++) {
  238. List<String> queryList = params.getField().get(i).getValue();
  239. String key = params.getField().get(i).getKey();
  240. List<Integer> field = StringUtils.changeStringToInteger(key, "-");
  241. if (queryList.size() == 0) {
  242. continue;
  243. }
  244. String fieldType = params.getField().get(i).getType();
  245. switch (key) {
  246. case "13":
  247. case "15":
  248. case "16":
  249. case "17":
  250. if (field.get(0) == 13) {
  251. params.setQueryClassNumberIpc(true);
  252. params.setWhereClassNumberIpc(queryList);
  253. params.setQueryClassNumberIpcMethod(params.getField().get(i).getClassId());
  254. }
  255. if (field.get(0) == 15) {
  256. params.setQueryClassNumberCpc(true);
  257. params.setWhereClassNumberCpc(queryList);
  258. params.setQueryClassNumberCpcMethod(params.getField().get(i).getClassId());
  259. }
  260. if (field.get(0) == 17) {
  261. params.setQueryClassNumberUpc(true);
  262. params.setWhereClassNumberUpc(queryList);
  263. params.setQueryClassNumberUpcMethod(params.getField().get(i).getClassId());
  264. }
  265. if (field.get(0) == 16) {
  266. params.setQueryClassNumberLoc(true);
  267. params.setWhereClassNumberLoc(queryList);
  268. params.setQueryClassNumberLocMethod(params.getField().get(i).getClassId());
  269. }
  270. break;
  271. case "18-6":
  272. params.setQueryApplicantOriginal(true);
  273. params.setWhereApplicantOriginal(queryList);
  274. break;
  275. case "19-6":
  276. params.setQueryApplicantCurrent(true);
  277. params.setWhereApplicantCurrent(queryList);
  278. break;
  279. case "20-0":
  280. params.setQueryInventor(true);
  281. params.setWhereInventor(queryList);
  282. break;
  283. case "20-1":
  284. params.setQueryInventor(true);
  285. params.setQueryInventorMerge(true);
  286. params.setWhereInventorMerge(queryList);
  287. break;
  288. case "18-7":
  289. params.setQueryApplicantOriginalStandard(true);
  290. params.setWhereApplicantOriginalStandard(queryList);
  291. break;
  292. case "19-7":
  293. params.setQueryApplicantCurrentStandard(true);
  294. params.setWhereApplicantCurrentStandard(queryList);
  295. break;
  296. case "18-8":
  297. params.setQueryApplicantOriginal(true);
  298. params.setQueryApplicantOriginalMerge(true);
  299. params.setWhereApplicantOriginalMerge(queryList);
  300. break;
  301. case "19-8":
  302. params.setQueryApplicantCurrent(true);
  303. params.setQueryApplicantCurrentMerge(true);
  304. params.setWhereApplicantCurrentMerge(queryList);
  305. break;
  306. case "28-0":
  307. params.setQueryBureau(true);
  308. params.setWhereBureau(queryList);
  309. break;
  310. case "37-0":
  311. params.setQueryType(true);
  312. params.setWhereType(queryList);
  313. break;
  314. case "36-0":
  315. params.setQueryStatus(true);
  316. params.setWhereStatus(queryList);
  317. break;
  318. case "25-12":
  319. params.setQueryAppDate(true);
  320. params.setWhereAppDate(queryList);
  321. break;
  322. case "26-12":
  323. params.setQueryPublicDate(true);
  324. params.setWherePublicDate(queryList);
  325. break;
  326. case "29-17":
  327. params.setQueryApplicantAddress(true);
  328. params.setQueryCountry(true);
  329. params.setWhereCountry(queryList);
  330. break;
  331. case "29-18":
  332. params.setQueryApplicantAddress(true);
  333. params.setQueryApplicantProvince(true);
  334. params.setWhereApplicantProvince(queryList);
  335. break;
  336. case "40-0":
  337. params.setQueryAffair(true);
  338. StringBuilder str = new StringBuilder();
  339. for (String s : queryList) {
  340. str.append(s).append("|");
  341. }
  342. params.setWhereAffair(str.substring(0, str.length() - 1));
  343. break;
  344. case "54-0":
  345. params.setQueryLabel(true);
  346. params.setWhereLabel(queryList);
  347. break;
  348. default:
  349. //判断值里面是否含空
  350. params.getField().get(i).setIsNull(queryList.stream().anyMatch(item -> item.equals("null")));
  351. params.getSelfField().add(params.getField().get(i));
  352. customIds.add(String.valueOf(field.get(0)));
  353. if(params.getField().get(i).getIsNull()==null||!params.getField().get(i).getIsNull()){
  354. params.getCids().add(field.get(0));
  355. }
  356. else if(params.getField().get(i).getIsNull()&&queryList.size()==1){
  357. notInIds.add(String.valueOf(field.get(0)));
  358. }
  359. }
  360. }
  361. if (customIds.size() != 0) {
  362. params.setCustomIds(customIds);
  363. }
  364. params.getField().forEach(item->{
  365. List<String> temIds =new ArrayList<>(notInIds);
  366. temIds.remove(item.getKey());
  367. item.setNotInIds(temIds);
  368. });
  369. }
  370. public List<Integer> getPatentListIds(PatentVO params) {
  371. this.setQueryFamilyParams(params);
  372. params.setSelected(new ArrayList<>());
  373. List<Integer> ids = this.getQueryPatentIds(params);
  374. return ids.stream().skip(params.getStartNumber() - 1).limit(params.getEndNumber() - params.getStartNumber() + 1).collect(Collectors.toList());
  375. }
  376. private void setQueryFamilyParams(PatentVO params) {
  377. switch (params.getFamily()) {
  378. case 0:
  379. params.setQuerySimpleFamily(false);
  380. params.setQueryInpadocFamily(false);
  381. params.setQueryPatSnapFamily(false);
  382. break;
  383. case 1:
  384. params.setQuerySimpleFamily(true);
  385. params.setQueryInpadocFamily(false);
  386. params.setQueryPatSnapFamily(false);
  387. break;
  388. case 2:
  389. params.setQuerySimpleFamily(false);
  390. params.setQueryInpadocFamily(true);
  391. params.setQueryPatSnapFamily(false);
  392. break;
  393. case 3:
  394. params.setQuerySimpleFamily(false);
  395. params.setQueryInpadocFamily(false);
  396. params.setQueryPatSnapFamily(true);
  397. break;
  398. }
  399. }
  400. public IPage<PatentDTO> getPageList(PatentVO params) {
  401. this.setQueryFamilyParams(params);
  402. this.setQueryPatentParams(params);
  403. IPage<Patent> dataPage = baseMapper.getPageList(new Page<>(params.getCurrent(), params.getSize()), params);
  404. IPage<PatentDTO> pageList = new Page<>();
  405. List<PatentDTO> records = new ArrayList<>();
  406. List<Integer> patentIds = dataPage.getRecords().stream().map(Patent::getId).collect(Collectors.toList());
  407. List<PatentApplicant> patentApplicantList = patentApplicantService.getPatentApplicantByPatentIds(patentIds);
  408. List<PatentInventor> patentInventorList = patentInventorService.getPatentInventorByPatentIds(patentIds);
  409. List<PatentLabel> patentLabelList = patentLabelService.getPatentLabelByPatentIdsAndProjectId(patentIds, params.getProjectId());
  410. List<PatentClassNumberLink> patentClassNumberLinkList = patentClassNumberLinkService.getPatentClassNumberLinkByPatentIds(patentIds);
  411. List<PatentAgent> patentAgentList = patentAgentService.getPatentAgentByPatentIds(patentIds);
  412. List<PatentAgency> patentAgencyList = patentAgencyService.getPatentAgencyByIds(dataPage.getRecords().stream().filter(item -> StringUtils.isNotEmpty(item.getAgencyId())).map(item -> Integer.parseInt(item.getAgencyId())).distinct().collect(Collectors.toList()));
  413. List<PatentSimpleFamilyLink> patentSimpleFamilyLinkList = patentSimpleFamilyLinkService.getPatentSimpleFamilyLinkByFamilyIds(dataPage.getRecords().stream().map(Patent::getSimpleFamily).collect(Collectors.toList()));
  414. List<PatentSimpleFamilyLink> patentInpadocFamilyLinkList = patentSimpleFamilyLinkService.getPatentSimpleFamilyLinkByFamilyIds(dataPage.getRecords().stream().map(Patent::getInpadocFamily).collect(Collectors.toList()));
  415. List<PatentSimpleFamilyLink> patentPatSnapFamilyLinkList = patentSimpleFamilyLinkService.getPatentSimpleFamilyLinkByFamilyIds(dataPage.getRecords().stream().map(Patent::getPatSnapFamily).collect(Collectors.toList()));
  416. List<SystemDict> systemDictList = systemDictService.getSystemDictListByType(Arrays.asList(Constants.PATENT_TYPE, Constants.PATENT_SIMPLE_STATUS));
  417. //获得所有的自定义字段信息
  418. Map<Integer,List<PatentDTO.Field>> map =projectFieldService.getPatentFieldByPatentIdAndProjectId2(params.getProjectId(),patentIds);
  419. dataPage.getRecords().forEach(item -> {
  420. PatentDTO patentDTO = new PatentDTO();
  421. BeanUtils.copyProperties(item, patentDTO);
  422. patentDTO.setApplicationDate(DateUtils.formatDate(item.getApplicationDate(), DateUtils.YYYY_MM_DD));
  423. patentDTO.setPriorityDate(DateUtils.formatDate(item.getPriorityDate(), DateUtils.YYYY_MM_DD));
  424. patentDTO.setPublicDate(DateUtils.formatDate(item.getPublicDate(), DateUtils.YYYY_MM_DD));
  425. patentDTO.setPublicAccreditDate(DateUtils.formatDate(item.getPublicAccreditDate(), DateUtils.YYYY_MM_DD));
  426. patentDTO.setFirstPublicDate(DateUtils.formatDate(item.getFirstPublicDate(), DateUtils.YYYY_MM_DD));
  427. patentDTO.setSimpleStatus(systemDictList.stream().filter(systemDict -> systemDict.getType().equals(Constants.PATENT_SIMPLE_STATUS) && systemDict.getValue().equals(String.valueOf(item.getSimpleStatus()))).findFirst().orElse(new SystemDict()).getLabel());
  428. patentDTO.setType(systemDictList.stream().filter(systemDict -> systemDict.getType().equals(Constants.PATENT_TYPE) && systemDict.getValue().equals(String.valueOf(item.getType()))).findFirst().orElse(new SystemDict()).getLabel());
  429. patentDTO.setApplicant(patentApplicantList.stream().filter(patentApplicant -> patentApplicant.getPatentId().equals(item.getId())).collect(Collectors.toList()));
  430. patentDTO.setInventor(patentInventorList.stream().filter(patentInventor -> patentInventor.getPatentId().equals(item.getId())).collect(Collectors.toList()));
  431. patentDTO.setLabel(patentLabelList.stream().filter(patentLabel -> patentLabel.getPatentId().equals(item.getId())).collect(Collectors.toList()));
  432. patentDTO.setIpcList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getPatentId().equals(item.getId()) && patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_IPC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  433. patentDTO.setCpcList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getPatentId().equals(item.getId()) && patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_CPC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  434. patentDTO.setUpcList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getPatentId().equals(item.getId()) && patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_UPC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  435. patentDTO.setLocList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getPatentId().equals(item.getId()) && patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_LOC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  436. if (StringUtils.isNotEmpty(item.getAgencyId())) {
  437. patentDTO.setAgency(patentAgencyList.stream().filter(patentAgency -> patentAgency.getId().equals(Integer.parseInt(item.getAgencyId()))).findFirst().orElse(null));
  438. }
  439. PatentDTO.PatentFamily patentFamily = new PatentDTO.PatentFamily();
  440. patentFamily.setSimple(patentSimpleFamilyLinkList.stream().filter(patentSimpleFamilyLink -> patentSimpleFamilyLink.getFamilyId().equals(item.getSimpleFamily())).map(PatentSimpleFamilyLink::getPatentNo).collect(Collectors.toList()));
  441. patentFamily.setInpadoc(patentInpadocFamilyLinkList.stream().filter(patentSimpleFamilyLink -> patentSimpleFamilyLink.getFamilyId().equals(item.getInpadocFamily())).map(PatentSimpleFamilyLink::getPatentNo).collect(Collectors.toList()));
  442. patentFamily.setPatSnap(patentPatSnapFamilyLinkList.stream().filter(patentSimpleFamilyLink -> patentSimpleFamilyLink.getFamilyId().equals(item.getPatSnapFamily())).map(PatentSimpleFamilyLink::getPatentNo).collect(Collectors.toList()));
  443. patentDTO.setFamily(patentFamily);
  444. patentDTO.setAgent(patentAgentList.stream().filter(patentAgent -> patentAgent.getPatentId().equals(item.getId())).collect(Collectors.toList()));
  445. // TODO 性能优化
  446. patentDTO.setField(map.get(item.getId()));
  447. records.add(patentDTO);
  448. });
  449. pageList.setTotal(dataPage.getTotal());
  450. pageList.setRecords(records);
  451. pageList.setPages(dataPage.getPages());
  452. pageList.setSize(dataPage.getSize());
  453. pageList.setCurrent(dataPage.getCurrent());
  454. return pageList;
  455. }
  456. public IPage<PatentDTO> getPageListForRMS(QueryPatentVO params) {
  457. if(params.getObligeeName()!=null) {
  458. String obligeeName = params.getObligeeName().replace("(", "\\(");
  459. obligeeName = obligeeName.replace(")", "\\)");
  460. params.setObligeeName(obligeeName);
  461. }
  462. if(params.getApplicationName()!=null) {
  463. String applicationName =params.getApplicationName().replace("(","\\(");
  464. applicationName =applicationName.replace(")","\\)");
  465. params.setApplicationName(applicationName);}
  466. IPage<Patent> dataPage = baseMapper.getPageListForRMS2(new Page<>(params.getCurrent(), params.getSize()),params);
  467. IPage<PatentDTO> pageList = new Page<>();
  468. List<PatentDTO> records = new ArrayList<>();
  469. List<Integer> patentIds = dataPage.getRecords().stream().map(Patent::getId).collect(Collectors.toList());
  470. List<PatentApplicant> patentApplicantList = patentApplicantService.getPatentApplicantByPatentIds(patentIds);
  471. List<PatentInventor> patentInventorList = patentInventorService.getPatentInventorByPatentIds(patentIds);
  472. List<PatentLabel> patentLabelList = patentLabelService.getPatentLabelByPatentIdsAndProjectId(patentIds, params.getProjectId());
  473. List<PatentClassNumberLink> patentClassNumberLinkList = patentClassNumberLinkService.getPatentClassNumberLinkByPatentIds(patentIds);
  474. List<PatentAgent> patentAgentList = patentAgentService.getPatentAgentByPatentIds(patentIds);
  475. List<PatentAgency> patentAgencyList = patentAgencyService.getPatentAgencyByIds(dataPage.getRecords().stream().filter(item -> StringUtils.isNotEmpty(item.getAgencyId())).map(item -> Integer.parseInt(item.getAgencyId())).distinct().collect(Collectors.toList()));
  476. List<PatentSimpleFamilyLink> patentSimpleFamilyLinkList = patentSimpleFamilyLinkService.getPatentSimpleFamilyLinkByFamilyIds(dataPage.getRecords().stream().map(Patent::getSimpleFamily).collect(Collectors.toList()));
  477. List<PatentSimpleFamilyLink> patentInpadocFamilyLinkList = patentSimpleFamilyLinkService.getPatentSimpleFamilyLinkByFamilyIds(dataPage.getRecords().stream().map(Patent::getInpadocFamily).collect(Collectors.toList()));
  478. List<PatentSimpleFamilyLink> patentPatSnapFamilyLinkList = patentSimpleFamilyLinkService.getPatentSimpleFamilyLinkByFamilyIds(dataPage.getRecords().stream().map(Patent::getPatSnapFamily).collect(Collectors.toList()));
  479. List<SystemDict> systemDictList = systemDictService.getSystemDictListByType(Arrays.asList(Constants.PATENT_TYPE, Constants.PATENT_SIMPLE_STATUS));
  480. dataPage.getRecords().forEach(item -> {
  481. PatentDTO patentDTO = new PatentDTO();
  482. BeanUtils.copyProperties(item, patentDTO);
  483. patentDTO.setApplicationDate(DateUtils.formatDate(item.getApplicationDate(), DateUtils.YYYY_MM_DD));
  484. patentDTO.setPriorityDate(DateUtils.formatDate(item.getPriorityDate(), DateUtils.YYYY_MM_DD));
  485. patentDTO.setPublicDate(DateUtils.formatDate(item.getPublicDate(), DateUtils.YYYY_MM_DD));
  486. patentDTO.setPublicAccreditDate(DateUtils.formatDate(item.getPublicAccreditDate(), DateUtils.YYYY_MM_DD));
  487. patentDTO.setFirstPublicDate(DateUtils.formatDate(item.getFirstPublicDate(), DateUtils.YYYY_MM_DD));
  488. patentDTO.setSimpleStatus(systemDictList.stream().filter(systemDict -> systemDict.getType().equals(Constants.PATENT_SIMPLE_STATUS) && systemDict.getValue().equals(String.valueOf(item.getSimpleStatus()))).findFirst().orElse(new SystemDict()).getLabel());
  489. patentDTO.setType(systemDictList.stream().filter(systemDict -> systemDict.getType().equals(Constants.PATENT_TYPE) && systemDict.getValue().equals(String.valueOf(item.getType()))).findFirst().orElse(new SystemDict()).getLabel());
  490. patentDTO.setApplicant(patentApplicantList.stream().filter(patentApplicant -> patentApplicant.getPatentId().equals(item.getId())).collect(Collectors.toList()));
  491. patentDTO.setInventor(patentInventorList.stream().filter(patentInventor -> patentInventor.getPatentId().equals(item.getId())).collect(Collectors.toList()));
  492. patentDTO.setLabel(patentLabelList.stream().filter(patentLabel -> patentLabel.getPatentId().equals(item.getId())).collect(Collectors.toList()));
  493. patentDTO.setIpcList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getPatentId().equals(item.getId()) && patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_IPC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  494. patentDTO.setCpcList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getPatentId().equals(item.getId()) && patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_CPC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  495. patentDTO.setUpcList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getPatentId().equals(item.getId()) && patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_UPC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  496. patentDTO.setLocList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getPatentId().equals(item.getId()) && patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_LOC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  497. patentDTO.setAffair(patentAffairService.getPatentAffairByPatentId(item.getId()));
  498. if (StringUtils.isNotEmpty(item.getAgencyId())) {
  499. patentDTO.setAgency(patentAgencyList.stream().filter(patentAgency -> patentAgency.getId().equals(Integer.parseInt(item.getAgencyId()))).findFirst().orElse(null));
  500. }
  501. PatentDTO.PatentFamily patentFamily = new PatentDTO.PatentFamily();
  502. patentFamily.setSimple(patentSimpleFamilyLinkList.stream().filter(patentSimpleFamilyLink -> patentSimpleFamilyLink.getFamilyId().equals(item.getSimpleFamily())).map(PatentSimpleFamilyLink::getPatentNo).collect(Collectors.toList()));
  503. patentFamily.setInpadoc(patentInpadocFamilyLinkList.stream().filter(patentSimpleFamilyLink -> patentSimpleFamilyLink.getFamilyId().equals(item.getInpadocFamily())).map(PatentSimpleFamilyLink::getPatentNo).collect(Collectors.toList()));
  504. patentFamily.setPatSnap(patentPatSnapFamilyLinkList.stream().filter(patentSimpleFamilyLink -> patentSimpleFamilyLink.getFamilyId().equals(item.getPatSnapFamily())).map(PatentSimpleFamilyLink::getPatentNo).collect(Collectors.toList()));
  505. patentDTO.setFamily(patentFamily);
  506. patentDTO.setAgent(patentAgentList.stream().filter(patentAgent -> patentAgent.getPatentId().equals(item.getId())).collect(Collectors.toList()));
  507. // TODO 性能优化
  508. patentDTO.setField(projectFieldService.getPatentFieldByPatentIdAndProjectId(params.getProjectId(), item.getId()));
  509. records.add(patentDTO);
  510. });
  511. pageList.setTotal(dataPage.getTotal());
  512. pageList.setRecords(records);
  513. pageList.setPages(dataPage.getPages());
  514. pageList.setSize(dataPage.getSize());
  515. pageList.setCurrent(dataPage.getCurrent());
  516. return pageList;
  517. }
  518. public List<PatentDTO> getPatentDTOListForRMS(PatentVO params) {
  519. List<PatentDTO> records = new ArrayList<>();
  520. if(params.getPatentNos()==null||params.getPatentNos().size()==0){
  521. return records;
  522. }
  523. List<Patent> dataPage = baseMapper.getPatent(params.getPatentNos(),-1,-1);
  524. List<Integer> patentIds = dataPage.stream().map(Patent::getId).collect(Collectors.toList());
  525. List<PatentApplicant> patentApplicantList = patentApplicantService.getPatentApplicantByPatentIds(patentIds);
  526. List<PatentInventor> patentInventorList = patentInventorService.getPatentInventorByPatentIds(patentIds);
  527. List<PatentClassNumberLink> patentClassNumberLinkList = patentClassNumberLinkService.getPatentClassNumberLinkByPatentIds(patentIds);
  528. List<PatentAgent> patentAgentList = patentAgentService.getPatentAgentByPatentIds(patentIds);
  529. List<PatentAgency> patentAgencyList = patentAgencyService.getPatentAgencyByIds(dataPage.stream().filter(item -> StringUtils.isNotEmpty(item.getAgencyId())).map(item -> Integer.parseInt(item.getAgencyId())).distinct().collect(Collectors.toList()));
  530. List<PatentSimpleFamilyLink> patentSimpleFamilyLinkList = patentSimpleFamilyLinkService.getPatentSimpleFamilyLinkByFamilyIds(dataPage.stream().map(Patent::getSimpleFamily).collect(Collectors.toList()));
  531. List<PatentSimpleFamilyLink> patentInpadocFamilyLinkList = patentSimpleFamilyLinkService.getPatentSimpleFamilyLinkByFamilyIds(dataPage.stream().map(Patent::getInpadocFamily).collect(Collectors.toList()));
  532. List<PatentSimpleFamilyLink> patentPatSnapFamilyLinkList = patentSimpleFamilyLinkService.getPatentSimpleFamilyLinkByFamilyIds(dataPage.stream().map(Patent::getPatSnapFamily).collect(Collectors.toList()));
  533. List<SystemDict> systemDictList = systemDictService.getSystemDictListByType(Arrays.asList(Constants.PATENT_TYPE, Constants.PATENT_SIMPLE_STATUS));
  534. dataPage.forEach(item -> {
  535. PatentDTO patentDTO = new PatentDTO();
  536. BeanUtils.copyProperties(item, patentDTO);
  537. patentDTO.setApplicationDate(DateUtils.formatDate(item.getApplicationDate(), DateUtils.YYYY_MM_DD));
  538. patentDTO.setPriorityDate(DateUtils.formatDate(item.getPriorityDate(), DateUtils.YYYY_MM_DD));
  539. patentDTO.setPublicDate(DateUtils.formatDate(item.getPublicDate(), DateUtils.YYYY_MM_DD));
  540. patentDTO.setPublicAccreditDate(DateUtils.formatDate(item.getPublicAccreditDate(), DateUtils.YYYY_MM_DD));
  541. patentDTO.setFirstPublicDate(DateUtils.formatDate(item.getFirstPublicDate(), DateUtils.YYYY_MM_DD));
  542. patentDTO.setSimpleStatus(systemDictList.stream().filter(systemDict -> systemDict.getType().equals(Constants.PATENT_SIMPLE_STATUS) && systemDict.getValue().equals(String.valueOf(item.getSimpleStatus()))).findFirst().orElse(new SystemDict()).getLabel());
  543. patentDTO.setSimpleStatusInt(item.getSimpleStatus());
  544. patentDTO.setType(systemDictList.stream().filter(systemDict -> systemDict.getType().equals(Constants.PATENT_TYPE) && systemDict.getValue().equals(String.valueOf(item.getType()))).findFirst().orElse(new SystemDict()).getLabel());
  545. patentDTO.setApplicant(patentApplicantList.stream().filter(patentApplicant -> patentApplicant.getPatentId().equals(item.getId())).collect(Collectors.toList()));
  546. patentDTO.setInventor(patentInventorList.stream().filter(patentInventor -> patentInventor.getPatentId().equals(item.getId())).collect(Collectors.toList()));
  547. patentDTO.setIpcList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getPatentId().equals(item.getId()) && patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_IPC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  548. patentDTO.setCpcList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getPatentId().equals(item.getId()) && patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_CPC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  549. patentDTO.setUpcList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getPatentId().equals(item.getId()) && patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_UPC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  550. patentDTO.setLocList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getPatentId().equals(item.getId()) && patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_LOC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  551. if (StringUtils.isNotEmpty(item.getAgencyId())) {
  552. patentDTO.setAgency(patentAgencyList.stream().filter(patentAgency -> patentAgency.getId().equals(Integer.parseInt(item.getAgencyId()))).findFirst().orElse(null));
  553. }
  554. PatentDTO.PatentFamily patentFamily = new PatentDTO.PatentFamily();
  555. patentFamily.setSimple(patentSimpleFamilyLinkList.stream().filter(patentSimpleFamilyLink -> patentSimpleFamilyLink.getFamilyId().equals(item.getSimpleFamily())).map(PatentSimpleFamilyLink::getPatentNo).collect(Collectors.toList()));
  556. patentFamily.setInpadoc(patentInpadocFamilyLinkList.stream().filter(patentSimpleFamilyLink -> patentSimpleFamilyLink.getFamilyId().equals(item.getInpadocFamily())).map(PatentSimpleFamilyLink::getPatentNo).collect(Collectors.toList()));
  557. patentFamily.setPatSnap(patentPatSnapFamilyLinkList.stream().filter(patentSimpleFamilyLink -> patentSimpleFamilyLink.getFamilyId().equals(item.getPatSnapFamily())).map(PatentSimpleFamilyLink::getPatentNo).collect(Collectors.toList()));
  558. patentDTO.setFamily(patentFamily);
  559. patentDTO.setAffair(patentAffairService.getPatentAffairByPatentId(item.getId()));
  560. patentDTO.setAgent(patentAgentList.stream().filter(patentAgent -> patentAgent.getPatentId().equals(item.getId())).collect(Collectors.toList()));
  561. // TODO 性能优化
  562. records.add(patentDTO);
  563. });
  564. return records;
  565. }
  566. //查询对比文件信息
  567. public List<PatentDTO> getRmsComparePatent(PatentVO params) {
  568. List<Patent> dataPage = baseMapper.getPatent(params.getPatentNos(),-1,-1);
  569. List<PatentDTO> records = new ArrayList<>();
  570. List<Integer> patentIds = dataPage.stream().map(Patent::getId).collect(Collectors.toList());
  571. List<PatentApplicant> patentApplicantList = patentApplicantService.getPatentApplicantByPatentIds(patentIds);
  572. List<PatentInventor> patentInventorList = patentInventorService.getPatentInventorByPatentIds(patentIds);
  573. List<PatentClassNumberLink> patentClassNumberLinkList = patentClassNumberLinkService.getPatentClassNumberLinkByPatentIds(patentIds);
  574. List<PatentAgent> patentAgentList = patentAgentService.getPatentAgentByPatentIds(patentIds);
  575. List<PatentAgency> patentAgencyList = patentAgencyService.getPatentAgencyByIds(dataPage.stream().filter(item -> StringUtils.isNotEmpty(item.getAgencyId())).map(item -> Integer.parseInt(item.getAgencyId())).distinct().collect(Collectors.toList()));
  576. List<PatentSimpleFamilyLink> patentSimpleFamilyLinkList = patentSimpleFamilyLinkService.getPatentSimpleFamilyLinkByFamilyIds(dataPage.stream().map(Patent::getSimpleFamily).collect(Collectors.toList()));
  577. List<PatentSimpleFamilyLink> patentInpadocFamilyLinkList = patentSimpleFamilyLinkService.getPatentSimpleFamilyLinkByFamilyIds(dataPage.stream().map(Patent::getInpadocFamily).collect(Collectors.toList()));
  578. List<PatentSimpleFamilyLink> patentPatSnapFamilyLinkList = patentSimpleFamilyLinkService.getPatentSimpleFamilyLinkByFamilyIds(dataPage.stream().map(Patent::getPatSnapFamily).collect(Collectors.toList()));
  579. List<SystemDict> systemDictList = systemDictService.getSystemDictListByType(Arrays.asList(Constants.PATENT_TYPE, Constants.PATENT_SIMPLE_STATUS));
  580. dataPage.forEach(item -> {
  581. PatentDTO patentDTO = new PatentDTO();
  582. BeanUtils.copyProperties(item, patentDTO);
  583. patentDTO.setApplicationDate(DateUtils.formatDate(item.getApplicationDate(), DateUtils.YYYY_MM_DD));
  584. patentDTO.setPriorityDate(DateUtils.formatDate(item.getPriorityDate(), DateUtils.YYYY_MM_DD));
  585. patentDTO.setPublicDate(DateUtils.formatDate(item.getPublicDate(), DateUtils.YYYY_MM_DD));
  586. patentDTO.setPublicAccreditDate(DateUtils.formatDate(item.getPublicAccreditDate(), DateUtils.YYYY_MM_DD));
  587. patentDTO.setFirstPublicDate(DateUtils.formatDate(item.getFirstPublicDate(), DateUtils.YYYY_MM_DD));
  588. patentDTO.setSimpleStatus(systemDictList.stream().filter(systemDict -> systemDict.getType().equals(Constants.PATENT_SIMPLE_STATUS) && systemDict.getValue().equals(String.valueOf(item.getSimpleStatus()))).findFirst().orElse(new SystemDict()).getLabel());
  589. patentDTO.setSimpleStatusInt(item.getSimpleStatus());
  590. patentDTO.setType(systemDictList.stream().filter(systemDict -> systemDict.getType().equals(Constants.PATENT_TYPE) && systemDict.getValue().equals(String.valueOf(item.getType()))).findFirst().orElse(new SystemDict()).getLabel());
  591. patentDTO.setApplicant(patentApplicantList.stream().filter(patentApplicant -> patentApplicant.getPatentId().equals(item.getId())).collect(Collectors.toList()));
  592. patentDTO.setInventor(patentInventorList.stream().filter(patentInventor -> patentInventor.getPatentId().equals(item.getId())).collect(Collectors.toList()));
  593. patentDTO.setIpcList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getPatentId().equals(item.getId()) && patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_IPC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  594. patentDTO.setCpcList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getPatentId().equals(item.getId()) && patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_CPC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  595. patentDTO.setUpcList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getPatentId().equals(item.getId()) && patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_UPC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  596. patentDTO.setLocList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getPatentId().equals(item.getId()) && patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_LOC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  597. if (StringUtils.isNotEmpty(item.getAgencyId())) {
  598. patentDTO.setAgency(patentAgencyList.stream().filter(patentAgency -> patentAgency.getId().equals(Integer.parseInt(item.getAgencyId()))).findFirst().orElse(null));
  599. }
  600. PatentDTO.PatentFamily patentFamily = new PatentDTO.PatentFamily();
  601. patentFamily.setSimple(patentSimpleFamilyLinkList.stream().filter(patentSimpleFamilyLink -> patentSimpleFamilyLink.getFamilyId().equals(item.getSimpleFamily())).map(PatentSimpleFamilyLink::getPatentNo).collect(Collectors.toList()));
  602. patentFamily.setInpadoc(patentInpadocFamilyLinkList.stream().filter(patentSimpleFamilyLink -> patentSimpleFamilyLink.getFamilyId().equals(item.getInpadocFamily())).map(PatentSimpleFamilyLink::getPatentNo).collect(Collectors.toList()));
  603. patentFamily.setPatSnap(patentPatSnapFamilyLinkList.stream().filter(patentSimpleFamilyLink -> patentSimpleFamilyLink.getFamilyId().equals(item.getPatSnapFamily())).map(PatentSimpleFamilyLink::getPatentNo).collect(Collectors.toList()));
  604. patentDTO.setFamily(patentFamily);
  605. patentDTO.setAffair(patentAffairService.getPatentAffairByPatentId(item.getId()));
  606. patentDTO.setAgent(patentAgentList.stream().filter(patentAgent -> patentAgent.getPatentId().equals(item.getId())).collect(Collectors.toList()));
  607. // TODO 性能优化
  608. records.add(patentDTO);
  609. });
  610. return records;
  611. }
  612. // 获得对比专利号
  613. public String getComPantentNos(QueryPatentVO params){
  614. List<String> patents = baseMapper.getListForRMS(params);
  615. return Response.success(patents);
  616. }
  617. // 获得带筛选条件的对比专利号
  618. public String getConPantentNos(QueryPatentVO params){
  619. List<String> patents = baseMapper.getConPantentNos(params);
  620. return Response.success(patents);
  621. }
  622. // 获得带筛选条件的专利
  623. public String getConPantents(QueryPatentVO params){
  624. if(params.getStartNumber()!=null&&params.getEndNumber()!=null){
  625. params.setEndNumber(params.getEndNumber()-params.getStartNumber()+1);
  626. }
  627. List<Patent> patents = baseMapper.getConPantents(params);
  628. return Response.success(patents);
  629. }
  630. public PatentDTO getPatentDTOById(Integer id, Integer projectId) {
  631. Patent patent = baseMapper.selectById(id);
  632. PatentDTO patentDTO = new PatentDTO();
  633. BeanUtils.copyProperties(patent, patentDTO);
  634. List<SystemDict> systemDictList = systemDictService.getSystemDictListByType(Arrays.asList(Constants.PATENT_TYPE, Constants.PATENT_SIMPLE_STATUS, Constants.COUNTRIES));
  635. List<PatentClassNumberLink> patentClassNumberLinkList = patentClassNumberLinkService.getPatentClassNumberLinkByPatentIds(Collections.singletonList(id));
  636. if (patent.getPriorityNo() != null) {
  637. patentDTO.setPriorityNo(patent.getPriorityNo());
  638. } else {
  639. patentDTO.setPriorityNo("");
  640. }
  641. if (patent.getPriorityCountry() != null) {
  642. if (patent.getPriorityCountry().contains("\\|")) {
  643. List<String> countryList = StringUtils.changeStringToString(patent.getPriorityCountry().replaceAll(" ", ""), "\\|");
  644. patentDTO.setPriorityCountry(countryList);
  645. } else if (patent.getPriorityCountry().contains(",")) {
  646. List<String> countryList = StringUtils.changeStringToString(patent.getPriorityCountry().replaceAll(" ", ""), ",");
  647. patentDTO.setPriorityCountry(countryList);
  648. } else if (patent.getPriorityCountry().contains(";")) {
  649. List<String> countryList = StringUtils.changeStringToString(patent.getPriorityCountry().replaceAll(" ", ""), ";");
  650. patentDTO.setPriorityCountry(countryList);
  651. }
  652. } else {
  653. patentDTO.setPriorityCountry(Collections.singletonList(""));
  654. }
  655. patentDTO.setApplicationDate(DateUtils.formatDate(patent.getApplicationDate(), DateUtils.YYYY_MM_DD));
  656. patentDTO.setPriorityDate(DateUtils.formatDate(patent.getPriorityDate(), DateUtils.YYYY_MM_DD));
  657. patentDTO.setPublicDate(DateUtils.formatDate(patent.getPublicDate(), DateUtils.YYYY_MM_DD));
  658. patentDTO.setPublicAccreditDate(DateUtils.formatDate(patent.getPublicAccreditDate(), DateUtils.YYYY_MM_DD));
  659. patentDTO.setFirstPublicDate(DateUtils.formatDate(patent.getFirstPublicDate(), DateUtils.YYYY_MM_DD));
  660. patentDTO.setSimpleStatus(systemDictList.stream().filter(systemDict -> systemDict.getType().equals(Constants.PATENT_SIMPLE_STATUS) && systemDict.getValue().equals(String.valueOf(patent.getSimpleStatus()))).findFirst().orElse(new SystemDict()).getLabel());
  661. patentDTO.setType(systemDictList.stream().filter(systemDict -> systemDict.getType().equals(Constants.PATENT_TYPE) && systemDict.getValue().equals(String.valueOf(patent.getType()))).findFirst().orElse(new SystemDict()).getLabel());
  662. patentDTO.setLabel(patentLabelService.getPatentLabelByPatentIdAndProjectId(patent.getId(), projectId));
  663. patentDTO.setApplicant(patentApplicantService.getPatentApplicantByPatentId(patent.getId()));
  664. patentDTO.setInventor(patentInventorService.getPatentInventorByPatentId(patent.getId()));
  665. if (StringUtils.isNotEmpty(patent.getAgencyId())) {
  666. patentDTO.setAgency(patentAgencyService.getPatentAgencyById(Integer.parseInt(patent.getAgencyId())));
  667. } else {
  668. PatentAgency patentAgency = new PatentAgency();
  669. patentAgency.setName("");
  670. patentDTO.setAgency(patentAgency);
  671. }
  672. patentDTO.setAgent(patentAgentService.getPatentAgentByPatentId(patent.getId()));
  673. patentDTO.setAffair(patentAffairService.getPatentAffairByPatentId(patent.getId()));
  674. if (projectId != null) {
  675. patentDTO.setField(projectFieldService.getPatentFieldByPatentIdAndProjectId(projectId, patent.getId()));
  676. }
  677. if (StringUtils.isNotEmpty(patent.getPriorityCountry())) {
  678. List<String> priorityList = PatentUtils.formatValue(patent.getPriorityCountry());
  679. List<String> priorityCountryList = new ArrayList<>();
  680. for (String priorityCountry : priorityList) {
  681. priorityCountryList.add(systemDictList.stream().filter(systemDict -> systemDict.getType().equals(Constants.COUNTRIES) && systemDict.getValue().equals(priorityCountry)).findFirst().orElse(new SystemDict()).getLabel());
  682. }
  683. patentDTO.setPriorityCountry(priorityCountryList);
  684. }
  685. patentDTO.setInstruction(patentInstructionTextService.getPatentInstructionTextByPatentId(patent.getId()));
  686. patentDTO.setRights(patentRightService.getPatentRightByPatentId(patent.getId()));
  687. patentDTO.setImage(patentImageService.getPatentImageByPatentId(patent.getId()));
  688. patentDTO.setPdf(patentInstructionService.getPatentInstructionByPatentNo(patent.getPatentNo()));
  689. patentDTO.setIpc(patentClassNumberLinkList.stream().filter(patentClassNumberLink -> patentClassNumberLink.getType().equals(Constants.PATENT_CLASS_NUMBER_IPC) && patentClassNumberLink.getMain().equals(1)).findFirst().orElse(new PatentClassNumberLink()).getCode());
  690. patentDTO.setUpc(patentClassNumberLinkList.stream().filter(patentClassNumberLink -> patentClassNumberLink.getType().equals(Constants.PATENT_CLASS_NUMBER_UPC) && patentClassNumberLink.getMain().equals(1)).findFirst().orElse(new PatentClassNumberLink()).getCode());
  691. patentDTO.setIpcList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_IPC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  692. patentDTO.setCpcList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_CPC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  693. patentDTO.setUpcList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_UPC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  694. patentDTO.setLocList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_LOC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  695. return patentDTO;
  696. }
  697. public PatentDTO getPatentDTOById(String patentNo,Integer projectId) {
  698. LambdaQueryWrapper<Patent> wrapper = new LambdaQueryWrapper<>();
  699. wrapper.eq(Patent::getPatentNo, patentNo);
  700. List<Patent> patents =this.list(wrapper);
  701. PatentDTO patentDTO = new PatentDTO();
  702. //如果未查出专利则返回为空
  703. if (patents ==null||patents.size()==0) {
  704. return patentDTO;
  705. }
  706. Patent patent = patents.get(0);
  707. BeanUtils.copyProperties(patent, patentDTO);
  708. List<SystemDict> systemDictList = systemDictService.getSystemDictListByType(Arrays.asList(Constants.PATENT_TYPE, Constants.PATENT_SIMPLE_STATUS, Constants.COUNTRIES));
  709. List<PatentClassNumberLink> patentClassNumberLinkList = patentClassNumberLinkService.getPatentClassNumberLinkByPatentIds(Collections.singletonList(patent.getId()));
  710. if (patent.getPriorityNo() != null) {
  711. patentDTO.setPriorityNo(patent.getPriorityNo());
  712. } else {
  713. patentDTO.setPriorityNo("");
  714. }
  715. if (patent.getPriorityCountry() != null) {
  716. if (patent.getPriorityCountry().contains("\\|")) {
  717. List<String> countryList = StringUtils.changeStringToString(patent.getPriorityCountry().replaceAll(" ", ""), "\\|");
  718. patentDTO.setPriorityCountry(countryList);
  719. } else if (patent.getPriorityCountry().contains(",")) {
  720. List<String> countryList = StringUtils.changeStringToString(patent.getPriorityCountry().replaceAll(" ", ""), ",");
  721. patentDTO.setPriorityCountry(countryList);
  722. } else if (patent.getPriorityCountry().contains(";")) {
  723. List<String> countryList = StringUtils.changeStringToString(patent.getPriorityCountry().replaceAll(" ", ""), ";");
  724. patentDTO.setPriorityCountry(countryList);
  725. }
  726. } else {
  727. patentDTO.setPriorityCountry(Collections.singletonList(""));
  728. }
  729. patentDTO.setQuote("");
  730. if(patent.getQuote()!=null){
  731. patentDTO.setQuote(patent.getQuote());
  732. }
  733. patentDTO.setQuoted("");
  734. if(patent.getQuoted()!=null){
  735. patentDTO.setQuoted(patent.getQuoted());
  736. }
  737. //根据同族号,获得所有同族专利(三种同族)
  738. List<Integer> familyIds= new ArrayList<>();
  739. if(patent.getSimpleFamily()!=null)
  740. {familyIds.add(patent.getSimpleFamily());}
  741. if(patent.getInpadocFamily()!=null){
  742. familyIds.add(patent.getInpadocFamily());
  743. }
  744. if(patent.getPatSnapFamily()!=null){
  745. familyIds.add(patent.getPatSnapFamily());
  746. }
  747. if(familyIds.size()!=0) {
  748. LambdaQueryWrapper<PatentSimpleFamilyLink> queryWrapper = new LambdaQueryWrapper<>();
  749. queryWrapper.in(PatentSimpleFamilyLink::getFamilyId, familyIds);
  750. List<PatentSimpleFamilyLink> patentSimpleFamilyLinks = patentSimpleFamilyLinkService.list(queryWrapper);
  751. List<String> familyPatentNos = patentSimpleFamilyLinks.stream().map(PatentSimpleFamilyLink::getPatentNo).collect(Collectors.toList());
  752. PatentDTO.PatentFamily patentFamily =new PatentDTO.PatentFamily();
  753. patentFamily.setSimple(familyPatentNos);
  754. patentDTO.setFamily(patentFamily);
  755. }
  756. patentDTO.setApplicationDate(DateUtils.formatDate(patent.getApplicationDate(), DateUtils.YYYY_MM_DD));
  757. patentDTO.setPriorityDate(DateUtils.formatDate(patent.getPriorityDate(), DateUtils.YYYY_MM_DD));
  758. patentDTO.setPublicDate(DateUtils.formatDate(patent.getPublicDate(), DateUtils.YYYY_MM_DD));
  759. patentDTO.setPublicAccreditDate(DateUtils.formatDate(patent.getPublicAccreditDate(), DateUtils.YYYY_MM_DD));
  760. patentDTO.setFirstPublicDate(DateUtils.formatDate(patent.getFirstPublicDate(), DateUtils.YYYY_MM_DD));
  761. patentDTO.setSimpleStatus(systemDictList.stream().filter(systemDict -> systemDict.getType().equals(Constants.PATENT_SIMPLE_STATUS) && systemDict.getValue().equals(String.valueOf(patent.getSimpleStatus()))).findFirst().orElse(new SystemDict()).getLabel());
  762. patentDTO.setSimpleStatusInt(patent.getSimpleStatus());
  763. patentDTO.setType(systemDictList.stream().filter(systemDict -> systemDict.getType().equals(Constants.PATENT_TYPE) && systemDict.getValue().equals(String.valueOf(patent.getType()))).findFirst().orElse(new SystemDict()).getLabel());
  764. patentDTO.setApplicant(patentApplicantService.getPatentApplicantByPatentId(patent.getId()));
  765. patentDTO.setInventor(patentInventorService.getPatentInventorByPatentId(patent.getId()));
  766. if(projectId!=null) {
  767. patentDTO.setLabel(patentLabelService.getPatentLabelByPatentIdAndProjectId(patent.getId(), projectId));
  768. }
  769. if (StringUtils.isNotEmpty(patent.getAgencyId())) {
  770. patentDTO.setAgency(patentAgencyService.getPatentAgencyById(Integer.parseInt(patent.getAgencyId())));
  771. } else {
  772. PatentAgency patentAgency = new PatentAgency();
  773. patentAgency.setName("");
  774. patentDTO.setAgency(patentAgency);
  775. }
  776. patentDTO.setAgent(patentAgentService.getPatentAgentByPatentId(patent.getId()));
  777. patentDTO.setAffair(patentAffairService.getPatentAffairByPatentId(patent.getId()));
  778. if (StringUtils.isNotEmpty(patent.getPriorityCountry())) {
  779. List<String> priorityList = PatentUtils.formatValue(patent.getPriorityCountry());
  780. List<String> priorityCountryList = new ArrayList<>();
  781. for (String priorityCountry : priorityList) {
  782. priorityCountryList.add(systemDictList.stream().filter(systemDict -> systemDict.getType().equals(Constants.COUNTRIES) && systemDict.getValue().equals(priorityCountry)).findFirst().orElse(new SystemDict()).getLabel());
  783. }
  784. patentDTO.setPriorityCountry(priorityCountryList);
  785. }
  786. patentDTO.setInstruction(patentInstructionTextService.getPatentInstructionTextByPatentId(patent.getId()));
  787. patentDTO.setRights(patentRightService.getPatentRightByPatentId(patent.getId()));
  788. patentDTO.setImage(patentImageService.getPatentImageByPatentId(patent.getId()));
  789. patentDTO.setPdf(patentInstructionService.getPatentInstructionByPatentNo(patent.getPatentNo()));
  790. patentDTO.setIpc(patentClassNumberLinkList.stream().filter(patentClassNumberLink -> patentClassNumberLink.getType().equals(Constants.PATENT_CLASS_NUMBER_IPC) && patentClassNumberLink.getMain().equals(1)).findFirst().orElse(new PatentClassNumberLink()).getCode());
  791. patentDTO.setUpc(patentClassNumberLinkList.stream().filter(patentClassNumberLink -> patentClassNumberLink.getType().equals(Constants.PATENT_CLASS_NUMBER_UPC) && patentClassNumberLink.getMain().equals(1)).findFirst().orElse(new PatentClassNumberLink()).getCode());
  792. patentDTO.setIpcList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_IPC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  793. patentDTO.setCpcList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_CPC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  794. patentDTO.setUpcList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_UPC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  795. patentDTO.setLocList(patentClassNumberLinkList.stream().filter(patentClassNumber -> patentClassNumber.getType().equals(Constants.PATENT_CLASS_NUMBER_LOC)).map(PatentClassNumberLink::getCode).distinct().collect(Collectors.toList()));
  796. return patentDTO;
  797. }
  798. public List<Integer> getQueryPatentIds(PatentVO params) {
  799. if (params.getSelected() != null && params.getSelected().size() != 0 && params.getSelectId() != null && params.getSelectId()) {
  800. return params.getSelected().stream().distinct().collect(Collectors.toList());
  801. }
  802. this.setQueryPatentParams(params);
  803. List<Patent> patentList = baseMapper.getPageList(params);
  804. return patentList.stream().map(Patent::getId).distinct().collect(Collectors.toList());
  805. }
  806. @Async
  807. public void exportPatent(TaskParams taskParams) {
  808. try {
  809. List<PatentExportVO> selected = JsonUtils.jsonToList(taskParams.getSelected(), PatentExportVO.class);
  810. List<Integer> ids = StringUtils.changeStringToInteger(taskParams.getIds(), ",");
  811. if (selected != null) {
  812. List<String> columns = selected.stream().filter(PatentExportVO::getSelected).map(PatentExportVO::getKey).distinct().collect(Collectors.toList());
  813. List<String> headers = selected.stream().filter(PatentExportVO::getSelected).map(PatentExportVO::getName).distinct().collect(Collectors.toList());
  814. String fileName = IdUtil.simpleUUID() + ".xls";
  815. String directoryName = fileUtils.createDirectory();
  816. String savePath = fileUtils.getSavePath(directoryName);
  817. HSSFWorkbook hssfWorkbook = new HSSFWorkbook();
  818. HSSFSheet sheet = hssfWorkbook.createSheet();
  819. sheet.setDefaultColumnWidth(30);
  820. HSSFRow headerRow = sheet.createRow(0);
  821. headerRow.setHeight((short) 500);
  822. HSSFCellStyle headerCellStyle = hssfWorkbook.createCellStyle();
  823. HSSFCellStyle commonCellStyle = hssfWorkbook.createCellStyle();
  824. for (int i = 0; i < headers.size(); i++) {
  825. HSSFCell cell = headerRow.createCell(i);
  826. ExcelUtils.setExcelCellStyle(headerCellStyle);
  827. headerCellStyle.setAlignment(HorizontalAlignment.CENTER);
  828. headerCellStyle.setVerticalAlignment(VerticalAlignment.CENTER);
  829. headerCellStyle.setFillForegroundColor(HSSFColor.HSSFColorPredefined.SKY_BLUE.getIndex());
  830. headerCellStyle.setFillPattern(FillPatternType.SOLID_FOREGROUND);
  831. headerCellStyle.setWrapText(true);
  832. cell.setCellStyle(headerCellStyle);
  833. cell.setCellValue(headers.get(i));
  834. }
  835. for (int i = 0; i < ids.size(); i++) {
  836. Map<String, Object> map = new LinkedHashMap<>();
  837. PatentDTO patent = this.getPatentDTOById(ids.get(i), taskParams.getProjectId());
  838. if (patent == null) {
  839. continue;
  840. }
  841. String country = PatentUtils.getPatentCountry(patent.getPatentNo());
  842. for (int j = 0; j < columns.size(); j++) {
  843. String column = columns.get(j);
  844. PatentExportVO patentExportVO = selected.stream().filter(item -> item.getKey().equals(column)).findFirst().orElse(new PatentExportVO());
  845. Object value = null;
  846. switch (column) {
  847. case "pname":
  848. value = patent.getName();
  849. break;
  850. case "pname_out":
  851. value = patent.getNameOut();
  852. break;
  853. case "patentno":
  854. value = patent.getPatentNo();
  855. break;
  856. case "abstract":
  857. value = patent.getAbstractStr();
  858. break;
  859. case "abstract_out":
  860. value = patent.getAbstractOut();
  861. break;
  862. case "abstract_path":
  863. break;
  864. case "applicationno":
  865. value = patent.getApplicationNo();
  866. break;
  867. case "appdate":
  868. value = patent.getApplicationDate();
  869. break;
  870. case "publicno":
  871. value = patent.getPublicNo();
  872. break;
  873. case "publicdate":
  874. value = patent.getPublicDate();
  875. break;
  876. case "fpublicdate":
  877. value = patent.getFirstPublicDate();
  878. break;
  879. case "publictono":
  880. value = patent.getPublicAccreditNo();
  881. break;
  882. case "publictodate":
  883. value = patent.getPublicAccreditDate();
  884. break;
  885. case "tags":
  886. value = StringUtils.join(patent.getLabel().stream().map(PatentLabel::getName).distinct().collect(Collectors.toList()), "\n");
  887. break;
  888. case "bureau":
  889. value = patent.getBureau();
  890. break;
  891. case "simplefamily":
  892. List<PatentSimpleFamilyLink> patentSimpleFamilyLinkList = patentSimpleFamilyLinkService.getPatentSimpleFamilyLinkByFamilyIds(Collections.singletonList(patent.getSimpleFamily()));
  893. value = StringUtils.join(patentSimpleFamilyLinkList.stream().map(PatentSimpleFamilyLink::getPatentNo).collect(Collectors.toList()), Constants.SEPARATOR_VERTICAL_BAR);
  894. break;
  895. case "inpadocfamily":
  896. List<PatentSimpleFamilyLink> patentInpadocFamilyLinkList = patentSimpleFamilyLinkService.getPatentSimpleFamilyLinkByFamilyIds(Collections.singletonList(patent.getInpadocFamily()));
  897. value = StringUtils.join(patentInpadocFamilyLinkList.stream().map(PatentSimpleFamilyLink::getPatentNo).collect(Collectors.toList()), Constants.SEPARATOR_VERTICAL_BAR);
  898. break;
  899. case "patsnapfamily":
  900. List<PatentSimpleFamilyLink> patentPatSnapFamilyLinkList = patentSimpleFamilyLinkService.getPatentSimpleFamilyLinkByFamilyIds(Collections.singletonList(patent.getPatSnapFamily()));
  901. value = StringUtils.join(patentPatSnapFamilyLinkList.stream().map(PatentSimpleFamilyLink::getPatentNo).collect(Collectors.toList()), Constants.SEPARATOR_VERTICAL_BAR);
  902. break;
  903. case "ipc":
  904. value = StringUtils.join(patent.getIpcList(), Constants.SEPARATOR_VERTICAL_BAR);
  905. break;
  906. case "upc":
  907. value = StringUtils.join(patent.getUpcList(), Constants.SEPARATOR_VERTICAL_BAR);
  908. break;
  909. case "intclassno":
  910. value = patent.getIpc();
  911. break;
  912. case "intclasscpcno":
  913. value = StringUtils.join(patent.getCpcList(), Constants.SEPARATOR_VERTICAL_BAR);
  914. break;
  915. case "intclassupcno":
  916. value = patent.getUpc();
  917. break;
  918. case "intclasslocno":
  919. value = StringUtils.join(patent.getLocList(), Constants.SEPARATOR_VERTICAL_BAR);
  920. break;
  921. case "pstatus":
  922. value = patent.getSimpleStatus();
  923. break;
  924. case "ptype":
  925. value = patent.getType();
  926. break;
  927. case "law_datetime":
  928. value = PatentUtils.getPatentAffair(patent.getAffair(), 0);
  929. break;
  930. case "law_status":
  931. value = PatentUtils.getPatentAffair(patent.getAffair(), 1);
  932. break;
  933. case "law_simplestatus":
  934. value = PatentUtils.getPatentAffair(patent.getAffair(), 2);
  935. break;
  936. case "law_content":
  937. value = PatentUtils.getPatentAffair(patent.getAffair(), 3);
  938. break;
  939. case "applicant":
  940. value = StringUtils.join(patent.getApplicant().stream().filter(item -> item.getDataType().equals(2)).collect(Collectors.toList()).stream().map(PatentApplicant::getName).distinct().collect(Collectors.toList()), Constants.SEPARATOR_VERTICAL_BAR);
  941. break;
  942. case "applicant1":
  943. value = StringUtils.join(patent.getApplicant().stream().filter(item -> item.getDataType().equals(2)).collect(Collectors.toList()).stream().map(PatentApplicant::getShortName).distinct().collect(Collectors.toList()), Constants.SEPARATOR_VERTICAL_BAR);
  944. break;
  945. case "rightholder":
  946. value = StringUtils.join(patent.getApplicant().stream().filter(item -> item.getDataType().equals(1)).collect(Collectors.toList()).stream().map(PatentApplicant::getName).distinct().collect(Collectors.toList()), Constants.SEPARATOR_VERTICAL_BAR);
  947. break;
  948. case "rightholder1":
  949. value = StringUtils.join(patent.getApplicant().stream().filter(item -> item.getDataType().equals(1)).collect(Collectors.toList()).stream().map(PatentApplicant::getShortName).distinct().collect(Collectors.toList()), Constants.SEPARATOR_VERTICAL_BAR);
  950. break;
  951. case "applicantcountry":
  952. value = PatentUtils.getPeopleCountry(patent.getApplicant().stream().filter(item -> item.getDataType().equals(2)).collect(Collectors.toList()));
  953. break;
  954. case "rightholdercountry":
  955. value = PatentUtils.getPeopleCountry(patent.getApplicant().stream().filter(item -> item.getDataType().equals(1)).collect(Collectors.toList()));
  956. break;
  957. case "applicantaddress":
  958. value = PatentUtils.getPeopleAddress(patent.getApplicant().stream().filter(item -> item.getDataType().equals(2)).collect(Collectors.toList()));
  959. break;
  960. case "rightholderaddress":
  961. value = PatentUtils.getPeopleAddress(patent.getApplicant().stream().filter(item -> item.getDataType().equals(1)).collect(Collectors.toList()));
  962. break;
  963. case "applicantaddr":
  964. break;
  965. case "rightholderaddr":
  966. break;
  967. case "firstapplicant":
  968. PatentApplicant firstApplicant1 = patent.getApplicant().stream().filter(item -> item.getDataType().equals(2) && item.getOrder().equals(0)).findFirst().orElse(null);
  969. if (firstApplicant1 != null) {
  970. value = firstApplicant1.getName();
  971. }
  972. break;
  973. case "firstrightholder":
  974. PatentApplicant firstApplicant3 = patent.getApplicant().stream().filter(item -> item.getDataType().equals(1) && item.getOrder().equals(0)).findFirst().orElse(null);
  975. if (firstApplicant3 != null) {
  976. value = firstApplicant3.getName();
  977. }
  978. break;
  979. case "firstapplicantaddr":
  980. PatentApplicant firstApplicant2 = patent.getApplicant().stream().filter(item -> item.getDataType().equals(2) && item.getOrder().equals(0)).findFirst().orElse(null);
  981. if (firstApplicant2 != null) {
  982. value = firstApplicant2.getAddressStr();
  983. }
  984. break;
  985. case "firstrightholderaddr":
  986. PatentApplicant firstApplicant4 = patent.getApplicant().stream().filter(item -> item.getDataType().equals(1) && item.getOrder().equals(0)).findFirst().orElse(null);
  987. if (firstApplicant4 != null) {
  988. value = firstApplicant4.getAddressStr();
  989. }
  990. break;
  991. case "firstapplicantnum":
  992. value = patent.getApplicantNum();
  993. break;
  994. case "inventor":
  995. value = StringUtils.join(patent.getInventor().stream().map(PatentInventor::getName).distinct().collect(Collectors.toList()), Constants.SEPARATOR_VERTICAL_BAR);
  996. break;
  997. case "firstnventoraddr":
  998. value = patent.getInventor().stream().filter(PatentInventor::getFirst).findFirst().orElse(new PatentInventor()).getAddress();
  999. break;
  1000. case "firstnventor":
  1001. value = patent.getInventor().stream().filter(PatentInventor::getFirst).findFirst().orElse(new PatentInventor()).getName();
  1002. break;
  1003. case "inventornum":
  1004. value = patent.getInventorNum();
  1005. break;
  1006. case "num2":
  1007. value = patent.getRightNum();
  1008. break;
  1009. case "content":
  1010. case "content_out":
  1011. case "selfcontent":
  1012. List<String> content = new ArrayList<>();
  1013. if (column.equals("content")) {
  1014. content = patent.getRights().stream().map(PatentRight::getContent).collect(Collectors.toList());
  1015. }
  1016. if (column.equals("content_out")) {
  1017. content = patent.getRights().stream().map(PatentRight::getContentOut).collect(Collectors.toList());
  1018. }
  1019. if (column.equals("selfcontent")) {
  1020. content = patent.getRights().stream().filter(item -> item.getType().equals(1)).map(PatentRight::getContent).collect(Collectors.toList());
  1021. }
  1022. StringBuffer contentBuffer = new StringBuffer();
  1023. for (String s : content) {
  1024. contentBuffer.append(s);
  1025. switch (country) {
  1026. case "JP":
  1027. case "CN":
  1028. contentBuffer.append("。\n");
  1029. break;
  1030. default:
  1031. contentBuffer.append("\n");
  1032. }
  1033. }
  1034. value = contentBuffer.toString();
  1035. break;
  1036. case "priorityno":
  1037. value = patent.getPriorityNo();
  1038. break;
  1039. case "prioritycountry":
  1040. value = patent.getPriorityCountry();
  1041. break;
  1042. case "prioritydate":
  1043. value = patent.getPriorityDate();
  1044. break;
  1045. case "page":
  1046. value = patent.getDocPage();
  1047. break;
  1048. case "code":
  1049. value = patent.getCode();
  1050. break;
  1051. case "manual":
  1052. if (patent.getInstruction() != null) {
  1053. value = patent.getInstruction().getManual();
  1054. }
  1055. break;
  1056. case "simplefamilynum":
  1057. value = patent.getSimpleFamilyNum();
  1058. break;
  1059. case "inpadocfamilynum":
  1060. value = patent.getInpadocFamilyNum();
  1061. break;
  1062. case "patsnapfamilynum":
  1063. value = patent.getPatSnapFamilyNum();
  1064. break;
  1065. case "quoteno":
  1066. value = patent.getQuoteNum();
  1067. break;
  1068. case "quotedno":
  1069. value = patent.getQuotedNum();
  1070. break;
  1071. case "quotedno3":
  1072. value = patent.getQuotedNum3();
  1073. break;
  1074. case "quotedno5":
  1075. value = patent.getQuotedNum5();
  1076. break;
  1077. case "agency":
  1078. PatentAgency agency = patent.getAgency();
  1079. if (agency != null) {
  1080. value = agency.getName();
  1081. }
  1082. break;
  1083. case "agent":
  1084. value = StringUtils.join(patent.getAgent().stream().map(PatentAgent::getName).distinct().collect(Collectors.toList()), Constants.SEPARATOR_VERTICAL_BAR);
  1085. break;
  1086. case "wonational":
  1087. value = patent.getWo();
  1088. break;
  1089. case "examiner":
  1090. value = patent.getExaminer();
  1091. break;
  1092. case "assexaminer":
  1093. value = patent.getAidExaminer();
  1094. break;
  1095. case "quote":
  1096. value = patent.getQuote();
  1097. break;
  1098. case "quoted":
  1099. value = patent.getQuoted();
  1100. break;
  1101. case "nonpatentquote":
  1102. value = patent.getNotPatentQuote();
  1103. break;
  1104. case "epcountry":
  1105. value = patent.getEpStatus();
  1106. break;
  1107. default:
  1108. PatentDTO.Field field = patent.getField().stream().filter(item -> item.getId().equals(Integer.parseInt(column))).findFirst().orElse(null);
  1109. if (field != null) {
  1110. value = StringUtils.join(field.getSelected(), "\n");
  1111. }
  1112. }
  1113. map.put(patentExportVO.getName(), value);
  1114. }
  1115. HSSFRow row = sheet.createRow(i + 1);
  1116. row.setHeight((short) 800);
  1117. for (String key : map.keySet()) {
  1118. int index = headers.indexOf(key);
  1119. if (index != -1) {
  1120. HSSFCell cell = row.createCell(index);
  1121. ExcelUtils.setExcelCellStyle(commonCellStyle);
  1122. commonCellStyle.setVerticalAlignment(VerticalAlignment.TOP);
  1123. commonCellStyle.setWrapText(true);
  1124. cell.setCellStyle(commonCellStyle);
  1125. if (key.equals("摘要附图")) {
  1126. if (StringUtils.isNotEmpty(patent.getAbstractPath())) {
  1127. try {
  1128. byte[] pictureData = FileUtil.readBytes(fileUtils.getSystemPath(patent.getAbstractPath()));
  1129. if (pictureData != null) {
  1130. ExcelUtils.writePicture(sheet, index, i + 1, pictureData, HSSFWorkbook.PICTURE_TYPE_JPEG);
  1131. }
  1132. row.setHeight((short) 2500);
  1133. } catch (Exception e) {
  1134. }
  1135. }
  1136. } else if (StringUtils.isNotNull(map.get(key))) {
  1137. cell.setCellValue(String.valueOf(map.get(key)));
  1138. }
  1139. }
  1140. }
  1141. Integer total = ids.size();
  1142. WebSocketServer.sendInfo(Response.websocket(new TaskWebSocketDTO()
  1143. .setTaskId(taskParams.getTaskId())
  1144. .setProjectId(taskParams.getProjectId())
  1145. .setComplete(false)
  1146. .setIndex(i)
  1147. .setTaskType(Constants.TASK_EXPORT_PATENT)
  1148. .setPercentage(total == 0 ? 0 : Math.round((total.equals(i) ? (i * 1D) : (i + 1D)) / total * 100D))
  1149. .setFileName("")
  1150. .setOldName("")
  1151. .setUrl("")
  1152. .setTotal(total), ResponseEnum.PATENT_EXPORT_TASK_SUCCESS), taskParams.getUserId());
  1153. }
  1154. FileOutputStream fos = new FileOutputStream(savePath + fileName);
  1155. hssfWorkbook.write(fos);
  1156. fos.flush();
  1157. fos.close();
  1158. String url = fileUtils.getDirectory(fileName);
  1159. taskService.updateTime(taskParams.getTaskId(), 2, DateUtils.getDateTime(), url, fileName);
  1160. WebSocketServer.sendInfo(Response.websocket(new TaskWebSocketDTO()
  1161. .setTaskId(taskParams.getTaskId())
  1162. .setProjectId(taskParams.getProjectId())
  1163. .setComplete(true)
  1164. .setIndex(ids.size())
  1165. .setTaskType(Constants.TASK_EXPORT_PATENT)
  1166. .setPercentage(100L)
  1167. .setFileName(fileName)
  1168. .setOldName("")
  1169. .setUrl(url)
  1170. .setTotal(ids.size()), ResponseEnum.PATENT_EXPORT_TASK_SUCCESS), taskParams.getUserId());
  1171. }
  1172. } catch (Exception e) {
  1173. e.printStackTrace();
  1174. taskService.updateTime(taskParams.getTaskId(), 3, DateUtils.getDateTime(), null, null);
  1175. WebSocketServer.sendInfo(Response.error(ResponseEnum.PATENT_EXPORT_TASK_ERROR), taskParams.getUserId());
  1176. }
  1177. }
  1178. public IPage<PatentQueryFieldSourceDTO> getPatentQuerySourcePageList(PatentQueryFieldSourceVO params) {
  1179. return this.getPatentAttributeSourcePageList(params);
  1180. }
  1181. public IPage<PatentQueryFieldSourceDTO> getPatentAttributeSourcePageList(PatentQueryFieldSourceVO params) {
  1182. this.setPatentQuerySourceParams(params);
  1183. if (params.getKey().equals("40-0")) {
  1184. Integer projectId = params.getProjectId();
  1185. List<PatentQueryFieldSourceDTO> dataList = baseMapper.getCountStatus(projectId);
  1186. List<PatentQueryFieldSourceDTO> lstA = new ArrayList<>();
  1187. List<PatentQueryFieldSourceDTO> lstB = new ArrayList<>();
  1188. dataList.forEach(item -> {
  1189. if (StringUtils.changeStringToString(item.getLabel(), "\\|").size() > 1) {
  1190. lstA.add(item);
  1191. } else {
  1192. lstB.add(item);
  1193. }
  1194. });
  1195. lstA.forEach(item -> {
  1196. List<String> stringList = StringUtils.changeStringToString(item.getLabel(), "\\|");
  1197. stringList.forEach(x -> {
  1198. List<PatentQueryFieldSourceDTO> lstC = new ArrayList<>();
  1199. for (PatentQueryFieldSourceDTO patentQueryFieldSourceDTO : lstB) {
  1200. if (!lstB.stream().map(PatentQueryFieldSourceDTO::getLabel).collect(Collectors.toList()).contains(x)) {
  1201. PatentQueryFieldSourceDTO a = new PatentQueryFieldSourceDTO();
  1202. a.setCount(item.getCount());
  1203. a.setLabel(x);
  1204. lstC.add(a);
  1205. break;
  1206. }
  1207. if (patentQueryFieldSourceDTO.getLabel().equals(x)) {
  1208. patentQueryFieldSourceDTO.setCount(patentQueryFieldSourceDTO.getCount() + item.getCount());
  1209. }
  1210. }
  1211. lstB.addAll(lstC);
  1212. });
  1213. });
  1214. List<SystemDict> systemDictList = systemDictService.getSystemDictListByType(Collections.singletonList(Constants.PATENT_STATUS));
  1215. lstB.forEach(b -> {
  1216. Integer status = Integer.parseInt(systemDictList.stream()
  1217. .filter(systemDict -> systemDict.getType().equals(Constants.PATENT_STATUS) && systemDict.getLabel().equals(b.getLabel()))
  1218. .findFirst()
  1219. .orElse(new SystemDict()).getValue());
  1220. b.setValue(String.valueOf(status));
  1221. });
  1222. IPage<PatentQueryFieldSourceDTO> pageList = baseMapper.getPatentQuerySourcePageList(new Page<>(params.getCurrent(), params.getSize()), params, new ArrayList<>());
  1223. pageList.setRecords(lstB);
  1224. return pageList;
  1225. }
  1226. IPage<PatentQueryFieldSourceDTO> pageList = baseMapper.getPatentQuerySourcePageList(new Page<>(params.getCurrent(), params.getSize()), params, new ArrayList<>());
  1227. pageList.getRecords().forEach(item -> item.setIds(null));
  1228. return pageList;
  1229. }
  1230. public List<PatentQueryFieldSourceDTO> getPatentAttributeSourceList(PatentQueryFieldSourceVO params, List<Integer> patentIds) {
  1231. this.setPatentQuerySourceParams(params);
  1232. List<PatentQueryFieldSourceDTO> dataList = baseMapper.getPatentQuerySourcePageList(params, patentIds);
  1233. return dataList;
  1234. }
  1235. private void setPatentQuerySourceParams(PatentQueryFieldSourceVO params) {
  1236. List<Integer> field = StringUtils.changeStringToInteger(params.getKey(), "-");
  1237. Integer type = 0;
  1238. Integer level = 0;
  1239. Integer status = 0;
  1240. switch (params.getKey()) {
  1241. case "18-6":
  1242. case "18-7":
  1243. case "18-8":
  1244. case "23-6":
  1245. case "23-7":
  1246. case "23-8":
  1247. params.setApplicantType(2);
  1248. break;
  1249. case "19-6":
  1250. case "19-7":
  1251. case "19-8":
  1252. case "24-6":
  1253. case "24-7":
  1254. case "24-8":
  1255. params.setApplicantType(1);
  1256. break;
  1257. case "29-17":
  1258. case "30-17":
  1259. case "29-18":
  1260. case "29-19":
  1261. case "29-20":
  1262. case "30-18":
  1263. case "30-19":
  1264. case "30-20":
  1265. params.setApplicantType(field.get(0) == 29 ? 2 : 1);
  1266. break;
  1267. default:
  1268. params.setCustomFieldId(field.get(0));
  1269. if (params.getType().equals("6") && field.get(1).equals(0)) {
  1270. params.setCustomFieldTreeType(0);
  1271. } else {
  1272. params.setCustomFieldTreeType(null);
  1273. }
  1274. }
  1275. }
  1276. public void updatePatentCustomField(PatentCustomFieldParams params) {
  1277. List<CustomFieldDTO> dataList = new ArrayList<>();
  1278. for (String key : params.keySet()) {
  1279. List<String> fields = StringUtils.changeStringToString(key, ":");
  1280. if (fields.size() == 2) {
  1281. Object name = fields.get(0);
  1282. Object selected = params.get(key);
  1283. List<String> select = JsonUtils.jsonToList(JsonUtils.objectToJson(selected), String.class);
  1284. if (StringUtils.isNull(select)) {
  1285. select = new ArrayList<>();
  1286. }
  1287. CustomFieldDTO data = new CustomFieldDTO();
  1288. data.setName(name.toString());
  1289. data.setSelected(select);
  1290. data.setType(Integer.parseInt(fields.get(1)));
  1291. dataList.add(data);
  1292. }
  1293. }
  1294. for (CustomFieldDTO data : dataList) {
  1295. ProjectField projectField = projectFieldService.getProjectFieldByNameAndType(data.getName(), data.getType(), params.getProjectId(), params.getUserId());
  1296. projectFieldPatentLinkService.deleteByPatentIdAndProjectIdAndFieldId(params.getPatentId(), params.getProjectId(), projectField.getId());
  1297. switch (projectField.getType()) {
  1298. case 0:
  1299. case 1:
  1300. case 2:
  1301. for (String text : data.getSelected()) {
  1302. ProjectFieldText projectFieldText = projectFieldTextService.getProjectFieldTextByNameAndFieldId(text, projectField.getId());
  1303. if (projectFieldText == null) {
  1304. projectFieldText = new ProjectFieldText();
  1305. projectFieldText.setFieldId(projectField.getId());
  1306. projectFieldText.setText(text);
  1307. projectFieldText.insert();
  1308. }
  1309. projectFieldPatentLinkService.updateProjectPatentLink(params.getPatentId(), projectField.getType(), projectField.getId(), projectFieldText.getId(), params.getUserId(), params.getProjectId());
  1310. }
  1311. break;
  1312. case 3:
  1313. case 4:
  1314. case 5:
  1315. for (String option : data.getSelected()) {
  1316. ProjectFieldOption projectFieldOption = projectFieldOptionService.getProjectFieldOptionByNameAndFieldId(option, projectField.getId());
  1317. if (projectFieldOption == null) {
  1318. projectFieldOption = new ProjectFieldOption();
  1319. projectFieldOption.setFieldId(projectField.getId());
  1320. projectFieldOption.setName(option);
  1321. projectFieldOption.insert();
  1322. }
  1323. projectFieldPatentLinkService.updateProjectPatentLink(params.getPatentId(), projectField.getType(), projectField.getId(), projectFieldOption.getId(), params.getUserId(), params.getProjectId());
  1324. }
  1325. break;
  1326. case 6:
  1327. for (String tree : data.getSelected()) {
  1328. List<String> treeNode = StringUtils.changeStringToString(tree, "\\\\");
  1329. Integer treeNodeId = projectFieldTreeService.getTreeNodeIdByPathNameAndUpdateTreeData(treeNode, projectField);
  1330. if (treeNodeId != 0) {
  1331. projectFieldPatentLinkService.updateProjectPatentLink(params.getPatentId(), projectField.getType(), projectField.getId(), treeNodeId, params.getUserId(), params.getProjectId());
  1332. }
  1333. }
  1334. break;
  1335. }
  1336. }
  1337. }
  1338. public Map<String, Object> getBetweenPatentList(PatentVO params) {
  1339. this.setQueryPatentParams(params);
  1340. List<Patent> patentList = baseMapper.getPageList(params);
  1341. int index = patentList.stream().map(Patent::getId).collect(Collectors.toList()).indexOf(params.getPatentId());
  1342. Map<String, Object> map = new HashMap<>();
  1343. if (index > 0) {
  1344. Patent patent = patentList.get(index - 1);
  1345. Map<String, Object> prev = new HashMap<>();
  1346. prev.put("id", patent.getId());
  1347. prev.put("patentNo", patent.getPatentNo());
  1348. prev.put("total", index);
  1349. map.put("prev", prev);
  1350. }
  1351. if (index < patentList.size() - 1) {
  1352. Patent patent = patentList.get(index + 1);
  1353. Map<String, Object> next = new HashMap<>();
  1354. next.put("id", patent.getId());
  1355. next.put("patentNo", patent.getPatentNo());
  1356. next.put("total", patentList.size() - index - 1);
  1357. map.put("next", next);
  1358. }
  1359. return map;
  1360. }
  1361. public void importPatent(Integer projectId, String patentJson, String patentAffairJson, String patentAgencyJson, String patentFamilyJson, String patentFamilyLinkJson, String patentInventorJson, String patentInventorLinkJson, String patentAgentJson, String patentAgentLinkJson, String patentApplicantJson, String patentApplicantLinkJson, String patentApplicantMergeLinkJson, String patentClassNumberJson, String patentInstructionTextJson, String patentRightJson, String patentLicensorJson, String patentPledgeJson, String patentInventorMergeJson) {
  1362. List<Patent> importPatentList = JsonUtils.jsonToList(patentJson, Patent.class);
  1363. List<PatentAffair> importPatentAffairList = JsonUtils.jsonToList(patentAffairJson, PatentAffair.class);
  1364. List<PatentAgency> importPatentAgencyList = JsonUtils.jsonToList(patentAgencyJson, PatentAgency.class);
  1365. List<PatentAgent> importPatentAgentList = JsonUtils.jsonToList(patentAgentJson, PatentAgent.class);
  1366. List<PatentAgentLink> importPatentAgentLinkList = JsonUtils.jsonToList(patentAgentLinkJson, PatentAgentLink.class);
  1367. List<PatentInventor> importPatentInventorList = JsonUtils.jsonToList(patentInventorJson, PatentInventor.class);
  1368. List<PatentInventorMerge> importPatentInventorMergeList = JsonUtils.jsonToList(patentInventorMergeJson, PatentInventorMerge.class);
  1369. List<PatentInventorLink> importPatentInventorLinkList = JsonUtils.jsonToList(patentInventorLinkJson, PatentInventorLink.class);
  1370. List<PatentApplicant> importPatentApplicantList = JsonUtils.jsonToList(patentApplicantJson, PatentApplicant.class);
  1371. List<PatentApplicantLink> importPatentApplicantLinkList = JsonUtils.jsonToList(patentApplicantLinkJson, PatentApplicantLink.class);
  1372. List<PatentApplicantMergeLink> importPatentApplicantMergeLinkList = JsonUtils.jsonToList(patentApplicantMergeLinkJson, PatentApplicantMergeLink.class);
  1373. List<PatentSimpleFamily> importPatentSimpleFamilyList = JsonUtils.jsonToList(patentFamilyJson, PatentSimpleFamily.class);
  1374. List<PatentSimpleFamilyLink> importPatentSimpleFamilyLinkList = JsonUtils.jsonToList(patentFamilyLinkJson, PatentSimpleFamilyLink.class);
  1375. List<PatentClassNumberLink> importPatentClassNumberLinkList = JsonUtils.jsonToList(patentClassNumberJson, PatentClassNumberLink.class);
  1376. List<PatentInstructionText> importPatentInstructionTextList = JsonUtils.jsonToList(patentInstructionTextJson, PatentInstructionText.class);
  1377. List<PatentRight> importPatentRightList = JsonUtils.jsonToList(patentRightJson, PatentRight.class);
  1378. List<PatentLicensor> importPatentLicensorList = JsonUtils.jsonToList(patentLicensorJson, PatentLicensor.class);
  1379. List<PatentPledge> importPatentPledgeList = JsonUtils.jsonToList(patentPledgeJson, PatentPledge.class);
  1380. List<Patent> localPatentList = this.getPatentListByPatentNo(importPatentList.stream().map(Patent::getPatentNo).collect(Collectors.toList()));
  1381. List<Patent> patentList = new ArrayList<>();
  1382. for (Patent importPatent : importPatentList) {
  1383. Patent localPatent = localPatentList.stream().filter(item -> item.getPatentNo().equals(importPatent.getPatentNo())).findFirst().orElse(null);
  1384. Integer patentId;
  1385. if (localPatent == null) {
  1386. localPatent = new Patent();
  1387. patentId = null;
  1388. } else {
  1389. patentId = localPatent.getId();
  1390. }
  1391. BeanUtils.copyProperties(importPatent, localPatent);
  1392. localPatent.setId(patentId);
  1393. if (StringUtils.isNotEmpty(importPatent.getAgencyId())) {
  1394. PatentAgency importPatentAgency = importPatentAgencyList.stream().filter(item -> item.getId().equals(Integer.valueOf(importPatent.getAgencyId()))).findFirst().orElse(new PatentAgency());
  1395. localPatent.setAgencyId(patentAgencyService.getAgencyStringIdByName(importPatentAgency.getName()));
  1396. }
  1397. localPatent.insertOrUpdate();
  1398. patentList.add(localPatent);
  1399. }
  1400. for (Patent patent : patentList) {
  1401. Patent importPatent = importPatentList.stream().filter(item -> item.getPatentNo().equals(patent.getPatentNo())).findFirst().orElse(new Patent());
  1402. patentAffairService.importPatentAffair(patent, importPatentList, importPatentAffairList);
  1403. patentAgentService.importPatentAgent(patent.getId(), importPatent.getId(), importPatentAgentList, importPatentAgentLinkList);
  1404. patentSimpleFamilyService.importPatentSimpleFamily(patent, importPatentSimpleFamilyList, importPatentSimpleFamilyLinkList);
  1405. patentInventorService.importPatentInventor(patent.getId(), importPatent.getId(), importPatentInventorList, importPatentInventorLinkList);
  1406. patentApplicantService.importPatentApplicant(projectId, patent.getId(), importPatent.getId(), importPatentApplicantList, importPatentApplicantLinkList);
  1407. patentClassNumberLinkService.importPatentClassNumberLink(patent.getId(), importPatent.getId(), importPatentClassNumberLinkList);
  1408. patentInstructionTextService.importPatentInstructionText(patent.getId(), importPatent.getId(), importPatentInstructionTextList);
  1409. patentRightService.importPatentRight(patent.getId(), importPatent.getId(), importPatentRightList);
  1410. patentLicensorService.importPatentLicensor(patent.getId(), importPatent.getId(), importPatentLicensorList);
  1411. patentPledgeService.importPatentPledge(patent.getId(), importPatent.getId(), importPatentPledgeList);
  1412. }
  1413. patentInventorMergeService.importPatentInventorMergeLink(projectId, importPatentInventorList, importPatentInventorMergeList);
  1414. patentApplicantMergeLinkService.importPatentApplicantMergeLink(projectId, importPatentApplicantList, importPatentApplicantMergeLinkList);
  1415. }
  1416. public String getPatentNos(Integer projectId) {
  1417. //根据专题库号获得专利id
  1418. LambdaQueryWrapper<ProjectPatentLink> wrapper = new LambdaQueryWrapper<>();
  1419. wrapper.select(ProjectPatentLink::getPatentId).eq(ProjectPatentLink::getProjectId, projectId);
  1420. List<ProjectPatentLink> projectPatentLinkList = projectPatentLinkService.list(wrapper);
  1421. List<Integer> patentIds = projectPatentLinkList.stream().map(ProjectPatentLink::getPatentId).collect(Collectors.toList());
  1422. //根据专利Id获得专利号
  1423. LambdaQueryWrapper<Patent> queryWrapper = new LambdaQueryWrapper<>();
  1424. queryWrapper.in(Patent::getId, patentIds);
  1425. List<Patent> patents = this.list(queryWrapper);
  1426. List<String> patentNos = patents.stream().map(Patent::getPatentNo).collect(Collectors.toList());
  1427. return Response.success(patentNos);
  1428. }
  1429. public String getPagination(List<String> list,int location){
  1430. Map map=new HashMap();
  1431. LambdaQueryWrapper<Patent> wrapper =new LambdaQueryWrapper<>();
  1432. wrapper.in(Patent::getPatentNo,list);
  1433. Integer totalNumber = Math.toIntExact(this.count(wrapper));
  1434. if(location>=totalNumber){
  1435. location=totalNumber;
  1436. int a=location-2;
  1437. int b=2;
  1438. List<Patent> patent = patentMapper.getPatent(list, a, b);
  1439. int front=location-1;
  1440. String str1 =patent.get(0).getPatentNo();
  1441. String srr2= patent.get(1).getPatentNo();
  1442. int i=patent.get(0).getId();
  1443. int j=patent.get(1).getId();
  1444. map.put("frontID",i);
  1445. map.put("currentID",j);
  1446. map.put("behindPatentNo",null);
  1447. map.put("frontNumber",front);
  1448. map.put("behindNumber",0);
  1449. map.put("frontPatentNo",str1);
  1450. map.put("currentPatentNo",srr2);
  1451. map.put("totalNumber",totalNumber);
  1452. return Response.success(map);
  1453. }
  1454. if(location==1){
  1455. int a=0;
  1456. int p=2;
  1457. List<Patent> patent = patentMapper.getPatent(list, a, p);
  1458. String str1 =patent.get(0).getPatentNo();
  1459. String srr2= patent.get(1).getPatentNo();
  1460. int i=patent.get(0).getId();
  1461. int j=patent.get(1).getId();
  1462. map.put("currentID",i);
  1463. map.put("behindID",j);
  1464. map.put("currentPatentNo",str1);
  1465. map.put("behindPatentNo",srr2);
  1466. map.put("frontPatentNo",null);
  1467. map.put("frontNumber",0);
  1468. int behindNumber=totalNumber-location;
  1469. map.put("behindNumber",behindNumber);
  1470. map.put("totalNumber",totalNumber);
  1471. return Response.success(map);
  1472. }
  1473. int a=location-2;
  1474. int p=3;
  1475. List<Patent> patent = patentMapper.getPatent(list, a, p);
  1476. String str1 =patent.get(0).getPatentNo();
  1477. String str2 =patent.get(1).getPatentNo();
  1478. String str3 =patent.get(2).getPatentNo();
  1479. int i=patent.get(0).getId();
  1480. int j=patent.get(1).getId();
  1481. int k=patent.get(2).getId();
  1482. map.put("frontID",i);
  1483. map.put("currentID",j);
  1484. map.put("behindID",k);
  1485. map.put("frontPatentNo",str1);
  1486. map.put("currentPatentNo",str2);
  1487. map.put("behindPatentNo",str3);
  1488. map.put("totalNumber",totalNumber);
  1489. int behindNumber=totalNumber-location;
  1490. int frontNumber=location-1;
  1491. map.put("behindNumber",behindNumber);
  1492. map.put("frontNumber",frontNumber);
  1493. return Response.success(map);
  1494. }
  1495. }