1. 程式人生 > >Android USB轉串列埠開發(hoho.android.usbserial串列埠庫)

Android USB轉串列埠開發(hoho.android.usbserial串列埠庫)

使用hoho.android.usbserial串列埠庫開發串列埠
import android.app.Application
import android.app.PendingIntent
import android.content.BroadcastReceiver
import android.content.Context
import android.content.Intent
import android.hardware.usb.UsbDevice
import android.hardware.usb.UsbManager
import android.util.Log
import android.widget.Toast
import com.cuifeipeng.unfix.raman.BaseActivity
import com.cuifeipeng.unfix.raman.model.LaserParameter
import com.hoho.android.usbserial.driver.UsbSerialProber
import java.util.concurrent.Semaphore
廣播類


class DeviceBroadcastReceiver (var deviceContext: DeviceContext) : BroadcastReceiver() {

override fun onReceive(context: Context?, intent: Intent?) {
    val device1 = intent!!.getParcelableExtra<UsbDevice>(UsbManager.EXTRA_DEVICE)
    val action = intent!!.action
    when (action) {
        UsbManager.ACTION_USB_DEVICE_ATTACHED -> {
            val device = intent.getParcelableExtra<UsbDevice>(UsbManager.EXTRA_DEVICE)
            val mUsbManager = context!!.getSystemService(Context.USB_SERVICE) as UsbManager
            val mPermissionIntent = PendingIntent.getBroadcast(context, 0, Intent(DeviceContext.ACTION_USB_PERMISSION), 0)
            mUsbManager.requestPermission(device, mPermissionIntent)
        }
        UsbManager.ACTION_USB_DEVICE_DETACHED -> {
            val device = intent.getParcelableExtra<UsbDevice>(UsbManager.EXTRA_DEVICE)
            if (deviceContext.ccdAdapter?.usbDevice == device) {
                deviceContext.ccdAdapter = null
            } else if (deviceContext.laserAdapter?.usbDevice == device) {
                deviceContext.laserAdapter = null
            }
        }
        DeviceContext.ACTION_USB_PERMISSION -> {
            synchronized(this) {
                val device = intent.getParcelableExtra<UsbDevice>(UsbManager.EXTRA_DEVICE)
                if (intent.getBooleanExtra(UsbManager.EXTRA_PERMISSION_GRANTED, false)) {
                    val mUsbManager = context!!.getSystemService(Context.USB_SERVICE) as UsbManager
                    connectDevice(mUsbManager, device, context)

                    if (deviceIterator!!.hasNext()) {
                        val nextDevice = deviceIterator!!.next()
                        mUsbManager.requestPermission(nextDevice, mPermissionIntent!!)
                    } else {

                    }
                } else {

                    Log.d("sss", "permission denied for device " + device)
                }
            }
        }
    }
}

private var deviceIterator: MutableIterator<UsbDevice>? = null
private var mPermissionIntent: PendingIntent? = null
private val semaphore : Semaphore = Semaphore(1)
private val semaphore2 : Semaphore = Semaphore(1)
fun requestPermission(context: Context) {
    mPermissionIntent = PendingIntent.getBroadcast(context, 0, Intent(DeviceContext.ACTION_USB_PERMISSION), 0)

    val mUsbManager = context.getSystemService(Context.USB_SERVICE) as UsbManager
    val deviceList = mUsbManager.deviceList

    deviceIterator = deviceList.values.iterator()
    if (deviceIterator!!.hasNext()) {
        val device = deviceIterator!!.next()
        mUsbManager.requestPermission(device, mPermissionIntent!!)
    }
}

private fun connectDevice(usbManager: UsbManager, usbDevice: UsbDevice?, context: Context) {
    try {
        if (usbDevice != null) {
            //context!!.getSystemService(Context.USB_SERVICE) as UsbManager
            val availableDriver = UsbSerialProber.getDefaultProber().probeDevice(usbDevice)
            if (availableDriver != null) {
                val connection = usbManager.openDevice(availableDriver.device) ?: return
                val port = availableDriver.ports[0]
                port.open(connection)
                if (deviceContext.ccdAdapter == null && CCDAdapter.isCCDDevice(port)) {
                    deviceContext.ccdAdapter = CCDAdapter(port, usbDevice)
                }else if(deviceContext.laserAdapter == null)
                {
                    if (LaserAdapter4.isLaserDevice(port)) {
                        val laserParameter = LaserParameter.fromSharedPreferences(context.getSharedPreferences(BaseActivity.preferenceName, Context.MODE_PRIVATE))
                        deviceContext.laserAdapter = LaserAdapter4(port, laserParameter, usbDevice)
                    }
                }
                else if (deviceContext.laserAdapter == null ) {
                    if (LaserAdapter3.isLaserDevice(port)) {
                        val laserParameter = LaserParameter.fromSharedPreferences(context.getSharedPreferences(BaseActivity.preferenceName, Context.MODE_PRIVATE))
                        deviceContext.laserAdapter = LaserAdapter3(port, laserParameter, usbDevice)
                    }
                } else if (deviceContext.laserAdapter == null) {
                    if (LaserAdapter2.isLaserDevice(port)) {
                        val laserParameter = LaserParameter.fromSharedPreferences(context.getSharedPreferences(BaseActivity.preferenceName, Context.MODE_PRIVATE))
                        deviceContext.laserAdapter = LaserAdapter2(port, laserParameter, usbDevice)
                    }
                } else if (deviceContext.laserAdapter == null ) {
                    if (LaserAdapter1.isLaserDevice(port)) {
                        val laserParameter = LaserParameter.fromSharedPreferences(context.getSharedPreferences(BaseActivity.preferenceName, Context.MODE_PRIVATE))
                        deviceContext.laserAdapter = LaserAdapter1(port, laserParameter, usbDevice)
                    }
                }
                else {
                    port.close()
                }
            } else {
            }
        } else {
        }
    } catch (e: Exception) {
        deviceContext.setError(e.message.toString() + e.stackTrace.joinToString("@"))
    }
}

}

