package com.example.serial;

import androidx.activity.EdgeToEdge;
import androidx.appcompat.app.AppCompatActivity;

import android.graphics.Color;
import android.graphics.Paint;
import android.os.Bundle;
import android.text.method.ScrollingMovementMethod;
import android.util.Log;
import android.view.View;
import android.widget.AdapterView;
import android.widget.ArrayAdapter;
import android.widget.Button;
import android.widget.EditText;
import android.widget.Spinner;
import android.widget.TextView;
import android.widget.Toast;

import com.example.serial.databinding.ActivityMainBinding;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.TimeZone;


public class RS485Activity extends AppCompatActivity {

    // Used to load the 'serial' library on application startup.
    static {
        System.loadLibrary("serial");
    }

    // 与串口参数相关的组件
    private ActivityMainBinding binding;
    private Spinner mSpBaud;
    private Spinner mSpSerial;
    private Spinner mSpData;
    private Spinner mSpStop;
    private Spinner mSpParity;
    private Spinner mSpFlow;

    // 和发送信息相关的控件
    private Button mBtnClearSend;
    private Button mBtnSend;
    private EditText mEtSend;
    // 和接收信息相关的控件
    private Button mBtnClearRev;
    private TextView mTvRev;
    private TextView mTvShow;
    private Button mBtnRecv;

    // 打开串口&关闭串口
    private Button mBtnOpen;
    private Button mBtnClose;
    private Button mBtnSendState;
    private Button mBtnRecvState;


    // 设置串口的参数
    private String serial;
    private long baudRate;
    private int dataBits;
    private double stopBits;
    private int parity;
    private int flowControl; // 0:None, 1:RTS/CTS, 2:XON/XOFF

    // 获取已经设定的值
    String[] serialArray;
    String[] baudArray;
    String[] dataArray;
    String[] stopArray;
    String[] parityArray;
    String[] flowArray;
    String sendData;
    String currenState = null;
    int    sendOnTime;
    int    state = -1;
    private static final int MSG_SEND_DATA = 1;

    boolean turnFlag = false;
    private RS485Control RS485Control;
    Runnable runnable;


    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        EdgeToEdge.enable(this);
        setContentView(R.layout.activity_rs485);

        RS485Control = new RS485Control();
        // 找到控件
        mSpSerial = findViewById(R.id.sp_serial);
        mSpBaud = findViewById(R.id.sp_baud);
        mSpData = findViewById(R.id.sp_data);
        mSpStop = findViewById(R.id.sp_stop);
        mSpParity = findViewById(R.id.sp_parity);
        mSpFlow = findViewById(R.id.sp_flow);

        mBtnOpen = findViewById(R.id.btn_open);
        mBtnClose = findViewById(R.id.btn_close);
        mBtnClearRev = findViewById(R.id.btn_clear_rev);
        mBtnClearSend = findViewById(R.id.btn_clear_send);
        mBtnSend = findViewById(R.id.btn_send);
        mEtSend = findViewById(R.id.et_send);
        mTvRev = findViewById(R.id.txt_rev);
        mTvShow = findViewById(R.id.txt_show);
        mBtnRecv = findViewById(R.id.btn_recv);
        mBtnRecvState = findViewById(R.id.btn_recv_state);
        mBtnSendState = findViewById(R.id.btn_send_state);

        // 还没有连接串口时，显示not connected
        mTvShow.setTextColor(Color.parseColor("#FF0000"));
        mTvShow.setText("NOT CONNECTED");
        mTvShow.setPaintFlags(mTvShow.getPaintFlags() | Paint.ANTI_ALIAS_FLAG);
        // 设置并监听下拉列表
        setSpinner(mSpSerial);
        setSpinner(mSpBaud);
        setSpinner(mSpData);
        setSpinner(mSpStop);
        setSpinner(mSpParity);
        setSpinner(mSpFlow);

        mTvRev.setMovementMethod(ScrollingMovementMethod.getInstance());

