diff --git a/GTaskASyncTask.java b/GTaskASyncTask.java new file mode 100644 index 0000000..3453bc9 --- /dev/null +++ b/GTaskASyncTask.java @@ -0,0 +1,138 @@ + +/* + * Copyright (c) 2010-2011, The MiCode Open Source Community (www.micode.net) + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +// 定义包名,表示这个类属于net.micode.notes.remote包 +package net.micode.notes.remote; + +// 导入所需的Android类和接口 +import android.app.Notification; +import android.app.NotificationManager; +import android.app.PendingIntent; +import android.content.Context; +import android.content.Intent; +import android.os.AsyncTask; + +// 导入应用内部的资源和类 +import net.micode.notes.R; +import net.micode.notes.ui.NotesListActivity; +import net.micode.notes.ui.NotesPreferenceActivity; + +// 定义GTaskASyncTask类,它继承自AsyncTask +// 该类的参数分别为:参数类型Void,进度更新的参数类型String,返回结果的类型Integer +public class GTaskASyncTask extends AsyncTask { + + // 定义一个常量,用于通知的ID + private static int GTASK_SYNC_NOTIFICATION_ID = 5234235; + + // 定义一个接口,用于在任务完成时回调 + public interface OnCompleteListener { + void onComplete(); + } + + // 定义成员变量 + private Context mContext; // Android上下文 + private NotificationManager mNotifiManager; // 通知管理器 + private GTaskManager mTaskManager; // 任务管理器 + private OnCompleteListener mOnCompleteListener; // 完成时的回调接口 + + // 构造函数,接收上下文和完成时的回调接口 + public GTaskASyncTask(Context context, OnCompleteListener listener) { + mContext = context; + mOnCompleteListener = listener; + mNotifiManager = (NotificationManager) mContext + .getSystemService(Context.NOTIFICATION_SERVICE); // 获取通知管理器 + mTaskManager = GTaskManager.getInstance(); // 获取任务管理器的实例 + } + + // 取消同步的方法 + public void cancelSync() { + mTaskManager.cancelSync(); + } + + // 发布进度更新的方法 + public void publishProgess(String message) { + publishProgress(new String[] { message }); // 发布进度更新 + } + + // 显示通知的方法 + private void showNotification(int tickerId, String content) { + // 创建通知对象 + Notification notification = new Notification(R.drawable.notification, mContext + .getString(tickerId), System.currentTimeMillis()); + notification.defaults = Notification.DEFAULT_LIGHTS; // 设置默认的灯光 + notification.flags = Notification.FLAG_AUTO_CANCEL; // 设置通知自动取消 + + // 根据tickerId创建PendingIntent + PendingIntent pendingIntent; + if (tickerId != R.string.ticker_success) { + pendingIntent = PendingIntent.getActivity(mContext, 0, new Intent(mContext, + NotesPreferenceActivity.class), 0); + } else { + pendingIntent = PendingIntent.getActivity(mContext, 0, new Intent(mContext, + NotesListActivity.class), 0); + } + + // 设置通知的详细信息 + notification.setLatestEventInfo(mContext, mContext.getString(R.string.app_name), content, + pendingIntent); + // 发布通知 + mNotifiManager.notify(GTASK_SYNC_NOTIFICATION_ID, notification); + } + + // 后台任务执行的方法 + @Override + protected Integer doInBackground(Void... unused) { + publishProgess(mContext.getString(R.string.sync_progress_login, NotesPreferenceActivity + .getSyncAccountName(mContext))); // 发布进度更新 + return mTaskManager.sync(mContext, this); // 执行同步操作并返回结果 + } + + // 进度更新的方法 + @Override + protected void onProgressUpdate(String... progress) { + showNotification(R.string.ticker_syncing, progress[0]); // 显示进度通知 + if (mContext instanceof GTaskSyncService) { + ((GTaskSyncService) mContext).sendBroadcast(progress[0]); // 发送广播 + } + } + + // 任务执行完毕后的方法 + @Override + protected void onPostExecute(Integer result) { + // 根据结果展示不同的通知 + if (result == GTaskManager.STATE_SUCCESS) { + showNotification(R.string.ticker_success, mContext.getString( + R.string.success_sync_account, mTaskManager.getSyncAccount())); + NotesPreferenceActivity.setLastSyncTime(mContext, System.currentTimeMillis()); + } else if (result == GTaskManager.STATE_NETWORK_ERROR) { + showNotification(R.string.ticker_fail, mContext.getString(R.string.error_sync_network)); + } else if (result == GTaskManager.STATE_INTERNAL_ERROR) { + showNotification(R.string.ticker_fail, mContext.getString(R.string.error_sync_internal)); + } else if (result == GTaskManager.STATE_SYNC_CANCELLED) { + showNotification(R.string.ticker_cancel, mContext + .getString(R.string.error_sync_cancelled)); + } + // 如果设置了完成时的回调接口,则执行回调 + if (mOnCompleteListener != null) { + new Thread(new Runnable() { + public void run() { + mOnCompleteListener.onComplete(); + } + }).start(); + } + } +}