import com.google.samples.apps.iosched.service.SessionAlarmService; //导入依赖的package包/类
@Override
public void onDataChanged(DataEventBuffer dataEvents) {
    LOGD(TAG, "onDataChanged: " + dataEvents + " for " + getPackageName());

    for (DataEvent event : dataEvents) {
        LOGD(TAG, "Uri is: " + event.getDataItem().getUri());
        DataMapItem mapItem = DataMapItem.fromDataItem(event.getDataItem());
        String path = event.getDataItem().getUri().getPath();
        if (event.getType() == DataEvent.TYPE_CHANGED) {
            if (PATH_RESPONSE.equals(path)) {
                // we have a response
                DataMap data = mapItem.getDataMap();
                saveFeedback(data);
            }
        } else if (event.getType() == DataEvent.TYPE_DELETED) {
            if (path.startsWith(SessionAlarmService.PATH_FEEDBACK)) {
                Uri uri = event.getDataItem().getUri();
                dismissLocalNotification(uri.getLastPathSegment());
            }
        }
    }
}
 

import com.google.samples.apps.iosched.service.SessionAlarmService; //导入依赖的package包/类
/**
 * Checks if there are changes on User's Data to sync with/from remote AppData folder.
 *
 * @return Whether or not data was changed.
 * @throws IOException if there is a problem uploading the data.
 */
private boolean doUserDataSync(String accountName) throws IOException {
    if (!isOnline()) {
        LOGD(TAG, "Not attempting userdata sync because device is OFFLINE");
        return false;
    }

    LOGD(TAG, "Starting user data sync.");

    AbstractUserDataSyncHelper helper = UserDataSyncHelperFactory.buildSyncHelper(
            mContext, accountName);
    boolean modified = helper.sync();
    if (modified) {
        // Schedule notifications for the starred sessions.
        Intent scheduleIntent = new Intent(
                SessionAlarmService.ACTION_SCHEDULE_ALL_STARRED_BLOCKS,
                null, mContext, SessionAlarmService.class);
        mContext.startService(scheduleIntent);
    }
    return modified;
}
 

import com.google.samples.apps.iosched.service.SessionAlarmService; //导入依赖的package包/类
@Override
public void run(final Context context, final Callback callback) {
    final String sessionId = SessionAlarmService.DEBUG_SESSION_ID;
    final String sessionTitle = "Debugging with Placeholder Text";
    final String sessionRoom = "Room 1";
    final String sessionSpeaker = "Lauren Ipsum";

    Intent intent = new Intent(
            SessionAlarmService.ACTION_NOTIFY_SESSION_FEEDBACK,
            null, context, SessionAlarmService.class);
    intent.putExtra(SessionAlarmService.EXTRA_SESSION_ID, sessionId);
    intent.putExtra(SessionAlarmService.EXTRA_SESSION_START, System.currentTimeMillis()
            - 30 * 60 * 1000);
    intent.putExtra(SessionAlarmService.EXTRA_SESSION_END, System.currentTimeMillis());
    intent.putExtra(SessionAlarmService.EXTRA_SESSION_TITLE, sessionTitle);
    intent.putExtra(SessionAlarmService.EXTRA_SESSION_ROOM, sessionRoom);
    intent.putExtra(SessionAlarmService.EXTRA_SESSION_SPEAKERS, sessionSpeaker);
    context.startService(intent);
    Toast.makeText(context, "Showing debug session feedback notification.", Toast.LENGTH_LONG).show();
}
 

import com.google.samples.apps.iosched.service.SessionAlarmService; //导入依赖的package包/类
/**
 * Checks if there are changes on MySchedule to sync with/from remote AppData folder.
 *
 * @return Whether or not data was changed.
 * @throws IOException if there is a problem uploading the data.
 */
private boolean doUserScheduleSync(String accountName) throws IOException {
    if (!isOnline()) {
        LOGD(TAG, "Not attempting myschedule sync because device is OFFLINE");
        return false;
    }

    LOGD(TAG, "Starting user data (myschedule) sync.");

    AbstractUserDataSyncHelper helper = UserDataSyncHelperFactory.buildSyncHelper(
            mContext, accountName);
    boolean modified = helper.sync();
    if (modified) {
        // schedule notifications for the starred sessions
        Intent scheduleIntent = new Intent(
                SessionAlarmService.ACTION_SCHEDULE_ALL_STARRED_BLOCKS,
                null, mContext, SessionAlarmService.class);
        mContext.startService(scheduleIntent);
    }
    return modified;
}
 

