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.RadioButton;
|
import android.widget.TextView;
|
|
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.ResolutionAdaptation;
|
import com.basic.security.utils.ToastUtil;
|
import com.basic.security.widget.ClusterRoundView;
|
|
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;
|
|
@EFragment
|
public class ClusterFragment extends BaseFragment {
|
@ViewById
|
Button cluster_a, cluster_b, cluster_c, cluster_plus, confirm_save, cancel_save, cluster_add, cluster_exit;
|
@ViewById
|
RadioButton only_allow, no_limit;
|
@ViewById
|
EditText cluster_name, cluster_id, cluster_cookie, cluster_ip, node_id, node_name;
|
@ViewById
|
ClusterRoundView round_view;
|
@ViewById
|
ListView lv_device_list;
|
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));
|
}
|
|
public void queryDeviceList() {
|
}
|
|
@UiThread
|
public void queryDeviceListReturn() {
|
if (deviceListAdapter == null) {
|
deviceListAdapter = new DeviceListAdapter();
|
lv_device_list.setAdapter(deviceListAdapter);
|
}
|
deviceListAdapter.notifyDataSetChanged();
|
}
|
|
@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 {
|
// password = new String(Base64.decode(password, Base64.NO_WRAP), "UTF8");
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
cluster_cookie.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);
|
}
|
|
@Click
|
public void cluster_plus() {
|
isCreateCluster = true;
|
}
|
|
@Click
|
void confirm_save() {
|
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_cookie.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 {
|
// password = Base64.encodeToString(password.getBytes("UTF-8"), Base64.NO_WRAP);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
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();
|
}
|
}
|
|
@Click
|
void cancel_save() {
|
}
|
|
@Click
|
public void cluster_add() {
|
confirm_save();
|
isCreateCluster = false;
|
}
|
|
@TextChange(com.basic.security.utils.RUtils.R_id_cluster_ip)
|
public void cluster_ip(TextView tv, CharSequence text) {
|
if (TextUtils.isEmpty(text)) {
|
cluster_add.setText("创建集群");
|
} else {
|
cluster_add.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("退出集群成功");
|
}
|
|
@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) {
|
e.printStackTrace();
|
}
|
}
|
|
@Click
|
public void search_cluster() {
|
// synchronized (ClusterSerfSyncManager.serfQueueLock) {
|
// ClusterSerfSyncManager.serfQueue.add("search");
|
// ClusterSerfSyncManager.serfQueueLock.notify();
|
// }
|
}
|
|
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;
|
}
|
}
|
}
|
