package com.basic.security.fragment;
|
|
import android.text.TextUtils;
|
import android.view.View;
|
import android.view.ViewGroup;
|
import android.widget.BaseAdapter;
|
import android.widget.Button;
|
import android.widget.EditText;
|
import android.widget.LinearLayout;
|
import android.widget.ListView;
|
import android.widget.RadioButton;
|
import android.widget.TextView;
|
|
import com.basic.security.R;
|
import com.basic.security.base.BaseApplication;
|
import com.basic.security.base.BaseFragment;
|
import com.basic.security.manager.impl.erlang.ClusterManager;
|
import com.basic.security.manager.impl.erlang.ErlangConnection;
|
import com.basic.security.manager.impl.erlang.SqliteManager;
|
import com.basic.security.utils.Constants;
|
import com.basic.security.utils.ToastUtil;
|
import com.basic.security.widget.RoundView;
|
|
import org.androidannotations.annotations.AfterViews;
|
import org.androidannotations.annotations.Click;
|
import org.androidannotations.annotations.EFragment;
|
import org.androidannotations.annotations.UiThread;
|
import org.androidannotations.annotations.ViewById;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
|
@EFragment(R.layout.fragment_cluster_setting)
|
public class ClusterSettingFragment 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_cookie, cluster_ip;
|
@ViewById
|
RoundView round_view;
|
@ViewById
|
LinearLayout ll_cluster_ip;
|
@ViewById
|
ListView lv_device_list;
|
private DeviceListAdapter deviceListAdapter;
|
private List<Map<String, String>> deviceList = new ArrayList<>();
|
private boolean isCreateCluster = true;
|
|
@AfterViews
|
public void afterViews() {
|
// lv_device_list.addHeaderView(View.inflate(getContext(), R.layout.cluster_setting_list_head, null));
|
|
}
|
|
public void queryDeviceList() {
|
BaseApplication.getApplication().executorService.execute(() -> {
|
deviceList = SqliteManager.queryFromSync(ErlangConnection.getLocalConnection(),
|
"SELECT\n" +
|
" a.father_node,\n" +
|
" a.\"table\",\n" +
|
" a.uuid,\n" +
|
" a.node_id,\n" +
|
" a.device_id,\n" +
|
" a.cluster_id,\n" +
|
" a.create_time,\n" +
|
" a.update_time,\n" +
|
" a.create_by,\n" +
|
" a.del_flag\n" +
|
"FROM\n" +
|
" device_info a\n" +
|
"WHERE a.del_flag = 0\n" +
|
"and a.device_id = '" + Constants.deviceId + "'"
|
);
|
queryDeviceListReturn();
|
});
|
|
}
|
|
@UiThread
|
public void queryDeviceListReturn() {
|
if (deviceListAdapter == null) {
|
deviceListAdapter = new DeviceListAdapter();
|
lv_device_list.setAdapter(deviceListAdapter);
|
}
|
// System.out.println("deviceList.size" + deviceList.size());
|
deviceListAdapter.notifyDataSetChanged();
|
}
|
|
@Override
|
public void show() {
|
super.show();
|
isCreateCluster = true;
|
ll_cluster_ip.setVisibility(View.GONE);
|
deviceListAdapter = new DeviceListAdapter();
|
lv_device_list.setAdapter(deviceListAdapter);
|
deviceList.clear();
|
queryDeviceList();
|
|
|
}
|
|
@Click
|
public void cluster_plus() {
|
// clearEditText();
|
isCreateCluster = true;
|
ll_cluster_ip.setVisibility(View.GONE);
|
|
}
|
|
// 保存按钮
|
@Click
|
void confirm_save() {
|
String cluster_name = this.cluster_name.getText().toString().trim();
|
String cluster_cookie = this.cluster_cookie.getText().toString().trim();
|
String cluster_ip = this.cluster_ip.getText().toString().trim();
|
if (TextUtils.isEmpty(cluster_name)) {
|
ToastUtil.show("请输入集群名称");
|
return;
|
}
|
if (TextUtils.isEmpty(cluster_cookie)) {
|
ToastUtil.show("请输入集群cookie");
|
return;
|
}
|
if (!isCreateCluster) {
|
if (TextUtils.isEmpty(cluster_ip)) {
|
ToastUtil.show("请输入集群ip");
|
return;
|
}
|
|
class TempJoin {
|
void joinClu() {
|
// OtpConnection otpConnection = ErlangConnection.getRemoteConnection(cluster_ip);
|
// try {
|
// Thread.sleep(200);
|
// if(otpConnection== null || !otpConnection.isConnected()){
|
// ToastUtil.show("集群IP有误无法连接到该集群！");
|
// }else{
|
// // 保存加入集群逻辑
|
// ClusterManager.joinCluster(cluster_ip, cluster_cookie, cluster_name);
|
// try {
|
// updateUI();
|
// } catch (InterruptedException e) {
|
// e.printStackTrace();
|
// }
|
// }
|
// } catch (InterruptedException e) {
|
// e.printStackTrace();
|
// }
|
|
// 保存加入集群逻辑
|
BaseApplication.getApplication().executorService.execute(() -> {
|
ClusterManager.joinCluster(cluster_ip, cluster_cookie, cluster_name);
|
updateUI();
|
});
|
}
|
|
@UiThread
|
void updateUI() {
|
try {
|
Thread.sleep(500);
|
ToastUtil.show("加入集群成功！");
|
clearEditText();
|
show();
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
|
// mainActivity().showFragment(mainActivity().fragment_cluster_setting);
|
}
|
}
|
new TempJoin().joinClu();
|
} else {
|
class TempCreate {
|
void createClu() {
|
BaseApplication.getApplication().executorService.execute(() -> {
|
// 保存创建集群逻辑
|
// System.out.println(System.currentTimeMillis()+"创建集群的时间！！");
|
List<Map<String, String>> list = new ArrayList<>();
|
list = ClusterManager.queryClusterByDevice();
|
if (list.size() != 0) {
|
ToastUtil.show("该设备已经创建集群！");
|
} else {
|
ClusterManager.createCluster(cluster_cookie, cluster_name, "1");
|
try {
|
updateUI();
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
}
|
});
|
|
}
|
|
@UiThread
|
void updateUI() throws InterruptedException {
|
Thread.sleep(500);
|
// System.out.println(System.currentTimeMillis()+"进入updateUI的时间！！");
|
ToastUtil.show("创建集群成功！");
|
show();
|
// mainActivity().showFragment(mainActivity().fragment_cluster_setting);
|
}
|
}
|
new TempCreate().createClu();
|
}
|
|
}
|
|
// 取消按钮
|
@Click
|
void cancel_save() {
|
|
}
|
|
@Click
|
public void cluster_add() {
|
isCreateCluster = false;
|
// clearEditText();
|
ll_cluster_ip.setVisibility(View.VISIBLE);
|
}
|
|
// private synchronized void f1( String deviceId){
|
// ClusterManager.exitCluster(deviceId);
|
// }
|
@Click
|
public void cluster_exit() {
|
Map<String, String> device = deviceList.get(0);
|
if (!device.isEmpty()) {
|
String deviceId = device.get("device_id");
|
try {
|
ToastUtil.show("退出集群成功！");
|
class Temp {
|
void deleteBackGround(String deviceId) {
|
BaseApplication.getApplication().executorService.execute(() -> {
|
ClusterManager.phyDelDeviceInfo(deviceId);
|
try {
|
showUiThread();
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
});
|
}
|
|
@UiThread
|
void showUiThread() throws InterruptedException {
|
Thread.sleep(500);
|
clearEditText();
|
show();
|
}
|
}
|
new Temp().deleteBackGround(deviceId);
|
// ExecutorService service = Executors.newSingleThreadExecutor();
|
// service.submit(() -> {
|
// ClusterManager.exitCluster(deviceId);
|
// });
|
// service.submit(() -> {
|
// show();
|
// ToastUtil.show("退出集群成功！");
|
// });
|
// service.shutdown();
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
private void clearEditText() {
|
cluster_name.setText("");
|
cluster_cookie.setText("");
|
cluster_ip.setText("");
|
}
|
|
private class DeviceListAdapter extends BaseAdapter {
|
@Override
|
public int getCount() {
|
return deviceList == null ? 0 : deviceList.size();
|
}
|
|
@Override
|
public Object getItem(int position) {
|
return deviceList.get(position);
|
}
|
|
@Override
|
public long getItemId(int position) {
|
return position;
|
}
|
|
@Override
|
public View getView(int position, View convertView, ViewGroup parent) {
|
ViewHolder viewHolder = null;
|
if (convertView == null) {
|
viewHolder = new ViewHolder();
|
convertView = View.inflate(getContext(), R.layout.cluster_setting_list_item, null);
|
viewHolder.deviceID = convertView.findViewById(R.id.tv_cluster_device_id);
|
viewHolder.IP = convertView.findViewById(R.id.tv_cluster_ip);
|
viewHolder.fatherClusterName = convertView.findViewById(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_id"));
|
viewHolder.fatherClusterName.setText(device.get("father_node"));
|
return convertView;
|
}
|
|
class ViewHolder {
|
TextView deviceID;
|
TextView IP;
|
TextView fatherClusterName;
|
}
|
}
|
|
}
|