硬體上下文類
class DeviceContext {

companion object {
    var ACTION_USB_PERMISSION = "com.android.example.USB_PERMISSION"
    private var instance: DeviceContext? = null
    fun setInstance(context: DeviceContext) {
        instance = context
    }

    fun getInstance(): DeviceContext? {
        return instance
    }
}

private var _ccdAdapter: CCDAdapter? = null;
private var _laserAdapter: LaserAdapter? = null;
var ccdAdapter: CCDAdapter?
    set(value) {
        if (_ccdAdapter == value) return
        _ccdAdapter = value;
        if (value != null)
            onConnectDevice("ccd")
        else onDisConnectDevice("ccd")
    }
    get() {
        return _ccdAdapter;
    }
var laserAdapter: LaserAdapter?
    set(value) {
        if (_laserAdapter == value) return
        _laserAdapter = value;
        if (value != null)
            onConnectDevice("laser")
        else onDisConnectDevice("laser")
    }
    get() {
        return _laserAdapter;
    }

var deviceConnected: IOnDeviceConnected? = null;

fun isAllConnected(): Boolean {
    //return ccdAdapter != null
    return ccdAdapter != null && laserAdapter != null;
}

private fun onConnectDevice(message:String) {
    deviceConnected?.onConnected(this,message)
}

private fun onDisConnectDevice(message:String) {
    deviceConnected?.onDisConnected(this,message)
}

fun dispose() {
    ccdAdapter?.dispose()
    ccdAdapter = null
    laserAdapter?.dispose()
    laserAdapter = null
}

fun setError(message: String) {
    deviceConnected?.onError(this, message)
}

fun setOnConnected(deviceConnected: IOnDeviceConnected) {
    this.deviceConnected = deviceConnected;
}

}
裝置類
import android.hardware.usb.UsbDevice
import com.cuifeipeng.unfix.raman.model.LaserParameter
import com.cuifeipeng.unfix.raman.util.LogUtil
import com.hoho.android.usbserial.driver.UsbSerialPort

