import com.google.android.gms.awareness.Awareness; //导入依赖的package包/类
protected void registerFence(final String fenceKey, final AwarenessFence fence) {
    Awareness.FenceApi.updateFences(
            client,
            new FenceUpdateRequest.Builder()
                    .addFence(fenceKey, fence, myPendingIntent)             //Add fence to the pendingIntent
                    .build())
            .setResultCallback(new ResultCallback<Status>() {
                @Override
                public void onResult(@NonNull Status status) {
                    if (status.isSuccess()) {
                        Log.e(fenceKey, "Fence was successfully registered.");
                    } else {
                        Log.e(fenceKey, "Fence could not be registered: " + status);
                    }
                }
            });
}
 

import com.google.android.gms.awareness.Awareness; //导入依赖的package包/类
protected void unregisterFence(final String fenceKey) {
    Awareness.FenceApi.updateFences(
            client,
            new FenceUpdateRequest.Builder()
                    .removeFence(fenceKey)
                    .build()).setResultCallback(new ResultCallback<Status>() {
        @Override
        public void onResult(@NonNull Status status) {
            if (status.isSuccess()) {
                Log.e("Fence", "Fence " + fenceKey + " successfully removed.");

            } else {
                Log.e("Fence", "Fence " + fenceKey + " can not be removed.");
            }
        }
    });
}
 

import com.google.android.gms.awareness.Awareness; //导入依赖的package包/类
/**
 * Get the current weather condition at current location.
 */
@RequiresPermission("android.permission.ACCESS_FINE_LOCATION")
private void getWeather() {
    //noinspection MissingPermission
    Awareness.SnapshotApi.getWeather(mGoogleApiClient)
            .setResultCallback(new ResultCallback<WeatherResult>() {
                @Override
                public void onResult(@NonNull WeatherResult weatherResult) {
                    if (!weatherResult.getStatus().isSuccess()) {
                        Toast.makeText(SnapshotApiActivity.this, "Could not get weather.", Toast.LENGTH_LONG).show();
                        return;
                    }

                    //parse and display current weather status
                    Weather weather = weatherResult.getWeather();
                    String weatherReport = "Temperature: " + weather.getTemperature(Weather.CELSIUS)
                            + "\nHumidity: " + weather.getHumidity();
                    ((TextView) findViewById(R.id.weather_status)).setText(weatherReport);
                }
            });
}
 

import com.google.android.gms.awareness.Awareness; //导入依赖的package包/类
/**
 * Check weather the headphones are plugged in or not? This is under snapshot api category.
 */
private void getHeadphoneStatus() {
    Awareness.SnapshotApi.getHeadphoneState(mGoogleApiClient)
            .setResultCallback(new ResultCallback<HeadphoneStateResult>() {
                @Override
                public void onResult(@NonNull HeadphoneStateResult headphoneStateResult) {
                    if (!headphoneStateResult.getStatus().isSuccess()) {
                        Toast.makeText(SnapshotApiActivity.this, "Could not get headphone state.", Toast.LENGTH_LONG).show();
                        return;
                    }
                    HeadphoneState headphoneState = headphoneStateResult.getHeadphoneState();

                    //display the status
                    TextView headphoneStatusTv = (TextView) findViewById(R.id.headphone_status);
                    headphoneStatusTv.setText(headphoneState.getState() == HeadphoneState.PLUGGED_IN ? "Plugged in." : "Unplugged.");
                }
            });
}
 

import com.google.android.gms.awareness.Awareness; //导入依赖的package包/类
/**
 * Add a fence to the Google API
 * If not connected, this will only trigger a connection.
 * This call requires that the following granted permissions:
 *      - ACCESS_FINE_LOCATION if one of the fence is a {@link StorableLocationFence}
 *      - ACTIVITY_RECOGNITION if one of the fence is a {@link StorableActivityFence}
 * @param id the unique id of the fence.
 * @param fence the fence to store
 * @param pendingIntentClassName the class name of the pending intent to call when the fence will be valid.
 * @param status the status that will be called when the addition fails or succeed.
 * @return true if add has been asked, false otherwise.
 */
