我正在尝试获取所有已更新的android联系人。
我在Firebase上保存了我添加的最后一个联系人ID和上次更新的时间戳
我正在使用下一个函数来检索所有已更新联系人的光标以与Firebase服务器进行比较
right_div = response.xpath('//div[@class="CLASsnAME"]')
right_value = right_div.xpath(
'./h3/span[contains(@title,"VALUE")]'
'/text()'
).get()
但是当我在手机中更改一个联系人时，会返回很多我从未使用过的不相关联系人，并将它们标记为已更改。上一次，当我只是向现有联系人添加电话号码时，我从该游标中获取了50多个已更新的联系人。
Android上发生了什么？？我现在正在尝试同步过去三个月的联系人。为什么这么难？？
这是几乎与您的另一个问题相同的问题，答案相同：When deleting a contact on android,other random contacts id's being changed
您对无法确定的联系人ID进行了一些假设-没有人保证联系人ID是递增的，也没有人保证联系人ID稳定，实际上它们绝对不是。
您可以在应用运行时使用查询的联系人ID，极少的机会在几分钟之内即可更改它们，但有时也有可能偶尔更改现有用户的ID。 不仅如此，相同的ID还可以指向今天的某些联系人，而可以指向明天的完全不同的联系人。
如果您将本地联系人的某些副本保留在云中，则应使用以下组合ID来引用联系人： Contacts.CONTACT_ID，Contacts.LOOKUP_KEY，Contacts.DISPLAY_NAME
在此处查看我的答案以获取更多详细信息：How to uniquely identify a contact on ContactsContract.Contacts table
这不是一个完美的解决方案，但这是我们拥有的最好的解决方案
,我已经对该解决方案进行了几天的测试，似乎还可以，但是我认为我需要对其进行更多的测试。如果您使用这种方法，请进行自己的测试，最重要的是，如果我有任何遗漏，请让我知道，不要着急降级。谢谢！
withContext(Dispatchers.IO)暂停任何代码以简化流程batchArray，以避免超过500个限制现在，由于进行实际同步需要所有用户的访问权，因此我在节点中使用了Firebase功能。我创建了2个函数：
这两个函数会将用户与文档中的规范化数字进行比较，如果匹配，则将该用户的uid写入Firestore文档的“ friend_uid”字段中。
请注意，如果您尝试在免费的Firebase计划中使用这些功能，则可能会出现错误。我建议更改为Blaze计划，并将收费限制在几美元。通过更改为Blaze，Google还可以为您提供免费的附加功能，并避免实际付款
到此，同步完成。同步仅需几秒钟
要显示该应用程序用户的所有联系人，请使用“ friend_uid”查询所有不为空的用户联系人。
一些注意事项：
.get(Source.DEFAULT)，在其他时间使用.get(Source.CACHE)。由于这些文档的名称和编号仅由用户修改，因此我相信大多数时候（仍在测试中）将不会有问题一些源代码（仍在测试中，如果有任何错误，请告知我）
private fun getContacts(): Cursor? {
val projection = arrayOf(
ContactsContract.CommonDataKinds.Phone._ID,ContactsContract.CommonDataKinds.Phone.NUMBER,ContactsContract.CommonDataKinds.Phone.NORMALIZED_NUMBER,ContactsContract.CommonDataKinds.Phone.DISPLAY_NAME,ContactsContract.CommonDataKinds.Phone.CONTACT_LAST_UPDATED_TIMESTAMP)
//sort by NORMALIZED_NUMBER to detect duplicates and then by name to keep order and avoiding name change
val sortOrder = ContactsContract.CommonDataKinds.Phone.NORMALIZED_NUMBER + " ASC," +
ContactsContract.CommonDataKinds.Phone.DISPLAY_NAME + " ASC"
return mContentResolver.query(
ContactsContract.CommonDataKinds.Phone.CONTENT_URI,projection,null,sortOrder)
}
private suspend fun syncContactsAsync() = withContext(Dispatchers.IO) {
if (isAnythingChanged() || mFirstRun) {
if (getValues() == Result.SUCCESS) {
myPrintln("values retrieved success")
} else {
myPrintln("values retrieved failed. Aborting.")
return@withContext
}
val cursor: Cursor? = getContacts()
if (cursor == null) {
myPrintln("cursor cannot be null")
mFireContactHashMap.clear()
return@withContext
}
if (cursor.count == 0) {
cursor.close()
mFireContactHashMap.clear()
myPrintln("cursor empty")
return@withContext
}
var contactName: String?
var internalContact: InternalContact?
val batchArray = mutableListOf(FirebaseFirestore.getInstance().batch())
var batchIndex = 0
var batchCount = 0
var normalizedNumber:String?
var prevNumber = ""
var firestoreId: String
while (cursor.moveToNext()) {
normalizedNumber = cursor.getString(COLUMN_UPDATED_NORMALIZED_NUMBER)
if (normalizedNumber == null) {
normalizedNumber = cursor.getString(COLUMN_UPDATED_PHONE_NUMBER)
normalizedNumber = Phone.getParsedPhoneNumber(mDeviceCountryIso,normalizedNumber,mContext)
}
//cursor sorted by normalized numbers so if same as previous,do not check
if (normalizedNumber != prevNumber) {
prevNumber = normalizedNumber
contactName = cursor.getString(COLUMN_UPDATED_DISPLAY_NAME)
internalContact = mFireContactHashMap[normalizedNumber]
//if phone number exists on firestore
if (internalContact != null) {
//if name changed,update in firestore
if (internalContact.name != contactName) {
myPrintln("updating $normalizedNumber from name: ${internalContact.name} to: $contactName")
batchArray[batchIndex].update(
mFireContactRef.document(internalContact.id),FireContact.COLUMN_NAME,contactName)
batchCount++
}
//remove to avoid deletions
mFireContactHashMap.remove(normalizedNumber)
} else {
//New item. Insert
if (normalizedNumber != mUserPhoneNumber) {
myPrintln("adding $normalizedNumber / $contactName")
firestoreId = mFireContactRef.document().id
batchArray[batchIndex].set(mFireContactRef.document(firestoreId),FireContact(firestoreId,-1,contactName,cursor.getString(COLUMN_UPDATED_PHONE_NUMBER),normalizedNumber))
batchCount++
}
}
if (BATCH_HALF_MAX < batchCount ) {
batchArray += FirebaseFirestore.getInstance().batch()
batchCount = 0
batchIndex++
}
}
}
cursor.close()
//Remaining contacts not found on cursor so assumed deleted. Delete from firestore
mFireContactHashMap.forEach { (key,value) ->
myPrintln("deleting ${value.name} / $key")
batchArray[batchIndex].delete(mFireContactRef.document(value.id))
batchCount++
if (BATCH_HALF_MAX < batchCount ) {
batchArray += FirebaseFirestore.getInstance().batch()
batchCount = 0
batchIndex++
}
}
//execute all batches
if ((batchCount > 0) || (batchIndex > 0)) {
myPrintln("committing changes...")
batchArray.forEach { batch ->
batch.commit()
}
} else {
myPrintln("no records to commit")
}
myPrintln("end sync")
mFireContactHashMap.clear()
mPreferenceManager.edit().putLong(PREF_LAST_TIMESTAMP,mLastContactUpdated).apply()
mFirstRun = false
} else {
myPrintln("no change in contacts")
}
}
private suspend fun putAllUserContactsToHashMap() : Result {
var result = Result.FAILED
val batchArray = mutableListOf(FirebaseFirestore.getInstance().batch())
var batchIndex = 0
var batchCount = 0
mFireContactHashMap.clear()
var source = Source.CACHE
if (mFirstRun) {
source = Source.DEFAULT
myPrintln("get contacts via Source.DEFAULT")
} else {
myPrintln("get contacts via Source.CACHE")
}
mFireContactRef.whereEqualTo( FireContact.COLUMN_USER_ID,mUid ).get(source)
.addOnSuccessListener {documents ->
var fireContact : FireContact
for (doc in documents) {
fireContact = doc.toObject(FireContact::class.java)
if (!mFireContactHashMap.containsKey(fireContact.paPho)) {
mFireContactHashMap[fireContact.paPho] = InternalContact(fireContact.na,doc.id)
} else {
myPrintln("duplicate will be removed from firestore: ${fireContact.paPho} / ${fireContact.na} / ${doc.id}")
batchArray[batchIndex].delete(mFireContactRef.document(doc.id))
batchCount++
if (BATCH_HALF_MAX < batchCount) {
batchArray += FirebaseFirestore.getInstance().batch()
batchCount = 0
batchIndex++
}
}
}
result = Result.SUCCESS
}.addOnFailureListener { exception ->
myPrintln("Error getting documents: $exception")
}.await()
//execute all batches
if ((batchCount > 0) || (batchIndex > 0)) {
myPrintln("committing duplicate delete... ")
batchArray.forEach { batch ->
batch.commit()
}
} else {
myPrintln("no duplicates to delete")
}
return result
}