class LaserAdapter4 (port: UsbSerialPort, laserParameter: LaserParameter, usbDevice: UsbDevice):LaserAdapter(port,laserParameter,usbDevice) {
override fun dispose() {

    closeLaser()
    port.close()
}

override fun openLaser() {
    SetControlMode(0)//設定鐳射器工作模式
    SetLaserStatus(1)//設定鐳射器工作狀態

}

override fun closeLaser() {

    SetLaserStatus(0)//設定鐳射器工作狀態
    SetLaserCurrent(0)//設定電流


}

override fun setLaserPower(power: Double) {

    SetLaserCurrent(power.toInt())//設定鐳射器工作電流(mA)
}

//********************************************************************************************************************
private fun SetDeviceID(id:String): Boolean//設定序列號
{
    var tempStr= ":SN=" + id+";"
    var sendByte:ByteArray=tempStr.toByteArray(Charsets.US_ASCII)
    write(port, sendByte)
    var ReceiveBuffer = ByteArray(17)

    read(port, ReceiveBuffer)
    var resultStr:String = ReceiveBuffer.toString(Charsets.US_ASCII)
    var value:String= resultStr.substring(4,10)
    if(id== value)
    {
        return true;
    }
    else
    {
        return false;
    }

}
public fun GetDeviceID():String//獲取序列號
{
   var tempStr= ":SN=?;"

    var sendByte:ByteArray = tempStr.toByteArray(Charsets.US_ASCII)
    write(port, sendByte)
    var ReceiveBuffer = ByteArray(17)
    read(port, ReceiveBuffer)
    var resultStr:String = ReceiveBuffer.toString(Charsets.US_ASCII)

    var value:String= resultStr.substring(4,10)
    return value
}

public fun GetRunTime():Int//獲取執行時間
{
    var tempStr= ":WT=?;"

    var sendByte:ByteArray = tempStr.toByteArray(Charsets.US_ASCII)
    write(port, sendByte)
    var ReceiveBuffer = ByteArray(15)
    read(port, ReceiveBuffer)
    var resultStr:String = ReceiveBuffer.toString(Charsets.US_ASCII)

    var value:Int= resultStr.substring(4,5).toInt()
    return value
}

public fun SetControlMode(mode:Int):Boolean//設定控制模式:PCN=0;PCN=1;(PCN=1 切換到外部模擬量控制;PCN=0 使用USB設定)
{
    var sendStr:String = ""
    if (mode == 0)
    {
        sendStr = ":PCN=0;"
    }
    else if (mode == 1)
    {
        sendStr = ":PCN=1;"

    }

    var sendByte:ByteArray = sendStr.toByteArray(Charsets.US_ASCII)
    write(port, sendByte)
    return true
    var ReceiveBuffer = ByteArray(9)
    read(port, ReceiveBuffer)
    var resultStr:String = ReceiveBuffer.toString(Charsets.US_ASCII)

    var value:Int= resultStr.substring(5,1).toInt()
    if (value == mode)
    { return true }
    else
    {
        return false
    }
}

public fun GetModuleTemprature():Int//讀取鐳射器模組溫度
{
    var tempStr=":LDDT=?;"

    var sendByte:ByteArray = tempStr.toByteArray(Charsets.US_ASCII)
    write(port, sendByte)
    var ReceiveBuffer = ByteArray(14)
    read(port, ReceiveBuffer)
    var resultStr:String = ReceiveBuffer.toString(Charsets.US_ASCII)

    var value:Int= resultStr.substring(6,5).toInt()
    return value
}
public fun GetLaserCurrentTemprature():Int//讀取鐳射器溫度
{
    var tempStr=":LDT=?;"

    var sendByte:ByteArray = tempStr.toByteArray(Charsets.US_ASCII)
    write(port, sendByte)
    var ReceiveBuffer = ByteArray(15)
    read(port, ReceiveBuffer)
    var resultStr:String = ReceiveBuffer.toString(Charsets.US_ASCII)

    var value:Int= resultStr.substring(5,5).toInt()
    return value
}
public fun GetLaserCurrent():Int//讀取鐳射器實際電流
{
    var tempStr= ":LDC=?;"

    var sendByte:ByteArray = tempStr.toByteArray(Charsets.US_ASCII)
    write(port, sendByte)
    var ReceiveBuffer = ByteArray(15)
    read(port, ReceiveBuffer)
    var resultStr:String = ReceiveBuffer.toString(Charsets.US_ASCII)

    var value:Int= resultStr.substring(5,5).toInt()
    return value
}
public fun GetTECCurrent():Int//讀取TEC實際電流
{
    var tempStr= ":TECC=?;"

    var sendByte:ByteArray = tempStr.toByteArray(Charsets.US_ASCII)
    write(port, sendByte)
    var ReceiveBuffer = ByteArray(16)
    read(port, ReceiveBuffer)
    var resultStr:String = ReceiveBuffer.toString(Charsets.US_ASCII)

    var value:Int= resultStr.substring(6,5).toInt()
    return value
}

public fun SetLaserCurrent(current:Int):Boolean//設定鐳射器工作電流(mA)
{
    var tempValue=current.toString()
    while(tempValue.length<5)
    {
        tempValue = "0"+tempValue;
    }
    var tempStr = ":LDC=" + tempValue.toString() + ";"

    var sendByte: ByteArray = tempStr.toByteArray(Charsets.US_ASCII)
    write(port, sendByte)
    var ReceiveBuffer = ByteArray(13)
    return true
    read(port, ReceiveBuffer)
    var resultStr: String = ReceiveBuffer.toString(Charsets.US_ASCII)

    var value: Int = resultStr.substring(5, 5).toInt()
    if (current == value) {
        return true
    } else {
        return false
    }
}
    public fun SetLaserStatus(status:Int):Boolean//設定鐳射器工作狀態
    {
        var sendStr = ""

        if (status == 0) {
            sendStr = ":LDON=0;";
        } else if (status == 1) {
            sendStr = ":LDON=1;";

        }

        var sendByte: ByteArray = sendStr.toByteArray(Charsets.US_ASCII)
        write(port, sendByte)
        var ReceiveBuffer = ByteArray(10)
        return true
        read(port, ReceiveBuffer)
        var resultStr: String = ReceiveBuffer.toString(Charsets.US_ASCII)

        var value: Int = resultStr.substring(6, 1).toInt()
        if (value == status) {
            return true
        } else {
            return false
        }
    }