boolean addFence(@NonNull String id, @NonNull AwarenessFence fence,
                        @NonNull String pendingIntentClassName, ResultCallback<Status> status) {
    if (mGoogleApiClient.isConnected()) {
        FenceUpdateRequest.Builder requestBuilder = new FenceUpdateRequest.Builder()
                .addFence(id, fence, createRequestPendingIntent(pendingIntentClassName));

        Awareness.FenceApi.updateFences(mGoogleApiClient, requestBuilder.build())
                .setResultCallback(status);

        return true;
    } else {
        connect();
        return false;
    }
}
 

import com.google.android.gms.awareness.Awareness; //导入依赖的package包/类
/**
 * Ask to remove a fence from the Google API.
 * @param fenceId The id of the fence to remove.
 * @param status the status that will be called when the addition fails or succeed.
 * @return true if remove has been asked, false otherwise.
 */
boolean removeFence(@NonNull String fenceId, ResultCallback<Status> status) {

    if (mGoogleApiClient.isConnected()) {

        FenceUpdateRequest.Builder requestBuilder = new FenceUpdateRequest.Builder()
                .removeFence(fenceId);

        Awareness.FenceApi.updateFences(mGoogleApiClient, requestBuilder.build())
                .setResultCallback(status);
        Log.i(TAG, "Removed " + fenceId);
        return true;
    } else {
        connect();
        return false;
    }
}
 

import com.google.android.gms.awareness.Awareness; //导入依赖的package包/类
@Override
protected void onPause() {
    // Unregister the fence:
    Awareness.getFenceClient(this).updateFences(new FenceUpdateRequest.Builder()
            .removeFence(FENCE_KEY)
            .build())
            .addOnSuccessListener(new OnSuccessListener<Void>() {
                @Override
                public void onSuccess(Void aVoid) {
                    Log.i(TAG, "Fence was successfully unregistered.");
                }
            })
            .addOnFailureListener(new OnFailureListener() {
                @Override
                public void onFailure(@NonNull Exception e) {
                    Log.e(TAG, "Fence could not be unregistered: " + e);
                }
            });

    super.onPause();
}
 

import com.google.android.gms.awareness.Awareness; //导入依赖的package包/类
/**
 * Helper method to retrieve weather data using the Snapshot API.  Since Weather is protected
 * by a runtime permission, this snapshot code is going to be called in multiple places:
 * {@link #printSnapshot()} when the permission has already been accepted, and
 * {@link #onRequestPermissionsResult(int, String[], int[])} when the permission is requested
 * and has been granted.
 */
private void getWeatherSnapshot() {
    if (ActivityCompat.checkSelfPermission(this, Manifest.permission.ACCESS_FINE_LOCATION)
            == PackageManager.PERMISSION_GRANTED) {
        Awareness.getSnapshotClient(this).getWeather()
                .addOnSuccessListener(new OnSuccessListener<WeatherResponse>() {
                    @Override
                    public void onSuccess(WeatherResponse weatherResponse) {
                        Weather weather = weatherResponse.getWeather();
                        weather.getConditions();
                        mLogFragment.getLogView().println("Weather: " + weather);
                    }
                })
                .addOnFailureListener(new OnFailureListener() {
                    @Override
                    public void onFailure(@NonNull Exception e) {
                        Log.e(TAG, "Could not get weather: " + e);
                    }
                });
    }
}
 

import com.google.android.gms.awareness.Awareness; //导入依赖的package包/类
private void unregisterFenceRequest(GoogleApiClient googleApiClient, ObservableEmitter<Boolean> emitter) {
    FenceUpdateRequest fenceUpdateRequest = new FenceUpdateRequest.Builder()
            .removeFence(OBSERVABLE_FENCE)
            .build();

    Awareness.FenceApi.updateFences(googleApiClient, fenceUpdateRequest)
            .setResultCallback(status -> {
                if (!status.isSuccess()) {
                    emitter.onError(new ClientException("Error removing observable fence. " + status.getStatusMessage()));
                }

                if (googleApiClient.isConnecting() || googleApiClient.isConnected()) {
                    googleApiClient.disconnect();
                }
                emitter.onComplete();
            });
}
 

