Java 访问 DataInsight Demo

GkycAction.java （挂科预测）

package com.bp.gkyc.action;

import java.io.IOException;
import java.util.List;
import java.util.Map;

import org.apache.http.HttpEntity;
import org.apache.http.ParseException;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import org.springframework.stereotype.Controller;
import org.springframework.ui.ModelMap;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;

import com.alibaba.fastjson.JSONObject;

@Controller
@RequestMapping("/bp/gkyc")
public class GkycAction {

    @RequestMapping
    public String index(ModelMap map) {
        return "bp/gkyc/gkyc";
    }

    @ResponseBody
    @RequestMapping(value = "gkuser", method = RequestMethod.POST)
    public String getGkUser() {
        String res ="";
        try {
            JSONObject body = new JSONObject();
            String dsl = "es "stu-model" --maxevent=1000 | where score==-1 | applymodel "BpNeural","stuScoreModel" --inputFields="clubtime,schoolAbsent,classAbsent,entertainmentInternet" --predictField="PredictScore" | keep "name","PredictScore" | sort PredictScore";
            JSONObject params = new JSONObject();
            params.put("sync", true);
            body.put("dsl", dsl);
            body.put("params", params);
            String str = body.toJSONString();
            String url = "http://localhost:9000/explorer/query/";
            CloseableHttpClient client = HttpClients.createDefault();
            HttpPost post = new HttpPost(url);
            if (!str.isEmpty()) {
                post.setEntity(new StringEntity(str, ContentType.APPLICATION_JSON));
            }
            CloseableHttpResponse response = client.execute(post);
            HttpEntity entity = response.getEntity();

            res = EntityUtils.toString(entity);

            if (entity != null) {
                EntityUtils.consume(entity);
            }
            client.close();
        } catch (ParseException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return res;
    }

}

js

    Util.ajax({
        url : contextpath + "/bp/gk/gkuser" ,//请求后台的路径
        success : function(data){
            var gkxs = "";
            for(var i=1;i<11;i++){
                if(i==1){
                    gkxs += "<a href="#" name="xslb" id="xs"+i+"" onclick="clickxs("+i+")" class="list-group-item active">"+data.content.data[i+1].values[0]+"<span class="badge badge-primary">"+i+"</span></a>";
                }else{
                    gkxs += "<a href="#" name="xslb" id="xs"+i+"" onclick="clickxs("+i+")" class="list-group-item">"+data.content.data[i+1].values[0]+"<span class="badge badge-primary">"+i+"</span></a>";
                }
            }
            $("#gkxs").html(gkxs);
        }
    });