package com.mm.android.deviceaddmodule;
|
|
import android.content.ComponentName;
|
import android.content.Context;
|
import android.content.Intent;
|
import android.content.ServiceConnection;
|
import android.os.IBinder;
|
import android.text.TextUtils;
|
import com.company.NetSDK.CB_fSDKLogCallBack;
|
import com.company.NetSDK.DEVICE_NET_INFO_EX;
|
import com.lechange.opensdk.media.DeviceInitInfo;
|
import com.mm.android.deviceaddmodule.entity.DeviceNetInfo;
|
import com.mm.android.deviceaddmodule.mobilecommon.AppConsume.ProviderManager;
|
import com.mm.android.deviceaddmodule.mobilecommon.utils.LogUtil;
|
|
import org.json.JSONException;
|
import org.json.JSONObject;
|
|
import java.util.Map;
|
import java.util.concurrent.ConcurrentHashMap;
|
|
/**
|
* 搜索局域网内设备信息的管理类
|
*/
|
|
public class SearchDeviceManager {
|
private static final String TAG = "SearchDeviceService";
|
|
private static volatile SearchDeviceManager sInstance;
|
private volatile ConcurrentHashMap<String, DeviceNetInfo> mDeviceNetInfos = new ConcurrentHashMap<>();
|
private SeachDeviceService.SearchDeviceBinder searchDevice;
|
private ISearchDeviceListener mListener;
|
boolean mIsConnected; //service是否已连接
|
volatile boolean mIsExist = false;
|
|
private SearchDeviceManager() {
|
mListener = new SearchDeviceImpl();
|
mDeviceNetInfos = new ConcurrentHashMap<>();
|
|
}
|
|
public static SearchDeviceManager getInstance() {
|
if (sInstance == null) {
|
synchronized (SearchDeviceManager.class) {
|
if (sInstance == null) {
|
sInstance = new SearchDeviceManager();
|
|
}
|
}
|
}
|
return sInstance;
|
}
|
|
|
public synchronized void connectService() {
|
|
if(!mIsConnected){
|
Intent intent = new Intent(ProviderManager.getAppProvider().getAppContext(), SeachDeviceService.class);
|
mIsConnected = ProviderManager.getAppProvider().getAppContext().bindService(intent, mBinderPoolConnection, Context.BIND_AUTO_CREATE);
|
}
|
if(!mIsExist){
|
mIsExist = true;
|
}
|
}
|
|
private ServiceConnection mBinderPoolConnection = new ServiceConnection() {
|
|
@Override
|
public void onServiceDisconnected(ComponentName arg0) {
|
}
|
|
@Override
|
public void onServiceConnected(ComponentName arg0, IBinder arg1) {
|
LogUtil.debugLog(TAG, "onServiceConnected");
|
|
searchDevice = (SeachDeviceService.SearchDeviceBinder) arg1;
|
|
if (searchDevice != null) {
|
try {
|
searchDevice.linkToDeath(mBinderPoolDeathRecipient, 0);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
registerListener(mListener);
|
startSearch();
|
}
|
};
|
|
private IBinder.DeathRecipient mBinderPoolDeathRecipient = new IBinder.DeathRecipient() {
|
|
@Override
|
public void binderDied() {
|
LogUtil.debugLog(TAG, "binderDied");
|
if (searchDevice != null) {
|
searchDevice.unlinkToDeath(mBinderPoolDeathRecipient, 0);
|
searchDevice = null;
|
}
|
connectService();
|
}
|
};
|
|
public void registerListener(ISearchDeviceListener listener) {
|
if (searchDevice != null) {
|
searchDevice.registerListener(listener);
|
}
|
}
|
|
public void unRegisterListener(ISearchDeviceListener listener) {
|
if (searchDevice != null) {
|
searchDevice.unRegisterListener(listener);
|
}
|
}
|
|
public void stopSearch() {
|
if (searchDevice != null) {
|
searchDevice.stopSearchDevices();
|
if(mIsConnected){
|
ProviderManager.getAppProvider().getAppContext().unbindService(mBinderPoolConnection);
|
mIsConnected = false;
|
}
|
|
}
|
}
|
|
public synchronized DeviceInitInfo getDeviceNetInfo(String snCode) {
|
if (TextUtils.isEmpty(snCode))
|
return null;
|
if (mDeviceNetInfos != null&&mDeviceNetInfos.get(snCode)!=null&&mDeviceNetInfos.get(snCode).isValid()) {
|
return mDeviceNetInfos.get(snCode).getDevNetInfoEx();
|
}
|
return null;
|
}
|
|
/**
|
* 搜索
|
*/
|
public synchronized void startSearch() {
|
removeInvalidDevice();
|
if (searchDevice != null) {
|
connectService();
|
searchDevice.startSearchDevices();
|
}
|
}
|
|
public synchronized void clearDevice() {
|
if (mDeviceNetInfos != null) {
|
mDeviceNetInfos.clear();
|
LogUtil.debugLog(TAG, "clear");
|
}
|
}
|
|
/**
|
* 列表中移除无效的设备信息
|
*/
|
public synchronized void removeInvalidDevice() {
|
if (mDeviceNetInfos != null) {
|
LogUtil.debugLog(TAG, "removeInvalidDevice： " + mDeviceNetInfos);
|
for (Map.Entry<String, DeviceNetInfo> entry : mDeviceNetInfos.entrySet()) {
|
if (entry.getValue() != null) {
|
if (!entry.getValue().isValid()) {
|
// 移除无效的DeviceNetInfo
|
mDeviceNetInfos.remove(entry.getKey());
|
LogUtil.debugLog(TAG, "remove： " + entry.getKey());
|
} else {
|
// 将标志位重置
|
entry.getValue().setValid(false);
|
}
|
}
|
}
|
LogUtil.debugLog(TAG, "removeInvalidDevice： " + mDeviceNetInfos);
|
}
|
}
|
|
/**
|
* 释放资源
|
*/
|
public synchronized void checkSearchDeviceServiceDestory() {
|
stopSearch();
|
unRegisterListener(mListener);
|
clearDevice();
|
mIsExist = false;
|
}
|
|
public synchronized boolean checkSearchDeviceServiceIsExist() {
|
return mIsExist;
|
}
|
|
private class SearchDeviceImpl implements ISearchDeviceListener {
|
|
@Override
|
public void onDeviceSearched(String sncode, DeviceInitInfo info) {
|
if (mDeviceNetInfos != null) {
|
DeviceNetInfo deviceNetInfo=new DeviceNetInfo(info);
|
mDeviceNetInfos.put(sncode, deviceNetInfo);
|
LogUtil.debugLog(TAG, "onDeviceSearched： " + mDeviceNetInfos);
|
}
|
}
|
}
|
|
public interface ISearchDeviceListener {
|
void onDeviceSearched(String sncode, DeviceInitInfo info);
|
}
|
|
}
|
