PAS/src/test/java/cn/cslg/pas/service/EventServiceTests.java

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<OrderDTO> 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<MultipartFile> 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<OrderDTO> 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<Patent> list = esService.Search("publicDate=2009-03", 0, 50,null);
//        MapRequest mapRequest = new MapRequest();
//        Map<String, Object> 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<Integer> list = Arrays.asList(1, 2, 3, 4);
        List<Integer> list1 = Arrays.asList(4, 5);
//        list1.removeAll(list);
        System.out.println(list1);
    }

    @Test
    void add1() throws Exception {
        List<FamilyPatent> 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<String> stringList = Arrays.asList("US369258147", "US258369147", "14528");
        EsPatentFamilyDTO test = esService.addEsPatentFamily(stringList, "test");
        System.out.println(test);
    }

    @Test
    void test4() throws IOException {
//        List<String> stringList = Arrays.asList("US369258147", "US258369147", "14528");
//        EsPatentFamilyDTO test = esService.selectEsPatentFamily(stringList, "test");
//        System.out.println(test);
    }
}