Skip to content

Commit

Permalink
重寫部分函數
Browse files Browse the repository at this point in the history
  • Loading branch information
qwe7002 committed Oct 31, 2022
1 parent 4e7e974 commit 4e88eaa
Show file tree
Hide file tree
Showing 18 changed files with 260 additions and 260 deletions.
24 changes: 12 additions & 12 deletions app/src/main/java/com/qwe7002/telegram_sms/battery_service.java
Original file line number Diff line number Diff line change
Expand Up @@ -14,10 +14,10 @@
import com.google.gson.Gson;
import com.qwe7002.telegram_sms.config.proxy;
import com.qwe7002.telegram_sms.data_structure.request_message;
import com.qwe7002.telegram_sms.static_class.log_func;
import com.qwe7002.telegram_sms.static_class.network_func;
import com.qwe7002.telegram_sms.static_class.other_func;
import com.qwe7002.telegram_sms.static_class.sms_func;
import com.qwe7002.telegram_sms.static_class.logFunc;
import com.qwe7002.telegram_sms.static_class.networkFunc;
import com.qwe7002.telegram_sms.static_class.otherFunc;
import com.qwe7002.telegram_sms.static_class.smsFunc;
import com.qwe7002.telegram_sms.value.const_value;
import com.qwe7002.telegram_sms.value.notify_id;

