AndroidビームとPush通知で最強のO2Oアプリを作る：Androidで使えるO2O技術まとめ解説（終）（2/3 ページ）

<uses-sdk android:minSdkVersion="14" />
<uses-permission android:name="android.permission.INTERNET"/>
<permission android:name="com.example.pecorin.permission.C2D_MESSAGE" android:protectionLevel="signature" />
<uses-permission android:name="com.example.pecorin.permission.C2D_MESSAGE" />
<uses-permission android:name="com.google.android.c2dm.permission.RECEIVE" />
<uses-permission android:name="android.permission.WAKE_LOCK"></uses-permission>
<application
  <receiver android:name="com.google.android.gcm.GCMBroadcastReceiver" android:permission="com.google.android.c2dm.permission.SEND" >
    <intent-filter>
      <action android:name="com.google.android.c2dm.intent.RECEIVE" />
      <action android:name="com.google.android.c2dm.intent.REGISTRATION" />
      <category android:name="com.example.pecorin" />
    </intent-filter>
  </receiver>
  <service android:name=".GCMIntentService"></service>
</application>

public class DeviceRegistrationActivity extends Activity {
 
    private static final String SENDER_ID = "**********";
 
    @Override
    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.device_registration);
        Button button = (Button) findViewById(R.id.registration_button);
        button.setText(getString(R.string.registration_button));
        button.setOnClickListener(new OnClickListener() {
            @Override
            public void onClick(View v) {
                Context context = getApplicationContext();
 
                try {
                    // デバイスがGCMに対応しているかどうかをチェック
                    GCMRegistrar.checkDevice(context);
                    // GCMを利用するうえでマニフェストが適切に書かれているかどうかをチェック
                    GCMRegistrar.checkManifest(context);
                } catch (UnsupportedOperationException e) {
                    e.printStackTrace();
                } catch (IllegalStateException e) {
                    e.printStackTrace();
                }
                // RegistrationIDを取得
                final String regId = GCMRegistrar.getRegistrationId(context);
                // GCMサーバ（Googleが管理するサーバ）にサインアップしていない場合
                if (regId.equals("")) {
                  // 取得したSender IDを使ってGCMサーバにサインアップする
                  GCMRegistrar.register(context, SENDER_ID);
                } else {
                     // GCMサーバ（Googleが管理するサーバ）にサインアップしている場合、メッセージを出力する
                    Toast.makeText(context, "Already registered", Toast.LENGTH_SHORT).show();
                }
            }
        });
    }
}

public class GCMIntentService extends GCMBaseIntentService {
  
    private static final String SENDER_ID = "**********";
    private static final String PREFERENCE_KEY = "preference";
    private static final String SERVER_URL = "http://";
  
    public GCMIntentService() {
        super(SENDER_ID);
    }
  
    // GCMからメッセージが送信された場合、このメソッドが呼ばれる
    @Override
    protected void onMessage(Context context, Intent intent) {
  
        String message = intent.getStringExtra("message");
  
        NotificationManager notificationManager = (NotificationManager) context.getSystemService(NOTIFICATION_SERVICE);
        Notification notification = new Notification(R.drawable.ic_launcher, message, System.currentTimeMillis());
        notification.flags = Notification.FLAG_AUTO_CANCEL;
        Intent remoteIntent = new Intent(context.getApplicationContext(), FriendList.class);
        PendingIntent contentIntent = PendingIntent.getActivity(context.getApplicationContext(), 0, remoteIntent, 0);
        notification.setLatestEventInfo(context.getApplicationContext(), context.getString(R.string.app_name), message, contentIntent);
        notificationManager.notify(R.string.app_name, notification);
    }
  
    // GCMサーバに端末登録が完了した場合、このメソッドが呼ばれる
    @Override
    protected void onRegistered(Context context, String regId) {
        SharedPreferences sharedpref = context.getSharedPreferences(PREFERENCE_KEY, MODE_PRIVATE);
        String facebook_id = sharedpref.getString("facebook_id", null);
        UpLoadRegistrationIdTask task = new UpLoadRegistrationIdTask(facebook_id, regId, context);
        task.execute();
    }
  
    // 非同期で行うためにAsyncTaskを利用して、RegistrationIDをサードパーティアプリサーバにアップロード
    public class UpLoadRegistrationIdTask extends AsyncTask<Void, Void, Integer> {
        private Context context;
        private String facebook_id;
        private String regId;
 
        public UpLoadRegistrationIdTask(String facebookId, String regId, Context context) {
            this.facebook_id = facebookId;
            this.regId = regId;
            this.context = context;
        }
  
        @Override
        protected Integer doInBackground(Void... arg0) {
 
            int statusCode = 0;
            HttpResponse objResponse = uploadRegistrationId(facebook_id, regId);
            statusCode = objResponse.getStatusLine().getStatusCode();
            return statusCode;
        }
  
