|
|
|
|
@ -46,47 +46,59 @@ 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;
|
|
|
|
|
|
|
|
|
|
// 单例模式，存储唯一的GTaskManager实例，初始化为null
|
|
|
|
|
private static GTaskManager mInstance = null;
|
|
|
|
|
|
|
|
|
|
// 用于获取认证令牌等相关操作的Activity对象，可在不同的同步相关操作中使用，例如登录时获取账户认证信息等
|
|
|
|
|
|
|
|
|
|
private Activity mActivity;
|
|
|
|
|
|
|
|
|
|
// 应用上下文对象，用于获取内容解析器（ContentResolver）等系统服务，方便与本地数据库等进行交互操作
|
|
|
|
|
|
|
|
|
|
private Context mContext;
|
|
|
|
|
|
|
|
|
|
// 用于与本地内容提供者（Content Provider）进行交互，实现对本地数据（如数据库中的笔记、任务等相关数据）的查询、更新等操作
|
|
|
|
|
private ContentResolver mContentResolver;
|
|
|
|
|
|
|
|
|
|
// 标记当前是否正在进行同步操作，初始化为false，在同步开始时设置为true，结束时设置为false
|
|
|
|
|
private boolean mSyncing;
|
|
|
|
|
|
|
|
|
|
// 标记当前同步操作是否已被取消，初始化为false，可通过相应方法设置为true来取消正在进行的同步过程
|
|
|
|
|
private boolean mCancelled;
|
|
|
|
|
// 以任务列表的全局唯一标识符（Gid）为键，存储任务列表对象的哈希映射，用于缓存从远程获取的任务列表信息以及在同步过程中管理本地和远程任务列表的对应关系
|
|
|
|
|
|
|
|
|
|
private HashMap<String, TaskList> mGTaskListHashMap;
|
|
|
|
|
|
|
|
|
|
// 以节点（任务、任务列表、元数据等都可视为节点，通过共同的父类Node进行抽象）的Gid为键，存储节点对象的哈希映射，方便在同步过程中快速查找和操作各个节点
|
|
|
|
|
|
|
|
|
|
private HashMap<String, Node> mGTaskHashMap;
|
|
|
|
|
|
|
|
|
|
// 以相关Gid为键，存储元数据（MetaData）对象的哈希映射，用于管理和跟踪与任务等相关的元数据信息，例如可能包含一些额外的描述、配置等数据
|
|
|
|
|
|
|
|
|
|
private HashMap<String, MetaData> mMetaHashMap;
|
|
|
|
|
|
|
|
|
|
// 用于存储特殊的元数据列表（可能是具有特定用途、结构的元数据集合），初始化为null，在同步过程中根据情况进行创建和填充
|
|
|
|
|
|
|
|
|
|
private TaskList mMetaList;
|
|
|
|
|
|
|
|
|
|
// 用于存储本地已删除的任务或数据对应的唯一标识符（可能是本地数据库中的主键等），通过哈希集合来避免重复记录，方便后续统一处理删除相关逻辑
|
|
|
|
|
|
|
|
|
|
private HashSet<Long> mLocalDeleteIdMap;
|
|
|
|
|
|
|
|
|
|
// 以节点的Gid为键，存储对应本地唯一标识符（如数据库中的记录ID）的哈希映射，用于建立远程节点Gid和本地数据ID之间的对应关系，便于同步时查找和关联数据
|
|
|
|
|
|
|
|
|
|
private HashMap<String, Long> mGidToNid;
|
|
|
|
|
|
|
|
|
|
// 以本地唯一标识符为键，存储对应节点Gid的哈希映射，与mGidToNid作用类似，是反向的映射关系，用于在不同的同步操作场景下根据需要进行查找和转换
|
|
|
|
|
|
|
|
|
|
private HashMap<Long, String> mNidToGid;
|
|
|
|
|
|
|
|
|
|
// 私有构造函数，用于初始化GTaskManager类的各个成员变量，采用单例模式，限制外部直接实例化该类，在这里初始化了各种用于存储数据和管理同步状态的集合、映射等变量。
|
|
|
|
|
|
|
|
|
|
private GTaskManager() {
|
|
|
|
|
mSyncing = false;
|
|
|
|
|
mCancelled = false;
|
|
|
|
|
@ -98,6 +110,7 @@ public class GTaskManager {
|
|
|
|
|
mGidToNid = new HashMap<String, Long>();
|
|
|
|
|
mNidToGid = new HashMap<Long, String>();
|
|
|
|
|
}
|
|
|
|
|
// 静态方法，用于获取GTaskManager的单例实例，如果实例不存在则创建一个新的实例，保证整个应用中只有一个GTaskManager对象在管理任务同步等相关操作
|
|
|
|
|
|
|
|
|
|
public static synchronized GTaskManager getInstance() {
|
|
|
|
|
if (mInstance == null) {
|
|
|
|
|
@ -105,12 +118,16 @@ public class GTaskManager {
|
|
|
|
|
}
|
|
|
|
|
return mInstance;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 用于设置关联的Activity上下文对象的方法，主要是为了后续在需要获取认证令牌等与Activity相关的操作时能够获取到相应的上下文环境，
|
|
|
|
|
// 该方法是同步的，以保证在多线程环境下设置上下文对象的操作的原子性和一致性。
|
|
|
|
|
public synchronized void setActivityContext(Activity activity) {
|
|
|
|
|
// used for getting authtoken
|
|
|
|
|
mActivity = activity;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 执行同步操作的核心方法，负责协调本地数据和远程数据的同步过程，首先检查是否正在同步，如果正在同步则直接返回相应状态码，
|
|
|
|
|
// 然后初始化一系列用于同步的数据结构，进行登录操作（通过GTaskClient），获取远程任务列表，执行具体的内容同步逻辑（包括处理本地删除、新增、更新等不同情况的同步），
|
|
|
|
|
// 最后根据同步过程中的各种情况（如是否取消、是否出现异常等）返回对应的同步状态码，并且在finally块中清理相关的数据结构，重置同步状态。
|
|
|
|
|
|
|
|
|
|
public int sync(Context context, GTaskASyncTask asyncTask) {
|
|
|
|
|
if (mSyncing) {
|
|
|
|
|
Log.d(TAG, "Sync is in progress");
|
|
|
|
|
@ -130,18 +147,18 @@ public class GTaskManager {
|
|
|
|
|
try {
|
|
|
|
|
GTaskClient client = GTaskClient.getInstance();
|
|
|
|
|
client.resetUpdateArray();
|
|
|
|
|
|
|
|
|
|
// 登录Google任务服务
|
|
|
|
|
// login google task
|
|
|
|
|
if (!mCancelled) {
|
|
|
|
|
if (!client.login(mActivity)) {
|
|
|
|
|
throw new NetworkFailureException("login google task failed");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 获取Google任务列表
|
|
|
|
|
// get the task list from google
|
|
|
|
|
asyncTask.publishProgess(mContext.getString(R.string.sync_progress_init_list));
|
|
|
|
|
initGTaskList();
|
|
|
|
|
|
|
|
|
|
// 执行内容同步工作
|
|
|
|
|
// do content sync work
|
|
|
|
|
asyncTask.publishProgess(mContext.getString(R.string.sync_progress_syncing));
|
|
|
|
|
syncContent();
|
|
|
|
|
@ -167,14 +184,16 @@ public class GTaskManager {
|
|
|
|
|
|
|
|
|
|
return mCancelled ? STATE_SYNC_CANCELLED : STATE_SUCCESS;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 初始化远程任务列表相关数据的私有方法，首先检查同步是否已取消，如果取消则直接返回，然后通过GTaskClient获取远程任务列表的JSON数据，
|
|
|
|
|
// 接着分别处理元数据列表（如果不存在则创建）以及普通任务列表，解析JSON数据创建对应的任务列表和任务对象，并建立相关的映射关系（如将任务列表、任务等存入对应的哈希映射中），
|
|
|
|
|
// 若在处理JSON数据过程中出现异常则抛出相应异常表示初始化任务列表失败。
|
|
|
|
|
private void initGTaskList() throws NetworkFailureException {
|
|
|
|
|
if (mCancelled)
|
|
|
|
|
return;
|
|
|
|
|
GTaskClient client = GTaskClient.getInstance();
|
|
|
|
|
try {
|
|
|
|
|
JSONArray jsTaskLists = client.getTaskLists();
|
|
|
|
|
|
|
|
|
|
// 首先初始化元数据列表
|
|
|
|
|
// init meta list first
|
|
|
|
|
mMetaList = null;
|
|
|
|
|
for (int i = 0; i < jsTaskLists.length(); i++) {
|
|
|
|
|
@ -186,7 +205,7 @@ public class GTaskManager {
|
|
|
|
|
.equals(GTaskStringUtils.MIUI_FOLDER_PREFFIX + GTaskStringUtils.FOLDER_META)) {
|
|
|
|
|
mMetaList = new TaskList();
|
|
|
|
|
mMetaList.setContentByRemoteJSON(object);
|
|
|
|
|
|
|
|
|
|
// 加载元数据
|
|
|
|
|
// load meta data
|
|
|
|
|
JSONArray jsMetas = client.getTaskList(gid);
|
|
|
|
|
for (int j = 0; j < jsMetas.length(); j++) {
|
|
|
|
|
@ -202,7 +221,7 @@ public class GTaskManager {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 如果元数据列表不存在则创建它
|
|
|
|
|
// create meta list if not existed
|
|
|
|
|
if (mMetaList == null) {
|
|
|
|
|
mMetaList = new TaskList();
|
|
|
|
|
@ -210,7 +229,7 @@ public class GTaskManager {
|
|
|
|
|
+ GTaskStringUtils.FOLDER_META);
|
|
|
|
|
GTaskClient.getInstance().createTaskList(mMetaList);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 初始化任务列表
|
|
|
|
|
// init task list
|
|
|
|
|
for (int i = 0; i < jsTaskLists.length(); i++) {
|
|
|
|
|
JSONObject object = jsTaskLists.getJSONObject(i);
|
|
|
|
|
@ -224,7 +243,7 @@ public class GTaskManager {
|
|
|
|
|
tasklist.setContentByRemoteJSON(object);
|
|
|
|
|
mGTaskListHashMap.put(gid, tasklist);
|
|
|
|
|
mGTaskHashMap.put(gid, tasklist);
|
|
|
|
|
|
|
|
|
|
// 加载任务
|
|
|
|
|
// load tasks
|
|
|
|
|
JSONArray jsTasks = client.getTaskList(gid);
|
|
|
|
|
for (int j = 0; j < jsTasks.length(); j++) {
|
|
|
|
|
@ -246,7 +265,9 @@ public class GTaskManager {
|
|
|
|
|
throw new ActionFailureException("initGTaskList: handing JSONObject failed");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 执行具体内容同步的私有方法，负责协调本地和远程数据在内容层面的同步操作，包括处理本地已删除的笔记、文件夹同步、数据库中现有笔记的同步等多种情况，
|
|
|
|
|
// 在不同的同步场景下调用相应的辅助方法（如doContentSync）来执行具体的添加、删除、更新等操作，并且在合适的时机提交更新到远程（通过GTaskClient）以及清理本地删除记录等操作，
|
|
|
|
|
// 整个过程中会不断检查同步是否已被取消，若已取消则及时终止操作。
|
|
|
|
|
private void syncContent() throws NetworkFailureException {
|
|
|
|
|
int syncType;
|
|
|
|
|
Cursor c = null;
|
|
|
|
|
@ -258,7 +279,7 @@ public class GTaskManager {
|
|
|
|
|
if (mCancelled) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 处理本地已删除的笔记
|
|
|
|
|
// for local deleted note
|
|
|
|
|
try {
|
|
|
|
|
c = mContentResolver.query(Notes.CONTENT_NOTE_URI, SqlNote.PROJECTION_NOTE,
|
|
|
|
|
@ -285,10 +306,10 @@ public class GTaskManager {
|
|
|
|
|
c = null;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 同步文件夹
|
|
|
|
|
// sync folder first
|
|
|
|
|
syncFolder();
|
|
|
|
|
|
|
|
|
|
// 处理数据库中已存在的笔记
|
|
|
|
|
// for note existing in database
|
|
|
|
|
try {
|
|
|
|
|
c = mContentResolver.query(Notes.CONTENT_NOTE_URI, SqlNote.PROJECTION_NOTE,
|
|
|
|
|
@ -306,9 +327,11 @@ public class GTaskManager {
|
|
|
|
|
syncType = node.getSyncAction(c);
|
|
|
|
|
} else {
|
|
|
|
|
if (c.getString(SqlNote.GTASK_ID_COLUMN).trim().length() == 0) {
|
|
|
|
|
// 本地新增
|
|
|
|
|
// local add
|
|
|
|
|
syncType = Node.SYNC_ACTION_ADD_REMOTE;
|
|
|
|
|
} else {
|
|
|
|
|
// 远程已删除
|
|
|
|
|
// remote delete
|
|
|
|
|
syncType = Node.SYNC_ACTION_DEL_LOCAL;
|
|
|
|
|
}
|
|
|
|
|
@ -325,7 +348,7 @@ public class GTaskManager {
|
|
|
|
|
c = null;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 处理剩余的项目（可能是本地新增但还未处理完全的等情况）
|
|
|
|
|
// go through remaining items
|
|
|
|
|
Iterator<Map.Entry<String, Node>> iter = mGTaskHashMap.entrySet().iterator();
|
|
|
|
|
while (iter.hasNext()) {
|
|
|
|
|
@ -333,16 +356,16 @@ public class GTaskManager {
|
|
|
|
|
node = entry.getValue();
|
|
|
|
|
doContentSync(Node.SYNC_ACTION_ADD_LOCAL, node, null);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// mCancelled可以被其他线程设置，所以我们需要逐个检查
|
|
|
|
|
// mCancelled can be set by another thread, so we neet to check one by
|
|
|
|
|
// one
|
|
|
|
|
// one // 清除本地删除表（如果同步未取消）
|
|
|
|
|
// clear local delete table
|
|
|
|
|
if (!mCancelled) {
|
|
|
|
|
if (!DataUtils.batchDeleteNotes(mContentResolver, mLocalDeleteIdMap)) {
|
|
|
|
|
throw new ActionFailureException("failed to batch-delete local deleted notes");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 刷新本地同步ID（如果同步未取消）
|
|
|
|
|
// refresh local sync id
|
|
|
|
|
if (!mCancelled) {
|
|
|
|
|
GTaskClient.getInstance().commitUpdate();
|
|
|
|
|
@ -350,7 +373,9 @@ public class GTaskManager {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 专门用于文件夹同步的私有方法，处理各种不同类型的文件夹（如根文件夹、通话记录文件夹、本地已存在的文件夹以及远程新增的文件夹等）的同步逻辑，
|
|
|
|
|
// 在不同情况下判断文件夹在本地和远程的存在情况，调用相应的辅助方法（如doContentSync）来执行添加、更新等操作，并且在合适的时机提交更新到远程（通过GTaskClient），
|
|
|
|
|
// 整个过程中会不断检查同步是否已被取消，若已取消则及时终止操作。
|
|
|
|
|
private void syncFolder() throws NetworkFailureException {
|
|
|
|
|
Cursor c = null;
|
|
|
|
|
String gid;
|
|
|
|
|
@ -360,7 +385,7 @@ public class GTaskManager {
|
|
|
|
|
if (mCancelled) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 处理根文件夹
|
|
|
|
|
// for root folder
|
|
|
|
|
try {
|
|
|
|
|
c = mContentResolver.query(ContentUris.withAppendedId(Notes.CONTENT_NOTE_URI,
|
|
|
|
|
@ -373,6 +398,7 @@ public class GTaskManager {
|
|
|
|
|
mGTaskHashMap.remove(gid);
|
|
|
|
|
mGidToNid.put(gid, (long) Notes.ID_ROOT_FOLDER);
|
|
|
|
|
mNidToGid.put((long) Notes.ID_ROOT_FOLDER, gid);
|
|
|
|
|
// 对于系统文件夹，仅在必要时更新远程名称
|
|
|
|
|
// for system folder, only update remote name if necessary
|
|
|
|
|
if (!node.getName().equals(
|
|
|
|
|
GTaskStringUtils.MIUI_FOLDER_PREFFIX + GTaskStringUtils.FOLDER_DEFAULT))
|
|
|
|
|
@ -389,7 +415,7 @@ public class GTaskManager {
|
|
|
|
|
c = null;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 处理通话记录文件夹
|
|
|
|
|
// for call-note folder
|
|
|
|
|
try {
|
|
|
|
|
c = mContentResolver.query(Notes.CONTENT_NOTE_URI, SqlNote.PROJECTION_NOTE, "(_id=?)",
|
|
|
|
|
@ -404,6 +430,7 @@ public class GTaskManager {
|
|
|
|
|
mGTaskHashMap.remove(gid);
|
|
|
|
|
mGidToNid.put(gid, (long) Notes.ID_CALL_RECORD_FOLDER);
|
|
|
|
|
mNidToGid.put((long) Notes.ID_CALL_RECORD_FOLDER, gid);
|
|
|
|
|
// 对于系统文件夹，仅在必要时更新远程名称
|
|
|
|
|
// for system folder, only update remote name if
|
|
|
|
|
// necessary
|
|
|
|
|
if (!node.getName().equals(
|
|
|
|
|
@ -423,7 +450,7 @@ public class GTaskManager {
|
|
|
|
|
c = null;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 处理本地已存在的文件夹
|
|
|
|
|
// for local existing folders
|
|
|
|
|
try {
|
|
|
|
|
c = mContentResolver.query(Notes.CONTENT_NOTE_URI, SqlNote.PROJECTION_NOTE,
|
|
|
|
|
@ -441,9 +468,11 @@ public class GTaskManager {
|
|
|
|
|
syncType = node.getSyncAction(c);
|
|
|
|
|
} else {
|
|
|
|
|
if (c.getString(SqlNote.GTASK_ID_COLUMN).trim().length() == 0) {
|
|
|
|
|
// 本地新增
|
|
|
|
|
// local add
|
|
|
|
|
syncType = Node.SYNC_ACTION_ADD_REMOTE;
|
|
|
|
|
} else {
|
|
|
|
|
// 远程已删除
|
|
|
|
|
// remote delete
|
|
|
|
|
syncType = Node.SYNC_ACTION_DEL_LOCAL;
|
|
|
|
|
}
|
|
|
|
|
@ -459,7 +488,7 @@ public class GTaskManager {
|
|
|
|
|
c = null;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 处理远程新增的文件夹
|
|
|
|
|
// for remote add folders
|
|
|
|
|
Iterator<Map.Entry<String, TaskList>> iter = mGTaskListHashMap.entrySet().iterator();
|
|
|
|
|
while (iter.hasNext()) {
|
|
|
|
|
@ -475,7 +504,9 @@ public class GTaskManager {
|
|
|
|
|
if (!mCancelled)
|
|
|
|
|
GTaskClient.getInstance().commitUpdate();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 根据不同的同步操作类型执行具体同步动作的私有方法，通过一个switch语句根据传入的同步类型（syncType）来决定调用相应的添加、删除、更新等具体操作方法，
|
|
|
|
|
// 整个过程中会不断检查同步是否已被取消，若已取消则及时终止操作，若传入的同步类型不合法则抛出异常表示未知的同步操作类型。
|
|
|
|
|
|
|
|
|
|
private void doContentSync(int syncType, Node node, Cursor c) throws NetworkFailureException {
|
|
|
|
|
if (mCancelled) {
|
|
|
|
|
return;
|
|
|
|
|
@ -510,6 +541,7 @@ public class GTaskManager {
|
|
|
|
|
updateRemoteNode(node, c);
|
|
|
|
|
break;
|
|
|
|
|
case Node.SYNC_ACTION_UPDATE_CONFLICT:
|
|
|
|
|
// 合并双方的修改可能是个好主意，目前简单使用本地更新
|
|
|
|
|
// merging both modifications maybe a good idea
|
|
|
|
|
// right now just use local update simply
|
|
|
|
|
updateRemoteNode(node, c);
|
|
|
|
|
@ -521,7 +553,10 @@ public class GTaskManager {
|
|
|
|
|
throw new ActionFailureException("unkown sync action type");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 将本地节点添加到本地数据库以及处理相关同步逻辑的私有方法，首先判断同步是否已取消，如果取消则直接返回，
|
|
|
|
|
// 然后根据节点类型（是任务列表还是普通任务等）进行不同的处理，创建对应的本地数据记录（通过SqlNote），设置相关属性（如父节点ID、全局唯一标识符等），
|
|
|
|
|
// 将数据提交到本地数据库，更新本地和远程标识符的映射关系，并且调用updateRemoteMeta方法来处理与元数据相关的更新操作，若在过程中出现找不到父节点ID等问题则抛出异常表示无法添加本地节点。
|
|
|
|
|
|
|
|
|
|
private void addLocalNode(Node node) throws NetworkFailureException {
|
|
|
|
|
if (mCancelled) {
|
|
|
|
|
return;
|
|
|
|
|
@ -549,6 +584,7 @@ public class GTaskManager {
|
|
|
|
|
if (note.has(NoteColumns.ID)) {
|
|
|
|
|
long id = note.getLong(NoteColumns.ID);
|
|
|
|
|
if (DataUtils.existInNoteDatabase(mContentResolver, id)) {
|
|
|
|
|
// 该ID不可用，必须创建一个新的
|
|
|
|
|
// the id is not available, have to create a new one
|
|
|
|
|
note.remove(NoteColumns.ID);
|
|
|
|
|
}
|
|
|
|
|
@ -562,6 +598,7 @@ public class GTaskManager {
|
|
|
|
|
if (data.has(DataColumns.ID)) {
|
|
|
|
|
long dataId = data.getLong(DataColumns.ID);
|
|
|
|
|
if (DataUtils.existInDataDatabase(mContentResolver, dataId)) {
|
|
|
|
|
// 数据ID不可用，必须创建一个新的
|
|
|
|
|
// the data id is not available, have to create
|
|
|
|
|
// a new one
|
|
|
|
|
data.remove(DataColumns.ID);
|
|
|
|
|
@ -583,25 +620,29 @@ public class GTaskManager {
|
|
|
|
|
}
|
|
|
|
|
sqlNote.setParentId(parentId.longValue());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 创建本地节点
|
|
|
|
|
// create the local node
|
|
|
|
|
sqlNote.setGtaskId(node.getGid());
|
|
|
|
|
sqlNote.commit(false);
|
|
|
|
|
|
|
|
|
|
// 更新Gid-Nid映射
|
|
|
|
|
// update gid-nid mapping
|
|
|
|
|
mGidToNid.put(node.getGid(), sqlNote.getId());
|
|
|
|
|
mNidToGid.put(sqlNote.getId(), node.getGid());
|
|
|
|
|
|
|
|
|
|
// 更新元数据
|
|
|
|
|
// update meta
|
|
|
|
|
updateRemoteMeta(node.getGid(), sqlNote);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 更新本地节点数据以及相关同步逻辑的私有方法，首先判断同步是否已取消，如果取消则直接返回，
|
|
|
|
|
// 然后根据节点类型（是任务还是其他类型等）获取对应的本地数据记录（通过SqlNote），更新其内容、父节点ID等属性，将更新后的数据提交到本地数据库，
|
|
|
|
|
// 并调用updateRemoteMeta方法来处理与元数据相关的更新操作，若在过程中出现找不到父节点ID等问题则抛出异常表示无法更新本地节点。
|
|
|
|
|
|
|
|
|
|
private void updateLocalNode(Node node, Cursor c) throws NetworkFailureException {
|
|
|
|
|
if (mCancelled) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
SqlNote sqlNote;
|
|
|
|
|
// 更新本地笔记
|
|
|
|
|
// update the note locally
|
|
|
|
|
sqlNote = new SqlNote(mContext, c);
|
|
|
|
|
sqlNote.setContent(node.getLocalJSONFromContent());
|
|
|
|
|
@ -614,11 +655,15 @@ public class GTaskManager {
|
|
|
|
|
}
|
|
|
|
|
sqlNote.setParentId(parentId.longValue());
|
|
|
|
|
sqlNote.commit(true);
|
|
|
|
|
|
|
|
|
|
// 更新元数据信息
|
|
|
|
|
// update meta info
|
|
|
|
|
updateRemoteMeta(node.getGid(), sqlNote);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 将远程节点添加到本地数据库以及处理相关同步逻辑的私有方法，首先判断同步是否已取消，如果取消则直接返回，
|
|
|
|
|
// 然后根据节点类型（是任务还是任务列表等）进行不同的处理，创建对应的本地数据记录（通过SqlNote），
|
|
|
|
|
// 对于任务，找到其对应的父任务列表，添加到任务列表中，然后向远程服务创建任务（通过GTaskClient），对于任务列表，判断是否已存在，不存在则创建，
|
|
|
|
|
// 接着更新本地数据记录的相关属性（如全局唯一标识符等），提交到本地数据库，更新本地和远程标识符的映射关系，若在过程中出现找不到父任务列表等问题则抛出异常表示无法添加远程节点。
|
|
|
|
|
|
|
|
|
|
private void addRemoteNode(Node node, Cursor c) throws NetworkFailureException {
|
|
|
|
|
if (mCancelled) {
|
|
|
|
|
return;
|
|
|
|
|
@ -626,7 +671,7 @@ public class GTaskManager {
|
|
|
|
|
|
|
|
|
|
SqlNote sqlNote = new SqlNote(mContext, c);
|
|
|
|
|
Node n;
|
|
|
|
|
|
|
|
|
|
// 远程更新
|
|
|
|
|
// update remotely
|
|
|
|
|
if (sqlNote.isNoteType()) {
|
|
|
|
|
Task task = new Task();
|
|
|
|
|
@ -641,12 +686,12 @@ public class GTaskManager {
|
|
|
|
|
|
|
|
|
|
GTaskClient.getInstance().createTask(task);
|
|
|
|
|
n = (Node) task;
|
|
|
|
|
|
|
|
|
|
// 添加元数据
|
|
|
|
|
// add meta
|
|
|
|
|
updateRemoteMeta(task.getGid(), sqlNote);
|
|
|
|
|
} else {
|
|
|
|
|
TaskList tasklist = null;
|
|
|
|
|
|
|
|
|
|
// 我们需要跳过已存在的文件夹
|
|
|
|
|
// we need to skip folder if it has already existed
|
|
|
|
|
String folderName = GTaskStringUtils.MIUI_FOLDER_PREFFIX;
|
|
|
|
|
if (sqlNote.getId() == Notes.ID_ROOT_FOLDER)
|
|
|
|
|
@ -670,7 +715,7 @@ public class GTaskManager {
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 没有匹配的则添加
|
|
|
|
|
// no match we can add now
|
|
|
|
|
if (tasklist == null) {
|
|
|
|
|
tasklist = new TaskList();
|
|
|
|
|
@ -680,32 +725,36 @@ public class GTaskManager {
|
|
|
|
|
}
|
|
|
|
|
n = (Node) tasklist;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 更新本地笔记
|
|
|
|
|
// update local note
|
|
|
|
|
sqlNote.setGtaskId(n.getGid());
|
|
|
|
|
sqlNote.commit(false);
|
|
|
|
|
sqlNote.resetLocalModified();
|
|
|
|
|
sqlNote.commit(true);
|
|
|
|
|
|
|
|
|
|
// gid-id映射
|
|
|
|
|
// gid-id mapping
|
|
|
|
|
mGidToNid.put(n.getGid(), sqlNote.getId());
|
|
|
|
|
mNidToGid.put(sqlNote.getId(), n.getGid());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 更新远程节点数据以及相关同步逻辑的私有方法，首先判断同步是否已取消，如果取消则直接返回，
|
|
|
|
|
// 然后获取对应的本地数据记录（通过SqlNote），将本地数据内容设置到远程节点，向远程服务添加更新节点的请求（通过GTaskClient），
|
|
|
|
|
// 接着调用updateRemoteMeta方法处理元数据更新，对于任务类型的节点，还会判断是否需要移动任务（根据父任务列表的变化），若需要则执行移动任务操作（通过GTaskClient），
|
|
|
|
|
// 最后清除本地数据的修改标记并提交到本地数据库，若在过程中出现找不到父任务列表等问题则抛出异常表示无法更新远程任务。
|
|
|
|
|
|
|
|
|
|
private void updateRemoteNode(Node node, Cursor c) throws NetworkFailureException {
|
|
|
|
|
if (mCancelled) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
SqlNote sqlNote = new SqlNote(mContext, c);
|
|
|
|
|
|
|
|
|
|
// 远程更新
|
|
|
|
|
// update remotely
|
|
|
|
|
node.setContentByLocalJSON(sqlNote.getContent());
|
|
|
|
|
GTaskClient.getInstance().addUpdateNode(node);
|
|
|
|
|
|
|
|
|
|
// 更新元数据
|
|
|
|
|
// update meta
|
|
|
|
|
updateRemoteMeta(node.getGid(), sqlNote);
|
|
|
|
|
|
|
|
|
|
// 如果必要的话移动任务
|
|
|
|
|
// move task if necessary
|
|
|
|
|
if (sqlNote.isNoteType()) {
|
|
|
|
|
Task task = (Task) node;
|
|
|
|
|
@ -724,12 +773,15 @@ public class GTaskManager {
|
|
|
|
|
GTaskClient.getInstance().moveTask(task, preParentList, curParentList);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 清除本地修改标记
|
|
|
|
|
// clear local modified flag
|
|
|
|
|
sqlNote.resetLocalModified();
|
|
|
|
|
sqlNote.commit(true);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 更新远程元数据的私有方法，首先判断传入的本地数据记录（sqlNote）是否为笔记类型且不为空，
|
|
|
|
|
// 如果是，则先从元数据映射中查找对应Gid的元数据对象，若存在则更新其元数据内容并向远程服务添加更新节点请求（通过GTaskClient），
|
|
|
|
|
// 若不存在则创建新的元数据对象，添加到元数据列表中，然后向远程服务创建元数据任务（通过GTaskClient），以此来保证元数据在本地和远程的同步更新。
|
|
|
|
|
|
|
|
|
|
private void updateRemoteMeta(String gid, SqlNote sqlNote) throws NetworkFailureException {
|
|
|
|
|
if (sqlNote != null && sqlNote.isNoteType()) {
|
|
|
|
|
MetaData metaData = mMetaHashMap.get(gid);
|
|
|
|
|
@ -745,12 +797,15 @@ public class GTaskManager {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 刷新本地同步ID的私有方法，用于在同步完成后，根据最新的远程任务列表数据来更新本地数据的同步ID，首先判断同步是否已取消，如果取消则直接返回，
|
|
|
|
|
// 然后清空之前缓存的相关任务数据结构（如任务哈希映射、任务列表哈希映射、元数据哈希映射等），重新初始化任务列表数据（通过initGTaskList方法），
|
|
|
|
|
// 接着查询本地数据库中的相关数据，对于在远程任务列表中能找到对应节点的数据，更新其同步ID，若在过程中出现找不到对应节点等问题则抛出异常表示同步后本地部分数据缺失对应的Gid。
|
|
|
|
|
|
|
|
|
|
private void refreshLocalSyncId() throws NetworkFailureException {
|
|
|
|
|
if (mCancelled) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 获取最新的gtask列表
|
|
|
|
|
// get the latest gtask list
|
|
|
|
|
mGTaskHashMap.clear();
|
|
|
|
|
mGTaskListHashMap.clear();
|
|
|
|
|
@ -789,11 +844,13 @@ public class GTaskManager {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 获取当前同步账户名称的方法，通过调用GTaskClient的实例获取当前同步账户对象，然后返回其账户名称，外部可通过此方法获取当前正在用于同步的账户信息。
|
|
|
|
|
|
|
|
|
|
public String getSyncAccount() {
|
|
|
|
|
return GTaskClient.getInstance().getSyncAccount().name;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 用于取消正在进行的同步操作的方法，将同步取消标记（mCancelled）设置为true，在同步过程中的各个关键步骤都会检查这个标记，
|
|
|
|
|
// 一旦发现被设置为true，则会及时终止相应的同步操作，避免不必要的资源消耗和数据不一致问题。
|
|
|
|
|
public void cancelSync() {
|
|
|
|
|
mCancelled = true;
|
|
|
|
|
}
|
|
|
|
|
|