Expand Down Expand Up @@ -46,7 +46,7 @@ public class battery_service extends Service {
private static ArrayList<send_obj> send_loop_list;
@Override
public int onStartCommand(Intent intent, int flags, int startId) {
Notification notification = other_func.get_notification_obj(context, getString(R.string.battery_monitoring_notify));
Notification notification = otherFunc.getNotificationObj(context, getString(R.string.battery_monitoring_notify));
startForeground(notify_id.BATTERY, notification);
return START_STICKY;
}
Expand Down Expand Up @@ -99,14 +99,14 @@ private void network_handle(send_obj obj) {
final request_message request_body = new request_message();
request_body.chat_id = battery_service.chat_id;
request_body.text = obj.content;
String request_uri = network_func.get_url(battery_service.bot_token, "sendMessage");
String request_uri = networkFunc.getUrl(battery_service.bot_token, "sendMessage");
if ((System.currentTimeMillis() - last_receive_time) <= 5000L && last_receive_message_id != -1) {
request_uri = network_func.get_url(bot_token, "editMessageText");
request_uri = networkFunc.getUrl(bot_token, "editMessageText");
request_body.message_id = last_receive_message_id;
Log.d(TAG, "onReceive: edit_mode");
}
last_receive_time = System.currentTimeMillis();
OkHttpClient okhttp_client = network_func.get_okhttp_obj(battery_service.doh_switch, Paper.book("system_config").read("proxy_config", new proxy()));
OkHttpClient okhttp_client = networkFunc.get_okhttp_obj(battery_service.doh_switch, Paper.book("system_config").read("proxy_config", new proxy()));
String request_body_raw = new Gson().toJson(request_body);
RequestBody body = RequestBody.create(request_body_raw, const_value.JSON);
Request request = new Request.Builder().url(request_uri).method("POST", body).build();
Expand All @@ -115,19 +115,19 @@ private void network_handle(send_obj obj) {
try {
Response response = call.execute();
if (response.code() == 200) {
last_receive_message_id = other_func.get_message_id(Objects.requireNonNull(response.body()).string());
last_receive_message_id = otherFunc.get_message_id(Objects.requireNonNull(response.body()).string());
} else {
assert response.body() != null;
last_receive_message_id = -1;
if (obj.action.equals(Intent.ACTION_BATTERY_LOW)) {
sms_func.send_fallback_sms(context, request_body.text, -1);
smsFunc.send_fallback_sms(context, request_body.text, -1);
}
}
} catch (IOException e) {
e.printStackTrace();
log_func.write_log(context, error_head + e.getMessage());
logFunc.writeLog(context, error_head + e.getMessage());
if (obj.action.equals(Intent.ACTION_BATTERY_LOW)) {
sms_func.send_fallback_sms(context, request_body.text, -1);
smsFunc.send_fallback_sms(context, request_body.text, -1);
}
}
}
Expand Down
12 changes: 6 additions & 6 deletions app/src/main/java/com/qwe7002/telegram_sms/boot_receiver.java
Original file line number Diff line number Diff line change
Expand Up @@ -6,9 +6,9 @@
import android.content.SharedPreferences;
import android.util.Log;

import com.qwe7002.telegram_sms.static_class.log_func;
import com.qwe7002.telegram_sms.static_class.resend_func;
import com.qwe7002.telegram_sms.static_class.service_func;
import com.qwe7002.telegram_sms.static_class.logFunc;
import com.qwe7002.telegram_sms.static_class.resendFunc;
import com.qwe7002.telegram_sms.static_class.serviceFunc;

import org.jetbrains.annotations.NotNull;

Expand All @@ -25,11 +25,11 @@ public void onReceive(@NotNull final Context context, @NotNull Intent intent) {
final SharedPreferences sharedPreferences = context.getSharedPreferences("data", Context.MODE_PRIVATE);
if (sharedPreferences.getBoolean("initialized", false)) {
Paper.init(context);
log_func.write_log(context, "Received [" + intent.getAction() + "] broadcast, starting background service.");
service_func.start_service(context, sharedPreferences.getBoolean("battery_monitoring_switch", false), sharedPreferences.getBoolean("chat_command", false));
logFunc.writeLog(context, "Received [" + intent.getAction() + "] broadcast, starting background service.");
serviceFunc.start_service(context, sharedPreferences.getBoolean("battery_monitoring_switch", false), sharedPreferences.getBoolean("chat_command", false));
if (Paper.book().read("resend_list", new ArrayList<>()).size() != 0) {
Log.d(TAG, "An unsent message was detected, and the automatic resend process was initiated.");
resend_func.start_resend(context);
resendFunc.startResend(context);
}
}
}
Expand Down
54 changes: 27 additions & 27 deletions app/src/main/java/com/qwe7002/telegram_sms/call_receiver.java
Original file line number Diff line number Diff line change
Expand Up @@ -13,11 +13,11 @@
import com.google.gson.Gson;
import com.qwe7002.telegram_sms.config.proxy;
import com.qwe7002.telegram_sms.data_structure.request_message;
import com.qwe7002.telegram_sms.static_class.log_func;
import com.qwe7002.telegram_sms.static_class.network_func;
import com.qwe7002.telegram_sms.static_class.other_func;
import com.qwe7002.telegram_sms.static_class.resend_func;
import com.qwe7002.telegram_sms.static_class.sms_func;
import com.qwe7002.telegram_sms.static_class.logFunc;
import com.qwe7002.telegram_sms.static_class.networkFunc;
import com.qwe7002.telegram_sms.static_class.otherFunc;
import com.qwe7002.telegram_sms.static_class.resendFunc;
import com.qwe7002.telegram_sms.static_class.smsFunc;
import com.qwe7002.telegram_sms.value.const_value;

import org.jetbrains.annotations.NotNull;
Expand All @@ -36,7 +36,7 @@

public class call_receiver extends BroadcastReceiver {
private static int slot;
private static String incoming_number;
private static String incomingNumber;

@Override
public void onReceive(Context context, @NotNull Intent intent) {
Expand All @@ -45,11 +45,11 @@ public void onReceive(Context context, @NotNull Intent intent) {
switch (Objects.requireNonNull(intent.getAction())) {
case "android.intent.action.PHONE_STATE":
if (intent.getStringExtra("incoming_number") != null) {
incoming_number = intent.getStringExtra("incoming_number");
incomingNumber = intent.getStringExtra("incoming_number");
}
TelephonyManager telephony = (TelephonyManager) context
.getSystemService(Context.TELEPHONY_SERVICE);
call_status_listener custom_phone_listener = new call_status_listener(context, slot, incoming_number);
callStatusListener custom_phone_listener = new callStatusListener(context, slot, incomingNumber);
assert telephony != null;
telephony.listen(custom_phone_listener, PhoneStateListener.LISTEN_CALL_STATE);
break;
Expand All @@ -60,17 +60,17 @@ public void onReceive(Context context, @NotNull Intent intent) {
}
}

static class call_status_listener extends PhoneStateListener {
static class callStatusListener extends PhoneStateListener {
private static int last_receive_status = TelephonyManager.CALL_STATE_IDLE;
private static String incoming_number;
private final Context context;
private final int slot;

call_status_listener(Context context, int slot, String incoming_number) {
callStatusListener(Context context, int slot, String incoming_number) {
super();
this.context = context;
this.slot = slot;
call_status_listener.incoming_number = incoming_number;
callStatusListener.incoming_number = incoming_number;
}

public void onCallStateChanged(int now_state, String now_incoming_number) {
Expand All @@ -81,42 +81,42 @@ public void onCallStateChanged(int now_state, String now_incoming_number) {
Log.i("call_status_listener", "Uninitialized, Phone receiver is deactivated.");
return;
}
String bot_token = sharedPreferences.getString("bot_token", "");
String chat_id = sharedPreferences.getString("chat_id", "");
String request_uri = network_func.get_url(bot_token, "sendMessage");
String botToken = sharedPreferences.getString("bot_token", "");
String chatId = sharedPreferences.getString("chat_id", "");
String requestUri = networkFunc.getUrl(botToken, "sendMessage");
final request_message request_body = new request_message();
request_body.chat_id = chat_id;
String dual_sim = other_func.get_dual_sim_card_display(context, slot, sharedPreferences.getBoolean("display_dual_sim_display_name", false));
request_body.text = "[" + dual_sim + context.getString(R.string.missed_call_head) + "]" + "\n" + context.getString(R.string.Incoming_number) + call_status_listener.incoming_number;
request_body.chat_id = chatId;
String dual_sim = otherFunc.get_dual_sim_card_display(context, slot, sharedPreferences.getBoolean("display_dual_sim_display_name", false));
request_body.text = "[" + dual_sim + context.getString(R.string.missed_call_head) + "]" + "\n" + context.getString(R.string.Incoming_number) + callStatusListener.incoming_number;
String request_body_raw = new Gson().toJson(request_body);
RequestBody body = RequestBody.create(request_body_raw, const_value.JSON);
OkHttpClient okhttp_client = network_func.get_okhttp_obj(sharedPreferences.getBoolean("doh_switch", true), Paper.book("system_config").read("proxy_config", new proxy()));
Request request = new Request.Builder().url(request_uri).method("POST", body).build();
OkHttpClient okhttp_client = networkFunc.get_okhttp_obj(sharedPreferences.getBoolean("doh_switch", true), Paper.book("system_config").read("proxy_config", new proxy()));
Request request = new Request.Builder().url(requestUri).method("POST", body).build();
Call call = okhttp_client.newCall(request);
final String error_head = "Send missed call error:";
call.enqueue(new Callback() {
@Override
public void onFailure(@NonNull Call call, @NonNull IOException e) {
e.printStackTrace();
log_func.write_log(context, error_head + e.getMessage());
sms_func.send_fallback_sms(context, request_body.text, other_func.get_sub_id(context, slot));
resend_func.add_resend_loop(context, request_body.text);
logFunc.writeLog(context, error_head + e.getMessage());
smsFunc.send_fallback_sms(context, request_body.text, otherFunc.getSubId(context, slot));
resendFunc.addResendLoop(context, request_body.text);
}

@Override
public void onResponse(@NonNull Call call, @NonNull Response response) throws IOException {
assert response.body() != null;
if (response.code() != 200) {
String error_message = error_head + response.code() + " " + Objects.requireNonNull(response.body()).string();
log_func.write_log(context, error_message);
resend_func.add_resend_loop(context, request_body.text);
logFunc.writeLog(context, error_message);
resendFunc.addResendLoop(context, request_body.text);
} else {
String result = Objects.requireNonNull(response.body()).string();
if (!other_func.isPhoneNumber(call_status_listener.incoming_number)) {
log_func.write_log(context, "[" + call_status_listener.incoming_number + "] Not a regular phone number.");
if (!otherFunc.isPhoneNumber(callStatusListener.incoming_number)) {
logFunc.writeLog(context, "[" + callStatusListener.incoming_number + "] Not a regular phone number.");
return;
}
other_func.add_message_list(other_func.get_message_id(result), call_status_listener.incoming_number, slot);
otherFunc.add_message_list(otherFunc.get_message_id(result), callStatusListener.incoming_number, slot);
}
}
});
Expand Down
Loading

0 comments on commit 4e88eaa

Please sign in to comment.