import com.google.android.gms.awareness.Awareness; //导入依赖的package包/类
@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_snapshot);

    mGoogleApiClient = new GoogleApiClient.Builder(SnapshotActivity.this)
            .addApi(Awareness.API)
            .build();
    mGoogleApiClient.connect();

    mUserActivityTextView = (TextView) findViewById(R.id.userActivityTextView);
    mLocationTextView = (TextView) findViewById(R.id.locationTextView);
    mBeaconTextView = (TextView) findViewById(R.id.beaconTextView);
    mPlacesTextView = (TextView) findViewById(R.id.placesTextView);
    mTimeTextView = (TextView) findViewById(R.id.timeTextView);
    mWeatherTextView = (TextView) findViewById(R.id.weatherTextView);
    mHeadphonesTextView = (TextView) findViewById(R.id.action1TextView);

    mSnapshotButton = (Button) findViewById(R.id.snapshotButton);
    mSnapshotButton.setOnClickListener(new View.OnClickListener() {
        @Override
        public void onClick(View view) {
            getSnapshots();
        }
    });
}
 

import com.google.android.gms.awareness.Awareness; //导入依赖的package包/类
private void addHeadphoneFence() {
    Intent intent = new Intent(MY_FENCE_RECEIVER_ACTION);
    PendingIntent mFencePendingIntent = PendingIntent.getBroadcast(FenceActivity.this,
            10001,
            intent,
            0);

    AwarenessFence headphoneFence = HeadphoneFence.during(HeadphoneState.PLUGGED_IN);
    Awareness.FenceApi.updateFences(
            mGoogleApiClient,
            new FenceUpdateRequest.Builder()
                    .addFence(HEADPHONE_FENCE_KEY, headphoneFence, mFencePendingIntent)
                    .build())
            .setResultCallback(new ResultCallback<Status>() {
                @Override
                public void onResult(@NonNull Status status) {
                    if (status.isSuccess()) {
                        Log.i(TAG, "Fence was successfully registered.");
                    } else {
                        Log.e(TAG, "Fence could not be registered: " + status);
                    }
                }
            });
}
 

import com.google.android.gms.awareness.Awareness; //导入依赖的package包/类
private void addHeadphoneAndLocationFence() {
        Intent intent = new Intent(MY_FENCE_RECEIVER_ACTION);
        PendingIntent mFencePendingIntent = PendingIntent.getBroadcast(FenceActivity.this,
                10001,
                intent,
                0);

        AwarenessFence headphoneFence = HeadphoneFence.during(HeadphoneState.PLUGGED_IN);
        AwarenessFence activityFence = DetectedActivityFence.during(DetectedActivityFence.WALKING);
        AwarenessFence jointFence = AwarenessFence.and(headphoneFence, activityFence);
        Awareness.FenceApi.updateFences(
                mGoogleApiClient,
                new FenceUpdateRequest.Builder()
                        .addFence(HEADPHONE_AND_WALKING_FENCE_KEY,
                                jointFence, mFencePendingIntent)
                        .build())
                .setResultCallback(new ResultCallback<Status>() {
                    @Override
                    public void onResult(@NonNull Status status) {
                        if (status.isSuccess()) {
                            Log.i(TAG, "Headphones AND Walking Fence was successfully registered.");
                        } else {
                            Log.e(TAG, "Headphones AND Walking Fence could not be registered: " + status);
                        }
                    }
                });
}
 

