Subversion Repositories SmartDukaan

package com.saholic.profittill.BroadcastReceivers;

import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.content.SharedPreferences;
import android.os.AsyncTask;
import android.os.Bundle;
import android.telephony.SmsManager;
import android.telephony.SmsMessage;
import android.util.Log;
import android.widget.Toast;

import com.saholic.profittill.Constants.ProfitTillConstants;

import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
import org.apache.http.client.HttpClient;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.message.BasicNameValuePair;

import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;

/**
 * Created by rajender on 5/5/17.
 */
public class SmsReceiver extends BroadcastReceiver {
    SharedPreferences.Editor apiDataEditor,userDataEditor;
    SharedPreferences apiData,userData;
    ArrayList<NameValuePair> messageNameValuePair;

    // Get the object of SmsManager
    public SmsReceiver() {
    }
    final SmsManager sms = SmsManager.getDefault();
    public void onReceive(Context context, Intent intent) {
        apiData = context.getSharedPreferences("API_Data", Context.MODE_PRIVATE);
        userData = context.getSharedPreferences("User_Data", Context.MODE_PRIVATE);
        userDataEditor = userData.edit();
        apiDataEditor = apiData.edit();
        Log.d("recieved","received");
        // Retrieves a map of extended data from the intent.
        final Bundle bundle = intent.getExtras();

        try {

            if (bundle != null) {

                final Object[] pdusObj = (Object[]) bundle.get("pdus");

                for (int i = 0; i < pdusObj.length; i++) {

                    SmsMessage currentMessage = SmsMessage.createFromPdu((byte[]) pdusObj[i]);
                    String phoneNumber = currentMessage.getDisplayOriginatingAddress();

                    String senderNum = phoneNumber;
                    String message = currentMessage.getDisplayMessageBody();

                    Log.i("SmsReceiver", "senderNum: "+ senderNum + "; message: " + message);
                    String lastTwo = null;
                    if (senderNum != null && senderNum.length() >= 6) {
                        lastTwo = senderNum.substring(senderNum.length() - 6);
                    }
                    try {
                        if (lastTwo.equalsIgnoreCase(apiData.getString("Sender_CLI","PROFTM"))){
                              messageNameValuePair = new ArrayList<>();
                              messageNameValuePair.add(new BasicNameValuePair("message",message));

                              new sendOtpmessage().execute();
                            int duration = Toast.LENGTH_LONG;
                            Toast toast = Toast.makeText(context,"senderNum: "+ senderNum + ", message: " + message, duration);
                            toast.show();

                        }
                        else{

                        }
                    }
                    catch(Exception e){
                        e.printStackTrace();
                    }


                }
            }

        } catch (Exception e) {
            Log.e("SmsReceiver", "Exception smsReceiver" +e);

        }
    }

    class sendOtpmessage extends AsyncTask<String, Integer, String> {

        @Override
        protected void onPreExecute() {

            super.onPreExecute();
        }

        @Override
        protected String doInBackground(String... params) {
            try {
            HttpClient httpclient = new DefaultHttpClient();
            HttpPost httppost = new HttpPost(ProfitTillConstants.Web_Api+"/otp/parseOTP");
            httppost.setHeader("Auth-Token",userData.getString("token",""));
            httppost.setEntity(new UrlEncodedFormEntity(messageNameValuePair));
            HttpResponse response = httpclient.execute(httppost);
            HttpEntity entity = response.getEntity();
            int status = response.getStatusLine().getStatusCode();
            }
            catch (UnsupportedEncodingException e) {
                e.printStackTrace();
            }
            catch (IOException e) {
                e.printStackTrace();
            }
            return null;
        }
        @Override
        protected void onPostExecute(String result) {
            super.onPostExecute(result);

        }

    }
    }