Flutter Odoo RPC通信插件flutter_odoo_rpc的使用

Odoo RPC客户端库

Odoo RPC客户端库用于Dart。

特性

• 使用之前存储的Odoo会话初始化客户端。
• 通过数据库名称、登录名和密码进行身份验证。
• 向JSON控制器发出JSON-RPC请求。
• 通过CallKw执行公共方法。
• 通过流获取Odoo会话更新。
• 终止会话（登出）。
• 捕获会话过期时的异常。

使用

要使用此插件，在您的pubspec.yaml文件中添加flutter_odoo_rpc作为依赖。例如：

dependencies:
  flutter_odoo_rpc: ^0.4.5

示例

基本RPC调用

import 'dart:io';
import 'package:flutter_odoo_rpc/flutter_odoo_rpc.dart';

main() async {
  final client = OdooClient('https://my-db.odoo.com');
  try {
    await client.authenticate('my-db', 'admin', 'admin');
    final res = await client.callRPC('/web/session/modules', 'call', {});
    print('已安装模块: \n' + res.toString());
  } on OdooException catch (e) {
    print(e);
    client.close();
    exit(-1);
  }
  client.close();
}

带有跟踪会话变化的RPC调用

Odoo服务器将在每次调用时发出新的session_id。

import 'dart:io';
import 'package:flutter_odoo_rpc/flutter_odoo_rpc.dart';

void sessionChanged(OdooSession sessionId) async {
  print('我们得到了新的会话ID: ' + sessionId.id);
  // 将会话ID存储到某种持久化存储中
}

void main() async {
  // 从某种持久化存储中恢复会话
  var prev_session = restore_session_somehow();
  var client = OdooClient("https://my-db.odoo.com", prev_session);

  // 订阅会话变化以存储最新的会话
  var subscription = client.sessionStream.listen(sessionChanged);

  try {
    final session = await client.authenticate('my-db', 'admin', 'admin');
    var res = await client.callRPC('/web/session/modules', 'call', {});
    print('已安装模块: \n' + res.toString());

    // 登出
    await client.destroySession();
  } on OdooException catch (e) {
    print(e);
    subscription.cancel();
    client.close();
    exit(-1);
  }

  try {
    await client.checkSession();
  } on OdooSessionExpiredException {
    print('会话过期');
  }

  subscription.cancel();
  client.close();
}

使用FutureBuilder的Flutter示例

import 'package:flutter/material.dart';
import 'package:flutter_odoo_rpc/flutter_odoo_rpc.dart';

final orpc = OdooClient('https://my-odoo-instance.com');
void main() async {
  await orpc.authenticate('odoo-db', 'admin', 'admin');
  runApp(MyApp());
}

class MyApp extends StatelessWidget {
  [@override](/user/override)
  Widget build(BuildContext context) {
    return MaterialApp(
      title: 'Flutter Demo',
      theme: ThemeData(
        primarySwatch: Colors.blue,
      ),
      home: HomePage(),
    );
  }
}

class HomePage extends StatelessWidget {
  Future<dynamic> fetchContacts() {
    return orpc.callKw({
      'model': 'res.partner',
      'method': 'search_read',
      'args': [],
      'kwargs': {
        'context': {'bin_size': true},
        'domain': [],
        'fields': ['id', 'name', 'email', '__last_update', 'image_128'],
        'limit': 80,
      },
    });
  }

  Widget buildListItem(Map<String, dynamic> record) {
    var unique = record['__last_update'] as String;
    unique = unique.replaceAll(RegExp(r'[^0-9]'), '');
    final avatarUrl = '${orpc.baseURL}/web/image?model=res.partner&field=image_128&id=${record["id"]}&unique=$unique';
    return ListTile(
      leading: CircleAvatar(backgroundImage: NetworkImage(avatarUrl)),
      title: Text(record['name']),
      subtitle: Text(record['email'] is String ? record['email'] : ''),
    );
  }

  [@override](/user/override)
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        title: Text('联系人'),
      ),
      body: Center(
        child: FutureBuilder(
            future: fetchContacts(),
            builder: (BuildContext context, AsyncSnapshot<dynamic> snapshot) {
              if (snapshot.hasData) {
                return ListView.builder(
                    itemCount: snapshot.data.length,
                    itemBuilder: (context, index) {
                      final record = snapshot.data[index] as Map<String, dynamic>;
                      return buildListItem(record);
                    });
              } else {
                if (snapshot.hasError) return Text('无法获取数据');
                return CircularProgressIndicator();
              }
            }),
      ),
    );
  }
}