        public fun SetTECTemprature(temprature:Int):Boolean//設TEC工作溫度
        {
            var tempStr = ":LDT=" + temprature.toString() + ";";
            var sendByte: ByteArray = tempStr.toByteArray(Charsets.US_ASCII)
            write(port, sendByte)
            var ReceiveBuffer = ByteArray(13)
            read(port, ReceiveBuffer)
            var resultStr: String = ReceiveBuffer.toString(Charsets.US_ASCII)

            var value: Int = resultStr.substring(5, 5).toInt()
            if (value == temprature) {
                return true
            } else {
                return false
            }
        }


companion object {


    //**********************************************************************************************



    private fun write(port: UsbSerialPort, cmd: ByteArray) {

        LogUtil.debug("Laser4 write", cmd.joinToString(","))
        port.write(cmd, 1000)
    }

    private fun read(port: UsbSerialPort, resultByte: ByteArray) {
        val bufferArray = ByteArray(resultByte.size)
        var readCount = 0
        do {
            val count = port.read(bufferArray, 1000)
            for (i in 0..(count -1)) {
                if (readCount + i < resultByte.count())
                    resultByte[readCount + i] = bufferArray[i]
            }
            readCount += count
        } while (readCount < resultByte.count())

        //LogUtil.debug("Laser4 read", resultByte.joinToString(","))


    }
    private fun read2(port: UsbSerialPort, resultByte: ByteArray) {
        val bufferArray = ByteArray(resultByte.size)

            val count = port.read(bufferArray, 1000)

          var tempStr=bufferArray.toString(Charsets.US_ASCII)


        LogUtil.debug("Laser4 read", tempStr)


    }

    fun isLaserDevice(port: UsbSerialPort): Boolean {
        return try {

            port.setParameters(115200, 8, UsbSerialPort.STOPBITS_1, UsbSerialPort.PARITY_NONE)
            var tempStr=":SN=?;"
            val cmd =tempStr.toByteArray(Charsets.US_ASCII)

            write(port, cmd)

            val resultByte = ByteArray(15)
            return true
            read(port, resultByte)

            var resultStr: String = resultByte.toString(Charsets.US_ASCII)
           var value= resultStr.substring(4, 10)

            if (value!="0123456789") return false
            LogUtil.debug("Laser4 connected", ":true")

            true
        } catch (e: Exception) {
            false
        }
    }
}

}

在其他類呼叫
private var deviceContext = DeviceContext()
private var deviceBroadcastReceiver = DeviceBroadcastReceiver(deviceContext)