import json,sys,zipfile
sys.path.insert(0,'/www/server/xingyu-im/ops')
from baota_publish_test_users import database,env_values,query
with zipfile.ZipFile('/tmp/xingyu-nearby-distance-20260902-083041.zip') as z:
 profiles=json.loads(z.read('fixture-locations.json'))
expected={p['publicId'] for p in profiles}
conn,_=database(env_values())
try:
 rows=query(conn,"SELECT u.id,u.public_id FROM users u WHERE u.is_test=1 AND u.test_batch=%s AND u.status=1 AND u.deleted_at IS NULL ORDER BY u.id",('cn-adults-20260831-v1',))
 actual={r[1] for r in rows}
 print({'rows':len(rows),'expected':len(expected),'actual':len(actual),'missing':sorted(expected-actual),'extra':sorted(actual-expected)})
finally: conn.close()