        // 监听所有的button
        setListener();

    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        RS485Control.closeSerialPort();
    }

    private void setSpinner(Spinner spinner){
        ArrayAdapter<CharSequence> adapter;
        int id = spinner.getId();

        if (id == R.id.sp_serial){
            adapter = ArrayAdapter.createFromResource(RS485Activity.this, R.array.serial_name, android.R.layout.simple_spinner_item);
        }else if (id == R.id.sp_baud) {
            adapter = ArrayAdapter.createFromResource(RS485Activity.this, R.array.baud_rate, android.R.layout.simple_spinner_item);
        } else if (id == R.id.sp_data) {
            adapter = ArrayAdapter.createFromResource(RS485Activity.this, R.array.data_bits, android.R.layout.simple_spinner_item);
        } else if (id == R.id.sp_stop) {
            adapter = ArrayAdapter.createFromResource(RS485Activity.this, R.array.stop_bits, android.R.layout.simple_spinner_item);
        } else if (id == R.id.sp_parity) {
            adapter = ArrayAdapter.createFromResource(RS485Activity.this, R.array.parity, android.R.layout.simple_spinner_item);
        } else if (id == R.id.sp_flow) {
            adapter = ArrayAdapter.createFromResource(RS485Activity.this, R.array.flow_control, android.R.layout.simple_spinner_item);
        } else {
            throw new IllegalStateException("Unexpected value: " + spinner.getId());
        }
        adapter.setDropDownViewResource(android.R.layout.simple_spinner_item);
        spinner.setAdapter(adapter);

        spinner.setOnItemSelectedListener(new AdapterView.OnItemSelectedListener() {
            @Override
            public void onItemSelected(AdapterView<?> parent, View view, int position, long id) {
                int spinnerId = spinner.getId();

                if (spinnerId == R.id.sp_serial) {
                    serialArray = getResources().getStringArray(R.array.serial_name);
                    serial = serialArray[position];
//                    Toast.makeText(MainActivity.this, "串口:" + serial, Toast.LENGTH_SHORT).show();
                } else if (spinnerId == R.id.sp_baud) {
                    baudArray = getResources().getStringArray(R.array.baud_rate);
                    baudRate = Integer.parseInt(baudArray[position]);
//                    Toast.makeText(MainActivity.this, "波特率:" + baudRate, Toast.LENGTH_SHORT).show();
                } else if (spinnerId == R.id.sp_data) {
                    dataArray = getResources().getStringArray(R.array.data_bits);
                    dataBits = Integer.parseInt(dataArray[position]);
//                    Toast.makeText(MainActivity.this, "数据位:" + dataBits, Toast.LENGTH_SHORT).show();
                } else if (spinnerId == R.id.sp_stop) {
                    stopArray = getResources().getStringArray(R.array.stop_bits);
                    stopBits = Double.parseDouble(stopArray[position]);
//                    Toast.makeText(MainActivity.this, "停止位:" + stopBits, Toast.LENGTH_SHORT).show();
                } else if (spinnerId == R.id.sp_parity) {
                    parityArray = getResources().getStringArray(R.array.parity);
                    if (parityArray[position].equals("偶校验"))
                        parity = 2;
                    else if (parityArray[position].equals("奇校验"))
                        parity = 1;
                    else if (parityArray[position].equals("None"))
                        parity = 0;
//                    Toast.makeText(MainActivity.this, "校验位:" + parityArray[position], Toast.LENGTH_SHORT).show();
                } else if (spinnerId == R.id.sp_flow) {
                    flowArray = getResources().getStringArray(R.array.flow_control);
                    flowControl = position;
                } else {
                    throw new IllegalStateException("Unexpected value: " + spinner.getId());
                }
            }
            @Override
            public void onNothingSelected(AdapterView<?> parent) {
            }
        });
    }

    private void setListener(){
        OnClick onClick = new OnClick();
        mBtnOpen.setOnClickListener(onClick);
        mBtnClose.setOnClickListener(onClick);
        mBtnClearRev.setOnClickListener(onClick);
        mBtnClearSend.setOnClickListener(onClick);
        mBtnSend.setOnClickListener(onClick);
        mBtnRecvState.setOnClickListener(onClick);
        mBtnSendState.setOnClickListener(onClick);
        mBtnRecv.setOnClickListener(onClick);
    }
    private class OnClick implements View.OnClickListener{

        @Override
        public void onClick(View v) {
            int id = v.getId();
            if (id == R.id.btn_open) {
                if (turnFlag) {
                    Toast.makeText(RS485Activity.this, "串口已打开, 不能重复打开", Toast.LENGTH_SHORT).show();
                }else {
                    int rv = RS485Control.openSerialPort(serial, (int) baudRate, dataBits, parity, (int) stopBits, flowControl);
                    if(rv == 1){
                        Toast.makeText(RS485Activity.this, "请添加"+serial+"的权限", Toast.LENGTH_SHORT).show();
                    }else if (rv < 0) {
                        Toast.makeText(RS485Activity.this, "打开串口失败", Toast.LENGTH_SHORT).show();
                    } else {
                        turnFlag = true;
//                        startReceiving(); // 串口打开后默认开始读
                        serialOpened();
                        Toast.makeText(RS485Activity.this, "成功打开串口", Toast.LENGTH_SHORT).show();
                    }
                }
            } else if (id == R.id.btn_close){
                if (!turnFlag) {
                    Toast.makeText(RS485Activity.this, "串口已关闭，不能重复关闭", Toast.LENGTH_SHORT).show();
                }else {
                    // 关闭串口
                    int rv = RS485Control.closeSerialPort();
//                    Toast.makeText(MainActivity.this, "close", Toast.LENGTH_SHORT).show();
                    if (rv < 0) {
                        Toast.makeText(RS485Activity.this, "关闭串口失败", Toast.LENGTH_SHORT).show();
                    } else {
                        turnFlag = false;
                        serialClosed();
                        Toast.makeText(RS485Activity.this, "关闭串口", Toast.LENGTH_SHORT).show();
                    }
                }
            } else if (id == R.id.btn_clear_rev) {
                // 清空接收区数据
                mTvRev.setText("");
            } else if (id == R.id.btn_clear_send) {
                // 清空发送区内的数据
                mEtSend.getText().clear();
            } else if (id == R.id.btn_send) {
                // 读取发送区中的数据
                sendData = mEtSend.getText().toString();

                // 判断是否已连接串口, 如果没有连接串口则需先连接串口
                if( !turnFlag ){
                    Toast.makeText(RS485Activity.this, "串口未打开，请打开串口！", Toast.LENGTH_SHORT).show();
                }else if(sendData.isEmpty()){
                    // 判断发送区是否为空,如果为空则弹出提示
                    Toast.makeText(RS485Activity.this, "发送区为空，请输入数据！", Toast.LENGTH_SHORT).show();
                } else if (state != 0) {
                    Toast.makeText(RS485Activity.this, "串口未处于发送状态，不能发送数据!", Toast.LENGTH_SHORT).show();
                } else {
                    int rv = RS485Control.sendToPort(sendData, sendData.length());
                    if( rv < 0 )
                    {
                        Toast.makeText(RS485Activity.this, "发送数据失败！", Toast.LENGTH_SHORT).show();
                    }
                    Toast.makeText(RS485Activity.this, "发送数据成功", Toast.LENGTH_SHORT).show();

                }
            } else if (id == R.id.btn_send_state) {
                // 当gpio4-io26为0时，处于发送模式
                if( RS485Control.changeState(0) < 0 ){
                    Log.e("Change State for send", "Change State as send failed");
                }else {
                    state = 0;
                    if (turnFlag)
                        serialOpened();
                    else
                        serialClosed();
                }
            } else if (id == R.id.btn_recv_state) {
                // 当gpio4-io26为1时，处于接收模式
                if (RS485Control.changeState(1) < 0) {
                    Log.e("Change State for recv", "Change State as recv failed");
                } else {
                    state = 1;
                    if (turnFlag)
                        serialOpened();
                    else
                        serialClosed();
                }
            } else if (id == R.id.btn_recv) {
                // 当按下按钮后接收一次数据
                int len = 1024;
                int timeout = 10;
                SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                df.setTimeZone(TimeZone.getTimeZone("GMT+8"));
                String date = df.format(new Date());
                String buf = RS485Control.recvFromPort(len, timeout); // 超时时间设置为 1000 ms
                if (buf != null) {
                    String revData = date + "\t" + buf;
                    String currentText = mTvRev.getText().toString();
                    String newText = currentText + "\n" + revData; // 追加新数据
//                    mTvRev.setText(newText);
                    mTvRev.append("\n" + revData);
                    mTvRev.invalidate();
                    mTvRev.requestLayout();
                } else if (buf == null) {
                    System.err.println("Error receiving data.");
                }
            }
        }
    }

    private void serialClosed(){
        mTvShow.setTextColor(Color.parseColor("#FF0000"));
        if(currenState == null){
            mTvShow.setText("NOT CONNECTED");
        } else if (currenState.equals("recv"))
            mTvShow.setText("NOT CONNECTED"+"接收模式");
        else if (currenState.equals("send")) {
            mTvShow.setText("NOT CONNECTED"+"发送模式");
        }
        mTvShow.setPaintFlags(mTvShow.getPaintFlags() | Paint.ANTI_ALIAS_FLAG);
    }

    private void serialOpened(){
        mTvShow.setTextColor(Color.parseColor("#1FA324"));
        if (state == 1)
            mTvShow.setText(serial+" OPENED, "+baudRate+", "+dataBits+", "+stopBits+", "+parity+", "+"接收模式");
        else if (state == 0) {
            mTvShow.setText(serial+" OPENED, "+baudRate+", "+dataBits+", "+stopBits+", "+parity+", "+"发送模式");
        }else{
            mTvShow.setText(serial+" OPENED, "+baudRate+", "+dataBits+", "+stopBits+", "+parity);
        }

        mTvShow.setPaintFlags(mTvShow.getPaintFlags() | Paint.ANTI_ALIAS_FLAG);
    }
}