import com.google.samples.apps.iosched.service.SessionAlarmService; //导入依赖的package包/类
@Override
public void onReceive(Context context, Intent intent) {
    Intent scheduleIntent = new Intent(
            SessionAlarmService.ACTION_SCHEDULE_ALL_STARRED_BLOCKS,
            null, context, SessionAlarmService.class);
    context.startService(scheduleIntent);
}
 

import com.google.samples.apps.iosched.service.SessionAlarmService; //导入依赖的package包/类
@Override
public void run(Context context, Callback callback) {
    Intent intent = new Intent(
            SessionAlarmService.ACTION_SCHEDULE_ALL_STARRED_BLOCKS,
            null, context, SessionAlarmService.class);
    context.startService(intent);
}
 

import com.google.samples.apps.iosched.service.SessionAlarmService; //导入依赖的package包/类
public int onStartCommand(Intent intent, int flags, int startId) {
    if (intent != null) {
        String action = intent.getAction();
        if (SessionAlarmService.ACTION_NOTIFICATION_DISMISSAL.equals(action)) {
            String sessionId = intent.getStringExtra(SessionAlarmService.KEY_SESSION_ID);
            LOGD(TAG, "onStartCommand(): Action = ACTION_NOTIFICATION_DISMISSAL Session: "
                    + sessionId);
            dismissWearableNotification(sessionId);
        }
    }
    return Service.START_NOT_STICKY;
}
 

import com.google.samples.apps.iosched.service.SessionAlarmService; //导入依赖的package包/类
/**
 * Invokes the {@link FeedbackWearableListenerService} to dismiss the notification on both the device
 * and wear.
 */
private void dismissFeedbackNotification(String sessionId) {
    Intent dismissalIntent = new Intent(mContext, FeedbackWearableListenerService.class);
    dismissalIntent.setAction(SessionAlarmService.ACTION_NOTIFICATION_DISMISSAL);
    dismissalIntent.putExtra(SessionAlarmService.KEY_SESSION_ID, sessionId);
    mContext.startService(dismissalIntent);
}
 

import com.google.samples.apps.iosched.service.SessionAlarmService; //导入依赖的package包/类
private void setUpNotification() {
    Intent scheduleIntent;

    // Schedule session notification
    if (!hasSessionStarted()) {
        LOGD(TAG, "Scheduling notification about session start.");
        scheduleIntent = new Intent(
                SessionAlarmService.ACTION_SCHEDULE_STARRED_BLOCK,
                null, mContext, SessionAlarmService.class);
        scheduleIntent.putExtra(SessionAlarmService.EXTRA_SESSION_START, mSessionStart);
        scheduleIntent.putExtra(SessionAlarmService.EXTRA_SESSION_END, mSessionEnd);
        mContext.startService(scheduleIntent);
    } else {
        LOGD(TAG, "Not scheduling notification about session start, too late.");
    }

    // Schedule feedback notification
    if (!hasSessionEnded()) {
        LOGD(TAG, "Scheduling notification about session feedback.");
        scheduleIntent = new Intent(
                SessionAlarmService.ACTION_SCHEDULE_FEEDBACK_NOTIFICATION,
                null, mContext, SessionAlarmService.class);
        scheduleIntent.putExtra(SessionAlarmService.EXTRA_SESSION_ID, mSessionId);
        scheduleIntent.putExtra(SessionAlarmService.EXTRA_SESSION_START, mSessionStart);
        scheduleIntent.putExtra(SessionAlarmService.EXTRA_SESSION_END, mSessionEnd);
        scheduleIntent.putExtra(SessionAlarmService.EXTRA_SESSION_TITLE, mTitle);
        mContext.startService(scheduleIntent);
    } else {
        LOGD(TAG, "Not scheduling feedback notification, too late.");
    }
}
 

