//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();
|
// }
|
// }
|
//
|
//
|
//}
|