import com.google.android.gms.awareness.Awareness; //导入依赖的package包/类
@Override
    protected void provide() {
        Thread thread = Thread.currentThread();
        Thread.UncaughtExceptionHandler wrapped = thread.getUncaughtExceptionHandler();
        if (!(wrapped instanceof GoogleApiFixUncaughtExceptionHandler)) {
            GoogleApiFixUncaughtExceptionHandler handler = new GoogleApiFixUncaughtExceptionHandler(wrapped);
            thread.setUncaughtExceptionHandler(handler);
        }
//        Thread thread = Thread.currentThread();
//        thread.setUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() {
//            @Override
//            public void uncaughtException(Thread thread, Throwable throwable) {
//                System.out.println(thread.getName() + " throws exception: " + throwable);
//            }
//        });

            client = new GoogleApiClient.Builder(getContext())                              //Establish Connection
                    .addApi(Awareness.API)
                    .build();
            client.connect();
            walkingFence = DetectedActivityFence.during(DetectedActivityFence.WALKING);     //Create Fence
            onFootFence = DetectedActivityFence.during(DetectedActivityFence.ON_FOOT);
            runningFence = DetectedActivityFence.during(DetectedActivityFence.RUNNING);

            intent = new Intent(FENCE_RECEIVER_ACTION);                                     //Set up the intent and intent filter
            myFillter = new IntentFilter(FENCE_RECEIVER_ACTION);
            myPendingIntent = PendingIntent.getBroadcast(getContext(), 0, intent, 0);           //Set up the pendingIntent
            myFenceReceiver = new FenceReceiver();                                              //Set up the receiver
            getContext().registerReceiver(myFenceReceiver, myFillter);
            registerFence(WALKINGFENCE, walkingFence);                                       //register the fences
            registerFence(TILTINGFENCE, tiltingFence);
            registerFence(ONFOOTFENCE, onFootFence);
            registerFence(RUNNINGFENCE, runningFence);
    }
 

import com.google.android.gms.awareness.Awareness; //导入依赖的package包/类
private void initAwarenessClient() {
    if (awarenessApiClient == null || !awarenessApiClient.isConnected()) {
        awarenessApiClient = new GoogleApiClient.Builder(getApplicationContext())
                .addApi(Awareness.API)
                .build();
        awarenessApiClient.connect();
    }
}
 

import com.google.android.gms.awareness.Awareness; //导入依赖的package包/类
@Override
public void onMapReady(final GoogleMap googleMap) {
    googleMap.getUiSettings().setAllGesturesEnabled(false);

    googleMap.setMaxZoomPreference(20.0f);
    googleMap.setMinZoomPreference(10.0f);
    final LatLng[] currentLocation = new LatLng[1];


    if (ActivityCompat.checkSelfPermission(this, Manifest.permission.ACCESS_FINE_LOCATION) != PackageManager.PERMISSION_GRANTED) {
        return;
    }
    Awareness.SnapshotApi.getLocation(awarenessApiClient)
            .setResultCallback(new ResultCallback<LocationResult>() {
                @Override
                public void onResult(@NonNull LocationResult locationResult) {
                    if (!locationResult.getStatus().isSuccess()) {
                        Log.e("", "Could not get location.");
                        return;
                    }
                    Location location = locationResult.getLocation();
                    currentLocation[0] = new LatLng(location.getLatitude(), location.getLongitude());
                    googleMap.moveCamera(CameraUpdateFactory.newLatLngZoom(currentLocation[0], 12.0f));
                    googleMap.animateCamera(CameraUpdateFactory.zoomTo(16.0f), 3000, null);
                }
            });
}
 

import com.google.android.gms.awareness.Awareness; //导入依赖的package包/类
@Override
public void init(Context context) {
    client = new GoogleApiClient.Builder(context)
            .addApi(Awareness.API)
            .addConnectionCallbacks(this)
            .addOnConnectionFailedListener(this)
            .build();
    client.connect();

    HandlerThread googleHandleThread = new HandlerThread("googleHandleThread");
    googleHandleThread.start();
    googleHandler = new Handler(googleHandleThread.getLooper()){
        @Override
        public void handleMessage(Message msg) {
            Awareness.SnapshotApi.getDetectedActivity(client)
                    .setResultCallback(new ResultCallback<DetectedActivityResult>(){
                        @Override
                        public void onResult(@NonNull DetectedActivityResult detectedActivityResult) {
                            handleResult(detectedActivityResult);
                        }
                    });
            Message newMsg = new Message();
            newMsg.what = 0;
            googleHandler.sendMessageDelayed(newMsg, 5000);
        }
    };
}
 

import com.google.android.gms.awareness.Awareness; //导入依赖的package包/类
/**
 * Build the google api client to use awareness apis.
 */