import com.google.samples.apps.iosched.service.SessionAlarmService; //导入依赖的package包/类
private void setupNotification() {
    Intent scheduleIntent;

    // Schedule session notification
    if (UIUtils.getCurrentTime(this) < mSessionStart) {
        LOGD(TAG, "Scheduling notification about session start.");
        scheduleIntent = new Intent(
                SessionAlarmService.ACTION_SCHEDULE_STARRED_BLOCK,
                null, this, SessionAlarmService.class);
        scheduleIntent.putExtra(SessionAlarmService.EXTRA_SESSION_START, mSessionStart);
        scheduleIntent.putExtra(SessionAlarmService.EXTRA_SESSION_END, mSessionEnd);
        startService(scheduleIntent);
    } else {
        LOGD(TAG, "Not scheduling notification about session start, too late.");
    }

    // Schedule feedback notification
    if (UIUtils.getCurrentTime(this) < mSessionEnd) {
        LOGD(TAG, "Scheduling notification about session feedback.");
        scheduleIntent = new Intent(
                SessionAlarmService.ACTION_SCHEDULE_FEEDBACK_NOTIFICATION,
                null, this, SessionAlarmService.class);
        scheduleIntent.putExtra(SessionAlarmService.EXTRA_SESSION_ID, mSessionId);
        scheduleIntent.putExtra(SessionAlarmService.EXTRA_SESSION_START, mSessionStart);
        scheduleIntent.putExtra(SessionAlarmService.EXTRA_SESSION_END, mSessionEnd);
        scheduleIntent.putExtra(SessionAlarmService.EXTRA_SESSION_TITLE, mTitleString);
        scheduleIntent.putExtra(SessionAlarmService.EXTRA_SESSION_ROOM, mRoomName);
        scheduleIntent.putExtra(SessionAlarmService.EXTRA_SESSION_SPEAKERS, mSpeakers);
        startService(scheduleIntent);
    } else {
        LOGD(TAG, "Not scheduling feedback notification, too late.");
    }
}
 

import com.google.samples.apps.iosched.service.SessionAlarmService; //导入依赖的package包/类
/**
 * Invokes the action {@link SessionAlarmService#ACTION_NOTIFICATION_DISMISSAL} which should
 * result in removal of the notification associated with the given session, which, in turn,
 * should result in removal of the corresponding notifications on both ends.
 */
public static void dismissFeedbackNotification(Context context, String sessionId) {
    Intent dismissalIntent = new Intent(context, FeedbackListenerService.class);
    dismissalIntent.setAction(SessionAlarmService.ACTION_NOTIFICATION_DISMISSAL);
    dismissalIntent.putExtra(SessionAlarmService.KEY_SESSION_ID, sessionId);
    context.startService(dismissalIntent);
}
 

import com.google.samples.apps.iosched.service.SessionAlarmService; //导入依赖的package包/类
@Override
public void onReceive(Context context, Intent intent) {
    final String action = intent.getAction();
    if (SessionCalendarService.ACTION_UPDATE_ALL_SESSIONS_CALENDAR_COMPLETED.equals(action)
            || Intent.ACTION_BOOT_COMPLETED.equals(action)) {
        Intent scheduleIntent = new Intent(
                SessionAlarmService.ACTION_SCHEDULE_ALL_STARRED_BLOCKS,
                null, context, SessionAlarmService.class);
        context.startService(scheduleIntent);
    }
}
 

import com.google.samples.apps.iosched.service.SessionAlarmService; //导入依赖的package包/类
/**
 * Checks if there are changes on User's Data to sync with/from remote AppData folder.
 *
 * @return Whether or not data was changed.
 * @throws IOException if there is a problem uploading the data.
 */
private boolean doUserDataSync(SyncResult syncResult) throws IOException {
    if (!ConnectivityUtils.isConnected(mContext)) {
        LOGD(TAG, "Not attempting userdata sync because device is OFFLINE");
        return false;
    }

    String accountName = AccountUtils.getActiveAccountName(mContext);
    if (TextUtils.isEmpty(accountName)) {
        LOGD(TAG, "Not attempting userdata sync because user is not signed in");
        return false;
    }

    LOGD(TAG, "Starting user data sync.");

    AbstractUserDataSyncHelper helper = UserDataSyncHelperFactory.buildSyncHelper(
            mContext, accountName);
    boolean modified = helper.sync();

    if (modified) {
        // Schedule notifications for the starred sessions.
        Intent scheduleIntent = new Intent(
                SessionAlarmService.ACTION_SCHEDULE_ALL_STARRED_BLOCKS,
                null, mContext, SessionAlarmService.class);
        mContext.startService(scheduleIntent);
    }
    syncResult.stats.numIoExceptions += helper.getIoExcpetions();
    return modified;
}
 

import com.google.samples.apps.iosched.service.SessionAlarmService; //导入依赖的package包/类
/**
 * Dismisses the local notification for the given session
 */
private void dismissLocalNotification(String sessionId) {
    LOGD(TAG, "dismissLocalNotification: sessionId=" + sessionId);
    NotificationManagerCompat.from(this)
            .cancel(sessionId, SessionAlarmService.FEEDBACK_NOTIFICATION_ID);
}