Android CameraX を始めてみて3

copy

    private fun takePhoto() {
        // Get a stable reference of the modifiable image capture use case
        val imageCapture = imageCapture ?: return

        // Create time stamped name and MediaStore entry.
        val name = SimpleDateFormat(FILENAME_FORMAT, Locale.US)
            .format(System.currentTimeMillis())
        val contentValues = ContentValues().apply {
            put(MediaStore.MediaColumns.DISPLAY_NAME, name)
            put(MediaStore.MediaColumns.MIME_TYPE, "image/jpeg")
            if (Build.VERSION.SDK_INT > Build.VERSION_CODES.P) {
                put(MediaStore.Images.Media.RELATIVE_PATH, "Pictures/CameraX-Image")
            }
        }

        // Create output options object which contains file + metadata
        val outputOptions = ImageCapture.OutputFileOptions
            .Builder(
                contentResolver,
                MediaStore.Images.Media.EXTERNAL_CONTENT_URI,
                contentValues
            )
            .build()

        // Set up image capture listener, which is triggered after photo has
        // been taken
        imageCapture.takePicture(
            outputOptions,
            ContextCompat.getMainExecutor(this),
            object : ImageCapture.OnImageSavedCallback {
                override fun
                        onError(exc: ImageCaptureException) {
                    Log.e(TAG, "Photo capture failed: ${exc.message}", exc)
                }

                override fun
                        onImageSaved(output: ImageCapture.OutputFileResults) {
                    val msg = "Photo capture succeeded: ${output.savedUri}"
                    Toast.makeText(baseContext, msg, Toast.LENGTH_SHORT).show()
                    Log.d(TAG, msg)

                    val projection = arrayOf(MediaStore.MediaColumns.DATA)
                    //アプリケーションのデータベースに接続して URI を検索します
                    val cursor =
                        applicationContext.contentResolver.query(
                            Uri.parse(
                                output.savedUri.toString()
                            ), projection, null, null, null
                        )

                    if (cursor != null) {
                        var path: String? = null
                        //最初のレコードにカーソルを移します
                        if (cursor.moveToFirst()) {
                            //path はカラムのインデックスが 0 のようです
                            path = cursor.getString(0)
                            //スマホのテキストビューにパスを表示します
                            findViewById<TextView>(R.id.tvinfo).text = path
                        }
                        cursor.close()
                        if (path != null) {
                            //パスが取得できたので File を作成します
                            val file = File(path)
                            //ftpDirectory は "ftp://192.168.□□.□□/" 不要
                            val filelist = FtpAccess().Await(
                                "□□□□",
                                "□□□□□□□□□□",
                                "192.168.□□.□□",
                                "□□□□□□/□□□□□□/",
                                file
                            )
                            findViewById<TextView>(R.id.tvinfo).text = filelist
                        }
                    }
                }
            }
        )
    }

copy

//fun takePhoto() から呼び出すようにしています
class FtpAccess {
    // 非同期内でセットした文字列を返す
    fun Await(ftpUsername: String,
              ftpPassword: String,
              ftpServer: String,
              ftpDirectory: String,
              file: File): String? {
        Log.d("Coroutine", "executeAwait start")
        var ayncString: String?
        //ここでコルーチンを使います
        runBlocking {
            ayncString = execute(ftpUsername,
                                 ftpPassword,
                                 ftpServer,
                                 ftpDirectory,
                                 file)
        }
        return ayncString
    }

    suspend fun execute(ftpUsername: String,
                        ftpPassword: String,
                        ftpServer: String,
                        ftpDirectory: String,
                        file: File): String? {
        //ファイルの一覧表を返します
        return withContext(Dispatchers.IO) {
            var infolist = mutableListOf<String>()
            val ftpClient = FTPClient()
            try {
                //デフォルト ポートでリモート ホストに接続され、システムに割り当てられたポートで現在のホストから発信されるソケットを開きます
                ftpClient.connect(ftpServer)

                //指定されたユーザーとパスワードを使用して FTP サーバーにログインします
                ftpClient.login(ftpUsername, ftpPassword)

                //データ転送を行うために接続するデータ ポートを開くようにサーバーに指示されます
                ftpClient.enterLocalPassiveMode()

                //多くの FTP サーバーはデフォルトで BINARY になっています
                ftpClient.setFileType(FTP.BINARY_FILE_TYPE)

                Log.d("ServerFileAccess", ftpClient.status)

                //ディレクトリ移動
                ftpClient.changeWorkingDirectory(ftpDirectory)

                //
                val filenames: Array<String> = ftpClient.listNames()
                for (i in filenames.indices) {
                    Log.d("ServerFileAccess", filenames[i])
                    infolist.add(filenames[i])
                }

                //NASにファイルをアップロード
                val inputStream = FileInputStream(file)
                val fileName = file.name
                ftpClient.storeFile(fileName, inputStream)
                inputStream.close()

            } catch (e: Exception) {
                e.printStackTrace()
                infolist.add(e.printStackTrace().toString())
            } finally {
                Log.d("ServerFileAccess", "finally")
                infolist.add("処理を終了します")
                ftpClient.logout()
                ftpClient.disconnect()
            }
            infolist.joinToString("\n")
        }
    }
}

copy

    private fun initstart() {
        findViewById<Button>(R.id.btLeft).setOnClickListener() {
            // 非同期処理
            //smbroot は "sm://192.168.□□.□□/□□□□□□□□□□□□□□/"
            val filelist = SmbAccess().Await("□□□□",
                "□□□□□□□□□□",
                "192.168.□□.□□",
                "sm://192.168.□□.□□/□□□□□□/□□□□□□/"
            )
            findViewById<TextView>(R.id.tvinfo).text = filelist
        }

        findViewById<Button>(R.id.btRight).setOnClickListener() {
            findViewById<TextView>(R.id.tvinfo).text = "FTP"
            // 非同期処理
            //ftpDirectory は "ftp://192.168.□□.□□/" 不要
            //FtpAccess("□□□□",
            //    "□□□□□□□□□□",
            //    "192.168.□□.□□",
            //    "□□□□□□/□□□□□□/")
        }
    }
}