private void buildApiClient() {
    mGoogleApiClient = new GoogleApiClient.Builder(CombineFenceApiActivity.this)
            .addApi(Awareness.API)
            .addConnectionCallbacks(this)
            .build();
    mGoogleApiClient.connect();
}
 

import com.google.android.gms.awareness.Awareness; //导入依赖的package包/类
/**
 * Build the google api client to use awareness apis.
 */
private void buildApiClient() {
    mGoogleApiClient = new GoogleApiClient.Builder(SnapshotApiActivity.this)
            .addApi(Awareness.API)
            .addConnectionCallbacks(this)
            .build();
    mGoogleApiClient.connect();
}
 

import com.google.android.gms.awareness.Awareness; //导入依赖的package包/类
/**
 * Get the nearby places using Snapshot apis. We are going to display only first 5 places to the user in the list.
 */
@RequiresPermission("android.permission.ACCESS_FINE_LOCATION")
private void getPlace() {
    //noinspection MissingPermission
    Awareness.SnapshotApi.getPlaces(mGoogleApiClient)
            .setResultCallback(new ResultCallback<PlacesResult>() {
                @Override
                public void onResult(@NonNull final PlacesResult placesResult) {
                    if (!placesResult.getStatus().isSuccess()) {
                        Toast.makeText(SnapshotApiActivity.this, "Could not get places.", Toast.LENGTH_LONG).show();
                        return;
                    }

                    //get the list of all like hood places
                    List<PlaceLikelihood> placeLikelihoodList = placesResult.getPlaceLikelihoods();

                    // Show the top 5 possible location results.
                    LinearLayout linearLayout = (LinearLayout) findViewById(R.id.current_place_container);
                    linearLayout.removeAllViews();
                    if (placeLikelihoodList != null) {
                        for (int i = 0; i < 5 && i < placeLikelihoodList.size(); i++) {
                            PlaceLikelihood p = placeLikelihoodList.get(i);

                            //add place row
                            View v = LayoutInflater.from(SnapshotApiActivity.this).inflate(R.layout.row_nearby_place, linearLayout, false);
                            ((TextView) v.findViewById(R.id.place_name)).setText(p.getPlace().getName());
                            ((TextView) v.findViewById(R.id.place_address)).setText(p.getPlace().getAddress());
                            linearLayout.addView(v);
                        }
                    } else {
                        Toast.makeText(SnapshotApiActivity.this, "Could not get nearby places.", Toast.LENGTH_LONG).show();
                    }
                }
            });
}
 

import com.google.android.gms.awareness.Awareness; //导入依赖的package包/类
/**
 * Get user's current location. We are also displaying Google Static map.
 */
@RequiresPermission("android.permission.ACCESS_FINE_LOCATION")
private void getLocation() {
    //noinspection MissingPermission
    Awareness.SnapshotApi.getLocation(mGoogleApiClient)
            .setResultCallback(new ResultCallback<LocationResult>() {
                @Override
                public void onResult(@NonNull LocationResult locationResult) {
                    if (!locationResult.getStatus().isSuccess()) {
                        Toast.makeText(SnapshotApiActivity.this, "Could not get location.", Toast.LENGTH_LONG).show();
                        return;
                    }

                    //get location
                    Location location = locationResult.getLocation();
                    ((TextView) findViewById(R.id.current_latlng)).setText(location.getLatitude() + ", " + location.getLongitude());

                    //display the time
                    TextView timeTv = (TextView) findViewById(R.id.latlng_time);
                    SimpleDateFormat sdf = new SimpleDateFormat("h:mm a dd-MM-yyyy", Locale.getDefault());
                    timeTv.setText("as on: " + sdf.format(new Date(location.getTime())));

                    //Load the current map image from Google map
                    String url = "https://maps.googleapis.com/maps/api/staticmap?center="
                            + location.getLatitude() + "," + location.getLongitude()
                            + "&zoom=20&size=400x250&key=" + getString(R.string.api_key);
                    Picasso.with(SnapshotApiActivity.this).load(url).into((ImageView) findViewById(R.id.current_map));
                }
            });
}