        @Override
        protected void onPostExecute(Integer statusCode) {
  
            if (statusCode == 201) {
                Intent newIntent = new Intent(context, FriendList.class);
                newIntent.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK | Intent.FLAG_ACTIVITY_CLEAR_TOP);
                context.startActivity(newIntent);
            }
        }
    }
  
    private HttpResponse uploadRegistrationId(String facebook_id, String regId) {
    〜（省略）〜
    }
}

public class FriendListActivity extends Activity {
  
    private User mSender;
    private ListView mListView;
  
    @Override
    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
  
    〜（省略）〜
  
        LayoutInflater factory = LayoutInflater.from(this);
        final View inputView = factory.inflate(R.layout.custom_dialog, null);
  
        AlertDialog.Builder builder = new AlertDialog.Builder(this);
        builder.setIcon(R.drawable.ic_launcher).setTitle(R.string.greet_message).setCancelable(true).setView(inputView);
        final AlertDialog dialog = builder.create();
        mListView.setOnItemClickListener(new AdapterView.OnItemClickListener() {
            @Override
            public void onItemClick(AdapterView<?> parent, View view, int position, long id) {
                ListView listView = (ListView) parent;
                User item = (User) listView.getItemAtPosition(position);
                final String recieverFacebookId = item.getFacebookId();
                final String recieverName = item.getName();
  
                greetButton.setOnClickListener(new OnClickListener() {
                    @Override
                    public void onClick(View v) {
                        dialog.dismiss();
                        String type = "gcm";
                        greetTask task = new greetTask(mSender, type);
                        task.execute(recieverFacebookId);
                    }
                });
  〜（省略）〜
            }
            public class greetTask extends AsyncTask<String, Void, String> {
                private User sender;
                private String type;
                private String ServerURL = "http://";
  
                public greetTask(User sender, String type) {
                    this.sender = sender;
                }
                @Override
                protected String doInBackground(String... ids) {
  
                    String recieverFacebookId = ids[0];
                    String message = sender.greet(recieverFacebookId, type, ServerURL);
                    return message;
                }
                @Override
                protected void onPostExecute(String message) {
                    Toast.makeText(getApplicationContext(), message, Toast.LENGTH_SHORT).show();
                }
            }
        }

public class User {
    public String greet(String recieverFacebookId, String type, String ServerUrl) {
〜（省略）〜
    }
}

class DeviceRegistrationsController < ApplicationController
  protect_from_forgery :except => :create
 
  def create
    facebook_id = params["facebook_id"]
    registration_id = params["registration_id"]
    if user = User.find_by_facebook_id(facebook_id)
      user.registration_id = registration_id
      if user.save
        render :text => "Completion of registration!", :status => 201
      else
        render :text => "Failure to register", :status => 500
      end
    else
      render :text => "Failure to register", :status => 500
    end
  end
end

class PecoriController < ApplicationController
  protect_from_forgery :except => :create
 
  def create
    sender_facebook_id = params["sender_facebook_id"]
    receiver_facebook_id = params["receiver_facebook_id"]
    type = params["type"]
    receiver_user = User.find_by_facebook_id(receiver_facebook_id)
    sender_user = User.find_by_facebook_id(sender_facebook_id)
    if receiver_user and sender_user
      receiver_registration_id = receiver_user.registration_id
      sender_name = sender_user.name
      pecori_message = "Pecori from " + sender_name
      message = {:message => pecori_message }
      registration_ids = []
      registration_ids << receiver_registration_id
      gcm_result, gcm_result_message = GcmAccess.gcm_post_message(registration_ids, message)
      if gcm_result
        render :text => gcm_result_message, :status => 200
      else
        render :text => gcm_result_message, :status => 500
      end
    end
  end
end

module GcmAccess
  require 'net/http'
  require 'uri'
  require 'json'
  
  API_KEY = "**********"
  
  def self.gcm_post_message(registration_ids, data={ })
  
    url = URI.parse("https://android.googleapis.com/gcm/send")
  
    message_data = {}
    message_data["registration_ids"] = registration_ids
    message_data["data"] = data
  
    headers = { "Content-Type" => "application/json", "Authorization" => "key=" + API_KEY }
  
    http = Net::HTTP.new(url.host, url.port)
    http.use_ssl = true
    # 動作確認のみ行いたいので、一時的にOpenSSL::SSL::VERIFY_NONE
    http.verify_mode = OpenSSL::SSL::VERIFY_NONE
  
    res = http.post(url.path, message_data.to_json, headers)
  
    if res.code == "200"
      res_message = "GCM Post Message Success."
      return true, res_message
    else
      res_message = "GCM Post Message Failed."
    end
  
    return false, res_message
  
  end
end