package com.basic.security.utils;
|
import android.os.SystemClock;
|
import android.text.TextUtils;
|
|
import com.basic.security.activity.MainActivity;
|
import com.basic.security.base.BaseApplication;
|
import com.basic.security.manager.AlarmManager;
|
import com.basic.security.utils.Constants;
|
import com.google.gson.JsonArray;
|
import com.google.gson.JsonElement;
|
import com.google.gson.JsonObject;
|
import com.google.gson.JsonParseException;
|
import com.google.gson.JsonParser;
|
|
import java.io.BufferedInputStream;
|
import java.io.BufferedOutputStream;
|
import java.io.ByteArrayOutputStream;
|
import java.net.Socket;
|
import java.util.ArrayList;
|
import java.util.Collections;
|
import java.util.Comparator;
|
import java.util.HashMap;
|
import java.util.LinkedList;
|
import java.util.List;
|
import java.util.Map;
|
|
public class SocketAcceptedClient extends Thread {
|
|
Socket mSocket;
|
byte[] buff = new byte[1*1024*1024];
|
ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
|
public static boolean needRestart = false;
|
List<Map<String, String>> newRemoteAlarmList = null;
|
|
private static final int MAX_BUFFER = 15;
|
|
private static LinkedList<byte[]> mRgbCameraQueue = new LinkedList<byte[]>();
|
|
public SocketAcceptedClient(Socket client) {
|
mSocket = client;
|
}
|
|
public Comparator<Map<String, String>> mapComparator = new Comparator<Map<String, String>>() {
|
public int compare(Map<String, String> m1, Map<String, String> m2) {
|
try {
|
double score1 = Double.parseDouble(m1.get("likePer"));
|
double score2 = Double.parseDouble(m2.get("likePer"));
|
return (int)(score1 - score2);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return 0;
|
}
|
};
|
|
public void parseJson(String msg) {
|
|
JsonParser parser = new JsonParser();
|
boolean isJSON = true;
|
JsonElement element = null;
|
try {
|
element = parser.parse(msg);
|
} catch (JsonParseException e) {
|
System.out.println("exception: "+ msg + " " + e);
|
isJSON = false;
|
}
|
newRemoteAlarmList = new ArrayList<>();
|
if (isJSON && element != null) {
|
Object obj = element.getAsJsonObject();
|
JsonArray dataList = (JsonArray) ((JsonObject) obj).get("datalist");
|
for (int i = 0; i < dataList.size(); i++) {
|
JsonObject je = (JsonObject)dataList.get(i);
|
Map<String, String> newRemoteAlarm = new HashMap<>();
|
for(Map.Entry<String, JsonElement> entry : je.entrySet()) {
|
Object value = entry.getValue();
|
String key = entry.getKey();
|
if (value != null) {
|
if ("baseInfo".equals(key)) {
|
List<Map<String, String>> matchPersonMapList = new ArrayList<>();
|
List<String> matchPersonStrList = new ArrayList<>();
|
String matchPersonListStr = "";
|
if (value instanceof JsonArray) {
|
JsonArray matchPersonList = (JsonArray)value;
|
for (int ii = 0; ii < matchPersonList.size(); ii++ ) {
|
JsonObject matchPerson = (JsonObject)matchPersonList.get(ii);
|
Map<String, String> matchPersonMap = new HashMap<>();
|
|
for(Map.Entry<String, JsonElement> matchPersonEntry : matchPerson.entrySet()) {
|
String matchPersonKey = matchPersonEntry.getKey();
|
Object matchPersonValue = matchPersonEntry.getValue();
|
if (matchPersonValue != null) {
|
String matchPersonValueStr = matchPersonValue.toString();
|
if (matchPersonValueStr.startsWith("\"")) {
|
matchPersonValueStr = matchPersonValueStr.substring(1);
|
}
|
if (matchPersonValueStr.endsWith("\"")) {
|
matchPersonValueStr = matchPersonValueStr.substring(0, matchPersonValueStr.length() - 1);
|
}
|
matchPersonMap.put(matchPersonKey, matchPersonValueStr);
|
} else {
|
matchPersonMap.put(matchPersonKey, "");
|
}
|
}
|
matchPersonMap.put("mathPersonStr", matchPersonMap.get("tableName")+ " " + matchPersonMap.get("personName"));
|
matchPersonMapList.add(matchPersonMap);
|
}
|
Collections.sort(matchPersonMapList, mapComparator);
|
for (Map<String, String> matchPersonMap : matchPersonMapList) {
|
matchPersonStrList.add(matchPersonMap.get("mathPersonStr"));
|
}
|
matchPersonListStr = TextUtils.join("`", matchPersonStrList);
|
}
|
newRemoteAlarm.put("matchPersonListStr", matchPersonListStr);
|
} else {
|
newRemoteAlarm.put(entry.getKey(), value.toString());
|
}
|
}
|
}
|
newRemoteAlarmList.add(newRemoteAlarm);
|
}
|
//
|
if (newRemoteAlarmList != null && newRemoteAlarmList.size() > 0) {
|
// System.out.println("receive");
|
// if (1==1) {
|
// return;
|
// }
|
AlarmManager.renameKeys(newRemoteAlarmList);
|
if (AlarmManager.saveRemoteAlarmListToSqlite(newRemoteAlarmList) > 0) {
|
((MainActivity) BaseApplication.getApplication().activity).fragment_home.refreshGridView();
|
}
|
} else {
|
if (((MainActivity)BaseApplication.getApplication().activity).currentFragment ==
|
((MainActivity)BaseApplication.getApplication().activity).fragment_home) {
|
ToastUtil.show("获取报警数据失败");
|
}
|
}
|
}
|
}
|
|
@Override
|
public void run() {
|
try {
|
BufferedOutputStream outputStream = new BufferedOutputStream(mSocket.getOutputStream());
|
BufferedInputStream inputStream = new BufferedInputStream(mSocket.getInputStream());
|
String msg = "";
|
int len = 0;
|
while ((len = inputStream.read(buff)) != -1) {
|
for (int i1 = 0; i1 <len; i1++) {
|
if (buff[i1] == '\0') {
|
try {
|
byte[] msgBuf = byteArrayOutputStream.toByteArray();
|
byteArrayOutputStream.reset();
|
msg = new String(msgBuf, 0, msgBuf.length);
|
msg = msg.substring(0, msg.lastIndexOf("}") + 1);
|
System.out.println("msg="+msg);
|
if (msg.length() > 3) {
|
parseJson(msg);
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
} else {
|
byteArrayOutputStream.write(buff[i1]);
|
}
|
}
|
if (needRestart) {
|
needRestart = false;
|
break;
|
}
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
|
}
|
