package com.basic.security.utils.socket.indoor;
|
|
import android.graphics.Bitmap;
|
import android.graphics.BitmapFactory;
|
import android.os.SystemClock;
|
import android.text.TextUtils;
|
import android.widget.ImageView;
|
|
import com.basic.security.activity.MainActivity;
|
import com.basic.security.base.BaseApplication;
|
import com.basic.security.manager.RemoteOutdoorManager;
|
import com.basic.security.manager.SettingManager;
|
import com.basic.security.model.GuestMessage;
|
import com.basic.security.model.ModelAdapter;
|
import com.basic.security.model.RemoteCameraMessage;
|
import com.basic.security.utils.Constants;
|
import com.basic.security.utils.FragmentUtil;
|
import com.basic.security.utils.SocketUtil;
|
import com.basic.security.utils.socket.BitmapListener;
|
import com.google.gson.Gson;
|
import com.google.gson.reflect.TypeToken;
|
|
import java.lang.reflect.Type;
|
import java.net.NoRouteToHostException;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
public class IndoorGuestSocketClient extends Thread {
|
public String serverIp;
|
public ImageView cameraBitmap;
|
public int guestListCameraType;
|
public ModelAdapter outdoor;
|
public long lastUpdateTime;
|
|
public IndoorGuestSocketClient(String serverIp, ImageView cameraBitmap, int guestListCameraType) {
|
this.serverIp = serverIp;
|
this.cameraBitmap = cameraBitmap;
|
this.guestListCameraType = guestListCameraType;
|
}
|
|
public void run() {
|
lastUpdateTime = System.currentTimeMillis();
|
boolean reConnectSocket;
|
SocketUtil socketUtil = new SocketUtil();
|
while (true) {
|
// System1.out.println("GuestSocketClient.run 1");
|
try {
|
lastUpdateTime = System.currentTimeMillis();
|
reConnectSocket = false;
|
try {
|
String outdoorServerIp = "";
|
List<String> outdoorDeviceIpList = RemoteOutdoorManager.getOutdoorDeviceIp();
|
// System1.out.println("IndoorGuestSocketClient.run outdoorDeviceIpList="+outdoorDeviceIpList);
|
if (outdoorDeviceIpList.size() > 0) {
|
outdoorServerIp = outdoorDeviceIpList.get(0);
|
}
|
if (TextUtils.isEmpty(outdoorServerIp)) {
|
SystemClock.sleep(1000);
|
continue;
|
}
|
serverIp = outdoorServerIp;
|
// System1.out.println("IndoorGuestSocketClient.run serverIp="+serverIp);
|
} catch (Exception e) {
|
System1.out.println("GuestSocketClient.run 1 " + e.getMessage());
|
SystemClock.sleep(1000);
|
continue;
|
}
|
socketUtil.openSocket(serverIp, Constants.guestServerPort);
|
while (!reConnectSocket) {
|
lastUpdateTime = System.currentTimeMillis();
|
if (socketUtil.readBitmapHeader()) {
|
socketUtil.setBitmapListener(new BitmapListener() {
|
public void onBitmap(Bitmap image) {
|
try {
|
MainActivity activity = BaseApplication.getApplication().activity;
|
activity.runOnUiThread(() -> {
|
try {
|
// System1.out.println("IndoorGuestSocketClient.onBitmap ");
|
activity.fragment_camera.camera2.setImageBitmap(image);
|
// FragmentUtil.guestModeFragment().camera1.setImageBitmap(image);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
});
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
public void detectFace(Map<String, Object> faceListMap, byte[] nv21Array, int width, int height, Bitmap image, byte[] featureArray) {
|
try {
|
MainActivity activity = BaseApplication.getApplication().activity;
|
if (activity.currentFragment == activity.fragment_guest_mode) {
|
String facePositionsJson = (String) faceListMap.get(GuestMessage.facePositions);
|
Type listType = new TypeToken<List<Map<String, String>>>() {
|
}.getType();
|
List<Map<String, String>> faces = new Gson().fromJson(facePositionsJson, listType);
|
// System1.out.println("IndoorGuestSocketClient.detectFace " + faces + " " + guestListCameraType + " facePositionsJson="+facePositionsJson);
|
FragmentUtil.guestModeFragment().addGuestList(faces, guestListCameraType, image, featureArray);
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
});
|
while (!Thread.currentThread().isInterrupted() && !reConnectSocket) {
|
// System1.out.println("GuestSocketClient.run 6");
|
lastUpdateTime = System.currentTimeMillis();
|
Map<String, String> requestMap = new HashMap<>();
|
requestMap.put(RemoteCameraMessage.requestFrame, BaseApplication.getApplication().activity.requestFrame());
|
requestMap.put(RemoteCameraMessage.transferVideo, SettingManager.getTransferVideo());
|
socketUtil.writeMap(requestMap);
|
Map<String, Object> map = socketUtil.readMap();
|
if (Constants.TRUE.equals(map.get(RemoteCameraMessage.hasFrameData))) {
|
String facePositions = (String) map.get(GuestMessage.facePositions);
|
int featureLength = Integer.parseInt((String) map.get(GuestMessage.featureLength));
|
int frameJpgLength = Integer.parseInt((String) map.get(GuestMessage.frameJpgLength));
|
boolean hasFaces = false;
|
if (facePositions != null && !"".equals(facePositions)) {
|
hasFaces = true;
|
}
|
byte[] featureArray = null;
|
if (featureLength > 0) {
|
featureArray = new byte[featureLength];
|
socketUtil.readFullByteArray(featureArray);
|
}
|
String frameJpgOrYuv = (String) map.get(GuestMessage.frameJpgOrYuv);
|
if (GuestMessage.JPG.equals(frameJpgOrYuv)) {
|
if (frameJpgLength > 0) {
|
socketUtil.readFullByteArray(socketUtil.imageBuff, frameJpgLength);
|
Bitmap frameBitmap = BitmapFactory.decodeByteArray(socketUtil.imageBuff, 0, frameJpgLength);
|
if (frameBitmap != null) {
|
if (!hasFaces) {
|
socketUtil.cameraDataListener.onBitmap(frameBitmap);
|
}
|
socketUtil.cameraDataListener.detectFace(map, null, frameBitmap.getWidth(), frameBitmap.getHeight(), frameBitmap, featureArray);
|
}
|
}
|
} else {
|
socketUtil.readFullByteArray(socketUtil.imageBuff);
|
socketUtil.mBufferManager.fillBuffer1(map, socketUtil.imageBuff, socketUtil.imageBuff.length, hasFaces);
|
}
|
}
|
if (Constants.TRUE.equals(SettingManager.getTransferVideo())) {
|
SystemClock.sleep(40);
|
} else {
|
SystemClock.sleep(500);
|
}
|
}
|
} else {
|
SystemClock.sleep(2000);
|
}
|
}
|
} catch (Exception e) {
|
if (e instanceof NoRouteToHostException) {
|
} else {
|
System1.out.println("GuestSocketClient.run 3 " + e.getMessage());
|
}
|
SystemClock.sleep(3000);
|
} finally {
|
socketUtil.close();
|
}
|
}
|
}
|
}
|
