/* * 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.text.TextUtils; 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 net.micode.notes.tool.GTaskStringUtils; import org.json.JSONArray; import org.json.JSONException; import org.json.JSONObject; /** *

Google任务类,继承自{@link Node}抽象类。

*

设计意图:实现Google任务的具体数据模型和同步操作,处理任务的创建、更新、删除等功能。

*

核心职责:

* *

关键关联:

* */ public class Task extends Node { private static final String TAG = Task.class.getSimpleName(); /** * 任务完成状态标记 */ private boolean mCompleted; /** * 任务备注信息 */ private String mNotes; /** * 任务元信息JSON对象,包含本地任务的详细信息 */ private JSONObject mMetaInfo; /** * 前一个兄弟任务,用于维护任务的顺序 */ private Task mPriorSibling; /** * 父任务列表,任务所属的任务列表 */ private TaskList mParent; /** * 默认构造方法,初始化任务属性 */ public Task() { super(); mCompleted = false; mNotes = null; mPriorSibling = null; mParent = null; mMetaInfo = null; } /** *

生成创建任务的JSON动作对象。

*

业务逻辑:构造用于向Google任务服务添加新任务的JSON数据,包含任务的基本信息和关系。

*

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, 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动作对象。

*

业务逻辑:构造用于向Google任务服务更新现有任务的JSON数据,包含任务的更新信息。

*

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()); 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数据解析并设置任务内容。

*

业务逻辑:将Google任务服务返回的JSON数据转换为任务对象的属性值。

*

解析的JSON字段: *

*

* * @param js 远程获取的JSON对象,包含Google任务服务返回的任务数据 * @throws ActionFailureException 如果解析JSON对象失败,抛出此异常 */ 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数据解析并设置任务内容。

*

业务逻辑:将本地存储的JSON数据转换为任务对象的属性值。

*

解析的JSON结构: *

*

* * @param js 本地存储的JSON对象,包含应用内持久化的任务数据 */ 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 { 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) { Log.e(TAG, e.toString()); e.printStackTrace(); } } /** *

从任务内容生成本地JSON对象。

*

业务逻辑:根据任务名称和元信息生成本地存储所需的JSON数据结构。

*

JSON结构说明: *

*

*

处理流程: *

    *
  1. 如果没有元信息,生成新的JSON结构(适用于从Web创建的新任务)
  2. *
  3. 如果有元信息,更新现有结构中的任务名称(适用于已同步的任务)
  4. *
*

* * @return 本地存储的JSON对象,包含任务的完整数据结构 */ public JSONObject getLocalJSONFromContent() { String name = getName(); try { if (mMetaInfo == null) { // new task created from web if (name == null) { Log.w(TAG, "the note seems to be an empty one"); return null; } 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 { // synced task 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) { Log.e(TAG, e.toString()); e.printStackTrace(); return null; } } /** *

设置任务的元信息。

*

业务逻辑:从MetaData对象中解析JSON字符串,获取任务的元信息。

*

处理流程: *

    *
  1. 检查MetaData对象及其notes字段是否为空
  2. *
  3. 将notes字段的JSON字符串解析为JSONObject
  4. *
  5. 如果解析失败,将元信息设置为null
  6. *
*

* * @param metaData 包含元信息的MetaData对象 */ public void setMetaInfo(MetaData metaData) { if (metaData != null && metaData.getNotes() != null) { try { mMetaInfo = new JSONObject(metaData.getNotes()); } catch (JSONException e) { Log.w(TAG, e.toString()); mMetaInfo = null; } } } /** *

获取同步动作类型。

*

业务逻辑:通过比较本地任务和远程任务的状态,确定需要执行的同步动作。

*

同步动作类型说明: *

*

*

处理流程: *

    *
  1. 验证元信息和笔记ID的有效性
  2. *
  3. 比较本地和远程的最后修改时间
  4. *
  5. 检查本地修改标记和GTASK ID的一致性
  6. *
  7. 根据比较结果返回相应的同步动作类型
  8. *
*

* * @param c 包含本地任务数据的游标对象 * @return 同步动作类型,对应Node类中定义的SYNC_ACTION_*常量 */ public int getSyncAction(Cursor c) { try { 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; } // validate the note id now 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) { // there is no local update if (c.getLong(SqlNote.SYNC_ID_COLUMN) == getLastModified()) { // no update both side return SYNC_ACTION_NONE; } else { // apply remote to local return SYNC_ACTION_UPDATE_LOCAL; } } else { // validate gtask 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()) { // local modification only 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; } /** *

判断任务是否值得保存。

*

业务逻辑:检查任务是否包含有价值的信息,用于决定是否需要保存到数据库或同步到远程。

*

判断条件:满足以下任一条件则认为值得保存: *

*

* * @return true表示任务值得保存,false表示任务为空或无价值信息 */ public boolean isWorthSaving() { return mMetaInfo != null || (getName() != null && getName().trim().length() > 0) || (getNotes() != null && getNotes().trim().length() > 0); } /** * 设置任务的完成状态。 * * @param completed 任务的完成状态,true表示已完成,false表示未完成 */ public void setCompleted(boolean completed) { this.mCompleted = completed; } /** * 设置任务的备注信息。 * * @param notes 任务的备注信息字符串 */ public void setNotes(String notes) { this.mNotes = notes; } /** * 设置任务的前一个兄弟任务,用于维护任务的顺序。 * * @param priorSibling 前一个兄弟任务对象 */ public void setPriorSibling(Task priorSibling) { this.mPriorSibling = priorSibling; } /** * 设置任务的父任务列表。 * * @param parent 父任务列表对象 */ public void setParent(TaskList parent) { this.mParent = parent; } /** * 获取任务的完成状态。 * * @return 任务的完成状态,true表示已完成,false表示未完成 */ public boolean getCompleted() { return this.mCompleted; } /** * 获取任务的备注信息。 * * @return 任务的备注信息字符串 */ public String getNotes() { return this.mNotes; } /** * 获取任务的前一个兄弟任务。 * * @return 前一个兄弟任务对象,如果没有则返回null */ public Task getPriorSibling() { return this.mPriorSibling; } /** * 获取任务的父任务列表。 * * @return 父任务列表对象,如果没有则返回null */ public TaskList getParent() { return this.mParent; } }