From e7186ac6324712fa73d0b0a27bc8a5a19e9733be Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=8C=83=E5=8F=8C?= <2963071932qq.com> Date: Sat, 28 Dec 2024 17:32:20 +0800 Subject: [PATCH] java --- src/net/micode/notes/data/Contact.java | 79 --- src/net/micode/notes/data/Notes.java | 341 ---------- .../notes/data/NotesDatabaseHelper.java | 230 ------- src/net/micode/notes/data/NotesProvider.java | 340 ---------- src/net/micode/notes/gtask/data/MetaData.java | 130 ---- src/net/micode/notes/gtask/data/Node.java | 215 ------ src/net/micode/notes/gtask/data/SqlData.java | 226 ------- src/net/micode/notes/gtask/data/SqlNote.java | 620 ------------------ src/net/micode/notes/gtask/data/Task.java | 387 ----------- src/net/micode/notes/gtask/data/TaskList.java | 448 ------------- .../exception/ActionFailureException.java | 41 -- .../exception/NetworkFailureException.java | 41 -- .../notes/gtask/remote/GTaskASyncTask.java | 155 ----- .../notes/gtask/remote/GTaskClient.java | 599 ----------------- .../notes/gtask/remote/GTaskManager.java | 617 ----------------- .../notes/gtask/remote/GTaskSyncService.java | 212 ------ 16 files changed, 4681 deletions(-) delete mode 100644 src/net/micode/notes/data/Contact.java delete mode 100644 src/net/micode/notes/data/Notes.java delete mode 100644 src/net/micode/notes/data/NotesDatabaseHelper.java delete mode 100644 src/net/micode/notes/data/NotesProvider.java delete mode 100644 src/net/micode/notes/gtask/data/MetaData.java delete mode 100644 src/net/micode/notes/gtask/data/Node.java delete mode 100644 src/net/micode/notes/gtask/data/SqlData.java delete mode 100644 src/net/micode/notes/gtask/data/SqlNote.java delete mode 100644 src/net/micode/notes/gtask/data/Task.java delete mode 100644 src/net/micode/notes/gtask/data/TaskList.java delete mode 100644 src/net/micode/notes/gtask/exception/ActionFailureException.java delete mode 100644 src/net/micode/notes/gtask/exception/NetworkFailureException.java delete mode 100644 src/net/micode/notes/gtask/remote/GTaskASyncTask.java delete mode 100644 src/net/micode/notes/gtask/remote/GTaskClient.java delete mode 100644 src/net/micode/notes/gtask/remote/GTaskManager.java delete mode 100644 src/net/micode/notes/gtask/remote/GTaskSyncService.java diff --git a/src/net/micode/notes/data/Contact.java b/src/net/micode/notes/data/Contact.java deleted file mode 100644 index d5b30be..0000000 --- a/src/net/micode/notes/data/Contact.java +++ /dev/null @@ -1,79 +0,0 @@ - - -// 定义一个Contact类，用于处理联系人相关信息 -package net.micode.notes.data; - -import android.content.Context; -import android.database.Cursor; -import android.provider.ContactsContract.CommonDataKinds.Phone; -import android.provider.ContactsContract.Data; -import android.telephony.PhoneNumberUtils; -import android.util.Log; - -import java.util.HashMap; - -public class Contact { - // 定义一个静态HashMap来缓存联系人信息，以提高查询效率. - private static HashMap sContactCache; - // 定义日志输出的标签 - private static final String TAG = "Contact"; - - // 定义查询联系人的SQL语句模板 - private static final String CALLER_ID_SELECTION = "PHONE_NUMBERS_EQUAL(" + Phone.NUMBER - + ",?) AND " + Data.MIMETYPE + "='" + Phone.CONTENT_ITEM_TYPE + "'" - + " AND " + Data.RAW_CONTACT_ID + " IN " - + "(SELECT raw_contact_id " - + " FROM phone_lookup" - + " WHERE min_match = '+')"; - - /** - * 根据电话号码获取联系人名称 - * - * @param context 上下文对象，用于访问内容提供者 - * @param phoneNumber 电话号码 - * @return 如果找到匹配的联系人，则返回联系人名称；否则返回null - */ - public static String getContact(Context context, String phoneNumber) { - // 检查缓存是否为空，如果为空则初始化 - if(sContactCache == null) { - sContactCache = new HashMap(); - } - - // 检查缓存中是否已经存在该电话号码对应的联系人名称 - if(sContactCache.containsKey(phoneNumber)) { - return sContactCache.get(phoneNumber); - } - - // 根据电话号码构建查询联系人的SQL语句 - String selection = CALLER_ID_SELECTION.replace("+", - PhoneNumberUtils.toCallerIDMinMatch(phoneNumber)); - // 执行查询 - Cursor cursor = context.getContentResolver().query( - Data.CONTENT_URI, - new String [] { Phone.DISPLAY_NAME }, - selection, - new String[] { phoneNumber }, - null); - - // 处理查询结果 - if (cursor != null && cursor.moveToFirst()) { - try { - // 获取联系人名称，并存入缓存中 - String name = cursor.getString(0); - sContactCache.put(phoneNumber, name); - return name; - } catch (IndexOutOfBoundsException e) { - // 日志输出异常信息 - Log.e(TAG, " Cursor get string error " + e.toString()); - return null; - } finally { - // 关闭游标 - cursor.close(); - } - } else { - // 如果没有找到匹配的联系人，输出日志信息并返回null - Log.d(TAG, "No contact matched with number:" + phoneNumber); - return null; - } - } -} diff --git a/src/net/micode/notes/data/Notes.java b/src/net/micode/notes/data/Notes.java deleted file mode 100644 index 63bba4a..0000000 --- a/src/net/micode/notes/data/Notes.java +++ /dev/null @@ -1,341 +0,0 @@ -package net.micode.notes.data; - -以下是为 `Notes.java` 文件生成的中文注释： - - ```java - /* - * Copyright (c) 2010-2011, The MiCode Open Source Community (www.micode.net) - * - * 版权所有，遵循 Apache License 2.0 许可证。 - * 您可以从 http://www.apache.org/licenses/LICENSE-2.0 获取许可证副本。 - */ - - package net.micode.notes.data; - -import android.net.Uri; - -/** - * Notes 类用于定义笔记和文件夹的相关常量、Uri 和接口。 - */ -public class Notes { - /** - * 内容提供者的权威名称。 - */ - public static final String AUTHORITY = "micode_notes"; - - /** - * 日志标签。 - */ - public static final String TAG = "Notes"; - - /** - * 笔记类型。 - */ - public static final int TYPE_NOTE = 0; - - /** - * 文件夹类型。 - */ - public static final int TYPE_FOLDER = 1; - - /** - * 系统类型。 - */ - public static final int TYPE_SYSTEM = 2; - - /** - * 系统文件夹的 ID。 - * {@link Notes#ID_ROOT_FOLDER } 是默认文件夹。 - * {@link Notes#ID_TEMPARAY_FOLDER } 是未归属文件夹的笔记。 - * {@link Notes#ID_CALL_RECORD_FOLDER} 是存储通话记录的文件夹。 - */ - public static final int ID_ROOT_FOLDER = 0; - public static final int ID_TEMPARAY_FOLDER = -1; - public static final int ID_CALL_RECORD_FOLDER = -2; - public static final int ID_TRASH_FOLER = -3; - - /** - * Intent 额外数据键值对。 - */ - public static final String INTENT_EXTRA_ALERT_DATE = "net.micode.notes.alert_date"; - public static final String INTENT_EXTRA_BACKGROUND_ID = "net.micode.notes.background_color_id"; - public static final String INTENT_EXTRA_WIDGET_ID = "net.micode.notes.widget_id"; - public static final String INTENT_EXTRA_WIDGET_TYPE = "net.micode.notes.widget_type"; - public static final String INTENT_EXTRA_FOLDER_ID = "net.micode.notes.folder_id"; - public static final String INTENT_EXTRA_CALL_DATE = "net.micode.notes.call_date"; - - /** - * 小部件类型。 - */ - public static final int TYPE_WIDGET_INVALIDE = -1; - public static final int TYPE_WIDGET_2X = 0; - public static final int TYPE_WIDGET_4X = 1; - - /** - * 数据常量类，包含笔记和通话记录的内容类型。 - */ - public static class DataConstants { - public static final String NOTE = TextNote.CONTENT_ITEM_TYPE; - public static final String CALL_NOTE = CallNote.CONTENT_ITEM_TYPE; - } - - /** - * 查询所有笔记和文件夹的 Uri。 - */ - public static final Uri CONTENT_NOTE_URI = Uri.parse("content://" + AUTHORITY + "/note"); - - /** - * 查询数据的 Uri。 - */ - public static final Uri CONTENT_DATA_URI = Uri.parse("content://" + AUTHORITY + "/data"); - - /** - * 笔记或文件夹的列名接口。 - */ - public interface NoteColumns { - /** - * 行的唯一 ID。 - *

类型: INTEGER (long)

