|
|
|
|
@ -48,46 +48,46 @@ import java.util.Iterator;
|
|
|
|
|
import java.util.Map;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* @Author: 林迪文
|
|
|
|
|
* @Updator: 林迪文
|
|
|
|
|
* @Date 2025/12/22 21:30
|
|
|
|
|
* @Description 这个是同步功能的核心管理者。它负责整个同步流程的调度，比如登录、拉取云端数据、比对本地和云端的数据差异，然后决定哪些需要上传，哪些需要下载。
|
|
|
|
|
*/
|
|
|
|
|
public class GTaskManager {
|
|
|
|
|
// 日志标签
|
|
|
|
|
private static final String TAG = GTaskManager.class.getSimpleName();
|
|
|
|
|
|
|
|
|
|
// 定义了一堆同步结果的状态码，方便给调用方（比如Service）返回结果
|
|
|
|
|
public static final int STATE_SUCCESS = 0; // 0代表成功
|
|
|
|
|
public static final int STATE_NETWORK_ERROR = 1; // 1是网络问题
|
|
|
|
|
public static final int STATE_INTERNAL_ERROR = 2; // 2是程序内部错误
|
|
|
|
|
public static final int STATE_SYNC_IN_PROGRESS = 3; // 3是正在同步中，防止重复启动
|
|
|
|
|
public static final int STATE_SYNC_CANCELLED = 4; // 4是用户手动取消了
|
|
|
|
|
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<String, TaskList> mGTaskListHashMap;
|
|
|
|
|
|
|
|
|
|
private static GTaskManager mInstance = null; // 单例模式
|
|
|
|
|
private HashMap<String, Node> mGTaskHashMap;
|
|
|
|
|
|
|
|
|
|
private Activity mActivity; // Activity的上下文，主要给GTaskClient登录用
|
|
|
|
|
private Context mContext; // 全局的上下文
|
|
|
|
|
private ContentResolver mContentResolver; // 内容提供者，可以理解成咱们App访问便签数据库的“管家”
|
|
|
|
|
private HashMap<String, MetaData> mMetaHashMap;
|
|
|
|
|
|
|
|
|
|
private boolean mSyncing; // 同步状态的标记
|
|
|
|
|
private boolean mCancelled; // 取消同步的标记
|
|
|
|
|
private TaskList mMetaList;
|
|
|
|
|
|
|
|
|
|
// HashMap是整个同步算法的核心，用来在内存里缓存和映射数据
|
|
|
|
|
private HashMap<String, TaskList> mGTaskListHashMap; // Google云端任务清单的缓存，key是清单的gid
|
|
|
|
|
private HashMap<String, Node> mGTaskHashMap; // Google云端所有节点的缓存（包括清单和任务），key是gid
|
|
|
|
|
private HashMap<String, MetaData> mMetaHashMap; // Google云端元数据的缓存，key是被关联任务的gid
|
|
|
|
|
private TaskList mMetaList; // 专门存meta数据的那个清单对象
|
|
|
|
|
private HashSet<Long> mLocalDeleteIdMap;
|
|
|
|
|
|
|
|
|
|
private HashSet<Long> mLocalDeleteIdMap; // 存放在本地被删除了的笔记ID
|
|
|
|
|
private HashMap<String, Long> mGidToNid;
|
|
|
|
|
|
|
|
|
|
// 这两个是关键，用来建立Google ID和本地数据库ID之间的对应关系
|
|
|
|
|
private HashMap<String, Long> mGidToNid; // Google ID到本地笔记ID的映射
|
|
|
|
|
private HashMap<Long, String> mNidToGid; // 本地笔记ID到Google ID的映射
|
|
|
|
|
private HashMap<Long, String> mNidToGid;
|
|
|
|
|
|
|
|
|
|
private GTaskManager() {
|
|
|
|
|
// 构造函数里做一些初始化，防止空指针
|
|
|
|
|
mSyncing = false;
|
|
|
|
|
mCancelled = false;
|
|
|
|
|
mGTaskListHashMap = new HashMap<String, TaskList>();
|
|
|
|
|
@ -106,29 +106,20 @@ public class GTaskManager {
|
|
|
|
|
return mInstance;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 设置Activity上下文，因为登录Google账户需要一个Activity
|
|
|
|
|
public synchronized void setActivityContext(Activity activity) {
|
|
|
|
|
// used for getting authtoken
|
|
|
|
|
mActivity = activity;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 这是同步操作的总入口，所有同步逻辑都从这里开始。
|
|
|
|
|
* @param context 上下文
|
|
|
|
|
* @param asyncTask 异步任务的实例，用来在同步过程中更新界面上的进度提示
|
|
|
|
|
* @return 返回上面定义的状态码，告诉调用者同步结果
|
|
|
|
|
*/
|
|
|
|
|
public int sync(Context context, GTaskASyncTask asyncTask) {
|
|
|
|
|
// 先检查是不是已经在同步了，是的话就直接返回，避免重复执行
|
|
|
|
|
if (mSyncing) {
|
|
|
|
|
Log.d(TAG, "Sync is in progress");
|
|
|
|
|
return STATE_SYNC_IN_PROGRESS;
|
|
|
|
|
}
|
|
|
|
|
mContext = context;
|
|
|
|
|
mContentResolver = mContext.getContentResolver(); // 拿到数据库“管家”
|
|
|
|
|
mSyncing = true; // 标记开始同步
|
|
|
|
|
mCancelled = false; // 重置取消标记
|
|
|
|
|
|
|
|
|
|
// 每次同步前，先把上次的缓存清空，保证拿到的是最新数据
|
|
|
|
|
mContentResolver = mContext.getContentResolver();
|
|
|
|
|
mSyncing = true;
|
|
|
|
|
mCancelled = false;
|
|
|
|
|
mGTaskListHashMap.clear();
|
|
|
|
|
mGTaskHashMap.clear();
|
|
|
|
|
mMetaHashMap.clear();
|
|
|
|
|
@ -138,35 +129,33 @@ public class GTaskManager {
|
|
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
GTaskClient client = GTaskClient.getInstance();
|
|
|
|
|
client.resetUpdateArray(); // 万一上次同步失败有残留，先把待提交队列清一下
|
|
|
|
|
client.resetUpdateArray();
|
|
|
|
|
|
|
|
|
|
// 登录
|
|
|
|
|
// login google task
|
|
|
|
|
if (!mCancelled) {
|
|
|
|
|
if (!client.login(mActivity)) {
|
|
|
|
|
throw new NetworkFailureException("login google task failed");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 从Google服务器上把所有任务清单和任务都拉下来，放到内存的HashMap里
|
|
|
|
|
asyncTask.publishProgess(mContext.getString(R.string.sync_progress_init_list)); // 通知界面，“正在初始化列表...”
|
|
|
|
|
// get the task list from google
|
|
|
|
|
asyncTask.publishProgess(mContext.getString(R.string.sync_progress_init_list));
|
|
|
|
|
initGTaskList();
|
|
|
|
|
|
|
|
|
|
// 开始比对和同步本地与云端的内容
|
|
|
|
|
asyncTask.publishProgess(mContext.getString(R.string.sync_progress_syncing)); // 通知界面，“正在同步...”
|
|
|
|
|
// do content sync work
|
|
|
|
|
asyncTask.publishProgess(mContext.getString(R.string.sync_progress_syncing));
|
|
|
|
|
syncContent();
|
|
|
|
|
|
|
|
|
|
} catch (NetworkFailureException e) {
|
|
|
|
|
Log.e(TAG, e.toString());
|
|
|
|
|
return STATE_NETWORK_ERROR; // 网络异常
|
|
|
|
|
return STATE_NETWORK_ERROR;
|
|
|
|
|
} catch (ActionFailureException e) {
|
|
|
|
|
Log.e(TAG, e.toString());
|
|
|
|
|
return STATE_INTERNAL_ERROR; // 操作失败，比如JSON解析错了
|
|
|
|
|
return STATE_INTERNAL_ERROR;
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
Log.e(TAG, e.toString());
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
return STATE_INTERNAL_ERROR; // 其他未知错误
|
|
|
|
|
return STATE_INTERNAL_ERROR;
|
|
|
|
|
} finally {
|
|
|
|
|
// 关键的收尾工作，不管同步成功、失败还是取消，都要把这些缓存清掉，把状态改回去，保证下次能正常同步
|
|
|
|
|
mGTaskListHashMap.clear();
|
|
|
|
|
mGTaskHashMap.clear();
|
|
|
|
|
mMetaHashMap.clear();
|
|
|
|
|
@ -176,43 +165,37 @@ public class GTaskManager {
|
|
|
|
|
mSyncing = false;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 最后根据取消标志返回最终状态
|
|
|
|
|
return mCancelled ? STATE_SYNC_CANCELLED : STATE_SUCCESS;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 这个方法负责从Google Tasks服务器拉取所有的数据，并初始化到内存中的各个HashMap里，为后续的数据比对做准备。
|
|
|
|
|
* @throws NetworkFailureException
|
|
|
|
|
*/
|
|
|
|
|
private void initGTaskList() throws NetworkFailureException {
|
|
|
|
|
if (mCancelled) // 同步过程中随时检查是否被取消了
|
|
|
|
|
if (mCancelled)
|
|
|
|
|
return;
|
|
|
|
|
GTaskClient client = GTaskClient.getInstance();
|
|
|
|
|
try {
|
|
|
|
|
JSONArray jsTaskLists = client.getTaskLists(); // 从服务器拿到所有清单的JSON数组
|
|
|
|
|
JSONArray jsTaskLists = client.getTaskLists();
|
|
|
|
|
|
|
|
|
|
// 优先处理meta清单。这个清单是用来存一些便签的附加信息（比如颜色、提醒时间）的，在Google Tasks界面上看不到，是咱们App自己用的
|
|
|
|
|
// init meta list first
|
|
|
|
|
mMetaList = null;
|
|
|
|
|
for (int i = 0; i < jsTaskLists.length(); i++) {
|
|
|
|
|
JSONObject object = jsTaskLists.getJSONObject(i);
|
|
|
|
|
String gid = object.getString(GTaskStringUtils.GTASK_JSON_ID); // 清单的gid
|
|
|
|
|
String name = object.getString(GTaskStringUtils.GTASK_JSON_NAME); // 清单的名字
|
|
|
|
|
String gid = object.getString(GTaskStringUtils.GTASK_JSON_ID);
|
|
|
|
|
String name = object.getString(GTaskStringUtils.GTASK_JSON_NAME);
|
|
|
|
|
|
|
|
|
|
// 通过一个特殊的前缀名来识别出哪个是meta清单
|
|
|
|
|
if (name.equals(GTaskStringUtils.MIUI_FOLDER_PREFFIX + GTaskStringUtils.FOLDER_META)) {
|
|
|
|
|
if (name
|
|
|
|
|
.equals(GTaskStringUtils.MIUI_FOLDER_PREFFIX + GTaskStringUtils.FOLDER_META)) {
|
|
|
|
|
mMetaList = new TaskList();
|
|
|
|
|
mMetaList.setContentByRemoteJSON(object); // 把JSON数据填到TaskList对象里
|
|
|
|
|
mMetaList.setContentByRemoteJSON(object);
|
|
|
|
|
|
|
|
|
|
// 找到meta清单后，再去拉这个清单下面所有的meta数据
|
|
|
|
|
// load meta data
|
|
|
|
|
JSONArray jsMetas = client.getTaskList(gid);
|
|
|
|
|
for (int j = 0; j < jsMetas.length(); j++) {
|
|
|
|
|
object = (JSONObject) jsMetas.getJSONObject(j);
|
|
|
|
|
MetaData metaData = new MetaData();
|
|
|
|
|
metaData.setContentByRemoteJSON(object);
|
|
|
|
|
if (metaData.isWorthSaving()) { // 检查一下数据是不是有效
|
|
|
|
|
mMetaList.addChildTask(metaData); // 加到meta清单的子任务列表里
|
|
|
|
|
if (metaData.isWorthSaving()) {
|
|
|
|
|
mMetaList.addChildTask(metaData);
|
|
|
|
|
if (metaData.getGid() != null) {
|
|
|
|
|
// 把meta数据存到缓存里，key是它关联的那个笔记的gid，方便后面查找
|
|
|
|
|
mMetaHashMap.put(metaData.getRelatedGid(), metaData);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
@ -220,7 +203,7 @@ public class GTaskManager {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 如果服务器上没有meta清单，说明是第一次同步，那咱们就在云端给它创建一个
|
|
|
|
|
// create meta list if not existed
|
|
|
|
|
if (mMetaList == null) {
|
|
|
|
|
mMetaList = new TaskList();
|
|
|
|
|
mMetaList.setName(GTaskStringUtils.MIUI_FOLDER_PREFFIX
|
|
|
|
|
@ -228,23 +211,21 @@ public class GTaskManager {
|
|
|
|
|
GTaskClient.getInstance().createTaskList(mMetaList);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 处理正常的便签夹（任务清单）
|
|
|
|
|
// init task list
|
|
|
|
|
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);
|
|
|
|
|
|
|
|
|
|
// 通过前缀名过滤出我们自己App创建的清单，忽略用户在Google Tasks上创建的其他清单
|
|
|
|
|
if (name.startsWith(GTaskStringUtils.MIUI_FOLDER_PREFFIX)
|
|
|
|
|
&& !name.equals(GTaskStringUtils.MIUI_FOLDER_PREFFIX
|
|
|
|
|
+ GTaskStringUtils.FOLDER_META)) {
|
|
|
|
|
+ GTaskStringUtils.FOLDER_META)) {
|
|
|
|
|
TaskList tasklist = new TaskList();
|
|
|
|
|
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++) {
|
|
|
|
|
object = (JSONObject) jsTasks.getJSONObject(j);
|
|
|
|
|
@ -252,10 +233,9 @@ public class GTaskManager {
|
|
|
|
|
Task task = new Task();
|
|
|
|
|
task.setContentByRemoteJSON(object);
|
|
|
|
|
if (task.isWorthSaving()) {
|
|
|
|
|
// 从meta缓存里找到这条便签对应的meta数据，然后关联起来
|
|
|
|
|
task.setMetaInfo(mMetaHashMap.get(gid));
|
|
|
|
|
tasklist.addChildTask(task); // 把任务加到清单的子节点里
|
|
|
|
|
mGTaskHashMap.put(gid, task); // 也放到总节点缓存里
|
|
|
|
|
tasklist.addChildTask(task);
|
|
|
|
|
mGTaskHashMap.put(gid, task);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
@ -267,15 +247,11 @@ public class GTaskManager {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 这个方法是数据同步的核心。它会遍历本地数据库和从云端拉下来的数据，找出两边的差异，然后调用doContentSync来决定具体执行哪种同步操作。
|
|
|
|
|
* @throws NetworkFailureException
|
|
|
|
|
*/
|
|
|
|
|
private void syncContent() throws NetworkFailureException {
|
|
|
|
|
int syncType; // 用来存同步操作的类型，比如是本地新增、还是远程删除
|
|
|
|
|
Cursor c = null; // 数据库查询用的游标
|
|
|
|
|
String gid; // Google ID
|
|
|
|
|
Node node; // 云端节点对象
|
|
|
|
|
int syncType;
|
|
|
|
|
Cursor c = null;
|
|
|
|
|
String gid;
|
|
|
|
|
Node node;
|
|
|
|
|
|
|
|
|
|
mLocalDeleteIdMap.clear();
|
|
|
|
|
|
|
|
|
|
@ -283,7 +259,7 @@ public class GTaskManager {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 处理本地已经删除的笔记。这些笔记在回收站里，需要通知云端也删除。
|
|
|
|
|
// for local deleted note
|
|
|
|
|
try {
|
|
|
|
|
c = mContentResolver.query(Notes.CONTENT_NOTE_URI, SqlNote.PROJECTION_NOTE,
|
|
|
|
|
"(type<>? AND parent_id=?)", new String[] {
|
|
|
|
|
@ -291,14 +267,13 @@ public class GTaskManager {
|
|
|
|
|
}, null);
|
|
|
|
|
if (c != null) {
|
|
|
|
|
while (c.moveToNext()) {
|
|
|
|
|
gid = c.getString(SqlNote.GTASK_ID_COLUMN); // 拿到本地笔记对应的Google ID
|
|
|
|
|
node = mGTaskHashMap.get(gid); // 去云端数据缓存里找找，看云上还有没有
|
|
|
|
|
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); // 告诉云端也要删除
|
|
|
|
|
mGTaskHashMap.remove(gid);
|
|
|
|
|
doContentSync(Node.SYNC_ACTION_DEL_REMOTE, node, c);
|
|
|
|
|
}
|
|
|
|
|
// 把这个本地ID记下来，最后统一从本地数据库的data表里删掉
|
|
|
|
|
|
|
|
|
|
mLocalDeleteIdMap.add(c.getLong(SqlNote.ID_COLUMN));
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
@ -306,17 +281,16 @@ public class GTaskManager {
|
|
|
|
|
}
|
|
|
|
|
} finally {
|
|
|
|
|
if (c != null) {
|
|
|
|
|
c.close(); // 确保游标一定被关闭，防止内存泄漏
|
|
|
|
|
c.close();
|
|
|
|
|
c = null;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 同步文件夹。文件夹的层级关系比较重要，所以要优先同步
|
|
|
|
|
// sync folder first
|
|
|
|
|
syncFolder();
|
|
|
|
|
|
|
|
|
|
// 处理本地数据库里还存在的笔记
|
|
|
|
|
// for note existing in database
|
|
|
|
|
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)
|
|
|
|
|
@ -324,23 +298,22 @@ public class GTaskManager {
|
|
|
|
|
if (c != null) {
|
|
|
|
|
while (c.moveToNext()) {
|
|
|
|
|
gid = c.getString(SqlNote.GTASK_ID_COLUMN);
|
|
|
|
|
node = mGTaskHashMap.get(gid); // 拿本地笔记的gid去云端缓存里找
|
|
|
|
|
if (node != null) { // 在云端找到了对应的笔记
|
|
|
|
|
mGTaskHashMap.remove(gid); // 从待处理的云端数据里移除
|
|
|
|
|
mGidToNid.put(gid, c.getLong(SqlNote.ID_COLUMN)); // 再次确认一下ID映射关系
|
|
|
|
|
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);
|
|
|
|
|
// 调用node自己的方法来比对内容，判断是谁更新了，还是都更新了（冲突）
|
|
|
|
|
syncType = node.getSyncAction(c);
|
|
|
|
|
} else { // 在云端没找到对应的笔记
|
|
|
|
|
} else {
|
|
|
|
|
if (c.getString(SqlNote.GTASK_ID_COLUMN).trim().length() == 0) {
|
|
|
|
|
// 如果本地笔记的gid是空的，说明这是在本地新建的，还没同步过
|
|
|
|
|
// local add
|
|
|
|
|
syncType = Node.SYNC_ACTION_ADD_REMOTE;
|
|
|
|
|
} else {
|
|
|
|
|
// 如果本地有gid，但云端没有，说明这个笔记在云端被删掉了
|
|
|
|
|
// remote delete
|
|
|
|
|
syncType = Node.SYNC_ACTION_DEL_LOCAL;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
doContentSync(syncType, node, c); // 根据比对结果执行相应的同步操作
|
|
|
|
|
doContentSync(syncType, node, c);
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
Log.w(TAG, "failed to query existing note in database");
|
|
|
|
|
@ -353,35 +326,31 @@ public class GTaskManager {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 处理云端数据缓存(mGTaskHashMap)里剩下的东西
|
|
|
|
|
// 经过上面几步，缓存里剩下的就是那些“云端有，本地没有”的笔记了，说明是需要下载到本地的
|
|
|
|
|
// go through remaining items
|
|
|
|
|
Iterator<Map.Entry<String, Node>> iter = mGTaskHashMap.entrySet().iterator();
|
|
|
|
|
while (iter.hasNext()) {
|
|
|
|
|
Map.Entry<String, Node> entry = iter.next();
|
|
|
|
|
node = entry.getValue();
|
|
|
|
|
doContentSync(Node.SYNC_ACTION_ADD_LOCAL, node, null); // 执行本地新增操作
|
|
|
|
|
doContentSync(Node.SYNC_ACTION_ADD_LOCAL, node, null);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 收尾工作
|
|
|
|
|
// 检查是否被取消
|
|
|
|
|
// mCancelled can be set by another thread, so we neet to check one by
|
|
|
|
|
// one
|
|
|
|
|
// clear local delete table
|
|
|
|
|
if (!mCancelled) {
|
|
|
|
|
// 把之前记录的、在本地被删除的笔记，批量从数据库里彻底清理掉
|
|
|
|
|
if (!DataUtils.batchDeleteNotes(mContentResolver, mLocalDeleteIdMap)) {
|
|
|
|
|
throw new ActionFailureException("failed to batch-delete local deleted notes");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// refresh local sync id
|
|
|
|
|
if (!mCancelled) {
|
|
|
|
|
GTaskClient.getInstance().commitUpdate(); // 提交所有攒着的更新操作
|
|
|
|
|
refreshLocalSyncId(); // 最后再刷新一下本地笔记的sync_id，保证和云端一致
|
|
|
|
|
GTaskClient.getInstance().commitUpdate();
|
|
|
|
|
refreshLocalSyncId();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 这个是专门同步文件夹的逻辑，和同步笔记的流程基本一样，只是查询条件和处理的对象不同。
|
|
|
|
|
* @throws NetworkFailureException
|
|
|
|
|
*/
|
|
|
|
|
private void syncFolder() throws NetworkFailureException {
|
|
|
|
|
Cursor c = null;
|
|
|
|
|
String gid;
|
|
|
|
|
@ -392,7 +361,7 @@ public class GTaskManager {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 先处理“默认便签夹”（根目录），这是个系统文件夹
|
|
|
|
|
// for root folder
|
|
|
|
|
try {
|
|
|
|
|
c = mContentResolver.query(ContentUris.withAppendedId(Notes.CONTENT_NOTE_URI,
|
|
|
|
|
Notes.ID_ROOT_FOLDER), SqlNote.PROJECTION_NOTE, null, null, null);
|
|
|
|
|
@ -401,15 +370,14 @@ public class GTaskManager {
|
|
|
|
|
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); // 建立ID映射
|
|
|
|
|
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))
|
|
|
|
|
doContentSync(Node.SYNC_ACTION_UPDATE_REMOTE, node, c);
|
|
|
|
|
} else {
|
|
|
|
|
// 云端没有这个文件夹，就创建一个
|
|
|
|
|
doContentSync(Node.SYNC_ACTION_ADD_REMOTE, node, c);
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
@ -422,12 +390,11 @@ public class GTaskManager {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 再处理“通话便签”文件夹，也是系统文件夹
|
|
|
|
|
// for call-note folder
|
|
|
|
|
try {
|
|
|
|
|
// 这块逻辑和上面处理根目录的完全一样，只是ID和名字换了
|
|
|
|
|
c = mContentResolver.query(Notes.CONTENT_NOTE_URI, SqlNote.PROJECTION_NOTE, "(_id=?)",
|
|
|
|
|
new String[] {
|
|
|
|
|
String.valueOf(Notes.ID_CALL_RECORD_FOLDER)
|
|
|
|
|
String.valueOf(Notes.ID_CALL_RECORD_FOLDER)
|
|
|
|
|
}, null);
|
|
|
|
|
if (c != null) {
|
|
|
|
|
if (c.moveToNext()) {
|
|
|
|
|
@ -437,7 +404,8 @@ 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(
|
|
|
|
|
GTaskStringUtils.MIUI_FOLDER_PREFFIX
|
|
|
|
|
+ GTaskStringUtils.FOLDER_CALL_NOTE))
|
|
|
|
|
@ -456,9 +424,8 @@ public class GTaskManager {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 处理本地存在的其他普通文件夹
|
|
|
|
|
// for local existing folders
|
|
|
|
|
try {
|
|
|
|
|
// 这里的比对逻辑和syncContent里处理普通笔记的逻辑是一样的
|
|
|
|
|
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)
|
|
|
|
|
@ -472,10 +439,12 @@ public class GTaskManager {
|
|
|
|
|
mGidToNid.put(gid, c.getLong(SqlNote.ID_COLUMN));
|
|
|
|
|
mNidToGid.put(c.getLong(SqlNote.ID_COLUMN), gid);
|
|
|
|
|
syncType = node.getSyncAction(c);
|
|
|
|
|
} else {
|
|
|
|
|
} 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;
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
@ -491,77 +460,61 @@ public class GTaskManager {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 处理云端新增的文件夹
|
|
|
|
|
// mGTaskListHashMap里是所有云端文件夹，经过上面的处理，还在mGTaskHashMap里的就是“云端有，本地没有”的
|
|
|
|
|
// for remote add folders
|
|
|
|
|
Iterator<Map.Entry<String, TaskList>> iter = mGTaskListHashMap.entrySet().iterator();
|
|
|
|
|
while (iter.hasNext()) {
|
|
|
|
|
Map.Entry<String, TaskList> entry = iter.next();
|
|
|
|
|
gid = entry.getKey();
|
|
|
|
|
node = entry.getValue();
|
|
|
|
|
if (mGTaskHashMap.containsKey(gid)) { // 再次确认一下
|
|
|
|
|
if (mGTaskHashMap.containsKey(gid)) {
|
|
|
|
|
mGTaskHashMap.remove(gid);
|
|
|
|
|
doContentSync(Node.SYNC_ACTION_ADD_LOCAL, node, null);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (!mCancelled)
|
|
|
|
|
GTaskClient.getInstance().commitUpdate(); // 同步完文件夹就提交一次，免得操作太多
|
|
|
|
|
GTaskClient.getInstance().commitUpdate();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 这是一个分发器。根据传入的同步类型，决定具体是调用本地新增、远程删除还是其他方法。
|
|
|
|
|
* @param syncType 同步操作的类型
|
|
|
|
|
* @param node 云端节点对象
|
|
|
|
|
* @param c 本地数据库查询的游标
|
|
|
|
|
* @throws NetworkFailureException
|
|
|
|
|
*/
|
|
|
|
|
private void doContentSync(int syncType, Node node, Cursor c) throws NetworkFailureException {
|
|
|
|
|
if (mCancelled) { // 最后一层检查，确保取消指令能及时生效
|
|
|
|
|
if (mCancelled) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
MetaData meta;
|
|
|
|
|
switch (syncType) {
|
|
|
|
|
case Node.SYNC_ACTION_ADD_LOCAL:
|
|
|
|
|
// 云端有，本地没有 -> 在本地数据库里新建
|
|
|
|
|
addLocalNode(node);
|
|
|
|
|
break;
|
|
|
|
|
case Node.SYNC_ACTION_ADD_REMOTE:
|
|
|
|
|
// 本地有，云端没有 -> 上传到Google服务器
|
|
|
|
|
addRemoteNode(node, c);
|
|
|
|
|
break;
|
|
|
|
|
case Node.SYNC_ACTION_DEL_LOCAL:
|
|
|
|
|
// 本地有，云端没有（但本地有gid，说明之前同步过） -> 在本地删除
|
|
|
|
|
// 删之前，先看看它有没有关联的meta数据，有的话也要一起删掉
|
|
|
|
|
meta = mMetaHashMap.get(c.getString(SqlNote.GTASK_ID_COLUMN));
|
|
|
|
|
if (meta != null) {
|
|
|
|
|
GTaskClient.getInstance().deleteNode(meta);
|
|
|
|
|
}
|
|
|
|
|
mLocalDeleteIdMap.add(c.getLong(SqlNote.ID_COLUMN)); // 记下ID，最后统一删
|
|
|
|
|
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); // 同样，连meta数据一起删
|
|
|
|
|
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:
|
|
|
|
|
// 两边都更新了，冲突了
|
|
|
|
|
// 直接用本地的覆盖云端的
|
|
|
|
|
// merging both modifications maybe a good idea
|
|
|
|
|
// right now just use local update simply
|
|
|
|
|
updateRemoteNode(node, c);
|
|
|
|
|
break;
|
|
|
|
|
case Node.SYNC_ACTION_NONE:
|
|
|
|
|
// 两边数据一样，啥也不用干
|
|
|
|
|
break;
|
|
|
|
|
case Node.SYNC_ACTION_ERROR:
|
|
|
|
|
default:
|
|
|
|
|
@ -569,30 +522,26 @@ public class GTaskManager {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 在本地数据库里添加一个节点（文件夹或便签）
|
|
|
|
|
private void addLocalNode(Node node) throws NetworkFailureException {
|
|
|
|
|
if (mCancelled) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
SqlNote sqlNote;
|
|
|
|
|
if (node instanceof TaskList) { // 判断是文件夹还是便签
|
|
|
|
|
// 对系统文件夹做特殊处理，直接关联到固定的ID上，而不是新建
|
|
|
|
|
if (node instanceof TaskList) {
|
|
|
|
|
if (node.getName().equals(
|
|
|
|
|
GTaskStringUtils.MIUI_FOLDER_PREFFIX + GTaskStringUtils.FOLDER_DEFAULT)) {
|
|
|
|
|
sqlNote = new SqlNote(mContext, Notes.ID_ROOT_FOLDER);
|
|
|
|
|
} else if (node.getName().equals(
|
|
|
|
|
GTaskStringUtils.MIUI_FOLDER_PREFFIX + GTaskStringUtils.FOLDER_CALL_NOTE)) {
|
|
|
|
|
sqlNote = new SqlNote(mContext, Notes.ID_CALL_RECORD_FOLDER);
|
|
|
|
|
} else { // 普通文件夹
|
|
|
|
|
} else {
|
|
|
|
|
sqlNote = new SqlNote(mContext);
|
|
|
|
|
sqlNote.setContent(node.getLocalJSONFromContent()); // 把云端节点内容转成本地格式
|
|
|
|
|
sqlNote.setParentId(Notes.ID_ROOT_FOLDER); // 普通文件夹都放在根目录下
|
|
|
|
|
sqlNote.setContent(node.getLocalJSONFromContent());
|
|
|
|
|
sqlNote.setParentId(Notes.ID_ROOT_FOLDER);
|
|
|
|
|
}
|
|
|
|
|
} else { // 是便签
|
|
|
|
|
} else {
|
|
|
|
|
sqlNote = new SqlNote(mContext);
|
|
|
|
|
// 这里有一段防御性代码，检查下载下来的笔记ID和dataID在本地是不是已经被占用了
|
|
|
|
|
// 如果被占用了，就把它ID去掉，让数据库自己生成新的，避免主键冲突
|
|
|
|
|
JSONObject js = node.getLocalJSONFromContent();
|
|
|
|
|
try {
|
|
|
|
|
if (js.has(GTaskStringUtils.META_HEAD_NOTE)) {
|
|
|
|
|
@ -600,11 +549,12 @@ public class GTaskManager {
|
|
|
|
|
if (note.has(NoteColumns.ID)) {
|
|
|
|
|
long id = note.getLong(NoteColumns.ID);
|
|
|
|
|
if (DataUtils.existInNoteDatabase(mContentResolver, id)) {
|
|
|
|
|
// the id is not available, have to create a new one
|
|
|
|
|
note.remove(NoteColumns.ID);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
// data表里的ID也要检查
|
|
|
|
|
|
|
|
|
|
if (js.has(GTaskStringUtils.META_HEAD_DATA)) {
|
|
|
|
|
JSONArray dataArray = js.getJSONArray(GTaskStringUtils.META_HEAD_DATA);
|
|
|
|
|
for (int i = 0; i < dataArray.length(); i++) {
|
|
|
|
|
@ -612,10 +562,13 @@ public class GTaskManager {
|
|
|
|
|
if (data.has(DataColumns.ID)) {
|
|
|
|
|
long dataId = data.getLong(DataColumns.ID);
|
|
|
|
|
if (DataUtils.existInDataDatabase(mContentResolver, dataId)) {
|
|
|
|
|
// the data id is not available, have to create
|
|
|
|
|
// a new one
|
|
|
|
|
data.remove(DataColumns.ID);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
} catch (JSONException e) {
|
|
|
|
|
Log.w(TAG, e.toString());
|
|
|
|
|
@ -623,7 +576,6 @@ public class GTaskManager {
|
|
|
|
|
}
|
|
|
|
|
sqlNote.setContent(js);
|
|
|
|
|
|
|
|
|
|
// 从ID映射表里找到它的parent（父文件夹）在本地的ID
|
|
|
|
|
Long parentId = mGidToNid.get(((Task) node).getParent().getGid());
|
|
|
|
|
if (parentId == null) {
|
|
|
|
|
Log.e(TAG, "cannot find task's parent id locally");
|
|
|
|
|
@ -632,30 +584,28 @@ public class GTaskManager {
|
|
|
|
|
sqlNote.setParentId(parentId.longValue());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
sqlNote.setGtaskId(node.getGid()); // 关联Google ID
|
|
|
|
|
sqlNote.commit(false); // 提交到数据库
|
|
|
|
|
// create the local node
|
|
|
|
|
sqlNote.setGtaskId(node.getGid());
|
|
|
|
|
sqlNote.commit(false);
|
|
|
|
|
|
|
|
|
|
// 关键一步：在ID映射表里把这个新节点的对应关系加上
|
|
|
|
|
// update gid-nid mapping
|
|
|
|
|
mGidToNid.put(node.getGid(), sqlNote.getId());
|
|
|
|
|
mNidToGid.put(sqlNote.getId(), node.getGid());
|
|
|
|
|
|
|
|
|
|
// 顺便把meta数据也更新一下
|
|
|
|
|
// update meta
|
|
|
|
|
updateRemoteMeta(node.getGid(), sqlNote);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 更新本地数据库里的一个节点
|
|
|
|
|
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());
|
|
|
|
|
|
|
|
|
|
// 找到它的parent在本地的ID
|
|
|
|
|
Long parentId = (node instanceof Task) ? mGidToNid.get(((Task) node).getParent().getGid())
|
|
|
|
|
: new Long(Notes.ID_ROOT_FOLDER);
|
|
|
|
|
if (parentId == null) {
|
|
|
|
|
@ -663,39 +613,41 @@ public class GTaskManager {
|
|
|
|
|
throw new ActionFailureException("cannot update local node");
|
|
|
|
|
}
|
|
|
|
|
sqlNote.setParentId(parentId.longValue());
|
|
|
|
|
sqlNote.commit(true); // 提交更新
|
|
|
|
|
sqlNote.commit(true);
|
|
|
|
|
|
|
|
|
|
updateRemoteMeta(node.getGid(), sqlNote); // 更新meta
|
|
|
|
|
// update meta info
|
|
|
|
|
updateRemoteMeta(node.getGid(), sqlNote);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 把本地新建的节点上传到云端
|
|
|
|
|
private void addRemoteNode(Node node, Cursor c) throws NetworkFailureException {
|
|
|
|
|
if (mCancelled) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
SqlNote sqlNote = new SqlNote(mContext, c);
|
|
|
|
|
Node n; // 用来存创建成功后的云端节点对象
|
|
|
|
|
Node n;
|
|
|
|
|
|
|
|
|
|
if (sqlNote.isNoteType()) { // 是便签
|
|
|
|
|
// update remotely
|
|
|
|
|
if (sqlNote.isNoteType()) {
|
|
|
|
|
Task task = new Task();
|
|
|
|
|
task.setContentByLocalJSON(sqlNote.getContent()); // 用本地数据填充Task对象
|
|
|
|
|
task.setContentByLocalJSON(sqlNote.getContent());
|
|
|
|
|
|
|
|
|
|
// 从映射表里找到父文件夹的gid
|
|
|
|
|
String parentGid = mNidToGid.get(sqlNote.getParentId());
|
|
|
|
|
if (parentGid == null) {
|
|
|
|
|
Log.e(TAG, "cannot find task's parent tasklist");
|
|
|
|
|
throw new ActionFailureException("cannot add remote task");
|
|
|
|
|
}
|
|
|
|
|
mGTaskListHashMap.get(parentGid).addChildTask(task); // 在内存里也维护一下父子关系
|
|
|
|
|
mGTaskListHashMap.get(parentGid).addChildTask(task);
|
|
|
|
|
|
|
|
|
|
GTaskClient.getInstance().createTask(task); // 发请求创建
|
|
|
|
|
GTaskClient.getInstance().createTask(task);
|
|
|
|
|
n = (Node) task;
|
|
|
|
|
|
|
|
|
|
// add meta
|
|
|
|
|
updateRemoteMeta(task.getGid(), sqlNote);
|
|
|
|
|
} else { // 是文件夹
|
|
|
|
|
} 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)
|
|
|
|
|
folderName += GTaskStringUtils.FOLDER_DEFAULT;
|
|
|
|
|
@ -711,7 +663,7 @@ public class GTaskManager {
|
|
|
|
|
TaskList list = entry.getValue();
|
|
|
|
|
|
|
|
|
|
if (list.getName().equals(folderName)) {
|
|
|
|
|
tasklist = list; // 找到了同名的
|
|
|
|
|
tasklist = list;
|
|
|
|
|
if (mGTaskHashMap.containsKey(gid)) {
|
|
|
|
|
mGTaskHashMap.remove(gid);
|
|
|
|
|
}
|
|
|
|
|
@ -719,7 +671,7 @@ public class GTaskManager {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 如果没找到同名的，才真的去创建
|
|
|
|
|
// no match we can add now
|
|
|
|
|
if (tasklist == null) {
|
|
|
|
|
tasklist = new TaskList();
|
|
|
|
|
tasklist.setContentByLocalJSON(sqlNote.getContent());
|
|
|
|
|
@ -729,18 +681,17 @@ public class GTaskManager {
|
|
|
|
|
n = (Node) tasklist;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 上传成功后，把服务器返回的gid写回本地数据库
|
|
|
|
|
// update local note
|
|
|
|
|
sqlNote.setGtaskId(n.getGid());
|
|
|
|
|
sqlNote.commit(false);
|
|
|
|
|
sqlNote.resetLocalModified(); // 清除'本地已修改'的标记
|
|
|
|
|
sqlNote.resetLocalModified();
|
|
|
|
|
sqlNote.commit(true);
|
|
|
|
|
|
|
|
|
|
// 更新ID映射表
|
|
|
|
|
// gid-id mapping
|
|
|
|
|
mGidToNid.put(n.getGid(), sqlNote.getId());
|
|
|
|
|
mNidToGid.put(sqlNote.getId(), n.getGid());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 把本地修改过的节点上传到云端
|
|
|
|
|
private void updateRemoteNode(Node node, Cursor c) throws NetworkFailureException {
|
|
|
|
|
if (mCancelled) {
|
|
|
|
|
return;
|
|
|
|
|
@ -748,61 +699,59 @@ public class GTaskManager {
|
|
|
|
|
|
|
|
|
|
SqlNote sqlNote = new SqlNote(mContext, c);
|
|
|
|
|
|
|
|
|
|
// 用本地数据更新云端节点对象的内容
|
|
|
|
|
// update remotely
|
|
|
|
|
node.setContentByLocalJSON(sqlNote.getContent());
|
|
|
|
|
GTaskClient.getInstance().addUpdateNode(node); // 把这个更新操作加到待提交队列
|
|
|
|
|
GTaskClient.getInstance().addUpdateNode(node);
|
|
|
|
|
|
|
|
|
|
// update meta
|
|
|
|
|
updateRemoteMeta(node.getGid(), sqlNote);
|
|
|
|
|
|
|
|
|
|
// 如果是便签，还要检查一下它的父文件夹有没有变，变了的话就要发一个'move'指令
|
|
|
|
|
// move task if necessary
|
|
|
|
|
if (sqlNote.isNoteType()) {
|
|
|
|
|
Task task = (Task) node;
|
|
|
|
|
TaskList preParentList = task.getParent(); // 之前的parent
|
|
|
|
|
TaskList preParentList = task.getParent();
|
|
|
|
|
|
|
|
|
|
String curParentGid = mNidToGid.get(sqlNote.getParentId());
|
|
|
|
|
if (curParentGid == null) {
|
|
|
|
|
Log.e(TAG, "cannot find task's parent tasklist");
|
|
|
|
|
throw new ActionFailureException("cannot update remote task");
|
|
|
|
|
}
|
|
|
|
|
TaskList curParentList = mGTaskListHashMap.get(curParentGid);// parent变了
|
|
|
|
|
TaskList curParentList = mGTaskListHashMap.get(curParentGid);
|
|
|
|
|
|
|
|
|
|
if (preParentList != curParentList) {
|
|
|
|
|
// 在内存里维护父子关系
|
|
|
|
|
preParentList.removeChildTask(task);
|
|
|
|
|
curParentList.addChildTask(task);
|
|
|
|
|
GTaskClient.getInstance().moveTask(task, preParentList, curParentList); // 发送移动请求
|
|
|
|
|
GTaskClient.getInstance().moveTask(task, preParentList, curParentList);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 上传成功后，清除'本地已修改'的标记
|
|
|
|
|
// clear local modified flag
|
|
|
|
|
sqlNote.resetLocalModified();
|
|
|
|
|
sqlNote.commit(true);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 更新云端的meta数据
|
|
|
|
|
private void updateRemoteMeta(String gid, SqlNote sqlNote) throws NetworkFailureException {
|
|
|
|
|
if (sqlNote != null && sqlNote.isNoteType()) {
|
|
|
|
|
MetaData metaData = mMetaHashMap.get(gid); // 先看看这个便签之前有没有meta数据
|
|
|
|
|
if (metaData != null) { // 有的话，直接更新
|
|
|
|
|
MetaData metaData = mMetaHashMap.get(gid);
|
|
|
|
|
if (metaData != null) {
|
|
|
|
|
metaData.setMeta(gid, sqlNote.getContent());
|
|
|
|
|
GTaskClient.getInstance().addUpdateNode(metaData);
|
|
|
|
|
} else { // 没有的话，就新建一个
|
|
|
|
|
} else {
|
|
|
|
|
metaData = new MetaData();
|
|
|
|
|
metaData.setMeta(gid, sqlNote.getContent());
|
|
|
|
|
mMetaList.addChildTask(metaData); // 关联到meta清单下
|
|
|
|
|
mMetaHashMap.put(gid, metaData); // 加到缓存
|
|
|
|
|
GTaskClient.getInstance().createTask(metaData); // 发请求创建
|
|
|
|
|
mMetaList.addChildTask(metaData);
|
|
|
|
|
mMetaHashMap.put(gid, metaData);
|
|
|
|
|
GTaskClient.getInstance().createTask(metaData);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 同步完成后，刷新本地数据库里所有笔记的sync_id，让它和云端的lastModified时间戳保持一致
|
|
|
|
|
private void refreshLocalSyncId() throws NetworkFailureException {
|
|
|
|
|
if (mCancelled) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 重新从服务器拉一遍最新的数据，因为commitUpdate之后，云端的lastModified可能变了
|
|
|
|
|
// get the latest gtask list
|
|
|
|
|
mGTaskHashMap.clear();
|
|
|
|
|
mGTaskListHashMap.clear();
|
|
|
|
|
mMetaHashMap.clear();
|
|
|
|
|
@ -810,7 +759,6 @@ public class GTaskManager {
|
|
|
|
|
|
|
|
|
|
Cursor c = null;
|
|
|
|
|
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)
|
|
|
|
|
@ -819,15 +767,13 @@ public class GTaskManager {
|
|
|
|
|
while (c.moveToNext()) {
|
|
|
|
|
String gid = c.getString(SqlNote.GTASK_ID_COLUMN);
|
|
|
|
|
Node node = mGTaskHashMap.get(gid);
|
|
|
|
|
if (node != null) { // 找到对应的云端节点
|
|
|
|
|
if (node != null) {
|
|
|
|
|
mGTaskHashMap.remove(gid);
|
|
|
|
|
ContentValues values = new ContentValues();
|
|
|
|
|
// 把云端节点的时间戳更新到本地的sync_id字段
|
|
|
|
|
values.put(NoteColumns.SYNC_ID, node.getLastModified());
|
|
|
|
|
mContentResolver.update(ContentUris.withAppendedId(Notes.CONTENT_NOTE_URI,
|
|
|
|
|
c.getLong(SqlNote.ID_COLUMN)), values, null, null);
|
|
|
|
|
} else {
|
|
|
|
|
// 如果同步完，本地有的笔记在云端居然找不到了，说明出错了
|
|
|
|
|
Log.e(TAG, "something is missed");
|
|
|
|
|
throw new ActionFailureException(
|
|
|
|
|
"some local items don't have gid after sync");
|
|
|
|
|
@ -844,12 +790,10 @@ public class GTaskManager {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 获取当前同步的账户名
|
|
|
|
|
public String getSyncAccount() {
|
|
|
|
|
return GTaskClient.getInstance().getSyncAccount().name;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 从外部取消同步
|
|
|
|
|
public void cancelSync() {
|
|
|
|
|
mCancelled = true;
|
|
|
|
|
}
|
|
|
|
|
|
