Android6.0来电号码与电话薄联系人进行匹配

//packages/service/***/call.java

public void handlecreateconnectionsuccess(

 callidmapper idmapper,

 parcelableconnection connection) {

 sethandle(connection.gethandle(), connection.gethandlepresentation());//这个函数很重要，会启动一个查询

 setcallerdisplayname(connection.getcallerdisplayname(), connection.getcallerdisplaynamepresentation());

 setextras(connection.getextras());

 if (misincoming) {

 // we do not handle incoming calls immediately when they are verified by the connection

 // service. we allow the caller-info-query code to execute first so that we can read the

 // direct-to-voicemail property before deciding if we want to show the incoming call to

 // the user or if we want to reject the call.

 mdirecttovoicemailquerypending = true;

 // timeout the direct-to-voicemail lookup execution so that we dont wait too long before

 // showing the user the incoming call screen.

 mhandler.postdelayed(mdirecttovoicemailrunnable, timeouts.getdirecttovoicemailmillis(

  mcontext.getcontentresolver()));

 }

}

//call.java

public void sethandle(uri handle, int presentation) {

 startcallerinfolookup();

}

private void startcallerinfolookup() {

 final string number = mhandle == null ? null : mhandle.getschemespecificpart();

 mquerytoken++; // updated so that previous queries can no longer set the information.

 mcallerinfo = null;

 if (!textutils.isempty(number)) {

 mhandler.post(new runnable() {

  @override

  public void run() {

  mcallerinfoasyncqueryfactory.startquery(mquerytoken,

   mcontext,number,mcallerinfoquerylistener,call.this);

  }});

 }

}

private static final componentname service_component = new componentname(

  "com.android.server.telecom",

  "com.android.server.telecom.components.telecomservice");

private void connecttotelecom() {

 synchronized (mlock) {

 telecomserviceconnection serviceconnection = new telecomserviceconnection();

 intent intent = new intent(service_action);

 intent.setcomponent(service_component);

 // bind to telecom and register the service

 if (mcontext.bindserviceasuser(intent, serviceconnection, flags, userhandle.owner)) {

  mserviceconnection = serviceconnection;

 } }}

public void onbootphase(int phase) {//这个在系统启动阶段就会触发

 if (phase == phase_activity_manager_ready) {

 connecttotelecom();

 }}

//telecomservice.java

telecomsystem.setinstance(

 new telecomsystem(

 context,

 new missedcallnotifierimpl(context.getapplicationcontext()),

 new callerinfoasyncqueryfactory() {

  @override

  public callerinfoasyncquery startquery(int token, context context,

   string number,callerinfoasyncquery.onquerycompletelistener listener,

   object cookie) {

  return callerinfoasyncquery.startquery(token, context, number, listener, cookie);

  }},

 new headsetmediabuttonfactory() {},

 new proximitysensormanagerfactory() {},

 new incallwakelockcontrollerfactory() {},

 new vicenotifier() {}));

//frameworks/base/telephony/java/com/android/internal/callerinfoasyncquery.java

/**

 * factory method to start the query based on a number.

 *

 * note: if the number contains an "@" character we treat it

 * as a sip address, and look it up directly in the data table

 * rather than using the phonelookup table.

 * todo: but eventually we should expose two separate methods, one for

 * numbers and one for sip addresses, and then have

 * phoneutils.startgetcallerinfo() decide which one to call based on

 * the phone type of the incoming connection.

 */

 public static callerinfoasyncquery startquery(int token, context context, string number,

  onquerycompletelistener listener, object cookie) {

 int subid = subscriptionmanager.getdefaultsubid();

 return startquery(token, context, number, listener, cookie, subid);

 }

/**

 * factory method to start the query with a uri query spec.

 */ 

public static callerinfoasyncquery startquery(int token, context context, uri contactref,

  onquerycompletelistener listener, object cookie) {

c.mhandler.startquery(token,

    cw, // cookie
    contactref, // uri，注意这里的查询地址
    null, // projection
    null, // selection
    null, // selectionargs
    null); // orderby
 return c;
}

