package com.basic.security.fragment;
|
|
import android.os.Bundle;
|
import android.text.TextUtils;
|
import android.view.LayoutInflater;
|
import android.view.View;
|
import android.view.ViewGroup;
|
import android.widget.BaseAdapter;
|
import android.widget.Button;
|
import android.widget.EditText;
|
import android.widget.ListView;
|
import android.widget.TextView;
|
|
import com.basic.security.base.BaseApplication;
|
import com.basic.security.base.BaseFragment;
|
import com.basic.security.manager.ClusterSerfSyncManager;
|
import com.basic.security.manager.ClusterSettingManager;
|
import com.basic.security.model.ClusterSetting;
|
import com.basic.security.model.ModelAdapter;
|
import com.basic.security.utils.Constants;
|
import com.basic.security.utils.ExceptionUtil;
|
import com.basic.security.utils.ResolutionAdaptation;
|
import com.basic.security.utils.ToastUtil;
|
import com.google.gson.Gson;
|
|
import org.androidannotations.annotations.AfterViews;
|
import org.androidannotations.annotations.Click;
|
import org.androidannotations.annotations.EFragment;
|
import org.androidannotations.annotations.TextChange;
|
import org.androidannotations.annotations.UiThread;
|
import org.androidannotations.annotations.ViewById;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
|
import androidSync.AndroidSync;
|
|
@EFragment
|
public class ClusterFragment extends BaseFragment {
|
public List<View> allViews = new ArrayList<>();
|
@ViewById
|
Button cluster_search, cluster_save, cluster_join, cluster_exit;
|
@ViewById
|
EditText cluster_name, cluster_id, cluster_password, cluster_ip, node_id, node_name;
|
@ViewById
|
TextView node_id_label, node_name_label, cluster_id_label, cluster_name_label, cluster_password_label, cluster_ip_label;
|
@ViewById
|
ListView lv_device_list;
|
@ViewById
|
View cluster_tab_parent, create_cluster_tab, join_cluster_tab;
|
private DeviceListAdapter deviceListAdapter;
|
private List<Map<String, String>> deviceList = new ArrayList<>();
|
private boolean isCreateCluster = true;
|
|
public View onCreateView(LayoutInflater inflater, ViewGroup container, Bundle savedInstanceState) {
|
return inflater.inflate(ResolutionAdaptation.fragment_cluster1(), container, false);
|
}
|
|
@AfterViews
|
public void afterViews() {
|
lv_device_list.addHeaderView(View.inflate(getContext(), com.basic.security.utils.ResolutionAdaptation.cluster_setting_list_head(), null));
|
allViews.add(cluster_search);
|
allViews.add(cluster_save);
|
allViews.add(cluster_join);
|
allViews.add(cluster_exit);
|
|
allViews.add(node_id_label);
|
allViews.add(node_name_label);
|
allViews.add(cluster_id_label);
|
allViews.add(cluster_name_label);
|
allViews.add(cluster_password_label);
|
allViews.add(cluster_ip_label);
|
|
allViews.add(node_id);
|
allViews.add(node_name);
|
allViews.add(cluster_id);
|
allViews.add(cluster_name);
|
allViews.add(cluster_password);
|
allViews.add(cluster_ip);
|
hideAllViews();
|
cluster_tab_parent.setVisibility(View.GONE);
|
}
|
|
@UiThread
|
public void queryDeviceListReturn() {
|
if (deviceListAdapter == null) {
|
deviceListAdapter = new DeviceListAdapter();
|
lv_device_list.setAdapter(deviceListAdapter);
|
}
|
deviceListAdapter.notifyDataSetChanged();
|
}
|
|
public void hideAllViews() {
|
for (View view : allViews) {
|
view.setVisibility(View.GONE);
|
}
|
}
|
|
@Click
|
public void create_cluster_tab() {
|
hideAllViews();
|
join_cluster_tab.setBackgroundResource(com.basic.security.utils.RUtils.R_drawable_bg_time_rule_add_no_checked);
|
create_cluster_tab.setBackground(null);
|
cluster_tab_parent.setVisibility(View.VISIBLE);
|
cluster_name.setVisibility(View.VISIBLE);
|
cluster_name_label.setVisibility(View.VISIBLE);
|
cluster_password.setVisibility(View.VISIBLE);
|
cluster_password_label.setVisibility(View.VISIBLE);
|
cluster_id.setVisibility(View.VISIBLE);
|
cluster_id_label.setVisibility(View.VISIBLE);
|
cluster_save.setVisibility(View.VISIBLE);
|
}
|
|
@Click
|
public void join_cluster_tab() {
|
hideAllViews();
|
create_cluster_tab.setBackgroundResource(com.basic.security.utils.RUtils.R_drawable_bg_time_rule_add_no_checked);
|
join_cluster_tab.setBackground(null);
|
cluster_tab_parent.setVisibility(View.VISIBLE);
|
cluster_ip.setVisibility(View.VISIBLE);
|
cluster_ip_label.setVisibility(View.VISIBLE);
|
cluster_password.setVisibility(View.VISIBLE);
|
cluster_password_label.setVisibility(View.VISIBLE);
|
cluster_search.setVisibility(View.VISIBLE);
|
cluster_join.setVisibility(View.VISIBLE);
|
cluster_id.setVisibility(View.VISIBLE);
|
cluster_id_label.setVisibility(View.VISIBLE);
|
}
|
|
public void manage_cluster_tab() {
|
hideAllViews();
|
cluster_tab_parent.setVisibility(View.GONE);
|
cluster_name.setVisibility(View.VISIBLE);
|
cluster_name_label.setVisibility(View.VISIBLE);
|
cluster_id.setVisibility(View.VISIBLE);
|
cluster_id_label.setVisibility(View.VISIBLE);
|
cluster_password.setVisibility(View.VISIBLE);
|
cluster_password_label.setVisibility(View.VISIBLE);
|
cluster_save.setVisibility(View.VISIBLE);
|
cluster_exit.setVisibility(View.VISIBLE);
|
}
|
|
@UiThread
|
public void show() {
|
super.show();
|
ModelAdapter cluster = ClusterSettingManager.getCluster();
|
cluster_name.setText(cluster.getString(ClusterSetting.cluster_name));
|
cluster_id.setText(cluster.getString(ClusterSetting.cluster_id));
|
String password = cluster.getString(ClusterSetting.password);
|
if (!TextUtils.isEmpty(password)) {
|
try {
|
} catch (Exception e) {
|
ExceptionUtil.printException(e);
|
}
|
}
|
cluster_password.setText(password);
|
cluster_ip.setText(cluster.getString(ClusterSetting.other_node_ip));
|
node_id.setText(cluster.getString(ClusterSetting.node_id));
|
node_name.setText(cluster.getString(ClusterSetting.node_name));
|
isCreateCluster = true;
|
deviceListAdapter = new DeviceListAdapter();
|
lv_device_list.setAdapter(deviceListAdapter);
|
if (Constants.FALSE.equals(cluster.getString(ClusterSetting.exit))) {
|
manage_cluster_tab();
|
} else {
|
create_cluster_tab();
|
}
|
}
|
|
@Click
|
public void cluster_search() {
|
BaseApplication.getApplication().executorService.execute(() -> {
|
try {
|
Gson gson = new Gson();
|
String clusterPassword = cluster_password.getText().toString();
|
//12-30 10:50:00.826 20808-20808/com.basic.security.yuyin.indoor I/System.out: ClusterFragment.cluster_search {"PAD97a1cfb8c50c":{"clusterID":"c4d03d5d-64c3-4941-bb53-152277a3271a","nodeID":"PAD97a1cfb8c50c","nodeAddress":"192.168.222.103:30190","isAlive":1}}
|
String clusters = new String(AndroidSync.getClusters("bjbasic123" + clusterPassword));
|
String clusterId = "";
|
if (!"{}".equals(clusters) && clusters.contains("clusterID\":\"")) {
|
int clusterIDIndex = clusters.indexOf("clusterID\":\"");
|
if (clusterIDIndex > 0) {
|
clusterId = clusters.substring(clusterIDIndex + "clusterID\":\"".length());
|
clusterId = clusters.substring(0, clusterId.indexOf("\""));
|
clusterId = clusterId.replace("\"", "");
|
}
|
}
|
if (clusterId.length() > 4) {
|
ToastUtil.show("搜索集群成功");
|
} else {
|
ToastUtil.show("没有搜索集群");
|
}
|
System.out.println("ClusterFragment.cluster_search " + clusters);
|
} catch (Exception e) {
|
ExceptionUtil.printException(e);
|
}
|
});
|
}
|
|
@Click
|
public void cluster_save() {
|
cluster_join();
|
}
|
|
@Click
|
public void cluster_join() {
|
ModelAdapter cluster = ClusterSettingManager.cluster;
|
String cluster_name = this.cluster_name.getText().toString().trim();
|
String cluster_id = this.cluster_id.getText().toString().trim();
|
String password = this.cluster_password.getText().toString().trim();
|
String cluster_ip = this.cluster_ip.getText().toString().trim();
|
String node_id = this.node_id.getText().toString().trim();
|
String node_name = this.node_name.getText().toString().trim();
|
if (TextUtils.isEmpty(node_id)) {
|
ToastUtil.show("请输入节点ID");
|
return;
|
}
|
if (TextUtils.isEmpty(node_name)) {
|
ToastUtil.show("请输入节点名称");
|
return;
|
}
|
if (TextUtils.isEmpty(cluster_name)) {
|
ToastUtil.show("请输入集群名称");
|
return;
|
}
|
if (TextUtils.isEmpty(password)) {
|
ToastUtil.show("请输入集群密码");
|
return;
|
}
|
try {
|
} catch (Exception e) {
|
ExceptionUtil.printException(e);
|
}
|
cluster.setString(ClusterSetting.cluster_name, cluster_name);
|
cluster.setString(ClusterSetting.cluster_id, cluster_id);
|
cluster.setString(ClusterSetting.password, password);
|
cluster.setString(ClusterSetting.other_node_ip, cluster_ip);
|
cluster.setString(ClusterSetting.exit, Constants.FALSE);
|
ClusterSettingManager.saveCluster(cluster);
|
ToastUtil.show("操作成功");
|
synchronized (ClusterSerfSyncManager.serfQueueLock) {
|
ClusterSerfSyncManager.serfQueue.add("1");
|
ClusterSerfSyncManager.serfQueueLock.notify();
|
}
|
isCreateCluster = false;
|
manage_cluster_tab();
|
}
|
|
@TextChange(com.basic.security.utils.RUtils.R_id_cluster_ip)
|
public void cluster_ip(TextView tv, CharSequence text) {
|
if (TextUtils.isEmpty(text)) {
|
cluster_join.setText("创建集群");
|
} else {
|
cluster_join.setText("加入集群");
|
}
|
}
|
|
@Click
|
public void cluster_exit() {
|
ClusterSettingManager.cluster.setTrue(ClusterSetting.exit);
|
ClusterSettingManager.saveCluster(ClusterSettingManager.cluster);
|
updateDeviceList(new ArrayList<>());
|
synchronized (ClusterSerfSyncManager.serfQueueLock) {
|
ClusterSerfSyncManager.serfQueue.add("exit");
|
ClusterSerfSyncManager.serfQueueLock.notify();
|
}
|
ToastUtil.show("退出集群成功");
|
create_cluster_tab();
|
}
|
|
@UiThread
|
public void updateDeviceList(List<Map<String, String>> availableNodes) {
|
try {
|
if (deviceList != null && deviceListAdapter != null) {
|
if (availableNodes != null) {
|
if (availableNodes.size() == 0 && deviceList.size() == 0) {
|
return;
|
}
|
for (Map<String, String> availableNode : availableNodes) {
|
String nodeIp = availableNode.get("nodeAddress");
|
if (!TextUtils.isEmpty(nodeIp)) {
|
nodeIp = nodeIp.replace(":30190", "");
|
} else {
|
nodeIp = "";
|
}
|
availableNode.put("device_id", availableNode.get("nodeID"));
|
availableNode.put("node_ip", nodeIp);
|
availableNode.put("father_node", "");
|
}
|
deviceList = availableNodes;
|
deviceListAdapter.notifyDataSetChanged();
|
}
|
}
|
} catch (Exception e) {
|
ExceptionUtil.printException(e);
|
}
|
}
|
|
|
private class DeviceListAdapter extends BaseAdapter {
|
public int getCount() {
|
return deviceList == null ? 0 : deviceList.size();
|
}
|
|
public Object getItem(int position) {
|
return deviceList.get(position);
|
}
|
|
public long getItemId(int position) {
|
return position;
|
}
|
|
public View getView(int position, View convertView, ViewGroup parent) {
|
ViewHolder viewHolder;
|
if (convertView == null) {
|
viewHolder = new ViewHolder();
|
convertView = View.inflate(getContext(), com.basic.security.utils.ResolutionAdaptation.cluster_setting_list_item(), null);
|
viewHolder.deviceID = convertView.findViewById(com.basic.security.utils.RUtils.R_id_tv_cluster_device_id);
|
viewHolder.IP = convertView.findViewById(com.basic.security.utils.RUtils.R_id_tv_cluster_ip);
|
viewHolder.fatherClusterName = convertView.findViewById(com.basic.security.utils.RUtils.R_id_tv_cluster_father_name);
|
convertView.setTag(viewHolder);
|
} else {
|
viewHolder = (ViewHolder) convertView.getTag();
|
}
|
Map<String, String> device = deviceList.get(position);
|
viewHolder.deviceID.setText(device.get("device_id"));
|
viewHolder.IP.setText(device.get("node_ip"));
|
viewHolder.fatherClusterName.setText(device.get("father_node"));
|
return convertView;
|
}
|
|
class ViewHolder {
|
TextView deviceID;
|
TextView IP;
|
TextView fatherClusterName;
|
}
|
}
|
}
|
