ZSGF Client Ruby SDK

gem 'zsgf_client'

require 'zsgf_client'

# 配置SDK
ZSGFClient.configure do |config|
  # 方式1：直接设置访问令牌
  config.access_token = 'YOUR_BEARER_TOKEN'
  
  # 方式2：动态获取访问令牌（推荐）
  config.access_token_getter = -> { 
    # 这里可以实现您的令牌获取逻辑
    # 例如从数据库、缓存或其他服务获取
    get_token_from_database()
  }
end

# 获取应用信息
api_instance = ZSGFClient::AppApi.new
app_key = 'your_app_key'

begin
  result = api_instance.app_info(app_key)
  puts "应用名称: #{result.data.name}"
  puts "应用描述: #{result.data.description}"
rescue ZSGFClient::ApiError => e
  puts "API调用失败: #{e.message}"
  puts "错误代码: #{e.code}"
end

user_api = ZSGFClient::UserApi.new

# 邮箱注册
signup_request = ZSGFClient::EmailSignUpRequest.new(
  email: 'user@example.com',
  password: 'secure_password',
  code: 'verification_code'
)

begin
  result = user_api.user_email_sign_up(app_key, signup_request)
  puts "注册成功，用户ID: #{result.data.user_id}"
rescue ZSGFClient::ApiError => e
  puts "注册失败: #{e.message}"
end

# 邮箱登录
signin_request = ZSGFClient::EmailSignInRequest.new(
  email: 'user@example.com',
  password: 'secure_password'
)

result = user_api.user_email_sign_in(app_key, signin_request)
access_token = result.data.access_token

# 获取用户资料
profile = user_api.user_profile(app_key)
puts "用户昵称: #{profile.data.nickname}"

# 更新用户资料
update_request = ZSGFClient::UpdateProfileRequest.new(
  nickname: '新昵称',
  avatar: 'https://example.com/avatar.jpg'
)

user_api.user_update_profile(app_key, update_request)

currency_api = ZSGFClient::UserCurrencyApi.new

# 查询用户资产
currencies = currency_api.user_currencies(app_key, user_id)
currencies.data.each do |currency|
  puts "货币: #{currency.name}, 余额: #{currency.balance}"
end

# 充值虚拟币
recharge_request = ZSGFClient::RechargePointRequest.new(
  currency_id: 1,
  amount: 100,
  reason: '充值'
)

currency_api.user_currency_recharge(app_key, recharge_request)

# 消费虚拟币
consume_request = ZSGFClient::CurrencyConsumeRequest.new(
  currency_id: 1,
  amount: 50,
  reason: '购买商品'
)

currency_api.user_currency_consume(app_key, consume_request)

file_api = ZSGFClient::FileApi.new

# 获取文件列表
files = file_api.files(app_key, path: '/')
files.data.each do |file|
  puts "文件名: #{file.name}, 大小: #{file.size}"
end

# 创建文件夹
file_api.file_create_folder(app_key, {
  path: '/新文件夹',
  name: '我的文件夹'
})

# 上传文件
File.open('local_file.txt', 'rb') do |file|
  file_api.file_upload(app_key, {
    path: '/',
    file: file
  })
end

storage_api = ZSGFClient::StorageApi.new
table_name = 'users'

# 添加数据
data = {
  name: '张三',
  age: 25,
  email: 'zhangsan@example.com'
}

result = storage_api.storage_post(app_key, table_name, data)
record_id = result.data.id

# 查询数据
records = storage_api.storage_list(app_key, table_name, {
  filter: 'age > 20',
  limit: 10
})

# 更新数据
update_data = { age: 26 }
storage_api.storage_put(app_key, table_name, record_id, update_data)

# 删除数据
storage_api.storage_delete(app_key, table_name, record_id)

# 支付宝支付
alipay_api = ZSGFClient::AlipayApi.new

# 创建当面付订单
order_request = ZSGFClient::AlipayCreateOrderRequest.new(
  out_trade_no: "ORDER_#{Time.now.to_i}",
  total_amount: '99.00',
  subject: '商品标题',
  body: '商品描述'
)

result = alipay_api.alipay_create_order(app_key, order_request)
puts "支付二维码: #{result.data.qr_code}"

# 查询订单状态
order_detail = alipay_api.alipay_order_detail(app_key, {
  out_trade_no: order_request.out_trade_no
})
puts "订单状态: #{order_detail.data.trade_status}"

wechat_api = ZSGFClient::WechatApi.new

# 小程序登录
js_code = 'wx_js_code_from_frontend'
session_result = wechat_api.wechat_js_code2_session(app_key, {
  js_code: js_code
})

openid = session_result.data.openid
session_key = session_result.data.session_key

# 发送订阅消息
subscribe_msg = {
  touser: openid,
  template_id: 'template_id',
  data: {
    thing1: { value: '消息内容' },
    time2: { value: Time.now.strftime('%Y-%m-%d %H:%M:%S') }
  }
}

wechat_api.wechat_subscribe_send(app_key, subscribe_msg)

begin
  result = api_instance.some_method(params)
rescue ZSGFClient::ApiError => e
  case e.code
  when 401
    puts "认证失败，请检查访问令牌"
  when 403
    puts "权限不足"
  when 404
    puts "资源不存在"
  when 429
    puts "请求过于频繁，请稍后再试"
  else
    puts "API错误: #{e.message}"
  end
rescue StandardError => e
  puts "系统错误: #{e.message}"
end

ZSGFClient.configure do |config|
  # API基础URL（通常不需要修改）
  config.host = 'api.zashigaofa.cn'
  
  # 超时设置
  config.timeout = 30
  
  # 调试模式
  config.debugging = true
  
  # 自定义用户代理
  config.user_agent = 'MyApp/1.0'
end

# 测试环境配置
ZSGFClient.configure do |config|
  config.host = 'test-api.zashigaofa.cn'  # 测试环境地址
  config.access_token = 'test_token'
  config.debugging = true
end

ZSGFClient.configure do |config|
  config.access_token_getter = -> { 
    # 实现自动刷新令牌的逻辑
    token = get_cached_token()
    if token_expired?(token)
      token = refresh_token()
      cache_token(token)
    end
    token
  }
end

def api_call_with_retry(api_method, *args, max_retries: 3)
  retries = 0
  begin
    api_method.call(*args)
  rescue ZSGFClient::ApiError => e
    retries += 1
    if retries <= max_retries && [429, 500, 502, 503].include?(e.code)
      sleep(2 ** retries) # 指数退避
      retry
    else
      raise e
    end
  end
end