127 lines
4.0 KiB
Dart
127 lines
4.0 KiB
Dart
import 'dart:convert';
|
||
|
||
import 'package:adjust_sdk/adjust.dart';
|
||
import 'package:adjust_sdk/adjust_attribution.dart';
|
||
import 'package:flutter/cupertino.dart';
|
||
import 'package:shared_preferences/shared_preferences.dart';
|
||
|
||
import 'device_info.dart';
|
||
import 'http_util.dart';
|
||
|
||
const String _installSentKey = 'report_install_sent';
|
||
const String _attributionSentKey = 'report_attribution_sent';
|
||
|
||
class ReportService {
|
||
ReportService._();
|
||
static final ReportService I = ReportService._();
|
||
|
||
String adjustId = '';
|
||
AdjustAttribution? _attribution;
|
||
AdjustAttribution? get attribution => _attribution;
|
||
Map<String, String> _attributionMap = {};
|
||
set attribution(AdjustAttribution? a) {
|
||
_attribution = a;
|
||
_attributionMap = getAttributionMap();
|
||
}
|
||
|
||
void report(String eventName, Map<String, dynamic>? params) {
|
||
sendReportAsync(eventName, params)
|
||
.then((_) => debugPrint('Report sent successfully $eventName'))
|
||
.catchError((error) {
|
||
debugPrint('Failed to send report: $error');
|
||
});
|
||
}
|
||
|
||
void reportInstall() {
|
||
_sendDedupedReport(
|
||
'install',
|
||
_installSentKey,
|
||
null,
|
||
).then((_) => debugPrint('Report install finished')).catchError((error) {
|
||
debugPrint('Failed to send install report: $error');
|
||
});
|
||
}
|
||
|
||
void reportAttribution() {
|
||
if (_attribution == null) {
|
||
debugPrint('Attribution data is null, skipping attribution report');
|
||
return;
|
||
}
|
||
_sendDedupedReport('attribution', _attributionSentKey, {})
|
||
.then((_) => debugPrint('Report attribution finished'))
|
||
.catchError((error) {
|
||
debugPrint('Failed to send attribution report: $error');
|
||
});
|
||
}
|
||
|
||
Future<void> sendReportAsync(
|
||
String eventName,
|
||
Map<String, dynamic>? params,
|
||
) async {
|
||
if (eventName.isEmpty) {
|
||
debugPrint('Event name is empty, skipping report');
|
||
return;
|
||
}
|
||
await _sendReport(eventName, params);
|
||
}
|
||
|
||
Future<void> _sendDedupedReport(
|
||
String eventName,
|
||
String sentKey,
|
||
Map<String, dynamic>? params,
|
||
) async {
|
||
final prefs = await SharedPreferences.getInstance();
|
||
final alreadySent = prefs.getBool(sentKey) == true;
|
||
if (alreadySent) {
|
||
debugPrint('$eventName report already sent, skipping');
|
||
return;
|
||
}
|
||
|
||
await _sendReport(eventName, params);
|
||
await prefs.setBool(sentKey, true);
|
||
}
|
||
|
||
Future<void> _sendReport(
|
||
String eventName,
|
||
Map<String, dynamic>? params,
|
||
) async {
|
||
final deviceInfo = await DeviceInfo.I.deviceInfo(includeAdjust: false);
|
||
Map<String, dynamic> reportData = {
|
||
'event': eventName,
|
||
'params': params ?? {},
|
||
'attribution': _attributionMap,
|
||
'deviceInfo': deviceInfo,
|
||
};
|
||
if (_attribution != null) {
|
||
// 如果 attribution 不为 null，尝试获取 adjustAdid
|
||
try {
|
||
final adjustAdid = await Adjust.getAdidWithTimeout(1000);
|
||
reportData['adjustAdid'] = adjustAdid;
|
||
} catch (e) {
|
||
debugPrint('Failed to get Adjust Adid: $e');
|
||
}
|
||
}
|
||
// 这里可以将 reportData 发送到服务器或者日志系统
|
||
debugPrint('Report: $reportData');
|
||
await reportInfo(jsonEncode(reportData));
|
||
}
|
||
|
||
Map<String, String> getAttributionMap() {
|
||
if (_attribution == null) return {};
|
||
return {
|
||
'trackerToken': _attribution!.trackerToken ?? '',
|
||
'trackerName': _attribution!.trackerName ?? '',
|
||
'network': _attribution!.network ?? '',
|
||
'campaign': _attribution!.campaign ?? '',
|
||
'adgroup': _attribution!.adgroup ?? '',
|
||
'creative': _attribution!.creative ?? '',
|
||
'clickLabel': _attribution!.clickLabel ?? '',
|
||
'costType': _attribution!.costType ?? '',
|
||
'costAmount': _attribution!.costAmount?.toString() ?? '',
|
||
'costCurrency': _attribution!.costCurrency ?? '',
|
||
'jsonResponse': _attribution!.jsonResponse ?? '',
|
||
'fbInstallReferrer': _attribution!.fbInstallReferrer ?? '',
|
||
};
|
||
}
|
||
}
|