Springboot_japhet_es搜索

【实例截图】

【核心代码】

package com.japhet.test.controller;

import com.japhet.test.bean.es.EsUserBean;
import com.japhet.test.bean.mysql.UserBean;
import com.japhet.test.service.EsService;
import com.japhet.test.service.UserService;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.WildcardQueryBuilder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.stereotype.Controller;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.StopWatch;
import org.springframework.web.bind.annotation.*;

import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * @author japhet_jiu
 * @version 1.0
 */
@Controller
public class DataController {

    @Autowired
    UserService userService;

    @Autowired
    EsService esService;

    @ResponseBody
    @GetMapping("/selectAll")
    public Map<String, Object> selectAll() {
        Map<String, Object> map = new HashMap<String, Object>();
        List<UserBean> userBeans = userService.selectUserBeanList(new UserBean());
        map.put("userBeans", userBeans);
        return map;
    }

    /**
     * @param type
     * @param keyword
     * @return
     * @PathVariable用于告诉Spring URI路径的一部分是您希望传递给方法的值。这是你想要的，还是应该将形式数据的变量发布到URI？
     * <p>
     * 如果您想要表单数据，请使用@RequestParam而不是@PathVariable。
     */
    @PostMapping("/search")
    @ResponseBody
    public Object search(@RequestParam("type") String type, @RequestParam("keyword") String keyword) {
        HashMap<String, Object> map = new HashMap<>();
        StopWatch stopWatch = new StopWatch();
        stopWatch.start();
        WildcardQueryBuilder builder = QueryBuilders.wildcardQuery("name", "*"   keyword   "*");
            /*builder.should(QueryBuilders.wildcardQuery("name","*" keyword "*"));
            builder.should(QueryBuilders.wildcardQuery("phone","*" keyword "*"));
            builder.should(QueryBuilders.wildcardQuery("remark","*" keyword "*"));*/
        String s = builder.toString();
        System.out.println("es的数据查询 === "   s);
//            Iterable<EsUserInfo> search = esUserInfoDao.search(builder);
        Page<EsUserBean> search = (Page<EsUserBean>) esService.search(builder);
        List<EsUserBean> content = search.getContent();
        map.put("list", content);
        stopWatch.stop();
        map.put("totalTimeMillis", stopWatch.getTotalTimeMillis());
        return map;
    }

    @PostMapping("/updateSave")
    @ResponseBody
    @Transactional(rollbackFor = Exception.class)
    public Map<String, Object> updateSave(@RequestParam("id") String id, @RequestParam("name") String name, @RequestParam("age") String age, @RequestParam("phone") String phone, @RequestParam("remark") String remark) {
        Map<String, Object> map = new HashMap<String, Object>();
        //修改mysql数据库
        UserBean ub = new UserBean();
        ub.setId(Integer.parseInt(id));
        ub.setName(name);
        ub.setAge(Integer.parseInt(age));
        ub.setPhone(phone);
        ub.setRemark(remark);
        int row = userService.updateById(ub);
        //修改es
        EsUserBean esUserBean = esService.queryEmployeeById(id);
        esUserBean.setId(Integer.parseInt(id));
        esUserBean.setName(name);
        esUserBean.setAge(Integer.parseInt(age));
        esUserBean.setPhone(phone);
        esUserBean.setRemark(remark);
        esService.save(esUserBean);
        if (row > 0) {
            map.put("code", "200");
            map.put("msg", "操作成功");
        } else {
            map.put("code", "500");
            map.put("msg", "网络异常");
        }
        return map;
    }

    @PostMapping("/addSave")
    @ResponseBody
    @Transactional(rollbackFor = Exception.class)
    public Map<String, Object> addSave(@RequestParam("name") String name, @RequestParam("age") String age, @RequestParam("phone") String phone, @RequestParam("remark") String remark) {
        Map<String, Object> map = new HashMap<String, Object>();

        //向mysql添加数据
        UserBean ub = new UserBean();
        ub.setName(name);
        ub.setPassword(name);
        ub.setAge(Integer.parseInt(age));
        ub.setPhone(phone);
        ub.setRemark(remark);
        Date date = new Date();
        Date date2 = new Date();
        ub.setCreateTime(date);
        ub.setUpdateTime(date2);
        int row = userService.save(ub);


        //向es添加数据
        List<UserBean> userBeans = userService.selectUserBeanList(ub);
        EsUserBean eub = new EsUserBean();
        eub.setId(userBeans.get(0).getId()); //确保es mysql 的id一样
        eub.setName(name);
        eub.setPassword(name);
        eub.setAge(Integer.parseInt(age));
        eub.setPhone(phone);
        eub.setRemark(remark);
        eub.setCreateTime(date);
        eub.setUpdateTime(date2);
        EsUserBean save = esService.save(eub);
        if (row > 0) {
            map.put("code", "200");
            map.put("msg", "操作成功");
        } else {
            map.put("code", "500");
            map.put("msg", "网络异常");
        }
        return map;
    }


    @GetMapping("/deleteById/{id}")
    @ResponseBody
    @Transactional(rollbackFor = Exception.class)
    public Map<String, Object> deleteById(@PathVariable("id") String id) {
        Map<String, Object> map = new HashMap<String, Object>();
        //删除mysql 数据库
        int row = userService.deleteById(id);

        //删除es
        EsUserBean esUserBean = esService.queryEmployeeById(id);
        esService.delete(esUserBean);

        if (row > 0) {
            map.put("code", "200");
            map.put("msg", "操作成功");
        } else {
            map.put("code", "500");
            map.put("msg", "网络异常");
        }
        return map;
    }

}