package cn.cslg.pas.service; import cn.cslg.pas.common.dto.PatentDTO; import cn.cslg.pas.common.dto.business.EsPatentFamilyDTO; import cn.cslg.pas.common.model.cronModel.Records; import cn.cslg.pas.common.model.request.*; import cn.cslg.pas.common.utils.Response; import cn.cslg.pas.controller.EventController; import cn.cslg.pas.controller.PatentController; import cn.cslg.pas.domain.es.FamilyPatent; import cn.cslg.pas.domain.es.Patent; import cn.cslg.pas.domain.es.PatentFamilyMessage; import cn.cslg.pas.service.business.ProductMarketDataService; import cn.cslg.pas.service.business.es.EsService; import co.elastic.clients.elasticsearch.core.DeleteRequest; import com.alibaba.fastjson.JSONObject; import org.apache.http.entity.ContentType; import org.junit.Before; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.mock.web.MockMultipartFile; import org.springframework.web.multipart.MultipartFile; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.util.*; /** * @author chenyu * @date 2023/9/6 */ @SpringBootTest public class EventServiceTests { @Autowired private EventController eventController; @Autowired PatentController patentController; @Autowired private EsService esService; @Autowired private ProductMarketDataService productMarketDataService; @Test void test() throws Exception { StringRequest queryRequest = new StringRequest(); queryRequest.setSearchQuery("id=52"); List dtos = new ArrayList<>(); OrderDTO orderDTO1 = new OrderDTO(); orderDTO1.setOrderBy("name"); orderDTO1.setOrderType(0); OrderDTO orderDTO2 = new OrderDTO(); orderDTO2.setOrderBy("createName"); orderDTO2.setOrderType(1); dtos.add(orderDTO1); dtos.add(orderDTO2); queryRequest.setOrderDTOList(dtos); queryRequest.setCurrent(Long.parseLong("1")); queryRequest.setSize(Long.parseLong("10")); Response response = eventController.queryEvent(queryRequest); System.out.println(response); } @Test void add() throws Exception { JSONObject jsonObj = new JSONObject(); jsonObj.put("name", "事件4"); jsonObj.put("description", "描述1"); jsonObj.put("clientId", 1); jsonObj.put("scenarioId", 2); jsonObj.put("eventDate",""); String json_to_string = JSONObject.toJSONString(jsonObj); List list = new ArrayList<>(); File file = new File("C:\\Users\\admin\\Desktop\\test.txt"); MultipartFile mulFile = new MockMultipartFile( "th.jpg", //文件名 "th.jpg", //originalName 相当于上传文件在客户机上的文件名 ContentType.APPLICATION_OCTET_STREAM.toString(), //文件类型 new FileInputStream(file) //文件流 ); list.add(mulFile); eventController.addEvent(json_to_string, list); } @Test void groupEvent() throws Exception { StringGroupRequest queryRequest = new StringGroupRequest(); queryRequest.setSearchQuery("name~事件 and createName=朱"); List dtos = new ArrayList<>(); OrderDTO orderDTO1 = new OrderDTO(); orderDTO1.setOrderBy("name"); orderDTO1.setOrderType(0); OrderDTO orderDTO2 = new OrderDTO(); orderDTO2.setOrderBy("createName"); orderDTO2.setOrderType(1); dtos.add(orderDTO1); dtos.add(orderDTO2); queryRequest.setOrderDTOList(dtos); queryRequest.setCurrent(Long.parseLong("1")); queryRequest.setSize(Long.parseLong("10")); queryRequest.setGroupBy("name"); eventController.groupEvent(queryRequest); } @Test void test1() throws Exception { StringGroupRequest groupRequest = new StringGroupRequest(); groupRequest.setGroupBy("groupMonthTime"); Records records=(Records) productMarketDataService.getGroup(groupRequest,"productMarketData"); System.out.println(records); } @Test void test11() throws Exception { // List list = esService.Search("publicDate=2009-03", 0, 50,null); // MapRequest mapRequest = new MapRequest(); // Map map = new HashMap<>(); // map.put("titleTextContent", "电子"); // map.put("patentNo", "CN201199922Y"); // mapRequest.setSearchQuery(map); // mapRequest.setCurrent(0L); // mapRequest.setSize(50L); // mapRequest.setProjectId(1); StringRequest stringRequest = new StringRequest(); stringRequest.setSearchQuery("appCity=济南"); // stringRequest.setSearchQuery("mipcLevel1=H"); // stringRequest.setSearchQuery("agent=李桂存"); // stringRequest.setSearchQuery("IN=郝旭东"); // stringRequest.setSearchQuery("simpleStatus=3"); // stringRequest.setSearchQuery("CL=一种考虑电流限制和出力水平的分布式光伏机电暂态建模方法"); // stringRequest.setSearchQuery("AB=一种考虑电流限制和出力水平的分布式光伏机电暂态模型"); // stringRequest.setSearchQuery("PN=CN114513005B"); // stringRequest.setSearchQuery("AN=CN201810025278.2"); // stringRequest.setSearchQuery("patentNo=CN"); // stringRequest.setSearchQuery("PD<=200903"); // stringRequest.setSearchQuery("patentNo=CN201199922Y and (simpleFamilyNum>1 or simpleFamilyNum=0)"); stringRequest.setCurrent(1L); stringRequest.setSize(5L); // stringRequest.setProjectId(1); // PatentDTO patentDTO = esService.esSearch(stringRequest); System.out.println(patentDTO); } @Test void test12() throws IOException { Boolean bool = esService.searchPatent("YiQCGowBmB3pRkTj4NNG", 5); System.out.println(bool); } @Test void getpagetexst() throws IOException{ //1.添加一批数据(10) //2.调用查询取第一页(5笔一页) //3.判断5笔数据是正确的; //4.删除测试数据 List list = Arrays.asList(1, 2, 3, 4); List list1 = Arrays.asList(4, 5); // list1.removeAll(list); System.out.println(list1); } @Test void add1() throws Exception { List list = new ArrayList<>(); FamilyPatent patent =new FamilyPatent(); patent.setAppNo("CN147258369"); patent.setGrantNo("CN258369147"); patent.setPublicNo("CN369258147"); FamilyPatent patent1 =new FamilyPatent(); patent1.setAppNo("US147258369"); patent1.setGrantNo("US258369147"); patent1.setPublicNo("US369258147"); list.add(patent); list.add(patent1); PatentFamilyMessage patentFamilyMessage =new PatentFamilyMessage(); patentFamilyMessage.setPatent(list); patentFamilyMessage.setFamilyType("test"); String id = esService.addPatentFamily(patentFamilyMessage); System.out.println(id); } @Test void test3() throws IOException { List stringList = Arrays.asList("US369258147", "US258369147", "14528"); EsPatentFamilyDTO test = esService.addEsPatentFamily(stringList, "test"); System.out.println(test); } @Test void test4() throws IOException { // List stringList = Arrays.asList("US369258147", "US258369147", "14528"); // EsPatentFamilyDTO test = esService.selectEsPatentFamily(stringList, "test"); // System.out.println(test); } }