a

554325746@qq.com

2020-01-15 956063ff14bc75e3a2a97c7bcaa06b9edc84ad24

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
package com.basic.security.manager.es;
 
import android.util.Log;
 
import com.basic.security.manager.BaseManager;
import com.basic.security.manager.DeviceManager;
import com.basic.security.model.ModelAdapter;
import com.basic.security.utils.Constants;
import com.basic.security.utils.ExceptionUtil;
 
import java.io.IOException;
import java.util.Properties;
 
import okhttp3.Call;
import okhttp3.Callback;
import okhttp3.MediaType;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;
 
import static com.basic.security.utils.DateUtil.formatTime;
 
public class EsBaseManager {
 
    private static String HOSTNAME;
 
    private static String HTTP_PORT;
 
    private static String HTTP_URL;
 
    private static String PERSON_URL;
 
    public EsBaseManager() {
        Properties properties = new Properties();
        try {
            properties.load(EsBaseManager.class.getResourceAsStream("/assets/es_config.properties"));
        } catch (Exception e) {
            ExceptionUtil.printException(e);
        }
        HOSTNAME = properties.getProperty("HOSTNAME");
        HTTP_PORT = properties.getProperty("HTTP_PORT");
        HTTP_URL = properties.getProperty("HTTP_URL");
        PERSON_URL = properties.getProperty("PERSON_URL");
    }
 
    public void queryAndSend(String recordTime) {
 
        ModelAdapter modelAdapter = new ModelAdapter();
        modelAdapter = BaseManager.findByTime("visit", recordTime);
        ModelAdapter deviceAdapter = DeviceManager.getDevice();
        if (modelAdapter.model.size() != 0) {
 
            String jsonStr = "{\n" +
 
                    "\"videoReqNum\" : \"" + modelAdapter.getString("device_id") + "\",\n" +
 
                    "\"Gender\" : \"1\",\n" +
 
                    "\"content\" : \"\",\n" +
 
                    "\"likeDate\" : \"" + formatTime(Long.parseLong(String.valueOf(Constants.compareFeatureTime)), "yyyy-MM-dd HH:mm:ss") + "\",\n" +
 
                    "\"picAddress\" : \"" + deviceAdapter.getString("address") + "\",\n" +
 
                    "\"Age\" : \"\",\n" +
 
                    "\"picDate\" : \"" + formatTime(Long.parseLong(modelAdapter.getString("visit_time").toString()), "yyyy-MM-dd HH:mm:ss") + "\",\n" +
 
                    "\"likePer\" : \"" + Constants.score + "\",\n" +
 
                    "\"indeviceid\" : \"" + modelAdapter.getString("device_id") + "\",\n" +
 
                    "\"personId\" : \"" + modelAdapter.getString("person_id") + "\",\n" +
 
                    "\"indevicename\" : \"" + modelAdapter.getString("device_name") + "\",\n" +
 
                    "\"personIsHub\" : \"\",\n" +
 
                    "\"videoIp\" : \"" + modelAdapter.getString("device_id") + "\"\n" +
                    "}";
 
            useOkHttp(modelAdapter.getString("id").toString(), jsonStr);
        }
    }
 
    public void useOkHttp(String id, String jsonStr) {
        try {
            OkHttpClient okHttpClient = new OkHttpClient();
            MediaType JSON = MediaType.parse("application/json");
            RequestBody body = RequestBody.create(JSON, jsonStr);
            Request request = new Request.Builder()
                    .url("http://" + HOSTNAME + ":" + HTTP_PORT + "" + HTTP_URL + "" + id + "")
                    .put(body)
                    .build();
            okHttpClient.newCall(request).enqueue(new Callback() {
                public void onFailure(Call call, IOException e) {
                    Log.d("Http:call", "" + call.request() + "");
                }
 
                public void onResponse(Call call, Response response) {
                    Log.d("Http:call", "" + response.code() + "");
                }
            });
        } catch (Exception e) {
            ExceptionUtil.printException(e);
        }
    }
}