From 38492bbaa63586e2f4877da0eaa01a082fd565a6 Mon Sep 17 00:00:00 2001
From: 554325746@qq.com <554325746@qq.com>
Date: 星期三, 25 十二月 2019 08:42:58 +0800
Subject: [PATCH] a
---
app/src/main/java/com/basic/security/utils/SocketAcceptedClient.java | 352 +++++++++++++++++++++++++++++-----------------------------
1 files changed, 176 insertions(+), 176 deletions(-)
diff --git a/app/src/main/java/com/basic/security/utils/SocketAcceptedClient.java b/app/src/main/java/com/basic/security/utils/SocketAcceptedClient.java
index a14d934..a0949ce 100644
--- a/app/src/main/java/com/basic/security/utils/SocketAcceptedClient.java
+++ b/app/src/main/java/com/basic/security/utils/SocketAcceptedClient.java
@@ -1,178 +1,178 @@
-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);
- }
+//package com.basic.security.utils;
+//import android.os.SystemClock;
+//import android.text.TextUtils;
//
- if (newRemoteAlarmList != null && newRemoteAlarmList.size() > 0) {
-// System.out.println("receive");
-// if (1==1) {
-// return;
+//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, "");
// }
- 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();
- }
- }
-
-
-}
+// }
+// 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();
+// }
+// }
+//
+//
+//}
--
Gitblit v1.8.0