//frameworks/base/***/callerinfoasyncquery.java
public static callerinfoasyncquery startquery(int token, context context, string number, onquerycompletelistener listener, object cookie, int subid) {
 // construct the uri object and query params, and start the query.
 final uri contactref = phonelookup.enterprise_content_filter_uri.buildupon().appendpath(number)
  .appendqueryparameter(phonelookup.query_parameter_sip_address, string.valueof(phonenumberutils.isurinumber(number)))
  .build();
 callerinfoasyncquery c = new callerinfoasyncquery();
 c.allocate(context, contactref);
 //create cookiewrapper, start query
 cookiewrapper cw = new cookiewrapper();
 cw.listener = listener; cw.cookie = cookie;
 cw.number = number; cw.subid = subid;
 // check to see if these are recognized numbers, and use shortcuts if we can.
 if (phonenumberutils.islocalemergencynumber(context, number)) {
 cw.event = event_emergency_number;
 } else if (phonenumberutils.isvoicemailnumber(subid, number)) {
 cw.event = event_voicemail_number;
 } else {
 cw.event = event_new_query;
 }

 c.mhandler.startquery(token,
    cw, // cookie
    contactref, // uri
    null, // projection
    null, // selection
    null, // selectionargs
    null); // orderby
 return c;
}

//asyncqueryhandler.java
public void startquery(int token, object cookie, uri uri,
 string[] projection, string selection, string[] selectionargs,
 string orderby) {
 // use the token as what so canceloperations works properly
 message msg = mworkerthreadhandler.obtainmessage(token);
 msg.arg1 = event_arg_query;
 workerargs args = new workerargs();
 args.handler = this;
 args.uri = uri;
 msg.obj = args;
 mworkerthreadhandler.sendmessage(msg);

}

//asyncqueryhandler.java
public void handlemessage(message msg) {
 workerargs args = (workerargs) msg.obj;
 cookiewrapper cw = (cookiewrapper) args.cookie;
 if (cw == null) {
 // normally, this should never be the case for calls originating
 // from within this code.
 // however, if there is any code that this handler calls (such as in
 // super.handlemessage) that does place unexpected messages on the
 // queue, then we need pass these messages on.
 } else {
 switch (cw.event) {
  case event_new_query://它的值跟asyncqueryhandler的event_arg_query一样，都是1
  //start the sql command.
  super.handlemessage(msg);
  break;
  case event_end_of_queue:
  // query was already completed, so just send the reply.
  // passing the original token value back to the caller
  // on top of the event values in arg1.
  message reply = args.handler.obtainmessage(msg.what);
  reply.obj = args;
  reply.arg1 = msg.arg1;
  reply.sendtotarget();
  break;
  default:
 }}}}

//asyncqueryhandler.java
protected class workerhandler extends handler {
 @override
 public void handlemessage(message msg) {
 final contentresolver resolver = mresolver.get();
 workerargs args = (workerargs) msg.obj;
 int token = msg.what;
 int event = msg.arg1;
 switch (event) {
  case event_arg_query:
  cursor cursor;
  try {
   cursor = resolver.query(args.uri, args.projection,
    args.selection, args.selectionargs,
    args.orderby);
   // calling getcount() causes the cursor window to be filled,
   // which will make the first access on the main thread a lot faster.
   if (cursor != null) {
   cursor.getcount();
   }} 
  args.result = cursor;
  break;
 }
 // passing the original token value back to the caller
 // on top of the event values in arg1.
 message reply = args.handler.obtainmessage(token);

 reply.obj = args;
 reply.arg1 = msg.arg1;
 reply.sendtotarget();
 }}

<provider android:name="contactsprovider2"
  android:authorities="contacts;com.android.contacts"
  android:readpermission="android.permission.read_contacts"
  android:writepermission="android.permission.write_contacts">
  <path-permission android:pathprefix="/search_suggest_query"
   android:readpermission="android.permission.global_search" />
  <path-permission android:pathpattern="/contacts/.*/photo"   android:readpermission="android.permission.global_search" />
  <grant-uri-permission android:pathpattern=".*" />
 </provider>

protected void onquerycomplete(int token, object cookie, cursor cursor) {
 // check the token and if needed, create the callerinfo object.
 if (mcallerinfo == null) {
  if (cw.event == event_emergency_number) {
  } else if (cw.event == event_voicemail_number) {
  } else {
  mcallerinfo = callerinfo.getcallerinfo(mcontext, mqueryuri, cursor);
  }
  }
 }
 //notify the listener that the query is complete.
 if (cw.listener != null) {
  cw.listener.onquerycomplete(token, cw.cookie, mcallerinfo);
 }
 }
}

//callerinfo.java
public static callerinfo getcallerinfo(context context, uri contactref, cursor cursor) {
 callerinfo info = new callerinfo();
 if (cursor != null) {
 if (cursor.movetofirst()) {
  columnindex = cursor.getcolumnindex(phonelookup.lookup_key);
  if (columnindex != -1) {
  info.lookupkey = cursor.getstring(columnindex);

  }
  info.contactexists = true;
 }
 cursor.close();
 cursor = null;
 }
 info.needupdate = false;
 info.name = normalize(info.name);
 info.contactrefuri = contactref;
 return info;
}