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