Update HeartbeatAlarmReceiver.java

dev
wangsiyuan 2024-04-22 10:59:19 +08:00
parent 2314852b1c
commit db097f7dd9
1 changed files with 46 additions and 17 deletions

View File

@ -24,23 +24,40 @@ public class HeartbeatAlarmReceiver extends BroadcastReceiver {
private Context context; private Context context;
private String accessToken; private String accessToken;
private String SN; private String SN;
/**
* 广
*
* @param context1 访
* @param intent 广
*/
@Override @Override
public void onReceive(Context context1, Intent intent) { public void onReceive(Context context1, Intent intent) {
// 在这里执行发送心跳的逻辑 // 初始化上下文对象为后续操作提供context
context = context1; context = context1;
// 例如,你可以启动一个服务或者直接在这里执行网络请求 // 执行发送心跳信号的逻辑
sendHeartbeatSignal(); sendHeartbeatSignal();
// 重新设置下一个闹钟 // 在发送心跳后,重新设置下一次心跳发送的时间
MonitorService.scheduleHeartbeat(context); MonitorService.scheduleHeartbeat(context);
} }
/**
*
*
*
*/
private void sendHeartbeatSignal() { private void sendHeartbeatSignal() {
String heartBeatURL = context.getResources().getString(R.string.heart_beat_url); // 获取URL // 获取心跳请求的URL
String heartBeatURL = context.getResources().getString(R.string.heart_beat_url);
OkHttpClient client = new OkHttpClient(); OkHttpClient client = new OkHttpClient();
Request request = buildRequest(heartBeatURL); Request request = buildRequest(heartBeatURL);
// 发送异步请求
client.newCall(request).enqueue(new okhttp3.Callback() { client.newCall(request).enqueue(new okhttp3.Callback() {
@Override @Override
public void onFailure(okhttp3.Call call, IOException e) { public void onFailure(okhttp3.Call call, IOException e) {
// 请求失败时的处理逻辑
Timber.e(e, "请求 " + heartBeatURL + "失败"); Timber.e(e, "请求 " + heartBeatURL + "失败");
} }
@ -48,55 +65,67 @@ public class HeartbeatAlarmReceiver extends BroadcastReceiver {
public void onResponse(okhttp3.Call call, okhttp3.Response response) { public void onResponse(okhttp3.Call call, okhttp3.Response response) {
try { try {
if (!response.isSuccessful()) { if (!response.isSuccessful()) {
// 在这里处理响应错误 // 处理响应错误的情况
Timber.d("Request to " + heartBeatURL + " returned error: " + response.code() + ", " + response.message()); Timber.d("Request to " + heartBeatURL + " returned error: " + response.code() + ", " + response.message());
} else { } else {
// 处理成功响应 // 处理成功响应的逻辑
String responseBody = response.body().string(); // 获取响应体 String responseBody = response.body().string(); // 获取响应体内容
Gson gson = new Gson(); Gson gson = new Gson();
ApiResponse apiResponse = gson.fromJson(responseBody, ApiResponse.class); ApiResponse apiResponse = gson.fromJson(responseBody, ApiResponse.class);
if (apiResponse == null){ if (apiResponse == null) {
// 处理api响应为空的情况
Timber.d("apiResponse is null."); Timber.d("apiResponse is null.");
} }
if (!apiResponse.getCode().equals("0")) { if (!apiResponse.getCode().equals("0")) {
// 处理响应状态码错误的情况
Timber.d("请求返回状态码错误,返回内容: " + apiResponse); Timber.d("请求返回状态码错误,返回内容: " + apiResponse);
} }
} }
} catch (IOException e) { } catch (IOException e) {
// 处理响应处理过程中的IO异常
Timber.e(e, "IOException during handling response"); Timber.e(e, "IOException during handling response");
} catch (JsonSyntaxException e) { } catch (JsonSyntaxException e) {
// 处理响应解析过程中的JSON格式异常
Timber.e(e, "JsonSyntaxException during parsing response"); Timber.e(e, "JsonSyntaxException during parsing response");
} finally { } finally {
response.close(); // 确保响应体被关闭 // 确保响应体被关闭,避免资源泄露
response.close();
} }
} }
}); });
} }
private <T>Request buildRequest(String apiUrl){
/**
*
*
* @param apiUrl API
* @param <T>
* @return Request
*/
private <T> Request buildRequest(String apiUrl) {
// 从资源文件中读取序列号和访问令牌
SN = context.getResources().getString(R.string.SN); SN = context.getResources().getString(R.string.SN);
accessToken = context.getResources().getString(R.string.access_token); accessToken = context.getResources().getString(R.string.access_token);
// 创建设备信息对象并设置设备相关属性
DeviceInfo deviceInfo = new DeviceInfo(); DeviceInfo deviceInfo = new DeviceInfo();
deviceInfo.setDeviceBrand(DeviceInfoUtils.getDeviceBrand()); deviceInfo.setDeviceBrand(DeviceInfoUtils.getDeviceBrand());
deviceInfo.setDeviceModel(DeviceInfoUtils.getDeviceModel()); deviceInfo.setDeviceModel(DeviceInfoUtils.getDeviceModel());
deviceInfo.setAndroidVersion("Android " + DeviceInfoUtils.getDeviceAndroidVersion()); deviceInfo.setAndroidVersion("Android " + DeviceInfoUtils.getDeviceAndroidVersion());
deviceInfo.setSn(SN); deviceInfo.setSn(SN);
// 使用Gson将设备信息对象转换为JSON字符串
Gson gson = new Gson(); Gson gson = new Gson();
// 将对象转换为JSON字符串
String json = gson.toJson(deviceInfo); String json = gson.toJson(deviceInfo);
// Timber.d("Building request to " + apiUrl + " with data: " + json); // 创建请求体使用JSON格式
// 创建请求体
MediaType JSON = MediaType.get("application/json; charset=utf-8"); MediaType JSON = MediaType.get("application/json; charset=utf-8");
RequestBody body = RequestBody.create(json, JSON); RequestBody body = RequestBody.create(json, JSON);
// 构建请求对象并设置请求头包括accessToken和Content-Type
// 构建请求,并设置请求头
Request request = new Request.Builder() Request request = new Request.Builder()
.url(apiUrl) .url(apiUrl)
.addHeader("accessToken", accessToken) // 使用加载的accessToken .addHeader("accessToken", accessToken)
.addHeader("Content-Type", "application/json") .addHeader("Content-Type", "application/json")
.post(body) .post(body)
.build(); .build();
return request; return request;
} }
} }