- */ - public static final String ID = "_id"; - - /** - * 笔记或文件夹的父级 ID。 - *

类型: INTEGER (long)

- */ - public static final String PARENT_ID = "parent_id"; - - /** - * 创建日期。 - *

类型: INTEGER (long)

- */ - public static final String CREATED_DATE = "created_date"; - - /** - * 最后修改日期。 - *

类型: INTEGER (long)

- */ - public static final String MODIFIED_DATE = "modified_date"; - - /** - * 提醒日期。 - *

类型: INTEGER (long)

- */ - public static final String ALERTED_DATE = "alert_date"; - - /** - * 文件夹名称或笔记文本内容。 - *

类型: TEXT

- */ - public static final String SNIPPET = "snippet"; - - /** - * 笔记的小部件 ID。 - *

类型: INTEGER (long)

- */ - public static final String WIDGET_ID = "widget_id"; - - /** - * 笔记的小部件类型。 - *

类型: INTEGER (long)

- */ - public static final String WIDGET_TYPE = "widget_type"; - - /** - * 笔记的背景颜色 ID。 - *

类型: INTEGER (long)

- */ - public static final String BG_COLOR_ID = "bg_color_id"; - - /** - * 是否有附件。 - *

类型: INTEGER

- */ - public static final String HAS_ATTACHMENT = "has_attachment"; - - /** - * 文件夹中的笔记数量。 - *

类型: INTEGER (long)

- */ - public static final String NOTES_COUNT = "notes_count"; - - /** - * 文件类型：文件夹或笔记。 - *

类型: INTEGER

- */ - public static final String TYPE = "type"; - - /** - * 最后同步 ID。 - *

类型: INTEGER (long)

- */ - public static final String SYNC_ID = "sync_id"; - - /** - * 是否本地已修改。 - *

类型: INTEGER

- */ - public static final String LOCAL_MODIFIED = "local_modified"; - - /** - * 移动到临时文件夹之前的原始父级 ID。 - *

类型: INTEGER

- */ - public static final String ORIGIN_PARENT_ID = "origin_parent_id"; - - /** - * Google 任务 ID。 - *

类型: TEXT

- */ - public static final String GTASK_ID = "gtask_id"; - - /** - * 版本代码。 - *

类型: INTEGER (long)

- */ - public static final String VERSION = "version"; - } - - /** - * 数据列名接口。 - */ - public interface DataColumns { - /** - * 行的唯一 ID。 - *

类型: INTEGER (long)

- */ - public static final String ID = "_id"; - - /** - * 该项的 MIME 类型。 - *

类型: TEXT

- */ - public static final String MIME_TYPE = "mime_type"; - - /** - * 所属笔记的引用 ID。 - *

类型: INTEGER (long)

- */ - public static final String NOTE_ID = "note_id"; - - /** - * 创建日期。 - *

类型: INTEGER (long)

- */ - public static final String CREATED_DATE = "created_date"; - - /** - * 最后修改日期。 - *

类型: INTEGER (long)

- */ - public static final String MODIFIED_DATE = "modified_date"; - - /** - * 数据内容。 - *

类型: TEXT

- */ - public static final String CONTENT = "content"; - - /** - * 泛型数据列，用于整数类型。 - *

类型: INTEGER

- */ - public static final String DATA1 = "data1"; - - /** - * 泛型数据列，用于整数类型。 - *

类型: INTEGER

- */ - public static final String DATA2 = "data2"; - - /** - * 泛型数据列，用于文本类型。 - *

类型: TEXT

- */ - public static final String DATA3 = "data3"; - - /** - * 泛型数据列，用于文本类型。 - *

类型: TEXT

- */ - public static final String DATA4 = "data4"; - - /** - * 泛型数据列，用于文本类型。 - *

类型: TEXT

- */ - public static final String DATA5 = "data5"; - } - - /** - * 文本笔记类，实现 DataColumns 接口。 - */ - public static final class TextNote implements DataColumns { - /** - * 标识文本是否为检查列表模式。 - *

类型: Integer 1: 检查列表模式 0: 正常模式

- */ - public static final String MODE = DATA1; - - /** - * 检查列表模式标识。 - */ - public static final int MODE_CHECK_LIST = 1; - - /** - * 内容类型。 - */ - public static final String CONTENT_TYPE = "vnd.android.cursor.dir/text_note"; - - /** - * 内容项类型。 - */ - public static final String CONTENT_ITEM_TYPE = "vnd.android.cursor.item/text_note"; - - /** - * 内容 URI。 - */ - public static final Uri CONTENT_URI = Uri.parse("content://" + AUTHORITY + "/text_note"); - } - - /** - * 通话记录类，实现 DataColumns 接口。 - */ - public static final class CallNote implements DataColumns { - /** - * 通话日期。 - *

类型: INTEGER (long)

- */ - public static final String CALL_DATE = DATA1; - - /** - * 电话号码。 - *

类型: TEXT

- */ - public static final String PHONE_NUMBER = DATA3; - - /** - * 内容类型。 - */ - public static final String CONTENT_TYPE = "vnd.android.cursor.dir/call_note"; - - /** - * 内容项类型。 - */ - public static final String CONTENT_ITEM_TYPE = "vnd.android.cursor.item/call_note"; - - /** - * 内容 URI。 - */ - public static final Uri CONTENT_URI = Uri.parse("content://" + AUTHORITY + "/call_note"); - } -} -``` - - - ### 主要改动： - 1. **类和接口的注释**：为每个类和接口添加了简要说明。 - 2. **字段的注释**：为每个字段添加了详细的中文注释，解释其用途和数据类型。 - 3. **方法的注释**：为每个静态内部类的方法添加了注释。 - -这样可以更好地理解代码的功能和结构。 \ No newline at end of file diff --git a/src/net/micode/notes/data/NotesDatabaseHelper.java b/src/net/micode/notes/data/NotesDatabaseHelper.java deleted file mode 100644 index 6005219..0000000 --- a/src/net/micode/notes/data/NotesDatabaseHelper.java +++ /dev/null @@ -1,230 +0,0 @@ -package net.micode.notes.data; - -import javax.naming.Context; - -/** - * NotesDatabaseHelper 类用于管理笔记数据库的创建和升级。 - * 它继承自 SQLiteOpenHelper 并实现了 onCreate 和 onUpgrade 方法 - */ -public class NotesDatabaseHelper extends SQLiteOpenHelper { - - private static final String DB_NAME = "notes.db"; - private static final int DB_VERSION = 4; - private static NotesDatabaseHelper mInstance; - private static final String TAG = "NotesDatabaseHelper"; - - /** - * 构造函数，初始化数据库助手。 - * - * @param context 应用程序上下文 - */ - public NotesDatabaseHelper(Context context) { - super(context, DB_NAME, null, DB_VERSION); - } - - /** - * 创建笔记表。 - * - * @param db 数据库实例 - */ - public void createNoteTable(SQLiteDatabase db) { - db.execSQL(CREATE_NOTE_TABLE_SQL); - reCreateNoteTableTriggers(db); - createSystemFolder(db); - Log.d(TAG, "note table has been created"); - } - - /** - * 重新创建笔记表的触发器。 - * - * @param db 数据库实例 - */ - private void reCreateNoteTableTriggers(SQLiteDatabase db) { - // 删除旧的触发器 - db.execSQL("DROP TRIGGER IF EXISTS increase_folder_count_on_update"); - db.execSQL("DROP TRIGGER IF EXISTS decrease_folder_count_on_update"); - db.execSQL("DROP TRIGGER IF EXISTS decrease_folder_count_on_delete"); - db.execSQL("DROP TRIGGER IF EXISTS delete_data_on_delete"); - db.execSQL("DROP TRIGGER IF EXISTS increase_folder_count_on_insert"); - db.execSQL("DROP TRIGGER IF EXISTS folder_delete_notes_on_delete"); - db.execSQL("DROP TRIGGER IF EXISTS folder_move_notes_on_trash"); - - // 创建新的触发器 - db.execSQL(NOTE_INCREASE_FOLDER_COUNT_ON_UPDATE_TRIGGER); - db.execSQL(NOTE_DECREASE_FOLDER_COUNT_ON_UPDATE_TRIGGER); - db.execSQL(NOTE_DECREASE_FOLDER_COUNT_ON_DELETE_TRIGGER); - db.execSQL(NOTE_DELETE_DATA_ON_DELETE_TRIGGER); - db.execSQL(NOTE_INCREASE_FOLDER_COUNT_ON_INSERT_TRIGGER); - db.execSQL(FOLDER_DELETE_NOTES_ON_DELETE_TRIGGER); - db.execSQL(FOLDER_MOVE_NOTES_ON_TRASH_TRIGGER); - } - - /** - * 创建系统文件夹。 - * - * @param db 数据库实例 - */ - private void createSystemFolder(SQLiteDatabase db) { - ContentValues values = new ContentValues(); - - // 创建通话记录文件夹 - values.put(NoteColumns.ID, Notes.ID_CALL_RECORD_FOLDER); - values.put(NoteColumns.TYPE, Notes.TYPE_SYSTEM); - db.insert(TABLE.NOTE, null, values); - - // 创建根文件夹（默认文件夹） - values.clear(); - values.put(NoteColumns.ID, Notes.ID_ROOT_FOLDER); - values.put(NoteColumns.TYPE, Notes.TYPE_SYSTEM); - db.insert(TABLE.NOTE, null, values); - - // 创建临时文件夹（用于移动笔记） - values.clear(); - values.put(NoteColumns.ID, Notes.ID_TEMPARAY_FOLDER); - values.put(NoteColumns.TYPE, Notes.TYPE_SYSTEM); - db.insert(TABLE.NOTE, null, values); - - // 创建回收站文件夹 - values.clear(); - values.put(NoteColumns.ID, Notes.ID_TRASH_FOLER); - values.put(NoteColumns.TYPE, Notes.TYPE_SYSTEM); - db.insert(TABLE.NOTE, null, values); - } - - /** - * 创建数据表。 - * - * @param db 数据库实例 - */ - public void createDataTable(SQLiteDatabase db) { - db.execSQL(CREATE_DATA_TABLE_SQL); - reCreateDataTableTriggers(db); - db.execSQL(CREATE_DATA_NOTE_ID_INDEX_SQL); - Log.d(TAG, "data table has been created"); - } - - /** - * 重新创建数据表的触发器。 - * - * @param db 数据库实例 - */ - private void reCreateDataTableTriggers(SQLiteDatabase db) { - // 删除旧的触发器 - db.execSQL("DROP TRIGGER IF EXISTS update_note_content_on_insert"); - db.execSQL("DROP TRIGGER IF EXISTS update_note_content_on_update"); - db.execSQL("DROP TRIGGER IF EXISTS update_note_content_on_delete"); - - // 创建新的触发器 - db.execSQL(DATA_UPDATE_NOTE_CONTENT_ON_INSERT_TRIGGER); - db.execSQL(DATA_UPDATE_NOTE_CONTENT_ON_UPDATE_TRIGGER); - db.execSQL(DATA_UPDATE_NOTE_CONTENT_ON_DELETE_TRIGGER); - } - - /** - * 获取 NotesDatabaseHelper 的单例实例。 - * - * @param context 应用程序上下文 - * @return NotesDatabaseHelper 实例 - */ - static synchronized NotesDatabaseHelper getInstance(Context context) { - if (mInstance == null) { - mInstance = new NotesDatabaseHelper(context); - } - return mInstance; - } - - /** - * 在数据库首次创建时调用，创建必要的表和触发器。 - * - * @param db 数据库实例 - */ - @Override - public void onCreate(SQLiteDatabase db) { - createNoteTable(db); - createDataTable(db); - } - - /** - * 在数据库版本升级时调用，根据旧版本号执行相应的升级操作。 - * - * @param db 数据库实例 - * @param oldVersion 旧版本号 - * @param newVersion 新版本号 - */ - @Override - public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) { - boolean reCreateTriggers = false; - boolean skipV2 = false; - - if (oldVersion == 1) { - upgradeToV2(db); - skipV2 = true; // 此次升级包括从 v2 到 v3 的升级 - oldVersion++; - } - - if (oldVersion == 2 && !skipV2) { - upgradeToV3(db); - reCreateTriggers = true; - oldVersion++; - } - - if (oldVersion == 3) { - upgradeToV4(db); - oldVersion++; - } - - if (reCreateTriggers) { - reCreateNoteTableTriggers(db); - reCreateDataTableTriggers(db); - } - - if (oldVersion != newVersion) { - throw new IllegalStateException("升级笔记数据库到版本 " + newVersion + " 失败"); - } - } - - /** - * 升级数据库到版本 2。 - * - * @param db 数据库实例 - */ - private void upgradeToV2(SQLiteDatabase db) { - db.execSQL("DROP TABLE IF EXISTS " + TABLE.NOTE); - db.execSQL("DROP TABLE IF EXISTS " + TABLE.DATA); - createNoteTable(db); - createDataTable(db); - } - - /** - * 升级数据库到版本 3。 - * - * @param db 数据库实例 - */ - private void upgradeToV3(SQLiteDatabase db) { - // 删除未使用的触发器 - db.execSQL("DROP TRIGGER IF EXISTS update_note_modified_date_on_insert"); - db.execSQL("DROP TRIGGER IF EXISTS update_note_modified_date_on_delete"); - db.execSQL("DROP TRIGGER IF EXISTS update_note_modified_date_on_update"); - - // 添加 gtask_id 列 - db.execSQL("ALTER TABLE " + TABLE.NOTE + " ADD COLUMN " + NoteColumns.GTASK_ID - + " TEXT NOT NULL DEFAULT ''"); - - // 添加回收站系统文件夹 - ContentValues values = new ContentValues(); - values.put(NoteColumns.ID, Notes.ID_TRASH_FOLER); - values.put(NoteColumns.TYPE, Notes.TYPE_SYSTEM); - db.insert(TABLE.NOTE, null, values); - } - - /** - * 升级数据库到版本 4。 - * - * @param db 数据库实例 - */ - private void upgradeToV4(SQLiteDatabase db) { - db.execSQL("ALTER TABLE " + TABLE.NOTE + " ADD COLUMN " + NoteColumns.VERSION - + " INTEGER NOT NULL DEFAULT 0"); - } -} -``` diff --git a/src/net/micode/notes/data/NotesProvider.java b/src/net/micode/notes/data/NotesProvider.java deleted file mode 100644 index 0aaa191..0000000 --- a/src/net/micode/notes/data/NotesProvider.java +++ /dev/null @@ -1,340 +0,0 @@ -package net.micode.notes.data; - -import java.awt.*; - -/** - * NotesProvider 类用于管理笔记内容提供者，继承自 ContentProvider。 - * 它负责处理来自其他应用程序的对笔记数据库的访问请求 - */ -public class NotesProvider extends ContentProvider { - - /** - * UriMatcher 用于匹配传入的 URI，并根据不同的 URI 执行相应的操作。 - */ - private static final UriMatcher mMatcher; - - /** - * NotesDatabaseHelper 实例，用于与数据库进行交互。 - */ - private NotesDatabaseHelper mHelper; - - /** - * 日志标签，用于调试和日志记录。 - */ - private static final String TAG = "NotesProvider"; - - /** - * 定义不同类型的 URI 对应的代码值。 - */ - private static final int URI_NOTE = 1; - private static final int URI_NOTE_ITEM = 2; - private static final int URI_DATA = 3; - private static final int URI_DATA_ITEM = 4; - private static final int URI_SEARCH = 5; - private static final int URI_SEARCH_SUGGEST = 6; - - /** - * 静态代码块中初始化 UriMatcher，添加各种 URI 匹配规则。 - */ - static { - mMatcher = new UriMatcher(UriMatcher.NO_MATCH); - mMatcher.addURI(Notes.AUTHORITY, "note", URI_NOTE); - mMatcher.addURI(Notes.AUTHORITY, "note/#", URI_NOTE_ITEM); - mMatcher.addURI(Notes.AUTHORITY, "data", URI_DATA); - mMatcher.addURI(Notes.AUTHORITY, "data/#", URI_DATA_ITEM); - mMatcher.addURI(Notes.AUTHORITY, "search", URI_SEARCH); - mMatcher.addURI(Notes.AUTHORITY, SearchManager.SUGGEST_URI_PATH_QUERY, URI_SEARCH_SUGGEST); - mMatcher.addURI(Notes.AUTHORITY, SearchManager.SUGGEST_URI_PATH_QUERY + "/*", URI_SEARCH_SUGGEST); - } - - /** - * 搜索结果投影，定义了搜索结果返回的列及其别名。 - */ - private static final String NOTES_SEARCH_PROJECTION = NoteColumns.ID + "," - + NoteColumns.ID + " AS " + SearchManager.SUGGEST_COLUMN_INTENT_EXTRA_DATA + "," - + "TRIM(REPLACE(" + NoteColumns.SNIPPET + ", x'0A','')) AS " + SearchManager.SUGGEST_COLUMN_TEXT_1 + "," - + "TRIM(REPLACE(" + NoteColumns.SNIPPET + ", x'0A','')) AS " + SearchManager.SUGGEST_COLUMN_TEXT_2 + "," - + R.drawable.search_result + " AS " + SearchManager.SUGGEST_COLUMN_ICON_1 + "," - + "'" + Intent.ACTION_VIEW + "' AS " + SearchManager.SUGGEST_COLUMN_INTENT_ACTION + "," - + "'" + Notes.TextNote.CONTENT_TYPE + "' AS " + SearchManager.SUGGEST_COLUMN_INTENT_DATA; - - /** - * 搜索查询语句，用于从笔记表中检索包含特定关键字的笔记片段。 - */ - private static String NOTES_SNIPPET_SEARCH_QUERY = "SELECT " + NOTES_SEARCH_PROJECTION - + " FROM " + TABLE.NOTE - + " WHERE " + NoteColumns.SNIPPET + " LIKE ?" - + " AND " + NoteColumns.PARENT_ID + "<>" + Notes.ID_TRASH_FOLER - + " AND " + NoteColumns.TYPE + "=" + Notes.TYPE_NOTE; - - /** - * 在 ContentProvider 创建时调用，初始化 NotesDatabaseHelper 实例。 - * - * @return 返回 true 表示创建成功。 - */ - @Override - public boolean onCreate() { - mHelper = NotesDatabaseHelper.getInstance(getContext()); - return true; - } - - /** - * 处理查询请求，根据传入的 URI 返回相应的 Cursor。 - * - * @param uri 要查询的 URI。 - * @param projection 要查询的列。 - * @param selection 查询条件。 - * @param selectionArgs 查询条件参数。 - * @param sortOrder 排序顺序。 - * @return 返回查询结果的 Cursor。 - */ - @Override - public Cursor query(Uri uri, String[] projection, String selection, String[] selectionArgs, - String sortOrder) { - Cursor c = null; - SQLiteDatabase db = mHelper.getReadableDatabase(); - String id = null; - switch (mMatcher.match(uri)) { - case URI_NOTE: - c = db.query(TABLE.NOTE, projection, selection, selectionArgs, null, null, sortOrder); - break; - case URI_NOTE_ITEM: - id = uri.getPathSegments().get(1); - c = db.query(TABLE.NOTE, projection, NoteColumns.ID + "=" + id + parseSelection(selection), - selectionArgs, null, null, sortOrder); - break; - case URI_DATA: - c = db.query(TABLE.DATA, projection, selection, selectionArgs, null, null, sortOrder); - break; - case URI_DATA_ITEM: - id = uri.getPathSegments().get(1); - c = db.query(TABLE.DATA, projection, DataColumns.ID + "=" + id + parseSelection(selection), - selectionArgs, null, null, sortOrder); - break; - case URI_SEARCH: - case URI_SEARCH_SUGGEST: - if (sortOrder != null || projection != null) { - throw new IllegalArgumentException( - "do not specify sortOrder, selection, selectionArgs, or projection with this query"); - } - - String searchString = null; - if (mMatcher.match(uri) == URI_SEARCH_SUGGEST) { - if (uri.getPathSegments().size() > 1) { - searchString = uri.getPathSegments().get(1); - } - } else { - searchString = uri.getQueryParameter("pattern"); - } - - if (TextUtils.isEmpty(searchString)) { - return null; - } - - try { - searchString = String.format("%%%s%%", searchString); - c = db.rawQuery(NOTES_SNIPPET_SEARCH_QUERY, new String[]{searchString}); - } catch (IllegalStateException ex) { - Log.e(TAG, "got exception: " + ex.toString()); - } - break; - default: - throw new IllegalArgumentException("Unknown URI " + uri); - } - if (c != null) { - c.setNotificationUri(getContext().getContentResolver(), uri); - } - return c; - } - - /** - * 插入新数据到指定 URI 对应的表中。 - * - * @param uri 要插入的 URI。 - * @param values 要插入的数据。 - * @return 返回插入后的新 URI。 - */ - @Override - public Uri insert(Uri uri, ContentValues values) { - SQLiteDatabase db = mHelper.getWritableDatabase(); - long dataId = 0, noteId = 0, insertedId = 0; - switch (mMatcher.match(uri)) { - case URI_NOTE: - insertedId = noteId = db.insert(TABLE.NOTE, null, values); - break; - case URI_DATA: - if (values.containsKey(DataColumns.NOTE_ID)) { - noteId = values.getAsLong(DataColumns.NOTE_ID); - } else { - Log.d(TAG, "Wrong data format without note id:" + values.toString()); - } - insertedId = dataId = db.insert(TABLE.DATA, null, values); - break; - default: - throw new IllegalArgumentException("Unknown URI " + uri); - } - // Notify the note uri - if (noteId > 0) { - getContext().getContentResolver().notifyChange( - ContentUris.withAppendedId(Notes.CONTENT_NOTE_URI, noteId), null); - } - - // Notify the data uri - if (dataId > 0) { - getContext().getContentResolver().notifyChange( - ContentUris.withAppendedId(Notes.CONTENT_DATA_URI, dataId), null); - } - - return ContentUris.withAppendedId(uri, insertedId); - } - - /** - * 删除指定 URI 对应的数据。 - * - * @param uri 要删除的 URI。 - * @param selection 删除条件。 - * @param selectionArgs 删除条件参数。 - * @return 返回删除的行数。 - */ - @Override - public int delete(Uri uri, String selection, String[] selectionArgs) { - int count = 0; - String id = null; - SQLiteDatabase db = mHelper.getWritableDatabase(); - boolean deleteData = false; - switch (mMatcher.match(uri)) { - case URI_NOTE: - selection = "(" + selection + ") AND " + NoteColumns.ID + ">0 "; - count = db.delete(TABLE.NOTE, selection, selectionArgs); - break; - case URI_NOTE_ITEM: - id = uri.getPathSegments().get(1); - /** - * ID 小于等于 0 的是系统文件夹，不允许删除。 - */ - long noteId = Long.valueOf(id); - if (noteId <= 0) { - break; - } - count = db.delete(TABLE.NOTE, NoteColumns.ID + "=" + id + parseSelection(selection), selectionArgs); - break; - case URI_DATA: - count = db.delete(TABLE.DATA, selection, selectionArgs); - deleteData = true; - break; - case URI_DATA_ITEM: - id = uri.getPathSegments().get(1); - count = db.delete(TABLE.DATA, DataColumns.ID + "=" + id + parseSelection(selection), selectionArgs); - deleteData = true; - break; - default: - throw new IllegalArgumentException("Unknown URI " + uri); - } - if (count > 0) { - if (deleteData) { - getContext().getContentResolver().notifyChange(Notes.CONTENT_NOTE_URI, null); - } - getContext().getContentResolver().notifyChange(uri, null); - } - return count; - } - - /** - * 更新指定 URI 对应的数据。 - * - * @param uri 要更新的 URI。 - * @param values 更新的数据。 - * @param selection 更新条件。 - * @param selectionArgs 更新条件参数。 - * @return 返回更新的行数。 - */ - @Override - public int update(Uri uri, ContentValues values, String selection, String[] selectionArgs) { - int count = 0; - String id = null; - SQLiteDatabase db = mHelper.getWritableDatabase(); - boolean updateData = false; - switch (mMatcher.match(uri)) { - case URI_NOTE: - increaseNoteVersion(-1, selection, selectionArgs); - count = db.update(TABLE.NOTE, values, selection, selectionArgs); - break; - case URI_NOTE_ITEM: - id = uri.getPathSegments().get(1); - increaseNoteVersion(Long.valueOf(id), selection, selectionArgs); - count = db.update(TABLE.NOTE, values, NoteColumns.ID + "=" + id + parseSelection(selection), selectionArgs); - break; - case URI_DATA: - count = db.update(TABLE.DATA, values, selection, selectionArgs); - updateData = true; - break; - case URI_DATA_ITEM: - id = uri.getPathSegments().get(1); - count = db.update(TABLE.DATA, values, DataColumns.ID + "=" + id + parseSelection(selection), selectionArgs); - updateData = true; - break; - default: - throw new IllegalArgumentException("Unknown URI " + uri); - } - - if (count > 0) { - if (updateData) { - getContext().getContentResolver().notifyChange(Notes.CONTENT_NOTE_URI, null); - } - getContext().getContentResolver().notifyChange(uri, null); - } - return count; - } - - /** - * 解析并格式化查询条件。 - * - * @param selection 查询条件。 - * @return 返回格式化后的查询条件。 - */ - private String parseSelection(String selection) { - return (!TextUtils.isEmpty(selection) ? " AND (" + selection + ')' : ""); - } - - /** - * 增加笔记版本号。 - * - * @param id 笔记 ID。 - * @param selection 更新条件。 - * @param selectionArgs 更新条件参数。 - */ - private void increaseNoteVersion(long id, String selection, String[] selectionArgs) { - StringBuilder sql = new StringBuilder(120); - sql.append("UPDATE ").append(TABLE.NOTE).append(" SET ").append(NoteColumns.VERSION) - .append("=" + NoteColumns.VERSION + "+1 "); - - if (id > 0 || !TextUtils.isEmpty(selection)) { - sql.append(" WHERE "); - } - if (id > 0) { - sql.append(NoteColumns.ID + "=" + String.valueOf(id)); - } - if (!TextUtils.isEmpty(selection)) { - String selectString = id > 0 ? parseSelection(selection) : selection; - for (String args : selectionArgs) { - selectString = selectString.replaceFirst("\\?", args); - } - sql.append(selectString); - } - - mHelper.getWritableDatabase().execSQL(sql.toString()); - } - - /** - * 获取 MIME 类型，目前未实现。 - * - * @param uri 要获取 MIME 类型的 URI。 - * @return 返回 MIME 类型。 - */ - @Override - public String getType(Uri uri) { - // TODO Auto-generated method stub - return null; - } -} -``` diff --git a/src/net/micode/notes/gtask/data/MetaData.java b/src/net/micode/notes/gtask/data/MetaData.java deleted file mode 100644 index b7c36ab..0000000 --- a/src/net/micode/notes/gtask/data/MetaData.java +++ /dev/null @@ -1,130 +0,0 @@ -package net.micode.notes.gtask.data; - -```java - /* - * 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. - */ - - package net.micode.notes.gtask.data; - -import android.database.Cursor; -import android.util.Log; - -import net.micode.notes.tool.GTaskStringUtils; - -import org.json.JSONException; -import org.json.JSONObject; - -/** - * MetaData 类继承自 Task，用于处理与任务相关的元数据。 - * 主要功能包括设置和获取与任务关联的全局唯一标识符（GID）。 - */ -public class MetaData extends Task { - private final static String TAG = MetaData.class.getSimpleName(); - - /** - * 存储与任务关联的全局唯一标识符（GID）。 - */ - private String mRelatedGid = null; - - /** - * 设置任务的元数据信息，并将 GID 添加到元数据中。 - * - * @param gid 任务的全局唯一标识符（GID） - * @param metaInfo 包含任务元数据的 JSON 对象 - */ - public void setMeta(String gid, JSONObject metaInfo) { - try { - // 将 GID 添加到元数据中 - metaInfo.put(GTaskStringUtils.META_HEAD_GTASK_ID, gid); - } catch (JSONException e) { - Log.e(TAG, "failed to put related gid"); - } - setNotes(metaInfo.toString()); - setName(GTaskStringUtils.META_NOTE_NAME); - } - - /** - * 获取与任务关联的全局唯一标识符（GID）。 - * - * @return 返回任务的 GID - */ - public String getRelatedGid() { - return mRelatedGid; - } - - /** - * 判断是否有值得保存的笔记内容。 - * - * @return 如果有笔记内容则返回 true，否则返回 false - */ - @Override - public boolean isWorthSaving() { - return getNotes() != null; - } - - /** - * 通过远程 JSON 数据设置任务内容，并解析出 GID。 - * - * @param js 包含任务内容的 JSON 对象 - */ - @Override - public void setContentByRemoteJSON(JSONObject js) { - super.setContentByRemoteJSON(js); - if (getNotes() != null) { - try { - // 解析笔记内容中的元数据并提取 GID - JSONObject metaInfo = new JSONObject(getNotes().trim()); - mRelatedGid = metaInfo.getString(GTaskStringUtils.META_HEAD_GTASK_ID); - } catch (JSONException e) { - Log.w(TAG, "failed to get related gid"); - mRelatedGid = null; - } - } - } - - /** - * 本地 JSON 数据设置任务内容的方法不应被调用。 - * - * @param js 包含任务内容的 JSON 对象 - * @throws IllegalAccessError 抛出异常表示该方法不应被调用 - */ - @Override - public void setContentByLocalJSON(JSONObject js) { - throw new IllegalAccessError("MetaData:setContentByLocalJSON should not be called"); - } - - /** - * 从任务内容生成本地 JSON 数据的方法不应被调用。 - * - * @throws IllegalAccessError 抛出异常表示该方法不应被调用 - */ - @Override - public JSONObject getLocalJSONFromContent() { - throw new IllegalAccessError("MetaData:getLocalJSONFromContent should not be called"); - } - - /** - * 获取同步操作的方法不应被调用。 - * - * @param c 游标对象 - * @throws IllegalAccessError 抛出异常表示该方法不应被调用 - */ - @Override - public int getSyncAction(Cursor c) { - throw new IllegalAccessError("MetaData:getSyncAction should not be called"); - } -} -``` diff --git a/src/net/micode/notes/gtask/data/Node.java b/src/net/micode/notes/gtask/data/Node.java deleted file mode 100644 index f1cf338..0000000 --- a/src/net/micode/notes/gtask/data/Node.java +++ /dev/null @@ -1,215 +0,0 @@ -/* - * 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. - */ - -package net.micode.notes.gtask.data; - -import android.database.Cursor; - -import org.json.JSONObject; - -public abstract class Node { - -package net.micode.notes.gtask.data; - -import android.database.Cursor; - -import org.json.JSONObject; - - /** - * 表示任务节点的抽象类，用于同步和管理任务数据 - * 包含了与任务相关的属性和方法，支持本地和远程数据的同步操作。 - */ - public abstract class Node { - - /** - * 同步动作：无操作 - */ - public static final int SYNC_ACTION_NONE = 0; - - /** - * 同步动作：远程添加 - */ - public static final int SYNC_ACTION_ADD_REMOTE = 1; - - /** - * 同步动作：本地添加 - */ - public static final int SYNC_ACTION_ADD_LOCAL = 2; - - /** - * 同步动作：远程删除 - */ - public static final int SYNC_ACTION_DEL_REMOTE = 3; - - /** - * 同步动作：本地删除 - */ - public static final int SYNC_ACTION_DEL_LOCAL = 4; - - /** - * 同步动作：远程更新 - */ - public static final int SYNC_ACTION_UPDATE_REMOTE = 5; - - /** - * 同步动作：本地更新 - */ - public static final int SYNC_ACTION_UPDATE_LOCAL = 6; - - /** - * 同步动作：更新冲突 - */ - public static final int SYNC_ACTION_UPDATE_CONFLICT = 7; - - /** - * 同步动作：错误 - */ - public static final int SYNC_ACTION_ERROR = 8; - - private String mGid; // 任务的全局唯一标识符 - private String mName; // 任务名称 - private long mLastModified; // 最后修改时间 - private boolean mDeleted; // 是否已删除 - - /** - * 构造函数，初始化任务节点的基本属性。 - */ - public Node() { - mGid = null; - mName = ""; - mLastModified = 0; - mDeleted = false; - } - - /** - * 获取创建操作的 JSON 对象。 - * - * @param actionId 操作类型 ID - * @return 创建操作的 JSON 对象 - */ - public abstract JSONObject getCreateAction(int actionId); - - /** - * 获取更新操作的 JSON 对象。 - * - * @param actionId 操作类型 ID - * @return 更新操作的 JSON 对象 - */ - public abstract JSONObject getUpdateAction(int actionId); - - /** - * 根据远程 JSON 数据设置任务内容。 - * - * @param js 远程 JSON 数据 - */ - public abstract void setContentByRemoteJSON(JSONObject js); - - /** - * 根据本地 JSON 数据设置任务内容。 - * - * @param js 本地 JSON 数据 - */ - public abstract void setContentByLocalJSON(JSONObject js); - - /** - * 将任务内容转换为本地 JSON 对象。 - * - * @return 任务内容的本地 JSON 对象 - */ - public abstract JSONObject getLocalJSONFromContent(); - - /** - * 根据数据库游标获取同步操作类型。 - * - * @param c 数据库游标 - * @return 同步操作类型 - */ - public abstract int getSyncAction(Cursor c); - - /** - * 设置任务的全局唯一标识符。 - * - * @param gid 全局唯一标识符 - */ - public void setGid(String gid) { - this.mGid = gid; - } - - /** - * 设置任务名称。 - * - * @param name 任务名称 - */ - public void setName(String name) { - this.mName = name; - } - - /** - * 设置任务的最后修改时间。 - * - * @param lastModified 最后修改时间 - */ - public void setLastModified(long lastModified) { - this.mLastModified = lastModified; - } - - /** - * 设置任务是否已删除。 - * - * @param deleted 是否已删除 - */ - public void setDeleted(boolean deleted) { - this.mDeleted = deleted; - } - - /** - * 获取任务的全局唯一标识符。 - * - * @return 全局唯一标识符 - */ - public String getGid() { - return this.mGid; - } - - /** - * 获取任务名称。 - * - * @return 任务名称 - */ - public String getName() { - return this.mName; - } - - /** - * 获取任务的最后修改时间。 - * - * @return 最后修改时间 - */ - public long getLastModified() { - return this.mLastModified; - } - - /** - * 获取任务是否已删除。 - * - * @return 是否已删除 - */ - public boolean getDeleted() { - return this.mDeleted; - } - } - -} \ No newline at end of file diff --git a/src/net/micode/notes/gtask/data/SqlData.java b/src/net/micode/notes/gtask/data/SqlData.java deleted file mode 100644 index fde3d87..0000000 --- a/src/net/micode/notes/gtask/data/SqlData.java +++ /dev/null @@ -1,226 +0,0 @@ - package net.micode.notes.gtask.data; - -import android.content.ContentResolver; -import android.content.ContentUris; -import android.content.ContentValues; -import android.content.Context; -import android.database.Cursor; -import android.net.Uri; -import android.util.Log; - -import net.micode.notes.data.Notes; -import net.micode.notes.data.Notes.DataColumns; -import net.micode.notes.data.Notes.DataConstants; -import net.micode.notes.data.Notes.NoteColumns; -import net.micode.notes.gtask.exception.ActionFailureException; - -import org.json.JSONException; -import org.json.JSONObject; - -/** - * SqlData 类用于处理与数据库交互的任务数据。 - * 包含了从 JSON 对象加载数据、将数据保存到数据库以及获取和设置任务数据的方法。 - */ -public class SqlData { - private static final String TAG = SqlData.class.getSimpleName(); // 日志标签 - - private static final int INVALID_ID = -99999; // 无效的 ID，表示未初始化或无效的数据 - - /** - * 数据库查询投影，包含需要查询的列名 - */ - public static final String[] PROJECTION_DATA = new String[] { - DataColumns.ID, DataColumns.MIME_TYPE, DataColumns.CONTENT, DataColumns.DATA1, - DataColumns.DATA3 - }; - - /** - * 数据 ID 列索引 - */ - public static final int DATA_ID_COLUMN = 0; - - /** - * MIME 类型列索引 - */ - public static final int DATA_MIME_TYPE_COLUMN = 1; - - /** - * 内容列索引 - */ - public static final int DATA_CONTENT_COLUMN = 2; - - /** - * 数据1列索引 - */ - public static final int DATA_CONTENT_DATA_1_COLUMN = 3; - - /** - * 数据3列索引 - */ - public static final int DATA_CONTENT_DATA_3_COLUMN = 4; - - private ContentResolver mContentResolver; // 内容解析器，用于与内容提供者交互 - private boolean mIsCreate; // 标记是否为创建操作 - private long mDataId; // 数据 ID - private String mDataMimeType; // 数据 MIME 类型 - private String mDataContent; // 数据内容 - private long mDataContentData1; // 数据字段1 - private String mDataContentData3; // 数据字段3 - private ContentValues mDiffDataValues; // 用于存储要更新的字段值 - - /** - * 构造函数，初始化一个新的 SqlData 实例。 - * - * @param context 上下文对象 - */ - public SqlData(Context context) { - mContentResolver = context.getContentResolver(); - mIsCreate = true; - mDataId = INVALID_ID; - mDataMimeType = DataConstants.NOTE; - mDataContent = ""; - mDataContentData1 = 0; - mDataContentData3 = ""; - mDiffDataValues = new ContentValues(); - } - - /** - * 构造函数，从游标加载现有数据并初始化 SqlData 实例。 - * - * @param context 上下文对象 - * @param c 游标对象 - */ - public SqlData(Context context, Cursor c) { - mContentResolver = context.getContentResolver(); - mIsCreate = false; - loadFromCursor(c); - mDiffDataValues = new ContentValues(); - } - - /** - * 从游标中加载数据。 - * - * @param c 游标对象 - */ - private void loadFromCursor(Cursor c) { - mDataId = c.getLong(DATA_ID_COLUMN); - mDataMimeType = c.getString(DATA_MIME_TYPE_COLUMN); - mDataContent = c.getString(DATA_CONTENT_COLUMN); - mDataContentData1 = c.getLong(DATA_CONTENT_DATA_1_COLUMN); - mDataContentData3 = c.getString(DATA_CONTENT_DATA_3_COLUMN); - } - - /** - * 从 JSON 对象加载数据，并记录差异。 - * - * @param js JSON 对象 - * @throws JSONException 如果解析 JSON 失败 - */ - public void setContent(JSONObject js) throws JSONException { - long dataId = js.has(DataColumns.ID) ? js.getLong(DataColumns.ID) : INVALID_ID; - if (mIsCreate || mDataId != dataId) { - mDiffDataValues.put(DataColumns.ID, dataId); - } - mDataId = dataId; - - String dataMimeType = js.has(DataColumns.MIME_TYPE) ? js.getString(DataColumns.MIME_TYPE) - : DataConstants.NOTE; - if (mIsCreate || !mDataMimeType.equals(dataMimeType)) { - mDiffDataValues.put(DataColumns.MIME_TYPE, dataMimeType); - } - mDataMimeType = dataMimeType; - - String dataContent = js.has(DataColumns.CONTENT) ? js.getString(DataColumns.CONTENT) : ""; - if (mIsCreate || !mDataContent.equals(dataContent)) { - mDiffDataValues.put(DataColumns.CONTENT, dataContent); - } - mDataContent = dataContent; - - long dataContentData1 = js.has(DataColumns.DATA1) ? js.getLong(DataColumns.DATA1) : 0; - if (mIsCreate || mDataContentData1 != dataContentData1) { - mDiffDataValues.put(DataColumns.DATA1, dataContentData1); - } - mDataContentData1 = dataContentData1; - - String dataContentData3 = js.has(DataColumns.DATA3) ? js.getString(DataColumns.DATA3) : ""; - if (mIsCreate || !mDataContentData3.equals(dataContentData3)) { - mDiffDataValues.put(DataColumns.DATA3, dataContentData3); - } - mDataContentData3 = dataContentData3; - } - - /** - * 将当前数据转换为 JSON 对象。 - * - * @return JSON 对象 - * @throws JSONException 如果生成 JSON 失败 - */ - public JSONObject getContent() throws JSONException { - if (mIsCreate) { - Log.e(TAG, "似乎我们还没有在数据库中创建此数据"); - return null; - } - JSONObject js = new JSONObject(); - js.put(DataColumns.ID, mDataId); - js.put(DataColumns.MIME_TYPE, mDataMimeType); - js.put(DataColumns.CONTENT, mDataContent); - js.put(DataColumns.DATA1, mDataContentData1); - js.put(DataColumns.DATA3, mDataContentData3); - return js; - } - - /** - * 将数据提交到数据库。 - * - * @param noteId 笔记 ID - * @param validateVersion 是否验证版本号 - * @param version 版本号 - */ - public void commit(long noteId, boolean validateVersion, long version) { - if (mIsCreate) { - if (mDataId == INVALID_ID && mDiffDataValues.containsKey(DataColumns.ID)) { - mDiffDataValues.remove(DataColumns.ID); - } - - mDiffDataValues.put(DataColumns.NOTE_ID, noteId); - Uri uri = mContentResolver.insert(Notes.CONTENT_DATA_URI, mDiffDataValues); - try { - mDataId = Long.valueOf(uri.getPathSegments().get(1)); - } catch (NumberFormatException e) { - Log.e(TAG, "获取笔记 ID 错误：" + e.toString()); - throw new ActionFailureException("创建笔记失败"); - } - } else { - if (mDiffDataValues.size() > 0) { - int result = 0; - if (!validateVersion) { - result = mContentResolver.update(ContentUris.withAppendedId( - Notes.CONTENT_DATA_URI, mDataId), mDiffDataValues, null, null); - } else { - result = mContentResolver.update(ContentUris.withAppendedId( - Notes.CONTENT_DATA_URI, mDataId), mDiffDataValues, - " ? in (SELECT " + NoteColumns.ID + " FROM " + Notes.TABLE_NAME - + " WHERE " + NoteColumns.VERSION + "=?)", new String[] { - String.valueOf(noteId), String.valueOf(version) - }); - } - if (result == 0) { - Log.w(TAG, "没有更新。可能是用户在同步时修改了笔记"); - } - } - } - - mDiffDataValues.clear(); - mIsCreate = false; - } - - /** - * 获取数据 ID。 - * - * @return 数据 ID - */ - public long getId() { - return mDataId; - } -} - diff --git a/src/net/micode/notes/gtask/data/SqlNote.java b/src/net/micode/notes/gtask/data/SqlNote.java deleted file mode 100644 index d7f8ece..0000000 --- a/src/net/micode/notes/gtask/data/SqlNote.java +++ /dev/null @@ -1,620 +0,0 @@ -import net.micode.notes.gtask.data.SqlData; -import net.micode.notes.gtask.exception.ActionFailureException; -import net.micode.notes.tool.GTaskStringUtils; -import net.micode.notes.tool.ResourceParser; - -import javax.naming.Context; -import java.awt.*; -import java.util.ArrayList; /** - * SqlNote 类用于表示和操作笔记对象，包括创建、更新和查询笔记数据。 - */ -public class SqlNote { - - /** - * 日志标签，用于调试和日志记录。 - */ - private static final String TAG = SqlNote.class.getSimpleName(); - - /** - * 无效 ID 的常量值。 - */ - private static final int INVALID_ID = -99999; - - /** - * 笔记的投影字段数组，定义了从数据库中查询笔记时需要的列。 - */ - public static final String[] PROJECTION_NOTE = new String[]{ - NoteColumns.ID, NoteColumns.ALERTED_DATE, NoteColumns.BG_COLOR_ID, - NoteColumns.CREATED_DATE, NoteColumns.HAS_ATTACHMENT, NoteColumns.MODIFIED_DATE, - NoteColumns.NOTES_COUNT, NoteColumns.PARENT_ID, NoteColumns.SNIPPET, NoteColumns.TYPE, - NoteColumns.WIDGET_ID, NoteColumns.WIDGET_TYPE, NoteColumns.SYNC_ID, - NoteColumns.LOCAL_MODIFIED, NoteColumns.ORIGIN_PARENT_ID, NoteColumns.GTASK_ID, - NoteColumns.VERSION - }; - - /** - * 定义投影字段数组中各列的索引位置。 - */ - public static final int ID_COLUMN = 0; - public static final int ALERTED_DATE_COLUMN = 1; - public static final int BG_COLOR_ID_COLUMN = 2; - public static final int CREATED_DATE_COLUMN = 3; - public static final int HAS_ATTACHMENT_COLUMN = 4; - public static final int MODIFIED_DATE_COLUMN = 5; - public static final int NOTES_COUNT_COLUMN = 6; - public static final int PARENT_ID_COLUMN = 7; - public static final int SNIPPET_COLUMN = 8; - public static final int TYPE_COLUMN = 9; - public static final int WIDGET_ID_COLUMN = 10; - public static final int WIDGET_TYPE_COLUMN = 11; - public static final int SYNC_ID_COLUMN = 12; - public static final int LOCAL_MODIFIED_COLUMN = 13; - public static final int ORIGIN_PARENT_ID_COLUMN = 14; - public static final int GTASK_ID_COLUMN = 15; - public static final int VERSION_COLUMN = 16; - - /** - * 上下文对象，用于访问应用程序资源。 - */ - private Context mContext; - - /** - * 内容解析器，用于与内容提供者进行交互。 - */ - private ContentResolver mContentResolver; - - /** - * 标记是否是新创建的笔记。 - */ - private boolean mIsCreate; - - /** - * 笔记的唯一标识符。 - */ - private long mId; - - /** - * 提醒日期。 - */ - private long mAlertDate; - - /** - * 背景颜色 ID。 - */ - private int mBgColorId; - - /** - * 创建日期。 - */ - private long mCreatedDate; - - /** - * 是否包含附件。 - */ - private int mHasAttachment; - - /** - * 修改日期。 - */ - private long mModifiedDate; - - /** - * 父级笔记 ID。 - */ - private long mParentId; - - /** - * 笔记片段。 - */ - private String mSnippet; - - /** - * 笔记类型。 - */ - private int mType; - - /** - * 小部件 ID。 - */ - private int mWidgetId; - - /** - * 小部件类型。 - */ - private int mWidgetType; - - /** - * 原始父级笔记 ID。 - */ - private long mOriginParent; - - /** - * 笔记版本号。 - */ - private long mVersion; - - /** - * 存储差异笔记值的 ContentValues 对象。 - */ - private ContentValues mDiffNoteValues; - - /** - * 存储笔记数据的列表。 - */ - private ArrayList mDataList; - - /** - * 构造函数，用于创建新的 SqlNote 实例。 - * - * @param context 应用程序上下文。 - */ - public SqlNote(Context context) { - mContext = context; - mContentResolver = context.getContentResolver(); - mIsCreate = true; - mId = INVALID_ID; - mAlertDate = 0; - mBgColorId = ResourceParser.getDefaultBgId(context); - mCreatedDate = System.currentTimeMillis(); - mHasAttachment = 0; - mModifiedDate = System.currentTimeMillis(); - mParentId = 0; - mSnippet = ""; - mType = Notes.TYPE_NOTE; - mWidgetId = AppWidgetManager.INVALID_APPWIDGET_ID; - mWidgetType = Notes.TYPE_WIDGET_INVALIDE; - mOriginParent = 0; - mVersion = 0; - mDiffNoteValues = new ContentValues(); - mDataList = new ArrayList(); - } - - /** - * 构造函数，用于从游标加载现有笔记数据。 - * - * @param context 应用程序上下文。 - * @param c 包含笔记数据的游标。 - */ - public SqlNote(Context context, Cursor c) { - mContext = context; - mContentResolver = context.getContentResolver(); - mIsCreate = false; - loadFromCursor(c); - mDataList = new ArrayList(); - if (mType == Notes.TYPE_NOTE) - loadDataContent(); - mDiffNoteValues = new ContentValues(); - } - - /** - * 构造函数，用于通过笔记 ID 加载现有笔记数据。 - * - * @param context 应用程序上下文。 - * @param id 笔记的唯一标识符。 - */ - public SqlNote(Context context, long id) { - mContext = context; - mContentResolver = context.getContentResolver(); - mIsCreate = false; - loadFromCursor(id); - mDataList = new ArrayList(); - if (mType == Notes.TYPE_NOTE) - loadDataContent(); - mDiffNoteValues = new ContentValues(); - } - - /** - * 通过笔记 ID 从内容提供者加载笔记数据。 - * - * @param id 笔记的唯一标识符。 - */ - private void loadFromCursor(long id) { - Cursor c = null; - try { - c = mContentResolver.query(Notes.CONTENT_NOTE_URI, PROJECTION_NOTE, "(_id=?)", - new String[]{String.valueOf(id)}, null); - if (c != null) { - c.moveToNext(); - loadFromCursor(c); - } else { - Log.w(TAG, "loadFromCursor: cursor = null"); - } - } finally { - if (c != null) - c.close(); - } - } - - /** - * 从游标加载笔记数据。 - * - * @param c 包含笔记数据的游标。 - */ - private void loadFromCursor(Cursor c) { - mId = c.getLong(ID_COLUMN); - mAlertDate = c.getLong(ALERTED_DATE_COLUMN); - mBgColorId = c.getInt(BG_COLOR_ID_COLUMN); - mCreatedDate = c.getLong(CREATED_DATE_COLUMN); - mHasAttachment = c.getInt(HAS_ATTACHMENT_COLUMN); - mModifiedDate = c.getLong(MODIFIED_DATE_COLUMN); - mParentId = c.getLong(PARENT_ID_COLUMN); - mSnippet = c.getString(SNIPPET_COLUMN); - mType = c.getInt(TYPE_COLUMN); - mWidgetId = c.getInt(WIDGET_ID_COLUMN); - mWidgetType = c.getInt(WIDGET_TYPE_COLUMN); - mVersion = c.getLong(VERSION_COLUMN); - } - - /** - * 加载笔记的内容数据。 - */ - private void loadDataContent() { - Cursor c = null; - mDataList.clear(); - try { - c = mContentResolver.query(Notes.CONTENT_DATA_URI, SqlData.PROJECTION_DATA, - "(note_id=?)", new String[]{String.valueOf(mId)}, null); - if (c != null) { - if (c.getCount() == 0) { - Log.w(TAG, "it seems that the note has not data"); - return; - } - while (c.moveToNext()) { - SqlData data = new SqlData(mContext, c); - mDataList.add(data); - } - } else { - Log.w(TAG, "loadDataContent: cursor = null"); - } - } finally { - if (c != null) - c.close(); - } - } - - /** - * 设置笔记内容，从 JSON 对象中解析并更新笔记属性。 - * - * @param js 包含笔记内容的 JSON 对象。 - * @return 返回设置是否成功。 - */ - public boolean setContent(JSONObject js) { - try { - JSONObject note = js.getJSONObject(GTaskStringUtils.META_HEAD_NOTE); - if (note.getInt(NoteColumns.TYPE) == Notes.TYPE_SYSTEM) { - Log.w(TAG, "cannot set system folder"); - } else if (note.getInt(NoteColumns.TYPE) == Notes.TYPE_FOLDER) { - // 对于文件夹，我们只能更新片段和类型 - String snippet = note.has(NoteColumns.SNIPPET) ? note.getString(NoteColumns.SNIPPET) : ""; - if (mIsCreate || !mSnippet.equals(snippet)) { - mDiffNoteValues.put(NoteColumns.SNIPPET, snippet); - } - mSnippet = snippet; - - int type = note.has(NoteColumns.TYPE) ? note.getInt(NoteColumns.TYPE) : Notes.TYPE_NOTE; - if (mIsCreate || mType != type) { - mDiffNoteValues.put(NoteColumns.TYPE, type); - } - mType = type; - } else if (note.getInt(NoteColumns.TYPE) == Notes.TYPE_NOTE) { - JSONArray dataArray = js.getJSONArray(GTaskStringUtils.META_HEAD_DATA); - long id = note.has(NoteColumns.ID) ? note.getLong(NoteColumns.ID) : INVALID_ID; - if (mIsCreate || mId != id) { - mDiffNoteValues.put(NoteColumns.ID, id); - } - mId = id; - - long alertDate = note.has(NoteColumns.ALERTED_DATE) ? note.getLong(NoteColumns.ALERTED_DATE) : 0; - if (mIsCreate || mAlertDate != alertDate) { - mDiffNoteValues.put(NoteColumns.ALERTED_DATE, alertDate); - } - mAlertDate = alertDate; - - int bgColorId = note.has(NoteColumns.BG_COLOR_ID) ? note.getInt(NoteColumns.BG_COLOR_ID) : ResourceParser.getDefaultBgId(mContext); - if (mIsCreate || mBgColorId != bgColorId) { - mDiffNoteValues.put(NoteColumns.BG_COLOR_ID, bgColorId); - } - mBgColorId = bgColorId; - - long createDate = note.has(NoteColumns.CREATED_DATE) ? note.getLong(NoteColumns.CREATED_DATE) : System.currentTimeMillis(); - if (mIsCreate || mCreatedDate != createDate) { - mDiffNoteValues.put(NoteColumns.CREATED_DATE, createDate); - } - mCreatedDate = createDate; - - int hasAttachment = note.has(NoteColumns.HAS_ATTACHMENT) ? note.getInt(NoteColumns.HAS_ATTACHMENT) : 0; - if (mIsCreate || mHasAttachment != hasAttachment) { - mDiffNoteValues.put(NoteColumns.HAS_ATTACHMENT, hasAttachment); - } - mHasAttachment = hasAttachment; - - long modifiedDate = note.has(NoteColumns.MODIFIED_DATE) ? note.getLong(NoteColumns.MODIFIED_DATE) : System.currentTimeMillis(); - if (mIsCreate || mModifiedDate != modifiedDate) { - mDiffNoteValues.put(NoteColumns.MODIFIED_DATE, modifiedDate); - } - mModifiedDate = modifiedDate; - - long parentId = note.has(NoteColumns.PARENT_ID) ? note.getLong(NoteColumns.PARENT_ID) : 0; - if (mIsCreate || mParentId != parentId) { - mDiffNoteValues.put(NoteColumns.PARENT_ID, parentId); - } - mParentId = parentId; - - String snippet = note.has(NoteColumns.SNIPPET) ? note.getString(NoteColumns.SNIPPET) : ""; - if (mIsCreate || !mSnippet.equals(snippet)) { - mDiffNoteValues.put(NoteColumns.SNIPPET, snippet); - } - mSnippet = snippet; - - int type = note.has(NoteColumns.TYPE) ? note.getInt(NoteColumns.TYPE) : Notes.TYPE_NOTE; - if (mIsCreate || mType != type) { - mDiffNoteValues.put(NoteColumns.TYPE, type); - } - mType = type; - - int widgetId = note.has(NoteColumns.WIDGET_ID) ? note.getInt(NoteColumns.WIDGET_ID) : AppWidgetManager.INVALID_APPWIDGET_ID; - if (mIsCreate || mWidgetId != widgetId) { - mDiffNoteValues.put(NoteColumns.WIDGET_ID, widgetId); - } - mWidgetId = widgetId; - - int widgetType = note.has(NoteColumns.WIDGET_TYPE) ? note.getInt(NoteColumns.WIDGET_TYPE) : Notes.TYPE_WIDGET_INVALIDE; - if (mIsCreate || mWidgetType != widgetType) { - mDiffNoteValues.put(NoteColumns.WIDGET_TYPE, widgetType); - } - mWidgetType = widgetType; - - long originParent = note.has(NoteColumns.ORIGIN_PARENT_ID) ? note.getLong(NoteColumns.ORIGIN_PARENT_ID) : 0; - if (mIsCreate || mOriginParent != originParent) { - mDiffNoteValues.put(NoteColumns.ORIGIN_PARENT_ID, originParent); - } - mOriginParent = originParent; - - for (int i = 0; i < dataArray.length(); i++) { - JSONObject data = dataArray.getJSONObject(i); - SqlData sqlData = null; - if (data.has(DataColumns.ID)) { - long dataId = data.getLong(DataColumns.ID); - for (SqlData temp : mDataList) { - if (dataId == temp.getId()) { - sqlData = temp; - } - } - } - - if (sqlData == null) { - sqlData = new SqlData(mContext); - mDataList.add(sqlData); - } - - sqlData.setContent(data); - } - } - } catch (JSONException e) { - Log.e(TAG, e.toString()); - e.printStackTrace(); - return false; - } - return true; - } - - /** - * 获取笔记内容，将笔记属性转换为 JSON 对象。 - * - * @return 返回包含笔记内容的 JSON 对象。 - */ - public JSONObject getContent() { - try { - JSONObject js = new JSONObject(); - - if (mIsCreate) { - Log.e(TAG, "it seems that we haven't created this in database yet"); - return null; - } - - JSONObject note = new JSONObject(); - if (mType == Notes.TYPE_NOTE) { - note.put(NoteColumns.ID, mId); - note.put(NoteColumns.ALERTED_DATE, mAlertDate); - note.put(NoteColumns.BG_COLOR_ID, mBgColorId); - note.put(NoteColumns.CREATED_DATE, mCreatedDate); - note.put(NoteColumns.HAS_ATTACHMENT, mHasAttachment); - note.put(NoteColumns.MODIFIED_DATE, mModifiedDate); - note.put(NoteColumns.PARENT_ID, mParentId); - note.put(NoteColumns.SNIPPET, mSnippet); - note.put(NoteColumns.TYPE, mType); - note.put(NoteColumns.WIDGET_ID, mWidgetId); - note.put(NoteColumns.WIDGET_TYPE, mWidgetType); - note.put(NoteColumns.ORIGIN_PARENT_ID, mOriginParent); - js.put(GTaskStringUtils.META_HEAD_NOTE, note); - - JSONArray dataArray = new JSONArray(); - for (SqlData sqlData : mDataList) { - JSONObject data = sqlData.getContent(); - if (data != null) { - dataArray.put(data); - } - } - js.put(GTaskStringUtils.META_HEAD_DATA, dataArray); - } else if (mType == Notes.TYPE_FOLDER || mType == Notes.TYPE_SYSTEM) { - note.put(NoteColumns.ID, mId); - note.put(NoteColumns.TYPE, mType); - note.put(NoteColumns.SNIPPET, mSnippet); - js.put(GTaskStringUtils.META_HEAD_NOTE, note); - } - - return js; - } catch (JSONException e) { - Log.e(TAG, e.toString()); - e.printStackTrace(); - } - return null; - } - - /** - * 设置笔记的父级 ID。 - * - * @param id 父级笔记的唯一标识符。 - */ - public void setParentId(long id) { - mParentId = id; - mDiffNoteValues.put(NoteColumns.PARENT_ID, id); - } - - /** - * 设置笔记的 GTask ID。 - * - * @param gid GTask ID。 - */ - public void setGtaskId(String gid) { - mDiffNoteValues.put(NoteColumns.GTASK_ID, gid); - } - - /** - * 设置笔记的同步 ID。 - * - * @param syncId 同步 ID。 - */ - public void setSyncId(long syncId) { - mDiffNoteValues.put(NoteColumns.SYNC_ID, syncId); - } - - /** - * 重置本地修改标记。 - */ - public void resetLocalModified() { - mDiffNoteValues.put(NoteColumns.LOCAL_MODIFIED, 0); - } - - /** - * 获取笔记的唯一标识符。 - * - * @return 返回笔记的唯一标识符。 - */ - public long getId() { - return mId; - } - - /** - * 获取笔记的父级 ID。 - * - * @return 返回父级笔记的唯一标识符。 - */ - public long getParentId() { - return mParentId; - } - - /** - * 获取笔记片段。 - * - * @return 返回笔记片段。 - */ - public String getSnippet() { - return mSnippet; - } - - /** - * 检查笔记是否为普通笔记类型。 - * - * @return 如果是普通笔记类型返回 true，否则返回 false。 - */ - public boolean isNoteType() { - return mType == Notes.TYPE_NOTE; - } -/** - * 提交笔记更改到内容提供者。 - * - * @param validateVersion 是否验证版本号。 - */ -public void commit(boolean validateVersion) { - if (mIsCreate) { - // 如果是新创建的笔记，插入数据并获取生成的 ID - if (mId == INVALID_ID && mDiffNoteValues.containsKey(NoteColumns.ID)) { - mDiffNoteValues.remove(NoteColumns.ID); - } - - Uri uri = mContentResolver.insert(Notes.CONTENT_NOTE_URI, mDiffNoteValues); - try { - mId = Long.valueOf(uri.getPathSegments().get(1)); - } catch (NumberFormatException e) { - Log.e(TAG, "获取笔记 ID 错误: " + e.toString()); - throw new ActionFailureException("创建笔记失败"); - } - if (mId == 0) { - throw new IllegalStateException("创建线程 ID 失败"); - } - - if (mType == Notes.TYPE_NOTE) { - for (SqlData sqlData : mDataList) { - sqlData.commit(mId, false, -1); - } - } - } else { - // 检查笔记 ID 是否有效 - if (mId <= 0 && mId != Notes.ID_ROOT_FOLDER && mId != Notes.ID_CALL_RECORD_FOLDER) { - Log.e(TAG, "不存在此笔记"); - throw new IllegalStateException("尝试使用无效 ID 更新笔记"); - } - - // 如果有差异值需要更新 - if (mDiffNoteValues.size() > 0) { - mVersion++; - int result = 0; - if (!validateVersion) { - // 不验证版本号时直接更新笔记 - result = mContentResolver.update(Notes.CONTENT_NOTE_URI, mDiffNoteValues, - "(" + NoteColumns.ID + "=?)", - new String[]{String.valueOf(mId)}); - } else { - // 验证版本号时更新笔记 - result = mContentResolver.update(Notes.CONTENT_NOTE_URI, mDiffNoteValues, - "(" + NoteColumns.ID + "=?) AND (" + NoteColumns.VERSION + "<=?)", - new String[]{String.valueOf(mId), String.valueOf(mVersion)}); - } - - if (result == 0) { - Log.w(TAG, "没有进行任何更新。可能是用户在同步时修改了笔记"); - } - } - - // 如果是普通笔记类型，提交笔记内容数据 - if (mType == Notes.TYPE_NOTE) { - for (SqlData sqlData : mDataList) { - sqlData.commit(mId, validateVersion, mVersion); - } - } - } - - // 刷新本地信息 - loadFromCursor(mId); - if (mType == Notes.TYPE_NOTE) - loadDataContent(); - - // 清空差异值，并标记为已创建 - mDiffNoteValues.clear(); - mIsCreate = false; -} -} - - 注释解释 - -1. 检查笔记 ID 是否有效： - - 如果笔记 ID 小于等于 0 且不是根文件夹或通话记录文件夹，则抛出异常，提示尝试使用无效 ID 更新笔记。 - -2. 更新笔记数据： - - 如果 `mDiffNoteValues` 中有需要更新的数据，则增加版本号 `mVersion`。 - - 根据是否验证版本号，选择不同的更新条件： - - 不验证版本号时，直接根据笔记 ID 更新。 - - 验证版本号时，确保笔记版本号小于等于当前版本号。 - - 记录更新结果，如果没有任何更新，日志警告可能用户在同步时修改了笔记。 - -3. 提交笔记内容数据： - - 如果是普通笔记类型（`Notes.TYPE_NOTE`），则遍历 `mDataList` 并提交每个 `SqlData` 的内容。 - -4. 刷新本地信息： - - 通过 `loadFromCursor` 方法重新加载笔记数据。 - - 如果是普通笔记类型，加载笔记的内容数据。 - -5. 清理和标记： - - 清空 `mDiffNoteValues`，防止重复提交。 - - 将 `mIsCreate` 标记为 `false`，表示笔记已经创建或更新完成。 \ No newline at end of file diff --git a/src/net/micode/notes/gtask/data/Task.java b/src/net/micode/notes/gtask/data/Task.java deleted file mode 100644 index d09bc02..0000000 --- a/src/net/micode/notes/gtask/data/Task.java +++ /dev/null @@ -1,387 +0,0 @@ -package net.micode.notes.gtask.data; - -// Task类继承自Node类，用于表示一个任务对象 -public class Task extends Node { - // 日志标签，用于标识日志信息来源 - private static final String TAG = Task.class.getSimpleName(); - - // 表示任务是否已完成 - private boolean mCompleted; - - // 任务的备注信息 - private String mNotes; - - // 任务的元信息，使用JSONObject存储 - private JSONObject mMetaInfo; - - // 任务的前一个兄弟任务，用于任务排序 - private Task mPriorSibling; - - // 任务所属的任务列表 - private TaskList mParent; - - // Task类的构造方法，初始化任务的默认状态 - public Task() { - super(); - mCompleted = false; - mNotes = null; - mPriorSibling = null; - mParent = null; - mMetaInfo = null; - } - - /** - * 生成任务创建操作的JSON对象 - * @param actionId 操作ID. - * @return 返回表示创建操作的JSONObject - * @throws ActionFailureException 如果JSON对象生成失败，则抛出此异常 - */ - public JSONObject getCreateAction(int actionId) { - JSONObject js = new JSONObject(); - - try { - // action_type - js.put(GTaskStringUtils.GTASK_JSON_ACTION_TYPE, - GTaskStringUtils.GTASK_JSON_ACTION_TYPE_CREATE); - - // action_id - js.put(GTaskStringUtils.GTASK_JSON_ACTION_ID, actionId); - - // index - js.put(GTaskStringUtils.GTASK_JSON_INDEX, mParent.getChildTaskIndex(this)); - - // entity_delta - JSONObject entity = new JSONObject(); - entity.put(GTaskStringUtils.GTASK_JSON_NAME, getName()); - entity.put(GTaskStringUtils.GTASK_JSON_CREATOR_ID, "null"); - entity.put(GTaskStringUtils.GTASK_JSON_ENTITY_TYPE, - GTaskStringUtils.GTASK_JSON_TYPE_TASK); - if (getNotes() != null) { - entity.put(GTaskStringUtils.GTASK_JSON_NOTES, getNotes()); - } - js.put(GTaskStringUtils.GTASK_JSON_ENTITY_DELTA, entity); - - // parent_id - js.put(GTaskStringUtils.GTASK_JSON_PARENT_ID, mParent.getGid()); - - // dest_parent_type - js.put(GTaskStringUtils.GTASK_JSON_DEST_PARENT_TYPE, - GTaskStringUtils.GTASK_JSON_TYPE_GROUP); - - // list_id - js.put(GTaskStringUtils.GTASK_JSON_LIST_ID, mParent.getGid()); - - // prior_sibling_id - if (mPriorSibling != null) { - js.put(GTaskStringUtils.GTASK_JSON_PRIOR_SIBLING_ID, mPriorSibling.getGid()); - } - - } catch (JSONException e) { - Log.e(TAG, e.toString()); - e.printStackTrace(); - throw new ActionFailureException("fail to generate task-create jsonobject"); - } - - return js; - } - - /** - * 生成任务更新操作的JSON对象 - * @param actionId 操作ID - * @return 返回表示更新操作的JSONObject - * @throws ActionFailureException 如果JSON对象生成失败，则抛出此异常 - */ - public JSONObject getUpdateAction(int actionId) { - JSONObject js = new JSONObject(); - - try { - // action_type - js.put(GTaskStringUtils.GTASK_JSON_ACTION_TYPE, - GTaskStringUtils.GTASK_JSON_ACTION_TYPE_UPDATE); - - // action_id - js.put(GTaskStringUtils.GTASK_JSON_ACTION_ID, actionId); - - // id - js.put(GTaskStringUtils.GTASK_JSON_ID, getGid()); - - // entity_delta - JSONObject entity = new JSONObject(); - entity.put(GTaskStringUtils.GTASK_JSON_NAME, getName()); - if (getNotes() != null) { - entity.put(GTaskStringUtils.GTASK_JSON_NOTES, getNotes()); - } - entity.put(GTaskStringUtils.GTASK_JSON_DELETED, getDeleted()); - js.put(GTaskStringUtils.GTASK_JSON_ENTITY_DELTA, entity); - - } catch (JSONException e) { - Log.e(TAG, e.toString()); - e.printStackTrace(); - throw new ActionFailureException("fail to generate task-update jsonobject"); - } - - return js; - } - - /** - * 通过远程JSON对象设置任务内容 - * @param js 远程JSON对象，包含任务的相关信息 - * @throws ActionFailureException 如果设置内容失败，则抛出此异常 - */ - public void setContentByRemoteJSON(JSONObject js) { - if (js != null) { - try { - // id - if (js.has(GTaskStringUtils.GTASK_JSON_ID)) { - setGid(js.getString(GTaskStringUtils.GTASK_JSON_ID)); - } - - // last_modified - if (js.has(GTaskStringUtils.GTASK_JSON_LAST_MODIFIED)) { - setLastModified(js.getLong(GTaskStringUtils.GTASK_JSON_LAST_MODIFIED)); - } - - // name - if (js.has(GTaskStringUtils.GTASK_JSON_NAME)) { - setName(js.getString(GTaskStringUtils.GTASK_JSON_NAME)); - } - - // notes - if (js.has(GTaskStringUtils.GTASK_JSON_NOTES)) { - setNotes(js.getString(GTaskStringUtils.GTASK_JSON_NOTES)); - } - - // deleted - if (js.has(GTaskStringUtils.GTASK_JSON_DELETED)) { - setDeleted(js.getBoolean(GTaskStringUtils.GTASK_JSON_DELETED)); - } - - // completed - if (js.has(GTaskStringUtils.GTASK_JSON_COMPLETED)) { - setCompleted(js.getBoolean(GTaskStringUtils.GTASK_JSON_COMPLETED)); - } - } catch (JSONException e) { - Log.e(TAG, e.toString()); - e.printStackTrace(); - throw new ActionFailureException("fail to get task content from jsonobject"); - } - } - } - - /** - * 通过本地JSON对象设置任务内容 - * @param js 本地JSON对象，包含任务的相关信息 - * @throws ActionFailureException 如果设置内容失败，则抛出此异常 - */ - public void setContentByLocalJSON(JSONObject js) { - if (js == null || !js.has(GTaskStringUtils.META_HEAD_NOTE) - || !js.has(GTaskStringUtils.META_HEAD_DATA)) { -``` - -// 当没有可用内容时记录警告信息 -Log.w(TAG, "setContentByLocalJSON: nothing is avaiable"); -} - -try { - // 从JSON对象中获取笔记和数据数组 - JSONObject note = js.getJSONObject(GTaskStringUtils.META_HEAD_NOTE); - JSONArray dataArray = js.getJSONArray(GTaskStringUtils.META_HEAD_DATA); - - // 检查笔记类型是否无效 - if (note.getInt(NoteColumns.TYPE) != Notes.TYPE_NOTE) { - Log.e(TAG, "invalid type"); - return; - } - - // 遍历数据数组以查找并设置笔记内容 - for (int i = 0; i < dataArray.length(); i++) { - JSONObject data = dataArray.getJSONObject(i); - if (TextUtils.equals(data.getString(DataColumns.MIME_TYPE), DataConstants.NOTE)) { - setName(data.getString(DataColumns.CONTENT)); - break; - } - } - -} catch (JSONException e) { - // 记录并打印JSONException的堆栈跟踪 - Log.e(TAG, e.toString()); - e.printStackTrace(); -} -``` -/** - * 从内容生成本地使用的JSON对象 - * - * @return 表示笔记内容的JSONObject，如果内容为空则返回null - */ -public JSONObject getLocalJSONFromContent() { - String name = getName(); - try { - // 处理从网页创建的新任务 - if (mMetaInfo == null) { - if (name == null) { - Log.w(TAG, "the note seems to be an empty one"); - return null; - } - - // 构建新的笔记JSON对象 - JSONObject js = new JSONObject(); - JSONObject note = new JSONObject(); - JSONArray dataArray = new JSONArray(); - JSONObject data = new JSONObject(); - data.put(DataColumns.CONTENT, name); - dataArray.put(data); - js.put(GTaskStringUtils.META_HEAD_DATA, dataArray); - note.put(NoteColumns.TYPE, Notes.TYPE_NOTE); - js.put(GTaskStringUtils.META_HEAD_NOTE, note); - return js; - } else { - // 处理已同步的任务 - JSONObject note = mMetaInfo.getJSONObject(GTaskStringUtils.META_HEAD_NOTE); - JSONArray dataArray = mMetaInfo.getJSONArray(GTaskStringUtils.META_HEAD_DATA); - - // 更新数据数组中的笔记内容 - for (int i = 0; i < dataArray.length(); i++) { - JSONObject data = dataArray.getJSONObject(i); - if (TextUtils.equals(data.getString(DataColumns.MIME_TYPE), DataConstants.NOTE)) { - data.put(DataColumns.CONTENT, getName()); - break; - } - } - - note.put(NoteColumns.TYPE, Notes.TYPE_NOTE); - return mMetaInfo; - } - } catch (JSONException e) { - // 记录并打印JSONException的堆栈跟踪 - Log.e(TAG, e.toString()); - e.printStackTrace(); - return null; - } -} -/** - * 设置任务的元信息 - * - * @param metaData 包含笔记信息的MetaData对象 - */ -public void setMetaInfo(MetaData metaData) { - if (metaData != null && metaData.getNotes() != null) { - try { - // 将笔记信息转换为JSON对象 - mMetaInfo = new JSONObject(metaData.getNotes()); - } catch (JSONException e) { - // 转换失败时记录错误并将mMetaInfo设置为null - Log.w(TAG, e.toString()); - mMetaInfo = null; - } - } -} -``` -```java -/** - * 根据当前状态和数据库游标确定同步操作 - * - * @param c 指向数据库中笔记数据的游标 - * @return 表示要执行的同步操作的整数 - */ -public int getSyncAction(Cursor c) { - try { - // 从mMetaInfo中获取笔记信息 - JSONObject noteInfo = null; - if (mMetaInfo != null && mMetaInfo.has(GTaskStringUtils.META_HEAD_NOTE)) { - noteInfo = mMetaInfo.getJSONObject(GTaskStringUtils.META_HEAD_NOTE); - } - - // 根据笔记信息确定同步操作 - if (noteInfo == null) { - Log.w(TAG, "it seems that note meta has been deleted"); - return SYNC_ACTION_UPDATE_REMOTE; - } - - if (!noteInfo.has(NoteColumns.ID)) { - Log.w(TAG, "remote note id seems to be deleted"); - return SYNC_ACTION_UPDATE_LOCAL; - } - - // 验证笔记ID - if (c.getLong(SqlNote.ID_COLUMN) != noteInfo.getLong(NoteColumns.ID)) { - Log.w(TAG, "note id doesn't match"); - return SYNC_ACTION_UPDATE_LOCAL; - } - - // 根据本地修改状态确定同步操作 - if (c.getInt(SqlNote.LOCAL_MODIFIED_COLUMN) == 0) { - if (c.getLong(SqlNote.SYNC_ID_COLUMN) == getLastModified()) { - return SYNC_ACTION_NONE; - } else { - return SYNC_ACTION_UPDATE_LOCAL; - } - } else { - // 验证GTasks ID - if (!c.getString(SqlNote.GTASK_ID_COLUMN).equals(getGid())) { - Log.e(TAG, "gtask id doesn't match"); - return SYNC_ACTION_ERROR; - } - if (c.getLong(SqlNote.SYNC_ID_COLUMN) == getLastModified()) { - return SYNC_ACTION_UPDATE_REMOTE; - } else { - return SYNC_ACTION_UPDATE_CONFLICT; - } - } - } catch (Exception e) { - // 记录并打印异常的堆栈跟踪 - Log.e(TAG, e.toString()); - e.printStackTrace(); - } - - return SYNC_ACTION_ERROR; -} -``` -```java -/** - * 检查任务是否有值得保存的内容 - * - * @return 布尔值，表示任务是否有值得保存的内容 - */ -public boolean isWorthSaving() { - return mMetaInfo != null || (getName() != null && getName().trim().length() > 0) - || (getNotes() != null && getNotes().trim().length() > 0); -} -// 设置任务的完成状态 -public void setCompleted(boolean completed) { - this.mCompleted = completed; -} - -// 设置任务的笔记内容 -public void setNotes(String notes) { - this.mNotes = notes; -} - -// 设置任务的前一个兄弟任务 -public void setPriorSibling(Task priorSibling) { - this.mPriorSibling = priorSibling; -} - -// 设置任务的父任务列表 -public void setParent(TaskList parent) { - this.mParent = parent; -} - -// 获取任务的完成状态 -public boolean getCompleted() { - return this.mCompleted; -} - -// 获取任务的笔记内容 -public String getNotes() { - return this.mNotes; -} - -// 获取任务的前一个兄弟任务 -public Task getPriorSibling() { - return this.mPriorSibling; -} - -// 获取任务的父任务列表 -public TaskList getParent() { - return this.mParent; -} diff --git a/src/net/micode/notes/gtask/data/TaskList.java b/src/net/micode/notes/gtask/data/TaskList.java deleted file mode 100644 index 0866ed2..0000000 --- a/src/net/micode/notes/gtask/data/TaskList.java +++ /dev/null @@ -1,448 +0,0 @@ - -package net.micode.notes.gtask.data; - -import android.database.Cursor; -import android.util.Log; - -import net.micode.notes.data.Notes; -import net.micode.notes.data.Notes.NoteColumns; -import net.micode.notes.gtask.exception.ActionFailureException; -import net.micode.notes.tool.GTaskStringUtils; - -import org.json.JSONException; -import org.json.JSONObject; - -import java.util.ArrayList; - -/** - * TaskList 类代表一个任务列表，继承自 Node 类 - * 它包含一个任务列表和相关的操作，如创建和更新任务列表的 JSON 对象 - */ -public class TaskList extends Node { - private static final String TAG = TaskList.class.getSimpleName(); - - // 任务列表的索引 - private int mIndex; - - // 任务列表 - private ArrayList mChildren; - - /** - * TaskList 构造函数初始化任务列表和索引. - */ - public TaskList() { - super(); - mChildren = new ArrayList(); - mIndex = 1; - } - - /** - * 生成创建任务列表的 JSON 对象 - * - * @param actionId 操作的 ID - * @return 创建操作的 JSON 对象 - * @throws ActionFailureException 如果生成 JSON 对象失败 - */ - public JSONObject getCreateAction(int actionId) { - JSONObject js = new JSONObject(); - - try { - // action_type - js.put(GTaskStringUtils.GTASK_JSON_ACTION_TYPE, - GTaskStringUtils.GTASK_JSON_ACTION_TYPE_CREATE); - - // action_id - js.put(GTaskStringUtils.GTASK_JSON_ACTION_ID, actionId); - - // index - js.put(GTaskStringUtils.GTASK_JSON_INDEX, mIndex); - - // entity_delta - JSONObject entity = new JSONObject(); - entity.put(GTaskStringUtils.GTASK_JSON_NAME, getName()); - entity.put(GTaskStringUtils.GTASK_JSON_CREATOR_ID, "null"); - entity.put(GTaskStringUtils.GTASK_JSON_ENTITY_TYPE, - GTaskStringUtils.GTASK_JSON_TYPE_GROUP); - js.put(GTaskStringUtils.GTASK_JSON_ENTITY_DELTA, entity); - - } catch (JSONException e) { - Log.e(TAG, e.toString()); - e.printStackTrace(); - throw new ActionFailureException("fail to generate tasklist-create jsonobject"); - } - - return js; - } - - /** - * 生成更新任务列表的 JSON 对象 - * - * @param actionId 操作的 ID - * @return 更新操作的 JSON 对象 - * @throws ActionFailureException 如果生成 JSON 对象失败 - */ - public JSONObject getUpdateAction(int actionId) { - JSONObject js = new JSONObject(); - - try { - // action_type - js.put(GTaskStringUtils.GTASK_JSON_ACTION_TYPE, - GTaskStringUtils.GTASK_JSON_ACTION_TYPE_UPDATE); - - // action_id - js.put(GTaskStringUtils.GTASK_JSON_ACTION_ID, actionId); - - // id - js.put(GTaskStringUtils.GTASK_JSON_ID, getGid()); - - // entity_delta - JSONObject entity = new JSONObject(); - entity.put(GTaskStringUtils.GTASK_JSON_NAME, getName()); - entity.put(GTaskStringUtils.GTASK_JSON_DELETED, getDeleted()); - js.put(GTaskStringUtils.GTASK_JSON_ENTITY_DELTA, entity); - - } catch (JSONException e) { - Log.e(TAG, e.toString()); - e.printStackTrace(); - throw new ActionFailureException("fail to generate tasklist-update jsonobject"); - } - - return js; - } - - /** - * 通过远程 JSON 对象设置任务列表的内容 - * - * @param js 远程 JSON 对象 - * @throws ActionFailureException 如果设置内容失败 - */ - public void setContentByRemoteJSON(JSONObject js) { - if (js != null) { - try { - // id - if (js.has(GTaskStringUtils.GTASK_JSON_ID)) { - setGid(js.getString(GTaskStringUtils.GTASK_JSON_ID)); - } - - // last_modified - if (js.has(GTaskStringUtils.GTASK_JSON_LAST_MODIFIED)) { - setLastModified(js.getLong(GTaskStringUtils.GTASK_JSON_LAST_MODIFIED)); - } - - // name - if (js.has(GTaskStringUtils.GTASK_JSON_NAME)) { - setName(js.getString(GTaskStringUtils.GTASK_JSON_NAME)); - } - - } catch (JSONException e) { - Log.e(TAG, e.toString()); - e.printStackTrace(); - throw new ActionFailureException("fail to get tasklist content from jsonobject"); - } - } - } - - /** - * 通过本地 JSON 对象设置任务列表的内容 - * - * @param js 本地 JSON 对象 - * @throws ActionFailureException 如果设置内容失败 - */ - public void setContentByLocalJSON(JSONObject js) { - if (js == null || !js.has(GTaskStringUtils.META_HEAD_NOTE)) { - Log.w(TAG, "setContentByLocalJSON: nothing is avaiable"); - } - - try { - JSONObject folder = js.getJSONObject(GTaskStringUtils.META_HEAD_NOTE); - - if (folder.getInt(NoteColumns.TYPE) == Notes.TYPE_FOLDER) { - String name = folder.getString(NoteColumns.SNIPPET); - setName(GTaskStringUtils.MIUI_FOLDER_PREFFIX + name); - } else if (folder.getInt(NoteColumns.TYPE) == Notes.TYPE_SYSTEM) { - if (folder.getLong(NoteColumns.ID) == Notes.ID_ROOT_FOLDER) - setName(GTaskStringUtils.MIUI_FOLDER_PREFFIX + GTaskStringUtils.FOLDER_DEFAULT); - else if (folder.getLong(NoteColumns.ID) == Notes.ID_CALL_RECORD_FOLDER) - setName(GTaskStringUtils.MIUI_FOLDER_PREFFIX - + GTaskStringUtils.FOLDER_CALL_NOTE); - else - Log.e(TAG, "invalid system folder"); - } else { - Log.e(TAG, "error type"); - } - } catch (JSONException e) { - Log.e(TAG, e.toString()); - e.printStackTrace(); -} -} - -/** - * 获取本地 JSON 内容 - * - * 该方法构建一个表示本地笔记信息的 JSONObject，包括文件夹名称和类型 - * @return 包含本地笔记信息的 JSONObject，如果发生异常则返回 null - */ -public JSONObject getLocalJSONFromContent() { - try { - JSONObject js = new JSONObject(); - JSONObject folder = new JSONObject(); - - String folderName = getName(); - if (getName().startsWith(GTaskStringUtils.MIUI_FOLDER_PREFFIX)) - folderName = folderName.substring(GTaskStringUtils.MIUI_FOLDER_PREFFIX.length(), - folderName.length()); - folder.put(NoteColumns.SNIPPET, folderName); - if (folderName.equals(GTaskStringUtils.FOLDER_DEFAULT) - || folderName.equals(GTaskStringUtils.FOLDER_CALL_NOTE)) - folder.put(NoteColumns.TYPE, Notes.TYPE_SYSTEM); - else - folder.put(NoteColumns.TYPE, Notes.TYPE_FOLDER); - - js.put(GTaskStringUtils.META_HEAD_NOTE, folder); - - return js; - } catch (JSONException e) { - Log.e(TAG, e.toString()); - e.printStackTrace(); - return null; - } -} - -/** - * 根据游标获取同步操作 - * - * 根据游标信息确定本地和远程笔记之间的同步操作 - * @param c 指向数据库记录的游标 - * @return 同步操作常量之一 - */ -public int getSyncAction(Cursor c) { - try { - if (c.getInt(SqlNote.LOCAL_MODIFIED_COLUMN) == 0) { - // 本地没有更新 - if (c.getLong(SqlNote.SYNC_ID_COLUMN) == getLastModified()) { - // 双方都没有更新 - return SYNC_ACTION_NONE; - } else { - // 将远程应用到本地 - return SYNC_ACTION_UPDATE_LOCAL; - } - } else { - // 验证 gtask id - if (!c.getString(SqlNote.GTASK_ID_COLUMN).equals(getGid())) { - Log.e(TAG, "gtask id 不匹配"); - return SYNC_ACTION_ERROR; - } - if (c.getLong(SqlNote.SYNC_ID_COLUMN) == getLastModified()) { - // 仅本地有修改 - return SYNC_ACTION_UPDATE_REMOTE; - } else { - // 对于文件夹冲突，仅应用本地修改 - return SYNC_ACTION_UPDATE_REMOTE; - } - } - } catch (Exception e) { - Log.e(TAG, e.toString()); - e.printStackTrace(); - } - - return SYNC_ACTION_ERROR; -} - -/** - * 获取子任务的数量 - * - * @return 子任务的数量 - */ -public int getChildTaskCount() { - return mChildren.size(); -} - -/** - * 添加子任务 - * - * 如果子任务列表中不存在该任务，则将其添加到子任务列表中 - * @param task 要添加的任务 - * @return 如果任务成功添加则返回 true，否则返回 false - */ -public boolean addChildTask(Task task) { - boolean ret = false; - if (task != null && !mChildren.contains(task)) { - ret = mChildren.add(task); - if (ret) { - // 需要设置前一个兄弟任务和父任务 - task.setPriorSibling(mChildren.isEmpty() ? null : mChildren - .get(mChildren.size() - 1)); - task.setParent(this); - } - } - return ret; -} - -/** - * 在指定索引位置添加子任务 - * - * 将任务添加到子任务列表的指定索引位置，并更新任务列表 - * @param task 要添加的任务 - * @param index 要添加任务的索引位置 - * @return 如果任务成功添加则返回 true，否则返回 false - */ -public boolean addChildTask(Task task, int index) { - if (index < 0 || index > mChildren.size()) { - Log.e(TAG, "添加子任务: 无效的索引"); - return false; - } - - int pos = mChildren.indexOf(task); - if (task != null && pos == -1) { - mChildren.add(index, task); - - // 更新任务列表 - Task preTask = null; - Task afterTask = null; - if (index != 0) - preTask = mChildren.get(index - 1); - if (index != mChildren.size() - 1) - afterTask = mChildren.get(index + 1); - - task.setPriorSibling(preTask); - if (afterTask != null) - afterTask.setPriorSibling(task); - } - - return true; -} - -/** - * 移除子任务 - * - * 从子任务列表中移除任务，并更新任务列表 - * @param task 要移除的任务 - * @return 如果任务成功移除则返回 true，否则返回 false - */ -public boolean removeChildTask(Task task) { - boolean ret = false; - int index = mChildren.indexOf(task); - if (index != -1) { - ret = mChildren.remove(task); - - if (ret) { - // 重置前一个兄弟任务和父任务 - task.setPriorSibling(null); - task.setParent(null); - - // 更新任务列表 - if (index != mChildren.size()) { - mChildren.get(index).setPriorSibling( - index == 0 ? null : mChildren.get(index - 1)); - } - } - } - return ret; -} - -/** - * 移动子任务到新的索引位置 - * - * 将任务在子任务列表中移动到新的索引位置 - * @param task 要移动的任务 - * @param index 新的索引位置 - * @return 如果任务成功移动则返回 true，否则返回 false - */ -public boolean moveChildTask(Task task, int index) { - if (index < 0 || index >= mChildren.size()) { - Log.e(TAG, "移动子任务: 无效的索引"); - return false; - } - - int pos = mChildren.indexOf(task); - if (pos == -1) { - Log.e(TAG, "移动子任务: 任务不在列表中"); - return false; - } - - if (pos == index) - return true; - return (removeChildTask(task) && addChildTask(task, index)); -} - -/** - * 通过 GID 查找子任务 - * - * @param gid 要查找的任务的 GID - * @return 找到的任务，如果没有找到则返回 null - */ -public Task findChildTaskByGid(String gid) { - for (int i = 0; i < mChildren.size(); i++) { - Task t = mChildren.get(i); - if (t.getGid().equals(gid)) { - return t; - } - } - return null; -} - -/** - * 获取子任务的索引 - * - * @param task 子任务 - * @return 子任务的索引，如果没有找到则返回 -1 - */ -public int getChildTaskIndex(Task task) { - return mChildren.indexOf(task); -} - -/** - * 通过索引获取子任务 - * - * @param index 子任务的索引 - * @return 指定索引位置的子任务，如果索引无效则返回 null - */ -public Task getChildTaskByIndex(int index) { - if (index < 0 || index >= mChildren.size()) { - Log.e(TAG, "通过索引获取任务: 无效的索引"); - return null; - } - return mChildren.get(index); -} - -/** - * 通过 GID 查找子任务（替代方法） - * - * @param gid 要查找的任务的 GID - * @return 找到的任务，如果没有找到则返回 null - */ -public Task getChilTaskByGid(String gid) { - for (Task task : mChildren) { - if (task.getGid().equals(gid)) - return task; - } - return null; -} - -/** - * 获取子任务列表 - * - * @return 子任务列表 - */ -public ArrayList getChildTaskList() { - return this.mChildren; -} - -/** - * 设置任务的索引 - * - * @param index 任务的新索引 - */ -public void setIndex(int index) { - this.mIndex = index; -} - -/** - * 获取任务的索引 - * - * @return 任务的索引 - */ -public int getIndex() { - return this.mIndex; -} -} diff --git a/src/net/micode/notes/gtask/exception/ActionFailureException.java b/src/net/micode/notes/gtask/exception/ActionFailureException.java deleted file mode 100644 index 4c5b1d6..0000000 --- a/src/net/micode/notes/gtask/exception/ActionFailureException.java +++ /dev/null @@ -1,41 +0,0 @@ - - -package net.micode.notes.gtask.exception; - -/** - * ActionFailureException 类用于表示操作失败时抛出的异常。 - * 继承自 RuntimeException，表示该异常是运行时异常，不需要强制捕获。 - */ -public class ActionFailureException extends RuntimeException { - /** - * 序列化版本UID，用于确保序列化和反序列化的一致性。 - */ - private static final long serialVersionUID = 4425249765923293627L; - - /** - * 默认构造函数，无参数 - */ - public ActionFailureException() { - super(); - } - - /** - * 带有错误消息的构造函数。 - * - * @param message 错误消息 - */ - public ActionFailureException(String message) { - super(message); - } - - /** - * 带有错误消息和原因的构造函数。 - * - * @param message 错误消息 - * @param cause 引发此异常的原因（可选） - */ - public ActionFailureException(String message, Throwable cause) { - super(message, cause); - } -} - diff --git a/src/net/micode/notes/gtask/exception/NetworkFailureException.java b/src/net/micode/notes/gtask/exception/NetworkFailureException.java deleted file mode 100644 index e3ee760..0000000 --- a/src/net/micode/notes/gtask/exception/NetworkFailureException.java +++ /dev/null @@ -1,41 +0,0 @@ - - -package net.micode.notes.gtask.exception; - -/** - * NetworkFailureException 类用于表示网络操作失败时抛出的异常。 - * 继承自 Exception，表示该异常是检查型异常，需要在代码中显式捕获或声明抛出。 - */ -public class NetworkFailureException extends Exception { - /** - * 序列化版本UID，用于确保序列化和反序列化的一致性。 - */ - private static final long serialVersionUID = 2107610287180234136L; - - /** - * 默认构造函数，无参数 - */ - public NetworkFailureException() { - super(); - } - - /** - * 带有错误消息的构造函数。 - * - * @param message 错误消息 - */ - public NetworkFailureException(String message) { - super(message); - } - - /** - * 带有错误消息和原因的构造函数。 - * - * @param message 错误消息 - * @param cause 引发此异常的原因（可选） - */ - public NetworkFailureException(String message, Throwable cause) { - super(message, cause); - } -} - diff --git a/src/net/micode/notes/gtask/remote/GTaskASyncTask.java b/src/net/micode/notes/gtask/remote/GTaskASyncTask.java deleted file mode 100644 index a51bae3..0000000 --- a/src/net/micode/notes/gtask/remote/GTaskASyncTask.java +++ /dev/null @@ -1,155 +0,0 @@ -package net.micode.notes.gtask.remote; - -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.gtask.remote.GTaskManager; -import net.micode.notes.gtask.remote.GTaskSyncService; -import net.micode.notes.ui.NotesListActivity; -import net.micode.notes.ui.NotesPreferenceActivity; - -/** - * GTaskASyncTask 类用于异步执行 Google Task 同步任务。 - * 它继承自 AsyncTask，并在后台线程中执行同步操作，同时通过通知和回调接口向用户反馈进度和结果。 - */ -public class GTaskASyncTask extends AsyncTask { - - /** - * 同步任务的通知 ID - */ - private static int GTASK_SYNC_NOTIFICATION_ID = 5234235; - - /** - * 定义一个完成监听器接口，用于在任务完成后调用。 - */ - public interface OnCompleteListener { - void onComplete(); - } - - /** - * 上下文对象，用于访问应用程序资源。 - */ - private Context mContext; - - /** - * 通知管理器，用于显示同步任务的通知。 - */ - private NotificationManager mNotifiManager; - - /** - * 任务管理器，用于执行实际的同步逻辑。 - */ - private GTaskManager mTaskManager; - - /** - * 完成监听器实例，用于在任务完成后触发回调。 - */ - private OnCompleteListener mOnCompleteListener; - - /** - * 构造函数，初始化上下文和监听器。 - * - * @param context 应用程序上下文 - * @param listener 完成监听器 - */ - 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(); - } - - /** - * 发布进度消息。 - * - * @param message 进度消息 - */ - public void publishProgess(String message) { - publishProgress(new String[]{message}); - } - - /** - * 显示通知。 - * - * @param tickerId 提示文本资源ID - * @param content 通知内容 - */ - 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; - 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); - } - - /** - * 在后台线程中执行同步任务。 - * - * @param unused 未使用的参数 - * @return 同步结果状态码 - */ - @Override - protected Integer doInBackground(Void... unused) { - publishProgess(mContext.getString(R.string.sync_progress_login, NotesPreferenceActivity.getSyncAccountName(mContext))); - return mTaskManager.sync(mContext, this); - } - - /** - * 更新进度时调用此方法。 - * - * @param progress 进度消息数组 - */ - @Override - protected void onProgressUpdate(String... progress) { - showNotification(R.string.ticker_syncing, progress[0]); - if (mContext instanceof GTaskSyncService) { - ((GTaskSyncService) mContext).sendBroadcast(progress[0]); - } - } - - /** - * 任务完成后调用此方法。 - * - * @param result 同步结果状态码 - */ - @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(); - } - } -} diff --git a/src/net/micode/notes/gtask/remote/GTaskClient.java b/src/net/micode/notes/gtask/remote/GTaskClient.java deleted file mode 100644 index 1eac755..0000000 --- a/src/net/micode/notes/gtask/remote/GTaskClient.java +++ /dev/null @@ -1,599 +0,0 @@ - - /* - * 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. - */ - - package net.micode.notes.gtask.remote; - -import android.accounts.Account; -import android.accounts.AccountManager; -import android.accounts.AccountManagerFuture; -import android.app.Activity; -import android.os.Bundle; -import android.text.TextUtils; -import android.util.Log; - -import net.micode.notes.gtask.data.Node; -import net.micode.notes.gtask.data.Task; -import net.micode.notes.gtask.data.TaskList; -import net.micode.notes.gtask.exception.ActionFailureException; -import net.micode.notes.gtask.exception.NetworkFailureException; -import net.micode.notes.tool.GTaskStringUtils; -import net.micode.notes.ui.NotesPreferenceActivity; - -import org.apache.http.HttpEntity; -import org.apache.http.HttpResponse; -import org.apache.http.client.ClientProtocolException; -import org.apache.http.client.entity.UrlEncodedFormEntity; -import org.apache.http.client.methods.HttpGet; -import org.apache.http.client.methods.HttpPost; -import org.apache.http.cookie.Cookie; -import org.apache.http.impl.client.BasicCookieStore; -import org.apache.http.impl.client.DefaultHttpClient; -import org.apache.http.message.BasicNameValuePair; -import org.apache.http.params.BasicHttpParams; -import org.apache.http.params.HttpConnectionParams; -import org.apache.http.params.HttpProtocolParams; -import org.json.JSONArray; -import org.json.JSONException; -import org.json.JSONObject; - -import java.io.BufferedReader; -import java.io.IOException; -import java.io.InputStream; -import java.io.InputStreamReader; -import java.util.LinkedList; -import java.util.List; -import java.util.zip.GZIPInputStream; -import java.util.zip.Inflater; -import java.util.zip.InflaterInputStream; - -/** - * GTaskClient 类用于处理与 Google Tasks 的远程交互，包括登录、创建任务、移动任务等操作 - */ -public class GTaskClient { - private static final String TAG = GTaskClient.class.getSimpleName(); - - // Google Tasks API URL - private static final String GTASK_URL = "https://mail.google.com/tasks/"; - private static final String GTASK_GET_URL = "https://mail.google.com/tasks/ig"; - private static final String GTASK_POST_URL = "https://mail.google.com/tasks/r/ig"; - - // 单例模式实例 - private static GTaskClient mInstance = null; - - // HTTP 客户端和相关配置 - private DefaultHttpClient mHttpClient; - private String mGetUrl; - private String mPostUrl; - private long mClientVersion; - private boolean mLoggedin; - private long mLastLoginTime; - private int mActionId; - private Account mAccount; - private JSONArray mUpdateArray; - - /** - * 构造函数，初始化默认值。 - */ - private GTaskClient() { - mHttpClient = null; - mGetUrl = GTASK_GET_URL; - mPostUrl = GTASK_POST_URL; - mClientVersion = -1; - mLoggedin = false; - mLastLoginTime = 0; - mActionId = 1; - mAccount = null; - mUpdateArray = null; - } - - /** - * 获取单例实例。 - * - * @return GTaskClient 实例 - */ - public static synchronized GTaskClient getInstance() { - if (mInstance == null) { - mInstance = new GTaskClient(); - } - return mInstance; - } - - /** - * 登录 Google 账户并获取授权令牌。 - * - * @param activity 当前活动的上下文 - * @return 是否登录成功 - */ - public boolean login(Activity activity) { - // 如果上次登录时间超过5分钟，则需要重新登录 - final long interval = 1000 * 60 * 5; - if (mLastLoginTime + interval < System.currentTimeMillis()) { - mLoggedin = false; - } - - // 如果切换了账户，则需要重新登录 - if (mLoggedin && !TextUtils.equals(getSyncAccount().name, NotesPreferenceActivity.getSyncAccountName(activity))) { - mLoggedin = false; - } - - if (mLoggedin) { - Log.d(TAG, "已经登录"); - return true; - } - - mLastLoginTime = System.currentTimeMillis(); - String authToken = loginGoogleAccount(activity, false); - if (authToken == null) { - Log.e(TAG, "登录 Google 账户失败"); - return false; - } - - // 如果是自定义域名，则使用特定的 URL 进行登录 - if (!(mAccount.name.toLowerCase().endsWith("gmail.com") || mAccount.name.toLowerCase().endsWith("googlemail.com"))) { - StringBuilder url = new StringBuilder(GTASK_URL).append("a/"); - int index = mAccount.name.indexOf('@') + 1; - String suffix = mAccount.name.substring(index); - url.append(suffix + "/"); - mGetUrl = url.toString() + "ig"; - mPostUrl = url.toString() + "r/ig"; - - if (tryToLoginGtask(activity, authToken)) { - mLoggedin = true; - } - } - - // 尝试使用官方 URL 登录 - if (!mLoggedin) { - mGetUrl = GTASK_GET_URL; - mPostUrl = GTASK_POST_URL; - if (!tryToLoginGtask(activity, authToken)) { - return false; - } - } - - mLoggedin = true; - return true; - } - - /** - * 获取 Google 账户的授权令牌。 - * - * @param activity 当前活动的上下文 - * @param invalidateToken 是否无效化当前令牌 - * @return 授权令牌 - */ - private String loginGoogleAccount(Activity activity, boolean invalidateToken) { - String authToken; - AccountManager accountManager = AccountManager.get(activity); - Account[] accounts = accountManager.getAccountsByType("com.google"); - - if (accounts.length == 0) { - Log.e(TAG, "没有可用的 Google 账户"); - return null; - } - - String accountName = NotesPreferenceActivity.getSyncAccountName(activity); - Account account = null; - for (Account a : accounts) { - if (a.name.equals(accountName)) { - account = a; - break; - } - } - if (account != null) { - mAccount = account; - } else { - Log.e(TAG, "无法找到与设置中相同的账户"); - return null; - } - - // 获取授权令牌 - AccountManagerFuture accountManagerFuture = accountManager.getAuthToken(account, "goanna_mobile", null, activity, null, null); - try { - Bundle authTokenBundle = accountManagerFuture.getResult(); - authToken = authTokenBundle.getString(AccountManager.KEY_AUTHTOKEN); - if (invalidateToken) { - accountManager.invalidateAuthToken("com.google", authToken); - loginGoogleAccount(activity, false); - } - } catch (Exception e) { - Log.e(TAG, "获取授权令牌失败"); - authToken = null; - } - - return authToken; - } - - /** - * 尝试使用授权令牌登录 Google Tasks。 - * - * @param activity 当前活动的上下文 - * @param authToken 授权令牌 - * @return 是否登录成功 - */ - private boolean tryToLoginGtask(Activity activity, String authToken) { - if (!loginGtask(authToken)) { - // 如果授权令牌过期，则尝试重新获取并再次登录 - authToken = loginGoogleAccount(activity, true); - if (authToken == null) { - Log.e(TAG, "登录 Google 账户失败"); - return false; - } - - if (!loginGtask(authToken)) { - Log.e(TAG, "登录 Google Tasks 失败"); - return false; - } - } - return true; - } - - /** - * 使用授权令牌登录 Google Tasks。 - * - * @param authToken 授权令牌 - * @return 是否登录成功 - */ - private boolean loginGtask(String authToken) { - int timeoutConnection = 10000; - int timeoutSocket = 15000; - HttpParams httpParameters = new BasicHttpParams(); - HttpConnectionParams.setConnectionTimeout(httpParameters, timeoutConnection); - HttpConnectionParams.setSoTimeout(httpParameters, timeoutSocket); - mHttpClient = new DefaultHttpClient(httpParameters); - BasicCookieStore localBasicCookieStore = new BasicCookieStore(); - mHttpClient.setCookieStore(localBasicCookieStore); - HttpProtocolParams.setUseExpectContinue(mHttpClient.getParams(), false); - - // 登录 Google Tasks - try { - String loginUrl = mGetUrl + "?auth=" + authToken; - HttpGet httpGet = new HttpGet(loginUrl); - HttpResponse response = null; - response = mHttpClient.execute(httpGet); - - // 获取 Cookie - List cookies = mHttpClient.getCookieStore().getCookies(); - boolean hasAuthCookie = false; - for (Cookie cookie : cookies) { - if (cookie.getName().contains("GTL")) { - hasAuthCookie = true; - } - } - if (!hasAuthCookie) { - Log.w(TAG, "似乎没有授权 Cookie"); - } - - // 获取客户端版本 - String resString = getResponseContent(response.getEntity()); - String jsBegin = "_setup("; - String jsEnd = ")}"; - int begin = resString.indexOf(jsBegin); - int end = resString.lastIndexOf(jsEnd); - String jsString = null; - if (begin != -1 && end != -1 && begin < end) { - jsString = resString.substring(begin + jsBegin.length(), end); - } - JSONObject js = new JSONObject(jsString); - mClientVersion = js.getLong("v"); - } catch (JSONException e) { - Log.e(TAG, e.toString()); - e.printStackTrace(); - return false; - } catch (Exception e) { - Log.e(TAG, "HTTP GET 请求失败"); - return false; - } - - return true; - } - - /** - * 获取下一个操作 ID。 - * - * @return 操作 ID - */ - private int getActionId() { - return mActionId++; - } - - /** - * 创建 HTTP POST 请求。 - * - * @return HttpPost 对象 - */ - private HttpPost createHttpPost() { - HttpPost httpPost = new HttpPost(mPostUrl); - httpPost.setHeader("Content-Type", "application/x-www-form-urlencoded;charset=utf-8"); - httpPost.setHeader("AT", "1"); - return httpPost; - } - - /** - * 获取 HTTP 响应内容。 - * - * @param entity HTTP 响应实体 - * @return 响应内容字符串 - * @throws IOException IO 异常 - */ - private String getResponseContent(HttpEntity entity) throws IOException { - String contentEncoding = null; - if (entity.getContentEncoding() != null) { - contentEncoding = entity.getContentEncoding().getValue(); - Log.d(TAG, "编码: " + contentEncoding); - } - - InputStream input = entity.getContent(); - if (contentEncoding != null && contentEncoding.equalsIgnoreCase("gzip")) { - input = new GZIPInputStream(entity.getContent()); - } else if (contentEncoding != null && contentEncoding.equalsIgnoreCase("deflate")) { - Inflater inflater = new Inflater(true); - input = new InflaterInputStream(entity.getContent(), inflater); - } - - try { - InputStreamReader isr = new InputStreamReader(input); - BufferedReader br = new BufferedReader(isr); - StringBuilder sb = new StringBuilder(); - - while (true) { - String buff = br.readLine(); - if (buff == null) { - return sb.toString(); - } - sb = sb.append(buff); - } - } finally { - input.close(); - } - } - - /** - * 发送 POST 请求并返回响应 JSON 对象。 - * - * @param js 请求 JSON 对象 - * @return 响应 JSON 对象 - * @throws NetworkFailureException 网络异常 - */ - private JSONObject postRequest(JSONObject js) throws NetworkFailureException { - if (!mLoggedin) { - Log.e(TAG, "请先登录"); - throw new ActionFailureException("未登录"); - } - - HttpPost httpPost = createHttpPost(); - try { - LinkedList list = new LinkedList(); - list.add(new BasicNameValuePair("r", js.toString())); - UrlEncodedFormEntity entity = new UrlEncodedFormEntity(list, "UTF-8"); - httpPost.setEntity(entity); - - // 执行 POST 请求 - HttpResponse response = mHttpClient.execute(httpPost); - String jsString = getResponseContent(response.getEntity()); - return new JSONObject(jsString); - - } catch (ClientProtocolException e) { - Log.e(TAG, e.toString()); - e.printStackTrace(); - throw new NetworkFailureException("POST 请求失败"); - } catch (IOException e) { - Log.e(TAG, e.toString()); - e.printStackTrace(); - throw new NetworkFailureException("POST 请求失败"); - } catch (JSONException e) { - Log.e(TAG, e.toString()); - e.printStackTrace(); - throw new ActionFailureException("无法将响应内容转换为 JSON 对象"); - } catch (Exception e) { - Log.e(TAG, e.toString()); - e.printStackTrace(); - throw new ActionFailureException("发送请求时发生错误"); - } - } - - /** - * 创建任务。 - * - * @param task 任务对象 - * @throws NetworkFailureException 网络异常 - */ - public void createTask(Task task) throws NetworkFailureException { - commitUpdate(); - try { - JSONObject jsPost = new JSONObject(); - JSONArray actionList = new JSONArray(); - - // 添加创建任务的操作 - actionList.put(task.getCreateAction(getActionId())); - jsPost.put(GTaskStringUtils.GTASK_JSON_ACTION_LIST, actionList); - - // 设置客户端版本 - jsPost.put(GTaskStringUtils.GTASK_JSON_CLIENT_VERSION, mClientVersion); - - // 发送请求 - JSONObject jsResponse = postRequest(jsPost); - JSONObject jsResult = (JSONObject) jsResponse.getJSONArray(GTaskStringUtils.GTASK_JSON_RESULTS).get(0); - task.setGid(jsResult.getString(GTaskStringUtils.GTASK_JSON_NEW_ID)); - - } catch (JSONException e) { - Log.e(TAG, e.toString()); - e.printStackTrace(); - throw new ActionFailureException("创建任务时处理 JSON 对象失败"); - } - } - - /** - * 创建任务列表。 - * - * @param tasklist 任务列表对象 - * @throws NetworkFailureException 网络异常 - */ - public void createTaskList(TaskList tasklist) throws NetworkFailureException { - commitUpdate(); - try { - JSONObject jsPost = new JSONObject(); - JSONArray actionList = new JSONArray(); - - // 添加创建任务列表的操作 - actionList.put(tasklist.getCreateAction(getActionId())); - jsPost.put(GTaskStringUtils.GTASK_JSON_ACTION_LIST, actionList); - - // 设置客户端版本 - jsPost.put(GTaskStringUtils.GTASK_JSON_CLIENT_VERSION, mClientVersion); - - // 发送请求 - JSONObject jsResponse = postRequest(jsPost); - JSONObject jsResult = (JSONObject) jsResponse.getJSONArray(GTaskStringUtils.GTASK_JSON_RESULTS).get(0); - tasklist.setGid(jsResult.getString(GTaskStringUtils.GTASK_JSON_NEW_ID)); - - } catch (JSONException e) { - Log.e(TAG, e.toString()); - e.printStackTrace(); - throw new ActionFailureException("创建任务列表时处理 JSON 对象失败"); - } - } - - /** - * 提交更新操作。 - * - * @throws NetworkFailureException 网络异常 - */ - public void commitUpdate() throws NetworkFailureException { - if (mUpdateArray != null) { - try { - JSONObject jsPost = new JSONObject(); - - // 添加更新操作列表 - jsPost.put(GTaskStringUtils.GTASK_JSON_ACTION_LIST, mUpdateArray); - - // 设置客户端版本 - jsPost.put(GTaskStringUtils.GTASK_JSON_CLIENT_VERSION, mClientVersion); - - postRequest(jsPost); - mUpdateArray = null; - } catch (JSONException e) { - Log.e(TAG, e.toString()); - e.printStackTrace(); - throw new ActionFailureException("提交更新时处理 JSON 对象失败"); - } - } - } - - /** - * 添加更新节点。 - * - * @param node 节点对象 - * @throws NetworkFailureException 网络异常 - */ - public void addUpdateNode(Node node) throws NetworkFailureException { - if (node != null) { - // 更新项过多可能导致错误，限制最多 10 个 - if (mUpdateArray != null && mUpdateArray.length() > 10) { - commitUpdate(); - } - - if (mUpdateArray == null) - mUpdateArray = new JSONArray(); - mUpdateArray.put(node.getUpdateAction(getActionId())); - } - } - - /** - * 移动任务。 - * - * @param task 任务对象 - * @param preParent 原父任务列表 - * @param curParent 新父任务列表 - * @throws NetworkFailureException 网络异常 - */ - public void moveTask(Task task, TaskList preParent, TaskList curParent) throws NetworkFailureException { - commitUpdate(); - try { - JSONObject jsPost = new JSONObject(); - JSONArray actionList = new JSONArray(); - JSONObject action = new JSONObject(); - - // 添加移动任务的操作 - action.put(GTaskStringUtils.GTASK_JSON_ACTION_TYPE, GTaskStringUtils.GTASK_JSON_ACTION_TYPE_MOVE); - action.put(GTaskStringUtils.GTASK_JSON_ACTION_ID, getActionId()); - action.put(GTaskStringUtils.GTASK_JSON_ID, task.getGid()); - if (preParent == curParent && task.getPriorSibling() != null) { - // 如果在同一个任务列表内移动且不是第一个任务，则添加前一个兄弟任务 ID - action.put(GTaskStringUtils.GTASK_JSON_PRIOR_SIBLING_ID, task.getPriorSibling()); - } - action.put(GTaskStringUtils.GTASK_JSON_SOURCE_LIST, preParent.getGid()); - action.put(GTaskStringUtils.GTASK_JSON_DEST_PARENT, curParent.getGid()); - if (preParent != curParent) { - // 如果在不同任务列表之间移动，则添加目标任务列表 ID - action.put(GTaskStringUtils.GTASK_JSON_DEST_LIST, curParent.getGid()); - } - actionList.put(action); - - 以下是为 `GTaskClient.java` 文件中选定代码段生成的中文注释： - -```java -/** - * 获取指定任务列表中的所有任务。 - * - * @param listGid 任务列表的全局唯一标识符（GID） - * @return 包含任务的 JSONArray - * @throws NetworkFailureException 网络异常 - */ - public JSONArray getTaskList(String listGid) throws NetworkFailureException { - commitUpdate(); // 提交任何未完成的更新操作 - try { - JSONObject jsPost = new JSONObject(); - JSONArray actionList = new JSONArray(); - JSONObject action = new JSONObject(); - - // 添加获取所有任务的操作到操作列表 - action.put(GTaskStringUtils.GTASK_JSON_ACTION_TYPE, GTaskStringUtils.GTASK_JSON_ACTION_TYPE_GETALL); - action.put(GTaskStringUtils.GTASK_JSON_ACTION_ID, getActionId()); // 获取唯一的操作 ID - action.put(GTaskStringUtils.GTASK_JSON_LIST_ID, listGid); // 设置任务列表 ID - action.put(GTaskStringUtils.GTASK_JSON_GET_DELETED, false); // 不获取已删除的任务 - actionList.put(action); - jsPost.put(GTaskStringUtils.GTASK_JSON_ACTION_LIST, actionList); // 将操作列表添加到请求 JSON 对象 - - // 设置客户端版本 - jsPost.put(GTaskStringUtils.GTASK_JSON_CLIENT_VERSION, mClientVersion); - - // 发送 POST 请求并获取响应 - JSONObject jsResponse = postRequest(jsPost); - return jsResponse.getJSONArray(GTaskStringUtils.GTASK_JSON_TASKS); // 返回任务列表的 JSONArray - } catch (JSONException e) { - Log.e(TAG, e.toString()); - e.printStackTrace(); - throw new ActionFailureException("获取任务列表时处理 JSON 对象失败"); - } - } - -/** - * 获取当前同步的 Google 账户。 - * - * @return 当前同步的 Account 对象 - */ - public Account getSyncAccount() { - return mAccount; - } - -/** - * 重置更新数组，清除所有待提交的更新操作。 - */ - public void resetUpdateArray() { - mUpdateArray = null; - } diff --git a/src/net/micode/notes/gtask/remote/GTaskManager.java b/src/net/micode/notes/gtask/remote/GTaskManager.java deleted file mode 100644 index 227f0ba..0000000 --- a/src/net/micode/notes/gtask/remote/GTaskManager.java +++ /dev/null @@ -1,617 +0,0 @@ - - /* - * 版权所有 (c) 2010-2011, MiCode 开源社区 (www.micode.net) - * - * 根据 Apache License 2.0 许可证授权； - * 除非符合许可证规定，否则不得使用此文件。 - * 您可以从以下网址获取许可证副本： - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * 除非法律要求或书面同意，否则根据许可证分发的软件按“原样”分发， - * 不提供任何明示或暗示的保证或条件。请参阅许可证以了解具体的许可和限制。 - */ - - package net.micode.notes.gtask.remote; - -import android.app.Activity; -import android.content.ContentResolver; -import android.content.ContentUris; -import android.content.ContentValues; -import android.content.Context; -import android.database.Cursor; -import android.util.Log; - -import net.micode.notes.R; -import net.micode.notes.data.Notes; -import net.micode.notes.data.Notes.DataColumns; -import net.micode.notes.data.Notes.NoteColumns; -import net.micode.notes.gtask.data.MetaData; -import net.micode.notes.gtask.data.Node; -import net.micode.notes.gtask.data.Task; -import net.micode.notes.gtask.data.TaskList; -import net.micode.notes.gtask.exception.ActionFailureException; -import net.micode.notes.gtask.exception.NetworkFailureException; -import net.micode.notes.gtask.remote.GTaskASyncTask; -import net.micode.notes.tool.DataUtils; -import net.micode.notes.tool.GTaskStringUtils; - -import org.json.JSONArray; -import org.json.JSONException; -import org.json.JSONObject; - -import java.util.HashMap; -import java.util.HashSet; -import java.util.Iterator; -import java.util.Map; - -/** - * GTaskManager 类负责管理 Google Tasks 的同步操作 - */ -public class GTaskManager { - private static final String TAG = GTaskManager.class.getSimpleName(); - - // 同步状态常量 - public static final int STATE_SUCCESS = 0; // 成功 - public static final int STATE_NETWORK_ERROR = 1; // 网络错误 - public static final int STATE_INTERNAL_ERROR = 2; // 内部错误 - public static final int STATE_SYNC_IN_PROGRESS = 3; // 同步正在进行中 - public static final int STATE_SYNC_CANCELLED = 4; // 同步被取消 - - // 单例模式实例 - private static GTaskManager mInstance = null; - - // 上下文和活动对象 - private Activity mActivity; - private Context mContext; - private ContentResolver mContentResolver; - - // 同步标志 - private boolean mSyncing; - private boolean mCancelled; - - // 数据结构 - private HashMap mGTaskListHashMap; - private HashMap mGTaskHashMap; - private HashMap mMetaHashMap; - private TaskList mMetaList; - private HashSet mLocalDeleteIdMap; - private HashMap mGidToNid; - private HashMap mNidToGid; - - /** - * 构造函数，初始化数据结构。 - */ - private GTaskManager() { - mSyncing = false; - mCancelled = false; - mGTaskListHashMap = new HashMap<>(); - mGTaskHashMap = new HashMap<>(); - mMetaHashMap = new HashMap<>(); - mMetaList = null; - mLocalDeleteIdMap = new HashSet<>(); - mGidToNid = new HashMap<>(); - mNidToGid = new HashMap<>(); - } - - /** - * 获取 GTaskManager 的单例实例。 - * - * @return GTaskManager 实例 - */ - public static synchronized GTaskManager getInstance() { - if (mInstance == null) { - mInstance = new GTaskManager(); - } - return mInstance; - } - - /** - * 设置 Activity 上下文。 - * - * @param activity Activity 对象 - */ - public synchronized void setActivityContext(Activity activity) { - mActivity = activity; - } - - /** - * 执行同步操作。 - * - * @param context 上下文 - * @param asyncTask 异步任务 - * @return 同步状态码 - */ - public int sync(Context context, GTaskASyncTask asyncTask) { - if (mSyncing) { - Log.d(TAG, "同步正在进行中"); - return STATE_SYNC_IN_PROGRESS; - } - mContext = context; - mContentResolver = mContext.getContentResolver(); - mSyncing = true; - mCancelled = false; - - try { - GTaskClient client = GTaskClient.getInstance(); - client.resetUpdateArray(); - - // 登录 Google Tasks - if (!mCancelled && !client.login(mActivity)) { - throw new NetworkFailureException("登录 Google Tasks 失败"); - } - - // 初始化任务列表 - asyncTask.publishProgress(mContext.getString(R.string.sync_progress_init_list)); - initGTaskList(); - - // 执行内容同步 - asyncTask.publishProgress(mContext.getString(R.string.sync_progress_syncing)); - syncContent(); - } catch (NetworkFailureException e) { - Log.e(TAG, e.toString()); - return STATE_NETWORK_ERROR; - } catch (ActionFailureException e) { - Log.e(TAG, e.toString()); - return STATE_INTERNAL_ERROR; - } catch (Exception e) { - Log.e(TAG, e.toString()); - e.printStackTrace(); - return STATE_INTERNAL_ERROR; - } finally { - mGTaskListHashMap.clear(); - mGTaskHashMap.clear(); - mMetaHashMap.clear(); - mLocalDeleteIdMap.clear(); - mGidToNid.clear(); - mNidToGid.clear(); - mSyncing = false; - } - - return mCancelled ? STATE_SYNC_CANCELLED : STATE_SUCCESS; - } - - /** - * 初始化任务列表。 - * - * @throws NetworkFailureException 网络失败异常 - */ - private void initGTaskList() throws NetworkFailureException { - if (mCancelled) return; - GTaskClient client = GTaskClient.getInstance(); - try { - JSONArray jsTaskLists = client.getTaskLists(); - - // 初始化元数据列表 - mMetaList = null; - for (int i = 0; i < jsTaskLists.length(); i++) { - JSONObject object = jsTaskLists.getJSONObject(i); - String gid = object.getString(GTaskStringUtils.GTASK_JSON_ID); - String name = object.getString(GTaskStringUtils.GTASK_JSON_NAME); - - if (name.equals(GTaskStringUtils.MIUI_FOLDER_PREFFIX + GTaskStringUtils.FOLDER_META)) { - mMetaList = new TaskList(); - mMetaList.setContentByRemoteJSON(object); - - // 加载元数据 - JSONArray jsMetas = client.getTaskList(gid); - for (int j = 0; j < jsMetas.length(); j++) { - object = jsMetas.getJSONObject(j); - MetaData metaData = new MetaData(); - metaData.setContentByRemoteJSON(object); - if (metaData.isWorthSaving()) { - mMetaList.addChildTask(metaData); - if (metaData.getGid() != null) { - mMetaHashMap.put(metaData.getRelatedGid(), metaData); - } - } - } - } - } - - // 如果元数据列表不存在，则创建 - if (mMetaList == null) { - mMetaList = new TaskList(); - mMetaList.setName(GTaskStringUtils.MIUI_FOLDER_PREFFIX + GTaskStringUtils.FOLDER_META); - GTaskClient.getInstance().createTaskList(mMetaList); - } - - // 初始化任务列表 - for (int i = 0; i < jsTaskLists.length(); i++) { - JSONObject object = jsTaskLists.getJSONObject(i); - String gid = object.getString(GTaskStringUtils.GTASK_JSON_ID); - String name = object.getString(GTaskStringUtils.GTASK_JSON_NAME); - - if (name.startsWith(GTaskStringUtils.MIUI_FOLDER_PREFFIX) && - !name.equals(GTaskStringUtils.MIUI_FOLDER_PREFFIX + GTaskStringUtils.FOLDER_META)) { - TaskList tasklist = new TaskList(); - tasklist.setContentByRemoteJSON(object); - mGTaskListHashMap.put(gid, tasklist); - mGTaskHashMap.put(gid, tasklist); - - // 加载任务 - JSONArray jsTasks = client.getTaskList(gid); - for (int j = 0; j < jsTasks.length(); j++) { - object = jsTasks.getJSONObject(j); - gid = object.getString(GTaskStringUtils.GTASK_JSON_ID); - Task task = new Task(); - task.setContentByRemoteJSON(object); - if (task.isWorthSaving()) { - task.setMetaInfo(mMetaHashMap.get(gid)); - tasklist.addChildTask(task); - mGTaskHashMap.put(gid, task); - } - } - } - } - } catch (JSONException e) { - Log.e(TAG, e.toString()); - e.printStackTrace(); - throw new ActionFailureException("处理 JSONObject 失败"); - } - } - - /** - * 执行内容同步。 - * - * @throws NetworkFailureException 网络失败异常 - */ - private void syncContent() throws NetworkFailureException { - int syncType; - Cursor c = null; - String gid; - Node node; - - mLocalDeleteIdMap.clear(); - - if (mCancelled) return; - - // 同步已删除的本地笔记 - try { - c = mContentResolver.query(Notes.CONTENT_NOTE_URI, SqlNote.PROJECTION_NOTE, - "(type<>? AND parent_id=?)", new String[]{ - String.valueOf(Notes.TYPE_SYSTEM), String.valueOf(Notes.ID_TRASH_FOLER) - }, null); - if (c != null) { - while (c.moveToNext()) { - gid = c.getString(SqlNote.GTASK_ID_COLUMN); - node = mGTaskHashMap.get(gid); - if (node != null) { - mGTaskHashMap.remove(gid); - doContentSync(Node.SYNC_ACTION_DEL_REMOTE, node, c); - } - mLocalDeleteIdMap.add(c.getLong(SqlNote.ID_COLUMN)); - } - } else { - Log.w(TAG, "查询回收站文件夹失败"); - } - } finally { - if (c != null) { - c.close(); - c = null; - } - } - - // 同步文件夹 - syncFolder(); - - // 同步数据库中存在的笔记 - try { - c = mContentResolver.query(Notes.CONTENT_NOTE_URI, SqlNote.PROJECTION_NOTE, - "(type=? AND parent_id<>?)", new String[]{ - String.valueOf(Notes.TYPE_NOTE), String.valueOf(Notes.ID_TRASH_FOLER) - }, NoteColumns.TYPE + " DESC"); - if (c != null) { - while (c.moveToNext()) { - gid = c.getString(SqlNote.GTASK_ID_COLUMN); - node = mGTaskHashMap.get(gid); - if (node != null) { - mGTaskHashMap.remove(gid); - mGidToNid.put(gid, c.getLong(SqlNote.ID_COLUMN)); - mNidToGid.put(c.getLong(SqlNote.ID_COLUMN), gid); - syncType = node.getSyncAction(c); - } else { - if (c.getString(SqlNote.GTASK_ID_COLUMN).trim().length() == 0) { - // 本地添加 - syncType = Node.SYNC_ACTION_ADD_REMOTE; - } else { - // 远程删除 - syncType = Node.SYNC_ACTION_DEL_LOCAL; - } - } - doContentSync(syncType, node, c); - } - } else { - Log.w(TAG, "查询数据库中现有笔记失败"); - } - } finally { - if (c != null) { - c.close(); - c = null; - } - } - - // 处理剩余项目 - Iterator> iter = mGTaskHashMap.entrySet().iterator(); - while (iter.hasNext()) { - Map.Entry entry = iter.next(); - node = entry.getValue(); - doContentSync(Node.SYNC_ACTION_ADD_LOCAL, node, null); - } - - // 清除本地删除表 - if (!mCancelled && !DataUtils.batchDeleteNotes(mContentResolver, mLocalDeleteIdMap)) { - throw new ActionFailureException("批量删除本地已删除笔记失败"); - } - - // 刷新本地同步 ID - if (!mCancelled) { - GTaskClient.getInstance().commitUpdate(); - refreshLocalSyncId(); - } - } - - /** - * 同步文件夹。 - * - * @throws NetworkFailureException 网络失败异常 - */ - private void syncFolder() throws NetworkFailureException { - Cursor c = null; - String gid; - Node node; - int syncType; - - if (mCancelled) return; - - // 同步根文件夹 - try { - c = mContentResolver.query(ContentUris.withAppendedId(Notes.CONTENT_NOTE_URI, - Notes.ID_ROOT_FOLDER), SqlNote.PROJECTION_NOTE, null, null, null); - if (c != null) { - c.moveToNext(); - gid = c.getString(SqlNote.GTASK_ID_COLUMN); - node = mGTaskHashMap.get(gid); - if (node != null) { - mGTaskHashMap.remove(gid); - mGidToNid.put(gid, (long) Notes.ID_ROOT_FOLDER); - mNidToGid.put((long) Notes.ID_ROOT_FOLDER, gid); - // 只有在必要时更新远程名称 - if (!node.getName().equals( - GTaskStringUtils.MIUI_FOLDER_PREFFIX + GTaskStringUtils.FOLDER_DEFAULT)) - doContentSync(Node.SYNC_ACTION_UPDATE_REMOTE, node, c); - } else { - doContentSync(Node.SYNC_ACTION_ADD_REMOTE, node, c); - } - } else { - Log.w(TAG, "查询根文件夹失败"); - } - } finally { - if (c != null) { - c.close(); - c = null; - } - } - - // 同步通话记录文件夹 - try { - c = mContentResolver.query(Notes.CONTENT_NOTE_URI, SqlNote.PROJECTION_NOTE, "(_id=?)", - new String[]{String.valueOf(Notes.ID_CALL_RECORD_FOLDER)}, null); - if (c != null) { - if (c.moveToNext()) { - gid = c.getString(SqlNote.GTASK_ID_COLUMN); - node = mGTaskHashMap.get(gid); - if (node != null) { - mGTaskHashMap.remove(gid); - mGidToNid.put(gid, (long) Notes.ID_CALL_RECORD_FOLDER); - mNidToGid.put((long) Notes.ID_CALL_RECORD_FOLDER, gid); - // 只有在必要时更新远程名称 - if (!node.getName().equals( - GTaskStringUtils.MIUI_FOLDER_PREFFIX + GTaskStringUtils.FOLDER_CALL_NOTE)) - doContentSync(Node.SYNC_ACTION_UPDATE_REMOTE, node, c); - } else { - doContentSync(Node.SYNC_ACTION_ADD_REMOTE, node, c); - } - } - } else { - Log.w(TAG, "查询通话记录文件夹失败"); - } - } finally { - if (c != null) { - c.close(); - c = null; - } - } - - // 同步本地存在的文件夹 - try { - c = mContentResolver.query(Notes.CONTENT_NOTE_URI, SqlNote.PROJECTION_NOTE, - "(type=? AND parent_id<>?)", new String[]{ - String.valueOf(Notes.TYPE_FOLDER), String.valueOf(Notes.ID_TRASH_FOLER) - }, NoteColumns.TYPE + " DESC"); - if (c != null) { - while (c.moveToNext()) { - gid = c.getString(SqlNote.GTASK_ID_COLUMN); - node = mGTaskHashMap.get(gid); - if (node != null) { - mGTaskHashMap.remove(gid); - mGidToNid.put(gid, c.getLong(SqlNote.ID_COLUMN)); - mNidToGid.put(c.getLong(SqlNote.ID_COLUMN), gid); - syncType = node.getSyncAction(c); - } else { - if (c.getString(SqlNote.GTASK_ID_COLUMN).trim().length() == 0) { - // 本地添加 - syncType = Node.SYNC_ACTION_ADD_REMOTE; - } else { - // 远程删除 - syncType = Node.SYNC_ACTION_DEL_LOCAL; - } - } - doContentSync(syncType, node, c); - } - } else { - Log.w(TAG, "查询现有文件夹失败"); - } - } finally { - if (c != null) { - c.close(); - c = null; - } - } - - // 同步远程添加的文件夹 - Iterator> iter = mGTaskListHashMap.entrySet().iterator(); - while (iter.hasNext()) { - Map.Entry entry = iter.next(); - gid = entry.getKey(); - node = entry.getValue(); - if (mGTaskHashMap.containsKey(gid)) { - mGTaskHashMap.remove(gid); - doContentSync(Node.SYNC_ACTION_ADD_LOCAL, node, null); - } - } - - if (!mCancelled) - GTaskClient.getInstance().commitUpdate(); - } - - /** - * 执行内容同步操作。 - * - * @param syncType 同步类型 - * @param node 节点对象 - * @param c 游标对象 - * @throws NetworkFailureException 网络失败异常 - */ - private void doContentSync(int syncType, Node node, Cursor c) throws NetworkFailureException { - if (mCancelled) return; - - MetaData meta; - switch (syncType) { - case Node.SYNC_ACTION_ADD_LOCAL: - addLocalNode(node); - break; - case Node.SYNC_ACTION_ADD_REMOTE: - addRemoteNode(node, c); - break; - case Node.SYNC_ACTION_DEL_LOCAL: - meta = mMetaHashMap.get(c.getString(SqlNote.GTASK_ID_COLUMN)); - if (meta != null) { - GTaskClient.getInstance().deleteNode(meta); - } - mLocalDeleteIdMap.add(c.getLong(SqlNote.ID_COLUMN)); - break; - case Node.SYNC_ACTION_DEL_REMOTE: - meta = mMetaHashMap.get(node.getGid()); - if (meta != null) { - GTaskClient.getInstance().deleteNode(meta); - } - GTaskClient.getInstance().deleteNode(node); - break; - case Node.SYNC_ACTION_UPDATE_LOCAL: - updateLocalNode(node, c); - break; - case Node.SYNC_ACTION_UPDATE_REMOTE: - updateRemoteNode(node, c); - break; - case Node.SYNC_ACTION_UPDATE_CONFLICT: - // 合并冲突可能是个好主意 - // 目前只是简单地使用本地更新 - updateRemoteNode(node, c); - break; - case Node.SYNC_ACTION_NONE: - break; - case Node.SYNC_ACTION_ERROR: - 以下是为 `GTaskManager.java`文件中部分方法生成的中文注释： - -```java -/** - * 添加本地节点到数据库中。 - * - * 该方法负责将同步接收到的远程节点添加到本地数据库中。它会根据节点类型（任务列表或任务）进行不同的处理： - * - 对于任务列表，会检查其名称并设置相应的父ID。 - * - 对于任务，会解析JSON内容，确保ID唯一性，并设置正确的父ID。 - * 最后，创建本地记录并更新GID-NID映射关系。 - * - * @param node 要添加的节点 - * @throws NetworkFailureException 如果发生网络错误 - */ - private void addLocalNode (Node node) throws NetworkFailureException { - // 方法实现... - } - -/** - * 更新本地节点信息。 - * - * 该方法用于更新已存在的本地节点信息。它会根据节点类型（任务列表或任务）进行不同的处理： - * - 对于任务，会更新其内容和父ID。 - * - 对于任务列表，会跳过已经存在的文件夹。 - * 最后，更新本地记录并更新GID-NID映射关系。 - * - * @param node 要更新的节点 - * @param c 数据库游标 - * @throws NetworkFailureException 如果发生网络错误 - */ - private void updateLocalNode (Node node, Cursor c) throws NetworkFailureException { - // 方法实现... - } - -/** - * 添加远程节点到服务器。 - * - * 该方法负责将本地创建的节点同步到远程服务器。它会根据节点类型（任务列表或任务）进行不同的处理： - * - 对于任务，会创建新的任务并添加到对应的任务列表中。 - * - 对于任务列表，会检查是否已存在同名文件夹，若不存在则创建新的任务列表。 - * 最后，更新本地记录并更新GID-NID映射关系。 - * - * @param node 要添加的节点 - * @param c 数据库游标 - * @throws NetworkFailureException 如果发生网络错误 - */ - private void addRemoteNode (Node node, Cursor c) throws NetworkFailureException { - // 方法实现... - } - -/** - * 更新远程节点信息。 - * - * 该方法用于更新远程节点的信息。它会根据节点类型（任务列表或任务）进行不同的处理： - * - 对于任务，会更新其内容，并在需要时移动任务到新的任务列表。 - * - 对于任务列表，会更新其内容。 - * 最后，清除本地修改标志并提交更改。 - * - * @param node 要更新的节点 - * @param c 数据库游标 - * @throws NetworkFailureException 如果发生网络错误 - */ - private void updateRemoteNode (Node node, Cursor c) throws NetworkFailureException { - // 方法实现... - } - -/** - * 更新远程元数据。 - * - * 该方法负责更新与节点关联的元数据信息。如果元数据存在，则更新其内容；如果不存在，则创建新的元数据记录。 - * - * @param gid 节点的全局ID - * @param sqlNote SQL记录对象 - * @throws NetworkFailureException 如果发生网络错误 - */ - private void updateRemoteMeta (String gid, SqlNote sqlNote) throws NetworkFailureException { - // 方法实现... - } - -/** - * 刷新本地同步ID。 - * - * 该方法会查询本地数据库中的所有记录，并根据最新的远程节点信息刷新每个记录的同步ID。 - * 如果发现任何不匹配的情况，会抛出异常。 - * - * @throws NetworkFailureException 如果发生网络错误 - */ - private void refreshLocalSyncId () throws NetworkFailureException { - // 方法实现... - } - } - } -} \ No newline at end of file diff --git a/src/net/micode/notes/gtask/remote/GTaskSyncService.java b/src/net/micode/notes/gtask/remote/GTaskSyncService.java deleted file mode 100644 index e078f50..0000000 --- a/src/net/micode/notes/gtask/remote/GTaskSyncService.java +++ /dev/null @@ -1,212 +0,0 @@ - - /* - * 版权所有 (c) 2010-2011, MiCode 开源社区 (www.micode.net) - * - * 本文件根据 Apache License 2.0 许可证授权。您可以在以下网址获取许可证副本： - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * 除非法律要求或书面同意，否则根据此许可证分发的软件均为“按原样”分发， - * 不附带任何明示或暗示的担保或条件。请参阅许可证以了解具体的权限和限制。 - */ - - package net.micode.notes.gtask.remote; - -import android.app.Activity; -import android.app.Service; -import android.content.Context; -import android.content.Intent; -import android.os.Bundle; -import android.os.IBinder; -import net.micode.notes.gtask.remote.GTaskASyncTask; - -/** - * GTask 同步服务类。 - * - * 该服务负责处理与 GTask 相关的同步操作，包括启动同步、取消同步以及广播同步状态 - */ -public class GTaskSyncService extends Service { - /** - * 同步操作类型的动作字符串名称。 - */ - public final static String ACTION_STRING_NAME = "sync_action_type"; - - /** - * 启动同步操作的代码。 - */ - public final static int ACTION_START_SYNC = 0; - - /** - * 取消同步操作的代码。 - */ - public final static int ACTION_CANCEL_SYNC = 1; - - /** - * 无效操作的代码。 - */ - public final static int ACTION_INVALID = 2; - - /** - * 广播名称，用于发送同步状态更新。 - */ - public final static String GTASK_SERVICE_BROADCAST_NAME = "net.micode.notes.gtask.remote.gtask_sync_service"; - - /** - * 广播键，表示是否正在进行同步。 - */ - public final static String GTASK_SERVICE_BROADCAST_IS_SYNCING = "isSyncing"; - - /** - * 广播键，表示同步进度信息。 - */ - public final static String GTASK_SERVICE_BROADCAST_PROGRESS_MSG = "progressMsg"; - - /** - * 当前正在执行的同步任务实例。 - */ - private static GTaskASyncTask mSyncTask = null; - - /** - * 同步进度信息。 - */ - private static String mSyncProgress = ""; - - /** - * 启动同步操作。 - */ - private void startSync() { - if (mSyncTask == null) { - mSyncTask = new GTaskASyncTask(this, new GTaskASyncTask.OnCompleteListener() { - /** - * 同步完成时调用。 - */ - public void onComplete() { - mSyncTask = null; - sendBroadcast(""); - stopSelf(); - } - }); - sendBroadcast(""); - mSyncTask.execute(); - } - } - - /** - * 取消同步操作。 - */ - private void cancelSync() { - if (mSyncTask != null) { - mSyncTask.cancelSync(); - } - } - - /** - * 服务创建时调用。 - */ - @Override - public void onCreate() { - mSyncTask = null; - } - - /** - * 服务启动时调用。 - * - * 根据传入的 Intent 中的操作类型，决定是启动同步还是取消同步。 - */ - @Override - public int onStartCommand(Intent intent, int flags, int startId) { - Bundle bundle = intent.getExtras(); - if (bundle != null && bundle.containsKey(ACTION_STRING_NAME)) { - switch (bundle.getInt(ACTION_STRING_NAME, ACTION_INVALID)) { - case ACTION_START_SYNC: - startSync(); - break; - case ACTION_CANCEL_SYNC: - cancelSync(); - break; - default: - break; - } - return START_STICKY; - } - return super.onStartCommand(intent, flags, startId); - } - - /** - * 内存不足时调用。 - * - * 如果有正在进行的同步任务，则取消同步。 - */ - @Override - public void onLowMemory() { - if (mSyncTask != null) { - mSyncTask.cancelSync(); - } - } - - /** - * 绑定到服务时调用。 - * - * 该服务不支持绑定，因此返回 null。 - */ - public IBinder onBind(Intent intent) { - return null; - } - - /** - * 发送广播通知同步状态。 - * - * @param msg 进度信息字符串 - */ - public void sendBroadcast(String msg) { - mSyncProgress = msg; - Intent intent = new Intent(GTASK_SERVICE_BROADCAST_NAME); - intent.putExtra(GTASK_SERVICE_BROADCAST_IS_SYNCING, mSyncTask != null); - intent.putExtra(GTASK_SERVICE_BROADCAST_PROGRESS_MSG, msg); - sendBroadcast(intent); - } - - /** - * 静态方法，用于从 Activity 启动同步操作。 - * - * @param activity 调用此方法的 Activity 实例 - */ - public static void startSync(Activity activity) { - GTaskManager.getInstance().setActivityContext(activity); - Intent intent = new Intent(activity, GTaskSyncService.class); - intent.putExtra(GTaskSyncService.ACTION_STRING_NAME, GTaskSyncService.ACTION_START_SYNC); - activity.startService(intent); - } - - /** - * 静态方法，用于取消同步操作。 - * - * @param context 上下文对象 - */ - public static void cancelSync(Context context) { - Intent intent = new Intent(context, GTaskSyncService.class); - intent.putExtra(GTaskSyncService.ACTION_STRING_NAME, GTaskSyncService.ACTION_CANCEL_SYNC); - context.startService(intent); - } - - /** - * 检查当前是否正在进行同步操作。 - * - * @return 如果有同步任务在进行则返回 true，否则返回 false - */ - public static boolean isSyncing() { - return mSyncTask != null; - } - - /** - * 获取当前同步进度信息。 - * - * @return 同步进度信息字符串 - */ - public static String getProgressString() { - return mSyncProgress; - } -} - - -